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

多语言-Admin模块下使用AdminServiceException作为业务异常

Browse Source
This commit is contained in:
khalil
2024-04-11 16:49:16 +08:00
parent 1e0d33227e
commit 2768e9abe0
895 changed files with 1392 additions and 51954 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
accompany-mq/accompany-mq-sdk/src/main/java/com/accompany/mq/constant/MqConstant.java
View File

@@ -11,18 +11,12 @@ public interface MqConstant {
String LINEARLY_POOL_TOPIC = "linearly_pool_topic";
String LINEARLY_POOL_CONSUME_GROUP = "linearly_pool_consume_group";
String CLEAN_MUSIC_TOPIC = "clean_music_topic";
String CLEAN_MUSIC_CONSUME_GROUP = "clean_music_consume_group";
String ACTIVITY_PACK_TOPIC = "activity_pack_topic";
String ACTIVITY_PACK_CONSUME_GROUP = "activity_pack_consume_group";
String PAY_FINISH_TOPIC = "pay_finish_topic";
String PAY_FINISH_CONSUME_GROUP = "pay_finish_consume_group";
String VOICE_LIKE_TOPIC = "voice_like_topic";
String VOICE_LIKE_CONSUME_GROUP = "voice_like_consume_group";
String YI_DUN_TEXT_ANTI_TOPIC = "yidun_text_anti_topic";
String YI_DUN_TEXT_ANTI_CONSUME_GROUP = "yidun_text_anti_consume_group";

2
accompany-mq/accompany-mq-service/src/main/java/com/accompany/mq/producer/MQMessageProducer.java
View File

@@ -1,7 +1,5 @@
package com.accompany.mq.producer;
import cn.hutool.core.lang.UUID;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.accompany.mq.model.BaseMqMessage;
import lombok.extern.slf4j.Slf4j;

55
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/CleanMusicDelayMessageConsumer.java
View File

@@ -1,55 +0,0 @@
package com.accompany.mq.consumer;
import com.accompany.business.message.CleanMusicDelayMessage;
import com.accompany.business.service.ktv.UserChooseMusicService;
import com.accompany.business.service.user.UserInRoomService;
import com.accompany.business.vo.RoomVo;
import com.accompany.common.redis.RedisKey;
import com.accompany.core.service.common.JedisService;
import com.accompany.mq.constant.MqConstant;
import com.accompany.mq.listener.AbstractMessageListener;
import com.alibaba.fastjson.JSON;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
/**
* 清歌消息监听器
* @author xiaoyuyou
* @date 2018/9/5 11:03
*/
@Slf4j
@Component
@ConditionalOnProperty(name = "spring.application.name", havingValue = "web")
@RocketMQMessageListener(topic = MqConstant.CLEAN_MUSIC_TOPIC, consumerGroup = MqConstant.CLEAN_MUSIC_CONSUME_GROUP)
public class CleanMusicDelayMessageConsumer extends AbstractMessageListener<CleanMusicDelayMessage> {
@Autowired
private UserChooseMusicService userChooseMusicService;
@Autowired
private UserInRoomService userInRoomService;
@Autowired
private JedisService jedisService;
@SneakyThrows
@Override
public void onMessage(CleanMusicDelayMessage cleanMusicMsg) {
log.info("clean music delay message {}", JSON.toJSONString(cleanMusicMsg));
Long roomUid = cleanMusicMsg.getRoomUid();
Long uid = cleanMusicMsg.getUid();
String messId = jedisService.hget(RedisKey.room_clean_music_messId.getKey(), roomUid + "_" + uid);
log.info("clean music listener exec, roomUid:{}, uid:{}, period:{}, redis messId:{}, current messId:{}",
roomUid, uid, System.currentTimeMillis() - cleanMusicMsg.getMessTime(), messId, cleanMusicMsg.getMessId());
if (StringUtils.isEmpty(messId) || !StringUtils.equals(messId, cleanMusicMsg.getMessId())){
return;
}
RoomVo roomVo = userInRoomService.getUserInRoomInfoCache(uid);
if (roomVo == null || roomVo.getUid().longValue() != roomUid.longValue()){
userChooseMusicService.deleteUserAllChooseMusic(roomUid, uid);
}
}
}

1
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/MyCardChargeMessageConsumer.java
View File

@@ -1,7 +1,6 @@
package com.accompany.mq.consumer;
import cn.hutool.core.util.StrUtil;
import com.accompany.business.message.ActivityPackMessage;
import com.accompany.business.service.mycard.MyCardBizService;
import com.accompany.common.constant.Constant;
import com.accompany.common.redis.RedisKey;

46
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/VoiceLikeMessageConsumer.java
View File

@@ -1,46 +0,0 @@
package com.accompany.mq.consumer;
import com.accompany.business.message.VoiceLikeMessage;
import com.accompany.business.service.voice.VoiceService;
import com.accompany.common.redis.RedisKey;
import com.accompany.core.service.common.JedisService;
import com.accompany.core.util.StringUtils;
import com.accompany.mq.constant.MqConstant;
import com.accompany.mq.listener.AbstractMessageListener;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
/**
* @author chucheng
* @date 2019-06-05
* @description 声音瓶子 喜欢/不喜欢消息监听
*/
@Slf4j
@Component
@ConditionalOnProperty(name = "spring.application.name", havingValue = "web")
@RocketMQMessageListener(topic = MqConstant.VOICE_LIKE_TOPIC, consumerGroup = MqConstant.VOICE_LIKE_CONSUME_GROUP)
public class VoiceLikeMessageConsumer extends AbstractMessageListener<VoiceLikeMessage> {
@Autowired
private VoiceService voiceService;
@Autowired
private JedisService jedisService;
@Override
public void onMessage(VoiceLikeMessage message) {
log.info("onMessage VoiceLikeMessage: {}", JSON.toJSONString(message));
// 判断该消息是否已经消费过
String messStatus = jedisService.hget(RedisKey.voice_like_status.getKey(), message.getMessId());
if (StringUtils.isBlank(messStatus)) {
log.error("handleVoiceLikeMessage status error.message = {}", JSON.toJSONString(message));
return;
}
voiceService.handleVoiceLikeMessage(message);
}
}

5
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/YiDunIMTextAntiMessageConsumer.java
View File

@@ -31,11 +31,6 @@ public class YiDunIMTextAntiMessageConsumer extends AbstractMessageListener<Yidu
@Override
public void onMessage(YidunIMAntiMessage message) {
log.info("handle yidun im text anti message {}", JSON.toJSONString(message));
String messStatus = jedisService.hget(RedisKey.voice_like_status.getKey(), message.getMessId());
if (StringUtils.isBlank(messStatus)) {
log.error("handleYidunIMAntiMessage status error.message = {}", JSON.toJSONString(message));
return;
}
yidunAntiHandleService.handlIMTextAnti(message.getChatMsg());
// 删除消息标识
jedisService.hdel(RedisKey.mq_yindun_im_text_anti_status.getKey(), message.getMessId());