other_project/message-center
7
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

修改问题

Browse Source
This commit is contained in:
dimengzhe
2023-01-09 16:19:45 +08:00
parent 7f090e71b5
commit 1f17cd0b1a
6 changed files with 145 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
message-center-biz/src/main/java/com/yxt/messagecenter/biz/message/MessageRest.java
View File

@@ -135,4 +135,9 @@ public class MessageRest implements MessageFeign {
public ResultBean sendAppVersionMessage(AppVersionMessageDto dto) {
return messageService.sendAppVersionMessage(dto);
}
@Override
public ResultBean sendOrderMessage(OrderMesageDto dto) {
return messageService.sendOrderMessage(dto);
}
}

74
message-center-biz/src/main/java/com/yxt/messagecenter/biz/message/MessageService.java
View File

@@ -638,4 +638,78 @@ public class MessageService extends MybatisBaseService<MessageMapper, Message> {
System.out.println("process end");
return rb.success();
}
public ResultBean sendOrderMessage(OrderMesageDto dto) {
ResultBean rb = ResultBean.fireFail();
//保存消息体
List<OrderListMessageDto> list = dto.getList();
for (OrderListMessageDto dto1 : list) {
String msgTitle = dto1.getMsgTitle();
String msgContent = dto1.getMsgContent();
String msgTargetUri = dto1.getMsgTargetUri();
String app_type = dto1.getApp_type();
List<String> createBySidList = dto1.getCreateBySid();
AppMessageDto messageDto = new AppMessageDto();
List<MessageTypeVo> typeVoList = messageTypeService.selectMsgTypeList(IDENTIFIER);
if (typeVoList.size() > 0) {
for (MessageTypeVo message : typeVoList) {
if (message.getMsgType().equals("业务")) {
messageDto.setMsgTypeSid(message.getMsgTypeSid());
messageDto.setMsgType(message.getMsgType());
}
}
}
messageDto.setMsgTitle(msgTitle);
messageDto.setMsgContent(msgContent);
messageDto.setMsgSource("业务");
messageDto.setMsgTargetUri(msgTargetUri);
messageDto.setApp_type(app_type);
JSONObject json = new JSONObject(dto1.getAppMap());
messageDto.setArgs_json(json.toJSONString());
String msgSid = saveOrUpdateAppMessage(messageDto).getData();
String msgTypeSid = messageDto.getMsgTypeSid();
// 2、保存至消息列表
ResultBean<String> stringList = sysUserFeign.selectIdBySid(createBySidList);
List<String> receiveIdList = Arrays.asList(stringList.getData().split(","));
// 使用多线程保存
List<Future<?>> futures = new ArrayList<Future<?>>();
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < createBySidList.size(); i++) {
int finalI = i;
Future<?> f = executor.submit(new Runnable() {
@Override
public void run() {
try {
System.out.println("run start-----------------" + System.currentTimeMillis() + ":" + Thread.currentThread().getName());
MessageListDto messageList = new MessageListDto();
messageList.setMsgSid(msgSid);
messageList.setRDelStatus(0);
messageList.setSDelStatus(0);
messageList.setReceiverSid(createBySidList.get(finalI));
messageListService.saveOrUpdateDto(messageList);
System.out.println("run end-----------------" + System.currentTimeMillis() + ":" + Thread.currentThread().getName());
} catch (Exception e) {
e.printStackTrace();
}
}
});
futures.add(f);
}
executor.shutdown();
//标题、内容、消息类别key、消息类别名称、
YamlPropertiesFactoryBean factoryBean = new YamlPropertiesFactoryBean();
factoryBean.setResources(new ClassPathResource("application.yml"));
Properties properties = factoryBean.getObject();
if ("pro".equals(properties.get("spring.profiles.active"))) {
for (int i = 0; i < receiveIdList.size(); i++) {
JPushServer.sendPushAlias(msgTitle, msgContent, msgTypeSid, "业务", receiveIdList.get(i));
}
} else {
for (int i = 0; i < receiveIdList.size(); i++) {
JPushServer.sendPushAlias(msgTitle, msgContent, msgTypeSid, "业务", "T" + receiveIdList.get(i));
}
}
}
return rb.success();
}
}