init

commands/mobile_activity.php

@@ -2,18 +2,23 @@
 use app\common\model\Mobile;
 use Workerman\Worker as WO;
 
-$work=new WO();
-$work->onWorkerStart=function ($conn){
-    while (true){
-        $ids=Mobile::where('activity_time_end','<=',time())
-            ->where('is_activity',1)
-            ->where('type',1)
-            ->column('id');
-        //user_log('mobileActivityExpired',"找到".count($ids).'条记录');
-        foreach ($ids as $id){
-            $mobile=Mobile::find($id);
-            $mobile->makeNotActivity();
-        }
-        sleep(3);
+class MobileActivity {
+    public static function run(){
+        $work=new WO();
+        $work->onWorkerStart=function ($conn){
+            while (true){
+                $ids=Mobile::where('activity_time_end','<=',time())
+                    ->where('is_activity',1)
+                    ->where('type',1)
+                    ->column('id');
+                user_log('mobileActivityExpired',"找到".count($ids).'条记录');
+                foreach ($ids as $id){
+                    $mobile=Mobile::find($id);
+                    $mobile->makeNotActivity();
+                }
+                sleep(3);
+            }
+        };
     }
-};
+}
+MobileActivity::run();

commands/mobile_order_expired.php

@@ -4,20 +4,26 @@ use think\Db;
 use think\Log;
 use Workerman\Worker as WO;
 
-$work=new WO();
-$work->onWorkerStart=function ($conn){
-    while (true){
-        $orders= MobileOrder::expired()->field('id')->select();
-        foreach ($orders as $order){
-            try {
-                Db::startTrans();
-                $order=MobileOrder::where('id',$order['id'])->lock(true)->find();
-                $order->cancel();
-                Db::commit();
-            }catch (\Exception $e){
-                Log::error("关闭订单[$order->id]失败：{$e->getMessage()}");
+class MobileOrderExpired{
+    public static function run()
+    {
+        $work=new WO();
+        $work->onWorkerStart=function ($conn){
+            while (true){
+                $orders= MobileOrder::expired()->field('id')->select();
+                foreach ($orders as $order){
+                    try {
+                        Db::startTrans();
+                        $order=MobileOrder::where('id',$order['id'])->lock(true)->find();
+                        $order->cancel();
+                        Db::commit();
+                    }catch (\Exception $e){
+                        Log::error("关闭订单[$order->id]失败：{$e->getMessage()}");
+                    }
+                }
+                sleep(3);
             }
-        }
-        sleep(3);
+        };
     }
-};
+}
+MobileOrderExpired::run();

work

@@ -12,7 +12,8 @@ App::initCommon();
 WO::$logFile=sprintf('%s/workerman.log',RUNTIME_PATH);
 WO::$pidFile=sprintf('%s/workerman.pid',RUNTIME_PATH);
 
-require __DIR__.'/commands/mobile_activity.php';
-require __DIR__.'/commands/mobile_order_expired.php';
+foreach (glob(__DIR__.'/commands/*.php') as $file){
+    require $file;
+}
 
 WO::runAll();