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');
const config = require('./etc/config.json')
const hy_search_book = require('./src/api/hy/hy_search_book'); 
// function getPlatformInfoByI(PlatformConfig,tg_platform_id){
//     for (let index = 0; index < PlatformConfig.length; index++) {
//         const element = PlatformConfig[index];
//         if(element.tg_platform_id==tg_platform_id){
//             return element
//         }
//     }
//     return null
// }

// function getMainInfoById(MainConfig,main_id){
//     // console.log("MainConfig:",MainConfig)
//     for (let index = 0; index < MainConfig.length; index++) {
//         const element = MainConfig[index];
//         if(element.id==main_id){
//             return element
//         }
//     }
//     return null
// }
let isInit = false
// config.isDebug
if(config.isDebug){
    redis_help.connect( async (results)=>{
        if(results){
            isInit = true
            // main()
            // let hy_book_data = await require('./2_PRODUCT_FACTORY/collect_hy_book').runTask({book_id:"1869900926728654850"})
            // console.log("hy_book_data:",hy_book_data)
        }
    })
}

// let data = await hy_search_book.search_id("1868479666362478594")
// console.log("data:",data)

        //  let response =  helper.resolveDomain("clipvideoup.s6kuwan.com")
        //  console.log("response:",response)



            // let MainConfig = await redis_help.getKeyValue("MainConfig")
            // MainConfig = JSON.parse(MainConfig)
            // let PlatformConfig = await redis_help.getKeyValue("PlatformConfig")
            // PlatformConfig = JSON.parse(PlatformConfig)

            // let PlatformInfo =  getPlatformInfoByI(PlatformConfig,4)

            // let main_info = getMainInfoById(MainConfig,150)

            // let data = {
            //     product_id:"11010288676",
            //     product_name:"侍女有谋"
            // }
 
            // require("./5_CREATE_LINK_FACTORY/dz_create_link").runTask(data,main_info,PlatformInfo,()=>{

            // })

            // let data = await require('./src/api/dz/dz_search_book').search_id('11010288676')
            // console.log("data:",data)
            //  require('./src/api/qm/qm_search_book').search_id('396740')
            // console.log("results:",await redis_help.getKeyValue("isPauseTask"))




            // let MainConfig = await redis_help.getKeyValue("MainConfig")
            // MainConfig = JSON.parse(MainConfig)
            // let PlatformConfig = await redis_help.getKeyValue("PlatformConfig")
            // PlatformConfig = JSON.parse(PlatformConfig)

            // let PlatformInfo =  getPlatformInfoByI(PlatformConfig,3)

            // let main_info = getMainInfoById(MainConfig,151)

            // let data = {
            //     product_id:"393425",
            //     product_name:"转学生自称苗疆圣子，可我才是真圣子"
            // }
 
            // let {promotion_name} = await require("./5_CREATE_LINK_FACTORY/qm_create_link").runTask(data,main_info,PlatformInfo,()=>{

            // })
            // console.log("promotion_name:",promotion_name)
            // let n_data = await require("./src/api/qm/get_qm_promotion").getPromotionList(promotion_name)
            // console.log("get_qm_promotion:",n_data)


// let get_hy_group_mapping = require('./src/api/hy/get_hy_group_mapping');
// get_hy_group_mapping.get_group_mapping((data)=>{
//     if(data.code==200){
//         let list = data.data
//     }
//     console.log("get_hy_group_mapping:",data)
// })

// setTimeout( async ()=>{
//     let black_books = await redis_help.getKeyValue("all_black_books")
//     console.log("black_books:",black_books)
// },5000)
// let main = async function(){
//     let test = new HttpClient()
//     const postData = {
//         cmd:"create_link",
//         name:"台风夜老婆去救男秘书",
//         bookId:"1848991033902665730",
//         topUpTemplateId:"1854833762266247169",
//         passBackTemplateId:"6",
//         paidPoint:"9999999",
//         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: { /* 配置数据 */ } 
//             });
//         }
//     })
// }