exhibition-register/internal/logic/register_logic.go

282 lines
9.3 KiB
Go

package logic
import (
"errors"
"exhibition-register/internal/dao"
"exhibition-register/internal/model"
"exhibition-register/pb/exhibition"
"exhibition-register/pkg/utils"
"fmt"
)
type IRegister interface {
CheckByPhone(in *exhibition.RegisterInfo) (out *exhibition.CheckPhoneResp, err error)
CheckIdCard(in *exhibition.RegisterInfo) (out *exhibition.CheckIdCardResp, err error)
SaveRegisterRecord(in *exhibition.RegisterInfo) (out *exhibition.SaveRegisterRecordResp, err error)
RegisterRecordList(in *exhibition.RecordListReq) (out *exhibition.RecordListResp, err error)
FindAllRecord() (out *exhibition.ExportRecordResp, err error)
}
func NewRegister() IRegister {
return &Register{}
}
type Register struct {
}
func (r *Register) CheckIdCard(in *exhibition.RegisterInfo) (out *exhibition.CheckIdCardResp, err error) {
out = &exhibition.CheckIdCardResp{}
check, err1 := dao.CheckBy("id_card", in.IdCard, "")
if err1 != nil {
return nil, err1
}
if check != nil {
return nil, errors.New("该身份证号已被" + check.PhoneNum + "注册!")
}
return out, nil
}
func (r *Register) FindAllRecord() (out *exhibition.ExportRecordResp, err error) {
out = &exhibition.ExportRecordResp{}
allRecord, err := dao.AllRecord()
if err != nil {
return nil, err
}
if len(allRecord) > 0 {
for _, record := range allRecord {
var address string
address = fmt.Sprintf("%s%s", record.Address, record.Address1)
tmp := &exhibition.ExportInfo{
ArtistName: record.ArtistName,
Gender: record.Gender,
PhoneNum: record.PhoneNum,
IdCard: record.IdCard,
Address: address,
IdCardPhoto: record.IdCardPhoto,
IdCardBackPhoto: record.IdCardBackPhoto,
ArtistPhoto: record.ArtistPhoto,
ArtworkName: record.ArtworkName,
PreliminaryRatingNo: record.PreliminaryRatingNo,
ReRatingNo: record.ReRatingNo,
ArtworkType: record.ArtworkType,
ArtworkSize: record.ArtworkSize,
Province: record.Province,
CreatedAt: record.CreatedAt.Format("2006-01-02 15:04:05"),
UpdatedAt: record.UpdatedAt.Format("2006-01-02 15:04:05"),
}
out.Data = append(out.Data, tmp)
}
}
return
}
func (r *Register) RegisterRecordList(in *exhibition.RecordListReq) (out *exhibition.RecordListResp, err error) {
out = &exhibition.RecordListResp{}
recordList, total, err := dao.RecordList(in)
if err != nil {
return nil, err
}
if total > 0 {
for _, item := range recordList {
tmp := &exhibition.RegisterInfo{
Id: int32(item.ID),
Uuid: item.UUID,
ArtistName: item.ArtistName,
Gender: item.Gender,
PhoneNum: item.PhoneNum,
IdCard: item.IdCard,
Address: item.Address,
Address1: item.Address1,
IdCardPhoto: item.IdCardPhoto,
IdCardBackPhoto: item.IdCardBackPhoto,
ArtistPhoto: item.ArtistPhoto,
ArtworkFile: item.ArtworkFile,
ArtworkName: item.ArtworkName,
PreliminaryRatingNo: item.PreliminaryRatingNo,
ReRatingNo: item.ReRatingNo,
ArtworkType: item.ArtworkType,
ArtworkSize: item.ArtworkSize,
Province: item.Province,
CreatedAt: item.CreatedAt.Format("2006-01-02 15:04:05"),
UpdatedAt: item.UpdatedAt.Format("2006-01-02 15:04:05"),
}
out.Data = append(out.Data, tmp)
}
out.Count = int32(total)
}
return out, err
}
func (r *Register) SaveRegisterRecord(in *exhibition.RegisterInfo) (out *exhibition.SaveRegisterRecordResp, err error) {
out = &exhibition.SaveRegisterRecordResp{}
record := &model.RegisterRecord{
ArtistName: in.ArtistName,
Gender: in.Gender,
PhoneNum: in.PhoneNum,
IdCard: in.IdCard,
Address: in.Address,
Address1: in.Address1,
IdCardPhoto: in.IdCardPhoto,
IdCardBackPhoto: in.IdCardBackPhoto,
ArtistPhoto: in.ArtistPhoto,
ArtworkFile: in.ArtworkFile,
ArtworkName: in.ArtworkName,
Province: in.Province,
ArtworkType: in.ArtworkType,
ArtworkSize: in.ArtworkSize,
PreliminaryRatingNo: in.PreliminaryRatingNo,
ReRatingNo: in.ReRatingNo,
}
tmpRecord := &model.RegisterRecord{}
if in.Uuid != "" {
check, err := dao.CheckBy("phone_num", record.PhoneNum, in.Uuid)
if err != nil {
return nil, err
}
if check != nil {
return nil, errors.New("该手机号已经被注册!")
}
record.UUID = in.Uuid
registerRecord, err1 := dao.UpdateRegisterRecord(record)
if err1 != nil {
return nil, err1
}
tmpRecord = registerRecord
} else {
record.UUID = utils.GetUUID()
registerRecord, err := dao.CreateRegisterRecord(record)
if err != nil {
return nil, err
}
tmpRecord = registerRecord
}
data := &exhibition.RegisterInfo{
Id: int32(tmpRecord.ID),
Uuid: tmpRecord.UUID,
ArtistName: tmpRecord.ArtistName,
Gender: tmpRecord.Gender,
PhoneNum: tmpRecord.PhoneNum,
IdCard: tmpRecord.IdCard,
Address: tmpRecord.Address,
Address1: tmpRecord.Address1,
IdCardPhoto: tmpRecord.IdCardPhoto,
IdCardBackPhoto: tmpRecord.IdCardBackPhoto,
ArtistPhoto: tmpRecord.ArtistPhoto,
ArtworkFile: tmpRecord.ArtworkFile,
ArtworkName: tmpRecord.ArtworkName,
Province: tmpRecord.Province,
ArtworkType: tmpRecord.ArtworkType,
ArtworkSize: tmpRecord.ArtworkSize,
PreliminaryRatingNo: tmpRecord.PreliminaryRatingNo,
ReRatingNo: tmpRecord.ReRatingNo,
CreatedAt: tmpRecord.CreatedAt.Format("2006-01-02 15:04:05"),
UpdatedAt: tmpRecord.UpdatedAt.Format("2006-01-02 15:04:05"),
}
out.Data = data
return out, nil
}
// CheckByPhone 通过手机号检索 存在的就返回数据
func (r *Register) CheckByPhone(in *exhibition.RegisterInfo) (out *exhibition.CheckPhoneResp, err error) {
out = &exhibition.CheckPhoneResp{}
record, err := dao.CheckByPhone(in.PhoneNum)
if err != nil {
return nil, err
}
if record == nil {
out.IsExist = false
return out, nil
}
data := &exhibition.RegisterInfo{
Id: int32(record.ID),
Uuid: record.UUID,
ArtistName: record.ArtistName,
Gender: record.Gender,
PhoneNum: record.PhoneNum,
IdCard: record.IdCard,
Address: record.Address,
Address1: record.Address1,
IdCardPhoto: record.IdCardPhoto,
IdCardBackPhoto: record.IdCardBackPhoto,
ArtistPhoto: record.ArtistPhoto,
ArtworkFile: record.ArtworkFile,
ArtworkName: record.ArtworkName,
CreatedAt: record.CreatedAt.Format("2006-01-02 15:04:05"),
UpdatedAt: record.UpdatedAt.Format("2006-01-02 15:04:05"),
}
out.Data = data
out.IsExist = true
return out, nil
}
func (r *Register) GetRecordByName(in *exhibition.RegisterInfo) (out *exhibition.RegisterInfo, err error) {
record, err := dao.GetRecordByName(in)
if err != nil {
return nil, err
}
if record == nil {
return nil, errors.New("未找到该记录")
}
data := &exhibition.RegisterInfo{
Id: int32(record.ID),
Uuid: record.UUID,
}
return data, nil
}
func (r *Register) UpdateRegisterRecord(in *exhibition.RegisterInfo) (out *exhibition.SaveRegisterRecordResp, err error) {
out = &exhibition.SaveRegisterRecordResp{}
record := &model.RegisterRecord{
ArtistName: in.ArtistName,
Gender: in.Gender,
PhoneNum: in.PhoneNum,
IdCard: in.IdCard,
Address: in.Address,
Address1: in.Address1,
IdCardPhoto: in.IdCardPhoto,
IdCardBackPhoto: in.IdCardBackPhoto,
ArtistPhoto: in.ArtistPhoto,
ArtworkFile: in.ArtworkFile,
ArtworkName: in.ArtworkName,
Province: in.Province,
ArtworkType: in.ArtworkType,
ArtworkSize: in.ArtworkSize,
PreliminaryRatingNo: in.PreliminaryRatingNo,
ReRatingNo: in.ReRatingNo,
UUID: in.Uuid,
}
registerRecord, err1 := dao.UpdateRegisterRecord(record)
if err1 != nil {
return nil, err1
}
data := &exhibition.RegisterInfo{
Id: int32(registerRecord.ID),
Uuid: registerRecord.UUID,
ArtistName: registerRecord.ArtistName,
Gender: registerRecord.Gender,
PhoneNum: registerRecord.PhoneNum,
IdCard: registerRecord.IdCard,
Address: registerRecord.Address,
Address1: registerRecord.Address1,
IdCardPhoto: registerRecord.IdCardPhoto,
IdCardBackPhoto: registerRecord.IdCardBackPhoto,
ArtistPhoto: registerRecord.ArtistPhoto,
ArtworkFile: registerRecord.ArtworkFile,
ArtworkName: registerRecord.ArtworkName,
Province: registerRecord.Province,
ArtworkType: registerRecord.ArtworkType,
ArtworkSize: registerRecord.ArtworkSize,
PreliminaryRatingNo: registerRecord.PreliminaryRatingNo,
ReRatingNo: registerRecord.ReRatingNo,
CreatedAt: registerRecord.CreatedAt.Format("2006-01-02 15:04:05"),
UpdatedAt: registerRecord.UpdatedAt.Format("2006-01-02 15:04:05"),
}
out.Data = data
return out, nil
}