From 5067f8575ac0e89a41988778c2b24718d1375d97 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Tue, 30 May 2023 15:22:55 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8C=87=E6=A0=87=E5=AD=97=E5=85=B8=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../system/pojo/param/EleEpdPqdParam.java     |  3 +-
 .../com/njcn/system/pojo/po/EleEpdPqd.java    |  9 ++++
 .../com/njcn/system/pojo/vo/EleEpdPqdVO.java  | 45 +++++++++++++++++++
 .../system/mapper/mapping/EleEpdPqdMapper.xml | 16 +++++--
 .../service/impl/EleEpdPqdServiceImpl.java    | 10 ++++-
 5 files changed, 78 insertions(+), 5 deletions(-)

diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EleEpdPqdParam.java b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EleEpdPqdParam.java
index d7bb18b0d..f658df7cf 100644
--- a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EleEpdPqdParam.java
+++ b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/param/EleEpdPqdParam.java
@@ -112,7 +112,8 @@ public class EleEpdPqdParam {
     @Data
     @EqualsAndHashCode(callSuper = true)
     public static class EleEpdPqdQueryParam extends BaseParam {
-
+        @ApiModelProperty("dataType")
+        private String dataType;
     }
 
 }
diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/po/EleEpdPqd.java b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/po/EleEpdPqd.java
index 45206dfdd..de959518b 100644
--- a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/po/EleEpdPqd.java
+++ b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/po/EleEpdPqd.java
@@ -146,5 +146,14 @@ public class EleEpdPqd {
      */
     private String defaultValue;
 
+    /**
+     * 状态(0:删除 1:正常)
+     */
+    private Integer status;
+
+    /**
+     * 报表数据来源(mysql表名)
+     */
+    private String resourcesId;
 
 }
diff --git a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EleEpdPqdVO.java b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EleEpdPqdVO.java
index a6fa28eef..b273fa839 100644
--- a/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EleEpdPqdVO.java
+++ b/pqs-system/system-api/src/main/java/com/njcn/system/pojo/vo/EleEpdPqdVO.java
@@ -17,6 +17,9 @@ public class EleEpdPqdVO implements Serializable {
 
     private static final long serialVersionUID = 1L;
 
+    @ApiModelProperty(value = "id")
+    private String id;
+
     @ApiModelProperty(value = "数据名称")
     private String name;
 
@@ -44,13 +47,55 @@ public class EleEpdPqdVO implements Serializable {
     @ApiModelProperty(value = "数据结束谐波次数")
     private Integer harmEnd;
 
+    @ApiModelProperty(value = "统计方式")
+    private String statMethod;
+
+    @ApiModelProperty(value = "系统类型")
+    private String systemType;
+
     @ApiModelProperty(value = "数据分类(influxDB表名)")
     private String classId;
 
     @ApiModelProperty(value = "数据模型")
     private String dataType;
 
+    @ApiModelProperty(value = "数据模型名称")
+    private String dataTypeName;
+
     @ApiModelProperty(value = "报表数据来源(mysql表名)")
     private String resourcesId;
 
+    @ApiModelProperty(value = "数据是否上送 0:不上送 1:上送")
+    private Integer tranFlag;
+
+    @ApiModelProperty(value = "上送规则 变化:change 周期:period")
+    private String tranRule;
+
+    @ApiModelProperty(value = "事件类别||参数类别||系统参数||定值数据类型")
+    private String eventType;
+
+    @ApiModelProperty(value = "是否存储 1:存储 0:不存储||是否加密 1:加密 0:不加密")
+    private Integer storeFlag;
+
+    @ApiModelProperty(value = "当前值||是否需遥控校验 1：需要 0：不需要")
+    private Integer curSts;
+
+    @ApiModelProperty(value = "是否可远程控制 1:是 0:否||是否可修改 1:是 0:否||是否支持自动控制 1:是 0:否")
+    private Integer ctlSts;
+
+    @ApiModelProperty(value = "设置最大值")
+    private Integer maxNum;
+
+    @ApiModelProperty(value = "设置最小值")
+    private Integer minNum;
+
+    @ApiModelProperty(value = "参数为enum可设置的所有值序列")
+    private String setValue;
+
+    @ApiModelProperty(value = "参数string可设置字符串的长度上限")
+    private Integer strlen;
+
+    @ApiModelProperty(value = "参数缺省值")
+    private String defaultValue;
+
 }
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/EleEpdPqdMapper.xml b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/EleEpdPqdMapper.xml
index 79558f015..59273ef1d 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/EleEpdPqdMapper.xml
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/EleEpdPqdMapper.xml
@@ -3,9 +3,19 @@
 <mapper namespace="com.njcn.system.mapper.EleEpdPqdMapper">
 
     <select id="page" resultType="EleEpdPqdVO">
-        SELECT t0.*
-        FROM ele_epd_pqd t0
-        ${ew.sqlSegment}
+        SELECT
+            sdd.Name dataTypeName,
+            ele_epd_pqd.*
+        FROM
+            ele_epd_pqd ele_epd_pqd
+        left join
+            sys_dict_data sdd
+        on
+            ele_epd_pqd.data_type = sdd.Id
+        <where>
+            1=1
+            and ${ew.sqlSegment}
+        </where>
     </select>
 
 </mapper>
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EleEpdPqdServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EleEpdPqdServiceImpl.java
index 585aea184..d85b9784f 100644
--- a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EleEpdPqdServiceImpl.java
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EleEpdPqdServiceImpl.java
@@ -43,6 +43,7 @@ public class EleEpdPqdServiceImpl extends MppServiceImpl<EleEpdPqdMapper, EleEpd
             if (StringUtils.isBlank(item.getType())){
                 eleEpdPqd.setType("");
             }
+            eleEpdPqd.setStatus(1);
             return eleEpdPqd;
         }).collect(Collectors.toList());
         this.saveBatch(list,1000);
@@ -53,12 +54,15 @@ public class EleEpdPqdServiceImpl extends MppServiceImpl<EleEpdPqdMapper, EleEpd
         checkEleEpdPqdParam(eleEpdPqdParam,false);
         EleEpdPqd eleEpdPqd = new EleEpdPqd();
         BeanUtils.copyProperties(eleEpdPqdParam,eleEpdPqd);
+        eleEpdPqd.setStatus(1);
         this.save(eleEpdPqd);
     }
 
     @Override
     public void delete(String id) {
-        this.baseMapper.deleteById(id);
+        EleEpdPqd eleEpdPqd = this.lambdaQuery().eq(EleEpdPqd::getId,id).one();
+        eleEpdPqd.setStatus(0);
+        this.updateById(eleEpdPqd);
     }
 
     @Override
@@ -89,6 +93,10 @@ public class EleEpdPqdServiceImpl extends MppServiceImpl<EleEpdPqdMapper, EleEpd
                 queryWrapper.orderBy(true, true, "Sort");
             }
         }
+        if (!StringUtils.isBlank(queryParam.getDataType())){
+            queryWrapper.eq("ele_epd_pqd.data_type", queryParam.getDataType());
+        }
+        queryWrapper.eq("ele_epd_pqd.status", 1);
         return this.baseMapper.page(new Page<>(PageFactory.getPageNum(queryParam), PageFactory.getPageSize(queryParam)), queryWrapper);
     }