java/zhihuishenqu.git

			@@ -1,17 +1,16 @@
			package com.panzhihua.common.utlis;

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

			import cn.hutool.core.util.StrUtil;
			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONObject;
			import com.panzhihua.common.constants.SecurityConstants;
			import com.panzhihua.common.controller.BaseController;
			import com.panzhihua.common.redis.RedisUtils;
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.fileupload.FileItem;
			import org.apache.commons.fileupload.FileItemFactory;
			import org.apache.commons.fileupload.disk.DiskFileItemFactory;
			import org.apache.http.entity.ContentType;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.data.redis.core.StringRedisTemplate;
			import org.springframework.data.redis.core.ValueOperations;
			@@ -19,14 +18,18 @@
			import org.springframework.web.multipart.MultipartFile;
			import org.springframework.web.multipart.commons.CommonsMultipartFile;

			import com.alibaba.fastjson.JSON;
			import com.alibaba.fastjson.JSONObject;
			import com.panzhihua.common.constants.SecurityConstants;

			import lombok.extern.slf4j.Slf4j;

			import javax.annotation.PostConstruct;
			import javax.annotation.Resource;
			import javax.servlet.http.HttpServletRequest;
			import java.io.*;
			import java.net.HttpURLConnection;
			import java.net.URL;
			import java.nio.charset.StandardCharsets;
			import java.text.MessageFormat;
			import java.text.SimpleDateFormat;
			import java.util.Date;
			import java.util.Map;
			import java.util.concurrent.TimeUnit;

			@Slf4j
			@Component
			@@ -37,10 +40,18 @@
			private static String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential";
			private static String APP_IMAGE_URL = "https://www.psciio.com//idcard/8fa82cfba258498eab2fa818220fb592.jpg";
			private static String APP_IMAGE_NAME = "5.jpg";
			private static String WX_CALL_BACK = "https://api.weixin.qq.com/cgi-bin/getcallbackip?access_token=";
			//2小时
			private static final Long EXPIRE_TIME = 2L;
			@Resource
			private RedisTemplate redisTemplate;
			@Resource
			private StringRedisTemplate stringRedisTemplate;
			@Resource
			private RedisUtils redisUtils;

			private static WxXCXTempSend wxXCXTempSend;

			/**
			* url转变为 MultipartFile对象
			*
			@@ -52,7 +63,7 @@
			private static MultipartFile createFileItem(String url, String fileName) throws Exception {
			FileItem item = null;
			try {
			HttpURLConnection conn = (HttpURLConnection)new URL(url).openConnection();
			HttpURLConnection conn = (HttpURLConnection) new URL(url).openConnection();
			conn.setReadTimeout(30000);
			conn.setConnectTimeout(30000);
			// 设置应用程序要从网络连接读取数据
			@@ -64,7 +75,7 @@
			FileItemFactory factory = new DiskFileItemFactory(16, null);
			String textFieldName = "uploadfile";
			item =
			factory.createItem(textFieldName, ContentType.APPLICATION_OCTET_STREAM.toString(), false, fileName);
			factory.createItem(textFieldName, ContentType.APPLICATION_OCTET_STREAM.toString(), false, fileName);
			OutputStream os = item.getOutputStream();

			int bytesRead = 0;
			@@ -88,33 +99,70 @@
			* @return
			*/
			public String getAccessToken() throws Exception {
			String accessToken = "";
			Boolean aBoolean = wxXCXTempSend.redisTemplate.hasKey(SecurityConstants.APPLETS_ACCESS_TOKEN);
			ValueOperations<String, String> valueOperations = wxXCXTempSend.redisTemplate.opsForValue();
			if(aBoolean){
			Long expireTime = Long.parseLong(valueOperations.get(SecurityConstants.APPLETS_ACCESS_TOKEN_TIME));
			if(expireTime <= System.currentTimeMillis()){
			wxXCXTempSend.redisTemplate.delete(SecurityConstants.APPLETS_ACCESS_TOKEN);//如果过期则删除
			wxXCXTempSend.redisTemplate.delete(SecurityConstants.APPLETS_ACCESS_TOKEN_TIME);//如果过期则删除

			valueOperations.set(SecurityConstants.APPLETS_ACCESS_TOKEN, getAppAccessToken());
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_TOKEN_TIME, System.currentTimeMillis() + 1100000 + "");
			}else{
			accessToken = valueOperations.get(SecurityConstants.APPLETS_ACCESS_TOKEN);
			}
			}else{
			accessToken = getAppAccessToken();
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_TOKEN, accessToken);
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_TOKEN_TIME, System.currentTimeMillis() + 1100000 + "");
			}
			String accessToken = "";
			String appId = this.getAppId();
			accessToken = wxXCXTempSend.stringRedisTemplate.boundValueOps("access_token:access_token:" + appId).get();
			return accessToken;
			}

			public String getAppAccessToken() throws Exception {

			public String getAccessToken(String appId) throws Exception {
			String accessToken = "";
			accessToken = wxXCXTempSend.stringRedisTemplate.boundValueOps("access_token:access_token:" + appId).get();
			return accessToken;
			}

			private String validAccessToken(String accessToken, String appId, String appSecret) throws Exception {
			if (StrUtil.isEmpty(accessToken)) {
			//重新获取并设置到缓存该方法暂时只用在花城
			accessToken = getAppAccessToken(appId, appSecret);
			wxXCXTempSend.stringRedisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken, EXPIRE_TIME, TimeUnit.HOURS);
			} else {
			String accessTokenUrl = WX_CALL_BACK + accessToken;
			String result = HttpClientUtil.httpGet(accessTokenUrl, null, null);
			Map<String, Object> resultMap = JSON.parseObject(result, Map.class);
			//如果Access_token过期也重新获取
			if (resultMap.containsKey("errcode")) {
			accessToken = getAppAccessToken(appId, appSecret);
			wxXCXTempSend.stringRedisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken, EXPIRE_TIME, TimeUnit.HOURS);
			}
			}
			return accessToken;
			}

			public String getAppAccessToken(String appId, String appSecret) throws Exception {
			String accessToken = "0";
			try {
			log.info("获取微信token参数：appid=" + APP_ID + "，appSecret=" + APP_SECRET);
			String accessTokenUrl = ACCESS_TOKEN_URL + "&appid=" + APP_ID + "&secret=" + APP_SECRET;
			log.info("获取微信token参数：appid=" + appId + "，appSecret=" + appSecret);
			String accessTokenUrl = ACCESS_TOKEN_URL + "&appid=" + appId + "&secret=" + appSecret;
			String result = HttpClientUtil.httpGet(accessTokenUrl, null, null);
			Map<String, Object> resultMap = JSON.parseObject(result, Map.class);
			StringRedisTemplate redisTemplate = wxXCXTempSend.stringRedisTemplate;
			if (resultMap.containsKey("access_token")) {
			accessToken = resultMap.get("access_token").toString();
			redisTemplate.opsForValue().set("access_token:access_token:" + appId, accessToken);
			}
			HttpServletRequest request = ServletUtils.getRequest();
			String requestURI = request.getRequestURI();
			//加上时间戳
			String datetime = new SimpleDateFormat("yyyyMMdd").format(new Date());
			//这里是 Redis key的前缀，如: sys:tabieId:表名如果不需要去掉表名也可以
			String key = MessageFormat.format("{0}:{1}:{2}", "access_token_request_incr",datetime,requestURI);
			//查询 key 是否存在，不存在返回 1 ，存在的话则自增加1
			redisTemplate.opsForValue().increment(key, 1);

			} catch (IOException ioe) {
			log.error("小程序http请求异常");
			ioe.printStackTrace();
			}
			return accessToken;
			}

			public String getWsAccessToken() throws Exception {
			String accessToken = "0";
			try {
			// log.info("获取微信token参数：appid=" + APP_ID + "，appSecret=" + APP_SECRET);
			String accessTokenUrl = ACCESS_TOKEN_URL + "&appid=wx98d62711dfbd8425" + "&secret=97a2a10b990c2774ed279724337b5337";
			String result = HttpClientUtil.httpGet(accessTokenUrl, null, null);
			Map<String, Object> resultMap = JSON.parseObject(result, Map.class);
			if (resultMap.containsKey("access_token")) {
			@@ -129,7 +177,8 @@

			/**
			* 获取西区社区通微信token
			* @return 西区社区通微信token
			*
			* @return 西区社区通微信token
			* @throws Exception 异常
			*/
			public String getXQAppAccessToken() throws Exception {
			@@ -162,7 +211,7 @@
			mediaId = getAppMediaId(accessToken);
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_MEDIA_ID, mediaId);
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_MEDIA_ID_TIME,
			System.currentTimeMillis() + 259000000 + "");
			System.currentTimeMillis() + 259000000 + "");
			} else {
			mediaId = valueOperations.get(SecurityConstants.APPLETS_ACCESS_MEDIA_ID);
			}
			@@ -170,7 +219,7 @@
			mediaId = getAppMediaId(accessToken);
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_MEDIA_ID, mediaId);
			valueOperations.set(SecurityConstants.APPLETS_ACCESS_MEDIA_ID_TIME,
			System.currentTimeMillis() + 259000000 + "");
			System.currentTimeMillis() + 259000000 + "");
			}
			return mediaId;
			}
			@@ -191,15 +240,15 @@
			*
			* @param file
			* @return
			* @author yixiu
			* @throws Exception
			* @author yixiu
			*/
			public String uploadFile(MultipartFile file, String access_token) throws Exception {
			String url = "https://api.weixin.qq.com/cgi-bin/media/upload?access_token=" + access_token + "&type=image";
			String result = null;
			String fileName = file.getOriginalFilename();
			URL urlObj = new URL(url);
			HttpURLConnection con = (HttpURLConnection)urlObj.openConnection();
			HttpURLConnection con = (HttpURLConnection) urlObj.openConnection();
			con.setRequestMethod("POST");
			con.setDoInput(true);
			con.setDoOutput(true);
			@@ -271,6 +320,9 @@
			public void init() {
			wxXCXTempSend = this;
			wxXCXTempSend.redisTemplate = this.redisTemplate;
			wxXCXTempSend.stringRedisTemplate = this.stringRedisTemplate;
			wxXCXTempSend.redisUtils = this.redisUtils;

			}

			}