diff --git a/Makefile b/Makefile index a050764..35ef016 100644 --- a/Makefile +++ b/Makefile @@ -45,7 +45,7 @@ swag: # 生成protobuf文件 .PHONY: proto proto: - protoc --go_out=internal/domain/device/proto --go_opt=paths=source_relative --go-grpc_out=internal/domain/device/proto --go-grpc_opt=paths=source_relative -Iinternal/domain/device/proto internal/domain/device/proto/device.proto + protoc --go_out=internal/infra/transport/proto --go_opt=paths=source_relative --go-grpc_out=internal/infra/transport/proto --go-grpc_opt=paths=source_relative -Iinternal/infra/transport/proto internal/infra/transport/proto/device.proto # 运行代码检查 .PHONY: lint diff --git a/config.yml b/config.yml index 6b3f841..a3aa9e2 100644 --- a/config.yml +++ b/config.yml @@ -62,25 +62,28 @@ task: # Lora 配置 lora: - mode: "lora_wan" # "lora_wan" or "lora_mesh" + mode: "lora_mesh" # "lora_wan" or "lora_mesh" lora_mesh: # 主节点串口 uart_port: "/dev/ttyS1" # LoRa模块的通信波特率 baud_rate: 9600 - # 等待LoRa模块AT指令响应的超时时间 - timeout: 5 + # 等待LoRa模块AT指令响应的超时时间(ms) + timeout: 50 # LoRa Mesh 模块发送模式(EC: 透传; ED: 完整数据包) # e.g. # EC: 接收端只会接收到消息, 不会接收到请求头 # e.g. 发送: EC 05 02 01 48 65 6c 6c 6f # (EC + 05(消息长度) + 0201(地址) + "Hello"(消息本体)) # 接收: 48 65 6c 6c 6f ("Hello") - # ED: 接收端会接收完整数据包，包含请求头 - # e.g. 发送: ED 05 02 01 48 65 6c 6c 6f - # (ED + 05(消息长度) + 0201(地址) + "Hello"(消息本体)) - # 接收: ED 05 02 01 48 65 6c 6c 6f + # ED: 接收端会接收完整数据包，包含自定义协议头和地址信息。 + # e.g. 发送: ED 05 12 34 01 00 01 02 03 + # (ED(帧头) + 05(Length, 即 1(总包数)+1(当前包序号)+3(数据块)) + 12 34(目标地址) + 01(总包数) + 00(当前包序号) + 01 02 03(数据块)) + # 接收: ED 05 12 34 01 00 01 02 03 56 78(56 78 是发送方地址,会自动拼接到消息末尾) lora_mesh_mode: "ED" # 单包最大用户数据数据长度, 模块限制240, 去掉两位自定义包头, 还剩238 - max_chunk_size: 238 \ No newline at end of file + max_chunk_size: 238 + #分片重组超时时间（秒）。如果在一个分片到达后，超过这个时间 + # 还没收到完整的包，则认为接收失败。 + reassembly_timeout: 30 \ No newline at end of file diff --git a/go.mod b/go.mod index 5370975..ebb6587 100644 --- a/go.mod +++ b/go.mod @@ -10,12 +10,14 @@ require ( github.com/go-openapi/swag v0.24.1 github.com/go-openapi/validate v0.24.0 github.com/golang-jwt/jwt/v5 v5.3.0 + github.com/google/uuid v1.6.0 github.com/panjf2000/ants/v2 v2.11.3 github.com/robfig/cron/v3 v3.0.1 github.com/stretchr/testify v1.11.1 github.com/swaggo/files v1.0.1 github.com/swaggo/gin-swagger v1.6.1 github.com/swaggo/swag v1.16.6 + github.com/tarm/serial v0.0.0-20180830185346-98f6abe2eb07 go.uber.org/zap v1.27.0 golang.org/x/crypto v0.42.0 google.golang.org/protobuf v1.36.9 @@ -35,8 +37,6 @@ require ( github.com/bytedance/sonic v1.14.1 // indirect github.com/bytedance/sonic/loader v0.3.0 // indirect github.com/cloudwego/base64x v0.1.6 // indirect - github.com/cloudwego/iasm v0.2.0 // indirect - github.com/cpuguy83/go-md2man/v2 v2.0.7 // indirect github.com/davecgh/go-spew v1.1.1 // indirect github.com/gabriel-vasile/mimetype v1.4.10 // indirect github.com/gin-contrib/sse v1.1.0 // indirect @@ -63,7 +63,6 @@ require ( github.com/go-playground/validator/v10 v10.27.0 // indirect github.com/go-sql-driver/mysql v1.8.1 // indirect github.com/goccy/go-json v0.10.5 // indirect - github.com/google/uuid v1.6.0 // indirect github.com/jackc/pgpassfile v1.0.0 // indirect github.com/jackc/pgservicefile v0.0.0-20240606120523-5a60cdf6a761 // indirect github.com/jackc/pgx/v5 v5.6.0 // indirect @@ -85,19 +84,14 @@ require ( github.com/pelletier/go-toml/v2 v2.2.4 // indirect github.com/pmezard/go-difflib v1.0.0 // indirect github.com/rogpeppe/go-internal v1.14.1 // indirect - github.com/russross/blackfriday/v2 v2.1.0 // indirect - github.com/shurcooL/sanitized_anchor_name v1.0.0 // indirect github.com/stretchr/objx v0.5.2 // indirect github.com/twitchyliquid64/golang-asm v0.15.1 // indirect github.com/ugorji/go/codec v1.3.0 // indirect - github.com/urfave/cli/v2 v2.27.7 // indirect - github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 // indirect go.mongodb.org/mongo-driver v1.14.0 // indirect go.opentelemetry.io/otel v1.24.0 // indirect go.opentelemetry.io/otel/metric v1.24.0 // indirect go.opentelemetry.io/otel/trace v1.24.0 // indirect go.uber.org/multierr v1.10.0 // indirect - go.yaml.in/yaml/v2 v2.4.3 // indirect golang.org/x/arch v0.21.0 // indirect golang.org/x/mod v0.28.0 // indirect golang.org/x/net v0.44.0 // indirect @@ -107,5 +101,4 @@ require ( golang.org/x/tools v0.37.0 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect gorm.io/driver/mysql v1.5.6 // indirect - sigs.k8s.io/yaml v1.6.0 // indirect ) diff --git a/go.sum b/go.sum index 82c0757..7c99d20 100644 --- a/go.sum +++ b/go.sum @@ -6,33 +6,19 @@ github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2 h1:DklsrG3d github.com/asaskevich/govalidator v0.0.0-20230301143203-a9d515a09cc2/go.mod h1:WaHUgvxTVq04UNunO+XhnAqY/wQc+bxr74GqbsZ/Jqw= github.com/bytedance/gopkg v0.1.3 h1:TPBSwH8RsouGCBcMBktLt1AymVo2TVsBVCY4b6TnZ/M= github.com/bytedance/gopkg v0.1.3/go.mod h1:576VvJ+eJgyCzdjS+c4+77QF3p7ubbtiKARP3TxducM= -github.com/bytedance/sonic v1.11.6 h1:oUp34TzMlL+OY1OUWxHqsdkgC/Zfc85zGqw9siXjrc0= -github.com/bytedance/sonic v1.11.6/go.mod h1:LysEHSvpvDySVdC2f87zGWf6CIKJcAvqab1ZaiQtds4= github.com/bytedance/sonic v1.14.1 h1:FBMC0zVz5XUmE4z9wF4Jey0An5FueFvOsTKKKtwIl7w= github.com/bytedance/sonic v1.14.1/go.mod h1:gi6uhQLMbTdeP0muCnrjHLeCUPyb70ujhnNlhOylAFc= -github.com/bytedance/sonic/loader v0.1.1 h1:c+e5Pt1k/cy5wMveRDyk2X4B9hF4g7an8N3zCYjJFNM= -github.com/bytedance/sonic/loader v0.1.1/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU= github.com/bytedance/sonic/loader v0.3.0 h1:dskwH8edlzNMctoruo8FPTJDF3vLtDT0sXZwvZJyqeA= github.com/bytedance/sonic/loader v0.3.0/go.mod h1:N8A3vUdtUebEY2/VQC0MyhYeKUFosQU6FxH2JmUe6VI= -github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/0Y= -github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w= github.com/cloudwego/base64x v0.1.6 h1:t11wG9AECkCDk5fMSoxmufanudBtJ+/HemLstXDLI2M= github.com/cloudwego/base64x v0.1.6/go.mod h1:OFcloc187FXDaYHvrNIjxSe8ncn0OOM8gEHfghB2IPU= -github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg= -github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY= -github.com/cpuguy83/go-md2man/v2 v2.0.7 h1:zbFlGlXEAKlwXpmvle3d8Oe3YnkKIK4xSRTd3sHPnBo= -github.com/cpuguy83/go-md2man/v2 v2.0.7/go.mod h1:oOW0eioCTA6cOiMLiUPZOpcVxMig6NIQQ7OS05n1F4g= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/gabriel-vasile/mimetype v1.4.3 h1:in2uUcidCuFcDKtdcBxlR0rJ1+fsokWf+uqxgUFjbI0= -github.com/gabriel-vasile/mimetype v1.4.3/go.mod h1:d8uq/6HKRL6CGdk+aubisF/M5GcPfT7nKyLpA0lbSSk= github.com/gabriel-vasile/mimetype v1.4.10 h1:zyueNbySn/z8mJZHLt6IPw0KoZsiQNszIpU+bX4+ZK0= github.com/gabriel-vasile/mimetype v1.4.10/go.mod h1:d+9Oxyo1wTzWdyVUPMmXFvp4F9tea18J8ufA774AB3s= github.com/gin-contrib/gzip v0.0.6 h1:NjcunTcGAj5CO1gn4N8jHOSIeRFHIbn51z6K+xaN4d4= github.com/gin-contrib/gzip v0.0.6/go.mod h1:QOJlmV2xmayAjkNS2Y8NQsMneuRShOU/kjovCXNuzzk= -github.com/gin-contrib/sse v0.1.0 h1:Y/yl/+YNO8GZSjAhjMsSuLt29uWRFHdHYUb5lYOV9qE= -github.com/gin-contrib/sse v0.1.0/go.mod h1:RHrZQHXnP2xjPF+u1gW/2HnVO7nvIa9PG3Gm+fLHvGI= github.com/gin-contrib/sse v1.1.0 h1:n0w2GMuUpWDVp7qSpvze6fAu9iRxJY4Hmj6AmBOU05w= github.com/gin-contrib/sse v1.1.0/go.mod h1:hxRZ5gVpWMT7Z0B0gSNYqqsSCNIJMjzvm6fqCz9vjwM= github.com/gin-gonic/gin v1.10.1 h1:T0ujvqyCSqRopADpgPgiTT63DUQVSfojyME59Ei63pQ= @@ -46,12 +32,8 @@ github.com/go-openapi/analysis v0.23.0 h1:aGday7OWupfMs+LbmLZG4k0MYXIANxcuBTYUC0 github.com/go-openapi/analysis v0.23.0/go.mod h1:9mz9ZWaSlV8TvjQHLl2mUW2PbZtemkE8yA5v22ohupo= github.com/go-openapi/errors v0.22.2 h1:rdxhzcBUazEcGccKqbY1Y7NS8FDcMyIRr0934jrYnZg= github.com/go-openapi/errors v0.22.2/go.mod h1:+n/5UdIqdVnLIJ6Q9Se8HNGUXYaY6CN8ImWzfi/Gzp0= -github.com/go-openapi/jsonpointer v0.21.0 h1:YgdVicSA9vH5RiHs9TZW5oyafXZFc6+2Vc1rr/O9oNQ= -github.com/go-openapi/jsonpointer v0.21.0/go.mod h1:IUyH9l/+uyhIYQ/PXVA41Rexl+kOkAPDdXEYns6fzUY= github.com/go-openapi/jsonpointer v0.22.0 h1:TmMhghgNef9YXxTu1tOopo+0BGEytxA+okbry0HjZsM= github.com/go-openapi/jsonpointer v0.22.0/go.mod h1:xt3jV88UtExdIkkL7NloURjRQjbeUgcxFblMjq2iaiU= -github.com/go-openapi/jsonreference v0.21.0 h1:Rs+Y7hSXT83Jacb7kFyjn4ijOuVGSvOdF2+tg1TRrwQ= -github.com/go-openapi/jsonreference v0.21.0/go.mod h1:LmZmgsrTkVg9LG4EaHeY8cBDslNPMo06cago5JNLkm4= github.com/go-openapi/jsonreference v0.21.1 h1:bSKrcl8819zKiOgxkbVNRUBIr6Wwj9KYrDbMjRs0cDA= github.com/go-openapi/jsonreference v0.21.1/go.mod h1:PWs8rO4xxTUqKGu+lEvvCxD5k2X7QYkKAepJyCmSTT8= github.com/go-openapi/loads v0.22.0 h1:ECPGd4jX1U6NApCGG1We+uEozOAvXvJSF4nnwHZ8Aco= @@ -62,8 +44,6 @@ github.com/go-openapi/spec v0.21.0 h1:LTVzPc3p/RzRnkQqLRndbAzjY0d0BCL72A6j3CdL9Z github.com/go-openapi/spec v0.21.0/go.mod h1:78u6VdPw81XU44qEWGhtr982gJ5BWg2c0I5XwVMotYk= github.com/go-openapi/strfmt v0.23.0 h1:nlUS6BCqcnAk0pyhi9Y+kdDVZdZMHfEKQiS4HaMgO/c= github.com/go-openapi/strfmt v0.23.0/go.mod h1:NrtIpfKtWIygRkKVsxh7XQMDQW5HKQl6S5ik2elW+K4= -github.com/go-openapi/swag v0.23.0 h1:vsEVJDUo2hPJ2tu0/Xc+4noaxyEffXNIs3cOULZ+GrE= -github.com/go-openapi/swag v0.23.0/go.mod h1:esZ8ITTYEsH1V2trKHjAN8Ai7xHb8RV+YSZ577vPjgQ= github.com/go-openapi/swag v0.24.1 h1:DPdYTZKo6AQCRqzwr/kGkxJzHhpKxZ9i/oX0zag+MF8= github.com/go-openapi/swag v0.24.1/go.mod h1:sm8I3lCPlspsBBwUm1t5oZeWZS0s7m/A+Psg0ooRU0A= github.com/go-openapi/swag/cmdutils v0.24.0 h1:KlRCffHwXFI6E5MV9n8o8zBRElpY4uK4yWyAMWETo9I= @@ -96,15 +76,11 @@ github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/o github.com/go-playground/locales v0.14.1/go.mod h1:hxrqLVvrK65+Rwrd5Fc6F2O76J/NuW9t0sjnWqG1slY= github.com/go-playground/universal-translator v0.18.1 h1:Bcnm0ZwsGyWbCzImXv+pAJnYK9S473LQFuzCbDbfSFY= github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91TpwSH2VMlDf28Uj24BCp08ZFTUY= -github.com/go-playground/validator/v10 v10.20.0 h1:K9ISHbSaI0lyB2eWMPJo+kOS/FBExVwjEviJTixqxL8= -github.com/go-playground/validator/v10 v10.20.0/go.mod h1:dbuPbCMFw/DrkbEynArYaCwl3amGuJotoKCe95atGMM= github.com/go-playground/validator/v10 v10.27.0 h1:w8+XrWVMhGkxOaaowyKH35gFydVHOvC0/uWoy2Fzwn4= github.com/go-playground/validator/v10 v10.27.0/go.mod h1:I5QpIEbmr8On7W0TktmJAumgzX4CA1XNl4ZmDuVHKKo= github.com/go-sql-driver/mysql v1.7.0/go.mod h1:OXbVy3sEdcQ2Doequ6Z5BW6fXNQTmx+9S1MCJN5yJMI= github.com/go-sql-driver/mysql v1.8.1 h1:LedoTUt/eveggdHS9qUFC1EFSa8bU2+1pZjSRpvNJ1Y= github.com/go-sql-driver/mysql v1.8.1/go.mod h1:wEBSXgmK//2ZFJyE+qWnIsVGmvmEKlqwuVSjsCm7DZg= -github.com/goccy/go-json v0.10.2 h1:CrxCmQqYDkv1z7lO7Wbh2HN93uovUHgrECaO5ZrCXAU= -github.com/goccy/go-json v0.10.2/go.mod h1:6MelG93GURQebXPDq3khkgXZkazVtN9CRI+MGFi0w8I= github.com/goccy/go-json v0.10.5 h1:Fq85nIqj+gXn/S5ahsiTlK3TmC85qgirsdTP/+DeaC4= github.com/goccy/go-json v0.10.5/go.mod h1:oq7eo15ShAhp70Anwd5lgX2pLfOS3QCiwU/PULtXL6M= github.com/golang-jwt/jwt/v5 v5.3.0 h1:pv4AsKCKKZuqlgs5sUmn4x8UlGa0kEVt/puTpKx9vvo= @@ -113,9 +89,8 @@ github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9 h1:au07oEsX2xN0kt github.com/golang-sql/civil v0.0.0-20220223132316-b832511892a9/go.mod h1:8vg3r2VgvsThLBIFL93Qb5yWzgyZWhEmBwUJWevAkK0= github.com/golang-sql/sqlexp v0.1.0 h1:ZCD6MBpcuOVfGVqsEmY5/4FtYiKz6tSyUv9LPEDei6A= github.com/golang-sql/sqlexp v0.1.0/go.mod h1:J4ad9Vo8ZCWQ2GMrC4UCQy1JpCbwU9m3EOqtpKwwwHI= -github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= -github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8= +github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU= github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= @@ -135,20 +110,14 @@ github.com/josharian/intern v1.0.0 h1:vlS4z54oSdjm0bgjRigI+G1HpF+tI+9rE5LLzOg8Hm github.com/josharian/intern v1.0.0/go.mod h1:5DoeVV0s6jJacbCEi61lwdGj/aVlrQvzHFFd8Hwg//Y= github.com/json-iterator/go v1.1.12 h1:PV8peI4a0ysnczrg+LtxykD8LfKY9ML6u2jnxaEnrnM= github.com/json-iterator/go v1.1.12/go.mod h1:e30LSqwooZae/UwlEbR2852Gd8hjQvJoHmT4TnhNGBo= -github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa0213Md/qVLRg= -github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM= -github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws= github.com/klauspost/cpuid/v2 v2.3.0 h1:S4CRMLnYUhGeDFDqkGriYKdfoFlDnMtqTiI/sFzhA9Y= github.com/klauspost/cpuid/v2 v2.3.0/go.mod h1:hqwkgyIinND0mEev00jJYCxPNVRVXFQeu1XKlok6oO0= -github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M= github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ= github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI= -github.com/mailru/easyjson v0.7.7 h1:UGYAvKxe3sBsEDzO8ZeWOSlIQfWFlxbzLZe7hwFURr0= -github.com/mailru/easyjson v0.7.7/go.mod h1:xzfreul335JAWq5oZzymOObrkdz5UnU4kGfJJLY9Nlc= github.com/mailru/easyjson v0.9.1 h1:LbtsOm5WAswyWbvTEOqhypdPeZzHavpZx96/n553mR8= github.com/mailru/easyjson v0.9.1/go.mod h1:1+xMtQp2MRNVL/V1bOzuP3aP8VNwRW55fQUto+XFtTU= github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= @@ -170,8 +139,6 @@ github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+ github.com/opentracing/opentracing-go v1.2.0/go.mod h1:GxEUsuufX4nBwe+T+Wl9TAgYrxe9dPLANfrWvHYVTgc= github.com/panjf2000/ants/v2 v2.11.3 h1:AfI0ngBoXJmYOpDh9m516vjqoUu2sLrIVgppI9TZVpg= github.com/panjf2000/ants/v2 v2.11.3/go.mod h1:8u92CYMUc6gyvTIw8Ru7Mt7+/ESnJahz5EVtqfrilek= -github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM= -github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs= github.com/pelletier/go-toml/v2 v2.2.4 h1:mye9XuhQ6gvn5h28+VilKrrPoQVanw5PMw/TB0t5Ec4= github.com/pelletier/go-toml/v2 v2.2.4/go.mod h1:2gIqNv+qfxSVS7cM2xJQKtLSTLUE9V8t9Stt+h56mCY= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= @@ -180,10 +147,6 @@ github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= github.com/rogpeppe/go-internal v1.14.1 h1:UQB4HGPB6osV0SQTLymcB4TgvyWu6ZyliaW0tI/otEQ= github.com/rogpeppe/go-internal v1.14.1/go.mod h1:MaRKkUm5W0goXpeCfT7UZI6fk/L7L7so1lCWt35ZSgc= -github.com/russross/blackfriday/v2 v2.1.0 h1:JIOH55/0cWyOuilr9/qlrm0BSXldqnqwMsf35Ld67mk= -github.com/russross/blackfriday/v2 v2.1.0/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM= -github.com/shurcooL/sanitized_anchor_name v1.0.0 h1:PdmoCO6wvbs+7yrJyMORt4/BmY5IYyJwS/kOiWx8mHo= -github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc= github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw= github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo= @@ -194,8 +157,6 @@ github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= -github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= -github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U= github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U= github.com/swaggo/files v1.0.1 h1:J1bVJ4XHZNq0I46UU90611i9/YzdrF7x92oX1ig5IdE= @@ -204,16 +165,12 @@ github.com/swaggo/gin-swagger v1.6.1 h1:Ri06G4gc9N4t4k8hekMigJ9zKTFSlqj/9paAQCQs github.com/swaggo/gin-swagger v1.6.1/go.mod h1:LQ+hJStHakCWRiK/YNYtJOu4mR2FP+pxLnILT/qNiTw= github.com/swaggo/swag v1.16.6 h1:qBNcx53ZaX+M5dxVyTrgQ0PJ/ACK+NzhwcbieTt+9yI= github.com/swaggo/swag v1.16.6/go.mod h1:ngP2etMK5a0P3QBizic5MEwpRmluJZPHjXcMoj4Xesg= +github.com/tarm/serial v0.0.0-20180830185346-98f6abe2eb07 h1:UyzmZLoiDWMRywV4DUYb9Fbt8uiOSooupjTq10vpvnU= +github.com/tarm/serial v0.0.0-20180830185346-98f6abe2eb07/go.mod h1:kDXzergiv9cbyO7IOYJZWg1U88JhDg3PB6klq9Hg2pA= github.com/twitchyliquid64/golang-asm v0.15.1 h1:SU5vSMR7hnwNxj24w34ZyCi/FmDZTkS4MhqMhdFk5YI= github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2+aY1QWCk3Cedj/Gdt08= -github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE= -github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg= github.com/ugorji/go/codec v1.3.0 h1:Qd2W2sQawAfG8XSvzwhBeoGq71zXOC/Q1E9y/wUcsUA= github.com/ugorji/go/codec v1.3.0/go.mod h1:pRBVtBSKl77K30Bv8R2P+cLSGaTtex6fsA2Wjqmfxj4= -github.com/urfave/cli/v2 v2.27.7 h1:bH59vdhbjLv3LAvIu6gd0usJHgoTTPhCFib8qqOwXYU= -github.com/urfave/cli/v2 v2.27.7/go.mod h1:CyNAG/xg+iAOg0N4MPGZqVmv2rCoP267496AOXUZjA4= -github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342 h1:FnBeRrxr7OU4VvAzt5X7s6266i6cSVkkFPS0TuXWbIg= -github.com/xrash/smetrics v0.0.0-20250705151800-55b8f293f342/go.mod h1:Ohn+xnUBiLI6FVj/9LpzZWtj1/D6lUovWYBkxHVV3aM= github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= go.mongodb.org/mongo-driver v1.14.0 h1:P98w8egYRjYe3XDjxhYJagTokP/H6HzlsnojRgZRd80= go.mongodb.org/mongo-driver v1.14.0/go.mod h1:Vzb0Mk/pa7e6cWw85R4F/endUC3u0U9jGcNU603k65c= @@ -231,36 +188,23 @@ go.uber.org/multierr v1.10.0 h1:S0h4aNzvfcFsC3dRF1jLoaov7oRaKqRGC/pUEJ2yvPQ= go.uber.org/multierr v1.10.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8= go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E= -go.yaml.in/yaml/v2 v2.4.3 h1:6gvOSjQoTB3vt1l+CU+tSyi/HOjfOjRLJ4YwYZGwRO0= -go.yaml.in/yaml/v2 v2.4.3/go.mod h1:zSxWcmIDjOzPXpjlTTbAsKokqkDNAVtZO0WOMiT90s8= -golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8= -golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc= -golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys= golang.org/x/arch v0.21.0 h1:iTC9o7+wP6cPWpDWkivCvQFGAHDQ59SrSxsLPcnkArw= golang.org/x/arch v0.21.0/go.mod h1:dNHoOeKiyja7GTvF9NJS1l3Z2yntpQNzgrjh1cU103A= golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w= golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc= -golang.org/x/crypto v0.36.0 h1:AnAEvhDddvBdpY+uR+MyHmuZzzNqXSe/GvuDeob5L34= -golang.org/x/crypto v0.36.0/go.mod h1:Y4J0ReaxCR1IMaabaSMugxJES1EpwhBHhv2bDHklZvc= golang.org/x/crypto v0.42.0 h1:chiH31gIWm57EkTXpwnqf8qeuMUi0yekh6mT2AvFlqI= golang.org/x/crypto v0.42.0/go.mod h1:4+rDnOTJhQCx2q7/j6rAN5XDw8kPjeaXEUR2eL94ix8= golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4/go.mod h1:jJ57K6gSWd91VN4djpZkiMVwK6gcyfeH4XE8wZrZaV4= -golang.org/x/mod v0.21.0 h1:vvrHzRwRfVKSiLrG+d4FMl/Qi4ukBCE6kZlTUkDYRT0= -golang.org/x/mod v0.21.0/go.mod h1:6SkKJ3Xj0I0BrPOZoBy3bdMptDDU9oJrpohJ3eWZ1fY= golang.org/x/mod v0.28.0 h1:gQBtGhjxykdjY9YhZpSlZIsbnaE2+PgjfLWUQTnoZ1U= golang.org/x/mod v0.28.0/go.mod h1:yfB/L0NOf/kmEbXjzCPOx1iK1fRutOydrCMsqRhEBxI= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= -golang.org/x/net v0.38.0 h1:vRMAPTMaeGqVhG5QyLJHqNDwecKTomGeqbnfZyKlBI8= -golang.org/x/net v0.38.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8= golang.org/x/net v0.44.0 h1:evd8IRDyfNBMBTTY5XRF1vaZlD+EmWx6x8PkhR04H/I= golang.org/x/net v0.44.0/go.mod h1:ECOoLqd5U3Lhyeyo/QDCEVQ4sNgYsqvCZ722XogGieY= golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM= -golang.org/x/sync v0.12.0 h1:MHc5BpPuC30uJk597Ri8TV3CNZcTLu6B6z4lJy+g6Jw= -golang.org/x/sync v0.12.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA= golang.org/x/sync v0.17.0 h1:l60nONMj9l5drqw6jlhIELNv9I0A4OFgRsG9k2oT9Ug= golang.org/x/sync v0.17.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= @@ -270,8 +214,6 @@ golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBc golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= -golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik= -golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= golang.org/x/sys v0.36.0 h1:KVRy2GtZBrk1cBYA7MKu5bEZFxQk4NIDV6RLVcC8o0k= golang.org/x/sys v0.36.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks= golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo= @@ -281,20 +223,14 @@ golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= -golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY= -golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4= golang.org/x/text v0.29.0 h1:1neNs90w9YzJ9BocxfsQNHKuAT4pkghyXc4nhZ6sJvk= golang.org/x/text v0.29.0/go.mod h1:7MhJOA9CD2qZyOKYazxdYMF85OwPdEr9jTtBpO7ydH4= golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ= golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo= golang.org/x/tools v0.1.12/go.mod h1:hNGJHUnrk76NpqgfD5Aqm5Crs+Hm0VOH/i9J2+nxYbc= -golang.org/x/tools v0.26.0 h1:v/60pFQmzmT9ExmjDv2gGIfi3OqfKoEP6I5+umXlbnQ= -golang.org/x/tools v0.26.0/go.mod h1:TPVVj70c7JJ3WCazhD8OdXcZg/og+b9+tH/KxylGwH0= golang.org/x/tools v0.37.0 h1:DVSRzp7FwePZW356yEAChSdNcQo6Nsp+fex1SUW09lE= golang.org/x/tools v0.37.0/go.mod h1:MBN5QPQtLMHVdvsbtarmTNukZDdgwdwlO5qGacAzF0w= golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0= -google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFWg= -google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= google.golang.org/protobuf v1.36.9 h1:w2gp2mA27hUeUzj9Ex9FBjsBm40zfaDtEWow293U7Iw= google.golang.org/protobuf v1.36.9/go.mod h1:fuxRtAxBytpl4zzqUh6/eyUujkJdNiuEkXntxiD/uRU= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= @@ -320,7 +256,3 @@ gorm.io/driver/sqlserver v1.6.0/go.mod h1:WQzt4IJo/WHKnckU9jXBLMJIVNMVeTu25dnOze gorm.io/gorm v1.25.7/go.mod h1:hbnx/Oo0ChWMn1BIhpy1oYozzpM15i4YPuHDmfYtwg8= gorm.io/gorm v1.30.5 h1:dvEfYwxL+i+xgCNSGGBT1lDjCzfELK8fHZxL3Ee9X0s= gorm.io/gorm v1.30.5/go.mod h1:8Z33v652h4//uMA76KjeDH8mJXPm1QNCYrMeatR0DOE= -nullprogram.com/x/optparse v1.0.0/go.mod h1:KdyPE+Igbe0jQUrVfMqDMeJQIJZEuyV7pjYmp6pbG50= -rsc.io/pdf v0.1.1/go.mod h1:n8OzWcQ6Sp37PL01nO98y4iUCRdTGarVfzxY20ICaU4= -sigs.k8s.io/yaml v1.6.0 h1:G8fkbMSAFqgEFgh4b1wmtzDnioxFCUgTZhlbj5P9QYs= -sigs.k8s.io/yaml v1.6.0/go.mod h1:796bPqUfzR/0jLAl6XjHl3Ck7MiyVv8dbTdyT3/pMf4= diff --git a/internal/app/webhook/chirp_stack.go b/internal/app/webhook/chirp_stack.go index 2f46263..7be960e 100644 --- a/internal/app/webhook/chirp_stack.go +++ b/internal/app/webhook/chirp_stack.go @@ -8,10 +8,10 @@ import ( "net/http" "time" - "git.huangwc.com/pig/pig-farm-controller/internal/domain/device/proto" "git.huangwc.com/pig/pig-farm-controller/internal/infra/logs" "git.huangwc.com/pig/pig-farm-controller/internal/infra/models" "git.huangwc.com/pig/pig-farm-controller/internal/infra/repository" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport/proto" gproto "google.golang.org/protobuf/proto" "gorm.io/datatypes" ) diff --git a/internal/app/webhook/placeholder_listener.go b/internal/app/webhook/placeholder_listener.go new file mode 100644 index 0000000..ffcf216 --- /dev/null +++ b/internal/app/webhook/placeholder_listener.go @@ -0,0 +1,30 @@ +package webhook + +import ( + "net/http" + + "git.huangwc.com/pig/pig-farm-controller/internal/infra/logs" +) + +// PlaceholderListener 是一个占位符, 用于在非 LoRaWAN 配置下满足 ListenHandler 接口 +type PlaceholderListener struct { + logger *logs.Logger +} + +// NewPlaceholderListener 创建一个新的 PlaceholderListener 实例 +// 它只打印一条日志, 表明 ChirpStack webhook 未被激活 +func NewPlaceholderListener(logger *logs.Logger) ListenHandler { + logger.Info("当前配置非 LoRaWAN, ChirpStack webhook 监听器未激活。") + return &PlaceholderListener{ + logger: logger, + } +} + +// Handler 返回一个不执行任何操作的 http.HandlerFunc +// 理论上, 在占位符生效的模式下, 这个 Handler 不应该被调用 +func (p *PlaceholderListener) Handler() http.HandlerFunc { + return func(w http.ResponseWriter, r *http.Request) { + p.logger.Warn("PlaceholderListener 的 Handler 被调用, 这通常是意料之外的。") + w.WriteHeader(http.StatusNotImplemented) + } +} diff --git a/internal/core/application.go b/internal/core/application.go index 25e596f..3658090 100644 --- a/internal/core/application.go +++ b/internal/core/application.go @@ -20,6 +20,7 @@ import ( "git.huangwc.com/pig/pig-farm-controller/internal/infra/logs" "git.huangwc.com/pig/pig-farm-controller/internal/infra/models" "git.huangwc.com/pig/pig-farm-controller/internal/infra/repository" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport" "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport/lora" ) @@ -37,6 +38,9 @@ type Application struct { executionLogRepo repository.ExecutionLogRepository pendingCollectionRepo repository.PendingCollectionRepository analysisPlanTaskManager *task.AnalysisPlanTaskManager + + // Lora Mesh 监听器 + loraMeshCommunicator transport.Listener } // NewApplication 创建并初始化一个新的 Application 实例。 @@ -98,15 +102,30 @@ func NewApplication(configPath string) (*Application, error) { // 初始化审计服务 auditService := audit.NewService(userActionLogRepo, logger) - // 初始化设备上行监听器 - listenHandler := webhook.NewChirpStackListener(logger, sensorDataRepo, deviceRepo, areaControllerRepo, deviceCommandLogRepo, pendingCollectionRepo) + // --- 初始化 LoRa 相关组件 --- + var listenHandler webhook.ListenHandler + var comm transport.Communicator + var loraListener transport.Listener + + if cfg.Lora.Mode == config.LoraMode_LoRaWAN { + logger.Info("当前运行模式: lora_wan。初始化 ChirpStack 监听器和传输层。") + listenHandler = webhook.NewChirpStackListener(logger, sensorDataRepo, deviceRepo, areaControllerRepo, deviceCommandLogRepo, pendingCollectionRepo) + comm = lora.NewChirpStackTransport(cfg.ChirpStack, logger) + loraListener = lora.NewPlaceholderTransport(logger) + } else { + logger.Info("当前运行模式: lora_mesh。初始化 LoRa Mesh 传输层和占位符监听器。") + listenHandler = webhook.NewPlaceholderListener(logger) + tp, err := lora.NewLoRaMeshUartPassthroughTransport(cfg.LoraMesh, logger, areaControllerRepo, pendingCollectionRepo, deviceRepo, sensorDataRepo) + loraListener = tp + comm = tp + if err != nil { + return nil, fmt.Errorf("无法初始化 LoRa Mesh 模块: %w", err) + } + } // 初始化计划触发器管理器 analysisPlanTaskManager := task.NewAnalysisPlanTaskManager(planRepo, pendingTaskRepo, executionLogRepo, logger) - // 初始化设备通信器 (纯粹的通信客户端) - comm := lora.NewChirpStackTransport(cfg.ChirpStack, logger) - // 初始化通用设备服务 generalDeviceService := device.NewGeneralDeviceService( deviceRepo, @@ -160,6 +179,7 @@ func NewApplication(configPath string) (*Application, error) { executionLogRepo: executionLogRepo, pendingCollectionRepo: pendingCollectionRepo, analysisPlanTaskManager: analysisPlanTaskManager, + loraMeshCommunicator: loraListener, } return app, nil @@ -169,6 +189,11 @@ func NewApplication(configPath string) (*Application, error) { func (app *Application) Start() error { app.Logger.Info("应用启动中...") + // -- 启动 LoRa Mesh 监听器 + if err := app.loraMeshCommunicator.Listen(); err != nil { + return fmt.Errorf("启动 LoRa Mesh 监听器失败: %w", err) + } + // --- 清理待采集任务 --- if err := app.initializePendingCollections(); err != nil { // 这是一个非致命错误，记录它，但应用应继续启动 @@ -216,6 +241,11 @@ func (app *Application) Stop() error { app.Logger.Errorw("数据库连接断开失败", "error", err) } + // 关闭 LoRa Mesh 监听器 + if err := app.loraMeshCommunicator.Stop(); err != nil { + app.Logger.Errorw("LoRa Mesh 监听器关闭失败", "error", err) + } + // 刷新日志缓冲区 _ = app.Logger.Sync() diff --git a/internal/domain/device/general_device_service.go b/internal/domain/device/general_device_service.go index 8fa2894..480ab98 100644 --- a/internal/domain/device/general_device_service.go +++ b/internal/domain/device/general_device_service.go @@ -5,11 +5,11 @@ import ( "fmt" "time" - "git.huangwc.com/pig/pig-farm-controller/internal/domain/device/proto" "git.huangwc.com/pig/pig-farm-controller/internal/infra/logs" "git.huangwc.com/pig/pig-farm-controller/internal/infra/models" "git.huangwc.com/pig/pig-farm-controller/internal/infra/repository" "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport/proto" "git.huangwc.com/pig/pig-farm-controller/internal/infra/utils/command_generater" "github.com/google/uuid" diff --git a/internal/infra/config/config.go b/internal/infra/config/config.go index 966f402..0fd56ff 100644 --- a/internal/infra/config/config.go +++ b/internal/infra/config/config.go @@ -136,18 +136,26 @@ type TaskConfig struct { NumWorkers int `yaml:"num_workers"` } +type LoraMode string + +const ( + LoraMode_LoRaWAN LoraMode = "lora_wan" + LoraMode_LoRaMesh LoraMode = "lora_mesh" +) + // LoraConfig 代表Lora配置 type LoraConfig struct { - Mode string `yaml:"mode"` + Mode LoraMode `yaml:"mode"` } // LoraMeshConfig 代表Lora Mesh配置 type LoraMeshConfig struct { - UARTPort string `yaml:"uart_port"` - BaudRate int `yaml:"baud_rate"` - Timeout int `yaml:"timeout"` - LoraMeshMode string `yaml:"lora_mesh_mode"` - MaxChunkSize int `yaml:"max_chunk_size"` + UARTPort string `yaml:"uart_port"` + BaudRate int `yaml:"baud_rate"` + Timeout int `yaml:"timeout"` + LoraMeshMode string `yaml:"lora_mesh_mode"` + MaxChunkSize int `yaml:"max_chunk_size"` + ReassemblyTimeout int `yaml:"reassembly_timeout"` } // NewConfig 创建并返回一个新的配置实例 diff --git a/internal/infra/transport/lora/lora_mesh_uart_passthrough_transport.go b/internal/infra/transport/lora/lora_mesh_uart_passthrough_transport.go new file mode 100644 index 0000000..3514634 --- /dev/null +++ b/internal/infra/transport/lora/lora_mesh_uart_passthrough_transport.go @@ -0,0 +1,545 @@ +package lora + +import ( + "bytes" + "encoding/binary" + "encoding/json" + "fmt" + "io" + "math" + "strconv" + "sync" + "time" + + "git.huangwc.com/pig/pig-farm-controller/internal/infra/config" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/logs" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/models" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/repository" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport/proto" + "github.com/google/uuid" + "github.com/tarm/serial" + gproto "google.golang.org/protobuf/proto" + "gorm.io/datatypes" +) + +// transportState 定义了传输层的内部状态 +type transportState int + +const ( + stateIdle transportState = iota // 空闲状态 + stateReceiving // 接收状态：正在接收一个（可能分片的）消息 + stateSending // 发送状态：正在发送一个（可能分片的）消息 +) + +// message 是一个内部结构，用于封装一个完整的、已重组的消息及其元数据 +type message struct { + SourceAddr string // 源地址 + DestAddr string // 目标地址 + Payload []byte // 有效载荷 +} + +// LoRaMeshUartPassthroughTransport 实现了 transport.Communicator 和 transport.Listener 接口 +type LoRaMeshUartPassthroughTransport struct { + config config.LoraMeshConfig + logger *logs.Logger + port *serial.Port + + mu sync.Mutex // 用于保护对外的公共方法（如Send）的并发调用 + state transportState + + stopChan chan struct{} // 用于优雅地停止worker协程 + wg sync.WaitGroup // 用于等待worker协程完全退出 + sendChan chan *sendRequest // 发送任务的请求通道 + + // --- 接收与重组相关 --- + reassemblyBuffers map[uint16]*reassemblyBuffer // 键为源地址SourceAddr，值为对应的重组缓冲区 + currentRecvSource uint16 // 当前正在接收的源地址 + reassemblyTimeout *time.Timer // 分片重组的超时定时器 + reassemblyTimeoutCh chan uint16 // 当超时触发时，用于传递源地址 + + // --- 依赖注入的仓库 --- + areaControllerRepo repository.AreaControllerRepository + pendingCollectionRepo repository.PendingCollectionRepository + deviceRepo repository.DeviceRepository + sensorDataRepo repository.SensorDataRepository +} + +// sendRequest 封装了一次发送请求 +type sendRequest struct { + address string + payload []byte + result chan *sendResultTuple +} + +// sendResultTuple 用于在通道中安全地传递Send方法的返回值 +type sendResultTuple struct { + result *transport.SendResult + err error +} + +// reassemblyBuffer 用于缓存和重组来自同一源的分片 +type reassemblyBuffer struct { + chunks map[uint8][]byte // 键为当前包序号CurrentChunk + totalChunks uint8 + receivedChunks int +} + +// NewLoRaMeshUartPassthroughTransport 创建一个新的 LoRaMeshUartPassthroughTransport 实例 +func NewLoRaMeshUartPassthroughTransport( + config config.LoraMeshConfig, + logger *logs.Logger, + areaControllerRepo repository.AreaControllerRepository, + pendingCollectionRepo repository.PendingCollectionRepository, + deviceRepo repository.DeviceRepository, + sensorDataRepo repository.SensorDataRepository, +) (*LoRaMeshUartPassthroughTransport, error) { + c := &serial.Config{ + Name: config.UARTPort, + Baud: config.BaudRate, + ReadTimeout: time.Millisecond * time.Duration(config.Timeout), + } + + port, err := serial.OpenPort(c) + if err != nil { + return nil, fmt.Errorf("无法打开串口 %s: %w", config.UARTPort, err) + } + + t := &LoRaMeshUartPassthroughTransport{ + config: config, + logger: logger, + port: port, + state: stateIdle, + stopChan: make(chan struct{}), + sendChan: make(chan *sendRequest), + reassemblyBuffers: make(map[uint16]*reassemblyBuffer), + reassemblyTimeoutCh: make(chan uint16, 1), + + // 注入依赖 + areaControllerRepo: areaControllerRepo, + pendingCollectionRepo: pendingCollectionRepo, + deviceRepo: deviceRepo, + sensorDataRepo: sensorDataRepo, + } + + return t, nil +} + +// Listen 启动后台监听协程（非阻塞） +func (t *LoRaMeshUartPassthroughTransport) Listen() error { + t.wg.Add(1) + go t.workerLoop() + t.logger.Info("LoRa传输层工作协程已启动") + return nil +} + +// Send 将发送任务提交给worker协程 +func (t *LoRaMeshUartPassthroughTransport) Send(address string, payload []byte) (*transport.SendResult, error) { + t.mu.Lock() + defer t.mu.Unlock() + + resultChan := make(chan *sendResultTuple, 1) + req := &sendRequest{ + address: address, + payload: payload, + result: resultChan, + } + + select { + case t.sendChan <- req: + // 等待worker协程处理完毕 + res := <-resultChan + return res.result, res.err + case <-t.stopChan: + return nil, fmt.Errorf("传输层正在停止") + } +} + +// Stop 停止传输层 +func (t *LoRaMeshUartPassthroughTransport) Stop() error { + close(t.stopChan) + t.wg.Wait() + return t.port.Close() +} + +// workerLoop 是核心的状态机和调度器 +func (t *LoRaMeshUartPassthroughTransport) workerLoop() { + defer t.wg.Done() + + readBuffer := make([]byte, 1024) + parserBuffer := new(bytes.Buffer) + + for { + // 1. 检查是否需要停止 (优先检查，以便快速退出) + select { + case <-t.stopChan: + if t.reassemblyTimeout != nil { + t.reassemblyTimeout.Stop() + } + t.logger.Info("LoRa传输层工作协程已停止") + return + default: + } + + // 2. 尝试从串口读取数据 + n, err := t.port.Read(readBuffer) + if n > 0 { + parserBuffer.Write(readBuffer[:n]) + } + if err != nil && err != io.EOF { + // 忽略预期的超时错误(io.EOF)，只记录真正的IO错误 + t.logger.Errorf("从串口读取数据时发生错误: %v", err) + } + + // 3. 循环解析缓冲区中的完整物理帧 + for { + frame := t.parseCompleteFrame(parserBuffer) + if frame == nil { + break // 缓冲区中没有更多完整帧了 + } + t.handleFrame(frame) + } + + // 4. 根据当前状态执行主要逻辑 + switch t.state { + case stateIdle: + t.runIdleState() + case stateReceiving: + t.runReceivingState() + } + } +} + +// runIdleState 处理空闲状态下的逻辑，主要是检查并启动发送任务 +func (t *LoRaMeshUartPassthroughTransport) runIdleState() { + select { + case req := <-t.sendChan: + t.state = stateSending + // 此处为阻塞式发送 + result, err := t.executeSend(req) + req.result <- &sendResultTuple{result: result, err: err} + t.state = stateIdle + default: + // 没有发送任务，保持空闲 + } +} + +// runReceivingState 处理接收状态下的逻辑，主要是检查超时 +func (t *LoRaMeshUartPassthroughTransport) runReceivingState() { + select { + case sourceAddr := <-t.reassemblyTimeoutCh: + t.logger.Warnf("接收来自 0x%04X 的消息超时", sourceAddr) + delete(t.reassemblyBuffers, sourceAddr) + t.state = stateIdle + default: + // 等待更多分片或超时 + } +} + +// executeSend 执行完整的发送流程（分片、构建、写入） +func (t *LoRaMeshUartPassthroughTransport) executeSend(req *sendRequest) (*transport.SendResult, error) { + chunks := splitPayload(req.payload, t.config.MaxChunkSize) + totalChunks := uint8(len(chunks)) + + destAddr, err := strconv.ParseUint(req.address, 16, 16) + if err != nil { + return nil, fmt.Errorf("无效的目标地址: %s", req.address) + } + + for i, chunk := range chunks { + currentChunk := uint8(i) + frame := new(bytes.Buffer) + frame.WriteByte(0xED) // 帧头 + frame.WriteByte(uint8(len(chunk) + 2)) // 数据长度 = 数据块 + 2 (总包数+当前包序号) + binary.Write(frame, binary.BigEndian, uint16(destAddr)) // 目标地址 + frame.WriteByte(totalChunks) // 总包数 + frame.WriteByte(currentChunk) // 当前包序号 + frame.Write(chunk) // 数据块 + + _, err := t.port.Write(frame.Bytes()) + if err != nil { + return nil, fmt.Errorf("写入串口失败: %w", err) + } + } + + msgID := uuid.New().String() + return &transport.SendResult{MessageID: msgID}, nil +} + +// handleFrame 处理一个从串口解析出的完整物理帧 +func (t *LoRaMeshUartPassthroughTransport) handleFrame(frame []byte) { + if len(frame) < 8 { + t.logger.Warnf("收到了一个无效长度的帧: %d", len(frame)) + return + } + + destAddr := binary.BigEndian.Uint16(frame[2:4]) + totalChunks := frame[4] + currentChunk := frame[5] + sourceAddr := binary.BigEndian.Uint16(frame[len(frame)-2:]) + chunkData := frame[6 : len(frame)-2] + + // 如果是单包消息 + if totalChunks == 1 { + msg := &message{ + SourceAddr: fmt.Sprintf("%04X", sourceAddr), + DestAddr: fmt.Sprintf("%04X", destAddr), + Payload: chunkData, + } + go t.handleUpstreamMessage(msg) + return + } + + // --- 处理分片消息 --- + switch t.state { + case stateIdle: + if currentChunk == 0 { + t.state = stateReceiving + t.currentRecvSource = sourceAddr + t.reassemblyBuffers[sourceAddr] = &reassemblyBuffer{ + chunks: make(map[uint8][]byte), + totalChunks: totalChunks, + receivedChunks: 0, + } + t.reassemblyBuffers[sourceAddr].chunks[currentChunk] = chunkData + t.reassemblyBuffers[sourceAddr].receivedChunks++ + + if t.reassemblyTimeout != nil { + t.reassemblyTimeout.Stop() + } + t.reassemblyTimeout = time.AfterFunc(time.Duration(t.config.ReassemblyTimeout)*time.Second, func() { + t.reassemblyTimeoutCh <- sourceAddr + }) + } else { + t.logger.Warnf("在空闲状态下收到了一个来自 0x%04X 的非首包分片，已忽略。", sourceAddr) + } + + case stateReceiving: + if sourceAddr != t.currentRecvSource { + t.logger.Warnf("正在接收来自 0x%04X 的数据时，收到了另一个源 0x%04X 的分片，已忽略。", t.currentRecvSource, sourceAddr) + return + } + + buffer, ok := t.reassemblyBuffers[sourceAddr] + if !ok { + t.logger.Errorf("内部错误: 处于接收状态，但没有为 0x%04X 找到缓冲区", sourceAddr) + t.state = stateIdle // 重置状态 + return + } + + // 存入分片并重置超时 + buffer.chunks[currentChunk] = chunkData + buffer.receivedChunks++ + t.reassemblyTimeout.Reset(time.Duration(t.config.ReassemblyTimeout) * time.Second) + + // 检查是否已全部收到 + if buffer.receivedChunks == int(buffer.totalChunks) { + t.reassemblyTimeout.Stop() + + // 重组消息 + fullPayload := new(bytes.Buffer) + for i := 0; i < int(buffer.totalChunks); i++ { + fullPayload.Write(buffer.chunks[uint8(i)]) + } + + msg := &message{ + SourceAddr: fmt.Sprintf("%04X", sourceAddr), + DestAddr: fmt.Sprintf("%04X", destAddr), + Payload: fullPayload.Bytes(), + } + go t.handleUpstreamMessage(msg) + + // 清理并返回空闲状态 + delete(t.reassemblyBuffers, sourceAddr) + t.state = stateIdle + } + } +} + +// handleUpstreamMessage 在独立的协程中处理单个上行的、完整的消息。 +func (t *LoRaMeshUartPassthroughTransport) handleUpstreamMessage(msg *message) { + t.logger.Infof("开始处理来自 %s 的上行消息", msg.SourceAddr) + + // 1. 解析外层 "信封" + var instruction proto.Instruction + if err := gproto.Unmarshal(msg.Payload, &instruction); err != nil { + t.logger.Errorf("解析上行 Instruction Protobuf 失败: %v, 源地址: %s, 原始数据: %x", err, msg.SourceAddr, msg.Payload) + return + } + + // 2. 使用 type switch 从 oneof payload 中提取 CollectResult + var collectResp *proto.CollectResult + switch p := instruction.GetPayload().(type) { + case *proto.Instruction_CollectResult: + collectResp = p.CollectResult + default: + // 如果上行的数据不是采集结果，记录日志并忽略 + t.logger.Infof("收到一个非采集响应的上行指令 (类型: %T)，无需处理。源地址: %s", p, msg.SourceAddr) + return + } + + if collectResp == nil { + t.logger.Errorf("从 Instruction 中提取的 CollectResult 为 nil。源地址: %s", msg.SourceAddr) + return + } + + correlationID := collectResp.CorrelationId + t.logger.Infof("成功解析采集响应 (CorrelationID: %s)，包含 %d 个值。", correlationID, len(collectResp.Values)) + + // 3. 查找区域主控 (注意：LoRa Mesh 的 SourceAddr 对应于区域主控的 NetworkID) + regionalController, err := t.areaControllerRepo.FindByNetworkID(msg.SourceAddr) + if err != nil { + t.logger.Errorf("处理上行消息失败：无法通过源地址 '%s' 找到区域主控设备: %v", msg.SourceAddr, err) + return + } + if err := regionalController.SelfCheck(); err != nil { + t.logger.Errorf("处理上行消息失败：区域主控 %v(ID: %d) 未通过自检: %v", regionalController.Name, regionalController.ID, err) + return + } + + // 4. 根据 CorrelationID 查找待处理请求 + pendingReq, err := t.pendingCollectionRepo.FindByCorrelationID(correlationID) + if err != nil { + t.logger.Errorf("处理采集响应失败：无法找到待处理请求 (CorrelationID: %s): %v", correlationID, err) + return + } + + // 检查状态，防止重复处理 + if pendingReq.Status != models.PendingStatusPending && pendingReq.Status != models.PendingStatusTimedOut { + t.logger.Warnf("收到一个已处理过的采集响应 (CorrelationID: %s, Status: %s)，将忽略。", correlationID, pendingReq.Status) + return + } + + // 5. 匹配数据并存入数据库 + deviceIDs := pendingReq.CommandMetadata + values := collectResp.Values + if len(deviceIDs) != len(values) { + t.logger.Errorf("数据不匹配：下行指令要求采集 %d 个设备，但上行响应包含 %d 个值 (CorrelationID: %s)", len(deviceIDs), len(values), correlationID) + err = t.pendingCollectionRepo.UpdateStatusToFulfilled(correlationID, time.Now()) + if err != nil { + t.logger.Errorf("处理采集响应失败：无法更新待处理请求 (CorrelationID: %s) 的状态为完成: %v", correlationID, err) + } + return + } + + for i, deviceID := range deviceIDs { + rawSensorValue := values[i] + + if math.IsNaN(float64(rawSensorValue)) { + t.logger.Warnf("设备 (ID: %d) 上报了一个无效的 NaN 值，已跳过当前值的记录。", deviceID) + continue + } + + dev, err := t.deviceRepo.FindByID(deviceID) + if err != nil { + t.logger.Errorf("处理采集数据失败：无法找到设备 (ID: %d): %v", deviceID, err) + continue + } + if err := dev.SelfCheck(); err != nil { + t.logger.Warnf("跳过设备 %d，因其未通过自检: %v", dev.ID, err) + continue + } + if err := dev.DeviceTemplate.SelfCheck(); err != nil { + t.logger.Warnf("跳过设备 %d，因其设备模板未通过自检: %v", dev.ID, err) + continue + } + + var valueDescriptors []*models.ValueDescriptor + if err := dev.DeviceTemplate.ParseValues(&valueDescriptors); err != nil { + t.logger.Warnf("跳过设备 %d，因其设备模板的 Values 属性解析失败: %v", dev.ID, err) + continue + } + if len(valueDescriptors) == 0 { + t.logger.Warnf("跳过设备 %d，因其设备模板缺少 ValueDescriptor 定义", dev.ID) + continue + } + valueDescriptor := valueDescriptors[0] + + parsedValue := float64(rawSensorValue)*valueDescriptor.Multiplier + valueDescriptor.Offset + + var dataToRecord interface{} + switch valueDescriptor.Type { + case models.SensorTypeTemperature: + dataToRecord = models.TemperatureData{TemperatureCelsius: parsedValue} + case models.SensorTypeHumidity: + dataToRecord = models.HumidityData{HumidityPercent: parsedValue} + case models.SensorTypeWeight: + dataToRecord = models.WeightData{WeightKilograms: parsedValue} + default: + t.logger.Warnf("未知的传感器类型 '%s'，将使用通用格式记录", valueDescriptor.Type) + dataToRecord = map[string]float64{"value": parsedValue} + } + + t.recordSensorData(regionalController.ID, dev.ID, time.Now(), valueDescriptor.Type, dataToRecord) + t.logger.Infof("成功记录传感器数据: 设备ID=%d, 类型=%s, 原始值=%f, 解析值=%.2f", dev.ID, valueDescriptor.Type, rawSensorValue, parsedValue) + } + + // 6. 更新请求状态为“已完成” + if err := t.pendingCollectionRepo.UpdateStatusToFulfilled(correlationID, time.Now()); err != nil { + t.logger.Errorf("更新待采集请求状态为 'fulfilled' 失败 (CorrelationID: %s): %v", correlationID, err) + } else { + t.logger.Infof("成功完成并关闭采集请求 (CorrelationID: %s)", correlationID) + } +} + +// recordSensorData 是一个通用方法，用于将传感器数据存入数据库。 +func (t *LoRaMeshUartPassthroughTransport) recordSensorData(regionalControllerID uint, sensorDeviceID uint, eventTime time.Time, sensorType models.SensorType, data interface{}) { + jsonData, err := json.Marshal(data) + if err != nil { + t.logger.Errorf("记录传感器数据失败：序列化数据为 JSON 时出错: %v", err) + return + } + + sensorData := &models.SensorData{ + Time: eventTime, + DeviceID: sensorDeviceID, + RegionalControllerID: regionalControllerID, + SensorType: sensorType, + Data: datatypes.JSON(jsonData), + } + + if err := t.sensorDataRepo.Create(sensorData); err != nil { + t.logger.Errorf("记录传感器数据失败：存入数据库时出错: %v", err) + } +} + +// parseCompleteFrame 实现粘包和半包处理 +func (t *LoRaMeshUartPassthroughTransport) parseCompleteFrame(buffer *bytes.Buffer) []byte { + for { + headerIndex := bytes.IndexByte(buffer.Bytes(), 0xED) + if headerIndex == -1 { + return nil + } + buffer.Next(headerIndex) + + if buffer.Len() < 2 { + return nil + } + + lengthField := buffer.Bytes()[1] + frameLength := 1 + 1 + 2 + int(lengthField) + 2 + + if buffer.Len() < frameLength { + return nil + } + + return buffer.Next(frameLength) + } +} + +// splitPayload 将数据块按最大长度进行切分 +func splitPayload(payload []byte, maxChunkSize int) [][]byte { + if len(payload) == 0 { + return [][]byte{{}} + } + + var chunks [][]byte + for i := 0; i < len(payload); i += maxChunkSize { + end := i + maxChunkSize + if end > len(payload) { + end = len(payload) + } + chunks = append(chunks, payload[i:end]) + } + return chunks +} diff --git a/internal/infra/transport/lora/placeholder_transport.go b/internal/infra/transport/lora/placeholder_transport.go new file mode 100644 index 0000000..967b0b9 --- /dev/null +++ b/internal/infra/transport/lora/placeholder_transport.go @@ -0,0 +1,27 @@ +package lora + +import ( + "git.huangwc.com/pig/pig-farm-controller/internal/infra/logs" + "git.huangwc.com/pig/pig-farm-controller/internal/infra/transport" +) + +type PlaceholderTransport struct { + logger *logs.Logger +} + +func NewPlaceholderTransport(logger *logs.Logger) transport.Listener { + logger.Info("当前配置非 LoRaMesh, LoRaMesh UART 透传传输器未激活。") + return &PlaceholderTransport{ + logger: logger, + } +} + +func (p *PlaceholderTransport) Listen() error { + p.logger.Warnf("当前不是LoRa Mesh 模式, 这只是个占位监听器") + return nil +} + +func (p *PlaceholderTransport) Stop() error { + p.logger.Warnf("当前不是LoRa Mesh 模式, 占位监听器停止工作") + return nil +} diff --git a/internal/domain/device/proto/device.pb.go b/internal/infra/transport/proto/device.pb.go similarity index 100% rename from internal/domain/device/proto/device.pb.go rename to internal/infra/transport/proto/device.pb.go diff --git a/internal/domain/device/proto/device.proto b/internal/infra/transport/proto/device.proto similarity index 100% rename from internal/domain/device/proto/device.proto rename to internal/infra/transport/proto/device.proto diff --git a/internal/infra/transport/transport.go b/internal/infra/transport/transport.go index 648aaeb..aee61a8 100644 --- a/internal/infra/transport/transport.go +++ b/internal/infra/transport/transport.go @@ -13,3 +13,12 @@ type SendResult struct { // 调用方需要保存此 ID，以便后续关联 ACK 等事件。 MessageID string } + +// Listener 用于监听其他设备发送过来的数据 +type Listener interface { + // Listen 用于开始监听其他设备发送过来的数据 + Listen() error + + // Stop 用于停止监听 + Stop() error +}