From 24a8d17e007545f7426c48352109aa1a9c6587ee Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 06 五月 2020 12:02:09 +0800 Subject: [PATCH] IOS上线隐藏我的界面的banner与超级会员升级信息 --- fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandInfoServiceImpl.java | 303 +++++++++++++++++++++++++++++++++++++------------- 1 files changed, 223 insertions(+), 80 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandInfoServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandInfoServiceImpl.java index 6e2cf5f..28bc515 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandInfoServiceImpl.java +++ b/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,6 +18,7 @@ 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; @@ -26,15 +26,18 @@ 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; @@ -49,6 +52,9 @@ @Resource private HongBaoManageService hongBaoManageService; + + @Resource + private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService; @Resource private QualityGoodsService qualityGoodsService; @@ -73,41 +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 shopKey = record.getShopKey(); - if (StringUtil.isNullOrEmpty(shopKey)) - record.setShopKey(name); - - 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) @@ -117,23 +151,27 @@ // 鍒犻櫎鑰佸浘 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()); } - if (state == 0){ + + 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() { @@ -148,66 +186,115 @@ executor.execute(new Runnable() { @Override public void run() { - int goodsTotal = brandGoodsCaheService.addBrandGoods(record); - record.setGoodsTotal(goodsTotal); - - List<BrandShopCahe> listshop = brandShopCaheService.getByBrandId(record.getId()); - if (listshop == null) { - record.setShopTotal(0); - } else { - record.setShopTotal(listshop.size()); - } - 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 { - - // 鏂囦欢瑙f瀽 + // 鏂囦欢瑙f瀽 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 @@ -229,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; @@ -262,15 +349,14 @@ 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; @@ -282,6 +368,7 @@ /** * 鏇存柊鍟嗗搧鏁伴噺 + * * @param start * @param count */ @@ -289,51 +376,57 @@ List<BrandInfo> list = brandInfoMapper.listValidAll(start, count); if (list == null || list.size() == 0) return; - + for (BrandInfo brandInfo : list) { long goodsTotal = brandGoodsCaheService.countByBrandId(brandInfo.getId()); - + BrandInfo updateInfo = new BrandInfo(); updateInfo.setId(brandInfo.getId()); - updateInfo.setGoodsTotal((int)goodsTotal); + 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) { - String name = brandInfo.getName(); - String searchKey = brandInfo.getSearchKey(); - if (StringUtil.isNullOrEmpty(name) && StringUtil.isNullOrEmpty(searchKey)) - continue; + try { + String name = brandInfo.getName(); + String searchKey = brandInfo.getSearchKey(); + if (StringUtil.isNullOrEmpty(name) && StringUtil.isNullOrEmpty(searchKey)) + continue; + // 娣诲姞鍟嗗搧 + BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(brandInfo); - // 娣诲姞鍟嗗搧 - int goodsTotal = brandGoodsCaheService.addBrandGoods(brandInfo); - - brandInfo.setGoodsTotal(goodsTotal); - brandInfo.setUpdateTime(new Date()); - - List<BrandShopCahe> listshop = brandShopCaheService.getByBrandId(brandInfo.getId()); - if (listshop == null) { - brandInfo.setShopTotal(0); - } else { - brandInfo.setShopTotal(listshop.size()); + 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); } - brandInfoMapper.updateByPrimaryKeySelective(brandInfo); } + // long endTime = java.lang.System.currentTimeMillis(); } @Override @@ -356,20 +449,19 @@ @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; @@ -402,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); + } + } -- Gitblit v1.8.0