1 消息输出 逻辑修改

@@ -33,12 +33,17 @@ func main() {
 
 	// 服务初始化
 	opts := make([]rest.RunOption, 0)
-	opt := rest.WithCustomCors(func(header http.Header) {
+	opts = append(opts, rest.WithCustomCors(func(header http.Header) {
 		header.Set("Access-Control-Allow-Headers", "*")
 	}, func(writer http.ResponseWriter) {
 
-	})
-	opts = append(opts, opt)
+	}))
+	opts = append(opts, rest.WithUnauthorizedCallback(func(w http.ResponseWriter, r *http.Request, err error) {
+		if err != nil {
+			logx.Debugf("unauthorized: %s \n", err.Error())
+		}
+	}))
+
 	server := rest.MustNewServer(c.RestConf, opts...)
 	defer server.Stop()
 	ctx := svc.NewServiceContext(c)
@@ -73,6 +78,7 @@ func systemSetup(c config.Config) {
 	httpx.SetErrorHandlerCtx(func(ctx context.Context, err error) (int, any) {
 		return http.StatusOK, result.Error(xerr.ServerCommonError, err.Error())
 	})
+
 	// 系统成功应答包装
 	httpx.SetOkHandler(func(ctx context.Context, a any) any {
 		return result.Success(a)

@@ -32,7 +32,9 @@ func (l *MiniBusinessLogic) MiniBusiness(req *types.MessageRequest, msgType doma
 
 	total, list, err := l.svcCtx.MessageBusinessRepository.Find(l.ctx, conn, domain.NewQueryOptions().
 		WithOffsetLimit(req.Page, req.Size).
-		WithKV("type", msgType))
+		WithKV("type", msgType).
+		WithKV("companyId", userToken.CompanyId).
+		WithKV("recipientId", userToken.UserId))
 	if err != nil {
 		return nil, err
 	}