perf:fwd消息配置

This commit is contained in:
Zhujx
2025-08-07 10:57:59 +08:00
parent dadf90927c
commit af929b1c1d
6 changed files with 44 additions and 19 deletions

View File

@@ -3,6 +3,7 @@ package com.xiang;
import org.mybatis.spring.annotation.MapperScan; import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.properties.ConfigurationPropertiesScan;
import org.springframework.scheduling.annotation.EnableScheduling; import org.springframework.scheduling.annotation.EnableScheduling;
/** /**
@@ -16,6 +17,11 @@ import org.springframework.scheduling.annotation.EnableScheduling;
"com.xiang.xservice.glados.repository", "com.xiang.xservice.glados.repository",
"com.xiang.xservice.xb.repository" "com.xiang.xservice.xb.repository"
}) })
@ConfigurationPropertiesScan(basePackages = {
"com.xiang.xservice.fwd.config",
"com.xiang.xservice.xb.config",
"com.xiang.xservice.glados.config",
})
public class ServiceScriptApplication { public class ServiceScriptApplication {
public static void main(String[] args) { public static void main(String[] args) {
SpringApplication.run(ServiceScriptApplication.class, args); SpringApplication.run(ServiceScriptApplication.class, args);

View File

@@ -0,0 +1,22 @@
package com.xiang.xservice.fwd.config;
import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import java.util.List;
/**
* @Author: xiang
* @Date: 2025-08-07 10:46
*/
@Getter
@Setter
@ConfigurationProperties(prefix = "dingtalk.robot.script")
public class DingTalkRobotConfig {
private String token;
private String secret;
private List<String> users;
}

View File

@@ -18,7 +18,7 @@ import com.xiang.xservice.fwd.mapper.FwdAudienceConfigMapper;
import com.xiang.xservice.fwd.mapper.FwdPerformConfigMapper; import com.xiang.xservice.fwd.mapper.FwdPerformConfigMapper;
import com.xiang.xservice.fwd.mapper.FwdPerformProjectInfoMapper; import com.xiang.xservice.fwd.mapper.FwdPerformProjectInfoMapper;
import com.xiang.xservice.fwd.mapper.FwdUserConfigMapper; import com.xiang.xservice.fwd.mapper.FwdUserConfigMapper;
import com.xiang.xservice.fwd.service.DingTalkFWDMsgService; import com.xiang.xservice.fwd.service.DingTalkScriptMsgService;
import com.xiang.xservice.fwd.service.IPerformService; import com.xiang.xservice.fwd.service.IPerformService;
import com.xiang.xservice.fwd.service.IPerformServiceHttp; import com.xiang.xservice.fwd.service.IPerformServiceHttp;
import com.xiang.xservice.schedule.core.DynamicTaskScheduler; import com.xiang.xservice.schedule.core.DynamicTaskScheduler;
@@ -62,7 +62,7 @@ public class FwdImportantMsgJob {
private final FwdPerformProjectInfoMapper performProjectInfoMapper; private final FwdPerformProjectInfoMapper performProjectInfoMapper;
private final FwdPerformConfigMapper performConfigMapper; private final FwdPerformConfigMapper performConfigMapper;
private final DynamicTaskScheduler dynamicTaskScheduler; private final DynamicTaskScheduler dynamicTaskScheduler;
private final DingTalkFWDMsgService dingTalkFWDMsgService; private final DingTalkScriptMsgService dingTalkScriptMsgService;
private final FwdUserConfigMapper fwdUserConfigMapper; private final FwdUserConfigMapper fwdUserConfigMapper;
private final FwdAudienceConfigMapper fwdAudienceConfigMapper; private final FwdAudienceConfigMapper fwdAudienceConfigMapper;
private final IPerformService iPerformService; private final IPerformService iPerformService;
@@ -132,7 +132,7 @@ public class FwdImportantMsgJob {
savaTask(data, taskId, params); savaTask(data, taskId, params);
} }
msg.append("请注意进行数据库配置的更改!"); msg.append("请注意进行数据库配置的更改!");
dingTalkFWDMsgService.sendFWDMsg(msg.toString()); dingTalkScriptMsgService.sendScriptMsg(msg.toString());
log.info("【芬玩岛】演唱会预售定时任务结束time:{}", System.currentTimeMillis()); log.info("【芬玩岛】演唱会预售定时任务结束time:{}", System.currentTimeMillis());
} }
@@ -229,7 +229,7 @@ public class FwdImportantMsgJob {
} }
} }
}); });
dingTalkFWDMsgService.sendFWDMsg(msg.toString()); dingTalkScriptMsgService.sendScriptMsg(msg.toString());
} }
private void savaTask(FPerformProjectInfo data, long taskId, Map<String, Object> params) { private void savaTask(FPerformProjectInfo data, long taskId, Map<String, Object> params) {

View File

@@ -1,12 +1,11 @@
package com.xiang.xservice.fwd.service; package com.xiang.xservice.fwd.service;
import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService; import com.xiang.xservice.basic.xservice.dingTalk.service.DingTalkService;
import com.xiang.xservice.fwd.config.DingTalkRobotConfig;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List;
/** /**
* @Author: xiang * @Author: xiang
* @Date: 2025-08-07 10:30 * @Date: 2025-08-07 10:30
@@ -14,20 +13,18 @@ import java.util.List;
@Slf4j @Slf4j
@Service @Service
@RequiredArgsConstructor @RequiredArgsConstructor
public class DingTalkFWDMsgService { public class DingTalkScriptMsgService {
private final DingTalkService dingTalkService; private final DingTalkService dingTalkService;
private static final String SECRET = "SEC768ed578c0fb31a9aec84b1c1db4f195f5aca203985bbb9d549e23e41c8874d1"; private final DingTalkRobotConfig dingTalkRobotConfig;
private static final String TOKEN = "4709b708d961846e0aee523c5abc3b67e8fa424ee292501d85efd4e504f15a8b";
private static final String USER_ID = "450841600726084717";
/** /**
* 发送芬玩岛消息 * 发送脚本消息
* @param msg 消息 * @param msg 消息
*/ */
public void sendFWDMsg(String msg) { public void sendScriptMsg(String msg) {
try { try {
dingTalkService.sendRobotMessage(SECRET, TOKEN, List.of(USER_ID), msg); dingTalkService.sendRobotMessage(dingTalkRobotConfig.getSecret(), dingTalkRobotConfig.getToken(), dingTalkRobotConfig.getUsers(), msg);
} catch (Exception e) { } catch (Exception e) {
log.error("信息发送异常, 信息:{}", msg, e); log.error("信息发送异常, 信息:{}", msg, e);
} }

View File

@@ -12,7 +12,7 @@ import com.xiang.xservice.fwd.mapper.FwdPerformConfigMapper;
import com.xiang.xservice.fwd.mapper.FwdPerformProjectInfoMapper; import com.xiang.xservice.fwd.mapper.FwdPerformProjectInfoMapper;
import com.xiang.xservice.fwd.mapper.FwdPerformSeatInfoMapper; import com.xiang.xservice.fwd.mapper.FwdPerformSeatInfoMapper;
import com.xiang.xservice.fwd.mapper.FwdUserConfigMapper; import com.xiang.xservice.fwd.mapper.FwdUserConfigMapper;
import com.xiang.xservice.fwd.service.DingTalkFWDMsgService; import com.xiang.xservice.fwd.service.DingTalkScriptMsgService;
import com.xiang.xservice.fwd.service.IPerformService; import com.xiang.xservice.fwd.service.IPerformService;
import com.xiang.xservice.fwd.service.IPerformServiceHttp; import com.xiang.xservice.fwd.service.IPerformServiceHttp;
import com.xiang.xservice.http.helper.HttpRequestHelper; import com.xiang.xservice.http.helper.HttpRequestHelper;
@@ -45,7 +45,7 @@ public class PerformServiceImpl implements IPerformService {
private final FwdPerformProjectInfoMapper fwdPerformProjectInfoMapper; private final FwdPerformProjectInfoMapper fwdPerformProjectInfoMapper;
private final FwdPerformConfigMapper fwdPerformConfigMapper; private final FwdPerformConfigMapper fwdPerformConfigMapper;
private final IPerformServiceHttp performServiceHttp; private final IPerformServiceHttp performServiceHttp;
private final DingTalkFWDMsgService dingTalkService; private final DingTalkScriptMsgService dingTalkService;
private final FwdUserConfigMapper fwdUserConfigMapper; private final FwdUserConfigMapper fwdUserConfigMapper;
@Value("${DingTalk.chatId}") @Value("${DingTalk.chatId}")
private String chatId; private String chatId;
@@ -110,7 +110,7 @@ public class PerformServiceImpl implements IPerformService {
if (Objects.nonNull(projectOrder)) { if (Objects.nonNull(projectOrder)) {
log.info("下单成功,订单信息:{}", JSONObject.toJSONString(projectOrder)); log.info("下单成功,订单信息:{}", JSONObject.toJSONString(projectOrder));
String msg = "【芬玩岛】下单成功✅✅✅,演出名称:" + performByProjectId.getProjectName() + "请在2分钟内完成付款"; String msg = "【芬玩岛】下单成功✅✅✅,演出名称:" + performByProjectId.getProjectName() + "请在2分钟内完成付款";
dingTalkService.sendFWDMsg(msg); dingTalkService.sendScriptMsg(msg);
return Boolean.TRUE; return Boolean.TRUE;
} }
} }

View File

@@ -22,7 +22,7 @@ aliyun:
RR: RR:
- local - local
DingTalk: dingtalk:
# 钉钉消息用户,用逗号隔开 # 钉钉消息用户,用逗号隔开
userList: "450841600726084717" userList: "450841600726084717"
# 钉钉消息群ID需要调用/chat/create api创建群返回 # 钉钉消息群ID需要调用/chat/create api创建群返回
@@ -31,10 +31,10 @@ DingTalk:
script: script:
token: 797be7f32062e31dec1d567f8b490a5649a5366083618e236c7a1263df1f4af3 token: 797be7f32062e31dec1d567f8b490a5649a5366083618e236c7a1263df1f4af3
secret: SEC9aca642c0c29c9da261462869c464d34623247583d98fc82343a0a4464abbe91 secret: SEC9aca642c0c29c9da261462869c464d34623247583d98fc82343a0a4464abbe91
userIds: users:
- 450841600726084717 - 450841600726084717
xb: xb:
token: ad21ead99f0fdc63aa00d6732b7b0888c17590f7612c68297edfcb71844d1437 token: ad21ead99f0fdc63aa00d6732b7b0888c17590f7612c68297edfcb71844d1437
secret: SECc09d8aad6635f1a4cbadb7c0ab365523c46299f138438cd885e445e0f5f4d730 secret: SECc09d8aad6635f1a4cbadb7c0ab365523c46299f138438cd885e445e0f5f4d730
userIds: users:
- 450841600726084717 - 450841600726084717