From df99e46312fdd5ee830f1451e478f6658e09f9ed Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期一, 16 十二月 2024 13:41:41 +0800
Subject: [PATCH] 导出测点数据 修改

---
 iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java |    5 +++++
 1 files changed, 5 insertions(+), 0 deletions(-)

diff --git a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java
index 86304da..53c8b35 100644
--- a/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java
+++ b/iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/point/service/impl/DaPointServiceImpl.java
@@ -64,6 +64,9 @@
     @Resource
     private ChannelSourceService channelSourceService;
 
+    @Resource
+    private DaPointCollectStatusService daPointCollectStatusService;
+
     private static Map<String, DaPointDTO> pointIdMap = new ConcurrentHashMap<>();
 
     private static Map<String, DaPointDTO> pointNoMap = new ConcurrentHashMap<>();
@@ -182,6 +185,7 @@
         daPointEntity.setCreateTime(new Date());
         daPointDao.insert(daPointEntity);
 
+        daPointCollectStatusService.add(daPointEntity.getPointNo());
         // 清空缓存
         clearCache();
     }
@@ -417,6 +421,7 @@
                 }
 
                 daPointDao.insert(daPointEntity);
+                daPointCollectStatusService.add(daPointEntity.getPointNo());
                 respVO.getCreatePointnames().add(importPoint.getPointName());
                 return;
             }

--
Gitblit v1.9.3