refactor(sales): 添加删除U8C历史数据功能

- 在 SoSaleOutPluginInitializerToB 类中添加删除U8C历史数据的方法
- 在 DeleteU8cDataUtil 类中实现删除U8C历史数据的逻辑
-此功能作为临时程序,在特定环境下执行
This commit is contained in:
liuy 2024-12-19 17:12:10 +08:00
parent 17d42022bf
commit 5fbe2a3642
2 changed files with 9 additions and 1 deletions

View File

@ -8,6 +8,7 @@ import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import com.hzya.frame.base.PluginBaseEntity; import com.hzya.frame.base.PluginBaseEntity;
import com.hzya.frame.beanutil.BeanUtil; import com.hzya.frame.beanutil.BeanUtil;
import com.hzya.frame.deletedata.DeleteU8cDataUtil;
import com.hzya.frame.plugin.lets.constant.ExportConstant; import com.hzya.frame.plugin.lets.constant.ExportConstant;
import com.hzya.frame.plugin.lets.constant.OverallConstant; import com.hzya.frame.plugin.lets.constant.OverallConstant;
import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant; import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant;
@ -76,6 +77,9 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity {
@Autowired @Autowired
private OffsetTimeTime offsetTimeTime; private OffsetTimeTime offsetTimeTime;
@Autowired
private DeleteU8cDataUtil deleteU8cDataUtil;
@Override @Override
public void initialize() { public void initialize() {
logger.info(getPluginLabel() + "執行初始化方法initialize()"); logger.info(getPluginLabel() + "執行初始化方法initialize()");
@ -145,6 +149,10 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity {
} }
} else { } else {
if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals(PROD_FILED)) { if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals(PROD_FILED)) {
//TODO 临时程序,删除U8C历史数据
//TODO 临时程序,删除U8C历史数据
deleteU8cDataUtil.deleteTargetU8cData();
//实时执行每1分钟调度一次 //实时执行每1分钟调度一次
StartAndEndVo startAndEndVo = offsetTimeTime.offsetTime(); StartAndEndVo startAndEndVo = offsetTimeTime.offsetTime();
startImplementByStockTime(startAndEndVo.getStart_time(), startAndEndVo.getEnd_time()); startImplementByStockTime(startAndEndVo.getStart_time(), startAndEndVo.getEnd_time());

View File

@ -33,7 +33,7 @@ public class DeleteU8cDataUtil {
protected Logger logger = LogManager.getLogger(super.getClass()); protected Logger logger = LogManager.getLogger(super.getClass());
public void deleteTarget() { public void deleteTargetU8cData() {
Thread thread = new Thread(new Runnable() { Thread thread = new Thread(new Runnable() {
@Override @Override
public void run() { public void run() {