admin
2020-05-06 24a8d17e007545f7426c48352109aa1a9c6587ee
fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java
@@ -5,14 +5,17 @@
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;
@@ -32,7 +35,7 @@
   @Resource
   private CommonGoodsService commonGoodsService;
   @Transactional
   @Transactional(rollbackFor=Exception.class)
   @Override
   public void addCollection(Long uid, TaoBaoGoodsBrief goods) throws CollectionGoodsException {
      if (uid == null || uid == 0)
@@ -62,6 +65,69 @@
      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)
@@ -83,7 +149,7 @@
      collectionGoodsV2Mapper.insertSelective(goods);
   }
   @Transactional
   @Transactional(rollbackFor=Exception.class)
   @Override
   public void cancelCollection(Long uid, Long id) throws CollectionGoodsException {
      if (uid == null || uid == 0)
@@ -101,19 +167,18 @@
   }
   @Override
   public List<CollectionGoodsV2> getCollectionGoodsList(Long uid, int page, int pageSize) {
      return collectionGoodsV2Mapper.selectByUidOrderByCreateTimeDesc(uid, (page - 1) * pageSize, pageSize);
   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) {
      return collectionGoodsV2Mapper.selectCountByUid(uid);
   public long getCollectionGoodsCount(Long uid, Integer source) {
      return collectionGoodsV2Mapper.selectCountByUid(uid, source);
   }
   @Override
   public void cancelCollectionByAuctionId(Long uid, Long auctionId) throws CollectionGoodsException {
      CollectionGoodsV2 goodsV2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid,
            CommonGoods.GOODS_TYPE_TB, auctionId);
   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());
@@ -125,10 +190,19 @@
   }
   @Override
   public CollectionGoodsV2 findByUidAndAuctionId(Long uid, Long actionId) {
      CollectionGoodsV2 v2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid, CommonGoods.GOODS_TYPE_TB,
            actionId);
   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());
         }
      }
   }
}