zoukankan html css js c++ java

微信get post请求到微信服务器模版素材操作

1：素材管理

package org.konghao.weixin.media;

import java.io.File;
import java.io.IOException;
import java.io.InputStream;

import org.apache.commons.io.FileUtils;
import org.apache.http.HttpEntity;
import org.apache.http.ParseException;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.entity.mime.content.FileBody;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.konghao.basic.util.JsonUtil;
import org.konghao.weixin.json.WeixinMedia;
import org.konghao.weixin.model.WeixinFinalValue;
import org.konghao.weixin.quartz.RefreshAccessTokenTask;

public class MediaKit {

    public static String postMedia(String path,String type) {
        CloseableHttpClient client = null;
        CloseableHttpResponse resp = null;
        
        try {
            client = HttpClients.createDefault();
            String url = WeixinFinalValue.POST_MEDIA;
            url = url.replace("ACCESS_TOKEN", RefreshAccessTokenTask.refreshToken());
            url = url.replace("TYPE", type);
            HttpPost post = new HttpPost(url);
            FileBody fb = new FileBody(new File(path));
            HttpEntity reqEntity = MultipartEntityBuilder.create().addPart("media", fb).build();
            post.setEntity(reqEntity);
            resp = client.execute(post);
            int sc = resp.getStatusLine().getStatusCode();
            if(sc>=200&&sc<300) {
                String json = EntityUtils.toString(resp.getEntity());
                System.out.println(json);
                WeixinMedia wm = (WeixinMedia)JsonUtil.getInstance().json2obj(json, WeixinMedia.class);
                return wm.getMedia_id();
            }
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if(client!=null) client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(resp!=null) resp.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        return null;
    }
    
    public static void getMedia(String mediaId,File f) {
        CloseableHttpClient client = null;
        CloseableHttpResponse resp = null;
        
        try {
            client = HttpClients.createDefault();
            String url = WeixinFinalValue.GET_MEDIA;
            url = url.replace("ACCESS_TOKEN", RefreshAccessTokenTask.refreshToken());
            url = url.replace("MEDIA_ID", mediaId);
            HttpGet get = new HttpGet(url);
            resp = client.execute(get);
            int sc = resp.getStatusLine().getStatusCode();
            if(sc>=200&&sc<300) {
                InputStream is = resp.getEntity().getContent();
                System.out.println(resp.toString());
                FileUtils.copyInputStreamToFile(is, f);
            }
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            try {
                if(client!=null) client.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
            try {
                if(resp!=null) resp.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

1.1 调用方法：

 1     
 2     //上传素材
 3     @Test
 4     public void testPostMedia() {
 5         String mid = MediaKit.postMedia("C:\Users\Public\Pictures\Sample Pictures\aa.jpg","image");
 6         System.out.println(mid);
 7     }
 8     
 9     //获取素材
10     @Test
11     public void testGetMedia() {
12         try {
13             String mid = MediaKit.postMedia("C:\Users\Public\Pictures\Sample Pictures\aa.jpg","image");
14             MediaKit.getMedia(mid,new File("C:\Users\Public\Pictures\Sample Pictures\x.jpg"));
15         } catch (Exception e) {
16             e.printStackTrace();
17         }
18     }
19

2 ：模版测试

　　官方参考文档

　　2.1 实体类

 1 package org.konghao.weixin.json;
 2 
 3 import java.util.Map;
 4 
 5 public class TemplateMsg {
 6     
 7     private String touser ; 
 8     private String template_id;
 9     private String url ; 
10     private String topcolor ; 
11     private Map<String, Object> data;
12     public String getTouser() {
13         return touser;
14     }
15     public void setTouser(String touser) {
16         this.touser = touser;
17     }
18     public String getTemplate_id() {
19         return template_id;
20     }
21     public void setTemplate_id(String template_id) {
22         this.template_id = template_id;
23     }
24     public String getUrl() {
25         return url;
26     }
27     public void setUrl(String url) {
28         this.url = url;
29     }
30     public String getTopcolor() {
31         return topcolor;
32     }
33     public void setTopcolor(String topcolor) {
34         this.topcolor = topcolor;
35     }
36     public Map<String, Object> getData() {
37         return data;
38     }
39     public void setData(Map<String, Object> data) {
40         this.data = data;
41     }
42 
43 }

　　2.2测试类

 1     //测试模板消息I
 2     @Test
 3     public void testPostTemplateMsg(){
 4         TemplateMsg tm = new TemplateMsg();
 5         tm.setTouser("oUigKxHuNI-QMHKzvyYpw1lCY8VQ");//接受者的微信号
 6         tm.setTemplate_id("eeXrrEtSncwNZ8P1uZnKXpB8jqNbI1-usso5Ifp-Ow0");//模版id
 7         tm.setTopcolor("#ff0000");
 8         tm.setUrl("http://www.konghao.org/index");
 9         Map<String, Object> data = new HashMap<String, Object>();
10         data.put("num", new ModelMsgData("123" , "#00ff00"));
11         tm.setData(data);
12         System.out.println("TemplateMsg json:" + JsonUtil.getInstance().obj2json(tm));
13         
14         MessageKit.postTemplateMsg(tm);
15     }

　　2.3 模版工具类

  1 package org.konghao.weixin.msg;
  2 
  3 import java.io.BufferedReader;
  4 import java.io.IOException;
  5 import java.io.InputStreamReader;
  6 import java.io.StringWriter;
  7 import java.util.Date;
  8 import java.util.HashMap;
  9 import java.util.List;
 10 import java.util.Map;
 11 import java.util.Set;
 12 
 13 import javax.servlet.http.HttpServletRequest;
 14 
 15 import org.apache.http.client.ClientProtocolException;
 16 import org.apache.http.client.methods.CloseableHttpResponse;
 17 import org.apache.http.client.methods.HttpPost;
 18 import org.apache.http.entity.ContentType;
 19 import org.apache.http.entity.StringEntity;
 20 import org.apache.http.impl.client.CloseableHttpClient;
 21 import org.apache.http.impl.client.HttpClients;
 22 import org.apache.http.util.EntityUtils;
 23 import org.dom4j.Document;
 24 import org.dom4j.DocumentException;
 25 import org.dom4j.DocumentHelper;
 26 import org.dom4j.Element;
 27 import org.dom4j.io.XMLWriter;
 28 import org.konghao.basic.util.JsonUtil;
 29 import org.konghao.weixin.json.TemplateMsg;
 30 import org.konghao.weixin.kit.WeixinKit;
 31 import org.konghao.weixin.model.WeixinFinalValue;
 32 import org.konghao.weixin.quartz.RefreshAccessTokenTask;
 33 
 34 public class MessageKit {
 35     private static Map<String,String> replyMsgs = new HashMap<String,String>();
 36     static{
 37         replyMsgs.put("123", "你输入了123");
 38         replyMsgs.put("hello", "world");
 39         replyMsgs.put("run", "祝你一路平安!");
 40     }
 41     
 42     @SuppressWarnings("unchecked")
 43     public static Map<String,String> reqMsg2Map(HttpServletRequest req) throws IOException {
 44         String xml = req2xml(req);
 45         System.out.println("xml字符串：" + xml);
 46         try {
 47             Map<String,String> maps = new HashMap<String, String>();
 48             Document document = DocumentHelper.parseText(xml);
 49             Element root = document.getRootElement();
 50             List<Element> eles = root.elements();
 51             for(Element e:eles) {
 52                 maps.put(e.getName(), e.getTextTrim());
 53             }
 54             return maps;
 55         } catch (DocumentException e) {
 56             e.printStackTrace();
 57         }
 58         return null;
 59     }
 60     
 61     private static String req2xml(HttpServletRequest req) throws IOException {
 62         BufferedReader br = null;
 63         br = new BufferedReader(new InputStreamReader(req.getInputStream(), "utf-8"));
 64         String str = null;
 65         StringBuffer sb = new StringBuffer();
 66         while((str=br.readLine())!=null) {
 67             sb.append(str);
 68         }
 69         return sb.toString();
 70     }
 71     
 72     public static String handlerMsg(Map<String, String> msgMap) throws IOException {
 73         String msgType = msgMap.get("MsgType");
 74         if(msgType.equals(WeixinFinalValue.MSG_EVENT_TYPE)) {
 75             
 76         } else if(msgType.equals(WeixinFinalValue.MSG_TEXT_TYPE)) {
 77             return textTypeHandler(msgMap);
 78         } else if(msgType.equals(WeixinFinalValue.MSG_IMAGE_TYPE)) {
 79             return imageTypeHandler(msgMap,msgMap.get("MediaId"));
 80         }
 81         return null;
 82     }
 83     
 84     private static String imageTypeHandler(Map<String, String> msgMap,String mediaId) throws IOException {
 85         Map<String,String> map = new HashMap<String, String>();
 86         map.put("ToUserName", msgMap.get("FromUserName"));
 87         map.put("FromUserName", msgMap.get("ToUserName"));
 88         map.put("CreateTime", new Date().getTime()+"");
 89         map.put("MsgType", "image");
 90         System.out.println("mediaId:" + mediaId);
 91         map.put("Image", "<MediaId>"+mediaId+"</MediaId>");
 92         return map2xml(map);
 93     }
 94     
 95     private static String textTypeHandler(Map<String, String> msgMap) throws IOException {
 96         Map<String,String> map = new HashMap<String, String>();
 97         map.put("ToUserName", msgMap.get("FromUserName"));
 98         map.put("FromUserName", msgMap.get("ToUserName"));
 99         map.put("CreateTime", new Date().getTime()+"");
100         map.put("MsgType", "text");
101         String replyContent = "你请求的消息的内容不正确!";
102         String con = msgMap.get("Content");
103         if(replyMsgs.containsKey(con)) {
104             replyContent = replyMsgs.get(con);
105         }
106         map.put("Content", replyContent);
107         return map2xml(map);
108     }
109     
110     public static String map2xml(Map<String, String> map) throws IOException {
111         Document d = DocumentHelper.createDocument();
112         Element root = d.addElement("xml");
113         Set<String> keys = map.keySet();
114         for(String key:keys) {
115             root.addElement(key).addText(map.get(key));
116         }
117         StringWriter sw = new StringWriter();
118         //d.write(sw);//会造成标签被转义  , 改进方法
119         XMLWriter xw = new XMLWriter(sw);
120         xw.setEscapeText(false);
121         xw.write(d);
122         
123         return sw.toString();
124     }
125     
126     
127     //测试类使用方法:模板消息
128     public static String postTemplateMsg(TemplateMsg tm) {
129         CloseableHttpClient client = null;
130         CloseableHttpResponse response = null;
131         try {
132             client = HttpClients.createDefault();
133             String url = WeixinFinalValue.SEND_TEMPLATE_MSG ; 
134             url = url.replace("ACCESS_TOKEN", RefreshAccessTokenTask.refreshToken());
135             HttpPost post = new HttpPost(url);
136             String json = JsonUtil.getInstance().obj2json(tm);
137             post.addHeader("Content-Type","application/json");
138             StringEntity entity = new StringEntity(json , ContentType.create("application/json", "utf-8"));
139             post.setEntity(entity);
140             response = client.execute(post);
141             int statusCode = response.getStatusLine().getStatusCode();
142             if(statusCode >= 200 && statusCode < 300){
143                 String str = EntityUtils.toString(response.getEntity());
144                 System.out.println(str);
145                 return str ; 
146         }
147         } catch (ClientProtocolException e) {
148             e.printStackTrace();
149         } catch (IOException e) {
150             e.printStackTrace();
151         }
152         return null;
153     }
154     
155     //模板消息
156     public static String postTemplateMsg2(TemplateMsg tm) {
157         CloseableHttpClient client = null;
158         CloseableHttpResponse response = null;
159         String url = WeixinFinalValue.SEND_TEMPLATE_MSG;
160         url = url.replace("ACCESS_TOKEN", RefreshAccessTokenTask.at);
161         String json = JsonUtil.getInstance().obj2json(tm);
162         return WeixinKit.postReq(url, json, "application/json");
163     }
164 }

3 微信相关常量url

 1 package org.konghao.weixin.model;
 2 
 3 public class WeixinFinalValue {
 4     public final static String APPID = "wxb6cb4dfef6995d43";
 5     public final static String APPSECRET = "e069099f1e9d95794c1b015d216a50f6";
 6     public final static String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";
 7     public final static String MENU_ADD = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=ACCESS_TOKEN";
 8     
 9     public final static String MSG_TEXT_TYPE = "text";
10     public final static String MSG_IMAGE_TYPE = "image";
11     public final static String MSG_VOICE_TYPE = "voice";
12     public final static String MSG_VIDEO_TYPE = "video";
13     public final static String MSG_SHORTVIDEO_TYPE = "shortvideo";
14     public final static String MSG_LOCATION_TYPE = "location";
15     public final static String MSG_EVENT_TYPE = "event";
16     
17     //素材管理 ： 新增临时素材
18     public final static String POST_MEDIA="https://api.weixin.qq.com/cgi-bin/media/upload?access_token=ACCESS_TOKEN&type=TYPE";
19     //素材管理 ：获取临时素材
20     public final static String GET_MEDIA="https://api.weixin.qq.com/cgi-bin/media/get?access_token=ACCESS_TOKEN&media_id=MEDIA_ID";
21     
22     //消息管理  发送模板消息
23     public final static String SEND_TEMPLATE_MSG = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=ACCESS_TOKEN";
24 
25     //用户
26     public final static String ADD_GROUP = "https://api.weixin.qq.com/cgi-bin/groups/create?access_token=ACCESS_TOKEN";
27     public final static String QUERY_ALL_GROUP = "https://api.weixin.qq.com/cgi-bin/groups/get?access_token=ACCESS_TOKEN";
28     public final static String QUERY_USER_GROUP = "https://api.weixin.qq.com/cgi-bin/groups/getid?access_token=ACCESS_TOKEN";
29     public final static String UPDATE_GROUP_NAME = "https://api.weixin.qq.com/cgi-bin/groups/update?access_token=ACCESS_TOKEN";
30     public final static String MOVE_USER_GROUP = "https://api.weixin.qq.com/cgi-bin/groups/members/update?access_token=ACCESS_TOKEN";
31     public final static String MOVE_USERS_GROUP = "https://api.weixin.qq.com/cgi-bin/groups/members/batchupdate?access_token=ACCESS_TOKEN";
32     public final static String DELETE_GROUP_USER = "https://api.weixin.qq.com/cgi-bin/groups/delete?access_token=ACCESS_TOKEN";
33     
34     
35 }

查看全文

相关阅读:
搭建wamp环境，数据库基础知识
 练习题：选择器和选择好友
 例子：滑动效果
 TCPDump
内存
 Cache和Buffer的区别(转载)
经典问题回忆
 history
DNS
bc的用法

原文地址：https://www.cnblogs.com/a757956132/p/5411483.html

微信get post请求到微信服务器 模版 素材操作

微信get post请求到微信服务器模版素材操作