|
|
@@ -9,6 +9,7 @@ class QueueOne extends Start_Controller {
|
|
|
$this->load->_model("Model_logic_crm",'logic_crm');
|
|
|
$this->load->_model("Model_logic_u9action",'logic_u9action') ;
|
|
|
$this->load->_model("Model_logic_u9bh",'logic_u9bh');
|
|
|
+ $this->load->_model("Model_waybilldowns","waybilldowns");
|
|
|
}
|
|
|
private $ip = ['127.0.0.1','47.105.156.18'];
|
|
|
//定义方法的调用规则 获取URI第二段值
|
|
|
@@ -23,9 +24,53 @@ class QueueOne extends Start_Controller {
|
|
|
|
|
|
private function _u9action(){
|
|
|
$this->logic_u9action->waixiao();
|
|
|
- echo "执行了u9外销";
|
|
|
+ var_dump("执行了u9外销");
|
|
|
$this->logic_u9bh->doAction();
|
|
|
- echo "执行了u9备货";
|
|
|
+ var_dump("执行了u9备货");
|
|
|
+ $this->_downloadWaybill();
|
|
|
+ var_dump("执行了下载图片");
|
|
|
+ }
|
|
|
+
|
|
|
+ //定时执行下载图片
|
|
|
+ private function _downloadWaybill(){
|
|
|
+ $list = $this->waybilldowns->find_all("status = 0","*",'id asc',0,250);
|
|
|
+
|
|
|
+ foreach($list as $k => $v){
|
|
|
+ $this->_pdfurl($v['url'], $v['pdf_name'], $v['date_dir']);
|
|
|
+ $this->waybilldowns->save([
|
|
|
+ 'status'=>1,
|
|
|
+ 'do_time'=>time()
|
|
|
+ ],$v['id']);
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
+
|
|
|
+ private function _pdfurl($pdf, $title, $bctime)
|
|
|
+ {
|
|
|
+ $pdf_path = './data/pdf/' . $bctime . '/';
|
|
|
+
|
|
|
+ // 创建目录(如果不存在)
|
|
|
+ if (!is_dir($pdf_path)) {
|
|
|
+ mkdir($pdf_path, 0777, true); // 第三个参数 true 可以递归创建目录
|
|
|
+ }
|
|
|
+
|
|
|
+ // 获取PDF内容
|
|
|
+ $pdf_content = file_get_contents($pdf);
|
|
|
+
|
|
|
+ // 保存文件
|
|
|
+ file_put_contents($pdf_path . $title . '.pdf', $pdf_content);
|
|
|
+ $size = filesize($pdf_path . $title . '.pdf');
|
|
|
+ if($size > 0){
|
|
|
+
|
|
|
+ }else{
|
|
|
+ sleep(1);
|
|
|
+ // 获取PDF内容
|
|
|
+ $pdf_content = file_get_contents($pdf);
|
|
|
+ // 保存文件
|
|
|
+ file_put_contents($pdf_path . $title . '.pdf', $pdf_content);
|
|
|
+ }
|
|
|
+ return $bctime;
|
|
|
+
|
|
|
+
|
|
|
+ }
|
|
|
}
|