Переглянути джерело

新增超污染物限制 和 超污染物负荷 进出水五大指标相关计算 -- 计算表处理

王苗苗 1 тиждень тому
батько
коміт
a69a63450c

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

@@ -313,6 +313,24 @@ public class AsyncTask {
         xinyiBigTableHour.setJsFcxslbl(xinyiCalculate.getFCXSLBL());
         //2024年7月11日15:57:20 外回流比采用新的公式计算
         xinyiBigTableHour.setJsWhlbRN(xinyiCalculate.getWhlRN());
+        //2025年03月19日17:14:35 处理 超污染物限制 和 超污染物负荷 进出水五大指标相关计算
+        xinyiBigTableHour.setJsCsCodCwrwxz(xinyiCalculate.getCsCodCwrwxz());
+        xinyiBigTableHour.setJsCsSsCwrwxz(xinyiCalculate.getCsSsCwrwxz());
+        xinyiBigTableHour.setJsCsZdCwrwxz(xinyiCalculate.getCsZdCwrwxz());
+        xinyiBigTableHour.setJsCsZlCwrwxz(xinyiCalculate.getCsZlCwrwxz());
+        xinyiBigTableHour.setJsCsAdCwrwxz(xinyiCalculate.getCsAdCwrwxz());
+
+        xinyiBigTableHour.setJsJsCodCwrwfh(xinyiCalculate.getJsCodCwrwfh());
+        xinyiBigTableHour.setJsJsSsCwrwfh(xinyiCalculate.getJsSsCwrwfh());
+        xinyiBigTableHour.setJsJsZdCwrwfh(xinyiCalculate.getJsZdCwrwfh());
+        xinyiBigTableHour.setJsJsZlCwrwfh(xinyiCalculate.getJsZlCwrwfh());
+        xinyiBigTableHour.setJsJsAdCwrwfh(xinyiCalculate.getJsAdCwrwfh());
+
+        xinyiBigTableHour.setJsJsCodCwrwxz(xinyiCalculate.getJsCodCwrwxz());
+        xinyiBigTableHour.setJsJsSsCwrwxz(xinyiCalculate.getJsSsCwrwxz());
+        xinyiBigTableHour.setJsJsZdCwrwxz(xinyiCalculate.getJsZdCwrwxz());
+        xinyiBigTableHour.setJsJsZlCwrwxz(xinyiCalculate.getJsZlCwrwxz());
+        xinyiBigTableHour.setJsJsAdCwrwxz(xinyiCalculate.getJsAdCwrwxz());
     }
 
     /**

+ 1 - 0
slibra-quartz/src/main/java/com/slibra/quartz/task/RyTask.java

@@ -411,6 +411,7 @@ public class RyTask
             //2024年6月7日15:26:44 把一些额外的计算的值,同时记录下来(xinyiCalculate对象在生化报警可能用的到)
             TXinyiCalculate xinyiCalculate = asyncTask.addCalculateByIndustry(industry, normConfig);
             this.xinyiCalculateMapper.insertTXinyiCalculate(xinyiCalculate);
+            //处理大表-小时维度的数据
             asyncTask.addBigTable(industry, xinyiCalculate);
 
             //判断是否触发告警、接触告警、保存决策等等