dsMin/dsBaseWeb/Business/BaseClass/BaseClassService/BaseClassProtoServiceRpc.go

package BaseClassService

import (
	"context"
	"dsBaseWeb/Business/BaseClass/BaseClassProto"
	"dsBaseWeb/Utils/GRpcUtil"
	"dsBaseWeb/Utils/LogUtil"
	"errors"
	"time"
)

/**
功能：获取班级列表
作者：吴缤
时间：2020-06-02 11:37:49
*/
func PageBaseClass(queryArg BaseClassProto.QueryArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.PageBaseClass(ctx, &queryArg)
	if err != nil {
		LogUtil.Error("获取班级列表错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：获取班级信息
作者：吴缤
时间：2020-06-02 11:38:52
*/
func GetBaseClass(modelArg BaseClassProto.ModelArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.GetBaseClass(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("获取班级信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：增加班级信息
作者：吴缤
时间：2020-06-02 11:39:20
*/
func AddBaseClass(modelArg BaseClassProto.ModelArg) (*BaseClassProto.Reply, error) {
	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
	defer cancel()
	conn := GRpcUtil.GetConnection()
	if conn == nil {
		return nil, errors.New("RPC服务未启动！")
	}
	//2、业务传参
	c := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.AddBaseClass(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("增加班级信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：删除班级信息
作者：吴缤
时间：2020-06-02 11:40:01
*/
func DeleteBaseClass(deleteIdsArg BaseClassProto.DeleteIdsArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.DeleteBaseClass(ctx, &deleteIdsArg)
	if err != nil {
		LogUtil.Error("删除班级信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：修改班级信息(只允许修改班级别名)
作者：吴缤
时间：2020-06-02 11:40:28
*/
func UpdateBaseClass(modelArg BaseClassProto.ModelArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.UpdateBaseClass(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("修改班级信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：根据学校ID获取学部(学段)信息
作者：吴缤
时间：2020-06-12 11:40:28
*/
func GetStage(modelArg BaseClassProto.ModelArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.GetStage(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("获取学部(学段)信息错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：根据学校ID和学部(学段)ID获取入学年份
作者：吴缤
时间：2020-06-12 11:40:28
*/
func GetRxnf(modelArg BaseClassProto.ModelArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.GetRxnf(ctx, &modelArg)
	if err != nil {
		LogUtil.Error("获取入学年份错误: ", err.Error())
	}
	return Reply, err
}

/**
功能：批量设置班级毕业状态 1：恢复为正常班级  -3：毕业
作者：吴缤
时间：2020-08-04 16:40:28
*/
func BacthSetClassGraduateStatus(bacthSetClassGraduateStageArg BaseClassProto.BacthSetClassGraduateStageArg) (*BaseClassProto.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 := BaseClassProto.NewBaseClassManageClient(conn)
	Reply, err := c.BacthSetClassGraduateStatus(ctx, &bacthSetClassGraduateStageArg)
	if err != nil {
		LogUtil.Error("批量设置班级毕业状态错误: ", err.Error())
	}
	return Reply, err
}