1. 编辑通讯录的上级

2. 增到通讯录上级数据导入

+package adapter
+
+type ImportParentUser struct {
+	Phone       string `json:"phone"`       // 用户手机号码
+	Name        string `json:"name"`        // 用户名称
+	ParentPhone string `json:"parentPhone"` // 上级手机号码
+	ParentName  string `json:"parentName"`  // 上级名称
+}

 package command
 package command
 
 
+import (
+	"github.com/beego/beego/v2/core/validation"
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user/adapter"
+)
+
 type ImportUserCommand struct {
 type ImportUserCommand struct {
 	AddUsers  []SaveUserCommand `json:"add"`
 	AddUsers  []SaveUserCommand `json:"add"`
 	EditUsers []SaveUserCommand `json:"edit"`
 	EditUsers []SaveUserCommand `json:"edit"`
 }
 }
+
+// ImportParentUserCommand 导入直接上级
+type ImportParentUserCommand struct {
+	CompanyId  int                        `cname:"公司ID" json:"companyId"`
+	OperatorId int                        `cname:"操作人ID" json:"operatorId"`
+	Data       []adapter.ImportParentUser `cname:"数据" json:"-"` // 文件中读取到的数据
+}
+
+func (in *ImportParentUserCommand) Valid(_ *validation.Validation) {
+}

@@ -140,7 +140,7 @@ func (us *UserService) EditParentUser(in *command.EditParentCommand) error {
 		return application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 		return application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 	}
 	}
 	if hrbp != 1 {
 	if hrbp != 1 {
-		return application.ThrowError(application.BUSINESS_ERROR, "拥有HRBP权限才能编辑")
+		return application.ThrowError(application.BUSINESS_ERROR, "HRBP权限的员工才能操作")
 	}
 	}
 
 
 	userRepo := factory.CreateUserRepository(map[string]interface{}{"transactionContext": transactionContext})
 	userRepo := factory.CreateUserRepository(map[string]interface{}{"transactionContext": transactionContext})
@@ -164,3 +164,64 @@ func (us *UserService) EditParentUser(in *command.EditParentCommand) error {
 	}
 	}
 	return nil
 	return nil
 }
 }
+
+func (us *UserService) ImportParentUser(in *command.ImportParentUserCommand) (interface{}, error) {
+	transactionContext, err := factory.ValidateStartTransaction(in)
+	if err != nil {
+		return nil, err
+	}
+	defer func() {
+		transactionContext.RollbackTransaction()
+	}()
+
+	hrbp, err := service.GetHRBP(transactionContext, in.CompanyId, in.OperatorId)
+	if err != nil {
+		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+	}
+	if hrbp != 1 {
+		return nil, application.ThrowError(application.BUSINESS_ERROR, "HRBP权限的员工才能操作")
+	}
+	userRepo := factory.CreateUserRepository(map[string]interface{}{"transactionContext": transactionContext})
+
+	userMap := map[string]*domain.User{}
+	accounts := make([]string, 0) // 全部账号数组（查询一次）
+	for i := range in.Data {
+		v := in.Data[i]
+		if len(v.Phone) == 0 || len(v.ParentPhone) == 0 {
+			continue
+		}
+		accounts = append(accounts, v.Phone)
+		accounts = append(accounts, v.ParentPhone)
+	}
+	if len(accounts) > 0 {
+		if _, users, err := userRepo.Find(map[string]interface{}{"accounts": accounts, "companyId": in.CompanyId}); err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		} else {
+			for i := range users {
+				userMap[users[i].Account] = users[i]
+			}
+		}
+	}
+
+	for i := range in.Data {
+		v := in.Data[i]
+		if len(v.Phone) == 0 || len(v.ParentPhone) == 0 {
+			continue
+		}
+		if vCurrentUser, ok := userMap[v.Phone]; ok {
+			if vParentUser, ok := userMap[v.ParentPhone]; ok {
+				vCurrentUser.ParentId = vParentUser.Id
+
+				// 更新上级数据
+				if _, err := userRepo.Update(vCurrentUser); err != nil {
+					return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+				}
+			}
+		}
+	}
+
+	if err := transactionContext.CommitTransaction(); err != nil {
+		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
+	}
+	return nil, nil
+}

@@ -121,6 +121,9 @@ func (repo *UserRepository) Find(queryOptions map[string]interface{}) (int, []*d
 	if v, ok := queryOptions["account"]; ok {
 	if v, ok := queryOptions["account"]; ok {
 		query.Where("account like ?", v)
 		query.Where("account like ?", v)
 	}
 	}
+	if v, ok := queryOptions["accounts"]; ok {
+		query.Where("account in(?)", pg.In(v))
+	}
 	if v, ok := queryOptions["status"]; ok {
 	if v, ok := queryOptions["status"]; ok {
 		query.Where("status=?", v)
 		query.Where("status=?", v)
 	}
 	}

@@ -20,6 +20,15 @@ func (controller *TemplateImplController) TemplateQuestion() {
 	controller.WriteExcel(fileBytes, "评估导入模板.xlsx")
 	controller.WriteExcel(fileBytes, "评估导入模板.xlsx")
 }
 }
 
 
+func (controller *TemplateImplController) TemplateParentUser() {
+	fileBytes, err := ioutil.ReadFile("./templates/tpl_template_user.xlsx")
+	if err != nil {
+		controller.Response(nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "未读取到模板文件"))
+		return
+	}
+	controller.WriteExcel(fileBytes, "直接上级导入模板.xlsx")
+}
+
 func (controller *TemplateImplController) WriteExcel(fileBytes []byte, fileName string) {
 func (controller *TemplateImplController) WriteExcel(fileBytes []byte, fileName string) {
 	controller.Ctx.Output.Header("Content-Disposition", "attachment;filename="+fileName)
 	controller.Ctx.Output.Header("Content-Disposition", "attachment;filename="+fileName)
 	controller.Ctx.Output.Header("Content-Description", "FileTransfer")
 	controller.Ctx.Output.Header("Content-Description", "FileTransfer")

@@ -3,11 +3,14 @@ package controllers
 import (
 import (
 	"github.com/linmadan/egglib-go/core/application"
 	"github.com/linmadan/egglib-go/core/application"
 	"github.com/linmadan/egglib-go/web/beego"
 	"github.com/linmadan/egglib-go/web/beego"
+	"github.com/xuri/excelize/v2"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user"
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user/adapter"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user/command"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user/command"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user/query"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/user/query"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego/middlewares"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego/middlewares"
+	"strings"
 )
 )
 
 
 type UserController struct {
 type UserController struct {
@@ -46,3 +49,85 @@ func (controller *UserController) EditParentUser() {
 		controller.Response(nil, (&user.UserService{}).EditParentUser(in))
 		controller.Response(nil, (&user.UserService{}).EditParentUser(in))
 	}
 	}
 }
 }
+
+// ImportParentUser 导入用户上级
+func (controller *UserController) ImportParentUser() {
+	in := &command.ImportParentUserCommand{}
+	if err := controller.Unmarshal(in); err != nil {
+		controller.Response(nil, application.ThrowError(application.ARG_ERROR, err.Error()))
+	} else {
+		if itcArray, err := controller.readExcelFormUserParent(); err != nil {
+			controller.Response(nil, application.ThrowError(application.ARG_ERROR, err.Error()))
+		} else {
+			ua := middlewares.GetUser(controller.Ctx)
+			in.CompanyId = int(ua.CompanyId)
+			in.OperatorId = int(ua.UserId)
+			in.Data = itcArray
+			if data, err := (&user.UserService{}).ImportParentUser(in); nil != err {
+				controller.Response(nil, err)
+			} else {
+				controller.Response(data, nil)
+			}
+		}
+	}
+}
+
+func (controller *UserController) readExcelFormUserParent() ([]adapter.ImportParentUser, error) {
+	// 读取文件
+	_, header, err := controller.GetFile("file")
+	if err != nil {
+		controller.Response(nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "上传错误："+err.Error()))
+		return nil, err
+	}
+	file, err := header.Open()
+	if err != nil {
+		controller.Response(nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "上传错误："+err.Error()))
+		return nil, err
+	}
+	defer func() {
+		if err := file.Close(); err != nil {
+			return
+		}
+	}()
+
+	reader, err := excelize.OpenReader(file)
+	if err != nil {
+		controller.Response(nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "上传错误："+err.Error()))
+		return nil, err
+	}
+
+	index := reader.GetActiveSheetIndex()
+	rows, err := reader.GetRows(reader.GetSheetName(index))
+	if err != nil {
+		controller.Response(nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "读取excel错误："+err.Error()))
+		return nil, err
+	}
+	if len(rows) <= 0 {
+		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "文件内数据不能为空："+err.Error())
+	}
+
+	adapters := make([]adapter.ImportParentUser, 0)
+	for rowIndex, row := range rows {
+		if rowIndex < 2 { // 头2行不读取
+			continue
+		}
+		ipu := adapter.ImportParentUser{}
+		for colIndex, colCell := range row {
+			switch colIndex {
+			case 0:
+				ipu.Name = strings.TrimSpace(colCell) // 员工名称
+			case 1:
+				ipu.Phone = strings.TrimSpace(colCell) // 员工手机号码
+			case 2:
+				ipu.ParentName = strings.TrimSpace(colCell) // 直接上级名称
+			case 3:
+				ipu.ParentPhone = strings.TrimSpace(colCell) // 直接上级手机号码
+			}
+		}
+		adapters = append(adapters, ipu)
+	}
+	if len(adapters) <= 0 {
+		return adapters, application.ThrowError(application.INTERNAL_SERVER_ERROR, "文件内数据不能为空："+err.Error())
+	}
+	return adapters, err
+}

@@ -7,4 +7,6 @@ import (
 
 
 func init() {
 func init() {
 	web.Router("/templates/tpl_template_question.xlsx", &controllers.TemplateImplController{}, "Get:TemplateQuestion")
 	web.Router("/templates/tpl_template_question.xlsx", &controllers.TemplateImplController{}, "Get:TemplateQuestion")
+	web.Router("/templates/tpl_template_user.xlsx", &controllers.TemplateImplController{}, "Get:TemplateParentUser")
+
 }
 }

@@ -13,6 +13,8 @@ func init() {
 		web.NSRouter("/search", &controllers.UserController{}, "Post:ListUsers"),
 		web.NSRouter("/search", &controllers.UserController{}, "Post:ListUsers"),
 		web.NSRouter("/list-dep", &controllers.UserController{}, "Post:ListByDepartment"),
 		web.NSRouter("/list-dep", &controllers.UserController{}, "Post:ListByDepartment"),
 		web.NSRouter("/edit-parent", &controllers.UserController{}, "Put:EditParentUser"),
 		web.NSRouter("/edit-parent", &controllers.UserController{}, "Put:EditParentUser"),
+		web.NSRouter("/edit-parent", &controllers.UserController{}, "Put:EditParentUser"),
+		web.NSRouter("/import-parent", &controllers.UserController{}, "Post:ImportParentUser"), // 直接上级导入
 	)
 	)
 	web.AddNamespace(ns)
 	web.AddNamespace(ns)
 }
 }