修改MQ消息发送

pull/4/head
fangjiakai 2024-01-11 17:18:06 +08:00
parent d91e162379
commit 0b01e507c9
9 changed files with 16 additions and 78 deletions

View File

@ -171,7 +171,7 @@ public class AppConfinedSpaceController extends BaseController {
sendMessageUtil.sendMessages(mes1, paramsList1); sendMessageUtil.sendMessages(mes1, paramsList1);
} }
TenCorpDto tenCorpDto = new TenCorpDto(); TenCorpDto tenCorpDto = new TenCorpDto();
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID")); tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID"));
tenCorpDto.setMessage(TenCorpConst.confinedSpace); tenCorpDto.setMessage(TenCorpConst.confinedSpace);
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
@ -254,7 +254,7 @@ public class AppConfinedSpaceController extends BaseController {
sendMessageUtil.sendMessages(mes, paramsList); sendMessageUtil.sendMessages(mes, paramsList);
} }
TenCorpDto tenCorpDto = new TenCorpDto(); TenCorpDto tenCorpDto = new TenCorpDto();
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID")); tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID"));
tenCorpDto.setMessage(TenCorpConst.confinedSpace); tenCorpDto.setMessage(TenCorpConst.confinedSpace);
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
@ -710,7 +710,7 @@ public class AppConfinedSpaceController extends BaseController {
paramsList.add(params4); paramsList.add(params4);
sendMessageUtil.sendMessages(mes, paramsList); sendMessageUtil.sendMessages(mes, paramsList);
TenCorpDto tenCorpDto = new TenCorpDto(); TenCorpDto tenCorpDto = new TenCorpDto();
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID")); tenCorpDto.setMark(pd.getString("CONFINEDSPACE_ID"));
tenCorpDto.setMessage(TenCorpConst.confinedSpace); tenCorpDto.setMessage(TenCorpConst.confinedSpace);
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");

View File

@ -153,7 +153,7 @@ public class AppElectricityController extends BaseController {
tenCorpDto.setMark(pd.getString("ELECTRICITY_ID")); tenCorpDto.setMark(pd.getString("ELECTRICITY_ID"));
tenCorpDto.setMark_name("ELECTRICITY_ID"); tenCorpDto.setMark_name("ELECTRICITY_ID");
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setData(pd); tenCorpDto.setData(pd);
tenCorpDto.setMessage(TenCorpConst.electricity); tenCorpDto.setMessage(TenCorpConst.electricity);
@ -258,7 +258,7 @@ public class AppElectricityController extends BaseController {
tenCorpDto.setMark(pd.getString("ELECTRICITY_ID")); tenCorpDto.setMark(pd.getString("ELECTRICITY_ID"));
tenCorpDto.setMark_name("ELECTRICITY_ID"); tenCorpDto.setMark_name("ELECTRICITY_ID");
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setData(pd); tenCorpDto.setData(pd);
tenCorpDto.setMessage(TenCorpConst.electricity); tenCorpDto.setMessage(TenCorpConst.electricity);
@ -635,7 +635,7 @@ public class AppElectricityController extends BaseController {
tenCorpDto.setMark(pd.getString("ELECTRICITY_ID")); tenCorpDto.setMark(pd.getString("ELECTRICITY_ID"));
tenCorpDto.setMark_name("ELECTRICITY_ID"); tenCorpDto.setMark_name("ELECTRICITY_ID");
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setData(pd); tenCorpDto.setData(pd);
tenCorpDto.setMessage(TenCorpConst.electricity); tenCorpDto.setMessage(TenCorpConst.electricity);

View File

@ -176,7 +176,7 @@ public class AppHotworkController extends BaseController {
tenCorpDto.setMark(pd.getString("HOTWORK_ID")); tenCorpDto.setMark(pd.getString("HOTWORK_ID"));
tenCorpDto.setMark_name("HOTWORK_ID"); tenCorpDto.setMark_name("HOTWORK_ID");
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setData(pd); tenCorpDto.setData(pd);
tenCorpDto.setMessage(TenCorpConst.hotWork); tenCorpDto.setMessage(TenCorpConst.hotWork);
@ -264,7 +264,7 @@ public class AppHotworkController extends BaseController {
tenCorpDto.setMark(pd.getString("HOTWORK_ID")); tenCorpDto.setMark(pd.getString("HOTWORK_ID"));
tenCorpDto.setMark_name("HOTWORK_ID"); tenCorpDto.setMark_name("HOTWORK_ID");
tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000"); tenCorpDto.setTime_stamp(pd.getString("WORK_START_DATE") + ":00:000");
tenCorpDto.setTopic("eightWork"); tenCorpDto.setTopic(Const.TOPIC_EIGHTWORK);
tenCorpDto.setData(pd); tenCorpDto.setData(pd);
tenCorpDto.setMessage(TenCorpConst.hotWork); tenCorpDto.setMessage(TenCorpConst.hotWork);

View File

@ -4,8 +4,5 @@ import com.zcloud.dto.TenCorpDto;
public interface SendMessageService { public interface SendMessageService {
void sendMessage(TenCorpDto tenCorpDto) throws Exception;
void sendDelayQueue(TenCorpDto tenCorpDto); void sendDelayQueue(TenCorpDto tenCorpDto);
void sendDelayQueue(String message);
} }

View File

@ -22,9 +22,6 @@ import javax.annotation.Resource;
@Service @Service
public class SendMessageServiceImpl implements SendMessageService { public class SendMessageServiceImpl implements SendMessageService {
@Value("${mq.topic.info}")
private String info;
@Resource @Resource
private RocketMQTemplate rocketMQTemplate; private RocketMQTemplate rocketMQTemplate;
@ -37,28 +34,6 @@ public class SendMessageServiceImpl implements SendMessageService {
@Resource @Resource
private MqMessageLogMapper mqMessageLogMapper; private MqMessageLogMapper mqMessageLogMapper;
public void sendMessage(TenCorpDto tenCorpDto) throws Exception {
try {
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
log.put("CREATE_TIME", DateUtil.getTime());
mqMessageLogMapper.save(log);
System.out.println("生产者:" + tenCorpDto.toString());
SendResult sendResult = rocketMQTemplate.syncSend(this.info, tenCorpDto.toString());
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
} catch (Exception e) {
e.printStackTrace();
PageData log = tenCorpDto.getPd();
log.put("MESSAGE_ERROR_LOG_ID", Warden.get32UUID());
log.put("ERROR_MESSAGE", e.getMessage());
log.put("TYPE", "0");
log.put("TIME", DateUtil.getTime());
mqErrorMessageLogMapper.save(log);
}
}
@Override @Override
public void sendDelayQueue(TenCorpDto tenCorpDto) { public void sendDelayQueue(TenCorpDto tenCorpDto) {
PageData log = tenCorpDto.getPd(); PageData log = tenCorpDto.getPd();
@ -72,7 +47,7 @@ public class SendMessageServiceImpl implements SendMessageService {
System.out.println("生产者:" + tenCorpDto.toString()); System.out.println("生产者:" + tenCorpDto.toString());
// 推送消息 // 推送消息
SendResult sendResult = rocketMQTemplate.syncSend( SendResult sendResult = rocketMQTemplate.syncSend(
MqUtil.analysistopic(tenCorpDto.getTopic()), tenCorpDto.getTopic(),
new GenericMessage<>(tenCorpDto.toString()), new GenericMessage<>(tenCorpDto.toString()),
3000, 3000,
MqUtil.analysisTime(tenCorpDto.getTime_stamp())); MqUtil.analysisTime(tenCorpDto.getTime_stamp()));
@ -90,33 +65,6 @@ public class SendMessageServiceImpl implements SendMessageService {
} }
} }
@Override
public void sendDelayQueue(String message) {
TenCorpDto tenCorpDto = JSONObject.parseObject(message,TenCorpDto.class);
try {
PageData log = tenCorpDto.getPd();
log.put("CREATE_TIME", DateUtil.getTime());
log.put("PRODUCER_NAME",tenCorpDto.getProducer_name());
log.put("MESSAGE_LOG_ID", Warden.get32UUID());
mqMessageLogMapper.save(log);
System.out.println("生产者:" + tenCorpDto.toString());
// 推送消息
SendResult sendResult = rocketMQTemplate.syncSend(
MqUtil.analysistopic(tenCorpDto.getTopic()),
new GenericMessage<>(message),
3000,
MqUtil.analysisTime(tenCorpDto.getTime_stamp()));
if (!sendResult.getSendStatus().equals(SendStatus.SEND_OK)) {
throw new RuntimeException("产品入栈失败");
}
} catch (Exception e) {
PageData log = tenCorpDto.getPd();
logService.saveErrorMessage(log,e.getMessage());
e.printStackTrace();
}
}
public static void main(String[] args) { public static void main(String[] args) {
try { try {
System.out.println(MqUtil.analysisTime("2023-06-30 14:30:00:000")); System.out.println(MqUtil.analysisTime("2023-06-30 14:30:00:000"));

View File

@ -67,6 +67,5 @@ public class Const {
public static final String ALIYUN_REGIONID = "cn-beijing"; // 点播服务接入地域 public static final String ALIYUN_REGIONID = "cn-beijing"; // 点播服务接入地域
public static final String ENDPOINT = "vod.cn-beijing.aliyuncs.com";// 访问的域名 public static final String ENDPOINT = "vod.cn-beijing.aliyuncs.com";// 访问的域名
public static final String topic_eightWork="eightWork"; public static final String TOPIC_EIGHTWORK="eightWork_whb";
public static final String topic_info="info";
} }

View File

@ -71,14 +71,6 @@ public class MqUtil {
return 0; return 0;
} }
public static String analysistopic(String producerName) {
switch (producerName){
case "eightWork" : return Const.topic_eightWork;
case "info" : return Const.topic_info;
default: return "";
}
}
public static Date dateFormat(String date) throws Exception{ public static Date dateFormat(String date) throws Exception{
return timeFormat.parse(date); return timeFormat.parse(date);
} }

View File

@ -62,14 +62,14 @@ rocketmq.producer.retry-times-when-send-async-failed=3
## topic 前缀 ## topic 前缀
mq.topic.info=info mq.topic.info=info
mq.topic.eightWork=eightWork mq.topic.eightWork=eightWork_whb
mq.group.info=scheduled_tasks mq.group.info=scheduled_tasks
mq.group.eightWork=scheduled_tasks_eightWork mq.group.eightWork=scheduled_tasks_eightWork
#字符 #字符
spring.http.encoding.charset=UTF-8 spring.servlet.encoding.charset=UTF-8
spring.http.encoding.force=true spring.servlet.encoding.force=true
spring.http.encoding.enabled=true spring.servlet.encoding.enabled=true
# 关闭springboot启动时的banner # 关闭springboot启动时的banner
spring.main.banner-mode=off spring.main.banner-mode=off
#jar包部署时去掉注释 #jar包部署时去掉注释

View File

@ -232,6 +232,7 @@
p.NAME PERIODNAME, p.NAME PERIODNAME,
t.NAME TYPENAME, t.NAME TYPENAME,
d.NAME as DEPARTMENT_NAME, d.NAME as DEPARTMENT_NAME,
tt.NAME as TASK_TYPE_NAME,
sp.NAME sp.NAME
AS POST_NAME, AS POST_NAME,
s.NAME AS SCREENTYPENAME, s.NAME AS SCREENTYPENAME,
@ -244,6 +245,7 @@
left join sys_dictionaries p on f.PERIOD = p.BIANMA left join sys_dictionaries p on f.PERIOD = p.BIANMA
left join sys_dictionaries t on f.TYPE = t.BIANMA left join sys_dictionaries t on f.TYPE = t.BIANMA
left join sys_dictionaries s on f.SCREENTYPE = s.BIANMA left join sys_dictionaries s on f.SCREENTYPE = s.BIANMA
left join sys_dictionaries tt on f.TASK_TYPE = tt.DICTIONARIES_ID
left join OA_DEPARTMENT d on d.DEPARTMENT_ID=f.DEPARTMENT_ID left join OA_DEPARTMENT d on d.DEPARTMENT_ID=f.DEPARTMENT_ID
left join SYS_POST sp on sp.POST_ID = f.POST_ID left join SYS_POST sp on sp.POST_ID = f.POST_ID
LEFT JOIN SYS_USER u on u.USER_ID = f.USER_ID LEFT JOIN SYS_USER u on u.USER_ID = f.USER_ID