egg定時任務

時間 2019-12-07

標籤 egg 定時任務简体版

原文原文鏈接

代碼地址 https://github.com/MoceptWeb/...
看以前肯定至少了解了一下egg的文檔了，否則看下面是浪費時間哈
有不對的地方請你們猛烈的提醒我吧

egg定時任務

不少狀況咱們須要去定時（或者就一次）執行某些腳本，這個時候就能夠利用egg的schedule功能了javascript

怎樣寫

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支持異步操做java

// 按行特殊處理文件後獲取所有數據返回（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;
        }
    }