lims_adapter/handler/equipment.go

package handler

import (
	"context"
	"dashoo.cn/common_definition/comm_def"
	"dashoo.cn/micro_libary/micro_srv"
	"dashoo.cn/micro_libary/myerrors"
	"errors"
	"github.com/gogf/gf/frame/g"
	"lims_adapter/model"
	"lims_adapter/service/equipment"
	"strconv"
)

// 设备
type Equipment struct{}

// AppointmentQualificationList 设备预约资格列表查询
func (e *Equipment) AppointmentQualificationList(ctx context.Context, req *model.QualificationListReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.AppointmentQualificationList request @ " + tenant)
	if req.Size == 0 {
		req.Size = DefaultPageNum
	}
	if req.Current < 0 {
		req.Current = DefaultPageCurrent
	}
	list, total, err := equipment.NewSrv(tenant).AppointmentQualificationList(req)
	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	rsp.Data = g.Map{"total": total, "tableData": list}
	return nil
}

// AppointmentQualificationList 优先预约权资格列表查询
func (e *Equipment) AdvanceList(ctx context.Context, req *model.QualificationListReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.AdvanceList request @ " + tenant)
	if req.Size == 0 {
		req.Size = DefaultPageNum
	}
	if req.Current < 0 {
		req.Current = DefaultPageCurrent
	}
	list, total, err := equipment.NewSrv(tenant).AdvanceList(req)
	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	rsp.Data = g.Map{"total": total, "tableData": list}
	return nil
}

// AddOrUpdateQualification 新增、修改预约资格名单
func (e *Equipment) AddOrUpdateQualification(ctx context.Context, req *model.AddOrUpdateQualification, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	info, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.AddOrUpdateQualification request @ " + tenant)
	if strconv.Itoa(req.InstrumentId) == "" {
		return errors.New("设备Id为空！")
	}
	if len(req.Ids) == 0 {
		return errors.New("选择授权的用户Id为空")
	}
	err = equipment.NewSrv(tenant).AddOrUpdateQualification(req, info)
	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	return nil
}

// DeleteQualification 删除预约资格
func(e *Equipment) DeleteQualification(ctx context.Context, req *model.IdReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	info, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.DeleteQualification request @ " + tenant)
	if err != nil {
		return err
	}
	if strconv.Itoa(req.UserId) == "" && strconv.Itoa(req.EquipmentId) == "" {
		return errors.New("未传入删除资格参数不完整，请核对后再试")
	}
	err = equipment.NewSrv(tenant).DeleteQualification(req, info)
	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	return nil
}

// DeleteAdvance 删除优先预约资格
func(e *Equipment) DeleteAdvance(ctx context.Context, req *model.IdReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.DeleteAdvance request @ " + tenant)
	if strconv.Itoa(req.UserId) == "" && strconv.Itoa(req.EquipmentId) == "" {
		return errors.New("未传入删除资格参数不完整，请核对后再试")
	}
	err = equipment.NewSrv(tenant).DeleteAdvance(req)
	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	return nil
}

// SearchAdvanceTime 查看设备优先预约时间段
func(e *Equipment) SearchAdvanceTime(ctx context.Context, req *model.QualificationListReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.SearchAdvanceTime request @ " + tenant)
	if req.Size == 0 {
		req.Size = DefaultPageNum
	}
	if req.Current < 0 {
		req.Current = DefaultPageCurrent
	}
	equipmentId := req.InstrumentId
	if strconv.Itoa(equipmentId) == "" {
		return errors.New("设备Id为空，请检查传入参数")
	}
	list, total, err := equipment.NewSrv(tenant).SearchAdvanceTime(req)
	_, err, code, msg := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = msg
	rsp.Data = g.Map{"total": total, "tableData": list}
	return nil
}

// AddAdvanceTime 添加设备优先预约时间段
func(e *Equipment) AddAdvanceTime(ctx context.Context, req *model.AdvanceTimeReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	info, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.AddAdvanceTime request @ " + tenant)
	equipmentId := req.EquipmentId
	if strconv.Itoa(equipmentId) == "" {
		return errors.New("设备Id为空，请检查传入参数")
	}
	err = equipment.NewSrv(tenant).AddAdvanceTime(req, info)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Msg = "添加优先预约时间段成功"
	return nil
}

// DeleteAdvanceTime 删除设备预约时间段
func(e *Equipment) DeleteAdvanceTime(ctx context.Context, req *model.IdReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.DeleteAdvanceTime request @ " + tenant)
	if strconv.Itoa(req.Id) == "" {
		return errors.New("未传入删除id")
	}
	err = equipment.NewSrv(tenant).DeleteAdvanceTime(req.Id)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	return nil
}

// AppointmentTime 设备预约时间段
func(e *Equipment) AppointmentTime(ctx context.Context, req *model.IdReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.AppointmentTime request @ " + tenant)
	equipmentId := req.EquipmentId
	if strconv.Itoa(equipmentId) == "" {
		return errors.New("设备Id为空，请检查传入参数")
	}
	if strconv.Itoa(req.UserId) == "" {
		return errors.New("人员Id为空，请检查传入参数")
	}
	equipment.NewSrv(tenant).AppointmentTime(req)
	return nil
}

// SearchNoAppointment 查看不能预约时间段信息
func (e *Equipment) SearchNoAppointment(ctx context.Context, req *model.IdReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	info, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.SearchNoAppointment request @ " + tenant)
	equipmentId := req.EquipmentId
	if strconv.Itoa(equipmentId) == "" {
		return errors.New("设备Id为空，请检查传入参数")
	}
	if req.Date == "" {
		return errors.New("日期为空，请检查传入参数")
	}
	appointment, err := equipment.NewSrv(tenant).SearchNoAppointment(req, info)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	rsp.Data = appointment
	return nil
}

// ChangeInstrStauts 修改设备所属
func(e *Equipment) ChangeBelongs(ctx context.Context, req *model.IdReq, rsp *comm_def.CommonMsg) error {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return err
	}
	g.Log().Info("Received Equipment.ChangeBelongs request @ " + tenant)
	equipmentId := req.EquipmentId
	if strconv.Itoa(equipmentId) == "" {
		return errors.New("设备Id为空，请检查传入参数")
	}
	if req.Belongs == "" {
		return errors.New("设备所属为空")
	}
	err = equipment.NewSrv(tenant).ChangeBelongs(req)
	_, err, code, _ := myerrors.CheckError(err)
	if err != nil {
		return err
	}
	rsp.Code = code
	return nil
}