Merge branch 'div' of ssh://193.112.35.168:29418/fanli-server into div

yujian

2019-11-04 148af6b2f57be264c84d0991237fbd7ddea491a4

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

@@ -55,14 +55,12 @@
   @Lazy

   @Resource

   private IntegralTaskClassService integralTaskClassService;

	


   @Resource

   private UserOtherMsgNotificationService userOtherMsgNotificationService;

	


   @Resource

   private ConfigService configService;

	
	


   @Override

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

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

   }



	
   @Override

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

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

@@ -165,8 +162,8 @@
               }

               date = createTime;

               listRecord.add(record);

					
               if(listRecord.size() >= 7)



               if (listRecord.size() >= 7)

                  break;

            }

         }

@@ -175,7 +172,7 @@
      }

      return listRecord;

   }

	


   @Override

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

      return integralTaskRecordMapper.listNotReceived(count, uid);

@@ -190,7 +187,7 @@
   }



   @Override

   @Transactional(rollbackFor=Exception.class)

   @Transactional(rollbackFor = Exception.class)

   public Integer receiveGoldCoinALL(Long uid) throws IntegralTaskRecordException {

      UserInfoExtra userInfoExtra = userInfoExtraService.getByUidForUpdate(uid);

      if (userInfoExtra == null)

@@ -205,21 +202,15 @@
         if (addDetail(uid, record))

            totalGoldCoin += record.getGoldCoin();

      }

		
      Integer goldCoin = userInfoExtra.getGoldCoin();

      if (goldCoin == null)

         goldCoin = 0;



      goldCoin = goldCoin + totalGoldCoin;

		
      // 更新金币

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

		
      return goldCoin;

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



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

   }



   @Override	
   @Transactional(rollbackFor=Exception.class)

   @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为空");

@@ -229,32 +220,26 @@
      if (userInfoExtra == null) {

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

      }

 


      Integer totalGoldCoin = 0;

      for (Long id : idList) {

         IntegralTaskRecord record = integralTaskRecordMapper.selectByPrimaryKey(id);

         if (record == null)

            continue;

			


         // 已领取

         Integer state = record.getState();

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

            continue;

			


         if (addDetail(uid, record))

            totalGoldCoin += record.getGoldCoin();

      }

		
      Integer goldCoin = userInfoExtra.getGoldCoin();

      if (goldCoin == null)

         goldCoin = 0;



      goldCoin = goldCoin + totalGoldCoin;

		
      // 更新金币

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

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



      return goldCoin;

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

   }



   @Transactional

@@ -321,7 +306,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 + "次";

@@ -389,6 +374,13 @@
   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()

@@ -396,78 +388,77 @@
   public void firstRebateOrderRewardBoss(Long uid, Long originUid, String beizu) {

      if (uid == null || originUid == null)

         return;

		


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

      if (StringUtil.isNullOrEmpty(reward)) 
      if (StringUtil.isNullOrEmpty(reward))

         return;

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

   }

	


   @Async()

   @Override

   public void firstRebateOrderRewardBossSuper(Long uid, Long originUid, String beizu) {

      if (uid == null || originUid == null)

         return;

		


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

      if (StringUtil.isNullOrEmpty(reward)) 
      if (StringUtil.isNullOrEmpty(reward))

         return;

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

   }

	
	


   @Async()

   @Override

   public void firstShareOrderReward(Long uid, String beizu) {

      if(uid == null)

      if (uid == null)

         return;

		


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

      if (StringUtil.isNullOrEmpty(reward)) 
      if (StringUtil.isNullOrEmpty(reward))

         return;

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

   }

	
	


   @Async()

   @Override

   public void firstSharerOrderRewardBoss(Long uid, Long originUid, String beizu) {

      if (uid == null || originUid == null)

         return;

		


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

      if (StringUtil.isNullOrEmpty(reward)) 
      if (StringUtil.isNullOrEmpty(reward))

         return;

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

   }

	
	


   /**

    * 队员首单奖励金币

    * 
    * @param uid

    * @param addGoldCoin

    * @param level 所属哪级队员

    * @param level

    *            所属哪级队员

    * @param beizu

    */

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

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

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

      if (originUid != null)

         uniqueKey = uniqueKey + "-" + originUid;

		


      // 判断是否已领取

      IntegralDetail detailRecord = integralDetailService.getDetailByUniqueKey(uniqueKey);

      if (detailRecord != null)

         return;

		


      UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

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

         return;

		


      Integer goldCoin = userInfoExtra.getGoldCoin();

      if (goldCoin == null)

         goldCoin = 0;

      goldCoin = goldCoin + addGoldCoin;

		


      try {

         UserInfoExtra extra = new UserInfoExtra();

         extra.setId(userInfoExtra.getId());

@@ -487,7 +478,7 @@
      detail.setUniqueKey(uniqueKey);

      detail.setCreateTime(new Date());

      integralDetailService.insertSelective(detail);

		


      // 消息

      MsgOtherRewardIntegralDTO msgOther = new MsgOtherRewardIntegralDTO();

      msgOther.setTitle("金币奖励");