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