'use strict';
|
|
const {
|
OpenBridgeConfig
|
} = require('./config.js')
|
|
const {
|
TaskManager
|
} = require('./basic.js')
|
|
const {
|
TaskAccessTokenMP
|
} = require('./task-mp-weixin.js')
|
|
const {
|
TaskAccessTokenH5,
|
TaskTicket
|
} = require('./task-h5-weixin.js')
|
|
const TaskMapping = {
|
'mp-weixin': {
|
'accessToken': TaskAccessTokenMP
|
},
|
'h5-weixin': {
|
'accessToken': TaskAccessTokenH5,
|
'ticket': TaskTicket
|
}
|
}
|
|
class ScheduleManager extends TaskManager {
|
|
constructor() {
|
super()
|
}
|
|
async runAll() {
|
for (let i = 0; i < this.tasks.length; i++) {
|
const task = this.tasks[i]
|
|
try {
|
await task.run()
|
} catch (e) {
|
console.log("task.run::", e)
|
}
|
}
|
}
|
|
newTask(T, config) {
|
const newTask = new T(config)
|
|
super.addTask(newTask)
|
|
return newTask
|
}
|
}
|
|
ScheduleManager.instance = function() {
|
if (!ScheduleManager._instance) {
|
ScheduleManager._instance = new ScheduleManager()
|
}
|
return ScheduleManager._instance
|
}
|
|
async function main() {
|
const openBridgeConfig = new OpenBridgeConfig()
|
|
ScheduleManager.instance().clear()
|
|
for (let taskConfig of openBridgeConfig.tasks) {
|
let {
|
platform,
|
tasks
|
} = taskConfig
|
|
for (let taskName of tasks) {
|
const platformTask = TaskMapping[platform]
|
if (platformTask) {
|
ScheduleManager.instance().newTask(platformTask[taskName], taskConfig)
|
}
|
}
|
}
|
|
await ScheduleManager.instance().runAll()
|
}
|
|
module.exports = main;
|
