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