From 88b54772dbcf5ecab1e2316e4e4626ac901b8908 Mon Sep 17 00:00:00 2001 From: yujian <yujian> Date: 星期二, 22 一月 2019 15:58:24 +0800 Subject: [PATCH] 邀请码添加返回状态 --- fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java | 51 ++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 46 insertions(+), 5 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java index ddf93c9..6b7aa80 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/goods/CollectionGoodsV2ServiceImpl.java @@ -11,11 +11,11 @@ import com.yeshi.fanli.dao.mybatis.goods.CollectionGoodsV2Mapper; import com.yeshi.fanli.dao.mybatis.goods.CommonGoodsMapper; 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.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.exception.goods.CollectionGoodsException; import com.yeshi.fanli.exception.goods.CommonGoodsException; -import com.yeshi.fanli.goods.CollectionGoodsV2; -import com.yeshi.fanli.goods.CommonGoods; import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service; import com.yeshi.fanli.service.inter.goods.CommonGoodsService; import com.yeshi.fanli.util.factory.CommonGoodsFactory; @@ -62,7 +62,27 @@ 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 @Override public void cancelCollection(Long uid, Long id) throws CollectionGoodsException { @@ -82,12 +102,33 @@ @Override public List<CollectionGoodsV2> getCollectionGoodsList(Long uid, int page, int pageSize) { - return null; + return collectionGoodsV2Mapper.selectByUidOrderByCreateTimeDesc(uid, (page - 1) * pageSize, pageSize); } @Override public long getCollectionGoodsCount(Long uid) { - return 0; + return collectionGoodsV2Mapper.selectCountByUid(uid); + } + + @Override + public void cancelCollectionByAuctionId(Long uid, Long auctionId) throws CollectionGoodsException { + CollectionGoodsV2 goodsV2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid, + CommonGoods.GOODS_TYPE_TB, auctionId); + 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) { + CollectionGoodsV2 v2 = collectionGoodsV2Mapper.selectByUidAndGoodsTypeAndGoodsId(uid, CommonGoods.GOODS_TYPE_TB, + actionId); + return v2; } } -- Gitblit v1.8.0