'commit'

dsBaseRpc/RpcService/BaseOrganization/BaseOrganizationDao/BaseOrganizationDao.go

@@ -555,7 +555,7 @@ func ListEduByCityCode(cityCode string) ([]map[string]interface{}, error) {
 作者：黄海
 时间：2020-07-17
 */
-func ModifyFsb(bureauId string, fsbCode []string) error {
+func UpdateFsb(bureauId string, fsbCode []string) error {
 	//1、旧数据全面修改为-2
 	myBuilder := builder.Dialect(builder.MYSQL).Update(builder.Eq{"b_use": -2}).From("t_base_school_fsb").
 		Where(builder.Eq{"bureau_id": bureauId}).And(builder.Eq{"b_use": 1})
@@ -575,3 +575,14 @@ func ModifyFsb(bureauId string, fsbCode []string) error {
 	}
 	return nil
 }
+
+/**
+功能：获取附设班信息
+作者：黄海
+时间：2020-08-21
+*/
+func GetFsb(bureauId string) ([]map[string]interface{}, error) {
+	sql := `select * from t_base_school_fsb where b_use=1 and bureau_id=?`
+	list, err := db.SQL(sql, bureauId).Query().List()
+	return list, err
+}

dsBaseRpc/RpcService/BaseOrganization/BaseOrganizationService/BaseOrganizationService.go

@@ -20,6 +20,7 @@ import (
 	"dsBaseRpc/Utils/PinYinUtil"
 	"dsBaseRpc/Utils/SqlKit"
 	"dsBaseRpc/models"
+	"encoding/json"
 	"errors"
 	"fmt"
 )
@@ -38,7 +39,25 @@ func (s *Rpc) GetBaseOrganization(ctx context.Context, in *BaseOrganizationProto
 	var reply BaseOrganizationProto.Reply
 	//使用通用方法获取单条记录
 	list := SqlKit.QueryByIds([]string{in.OrgId}, "t_base_organization")
-
+	if len(list) > 0 {
+		//扩展一下附设班信息
+		fsbArray, err := BaseOrganizationDao.GetFsb(in.BureauId)
+		if err != nil {
+			reply.Success = false
+			reply.Message = Const.DataBaseActionError
+			LogUtil.Error(ErrorConst.SqlQueryError, "执行GetFsb时发生严重错误："+err.Error())
+			return &reply, err
+		}
+		//转换数组为JSON数据格式
+		b, err := json.Marshal(fsbArray)
+		if err != nil {
+			reply.Success = false
+			reply.Message = Const.DataBaseActionError
+			LogUtil.Error(ErrorConst.SqlQueryError, "执行fsbArray转JSON时发生严重错误："+err.Error())
+			return &reply, err
+		}
+		list[0]["fsb"] = string(b)
+	}
 	//将结果序列化
 	reply.Success = true
 	reply.Count = 1
@@ -213,7 +232,7 @@ func (s *Rpc) AddBaseOrganization(ctx context.Context, in *BaseOrganizationProto
 		return nil, err
 	}
 	//保存附设班信息
-	BaseOrganizationDao.ModifyFsb(model.BureauId, in.FsbIds)
+	BaseOrganizationDao.UpdateFsb(model.BureauId, in.FsbIds)
 	// *********************************************************************//
 	// 组织机构类型 1：教育局 2：学校 3：部门 4：院 5：系 6：专业 7：教辅单位,8:大学区
 	// 如果是学校，教辅单位，大学区的话，需要生成管理员账号
@@ -494,8 +513,8 @@ func (s *Rpc) UpdateBaseOrganization(ctx context.Context, in *BaseOrganizationPr
 		return nil, err
 	}
 	//保存附设班信息
-	BaseOrganizationDao.ModifyFsb(model.BureauId, in.FsbIds)
-	
+	BaseOrganizationDao.UpdateFsb(model.BureauId, in.FsbIds)
+
 	//是否传递了部门管理员 ,黄海添加于2020-06-04
 	if len(in.OrgManagerIds) > 0 && len(in.OrgManagerIds[0]) > 0 {
 		err = BaseOrganizationManagerDao.UpdateOrgManager(model.OrgId, in.OrgManagerIds)