package logic

import (
	"context"
	"encoding/base64"
	"git.i2edu.net/i2/i2-bill-api/internal/svc"
	"git.i2edu.net/i2/i2-bill-api/internal/types"
	"git.i2edu.net/i2/i2-bill-api/internal/utils"
	"git.i2edu.net/i2/i2-bill-api/model"
	"strconv"
	"time"

	"git.i2edu.net/i2/go-zero/core/logx"
)

type AcquirerStudentAddLogic struct {
	logx.Logger
	ctx    context.Context
	svcCtx *svc.ServiceContext
}

func NewAcquirerStudentAddLogic(ctx context.Context, svcCtx *svc.ServiceContext) AcquirerStudentAddLogic {
	return AcquirerStudentAddLogic{
		Logger: logx.WithContext(ctx),
		ctx:    ctx,
		svcCtx: svcCtx,
	}
}

func (l *AcquirerStudentAddLogic) AcquirerStudentAdd(req types.EnrollAddReq) (*types.Response, error) {
	// todo: add your logic here and delete this line
	//解析id
	sign, err := base64.StdEncoding.DecodeString(req.Sign)
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, "二维码已失效", nil}, nil
	}
	userIdByte, err := utils.AesDecrypt(sign, []byte(l.svcCtx.Config.AesSecret))
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, "二维码已失效", nil}, nil
	}
	userId, err := strconv.ParseInt(string(userIdByte), 10, 64)
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, err.Error(), nil}, nil
	}
	//是否有权限收单
	erpId, err := model.GetAcquirePerm(userId, l.svcCtx.Transformer, l.svcCtx.DB)
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, err.Error(), nil}, nil
	}
	if erpId == "" {
		return &types.Response{500, "二维码已失效", nil}, nil
	}
	//去重
	stu, err := l.svcCtx.DB.SQL("select * from i2bill_acquirer_student where stu_phone = ?  and DATE_FORMAT(create_time,'%Y-%m-%d') = ? ", req.StuPhone, time.Now().Format("2006-01-02")).Query().List()
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, err.Error(), nil}, nil
	}
	if len(stu) > 0 {
		return &types.Response{500, "你今天已提交过信息，感谢你的填写", nil}, nil
	}
	bean := new(model.I2billAcquirerStudentXorm)
	bean.AgeGroup = int64(req.AgeGroup)
	bean.StuPhone = req.StuPhone
	bean.Address = req.Address
	bean.UserId = userId
	//获取渠道收单信息
	acquirerInfo, err := model.GetAcquirerMktQr(userId, l.svcCtx.DB)
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, err.Error(), nil}, nil
	}
	if acquirerInfo.Id == 0 {
		return &types.Response{500, "二维码已失效", nil}, nil
	}

	bean.MkId = erpId
	bean.NetworkDetailId = acquirerInfo.QudaoId
	bean.ActiveId = acquirerInfo.ActivityId
	bean.DelFlag = 0
	bean.CheckState = 54
	bean.StuName = req.StuName
	bean.StuLinkPerson = req.StuLinkPerson
	bean.SchId = int64(req.SchId)
	bean.CreateTime = time.Now()
	_, err = l.svcCtx.DB.Insert(bean)
	if err != nil {
		logx.Error(err.Error())
		return &types.Response{500, err.Error(), nil}, nil
	}
	return &types.Response{200, "", nil}, nil
}