admin
2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c
fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java
@@ -13,10 +13,11 @@
import com.yeshi.fanli.dto.mq.UidDateDTO;
import com.yeshi.fanli.entity.money.TeamEincomeRecord;
import com.yeshi.fanli.service.inter.money.TeamEincomeRecordService;
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderUserMapService;
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;
import com.yeshi.fanli.service.manger.money.TeamEincomeManager;
import com.yeshi.fanli.service.manger.order.TeamDividentsManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.util.cmq.order.TeamOrderCMQManager;
@@ -27,8 +28,9 @@
   @Resource
   private TeamDividentsManager teamDividentsManager;
   @Resource
   private TeamDividentsSourceOrderService teamDividentsSourceOrderService;
   private TeamDividentsSourceOrderUserMapService teamDividentsSourceOrderUserMapService;
   @Resource
   private TeamDividentsSourceUserService teamDividentsSourceUserService;
@@ -47,15 +49,20 @@
   @XxlJob("startPreOrderTeamDividentsHandler")
   public ReturnT<String> startPreDividents(String param) throws Exception {
      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM") + "-25";
      if (!StringUtil.isNullOrEmpty(param)) {
         day = param;
      }
      Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));
      long count = teamDividentsSourceOrderService.countCanSendUidByPreSendTime(preSendTime);
      long count = teamDividentsSourceOrderUserMapService.countCanSendSourceUidByPreSendTime(preSendTime);
      int pageSize = 500;
      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);
         List<Long> list = teamDividentsSourceOrderUserMapService.listCanSendSourceUidByPreSendTime(preSendTime,
               i + 1, pageSize);
         for (Long uid : list) {
            teamDividentsManager.startDividents(uid);
            teamDividentsManager.startDividents(uid, preSendTime);
         }
      }
      startAddDividentsRecord(preSendTime);
@@ -85,6 +92,10 @@
   @XxlJob("addTeamDividentsTOUserAccountHandler")
   public ReturnT<String> addTeamIncomeTOUserAccount(String param) throws Exception {
      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM") + "-25";
      if (!StringUtil.isNullOrEmpty(param)) {
         day = param;
      }
      Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));
      List<Integer> typeList = new ArrayList<>();
@@ -95,7 +106,7 @@
      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 * pageSize, pageSize);
         List<Long> list = teamEincomeRecordService.listCanRecieveUid(preSendTime, typeList, i + 1, pageSize);
         for (Long uid : list) {
            TeamOrderCMQManager.getInstance().addTeamDividentsMsg(new UidDateDTO(uid, preSendTime));
         }