From 8b2191df2f7d94aa299bd43dcbe97c94e5a61bbd Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 20 十一月 2019 14:53:34 +0800 Subject: [PATCH] RocketMQ的消息整改 --- fanli/src/main/java/com/yeshi/fanli/service/impl/order/CommonOrderServiceImpl.java | 1052 ++++++++++++++++++++++++++++++++++------------------------ 1 files changed, 614 insertions(+), 438 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 d17a644..c2ab5e5 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 @@ -1,7 +1,6 @@ package com.yeshi.fanli.service.impl.order; import java.math.BigDecimal; -import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Date; @@ -14,12 +13,15 @@ import org.apache.commons.beanutils.PropertyUtils; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; +import org.yeshi.utils.DateUtil; +import org.yeshi.utils.entity.DateInfo; import org.yeshi.utils.taobao.TbImgUtil; 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.order.CommonOrderAddResultDTO; import com.yeshi.fanli.dto.pdd.PDDGoodsDetail; import com.yeshi.fanli.entity.accept.AcceptData; import com.yeshi.fanli.entity.bus.user.HongBaoV2; @@ -33,6 +35,7 @@ import com.yeshi.fanli.entity.order.CommonOrderGoods; import com.yeshi.fanli.entity.order.CommonOrderTradeIdMap; 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.SystemCoupon.CouponTypeEnum; import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief; @@ -45,9 +48,10 @@ import com.yeshi.fanli.service.inter.config.ConfigService; import com.yeshi.fanli.service.inter.config.SystemCouponService; import com.yeshi.fanli.service.inter.goods.CommonGoodsService; -import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service; import com.yeshi.fanli.service.inter.order.CommonOrderService; import com.yeshi.fanli.service.inter.order.HongBaoOrderService; +import com.yeshi.fanli.service.inter.order.HongBaoV2Service; +import com.yeshi.fanli.service.inter.order.InviteOrderSubsidyService; import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService; import com.yeshi.fanli.service.inter.user.UserSystemCouponService; import com.yeshi.fanli.util.Constant; @@ -109,6 +113,10 @@ @Resource private HongBaoOrderService hongBaoOrderService; + + @Resource + private InviteOrderSubsidyService inviteOrderSubsidyService; + // 濂栧姳璁㈠崟鍥剧墖 public final static String PIC_REWARD = "http://img.flqapp.com/resource/order/order_state_reward.png"; @@ -166,7 +174,7 @@ @Override public List<CommonOrderVO> getOrderByUid(AcceptData acceptData, Integer page, Long uid, Integer state, Integer type, Integer orderState, String orderNo, String startTime, String endTime, Integer dateType, Integer source) - throws CommonOrderException { + throws CommonOrderException, Exception{ int pageSize = Constant.PAGE_SIZE; @@ -187,388 +195,12 @@ } // 鏁版嵁鍔犲伐閲嶆柊缁勭粐 - listDataFactory(acceptData, listOrder, listGoods, uid); - + orderInfoFactory(acceptData, listOrder, listGoods, uid); + //listDataFactory(acceptData, listOrder, listGoods, uid); return listOrder; } - @Override - public Map<String, BigDecimal> countHistoryOrder(Long uid, Integer day, Integer source) { - return commonOrderMapper.countHistoryOrder(uid, day, source); - } - - @Override - public long countBonusOrderNumber(Long uid, Integer type, Integer day, String startTime, String endTime, - Integer source) { - return commonOrderMapper.countBonusOrderNumber(uid, type, day, startTime, endTime, source); - } - - @Override - public BigDecimal countBonusOrderMoney(Long uid, Integer type, Integer day, String startTime, String endTime, - Integer source) { - return commonOrderMapper.countBonusOrderMoney(uid, type, day, startTime, endTime, source); - } - - @Override - public Map<String, Object> countBonusOrderMoneyAndNumber(Long uid, Integer type, Integer day, String startTime, - String endTime, Integer source) { - return commonOrderMapper.countBonusOrderMoneyAndNumber(uid, type, day, startTime, endTime, source); - } - - @Override - public Map<String, BigDecimal> countByUidAndOrderState(Long uid, Integer type, String startTime, String endTime, - Integer day, Integer source) { - return commonOrderMapper.countByUidAndOrderState(uid, type, startTime, endTime, day, source); - } - - public void listDataFactory(AcceptData acceptData, List<CommonOrderVO> listOrder, List<CommonOrderVO> listGoods, - Long uid) { - - List<String> listTB = new ArrayList<String>(); - List<String> listJD = new ArrayList<String>(); - List<String> listPDD = new ArrayList<String>(); - for (CommonOrderVO commonOrderVO : listOrder) { - Integer sourceType = commonOrderVO.getSourceType(); - if (sourceType == null) { - continue; - } else if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { - listTB.add(commonOrderVO.getOrderNo()); - } else if (sourceType == Constant.SOURCE_TYPE_JD) { - listJD.add(commonOrderVO.getOrderNo()); - } else if (sourceType == Constant.SOURCE_TYPE_PDD) { - listPDD.add(commonOrderVO.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); - } - - /* 缁勫悎鍟嗗搧淇℃伅 */ - for (CommonOrderVO commonOrder : listGoods) { - CommonOrderGoods goods = commonOrder.getCommonOrderGoods(); - if (goods == null) { - continue; - } - - String orderNo1 = commonOrder.getOrderNo(); - Integer sourceType = commonOrder.getSourceType(); - for (CommonOrderVO order : listOrder) { - String orderNo2 = order.getOrderNo(); - Integer sourceType2 = order.getSourceType(); - - // 鏉ユ簮銆佽鍗曞彿鐩稿悓 - if (sourceType.equals(sourceType2) && orderNo1.equals(orderNo2)) { - // 鍔犲叆鍟嗗搧淇℃伅 - List<CommonOrderGoodsVO> listOrderGoods = order.getListOrderGoods(); - - CommonOrderGoodsVO commonGoodsVO = new CommonOrderGoodsVO(); - try { - PropertyUtils.copyProperties(commonGoodsVO, goods); - } catch (Exception e) { - e.printStackTrace(); - } - - commonGoodsVO.setGoodsType(sourceType2); - - String picture = commonGoodsVO.getPicture(); - if (!StringUtil.isNullOrEmpty(picture) && !picture.contains("320x320")) { - commonGoodsVO.setPicture(TbImgUtil.getTBSize320Img(picture)); - } - - Integer hongBaoType = order.getHongBaoType(); - // 閭�璇疯鍗曚俊鎭繚鎶� - 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); - } - - // 璐拱鏁伴噺 - commonGoodsVO.setActualCount(commonOrder.getTotalCount() + "浠�"); - - BigDecimal totalSettlement = commonOrder.getTotalSettlement(); - if (totalSettlement == null || totalSettlement.compareTo(new BigDecimal(0)) <= 0) { - totalSettlement = commonOrder.getTotalPayment(); - } - // 瀹炰粯娆� - commonGoodsVO.setActualPay("浠樻閲戦锛毬�" + totalSettlement); - - 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); - } - } - listOrderGoods.add(commonGoodsVO); - break; - } - } - } - - SimpleDateFormat format = new SimpleDateFormat("yyyy.MM.dd HH:mm"); - SimpleDateFormat formatday = new SimpleDateFormat("yyyy.MM.dd"); - - // 鏄惁瀛樺湪濂栧姳鍒� - //boolean hasRewardCoupon = userSystemCouponService.hasRewardCoupon(uid); - boolean hasRewardCoupon = userSystemCouponService.getIncludeNotExchange(uid); - boolean exchangeCoupon = userSystemCouponService.getIncludeExchange(uid); - - // 2019.8.1寮�濮嬭繑鍥炵淮鏉冧俊鎭� - Date august = null; - try { - august = TimeUtil.parse("2019-08-01"); - } catch (ParseException e) { - e.printStackTrace(); - } - - /* 缁勭粐璁㈠崟鐘舵�� 绛変俊鎭� */ - for (CommonOrderVO order : listOrder) { - - 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)); - } - - Integer sourceType2 = order.getSourceType(); - if (sourceType2 == Constant.SOURCE_TYPE_TAOBAO) { - Integer orderType = order.getOrderType(); - if (orderType == null) { - order.setOrderType(1); - } - } else if (sourceType2 == Constant.SOURCE_TYPE_JD) { - order.setOrderType(3); - } else if (sourceType2 == Constant.SOURCE_TYPE_PDD) { - order.setOrderType(4); - } - - /* 璁㈠崟鐘舵�� 杞崲澶勭悊 */ - String orderStateContent = ""; - Map<String, String> orderStateMap = new HashMap<String, String>(); - - // 璁㈠崟鐘舵�� - Integer orderState = order.getState(); - // 绾㈠寘鐘舵�� - Integer hongBaoState = order.getHongBaoState(); - - Integer stateWholeOrder = order.getStateWholeOrder(); - if (CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO == stateWholeOrder) { - // 鏁翠釜璁㈠崟閮ㄥ垎澶辨晥锛氬垽鏂湡瀹炵姸鎬� 璁㈠崟銆佺孩鍖� - CommonOrderVO buFenOrder = commonOrderMapper.getBuFenOrderState(uid, order.getOrderNo()); - if (buFenOrder != null) { - // 鏈夋晥鐨勮鍗曠姸鎬� - orderState = buFenOrder.getState(); - // 鏈夋晥鐨勭孩鍖呯姸鎬� - hongBaoState = buFenOrder.getHongBaoState(); - } - } - - BigDecimal hongBao = order.getHongBao(); - if (hongBao == null) { - hongBao = new BigDecimal(0); - } - - 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 = "宸茬淮鏉�"; - - Integer sourceType = order.getSourceType(); - if (sourceType != null && sourceType == Constant.SOURCE_TYPE_TAOBAO) { - /* 璁㈠崟缁存潈 鍒ゆ柇鏄惁鍏ㄩ儴缁存潈 */ - List<TaoBaoWeiQuanOrder> listWQ = taoBaoWeiQuanOrderMapper - .selectListByOrderIdAndState(order.getOrderNo(), "缁存潈鎴愬姛"); - - boolean isPart = false;// 榛樿澶辨晥 - BigDecimal weiQuanMoney = new BigDecimal(0); - if (listWQ != null && listWQ.size() > 0) { - BigDecimal fanTotalMoney = new BigDecimal(0); - for (TaoBaoWeiQuanOrder weiQuanOrder : listWQ) { - BigDecimal fanMoney = weiQuanOrder.getFanMoney(); - if (fanMoney != null) { - fanTotalMoney = MoneyBigDecimalUtil.add(fanTotalMoney, fanMoney); - } - weiQuanMoney = MoneyBigDecimalUtil.add(weiQuanOrder.getMoney(), weiQuanMoney); - } - - if (fanTotalMoney.compareTo(hongBao) < 0) { - isPart = true; - } - } - - if (!VersionUtil.greaterThan_1_6_0(acceptData.getPlatform(), acceptData.getVersion())) { - if (isPart) { - hongBaoState = HongBaoV2.STATE_BUFENSHIXIAO; // 閮ㄥ垎澶辨晥 - } else { - hongBaoState = HongBaoV2.STATE_SHIXIAO; // 鍏ㄩ儴澶辨晥 - } - } else { - // 2019.8.1 杩斿洖缁存潈淇℃伅 - if (settleTime != null && august != null && settleTime.getTime() > august.getTime()) { - orderStateContent = "缁存潈鎴愬姛"; - WeiQuanInfo weiQuanInfo = new WeiQuanInfo(); - weiQuanInfo.setOldHongBao("楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN).toString()); - if (isPart) { - // 缁存潈澶辨晥閲戦=缁存潈鐨勯噾棰�*鑾峰緱鐨勭孩鍖�/缁撶畻閲戦 - BigDecimal settlement = order.getSettlement(); - BigDecimal wqHongbao = MoneyBigDecimalUtil - .div(MoneyBigDecimalUtil.mul(hongBao, settlement), settlement); - weiQuanInfo.setWqHongBao( - "缁存潈锛�-楼" + wqHongbao.setScale(2, BigDecimal.ROUND_DOWN).toString()); - hongBao = MoneyBigDecimalUtil.sub(hongBao, wqHongbao); - } else { - weiQuanInfo - .setWqHongBao("缁存潈锛�-楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN).toString()); - hongBao = new BigDecimal(0); - } - order.setWeiQuanInfo(weiQuanInfo); - } - } - } - } - orderStateMap.put("content", orderStateContent); - orderStateMap.put("fontColor", "#666666"); - order.setOrderState(orderStateMap); - - String hongbaoInfo = ""; - // 璁㈠崟鏍囪瘑 - List<String> signList = new ArrayList<String>(); - /* 璁㈠崟杩斿埄绫诲瀷 杞崲 */ - Integer hongBaoType = order.getHongBaoType(); - if (HongBaoV2.TYPE_ZIGOU == hongBaoType || 2 == hongBaoType) { - // 鑷喘 - hongbaoInfo = "杩斿埄"; - order.setOrderOrigin("1"); - order.setHongBaoTypePic(CommonOrder.TYPE_FANLI); - signList.add(CommonOrder.TYPE_FANLI); - } 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_YAOQING == hongBaoType || HongBaoV2.TYPE_YIJI == hongBaoType - || HongBaoV2.TYPE_ERJI == hongBaoType || HongBaoV2.TYPE_SHARE_YIJI == hongBaoType - || HongBaoV2.TYPE_SHARE_ERJI == hongBaoType) { - // 閭�璇� - hongbaoInfo = "濂栭噾"; - order.setOrderOrigin("3"); - order.setHongBaoTypePic(CommonOrder.TYPE_INVITE); - signList.add(CommonOrder.TYPE_INVITE); - } - - 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_BUFENSHIXIAO == hongBaoState) { - stateContent = "閮ㄥ垎澶辨晥"; - orderHongBaoState = 3; - 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); - - 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); - - Integer sourceType = order.getSourceType(); - // 闈炶嚜璐殑璁㈠崟 涓嶆樉绀鸿繑鍒┿�佸厤鍗曡鎯� - if (HongBaoV2.TYPE_ZIGOU != hongBaoType) { - order.setSignList(signList); - } else { - // 濂栧姳璁㈠崟銆佸厤鍗� 浣跨敤璁板綍 - if (sourceType == null) { - setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, null, signList, acceptData); - } else if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { - setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, listRecordTB, signList, acceptData); - } else if (sourceType == Constant.SOURCE_TYPE_JD) { - setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, listRecordJD, signList, acceptData); - } else if (sourceType == Constant.SOURCE_TYPE_PDD) { - setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, listRecordPDD, signList, acceptData); - } - } - - // 鍒嗕韩銆侀個璇� 闅愯棌璁㈠崟鍙� - 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())); - } - } - } - + /** * 璁㈠崟锛� 鍏嶅崟鏍囪瘑 濂栧姳鏍囪瘑 * @@ -578,11 +210,12 @@ * @param list * @param signList */ - public void setSystemCouponRecord(CommonOrderVO order, boolean hasRewardCoupon, boolean exchangeCoupon, Integer hongBaoState, - Integer hongBaoType, List<UserSystemCouponRecord> list, List<String> signList, AcceptData acceptData) { + public void setSystemCouponRecord(CommonOrderVO order, boolean hasRewardCoupon, boolean exchangeCoupon, + Integer hongBaoState, Integer hongBaoType, List<UserSystemCouponRecord> list, List<String> signList, + AcceptData acceptData) { // 鏄惁鍏嶅崟鍟嗗搧 - boolean freeOrder = false; + boolean freeOrder = false; // 鏄惁濂栧姳鎴愬姛 boolean rewardSuccess = false; @@ -629,54 +262,134 @@ // 1.6.5 鏄惁瀛樺湪鏂板厬鎹㈢殑鍒� if (!hasRewardCoupon && exchangeCoupon) { try { - String downTime = order.getDownTime(); - if (!StringUtil.isNullOrEmpty(downTime)) { - long downOrderTime = TimeUtil.convertDateToTemp2(downTime); - long limitDate = TimeUtil.convertDateToTemp("2019-09-01"); - if (downOrderTime > limitDate ) + Date thirdCreateTime = order.getThirdCreateTime(); + if (thirdCreateTime != null) { + long downOrderTime = thirdCreateTime.getTime(); + long limitDate = TimeUtil.convertDateToTemp("2019-09-10"); + if (downOrderTime > limitDate) hasRewardCoupon = true; } } catch (Exception e) { e.printStackTrace(); } } - - boolean rewardOrder = false; + boolean rewardOrder = false; int type = 1; // 1 甯歌璺宠浆椤甸潰 2寮瑰嚭閫夐」锛堝鍔卞埜锛� if (rewardSuccess) { - // 濂栧姳鎴愬姛 - rewardOrder = true; + if (!VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + rewardOrder = true; //濂栧姳鎴愬姛 2.0.2 娑堝け + } } else if (hasRewardCoupon && !freeOrder && HongBaoV2.TYPE_ZIGOU == hongBaoType && HongBaoV2.STATE_YILINGQU == hongBaoState) { // 鏈夊彲鐢ㄧ殑濂栧姳鍒� 銆侀潪鍏嶅崟璁㈠崟 銆佷笖宸插埌璐︾殑 銆佽繑鍒╄鍗� type = 2; rewardOrder = true; - } + } if (rewardOrder) { - ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO(); - // 濂栧姳鍒歌繘搴﹁鎯� - rewardStyleVO.setContent("杩斿埄濂栧姳 >"); - rewardStyleVO.setColor("#E5005C"); - rewardStyleVO.setBottomColor("#FFDCEA"); + try { + boolean newEdition = false; + String num = null; + String unit = null; + boolean canUse = false; + + // 鐗堟湰鍖哄垎锛�2.1 + if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + Date thirdCreateTime = order.getThirdCreateTime(); + if (thirdCreateTime != null) { + long downOrderTime = thirdCreateTime.getTime(); + long limitDate = Long.parseLong("1571760000000"); // TODO 鏃ユ湡寰呯‘瀹�2019-11-10 + if (downOrderTime > limitDate) { + newEdition = true; + Date endDay = DateUtil.plusDayDate(4, thirdCreateTime); + long currentTime = java.lang.System.currentTimeMillis(); + if (endDay.getTime() > currentTime) { + DateInfo dateInfo = DateUtil.dateDiff3(currentTime, endDay.getTime()); + if (dateInfo != null) { + if (dateInfo.getDay() > 0) { + canUse = true; + unit = "澶�"; + num = dateInfo.getDay().toString(); + } - Map<String, Object> jumpLink = new HashMap<String, Object>(); - jumpLink.put("orderNo", order.getOrderNo()); - if (VersionUtil.greaterThan_1_6_0(acceptData.getPlatform(), acceptData.getVersion())) { - jumpLink.put("goodsType", order.getSourceType()); + if (!canUse && dateInfo.getHour() > 0) { + canUse = true; + unit = "灏忔椂"; + num = dateInfo.getHour().toString(); + } + + if (!canUse && dateInfo.getMinute() > 0) { + canUse = true; + unit = "鍒�"; + num = dateInfo.getMinute().toString(); + } + + if (!canUse && dateInfo.getSecond() > 0) { + canUse = true; + unit = "绉�"; + num = dateInfo.getSecond().toString(); + } + } + } + } + } + } + + if (newEdition && !canUse) { + // 鏂扮増涓嶅彲浣跨敤 + } else { + Map<String, Object> rewardMap = new HashMap<String, Object>(); + ClientTextStyleVO rewardStyleVO = new ClientTextStyleVO(); + rewardStyleVO.setColor("#E5005C"); + rewardStyleVO.setBottomColor("#FFDCEA"); + if (!newEdition) { + if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + rewardStyleVO.setContent("浣跨敤濂栧姳鍒� >"); + } else { + rewardStyleVO.setContent("杩斿埄濂栧姳 >"); + } + } else if (canUse) { + rewardStyleVO.setContent("浣跨敤濂栧姳鍒�"); + + ClientTextStyleVO txt1 = new ClientTextStyleVO(); + txt1.setContent("鍓�"); + txt1.setColor("#666666"); + txt1.setBottomColor("#FFDCEA"); + + ClientTextStyleVO txt2 = new ClientTextStyleVO(); + txt2.setContent(num); + txt2.setColor("#E5005C"); + txt2.setBottomColor("#FFDCEA"); + txt2.setFontSize("1.33"); + + ClientTextStyleVO txt3 = new ClientTextStyleVO(); + txt3.setContent(unit + "鍏抽棴 >"); + txt3.setColor("#666666"); + txt3.setBottomColor("#FFDCEA"); + + List<ClientTextStyleVO> ticking = new ArrayList<ClientTextStyleVO>(); + ticking.add(txt1); + ticking.add(txt2); + ticking.add(txt3); + rewardMap.put("ticking", ticking); + } + 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", type); + jump.put("params", jumpLink); + jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail")); + rewardMap.put("jump", jump); + order.setRewardDetail(rewardMap); + } + } catch (Exception e) { + e.printStackTrace(); } - - Map<String, Object> jump = new HashMap<String, Object>(); - jump.put("type", type); - jump.put("params", jumpLink); - jump.put("jumpDetail", jumpDetailV2Service.getByTypeCache("rewardCouponDetail")); - - Map<String, Object> rewardMap = new HashMap<String, Object>(); - rewardMap.put("text", rewardStyleVO); - rewardMap.put("jump", jump); - - order.setRewardDetail(rewardMap); } if (freeOrder) { @@ -689,7 +402,7 @@ Map<String, Object> jumpLink = new HashMap<String, Object>(); jumpLink.put("orderNo", order.getOrderNo()); if (VersionUtil.greaterThan_1_6_0(acceptData.getPlatform(), acceptData.getVersion())) { - jumpLink.put("goodsType", order.getSourceType()); + jumpLink.put("goodsType", order.getSourceType()+""); } Map<String, Object> jump = new HashMap<String, Object>(); @@ -705,6 +418,416 @@ } } + + + /** + * 璁㈠崟淇℃伅鍔犲伐 + * @param acceptData + * @param listOrder + * @param listGoods + * @param uid + */ + public void orderInfoFactory(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 commonOrderVO : listOrder) { + Integer sourceType = commonOrderVO.getSourceType(); + if (sourceType == null) { + continue; + } else if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + listTB.add(commonOrderVO.getOrderNo()); + } else if (sourceType == Constant.SOURCE_TYPE_JD) { + listJD.add(commonOrderVO.getOrderNo()); + } else if (sourceType == Constant.SOURCE_TYPE_PDD) { + listPDD.add(commonOrderVO.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"); + // 2019.8.1寮�濮嬭繑鍥炵淮鏉冧俊鎭� + Date august = TimeUtil.parse("2019-08-01"); + + // 鏄惁瀛樺湪濂栧姳鍒� + boolean hasRewardCoupon = userSystemCouponService.getIncludeNotExchange(uid); + boolean exchangeCoupon = userSystemCouponService.getIncludeExchange(uid); + + + for (CommonOrderVO order: listOrder) { + String orderNo = order.getOrderNo(); + Integer sourceType = order.getSourceType(); + + // 鍟嗗搧淇℃伅缁勫悎 + 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); + 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); + + + Integer hongBaoType = order.getHongBaoType(); + // 閭�璇疯鍗曚俊鎭繚鎶� + 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); + } + + + // 璁㈠崟绫诲瀷涓虹┖鏃� 宸插晢鍝佺被涓哄噯 + 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); + } + } + + order.getListOrderGoods().add(commonGoodsVO); + } + } + + + 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)); + } + + // 璁㈠崟绫诲瀷 + 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); + } + + + + /* 璁㈠崟鐘舵�� 杞崲澶勭悊 */ + String orderStateContent = ""; + Map<String, String> orderStateMap = new HashMap<String, String>(); + // 璁㈠崟鐘舵�� + Integer orderState = order.getState(); + // 绾㈠寘鐘舵�� + Integer hongBaoState = order.getHongBaoState(); + + Integer stateWholeOrder = order.getStateWholeOrder(); + if (CommonOrder.STATE_WHOLE_ORDER_BUFENYOUXIAO == stateWholeOrder) { + // 鏁翠釜璁㈠崟閮ㄥ垎澶辨晥锛氬垽鏂湡瀹炵姸鎬� 璁㈠崟銆佺孩鍖� + CommonOrderVO buFenOrder = commonOrderMapper.getBuFenOrderState(uid, order.getOrderNo()); + if (buFenOrder != null) { + // 鏈夋晥鐨勮鍗曠姸鎬� + orderState = buFenOrder.getState(); + // 鏈夋晥鐨勭孩鍖呯姸鎬� + hongBaoState = buFenOrder.getHongBaoState(); + } + } + + BigDecimal hongBao = order.getHongBao(); + if (hongBao == null) { + hongBao = new BigDecimal(0); + } + + 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 != null && sourceType == Constant.SOURCE_TYPE_TAOBAO) { + /* 璁㈠崟缁存潈 鍒ゆ柇鏄惁鍏ㄩ儴缁存潈 */ + List<TaoBaoWeiQuanOrder> listWQ = taoBaoWeiQuanOrderMapper + .selectListByOrderIdAndState(order.getOrderNo(), "缁存潈鎴愬姛"); + + boolean isPart = false;// 榛樿澶辨晥 + BigDecimal weiQuanMoney = getWeiQuanMoney(listWQ, sourceType, uid); + + if (!VersionUtil.greaterThan_1_6_0(acceptData.getPlatform(), acceptData.getVersion())) { + if (isPart) { + hongBaoState = HongBaoV2.STATE_BUFENSHIXIAO; // 閮ㄥ垎澶辨晥 + } else { + hongBaoState = HongBaoV2.STATE_SHIXIAO; // 鍏ㄩ儴澶辨晥 + } + } else { + // 2019.8.1 杩斿洖缁存潈淇℃伅 + if (settleTime != null && august != null && settleTime.getTime() > august.getTime()) { + orderStateContent = "缁存潈鎴愬姛"; + WeiQuanInfo weiQuanInfo = new WeiQuanInfo(); + weiQuanInfo.setOldHongBao("楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN).toString()); + weiQuanInfo.setWqHongBao("缁存潈锛�-楼" + weiQuanMoney.setScale(2, BigDecimal.ROUND_DOWN).toString()); + hongBao = MoneyBigDecimalUtil.sub(hongBao, weiQuanMoney); + order.setWeiQuanInfo(weiQuanInfo); + } + } + } + } + orderStateMap.put("content", orderStateContent); + orderStateMap.put("fontColor", "#666666"); + order.setOrderState(orderStateMap); + + + + + String hongbaoInfo = ""; + // 璁㈠崟鏍囪瘑 + List<String> signList = new ArrayList<String>(); + /* 璁㈠崟杩斿埄绫诲瀷 杞崲 */ + Integer hongBaoType = order.getHongBaoType(); + if (HongBaoV2.TYPE_ZIGOU == hongBaoType || 2 == hongBaoType) { + // 鑷喘 + hongbaoInfo = "杩斿埄"; + order.setOrderOrigin("1"); + order.setHongBaoTypePic(CommonOrder.TYPE_FANLI); + signList.add(CommonOrder.TYPE_FANLI); + } 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) { + // 涓嬬骇鐨勫垎浜鍗曪細 鏄剧ず閭�璇� + hongbaoInfo = "濂栭噾"; + order.setOrderOrigin("3"); + order.setHongBaoTypePic(CommonOrder.TYPE_INVITE); + signList.add(CommonOrder.TYPE_INVITE); + } else if (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); + + // 鐗堟湰鍖哄垎锛�2-0-2 + if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion())) { + InviteOrderSubsidy orderSubsidy = inviteOrderSubsidyService.getByOrderNoAndType(uid, order.getOrderNo(), sourceType); + if (orderSubsidy != null) { + ClientTextStyleVO subsidyInfo = new ClientTextStyleVO(); + subsidyInfo.setContent("(琛ヨ创楼" + orderSubsidy.getMoney() + ")"); + if (orderSubsidy.getState() == InviteOrderSubsidy.STATE_SUBSIDIZED) { + subsidyInfo.setColor("#E5005C"); + } else { + subsidyInfo.setColor("#888888"); + } + order.setSubsidy(subsidyInfo); + + // 瑙i噴淇℃伅锛堥棶鍙凤級 + List<String> subsidyList = new ArrayList<String>(); + subsidyList.add("棰濆琛ヨ创鑳藉惁鑾峰緱鐢辩郴缁熺畻娉曡嚜鍔ㄥ垽鏂紝浜轰负鏃犳硶骞叉秹锛�"); + subsidyList.add("棰濆琛ヨ创鍒拌处鏃堕棿浠ュ強閲戦璇蜂互瀹為檯鍒拌处涓哄噯锛�"); + subsidyList.add("棰濆琛ヨ创浜х敓鍚庡皢浼氬湪娑堟伅-璧勯噾娑堟伅涓彁閱掍綘銆�"); + order.setSubsidyList(subsidyList); + } + } + } + + 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_BUFENSHIXIAO == hongBaoState) { + stateContent = "閮ㄥ垎澶辨晥"; + orderHongBaoState = 3; + 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_ZIGOU != hongBaoType) { + order.setSignList(signList); + } else { + // 濂栧姳璁㈠崟銆佸厤鍗� 浣跨敤璁板綍 + if (sourceType == null) { + setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, null, + signList, acceptData); + } else if (sourceType == Constant.SOURCE_TYPE_TAOBAO) { + setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, + listRecordTB, signList, acceptData); + } else if (sourceType == Constant.SOURCE_TYPE_JD) { + setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, + listRecordJD, signList, acceptData); + } else if (sourceType == Constant.SOURCE_TYPE_PDD) { + setSystemCouponRecord(order, hasRewardCoupon, exchangeCoupon, hongBaoState, hongBaoType, + listRecordPDD, signList, acceptData); + } + } + + // 鍒嗕韩銆侀個璇� 闅愯棌璁㈠崟鍙� + 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())); + } + } + } + + @Override + public Map<String, BigDecimal> countHistoryOrder(Long uid, Integer day, Integer source) { + return commonOrderMapper.countHistoryOrder(uid, day, source); + } + + @Override + public long countBonusOrderNumber(Long uid, Integer type, Integer day, String startTime, String endTime, + Integer source) { + return commonOrderMapper.countBonusOrderNumber(uid, type, day, startTime, endTime, source); + } + + @Override + public BigDecimal countBonusOrderMoney(Long uid, Integer type, Integer day, String startTime, String endTime, + Integer source) { + return commonOrderMapper.countBonusOrderMoney(uid, type, day, startTime, endTime, source); + } + + @Override + public Map<String, Object> countBonusOrderMoneyAndNumber(Long uid, Integer type, Integer day, String startTime, + String endTime, Integer source) { + return commonOrderMapper.countBonusOrderMoneyAndNumber(uid, type, day, startTime, endTime, source); + } + + @Override + public Long countUserOrderToApp(Long uid, Integer type, String startTime, String endTime, + Integer day, Integer source, Integer state, Integer stateOrder) { + return commonOrderMapper.countUserOrderToApp(uid, type, startTime, endTime, day, source, state, stateOrder); + } + + private BigDecimal getWeiQuanMoney(List<TaoBaoWeiQuanOrder> listWQ, int sourceType, Long uid) { + BigDecimal weiQuanMoney = new BigDecimal(0); + if (listWQ != null && listWQ.size() > 0) { + for (TaoBaoWeiQuanOrder weiQuanOrder : listWQ) { + String tradeId = weiQuanOrder.getOrderItemId(); + // 鏌ヨ绾㈠寘 + List<String> tradeList = new ArrayList<>(); + tradeList.add(tradeId); + List<HongBaoV2> hongBaoList = hongBaoV2Service.listBySourceTypeAndTradeIdListAndUid(sourceType, uid, + tradeList); + if (hongBaoList != null && hongBaoList.size() > 0) { + CommonOrder commonOrder = commonOrderMapper.selectBySourceTypeAndTradeId(sourceType, tradeId); + if (commonOrder != null && commonOrder.getSettlement().compareTo(new BigDecimal(0)) > 0) { + BigDecimal wqMoney = MoneyBigDecimalUtil + .mul(hongBaoList.get(0).getMoney(), weiQuanOrder.getMoney()) + .divide(commonOrder.getSettlement(), 2, BigDecimal.ROUND_UP); + if (wqMoney.compareTo(hongBaoList.get(0).getMoney()) > 0) + wqMoney = hongBaoList.get(0).getMoney(); + weiQuanMoney = weiQuanMoney.add(wqMoney); + } + } + } + } + return weiQuanMoney; + } + + + + + @Override public List<CommonOrder> listBySourceTypeAndOrderId(int sourceType, String orderId) { return commonOrderMapper.listBySourceTypeAndOrderNo(sourceType, orderId); @@ -712,8 +835,9 @@ @Transactional @Override - public List<CommonOrder> addTaoBaoOrder(List<TaoBaoOrder> taoBaoOrders, Long uid) throws CommonOrderException { - List<CommonOrder> commonOrderList = new ArrayList<>(); + public List<CommonOrderAddResultDTO> addTaoBaoOrder(List<TaoBaoOrder> taoBaoOrders, Long uid) + throws CommonOrderException { + List<CommonOrderAddResultDTO> commonOrderList = new ArrayList<>(); // 鍒ゆ柇鎵�鏈夌殑璁㈠崟鐘舵�� int invalidCount = 0; for (TaoBaoOrder tb : taoBaoOrders) { @@ -773,8 +897,9 @@ @Transactional @Override - public List<CommonOrder> addPDDOrder(List<PDDOrder> pddOrderList, Long uid) throws CommonOrderException { - List<CommonOrder> commonOrderList = new ArrayList<>(); + public List<CommonOrderAddResultDTO> addPDDOrder(List<PDDOrder> pddOrderList, Long uid) + throws CommonOrderException { + List<CommonOrderAddResultDTO> commonOrderList = new ArrayList<>(); // 鍒ゆ柇鎵�鏈夌殑璁㈠崟鐘舵�� int invalidCount = 0; for (PDDOrder order : pddOrderList) { @@ -822,8 +947,8 @@ @Transactional @Override - public List<CommonOrder> addJDOrder(JDOrder jdOrder, Long uid) throws CommonOrderException { - List<CommonOrder> commonOrderList = new ArrayList<>(); + public List<CommonOrderAddResultDTO> addJDOrder(JDOrder jdOrder, Long uid) throws CommonOrderException { + List<CommonOrderAddResultDTO> commonOrderList = new ArrayList<>(); // 鍒ゆ柇鎵�鏈夌殑璁㈠崟鐘舵�� int invalidCount = 0; for (JDOrderItem tb : jdOrder.getOrderItemList()) { @@ -891,7 +1016,7 @@ * @param commonOrder */ @Transactional - private CommonOrder addCommonOrder(CommonOrder commonOrder) throws CommonOrderException { + private CommonOrderAddResultDTO addCommonOrder(CommonOrder commonOrder) throws CommonOrderException { // 鍒ゆ柇鍟嗗搧鏄惁瀛樺湪 if (commonOrder == null) throw new CommonOrderException(1, "璁㈠崟涓虹┖"); @@ -934,13 +1059,13 @@ // 鎻掑叆鏄犲皠锛屼繚璇佷氦鏄揑D鐨勫畬鏁存�� commonOrderTradeIdMapMapper.insertSelective(new CommonOrderTradeIdMap(commonOrder.getId(), commonOrder.getTradeId(), new Date(), commonOrder.getSourceType())); - return commonOrder; + return new CommonOrderAddResultDTO(commonOrder, CommonOrderAddResultDTO.TYPE_ADD); } else {// 淇敼 - // 宸茬粡缁撶畻锛屽凡缁忓け鏁堬紝鐘舵�佹湭鏀瑰彉鐨勮鍗曚笉澶勭悊 - if (oldCommonOrder.getState() == CommonOrder.STATE_JS || oldCommonOrder.getState() == CommonOrder.STATE_SX + // 闈炰含涓滃凡缁忕粨绠楋紝宸茬粡澶辨晥锛岀姸鎬佹湭鏀瑰彉鐨勮鍗曚笉澶勭悊 + if ((oldCommonOrder.getState() == CommonOrder.STATE_JS&&oldCommonOrder.getSourceType()!=Constant.SOURCE_TYPE_JD) || oldCommonOrder.getState() == CommonOrder.STATE_SX || oldCommonOrder.getState() == CommonOrder.STATE_WQ || (oldCommonOrder.getState().intValue() == commonOrder.getState())) { - return oldCommonOrder; + return new CommonOrderAddResultDTO(oldCommonOrder, CommonOrderAddResultDTO.TYPE_NOUPDATE); } // 浜ゆ槗ID涓�鑷存墠淇敼 if (commonOrder.getTradeId() != null @@ -956,9 +1081,10 @@ updateCommonOrder.setUpdateTime(new Date()); updateCommonOrder.setTradeId(commonOrder.getTradeId()); commonOrderMapper.updateByPrimaryKeySelective(updateCommonOrder); - return commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId()); + return new CommonOrderAddResultDTO(commonOrderMapper.selectByPrimaryKey(updateCommonOrder.getId()), + CommonOrderAddResultDTO.TYPE_UPDATE); } else - return oldCommonOrder; + return new CommonOrderAddResultDTO(oldCommonOrder, CommonOrderAddResultDTO.TYPE_NOUPDATE); } } @@ -1051,7 +1177,8 @@ @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) + Integer type, Integer orderState, String startTime, String endTime, Integer source,List<Long> listShopId, + List<Long> listGoodsId, Date minTime, BigDecimal money) throws CommonOrderException { List<CommonOrderVO> list = null; @@ -1059,10 +1186,11 @@ if (StringUtil.isNullOrEmpty(key) || keyType == 1) {// 鎼滅储妗嗘棤鍊兼垨鑰呮寜璁㈠崟鍙锋悳绱㈡椂閮藉彧鎼滅储涓昏鍗� list = commonOrderMapper.listQueryWithNoChild(start, count, keyType, key, state, type, orderState, startTime, endTime, source); - } else + } else { list = commonOrderMapper.listQuery(start, count, keyType, key, state, type, orderState, startTime, endTime, - source); - + source, listShopId, listGoodsId, minTime, money); + } + if (list == null) { list = new ArrayList<CommonOrderVO>(); } @@ -1246,12 +1374,15 @@ @Override public long countQuery(Integer keyType, String key, Integer state, Integer type, Integer orderState, - String startTime, String endTime, Integer source) throws CommonOrderException { + String startTime, String endTime, Integer source, List<Long> listShopId, List<Long> listGoodsId, + Date minTime, BigDecimal money) throws CommonOrderException { if (StringUtil.isNullOrEmpty(key) || keyType == 1) {// 鎼滅储妗嗘棤鍊兼垨鑰呮寜璁㈠崟鍙锋悳绱㈡椂閮藉彧鎼滅储涓昏鍗� return commonOrderMapper.countQueryWithNoChild(keyType, key, state, type, orderState, startTime, endTime, source); - } else - return commonOrderMapper.countQuery(keyType, key, state, type, orderState, startTime, endTime, source); + } else { + return commonOrderMapper.countQuery(keyType, key, state, type, orderState, startTime, endTime, source, listShopId, + listGoodsId, minTime,money); + } } @Override @@ -1352,7 +1483,7 @@ } @Override - public JSONObject getRewardJumpInfo(String orderNo) { + public JSONObject getRewardJumpInfo(String orderNo, Integer goodsType) { JSONObject map = new JSONObject(); // 璁㈠崟鏍囪瘑 @@ -1369,6 +1500,7 @@ Map<String, Object> jumpLink = new HashMap<String, Object>(); jumpLink.put("orderNo", orderNo); + jumpLink.put("goodsType", goodsType == null? goodsType: goodsType +""); Map<String, Object> jump = new HashMap<String, Object>(); jump.put("type", 1); @@ -1429,10 +1561,54 @@ return commonOrderMapper.listBySourceTypeAndStateAndThirdCrateTime(sourceType, state, minTime, maxTime, (page - 1) * pageSize, pageSize); } - + @Override public List<CommonOrder> getByOrderNo(Long uid, String orderNO) { return commonOrderMapper.getByOrderNo(uid, orderNO); } + @Override + public CommonOrder selectLatestValidByUid(Long uid) { + List<Integer> stateList = new ArrayList<>(); + stateList.add(CommonOrder.STATE_FK); + stateList.add(CommonOrder.STATE_JS); + List<CommonOrder> commonOrderList = commonOrderMapper.listByUid(uid, stateList, 0, 1); + if (commonOrderList == null || commonOrderList.size() == 0) + return null; + return commonOrderList.get(0); + } + + + + @Override + public CommonOrderVO firstValidOrderByUid(Long uid) { + return commonOrderMapper.firstValidOrderByUid(uid, null, null); + } + + @Override + public CommonOrderVO firstValidOrderByUidAndType(Long uid, Integer type) { + return commonOrderMapper.firstValidOrderByUid(uid, type, null); + } + + + @Override + public CommonOrderVO firstValidOrderLastMonthByUidAndType(Long uid, Integer type) { + return commonOrderMapper.firstValidOrderByUid(uid, type, 4); + } + + @Override + public CommonOrder getFirstShareOrderByUid(Long uid) { + return commonOrderMapper.getFirstShareOrderByUid(uid); + } + + @Override + public BigDecimal getTotalRewardMoneyByOrderNoAndSourceType(String orderNo, Integer sourceType) { + return commonOrderMapper.getTotalRewardMoneyByOrderNoAndSourceType(orderNo, sourceType); + } + + + @Override + public long count24HValidOrderByUid(Long uid, Date minTime) { + return commonOrderMapper.count24HValidOrderByUid(uid, minTime); + } } -- Gitblit v1.8.0