tg_factory/5_CREATE_LINK_FACTORY/qm_create_link.js

const fetch = require('node-fetch'); // Node.js 18以下版本需要安装 node-fetch
const tools = require('../tools');
const helper = require('../src/helper');
const config = require('../etc/config.json')
const CMD = {}
CMD.runTask = async function (data,main_info,PlatformInfo,call_back) {
    let timestamp = helper.getCurrentUnixTimestamp()
    let tg_link_config = JSON.parse(main_info.tg_link_config)
    let chongzhi_id = tg_link_config['chongzhi_id']
    let huichuan_id = tg_link_config['huichuan_id']
    let f_chongzhi_id = tg_link_config['f_chongzhi_id']
    let chongzhi_list = JSON.parse(PlatformInfo.chongzhi)
    let huichuan_list = JSON.parse(PlatformInfo.huichuan)
    let f_chongzhi_list = JSON.parse(PlatformInfo.f_chongzhi)
    let recharge_template_id = ""
    let f_recharge_template_id = ""
    let call_back_template_id = ""

    for (let index = 0; index < chongzhi_list.length; index++) {
        const cz_obj = chongzhi_list[index];
        if(cz_obj.id==chongzhi_id){
          recharge_template_id = cz_obj.value
          break
        }
    }

    for (let index = 0; index < huichuan_list.length; index++) {
        const hc_obj = huichuan_list[index];
        if(hc_obj.id==huichuan_id){
          call_back_template_id = hc_obj.value
          break
        }
    }

    for (let index = 0; index < f_chongzhi_list.length; index++) {
        const cz_obj = f_chongzhi_list[index];
        if(cz_obj.id==f_chongzhi_id){
            f_recharge_template_id = cz_obj.value
          break
        }
    }
    const url = 'https://new-media-fx.qimao.com/api/promotion/create';

    let postData = {
        media_id: '1', //今日头条
        postback_rule_id: call_back_template_id, //# 回传规则 value
        book_id:data.product_id,
        book_name:data.product_name,
        chapter_num:1,
        first_panel_id:recharge_template_id, //首充模板id
        repeated_panel_id:f_recharge_template_id, //# 复充模板id
        batch_num:1,
        promotion_name:`${data.product_name}_${timestamp}`,
        env: '',
        t: timestamp  // 当前时间戳
    }
    
    console.log("postData:",postData)
    // 请求参数
    const params = new URLSearchParams(postData);

    // 请求头
    var dy_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',
            "Content-Type": "application/json;charset=UTF-8",
        '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'
    };

    var wx_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': '9a2737aabb8f11ef93f90293e6ac97a2',
        'authorization': 'Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJBY2NvdW50SUQiOjU0NDA1NjQxNjM3MTI4MjExMSwiQWNjb3VudE5hbWUiOiJ6aHVveXVlIiwiVGltZVN0YW1wIjoxNzM0MDg4MjI1LCJDbGllbnRJUCI6IjIxOS43Ny4yMzYuMTgwIiwiQnVmZmVyVGltZSI6MCwiZXhwIjoxNzM0MTc0NjI1LCJpc3MiOiJxbV9uZXdfbWVkaWFfZngiLCJuYmYiOjE3MzQwODgyMjUsIkVudiI6InJlbGVhc2UiLCJJc1NpbXVsYXRpb25Mb2dpbiI6ZmFsc2V9.LaEHd147NoCt1Wfo9ZZlCs4pludA7D3LajN4xff2H5o',
        'project': 'reader_paid_wxminiapp',
        "Content-Type": "application/json;charset=UTF-8",
        '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'
    };

    let headers = ""
    if(PlatformInfo.mini_program_platform_id==config.wx){
        headers = wx_headers
    }else if(PlatformInfo.mini_program_platform_id==config.dy){
        headers = dy_headers
    }

    headers['authorization'] = await tools.getQMToken()
    try {
        const response = await fetch(`${url}?${params}`, {
            method: 'Post',
            headers: headers
        });

        const result = await response.json();
        // { code: 200, data: {}, msg: 'ok' }
        if(result.code!=200){
            throw result
        }
        console.log('响应状态:', response.status);
        console.log('响应数据:', result);
        
        let n_data = await require("../src/api/qm/get_qm_promotion").getPromotionList(postData.promotion_name,PlatformInfo.mini_program_platform_id)
        if(n_data==null){
            throw result
        }

        if(n_data.code!=200){
            throw result
        }
        let promotion_id = n_data.promotion_id
        let promotion_info = n_data.data
        let t_params = promotion_info.promotion_url.split('?')
        let start_page = t_params[0]
        let start_param = t_params[1]
        data.start_page = start_page
        data.start_param = start_param
        data.promotion_id = promotion_id
        call_back(data,null)
    } catch (error) {
        call_back(data,error)
        console.error('请求错误:', error);
    }
}

// Node.js 18及以上版本可以直接运行
// Node.js 18以下版本需要先安装 node-fetch:
// npm install node-fetch@2

module.exports = CMD;