pc

application/api/controller/UserSiteMsg.php

@@ -47,7 +47,7 @@ class UserSiteMsg extends Api
         ]);
         $user=$this->auth->getUser();
         $msg=SiteMsg::findOrFail($data['id']);
-        if(!$msg->read()->where('user_id',$user->id)->find()) {
+        if(!$msg->read()->filterUser($user)->find()) {
             $msg->read()->save([
                 'user_id' => $user->id,
             ]);

application/common/model/SiteMsg.php

@@ -4,6 +4,7 @@ namespace app\common\model;
 
 use think\db\Query;
 use think\Model;
+use think\model\relation\HasMany;
 use Yansongda\Supports\Arr;
 
 /**
@@ -19,6 +20,9 @@ class SiteMsg extends Model
     const TYPE_ORDER_REFUND_PASS='order_refund_pass';
     const TYPE_ORDER_REFUND_REJECT='order_refund_reject';
     const TYPE_NEW_GOODS='new_goods';
+    /**
+     * @return SiteMsgRead|HasMany
+     */
     public function read(){
         return $this->hasMany(SiteMsgRead::class);
     }

application/common/model/SiteMsgRead.php

@@ -2,9 +2,15 @@
 
 namespace app\common\model;
 
+use think\db\Query;
 use think\Model;
 
-
+/**
+ * @method $this|Query filterUser($user)
+ */
 class SiteMsgRead extends Model
 {
+    public function scopeFilterUser(Query $query,$user){
+        $query->where($this->__('user_id'),$user instanceof User?$user->id:$user);
+    }
 }