From feb30c71dde01aea878f53ad486ab50b8e51f686 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Thu, 6 Jul 2023 11:32:25 +0800
Subject: [PATCH] =?UTF-8?q?=E6=A8=A1=E6=8B=9F=E7=9B=B4=E8=BF=9E=E8=AE=BE?=
=?UTF-8?q?=E5=A4=87=E5=9C=A8APP=E6=B3=A8=E5=86=8C=E6=8E=A5=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
iot-access/access-api/pom.xml | 22 +-
.../{param => annotation}/ParamName.java | 2 +-
.../njcn/access/enums/AccessResponseEnum.java | 12 +-
.../com/njcn/access/param/DevAccessParam.java | 71 ++
.../com/njcn/access/pojo/dto/AccessDto.java | 2 +-
.../com/njcn/access/pojo/dto/DevCfgDto.java | 3 +-
.../com/njcn/access/pojo/dto/ModelDto.java | 44 +-
.../ReqAndResDto.java} | 10 +-
.../com/njcn/access/pojo/dto/data/StsDto.java | 9 -
.../njcn/access/pojo/dto/devModel/ApfDto.java | 45 ++
.../njcn/access/pojo/dto/devModel/CfgDto.java | 63 --
.../access/pojo/dto/devModel/ClDevDto.java | 2 +-
.../pojo/dto/devModel/DevModDataListDto.java | 77 ---
.../access/pojo/dto/devModel/DevModDto.java | 44 --
.../dto/devModel/NetDevModDataListDto.java | 27 -
.../pojo/dto/devModel/NetDevModDto.java | 35 -
.../access/pojo/dto/devModel/TemplateDto.java | 91 ++-
.../access/pojo/dto/heart/HeartBeatDto.java | 2 +-
.../access/pojo/{ => param}/MessageParam.java | 2 +-
.../java/com/njcn/access/pojo/po/CsAlmPO.java | 62 --
.../java/com/njcn/access/pojo/po/CsBmdPO.java | 46 --
.../com/njcn/access/pojo/po/CsCtrlPO.java | 99 ---
.../java/com/njcn/access/pojo/po/CsDiPO.java | 83 ---
.../java/com/njcn/access/pojo/po/CsDoPO.java | 93 ---
.../com/njcn/access/pojo/po/CsEpdPqdPO.java | 61 --
.../java/com/njcn/access/pojo/po/CsEvtPO.java | 85 ---
.../com/njcn/access/pojo/po/CsLineModel.java | 62 ++
.../com/njcn/access/pojo/po/CsParmPO.java | 98 ---
.../java/com/njcn/access/pojo/po/CsSetPO.java | 103 ---
.../java/com/njcn/access/pojo/po/CsStsPO.java | 78 ---
iot-access/access-boot/pom.xml | 38 +-
.../njcn/access/AccessBootApplication.java | 2 -
.../com/njcn/access/config/SwaggerConfig.java | 91 ---
.../access/controller/AccessController.java | 33 -
...troller.java => CsDevModelController.java} | 30 +-
.../access/controller/CsDeviceController.java | 65 ++
...roller.java => CsLineModelController.java} | 18 +-
.../access/controller/KafkaController.java | 108 +--
.../access/controller/RegisterController.java | 51 --
.../access/controller/TopicController.java | 48 --
.../access/handler/MqttMessageHandler.java | 182 +++--
.../com/njcn/access/mapper/CsAlmMapper.java | 16 -
.../com/njcn/access/mapper/CsBmdMapper.java | 16 -
.../com/njcn/access/mapper/CsCtrlMapper.java | 16 -
.../njcn/access/mapper/CsDataArrayMapper.java | 16 -
.../njcn/access/mapper/CsDataSetMapper.java | 16 -
.../com/njcn/access/mapper/CsDiMapper.java | 16 -
.../com/njcn/access/mapper/CsDoMapper.java | 16 -
.../njcn/access/mapper/CsEpdPqdMapper.java | 16 -
.../com/njcn/access/mapper/CsEvtMapper.java | 16 -
.../njcn/access/mapper/CsEvtParmMapper.java | 16 -
.../njcn/access/mapper/CsLineModelMapper.java | 16 +
.../njcn/access/mapper/CsNetDevMapper.java | 16 -
.../com/njcn/access/mapper/CsParmMapper.java | 17 -
.../njcn/access/mapper/CsPrjInfoMapper.java | 16 -
.../com/njcn/access/mapper/CsSetMapper.java | 16 -
.../njcn/access/mapper/CsSoftInfoMapper.java | 16 -
.../com/njcn/access/mapper/CsStsMapper.java | 16 -
.../com/njcn/access/mapper/CsTopicMapper.java | 18 -
.../access/mapper/mapping/CsEpdPqdMapper.xml | 6 -
.../njcn/access/service/IAccessService.java | 16 -
.../njcn/access/service/ICsAlmService.java | 19 -
.../njcn/access/service/ICsBmdService.java | 21 -
.../njcn/access/service/ICsCtrlService.java | 19 -
.../access/service/ICsDataArrayService.java | 19 -
.../access/service/ICsDataSetService.java | 17 -
.../access/service/ICsDevModelService.java | 21 +
.../njcn/access/service/ICsDeviceService.java | 33 +
.../com/njcn/access/service/ICsDiService.java | 19 -
.../com/njcn/access/service/ICsDoService.java | 19 -
.../njcn/access/service/ICsEpdPqdService.java | 20 -
.../access/service/ICsEvtParmService.java | 19 -
.../njcn/access/service/ICsEvtService.java | 20 -
.../access/service/ICsLineModelService.java | 24 +
.../njcn/access/service/ICsNetDevService.java | 17 -
.../njcn/access/service/ICsParmService.java | 19 -
.../access/service/ICsPrjInfoService.java | 18 -
.../njcn/access/service/ICsSetService.java | 19 -
.../access/service/ICsSoftInfoService.java | 17 -
.../njcn/access/service/ICsStsService.java | 19 -
.../njcn/access/service/ICsTopicService.java | 22 -
.../access/service/IDataArrayService.java | 7 -
.../njcn/access/service/IDataSetService.java | 9 -
.../njcn/access/service/IDevModelService.java | 18 -
.../service/impl/CsDevModelServiceImpl.java | 44 ++
.../service/impl/CsDeviceServiceImpl.java | 212 ++++++
.../service/impl/CsLineModelServiceImpl.java | 27 +
.../serviceImpl/AccessServiceImpl.java | 105 ---
.../service/serviceImpl/CsAlmServiceImpl.java | 27 -
.../service/serviceImpl/CsBmdServiceImpl.java | 26 -
.../serviceImpl/CsCtrlServiceImpl.java | 26 -
.../serviceImpl/CsDataArrayServiceImpl.java | 26 -
.../serviceImpl/CsDataSetServiceImpl.java | 25 -
.../service/serviceImpl/CsDiServiceImpl.java | 27 -
.../service/serviceImpl/CsDoServiceImpl.java | 26 -
.../serviceImpl/CsEpdPqdServiceImpl.java | 41 --
.../serviceImpl/CsEvtParmServiceImpl.java | 26 -
.../service/serviceImpl/CsEvtServiceImpl.java | 40 --
.../serviceImpl/CsNetDevServiceImpl.java | 39 --
.../serviceImpl/CsParmServiceImpl.java | 27 -
.../serviceImpl/CsPrjInfoServiceImpl.java | 25 -
.../service/serviceImpl/CsSetServiceImpl.java | 27 -
.../serviceImpl/CsSoftInfoServiceImpl.java | 25 -
.../service/serviceImpl/CsStsServiceImpl.java | 27 -
.../serviceImpl/CsTopicServiceImpl.java | 61 --
.../serviceImpl/DataArrayServiceImpl.java | 18 -
.../serviceImpl/DataSetServiceImpl.java | 19 -
.../serviceImpl/DevModelServiceImpl.java | 638 ------------------
.../src/main/resources/bootstrap.yml | 2 +-
iot-access/pom.xml | 133 +---
pom.xml | 5 -
111 files changed, 968 insertions(+), 3603 deletions(-)
rename iot-access/access-api/src/main/java/com/njcn/access/{param => annotation}/ParamName.java (91%)
create mode 100644 iot-access/access-api/src/main/java/com/njcn/access/param/DevAccessParam.java
rename iot-access/access-api/src/main/java/com/njcn/access/pojo/{param/ReqAndResParam.java => dto/ReqAndResDto.java} (89%)
create mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/devModel/ApfDto.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/devModel/CfgDto.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/devModel/DevModDataListDto.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/devModel/DevModDto.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/devModel/NetDevModDataListDto.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/devModel/NetDevModDto.java
rename iot-access/access-api/src/main/java/com/njcn/access/pojo/{ => param}/MessageParam.java (84%)
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsAlmPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsBmdPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsCtrlPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsDiPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsDoPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsEpdPqdPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsEvtPO.java
create mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsLineModel.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsParmPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsSetPO.java
delete mode 100644 iot-access/access-api/src/main/java/com/njcn/access/pojo/po/CsStsPO.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/config/SwaggerConfig.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/controller/AccessController.java
rename iot-access/access-boot/src/main/java/com/njcn/access/controller/{DevModelController.java => CsDevModelController.java} (59%)
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/controller/CsDeviceController.java
rename iot-access/access-boot/src/main/java/com/njcn/access/controller/{CsNetDevController.java => CsLineModelController.java} (59%)
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/controller/RegisterController.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/controller/TopicController.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsAlmMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsBmdMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsCtrlMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsDataArrayMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsDataSetMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsDiMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsDoMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsEpdPqdMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsEvtMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsEvtParmMapper.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsLineModelMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsNetDevMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsParmMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsPrjInfoMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsSetMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsSoftInfoMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsStsMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/CsTopicMapper.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/mapper/mapping/CsEpdPqdMapper.xml
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/IAccessService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsAlmService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsBmdService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsCtrlService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsDataArrayService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsDataSetService.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsDevModelService.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsDeviceService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsDiService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsDoService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsEpdPqdService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsEvtParmService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsEvtService.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsLineModelService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsNetDevService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsParmService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsPrjInfoService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsSetService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsSoftInfoService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsStsService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/ICsTopicService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/IDataArrayService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/IDataSetService.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/IDevModelService.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDevModelServiceImpl.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsDeviceServiceImpl.java
create mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/impl/CsLineModelServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/AccessServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsAlmServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsBmdServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsCtrlServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsDataArrayServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsDataSetServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsDiServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsDoServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsEpdPqdServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsEvtParmServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsEvtServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsNetDevServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsParmServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsPrjInfoServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsSetServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsSoftInfoServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsStsServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/CsTopicServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/DataArrayServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/DataSetServiceImpl.java
delete mode 100644 iot-access/access-boot/src/main/java/com/njcn/access/service/serviceImpl/DevModelServiceImpl.java
diff --git a/iot-access/access-api/pom.xml b/iot-access/access-api/pom.xml
index 8426020..89d2f34 100644
--- a/iot-access/access-api/pom.xml
+++ b/iot-access/access-api/pom.xml
@@ -21,10 +21,24 @@
- junit
- junit
- 4.11
- test
+ com.njcn
+ common-core
+ ${project.version}
+
+
+ com.njcn
+ common-db
+ ${project.version}
+
+
+ com.njcn
+ common-microservice
+ ${project.version}
+
+
+ com.njcn
+ common-poi
+ ${project.version}
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/param/ParamName.java b/iot-access/access-api/src/main/java/com/njcn/access/annotation/ParamName.java
similarity index 91%
rename from iot-access/access-api/src/main/java/com/njcn/access/param/ParamName.java
rename to iot-access/access-api/src/main/java/com/njcn/access/annotation/ParamName.java
index 97709a9..aa3910f 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/param/ParamName.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/annotation/ParamName.java
@@ -1,4 +1,4 @@
-package com.njcn.access.param;
+package com.njcn.access.annotation;
import java.lang.annotation.ElementType;
import java.lang.annotation.Retention;
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/enums/AccessResponseEnum.java b/iot-access/access-api/src/main/java/com/njcn/access/enums/AccessResponseEnum.java
index fbc0a3b..48202ba 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/enums/AccessResponseEnum.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/enums/AccessResponseEnum.java
@@ -14,19 +14,22 @@ public enum AccessResponseEnum {
* A0301 ~ A0399 用于用户模块的枚举
*
*/
- NDID_NO_FIND("A0301", "与平台nDid匹配错误!"),
+ NDID_NO_FIND("A0301", "nDid在平台端未找到或者已接入"),
MODEL_REPEAT("A0302", "模板重复,请勿重复录入!"),
MODEL_NO_FIND("A0302", "模板不存在,请先录入模板数据!"),
MESSAGE_TYPE_ERROR("A0303","报文消息类型Type错误!"),
DEV_TYPE_ERROR("A0303","装置类型错误!"),
+ DEV_NOT_FIND("A0303","装置类型未找到!"),
+ DEV_MODEL_NOT_FIND("A0303","装置型号未找到!"),
+ DEV_IS_NOT_ZL("A0303","注册装置不是直连装置!"),
- RESPONSE_ERROR("A0304","装置请求响应错误!"),
+ REGISTER_RESPONSE_ERROR("A0304","装置注册,装置侧应答失败!"),
DEV_TYPE_NOT_FIND("A0305","装置类型未找到,需要录入!"),
- NO_RECEIVE_FROM_DEV("A0306","未收到装置注册响应,请核查!"),
+ REGISTER_ERROR("A0306","装置注册失败!"),
DICT_MISSING("A0307","字典数据缺失!"),
EPD_DICT_MISSING("A0307","Epd字典数据缺失!"),
@@ -42,6 +45,9 @@ public enum AccessResponseEnum {
INSET_DICT_MISSING("A0307","InSet字典数据缺失!"),
CTRL_DICT_MISSING("A0307","Ctrl字典数据缺失!"),
+ MODEL_MISS("A0308","模板信息缺失!"),
+ MODEL_VERSION_ERROR("A0308","询问装置模板信息错误"),
+
;
private final String code;
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/param/DevAccessParam.java b/iot-access/access-api/src/main/java/com/njcn/access/param/DevAccessParam.java
new file mode 100644
index 0000000..46d815f
--- /dev/null
+++ b/iot-access/access-api/src/main/java/com/njcn/access/param/DevAccessParam.java
@@ -0,0 +1,71 @@
+package com.njcn.access.param;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import javax.validation.constraints.NotNull;
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 类的介绍:
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/7/5 16:25
+ */
+@Data
+public class DevAccessParam implements Serializable {
+
+ @ApiModelProperty("项目id")
+ @NotNull(message = "项目id不能为空")
+ private String projectId;
+
+ @ApiModelProperty("区域")
+ private String area;
+
+ @ApiModelProperty("拓扑图id")
+ @NotNull(message = "拓扑图id不能为空")
+ private String topologyDiagram;
+
+ @ApiModelProperty("设备识别码")
+ @NotNull(message = "设备识别码不能为空")
+ private String nDid;
+
+ @ApiModelProperty("监测点集合")
+ @NotNull(message = "监测点集合不能为空")
+ private List list;
+
+ @Data
+ public static class LineParam {
+
+ @ApiModelProperty("监测点名称")
+ @NotNull(message = "监测点名称不能为空")
+ private String name;
+
+ @ApiModelProperty("安装位置")
+ @NotNull(message = "安装位置不能为空")
+ private String position;
+
+ @ApiModelProperty("电压等级")
+ @NotNull(message = "电压等级不能为空")
+ private String volGrade;
+
+ @ApiModelProperty("PT变比")
+ @NotNull(message = "PT变比不能为空")
+ private String ptRatio;
+
+ @ApiModelProperty("CT变比")
+ @NotNull(message = "CT变比不能为空")
+ private String ctRatio;
+
+ @ApiModelProperty("中心点经度")
+ @NotNull(message = "中心点经度不能为空")
+ private Double lng;
+
+ @ApiModelProperty("中心点纬度")
+ @NotNull(message = "中心点纬度不能为空")
+ private Double lat;
+ }
+
+}
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/AccessDto.java b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/AccessDto.java
index a650d8f..229c140 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/AccessDto.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/AccessDto.java
@@ -1,6 +1,6 @@
package com.njcn.access.pojo.dto;
-import com.njcn.access.param.ParamName;
+import com.njcn.access.annotation.ParamName;
import lombok.Data;
import java.io.Serializable;
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/DevCfgDto.java b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/DevCfgDto.java
index 25dcd39..569309c 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/DevCfgDto.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/DevCfgDto.java
@@ -1,8 +1,7 @@
package com.njcn.access.pojo.dto;
import com.alibaba.nacos.shaded.com.google.gson.annotations.SerializedName;
-import com.njcn.access.param.ParamName;
-import io.swagger.annotations.ApiModelProperty;
+import com.njcn.access.annotation.ParamName;
import lombok.Data;
import javax.validation.constraints.NotNull;
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ModelDto.java b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ModelDto.java
index 31f81dc..e96b0c4 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ModelDto.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ModelDto.java
@@ -1,8 +1,11 @@
package com.njcn.access.pojo.dto;
import com.alibaba.nacos.shaded.com.google.gson.annotations.SerializedName;
+import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
+import lombok.EqualsAndHashCode;
+import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.io.Serializable;
import java.util.List;
@@ -12,16 +15,43 @@ import java.util.List;
*
* @author xuyang
* @version 1.0.0
- * @createTime 2023/4/10 10:54
+ * @createTime 2023/7/5 11:26
*/
@Data
public class ModelDto implements Serializable {
- @SerializedName("DevCfg")
- @NotNull(message = "设备配置序列,不为空")
- private List devCfg;
+ @SerializedName("Mid")
+ @ApiModelProperty("报文ID,在请求报文中该值为请求ID")
+ @NotNull(message = "报文ID不能为空")
+ private Integer mid;
- @SerializedName("DevModInfo")
- @NotNull(message = "设备模板信息序列,不为空")
- private List devMod;
+ @SerializedName("Did")
+ @ApiModelProperty("设备唯一标识lDid,填入0代表nDid")
+ @NotBlank(message = "设备唯一标识lDid不能为空")
+ private String did;
+
+ @SerializedName("Pri")
+ @ApiModelProperty("报文处理的优先级")
+ @NotNull(message = "报文处理的优先级不能为空")
+ private Integer pri;
+
+ @SerializedName("Type")
+ @ApiModelProperty("消息类型")
+ @NotNull(message = "消息类型不能为空")
+ private String type;
+
+ @SerializedName("Msg")
+ @ApiModelProperty("报文内容")
+ private Msg msg;
+
+ @Data
+ public static class Msg {
+ @SerializedName("DevCfg")
+ @ApiModelProperty("设备配置序列")
+ private List devCfg;
+
+ @SerializedName("DevModInfo")
+ @ApiModelProperty("设备模板信息序列")
+ private List devMod;
+ }
}
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/pojo/param/ReqAndResParam.java b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ReqAndResDto.java
similarity index 89%
rename from iot-access/access-api/src/main/java/com/njcn/access/pojo/param/ReqAndResParam.java
rename to iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ReqAndResDto.java
index 96f115f..521ffd5 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/pojo/param/ReqAndResParam.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/ReqAndResDto.java
@@ -1,4 +1,4 @@
-package com.njcn.access.pojo.param;
+package com.njcn.access.pojo.dto;
import com.alibaba.nacos.shaded.com.google.gson.annotations.SerializedName;
import io.swagger.annotations.ApiModelProperty;
@@ -8,6 +8,7 @@ import lombok.EqualsAndHashCode;
import javax.validation.constraints.NotBlank;
import javax.validation.constraints.NotNull;
import java.io.Serializable;
+import java.util.List;
/**
* 类的介绍:
@@ -17,7 +18,7 @@ import java.io.Serializable;
* @createTime 2023/4/20 14:05
*/
@Data
-public class ReqAndResParam implements Serializable {
+public class ReqAndResDto implements Serializable {
@SerializedName("Mid")
@ApiModelProperty("报文ID,在请求报文中该值为请求ID")
@@ -48,7 +49,7 @@ public class ReqAndResParam implements Serializable {
*/
@Data
@EqualsAndHashCode(callSuper = true)
- public static class Req extends ReqAndResParam {
+ public static class Req extends ReqAndResDto {
@SerializedName("Expire")
@ApiModelProperty("此报文过期的相对时间,单位秒,该字段为-1时表示永不过期.控制类报文接收者超时处理按此时间")
@NotNull(message = "报文过期的相对时间不能为空")
@@ -60,10 +61,11 @@ public class ReqAndResParam implements Serializable {
*/
@Data
@EqualsAndHashCode(callSuper = true)
- public static class Res extends ReqAndResParam {
+ public static class Res extends ReqAndResDto {
@SerializedName("Code")
@ApiModelProperty("标识应答的返回码")
@NotNull(message = "状态码不能为空")
private Integer code;
}
+
}
diff --git a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/data/StsDto.java b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/data/StsDto.java
index 03743a7..8b89f97 100644
--- a/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/data/StsDto.java
+++ b/iot-access/access-api/src/main/java/com/njcn/access/pojo/dto/data/StsDto.java
@@ -38,17 +38,8 @@ public class StsDto implements Serializable {
@NotNull(message = "当前值,不为空")
private Integer curSts;
- @SerializedName("ClassID")
- @NotNull(message = "数据分类,不为空")
- private String classId;
-
@SerializedName("TranRule")
@NotNull(message = "上送规则,不为空")
@ApiModelProperty("变化:change 周期:period")
private String tranRule;
-
- //todo 不确定是否还有这个字段先保留
- @SerializedName("GroupId")
- @NotNull(message = "数据分组组号,不为空")
- private List