mirror of
https://github.com/silenceper/wechat.git
synced 2026-02-04 21:02:25 +08:00
e1ef3ea160
* 添加微信客服SDK * polish:优化签名函数 * polish：优化注释内容 * polish:复用已有的Token以及CommonError,移除无用的输出 * polish:复用已有的消息加解密 * fix:修复错误信息被覆盖的问题 * polish:go fmt 文件 * polish:客服链接支持自定义参数并更新注释文档内容 * feat:支持微信客服回调请求的校验和消息的解析，复用原有的Signature和DecryptMsg方法 * feat:对外暴露SDKApiForbidden等错误 可以通过调用升级服务相关接口然后根据该错误判断微信客服配置来源 * feat:添加无效的open_kfid错误信息 * fix: 添加SDKApiNotOpen 错误信息 目前主要用于判断客户是否关闭了API授权，如果客户关闭了API功能导致服务异常，则可以引导用户执行相应的操作重新开启改功能 * feat:暴露接待人员ID到消息列表 无需对消息进行序列化即可直接获取接待人员ID，便于处理接待人员的相关业务，例如：统计接待人员当天应答次数 * feat: 添加SDKNotUseInWeCom错误信息 如果SDK输出当前错误，则说明用户在企业微信后台关闭了微信客服功能，需引导用户重新开启该功能 Co-authored-by: Afeyer <afeyer@h5base.cn>
104 lines
3.3 KiB
Go
104 lines
3.3 KiB
Go
package syncmsg
|
|
|
|
import "encoding/json"
|
|
|
|
// Message 同步的消息内容
|
|
type Message struct {
|
|
MsgID string `json:"msgid"` // 消息ID
|
|
OpenKFID string `json:"open_kfid"` // 客服帐号ID
|
|
ExternalUserID string `json:"external_userid"` // 客户UserID
|
|
ReceptionistUserID string `json:"servicer_userid"` // 接待客服userID
|
|
SendTime uint64 `json:"send_time"` // 消息发送时间
|
|
Origin uint32 `json:"origin"` // 消息来源。3-客户回复的消息 4-系统推送的消 息
|
|
MsgType string `json:"msgtype"` // 消息类型
|
|
EventType string `json:"event_type"` // 事件类型
|
|
OriginData []byte `json:"origin_data"` // 原始数据内容
|
|
}
|
|
|
|
// GetOriginMessage 获取原始消息
|
|
func (r Message) GetOriginMessage() (info []byte) {
|
|
return r.OriginData
|
|
}
|
|
|
|
// GetTextMessage 获取文本消息
|
|
func (r Message) GetTextMessage() (info Text, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetImageMessage 获取图片消息
|
|
func (r Message) GetImageMessage() (info Image, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetVoiceMessage 获取语音消息
|
|
func (r Message) GetVoiceMessage() (info Voice, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetVideoMessage 获取视频消息
|
|
func (r Message) GetVideoMessage() (info Video, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetFileMessage 获取文件消息
|
|
func (r Message) GetFileMessage() (info File, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetLocationMessage 获取文件消息
|
|
func (r Message) GetLocationMessage() (info Location, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetLinkMessage 获取链接消息
|
|
func (r Message) GetLinkMessage() (info Link, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetBusinessCardMessage 获取名片消息
|
|
func (r Message) GetBusinessCardMessage() (info BusinessCard, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetMiniProgramMessage 获取小程序消息
|
|
func (r Message) GetMiniProgramMessage() (info MiniProgram, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetEnterSessionEvent 用户进入会话事件
|
|
func (r Message) GetEnterSessionEvent() (info EnterSessionEvent, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
info.OpenKFID = info.Event.OpenKFID
|
|
info.ExternalUserID = info.Event.ExternalUserID
|
|
return info, err
|
|
}
|
|
|
|
// GetMsgSendFailEvent 消息发送失败事件
|
|
func (r Message) GetMsgSendFailEvent() (info MsgSendFailEvent, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetReceptionistStatusChangeEvent 客服人员接待状态变更事件
|
|
func (r Message) GetReceptionistStatusChangeEvent() (info ReceptionistStatusChangeEvent, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
return info, err
|
|
}
|
|
|
|
// GetSessionStatusChangeEvent 会话状态变更事件
|
|
func (r Message) GetSessionStatusChangeEvent() (info SessionStatusChangeEvent, err error) {
|
|
err = json.Unmarshal(r.OriginData, &info)
|
|
info.OpenKFID = info.Event.OpenKFID
|
|
info.ExternalUserID = info.Event.ExternalUserID
|
|
return info, err
|
|
}
|