package com.yeshi.fanli.service.impl.goods;
|
|
import java.io.InputStream;
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.UUID;
|
|
import javax.annotation.Resource;
|
import javax.transaction.Transactional;
|
|
import org.apache.commons.beanutils.PropertyUtils;
|
import org.springframework.cache.annotation.Cacheable;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.multipart.MultipartFile;
|
import org.yeshi.utils.tencentcloud.COSManager;
|
|
import com.google.gson.Gson;
|
import com.google.gson.GsonBuilder;
|
import com.yeshi.fanli.dao.mybatis.GoodsClassMapper;
|
import com.yeshi.fanli.entity.bus.clazz.GoodsClass;
|
import com.yeshi.fanli.entity.bus.clazz.GoodsSubClass;
|
import com.yeshi.fanli.entity.bus.su.clazz.SuperGoodsClass;
|
import com.yeshi.fanli.entity.system.BusinessSystem;
|
import com.yeshi.fanli.exception.GoodsClassException;
|
import com.yeshi.fanli.service.inter.config.BusinessSystemService;
|
import com.yeshi.fanli.service.inter.goods.GoodsClassService;
|
import com.yeshi.fanli.service.inter.goods.GoodsSubClassService;
|
import com.yeshi.fanli.service.inter.goods.SuperGoodsClassService;
|
import com.yeshi.fanli.service.inter.lable.LabelClassService;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.Utils;
|
|
@Service
|
public class GoodsClassServiceImpl implements GoodsClassService {
|
|
@Resource
|
private BusinessSystemService businessSystemService;
|
|
@Resource
|
private SuperGoodsClassService superGoodsClassService;
|
|
@Resource
|
private GoodsClassMapper goodsClassMapper;
|
|
@Resource
|
private GoodsSubClassService goodsSubClassService;
|
|
@Resource
|
private LabelClassService labelClassService;
|
|
|
public GoodsClass getGoodsClass(long id) {
|
return goodsClassMapper.selectByPrimaryKey(id);
|
}
|
|
@Override
|
public int updateByPrimaryKey(GoodsClass record) {
|
return goodsClassMapper.updateByPrimaryKey(record);
|
}
|
|
@Override
|
public String getKeysById(Long id) {
|
return goodsClassMapper.getKeysById(id);
|
}
|
|
@Override
|
public GoodsClass selectByPrimaryKey(Long gcid) {
|
return goodsClassMapper.selectByPrimaryKey(gcid);
|
}
|
|
@Override
|
public int updateByPrimaryKeySelective(GoodsClass record) {
|
return goodsClassMapper.updateByPrimaryKeySelective(record);
|
}
|
|
|
@Cacheable(value="classCache",key="'getGoodsClass-'+#gcid")
|
@Override
|
public GoodsClass getGoodsClassCache(long gcid) {
|
return getGoodsClass(gcid);
|
}
|
|
|
@Override
|
public void deleteGoodsClass(long id) {
|
goodsClassMapper.deleteByPrimaryKey(id);
|
}
|
|
|
@Override
|
public int getCount(String platform, String packages, final String key) {
|
|
Long systemId = null;
|
|
platform = Utils.getMap().get(platform);
|
|
BusinessSystem system = businessSystemService.getBusinessSystem(platform, packages);
|
if (system != null) {
|
systemId = system.getId();
|
}
|
;
|
return goodsClassMapper.countByName(key, systemId);
|
}
|
|
|
@Override
|
public List<GoodsClass> queryAll(String platform, String packages) throws Exception{
|
|
List<BusinessSystem> defultList = businessSystemService.getBusinessSystems();
|
|
platform = Utils.getMap().get(platform);
|
BusinessSystem system = businessSystemService.getBusinessSystem(platform, packages);
|
|
List<GoodsClass> goodsClassList = new ArrayList<GoodsClass>();
|
List<SuperGoodsClass> superGoodsClassList = null;
|
List<Long> gcIdList = new ArrayList<Long>();
|
|
if (system == null) {
|
|
goodsClassList = goodsClassMapper.getGoodsClassAll();
|
|
if (goodsClassList == null || goodsClassList.size() == 0) {
|
return null;
|
}
|
|
/* 存放类别id集合 */
|
for (GoodsClass rs : goodsClassList) {
|
gcIdList.add(rs.getId());
|
}
|
|
} else if (system != null) {
|
superGoodsClassList = superGoodsClassService.getSuperGoodsClassBySystemId(system.getId());
|
|
if (goodsClassList == null || goodsClassList.size() == 0) {
|
return null;
|
}
|
|
for (SuperGoodsClass superGoodsClass : superGoodsClassList) {
|
GoodsClass goodsClass = superGoodsClass.getGoodsClass();
|
goodsClassList.add(goodsClass);
|
gcIdList.add(goodsClass.getId());
|
}
|
|
}
|
|
/* 根据类别 id 查询关联系统数据 */
|
superGoodsClassList = superGoodsClassService.getSuperGoodsClasss(gcIdList);
|
|
for (GoodsClass gclass : goodsClassList) {
|
|
Long iosClick = gclass.getIosClick();
|
Long androidClick = gclass.getAndroidClick();
|
|
if (iosClick != null && androidClick != null) {
|
gclass.setCountClick(iosClick + androidClick);
|
} else if (androidClick != null) {
|
gclass.setCountClick(androidClick);
|
} else if (iosClick != null) {
|
gclass.setCountClick(iosClick);
|
} else {
|
gclass.setCountClick(0l);
|
}
|
|
String searchParam = gclass.getSearchParam();
|
if (searchParam == null) {
|
gclass.setSearchParam("");
|
} else {
|
gclass.setSearchParam(searchParam);
|
}
|
|
|
int countlabel = labelClassService.getCountQueryByClassId(gclass.getId());
|
gclass.setCountlabel(countlabel);
|
|
List<Long> gList = new ArrayList<Long>();
|
if (superGoodsClassList != null && superGoodsClassList.size() > 0) {
|
for (SuperGoodsClass srs : superGoodsClassList) {
|
|
long rsId = srs.getGoodsClass().getId();
|
|
if (gclass.getId() == rsId) {
|
BusinessSystem gsystem = srs.getSystem();
|
gList.add(gsystem.getId());
|
}
|
}
|
}
|
|
List<BusinessSystem> newList = new ArrayList<BusinessSystem>();
|
// 是否有关联系统选项
|
for (BusinessSystem dsystem : defultList) {
|
|
BusinessSystem newsystem = new BusinessSystem();
|
|
PropertyUtils.copyProperties(newsystem, dsystem);
|
newsystem.setCheck(0);
|
|
if (gList != null && gList.size() > 0) {
|
Long did = newsystem.getId();
|
for (Long gid : gList) {
|
if (gid == did) {
|
newsystem.setCheck(1);
|
}
|
}
|
}
|
|
newList.add(newsystem);
|
}
|
|
gclass.setSystemList(newList);
|
|
}
|
|
return goodsClassList;
|
|
}
|
|
public List<GoodsClass> getGoodsClassAll() {
|
return goodsClassMapper.getGoodsClassAll();
|
}
|
|
|
@Override
|
public void saveObject(MultipartFile file, GoodsClass record) throws GoodsClassException, Exception{
|
|
String name = record.getName();
|
if (name == null || name.trim().length() == 0) {
|
throw new GoodsClassException(1, "分类名称不能为空");
|
}
|
|
|
// 图片上传
|
String picture = null;
|
if (file != null) {
|
picture = uploadPicture(file);
|
}
|
|
String params = record.getSearchParam();
|
if (params== null || params.trim().length() == 0 || "null".equalsIgnoreCase(params)) {
|
record.setSearchParam(null);
|
} else {
|
record.setSearchParam(params);
|
}
|
|
|
|
Long id = record.getId();
|
if (id == null) {
|
record.setPicture(picture);
|
record.setIosClick(0L);
|
record.setAndroidClick(0L);
|
|
record.setCreatetime(java.lang.System.currentTimeMillis());
|
|
if (params== null || params.trim().length() == 0 || "null".equalsIgnoreCase(params)) {
|
// 搜索条件:有券、在售价20-200、牛皮癣轻微
|
record.setSearchParam("{\"quan\":1,\"endPrice\":220,\"includeGoodRate\":true,\"baoYou\":true,\"ip\":\"218.72.111.105\"}");
|
}
|
|
// 排序
|
int maxOrder = goodsClassMapper.getMaxOrder();
|
record.setOrderby(maxOrder + 1);
|
|
goodsClassMapper.insert(record);
|
|
// 默认所有系统使用
|
List<BusinessSystem> listSystems = businessSystemService.getBusinessSystems();
|
if (listSystems != null && listSystems.size() > 0) {
|
for(BusinessSystem businessSystem: listSystems) {
|
SuperGoodsClass superGoodsClass = new SuperGoodsClass();
|
superGoodsClass.setGoodsClass(record);;
|
superGoodsClass.setSystem(businessSystem);
|
superGoodsClassService.insertSelective(superGoodsClass);
|
}
|
}
|
|
} else {
|
// 修改
|
GoodsClass resultObj = goodsClassMapper.selectByPrimaryKey(id);
|
if (resultObj == null) {
|
throw new GoodsClassException(1, "修改内容已不存在");
|
}
|
|
if (picture != null && picture.trim().length() > 0) {
|
// 删除老图
|
removePicture(resultObj.getPicture());
|
// 存储新图
|
record.setPicture(picture);
|
} else {
|
record.setPicture(resultObj.getPicture());
|
}
|
|
record.setIosClick(resultObj.getIosClick());
|
record.setOrderby(resultObj.getOrderby());
|
record.setAndroidClick(resultObj.getAndroidClick());
|
record.setCreatetime(resultObj.getCreatetime());
|
goodsClassMapper.updateByPrimaryKey(record);
|
}
|
}
|
|
|
/**
|
* 上传图片
|
* @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/GoodsClass/"+UUID.randomUUID().toString().replace("-", "") + "." + type;
|
// 执行上传
|
String fileLink= COSManager.getInstance().uploadFile(inputStream, filePath).getUrl();
|
|
return fileLink;
|
}
|
|
/**
|
* 删除图片-不更新数据库
|
* @param record
|
* @throws Exception
|
*/
|
public void removePicture(String picture) throws Exception {
|
if (picture != null && picture.trim().length() > 0) {
|
COSManager.getInstance().deleteFile(picture);
|
}
|
}
|
|
|
|
|
|
@Override
|
public void uploadPicture(GoodsClass record, MultipartFile file) throws Exception {
|
|
InputStream inputStream = file.getInputStream();
|
String contentType = file.getContentType();
|
String type = contentType.substring(contentType.indexOf("/") + 1);
|
// 上传文件相对位置
|
String fileUrl="ClassImg/"+UUID.randomUUID().toString().replace("-", "") + "." + type;
|
|
boolean deleteFile =true;
|
|
/* 修改图片时，先删除已存在图片 */
|
String picture = record.getPicture();
|
if (!StringUtil.isNullOrEmpty(picture))
|
deleteFile = COSManager.getInstance().deleteFile(picture);
|
|
String uploadFilePath = null;
|
/* 上传新图片 */
|
if (deleteFile) {
|
uploadFilePath = COSManager.getInstance().uploadFile(inputStream, fileUrl).getUrl();
|
}
|
|
/* 更新数据库信息 */
|
if (!StringUtil.isNullOrEmpty(uploadFilePath)) {
|
record.setPicture(uploadFilePath);
|
goodsClassMapper.updateByPrimaryKey(record);
|
}
|
|
}
|
|
/**
|
* 删除图片
|
*/
|
@Override
|
public void removePicture(GoodsClass record) throws Exception {
|
|
String fileUrl = record.getPicture();
|
boolean deleteFile = true;
|
|
if (StringUtil.isNullOrEmpty(fileUrl)) {
|
return;
|
}
|
|
deleteFile = COSManager.getInstance().deleteFile(fileUrl);
|
if (deleteFile) {
|
record.setPicture(null);
|
// 更新数据库
|
goodsClassMapper.updateByPrimaryKey(record);
|
}
|
}
|
|
@Override
|
@Cacheable(value="classCache",key="'getListClassCache-'+#systemId")
|
public List<GoodsClass> getListClassCache(Long systemId) throws Exception {
|
List<SuperGoodsClass> superGoodsClassList = superGoodsClassService.getSuperGoodsClassBySystemId(systemId);
|
|
if (superGoodsClassList == null || superGoodsClassList.size() == 0) {
|
return null;
|
}
|
|
List<GoodsClass> goodsClassList = new ArrayList<GoodsClass>();
|
for (SuperGoodsClass superGoodsClass : superGoodsClassList) {
|
GoodsClass goodsClass = superGoodsClass.getGoodsClass();
|
goodsClassList.add(goodsClass);
|
}
|
|
return goodsClassList;
|
}
|
|
|
@Override
|
@Cacheable(value="classCache",key="'getClassListAllCache-'+#systemId")
|
public List<Map<String, Object>> getClassListAllCache(Long systemId) throws Exception {
|
|
List<GoodsClass> goodsClassList = goodsClassMapper.listGoodsClassBySystemId(systemId);
|
if (goodsClassList == null || goodsClassList.size() == 0) {
|
return null;
|
}
|
|
List<Long> listID = new ArrayList<Long>();
|
for (GoodsClass coodsClass : goodsClassList) {
|
listID.add(coodsClass.getId());
|
}
|
|
List<GoodsSubClass> listSub = goodsSubClassService.queryByListCid(listID);
|
|
Gson gson = new GsonBuilder().create();
|
|
List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
|
for (GoodsClass goodsClass : goodsClassList) {
|
|
List<GoodsSubClass> subClassList = new ArrayList<GoodsSubClass>();
|
|
if (listSub != null && listSub.size() > 0) {
|
Iterator<GoodsSubClass> iterator = listSub.iterator();
|
while (iterator.hasNext()) {
|
GoodsSubClass goodsSubClass = iterator.next();
|
GoodsClass goodsClassInner = goodsSubClass.getRootClass();
|
if (goodsClass.getId() == goodsClassInner.getId()) {
|
// 对应下子分类
|
subClassList.add(goodsSubClass);
|
iterator.remove();
|
}
|
}
|
}
|
|
Map<String, Object> map = new HashMap<String, Object>();
|
map.put("gclass", goodsClass);
|
map.put("subList", gson.toJson(subClassList));
|
|
list.add(map);
|
}
|
|
return list;
|
}
|
|
|
@Override
|
@Transactional
|
public void updateOrder(Long id, Integer moveType) throws GoodsClassException {
|
|
if (id == null || moveType == null || (!moveType.equals(1) && !moveType.equals(-1))) {
|
throw new GoodsClassException(1, "请传递正确参数");
|
}
|
|
GoodsClass resultObj = goodsClassMapper.selectByPrimaryKey(id);
|
if (resultObj == null) {
|
throw new GoodsClassException(1, "此内容已不存在");
|
}
|
|
Integer order = resultObj.getOrderby();
|
// 获取交换对象
|
GoodsClass exchangeObject = goodsClassMapper.getByAdjoinOrder( order, moveType);
|
if (exchangeObject == null) {
|
if (moveType == 1) {
|
throw new GoodsClassException(1, "在相同使用地方中优先级已经最低了");
|
} else {
|
throw new GoodsClassException(1, "在相同使用地方中优先级已经最高了");
|
}
|
}
|
|
resultObj.setOrderby(exchangeObject.getOrderby());
|
exchangeObject.setOrderby(order);
|
|
goodsClassMapper.updateByPrimaryKey(resultObj);
|
goodsClassMapper.updateByPrimaryKey(exchangeObject);
|
}
|
|
}
|
