lims_adapter/service/repair/repair.go

package repair

import (
	"context"
	"database/sql"
	"fmt"
	dao "lims_adapter/dao/repair"
	"lims_adapter/model/repair"

	"dashoo.cn/common_definition/admin/permission_def"
	"dashoo.cn/micro_libary/micro_srv"
	"dashoo.cn/micro_libary/myerrors"
	"dashoo.cn/micro_libary/request"
	"github.com/gogf/gf/os/gtime"
	"github.com/gogf/gf/util/gvalid"
)

const PermissionRepairProcess = "repair:process"

type RepairService struct {
	Dao       *dao.RepairDao
	DaoFlow   *dao.RepairFlowDao
	DaoResult *dao.RepairResultDao
	Tenant    string
	userInfo  request.UserInfo
}

func NewRepairService(ctx context.Context) (*RepairService, 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 &RepairService{
		Dao:       dao.NewRepairDao(tenant),
		DaoFlow:   dao.NewRepairFlowDao(tenant),
		DaoResult: dao.NewRepairResultDao(tenant),
		Tenant:    tenant,
		userInfo:  userInfo,
	}, nil
}

func (s RepairService) Get(ctx context.Context, req *repair.RepairGetReq) (*repair.RepairGetRsp, error) {
	f, err := s.Dao.Where("Id = ?", req.Id).One()
	if err != nil {
		return nil, err
	}
	if f == nil {
		return nil, myerrors.NewMsgError(nil, "报修不存在")
	}
	flow, err := s.DaoFlow.Where("RepairId = ?", f.Id).All()
	if err != nil {
		return nil, err
	}
	result, err := s.DaoResult.Where("RepairId = ?", f.Id).All()
	if err != nil {
		return nil, err
	}

	return &repair.RepairGetRsp{
		Repair: *f,
		Flow:   flow,
		Result: result,
	}, nil
}

func (s RepairService) List(ctx context.Context, req *repair.RepairListReq) (int, []*repair.Repair, error) {
	dao := &s.Dao.RepairDao
	if req.Status != 0 {
		dao = dao.Where("Status = ?", req.Status)
	}
	if req.Type != "" {
		dao = dao.Where("Type = ?", req.Type)
	}
	if req.CreatedByName != "" {
		dao = dao.Where("CreatedByName LIKE ?", fmt.Sprintf("%%%s%%", req.CreatedByName))
	}
	if req.CreatedAtStart != nil {
		dao = dao.Where("CreatedAt > ?", req.CreatedAtStart)
	}
	if req.CreatedAtEnd != nil {
		dao = dao.Where("CreatedAt < ?", req.CreatedAtEnd)
	}

	allow, err := Allow(s.Tenant, s.userInfo.Uuid, PermissionRepairProcess)
	if err != nil {
		return 0, nil, err
	}
	if !allow {
		dao = dao.Where("CreatedById = ?", s.userInfo.Id)
	}

	total, err := dao.Count()
	if err != nil {
		return 0, nil, err
	}

	if req.Page != nil {
		if req.Page.Current == 0 {
			req.Page.Current = 1
		}
		if req.Page.Size == 0 {
			req.Page.Size = 10
		}
		dao = dao.Page(req.Page.Current, req.Page.Size)
	}

	dao = dao.Order("CreatedAt", "desc")
	ent, err := dao.All()
	return total, ent, err
}

type organize struct {
	Id       int
	FullName string
}

func (s RepairService) Add(ctx context.Context, req *repair.RepairAddReq) (int, error) {
	validErr := gvalid.CheckStruct(ctx, req, nil)
	if validErr != nil {
		return 0, myerrors.NewMsgError(nil, validErr.Current().Error())
	}
	dept := &organize{}
	err := s.Dao.DB.Table("base_organize").Where("Id", s.userInfo.DeptId).Struct(dept)
	if err == sql.ErrNoRows {
		return 0, myerrors.NewMsgError(err, fmt.Sprintf("部门不存在 %s", s.userInfo.DeptId))
	}
	if err != nil {
		return 0, err
	}

	id, err := s.Dao.InsertAndGetId(repair.Repair{
		Type:               req.Type,
		Status:             1,
		Content:            req.Content,
		CurrentProcessorId: 0,
		CreatedById:        int(s.userInfo.Id),
		CreatedByName:      s.userInfo.RealName,
		CreatedByMobile:    req.Mobile,
		CreatedByEmail:     req.Email,
		CreatedByDeptId:    dept.Id,
		CreatedByDeptName:  dept.FullName,
		CreatedAt:          gtime.New(),
		UpdatedAt:          gtime.New(),
	})
	if err != nil {
		return 0, err
	}

	_, err = s.DaoFlow.Insert(repair.RepairFlow{
		RepairId:      int(id),
		Type:          1,
		Status:        1,
		ProcessById:   int(s.userInfo.Id),
		ProcessByName: s.userInfo.RealName,
		Note:          "",
		CreatedAt:     gtime.New(),
		UpdatedAt:     gtime.New(),
	})
	return int(id), err
}

func (s RepairService) Trans(ctx context.Context, req *repair.RepairTransReq) error {
	validErr := gvalid.CheckStruct(ctx, req, nil)
	if validErr != nil {
		return myerrors.NewMsgError(nil, validErr.Current().Error())
	}
	r, err := s.Dao.DB.Table("base_user").Where("Id", req.UserId).One()
	if err != nil {
		return err
	}
	if r.IsEmpty() {
		return myerrors.NewMsgError(nil, fmt.Sprintf("转交人不存在: %d", req.UserId))
	}

	f, err := s.Dao.Where("Id = ?", req.Id).One()
	if err != nil {
		return err
	}
	if f == nil {
		return myerrors.NewMsgError(nil, fmt.Sprintf("报修不存在: %d", req.Id))
	}

	_, err = s.Dao.Where("Id = ?", req.Id).Data("CurrentProcessorId", req.UserId).Update()
	if err != nil {
		return err
	}
	_, err = s.DaoFlow.Insert(repair.RepairFlow{
		RepairId:      req.Id,
		Type:          2,
		Status:        1,
		ProcessById:   int(s.userInfo.Id),
		ProcessByName: s.userInfo.RealName,
		Note:          req.Note,
		CreatedAt:     gtime.New(),
		UpdatedAt:     gtime.New(),
	})
	return err
}

func (s RepairService) Process(ctx context.Context, req *repair.RepairProcessReq) error {
	validErr := gvalid.CheckStruct(ctx, req, nil)
	if validErr != nil {
		return myerrors.NewMsgError(nil, validErr.Current().Error())
	}
	f, err := s.Dao.Where("Id = ?", req.Id).One()
	if err != nil {
		return err
	}
	if f == nil {
		return myerrors.NewMsgError(nil, fmt.Sprintf("报修不存在: %d", req.Id))
	}

	_, err = s.Dao.Where("Id = ?", req.Id).Data("Status", 2).Update()
	if err != nil {
		return err
	}
	_, err = s.DaoFlow.Insert(repair.RepairFlow{
		RepairId:      req.Id,
		Type:          3,
		Status:        1,
		ProcessById:   int(s.userInfo.Id),
		ProcessByName: s.userInfo.RealName,
		Note:          "",
		CreatedAt:     gtime.New(),
		UpdatedAt:     gtime.New(),
	})
	if err != nil {
		return err
	}
	_, err = s.DaoResult.Insert(repair.RepairResult{
		RepairId:      req.Id,
		ProcessById:   int(s.userInfo.Id),
		ProcessByName: s.userInfo.RealName,
		ProcessType:   req.Type,
		ProcessNote:   req.Note,
		CreatedAt:     gtime.New(),
		UpdatedAt:     gtime.New(),
	})
	return err
}

func (s RepairService) Reactivate(ctx context.Context, req *repair.RepairReactivateReq) error {
	validErr := gvalid.CheckStruct(ctx, req, nil)
	if validErr != nil {
		return myerrors.NewMsgError(nil, validErr.Current().Error())
	}
	f, err := s.Dao.Where("Id = ?", req.Id).One()
	if err != nil {
		return err
	}
	if f == nil {
		return myerrors.NewMsgError(nil, fmt.Sprintf("报修不存在: %d", req.Id))
	}

	_, err = s.Dao.Where("Id = ?", req.Id).Data(
		map[string]interface{}{
			"Status":             1,
			"CurrentProcessorId": 0,
		}).Update()
	if err != nil {
		return err
	}
	_, err = s.DaoFlow.Insert(repair.RepairFlow{
		RepairId:      req.Id,
		Type:          4,
		Status:        1,
		ProcessById:   int(s.userInfo.Id),
		ProcessByName: s.userInfo.RealName,
		Note:          req.Note,
		CreatedAt:     gtime.New(),
		UpdatedAt:     gtime.New(),
	})
	return err
}

type id struct {
	Id int
}

func (s RepairService) Processor(ctx context.Context) ([]repair.RepairProcessorRsp, error) {
	rsp := []repair.RepairProcessorRsp{}
	menu := &id{}
	err := s.Dao.DB.Table("base_menu").
		Where("Permission = ?", PermissionRepairProcess).
		Fields("Id").Struct(menu)
	if err == sql.ErrNoRows {
		return nil, myerrors.NewMsgError(err,
			fmt.Sprintf("未配置权限: %s", PermissionRepairProcess))
	}
	if err != nil {
		return nil, err
	}

	roles := []id{}
	err = s.Dao.DB.Table("base_role_menu").
		Where("find_in_set(?, `MenuIds`)", menu.Id).
		Fields("RoleId as Id").Structs(&roles)
	if err == sql.ErrNoRows {
		return rsp, nil
	}
	if err != nil {
		return nil, err
	}
	if len(roles) == 0 {
		return rsp, nil
	}

	dao := s.Dao.DB.Table("base_user a").LeftJoin("base_user_role b", "b.UserId=a.Id")
	orsql := ""
	for i, r := range roles {
		if i != 0 {
			orsql += " OR "
		}
		orsql += fmt.Sprintf("find_in_set(%d, `RoleIds`)", r.Id)
	}
	dao = dao.Where("a.Enabled = 1").Where(fmt.Sprintf("(%s)", orsql))
	err = dao.Fields("a.Id, a.Realname").Structs(&rsp)
	if err == sql.ErrNoRows {
		return rsp, nil
	}
	return rsp, err
}

func Allow(tenant, uuid, permission string) (bool, error) {
	permissionSrv := micro_srv.InitMicroSrvClient("Permission", "micro_srv.admin")
	defer permissionSrv.Close()
	rsp := &permission_def.PermissionResp{}
	err := permissionSrv.Call(context.TODO(), "GetAllPermissionByUser", &permission_def.UuidReq{
		Tenant: tenant,
		Uuid:   uuid,
	}, rsp)
	if err != nil {
		return false, fmt.Errorf("获取权限失败 %s", err.Error())
	}
	for _, p := range rsp.UserPermissions {
		if p == permission {
			return true, nil
		}
	}
	return false, nil
}