因Safari及微信内置浏览器均不支持下载文件，所以保存视频需要借助第三方App来完成下载。这次教教大家如何借助Documents App的内置浏览器来保存视频到手机相册。

第一步:关注公众号[考拉解析]获取视频mp4地址
和Android手机一样，将要下载的视频分享链接发送给 [考拉解析] 公众号。打开回复页面，点击 [复制视频] 按钮拷贝视频mp4地址。

第二步:借助Documents内置浏览器下载mp4文件
打开Documents App内置浏览器，粘贴刚才复制的mp4至地址栏 ，即可下载mp4文件。下载完成后，回到Documents的主界面，在"下载"文件夹里，就能看到刚才保存的视频了。

第三步:将下载的视频移动到手机相册
如果你想把这个视频移到手机相册，很简单，点这个视频右下角的三个点号(...)，然后选择移动，移动到"文档 > 照片"文件夹里就OK了。这个时候，你就可以在手机相册里看到这个视频了。

 

实现过程: Python发送请求获得微信公众号返回的json数据，微信公众号接口看这里。利用Python的requests包发送post请求返回json数据，解析出来需要的字段，利用阿里云的pyODPS包，写入阿里云的maxcompute
代码如下:
from odps import ODPS
from odps.models import Schema, Column, Partition
import requests
import json
import datetime
import redis
#参数定义
#r = redis.StrictRedis(host='redishost,password='redispassword', port=6379,db=1, decode_responses=True)
# access_token =r.get('foo')
access_token = "xxxxxxxxxxxxxxx"
ds = (datetime.datetime.now() + datetime.timedelta(days=-1)).strftime('%Y%m%d')
qureydate=(datetime.datetime.now() + datetime.timedelta(days=-1)).strftime('%Y-%m-%d')
o = ODPS('accesskey', 'Iaccessid',
project='projectname', endpoint='http://service.odps.aliyun.com/api')
#删除分区数据
t_articletotal=o.get_table('wechat_articletotal')
t_articletotal.delete_partition('ds=' + ds, if_exists=True)
para = {
"begin_date": str(qureydate),
"end_date": str(qureydate)
}
def get_articletotal():
url_articletotal = "https://api.weixin.qq.com/datacube/getarticletotal?access_token=" + access_token
response = requests.post(url=url_articletotal, json=para)
data=response.text
try:
lists=json.loads(data)['list']
for i in lists:
ref_date=datetime.datetime.strptime(i['ref_date'], "%Y-%m-%d") #数据的日期
msgid=i['msgid'] #图文消息id
title=i['title'] #图文消息标题
user_source=i['user_source'] #代表用户从哪里进入来阅读该图文。0:会话;1.好友;2.朋友圈;3.腾讯微博;4.历史消息页;5.其他
for j in i['details']:
stat_date=j['stat_date']
target_user=j['target_user']
int_page_read_user=j['int_page_read_user'] #图文页(点击群发图文卡片进入的页面)的阅读人数
int_page_read_count=j['int_page_read_count'] #图文页的阅读次数
ori_page_read_user=j['ori_page_read_user'] #原文页(点击图文页“阅读原文”进入的页面)的阅读人数，无原文页时此处数据为0
ori_page_read_count=j['ori_page_read_count'] #原文页的阅读次数
share_user=j['share_user'] #分享的场景1代表好友转发 2代表朋友圈 3代表腾讯微博 255代表其他
share_count=j['share_count'] #分享的次数
add_to_fav_user=j['add_to_fav_user'] #收藏的人数
add_to_fav_count=j['add_to_fav_count'] #收藏的次数
records_articletotal=(ref_date,msgid,title,user_source,stat_date,target_user,int_page_read_user,int_page_read_count,ori_page_read_user,ori_page_read_count,share_user,share_count,add_to_fav_user,add_to_fav_count)
o.write_table('wechat_articletotal', records_articletotal, partition='ds=' + ds, create_partition=True)
print('articletotal写入成功')
except Exception as e:
print(e)
if __name__ == '__main__':
get_articletotal()

如果要用阿里的dataphin调度Python任务，同时Python需要用到第三方包，比如Redis，可以通过创建shell脚本实现，在dataphin的研发界面，数据处理创建一个shell任务，代码如下.
顺便吐槽一下，用的居然是Python2.7,前面要加# -*- coding:utf-8*-，而且每次都要先装第三方包。。。。。。

#安装第三方Python包。
pip install -i https://mirrors.aliyun.com/pypi/simple/ \
redis
#指定的python源写入至wechat_data_etl.py。
cat >wechat_data_etl.py <<EOF
----上面的Python代码-----
EOF
#python中调用文件。
python wechat_data_etl.py
 

https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1421140453
1.解析普通信息.
代码
package servlet;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.HashMap;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import utils.WxUtils;
/**
* Servlet implementation class Wx
*/
public class Wx extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public Wx() {
super();
// TODO Auto-generated constructor stub
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
/*开发者提交信息后，微信服务器将发送GET请求到填写的服务器地址URL上，GET请求携带参数如下表所示:
参数 描述
signature 微信加密签名，signature结合了开发者填写的token参数和请求中的timestamp参数、nonce参数。
timestamp 时间戳
nonce 随机数
echostr 随机字符串*/
String signature = request.getParameter("signature");
String timestamp = request.getParameter("timestamp");
String nonce = request.getParameter("nonce");
String echostr = request.getParameter("echostr");
System.out.println(signature);
System.out.println(timestamp);
System.out.println(nonce);
System.out.println(echostr);
boolean checkSignature = WxUtils.CheckSignature(signature,timestamp,nonce);
if (checkSignature) {
System.out.println("success");
//
PrintWriter writer = response.getWriter();
writer.print(echostr);
writer.flush();
writer.close();
}else {
System.out.println("failed");
}
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
System.out.println("post");
//解析接收的消息
HashMap<String, String> hashMap=WxUtils.parseRequest(request.getInputStream());
System.out.println(hashMap);
}
}

 
package utils;
import java.security.MessageDigest;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import javax.servlet.ServletInputStream;
import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
public class WxUtils {
private static final String Token="shxx";
private static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5',
'6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
public static boolean CheckSignature(String signature, String timestamp, String nonce) {
// 1)将token、timestamp、nonce三个参数进行字典序排序
// 2)将三个参数字符串拼接成一个字符串进行sha1加密
// 3)开发者获得加密后的字符串可与signature对比，标识该请求来源于微信
String[] strs=new String[]{Token,timestamp,nonce};
Arrays.sort(strs);
String str=strs[0]+strs[1]+strs[2];
String mysignature=sha1(str);
return mysignature.equals(signature);
}
private static String sha1(String str) {
if (str == null) {
return null;
}
try {
MessageDigest messageDigest = MessageDigest.getInstance("SHA1");
messageDigest.update(str.getBytes());
return getFormattedText(messageDigest.digest());
} catch (Exception e) {
throw new RuntimeException(e);
}
}
private static String getFormattedText(byte[] bytes) {
int len = bytes.length;
StringBuilder buf = new StringBuilder(len * 2);
// 把密文转换成十六进制的字符串形式
for (int j = 0; j < len; j++) {
buf.append(HEX_DIGITS[(bytes[j] >> 4) & 0x0f]);
buf.append(HEX_DIGITS[bytes[j] & 0x0f]);
}
return buf.toString();
}
public static HashMap<String, String> parseRequest(ServletInputStream inputStream) {
/*参数 描述
ToUserName 开发者微信号
FromUserName 发送方帐号(一个OpenID)
CreateTime 消息创建时间 (整型)
MsgType 消息类型，文本为text
Content 文本消息内容
MsgId 消息id，64位整型*/
SAXReader saxReader = new SAXReader();
HashMap<String, String> map = new HashMap<>();
try {
Document document = saxReader.read(inputStream);
Element root = document.getRootElement();
List<Element> elements = root.elements();
for (Element element : elements) {
map.put(element.getName(), element.getStringValue());
}
return map;
} catch (DocumentException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return map;
}
}

 
2.扫描关注公众号

 
发送消息

解析消息

由于[考拉解析]公众号解析以后给出来的是一个网页链接，而微信内置浏览器又不支持直接下载视频(还有一些平台的视频链接被微信屏蔽了)所以需要用手机安装的浏览器来打开当前的网页进行下载(推荐Chrome、QQ、UC、360浏览器)
第一步:关注公众号[考拉解析]获取视频mp4地址
将要下载的视频分享链接发送给 [考拉解析] 公众号。打开回复页面，点右上角[┇]，选[在浏览器打开]。

第二步:在独立的浏览器(推荐Chrome、QQ、UC、360浏览器)中打开后，点击下载视频按钮即可