From 6c09cbd70388ae53ec593de253f69cfa1a3eeda7 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 06 二月 2021 15:41:25 +0800
Subject: [PATCH] 活动管理界面完善
---
service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java | 123 +++++++++++++++++++++++++----------------
1 files changed, 75 insertions(+), 48 deletions(-)
diff --git a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
index c48cf29..6ec3f3f 100644
--- a/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
+++ b/service-daylucky/src/main/java/com/ks/daylucky/util/mq/consumer/MsgConsumer.java
@@ -1,24 +1,24 @@
package com.ks.daylucky.util.mq.consumer;
+import com.google.gson.Gson;
import com.ks.daylucky.exception.UserMsgException;
import com.ks.daylucky.pojo.DTO.UserMsgSettings;
import com.ks.daylucky.pojo.VO.SimpleUser;
import com.ks.daylucky.service.UserInfoExtraService;
import com.ks.daylucky.service.UserInfoService;
import com.ks.daylucky.service.UserMsgService;
+import com.ks.daylucky.service.impl.AlipayTemplateMsgManager;
+import com.ks.daylucky.service.impl.AppManager;
+import com.ks.daylucky.util.LoggerUtil;
import com.ks.daylucky.util.factory.LuckyMsgContentFactory;
import com.ks.daylucky.util.factory.UserMsgFactory;
import com.ks.daylucky.util.mq.CMQManager;
+import com.ks.lucky.exception.LuckyActivityException;
+import com.ks.lucky.exception.LuckyActivityJoinAssistException;
import com.ks.lucky.pojo.DO.*;
import com.ks.lucky.pojo.DTO.ActivitySimpleUser;
-import com.ks.lucky.pojo.DTO.mq.ActivityAssistMsgDTO;
-import com.ks.lucky.pojo.DTO.mq.ActivityDrawnMsgDTO;
-import com.ks.lucky.pojo.DTO.mq.ActivityJoinMsgDTO;
-import com.ks.lucky.pojo.DTO.mq.ActivityStateChangeMsgDTO;
-import com.ks.lucky.remote.service.LuckyActivityAwardResultService;
-import com.ks.lucky.remote.service.LuckyActivityAwardService;
-import com.ks.lucky.remote.service.LuckyActivityJoinAssistService;
-import com.ks.lucky.remote.service.LuckyActivityJoinService;
+import com.ks.lucky.pojo.DTO.mq.*;
+import com.ks.lucky.remote.service.*;
import com.ks.lucky.utils.LuckyCMQConstant;
import com.ks.lucky.utils.mq.CMQConsumeRunner;
import com.qcloud.cmq.Message;
@@ -31,7 +31,6 @@
import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.List;
-import java.util.Vector;
public class MsgConsumer implements CMQConsumeRunner {
@@ -43,17 +42,26 @@
@Resource
private UserInfoService userInfoService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0", check = false)
private LuckyActivityJoinAssistService luckyActivityJoinAssistService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0", check = false)
private LuckyActivityJoinService luckyActivityJoinService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0", check = false)
private LuckyActivityAwardResultService luckyActivityAwardResultService;
- @Reference(version = "1.0.0")
+ @Reference(version = "1.0.0", check = false)
private LuckyActivityAwardService luckyActivityAwardService;
+
+ @Reference(version = "1.0.0", check = false)
+ private LuckyActivityService luckyActivityService;
+
+ @Resource
+ private AppManager appManager;
+
+ @Resource
+ private AlipayTemplateMsgManager alipayTemplateMsgManager;
@Resource
private UserMsgService userMsgService;
@@ -86,13 +94,20 @@
new JobThreadExecutorServiceImpl().run(new Runnable() {
@Override
public void run() {
+ LoggerUtil.mqLogger.info("鎺ユ敹娑堟伅 {}", MsgConsumer.class.getSimpleName());
List<Message> messageList = CMQManager.getInstance().consumeMsgMsg(16);
if (messageList != null) {
for (Message message : messageList) {
- Vector<String> vectors = message.msgTag;
- if (vectors.contains(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE)) {
+ BaseMQMsg baseMQMsg = JsonUtil.getSimpleGson().fromJson(message.msgBody, BaseMQMsg.class);
+ String tag = baseMQMsg.getCmqMsgTag();
+ LoggerUtil.mqLogger.info("娑堟伅娑堣垂锛歿}",new Gson().toJson(baseMQMsg));
+
+ if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_STATE_CHANGE)) {
+
//娲诲姩鐘舵�佹敼鍙�
ActivityStateChangeMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityStateChangeMsgDTO.class);
+ LoggerUtil.mqLogger.info("娲诲姩鐘舵�佹敼鍙橈細{}",new Gson().toJson(dto));
+
List<ActivitySimpleUser> userList;
switch (dto.getState()) {
//寮�濂�
@@ -102,25 +117,31 @@
for (ActivitySimpleUser user : userList) {
//鍒ゆ柇鏄惁涓
UserMsgSettings settings = getUserMsgSetting(Long.parseLong(user.getUid()));
+ LuckyActivity activity = luckyActivityService.getActivity(dto.getActivityId());
LuckyActivityAwardResult result = luckyActivityAwardResultService.getResult(user.getAppId(), user.getUid(), dto.getActivityId());
if (result != null) {
- if (settings.getDrawnMsg()) {
+ if (settings.getDrawnMsg() != null && settings.getDrawnMsg()) {
LuckyActivityAwards awards = luckyActivityAwardService.getAwardDetail(result.getAwardId());
try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(result.getUid()), LuckyMsgContentFactory.createDrawn(dto.getActivityId(), awards.getAwardName())));
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(result.getUid()), LuckyMsgContentFactory.createDrawn(dto.getActivityId(), activity.getCreateTime(), awards.getAwardName())));
} catch (UserMsgException e) {
- logger.error("娣诲姞涓娑堟伅鍑洪敊", e.getMessage(), result.getId());
+ logger.error("娣诲姞涓娑堟伅鍑洪敊 awardResultId-{}", result.getId(), e);
}
+
+ //鍙戦�佷腑濂栨ā鏉挎秷鎭�
+ alipayTemplateMsgManager.sendDrawnMsg(activity, Long.parseLong(result.getUid()));
}
} else {
- if (settings.getNotDrawnMsg()) {
+ if (settings.getNotDrawnMsg() != null && settings.getNotDrawnMsg()) {
try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(user.getUid()), LuckyMsgContentFactory.createNotDrawn(dto.getActivityId())));
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(user.getUid()), LuckyMsgContentFactory.createNotDrawn(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞鏈腑濂栨秷鎭嚭閿�", e.getMessage(), user.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鏈腑濂栨秷鎭嚭閿� activityId-{} uid-{} ", dto.getActivityId(),user.getUid(),e);
}
+ //鍙戦�佹湭涓妯℃澘娑堟伅
+ alipayTemplateMsgManager.sendUnDrawnMsg(activity, Long.parseLong(result.getUid()));
}
}
}
@@ -128,14 +149,15 @@
case LuckyActivity.STATE_OPEN_FAIL:
userList = getValidJoinerList(dto.getActivityId());
+ LuckyActivity activity = luckyActivityService.getActivity(dto.getActivityId());
for (ActivitySimpleUser user : userList) {
//鍒ゆ柇鏄惁涓
UserMsgSettings settings = getUserMsgSetting(Long.parseLong(user.getUid()));
- if (settings.getNotOpenActivityMsg()) {
+ if (settings.getNotOpenActivityMsg() != null && settings.getNotOpenActivityMsg()) {
try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(user.getUid()), LuckyMsgContentFactory.createOpenFail(dto.getActivityId())));
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(user.getUid()), LuckyMsgContentFactory.createOpenFail(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞鏈紑濂栨秷鎭嚭閿�", e.getMessage(), user.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鏈紑濂栨秷鎭嚭閿� activityId-{} uid-{}", dto.getActivityId(), user.getUid(), e);
}
}
}
@@ -145,62 +167,67 @@
}
- } else if (vectors.contains(LuckyCMQConstant.TAG_ACTIVITY_JOIN)) {
+ } else if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_JOIN)) {
ActivityJoinMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityJoinMsgDTO.class);
+ LuckyActivity activity = luckyActivityService.getActivity(dto.getActivityId());
UserMsgSettings settings = getUserMsgSetting(Long.parseLong(dto.getUid()));
- if (settings.getJoinActivityMsg()) {
+ if (settings.getJoinActivityMsg() != null && settings.getJoinActivityMsg()) {
try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getUid()), LuckyMsgContentFactory.createJoinSuccess(dto.getActivityId())));
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getUid()), LuckyMsgContentFactory.createJoinSuccess(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞鍙備笌鎴愬姛娑堟伅鍑洪敊", e.getMessage(), dto.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鍙備笌鎴愬姛娑堟伅鍑洪敊 activityId-{} uid-{}", dto.getActivityId(), dto.getUid(), e);
}
}
- //鏌ヨ鏄惁鏈夊姪鍔涘埆浜�
- LuckyActivityJoinAssist assist = luckyActivityJoinAssistService.getRecord(dto.getJoinId(), dto.getAppId(), dto.getUid(), ActivityJoinAssistEvent.assistJoin);
+ //鏌ヨ鏈椿鍔ㄦ槸鍚︽湁鍔╁姏鍒汉
+ LuckyActivityJoinAssist assist = luckyActivityJoinAssistService.getRecord(null, dto.getActivityId(), dto.getAppId(), dto.getUid(), ActivityJoinAssistEvent.assist);
if (assist != null) {
//鏄惁鍔╁姏杩囧埆浜�
LuckyActivityJoinRecord joinRecord = luckyActivityJoinService.getJoinRecord(assist.getJoinId());
if (joinRecord != null) {
- settings = getUserMsgSetting(Long.parseLong(joinRecord.getUid()));
- if (settings.getAssistSuccessMsg()) {
- SimpleUser user = userInfoService.getSimpleUser(Long.parseLong(dto.getUid()));
- try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(joinRecord.getUid()), LuckyMsgContentFactory.createAssistAndJoin(dto.getActivityId(), user, assist.getWeight())));
- } catch (UserMsgException e) {
- logger.error("娣诲姞鍔╁姏鎴愬姛涓旇嚜宸卞弬鍔犳秷鎭嚭閿�", e.getMessage(), dto.getUid(), dto.getActivityId());
- }
-
+ //寰楀垢杩愬埜
+ try {
+ luckyActivityJoinAssistService.assist(activity.getId(), dto.getAppId(), dto.getUid(), joinRecord.getUid(), ActivityJoinAssistEvent.assistJoin, 1);
+ } catch (LuckyActivityException e) {
+ e.printStackTrace();
+ } catch (LuckyActivityJoinAssistException e) {
+ e.printStackTrace();
}
}
}
- } else if (vectors.contains(LuckyCMQConstant.TAG_ASSIST)) {
+ } else if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ASSIST)) {
//鍔╁姏
ActivityAssistMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityAssistMsgDTO.class);
- UserMsgSettings settings = getUserMsgSetting(Long.parseLong(dto.getUid()));
- if (settings.getAssistSuccessMsg()) {
+ LuckyActivity activity = luckyActivityService.getActivity(dto.getActivityId());
+ UserMsgSettings settings = getUserMsgSetting(Long.parseLong(dto.getTargetUid()));
+ if (settings.getAssistSuccessMsg() != null && settings.getAssistSuccessMsg()) {
LuckyActivityJoinRecord record = luckyActivityJoinService.getJoinInfo(dto.getActivityId(), dto.getAppId(), dto.getTargetUid());
if (record != null) {
- LuckyActivityJoinAssist assist = luckyActivityJoinAssistService.getRecord(record.getId(), dto.getAppId(), dto.getUid(), ActivityJoinAssistEvent.assist);
+ LuckyActivityJoinAssist assist = luckyActivityJoinAssistService.getRecord(record.getId(), null, dto.getAppId(), dto.getUid(), dto.getAssistEvent());
SimpleUser user = userInfoService.getSimpleUser(Long.parseLong(dto.getUid()));
try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getTargetUid()), LuckyMsgContentFactory.createAssist(dto.getActivityId(), user, assist.getWeight())));
+ if (dto.getAssistEvent() == ActivityJoinAssistEvent.assist) {
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getTargetUid()), LuckyMsgContentFactory.createAssist(dto.getActivityId(), activity.getCreateTime(), user, assist.getWeight())));
+ } else if (dto.getAssistEvent() == ActivityJoinAssistEvent.assistJoin) {
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getTargetUid()), LuckyMsgContentFactory.createAssistAndJoin(dto.getActivityId(), activity.getCreateTime(), user, assist.getWeight())));
+ }
} catch (UserMsgException e) {
- logger.error("娣诲姞鍔╁姏鎴愬姛娑堟伅鍑洪敊", e.getMessage(), dto.getUid(), dto.getActivityId());
+ logger.error("娣诲姞鍔╁姏鎴愬姛娑堟伅鍑洪敊锛歛ctivityId-{} uid-{}", dto.getActivityId(), dto.getUid(), e);
}
}
}
- } else if (vectors.contains(LuckyCMQConstant.TAG_ACTIVITY_DRAWN)) {
+ } else if (tag.equalsIgnoreCase(LuckyCMQConstant.TAG_ACTIVITY_DRAWN)) {
ActivityDrawnMsgDTO dto = JsonUtil.getSimpleGson().fromJson(message.msgBody, ActivityDrawnMsgDTO.class);
+ LuckyActivity activity = luckyActivityService.getActivity(dto.getActivityId());
switch (dto.getAwardResultState()) {
case LuckyActivityAwardResult.STATE_OUT_OF_DATE:
try {
- userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getUid()), LuckyMsgContentFactory.createReceiveOutDate(dto.getActivityId())));
+ userMsgService.addMsg(UserMsgFactory.createLuckyMsg(Long.parseLong(dto.getUid()), LuckyMsgContentFactory.createReceiveOutDate(dto.getActivityId(), activity.getCreateTime())));
} catch (UserMsgException e) {
- logger.error("娣诲姞杩囨湡鏈娑堟伅鍑洪敊", e.getMessage(), dto.getUid(), dto.getActivityId());
+ logger.error("娣诲姞杩囨湡鏈娑堟伅鍑洪敊锛�", dto.getActivityId(), dto.getUid(), e);
}
break;
--
Gitblit v1.8.0