package train

import (
	"context"
	dao "dashoo.cn/micro/app/dao/train"
	model "dashoo.cn/micro/app/model/train"
	"dashoo.cn/micro/app/service"
	"dashoo.cn/opms_libary/myerrors"
	"github.com/gogf/gf/database/gdb"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/util/gconv"
)

type SaleApplySummaryService struct {
	*service.ContextService
	Dao *dao.TrainSaleApplySummaryDao
}

func NewSaleApplySummaryService(ctx context.Context) (svc *SaleApplySummaryService, err error) {
	svc = new(SaleApplySummaryService)
	if svc.ContextService, err = svc.Init(ctx); err != nil {
		return nil, err
	}
	svc.Dao = dao.NewTrainSaleApplySummaryDao(svc.Tenant)
	return svc, nil
}

// GetList 销售申请总结信息列表
func (s *SaleApplySummaryService) GetList(ctx context.Context, req *model.TraSaleApplySummarySearchReq) (total int, distributorList []*model.TraSaleApplySummaryRes, err error) {
	distributorModel := s.Dao.FieldsEx(s.Dao.C.DeletedTime)
	if req.ApplyId != 0 {
		distributorModel = distributorModel.Where(s.Dao.C.ApplyId, req.ApplyId)
	}
	total, _ = distributorModel.Count()
	err = distributorModel.Order("id desc").Scan(&distributorList)
	if err != nil {
		return 0, nil, err
	}
	return
}

// GetEntityById 详情
func (s *SaleApplySummaryService) GetEntityById(ctx context.Context, id int64) (distributorInfo *model.TraSaleApplySummaryRes, err error) {
	err = s.Dao.Where(s.Dao.C.Id, id).Scan(&distributorInfo)
	if err != nil {
		return nil, err
	}
	return
}

// Create 销售申请总结创建
func (s *SaleApplySummaryService) Create(ctx context.Context, req *model.TraSaleApplySummaryCreateReq) (lastId int64, err error) {
	DistributorData := new(model.TrainSaleApplySummary)
	if err = gconv.Struct(req, DistributorData); err != nil {
		return 0, err
	}
	service.SetCreatedInfo(DistributorData, s.GetCxtUserId(), s.GetCxtUserName())
	svc, _ := NewSaleApplyService(ctx)
	txerr := s.Dao.DB.Transaction(ctx, func(ctx context.Context, tx *gdb.TX) error {
		lastId, err = tx.InsertAndGetId("train_sale_apply_summary", DistributorData)
		if err != nil {
			return err
		}
		_, err = svc.Dao.Ctx(ctx).TX(tx).WherePri(req.ApplyId).Data(g.Map{svc.Dao.C.ApplyType: "30"}).Update()
		if err != nil {
			return err
		}
		return err
	})
	if txerr != nil {
		return 0, txerr
	}
	return lastId, nil
}

// UpdateById 修改数据
func (s *SaleApplySummaryService) UpdateById(ctx context.Context, req *model.TraSaleApplySummaryUpdateReq) (err error) {
	ent, err := s.Dao.Where("id = ", req.Id).One()
	if err != nil {
		g.Log().Error(err)
		return
	}
	if ent == nil {
		err = myerrors.TipsError("无修改数据")
		return
	}
	distData := new(model.TrainSaleApplySummary)
	if err = gconv.Struct(req, distData); err != nil {
		return
	}
	service.SetUpdatedInfo(distData, s.GetCxtUserId(), s.GetCxtUserName())
	_, err = s.Dao.FieldsEx(s.Dao.C.Id, s.Dao.C.CreatedName, s.Dao.C.CreatedBy, s.Dao.C.CreatedTime).
		WherePri(s.Dao.C.Id, req.Id).Update(distData)
	if err != nil {
		g.Log().Error(err)
		return
	}
	return
}

// DeleteByIds 删除
func (s *SaleApplySummaryService) DeleteByIds(ctx context.Context, ids []int64) (err error) {
	_, err = s.Dao.WhereIn(s.Dao.C.Id, ids).Delete()
	if err != nil {
		return err
	}
	return
}