jiazhizhong/crmeb_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

注释任务开启日志

Browse Source
This commit is contained in:
张乐
2020-09-17 17:16:32 +08:00
parent 2974dce33b
commit 84bc747af1
12 changed files with 12 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
crmeb/src/main/java/com/zbkj/crmeb/task/cloud/AsyncCloud.java
View File

@@ -1,6 +1,5 @@
package com.zbkj.crmeb.task.cloud; package com.zbkj.crmeb.task.cloud;
import com.utils.DateUtil;
import com.zbkj.crmeb.system.service.SystemAttachmentService; import com.zbkj.crmeb.system.service.SystemAttachmentService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -23,7 +22,7 @@ public class AsyncCloud {
@Scheduled(fixedDelay = 1000 * 5L) //5秒钟同步一次数据 @Scheduled(fixedDelay = 1000 * 5L) //5秒钟同步一次数据
public void init(){ 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 { try {
systemAttachmentService.async(); systemAttachmentService.async();

2
crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCancelByUser.java
View File

@@ -24,7 +24,7 @@ public class OrderCancelByUser {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
orderTaskService.cancelByUser(); orderTaskService.cancelByUser();

2
crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderCompleteByUser.java
View File

@@ -23,7 +23,7 @@ public class OrderCompleteByUser {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
orderTaskService.complete(); orderTaskService.complete();

2
crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderDeleteByUser.java
View File

@@ -23,7 +23,7 @@ public class OrderDeleteByUser {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
orderTaskService.deleteByUser(); orderTaskService.deleteByUser();

3
crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderRefundByUser.java
View File

@@ -1,6 +1,5 @@
package com.zbkj.crmeb.task.order; package com.zbkj.crmeb.task.order;
import com.utils.DateUtil;
import com.zbkj.crmeb.store.service.OrderTaskService; import com.zbkj.crmeb.store.service.OrderTaskService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -23,7 +22,7 @@ public class OrderRefundByUser {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
orderTaskService.refundApply(); orderTaskService.refundApply();

2
crmeb/src/main/java/com/zbkj/crmeb/task/order/OrderTakeByUser.java
View File

@@ -23,7 +23,7 @@ public class OrderTakeByUser {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
orderTaskService.takeByUser(); orderTaskService.takeByUser();

2
crmeb/src/main/java/com/zbkj/crmeb/task/product/ProductStock.java
View File

@@ -32,7 +32,7 @@ public class ProductStock {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
storeProductService.consumeProductStock(); storeProductService.consumeProductStock();

3
crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSend.java
View File

@@ -1,6 +1,5 @@
package com.zbkj.crmeb.task.sms; package com.zbkj.crmeb.task.sms;
import com.utils.DateUtil;
import com.zbkj.crmeb.sms.service.SmsService; import com.zbkj.crmeb.sms.service.SmsService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -28,7 +27,7 @@ public class AsyncSmsSend {
@Scheduled(fixedDelay = 1000 * 5L) //5秒同步一次数据 @Scheduled(fixedDelay = 1000 * 5L) //5秒同步一次数据
public void init(){ 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 { try {
smsService.consume(); smsService.consume();

5
crmeb/src/main/java/com/zbkj/crmeb/task/sms/AsyncSmsSendResult.java
View File

@@ -1,8 +1,5 @@
package com.zbkj.crmeb.task.sms; 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.SmsRecordService;
import com.zbkj.crmeb.sms.service.SmsService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@@ -29,7 +26,7 @@ public class AsyncSmsSendResult {
@Scheduled(fixedDelay = 1000 * 60L) // todo 后面更改为 一分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) // todo 后面更改为 一分钟同步一次数据
public void init(){ 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 { try {
smsRecordsService.consumeSmsStatus(); smsRecordsService.consumeSmsStatus();

3
crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempList.java
View File

@@ -1,6 +1,5 @@
package com.zbkj.crmeb.task.wechat; package com.zbkj.crmeb.task.wechat;
import com.utils.DateUtil;
import com.zbkj.crmeb.wechat.service.WechatProgramPublicTempService; import com.zbkj.crmeb.wechat.service.WechatProgramPublicTempService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -27,7 +26,7 @@ public class AsyncWeChatProgramTempList {
@Scheduled(fixedDelay = 1000L * 60 * 60 * 24) //1天同步一次数据 @Scheduled(fixedDelay = 1000L * 60 * 60 * 24) //1天同步一次数据
public void init(){ 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 { try {
if(asyncWeChatProgramTempList){ if(asyncWeChatProgramTempList){
wechatProgramPublicTempService.async(); wechatProgramPublicTempService.async();

3
crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatProgramTempMessage.java
View File

@@ -1,6 +1,5 @@
package com.zbkj.crmeb.task.wechat; package com.zbkj.crmeb.task.wechat;
import com.utils.DateUtil;
import com.zbkj.crmeb.wechat.service.TemplateMessageService; import com.zbkj.crmeb.wechat.service.TemplateMessageService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -23,7 +22,7 @@ public class AsyncWeChatProgramTempMessage {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
templateMessageService.consumeProgram(); templateMessageService.consumeProgram();

3
crmeb/src/main/java/com/zbkj/crmeb/task/wechat/AsyncWeChatPublicTempMessage.java
View File

@@ -1,6 +1,5 @@
package com.zbkj.crmeb.task.wechat; package com.zbkj.crmeb.task.wechat;
import com.utils.DateUtil;
import com.zbkj.crmeb.wechat.service.TemplateMessageService; import com.zbkj.crmeb.wechat.service.TemplateMessageService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@@ -23,7 +22,7 @@ public class AsyncWeChatPublicTempMessage {
@Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据 @Scheduled(fixedDelay = 1000 * 60L) //1分钟同步一次数据
public void init(){ 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 { try {
templateMessageService.consumePublic(); templateMessageService.consumePublic();