123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144 |
- package services
- import (
- "encoding/json"
- "eta/eta_mobile/models"
- "eta/eta_mobile/models/company"
- "eta/eta_mobile/models/system"
- "eta/eta_mobile/utils"
- "fmt"
- "strconv"
- "strings"
- "time"
- )
- // SendAdminMobileVerifyCode 发送用户手机验证码
- func SendAdminMobileVerifyCode(source int, mobile, areaCode string) (ok bool, err error) {
- verifyCode := utils.GetRandDigit(6)
- record := new(system.AdminVerifyCodeRecord)
- record.VerifyType = system.AdminVerifyCodeRecordTypeMobile
- record.Mobile = mobile
- record.Source = source
- record.Code = verifyCode
- record.ExpiredTime = time.Now().Add(utils.VerifyCodeExpireMinute * time.Minute)
- record.CreateTime = time.Now().Local()
- record.ModifyTime = time.Now().Local()
- if e := record.Create(); e != nil {
- err = fmt.Errorf("新增验证码记录失败, Err: %s", e.Error())
- return
- }
- tplId := utils.SmsNewLoginTplId
- if areaCode == "86" {
- ok = SendSmsCode(mobile, verifyCode, tplId)
- } else {
- ok = SendSmsCodeGj(mobile, verifyCode, areaCode)
- }
- record.SendStatus = system.AdminVerifyCodeRecordStatusSuccess
- if !ok {
- record.SendStatus = system.AdminVerifyCodeRecordStatusFail
- }
- cols := []string{"SendStatus"}
- if e := record.Update(cols); e != nil {
- err = fmt.Errorf("更新验证码记录失败, Err: %s", e.Error())
- }
- return
- }
- // SendAdminEmailVerifyCode 发送用户邮箱验证码
- func SendAdminEmailVerifyCode(source int, email string) (ok bool, err error) {
- verifyCode := utils.GetRandDigit(6)
- record := new(system.AdminVerifyCodeRecord)
- record.VerifyType = system.AdminVerifyCodeRecordTypeEmail
- record.Email = email
- record.Source = source
- record.Code = verifyCode
- record.ExpiredTime = time.Now().Add(utils.VerifyCodeExpireMinute * time.Minute)
- record.CreateTime = time.Now().Local()
- record.ModifyTime = time.Now().Local()
- if e := record.Create(); e != nil {
- err = fmt.Errorf("新增验证码记录失败, Err: %s", e.Error())
- return
- }
- // 获取邮件配置
- authKey := "english_report_email_conf"
- emailConf, e := company.GetConfigDetailByCode(authKey)
- if e != nil {
- err = fmt.Errorf("获取群发邮件权限失败, Err: %s", e.Error())
- return
- }
- if emailConf.ConfigValue == "" {
- err = fmt.Errorf("邮件配置为空, 不可推送")
- return
- }
- conf := new(models.EnglishReportEmailConf)
- if e = json.Unmarshal([]byte(emailConf.ConfigValue), &conf); e != nil {
- err = fmt.Errorf("邮件配置有误, 不可推送")
- return
- }
- // 获取邮箱模板
- // 获取配置好的短信模版
- cond := ` AND (conf_key = ? OR conf_key = ?)`
- pars := make([]interface{}, 0)
- pars = append(pars, "LoginEmailTemplateSubject", "LoginEmailTemplateContent")
- busiConf := new(models.BusinessConf)
- emailConfList, e := busiConf.GetItemsByCondition(cond, pars, []string{"conf_key, conf_val"}, "")
- if e != nil {
- if e.Error() == utils.ErrNoRow() {
- err = fmt.Errorf("请先配置邮件模版")
- return
- }
- err = fmt.Errorf("获取邮件模版失败, Err: %s", e.Error())
- return
- }
- var emaiContent, emailSubject string
- for _, v := range emailConfList {
- if v.ConfKey == "LoginEmailTemplateContent" {
- emaiContent = v.ConfVal
- } else if v.ConfKey == "LoginEmailTemplateSubject" {
- emailSubject = v.ConfVal
- }
- }
- if emailSubject == "" {
- err = fmt.Errorf("请先配置邮件模版主题")
- return
- }
- if emaiContent == "" {
- err = fmt.Errorf("请先配置邮件模版内容")
- return
- }
- req := new(EnglishReportSendEmailRequest)
- req.Subject = emailSubject
- req.Email = email
- // todo 发信人昵称
- req.FromAlias = conf.FromAlias
- // 填充模板
- t := time.Now().Format("2006年01月02日")
- ct := emaiContent
- ct = strings.Replace(ct, "{{VERIFY_CODE}}", verifyCode, 1)
- ct = strings.Replace(ct, "{{EXPIRED_MINUTE}}", strconv.Itoa(utils.VerifyCodeExpireMinute), 1)
- ct = strings.Replace(ct, "{{DATE_TIME}}", t, 1)
- req.HtmlBody = ct
- aliEmail := new(AliyunEmail)
- o, result, e := aliEmail.SendEmail(req)
- if e != nil {
- err = fmt.Errorf("邮箱推送失败, Err: %s", e.Error())
- return
- }
- ok = o
- record.SendStatus = system.AdminVerifyCodeRecordStatusSuccess
- if !ok {
- record.SendStatus = system.AdminVerifyCodeRecordStatusFail
- }
- record.SendResult = result
- cols := []string{"SendStatus", "SendResult"}
- if e = record.Update(cols); e != nil {
- err = fmt.Errorf("更新验证码记录失败, Err: %s", e.Error())
- }
- return
- }
|