From d28bed1a1275131a5ca37f7da37961e2b518ac07 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 26 八月 2019 13:44:00 +0800
Subject: [PATCH] 淘礼金创建异常处理
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserGoodsStorageServiceImpl.java | 316 ++++++++++++++++++++++++++++++++++++----------------
1 files changed, 218 insertions(+), 98 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserGoodsStorageServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserGoodsStorageServiceImpl.java
index 933a834..c7056a0 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserGoodsStorageServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserGoodsStorageServiceImpl.java
@@ -4,24 +4,24 @@
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
-import java.util.Map;
import java.util.Set;
import javax.annotation.Resource;
-import net.sf.json.JSONArray;
-import net.sf.json.JSONObject;
-
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.JsonUtil;
+import org.yeshi.utils.entity.FileUploadResult;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.yeshi.fanli.dao.mybatis.user.UserGoodsStorageMapper;
-import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord.ShareSourceTypeEnum;
+import com.yeshi.fanli.dto.pdd.PDDGoodsDetail;
+import com.yeshi.fanli.dto.share.ShareGoodsRecordDTO;
import com.yeshi.fanli.entity.bus.user.UserGoodsStorage;
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.CommonGoodsException;
import com.yeshi.fanli.exception.share.UserShareGoodsRecordException;
@@ -33,11 +33,18 @@
import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;
import com.yeshi.fanli.service.inter.user.UserGoodsStorageService;
import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;
+import com.yeshi.fanli.util.CommonGoodsUtil;
+import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.MoneyBigDecimalUtil;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.factory.CommonGoodsFactory;
+import com.yeshi.fanli.util.jd.JDApiUtil;
+import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil;
import com.yeshi.fanli.util.taobao.TaoBaoUtil;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
+
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
@Service
public class UserGoodsStorageServiceImpl implements UserGoodsStorageService {
@@ -117,27 +124,22 @@
}
@Override
- public List<UserGoodsStorage> listQueryByUid(long start, int count, Long uid) {
- return userGoodsStorageMapper.listQueryByUid(start, count, uid);
+ public List<UserGoodsStorage> listQueryByUid(long start, int count, Long uid, Integer source) {
+ return userGoodsStorageMapper.listQueryByUid(start, count, uid, source);
}
@Override
- public UserGoodsStorage getByUidAndAuctionId(Long uid, Long auctionId) {
- return userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId);
+ public UserGoodsStorage getByUidAndAuctionId(Long uid, Long auctionId, Integer goodsType) {
+ return userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId, goodsType);
}
@Override
- public long countQueryByUid(Long uid) {
- return userGoodsStorageMapper.countQueryByUid(uid);
+ public long countQueryByUid(Long uid, Integer source) {
+ return userGoodsStorageMapper.countQueryByUid(uid, source);
}
@Override
- public void updateShareState(Long shareId) {
- userGoodsStorageMapper.updateShareState(shareId);
- }
-
- @Override
- public void save(Long uid, Set<Long> auctionIds) throws UserGoodsStorageException {
+ public void save(Long uid, Set<Long> auctionIds, Integer goodsType) throws UserGoodsStorageException {
if (uid == null) {
throw new UserGoodsStorageException(1, "鐢ㄦ埛灏氭湭鐧诲綍");
@@ -148,86 +150,145 @@
}
for (Long auctionId : auctionIds) {
-
- TaoBaoGoodsBrief goodsBrief = null;
-
- try {
- // 鑾峰彇鍟嗗搧璇︽儏
- goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
- } catch (TaobaoGoodsDownException e) {
-
- // 鏇存柊绠�鐗� 涓嬫灦鐘舵��
- CommonGoods commonGoods = new CommonGoods();
- commonGoods.setGoodsId(auctionId);
- commonGoods.setGoodsType(CommonGoods.GOODS_TYPE_TB);
- commonGoods.setState(CommonGoods.STATE_OFFLINE);
-
- throw new UserGoodsStorageException(1, "璇ュ晢鍝佸凡涓嬫灦");
- }
-
- // 杞崲绠�鐗堝晢鍝佷俊鎭�
- CommonGoods commonGoods = CommonGoodsFactory.create(goodsBrief);
- try {
- commonGoodsService.addOrUpdateCommonGoods(commonGoods);
- } catch (CommonGoodsException e) {
- e.printStackTrace();
- throw new UserGoodsStorageException(1, "鍟嗗搧淇℃伅鏇存柊澶辫触");
- }
-
- Long cid = commonGoods.getId();
-
- UserGoodsStorage goodsStorage = userGoodsStorageMapper.getByUidAndCid(uid, cid);
-
- if (goodsStorage != null) {
- // 鍒濆璇濈姸鎬�
- goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
- goodsStorage.setUpdateTime(new Date());
- userGoodsStorageMapper.updateByPrimaryKeySelective(goodsStorage);
+ CommonGoods commonGoods = null;
+ if (goodsType == null) {
+ goodsType = Constant.SOURCE_TYPE_TAOBAO;
+ }
+
+ if (goodsType == Constant.SOURCE_TYPE_JD) {
+ // 浜笢
+ JDGoods jdGoods = JDApiUtil.queryGoodsDetail(auctionId);
+ if (jdGoods == null) {
+ jdGoods = JDApiUtil.getGoodsDetail(auctionId);
+ }
+ if (jdGoods == null) {
+ throw new UserGoodsStorageException(1, auctionId + "鍟嗗搧宸蹭笅鏋�");
+ }
+ commonGoods = CommonGoodsFactory.create(jdGoods);
+
+ } else if (goodsType == Constant.SOURCE_TYPE_PDD) {
+ // 鎷煎澶�
+ PDDGoodsDetail pddGoods = PinDuoDuoApiUtil.getGoodsDetail(auctionId);
+ if (pddGoods == null) {
+ throw new UserGoodsStorageException(1, auctionId + "鍟嗗搧宸蹭笅鏋�");
+ }
+ commonGoods = CommonGoodsFactory.create(pddGoods);
} else {
- goodsStorage = new UserGoodsStorage();
- goodsStorage.setUid(uid);;
- goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
- goodsStorage.setCommonGoods(commonGoods);
- goodsStorage.setCreateTime(new Date());
- goodsStorage.setUpdateTime(new Date());
- userGoodsStorageMapper.insertSelective(goodsStorage);
+ // 娣樺疂
+ try {
+ // 鑾峰彇鍟嗗搧璇︽儏
+ TaoBaoGoodsBrief goodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
+ commonGoods = CommonGoodsFactory.create(goodsBrief);
+ } catch (TaobaoGoodsDownException e) {
+ throw new UserGoodsStorageException(1, auctionId + "鍟嗗搧宸蹭笅鏋�");
+ }
}
+
+
+ if (commonGoods != null) {
+ try {
+ commonGoodsService.addOrUpdateCommonGoods(commonGoods);
+ } catch (CommonGoodsException e) {
+ e.printStackTrace();
+ throw new UserGoodsStorageException(1, "鍟嗗搧淇℃伅鏇存柊澶辫触");
+ }
+ Long cid = commonGoods.getId();
+
+ UserGoodsStorage goodsStorage = userGoodsStorageMapper.getByUidAndCid(uid, cid);
+
+ if (goodsStorage != null) {
+ // 鍒濆璇濈姸鎬�
+ goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
+ goodsStorage.setUpdateTime(new Date());
+ userGoodsStorageMapper.updateByPrimaryKeySelective(goodsStorage);
+ } else {
+ goodsStorage = new UserGoodsStorage();
+ goodsStorage.setUid(uid);;
+ goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
+ goodsStorage.setCommonGoods(commonGoods);
+ goodsStorage.setCreateTime(new Date());
+ goodsStorage.setUpdateTime(new Date());
+ userGoodsStorageMapper.insertSelective(goodsStorage);
+ }
+ }
}
}
@Override
- public JSONArray getMyStorage(int page, int pageSize, Long uid) throws UserGoodsStorageException {
-
- JSONArray array = new JSONArray();
+ @Transactional
+ public void addCommonGoods(Long uid, Set<Long> ids) throws UserGoodsStorageException {
- List<UserGoodsStorage> listStorage = listQueryByUid(page , pageSize, uid);
+ if (uid == null) {
+ throw new UserGoodsStorageException(1, "鐢ㄦ埛灏氭湭鐧诲綍");
+ }
+
+ if (ids == null || ids.size() == 0) {
+ throw new UserGoodsStorageException(1, "鍟嗗搧ID涓虹┖");
+ }
+
+ for (Long id : ids) {
+ CommonGoods commonGoods = commonGoodsService.selectByPrimaryKey(id);
+ if (commonGoods != null) {
+ UserGoodsStorage goodsStorage = userGoodsStorageMapper.getByUidAndCid(uid, id);
+
+ if (goodsStorage != null) {
+ // 鍒濆璇濈姸鎬�
+ goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
+ goodsStorage.setUpdateTime(new Date());
+ userGoodsStorageMapper.updateByPrimaryKeySelective(goodsStorage);
+ } else {
+ goodsStorage = new UserGoodsStorage();
+ goodsStorage.setUid(uid);;
+ goodsStorage.setState(UserGoodsStorage.STATE_NORMAL);
+ goodsStorage.setCommonGoods(commonGoods);
+ goodsStorage.setCreateTime(new Date());
+ goodsStorage.setUpdateTime(new Date());
+ userGoodsStorageMapper.insertSelective(goodsStorage);
+ }
+ }
+ }
+ }
+
+
+ @Override
+ public JSONArray getMyStorage(int page, int pageSize, Long uid, Integer source) throws UserGoodsStorageException {
+
+ JSONArray array = new JSONArray();
+
+ List<UserGoodsStorage> listStorage = listQueryByUid(page , pageSize, uid, source);
if (listStorage == null || listStorage.size() == 0) {
return array;
}
-
- List<Long> listGid = new ArrayList<Long>();
- for (UserGoodsStorage userGoodsStorage : listStorage) {
- CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
- if (commonGoods == null) {
- continue;
- }
- listGid.add(commonGoods.getGoodsId());
+ if (source == null) {
+ source = Constant.SOURCE_TYPE_TAOBAO;
}
- // API缃戠粶鎺ュ彛楠岃瘉鏄惁鍦ㄥ敭
List<TaoBaoGoodsBrief> listTaoKeGoods = null;
- try {
- listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);
- } catch (TaoKeApiException e) {
- e.printStackTrace();
- } catch (TaobaoGoodsDownException e) {
- e.printStackTrace();
- } catch (Exception e) {
- e.printStackTrace();
+ if (source == Constant.SOURCE_TYPE_TAOBAO) {
+ List<Long> listGid = new ArrayList<Long>();
+ for (UserGoodsStorage userGoodsStorage : listStorage) {
+ CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
+ if (commonGoods == null) {
+ continue;
+ }
+ listGid.add(commonGoods.getGoodsId());
+ }
+
+ // API缃戠粶鎺ュ彛楠岃瘉鏄惁鍦ㄥ敭
+ try {
+ listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);
+ } catch (TaoKeApiException e) {
+ e.printStackTrace();
+ } catch (TaobaoGoodsDownException e) {
+ e.printStackTrace();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
+
BigDecimal rate = manageService.getFanLiRate();
Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())
@@ -239,8 +300,13 @@
continue;
}
- if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 ) {
- int state = 1; // 榛樿鍋滃敭
+
+ int state = 0;
+ Integer goodsType = commonGoods.getGoodsType();
+
+ if (listTaoKeGoods != null && listTaoKeGoods.size() > 0
+ && goodsType != null && goodsType == Constant.SOURCE_TYPE_TAOBAO) {
+ state = 1; // 榛樿鍋滃敭
Long goodsId = commonGoods.getGoodsId();
for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {
Long auctionId = taoKeGoods.getAuctionId();
@@ -249,9 +315,8 @@
break;
}
}
- commonGoods.setState(state);
}
-
+ commonGoods.setState(state);
TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);
// 鍒ゆ柇鏄惁宸插垎浜�
@@ -276,26 +341,24 @@
@Override
- public boolean isExistStorage(Long uid, Long auctionId) {
+ public boolean isExistStorage(Long uid, Long auctionId, Integer goodType) {
boolean state = false;
if (uid != null && auctionId != null) {
- UserGoodsStorage userGoodsStorage = userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId);
+ UserGoodsStorage userGoodsStorage = userGoodsStorageMapper.getByUidAndAuctionId(uid, auctionId, goodType);
if (userGoodsStorage != null) {
state = true;
}
}
return state;
}
-
+
@Override
public JSONObject shareGoods(Long uid, List<Long> listStorageID)
throws UserGoodsStorageException, UserShareGoodsRecordException {
-
List<UserGoodsStorage> listStorage = userGoodsStorageMapper.listQueryByIds(listStorageID);
if (listStorage == null || listStorage.size() == 0) {
throw new UserGoodsStorageException(1, "閫夊搧搴撳晢鍝佷笉瀛樺湪");
}
-
List<UserGoodsStorage> listResult = new ArrayList<UserGoodsStorage>();
// 杩樺師椤哄簭 鐢ㄤ簬鍒跺浘
@@ -308,7 +371,6 @@
}
}
}
-
BigDecimal totalMoney = new BigDecimal(0.00);
List<TaoBaoGoodsBrief> listGoodsBrief = new ArrayList<TaoBaoGoodsBrief>();
@@ -323,17 +385,75 @@
totalMoney = MoneyBigDecimalUtil.add(totalMoney, money);
}
- String revenue = listGoodsBrief.size() + "涓晢鍝侀浼板垎浜閲戯細楼"+totalMoney;
-
- Map<String,Object> map = userShareGoodsRecordService.save(uid, ShareSourceTypeEnum.storage,
- null, listGoodsBrief);
+ ShareGoodsRecordDTO shareRecord = userShareGoodsRecordService.addRecordGoodsStorage(uid, listGoodsBrief, listStorageID);
+ FileUploadResult uploadResult = new FileUploadResult();
+ uploadResult.setUrl(shareRecord.getSharePictureUrl());
JSONObject data = new JSONObject();
- data.put("revenue", revenue);
- data.put("shareId", map.get("shareId"));
- data.put("shareImg", map.get("loadResult"));
+ data.put("revenue", listGoodsBrief.size() + "涓晢鍝侀浼板垎浜閲戯細楼"+totalMoney);
+ data.put("shareId", shareRecord.getRedisKey());
+ data.put("shareImg", uploadResult);
data.put("notifyDesc", configService.get("goods_share_multiple_notify"));
-
return data;
}
+
+
+
+ @Override
+ public JSONObject createShareV2(Long uid, List<Long> listStorageID) throws UserGoodsStorageException, UserShareGoodsRecordException {
+ List<UserGoodsStorage> listStorage = userGoodsStorageMapper.listQueryByIds(listStorageID);
+ if (listStorage == null || listStorage.size() == 0) {
+ throw new UserGoodsStorageException(1, "閫夊搧搴撳晢鍝佷笉瀛樺湪");
+ }
+
+ List<UserGoodsStorage> listResult = new ArrayList<UserGoodsStorage>();
+ // 杩樺師椤哄簭 鐢ㄤ簬鍒跺浘
+ for (Long sid: listStorageID) {
+ for (UserGoodsStorage torage: listStorage) {
+ Long id = torage.getId();
+ if (sid == id || sid.equals(id)) {
+ listResult.add(torage);
+ break;
+ }
+ }
+ }
+
+ BigDecimal totalMoney = new BigDecimal(0.00);
+ List<CommonGoods> listCommonGoods = new ArrayList<CommonGoods>();
+
+ Integer goodsType = null;
+ BigDecimal rate = hongBaoManageService.getShareRate();
+ for (UserGoodsStorage userGoodsStorage: listResult) {
+ CommonGoods commonGoods = userGoodsStorage.getCommonGoods();
+ BigDecimal money = CommonGoodsUtil.getCommission(commonGoods, rate);
+ totalMoney = MoneyBigDecimalUtil.add(totalMoney, money);
+ listCommonGoods.add(commonGoods);
+
+ if (goodsType == null) {
+ goodsType = commonGoods.getGoodsType();
+ }
+ }
+
+ ShareGoodsRecordDTO shareRecord = userShareGoodsRecordService.addRecordGoodsStorageV2(uid, listCommonGoods, listStorageID);
+ FileUploadResult uploadResult = new FileUploadResult();
+ uploadResult.setUrl(shareRecord.getSharePictureUrl());
+
+ JSONObject data = new JSONObject();
+ data.put("revenue", listCommonGoods.size() + "涓晢鍝侀浼板垎浜閲戯細楼"+totalMoney);
+ data.put("shareId", shareRecord.getRedisKey());
+ data.put("shareImg", uploadResult);
+
+ // 鎻愮ず璇笉鍚�
+ if (goodsType == Constant.SOURCE_TYPE_JD) {
+ // 浜笢
+ data.put("notifyDesc", configService.get("goods_share_notify_jd"));
+ } else if (goodsType == Constant.SOURCE_TYPE_PDD) {
+ // 鎷煎澶�
+ data.put("notifyDesc", configService.get("goods_share_notify_pdd"));
+ } else {
+ data.put("notifyDesc", configService.get("goods_share_multiple_notify"));
+ }
+ return data;
+ }
+
}
--
Gitblit v1.8.0