merage

kimi

2020-05-27 c007f0ca1785db093d48f4846cda82fe8e955765

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

@@ -1,5 +1,6 @@
package com.highdatas.mdm.util.pool;



import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.JSONObject;

import com.highdatas.mdm.service.ISysDispenseConfigService;

import com.highdatas.mdm.util.DbUtils;

@@ -47,13 +48,18 @@
        return mqResult;

    }









    private MqResult sendMqEntity(String url, MqEntity mqEntity) {

        Map<String, Object> dataMap = DbUtils.beanToMap(mqEntity);

        Object msgBody = dataMap.get("msgBody");

        JSONObject mqJsonObject = (JSONObject) JSON.toJSON(mqEntity);

        JSONObject msgBody = mqJsonObject.getJSONObject("msgBody");

        Map<String, Object> dataMap = DbUtils.JsonObjectToHashMap(mqJsonObject);

        String bodyStr = JSONObject.toJSONString(msgBody);

        dataMap.put("msgBody", bodyStr);

        dataMap.remove("increment");

        dataMap.remove("pageSize");

        dataMap.remove("logId");

        dataMap.remove("type");

        dataMap.remove("userId");

        dataMap.remove("maintainId");

@@ -61,6 +67,9 @@
        dataMap.remove("dataId");

        dataMap.remove("pageNo");

        dataMap.remove("msgCode");

        dataMap.remove("totalSize");



//        dataMap.put("msgTagName", "datas");

        String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, dataMap,null, null,MediaType.APPLICATION_JSON);

        MqResult mqResult = JSONObject.parseObject(s, MqResult.class);

        return mqResult;