egg定时任务

代码地址 github.com/MoceptWeb/e… 看以前肯定至少了解了egg的文档了， 否则看下面是浪费时间哈

egg定时任务

不少状况咱们须要去定时（或者就一次）执行某些脚本， 这个时候就能够利用egg的schedule功能了

怎样写

schedule

• {app_root}/app/schedule.js

// 经过 schedule 属性来设置定时任务的执行间隔等配置
  static get schedule() {
    return {
      interval: '5m', // 5 min间隔
      type: 'worker', // worker 类型：每台机器上只有一个 worker 会执行这个定时任务
    };
  }
  async subscribe() {
    this.ctx.logger.info('schedule updateOa2User begin')
    const res = await this.ctx.service.portal.oa.updateOa2User();
    this.ctx.logger.info('schedule updateOa2User finish')
  }
复制代码

启动时候自定决定启动哪些定时任务

在get schedule() 中配置immediate：配置了该参数为 true 时，这个定时任务会在应用启动并 ready 后马上执行一次这个定时任务

app.beforeStart(async () => {
    // await app.runSchedule('updateOa2User');updatePortal2User
    await app.runSchedule('updatePortal2User');
  });

复制代码

service

• {app_root}/app/service/portal/oa.js

sqlserver 链接

// helper.js 统一链接一个sqlserver connection
const mssql = require('mssql')
let pool = await mssql.connect(config)

// app.js 链接错误的日志
  mssql.on('error', err => {
    console.log('database err', err)
    app.logger.error(err);
    // ... error handler
  })
复制代码

异步中的多个所有异步完成的操做

• 例如对一个数据进行一个个的异步操做， 可是最后获取所有异步后的结果

切忌不要在异步中作同步操做， 否则执行顺序很意外！！！

async updateUser(oaUser) {
        const self = this;
        let promiseAll = [];
      // 设置promise对象，同步发请求
        oaUser.forEach(oa => {
          promiseAll.push(Promise.resolve(self.updateUserByName(oa)));
        });
        await Promise.all(promiseAll);
    }
复制代码

• {app_root}/app/service/portal/portal.js

异步中的多个所有异步完成的操做

若是须要一步步获取所有数据（这里是同步）后才要进行所有异步其余操做， 那么须要先将同步操做封装成promise支持异步操做

async readLine(target) {
      let array = [];
      const self = this;
      const file = await new Promise(function (resolve, reject) {
        lineReader.eachLine(target, function(line, last) {
            // line.split(/\s/)[0]
            let data = line.split(/\s/)
            if(data[2]) {
                array.push({
                    user_id: self.ctx.helper.trim(data[0], '"'),
                    mail: self.ctx.helper.trim(data[1], '"'),
                    user_center_id: self.ctx.helper.trim(data[2], '"'),
                })
            }

            if(last) {
                resolve(array)
            }
        })
      })

      return file;

  }

// 使用
const fileData = await this.readLine(target);
    let promiseAll = [];
    fileData.forEach(portal => {
      promiseAll.push(Promise.resolve(self.updateUserByPortalId(portal)));
    });
await Promise.all(promiseAll);
复制代码

mysql

• sql的占位符

const res = await conn.query('update t_user set mail = ? where user_id = ?', [oaUser.email, user.user_id]);
复制代码

• sql的事务

async sqlBeginTransaction() {
        const conn = await this.app.mysql.beginTransaction();

        try {
            const res = await conn.query('update t_user set mail = ? where user_id = ?', [oaUser.email, user.user_id]);
            if(res && res.affectedRows === 1) {
               await conn.commit();
            } else if(res.affectedRows > 1){
                // this.ctx.logger.error('')
               await conn.rollback()                
            } else {
                await conn.rollback()                
            }
        } catch (err) {
        // error, rollback
          await conn.rollback(); // rollback call won't throw err throw err; } } 复制代码

extend

• {app_root}/app/extend/helper.js

统一封装各类数据的链接和error信息

test

• {app_root}/app/test/service/portal/portal.test.js 待完善

单元测试说明

config

谨记更环境用的配置是不同的

单元测试用的是 config.unittest.js

为何这样写

TODO 分析源码

拓展和优化

• 将service中的纯数据库封装到model

• 基于redis的任务消息队列的优化 不须要人工去进行开启任务

• 编写egg-mssql链接sqlserver