Explorar o código

Merge remote-tracking branch 'origin/feature/1219_opt' into feature/1219_opt

zouxuan hai 5 meses
pai
achega
eaa7d4fade

+ 1 - 0
cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/enums/MessageTypeEnum.java

@@ -197,6 +197,7 @@ public enum MessageTypeEnum implements BaseEnum<String, MessageTypeEnum> {
     GROUP_FAIL_TEACHER("小组课成课失败"),
     DEDUCTION_DISCOUNT_SMS("扣减畅学卡"),
     ADD_DISCOUNT_SMS("添加畅学卡"),
+    PAY_DISCOUNT_JG("购买畅学卡"),
     DEDUCTION_TENANT_ALBUM_JG("扣减畅学卡"),
     ADD_TENANT_ALBUM_JG("添加畅学卡"),
     ;

+ 18 - 0
cooleshow-user/user-biz/src/main/java/com/yonge/cooleshow/biz/dal/service/impl/DiscountCardRecordServiceImpl.java

@@ -28,6 +28,8 @@ import java.time.ZoneId;
 import java.util.*;
 import java.util.stream.Collectors;
 
+import static com.yonge.cooleshow.biz.dal.enums.MessageTypeEnum.PAY_DISCOUNT_JG;
+
 /**
  * 购买会员卡记录表
  * 2024-11-15 10:57:20
@@ -71,6 +73,22 @@ public class DiscountCardRecordServiceImpl extends ServiceImpl<DiscountCardRecor
 
         addStudentDiscount(discountCardRecord);
 
+        // 购买成功推送
+        com.yonge.cooleshow.auth.api.entity.SysUser sysUser = sysUserService.getByUserId(discountCardRecord.getUserId());
+        if (sysUser == null) {
+            return;
+        }
+
+        Map<Long, String> receivers = new HashMap<>();
+        receivers.put(sysUser.getId(), sysUser.getPhone());
+
+        try {
+            sysMessageService.batchSendMessage(MessageSenderPluginContext.MessageSender.JIGUANG, PAY_DISCOUNT_JG,receivers,
+                    null,0,null,ClientEnum.STUDENT.name()
+                    ,discountCardRecord.getTimes());
+        } catch (Exception e) {
+            log.error("消息发送失败 ", e);
+        }
     }