功能完善

admin

2024-06-24 5d3b3b74afd2ac4cf21697fc38367b2f88170e9f

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

@@ -1,12 +1,18 @@
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.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;

@@ -17,7 +23,7 @@
    private KeyOrderService keyOrderService;

    @Scheduled(cron = "0/5 * * * * ? ")
    private void distribute(){
    private void distribute() {
        try {
            List<KeyOrder> results = keyOrderService.listNotDistributed(1, 20);
            if (results != null) {
@@ -35,9 +41,66 @@
                    }
                }
            }
        }catch(Exception e){
        } 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);
                }
            }
        }
    }

}