任务列表屏

mes/hd/nladmin-system/src/main/java/org/nl/wms/sb/stat/websocket/AutoWebSocketTaskScreen.java

@@ -0,0 +1,38 @@
+package org.nl.wms.sb.stat.websocket;
+
+import cn.hutool.core.date.DateUtil;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.modules.mnt.websocket.MsgType;
+import org.nl.modules.mnt.websocket.SocketMsg;
+import org.nl.modules.mnt.websocket.WebSocketServer;
+import org.nl.wql.WQL;
+import org.nl.wql.core.bean.WQLObject;
+import org.springframework.stereotype.Component;
+
+import java.io.IOException;
+import java.util.HashMap;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class AutoWebSocketTaskScreen {
+
+    public void run() {
+        try {
+            JSONObject param = new JSONObject();
+            JSONArray requestArr = WQL.getWO("TASK_AUTOWEBSOCKETTSK").addParam("flag", "2").process().getResultJSONArray(0);
+            JSONArray repaiArr = WQL.getWO("TASK_AUTOWEBSOCKETTSK").addParam("flag", "3").process().getResultJSONArray(0);
+
+            param.put("requestArr",requestArr);
+            param.put("repaiArr",repaiArr);
+
+            SocketMsg socketMsg = new SocketMsg(param, MsgType.INFO);
+            WebSocketServer.sendInfo(socketMsg,"21");
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

mes/hd/nladmin-system/src/main/java/org/nl/wms/sb/stat/wql/TASK_AUTOWEBSOCKETTSK.wql

@@ -159,5 +159,62 @@
 		ENDQUERY
 	ENDIF
 
+	IF 输入.flag = "2"
+		QUERY
+			SELECT
+			    st.*,
+			    file.device_name,
+			    class.class_name,
+			    dept.name
+            FROM
+            	EM_BI_DeviceRepairRequest st
+            	LEFT JOIN EM_BI_EquipmentFile file ON st.devicerecord_id = file.devicerecord_id
+            	LEFT JOIN md_pb_classstandard class ON class.class_id = st.device_faultclass_id
+                LEFT JOIN sys_user user ON user.user_id = st.create_id
+                LEFT JOIN sys_dept dept ON user.dept_id = dept.dept_id
+            WHERE
+                st.is_delete = '0'
+                AND st.status = '01'
+                AND ( ISNULL( st.is_passed ) or (st.is_passed = '0'))
+
+			ENDSELECT
+		ENDQUERY
+	ENDIF
+
+	IF 输入.flag = "3"
+		QUERY
+			SELECT
+			    st.*,
+			    file.device_name,
+			    class.class_name,
+			    (
+			        CASE
+			        mst.fault_level
+			            WHEN '01' THEN '一级'
+			            WHEN '02' THEN '二级'
+			            WHEN '03' THEN '三级'
+			        END
+			    ) AS fault_level_name,
+			    mst.real_start_date,
+			    mst.update_optname,
+			    dept.name
+            FROM
+            	EM_BI_DeviceRepairRequest st
+            	INNER JOIN EM_BI_DeviceRepairMst mst ON mst.source_bill_id = st.request_id
+            	LEFT JOIN EM_BI_EquipmentFile file ON st.devicerecord_id = file.devicerecord_id
+            	LEFT JOIN md_pb_classstandard class ON class.class_id = st.device_faultclass_id
+            	LEFT JOIN sys_user user ON user.user_id = mst.update_optid
+            	LEFT JOIN sys_dept dept ON user.dept_id = dept.dept_id
+            WHERE
+                st.is_delete = '0'
+                AND st.status in (01,02)
+                AND st.is_passed = '1'
+                AND mst.invstatus in (01,02,03,04,05,06)
+                AND mst.is_delete = '0'
+
+			ENDSELECT
+		ENDQUERY
+	ENDIF
+