rkljw 3 өдөр өмнө
parent
commit
35b96edff3

+ 169 - 4
app/JsonRpc/NewsService.php

@@ -691,7 +691,8 @@ class NewsService implements NewsServiceInterface
           'talk_type'=>100,
           'talk_type'=>100,
           'title'=>$articleData['title'],
           'title'=>$articleData['title'],
           'content'=>'提交了审核',
           'content'=>'提交了审核',
-          'messageType'=>2,]);
+          'messageType'=>2,
+        ]);
       }
       }
       $id = Article::where(['id' => $data['id']])->update($articleData);
       $id = Article::where(['id' => $data['id']])->update($articleData);
       $articleDataContent = [
       $articleDataContent = [
@@ -3870,7 +3871,14 @@ class NewsService implements NewsServiceInterface
       // 如果 city_arr_id 不是字符串,直接取最后一个数据
       // 如果 city_arr_id 不是字符串,直接取最后一个数据
       $data['city_id'] = end($data['city_arr_id']);
       $data['city_id'] = end($data['city_arr_id']);
     }
     }
-
+    if((isset($data['status']) && $data['status']==1) || !isset($data['status'])){
+      $this->sendMessage([
+        'talk_type'=>600,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>11,
+      ]);
+    }
     $result = JobHunting::create($data);
     $result = JobHunting::create($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("添加失败", 0);
       return Result::error("添加失败", 0);
@@ -3906,7 +3914,14 @@ class NewsService implements NewsServiceInterface
       // 如果 city_arr_id 不是字符串,直接取最后一个数据
       // 如果 city_arr_id 不是字符串,直接取最后一个数据
       $data['city_id'] = end($data['city_arr_id']);
       $data['city_id'] = end($data['city_arr_id']);
     }
     }
-
+    if((isset($data['status']) && $data['status']==1) || !isset($data['status'])){
+      $this->sendMessage([
+        'talk_type'=>600,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>11,
+      ]);
+    }
     $result = JobHunting::where('id', $data['id'])->update($data);
     $result = JobHunting::where('id', $data['id'])->update($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("更新失败", 0);
       return Result::error("更新失败", 0);
@@ -4393,6 +4408,25 @@ class NewsService implements NewsServiceInterface
     $type_id = $data['type_id'] ?? 0;
     $type_id = $data['type_id'] ?? 0;
     unset($data['user_id']);
     unset($data['user_id']);
     unset($data['type_id']);
     unset($data['type_id']);
+    $jogHuntingInfo = JobHunting::where('id', $data['id'])->first();
+    if($data['status']==2){
+      $this->sendMessage([
+        'talk_type'=>600,
+        'title'=>$jogHuntingInfo['name'],
+        'content'=>'审核通过',
+        'messageType'=>11,
+        'user_id'=>$jogHuntingInfo['user_id'],
+      ]);
+    }
+    if($data['status']==3){
+      $this->sendMessage([
+        'talk_type'=>600,
+        'title'=>$jogHuntingInfo['name'],
+        'content'=>'审核拒绝',
+        'messageType'=>11,
+        'user_id'=>$jogHuntingInfo['user_id'],
+      ]);
+    }
     $result = JobHunting::where('id', $data['id'])->update($data);
     $result = JobHunting::where('id', $data['id'])->update($data);
     return Result::success($result);
     return Result::success($result);
   }
   }
@@ -4663,6 +4697,14 @@ class NewsService implements NewsServiceInterface
       } else {
       } else {
         $job['experience'] = $data['experience'];
         $job['experience'] = $data['experience'];
       }
       }
+      if((isset($data['status']) && $data['status']==0) || !isset($data['status'])){
+        $this->sendMessage([
+          'talk_type'=>500,
+          'title'=>$data['title'],
+          'content'=>'提交了审核',
+          'messageType'=>10,
+        ]);
+      }
       $jobId = JobRecruiting::insertGetId($job);
       $jobId = JobRecruiting::insertGetId($job);
       if (empty($jobId)) {
       if (empty($jobId)) {
         Db::rollBack();
         Db::rollBack();
@@ -4837,6 +4879,14 @@ class NewsService implements NewsServiceInterface
       }
       }
       // Db::rollBack();
       // Db::rollBack();
       // return Result::success($company);
       // return Result::success($company);
+      if((isset($data['status']) && $data['status']==0) || !isset($data['status'])){
+        $this->sendMessage([
+          'talk_type'=>500,
+          'title'=>$data['title'],
+          'content'=>'提交了审核',
+          'messageType'=>10,
+        ]);
+      }
       $result['job'] = JobRecruiting::where('id', $jobId)->update($data);
       $result['job'] = JobRecruiting::where('id', $jobId)->update($data);
       if (empty($result['job'])) {
       if (empty($result['job'])) {
         Db::rollBack();
         Db::rollBack();
@@ -5136,6 +5186,26 @@ class NewsService implements NewsServiceInterface
     }
     }
     $data['action_id'] = $data['user_id'];
     $data['action_id'] = $data['user_id'];
     unset($data['user_id']);
     unset($data['user_id']);
+	  
+    if($data['status']==1){
+      $this->sendMessage([
+        'talk_type'=>500,
+        'title'=>$job['title'],
+        'content'=>'审核通过',
+        'messageType'=>10,
+        'user_id'=>$job['user_id'],
+      ]);
+    }
+    if($data['status']==2){
+      $this->sendMessage([
+        'talk_type'=>500,
+        'title'=>$job['title'],
+        'content'=>'审核拒绝',
+        'messageType'=>10,
+        'user_id'=>$job['user_id'],
+      ]);
+    }
+
     $result = JobRecruiting::where('id', $data['id'])->update($data);
     $result = JobRecruiting::where('id', $data['id'])->update($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("审核失败", 0);
       return Result::error("审核失败", 0);
@@ -5387,7 +5457,14 @@ class NewsService implements NewsServiceInterface
       $data['description'] = mb_substr($cleaned, 0, 100, 'UTF-8');
       $data['description'] = mb_substr($cleaned, 0, 100, 'UTF-8');
     }
     }
     var_dump($data, '--');
     var_dump($data, '--');
-
+    if($data['status']==1){
+      $this->sendMessage([
+        'talk_type'=>400,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>7,
+      ]);
+    }
     $result = Book::insertGetId($data);
     $result = Book::insertGetId($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("添加失败", 0);
       return Result::error("添加失败", 0);
@@ -5480,6 +5557,14 @@ class NewsService implements NewsServiceInterface
     }
     }
     $data['city_arr_id'] = is_array($data['city_arr_id']) ? Json::encode($data['city_arr_id']) : '[]';
     $data['city_arr_id'] = is_array($data['city_arr_id']) ? Json::encode($data['city_arr_id']) : '[]';
     $data['cat_arr_id'] = is_array($data['cat_arr_id']) ? Json::encode($data['cat_arr_id']) : '[]';
     $data['cat_arr_id'] = is_array($data['cat_arr_id']) ? Json::encode($data['cat_arr_id']) : '[]';
+    if($data['status']==1){
+      $this->sendMessage([
+        'talk_type'=>400,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>7,
+      ]);
+    }
     $result = Book::where("id", $data["id"])->update($data);
     $result = Book::where("id", $data["id"])->update($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("更新失败", 0);
       return Result::error("更新失败", 0);
@@ -5498,6 +5583,25 @@ class NewsService implements NewsServiceInterface
   {
   {
     //审核
     //审核
     unset($data['user_id']);
     unset($data['user_id']);
+    $bookInfo = Book::where("id", $data["id"])->first();
+    if($bookInfo['status']==2){
+      $this->sendMessage([
+        'talk_type'=>400,
+        'title'=>$bookInfo['title'],
+        'content'=>'审核通过',
+        'messageType'=>7,
+        'user_id'=>$bookInfo['user_id'],
+      ]);
+    }
+    if($bookInfo['status']==3){
+      $this->sendMessage([
+        'talk_type'=>400,
+        'title'=>$bookInfo['title'],
+        'content'=>'审核拒绝',
+        'messageType'=>7,
+        'user_id'=>$bookInfo['user_id'],
+      ]);
+    }
     $result = Book::where("id", $data["id"])->update($data);
     $result = Book::where("id", $data["id"])->update($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("更新失败", 0);
       return Result::error("更新失败", 0);
@@ -6020,6 +6124,14 @@ class NewsService implements NewsServiceInterface
     } else {
     } else {
       $data['level'] = null;
       $data['level'] = null;
     }
     }
+    if((isset($data['status']) && $data['status']==0) || !isset($data['status'])){
+      $this->sendMessage([
+        'talk_type'=>900,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>8,
+      ]);
+    }
     $result = Company::insertGetId($data);
     $result = Company::insertGetId($data);
     if ($result) {
     if ($result) {
       return Result::success($result);
       return Result::success($result);
@@ -6090,6 +6202,14 @@ class NewsService implements NewsServiceInterface
     } else {
     } else {
       $data['status'] = 0;
       $data['status'] = 0;
     }
     }
+    if((isset($data['status']) && $data['status']==0) || !isset($data['status'])){
+      $this->sendMessage([
+        'talk_type'=>900,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>8,
+      ]);
+    }
     $result = Company::where('id', $data['id'])->update($data);
     $result = Company::where('id', $data['id'])->update($data);
     if ($result) {
     if ($result) {
       return Result::success($result);
       return Result::success($result);
@@ -6128,8 +6248,23 @@ class NewsService implements NewsServiceInterface
     }
     }
     // 状态:0:未审核 1:已审核 2:已拒绝
     // 状态:0:未审核 1:已审核 2:已拒绝
     if ($data['status'] == 2 || $data['status'] == '2') {
     if ($data['status'] == 2 || $data['status'] == '2') {
+      $this->sendMessage([
+        'talk_type'=>901,
+        'title'=>$company['title'],
+        'content'=>'审核拒绝',
+        'messageType'=>8,
+        'user_id'=>$company['user_id'],
+      ]);
       $result = Company::where('id', $data['id'])->update(['status' => $data['status'], 'reject_reason' => $data['reason']]);
       $result = Company::where('id', $data['id'])->update(['status' => $data['status'], 'reject_reason' => $data['reason']]);
     } else {
     } else {
+      $this->sendMessage([
+        'talk_type'=>901,
+        'title'=>$company['title'],
+        'content'=>'审核通过',
+        'messageType'=>8,
+        'user_id'=>$company['user_id'],
+      ]);
+     
       $result = Company::where('id', $data['id'])->update(['status' => $data['status']]);
       $result = Company::where('id', $data['id'])->update(['status' => $data['status']]);
     }
     }
     if (empty($result)) {
     if (empty($result)) {
@@ -6408,6 +6543,14 @@ class NewsService implements NewsServiceInterface
       $data['description'] = mb_substr($content, 0, 100);
       $data['description'] = mb_substr($content, 0, 100);
       // 过滤 HTML 标签并去除空格,然后截取前 100 个字符
       // 过滤 HTML 标签并去除空格,然后截取前 100 个字符
     }
     }
+    if($data['status']==0){
+      $this->sendMessage([
+        'talk_type'=>1000,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>9,
+      ]);
+    }
     $project = Project::insertGetId($data);
     $project = Project::insertGetId($data);
     if (empty($project)) {
     if (empty($project)) {
       return Result::error("暂无相关项目信息", 0);
       return Result::error("暂无相关项目信息", 0);
@@ -6466,6 +6609,14 @@ class NewsService implements NewsServiceInterface
       $data['description'] = mb_substr($content, 0, 100);
       $data['description'] = mb_substr($content, 0, 100);
       // 过滤 HTML 标签并去除空格,然后截取前 100 个字符
       // 过滤 HTML 标签并去除空格,然后截取前 100 个字符
     }
     }
+    if($data['status']==0){
+      $this->sendMessage([
+        'talk_type'=>1000,
+        'title'=>$data['title'],
+        'content'=>'提交了审核',
+        'messageType'=>9,
+      ]);
+    }
     $result = Project::where('id', $id)->update($data);
     $result = Project::where('id', $id)->update($data);
     if (empty($result)) {
     if (empty($result)) {
       return Result::error("更新失败", 0);
       return Result::error("更新失败", 0);
@@ -6516,8 +6667,22 @@ class NewsService implements NewsServiceInterface
       return Result::error("暂无相关项目信息", 0);
       return Result::error("暂无相关项目信息", 0);
     }
     }
     if ($data['status'] == 2) {
     if ($data['status'] == 2) {
+      $this->sendMessage([
+        'talk_type'=>1001,
+        'title'=>$project['title'],
+        'content'=>'审核拒绝',
+        'messageType'=>9,
+        'user_id'=>$project['user_id'],
+      ]);
       $result = Project::where('id', $data['id'])->update(['status' => $data['status'], 'refuse_reason' => $data['refuse_reason']]);
       $result = Project::where('id', $data['id'])->update(['status' => $data['status'], 'refuse_reason' => $data['refuse_reason']]);
     } else {
     } else {
+      $this->sendMessage([
+        'talk_type'=>1001,
+        'title'=>$project['title'],
+        'content'=>'审核通过',
+        'messageType'=>9,
+        'user_id'=>$project['user_id'],
+      ]);
       $result = Project::where('id', $data['id'])->update(['status' => $data['status']]);
       $result = Project::where('id', $data['id'])->update(['status' => $data['status']]);
     }
     }