tg_factory/tg_factory_main.js

setInterval(() => {

}, 15000);
const ProcessManager = require('./ProcessManager');
const helper = require('./src/helper');
const HttpClient = require('./src/HttpClient');
const redis_help = require('./src/use_redis'); 
const tools = require('./tools');
redis_help.connect( async (results)=>{
    if(results){
        // main()
        console.log("results:",await redis_help.getKeyValue("isPauseTask"))
    }
})
// let main = async function(){
//     let test = new HttpClient()
//     const postData = {
//         cmd:"create_link",
//         name:"台风夜老婆去救男秘书",
//         bookId:"1848991033902665730",
//         topUpTemplateId:"1854833762266247169",
//         passBackTemplateId:"6",
//         paidPoint:0,
//         token:await tools.getHyToken()
//     };

//     let data = {
//         "name": postData.name,
//         "bookId": postData.bookId,
//         "passBackTemplateId":  postData.passBackTemplateId,
//         "adPassbackTemplateId": "",
//         "topUpTemplateId": postData.topUpTemplateId,
//         "mediaChannel": "1",
//         "group": "35", 
//         "paidPoint": postData.paidPoint,
//         "site": "5" 
//     }
//     let res =  await test.otherPost( helper.getHyCreateLinkOpt(postData.token) ,data)
//     console.log("res:",res)

//     let response = {
//         "message": "create_link successfully",
//         "received_data":{"originalId":res["data"]["originalId"],
//                          "appId":res["data"]["appId"],
//                          "launchPath":res["data"]["launchPath"],
//                          "fullPath":res["data"]["fullPath"],
//                          "wxMountLink":res["data"]["wxMountLink"]}
//     }
//     console.log("response:",response)
// }


// var main = function(){
//     require("./2_PRODUCT_FACTORY/PRODUCT_FACTORY")
//     require("./5_CREATE_LINK_FACTORY/CREATE_LINK_FACTORY")
//     require("./MAIN_SERVE_FACTORY/MAIN_SERVE_FACTORY")
//     require("./0_RECEIVE_FACTORY/RECEIVE_FACTORY")
//     require("./1_FILTER_FACTORY/FILTER_FACTORY")
// }


// let main = function(){
//     let manager = new ProcessManager()
//     manager.start()
//     manager.workers.forEach((v,k)=>{
//         if (v.process) {
//             v.process.send({ 
//                 type: 'config', 
//                 data: { /* 配置数据 */ } 
//             });
//         }
//     })
// }