From 80f7eaf4e6aaedf5fefc0587a28d67c9c9a55931 Mon Sep 17 00:00:00 2001
From: xuhy <3313886187@qq.com>
Date: 星期五, 25 十月 2024 20:15:31 +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 5a8e7ee..437fb00 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
@@ -590,15 +590,19 @@
 		if(datas.size() > 0){
 			for (TChargingPile data : datas) {
 				if(data.getStatus() == 1){
-					TFaultMessage faultMessage = new TFaultMessage();
-					faultMessage.setSiteId(data.getSiteId());
-					faultMessage.setChargingPileId(data.getId());
-					faultMessage.setStatus(1);
-					faultMessage.setDownTime(LocalDateTime.now());
-					faultMessage.setCreateTime(LocalDateTime.now());
-					faultMessage.setDelFlag(false);
-					faultMessage.setContent("设备离线");
-					faultMessageService.save(faultMessage);
+					TFaultMessage faultMessage = faultMessageService.getOne(new LambdaQueryWrapper<TFaultMessage>().eq(TFaultMessage::getChargingPileId, data.getId())
+							.eq(TFaultMessage::getStatus, 1).eq(TFaultMessage::getDelFlag, 0).isNull(TFaultMessage::getEndTime));
+					if(null == faultMessage){
+						faultMessage = new TFaultMessage();
+						faultMessage.setSiteId(data.getSiteId());
+						faultMessage.setChargingPileId(data.getId());
+						faultMessage.setStatus(1);
+						faultMessage.setDownTime(LocalDateTime.now());
+						faultMessage.setCreateTime(LocalDateTime.now());
+						faultMessage.setDelFlag(false);
+						faultMessage.setContent("设备离线");
+						faultMessageService.save(faultMessage);
+					}
 				}
 			}
 			this.updateBatchById(datas);

--
Gitblit v1.7.1