dms
This commit is contained in:
@@ -13,6 +13,7 @@ class Spider extends HD_Controller
|
||||
parent::__construct();
|
||||
$this->load->model('dms/dms_clues_model','dms_clues_model');
|
||||
$this->log_dir = 'dms';
|
||||
$this->file_name = 'clues.txt';
|
||||
}
|
||||
|
||||
public function get_clues()
|
||||
@@ -25,12 +26,12 @@ class Spider extends HD_Controller
|
||||
if (!file_exists($loginResultFile)) {
|
||||
$resArr = $this->doLogin($autoLogin, $loginResultFile);
|
||||
} else {
|
||||
debug_log("有登录态,自动登录...\n", 'dms.txt', $this->log_dir);
|
||||
debug_log("有登录态,自动登录...\n", $this->file_name, $this->log_dir);
|
||||
$resArr = json_decode(file_get_contents($loginResultFile), true);
|
||||
}
|
||||
|
||||
if (empty($resArr['username'])) {
|
||||
debug_log("未登录成功...\n", 'dms.txt', $this->log_dir);
|
||||
debug_log("未登录成功...\n", $this->file_name, $this->log_dir);
|
||||
exit("未登录成功\n");
|
||||
}
|
||||
|
||||
@@ -42,8 +43,8 @@ class Spider extends HD_Controller
|
||||
$createdDateStart = date("Y-m-d H:i:s", strtotime("-1 minute"));
|
||||
$createdDateEnd = date("Y-m-d H:i:s", strtotime("now"));
|
||||
|
||||
debug_log("开始时间: ".$createdDateStart." ", 'dms.txt', $this->log_dir);
|
||||
debug_log("截止时间: ".$createdDateEnd." ", 'dms.txt', $this->log_dir);
|
||||
debug_log("开始时间: ".$createdDateStart." ", $this->file_name, $this->log_dir);
|
||||
debug_log("截止时间: ".$createdDateEnd." ", $this->file_name, $this->log_dir);
|
||||
|
||||
$curl = <<<CURL
|
||||
curl 'http://dms.dna-nev.com.cn/ly/mp/busicen/csc/graphql.do?v=clueServerQueryFromDlr' \
|
||||
@@ -68,10 +69,10 @@ CURL;
|
||||
}
|
||||
|
||||
if(!$resArr['data']['clueServerQueryFromDlr']['rows']){
|
||||
debug_log("无新增数据\n", 'dms.txt', $this->log_dir);
|
||||
debug_log("无新增数据\n", $this->file_name, $this->log_dir);
|
||||
exit;
|
||||
}else{
|
||||
debug_log("共 ".$resArr['data']['clueServerQueryFromDlr']['records']." 条新增数据\n", 'dms.txt', $this->log_dir);
|
||||
debug_log("共 ".$resArr['data']['clueServerQueryFromDlr']['records']." 条新增数据\n", $this->file_name, $this->log_dir);
|
||||
}
|
||||
|
||||
foreach ($resArr['data']['clueServerQueryFromDlr']['rows'] as $k => $v) {
|
||||
@@ -92,7 +93,7 @@ CURL;
|
||||
private function doLogin($autoLogin, $loginResultFile)
|
||||
{
|
||||
echo "无登录态,模拟登录...\n";
|
||||
debug_log("无登录态,模拟登录...\n", 'dms.txt', $this->log_dir);
|
||||
debug_log("无登录态,模拟登录...\n", $this->file_name, $this->log_dir);
|
||||
$curl = <<<CURL
|
||||
curl 'http://dms.dna-nev.com.cn/mp/login/validlogin.do' \
|
||||
-H 'Accept: application/json, text/plain, */*' \
|
||||
|
||||
@@ -63,7 +63,7 @@ class Plan extends CI_Controller
|
||||
$plan[] = array('url' => base_url(array('plan', 'syt', 'out_time')), 'interval' => 1); //订单过期
|
||||
$plan[] = array('url' => base_url(array('plan', 'syt', 'thApi')), 'interval' => 1); //私域通通知第三方脚本
|
||||
|
||||
$plan[] = array('url' => base_url(array('dms', 'test', 'index')), 'interval' => 1); //dms爬虫
|
||||
$plan[] = array('url' => base_url(array('dms', 'spider', 'get_clues')), 'interval' => 1); //dms爬虫
|
||||
|
||||
$this->plan = $plan;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user