diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java b/crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java index dcefd7ed..612c1ed9 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java @@ -1,6 +1,5 @@ package com.zbkj.crmeb.task.cloud; -import com.utils.DateUtil; import com.zbkj.crmeb.system.service.SystemAttachmentService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,7 +22,7 @@ public class AsyncCloud { @Scheduled(fixedDelay = 1000 * 5L) //5秒钟同步一次数据 public void init(){ - logger.info("---AsyncCloud task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---AsyncCloud task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { systemAttachmentService.async(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCancelByUser.java b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCancelByUser.java index 1708d466..33e636a1 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCancelByUser.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCancelByUser.java @@ -24,7 +24,7 @@ public class OrderCancelByUser { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---OrderRefundByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---OrderRefundByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { orderTaskService.cancelByUser(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCompleteByUser.java b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCompleteByUser.java index 3ec182c1..760252dd 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCompleteByUser.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCompleteByUser.java @@ -23,7 +23,7 @@ public class OrderCompleteByUser { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---OrderCompleteByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---OrderCompleteByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { orderTaskService.complete(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderDeleteByUser.java b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderDeleteByUser.java index 9cda4d15..a9e86b14 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderDeleteByUser.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderDeleteByUser.java @@ -23,7 +23,7 @@ public class OrderDeleteByUser { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---OrderDeleteByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---OrderDeleteByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { orderTaskService.deleteByUser(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderRefundByUser.java b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderRefundByUser.java index 109ee479..8d3656e3 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderRefundByUser.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderRefundByUser.java @@ -1,6 +1,5 @@ package com.zbkj.crmeb.task.order; -import com.utils.DateUtil; import com.zbkj.crmeb.store.service.OrderTaskService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,7 +22,7 @@ public class OrderRefundByUser { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---OrderRefundByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---OrderRefundByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { orderTaskService.refundApply(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderTakeByUser.java b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderTakeByUser.java index 82c26655..4c0814a3 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderTakeByUser.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderTakeByUser.java @@ -23,7 +23,7 @@ public class OrderTakeByUser { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---OrderTakeByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---OrderTakeByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { orderTaskService.takeByUser(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/product/ProductStock.java b/crmeb/src/main/java/com/zbkj/crmeb/task/product/ProductStock.java index 567dae89..a3847d08 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/product/ProductStock.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/product/ProductStock.java @@ -32,7 +32,7 @@ public class ProductStock { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---OrderTakeByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); +// logger.info("---OrderTakeByUser task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDateTime()); try { storeProductService.consumeProductStock(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java index 3e6ec932..9800404f 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java @@ -1,6 +1,5 @@ package com.zbkj.crmeb.task.sms; -import com.utils.DateUtil; import com.zbkj.crmeb.sms.service.SmsService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -28,7 +27,7 @@ public class AsyncSmsSend { @Scheduled(fixedDelay = 1000 * 5L) //5秒同步一次数据 public void init(){ - logger.info("---AsyncSmsSend task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); +// logger.info("---AsyncSmsSend task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); try { smsService.consume(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java index 6c517b97..90c89167 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java @@ -1,8 +1,5 @@ package com.zbkj.crmeb.task.sms; -import com.utils.DateUtil; -import com.zbkj.crmeb.sms.model.SmsRecord; import com.zbkj.crmeb.sms.service.SmsRecordService; -import com.zbkj.crmeb.sms.service.SmsService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -29,7 +26,7 @@ public class AsyncSmsSendResult { @Scheduled(fixedDelay = 1000 * 60L) // todo 后面更改为 一分钟同步一次数据 public void init(){ - logger.info("---AsyncSmsResult task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); +// logger.info("---AsyncSmsResult task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); try { smsRecordsService.consumeSmsStatus(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempList.java b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempList.java index 19b75636..d60563c1 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempList.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempList.java @@ -1,6 +1,5 @@ package com.zbkj.crmeb.task.wechat; -import com.utils.DateUtil; import com.zbkj.crmeb.wechat.service.WechatProgramPublicTempService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -27,7 +26,7 @@ public class AsyncWeChatProgramTempList { @Scheduled(fixedDelay = 1000L * 60 * 60 * 24) //1天同步一次数据 public void init(){ - logger.info("---AsyncWeChatProgramTempList task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); +// logger.info("---AsyncWeChatProgramTempList task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); try { if(asyncWeChatProgramTempList){ wechatProgramPublicTempService.async(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java index d60fd7c5..786932a9 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java @@ -1,6 +1,5 @@ package com.zbkj.crmeb.task.wechat; -import com.utils.DateUtil; import com.zbkj.crmeb.wechat.service.TemplateMessageService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,7 +22,7 @@ public class AsyncWeChatProgramTempMessage { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---AsyncWeChatProgramTempMessage task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); +// logger.info("---AsyncWeChatProgramTempMessage task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); try { templateMessageService.consumeProgram(); diff --git a/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java index b0a26ca7..d00165ee 100644 --- a/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java +++ b/crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java @@ -1,6 +1,5 @@ package com.zbkj.crmeb.task.wechat; -import com.utils.DateUtil; import com.zbkj.crmeb.wechat.service.TemplateMessageService; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,7 +22,7 @@ public class AsyncWeChatPublicTempMessage { @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 public void init(){ - logger.info("---AsyncWeChatPublicTempMessage task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); +// logger.info("---AsyncWeChatPublicTempMessage task------produce Data with fixed rate task: Execution Time - {}", DateUtil.nowDate()); try { templateMessageService.consumePublic();