koa2开发微信公众号: 不定期推送最新币圈消息
当然你也可以不看wechat-koa2的代码,直接使用下面的demo,不用百行代码便可轻松实现定制的币圈最新消息推送,后期会推出自动爬取全球各大交易所的最新消息,任何币种上线第一时间通知到位 先放出wechat-koa2 API,后续有时间再根据库币提供的api作封装 插播一个广告: 库币是由一群数字资产爱好者创建而成的一个专注区块链资产的交易平台,创始团队主要来自蚂蚁金服、广发证券等互联网和金融公司,致力于打造世界级的区块链资产交易平台。(跟NEO发放GAS一样,定期每天会根据用户持有的KCS发放鼓励金) 邀请注册链接 -> https://www.kucoin.com/#/?r=E... 0x00 wechat-koa2const config = require('./config') const Koa = require('koa') const app = new Koa() const Router = require('koa-router') const router = new Router() const Wechat = require('wechat-koa2') const w = new Wechat(config) // 封装过后的koa-bodyparser app.use(w.bodyParser()) // 微信服务器校验 router.get('/',async(ctx) => { w.serverVerify(ctx) }) // 监听用户发送过来的消息 router.post('/',async (ctx) => { await w.listening(ctx) } // 具体业务在可全写在这里,注册监听(具体看后文介绍) // .... // .... app.use(router.routes()).use(router.allowedMethods()) console.log('START: ',`wechat server is listening at ${config.port} ...`) app.listen(config.port) 0x01 发送币种,查询实时价格和涨幅这里使用的是sosobtc的接口,当然你也可以使用其他接口,如 zb.com、库币 等 const config = require('./config') const Koa = require('koa') const app = new Koa() const Router = require('koa-router') const router = new Router() const Wechat = require('wechat-koa2') const w = new Wechat(config) // 封装过后的koa-bodyparser app.use(w.bodyParser()) // 微信服务器校验 router.get('/',async (ctx) => { await w.listening(ctx) } // 具体业务 具体业务 具体业务 w.onText(data => { const text = data.Content.toLowerCase() const coinURL = `http://sosobtc.in/api/vi/analysis/coinAllWeb?coin=${text}` w.get(coinURL).then(result => { result = result[0] const coin = result.coin const webSiteCn = result.webSiteCn || result.webSite const change24H = result.change24H const close = result.close const high = result.high const low = result.low if(coin.toLowerCase() === 'btc') { w.replyText(result_2 => { toUser: result_2.FromUserName,fromUser: result_2.ToUserName,content: `当前查询币种: BTC (${webSiteCn}) 最新价格: ${close} 24H涨幅: ${change24H}% 最高价格: ${high} USD 最低价格: ${low} USD 来源: <a href="http://sosobtc.in/soso/kline_list?coin=btc">点击这里</a> ` }) } else { w.replyText(result_2 => { toUser: result_2.FromUserName,content: `当前查询币种: ${coin.toLowerCase()} (${webSiteCn}) 最新价格: ${close} 24H涨幅: ${change24H}% 最高价格: ${high} BTC 最低价格: ${low} BTC 来源: <a href="http://sosobtc.in/soso/kline_list?coin=${coin.toLowerCase()}">点击这里</a> ` }) } }) }) app.use(router.routes()).use(router.allowedMethods()) console.log('START: ',`wechat server is listening at ${config.port} ...`) app.listen(config.port)
(编辑:ASP站长网) |