用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

 fanli/src/main/java/com/yeshi/fanli/service/impl/homemodule/FloatADServiceImpl.java

@@ -3,23 +3,35 @@
import java.io.InputStream;

import java.text.ParseException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashSet;

import java.util.List;

import java.util.Set;

import java.util.UUID;



import javax.annotation.Resource;

import javax.transaction.Transactional;



import org.springframework.cache.annotation.Cacheable;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.web.multipart.MultipartFile;

import org.yeshi.utils.tencentcloud.COSManager;



import com.yeshi.fanli.dao.mybatis.homemodule.FloatADMapper;

import com.yeshi.fanli.entity.AppVersionInfo;

import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl;

import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl.AdActivityType;

import com.yeshi.fanli.entity.bus.homemodule.FloatAD;

import com.yeshi.fanli.entity.bus.homemodule.FloatAD.FloatADTypeEnum;

import com.yeshi.fanli.entity.common.JumpDetailV2;

import com.yeshi.fanli.exception.FloatADException;

import com.yeshi.fanli.exception.banner.SwiperPictureException;

import com.yeshi.fanli.exception.homemodule.FloatADException;

import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;

import com.yeshi.fanli.service.inter.config.AppVersionService;

import com.yeshi.fanli.service.inter.homemodule.AdActivityVersionControlService;

import com.yeshi.fanli.service.inter.homemodule.FloatADService;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.StringUtil;



@Service

@@ -30,6 +42,12 @@
   

   @Resource

   private JumpDetailV2Service jumpDetailV2Service;

	
   @Resource

   private AppVersionService appVersionService;

	
   @Resource

   private AdActivityVersionControlService adActivityVersionControlService;

   

   

   @Override

@@ -50,8 +68,14 @@
         record.setParams(null);

      } else if (!StringUtil.isJson(params)) {

         throw new FloatADException(1, "跳转参数非JSON格式");

      } else {

         record.setParams(params.trim());

      }

      

      FloatADTypeEnum typeEnum = record.getTypeEnum();

      if (typeEnum == null)

         throw new FloatADException(1, "类型不能为空");

			
      if (!StringUtil.isNullOrEmpty(jumpType)) {

         List<JumpDetailV2> listByType = jumpDetailV2Service.listByType(jumpType);

         if (listByType !=null && listByType.size() > 0) {

@@ -82,6 +106,12 @@
      String picture = null;

      if (file != null) {

         picture = uploadPicture(file);

      }

		
      // 适用类型 ： 0通用  1新人

      Integer type = record.getType();

      if (type == null) {

         record.setType(0);

      }

      

      Long id = record.getId();

@@ -135,7 +165,7 @@
      String type = contentType.substring(contentType.indexOf("/") + 1);

   

      // 文件路径

      String filePath="/img/FloatAD/"+UUID.randomUUID().toString().replace("-", "") + "." + type;

      String filePath= FilePathEnum.floatAD.getPath() +UUID.randomUUID().toString().replace("-", "") + "." + type;

      // 执行上传

      String fileLink= COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();

      

@@ -154,7 +184,7 @@
   }

   

   @Override

   @Transactional

   @Transactional(rollbackFor=Exception.class)

   public void updateOrder(Long id, Integer moveType) throws FloatADException {

      

      if (id == null || moveType == null || (!moveType.equals(1) && !moveType.equals(-1))) {

@@ -187,7 +217,7 @@
   }

   

   @Override

   @Transactional

   @Transactional(rollbackFor=Exception.class)

   public int deleteByPrimaryKeyList(List<Long> list) throws Exception{

      

      List<FloatAD> listSwiper = floatADMapper.ListByPrimaryKey(list);

@@ -198,6 +228,12 @@
      // 删除已存在图片

      for (FloatAD floatAD: listSwiper) {

         removePicture(floatAD.getPicture());

			
         List<AdActivityVersionControl> versionList = adActivityVersionControlService

               .listByTypeAndSourceId(AdActivityType.floatAD, floatAD.getId());

         if (versionList != null)

            for (AdActivityVersionControl control : versionList)

               adActivityVersionControlService.deleteByPrimaryKey(control.getId());

      }

      

      return floatADMapper.deleteByPrimaryKeyList(list);

@@ -214,6 +250,11 @@
      }

      

      for (FloatAD floatAD : listQuery) {

			
         FloatADTypeEnum typeEnum = floatAD.getTypeEnum();

         if (typeEnum != null) {

            floatAD.setTypeName(typeEnum.getDesc());

         }

         

         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm");

         Date startTime = floatAD.getStartTime();

@@ -257,9 +298,10 @@
      return floatADMapper.countQuery(key, state);

   }



   @Cacheable(value = "configCache", key = "'getEffectiveFloatAD-'+#position+'-'+#type")

   @Override

   public FloatAD getEffectiveFloatAD(String position) {

      FloatAD floatAD = floatADMapper.getEffectiveFloatAD(position);

   public FloatAD getEffectiveFloatAD(String position, Integer type) {

      FloatAD floatAD = floatADMapper.getEffectiveFloatAD(position, type);

      if (floatAD != null) {

         JumpDetailV2 jumpDetail = floatAD.getJumpDetail();

         

@@ -277,5 +319,107 @@
      return floatAD;

   }

   

	
   @Transactional(rollbackFor = Exception.class)

   @Override

   public void setVersions(Long id, List<Long> versions) throws Exception {

      FloatAD record = floatADMapper.selectByPrimaryKey(id);

      if (record == null) {

         throw new Exception("专题不存在");

      }



      Set<Long> oldSet = new HashSet<>();



      List<AdActivityVersionControl> versionList = adActivityVersionControlService

            .listByTypeAndSourceId(AdActivityType.floatAD, id);

      if (versionList != null) {

         for (AdActivityVersionControl control : versionList)

            oldSet.add(control.getVersion().getId());

      }



      Set<Long> newSet = new HashSet<>();

      for (Long version : versions) {

         newSet.add(version);

      }



      Set<Long> delSet = new HashSet<>();

      delSet.addAll(oldSet);

      delSet.removeAll(newSet);

      for (Long versionId : delSet) {

         adActivityVersionControlService.deleteBySourceAndVersion(id, AdActivityType.floatAD, versionId);

      }



      Set<Long> addSet = new HashSet<>();

      addSet.addAll(newSet);

      addSet.removeAll(oldSet);

      // 添加映射

      for (Long versionId : addSet) {

         AdActivityVersionControl control = new AdActivityVersionControl();

         control.setCreateTime(new Date());

         control.setSourceId(id);

         control.setType(AdActivityType.floatAD);

         control.setVersion(new AppVersionInfo(versionId));

         try {

            adActivityVersionControlService.addVersionControl(control);

         } catch (Exception e) {

            throw new SwiperPictureException(2, e.getMessage());

         }

      }

   }

	
   @Cacheable(value = "configCache", key = "'getValidFloatADCache-'+#position+'-'+#type+'-'+#platform+'-'+#versionCode")

   @Override

   public List<FloatAD> getValidFloatADCache(String position, Integer type, String platform, Integer versionCode) {

      List<FloatAD> list = floatADMapper.getValidFloatAD(position, type);

      // 过滤

      filterFloatAD(list, platform, versionCode);

		
      return list;

   }

	
   /**

    * 过滤

    * 
    * @param list

    * @param platform

    * @param versionCode

    */

   private void filterFloatAD(List<FloatAD> list, String platform, int versionCode) {

      if (list == null || list.size() == 0)

         return;

      AppVersionInfo app = appVersionService.getClientVersion(platform, versionCode);

      if (app == null) {

         list.clear();

         return;

      }

      List<Long> versionIdList = new ArrayList<>();

      versionIdList.add(app.getId());

      List<Long> sourceIdList = new ArrayList<>();

      for (FloatAD record : list) {

         sourceIdList.add(record.getId());

      }



      Set<Long> sourceIds = adActivityVersionControlService.filterSourceIdByVersion(sourceIdList,

            AdActivityType.floatAD, versionIdList);

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

         // 过滤版本

         if (!sourceIds.contains(list.get(i).getId())) {

            list.remove(i--);

            continue;

         }

			
         // 跳转是否登录

         FloatAD floatAD = list.get(i);

         JumpDetailV2 jumpDetail = floatAD.getJumpDetail();

         if (jumpDetail != null) {

            jumpDetail = jumpDetailV2Service.selectByPrimaryKey(jumpDetail.getId());

            if (jumpDetail != null) {

               jumpDetail.setNeedLogin(floatAD.isJumpNeedLogin());

            }

         }

      }

   }



}