From aa774af6df16ef11e1e34ac5aeed9aae0cb3e8e2 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 09 四月 2020 16:25:03 +0800
Subject: [PATCH] 团队分红完善
---
fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java | 14 ++++----------
1 files changed, 4 insertions(+), 10 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java b/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java
index d9514b7..ce099f2 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java
@@ -10,11 +10,9 @@
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
-import com.yeshi.fanli.dto.order.dividents.UserDividentsDayDTO;
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;
import com.yeshi.fanli.service.manger.order.TeamDividentsManager;
-import com.yeshi.fanli.util.CMQManager;
import com.yeshi.fanli.util.TimeUtil;
//璁㈠崟鍥㈤槦鍒嗙孩
@@ -42,7 +40,7 @@
long count = teamDividentsSourceOrderService.countCanSendUidByPreSendTime(preSendTime);
int pageSize = 500;
- int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize);
+ int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);
for (int i = 0; i < totalPage; i++) {
List<Long> list = teamDividentsSourceOrderService.listCanSendUidByPreSendTime(preSendTime, i + 1, pageSize);
for (Long uid : list) {
@@ -68,13 +66,9 @@
targetUidList.addAll(uidList);
}
- for (Long uid : targetUidList)
- CMQManager.getInstance().addTeamDividentsMsg(new UserDividentsDayDTO(uid, day));
+ // for (Long uid : targetUidList)
+ // CMQManager.getInstance().addTeamDividentsMsg(new
+ // UserDividentsDayDTO(uid, day));
}
-
-
-
-
-
}
--
Gitblit v1.8.0