update:分拣看板更新当日拆码垛数据

update:错误记录过滤,只记录error不为0的情况
update:更新大屏设备数量图表数据

acs/nladmin-system/src/main/java/org/nl/acs/ext/wms/service/impl/WmsToAcsServiceImpl.java

@@ -1275,6 +1275,12 @@ public class WmsToAcsServiceImpl implements WmsToAcsService {
             if (ObjectUtil.isEmpty(device)) {
                 continue;
             }
+            if (device.getDeviceDriver() instanceof LnshRGVDeviceDriver) {
+                LnshRGVDeviceDriver driver = (LnshRGVDeviceDriver) device.getDeviceDriver();
+                status.put("device_status", driver.getStatus());
+                status.put("mode", driver.getMode());
+                status.put("error", driver.getError());
+            }
             if (device.getDeviceDriver() instanceof ConveyorBarcodeDeviceDriver) {
                 ConveyorBarcodeDeviceDriver driver = (ConveyorBarcodeDeviceDriver) device.getDeviceDriver();
                 status.put("mode", driver.getMode());

lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/cockpit/service/dao/StackVo.java

@@ -10,10 +10,9 @@ import java.util.Date;
  */
 @Data
 public class StackVo {
-    private String vehicleCode;
     private String materialQty;
-    private String materialWeight;
+    private String materialModel;
-    private String materialName;
+    private String materialCode;
     @JsonFormat(pattern ="MM-dd HH:mm:ss", timezone = "GMT+8")
     private Date createTime;
 }

lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/cockpit/service/impl/CockpitServiceImpl.java

@@ -264,6 +264,7 @@ public class CockpitServiceImpl implements CockpitService {
         CompletableFuture<DeviceRunStatVo> deviceRunStatCompletableFuture = CompletableFuture.supplyAsync(
                 () -> {
                     List<String> devices = cockPitMapper.selectAllDevice();
+                    devices.add("RGV");
                     if (devices.isEmpty()) {
                         return null;
                     }

lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/cockpit/service/mapper/CockPitMapper.xml

@@ -103,30 +103,30 @@
     </select>
 
     <select id="getUnstackingList" resultType="org.nl.wms.cockpit.service.dao.StackVo">
-        SELECT g.create_time     AS createTime,
+        SELECT g.update_time    AS createTime,
-               g.vehicle_code    AS vehicleCode,
+               g.material_qty   AS materialQty,
-               g.material_qty    AS materialQty,
+               m.material_code  AS materialCode,
-               g.material_weight AS materialWeight,
+               m.material_model AS materialModel
-               m.material_code   AS materialName
         FROM sch_base_vehiclematerialgroup g
                  LEFT JOIN md_base_material m ON g.material_id = m.material_id
         WHERE g.point_code LIKE ('%CDW%')
-          AND DATE (g.update_time) = CURDATE()
+          AND DATE ( g.update_time ) = CURDATE()
-        ORDER BY g.update_time DESC
+        ORDER BY
+            g.update_time DESC
     </select>
 
     <select id="getStackingList" resultType="org.nl.wms.cockpit.service.dao.StackVo">
-        SELECT g.create_time     as createTime,
+        SELECT g.create_time    AS createTime,
-               g.vehicle_code    as vehicleCode,
+               g.material_qty   AS materialQty,
-               g.material_qty    as materialQty,
+               m.material_code  AS materialCode,
-               g.material_weight as materialWeight,
+               m.material_model AS materialModel
-               m.material_code   as materialName
         FROM sch_base_vehiclematerialgroup g
                  LEFT JOIN pdm_bd_workorder w ON g.workorder_code = w.workorder_code
-                 left join md_base_material m on g.material_id = m.material_id
+                 LEFT JOIN md_base_material m ON g.material_id = m.material_id
         WHERE w.region_code = 'FJ'
-          AND DATE (g.update_time) = CURDATE()
+          AND DATE ( g.create_time ) = CURDATE()
-        order by g.create_time desc
+        ORDER BY
+            g.create_time DESC
     </select>
 
     <select id="selectRgSortCount" resultType="org.nl.wms.cockpit.service.dao.SortingLineRes">
@@ -194,6 +194,21 @@
         SELECT point_code
         FROM sch_base_point
         WHERE is_used = '1'
+            AND (region_code = 'HN' AND point_type = '2')
+           OR (region_code = 'YZ' AND point_type = '1')
+           OR (point_code = 'DTW01')
+           OR (region_code = 'FJ')
+            AND point_code NOT IN (
+                                   'FJ02CDW01',
+                                   'FJ02CDW02',
+                                   'FJ02MDW01',
+                                   'FJ02MDW02',
+                                   'FJCDJXS02',
+                                   'FJMDJXS02',
+                                   'HNJ07DJW',
+                                   'HNJ08DJW',
+                                   'YJ09',
+                                   'YZJXS06')
     </select>
 
     <select id="selectInKilnInfo" resultType="org.nl.wms.cockpit.service.dao.InOutKilnVo">
@@ -299,6 +314,7 @@
                if(LENGTH(p.point_name) <![CDATA[ > ]]> 0, p.point_name, r.device_code) as deviceName
         FROM `das_device_error_record` r
                  LEFT JOIN sch_base_point p ON r.device_code = p.point_code
+        where r.error not in ('0')
         ORDER BY r.record_time desc limit 100
     </select>
     <select id="selectHchjList" resultType="org.nl.wms.cockpit.service.dao.HchjMaterialInfo">

lms/nladmin-system/nlsso-server/src/main/java/org/nl/wms/ext/acs/service/impl/AcsToWmsServiceImpl.java

@@ -1053,6 +1053,10 @@ public class AcsToWmsServiceImpl implements AcsToWmsService {
 
     @Override
     public JSONObject errorDeviceRecord(JSONObject param) {
+        String error = param.getString("error");
+        if(StringUtils.isNotEmpty(error) && "0".equals(error)){
+            return null;
+        }
         DasDeviceErrorRecord dasDeviceErrorRecord = new DasDeviceErrorRecord();
         dasDeviceErrorRecord.setDevice_code(param.getString("device_code"));
         dasDeviceErrorRecord.setError(param.getString("error"));