Explorar o código

大表维度-小时维度数据 新增 风机、泵等参数的实时数据处理 和 对应的 历史数据接口处理

王苗苗 hai 1 mes
pai
achega
58c5b39ebc

+ 27 - 1
slibra-admin/src/main/java/com/slibra/web/controller/business/HandleDataController.java

@@ -735,7 +735,6 @@ public class HandleDataController extends BaseController
      */
     @GetMapping("/updateGYKSomeFields")
     public String updateGYKSomeFields() {
-        //ToDo 更新工业库部分字段 xxxxxx
         //更新的某个指标
 //        String[] queryTags = {"信义污水厂_除磷P04预测值_"};
         String[] queryTags = {"信义污水厂一号鼓风机电流", "信义污水厂二号鼓风机电流", "信义污水厂三号鼓风机电流", "信义污水厂四号鼓风机电流", "信义污水厂五号鼓风机电流", "信义污水厂六号鼓风机电流", "信义污水厂XGS1_R_Value", "信义污水厂细格栅间_2号细格栅主机_运行信号", "信义污水厂细格栅间_3号细格栅主机_运行信号", "信义污水厂XGS4_R_Value", "信义污水厂细格栅间_5号细格栅主机_运行信号", "信义污水厂细格栅间_6号细格栅主机_运行信号", "信义污水厂内回流1#_Ia", "信义污水厂内回流2#_Ia", "信义污水厂内回流3#_Ia", "信义污水厂内回流4#_Ia", "信义污水厂内回流5#_Ia", "信义污水厂内回流6#_Ia", "信义污水厂PNBFPNB1_R_Value", "信义污水厂PNBFPNB2_R_Value", "信义污水厂SWCSYWNHLB1_R_Value", "信义污水厂SWCSYWNHLB2_R_Value", "信义污水厂升级1#空压机主机A相电流", "信义污水厂升级2#空压机主机A相电流", "信义污水厂升级3#空压机主机A相电流", "信义污水厂升级4#空压机主机A相电流"};
@@ -1598,6 +1597,33 @@ public class HandleDataController extends BaseController
         xinyiBigTableHour.setGyHycRjyZdAll(tXinyiIndustry.getHycRjyZdAll());
         xinyiBigTableHour.setGyHycWnndAll(tXinyiIndustry.getHycWnndAll());
         xinyiBigTableHour.setGyClP04Ycz(tXinyiIndustry.getCLP04YCZ());
+        //2025年04月03日10:31:13 新增风机 泵相关参数处理
+        xinyiBigTableHour.setGyOneFjDl(tXinyiIndustry.getOneFjDl());
+        xinyiBigTableHour.setGyTwoFjDl(tXinyiIndustry.getTwoFjDl());
+        xinyiBigTableHour.setGyThreeFjDl(tXinyiIndustry.getThreeFjDl());
+        xinyiBigTableHour.setGyFourFjDl(tXinyiIndustry.getFourFjDl());
+        xinyiBigTableHour.setGyFiveFjDl(tXinyiIndustry.getFiveFjDl());
+        xinyiBigTableHour.setGySixFjDl(tXinyiIndustry.getSixFjDl());
+        xinyiBigTableHour.setGyOneXgsQt(tXinyiIndustry.getOneXgsQt());
+        xinyiBigTableHour.setGyTwoXgsQt(tXinyiIndustry.getTwoXgsQt());
+        xinyiBigTableHour.setGyThreeXgsQt(tXinyiIndustry.getThreeXgsQt());
+        xinyiBigTableHour.setGyFourXgsQt(tXinyiIndustry.getFourXgsQt());
+        xinyiBigTableHour.setGyFiveXgsQt(tXinyiIndustry.getFiveXgsQt());
+        xinyiBigTableHour.setGySixXgsQt(tXinyiIndustry.getSixXgsQt());
+        xinyiBigTableHour.setGyOneNhlbDl(tXinyiIndustry.getOneNhlbDl());
+        xinyiBigTableHour.setGyTwoNhlbDl(tXinyiIndustry.getTwoNhlbDl());
+        xinyiBigTableHour.setGyThreeNhlbDl(tXinyiIndustry.getThreeNhlbDl());
+        xinyiBigTableHour.setGyFourNhlbDl(tXinyiIndustry.getFourNhlbDl());
+        xinyiBigTableHour.setGyFiveNhlbDl(tXinyiIndustry.getFiveNhlbDl());
+        xinyiBigTableHour.setGySixNhlbDl(tXinyiIndustry.getSixNhlbDl());
+        xinyiBigTableHour.setGyOneCccpnbQt(tXinyiIndustry.getOneCccpnbQt());
+        xinyiBigTableHour.setGyTwoCccpnbQt(tXinyiIndustry.getTwoCccpnbQt());
+        xinyiBigTableHour.setGyOneSywndbQt(tXinyiIndustry.getOneSywndbQt());
+        xinyiBigTableHour.setGyTwoSywndbQt(tXinyiIndustry.getTwoSywndbQt());
+        xinyiBigTableHour.setGyOneSdclDl(tXinyiIndustry.getOneSdclDl());
+        xinyiBigTableHour.setGyTwoSdclDl(tXinyiIndustry.getTwoSdclDl());
+        xinyiBigTableHour.setGyThreeSdclDl(tXinyiIndustry.getThreeSdclDl());
+        xinyiBigTableHour.setGyFourSdclDl(tXinyiIndustry.getFourSdclDl());
     }
 
     // 处理计算表

+ 27 - 0
slibra-quartz/src/main/java/com/slibra/quartz/task/AsyncTask.java

@@ -281,6 +281,33 @@ public class AsyncTask {
         xinyiBigTableHour.setGyHycRjyZdAll(tXinyiIndustry.getHycRjyZdAll());
         xinyiBigTableHour.setGyHycWnndAll(tXinyiIndustry.getHycWnndAll());
         xinyiBigTableHour.setGyClP04Ycz(tXinyiIndustry.getCLP04YCZ());
+        //2025年04月03日10:31:13 新增风机 泵相关参数处理
+        xinyiBigTableHour.setGyOneFjDl(tXinyiIndustry.getOneFjDl());
+        xinyiBigTableHour.setGyTwoFjDl(tXinyiIndustry.getTwoFjDl());
+        xinyiBigTableHour.setGyThreeFjDl(tXinyiIndustry.getThreeFjDl());
+        xinyiBigTableHour.setGyFourFjDl(tXinyiIndustry.getFourFjDl());
+        xinyiBigTableHour.setGyFiveFjDl(tXinyiIndustry.getFiveFjDl());
+        xinyiBigTableHour.setGySixFjDl(tXinyiIndustry.getSixFjDl());
+        xinyiBigTableHour.setGyOneXgsQt(tXinyiIndustry.getOneXgsQt());
+        xinyiBigTableHour.setGyTwoXgsQt(tXinyiIndustry.getTwoXgsQt());
+        xinyiBigTableHour.setGyThreeXgsQt(tXinyiIndustry.getThreeXgsQt());
+        xinyiBigTableHour.setGyFourXgsQt(tXinyiIndustry.getFourXgsQt());
+        xinyiBigTableHour.setGyFiveXgsQt(tXinyiIndustry.getFiveXgsQt());
+        xinyiBigTableHour.setGySixXgsQt(tXinyiIndustry.getSixXgsQt());
+        xinyiBigTableHour.setGyOneNhlbDl(tXinyiIndustry.getOneNhlbDl());
+        xinyiBigTableHour.setGyTwoNhlbDl(tXinyiIndustry.getTwoNhlbDl());
+        xinyiBigTableHour.setGyThreeNhlbDl(tXinyiIndustry.getThreeNhlbDl());
+        xinyiBigTableHour.setGyFourNhlbDl(tXinyiIndustry.getFourNhlbDl());
+        xinyiBigTableHour.setGyFiveNhlbDl(tXinyiIndustry.getFiveNhlbDl());
+        xinyiBigTableHour.setGySixNhlbDl(tXinyiIndustry.getSixNhlbDl());
+        xinyiBigTableHour.setGyOneCccpnbQt(tXinyiIndustry.getOneCccpnbQt());
+        xinyiBigTableHour.setGyTwoCccpnbQt(tXinyiIndustry.getTwoCccpnbQt());
+        xinyiBigTableHour.setGyOneSywndbQt(tXinyiIndustry.getOneSywndbQt());
+        xinyiBigTableHour.setGyTwoSywndbQt(tXinyiIndustry.getTwoSywndbQt());
+        xinyiBigTableHour.setGyOneSdclDl(tXinyiIndustry.getOneSdclDl());
+        xinyiBigTableHour.setGyTwoSdclDl(tXinyiIndustry.getTwoSdclDl());
+        xinyiBigTableHour.setGyThreeSdclDl(tXinyiIndustry.getThreeSdclDl());
+        xinyiBigTableHour.setGyFourSdclDl(tXinyiIndustry.getFourSdclDl());
     }
 
     private void addCalculate2BigTable(TXinyiBigTableHour xinyiBigTableHour, TXinyiCalculate xinyiCalculate) {