Merge branch 'master' of http://git.shengws.com/zhangbj/scrm-go

controllers/admin_user/admin_controller.go

@@ -6,6 +6,9 @@ import (
 	base_service "SCRM/service"
 	"SCRM/service/admin_service"
 	"SCRM/service/role_service"
+	"SCRM/service/sms_service"
+	"strconv"
+	"time"
 
 	"github.com/astaxie/beego"
 )
@@ -49,22 +52,34 @@ func (this *AdminController) EditAdminUserInfo() {
 
 // /api/password/code [post]
 func (this *AdminController) CodeOfModifyPwd() {
-	//////////////////////////////
-	// 待把 SMS 的 service 添加完再重新放开
-	//////////////////////////////
-	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-	return
-	// adminUserInfo := this.GetAdminUserInfo()
-	// mobile := adminUserInfo.AdminUser.Mobile
-	// if err := service.SMSSendVerificationCode(mobile); err != nil {
-	// 	utils.ErrorLog("修改密码发送验证码失败:%v", err)
-	// 	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-	// 	return
-	// } else {
-	// 	this.ServeSuccessJSON(map[string]interface{}{
-	// 		"msg": "短信发送成功,有效期为10分钟",
-	// 	})
-	// }
+	adminUserInfo := this.GetAdminUserInfo()
+	mobile := adminUserInfo.AdminUser.Mobile
+
+	redisClient := base_service.RedisClient()
+	defer redisClient.Close()
+
+	cur_date := time.Now().Format("2006-01-02")
+	moblie_count, _ := redisClient.Get("scrm_verification_code_" + mobile + "_" + cur_date).Result()
+	moblie_count_int, _ := strconv.Atoi(moblie_count)
+	if moblie_max := 5; moblie_count_int >= moblie_max {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeVerificationCodeLimit)
+		return
+	}
+
+	if code, err := sms_service.SMSSendVerificationCode(mobile); err != nil {
+		this.ErrorLog("修改密码发送验证码失败:%v", err)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+
+	} else {
+		cur_date := time.Now().Format("2006-01-02")
+		redisClient.Set("scrm_verification_code_"+mobile, code, time.Minute*10)
+		redisClient.Incr("scrm_verification_code_" + mobile + "_" + cur_date).Result()
+
+		this.ServeSuccessJSON(map[string]interface{}{
+			"msg": "短信发送成功,有效期为10分钟",
+		})
+	}
 }
 
 // /api/password/modify [post]
@@ -83,7 +98,7 @@ func (this *AdminController) ModifyPwd() {
 
 	redisClient := base_service.RedisClient()
 	defer redisClient.Close()
-	cachedCode, err := redisClient.Get("xt_modify_pwd_" + mobile).Result()
+	cachedCode, err := redisClient.Get("scrm_verification_code_" + mobile).Result()
 	if err != nil {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAccountOrVerCodeWrong)
 		return
@@ -100,7 +115,7 @@ func (this *AdminController) ModifyPwd() {
 	}
 
 	// 清除验证码
-	redisClient.Del("xt_modify_pwd_" + mobile)
+	redisClient.Del("scrm_verification_code_" + mobile)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"msg": "密码已修改",
 	})

controllers/global/router_collector.go

@@ -5,4 +5,5 @@ func RegisterRouters() {
 	DistrictCtlRegistRouters()
 	QiniuCtlRegistRouters()
 	OpenWechatCtlRegistRouters()
+	SMSCBAPICtlRegistRouters()
 }

controllers/global/sms_controller.go

@@ -0,0 +1,50 @@
+package global
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/service/sms_service"
+	"encoding/json"
+	"strconv"
+
+	"github.com/astaxie/beego"
+)
+
+func SMSCBAPICtlRegistRouters() {
+	beego.Router("/sms/callback", &SMSTplCallBackAPIController{}, "post:CallBack")
+}
+
+type SMSTplCallBackAPIController struct {
+	base_ctl.BaseAPIController
+}
+
+// /sms/callback [post]
+func (this *SMSTplCallBackAPIController) CallBack() {
+	var callbackParams map[string]string
+	json.Unmarshal(this.Ctx.Input.RequestBody, &callbackParams)
+	this.TraceLog("短信平台回调: params: %v", callbackParams)
+
+	code := callbackParams["code"]
+	templateIDStr := callbackParams["templateid"]
+
+	if len(templateIDStr) != 0 {
+		templateID, _ := strconv.Atoi(templateIDStr)
+		if code == "2" {
+			err := sms_service.SMSUCPaasTemplateApproved(int64(templateID))
+			if err != nil {
+				this.ErrorLog("短信平台回调(成功)——数据库操作失败: err: %v; templateID: %v", err, templateID)
+			}
+		} else if code == "3" {
+			err := sms_service.SMSUCPaasTemplateUnapproved(int64(templateID))
+			if err != nil {
+				this.ErrorLog("短信平台回调(失败)——数据库操作失败: err: %v; templateID: %v", err, templateID)
+			}
+		}
+
+	} else {
+		this.TraceLog("短信平台回调: %+v", this.Ctx.Request)
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"result": true,
+	})
+}

controllers/kefu/tencent_usersig_api_controller.go

@@ -62,3 +62,4 @@ func (c *TencentUsersigApiController) GetUsersig() {
 	c.ServeSuccessJSON(returnData)
 	return
 }
+

controllers/members/members_controller.go

@@ -6,16 +6,17 @@ import (
 	"SCRM/models"
 	"SCRM/service/member_service"
 	"SCRM/utils"
+	"encoding/json"
+	"fmt"
 	"reflect"
 	"time"
-    "fmt"
-	"encoding/json"
 
 	"github.com/astaxie/beego"
 )
 
 func MemberCtlRegistRouters() {
 	beego.Router("/api/members", &MembersAPIController{}, "get:GetMembers")
+	beego.Router("/api/members/all", &MembersAPIController{}, "get:GetAllMembers")
 	beego.Router("/api/member/create", &MembersAPIController{}, "Post:CreateMember")
 	beego.Router("/api/member/edit", &MembersAPIController{}, "Put:EditMember")
 	beego.Router("/api/members/delete", &MembersAPIController{}, "Delete:DeleteMembers")
@@ -35,7 +36,7 @@ func (c *MembersAPIController) GetMembers() {
 	source, _ := c.GetInt64("source", 0)
 	tag, _ := c.GetInt64("tag", 0)
 	init, _ := c.GetInt64("init", 0)
-	fmt.Println("level",level,"source",source)
+	fmt.Println("level", level, "source", source)
 	if page <= 0 {
 		page = 1
 	}
@@ -107,6 +108,22 @@ func (c *MembersAPIController) GetMembers() {
 	return
 }
 
+func (c *MembersAPIController) GetAllMembers() {
+
+	adminUserInfo := c.GetAdminUserInfo()
+	members, err := member_service.GetAllMemberList(adminUserInfo.CurrentOrgId)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取列表失败")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["members"] = members
+
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
 func (c *MembersAPIController) CreateMember() {
 
 	adminUserInfo := c.GetAdminUserInfo()

controllers/role/admin_controller.go

@@ -7,6 +7,7 @@ import (
 	"SCRM/service"
 	base_service "SCRM/service"
 	"SCRM/service/role_service"
+	"SCRM/service/sms_service"
 	"time"
 
 	"github.com/astaxie/beego"
@@ -36,7 +37,7 @@ func (this *AdminAPIController) AdminMainView() {
 
 	viewModels, total, getAdminsErr := role_service.GetAdminUsersAndLoginInfo(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, 1, 10)
 	if getAdminsErr != nil {
-		//beego.Error("获取管理员列表失败:", getAdminsErr)
+		this.ErrorLog("获取管理员列表失败:", getAdminsErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -62,7 +63,7 @@ func (this *AdminAPIController) Admins() {
 	page, _ := this.GetInt("page")
 	viewModels, total, getAdminsErr := role_service.GetAdminUsersAndLoginInfo(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, page, 10)
 	if getAdminsErr != nil {
-		//beego.Error("获取管理员列表失败:", getAdminsErr)
+		this.ErrorLog("获取管理员列表失败:", getAdminsErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 	} else {
 		this.ServeSuccessJSON(map[string]interface{}{
@@ -82,7 +83,7 @@ func (this *AdminAPIController) AddAdminInitData() {
 
 	roles, getRoleErr := role_service.GetAllValidRoles(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId)
 	if getRoleErr != nil {
-		//beego.Error("获取所有角色失败:", getRoleErr)
+		this.ErrorLog("获取所有角色失败:", getRoleErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -126,7 +127,7 @@ func (this *AdminAPIController) AddAdmin() {
 
 	isRoleExist, getRoleErr := role_service.IsRoleExist(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, roleId)
 	if getRoleErr != nil {
-		//beego.Error("查询角色是否存在时失败:", getRoleErr)
+		this.ErrorLog("查询角色是否存在时失败:", getRoleErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -137,7 +138,7 @@ func (this *AdminAPIController) AddAdmin() {
 
 	// 判断该应用是否已存在该手机号
 	if isMobileDidUsed, err := role_service.IsMobileDidUsedAtApp(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, mobile); err != nil {
-		//beego.Error("查询用户是否已被添加为管理员时失败:", err)
+		this.ErrorLog("查询用户是否已被添加为管理员时失败:", err)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	} else {
@@ -159,18 +160,17 @@ func (this *AdminAPIController) AddAdmin() {
 
 	_, password, createErr := role_service.CreateGeneralAdminUser(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, mobile, name, userType, userTitle, intro, roleId)
 	if createErr != nil {
-		//beego.Error("创建管理员失败:", createErr)
+		this.ErrorLog("创建管理员失败:", createErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
 		return
 
 	} else {
 		this.TraceLog("%v", password)
-		//beego.Trace("用户密码:", password)
 		// 发送短信通知这个手机号
-		// sendSMSErr := role_service.SMSSendInviteMobileToJoinOrgAdmin(name, mobile, password)
-		// if sendSMSErr != nil {
-		// 	//beego.Error("发送邀请短信失败：%v", sendSMSErr)
-		// }
+		sendSMSErr := sms_service.SMSSendInviteMobileToJoinOrgAdmin(name, mobile, password)
+		if sendSMSErr != nil {
+			this.ErrorLog("发送邀请短信失败：%v", sendSMSErr)
+		}
 
 		this.ServeSuccessJSON(nil)
 		return
@@ -194,7 +194,7 @@ func (this *AdminAPIController) EditAdminInitData() {
 
 	adminUserViewModel, getInfoErr := role_service.GetGeneralAdminUser(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, admin_user_id)
 	if getInfoErr != nil {
-		//beego.Error("获取管理员信息失败:", getInfoErr)
+		this.ErrorLog("获取管理员信息失败:", getInfoErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -205,7 +205,7 @@ func (this *AdminAPIController) EditAdminInitData() {
 
 	roles, getRoleErr := role_service.GetAllValidRoles(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId)
 	if getRoleErr != nil {
-		//beego.Error("获取所有角色失败:", getRoleErr)
+		this.ErrorLog("获取所有角色失败:", getRoleErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -250,7 +250,7 @@ func (this *AdminAPIController) EditAdmin() {
 
 	appRole, getAppRoleErr := role_service.GetAppRole(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, adminUserId)
 	if getAppRoleErr != nil {
-		//beego.Error("查询管理员信息时失败:", getAppRoleErr)
+		this.ErrorLog("查询管理员信息时失败:", getAppRoleErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -261,7 +261,7 @@ func (this *AdminAPIController) EditAdmin() {
 
 	isRoleExist, getRoleErr := role_service.IsRoleExist(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, roleId)
 	if getRoleErr != nil {
-		//beego.Error("查询角色是否存在时失败:", getRoleErr)
+		this.ErrorLog("查询角色是否存在时失败:", getRoleErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	}
@@ -278,7 +278,7 @@ func (this *AdminAPIController) EditAdmin() {
 	appRole.ModifyTime = time.Now().Unix()
 	saveErr := role_service.SaveAppRole(appRole)
 	if saveErr != nil {
-		//beego.Error("修改App_Role失败:", saveErr)
+		this.ErrorLog("修改App_Role失败:", saveErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
 
 	} else {
@@ -303,7 +303,7 @@ func (this *AdminAPIController) AdminSetStatus() {
 	}
 	appRole, getAppRoleErr := role_service.GetAppRole(adminUserInfo.CurrentOrgId, adminUserInfo.CurrentAppId, userID)
 	if getAppRoleErr != nil {
-		//beego.Error("查询管理员信息失败:", getAppRoleErr)
+		this.ErrorLog("查询管理员信息失败:", getAppRoleErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		return
 	} else if appRole == nil {
@@ -327,7 +327,7 @@ func (this *AdminAPIController) AdminSetStatus() {
 	appRole.ModifyTime = time.Now().Unix()
 	saveErr := role_service.SaveAppRole(appRole)
 	if saveErr != nil {
-		//beego.Error("保存AppRole失败:", saveErr)
+		this.ErrorLog("保存AppRole失败:", saveErr)
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDBUpdate)
 
 	} else {

controllers/sms/router_collector.go

@@ -0,0 +1,5 @@
+package sms
+
+func RegisterRouters() {
+	SMSCtlRegistRouters()
+}

controllers/sms/sms_controller.go

@@ -0,0 +1,227 @@
+package sms
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/service/marketing_tool_service"
+	"SCRM/service/member_service"
+	"SCRM/service/sms_service"
+	"fmt"
+	"strings"
+
+	"github.com/astaxie/beego"
+)
+
+func SMSCtlRegistRouters() {
+	beego.Router("/api/sms/records", &SMSController{}, "get:GetSendRecords")
+	beego.Router("/api/sms/sendinit", &SMSController{}, "get:SendInitData")
+	beego.Router("/api/sms/tagfiltercount", &SMSController{}, "get:TagFilterCustomerCount")
+
+	beego.Router("/api/sms/send2all", &SMSController{}, "post:Send2AllCustomers")
+	beego.Router("/api/sms/send2tag", &SMSController{}, "post:Send2TagCustomers")
+	beego.Router("/api/sms/send2specific", &SMSController{}, "post:Send2SpecificCustomers")
+}
+
+type SMSController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+// /api/sms/records [get]
+// @param page:int
+func (this *SMSController) GetSendRecords() {
+	page, _ := this.GetInt("page")
+	if page <= 0 {
+		page = 1
+	}
+
+	adminUserInfo := this.GetAdminUserInfo()
+	records, total, getRecordErr := sms_service.GetBatchSendRecords(adminUserInfo.CurrentOrgId, page, 10)
+	if getRecordErr != nil {
+		this.ErrorLog("获取短信批次记录失败:%v", getRecordErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"records": records,
+		"total":   total,
+	})
+}
+
+// /api/sms/sendinit [get]
+// @param action?:int 事件类型 1.活动
+// @param id?:int 事件对应的id，如活动id
+func (this *SMSController) SendInitData() {
+	adminUserInfo := this.GetAdminUserInfo()
+	tags, getTagErr := member_service.GetTagList(adminUserInfo.CurrentOrgId)
+	if getTagErr != nil {
+		this.ErrorLog("获取标签失败:%v", getTagErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	action, _ := this.GetInt("action")
+	id, _ := this.GetInt64("id")
+	defaultSMSContent := ""
+	if id > 0 {
+		if action == 1 {
+			activity, _ := marketing_tool_service.GetActivityWithID(adminUserInfo.CurrentOrgId, id)
+			if activity != nil { // 因为 defaultSMSContent 不是必须的，所以不理会出现的错误
+				shareObj, _ := marketing_tool_service.GetActivityWxShareByActivityID(id)
+				if shareObj != nil {
+					defaultSMSContent = fmt.Sprintf("给您分享一个活动，点击参与：%v", shareObj.ShortURL)
+				}
+			}
+		}
+	}
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"tags":            tags,
+		"default_content": defaultSMSContent,
+	})
+}
+
+// /api/sms/tagfiltercount [get]
+// @param tags:string tag_id 以逗号隔开 (1,2,4)
+func (this *SMSController) TagFilterCustomerCount() {
+	tagIDsStr := this.GetString("tags")
+	if len(tagIDsStr) == 0 {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"count": 0,
+		})
+		return
+	}
+	tagIDs := strings.Split(tagIDsStr, ",")
+	count, getCountErr := member_service.GetTagUsersCountWithMobileByTagIDs(tagIDs)
+	if getCountErr != nil {
+		this.ErrorLog("获取标签人数失败:%v", getCountErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	this.ServeSuccessJSON(map[string]interface{}{
+		"count": count,
+	})
+}
+
+// /api/sms/send2all [post]
+// @param content:string
+func (this *SMSController) Send2AllCustomers() {
+	content := this.GetString("content")
+	if len(content) == 0 || strings.Contains(content, "【") || strings.Contains(content, "】") {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	adminUserInfo := this.GetAdminUserInfo()
+	customers, getCustomerErr := member_service.GetAllCustomersWithMobile(adminUserInfo.CurrentOrgId)
+	if getCustomerErr != nil {
+		this.ErrorLog("获取所有客户失败:%v", getCustomerErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if len(customers) == 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSMSNoCustomer)
+		return
+	}
+
+	mobiles := make([]string, 0, len(customers))
+	for _, customer := range customers {
+		mobiles = append(mobiles, customer.Mobile)
+	}
+
+	sendErr := sms_service.SMSOrgSendWithCustomContent(adminUserInfo.CurrentOrgId, content, mobiles)
+	if sendErr != nil {
+		if sendErr == sms_service.SMSErrorFreeLimitInsufficient {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSMSLimitInsufficient)
+			return
+		} else {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+	} else {
+		this.ServeSuccessJSON(nil)
+	}
+}
+
+// /api/sms/send2tag [post]
+// @param content:string
+// @param tags:string 标签id以逗号隔开 (1,2,43)
+func (this *SMSController) Send2TagCustomers() {
+	content := this.GetString("content")
+	tagIDsStr := this.GetString("tags")
+	if len(content) == 0 || strings.Contains(content, "【") || strings.Contains(content, "】") || len(tagIDsStr) == 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	tagIDs := strings.Split(tagIDsStr, ",")
+	adminUserInfo := this.GetAdminUserInfo()
+	customers, getCustomerErr := member_service.GetTagCustomersWithMobileByTagIDs(adminUserInfo.CurrentOrgId, tagIDs)
+	if getCustomerErr != nil {
+		this.ErrorLog("获取标签指定客户失败:%v", getCustomerErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if len(customers) == 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSMSNoCustomer)
+		return
+	}
+
+	mobiles := make([]string, 0, len(customers))
+	for _, customer := range customers {
+		mobiles = append(mobiles, customer.Mobile)
+	}
+
+	sendErr := sms_service.SMSOrgSendWithCustomContent(adminUserInfo.CurrentOrgId, content, mobiles)
+	if sendErr != nil {
+		if sendErr == sms_service.SMSErrorFreeLimitInsufficient {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSMSLimitInsufficient)
+			return
+		} else {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+	} else {
+		this.ServeSuccessJSON(nil)
+	}
+}
+
+// /api/sms/send2specific [post]
+// @param content:string
+// @param ids:string customer_id以逗号隔开 (4,11)
+func (this *SMSController) Send2SpecificCustomers() {
+	content := this.GetString("content")
+	customerIDsStr := this.GetString("ids")
+	if len(content) == 0 || strings.Contains(content, "【") || strings.Contains(content, "】") || len(customerIDsStr) == 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	customerIDs := strings.Split(customerIDsStr, ",")
+	adminUserInfo := this.GetAdminUserInfo()
+	customers, getCustomerErr := member_service.GetSpecificCustomersWithMobile(adminUserInfo.CurrentOrgId, customerIDs)
+	if getCustomerErr != nil {
+		this.ErrorLog("获取指定客户失败:%v", getCustomerErr)
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	} else if len(customers) == 0 {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSMSNoCustomer)
+		return
+	}
+
+	mobiles := make([]string, 0, len(customers))
+	for _, customer := range customers {
+		mobiles = append(mobiles, customer.Mobile)
+	}
+
+	sendErr := sms_service.SMSOrgSendWithCustomContent(adminUserInfo.CurrentOrgId, content, mobiles)
+	if sendErr != nil {
+		if sendErr == sms_service.SMSErrorFreeLimitInsufficient {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSMSLimitInsufficient)
+			return
+		} else {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+	} else {
+		this.ServeSuccessJSON(nil)
+	}
+}

controllers/短信模块临时备注

@@ -1,2 +0,0 @@
-修改个人信息
-权限管理中添加管理员

enums/error_code.go

@@ -21,6 +21,7 @@ const ( // ErrorCode
 	ErrorCodeUserWasForbidden               = 6015
 	ErrorCodeNeverCreateTypeApp             = 6016
 	ErrorCodeContactSuperAdminCreateTypeApp = 6017
+	ErrorCodeVerificationCodeLimit          = 6018
 
 	// 数据验证错误 7000+
 	ErrorCodeMobileFormat     = 7001
@@ -57,6 +58,9 @@ const ( // ErrorCode
 	ErrorCodeHetongHad         = 4007
 	ErrorCodeCreateHetongFail  = 4008
 	ErrorCodePatientReachLimit = 4009
+
+	ErrorCodeSMSNoCustomer        = 10001
+	ErrorCodeSMSLimitInsufficient = 10002
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -78,6 +82,7 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeUserWasForbidden:               "该用户被禁用",
 	ErrorCodeNeverCreateTypeApp:             "未创建此种应用",
 	ErrorCodeContactSuperAdminCreateTypeApp: "请联系超级管理员开通此种应用",
+	ErrorCodeVerificationCodeLimit:          "该号码今日验证码已超限",
 
 	// 数据验证错误
 	ErrorCodeMobileFormat:     "手机号格式错误",
@@ -114,6 +119,9 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeHetongHad:         "合同已经存在！",
 	ErrorCodeCreateHetongFail:  "合同创建失败",
 	ErrorCodePatientReachLimit: "患者数已达到当前服务版本病人数，需要升级到更高的版本",
+
+	ErrorCodeSMSNoCustomer:        "没有目标客户",
+	ErrorCodeSMSLimitInsufficient: "当月可用短信额度不足",
 }
 
 type SGJError struct {

jobcron/activity_short_url_job.go

@@ -0,0 +1,128 @@
+package jobcron
+
+import (
+	"SCRM/service"
+	"SCRM/utils"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+	"net/url"
+	"strings"
+	"time"
+
+	"github.com/astaxie/beego"
+	"github.com/robfig/cron"
+)
+
+// cron表达式 https://www.cnblogs.com/zuxingyu/p/6023919.html
+var activityShortUrlCronJob *cron.Cron
+
+func init() {
+	activityShortUrlCronJob = cron.New()
+	spec := "0 0 0 * * ?" // 每天晚上12点整检查活动短链接库存充不充足
+	activityShortUrlCronJob.AddFunc(spec, func() {
+		CreateActivityShortURLIfNeeded()
+	})
+}
+
+type CreateShortURLServiceMaxId struct {
+	Value int
+}
+
+func CreateActivityShortURLIfNeeded() {
+	var maxActivityId CreateShortURLServiceMaxId
+	service.PatientReadDB().Raw("SELECT MAX(id) AS value FROM sgj_patient_activity").Scan(&maxActivityId)
+	utils.TraceLog("当前最大的活动 ID 为：%v", maxActivityId)
+	var maxShortURLId CreateShortURLServiceMaxId
+	service.PatientReadDB().Raw("SELECT MAX(id) AS value FROM sgj_patient_activity_wx_share").Scan(&maxShortURLId)
+	utils.TraceLog("当前最大的活动短链接 ID 为：%v", maxShortURLId)
+
+	if maxShortURLId.Value-maxActivityId.Value <= 300 {
+		utils.TraceLog("即将生成更多活动短链接")
+		go CreateMoreActivityShortURL(maxShortURLId.Value)
+	} else {
+		utils.TraceLog("活动短链接充足，无需生成")
+	}
+}
+
+// 新浪短链接服务示例 https://www.cnblogs.com/azure/archive/2012/08/29/WeiboAPI.html
+func CreateMoreActivityShortURL(lastShortURLID int) {
+	var maxUrlCountPerRequest int = 20
+	createCount, _ := beego.AppConfig.Int("create_short_url_count_every_time")
+	pageCount := createCount / maxUrlCountPerRequest
+	tx := service.PatientWriteDB().Begin()
+	for i := 0; i < pageCount; i++ {
+		longURLParams := make([]string, 0, maxUrlCountPerRequest)
+		for longURLIndex := 1; longURLIndex < maxUrlCountPerRequest+1; longURLIndex++ {
+			id := lastShortURLID + i*maxUrlCountPerRequest + longURLIndex
+			param := fmt.Sprintf("url_long=%v", fmt.Sprintf("%v/weixin/activity/%v", beego.AppConfig.String("weixinwebdomain"), id))
+			longURLParams = append(longURLParams, param)
+		}
+
+		urlStr := fmt.Sprintf("http://api.weibo.com/2/short_url/shorten.json?source=2849184197&%v", strings.Join(longURLParams, "&"))
+		u, _ := url.Parse(urlStr)
+		u.RawQuery = u.Query().Encode()
+		// fmt.Println(u.String())
+
+		resp, requestErr := http.Get(u.String())
+		if requestErr != nil {
+			utils.ErrorLog("http.Get error: %v", requestErr)
+			continue
+		}
+		result, readErr := ioutil.ReadAll(resp.Body)
+		resp.Body.Close()
+		if readErr != nil {
+			utils.ErrorLog("ioutil.ReadAll error: %v", readErr)
+			continue
+		}
+		// fmt.Println(string(result))
+		var respJSON map[string]interface{}
+		if err := json.Unmarshal([]byte(string(result)), &respJSON); err != nil {
+			utils.ErrorLog("json.Unmarshal error: %v\n", err)
+			continue
+		}
+		// fmt.Printf("resp: %v\n", respJSON)
+		if respJSON["error"] != nil {
+			utils.ErrorLog("request error: %v\n", respJSON)
+			continue
+		}
+
+		urlJSONs := respJSON["urls"].([]interface{})
+		now := time.Now().Unix()
+		valueStrs := make([]string, 0, len(urlJSONs))
+		values := make([]interface{}, 0, len(urlJSONs)*9)
+
+		for index, url := range urlJSONs {
+			urlJSON := url.(map[string]interface{})
+			shortURL := urlJSON["url_short"].(string)
+			id := lastShortURLID + i*maxUrlCountPerRequest + (index + 1)
+			// CreateActivityWxShareWithShortURL(id, shortURL)
+
+			// (`id`,`activity_id`,`title`,`subtitle`,`image`,`status`,`ctime`,`mtime`,`short_url`)
+			valueStrs = append(valueStrs, "(?, ?, ?, ?, ?, ?, ?, ?, ?)")
+			values = append(values, id)
+			values = append(values, id)
+			values = append(values, "")
+			values = append(values, "")
+			values = append(values, "")
+			values = append(values, 1)
+			values = append(values, now)
+			values = append(values, now)
+			values = append(values, shortURL)
+		}
+
+		sql := fmt.Sprintf("INSERT INTO sgj_patient_activity_wx_share (id, activity_id, title, subtitle, image, status, ctime, mtime, short_url) VALUES %v;", strings.Join(valueStrs, ", "))
+		if err := tx.Exec(sql, values...).Error; err != nil {
+			utils.ErrorLog("插入活动短链接失败: %v", err)
+			tx.Rollback()
+			break
+		}
+	}
+	tx.Commit()
+	utils.TraceLog("完成生成更多活动短链接")
+}
+
+func BeginCreateActivityShortURLCronJob() {
+	activityShortUrlCronJob.Start()
+}

jobcron/qiniu_job.go

@@ -0,0 +1,42 @@
+package jobcron
+
+import (
+	"SCRM/service"
+	"fmt"
+
+	"github.com/astaxie/beego"
+	"github.com/qiniu/api.v7/auth/qbox"
+	"github.com/qiniu/api.v7/storage"
+	"github.com/robfig/cron"
+)
+
+var qnTokenCronJob *cron.Cron
+
+func init() {
+	qnTokenCronJob = cron.New()
+	qnTokenCronJob.AddFunc("@every 1h50m", func() {
+		go RequestQNToken()
+	})
+}
+
+func RequestQNToken() {
+	accessKey := beego.AppConfig.String("qiniu_accesskey")
+	secretKey := beego.AppConfig.String("qiniu_secretkey")
+	bucket := beego.AppConfig.String("qiniu_bucket")
+	putPolicy := storage.PutPolicy{
+		Scope:      bucket,
+		ReturnBody: `{"url":"$(key)","hash":"$(etag)","state":"SUCCESS"}`,
+	}
+	putPolicy.Expires = 7200
+	mac := qbox.NewMac(accessKey, secretKey)
+	upToken := putPolicy.UploadToken(mac)
+	fmt.Println("new qiniu token: ", upToken)
+
+	redisClient := service.RedisClient()
+	defer redisClient.Close()
+	redisClient.Set("qn_token", upToken, 0)
+}
+
+func BeginRerequestQNTokenCronJob() {
+	qnTokenCronJob.Start()
+}

jobcron/sms_job.go

@@ -0,0 +1,24 @@
+package jobcron
+
+import (
+	"SCRM/service/sms_service"
+	"SCRM/utils"
+
+	"github.com/robfig/cron"
+)
+
+// cron表达式 https://www.cnblogs.com/zuxingyu/p/6023919.html
+var smsCronJob *cron.Cron
+
+func init() {
+	smsCronJob = cron.New()
+	spec := "0 */5 * * * ?" // 每五分钟检查一次
+	smsCronJob.AddFunc(spec, func() {
+		utils.TraceLog("定时发送未发送的短信")
+		sms_service.SMSSendUnsendBatchRealTime()
+	})
+}
+
+func BeginSendUnsendSMSCronJob() {
+	smsCronJob.Start()
+}

main.go

@@ -5,8 +5,6 @@ import (
 	_ "SCRM/routers"
 	"SCRM/service"
 
-	// "SCRM/jobcron"
-
 	"github.com/astaxie/beego"
 )
 
@@ -22,7 +20,15 @@ func main() {
 		// jobcron.RequestMpWechatAccessToken()
 		// jobcron.ReqJsapiTicket()
 	}()
+
 	jobcron.StartOpenWechatCron()
+	jobcron.BeginSendUnsendSMSCronJob()
+
+	jobcron.CreateActivityShortURLIfNeeded()
+	jobcron.BeginCreateActivityShortURLCronJob()
+
+	go jobcron.RequestQNToken()
+	jobcron.BeginRerequestQNTokenCronJob()
 
 	beego.Run()
 }

models/sms_models.go

@@ -0,0 +1,77 @@
+package models
+
+type SMSTemplate struct {
+	ID           int64  `gorm:"column:id"`
+	TemplateType int8   `gorm:"column:template_type"` // 模板类型 1.默认模板 2.自定义模板
+	TemplateID   int64  `gorm:"column:template_id"`   // 短信平台上的模板 id
+	MessageType  int8   `gorm:"column:message_type"`  // 短信类型 1.通知短信 2.服务短信
+	Content      string // 模板内容
+	// ParamTypes   string `gorm:"column:param_types"` // 字段因业务没有采用默认模板的方式而弃用了！！！！ 模板内容里的参数类型：1,2,3 。参数类型以逗号隔开，位置代表了参数‘{n+1}’，类型暂时有：1.用户名 2.商家简称 3.链接 4.商品名称 5.活动名称 6.验证码。（自定义模板是没有值的，因为它没有参数）
+	Autograph  string // 短信签名
+	OrgID      int64  `gorm:"column:org_id"` // 模板所属机构（自定义模板才有值）
+	Status     int8   // 模板状态 0.无效 1.有效 2.审核中
+	CreateTime int64  `gorm:"column:ctime"` // 创建时间
+	ModifyTime int64  `gorm:"column:mtime"` // 修改时间
+}
+
+func (SMSTemplate) TableName() string {
+	return "sgj_patient_sms_template"
+}
+
+type UserSMSFreeLimit struct {
+	ID         int64  `gorm:"column:id"`
+	OrgID      int64  `gorm:"column:org_id"`      // 机构 ID
+	TotalCount int    `gorm:"column:total_count"` // 免费额度，单位:条，下同
+	UsedCount  int    `gorm:"column:used_count"`  // 已用额度
+	ValidMonth string `gorm:"column:valid_month"` // 生效月份，格式:201804
+	Status     int8   // 状态 0.无效 1.有效
+	CreateTime int64  `gorm:"column:ctime"` // 创建时间
+	ModifyTime int64  `gorm:"column:mtime"` // 修改时间
+}
+
+func (UserSMSFreeLimit) TableName() string {
+	return "sgj_patient_user_sms_free_limit"
+}
+
+type SMSBatch struct {
+	ID          int64  `gorm:"column:id"`
+	OrgID       int64  `gorm:"column:org_id"`          // 机构 ID
+	TemplateID  int64  `gorm:"column:sms_template_id"` // 对应短信平台上的模板 ID
+	Autograph   string // 短信签名
+	Params      string // 模板参数，以“,”隔开
+	FullContent string `gorm:"column:full_content"` // 完整短信内容
+	Mobiles     string // 接收手机号，以“,”隔开
+	SendTime    int64  `gorm:"column:send_time"` // 发送时间
+	Status      int8   // 状态: 1.待审核 2.审核未通过 3.未发送 4.已发送 5.发送失败
+	CreateTime  int64  `gorm:"column:ctime"` // 创建时间
+	ModifyTime  int64  `gorm:"column:mtime"` // 修改时间
+}
+
+func (SMSBatch) TableName() string {
+	return "sgj_patient_sms_batch"
+}
+
+type SMSSendStatus struct {
+	ID         int64  `gorm:"column:id"`
+	BatchID    int64  `gorm:"batch_id"` // 批次 ID，对应 SMSBatch.ID
+	Mobile     string // 接收手机号
+	Status     int8   // 发送结果状态: 0.失败 1.成功
+	Code       string // 短信平台返回的错误码
+	Msg        string // 短信平台返回的错误信息
+	CreateTime int64  `gorm:"column:ctime"` // 创建时间
+	ModifyTime int64  `gorm:"column:mtime"` // 修改时间
+}
+
+func (SMSSendStatus) TableName() string {
+	return "sgj_patient_sms_send_status"
+}
+
+// 1.待审核 2.审核未通过 3.未发送 4.已发送 5.发送失败
+const (
+	SMSBatchStatusInReview   = int8(1)
+	SMSBatchStatusUnapproved = int8(2)
+	SMSBatchStatusUnsend     = int8(3)
+	SMSBatchStatusDidSend    = int8(4)
+	SMSBatchStatusSendFailed = int8(5)
+	SMSBatchStatusSending    = int8(6)
+)

routers/router.go

@@ -4,16 +4,17 @@ import (
 	"SCRM/controllers/admin_user"
 	"SCRM/controllers/article"
 	"SCRM/controllers/global"
+	"SCRM/controllers/kefu"
 	"SCRM/controllers/login"
 	"SCRM/controllers/marketing_tool"
 	"SCRM/controllers/members"
 	"SCRM/controllers/mpwechat"
 	"SCRM/controllers/role"
-	"SCRM/controllers/kefu"
+	"SCRM/controllers/sms"
+	"SCRM/controllers/staff"
 
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/plugins/cors"
-	"SCRM/controllers/staff"
 )
 
 func init() {
@@ -33,7 +34,7 @@ func init() {
 	marketing_tool.RegisterRouters()
 	article.RegisterRouters()
 	mpwechat.RegisterRouters()
+	sms.RegisterRouters()
 	staff.RegisterRouters()
 	kefu.RegisterRouters()
-
 }

service/member_service/member_service.go

@@ -146,3 +146,54 @@ func FindCustomerInfoByOpenid(orgID int64, openid string) (*models.UserCustomer,
 	}
 	return &cusotmer, nil
 }
+
+// 获取所有有手机号的客户（仅取部分信息！）
+func GetAllCustomersWithMobile(orgUserID int64) ([]*models.UserCustomer, error) {
+	var customer []*models.UserCustomer
+	err := service.UserReadDB().Table("sgj_user_customer AS uc").
+		Where("uc.user_org_id = ? AND uc.status=1 and uc.mobile <>'' ", orgUserID).
+		Select("uc.id, uc.name, uc.mobile").
+		Scan(&customer).
+		Error
+	return customer, err
+}
+
+// 获取指定标签下有手机号的客户（仅取部分信息！）
+func GetTagCustomersWithMobileByTagIDs(orgID int64, tagIDs []string) ([]*models.UserCustomer, error) {
+	var customer []*models.UserCustomer
+	err := service.UserReadDB().Table("sgj_user_customer AS uc").
+		Joins("JOIN sgj_user_tag_links AS tl on uc.id = tl.user_link_id").
+		Where("tl.tag_id IN (?) and tl.status = 1 and uc.user_org_id = ? and uc.status=1 and uc.mobile <>'' ", orgID, tagIDs).
+		Group("uc.id").
+		Select("uc.id, uc.name, uc.mobile").
+		Scan(&customer).
+		Error
+	return customer, err
+}
+
+// 获取指定客户ID的且有手机号的客户（仅取部分信息！）
+func GetSpecificCustomersWithMobile(orgID int64, customerIDs []string) ([]*models.UserCustomer, error) {
+	var customer []*models.UserCustomer
+	err := service.UserReadDB().Table("sgj_user_customer AS uc").
+		Where("uc.user_org_id = ? AND uc.status=1 and uc.mobile <>'' and id in (?)", orgID, customerIDs).
+		Select("uc.id, uc.name, uc.mobile").
+		Scan(&customer).
+		Error
+	return customer, err
+}
+
+func GetAllMemberList(orgID int64) (members []*Members, err error) {
+	db := service.UserReadDB().Table("sgj_user_customer as c").Where("c.user_org_id=? and c.status=1", orgID)
+
+	err = db.Order("c.created_time desc").
+		Select("c.id, c.user_org_id, c.user_id, c.mobile, c.name, c.gender, c.province_id, c.city_id, c.address, c.birthday, c.treat_type, c.relationship, c.illness_id, c.wechat_openid, c.membership, c.sources, c.status, c.created_time, c.updated_time, c.avatar, c.wechat_unionid, c.remark, c.medical_diagnose, c.yz_uid, c.ill_date, c.district_id").Find(&members).Error
+	if err != nil {
+		return
+	}
+	if len(members) > 0 {
+		for _, member := range members {
+			member.Avatar = strings.Replace(member.Avatar, "http://7xkofe.com1.z0.glb.clouddn.com", "https://images.shengws.com", 1)
+		}
+	}
+	return
+}

service/member_service/tags_service.go

@@ -170,3 +170,15 @@ func DeleteTags(orgID int64, ids []int64) (err error) {
 	}
 	return
 }
+
+// 获取 tag ids 下有手机号的客户的数量
+func GetTagUsersCountWithMobileByTagIDs(tagIDs []string) (int, error) {
+	var count int
+	err := service.UserReadDB().Table("sgj_user_customer AS uc").
+		Joins("JOIN sgj_user_tag_links AS tl on uc.id = tl.user_link_id").
+		Where("tl.tag_id IN (?) and tl.status = 1 and uc.status=1 and uc.mobile <>'' ", tagIDs).
+		Group("uc.id").
+		Count(&count).
+		Error
+	return count, err
+}

service/sms_service/sms_db_service.go

@@ -0,0 +1,116 @@
+package sms_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+	"SCRM/utils"
+	"time"
+
+	"github.com/jinzhu/gorm"
+)
+
+func GetBatchSendRecords(orgID int64, page int, count int) ([]*SMSBatchListViewModel, int, error) {
+	if count <= 0 {
+		return []*SMSBatchListViewModel{}, 0, nil
+	}
+	var viewModels []*SMSBatchListViewModel = make([]*SMSBatchListViewModel, 0)
+	readDB := service.PatientReadDB()
+	var total int
+	getTotalErr := readDB.Model(&models.SMSBatch{}).Where("org_id = ?", orgID).Count(&total).Error
+	if getTotalErr != nil {
+		return nil, 0, getTotalErr
+	}
+
+	rows, err := readDB.Raw("SELECT b.full_content, b.status, (SELECT COUNT(id) AS c FROM sgj_patient_sms_send_status WHERE batch_id = b.id) AS total_count, (SELECT COUNT(id) AS c FROM sgj_patient_sms_send_status WHERE batch_id = b.id AND STATUS = '1') AS success_count FROM sgj_patient_sms_batch AS b WHERE b.org_id = ? ORDER BY b.id LIMIT ? OFFSET ?;", orgID, count, (page-1)*count).Rows()
+	defer rows.Close()
+	if err != nil {
+		return nil, 0, err
+	}
+	for rows.Next() {
+		var viewModel SMSBatchListViewModel
+		readDB.ScanRows(rows, &viewModel)
+		viewModels = append(viewModels, &viewModel)
+	}
+	return viewModels, total, nil
+}
+
+// 获取指定模板id的模板
+func GetSMSTemplateWithTemplateID(templateID int64) (*models.SMSTemplate, error) {
+	var template models.SMSTemplate
+	err := service.PatientReadDB().Where("template_id = ? AND (status = 1 OR status = 2)", templateID).First(&template).Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, err
+		}
+	}
+	return &template, nil
+}
+
+// 获取审核中的短信批次
+func getInReviewSMSBatchWithTemplateID(templateID int) ([]*models.SMSBatch, error) {
+	var batchs []*models.SMSBatch
+	err := service.PatientReadDB().Where("sms_template_id = ? AND status = ?", templateID, models.SMSBatchStatusInReview).Find(&batchs).Error
+	if err != nil {
+		return nil, err
+	} else {
+		return batchs, nil
+	}
+}
+
+// 获取用户的免费短信额度
+func GetUserSMSFreeLimit(orgID int64, date time.Time) (*models.UserSMSFreeLimit, error) {
+	month := date.Format("200601")
+	var freeLimit models.UserSMSFreeLimit
+	if readErr := service.PatientReadDB().Where("org_id = ? AND valid_month = ?", orgID, month).First(&freeLimit).Error; readErr == gorm.ErrRecordNotFound {
+		// 创建
+		now := time.Now().Unix()
+		freeLimit = models.UserSMSFreeLimit{
+			OrgID:      orgID,
+			TotalCount: 200,
+			UsedCount:  0,
+			ValidMonth: month,
+			Status:     1,
+			CreateTime: now,
+			ModifyTime: now,
+		}
+
+		if createErr := service.PatientWriteDB().Create(&freeLimit).Error; createErr != nil {
+			utils.ErrorLog("用户短信免费额度创建失败: %v", createErr)
+			return nil, createErr
+		} else {
+			return &freeLimit, nil
+		}
+
+	} else if readErr != nil {
+		utils.ErrorLog("获取用户短信免费额度信息失败: %v", readErr)
+		return nil, readErr
+
+	} else {
+		return &freeLimit, nil
+	}
+}
+
+// 获取未发送的短信批次
+func GetUnsendSMSBatch() ([]*models.SMSBatch, error) {
+	var batchs []*models.SMSBatch
+	err := service.PatientReadDB().Where("status = ?", models.SMSBatchStatusUnsend).Find(&batchs).Error
+	if err != nil {
+		if err == gorm.ErrRecordNotFound {
+			return nil, nil
+		} else {
+			return nil, err
+		}
+	} else {
+		return batchs, nil
+	}
+}
+
+func DisableTemplate(templateID int64) error {
+	err := service.PatientWriteDB().Model(&models.SMSTemplate{}).Where("template_id = ?", templateID).Updates(map[string]interface{}{
+		"status": 0,
+		"mtime":  time.Now().Unix(),
+	}).Error
+	return err
+}

service/sms_service/sms_service.go

@@ -0,0 +1,325 @@
+package sms_service
+
+import (
+	"SCRM/models"
+	base "SCRM/service"
+	"SCRM/utils"
+	"errors"
+	"fmt"
+	"math"
+	"strings"
+	"time"
+
+	"github.com/astaxie/beego"
+	"github.com/jinzhu/gorm"
+)
+
+// 发送验证码短信
+func SMSSendVerificationCode(mobile string) (string, error) {
+	if len(mobile) == 0 {
+		return "", errors.New("手机号为空")
+	}
+
+	code_str := utils.RandomNumberString(6)
+	templateID, _ := beego.AppConfig.Int("sms_verification_code_templateid")
+	_, _, _, err := singleSendMessageUseUCPaas(templateID, []string{code_str}, mobile)
+	return code_str, err
+}
+
+// 成为机构管理员的邀请短信
+func SMSSendInviteMobileToJoinOrgAdmin(name string, mobile string, password string) error {
+	if len(mobile) == 0 {
+		return errors.New("手机号为空")
+	}
+	if len(password) == 0 {
+		_, _, _, err := singleSendMessageUseUCPaas(332784, []string{name, mobile}, mobile)
+		return err
+	} else {
+		_, _, _, err := singleSendMessageUseUCPaas(332783, []string{name, mobile, password}, mobile)
+		return err
+	}
+}
+
+var (
+	SMSErrorFreeLimitInsufficient = errors.New("短信额度不足")
+)
+
+// 发送自定义内容短信，content 不需要包括签名及“退订请回复TD”字样
+/* 流程说明：
+检查额度 -> 创建短信平台模板 -> 创建数据库短信模板(待审核状态) -> 创建发送批次(待审核状态) -> 扣除额度 -> finish
+*/
+func SMSOrgSendWithCustomContent(orgID int64, originContent string, mobiles []string) error {
+	if len(mobiles) == 0 {
+		return nil
+	}
+
+	autograph := "酷医聚客"
+	content := fmt.Sprintf("%v退订请回复TD", originContent)
+	fullContent := fmt.Sprintf("【%v】%v", autograph, content)
+	if len(fullContent) > 500 {
+		return errors.New("短信太长")
+	}
+
+	willConsumeLimit := GetWillConsumeLimit(fullContent, len(mobiles))
+	freeLimit, getFreeLimitErr := GetUserSMSFreeLimit(orgID, time.Now())
+	if getFreeLimitErr != nil {
+		return getFreeLimitErr
+	}
+	if willConsumeLimit+freeLimit.UsedCount > freeLimit.TotalCount {
+		return SMSErrorFreeLimitInsufficient
+	}
+
+	smsTplID, createSMSTplErr := createTemplate2UCPaas(autograph, content, 5)
+	if createSMSTplErr != nil {
+		return createSMSTplErr
+	}
+
+	template := models.SMSTemplate{
+		TemplateType: 2,
+		TemplateID:   int64(smsTplID),
+		MessageType:  2,
+		Content:      content,
+		Autograph:    autograph,
+		OrgID:        orgID,
+		Status:       2,
+		CreateTime:   time.Now().Unix(),
+		ModifyTime:   time.Now().Unix(),
+	}
+
+	tx := base.PatientWriteDB().Begin()
+	if createTplErr := tx.Save(&template).Error; createTplErr != nil {
+		tx.Rollback()
+		return createTplErr
+	}
+
+	sendTime := time.Now()
+	batch := &models.SMSBatch{
+		OrgID:       orgID,
+		Autograph:   autograph,
+		FullContent: fullContent,
+		Mobiles:     strings.Join(mobiles, ","),
+		TemplateID:  int64(smsTplID),
+		SendTime:    sendTime.Unix(),
+		Status:      models.SMSBatchStatusInReview,
+		CreateTime:  time.Now().Unix(),
+		ModifyTime:  time.Now().Unix(),
+	}
+	if createBatchErr := tx.Save(batch).Error; createBatchErr != nil {
+		tx.Rollback()
+		return createBatchErr
+	}
+
+	freeLimit.UsedCount += willConsumeLimit
+	freeLimit.ModifyTime = time.Now().Unix()
+	updateLimitErr := tx.Save(freeLimit).Error
+	if updateLimitErr != nil {
+		tx.Rollback()
+		return updateLimitErr
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 计算即将消耗的额度 (smsFullContent 包含签名在内)
+func GetWillConsumeLimit(smsFullContent string, mobileCount int) int {
+	limitEachMessage := math.Ceil(float64(len(smsFullContent)) / 67.0)
+	return int(limitEachMessage) * mobileCount
+}
+
+// 短信平台模板审核成功
+/* 流程说明
+更新数据库模板状态(有效) -> 更新对应发送批次状态(待发送) -> finish
+*/
+func SMSUCPaasTemplateApproved(templateID int64) error {
+	tx := base.PatientWriteDB().Begin()
+
+	updateTplErr := tx.Model(&models.SMSTemplate{}).Where("template_id = ?", templateID).Updates(map[string]interface{}{
+		"status": 1,
+		"mtime":  time.Now().Unix(),
+	}).Error
+	if updateTplErr != nil {
+		tx.Rollback()
+		return updateTplErr
+	}
+
+	updateBatchErr := tx.Model(&models.SMSBatch{}).Where("sms_template_id = ?", templateID).Updates(map[string]interface{}{
+		"status": models.SMSBatchStatusUnsend,
+		"mtime":  time.Now().Unix(),
+	}).Error
+	if updateBatchErr != nil {
+		tx.Rollback()
+		return updateBatchErr
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 短信平台模板审核失败
+/* 流程说明
+更新数据库模板状态(无效) -> 更新对应发送批次状态(审核未通过) -> 返回发送当月的额度 -> finish
+*/
+func SMSUCPaasTemplateUnapproved(templateID int64) error {
+	var batch models.SMSBatch
+	getBatchErr := base.PatientReadDB().Model(&models.SMSBatch{}).Where("sms_template_id = ?", templateID).First(&batch).Error
+	if getBatchErr != nil {
+		if getBatchErr != gorm.ErrRecordNotFound {
+			return getBatchErr
+		}
+	}
+
+	tx := base.PatientWriteDB().Begin()
+
+	updateTplErr := tx.Model(&models.SMSTemplate{}).Where("template_id = ?", templateID).Updates(map[string]interface{}{
+		"status": 0,
+		"mtime":  time.Now().Unix(),
+	}).Error
+	if updateTplErr != nil {
+		tx.Rollback()
+		return updateTplErr
+	}
+
+	if batch.ID > 0 {
+		batch.Status = models.SMSBatchStatusUnapproved
+		batch.ModifyTime = time.Now().Unix()
+		updateBatchErr := tx.Save(&batch).Error
+		if updateBatchErr != nil {
+			tx.Rollback()
+			return updateBatchErr
+		}
+
+		freeLimit, getFreeLimitErr := GetUserSMSFreeLimit(batch.OrgID, time.Unix(batch.SendTime, 0))
+		if getFreeLimitErr != nil {
+			tx.Rollback()
+			return getFreeLimitErr
+		}
+
+		mobiles := strings.Split(batch.Mobiles, ",")
+		consumedLimit := GetWillConsumeLimit(batch.FullContent, len(mobiles))
+		freeLimit.UsedCount -= consumedLimit
+		freeLimit.ModifyTime = time.Now().Unix()
+		updateFreeLimitErr := tx.Save(freeLimit).Error
+		if updateFreeLimitErr != nil {
+			tx.Rollback()
+			return updateFreeLimitErr
+		}
+	}
+
+	tx.Commit()
+	return nil
+}
+
+// 发送“未发送”批次的短信
+// 备注：因短信平台每次群发限制 100 个号码，所以同一个批次可能需要分成多次发送
+func SMSSendUnsendBatchRealTime() {
+	batchs, getBatchErr := GetUnsendSMSBatch()
+	if getBatchErr != nil {
+		return
+	}
+
+	for _, batch := range batchs {
+		tx := base.PatientWriteDB().Begin()
+
+		isSendSuccess := false
+		failMobileCount := 0
+		reports := []interface{}{}
+
+		mobiles := strings.Split(batch.Mobiles, ",")
+		subbatchCount := int(math.Ceil(float64(len(mobiles)) / 100.0))
+		for index := 0; index < subbatchCount; index++ {
+			var subMobiles []string
+			if len(mobiles)-index*100 >= 100 {
+				subMobiles = mobiles[index*100 : 100]
+			} else {
+				subMobiles = mobiles[index*100:]
+			}
+
+			sendCount, report, sendErr := batchSendMessageUseUCPaas(int(batch.TemplateID), nil, subMobiles)
+			if sendErr != nil {
+				utils.ErrorLog("%v", sendErr)
+				failMobileCount += len(subMobiles)
+
+			} else {
+				isSendSuccess = true // 只要子批次有一次发送成功，就认为这个批次发送成功
+				reports = append(reports, report)
+				failMobileCount += len(subMobiles) - sendCount
+			}
+		}
+
+		if isSendSuccess {
+			batch.Status = models.SMSBatchStatusDidSend
+			batch.ModifyTime = time.Now().Unix()
+			updateBatchErr := tx.Save(batch).Error
+			if updateBatchErr != nil {
+				utils.ErrorLog("群发短信成功后 更新批次状态失败：%v", updateBatchErr)
+				tx.Rollback()
+				continue
+			}
+
+			valueStrs := make([]string, 0, len(reports))
+			values := make([]interface{}, 0, len(reports))
+			for _, item := range reports {
+				json := item.(map[string]interface{})
+				valueStrs = append(valueStrs, "(?, ?, ?, ?, ?, ?, ?)")
+
+				values = append(values, batch.ID)
+				values = append(values, json["mobile"])
+				if json["code"].(string) == "000000" {
+					values = append(values, 1)
+				} else {
+					values = append(values, 0)
+				}
+				values = append(values, json["code"])
+				values = append(values, json["msg"])
+				values = append(values, time.Now().Unix())
+				values = append(values, time.Now().Unix())
+			}
+			sql := fmt.Sprintf("INSERT INTO sgj_patient_sms_send_status (batch_id, mobile, status, code, msg, ctime, mtime) VALUES %v;", strings.Join(valueStrs, ", "))
+			if insertReportErr := tx.Exec(sql, values...).Error; insertReportErr != nil {
+				utils.ErrorLog("群发短信成功后 插入短信发送状态失败: %v", insertReportErr)
+				tx.Rollback()
+				continue
+			}
+
+			if failMobileCount > 0 {
+				freeLimit, getFreeLimitErr := GetUserSMSFreeLimit(batch.OrgID, time.Unix(batch.SendTime, 0))
+				if getFreeLimitErr == nil {
+					freeLimit.UsedCount -= GetWillConsumeLimit(batch.FullContent, failMobileCount)
+					freeLimit.ModifyTime = time.Now().Unix()
+					updateLimitErr := tx.Save(freeLimit).Error
+					if updateLimitErr != nil {
+						utils.ErrorLog("群发短信成功后 返回额度失败: %v", updateLimitErr)
+						tx.Rollback()
+						continue
+					}
+				}
+			}
+			tx.Commit()
+
+		} else {
+			batch.Status = models.SMSBatchStatusSendFailed
+			batch.ModifyTime = time.Now().Unix()
+			updateBatchErr := tx.Save(batch).Error
+			if updateBatchErr != nil {
+				utils.ErrorLog("群发短信成功后 更新批次状态失败：%v", updateBatchErr)
+				tx.Rollback()
+				continue
+			}
+
+			freeLimit, getFreeLimitErr := GetUserSMSFreeLimit(batch.OrgID, time.Unix(batch.SendTime, 0))
+			if getFreeLimitErr == nil {
+				freeLimit.UsedCount -= GetWillConsumeLimit(batch.FullContent, len(mobiles))
+				freeLimit.ModifyTime = time.Now().Unix()
+				updateLimitErr := tx.Save(freeLimit).Error
+				if updateLimitErr != nil {
+					utils.ErrorLog("群发短信成功后 返回额度失败: %v", updateLimitErr)
+					tx.Rollback()
+					continue
+				}
+			}
+
+			tx.Commit()
+		}
+	}
+}

service/sms_service/sms_vms.go

@@ -0,0 +1,8 @@
+package sms_service
+
+type SMSBatchListViewModel struct {
+	FullContent  string `json:"full_content"`  // 发送内容
+	Status       int8   `json:"status"`        // 批次状态 （值同 sms_models 中的 SMSBatchStatuss）
+	TotalCount   int    `json:"total_count"`   // 发送人数
+	SuccessCount int    `json:"success_count"` // 到达条数
+}

service/sms_service/ucpaas.go

@@ -0,0 +1,164 @@
+package sms_service
+
+import (
+	"SCRM/utils"
+	"bytes"
+	"encoding/json"
+	"errors"
+	"io/ioutil"
+	"net/http"
+	"strconv"
+	"strings"
+
+	"github.com/astaxie/beego"
+)
+
+// 获取短信平台信息
+func getUCPaasConfig() (string, string, string) {
+	return beego.AppConfig.String("sms_appId"),
+		beego.AppConfig.String("sms_sid"),
+		beego.AppConfig.String("sms_token")
+}
+
+// 向云之讯短信平台创建模板，返回新模板的 ID
+// autograph: 签名，即为机构简称
+// content: 模板内容
+// type_: 短信类型：0:通知短信 5:会员服务短信
+func createTemplate2UCPaas(autograph string, content string, type_ int) (int, error) {
+	sms_api := beego.AppConfig.String("sms_baseUrl") + "addsmstemplate"
+	appID, sid, token := getUCPaasConfig()
+	params := make(map[string]interface{})
+	params["appid"] = appID
+	params["sid"] = sid
+	params["token"] = token
+	params["type"] = type_
+	params["autograph"] = autograph
+	params["content"] = content
+
+	paramsBytes, _ := json.Marshal(params)
+	resp, requestErr := http.Post(sms_api, "application/json", bytes.NewBuffer(paramsBytes))
+
+	if requestErr != nil {
+		utils.ErrorLog("短信平台增加模板接口调用失败: %v", requestErr)
+		return 0, requestErr
+	}
+	defer resp.Body.Close()
+	body, ioErr := ioutil.ReadAll(resp.Body)
+	if ioErr != nil {
+		utils.ErrorLog("短信平台增加模板接口返回数据读取失败: %v", ioErr)
+		return 0, ioErr
+	}
+	var respJSON map[string]interface{}
+	utils.InfoLog(string(body))
+	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+		utils.ErrorLog("短信平台增加模板接口返回数据解析JSON失败: %v", err)
+		return 0, err
+	}
+	if respJSON["code"].(string) != "000000" {
+		msg := respJSON["msg"].(string)
+		utils.ErrorLog("短信平台增加模板接口请求失败: %v", msg)
+		return 0, errors.New("短信平台增加模板接口请求失败")
+	}
+
+	templateID, _ := strconv.Atoi(respJSON["templateid"].(string))
+	utils.SuccessLog("新短信模板 ID: %v", templateID)
+	return templateID, nil
+}
+
+// 用云之讯群发模板短信
+// 返回值为发送了 n 条短信
+func batchSendMessageUseUCPaas(templateID int, params []string, mobiles []string) (int, []interface{}, error) {
+	sms_api := beego.AppConfig.String("sms_baseUrl") + "sendsms_batch"
+	mobileStr := strings.Join(mobiles, ",")
+	appID, sid, token := getUCPaasConfig()
+	requestParams := make(map[string]interface{})
+	requestParams["appid"] = appID
+	requestParams["sid"] = sid
+	requestParams["token"] = token
+	requestParams["templateid"] = strconv.Itoa(templateID)
+	requestParams["mobile"] = mobileStr
+	if params != nil && len(params) != 0 {
+		paramStr := strings.Join(params, ",")
+		requestParams["param"] = paramStr
+	}
+
+	paramsBytes, _ := json.Marshal(requestParams)
+	resp, requestErr := http.Post(sms_api, "application/json", bytes.NewBuffer(paramsBytes))
+
+	if requestErr != nil {
+		utils.ErrorLog("短信平台模板群发接口调用失败: %v", requestErr)
+		return 0, nil, requestErr
+	}
+	defer resp.Body.Close()
+	body, ioErr := ioutil.ReadAll(resp.Body)
+	if ioErr != nil {
+		utils.ErrorLog("短信平台模板群发接口返回数据读取失败: %v", ioErr)
+		return 0, nil, ioErr
+	}
+	var respJSON map[string]interface{}
+	utils.InfoLog(string(body))
+	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+		utils.ErrorLog("短信平台模板群发接口返回数据解析JSON失败: %v", err)
+		return 0, nil, err
+	}
+	if respJSON["code"].(string) != "000000" {
+		msg := respJSON["msg"].(string)
+		utils.ErrorLog("短信平台模板群发接口请求失败: %v", msg)
+		return 0, nil, errors.New("短信平台模板群发接口请求失败")
+
+	} else {
+		utils.SuccessLog("短信发送成功 report: %v", respJSON["report"])
+		if len(mobiles) > 1 {
+			count, _ := strconv.Atoi(respJSON["count_sum"].(string))
+			return count, respJSON["report"].([]interface{}), nil
+		} else {
+			return 1, nil, nil
+		}
+	}
+}
+
+// 用云之讯单发模板短信
+// 返回值分别是 是否成功，code，msg，error
+func singleSendMessageUseUCPaas(templateID int, params []string, mobile string) (bool, string, string, error) {
+	sms_api := beego.AppConfig.String("sms_baseUrl") + "sendsms"
+	appID, sid, token := getUCPaasConfig()
+	requestParams := make(map[string]interface{})
+	requestParams["appid"] = appID
+	requestParams["sid"] = sid
+	requestParams["token"] = token
+	requestParams["templateid"] = strconv.Itoa(templateID)
+	requestParams["mobile"] = mobile
+	if params != nil && len(params) != 0 {
+		paramStr := strings.Join(params, ",")
+		requestParams["param"] = paramStr
+	}
+
+	paramsBytes, _ := json.Marshal(requestParams)
+	resp, requestErr := http.Post(sms_api, "application/json", bytes.NewBuffer(paramsBytes))
+
+	if requestErr != nil {
+		utils.ErrorLog("短信平台模板群发接口调用失败: %v", requestErr)
+		return false, "", "", requestErr
+	}
+	defer resp.Body.Close()
+	body, ioErr := ioutil.ReadAll(resp.Body)
+	if ioErr != nil {
+		utils.ErrorLog("短信平台模板群发接口返回数据读取失败: %v", ioErr)
+		return false, "", "", ioErr
+	}
+	var respJSON map[string]interface{}
+	utils.InfoLog(string(body))
+	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+		utils.ErrorLog("短信平台模板群发接口返回数据解析JSON失败: %v", err)
+		return false, "", "", err
+	}
+	if respJSON["code"].(string) != "000000" {
+		msg := respJSON["msg"].(string)
+		utils.ErrorLog("短信平台模板群发接口请求失败: %v", msg)
+		return false, "", "", errors.New("短信平台模板群发接口请求失败")
+
+	} else {
+		utils.SuccessLog("短信发送成功")
+		return true, respJSON["code"].(string), respJSON["msg"].(string), nil
+	}
+}

service/tencentim_service/user_service.go

@@ -0,0 +1,25 @@
+package tencentim_service
+
+import (
+	"SCRM/service"
+)
+
+type InfoMap struct {
+	Cname      string
+	Name       string
+	Image      string
+	Uid        int64
+	Identifier string
+}
+
+func GetImUserMap(accountKey []string, userOrgID int64) (infoMap []InfoMap) {
+	service.UserReadDB().Table("sgj_user_user_im AS ui").
+		Joins("JOIN sgj_user_user AS u ON u.id = ui.user_id").
+		Joins("LEFT JOIN sgj_user_customer AS c ON c.user_id = ui.user_id AND c.user_org_id=? and c.status=1 and c.user_id>0 ", userOrgID).
+		Where("ui.identifier IN (?)", accountKey).
+		Select("ui.identifier, u.username as name, u.avatar as image, c.name as cname, u.id as uid").
+		Scan(&infoMap)
+
+	return
+
+}