From d6df4ca797ee1c6ce8fa78768f5425f187734bd9 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 18 一月 2021 18:44:08 +0800
Subject: [PATCH] 外网部署参数修改
---
service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityJoinAssistServiceImpl.java | 39 +++++++++++++++++++++++++++++++++++----
1 files changed, 35 insertions(+), 4 deletions(-)
diff --git a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityJoinAssistServiceImpl.java b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityJoinAssistServiceImpl.java
index 044abab..b15093c 100644
--- a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityJoinAssistServiceImpl.java
+++ b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityJoinAssistServiceImpl.java
@@ -9,12 +9,13 @@
import com.ks.lucky.pojo.DO.*;
import com.ks.lucky.pojo.DTO.ActivityAssistFriend;
import com.ks.lucky.pojo.DTO.ActivityFriendAssistInfo;
+import com.ks.lucky.pojo.DTO.mq.ActivityAssistMsgDTO;
import com.ks.lucky.query.ActivityJoinAssistQuery;
-import com.ks.lucky.query.ActivityJoinRecordQuery;
import com.ks.lucky.remote.service.LuckyActivityJoinAssistService;
import com.ks.lucky.service.impl.LuckyActivityJoinManager;
import com.ks.lucky.service.impl.LuckyActivityUserWeightRecordManager;
import com.ks.lucky.util.factory.LuckyActivityUserWeightRecordFactory;
+import com.ks.lucky.util.mq.CMQManager;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;
@@ -44,7 +45,6 @@
private LuckyActivityMapper luckyActivityMapper;
@Transactional(rollbackFor = Exception.class)
- @Validated
@Override
public void assist(Long activityId, Long appId, String uid, String targetUid, ActivityJoinAssistEvent eventKey, int weight) throws LuckyActivityException, LuckyActivityJoinAssistException {
@@ -94,16 +94,19 @@
luckyActivityJoinAssistMapper.insertSelective(assist);
- LuckyActivityUserWeightRecord weightRecord = LuckyActivityUserWeightRecordFactory.createAssist(activityId, appId, uid, eventKey, weight);
+ LuckyActivityUserWeightRecord weightRecord = LuckyActivityUserWeightRecordFactory.createAssist(activityId, appId, targetUid, eventKey, weight);
try {
luckyActivityUserWeightRecordManager.addRecord(weightRecord);
} catch (ParamsException e) {
throw new LuckyActivityJoinAssistException(1, "娣诲姞璁板綍鍑洪敊");
}
+
+ //鍔╁姏娑堟伅
+ CMQManager.getInstance().publishActivityAssistMsg(new ActivityAssistMsgDTO(activityId, appId, uid, targetUid, true, assist.getCreateTime(),eventKey));
}
@Override
- public boolean isAssisted(@NotNull Long joinId, @NotEmpty Long appId, @NotEmpty String uid, @NotNull ActivityJoinAssistEvent eventKey) {
+ public boolean isAssisted(@NotNull Long joinId, @NotNull Long appId, @NotEmpty String uid, @NotNull ActivityJoinAssistEvent eventKey) {
ActivityJoinAssistQuery query = new ActivityJoinAssistQuery();
query.joinId = joinId;
query.appId = appId;
@@ -113,6 +116,34 @@
}
@Override
+ public LuckyActivityJoinAssist getRecord(Long joinId, Long activityId, @NotNull Long appId, @NotEmpty String uid, @NotNull ActivityJoinAssistEvent eventKey) {
+ if (joinId != null) {
+ ActivityJoinAssistQuery query = new ActivityJoinAssistQuery();
+ query.joinId = joinId;
+ query.appId = appId;
+ query.uid = uid;
+ query.eventKey = eventKey;
+ query.count = 1;
+ List<LuckyActivityJoinAssist> assistList = luckyActivityJoinAssistMapper.list(query);
+ if (assistList == null || assistList.size() == 0) {
+ return null;
+ }
+ return assistList.get(0);
+ } else {
+ ActivityJoinAssistQuery query = new ActivityJoinAssistQuery();
+ query.appId = appId;
+ query.uid = uid;
+ query.eventKey = eventKey;
+ query.count = 1;
+ List<LuckyActivityJoinAssist> assistList = luckyActivityJoinAssistMapper.listByActivityId(query, activityId);
+ if (assistList == null || assistList.size() == 0) {
+ return null;
+ }
+ return assistList.get(0);
+ }
+ }
+
+ @Override
public List<LuckyActivityJoinAssist> getAssistRecordList(Long activityId, Long appId, String uid, int page, int pageSize) {
LuckyActivityJoinRecord record = luckyActivityJoinManager.getRecord(activityId, appId, uid);
if (record == null) {
--
Gitblit v1.8.0