From 9f0e014981c7e7d1d6890d0636dd3a84f01c7ffa Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=82=B9=E5=AE=97=E6=A5=A0?= Date: Sun, 29 Jan 2023 14:42:40 +0800 Subject: [PATCH] 1 --- .../enterprise_wechat/enterprise_test.go | 33 +++++++-- platformapi/enterprise_wechat/wechat_model.go | 1 + platformapi/enterprise_wechat/wechat_msg.go | 73 +++++++++++++++++++ 3 files changed, 101 insertions(+), 6 deletions(-) create mode 100644 platformapi/enterprise_wechat/wechat_msg.go diff --git a/platformapi/enterprise_wechat/enterprise_test.go b/platformapi/enterprise_wechat/enterprise_test.go index fc1410a5..e3dc6a05 100644 --- a/platformapi/enterprise_wechat/enterprise_test.go +++ b/platformapi/enterprise_wechat/enterprise_test.go @@ -3,6 +3,7 @@ package enterprise_wechat import ( "fmt" "git.rosy.net.cn/baseapi" + "git.rosy.net.cn/jx-callback/globals" "go.uber.org/zap" "strconv" "testing" @@ -26,7 +27,6 @@ func init() { } func TestGetToken(t *testing.T) { - api = New("ww9a156bfa070e1857", "JQsEmSTltHhNgdPIT320YJFphiYmRs-YZa-rCBwplss") token, err := api.GetAccessToken() if err != nil { fmt.Println("err=", err) @@ -60,7 +60,6 @@ func TestGetAllDepartmentList(t *testing.T) { // 创建员工 func TestCreateStaff(t *testing.T) { - api = New("ww9a156bfa070e1857", "0jBdCjSmoFiOoHIXyeCK9VbGQ82fVNJZ8uMl6JNN7X4") // 通讯录 err := api.CreateBoss2JxStaff(&CreateBoos2JXStaffReq{ Userid: "jx2022524_6685111", Name: "门店老板", @@ -94,7 +93,6 @@ func TestGetUserByMobile(t *testing.T) { // 创建会话群聊 func TestCreateSession(t *testing.T) { - api = New("ww9a156bfa070e1857", "JQsEmSTltHhNgdPIT320YJFphiYmRs-YZa-rCBwplss") // 小程序 err := api.CreateAppChat(&CreateAppChatParamReq{ UserList: []string{"WangXiao", "LiuLei"}, Name: "刘磊的企业微信群1", @@ -104,7 +102,30 @@ func TestCreateSession(t *testing.T) { fmt.Println("err======", err) } -func TestGetSuiteTicket(t *testing.T) { - api = New("ww9a156bfa070e1857", "JQsEmSTltHhNgdPIT320YJFphiYmRs-YZa-rCBwplss") // 小程序 - +// 发送消息到企业微信 +func TestSendMsg(t *testing.T) { + msg := &EnterpriseSendMsgReq{ + Touser: "LiuLei", + Toparty: "", + Totag: "", + Msgtype: "textcard", + Agentid: 1000005, + Textcard: TextCardObject{ + Title: "异步任务", + Description: "刚刚的同步任务下载链接", + Url: "https://www.baidu.com", + Btntxt: "详情", + }, + EnableIdTrans: 0, + EnableDuplicateCheck: 0, + DuplicateCheckInterval: 0, + } + err := api.SendMsgToUser(msg) + fmt.Println("err === ", err) +} + +// 获取员工信息 +func TestGetUserId(t *testing.T) { + phone, err := api.GetUserIdByMobile("18981810340") + globals.SugarLogger.Debugf("phone := %s,err :=%s", phone, err) } diff --git a/platformapi/enterprise_wechat/wechat_model.go b/platformapi/enterprise_wechat/wechat_model.go index 7cc8c238..27ff1945 100644 --- a/platformapi/enterprise_wechat/wechat_model.go +++ b/platformapi/enterprise_wechat/wechat_model.go @@ -16,6 +16,7 @@ const ( CreateBoosToJxStaff = "cgi-bin/user/create" // 将京西老板创建为企业员工 GetDepartmentUserDetail = "cgi-bin/user/list" // 获取部门用户详细情况 GetUserByMobileUrl = "cgi-bin/user/getuserid" // 通过手机号获取用户id + SendMsgToUser = "cgi-bin/message/send" // 给用户发送消息 EnterpriseTicketInfo = "/suite/receive" // 企业微信服务器会定时（每十分钟）推送ticket ) diff --git a/platformapi/enterprise_wechat/wechat_msg.go b/platformapi/enterprise_wechat/wechat_msg.go new file mode 100644 index 00000000..7da0698e --- /dev/null +++ b/platformapi/enterprise_wechat/wechat_msg.go @@ -0,0 +1,73 @@ +package enterprise_wechat + +import ( + "errors" + "git.rosy.net.cn/baseapi/utils" + "net/http" +) + +const ( + MsgTypeText = "text" // 文本消息 + MsgTypeImg = "image" // 图片消息 + MsgTypeVoice = "voice" // 语音消息 + MsgTypeVideo = "video" // 视频消息 + MsgTypeFile = "file" // 文件消息 + MsgTypeTextCard = "textcard" // 文本卡片消息 + MsgTypeNews = "news" // 图文消息 + MsgTypeMpNews = "mpnews" // 图文消息 + MsgTypeMarkdown = "markdown" // markdown消息 + MsgTypeMiniprogramNotice = "miniprogram_notice" // 小程序通知消息 + MsgTypeTemplateCard = "template_card" // 模板卡片消息(文本型/图文型/按钮型/投票型/多项选择型) +) + +// EnterpriseSendMsgReq 发送企业微信文本卡片消息请求参数 +type EnterpriseSendMsgReq struct { + Touser string `json:"touser"` // 成员ID列表（消息接收者，多个接收者用‘|’分隔，最多支持1000个） + Toparty string `json:"toparty"` // 部门ID列表，多个接收者用‘|’分隔，最多支持100个 + Totag string `json:"totag"` // 标签ID列表，多个接收者用‘|’分隔，最多支持100个 + Msgtype string `json:"msgtype"` // 消息类型，此时固定为：textcard + Agentid int `json:"agentid"` // 企业应用的id + Textcard TextCardObject `json:"textcard"` + EnableIdTrans int `json:"enable_id_trans"` // 表示是否开启id转译，0表示否，1表示是，默认0 + EnableDuplicateCheck int `json:"enable_duplicate_check"` // 表示是否开启重复消息检查，0表示否，1表示是， + DuplicateCheckInterval int `json:"duplicate_check_interval"` // 表示是否重复消息检查的时间间隔，默认1800s，最大不超过4小时 +} + +type TextCardObject struct { + Title string `json:"title"` // 标题，不超过128个字节 + Description string `json:"description"` // 描述，不超过512个字节 + Url string `json:"url"` // 点击后跳转的链接 + Btntxt string `json:"btntxt"` // 按钮文字 +} + +// EnterpriseSendMsgRes 返回参数 +type EnterpriseSendMsgRes struct { + Errcode int `json:"errcode"` // 返回码 + Errmsg string `json:"errmsg"` // 对返回码的文本描述内容 + Invaliduser string `json:"invaliduser"` // 不合法的userid，不区分大小写，统一转为小写 + Invalidparty string `json:"invalidparty"` // 不合法的partyid + Invalidtag string `json:"invalidtag"` // 不合法的标签id + Unlicenseduser string `json:"unlicenseduser"` // 没有基础接口许可(包含已过期)的userid + Msgid string `json:"msgid"` // 消息id，用于撤回应用消息 + ResponseCode string `json:"response_code"` // 仅消息类型为“按钮交互型”，“投票选择型”和“多项选择型”的模板卡片消息返回，应用可使用response_code调用更新模版卡片消息接口，72小时内有效，且只能使用一次 +} + +// SendMsgToUser 将消息发送给企业微信用户 +func (a *API) SendMsgToUser(msg *EnterpriseSendMsgReq) error { + a.CheckAccessTokenExpiresIn() + param := utils.Struct2Map(msg, "", false) + data, err := a.AccessAPI(WeChatBaseApi, SendMsgToUser, http.MethodPost, param) + if err != nil { + return err + } + + result := &EnterpriseSendMsgRes{} + if err := utils.Map2StructByJson(data, result, false); err != nil { + return err + } + if result.Errcode != 0 { + return errors.New(result.Errmsg) + } + + return nil +}