From e1a62ec62e7331d97af9302e90e1ce44af8235eb Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 27 一月 2021 15:26:55 +0800
Subject: [PATCH] 拼多多授权绑定
---
fanli/src/main/java/com/yeshi/fanli/service/impl/brand/BrandInfoServiceImpl.java | 247 ++++++++++++++++++++++++++++++------------------
1 files changed, 154 insertions(+), 93 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 014b339..9c65dfd 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;
@@ -9,13 +8,13 @@
import javax.annotation.Resource;
+import com.yeshi.fanli.entity.SystemEnum;
import org.springframework.cache.annotation.Cacheable;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import org.yeshi.utils.tencentcloud.COSManager;
-import com.yeshi.fanli.dao.brand.BrandShopCaheDao;
import com.yeshi.fanli.dao.mybatis.brand.BrandInfoMapper;
import com.yeshi.fanli.dto.ConfigParamsDTO;
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
@@ -24,19 +23,17 @@
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.goods.facade.entity.taobao.TaoBaoGoodsBrief;
+import com.yeshi.common.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.config.HongBaoManageService;
-import com.yeshi.fanli.service.inter.taobao.TaoBaoGoodsUpdateService;
+import com.yeshi.fanli.service.inter.order.OrderHongBaoMoneyComputeService;
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;
@@ -50,22 +47,10 @@
private BrandInfoMapper brandInfoMapper;
@Resource
- private HongBaoManageService hongBaoManageService;
-
- @Resource
- private QualityGoodsService qualityGoodsService;
-
- @Resource
- private TaoBaoGoodsBriefService taoBaoGoodsBriefService;
-
- @Resource
- private TaoBaoGoodsUpdateService taoBaoGoodsUpdateService;
+ private OrderHongBaoMoneyComputeService orderHongBaoMoneyComputeService;
@Resource
private BrandClassShopService brandClassShopService;
-
- @Resource
- private BrandShopCaheDao brandShopCaheDao;
@Resource
private BrandGoodsCaheService brandGoodsCaheService;
@@ -75,8 +60,7 @@
@Resource(name = "taskExecutor")
private TaskExecutor executor;
-
-
+
@Override
public void saveObject(MultipartFile file, BrandInfo record) throws BrandInfoException {
String name = record.getName();
@@ -84,20 +68,19 @@
throw new BrandInfoException(1, "鍚嶇О涓嶈兘涓虹┖");
BrandClass brandClass = record.getBrandClass();
- if (brandClass ==null || brandClass.getId() == null)
+ 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) {
state = 0;
record.setState(state);
}
-
-
+
String picture = null;
if (file != null) {
try { // 鍥剧墖涓婁紶
@@ -106,27 +89,27 @@
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);
@@ -135,7 +118,7 @@
record.setShopTotal(0);
record.setCreateTime(new Date());
brandInfoMapper.insert(record);
-
+
BrandInfo resultObj = new BrandInfo();
resultObj.setId(record.getId());
resultObj.setOrder(Integer.valueOf(record.getId().toString()));
@@ -149,14 +132,15 @@
// 鍒犻櫎鑰佸浘
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 {
@@ -167,8 +151,8 @@
record.setWeight(resultObj.getWeight());
record.setCreateTime(resultObj.getCreateTime());
brandInfoMapper.updateByPrimaryKey(record);
-
- if (state == 0){
+
+ if (state == 0) {
executor.execute(new Runnable() {
@Override
public void run() {
@@ -183,8 +167,8 @@
executor.execute(new Runnable() {
@Override
public void run() {
- BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(record);
-
+ BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(record, SystemEnum.blks);
+
BrandInfo update = new BrandInfo();
update.setId(record.getId());
update.setGoodsTotal(numInfo.getGoodsTotal());
@@ -195,76 +179,98 @@
}
}
-
/**
* 涓婁紶鍥剧墖
+ *
* @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 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)
+ if (resultObj == null)
throw new BrandInfoException(1, "鎿嶄綔鏁版嵁宸蹭笉瀛樺湪");
-
+
Integer oldOrder = resultObj.getOrder();
- BrandInfo changeObj = brandInfoMapper.getByAdjoinOrder(resultObj.getBrandClass().getId(),oldOrder, moveType);
- if (changeObj == null )
+ 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 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);
+ 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
@@ -274,10 +280,10 @@
@Override
@Cacheable(value = "brandCache", key = "'listValidBrandInfoCache-'+#cid")
- public List<BrandInfo> listValidBrandInfoCache(Long cid) {
+ public List<BrandInfo> listValidBrandInfoCache(Long cid,SystemEnum system) {
List<BrandInfo> listInfo = new ArrayList<BrandInfo>();
- List<TaoBaoShop> listShop = brandClassShopService.listEffectiveClassShop(cid);
+ List<TaoBaoShop> listShop = brandClassShopService.listEffectiveClassShop(cid,system);
if (listShop == null || listShop.size() == 0)
return listInfo;
for (TaoBaoShop taoBaoShop : listShop) {
@@ -291,11 +297,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+'-'+#system")
+ public List<BrandInfoVO> listBrandInfoCache(long start, int count, Long cid, String platform, String version,SystemEnum system) {
List<BrandInfoVO> listInfo = new ArrayList<BrandInfoVO>();
- List<TaoBaoShopVO> listShop = brandClassShopService.listEffectiveShop(start, count, cid);
+ List<TaoBaoShopVO> listShop = brandClassShopService.listEffectiveShop(start, count, cid, platform, version,system);
if (listShop == null || listShop.size() == 0)
return listInfo;
@@ -324,15 +330,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;
@@ -344,6 +349,7 @@
/**
* 鏇存柊鍟嗗搧鏁伴噺
+ *
* @param start
* @param count
*/
@@ -351,13 +357,13 @@
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);
@@ -368,14 +374,19 @@
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();
@@ -383,9 +394,9 @@
if (StringUtil.isNullOrEmpty(name) && StringUtil.isNullOrEmpty(searchKey))
continue;
// 娣诲姞鍟嗗搧
- BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(brandInfo);
-
- BrandInfo updateInfo = new BrandInfo();
+ BrandInfo numInfo = brandGoodsCaheService.addBrandGoods(brandInfo, SystemEnum.blks);
+
+ BrandInfo updateInfo = new BrandInfo();
updateInfo.setId(brandInfo.getId());
updateInfo.setWeight(Math.random() * 1000);
updateInfo.setGoodsTotal(numInfo.getGoodsTotal());
@@ -395,8 +406,8 @@
} catch (Exception e) {
LogHelper.errorDetailInfo(e);
}
-
}
+ // long endTime = java.lang.System.currentTimeMillis();
}
@Override
@@ -405,34 +416,33 @@
}
@Override
- public long countValidByCidToApp(Long cid) {
- return brandInfoMapper.countValidByCidToApp(cid);
+ public long countValidByCidToApp(Long cid, SystemEnum system) {
+ return brandInfoMapper.countValidByCidToApp(cid,system);
}
@Override
- @Cacheable(value = "brandCache", key = "'listValidByCidToApp-'+#cid")
- public List<BrandInfo> listValidByCidToApp(Long cid) {
+ @Cacheable(value = "brandCache", key = "'listValidByCidToApp-'+#cid+'-'+#system")
+ public List<BrandInfo> listValidByCidToApp(Long cid, SystemEnum system) {
if (cid == null)
return null;
- return brandInfoMapper.listValidByCidToApp(cid);
+ return brandInfoMapper.listValidByCidToApp(cid,system);
}
- @Cacheable(value = "brandCache", key = "'listValidToApp-'+#start+'-'+#cid")
+ @Cacheable(value = "brandCache", key = "'listValidToApp-'+#start+'-'+#cid+'-'+#system")
@Override
- public List<BrandInfoVO> listValidToApp(long start, int count, Long cid) {
- List<BrandInfoVO> list = brandInfoMapper.listBrandInfoVO(start, count, cid);
+ public List<BrandInfoVO> listValidToApp(long start, int count, Long cid, String platform, String version,SystemEnum system) {
+ List<BrandInfoVO> list = brandInfoMapper.listBrandInfoVO(start, count, cid,system);
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,hongBaoManageService.getVIPFanLiRate());
+ ConfigParamsDTO configParamsDTO = orderHongBaoMoneyComputeService.getShowComputeRate(platform, version,system);
+
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;
@@ -465,4 +475,55 @@
}
return listInfo;
}
+
+ @Override
+ @Cacheable(value = "brandCache", key = "'listByAlikeName-'+#key+'-'+#platform+'-'+#version+'-'+#system")
+ public BrandInfoVO listByAlikeName(String key, String platform, String version,SystemEnum system) {
+ 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, system);
+
+ 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