From 6672ee5c6b56ab853d8d845cfe842d9bc58eabcc Mon Sep 17 00:00:00 2001 From: "jinguo24@163.com" Date: Fri, 31 Aug 2018 19:56:23 +0800 Subject: [PATCH] =?UTF-8?q?[pv=20uv=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1][?= =?UTF-8?q?=E4=BF=AE=E6=94=B9]=E6=97=B6=E9=97=B4=E7=9A=84=E4=BF=AE?= =?UTF-8?q?=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../simple/schedule/WxAppVisitSchedule.java | 28 ++++++++++++++++--- 1 file changed, 24 insertions(+), 4 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/simple/schedule/WxAppVisitSchedule.java b/mallinkAdmin/src/main/java/com/simple/schedule/WxAppVisitSchedule.java index 39c93d2b4..f40a460ab 100644 --- a/mallinkAdmin/src/main/java/com/simple/schedule/WxAppVisitSchedule.java +++ b/mallinkAdmin/src/main/java/com/simple/schedule/WxAppVisitSchedule.java @@ -19,7 +19,10 @@ import org.springframework.web.client.RestTemplate; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; +import com.github.pagehelper.PageInfo; +import com.simple.domain.po.WxAppinfo; import com.simple.domain.po.WxUserVisit; +import com.simple.service.WxAppinfoService; import com.simple.service.WxUserVisitService; @Component @@ -37,24 +40,40 @@ public class WxAppVisitSchedule { @Autowired private WxUserVisitService wxUserVisitService; + + @Autowired + private WxAppinfoService WxAppinfoService; // @Scheduled(cron = "0 */1 * * * *?") - @Scheduled(cron = "0 0 4 * * ? ") + @Scheduled(cron = "0 0 6 * * ? ") public void start() { try { Calendar c =Calendar.getInstance(); c.add(Calendar.DAY_OF_YEAR, -1); Date time = c.getTime(); String yesterday = new SimpleDateFormat("yyyyMMdd").format(time); - getData(yesterday); +// "wx8eb8275b78db4ede", "76c43df01296998d8ce12383f213ac10"; + WxAppinfo appInfo = new WxAppinfo(); + appInfo.setType(2); + PageInfo page = WxAppinfoService.listAsPage(appInfo, 1, 10000); + for(WxAppinfo w :page.getList()) { + w.getAppId(); + w.getSecret(); + w.getTenantId(); + //TODO 因为数据库表里数据问题,暂时不通过这种方式处理 + } + String appId = "wx8eb8275b78db4ede"; + String key ="76c43df01296998d8ce12383f213ac10"; + String talentId ="456"; + getData(yesterday,appId,key,talentId); }catch(Exception e) { logger.error("获取微信访问数据失败",e); } } - private void getData(String yesterday) throws Exception { - String accessToken = getAccessToken("wx8eb8275b78db4ede", "76c43df01296998d8ce12383f213ac10"); + private void getData(String yesterday,String appId,String key,String talentId) throws Exception { + String accessToken = getAccessToken(appId, key); HttpHeaders headers = new HttpHeaders(); headers.setContentType(MediaType.APPLICATION_JSON); Map map = new HashMap(); @@ -91,6 +110,7 @@ public class WxAppVisitSchedule { v.setStayTimeSession(itemMap.get("stay_time_session")+""); v.setVisitDepth(itemMap.get("visit_depth")+""); v.setStayTimeUv(itemMap.get("stay_time_uv")+""); + v.setTenantId(talentId); wxUserVisitService.saveOrUpdate(v); }