From a5bc9c4e52f98032b287a42fd243c2ffcb7d58f6 Mon Sep 17 00:00:00 2001 From: yujian <yujian@163.com> Date: 星期一, 13 四月 2020 09:52:16 +0800 Subject: [PATCH] 消息 --- fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java | 693 +++++++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 613 insertions(+), 80 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java index 8520dd0..e21b765 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java @@ -17,16 +17,21 @@ import org.yeshi.utils.entity.DateInfo; import org.yeshi.utils.taobao.TbImgUtil; +import com.aliyun.openservices.ons.api.Message; +import com.aliyun.openservices.ons.api.Producer; import com.yeshi.fanli.dao.mybatis.order.CommonOrderGoodsMapper; import com.yeshi.fanli.dao.mybatis.order.CommonOrderMapper; import com.yeshi.fanli.dao.mybatis.order.CommonOrderTradeIdMapMapper; import com.yeshi.fanli.dao.mybatis.taobao.TaoBaoWeiQuanOrderMapper; +import com.yeshi.fanli.dto.mq.order.OrderTopicTagEnum; +import com.yeshi.fanli.dto.mq.order.body.OrderConfirmMQMsg; import com.yeshi.fanli.dto.order.CommonOrderAddResultDTO; import com.yeshi.fanli.dto.pdd.PDDGoodsDetail; import com.yeshi.fanli.entity.accept.AcceptData; import com.yeshi.fanli.entity.bus.user.HongBaoV2; import com.yeshi.fanli.entity.bus.user.UserInfo; import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord; +import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum; import com.yeshi.fanli.entity.goods.CommonGoods; import com.yeshi.fanli.entity.jd.JDGoods; import com.yeshi.fanli.entity.jd.JDOrder; @@ -38,6 +43,7 @@ import com.yeshi.fanli.entity.order.HongBaoOrder; import com.yeshi.fanli.entity.order.InviteOrderSubsidy; import com.yeshi.fanli.entity.pdd.PDDOrder; +import com.yeshi.fanli.entity.system.ConfigKeyEnum; import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; import com.yeshi.fanli.entity.taobao.TaoBaoOrder; @@ -58,7 +64,9 @@ import com.yeshi.fanli.service.inter.user.UserInfoService; import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService; import com.yeshi.fanli.service.inter.user.UserSystemCouponService; +import com.yeshi.fanli.service.inter.user.invite.UserInviteService; import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService; +import com.yeshi.fanli.service.manger.user.UserLevelManager; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.MoneyBigDecimalUtil; import com.yeshi.fanli.util.StringUtil; @@ -70,12 +78,15 @@ import com.yeshi.fanli.util.jd.JDApiUtil; import com.yeshi.fanli.util.jd.JDUtil; import com.yeshi.fanli.util.pinduoduo.PinDuoDuoApiUtil; -import com.yeshi.fanli.util.taobao.TaoBaoOrderUtil; +import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory; +import com.yeshi.fanli.util.rocketmq.MQTopicName; import com.yeshi.fanli.util.taobao.TaoBaoUtil; import com.yeshi.fanli.util.taobao.TaoKeApiUtil; +import com.yeshi.fanli.util.user.UserLevelUtil; import com.yeshi.fanli.vo.msg.ClientTextStyleVO; import com.yeshi.fanli.vo.order.CommonOrderGoodsVO; import com.yeshi.fanli.vo.order.CommonOrderVO; +import com.yeshi.fanli.vo.order.HongBaoCountVO; import com.yeshi.fanli.vo.order.OrderCountVO; import com.yeshi.fanli.vo.order.WeiQuanInfo; @@ -128,6 +139,15 @@ @Resource private UserInfoService userInfoService; + + @Resource + private UserInviteService userInviteService; + + @Resource + private UserLevelManager userLevelManager; + + @Resource(name = "producer") + private Producer orderProducer; // 濂栧姳璁㈠崟鍥剧墖 public final static String PIC_REWARD = "http://img.flqapp.com/resource/order/order_state_reward.png"; @@ -210,7 +230,11 @@ } // 鏁版嵁鍔犲伐閲嶆柊缁勭粐 - orderVOFactory(acceptData, listOrder, listGoods, uid); + if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + orderVOFactory21(acceptData, listOrder, listGoods, uid); + } else { + orderVOFactory(acceptData, listOrder, listGoods, uid); + } return listOrder; } @@ -290,13 +314,14 @@ Date august = TimeUtil.parse("2019-08-01"); // 褰撳墠鐢ㄦ埛鏄惁VIP - boolean vip = userVIPInfoService.isVIP(uid); + boolean vip = userInviteService.verifyVIP(uid); + // 鏄惁瀛樺湪濂栧姳鍒� boolean hasRewardCoupon = userSystemCouponService.getValidRebateCoupon(uid); - for (CommonOrderVO order : listOrder) { String orderNo = order.getOrderNo(); Integer sourceType = order.getSourceType(); + Integer hongBaoType = order.getHongBaoType(); // 鍟嗗搧淇℃伅缁勫悎 for (CommonOrderVO commonOrder : listGoods) { @@ -327,7 +352,6 @@ } commonGoodsVO.setActualPay("浠樻閲戦锛毬�" + totalSettlement); - Integer hongBaoType = order.getHongBaoType(); // 閭�璇疯鍗曚俊鎭繚鎶� if (HongBaoV2.TYPE_YAOQING == hongBaoType || HongBaoV2.TYPE_YIJI == hongBaoType || HongBaoV2.TYPE_ERJI == hongBaoType || HongBaoV2.TYPE_SHARE_YIJI == hongBaoType @@ -356,10 +380,8 @@ } Date thirdCreateTime = order.getThirdCreateTime(); - if (thirdCreateTime != null) { - order.setDownTime("涓嬪崟鏃堕棿锛�" + format.format(thirdCreateTime)); - order.setObtainTime(thirdCreateTime.getTime()); - } + order.setDownTime("涓嬪崟鏃堕棿锛�" + format.format(thirdCreateTime)); + order.setObtainTime(thirdCreateTime.getTime()); Date settleTime = order.getSettleTime(); if (settleTime != null) { @@ -446,7 +468,6 @@ // 璁㈠崟鏍囪瘑 List<String> signList = new ArrayList<String>(); /* 璁㈠崟杩斿埄绫诲瀷 杞崲 */ - Integer hongBaoType = order.getHongBaoType(); if (HongBaoV2.TYPE_ZIGOU == hongBaoType || 2 == hongBaoType) { // 鑷喘 hongbaoInfo = "杩斿埄"; @@ -848,7 +869,9 @@ return commonOrderMapper.countUserOrderToApp(uid, type, startTime, endTime, day, source, state, stateOrder); } - private BigDecimal getWeiQuanMoney(List<TaoBaoWeiQuanOrder> listWQ, int sourceType, Long uid) { + + @Override + public BigDecimal getWeiQuanMoney(List<TaoBaoWeiQuanOrder> listWQ, int sourceType, Long uid) { BigDecimal weiQuanMoney = new BigDecimal(0); if (listWQ != null && listWQ.size() > 0) { for (TaoBaoWeiQuanOrder weiQuanOrder : listWQ) { @@ -902,11 +925,20 @@ wholeOrderState = CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO; for (TaoBaoOrder taoBaoOrder : taoBaoOrders) { - CommonOrder newCommonOrder = TaoBaoOrderUtil.convert(taoBaoOrder); + CommonOrder newCommonOrder = CommonOrderFactory.create(taoBaoOrder); CommonOrderGoods cog = new CommonOrderGoods(); - cog.setGoodsId(taoBaoOrder.getAuctionId() + ""); - cog.setGoodsType(Constant.SOURCE_TYPE_TAOBAO); - newCommonOrder.setCommonOrderGoods(cog); + + if ("楗夸簡涔�".equalsIgnoreCase(taoBaoOrder.getOrderType())) { + cog.setGoodsId(taoBaoOrder.getTradeId() + ""); + cog.setGoodsType(Constant.SOURCE_TYPE_ELME); + cog.setPicture("http://img.flqapp.com/resource/goods/elme_picture_demo.png"); + cog.setTitle(taoBaoOrder.getTitle()); + newCommonOrder.setCommonOrderGoods(cog); + } else { + cog.setGoodsId(taoBaoOrder.getAuctionId() + ""); + cog.setGoodsType(Constant.SOURCE_TYPE_TAOBAO); + newCommonOrder.setCommonOrderGoods(cog); + } newCommonOrder.setStateWholeOrder(wholeOrderState); // 璁㈠崟鍟嗗搧鎻掑叆 List<CommonOrderGoods> commonGoodsList = commonOrderGoodsMapper.listByGoodsIdAndGoodsType(cog.getGoodsId(), @@ -914,22 +946,25 @@ if (commonGoodsList.size() <= 0)// 涓嶅瓨鍦ㄥ氨鎻掑叆鍟嗗搧 { TaoBaoGoodsBrief taoBaoGoods = null; - try { - taoBaoGoods = TaoKeApiUtil.getSimpleGoodsInfo(taoBaoOrder.getAuctionId()); - LogManager.getLogger(LogType.taobaoGoods).info(String.format("璁㈠崟鍟嗗搧鍒嗙被:%s#%s#%s", - taoBaoGoods.getAuctionId(), taoBaoGoods.getRootCategoryName(), taoBaoGoods.getLeafName())); - } catch (TaobaoGoodsDownException e) { - e.printStackTrace(); - LogHelper.errorDetailInfo(e, "AUCTIONID:" + taoBaoOrder.getAuctionId(), ""); + if (cog.getGoodsType() != Constant.SOURCE_TYPE_ELME) { try { - taoBaoGoods = TaoBaoUtil.getSimpleGoodsBrief(taoBaoOrder.getAuctionId()); - // 璁板綍鍟嗗搧鍒嗙被 + taoBaoGoods = TaoKeApiUtil.getSimpleGoodsInfo(taoBaoOrder.getAuctionId()); + LogManager.getLogger(LogType.taobaoGoods) + .info(String.format("璁㈠崟鍟嗗搧鍒嗙被:%s#%s#%s", taoBaoGoods.getAuctionId(), + taoBaoGoods.getRootCategoryName(), taoBaoGoods.getLeafName())); + } catch (TaobaoGoodsDownException e) { + e.printStackTrace(); + LogHelper.errorDetailInfo(e, "AUCTIONID:" + taoBaoOrder.getAuctionId(), ""); + try { + taoBaoGoods = TaoBaoUtil.getSimpleGoodsBrief(taoBaoOrder.getAuctionId()); + // 璁板綍鍟嗗搧鍒嗙被 - } catch (Exception e1) { - CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType( - taoBaoOrder.getAuctionId(), Constant.SOURCE_TYPE_TAOBAO); - if (commonGoods != null) - taoBaoGoods = TaoBaoUtil.convert(commonGoods); + } catch (Exception e1) { + CommonGoods commonGoods = commonGoodsService.getCommonGoodsByGoodsIdAndGoodsType( + taoBaoOrder.getAuctionId(), Constant.SOURCE_TYPE_TAOBAO); + if (commonGoods != null) + taoBaoGoods = TaoBaoUtil.convert(commonGoods); + } } } if (taoBaoGoods != null) { @@ -942,6 +977,7 @@ newCommonOrder.setUserInfo(new UserInfo(uid)); commonOrderList.add(addCommonOrder(newCommonOrder)); } + addConfirmMQMsg(commonOrderList); return commonOrderList; } @@ -992,7 +1028,53 @@ newCommonOrder.setUserInfo(new UserInfo(uid)); commonOrderList.add(addCommonOrder(newCommonOrder)); } + addConfirmMQMsg(commonOrderList); return commonOrderList; + } + + private void addConfirmMQMsg(List<CommonOrderAddResultDTO> resultList) { + + // 璁㈠崟鏄惁鏂板鎴栬�呮洿鏂拌繃 + boolean isAddOrUpdate = false; + for (CommonOrderAddResultDTO dto : resultList) + if (dto.getType() == CommonOrderAddResultDTO.TYPE_ADD + || dto.getType() == CommonOrderAddResultDTO.TYPE_UPDATE) { + isAddOrUpdate = true; + break; + } + boolean hasSettleOrder = false; + // 鏌ヨ鏄惁鏈夌粨绠楃殑璁㈠崟 + if (isAddOrUpdate) { + for (CommonOrderAddResultDTO dto : resultList) { + if (dto.getCommonOrder().getSettleTime() != null && dto.getCommonOrder().getSettlement() != null) { + hasSettleOrder = true; + break; + } + } + } + // 鏈夌粨绠楃殑璁㈠崟 + if (hasSettleOrder) { + if (!Constant.IS_TEST) { + // 缁熻缁撶畻閲戦 + BigDecimal settlement = new BigDecimal("0"); + CommonOrder firstOrder = null; + for (CommonOrderAddResultDTO dto : resultList) + if (dto.getCommonOrder().getSettlement() != null) { + settlement = settlement.add(dto.getCommonOrder().getSettlement()); + if (firstOrder == null) + firstOrder = dto.getCommonOrder(); + } + if (firstOrder != null) { + Date placeDate = firstOrder.getThirdCreateTime(); + OrderConfirmMQMsg mqMsg = new OrderConfirmMQMsg(firstOrder.getOrderNo(), firstOrder.getSourceType(), + settlement, firstOrder.getUserInfo().getId(), placeDate, new Date()); + Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.orderConfirm, + mqMsg); + orderProducer.send(msg); + } + } + } + } @Transactional(rollbackFor = Exception.class) @@ -1057,6 +1139,7 @@ newCommonOrder.setUserInfo(new UserInfo(uid)); commonOrderList.add(addCommonOrder(newCommonOrder)); } + addConfirmMQMsg(commonOrderList); return commonOrderList; } @@ -1105,10 +1188,11 @@ if (oldCommonOrder == null)// 鏂板 { commonOrder.setCreateTime(new Date()); + UserLevelEnum userLevel = userLevelManager.getUserLevel(commonOrder.getUserInfo().getId(), + commonOrder.getThirdCreateTime()); // 鏌ヨ鏄惁涓簐ip - boolean isVIP = userVIPInfoService.isVIP(commonOrder.getUserInfo().getId()); - if (isVIP) - commonOrder.setUrank(100);// VIP璁㈠崟 + if (userLevel != null) + commonOrder.setUrank(userLevel.getOrderRank());// VIP璁㈠崟 else { UserInfo user = userInfoService.selectAvailableByPrimaryKey(commonOrder.getUserInfo().getId()); if (user != null) @@ -1240,7 +1324,7 @@ @Override public List<CommonOrderVO> listQuery(long start, int count, Integer keyType, String key, Integer state, Integer type, Integer orderState, String startTime, String endTime, Integer source, List<Long> listShopId, - List<Long> listGoodsId, Date minTime, BigDecimal money,BigDecimal payment) throws CommonOrderException { + List<Long> listGoodsId, Date minTime, BigDecimal money, BigDecimal payment) throws CommonOrderException { List<CommonOrderVO> list = null; @@ -1249,7 +1333,7 @@ startTime, endTime, source, payment); } else { list = commonOrderMapper.listQuery(start, count, keyType, key, state, type, orderState, startTime, endTime, - source, listShopId, listGoodsId, minTime, money,payment); + source, listShopId, listGoodsId, minTime, money, payment); } if (list == null) { @@ -1436,7 +1520,7 @@ @Override public long countQuery(Integer keyType, String key, Integer state, Integer type, Integer orderState, String startTime, String endTime, Integer source, List<Long> listShopId, List<Long> listGoodsId, - Date minTime, BigDecimal money,BigDecimal payment) throws CommonOrderException { + Date minTime, BigDecimal money, BigDecimal payment) throws CommonOrderException { if (StringUtil.isNullOrEmpty(key) || keyType == 1) {// 鎼滅储妗嗘棤鍊兼垨鑰呮寜璁㈠崟鍙锋悳绱㈡椂閮藉彧鎼滅储涓昏鍗� return commonOrderMapper.countQueryWithNoChild(keyType, key, state, type, orderState, startTime, endTime, source, payment); @@ -1673,7 +1757,13 @@ } @Override - public List<CommonOrderVO> searchOrderByUid(int page, int size, Long uid, List<ESOrder> list) throws Exception { + public List<CommonOrder> getMinSettleTimeAndUid() { + return commonOrderMapper.getMinSettleTimeAndUid(); + } + + @Override + public List<CommonOrderVO> searchOrderByUid(AcceptData acceptData, int page, int size, Long uid, List<ESOrder> list) + throws Exception { List<CommonOrderVO> listVO = commonOrderMapper.searchOrderByUid((page - 1) * size, size, uid, list); // 璁㈠崟淇℃伅涓虹┖ @@ -1690,7 +1780,11 @@ } // 鏁版嵁鍔犲伐閲嶆柊缁勭粐 - orderVOFactoryNew(listVO, listGoods, uid); + if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + orderVOFactory21(acceptData, listVO, listGoods, uid); + } else { + orderVOFactory(acceptData, listVO, listGoods, uid); + } return listVO; } @@ -1703,8 +1797,8 @@ * @param listGoods * @param uid */ - private void orderVOFactoryNew(List<CommonOrderVO> listOrder, List<CommonOrderVO> listGoods, Long uid) - throws Exception { + private void orderVOFactoryNew(AcceptData acceptData, List<CommonOrderVO> listOrder, List<CommonOrderVO> listGoods, + Long uid) throws Exception { List<String> listTB = new ArrayList<String>(); List<String> listJD = new ArrayList<String>(); List<String> listPDD = new ArrayList<String>(); @@ -1745,23 +1839,19 @@ || order.getHongBaoType() == HongBaoV2.TYPE_SHARE_ERJI) needSelectVIPUidList.add(Long.parseLong(order.getUserId())); } - Map<Long, Boolean> vipUserMap = userVIPInfoService.listByUids(needSelectVIPUidList); - // 璁剧疆鏄惁涓簐ip璁㈠崟 for (CommonOrderVO order : listOrder) { if (order.getHongBaoType() == HongBaoV2.TYPE_YIJI || order.getHongBaoType() == HongBaoV2.TYPE_ERJI || order.getHongBaoType() == HongBaoV2.TYPE_SHARE_ERJI || order.getHongBaoType() == HongBaoV2.TYPE_SHARE_ERJI) { - if (vipUserMap.get(Long.parseLong(order.getUserId())) != null - && vipUserMap.get(Long.parseLong(order.getUserId())) == true) - order.setVipOrder(true); - else - order.setVipOrder(false); - } else - order.setVipOrder(false); - - if (order.isVipOrder()) - order.setVipOrderDesc("璁㈠崟鏉ユ簮锛氱敱瓒呯骇浼氬憳鐨勭矇涓濅骇鐢�"); + Integer urank = order.getUrank(); + if (urank != null) { + String levelName = UserLevelUtil.getLevelName(urank); + if (!StringUtil.isNullOrEmpty(levelName)) { + order.setOrderDesc("璁㈠崟鏉ユ簮锛�" + levelName); + } + } + } } SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm"); @@ -1769,14 +1859,15 @@ // 2019.8.1寮�濮嬭繑鍥炵淮鏉冧俊鎭� Date august = TimeUtil.parse("2019-08-01"); - // 褰撳墠鐢ㄦ埛鏄惁VIP - boolean vip = userVIPInfoService.isVIP(uid); + // 褰撳墠鐢ㄦ埛鏄惁鍙互浣跨敤濂栧姳鍒� + boolean isvip = userInviteService.verifyVIP(uid); // 鏄惁瀛樺湪濂栧姳鍒� boolean hasRewardCoupon = userSystemCouponService.getValidRebateCoupon(uid); for (CommonOrderVO order : listOrder) { String orderNo = order.getOrderNo(); Integer sourceType = order.getSourceType(); + Integer hongBaoType = order.getHongBaoType(); // 鍟嗗搧淇℃伅缁勫悎 for (CommonOrderVO commonOrder : listGoods) { @@ -1788,7 +1879,9 @@ if (sourceType.equals(commonOrder.getSourceType()) && orderNo.equals(commonOrder.getOrderNo())) { CommonOrderGoodsVO commonGoodsVO = new CommonOrderGoodsVO(); PropertyUtils.copyProperties(commonGoodsVO, goods); - commonGoodsVO.setGoodsType(sourceType); + if (commonGoodsVO.getGoodsType() == null) { + commonGoodsVO.setGoodsType(sourceType); + } // 娣樺疂鍟嗗搧鍥剧墖澶勭悊 String picture = commonGoodsVO.getPicture(); @@ -1807,7 +1900,6 @@ } commonGoodsVO.setActualPay("浠樻閲戦锛毬�" + totalSettlement); - Integer hongBaoType = order.getHongBaoType(); // 閭�璇疯鍗曚俊鎭繚鎶� if (HongBaoV2.TYPE_YAOQING == hongBaoType || HongBaoV2.TYPE_YIJI == hongBaoType || HongBaoV2.TYPE_ERJI == hongBaoType || HongBaoV2.TYPE_SHARE_YIJI == hongBaoType @@ -1821,18 +1913,32 @@ } // 璁㈠崟绫诲瀷涓虹┖鏃� 宸插晢鍝佺被涓哄噯 - Integer orderType = order.getOrderType(); - if (orderType == null) { - String shopType = commonGoodsVO.getShopType(); - if (CommonOrderGoodsVO.TYPE_TAOBAO.equalsIgnoreCase(shopType)) { - order.setOrderType(1); - } else if (CommonOrderGoodsVO.TYPE_TMALL.equalsIgnoreCase(shopType)) { - order.setOrderType(2); - } + String shopType = commonGoodsVO.getShopType(); + if (CommonOrderGoodsVO.TYPE_TAOBAO.equalsIgnoreCase(shopType)) { + order.setOrderType(1); + } else if (CommonOrderGoodsVO.TYPE_TMALL.equalsIgnoreCase(shopType)) { + order.setOrderType(2); + } + + Integer goodsType = commonGoodsVO.getGoodsType(); + if (goodsType != null & goodsType == Constant.SOURCE_TYPE_ELME) { + order.setOrderType(Constant.SOURCE_TYPE_ELME); // 楗夸簡涔堣鍗� } order.getListOrderGoods().add(commonGoodsVO); } + } + + // 璁㈠崟绫诲瀷 + if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + Integer orderType = order.getOrderType(); + if (orderType == null) { + order.setOrderType(1); + } + } else if (sourceType == Constant.SOURCE_TYPE_JD) { + order.setOrderType(3); + } else if (sourceType == Constant.SOURCE_TYPE_PDD) { + order.setOrderType(4); } Date thirdCreateTime = order.getThirdCreateTime(); @@ -1844,17 +1950,6 @@ Date settleTime = order.getSettleTime(); if (settleTime != null) { order.setReceiveTime("鏀惰揣鏃堕棿锛�" + format.format(settleTime)); - } - - // 璁㈠崟绫诲瀷 - if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { - Integer orderType = order.getOrderType(); - if (orderType == null) - order.setOrderType(1); - } else if (sourceType == Constant.SOURCE_TYPE_JD) { - order.setOrderType(3); - } else if (sourceType == Constant.SOURCE_TYPE_PDD) { - order.setOrderType(4); } /* 璁㈠崟鐘舵�� 杞崲澶勭悊 */ @@ -1877,6 +1972,17 @@ } } + // 2.1鏄剧ず杩斿埄璇存槑杩炴帴> 鏈け鏁�-鑷喘-鍒嗕韩 + if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + if (CommonOrder.STATE_SX != orderState + && thirdCreateTime.getTime() > TimeUtil.convertDateToTemp(Constant.ORDER_SHOW_BRACE_TIME) + && ((HongBaoV2.TYPE_ZIGOU == hongBaoType || 2 == hongBaoType) + || HongBaoV2.TYPE_SHARE_GOODS == hongBaoType)) { + String rebateLink = configService.get(ConfigKeyEnum.orderRebateDescLink.getKey()); + order.setRebateLink(rebateLink + "?orderNo=" + orderNo + "&sourceType=" + sourceType); + } + } + BigDecimal hongBao = order.getHongBao(); if (hongBao == null) { hongBao = new BigDecimal(0); @@ -1895,7 +2001,6 @@ List<TaoBaoWeiQuanOrder> listWQ = taoBaoWeiQuanOrderMapper .selectListByOrderIdAndState(order.getOrderNo(), "缁存潈鎴愬姛"); - boolean isPart = false;// 榛樿澶辨晥 BigDecimal weiQuanMoney = getWeiQuanMoney(listWQ, sourceType, uid); if (settleTime != null && august != null && settleTime.getTime() > august.getTime()) { orderStateContent = "鍞悗鎴愬姛"; @@ -1915,7 +2020,6 @@ // 璁㈠崟鏍囪瘑 List<String> signList = new ArrayList<String>(); /* 璁㈠崟杩斿埄绫诲瀷 杞崲 */ - Integer hongBaoType = order.getHongBaoType(); if (HongBaoV2.TYPE_ZIGOU == hongBaoType || 2 == hongBaoType) { // 鑷喘 hongbaoInfo = "杩斿埄"; @@ -2031,13 +2135,13 @@ if (HongBaoV2.TYPE_ZIGOU == hongBaoType) { // 濂栧姳璁㈠崟銆佸厤鍗� 浣跨敤璁板綍 if (sourceType == null) { - couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, null, uid, vip); + couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, null, uid, isvip); } else if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { - couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, listRecordTB, uid, vip); + couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, listRecordTB, uid, isvip); } else if (sourceType == Constant.SOURCE_TYPE_JD) { - couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, listRecordJD, uid, vip); + couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, listRecordJD, uid, isvip); } else if (sourceType == Constant.SOURCE_TYPE_PDD) { - couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, listRecordPDD, uid, vip); + couponFactoryNew(order, hasRewardCoupon, hongBaoState, hongBaoType, listRecordPDD, uid, isvip); } } @@ -2184,4 +2288,433 @@ } } + @Override + public Date getThirdCreateTime(String orderId, int sourceType) { + List<CommonOrder> list = listBySourceTypeAndOrderId(sourceType, orderId); + if (list == null || list.size() == 0) + return null; + return list.get(0).getThirdCreateTime(); + } + + + + + @Override + public List<CommonOrderVO> getOrderList(AcceptData acceptData, Integer page, Long uid, Integer state, Integer type, + Integer orderState, String orderNo, String startTime, String endTime, Integer dateType, + List<Integer> listSource) throws CommonOrderException, Exception { + + int pageSize = Constant.PAGE_SIZE; + List<CommonOrderVO> listOrder = commonOrderMapper.getOrderList((page - 1) * pageSize, pageSize, uid, state, + type, orderState, orderNo, startTime, endTime, dateType, listSource); + + // 璁㈠崟淇℃伅涓虹┖ + if (listOrder == null || listOrder.size() == 0) { + listOrder = new ArrayList<CommonOrderVO>(); + return listOrder; + } + + // 鍟嗗搧淇℃伅 + List<CommonOrderVO> listGoods = commonOrderMapper.listOrderGoodsInfo(listOrder); + if (listGoods == null || listGoods.size() == 0) { + return listOrder; + } + + // 鏁版嵁鍔犲伐閲嶆柊缁勭粐 + orderVOFactory21(acceptData, listOrder, listGoods, uid); + + return listOrder; + } + + @Override + public long countOrderList(Long uid, Integer state, Integer type, Integer orderState, String orderNo, + String startTime, String endTime, Integer dateType, List<Integer> listSource) throws CommonOrderException { + return commonOrderMapper.countOrderList(uid, state, type, orderState, orderNo, startTime, endTime, dateType, + listSource); + } + + + + /** + * 璁㈠崟淇℃伅鍔犲伐 + * + * @param acceptData + * @param listOrder + * @param listGoods + * @param uid + */ + private void orderVOFactory21(AcceptData acceptData, List<CommonOrderVO> listOrder, List<CommonOrderVO> listGoods, + Long uid) throws Exception { + List<String> listTB = new ArrayList<String>(); + List<String> listJD = new ArrayList<String>(); + List<String> listPDD = new ArrayList<String>(); + for (CommonOrderVO order : listOrder) { + if (order.getHongBaoType() == HongBaoV2.TYPE_YIJI || order.getHongBaoType() == HongBaoV2.TYPE_ERJI + || order.getHongBaoType() == HongBaoV2.TYPE_SHARE_ERJI + || order.getHongBaoType() == HongBaoV2.TYPE_SHARE_ERJI) { + Integer urank = order.getUrank(); + if (urank != null) { + String levelName = UserLevelUtil.getLevelName(urank); + if (!StringUtil.isNullOrEmpty(levelName)) { + order.setOrderDesc("璁㈠崟鏉ユ簮锛�" + levelName); + } + } + } + + Integer sourceType = order.getSourceType(); + if (sourceType == null) { + continue; + } else if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + listTB.add(order.getOrderNo()); + } else if (sourceType == Constant.SOURCE_TYPE_JD) { + listJD.add(order.getOrderNo()); + } else if (sourceType == Constant.SOURCE_TYPE_PDD) { + listPDD.add(order.getOrderNo()); + } + } + + List<UserSystemCouponRecord> listRecordTB = null; + if (listTB.size() > 0) { + listRecordTB = userSystemCouponRecordService.getRecordByOrderNoList(Constant.SOURCE_TYPE_TAOBAO, listTB); + } + + List<UserSystemCouponRecord> listRecordJD = null; + if (listJD.size() > 0) { + listRecordJD = userSystemCouponRecordService.getRecordByOrderNoList(Constant.SOURCE_TYPE_JD, listJD); + } + + List<UserSystemCouponRecord> listRecordPDD = null; + if (listPDD.size() > 0) { + listRecordPDD = userSystemCouponRecordService.getRecordByOrderNoList(Constant.SOURCE_TYPE_PDD, listPDD); + } + + + SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm"); + SimpleDateFormat formatday = new SimpleDateFormat("yyyy.MM.dd"); + // 鏄惁瀛樺湪濂栧姳鍒� + for (CommonOrderVO order : listOrder) { + String orderNo = order.getOrderNo(); + Integer sourceType = order.getSourceType(); + Integer hongBaoType = order.getHongBaoType(); + + // 鍟嗗搧淇℃伅缁勫悎 + for (CommonOrderVO commonOrder : listGoods) { + CommonOrderGoods goods = commonOrder.getCommonOrderGoods(); + if (goods == null) { + continue; + } + + if (sourceType.equals(commonOrder.getSourceType()) && orderNo.equals(commonOrder.getOrderNo())) { + CommonOrderGoodsVO commonGoodsVO = new CommonOrderGoodsVO(); + PropertyUtils.copyProperties(commonGoodsVO, goods); + if (commonGoodsVO.getGoodsType() == null) { + commonGoodsVO.setGoodsType(sourceType); + } + + // 娣樺疂鍟嗗搧鍥剧墖澶勭悊 + String picture = commonGoodsVO.getPicture(); + if (sourceType == Constant.SOURCE_TYPE_TAOBAO && !StringUtil.isNullOrEmpty(picture) + && !picture.contains("320x320")) { + commonGoodsVO.setPicture(TbImgUtil.getTBSize320Img(picture)); + } + + // 璐拱鏁伴噺 + commonGoodsVO.setActualCount(commonOrder.getTotalCount() + "浠�"); + + // 瀹炰粯娆� + BigDecimal totalSettlement = commonOrder.getTotalSettlement(); + if (totalSettlement == null || totalSettlement.compareTo(new BigDecimal(0)) <= 0) { + totalSettlement = commonOrder.getTotalPayment(); + } + commonGoodsVO.setActualPay("浠樻閲戦锛毬�" + totalSettlement); + + // 閭�璇疯鍗曚俊鎭繚鎶� + if (HongBaoV2.TYPE_YAOQING == hongBaoType || HongBaoV2.TYPE_YIJI == hongBaoType + || HongBaoV2.TYPE_ERJI == hongBaoType || HongBaoV2.TYPE_SHARE_YIJI == hongBaoType + || HongBaoV2.TYPE_SHARE_ERJI == hongBaoType) { + Map<String, String> titleMap = new HashMap<String, String>(); + titleMap.put("content", "涓轰繚闅滅敤鎴烽殣绉侊紝鍟嗗搧淇℃伅宸查殣钘�!"); + titleMap.put("fontColor", "#888888"); + titleMap.put("bottomColor", "#E9E9E9"); + commonGoodsVO.setTitle(null); + commonGoodsVO.setGoodsTitle(titleMap); + } + + // 璁㈠崟绫诲瀷涓虹┖鏃� 宸插晢鍝佺被涓哄噯 + String shopType = commonGoodsVO.getShopType(); + if (CommonOrderGoodsVO.TYPE_TAOBAO.equalsIgnoreCase(shopType)) { + order.setOrderType(1); + } else if (CommonOrderGoodsVO.TYPE_TMALL.equalsIgnoreCase(shopType)) { + order.setOrderType(2); + } + + Integer goodsType = commonGoodsVO.getGoodsType(); + if (goodsType != null & goodsType == Constant.SOURCE_TYPE_ELME) { + order.setOrderType(Constant.SOURCE_TYPE_ELME); // 楗夸簡涔堣鍗� + } + order.getListOrderGoods().add(commonGoodsVO); + } + } + + // 璁㈠崟绫诲瀷 + if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + Integer orderType = order.getOrderType(); + if (orderType == null) { + order.setOrderType(1); + } + } else if (sourceType == Constant.SOURCE_TYPE_JD) { + order.setOrderType(3); + } else if (sourceType == Constant.SOURCE_TYPE_PDD) { + order.setOrderType(4); + } + + Date thirdCreateTime = order.getThirdCreateTime(); + if (thirdCreateTime != null) { + order.setDownTime("涓嬪崟鏃堕棿锛�" + format.format(thirdCreateTime)); + order.setObtainTime(thirdCreateTime.getTime()); + } + + Date settleTime = order.getSettleTime(); + if (settleTime != null) { + order.setReceiveTime("鏀惰揣鏃堕棿锛�" + format.format(settleTime)); + } + + + Map<String, String> orderStateMap = new HashMap<String, String>(); + // 璁㈠崟鐘舵�� + Integer orderState = order.getState(); + Integer stateWholeOrder = order.getStateWholeOrder(); + if (CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO == stateWholeOrder) { + // 鏁翠釜璁㈠崟閮ㄥ垎澶辨晥锛氬垽鏂湡瀹炵姸鎬� 璁㈠崟銆佺孩鍖� + CommonOrderVO buFenOrder = commonOrderMapper.getBuFenOrderState(uid, order.getOrderNo()); + if (buFenOrder != null) { + // 鏈夋晥鐨勮鍗曠姸鎬� + orderState = buFenOrder.getState(); + } + } + + // 鏄剧ず杩斿埄璇存槑杩炴帴> 鏈け鏁� + if (CommonOrder.STATE_SX != orderState + && thirdCreateTime.getTime() > TimeUtil.convertDateToTemp(Constant.ORDER_SHOW_BRACE_TIME)) { + String rebateLink = configService.get(ConfigKeyEnum.orderRebateDescLink.getKey()); + order.setRebateLink(rebateLink + "?orderNo=" + orderNo + "&sourceType=" + sourceType); + } + + // 绾㈠寘淇℃伅 + List<HongBaoOrder> hongBaoOrderList = hongBaoOrderService.listDetailByOrderIdAndSourceTypeAndUid(orderNo, sourceType, uid); + HongBaoCountVO hongBaoCountVO = hongBaoOrderService.getHongBaoCountVO(hongBaoOrderList); + BigDecimal hongBao = hongBaoCountVO.getValidMoney(); + Integer hongBaoState = hongBaoCountVO.getCurrentState(); + + + /* 璁㈠崟鐘舵�� 杞崲澶勭悊 */ + String orderStateContent = ""; + if (CommonOrder.STATE_FK == orderState) { + orderStateContent = "宸蹭粯娆�"; + } else if (CommonOrder.STATE_JS == orderState) { + orderStateContent = "宸叉敹璐�"; + } else if (CommonOrder.STATE_SX == orderState) { + orderStateContent = "鏈粯娆�/宸查��娆�"; + } else if (CommonOrder.STATE_WQ == orderState) { + orderStateContent = "宸插敭鍚�"; + if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + /* 璁㈠崟缁存潈 鍒ゆ柇鏄惁鍏ㄩ儴缁存潈 */ + List<TaoBaoWeiQuanOrder> listWQ = taoBaoWeiQuanOrderMapper.selectListByOrderIdAndState(order.getOrderNo(), "缁存潈鎴愬姛"); + BigDecimal weiQuanMoney = getWeiQuanMoney(listWQ, sourceType, uid); + hongBao = MoneyBigDecimalUtil.sub(hongBao, weiQuanMoney); + } + } + orderStateMap.put("content", orderStateContent); + orderStateMap.put("fontColor", "#666666"); + order.setOrderState(orderStateMap); + + String hongbaoInfo = ""; + // 璁㈠崟鏍囪瘑 + List<String> signList = new ArrayList<String>(); + /* 璁㈠崟杩斿埄绫诲瀷 杞崲 */ + if (HongBaoV2.TYPE_ZIGOU == hongBaoType || 2 == hongBaoType) { + // 鑷喘 + hongbaoInfo = "杩斿埄"; + order.setOrderOrigin("1"); + order.setHongBaoTypePic(CommonOrder.TYPE_FANLI); + signList.add(CommonOrder.TYPE_FANLI); + + // 鏄惁宸蹭娇鐢ㄥ鍔卞埜銆佸厤鍗曞埜鎯呭喌 + if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + couponUseFactory(order, listRecordTB); + } else if (sourceType == Constant.SOURCE_TYPE_JD) { + couponUseFactory(order, listRecordJD); + } else if (sourceType == Constant.SOURCE_TYPE_PDD) { + couponUseFactory(order, listRecordPDD); + } + } else if (HongBaoV2.TYPE_SHARE_GOODS == hongBaoType) { + // 鍒嗕韩 + hongbaoInfo = "濂栭噾"; + order.setOrderOrigin("2"); + order.setHongBaoTypePic(CommonOrder.TYPE_SHARE); + signList.add(CommonOrder.TYPE_SHARE); + + } else if (HongBaoV2.TYPE_SHARE_YIJI == hongBaoType || HongBaoV2.TYPE_SHARE_ERJI == hongBaoType + || HongBaoV2.TYPE_YAOQING == hongBaoType || HongBaoV2.TYPE_YIJI == hongBaoType + || HongBaoV2.TYPE_ERJI == hongBaoType) { + // 閭�璇疯鍗� + hongbaoInfo = "鏀剁泭"; + order.setOrderOrigin("3"); + order.setHongBaoTypePic(CommonOrder.TYPE_INVITE); + signList.add(CommonOrder.TYPE_INVITE); + } + order.setSignList(signList); + + String hongBaoDate = null; + String hongBaoState_Str = ""; + String hongbaoInfoFontColor = "#E5005C"; + + /* 绾㈠寘鐘舵�� 杞崲 */ + String stateContent = ""; + String stateFontColor = "#E5005C"; + Integer orderHongBaoState = null; + if (HongBaoV2.STATE_KELINGQU == hongBaoState || HongBaoV2.STATE_BUKELINGQU == hongBaoState) { + orderHongBaoState = 1; + stateContent = "鏈埌璐�"; + hongBaoState_Str = "棰勪及"; + Date preAccountTime = order.getPreAccountTime(); + if (preAccountTime != null) { + hongBaoDate = "棰勮鍒拌处鏃堕棿锛�" + formatday.format(preAccountTime); + } + } else if (HongBaoV2.STATE_YILINGQU == hongBaoState) { + orderHongBaoState = 3; + stateContent = "宸插埌璐�"; + Date accountTime = order.getAccountTime(); + if (accountTime != null) { + hongBaoDate = "鍒拌处鏃堕棿锛�" + formatday.format(accountTime); + } + } else if (HongBaoV2.STATE_SHIXIAO == hongBaoState) { + orderHongBaoState = 4; + stateContent = "宸插け鏁�"; + hongbaoInfoFontColor = "#888888"; + } + order.setHongBaoState(orderHongBaoState); + order.setHongBaoDate(hongBaoDate); + + if (!StringUtil.isNullOrEmpty(order.getStateDesc())) { + stateContent = stateContent + "-" + order.getStateDesc(); + } + + Map<String, String> stateMap = new HashMap<String, String>(); + stateMap.put("content", stateContent); + stateMap.put("fontColor", stateFontColor); + order.setAccountState(stateMap); + + hongbaoInfo = hongBaoState_Str + hongbaoInfo; + + Map<String, String> hongBaoMap = new HashMap<String, String>(); + hongBaoMap.put("content", hongbaoInfo + " 楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN).toString()); + hongBaoMap.put("fontColor", hongbaoInfoFontColor); + order.setHongBaoInfo(hongBaoMap); + + // 鍒嗕韩銆侀個璇� 闅愯棌璁㈠崟鍙� + if (HongBaoV2.TYPE_SHARE_GOODS == hongBaoType || HongBaoV2.TYPE_YAOQING == hongBaoType + || HongBaoV2.TYPE_YIJI == hongBaoType || HongBaoV2.TYPE_ERJI == hongBaoType + || HongBaoV2.TYPE_SHARE_YIJI == hongBaoType || HongBaoV2.TYPE_SHARE_ERJI == hongBaoType) { + order.setOrderNo(UserUtil.filterOrderId(order.getOrderNo())); + } + } + } + + /** + * 璁㈠崟锛� 鍏嶅崟鏍囪瘑 濂栧姳鏍囪瘑 + * + * @param order + * @param hasRewardCoupon + * @param hongBaoState + * @param list + * @param signList + */ + private void couponUseFactory(CommonOrderVO order, List<UserSystemCouponRecord> list) throws Exception { + if (list == null || list.size() == 0) { + return; + } + + // 鏄惁鍏嶅崟鍟嗗搧 + boolean freeOrder = false; + // 鏄惁濂栧姳鎴愬姛 + boolean rewardSuccess = false; + for (UserSystemCouponRecord couponRecord : list) { + int goodSource = couponRecord.getGoodSource(); + if (goodSource == 0) + goodSource = 1; + + String orderNo = couponRecord.getOrderNo(); + if (order.getOrderNo().equals(orderNo) && goodSource == order.getSourceType()) { + Integer state = couponRecord.getState(); + String systemCouponType = couponRecord.getCouponType(); + if (CouponTypeEnum.rebatePercentCoupon.name().equals(systemCouponType) + && UserSystemCouponRecord.STATE_SUCCESS == state) { + // 宸蹭娇鐢ㄥ鍔卞埜 + rewardSuccess = true; + } else if (CouponTypeEnum.freeCoupon.name().equals(systemCouponType) + || CouponTypeEnum.welfareFreeCoupon.name().equals(systemCouponType) + || CouponTypeEnum.freeCouponBuy.name().equals(systemCouponType)) { + if (UserSystemCouponRecord.STATE_FREE_ON == state) { + // 鍏嶅崟涓� + freeOrder = true; + order.getSignList().add(PIC_FREE_ON); + } else if (UserSystemCouponRecord.STATE_SUCCESS == state) { + // 鍏嶅崟鎴愬姛 + freeOrder = true; + order.getSignList().add(PIC_FREE_SUCCEED); + } else if (UserSystemCouponRecord.STATE_FAIL_RULE == state + || UserSystemCouponRecord.STATE_FAIL_DRAWBACK == state) { + // 瑙勫垯涓嶅尮閰嶃�侀��娆� + freeOrder = true; + order.getSignList().add(PIC_FREE_FAIL); + } + } + break; + } + } + + // 鍏嶅崟璇︽儏 + if (freeOrder) { + ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO(); + rewardStyleVO.setContent("鍏嶅崟璇︽儏 >"); + rewardStyleVO.setColor("#E5005C"); + rewardStyleVO.setBottomColor("#FFDCEA"); + + Map<String, Object> jumpLink = new HashMap<String, Object>(); + jumpLink.put("orderNo", order.getOrderNo()); + jumpLink.put("goodsType", order.getSourceType() + ""); + + Map<String, Object> jump = new HashMap<String, Object>(); + jump.put("type", 1); // 椤甸潰璺宠浆 + jump.put("params", jumpLink); + jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("freeCouponDetail")); + + Map<String, Object> rewardMap = new HashMap<String, Object>(); + rewardMap.put("text", rewardStyleVO); + rewardMap.put("jump", jump); + order.setRewardDetail(rewardMap); + } + + // 宸蹭娇鐢ㄥ鍔卞埜 + if (rewardSuccess) { + ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO(); + rewardStyleVO.setColor("#E5005C"); + rewardStyleVO.setBottomColor("#FFDCEA"); + rewardStyleVO.setContent("宸蹭娇鐢ㄥ鍔卞埜 >"); + + Map<String, Object> rewardMap = new HashMap<String, Object>(); + rewardMap.put("text", rewardStyleVO); + Map<String, Object> jumpLink = new HashMap<String, Object>(); + jumpLink.put("orderNo", order.getOrderNo()); + jumpLink.put("goodsType", order.getSourceType() + ""); + + Map<String, Object> jump = new HashMap<String, Object>(); + jump.put("type", 1); // 1 甯歌璺宠浆椤甸潰 + jump.put("params", jumpLink); + jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail")); + rewardMap.put("jump", jump); + order.setRewardDetail(rewardMap); + } + } } -- Gitblit v1.8.0