From a9e8a91fd4c8c504d7df9ef921f32d832390e77d Mon Sep 17 00:00:00 2001
From: whycq <10027870+whycq@user.noreply.gitee.com>
Date: 星期五, 15 九月 2023 13:42:39 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/zjfnwcs' into zjfnwcs

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   46 ++++++++++++++++++++---
 src/main/resources/mapper/LocMastMapper.xml                 |    3 +
 src/main/webapp/views/monitor/index.html                    |    7 +--
 src/main/java/com/zy/core/thread/SiemensDevpThread.java     |    6 +++
 src/main/resources/application.yml                          |    2 
 5 files changed, 53 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index da6144a..35e24ad 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -96,6 +96,8 @@
 
     @Value("${test.url}")
     private String testUrl;
+    @Autowired
+    private WrkMastService wrkMastService;
 
     /**
      * 缁勬墭
@@ -907,6 +909,7 @@
                         break;
 //                        return;
                     }
+
 
                     // 1.鍫嗗灈鏈哄紑濮嬬Щ鍔�
                     CrnCommand crnCommand = new CrnCommand();
@@ -2348,6 +2351,7 @@
                 SiemensDevpThread devpThread = (SiemensDevpThread) SlaveConnection.get(SlaveType.Devp, devp.getId());
                 if(null != devpThread){
                     for (int i = 0; i < 48; i++){
+                        boolean fig=false;
                         //鏌ヨ鍦ㄥ簱鍜岄绾﹀嚭搴�
                         LocMast locMast=locMastService.selectztgx("F","R",i);
                         if(!Cools.isEmpty(locMast)){
@@ -2365,12 +2369,32 @@
 
                             //testMast.setStatus
                             //"鐘舵�� 0: 寰呯敵璇�  1: 鐢宠涓�  2: 宸插鏍� 3:娴嬭瘯涓� 4:瀹屾垚 5:绉诲簱 6:鐏"
-                            if(devpThread.startSignal[i][0]==1){
+                            if(devpThread.startSignal[i][0]==8){
                                 testMast.setStatus(1);
+                                locMast.setPackStatus(1);
                                 testMast.setModiTime(new Date());
-                            }else if(devpThread.startSignal[i][0]==2){
+                            }else if(devpThread.startSignal[i][0]==2 && locMast.getPackStatus()!=2){
                                 testMast.setStatus(3);
+                                locMast.setPackStatus(2);
                                 testMast.setModiTime(new Date());
+                                //NG杞琌K闇�瑕佽繕鍘熸簮搴撲綅鍜岀洰鏍囧簱浣嶇姸鎬侊紝OK杞琋G 鍒犻櫎浠诲姟妗�
+                                WrkMast wrkMast=wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("source_loc_no",locMast.getLocNo()));
+                                if(!Cools.isEmpty(wrkMast)){
+                                    if(wrkMast.getIoType()==11){
+                                        LocMast locMast1=locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no",wrkMast.getLocNo()));
+                                        locMast1.setLocSts("O");
+                                        locMastService.update(locMast1,new EntityWrapper<LocMast>().eq("loc_no",wrkMast.getLocNo()));
+                                    }
+                                    wrkMastMapper.delete(new EntityWrapper<WrkMast>().eq("source_loc_no",locMast.getLocNo()));
+                                    locMast.setLocSts("F");
+                                    wrkDetlService.delete(new EntityWrapper<WrkDetl>().eq("zpallet",locMast.getBarcode()));
+                                    if(!locMastService.update(locMast,new EntityWrapper<LocMast>()
+                                            .eq("channel",i+1))){
+                                        log.error("淇敼娴嬭瘯搴撲綅鐘舵�佸け璐�"+locMast.getLocNo(),locMast);
+                                    }else{
+                                        fig=true;
+                                    }
+                                }
                             }else if(devpThread.startSignal[i][0]==3){
                                 locMast.setPackStatus(7);
                                 testMast.setModiTime(new Date());
@@ -2397,10 +2421,12 @@
                                     log.error("淇敼鍚姩鎸夐挳鐘舵�侊紝娴嬭瘯搴撲綅鐘舵�佸け璐�"+locMast.getLocNo(),locMast);
                                 }
                             }else if(!locMast.getLocSts().equals("R")){
-                                if(!locMastService.update(locMast,new EntityWrapper<LocMast>()
-                                        .eq("loc_sts","F")
-                                        .eq("channel",i+1))){
-                                    log.error("淇敼娴嬭瘯搴撲綅鐘舵�佸け璐�"+locMast.getLocNo(),locMast);
+                                if(!fig){
+                                    if(!locMastService.update(locMast,new EntityWrapper<LocMast>()
+                                            .eq("loc_sts","F")
+                                            .eq("channel",i+1))){
+                                        log.error("淇敼娴嬭瘯搴撲綅鐘舵�佸け璐�"+locMast.getLocNo(),locMast);
+                                    }
                                 }
                                 if(!testMastService.update(testMast,new EntityWrapper<TestMast>()
                                         .eq("loc_no",locMast.getLocNo())
@@ -2410,12 +2436,18 @@
                             }
                         }
                     }
+                    //褰撳厖鏀剧數搴撲綅涓篛绌哄簱浣嶆椂
+                    //搴撲綅鐘舵�佹敼涓�8绌洪棽
                     //缁橮LC鍐欐秷闃蹭俊鍙�
                     for (int i=0;i<48;i++){
                         LocMast locMast=locMastService.selectOne(new EntityWrapper<LocMast>().eq("channel",i+1));
                         TestMast testMast=testMastService.selectOne(new EntityWrapper<TestMast>()
                                 .eq("loc_no",locMast.getLocNo())
                                 .eq("user_id",locMast.getBarcode()));
+                        if(locMast.getLocSts().equals("O")&&devpThread.startSignal[i][0]!=8){
+                            Thread.sleep(1000);
+                            MessageQueue.offer(SlaveType.Devp, 1, new Task(6,locMast.getChannel()-1));
+                        }
                         try{
                             if(locMast.getFireStatus()!=devpThread.startSignal[i][1]){
                                 messageQueueOffer2(i,(short)((int)locMast.getFireStatus()),SlaveType.Devp, devp.getId());
@@ -2436,6 +2468,8 @@
                         }
                     }
 
+
+
                 }
 
             }
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 42f4ba1..e3ca63f 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -89,6 +89,12 @@
                         StaProtocol staProtocol2 = (StaProtocol)task.getData();
                         siemensS7Net.Write("DB108.0" + staProtocol2.getSiteId(), staProtocol2.getStaNo()==1);
                         break;
+                    //娴嬭瘯搴撳嚭搴擄紝搴撲綅鐘舵�佹敼涓�8
+                    case 6:
+                        String data = task.getData()+"";
+                        Byte coun=8;
+                        siemensS7Net.Write("DB38.0" + data, coun);
+                        break;
                     //澶嶄綅娴嬭瘯淇″彿
                     case 3:
                         StaProtocol staProtocol = (StaProtocol) task.getData();
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 5db0b6b..5305bc2 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -34,7 +34,7 @@
   enable: false
 
 wms:
-  url: localhost:8080/fnwms
+  url: 10.12.55.200:8080/fnwms
 
 # 涓嬩綅鏈洪厤缃�
 wcs-slave:
diff --git a/src/main/resources/mapper/LocMastMapper.xml b/src/main/resources/mapper/LocMastMapper.xml
index 5b4c293..b577fe8 100644
--- a/src/main/resources/mapper/LocMastMapper.xml
+++ b/src/main/resources/mapper/LocMastMapper.xml
@@ -34,6 +34,9 @@
         <result column="mk" property="mk" />
         <result column="barcode" property="barcode" />
         <result column="ctn_no" property="ctnNo" />
+        <result column="pack_status" property="packStatus" />
+        <result column="fire_status" property="fireStatus" />
+        <result column="fire_no" property="fireNo" />
         <result column="channel" property="channel" />
 
     </resultMap>
diff --git a/src/main/webapp/views/monitor/index.html b/src/main/webapp/views/monitor/index.html
index c2bcb81..82888f6 100644
--- a/src/main/webapp/views/monitor/index.html
+++ b/src/main/webapp/views/monitor/index.html
@@ -93,7 +93,7 @@
             document.msExitFullscreen();
         }
     }
-    let url = 'http://192.168.4.188:8088/fnwms'
+    let url = 'http://10.12.55.200:8080/fnwms'
     var item = [{locNo: '1',locSts: '1',mk: '1',packStatus$: '1'}]
     var year = '2020';
     var month = '05';
@@ -157,13 +157,12 @@
         $('#bar-hour').text(hour);
         $('#bar-minute').text(minute);
         $('#bar-second').text(second);
-        $('#bar-week').text(week);
     }
     /**
      * 鑾峰彇鏃堕棿
      */
     function getDate() {
-        http.get("http://localhost:9090/fnwcs/monitor/date", null, function (res) {
+        http.get("http://10.12.55.200:8080/fnwcs/monitor/date", null, function (res) {
             if (res.code === 200){
                 year = res.data.year;
                 month = res.data.month;
@@ -212,7 +211,7 @@
                         color: '#FFF'
                     }
                 },
-                data: ['鍏朵粬', '娴嬭瘯搴撲綅', '闈欑疆搴撲綅', '娴嬭瘯鍓嶆殏瀛樺簱涓�', '娴嬭瘯澶辫触搴撲綅']
+                data: ['娴嬭瘯搴撲綅', '闈欑疆搴撲綅', '鏆傚瓨搴撲綅', 'NG搴撲綅']
             }
         ],
         yAxis: [

--
Gitblit v1.9.1