From 2a10906a80efe9547a4a97169f6f81c86bea0391 Mon Sep 17 00:00:00 2001 From: Stormeye Wu Date: Sat, 25 Apr 2020 19:52:18 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=89=93=E6=A0=87=E7=AD=BE][=E4=BC=98?= =?UTF-8?q?=E5=8C=96]:=E4=B8=8D=E8=83=BD=E5=B9=B6=E5=8F=91=E6=89=A7?= =?UTF-8?q?=E8=A1=8C=E6=89=93=E6=A0=87=E7=AD=BE=E6=93=8D=E4=BD=9C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/UserTagsController.java | 50 +++++++++++++++++++ .../schedule/WxCUserTagsSchedule.java | 3 +- 2 files changed, 52 insertions(+), 1 deletion(-) create mode 100644 mallinkSchedule/src/main/java/com/iformall/controller/UserTagsController.java diff --git a/mallinkSchedule/src/main/java/com/iformall/controller/UserTagsController.java b/mallinkSchedule/src/main/java/com/iformall/controller/UserTagsController.java new file mode 100644 index 000000000..63864d432 --- /dev/null +++ b/mallinkSchedule/src/main/java/com/iformall/controller/UserTagsController.java @@ -0,0 +1,50 @@ +package com.iformall.controller; + +import com.github.pagehelper.PageInfo; +import com.iformall.common.ResultData; +import com.iformall.domain.po.WxCUserBasicInfo; +import com.iformall.domain.po.msg.WxMsgRecord; +import com.iformall.enums.EnumAssignTagsTrigger; +import com.iformall.mq.MqBaseProducer; +import com.iformall.mq.impl.RabbitMqMessageProducer; +import com.iformall.service.WxCUserBasicInfoService; +import com.iformall.service.WxCUserTagsService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RestController; + + +@RestController +@Api(description = "登录相关接口") +public class UserTagsController { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + WxCUserTagsService wxCUserTagsService; + + @Autowired + WxCUserBasicInfoService wxCUserBasicInfoService; + + @GetMapping("/userTag") + public void mqtest() { + WxCUserBasicInfo wxCUserBasicInfo = new WxCUserBasicInfo(); + + int pageIndex = 1; + final int pageSize = 1000; + + PageInfo page; + do{ + page = wxCUserBasicInfoService.listAsPage(wxCUserBasicInfo, pageIndex++, pageSize); + page.getList().stream().forEach(cubi -> { + long lStart = System.currentTimeMillis(); + wxCUserTagsService.triggerAssignTags(EnumAssignTagsTrigger.ASSIGN_TAGS_TRIGGER_SCAN, cubi); + logger.info("user tag cost time: {}", System.currentTimeMillis() - lStart); + }); + } while ((page.isHasNextPage())); + } +} \ No newline at end of file diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java index 1cb4d290e..7ac17824f 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/WxCUserTagsSchedule.java @@ -22,7 +22,8 @@ public class WxCUserTagsSchedule { @Autowired WxCUserBasicInfoService wxCUserBasicInfoService; - @Scheduled(cron = "0 0 0 25 * ?") // 每月25日凌晨01:00对会员列表扫描补录标签 + // TODO 先不执行打标签操作了, 数据量太大,导致数据库CPU 100% + //@Scheduled(cron = "0 0 0 25 * ?") // 每月25日凌晨01:00对会员列表扫描补录标签 //@Scheduled(cron = "0 */5 * * * ?") // 测试1分钟一次 public void wxCUserTagsSchedule() { WxCUserBasicInfo wxCUserBasicInfo = new WxCUserBasicInfo();