饿了么绘图，添加口碑

admin

2020-05-19 744594ef1a2f530fc3e86ea9dc48b62247f79420

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/integral/IntegralTaskRecordServiceImpl.java

@@ -15,8 +15,8 @@
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;

@@ -24,6 +24,7 @@
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;

@@ -34,6 +35,7 @@
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.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;



@@ -55,14 +57,15 @@
   @Lazy

   @Resource

   private IntegralTaskClassService integralTaskClassService;

	


   @Resource

   private UserOtherMsgNotificationService userOtherMsgNotificationService;

	


   @Resource

   private ConfigService configService;

	
	


   @Resource(name = "producer")

   private Producer producer;



   @Override

   public Integer getTotalGoldCoin(long uid, Long cid, Integer dateType) {

@@ -75,13 +78,18 @@
   }



   @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(0);

      taskRecord.setState(IntegralTaskRecord.STATE_WAITING_RECIEVE);

      taskRecord.setCreateTime(new Date());

      taskRecord.setUpdateTime(new Date());

      integralTaskRecordMapper.insertSelective(taskRecord);

@@ -149,7 +157,6 @@
      return listRecord;

   }



	
   @Override

   public List<IntegralTaskRecord> getSign7DaysRecord(long uid, Long cid) {

      List<IntegralTaskRecord> listRecord = new ArrayList<IntegralTaskRecord>();

@@ -165,8 +172,8 @@
               }

               date = createTime;

               listRecord.add(record);

					
               if(listRecord.size() >= 7)



               if (listRecord.size() >= 7)

                  break;

            }

         }

@@ -175,7 +182,7 @@
      }

      return listRecord;

   }

	


   @Override

   public List<IntegralTaskRecord> listNotReceived(int count, long uid) {

      return integralTaskRecordMapper.listNotReceived(count, uid);

@@ -190,9 +197,9 @@
   }



   @Override

   @Transactional

   @Transactional(rollbackFor = Exception.class)

   public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {

      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);

      if (userInfoExtra == null)

         throw new IntegralTaskRecordException(1, "用户信息不全");



@@ -206,67 +213,47 @@
            totalGoldCoin += record.getGoldCoin();

      }



      Integer goldCoin = userInfoExtra.getGoldCoin();

      if (goldCoin == null)

         goldCoin = 0;

      // 更新金币

      userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);



      UserInfoExtra extra = new UserInfoExtra();

      extra.setId(userInfoExtra.getId());

      extra.setGoldCoin(goldCoin + totalGoldCoin);

      try {

         userInfoExtraService.saveUserInfoExtra(extra);

      } catch (UserInfoExtraException e) {

         throw new IntegralTaskRecordException(1, "用户信息不全");

      }



      return extra.getGoldCoin();

      return (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin()) + totalGoldCoin;

   }



   @Override

   @Transactional

   @Transactional(rollbackFor = Exception.class)

   public Integer receiveGoldCoin(Long uid, Set<Long> idList) throws IntegralTaskRecordException {

      if (idList == null || idList.size() == 0) {

         throw new IntegralTaskRecordException(1, "id为空");

      }



      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);

      if (userInfoExtra == null) {

         throw new IntegralTaskRecordException(1, "用户信息不全");

      }

 


      Integer totalGoldCoin = 0;

      for (Long id : idList) {

         IntegralTaskRecord record = integralTaskRecordMapper.selectByPrimaryKey(id);

         if (record == null)

            continue;

			


         // 已领取

         Integer state = record.getState();

         if (state != null && state == 1) 
         if (state != null && state != 0)

            continue;

			


         if (addDetail(uid, record))

            totalGoldCoin += record.getGoldCoin();

      }



      Integer goldCoin = userInfoExtra.getGoldCoin();

      if (goldCoin == null)

         goldCoin = 0;

      // 更新金币

      userInfoExtraService.updateGoldCoin(userInfoExtra.getId(), totalGoldCoin);



      UserInfoExtra extra = new UserInfoExtra();

      extra.setId(userInfoExtra.getId());

      extra.setGoldCoin(goldCoin + totalGoldCoin);

      try {

         userInfoExtraService.saveUserInfoExtra(extra);

      } catch (UserInfoExtraException e) {

         throw new IntegralTaskRecordException(1, "用户信息不全");

      }



      return extra.getGoldCoin();

      return totalGoldCoin + (userInfoExtra.getGoldCoin() == null ? 0 : userInfoExtra.getGoldCoin());

   }



   @Transactional(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不符合

@@ -329,7 +316,7 @@
         FrequencyEnum frequency = integralTask.getFrequency();

         if (frequency == FrequencyEnum.everyday) {

            int num = integralTaskRecordMapper.countByTaskIdTodayNum(uid, taskId,

                  TimeUtil.getWholeTime(record.getCreateTime().getTime()));

                  TimeUtil.getWholeTime(record.getCreateTime().getTime()), record.getId());

            if (num <= 0)

               num = 1;

            String title = taskClass.getName() + "-" + integralTask.getName() + "-第" + num + "次";

@@ -363,6 +350,7 @@
      return integralTaskRecordMapper.countGetCountByTaskIdAndDay(taskId, uid, minTime, maxTime);

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

   public IntegralTaskRecord addRecord(IntegralTaskRecord record) throws IntegralTaskRecordException {

      if (record == null)

@@ -371,12 +359,15 @@
      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(new Date());

         record.setCreateTime(date);



      if (record.getUpdateTime() == null)

         record.setUpdateTime(new Date());

         record.setUpdateTime(date);

		
      // 设置有效期

      record.setEndTime(DateUtil.plusDayDate(Constant.GOLD_COIN_VALID_DAYS, date));

      integralTaskRecordMapper.insertSelective(record);

      return record;

   }

@@ -397,90 +388,91 @@
   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;

		
      String reward = configService.get("first_order_reward_boss");

      if (StringUtil.isNullOrEmpty(reward)) 


      String reward = configService.get(ConfigKeyEnum.firstOrderRewardBoss.getKey());

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


      String reward = configService.get(ConfigKeyEnum.firstOrderRewardBossSuper.getKey());

      if (StringUtil.isNullOrEmpty(reward))

         return;

      firstOrderReward(uid, originUid, Integer.parseInt(reward), "二", beizu);

   }

	
	


   @Async()

   @Override

   public void firstShareOrderReward(Long uid, String beizu) {

      if(uid == null)

      if (uid == null)

         return;

		
      String reward = configService.get("first_share_order_reward");

      if (StringUtil.isNullOrEmpty(reward)) 


      String reward = configService.get(ConfigKeyEnum.firstShareOrderReward.getKey());

      if (StringUtil.isNullOrEmpty(reward))

         return;

      firstOrderReward(uid, null, Integer.parseInt(reward), null, beizu);

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


      String reward = configService.get(ConfigKeyEnum.firstShareOrderRewardBoss.getKey());

      if (StringUtil.isNullOrEmpty(reward))

         return;

      firstOrderReward(uid, originUid, Integer.parseInt(reward), "一", beizu);

   }

	
	


   /**

    * 队员首单奖励金币

    * 
    * @param uid

    * @param addGoldCoin

    * @param level 所属哪级队员

    * @param level

    *            所属哪级队员

    * @param beizu

    */

   private void firstOrderReward(Long uid, Long originUid, Integer addGoldCoin, String level, String beizu) {

      String uniqueKey = "firstOrder-"+ uid.toString();

      if (originUid != null) 
      String uniqueKey = "firstOrder-" + uid.toString();

      if (originUid != null)

         uniqueKey = uniqueKey + "-" + originUid;

		


      // 判断是否已领取

      IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);

      if (detailRecord != null)

         return;

		


      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

      if (userInfoExtra == null) 
      if (userInfoExtra == null)

         return;

		
      Integer goldCoin = userInfoExtra.getGoldCoin();

      if (goldCoin == null)

         goldCoin = 0;

      goldCoin = goldCoin + addGoldCoin;

		


      int totalGoldCoin = 0;

      try {

         UserInfoExtra extra = new UserInfoExtra();

         extra.setId(userInfoExtra.getId());

         extra.setGoldCoin(goldCoin);

         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;

@@ -495,19 +487,16 @@
      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元时奖励 ");

      if (level.equalsIgnoreCase("一") || level.equalsIgnoreCase("1")) {

         // 直接粉丝

         userOtherMsgNotificationService.goldCoinOrderSubsidyMsg(originUid, addGoldCoin, totalGoldCoin, true);

      } else {

         msgOther.setSource(level + "级队员首次下单，系统奖励金币 ");

         msgOther.setExplain("仅新邀请队员首下单你得到的奖金不足0.01元时奖励 ");

         // 间接粉丝

         userOtherMsgNotificationService.goldCoinOrderSubsidyMsg(originUid, addGoldCoin, totalGoldCoin, false);

      }

      userOtherMsgNotificationService.firstOrderRewardMsg(uid, null, msgOther);

		
   }

	 
}