淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -1,117 +1,122 @@
package com.yeshi.fanli.job.order;



import java.util.ArrayList;

import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Component;



import com.xxl.job.core.biz.model.ReturnT;

import com.xxl.job.core.handler.annotation.XxlJob;

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

import org.yeshi.utils.TimeUtil;

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



//订单团队分红

@Component

public class OrderTeamDividentsJob {



   @Resource

   private TeamDividentsManager teamDividentsManager;





   @Resource

   private TeamDividentsSourceOrderUserMapService teamDividentsSourceOrderUserMapService;



   @Resource

   private TeamDividentsSourceUserService teamDividentsSourceUserService;



   @Resource

   private TeamEincomeManager teamEincomeManager;



   @Resource

   private TeamEincomeRecordService teamEincomeRecordService;



   public OrderTeamDividentsJob() {



   }



   // 预分红

   @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 = 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 = teamDividentsSourceOrderUserMapService.listCanSendSourceUidByPreSendTime(preSendTime,

               i + 1, pageSize);

         for (Long uid : list) {

            teamDividentsManager.startDividents(uid, preSendTime);

         }

      }

      startAddDividentsRecord(preSendTime);

      return ReturnT.SUCCESS;

   }



   private void startAddDividentsRecord(Date preSendTime) {

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

      if (!teamDividentsManager.isSourceUserComupteFinish(day))

         return;

      // 统计资金

      int pageSize = 500;

      long count = teamDividentsSourceUserService.countTargetUid(day);

      int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);



      List<Long> targetUidList = new ArrayList<>();

      for (int p = 0; p < totalPage; p++) {

         List<Long> uidList = teamDividentsSourceUserService.listTargetUid(day, p + 1, pageSize);

         if (uidList != null && uidList.size() > 0)

            targetUidList.addAll(uidList);

      }



      for (Long uid : targetUidList)

         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;

   }



}

package com.yeshi.fanli.job.order;

import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.annotation.XxlJob;
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.StringUtil;
import com.yeshi.fanli.util.mq.cmq.order.TeamOrderCMQManager;
import org.springframework.stereotype.Component;
import org.yeshi.utils.TimeUtil;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

//订单团队分红
@Component
public class OrderTeamDividentsJob {

   @Resource
   private TeamDividentsManager teamDividentsManager;


   @Resource
   private TeamDividentsSourceOrderUserMapService teamDividentsSourceOrderUserMapService;

   @Resource
   private TeamDividentsSourceUserService teamDividentsSourceUserService;

   @Resource
   private TeamEincomeManager teamEincomeManager;

   @Resource
   private TeamEincomeRecordService teamEincomeRecordService;


   @Resource
   private TeamOrderCMQManager teamOrderCMQManager;

   public OrderTeamDividentsJob() {

   }

   // 预分红
   @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 = 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 = teamDividentsSourceOrderUserMapService.listCanSendSourceUidByPreSendTime(preSendTime,
               i + 1, pageSize);
         for (Long uid : list) {
            teamDividentsManager.startDividents(uid, preSendTime);
         }
      }
      startAddDividentsRecord(preSendTime);
      return ReturnT.SUCCESS;
   }

   private void startAddDividentsRecord(Date preSendTime) {
      String day = TimeUtil.getGernalTime(preSendTime.getTime(), "yyyy-MM-dd");
      if (!teamDividentsManager.isSourceUserComupteFinish(day))
         return;
      // 统计资金
      int pageSize = 500;
      long count = teamDividentsSourceUserService.countTargetUid(day);
      int totalPage = (int) (count % pageSize == 0 ? count / pageSize : count / pageSize + 1);

      List<Long> targetUidList = new ArrayList<>();
      for (int p = 0; p < totalPage; p++) {
         List<Long> uidList = teamDividentsSourceUserService.listTargetUid(day, p + 1, pageSize);
         if (uidList != null && uidList.size() > 0)
            targetUidList.addAll(uidList);
      }

      for (Long uid : targetUidList)
         teamOrderCMQManager.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.addTeamDividentsMsg(new UidDateDTO(uid, preSendTime));
         }
      }
      if (count <= 0) {
         throw new Exception("暂无需要到账的用户");
      }
      return ReturnT.SUCCESS;
   }

}