大淘客搜索接口升级

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);

   }

}