优化 退款 调用银联接口

java110-core/src/main/java/com/java110/core/factory/GenerateCodeFactory.java

@@ -221,8 +221,6 @@ public class GenerateCodeFactory {
     public static final String CODE_PREFIX_dataId = "81";
 
 
-
-
     /**
      * 只有在不调用服务生成ID时有用
      */
@@ -979,9 +977,9 @@ public class GenerateCodeFactory {
         return result;
     }
 
-    public static String getUUID(){
+    public static String getUUID() {
         UUID uuid = UUID.randomUUID();
-        return uuid.toString();
+        return uuid.toString().replaceAll("-", "");
     }
 
 }

java110-utils/src/main/java/com/java110/utils/constant/DomainContant.java

@@ -33,6 +33,11 @@ public class DomainContant {
     public final static String COMMON_DOMAIN = "DOMAIN.COMMON";
 
 
+    /**
+     * 公用域
+     */
+    public final static String CHINA_UMS_DOMAIN = "DOMAIN.CHINA_UMS";
+
     /**
      * 商户类型对应 权限组 管理员
      *

service-front/src/main/java/com/java110/front/smo/payment/adapt/chinaums/ChinaUmsOweFeeToNotifyAdapt.java

@@ -128,7 +128,7 @@ public class ChinaUmsOweFeeToNotifyAdapt implements IOweFeeToNotifyAdapt {
             throw new IllegalArgumentException("鉴权失败");
         }
         JSONObject billPayment = JSONObject.parseObject(map.getString("billPayment"));
-        String orderId = billPayment.get("merOrderId").toString();
+        String orderId = billPayment.get("merOrderId").toString().substring(4);
         String order = CommonCache.getAndRemoveValue(FeeDto.REDIS_PAY_OWE_FEE + orderId);
 
         if (StringUtil.isEmpty(order)) {

service-front/src/main/java/com/java110/front/smo/payment/adapt/chinaums/ChinaUmsPayAdapt.java

@@ -152,7 +152,7 @@ public class ChinaUmsPayAdapt implements IPayAdapt {
         paramMap.put("mid", smallWeChatDto.getMchId()); // 富友分配给二级商户的商户号
         paramMap.put("tid", "88880001"); //终端号
         paramMap.put("instMid", "YUEDANDEFAULT");
-        paramMap.put("merOrderId", orderNum);
+        paramMap.put("merOrderId", "1017"+orderNum);
         paramMap.put("totalAmount", PayUtil.moneyToIntegerStr(payAmount));
         paramMap.put("notifyUrl", notifyUrl + "?wId=" + WechatFactory.getWId(smallWeChatDto.getAppId()));
         paramMap.put("tradeType", tradeType);

service-job/src/main/java/com/java110/job/adapt/fee/ReturnPayFeeToChinaUmsAdapt.java

@@ -0,0 +1,186 @@
+package com.java110.job.adapt.fee;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.java110.core.factory.ChinaUmsFactory;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.community.CommunityDto;
+import com.java110.dto.fee.FeeDetailDto;
+import com.java110.dto.order.BusinessDto;
+import com.java110.dto.order.OrderDto;
+import com.java110.dto.returnPayFee.ReturnPayFeeDto;
+import com.java110.dto.smallWeChat.SmallWeChatDto;
+import com.java110.entity.order.Business;
+import com.java110.intf.community.ICommunityInnerServiceSMO;
+import com.java110.intf.fee.IFeeDetailInnerServiceSMO;
+import com.java110.intf.fee.IFeeInnerServiceSMO;
+import com.java110.intf.fee.IReturnPayFeeInnerServiceSMO;
+import com.java110.intf.order.IOrderInnerServiceSMO;
+import com.java110.intf.store.ISmallWeChatInnerServiceSMO;
+import com.java110.intf.store.ISmallWechatAttrInnerServiceSMO;
+import com.java110.job.adapt.DatabusAdaptImpl;
+import com.java110.po.fee.ReturnPayFeePo;
+import com.java110.utils.cache.MappingCache;
+import com.java110.utils.constant.DomainContant;
+import com.java110.utils.util.Assert;
+import com.java110.utils.util.DateUtil;
+import com.java110.utils.util.PayUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 退费审核通过后 通知 银联支付平台退款处理
+ *
+ * @author fqz
+ * @Date 2021-08-19 10:12
+ */
+@Component(value = "returnPayFeeToChinaUmsAdapt")
+public class ReturnPayFeeToChinaUmsAdapt extends DatabusAdaptImpl {
+
+    @Autowired
+    private IFeeInnerServiceSMO feeInnerServiceSMOImpl;
+
+    @Autowired
+    private IFeeDetailInnerServiceSMO feeDetailInnerServiceSMOImpl;
+
+    @Autowired
+    private IReturnPayFeeInnerServiceSMO returnPayFeeInnerServiceSMOImpl;
+
+    @Autowired
+    private ICommunityInnerServiceSMO communityInnerServiceSMO;
+
+    @Autowired
+    private ISmallWechatAttrInnerServiceSMO smallWechatAttrInnerServiceSMOImpl;
+
+    @Autowired
+    private ISmallWeChatInnerServiceSMO smallWeChatInnerServiceSMOImpl;
+
+    @Autowired
+    private IOrderInnerServiceSMO orderInnerServiceSMOImpl;
+
+    @Autowired
+    private RestTemplate outRestTemplate;
+
+    public static final String chinaUmsReturnUrl = "chinaUmsReturnUrl";
+
+    private static Logger logger = LoggerFactory.getLogger(ReturnPayFeeToChinaUmsAdapt.class);
+
+    //模板信息推送地址
+    private static String sendMsgUrl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=";
+
+    @Override
+    public void execute(Business business, List<Business> businesses) {
+        JSONObject data = business.getData();
+        JSONArray businessReturnPayFees = null;
+        if (data.containsKey(ReturnPayFeePo.class.getSimpleName())) {
+            Object bObj = data.get(ReturnPayFeePo.class.getSimpleName());
+            if (bObj instanceof JSONObject) {
+                businessReturnPayFees = new JSONArray();
+                businessReturnPayFees.add(bObj);
+            } else if (bObj instanceof Map) {
+                businessReturnPayFees = new JSONArray();
+                businessReturnPayFees.add(JSONObject.parseObject(JSONObject.toJSONString(bObj)));
+            } else if (bObj instanceof List) {
+                businessReturnPayFees = JSONArray.parseArray(JSONObject.toJSONString(bObj));
+            } else {
+                businessReturnPayFees = (JSONArray) bObj;
+            }
+        } else {
+            return;
+        }
+
+        if (businessReturnPayFees == null) {
+            return;
+        }
+        for (int bReturnPayFeeIndex = 0; bReturnPayFeeIndex < businessReturnPayFees.size(); bReturnPayFeeIndex++) {
+            JSONObject businessReturnPayFee = businessReturnPayFees.getJSONObject(bReturnPayFeeIndex);
+            doPayFeeToChinaUms(business, businessReturnPayFee);
+        }
+    }
+
+    /**
+     * 通知退款
+     *
+     * @param business
+     * @param businessReturnPayFee
+     */
+    public void doPayFeeToChinaUms(Business business, JSONObject businessReturnPayFee) {
+
+        Assert.hasKeyAndValue(businessReturnPayFee, "returnFeeId", "未包含退费ID");
+        Assert.hasKeyAndValue(businessReturnPayFee, "communityId", "未包含小区ID");
+        //查询小区信息
+        CommunityDto communityDto = new CommunityDto();
+        communityDto.setCommunityId(businessReturnPayFee.getString("communityId"));
+        List<CommunityDto> communityDtos = communityInnerServiceSMO.queryCommunitys(communityDto);
+        Assert.listOnlyOne(communityDtos, "查询小区错误！");
+
+        //校验退费审核是否为通过
+        ReturnPayFeeDto returnPayFeeDto = new ReturnPayFeeDto();
+        returnPayFeeDto.setReturnFeeId(businessReturnPayFee.getString("returnFeeId"));
+        returnPayFeeDto.setCommunityId(businessReturnPayFee.getString("communityId"));
+        returnPayFeeDto.setState("1100");
+        List<ReturnPayFeeDto> returnPayFeeDtos = returnPayFeeInnerServiceSMOImpl.queryReturnPayFees(returnPayFeeDto);
+
+        if (returnPayFeeDtos == null || returnPayFeeDtos.size() < 1) {
+            return;//说明没有退款成功
+        }
+
+        //查询缴费明细表
+        FeeDetailDto feeDetailDto = new FeeDetailDto();
+        feeDetailDto.setDetailId(returnPayFeeDtos.get(0).getDetailId());
+        feeDetailDto.setCommunityId(returnPayFeeDtos.get(0).getCommunityId());
+        List<FeeDetailDto> feeDetailDtos = feeDetailInnerServiceSMOImpl.queryFeeDetails(feeDetailDto);
+
+        Assert.listOnlyOne(feeDetailDtos, "缴费明细不存在");
+
+        //查询缴费订单号
+        BusinessDto businessDto = new BusinessDto();
+        businessDto.setbId(feeDetailDtos.get(0).getbId());
+        List<OrderDto> orderDtos = orderInnerServiceSMOImpl.queryOrderByBId(businessDto);
+
+        Assert.listOnlyOne(orderDtos, "订单不存在");
+
+        //查询公众号配置
+        SmallWeChatDto smallWeChatDto = new SmallWeChatDto();
+        smallWeChatDto.setObjType(SmallWeChatDto.OBJ_TYPE_COMMUNITY);
+        smallWeChatDto.setObjId(communityDto.getCommunityId());
+        List<SmallWeChatDto> smallWeChatDtos = smallWeChatInnerServiceSMOImpl.querySmallWeChats(smallWeChatDto);
+        if (smallWeChatDto == null || smallWeChatDtos.size() <= 0) {
+            logger.info("未配置微信公众号信息,定时任务执行结束");
+            return;
+        }
+
+
+        JSONObject paramMap = new JSONObject();
+        paramMap.put("requestTimestamp", DateUtil.getNow(DateUtil.DATE_FORMATE_STRING_A));
+        paramMap.put("msgId", GenerateCodeFactory.getUUID()); // 富友分配给二级商户的商户号
+        paramMap.put("mid", smallWeChatDtos.get(0).getMchId()); // 富友分配给二级商户的商户号
+        paramMap.put("tid", "88880001"); //终端号
+        paramMap.put("instMid", "YUEDANDEFAULT");
+        paramMap.put("merOrderId", "1017" + orderDtos.get(0).getoId());
+        paramMap.put("refundOrderId", feeDetailDtos.get(0).getDetailId());
+        paramMap.put("refundAmount", PayUtil.moneyToIntegerStr(Double.parseDouble(feeDetailDtos.get(0).getReceivedAmount())));
+
+
+        logger.debug("调用支付统一下单接口" + paramMap.toJSONString());
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json");
+        headers.add("Authorization", ChinaUmsFactory.getAccessToken());
+        HttpEntity httpEntity = new HttpEntity(paramMap.toJSONString(), headers);
+        ResponseEntity<String> responseEntity = outRestTemplate.exchange(
+                MappingCache.getValue(DomainContant.CHINA_UMS_DOMAIN, chinaUmsReturnUrl), HttpMethod.POST, httpEntity, String.class);
+
+        logger.debug("退款 请求报文：" + paramMap.toJSONString() + ",返回报文：" + responseEntity);
+
+    }
+}