任务推送

zengh

2022-03-28 27065d03501874f1bbbf6e9f5484eb8f43892400

任务推送

 src/main/java/org/springblade/modules/taskqd/controller/TaskqdController.java

@@ -93,6 +93,7 @@
    @ApiOperationSupport(order = 4)
    @ApiOperation(value = "新增", notes = "传入task")
    public R save(@Valid @RequestBody Taskqd taskqd) {
        pushMsgService.pushMsg(taskqd.getJurisdiction());
        return R.status(taskqdService.save(taskqd));
    }


 src/main/java/org/springblade/modules/webscoket/service/impl/PushMsgServiceImpl.java

@@ -27,8 +27,10 @@
    public void pushMsg(String msg) {
        ChannelGroup group = NettyConfig.getChannelGroup();
        String name = group.name();
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("xqid", msg);
        System.out.println("空间大小：" + group.size() + ",名字：" + name);
        group.writeAndFlush(new TextWebSocketFrame(msg));
        group.writeAndFlush(new TextWebSocketFrame(String.valueOf(jsonObject)));
    }

    @Override