1
2
3
4
5
6
7
8
9

.editorconfig
.gitignore
config.js
init/
package.json
README.md
src/
util/
yarn.lock

1
2
3
4
5
6
7

// Koa 框架
const Koa = require('koa')
// 实例化
const app = new Koa()
// 监听端口
app.listen(config.port)
console.log(`the server is start at port ${config.port}`)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

// index.js
const Koa = require('koa')
const KoaRouter = require('koa-router')

const app = new Koa()
// 创建 router 实例对象
const router = new KoaRouter()

//注册路由
router.get('/', async ctx => {
  ctx.body = 'welcome~'
})

// 添加路由中间件
app.use(router.routes())

// 对请求进行一些限制处理
app.use(router.allowedMethods())

// 监听启动端口
app.listen(config.port)
console.log(`the server is start at port ${config.port}`)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

// index.js
const Koa = require('koa')
const KoaRouter = require('koa-router')
const bodyParser = require('koa-bodyparser')
const config = require('../config')

const app = new Koa()
// 创建 router 实例对象
const router = new KoaRouter()
// 账单获取核心逻辑
const wechatBill = require('./controllers/wechatBill')

// 配置ctx.body解析中间件
app.use(bodyParser())

//注册路由
router.get('/', async ctx => {
  ctx.body = 'welcome~'
})

router.post('/wechatBill', wechatBill)

// 添加路由中间件
app.use(router.routes())

// 对请求进行一些限制处理
app.use(router.allowedMethods())

// 监听启动端口
app.listen(config.port)
console.log(`the server is start at port ${config.port}`)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

while (Loop) {

    if (lastResp.last_create_time < 1514736000) {
      wechatList.splice(wechatList.indexOf(wechat_id) >>> 0, 1)
      Loop = false
      console.log('任务处理完毕，2018全部数据已存入');
    }

    axios.request({
      url: `https://wx.tenpay.com/userroll/userrolllist`,
      method: 'get',
      headers: {
        "Accept": "*/*",
        "Accept-Encoding": "gzip, deflate",
        "Accept-Language": "zh-CN,en-US;q=0.8",
        "Connection": "keep-alive",
        "Cookie": `userroll_encryption=${userroll_encryption}; userroll_pass_ticket=${userroll_pass_ticket}`,
        "Host": "wx.tenpay.com",
        "Q-Auth": AUTH,
        "Q-GUID": GUID,
        "Q-UA2": UA2,
        "Referer": "https://wx.tenpay.com/?classify_type=0",
        "User-Agent": "Mozilla/5.0 (Linux; Android 8.0; MIX 2 Build/OPR1.170623.027; wv) AppleWebKit/537.36 (KHTML, like Gecko) Version/4.0 Chrome/57.0.2987.132 MQQBrowser/6.2 TBS/044408 Mobile Safari/537.36 MMWEBID/4508 MicroMessenger/7.0.1380(0x27000038) Process/tools NetType/WIFI Language/zh_CN",
        "X-DevTools-Emulate-Network-Conditions-Client-Id": ClientId,
        "X-Requested-With": "com.tencent.mm",
      },
      params: {
        classify_type: 0,
        count: PAGE_SIZE,
        exportkey,
        last_bill_id: lastResp.last_bill_id,
        last_bill_type: lastResp.last_bill_type,
        last_create_time: lastResp.last_create_time,
        last_trans_id: lastResp.last_trans_id,
        sort_type: 1,
        start_time: lastResp.start_time,
      }

    }).then((res) => {

      lastResp = res.data

      if (!lastResp || lastResp.ret_code != 0 || !lastResp.record) {
        console.log(lastResp);
        Loop = false
        ctx.body = {
          code: 2,
          res: lastResp.ret_msg || '任务请求失败'
        }
        throw new Error(`任务请求失败`)
      }

      ctx.body = {
        code: 0,
        res: '创建任务成功，正在获取账单中...'
      }

      const dataList = res.data.record.map(e => ({ wechat_id, ...e }))
      dataList.map(async e => {
        delete e.coupon
        const sql = `INSERT INTO orders(${Object.keys(e)}) VALUES (${JSON.stringify(Object.values(e))})`
        const data = await query(sql.replace(/\[|\]/g, ""))
        console.log(`存入成功`, data.insertId)
      })

    }).catch((err) => {
      console.log(err)
    });
    await sleep(1000)
  }