用户注册信息

yujian

2020-01-18 f4a0f2acc63d7785eab108419a4e16f5f688cb95

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

@@ -1,9 +1,13 @@
package com.yeshi.fanli.service.impl.homemodule;



import java.io.InputStream;

import java.text.SimpleDateFormat;

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;

@@ -17,16 +21,25 @@


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

import com.yeshi.fanli.dto.common.CommonContentTypeEnum;

import com.yeshi.fanli.entity.AppVersionInfo;

import com.yeshi.fanli.entity.accept.AcceptData;

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

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.entity.system.ConfigKeyEnum;

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;

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

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

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

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.VersionUtil;



@@ -49,6 +62,12 @@


   @Resource

   private ConfigService configService;



   @Resource

   private AppVersionService appVersionService;



   @Resource

   private AdActivityVersionControlService adActivityVersionControlService;



   @Override

   public Special selectByPrimaryKey(Long id) {

@@ -79,6 +98,13 @@
         record.setParams(null);

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

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

      } else {

         record.setParams(params.trim());

      }



      String startTime_str = record.getStartTime_str();

      if (record.isTimeTask() && (startTime_str == null || startTime_str.length() == 0)) {

         throw new SpecialException(1, "控制时间不能为空");

      }



      if (!StringUtil.isNullOrEmpty(jumpType)) {

@@ -87,6 +113,9 @@
            record.setJumpDetail(listByType.get(0));

         }

      }



      // 时间转换

      conversionTime(record);



      Long state = record.getState();

      if (state == null) {

@@ -194,6 +223,38 @@
   }



   /**

    * web段时间转换

    * 
    * @param record

    */

   public void conversionTime(Special record) throws SpecialException, Exception {

      // 是否时间控制

      if (!record.isTimeTask()) {

         record.setStartTime(null);

         record.setEndTime(null);

      } else {

         String startTime_str = record.getStartTime_str();

         String endTime_str = record.getEndTime_str();



         if ((startTime_str == null || startTime_str.trim().length() == 0)

               && (endTime_str == null || endTime_str.trim().length() == 0)) {

            throw new HomeNavbarException(1, "请输入控制时间");

         } else {

            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm");

            if (startTime_str != null && startTime_str.trim().length() > 0) {

               startTime_str = startTime_str.replaceAll("T", " ");

               record.setStartTime(format.parse(startTime_str));

            }



            if (endTime_str != null && endTime_str.trim().length() > 0) {

               endTime_str = endTime_str.replaceAll("T", " ");

               record.setEndTime(format.parse(endTime_str));

            }

         }

      }

   }



   /**

    * 上传图片

    * 

    * @param file

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



      // 文件路径

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

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

      // 执行上传

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



@@ -228,7 +289,7 @@
   }



   @Override

   @Transactional

   @Transactional(rollbackFor=Exception.class)

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



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

@@ -280,7 +341,7 @@
   }



   @Override

   @Transactional

   @Transactional(rollbackFor = Exception.class)

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

      List<Special> listSpecial = specialMapper.queryByListPrimaryKey(list);

      for (Special special : listSpecial) {

@@ -294,6 +355,15 @@
            COSManager.getInstance().deleteFile(subPicture);

         }

      }

		
      if (listSpecial != null)

         for (Special special : listSpecial) {

            List<AdActivityVersionControl> versionList = adActivityVersionControlService

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

            if (versionList != null)

               for (AdActivityVersionControl control : versionList)

                  adActivityVersionControlService.deleteByPrimaryKey(control.getId());

         }

      return specialMapper.deleteBatchByPrimaryKey(list);

   }



@@ -325,6 +395,31 @@


      // 跳转链接

      for (Special special : list) {



         Date startTime = special.getStartTime();

         Date endTime = special.getEndTime();



         if (startTime == null && endTime == null) {

            special.setTimeTask(false);

            special.setStartTime_str("");

            special.setEndTime_str("");

         } else {

            special.setTimeTask(true);



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

            if (startTime == null) {

               special.setStartTime_str("");

            } else {

               special.setStartTime_str(sdf.format(startTime));

            }



            if (endTime == null) {

               special.setEndTime_str("");

            } else {

               special.setEndTime_str(sdf.format(endTime));

            }

         }



         String params = special.getParams();

         if (StringUtil.isNullOrEmpty(params)) {

            special.setParams("");

@@ -365,6 +460,45 @@
   }



   @Override

   @Cacheable(value = "specialCache", key = "'listByVersion-'+#start+'-'+#count+'-'+#card+'-'+#platform+'-'+#versionCode")

   public List<Special> listByVersion(long start, int count, String card, String platform, Integer versionCode) {

      List<Special> specialList = specialMapper.listByPlaceKey(card, null, null, null);

      filterSpecial(specialList, platform, versionCode);

      return specialList;

   }



   /**

    * 专题版本过滤

    * 
    * @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 {



@@ -372,14 +506,21 @@
      JSONObject arcMap = new JSONObject();



      String indexArc = "index_arc";

      if (VersionUtil.greaterThan_1_5_60(acceptData.getPlatform(), acceptData.getVersion()))

      if (VersionUtil.greaterThan_1_6_5(acceptData.getPlatform(), acceptData.getVersion()))

         indexArc = "index_arc_1.6.5";

      else if (VersionUtil.greaterThan_1_6_0(acceptData.getPlatform(), acceptData.getVersion()))

         indexArc = "index_arc_1.6.0";

      else if (VersionUtil.greaterThan_1_5_70(acceptData.getPlatform(), acceptData.getVersion()))

         indexArc = "index_arc_1.5.7";

      else if (VersionUtil.greaterThan_1_5_60(acceptData.getPlatform(), acceptData.getVersion()))

         indexArc = "index_arc_1.5.6";



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

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

@@ -390,6 +531,8 @@
         }

      }



      int hour = Calendar.getInstance().get(Calendar.HOUR_OF_DAY);



      // 处理9.9包邮

      if (listArc != null && VersionUtil.greaterThan_1_5_50(acceptData.getPlatform(), acceptData.getVersion()))

         for (Special s : listArc) {

@@ -399,6 +542,18 @@
               params.put("key", CommonContentTypeEnum._9k9.name());

               params.put("title", CommonContentTypeEnum._9k9.getDesc());

               s.setParams(params.toString());

            } else if (s.getName().contains("自购立减")) {

               if (hour < 6) {// 0-6点之间不进入自购立减的页面

                  s.setJumpDetail(jumpDetailV2Service.getByTypeCache("web"));

                  JSONObject params = new JSONObject();

                  params.put("url", configService.get(ConfigKeyEnum.tljOwnBuyNogoods.getKey()));

                  s.setParams(params.toString());

               } else {

                  // 查询专题详情

                  Special special = specialMapper.selectByPrimaryKey(s.getId());

                  s.setJumpDetail(special.getJumpDetail());

                  s.setParams(special.getParams());

               }

            }

         }



@@ -413,8 +568,10 @@
            && configService.iosOnLining(Integer.parseInt(acceptData.getVersion()))) {

         // 如果IOS当前版本处于审核状态就不返回

      } else {

         listActivity = specialMapper.listByPlaceKey("index_activity", null);

         listActivity = specialMapper.listByPlaceKey("index_activity", null, platformCode, version);

      }



      filterSpecial(listActivity, platform, version);



      if (listActivity == null) {

         listActivity = new ArrayList<Special>();

@@ -436,7 +593,8 @@
         indexBlock = "index_block_1.5.6";



      JSONObject blockJsonMap = new JSONObject();

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

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

@@ -470,8 +628,26 @@
   }



   @Override

   public List<Special> listByPlaceKey(String placeKey) {

      return specialMapper.listByPlaceKey(placeKey, null);

   public List<Special> listByPlaceKey(String placeKey, Integer platform, Integer versionCode) {

      return specialMapper.listByPlaceKey(placeKey, null, platform, versionCode);

   }



   @Override

   public List<Special> listByPlaceKeyList(long start, int count, List<String> list, Integer platform,

         Integer versionCode) {

      return specialMapper.listByPlaceKeyList(start, count, list, null, platform, versionCode);

   }



   @Override

   public long countByPlaceKeyList(List<String> list, Integer platform, Integer versionCode) {

      return specialMapper.countByPlaceKeyList(list, null, platform, versionCode);

   }



   @Override

   @Cacheable(value = "specialCache", key = "'listByPlaceKeyHasLabel'+#start+'-'+#platform+'-'+#versionCode+'-'+#list")

   public List<Special> listByPlaceKeyHasLabel(long start, int count, List<String> list, Integer platform,

         Integer versionCode) {

      return specialMapper.listByPlaceKeyHasLabel(start, count, list, null, platform, versionCode);

   }



   /**

@@ -491,4 +667,53 @@
         }

      }

   }



   @Transactional(rollbackFor = Exception.class)

   @Override

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

      Special special = selectByPrimaryKey(specialId);

      if (special == null) {

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

      }



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



      List<AdActivityVersionControl> versionList = adActivityVersionControlService

            .listByTypeAndSourceId(AdActivityType.special, specialId);

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

         control.setType(AdActivityType.special);

         control.setVersion(new AppVersionInfo(versionId));

         try {

            adActivityVersionControlService.addVersionControl(control);

         } catch (Exception e) {

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

         }

      }

   }

}