新增加成都监管数据对接

Pu Zhibing

2025-11-27 ee90d67775ec0926eb2e6ab4632a10ab0c461b7d

 ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java

@@ -54,6 +54,9 @@
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.util.*;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;

/**
@@ -128,6 +131,9 @@

   @Resource
   private AppUserClient appUserClient;

   @Resource
   private ChengDuJianGuanClient chengDuJianGuanClient;
   
   

@@ -211,6 +217,11 @@
         chargingPile.setIotdDeviceId(showDeviceResp.getDeviceId());
      }
      this.save(chargingPile);
      ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.SECONDS, new LinkedBlockingDeque<>());
      threadPoolExecutor.execute(()->{
         //推送成都监管
         chengDuJianGuanClient.notificationStationInfo(chargingPile.getSiteId());
      });
      return AjaxResult.success();
   }
   
@@ -330,6 +341,12 @@
         sendMessageClient.qrCodeDelivery(qrCodeDelivery);
      }
      tcecClient.superviseNotificationStationInfo(chargingPile.getSiteId());

      ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.SECONDS, new LinkedBlockingDeque<>());
      threadPoolExecutor.execute(()->{
         //推送成都监管
         chengDuJianGuanClient.notificationStationInfo(chargingPile.getSiteId());
      });
      return AjaxResult.success();
   }