添加消息发送系统

portal-manager/src/main/java/com/mortals/xhx/thread/AlarmSendMsgThread.java

@@ -58,7 +58,7 @@ public class AlarmSendMsgThread extends AbstractThread {
 
     @Override
     protected void process() {
-      //  log.info("AlarmSendMsgThread process");
+        //  log.info("AlarmSendMsgThread process");
         MessageTaskQuery messageTaskQuery = new MessageTaskQuery();
         messageTaskQuery.setEnabled(YesNoEnum.YES.getValue());
         messageTaskQuery.setSendStatus(SendStatusEnum.待发送.getValue());
@@ -70,9 +70,9 @@ public class AlarmSendMsgThread extends AbstractThread {
             smsThirdPartyReq.setAppid(apiId);
             //模板号
 
-            if(!ObjectUtils.isEmpty(messageTask.getMessageConfigEntity())){
+            if (!ObjectUtils.isEmpty(messageTask.getMessageConfigEntity())) {
                 smsThirdPartyReq.setType(messageTask.getMessageConfigEntity().getTemplateId() + "");
-            }else {
+            } else {
                 log.info("短信发送模板号不能为空！");
                 continue;
             }
@@ -92,7 +92,7 @@ public class AlarmSendMsgThread extends AbstractThread {
             TbQueueMsgHeaders header = new DefaultTbQueueMsgHeaders();
             header.put(MessageHeader.MESSAGETYPE, "alarm");
             header.put(MessageHeader.TIMESTAMP, new Date().getTime() + "");
-            TbQueueMsg queueMsg = new DefaultTbQueueMsg(IdUtil.fastUUID(),messageTask.getContent(), header);
+            TbQueueMsg queueMsg = new DefaultTbQueueMsg(IdUtil.fastUUID(), messageTask.getContent(), header);
 
             CorrelationData correlationData = new CorrelationData(IdUtil.fastSimpleUUID());
 
@@ -100,7 +100,7 @@ public class AlarmSendMsgThread extends AbstractThread {
 
         }
 
-
+//todo 发送失败的重新发送
 
 /*