eta_forum_admin/controllers/eta_business/user.go

package eta_business

import (
	"encoding/json"
	"eta/eta_forum_admin/controllers"
	"eta/eta_forum_admin/models"
	"eta/eta_forum_admin/models/eta_business"
	eta_business2 "eta/eta_forum_admin/services/eta_business"
	"eta/eta_forum_admin/utils"
	"fmt"
	"github.com/rdlucklib/rdluck_tools/paging"
	"github.com/tealeg/xlsx"
	"os"
	"strings"
	"time"
)

// 客户联系人管理
type EtaBusinessUserController struct {
	controllers.BaseAuthController
}

// List
// @Title 联系人列表
// @Description 联系人列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   CompanyId   query   int  true       "公司id，必填"
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Param   ProductType   query   int  true       "产品类型"
// @Param   ProductId   query   int  true       "产品id"
// @Param   IsSubscribe   query   int  true       "是否关注了公众号: -1-默认全部; 0-未关注; 1-已关注"
// @Param   IsSubscribeHzyj   query   int  true       "是否关注了弘则研究公众号: -1-默认全部; 0-未关注; 1-已关注"
// @Param   IsSubscribeCygx   query   int  true       "是否关注了查研观向小助手公众号: -1-默认全部; 0-未关注; 1-已关注"
// @Success 200 {object} company.CompanyUserListResp
// @router /user/list [get]
func (this *EtaBusinessUserController) List() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	positionStatus, _ := this.GetInt("PositionStatus", -1)
	enabled, _ := this.GetInt("Enabled", -1)
	businessCode := this.GetString("BusinessCode")
	keyword := utils.TrimStr(this.GetString("Keyword"))

	/*if businessCode <= 0 {
		br.Msg = "请选择客户"
		br.ErrMsg = "客户参数错误"
		return
	}*/
	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	var condition string
	var pars []interface{}

	if keyword != "" {
		condition += ` AND (real_name LIKE '%` + keyword + `%' OR mobile LIKE '%` + keyword + `%' OR email LIKE '%` + keyword + `%') `
	}

	if businessCode != "" {
		condition += ` AND business_code = ? `
		pars = append(pars, businessCode)
	}

	if positionStatus > 0 {
		condition += ` AND position_status = ? `
		pars = append(pars, positionStatus)
	}

	if enabled > 0 { // 0-禁用 1-启用
		condition += ` AND enabled = ? `
		pars = append(pars, enabled)
	}

	total, err := models.GetUserCountByCondition(condition, pars)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据总数失败，Err:" + err.Error()
		return
	}

	list, err := models.GetUserPageListByCondition(condition, pars, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	page := paging.GetPaging(currentIndex, pageSize, total)
	resp := new(models.UserListResp)
	userList := make([]*models.BusinessUser, 0)
	if len(list) == 0 {
		resp.List = userList
		resp.Paging = page
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		br.Data = resp
		return
	}
	// 查找商户信息
	businessCodeStr := make([]string, 0)
	businessCodeMap := make(map[string]string)
	for _, v := range list {
		if _, ok := businessCodeMap[v.BusinessCode]; ok {
			continue
		}
		businessCodeStr = append(businessCodeStr, v.BusinessCode)
	}
	obj := new(eta_business.EtaBusiness)
	condition1 := " AND business_code IN (" + utils.GetOrmInReplace(len(businessCodeStr)) + ") "
	var pars1 []interface{}
	pars1 = append(pars1, businessCodeStr)
	businessList, err := obj.GetItemsByCondition(condition1, pars1, []string{"business_code", "business_name"}, "")
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取商户信息失败，Err:" + err.Error()
		return
	}
	for _, v := range businessList {
		businessCodeMap[v.BusinessCode] = v.BusinessName
	}

	for _, v := range list {
		tmp := new(models.BusinessUser)
		if businessName, ok := businessCodeMap[v.BusinessCode]; ok {
			tmp.BusinessName = businessName
		}
		tmp.BusinessCode = v.BusinessCode
		tmp.UserId = v.UserId
		tmp.RealName = v.RealName
		tmp.Mobile = v.Mobile
		tmp.CountryCode = v.CountryCode
		tmp.Email = v.Email
		tmp.Enabled = v.Enabled
		tmp.PositionStatus = v.PositionStatus
		tmp.Position = v.Position
		tmp.DepartmentName = v.DepartmentName
		// 判断time类型是否为零值
		if !v.LastLoginTime.IsZero() {
			tmp.LastLoginTime = v.LastLoginTime.Format(utils.FormatDateTime)
		}

		tmp.CreatedTime = v.CreatedTime.Format(utils.FormatDateTime)
		tmp.LastUpdatedTime = v.LastUpdatedTime.Format(utils.FormatDateTime)
		userList = append(userList, tmp)
	}
	resp.List = userList
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 新增客户联系人
// @Description 新增客户联系人接口
// @Param	request	body company.AddUserReq true "type json string"
// @router /user/add [post]
func (this *EtaBusinessUserController) AddUser() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var req models.AddUserReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.RealName == "" {
		br.Msg = "请填写姓名"
		br.IsSendEmail = false
		return
	}

	if req.Mobile == "" {
		br.Msg = "请输入手机号"
		br.IsSendEmail = false
		return
	}

	if req.BusinessCode == "" {
		br.Msg = "请选择客户"
		br.IsSendEmail = false
		return
	}

	if req.CountryCode == "" {
		req.CountryCode = "86"
	}

	//空格移除
	req.Mobile = utils.TrimStr(req.Mobile)
	req.RealName = utils.TrimStr(req.RealName)
	//判断该手机号、邮箱是否已经添加，如果已经添加，那么就不再添加
	var key string
	if req.Mobile != "" {
		key = fmt.Sprintf("user:mobile:%s_%s", req.CountryCode, req.Mobile)
	}
	isHas := utils.Rc.IsExist(key)
	if isHas == true {
		br.Msg = "重复添加"
		return
	} else {
		//设置3分钟缓存，不允许重复添加
		utils.Rc.SetNX(key, 1, time.Second*300)

		//添加完成删除对应的缓存
		defer utils.Rc.Delete(key)
	}

	businessObj := new(eta_business.EtaBusiness)

	businessInfo, err := businessObj.GetItemByBusinessCode(req.BusinessCode)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "商户不存在"
			return
		}
		br.Msg = "客户信息有误"
		br.ErrMsg = "获取客户信息失败, Err: " + err.Error()
		return
	}
	//操作权限校验
	ok := eta_business2.CheckBusinessUserButton(sysUser.RoleTypeCode, businessInfo.SellerId, sysUser.AdminId)
	if !ok {
		br.Msg = "没有操作权限"
		br.ErrMsg = "没有操作权限"
		return
	}
	//systemUser models.Company.CompanyUser
	//var sysemUser company.CompanyUser
	//校验主手机号
	mobileItem, err := models.GetUserByMobileCountryCode(req.Mobile, req.CountryCode)
	if err != nil && err.Error() != utils.ErrNoRow() {
		br.Msg = "校验手机号有误"
		br.ErrMsg = "校验手机号有误, Err: " + err.Error()
		return
	}
	if err == nil && mobileItem.UserId > 0 {
		br.Msg = "手机号已存在"
		br.Success = true
		br.Data = mobileItem
		br.IsSendEmail = false
		br.Ret = 600
		return
	}
	err = nil

	user := new(models.User)
	user.RealName = utils.TrimStr(req.RealName)
	user.CountryCode = utils.TrimStr(req.CountryCode)
	user.Mobile = utils.TrimStr(req.Mobile)
	user.Position = req.Position
	user.PositionStatus = req.PositionStatus
	user.Enabled = 1
	user.BusinessCode = req.BusinessCode
	user.DepartmentName = req.DepartmentName
	user.CreatedTime = time.Now()
	user.RegisterTime = time.Now()

	newId, err := models.AddUser(user)
	user.UserId = int(newId)
	if err != nil {
		br.Msg = "新增失败"
		br.ErrMsg = "新增失败,Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "新增成功"
	br.Data = newId
	br.IsAddLog = true
}

// @Title 删除客户联系人
// @Description 删除客户联系人接口
// @Param	request	body company.DeleteUserReq true "type json string"
// @router /user/delete [post]
func (this *EtaBusinessUserController) DeleteUser() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var req models.DeleteUserReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	if req.UserId <= 0 {
		br.Msg = "参数错误！"
		return
	}

	//获取联系人详情
	userInfo, err := models.GetUserByUserId(req.UserId)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "用户不存在"
			return
		}
		br.Msg = "获取联系人异常！"
		br.ErrMsg = "获取联系人异常，Err:" + err.Error()
		return
	}
	// 查询商户关联的销售信息
	businessObj := new(eta_business.EtaBusiness)

	businessInfo, err := businessObj.GetItemByBusinessCode(userInfo.BusinessCode)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "商户不存在"
			return
		}
		br.Msg = "客户信息有误"
		br.ErrMsg = "获取客户信息失败, Err: " + err.Error()
		return
	}
	//操作权限校验
	ok := eta_business2.CheckBusinessUserButton(sysUser.RoleTypeCode, businessInfo.SellerId, sysUser.AdminId)
	if !ok {
		br.Msg = "删除失败，没有权限"
		br.ErrMsg = "删除失败，没有权限"
		return
	}

	err = models.DeleteUser(req.UserId)
	if err != nil {
		br.Msg = "删除失败"
		br.ErrMsg = "删除失败,Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "删除成功"
	br.IsAddLog = true
}

// @Title 编辑客户联系人
// @Description 编辑客户联系人接口
// @Param	request	body company.EditUserReq true "type json string"
// @router /user/edit [post]
func (this *EtaBusinessUserController) EditUser() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var req models.EditUserReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	if req.UserId <= 0 {
		br.Msg = "参数错误！"
		return
	}

	//移除空格
	req.Mobile = utils.TrimStr(req.Mobile)
	req.RealName = utils.TrimStr(req.RealName)

	if req.RealName == "" {
		br.Msg = "请填写姓名"
		br.IsSendEmail = false
		return
	}

	if req.Mobile == "" {
		br.Msg = "请输入手机号"
		br.IsSendEmail = false
		return
	}

	if req.BusinessCode == "" {
		br.Msg = "请选择客户"
		br.IsSendEmail = false
		return
	}

	if req.CountryCode == "" {
		req.CountryCode = "86"
	}

	//操作权限校验
	userInfo, err := models.GetUserByUserId(req.UserId)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "用户不存在"
			return
		}
		br.ErrMsg = "获取信息失败，Err:" + err.Error()
		br.Msg = "获取信息失败"
		return
	}

	businessObj := new(eta_business.EtaBusiness)

	businessInfo, err := businessObj.GetItemByBusinessCode(req.BusinessCode)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "商户不存在"
			return
		}
		br.Msg = "客户信息有误"
		br.ErrMsg = "获取客户信息失败, Err: " + err.Error()
		return
	}
	//操作权限校验
	ok := eta_business2.CheckBusinessUserButton(sysUser.RoleTypeCode, businessInfo.SellerId, sysUser.AdminId)
	if !ok {
		br.Msg = "没有操作权限"
		br.ErrMsg = "没有操作权限"
		return
	}

	if req.Mobile != "" && req.Mobile != userInfo.Mobile && req.CountryCode != userInfo.CountryCode {
		mobileItem, e := models.GetUserByMobileCountryCode(req.Mobile, req.CountryCode)
		if e != nil && e.Error() != utils.ErrNoRow() {
			br.Msg = "校验手机号有误"
			br.ErrMsg = "校验手机号有误, Err: " + err.Error()
			return
		}
		if e == nil && mobileItem.UserId > 0 && mobileItem.UserId != req.UserId {
			{
				br.Msg = "手机号已存在"
				br.Success = true
				br.Data = mobileItem
				br.IsSendEmail = false
				br.Ret = 600
				return
			}
		}
	}

	//待更新字段
	updateCol := []string{"RealName", "Mobile", "LastUpdatedTime", "Position", "PositionStatus", "DepartmentName", "BusinessCode", "CountryCode"}

	userInfo.RealName = req.RealName
	userInfo.Mobile = req.Mobile
	userInfo.LastUpdatedTime = time.Now()
	userInfo.Position = req.Position
	userInfo.DepartmentName = req.DepartmentName
	userInfo.BusinessCode = req.BusinessCode
	userInfo.CountryCode = req.CountryCode
	userInfo.PositionStatus = req.PositionStatus
	err = userInfo.Update(updateCol)
	if err != nil {
		br.Msg = "编辑失败！"
		br.ErrMsg = "编辑失败，Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "编辑成功"
	br.IsAddLog = true
}

// @Title 获取批量导入联系人数据
// @Description 获取批量导入联系人数据
// @Param   File   query   file  true       "文件"
// @Param   CompanyId   query   file  true       "客户id"
// @Success 200 {object} models.ImportListResp
// @router /user/import/list [post]
func (this *EtaBusinessUserController) ImportList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请重新登录"
		return
	}
	file, h, err := this.GetFile("File")
	if err != nil {
		br.Msg = "获取文件失败"
		br.ErrMsg = "获取文件失败，Err:" + err.Error()
		return
	}

	//todo 没有选择对应的商户所以无操作权限校验

	uploadDir := "static/xls"
	err = os.MkdirAll(uploadDir, 766)
	if err != nil {
		br.Msg = "存储目录创建失败"
		br.ErrMsg = "存储目录创建失败,Err:" + err.Error()
		return
	}
	path := uploadDir + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + h.Filename
	defer file.Close()
	err = this.SaveToFile("File", path)
	if err != nil {
		br.Msg = "文件保存失败"
		br.ErrMsg = "文件保存失败，Err:" + err.Error()
		return
	}
	xlFile, err := xlsx.OpenFile(path)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "打开文件失败，Err:" + err.Error() + ";path:" + path
		return
	}
	existUser := make([]*models.User, 0)
	addUser := make([]*models.User, 0)
	//excel中已经存在的数据，用来判断excel中是否存在相同手机号/邮箱，避免重复提交
	excelData := make(map[string]string)
	//重复数据
	repeatUser := make([]*models.User, 0)

	// 遍历sheet页读取
	for _, sheet := range xlFile.Sheets {
		//遍历行读取
		maxRow := sheet.MaxRow
		fmt.Println("maxRow:", maxRow)
		fmt.Println("maxRow")
		for i := 0; i < maxRow; i++ {
			if i == 1 {
				row := sheet.Row(i)
				cells := row.Cells
				for k, cell := range cells {
					text := cell.String()
					if k == 0 {
						if text != "姓名" {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 1 {
						if !strings.Contains(text, "区号") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 2 {
						if !strings.Contains(text, "手机号") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 3 {
						if !strings.Contains(text, "岗位") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 4 {
						if !strings.Contains(text, "部门") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 5 {
						if !strings.Contains(text, "客户名称") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 6 {
						if !strings.Contains(text, "社会信用码") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 7 {
						if !strings.Contains(text, "在职状态") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
				}
			}
			if i >= 2 {
				row := sheet.Row(i)
				cells := row.Cells
				var userName, countryCode, mobileOne, position, departmentName, businessName, creditCode, positionStatus string
				for k, cell := range cells {
					if k == 0 {
						userName = cell.String()
					}
					if k == 1 {
						countryCode = cell.String()
					}
					if k == 2 {
						mobileOne = cell.String()
					}
					if k == 3 {
						position = cell.String()
					}
					if k == 4 {
						departmentName = cell.String()
					}
					if k == 5 {
						businessName = cell.String()
					}
					if k == 6 {
						creditCode = cell.String()
					}
					if k == 7 {
						positionStatus = cell.String()
					}
				}

				//移除空格
				mobileOne = utils.TrimStr(mobileOne)
				//这些字段都没有的话，系统认为excel到底了
				if userName == "" {
					utils.FileLog.Info("姓名必填")
					continue
				}

				//如果手机号或者邮箱都没有填写的情况下
				if mobileOne == "" {
					utils.FileLog.Info("手机号必填")
					continue
				}
				if countryCode == "" {
					utils.FileLog.Info("导入数据中存在【国际区号】为空的用户，请检查")
					continue
				}

				if businessName == "" && creditCode == "" {
					utils.FileLog.Info("导入数据中存在【姓名】和【社会信用码】都为空的用户，请检查")
					continue
				}

				item := new(models.User)
				item.CountryCode = countryCode
				item.RealName = userName
				if positionStatus == "在职" {
					item.PositionStatus = 1
				} else if positionStatus == "离职" {
					item.PositionStatus = 0
				}
				item.Mobile = mobileOne
				item.Position = position
				item.DepartmentName = departmentName
				// 查询商户信息
				if creditCode != "" {
					businessObj := new(eta_business.EtaBusiness)
					businessInfo := new(eta_business.EtaBusiness)
					businessInfo, err = businessObj.GetItemByCreditCode(creditCode)
					if err != nil {
						if err.Error() == utils.ErrNoRow() {
							utils.FileLog.Info("商户不存在")
							continue
						}
						utils.FileLog.Info("获取商户信息失败, Err: " + err.Error())
						continue
					}
					item.BusinessCode = businessInfo.BusinessCode
				}
				if item.BusinessCode == "" && businessName != "" {
					businessObj := new(eta_business.EtaBusiness)
					businessInfo := new(eta_business.EtaBusiness)
					businessInfo, err = businessObj.GetItemByBusinessName(businessName)
					if err != nil {
						if err.Error() == utils.ErrNoRow() {
							utils.FileLog.Info("商户不存在")
							continue
						}
						utils.FileLog.Info("获取商户信息失败, Err: " + err.Error())
						continue
					}
					item.BusinessCode = businessInfo.BusinessCode
				}
				if _, ok := excelData[item.CountryCode+"_"+item.Mobile]; ok {
					//将用户插入其中，然后退出当前循环，进入下一循环
					//repeatUser = append(repeatUser, item)
					continue
				}
				excelData[item.CountryCode+"_"+item.Mobile] = item.CountryCode

				//没问题数据
				existUser = append(existUser, item)
			}
		}
	}

	// 判断系统里该手机号是否已存在
	mobiles := make([]string, 0)
	for k, _ := range excelData {
		mobile := strings.Split(k, "_")[1]
		mobiles = append(mobiles, mobile)
	}

	// 查询系统里是否存在
	existUserMap := make(map[string]struct{})
	if len(mobiles) > 0 {
		existUsers, e := models.GetUserByMobiles(mobiles)
		if e != nil {
			br.Msg = "查询用户失败"
			br.ErrMsg = "查询用户失败，Err:" + e.Error()
			return
		}
		for _, user := range existUsers {
			existUserMap[user.CountryCode+"_"+user.Mobile] = struct{}{}
		}
	}
	for _, v := range existUser {
		if _, ok := existUserMap[v.CountryCode+"_"+v.Mobile]; ok {
			repeatUser = append(repeatUser, v)
		} else {
			addUser = append(addUser, v)
		}
	}
	//defer func() {
	//	os.Remove(path)
	//}()
	br.Msg = "获取成功"
	br.Ret = 200
	br.Success = true
	br.Data = models.ImportListResp{
		ValidUser:  addUser,
		RepeatUser: repeatUser,
	}
}

// 需要更新的联系人数据实体
type UpdateWxUser struct {
	OldWxUser models.User  `description:"旧的联系人数据orm实体（未变更前的）"`
	WxUser    *models.User `description:"联系人数据orm实体"`
	Cols      []string     `description:"需要修改的字段名切片"`
}

// @Title 批量导入联系人数据
// @Description 批量导入联系人数据
// @Param   File   query   file  true       "文件"
// @Param   CompanyId   query   file  true       "客户id"
// @Success 600 {object} []*company.CompanyUser
// @Success 200 Ret=200 导入成功
// @router /user/import [post]
func (this *EtaBusinessUserController) Import() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请重新登录"
		return
	}
	file, h, err := this.GetFile("File")
	if err != nil {
		br.Msg = "获取文件失败"
		br.ErrMsg = "获取文件失败，Err:" + err.Error()
		return
	}

	//todo 没有选择对应的商户所以无操作权限校验

	uploadDir := "static/xls"
	err = os.MkdirAll(uploadDir, 766)
	if err != nil {
		br.Msg = "存储目录创建失败"
		br.ErrMsg = "存储目录创建失败,Err:" + err.Error()
		return
	}
	path := uploadDir + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + h.Filename
	defer file.Close()
	err = this.SaveToFile("File", path)
	if err != nil {
		br.Msg = "文件保存失败"
		br.ErrMsg = "文件保存失败，Err:" + err.Error()
		return
	}
	xlFile, err := xlsx.OpenFile(path)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "打开文件失败，Err:" + err.Error() + ";path:" + path
		return
	}
	existUser := make([]*models.User, 0)
	addUser := make([]*models.User, 0)
	//excel中已经存在的数据，用来判断excel中是否存在相同手机号/邮箱，避免重复提交
	excelData := make(map[string]string)

	// 遍历sheet页读取
	for _, sheet := range xlFile.Sheets {
		//遍历行读取
		maxRow := sheet.MaxRow
		fmt.Println("maxRow:", maxRow)
		fmt.Println("maxRow")
		for i := 0; i < maxRow; i++ {
			if i == 1 {
				row := sheet.Row(i)
				cells := row.Cells
				for k, cell := range cells {
					text := cell.String()
					if k == 0 {
						if text != "姓名" {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 1 {
						if !strings.Contains(text, "区号") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 2 {
						if !strings.Contains(text, "手机号") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 3 {
						if !strings.Contains(text, "岗位") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 4 {
						if !strings.Contains(text, "部门") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 5 {
						if !strings.Contains(text, "客户名称") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 6 {
						if !strings.Contains(text, "社会信用码") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 7 {
						if !strings.Contains(text, "在职状态") {
							br.Msg = "模板格式错误"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
				}
			}
			if i >= 2 {
				row := sheet.Row(i)
				cells := row.Cells
				var userName, countryCode, mobileOne, position, departmentName, businessName, creditCode, positionStatus string
				for k, cell := range cells {
					if k == 0 {
						userName = cell.String()
					}
					if k == 1 {
						countryCode = cell.String()
					}
					if k == 2 {
						mobileOne = cell.String()
					}
					if k == 3 {
						position = cell.String()
					}
					if k == 4 {
						departmentName = cell.String()
					}
					if k == 5 {
						businessName = cell.String()
					}
					if k == 6 {
						creditCode = cell.String()
					}
					if k == 7 {
						positionStatus = cell.String()
					}
				}

				//移除空格
				mobileOne = utils.TrimStr(mobileOne)
				//这些字段都没有的话，系统认为excel到底了
				if userName == "" {
					utils.FileLog.Info("姓名必填")
					continue
				}

				//如果手机号或者邮箱都没有填写的情况下
				if mobileOne == "" {
					utils.FileLog.Info("手机号必填")
					continue
				}
				if countryCode == "" {
					utils.FileLog.Info("导入数据中存在【国际区号】为空的用户，请检查")
					continue
				}

				if businessName == "" && creditCode == "" {
					utils.FileLog.Info("导入数据中存在【姓名】和【社会信用码】都为空的用户，请检查")
					continue
				}

				item := new(models.User)
				item.CountryCode = countryCode
				item.RealName = userName
				if positionStatus == "在职" {
					item.PositionStatus = 1
				} else if positionStatus == "离职" {
					item.PositionStatus = 0
				}
				item.Mobile = mobileOne
				item.Position = position
				item.DepartmentName = departmentName
				// 查询商户信息
				if creditCode != "" {
					businessObj := new(eta_business.EtaBusiness)
					businessInfo := new(eta_business.EtaBusiness)
					businessInfo, err = businessObj.GetItemByCreditCode(creditCode)
					if err != nil {
						if err.Error() == utils.ErrNoRow() {
							utils.FileLog.Info("商户不存在")
							continue
						}
						utils.FileLog.Info("获取商户信息失败, Err: " + err.Error())
						continue
					}
					item.BusinessCode = businessInfo.BusinessCode
				}
				if item.BusinessCode == "" && businessName != "" {
					businessObj := new(eta_business.EtaBusiness)
					businessInfo := new(eta_business.EtaBusiness)
					businessInfo, err = businessObj.GetItemByBusinessName(businessName)
					if err != nil {
						if err.Error() == utils.ErrNoRow() {
							utils.FileLog.Info("商户不存在")
							continue
						}
						utils.FileLog.Info("获取商户信息失败, Err: " + err.Error())
						continue
					}
					item.BusinessCode = businessInfo.BusinessCode
				}
				if _, ok := excelData[item.CountryCode+"_"+item.Mobile]; ok {
					//将用户插入其中，然后退出当前循环，进入下一循环
					//repeatUser = append(repeatUser, item)
					continue
				}
				excelData[item.CountryCode+"_"+item.Mobile] = item.CountryCode

				//没问题数据
				existUser = append(existUser, item)
			}
		}
	}

	// 判断系统里该手机号是否已存在
	mobiles := make([]string, 0)
	for k, _ := range excelData {
		mobile := strings.Split(k, "_")[1]
		mobiles = append(mobiles, mobile)
	}

	// 查询系统里是否存在
	existUserMap := make(map[string]struct{})
	if len(mobiles) > 0 {
		existUsers, e := models.GetUserByMobiles(mobiles)
		if e != nil {
			br.Msg = "查询用户失败"
			br.ErrMsg = "查询用户失败，Err:" + e.Error()
			return
		}
		for _, user := range existUsers {
			existUserMap[user.CountryCode+"_"+user.Mobile] = struct{}{}
		}
	}
	for _, v := range existUser {
		if _, ok := existUserMap[v.CountryCode+"_"+v.Mobile]; !ok {
			addUser = append(addUser, v)
		}
	}
	fmt.Println("表格中用户与系统中存在用户没有冲突")
	//如果表格中用户与系统中存在用户 没有冲突，那么继续执行
	for _, user := range addUser {
		if user.RealName != "" && user.Mobile != "" {
			userData := new(models.User)
			userData.RealName = user.RealName
			userData.Mobile = user.Mobile
			userData.CountryCode = user.CountryCode
			userData.Email = user.Email
			userData.Position = user.Position
			userData.PositionStatus = user.PositionStatus
			userData.BusinessCode = user.BusinessCode
			userData.DepartmentName = user.DepartmentName
			userData.CountryCode = user.CountryCode

			//判断该手机号、邮箱是否已经添加，如果已经添加，那么就不再添加
			var key string
			key = "user:mobile:" + userData.Mobile

			isHas := utils.Rc.IsExist(key)
			if isHas == false {
				newId, err := models.AddUser(userData)
				userData.UserId = int(newId)
				if err != nil {
					br.Msg = "导入失败"
					br.ErrMsg = "导入失败,Err:" + err.Error()
					return
				}
			}
		}
	}
	defer func() {
		os.Remove(path)
	}()

	br.Msg = "导入成功"
	br.Ret = 200
	br.Success = true
}

// @Title 移动用户至新的商户下
// @Description 移动用户至新的商户下
// @Param	request	body company.EditUserReq true "type json string"
// @router /user/changeBusiness [post]
func (this *EtaBusinessUserController) ChangeUserBusiness() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var req models.ChangeUserBusinessReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	if req.UserId <= 0 {
		br.Msg = "参数错误！"
		return
	}

	if req.BusinessCode == "" {
		br.Msg = "请选择商户"
		br.IsSendEmail = false
		return
	}
	//操作权限校验
	userInfo, err := models.GetUserByUserId(req.UserId)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "用户不存在"
			return
		}
		br.ErrMsg = "获取信息失败，Err:" + err.Error()
		br.Msg = "获取信息失败"
		return
	}
	if userInfo.BusinessCode == req.BusinessCode {
		br.Msg = "用户已经在该商户下"
		return
	}
	businessObj := new(eta_business.EtaBusiness)

	businessInfo, err := businessObj.GetItemByBusinessCode(req.BusinessCode)
	if err != nil {
		if err.Error() == utils.ErrNoRow() {
			br.Msg = "商户不存在"
			return
		}
		br.Msg = "商户信息有误"
		br.ErrMsg = "获取商户信息失败, Err: " + err.Error()
		return
	}
	//操作权限校验
	ok := eta_business2.CheckBusinessUserButton(sysUser.RoleTypeCode, businessInfo.SellerId, sysUser.AdminId)
	if !ok {
		br.Msg = "没有操作权限"
		br.ErrMsg = "没有操作权限"
		return
	}

	//待更新字段
	updateCol := []string{"LastUpdatedTime", "BusinessCode"}

	userInfo.LastUpdatedTime = time.Now()

	userInfo.BusinessCode = req.BusinessCode
	err = userInfo.Update(updateCol)
	if err != nil {
		br.Msg = "操作失败！"
		br.ErrMsg = "操作失败，Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
	br.IsAddLog = true
}