lims_adapter/service/system/system.go

package system

import (
	"dashoo.cn/micro_libary/request"
	"errors"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/os/gtime"
	"lims_adapter/dao/system"
	model "lims_adapter/model/system"
	"lims_adapter/model/user"
	"strconv"
)

type Service struct {
	Dao    *system.BaseItemdetailsDao
	Tenant string
}

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

// DictInfo 获取字典数据
func (s Service) DictInfo(req *model.DictReq) (dictInfo []model.BaseItemdetails, err error) {
	where := "DictCode = '" + req.DictCode + "' and Enabled = 1"
	if req.ItemName != "" {
		where += " and ItemName = '" + req.ItemName + "'"
	}
	if req.ItemValue != "" {
		where += " and ItemValue = '" + req.ItemValue + "'"
	}
	if req.SortCode != "" {
		where += " and SortCode = '" + req.SortCode + "'"
	}
	err = s.Dao.M.Where(where).Scan(&dictInfo)
	if err != nil {
		return dictInfo, err
	}
	return dictInfo, nil
}

// UserList 设备预约权管理：获取用户信息
func (s Service) UserList(req *user.UserInfoReq) (userInfos user.UserInfoRsp, err error) {
	where := "Enabled = 1"
	departmentId := strconv.Itoa(req.DepartmentId)
	instrumentId := strconv.Itoa(req.InstrumentId)
	current := req.PageNun
	size := req.PageSize
	count := 0
	model := s.Dao.DB.Model("base_user a")
	if departmentId != "" && departmentId != "0" {
		where += " and DepartmentId = " + departmentId
	}
	if req.ReqType == 1 { // 预约资格
		count, err = model.Where(where).Count()
	} else if req.ReqType == 2 { // 优先预约权
		where += " and Id not in(select UserId from base_equipment_qualification where EquipmentId = " +
			instrumentId + " and Qualification in (0,3))"
		count, err = model.Where(where).Count()
	}
	if err != nil {
		return userInfos, err
	}
	userInfos.Total = count
	err = model.Page(current, size).Scan(&userInfos.Records)
	return userInfos, nil
}

// GetProgramGroup 获取课题组信息
func (s Service) GetProgramGroup(id int) ([]model.BaseProgramGroup, error) {
	programGroup := []model.BaseProgramGroup{}
	err := s.Dao.DB.Model("base_program_group").Where("OrganizeId = ?", id).Scan(&programGroup)
	if err != nil {
		return nil, err
	}
	return programGroup, nil
}

// GetUserList 主从用户管理：获取用户信息
func (s Service) GetUserList(req *user.UserInfoReq, userId int32) (userInfos user.SearchUserInfoRsp, err error) {
	where := "a.Enabled = 1"
	departmentId := strconv.Itoa(req.DepartmentId)
	current := req.PageNun
	size := req.PageSize
	count := 0
	fields := "a.Id, a.UserName, a.RealName, a.Mobile, a.DepartmentName"
	model := s.Dao.DB.Model("base_user a")
	if departmentId != "" && departmentId != "0" {
		where += " and DepartmentId = " + departmentId
	}
	if req.UserName != "" {
		where += " and (a.UserName LIKE '%" + req.UserName + "%' or a.RealName LIKE '%" + req.UserName + "%')"
	}
	if req.Mobile != "" {
		where += " and a.Mobile LIKE '%" + req.Mobile + "%'"
	}
	if req.ReqType == 1 { // 获取主用户信息
		count, err = model.InnerJoin("master_user e", "a.Id = e.UserId ").Where(where + " and e.Id is not null").Count()
	} else if req.ReqType == 2 { // 从用户信息
		if req.IsSelf == "1" {
			count, err = model.InnerJoin("base_user_relation e", "a.Id = e.UserId").Where(where).Count()
		} else {
			count, err = model.InnerJoin("base_user_relation e", "a.Id = e.UserId").Where(where + " and e.Pid = " + strconv.Itoa(int(userId))).Count()
		}
		fields = "a.Id, a.UserName, a.RealName, a.Mobile, a.DepartmentName,e.Pid AS MasterId"
	} else if req.ReqType == 3 { // 不是主从用户信息
		count, err = model.Where(where + " and a.Id not in (select UserId from master_user) and a.Id not in (select UserId from base_user_relation)").Count()
	}
	if err != nil {
		return userInfos, err
	}
	userInfos.Total = count
	err = model.Fields(fields).Page(current, size).Scan(&userInfos.Records)
	return userInfos, nil
}

// AddMainUserOrSubUser 添加主从用户
func (s Service) AddMainUserOrUser(req *user.AddMainOrSubReq, userInfo request.UserInfo) error {
	tx, err := s.Dao.DB.Begin()
	if err != nil {
		return err
	}
	for _, v := range req.Ids {
		if req.ReqType == 1 { // 新增主用户
			_, err = tx.Insert("master_user", g.Map{"UserId": v})
			if err != nil {
				tx.Rollback()
				return err
			}
		} else if req.ReqType == 2 { // 添加主从用户关系
			// 添加主从用户关系表
			saveEntity := user.BaseUserRelation{
				UserId:    v,
				Pid:       int(userInfo.Id),
				PName:     userInfo.RealName,
				CreatedBy: int(userInfo.Id),
				CreatedAt: gtime.Now(),
			}
			_, err = tx.Insert("base_user_relation", saveEntity)
			if err != nil {
				tx.Rollback()
				return err
			}
		}
	}
	return tx.Commit()
}

// DeleteMainUserOrSubUser 删除主从用户
func (s Service) DeleteMainUserOrSubUser(req *user.AddMainOrSubReq, info request.UserInfo) error {
	if req.ReqType == 1 { // 删除主用户 先判断是否有从用户
		count, err := s.Dao.DB.Model("base_user_relation").Where("Pid = ?", req.Id).Count()
		if err != nil {
			return err
		}
		if count > 0 {
			return errors.New("该用户有从用户,无法删除！")
		}
		count, err = s.Dao.DB.Model("settle_account_main").Where("AppointUserId = " + strconv.Itoa(req.Id) + " and SettleStatus = 0").Count()
		if err != nil {
			return err
		}
		if count > 0 {
			return errors.New("该用户有未结账明细,无法删除！")
		}
		count, err = s.Dao.DB.Model("settle_account_bill").Where("MainUserId = " + strconv.Itoa(req.Id) + " and Status = 0").Count()
		if err != nil {
			return err
		}
		if count > 0 {
			return errors.New("该用户有未结账账单,无法删除！")
		}
		_, err = s.Dao.DB.Model("master_user").Delete("UserId = ?", req.Id)
		if err != nil {
			return err
		}
		_, err = s.Dao.DB.Model("base_user_relation").Delete("Pid = ?", req.Id)
		return err
	} else if req.ReqType == 2 { // 删除从用户 先判断是否有未结账
		count, err := s.Dao.DB.Model("settle_account_main").Where("AppointUserId = " + strconv.Itoa(req.Id) + " and SettleStatus = 0").Count()
		if err != nil {
			return err
		}
		if count > 0 {
			return errors.New("该用户有未结账明细,无法删除！")
		}
		_, err = s.Dao.DB.Model("base_user_relation").Delete("UserId = ?", req.Id)
		if err != nil {
			return err
		}
		_, err = s.Dao.DB.Model("base_user_relation").Delete("UserId = ?", req.Id)
		return err
	}
	return nil
}

// UserBindAccount 用户绑定
func (s Service) UserBindAccount(req *user.UserBindAccountReq) error {
	_, err := s.Dao.DB.Model("user_account_bind").Delete("UserId = " + strconv.Itoa(req.UserId))
	if err != nil {
		return err
	}
	_, err = s.Dao.DB.Model("user_account_bind").Insert(g.Map{"UserId": req.UserId, "AccountId": req.Id, "CreateOn": gtime.Now()})
	if err != nil {
		return err
	}
	return nil
}