|  | @@ -1,5 +1,6 @@
 | 
	
		
			
				|  |  |  package com.kmall.schedule.service;
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  | +import com.kmall.common.constant.Dict;
 | 
	
		
			
				|  |  |  import com.kmall.common.utils.*;
 | 
	
		
			
				|  |  |  import com.kmall.common.utils.wechat.*;
 | 
	
		
			
				|  |  |  import com.kmall.common.utils.wechat.wxglobal.WechatGlobalUtil;
 | 
	
	
		
			
				|  | @@ -265,47 +266,45 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |                  for (int i = 0; i < msgCount; i++) {
 | 
	
		
			
				|  |  |                      WechatRefundQueryResult querySuccessResponseDto =
 | 
	
		
			
				|  |  |                              ReaderXmlForDOM4J.parse(result.getXmlStr(), i);
 | 
	
		
			
				|  |  | -                    if (result.getReturn_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -                        if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -                            result.setRefund_success_time(querySuccessResponseDto.getRefund_success_time());
 | 
	
		
			
				|  |  | -                            result.setOut_refund_no(querySuccessResponseDto.getOut_refund_no());
 | 
	
		
			
				|  |  | -                            result.setRefund_account(querySuccessResponseDto.getRefund_account());
 | 
	
		
			
				|  |  | -                            result.setRefund_channel(querySuccessResponseDto.getRefund_channel());
 | 
	
		
			
				|  |  | -                            result.setRefund_fee(querySuccessResponseDto.getRefund_fee());
 | 
	
		
			
				|  |  | -                            result.setRefund_id(querySuccessResponseDto.getRefund_id());
 | 
	
		
			
				|  |  | -                            result.setRefund_recv_accout(querySuccessResponseDto.getRefund_recv_accout());
 | 
	
		
			
				|  |  | -                            result.setRefund_status(querySuccessResponseDto.getRefund_status());
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -                            Date successTime = DateUtils.strToDate(result.getRefund_success_time());
 | 
	
		
			
				|  |  | -                            refundRaram.put("refundTime", successTime);
 | 
	
		
			
				|  |  | -                            refundRaram.put("outRefundNo", result.getOut_refund_no());
 | 
	
		
			
				|  |  | -                            refundRaram.put("refundId", result.getRefund_id());
 | 
	
		
			
				|  |  | -                            refundRaram.put("refundMoney",
 | 
	
		
			
				|  |  | -                                    BigDecimal.valueOf(Long.valueOf(result.getRefund_fee()))
 | 
	
		
			
				|  |  | -                                            .divide(Constant.ONE_HUNDRED));
 | 
	
		
			
				|  |  | -                            if (result.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 2);
 | 
	
		
			
				|  |  | -                                refundRaram.put("wechat_refund_status_des", "退款成功");
 | 
	
		
			
				|  |  | -                            } else if (result.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 4);
 | 
	
		
			
				|  |  | -                                refundRaram.put("wechat_refund_status_des", "退款关闭");
 | 
	
		
			
				|  |  | -                            } else if (result.getRefund_status().equalsIgnoreCase("CHANGE")) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 4);
 | 
	
		
			
				|  |  | -                                refundRaram.put("wechat_refund_status_des", "退款异常");
 | 
	
		
			
				|  |  | -                            } else if (result.getRefund_status().equalsIgnoreCase("PROCESSING")) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 5);
 | 
	
		
			
				|  |  | -                                refundRaram.put("wechat_refund_status_des", "退款处理中");
 | 
	
		
			
				|  |  | -                            }
 | 
	
		
			
				|  |  | -                            refundRaram.put("refundRecvAccout", result.getRefund_recv_accout());
 | 
	
		
			
				|  |  | -                            refundRaram.put("orderRefundId", result.getOut_refund_no());
 | 
	
		
			
				|  |  | -                            qzOrderMapper.updateOrderRefund(refundRaram);//更新订单退款信息
 | 
	
		
			
				|  |  | -                        }
 | 
	
		
			
				|  |  | -                    }
 | 
	
		
			
				|  |  | +                    result.setRefund_success_time(querySuccessResponseDto.getRefund_success_time());
 | 
	
		
			
				|  |  | +                    result.setOut_refund_no(querySuccessResponseDto.getOut_refund_no());
 | 
	
		
			
				|  |  | +                    result.setRefund_account(querySuccessResponseDto.getRefund_account());
 | 
	
		
			
				|  |  | +                    result.setRefund_channel(querySuccessResponseDto.getRefund_channel());
 | 
	
		
			
				|  |  | +                    result.setRefund_fee(querySuccessResponseDto.getRefund_fee());
 | 
	
		
			
				|  |  | +                    result.setRefund_id(querySuccessResponseDto.getRefund_id());
 | 
	
		
			
				|  |  | +                    result.setRefund_recv_accout(querySuccessResponseDto.getRefund_recv_accout());
 | 
	
		
			
				|  |  | +                    result.setRefund_status(querySuccessResponseDto.getRefund_status());
 | 
	
		
			
				|  |  |                  }
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | +                Date successTime = DateUtils.strToDate(result.getRefund_success_time());
 | 
	
		
			
				|  |  | +                refundRaram.put("refundTime", successTime);
 | 
	
		
			
				|  |  | +                refundRaram.put("outRefundNo", result.getOut_refund_no());
 | 
	
		
			
				|  |  | +                refundRaram.put("refundId", result.getRefund_id());
 | 
	
		
			
				|  |  | +                refundRaram.put("refundMoney",
 | 
	
		
			
				|  |  | +                        BigDecimal.valueOf(Long.valueOf(result.getRefund_fee()))
 | 
	
		
			
				|  |  | +                                .divide(Constant.ONE_HUNDRED));
 | 
	
		
			
				|  |  |                  Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | -                orderRaram.put("payStatus", 4);
 | 
	
		
			
				|  |  | -                orderRaram.put("orderStatus", 401);
 | 
	
		
			
				|  |  | +                if (result.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | +                    refundRaram.put("refundStatus", Dict.RefundStatus.item_2.getItem());
 | 
	
		
			
				|  |  | +                    refundRaram.put("wechat_refund_status_des", "退款成功");
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_4.getItem());
 | 
	
		
			
				|  |  | +                } else if (result.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
 | 
	
		
			
				|  |  | +                    refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
 | 
	
		
			
				|  |  | +                    refundRaram.put("wechat_refund_status_des", "退款关闭");
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_5.getItem());
 | 
	
		
			
				|  |  | +                } else if (result.getRefund_status().equalsIgnoreCase("CHANGE")) {
 | 
	
		
			
				|  |  | +                    refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
 | 
	
		
			
				|  |  | +                    refundRaram.put("wechat_refund_status_des", "退款异常");
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_6.getItem());
 | 
	
		
			
				|  |  | +                } else if (result.getRefund_status().equalsIgnoreCase("PROCESSING")) {
 | 
	
		
			
				|  |  | +                    refundRaram.put("refundStatus", Dict.RefundStatus.item_5.getItem());
 | 
	
		
			
				|  |  | +                    refundRaram.put("wechat_refund_status_des", "退款处理中");
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_3.getItem());
 | 
	
		
			
				|  |  | +                }
 | 
	
		
			
				|  |  | +                refundRaram.put("refundRecvAccout", result.getRefund_recv_accout());
 | 
	
		
			
				|  |  | +                refundRaram.put("orderRefundId", result.getOut_refund_no());
 | 
	
		
			
				|  |  | +                qzOrderMapper.updateOrderRefund(refundRaram);//更新订单退款信息
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +                orderRaram.put("orderStatus", Dict.orderStatus.item_401.getItem());
 | 
	
		
			
				|  |  |                  orderRaram.put("orderId", order_id);
 | 
	
		
			
				|  |  |                  orderRaram.put("payTransactionId", result.getTransaction_id());
 | 
	
		
			
				|  |  |                  qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
	
		
			
				|  | @@ -326,6 +325,7 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |          logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalRefundQuery 微信国际退款查询接口调用");
 | 
	
		
			
				|  |  |          String out_trade_no = MapUtils.getString("merch_order_sn", map);
 | 
	
		
			
				|  |  |          String order_id = MapUtils.getString("order_id", map);
 | 
	
		
			
				|  |  | +        Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  |          WechatGlobalRefundQueryResult result = WechatGlobalUtil.wxRefundquery(out_trade_no);
 | 
	
		
			
				|  |  |          if (result.getReturn_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  |              if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
	
		
			
				|  | @@ -364,17 +364,21 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |                              refundRaram.put("cashFeeType", result.getCash_fee_type());//用户支付金额币种
 | 
	
		
			
				|  |  |                              refundRaram.put("rate", result.getRate());//汇率
 | 
	
		
			
				|  |  |                              if (result.getRefund_status().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 2);
 | 
	
		
			
				|  |  | +                                refundRaram.put("refundStatus", Dict.RefundStatus.item_2.getItem());
 | 
	
		
			
				|  |  |                                  refundRaram.put("wechat_refund_status_des", "退款成功");
 | 
	
		
			
				|  |  | +                                orderRaram.put("payStatus", Dict.payStatus.item_4.getItem());
 | 
	
		
			
				|  |  |                              } else if (result.getRefund_status().equalsIgnoreCase("PROCESSING")) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 5);
 | 
	
		
			
				|  |  | +                                refundRaram.put("refundStatus", Dict.RefundStatus.item_5.getItem());
 | 
	
		
			
				|  |  |                                  refundRaram.put("wechat_refund_status_des", "退款处理中");
 | 
	
		
			
				|  |  | +                                orderRaram.put("payStatus", Dict.payStatus.item_3.getItem());
 | 
	
		
			
				|  |  |                              } else if (result.getRefund_status().equalsIgnoreCase("REFUNDCLOSE")) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 4);
 | 
	
		
			
				|  |  | +                                refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
 | 
	
		
			
				|  |  |                                  refundRaram.put("wechat_refund_status_des", "退款关闭");
 | 
	
		
			
				|  |  | +                                orderRaram.put("payStatus", Dict.payStatus.item_5.getItem());
 | 
	
		
			
				|  |  |                              } else if (result.getRefund_status().equalsIgnoreCase("CHANGE")) {
 | 
	
		
			
				|  |  | -                                refundRaram.put("refundStatus", 4);
 | 
	
		
			
				|  |  | +                                refundRaram.put("refundStatus", Dict.RefundStatus.item_4.getItem());
 | 
	
		
			
				|  |  |                                  refundRaram.put("wechat_refund_status_des", "退款异常");
 | 
	
		
			
				|  |  | +                                orderRaram.put("payStatus", Dict.payStatus.item_6.getItem());
 | 
	
		
			
				|  |  |                              }
 | 
	
		
			
				|  |  |                              refundRaram.put("refundRecvAccout", result.getRefund_recv_accout());
 | 
	
		
			
				|  |  |                              refundRaram.put("orderRefundId", result.getOut_refund_no());
 | 
	
	
		
			
				|  | @@ -382,9 +386,7 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |                          }
 | 
	
		
			
				|  |  |                      }
 | 
	
		
			
				|  |  |                  }
 | 
	
		
			
				|  |  | -                Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | -                orderRaram.put("payStatus", 4);
 | 
	
		
			
				|  |  | -                orderRaram.put("orderStatus", 401);
 | 
	
		
			
				|  |  | +                orderRaram.put("orderStatus", Dict.orderStatus.item_401.getItem());
 | 
	
		
			
				|  |  |                  orderRaram.put("orderId", order_id);
 | 
	
		
			
				|  |  |                  orderRaram.put("payTransactionId", result.getTransaction_id());
 | 
	
		
			
				|  |  |                  qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
	
		
			
				|  | @@ -444,34 +446,65 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |          WechatRefundApiResult result = WechatUtil.wxOrderQuery(out_trade_no);
 | 
	
		
			
				|  |  |          if (result.getReturn_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -            if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode()) &&
 | 
	
		
			
				|  |  | -                    result.getTrade_state().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -                Date successTime = DateUtils.convertStringToDate(result.getTime_end(),
 | 
	
		
			
				|  |  | -                        DateUtils.DATE_TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
 | 
	
		
			
				|  |  | -                Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | -                orderRaram.put("payStatus", 2);//已支付
 | 
	
		
			
				|  |  | -                orderRaram.put("orderStatus", 201);//已支付
 | 
	
		
			
				|  |  | -                orderRaram.put("payTransactionId", result.getTransaction_id());
 | 
	
		
			
				|  |  | -                orderRaram.put("payTime", successTime);
 | 
	
		
			
				|  |  | -                orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | -                qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | -            } else if (result.getResult_code().equalsIgnoreCase("SUCCESS") &&
 | 
	
		
			
				|  |  | -                    result.getTrade_state().equalsIgnoreCase("NOTPAY")) {//订单未支付
 | 
	
		
			
				|  |  | -                Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | -                if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
 | 
	
		
			
				|  |  | -                    orderRaram.put("payStatus", 0);//支付状态未支付
 | 
	
		
			
				|  |  | -                    orderRaram.put("orderStatus", 101);//订单状态已取消
 | 
	
		
			
				|  |  | +            if (result.getResult_code().equalsIgnoreCase(WechatUtil.WXTradeState.SUCCESS.getCode()) ){
 | 
	
		
			
				|  |  | +                if(result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_SUCCESS.getItem())) {
 | 
	
		
			
				|  |  | +                    Date successTime = DateUtils.convertStringToDate(result.getTime_end(),
 | 
	
		
			
				|  |  | +                            DateUtils.DATE_TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_2.getItem());//已支付
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_201.getItem());//已支付
 | 
	
		
			
				|  |  | +                    orderRaram.put("payTransactionId", result.getTransaction_id());
 | 
	
		
			
				|  |  | +                    orderRaram.put("payTime", successTime);
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_NOTPAY.getItem())) {//订单未支付
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
 | 
	
		
			
				|  |  | +                        Map param = new HashMap();
 | 
	
		
			
				|  |  | +                        param.put("id", storeRelaId);
 | 
	
		
			
				|  |  | +                        param.put("stock_num", stock_num + number);
 | 
	
		
			
				|  |  | +                        qzOrderMapper.updateStockNum(param);//库存还原
 | 
	
		
			
				|  |  | +                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
 | 
	
		
			
				|  |  | +                        orderRaram.put("orderStatus", Dict.orderStatus.item_101.getItem());//订单状态已取消
 | 
	
		
			
				|  |  | +                    } else {
 | 
	
		
			
				|  |  | +                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
 | 
	
		
			
				|  |  | +                        orderRaram.put("orderStatus", Dict.orderStatus.item_0.getItem());//订单状态未支付
 | 
	
		
			
				|  |  | +                    }
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_CLOSED.getItem())) {
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_7.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_500.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  |                      Map param = new HashMap();
 | 
	
		
			
				|  |  |                      param.put("id", storeRelaId);
 | 
	
		
			
				|  |  |                      param.put("stock_num", stock_num + number);
 | 
	
		
			
				|  |  | -                    qzOrderMapper.updateStockNum(param);
 | 
	
		
			
				|  |  | -                } else {
 | 
	
		
			
				|  |  | -                    orderRaram.put("payStatus", 0);//支付状态未支付
 | 
	
		
			
				|  |  | -                    orderRaram.put("orderStatus", 0);//订单状态未支付
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateStockNum(param);//库存还原
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + result.getTrade_state_desc() + "】");
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_PAYERROR.getItem())) {
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_8.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_501.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + result.getTrade_state_desc() + "】");
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_USERPAYING.getItem())) {
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_1.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_100.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + result.getTrade_state_desc() + "】");
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_REVOKED.getItem())) {
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + result.getTrade_state_desc() + "】");
 | 
	
		
			
				|  |  |                  }
 | 
	
		
			
				|  |  | -                orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | -                qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | -            } else {
 | 
	
		
			
				|  |  | +            }else {
 | 
	
		
			
				|  |  |                  logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回失败信息:code 【" + result.getErr_code() +
 | 
	
		
			
				|  |  |                          "】,des【" + result.getErr_code_des() + "】");
 | 
	
		
			
				|  |  |              }
 | 
	
	
		
			
				|  | @@ -497,40 +530,71 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |  
 | 
	
		
			
				|  |  |          WechatGlobalQueryApiResult result = WechatGlobalUtil.wxOrderQuery(out_trade_no);
 | 
	
		
			
				|  |  |          if (result.getReturn_code().equalsIgnoreCase(WechatGlobalUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -            if (result.getResult_code().equalsIgnoreCase(WechatGlobalUtil.WXTradeState.SUCCESS.getCode()) &&
 | 
	
		
			
				|  |  | -                    result.getTrade_state().equalsIgnoreCase(WechatGlobalUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | -                Date successTime = DateUtils.convertStringToDate(result.getTime_end(),
 | 
	
		
			
				|  |  | -                        DateUtils.DATE_TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
 | 
	
		
			
				|  |  | -                Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | -                orderRaram.put("payStatus", 2);//已支付
 | 
	
		
			
				|  |  | -                orderRaram.put("orderStatus", 201);//已支付
 | 
	
		
			
				|  |  | -                orderRaram.put("payTransactionId", result.getTransaction_id());
 | 
	
		
			
				|  |  | -                orderRaram.put("payTime", successTime);
 | 
	
		
			
				|  |  | -                orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | -
 | 
	
		
			
				|  |  | -                orderRaram.put("totalFee", result.getTotal_fee());//标价金额
 | 
	
		
			
				|  |  | -                orderRaram.put("feeType", result.getFee_type());//标价币种
 | 
	
		
			
				|  |  | -                orderRaram.put("cashFee", result.getCash_fee());//用户支付金额
 | 
	
		
			
				|  |  | -                orderRaram.put("cashFeeType", result.getCash_fee_type());//用户支付金额币种
 | 
	
		
			
				|  |  | -                orderRaram.put("rate", result.getRate());//汇率
 | 
	
		
			
				|  |  | -                qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | -            } else if (result.getResult_code().equalsIgnoreCase(WechatGlobalUtil.WXTradeState.SUCCESS.getCode()) &&
 | 
	
		
			
				|  |  | -                    result.getTrade_state().equalsIgnoreCase("NOTPAY")) {//订单未支付
 | 
	
		
			
				|  |  | -                Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | -                if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
 | 
	
		
			
				|  |  | +            if (result.getResult_code().equalsIgnoreCase(WechatGlobalUtil.WXTradeState.SUCCESS.getCode())) {
 | 
	
		
			
				|  |  | +                if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_SUCCESS.getItem())) {
 | 
	
		
			
				|  |  | +                    Date successTime = DateUtils.convertStringToDate(result.getTime_end(),
 | 
	
		
			
				|  |  | +                            DateUtils.DATE_TIME_PATTERN_YYYY_MM_DD_HH_MM_SS);
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_2.getItem());//已支付
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_201.getItem());//已支付
 | 
	
		
			
				|  |  | +                    orderRaram.put("payTransactionId", result.getTransaction_id());
 | 
	
		
			
				|  |  | +                    orderRaram.put("payTime", successTime);
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +
 | 
	
		
			
				|  |  | +                    orderRaram.put("totalFee", result.getTotal_fee());//标价金额
 | 
	
		
			
				|  |  | +                    orderRaram.put("feeType", result.getFee_type());//标价币种
 | 
	
		
			
				|  |  | +                    orderRaram.put("cashFee", result.getCash_fee());//用户支付金额
 | 
	
		
			
				|  |  | +                    orderRaram.put("cashFeeType", result.getCash_fee_type());//用户支付金额币种
 | 
	
		
			
				|  |  | +                    orderRaram.put("rate", result.getRate());//汇率
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_NOTPAY.getItem())) {//订单未支付
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    if (getDateBetween(addTime, nowDate) >= 15) {//订单下单时间超过15分钟直接取消订单
 | 
	
		
			
				|  |  | +                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
 | 
	
		
			
				|  |  | +                        orderRaram.put("orderStatus", Dict.orderStatus.item_101.getItem());//订单状态已取消
 | 
	
		
			
				|  |  | +                        Map param = new HashMap();
 | 
	
		
			
				|  |  | +                        param.put("id", storeRelaId);
 | 
	
		
			
				|  |  | +                        param.put("stock_num", stock_num + number);
 | 
	
		
			
				|  |  | +                        qzOrderMapper.updateStockNum(param);
 | 
	
		
			
				|  |  | +                    } else {
 | 
	
		
			
				|  |  | +                        orderRaram.put("payStatus", Dict.payStatus.item_0.getItem());//支付状态未支付
 | 
	
		
			
				|  |  | +                        orderRaram.put("orderStatus", Dict.orderStatus.item_0.getItem());//订单状态未支付
 | 
	
		
			
				|  |  | +                    }
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_PAYERROR.getItem())) {
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_501.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_8.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + Dict.tradeState.item_PAYERROR.getItemName() + "】");
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_CLOSED.getItem())) {
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_7.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_500.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  |                      Map param = new HashMap();
 | 
	
		
			
				|  |  |                      param.put("id", storeRelaId);
 | 
	
		
			
				|  |  |                      param.put("stock_num", stock_num + number);
 | 
	
		
			
				|  |  | -                    qzOrderMapper.updateStockNum(param);
 | 
	
		
			
				|  |  | -                    orderRaram.put("payStatus", 0);//支付状态未支付
 | 
	
		
			
				|  |  | -                    orderRaram.put("orderStatus", 101);//订单状态已取消
 | 
	
		
			
				|  |  | -                } else {
 | 
	
		
			
				|  |  | -                    orderRaram.put("payStatus", 0);//支付状态未支付
 | 
	
		
			
				|  |  | -                    orderRaram.put("orderStatus", 0);//订单状态未支付
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateStockNum(param);//库存还原
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + Dict.tradeState.item_CLOSED.getItemName() + "】");
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_USERPAYING.getItem())) {
 | 
	
		
			
				|  |  | +                    Map orderRaram = new HashMap();
 | 
	
		
			
				|  |  | +                    orderRaram.put("payStatus", Dict.payStatus.item_1.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderStatus", Dict.orderStatus.item_100.getItem());
 | 
	
		
			
				|  |  | +                    orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | +                    qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + Dict.tradeState.item_USERPAYING.getItemName() + "】");
 | 
	
		
			
				|  |  | +                } else if (result.getTrade_state().equalsIgnoreCase(Dict.tradeState.item_REVOKED.getItem())) {
 | 
	
		
			
				|  |  | +                    logger.info(">>>>>>>>>>>>>>>>>>>>wxOrderQuery 微信查询接口返回信息:state 【" + result.getTrade_state() +
 | 
	
		
			
				|  |  | +                            "】,des【" + Dict.tradeState.item_REVOKED.getItemName() + "】");
 | 
	
		
			
				|  |  |                  }
 | 
	
		
			
				|  |  | -                orderRaram.put("orderId", orderId);
 | 
	
		
			
				|  |  | -                qzOrderMapper.updateOrderInfo(orderRaram);
 | 
	
		
			
				|  |  | -            } else {
 | 
	
		
			
				|  |  | +            }else {
 | 
	
		
			
				|  |  |                  logger.info(">>>>>>>>>>>>>>>>>>>>wxGlobalOrderQuery 微信查询接口返回失败信息:code 【" + result.getErr_code() +
 | 
	
		
			
				|  |  |                          "】,des【" + result.getErr_code_des() + "】");
 | 
	
		
			
				|  |  |              }
 | 
	
	
		
			
				|  | @@ -651,7 +715,7 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |      public void shipmentOrderAutoTakeGoods() {
 | 
	
		
			
				|  |  |          logger.info(">>>>>>>>>>>>>>>>>>>>shipmentOrderAutoTakeGoods is start ");
 | 
	
		
			
				|  |  |          logger.info(">>>>>>>>>>>>>>>>>>>>商品发货后7天自动确认收货 ");
 | 
	
		
			
				|  |  | -        // 查询门店业务发货后7天的订单
 | 
	
		
			
				|  |  | +        // 查询门店业务发货后7天的订单,门店业务根据清关完成时间后7天
 | 
	
		
			
				|  |  |          List<Map> shipmentOrderList = qzOrderMapper.queryShipmentOrderList();
 | 
	
		
			
				|  |  |          if (null != shipmentOrderList && shipmentOrderList.size() > 0) {
 | 
	
		
			
				|  |  |              for (Map map : shipmentOrderList) {
 | 
	
	
		
			
				|  | @@ -660,7 +724,7 @@ public class QzOrderService {
 | 
	
		
			
				|  |  |                  qzOrderMapper.updateShipmentOrder(orderMap);
 | 
	
		
			
				|  |  |              }
 | 
	
		
			
				|  |  |          }
 | 
	
		
			
				|  |  | -        //查询保税备货发货后7天的订单
 | 
	
		
			
				|  |  | +        //查询保税备货发货后7天的订单,保税备货根据发货完成时间后7天
 | 
	
		
			
				|  |  |          List<Map> shipmentBondedOrderList = qzOrderMapper.queryShipmentBondedOrderList();
 | 
	
		
			
				|  |  |          if (null != shipmentBondedOrderList && shipmentBondedOrderList.size() > 0) {
 | 
	
		
			
				|  |  |              for (Map map : shipmentBondedOrderList) {
 |