diff --git a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/sales/SoSaleOutPluginInitializerToB.java b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/sales/SoSaleOutPluginInitializerToB.java index 5fb489db..f50b6800 100644 --- a/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/sales/SoSaleOutPluginInitializerToB.java +++ b/buildpackage/src/main/java/com/hzya/frame/plugin/lets/plugin/sales/SoSaleOutPluginInitializerToB.java @@ -8,6 +8,7 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.hzya.frame.base.PluginBaseEntity; 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.OverallConstant; import com.hzya.frame.plugin.lets.constant.ProfilesActiveConstant; @@ -76,6 +77,9 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity { @Autowired private OffsetTimeTime offsetTimeTime; + @Autowired + private DeleteU8cDataUtil deleteU8cDataUtil; + @Override public void initialize() { logger.info(getPluginLabel() + "執行初始化方法initialize()"); @@ -145,6 +149,10 @@ public class SoSaleOutPluginInitializerToB extends PluginBaseEntity { } } else { if (ProfilesActiveConstant.LETS_PROFILES_ACTIVE.equals(PROD_FILED)) { + //TODO 临时程序,删除U8C历史数据 + //TODO 临时程序,删除U8C历史数据 + deleteU8cDataUtil.deleteTargetU8cData(); + //实时执行,每1分钟调度一次 StartAndEndVo startAndEndVo = offsetTimeTime.offsetTime(); startImplementByStockTime(startAndEndVo.getStart_time(), startAndEndVo.getEnd_time()); diff --git a/service/src/main/java/com/hzya/frame/deletedata/DeleteU8cDataUtil.java b/service/src/main/java/com/hzya/frame/deletedata/DeleteU8cDataUtil.java index 961b7c37..b957069a 100644 --- a/service/src/main/java/com/hzya/frame/deletedata/DeleteU8cDataUtil.java +++ b/service/src/main/java/com/hzya/frame/deletedata/DeleteU8cDataUtil.java @@ -33,7 +33,7 @@ public class DeleteU8cDataUtil { protected Logger logger = LogManager.getLogger(super.getClass()); - public void deleteTarget() { + public void deleteTargetU8cData() { Thread thread = new Thread(new Runnable() { @Override public void run() {