Skip to content

GitLab

S
speech_nlu_parse
Commit 099c71af authored by 赵文静's avatar 赵文静
Browse files
Options

对接思必驰

parent 7ac0726a
Hide whitespace changes
Inline Side-by-side
Showing with 1013 additions and 825 deletions
CHANGELOG.md
View file @ 099c71af
# 更新日志
## [v1.1.47] - 2025年2月24日20:25:28
### 新增
* 新增 local ip.
## [v1.1.46] - 2025年2月22日11:13:37
### 新增
* 新增 CGO_ENABLED=0 字段
## [v1.1.45] - 2025年2月21日15:56:07
### 新增
* 新增 log service 字段
## [v1.1.44-beta.1] - 2024年8月5日11:36:07
### 新增
* 新增 "gletkt_xlcj-1245258905417052160","ceshi-1149914105856290816","geliyoupingkongtiao-1289106967398617088","jhdpbxzswd-1364089899207012352","lxtest-1697504067777118921","lxtest-1697504245166677379","lchat-1736631343458063755" 的技能解析
## [v1.1.43-beta.28] - 2024年3月20日17:24:15
### 变更
* fm 细分码87654321 fm过滤m3u8 更改判断规则
## [v1.1.43-beta.27] - 2024年3月20日15:58:34
### 变更
* 腾讯切换正式环境
## [v1.1.43-beta.26] - 2024年3月20日10:47:31
### 变更
* 字段冲突 type更改为newsType
## [v1.1.43-beta.25] - 2024年3月4日16:44:11
### 删除
* 删除urltype判断逻辑
## [v1.1.43-beta.24] - 2024年3月4日15:57:55
### 变更
* appkey"a8814080829e11eda5c8e38bb1008e50" mid"10f05" 特殊处理同987654321设备一致
## [v1.1.43-beta.23] - 2024年3月4日15:15:19
### 变更
* appkey"a8814080829e11eda5c8e38bb1008e50" mid"10f05" 特殊处理同987654321设备一致
## [v1.1.43-beta.22] - 2024年2月1日17:17:05
### 修复
* 故事 title不存在则从selfData里找
## [v1.1.43-beta.21] - 2024年1月24日15:11:11
### 修复
* 旧版 修复闹钟不同步的问题
## [v1.1.43-beta.20] - 2024年1月10日15:06:14
### 变更
* 旧版 屏蔽音乐的"search_prev_song"意图
## [v1.1.43-beta.19] - 2023年12月22日10:04:48
### 变更
* 旧版 更改baike获取回复语的方式
### 新增
* 流式 新增mchat的解析
## [v1.1.43-beta.18] - 2023年11月30日14:31:38
### 新增
* 增加对提醒native command指令的支持
## [v1.1.43-beta.17] - 2023年11月29日09:56:13
### 新增
* 新增homeId
## [v1.1.43-beta.16] - 2023年11月28日10:39:22
### 新增
* tencentWs 接入闹钟提醒技能
* 修复mid mac 未赋值的问题
## [v1.1.43-beta.15] - 2023年11月23日11:15:13
### 变更
* OtherDomainWs 的回复语策略
## [v1.1.43-beta.14] - 2023年11月23日10:24:06
### 变更
* OtherDomainWs 的回复语策略
## [v1.1.43-beta.13] - 2023年11月23日10:24:06
### 变更
* OtherDomainWs 的回复语策略
## [v1.1.43-beta.12] - 2023年11月22日14:22:55
### 新增
* 增加技能解析
## [v1.1.43-beta.11] - 2023年11月16日10:54:44
### 新增
* 增加注释
## [v1.1.43-beta.10] - 2023年11月10日09:45:08
### 变更
* 直播类型链接过滤逻辑增加mid midType限制
## [v1.1.43-beta.9] - 2023年11月8日10:21:15
### 新增
* 增加直播类型链接的过滤逻辑, 过滤后资源列表为空时返回回复语"小格没有找到相关的资源哦"
## [v1.1.43-beta.8] - 2023年10月23日14:00:31
### 新增
* tencent wss 增加geography_kbqa general_question_answering htwhys_qa_pairs invention_qa_pairs 的解析
## [v1.1.43-beta.7] - 2023年10月23日14:00:31
### 变更
* tencent wss 增加language字段
## [v1.1.43-beta.6] - 2023年10月9日15:14:46
### 变更
* tencent wss 链接地址从consul env中获取
## [v1.1.43-beta.5] - 2023年10月9日14:05:08
### 变更
* tencent wss 链接地址从consul env中获取
## [v1.1.43-beta.4] - 2023年9月27日10:54:13
### 新增
* 新增 llm domain 的解析
## [v1.1.43-beta.3] - 2023年9月27日10:33:14
### 删除
* 去掉特殊处理(特殊处理部分设备切换到腾讯大语言模型bot)
## [v1.1.43-beta.2] - 2023年9月27日09:58:38
### 新增
* 特殊处理部分设备切换到腾讯大语言模型bot
## [v1.1.43-beta.1] - 2023年9月18日10:40:16
### 新增
* 腾讯流式接口 请求增加Location.City字段
* 增加RewrittenQuery字段
## [v1.1.42-beta.2] - 2023年9月18日10:40:16
### 修复
* search_ancientpoem_meaning responseText转义字符引发json解析错误
## [v1.1.42-beta.1] - 2023年9月13日14:51:14
### 修复
* search_ancientpoem_meaning responseText转义字符引发json解析错误
## [v1.1.41-beta.4] - 2023年8月3日14:08:56
### 修复
* 修复鉴权服务挂掉时引发的错误
## [v1.1.41-beta.3] - 2023年7月27日17:18:03
### 修复
* 修复鉴权服务挂掉时引发的错误
### 变更
* dmsdk status为1时也获取dsn
## [v1.1.41-beta.2] - 2023年7月27日11:03:12
### 变更
* 更改账号绑定\过期的提示话术
* 完善log输出
## [v1.1.41-beta.1] - 2023年7月26日15:37:48
### 变更
* 取消globalCtrl下'确定' '取消' 的协议转换
## [v1.1.40-beta.40] - 2023年6月29日14:11:48
### 变更
* SessionComplete字段缺失问题
## [v1.1.40-beta.39] - 2023年6月25日10:59:37
### 变更
* 查询闹钟和提醒时, 内容过多就进行截断, 按照句子截断
## [v1.1.40-beta.38] - 2023年6月21日15:24:46
### 变更
* 优化 日志字段
## [v1.1.40-beta.37] - 2023年6月21日11:51:00
### 新增
* 增加 腾讯wss 的接入方式
* 增加 流式grpc接口TencentNluParseStream
* 增加 日志字段
* 增加 readme对查票接口的说明
## [v1.1.40-beta.36] - 2023年6月16日16:10:43
### 变更
* 解决weather回复语带有转义字符导致json解析失败的问题
## [v1.1.40-beta.35] - 2023年6月16日11:28:26
### 变更
* 增加日志字段
* 增加help domain的解析, 使用固定的回复
## [v1.1.40-beta.34] - 2023年6月12日15:33:00
### 变更
* 增加日志字段
## [v1.1.40-beta.33] - 2023年6月12日14:17:00
### 变更
* 增加日志字段
## [v1.1.40-beta.32] - 2023年6月12日13:36:44
### 变更
* 增加日志字段
## [v1.1.40-beta.31] - 2023年6月12日10:48:21
### 变更
* 增加日志字段
* news 回复语修改
* tencentV2 票据字段的校验及默认字段
## [v1.1.40-beta.30] - 2023年6月5日10:46:46
### 变更
* 从环境变量读取腾讯的配置信息
## [v1.1.40-beta.29] - 2023年5月17日09:22:17
### 变更
* 删除音乐资源扩充的代码逻辑
## [v1.1.40-beta.28] - 2023年5月11日09:36:58
### 变更
* 音乐资源扩充到30首, 分组排序方便终端测试
## [v1.1.40-beta.27] - 2023年5月10日13:51:52
### 变更
* 音乐资源扩充到20首用于测试
## [v1.1.40-beta.26] - 2023年5月10日10:37:31
### 变更
* 音乐资源扩充到30首用于测试
* 增加音乐数目限制逻辑(mid非11011机型)
## [v1.1.40-beta.25] - 2023年5月9日17:18:10
### 变更
* dmsdk status==0时 使用其返回的appkey accessToken
## [v1.1.40-beta.24] - 2023年5月4日13:50:31
### 变更
* TokenSearch 使用增加mid vender字段查询dsn
## [v1.1.40-beta.23] - 2023年4月27日15:36:54
### 变更
* 腾讯v2 增加世界之最的解析
* 腾讯v2 古诗词鉴赏和意思, 拼接增加":"
## [v1.1.40-beta.22] - 2023年4月25日16:17:00
### 变更
* 腾讯v2 古诗domain中, 查询古诗含义, 查询古诗鉴赏, 拼接textContent 和 Text 进行返回
## [v1.1.40-beta.21] - 2023年4月24日13:59:24
### 变更
* 腾讯v2 增加mchat的解析
## [v1.1.40-beta.20] - 2023年4月19日11:16:51
### 变更
* 腾讯v2网关协议变更 auth字段放在http Header中
## [v1.1.40-beta.19] - 2023年4月14日11:27:34
### 变更
* 协议增加tRequestId字段
* 腾讯v2 增加requestid参数
## [v1.1.40-beta.18] - 2023年4月10日13:58:07
### 变更
* 腾讯v2 增加globalctrl3技能的解析
## [v1.1.40-beta.17] - 2023年4月4日17:18:55
### 变更
* 腾讯v2 不再填充guid字段
## [v1.1.40-beta.16] - 2023年4月4日15:42:13
### 新增
* 新增guid字段
## [v1.1.40-beta.15] - 2023年3月28日15:04:41
### 新增
* tencentV2 screen_control volumectrl3 music
### 修复
* tencentV2 guid的生成方式与旧接口的生成方式进行统一
## [v1.1.40-beta.14] - 2023年3月27日10:36:45
### 修复
* tencentV2 weather domain 的 text 校验
## [v1.1.40-beta.13] - 2023年3月27日10:03:54
### 修复
* tencentV2 weather domain 的 selfData 解析出错
## [v1.1.40-beta.12] - 2023年3月20日17:05:16
### 新增
* 增加鉴权信息字段, 腾讯v2 优先使用被传过来的鉴权信息
## [v1.1.40-beta.11] - 2023年3月17日09:06:01
### 修复
* 腾讯v2 newsdomain response_text 回复语过长, 替换成固定回复: "为你找到以下新闻:"
## [v1.1.40-beta.10] - 2023年3月16日17:24:16
### 修复
* 删除resType 字段的获取
## [v1.1.40-beta.9] - 2023年3月16日11:48:10
### 新增
* 腾讯v2接口 新增 Command字段透传
## [v1.1.40-beta.8] - 2023年3月15日15:44:38
### 新增
* 腾讯v2接口 新增 default domain
## [v1.1.40-beta.7] - 2023年3月15日15:24:10
### 变更
* 腾讯v2接口ip赋值更改为 Header X-Forwarded-For
## [v1.1.40-beta.6] - 2023年3月15日14:37:59
### 变更
* 细分码存在非十进制数字的情况, 将 midType 重命名为vender, 相关的proto协议及数据库表进行更新
## [v1.1.40-beta.5] - 2023年3月13日10:43:56
### 新增
* 增加服务发现没有找到对应服务的校验机制
### 变更
* weather 删除mid限制 删除selfData的返回
* chengyu 取消转为chat返回
## [v1.1.40-beta.4] - 2023年3月9日19:01:11
### 新增
* 模拟重定向
## [v1.1.40-beta.3] - 2023年3月3日08:49:51
### 新增
* 股票 星座 笑话 闲聊 体育 电台 古诗 新闻 节假日
## [v1.1.40-beta.2] - 2023年2月28日15:55:28
### 变更
* midAppKey 表增加midtype urltype字段, 读取进行兼容
* 请求协议增加midtype字段
* 增加新旧bot(接口)的访问逻辑, 指定的mid midtype(细分码)会访问新接口新bot
* 增加腾讯新接口的访问方式
* 新接口 天气 和 闲聊 技能的解析逻辑
## [v1.1.40-beta] - 2023年1月15日11:02:59
### 优化
* grpc请求增加 grpc.WithNoProxy()
## [v1.1.39] - 2023年1月12日11:08:53
### 修复
* 修复仅支持中英文翻译的判断逻辑
## [v1.1.38] - 2023年1月12日10:40:50
### 优化
* 变更consul服务信息获取方式
* 不再兼容从dmsk获取dsn的http接口
## [v1.1.37] - 2023年1月12日09:56:24
### 新增
* 增加middleware中间件对panic捕获
## [v1.1.36] - 2022年11月18日17:37:12
### 修复
* replyWithChat() response_text中含有特殊字符(\n)导致的解析错误问题
### 新增
* 对翻译语言进行了限制(测试)
## [v1.1.35] - 2022年10月28日10:23:16
### 变更
* newsDomain 取消replay_present不支持的回复语
## [v1.1.34] - 2022年10月21日11:14:33
### 修复
* poemDomain response_text中包含需转义的字符串导致json字符串无法加载的问题
## [v1.1.33] - 2022年10月14日14:19:37
### 变更
* poemDomain 对 "search_ancientpoem_meaning", "search_ancientpoem_appreciation", "search_ancientpoem_chains"意图 response_text进行拼接
## [v1.1.32] - 2022年9月14日19:17:35
### 变更
* poemDomain responst_text 为空时使用textContent
## [v1.1.31] - 2022年9月13日14:40:58
### 变更
* dislike的协议转换变更为next
## [v1.1.30] - 2022年9月5日09:31:12
### 修复
* fmDomain缺少mediaId
### 新增
* music 增加playmore dislike的协议转换
* poem 增加next的协议转换
* fm 增加playmore next prev 的协议转换
## [v1.1.29] - 2022年8月17日09:14:51
### 优化
* 优化consul client初始化方式
### 新增
* 增加对 globalctrl.turn_mid 协议转换
## [v1.1.28] - 2022年8月11日13:00:28
### 优化
* 优化通过consul获取host的方式
## [v1.1.27] - 2022年6月20日15:00:12
### 优化
* 天气技能 对内存不受限设备返回更多的天气数据
## [v1.0.15.1] - 2022年6月9日10:54:57
### 新增
- 天气技能 对无内存限制的设备返回更多的天气数据(vp柜机反馈缺少 温度，湿度，紫外线，七天天气数据，24小时温度数据)
### 说明
- tag v1.0.15 对应CHANGELOG.md文档中的 v1.0.9
- v1.0.15.1 表示在v1.0.15正式服版本基础上的修改
## [v1.1.26] - 2022年5月23日14:38:30
### 新增
* 天气技能 对有屏设备返回更多的天气数据(vp柜机反馈缺少 温度，湿度，紫外线，七天天气数据，24小时温度数据)
* config.yaml 配置文件 增加注释
## [v1.1.25] - 2022年5月23日10:17:48
### 优化
* 禅道 #64 对 music 下指定意图(pause pause_v2 next resume replay stop exit )进行协议转换
* 禅道 #71 对 fm 下指定意图(change)进行支持, 对指定意图(pause exit stop)进行协议转换
## [v1.1.24] - 2022年4月28日10:13:28
### 修复
* 未能从dmsdk查票服务获取到Appkey AccessToken 时 通过mid去查AppKey AccessToken
## [v1.1.23] - 2022年4月21日10:13:28
### 修复
* 更新docker file
## [v1.1.22] - 2022年4月19日10:13:28
### 修复
* 更新docker file
## [v1.1.21] - 2022年3月30日11:25:14
### 新增
* 请求叮当服务新增经纬度信息
## [v1.1.20] - 2022年3月25日15:26:40
### 新增
* 配置文件新增 11f06 10f05 相关的配置
### 修复
* 删除v1.1.18 "设备差异化的配置写死" 临时写死的逻辑
## [v1.1.19] - 2022年3月25日09:29:30
### 修复
* alarmDomain 返回字段格式问题
* 优化consul实时获取服务消息
## [v1.1.18] - 2022年3月22日17:38:36
### 新增
* 设备差异化的配置写死
### 修复
* 菜谱协议更改为listItems
* 优化http鉴权
## [v1.1.17] - 2022年3月4日15:11:00
### 新增
* dmsdk grpc服务不存在时则使用http接口获取鉴权dsn
* 实时从consul中获取服务信息
* 增加grpc recover中间件
## [v1.1.16] - 2022年3月4日15:11:00
### 修复
* globalctrl 协议转换, 修复错误字段origin->orgin
## [v1.1.15] - 2022年3月4日14:18:30
### 修复
* globalctrl 协议转换, turn_volume_to 分数 实体 转百分制数值
## [v1.1.10] - 时间
### 新增
* 接入grpc鉴权服务
### 修复
* 超时采用闲聊兜底
## [v1.0.10] - 2021年12月23日16:02:57
### 新增
* 增加"换一批歌曲"的解析
### 修复
* 修复无资源列表返回时不使用服务定义的激活提示回复语
## [v1.0.9] - 2021年11月26日15:27:50
### 新增
* 从配置文件读取测试音频的链接
## [v1.0.8] - 2021年11月11日15:21:34
### 修复
* 增加"声道测试"音频资源
## [v1.0.7] - 2021年11月8日16:23:53
### 修复
* 修复jokeDomain 资源列表为空的时造成的错误
## [v1.0.6] - 2021年10月27日10:03:47
### 修复
* 增加music next 的返回数据的合法检测, 当腾讯解析返回错误数据时进行兜底回复
## [v1.0.5] - 2021年10月19日14:03:45
### 修复
* 因腾讯问题返回jokeDomain资源列表为空时导致的数组越界问题
* alarmDomain 增加对ret字段的判断,不等于0是不进行闹钟的插入
### 新增
* mid 6400 及相应的appkey及token, 及相应的配置文件
```sql
INSERT INTO chatroom.mid_appkey
(idmid_appkey, mid, appkey, access_token, mode, uri_type, created_at, updated_at, deleted_at)
VALUES(101, '6400', 'd636a7e02d8111eca6607b3e5760da03', 'f4765fb437d342e2b4bdcf774db81882', 0, 0, '2021-10-15 15:56:45', NULL, NULL);
```
## [0.0.1-beta] - 2025.5.13
### Changed
- 对接思必驰
global/setting.go
View file @ 099c71af
......@@ -20,4 +20,5 @@ var (
ServiceSetting *setting.ServiceSettingS
ConsulObj *consul.ConsulObj
TencentGwSetting *setting.TencentGwSetting
SpeechSetting *setting.SpeechSettings
)
main.go
View file @ 099c71af
......@@ -125,7 +125,7 @@ func setupFlag() error {
flag.StringVar(&serverTag, "tag", "", "注册到注册中心的标签")
flag.StringVar(&ip, "ip", "", "IP")
flag.IntVar(&port, "port", 0, "端口")
flag.StringVar(&consulUrl, "consul", "http://172.28.124.105:8500", "consul服务地址")
flag.StringVar(&consulUrl, "consul", "http://172.28.124.106:8500", "consul服务地址")
flag.StringVar(&config, "config", "env/v2,speech_nlu_parse/conf", "指定要使用的配置文件路径")
flag.BoolVar(&isVersion, "version", false, "编译信息")
flag.StringVar(&consulToken, "token", "092288b5-824f-854c-39aa-a958afd9a633", "consul token")
......@@ -191,6 +191,10 @@ func setupSetting() error {
if err != nil {
return err
}
err = s.ReadSection("Speech", &global.SpeechSetting)
if err != nil {
return err
}
consulUrlParse, err := url.Parse(consulUrl)
if err != nil {
......
pkg/proto/alarm_remind_skill.pb.go 0 → 100644
View file @ 099c71af
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.30.0
// protoc v4.25.1
// source: pkg/proto/alarm_remind_skill.proto
package proto
import (
protoreflect "google.golang.org/protobuf/reflect/protoreflect"
protoimpl "google.golang.org/protobuf/runtime/protoimpl"
reflect "reflect"
sync "sync"
)
const (
// Verify that this generated code is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
// Verify that runtime/protoimpl is sufficiently up-to-date.
_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
type AlarmRemindSkillRequest struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AppInfo *AlarmRemindSkillRequest_AppInfo `protobuf:"bytes,1,opt,name=appInfo,proto3" json:"appInfo,omitempty"`
DevInfo *AlarmRemindSkillRequest_DevInfo `protobuf:"bytes,2,opt,name=devInfo,proto3" json:"devInfo,omitempty"`
UserInfo *AlarmRemindSkillRequest_UserInfo `protobuf:"bytes,3,opt,name=userInfo,proto3" json:"userInfo,omitempty"`
Command *AlarmRemindSkillRequest_Command `protobuf:"bytes,4,opt,name=command,proto3" json:"command,omitempty"`
AsrRecognize string `protobuf:"bytes,5,opt,name=asr_recognize,json=asrRecognize,proto3" json:"asr_recognize,omitempty"`
}
func (x *AlarmRemindSkillRequest) Reset() {
*x = AlarmRemindSkillRequest{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[0]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillRequest) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillRequest) ProtoMessage() {}
func (x *AlarmRemindSkillRequest) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[0]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillRequest.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillRequest) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{0}
}
func (x *AlarmRemindSkillRequest) GetAppInfo() *AlarmRemindSkillRequest_AppInfo {
if x != nil {
return x.AppInfo
}
return nil
}
func (x *AlarmRemindSkillRequest) GetDevInfo() *AlarmRemindSkillRequest_DevInfo {
if x != nil {
return x.DevInfo
}
return nil
}
func (x *AlarmRemindSkillRequest) GetUserInfo() *AlarmRemindSkillRequest_UserInfo {
if x != nil {
return x.UserInfo
}
return nil
}
func (x *AlarmRemindSkillRequest) GetCommand() *AlarmRemindSkillRequest_Command {
if x != nil {
return x.Command
}
return nil
}
func (x *AlarmRemindSkillRequest) GetAsrRecognize() string {
if x != nil {
return x.AsrRecognize
}
return ""
}
type AlarmRemindSkillResponse struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Status *AlarmRemindSkillResponse_Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}
func (x *AlarmRemindSkillResponse) Reset() {
*x = AlarmRemindSkillResponse{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[1]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillResponse) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillResponse) ProtoMessage() {}
func (x *AlarmRemindSkillResponse) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[1]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillResponse.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillResponse) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{1}
}
func (x *AlarmRemindSkillResponse) GetStatus() *AlarmRemindSkillResponse_Status {
if x != nil {
return x.Status
}
return nil
}
type AlarmRemindSkillRequest_AppInfo struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
AppId string `protobuf:"bytes,1,opt,name=appId,proto3" json:"appId,omitempty"`
RequestId string `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
}
func (x *AlarmRemindSkillRequest_AppInfo) Reset() {
*x = AlarmRemindSkillRequest_AppInfo{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[2]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillRequest_AppInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillRequest_AppInfo) ProtoMessage() {}
func (x *AlarmRemindSkillRequest_AppInfo) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[2]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillRequest_AppInfo.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillRequest_AppInfo) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{0, 0}
}
func (x *AlarmRemindSkillRequest_AppInfo) GetAppId() string {
if x != nil {
return x.AppId
}
return ""
}
func (x *AlarmRemindSkillRequest_AppInfo) GetRequestId() string {
if x != nil {
return x.RequestId
}
return ""
}
type AlarmRemindSkillRequest_UserInfo struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
Hid string `protobuf:"bytes,2,opt,name=hid,proto3" json:"hid,omitempty"`
}
func (x *AlarmRemindSkillRequest_UserInfo) Reset() {
*x = AlarmRemindSkillRequest_UserInfo{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[3]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillRequest_UserInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillRequest_UserInfo) ProtoMessage() {}
func (x *AlarmRemindSkillRequest_UserInfo) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[3]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillRequest_UserInfo.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillRequest_UserInfo) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{0, 1}
}
func (x *AlarmRemindSkillRequest_UserInfo) GetUid() string {
if x != nil {
return x.Uid
}
return ""
}
func (x *AlarmRemindSkillRequest_UserInfo) GetHid() string {
if x != nil {
return x.Hid
}
return ""
}
type AlarmRemindSkillRequest_DevInfo struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Mac string `protobuf:"bytes,1,opt,name=mac,proto3" json:"mac,omitempty"`
TarMac string `protobuf:"bytes,2,opt,name=tarMac,proto3" json:"tarMac,omitempty"`
}
func (x *AlarmRemindSkillRequest_DevInfo) Reset() {
*x = AlarmRemindSkillRequest_DevInfo{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[4]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillRequest_DevInfo) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillRequest_DevInfo) ProtoMessage() {}
func (x *AlarmRemindSkillRequest_DevInfo) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[4]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillRequest_DevInfo.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillRequest_DevInfo) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{0, 2}
}
func (x *AlarmRemindSkillRequest_DevInfo) GetMac() string {
if x != nil {
return x.Mac
}
return ""
}
func (x *AlarmRemindSkillRequest_DevInfo) GetTarMac() string {
if x != nil {
return x.TarMac
}
return ""
}
type AlarmRemindSkillRequest_Command struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Api string `protobuf:"bytes,1,opt,name=api,proto3" json:"api,omitempty"`
Repeat string `protobuf:"bytes,2,opt,name=repeat,proto3" json:"repeat,omitempty"`
Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Date string `protobuf:"bytes,4,opt,name=date,proto3" json:"date,omitempty"`
Time string `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
Event string `protobuf:"bytes,6,opt,name=event,proto3" json:"event,omitempty"`
Period string `protobuf:"bytes,7,opt,name=period,proto3" json:"period,omitempty"`
Object string `protobuf:"bytes,8,opt,name=object,proto3" json:"object,omitempty"` // 区分品类，闹钟/日程（提醒）
}
func (x *AlarmRemindSkillRequest_Command) Reset() {
*x = AlarmRemindSkillRequest_Command{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[5]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillRequest_Command) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillRequest_Command) ProtoMessage() {}
func (x *AlarmRemindSkillRequest_Command) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[5]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillRequest_Command.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillRequest_Command) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{0, 3}
}
func (x *AlarmRemindSkillRequest_Command) GetApi() string {
if x != nil {
return x.Api
}
return ""
}
func (x *AlarmRemindSkillRequest_Command) GetRepeat() string {
if x != nil {
return x.Repeat
}
return ""
}
func (x *AlarmRemindSkillRequest_Command) GetTimestamp() int64 {
if x != nil {
return x.Timestamp
}
return 0
}
func (x *AlarmRemindSkillRequest_Command) GetDate() string {
if x != nil {
return x.Date
}
return ""
}
func (x *AlarmRemindSkillRequest_Command) GetTime() string {
if x != nil {
return x.Time
}
return ""
}
func (x *AlarmRemindSkillRequest_Command) GetEvent() string {
if x != nil {
return x.Event
}
return ""
}
func (x *AlarmRemindSkillRequest_Command) GetPeriod() string {
if x != nil {
return x.Period
}
return ""
}
func (x *AlarmRemindSkillRequest_Command) GetObject() string {
if x != nil {
return x.Object
}
return ""
}
type AlarmRemindSkillResponse_Status struct {
state protoimpl.MessageState
sizeCache protoimpl.SizeCache
unknownFields protoimpl.UnknownFields
Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}
func (x *AlarmRemindSkillResponse_Status) Reset() {
*x = AlarmRemindSkillResponse_Status{}
if protoimpl.UnsafeEnabled {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[6]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
}
func (x *AlarmRemindSkillResponse_Status) String() string {
return protoimpl.X.MessageStringOf(x)
}
func (*AlarmRemindSkillResponse_Status) ProtoMessage() {}
func (x *AlarmRemindSkillResponse_Status) ProtoReflect() protoreflect.Message {
mi := &file_pkg_proto_alarm_remind_skill_proto_msgTypes[6]
if protoimpl.UnsafeEnabled && x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
ms.StoreMessageInfo(mi)
}
return ms
}
return mi.MessageOf(x)
}
// Deprecated: Use AlarmRemindSkillResponse_Status.ProtoReflect.Descriptor instead.
func (*AlarmRemindSkillResponse_Status) Descriptor() ([]byte, []int) {
return file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP(), []int{1, 0}
}
func (x *AlarmRemindSkillResponse_Status) GetCode() int32 {
if x != nil {
return x.Code
}
return 0
}
func (x *AlarmRemindSkillResponse_Status) GetMsg() string {
if x != nil {
return x.Msg
}
return ""
}
var File_pkg_proto_alarm_remind_skill_proto protoreflect.FileDescriptor
var file_pkg_proto_alarm_remind_skill_proto_rawDesc = []byte{
0x0a, 0x22, 0x70, 0x6b, 0x67, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x61, 0x6c, 0x61, 0x72,
0x6d, 0x5f, 0x72, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x5f, 0x73, 0x6b, 0x69, 0x6c, 0x6c, 0x2e, 0x70,
0x72, 0x6f, 0x74, 0x6f, 0x12, 0x05, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0xaf, 0x05, 0x0a, 0x17,
0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69, 0x6c, 0x6c,
0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x12, 0x40, 0x0a, 0x07, 0x61, 0x70, 0x70, 0x49, 0x6e,
0x66, 0x6f, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f,
0x2e, 0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69, 0x6c,
0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x41, 0x70, 0x70, 0x49, 0x6e, 0x66, 0x6f,
0x52, 0x07, 0x61, 0x70, 0x70, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x40, 0x0a, 0x07, 0x64, 0x65, 0x76,
0x49, 0x6e, 0x66, 0x6f, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x2e, 0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b,
0x69, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x44, 0x65, 0x76, 0x49, 0x6e,
0x66, 0x6f, 0x52, 0x07, 0x64, 0x65, 0x76, 0x49, 0x6e, 0x66, 0x6f, 0x12, 0x43, 0x0a, 0x08, 0x75,
0x73, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x18, 0x03, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x27, 0x2e,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e,
0x64, 0x53, 0x6b, 0x69, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74, 0x2e, 0x55, 0x73,
0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f, 0x52, 0x08, 0x75, 0x73, 0x65, 0x72, 0x49, 0x6e, 0x66, 0x6f,
0x12, 0x40, 0x0a, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28,
0x0b, 0x32, 0x26, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52,
0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69, 0x6c, 0x6c, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73,
0x74, 0x2e, 0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x52, 0x07, 0x63, 0x6f, 0x6d, 0x6d, 0x61,
0x6e, 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x61, 0x73, 0x72, 0x5f, 0x72, 0x65, 0x63, 0x6f, 0x67, 0x6e,
0x69, 0x7a, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x61, 0x73, 0x72, 0x52, 0x65,
0x63, 0x6f, 0x67, 0x6e, 0x69, 0x7a, 0x65, 0x1a, 0x3d, 0x0a, 0x07, 0x41, 0x70, 0x70, 0x49, 0x6e,
0x66, 0x6f, 0x12, 0x14, 0x0a, 0x05, 0x61, 0x70, 0x70, 0x49, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28,
0x09, 0x52, 0x05, 0x61, 0x70, 0x70, 0x49, 0x64, 0x12, 0x1c, 0x0a, 0x09, 0x72, 0x65, 0x71, 0x75,
0x65, 0x73, 0x74, 0x49, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x09, 0x72, 0x65, 0x71,
0x75, 0x65, 0x73, 0x74, 0x49, 0x64, 0x1a, 0x2e, 0x0a, 0x08, 0x55, 0x73, 0x65, 0x72, 0x49, 0x6e,
0x66, 0x6f, 0x12, 0x10, 0x0a, 0x03, 0x75, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
0x03, 0x75, 0x69, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x68, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28,
0x09, 0x52, 0x03, 0x68, 0x69, 0x64, 0x1a, 0x33, 0x0a, 0x07, 0x44, 0x65, 0x76, 0x49, 0x6e, 0x66,
0x6f, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x61, 0x63, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03,
0x6d, 0x61, 0x63, 0x12, 0x16, 0x0a, 0x06, 0x74, 0x61, 0x72, 0x4d, 0x61, 0x63, 0x18, 0x02, 0x20,
0x01, 0x28, 0x09, 0x52, 0x06, 0x74, 0x61, 0x72, 0x4d, 0x61, 0x63, 0x1a, 0xbf, 0x01, 0x0a, 0x07,
0x43, 0x6f, 0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x10, 0x0a, 0x03, 0x61, 0x70, 0x69, 0x18, 0x01,
0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x61, 0x70, 0x69, 0x12, 0x16, 0x0a, 0x06, 0x72, 0x65, 0x70,
0x65, 0x61, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x72, 0x65, 0x70, 0x65, 0x61,
0x74, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x03,
0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12,
0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x65, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x64,
0x61, 0x74, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28,
0x09, 0x52, 0x04, 0x74, 0x69, 0x6d, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74,
0x18, 0x06, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x65, 0x76, 0x65, 0x6e, 0x74, 0x12, 0x16, 0x0a,
0x06, 0x70, 0x65, 0x72, 0x69, 0x6f, 0x64, 0x18, 0x07, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x70,
0x65, 0x72, 0x69, 0x6f, 0x64, 0x12, 0x16, 0x0a, 0x06, 0x6f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x18,
0x08, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x6f, 0x62, 0x6a, 0x65, 0x63, 0x74, 0x22, 0x8a, 0x01,
0x0a, 0x18, 0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69,
0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x3e, 0x0a, 0x06, 0x73, 0x74,
0x61, 0x74, 0x75, 0x73, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x26, 0x2e, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x2e, 0x41, 0x6c, 0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b,
0x69, 0x6c, 0x6c, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x53, 0x74, 0x61, 0x74,
0x75, 0x73, 0x52, 0x06, 0x73, 0x74, 0x61, 0x74, 0x75, 0x73, 0x1a, 0x2e, 0x0a, 0x06, 0x53, 0x74,
0x61, 0x74, 0x75, 0x73, 0x12, 0x12, 0x0a, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x18, 0x01, 0x20, 0x01,
0x28, 0x05, 0x52, 0x04, 0x63, 0x6f, 0x64, 0x65, 0x12, 0x10, 0x0a, 0x03, 0x6d, 0x73, 0x67, 0x18,
0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x03, 0x6d, 0x73, 0x67, 0x32, 0x6a, 0x0a, 0x10, 0x41, 0x6c,
0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69, 0x6c, 0x6c, 0x12, 0x56,
0x0a, 0x13, 0x48, 0x61, 0x6e, 0x64, 0x6c, 0x65, 0x53, 0x70, 0x65, 0x65, 0x63, 0x68, 0x43, 0x6f,
0x6d, 0x6d, 0x61, 0x6e, 0x64, 0x12, 0x1e, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x41, 0x6c,
0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69, 0x6c, 0x6c, 0x52, 0x65,
0x71, 0x75, 0x65, 0x73, 0x74, 0x1a, 0x1f, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2e, 0x41, 0x6c,
0x61, 0x72, 0x6d, 0x52, 0x65, 0x6d, 0x69, 0x6e, 0x64, 0x53, 0x6b, 0x69, 0x6c, 0x6c, 0x52, 0x65,
0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x42, 0x13, 0x5a, 0x11, 0x2e, 0x2f, 0x70, 0x6b, 0x67, 0x2f,
0x70, 0x72, 0x6f, 0x74, 0x6f, 0x3b, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f,
0x74, 0x6f, 0x33,
}
var (
file_pkg_proto_alarm_remind_skill_proto_rawDescOnce sync.Once
file_pkg_proto_alarm_remind_skill_proto_rawDescData = file_pkg_proto_alarm_remind_skill_proto_rawDesc
)
func file_pkg_proto_alarm_remind_skill_proto_rawDescGZIP() []byte {
file_pkg_proto_alarm_remind_skill_proto_rawDescOnce.Do(func() {
file_pkg_proto_alarm_remind_skill_proto_rawDescData = protoimpl.X.CompressGZIP(file_pkg_proto_alarm_remind_skill_proto_rawDescData)
})
return file_pkg_proto_alarm_remind_skill_proto_rawDescData
}
var file_pkg_proto_alarm_remind_skill_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_pkg_proto_alarm_remind_skill_proto_goTypes = []interface{}{
(*AlarmRemindSkillRequest)(nil), // 0: proto.AlarmRemindSkillRequest
(*AlarmRemindSkillResponse)(nil), // 1: proto.AlarmRemindSkillResponse
(*AlarmRemindSkillRequest_AppInfo)(nil), // 2: proto.AlarmRemindSkillRequest.AppInfo
(*AlarmRemindSkillRequest_UserInfo)(nil), // 3: proto.AlarmRemindSkillRequest.UserInfo
(*AlarmRemindSkillRequest_DevInfo)(nil), // 4: proto.AlarmRemindSkillRequest.DevInfo
(*AlarmRemindSkillRequest_Command)(nil), // 5: proto.AlarmRemindSkillRequest.Command
(*AlarmRemindSkillResponse_Status)(nil), // 6: proto.AlarmRemindSkillResponse.Status
}
var file_pkg_proto_alarm_remind_skill_proto_depIdxs = []int32{
2, // 0: proto.AlarmRemindSkillRequest.appInfo:type_name -> proto.AlarmRemindSkillRequest.AppInfo
4, // 1: proto.AlarmRemindSkillRequest.devInfo:type_name -> proto.AlarmRemindSkillRequest.DevInfo
3, // 2: proto.AlarmRemindSkillRequest.userInfo:type_name -> proto.AlarmRemindSkillRequest.UserInfo
5, // 3: proto.AlarmRemindSkillRequest.command:type_name -> proto.AlarmRemindSkillRequest.Command
6, // 4: proto.AlarmRemindSkillResponse.status:type_name -> proto.AlarmRemindSkillResponse.Status
0, // 5: proto.AlarmRemindSkill.HandleSpeechCommand:input_type -> proto.AlarmRemindSkillRequest
1, // 6: proto.AlarmRemindSkill.HandleSpeechCommand:output_type -> proto.AlarmRemindSkillResponse
6, // [6:7] is the sub-list for method output_type
5, // [5:6] is the sub-list for method input_type
5, // [5:5] is the sub-list for extension type_name
5, // [5:5] is the sub-list for extension extendee
0, // [0:5] is the sub-list for field type_name
}
func init() { file_pkg_proto_alarm_remind_skill_proto_init() }
func file_pkg_proto_alarm_remind_skill_proto_init() {
if File_pkg_proto_alarm_remind_skill_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_pkg_proto_alarm_remind_skill_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pkg_proto_alarm_remind_skill_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pkg_proto_alarm_remind_skill_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillRequest_AppInfo); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pkg_proto_alarm_remind_skill_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillRequest_UserInfo); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pkg_proto_alarm_remind_skill_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillRequest_DevInfo); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pkg_proto_alarm_remind_skill_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillRequest_Command); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_pkg_proto_alarm_remind_skill_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*AlarmRemindSkillResponse_Status); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_pkg_proto_alarm_remind_skill_proto_rawDesc,
NumEnums: 0,
NumMessages: 7,
NumExtensions: 0,
NumServices: 1,
},
GoTypes: file_pkg_proto_alarm_remind_skill_proto_goTypes,
DependencyIndexes: file_pkg_proto_alarm_remind_skill_proto_depIdxs,
MessageInfos: file_pkg_proto_alarm_remind_skill_proto_msgTypes,
}.Build()
File_pkg_proto_alarm_remind_skill_proto = out.File
file_pkg_proto_alarm_remind_skill_proto_rawDesc = nil
file_pkg_proto_alarm_remind_skill_proto_goTypes = nil
file_pkg_proto_alarm_remind_skill_proto_depIdxs = nil
}
pkg/proto/alarm_remind_skill.proto 0 → 100644
View file @ 099c71af
syntax = "proto3";
package proto; //新增一个可选的package声明符，用来防止不同的消息类型有命名冲突
option go_package = "./pkg/proto;proto"; //这个选项表明生成go结构体所在的包
message AlarmRemindSkillRequest{
message AppInfo {
string appId = 1;
string requestId = 2;
}
message UserInfo {
string uid = 1;
string hid = 2;
}
message DevInfo {
string mac = 1;
string tarMac = 2;
}
AppInfo appInfo = 1;
DevInfo devInfo = 2;
UserInfo userInfo = 3;
message Command {
string api = 1;
string repeat = 2;
int64 timestamp = 3;
string date = 4;
string time = 5;
string event = 6;
string period = 7;
string object = 8; // 区分品类，闹钟/日程（提醒）
}
Command command = 4;
string asr_recognize = 5;
}
message AlarmRemindSkillResponse{
message Status {
int32 code = 1;
string msg = 2;
}
Status status = 1;
}
service AlarmRemindSkill {
rpc HandleSpeechCommand (AlarmRemindSkillRequest) returns (AlarmRemindSkillResponse);
}
\ No newline at end of file
pkg/proto/alarm_remind_skill_grpc.pb.go 0 → 100644
View file @ 099c71af
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc v4.25.1
// source: pkg/proto/alarm_remind_skill.proto
package proto
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
const (
AlarmRemindSkill_HandleSpeechCommand_FullMethodName = "/proto.AlarmRemindSkill/HandleSpeechCommand"
)
// AlarmRemindSkillClient is the client API for AlarmRemindSkill service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type AlarmRemindSkillClient interface {
HandleSpeechCommand(ctx context.Context, in *AlarmRemindSkillRequest, opts ...grpc.CallOption) (*AlarmRemindSkillResponse, error)
}
type alarmRemindSkillClient struct {
cc grpc.ClientConnInterface
}
func NewAlarmRemindSkillClient(cc grpc.ClientConnInterface) AlarmRemindSkillClient {
return &alarmRemindSkillClient{cc}
}
func (c *alarmRemindSkillClient) HandleSpeechCommand(ctx context.Context, in *AlarmRemindSkillRequest, opts ...grpc.CallOption) (*AlarmRemindSkillResponse, error) {
out := new(AlarmRemindSkillResponse)
err := c.cc.Invoke(ctx, AlarmRemindSkill_HandleSpeechCommand_FullMethodName, in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// AlarmRemindSkillServer is the server API for AlarmRemindSkill service.
// All implementations must embed UnimplementedAlarmRemindSkillServer
// for forward compatibility
type AlarmRemindSkillServer interface {
HandleSpeechCommand(context.Context, *AlarmRemindSkillRequest) (*AlarmRemindSkillResponse, error)
mustEmbedUnimplementedAlarmRemindSkillServer()
}
// UnimplementedAlarmRemindSkillServer must be embedded to have forward compatible implementations.
type UnimplementedAlarmRemindSkillServer struct {
}
func (UnimplementedAlarmRemindSkillServer) HandleSpeechCommand(context.Context, *AlarmRemindSkillRequest) (*AlarmRemindSkillResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method HandleSpeechCommand not implemented")
}
func (UnimplementedAlarmRemindSkillServer) mustEmbedUnimplementedAlarmRemindSkillServer() {}
// UnsafeAlarmRemindSkillServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to AlarmRemindSkillServer will
// result in compilation errors.
type UnsafeAlarmRemindSkillServer interface {
mustEmbedUnimplementedAlarmRemindSkillServer()
}
func RegisterAlarmRemindSkillServer(s grpc.ServiceRegistrar, srv AlarmRemindSkillServer) {
s.RegisterService(&AlarmRemindSkill_ServiceDesc, srv)
}
func _AlarmRemindSkill_HandleSpeechCommand_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(AlarmRemindSkillRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(AlarmRemindSkillServer).HandleSpeechCommand(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: AlarmRemindSkill_HandleSpeechCommand_FullMethodName,
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(AlarmRemindSkillServer).HandleSpeechCommand(ctx, req.(*AlarmRemindSkillRequest))
}
return interceptor(ctx, in, info, handler)
}
// AlarmRemindSkill_ServiceDesc is the grpc.ServiceDesc for AlarmRemindSkill service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var AlarmRemindSkill_ServiceDesc = grpc.ServiceDesc{
ServiceName: "proto.AlarmRemindSkill",
HandlerType: (*AlarmRemindSkillServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "HandleSpeechCommand",
Handler: _AlarmRemindSkill_HandleSpeechCommand_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "pkg/proto/alarm_remind_skill.proto",
}
pkg/setting/section.go
View file @ 099c71af
......@@ -90,6 +90,12 @@ type TencentGwSetting struct {
}
}
type SpeechSettings struct {
ProductId string
ApiKey string
Url string
}
func (s *Setting) ReadSection(k string, v interface{}) error {
return s.vp.UnmarshalKey(k, v)
}
service/connect/find_grpc.go
View file @ 099c71af
......@@ -28,16 +28,22 @@ func GrpcConn(serverName string) (*grpc.ClientConn, error) {
// 通过 Consul 客户端查询服务实例
consulConfig := api.DefaultConfig()
consulConfig.Address = global.ServerSetting.ConsulAddr
client, _ := api.NewClient(consulConfig)
client, err := api.NewClient(consulConfig)
if err != nil {
return nil, fmt.Errorf("consul client init failed: %v", err)
}
entries, _, _ := client.Health().Service(serverName, "", true, nil)
// 健康实例检查
if len(entries) == 0 {
return nil, fmt.Errorf("no available instances for service [%s]", serverName)
}
// 获取第一个健康实例的地址
targetAddr := fmt.Sprintf("%s:%d",
entries[0].Service.Address,
entries[0].Service.Port)
//target := fmt.Sprintf("consul://%s/%s", global.ConsulAddr, serverName)
//fmt.Println("1111123132131312")
fmt.Println(targetAddr)
opts := []grpc.DialOption{
//grpc.WithBlock(), //阻塞连接直到成功或超时，存在缺陷
......@@ -45,7 +51,6 @@ func GrpcConn(serverName string) (*grpc.ClientConn, error) {
grpc.WithDefaultServiceConfig(fmt.Sprintf(`{"LoadBalancingPolicy": "%s"}`, roundrobin.Name)), // 设置默认的负载均衡策略
}
var err error
conn, err := grpc.DialContext(ctx, targetAddr, opts...)
if err != nil {
return nil, err
......
service/speechNlu/constant.go
View file @ 099c71af
......@@ -84,6 +84,7 @@ const (
PlayCTRL = "播放控制"
MUSIC = "音乐"
HELP = "产品形象"
STORY = "故事"
HOLIDAY = "holiday"
SOUND = "sound"
......
service/speechNlu/domain.go
View file @ 099c71af
......@@ -5,14 +5,12 @@ import (
"errors"
"fmt"
"regexp"
"speech-nlu-parse/dao"
"speech-nlu-parse/global"
"speech-nlu-parse/model"
"speech-nlu-parse/pkg/logger"
"speech-nlu-parse/service/connect"
"strconv"
"strings"
"time"
)
const (
......@@ -330,105 +328,107 @@ type AlarmItem struct {
// 闹钟待写
func alarmDomain(params *model.SpeechDomainParams) []byte {
mac := params.Mac
if !params.CheckDm() || !params.CheckDmParam() {
return replyWithChat(error_reply, "doudi")
}
var result model.ResponseBody
result.Header.Semantic.Code = 0
result.Header.Semantic.Msg = speech_nlu_parse
result.Header.Semantic.SessionComplete = params.SpeechWsResp.Dm.ShouldEndSession
//mac := params.Mac
//
//if !params.CheckDm() || !params.CheckDmParam() {
// return replyWithChat(error_reply, "doudi")
//}
//
//var result model.ResponseBody
//result.Header.Semantic.Code = 0
//result.Header.Semantic.Msg = speech_nlu_parse
//result.Header.Semantic.SessionComplete = params.SpeechWsResp.Dm.ShouldEndSession
////result.Header.Semantic.SkillId = result.Header.Semantic.Domain + "." + result.Header.Semantic.Intent
//result.AsrRecongize = params.SpeechWsResp.Dm.Input
//
//var alarmDBData model.AlarmRemindInfo
//alarmDBData.Mac = params.Mac
//alarmDBData.Note = ""
//alarmDBData.URL = ""
//alarmDBData.Speech_Type = onlyTTS
//alarmDBData.Createtime = time.Now().String()[:19]
////items := ""
//contentTTS := ""
//
//if params.SpeechWsResp.Dm.Param.Object == "闹钟" {
// alarmDBData.E_type = alarm
// result.Header.Semantic.Domain = "alarm"
//} else {
// alarmDBData.E_type = remind
// result.Header.Semantic.Domain = "reminder_v2"
// if !params.CheckEvent() {
// contentTTS = alarm_remind_common + params.SpeechWsResp.Dm.Param.Event
// } else {
// contentTTS = alarm_remind_raw
// }
// alarmDBData.Note = contentTTS
//}
//fmt.Println(contentTTS)
//
//if params.SpeechWsResp.Dm.Api == "DUI.Alerts.SetAlert" {
// result.Header.Semantic.Intent = "new"
// if !params.CheckDate() {
// global.Logger.WithFields(logger.Fields{
// "requestId": params.RequestId,
// "mac": params.Mac,
// "mid": params.Mid,
// "vender": params.MidType}).Error("params.CheckDate() error")
// return replyWithChat(error_reply, "doudi")
// } else {
// //如果日期存在
// t, err := time.Parse("20060102", params.SpeechWsResp.Dm.Param.Date)
// if err != nil {
// global.Logger.WithFields(logger.Fields{
// "requestId": params.RequestId,
// "mac": params.Mac,
// "mid": params.Mid,
// "vender": params.MidType}).Error(err.Error())
// return replyWithChat(error_reply, "doudi")
// }
//
// // 将日期转换为目标格式
// formatted := t.Format("2006-01-02")
// alarmDBData.E_date = formatted
// //获得时间
// alarmDBData.E_time = params.SpeechWsResp.Dm.Param.Time
// }
//
// if !params.CheckRepeat() {
// alarmDBData.Repeat_type = 1
// } else if params.SpeechWsResp.Dm.Param.Repeat == "W1W2W3W4W5W6W7" {
// alarmDBData.Repeat_type = 2
// } else if params.SpeechWsResp.Dm.Param.Repeat == "W1W2W3W4W5" {
// alarmDBData.Repeat_type = 5
// } else if strings.Contains(strings.ToLower(params.SpeechWsResp.Dm.Param.Repeat), "M") {
// alarmDBData.Repeat_type = 4
// } else if strings.Contains(strings.ToLower(params.SpeechWsResp.Dm.Param.Repeat), "W") {
// alarmDBData.Repeat_type = 3
// //每周几待写
// }
// dao.SaveAlarmRemindData(alarmDBData)
// if params.SpeechWsResp.Dm.Nlg != "" {
// result.ResponseText = params.SpeechWsResp.Dm.Nlg
// } else {
// result.ResponseText = "已经设置好了"
// }
//
//} else if params.SpeechWsResp.Dm.Api == "DUI.Alerts.QueryAlert" {
// result.Header.Semantic.Intent = "check"
// dao.DeleteOverdueAlarmRemindData(mac)
//
//} else if params.SpeechWsResp.Dm.Api == "DUI.Alerts.DeleteAlert" {
// result.Header.Semantic.Intent = "delete"
//}
//
//result.Header.Semantic.SkillId = result.Header.Semantic.Domain + "." + result.Header.Semantic.Intent
result.AsrRecongize = params.SpeechWsResp.Dm.Input
var alarmDBData model.AlarmRemindInfo
alarmDBData.Mac = params.Mac
alarmDBData.Note = ""
alarmDBData.URL = ""
alarmDBData.Speech_Type = onlyTTS
alarmDBData.Createtime = time.Now().String()[:19]
//items := ""
contentTTS := ""
if params.SpeechWsResp.Dm.Param.Object == "闹钟" {
alarmDBData.E_type = alarm
result.Header.Semantic.Domain = "alarm"
} else {
alarmDBData.E_type = remind
result.Header.Semantic.Domain = "reminder_v2"
if !params.CheckEvent() {
contentTTS = alarm_remind_common + params.SpeechWsResp.Dm.Param.Event
} else {
contentTTS = alarm_remind_raw
}
alarmDBData.Note = contentTTS
}
fmt.Println(contentTTS)
if params.SpeechWsResp.Dm.Api == "DUI.Alerts.SetAlert" {
result.Header.Semantic.Intent = "new"
if !params.CheckDate() {
global.Logger.WithFields(logger.Fields{
"requestId": params.RequestId,
"mac": params.Mac,
"mid": params.Mid,
"vender": params.MidType}).Error("params.CheckDate() error")
return replyWithChat(error_reply, "doudi")
} else {
//如果日期存在
t, err := time.Parse("20060102", params.SpeechWsResp.Dm.Param.Date)
if err != nil {
global.Logger.WithFields(logger.Fields{
"requestId": params.RequestId,
"mac": params.Mac,
"mid": params.Mid,
"vender": params.MidType}).Error(err.Error())
return replyWithChat(error_reply, "doudi")
}
// 将日期转换为目标格式
formatted := t.Format("2006-01-02")
alarmDBData.E_date = formatted
//获得时间
alarmDBData.E_time = params.SpeechWsResp.Dm.Param.Time
}
if !params.CheckRepeat() {
alarmDBData.Repeat_type = 1
} else if params.SpeechWsResp.Dm.Param.Repeat == "W1W2W3W4W5W6W7" {
alarmDBData.Repeat_type = 2
} else if params.SpeechWsResp.Dm.Param.Repeat == "W1W2W3W4W5" {
alarmDBData.Repeat_type = 5
} else if strings.Contains(strings.ToLower(params.SpeechWsResp.Dm.Param.Repeat), "M") {
alarmDBData.Repeat_type = 4
} else if strings.Contains(strings.ToLower(params.SpeechWsResp.Dm.Param.Repeat), "W") {
alarmDBData.Repeat_type = 3
//每周几待写
}
dao.SaveAlarmRemindData(alarmDBData)
if params.SpeechWsResp.Dm.Nlg != "" {
result.ResponseText = params.SpeechWsResp.Dm.Nlg
} else {
result.ResponseText = "已经设置好了"
}
} else if params.SpeechWsResp.Dm.Api == "DUI.Alerts.QueryAlert" {
result.Header.Semantic.Intent = "check"
dao.DeleteOverdueAlarmRemindData(mac)
} else if params.SpeechWsResp.Dm.Api == "DUI.Alerts.DeleteAlert" {
result.Header.Semantic.Intent = "delete"
}
result.Header.Semantic.SkillId = result.Header.Semantic.Domain + "." + result.Header.Semantic.Intent
if !alarmDevFilter(params) {
return Marshal(params, &result)
}
return Marshal(params, &result)
//
//if !alarmDevFilter(params) {
// return Marshal(params, &result)
//}
//
//return Marshal(params, &result)
resultTextStr := "暂不支持闹钟设定"
return replyWithChat(resultTextStr, "chat.chat")
}
func scienceDomain(params *model.SpeechDomainParams) []byte {
......@@ -512,6 +512,9 @@ func fmDomain(params *model.SpeechDomainParams) []byte {
"mid": params.Mid,
"vender": params.MidType,
}).Error("params.SpeechWsResp.Dm.Widget.Content不是数组类型")
if res.ResponseText != "" {
return replyWithChat(res.ResponseText, "doudi")
}
return replyWithChat(error_reply, "doudi")
}
......@@ -667,7 +670,7 @@ func musicDomain(params *model.SpeechDomainParams) []byte {
result.Header.Semantic.Msg = speech_nlu_parse
result.Header.Semantic.SessionComplete = params.SpeechWsResp.Dm.ShouldEndSession
result.Header.Semantic.SkillId = result.Header.Semantic.Domain + "." + result.Header.Semantic.Intent
result.ResponseText = params.SpeechWsResp.Dm.Nlg
//result.ResponseText = "以下音乐由网易云提供：" //params.SpeechWsResp.Dm.Nlg
result.AsrRecongize = params.SpeechWsResp.Dm.Input
result.ListItems = make([]map[string]interface{}, 0)
if len(list.Data.ListItems) > 0 {
......@@ -678,6 +681,9 @@ func musicDomain(params *model.SpeechDomainParams) []byte {
"song": list.Data.ListItems[i].Song,
})
}
result.ResponseText = "以下音乐由网易云提供：" //params.SpeechWsResp.Dm.Nlg
} else {
return otherDomain(params)
}
return Marshal(params, &result)
}
......
service/speechNlu/register.go
View file @ 099c71af
......@@ -44,6 +44,7 @@ func register() {
DomainRegister(PlayCTRL, playCtrlDomain)
DomainRegister(MUSIC, musicDomain)
DomainRegister(HELP, helpDomain)
DomainRegister(STORY, fmDomain)
//
//DomainRegisterV2(CHAT, chatDomainV2)
......
service/speechNlu/speech.go
View file @ 099c71af
......@@ -8,6 +8,7 @@ import (
"speech-nlu-parse/global"
"speech-nlu-parse/model"
"speech-nlu-parse/pkg/errCode"
"speech-nlu-parse/pkg/logger"
"sync"
"time"
)
......@@ -49,8 +50,6 @@ func SpeechNlu(reqStruct *model.SemanticReq) (string, *errCode.Error) {
} else if reqStruct.Query == "编号七零六八一" && reqStruct.MacWifi == "f4911e594443" {
channelStr = string(getGreeNluChatReply("好的，计时五分钟马上开始，五，四，三，二，一", "countdown", reqStruct.Query))
} else {
fmt.Println("---------------------待解析---------------------")
data := SpeechNlpWsReq(reqStruct)
speechNluWs := SpeechNlpWs{}
......@@ -58,7 +57,10 @@ func SpeechNlu(reqStruct *model.SemanticReq) (string, *errCode.Error) {
nlpWsConn, err = speechNluWs.SpeechWs()
if err != nil {
global.Logger.Errorf("speechWs.SpeechWs error. %v", err)
global.Logger.WithFields(logger.Fields{
"requestId": reqStruct.RequestId,
"reqStruct": reqStruct,
}).Errorf("speechNluWs.SpeechWs error: %v", err)
return string(replyWithChat(error_reply, "doudi")), errCode.InternalServiceError
}
speechNluWs.NlpWsConn = nlpWsConn
......@@ -70,7 +72,10 @@ func SpeechNlu(reqStruct *model.SemanticReq) (string, *errCode.Error) {
go receiveMessage(nlpWsConn, done, dataChan)
if err := sendRunTaskMsg(nlpWsConn, data); err != nil {
fmt.Println("发送run-task指令失败：", err)
global.Logger.WithFields(logger.Fields{
"requestId": reqStruct.RequestId,
"reqStruct": reqStruct,
}).Errorf("发送run-task指令失败：%v", err)
return string(replyWithChat(error_reply, "doudi")), errCode.InternalServiceError
}
......@@ -78,23 +83,25 @@ func SpeechNlu(reqStruct *model.SemanticReq) (string, *errCode.Error) {
select {
case <-done:
responses = <-dataChan
fmt.Println("任务成功完成，接收数据如下：")
for _, resp := range responses {
semanticRespByteData := ParseSpeechJson(resp, reqStruct.MacWifi, reqStruct.OriginQuery, reqStruct.Mid)
semanticRespByteData := ParseSpeechJson(resp, reqStruct.MacWifi, reqStruct.OriginQuery, reqStruct.Mid, reqStruct.RequestId,
reqStruct.Vender)
return string(semanticRespByteData), errCode.Success
//fmt.Printf("%+v\n", resp)
}
case <-time.After(5 * time.Minute):
fmt.Println("任务超时，尝试获取已接收数据...")
select {
case responses = <-dataChan:
fmt.Println("部分接收数据如下：")
for _, resp := range responses {
fmt.Printf("%+v\n", resp)
semanticRespByteData := ParseSpeechJson(resp, reqStruct.MacWifi, reqStruct.OriginQuery, reqStruct.Mid, reqStruct.RequestId,
reqStruct.Vender)
return string(semanticRespByteData), errCode.Success
}
default:
fmt.Println("未接收到任何数据")
global.Logger.WithFields(logger.Fields{
"requestId": reqStruct.RequestId,
"reqStruct": reqStruct,
}).Error("未接收到任何数据")
return string(replyWithChat(error_reply, "doudi")), errCode.InternalServiceError
}
}
......@@ -124,20 +131,18 @@ func receiveMessage(conn *websocket.Conn, done chan struct{}, dataChan chan<- []
for {
_, message, err := conn.ReadMessage()
if err != nil {
fmt.Println("\n消息接收终止：", err)
global.Logger.Errorf("消息接收终止:%v", err)
return
}
//思必驰nlu回复
fmt.Println("原始消息")
fmt.Println(string(message))
var resp model.SpeechWsResp
if err := json.Unmarshal(message, &resp); err != nil {
fmt.Println("消息解析失败：", err)
global.Logger.WithFields(logger.Fields{
"origin-data": string(message),
}).Errorf("json.Unmarshal error:%v", err)
continue
}
fmt.Printf("\n收到新消息：%+v\n", string(message))
responses = append(responses, resp)
//resp.Dm.ShouldEndSession不能判定是否结束
......@@ -148,41 +153,10 @@ func receiveMessage(conn *websocket.Conn, done chan struct{}, dataChan chan<- []
if resp.Dm != nil {
return
}
//r := resp.SpeechWsResponse(p.RequestId)
//
//if resp.Topic == "tts.error" {
// global.Logger.WithFields(logger.Fields{
// "RequestId": p.RequestId,
// "Code": resp.Error.ErrId,
// "Message": resp.Error.Error,
// "Time": time.Since(st),
// "SpeechWsRequestId": resp.RecordId,
// }).Error("[SpeechWs] 返回message错误")
// r.Status.Code = int32(YXWConvertErrorCode(YXWRespCode(r.Status.Code)))
// p.Send(r)
// return
//}
//p.Send(r)
//
//fmt.Println("1111111")
//fmt.Println(resp)
//
//if resp.Topic == "tts.stream.end" {
// global.Logger.WithFields(logger.Fields{
// "RequestId": p.RequestId,
// "Topic": resp.Topic,
// "Time": time.Since(st).Seconds(),
// "SpeechWsRequestId": resp.RecordId,
// }).Info("[SpeechWs] 读取结束")
//
// close(audioChan)
// break
//}
}
}
func ParseSpeechJson(speechJson model.SpeechWsResp, mac string, query, mid string) []byte {
func ParseSpeechJson(speechJson model.SpeechWsResp, mac string, query, mid, requestId, vender string) []byte {
//思必驰返回的domain是中文,待改
domain := speechJson.Skill
......@@ -192,14 +166,11 @@ func ParseSpeechJson(speechJson model.SpeechWsResp, mac string, query, mid strin
params := &model.SpeechDomainParams{
SpeechWsResp: &speechJson,
Query: query,
RequestId: "",
RequestId: requestId,
Mac: mac,
Domain: domain,
Mid: mid,
MidType: "",
SessionId: "",
HomeId: "",
AppKey: "",
MidType: vender,
}
// 根据mid屏蔽部分domain, 并返回
......@@ -210,8 +181,6 @@ func ParseSpeechJson(speechJson model.SpeechWsResp, mac string, query, mid strin
//jsonByte = jokeDomain(speechJson)
fmt.Println("domain:", domain)
if value, ok := getHandler(domain); ok {
jsonByte = value(params)
} else {
......
service/speechNlu/speechWs.go
View file @ 099c71af
......@@ -18,10 +18,10 @@ type SpeechNlpWs struct {
mutex sync.Mutex
}
func (this *SpeechNlpWs) SpeechWs() (*websocket.Conn, error) {
SpeechWs_Url := "wss://dds.dui.ai/dds/v2/test"
SpeechWs_ProductId := "279629895"
SpeechWs_ApiKey := "0c74988953dd4ed4bf31955527802cf3"
func (s *SpeechNlpWs) SpeechWs() (*websocket.Conn, error) {
SpeechWs_Url := global.SpeechSetting.Url
SpeechWs_ProductId := global.SpeechSetting.ProductId
SpeechWs_ApiKey := global.SpeechSetting.ApiKey
//st := time.Now()
dialer := websocket.Dialer{
......@@ -40,19 +40,18 @@ func (this *SpeechNlpWs) SpeechWs() (*websocket.Conn, error) {
//"RequestId": p.RequestId,
"resp": readResp(resp),
}).Errorf("[SpeechWs] Connect error : %v", err.Error())
//p.Send(ErrorResponse(CodeConnectError, "connect speechWs error"))
return nil, err
}
return conn, nil
}
func (this *SpeechNlpWs) Send(data interface{}) error {
this.NlpWsConn.WriteJSON(data)
func (s *SpeechNlpWs) Send(data interface{}) error {
s.NlpWsConn.WriteJSON(data)
return nil
}
func (this *SpeechNlpWs) Recv() ([]byte, error) {
_, msg, err := this.NlpWsConn.ReadMessage()
func (s *SpeechNlpWs) Recv() ([]byte, error) {
_, msg, err := s.NlpWsConn.ReadMessage()
return msg, err
}
......@@ -76,7 +75,7 @@ func SpeechNlpWsReq(data *model.SemanticReq) *SpeechWsData {
return req
}
func (this *SpeechNlpWs) ParseSpeechNluData(jsonData []byte, requestId, sessionId string) []byte {
func (s *SpeechNlpWs) ParseSpeechNluData(jsonData []byte, requestId, sessionId string) []byte {
speechNlpWsResp := model.SpeechWsResp{}
err := json.Unmarshal(jsonData, &speechNlpWsResp)
if err != nil {
......@@ -94,153 +93,13 @@ func (this *SpeechNlpWs) ParseSpeechNluData(jsonData []byte, requestId, sessionI
return jsonData
}
func (this *SpeechNlpWs) WsSend(body *SpeechWsData) {
this.Send(body)
func (s *SpeechNlpWs) WsSend(body *SpeechWsData) {
s.Send(body)
}
//type SpeechWsConnection struct {
// conn *websocket.Conn
// mutex sync.Mutex
//}
//
//var SpeechWg = &sync.WaitGroup{}
type SpeechWsData struct {
Topic string `json:"topic"` // 必选
RecordId string `json:"recordId"` // 可选，uuid，请求标识
SessionId string `json:"sessionId"` // 可选，首轮不带此参数，非首轮必须带此参数
RefText string `json:"refText"` // 必选，请求文本
}
//func SpeechWs(data model.SemanticReq) {
// da := SpeechNlpWsReq(data)
//
// st := time.Now()
// dialer := websocket.Dialer{
// HandshakeTimeout: 30 * time.Second,
// }
//
// header := http.Header{}
// SpeechUrl := SpeechWs_Url + "?serviceType=websocket&productId=" + SpeechWs_ProductId +
// "&apikey=" + SpeechWs_ApiKey
// global.Logger.WithFields(logger.Fields{
// "Header": header,
// "RequestId": data.RequestId,
// "Url": SpeechUrl,
// }).Info("[SpeechWs] dial")
// conn, resp, err := dialer.Dial(SpeechUrl, header)
// if err != nil {
// global.Logger.WithFields(logger.Fields{
// "RequestId": data.RequestId,
// "resp": readResp(resp),
// }).Errorf("[SpeechWs] Connect error : %v", err.Error())
// //p.Send(ErrorResponse(CodeConnectError, "connect speechWs error"))
// return
// }
//
// c := SpeechWsConnection{
// conn: conn,
// mutex: sync.Mutex{},
// }
// defer c.conn.Close()
//
// global.Logger.WithFields(logger.Fields{
// "RequestId": data.RequestId,
// }).Info("[SpeechWs] Send start")
//
// SpeechWg.Add(2)
// go c.read(st, SpeechWg, data)
// go c.write(da, SpeechWg, data)
// SpeechWg.Wait()
//}
//
//func (c *SpeechWsConnection) write(v interface{}, wg *sync.WaitGroup, p model.SemanticReq) {
// defer wg.Done()
// c.mutex.Lock()
// if err := c.conn.WriteJSON(v); err != nil {
// global.Logger.WithFields(logger.Fields{
// "data": v,
// "RequestId": p.RequestId,
// }).Errorf("[SpeechWs] write error: %v", err.Error())
// } else {
// global.Logger.WithFields(logger.Fields{
// "data": v,
// "RequestId": p.RequestId,
// }).Info("[SpeechWs] write success")
// }
// c.mutex.Unlock()
//}
//
//func (c *SpeechWsConnection) read(st time.Time, wg *sync.WaitGroup, p model.SemanticReq) {
// defer wg.Done()
//
// // XF使用的是追加上传
// //var nextPos int64
// for {
// var resp = SpeechWsResp{}
// _, message, err := c.conn.ReadMessage()
// if err != nil {
// global.Logger.WithFields(logger.Fields{
// "RequestId": p.RequestId,
// "SpeechWsRequestId": resp.RecordId,
// }).Errorf("[SpeechWs] 读取message失败: %v", err.Error())
// //
// //if websocket.IsCloseError(err, websocket.CloseAbnormalClosure) {
// // p.YunXiaoWeiWs()
// // continue
// //}
//
// //p.Send(ErrorResponse(CodeReadOrParseMsgError, "[SpeechWs] 读取message失败"))
// break
// }
// err = json.Unmarshal(message, &resp)
// if err != nil {
// global.Logger.WithFields(logger.Fields{
// "RequestId": p.RequestId,
// "SpeechWsRequestId": resp.RecordId,
// }).Errorf("[SpeechWs] 解析message失败: %v", err.Error())
// //p.Send(ErrorResponse(CodeReadOrParseMsgError, "[SpeechWs] 解析message失败"))
// return
// }
// fmt.Println(message)
// //r := resp.SpeechWsResponse(p.RequestId)
// //
// //if resp.Topic == "tts.error" {
// // global.Logger.WithFields(logger.Fields{
// // "RequestId": p.RequestId,
// // "Code": resp.Error.ErrId,
// // "Message": resp.Error.Error,
// // "Time": time.Since(st),
// // "SpeechWsRequestId": resp.RecordId,
// // }).Error("[SpeechWs] 返回message错误")
// // r.Status.Code = int32(YXWConvertErrorCode(YXWRespCode(r.Status.Code)))
// // p.Send(r)
// // return
// //}
// //p.Send(r)
// //
// //
// //if resp.Topic == "tts.stream.end" {
// // global.Logger.WithFields(logger.Fields{
// // "RequestId": p.RequestId,
// // "Topic": resp.Topic,
// // "Time": time.Since(st).Seconds(),
// // "SpeechWsRequestId": resp.RecordId,
// // }).Info("[SpeechWs] 读取结束")
// //
// // close(audioChan)
// // break
// //}
// }
//}
//
//func readResp(resp *http.Response) string {
// if resp == nil {
// return ""
// }
// b, err := ioutil.ReadAll(resp.Body)
// if err != nil {
// panic(err)
// }
// return fmt.Sprintf("code=%d,body=%s", resp.StatusCode, string(b))
//}
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment