Javaweb在线 农副产品电子商城系统源码(含数据库脚本).zip

package com.cms.util; import java.io.ByteArrayInputStream; import java.io.File; import java.io.FileInputStream; import java.io.InputStream; import java.io.StringWriter; import java.math.BigDecimal; import java.security.KeyStore; import java.security.MessageDigest; import java.util.Arrays; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; import java.util.UUID; import javax.crypto.Mac; import javax.crypto.spec.SecretKeySpec; import javax.net.ssl.SSLContext; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilderFactory; import javax.xml.transform.OutputKeys; import javax.xml.transform.Transformer; import javax.xml.transform.TransformerFactory; import javax.xml.transform.dom.DOMSource; import javax.xml.transform.stream.StreamResult; import org.apache.commons.lang.StringUtils; import org.apache.http.HttpEntity; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpPost; import org.apache.http.conn.ssl.SSLConnectionSocketFactory; import org.apache.http.entity.StringEntity; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClients; import org.apache.http.ssl.SSLContexts; import org.apache.http.util.EntityUtils; import org.w3c.dom.Node; import org.w3c.dom.NodeList; import com.alibaba.fastjson.JSONException; import com.alibaba.fastjson.JSONObject; import com.cms.Config; import com.jfinal.kit.HttpKit; import net.sf.ehcache.CacheManager; import net.sf.ehcache.Ehcache; import net.sf.ehcache.Element; public class WeixinUtils { /** 缓存名称 */ public static final String CACHE_NAME = "weixin"; /** CacheManager */ private static final CacheManager CACHE_MANAGER = CacheUtils.getCacheManager(); //=====基本 token 和 ticket private static final String GET_TOKEN_URL="https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"; public static String getAccessToken(String appId,String appSecret){ Ehcache cache = CACHE_MANAGER.getEhcache(CACHE_NAME); String cacheKey = "accessToken"; Element cacheElement = cache.get(cacheKey); if (cacheElement == null) { //======获取开始 String url = String.format(GET_TOKEN_URL, appId, appSecret); String content= HttpKit.get(url, null); JSONObject jsonObject = JSONObject.parseObject(content); System.out.println("======"+jsonObject.toJSONString()); String token = ""; if (null != jsonObject) { try { token = jsonObject.getString("access_token"); } catch (JSONException e) { System.out.println("获取token失败 errcode:" + jsonObject.getIntValue("errcode") + " errmsg:" + jsonObject.getString("errmsg")); } } //======获取结束 cache.put(new Element(cacheKey, token)); cacheElement = cache.get(cacheKey); } return (String)cacheElement.getObjectValue(); } private static final String GET_JSAPI_TICKET_URL="https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=%s&type=jsapi"; public static String getJsapiTicket(String accessToken){ Ehcache cache = CACHE_MANAGER.getEhcache(CACHE_NAME); String cacheKey = "jsapiTicket"; Element cacheElement = cache.get(cacheKey); if (cacheElement == null) { //======获取开始 String url = String.format(GET_JSAPI_TICKET_URL,accessToken); System.out.println(url); String content= HttpKit.get(url, null); JSONObject jsonObject = JSONObject.parseObject(content); String ticket = jsonObject.getString("ticket"); if(StringUtils.isBlank(ticket)){ return null; } //======获取结束 cache.put(new Element(cacheKey, ticket)); cacheElement = cache.get(cacheKey); } return (String)cacheElement.getObjectValue(); } //获取用户信息 private static final String GET_USER_INFO_URL = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=%s&openid=%s&lang=zh_CN"; //{country=中国, subscribe=1, city=长沙, openid=obknuvpx-L2QwySLwCDBs6VwUuc0, tagid_list=[], sex=1, groupid=0, language=zh_CN, remark=, subscribe_time=1515471683, province=湖南, nickname=樱木, headimgurl=http://wx.qlogo.cn/mmopen/Q3auHgzwzM5N6OYHyYyICmNCHuvT1rBvB81IZ1My8ricRVg3GeHdCCmvXQ1QuGYeXSTEQSjpzXicylicOZibBKIgXw/0} public static Map<String,Object> getUserInfo(String accessToken,String openId){ String content = HttpKit.get(String.format(GET_USER_INFO_URL, accessToken,openId), null); System.out.println("GET_USER_INFO_URL=="+content); return JSONObject.parseObject(content, Map.class); } //获取用户auth信息 private static final String GET_AUTHORIZE_URL="https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&redirect_uri=%s&response_type=code&scope=snsapi_userinfo&state=%s#wechat_redirect"; public static String getAuthorizeUrl(String appId,String redirectUri,String state){ String url = String.format(GET_AUTHORIZE_URL, appId,redirectUri,state); System.out.println("url=="+url); return url; } private static final String GET_ACCESS_TOKEN_URL = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code"; //access_token openid public static Map<String,Object> getOauth2Token(String appId,String appSecret,String code){ String content = HttpKit.get(String.format(GET_ACCESS_TOKEN_URL, appId,appSecret,code), null); System.out.println("GET_ACCESS_TOKEN_URL=="+content); return JSONObject.parseObject(content, Map.class); } private static final String GET_OAUTH2_USERINFO_URL= "https://api.weixin.qq.com/sns/userinfo?access_token=%s&openid=%s&lang=zh_CN"; //nickname headimgurl public static Map<String,Object> getOauth2Userinfo(String accessToken,String openId){ String content = HttpKit.get(String.format(GET_OAUTH2_USERINFO_URL, accessToken,openId), null); System.out.println("GET_OAUTH2_USERINFO_URL=="+content); return JSONObject.parseObject(content, Map.class); } //客服消息 private static final String CUSTOM_SEND_URL="https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=%s"; public static void customSend(String accessToken,String message){ String content = HttpKit.post(String.format(CUSTOM_SEND_URL, accessToken), message); System.out.println("==CUSTOM_SEND_URL=="+content); } //获取文本消息内容 public static String getTextMessage(String touser,String content){ String message=""; message+="{"; message+="\"touser\":\""+touser+"\","; //OPENID message+="\"msgtype\":\"text\","; message+="\"text\":"; message+="{"; message+="\"content\":\""+content+"\""; message+="}"; message+="}"; return message; } //获取图片消息内容 public static String getImageMessage(String touser,String mediaId){ String message=""; message+="{"; message+="\"touser\":\""+touser+"\","; //OPENID message+="\"msgtype\":\"image\","; message+="\"image\":"; message+="{"; message+="\"media_id\":\""+mediaId+"\""; message+="}"; message+="}"; return message; } //获取语音消息内容 public static String getVoiceMessage(String touser,String mediaId){ String message=""; message+="{"; message+=