423 lines
11 KiB
Go
423 lines
11 KiB
Go
|
package controller
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"encoding/json"
|
|||
|
|
"fmt"
|
|||
|
|
"github.com/gin-contrib/sessions"
|
|||
|
|
"github.com/gin-gonic/gin"
|
|||
|
|
"github.com/silenceper/wechat/v2/officialaccount/message"
|
|||
|
|
"kefu/common"
|
|||
|
|
"kefu/lib"
|
|||
|
|
"kefu/models"
|
|||
|
|
"kefu/tools"
|
|||
|
|
"kefu/types"
|
|||
|
|
"kefu/ws"
|
|||
|
|
"log"
|
|||
|
|
"regexp"
|
|||
|
|
"strconv"
|
|||
|
|
"strings"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
func SendServerJiang(title string, content string, domain string) string {
|
|||
|
|
noticeServerJiang, err := strconv.ParseBool(models.FindConfig("NoticeServerJiang"))
|
|||
|
|
serverJiangAPI := models.FindConfig("ServerJiangAPI")
|
|||
|
|
if err != nil || !noticeServerJiang || serverJiangAPI == "" {
|
|||
|
|
log.Println("do not notice serverjiang:", serverJiangAPI, noticeServerJiang)
|
|||
|
|
return ""
|
|||
|
|
}
|
|||
|
|
sendStr := fmt.Sprintf("%s%s", title, content)
|
|||
|
|
desp := title + ":" + content + "[登录](http://" + domain + "/main)"
|
|||
|
|
url := serverJiangAPI + "?text=" + sendStr + "&desp=" + desp
|
|||
|
|
//log.Println(url)
|
|||
|
|
res := tools.Get(url)
|
|||
|
|
return res
|
|||
|
|
}
|
|||
|
|
func SendVisitorLoginNotice(kefuName, visitorName, avator, content, visitorId string) {
|
|||
|
|
if !tools.LimitFreqSingle("sendnotice:"+visitorId, 1, 5) {
|
|||
|
|
log.Println("SendVisitorLoginNotice limit")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
userInfo := make(map[string]string)
|
|||
|
|
userInfo["username"] = visitorName
|
|||
|
|
userInfo["avator"] = avator
|
|||
|
|
userInfo["content"] = content
|
|||
|
|
msg := ws.TypeMessage{
|
|||
|
|
Type: "notice",
|
|||
|
|
Data: userInfo,
|
|||
|
|
}
|
|||
|
|
str, _ := json.Marshal(msg)
|
|||
|
|
ws.OneKefuMessage(kefuName, str)
|
|||
|
|
}
|
|||
|
|
func SendNoticeEmail(username, subject, entId, content string) {
|
|||
|
|
if !tools.LimitFreqSingle("send_notice_email:"+username, 1, 10) {
|
|||
|
|
log.Println("send_notice_email limit")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
configs := models.FindEntConfigByEntid(entId)
|
|||
|
|
smtp := ""
|
|||
|
|
email := ""
|
|||
|
|
password := ""
|
|||
|
|
for _, config := range configs {
|
|||
|
|
if config.ConfKey == "NoticeEmailAddress" {
|
|||
|
|
email = config.ConfValue
|
|||
|
|
}
|
|||
|
|
if config.ConfKey == "NoticeEmailPassword" {
|
|||
|
|
password = config.ConfValue
|
|||
|
|
}
|
|||
|
|
if config.ConfKey == "NoticeEmailSmtp" {
|
|||
|
|
smtp = config.ConfValue
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if smtp == "" || email == "" || password == "" {
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
log.Println("发送访客通知邮件:" + smtp + "," + email + "," + password)
|
|||
|
|
err := tools.SendSmtp(smtp, email, password, []string{email}, subject, content)
|
|||
|
|
if err != nil {
|
|||
|
|
log.Println("发送访客通知邮件失败:")
|
|||
|
|
log.Println(err)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
func SendEntSmtpEmail(subject, msg, entId string) {
|
|||
|
|
if !tools.LimitFreqSingle("send_ent_email:"+entId, 1, 2) {
|
|||
|
|
log.Println("send_ent_email limit")
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
configs := models.FindEntConfigByEntid(entId)
|
|||
|
|
smtp := ""
|
|||
|
|
email := ""
|
|||
|
|
password := ""
|
|||
|
|
for _, config := range configs {
|
|||
|
|
if config.ConfKey == "NoticeEmailAddress" {
|
|||
|
|
email = config.ConfValue
|
|||
|
|
}
|
|||
|
|
if config.ConfKey == "NoticeEmailPassword" {
|
|||
|
|
password = config.ConfValue
|
|||
|
|
}
|
|||
|
|
if config.ConfKey == "NoticeEmailSmtp" {
|
|||
|
|
smtp = config.ConfValue
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
if smtp == "" || email == "" || password == "" {
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
err := tools.SendSmtp(smtp, email, password, []string{email}, subject, msg)
|
|||
|
|
if err != nil {
|
|||
|
|
log.Println(err)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
func SendAppGetuiPush(kefu string, title, content string) {
|
|||
|
|
clientModel := &models.User_client{
|
|||
|
|
Kefu: kefu,
|
|||
|
|
}
|
|||
|
|
clientInfos := clientModel.FindClients()
|
|||
|
|
if len(clientInfos) == 0 {
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
appid := models.FindConfig("GetuiAppID")
|
|||
|
|
appkey := models.FindConfig("GetuiAppKey")
|
|||
|
|
appsecret := models.FindConfig("GetuiAppSecret")
|
|||
|
|
appmastersecret := models.FindConfig("GetuiMasterSecret")
|
|||
|
|
token := models.FindConfig("GetuiToken")
|
|||
|
|
getui := &lib.Getui{
|
|||
|
|
AppId: appid,
|
|||
|
|
AppKey: appkey,
|
|||
|
|
AppSecret: appsecret,
|
|||
|
|
AppMasterSecret: appmastersecret,
|
|||
|
|
}
|
|||
|
|
for _, client := range clientInfos {
|
|||
|
|
res, err := getui.PushSingle(token, client.Client_id, title, content)
|
|||
|
|
//不正确的账号
|
|||
|
|
if res == 20001 && err.Error() == "target user is invalid" {
|
|||
|
|
clientModel2 := &models.User_client{
|
|||
|
|
Kefu: kefu,
|
|||
|
|
Client_id: client.Client_id,
|
|||
|
|
}
|
|||
|
|
clientModel2.DeleteClient()
|
|||
|
|
}
|
|||
|
|
if res == 10001 {
|
|||
|
|
token, _ = getui.GetGetuiToken()
|
|||
|
|
models.UpdateConfig("GetuiToken", token)
|
|||
|
|
getui.PushSingle(token, client.Client_id, title, content)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发送邮件验证码
|
|||
|
|
func SendEmailAuthCode(c *gin.Context) {
|
|||
|
|
email := c.PostForm("email")
|
|||
|
|
//验证邮箱
|
|||
|
|
matched, _ := regexp.MatchString("\\w+([-+.]\\w+)*@\\w+([-.]\\w+)*\\.\\w+([-.]\\w+)*", email)
|
|||
|
|
if !matched {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.INVALID,
|
|||
|
|
"msg": "邮箱格式不正确",
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
if !tools.LimitFreqSingle("send_email_authcode:"+email, 1, 50) {
|
|||
|
|
log.Println("send_email_authcode limit " + email)
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.FREQ_LIMIT,
|
|||
|
|
"msg": types.ApiCode.GetMessage(types.ApiCode.FREQ_LIMIT),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
smtp := models.FindConfig("NoticeEmailSmtp")
|
|||
|
|
sender := models.FindConfig("NoticeEmailAddress")
|
|||
|
|
password := models.FindConfig("NoticeEmailPassword")
|
|||
|
|
|
|||
|
|
if smtp == "" || sender == "" || password == "" {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.INVALID,
|
|||
|
|
"msg": "系统没有配置发送邮箱",
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
ranNum := tools.RandNum(6)
|
|||
|
|
session := sessions.DefaultMany(c, "go-session")
|
|||
|
|
session.Set("emailCode"+email, ranNum)
|
|||
|
|
_ = session.Save()
|
|||
|
|
content := strings.Replace(common.NoticeTemplate, "[:content]", "你好，验证码为 "+ranNum, -1)
|
|||
|
|
|
|||
|
|
log.Println("发送邮件验证码:" + smtp + "," + sender + "," + password + "," + email + "," + content)
|
|||
|
|
|
|||
|
|
logContent := fmt.Sprintf("'%s'获取邮箱验证码 %s", email, ranNum)
|
|||
|
|
go models.CreateFlyLog(email, c.ClientIP(), logContent, "user")
|
|||
|
|
|
|||
|
|
err := tools.SendSmtp(smtp, sender, password, []string{email}, "在线客服系统验证码", content)
|
|||
|
|
|
|||
|
|
if err != nil {
|
|||
|
|
logContent := "发送邮件验证码失败:" + err.Error()
|
|||
|
|
log.Println(logContent)
|
|||
|
|
go models.CreateFlyLog(email, c.ClientIP(), logContent, "user")
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.EMAIL_FAILD,
|
|||
|
|
"msg": err.Error(),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 200,
|
|||
|
|
"msg": "ok",
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发送注册通知邮件
|
|||
|
|
func SendRegisterEmail(username, nickname, loginEmail string) {
|
|||
|
|
|
|||
|
|
smtp := models.FindConfig("NoticeEmailSmtp")
|
|||
|
|
sender := models.FindConfig("NoticeEmailAddress")
|
|||
|
|
password := models.FindConfig("NoticeEmailPassword")
|
|||
|
|
|
|||
|
|
if smtp == "" || sender == "" || password == "" {
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
content := fmt.Sprintf("账户：%s，邮箱：%s，昵称：%s，注册成功", username, nickname, loginEmail)
|
|||
|
|
|
|||
|
|
err := tools.SendSmtp(smtp, sender, password, []string{sender}, "在线客服系统注册成功", content)
|
|||
|
|
if err != nil {
|
|||
|
|
log.Println("发送邮件失败:", err)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发送短信验证码
|
|||
|
|
func SendSmsCode(c *gin.Context) {
|
|||
|
|
phone := c.Query("phone")
|
|||
|
|
//验证
|
|||
|
|
matched, _ := regexp.MatchString("1[3-9]\\d{9}$", phone)
|
|||
|
|
if !matched {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.INVALID,
|
|||
|
|
"msg": types.ApiCode.GetMessage(types.ApiCode.INVALID),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
if !tools.LimitFreqSingle("sendsms:"+c.ClientIP(), 1, 50) {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.FREQ_LIMIT,
|
|||
|
|
"msg": types.ApiCode.GetMessage(types.ApiCode.FREQ_LIMIT),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
ranNum := tools.RandNum(6)
|
|||
|
|
session := sessions.DefaultMany(c, "go-session-a")
|
|||
|
|
session.Set("smsCode"+phone, ranNum)
|
|||
|
|
_ = session.Save()
|
|||
|
|
|
|||
|
|
log.Println("发送短信验证码:", phone, ranNum)
|
|||
|
|
|
|||
|
|
err := lib.SendSms(phone, ranNum)
|
|||
|
|
|
|||
|
|
if err != nil {
|
|||
|
|
log.Println("发送短信验证码:", err)
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": types.ApiCode.EMAIL_FAILD,
|
|||
|
|
"msg": err.Error(),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
kefuName, _ := c.Get("kefu_name")
|
|||
|
|
entId, _ := c.Get("ent_id")
|
|||
|
|
logContent := fmt.Sprintf("'%s'手机%s，发送短信验证码'%s'", kefuName, phone, ranNum)
|
|||
|
|
go models.CreateFlyLog(entId.(string), c.ClientIP(), logContent, "sms")
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 200,
|
|||
|
|
"msg": "ok",
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发送微信模板消息
|
|||
|
|
func PostSendWechatTemplate(c *gin.Context) {
|
|||
|
|
entId := c.PostForm("ent_id")
|
|||
|
|
kefuName := c.PostForm("kefu_name")
|
|||
|
|
tel := c.PostForm("tel")
|
|||
|
|
customer := models.FindCustomerWhere("kefu_name = ? and tel = ?", kefuName, tel)
|
|||
|
|
if customer.AcountOpenid == "" {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 200,
|
|||
|
|
"msg": "未查询到绑定的公众号OpenID",
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
templateId := c.PostForm("template_id")
|
|||
|
|
url := c.PostForm("url")
|
|||
|
|
keyword1 := c.PostForm("keyword1")
|
|||
|
|
keyword2 := c.PostForm("keyword2")
|
|||
|
|
keyword3 := c.PostForm("keyword3")
|
|||
|
|
keyword4 := c.PostForm("keyword4")
|
|||
|
|
keyword5 := c.PostForm("keyword5")
|
|||
|
|
keyword6 := c.PostForm("keyword6")
|
|||
|
|
remark := c.PostForm("remark")
|
|||
|
|
wechatConfig, _ := lib.NewWechatLib(entId)
|
|||
|
|
|
|||
|
|
msgData := make(map[string]*message.TemplateDataItem)
|
|||
|
|
msgData["keyword1"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword1,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword2"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword2,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword3"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword3,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword4"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword4,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword5"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword5,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword6"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword6,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["remark"] = &message.TemplateDataItem{
|
|||
|
|
Value: remark,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msg := &message.TemplateMessage{
|
|||
|
|
ToUser: customer.AcountOpenid,
|
|||
|
|
Data: msgData,
|
|||
|
|
TemplateID: templateId,
|
|||
|
|
URL: url,
|
|||
|
|
}
|
|||
|
|
_, err := SendWechatTemplate(wechatConfig, msg)
|
|||
|
|
if err != nil {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 400,
|
|||
|
|
"msg": err.Error(),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 200,
|
|||
|
|
"msg": "ok",
|
|||
|
|
})
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发送微信模板消息
|
|||
|
|
func PostSendWechatTemplateByOpenid(c *gin.Context) {
|
|||
|
|
openid := c.PostForm("openid")
|
|||
|
|
entId := c.PostForm("ent_id")
|
|||
|
|
if openid == "" {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 400,
|
|||
|
|
"msg": "请传递公众号OpenID！",
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
templateId := c.PostForm("template_id")
|
|||
|
|
url := c.PostForm("url")
|
|||
|
|
keyword1 := c.PostForm("keyword1")
|
|||
|
|
keyword2 := c.PostForm("keyword2")
|
|||
|
|
keyword3 := c.PostForm("keyword3")
|
|||
|
|
keyword4 := c.PostForm("keyword4")
|
|||
|
|
keyword5 := c.PostForm("keyword5")
|
|||
|
|
keyword6 := c.PostForm("keyword6")
|
|||
|
|
remark := c.PostForm("remark")
|
|||
|
|
systemBussinesId := models.FindConfig("SystemBussinesId")
|
|||
|
|
if entId == "" {
|
|||
|
|
entId = systemBussinesId
|
|||
|
|
}
|
|||
|
|
wechatConfig, _ := lib.NewWechatLib(entId)
|
|||
|
|
|
|||
|
|
msgData := make(map[string]*message.TemplateDataItem)
|
|||
|
|
msgData["keyword1"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword1,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword2"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword2,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword3"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword3,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword4"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword4,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword5"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword5,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["keyword6"] = &message.TemplateDataItem{
|
|||
|
|
Value: keyword6,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msgData["remark"] = &message.TemplateDataItem{
|
|||
|
|
Value: remark,
|
|||
|
|
Color: "",
|
|||
|
|
}
|
|||
|
|
msg := &message.TemplateMessage{
|
|||
|
|
ToUser: openid,
|
|||
|
|
Data: msgData,
|
|||
|
|
TemplateID: templateId,
|
|||
|
|
URL: url,
|
|||
|
|
}
|
|||
|
|
_, err := SendWechatTemplate(wechatConfig, msg)
|
|||
|
|
if err != nil {
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 400,
|
|||
|
|
"msg": err.Error(),
|
|||
|
|
})
|
|||
|
|
return
|
|||
|
|
}
|
|||
|
|
c.JSON(200, gin.H{
|
|||
|
|
"code": 200,
|
|||
|
|
"msg": "ok",
|
|||
|
|
})
|
|||
|
|
}
|