订单搜索引擎增量更新

admin

2020-01-07 6fdcc0c26dd33e87a024a69ed635d9aedb59cad6

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

@@ -38,6 +38,7 @@
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;



@@ -265,7 +266,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();



@@ -285,7 +286,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) {

@@ -337,7 +338,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) {

@@ -351,6 +352,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);

   }



@@ -448,8 +458,10 @@


   @Override

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

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

      return specialMapper.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;

   }



   /**