From 220bdea9288ee5b07f124900eb71ac1f56552b55 Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期六, 07 十二月 2019 15:26:30 +0800
Subject: [PATCH] 分享记录
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java | 196 +++++++++++++++++++++++++++++++------------------
1 files changed, 124 insertions(+), 72 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java
index a9e170a..d118e16 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java
@@ -1,5 +1,6 @@
package com.yeshi.fanli.service.impl.user.integral;
+import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
@@ -15,7 +16,11 @@
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.DateUtil;
+import com.aliyun.openservices.ons.api.Message;
+import com.aliyun.openservices.ons.api.Producer;
import com.yeshi.fanli.dao.mybatis.integral.IntegralTaskRecordMapper;
+import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
+import com.yeshi.fanli.dto.mq.user.body.IntegralTaskMQMsg;
import com.yeshi.fanli.dto.msg.MsgOtherRewardIntegralDTO;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.integral.IntegralDetail;
@@ -36,6 +41,8 @@
import com.yeshi.fanli.service.inter.user.integral.IntegralTaskService;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
+import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
+import com.yeshi.fanli.util.rocketmq.MQTopicName;
@Service
public class IntegralTaskRecordServiceImpl implements IntegralTaskRecordService {
@@ -55,14 +62,15 @@
@Lazy
@Resource
private IntegralTaskClassService integralTaskClassService;
-
+
@Resource
private UserOtherMsgNotificationService userOtherMsgNotificationService;
-
+
@Resource
private ConfigService configService;
-
-
+
+ @Resource(name = "producer")
+ private Producer producer;
@Override
public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) {
@@ -81,7 +89,7 @@
taskRecord.setCid(cid);
taskRecord.setTaskId(taskId);
taskRecord.setGoldCoin(goldCoin);
- taskRecord.setState(0);
+ taskRecord.setState(IntegralTaskRecord.STATE_WAITING_RECIEVE);
taskRecord.setCreateTime(new Date());
taskRecord.setUpdateTime(new Date());
integralTaskRecordMapper.insertSelective(taskRecord);
@@ -149,7 +157,6 @@
return listRecord;
}
-
@Override
public List<IntegralTaskRecord> getSign7DaysRecord(long uid, Long cid) {
List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>();
@@ -165,8 +172,8 @@
}
date = createTime;
listRecord.add(record);
-
- if(listRecord.size() >= 7)
+
+ if (listRecord.size() >= 7)
break;
}
}
@@ -175,7 +182,7 @@
}
return listRecord;
}
-
+
@Override
public List<IntegralTaskRecord> listNotReceived(int count, long uid) {
return integralTaskRecordMapper.listNotReceived(count, uid);
@@ -190,9 +197,9 @@
}
@Override
- @Transactional
+ @Transactional(rollbackFor = Exception.class)
public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {
- UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+ UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
if (userInfoExtra == null)
throw new IntegralTaskRecordException(1, "鐢ㄦ埛淇℃伅涓嶅叏");
@@ -206,67 +213,47 @@
totalGoldCoin += record.getGoldCoin();
}
- Integer goldCoin = userInfoExtra.getGoldCoin();
- if (goldCoin == null)
- goldCoin = 0;
+ // 鏇存柊閲戝竵
+ userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
- UserInfoExtra extra = new UserInfoExtra();
- extra.setId(userInfoExtra.getId());
- extra.setGoldCoin(goldCoin + totalGoldCoin);
- try {
- userInfoExtraService.saveUserInfoExtra(extra);
- } catch (UserInfoExtraException e) {
- throw new IntegralTaskRecordException(1, "鐢ㄦ埛淇℃伅涓嶅叏");
- }
-
- return extra.getGoldCoin();
+ return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin;
}
@Override
- @Transactional
+ @Transactional(rollbackFor = Exception.class)
public Integer receiveGoldCoin(Long uid, Set<Long> idList) throws IntegralTaskRecordException {
if (idList == null || idList.size() == 0) {
throw new IntegralTaskRecordException(1, "id涓虹┖");
}
- UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+ UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
if (userInfoExtra == null) {
throw new IntegralTaskRecordException(1, "鐢ㄦ埛淇℃伅涓嶅叏");
}
-
+
Integer totalGoldCoin = 0;
for (Long id : idList) {
IntegralTaskRecord record = integralTaskRecordMapper.selectByPrimaryKey(id);
if (record == null)
continue;
-
+
// 宸查鍙�
Integer state = record.getState();
- if (state != null && state == 1)
+ if (state != null && state == 1)
continue;
-
+
if (addDetail(uid, record))
totalGoldCoin += record.getGoldCoin();
}
- Integer goldCoin = userInfoExtra.getGoldCoin();
- if (goldCoin == null)
- goldCoin = 0;
+ // 鏇存柊閲戝竵
+ userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
- UserInfoExtra extra = new UserInfoExtra();
- extra.setId(userInfoExtra.getId());
- extra.setGoldCoin(goldCoin + totalGoldCoin);
- try {
- userInfoExtraService.saveUserInfoExtra(extra);
- } catch (UserInfoExtraException e) {
- throw new IntegralTaskRecordException(1, "鐢ㄦ埛淇℃伅涓嶅叏");
- }
-
- return extra.getGoldCoin();
+ return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin());
}
+ @Transactional
public boolean addDetail(Long uid, IntegralTaskRecord record) throws IntegralTaskRecordException {
-
Long uid2 = record.getUid();
if (uid2 == null || uid.longValue() != uid2.longValue())
return false; // 鐢ㄦ埛id涓嶇鍚�
@@ -329,7 +316,7 @@
FrequencyEnum frequency = integralTask.getFrequency();
if (frequency == FrequencyEnum.everyday) {
int num = integralTaskRecordMapper.countByTaskIdTodayNum(uid, taskId,
- TimeUtil.getWholeTime(record.getCreateTime().getTime()));
+ TimeUtil.getWholeTime(record.getCreateTime().getTime()), record.getId());
if (num <= 0)
num = 1;
String title = taskClass.getName() + "-" + integralTask.getName() + "-绗�" + num + "娆�";
@@ -363,6 +350,7 @@
return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime);
}
+ @Transactional
@Override
public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {
if (record == null)
@@ -378,6 +366,14 @@
if (record.getUpdateTime() == null)
record.setUpdateTime(new Date());
integralTaskRecordMapper.insertSelective(record);
+ long count = integralTaskRecordMapper.getTotalGoldCoinByUid(record.getUid());
+ if (count >= 200) {// 澶т簬200鍙戦�佹秷鎭�
+ IntegralTaskMQMsg msg = new IntegralTaskMQMsg(record.getUid(), count, new Date());
+ Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.integralTaskFinish,
+ msg);
+ producer.send(message);
+ }
+
return record;
}
@@ -397,85 +393,88 @@
public List<IntegralTaskRecord> listByUidAndTaskId(Long uid, Long taskId, int page, int count) {
return integralTaskRecordMapper.listByUidAndTaskId(uid, taskId, (page - 1) * count, count);
}
-
-
+
+ @Override
+ public long getTotalGoldCoinByUid(Long uid) {
+ return integralTaskRecordMapper.getTotalGoldCoinByUid(uid);
+ }
+
@Async()
@Override
public void firstRebateOrderRewardBoss(Long uid, Long originUid, String beizu) {
if (uid == null || originUid == null)
return;
-
+
String reward = configService.get("first_order_reward_boss");
- if (StringUtil.isNullOrEmpty(reward))
+ if (StringUtil.isNullOrEmpty(reward))
return;
firstOrderReward(uid, originUid, Integer.parseInt(reward), "涓�", beizu);
}
-
+
@Async()
@Override
public void firstRebateOrderRewardBossSuper(Long uid, Long originUid, String beizu) {
if (uid == null || originUid == null)
return;
-
+
String reward = configService.get("first_order_reward_boss_super");
- if (StringUtil.isNullOrEmpty(reward))
+ if (StringUtil.isNullOrEmpty(reward))
return;
firstOrderReward(uid, originUid, Integer.parseInt(reward), "浜�", beizu);
}
-
-
+
@Async()
@Override
public void firstShareOrderReward(Long uid, String beizu) {
- if(uid == null)
+ if (uid == null)
return;
-
+
String reward = configService.get("first_share_order_reward");
- if (StringUtil.isNullOrEmpty(reward))
+ if (StringUtil.isNullOrEmpty(reward))
return;
firstOrderReward(uid, null, Integer.parseInt(reward), null, beizu);
}
-
-
+
@Async()
@Override
public void firstSharerOrderRewardBoss(Long uid, Long originUid, String beizu) {
if (uid == null || originUid == null)
return;
-
+
String reward = configService.get("first_share_order_reward_boss");
- if (StringUtil.isNullOrEmpty(reward))
+ if (StringUtil.isNullOrEmpty(reward))
return;
firstOrderReward(uid, originUid, Integer.parseInt(reward), "涓�", beizu);
}
-
-
+
/**
* 闃熷憳棣栧崟濂栧姳閲戝竵
+ *
* @param uid
* @param addGoldCoin
- * @param level 鎵�灞炲摢绾ч槦鍛�
+ * @param level
+ * 鎵�灞炲摢绾ч槦鍛�
* @param beizu
*/
private void firstOrderReward(Long uid, Long originUid, Integer addGoldCoin, String level, String beizu) {
- String uniqueKey = "firstOrder-"+ uid.toString();
- if (originUid != null)
+ String uniqueKey = "firstOrder-" + uid.toString();
+ if (originUid != null)
uniqueKey = uniqueKey + "-" + originUid;
-
+
// 鍒ゆ柇鏄惁宸查鍙�
IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);
if (detailRecord != null)
return;
-
+
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
- if (userInfoExtra == null)
+ if (userInfoExtra == null)
return;
-
+
Integer goldCoin = userInfoExtra.getGoldCoin();
if (goldCoin == null)
goldCoin = 0;
goldCoin = goldCoin + addGoldCoin;
-
+
try {
UserInfoExtra extra = new UserInfoExtra();
extra.setId(userInfoExtra.getId());
@@ -495,7 +494,7 @@
detail.setUniqueKey(uniqueKey);
detail.setCreateTime(new Date());
integralDetailService.insertSelective(detail);
-
+
// 娑堟伅
MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();
msgOther.setTitle("閲戝竵濂栧姳");
@@ -510,4 +509,57 @@
}
userOtherMsgNotificationService.firstOrderRewardMsg(uid, null, msgOther);
}
+
+ /**
+ * 鎺ㄥ箍绾㈠寘鎶樼畻閲戝竵
+ *
+ * @param uid
+ * @param addGoldCoin
+ * @param tlj
+ */
+ @Override
+ @Transactional(rollbackFor = Exception.class)
+ public void taoLiJinExchange(Long uid, Integer addGoldCoin, BigDecimal tlj) {
+ String uniqueKey = "taoLiJinExchange-" + uid.toString();
+ IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);
+ if (detailRecord != null)
+ return;
+
+ UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
+ if (userInfoExtra == null)
+ return;
+
+ Integer goldCoin = userInfoExtra.getGoldCoin();
+ if (goldCoin == null)
+ goldCoin = 0;
+ goldCoin = goldCoin + addGoldCoin;
+
+ try {
+ UserInfoExtra extra = new UserInfoExtra();
+ extra.setId(userInfoExtra.getId());
+ extra.setGoldCoin(goldCoin);
+ userInfoExtraService.saveUserInfoExtra(extra);
+ } catch (UserInfoExtraException e) {
+ LogHelper.errorDetailInfo(e);
+ return;
+ }
+
+ // 閲戝竵璇︽儏
+ IntegralDetail detail = new IntegralDetail();
+ detail.setTitle("鎺ㄥ箍绾㈠寘涓嬬嚎-绯荤粺鎶樼畻鎴愰噾甯�");
+ detail.setUid(uid);
+ detail.setMoney(addGoldCoin);
+ detail.setUniqueKey(uniqueKey);
+ detail.setCreateTime(new Date());
+ integralDetailService.insertSelective(detail);
+
+ // 娑堟伅
+ MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();
+ msgOther.setTitle("鎺ㄥ箍绾㈠寘");
+ msgOther.setTotal("鎺ㄥ箍绾㈠寘楼" + tlj.setScale(2));
+ msgOther.setNum(addGoldCoin + "鏋�");
+ msgOther.setSource("宸茶繘鍏ュ埌鍙敤閲戝竵涓�");
+ msgOther.setExplain("鍘熸帹骞跨孩鍖呭姛鑳戒笅绾匡紝鍓╀綑鎺ㄥ箍绾㈠寘鎸夌収10:1鎶樼畻涓洪噾甯� ");
+ userOtherMsgNotificationService.taoLiJinExchangeMsg(uid, "鏈姌绠楁湁涓斾粎鏈変竴娆�", msgOther);
+ }
}
--
Gitblit v1.8.0