抖音转链修改

admin

2024-01-23 81da61b828e29b7745e1382dfbbaeb685dc083ef

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

@@ -1,148 +1,148 @@
package com.yeshi.fanli.service.impl.user.integral;



import java.util.Date;

import java.util.List;



import javax.annotation.Resource;



import org.springframework.stereotype.Service;



import com.yeshi.fanli.dao.mybatis.integral.IntegralExchangeRecordMapper;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.entity.integral.IntegralExchange;

import com.yeshi.fanli.entity.integral.IntegralExchange.ExchangeTypeEnum;

import com.yeshi.fanli.entity.integral.IntegralExchangeRecord;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.user.UserInfoExtraService;

import com.yeshi.fanli.service.inter.user.integral.CodePublishRecordService;

import com.yeshi.fanli.service.inter.user.integral.IntegralExchangeRecordService;

import com.yeshi.fanli.service.inter.user.integral.IntegralExchangeService;

import com.yeshi.fanli.util.StringUtil;



@Service

public class IntegralExchangeRecordServiceImpl implements IntegralExchangeRecordService {



   @Resource

   private IntegralExchangeRecordMapper integralExchangeRecordMapper;



   @Resource

   private IntegralExchangeService integralExchangeService;

	
   @Resource

   private UserInfoExtraService userInfoExtraService;

	
   @Resource

   private CodePublishRecordService codePublishRecordService;

	
	
	
   @Override

   public List<IntegralExchange> listExchange(long start, int count, Long uid){

      List<IntegralExchange> listValid = integralExchangeService.listValidCache(start, count);

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

         return listValid;

      }

		
      boolean hasCode = false;

      try {

         UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

         if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) {

            hasCode = true;

         }

      } catch (Exception e) {

         LogHelper.errorDetailInfo(e);

      }

		
      for(int i = 0; i < listValid.size(); i++) {

         IntegralExchange exchange = listValid.get(i);

			
         ExchangeTypeEnum type = exchange.getType();

         if (type == null) {

            listValid.remove(i);

            i --;

            continue;

         }

			
         Long id = exchange.getId();

         if (type == ExchangeTypeEnum.freeCouponBuy) {

            // 注：因自购免单券，一个用户只能兑换一次，则当前用户一旦兑换成功，自购免单券兑换入口永久在当前用户金币兑换列表中消失。

            long num = integralExchangeRecordMapper.countRecordByUid(id, uid, null);

            if (num >= 1) {

               listValid.remove(i);

               i --;

               continue;

            }

         }

			
         // 邀请码激活卡，兑换项，如果当前用户已经激活了邀请功能，则不需要显示该兑换项。

         if (type == ExchangeTypeEnum.inviteCodeActivate) {

            if (hasCode) {

               listValid.remove(i);

               i --;

               continue;

            } 
				
            // 兑换一次之后隐藏

            long num = integralExchangeRecordMapper.countRecordByUid(id, uid, null);

            if  (num >= 1) {

               listValid.remove(i);

               i --;

               continue;

            }

         }

			
         // 邀请码发布卡，兑换项，如果当前用户未激活邀请功能，则不需要显示该兑换项。

         if (type == ExchangeTypeEnum.inviteCodePublish) {

            if (!hasCode) {

               listValid.remove(i);

               i --;

               continue;

            }

				
            if(codePublishRecordService.countValidRecord(uid) > 0) {

               exchange.setBtnName("去查看");

               exchange.setNeedJump(true);

            }

         }

			
         String progress = exchange.getProgress();

         if (StringUtil.isNullOrEmpty(progress))

            continue;

			
         // 自购免单券-只能兑换一次

         if (type == ExchangeTypeEnum.freeCouponBuy) {

            long num = integralExchangeRecordMapper.countRecordByUid(id, uid, null);

            if  (num >= 1) {

               listValid.remove(i);

               i --;

               continue;

            }

         }

			
         // 今日兑换情况

         long num = integralExchangeRecordMapper.countRecordByUid(id, uid, 1);

         Integer upperLimit = exchange.getUpperLimit();

         if (upperLimit == null) {

            progress = progress.replace("{已兑换}", num + "").replace("/{上限数}", "");

         } else {

            progress = progress.replace("{已兑换}", num + "").replace("{上限数}", exchange.getUpperLimit() + "");

         }

         exchange.setProgress(progress);

      }

      return listValid;

   }

	
   @Override

   public long countRecordByUid(long exchangeid, Long uid, Integer today){

      return integralExchangeRecordMapper.countRecordByUid(exchangeid, uid, today);

   }

	
   @Override

   public void addExchangeRecord(long exchangeid, Long uid){

      IntegralExchangeRecord record = new IntegralExchangeRecord();

      record.setExchangeId(exchangeid);

      record.setUid(uid);

      record.setCreateTime(new Date());

      integralExchangeRecordMapper.insertSelective(record);

   }

}

package com.yeshi.fanli.service.impl.user.integral;

import java.util.Date;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;

import com.yeshi.fanli.dao.mybatis.integral.IntegralExchangeRecordMapper;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.integral.IntegralExchange;
import com.yeshi.fanli.entity.integral.IntegralExchange.ExchangeTypeEnum;
import com.yeshi.fanli.entity.integral.IntegralExchangeRecord;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.integral.CodePublishRecordService;
import com.yeshi.fanli.service.inter.user.integral.IntegralExchangeRecordService;
import com.yeshi.fanli.service.inter.user.integral.IntegralExchangeService;
import com.yeshi.fanli.util.StringUtil;

@Service
public class IntegralExchangeRecordServiceImpl implements IntegralExchangeRecordService {

   @Resource
   private IntegralExchangeRecordMapper integralExchangeRecordMapper;

   @Resource
   private IntegralExchangeService integralExchangeService;
	
   @Resource
   private UserInfoExtraService userInfoExtraService;
	
   @Resource
   private CodePublishRecordService codePublishRecordService;
	
	
	
   @Override
   public List<IntegralExchange> listExchange(long start, int count, Long uid){
      List<IntegralExchange> listValid = integralExchangeService.listValidCache(start, count);
      if (listValid == null || listValid.size() == 0) {
         return listValid;
      }
		
      boolean hasCode = false;
      try {
         UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
         if (userInfoExtra != null && !StringUtil.isNullOrEmpty(userInfoExtra.getInviteCode())) {
            hasCode = true;
         }
      } catch (Exception e) {
         LogHelper.errorDetailInfo(e);
      }
		
      for(int i = 0; i < listValid.size(); i++) {
         IntegralExchange exchange = listValid.get(i);
			
         ExchangeTypeEnum type = exchange.getType();
         if (type == null) {
            listValid.remove(i);
            i --;
            continue;
         }
			
         Long id = exchange.getId();
         if (type == ExchangeTypeEnum.freeCouponBuy) {
            // 注：因自购免单券，一个用户只能兑换一次，则当前用户一旦兑换成功，自购免单券兑换入口永久在当前用户金币兑换列表中消失。
            long num = integralExchangeRecordMapper.countRecordByUid(id, uid, null);
            if (num >= 1) {
               listValid.remove(i);
               i --;
               continue;
            }
         }
			
         // 邀请码激活卡，兑换项，如果当前用户已经激活了邀请功能，则不需要显示该兑换项。
         if (type == ExchangeTypeEnum.inviteCodeActivate) {
            if (hasCode) {
               listValid.remove(i);
               i --;
               continue;
            } 
				
            // 兑换一次之后隐藏
            long num = integralExchangeRecordMapper.countRecordByUid(id, uid, null);
            if  (num >= 1) {
               listValid.remove(i);
               i --;
               continue;
            }
         }
			
         // 邀请码发布卡，兑换项，如果当前用户未激活邀请功能，则不需要显示该兑换项。
         if (type == ExchangeTypeEnum.inviteCodePublish) {
            if (!hasCode) {
               listValid.remove(i);
               i --;
               continue;
            }
				
            if(codePublishRecordService.countValidRecord(uid) > 0) {
               exchange.setBtnName("去查看");
               exchange.setNeedJump(true);
            }
         }
			
         String progress = exchange.getProgress();
         if (StringUtil.isNullOrEmpty(progress))
            continue;
			
         // 自购免单券-只能兑换一次
         if (type == ExchangeTypeEnum.freeCouponBuy) {
            long num = integralExchangeRecordMapper.countRecordByUid(id, uid, null);
            if  (num >= 1) {
               listValid.remove(i);
               i --;
               continue;
            }
         }
			
         // 今日兑换情况
         long num = integralExchangeRecordMapper.countRecordByUid(id, uid, 1);
         Integer upperLimit = exchange.getUpperLimit();
         if (upperLimit == null) {
            progress = progress.replace("{已兑换}", num + "").replace("/{上限数}", "");
         } else {
            progress = progress.replace("{已兑换}", num + "").replace("{上限数}", exchange.getUpperLimit() + "");
         }
         exchange.setProgress(progress);
      }
      return listValid;
   }
	
   @Override
   public long countRecordByUid(long exchangeid, Long uid, Integer today){
      return integralExchangeRecordMapper.countRecordByUid(exchangeid, uid, today);
   }
	
   @Override
   public void addExchangeRecord(long exchangeid, Long uid){
      IntegralExchangeRecord record = new IntegralExchangeRecord();
      record.setExchangeId(exchangeid);
      record.setUid(uid);
      record.setCreateTime(new Date());
      integralExchangeRecordMapper.insertSelective(record);
   }
}