淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -6,6 +6,7 @@

import javax.annotation.Resource;

import com.yeshi.fanli.util.mq.rabbit.RabbitmqManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@@ -25,51 +26,59 @@
//团队收益
@Component
public class OrderTeamIncomeJob {
   Logger orderMoneyLog= LoggerFactory.getLogger("orderMoneyLog");
   @Resource
   private OrderProcessService orderProcessService;
    Logger orderMoneyLog = LoggerFactory.getLogger("orderMoneyLog");
    @Resource
    private OrderProcessService orderProcessService;

   @Resource
   private TeamEincomeRecordService teamEincomeRecordService;
    @Resource
    private TeamEincomeRecordService teamEincomeRecordService;

   public OrderTeamIncomeJob() {
    @Resource
    private TeamOrderCMQManager teamOrderCMQManager;

   }
    public OrderTeamIncomeJob() {

   // 预分红
   @XxlJob("startPreOrderTeamIncomeHandler")
   public ReturnT<String> startPreOrderTeamIncome(String param) throws Exception {
      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM") + "-25";
      Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));
      orderProcessService.fanliPreInvaite(preSendTime);
      return ReturnT.SUCCESS;
   }
    }

   @XxlJob("addTeamIncomeTOUserAccountHandler")
   public ReturnT<String> addTeamIncomeTOUserAccount(String param) throws Exception {
      String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM") + "-25";
      if (!StringUtil.isNullOrEmpty(param))
         day = param;
    // 预分红
    @XxlJob("startPreOrderTeamIncomeHandler")
    public ReturnT<String> startPreOrderTeamIncome(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"));
        orderProcessService.fanliPreInvaite(preSendTime);
        return ReturnT.SUCCESS;
    }

      Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));
    @XxlJob("addTeamIncomeTOUserAccountHandler")
    public ReturnT<String> addTeamIncomeTOUserAccount(String param) throws Exception {
        String day = TimeUtil.getGernalTime(System.currentTimeMillis(), "yyyy-MM") + "-25";
        if (!StringUtil.isNullOrEmpty(param))
            day = param;

      List<Integer> typeList = new ArrayList<>();
      typeList.add(TeamEincomeRecord.TYPE_TEAM_REWARD);
      typeList.add(TeamEincomeRecord.TYPE_TEAM_SUBSIDY);
        Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd"));

      long count = teamEincomeRecordService.countCanRecieveUid(preSendTime, typeList);
      orderMoneyLog.info("团队收益结算： 日期-{} 用户数量-{}",day,count);
      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().addFanLiTeamIncomeMsg(new UidDateDTO(uid, preSendTime));
            orderMoneyLog.info("团队收益结算： 日期-{} Uid-{}",day,uid);
         }
      }
      //TODO 将红包金额为0的状态设置为已到账
      return ReturnT.SUCCESS;
   }
        List<Integer> typeList = new ArrayList<>();
        typeList.add(TeamEincomeRecord.TYPE_TEAM_REWARD);
        typeList.add(TeamEincomeRecord.TYPE_TEAM_SUBSIDY);

        long count = teamEincomeRecordService.countCanRecieveUid(preSendTime, typeList);
        orderMoneyLog.info("团队收益结算： 日期-{} 用户数量-{}", day, count);
        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.addFanLiTeamIncomeMsg(new UidDateDTO(uid, preSendTime));
                orderMoneyLog.info("团队收益结算： 日期-{} Uid-{}", day, uid);
            }
        }
        if (count <= 0) {
            throw new Exception("暂无需要到账的用户");
        }
        return ReturnT.SUCCESS;
    }

}