merage

kimi

2020-05-27 c007f0ca1785db093d48f4846cda82fe8e955765

 src/main/java/com/highdatas/mdm/util/pool/MqMessage.java

@@ -109,7 +109,6 @@
            object.fluentPut("pages", page.getPageCount());

            object.fluentPut("current", page.getPageNo());

            object.fluentPut("records", maps);

            mqEntity.getMsgBody().setTotal(Long.valueOf(page.getRecordCount()).intValue());

            content = JSONObject.toJSONString(object);

        } else {

            Result result = DbUtils.masterDataService.selectListByPageByVersion(user, maintain.getTableName(), fieldList, filter, pageNo.get(), pageSize.get(), maintain.getVersion(), false);

@@ -122,7 +121,6 @@
            object.fluentPut("current", grid.get("current"));

            object.fluentPut("records", grid.get("record"));



            mqEntity.getMsgBody().setTotal(grid.getInteger("total"));

            content = JSONObject.toJSONString(object);



        }

@@ -166,7 +164,6 @@
    private void sendOneViewPackage(AtomicInteger pageNo, AtomicInteger pageSize, SysView sysView) throws Exception {

        Result viewData = DbUtils.viewService.getViewData(sysView, pageNo.get(), pageSize.get());

        JSONObject object = (JSONObject) viewData.getData();

        mqEntity.getMsgBody().setTotal(object.getInteger("total"));

        String content = JSONObject.toJSONString(object);

        sendMqBody(pageSize.get(), content);

    }

@@ -193,7 +190,7 @@
//        String mqBody = content;

        MqEntity.MsgBodyBean msgBody = mqEntity.getMsgBody();

        msgBody.setData(mqBody);



        msgBody.setTotal(pageSize);

        mqEntity.setMsgBody(msgBody);

//        Thread.sleep(1000 * 60 * 3);

        mqEntity.send2Mq();