看课小程序加载/

fs-service/src/main/java/com/fs/qw/service/impl/QwExternalContactServiceImpl.java

@@ -1710,10 +1710,10 @@ public class QwExternalContactServiceImpl extends ServiceImpl<QwExternalContactM
             new Thread(() -> {
                 try {
                     Thread.sleep(3000);
+                    rocketMQTemplate.syncSend("repeat-upload", JSON.toJSONString(RepeatUploadVo.builder().type(0).externalUserId(externalUserID).build()));
                 } catch (InterruptedException e) {
                     logger.error("添加等待时长错误", e);
                 }
-                rocketMQTemplate.syncSend("repeat-upload", JSON.toJSONString(RepeatUploadVo.builder().type(0).externalUserId(externalUserID).build()));
             }).start();
         }catch (Exception e){
             logger.error("重粉提交mq失败", e);

fs-user-app/src/main/java/com/fs/app/controller/WxUserController.java

@@ -244,14 +244,14 @@ public class WxUserController extends AppBaseController{
             }
 
             // 保存用户openId
-            FsUserWx wx = new FsUserWx();
-            wx.setFsUserId(user.getUserId());
-            wx.setAppId(appId);
-            wx.setOpenId(session.getOpenid());
-            wx.setUnionId(session.getUnionid());
-            wx.setCreateTime(LocalDateTime.now());
-            wx.setUpdateTime(LocalDateTime.now());
-            userWxService.saveOrUpdate(wx);
+//            FsUserWx wx = new FsUserWx();
+//            wx.setFsUserId(user.getUserId());
+//            wx.setAppId(appId);
+//            wx.setOpenId(session.getOpenid());
+//            wx.setUnionId(session.getUnionid());
+//            wx.setCreateTime(LocalDateTime.now());
+//            wx.setUpdateTime(LocalDateTime.now());
+//            userWxService.saveOrUpdate(wx);
 
             // 生成Token
             String token = jwtUtils.generateToken(user.getUserId());