新增账户余额充值成功微信小程序通知

src/main/java/com/sqx/modules/app/service/impl/UserMoneyServiceImpl.java

@@ -11,15 +11,20 @@ import com.sqx.modules.app.entity.*;
 import com.sqx.modules.app.service.UserMoneyDetailsService;
 import com.sqx.modules.app.service.UserMoneyService;
 
+import com.sqx.modules.common.entity.CommonInfo;
+import com.sqx.modules.common.service.CommonInfoService;
 import com.sqx.modules.order.entity.TbOrder;
+import com.sqx.modules.utils.SenInfoCheckUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Date;
+import java.util.List;
 
 @Service
 @Slf4j
@@ -37,6 +42,8 @@ public class UserMoneyServiceImpl extends ServiceImpl<UserMoneyDao, UserMoney> i
     private UserMoneyDao userMoneyDao;
     @Autowired
     private UserMoneyDetailsService userMoneyDetailsService;
+    @Autowired
+    private CommonInfoService commonInfoService;
 
     @Override
     public void updateMoney(int i, Long userId, double money) {
@@ -95,6 +102,23 @@ public class UserMoneyServiceImpl extends ServiceImpl<UserMoneyDao, UserMoney> i
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         userMoneyDetails.setCreateTime(simpleDateFormat.format(new Date()));
         userMoneyDetailsService.save(userMoneyDetails);
+
+        // 发送通知
+        try {
+            if(type.equals(1)) {
+                UserEntity userEntity = userDao.selectById(userId);
+                List<String> msgList = new ArrayList<>();
+                msgList.add(userEntity.getUserName());
+                msgList.add(money.toString());
+                msgList.add(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
+
+                CommonInfo one = commonInfoService.findOne(424);
+                SenInfoCheckUtil.sendMsg(userEntity.getOpenId(), one.getValue(), msgList, 10);
+            }
+        } catch (Exception e) {
+            log.error("充值成功消息发送失败：{}", e.getMessage());
+        }
+
         return Result.success();
     }
 

src/main/java/com/sqx/modules/utils/SenInfoCheckUtil.java

@@ -318,7 +318,9 @@ public class SenInfoCheckUtil {
 
     /**
      * 订阅消息模板
-     * @param type  类型  1 用户端订单状态通知 2骑手端订单完成通知 3 用户端订单取消通知   4 骑手端接单成功通知 5 6 骑手端订单完成 7骑手端新订单通知 8商家端新订单通知 9商家端订单变更通知
+     * @param type  类型  1 用户端订单状态通知 2骑手端订单完成通知 3 用户端订单取消通知
+     *              4 骑手端接单成功通知 5 6 骑手端订单完成 7骑手端新订单通知 8商家端新订单通知 9商家端订单变更通知
+     *              10 账户余额充值成功通知
      * @param msgList 对应值
      * @return
      */
@@ -408,6 +410,12 @@ public class SenInfoCheckUtil {
             paras.put("phrase5", new TemplateParam(msgList.get(1)));
             paras.put("time3", new TemplateParam(msgList.get(2)));
             return paras;
+        } else if (type == 10) {
+            Map<String, TemplateParam> paras = new HashMap<>(3);
+            paras.put("thing1", new TemplateParam(msgList.get(0)));
+            paras.put("amount2", new TemplateParam(msgList.get(1)));
+            paras.put("time3", new TemplateParam(msgList.get(2)));
+            return paras;
         }
         return null;
     }