新增 未接单的退款售后处理逻辑

assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/enums/PayRefundStatus.java

@@ -19,7 +19,8 @@ public enum PayRefundStatus {
     /**
      * 额外状态码 用于判断逻辑,
      */
-    NOT_SUFFICIENT_FUNDS(8200201,"余额不足");
+    NOT_SUFFICIENT_FUNDS(8200201,"余额不足"),
+    COMPATIBILITY_STATUS(9999999,"兼容爱马哥报错");
 
     private Integer code;
     private String desc;

order-application-service/src/main/java/cn/freemud/enums/ResponseResult.java

@@ -206,6 +206,7 @@ public enum ResponseResult {
      */
     PAY_BACKEND_CONFIG_ERROR("58003", "支付交易异常","Abnormal payment transaction"),
     PAY_SVC_CONFIG_ERROR("58004", "不支持储值卡支付",""),
+    PAY_REFUND_ERROR("58005", "退款已受理,请等待",""),
     /**
      * 优惠券活动
      */

order-application-service/src/main/java/cn/freemud/service/impl/OrderServiceImpl.java

@@ -2018,9 +2018,9 @@ public class OrderServiceImpl implements Orderservice {
                 BaseResponse baseResponse = partnerNoTakeOrder(orderRefundVo, orderBean, orderId, AfterSalesType.USER_CANCEL, isRefundDeliveryFee);
                 if (baseResponse != null) {
                     return baseResponse;
-                }
-                // 删除订单 通知活动添加商品库存
+                }   // 删除订单 通知活动添加商品库存
                 orderQueueService.backOrdersStatusChange(orderBean.getOid(), orderBean.getStatus(), orderBean.getPayStatus());
+
             } else {
                 CancelOrderRequest cancelOrderRequest = new CancelOrderRequest();
                 cancelOrderRequest.setPartnerId(orderBean.getCompanyId());
@@ -2074,50 +2074,24 @@ public class OrderServiceImpl implements Orderservice {
         String partnerId = orderBean.getCompanyId();
         int state = PayRefundStatus.SUCCESS.getCode();
         if (orderBean.getAmount() != 0) {
-            if (null != orderBean.getOrderPayItem() && orderBean.getOrderPayItem().size() > 0) {
-                //调用支付退款
-                MultiOrderRefundRequest multiOrderRefundRequest = orderAdapter.getMultiOrderPayRefundRequest(orderBean, refundId);
-                MultiOrderRefundResponse multiOrderRefundResponse = payServiceImpl.paymentApplicationRefund(multiOrderRefundRequest, orderBean.getCompanyId());
-                if (multiOrderRefundResponse == null || multiOrderRefundResponse.getData() == null || !com.freemud.sdk.api.assortment.order.domain.ResponseCodeConstant.ORDER_PAY_RESPONSE_SUCCESS.equals(multiOrderRefundResponse.getCode())) {
-                    return ResponseUtil.error(ResponseResult.MULTIORDER__ERRORREFUND.getCode(), "multiOrderRefund_failed");
-                }
-                List<MultiOrderRefundResponse.RefundPlatformResponse> refundPlatformResponseList = multiOrderRefundResponse.getData().refundPlatformResponseList;
-                if (null != refundPlatformResponseList && refundPlatformResponseList.size() > 0) {
-                    redisCache.save(RedisUtil.getPaymentTransIdSequenceKey(refundPlatformResponseList.get(0).getTransId()), orderBean.getOid(), 1L, TimeUnit.DAYS);
-                }
-                //获取支付返回退款状态
-                state = PayRefundStatus.SUCCESS.getCode();
-            } else {
-                OrderExtendedReq ext = orderBean.getOrderExtended();
-                if (StringUtils.isNotBlank(ext.getAgentPayerId()) && !Objects.equals(ext.getAgentPayerId(), orderBean.getUserId())) {
-                    //代付人信息不为空  并且和订单创建人不一样，表示代付单
-                    PayRefundResponse resp = paymentHandle.agentPayRefund(orderBean);
-                    state = resp.getPayRefundStatus().getCode();
-                } else {
-                    //调用支付退款
-                    PayRefundRequestDto orderPayRefundRequest = orderAdapter.getOrderPayRefundRequest(orderBean, refundId, fatherOrderId);
-                    //抖音支付退款必传
-                    orderPayRefundRequest.setRefundDesc(orderRefundVo.getReason() == null ? "用户退款" : orderRefundVo.getReason());
-                    response = payServiceImpl.orderRefund(orderPayRefundRequest);
-                    if (response == null || response.getData() == null || !com.freemud.sdk.api.assortment.order.domain.ResponseCodeConstant.RESPONSE_SUCCESS_STR.equals(response.getCode())) {
-                        return ResponseUtil.error(ResponseResult.ORDER__ERRORREFUND.getCode(), "orderRefund_failed");
-                    }
-                    //获取支付返回退款状态
-                    state = response.getData().getRefundStatus() == null ? PayRefundStatus.SUCCESS.getCode() : response.getData().getRefundStatus();
-                }
-            }
+            OrderManagerRequest orderManagerRequest = new OrderManagerRequest();
+            orderManagerRequest.setReason(orderRefundVo.getReason());
+            PayRefundResponse refundResponse = paymentHandle.getCommonPayRefundResponse(orderManagerRequest, orderBean);
+            state = refundResponse.getPayRefundStatus().getCode();
         }
 
         CancelOrderRequest cancelOrderRequest = orderAdapter.convent2CancelOrderRequest(orderBean.getOid(),
                 partnerId, afterSalesType, orderRefundVo.getReason(), LogThreadLocal.getTrackingNo(), refundId.toString());
         cancelOrderRequest.setOperator(orderBean.getUserName());
         cancelOrderRequest.setPartnerId(orderBean.getCompanyId());
-        if (Objects.equals(PayRefundStatus.RUNNING.getCode(), state)) {
+        if (Objects.equals(PayRefundStatus.FAIL.getCode(), state)) {
             // 退款中
             cancelOrderRequest.setCreateEvent(AfterSalesOrderCreateEventEnum.RETURN_COMPLETE.getCreateEvent());
         } else if (Objects.equals(PayRefundStatus.SUCCESS.getCode(), state)) {
             //退款成功
             cancelOrderRequest.setCreateEvent(AfterSalesOrderCreateEventEnum.REFUND_COMPLETE.getCreateEvent());
+        } else if (Objects.equals(PayRefundStatus.RUNNING.getCode(), state)) {
+            cancelOrderRequest.setCreateEvent(null);
         }
         cancelOrderRequest.setReqRemark(orderRefundVo.getRemarks());
         cancelOrderRequest.setRefundDeliveryAmount(isRefundDeliveryFee);
@@ -2130,6 +2104,11 @@ public class OrderServiceImpl implements Orderservice {
         if (baseOrderResponse == null || !ObjectUtils.equals(ResponseConstant.SUCCESS_RESPONSE_CODE, baseOrderResponse.getErrcode())) {
             return ResponseUtil.error(ResponseResult.ORDER__ERRORREFUND.getCode(), "orderRefund_failed");
         }
+
+        if (state == PayRefundStatus.RUNNING.getCode().intValue()) {
+            // 如果退款中, 直接来个申请记录,  退款回调进行处理
+            return ResponseUtil.error(ResponseResult.PAY_REFUND_ERROR);
+        }
         return null;
     }
 
@@ -2336,7 +2315,7 @@ public class OrderServiceImpl implements Orderservice {
             messageTemplateRequest.setMessageEventType(messageEventType);
             com.freemud.application.sdk.api.base.BaseResponse baseResponse = this.messageTemplatePushService.sendTemplateMsg(messageTemplateRequest);
             if (!Objects.equals(baseResponse.getCode(), ResponseResultEnum.SUCCESS.getCode())) {
-                AppLogUtil.errorLog("发送支付成功模板消息 失败",orderBean.getOid(),JSON.toJSONString(baseResponse),null);
+                AppLogUtil.errorLog("发送支付成功模板消息 失败", orderBean.getOid(), JSON.toJSONString(baseResponse), null);
             }
         } catch (Exception e) {
             AppLogUtil.errorLog("sendTemplateMsg_error", JSONObject.toJSONString(orderBean), JSONObject.toJSONString(messageTemplateRequest), e);
@@ -3592,7 +3571,7 @@ public class OrderServiceImpl implements Orderservice {
                 } else {
                     resultMap.put(orderCode, resp.getMessage());
                 }
-            }catch (Exception e){
+            } catch (Exception e) {
                 resultMap.put(orderCode, e.getMessage());
             }
         });
@@ -3623,7 +3602,7 @@ public class OrderServiceImpl implements Orderservice {
             return ResponseUtil.error(ResponseResult.ORDER__ERRORREFUND.getCode(), "订单已取消，无法退款");
         }
         // fisherman 仅仅支持 餐饮类订单进行操作
-        if (BizTypeEnum.ORDINARY.getBizType().compareTo(orderBean.getBizType()) !=0) {
+        if (BizTypeEnum.ORDINARY.getBizType().compareTo(orderBean.getBizType()) != 0) {
             return ResponseUtil.error(ResponseResult.ORDER__ERRORREFUND.getCode(), "仅支持餐饮订单操作");
         }
 
@@ -3682,9 +3661,9 @@ public class OrderServiceImpl implements Orderservice {
                         Long bLong = Long.valueOf(o2.getCreateTime());
                         if (bLong > aLong) {
                             return 1;
-                        }else if (bLong < aLong){
+                        } else if (bLong < aLong) {
                             return -1;
-                        }else {
+                        } else {
                             return 0;
                         }
                     });
@@ -3931,5 +3910,4 @@ public class OrderServiceImpl implements Orderservice {
     }
 
 
-
 }

order-management/src/main/java/cn/freemud/management/entities/dto/response/pay/PayRefundResponse.java

 package cn.freemud.management.entities.dto.response.pay;
 
+import cn.freemud.management.enums.ResponseResult;
 import com.freemud.sdk.api.assortment.order.enums.PayRefundStatus;
 import lombok.Data;
 
@@ -28,4 +29,9 @@ public class PayRefundResponse {
      * 退款序列号
      */
     private String refundId;
+
+    /**
+     *  兼容爱马哥退款报错的字段 ,其他场景不会有值
+     */
+    private ResponseResult result;
 }

order-management/src/main/java/cn/freemud/management/service/handle/PaymentHandle.java

@@ -21,6 +21,7 @@ import com.freemud.application.sdk.api.log.ErrorLog;
 import com.freemud.application.sdk.api.ordercenter.entities.v1.OrderBeanV1;
 import com.freemud.application.sdk.api.ordercenter.enums.orderv1.OrderTypeV1;
 import com.freemud.application.sdk.api.ordercenter.request.OrderExtInfoDto;
+import com.freemud.application.sdk.api.ordercenter.request.OrderExtendedReq;
 import com.freemud.application.sdk.api.ordercenter.response.OrderBaseResp;
 import com.freemud.application.sdk.api.ordercenter.response.orderInfo.AfterSalesOrderResp;
 import com.freemud.application.sdk.api.ordercenter.service.OrderSdkService;
@@ -85,6 +86,32 @@ public class PaymentHandle {
     @Autowired
     private LogUtil logUtil;
 
+    public PayRefundResponse getCommonPayRefundResponse(OrderManagerRequest request, OrderBeanV1 orderBean) {
+        PayRefundResponse refundResponse;
+        try {
+            if (null != orderBean.getOrderPayItem() && orderBean.getOrderPayItem().size() > 0) {
+                //  payment/application/refund
+                refundResponse = this.multiRefund(orderBean);
+            } else {
+                OrderExtendedReq ext = orderBean.getOrderExtended();
+                if (StringUtils.isNotBlank(ext.getAgentPayerId()) && !Objects.equals(ext.getAgentPayerId(), orderBean.getUserId())) {
+                    //代付人信息不为空  并且和订单创建人不一样，表示代付单   payment/application/agentRefund
+                    refundResponse = this.agentPayRefund(orderBean);
+                } else {
+                    //正常订单现金退款  paymentcenter/refund
+                    refundResponse = this.refund(request, orderBean);
+                }
+            }
+        } catch (OrderServiceException orderEx) { // 爱马哥兼容，不抛错
+            ResponseResult result = orderEx.getResult();
+            refundResponse = new PayRefundResponse();
+            refundResponse.setPayRefundStatus(PayRefundStatus.COMPATIBILITY_STATUS);
+            refundResponse.setResult(result);
+            return refundResponse;
+        }
+        return refundResponse;
+    }
+
     /**
      * 退款
      *

order-management/src/main/java/cn/freemud/management/service/impl/SaasOrderMangerServiceImpl.java

@@ -243,25 +243,11 @@ public class SaasOrderMangerServiceImpl implements OrderManagerService {
         //取消配送单
         deliveryHandle.cancelDelivery(orderBean, request);
         //支付退款
-        PayRefundResponse refundResponse;
-        try {
-            if (null != orderBean.getOrderPayItem() && orderBean.getOrderPayItem().size() > 0) {
-                //  payment/application/refund
-                refundResponse = paymentHandle.multiRefund(orderBean);
-            } else {
-                OrderExtendedReq ext = orderBean.getOrderExtended();
-                if (StringUtils.isNotBlank(ext.getAgentPayerId()) && !Objects.equals(ext.getAgentPayerId(), orderBean.getUserId())) {
-                    //代付人信息不为空  并且和订单创建人不一样，表示代付单   payment/application/agentRefund
-                    refundResponse = paymentHandle.agentPayRefund(orderBean);
-                } else {
-                    //正常订单现金退款  paymentcenter/refund
-                    refundResponse = paymentHandle.refund(request, orderBean);
-                }
-            }
-        } catch (OrderServiceException orderEx) { // 爱马哥兼容，不抛错
-            return ResponseUtil.error(orderEx.getResult());
+        PayRefundResponse refundResponse = this.getPayRefundResponse(request, orderBean);
+        // 爱马哥报错
+        if (refundResponse.getPayRefundStatus().getCode().compareTo(PayRefundStatus.COMPATIBILITY_STATUS.getCode()) == 0) {
+            return ResponseUtil.error(refundResponse.getResult());
         }
-
         // fisherman --> 退款中的状态 阻止后续流程 等待支付回调
         if (refundResponse.getPayRefundStatus().getCode().compareTo(PayRefundStatus.RUNNING.getCode()) == 0) {
             return ResponseUtil.error(ResponseResult.REFUND_FAIL_WAIT_CALLBACK);
@@ -278,6 +264,17 @@ public class SaasOrderMangerServiceImpl implements OrderManagerService {
     }
 
     /**
+     * 提出 退款公共代码
+     *
+     * @param request
+     * @param orderBean
+     * @return
+     */
+    private PayRefundResponse getPayRefundResponse(OrderManagerRequest request, OrderBeanV1 orderBean) {
+        return paymentHandle.getCommonPayRefundResponse(request, orderBean);
+    }
+
+    /**
      * 拒绝退款
      *
      * @param request
@@ -449,7 +446,7 @@ public class SaasOrderMangerServiceImpl implements OrderManagerService {
 
         String refundStatus = request.getRefundStatus();
         PayRefundStatus payRefundStatus = PayRefundStatus.SUCCESS;
-        if (!Objects.equals(refundStatus,"100")) {
+        if (!Objects.equals(refundStatus, "100")) {
             payRefundStatus = PayRefundStatus.FAIL;
         }
         refundResponse.setPayRefundStatus(payRefundStatus);
@@ -459,9 +456,10 @@ public class SaasOrderMangerServiceImpl implements OrderManagerService {
         omRequest.setReason(reason);
         omRequest.setOperator("支付退款回调系统补偿");
         saasOrderHandle.refundAgree(omRequest, refundResponse, orderBean);
-        // 推送pos、微信消息中心
-
-        orderBaseService.sendMessage(orderBean, ORDER_AGREE_REFUND, reason);
+        // 推送pos、微信消息中心  未接单前 不需要推送pos
+        if (!NewOrderStatus.PLACE_AN_ORDER.getIndex().equals(orderBean.getStatusV2())) {
+            orderBaseService.sendMessage(orderBean, ORDER_AGREE_REFUND, reason);
+        }
         //todo  可以考虑基于订单回调异步实现
         //冲正库存
         stockHandle.revert(omRequest, orderBean);