From 0cf8c0bf5649b0b7269f78f6eae7c09cffea75cd Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期二, 12 十一月 2019 16:01:22 +0800 Subject: [PATCH] 券退回消息处理 --- fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareStorageControllerV2.java | 101 +++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 99 insertions(+), 2 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareStorageControllerV2.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareStorageControllerV2.java index cf84f9d..d91ed8a 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareStorageControllerV2.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v2/ShareStorageControllerV2.java @@ -17,17 +17,20 @@ import com.google.gson.Gson; import com.google.gson.GsonBuilder; import com.google.gson.reflect.TypeToken; +import com.yeshi.fanli.dto.ConfigParamsDTO; import com.yeshi.fanli.entity.accept.AcceptData; import com.yeshi.fanli.entity.bus.user.UserGoodsStorage; import com.yeshi.fanli.entity.goods.CommonGoods; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; +import com.yeshi.fanli.exception.share.UserShareGoodsRecordException; import com.yeshi.fanli.exception.taobao.TaoKeApiException; import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException; import com.yeshi.fanli.exception.user.UserGoodsStorageException; import com.yeshi.fanli.service.inter.config.ConfigService; -import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService; +import com.yeshi.fanli.service.inter.order.config.HongBaoManageService; import com.yeshi.fanli.service.inter.user.UserGoodsStorageService; import com.yeshi.fanli.util.Constant; +import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; import com.yeshi.fanli.vo.goods.GoodsDetailVO; @@ -54,6 +57,51 @@ @Resource private UserGoodsStorageService userGoodsStorageService; + + + /** + * 鍗曚釜鍟嗗搧鍔犲叆閫夊搧搴� + * + * @param callback + * @param storageIds + * id鏁扮粍 + * @param out + */ + @RequestMapping(value = "accordtorage", method = RequestMethod.POST) + public void accordtorage(AcceptData acceptData, Long uid, long id, Integer goodsType, PrintWriter out) { + + if (uid == null) { + out.print(JsonUtil.loadFalseResult("鐢ㄦ埛鏈櫥褰�")); + return; + } + + if (goodsType == null) { + goodsType = Constant.SOURCE_TYPE_TAOBAO; + } + + try { + UserGoodsStorage userGoodsStorage = userGoodsStorageService.getByUidAndAuctionId(uid, id, goodsType); + boolean storageState = false; + if (userGoodsStorage != null) { + // 鍙栨秷鍔犲叆閫夊搧搴� + userGoodsStorageService.deleteByPrimaryKey(userGoodsStorage.getId()); + } else { + // 鍔犲叆閫夊搧搴� + Set<Long> set = new HashSet<Long>(); + set.add(id); + userGoodsStorageService.save(uid, set, goodsType); + storageState = true; + } + + JSONObject data = new JSONObject(); + data.put("storageState", storageState); + out.print(JsonUtil.loadTrueResult(data)); + } catch (Exception e) { + out.print(JsonUtil.loadFalseResult("鎿嶄綔澶辫触")); + e.printStackTrace(); + } + } + /** * 鎵归噺娣诲姞閫夊搧搴� * @@ -156,6 +204,7 @@ BigDecimal fanLiRate = hongBaoManageService.getFanLiRate(); BigDecimal shareRate = hongBaoManageService.getShareRate(); + ConfigParamsDTO paramsDTO = new ConfigParamsDTO(fanLiRate, shareRate, Constant.MAX_REWARD_RATE); for (UserGoodsStorage userGoodsStorage : listStorage) { CommonGoods commonGoods = userGoodsStorage.getCommonGoods(); @@ -188,7 +237,7 @@ } } - GoodsDetailVO detailVO = GoodsDetailVOFactory.convertCommonGoods(commonGoods, null, fanLiRate, shareRate); + GoodsDetailVO detailVO = GoodsDetailVOFactory.convertCommonGoods(commonGoods, paramsDTO); detailVO.setId(commonGoods.getId()); JSONObject dataObject = new JSONObject(); @@ -203,4 +252,52 @@ out.print(JsonUtil.loadTrueResult(data)); } + + /** + * 鍒嗕韩鍟嗗搧杩斿洖浜岀淮鐮佸浘鐗� + * + * @param callback + * @param storageIds + * id鏁扮粍 + * @param out + */ + @RequestMapping(value = "createShare", method = RequestMethod.POST) + public void createShare(AcceptData acceptData, Long uid, String storageIds, PrintWriter out) { + + if (StringUtil.isNullOrEmpty(storageIds)) { + out.print(JsonUtil.loadFalseResult("鍒嗕韩鍟嗗搧涓嶈兘涓虹┖")); + return; + } + + if (uid == null) { + out.print(JsonUtil.loadFalseResult("鐢ㄦ埛鏈櫥褰�")); + return; + } + + try { + Gson gson = new Gson(); + List<Long> listStorageID = gson.fromJson(storageIds, new TypeToken<ArrayList<Long>>() {}.getType()); + if (listStorageID == null || listStorageID.size() < 9) { + out.print(JsonUtil.loadFalseResult("鍒嗕韩鍟嗗搧鏁伴噺涓嶈冻")); + return; + } + + if (listStorageID.size() != 9) { + out.print(JsonUtil.loadFalseResult("鍒嗕韩鍟嗗搧鏁伴噺鍙兘鏄�9涓�")); + return; + } + + JSONObject data = userGoodsStorageService.createShareV2(uid, listStorageID); + out.print(JsonUtil.loadTrueResult(data)); + } catch (UserGoodsStorageException e) { + out.print(JsonUtil.loadFalseResult("鍒嗕韩澶辫触")); + e.printStackTrace(); + } catch (UserShareGoodsRecordException e) { + out.print(JsonUtil.loadFalseResult("鍒嗕韩澶辫触")); + e.printStackTrace(); + } catch (Exception e) { + out.print(JsonUtil.loadFalseResult("鍒嗕韩澶辫触")); + e.printStackTrace(); + } + } } -- Gitblit v1.8.0