From 3c9e375697f758e43beeaba61c78d4c303d1f2d3 Mon Sep 17 00:00:00 2001
From: rk <94314517@qq.com>
Date: 星期五, 30 一月 2026 13:56:37 +0800
Subject: [PATCH] 功能优化
---
server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WarningServiceImpl.java | 33 ++++++++++++++++++++++++++++++++-
1 files changed, 32 insertions(+), 1 deletions(-)
diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WarningServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WarningServiceImpl.java
index cdf162f..1b8d374 100644
--- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WarningServiceImpl.java
+++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WarningServiceImpl.java
@@ -315,6 +315,9 @@
model.setSubscribeStatus(Constants.TWO);
model.setSubscribeInfo(response.getMsg());
}
+
+ startCheckThirdDest(eventParam);
+
}else{
model.setSubscribeStatus(Constants.ZERO);
}
@@ -323,6 +326,32 @@
model.setEditDate(new Date());
model.setEditor(param.getLoginUserInfo().getId());
warningMapper.updateById(model);
+ }
+
+ /**
+ * 妫�鏌ヤ笁鏂规槸鍚﹂渶瑕佽闃呮捣搴蜂簨浠�
+ * @param eventParam
+ */
+
+ private void startCheckThirdDest(EventSubRequest eventParam) {
+ try {
+ String thirdpath =systemDictDataBiz.queryByCode(Constants.HK_PARAM, Constants.HK_PUSH_THIRD_URL).getCode();
+ if(StringUtils.isNotBlank(thirdpath)){
+ String[] ss = thirdpath.split(";");
+ for(String s : ss){
+ eventParam.setEventDest(s);
+ BaseResponse response = HKService.eventSub(eventParam);
+ if(Objects.nonNull(response)&&StringUtils.equals(response.getCode(), HKConstants.RESPONSE_SUCCEE)){
+ log.error("========璁㈤槄鍏朵粬涓夋柟鍦板潃鎴愬姛:"+s);
+ }else{
+ log.error("========璁㈤槄鍏朵粬涓夋柟鍦板潃閿欒:"+s);
+ }
+ }
+ }
+ }catch (Exception e){
+ log.error("========璁㈤槄鍏朵粬涓夋柟鍦板潃閿欒"+e.getMessage());
+ }
+
}
@@ -395,13 +424,15 @@
if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(memberList)&&memberList.size()>Constants.ZERO){
List<String> ddUserIdList = memberList.stream().map(j->j.getErpId()).collect(Collectors.toList());
//鍙戦�佹帹閫侀拤閽夋秷鎭�
-
Boolean isSuccess = dingTalk.workInfoOANotice(Long.valueOf(systemDictDataBiz.queryByCode(Constants.DD_TALK,Constants.AGENT_ID).getCode()),
String.join(",",ddUserIdList),
ddNoticeConfigMapper.selectCount(new QueryWrapper<DdNoticeConfig>().lambda()
.eq(DdNoticeConfig::getIsdeleted,Constants.ZERO).eq(DdNoticeConfig::getStatus,Constants.ZERO)
.eq(DdNoticeConfig::getObjType,13))>Constants.ZERO?
dingTalk.getWeatherNoticeMsg(title,text):null);
+
+
+
for (Member member:memberList) {
WarningPush warningPush = new WarningPush();
warningPush.setCreateDate(new Date());
--
Gitblit v1.9.3