新增组织管理模块

src/bean/entity/system_organization.go

@@ -2,7 +2,7 @@ package entity
 
 import "time"
 
-//系统组织表
+// 系统组织表
 type SystemOrganization struct {
 	Id               int64     `json:"id" xorm:"pk autoincr"`       //id
 	OrganizationId   string    `json:"organization_id"`             //组织id
@@ -10,13 +10,12 @@ type SystemOrganization struct {
 	POrganizationId  string    `json:"p_organization_id"`           //父级组织id
 	Description      string    `json:"description"`                 //组织介绍
 	OrganizationCode string    `json:"organization_code"`           //组织机构代码
-	Attachment       string    `json:"attachment"`                  //组织附件
 	Sort             int64     `json:"sort"`                        //排序
 	DataType         int64     `json:"data_type"`                   //数据类型(0目录 1组织)
 	CreatedTime      time.Time `json:"created_time" xorm:"created"` //创建时间
 	UpdatedTime      time.Time `json:"updated_time" xorm:"updated"` //更新时间
 	IsDeleted        int64     `json:"is_deleted"`                  //是否删除0未删除 1已删除
-	CreatedBy        string    `json:"created_by"`                  //创建者
-	UpdatedBy        string    `json:"updated_by"`                  //更新者
+	CreatedBy        int       `json:"created_by"`                  //创建者
+	UpdatedBy        int       `json:"updated_by"`                  //更新者
 	Level            int64     `json:"level"`                       //组织节点层级
 }

src/bean/vo/request/system_organization.go

 package request
 
-//添加组织入参
+// 添加组织入参
 type OrgInput struct {
 	POrganizationId  string `json:"p_organization_id"` //父级组织id或者目录id
 	Name             string `json:"name"`              //组织名称or目录名称
 	OrganizationCode string `json:"organization_code"` //组织机构代码
 	Description      string `json:"description"`       //组织介绍
-	Attachment       string `json:"attachment"`        //组织附件
 	DataType         int64  `json:"data_type"`         //数据类型(0目录 1组织)
 }
 
-//组织排序参数
+// 组织排序参数
 type OrgSortInput struct {
 	Id   int64 `json:"id" xorm:"pk autoincr"` //id
 	Sort int64 `json:"sort"`                  //排序
 }
 
-//查询组织详情参数
+// 查询组织详情参数
 type QueryOrgDetailInput struct {
 	OrganizationId string `form:"organization_id"`    // 组织id
 	State          string `form:"state" xorm:"state"` // 状态0禁用 1启用
@@ -26,14 +25,14 @@ type QueryOrgDetailInput struct {
 	DataType       string `form:"data_type"`          // 数据类型(0目录 1组织 2平台用户组织)
 }
 
-//查询业务系统信息
+// 查询业务系统信息
 type GetBusinessMsgInput struct {
 	Limit          int    `form:"limit"`           // 页条
 	Page           int    `form:"page"`            // 页码
 	OrganizationId string `form:"organization_id"` // 所属组织
 }
 
-//新增用户
+// 新增用户
 type OrgUserInput struct {
 	Logo           string   `json:"logo"`                                         // 头像logo
 	SystemAccount  string   `json:"system_account"  vd:"len($)>1;msg:'请输入账号'"`    // 系统账号
@@ -50,7 +49,7 @@ type OrgUserInput struct {
 	IsAdmin        int      `json:"is_admin"`                                     // 用户类型(1.业务系统账号 2.组织管理员账号 3.平台用户账号)
 }
 
-//编辑用户
+// 编辑用户
 type UpdateOrgUserInput struct {
 	Logo          string `json:"logo"`                                      // 头像logo
 	SystemAccount string `json:"system_account"  vd:"len($)>1;msg:'请输入账号'"` // 系统账号
@@ -64,12 +63,12 @@ type UpdateOrgUserInput struct {
 	DocumentNumber string `json:"document_number"`             //证件号
 }
 
-//删除用户
+// 删除用户
 type DelOrgUser struct {
 	Ids []int `json:"ids" xorm:"pk autoincr"` //id
 }
 
-//去重校验
+// 去重校验
 type CheckRepetition struct {
 	Id           int    `form:"id" json:"id"`
 	ContactPhone string `form:"contact_phone" json:"contact_phone"`

src/bean/vo/response/system_organization.go

 package response
 
 import (
-	"time"
-
 	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/jsontime"
 )
 
@@ -14,11 +12,10 @@ type SystemOrganizationTree struct {
 	POrganizationId  string                   `json:"p_organization_id"`           //父级组织id
 	Description      string                   `json:"description"`                 //组织介绍
 	OrganizationCode string                   `json:"organization_code"`           //组织机构代码
-	Attachment       string                   `json:"attachment"`                  //组织附件
 	Sort             int64                    `json:"sort"`                        //排序
 	DataType         int64                    `json:"data_type"`                   //数据类型(0目录 1组织)
-	CreatedTime      time.Time                `json:"created_time" xorm:"created"` //创建时间
-	UpdatedTime      time.Time                `json:"updated_time" xorm:"updated"` //更新时间
+	CreatedTime      jsontime.Time            `json:"created_time" xorm:"created"` //创建时间
+	UpdatedTime      jsontime.Time            `json:"updated_time" xorm:"updated"` //更新时间
 	CreatedBy        string                   `json:"created_by"`                  //创建者
 	UpdatedBy        string                   `json:"updated_by"`                  //更新者
 	Level            int64                    `json:"level"`                       //组织节点层级
@@ -27,13 +24,12 @@ type SystemOrganizationTree struct {
 
 // 组织管理员列表
 type OrgAdminUser struct {
-	Id            int32         `json:"id" xorm:"pk autoincr" `               // id
+	Id            int           `json:"id" xorm:"pk autoincr" `               // id
 	SystemAccount string        `json:"system_account" xorm:"system_account"` // 系统账号
-	ContactPhone  string        `json:"contact_phone" xorm:"contact_phone"`   // 联系人电话
 	SystemRole    []string      `json:"system_role" xorm:"-"`                 // 系统角色
 	CreatedTime   jsontime.Time `json:"created_time" xorm:"created" `         // 创建时间
 	State         int           `json:"state" xorm:"state"`                   // 状态0禁用1启用
-	SystemId      string        `json:"system_id" xorm:"system_id"`           // 系统账号id
+	Phone         string        `json:"phone" xorm:"phone"`                   // 手机号
 }
 
 // 账号详情
@@ -74,15 +70,15 @@ type UpdateOrgUser struct {
 
 // 机构详情
 type OrgDetail struct {
-	OrganizationType     string        `json:"organization_type"`           //机构类型
-	OrganizationCode     string        `json:"organization_code"`           //组织机构代码
-	Name                 string        `json:"name"`                        //机构名称
-	CreatedTime          jsontime.Time `json:"created_time" xorm:"created"` //创建时间
-	OrgAdminNumber       int64         `json:"org_admin_number"`            //组织管理员数
-	BusinessSystemNumber int64         `json:"business_system_number"`      //业务系统数
-	Attachment           string        `json:"attachment"`                  //组织附件
-	Description          string        `json:"description"`                 //组织介绍
-	PlatformUsersNumber  int64         `json:"platform_users_number"`       //平台用户数
+	//OrganizationType string        `json:"organization_type"`           //机构类型
+	OrganizationCode string        `json:"organization_code"`           //组织机构代码
+	Name             string        `json:"name"`                        //机构名称
+	CreatedTime      jsontime.Time `json:"created_time" xorm:"created"` //创建时间
+	//OrgAdminNumber       int64         `json:"org_admin_number"`            //组织管理员数
+	//BusinessSystemNumber int64         `json:"business_system_number"`      //业务系统数
+	//Attachment           string        `json:"attachment"`                  //组织附件
+	Description         string `json:"description"`           //组织介绍
+	PlatformUsersNumber int64  `json:"platform_users_number"` //平台用户数
 }
 
 type BusinessSystem struct {

src/bean/vo/response/system_role.go

+package response
+
+import (
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/jsontime"
+	"time"
+)
+
+// 系统用户角色关联查询
+type SystemUserRole struct {
+	SystemId string `json:"system_id" xorm:"system_id"` // 系统账号id
+	RoleName string `json:"role_name"`                  // 角色名称
+}
+type SystemRoleList struct {
+	Id            int64     `json:"id"`                                   // id
+	RoleName      string    `json:"role_name"`                            // 角色名称
+	RoleDesc      string    `json:"role_desc"`                            // 角色描述
+	State         int       `json:"state"`                                // 状态0禁用1启用
+	CreatedBy     string    `json:"created_by"`                           // 角色创建人
+	CreatedTime   time.Time `json:"created_time"`                         // 角色创建时间
+	RoleType      int       `json:"role_type"`                            // 角色类型（0 普通角色 1 内置角色类型 不能删除和编辑 ）
+	RoleId        string    `json:"role_id"`                              // 角色id（uuid）
+	DataPurview   int       `json:"data_purview"`                         // 数据权限：1-仅自己，2-本组织所有，3-全平台所有
+	UserCount     int       `json:"user_count"`                           // 用户数
+	CantAllot     int       `json:"cant_allot"`                           // 是否可分配用户
+	SystemAccount string    `json:"system_account" xorm:"system_account"` // 系统账号
+}
+
+// SystemRoleDetailRes 系统角色详情
+type SystemRoleDetailRes struct {
+	Id          int64         `json:"id"`           // id
+	RoleName    string        `json:"role_name"`    // 角色名称
+	RoleDesc    string        `json:"role_desc"`    // 角色描述
+	State       int           `json:"state"`        // 状态0禁用1启用
+	DataPurview int           `json:"data_purview"` // 数据权限：1-仅自己，2-本组织所有，3-全平台所有
+	RoleId      string        `json:"role_id"`      // 角色id（uuid）
+	CreatedTime jsontime.Time `json:"created_time"` // 角色创建时间
+	UpdatedTime jsontime.Time `json:"updated_time"` // 角色更新时间
+	RoleType    int           `json:"role_type"`    // 角色类型（0 普通角色 1 内置角色类型 不能删除和编辑 ）
+	Menus       []SystemMenus `json:"menus"`        // 菜单
+}
+type SystemRoleListRes struct {
+	Id          int64         `json:"id"`           // id
+	RoleName    string        `json:"role_name"`    // 角色名称
+	RoleDesc    string        `json:"role_desc"`    // 角色描述
+	State       int           `json:"state"`        // 状态0禁用1启用
+	CreatedBy   string        `json:"created_by"`   // 角色创建人
+	CreatedTime jsontime.Time `json:"created_time"` // 角色创建时间
+	RoleType    int           `json:"role_type"`    // 角色类型（0 普通角色 1 内置角色类型 不能删除和编辑 ）
+	RoleId      string        `json:"role_id"`      // 角色id（uuid）
+	DataPurview int           `json:"data_purview"` // 数据权限：1-仅自己，2-本组织所有，3-全平台所有
+	UserCount   int           `json:"user_count"`   // 用户数
+	CantAllot   int           `json:"cant_allot"`   // 是否可分配用户
+
+}
+type SystemAllotUserList struct {
+	Id               int32     `json:"id" `                              // id
+	SystemAccount    string    `json:"system_account"`                   // 系统账号
+	IsAdmin          int       `json:"is_admin"`                         // 用户类型
+	ContactPhone     string    `json:"contact_phone"`                    // 联系人电话
+	OrganizationId   string    `json:"organization_id"`                  // 所属组织
+	OrganizationName string    `json:"organization_name" xorm:"name"`    // 所属组织
+	State            int       `json:"state"`                            // 状态0禁用1启用
+	CreatedTime      time.Time `json:"created_time"`                     // 创建时间
+	SystemId         string    `json:"system_id" xorm:"system_id"`       // 系统账号id
+	UrSystemId       string    `json:"ur_system_id" xorm:"ur_system_id"` // 系统账号id
+	IsBind           int       `json:"is_bind"`                          // 是否绑定 0否1是
+}
+
+type SystemAllotUserListRes struct {
+	Id               int32         `json:"id" `               // id
+	SystemAccount    string        `json:"system_account"`    // 系统账号
+	IsAdmin          int           `json:"is_admin"`          // 用户类型
+	ContactPhone     string        `json:"contact_phone"`     // 联系人电话
+	OrganizationId   string        `json:"organization_id"`   // 所属组织
+	OrganizationName string        `json:"organization_name"` // 所属组织
+	State            int           `json:"state"`             // 状态0禁用1启用
+	CreatedTime      jsontime.Time `json:"created_time"`      // 创建时间
+	SystemId         string        `json:"system_id"`         // 系统账号id
+	IsBind           int           `json:"is_bind"`           // 是否绑定 0否1是
+}

src/bean/vo/response/system_role_menu.go

+package response
+
+import "time"
+
+type SystemRoleMenu struct {
+	Id          int64     `json:"id" xorm:"pk autoincr" `       // 主键自增id
+	RoleId      string    `json:"role_id"  xorm:"role_id"`      // 角色id（uuid）
+	MenuId      string    `json:"menu_id" xorm:"menu_id" `      // 菜单id（uuid）
+	CreatedTime time.Time `json:"created_time" xorm:"created" ` // 创建时间
+}
+
+type SystemMenus struct {
+	Id     int32  `json:"id"`      // id
+	MenuId string `json:"menu_id"` // 菜单id
+}

src/controller/organization.go

+package controller
+
+import (
+	"errors"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/request"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/resp"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/router/middleware/header"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/service"
+
+	"github.com/gin-gonic/gin"
+	"github.com/spf13/cast"
+)
+
+// 新增组织
+func AddOrg(c *gin.Context) {
+	var input request.OrgInput
+	if err := c.ShouldBindJSON(&input); err != nil {
+		SendJsonResponse(c, resp.InvalidParam.WithError(err), nil)
+		return
+	}
+	//参数检测 DataType 0 目录 1组织
+	if input.DataType == 0 && input.Name == "" {
+		SendJsonResponse(c, resp.InvalidParam.WithMsg("请输入目录名称"), nil)
+		return
+	}
+	if input.DataType == 1 {
+		if input.Name == "" {
+			SendJsonResponse(c, resp.InvalidParam.WithError(errors.New("请输入机构名称")), nil)
+			return
+		}
+		if input.OrganizationCode == "" {
+			SendJsonResponse(c, resp.InvalidParam.WithMsg("请输入组织机构代码"), nil)
+			return
+		}
+	}
+	orgService := service.Organization{User: header.GetUser(c)}
+	result, err := orgService.AddOrg(input)
+	if err != nil {
+		SendJsonResponse(c, err, nil)
+		return
+	}
+	SendJsonResponse(c, resp.OK, result)
+}
+
+// 更新组织或目录
+func UpdateOrg(c *gin.Context) {
+	var input request.OrgInput
+	if err := c.ShouldBindJSON(&input); err != nil {
+		SendJsonResponse(c, resp.InvalidParam.WithError(err), nil)
+		return
+	}
+	//参数检测 DataType 0 目录 1组织
+	if input.DataType == 0 && input.Name == "" {
+		SendJsonResponse(c, resp.InvalidParam.WithMsg("请输入目录名称"), nil)
+		return
+	}
+	if input.DataType == 1 {
+		if input.Name == "" {
+			SendJsonResponse(c, resp.FAIL.WithMsg("请输入机构名称"), nil)
+			return
+		}
+		if input.OrganizationCode == "" {
+			SendJsonResponse(c, resp.FAIL.WithMsg("请输入组织机构代码"), nil)
+			return
+		}
+	}
+	orgService := service.Organization{User: header.GetUser(c)}
+	if err := orgService.UpdateOrg(cast.ToInt64(c.Param("id")), input); err != nil {
+		SendJsonResponse(c, err, nil)
+		return
+	}
+	SendJsonResponse(c, resp.OK, nil)
+}
+
+// 删除组织或者目录
+func DeleteOrg(c *gin.Context) {
+	orgService := service.Organization{User: header.GetUser(c)}
+	if err := orgService.DeleteOrg(cast.ToInt64(c.Param("id"))); err != nil {
+		SendJsonResponse(c, err, nil)
+		return
+	}
+	SendJsonResponse(c, resp.OK, nil)
+}
+
+// 组织排序
+func SortOrg(c *gin.Context) {
+	var input []request.OrgSortInput
+	if err := c.ShouldBindJSON(&input); err != nil {
+		SendJsonResponse(c, resp.InvalidParam.WithError(err), nil)
+		return
+	}
+	orgService := service.Organization{User: header.GetUser(c)}
+	if err := orgService.SortOrg(input); err != nil {
+		SendJsonResponse(c, err, nil)
+		return
+	}
+	SendJsonResponse(c, resp.OK, nil)
+}
+
+// 查询组织树
+func GetOrgTree(c *gin.Context) {
+	orgService := service.Organization{}
+	result, err := orgService.GetOrgTree()
+	if err != nil {
+		SendJsonResponse(c, err, nil)
+		return
+	}
+	SendJsonResponse(c, resp.OK, result)
+}
+
+// 查询组织详情
+func OrgDetail(c *gin.Context) {
+	var input request.QueryOrgDetailInput
+	if err := c.ShouldBind(&input); err != nil {
+		SendJsonResponse(c, resp.InvalidParam.WithError(err), nil)
+		return
+	}
+	if input.OrganizationId == "" {
+		SendJsonResponse(c, resp.InvalidParam.WithMsg("组织id必填"), nil)
+		return
+	}
+	//if input.DataType == "" {
+	//	SendJsonResponse(c, resp.InvalidParam.WithMsg("DataType必填"), nil)
+	//	return
+	//}
+	if input.Limit == 0 {
+		input.Limit = 10
+	}
+	orgService := service.Organization{}
+	result, err := orgService.OrgDetail(input)
+	if err != nil {
+		SendJsonResponse(c, err, nil)
+		return
+	}
+	SendJsonResponse(c, resp.OK, result)
+}
+
+//
+//// 查询业务系统信息
+//func GetBusinessMsg(c *gin.Context) {
+//	var input request.GetBusinessMsgInput
+//	if err := c.ShouldBind(&input); err != nil {
+//		SendJsonResponse(c, resp.InvalidParam.ErrorDetail(err), nil)
+//		return
+//	}
+//	if input.OrganizationId == "" {
+//		SendJsonResponse(c, resp.ParamsMissError.ErrorDetail(errors.New("组织id必填")), nil)
+//		return
+//	}
+//	if input.Limit == 0 {
+//		input.Limit = 10
+//	}
+//	orgService := service.Organization{}
+//	respult, count, err := orgService.GetBusinessMsg(input)
+//	if err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonPageResponse(c, resp.GET_OK, respult, count)
+//}
+//
+//// 查询组织用户详情
+//func OrgUserDetail(c *gin.Context) {
+//	id := cast.ToInt(c.Param("id"))
+//	if id <= 0 {
+//		SendJsonResponse(c, resp.ParamsMissError.ErrorDetail(errors.New("请输入用户id")), nil)
+//		return
+//	}
+//	orgService := service.Organization{}
+//	respult, err := orgService.OrgUserDetail(id)
+//	if err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonResponse(c, resp.GET_OK, respult)
+//}
+//
+//// 组织添加用户时查询的角色列表
+//func OrgUserRoles(c *gin.Context) {
+//	isadmin := c.Query("is_admin")
+//	if isadmin == "" {
+//		SendJsonResponse(c, resp.ParamsMissError.ErrorDetail(errors.New("用户类型必填")), nil)
+//		return
+//	}
+//	orgService := service.Organization{}
+//	respult, err := orgService.OrgUserRoles(cast.ToInt(isadmin))
+//	if err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonResponse(c, resp.GET_OK, respult)
+//}
+//
+//// 添加组织用户
+//func OrgAddUser(c *gin.Context) {
+//	var input request.OrgUserInput
+//	if err := c.ShouldBindJSON(&input); err != nil {
+//		SendJsonResponse(c, resp.ParamsParserError.ErrorDetail(err), nil)
+//		return
+//	}
+//	if err := vd.Validate(input); err != nil {
+//		SendJsonResponse(c, err, "")
+//		return
+//	}
+//	if input.IsAdmin != 2 && input.IsAdmin != 3 {
+//		SendJsonResponse(c, resp.ParamsParserError.ErrorDetail(errors.New("超出类型可选范围")), nil)
+//		return
+//	}
+//
+//	orgService := service.Organization{User: util.GetContextUser(c)}
+//	if err := orgService.OrgAddUser(input); err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonResponse(c, resp.ADD_OK, nil)
+//}
+//
+//// 编辑用户
+//func OrgUpdateUser(c *gin.Context) {
+//	id := cast.ToInt(c.Param("id"))
+//	if id <= 0 {
+//		SendJsonResponse(c, resp.ParamsMissError.ErrorDetail(errors.New("请输入用户id")), nil)
+//		return
+//	}
+//	var input request.UpdateOrgUserInput
+//	if err := c.ShouldBindJSON(&input); err != nil {
+//		SendJsonResponse(c, resp.ParamsParserError.ErrorDetail(err), nil)
+//		return
+//	}
+//	if err := vd.Validate(input); err != nil {
+//		SendJsonResponse(c, err, "")
+//		return
+//	}
+//	orgService := service.Organization{User: util.GetContextUser(c)}
+//	if err := orgService.OrgUpdateUser(id, input); err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonResponse(c, resp.UPDATE_OK, nil)
+//}
+//
+//// 删除组织用户
+//func DelOrgUser(c *gin.Context) {
+//	var input request.DelOrgUser
+//	if err := c.ShouldBindJSON(&input); err != nil {
+//		SendJsonResponse(c, resp.ParamsParserError.ErrorDetail(err), nil)
+//		return
+//	}
+//	if len(input.Ids) <= 0 {
+//		SendJsonResponse(c, resp.ParamsMissError.ErrorDetail(errors.New("请输入用户id")), nil)
+//		return
+//	}
+//	orgService := service.Organization{User: util.GetContextUser(c)}
+//	if err := orgService.DelOrgUser(input); err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonResponse(c, resp.DELETE_OK, nil)
+//}
+//
+//// 去重校验
+//func CheckRepetition(c *gin.Context) {
+//	var input request.CheckRepetition
+//	if err := c.ShouldBindJSON(&input); err != nil {
+//		SendJsonResponse(c, resp.ParamsParserError.ErrorDetail(err), nil)
+//		return
+//	}
+//	orgService := service.Organization{}
+//	if err := orgService.CheckRepetition(input); err != nil {
+//		SendJsonResponse(c, err, nil)
+//		return
+//	}
+//	SendJsonResponse(c, resp.GET_OK, nil)
+//}

src/router/middleware/header/user.go

+package header
+
+import (
+	"github.com/gin-gonic/gin"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/entity"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/conf"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/service"
+)
+
+func SetContext(c *gin.Context) {
+	bgToken, _ := c.Cookie(conf.CookieName)
+	if bgToken == "" {
+		c.String(401, "用户未登录!")
+		c.Abort()
+		return
+	}
+
+	svc := service.UserSvc{}
+	m, err := svc.GetCurUser(bgToken)
+	if err != nil {
+		c.String(500, "用户未登录!")
+		c.Abort()
+		return
+
+	}
+
+	c.Set("user_info", m)
+	c.Next()
+}
+
+func GetUser(c *gin.Context) entity.SystemUserInfo {
+	val, ok := c.Get("user_info")
+	if !ok {
+		return entity.SystemUserInfo{}
+	}
+
+	user, ok := val.(entity.SystemUserInfo)
+	if !ok {
+		return entity.SystemUserInfo{}
+	}
+	return user
+}

src/router/organizationrouter.go

+package router
+
+import (
+	"fmt"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/conf"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/controller"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/router/middleware/header"
+
+	"github.com/gin-gonic/gin"
+)
+
+// 初始化组织相关路由
+func InitOrganizationRouter(e *gin.Engine) {
+	base := e.Group(fmt.Sprintf("%s/org", conf.Options.Prefix), header.SetContext)
+	{
+		base.POST("/add", controller.AddOrg)      //新增组织or目录
+		base.PUT("/:id", controller.UpdateOrg)    //更新组织或目录
+		base.DELETE("/:id", controller.DeleteOrg) //删除组织或者目录
+		base.PUT("/sort", controller.SortOrg)     //组织排序
+		base.GET("/tree", controller.GetOrgTree)  //查询组织树
+		base.GET("/detail", controller.OrgDetail) //查询组织详情
+		//base.GET("/business/msg", controller.GetBusinessMsg)   //查询业务系统信息
+		//base.GET("/user/:id", controller.OrgUserDetail)        //查询组织用户详情
+		//base.GET("/select/role", controller.OrgUserRoles)      //注册平台用户使用的查询角色列表
+		//base.POST("/add/user", controller.OrgAddUser)          //添加组织用户
+		//base.PUT("/update/user/:id", controller.OrgUpdateUser) //组织编辑用户
+		//base.DELETE("/del/user", controller.DelOrgUser)        //删除组织用户
+		//base.POST("/check", controller.CheckRepetition)        //去重校验
+	}
+}

src/router/router.go

@@ -34,4 +34,6 @@ func Load(r *gin.Engine, middleware ...gin.HandlerFunc) {
 	InitAutomatedMaintenRouter(r)
 	// 初始化登录路由
 	InitSystemLoginRouter(r)
+	// 初始化组织相关路由
+	InitOrganizationRouter(r)
 }

src/service/organization.go

+package service
+
+import (
+	"errors"
+	"fmt"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/entity"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/request"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/bean/vo/response"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/client"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/common/conf"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/pkg/beagle/resp"
+	"gitlab.wodcloud.com/smart-operation/so-operation-api/src/util"
+	"xorm.io/xorm"
+
+	"go.uber.org/zap"
+)
+
+type Organization struct {
+	User entity.SystemUserInfo
+}
+
+// 新增目录或组织
+func (o *Organization) AddOrg(input request.OrgInput) (interface{}, error) {
+	db, err := client.GetDbClient()
+	if err != nil {
+		return nil, resp.DbConnectError.WithError(err)
+	}
+
+	//数据校验
+	if input.DataType == 1 {
+		has, err := db.Table("system_organization").Select("id").Where("organization_code = ? and is_deleted = 0", input.OrganizationCode).Exist(&entity.SystemOrganization{})
+		if err != nil {
+			conf.Logger.Error("组织机构代码获取组织信息失败", zap.Error(err))
+			return nil, resp.DbSelectError.WithError(err)
+		}
+		if has {
+			return nil, resp.DbInsertError.WithError(errors.New("组织机构代码已存在"))
+		}
+	}
+
+	orgModel := entity.SystemOrganization{
+		Id:               0,
+		OrganizationId:   util.GetUUID(),
+		Name:             input.Name,
+		POrganizationId:  input.POrganizationId,
+		Description:      input.Description,
+		OrganizationCode: input.OrganizationCode,
+
+		DataType:  input.DataType,
+		CreatedBy: o.User.Id,
+	}
+	var samelevelOrg, parentOrg entity.SystemOrganization
+	if orgModel.POrganizationId != "" {
+		has, err := db.Table("system_organization").Where("p_organization_id = ? and is_deleted = 0", orgModel.POrganizationId).Limit(1, 0).OrderBy("sort desc").Get(&samelevelOrg)
+		if err != nil {
+			conf.Logger.Error("获取同级组织信息失败", zap.Error(err))
+			return nil, resp.DbConnectError.WithError(err)
+		}
+
+		if !has {
+			_, err := db.Table("system_organization").Where("organization_id = ? and is_deleted = 0", orgModel.POrganizationId).Limit(1, 0).OrderBy("sort desc").Get(&parentOrg)
+			if err != nil {
+				conf.Logger.Error("获取父级组织信息失败", zap.Error(err))
+				return nil, resp.DbConnectError.WithError(err)
+			}
+			orgModel.Level = parentOrg.Level + 1
+			orgModel.Sort = 1
+		} else {
+			orgModel.Level = samelevelOrg.Level
+			orgModel.Sort = samelevelOrg.Sort + 1
+		}
+	} else {
+		//查询跟目录sort
+		has, err := db.Table("system_organization").Where("is_deleted = 0 and level = 1").Limit(1, 0).OrderBy("sort desc").Get(&parentOrg)
+		if err != nil {
+			conf.Logger.Error("获取同级组织信息失败", zap.Error(err))
+			return nil, resp.DbConnectError.WithError(err)
+		}
+		if has {
+			orgModel.Sort = parentOrg.Sort + 1
+		} else {
+			orgModel.Sort = 1
+		}
+		orgModel.Level = 1
+	}
+	if _, err := db.Table("system_organization").Omit("id").Insert(&orgModel); err != nil {
+		conf.Logger.Error("插入 system_organization", zap.String("error", err.Error()))
+		return nil, resp.DbInsertError.WithError(err)
+	}
+	result := map[string]interface{}{"id": orgModel.Id, "organization_id": orgModel.OrganizationId}
+	return result, nil
+}
+
+// 更新组织或目录
+func (o *Organization) UpdateOrg(id int64, input request.OrgInput) error {
+	db, err := client.GetDbClient()
+	if err != nil {
+		return resp.DbConnectError.WithError(err)
+	}
+
+	var org entity.SystemOrganization
+	has, err := db.Table("system_organization").ID(id).Where("is_deleted = 0").Get(&org)
+	if err != nil {
+		conf.Logger.Error("获取组织信息失败", zap.Error(err))
+		return resp.DbSelectError.WithError(err)
+	}
+	if !has {
+		if input.DataType == 0 {
+			return resp.FAIL.WithMsg("该目录不存在")
+		}
+		if input.DataType == 1 {
+			return resp.FAIL.WithMsg("该组织不存在")
+		}
+	}
+
+	//数据校验
+	if input.DataType == 1 && org.OrganizationCode != input.OrganizationCode {
+		has, err := db.Table("system_organization").Select("id").Where("organization_code = ? and is_deleted = 0", input.OrganizationCode).Exist(&entity.SystemOrganization{})
+		if err != nil {
+			conf.Logger.Error("组织机构代码获取组织信息失败", zap.Error(err))
+			return resp.DbSelectError.WithError(err)
+		}
+		if has {
+			return resp.DbUpdateError.WithError(errors.New("组织机构代码已存在"))
+		}
+	}
+
+	if _, err := db.Table("system_organization").Cols("name, description, organization_code,  updated_time, updated_by").
+		Where("id = ?", id).Update(&entity.SystemOrganization{
+		Name:             input.Name,
+		Description:      input.Description,
+		OrganizationCode: input.OrganizationCode,
+		UpdatedBy:        o.User.Id,
+	}); err != nil {
+		conf.Logger.Error("更新组织信息失败", zap.Error(err))
+		return resp.DbUpdateError.WithError(err)
+	}
+	return nil
+}
+
+// 删除组织或者目录
+func (o *Organization) DeleteOrg(id int64) error {
+	db, err := client.GetDbClient()
+	if err != nil {
+		return resp.DbConnectError.WithError(err)
+	}
+	_, err = db.Transaction(func(session *xorm.Session) (interface{}, error) {
+		var org entity.SystemOrganization
+		basehas, err := session.Table("system_organization").ID(id).Where("is_deleted = 0").Get(&org)
+		if err != nil {
+			conf.Logger.Error("查询基础组织信息失败", zap.Error(err))
+			return nil, resp.DbSelectError.WithError(err)
+		}
+
+		//目录 目录没有下级可删除
+		if org.DataType == 0 {
+			if !basehas {
+				return nil, resp.FAIL.WithMsg("该目录不存在")
+			}
+
+			//验证目录是否有下级
+			has, err := session.Table("system_organization").Select("id").Where("is_deleted = 0 and p_organization_id = ?", org.OrganizationId).Exist(&entity.SystemOrganization{})
+			if err != nil {
+				conf.Logger.Error("验证目录是否有下级查询基础组织信息失败", zap.Error(err))
+				return nil, resp.DbSelectError.WithError(err)
+			}
+			if has {
+				return nil, resp.FAIL.WithMsg("该目录下有数据，不可删除！")
+			}
+		}
+
+		//组织 组织没有组织管理员且没有绑定业务系统
+		if org.DataType == 1 {
+			if !basehas {
+				return nil, resp.FAIL.WithMsg("该组织不存在")
+			}
+
+			//验证组织下是否有组织管理员且是否绑定业务系统
+			has, err := session.Table("system_user").Select("id").Where("is_deleted = 0 and organization_id = ?", org.OrganizationId).Exist(&entity.SystemUser{})
+			if err != nil {
+				conf.Logger.Error("验证组织下是否有组织管理员查询基础组织信息失败", zap.Error(err))
+				return nil, resp.DbSelectError.WithError(err)
+			}
+			if has {
+				return nil, resp.FAIL.WithMsg("该组织下有业务数据，不可删除！")
+			}
+		}
+
+		//删除
+		_, err = session.Table("system_organization").Cols("is_deleted, updated_time, updated_by").ID(id).Update(&entity.SystemOrganization{IsDeleted: 1, UpdatedBy: o.User.Id})
+		return nil, err
+	})
+	return err
+}
+
+// 组织排序
+func (o *Organization) SortOrg(input []request.OrgSortInput) error {
+	db, err := client.GetDbClient()
+	if err != nil {
+		return resp.DbConnectError.WithError(err)
+	}
+	_, err = db.Transaction(func(s *xorm.Session) (interface{}, error) {
+		for _, v := range input {
+			_, err := s.Table("system_organization").Cols("sort, updated_time, updated_by").Where("id = ? and is_deleted = 0", v.Id).Update(&entity.SystemOrganization{Sort: v.Sort, UpdatedBy: o.User.Id})
+			if err != nil {
+				conf.Logger.Error("排序失败", zap.Error(err))
+				return nil, resp.DbUpdateError.WithError(err)
+			}
+		}
+		return nil, nil
+	})
+	return err
+}
+
+// 查询组织树
+func (o *Organization) GetOrgTree() (interface{}, error) {
+	db, err := client.GetDbClient()
+	if err != nil {
+		return nil, resp.DbConnectError.WithError(err)
+	}
+	var orgs []response.SystemOrganizationTree
+	if err := db.Table("system_organization").Where("is_deleted = 0").OrderBy("level").OrderBy("sort").Find(&orgs); err != nil {
+		conf.Logger.Error("查询组织树失败", zap.Error(err))
+		return nil, resp.DbSelectError.WithError(err)
+	}
+
+	var result []response.SystemOrganizationTree
+	// 组装树形
+	for i, v := range orgs {
+		if v.Level == 1 {
+			changeTree(&orgs[i], orgs)
+			result = append(result, orgs[i])
+		}
+	}
+	return result, nil
+}
+
+func changeTree(parent *response.SystemOrganizationTree, all []response.SystemOrganizationTree) {
+	for i, v := range all {
+		if v.POrganizationId == parent.OrganizationId {
+			changeTree(&all[i], all)
+			parent.Child = append(parent.Child, all[i])
+		}
+	}
+}
+
+// 查询组织详情
+func (o *Organization) OrgDetail(input request.QueryOrgDetailInput) (interface{}, error) {
+	db, err := client.GetDbClient()
+	if err != nil {
+		return nil, resp.DbConnectError.WithError(err)
+	}
+
+	//查询用户 区分组织管理员和平台用户
+	var orgAdminUsers []response.OrgAdminUser
+	querySystemUser := db.Table("system_user").Alias("su").Select("su.id, su.system_account,  su.created_time, su.state, su.phone").
+		Where("organization_id = ? and su.is_deleted = 0", input.OrganizationId)
+
+	//DataType 2平台用户组织
+	//if input.DataType == "2" {
+	//	querySystemUser.Where("su.is_admin = 3")
+	//} else {
+	//	//组织管理员用户
+	//	querySystemUser.Where("su.is_admin = 2")
+	//}
+
+	if input.KeyWord != "" {
+		querySystemUser.Where("su.system_account like ? or su.phone  like ?", fmt.Sprintf("%%%s%%", input.KeyWord), fmt.Sprintf("%%%s%%", input.KeyWord))
+	}
+	if input.State != "" {
+		querySystemUser.Where("su.state = ?", input.State)
+	}
+	count, err := querySystemUser.Limit(input.Limit, (input.Page-1)*input.Limit).Asc("su.created_time").FindAndCount(&orgAdminUsers)
+	if err != nil {
+		conf.Logger.Error("查询用户失败", zap.Error(err))
+		return nil, resp.DbSelectError.WithError(err)
+	}
+
+	//查询用户角色
+	var ids []int
+	for _, v := range orgAdminUsers {
+		ids = append(ids, v.Id)
+	}
+	//var systemUserRoles []response.SystemUserRole
+	//if err := db.Table("system_user_role").Alias("sur").Select("sur.system_id, sr.role_name").
+	//	Join("left", "system_role sr", "sr.role_id = sur.role_id").In("sur.system_id", system_ids).Find(&systemUserRoles); err != nil {
+	//	conf.Logger.Error("查询用户角色信息失败", zap.Error(err))
+	//	return nil, res.DbSelectError.ErrorDetail(err)
+	//}
+	//for i, v := range orgAdminUsers {
+	//	for _, s := range systemUserRoles {
+	//		if v.SystemId == s.SystemId {
+	//			orgAdminUsers[i].SystemRole = append(orgAdminUsers[i].SystemRole, s.RoleName)
+	//		}
+	//	}
+	//}
+
+	var orgInfo response.OrgDetail
+	if _, err = db.Table("system_organization").Alias("so").
+		Select("so.organization_code, so.name, so.created_time,  t3.count as platform_users_number,  so.description, (case when so.name <> '平台用户组织' then '政务机构' else '平台用户组织' end) as organization_type").
+		Join("LEFT", "(SELECT count(id),su.organization_id from system_user as su where  su.is_deleted = 0 and su.state = 1 GROUP BY su.organization_id) t3", "t3.organization_id = so.organization_id").
+		Where("so.organization_id = ? and is_deleted = 0", input.OrganizationId).Get(&orgInfo); err != nil {
+		conf.Logger.Error("查询组织基本信息失败", zap.Error(err))
+		return nil, resp.DbSelectError.WithError(err)
+	}
+
+	result := map[string]interface{}{
+		"org_info":  orgInfo,
+		"org_users": map[string]interface{}{"data": orgAdminUsers, "total": count},
+	}
+	if orgInfo.OrganizationCode == "" {
+		result = nil
+	}
+	return result, nil
+}
+
+//// 查询组织业务系统信息
+//func (o *Organization) GetBusinessMsg(input request.GetBusinessMsgInput) (interface{}, int64, error) {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return nil, 0, res.DbConnectError.ErrorDetail(err)
+//	}
+//
+//	//查询业务系统信息
+//	var result []response.BusinessSystem
+//	count, err := db.Table("system_user").Select("business_name, system_account, state").
+//		Where("organization_id = ? and is_admin = 1 and is_deleted = 0", input.OrganizationId).Limit(input.Limit, (input.Page-1)*input.Limit).Asc("system_user.created_time").FindAndCount(&result)
+//	if err != nil {
+//		conf.Logger.Error("查询业务系统信息失败", zap.Error(err))
+//		return nil, 0, res.DbSelectError.ErrorDetail(err)
+//	}
+//	return result, count, nil
+//}
+//
+//// 查询组织用户详情
+//func (o *Organization) OrgUserDetail(id int) (interface{}, error) {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return nil, res.DbConnectError.ErrorDetail(err)
+//	}
+//	selectSql := "su.id, su.organization_id, su.contact_phone, su.system_account, so.name as organization, createduser.contact_name as created_by, createduser.system_account as created_by_account, " +
+//		"su.updated_time, su.created_time, su.contact_name, su.contact_email, su.document_type, su.document_number, su.remark, su.logo, su.state, su.system_id, su.is_admin"
+//	var result response.OrgUserDetail
+//	has, err := db.Table("system_user").Alias("su").
+//		Select(selectSql).
+//		Join("left", "system_organization so", "so.organization_id = su.organization_id").
+//		Join("left", "system_user createduser", "createduser.system_id::varchar = su.created_by").
+//		Where("su.id = ? and su.is_deleted = 0", id).Get(&result)
+//	if err != nil {
+//		conf.Logger.Error("查询组织用户详情失败", zap.Error(err))
+//		return nil, res.DbSelectError.ErrorDetail(err)
+//	}
+//	if !has {
+//		return nil, res.DbSelectError.ErrorDetail(errors.New("用户不存在"))
+//	}
+//
+//	//查询用户角色
+//	var systemUserRoles []response.SystemUserRole
+//	if err := db.Table("system_user_role").Alias("sur").Select("sur.system_id::varchar, sr.role_name").
+//		Join("left", "system_role sr", "sr.role_id = sur.role_id").Where("sur.system_id::varchar = ?", result.SystemId).Find(&systemUserRoles); err != nil {
+//		conf.Logger.Error("查询用户角色信息失败", zap.Error(err))
+//		return nil, res.DbSelectError.ErrorDetail(err)
+//	}
+//	for _, v := range systemUserRoles {
+//		result.SystemRole = append(result.SystemRole, v.RoleName)
+//	}
+//	return result, nil
+//}
+//
+//// 组织添加用户时查询角色列表 查询非内置角色 + 平台运营者
+//func (o *Organization) OrgUserRoles(is_admin int) (interface{}, error) {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return nil, res.DbConnectError.ErrorDetail(err)
+//	}
+//	var rols []entity.SystemRole
+//	if is_admin == 3 {
+//		if err := db.Table("system_role").Where("(role_type = 0 and is_deleted = 0 and state = 1) or role_id = ?", util.PINGTAIYUNYINGZHE).Find(&rols); err != nil {
+//			conf.Logger.Error("查询用户角色信息失败", zap.Error(err))
+//			return nil, res.DbSelectError.ErrorDetail(err)
+//		}
+//	} else if is_admin == 2 {
+//		if err := db.Table("system_role").Where("role_id = ?", util.ZUZHIGUANLIYUAN).Find(&rols); err != nil {
+//			conf.Logger.Error("查询用户角色信息失败", zap.Error(err))
+//			return nil, res.DbSelectError.ErrorDetail(err)
+//		}
+//	} else if is_admin == 1 {
+//		if err := db.Table("system_role").Where("role_id = ?", util.YEWUXITONGJUESE).Find(&rols); err != nil {
+//			conf.Logger.Error("查询用户角色信息失败", zap.Error(err))
+//			return nil, res.DbSelectError.ErrorDetail(err)
+//		}
+//	}
+//	return rols, nil
+//}
+//
+//// 添加组织用户
+//func (o *Organization) OrgAddUser(input request.OrgUserInput) error {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return res.DbConnectError.ErrorDetail(err)
+//	}
+//
+//	//验证账号是否存在
+//	has, err := db.Table("system_user").Select("id").Where("system_account = ? and is_deleted = 0", input.SystemAccount).Exist(&entity.SystemUser{})
+//	if err != nil {
+//		conf.Logger.Error("查询账号信息验证失败", zap.Error(err))
+//		return res.DbInsertError.ErrorDetail(err)
+//	}
+//	if has {
+//		return res.DbInsertError.ErrorDetail(errors.New("账号已存在"))
+//	}
+//
+//	//验证手机号是否存在
+//	has, err = db.Table("system_user").Select("id").Where("contact_phone = ? and is_deleted = 0", input.ContactPhone).Exist(&entity.SystemUser{})
+//	if err != nil {
+//		conf.Logger.Error("查询账号信息验证失败", zap.Error(err))
+//		return res.DbInsertError.ErrorDetail(err)
+//	}
+//	if has {
+//		return res.DbInsertError.ErrorDetail(errors.New("手机号已存在"))
+//	}
+//
+//	systemId := util.GetUUID()
+//	upperMd5Pass, err := SolvePassword(systemId, input.Password)
+//	if err != nil {
+//		conf.Logger.Error("密码处理出错", zap.Error(err))
+//		return res.DbInsertError.ErrorDetail(err)
+//	}
+//	userModel := entity.SystemUser{
+//		SystemId:       systemId,
+//		Logo:           input.Logo,
+//		SystemAccount:  input.SystemAccount,
+//		ContactPhone:   input.ContactPhone,
+//		Password:       upperMd5Pass,
+//		State:          input.State,
+//		ContactName:    input.ContactName,
+//		ContactEmail:   input.ContactEmail,
+//		Remark:         input.Remark,
+//		OrganizationId: input.OrganizationId,
+//		DocumentType:   input.DocumentType,
+//		DocumentNumber: input.DocumentNumber,
+//		CreatedBy:      o.User.SystemId,
+//		IsAdmin:        cast.ToInt(input.IsAdmin),
+//	}
+//
+//	_, err = db.Transaction(func(s *xorm.Session) (interface{}, error) {
+//		if _, err := s.Table("system_user").Insert(&userModel); err != nil {
+//			conf.Logger.Error("创建系统账户失败", zap.Error(err))
+//			return nil, res.DbInsertError.ErrorDetail(err)
+//		}
+//
+//		var systemUserRoles []entity.SystemUserRole
+//		for _, v := range input.SelectRole {
+//			systemUserRoles = append(systemUserRoles, entity.SystemUserRole{SystemId: systemId, RoleId: v})
+//		}
+//		if _, err := s.Table("system_user_role").Insert(&systemUserRoles); err != nil {
+//			conf.Logger.Error("创建用户角色失败", zap.Error(err))
+//			return nil, res.DbInsertError.ErrorDetail(err)
+//		}
+//		return nil, nil
+//	})
+//	return err
+//}
+//
+//// 更新组织用户
+//func (o *Organization) OrgUpdateUser(id int, input request.UpdateOrgUserInput) error {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return res.DbConnectError.ErrorDetail(err)
+//	}
+//	var baseUser entity.SystemUser
+//	has, err := db.Table("system_user").ID(id).Where("is_deleted = 0").Get(&baseUser)
+//	if err != nil {
+//		conf.Logger.Error("查询账号信息失败", zap.Error(err))
+//		return res.DbUpdateError.ErrorDetail(err)
+//	}
+//	if !has {
+//		return res.DbUpdateError.ErrorDetail(errors.New("该用户不存在"))
+//	}
+//
+//	if baseUser.SystemAccount != input.SystemAccount {
+//		//验证账号是否存在
+//		has, err = db.Table("system_user").Select("id").Where("system_account = ? and is_deleted = 0", input.SystemAccount).Exist(&entity.SystemUser{})
+//		if err != nil {
+//			conf.Logger.Error("查询账号信息验证失败", zap.Error(err))
+//			return res.DbUpdateError.ErrorDetail(err)
+//		}
+//		if has {
+//			return res.DbUpdateError.ErrorDetail(errors.New("账号已存在"))
+//		}
+//	}
+//
+//	if baseUser.ContactPhone != input.ContactPhone {
+//		//验证手机号是否存在
+//		has, err = db.Table("system_user").Select("id").Where("contact_phone = ? and is_deleted = 0", input.ContactPhone).Exist(&entity.SystemUser{})
+//		if err != nil {
+//			conf.Logger.Error("查询账号信息验证失败", zap.Error(err))
+//			return res.DbUpdateError.ErrorDetail(err)
+//		}
+//		if has {
+//			return res.DbUpdateError.ErrorDetail(errors.New("手机号已存在"))
+//		}
+//	}
+//
+//	userModel := entity.SystemUser{
+//		Logo:           input.Logo,
+//		SystemAccount:  input.SystemAccount,
+//		ContactPhone:   input.ContactPhone,
+//		State:          input.State,
+//		ContactName:    input.ContactName,
+//		ContactEmail:   input.ContactEmail,
+//		Remark:         input.Remark,
+//		DocumentType:   input.DocumentType,
+//		DocumentNumber: input.DocumentNumber,
+//		UpdatedBy:      o.User.SystemId,
+//	}
+//
+//	if _, err := db.Table("system_user").ID(id).Update(&userModel); err != nil {
+//		conf.Logger.Error("账号信息更新失败", zap.Error(err))
+//		return res.DbUpdateError.ErrorDetail(err)
+//	}
+//	return nil
+//}
+//
+//// 删除组织用户
+//func (o *Organization) DelOrgUser(input request.DelOrgUser) error {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return res.DbConnectError.ErrorDetail(err)
+//	}
+//
+//	_, err = db.Transaction(func(s *xorm.Session) (interface{}, error) {
+//		var baseUsers []entity.SystemUser
+//		if err := s.Table("system_user").In("id", input.Ids).Where("is_deleted = 0").Find(&baseUsers); err != nil {
+//			conf.Logger.Error("查询账号信息失败", zap.Error(err))
+//			return nil, res.DbDeleteError.ErrorDetail(err)
+//		}
+//		if len(baseUsers) == 0 {
+//			return nil, res.DbDeleteError.ErrorDetail(errors.New("用户数据不存在，删除失败"))
+//		}
+//		for _, v := range baseUsers {
+//			if v.State == 1 {
+//				return nil, res.DbDeleteError.ErrorDetail(errors.New("删除内容中有启用状态的数据，不可删除！"))
+//			}
+//		}
+//
+//		//是组织管理员 验证是否为最后一个组织管理员账号 组织管理员人数不能为0，不可删除！
+//		if len(baseUsers) > 0 && baseUsers[0].IsAdmin == 2 {
+//			count, err := s.Table("system_user").Where("organization_id = ? and is_deleted = 0 and is_admin = 2", baseUsers[0].OrganizationId).Count(&entity.SystemUser{})
+//			if err != nil {
+//				conf.Logger.Error("查询账号验证统计失败", zap.Error(err))
+//				return nil, res.DbDeleteError.ErrorDetail(err)
+//			}
+//			if int(count)-len(baseUsers) <= 0 {
+//				return nil, res.DbDeleteError.ErrorDetail(errors.New("组织管理员人数不能为0，不可删除！"))
+//			}
+//		}
+//
+//		if _, err := db.Table("system_user").In("id", input.Ids).Update(&entity.SystemUser{IsDeleted: 1, UpdatedBy: o.User.SystemId}); err != nil {
+//			conf.Logger.Error("用户删除失败", zap.Error(err))
+//			return nil, res.DbDeleteError.ErrorDetail(err)
+//		}
+//
+//		//删除用户关联角色
+//		var system_ids []string
+//		for _, v := range baseUsers {
+//			system_ids = append(system_ids, v.SystemId)
+//		}
+//		if _, err := db.Table("system_user_role").In("system_id", system_ids).Delete(&entity.SystemUserRole{}); err != nil {
+//			conf.Logger.Error("删除用户关联角色失败", zap.Error(err))
+//			return nil, res.DbDeleteError.ErrorDetail(err)
+//		}
+//		return nil, nil
+//	})
+//	return err
+//}
+//
+//// 去重校验
+//func (o *Organization) CheckRepetition(input request.CheckRepetition) error {
+//	db, err := client.GetDbClient()
+//	if err != nil {
+//		return res.DbConnectError.ErrorDetail(err)
+//	}
+//
+//	var system_user entity.SystemUser
+//	if input.Id != 0 {
+//		if _, err := db.Table("system_user").Select("id, contact_phone").ID(input.Id).Where("is_deleted = 0").Get(&system_user); err != nil {
+//			conf.Logger.Error("查询用户失败", zap.Error(err))
+//			return res.DbDataCheckError.ErrorDetail(err)
+//		}
+//	}
+//	if input.ContactPhone != system_user.ContactPhone {
+//		has, err := db.Table("system_user").Select("id").Where("contact_phone = ? and is_deleted = 0", input.ContactPhone).Exist(&entity.SystemUser{})
+//		if err != nil {
+//			conf.Logger.Error("手机号去重查询失败", zap.Error(err))
+//			return res.DbDataCheckError.ErrorDetail(err)
+//		}
+//		if has {
+//			return res.DbDataCheckError.ErrorDetail(errors.New("该手机号已注册"))
+//		}
+//	}
+//	return nil
+//}