From b82493b0c083ed6bd5c0013bf21b8cb651a32eec Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 26 十二月 2020 17:21:40 +0800
Subject: [PATCH] 活动图片添加,自动生成代码框架初步搭建

---
 service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityJoinAssistServiceImpl.java |   41 +++++++++++++++++++++++++++++++++++------
 1 files changed, 35 insertions(+), 6 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 3cc2424..385d8d9 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
@@ -6,26 +6,27 @@
 import com.ks.lucky.mapper.LuckyActivityJoinAssistMapper;
 import com.ks.lucky.mapper.LuckyActivityJoinRecordMapper;
 import com.ks.lucky.mapper.LuckyActivityMapper;
-import com.ks.lucky.pojo.DO.LuckyActivity;
-import com.ks.lucky.pojo.DO.LuckyActivityJoinAssist;
-import com.ks.lucky.pojo.DO.LuckyActivityJoinRecord;
-import com.ks.lucky.pojo.DO.LuckyActivityUserWeightRecord;
+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.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;
 
 import javax.annotation.Resource;
+import javax.validation.constraints.NotEmpty;
+import javax.validation.constraints.NotNull;
 import java.util.Date;
 import java.util.List;
 
-@Service(version = "1.0")
+@Service(version = "1.0.0")
 public class LuckyActivityJoinAssistServiceImpl implements LuckyActivityJoinAssistService {
 
     @Resource
@@ -46,7 +47,7 @@
     @Transactional(rollbackFor = Exception.class)
     @Validated
     @Override
-    public void assist(Long activityId, Long appId, String uid, String targetUid, LuckyActivityJoinAssist.ActivityJoinAssistEvent eventKey, int weight) throws LuckyActivityException, LuckyActivityJoinAssistException {
+    public void assist(Long activityId, Long appId, String uid, String targetUid, ActivityJoinAssistEvent eventKey, int weight) throws LuckyActivityException, LuckyActivityJoinAssistException {
 
         if (uid.equalsIgnoreCase(targetUid)) {
             throw new LuckyActivityJoinAssistException(1, "涓嶈兘涓鸿嚜宸卞姪鍔�");
@@ -100,6 +101,34 @@
         } catch (ParamsException e) {
             throw new LuckyActivityJoinAssistException(1, "娣诲姞璁板綍鍑洪敊");
         }
+
+        //鍔╁姏娑堟伅
+        CMQManager.getInstance().publishActivityAssistMsg(new ActivityAssistMsgDTO(activityId, appId, uid, targetUid, true, assist.getCreateTime()));
+    }
+
+    @Override
+    public boolean isAssisted(@NotNull Long joinId, @NotEmpty Long appId, @NotEmpty String uid, @NotNull ActivityJoinAssistEvent eventKey) {
+        ActivityJoinAssistQuery query = new ActivityJoinAssistQuery();
+        query.joinId = joinId;
+        query.appId = appId;
+        query.uid = uid;
+        query.eventKey = eventKey;
+        return luckyActivityJoinAssistMapper.count(query) > 0;
+    }
+
+    @Override
+    public LuckyActivityJoinAssist getRecord(@NotNull Long joinId, @NotEmpty Long appId, @NotEmpty String uid, @NotNull ActivityJoinAssistEvent eventKey) {
+        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);
     }
 
     @Override

--
Gitblit v1.8.0