fdfe

application/api/controller/Ai.php

                             //写入日志
                             $log_content .= '指令id-' . $doc_id . '-' . json_encode($line, JSON_UNESCAPED_UNICODE) . '<br/>';
                             $s_num++;
+
+                            //通知前端
+                            $is_use_desc = $is_use === 1?'合法':'不匹配';
+                            $msg = [
+                                'info' => '['.$line[0].']成功新增记录!匹配结果:'.$is_use_desc
+                            ];
+                            $this->curlPost($msg);
                         } else {
                             //写日志
                             $log_content_error .= '<p>短标题-' . $line[0] . '-已存在-指令短标题id:' . $one['id'] . '</p>';
                             $f_num++;
+
+                            //通知前端
+                            $msg = [
+                                'info' => '相同规则与相同主词下,['.$line[0].']已存在-不可重复导入!'
+                            ];
+                            $this->curlPost($msg);
                         }
                     }
                 }
             fputcsv($file, $row);
         }
         fclose($file);
+
+        //执行下载
+
+    }
+
+    /*
+     * curl - post 通知
+     */
+    public function curlPost($data){
+        $ch = curl_init();
+        curl_setopt($ch, CURLOPT_URL, "http://workerman.dev.zx2049.com/work/push/test");
+        curl_setopt($ch, CURLOPT_POST, 1);
+        //The number of seconds to wait while trying to connect. Use 0 to wait indefinitely.
+        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 60);
+        curl_setopt($ch, CURLOPT_POSTFIELDS , http_build_query($data));
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
+        $output = curl_exec($ch);
+        curl_close($ch);
+        return $output;
     }
 }