package com.yeshi.fanli.service.impl.goods;
|
|
import java.util.Date;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
|
import org.apache.ibatis.annotations.Param;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.yeshi.fanli.dao.mybatis.goods.CollectionGoodsV2Mapper;
|
import com.yeshi.fanli.dao.mybatis.goods.CommonGoodsMapper;
|
import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
|
import com.yeshi.fanli.entity.bus.user.UserInfo;
|
import com.yeshi.fanli.entity.goods.CollectionGoodsV2;
|
import com.yeshi.fanli.entity.goods.CommonGoods;
|
import com.yeshi.fanli.entity.jd.JDGoods;
|
import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
|
import com.yeshi.fanli.exception.goods.CollectionGoodsException;
|
import com.yeshi.fanli.exception.goods.CommonGoodsException;
|
import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;
|
import com.yeshi.fanli.service.inter.goods.CommonGoodsService;
|
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
|
|
@Service
|
public class CollectionGoodsV2ServiceImpl implements CollectionGoodsV2Service {
|
|
@Resource
|
private CollectionGoodsV2Mapper collectionGoodsV2Mapper;
|
|
@Resource
|
private CommonGoodsMapper commonGoodsMapper;
|
|
@Resource
|
private CommonGoodsService commonGoodsService;
|
|
@Transactional(rollbackFor=Exception.class)
|
@Override
|
public void addCollection(Long uid, TaoBaoGoodsBrief goods) throws CollectionGoodsException {
|
if (uid == null || uid == 0)
|
throw new CollectionGoodsException(1, "无用户ID");
|
CommonGoods commonGoods = CommonGoodsFactory.create(goods);
|
if (commonGoods == null)
|
throw new CollectionGoodsException(2, "商品信息获取失败");
|
// 判断商品是否存在
|
try {
|
commonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
|
} catch (CommonGoodsException e) {
|
commonGoods = null;
|
}
|
if (commonGoods == null || commonGoods.getId() == null)
|
throw new CollectionGoodsException(3, "商品信息添加失败");
|
|
CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper.selectByUidAndCommonGoodsId(uid,
|
commonGoods.getId());
|
if (collectionGoodsV2 != null)
|
throw new CollectionGoodsException(4, "商品已被收藏");
|
|
collectionGoodsV2 = new CollectionGoodsV2();
|
collectionGoodsV2.setCommonGoods(commonGoods);
|
collectionGoodsV2.setCreateTime(new Date());
|
collectionGoodsV2.setUpdateTime(new Date());
|
collectionGoodsV2.setUserInfo(new UserInfo(uid));
|
collectionGoodsV2Mapper.insertSelective(collectionGoodsV2);
|
}
|
|
|
@Transactional(rollbackFor=Exception.class)
|
@Override
|
public void addJDCollection(Long uid, JDGoods jdGoods) throws CollectionGoodsException {
|
if (uid == null || uid == 0)
|
throw new CollectionGoodsException(1, "无用户ID");
|
CommonGoods commonGoods = CommonGoodsFactory.create(jdGoods);
|
if (commonGoods == null)
|
throw new CollectionGoodsException(2, "商品信息获取失败");
|
// 判断商品是否存在
|
try {
|
commonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
|
} catch (CommonGoodsException e) {
|
commonGoods = null;
|
}
|
if (commonGoods == null || commonGoods.getId() == null)
|
throw new CollectionGoodsException(3, "商品信息添加失败");
|
|
CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper.selectByUidAndCommonGoodsId(uid,
|
commonGoods.getId());
|
if (collectionGoodsV2 != null)
|
throw new CollectionGoodsException(4, "商品已被收藏");
|
|
collectionGoodsV2 = new CollectionGoodsV2();
|
collectionGoodsV2.setCommonGoods(commonGoods);
|
collectionGoodsV2.setCreateTime(new Date());
|
collectionGoodsV2.setUpdateTime(new Date());
|
collectionGoodsV2.setUserInfo(new UserInfo(uid));
|
collectionGoodsV2Mapper.insertSelective(collectionGoodsV2);
|
}
|
|
|
@Transactional(rollbackFor=Exception.class)
|
@Override
|
public void addPDDCollection(Long uid, PDDGoodsDetail goods) throws CollectionGoodsException {
|
if (uid == null || uid == 0)
|
throw new CollectionGoodsException(1, "无用户ID");
|
CommonGoods commonGoods = CommonGoodsFactory.create(goods);
|
if (commonGoods == null)
|
throw new CollectionGoodsException(2, "商品信息获取失败");
|
// 判断商品是否存在
|
try {
|
commonGoods = commonGoodsService.addOrUpdateCommonGoods(commonGoods);
|
} catch (CommonGoodsException e) {
|
commonGoods = null;
|
}
|
if (commonGoods == null || commonGoods.getId() == null)
|
throw new CollectionGoodsException(3, "商品信息添加失败");
|
|
CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper.selectByUidAndCommonGoodsId(uid,
|
commonGoods.getId());
|
if (collectionGoodsV2 != null)
|
throw new CollectionGoodsException(4, "商品已被收藏");
|
|
collectionGoodsV2 = new CollectionGoodsV2();
|
collectionGoodsV2.setCommonGoods(commonGoods);
|
collectionGoodsV2.setCreateTime(new Date());
|
collectionGoodsV2.setUpdateTime(new Date());
|
collectionGoodsV2.setUserInfo(new UserInfo(uid));
|
collectionGoodsV2Mapper.insertSelective(collectionGoodsV2);
|
}
|
|
|
@Override
|
public void addCollection(CollectionGoodsV2 goods) throws CollectionGoodsException {
|
if (goods.getUserInfo() == null || goods.getCommonGoods() == null)
|
throw new CollectionGoodsException(1, "数据不完整");
|
try {
|
CommonGoods commonGoods = commonGoodsService.addOrUpdateCommonGoods(goods.getCommonGoods());
|
goods.setCommonGoods(commonGoods);
|
} catch (CommonGoodsException e) {
|
goods.setCommonGoods(null);
|
}
|
|
if (goods.getCommonGoods() == null)
|
throw new CollectionGoodsException(3, "商品信息添加失败");
|
|
CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper
|
.selectByUidAndCommonGoodsId(goods.getUserInfo().getId(), goods.getCommonGoods().getId());
|
if (collectionGoodsV2 != null)
|
throw new CollectionGoodsException(4, "商品已被收藏");
|
collectionGoodsV2Mapper.insertSelective(goods);
|
}
|
|
@Transactional(rollbackFor=Exception.class)
|
@Override
|
public void cancelCollection(Long uid, Long id) throws CollectionGoodsException {
|
if (uid == null || uid == 0)
|
throw new CollectionGoodsException(1, "无用户ID");
|
|
if (id == null || id == 0)
|
throw new CollectionGoodsException(1, "无收藏");
|
|
CollectionGoodsV2 collectionGoodsV2 = collectionGoodsV2Mapper.selectByPrimaryKey(id);
|
if (collectionGoodsV2 == null)
|
return;
|
if (collectionGoodsV2.getUserInfo().getId() != uid.longValue())
|
throw new CollectionGoodsException(2, "无权限");
|
collectionGoodsV2Mapper.deleteByPrimaryKey(id);
|
}
|
|
@Override
|
public List<CollectionGoodsV2> getCollectionGoodsList(Long uid, int page, int pageSize, Integer source) {
|
return collectionGoodsV2Mapper.selectByUidOrderByCreateTimeDesc(uid, (page - 1) * pageSize, pageSize, source);
|
}
|
|
@Override
|
public long getCollectionGoodsCount(Long uid, Integer source) {
|
return collectionGoodsV2Mapper.selectCountByUid(uid, source);
|
}
|
|
@Override
|
public void cancelCollectionByAuctionId(Long uid, Long auctionId, Integer goodsType) throws CollectionGoodsException {
|
CollectionGoodsV2 goodsV2 = collectionGoodsV2Mapper.selectByUidAndGoodsType(uid, auctionId, goodsType);
|
if (goodsV2 == null)
|
throw new CollectionGoodsException(1, "无收藏");
|
collectionGoodsV2Mapper.deleteByPrimaryKey(goodsV2.getId());
|
}
|
|
@Override
|
public void cancelCollectionByUid(Long uid) throws CollectionGoodsException {
|
collectionGoodsV2Mapper.deleteByUid(uid);
|
}
|
|
@Override
|
public CollectionGoodsV2 findByUidAndAuctionId(Long uid, Long actionId, Integer goodsType) {
|
CollectionGoodsV2 v2 = collectionGoodsV2Mapper.selectByUidAndGoodsType(uid, actionId, goodsType);
|
return v2;
|
}
|
|
@Override
|
public void deteleBYByUidAndCommonId(Long uid, Long commonId) {
|
List<CollectionGoodsV2> list = collectionGoodsV2Mapper.getByUidAndCommonId(uid, commonId);
|
if (list != null && list.size() > 0) {
|
for (CollectionGoodsV2 v2: list) {
|
collectionGoodsV2Mapper.deleteByPrimaryKey(v2.getId());
|
}
|
}
|
}
|
|
}
|
