|
@@ -408,17 +408,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(() -> {
|
|
|
-// 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);
|
|
|
-// }
|
|
|
+ try {
|
|
|
+ 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();
|
|
|
|