| | |
|---|
| | | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | @Resource |
|---|
| | | private TeamEincomeRecordService teamEincomeRecordService; |
|---|
| | | |
|---|
| | | @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"; |
|---|
| | | if(!StringUtil.isNullOrEmpty(param)){ |
|---|
| | | day=param; |
|---|
| | | } |
|---|
| | | Date preSendTime = new Date(TimeUtil.convertToTimeTemp(day, "yyyy-MM-dd")); |
|---|
| | | orderProcessService.fanliPreInvaite(preSendTime); |
|---|
| | | return ReturnT.SUCCESS; |
|---|
| | |
|---|
| | | 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)); |
|---|
| | | teamOrderCMQManager.addFanLiTeamIncomeMsg(new UidDateDTO(uid, preSendTime)); |
|---|
| | | orderMoneyLog.info("团队收益结算： 日期-{} Uid-{}", day, uid); |
|---|
| | | } |
|---|
| | | } |
|---|
