1

@@ -130,9 +130,7 @@ function start(){
 
 
 
 
 
 
-$file = explode('/',__FILE__);
-$file = end($file);
-$ps = "ps -ef | grep \"{$file} start\" | grep -v grep | wc -l";
+$ps = "ps -ef | grep \"send_job.php start\" | grep -v grep | wc -l";
 
 
 switch ($argv[1]??0){
 switch ($argv[1]??0){
     case 'start':{
     case 'start':{

@@ -276,24 +276,32 @@ function sync($email_id,$worker_id){
 
 
 
 
 
 
-switch ($argv[1]){
+$ps = "ps -ef | grep \"sync.php start\" | grep -v grep | wc -l";
+
+switch ($argv[1]??0){
     case 'start':{
     case 'start':{
+        $num = exec($ps);
+        if($num){
+            echo '正则运行，请勿重复运行';
+        }else{
             start();
             start();
+        }
         break;
         break;
     }
     }
     case 'stop':{
     case 'stop':{
-        \Co\run(function (){
         echo "正在退出程序...\n非必要请不要强制kill掉进程\n";
         echo "正在退出程序...\n非必要请不要强制kill掉进程\n";
+
         redis()->set(SYNC_RUNNING_REDIS_KEY,'stop');
         redis()->set(SYNC_RUNNING_REDIS_KEY,'stop');
+
         while (true){
         while (true){
-                $num = exec("ps -ef | grep \"sync.php start\" | grep -v grep | wc -l");
+
+            $num = exec($ps);
             if(!$num){
             if(!$num){
                 break;
                 break;
             }
             }
-                co::sleep(0.5);
+            sleep(1);
         }
         }
         echo "已退出程序\n";
         echo "已退出程序\n";
-        });
         break;
         break;
     }
     }
     default:{
     default:{
@@ -309,4 +317,3 @@ switch ($argv[1]){
 
 
 
 
 
 
-