package instrument_surcharge

import (
	"dashoo.cn/micro_libary/request"
	"database/sql"
	"fmt"
	"github.com/gogf/gf/os/gtime"
	"github.com/gogf/gf/util/gconv"
	"lims_adapter/dao/equipment"
	"lims_adapter/model"
	selfModel "lims_adapter/model/equipment"
)

// Service 会议室服务
type Service struct {
	Dao    *equipment.InstrumentSurchargeDao
	Tenant string
}

// NewSrv 服务初始化
func NewService(tenant string) Service {
	return Service{Dao: equipment.NewInstrumentSurchargeDao(tenant), Tenant: tenant}
}

// List 获取数据列表
func (s Service) List(req model.ListReq) ([]selfModel.InstrumentSurcharge, error) {
	entityModel := s.Dao.M
	where := "1=1"

	if req.Entity != nil {
		entity := new(selfModel.InstrumentSurchargeReq)
		err := gconv.Struct(req.Entity, entity)
		if err != nil {
			return nil, err
		}
		if entity.InstrumentId != 0 {
			where += fmt.Sprintf(" AND InstrumentId='%v'", entity.InstrumentId)
		}
	}
	entityModel = entityModel.Where(where)

	res, err := entityModel.Fields("instrument_surcharge.*").FindAll()
	if err != nil {
		return nil, err
	}

	list := make([]selfModel.InstrumentSurcharge, 0)

	err = res.Structs(&list)
	if err != nil && err != sql.ErrNoRows {
		return nil, err
	}

	return list, nil
}

// 保存
func (s Service) Save(req selfModel.InstrumentSurchargeSaveReq, user request.UserInfo) error {
	now := gtime.Now() // 获取当前时间

	if req.Entity.Id == 0 {
		req.Entity.CreateUserId = int(user.Id)
		req.Entity.CreateBy = user.RealName
		req.Entity.CreateOn = now
	}
	req.Entity.UpdateUserId = int(user.Id)
	req.Entity.UpdateBy = user.RealName
	req.Entity.UpdateOn = now

	_, err := s.Dao.M.Save(req.Entity)
	return err
}

// 删除
func (s Service) Delete(req selfModel.InstrumentSurchargeDeleteReq) error {
	_, err := s.Dao.M.Delete(fmt.Sprintf("Id='%v'", req.Id))
	return err
}