package com.taoke.autopay.task;
|
|
import com.taoke.autopay.dao.KeyOrderMapper;
|
import com.taoke.autopay.dto.DYOrderDto;
|
import com.taoke.autopay.entity.KeyOrder;
|
import com.taoke.autopay.exception.KeyOrderException;
|
import com.taoke.autopay.manager.OrderPayFailProcessor;
|
import com.taoke.autopay.service.KeyOrderService;
|
import com.taoke.autopay.utils.StringUtil;
|
import com.taoke.autopay.utils.order.DYOrderApi;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import javax.annotation.Resource;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.List;
|
|
@Configuration
|
@EnableScheduling
|
public class KeyOrderDistributeTask {
|
@Resource
|
private KeyOrderService keyOrderService;
|
|
@Scheduled(cron = "0/5 * * * * ? ")
|
private void distribute() {
|
try {
|
List<KeyOrder> results = keyOrderService.listNotDistributed(1, 20);
|
if (results != null) {
|
for (KeyOrder order : results) {
|
if (order.getDistributeClientUid() != null) {
|
continue;
|
}
|
Long uid = keyOrderService.getCanDistributeUid();
|
if (uid != null) {
|
KeyOrder orderUpdate = new KeyOrder();
|
orderUpdate.setId(order.getId());
|
orderUpdate.setDistributeClientUid(uid);
|
orderUpdate.setDistributeTime(new Date());
|
keyOrderService.update(orderUpdate);
|
}
|
}
|
}
|
} catch (Exception e) {
|
|
}
|
}
|
|
/**
|
* @return void
|
* @author hxh
|
* @description 修正已经处理的订单
|
* @date 17:53 2024/6/20
|
**/
|
@Scheduled(cron = "0/5 * * * * ? ")
|
private void repaireProcessedOrders() {
|
// TODO 待完成
|
KeyOrderMapper.DaoQuery query = new KeyOrderMapper.DaoQuery();
|
// 修正1分钟到1小时的数据之前执行的数据
|
query.maxUpdateTime = new Date(System.currentTimeMillis() - 1000 * 60 * 1L);
|
query.minUpdateTime = new Date(System.currentTimeMillis() - 1000 * 60 * 60L);
|
query.sortList = Arrays.asList(new String[]{"update_time asc"});
|
query.stateList = Arrays.asList(new Integer[]{KeyOrder.STATE_NOT_PAY, KeyOrder.STATE_PAY});
|
query.orderState = DYOrderDto.ORDER_STATUS_NOT_PAY;
|
query.start = 0;
|
query.count = 20;
|
List<KeyOrder> list = keyOrderService.list(query);
|
if (list != null && list.size() > 0) {
|
for (KeyOrder order : list) {
|
// 如果没有拿到订单就不做处理
|
if (StringUtil.isNullOrEmpty(order.getOrderNo())) {
|
continue;
|
}
|
// 查询结果
|
DYOrderDto dto = null;
|
try {
|
dto = DYOrderApi.getOrderDetail(order.getOrderNo());
|
if (dto.getOrder_status() != DYOrderDto.ORDER_STATUS_NOT_PAY) {
|
// 订单不处于尚未付款状态
|
KeyOrder orderUpdate = new KeyOrder();
|
orderUpdate.setId(order.getId());
|
orderUpdate.setOrderState(dto.getOrder_status());
|
orderUpdate.setState(KeyOrder.STATE_PAY);
|
orderUpdate.setStateDesc(dto.getOrder_status_desc());
|
keyOrderService.update(orderUpdate);
|
} else {
|
KeyOrder update = new KeyOrder();
|
update.setId(order.getId());
|
update.setState(KeyOrder.STATE_NOT_PROCESS);
|
update.setStateDesc("重置未分配");
|
update.setOrderState(dto.getOrder_status());
|
keyOrderService.update(update);
|
}
|
} catch (KeyOrderException e) {
|
e.printStackTrace();
|
KeyOrder orderUpdate = new KeyOrder();
|
orderUpdate.setId(order.getId());
|
orderUpdate.setState(KeyOrder.STATE_PAY);
|
orderUpdate.setStateDesc(e.getMessage());
|
keyOrderService.update(orderUpdate);
|
}
|
}
|
}
|
}
|
|
|
@Resource
|
private OrderPayFailProcessor orderPayFailProcessor;
|
|
@Scheduled(cron = "0/5 * * * * ? ")
|
private void processPayFail(){
|
for(int i=0;i<10;i++) {
|
// 一次最多处理10条数据
|
orderPayFailProcessor.processFromQueue();
|
}
|
}
|
|
@Scheduled(cron = "0 0 3 * * ? ")
|
private void clearProcessPayFailCache(){
|
orderPayFailProcessor.clearCacheData();
|
}
|
|
}
|
