xiaoguangbin/AnalysisSystemForRadionuclide
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix：send message

Browse Source
This commit is contained in:
nieziyan 2024-01-30 11:51:34 +08:00
parent 7af7fafc86
commit 01eb8d22c2
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/feignclient/SystemClient.java
View File

@ -19,8 +19,8 @@ public interface SystemClient {
@RequestMapping("/sys/user/findUserMap")
Map<String, SysUser> findUserMap();
@GetMapping("/sys/sendMessage/send")
void sendMessage(@RequestParam MessageDTO messageDTO,
@PostMapping("/sys/sendMessage/send")
void sendMessage(@RequestBody MessageDTO messageDTO,
@RequestParam String groupId,
@RequestParam String notific);

4
jeecg-module-abnormal-alarm/src/main/java/org/jeecg/modules/redisStream/AnalysisConsumer.java
View File

@ -198,8 +198,10 @@ public class AnalysisConsumer implements StreamListener<String, ObjectRecord<Str
logService.saveLog(logInfo);
// 发送报警信息
String groupId = info.getGroupId();
MessageDTO messageDTO = new MessageDTO();
messageDTO.setTitle("Nuclied Warn Info").setContent(alarmInfo.toString());
if (StrUtil.isNotBlank(groupId))
systemClient.sendMessage(new MessageDTO(), groupId, ALL.getValue());
systemClient.sendMessage(messageDTO, groupId, ALL.getValue());
}
}

4
jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/controller/SendMessageController.java
View File

@ -18,8 +18,8 @@ public class SendMessageController {
@Autowired
private ISysBaseAPI sysBaseAPI;
@GetMapping("send")
public void sendMessage(@RequestParam MessageDTO messageDTO,
@PostMapping("send")
public void sendMessage(@RequestBody MessageDTO messageDTO,
@RequestParam String groupId,
@RequestParam String notific){
sendMessage.send(messageDTO, groupId, notific);