From 4f9263aeee1c7e5a87a7ff58d008fb1c47ceed6b Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期日, 28 九月 2025 10:12:19 +0800
Subject: [PATCH] 增加同步引流平台的开关的功能
---
ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java | 22 +++++++++++++---------
1 files changed, 13 insertions(+), 9 deletions(-)
diff --git a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java b/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java
index 954b3ca..5466368 100644
--- a/ruoyi-service/ruoyi-chargingPile/src/main/java/com/ruoyi/chargingPile/service/impl/TChargingPileServiceImpl.java
+++ b/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());
--
Gitblit v1.7.1