app/Console/Commands/ContentManage/ContentTest.php

@@ -6,6 +6,7 @@ use http\Exception\RuntimeException;
 use Illuminate\Console\Command;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Redis;
+use Modules\Audience\Services\UserGroupService;
 use Modules\Common\Errors\Errors;
 use Modules\Common\Exceptions\CommonBusinessException;
 
@@ -30,15 +31,24 @@ class ContentTest extends Command
      */
     public function handle(): void
     {
-       $result = DB::table('promotions')
-           ->where(['puid' => 0])
-           ->get();
-       foreach ($result as $item) {
-           DB::table('promotions')
-               ->where('id', $item->id)
-               ->update([
-                   'puid' => DB::table('users')->where('id', $item->uid)->value('pid')
-               ]);
-       }
+        $tags = [
+            'attention_hour' => '0-6',
+            'in_48_hour' => 1,
+            'interact_hour' => '0-6',
+            'last_watch_day' => '0-2',
+            'register_day' => '0-2',
+            'total_watch_day' => '0-2',
+            'charge_type' => 1,
+            'total_charge_money' => '1-1000',
+            'avg_charge_money' => '2-300',
+            'charge_num' => '1-1',
+            'remain_coin' => '0-1',
+            'last_charge_day' => '0-4',
+            'video_watch' => [1,2,3],
+            'video_charge' => [4,5]
+        ];
+
+        $sql = UserGroupService::getSQL($tags)->distinct()->count('a.uid');
+        dump($sql);
     }
 }

app/Exceptions/Handler.php

@@ -49,7 +49,7 @@ class Handler extends ExceptionHandler
     public function register()
     {
         $this->reportable(function (Throwable $e) {
-            //
+            dingTalkAlertException($e);
         });
     }
 

app/Libs/Helpers.php

@@ -9,6 +9,8 @@ use PhpOffice\PhpSpreadsheet\IOFactory;
 use PhpOffice\PhpSpreadsheet\Spreadsheet;
 use Modules\Common\Support\Trace\CustomizeLogger;
 use PHPMailer\PHPMailer\PHPMailer;
+use Illuminate\Support\Str;
+use Illuminate\Support\Facades\Http;
 
 if(!function_exists("str_decode")){
     /**
@@ -415,3 +417,68 @@ if(!function_exists('getTraceContext')) {
         return app(TraceContext::class);
     }
 }
+
+/**
+ * 钉钉报警
+ *
+ * @param \Throwable $exception
+ * @return void
+ */
+function dingTalkAlertException(\Throwable $exception)
+{
+    $code = $exception->getCode();
+    if($code >0){
+        return ;
+    }
+    $url = 'https://oapi.dingtalk.com/robot/send?access_token=07829435258bf07c5f0b0a0a84c50c4bebc15e585b3040ad43c5e94e213a9bba';
+    $key = 'SEC74f8117d06ae59a7edde24cd9706334dbdd09b5d5734522f060272bdfbfb1abd';
+    $timestamp = time()*1000;
+    $string = $timestamp . "\n" . $key; 
+    $sign = hash_hmac('sha256',$string,$key,true);
+    $sign = urlencode(base64_encode($sign));
+    $url .= '&'.http_build_query(['timestamp'=>$timestamp,'sign'=>$sign]);
+
+    $class_name = get_class($exception);
+    $app_path = base_path();
+    $trace = $exception->getTraceAsString();
+    $trace_list = preg_split('/\n/',$trace);
+    $error = '- '.$exception->getFile().':'.$exception->getLine()."\n";
+    foreach($trace_list as $item){
+        if( !Str::contains($item,'vendor')){
+            $error .= '- '.trim(preg_replace('/^(\#\d+)/','',$item))."\n";
+        }
+    }
+    $hostname = gethostname();
+
+    $ip = '';
+    $ssh = getenv('SSH_CONNECTION');
+    if($ssh){
+        $ssh_list = explode(' ',$ssh);
+        $ip = isset($ssh_list[2]) ? $ssh_list[2]:'';
+    }
+
+
+    $result = [
+        'message'=>$exception->getMessage(),
+        'class_name'=>$class_name,
+        'app_path'=>$app_path,
+        'error'=>$error,
+        'hostname'=>$hostname.' - '.$ip
+    ];
+
+    try{
+        $response = Http::post($url,[
+            'msgtype' => 'markdown',
+            'markdown' => [
+                'title'=>basename (base_path()).'异常',
+                'text' => sprintf("### 错误信息: \n%s\n ### 异常详情: \n%s\n### 项目路径: \n%s\n\n ### 主机名:\n%s\n",
+                $result['class_name'].':'.$result['message'],$result['error'],$result['app_path'],$result['hostname'])
+            ]
+        ]);
+    }catch(\Exception $e){
+
+    }
+    
+}
+
+

app/Providers/AppServiceProvider.php

@@ -2,6 +2,7 @@
 
 namespace App\Providers;
 
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\ServiceProvider;
 
 class AppServiceProvider extends ServiceProvider
@@ -23,6 +24,6 @@ class AppServiceProvider extends ServiceProvider
      */
     public function boot()
     {
-        //
+
     }
 }