好单库转链支持

admin

2020-06-15 3e4ef41ffacd7f5fda2e81c3810cd11a6375b83c

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

@@ -10,12 +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.service.inter.order.dividents.TeamDividentsSourceOrderService;

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

@@ -24,36 +28,49 @@
   @Resource

   private TeamDividentsManager teamDividentsManager;





   @Resource

   private TeamDividentsSourceOrderService teamDividentsSourceOrderService;

   private TeamDividentsSourceOrderUserMapService teamDividentsSourceOrderUserMapService;



   @Resource

   private TeamDividentsSourceUserService teamDividentsSourceUserService;



   @Resource

   private TeamEincomeManager teamEincomeManager;



   @Resource

   private TeamEincomeRecordService teamEincomeRecordService;



   public OrderTeamDividentsJob() {



   }



   // 开始分红，每月25号执行

   @XxlJob("startOrderTeamDividents")

   public ReturnT<String> startDividents(String param) throws Exception {

      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM-dd");

   // 预分红

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

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

      startAddDividentsRecord(preSendTime);

      return ReturnT.SUCCESS;

   }



   private void startAddDividentsRecord(String day) {

   private void startAddDividentsRecord(Date preSendTime) {

      String day = TimeUtil.getGernalTime(preSendTime.getTime(), "yyyy-MM-dd");

      if (!teamDividentsManager.isSourceUserComupteFinish(day))

         return;

      // 统计资金

@@ -69,12 +86,32 @@
      }



      for (Long uid : targetUidList)

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

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

   }

	
	
	
	
	


   @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_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 + 1, pageSize);

         for (Long uid : list) {

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

         }

      }

      return ReturnT.SUCCESS;

   }



}