package BaseOrganizationService

import (
	"context"
	"dsBaseWeb/Business/BaseOrganization/BaseOrganizationProto"
	"dsBaseWeb/Utils/GRpcUtil"
	"dsBaseWeb/Utils/LogUtil"
	"errors"
	"time"
)

/**
功能：获取组织机构列表
作者：吴缤
日期：2020-05-22
*/
func PageBaseOrganization(queryArg BaseOrganizationProto.QueryArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.PageBaseOrganization(ctx, &queryArg)
	if err != nil {
		LogUtil.Error("获取组织机构列表错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：根据ORG_ID获取组织机构信息
作者：吴缤
时间：2020-05-20 09:17:45
*/
func GetBaseOrganization(modelArg BaseOrganizationProto.ModelArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.GetBaseOrganization(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("获取组织机构信息: ", err.Error())
	}
	return Reply, err
}

/**
功能：修改组织机构信息
作者：吴缤
时间：2020-05-20 15:30:46
*/
func UpdateBaseOrganization(modelArg BaseOrganizationProto.ModelArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.UpdateBaseOrganization(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("修改组织机构信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：增加组织机构信息
作者：吴缤
时间：2020-05-20 14:18:21
*/
func AddBaseOrganization(modelArg BaseOrganizationProto.ModelArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.AddBaseOrganization(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("增加教辅单位信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：删除组织机构信息
作者：吴缤
时间：2020-05-20 14:26:46
*/
func DeleteBaseOrganization(deleteIdsArg BaseOrganizationProto.DeleteIdsArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.DeleteBaseOrganization(ctx, &deleteIdsArg)
	if err != nil {
		LogUtil.Error("删除教辅单位信息错误: ", err.Error())
	}
	return Reply, err
}

func GetMultipleBaseOrganization(ids []string) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.GetMultipleBaseOrganization(ctx, &BaseOrganizationProto.MultipleQueryArg{Ids: ids})
	if err != nil {
		LogUtil.Error("获取单位信息错误: ", err.Error())
	}
	return Reply, err
}

func GetBureauOrgTree(modelArg BaseOrganizationProto.ModelArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.GetBureauOrgTree(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("获取单位部门树错误: ", err.Error())
	}
	return Reply, err
}

func GetOrgManager(ids []string) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.GetOrgManager(ctx, &BaseOrganizationProto.MultipleQueryArg{Ids: ids})
	if err != nil {
		LogUtil.Error("获取部门领导错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：启用教育局
作者：吴缤
时间：2020-06-08 10:30:20
*/
func SetEnableEdu(multipleQueryArg BaseOrganizationProto.MultipleQueryArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.SetEnableEdu(ctx, &multipleQueryArg)
	if err != nil {
		LogUtil.Error("获取部门领导错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：禁用教育局
作者：吴缤
时间：2020-06-08 10:30:20
*/
func SetDisableEdu(multipleQueryArg BaseOrganizationProto.MultipleQueryArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.SetDisableEdu(ctx, &multipleQueryArg)
	if err != nil {
		LogUtil.Error("获取部门领导错误: ", err.Error())
	}
	return Reply, err
}

func ListOrgInfoByOrgKeyWord(listOrgArg BaseOrganizationProto.ListOrgArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.ListOrgInfoByOrgKeyWord(ctx, &listOrgArg)
	if err != nil {
		LogUtil.Error("查询单位列表错误: ", err.Error())
	}
	return Reply, err
}

func ListEduByCityCode(arg BaseOrganizationProto.CityCodeArg) (*BaseOrganizationProto.Reply, error) {
	//1、准备动作：连接服务器
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseOrganizationProto.NewBaseOrganizationManageClient(conn)
	Reply, err := c.ListEduByCityCode(ctx, &arg)
	if err != nil {
		LogUtil.Error("获取教育局列表错误: ", err.Error())
	}
	return Reply, err
}