zory hace 2 semanas
padre
commit
402a4b56f4

+ 3 - 1
app/controller/IndexController.php

@@ -17,7 +17,9 @@ class IndexController
             "content"   => "哈稍等哈就说客家话",
             "source" => 2,
             "avatar"    => "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png",
-            "poi_id"    => "7644106137976965139"
+            "poi_id"    => "7644106137976965139",
+            "openid"  => "_000KmfiVkio30K9VxoeLUUY3_hngEWcgR7u",
+            "service_id"  => "105"
         ]);
         echo "asd";
 //        $param = [

+ 22 - 4
app/controller/api/Service.php

@@ -67,16 +67,17 @@ class Service extends Base
             $store = (new SaasStore)->where("poi_id",$param['poi'])->findOrEmpty();
             if ($store->isEmpty()) return error("店铺不存在");
             $chatStore = (new SaasChatStore)->where(['poi_id'=> $store['poi_id'],"openid" => $request->user['openid']])->findOrEmpty();
+            // 获取在线客服
+            $service = (new SystemUser)->where("store_id",$param['poi'])->where("type",3)->where("is_line",1)->findOrEmpty();
+            if ($service->isEmpty()) return $this->encode("ok",['store' => $store,'code' => 3]); // 无客服在线
             if ($chatStore->isEmpty()) {
                 $chatStore->insertGetId([
                     "poi_id"    => $store['poi_id'],
                     "poi_name"  => $store['poi_name'],
-                    "openid"    => $request->user['openid']
+                    "openid"    => $request->user['openid'],
+                    "service_id"    => $service['id']
                 ]);
             }
-            // 获取在线客服
-            $service = (new SystemUser)->where("store_id",$param['poi'])->where("type",3)->where("is_line",1)->findOrEmpty();
-            if ($service->isEmpty()) return $this->encode("ok",['store' => $store,'code' => 3]); // 无客服在线
             // 获取最新的10条聊天记录
             $msg = (new SaasChatMsg)->where(['openid' => $request->user['openid'],'poi_id' => $store['poi_id']])->append(['avatar','time'])->withAttr(['avatar' => function(){
                 return "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png";
@@ -91,4 +92,21 @@ class Service extends Base
             return error($throwable->getMessage());
         }
     }
+
+    /**
+     * 发送消息
+     * @param Request $request
+     * @return Response
+     */
+    #[PostMapping("send")]
+    public function sendMsg(Request $request): Response
+    {
+        try {
+            $param = $request->all();
+
+            return error("err");
+        } catch (\Throwable $throwable) {
+            return error($throwable->getMessage());
+        }
+    }
 }

+ 53 - 0
app/controller/service/Service.php

@@ -0,0 +1,53 @@
+<?php
+
+namespace app\controller\service;
+
+use app\extra\basic\Base;
+use app\middleware\AuthMiddleware;
+use app\model\saas\SaasChatMsg;
+use app\model\saas\SaasChatStore;
+use app\service\saas\ChatStoreService;
+use DI\Attribute\Inject;
+use LinFly\Annotation\Attributes\Route\Controller;
+use LinFly\Annotation\Attributes\Route\GetMapping;
+use LinFly\Annotation\Attributes\Route\Middleware;
+use support\Request;
+use support\Response;
+
+
+#[Controller("/api/service/chat"),Middleware(AuthMiddleware::class)]
+class Service extends Base
+{
+
+    #[Inject]
+    protected ChatStoreService $service;
+
+    #[Inject]
+    protected SaasChatStore $model;
+
+    #[GetMapping('list')]
+    public function getServiceData(Request $request): Response
+    {
+
+        try {
+            $param = $request->all();
+            $param['poi_id'] = $request->user['store_id'];
+            $param['service_id'] = $request->user['id'];
+            $data = $this->service->setModel()->getList($param,['user' => function($query){
+                $query->field("openid,nickname,mobile");
+            }],true,['last','avatar'],['last' => function($data,$resp) use($param){
+                $last = (new SaasChatMsg)->where(["poi_id" => $resp['poi_id'],"service_id" => $param['service_id'],"openid" => $resp['openid']])->order("create_at desc")->field("content,create_at,type")->findOrEmpty();
+                if ($last->isEmpty()) {
+                    return ['type' => "text","content"=>"无",'num' => 0,"create_at"=> formatTime(date("Y-m-d H:i:s",time()))];
+                }
+                return ["content"=> $last['content'],'num' => 0,"create_at"=> formatTime($last['create_at']),'type' => $last['type']];
+            },'avatar' => function(){
+                return "https://washmy.oss-cn-guangzhou.aliyuncs.com/storage/20260511/23627b2cb8f73a8a90b95c31d726e6ecad0cbb9a.png";
+            }]);
+            return successTrans(100010,pageFormat($data),200);
+        } catch (\Throwable $th) {
+            return error($th->getMessage());
+        }
+    }
+
+}

+ 10 - 4
app/model/saas/SaasChatStore.php

@@ -3,13 +3,14 @@
 namespace app\model\saas;
 
 use app\extra\basic\Model;
+use think\model\relation\HasOne;
 
 
 /**
- * @property integer $id (主键)
- * @property mixed $openid 
- * @property mixed $poi_id 店铺ID
- * @property string $poi_name 店铺名称
+ * @property integer $id (主键)
+ * @property mixed $openid 
+ * @property mixed $poi_id 店铺ID
+ * @property string $poi_name 店铺名称
  * @property mixed $create_at
  */
 class SaasChatStore extends Model
@@ -43,4 +44,9 @@ class SaasChatStore extends Model
     public bool $timestamps = false;
 
 
+    public function user(): HasOne
+    {
+        return $this->hasOne(SaasUserOpen::class,"openid","openid");
+    }
+
 }

+ 2 - 0
app/service/saas/ChatStoreService.php

@@ -27,6 +27,8 @@ class ChatStoreService extends Service
     {
         $filter = [];
         !empty($param['openid']) && $filter[] = ["openid", '=', $param['openid']];
+        !empty($param['service_id']) && $filter[] = ["service_id", '=', $param['service_id']];
+        !empty($param['poi_id']) && $filter[] = ["poi_id", '=', $param['poi_id']];
         !empty($param['status']) && $filter[] = ["status", '=', $param['status']];
         !empty($param['type']) && $filter[] = ["type", '=', $param['type']];
         !empty($param['name']) && $filter[] = ["poi_name", 'like', "%{$param['name']}%"];