添加 mapping 逻辑 添加表 sys_view_logicmap 逻辑基类待提供

kimi

2020-04-22 f9a4612e1f3ed276f5eb057fd7d69d54e71aec41

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

@@ -32,6 +32,7 @@
    public void run() {

        log.info("mq: {} ---------- run", mqEntity.toString());

        String type = mqEntity.getType();

        SysDispenseLogs logByMqEntity = DbUtils.dispenseLogsService.getLogByMqEntity(mqEntity);

        try{

            if (type.equalsIgnoreCase(Constant.Master)) {

                sendMasterData();

@@ -41,7 +42,9 @@
        }

        catch (Exception e) {

            e.printStackTrace();

            //log

            if (logByMqEntity != null) {

                logByMqEntity.setErrorInfo(e.getMessage()).updateById();

            }

        }



    }

@@ -162,9 +165,14 @@
        String size = (bytes.length / 1024) + "k";

        log.info(size);

        Date now = new Date();



//        String mqBody = com.datacvg.common.AESUtil.getInstance().encoder(content, mqEntity.getUserId(),"http://180.169.94.250:9107");

        String mqBody = content;

        Boolean aes = DbUtils.dispenseService.getAes();

        String mqBody;

        if (aes) {

            String aesUrl = DbUtils.dispenseService.getAesUrl();

            mqBody = com.datacvg.common.AESUtil.getInstance().encoder(content, mqEntity.getUserId(), aesUrl);

        } else {

            mqBody = content;

        }

        bytes = mqBody.getBytes("UTF-8");

        size = (bytes.length / 1024) + "k";

        log.info(size);

@@ -176,7 +184,7 @@
        msgBody.setData(mqBody);

        msgBody.setTotal(pageSize);

        mqEntity.setMsgBody(msgBody);

        Thread.sleep(1000 * 60 * 3);

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

        mqEntity.send2Mq();

    }

}