From 0023e82d89189c6d3f2976e7574ac891a5553f21 Mon Sep 17 00:00:00 2001
From: mh <ljf25604@163.com>
Date: Mon, 13 May 2024 18:43:12 +0800
Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E7=94=A8=E8=83=BD=E9=A2=84=E6=B5=8B?=
 =?UTF-8?q?=E5=90=8E=E7=AB=AF=E6=95=B0=E6=8D=AE=E5=A4=84=E7=90=86=EF=BC=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mh/user/mapper/DeviceInstallMapper.java   |  6 ++--
 .../mh/user/mapper/HistoryDataPreMapper.java  | 16 +++++-----
 .../impl/HistoryDataPreServiceImpl.java       | 31 ++++++++++++++-----
 3 files changed, 35 insertions(+), 18 deletions(-)

diff --git a/user-service/src/main/java/com/mh/user/mapper/DeviceInstallMapper.java b/user-service/src/main/java/com/mh/user/mapper/DeviceInstallMapper.java
index ea8215b..1226275 100644
--- a/user-service/src/main/java/com/mh/user/mapper/DeviceInstallMapper.java
+++ b/user-service/src/main/java/com/mh/user/mapper/DeviceInstallMapper.java
@@ -19,8 +19,8 @@ public interface DeviceInstallMapper extends BaseMapper<DeviceInstallEntity> {
      * 保存设备信息
      * @param deviceInstallEntity
      */
-    @Insert("insert into device_install(device_addr,device_name,device_type,data_com,ratio,baudrate,brand,model,building_id,building_name,installer,install_date,is_use) values (" +
-            " #{deviceAddr},#{deviceName},#{deviceType},#{dataCom},#{ratio},#{baudRate},#{brand},#{model},#{buildingId},#{buildingName},#{installer},getDate(),#{use})")
+    @Insert("insert into device_install(device_addr,device_name,device_type,data_com,ratio,baudrate,brand,model,building_id,building_name,installer,install_date,is_use,parity) values (" +
+            " #{deviceAddr},#{deviceName},#{deviceType},#{dataCom},#{ratio},#{baudRate},#{brand},#{model},#{buildingId},#{buildingName},#{installer},getDate(),#{use},#{parity})")
     int saveDevice(DeviceInstallEntity deviceInstallEntity);
 
     /**
@@ -160,7 +160,7 @@ public interface DeviceInstallMapper extends BaseMapper<DeviceInstallEntity> {
 
     //根据通讯地址和设备类型查询对应的设备信息
     @ResultMap("rs")
-    @Select("select * from  device_install  where  device_addr=#{deviceAddr} and device_type=#{deviceType}  and building_id=#{buildingId}")
+    @Select("select top 1 * from  device_install  where  device_addr=#{deviceAddr} and device_type=#{deviceType}  and building_id=#{buildingId}")
     DeviceInstallEntity selectDevice(@Param("deviceAddr") String deviceAddr,@Param("deviceType") String deviceType,@Param("buildingId") String buildingId);
 
     //查询通讯编号是否存在
diff --git a/user-service/src/main/java/com/mh/user/mapper/HistoryDataPreMapper.java b/user-service/src/main/java/com/mh/user/mapper/HistoryDataPreMapper.java
index 875e2de..1db5222 100644
--- a/user-service/src/main/java/com/mh/user/mapper/HistoryDataPreMapper.java
+++ b/user-service/src/main/java/com/mh/user/mapper/HistoryDataPreMapper.java
@@ -130,13 +130,13 @@ public interface HistoryDataPreMapper extends BaseMapper<HistoryDataPre> {
     @Select("<script>" +
             "SELECT " +
             "  <choose>" +
-            "    <when test='type == \"1\"'>" +
+            "    <when test='type == \"2\"'>" +
             "      isnull(t.water_value_pre, 0) as cur_yes_data, " +
             "      isnull(t1.water_value, 0) as yes_data, " +
             "      isnull(t1.water_value_pre, 0) as pre_yes_data, " +
             "      CASE WHEN t1.water_value_pre > 0 THEN CONVERT(decimal(18, 2), ABS(isnull(t1.water_value_pre, 0) - isnull(t1.water_value, 0)) / t1.water_value_pre * 100) ELSE '0' END as error_data" +
             "    </when>" +
-            "    <when test='type == \"2\"'>" +
+            "    <when test='type == \"1\"'>" +
             "      isnull(t.elect_value_pre, 0) as cur_yes_data, " +
             "      isnull(t1.elect_value, 0) as yes_data, " +
             "      isnull(t1.elect_value_pre, 0) as pre_yes_data, " +
@@ -189,22 +189,22 @@ public interface HistoryDataPreMapper extends BaseMapper<HistoryDataPre> {
             "SELECT " +
             "  hdp.cur_date, " +
             "  <choose>" +
-            "    <when test='type == \"1\"'>isnull(hdp.water_value, 0)</when>" +
-            "    <when test='type == \"2\"'>isnull(hdp.elect_value, 0)</when>" +
+            "    <when test='type == \"2\"'>isnull(hdp.water_value, 0)</when>" +
+            "    <when test='type == \"1\"'>isnull(hdp.elect_value, 0)</when>" +
             "    <when test='type == \"3\"'>isnull(hdp.water_level, 0)</when>" +
             "    <otherwise>0</otherwise>" +
             "  </choose> as cur_data, " +
             "  <choose>" +
-            "    <when test='type == \"1\"'>isnull(hdp.water_value_pre, 0)</when>" +
-            "    <when test='type == \"2\"'>isnull(hdp.elect_value_pre, 0)</when>" +
+            "    <when test='type == \"2\"'>isnull(hdp.water_value_pre, 0)</when>" +
+            "    <when test='type == \"1\"'>isnull(hdp.elect_value_pre, 0)</when>" +
             "    <when test='type == \"3\"'>isnull(hdp.water_level_pre, 0)</when>" +
             "    <otherwise>0</otherwise>" +
             "  </choose> as pre_data, " +
             "  CASE " +
-            "    <when test='type == \"1\"'>" +
+            "    <when test='type == \"2\"'>" +
             "      WHEN hdp.water_value_pre > 0 THEN CONVERT(decimal(18, 2), ABS(isnull(hdp.water_value_pre, 0) - isnull(hdp.water_value, 0)) / hdp.water_value_pre * 100) else 0 " +
             "    </when>" +
-            "    <when test='type == \"2\"'>" +
+            "    <when test='type == \"1\"'>" +
             "      WHEN hdp.elect_value_pre > 0 THEN CONVERT(decimal(18, 2), ABS(isnull(hdp.elect_value_pre, 0) - isnull(hdp.elect_value, 0)) / hdp.elect_value_pre * 100) else 0 " +
             "    </when>" +
             "    <when test='type == \"3\"'>" +
diff --git a/user-service/src/main/java/com/mh/user/service/impl/HistoryDataPreServiceImpl.java b/user-service/src/main/java/com/mh/user/service/impl/HistoryDataPreServiceImpl.java
index 7533eb6..72d5de6 100644
--- a/user-service/src/main/java/com/mh/user/service/impl/HistoryDataPreServiceImpl.java
+++ b/user-service/src/main/java/com/mh/user/service/impl/HistoryDataPreServiceImpl.java
@@ -86,7 +86,7 @@ public class HistoryDataPreServiceImpl implements HistoryDataPreService {
         bpParameter.setHiddenLayerNeuronCount(3);
         bpParameter.setOutputLayerNeuronCount(3);
         bpParameter.setPrecision(0.01);
-        bpParameter.setMaxTimes(50000);
+        bpParameter.setMaxTimes(10000);
 
         // 训练BP神经网络
         BPModel bpModel = factory.trainBP(bpParameter, trainSet);
@@ -129,11 +129,12 @@ public class HistoryDataPreServiceImpl implements HistoryDataPreService {
         // 插入数据
         curHistoryData.setEnvMaxTemp(new BigDecimal(envMaxTemp));
         curHistoryData.setEnvMinTemp(new BigDecimal(envMinTemp));
-        historyDataPreMapper.insertData(curHistoryData);
-
+        HistoryDataPre historyDataPre = historyDataPreMapper.selectOneData(buildingId, curDate);
+        if (historyDataPre == null) {
+            historyDataPreMapper.insertData(curHistoryData);
+        }
         // 开始预测
         HistoryDataPre historyDataPre1 = historyDataPreMapper.selectOneData(buildingId, curDate);
-
         String[] preData = new String[]{historyDataPre1.getEnvMinTemp().toString(), historyDataPre1.getEnvMaxTemp().toString()};
 
         CsvInfo csvInfo = new CsvInfo();
@@ -156,14 +157,30 @@ public class HistoryDataPreServiceImpl implements HistoryDataPreService {
                 record[j] = result.getValOfIdx(i, j)+"";
             }
             // 拼接预测值
-            preHistoryData.setWaterValuePre(new BigDecimal(record[0]));
-            preHistoryData.setElectValuePre(new BigDecimal(record[1]));
-            preHistoryData.setWaterLevelPre(new BigDecimal(record[2]));
+            preHistoryData.setWaterValuePre(evaluateAndReturnBigDecimal(record[0]));
+            preHistoryData.setElectValuePre(evaluateAndReturnBigDecimal(record[1]));
+            preHistoryData.setWaterLevelPre(evaluateAndReturnBigDecimal(record[2]));
         }
         // 更新预测值
         historyDataPreMapper.updateById(preHistoryData);
     }
 
+    /**
+     * 判断输入的字符串转换的BigDecimal是否小于或等于0，返回BigDecimal.ZERO。
+     * 如果小于或等于0，返回输入的BigDecimal；如果大于0，然后返回相应的BigDecimal值。
+     *
+     * @param recordValue 记录中的值，用于转换为BigDecimal进行比较
+     * @return 经过判断后的BigDecimal值
+     */
+    public static BigDecimal evaluateAndReturnBigDecimal(String recordValue) {
+        BigDecimal value = new BigDecimal(recordValue);
+        if (value.compareTo(BigDecimal.ZERO) >= 0) {
+            return value;
+        } else {
+            return BigDecimal.ZERO;
+        }
+    }
+
     @Override
     public List<HistoryDataPre> getRecentData(String buildingId, String curDate) {
         return historyDataPreMapper.getRecentData(buildingId, curDate);