firsh

leutu

2024-05-20 a4e99a6a39284643fdf2b04dbe55212e5954973c

 src/main/java/com/skyline/electricity/timer/Consumer.java

@@ -41,7 +41,7 @@
    InformationService informationService ;
    @Override
    public void onMessage(String message) {
        System.out.println("recv msg:  "+message);
        //System.out.println("recv msg:  "+message);
        sendAllMessage(message);
    }

@@ -64,13 +64,13 @@
     */

    public void sendAllMessage(String message) {
        System.out.println("【websocket消息】广播消息:"+message);
        //System.out.println("【websocket消息】广播消息:"+message);

        JSONObject jsonObject = JSONObject.parseObject(message);
        String personNo = jsonObject.getString("personNo");

        SysUser sysUser = infoSynchService.selectUserInfoById(personNo) ;
        System.out.println("【user]:"+JSONObject.toJSONString(sysUser));
        //System.out.println("【user]:"+JSONObject.toJSONString(sysUser));
        List<RetInfo> list = new ArrayList<>();
        //查询用户所处围栏
        List<FencePosition> fencePositionList = null ;
@@ -79,7 +79,7 @@
        }catch (Exception e){
            System.out.println(e.getMessage());
        }
        System.out.println("【FencePosition]:"+JSONObject.toJSONString(fencePositionList));
        //System.out.println("【FencePosition]:"+JSONObject.toJSONString(fencePositionList));
        RetInfo alertinfo = new RetInfo();
        initAlertInfos(jsonObject, personNo, sysUser, alertinfo);
        if( fencePositionList != null && fencePositionList.size() > 0){
@@ -101,7 +101,7 @@
            list.add(alertinfo) ;
        }
        insertInformation(list);
        System.out.println( "list:"+jsonObject.toJSONString(list));
       // System.out.println( "list:"+jsonObject.toJSONString(list));
//        if( list != null && list.size() > 0)
//            System.out.println( "websocket status ..["+webSocketController.sendAllMessage(JSONObject.toJSONString(list))+"["+JSONObject.toJSONString(list)+"]" );
    }