From 84bc747af14a3c01eefa3aff2a25f56a47cbf7ab Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E4=B9=90?= <419641032@qq.com> Date: Thu, 17 Sep 2020 17:16:32 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E9=87=8A=E4=BB=BB=E5=8A=A1=E5=BC=80?= =?UTF-8?q?=E5=90=AF=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java | 3 +-- .../java/com/zbkj/crmeb/task/order/OrderCancelByUser.java | 2 +- .../java/com/zbkj/crmeb/task/order/OrderCompleteByUser.java | 2 +- .../java/com/zbkj/crmeb/task/order/OrderDeleteByUser.java | 2 +- .../java/com/zbkj/crmeb/task/order/OrderRefundByUser.java | 3 +-- .../main/java/com/zbkj/crmeb/task/order/OrderTakeByUser.java | 2 +- .../main/java/com/zbkj/crmeb/task/product/ProductStock.java | 2 +- .../src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java | 3 +-- .../java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java | 5 +---- .../zbkj/crmeb/task/wechat/AsyncWeChatProgramTempList.java | 3 +-- .../crmeb/task/wechat/AsyncWeChatProgramTempMessage.java | 3 +-- .../zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java | 3 +-- 12 files changed, 12 insertions(+), 21 deletions(-) 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();