moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

活动-企业微信-将各活动告警机器人合并成一个

Browse Source
This commit is contained in:
yeungchihang
2023-02-06 11:19:05 +08:00
parent 2aa0a55f27
commit 04d08c16fc
9 changed files with 16 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
accompany-base/accompany-common/src/main/java/com/accompany/common/config/WebSecurityConfig.java
View File

@@ -27,17 +27,8 @@ public class WebSecurityConfig {
// 企业微信推送key
private String enterpriseWechatPushKey;
// 赛事报名通知企业微信推送key
private String gameQuotaEnterpriseWechatPushKey;
// 召唤战斗活动企业微信机器人key
private String actCallBattleEnterpriseWechatPushKey;
// 寻找小精灵企业微信机器人key
private String seekElfinEnterpriseWechatPushKey;
// 线性奖池提醒企业微信机器人key
private String linearylyPoolEnterpriseWechatPushKey;
// 深海活动预警机器人key
private String luckySeaPreWarningRobotKey;
private String newYearFireworkEnterpriseWechatPushKey;
// 活动通知企业微信推送key
private String activityEnterpriseWechatPushKey;
public void setJwtWebKey(String jwtWebKey) {
WebSecurityConfig.jwtWebKey = jwtWebKey;

4
accompany-business/accompany-business-service/src/main/java/com/accompany/business/event/listener/gamemanage/GameQuotaNotifyListener.java
View File

@@ -121,7 +121,7 @@ public class GameQuotaNotifyListener implements ApplicationListener<QuotaSuccess
* @param hasQuotaCount
*/
private void sendNormalGameEnterpriseWechatMsg(GameManageInfo info, Long hasQuotaCount) {
String key = webSecurityConfig.getGameQuotaEnterpriseWechatPushKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
MarkdownMessage msg = new MarkdownMessage();
msg.add(MarkdownMessage.getHeaderText(3, "赛事报名通知"));
msg.add(MarkdownMessage.getReferenceText("赛事id： " + info.getMatchId()));
@@ -140,7 +140,7 @@ public class GameQuotaNotifyListener implements ApplicationListener<QuotaSuccess
* @param hasQuotaCount
*/
private void sendQuickGameEnterpriseWechatMsg(GameManageInfo info, Long hasQuotaCount) {
String key = webSecurityConfig.getGameQuotaEnterpriseWechatPushKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
MarkdownMessage msg = new MarkdownMessage();
msg.add(MarkdownMessage.getHeaderText(3, "快速赛报名通知"));
msg.add(MarkdownMessage.getReferenceText("赛事id： " + info.getMatchId()));

2
accompany-business/accompany-business-service/src/main/java/com/accompany/business/event/listener/linearlypool/LinearlyPoolPrizeWxNotifyListener.java
View File

@@ -73,7 +73,7 @@ public class LinearlyPoolPrizeWxNotifyListener implements ApplicationListener<Li
msg.add(MarkdownMessage.getReferenceText(new StringBuilder("奖品: ").append(prizes).toString()));
msg.add(MarkdownMessage.getReferenceText(new StringBuilder("获得者: ").append(user.getNick()).append("(").append(user.getErbanNo()).append(")").toString()));
msg.add(MarkdownMessage.getReferenceText(new StringBuilder("抽奖时间: ").append(DateTimeUtil.convertDate(new Date(drawTime))).toString()));
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getLinearylyPoolEnterpriseWechatPushKey(), msg);
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getActivityEnterpriseWechatPushKey(), msg);
}
}

4
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/LuckySeaPreWarningService.java
View File

@@ -136,7 +136,7 @@ public class LuckySeaPreWarningService {
msg.add(MarkdownMessage.getReferenceText("前"+ roundNum + "轮投入:" + stat.getGoldIn()));
msg.add(MarkdownMessage.getReferenceText("前"+ roundNum + "轮产出:" + stat.getGoldOut()));
msg.add(MarkdownMessage.getReferenceText("请判断是否需要前往后台查看"));
String key = webSecurityConfig.getLuckySeaPreWarningRobotKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
enterpriseWechatPushService.pushMessageByKey(key,msg);
}
@@ -223,7 +223,7 @@ public class LuckySeaPreWarningService {
Long stock = activitiesLuckySeaService.getStock();
String stockStr = new BigDecimal(stock).divide(new BigDecimal(ActivitiesLuckySeaServiceImpl.HANDLE_STOCK_MULTIPLE), 2, RoundingMode.HALF_DOWN).toString();
msg.add(MarkdownMessage.getReferenceText("当前库存数:" + stockStr));
String key = webSecurityConfig.getLuckySeaPreWarningRobotKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
enterpriseWechatPushService.pushMessageByKey(key,msg);
}

6
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/activities/ActNewYearFireworkService.java
View File

@@ -303,7 +303,7 @@ public class ActNewYearFireworkService implements InitializingBean, ApplicationL
msg.add(MarkdownMessage.getHeaderText(3, "2023新年烟花活动产出每日产出预警"));
msg.add(MarkdownMessage.getReferenceText(String.format(" %d %s 在第 %d 个池 抽出 %s 被触发的每日产出数量限制 %d 个， 目前已经产出 %s",
users.getErbanNo(), users.getNick(), type, null != drawGift? drawGift.getGiftName(): cacheKey, dayLimit, todayOutputNumMap)));
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getNewYearFireworkEnterpriseWechatPushKey(), msg);
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getActivityEnterpriseWechatPushKey(), msg);
});
}
@@ -330,7 +330,7 @@ public class ActNewYearFireworkService implements InitializingBean, ApplicationL
msg.add(MarkdownMessage.getHeaderText(3, "2023新年烟花活动产出每日产出预警"));
msg.add(MarkdownMessage.getReferenceText(String.format(" %d %s 在第 %d 个池 抽出 %s 触发每日产出数量限制 %d 个的 百分之70， 目前已经产出 %s",
users.getErbanNo(), users.getNick(), type, null != drawGift? drawGift.getGiftName(): cacheKey, dayLimit, todayOutputNumMap)));
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getNewYearFireworkEnterpriseWechatPushKey(), msg);
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getActivityEnterpriseWechatPushKey(), msg);
});
}
} else if (ratio >= 0.5d) {
@@ -355,7 +355,7 @@ public class ActNewYearFireworkService implements InitializingBean, ApplicationL
msg.add(MarkdownMessage.getHeaderText(3, "2023新年烟花活动产出每日产出预警"));
msg.add(MarkdownMessage.getReferenceText(String.format(" %d %s 在第 %d 个池 抽出 %s 触发每日产出数量限制 %d 个的 百分之50， 目前已经产出 %s",
users.getErbanNo(), users.getNick(), type, null != drawGift? drawGift.getGiftName(): cacheKey, dayLimit, todayOutputNumMap)));
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getNewYearFireworkEnterpriseWechatPushKey(), msg);
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getActivityEnterpriseWechatPushKey(), msg);
});
}
}

4
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/callbattle/ActCallBattlePreWarningService.java
View File

@@ -133,7 +133,7 @@ public class ActCallBattlePreWarningService {
msg.add(MarkdownMessage.getReferenceText("前"+ roundNum + "轮投入:" + stat.getGoldIn()));
msg.add(MarkdownMessage.getReferenceText("前"+ roundNum + "轮产出:" + stat.getGoldOut()));
msg.add(MarkdownMessage.getReferenceText("请判断是否需要前往后台查看"));
String key = webSecurityConfig.getActCallBattleEnterpriseWechatPushKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
enterpriseWechatPushService.pushMessageByKey(key, msg);
}
@@ -219,7 +219,7 @@ public class ActCallBattlePreWarningService {
Long stock = actCallBattleBizService.getStock();
String stockStr = new BigDecimal(stock).divide(new BigDecimal(ActCallBattleBizServiceImpl.HANDLE_STOCK_MULTIPLE), 2, RoundingMode.HALF_DOWN).toString();
msg.add(MarkdownMessage.getReferenceText("当前库存数:" + stockStr));
String key = webSecurityConfig.getActCallBattleEnterpriseWechatPushKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
enterpriseWechatPushService.pushMessageByKey(key, msg);
}

2
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/linearlypool/LinearlyPrizePoolService.java
View File

@@ -582,7 +582,7 @@ public class LinearlyPrizePoolService {
msg.add(MarkdownMessage.getReferenceText(new StringBuilder("用户参与总数: ").append(statisticsRes.getTotalPrice()).toString()));
msg.add(MarkdownMessage.getReferenceText(new StringBuilder("用户产出总价值: ").append(statisticsRes.getTotalPlatformValue()).toString()));
msg.add(MarkdownMessage.getReferenceText(new StringBuilder("游戏进行次数 ").append(statisticsRes.getDrawCounts()).toString()));
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getLinearylyPoolEnterpriseWechatPushKey(), msg);
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getActivityEnterpriseWechatPushKey(), msg);
}
@Data

4
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/seekelfin/SeekElfinPreWarningService.java
View File

@@ -116,7 +116,7 @@ public class SeekElfinPreWarningService {
msg.add(MarkdownMessage.getReferenceText("前"+ roundNum + "次投入:" + stat.getGoldIn()));
msg.add(MarkdownMessage.getReferenceText("前"+ roundNum + "次产出:" + stat.getGoldOut()));
msg.add(MarkdownMessage.getReferenceText("请判断是否需要前往后台查看"));
String key = webSecurityConfig.getSeekElfinEnterpriseWechatPushKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
enterpriseWechatPushService.pushMessageByKey(key, msg);
}
@@ -202,7 +202,7 @@ public class SeekElfinPreWarningService {
Long stock = seekElfinUtil.getStock();
String stockStr = new BigDecimal(stock).divide(new BigDecimal(SeekElfinUtil.HANDLE_STOCK_MULTIPLE), 2, RoundingMode.HALF_DOWN).toString();
msg.add(MarkdownMessage.getReferenceText("当前库存数:" + stockStr));
String key = webSecurityConfig.getSeekElfinEnterpriseWechatPushKey();
String key = webSecurityConfig.getActivityEnterpriseWechatPushKey();
enterpriseWechatPushService.pushMessageByKey(key, msg);
}
}

2
accompany-scheduler/accompany-scheduler-service/src/main/java/com/accompany/scheduler/task/KryptonRankTask.java
View File

@@ -56,7 +56,7 @@ public class KryptonRankTask {
msg.add(MarkdownMessage.getReferenceText(String.format("平台ID [%d]", u.getErbanNo())));
msg.add(MarkdownMessage.getReferenceText(String.format("昵称 [%s]", u.getNick())));
msg.add(MarkdownMessage.getReferenceText(String.format("当日累计送礼钻石价值 [%d]", score)));
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getNewYearFireworkEnterpriseWechatPushKey(), msg);
enterpriseWechatPushService.pushMessageByKey(webSecurityConfig.getActivityEnterpriseWechatPushKey(), msg);
}
}