package com.highdatas.mdm.util.pool;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.highdatas.mdm.service.ISysDispenseConfigService;
|
import com.highdatas.mdm.util.DbUtils;
|
import com.highdatas.mdm.util.HttpUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.boot.context.properties.ConfigurationProperties;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.MediaType;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Map;
|
|
@ConfigurationProperties(prefix = "mq")
|
@Component
|
public class MqClient {
|
|
@Value("${mq.url}")
|
String url;
|
@Autowired
|
ISysDispenseConfigService sysDispenseConfigService;
|
|
String prefix ;
|
|
private MqClient() {
|
this.prefix = "/api/datacvg/mqProducer/";
|
|
}
|
|
public MqResult syncProduce(MqEntity mqEntity) {
|
String url = this.url + prefix + "syncProduce";
|
MqResult mqResult = sendMqEntity(url, mqEntity);
|
return mqResult;
|
}
|
|
public MqResult oneWayProduce(MqEntity mqEntity) {
|
String url = this.url + prefix + "oneWayProduce";
|
MqResult mqResult = sendMqEntity(url, mqEntity);
|
return mqResult;
|
}
|
|
public MqResult asyncProduce(MqEntity mqEntity) {
|
String url = this.url + prefix + "asyncProduce";
|
MqResult mqResult = sendMqEntity(url, mqEntity);
|
return mqResult;
|
}
|
|
private MqResult sendMqEntity(String url, MqEntity mqEntity) {
|
Map<String, Object> dataMap = DbUtils.beanToMap(mqEntity);
|
Object msgBody = dataMap.get("msgBody");
|
String bodyStr = JSONObject.toJSONString(msgBody);
|
dataMap.put("msgBody", bodyStr);
|
dataMap.remove("increment");
|
dataMap.remove("pageSize");
|
dataMap.remove("type");
|
dataMap.remove("userId");
|
dataMap.remove("maintainId");
|
dataMap.remove("pages");
|
dataMap.remove("dataId");
|
dataMap.remove("pageNo");
|
dataMap.remove("msgCode");
|
String s = HttpUtils.HttpRestClientByObjectParams(url, HttpMethod.POST, dataMap,null, null,MediaType.APPLICATION_JSON);
|
MqResult mqResult = JSONObject.parseObject(s, MqResult.class);
|
return mqResult;
|
}
|
|
|
}
|
