diff --git a/api/controllers/dms/Spider.php b/api/controllers/dms/Spider.php index 40f76ad5..7fbcc69a 100644 --- a/api/controllers/dms/Spider.php +++ b/api/controllers/dms/Spider.php @@ -37,7 +37,7 @@ class Spider extends HD_Controller $token = $resArr['token']; $pageIndex = 1; - $pageSize = 30; + $pageSize = 100; $dollor = '$'; $createdDateStart = date("Y-m-d H:i:s", strtotime("-1 minute")); @@ -115,4 +115,79 @@ CURL; return $resArr; } + + public function mytest() + { + //登录态缓存文件 + $loginResultFile = APPPATH . "cache/loginRes.txt"; + $autoLogin = new CurlAutoLogin(); + + //已有登录态,则直接读取登录态,避免多次重复登录 + if (!file_exists($loginResultFile)) { + $resArr = $this->doLogin($autoLogin, $loginResultFile); + } else { + debug_log("有登录态,自动登录...\n", $this->file_name, $this->log_dir); + $resArr = json_decode(file_get_contents($loginResultFile), true); + } + + if (empty($resArr['username'])) { + debug_log("未登录成功...\n", $this->file_name, $this->log_dir); + exit("未登录成功\n"); + } + + $token = $resArr['token']; + $pageIndex = 1; + $pageSize = 100; + $dollor = '$'; + + $createdDateStart = date("Y-m-d 00:00:00", strtotime("today")); + $createdDateEnd = date("Y-m-d H:i:s", strtotime("now")); + + debug_log("开始时间: ".$createdDateStart." ", $this->file_name, $this->log_dir); + debug_log("截止时间: ".$createdDateEnd." ", $this->file_name, $this->log_dir); + + $curl = <<execCurl($curl); + $resArr = json_decode($content, true); + + if (!$resArr['result']) { + $this->doLogin($autoLogin, $loginResultFile); + } + + if(!$resArr['data']['clueServerQueryFromDlr']['rows']){ + debug_log("无新增数据\n", $this->file_name, $this->log_dir); + exit; + }else{ + debug_log("共 ".$resArr['data']['clueServerQueryFromDlr']['records']." 条新增数据\n", $this->file_name, $this->log_dir); + } + + print_r($resArr); +// foreach ($resArr['data']['clueServerQueryFromDlr']['rows'] as $k => $v) { +// $add = array( +// 'c_id' => $v['serverOrder'], +// 'name' => $v['custName'], +// 'mobile' => $v['contactTel'], +// 'cfrom1' => $v['infoChanMName'], +// 'cfrom2' => $v['infoChanDName'], +// 'jsondata' => json_encode($v, JSON_UNESCAPED_UNICODE), +// 'c_time' => strtotime($v['createdDate']) +// ); +// +// $this->dms_clues_model->add($add); +// } + } }