IOS上线隐藏我的界面的banner与超级会员升级信息

admin

2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee

 fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandInfoServiceImpl.java

@@ -1,7 +1,6 @@
package com.yeshi.fanli.service.impl.brand;



import java.io.InputStream;

import java.math.BigDecimal;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

@@ -19,21 +18,26 @@
import com.yeshi.fanli.dao.mybatis.brand.BrandInfoMapper;

import com.yeshi.fanli.dto.ConfigParamsDTO;

import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;

import com.yeshi.fanli.entity.brand.BrandClass;

import com.yeshi.fanli.entity.brand.BrandGoodsCahe;

import com.yeshi.fanli.entity.brand.BrandInfo;

import com.yeshi.fanli.entity.brand.BrandShopCahe;

import com.yeshi.fanli.entity.jd.JDGoods;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoShop;

import com.yeshi.fanli.exception.brand.BrandInfoException;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.inter.brand.BrandClassShopService;

import com.yeshi.fanli.service.inter.brand.BrandGoodsCaheService;

import com.yeshi.fanli.service.inter.brand.BrandInfoService;

import com.yeshi.fanli.service.inter.brand.BrandShopCaheService;

import com.yeshi.fanli.service.inter.goods.TaoBaoGoodsBriefService;

import com.yeshi.fanli.service.inter.lable.QualityGoodsService;

import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.FilePathEnum;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory;

import com.yeshi.fanli.vo.brand.BrandInfoVO;

@@ -48,6 +52,9 @@


   @Resource

   private HongBaoManageService hongBaoManageService;

	
   @Resource

   private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;



   @Resource

   private QualityGoodsService qualityGoodsService;

@@ -72,37 +79,69 @@


   @Resource(name = "taskExecutor")

   private TaskExecutor executor;

	
	


   @Override

   public void saveObject(MultipartFile file, BrandInfo record) throws BrandInfoException {

      String name = record.getName();

      if (StringUtil.isNullOrEmpty(name))

         throw new BrandInfoException(1, "名称不能为空");



      String searchKey = record.getSearchKey();

      if (StringUtil.isNullOrEmpty(searchKey))

         record.setSearchKey(name);

		
      BrandClass brandClass = record.getBrandClass();

      if (brandClass == null || brandClass.getId() == null)

         throw new BrandInfoException(1, "分类不能为空");



      BrandInfo existBrand = brandInfoMapper.selectByUniqueName(name.trim(), brandClass.getId(), record.getId());

      if (existBrand != null)

         throw new BrandInfoException(1, "该分类中已存在：" + name.trim());



      Integer state = record.getState();

      if (state == null)

         record.setState(0);

		
      // 图片上传

      if (state == null) {

         state = 0;

         record.setState(state);

      }



      String picture = null;

      if (file != null) {

         try {

         try { // 图片上传

            picture = uploadPicture(file);

         } catch (Exception e) {

            throw new BrandInfoException(1, "图片上传失败");

         }

      }



      String searchKey = record.getSearchKey();

      if (!StringUtil.isNullOrEmpty(searchKey)) {

         if (StringUtil.isNullOrEmpty(record.getSearchKeyJD()))

            record.setSearchKeyJD(searchKey);



         if (StringUtil.isNullOrEmpty(record.getSearchKeyPDD()))

            record.setSearchKeyPDD(searchKey);

      }



      String shopKey = record.getShopKey();

      if (!StringUtil.isNullOrEmpty(shopKey)) {

         if (StringUtil.isNullOrEmpty(record.getShopKeyJD()))

            record.setShopKeyJD(shopKey);



         if (StringUtil.isNullOrEmpty(record.getShopKeyPDD()))

            record.setShopKeyPDD(shopKey);

      }

      record.setName(name.trim());

      record.setUpdateTime(new Date());



      Long id = record.getId();

      if (id == null) {

         record.setIcon(picture);

         record.setWeight(500.00);

         record.setGoodsTotal(0);

         record.setShopTotal(0);

         record.setCreateTime(new Date());

         record.setUpdateTime(new Date());

         brandInfoMapper.insert(record);



         BrandInfo resultObj = new BrandInfo();

         resultObj.setId(record.getId());

         resultObj.setOrder(Integer.valueOf(record.getId().toString()));

         brandInfoMapper.updateByPrimaryKeySelective(resultObj);

      } else {

         BrandInfo resultObj = brandInfoMapper.selectByPrimaryKey(id);

         if (resultObj == null)

@@ -110,22 +149,29 @@


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

            // 删除老图

            if (picture != null && picture.trim().length() > 0 && !Constant.IS_TEST) {

               COSManager.getInstance().deleteFile(picture);

            };

            if (resultObj.getIcon() != null && resultObj.getIcon().trim().length() > 0 && !Constant.IS_TEST) {

               COSManager.getInstance().deleteFile(resultObj.getIcon());

            }

            ;

            // 存储新图

            record.setIcon(picture);

         } else {

            record.setIcon(resultObj.getIcon());

         }

			
         record.setGoodsTotal(resultObj.getGoodsTotal());



         if (state == 0) {

            record.setGoodsTotal(0);

            record.setShopTotal(0);

         } else {

            record.setGoodsTotal(resultObj.getGoodsTotal());

            record.setShopTotal(resultObj.getShopTotal());

         }

         record.setOrder(resultObj.getOrder());

         record.setWeight(resultObj.getWeight());

         record.setCreateTime(resultObj.getCreateTime());

         record.setUpdateTime(new Date());

         brandInfoMapper.updateByPrimaryKey(record);

			
			
         if (state == 0){



         if (state == 0) {

            executor.execute(new Runnable() {

               @Override

               public void run() {

@@ -140,59 +186,115 @@
         executor.execute(new Runnable() {

            @Override

            public void run() {

               int goodsTotal = brandGoodsCaheService.addBrandGoods(record);

               record.setGoodsTotal(goodsTotal);

               brandInfoMapper.updateByPrimaryKeySelective(record);

               BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(record);



               BrandInfo update = new BrandInfo();

               update.setId(record.getId());

               update.setGoodsTotal(numInfo.getGoodsTotal());

               update.setShopTotal(numInfo.getShopTotal());

               brandInfoMapper.updateByPrimaryKeySelective(update);

            }

         });

      }

   }



	
   /**

    * 上传图片

    * 
    * @param file

    * @return

    * @throws Exception

    */

   public String uploadPicture(MultipartFile file) throws Exception {

		
      // 文件解析 
      // 文件解析

      InputStream inputStream = file.getInputStream();

      String contentType = file.getContentType();

      String type = contentType.substring(contentType.indexOf("/") + 1);

	


      // 文件路径

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

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

      // 执行上传

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

		
      return fileLink;

      return COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();

   }



	
   @Override

   public void switchState(Long id) throws BrandInfoException {

      if (id == null) {

         throw new BrandInfoException(1, "请传递正确参数");

      }

      BrandInfo resultObj = brandInfoMapper.selectByPrimaryKey(id);

      if (resultObj == null) {

         throw new BrandInfoException(1, "此内容已不存在");

      }

		
      Integer state = resultObj.getState();

      if (state == null || state == 0) {

         state = 1;

      } else {

         state = 0;

      }

		
      BrandInfo updateObj = new BrandInfo();

      updateObj.setId(id);

      updateObj.setState(state);

      brandInfoMapper.updateByPrimaryKeySelective(updateObj);

   }

	
   

   @Override

   public int deleteBatchByPrimaryKey(List<Long> list) {

      executor.execute(new Runnable() {

         @Override

         public void run() {

            for (Long id: list) {

            for (Long id : list) {

               brandGoodsCaheService.removeByBrandId(id);

               brandShopCaheService.removeByBrandId(id);

            }

         }

      });

		


      return brandInfoMapper.deleteBatchByPrimaryKey(list);

   }



   @Override

   public List<BrandInfo> listQuery(long start, int count, String key, Long cid, Integer state) {

      return brandInfoMapper.listQuery(start, count, key, cid, state);

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

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

         throw new BrandInfoException(1, "传递的类型不正确");



      if (id == null)

         throw new BrandInfoException(1, "ID不能为空");



      BrandInfo resultObj = brandInfoMapper.selectByPrimaryKey(id);

      if (resultObj == null)

         throw new BrandInfoException(1, "操作数据已不存在");



      Integer oldOrder = resultObj.getOrder();

      BrandInfo changeObj = brandInfoMapper.getByAdjoinOrder(resultObj.getBrandClass().getId(), oldOrder, moveType);

      if (changeObj == null)

         throw new BrandInfoException(1, "已经在最边缘，无可交换的位置");



      BrandInfo changeObj1 = new BrandInfo();

      changeObj1.setId(id);

      changeObj1.setOrder(changeObj.getOrder());



      BrandInfo changeObj2 = new BrandInfo();

      changeObj2.setId(changeObj.getId());

      changeObj2.setOrder(oldOrder);



      brandInfoMapper.updateByPrimaryKeySelective(changeObj1);

      brandInfoMapper.updateByPrimaryKeySelective(changeObj2);

   }



   @Override

   public long countQuery(String key, Long cid, Integer state) {

      return brandInfoMapper.countQuery(key, cid, state);

   public List<BrandInfo> listQuery(long start, int count, List<String> keys, Long cid, Integer state,

         Integer showState) {

      return brandInfoMapper.listQuery(start, count, keys, cid, state, showState);

   }



   @Override

   public long countQuery(List<String> keys, Long cid, Integer state, Integer showState) {

      return brandInfoMapper.countQuery(keys, cid, state, showState);

   }



   @Override

@@ -214,11 +316,11 @@
   }



   @Override

   @Cacheable(value = "brandCache", key = "'listBrandInfoCache-'+#start+'-'+#start +'-'+#cid")

   public List<BrandInfoVO> listBrandInfoCache(long start, int count, Long cid) {

   @Cacheable(value = "brandCache", key = "'listBrandInfoCache-'+#start+'-'+#start +'-'+#cid+'-'+#platform+'-'+#version")

   public List<BrandInfoVO> listBrandInfoCache(long start, int count, Long cid, String platform, String version) {

      List<BrandInfoVO> listInfo = new ArrayList<BrandInfoVO>();



      List<TaoBaoShopVO> listShop = brandClassShopService.listEffectiveShop(start, count, cid);

      List<TaoBaoShopVO> listShop = brandClassShopService.listEffectiveShop(start, count, cid, platform, version);

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

         return listInfo;



@@ -247,37 +349,84 @@
      return brandClassShopService.countBrandShopinfo(cid);

   }



	
   @Override

   public void removeAgoByDate(Date date) {

      // 删除商品

      brandGoodsCaheService.removeAgoByDate(date);

		


      // 删除店铺

      brandShopCaheService.removeAgoByDate(date);



      long count = brandInfoMapper.countValidByCid(null);

      if (count == 0)

         return;



      for (int page = 0; page < (count / 100) + 1; page++) {

         updateTotalGoods(page * 100, 100);

      }

   }



	
	
   @Override

   public void addShopAndGoods(long start, int count) {

   /**

    * 更新商品数量

    * 
    * @param start

    * @param count

    */

   private void updateTotalGoods(long start, int count) {

      List<BrandInfo> list = brandInfoMapper.listValidAll(start, count);

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

         return;



      for (BrandInfo brandInfo : list) {

         String name = brandInfo.getName();

         String searchKey = brandInfo.getSearchKey();

         if (StringUtil.isNullOrEmpty(name) && StringUtil.isNullOrEmpty(searchKey))

            continue;

         long goodsTotal = brandGoodsCaheService.countByBrandId(brandInfo.getId());



         // 添加商品

         int goodsTotal = brandGoodsCaheService.addBrandGoods(brandInfo);



         brandInfo.setGoodsTotal(goodsTotal);

         brandInfo.setUpdateTime(new Date());

         brandInfoMapper.updateByPrimaryKeySelective(brandInfo);

         BrandInfo updateInfo = new BrandInfo();

         updateInfo.setId(brandInfo.getId());

         updateInfo.setGoodsTotal((int) goodsTotal);

         List<BrandShopCahe> listshop = brandShopCaheService.getByBrandId(brandInfo.getId());

         if (listshop == null) {

            updateInfo.setShopTotal(0);

         } else {

            updateInfo.setShopTotal(listshop.size());

         }

         updateInfo.setWeight(Math.random() * 1000);

         brandInfoMapper.updateByPrimaryKeySelective(updateInfo);

      }

   }



   @Override

   public void addShopAndGoods(long start, int count) {

      List<BrandInfo> list = brandInfoMapper.listValidAll(start, count);

      addShopAndGoods(list);

   }



   @Override

   public void addShopAndGoods(List<BrandInfo> list) {

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

         return;



      // long startTime = java.lang.System.currentTimeMillis();

      for (BrandInfo brandInfo : list) {

         try {

            String name = brandInfo.getName();

            String searchKey = brandInfo.getSearchKey();

            if (StringUtil.isNullOrEmpty(name) && StringUtil.isNullOrEmpty(searchKey))

               continue;

            // 添加商品

            BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(brandInfo);



            BrandInfo updateInfo = new BrandInfo();

            updateInfo.setId(brandInfo.getId());

            updateInfo.setWeight(Math.random() * 1000);

            updateInfo.setGoodsTotal(numInfo.getGoodsTotal());

            updateInfo.setShopTotal(numInfo.getShopTotal());

            updateInfo.setUpdateTime(new Date());

            brandInfoMapper.updateByPrimaryKeySelective(updateInfo);

         } catch (Exception e) {

            LogHelper.errorDetailInfo(e);

         }

      }

      // long endTime = java.lang.System.currentTimeMillis();

   }



   @Override

@@ -298,22 +447,21 @@
      return brandInfoMapper.listValidByCidToApp(cid);

   }



   @Cacheable(value = "brandCache", key = "'listValidToApp-'+#start+'-'+#start +'-'+#cid")

   @Cacheable(value = "brandCache", key = "'listValidToApp-'+#start+'-'+#cid")

   @Override

   public List<BrandInfoVO> listValidToApp(long start, int count, Long cid) {

   public List<BrandInfoVO> listValidToApp(long start, int count, Long cid, String platform, String version) {

      List<BrandInfoVO> list = brandInfoMapper.listBrandInfoVO(start, count, cid);

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

         return null;



      BigDecimal fanLiRate = hongBaoManageService.getFanLiRate();

      BigDecimal shareRate = hongBaoManageService.getShareRate();

      ConfigParamsDTO configParamsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE);

      ConfigParamsDTO configParamsDTO = orderHongBaoMoneyComputeService.getShowComputeRate(platform, version);



      List<BrandInfoVO> listInfo = new ArrayList<BrandInfoVO>();

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

         BrandInfoVO brand = list.get(i);

         if (brand == null)

            continue;

			


         List<BrandGoodsCahe> listGoods = brandGoodsCaheService.getByBrandId(1, 3, brand.getId());

         if (listGoods == null || listGoods.size() < 3)

            continue;

@@ -346,4 +494,55 @@
      }

      return listInfo;

   }



   @Override

   @Cacheable(value = "brandCache", key = "'listByAlikeName-'+#key+'-'+#platform+'-'+#version")

   public BrandInfoVO listByAlikeName(String key, String platform, String version) {

      if (StringUtil.isNullOrEmpty(key))

         return null;



      List<BrandInfoVO> list = brandInfoMapper.listByAlikeName(key);

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

         return null;



      ConfigParamsDTO configParamsDTO = orderHongBaoMoneyComputeService.getShowComputeRate(platform, version);



      BrandInfoVO brand = list.get(0);

      List<BrandGoodsCahe> listGoods = brandGoodsCaheService.getByBrandId(1, 3, brand.getId());

      if (listGoods == null || listGoods.size() < 3)

         return null;



      List<GoodsDetailVO> listGoodsVO = new ArrayList<GoodsDetailVO>();

      for (BrandGoodsCahe brandGoods : listGoods) {

         JDGoods goodsJD = brandGoods.getGoodsJD();

         if (goodsJD != null) {

            listGoodsVO.add(GoodsDetailVOFactory.convertJDGoods(goodsJD, configParamsDTO));

            continue;

         }



         TaoBaoGoodsBrief goodsTB = brandGoods.getGoodsTB();

         if (goodsTB != null) {

            listGoodsVO.add(GoodsDetailVOFactory.convertTaoBao(goodsTB, configParamsDTO));

            continue;

         }



         PDDGoodsDetail goodsPDD = brandGoods.getGoodsPDD();

         if (goodsPDD != null) {

            listGoodsVO.add(GoodsDetailVOFactory.convertPDDGoods(goodsPDD, configParamsDTO));

            continue;

         }

      }



      if (listGoodsVO.size() < 3)

         return null;



      brand.setListGoods(listGoodsVO);

      return brand;

   }



   @Override

   public List<BrandInfo> listValidOrderByUpdateTime(int page, int pageSize) {

      return brandInfoMapper.listValidAll((page - 1) * pageSize, pageSize);

   }



}