退款任务接口

mp-quartz/src/main/java/com/qs/mp/quartz/task/OperateToolTask.java

@@ -3,6 +3,7 @@ package com.qs.mp.quartz.task;
 import com.qs.mp.common.enums.MqTopicType;
 import com.qs.mp.common.pulsar.PulsarClientService;
 import com.qs.mp.common.utils.LogUtil;
+import com.qs.mp.pay.service.IWalletService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -22,6 +23,9 @@ public class OperateToolTask {
   @Autowired
   private PulsarClientService pulsarClientService;
 
+  @Autowired
+  private IWalletService walletService;
+
   /**
    * 重新发送消息
    */
@@ -36,4 +40,19 @@ public class OperateToolTask {
 
     LogUtil.info(logger, "...重新发送盲票支付消息任务结束...");
   }
+
+
+  /**
+   * 退款
+   * @param orderNo
+   * @param refundAmount
+   */
+  public void refund(String orderNo, Integer refundAmount){
+    LogUtil.info(logger, "...退款任务开始...");
+
+    walletService.refund(orderNo, refundAmount);
+
+    LogUtil.info(logger, "...退款任务结束...");
+
+  }
 }

mp-quartz/src/main/java/com/qs/mp/quartz/task/PayTask.java

@@ -1,31 +0,0 @@
-package com.qs.mp.quartz.task;
-
-import com.qs.mp.pay.service.IPayOrderService;
-import com.qs.mp.pay.service.IWalletService;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
-
-/**
- * 支付相关任务
- * @author Cup
- * @date 2022/4/20
- */
-@Component("payTask")
-public class PayTask {
-
-    protected final Logger logger = LoggerFactory.getLogger(this.getClass().getSimpleName());
-
-
-    @Autowired
-    private IWalletService walletService;
-
-    @Autowired
-    private IPayOrderService payOrderService;
-
-    public void refund(String orderNo, Integer refundAmount){
-        walletService.refund(orderNo, refundAmount);
-    }
-
-}

mp-service/src/main/java/com/qs/mp/pay/service/impl/WalletServiceImpl.java

@@ -133,18 +133,16 @@ public class WalletServiceImpl implements IWalletService {
 
     JSONObject sendData = new JSONObject();
     sendData.put("shop_no", userPayShopNo);
-    sendData.put("timestamp",DateUtils.getTime());
+    sendData.put("timestamp",System.currentTimeMillis());
     sendData.put("order_no",orderNo);
     sendData.put("refund_amount", refundAmount);
     sendData.put("order_remark", "测试退款");
     sendData.put("type","sno");
     sendData.put("sign",userPaySign);
-    LogUtil.error(logger, "sendData:" + sendData.toJSONString());
     System.err.println(sendData.toJSONString());
     String result = OkHttpUtil.postJsonParams(reqUrl, sendData.toJSONString());
-    LogUtil.error(logger, "result:" + result);
     System.err.println(result);
-    return false;
+    return true;
   }
 
   @Override