短信记录

controllers/sms/router_collector.go

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

controllers/sms/sms_controller.go

@@ -0,0 +1,39 @@
+package sms
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/service/sms_service"
+
+	"github.com/astaxie/beego"
+)
+
+func SMSCtlRegistRouters() {
+	beego.Router("/api/sms/records", &SMSController{}, "get:GetSendRecords")
+}
+
+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,
+	})
+}

controllers/短信模块临时备注

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

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.服务短信 3.验证码短信
+	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

@@ -9,6 +9,7 @@ import (
 	"SCRM/controllers/members"
 	"SCRM/controllers/mpwechat"
 	"SCRM/controllers/role"
+	"SCRM/controllers/sms"
 
 	"github.com/astaxie/beego"
 	"github.com/astaxie/beego/plugins/cors"
@@ -31,4 +32,5 @@ func init() {
 	marketing_tool.RegisterRouters()
 	article.RegisterRouters()
 	mpwechat.RegisterRouters()
+	sms.RegisterRouters()
 }

service/sms_service/sms_service.go

@@ -0,0 +1,31 @@
+package sms_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+)
+
+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
+}

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"` // 到达条数
+}