- 2020-1-28 23:11
流程优化和内容说明增加
2019-nCoV 牵动很多人的身心，借助自动化更友好的关注自己所关心的数据，在这紧张的情况下稍稍放松一下自己的身心。数据来源于丁香园，教程中涉及到企业微信的推送，相关教程这里找到：
目前提供三个功能
- 关注地区感染人数变化通知
- 相关最新消息通知
- 查询相关地区确认人数
流程里面涉及了两个 link 节点，微信内容后面的链接的是 高级推送 节点， 处理微信发送前面连接是 企业微信 服务器节点
修改内容如下， 应用id和部门的id
部门id获取方式如下：
实时新闻 下面的微信播送内容里面修改自己关注的省份信息，格式如下 ：
实时新闻和疫情推送都会判断消息是否已经推送过，当没有记录时以当前时间作为判断， 测试的时候可以把注释去掉
同时启用了微信消息去重功能，0是关闭，默认时间是1800s就是半个小时重复的消息不能推送
pushbear 流程示例
相关流程
[{"id":"fce8e4cb.4f33e8","type":"tab","label":"疫情提醒","disabled":false,"info":""},{"id":"dec5b0a0.5e498","type":"http request","z":"fce8e4cb.4f33e8","name":"","method":"GET","ret":"txt","url":"https://3g.dxy.cn/newh5/view/pneumonia","tls":"","x":220,"y":120,"wires":[["8bc5e4f1.fc6198"]]},{"id":"bf66d4fe.218f48","type":"inject","z":"fce8e4cb.4f33e8","name":"","topic":"","payload":"","payloadType":"date","repeat":"300","crontab":"","once":false,"onceDelay":0.1,"x":90,"y":120,"wires":[["dec5b0a0.5e498"]]},{"id":"8bc5e4f1.fc6198","type":"switch","z":"fce8e4cb.4f33e8","name":"请求正常的","property":"statusCode","propertyType":"msg","rules":[{"t":"eq","v":"200","vt":"str"}],"checkall":"true","repair":false,"outputs":1,"x":390,"y":120,"wires":[["5179dd9a.0ca5a4"]]},{"id":"144cb62d.12a5da","type":"debug","z":"fce8e4cb.4f33e8","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","x":610,"y":400,"wires":[]},{"id":"5179dd9a.0ca5a4","type":"function","z":"fce8e4cb.4f33e8","name":"基于正则提取内容","func":"const newsReg = /<script id=\"getTimelineService\">.+?window.getTimelineService\\s=\\s(\\[{.+?\\])}catch\\(e\\){}<\\/script>/\nconst dataReg = /<script id=\"getListByCountryTypeService1\">.+?window.getListByCountryTypeService1\\s=\\s(\\[{.+?\\])}catch\\(e\\){}<\\/script>/\nconst regAreaStat = /<script id=\"getAreaStat\">.+?window.getAreaStat\\s=\\s(\\[{.+?\\])}catch\\(e\\){}<\\/script>/\nconst regStatistics = /<script id=\"getStatisticsService\">.+?window.getStatisticsService\\s=\\s({.+?)}catch\\(e\\){}<\\/script>/\nconst payload = msg.payload\n\n\n\nlet news = payload.match(newsReg);\nlet data = payload.match(dataReg);\nlet areaStat = payload.match(regAreaStat);\nlet statistics = payload.match(regStatistics);\n\n\nconst newMsg = {}\n\nif (news && news.length > 1) {\n newMsg.news = JSON.parse(news[1])\n}\n\nif (statistics && statistics.length > 1) {\n newMsg.statistics = JSON.parse(statistics[1])\n}\n\nconst areaObj = {}\nif (areaStat && areaStat.length > 1) {\n const ad = JSON.parse(areaStat[1])\n newMsg.areaStat = ad\n \n for (let i = 0; i < ad.length; i++) {\n areaObj[ad[i].provinceShortName] = ad[i]\n }\n newMsg.areaObj = areaObj\n}\n\nconst retObj = {}\n\nif (data && data.length > 1) {\n const n = JSON.parse(data[1])\n newMsg.payload = n\n \n for (let i = 0; i < n.length; i++) {\n retObj[n[i].provinceShortName] = n[i]\n }\n newMsg.retObj = retObj\n \n}\n\nif (newMsg.payload && newMsg.areaStat && newMsg.statistics && newMsg.news) {\n return [newMsg, null]\n}else {\n if(msg.times > 1) {\n return null\n }\n newMsg.times = 2\n return [null, newMsg]\n}\n\n\n\n","outputs":2,"noerr":0,"x":570,"y":120,"wires":[["34b7cae3.d04fe6","b0845e10.0b21b","4844d129.1ada9"],["31aa6dfc.8c9092"]]},{"id":"34b7cae3.d04fe6","type":"function","z":"fce8e4cb.4f33e8","name":"实时新闻","func":"const keyName = 'news_last_time'\nlet lastTime = global.get(keyName) || new Date().getTime()\n\n\nconst news = msg.news\n\nif (!news) {\n return null\n}\n\nlet n = null\nlet index = -1;\n\nfor (let i = 0; i < news.length; i++) {\n n = news[i]\n if (n.createTime > lastTime) {\n index = i\n }else {\n break\n }\n \n}\n\nfor (let i = index; i >= 0; i--) {\n node.send(news[i])\n}\n\nconst newsData = news[0]\nglobal.set(keyName, newsData.createTime)\n\n","outputs":1,"noerr":0,"x":360,"y":280,"wires":[["4841baf9.407be4"]]},{"id":"b234cb.f7707b38","type":"debug","z":"fce8e4cb.4f33e8","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","x":690,"y":220,"wires":[]},{"id":"4841baf9.407be4","type":"delay","z":"fce8e4cb.4f33e8","name":"","pauseType":"rate","timeout":"5","timeoutUnits":"seconds","rate":"1","nbRateUnits":"5","rateUnits":"second","randomFirst":"1","randomLast":"5","randomUnits":"seconds","drop":false,"x":520,"y":280,"wires":[["b234cb.f7707b38","662eaf8.c549a5"]]},{"id":"31aa6dfc.8c9092","type":"delay","z":"fce8e4cb.4f33e8","name":"","pauseType":"delay","timeout":"5","timeoutUnits":"seconds","rate":"1","nbRateUnits":"1","rateUnits":"second","randomFirst":"1","randomLast":"5","randomUnits":"seconds","drop":false,"x":280,"y":200,"wires":[["dec5b0a0.5e498"]]},{"id":"b0845e10.0b21b","type":"function","z":"fce8e4cb.4f33e8","name":"微信播送内容","func":"const keyName = 'pusher_last_time'\nlet lastTime = global.get(keyName) || new Date().getTime()\n//lastTime = 0\nif (msg.statistics.modifyTime - lastTime < 1000 * 3 * 60) {\n return\n}\nglobal.set(keyName, msg.statistics.modifyTime)\n//\nconst d = new Date(msg.statistics.modifyTime)\nconst cities = ['湖北', '浙江']\nconst cityDescri = []\n\nfor (let i = 0; i < cities.length; i++) {\n let obj = msg.areaObj[cities[i]]\n cityDescri.push(`${obj.provinceName}, 确诊 ${obj.confirmedCount}, 死亡 ${obj.deadCount}, 治愈 ${obj.curedCount}`)\n}\nmsg.title = `全国数据统计，确诊 ${msg.statistics.confirmedCount}，疑似 ${msg.statistics.suspectedCount}，死亡 ${msg.statistics.deadCount}，治愈 ${msg.statistics.curedCount}`\nmsg.description = `截至 ${d.toLocaleString()}（北京时间）\n全国数据统计，确诊 ${msg.statistics.confirmedCount}，疑似 ${msg.statistics.suspectedCount}，死亡 ${msg.statistics.deadCount}，治愈 ${msg.statistics.curedCount}\n${cityDescri.join('\\n')}\n各项指标详情请点击进入查看\n`\n\nmsg.payload = {\n \"toparty\" : '4',\n \"msgtype\" : \"news\",\n \"agentid\" : \"1000006\",\n \"news\" : {\n \"articles\" : [\n {\n \"title\" : msg.title,\n \"description\" : msg.description,\n \"url\" : \"https://3g.dxy.cn/newh5/view/pneumonia\",\n \"picurl\" : \"http://image.thepaper.cn/www/image/44/788/266.jpg\"\n }\n ]\n },\n \"enable_id_trans\": 1\n}\nreturn msg;","outputs":1,"noerr":0,"x":340,"y":360,"wires":[["91a65042.d3ba1","144cb62d.12a5da"]]},{"id":"91a65042.d3ba1","type":"link out","z":"fce8e4cb.4f33e8","name":"","links":["de1dc7ef.474298"],"x":775,"y":360,"wires":[]},{"id":"662eaf8.c549a5","type":"function","z":"fce8e4cb.4f33e8","name":"微信消息内容","func":"msg.description = ``\nmsg.payload = {\n \"toparty\" : '4',\n \"msgtype\" : \"news\",\n \"agentid\" : \"1000006\",\n \"news\" : {\n \"articles\" : [\n {\n \"title\" : msg.title,\n \"description\" : msg.summary,\n \"url\" : msg.sourceUrl,\n \"picurl\" : \"http://image.thepaper.cn/www/image/44/788/266.jpg\"\n }\n ]\n }\n}\n\nreturn msg;","outputs":1,"noerr":0,"x":720,"y":280,"wires":[["91a65042.d3ba1"]]},{"id":"4844d129.1ada9","type":"function","z":"fce8e4cb.4f33e8","name":"缓存疫情信息","func":"const data = msg.areaStat\nconst CACHE_P = {}\nconst CACHE_P_S = {}\n\nfor (let i = 0; i < data.length; i++) {\n CACHE_P[data[i].provinceName] = data[i].provinceShortName\n CACHE_P_S[data[i].provinceShortName] = data[i].provinceShortName\n let cities = data[i].cities\n \n for (let c = 0; c < cities.length; c++) {\n let city = cities[c]\n \n CACHE_P[city.cityName] = data[i].provinceShortName\n }\n\n}\nconst keyName1 = 'pusher_cities_1'\nconst keyName2 = 'pusher_cities_2'\nconst keyName3 = 'CACHE_DATA'\nglobal.set(keyName1, CACHE_P)\nglobal.set(keyName2, CACHE_P_S)\nglobal.set(keyName3, msg)\n\n\nreturn msg;","outputs":1,"noerr":0,"x":780,"y":80,"wires":[[]]},{"id":"9f754fb4.c8b08","type":"link in","z":"fce8e4cb.4f33e8","name":"","links":["2f837926.c813c6"],"x":80,"y":460,"wires":[["b676040f.474648"]]},{"id":"b676040f.474648","type":"function","z":"fce8e4cb.4f33e8","name":"处理微信发送的消息","func":"const keyName1 = 'pusher_cities_1'\nconst keyName2 = 'pusher_cities_2'\nconst keyName3 = 'CACHE_DATA'\nconst CACHE_DATA = global.get(keyName3) || {}\n\nfunction getStatistics(name) {\n if (!CACHE_DATA.areaObj) return '';\n const provinceData = CACHE_DATA.areaObj[name]\n //console.log(JSON.stringify(provinceData))\n const statistics = CACHE_DATA.statistics\n\n let cities = provinceData.cities\n let msg = []\n msg.push(`${provinceData.provinceShortName} 确认${provinceData.confirmedCount}例`)\n for (let i = 0; i < cities.length; i++) {\n let c = cities[i]\n msg.push(`${c.cityName} 确认${c.confirmedCount}例`)\n }\n return `🏥疫情查询\n\n${msg.join('\\n')}\n时间： ${new Date(statistics.modifyTime).toLocaleString()}\n💊疫情播报→ t.cn/A6v1xgC0\n `\n}\n\nconst CACHE_P = global.get(keyName1) || {}\nconst CACHE_P_S = global.get(keyName2) || {}\nconst message = msg.message\n\nif(CACHE_P[message.Content] || CACHE_P_S[message.Content]) {\n let name = CACHE_P[message.Content] || CACHE_P_S[message.Content]\n msg.data = getStatistics(name)\n }else {\n return null\n }\n \n \n \n msg.payload = {\n \"touser\" : message.FromUserName,\n \"agentid\" : \"1000006\",\n \"msgtype\" : \"text\",\n \"text\" : {\n \"content\" : msg.data\n \n },\n \"safe\":0,\n \"enable_id_trans\": 0,\n \"enable_duplicate_check\": 0\n}\n\n\nreturn msg;","outputs":1,"noerr":0,"x":250,"y":460,"wires":[["57568615.fc84a8","91a65042.d3ba1"]]},{"id":"57568615.fc84a8","type":"debug","z":"fce8e4cb.4f33e8","name":"","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","x":530,"y":500,"wires":[]}]