返回最新的瞬时加药量

src/main/java/com/xlht/xlhtproject/domain/TTbDu.java

@@ -6,6 +6,7 @@ import lombok.Builder;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import java.math.BigDecimal;
 import java.util.Date;
 
 
@@ -27,13 +28,13 @@ public class TTbDu
     private Long ID;
 
     /** 1池投加流量 */
-    private Long c1TjLl;
+    private BigDecimal c1TjLl;
 
     /** 1池投加流量_更新时间 */
     private String c1TjLlTime;
 
     /** 2池投加流量 */
-    private Long c2TjLl;
+    private BigDecimal c2TjLl;
 
     /** 2池投加流量_更新时间 */
     private String c2TjLlTime;

src/main/java/com/xlht/xlhtproject/domain/TXinyiMedicineParam.java

@@ -130,8 +130,11 @@ public class TXinyiMedicineParam
     private Long revision;
 
     //额外查询的字段
-    //碳源投加瞬时流量
-    private BigDecimal tytjTransientLL;
+    //碳源投加瞬时流量(一池)
+    private BigDecimal tytjTransientLLOne;
+
+    //碳源投加瞬时流量(二池)
+    private BigDecimal tytjTransientLLTwo;
 
 
 

src/main/java/com/xlht/xlhtproject/service/impl/TXinyiMedicineParamServiceImpl.java

@@ -2,8 +2,10 @@ package com.xlht.xlhtproject.service.impl;
 
 
 import com.xlht.xlhtproject.domain.SmartAdd;
+import com.xlht.xlhtproject.domain.TTbDu;
 import com.xlht.xlhtproject.domain.TXinyiMedicineParam;
 import com.xlht.xlhtproject.mapper.TShuju1Mapper;
+import com.xlht.xlhtproject.mapper.TTbDuMapper;
 import com.xlht.xlhtproject.mapper.TXinyiMedicineParamMapper;
 import com.xlht.xlhtproject.service.ITXinyiMedicineParamService;
 import com.xlht.xlhtproject.utils.CalculateUtils;
@@ -17,6 +19,8 @@ import java.math.BigDecimal;
 import java.util.List;
 import java.util.Objects;
 
+import static com.xlht.xlhtproject.enums.MyConstants.LONG_1;
+
 
 /**
  * 智能投药参数设置Service业务层处理
@@ -37,6 +41,9 @@ public class TXinyiMedicineParamServiceImpl implements ITXinyiMedicineParamServi
     @Autowired
     private CalculateUtils calculateUtils;
 
+    @Autowired
+    private TTbDuMapper tTbDuMapper;
+
 
     /**
      * 查询智能投药参数设置
@@ -175,6 +182,12 @@ public class TXinyiMedicineParamServiceImpl implements ITXinyiMedicineParamServi
                 val = BigDecimal.ZERO;
             }
             latestRecord.setMedicineAmount(val);
+            //获取2个池子的瞬时投药流量
+            TTbDu tTbDu = tTbDuMapper.selectTTbDuByID(LONG_1);
+            if(!Objects.isNull(tTbDu)){
+                latestRecord.setTytjTransientLLOne(tTbDu.getC1TjLl());
+                latestRecord.setTytjTransientLLTwo(tTbDu.getC2TjLl());
+            }
         }
     }
 }