添加mqtt binding

test/mqtt_binding_test.go

@@ -5,6 +5,7 @@ import (
 	"git.sxidc.com/go-framework/baize"
 	"git.sxidc.com/go-framework/baize/framework/core/application"
 	"git.sxidc.com/go-framework/baize/framework/core/domain"
+	"git.sxidc.com/go-framework/baize/framework/core/domain/entity"
 	"git.sxidc.com/go-framework/baize/framework/core/infrastructure"
 	"git.sxidc.com/go-framework/baize/framework/core/mqtt_api"
 	"git.sxidc.com/go-framework/baize/framework/core/mqtt_api/mqtt_request"
@@ -14,10 +15,29 @@ import (
 )
 
 type Hello struct {
-	What  string `json:"what"`
+	What  string `json:"what" assign:"toField:what"`
 	Reply string `json:"reply"`
 }
 
+type Entity struct {
+	entity.Base
+	What string
+}
+
+func (e Entity) DomainCNName() string {
+	return "实体"
+}
+
+func (e Entity) DomainCamelName() string {
+	return "Entity"
+}
+
+func (e Entity) GetFieldMap() map[string]string {
+	return map[string]string{
+		"what": "什么",
+	}
+}
+
 func TestMqttBinding(t *testing.T) {
 	app := baize.NewApplication(application.Config{
 		ApiConfig: application.ApiConfig{
@@ -85,13 +105,16 @@ func TestMqttBinding(t *testing.T) {
 
 			return req.Reply, nil
 		},
+		Objects: []domain.Object{&Entity{}},
 		ServiceFunc: func(c *mqtt_api.Context, params any, objects []domain.Object, i *infrastructure.Infrastructure) (map[string]any, error) {
-			req, err := mqtt_request.ToConcrete[*Hello](params)
+			fmt.Println("Hello")
+
+			e, err := domain.ToConcrete[*Entity](objects[0])
 			if err != nil {
 				return make(map[string]any), err
 			}
 
-			return map[string]any{"message": "Hello " + req.What}, nil
+			return map[string]any{"message": "Hello " + e.What}, nil
 		},
 	}, func(c *mqtt_api.Context, i *infrastructure.Infrastructure) {
 		fmt.Println("Hello Middleware")