java/zhihuishenqu.git

			@@ -1,14 +1,14 @@
			package com.panzhihua.applets.api;

			import java.io.*;
			import java.net.HttpURLConnection;
			import java.net.URL;
			import java.nio.charset.StandardCharsets;
			import java.util.*;
			import java.util.concurrent.TimeUnit;

			import javax.annotation.Resource;

			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONObject;
			import com.panzhihua.applets.config.WxMaConfiguration;
			import com.panzhihua.common.constants.UserConstants;
			import com.panzhihua.common.model.vos.R;
			import com.panzhihua.common.utlis.HttpClientUtil;
			import com.panzhihua.common.utlis.StringUtils;
			import io.swagger.annotations.ApiOperation;
			import lombok.extern.slf4j.Slf4j;
			import org.springframework.data.redis.core.StringRedisTemplate;
			import org.springframework.data.redis.core.ValueOperations;
			import org.springframework.web.bind.annotation.GetMapping;
			@@ -16,15 +16,13 @@
			import org.springframework.web.bind.annotation.RequestParam;
			import org.springframework.web.bind.annotation.RestController;

			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONObject;
			import com.panzhihua.common.constants.UserConstants;
			import com.panzhihua.common.model.vos.R;
			import com.panzhihua.common.utlis.HttpClientUtil;
			import com.panzhihua.common.utlis.StringUtils;

			import io.swagger.annotations.ApiOperation;
			import lombok.extern.slf4j.Slf4j;
			import javax.annotation.Resource;
			import java.io.*;
			import java.net.HttpURLConnection;
			import java.net.URL;
			import java.nio.charset.StandardCharsets;
			import java.util.*;
			import java.util.concurrent.TimeUnit;

			@Slf4j
			@RestController
			@@ -33,7 +31,6 @@

			@Resource
			private StringRedisTemplate stringRedisTemplate;

			// 公众号appid
			private List<String> appidList = new ArrayList<String>() {
			{
			@@ -66,8 +63,7 @@
			/**
			* 根据文章链接抓取文章内容
			*
			* @param url
			* 文章链接
			* @param url 文章链接
			* @return 文章内容
			*/
			public static String getActicle(String url) {
			@@ -84,15 +80,14 @@
			/**
			* 获取token
			*
			* @param appid
			* 公众号appid
			* @param secret
			* 公众号secret
			* @param appid 公众号appid
			* @param secret 公众号secret
			* @return token
			*/
			private String getToken(String appid, String secret) throws IOException {
			// access_token接口https请求方式: GET
			// https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET

			String path = " https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential";
			URL url = new URL(path + "&appid=" + appid + "&secret=" + secret);
			HttpURLConnection connection = (HttpURLConnection)url.openConnection();
			@@ -107,22 +102,23 @@
			sb.append(new String(b, 0, len));
			}

			// System.out.println(sb.toString());
			in.close();


			return sb.toString();

			}

			/**
			* 通过token获取公众号文章
			*
			* @param token
			* token
			* @param token token
			* @return 获取的文章列表结果
			*/
			private String getContentList(String token) throws IOException {
			String path = " https://api.weixin.qq.com/cgi-bin/material/batchget_material?access_token=" + token;
			URL url = new URL(path);
			HttpURLConnection connection = (HttpURLConnection)url.openConnection();
			HttpURLConnection connection = (HttpURLConnection) url.openConnection();
			connection.setRequestMethod("POST");
			connection.setDoOutput(true);
			connection.setRequestProperty("content-type", "application/json;charset=utf-8");
			@@ -157,21 +153,29 @@
			public R pageDiscuss() throws Exception {
			WxOfficialApi officialApi = new WxOfficialApi();

			ValueOperations<String, String> valueOperations = stringRedisTemplate.opsForValue();
			List<String> tokenList = new ArrayList<>();
			if (!appidList.isEmpty()) {
			for (int i = 0; i < appidList.size(); i++) {
			String token = officialApi.getToken(appidList.get(i), secretList.get(i));
			log.info("通过appid:" + appidList.get(i) + "获取token返回参数：" + token);
			JSONObject tokenJson = JSON.parseObject(token);
			if (StringUtils.isNotEmpty(tokenJson)) {
			tokenList.add(tokenJson.getString("access_token"));
			if (StringUtils.isNotEmpty(token)) {
			tokenList.add(token);
			}
			}
			}
			}

			List<JSONObject> resultList = new ArrayList<>();
			Boolean newsListKey = stringRedisTemplate.hasKey(UserConstants.NEWS_LIST);
			if (newsListKey != null && newsListKey) {
			String json = valueOperations.get(UserConstants.NEWS_LIST);
			resultList = JSON.parseArray(json, JSONObject.class);
			return R.ok(resultList);
			}
			if (!tokenList.isEmpty()) {
			tokenList.forEach(token -> {
			for (String token : tokenList) {
			try {
			String url = "https://api.weixin.qq.com/cgi-bin/material/batchget_material?access_token=" + token;
			String result = getActicle(url);
			@@ -185,13 +189,12 @@
			String newsId = object.getString("media_id");
			JSONObject contentJson = JSON.parseObject(object.getString("content"));
			List<JSONObject> newsItemList =
			JSON.parseArray(contentJson.getString("news_item"), JSONObject.class);
			JSON.parseArray(contentJson.getString("news_item"), JSONObject.class);
			String newsUrl = newsItemList.get(0).getString("url");
			newsItemList.get(0).put("news_id", newsId);
			contentJson.put("news_item", newsItemList);
			object.put("content", contentJson);

			ValueOperations<String, String> valueOperations = stringRedisTemplate.opsForValue();
			valueOperations.set(UserConstants.NEWS_ID + newsId, newsUrl + "", 2, TimeUnit.DAYS);
			}
			}
			@@ -201,7 +204,8 @@
			} catch (Exception e) {
			log.error("通过token获取文章列表失败，错误原因：" + e.getMessage());
			}
			});
			valueOperations.set(UserConstants.NEWS_LIST, resultList.toString(), 12, TimeUnit.HOURS);
			}
			}
			return R.ok(resultList);
			}