Commit bad2f9cf by 徐高华

素材审批消息

parent 1555f44f
package com.gic.haoban.manage.web.controller.content;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.gic.api.base.commons.BasePageInfo;
import com.gic.api.base.commons.Constant;
import com.gic.api.base.commons.Page;
......@@ -144,22 +145,21 @@ public class ContentCreativeController {
private void send(String enterpriseId ,Map<String, String> map , String msgCode) {
log.info("发送消息={}",msgCode);
/* String mqName = "haobanNotice";
NoticeMessageForm noticeMessageForm = new NoticeMessageForm();
noticeMessageForm.setMessageCode(msgCode);
noticeMessageForm.setMqRouterCode(mqName);
noticeMessageForm.setEnterpriseId(enterpriseId);
noticeMessageForm.setBusinessId(ToolUtil.randomUUID());
noticeMessageForm.setUniqueKey(UniqueIdUtils.uniqueLongHex());
noticeMessageForm.setUserIdList(null);
noticeMessageForm.setCreateTime(new Date());
noticeMessageForm.setVariableMap(map);
String mqName = "haobanNotice";
JSONObject json = new JSONObject() ;
json.put("messageCode",msgCode) ;
json.put("mqRouterCode",mqName) ;
json.put("enterpriseId",enterpriseId) ;
json.put("businessId",ToolUtil.randomUUID()) ;
json.put("uniqueKey",UniqueIdUtils.uniqueLongHex()) ;
json.put("createTime",new Date()) ;
json.put("variableMap",map) ;
try {
GicMQClient client = GICMQClientUtil.getClientInstance();
client.sendMessage(mqName, JSON.toJSONString(noticeMessageForm));
client.sendMessage(mqName, JSON.toJSONString(json));
} catch (Exception e) {
log.info("异常",e);
}*/
}
}
/**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment