v6优化程序 OA绑定AICC

@@ -79,7 +79,7 @@ class PushAiccData extends Command
         $data['friend_id']  = $isExists->friend_id;
         $data['friend_id']  = $isExists->friend_id;
         $data['user_id']    = $isExists->user_id;
         $data['user_id']    = $isExists->user_id;
 
 
-        $url         = env('AICC_URL');
+        $url         = env('AICC_URL') . env('AICC_PUSH_API_URL');
         $msg         = http_post($url, json_encode(compact('data')));
         $msg         = http_post($url, json_encode(compact('data')));
         $status_code = 0;
         $status_code = 0;
         if ($msg) {
         if ($msg) {
@@ -105,7 +105,7 @@ class PushAiccData extends Command
 
 
     public function post_data($data)
     public function post_data($data)
     {
     {
-        $url = env('AICC_URL');
+        $url = env('AICC_URL') . env('AICC_PUSH_API_URL');
         $msg = http_post($url, json_encode(compact('data')));
         $msg = http_post($url, json_encode(compact('data')));
         print_r($msg);
         print_r($msg);
     }
     }

@@ -6,7 +6,9 @@ use App\Enums\Common\Code;
 use App\Exceptions\BsideGlobalException;
 use App\Exceptions\BsideGlobalException;
 use App\Http\Controllers\Bside\BaseController;
 use App\Http\Controllers\Bside\BaseController;
 use App\Http\Logic\Aside\ProjectAssociation\ProjectAssociationLogic;
 use App\Http\Logic\Aside\ProjectAssociation\ProjectAssociationLogic;
+use App\Models\ProjectAssociation\ProjectAssociation;
 use Illuminate\Http\Request;
 use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
 use Psr\Container\ContainerExceptionInterface;
 use Psr\Container\ContainerExceptionInterface;
 use Psr\Container\NotFoundExceptionInterface;
 use Psr\Container\NotFoundExceptionInterface;
 
 
@@ -48,4 +50,54 @@ class ProjectAssociationController extends BaseController
         $this->ProjectAssociationLogic->saveWeChatData($data);
         $this->ProjectAssociationLogic->saveWeChatData($data);
         $this->response('success');
         $this->response('success');
     }
     }
+
+    public function check()
+    {
+        $project_id = (int)request()->input('project_id', 0);
+        $status = request()->input('status');
+        if (isset($status)) {
+            $status = (int)$status ? ProjectAssociation::STATUS_NORMAL : ProjectAssociation::STATUS_DISABLED;
+        }
+        $isRes = $this->ProjectAssociationLogic->normal($project_id);
+        DB::beginTransaction();
+        try {
+            // 当数据不存在时并开启状态，自动添加一条数据
+            if (is_null($isRes) && (!is_null($status) && $status)) {
+                $isRes = $this->ProjectAssociationLogic->disabled($project_id);
+                if (is_null($isRes)) {
+                    $isRes = new ProjectAssociation();
+                }
+                $isRes->project_id = $project_id;
+                $isRes->user_id    = (int)env('AICC_WECHAT_USER_ID');
+                $isRes->status     = $status;
+                $isRes->save();
+                DB::commit();
+            } // 关闭状态
+            elseif (!is_null($isRes) && (!is_null($status) && empty($status))) {
+                $isRes->status = $status;
+                $isRes->save();
+                DB::commit();
+                return [
+                    'code'    => Code::SUCCESS,
+                    'data'    => [],
+                    'message' => '关闭AICC绑定成功!',
+                ];
+            }
+        } catch (\Exception $exception) {
+            DB::rollBack();
+            $this->response('数据错误，请重试！', Code::SERVER_ERROR);
+        }
+        if (is_null($isRes)) {
+            $this->response('请开启AICC绑定！', Code::USER_ERROR, []);
+        }
+        $url            = env('AICC_URL') . env('AICC_WECHAT_FRIEND_API_URL');
+        $result         = curlGet($url);
+        $result['info'] = [
+            'friend_id' => $isRes->friend_id ?? 0,
+            'nickname'  => $isRes->nickname ?? '',
+            'user_name' => $isRes->user_name ?? '',
+            'image'     => $isRes->image ?? '',
+        ];
+        $this->response('success', Code::SUCCESS, $result);
+    }
 }
 }

@@ -5,6 +5,8 @@ namespace App\Http\Logic\Aside\ProjectAssociation;
 use App\Enums\Common\Code;
 use App\Enums\Common\Code;
 use App\Http\Logic\Logic;
 use App\Http\Logic\Logic;
 use App\Models\ProjectAssociation\ProjectAssociation;
 use App\Models\ProjectAssociation\ProjectAssociation;
+use Illuminate\Database\Eloquent\Builder;
+use Illuminate\Database\Eloquent\Model;
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\DB;
 
 
 class ProjectAssociationLogic extends Logic
 class ProjectAssociationLogic extends Logic
@@ -24,4 +26,25 @@ class ProjectAssociationLogic extends Logic
         }
         }
         return $status;
         return $status;
     }
     }
+
+    /**
+     * status - 正常
+     * @param $project_id
+     * @return ProjectAssociation|Builder|Model|object|null
+     */
+    public function normal($project_id)
+    {
+        return ProjectAssociation::query()->whereProjectId($project_id)->whereStatus(ProjectAssociation::STATUS_NORMAL)->first();
+    }
+
+
+    /**
+     * status - 禁用
+     * @param $project_id
+     * @return ProjectAssociation|Builder|Model|object|null
+     */
+    public function disabled($project_id)
+    {
+        return ProjectAssociation::query()->whereProjectId($project_id)->whereStatus(ProjectAssociation::STATUS_DISABLED)->first();
+    }
 }
 }

@@ -73,6 +73,8 @@ Route::middleware(['aloginauth'])->group(function () {
         Route::any('/log', [Aside\Ai\AiLogController::class, 'lists'])->name('admin.lists');
         Route::any('/log', [Aside\Ai\AiLogController::class, 'lists'])->name('admin.lists');
         // 绑定AICC微信应用
         // 绑定AICC微信应用
         Route::post('/wechat', [ProjectAssociationController::class, 'saveWeChatData'])->name('admin.aicc.wechat');
         Route::post('/wechat', [ProjectAssociationController::class, 'saveWeChatData'])->name('admin.aicc.wechat');
+        // OA后台开启关闭AICC用户绑定
+        Route::get('/check', [ProjectAssociationController::class, 'check'])->name('admin.aicc.check');
     });
     });
     //特殊模块权限设置
     //特殊模块权限设置
     Route::prefix('special')->group(function () {
     Route::prefix('special')->group(function () {