admin
2020-11-28 dc5be7d38446f70e6ff86df311119c32b41fe7f8
fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java
@@ -1,6 +1,5 @@
package com.yeshi.fanli.service.impl.user.integral;
import java.math.BigDecimal;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
@@ -10,15 +9,15 @@
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.aliyun.openservices.ons.api.Producer;
import com.yeshi.fanli.dao.mybatis.integral.IntegralTaskRecordMapper;
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;
@@ -37,527 +36,473 @@
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 com.yeshi.fanli.util.TimeUtil;
import org.yeshi.utils.TimeUtil;
@Service
public class IntegralTaskRecordServiceImpl implements IntegralTaskRecordService {
   @Resource
   private IntegralTaskRecordMapper integralTaskRecordMapper;
    @Resource
    private IntegralTaskRecordMapper integralTaskRecordMapper;
   @Resource
   private UserInfoExtraService userInfoExtraService;
    @Resource
    private UserInfoExtraService userInfoExtraService;
   @Resource
   private IntegralDetailService integralDetailService;
    @Resource
    private IntegralDetailService integralDetailService;
   @Resource
   private IntegralTaskService integralTaskService;
    @Resource
    private IntegralTaskService integralTaskService;
   @Lazy
   @Resource
   private IntegralTaskClassService integralTaskClassService;
    @Lazy
    @Resource
    private IntegralTaskClassService integralTaskClassService;
   @Resource
   private UserOtherMsgNotificationService userOtherMsgNotificationService;
    @Resource
    private UserOtherMsgNotificationService userOtherMsgNotificationService;
   @Resource
   private ConfigService configService;
    @Resource
    private ConfigService configService;
   @Resource(name = "producer")
   private Producer producer;
    @Resource
    private RocketMQManager rocketMQManager;
   @Override
   public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) {
      return integralTaskRecordMapper.getTotalGoldCoin(uid, cid, dateType);
   }
    @Resource
    private UserInfoService userInfoService;
   @Override
   public Integer countFinished(long uid, Long cid, Integer dateType) {
      return integralTaskRecordMapper.countFinished(uid, cid, dateType);
   }
    @Override
    public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) {
        return integralTaskRecordMapper.getTotalGoldCoin(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 Integer countFinished(long uid, Long cid, Integer dateType) {
        return integralTaskRecordMapper.countFinished(uid, cid, dateType);
    }
   @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 void invalidGoldCoin() {
        integralTaskRecordMapper.invalidGoldCoin();
    }
   @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;
               }
    @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);
    }
               if (DateUtil.daysBetween2(record.getCreateTime(), today) != 1) {
                  break; // 天数未连续
               }
               today = record.getCreateTime();
               num++;
            }
         }
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
    @Override
    public boolean isToDaySign(long uid, Long cid) {
        Integer countFinished = integralTaskRecordMapper.countFinished(uid, cid, 1);
        if (countFinished != null && countFinished > 0) {
            return true;
        }
        return false;
    }
      if (num > 7) {
         num = 7;
      }
      return num;
   }
    @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;
                    }
   @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;
   }
                    if (DateUtil.daysBetween2(record.getCreateTime(), today) != 1) {
                        break; // 天数未连续
                    }
                    today = record.getCreateTime();
                    num++;
                }
            }
        } catch (Exception e) {
            LogHelper.errorDetailInfo(e);
        }
   @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 (num > 7) {
            num = 7;
        }
        return num;
    }
               if (listRecord.size() >= 7)
                  break;
            }
         }
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
      return listRecord;
   }
    @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> listNotReceived(int count, long uid) {
      return integralTaskRecordMapper.listNotReceived(count, uid);
   }
    @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);
   @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);
   }
                    if (listRecord.size() >= 7)
                        break;
                }
            }
        } catch (Exception e) {
            LogHelper.errorDetailInfo(e);
        }
        return listRecord;
    }
   @Override
   @Transactional(rollbackFor = Exception.class)
   public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {
      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
      if (userInfoExtra == null)
         throw new IntegralTaskRecordException(1, "用户信息不全");
    @Override
    public List<IntegralTaskRecord> listNotReceived(int count, long uid) {
        return integralTaskRecordMapper.listNotReceived(count, uid);
    }
      List<IntegralTaskRecord> list = integralTaskRecordMapper.listNotReceived(Integer.MAX_VALUE, uid);
      if (list == null || list.size() == 0)
         throw new IntegralTaskRecordException(1, "暂无可领取");
    @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);
    }
      Integer totalGoldCoin = 0;
      for (IntegralTaskRecord record : list) {
         if (addDetail(uid, record))
            totalGoldCoin += record.getGoldCoin();
      }
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {
        UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
        if (userInfoExtra == null)
            throw new IntegralTaskRecordException(1, "用户信息不全");
      // 更新金币
      userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
        List<IntegralTaskRecord> list = integralTaskRecordMapper.listNotReceived(Integer.MAX_VALUE, uid);
        if (list == null || list.size() == 0)
            throw new IntegralTaskRecordException(1, "暂无可领取");
      return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin;
   }
        Integer totalGoldCoin = 0;
        for (IntegralTaskRecord record : list) {
            if (addDetail(uid, record))
                totalGoldCoin += record.getGoldCoin();
        }
   @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为空");
      }
        // 更新金币
        userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
      if (userInfoExtra == null) {
         throw new IntegralTaskRecordException(1, "用户信息不全");
      }
        return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin;
    }
      Integer totalGoldCoin = 0;
      for (Long id : idList) {
         IntegralTaskRecord record = integralTaskRecordMapper.selectByPrimaryKey(id);
         if (record == null)
            continue;
    @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为空");
        }
         // 已领取
         Integer state = record.getState();
         if (state != null && state != 0)
            continue;
        UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);
        if (userInfoExtra == null) {
            throw new IntegralTaskRecordException(1, "用户信息不全");
        }
         if (addDetail(uid, record))
            totalGoldCoin += record.getGoldCoin();
      }
        Integer totalGoldCoin = 0;
        for (Long id : idList) {
            IntegralTaskRecord record = integralTaskRecordMapper.selectByPrimaryKey(id);
            if (record == null)
                continue;
      // 更新金币
      userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
            // 已领取
            Integer state = record.getState();
            if (state != null && state != 0)
                continue;
      return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin());
   }
            if (addDetail(uid, record))
                totalGoldCoin += record.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不符合
        // 更新金币
        userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);
      if (record.getState() != null && record.getState().intValue() == 1) {
         return false; // 已领取
      }
        return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin());
    }
      IntegralTaskRecord taskRecord = new IntegralTaskRecord();
      taskRecord.setId(record.getId());
      taskRecord.setState(1); // 已领取
      taskRecord.setUpdateTime(new Date());
      integralTaskRecordMapper.updateByPrimaryKeySelective(taskRecord);
    @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不符合
      Long cid = record.getCid();
      if (cid == null)
         return false;
        if (record.getState() != null && record.getState().intValue() == 1) {
            return false; // 已领取
        }
      IntegralTaskClass taskClass = integralTaskClassService.selectByPrimaryKey(cid);
      if (taskClass == null)
         return false;
        IntegralTaskRecord taskRecord = new IntegralTaskRecord();
        taskRecord.setId(record.getId());
        taskRecord.setState(1); // 已领取
        taskRecord.setUpdateTime(new Date());
        integralTaskRecordMapper.updateByPrimaryKeySelective(taskRecord);
      Long taskId = record.getTaskId();
      if (taskId == null)
         return false;
        Long cid = record.getCid();
        if (cid == null)
            return false;
      IntegralTask integralTask = integralTaskService.selectByPrimaryKey(taskId);
      if (integralTask == null)
         return false;
        IntegralTaskClass taskClass = integralTaskClassService.selectByPrimaryKey(cid);
        if (taskClass == 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;
                  }
        Long taskId = record.getTaskId();
        if (taskId == null)
            return false;
                  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);
   }
        IntegralTask integralTask = integralTaskService.selectByPrimaryKey(taskId);
        if (integralTask == null)
            return false;
   @Transactional(rollbackFor = Exception.class)
   @Override
   public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {
      if (record == null)
         throw new IntegralTaskRecordException(1, "记录为空");
        // 加入明细
        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 (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 (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);
            }
        }
      if (record.getUpdateTime() == null)
         record.setUpdateTime(date);
      // 设置有效期
      record.setEndTime(DateUtil.plusDayDate(Constant.GOLD_COIN_VALID_DAYS, date));
      integralTaskRecordMapper.insertSelective(record);
      return record;
   }
        detail.setUid(uid);
        detail.setMoney(record.getGoldCoin());
        detail.setCreateTime(record.getCreateTime());
        integralDetailService.insertSelective(detail);
   @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);
   }
        return true;
    }
   @Override
   public long countByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime) {
      return integralTaskRecordMapper.countByCidAndUidAndCreateTime(cid, uid, minTime, maxTime);
   }
    @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);
    }
   @Override
   public List<IntegralTaskRecord> listByUidAndTaskId(Long uid, Long taskId, int page, int count) {
      return integralTaskRecordMapper.listByUidAndTaskId(uid, taskId, (page - 1) * count, count);
   }
    @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);
   @Async()
   @Override
   public void firstRebateOrderRewardBoss(Long uid, Long originUid, String beizu) {
      if (uid == null || originUid == null)
         return;
        if (record.getUpdateTime() == null)
            record.setUpdateTime(date);
      String reward = configService.get(ConfigKeyEnum.firstOrderRewardBoss.getKey());
      if (StringUtil.isNullOrEmpty(reward))
         return;
      firstOrderReward(uid, originUid, Integer.parseInt(reward), "一", beizu);
   }
        // 设置有效期
        record.setEndTime(DateUtil.plusDayDate(Constant.GOLD_COIN_VALID_DAYS, date));
        integralTaskRecordMapper.insertSelective(record);
        return record;
    }
   @Async()
   @Override
   public void firstRebateOrderRewardBossSuper(Long uid, Long originUid, String beizu) {
      if (uid == null || originUid == null)
         return;
    @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);
    }
      String reward = configService.get(ConfigKeyEnum.firstOrderRewardBossSuper.getKey());
      if (StringUtil.isNullOrEmpty(reward))
         return;
      firstOrderReward(uid, originUid, Integer.parseInt(reward), "二", beizu);
   }
    @Override
    public long countByCidAndUidAndCreateTime(Long cid, Long uid, Date minTime, Date maxTime) {
        return integralTaskRecordMapper.countByCidAndUidAndCreateTime(cid, uid, minTime, maxTime);
    }
   @Async()
   @Override
   public void firstShareOrderReward(Long uid, String beizu) {
      if (uid == null)
         return;
    @Override
    public List<IntegralTaskRecord> listByUidAndTaskId(Long uid, Long taskId, int page, int count) {
        return integralTaskRecordMapper.listByUidAndTaskId(uid, taskId, (page - 1) * count, count);
    }
      String reward = configService.get(ConfigKeyEnum.firstShareOrderReward.getKey());
      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;
    @Async()
    @Override
    public void firstRebateOrderRewardBoss(Long uid, Long originUid, String beizu) {
        if (uid == null || originUid == null)
            return;
      String reward = configService.get(ConfigKeyEnum.firstShareOrderRewardBoss.getKey());
      if (StringUtil.isNullOrEmpty(reward))
         return;
      firstOrderReward(uid, originUid, Integer.parseInt(reward), "一", beizu);
   }
        SystemEnum system = userInfoService.getUserSystem(uid);
   /**
    * 队员首单奖励金币
    *
    * @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;
        String reward = configService.getValue(ConfigKeyEnum.firstOrderRewardBoss.getKey(), system);
        if (StringUtil.isNullOrEmpty(reward))
            return;
        firstOrderReward(uid, originUid, Integer.parseInt(reward), "一", beizu);
    }
      // 判断是否已领取
      IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);
      if (detailRecord != null)
         return;
    @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);
    }
      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
      if (userInfoExtra == null)
         return;
    @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);
    }
      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;
      }
    @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);
    }
      // 金币详情
      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);
    /**
     * 队员首单奖励金币
     *
     * @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;
      // 消息
      MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();
      msgOther.setTitle("金币奖励");
      msgOther.setNum(addGoldCoin + "金币");
      msgOther.setTotal(totalGoldCoin + "金币");
      if (StringUtil.isNullOrEmpty(level)) {
         msgOther.setSource("首笔分享订单,系统奖励金币 ");
         msgOther.setExplain("首笔分享订单得到的奖金不足0.01元时奖励 ");
      } else {
         if (level.equalsIgnoreCase("一") || level.equalsIgnoreCase("1"))
            msgOther.setSource("直接粉丝首次下单,系统奖励金币 ");
         else
            msgOther.setSource("间接粉丝首次下单,系统奖励金币 ");
         msgOther.setExplain("仅新邀请粉丝首下单你得到的奖金不足0.01元时奖励 ");
      }
      userOtherMsgNotificationService.firstOrderRewardMsg(uid, null, msgOther);
   }
        // 判断是否已领取
        IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);
        if (detailRecord != null)
            return;
   /**
    * 推广红包折算金币
    *
    * @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.getUserInfoExtra(uid);
        if (userInfoExtra == null)
            return;
      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(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;
        }
      Integer goldCoin = userInfoExtra.getGoldCoin();
      if (goldCoin == null)
         goldCoin = 0;
      goldCoin = goldCoin + addGoldCoin;
        // 金币详情
        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);
      try {
         UserInfoExtra extra = new UserInfoExtra();
         extra.setId(userInfoExtra.getId());
         extra.setGoldCoin(goldCoin);
         userInfoExtraService.saveUserInfoExtra(extra);
      } catch (UserInfoExtraException e) {
         LogHelper.errorDetailInfo(e);
         return;
      }
        // 消息
        if (level.equalsIgnoreCase("一") || level.equalsIgnoreCase("1")) {
            // 直接粉丝
            userOtherMsgNotificationService.goldCoinOrderSubsidyMsg(originUid, addGoldCoin, totalGoldCoin, true);
        } else {
            // 间接粉丝
            userOtherMsgNotificationService.goldCoinOrderSubsidyMsg(originUid, addGoldCoin, totalGoldCoin, false);
        }
      // 金币详情
      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);
   }
}