From 1717a12c83db01e3b31ea9ed913e5bacaf9edbf3 Mon Sep 17 00:00:00 2001
From: hdy <1105738590@qq.com>
Date: 星期六, 29 三月 2025 14:24:06 +0800
Subject: [PATCH] 修改

---
 billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java |   98 +++++++++++++------
 billion-main/src/main/resources/mapper/om/OmProductionOrderInfoMapper.xml                        |    6 +
 billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java                 |  178 ++++++++++++++++++-----------------
 3 files changed, 160 insertions(+), 122 deletions(-)

diff --git a/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java b/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java
index 58a7270..445a12c 100644
--- a/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java
+++ b/billion-main/src/main/java/com/billion/main/da/service/impl/DaMaterialCollectionServiceImpl.java
@@ -1,6 +1,7 @@
 package com.billion.main.da.service.impl;
 
 import java.text.SimpleDateFormat;
+import java.util.Arrays;
 import java.util.List;
 import java.util.Objects;
 
@@ -71,15 +72,16 @@
     public void insertDaMaterialCollection(DaMaterialCollection daMaterialCollection)
     {
         String url = "http://172.40.161.71:8890/Interaction/CollectMT";
-
         CollectMT collectMT = new CollectMT();
         DaMaterialCollection  daMaterialCollection1 = new DaMaterialCollection();
         BsBomChildInfo bsBomChildInfo = new BsBomChildInfo();
         OmOrderScheduling omOrderScheduling = new OmOrderScheduling();
+
         daMaterialCollection1.setSfcCode(daMaterialCollection.getSfcCode());
         daMaterialCollection1.setLocationCode(daMaterialCollection.getLocationCode());
         daMaterialCollection1.setParamValue(daMaterialCollection.getParamValue());
         daMaterialCollection1.setCollectTime(daMaterialCollection.getCollectTime());
+
         omOrderScheduling.setSfcCode(daMaterialCollection.getSfcCode());
         if(     Constants.PLC1.contains(daMaterialCollection.getLocationCode()) ||
                 Constants.C005.equals(daMaterialCollection.getLocationCode()) ||
@@ -87,33 +89,27 @@
         {omOrderScheduling.setRemarks("Head");}
         else if(
                 Constants.PLC2.contains(daMaterialCollection.getLocationCode()) ||
-                        Constants.OP005.equals(daMaterialCollection.getLocationCode()) ||
-                        Constants.OP310.equals(daMaterialCollection.getLocationCode()))
+                Constants.OP005.equals(daMaterialCollection.getLocationCode()) ||
+                Constants.OP310.equals(daMaterialCollection.getLocationCode()))
         {omOrderScheduling.setRemarks("Body");}
         else if(Constants.P010.equals(daMaterialCollection.getLocationCode()))
         {omOrderScheduling.setRemarks("Pre");}
         List<OmOrderScheduling> omOrderSchedulingList = omOrderSchedulingService.selectOmOrderSchedulingList(omOrderScheduling);
         String OrderNumber = omOrderSchedulingList.get(0).getWorkOrderNo();
-        //瑕佹敼锛侊紒锛侊紒
-        if(Objects.equals(daMaterialCollection.getLocationCode(), "OP130") || Objects.equals(daMaterialCollection.getLocationCode(), "OP020")){
-            daMaterialCollection1.setMaterialCode("0");
-            daMaterialCollection1.setMaterialName("0");
-            collectMT.setMaterial1("0");
-        }else{
-//            bsBomChildInfo.setLocationCode(daMaterialCollection.getLocationCode());
-//            bsBomChildInfo.setBomCode(OrderNumber);
-//            List<BsBomChildInfo> bsBomChildInfoList = bsBomChildInfoService.selectBsBomChildInfoList(bsBomChildInfo);
-//            String MaterialCode = bsBomChildInfoList.get(0).getMaterialCode();
-//            String MaterialName = bsBomChildInfoList.get(0).getMaterialName();
-//            daMaterialCollection1.setMaterialCode(MaterialCode);
-//            daMaterialCollection1.setMaterialName(MaterialName);
-//            collectMT.setMaterial1(MaterialName);
-            daMaterialCollection1.setMaterialCode("0");
-            daMaterialCollection1.setMaterialName("0");
-            collectMT.setMaterial1("0");
-        }
+
+            bsBomChildInfo.setLocationCode(daMaterialCollection.getLocationCode());
+            bsBomChildInfo.setBomCode(OrderNumber);
+            String[] parts = daMaterialCollection.getParamValue().split("#");
+            String targetValue = parts[1]; // 鍙栫浜屼釜鍏冪礌锛堢储寮�1锛�
+            bsBomChildInfo.setMaterialCode(targetValue);
+            List<BsBomChildInfo> bsBomChildInfoList = bsBomChildInfoService.selectBsBomChildInfoList(bsBomChildInfo);
+            String MaterialCode = bsBomChildInfoList.get(0).getMaterialCode();
+            String MaterialName = bsBomChildInfoList.get(0).getMaterialName();
+            daMaterialCollection1.setMaterialCode(MaterialCode);
+            daMaterialCollection1.setMaterialName(MaterialName);
 
         this.save(daMaterialCollection1);
+        collectMT.setMaterial1(MaterialName);
         collectMT.setOrderNumber(OrderNumber);
         collectMT.setEngineNumber(daMaterialCollection.getSfcCode());
         collectMT.setStationName(daMaterialCollection.getLocationCode());
@@ -131,13 +127,53 @@
     }
 
 
-//    @Override
-//    public void insertDaMaterialCollectionOP020OP130(DaMaterialCollection DaMaterialCollection)
-//    {
-//
-////        this.save(daMaterialCollection);
-//    }
-//
+    @Override
+    public void plusSave(DaMaterialCollection daMaterialCollection) {
+        String url = "http://172.40.161.71:8890/Interaction/CollectMT";
+        CollectMT collectMT = new CollectMT();
+        DaMaterialCollection  daMaterialCollection1 = new DaMaterialCollection();
+        BsBomChildInfo bsBomChildInfo = new BsBomChildInfo();
+        OmOrderScheduling omOrderScheduling = new OmOrderScheduling();
+        daMaterialCollection1.setSfcCode(daMaterialCollection.getSfcCode());
+        daMaterialCollection1.setLocationCode(daMaterialCollection.getLocationCode());
+        daMaterialCollection1.setParamValue(daMaterialCollection.getParamValue());
+        daMaterialCollection1.setCollectTime(daMaterialCollection.getCollectTime());
+        omOrderScheduling.setSfcCode(daMaterialCollection.getSfcCode());
+        omOrderScheduling.setSfcCode(daMaterialCollection.getSfcCode());
+        if(     Constants.PLC1.contains(daMaterialCollection.getLocationCode()) ||
+                Constants.C005.equals(daMaterialCollection.getLocationCode()) ||
+                Constants.C060.equals(daMaterialCollection.getLocationCode()) )
+        {omOrderScheduling.setRemarks("Head");}
+        else if(
+                Constants.PLC2.contains(daMaterialCollection.getLocationCode()) ||
+                        Constants.OP005.equals(daMaterialCollection.getLocationCode()) ||
+                        Constants.OP310.equals(daMaterialCollection.getLocationCode()))
+        {omOrderScheduling.setRemarks("Body");}
+        else if(Constants.P010.equals(daMaterialCollection.getLocationCode()))
+        {omOrderScheduling.setRemarks("Pre");}
+        List<OmOrderScheduling> omOrderSchedulingList = omOrderSchedulingService.selectOmOrderSchedulingList(omOrderScheduling);
+        String OrderNumber = omOrderSchedulingList.get(0).getWorkOrderNo();
+        String[] parts = daMaterialCollection.getParamValue().split("#");
+        String targetValue = parts[1]; // 鍙栫浜屼釜鍏冪礌锛堢储寮�1锛�
+        daMaterialCollection1.setMaterialCode(targetValue);
+        daMaterialCollection1.setMaterialName(daMaterialCollection.getParamName());
+        this.save(daMaterialCollection1);
+        collectMT.setMaterial1(daMaterialCollection.getMaterialName());
+        collectMT.setOrderNumber(OrderNumber);
+        collectMT.setEngineNumber(daMaterialCollection.getSfcCode());
+        collectMT.setStationName(daMaterialCollection.getLocationCode());
+        collectMT.setPartsNumber(daMaterialCollection.getParamValue());
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        collectMT.setInsertTime(sdf.format(daMaterialCollection.getCollectTime()));
+        try {
+            HttpResponse response = HttpRequest.post(url).body(JSONUtil.toJsonStr(collectMT)).execute();
+            log.info("鎺ㄩ�佹垚鍔燂紝鍝嶅簲鎶ユ枃: {}", response);
+        } catch (Exception e) {
+            // 璁板綍鏃ュ織
+            log.error("鎺ㄩ�佸け璐�");
+        }
+    }
+
 
     /**
      * 淇敼鐗╂枡閲囬泦
@@ -175,8 +211,4 @@
         return daMaterialCollectionMapper.deleteDaMaterialCollectionById(id);
     }
 
-    @Override
-    public void plusSave(DaMaterialCollection daMaterialCollection) {
-        this.save(daMaterialCollection);
-    }
-}
+}
\ No newline at end of file
diff --git a/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java b/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java
index 7d0b0b8..e92c791 100644
--- a/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java
+++ b/billion-main/src/main/java/com/billion/main/plcServer/sub/OPCUaSubscription.java
@@ -132,42 +132,45 @@
                                     miloService.writeToOpcUa(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".SerialNumber").value(SerialNumber).build());
                                 }
                                 //9L鍙戝姩鏈烘秱鑳惰建杩逛笅鍙�
-                                else if(Constants.OP080.equals(device) && Constants.PLC_4.equals(thoroughfare)){
-                                    // 1. 鍒濆鍖栧伐鍗曞璞″苟鏌ヨ宸ュ崟淇℃伅
-                                    String workOrderNo = resultList.get(0).getWorkOrderNo();
-                                    OmProductionOrderInfo queryOrder = new OmProductionOrderInfo();
-                                    queryOrder.setWorkOrderNo(workOrderNo);
-                                    List<OmProductionOrderInfo> orderList = omProductionOrderInfoService.selectOmProductionOrderInfoList(queryOrder);
-                                    // 2. 鍒ゆ柇绫诲瀷鍒嗘敮閫昏緫
-                                    String engineName = orderList.get(0).getEngineName();
-                                    if (!"9L".equals(engineName)) {
-                                        // 闈�9L鐩存帴鍐�0
-                                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".GlueType").value(0).build());
-                                    } else {
-                                        // 3. 鏌ヨ浜х嚎閰嶇疆鐨勪袱鏉¢缃暟鎹�
-                                        BsLineInfo lineQuery = new BsLineInfo();
-                                        lineQuery.setLineCode(engineName);  // 鍋囪閫氳繃lineCode=9L鑾峰彇涓ゆ潯鏁版嵁
-                                        List<BsLineInfo> configuredLines = bsLineInfoService.selectBsLineInfoList(lineQuery);
-                                            // 绗竴鏉¢厤缃暟鎹殑鏍¢獙
-                                            BsLineInfo firstLine = configuredLines.get(0);
-                                            BsBomChildInfo checkFirst  = new BsBomChildInfo();
-                                            checkFirst.setMaterialCode(firstLine.getLineName());
-                                            checkFirst.setBomCode(workOrderNo);
-                                            List<BsBomChildInfo> firstCheckList = bsBomChildInfoService.selectBsBomChildInfoList(checkFirst);
-                                            if (firstCheckList.size() == 1) {
-                                                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".GlueType").value(1).build());
-                                            } else {
-                                                // 绗簩鏉¢厤缃暟鎹殑鏍¢獙
-                                                BsLineInfo secondLine = configuredLines.get(1);
-                                                BsBomChildInfo checkSecond  = new BsBomChildInfo();
-                                                checkSecond.setMaterialCode(secondLine.getLineName());
-                                                checkSecond.setBomCode(workOrderNo);
-                                                List<BsBomChildInfo> secondCheckList = bsBomChildInfoService.selectBsBomChildInfoList(checkSecond);
-                                                if (secondCheckList.size() == 1) {
-                                                    miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".GlueType").value(2).build());
-                                                }
-                                            }
-                                    }
+                                 if(Constants.OP080.equals(device) ){
+                                     if(Constants.PLC_4.equals(thoroughfare)){
+                                         // 1. 鍒濆鍖栧伐鍗曞璞″苟鏌ヨ宸ュ崟淇℃伅
+                                         String workOrderNo = resultList.get(0).getWorkOrderNo();
+                                         OmProductionOrderInfo queryOrder = new OmProductionOrderInfo();
+                                         queryOrder.setWorkOrderNo(workOrderNo);
+                                         List<OmProductionOrderInfo> orderList = omProductionOrderInfoService.selectOmProductionOrderInfoList(queryOrder);
+                                         // 2. 鍒ゆ柇绫诲瀷鍒嗘敮閫昏緫
+                                         String engineName = orderList.get(0).getEngineName();
+                                         if (!"9L".equals(engineName)) {
+                                             // 闈�9L鐩存帴鍐�0
+                                             miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".GlueType").value(0).build());
+                                         } else {
+                                             // 3. 鏌ヨ浜х嚎閰嶇疆鐨勪袱鏉¢缃暟鎹�
+                                             BsLineInfo lineQuery = new BsLineInfo();
+                                             lineQuery.setLineCode(engineName);  // 鍋囪閫氳繃lineCode=9L鑾峰彇涓ゆ潯鏁版嵁
+                                             List<BsLineInfo> configuredLines = bsLineInfoService.selectBsLineInfoList(lineQuery);
+                                             // 绗竴鏉¢厤缃暟鎹殑鏍¢獙
+                                             BsLineInfo firstLine = configuredLines.get(0);
+                                             BsBomChildInfo checkFirst  = new BsBomChildInfo();
+                                             checkFirst.setMaterialCode(firstLine.getLineName());
+                                             checkFirst.setBomCode(workOrderNo);
+                                             List<BsBomChildInfo> firstCheckList = bsBomChildInfoService.selectBsBomChildInfoList(checkFirst);
+                                             if (firstCheckList.size() == 1) {
+                                                 miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".GlueType").value(1).build());
+                                             } else {
+                                                 // 绗簩鏉¢厤缃暟鎹殑鏍¢獙
+                                                 BsLineInfo secondLine = configuredLines.get(1);
+                                                 BsBomChildInfo checkSecond  = new BsBomChildInfo();
+                                                 checkSecond.setMaterialCode(secondLine.getLineName());
+                                                 checkSecond.setBomCode(workOrderNo);
+                                                 List<BsBomChildInfo> secondCheckList = bsBomChildInfoService.selectBsBomChildInfoList(checkSecond);
+                                                 if (secondCheckList.size() == 1) {
+                                                     miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".GlueType").value(2).build());
+                                                 }
+                                             }
+                                         }
+                                     }
+
                                 }
                                 String getWorkOrderNo = resultList.get(0).getWorkOrderNo();
                                 BsBomChildInfo bsbomChildInfo= new BsBomChildInfo();
@@ -282,56 +285,56 @@
                         if (Objects.equals(nowQty, getPreOrder2.getPlanQty().toString())){
                             omProductionOrderInfoService.updatePreStatus2();
                         }
-//                    }else if (Constants.OP020.equals(device)){
-//                        final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-//                        // 閬嶅巻 MaterialCode35 鍒� MaterialCode40 鍏�6缁勬暟鎹�
-//                        for (int i = 35; i <= 40; i++) {  // 淇敼寰幆鑼冨洿
-//                                // 鏋勫缓OPC UA鑺傜偣鍦板潃锛堜緥濡傦細PLC1.OP020.MaterialCode35锛�
-//                                String nodeId = "PLC2." + device + ".MaterialCode" + i;
-//                                // 鍒涘缓閲囬泦瀵硅薄
-//                                DaMaterialCollection materialCollection = new DaMaterialCollection();
-//                                materialCollection.setSfcCode(SFCCode.toString());
-//                                materialCollection.setLocationCode(device);
-//                                // 璁剧疆鍙傛暟鍚嶇О锛堟椿濉�1鍒版椿濉�6锛�
-//                                int pistonNumber = i - 34;  // 35鈫�1, 36鈫�2...40鈫�6
-//                                materialCollection.setParamName("娲诲" + pistonNumber);
-//                                // 閫氳繃OPC UA璇诲彇鍙傛暟鍊�
-//                                ReadWriteEntity dataRead = miloService.readFromOpcUa(nodeId);
-//                                if (dataRead != null && dataRead.getValue() != null && !Objects.equals(dataRead.getValue(), "                                                  ")) {
-//                                    materialCollection.setParamValue(dataRead.getValue().toString());
-//                                    Date collectTime = new Date();
-//                                    ReadWriteEntity collectTimeRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StopTime");//杩涚珯鏃堕棿
-//                                    collectTime = format.parse(TimeUtil.test(TimeUtil.stringProcessing(collectTimeRead.getValue().toString())));
-//                                    materialCollection.setCollectTime( collectTime);
-//                                    // 鎻掑叆鏁版嵁搴�
-//                                    daMaterialCollectionService.insertDaMaterialCollection(materialCollection);
-//                                } else {
-//                                    log.info("娲诲鍙蜂负绌�: {}",materialCollection.getParamName() );
-//                                }
-//                        }
-//                    }else if (Constants.OP130.equals(device)){
-//                        final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-//                        // 閬嶅巻 MaterialCode35 鍒� MaterialCode40 鍏�6缁勬暟鎹�
-//                            String nodeId = "PLC3." + device + ".MaterialCode35" ;
-//                            // 鍒涘缓閲囬泦瀵硅薄
-//                            DaMaterialCollection materialCollection = new DaMaterialCollection();
-//                            materialCollection.setSfcCode(SFCCode.toString());
-//                            materialCollection.setLocationCode(device);
-//                            materialCollection.setParamName("缂哥洊鐮�");
-//                            // 閫氳繃OPC UA璇诲彇鍙傛暟鍊�
-//                            ReadWriteEntity dataRead = miloService.readFromOpcUa(nodeId);
-//                            if (dataRead != null && dataRead.getValue() != null && !Objects.equals(dataRead.getValue(), "                                                  ")) {
-//                                materialCollection.setParamValue(dataRead.getValue().toString());
-//                                Date collectTime = new Date();
-//                                ReadWriteEntity collectTimeRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StopTime");//杩涚珯鏃堕棿
-//                                collectTime = format.parse(TimeUtil.test(TimeUtil.stringProcessing(collectTimeRead.getValue().toString())));
-//                                materialCollection.setCollectTime( collectTime);
-//                                // 鎻掑叆鏁版嵁搴�
-//                                daMaterialCollectionService.insertDaMaterialCollection(materialCollection);
-//                            } else {
-//                                log.info("缂哥洊鐮佷负绌�: {}",materialCollection.getParamName() );
-//                            }
-
+                    }
+                    else if (Constants.OP020.equals(device)){
+                        final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                        // 閬嶅巻 MaterialCode35 鍒� MaterialCode40 鍏�6缁勬暟鎹�
+                        for (int i = 35; i <= 40; i++) {  // 淇敼寰幆鑼冨洿
+                                // 鏋勫缓OPC UA鑺傜偣鍦板潃锛堜緥濡傦細PLC1.OP020.MaterialCode35锛�
+                                String nodeId = "PLC2." + device + ".MaterialCode" + i;
+                                // 鍒涘缓閲囬泦瀵硅薄
+                                DaMaterialCollection materialCollection = new DaMaterialCollection();
+                                materialCollection.setSfcCode(SFCCode.toString());
+                                materialCollection.setLocationCode(device);
+                                // 璁剧疆鍙傛暟鍚嶇О锛堟椿濉�1鍒版椿濉�6锛�
+                                int pistonNumber = i - 34;  // 35鈫�1, 36鈫�2...40鈫�6
+                                materialCollection.setParamName("娲诲" + pistonNumber);
+                                // 閫氳繃OPC UA璇诲彇鍙傛暟鍊�
+                                ReadWriteEntity dataRead = miloService.readFromOpcUa(nodeId);
+                                if (dataRead != null && dataRead.getValue() != null && !Objects.equals(dataRead.getValue(), "                                                  ")) {
+                                    materialCollection.setParamValue(dataRead.getValue().toString());
+                                    Date collectTime = new Date();
+                                    ReadWriteEntity collectTimeRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StopTime");//杩涚珯鏃堕棿
+                                    collectTime = format.parse(TimeUtil.test(TimeUtil.stringProcessing(collectTimeRead.getValue().toString())));
+                                    materialCollection.setCollectTime( collectTime);
+                                    // 鎻掑叆鏁版嵁搴�
+                                    daMaterialCollectionService.plusSave(materialCollection);
+                                } else {
+                                    log.info("娲诲鍙蜂负绌�: {}",materialCollection.getParamName() );
+                                }
+                        }
+                    }else if (Constants.OP130.equals(device)){
+                        final SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+                        // 閬嶅巻 MaterialCode35 鍒� MaterialCode40 鍏�6缁勬暟鎹�
+                            String nodeId = "PLC3." + device + ".MaterialCode35" ;
+                            // 鍒涘缓閲囬泦瀵硅薄
+                            DaMaterialCollection materialCollection = new DaMaterialCollection();
+                            materialCollection.setSfcCode(SFCCode.toString());
+                            materialCollection.setLocationCode(device);
+                            materialCollection.setParamName("缂哥洊鐮�");
+                            // 閫氳繃OPC UA璇诲彇鍙傛暟鍊�
+                            ReadWriteEntity dataRead = miloService.readFromOpcUa(nodeId);
+                            if (dataRead != null && dataRead.getValue() != null && !Objects.equals(dataRead.getValue(), "                                                  ")) {
+                                materialCollection.setParamValue(dataRead.getValue().toString());
+                                Date collectTime = new Date();
+                                ReadWriteEntity collectTimeRead = miloService.readFromOpcUa(thoroughfare + "." + device + ".StopTime");//杩涚珯鏃堕棿
+                                collectTime = format.parse(TimeUtil.test(TimeUtil.stringProcessing(collectTimeRead.getValue().toString())));
+                                materialCollection.setCollectTime( collectTime);
+                                // 鎻掑叆鏁版嵁搴�
+                                daMaterialCollectionService.plusSave(materialCollection);
+                            } else {
+                                log.info("缂哥洊鐮佷负绌�: {}",materialCollection.getParamName() );
+                            }
                     }
                     //鍑虹珯淇濆瓨
                     DaStationCollection daStationCollection = new DaStationCollection();
@@ -355,7 +358,6 @@
                     daCollectionParamConf1.setDescriptive("1");
                     List<DaCollectionParamConf> daCollectionParamConfList1 = daCollectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf1);
                     for (DaCollectionParamConf conf : daCollectionParamConfList1) {
-                        String index = String.valueOf(daCollectionParamConfList1.indexOf(conf));
                         String gatherAddress = conf.getGatherAddress();
                         String valueObj = null;
                         ReadWriteEntity entity = miloService.readFromOpcUa(gatherAddress);
@@ -365,7 +367,7 @@
                                 valueObj = value.toString();  // 鏈�缁堣祴鍊�
                                 if (!Objects.equals(valueObj, "                                                  ")) {
                                     DaMaterialCollection materialCollection = new DaMaterialCollection();
-                                    materialCollection.setRemark(index);
+
                                     materialCollection.setSfcCode(SFCCode.toString());
                                     materialCollection.setLocationCode(device);
                                     materialCollection.setParamName(conf.getParameterSetName());
diff --git a/billion-main/src/main/resources/mapper/om/OmProductionOrderInfoMapper.xml b/billion-main/src/main/resources/mapper/om/OmProductionOrderInfoMapper.xml
index a4b609c..c6ad2c2 100644
--- a/billion-main/src/main/resources/mapper/om/OmProductionOrderInfoMapper.xml
+++ b/billion-main/src/main/resources/mapper/om/OmProductionOrderInfoMapper.xml
@@ -33,7 +33,10 @@
     </resultMap>
 
     <sql id="selectOmProductionOrderInfoVo">
-        select id,body_status,head_status,pre_status,body_qty,head_qty,pre_qty,work_order_no, sales_order_code, product_code, line_code, plan_qty, plan_start_time, plan_end_time, order_status, create_time, update_time, create_by, update_by, remarks, del_flag from om_production_order_info
+        select id,body_status,head_status,pre_status,body_qty,head_qty,pre_qty,
+               work_order_no, sales_order_code, product_code, line_code, plan_qty,
+               plan_start_time, plan_end_time, order_status, create_time, update_time, create_by,
+               update_by, remarks, del_flag,engine_type,engine_name,flag from om_production_order_info
     </sql>
 
     <!-- 鏌ヨ order_status 涓� 1 涓� plan_start_time 鏈�鏃╃殑涓�鏉¤褰� -->
@@ -128,6 +131,7 @@
             <if test="salesOrderCode != null  and salesOrderCode != ''"> and sales_order_code = #{salesOrderCode}</if>
             <if test="productCode != null  and productCode != ''"> and product_code = #{productCode}</if>
             <if test="orderStatus != null  and orderStatus != ''"> and order_status = #{orderStatus}</if>
+            <if test="engineName != null  and engineName != ''"> and engine_name = #{engineName}</if>
             and del_flag = 0
         </where>
     </select>

--
Gitblit v1.9.3