UserRegister/internal/logic/hk_member/hk_member.go

package hk_member

import (
	v1 "UserRegister/api/v1"
	"UserRegister/internal/service"
	"github.com/gogf/gf/v2/frame/g"
)

type sHKMember struct{}

func init() {
	service.RegisterHKMember(NewHKMember())
}

func NewHKMember() *sHKMember {
	return &sHKMember{}
}

func (s *sHKMember) GetMemberList(req *v1.GetHKMemberListReq) (res []v1.GetHKMemberListRes, total int, err error) {
	err = g.Model("hk_member_info").OrderDesc("created_at").
		Page(req.Page, req.PageSize).ScanAndCount(&res, &total, false)
	return
}

func (s *sHKMember) InsertMember(req *v1.InsertHKMemberReq) (err error) {
	_, err = g.Model("hk_member_info").Data(g.Map{
		"name":             req.Name,
		"code":             req.Code,
		"telephone":        req.Tel,
		"wechat":           req.WeChat,
		"email":            req.Email,
		"feedback_type":    req.FeedbackType,
		"feedback_content": req.FeedbackContent,
	}).Insert()
	if err != nil {
		return
	}
	return
}

func (s *sHKMember) UpdateState(req *v1.UpdateHKStateReq) (err error) {
	_, err = g.Model("hk_member_info").Data(g.Map{
		"is_related": req.State,
	}).WherePri(req.Id).Update()
	if err != nil {
		return
	}
	return
}

func (s *sHKMember) EditNote(req *v1.EditHKNoteReq) (err error) {
	_, err = g.Model("hk_member_info").Data(g.Map{
		"note": req.Note,
	}).WherePri(req.Id).Update()
	if err != nil {
		return
	}
	return
}