tg_factory_main.js 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. setInterval(() => {
  2. }, 15000);
  3. const ProcessManager = require('./ProcessManager');
  4. const helper = require('./src/helper');
  5. const HttpClient = require('./src/HttpClient');
  6. const redis_help = require('./src/use_redis');
  7. const tools = require('./tools');
  8. redis_help.connect( async (results)=>{
  9. if(results){
  10. // main()
  11. // let response = helper.resolveDomain("www.changdunovel.com")
  12. // console.log("response:",response)
  13. console.log("results:",await redis_help.getKeyValue("isPauseTask"))
  14. }
  15. })
  16. // let get_hy_group_mapping = require('./src/api/hy/get_hy_group_mapping');
  17. // get_hy_group_mapping.get_group_mapping((data)=>{
  18. // if(data.code==200){
  19. // let list = data.data
  20. // }
  21. // console.log("get_hy_group_mapping:",data)
  22. // })
  23. // setTimeout( async ()=>{
  24. // let black_books = await redis_help.getKeyValue("all_black_books")
  25. // console.log("black_books:",black_books)
  26. // },5000)
  27. // let main = async function(){
  28. // let test = new HttpClient()
  29. // const postData = {
  30. // cmd:"create_link",
  31. // name:"台风夜老婆去救男秘书",
  32. // bookId:"1848991033902665730",
  33. // topUpTemplateId:"1854833762266247169",
  34. // passBackTemplateId:"6",
  35. // paidPoint:"9999999",
  36. // token:await tools.getHyToken()
  37. // };
  38. // let data = {
  39. // "name": postData.name,
  40. // "bookId": postData.bookId,
  41. // "passBackTemplateId": postData.passBackTemplateId,
  42. // "adPassbackTemplateId": "",
  43. // "topUpTemplateId": postData.topUpTemplateId,
  44. // "mediaChannel": "1",
  45. // "group": "35",
  46. // "paidPoint": postData.paidPoint,
  47. // "site": "5"
  48. // }
  49. // let res = await test.otherPost( helper.getHyCreateLinkOpt(postData.token) ,data)
  50. // console.log("res:",res)
  51. // let response = {
  52. // "message": "create_link successfully",
  53. // "received_data":{"originalId":res["data"]["originalId"],
  54. // "appId":res["data"]["appId"],
  55. // "launchPath":res["data"]["launchPath"],
  56. // "fullPath":res["data"]["fullPath"],
  57. // "wxMountLink":res["data"]["wxMountLink"]}
  58. // }
  59. // console.log("response:",response)
  60. // }
  61. // var main = function(){
  62. // require("./2_PRODUCT_FACTORY/PRODUCT_FACTORY")
  63. // require("./5_CREATE_LINK_FACTORY/CREATE_LINK_FACTORY")
  64. // require("./MAIN_SERVE_FACTORY/MAIN_SERVE_FACTORY")
  65. // require("./0_RECEIVE_FACTORY/RECEIVE_FACTORY")
  66. // require("./1_FILTER_FACTORY/FILTER_FACTORY")
  67. // }
  68. // let main = function(){
  69. // let manager = new ProcessManager()
  70. // manager.start()
  71. // manager.workers.forEach((v,k)=>{
  72. // if (v.process) {
  73. // v.process.send({
  74. // type: 'config',
  75. // data: { /* 配置数据 */ }
  76. // });
  77. // }
  78. // })
  79. // }