mq Try

fs-service/src/main/java/com/fs/course/service/impl/FsUserCourseVideoServiceImpl.java

@@ -402,10 +402,17 @@ public class FsUserCourseVideoServiceImpl implements IFsUserCourseVideoService
         String msg = "<div style=\"color: red;margin-bottom: 15px;font-weight: bold;\">本课程为会员独享<br>请长按二维码</div>\n" +
                 "\t\t\t\t\t<div style=\"color: #999;font-size: 14px;font-weight: bold;\">添加伴学助手免费领取会员权限</div>";
         try {
-            new Thread(() -> rocketMQTemplate.syncSend("repeat-upload", JSON.toJSONString(RepeatUploadVo.builder().type(1).fsUserId(param.getUserId()).build()))).start();
+            new Thread(() -> {
+                try {
+                    rocketMQTemplate.syncSend("repeat-upload", JSON.toJSONString(RepeatUploadVo.builder().type(1).fsUserId(param.getUserId()).build()));
+                }catch (Exception e){
+                    logger.error("看课重粉提交mq失败", e);
+                }
+            }).start();
         }catch (Exception e){
             logger.error("看课重粉提交mq失败", e);
         }
+
         Integer isRoom = param.getIsRoom();
 
         // 处理逻辑

fs-service/src/main/java/com/fs/his/service/impl/FsInquiryOrderServiceImpl.java

@@ -810,7 +810,20 @@ public class FsInquiryOrderServiceImpl implements IFsInquiryOrderService
                 String redisKey = String.valueOf(StrUtil.format("{}{}", FsConstants.REDIS_INQUIRY_ORDER_OUTTIME_UNRECEIVE, order.getOrderId()));
                 redisCache.setCacheObject(redisKey,order.getOrderId(),configDTO.getUnReceiveCancelTime(), TimeUnit.MINUTES);
             }
-            new Thread(() -> rocketMQTemplate.syncSend("repeat-upload", JSON.toJSONString(RepeatUploadVo.builder().type(2).fsUserId(order.getUserId()).build()))).start();
+            try {
+                new Thread(() -> {
+                    try {
+                        rocketMQTemplate.syncSend("repeat-upload", JSON.toJSONString(RepeatUploadVo.builder().type(2).fsUserId(order.getUserId()).build()));
+                    }catch (Exception e){
+                        logger.error("看课重粉提交mq失败", e);
+                    }
+                }).start();
+
+            }catch (Exception e){
+                logger.error("看课重粉提交mq失败", e);
+            }
+
+
             return R.ok();
         }catch (Exception e){
             TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();

fs-service/src/main/resources/application-config-druid-hzyy.yml

@@ -10,13 +10,13 @@ logging:
 wx:
   miniapp:
     configs:
-      - appid: wx4115995705bb0ea0   #中康智慧
-        secret: 58910ae743005c396012b029c7def579
+      - appid: wxb   #金悦澜湾药房
+        secret: 00
         token: Ncbnd7lJvkripVOpyTFAna6NAWCxCrvC
         aesKey: HlEiBB55eaWUaeBVAQO3cWKWPYv1vOVQSq7nFNICw4E
         msgDataFormat: JSON
-      - appid: wxedde588767b358b1   #中康未来智慧药房
-        secret: 928d2961c81610d8f64b019597212fcd
+      - appid: wxb48fe0acfdc70a92   #金悦澜湾药房
+        secret: 009e1c9f55071c1fd9c45f707356f2fb
         token: Ncbnd7lJvkripVOpyTFAna6NAWCxCrvC
         aesKey: HlEiBB55eaWUaeBVAQO3cWKWPYv1vOVQSq7nFNICw4E
         msgDataFormat: JSON
@@ -75,17 +75,17 @@ tencent_cloud_config:
   region: ap-chongqing
   proxy: hzyy
 tmp_secret_config:
-  secret_id: AKIDCj7NSNAovtqeJpBau8GZ4CGB71thXIxX
-  secret_key: lTB5zwqqz7CNhzDOWivFWedgfTBgxgBT
-  bucket: fs-1319721001
-  app_id: 1319721001
-  region: ap-chongqing
+  secret_id: AKIDCj7NSN
+  secret_key: lTB5zwqqz
+  bucket: fs-131
+  app_id: 131
+  region: ap-
   proxy: fs
 cloud_host:
   company_name: 弘珍医药
 #看课授权时显示的头像
 headerImg:
-  imgUrl: https://jz-cos-1356808054.cos.ap-chengdu.myqcloud.com/fs/20250515/0877754b59814ea8a428fa3697b20e68.png
+  imgUrl: https://hzyy.obs.cn-north-4.myhuaweicloud.com/fs/20250616/1750067609692.png
 ipad:
   ipadUrl: http://ipad.cdwjyyh.com
 wx_miniapp_temp: