北向接口路由转发代码提交

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/api/video/service/impl/VideoIntegrityCheckServiceImpl.java

@@ -82,7 +82,7 @@ public class VideoIntegrityCheckServiceImpl extends ServiceImpl<VideoIntegrityCh
     }
 
     @Override
-    public Object execute(Object data) {
+    public Object execute(String event,Object data) {
         VideoIntegrityCheckDto checkDto = transform(data);
         this.saveData(checkDto,"");
         return data;

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/handler/SocWebSocketHandler.java

@@ -114,14 +114,16 @@ public class SocWebSocketHandler extends AbstractWebSocketHandler {
             Object obj = websocketResult.getPayload();
             if (ObjectUtil.isNotEmpty(obj)){
                 Map map = JSON.parseObject(obj.toString(), Map.class);
-                String key = (String) map.get(WebSocketConstants.EVENT);
+                //上报事件
+                String event = (String) map.get(WebSocketConstants.EVENT);
+                //上报消息内容
                 JSONObject args = (JSONObject) map.get(WebSocketConstants.ARGS);
-                if (ObjectUtil.isEmpty(key)||args.isEmpty()){
+                if (ObjectUtil.isEmpty(event)||args.isEmpty()){
                     log.error("消息内容为空：{}",message.getPayload());
                     return;
                 }
-                RouterService routeService = RouterServiceHandler.getRouteService(key);
-                routeService.execute(args);
+                RouterService routeService = RouterServiceHandler.getRouteService(event);
+                routeService.execute(event,args);
                 //todo 返回iot消息
             }
         } catch (Exception e) {

soc-modules/soc-modules-mediator/src/main/java/com/xunmei/mediator/websocket/service/RouterService.java

@@ -4,6 +4,6 @@ public interface RouterService {
 
     String routerKey();
 
-    Object execute(Object obj);
+    Object execute(String event,Object obj);
 
 }