From a45a2b93e470d05773bd9e0640455b7dc1a86cec Mon Sep 17 00:00:00 2001
From: dengzedong <dengzedong@email>
Date: 星期四, 08 五月 2025 17:11:20 +0800
Subject: [PATCH] arcDataApi.queryArcLastValue

---
 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdDayTask.java |   36 +++++++++++++++++++++++++-----------
 1 files changed, 25 insertions(+), 11 deletions(-)

diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdDayTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdDayTask.java
index 4c5db81..7315d11 100644
--- a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdDayTask.java
+++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunCokingProdDayTask.java
@@ -6,6 +6,8 @@
 import com.iailab.module.ansteel.coking.service.CokingProcessConfService;
 import com.iailab.module.ansteel.coking.service.CokingProdDayService;
 import com.iailab.module.ansteel.common.enums.ProcessConfDataTypeEnum;
+import com.iailab.module.data.api.arc.ArcDataApi;
+import com.iailab.module.data.api.arc.dto.ApiArcDataDTO;
 import com.iailab.module.data.api.ind.IndItemApi;
 import com.iailab.module.data.api.ind.dto.ApiIndItemValueDTO;
 import com.iailab.module.data.api.point.DataPointApi;
@@ -16,7 +18,10 @@
 import org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.List;
+import java.util.Map;
 
 /**
  * 生成焦化日前生产信息
@@ -39,6 +44,8 @@
 
     @Resource
     private DataPointApi dataPointApi;
+    @Resource
+    private ArcDataApi arcDataApi;
 
     @Resource
     private IndItemApi indItemApi;
@@ -85,11 +92,17 @@
                             value = indValues.get(indValues.size() - 1).getDataValue().toString();
                         }
                         break;
+                    case ARC:
+                        ApiArcDataDTO apiArcDataDTO = arcDataApi.queryArcLastValue(conf.getPointNo());
+                        if (apiArcDataDTO != null) {
+                            value = apiArcDataDTO.getArcValue().toString();
+                        }
+                        break;
                    default:
                         break;
 
                 }
-                this.saveProdDay(conf, value, clock);
+                saveProdDay(conf, value, clock, conf.getIndCode());
             }
         } catch (Exception ex) {
             logger.error("RunCokingProdDayTask运行异常");
@@ -99,14 +112,15 @@
 
     }
 
-    private void saveProdDay(CokingProcessConfEntity conf, String value, String clock) {
-        CokingProdDayEntity cokingProdDayEntity = new CokingProdDayEntity();
-        cokingProdDayEntity.setInfoType(conf.getInfoType());
-        cokingProdDayEntity.setSort(conf.getSort());
-        cokingProdDayEntity.setIndName(conf.getIndName());
-        cokingProdDayEntity.setIndUnit(conf.getIndUnit());
-        cokingProdDayEntity.setIndValue(value);
-        cokingProdDayEntity.setClock(clock);
-        cokingProdDayService.save(cokingProdDayEntity);
+    private void saveProdDay(CokingProcessConfEntity conf, String value, String clock, String indCode) {
+        CokingProdDayEntity entity = new CokingProdDayEntity();
+        entity.setInfoType(conf.getInfoType());
+        entity.setSort(conf.getSort());
+        entity.setIndCode(indCode);
+        entity.setIndName(conf.getIndName());
+        entity.setIndUnit(conf.getIndUnit());
+        entity.setIndValue(value);
+        entity.setClock(clock);
+        cokingProdDayService.save(entity);
     }
 }
\ No newline at end of file

--
Gitblit v1.9.3