update

dsBaseRpc/Config/Config.ini

@@ -27,9 +27,6 @@ port = 8001
 [project]
 project_name = dsBaseRpc
 
-[kafka]
-KafkaAddress = 10.10.14.187:9092
-
 # 数据汇集的地址
 [dataExchange]
 host                = http://10.10.14.186:9009

dsBaseRpc/RpcService/BaseTeacher/BaseTeacherDao/BaseTeacherDao.go

@@ -1041,7 +1041,7 @@ func getOrgNameMap(bureauId string) (map[string]string, error) {
 作者：黄海
 时间：2020-08-05
 */
-func InsertTeacherOrgInfo(personIds []string, orgId string, isMain int32) (bool, string, error) {
+func AddTeacherOrgInfo(personIds []string, orgId string, isMain int32) (bool, string, error) {
 	//(1)获取单位ID
 	list := SqlKit.QueryByIds([]string{orgId}, "t_base_organization")
 	if len(list) == 0 {

dsBaseRpc/Utils/ConfigUtil/ConfigUtil.go

@@ -36,8 +36,6 @@ var (
 	RpcServerPort string
 	//项目名称
 	ProjectName string
-	//kafka地址
-	KafkaAddress string
 
 	//数据汇集中心地址
 	DataExchangeHost          string
@@ -93,8 +91,7 @@ func init() {
 	RpcServerPort = iniParser.GetString("rpcServer", "port")
 	//项目名称
 	ProjectName = iniParser.GetString("project", "project_name")
-	//kafka地址
+
-	KafkaAddress = iniParser.GetString("kafka", "KafkaAddress")
 	//数据汇集中心地址
 	DataExchangeHost = iniParser.GetString("dataExchange", "host")
 	DataExchangeUrl = DataExchangeHost + iniParser.GetString("dataExchange", "exchangeUrl")