eta_mini_crm/controllers/company.go

package controllers

import (
	"encoding/json"
	"eta/eta_mini_crm/models"
	"eta/eta_mini_crm/models/request"
	"eta/eta_mini_crm/models/response"
	"eta/eta_mini_crm/utils"
	"fmt"
	"github.com/rdlucklib/rdluck_tools/paging"
	"strconv"
	"strings"
	"time"
)

// CompanyController 机构
type CompanyController struct {
	BaseAuthController
}

// Add
// @Title 新增机构
// @Description 新增机构
// @Param	request	body request.CompanyAddReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /add [post]
func (this *CompanyController) Add() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		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 request.CompanyAddReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
		return
	}
	req.CompanyName = strings.TrimSpace(req.CompanyName)
	if req.CompanyName == "" {
		br.Msg = "请输入投资者名称"
		return
	}
	req.CreditCode = strings.TrimSpace(req.CreditCode)
	if req.CreditCode == "" {
		br.Msg = "请输入社会统一信用码"
		return
	}
	req.Industry = strings.TrimSpace(req.Industry)
	if req.Industry == "" {
		br.Msg = "请输入所属行业"
		return
	}
	req.Province = strings.TrimSpace(req.Province)
	if req.ProvinceId <= 0 || req.Province == "" {
		br.Msg = "请选择省"
		return
	}
	req.City = strings.TrimSpace(req.City)
	if req.CityId <= 0 || req.City == "" {
		br.Msg = "请选择市"
		return
	}
	if req.CityId <= 0 || req.City == "" {
		br.Msg = "请选择市"
		return
	}
	if req.SellerId <= 0 {
		br.Msg = "请选择营业部"
		return
	}
	sellerItem, e := models.GetSysUserById(req.SellerId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Msg = "所选营业部不存在，请刷新页面"
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("获取营业部销售失败, %v", e)
		return
	}

	// 校验社会统一信用码是否存在
	companyOb := new(models.Company)
	{
		cond := fmt.Sprintf(` AND %s = ?`, companyOb.Cols().CreditCode)
		pars := make([]interface{}, 0)
		pars = append(pars, req.CreditCode)
		exist, e := companyOb.GetItemByCondition(cond, pars, "")
		if e != nil && e.Error() != utils.ErrNoRow() {
			br.Msg = "操作失败"
			br.ErrMsg = fmt.Sprintf("获取重复机构信用码失败, %v", e)
			return
		}
		if exist != nil && exist.CompanyId > 0 {
			br.Msg = "社会统一信用码已存在"
			return
		}
	}

	companyOb.CompanyName = req.CompanyName
	companyOb.CreditCode = req.CreditCode
	companyOb.ProvinceId = req.ProvinceId
	companyOb.Province = req.Province
	companyOb.CityId = req.CityId
	companyOb.City = req.City
	companyOb.Address = req.Address
	companyOb.Industry = req.Industry
	companyOb.SellerId = req.SellerId
	companyOb.SellerName = sellerItem.SysRealName
	companyOb.SysUserId = sysUser.SysUserId
	companyOb.SysUserRealName = sysUser.SysRealName
	companyOb.AuthStatus = models.AuthStatusOpen
	companyOb.CreateTime = time.Now().Local()
	companyOb.ModifyTime = time.Now().Local()
	if e := companyOb.Create(); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("新增机构失败, %v", e)
		return
	}

	// 操作记录
	go func() {
		recordOb := new(models.CompanyUserOperateRecord)
		recordOb.CompanyId = companyOb.CompanyId
		recordOb.Remark = fmt.Sprintf("%s新增机构投资者", sysUser.SysRealName)
		recordOb.SysUserId = sysUser.SysUserId
		recordOb.SysUserRealName = sysUser.SysRealName
		recordOb.CreateTime = time.Now().Local()
		if e := recordOb.Create(); e != nil {
			utils.FileLog.Info(fmt.Sprintf("新增操作记录失败, CompanyId: %d, ErrMsg: %v", companyOb.CompanyId, e))
		}
	}()

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

// Edit
// @Title 编辑机构
// @Description 编辑机构
// @Param	request	body request.CompanyEditReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /edit [post]
func (this *CompanyController) Edit() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		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 request.CompanyEditReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
		return
	}
	if req.CompanyId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = fmt.Sprintf("机构ID参数有误, CompanyId: %d", req.CompanyId)
		return
	}
	req.CompanyName = strings.TrimSpace(req.CompanyName)
	if req.CompanyName == "" {
		br.Msg = "请输入投资者名称"
		return
	}
	req.CreditCode = strings.TrimSpace(req.CreditCode)
	if req.CreditCode == "" {
		br.Msg = "请输入社会统一信用码"
		return
	}
	req.Industry = strings.TrimSpace(req.Industry)
	if req.Industry == "" {
		br.Msg = "请输入所属行业"
		return
	}
	req.Province = strings.TrimSpace(req.Province)
	if req.ProvinceId <= 0 || req.Province == "" {
		br.Msg = "请选择省"
		return
	}
	req.City = strings.TrimSpace(req.City)
	if req.CityId <= 0 || req.City == "" {
		br.Msg = "请选择市"
		return
	}
	if req.CityId <= 0 || req.City == "" {
		br.Msg = "请选择市"
		return
	}
	if req.SellerId <= 0 {
		br.Msg = "请选择营业部"
		return
	}
	companyOb := new(models.Company)
	companyItem, e := companyOb.GetItemById(req.CompanyId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Msg = "机构不存在，请刷新页面"
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("获取机构失败, %v", e)
		return
	}
	// 操作权限校验
	if sysUser.SysRoleId != utils.AdminRoleId {
		if sysUser.SysUserId != companyItem.SysUserId && sysUser.SysUserId != companyItem.SellerId {
			br.Msg = "无权操作"
			return
		}
	}

	sellerItem, e := models.GetSysUserById(req.SellerId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Msg = "所选营业部不存在，请刷新页面"
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("获取营业部销售失败, %v", e)
		return
	}

	// 校验社会统一信用码是否存在
	{
		cond := fmt.Sprintf(` AND %s = ? AND %s <> ?`, companyOb.Cols().CreditCode, companyOb.Cols().PrimaryId)
		pars := make([]interface{}, 0)
		pars = append(pars, req.CreditCode, req.CompanyId)
		exist, e := companyOb.GetItemByCondition(cond, pars, "")
		if e != nil && e.Error() != utils.ErrNoRow() {
			br.Msg = "操作失败"
			br.ErrMsg = fmt.Sprintf("获取重复机构信用码失败, %v", e)
			return
		}
		if exist != nil && exist.CompanyId > 0 {
			br.Msg = "社会统一信用码已存在"
			return
		}
	}

	// 更新机构
	var updateName bool
	if companyItem.CompanyName != req.CompanyName {
		updateName = true
	}
	companyItem.CompanyName = req.CompanyName
	companyItem.CreditCode = req.CreditCode
	companyItem.ProvinceId = req.ProvinceId
	companyItem.Province = req.Province
	companyItem.CityId = req.CityId
	companyItem.City = req.City
	companyItem.Address = req.Address
	companyItem.Industry = req.Industry
	companyItem.SellerId = req.SellerId
	companyItem.SellerName = sellerItem.SysRealName
	companyItem.ModifyTime = time.Now().Local()
	updateCols := []string{
		companyOb.Cols().CompanyName, companyOb.Cols().CreditCode, companyOb.Cols().ProvinceId, companyOb.Cols().Province, companyOb.Cols().CityId, companyOb.Cols().City, companyOb.Cols().Address, companyOb.Cols().Industry, companyOb.Cols().SellerId, companyOb.Cols().SellerName, companyOb.Cols().ModifyTime,
	}
	if e := companyItem.Update(updateCols); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("更新机构失败, %v", e)
		return
	}

	// 更新冗余字段
	if updateName {
		userOb := new(models.Users)
		if e = userOb.UpdateCompanyNameById(req.CompanyId, req.CompanyName); e != nil {
			br.Msg = "操作失败"
			br.ErrMsg = fmt.Sprintf("更新用户表机构名称失败, CompanyId: %d, CompanyName: %s, ErrMsg: %v", req.CompanyId, req.CompanyName, e)
			return
		}
	}

	// 操作记录
	go func() {
		recordOb := new(models.CompanyUserOperateRecord)
		recordOb.CompanyId = companyItem.CompanyId
		recordOb.Remark = fmt.Sprintf("%s编辑机构投资者", sysUser.SysRealName)
		recordOb.SysUserId = sysUser.SysUserId
		recordOb.SysUserRealName = sysUser.SysRealName
		recordOb.CreateTime = time.Now().Local()
		if e := recordOb.Create(); e != nil {
			utils.FileLog.Info(fmt.Sprintf("新增操作记录失败, CompanyId: %d, ErrMsg: %v", companyItem.CompanyId, e))
		}
	}()

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

// Remove
// @Title 删除机构
// @Description 删除机构
// @Param	request	body request.CompanyRemoveReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /remove [post]
func (this *CompanyController) Remove() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		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 request.CompanyRemoveReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
		return
	}
	if req.CompanyId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = fmt.Sprintf("机构ID参数有误, CompanyId: %d", req.CompanyId)
		return
	}
	companyOb := new(models.Company)
	companyItem, e := companyOb.GetItemById(req.CompanyId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Ret = 200
			br.Msg = "操作成功"
			br.Success = true
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("获取机构失败, %v", e)
		return
	}
	// 操作权限校验
	if sysUser.SysRoleId != utils.AdminRoleId {
		if sysUser.SysUserId != companyItem.SysUserId && sysUser.SysUserId != companyItem.SellerId {
			br.Msg = "无权操作"
			return
		}
	}

	// 删除机构及用户
	if e = companyOb.RemoveCompanyAndUsers(req.CompanyId); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("删除机构及用户失败, %v", e)
		return
	}

	// 操作记录
	go func() {
		recordOb := new(models.CompanyUserOperateRecord)
		recordOb.CompanyId = companyItem.CompanyId
		recordOb.Remark = fmt.Sprintf("%s删除机构投资者", sysUser.SysRealName)
		recordOb.SysUserId = sysUser.SysUserId
		recordOb.SysUserRealName = sysUser.SysRealName
		recordOb.CreateTime = time.Now().Local()
		if e := recordOb.Create(); e != nil {
			utils.FileLog.Info(fmt.Sprintf("新增操作记录失败, CompanyId: %d, ErrMsg: %v", companyItem.CompanyId, e))
		}
	}()

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

// TransAuth
// @Title 切换阅读权限
// @Description 切换阅读权限
// @Param	request	body request.CompanyTransAuthReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /trans_auth [post]
func (this *CompanyController) TransAuth() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		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 request.CompanyTransAuthReq
	if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
		return
	}
	if req.CompanyId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = fmt.Sprintf("机构ID参数有误, CompanyId: %d", req.CompanyId)
		return
	}
	companyOb := new(models.Company)
	companyItem, e := companyOb.GetItemById(req.CompanyId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Ret = 200
			br.Msg = "操作成功"
			br.Success = true
			return
		}
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("获取机构失败, %v", e)
		return
	}
	// 操作权限校验
	if sysUser.SysRoleId != utils.AdminRoleId {
		if sysUser.SysUserId != companyItem.SysUserId && sysUser.SysUserId != companyItem.SellerId {
			br.Msg = "无权操作"
			return
		}
	}

	// 更新机构权限并同步其下用户
	statusChange := models.AuthStatusClose
	if companyItem.AuthStatus == models.AuthStatusClose {
		statusChange = models.AuthStatusOpen
	}
	optRemarks := map[int]string{models.AuthStatusClose: "关闭", models.AuthStatusOpen: "开启"}
	if e = companyOb.ChangeCompanyAndUsersAuth(req.CompanyId, statusChange); e != nil {
		br.Msg = "操作失败"
		br.ErrMsg = fmt.Sprintf("更新机构及用户权限失败, %v", e)
		return
	}

	// 操作记录
	go func() {
		recordOb := new(models.CompanyUserOperateRecord)
		recordOb.CompanyId = companyItem.CompanyId
		recordOb.Remark = fmt.Sprintf("%s%s机构投资者权限", sysUser.SysRealName, optRemarks[statusChange])
		recordOb.SysUserId = sysUser.SysUserId
		recordOb.SysUserRealName = sysUser.SysRealName
		recordOb.CreateTime = time.Now().Local()
		if e := recordOb.Create(); e != nil {
			utils.FileLog.Info(fmt.Sprintf("新增操作记录失败, CompanyId: %d, ErrMsg: %v", companyItem.CompanyId, e))
		}
	}()

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

// Detail
// @Title 机构详情
// @Description 机构详情
// @Param   CompanyId  query  int  true  "机构ID"
// @Success 200 {object} models.CompanyItem
// @router /detail [get]
func (this *CompanyController) Detail() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	companyId, _ := this.GetInt("CompanyId")
	if companyId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = fmt.Sprintf("参数有误, %d", companyId)
		return
	}
	companyOb := new(models.Company)
	companyItem, e := companyOb.GetItemById(companyId)
	if e != nil {
		if e.Error() == utils.ErrNoRow() {
			br.Msg = "机构不存在，请刷新页面"
			return
		}
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取机构失败, %v", e)
		return
	}
	resp := companyItem.Format2Item()

	br.Data = resp
	br.Ret = 200
	br.Msg = "获取成功"
	br.Success = true
}

// OperateRecords
// @Title 机构-操作记录
// @Description 机构-操作记录
// @Param   CompanyId  query  int  true  "机构ID"
// @Success 200 {object} models.CompanyUserOperateRecordItem
// @router /operate_records [get]
func (this *CompanyController) OperateRecords() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	companyId, _ := this.GetInt("CompanyId")
	if companyId <= 0 {
		br.Msg = "参数有误"
		br.ErrMsg = fmt.Sprintf("参数有误, %d", companyId)
		return
	}
	resp := make([]*models.CompanyUserOperateRecordItem, 0)

	recordOb := new(models.CompanyUserOperateRecord)
	cond := fmt.Sprintf(` AND %s = ?`, recordOb.Cols().CompanyId)
	pars := make([]interface{}, 0)
	pars = append(pars, companyId)
	list, e := recordOb.GetItemsByCondition(cond, pars, []string{}, "")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取操作记录列表失败, %v", e)
		return
	}
	for _, v := range list {
		resp = append(resp, v.Format2Item())
	}

	br.Data = resp
	br.Ret = 200
	br.Msg = "获取成功"
	br.Success = true
}

// PageList
// @Title 机构列表-分页
// @Description 机构列表-分页
// @Param	request	body request.CompanyListForm true "type json string"
// @Success 200 {object} response.CompanyPageListResp
// @router /page_list [get]
func (this *CompanyController) PageList() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	params := new(request.CompanyListForm)
	if e := this.ParseForm(params); e != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
		return
	}
	resp := new(response.CompanyPageListResp)
	companyOb := new(models.Company)

	// 仅超管/创建人/销售可见
	cond := ``
	pars := make([]interface{}, 0)
	if sysUser.SysRoleId != utils.AdminRoleId {
		cond += fmt.Sprintf(` AND (%s = ? OR %s = ?)`, companyOb.Cols().SysUserId, companyOb.Cols().SellerId)
		pars = append(pars, sysUser.SysUserId, sysUser.SysUserId)
	}

	// 筛选项
	{
		// 关键词（机构名称/联系人名称/联系人手机号）
		keywords := strings.TrimSpace(params.Keywords)
		if keywords != "" {
			kw := fmt.Sprint("%", keywords, "%")
			usersOb := new(models.Users)
			companyIds, e := usersOb.GetCompanyIdsByKeywords(kw)
			if e != nil {
				br.Msg = "获取失败"
				br.ErrMsg = fmt.Sprintf("搜索用户表关键词失败, %v", e)
				return
			}
			if len(companyIds) > 0 {
				cond += fmt.Sprintf(` AND (%s LIKE ? OR %s IN (%s))`, companyOb.Cols().CompanyName, companyOb.Cols().PrimaryId, utils.GetOrmInReplace(len(companyIds)))
				pars = append(pars, kw, companyIds)
			} else {
				cond += fmt.Sprintf(` AND %s LIKE ?`, companyOb.Cols().CompanyName)
				pars = append(pars, kw)
			}
		}

		// 营业部
		params.SellerIds = strings.TrimSpace(params.SellerIds)
		if params.SellerIds != "" {
			var sellerIds []int
			idArr := strings.Split(params.SellerIds, ",")
			for _, v := range idArr {
				id, _ := strconv.Atoi(v)
				if id > 0 {
					sellerIds = append(sellerIds, id)
				}
			}
			if len(sellerIds) == 0 {
				page := paging.GetPaging(params.CurrentIndex, params.PageSize, 0)
				resp.Paging = page
				resp.List = make([]*models.CompanyItem, 0)
				br.Data = resp
				br.Ret = 200
				br.Msg = "获取成功"
				br.Success = true
				return
			}
			cond += fmt.Sprintf(` AND %s IN (%s)`, companyOb.Cols().SellerId, utils.GetOrmInReplace(len(sellerIds)))
			pars = append(pars, sellerIds)
		}

		// 创建时间区间
		params.StartTime = strings.TrimSpace(params.StartTime)
		params.EndTime = strings.TrimSpace(params.EndTime)
		if params.StartTime != "" && params.EndTime != "" {
			_, e := time.ParseInLocation(utils.FormatDate, params.StartTime, time.Local)
			if e != nil {
				br.Msg = "开始时间格式有误"
				return
			}
			_, e = time.ParseInLocation(utils.FormatDate, params.EndTime, time.Local)
			if e != nil {
				br.Msg = "结束时间格式有误"
				return
			}
			cond += fmt.Sprintf(` AND (%s BETWEEN ? AND ?)`, companyOb.Cols().CreateTime)
			pars = append(pars, fmt.Sprintf("%s 00:00:00", params.StartTime), fmt.Sprintf("%s 23:59:59", params.EndTime))
		}
	}

	// 分页
	var startSize int
	if params.PageSize <= 0 {
		params.PageSize = utils.PageSize20
	}
	if params.CurrentIndex <= 0 {
		params.CurrentIndex = 1
	}
	startSize = utils.StartIndex(params.CurrentIndex, params.PageSize)

	// 排序
	orderRule := fmt.Sprintf(`%s DESC`, companyOb.Cols().CreateTime)
	if params.SortField > 0 && params.SortRule > 0 {
		fieldMap := map[int]string{1: companyOb.Cols().CreateTime}
		ruleMap := map[int]string{1: "ASC", 2: "DESC"}
		if fieldMap[params.SortField] != "" && ruleMap[params.SortRule] != "" {
			orderRule = fmt.Sprintf("%s %s", fieldMap[params.SortField], ruleMap[params.SortRule])
		}
	}

	total, e := companyOb.GetCountByCondition(cond, pars)
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取机构总数失败, %v", e)
		return
	}
	list, e := companyOb.GetPageItemsByCondition(cond, pars, []string{}, orderRule, startSize, params.PageSize)
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取机构分页列表失败, %v", e)
		return
	}
	respList := make([]*models.CompanyItem, 0)
	for _, v := range list {
		respList = append(respList, v.Format2Item())
	}

	page := paging.GetPaging(params.CurrentIndex, params.PageSize, total)
	resp.Paging = page
	resp.List = respList
	br.Data = resp
	br.Ret = 200
	br.Msg = "获取成功"
	br.Success = true
}

// Search
// @Title 机构列表-搜索
// @Description 机构列表-搜索
// @Param	request	body request.CompanyListForm true "type json string"
// @Success 200 {object} models.CompanyItem
// @router /search [get]
func (this *CompanyController) Search() {
	br := new(models.BaseResponse).Init()
	defer func() {
		if br.ErrMsg == "" {
			br.IsSendEmail = false
		}
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	params := new(request.CompanyListForm)
	if e := this.ParseForm(params); e != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = fmt.Sprintf("参数解析异常, %v", e)
		return
	}
	resp := make([]*models.CompanyItem, 0)
	companyOb := new(models.Company)

	// 仅超管/创建人/销售可见
	cond := ``
	pars := make([]interface{}, 0)
	if sysUser.SysRoleId != utils.AdminRoleId {
		cond += fmt.Sprintf(` AND (%s = ? OR %s = ?)`, companyOb.Cols().SysUserId, companyOb.Cols().SellerId)
		pars = append(pars, sysUser.SysUserId, sysUser.SysUserId)
	}

	keywords := strings.TrimSpace(params.Keywords)
	if keywords != "" {
		kw := fmt.Sprint("%", keywords, "%")
		cond += fmt.Sprintf(` AND %s LIKE ?`, companyOb.Cols().CompanyName)
		pars = append(pars, kw)
	}
	list, e := companyOb.GetItemsByCondition(cond, pars, []string{}, "")
	if e != nil {
		br.Msg = "获取失败"
		br.ErrMsg = fmt.Sprintf("获取机构列表失败, %v", e)
		return
	}
	for _, v := range list {
		resp = append(resp, v.Format2Item())
	}

	br.Data = resp
	br.Ret = 200
	br.Msg = "获取成功"
	br.Success = true
}