|
@ -45,16 +45,22 @@ let rndtime = "" //毫秒 |
|
|
let httpResult //global buffer
|
|
|
let httpResult //global buffer
|
|
|
|
|
|
|
|
|
var fs = require("fs"); |
|
|
var fs = require("fs"); |
|
|
|
|
|
const HttpsProxyAgent = require("https-proxy-agent") |
|
|
|
|
|
const HttpProxyAgent = require("http-proxy-agent") |
|
|
|
|
|
|
|
|
//使用参数 青龙task不支持参数
|
|
|
//使用参数 青龙task不支持参数
|
|
|
//const args = process.argv.slice(2);
|
|
|
//const args = process.argv.slice(2);
|
|
|
//let filename = (args.length>0?args[0]:undefined)|| "./zq_yilia.json";
|
|
|
//let filename = (args.length>0?args[0]:undefined)|| "./zq_yilia.json";
|
|
|
|
|
|
|
|
|
// .task desi # 指定账号执行 task zqkkzrw.js desi zqjson 1 使用'zqjson'的第一个参数 多个可以写1-3
|
|
|
// .task desi # 指定账号执行 task zqkkzrw.js desi zqjson 1 使用'zqjson'的第一个参数 多个可以写1-3
|
|
|
let filename =`./${process.env.zqjson || "./zq_yilia"}.json`; |
|
|
// debug
|
|
|
console.log(filename); |
|
|
// process.env.zqjson = 'zq_9839'
|
|
|
let kkzname = filename.replace(/.json/, "_kkz.txt"); |
|
|
// let filename = 'e:\\Works\\Git\\github\\autotask\\othenautojob\\zqjson\\zq_9839.json';;//`./${process.env.zqjson || "./zq_yilia"}.json`;
|
|
|
|
|
|
// let kkzname = 'e:\\Works\\Git\\github\\autotask\\othenautojob\\zqjson\\zq_9839_kkz.txt';// filename.replace(/.json/, "_kkz.txt");
|
|
|
|
|
|
|
|
|
|
|
|
let filename = `./${process.env.zqjson || "./zq_yilia"}.json`; |
|
|
|
|
|
let kkzname = filename.replace(/.json/, "_kkz.txt"); |
|
|
|
|
|
console.log(filename); |
|
|
let zqbody |
|
|
let zqbody |
|
|
|
|
|
|
|
|
let startArr = [], lookArr = [], searchArr = [], jsonArr = []; |
|
|
let startArr = [], lookArr = [], searchArr = [], jsonArr = []; |
|
@ -62,6 +68,11 @@ let gainscore = 0, lookscore = 0, searchscore = 0, boxscore = 0; |
|
|
let StartBody = [], LookBody = [], searchBody = []; |
|
|
let StartBody = [], LookBody = [], searchBody = []; |
|
|
|
|
|
|
|
|
let usernmae = "", zqjsons = "", gainbody = "", lookbody = "", zqcookie = "", kkzmodel = ""; |
|
|
let usernmae = "", zqjsons = "", gainbody = "", lookbody = "", zqcookie = "", kkzmodel = ""; |
|
|
|
|
|
let useProxy = undefined; |
|
|
|
|
|
if (process.env.zqjson == "zq_9839") { |
|
|
|
|
|
console.log("使用代理服务"); |
|
|
|
|
|
useProxy = process.env.zqjson; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
///////////////////////////////////////////////////////////////////
|
|
|
///////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
@ -501,9 +512,30 @@ function populateGetUrl (url) { |
|
|
return urlObject; |
|
|
return urlObject; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
function getProxy (url,session) { |
|
|
|
|
|
|
|
|
|
|
|
//"http://lum-customer-hl_7e7d94d3-zone-data_center-ip-158.46.169.208:k5v04d5knlys@zproxy.lum-superproxy.io:22225"
|
|
|
|
|
|
var httpProxy = new HttpProxyAgent( |
|
|
|
|
|
"http://lum-customer-hl_7e7d94d3-zone-data_center-session-"+session+":k5v04d5knlys@zproxy.lum-superproxy.io:22225" |
|
|
|
|
|
// `https://${process.env.PS_PROXY_USERNAME}:${process.env.PS_PROXY_PASSWORD}@${process.env.PS_PROXY_HOST}:${process.env.PS_PROXY_PORT}`
|
|
|
|
|
|
); |
|
|
|
|
|
var httpsProxy = new HttpsProxyAgent( |
|
|
|
|
|
"https://lum-customer-hl_7e7d94d3-zone-data_center-session-"+session+":k5v04d5knlys@zproxy.lum-superproxy.io:22225" |
|
|
|
|
|
// `https://${process.env.PS_PROXY_USERNAME}:${process.env.PS_PROXY_PASSWORD}@${process.env.PS_PROXY_HOST}:${process.env.PS_PROXY_PORT}`
|
|
|
|
|
|
); |
|
|
|
|
|
|
|
|
|
|
|
let agent = { http: httpProxy } |
|
|
|
|
|
if (url.indexOf("https") > -1) { |
|
|
|
|
|
agent.https = httpsProxy; |
|
|
|
|
|
} |
|
|
|
|
|
return agent; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
async function httpPost (url, caller) { |
|
|
async function httpPost (url, caller) { |
|
|
httpResult = null |
|
|
httpResult = null |
|
|
|
|
|
if (useProxy) { |
|
|
|
|
|
url.agent = getProxy(url.url,useProxy); |
|
|
|
|
|
} |
|
|
return new Promise((resolve) => { |
|
|
return new Promise((resolve) => { |
|
|
$.post(url, async (err, resp, data) => { |
|
|
$.post(url, async (err, resp, data) => { |
|
|
try { |
|
|
try { |
|
@ -528,6 +560,9 @@ async function httpPost (url, caller) { |
|
|
|
|
|
|
|
|
async function httpGet (url, caller) { |
|
|
async function httpGet (url, caller) { |
|
|
httpResult = null |
|
|
httpResult = null |
|
|
|
|
|
if (useProxy) { |
|
|
|
|
|
url.agent = getProxy(url.url,useProxy); |
|
|
|
|
|
} |
|
|
return new Promise((resolve) => { |
|
|
return new Promise((resolve) => { |
|
|
$.get(url, async (err, resp, data) => { |
|
|
$.get(url, async (err, resp, data) => { |
|
|
try { |
|
|
try { |
|
|