增加同步引流平台的开关的功能

Pu Zhibing

昨天 4f9263aeee1c7e5a87a7ff58d008fb1c47ceed6b

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

@@ -325,6 +325,8 @@
         qrCodeDelivery.setPrefix_length(code_prefix.length());
         qrCodeDelivery.setCode_prefix(code_prefix);
         qrCodeDelivery.setQr_code(code_prefix + chargingPile.getCode() + chargingGun.getCode());
         qrCodeDelivery.setCreate_time(new Date());
         qrCodeDelivery.setLast_time(new Date());
         sendMessageClient.qrCodeDelivery(qrCodeDelivery);
      }
      tcecClient.superviseNotificationStationInfo(chargingPile.getSiteId());
@@ -711,7 +713,7 @@
      keys.forEach(key -> {
                  Long time = (Long) redisTemplate.opsForHash().get("charging_gun_online", key);
                  if(null != time && System.currentTimeMillis() - time > 300000){
                     log.info("设备编号：{}已离线", key);
                     log.info("设备编号：{} 已离线", key);
                     log.info("间隔时间", System.currentTimeMillis() - time);
                     fullNumbers.add(key.toString());
                  }
@@ -727,13 +729,16 @@
         chargingGun1.setId(chargingGun.getId());
         chargingGun1.setStatus(1);
         chargingGunService.updateById(chargingGun1);
         new Thread(new Runnable() {
            @Override
            public void run() {
               //推送状态给三方平台
               tcecClient.pushChargingGunStatus(chargingGun1.getFullNumber(), chargingGun1.getStatus());
            }
         }).start();
         Site site = siteService.getById(chargingGun.getSiteId());
         if(1 == site.getIsOpenSynchronization()){
            new Thread(new Runnable() {
               @Override
               public void run() {
                  //推送状态给三方平台
                  tcecClient.pushChargingGunStatus(chargingGun.getFullNumber(), 1);
               }
            }).start();
         }
         
         //桩处于正常，桩所属的枪都处于非正常，修改桩状态为异常
         TChargingPile chargingPile = this.getById(chargingGun.getChargingPileId());
@@ -762,7 +767,6 @@
            faultMessageService.save(faultMessage);
            
            // 发送故障短信
            Site site = siteService.getById(faultMessage.getSiteId());
            String siteName = site.getName();
            SendMessageDTO sendMessageDTO = new SendMessageDTO();
            sendMessageDTO.setPhone(site.getPhone());