提交微信小程序多次推送问题

hai-cweb/src/main/java/com/cweb/controller/pay/CzOrderController.java

@@ -121,16 +121,19 @@ public class CzOrderController {
 
             // 判断是否充值成功
             if (dataObject.getInteger("status") == 3) {
-                new Thread(() -> {
-                    HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId());
-                    WxMsgConfig.rechargedSuccess(
-                            rechargeOrder.getRechargeContent() + "充值成功",
-                            String.valueOf(rechargeOrder.getPayRealPrice()),
-                            rechargeOrder.getOrderNo(),
-                            rechargeOrder.getFinishTime(),
-                            RechargePayType.getNameByType(rechargeOrder.getPayType()),
-                            highUser.getOpenId());
-                }).start();
+                if (rechargeOrder.getRechargeStatus() ==201) {
+                    new Thread(() -> {
+                        HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId());
+                        WxMsgConfig.rechargedSuccess(
+                                rechargeOrder.getRechargeContent() + "充值成功",
+                                String.valueOf(rechargeOrder.getPayRealPrice()),
+                                rechargeOrder.getOrderNo(),
+                                rechargeOrder.getFinishTime(),
+                                RechargePayType.getNameByType(rechargeOrder.getPayType()),
+                                highUser.getOpenId());
+                    }).start();
+                }
+
                 childOrder.setStatus(101);
                 rechargeOrder.setRechargeStatus(202);
                 rechargeOrder.setPayStatus(100);
@@ -188,16 +191,19 @@ public class CzOrderController {
 
             // 判断是否充值成功
             if (state == 1) {
-                new Thread(() -> {
-                    HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId());
-                    WxMsgConfig.rechargedSuccess(
-                            rechargeOrder.getRechargeContent() + "充值成功",
-                            String.valueOf(rechargeOrder.getPayRealPrice()),
-                            rechargeOrder.getOrderNo(),
-                            rechargeOrder.getFinishTime(),
-                            RechargePayType.getNameByType(rechargeOrder.getPayType()),
-                            highUser.getOpenId());
-                }).start();
+
+                if (rechargeOrder.getRechargeStatus() ==201) {
+                    new Thread(() -> {
+                        HighUser highUser = highUserService.findByUserId(rechargeOrder.getUserId());
+                        WxMsgConfig.rechargedSuccess(
+                                rechargeOrder.getRechargeContent() + "充值成功",
+                                String.valueOf(rechargeOrder.getPayRealPrice()),
+                                rechargeOrder.getOrderNo(),
+                                rechargeOrder.getFinishTime(),
+                                RechargePayType.getNameByType(rechargeOrder.getPayType()),
+                                highUser.getOpenId());
+                    }).start();
+                }
                 childOrder.setStatus(101);
                 rechargeOrder.setRechargeStatus(202);
                 rechargeOrder.setPayStatus(100);