代理新功能完善

admin

2024-07-26 c0fa314702c6bb19b0c8975dfaee8e39d1896844

 src/main/java/com/taoke/autopay/task/KeyOrderDistributeTask.java

@@ -4,6 +4,7 @@
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;
@@ -28,7 +29,7 @@
            List<KeyOrder> results = keyOrderService.listNotDistributed(1, 20);
            if (results != null) {
                for (KeyOrder order : results) {
                    if (order.getDistributeClientUid() == null) {
                    if (order.getDistributeClientUid() != null) {
                        continue;
                    }
                    Long uid = keyOrderService.getCanDistributeUid();
@@ -103,4 +104,21 @@
        }
    }


    @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();
    }

}