haoshihao 3 周之前
父節點
當前提交
431dd84c15

+ 13 - 0
src/main/java/com/juxin/client/websocket/FindTask.java

@@ -170,6 +170,10 @@ public class FindTask {
                         return;
                     }
                     break;
+                case FLUSH_BANK_INFO:
+                    result = flushBankWork(bean);
+                    client.sendMessage(result);
+                    break;
                 default:
                     return;
             }
@@ -180,6 +184,15 @@ public class FindTask {
 
     }
 
+    private String flushBankWork(WebsocketInfo bean) {
+        Map<String, Object> result = new HashMap<>();
+        result.put("infoType", "flushBankInfo");
+        result.put("postType", "python");
+        result.put("methodType", "flushBankInfo");
+        result.put("reqJson", "");
+        return JSONUtil.toJsonStr(result);
+    }
+
     /**
      * 提交任务
      *

+ 3 - 1
src/main/java/com/juxin/client/websocket/enums/WebsocketTypeEnum.java

@@ -16,7 +16,9 @@ public enum WebsocketTypeEnum {
     STOP_PAY_UPDATE("stopPayUpdate","预警止付更新"),
     LOG_MSG("logMsg", "日志传输"),
     GET_QUEUE_JOB("getQueueJob","获取执行队列任务"),
-    GET_RESULT_QUEUE_JOB("getResultQueueJob","获取回捞结果任务")
+    GET_RESULT_QUEUE_JOB("getResultQueueJob","获取回捞结果任务"),
+
+    FLUSH_BANK_INFO("flushBankInfo", "刷新银行信息")
     ;
     /**
      * websocket 识别标识