工具类优化

admin

2021-02-06 d1f26741bddf6f512d62c0100d42c52be8d37e76

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

@@ -1,46 +1,70 @@
package com.yeshi.fanli.job.order;



import java.util.Date;



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.service.inter.order.OrderProcessService;

import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceOrderService;

import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;

import com.yeshi.fanli.service.manger.order.TeamDividentsManager;

import com.yeshi.fanli.util.TimeUtil;



//团队收益

@Component

public class OrderTeamIncomeJob {



   @Resource

   private TeamDividentsManager teamDividentsManager;



   @Resource

   private TeamDividentsSourceOrderService teamDividentsSourceOrderService;



   @Resource

   private TeamDividentsSourceUserService teamDividentsSourceUserService;



   @Resource

   private OrderProcessService orderProcessService;



   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;

   }



}

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.OrderProcessService;
import com.yeshi.fanli.service.inter.order.dividents.TeamDividentsSourceUserService;
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 OrderTeamIncomeJob {
   @Resource
   private OrderProcessService orderProcessService;

   @Resource
   private TeamEincomeRecordService teamEincomeRecordService;

   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;

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

      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().addFanLiTeamIncomeMsg(new UidDateDTO(uid, preSendTime));
         }
      }
      return ReturnT.SUCCESS;
   }

}