From bdb4046a1ed5358a94cc9ce846f2a1ec88e5d5ec Mon Sep 17 00:00:00 2001
From: admin <15939171744@163.com>
Date: 星期二, 18 六月 2024 10:51:57 +0800
Subject: [PATCH] -

---
 jcdm-ui/src/views/main/kb/preInstalledTerminal/index.vue                                                |   71 ++++++-----
 jcdm-ui/src/views/main/kb/heatingFilmTerminal/index.vue                                                 |   13 --
 jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/impl/BsFormulaChildInfoServiceImpl.java   |   42 ++++--
 jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/IBsFormulaChildInfoService.java           |    3 
 jcdm-ui/src/views/main/kb/stationTerminal/index.vue                                                     |   21 ++-
 jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/controller/BsFormulaChildInfoController.java      |   29 ++++
 jcdm-ui/src/api/main/bs/formulaChild/formulaChild.js                                                    |   10 +
 jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java |   15 ++
 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java                              |  103 +++++++---------
 9 files changed, 182 insertions(+), 125 deletions(-)

diff --git a/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/controller/BsFormulaChildInfoController.java b/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/controller/BsFormulaChildInfoController.java
index b33d274..a77d9ca 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/controller/BsFormulaChildInfoController.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/controller/BsFormulaChildInfoController.java
@@ -48,14 +48,30 @@
      * 鎵爜纭
      */
     @GetMapping("/fistSetpNumber")
-    public void fistSetpNumber(BsFormulaChildInfo bsFormulaChildInfo)
+    public AjaxResult fistSetpNumber(BsFormulaChildInfo bsFormulaChildInfo)
     {
+//        try {
+//            String str = "PACK."+bsFormulaChildInfo.getProcessesCode()+".MStepNumber";
+//            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(str).value(1).build());
+//        } catch (Exception e) {
+//            throw new RuntimeException(e);
+//        }
+        Integer stepNumber = 1;
         try {
+            List<BsFormulaChildInfo> op260 = bsFormulaChildInfoService.list(new LambdaQueryWrapper<BsFormulaChildInfo>().eq(BsFormulaChildInfo::getProcessesCode, bsFormulaChildInfo.getProcessesCode()));
+            List<BsFormulaChildInfo> filteredList = op260.stream()
+                    .filter(obj -> obj.getResults() != null && !obj.getResults().isEmpty())
+                    .collect(Collectors.toList());
+            if(filteredList.size() > 0){
+                stepNumber = Integer.valueOf(filteredList.get(filteredList.size()-1).getStepSort())+1;
+            }
+
             String str = "PACK."+bsFormulaChildInfo.getProcessesCode()+".MStepNumber";
-            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(str).value(1).build());
+            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(str).value(stepNumber).build());
         } catch (Exception e) {
             throw new RuntimeException(e);
         }
+        return AjaxResult.success(stepNumber);
     }
 
     /**
@@ -164,6 +180,15 @@
     /**
      * 鏀捐璇风┖鐘舵��
      */
+    @GetMapping("/checkMaterialCode")
+    public AjaxResult checkMaterialCode(BsFormulaChildInfo bsFormulaChildInfo)
+    {
+        return bsFormulaChildInfoService.checkMaterialCode(bsFormulaChildInfo);
+    }
+
+    /**
+     * 鏀捐璇风┖鐘舵��
+     */
     @GetMapping("/clearWorkpieceRelease")
     public AjaxResult clearWorkpieceRelease(BsFormulaChildInfo bsFormulaChildInfo)
     {
diff --git a/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/IBsFormulaChildInfoService.java b/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/IBsFormulaChildInfoService.java
index 0bebc3e..c71dd8f 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/IBsFormulaChildInfoService.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/IBsFormulaChildInfoService.java
@@ -85,4 +85,7 @@
     AjaxResult jrmWorkpieceRelease(BsFormulaChildInfo bsFormulaChildInfo);
 
     AjaxResult clearWorkpieceRelease(BsFormulaChildInfo bsFormulaChildInfo);
+
+    AjaxResult checkMaterialCode(BsFormulaChildInfo bsFormulaChildInfo);
+
 }
diff --git a/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/impl/BsFormulaChildInfoServiceImpl.java b/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/impl/BsFormulaChildInfoServiceImpl.java
index 8350814..a83227a 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/impl/BsFormulaChildInfoServiceImpl.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/bs/formulaChild/service/impl/BsFormulaChildInfoServiceImpl.java
@@ -214,16 +214,16 @@
     public AjaxResult yzUpdateTighteningFormula(BsFormulaChildInfo bsFormulaChildInfo) {
         Boolean b = true;
         String result = "1";
-        BsFormulaChildInfo getMaterTwo = new BsFormulaChildInfo();
-        getMaterTwo.setProcessesCode(bsFormulaChildInfo.getLocationCode());
-        getMaterTwo.setOperationType("2");
-        List<BsFormulaChildInfo> operationType = bsFormulaChildInfoMapper.selectBsFormulaChildInfoList(getMaterTwo);
-        List<String> collect = operationType.stream().map(BsFormulaChildInfo::getResults).collect(Collectors.toList());
-        for (String s : collect) {
-            if(s.equals("")){
-//                return AjaxResult.success("鎵弿鏈畬鎴愶紝绂佹鎷х揣鎿嶄綔锛�");
-            }
-        }
+//        BsFormulaChildInfo getMaterTwo = new BsFormulaChildInfo();
+//        getMaterTwo.setProcessesCode(bsFormulaChildInfo.getLocationCode());
+//        getMaterTwo.setOperationType("2");
+//        List<BsFormulaChildInfo> operationType = bsFormulaChildInfoMapper.selectBsFormulaChildInfoList(getMaterTwo);
+//        List<String> collect = operationType.stream().map(BsFormulaChildInfo::getResults).collect(Collectors.toList());
+//        for (String s : collect) {
+//            if(s.equals("")){
+////                return AjaxResult.success("鎵弿鏈畬鎴愶紝绂佹鎷х揣鎿嶄綔锛�");
+//            }
+//        }
         BsFormulaChildInfo listQuery = new BsFormulaChildInfo();
         listQuery.setParamCode(bsFormulaChildInfo.getParamCode());
         listQuery.setProcessesCode(bsFormulaChildInfo.getLocationCode());
@@ -319,7 +319,7 @@
 //                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+strA+".RecordDataDone").value(21).build());
 //                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+strB+".RecordDataDone").value(21).build());
                         String locationCode = bsFormulaChildInfo.getLocationCode();
-                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+locationCode+".RecordDataDone").value(21).build());
+//                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+locationCode+".RecordDataDone").value(21).build());
                     } catch (Exception e) {
                         throw new RuntimeException(e);
                     }
@@ -373,6 +373,22 @@
     }
 
     @Override
+    public AjaxResult checkMaterialCode(BsFormulaChildInfo bsFormulaChildInfo) {
+        String result = "1";
+        BsFormulaChildInfo getMaterTwo = new BsFormulaChildInfo();
+        getMaterTwo.setProcessesCode(bsFormulaChildInfo.getLocationCode());
+        getMaterTwo.setOperationType("2");
+        List<BsFormulaChildInfo> operationType = bsFormulaChildInfoMapper.selectBsFormulaChildInfoList(getMaterTwo);
+        List<String> collect = operationType.stream().map(BsFormulaChildInfo::getResults).collect(Collectors.toList());
+        for (String s : collect) {
+            if(s.equals("")){
+                result = "2";
+            }
+        }
+        return AjaxResult.success(result);
+    }
+
+    @Override
     public BsFormulaChildInfo releaseCheck(BsFormulaChildInfo bsFormulaChildInfo) {
         return bsFormulaChildInfoMapper.releaseCheck(bsFormulaChildInfo);
     }
@@ -415,7 +431,7 @@
                 if(bsFormulaChildInfos.get(0).getSpareField4().equals("1")){
                     try {
                         result = "3";
-                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".RecordDataDone").value(21).build());
+//                        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".RecordDataDone").value(21).build());
                     } catch (Exception e) {
                         throw new RuntimeException(e);
                     }
@@ -563,7 +579,7 @@
     //                        List<DaPassingStationCollection> daPassingStationCollections = daPassingStationCollectionMapper.selectDaPassingStationCollectionList(daPassingStationCollection);
     //                        daPassingStationCollections.get(0).setOutboundTime(new Date());
     //                        daPassingStationCollectionMapper.updateDaPassingStationCollection(daPassingStationCollections.get(0));
-                            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".RecordDataDone").value(21).build());
+//                            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier("PACK."+bsFormulaChildInfo.getLocationCode()+".RecordDataDone").value(21).build());
                             WebSocketUsers.sendMessageToUserByText(map.get(bsFormulaChildInfo.getLocationCode()), "OUT");
                         } catch (Exception e) {
                             throw new RuntimeException(e);
diff --git a/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java b/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java
index 92bc866..8705ccc 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/da/paramCollection/service/impl/DaParamCollectionServiceImpl.java
@@ -36,9 +36,12 @@
 import com.jcdm.main.restful.qingYan.doman.ParentVO;
 import com.kangaroohy.milo.model.ReadWriteEntity;
 import com.kangaroohy.milo.service.MiloService;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.ibatis.session.ExecutorType;
 import org.apache.ibatis.session.SqlSession;
 import org.apache.ibatis.session.SqlSessionFactory;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.security.core.parameters.P;
 import org.springframework.stereotype.Service;
@@ -55,9 +58,12 @@
  * @author yyt
  * @date 2023-12-13
  */
+@Slf4j
 @Service
 public class DaParamCollectionServiceImpl extends ServiceImpl<DaParamCollectionMapper,DaParamCollection> implements IDaParamCollectionService
 {
+    private static final Logger logger = LoggerFactory.getLogger("sys-user");
+
     @Autowired
     private DaParamCollectionMapper daParamCollectionMapper;
 
@@ -119,6 +125,7 @@
         // ExecutorType.SIMPLE: 杩欎釜鎵ц鍣ㄧ被鍨嬩笉鍋氱壒娈婄殑浜嬫儏銆傚畠涓烘瘡涓鍙ョ殑鎵ц鍒涘缓涓�涓柊鐨勯澶勭悊璇彞銆�
         // ExecutorType.REUSE: 杩欎釜鎵ц鍣ㄧ被鍨嬩細澶嶇敤棰勫鐞嗚鍙ャ��
         // ExecutorType.BATCH: 杩欎釜鎵ц鍣ㄤ細鎵归噺鎵ц鎵�鏈夋洿鏂拌鍙�,濡傛灉 SELECT 鍦ㄥ畠浠腑闂存墽琛岃繕浼氭爣瀹氬畠浠槸 蹇呴』鐨�,鏉ヤ繚璇佷竴涓畝鍗曞苟鏄撲簬鐞嗚В鐨勮涓恒��
+        logger.info("杩涘叆涔愬伐鎵归噺鏂规硶saveBeachDaParamCollection");
 
         // 鍏抽棴session鐨勮嚜鍔ㄦ彁浜�
         SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
@@ -128,6 +135,8 @@
             // 鎻愪氦鏁版嵁
             sqlSession.commit();
             sqlSession.rollback();
+            logger.info("缁撴潫涔愬伐鎵归噺鏂规硶saveBeachDaParamCollection");
+
         } catch (Exception e) {
             sqlSession.rollback();
         } finally {
@@ -519,11 +528,13 @@
 
     @Override
     public void automaticWorkstationPushGeelycvMesFeedback(String packID, String stationCode,List<DaParamCollection> paramList) {
+        logger.info("杩涘叆宸ヤ綅{}-宸ュ巶MES鎺ㄩ�佹暟鎹柟娉昦utomaticWorkstationPushGeelycvMesFeedback",stationCode);
         SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 //        String url = "https://imes-uat-group.geelycv-test.com/api/mom-open/restful/aMesSysIntegration/deviceResultFeedback";
         String url = "https://imes-group.geelycv.com/api/mom-open/restful/aMesSysIntegration/deviceResultFeedback";
         String totalResult = "0";
         if(paramList.size() > 0){
+            logger.info("杩涘叆宸ヤ綅{}-鎷兼暟鎹�",stationCode);
             ParentVO parentVO = new ParentVO();
             parentVO.setSiteCode("3983");
             parentVO.setRecordId(String.valueOf(Instant.now().toEpochMilli()));
@@ -571,10 +582,14 @@
                 listChildVo.add(childVO);
             }
             parentVO.setCheckList(listChildVo);
+            logger.info("缁撴潫宸ヤ綅{}-鎷兼暟鎹�",stationCode);
+            logger.info("杩涘叆宸ヤ綅{}-宸ュ巶MES鎺ㄩ�佹暟鎹柟娉旽ttpResponseSend",stationCode);
             HttpResponse execute = HttpRequest.post(url).body(JSONUtil.toJsonStr(parentVO)).execute();
+            logger.info("缁撴潫宸ヤ綅{}-宸ュ巶MES鎺ㄩ�佹暟鎹柟娉旽ttpResponseSend",stationCode);
             System.out.println(execute.body());
             System.out.println("-----------------------"+totalResult);
         }
+        logger.info("缁撴潫宸ヤ綅{}-宸ュ巶MES鎺ㄩ�佹暟鎹柟娉昦utomaticWorkstationPushGeelycvMesFeedback",stationCode);
     }
 
     @Override
diff --git a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
index 99ba9d3..52c039b 100644
--- a/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
+++ b/jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java
@@ -193,10 +193,10 @@
                         if(automaticList.stream().anyMatch(s -> s.equals(device))){
                             //鑷姩宸ヤ綅
                             //鍑虹珯淇濆瓨鏁版嵁
-                            recordDataDoneValue = outSaveDate(thoroughfare,device);
+                            outSaveDate(thoroughfare,device);
                             //璁板綍鏁版嵁瀹屾垚
-                            String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
-                            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(recordDataDoneValue)).build());
+                            /*String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
+                            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf(recordDataDoneValue)).build());*/
                         }else {
                             //鎵嬪姩宸ヤ綅
 //                            if(device.contains("OP330")){
@@ -271,26 +271,22 @@
     /**
      * 鍑虹珯淇濆瓨鏁版嵁
      */
-    public String outSaveDate(String thoroughfare,String device) {
+    public void outSaveDate(String thoroughfare,String device) {
         String snCode = "";
         String result = "";
         String read = thoroughfare + "." + device + ".";
 
         try {
-            if(nullList.stream().noneMatch(s -> s.equals(device))){
+            if(nullList.stream().noneMatch(s -> s.equals(device))){//鍒犻櫎鈥︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹�︹��
                 if(moduleCodeList.stream().anyMatch(s -> s.equals(device))){
                     read = read + "ModuleCode";
-
                 }else {
                     read = read + "PACKCode";
                 }
             }
             if(device.equals("OP365")){
                 try {
-                    result = saveStationInfo365(thoroughfare,device);
-                    return result;
-//                    return saveStationInfo365(thoroughfare,device);
-//                    return result;
+                   saveStationInfo365(thoroughfare,device);
                 }catch (Exception e){
                     e.printStackTrace();
                 }
@@ -298,7 +294,8 @@
                 snCode = miloService.readFromOpcUa(read).getValue().toString();
 
                 if(null == snCode || "".equals(snCode)){
-                    result = "22";
+                    String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
+                    miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf("22")).build());
                 }else{
 
                     String workOrderNo = "";
@@ -324,19 +321,17 @@
                         //1銆佹洿鏂板伐鍗曚俊鎭�
                         updateOrderInfo(snCode);
                     }
+
                     try{
                         daParamCollectionService.automaticWorkstationPushGeelycvMesFeedback(snCode,device,daParamCollectionList);
                     }catch (Exception e){
                     }
-                    result = "21";
-
                 }
 
             }
         }catch (Exception e) {
             logger.error("鍑虹珯淇濆瓨鏁版嵁寮傚父锛�"+e);
         }
-        return result;
     }
 
 
@@ -374,6 +369,7 @@
      * 淇濆瓨杩囩珯閲囬泦
      */
     public void saveStationInfo(String packCode,String thoroughfare,String device,String workOrderNo,String productCode) throws Exception {
+        logger.info("杩涘叆宸ヤ綅{}-鏂规硶saveStationInfo",device);
         SimpleDateFormat sdf = new SimpleDateFormat("EEE MMM dd HH:mm:ss zzz yyyy", Locale.US);
         sdf.setTimeZone(TimeZone.getTimeZone("GMT+8")); // CST閫氬父琛ㄧず涓浗鏍囧噯鏃堕棿锛屽嵆涓滃叓鍖�
         String prefix = thoroughfare+"."+device+".";
@@ -392,9 +388,11 @@
         daPassingStationCollection.setOutboundTime(format.parse(TimeUtil.test(end)));//鍑虹珯鏃堕棿
         daPassingStationCollection.setOutRsSign(stationStatus);//鍑虹珯鏄惁鍚堟牸
         daPassingStationCollectionService.insertDaPassingStationCollection(daPassingStationCollection);
+        logger.info("缁撴潫宸ヤ綅{}-鏂规硶saveStationInfo",device);
     }
 
     public static List<DaParamCollection> SaveParamData(String packCode,String thoroughfare,String device,String workOrderNo,String productType) throws Exception {
+        logger.info("杩涘叆宸ヤ綅{}-鏂规硶SaveParamData",device);
         List<DaCollectionParamConf> list;
         DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
         daCollectionParamConf.setGatherAddress(thoroughfare+ "." + device);
@@ -408,54 +406,47 @@
 
         if(!nodeIdList.isEmpty()){
             List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList);
-            for (int i = 0; i < readWriteEntityList.size(); i++) {
+            for(int i=0;i<nodeIdList.size();i++){
                 if(readWriteEntityList.get(i).getValue() == null){
                     readWriteEntityList.get(i).setValue(" ");
                 }
-            }
-
-            for(int i=0;i<nodeIdList.size();i++){
-                if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){
-                    String tt = readWriteEntityList.get(i).getValue().toString();
-                    DaParamCollection ParamCollection = new DaParamCollection();
-                    ChildVO childVO = new ChildVO();
-                    ParamCollection.setParamCode(list.get(i).getCollectParameterId());
-                    ParamCollection.setLocationCode(device);
-                    if(tt.contains("Time")){
-//                        String str = TimeUtil.getTimestamp(TimeUtil.stringProcessing(tt));
-//                        ParamCollection.setParamValue(str);
-                        ParamCollection.setParamValue(TimeUtil.test(TimeUtil.stringProcessing(tt)));
-                    }else {
-                        ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
-                    }
-                    ParamCollection.setSfcCode(packCode);
-                    if(device.contains("OP360")){
-                        String node = nodeIdList.get(i);
-                        Object value = miloService.readFromOpcUa("PACK.OP360.ModuleSNCode"+node.charAt(node.length()-1)).getValue();
-                        if(value!=null){
-                            ParamCollection.setModuleCode(value.toString());
-                        }
-                    }
-                    ParamCollection.setParamName(list.get(i).getCollectParameterName());
-                    ParamCollection.setParamUpper(list.get(i).getParamUpper());
-                    ParamCollection.setParamLower(list.get(i).getParamLower());
-                    ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
-                    //ParamCollection.setState("鍚堟牸");
-                    ParamCollection.setType(list.get(i).getCollectParameterType());
-                    ParamCollection.setCollectionTime(new Date());
-                    ParamCollection.setWorkOrderNo(workOrderNo);
-                    ParamCollection.setProductCode(productType);
-                    daParamCollectionlist.add(ParamCollection);
-//                    daParamCollectionService.insertDaParamCollection(ParamCollection);
+                String paramValue = readWriteEntityList.get(i).getValue().toString();
+                DaParamCollection ParamCollection = new DaParamCollection();
+                ParamCollection.setParamCode(list.get(i).getCollectParameterId());
+                ParamCollection.setLocationCode(device);
+                if(paramValue.contains("Time")){
+                    ParamCollection.setParamValue(TimeUtil.test(TimeUtil.stringProcessing(paramValue)));
+                }else {
+                    ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
                 }
+                ParamCollection.setSfcCode(packCode);
+                if(device.contains("OP360")){
+                    String node = nodeIdList.get(i);
+                    Object value = miloService.readFromOpcUa("PACK.OP360.ModuleSNCode"+node.charAt(node.length()-1)).getValue();
+                    if(value!=null){
+                        ParamCollection.setModuleCode(value.toString());
+                    }
+                }
+                ParamCollection.setParamName(list.get(i).getCollectParameterName());
+                ParamCollection.setParamUpper(list.get(i).getParamUpper());
+                ParamCollection.setParamLower(list.get(i).getParamLower());
+                ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
+                ParamCollection.setType(list.get(i).getCollectParameterType());
+                ParamCollection.setCollectionTime(new Date());
+                ParamCollection.setWorkOrderNo(workOrderNo);
+                ParamCollection.setProductCode(productType);
+                daParamCollectionlist.add(ParamCollection);
             }
-            daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist);
-
         }
+        String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
+        miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(Integer.valueOf("21")).build());
+        logger.info("缁欏伐浣峽}鍐欎簡21",device);
+        daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist);
         List<DaParamCollection> baseDataList = addBaseData(workOrderNo,productType,device,packCode);
         for (int i = 0; i < baseDataList.size(); i++){
             daParamCollectionlist.add(baseDataList.get(i));
         }
+        logger.info("缁撴潫宸ヤ綅{}-鏂规硶SaveParamData",device);
         return daParamCollectionlist;
     }
 
@@ -575,7 +566,7 @@
     /**
      * 淇濆瓨杩囩珯閲囬泦
      */
-    public String saveStationInfo365(String thoroughfare,String device) throws Exception {
+    public void saveStationInfo365(String thoroughfare,String device) throws Exception {
         String RecordDataDoneAddress = thoroughfare + "." + device + ".RecordDataDone";
         String prefix = thoroughfare+"."+device+".";
         List<DaPassingStationCollection> passingStationCollections = new ArrayList<>();
@@ -612,13 +603,11 @@
                 passingStationCollections.add(daPassingStationCollection);
             }
             daPassingStationCollectionService.saveBeachDaPassingStationCollection(passingStationCollections);
-//            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build());
+            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(21).build());
             logger.info("宸ヤ綅{}鍥炲21",device);
 
-            return "21";
         }else {
-//            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(22).build());
-            return "22";
+            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(RecordDataDoneAddress).value(22).build());
         }
     }
 
diff --git a/jcdm-ui/src/api/main/bs/formulaChild/formulaChild.js b/jcdm-ui/src/api/main/bs/formulaChild/formulaChild.js
index 1d5ad78..1abc42e 100644
--- a/jcdm-ui/src/api/main/bs/formulaChild/formulaChild.js
+++ b/jcdm-ui/src/api/main/bs/formulaChild/formulaChild.js
@@ -97,6 +97,16 @@
 }
 
 // 鏌ヨ閰嶆柟閰嶇疆瀛愪俊鎭垪琛�
+export function checkMaterialCode(query) {
+  return request({
+    url: '/bs/formulaChild/checkMaterialCode',
+    method: 'get',
+    params: query
+
+  })
+}
+
+// 鏌ヨ閰嶆柟閰嶇疆瀛愪俊鎭垪琛�
 export function yzUpdateTighteningFormula(query) {
   return request({
     url: '/bs/formulaChild/yzUpdateTighteningFormula',
diff --git a/jcdm-ui/src/views/main/kb/heatingFilmTerminal/index.vue b/jcdm-ui/src/views/main/kb/heatingFilmTerminal/index.vue
index 0bec12d..d9276f0 100644
--- a/jcdm-ui/src/views/main/kb/heatingFilmTerminal/index.vue
+++ b/jcdm-ui/src/views/main/kb/heatingFilmTerminal/index.vue
@@ -409,19 +409,6 @@
     serialLink() {
       this.open1 = true
     },
-    bindYzSfc(){
-      if(this.headContent.sfcCode!==""&&this.headContent.yzSfcCode!==""){
-        let param = {
-          sfcCode: this.headContent.sfcCode,
-          locationCode: this.headContent.processesCode,
-          yzSfcCode: this.headContent.yzSfcCode
-        }
-        this.$message('鍙互缁戝畾锛�');
-        replaceAssemblyCode(param).then(response => {
-
-        });
-      }
-    },
     Release(){
       // this.$message('portsList锛�'+this.portsList.length);
       if(this.btnType === "danger"){
diff --git a/jcdm-ui/src/views/main/kb/preInstalledTerminal/index.vue b/jcdm-ui/src/views/main/kb/preInstalledTerminal/index.vue
index c637493..68e47eb 100644
--- a/jcdm-ui/src/views/main/kb/preInstalledTerminal/index.vue
+++ b/jcdm-ui/src/views/main/kb/preInstalledTerminal/index.vue
@@ -189,6 +189,8 @@
 <script>
 import {getIpv4, listStationConf} from "@/api/main/sc/stationConf";
 import {
+  checkMaterialCode,
+  clearWorkpieceRelease,
   fistSetpNumber,
   noPageListFormulaChild,
   workpieceRelease,
@@ -325,20 +327,6 @@
     serialLink() {
       this.open1 = true
     },
-    bindYzSfc(){
-      if(this.headContent.sfcCode!==""&&this.headContent.yzSfcCode!==""){
-        let param = {
-          sfcCode: this.headContent.sfcCode,
-          locationCode: this.headContent.processesCode,
-          yzSfcCode: this.headContent.yzSfcCode
-        }
-        this.$message('鍙互缁戝畾锛�');
-        replaceAssemblyCode(param).then(response => {
-
-        });
-      }
-    },
-
     Release(){
       // this.$message('portsList锛�'+this.portsList.length);
       if(this.btnType === "danger"){
@@ -406,8 +394,14 @@
       console.log(tab, event);
     },
     clearClick(){
-      this.$message('杩欐槸涓�鏉℃竻闄ゆ秷鎭彁绀�');
-      this.headContent.sfcCode = null
+      const param = {
+        productCode: '1P102S',
+        locationCode: this.headContent.processesCode,
+      }
+      clearWorkpieceRelease(param).then(response => {});
+      this.headContent.sfcCode = ''
+      this.formulaChildList = [];
+      this.$message('娓呴櫎鎴愬姛锛�');
     },
     scanCompleted(){
       this.$message('鎵爜瀹屾垚'+this.content);
@@ -537,25 +531,36 @@
             self.$message('鏈壘鍒板弬鏁扮爜锛岃妫�鏌ュ弬鏁扮爜鏄惁姝g‘');
             return;
           }
-          addTighteningParameters(param).then(response => {});
-          yzUpdateTighteningFormula(param).then(response => {
-            console.log(response)
-            if(response.msg === "1" || response.msg === "3"){
-                self.getListFormulaChild()
-            }else {
-              const param = {
-                workOrderNo: self.workpieceInformation.workOrderNo,
-                productCode: "1P102S",
-                locationCode: self.headContent.processesCode,
-                productBarcode: self.headContent.sfcCode,
-              }
-              saveCampaignTimeParameters(param).then(response => {});
-              workpieceRelease(param).then(response => {});
-              self.formulaChildList = [];
-              self.headContent.sfcCode = '';
+          if(self.headContent.sfcCode === null||self.headContent.sfcCode ===''){
+            self.$message('鏈壘鍒版�绘垚鐮侊紝璇峰厛鎵爜锛�');
+            return;
+          }
+          checkMaterialCode(param).then(response => {
+            if(response.msg === "2"){
+              self.$message('鏈壂鎻忕墿鏂欑爜瀹屾瘯锛�');
+              return;
             }
           });
-          // self.getListFormulaChild()
+
+          yzUpdateTighteningFormula(param).then(response => {
+          console.log(response)
+          if(response.msg === "1" || response.msg === "3"){
+              self.getListFormulaChild()
+          }else {
+            const param = {
+              workOrderNo: self.workpieceInformation.workOrderNo,
+              productCode: "1P102S",
+              locationCode: self.headContent.processesCode,
+              productBarcode: self.headContent.sfcCode,
+            }
+            saveCampaignTimeParameters(param).then(response => {});
+            workpieceRelease(param).then(response => {});
+            self.formulaChildList = [];
+            self.headContent.sfcCode = '';
+          }
+        });
+        addTighteningParameters(param).then(response => {});
+        // self.getListFormulaChild()
 
         }
       };
diff --git a/jcdm-ui/src/views/main/kb/stationTerminal/index.vue b/jcdm-ui/src/views/main/kb/stationTerminal/index.vue
index ab5af44..b11f999 100644
--- a/jcdm-ui/src/views/main/kb/stationTerminal/index.vue
+++ b/jcdm-ui/src/views/main/kb/stationTerminal/index.vue
@@ -575,7 +575,7 @@
       this.endClear()
       clearWorkpieceRelease(param).then(response => {});
       this.headContent.sfcCode = ''
-      this.$message('娓呮鎴愬姛锛�');
+      this.$message('娓呴櫎鎴愬姛锛�');
     },
     scanCompleted(){
       this.$message('鎵爜瀹屾垚'+this.content);
@@ -602,6 +602,12 @@
       });
       this.getListFormulaChild()
       this.addOverStationCollection()
+      const param = {
+        processesCode: this.headContent.processesCode,
+      }
+      fistSetpNumber(param).then(response => {
+        console.log("fistSetpNumber------"+response.msg)
+      });
     },
 
     addBaseData(){
@@ -673,10 +679,10 @@
         if (event.data === "IN") {
           self.cakeLamp.InPlace = 1;
           console.log(self.headContent.processesCode);
-          const param = {
-            processesCode: self.headContent.processesCode,
-          }
-          fistSetpNumber(param).then(response => {});
+          // const param = {
+          //   processesCode: self.headContent.processesCode,
+          // }
+          // fistSetpNumber(param).then(response => {});
         } else if (event.data === "IN0") {
           self.cakeLamp.InPlace = 0;
         } else if (event.data === "OUT") {
@@ -782,11 +788,12 @@
         const scanValue = this.myserialport.hex2atostr(value).replace(/[\r\n]/g, '');
         console.log("涓插彛鏀跺埌鏁版嵁-------------------"+scanValue)
 
-        if(this.headContent.sfcCode !== ''){
+        if(this.headContent.sfcCode !== '' && this.headContent.sfcCode !== null
+          && this.headContent.sfcCode !== undefined){
           if(scanValue.includes("P9900173252")){
             this.headContent.yzSfcCode = scanValue
             this.bindYzSfc();
-          }else if(scanValue.includes("0RSP1TE")){
+          }else if(scanValue.includes("0RSP1TE") && this.headContent.processesCode === 'OP240'){
             this.headContent.cardCode = scanValue
             this.bindcardCode();
           }else {

--
Gitblit v1.9.3