package com.yeshi.fanli.job.order;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
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 {
|
Logger orderMoneyLog = LoggerFactory.getLogger("orderMoneyLog");
|
@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";
|
if(!StringUtil.isNullOrEmpty(param)){
|
day=param;
|
}
|
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);
|
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);
|
}
|
}
|
if (count <= 0) {
|
throw new Exception("暂无需要到账的用户");
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
}
|
