lims_adapter/service/access/device_task.go

package service

import (
	"context"
	"fmt"
	dao "lims_adapter/dao/access"

	"dashoo.cn/micro_libary/micro_srv"
	"dashoo.cn/micro_libary/request"
)

type DeviceTaskService struct {
	Dao      *dao.DeviceTaskDao
	Tenant   string
	userInfo request.UserInfo
}

func NewDeviceTaskService(ctx context.Context) (*DeviceTaskService, error) {
	tenant, err := micro_srv.GetTenant(ctx)
	if err != nil {
		return nil, fmt.Errorf("获取组合码异常：%s", err.Error())
	}
	// 获取用户信息
	userInfo, err := micro_srv.GetUserInfo(ctx)
	if err != nil {
		return nil, fmt.Errorf("获取用户信息异常：%s", err.Error())
	}
	return &DeviceTaskService{
		Dao:      dao.NewDeviceTaskDao(tenant),
		Tenant:   tenant,
		userInfo: userInfo,
	}, nil
}

func (s DeviceTaskService) Delete(ctx context.Context, id []int) error {
	if len(id) == 0 {
		return nil
	}
	_, err := s.Dao.Where("Id  IN (?)", id).Delete()
	return err
}