帮助中心

yujian

2019-12-19 626d711cb15896055c13fe344eb7fcc824589715

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

@@ -5,7 +5,9 @@
import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.HashSet;

import java.util.List;

import java.util.Set;

import java.util.UUID;



import javax.annotation.Resource;

@@ -25,6 +27,7 @@
import com.yeshi.fanli.entity.bus.homemodule.AdActivityVersionControl.AdActivityType;

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

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

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

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

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

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

@@ -449,6 +452,37 @@
      return specialMapper.listByVersion(start, count, card, platform, versionCode);

   }



   /**

    * 专题版本过滤

    * 
    * @param list

    * @param platform

    * @param versionCode

    */

   private void filterSpecial(List<Special> 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 (Special special : list) {

         sourceIdList.add(special.getId());

      }



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

            AdActivityType.special, versionIdList);

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

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

            list.remove(i--);

         }

      }

   }



   @Override

   @Cacheable(value = "specialCache", key = "'listCacheSpecialToIndex'+#acceptData.platform+'-'+#acceptData.version+'-'+#sex")

   public JSONObject listCacheSpecialToIndex(AcceptData acceptData, Integer sex) throws Exception {

@@ -466,10 +500,12 @@
      else if (VersionUtil.greaterThan_1_5_60(acceptData.getPlatform(), acceptData.getVersion()))

         indexArc = "index_arc_1.5.6";



      int platformCode = Constant.getPlatformCode(acceptData.getPlatform());

      String platform = acceptData.getPlatform();

      int platformCode = Constant.getPlatformCode(platform);

      int version = Integer.parseInt(acceptData.getVersion());



      List<Special> listArc = specialMapper.listByPlaceKey(indexArc, sex, platformCode, version);

      filterSpecial(listArc, platform, version);

      if (listArc == null) {

         listArc = new ArrayList<Special>();

      } else if (listArc.size() > 0) {

@@ -520,6 +556,8 @@
         listActivity = specialMapper.listByPlaceKey("index_activity", null, platformCode, version);

      }



      filterSpecial(listActivity, platform, version);



      if (listActivity == null) {

         listActivity = new ArrayList<Special>();

      } else if (listActivity.size() > 0) {

@@ -541,6 +579,7 @@


      JSONObject blockJsonMap = new JSONObject();

      List<Special> listBlock = specialMapper.listByPlaceKey(indexBlock, sex, platformCode, version);

      filterSpecial(listBlock, platform, version);

      if (listBlock == null) {

         listBlock = new ArrayList<Special>();

      } else if (listBlock.size() > 0) {

@@ -621,20 +660,45 @@
      if (special == null) {

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

      }



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



      List<AdActivityVersionControl> versionList = adActivityVersionControlService

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

            .listByTypeAndSourceId(AdActivityType.special, specialId);

      if (versionList != null) {

         for (AdActivityVersionControl control : versionList)

            adActivityVersionControlService.deleteByPrimaryKey(control.getId());

            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(specialId, AdActivityType.special, versionId);

      }



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

      addSet.addAll(newSet);

      addSet.removeAll(oldSet);



      // 添加映射

      for (Long versionId : versions) {

      for (Long versionId : addSet) {

         AdActivityVersionControl control = new AdActivityVersionControl();

         control.setCreateTime(new Date());

         control.setSourceId(special.getId());

         control.setType(AdActivityType.special);

         control.setVersion(new AppVersionInfo(versionId));

         adActivityVersionControlService.addVersionControl(control);

         try {

            adActivityVersionControlService.addVersionControl(control);

         } catch (Exception e) {

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

         }

      }

   }

}