| | |
| | | package com.yeshi.fanli.service.impl.user.integral;
|
| | |
|
| | | import java.math.BigDecimal;
|
| | | import java.text.ParseException;
|
| | | import java.text.SimpleDateFormat;
|
| | | import java.util.ArrayList;
|
| | | import java.util.Date;
|
| | | import java.util.List;
|
| | | import java.util.Set;
|
| | |
|
| | | import javax.annotation.Resource;
|
| | |
|
| | | import org.springframework.context.annotation.Lazy;
|
| | | import org.springframework.scheduling.annotation.Async;
|
| | | import org.springframework.stereotype.Service;
|
| | | 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.google.gson.Gson;
|
| | | 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;
|
| | | import com.yeshi.fanli.entity.integral.IntegralTask;
|
| | | import com.yeshi.fanli.entity.integral.IntegralTask.FrequencyEnum;
|
| | | import com.yeshi.fanli.entity.integral.IntegralTaskClass;
|
| | | import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;
|
| | | import com.yeshi.fanli.entity.integral.IntegralTaskRecord;
|
| | | import com.yeshi.fanli.exception.integral.IntegralTaskRecordException;
|
| | | import com.yeshi.fanli.exception.user.UserInfoExtraException;
|
| | | import com.yeshi.fanli.log.LogHelper;
|
| | | import com.yeshi.fanli.service.inter.config.ConfigService;
|
| | | import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
|
| | | import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralDetailService;
|
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralTaskClassService;
|
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService;
|
| | | 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 {
|
| | |
|
| | | @Resource
|
| | | private IntegralTaskRecordMapper integralTaskRecordMapper;
|
| | |
|
| | | @Resource
|
| | | private UserInfoExtraService userInfoExtraService;
|
| | |
|
| | | @Resource
|
| | | private IntegralDetailService integralDetailService;
|
| | |
|
| | | @Resource
|
| | | private IntegralTaskService integralTaskService;
|
| | |
|
| | | @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) {
|
| | | return integralTaskRecordMapper.getTotalGoldCoin(uid, cid, dateType);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public Integer countFinished(long uid, Long cid, Integer dateType) {
|
| | | return integralTaskRecordMapper.countFinished(uid, cid, dateType);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public void finishedTask(long uid, long cid, long taskId, int goldCoin) {
|
| | | IntegralTaskRecord taskRecord = new IntegralTaskRecord();
|
| | | taskRecord.setUid(uid);
|
| | | taskRecord.setCid(cid);
|
| | | taskRecord.setTaskId(taskId);
|
| | | taskRecord.setGoldCoin(goldCoin);
|
| | | taskRecord.setState(IntegralTaskRecord.STATE_WAITING_RECIEVE);
|
| | | taskRecord.setCreateTime(new Date());
|
| | | taskRecord.setUpdateTime(new Date());
|
| | | integralTaskRecordMapper.insertSelective(taskRecord);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public boolean isToDaySign(long uid, Long cid) {
|
| | | Integer countFinished = integralTaskRecordMapper.countFinished(uid, cid, 1);
|
| | | if (countFinished != null && countFinished > 0) {
|
| | | return true;
|
| | | }
|
| | | return false;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public Integer getNowdaySignNum(long uid, Long cid) {
|
| | | int num = 1;
|
| | | try {
|
| | | // 签到时间倒序查询近7天数据
|
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listDaySignRecord(uid, cid);
|
| | | if (list != null && list.size() > 0) {
|
| | | Date today = new Date();
|
| | | for (IntegralTaskRecord record : list) {
|
| | | if (DateUtil.daysBetween2(record.getCreateTime(), today) == 0) {
|
| | | continue;
|
| | | }
|
| | |
|
| | | if (DateUtil.daysBetween2(record.getCreateTime(), today) != 1) {
|
| | | break; // 天数未连续
|
| | | }
|
| | | today = record.getCreateTime();
|
| | | num++;
|
| | | }
|
| | | }
|
| | | } catch (Exception e) {
|
| | | LogHelper.errorDetailInfo(e);
|
| | | }
|
| | |
|
| | | if (num > 7) {
|
| | | num = 7;
|
| | | }
|
| | | return num;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<IntegralTaskRecord> getSignDaysRecord(long uid, Long cid) {
|
| | | List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>();
|
| | | try {
|
| | | // 签到时间正序序查询近7天数据
|
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listDateSignRecord(uid, cid);
|
| | | if (list != null && list.size() > 0) {
|
| | | Date date = new Date();
|
| | | for (IntegralTaskRecord record : list) {
|
| | | Date createTime = record.getCreateTime();
|
| | | if (DateUtil.daysBetween2(createTime, date) > 1) {
|
| | | break; // 天数未连续
|
| | | }
|
| | | date = createTime;
|
| | | listRecord.add(record);
|
| | | }
|
| | | }
|
| | | } catch (Exception e) {
|
| | | LogHelper.errorDetailInfo(e);
|
| | | }
|
| | | return listRecord;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<IntegralTaskRecord> getSign7DaysRecord(long uid, Long cid) {
|
| | | List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>();
|
| | | try {
|
| | | // 签到时间正序序查询近7天数据
|
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listDaySignRecord(uid, cid);
|
| | | if (list != null && list.size() > 0) {
|
| | | Date date = new Date();
|
| | | for (IntegralTaskRecord record : list) {
|
| | | Date createTime = record.getCreateTime();
|
| | | if (DateUtil.daysBetween2(createTime, date) > 1) {
|
| | | break; // 天数未连续
|
| | | }
|
| | | date = createTime;
|
| | | listRecord.add(record);
|
| | |
|
| | | if (listRecord.size() >= 7)
|
| | | break;
|
| | | }
|
| | | }
|
| | | } catch (Exception e) {
|
| | | LogHelper.errorDetailInfo(e);
|
| | | }
|
| | | return listRecord;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<IntegralTaskRecord> listNotReceived(int count, long uid) {
|
| | | return integralTaskRecordMapper.listNotReceived(count, uid);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<IntegralTaskRecord> listNotReceivedExcludeId(int count, long uid, Set<Long> idList) {
|
| | | if (idList != null && idList.size() == 0) {
|
| | | idList = null;
|
| | | }
|
| | | return integralTaskRecordMapper.listNotReceivedExcludeId(count, uid, idList);
|
| | | }
|
| | |
|
| | | @Override
|
| | | @Transactional(rollbackFor = Exception.class)
|
| | | public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {
|
| | | UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
|
| | | if (userInfoExtra == null)
|
| | | throw new IntegralTaskRecordException(1, "用户信息不全");
|
| | |
|
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listNotReceived(Integer.MAX_VALUE, uid);
|
| | | if (list == null || list.size() == 0)
|
| | | throw new IntegralTaskRecordException(1, "暂无可领取");
|
| | |
|
| | | Integer totalGoldCoin = 0;
|
| | | for (IntegralTaskRecord record : list) {
|
| | | if (addDetail(uid, record))
|
| | | totalGoldCoin += record.getGoldCoin();
|
| | | }
|
| | |
|
| | | // 更新金币
|
| | | userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
|
| | |
|
| | | return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin;
|
| | | }
|
| | |
|
| | | @Override
|
| | | @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.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)
|
| | | continue;
|
| | |
|
| | | if (addDetail(uid, record))
|
| | | totalGoldCoin += record.getGoldCoin();
|
| | | }
|
| | |
|
| | | // 更新金币
|
| | | userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
|
| | |
|
| | | 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不符合
|
| | |
|
| | | if (record.getState() != null && record.getState().intValue() == 1) {
|
| | | return false; // 已领取
|
| | | }
|
| | |
|
| | | IntegralTaskRecord taskRecord = new IntegralTaskRecord();
|
| | | taskRecord.setId(record.getId());
|
| | | taskRecord.setState(1); // 已领取
|
| | | taskRecord.setUpdateTime(new Date());
|
| | | integralTaskRecordMapper.updateByPrimaryKeySelective(taskRecord);
|
| | |
|
| | | Long cid = record.getCid();
|
| | | if (cid == null)
|
| | | return false;
|
| | |
|
| | | IntegralTaskClass taskClass = integralTaskClassService.selectByPrimaryKey(cid);
|
| | | if (taskClass == null)
|
| | | return false;
|
| | |
|
| | | Long taskId = record.getTaskId();
|
| | | if (taskId == null)
|
| | | return false;
|
| | |
|
| | | IntegralTask integralTask = integralTaskService.selectByPrimaryKey(taskId);
|
| | | if (integralTask == null)
|
| | | return false;
|
| | |
|
| | | // 加入明细
|
| | | IntegralDetail detail = new IntegralDetail();
|
| | | if (UniqueKeyEnum.dailySign == taskClass.getUniqueKey()) {
|
| | | SimpleDateFormat format = new SimpleDateFormat("yy-MM-dd HH:mm:ss");
|
| | | Date recordTime = record.getCreateTime();
|
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listSignRecordByDateTime(uid, cid,
|
| | | format.format(recordTime));
|
| | | int num = 1;
|
| | | if (list != null && list.size() > 0) {
|
| | | try {
|
| | | Date nextDate = null;
|
| | | for (IntegralTaskRecord tntegralTaskRecord : list) {
|
| | | if (nextDate == null) {
|
| | | nextDate = tntegralTaskRecord.getCreateTime();
|
| | | continue;
|
| | | }
|
| | |
|
| | | if (DateUtil.daysBetween2(tntegralTaskRecord.getCreateTime(), nextDate) != 1) {
|
| | | break; // 天数未连续
|
| | | }
|
| | | nextDate = tntegralTaskRecord.getCreateTime();
|
| | | num++;
|
| | | }
|
| | | } catch (ParseException e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | }
|
| | | detail.setTitle(taskClass.getName() + "-第" + num + "天");
|
| | | } else {
|
| | | FrequencyEnum frequency = integralTask.getFrequency();
|
| | | if (frequency == FrequencyEnum.everyday) {
|
| | | int num = integralTaskRecordMapper.countByTaskIdTodayNum(uid, taskId,
|
| | | TimeUtil.getWholeTime(record.getCreateTime().getTime()), record.getId());
|
| | | if (num <= 0)
|
| | | num = 1;
|
| | | String title = taskClass.getName() + "-" + integralTask.getName() + "-第" + num + "次";
|
| | | detail.setTitle(title);
|
| | | } else if (frequency == FrequencyEnum.onlyOne) {
|
| | | String title = taskClass.getName() + "-" + integralTask.getName();
|
| | | detail.setTitle(title);
|
| | | }
|
| | | }
|
| | |
|
| | | detail.setUid(uid);
|
| | | detail.setMoney(record.getGoldCoin());
|
| | | detail.setCreateTime(record.getCreateTime());
|
| | | integralDetailService.insertSelective(detail);
|
| | |
|
| | | return true;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public int countGetCountByTaskIdAndDay(Long taskId, Long uid, Date day) {
|
| | | Date minTime = null;
|
| | | Date maxTime = null;
|
| | | if (day == null) {
|
| | | minTime = new Date(TimeUtil.convertToTimeTemp("1970-01-01", "yyyy-MM-dd"));
|
| | | maxTime = new Date(TimeUtil.convertToTimeTemp("2100-01-01", "yyyy-MM-dd"));
|
| | | } else {
|
| | | minTime = new Date(
|
| | | TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(day.getTime(), "yyyy-MM-dd"), "yyyy-MM-dd"));
|
| | | maxTime = new Date(minTime.getTime() + 1000 * 60 * 60 * 24L);
|
| | | }
|
| | | return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime);
|
| | | }
|
| | |
|
| | | @Transactional
|
| | | @Override
|
| | | public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {
|
| | | if (record == null)
|
| | | throw new IntegralTaskRecordException(1, "记录为空");
|
| | |
|
| | | if (record.getCid() == null || record.getTaskId() == null || record.getGoldCoin() == null
|
| | | || record.getState() == null || record.getUid() == null)
|
| | | throw new IntegralTaskRecordException(2, "数据不完成");
|
| | |
|
| | | if (record.getCreateTime() == null)
|
| | | record.setCreateTime(new Date());
|
| | |
|
| | | 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;
|
| | | }
|
| | |
|
| | | @Override
|
| | | public List<IntegralTaskRecord> listByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime,
|
| | | int page, int count) {
|
| | | return integralTaskRecordMapper.listByCidAndUidAndCreateTime(cid, uid, minTime, maxTime, (page - 1) * count,
|
| | | count);
|
| | | }
|
| | |
|
| | | @Override
|
| | | public long countByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime) {
|
| | | return integralTaskRecordMapper.countByCidAndUidAndCreateTime(cid, uid, minTime, maxTime);
|
| | | }
|
| | |
|
| | | @Override
|
| | | 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))
|
| | | 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))
|
| | | return;
|
| | | firstOrderReward(uid, originUid, Integer.parseInt(reward), "二", beizu);
|
| | | }
|
| | |
|
| | | @Async()
|
| | | @Override
|
| | | public void firstShareOrderReward(Long uid, String beizu) {
|
| | | if (uid == null)
|
| | | return;
|
| | |
|
| | | String reward = configService.get("first_share_order_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))
|
| | | return;
|
| | | firstOrderReward(uid, originUid, Integer.parseInt(reward), "一", beizu);
|
| | | }
|
| | |
|
| | | /**
|
| | | * 队员首单奖励金币
|
| | | * |
| | | * @param uid
|
| | | * @param addGoldCoin
|
| | | * @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)
|
| | | uniqueKey = uniqueKey + "-" + originUid;
|
| | |
|
| | | // 判断是否已领取
|
| | | IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);
|
| | | if (detailRecord != null)
|
| | | return;
|
| | |
|
| | | UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(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.setRemark(beizu);
|
| | | detail.setUniqueKey(uniqueKey);
|
| | | detail.setCreateTime(new Date());
|
| | | integralDetailService.insertSelective(detail);
|
| | |
|
| | | // 消息
|
| | | MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();
|
| | | msgOther.setTitle("金币奖励");
|
| | | msgOther.setNum(addGoldCoin + "金币");
|
| | | msgOther.setTotal(goldCoin + "金币");
|
| | | if (StringUtil.isNullOrEmpty(level)) {
|
| | | msgOther.setSource("首笔分享订单,系统奖励金币 ");
|
| | | msgOther.setExplain("首笔分享订单得到的奖金不足0.01元时奖励 ");
|
| | | } else {
|
| | | msgOther.setSource(level + "级队员首次下单,系统奖励金币 ");
|
| | | msgOther.setExplain("仅新邀请队员首下单你得到的奖金不足0.01元时奖励 ");
|
| | | }
|
| | | 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);
|
| | | }
|
| | | }
|
| | | package com.yeshi.fanli.service.impl.user.integral; |
| | | |
| | | import java.text.ParseException; |
| | | import java.text.SimpleDateFormat; |
| | | import java.util.ArrayList; |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | import java.util.Set; |
| | | |
| | | import javax.annotation.Resource; |
| | | |
| | | import com.yeshi.fanli.entity.SystemEnum; |
| | | import com.yeshi.fanli.service.inter.user.UserInfoService; |
| | | import org.springframework.context.annotation.Lazy; |
| | | import org.springframework.scheduling.annotation.Async; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | import org.yeshi.utils.DateUtil; |
| | | |
| | | import com.yeshi.fanli.dao.mybatis.integral.IntegralTaskRecordMapper; |
| | | import com.yeshi.fanli.entity.bus.user.UserInfoExtra; |
| | | import com.yeshi.fanli.entity.integral.IntegralDetail; |
| | | import com.yeshi.fanli.entity.integral.IntegralTask; |
| | | import com.yeshi.fanli.entity.integral.IntegralTask.FrequencyEnum; |
| | | import com.yeshi.fanli.entity.integral.IntegralTaskClass; |
| | | import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum; |
| | | import com.yeshi.fanli.entity.integral.IntegralTaskRecord; |
| | | import com.yeshi.fanli.entity.system.ConfigKeyEnum; |
| | | import com.yeshi.fanli.exception.integral.IntegralTaskRecordException; |
| | | import com.yeshi.fanli.exception.user.UserInfoExtraException; |
| | | import com.yeshi.fanli.log.LogHelper; |
| | | import com.yeshi.fanli.service.inter.config.ConfigService; |
| | | import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService; |
| | | import com.yeshi.fanli.service.inter.user.UserInfoExtraService; |
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralDetailService; |
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralTaskClassService; |
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralTaskRecordService; |
| | | import com.yeshi.fanli.service.inter.user.integral.IntegralTaskService; |
| | | import com.yeshi.fanli.service.manger.msg.RocketMQManager; |
| | | import com.yeshi.fanli.util.Constant; |
| | | import com.yeshi.fanli.util.StringUtil; |
| | | import org.yeshi.utils.TimeUtil; |
| | | |
| | | @Service |
| | | public class IntegralTaskRecordServiceImpl implements IntegralTaskRecordService { |
| | | |
| | | @Resource |
| | | private IntegralTaskRecordMapper integralTaskRecordMapper; |
| | | |
| | | @Resource |
| | | private UserInfoExtraService userInfoExtraService; |
| | | |
| | | @Resource |
| | | private IntegralDetailService integralDetailService; |
| | | |
| | | @Resource |
| | | private IntegralTaskService integralTaskService; |
| | | |
| | | @Lazy |
| | | @Resource |
| | | private IntegralTaskClassService integralTaskClassService; |
| | | |
| | | @Resource |
| | | private UserOtherMsgNotificationService userOtherMsgNotificationService; |
| | | |
| | | @Resource |
| | | private ConfigService configService; |
| | | |
| | | @Resource |
| | | private RocketMQManager rocketMQManager; |
| | | |
| | | @Resource |
| | | private UserInfoService userInfoService; |
| | | |
| | | @Override |
| | | public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) { |
| | | return integralTaskRecordMapper.getTotalGoldCoin(uid, cid, dateType); |
| | | } |
| | | |
| | | @Override |
| | | public Integer countFinished(long uid, Long cid, Integer dateType) { |
| | | return integralTaskRecordMapper.countFinished(uid, cid, dateType); |
| | | } |
| | | |
| | | @Override |
| | | public void invalidGoldCoin() { |
| | | integralTaskRecordMapper.invalidGoldCoin(); |
| | | } |
| | | |
| | | @Override |
| | | public void finishedTask(long uid, long cid, long taskId, int goldCoin) { |
| | | IntegralTaskRecord taskRecord = new IntegralTaskRecord(); |
| | | taskRecord.setUid(uid); |
| | | taskRecord.setCid(cid); |
| | | taskRecord.setTaskId(taskId); |
| | | taskRecord.setGoldCoin(goldCoin); |
| | | taskRecord.setState(IntegralTaskRecord.STATE_WAITING_RECIEVE); |
| | | taskRecord.setCreateTime(new Date()); |
| | | taskRecord.setUpdateTime(new Date()); |
| | | integralTaskRecordMapper.insertSelective(taskRecord); |
| | | } |
| | | |
| | | @Override |
| | | public boolean isToDaySign(long uid, Long cid) { |
| | | Integer countFinished = integralTaskRecordMapper.countFinished(uid, cid, 1); |
| | | if (countFinished != null && countFinished > 0) { |
| | | return true; |
| | | } |
| | | return false; |
| | | } |
| | | |
| | | @Override |
| | | public Integer getNowdaySignNum(long uid, Long cid) { |
| | | int num = 1; |
| | | try { |
| | | // 签到时间倒序查询近7天数据 |
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listDaySignRecord(uid, cid); |
| | | if (list != null && list.size() > 0) { |
| | | Date today = new Date(); |
| | | for (IntegralTaskRecord record : list) { |
| | | if (DateUtil.daysBetween2(record.getCreateTime(), today) == 0) { |
| | | continue; |
| | | } |
| | | |
| | | if (DateUtil.daysBetween2(record.getCreateTime(), today) != 1) { |
| | | break; // 天数未连续 |
| | | } |
| | | today = record.getCreateTime(); |
| | | num++; |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | LogHelper.errorDetailInfo(e); |
| | | } |
| | | |
| | | if (num > 7) { |
| | | num = 7; |
| | | } |
| | | return num; |
| | | } |
| | | |
| | | @Override |
| | | public List<IntegralTaskRecord> getSignDaysRecord(long uid, Long cid) { |
| | | List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>(); |
| | | try { |
| | | // 签到时间正序序查询近7天数据 |
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listDateSignRecord(uid, cid); |
| | | if (list != null && list.size() > 0) { |
| | | Date date = new Date(); |
| | | for (IntegralTaskRecord record : list) { |
| | | Date createTime = record.getCreateTime(); |
| | | if (DateUtil.daysBetween2(createTime, date) > 1) { |
| | | break; // 天数未连续 |
| | | } |
| | | date = createTime; |
| | | listRecord.add(record); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | LogHelper.errorDetailInfo(e); |
| | | } |
| | | return listRecord; |
| | | } |
| | | |
| | | @Override |
| | | public List<IntegralTaskRecord> getSign7DaysRecord(long uid, Long cid) { |
| | | List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>(); |
| | | try { |
| | | // 签到时间正序序查询近7天数据 |
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listDaySignRecord(uid, cid); |
| | | if (list != null && list.size() > 0) { |
| | | Date date = new Date(); |
| | | for (IntegralTaskRecord record : list) { |
| | | Date createTime = record.getCreateTime(); |
| | | if (DateUtil.daysBetween2(createTime, date) > 1) { |
| | | break; // 天数未连续 |
| | | } |
| | | date = createTime; |
| | | listRecord.add(record); |
| | | |
| | | if (listRecord.size() >= 7) |
| | | break; |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | LogHelper.errorDetailInfo(e); |
| | | } |
| | | return listRecord; |
| | | } |
| | | |
| | | @Override |
| | | public List<IntegralTaskRecord> listNotReceived(int count, long uid) { |
| | | return integralTaskRecordMapper.listNotReceived(count, uid); |
| | | } |
| | | |
| | | @Override |
| | | public List<IntegralTaskRecord> listNotReceivedExcludeId(int count, long uid, Set<Long> idList) { |
| | | if (idList != null && idList.size() == 0) { |
| | | idList = null; |
| | | } |
| | | return integralTaskRecordMapper.listNotReceivedExcludeId(count, uid, idList); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException { |
| | | UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid); |
| | | if (userInfoExtra == null) |
| | | throw new IntegralTaskRecordException(1, "用户信息不全"); |
| | | |
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listNotReceived(Integer.MAX_VALUE, uid); |
| | | if (list == null || list.size() == 0) |
| | | throw new IntegralTaskRecordException(1, "暂无可领取"); |
| | | |
| | | Integer totalGoldCoin = 0; |
| | | for (IntegralTaskRecord record : list) { |
| | | if (addDetail(uid, record)) |
| | | totalGoldCoin += record.getGoldCoin(); |
| | | } |
| | | |
| | | // 更新金币 |
| | | userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin); |
| | | |
| | | return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin; |
| | | } |
| | | |
| | | @Override |
| | | @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.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 != 0) |
| | | continue; |
| | | |
| | | if (addDetail(uid, record)) |
| | | totalGoldCoin += record.getGoldCoin(); |
| | | } |
| | | |
| | | // 更新金币 |
| | | userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin); |
| | | |
| | | return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()); |
| | | } |
| | | |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean addDetail(Long uid, IntegralTaskRecord record) throws IntegralTaskRecordException { |
| | | Long uid2 = record.getUid(); |
| | | if (uid2 == null || uid.longValue() != uid2.longValue()) |
| | | return false; // 用户id不符合 |
| | | |
| | | if (record.getState() != null && record.getState().intValue() == 1) { |
| | | return false; // 已领取 |
| | | } |
| | | |
| | | IntegralTaskRecord taskRecord = new IntegralTaskRecord(); |
| | | taskRecord.setId(record.getId()); |
| | | taskRecord.setState(1); // 已领取 |
| | | taskRecord.setUpdateTime(new Date()); |
| | | integralTaskRecordMapper.updateByPrimaryKeySelective(taskRecord); |
| | | |
| | | Long cid = record.getCid(); |
| | | if (cid == null) |
| | | return false; |
| | | |
| | | IntegralTaskClass taskClass = integralTaskClassService.selectByPrimaryKey(cid); |
| | | if (taskClass == null) |
| | | return false; |
| | | |
| | | Long taskId = record.getTaskId(); |
| | | if (taskId == null) |
| | | return false; |
| | | |
| | | IntegralTask integralTask = integralTaskService.selectByPrimaryKey(taskId); |
| | | if (integralTask == null) |
| | | return false; |
| | | |
| | | // 加入明细 |
| | | IntegralDetail detail = new IntegralDetail(); |
| | | if (UniqueKeyEnum.dailySign == taskClass.getUniqueKey()) { |
| | | SimpleDateFormat format = new SimpleDateFormat("yy-MM-dd HH:mm:ss"); |
| | | Date recordTime = record.getCreateTime(); |
| | | List<IntegralTaskRecord> list = integralTaskRecordMapper.listSignRecordByDateTime(uid, cid, |
| | | format.format(recordTime)); |
| | | int num = 1; |
| | | if (list != null && list.size() > 0) { |
| | | try { |
| | | Date nextDate = null; |
| | | for (IntegralTaskRecord tntegralTaskRecord : list) { |
| | | if (nextDate == null) { |
| | | nextDate = tntegralTaskRecord.getCreateTime(); |
| | | continue; |
| | | } |
| | | |
| | | if (DateUtil.daysBetween2(tntegralTaskRecord.getCreateTime(), nextDate) != 1) { |
| | | break; // 天数未连续 |
| | | } |
| | | nextDate = tntegralTaskRecord.getCreateTime(); |
| | | num++; |
| | | } |
| | | } catch (ParseException e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | detail.setTitle(taskClass.getName() + "-第" + num + "天"); |
| | | } else { |
| | | FrequencyEnum frequency = integralTask.getFrequency(); |
| | | if (frequency == FrequencyEnum.everyday) { |
| | | int num = integralTaskRecordMapper.countByTaskIdTodayNum(uid, taskId, |
| | | TimeUtil.getWholeTime(record.getCreateTime().getTime()), record.getId()); |
| | | if (num <= 0) |
| | | num = 1; |
| | | String title = taskClass.getName() + "-" + integralTask.getName() + "-第" + num + "次"; |
| | | detail.setTitle(title); |
| | | } else if (frequency == FrequencyEnum.onlyOne) { |
| | | String title = taskClass.getName() + "-" + integralTask.getName(); |
| | | detail.setTitle(title); |
| | | } |
| | | } |
| | | |
| | | detail.setUid(uid); |
| | | detail.setMoney(record.getGoldCoin()); |
| | | detail.setCreateTime(record.getCreateTime()); |
| | | integralDetailService.insertSelective(detail); |
| | | |
| | | return true; |
| | | } |
| | | |
| | | @Override |
| | | public int countGetCountByTaskIdAndDay(Long taskId, Long uid, Date day) { |
| | | Date minTime = null; |
| | | Date maxTime = null; |
| | | if (day == null) { |
| | | minTime = new Date(TimeUtil.convertToTimeTemp("1970-01-01", "yyyy-MM-dd")); |
| | | maxTime = new Date(TimeUtil.convertToTimeTemp("2100-01-01", "yyyy-MM-dd")); |
| | | } else { |
| | | minTime = new Date( |
| | | TimeUtil.convertToTimeTemp(TimeUtil.getGernalTime(day.getTime(), "yyyy-MM-dd"), "yyyy-MM-dd")); |
| | | maxTime = new Date(minTime.getTime() + 1000 * 60 * 60 * 24L); |
| | | } |
| | | return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime); |
| | | } |
| | | |
| | | @Transactional(rollbackFor = Exception.class) |
| | | @Override |
| | | public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException { |
| | | if (record == null) |
| | | throw new IntegralTaskRecordException(1, "记录为空"); |
| | | |
| | | if (record.getCid() == null || record.getTaskId() == null || record.getGoldCoin() == null |
| | | || record.getState() == null || record.getUid() == null) |
| | | throw new IntegralTaskRecordException(2, "数据不完成"); |
| | | Date date = new Date(); |
| | | if (record.getCreateTime() == null) |
| | | record.setCreateTime(date); |
| | | |
| | | if (record.getUpdateTime() == null) |
| | | record.setUpdateTime(date); |
| | | |
| | | // 设置有效期 |
| | | record.setEndTime(DateUtil.plusDayDate(Constant.GOLD_COIN_VALID_DAYS, date)); |
| | | integralTaskRecordMapper.insertSelective(record); |
| | | return record; |
| | | } |
| | | |
| | | @Override |
| | | public List<IntegralTaskRecord> listByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime, |
| | | int page, int count) { |
| | | return integralTaskRecordMapper.listByCidAndUidAndCreateTime(cid, uid, minTime, maxTime, (page - 1) * count, |
| | | count); |
| | | } |
| | | |
| | | @Override |
| | | public long countByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime) { |
| | | return integralTaskRecordMapper.countByCidAndUidAndCreateTime(cid, uid, minTime, maxTime); |
| | | } |
| | | |
| | | @Override |
| | | public List<IntegralTaskRecord> listByUidAndTaskId(Long uid, Long taskId, int page, int count) { |
| | | return integralTaskRecordMapper.listByUidAndTaskId(uid, taskId, (page - 1) * count, count); |
| | | } |
| | | |
| | | |
| | | @Async() |
| | | @Override |
| | | public void firstRebateOrderRewardBoss(Long uid, Long originUid, String beizu) { |
| | | if (uid == null || originUid == null) |
| | | return; |
| | | |
| | | SystemEnum system = userInfoService.getUserSystem(uid); |
| | | |
| | | String reward = configService.getValue(ConfigKeyEnum.firstOrderRewardBoss.getKey(), system); |
| | | 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; |
| | | SystemEnum system = userInfoService.getUserSystem(uid); |
| | | String reward = configService.getValue(ConfigKeyEnum.firstOrderRewardBossSuper.getKey(),system); |
| | | if (StringUtil.isNullOrEmpty(reward)) |
| | | return; |
| | | firstOrderReward(uid, originUid, Integer.parseInt(reward), "二", beizu); |
| | | } |
| | | |
| | | @Async() |
| | | @Override |
| | | public void firstShareOrderReward(Long uid, String beizu) { |
| | | if (uid == null) |
| | | return; |
| | | SystemEnum system = userInfoService.getUserSystem(uid); |
| | | String reward = configService.getValue(ConfigKeyEnum.firstShareOrderReward.getKey(),system); |
| | | 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; |
| | | SystemEnum system = userInfoService.getUserSystem(uid); |
| | | String reward = configService.getValue(ConfigKeyEnum.firstShareOrderRewardBoss.getKey(),system); |
| | | if (StringUtil.isNullOrEmpty(reward)) |
| | | return; |
| | | firstOrderReward(uid, originUid, Integer.parseInt(reward), "一", beizu); |
| | | } |
| | | |
| | | /** |
| | | * 队员首单奖励金币 |
| | | * |
| | | * @param uid |
| | | * @param addGoldCoin |
| | | * @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) |
| | | uniqueKey = uniqueKey + "-" + originUid; |
| | | |
| | | // 判断是否已领取 |
| | | IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey); |
| | | if (detailRecord != null) |
| | | return; |
| | | |
| | | UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid); |
| | | if (userInfoExtra == null) |
| | | return; |
| | | |
| | | int totalGoldCoin = 0; |
| | | try { |
| | | UserInfoExtra extra = new UserInfoExtra(); |
| | | extra.setId(userInfoExtra.getId()); |
| | | Integer goldCoin = userInfoExtra.getGoldCoin(); |
| | | if (goldCoin == null) { |
| | | extra.setGoldCoin(addGoldCoin); |
| | | } else { |
| | | extra.setGoldCoin(goldCoin + addGoldCoin); |
| | | } |
| | | userInfoExtraService.saveUserInfoExtra(extra); |
| | | totalGoldCoin = extra.getGoldCoin(); |
| | | } catch (UserInfoExtraException e) { |
| | | LogHelper.errorDetailInfo(e); |
| | | return; |
| | | } |
| | | |
| | | // 金币详情 |
| | | IntegralDetail detail = new IntegralDetail(); |
| | | detail.setTitle("金币奖励"); |
| | | detail.setUid(uid); |
| | | detail.setMoney(addGoldCoin); |
| | | detail.setRemark(beizu); |
| | | detail.setUniqueKey(uniqueKey); |
| | | detail.setCreateTime(new Date()); |
| | | integralDetailService.insertSelective(detail); |
| | | |
| | | // 消息 |
| | | if (level.equalsIgnoreCase("一") || level.equalsIgnoreCase("1")) { |
| | | // 直接粉丝 |
| | | userOtherMsgNotificationService.goldCoinOrderSubsidyMsg(originUid, addGoldCoin, totalGoldCoin, true); |
| | | } else { |
| | | // 间接粉丝 |
| | | userOtherMsgNotificationService.goldCoinOrderSubsidyMsg(originUid, addGoldCoin, totalGoldCoin, false); |
| | | } |
| | | |
| | | } |
| | | |
| | | } |