update

@@ -2,6 +2,7 @@
 
 
 namespace App\Console\Commands;
 namespace App\Console\Commands;
 
 
+use App\Repositories\BtRepository;
 use Illuminate\Console\Command;
 use Illuminate\Console\Command;
 use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Log;
 use Illuminate\Support\Facades\Redis;
 use Illuminate\Support\Facades\Redis;
@@ -23,12 +24,17 @@ public function handle()
         try {
         try {
             //拉取代码
             //拉取代码
             $this->pullCode();
             $this->pullCode();
+
+            if ($is_pull > 1) {
+                //重启进程
+                $this->resetProcess();
+            }
         } catch (\Exception $e) {
         } catch (\Exception $e) {
             Log::error('pull_code | error:' . $e->getMessage());
             Log::error('pull_code | error:' . $e->getMessage());
             $this->output($e->getMessage());
             $this->output($e->getMessage());
         }
         }
 
 
-        Redis::set('pull_code', false);
+        Redis::set('pull_code', 0);
         return true;
         return true;
     }
     }
 
 
@@ -52,6 +58,35 @@ public function pullCode()
     }
     }
 
 
     /**
     /**
+     * 重启进程
+     * @author Akun
+     * @date 2025/06/13 16:56
+     */
+    public function resetProcess()
+    {
+        $this->output('重启进程: start.');
+
+        $bt_repository = new BtRepository();
+        $bt = $bt_repository->getBtObject();
+
+        $list = $bt->getProcessList();
+        foreach ($list as $value) {
+            $process_name = $value['program'];
+            $process_num = $value['numprocs'];
+
+            $re_stop = $bt->stopProcess($process_name, $process_num);
+            $re_stop_msg = $re_stop['msg'] ?? '';
+            $this->output($value['ps'] . '-' . $re_stop_msg);
+
+            $re_start = $bt->startProcess($process_name, $process_num);
+            $re_start_msg = $re_start['msg'] ?? '';
+            $this->output($value['ps'] . '-' . $re_start_msg);
+        }
+
+        $this->output('重启进程: end.');
+    }
+
+    /**
      * 输出处理日志
      * 输出处理日志
      * @param $message
      * @param $message
      */
      */

@@ -285,13 +285,18 @@ public function getRandInquiryText(Request $request)
 
 
     /**
     /**
      * 通知拉代码
      * 通知拉代码
+     * @param Request $request
      * @return string
      * @return string
      * @author Akun
      * @author Akun
      * @date 2025/06/13 15:30
      * @date 2025/06/13 15:30
      */
      */
-    public function pullCode()
+    public function pullCode(Request $request)
     {
     {
-        Redis::set('pull_code', true);
+        $is_update_process = $request->get('is_update_process');
+
+        $pull_code = $is_update_process ? 2 : 1;
+
+        Redis::set('pull_code', $pull_code);
 
 
         return $this->success();
         return $this->success();
     }
     }
@@ -497,11 +502,11 @@ public function transmit($request, $type = self::TYPEVISIT, $traffic = self::TRA
             $this->response();
             $this->response();
         }
         }
 
 
-        if($type == self::TYPEINQUIRY){
+        if ($type == self::TYPEINQUIRY) {
             //询盘
             //询盘
             $ip = $data['submit_ip'] ?? $request->getClientIp();
             $ip = $data['submit_ip'] ?? $request->getClientIp();
             $referrer_url = $data['refer'] ?? $request->header('Referer');
             $referrer_url = $data['refer'] ?? $request->header('Referer');
-        }else{
+        } else {
             //访问
             //访问
             $ip = $data['ip'] ?? $request->getClientIp();
             $ip = $data['ip'] ?? $request->getClientIp();
             $referrer_url = $data['referrer_url'] ?? $request->header('Referer');
             $referrer_url = $data['referrer_url'] ?? $request->header('Referer');
@@ -538,9 +543,9 @@ public function transmit($request, $type = self::TYPEVISIT, $traffic = self::TRA
             @file_put_contents(storage_path('logs/fail_req/' . date('Y-m-d') . '.log'), var_export($dataJson, true) . PHP_EOL, FILE_APPEND);
             @file_put_contents(storage_path('logs/fail_req/' . date('Y-m-d') . '.log'), var_export($dataJson, true) . PHP_EOL, FILE_APPEND);
         }
         }
 
 
-        if($type == self::TYPEINQUIRY){
+        if ($type == self::TYPEINQUIRY) {
             $this->response("success", self::SUCCESS, $resp["data"] ?? []);
             $this->response("success", self::SUCCESS, $resp["data"] ?? []);
-        }else{
+        } else {
             $this->responseNew("success", self::SUCCESS, $resp["data"] ?? []);
             $this->responseNew("success", self::SUCCESS, $resp["data"] ?? []);
         }
         }
     }
     }
@@ -729,7 +734,7 @@ public function inquiryOtherInfo(Request $request)
      */
      */
     public function inquiryQd(Request $request)
     public function inquiryQd(Request $request)
     {
     {
-        return $this->transmit($request, self::TYPEINQUIRY,self::TRAFFICONE);
+        return $this->transmit($request, self::TYPEINQUIRY, self::TRAFFICONE);
     }
     }
 
 
     /**
     /**
@@ -764,14 +769,15 @@ public function search(Request $request)
      * 生成robots.txt
      * 生成robots.txt
      * @param Request $request
      * @param Request $request
      */
      */
-    public function updateRobots(Request $request){
+    public function updateRobots(Request $request)
+    {
         $req["domain"] = $request->getHost();
         $req["domain"] = $request->getHost();
         //转发data
         //转发data
         $transmitUrl = env("API_URL");
         $transmitUrl = env("API_URL");
         $resp = $this->httpPost($transmitUrl . "api/get_robots_content/", json_encode($req));
         $resp = $this->httpPost($transmitUrl . "api/get_robots_content/", json_encode($req));
         $robotsContent = $resp["data"]["content"];
         $robotsContent = $resp["data"]["content"];
-        $robotTxtPath = public_path($req["domain"]."/robots.txt");
-        $this->putSitemapFile($robotTxtPath,$robotsContent);
+        $robotTxtPath = public_path($req["domain"] . "/robots.txt");
+        $this->putSitemapFile($robotTxtPath, $robotsContent);
         $this->response("success", self::SUCCESS, $resp["data"] ?? []);
         $this->response("success", self::SUCCESS, $resp["data"] ?? []);
     }
     }