新增加成都监管数据对接

Pu Zhibing

2025-11-27 ee90d67775ec0926eb2e6ab4632a10ab0c461b7d

 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/util/task/TaskUtil.java

@@ -20,11 +20,13 @@
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.redis.service.RedisService;
import com.ruoyi.integration.api.feignClient.ChargingMessageClient;
import com.ruoyi.integration.api.feignClient.ChengDuJianGuanClient;
import com.ruoyi.integration.api.feignClient.TCECClient;
import com.ruoyi.integration.api.feignClient.UploadRealTimeMonitoringDataClient;
import com.ruoyi.integration.api.model.TransactionRecord;
import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData;
import com.ruoyi.integration.api.vo.ChargingOrderVo;
import com.ruoyi.integration.api.vo.NotificationConnectorChargeStatusVo;
import com.ruoyi.order.api.model.*;
import com.ruoyi.order.api.vo.AccountingStrategyDetailOrderVo;
import com.ruoyi.order.api.vo.TransactionRecordMessageVO;
@@ -63,6 +65,9 @@
import java.time.format.DateTimeFormatter;
import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

/**
@@ -129,6 +134,9 @@

    @Resource
    private ITChargingOrderSummaryDataService chargingOrderSummaryDataService;

    @Resource
    private ChengDuJianGuanClient chengDuJianGuanClient;


    //十分钟循环执行的定时任务
@@ -620,6 +628,17 @@
            if (2 == order.getOrderSource() && 1 == site.getIsOpenSynchronization()) {
                tcecClient.pushChargingGunStatus(chargingGun.getFullNumber(), 2);
            }
            ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.SECONDS, new LinkedBlockingDeque<>());
            TChargingOrder finalOrder = order;
            threadPoolExecutor.execute(()->{
                //推送成都监管
                NotificationConnectorChargeStatusVo statusVo = new NotificationConnectorChargeStatusVo();
                statusVo.setOrderCode(finalOrder.getCode());
                statusVo.setChargingGunId(finalOrder.getChargingGunId());
                chengDuJianGuanClient.notificationConnectorChargeStatus(statusVo);
                chengDuJianGuanClient.notificationOrderInfo(statusVo);
            });


            //添加积分
            if (1 == order.getOrderSource()) {