会员管理：编辑会员，单个会员设置标签，批量会员添加标签、删除，会员删除，会员设置会员卡

controllers/members/card_controller.go

@@ -0,0 +1,103 @@
+package members
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/member_service"
+	"time"
+
+	"fmt"
+
+	"github.com/astaxie/beego"
+	"github.com/bwmarrin/snowflake"
+)
+
+func CardCtlRegistRouters() {
+	beego.Router("/api/member/card/edit", &CardAPIController{}, "Put:EditMemberCard")
+}
+
+type CardAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *CardAPIController) EditMemberCard() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	cardID, _ := c.GetInt64("card_id", 0)
+	if cardID <= 0 { //设置为无卡
+		cardID = 0
+	}
+	adminUserInfo := c.GetAdminUserInfo()
+	timeNow := time.Now().Unix()
+	member, err := member_service.GetOnlyMemberByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+		return
+	}
+	if member == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（会员记录不存在）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	if cardID == 0 {
+		err = member_service.DeleteUserCard(adminUserInfo.CurrentOrgId, id)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		returnData["user_card"] = nil
+	} else {
+
+		card, err := member_service.GetCardByID(adminUserInfo.CurrentOrgId, cardID)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		if card == nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（会员卡不存在）")
+			return
+		}
+
+		oldUserCard, err := member_service.GetUserCardByID(adminUserInfo.CurrentOrgId, id)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		var userCard models.UserCard
+		if oldUserCard != nil {
+			userCard = *oldUserCard
+		} else {
+			node, err := snowflake.NewNode(1)
+			if err != nil {
+				c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（生成卡号时出错）")
+				return
+			}
+			cardNo := node.Generate()
+
+			userCard.CardId = card.ID
+			userCard.CardName = card.CardName
+			userCard.CustomerId = id
+			userCard.UserOrgId = adminUserInfo.CurrentOrgId
+			userCard.CreatedTime = timeNow
+			userCard.CardNo = fmt.Sprintf("%s", cardNo)
+		}
+
+		userCard.UpdatedTime = timeNow
+		userCard.Status = 1
+		err = member_service.SaveUserCard(&userCard, member)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "设置会员卡失败:（"+err.Error()+"）")
+			return
+		}
+		returnData["user_card"] = userCard
+		returnData["member"] = member
+	}
+
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/members/members_controller.go

@@ -17,6 +17,8 @@ import (
 func MemberCtlRegistRouters() {
 	beego.Router("/api/members", &MembersAPIController{}, "get:GetMembers")
 	beego.Router("/api/member/create", &MembersAPIController{}, "Post:CreateMember")
+	beego.Router("/api/member/edit", &MembersAPIController{}, "Put:EditMember")
+	beego.Router("/api/members/delete", &MembersAPIController{}, "Delete:DeleteMembers")
 }
 
 type MembersAPIController struct {
@@ -350,3 +352,287 @@ func (c *MembersAPIController) CreateMember() {
 	return
 
 }
+
+func (c *MembersAPIController) EditMember() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	adminUserInfo := c.GetAdminUserInfo()
+
+	member, err := member_service.GetOnlyMemberByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+		return
+	}
+	if member == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（会员记录不存在）")
+		return
+	}
+
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err = json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	if dataBody["name"] == nil || reflect.TypeOf(dataBody["name"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:姓名")
+		return
+	}
+	name, _ := dataBody["name"].(string)
+	if len(name) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "姓名不能为空")
+		return
+	}
+	member.Name = name
+
+	if dataBody["mobile"] == nil || reflect.TypeOf(dataBody["mobile"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:手机号")
+		return
+	}
+	mobile, _ := dataBody["mobile"].(string)
+	if len(mobile) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机号不能为空")
+		return
+	}
+	if !utils.CheckMobile(mobile) {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "手机号格式不正确")
+		return
+	}
+	changeMobile := true
+	if member.Mobile == mobile {
+		changeMobile = false
+	}
+	member.Mobile = mobile
+
+	if dataBody["gender"] == nil || reflect.TypeOf(dataBody["gender"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:性别")
+		return
+	}
+	gender := int64(dataBody["gender"].(float64))
+
+	if gender != 1 && gender != 2 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "性别选择不正确")
+		return
+	}
+	member.Gender = gender
+
+	if dataBody["birthday"] == nil || reflect.TypeOf(dataBody["birthday"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:生日")
+		return
+	}
+	birthday, _ := dataBody["birthday"].(string)
+	if len(birthday) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
+		return
+	}
+
+	timeLayout := "2006-01-02 15:04:05"
+	theTime, err := utils.ParseTimeStringToTime(timeLayout, birthday+" 00:00:00")
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "生日格式不正确")
+		return
+	}
+	member.Birthday = theTime.Unix()
+
+	if dataBody["province_id"] == nil || reflect.TypeOf(dataBody["province_id"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区（省）")
+		return
+	}
+	provinceID := int64(dataBody["province_id"].(float64))
+	if provinceID <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
+		return
+	}
+	member.ProvinceId = provinceID
+
+	if dataBody["city_id"] == nil || reflect.TypeOf(dataBody["city_id"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区（市）")
+		return
+	}
+	cityID := int64(dataBody["city_id"].(float64))
+	if cityID <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
+		return
+	}
+	member.CityId = cityID
+
+	if dataBody["district_id"] == nil || reflect.TypeOf(dataBody["district_id"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:地区（区/县）")
+		return
+	}
+	districtID := int64(dataBody["district_id"].(float64))
+	if districtID <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择地区")
+		return
+	}
+	member.DistrictId = districtID
+
+	if dataBody["illness"] == nil || reflect.TypeOf(dataBody["illness"]).String() != "[]interface {}" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:病种")
+		return
+	}
+	illnessInters := dataBody["illness"].([]interface{})
+	if len(illnessInters) <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择病种")
+		return
+	}
+	member.Illness = make([]*member_service.CustomerIllness, 0)
+	illnessIDS := make([]int64, 0)
+	illnessIDMap := make(map[int64]int64, 0)
+	for _, illnessInter := range illnessInters {
+		id := int64(illnessInter.(float64))
+		illnessIDS = append(illnessIDS, id)
+		illnessIDMap[id] = id
+	}
+	allIllness, err := member_service.GetMemberAllIllness(adminUserInfo.CurrentOrgId, member.ID)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+		return
+	}
+	oldIllIDMap := make(map[int64]int64, 0)
+	for _, illItem := range allIllness {
+		item := *illItem
+		item.Status = 1
+		if _, exist := illnessIDMap[item.IllnessId]; !exist {
+			item.Status = 0
+			item.UpdatedTime = timeNow
+		}
+		member.Illness = append(member.Illness, &item)
+		oldIllIDMap[item.IllnessId] = item.IllnessId
+	}
+
+	for _, id := range illnessIDMap {
+		if _, exist := oldIllIDMap[id]; exist {
+			continue
+		}
+		var illItem member_service.CustomerIllness
+		illItem.UserOrgId = adminUserInfo.CurrentOrgId
+		illItem.IllnessId = id
+		illItem.Status = 1
+		illItem.UpdatedTime = timeNow
+		illItem.CreatedTime = timeNow
+		member.Illness = append(member.Illness, &illItem)
+	}
+
+	if dataBody["ill_date"] == nil || reflect.TypeOf(dataBody["ill_date"]).String() != "string" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:患病时间")
+		return
+	}
+	illDate, _ := dataBody["ill_date"].(string)
+	if len(illDate) == 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "患病时间格式不正确")
+		return
+	}
+
+	illDateTime, err := utils.ParseTimeStringToTime(timeLayout, illDate+" 00:00:00")
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "患病时间格式不正确")
+		return
+	}
+	member.IllDate = illDateTime.Unix()
+
+	if dataBody["treat_type"] == nil || reflect.TypeOf(dataBody["treat_type"]).String() != "float64" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:治疗方式")
+		return
+	}
+	treatType := int64(dataBody["treat_type"].(float64))
+	if treatType <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "请选择治疗方式")
+		return
+	}
+	member.TreatType = treatType
+
+	if dataBody["remark"] != nil && reflect.TypeOf(dataBody["remark"]).String() == "string" {
+		remark, _ := dataBody["remark"].(string)
+		if len(remark) > 0 {
+			member.Remark = remark
+		}
+	}
+
+	if dataBody["avatar"] != nil && reflect.TypeOf(dataBody["avatar"]).String() == "string" {
+		avatar, _ := dataBody["avatar"].(string)
+		if len(avatar) > 0 {
+			member.Avatar = avatar
+		}
+	}
+
+	if changeMobile {
+		customer, err := member_service.GetCustomerByMobile(adminUserInfo.CurrentOrgId, member.Mobile)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+			return
+		}
+		if customer != nil && customer.ID != member.ID {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（已经存在该手机号的客户）")
+			return
+		}
+	}
+	member.UpdatedTime = timeNow
+
+	err = member_service.EditMember(member)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员失败：（"+err.Error()+"）")
+		return
+	}
+
+	illness := member.Illness
+	member.Illness = make([]*member_service.CustomerIllness, 0)
+	for _, ill := range illness {
+		illItem := *ill
+		if illItem.Status == 0 {
+			continue
+		}
+		member.Illness = append(member.Illness, &illItem)
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["member"] = member
+	c.ServeSuccessJSON(returnData)
+	return
+
+}
+
+func (c *MembersAPIController) DeleteMembers() {
+	adminUserInfo := c.GetAdminUserInfo()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+	}
+
+	err = member_service.DeleteMembers(adminUserInfo.CurrentOrgId, ids)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBDelete, "删除会员失败:（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+
+	c.ServeSuccessJSON(returnData)
+	return
+}

controllers/members/router_controller.go

@@ -2,4 +2,6 @@ package members
 
 func RegisterRouters() {
 	MemberCtlRegistRouters()
+	TagCtlRegistRouters()
+	CardCtlRegistRouters()
 }

controllers/members/tags_controller.go

@@ -0,0 +1,241 @@
+package members
+
+import (
+	base_ctl "SCRM/controllers"
+	"SCRM/enums"
+	"SCRM/models"
+	"SCRM/service/member_service"
+	"SCRM/utils"
+	"reflect"
+	"time"
+
+	"encoding/json"
+
+	"github.com/astaxie/beego"
+)
+
+func TagCtlRegistRouters() {
+	beego.Router("/api/member/tag/edit", &TagAPIController{}, "Post:EditMemberTags")
+	beego.Router("/api/members/tags/add", &TagAPIController{}, "Post:AddMembersTags")
+	beego.Router("/api/members/tags", &TagAPIController{}, "Get:GetTags")
+}
+
+type TagAPIController struct {
+	base_ctl.BaseAuthAPIController
+}
+
+func (c *TagAPIController) EditMemberTags() {
+	id, _ := c.GetInt64("id", 0)
+	if id <= 0 {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误:id")
+		return
+	}
+	adminUserInfo := c.GetAdminUserInfo()
+	member, err := member_service.GetOnlyMemberByID(adminUserInfo.CurrentOrgId, id)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败:（"+err.Error()+"）")
+		return
+	}
+	if member == nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败:（会员记录不存在）")
+		return
+	}
+
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err = json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	if dataBody["tags"] == nil || reflect.TypeOf(dataBody["tags"]).String() != "[]interface {}" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:tags")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+
+	tagsInters := dataBody["tags"].([]interface{})
+	if len(tagsInters) == 0 {
+		err = member_service.DeleteMemeberAllTags(adminUserInfo.CurrentOrgId, member.ID)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败：（"+err.Error()+"）")
+			return
+		}
+		returnData["tags"] = nil
+	} else {
+		userTags := make([]*models.UserTagLinks, 0)
+		tagIds := make([]int64, 0)
+		tagIDMap := make(map[int64]int64, 0)
+		for _, tagsInter := range tagsInters {
+			id := int64(tagsInter.(float64))
+			tagIds = append(tagIds, id)
+			tagIDMap[id] = id
+		}
+		allTags, err := member_service.GetMemberAllTags(adminUserInfo.CurrentOrgId, member.ID)
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败：（"+err.Error()+"）")
+			return
+		}
+		oldTagIDMap := make(map[int64]int64, 0)
+		for _, tagItem := range allTags {
+			item := *tagItem
+			item.Status = 1
+			if _, exist := tagIDMap[item.TagId]; !exist {
+				item.Status = 0
+				item.UpdatedTime = timeNow
+			}
+			userTags = append(userTags, &item)
+			oldTagIDMap[item.TagId] = item.TagId
+		}
+
+		for _, id := range tagIDMap {
+			if _, exist := oldTagIDMap[id]; exist {
+				continue
+			}
+			var tagItem models.UserTagLinks
+			tagItem.UserOrgId = adminUserInfo.CurrentOrgId
+			tagItem.TagId = id
+			tagItem.UserLinkId = member.ID
+			tagItem.Status = 1
+			tagItem.UpdatedTime = timeNow
+			tagItem.CreatedTime = timeNow
+			userTags = append(userTags, &tagItem)
+		}
+		err = member_service.SaveMemberTags(userTags)
+
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBUpdate, "编辑会员标签失败：（"+err.Error()+"）")
+			return
+		}
+
+		returnData["tags"] = tagIds
+	}
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) AddMembersTags() {
+	adminUserInfo := c.GetAdminUserInfo()
+	timeNow := time.Now().Unix()
+
+	dataBody := make(map[string]interface{}, 0)
+	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数错误")
+		return
+	}
+
+	if dataBody["tags"] == nil || reflect.TypeOf(dataBody["tags"]).String() != "[]interface {}" {
+		c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "缺少参数:tags")
+		return
+	}
+
+	idsInters := dataBody["ids"].([]interface{})
+	if len(idsInters) == 0 {
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败:（没有选择会员）")
+			return
+		}
+	}
+
+	ids := make([]int64, 0)
+	idsMap := make(map[int64]int64, 0)
+	for _, idsInter := range idsInters {
+		id := int64(idsInter.(float64))
+		ids = append(ids, id)
+		idsMap[id] = id
+	}
+
+	tagsInters := dataBody["tags"].([]interface{})
+	if len(tagsInters) == 0 {
+		if err != nil {
+			c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败:（没有选择标签）")
+			return
+		}
+	}
+	tagIds := make([]int64, 0)
+	tagIDMap := make(map[int64]int64, 0)
+	for _, tagsInter := range tagsInters {
+		id := int64(tagsInter.(float64))
+		tagIds = append(tagIds, id)
+		tagIDMap[id] = id
+	}
+
+	allTags, err := member_service.GetMembersAllTags(adminUserInfo.CurrentOrgId, ids)
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败:（"+err.Error()+"）")
+		return
+	}
+
+	userTags := make([]*models.UserTagLinks, 0)
+	oldTagIDMap := make(map[int64]map[int64]int64, 0)
+	for _, tagItem := range allTags {
+		_, exist := tagIDMap[tagItem.TagId]
+		_, uexist := idsMap[tagItem.UserLinkId]
+		if exist && uexist {
+			item := *tagItem
+			item.Status = 1
+			item.UpdatedTime = timeNow
+			userTags = append(userTags, &item)
+			if _, oex := oldTagIDMap[item.UserLinkId]; !oex {
+				oldTagIDMap[item.UserLinkId] = make(map[int64]int64, 0)
+			}
+			oldTagIDMap[item.UserLinkId][item.TagId] = item.TagId
+		}
+	}
+
+	for _, userid := range idsMap {
+		for _, tagid := range tagIDMap {
+			if _, exist := oldTagIDMap[userid]; exist {
+				if _, exist := oldTagIDMap[userid][tagid]; exist {
+					continue
+				}
+			}
+			var tagItem models.UserTagLinks
+			tagItem.UserOrgId = adminUserInfo.CurrentOrgId
+			tagItem.TagId = tagid
+			tagItem.UserLinkId = userid
+			tagItem.Status = 1
+			tagItem.UpdatedTime = timeNow
+			tagItem.CreatedTime = timeNow
+			userTags = append(userTags, &tagItem)
+		}
+	}
+	err = member_service.SaveMemberTags(userTags)
+
+	if err != nil {
+		c.ServeFailJsonSend(enums.ErrorCodeDBCreate, "添加会员标签失败：（"+err.Error()+"）")
+		return
+	}
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["msg"] = "ok"
+
+	c.ServeSuccessJSON(returnData)
+	return
+}
+
+func (c *TagAPIController) GetTags() {
+	page, _ := c.GetInt64("page", 1)
+	limit, _ := c.GetInt64("limit", 10)
+	searchKey := c.GetString("search", "")
+	if page <= 0 {
+		page = 1
+	}
+	if limit <= 0 {
+		limit = 10
+	}
+
+	adminUserInfo := c.GetAdminUserInfo()
+	tags, _ := member_service.GetPageTagList(adminUserInfo.CurrentOrgId, page, limit, searchKey)
+
+	returnData := make(map[string]interface{}, 0)
+	returnData["tags"] = tags
+	c.ServeSuccessJSON(returnData)
+	return
+}

service/member_service/cards_service.go

@@ -3,10 +3,65 @@ package member_service
 import (
 	"SCRM/models"
 	"SCRM/service"
+	"time"
+
+	"github.com/jinzhu/gorm"
 )
 
 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
+}
+
+func GetCardByID(orgID, cardID int64) (*models.UserMembershipCard, error) {
+	var card models.UserMembershipCard
+	var err error
+	err = service.UserReadDB().Model(&models.UserMembershipCard{}).Where("id=? and user_org_id=? and status=1", cardID, orgID).First(&card).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &card, nil
+}
+
+func GetUserCardByID(orgID, customerID int64) (*models.UserCard, error) {
+	var card models.UserCard
+	var err error
+	err = service.UserReadDB().Model(&models.UserCard{}).Where("user_org_id=? and customer_id=? and status=1", orgID, customerID).First(&card).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &card, nil
+}
+
+func DeleteUserCard(orgID, customerID int64) (err error) {
+	err = service.UserWriteDB().Model(&models.UserCard{}).Where("user_org_id=? and customer_id=? ", orgID, customerID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	return
+}
+
+func SaveUserCard(card *models.UserCard, member *Members) (err error) {
+	if member.Membership == 1 {
+		err = service.UserWriteDB().Save(card).Error
+	} else {
+		tx := service.UserWriteDB().Begin()
+		err = service.UserWriteDB().Save(card).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+
+		err = service.UserWriteDB().Model(&models.UserCustomer{}).Where("id=? and user_org_id=? ", member.ID, member.UserOrgId).Update(map[string]interface{}{"Membership": 1, "UpdatedTime": time.Now().Unix()}).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+		tx.Commit()
+	}
 
 	return
 }

service/member_service/illness_service.go

@@ -1,12 +1,22 @@
 package member_service
 
 import (
-	"SCRM/service"
 	"SCRM/models"
+	"SCRM/service"
 )
 
-
 func GetIllnessList() (ills []*models.Illness, err error) {
 	err = service.UserReadDB().Where("status=1").Find(&ills).Error
 	return
 }
+
+func GetMemberAllIllnessByIllIDs(orgID, customerID int64, ids []int64) (ills []*CustomerIllness, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and customer_id =? and illness_id IN (?) ", orgID, customerID, ids).Find(&ills).Error
+	return
+}
+
+//GetMemberAllIllness 取所有(包括已经软删除的记录)
+func GetMemberAllIllness(orgID, customerID int64) (ills []*CustomerIllness, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and customer_id =? ", orgID, customerID).Find(&ills).Error
+	return
+}

service/member_service/member_service.go

@@ -5,6 +5,8 @@ import (
 	"SCRM/service"
 	"strings"
 
+	"time"
+
 	"github.com/jinzhu/gorm"
 )
 
@@ -42,6 +44,7 @@ func GetMemberList(orgID, page, limit, level, source, tag, startTime, endTime in
 			return db.Where("user_org_id=? and status=1", orgID)
 		}).
 		Preload("UserCard.Card", "user_org_id=? and status=1", orgID).
+		Preload("Illness", "user_org_id=? and status=1", orgID).
 		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
@@ -81,11 +84,29 @@ func GetUserByMobile(mobile string) (*models.User, error) {
 	return &user, nil
 }
 
+func GetOnlyMemberByID(orgID, id int64) (*Members, error) {
+	var member Members
+	var err error
+	err = service.UserReadDB().Where("id =? and user_org_id=? and status=1", id, orgID).Find(&member).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, nil
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &member, nil
+}
+
 func CreateMember(member *Members) (err error) {
 	err = service.UserWriteDB().Create(member).Error
 	return
 }
 
+func EditMember(member *Members) (err error) {
+	err = service.UserWriteDB().Save(member).Error
+	return
+}
+
 func CreateMemberWithUser(member *Members, user *models.User) (err error) {
 	tx := service.UserWriteDB().Begin()
 	err = tx.Create(user).Error
@@ -104,3 +125,12 @@ func CreateMemberWithUser(member *Members, user *models.User) (err error) {
 
 	return
 }
+
+func DeleteMembers(orgID int64, ids []int64) (err error) {
+	if len(ids) == 1 {
+		err = service.UserWriteDB().Model(&models.UserCustomer{}).Where("id =? and user_org_id =?", ids[0], orgID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	} else {
+		err = service.UserWriteDB().Model(&models.UserCustomer{}).Where("id IN (?) and user_org_id =?", ids, orgID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	}
+	return
+}

service/member_service/models.go

@@ -34,3 +34,18 @@ type CustomerIllness struct {
 func (CustomerIllness) TableName() string {
 	return "sgj_user_customer_illness"
 }
+
+type Tags struct {
+	models.UserTags
+
+	MemberCount int64
+}
+
+func (Tags) TableName() string {
+	return "sgj_user_tags"
+}
+
+type TagsMemberCount struct {
+	MemberCount int64 `gorm:"member_count"`
+	TagID       int64 `gorm:"tag_id"`
+}

service/member_service/tags_service.go

@@ -3,10 +3,111 @@ package member_service
 import (
 	"SCRM/models"
 	"SCRM/service"
+	"errors"
+	"strings"
+	"time"
 )
 
 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
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID).Order("id asc").Find(&tags).Error
 
 	return
 }
+
+//GetMemberAllTags 取所有(包括已经软删除的记录)
+func GetMemberAllTags(orgID, customerID int64) (tags []*models.UserTagLinks, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and user_link_id =? ", orgID, customerID).Find(&tags).Error
+	return
+}
+
+//GetMembersAllTags 取所有(包括已经软删除的记录)
+func GetMembersAllTags(orgID int64, customerIDs []int64) (tags []*models.UserTagLinks, err error) {
+	err = service.UserReadDB().Where("user_org_id = ? and user_link_id in (?) ", orgID, customerIDs).Find(&tags).Error
+	return
+}
+
+//DeleteMemeberAllTags 删除会员所有标签
+func DeleteMemeberAllTags(orgID, customerID int64) (err error) {
+	err = service.UserWriteDB().Model(&models.UserTagLinks{}).Where("user_org_id = ? and user_link_id =? ", orgID, customerID).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+	return
+}
+
+func SaveMemberTags(tags []*models.UserTagLinks) (err error) {
+	if len(tags) == 0 {
+		err = errors.New("NotRecordToUpdate")
+		return
+	}
+
+	insertSql := "INSERT INTO sgj_user_tag_links (tag_id, user_link_id, status, created_time, updated_time, user_org_id) VALUES "
+	insertParams := make([]string, 0)
+	insertData := make([]interface{}, 0)
+	updateIds := make([]int64, 0)
+	deleteIds := make([]int64, 0)
+	for _, tag := range tags {
+		if tag.ID == 0 {
+			insertParams = append(insertParams, "(?,?,?,?,?,?)")
+			insertData = append(insertData, tag.TagId)
+			insertData = append(insertData, tag.UserLinkId)
+			insertData = append(insertData, tag.Status)
+			insertData = append(insertData, tag.CreatedTime)
+			insertData = append(insertData, tag.UpdatedTime)
+			insertData = append(insertData, tag.UserOrgId)
+		} else {
+			if tag.Status == 1 {
+				updateIds = append(updateIds, tag.ID)
+			} else {
+				deleteIds = append(deleteIds, tag.ID)
+			}
+		}
+	}
+
+	tx := service.UserWriteDB().Begin()
+	if len(insertParams) > 0 {
+		insertSql += strings.Join(insertParams, ", ")
+		err = tx.Exec(insertSql, insertData...).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+	}
+
+	if len(updateIds) > 0 {
+		err = service.UserWriteDB().Model(&models.UserTagLinks{}).Where("id IN (?)", updateIds).Update(map[string]interface{}{"Status": 1, "UpdatedTime": time.Now().Unix()}).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+	}
+	if len(deleteIds) > 0 {
+		err = service.UserWriteDB().Model(&models.UserTagLinks{}).Where("id IN (?)", deleteIds).Update(map[string]interface{}{"Status": 0, "UpdatedTime": time.Now().Unix()}).Error
+		if err != nil {
+			tx.Rollback()
+			return
+		}
+	}
+
+	tx.Commit()
+	return
+}
+
+func GetPageTagList(orgID, page, limit int64, search string) (tags []*Tags, err error) {
+	db := service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID)
+
+	if len(search) > 0 {
+		searchKey := "%" + search + "%"
+		db = db.Where("tag_name LIKE ?", searchKey)
+	}
+	offset := (page - 1) * limit
+
+	err = service.UserReadDB().Model(&models.UserTags{}).Where("user_org_id=? and status=1", orgID).Order("id desc").Offset(offset).Limit(limit).Find(&tags).Error
+
+	if len(tags) > 0 {
+		// var tmcs []*TagsMemberCount
+		// tagIDs := make([]int64, 0)
+		// for _, tag := range tags {
+		// 	tagIDs = append(tagIDs, tag.ID)
+		// }
+
+	}
+	return
+}