会员管理-列表

.gitignore

@@ -0,0 +1 @@
+/*.exe

controllers/members/members_controller.go

@@ -0,0 +1,93 @@
+package members
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/service/member_service"
+	"SCRM/utils"
+
+	"github.com/astaxie/beego"
+)
+
+func MemberCtlRegistRouters() {
+	beego.Router("/api/members", &MembersAPIController{}, "get:GetMembers")
+}
+
+type MembersAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *MembersAPIController) GetMembers() {
+	page, _ := c.GetInt64("page", 1)
+	limit, _ := c.GetInt64("limit", 10)
+	startTime := c.GetString("start_time", "")
+	endTime := c.GetString("end_time", "")
+	searchKey := c.GetString("search", "")
+	level, _ := c.GetInt64("level", 0)
+	source, _ := c.GetInt64("source", 0)
+	tag, _ := c.GetInt64("tag", 0)
+	init, _ := c.GetInt64("init", 0)
+
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+
+	adminUserInfo := c.GetAdminUserInfo()
+
+	timeLayout := "2006-01-02 15:04:05"
+
+	var isStartTime bool
+	var theStartTIme int64
+	if len(startTime) > 0 {
+		theTime, err := utils.ParseTimeStringToTime(timeLayout, startTime+" 00:00:00")
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "开始时间错误")
+			return
+		}
+		isStartTime = true
+		theStartTIme = theTime.Unix()
+	}
+	var isEndTime bool
+	var theEndtTIme int64
+	if len(endTime) > 0 {
+		theTime, err := utils.ParseTimeStringToTime(timeLayout, endTime+" 23:59:59")
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "结束时间错误")
+			return
+		}
+		isEndTime = true
+		theEndtTIme = theTime.Unix()
+	}
+
+	members, total, err := member_service.GetMemberList(adminUserInfo.CurrentOrgId, page, limit, level, source, tag, theStartTIme, theEndtTIme, isStartTime, isEndTime, searchKey)
+
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取会员列表失败")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	if init == 1 {
+		cards, err := member_service.GetCardList(adminUserInfo.CurrentOrgId)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取会员卡列表失败")
+			return
+		}
+		returnData["cards"] = cards
+
+		tags, err := member_service.GetTagList(adminUserInfo.CurrentOrgId)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDataException, "获取标签列表失败")
+			return
+		}
+		returnData["tags"] = tags
+	}
+	returnData["members"] = members
+	returnData["total"] = total
+
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/members/router_controller.go

@@ -0,0 +1,5 @@
+package members
+
+func RegisterRouters() {
+	MemberCtlRegistRouters()
+}

models/user_customer_models.go

@@ -0,0 +1,35 @@
+package models
+
+type UserCustomer struct {
+	ID              int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId       int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId          int64  `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	Mobile          string `gorm:"column:mobile" json:"mobile" form:"mobile"`
+	Name            string `gorm:"column:name" json:"name" form:"name"`
+	Gender          int64  `gorm:"column:gender" json:"gender" form:"gender"`
+	ProvinceId      int64  `gorm:"column:province_id" json:"province_id" form:"province_id"`
+	CityId          int64  `gorm:"column:city_id" json:"city_id" form:"city_id"`
+	Address         string `gorm:"column:address" json:"address" form:"address"`
+	Birthday        int64  `gorm:"column:birthday" json:"birthday" form:"birthday"`
+	TreatType       int64  `gorm:"column:treat_type" json:"treat_type" form:"treat_type"`
+	Relationship    int64  `gorm:"column:relationship" json:"relationship" form:"relationship"`
+	IllnessId       int64  `gorm:"column:illness_id" json:"illness_id" form:"illness_id"`
+	WechatOpenid    string `gorm:"column:wechat_openid" json:"wechat_openid" form:"wechat_openid"`
+	Membership      int64  `gorm:"column:membership" json:"membership" form:"membership"`
+	Sources         int64  `gorm:"column:sources" json:"sources" form:"sources"`
+	Status          int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime     int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime     int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Avatar          string `gorm:"column:avatar" json:"avatar" form:"avatar"`
+	WechatUnionid   string `gorm:"column:wechat_unionid" json:"wechat_unionid" form:"wechat_unionid"`
+	Remark          string `gorm:"column:remark" json:"remark" form:"remark"`
+	MedicalDiagnose string `gorm:"column:medical_diagnose" json:"medical_diagnose" form:"medical_diagnose"`
+	YzUid           int64  `gorm:"column:yz_uid" json:"yz_uid" form:"yz_uid"`
+	Tttime          int64  `gorm:"column:tttime" json:"tttime" form:"tttime"`
+	IllDate         int64  `gorm:"column:ill_date" json:"ill_date" form:"ill_date"`
+	DistrictId      int64  `gorm:"column:district_id" json:"district_id" form:"district_id"`
+}
+
+func (UserCustomer) TableName() string {
+	return "sgj_user_customer"
+}

models/user_membership_card_models.go

@@ -0,0 +1,21 @@
+package models
+
+type UserMembershipCard struct {
+	ID              int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId       int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	CardName        string `gorm:"column:card_name" json:"card_name" form:"card_name"`
+	CardLevel       int64  `gorm:"column:card_level" json:"card_level" form:"card_level"`
+	UpgradeIntegral int64  `gorm:"column:upgrade_integral" json:"upgrade_integral" form:"upgrade_integral"`
+	CardRight       string `gorm:"column:card_right" json:"card_right" form:"card_right"`
+	UseNotice       string `gorm:"column:use_notice" json:"use_notice" form:"use_notice"`
+	BackgroundType  int64  `gorm:"column:background_type" json:"background_type" form:"background_type"`
+	Background      string `gorm:"column:background" json:"background" form:"background"`
+	ServicePhone    string `gorm:"column:service_phone" json:"service_phone" form:"service_phone"`
+	Status          int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime     int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime     int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+func (UserMembershipCard) TableName() string {
+	return "sgj_user_membership_card"
+}

models/user_tag_models.go

@@ -0,0 +1,14 @@
+package models
+
+type UserTags struct {
+	ID          int64  `gorm:"column:id" json:"id" form:"id"`
+	TagName     string `gorm:"column:tag_name" json:"tag_name" form:"tag_name"`
+	UserOrgId   int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	Status      int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+func (UserTags) TableName() string {
+	return "sgj_user_tags"
+}

routers/router.go

@@ -4,6 +4,7 @@ import (
 	"SCRM/controllers/admin_user"
 	"SCRM/controllers/global"
 	"SCRM/controllers/login"
+	"SCRM/controllers/members"
 	"SCRM/controllers/role"
 
 	"github.com/astaxie/beego"
@@ -23,4 +24,5 @@ func init() {
 	admin_user.RegisterRouters()
 	login.RegisterRouters()
 	role.RegisterRouters()
+	members.RegisterRouters()
 }

service/member_service/cards_service.go

@@ -0,0 +1,12 @@
+package member_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+)
+
+func GetCardList(orgID int64) (cards []*models.UserMembershipCard, err error) {
+	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("status=1 and user_org_id=?", orgID).Order("card_level asc, id asc ").Find(&cards).Error
+
+	return
+}

service/member_service/member_service.go

@@ -0,0 +1,41 @@
+package member_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+	"strings"
+)
+
+func GetMemberList(orgID, page, limit, level, source, tag, startTime, endTime int64, isStartTime, isEndTime bool, searchKey string) (members []*Members, total int64, err error) {
+	db := service.UserReadDB().Model(&models.UserCustomer{}).Where("status=1")
+	if orgID > 0 {
+		db = db.Where("user_org_id=?", orgID)
+	}
+	if source > 0 {
+		db = db.Where("sources=?", source)
+	}
+
+	if isStartTime {
+		db = db.Where("created_time>=?", startTime)
+	}
+	if isEndTime {
+		db = db.Where("created_time<=?", endTime)
+	}
+	if len(searchKey) > 0 {
+		searchKey = "%" + searchKey + "%"
+		db = db.Where("name LIKE ? OR mobile LIKE ? ", searchKey, searchKey)
+	}
+
+	offset := (page - 1) * limit
+	err = db.Count(&total).Order("id desc").Offset(offset).Limit(limit).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/models.go

@@ -0,0 +1,11 @@
+package member_service
+
+import (
+	"SCRM/models"
+)
+
+type Members struct {
+	models.UserCustomer
+
+	// Tags         []tags `gorm:"many2many:user_languages;"`
+}

service/member_service/tags_service.go

@@ -0,0 +1,12 @@
+package member_service
+
+import (
+	"SCRM/models"
+	"SCRM/service"
+)
+
+func GetTagList(orgID int64) (tags []*models.UserTags, err error) {
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("status=1 and user_org_id=?", orgID).Order("id asc").Find(&tags).Error
+
+	return
+}