123

0_RECEIVE_FACTORY/RECEIVE_FACTORY.js

@@ -181,7 +181,43 @@ CMD.get_pull_token = async function(res){
     console.log('get_pull_token:', token);
 }
 
+CMD.get_dz_book = async function(book_id,res) {
+    let data = await require('../src/api/dz/dz_search_book').search_id(book_id)
+    res.writeHead(200, {'Content-Type': 'application/json'});
+    res.end(JSON.stringify({ message:"成功！",data:data,code:10000}));
+    console.log('get_dz_book:', data);
+}
 
+CMD.get_dz_callback_template = async function(channelId,res) {
+    console.log("get_dz_callback_template!")
+    require('../src/api/dz/get_dz_call_back_template').get_callback_template(channelId,(data)=>{
+        console.log('get_dz_callback_template:', data);
+        res.writeHead(200, {'Content-Type': 'application/json'});
+        res.end(JSON.stringify({ message:"成功！",data:data,code:10000}));
+    })
+}
+
+CMD.get_dz_recharge_template = async function(channelId,res) {
+    await require('../src/api/dz/get_dz_recharge_template').get_recharge_template(channelId,(data)=>{
+        console.log('get_dz_recharge_template:', data);
+        res.writeHead(200, {'Content-Type': 'application/json'});
+        res.end(JSON.stringify({ message:"成功！",data:data,code:10000}));
+    })
+}
+
+CMD.get_qm_callback_template = async function(res) {
+   let data = await require('../src/api/qm/get_qm_call_back_template').get_callback_template()
+   console.log('get_qm_callback_template:', data);
+   res.writeHead(200, {'Content-Type': 'application/json'});
+   res.end(JSON.stringify({ message:"成功！",data:data,code:10000}));
+}
+
+CMD.get_qm_recharge_template = async function(res) {
+    let data = await require('../src/api/qm/get_qm_recharge_template').get_recharge_template()
+    console.log('get_qm_recharge_template:', data);
+    res.writeHead(200, {'Content-Type': 'application/json'});
+    res.end(JSON.stringify({ message:"成功！",data:data,code:10000}));
+}
 
 var server = http.createServer(function(req,res){
 
@@ -234,6 +270,19 @@ var server = http.createServer(function(req,res){
                         CMD.get_fq_rechargeTemplate(res) 
                     }else if(jsonData['fun']=="get_pull_token"&&jsonData['cmd']=="pull_data_config"){
                         CMD.get_pull_token(res) 
+                    }else if(jsonData['fun']=="get_dz_book"&&jsonData['cmd']=="dz_link"){
+                        let book_id = jsonData['data']['book_id']
+                        CMD.get_dz_book(book_id,res) 
+                    }else if(jsonData['fun']=="get_dz_callback_template"&&jsonData['cmd']=="dz_link"){
+                        let channelId = jsonData['data']['channelId']
+                        CMD.get_dz_callback_template(channelId,res) 
+                    }else if(jsonData['fun']=="get_dz_recharge_template"&&jsonData['cmd']=="dz_link"){
+                        let channelId = jsonData['data']['channelId']
+                        CMD.get_dz_recharge_template(channelId,res) 
+                    }else if(jsonData['fun']=="get_qm_recharge_template"&&jsonData['cmd']=="qm_link"){
+                        CMD.get_qm_recharge_template(res) 
+                    }else if(jsonData['fun']=="get_qm_callback_template"&&jsonData['cmd']=="qm_link"){
+                        CMD.get_qm_callback_template(res) 
                     } else{
                         res.writeHead(200, {'Content-Type': 'application/json'});
                         res.end(JSON.stringify({ message: 'fun 错误',code:100}));

1_FILTER_FACTORY/FILTER_FACTORY.js

@@ -99,6 +99,12 @@ function filter_and_insert(origin_data,tg_config){
         obj.book_id = obj.key
     }else if(obj.channel=="黑岩"){
         tg_platform_id = 1
+    }else if(obj.channel=="七猫"){
+        tg_platform_id = 3
+        obj.book_id = obj.id
+    }else if(obj.channel=="点众"){
+        tg_platform_id = 4
+        obj.book_id = obj.book_id
     }
     // console.log("评论数正确")
     return {video_id:origin_data.video_id,book_id:obj.book_id,channel:obj.channel,source:obj.source,key:obj.key,video_link:origin_data.video_link,
@@ -108,6 +114,8 @@ function filter_and_insert(origin_data,tg_config){
 function getChannel(start_page,platform_select){
     let isOpenHeiYan = false
     let isOpenFanQie = false
+    let isOpenQiMao = false
+    let isOpenDianZhong = false
     for (let index = 0; index < platform_select.length; index++) {
         const element = platform_select[index];
         if(element==1){
@@ -116,6 +124,12 @@ function getChannel(start_page,platform_select){
         if(element==2){
             isOpenFanQie = true
         }
+        if(element==3){
+            isOpenQiMao = true
+        }
+        if(element==4){
+            isOpenDianZhong = true
+        }
     }
     // console.log("start_page:",isOpenHeiYan,isOpenFanQie,start_page)
     if(start_page=="pages/readPage/chapter?bookId"&&isOpenHeiYan){
@@ -123,6 +137,11 @@ function getChannel(start_page,platform_select){
     }else if(start_page=="pages/bookstore/index?aid"&&isOpenFanQie){
         return "番茄"
     }
+    // else if(start_page=="pages/reader/index?bookId"&&isOpenQiMao){ //点众
+    //     return "点众"
+    // }else if(start_page=="pages/reader/index?channel"&&isOpenDianZhong){ //七猫
+    //     return "七猫"
+    // }
     return null
 }
 
@@ -148,6 +167,7 @@ function parsePromotion(promotion,source_list,platform_select){
                 let item_info = {}
                 item_info['book_id'] = params['bookId'];
                 item_info['channel'] = channel;
+                item_info['id'] = params['id']
 
                 const str = params['x-signature']
                 const regex = /"name":"([^"]+)"/;

5_CREATE_LINK_FACTORY/dz_create_link.js

@@ -0,0 +1,58 @@
+//执行一个创建点众链接任务
+const axios = require('axios');
+const helper = require('../src/helper');
+const config = require('../etc/config.json')
+const HttpClient = require('../src/HttpClient')
+const CMD = {}
+
+CMD.runTask = async function(data,main_info,PlatformInfo,call_back){
+    let  tg_link_config = JSON.parse(main_info.tg_link_config)
+    let chongzhi_id = tg_link_config['chongzhi_id']
+    let chongzhi_list = JSON.parse(PlatformInfo.chongzhi)
+    let chongzhi_name = null
+    let recharge_template_id = ""
+    for (let index = 0; index < chongzhi_list.length; index++) {
+        const cz_obj = chongzhi_list[index];
+        if(cz_obj.id==chongzhi_id){
+          chongzhi_name = cz_obj.name
+          recharge_template_id = cz_obj.value
+          break
+        }
+    }
+
+    try {
+        let client = new HttpClient()
+        let clientId= config.dianzhong_config.clientId;
+        let timestamp = new Date().getTime();
+        let bookId = data.product_id;
+        let chapterIdx = 1;
+        let name = data.product_name;
+        let mediaSource = "dy";
+        let channelId = main_info.channelId;
+        let batchId = "";
+        let CallbackConfigId = "";
+        let fromDrId = "zywzfromDrId";
+        let chapterChargeStart = 1;
+        let chapterKandian = 0;
+        let response =  await client.post(config.dianzhong_config.create_link_host,{
+            clientId:clientId,
+            timestamp:timestamp,
+            bookId:bookId,
+            chapterIdx:chapterIdx,
+            name:name,
+            mediaSource:mediaSource,
+            channelId:channelId,
+            batchId:batchId,
+            CallbackConfigId:CallbackConfigId,
+            fromDrId:fromDrId,
+            chapterChargeStart:chapterChargeStart,
+            chapterKandian:chapterKandian
+        })
+    } catch (error) {
+        console.error('fq_create_link :Error:', error);
+        // 处理错误
+    }
+
+}
+
+module.exports = CMD;

5_CREATE_LINK_FACTORY/qm_create_link.js

@@ -0,0 +1,50 @@
+//执行一个创建七猫链接任务
+const axios = require('axios');
+const helper = require('../src/helper');
+const config = require('../etc/config.json')
+const HttpClient = require('../src/HttpClient')
+const CMD = {}
+
+CMD.runTask = async function(data,main_info,PlatformInfo,call_back){
+    let  tg_link_config = JSON.parse(main_info.tg_link_config)
+    let chongzhi_id = tg_link_config['chongzhi_id']
+    let chongzhi_list = JSON.parse(PlatformInfo.chongzhi)
+    let chongzhi_name = null
+    let recharge_template_id = ""
+    let appid = main_info.app_id
+    for (let index = 0; index < chongzhi_list.length; index++) {
+        const cz_obj = chongzhi_list[index];
+        if(cz_obj.id==chongzhi_id){
+          chongzhi_name = cz_obj.name
+          recharge_template_id = cz_obj.value
+          break
+        }
+    }
+
+
+
+
+
+    try {
+        let client = new HttpClient()
+
+        let response =  await client.request(config.qimao_config.create_link_host,{
+            admin_account_name:config.qimao_config.admin_account_name,
+            project:6,     //6 - 抖音小程序 8 -  微信小程序
+            appid:appid,
+            // create_time_start:0,
+            // create_time_end:0,
+            // last_modify_time_start:0,
+            // last_modify_time_end:0,
+            // page:0,
+            // page_size:0
+        })
+        return response
+    } catch (error) {
+        console.error('fq_create_link :Error:', error);
+        // 处理错误
+    }
+
+}
+
+module.exports = CMD;

PULL_DATA_FACTORY/PULL_DATA.js

@@ -128,7 +128,9 @@ async function processDetailTask() {
                             shared_num:info.shared_num,
                             is_guajian:1,
                             guajian_link:element.landingUrl,
-                            status:0
+                            status:0,
+                            createTime:info.createTime,
+                            updateTime:info.updateTime
                         }
                     )
                 }
@@ -258,61 +260,12 @@ async function processTask(timeRange){
         task_params = helper.getPaginationParams(detail_item.count,500)
         task_params.shift()
         detail_task.push(detail_item)
-        // for (let index = 0; index < detail_task.length; index++) {
-        //     const element = detail_task[index];
-        //     const pull_task_item = get_pull_data_task();
-        //     pull_task_item.runTask(
-        //         finish_material_list,
-        //         cur_timeRange,
-        //         element.page,
-        //         element.limit
-        //     )
-        // }
         await process_novel_material_list()     
         console.log("processTask over!")
-        // response = await pullDataService.get_detail(materialId_list)
-        // if(!response.success){
-        //     console.log("get_detail:",response)
-        //     throw {msg:response,timeRange:cur_timeRange,fun:"get_detail"}
-        // }
-
-        // if(cur_timeRange!=null){
-        //     cur_timeRange.finish_count+=response.data.list.length
-        //     const today = helper.getLocalDate();
-        //     cur_day_data.get(today)[cur_timeRange.start].finish_count = cur_timeRange.finish_count
-        //     await manager.updateRecord(today,cur_day_data.get(today));
-        // }
-        // for (let index = 0; index < response.data.list.length; index++) {
-        //     const element = response.data.list[index];
-        //     const info = materialId_data_list[element.materialId]
-        //     if(element.hasAnchorInfo){
-        //         await origin_data_controllers.createOriginData(
-        //             {
-        //                 video_id:element.awemeId,
-        //                 materialId:element.materialId,
-        //                 video_link:element.awemeUrl,
-        //                 title:CMD.subTitle(element.title),
-        //                 publish_time:new Date(element.publishTime),
-        //                 kepp_num:info.kepp_num,
-        //                 comment_num:info.comment_num,
-        //                 like_num:info.like_num,
-        //                 shared_num:info.shared_num,
-        //                 is_guajian:1,
-        //                 guajian_link:element.landingUrl,
-        //                 status:0
-        //             }
-        //         )
-        //     }
-        
-        // }
 
     }catch(e){
         console.error("PULL_DATA: error:",e)
     }finally{
-        // if(cur_page!=-1){
-        //     cur_page++;
-        //     global.setTimeout(processTask,time_count)
-        // }
     }
 
 }
@@ -623,4 +576,7 @@ CMD.startScheduler = function(taskCallback) {
 
     console.log(`调度器已启动，共设置 ${jobs.length} 个定时任务`);
 }
-CMD.init()
+
+if(!config.isDebug){
+    CMD.init()
+}

etc/config.json

@@ -28,6 +28,24 @@
         "distributorId": 1814786227164169,
         "secretKey": "CN6KQ8Bauo8JXg5fFPk86EHdRFIUVnyV"
     },
+    "dianzhong_config": {
+        "clientId": 10003204,
+        "token":"Mm1gpsDzGAgh6dNHqe",
+        "create_link_host": "https://video.wqxsw.com/api/channelapi/referralsave",
+        "callbacklist_hots": "https://video.wqxsw.com/api/channelapi/callbacklist",
+        "batchlist_hots": "https://video.wqxsw.com/api/channelapi/batchlist",
+        "type":"dy"
+    },
+    "qimao_config":{
+        "admin_account_name":"zhuoyue",
+        "access_key":"09ba094d2f70e0e5bc340cca365fabe3",
+        "secret_key":"36bb8183bf00a78dd55422156ee5b2dc",
+        "Appid":"tt79e30f5ee6d455b601",
+        "create_link_host":"https://new-media-mapi.qimao.com/mapi/v1/promotion-link/list", 
+        "login_host":"https://new-media-fx.qimao.com/api/account/login?env=&qm_csrf_backend=undefined&t=",
+        "callbacklist_hots":"https://new-media-fx.qimao.com/api/postback/rule/list?page=1&page_size=50&env=&t=",
+        "recharge_list_host":"https://new-media-fx.qimao.com/api/charge-configure/recharge-panel/list?panel_name=&category=0&page=1&page_size=50&env=&t="
+    },
     "python_config": {
         "host": "http://127.0.0.1:8080"
     },
@@ -75,13 +93,14 @@
     },
     "pull_data_config":{
         "debug_host":"https://t-playletweb.tarsocial.com/",
-        "release_host":"https://t-playletweb.tarsocial.com/",
+        "release_host":"https://dongxiaoju.com/",
         "get_token":"/api/login/account",
         "verCode":"7061",
         "loginType":"OPENAPI",
         "get_detail":"/api/v4/data/novel/detail",
         "get_novel_material_list":"/api/v4/data/novel/material?",
         "userName":"15975037061",
-        "password":"123456"
+        "password":"123456",
+        "release_password":"dca81111b5cb78e8e13bf4c8ef921bb6"
     }
 }

logs/combined.log

@@ -1,4 +1,5 @@
 <<<<<<< HEAD
+<<<<<<< HEAD
 2024-12-09T17:47:32: 
 2024-12-09T17:47:32: > heiyan@1.0.0 start
 2024-12-09T17:47:32: > node tg_factory_main.js
@@ -1057,3 +1058,5 @@
 2024-12-16T14:19:34: 
 2024-12-16T14:19:37: Connected to Redis
 2024-12-16T14:19:37: results: false
+=======
+>>>>>>> b1fd2d9bfb560de68ca12093b6d626a70b5944eb

logs/out.log

@@ -1,6 +1,9 @@
+<<<<<<< HEAD
 2024-12-16T14:19:34: 
 2024-12-16T14:19:34: > heiyan@1.0.0 start
 2024-12-16T14:19:34: > node tg_factory_main.js
 2024-12-16T14:19:34: 
 2024-12-16T14:19:37: Connected to Redis
 2024-12-16T14:19:37: results: false
+=======
+>>>>>>> b1fd2d9bfb560de68ca12093b6d626a70b5944eb

run_redis.sh

@@ -0,0 +1 @@
+/usr/local/redis/bin/redis-server /usr/local/redis/etc/redis.conf

src/PullDataService.js

@@ -22,7 +22,7 @@ class PullDataService {
                 const response = await this.session.post(config.pull_data_config.get_token,{
                     userName:config.pull_data_config.userName,
                     verCode:config.pull_data_config.verCode,
-                    password:config.pull_data_config.password,
+                    password:config.pull_data_config.release_password,
                     loginType:config.pull_data_config.loginType
                 });
 
@@ -50,7 +50,11 @@ class PullDataService {
                 var now = new Date(); // 当前时间
 
                 if(cur_timeRange!=null){
-                    now = helper.getTimeStampByHourMinute(cur_timeRange.start)
+                    if(cur_timeRange.start_time==null||cur_timeRange.start_time==""||cur_timeRange.start_time==undefined){
+                        now = helper.getTimeStampByHourMinute(cur_timeRange.start)
+                    }else{
+                        now = helper.getTimeStampByHourMinute(cur_timeRange.start_time)
+                    }
                 }
                 let interval_minute = 60;
             

src/api/dz/create_dianzhong_book_link.js

@@ -0,0 +1,120 @@
+const axios = require('axios');
+const dns = require('dns').promises;
+const qs = require('querystring');
+const CMD = {}
+async function addReferral(bookId, chapterId, adminId,bookName) {
+    try {
+        // 1. DNS解析
+        const ip = await dns.resolve4('admin.wqxsw.com')
+            .then(addresses => addresses[0])
+            .catch(() => '47.101.128.171');
+
+        // 2. 构建请求体
+        const requestBody = {
+            'row[admin_id]': adminId,
+            'row[book_id]': bookId,
+            'row[chapter_id]': chapterId,
+            'row[chapter_name]': '第1章',
+            'row[name]': bookName,
+            'row[create_num]': 1,
+            'row[media_source]': 'dy',  //抖音
+            'extend[guide_chapter]': '',
+            'extend[charge_switch]': 0,
+            'extend[chapter_charge_start]': '',
+            'extend[consume_type]': 1,
+            'extend[chapter_kandian]': '',
+            'extend[words_price]': '',
+            'row[token]': '',
+            'extend[xt_benefit]': '',
+            'extend[jx_benefit]': '',
+            'extend[vivo_ad_id]': '',
+            'extend[vivo_ad_source]': '',
+            'extend[vivo_access_token]': '',
+            'extend[oppo_ad_id]': '',
+            'extend[oppo_api_id]': '',
+            'extend[oppo_api_key]': '',
+            'extend[youkuAppKey]': '',
+            'extend[youkuToken]': '',
+            'extend[huaweiSecretKey]': '',
+            'extend[wifiClientId]': '',
+            'extend[wifiSecretKey]': '',
+            'extend[appKey360]': '',
+            'extend[secret360]': '',
+            'extend[jzqs]': '',
+            'extend[sph_id]': '',
+            'extend[sp_id]': '',
+            'row[callbacktype]': 1,
+            'row[callback_config_id]': 368330,  //回传id
+            'row[recharge-template-type]': 1,
+            'row[referral_goods_batch_id]': 18438416   //充值模板id
+        };
+
+        // 3. 构建请求配置
+        const config = {
+            baseURL: `https://${ip}`,
+            url: '/admin/referral/referral/add',
+            method: 'post',
+            headers: {
+                'Host': 'admin.wqxsw.com',
+                'accept': 'application/json, text/javascript, */*; q=0.01',
+                'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
+                'content-type': 'application/x-www-form-urlencoded; charset=UTF-8',
+                'x-requested-with': 'XMLHttpRequest',
+                'cookie': 'PHPSESSID=gaucu8us1dmvsjstqfgtp3676a; keeplogin=61920%7C604800%7C1734659746%7C2e8827290dda8e35651c20483ee07396',
+                'Referer': `https://admin.wqxsw.com/admin/referral/referral/add?book_id=${bookId}&chapter_id=${chapterId}&dialog=1`
+            },
+            params: {
+                book_id: bookId,
+                chapter_id: chapterId,
+                dialog: 1
+            },
+            data: qs.stringify(requestBody),
+            httpsAgent: new (require('https').Agent)({
+                rejectUnauthorized: false,
+                servername: 'admin.wqxsw.com'
+            }),
+            validateStatus: function (status) {
+                return status >= 200 && status < 500;
+            }
+        };
+
+        // 4. 发送请求
+        const response = await axios(config);
+
+        // 5. 处理响应
+        if (response.status === 200) {
+            return response.data;
+        } else {
+            throw new Error(`请求失败，状态码: ${response.status}`);
+        }
+
+    } catch (error) {
+        console.error('添加推荐失败:', {
+            message: error.message,
+            code: error.code,
+            response: error.response?.data
+        });
+        throw error;
+    }
+}
+
+// 使用示例
+async function main() {
+    try {
+        const bookId = '11010287703';
+        const chapterId = '1';
+        const adminId = '61920'; //channelId
+        
+        const result = await addReferral(bookId, chapterId, adminId);
+        console.log('添加推荐成功:', result);
+    } catch (error) {
+        console.error('操作失败:', error.message);
+    }
+}
+
+// 如果直接运行此文件
+if (require.main === module) {
+    main();
+}
+
+module.exports = CMD;

src/api/dz/dz_login.js

@@ -0,0 +1,173 @@
+const axios = require('axios');
+const qs = require('querystring');
+const dns = require('dns').promises;
+const net = require('net');
+
+
+class AdminSession {
+    constructor(options = {}) {
+        this.baseURL = 'https://admin.wqxsw.com';
+        this.dnsServers = options.dnsServers || ['8.8.8.8', '8.8.4.4', '223.5.5.5', '223.6.6.6'];
+        this.maxRetries = options.maxRetries || 3;
+        this.currentRetry = 0;
+
+        this.axiosInstance = axios.create({
+            baseURL: this.baseURL,
+            timeout: options.timeout || 15000,
+            headers: {
+                'accept': 'application/json, text/javascript, */*; q=0.01',
+                'content-type': 'application/x-www-form-urlencoded; charset=UTF-8',
+                'x-requested-with': 'XMLHttpRequest'
+            }
+        });
+    }
+
+    async checkDNS() {
+        console.log('开始DNS诊断...');
+        
+        for (const server of this.dnsServers) {
+            try {
+                // 临时设置DNS服务器
+                dns.setServers([server]);
+                console.log(`尝试使用DNS服务器 ${server}...`);
+                
+                const result = await dns.resolve4('admin.wqxsw.com');
+                console.log(`使用DNS ${server} 解析成功:`, result);
+                return result[0]; // 返回第一个IP地址
+            } catch (error) {
+                console.log(`DNS ${server} 解析失败:`, error.message);
+            }
+        }
+        throw new Error('所有DNS服务器解析失败');
+    }
+
+    async tryDirectIP() {
+        // 已知的备用IP地址列表
+        const knownIPs = [
+            '47.94.253.153',   // 示例IP，需要替换为实际的IP
+            '47.94.253.154'    // 备用IP
+        ];
+
+        for (const ip of knownIPs) {
+            try {
+                console.log(`尝试直接使用IP: ${ip}`);
+                const response = await axios.get(`http://${ip}`, {
+                    headers: {
+                        'Host': 'admin.wqxsw.com'
+                    },
+                    timeout: 5000
+                });
+                if (response.status === 200) {
+                    console.log(`IP ${ip} 连接成功`);
+                    return ip;
+                }
+            } catch (error) {
+                console.log(`IP ${ip} 连接失败:`, error.message);
+            }
+        }
+        return null;
+    }
+
+    async login(username = 'zydx16', password = 'Zy862520') {
+        try {
+            // 先进行DNS检查
+            let targetHost = this.baseURL;
+            try {
+                const ip = await this.checkDNS();
+                console.log('DNS解析成功，使用解析后的IP:', ip);
+                targetHost = `https://${ip}`;
+            } catch (error) {
+                console.log('DNS解析失败，尝试使用直连IP...');
+                const directIP = await this.tryDirectIP();
+                if (directIP) {
+                    targetHost = `https://${directIP}`;
+                }
+            }
+
+            // 更新axios实例的baseURL
+            this.axiosInstance.defaults.baseURL = targetHost;
+
+            // 添加重要的请求头
+            const headers = {
+                'Host': 'admin.wqxsw.com',
+                'Referer': `${this.baseURL}/admin/index/login?url=%2Fadmin%2Fnotice%2Findex%3Fref%3Daddtabs`,
+                'Cookie': 'PHPSESSID=vi938g4mfaqjeelunmjmfa68tn'
+            };
+
+            // 发送登录请求
+            const response = await this.axiosInstance.post(
+                '/admin/index/login',
+                qs.stringify({
+                    __token__: 'ef1d4c4197af8484b14c26108ba41d1c',
+                    username,
+                    password,
+                    keeplogin: 1
+                }),
+                {
+                    headers,
+                    params: {
+                        url: '/admin/notice/index?ref=addtabs'
+                    }
+                }
+            );
+
+            return response.data;
+        } catch (error) {
+            if (this.currentRetry < this.maxRetries) {
+                this.currentRetry++;
+                console.log(`登录失败，第 ${this.currentRetry} 次重试...`);
+                await new Promise(resolve => setTimeout(resolve, 2000));
+                return this.login(username, password);
+            }
+
+            const errorInfo = {
+                message: error.message,
+                code: error.code,
+                config: error.config,
+                timestamp: new Date().toISOString()
+            };
+
+            if (error.response) {
+                errorInfo.status = error.response.status;
+                errorInfo.data = error.response.data;
+            }
+
+            console.error('登录失败:', errorInfo);
+            throw error;
+        }
+    }
+}
+
+// 使用示例
+async function main() {
+    const session = new AdminSession({
+        maxRetries: 3,
+        timeout: 15000
+    });
+
+    try {
+        console.log('开始登录...');
+        const result = await session.login();
+        console.log('登录结果:', result);
+    } catch (error) {
+        console.error('登录失败:', error.message);
+        
+        // 提供解决建议
+        console.log('\n可能的解决方案:');
+        console.log('1. 检查网络连接是否正常');
+        console.log('2. 检查本地hosts文件');
+        console.log('3. 尝试清除DNS缓存:');
+        console.log('   Windows: ipconfig /flushdns');
+        console.log('   Linux: sudo systemctl restart systemd-resolved');
+        console.log('   Mac: sudo killall -HUP mDNSResponder');
+        console.log('4. 尝试使用其他DNS服务器');
+        console.log('5. 检查服务器是否可访问');
+    }
+}
+
+// 运行测试
+
+function login(){
+    main().catch(console.error);
+}
+module.exports = {login};

src/api/dz/dz_search_book.js

@@ -0,0 +1,71 @@
+const axios = require('axios');
+const dns = require('dns').promises;
+const CMD = {}
+async function fetchBookData(bookId) {
+    try {
+        // 1. 首先进行DNS解析
+        const ip = await dns.resolve4('admin.wqxsw.com')
+            .then(addresses => addresses[0])
+            .catch(() => '47.101.128.171'); // 如果DNS解析失败，使用备用IP
+
+        // 2. 构建URL，使用解析到的IP
+        const baseURL = `https://${ip}`;
+        const path = '/admin/bookshort/book/channelindex';
+        
+        // 3. 构建查询参数
+        const params = new URLSearchParams({
+            sort: 'id',
+            order: 'desc',
+            offset: '0',
+            limit: '1',
+            filter: JSON.stringify({
+                type_two: null,
+                type_three: null,
+                id: bookId
+            }),
+            op: JSON.stringify({
+                type_two: "=",
+                type_three: "=",
+                id: "="
+            }),
+            _: Date.now()
+        });
+
+        // 4. 设置请求配置
+        const config = {
+            baseURL,
+            headers: {
+                "Host": "admin.wqxsw.com",
+                "accept": "application/json, text/javascript, */*; q=0.01",
+                "accept-language": "zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6",
+                "content-type": "application/json",
+                "x-requested-with": "XMLHttpRequest",
+                "cookie": "PHPSESSID=gaucu8us1dmvsjstqfgtp3676a; keeplogin=61920%7C604800%7C1734659746%7C2e8827290dda8e35651c20483ee07396",
+                "Referer": "https://admin.wqxsw.com/admin/bookshort/book/channelindex?addtabs=1"
+            },
+            // 5. 禁用证书验证（仅开发环境使用）
+            httpsAgent: new (require('https').Agent)({
+                rejectUnauthorized: false,
+                servername: 'admin.wqxsw.com'
+            })
+        };
+
+        // 6. 执行请求
+        const response = await axios.get(`${path}?${params.toString()}`, config);
+        return response.data;
+
+    } catch (error) {
+        console.error('请求失败:', {
+            message: error.message,
+            code: error.code,
+            response: error.response?.data
+        });
+        throw error;
+    }
+}
+
+
+CMD.search_id = async function(bookId){
+    return await fetchBookData(bookId);
+}
+module.exports = CMD;

src/api/dz/get_dz_call_back_template.js

@@ -0,0 +1,20 @@
+const CMD = {}
+const HttpClient = require('../../../src/HttpClient')
+const config = require('../../../etc/config.json')
+const helper = require('../../helper')
+
+// 获取点众回传模板
+CMD.get_callback_template = async function(channelId,call_back){
+    let clinet = new HttpClient()
+    let timestamp = helper.getCurrentUnixTimestamp()
+    let signKey = helper.md5(config.dianzhong_config.clientId+config.dianzhong_config.token+timestamp)
+    let response = await clinet.post(config.dianzhong_config.callbacklist_hots,{
+        channelId:channelId,
+        clientId:config.dianzhong_config.clientId,
+        timestamp:timestamp,
+        type:config.dianzhong_config.type,
+        signKey:signKey
+    })
+    call_back(response)
+}
+module.exports = CMD;

src/api/dz/get_dz_recharge_template.js

@@ -0,0 +1,19 @@
+const CMD = {}
+const HttpClient = require('../../../src/HttpClient')
+const config = require('../../../etc/config.json')
+const helper = require('../../helper')
+
+// 获取点众充值模板
+CMD.get_recharge_template = async function(channelId,call_back){
+    let clinet = new HttpClient()
+    let timestamp = helper.getCurrentUnixTimestamp()
+    let signKey = helper.md5(config.dianzhong_config.clientId+config.dianzhong_config.token+timestamp)
+    let response = await clinet.post(config.dianzhong_config.batchlist_hots,{
+        channelId:channelId,
+        clientId:config.dianzhong_config.clientId,
+        timestamp:timestamp,
+        signKey:signKey
+    })
+    call_back(response)
+}
+module.exports = CMD;

src/api/qm/get_qm_call_back_template.js

@@ -0,0 +1,47 @@
+const fetch = require('node-fetch'); // Node.js 18以下版本需要安装 node-fetch
+const CMD = {}
+CMD.get_callback_template = async function () {
+    const url = 'https://new-media-fx.qimao.com/api/postback/rule/list';
+    
+    // 请求参数
+    const params = new URLSearchParams({
+        page: '1',
+        page_size: '50',
+        env: '',
+        t: Date.now()  // 当前时间戳
+    });
+
+    // 请求头
+    const headers = {
+        'accept': 'application/json, text/plain, */*',
+        'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
+        'app-external-id': '4c6e8d8709c14de9a4397b6cbb978f85',
+        'authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJBY2NvdW50SUQiOjU0NDA1NjQxNjM3MTI4MjExMSwiQWNjb3VudE5hbWUiOiJ6aHVveXVlIiwiVGltZVN0YW1wIjoxNzM0MDg4MjI1LCJDbGllbnRJUCI6IjIxOS43Ny4yMzYuMTgwIiwiQnVmZmVyVGltZSI6MCwiZXhwIjoxNzM0MTc0NjI1LCJpc3MiOiJxbV9uZXdfbWVkaWFfZngiLCJuYmYiOjE3MzQwODgyMjUsIkVudiI6InJlbGVhc2UiLCJJc1NpbXVsYXRpb25Mb2dpbiI6ZmFsc2V9.LaEHd147NoCt1Wfo9ZZlCs4pludA7D3LajN4xff2H5o',
+        'project': 'reader_paid_dyminiapp',
+        'signature': 'b4782a395b0d0de3f78bb5c8157cb35ab0d6c51f3677a1cfb4b5390c39f63169',
+        'target-id': '544180064332673816',
+        'cookie': 'sensorsdata2015jssdkcross=%7B%22%24device_id%22%3A%22193bdc124645e2-0cbeaee172d4ce8-4c657b58-921600-193bdc12465567%22%7D; sajssdk_2015_new_user_new-media-fx_qimao_com=1; acw_tc=1a0c380f17341043811111513e003f4b4a7b61bafaac1abb4e5d21e565003f; sa_jssdk_2015_new-media-fx_qimao_com=%7B%22distinct_id%22%3A%22193bdc124645e2-0cbeaee172d4ce8-4c657b58-921600-193bdc12465567%22%2C%22first_id%22%3A%22%22%2C%22props%22%3A%7B%22%24latest_traffic_source_type%22%3A%22%E7%9B%B4%E6%8E%A5%E6%B5%81%E9%87%8F%22%2C%22%24latest_search_keyword%22%3A%22%E6%9C%AA%E5%8F%96%E5%88%B0%E5%80%BC_%E7%9B%B4%E6%8E%A5%E6%89%93%E5%BC%80%22%2C%22%24latest_referrer%22%3A%22%22%7D%2C%22identities%22%3A%22eyIkaWRlbnRpdHlfY29va2llX2lkIjoiMTkzYmRjMTI0NjQ1ZTItMGNiZWFlZTE3MmQ0Y2U4LTRjNjU3YjU4LTkyMTYwMC0xOTNiZGMxMjQ2NTU2NyJ9%22%2C%22history_login_id%22%3A%7B%22name%22%3A%22%22%2C%22value%22%3A%22%22%7D%7D',
+        'Referer': 'https://new-media-fx.qimao.com/backend/postback-configuration/index?projectId=reader_paid_dyminiapp&appId=4c6e8d8709c14de9a4397b6cbb978f85&accountId=544180064332673816'
+    };
+
+    try {
+        const response = await fetch(`${url}?${params}`, {
+            method: 'GET',
+            headers: headers
+        });
+
+        const data = await response.json();
+        console.log('响应状态:', response.status);
+        console.log('响应数据:', data);
+        return data.data;
+    } catch (error) {
+        console.error('请求错误:', error);
+        throw error;
+    }
+}
+
+// Node.js 18及以上版本可以直接运行
+// Node.js 18以下版本需要先安装 node-fetch:
+// npm install node-fetch@2
+
+module.exports = CMD;

src/api/qm/get_qm_recharge_template.js

@@ -0,0 +1,50 @@
+
+const fetch = require('node-fetch'); // Node.js 18以下版本需要安装 node-fetch
+const CMD = {}
+CMD.get_recharge_template = async function () {
+    const url = 'https://new-media-fx.qimao.com/api/charge-configure/recharge-panel/list';
+    
+    // 请求参数
+    const params = new URLSearchParams({
+        page: '1',
+        page_size: '50',
+        env: '',
+        panel_name:'',
+        category:'',
+        t: Date.now()  // 当前时间戳
+    });
+
+    // 请求头
+    const headers = {
+        'accept': 'application/json, text/plain, */*',
+        'accept-language': 'zh-CN,zh;q=0.9,en;q=0.8,en-GB;q=0.7,en-US;q=0.6',
+        'app-external-id': '4c6e8d8709c14de9a4397b6cbb978f85',
+        'authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJBY2NvdW50SUQiOjU0NDA1NjQxNjM3MTI4MjExMSwiQWNjb3VudE5hbWUiOiJ6aHVveXVlIiwiVGltZVN0YW1wIjoxNzM0MDg4MjI1LCJDbGllbnRJUCI6IjIxOS43Ny4yMzYuMTgwIiwiQnVmZmVyVGltZSI6MCwiZXhwIjoxNzM0MTc0NjI1LCJpc3MiOiJxbV9uZXdfbWVkaWFfZngiLCJuYmYiOjE3MzQwODgyMjUsIkVudiI6InJlbGVhc2UiLCJJc1NpbXVsYXRpb25Mb2dpbiI6ZmFsc2V9.LaEHd147NoCt1Wfo9ZZlCs4pludA7D3LajN4xff2H5o',
+        'project': 'reader_paid_dyminiapp',
+        'signature': 'b4782a395b0d0de3f78bb5c8157cb35ab0d6c51f3677a1cfb4b5390c39f63169',
+        'target-id': '544180064332673816',
+        'cookie': 'sensorsdata2015jssdkcross=%7B%22%24device_id%22%3A%22193bdc124645e2-0cbeaee172d4ce8-4c657b58-921600-193bdc12465567%22%7D; sajssdk_2015_new_user_new-media-fx_qimao_com=1; acw_tc=1a0c380f17341043811111513e003f4b4a7b61bafaac1abb4e5d21e565003f; sa_jssdk_2015_new-media-fx_qimao_com=%7B%22distinct_id%22%3A%22193bdc124645e2-0cbeaee172d4ce8-4c657b58-921600-193bdc12465567%22%2C%22first_id%22%3A%22%22%2C%22props%22%3A%7B%22%24latest_traffic_source_type%22%3A%22%E7%9B%B4%E6%8E%A5%E6%B5%81%E9%87%8F%22%2C%22%24latest_search_keyword%22%3A%22%E6%9C%AA%E5%8F%96%E5%88%B0%E5%80%BC_%E7%9B%B4%E6%8E%A5%E6%89%93%E5%BC%80%22%2C%22%24latest_referrer%22%3A%22%22%7D%2C%22identities%22%3A%22eyIkaWRlbnRpdHlfY29va2llX2lkIjoiMTkzYmRjMTI0NjQ1ZTItMGNiZWFlZTE3MmQ0Y2U4LTRjNjU3YjU4LTkyMTYwMC0xOTNiZGMxMjQ2NTU2NyJ9%22%2C%22history_login_id%22%3A%7B%22name%22%3A%22%22%2C%22value%22%3A%22%22%7D%7D',
+        'Referer': 'https://new-media-fx.qimao.com/backend/postback-configuration/index?projectId=reader_paid_dyminiapp&appId=4c6e8d8709c14de9a4397b6cbb978f85&accountId=544180064332673816'
+    };
+
+    try {
+        const response = await fetch(`${url}?${params}`, {
+            method: 'GET',
+            headers: headers
+        });
+
+        const data = await response.json();
+        console.log('响应状态:', response.status);
+        console.log('响应数据:', data);
+        return data.data;
+    } catch (error) {
+        console.error('请求错误:', error);
+        throw error;
+    }
+}
+
+// Node.js 18及以上版本可以直接运行
+// Node.js 18以下版本需要先安装 node-fetch:
+// npm install node-fetch@2
+
+module.exports = CMD;

src/api/qm/qm_login.js

@@ -0,0 +1,24 @@
+const CMD = {}
+const HttpClient = require('../../../src/HttpClient')
+const config = require('../../../etc/config.json')
+const helper = require('../../helper')
+const dns = require('dns').promises;
+
+// 获取七猫充值模板
+CMD.login = async function(call_back){
+    let clinet = new HttpClient()
+    let timestamp = helper.getCurrentUnixTimestamp()
+    let response = await clinet.post(config.qimao_config.login_host+timestamp,{
+        account_name:"zhuoyue",
+        password:helper.base64("Zywz013"),
+        env:""
+    },{
+        headers:{
+            "signature": "751f80d87578c9392dcfe122b5ecdaccd9bf8bb26ef113b52955211bf6177181",
+            "target-id": "",
+            "cookie": "sensorsdata2015jssdkcross=%7B%22%24device_id%22%3A%22193bdc124645e2-0cbeaee172d4ce8-4c657b58-921600-193bdc12465567%22%7D; sajssdk_2015_new_user_new-media-fx_qimao_com=1; sa_jssdk_2015_new-media-fx_qimao_com=%7B%22distinct_id%22%3A%22193bdc124645e2-0cbeaee172d4ce8-4c657b58-921600-193bdc12465567%22%2C%22first_id%22%3A%22%22%2C%22props%22%3A%7B%22%24latest_traffic_source_type%22%3A%22%E5%BC%95%E8%8D%90%E6%B5%81%E9%87%8F%22%2C%22%24latest_search_keyword%22%3A%22%E6%9C%AA%E5%8F%96%E5%88%B0%E5%80%BC%22%2C%22%24latest_referrer%22%3A%22http%3A%2F%2F120.79.128.142%3A4999%2F%22%7D%2C%22identities%22%3A%22eyIkaWRlbnRpdHlfY29va2llX2lkIjoiMTkzYmRjMTI0NjQ1ZTItMGNiZWFlZTE3MmQ0Y2U4LTRjNjU3YjU4LTkyMTYwMC0xOTNiZGMxMjQ2NTU2NyJ9%22%2C%22history_login_id%22%3A%7B%22name%22%3A%22%22%2C%22value%22%3A%22%22%7D%7D; acw_tc=0aef82e517340850388764112e00e2e8ca36345c8df892669007f49604d897",
+        }
+    })
+    call_back(response)
+}
+module.exports = CMD;

src/helper.js

@@ -1,5 +1,52 @@
 const helper = {}
 const crypto = require('crypto');
+const dns = require('dns');
+
+helper.base64 = function(str){
+    return Buffer.from(str).toString('base64')
+}
+helper.resolveDomain = async function(domain) {
+  // 创建新的DNS解析器实例
+  const resolver = new dns.promises.Resolver();
+    
+  // 尝试不同的DNS服务器
+  const dnsServers = [
+      '8.8.8.8',      // Google DNS
+      '8.8.4.4',      // Google DNS备用
+      '1.1.1.1',      // Cloudflare DNS
+      '1.0.0.1',      // Cloudflare DNS备用
+      '223.5.5.5',    // 阿里DNS
+      '223.6.6.6',    // 阿里DNS备用
+      '119.29.29.29', // 腾讯DNS
+      '114.114.114.114' // 114 DNS
+  ];
+
+  for (const dnsServer of dnsServers) {
+      try {
+          console.log(`\nTrying DNS server: ${dnsServer}`);
+          resolver.setServers([dnsServer]);
+          
+          const addresses = await resolver.resolve4(domain);
+          console.log(`Success with DNS server ${dnsServer}:`);
+          console.log('IP Addresses:', addresses);
+          
+          // 如果成功找到IP，尝试ping或TCP连接测试
+          for (const ip of addresses) {
+              console.log(`Testing connectivity to IP: ${ip}`);
+              // 这里可以添加连接测试代码
+          }
+          
+          return addresses;
+      } catch (error) {
+          console.error(`Failed with DNS server ${dnsServer}:`, error.message);
+      }
+  }
+  
+  throw new Error('Failed to resolve domain with all DNS servers');
+}
+helper.md5 = function(text) {
+    return crypto.createHash('md5').update(text).digest('hex');
+}
 helper.getSign = function(distributorId,secretKey) {
     const params = [distributorId, secretKey, helper.getCurrentUnixTimestamp()];
     // 将参数数组中的每个元素转换为字符串并连接成一个单一的字符串