|
|
@@ -2259,18 +2259,18 @@ public class QwExternalContactServiceImpl extends ServiceImpl<QwExternalContactM
|
|
|
// }
|
|
|
// iAdHtmlClickLogService.upload(state, AdUploadType.ADD_WX, e -> finalQwExternalContact.setUploadAddWxStatus(1));
|
|
|
//重粉问题
|
|
|
-// try {
|
|
|
-// new Thread(() -> {
|
|
|
-// try {
|
|
|
-// Thread.sleep(3000);
|
|
|
-// } 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);
|
|
|
-// }
|
|
|
+ try {
|
|
|
+ new Thread(() -> {
|
|
|
+ try {
|
|
|
+ Thread.sleep(3000);
|
|
|
+ } 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);
|
|
|
+ }
|
|
|
|
|
|
|
|
|
|