From 70ebe043e6b62756be9e257fe954c747d46568b9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 16 九月 2022 19:00:59 +0800
Subject: [PATCH] 商品ID字符串化
---
fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamIncomeJob.java | 7 ++++++-
1 files changed, 6 insertions(+), 1 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamIncomeJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamIncomeJob.java
index 5bd67f2..a482858 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamIncomeJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamIncomeJob.java
@@ -6,6 +6,8 @@
import javax.annotation.Resource;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import com.xxl.job.core.biz.model.ReturnT;
@@ -23,6 +25,7 @@
//鍥㈤槦鏀剁泭
@Component
public class OrderTeamIncomeJob {
+ Logger orderMoneyLog= LoggerFactory.getLogger("orderMoneyLog");
@Resource
private OrderProcessService orderProcessService;
@@ -55,15 +58,17 @@
typeList.add(TeamEincomeRecord.TYPE_TEAM_SUBSIDY);
long count = teamEincomeRecordService.countCanRecieveUid(preSendTime, typeList);
-
+ orderMoneyLog.info("鍥㈤槦鏀剁泭缁撶畻锛� 鏃ユ湡-{} 鐢ㄦ埛鏁伴噺-{}",day,count);
int pageSize = 500;
int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
for (int i = 0; i < totalPage; i++) {
List<Long> list = teamEincomeRecordService.listCanRecieveUid(preSendTime, typeList, i + 1, pageSize);
for (Long uid : list) {
TeamOrderCMQManager.getInstance().addFanLiTeamIncomeMsg(new UidDateDTO(uid, preSendTime));
+ orderMoneyLog.info("鍥㈤槦鏀剁泭缁撶畻锛� 鏃ユ湡-{} Uid-{}",day,uid);
}
}
+ //TODO 灏嗙孩鍖呴噾棰濅负0鐨勭姸鎬佽缃负宸插埌璐�
return ReturnT.SUCCESS;
}
--
Gitblit v1.8.0