好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

 fanli/src/main/java/com/yeshi/fanli/job/order/OrderTeamDividentsJob.java

@@ -10,15 +10,16 @@


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.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.CMQManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.cmq.order.TeamOrderCMQManager;



//订单团队分红

@Component

@@ -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);

@@ -79,26 +86,29 @@
      }



      for (Long uid : targetUidList)

         CMQManager.getInstance().addTeamDividentsMsg(new UserDividentsDayDTO(uid, preSendTime));

         TeamOrderCMQManager.getInstance().addTeamDividentsPreMsg(new UidDateDTO(uid, preSendTime));

   }



   @XxlJob("addTeamIncomeTOUserAccountHandler")

   @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<>();

      typeList.add(TeamEincomeRecord.TYPE_TEAM_REWARD);

      typeList.add(TeamEincomeRecord.TYPE_TEAM_SUBSIDY);

      typeList.add(TeamEincomeRecord.TYPE_TEAM_DIVIDENTS);



      long count = teamEincomeRecordService.countCanRecieveUid(preSendTime, typeList);



      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));

         }

      }

      return ReturnT.SUCCESS;