From 6886f3d9f7e9848fd47da92637f28f46554179a7 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Fri, 18 Jun 2021 08:55:41 +0800
Subject: [PATCH] screen-api 增加kafka消费者以及websocket搭建
---
screen-manage/src/main/java/com/moral/api/service/impl/VersionServiceImpl.java | 8 ++++++++
1 files changed, 8 insertions(+), 0 deletions(-)
diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/VersionServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/VersionServiceImpl.java
index d81b12f..780bc84 100644
--- a/screen-manage/src/main/java/com/moral/api/service/impl/VersionServiceImpl.java
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/VersionServiceImpl.java
@@ -8,6 +8,7 @@
import com.moral.api.entity.User;
import com.moral.api.entity.Version;
import com.moral.api.entity.VersionSensorUnit;
+import com.moral.api.mapper.SensorMapper;
import com.moral.api.mapper.VersionMapper;
import com.moral.api.mapper.VersionSensorUnitMapper;
import com.moral.api.pojo.dto.version.VersionDTO;
@@ -41,6 +42,8 @@
VersionMapper versionMapper;
@Autowired
VersionSensorUnitMapper versionSensorUnitMapper;
+ @Autowired
+ SensorMapper sensorMapper;
@Override
public VersionQueryDTO query(VersionQueryForm form) {
@@ -193,6 +196,11 @@
deleteWrapper.eq("version_id", versionId);
deleteWrapper.set("is_delete", Constants.DELETE);
versionSensorUnitMapper.update(null, deleteWrapper);
+ //������������������id������code
+ for (VersionSensorUnit sensorUnit : sensorUnits) {
+ Sensor sensor = sensorMapper.selectById(sensorUnit.getId());
+ sensorUnit.setSensorCode(sensor.getCode());
+ }
//���������������������������������
for (VersionSensorUnit sensorUnit : sensorUnits) {
sensorUnit.setVersionId(versionId);
--
Gitblit v1.8.0