From f066298a11b302e6b19c7b5f589ccc3102dccf46 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期六, 22 十二月 2018 10:44:55 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java | 132 ++++++++++++++++++------------------------- 1 files changed, 55 insertions(+), 77 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java index 4d18107..9192eb4 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserShareGoodsRecordServiceImpl.java @@ -16,6 +16,7 @@ import org.springframework.core.task.TaskExecutor; import org.springframework.stereotype.Service; +import org.yeshi.utils.DateUtil; import org.yeshi.utils.HttpUtil; import org.yeshi.utils.JsonUtil; import org.yeshi.utils.QRCodeUtil; @@ -31,7 +32,6 @@ import com.yeshi.fanli.entity.bus.share.UserShareGoodsGroup; import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord; import com.yeshi.fanli.entity.bus.share.UserShareGoodsRecord.ShareSourceTypeEnum; -import com.yeshi.fanli.entity.bus.user.UserGoodsStorage; import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.entity.goods.CommonGoods; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; @@ -515,8 +515,7 @@ Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); - Map<String, String> map = hongBaoManageService.convertMap(); - String proportion = map.get("hongbao_goods_proportion"); + BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis()); for (UserShareGoodsGroup goodsGroup : list) { CommonGoods commonGoods = goodsGroup.getCommonGoods(); @@ -539,12 +538,20 @@ TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods); + // 浠婃棩娴忚璁板綍澶勭悊 + Date date = new Date(); + Date browseTime = goodsGroup.getBrowseTime(); + if (!DateUtil.isSameDay(browseTime, date)) { + goodsGroup.setTodayBrowse(0); // 涓嶆槸鍚屼竴澶╂祻瑙堣褰曡缃�0 + } + + JSONObject dataObject = new JSONObject(); dataObject.put("todayBrowse",goodsGroup.getTodayBrowse() ); dataObject.put("totalBrowse",goodsGroup.getTotalBrowse() ); dataObject.put("totalOrder", goodsGroup.getTotalOrder()); dataObject.put("totalMoney", "楼"+goodsGroup.getTotalMoney()); - dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, null))); + dataObject.put("goods", gson.toJson(TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate+"", null))); array.add(dataObject); } @@ -565,83 +572,68 @@ @Override public JSONObject getGoodsGroupDetail(Long recordId) throws UserShareGoodsRecordException { - List<CommonGoods> listUpadteCommonGoods = new ArrayList<CommonGoods>(); - JSONArray array = new JSONArray(); List<UserShareGoodsGroup> list = userShareGoodsGroupService.listByRecordId(recordId); + if (list != null && list.size() > 0) { - Date nowDate = new Date(); - long nh = 1000 * 60 * 60; - long nd = 1000 * 24 * 60 * 60; - - Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) - .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); - - - Map<String, String> map = hongBaoManageService.convertMap(); - String proportion = map.get("hongbao_goods_proportion"); - - for (UserShareGoodsGroup userShareGoodsGroup : list) { - CommonGoods commonGoods = userShareGoodsGroup.getCommonGoods(); + List<Long> listGid = new ArrayList<Long>(); + for (UserShareGoodsGroup goodsGroup : list) { + CommonGoods commonGoods = goodsGroup.getCommonGoods(); if (commonGoods == null) { continue; } - - TaoBaoGoodsBrief goodsBrief = null; - // 鏇存柊涓�涓皬鏃朵箣鍐呯殑鍟嗗搧涓嶅啀鏇存柊 - Integer goodsState = commonGoods.getState(); - // 鐘舵�佹湭涓嬫灦鏃惰繘琛屾洿鏂� - if (goodsState != null && (goodsState != 1 || !goodsState.equals(1))) { - Date updateTime = commonGoods.getUpdateTime(); - if (updateTime != null) { - - // 璁$畻宸灏戝皬鏃� - long diff = nowDate.getTime() - updateTime.getTime(); - long day = diff / nd; - long hour = diff % nd / nh; - if (hour > 1 || day > 0 ) { - try { - if (commonGoods.getGoodsType() == CommonGoods.GOODS_TYPE_TB) { - goodsBrief = redisManager.getTaoBaoGoodsBrief(commonGoods.getGoodsId()); - - goodsState = 0; - goodsBrief.setState(goodsState); // 鍦ㄥ敭 - - CommonGoods upadeteCommonGoods = CommonGoodsFactory.create(goodsBrief); - upadeteCommonGoods.setState(goodsState); - upadeteCommonGoods.setId(commonGoods.getId()); - listUpadteCommonGoods.add(upadeteCommonGoods); - } - } catch (TaobaoGoodsDownException e) { - // 宸蹭笅鏋� - goodsState = 1; - commonGoods.setState(goodsState); - listUpadteCommonGoods.add(commonGoods); - e.printStackTrace(); - } + listGid.add(commonGoods.getGoodsId()); + } + + // 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(); + } + + + Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder()) + .excludeFieldsWithoutExposeAnnotation().setDateFormat("yyyy-MM-dd").create(); + + BigDecimal shareRate = hongBaoManageService.getShareRate(java.lang.System.currentTimeMillis()); + + for (UserShareGoodsGroup goodsGroup : list) { + CommonGoods commonGoods = goodsGroup.getCommonGoods(); + if (commonGoods == null) { + continue; + } + + if (listTaoKeGoods != null && listTaoKeGoods.size() > 0 ) { + int state = 1; // 榛樿鍋滃敭 + Long goodsId = commonGoods.getGoodsId(); + for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) { + Long auctionId = taoKeGoods.getAuctionId(); + if (goodsId == auctionId || goodsId.equals(auctionId)) { + state = 0; // 鍦ㄥ敭 + break; } } + commonGoods.setState(state); } - - if (goodsBrief == null) { - goodsBrief = TaoBaoUtil.convert(commonGoods); - } + + TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods); if (goodsBrief.getCouponLeftCount() < 1 || StringUtil.isNullOrEmpty(goodsBrief.getCouponInfo())) { goodsBrief.setState(1); // 宸叉姠鍏� } - // 鏀瑰彉鍥剧墖灏哄 - String pictUrl = goodsBrief.getPictUrl(); - if (!StringUtil.isNullOrEmpty(pictUrl) && !pictUrl.contains("320x320")) { - goodsBrief.setPictUrl(TbImgUtil.getTBSize320Img(pictUrl)); - } - - TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, proportion, null); + TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief, shareRate +"", null); array.add(gson.toJson(taoBaoGoodsBriefExtra)); } + } String title = ""; @@ -654,20 +646,6 @@ data.put("title", title); data.put("count", list.size()); data.put("result_list", array); - - if (listUpadteCommonGoods.size() > 0) { - executor.execute(new Runnable() { - @Override - public void run() { - try { - // 鏇存柊绠�鐗堜俊鎭� - commonGoodsService.updateBatchCommonGoods(listUpadteCommonGoods); - } catch (Exception e) { - e.printStackTrace(); - } - } - }); - } return data; } -- Gitblit v1.8.0