From df4441322e9801c102299451da41d7c40b4502e9 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 24 六月 2021 18:53:13 +0800 Subject: [PATCH] zookeeper地址修改,Maven采用私服 --- service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityAwardResultServiceImpl.java | 34 +++++++++++++++++++++++++++++++++- 1 files changed, 33 insertions(+), 1 deletions(-) diff --git a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityAwardResultServiceImpl.java b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityAwardResultServiceImpl.java index cab38e6..45b0db4 100644 --- a/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityAwardResultServiceImpl.java +++ b/service-lucky/src/main/java/com/ks/lucky/service/impl/remote/LuckyActivityAwardResultServiceImpl.java @@ -8,6 +8,7 @@ import com.ks.lucky.pojo.DO.LuckyActivity; import com.ks.lucky.pojo.DO.LuckyActivityAwardResult; import com.ks.lucky.pojo.DO.LuckyActivityAwardResultExtra; +import com.ks.lucky.pojo.DTO.ActivityDrawnReceiveParams; import com.ks.lucky.query.ActivityAwardResultQuery; import com.ks.lucky.remote.service.LuckyActivityAwardResultService; import com.ks.lucky.service.impl.AppManager; @@ -62,7 +63,7 @@ @Transactional(rollbackFor = Exception.class) @Override - public void recieveAward(Long appId, String uid, Long activityId) throws LuckyActivityException, LuckyActivityAwardException, LuckyActivityAwardResultException { + public void recieveAward(Long appId, String uid, Long activityId, ActivityDrawnReceiveParams params) throws LuckyActivityException, LuckyActivityAwardException, LuckyActivityAwardResultException { //----------楠岃瘉寮�濮�----------- LuckyActivity activity = luckyActivityManager.selectByPrimaryKey(activityId); if (activity == null) { @@ -89,7 +90,17 @@ if (result.getState() != LuckyActivityAwardResult.STATE_NOT_RECIEVE) { throw new LuckyActivityAwardException(1, "灏氭湭澶勪簬鍙鍙栫姸鎬�"); } + + LuckyActivityAwardResultExtra extra = luckyActivityAwardResultExtraMapper.selectByAwardResultId(result.getId()); + LuckyActivityAwardResultExtra extraUpdate = new LuckyActivityAwardResultExtra(); + extraUpdate.setId(extra.getId()); + if (params.getAlipayUid() != null) { + extraUpdate.setAlipyUid(params.getAlipayUid()); + extra.setAlipyUid(params.getAlipayUid()); + } + luckyActivityAwardResultExtraMapper.updateByPrimaryKeySelective(extraUpdate); + //----------楠岃瘉缁撴潫----------- //鍙戝 @@ -158,6 +169,22 @@ } @Override + public LuckyActivityAwardResult getUnRecievedAward(Long appId, String uid, Long activityId) { + ActivityAwardResultQuery query = new ActivityAwardResultQuery(); + query.state = LuckyActivityAwardResult.STATE_NOT_RECIEVE; + query.appId = appId; + query.uid = uid; + query.activityId = activityId; + query.count = 1; + + List<LuckyActivityAwardResult> list = luckyActivityAwardResultMapper.list(query); + if (list != null && list.size() > 0) { + return list.get(0); + } + return null; + } + + @Override public long countUnRecievedAward(Long appId, String uid) { ActivityAwardResultQuery query = new ActivityAwardResultQuery(); query.state = LuckyActivityAwardResult.STATE_NOT_RECIEVE; @@ -166,5 +193,10 @@ return luckyActivityAwardResultMapper.count(query); } + @Override + public LuckyActivityAwardResult getDetail(Long id) { + return luckyActivityAwardResultMapper.selectByPrimaryKey(id); + } + } -- Gitblit v1.8.0