You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

250 lines
7.6 KiB

This file contains ambiguous Unicode characters!

This file contains ambiguous Unicode characters that may be confused with others in your current locale. If your use case is intentional and legitimate, you can safely ignore this warning. Use the Escape button to highlight these characters.

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
}