代理新功能完善

admin

2024-07-27 65aaf1c05bd06cefa82ebc40cc3e01cf4ac233c0

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

}