hz_crm_api/controllers/company_user.go

package controllers

import (
	"encoding/json"
	"errors"
	"fmt"
	"github.com/rdlucklib/rdluck_tools/paging"
	"github.com/tealeg/xlsx"
	"hongze/hz_crm_api/models"
	"hongze/hz_crm_api/models/advisory"
	"hongze/hz_crm_api/models/company"
	"hongze/hz_crm_api/models/company_user"
	"hongze/hz_crm_api/models/company_user/request"
	"hongze/hz_crm_api/models/company_user/response"
	"hongze/hz_crm_api/models/cygx"
	"hongze/hz_crm_api/models/system"
	"hongze/hz_crm_api/models/yb"
	"hongze/hz_crm_api/services"
	cygxService "hongze/hz_crm_api/services/cygx"
	"hongze/hz_crm_api/services/elastic"
	"hongze/hz_crm_api/utils"
	"os"
	"path"
	"path/filepath"
	"strconv"
	"strings"
	"time"
	"unicode/utf8"
)

// 客户联系人管理
type CompanyUserController struct {
	BaseAuthController
}

// @Title 新增客户联系人
// @Description 新增客户联系人接口
// @Param	request	body company.AddUserReq true "type json string"
// @router /user/add [post]
func (this *CompanyUserController) 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 company.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
	}

	//空格移除
	req.MobileOne = utils.TrimStr(req.MobileOne)
	req.MobileTwo = utils.TrimStr(req.MobileTwo)
	req.Email = utils.TrimStr(req.Email)
	req.RealName = utils.TrimStr(req.RealName)
	//判断该手机号、邮箱是否已经添加，如果已经添加，那么就不再添加
	var key string
	if req.MobileOne != "" {
		key = "wx_user:mobile:" + req.MobileOne
	} else {
		key = "wx_user:email:" + req.Email
	}
	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)
	}

	source := req.Source
	if source == "" {
		br.Msg = "没有来源"
		return
	}
	regionType := req.RegionType //区域来源
	productId := services.GetProductId(sysUser.RoleTypeCode)

	//操作员的产品权限
	companyProductList := make([]*company.CompanyProduct, 0)

	var companyInfo *company.Company
	var e error
	if req.CompanyId > 0 {
		companyInfo, e = company.GetCompanyById(req.CompanyId)
		if e != nil {
			br.Msg = "客户信息有误"
			br.ErrMsg = "获取客户信息失败, Err: " + e.Error()
			return
		}
	}

	//权益类客户，邮箱必填（2021-03-22 13:32:59修改）
	if productId == 1 || regionType == "国内" { //ficc类客户
		if req.MobileOne == "" && req.Email == "" {
			br.Msg = "请输入手机号或邮箱"
			br.IsSendEmail = false
			return
		}
	} else if productId == 2 { //权益类客户
		if req.MobileOne == "" {
			br.Msg = "请输入手机号"
			br.ErrMsg = "请输入手机号"
			br.IsSendEmail = false
			return
		}
		if req.Email == "" {
			br.Msg = "请输入邮箱"
			br.ErrMsg = "请输入邮箱"
			br.IsSendEmail = false
			return
		}
	} else {
		//如果是管理员账户，那么需要从企业信息里面去获取所属类型客户了
		//获取企业客户信息
		if req.Source == "add_custom" {
			//添加客户时新增联系人
		} else if req.Source == "pick_custom" {
			//领取客户时添加联系人
			br.ErrMsg = "管理员账户不允许领取客户"
			br.Msg = "来源异常"
			return
		} else if req.Source == "add_user" {
			//普通类型添加客户
			//companyInfo, err := company.GetCompanyById(req.CompanyId)
			//if err != nil {
			//	br.ErrMsg = "获取客户信息失败，Err:" + err.Error()
			//	br.Msg = "获取客户信息失败"
			//	return
			//}

			//手机号、邮箱校验（必填一个）
			if req.MobileOne == "" && req.Email == "" {
				br.Msg = "请输入手机号或邮箱"
				br.IsSendEmail = false
				return
			}
			//shareSellerId = companyInfo.ShareSellerId
			//获取当前操作员产品权限
			tmpCompanyProductList, productErr := getSysCompanyProductList(productId, req.CompanyId)
			if productErr != nil {
				br.Msg = "新增失败"
				br.ErrMsg = "新增失败，获取当前操作员产品权限异常,Err:" + productErr.Error()
				return
			}
			if tmpCompanyProductList == nil {
				br.Msg = "新增失败"
				br.ErrMsg = "新增失败，获取当前操作员找不到产品权限"
				return
			}
			for _, v := range tmpCompanyProductList {
				//权益（海外）客户，需要有提示
				if v.ProductId == 2 && companyInfo.RegionType == "海外" {
					if req.MobileOne == "" {
						br.Msg = "请输入手机号"
					}
					if req.Email == "" {
						br.Msg = "请输入邮箱"
						br.ErrMsg = "请输入邮箱"
						return
					}
				}
			}
			companyProductList = tmpCompanyProductList
		} else {
			br.ErrMsg = "来源异常"
			br.Msg = "来源异常"
			return
		}
	}

	if productId != 0 {
		if req.Source == "add_custom" {
			//添加客户时新增联系人
		} else if req.Source == "pick_custom" {
			//领取客户时添加联系人
			tmpCompanyProduct := &company.CompanyProduct{
				CompanyId:    req.CompanyId,
				ProductId:    productId,
				ProductName:  sysUser.RoleName,
				SellerId:     sysUser.AdminId,
				SellerName:   sysUser.RealName,
				GroupId:      sysUser.GroupId,
				DepartmentId: sysUser.DepartmentId,
			}
			companyProductList = append(companyProductList, tmpCompanyProduct)
		} else if req.Source == "add_user" {
			shareSellerId := 0
			if req.CompanyId > 0 {
				item, e := company.GetCompanyProductByCompanyIdAndProductId(req.CompanyId, productId)
				if e != nil {
					br.Msg = "客户信息有误"
					br.ErrMsg = "获取客户信息失败, Err: " + e.Error()
					return
				}
				shareSellerId = item.ShareSellerId
			}
			//获取当前操作员产品权限
			tmpCompanyProductList, productErr := getSysCompanyProductList(productId, req.CompanyId)
			if productErr != nil {
				br.Msg = "新增失败"
				br.ErrMsg = "新增失败，获取当前操作员产品权限异常,Err:" + productErr.Error()
				return
			}
			if tmpCompanyProductList == nil {
				br.Msg = "新增失败"
				br.ErrMsg = "新增失败，获取当前操作员找不到产品权限"
				return
			}
			companyProductList = tmpCompanyProductList

			//操作权限校验
			for _, v := range tmpCompanyProductList {
				companyUserStatus := services.CheckCompanyUserButton(sysUser.RoleTypeCode, v.SellerId, sysUser.AdminId, v.ProductId, shareSellerId, v.Status)
				if companyUserStatus == false {
					br.Msg = "没有操作权限"
					br.ErrMsg = "没有操作权限"
					br.IsSendEmail = false
					return
				}
			}
		}
	} else {
		//超管
		if req.Source != "add_custom" {
			//不是添加客户的时候添加的联系人
			tmpCompanyProductList, productErr := getSysCompanyProductList(productId, req.CompanyId)
			if productErr != nil {
				br.Msg = "新增失败"
				br.ErrMsg = "新增失败，获取当前操作员产品权限异常,Err:" + productErr.Error()
				return
			}
			if tmpCompanyProductList == nil {
				br.Msg = "新增失败"
				br.ErrMsg = "新增失败，获取当前操作员找不到产品权限"
				return
			}
			companyProductList = tmpCompanyProductList
		}
	}

	userCount, err := company.GetCompanyUserCount(req.CompanyId)
	if err != nil {
		br.Msg = "新增失败"
		br.ErrMsg = "判断联系人数量失败,Err:" + err.Error()
		return
	}

	if userCount == 0 {
		if req.BusinessCardUrl == "" {
			br.Msg = "请上传名片"
			br.IsSendEmail = false
			return
		}
	}

	//systemUser models.Company.CompanyUser
	//var sysemUser company.CompanyUser
	//校验主手机号
	if req.MobileOne != "" {
		mobileOneItem, err := company.GetUserCountByMobile(req.MobileOne)
		if err != nil && err.Error() == utils.ErrNoRow() {
			mobileOneItem, err = company.CheckCompanyUserCountByMobileTwo(req.MobileOne)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "新增失败"
				br.ErrMsg = "判断手机号1是否存在,Err:" + err.Error()
				return
			}
		}

		if mobileOneItem != nil {
			if mobileOneItem.UserId > 0 {
				//如果有传入客户编号，且客户编号与该查出来的用户编号一致的情况下
				if req.CompanyId > 0 {
					//获取联系人分组信息
					userSellerGroupInfo, err := models.GetUserGroupSellerByUserId(int(mobileOneItem.UserId))
					if err != nil && err.Error() != utils.ErrNoRow() {
						br.Msg = "查询信息异常"
						br.Success = true
						br.Data = mobileOneItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}

					if req.CompanyId == mobileOneItem.CompanyId {
						//如果是该客户下的用户，那么判断该用户与当前账号是否存在关系，如果没有关系，那么直接添加关系后直接返回
						if len(companyProductList) > 0 {
							isHas := checkUserSellerRelation(companyProductList, mobileOneItem, &req, br)
							if isHas == false {
								return
							}
						}

						//修改返回给前端用户的信息
						if userSellerGroupInfo != nil {
							mobileOneItem.SellerRealName = userSellerGroupInfo.SellerRealName
							mobileOneItem.Status = userSellerGroupInfo.Status
						}

						br.Msg = "手机号1已存在"
						br.Success = true
						br.Data = mobileOneItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					} else {
						hasMove := true //是否可移动

						//如果是大于 1 的客户，那么就是非潜在客户，需要去查询对应的销售
						if mobileOneItem.CompanyId > 1 {
							//获取联系人分组信息
							userSellerGroupInfoList, err := models.GetUserGroupSellersByUserId(int(mobileOneItem.UserId))

							//根据分组校验
							if err == nil && len(userSellerGroupInfoList) > 0 {
								sellerMap := make(map[int]string)    //销售信息map
								sellerNameSlice := make([]string, 0) //销售姓名切片
								statusNameSlice := make([]string, 0) //客户状态姓名切片
								for _, v := range userSellerGroupInfoList {
									if v.Status != utils.COMPANY_STATUS_LOSE && v.Status != utils.COMPANY_STATUS_FOREVER && hasMove == true {
										hasMove = false
									}
									statusNameSlice = append(statusNameSlice, v.Status)
									if _, ok := sellerMap[v.SellerId]; ok {
										continue
									}
									sellerMap[v.SellerId] = v.SellerRealName
									sellerNameSlice = append(sellerNameSlice, v.SellerRealName)
								}
								mobileOneItem.SellerRealName = strings.Join(sellerNameSlice, "/")
								mobileOneItem.Status = strings.Join(statusNameSlice, "/")
							}
						}

						//是否可移动
						mobileOneItem.HasMove = hasMove

						br.Msg = "手机号1已存在"
						br.Success = true
						br.Data = mobileOneItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}
				} else {
					if strings.Contains(mobileOneItem.Status, "/") {
						if strings.Contains(mobileOneItem.Status, "正式") || strings.Contains(mobileOneItem.Status, "试用") {
							mobileOneItem.HasMove = false
						} else {
							mobileOneItem.HasMove = true
						}
					} else {
						if mobileOneItem.Status == utils.COMPANY_STATUS_FREEZE || //冻结
							mobileOneItem.Status == utils.COMPANY_STATUS_LOSE || //流失
							mobileOneItem.Status == utils.COMPANY_STATUS_POTENTIAL || //潜在
							mobileOneItem.Status == utils.COMPANY_STATUS_FOREVER { //永续
							mobileOneItem.HasMove = true
						}
					}
					br.Msg = "手机号1已存在"
					br.Success = true
					br.Data = mobileOneItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				}
			}
		}
	}

	if req.Email != "" {
		emailItem, err := company.CheckCompanyUserCountByEmail(req.Email)
		if err != nil && err.Error() != utils.ErrNoRow() {
			br.Msg = "新增失败"
			br.ErrMsg = "新增失败,Err:" + err.Error()
			return
		}

		if emailItem != nil {
			if emailItem.UserId > 0 {
				if req.CompanyId > 0 {
					//获取联系人分组信息
					userSellerGroupInfo, err := models.GetUserGroupSellerByUserId(int(emailItem.UserId))
					if err != nil && err.Error() != utils.ErrNoRow() {
						br.Msg = "查询信息异常"
						br.Success = true
						br.Data = emailItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}
					if req.CompanyId == emailItem.CompanyId {
						//如果是该客户下的用户，那么判断该用户与当前账号是否存在关系，如果没有关系，那么直接添加关系后直接返回
						if len(companyProductList) > 0 {
							isHas := checkUserSellerRelation(companyProductList, emailItem, &req, br)
							if isHas == false {
								return
							}
						}

						//修改返回给前端用户的信息
						if userSellerGroupInfo != nil {
							emailItem.SellerRealName = userSellerGroupInfo.SellerRealName
							emailItem.Status = userSellerGroupInfo.Status
						}

						br.Msg = "邮箱已存在"
						br.Success = true
						br.Data = emailItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					} else {
						hasMove := true //是否可移动

						//如果是大于 1 的客户，那么就是非潜在客户，需要去查询对应的销售
						if emailItem.CompanyId > 1 {
							//获取联系人分组信息
							userSellerGroupInfoList, err := models.GetUserGroupSellersByUserId(int(emailItem.UserId))

							//根据分组校验
							if err == nil && len(userSellerGroupInfoList) > 0 {
								sellerMap := make(map[int]string)    //销售信息map
								sellerNameSlice := make([]string, 0) //销售姓名切片
								statusNameSlice := make([]string, 0) //客户状态姓名切片
								for _, v := range userSellerGroupInfoList {
									if v.Status != utils.COMPANY_STATUS_LOSE && v.Status != utils.COMPANY_STATUS_FOREVER && hasMove == true {
										hasMove = false
									}
									statusNameSlice = append(statusNameSlice, v.Status)
									if _, ok := sellerMap[v.SellerId]; ok {
										continue
									}
									sellerMap[v.SellerId] = v.SellerRealName
									sellerNameSlice = append(sellerNameSlice, v.SellerRealName)
								}
								emailItem.SellerRealName = strings.Join(sellerNameSlice, "/")
								emailItem.Status = strings.Join(statusNameSlice, "/")
							}
						}
						//是否可移动
						emailItem.HasMove = hasMove

						br.Msg = "邮箱已存在"
						br.Success = true
						br.Data = emailItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}
				} else {
					if strings.Contains(emailItem.Status, "/") {
						if strings.Contains(emailItem.Status, "正式") || strings.Contains(emailItem.Status, "试用") {
							emailItem.HasMove = false
						} else {
							emailItem.HasMove = true
						}
					} else {
						if emailItem.Status == utils.COMPANY_STATUS_FREEZE || //冻结
							emailItem.Status == utils.COMPANY_STATUS_LOSE || //流失
							emailItem.Status == utils.COMPANY_STATUS_POTENTIAL || //潜在
							emailItem.Status == utils.COMPANY_STATUS_FOREVER { //永续
							emailItem.HasMove = true
						}
					}
					br.Msg = "邮箱已存在"
					br.Success = true
					br.Data = emailItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				}
			}
		}
	}

	//if req.BusinessCardUrl != "" && utils.RunMode == "release" {
	if req.BusinessCardUrl != "" {
		// 获取图片识别客户名称的配置
		crmConfig, err := company.GetConfigDetailByCode("card_recognition_company_name")
		if err != nil {
			br.Msg = "获取配置失败"
			br.ErrMsg = "获取配置失败"
			br.IsSendEmail = false
			return
		}
		// 获取图片识别手机号的配置
		crmConfig2, err := company.GetConfigDetailByCode("card_recognition_tel")
		if err != nil {
			br.Msg = "获取配置失败"
			br.ErrMsg = "获取配置失败"
			br.IsSendEmail = false
			return
		}
		if crmConfig.ConfigValue == "true" || crmConfig2.ConfigValue == "true" {
			companyName := req.CompanyName
			if companyName == "" {
				companyInfo, err := company.GetCompanyById(req.CompanyId)
				if err != nil {
					br.Msg = "查找客户失败"
					br.ErrMsg = "查找客户失败,err:" + err.Error()
					return
				}
				companyName = companyInfo.CompanyName
			}
			companyName = utils.TrimStr(companyName)
			tmpCompanyNameList, err := elastic.Analyze(companyName)
			if err != nil {
				br.Msg = "添加失败"
				br.ErrMsg = "客户名称分词失败,Err:" + err.Error()
				return
			}
			//公司名称切片
			analyzeNameList := []string{companyName}
			for _, v := range tmpCompanyNameList {
				if v == "" {
					continue
				}
				ignoreStrs := []string{"", "有限", "投资", "资本", "管理", "贸易", "资产", "公司", "股份", "集团", "有限公司"}
				if !strings.Contains(strings.Join(ignoreStrs, ","), v) && utf8.RuneCount([]byte(v)) > 1 {
					//不在上面的过滤字里面，且切出来的字符大于1位
					analyzeNameList = append(analyzeNameList, v)
				}
			}

			//名片识别出来的客户名称切片
			companyNameSlice := make([]string, 0)
			card, err := services.GetBusinessCard(req.BusinessCardUrl)
			if err != nil {
				br.Msg = "名片识别失败"
				br.ErrMsg = "名片识别失败,Err:" + err.Error()
				return
			}
			//if card.Errno != 0 {
			//	br.Msg = "您上传了非名片图片，请重新上传"
			//	br.ErrMsg = "名片识别失败,ErrMsg:" + card.ErrorMsg + ";errCode:" + strconv.Itoa(card.Errno)
			//	return
			//}
			//var mobileStr string
			//for _, v := range card.WordsResult {
			//	mobileStr += v.Words + ","
			//}
			isFlag := false
			if len(card.WordsResult.MOBILE) > 0 {
				mobileStr := strings.Join(card.WordsResult.MOBILE, ",")
				//if req.MobileOne != "" {
				//	if strings.Contains(mobileStr, req.MobileOne) || mobileStr == "" {
				//		isFlag = true
				//	} else {
				//		isFlag = false
				//	}
				//}
				//
				//if isFlag == false && req.MobileTwo != "" {
				//	if strings.Contains(mobileStr, req.MobileTwo) {
				//		isFlag = true
				//	} else {
				//		isFlag = false
				//	}
				//}
				if req.MobileOne != "" && strings.Contains(mobileStr, req.MobileOne) {
					isFlag = true
				}
				if req.MobileTwo != "" && strings.Contains(mobileStr, req.MobileTwo) {
					isFlag = true
				}
				//如果百度识别出来了客户名称，那么将识别出来的客户名称添加到待校验客户名称切片中
				if len(card.WordsResult.COMPANY) > 0 && card.WordsResult.COMPANY[0] != "" {
					companyNameSlice = card.WordsResult.COMPANY
				}
			}
			//如果百度未识别出来手机号或者公司名称，那么进行阿里识别
			if !isFlag || (len(companyNameSlice) == 0 && crmConfig.ConfigValue == "true") {
				//阿里云识别
				aliyunResult, errMsg, err := services.AliyunOcrBusinessCard(req.BusinessCardUrl)
				if err != nil {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败,Err:" + err.Error()
					return
				}
				if !aliyunResult.Success {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败"
					return
				}
				if errMsg != "" {
					br.Msg = errMsg
					return
				}
				//如果百度没有识别出来手机号，那么还需要阿里识别出来的手机号校验下
				if !isFlag {
					if len(aliyunResult.TelCell) > 0 {
						mobileStr := strings.Join(aliyunResult.TelCell, ",")
						if req.MobileOne != "" {
							if strings.Contains(mobileStr, req.MobileOne) {
								isFlag = true
							} else {
								isFlag = false
							}
						}
					} else {
						isFlag = true
					}
				}
				//如果阿里云识别出来了客户名称，那么将识别出来的客户名称添加到待校验客户名称切片中
				if len(aliyunResult.Company) > 0 {
					companyNameSlice = append(companyNameSlice, aliyunResult.Company...)
				}
			}

			if !isFlag && crmConfig2.ConfigValue == "true" {
				br.Msg = "名片信息与联系人手机号不符"
				br.IsSendEmail = false
				return
			}

			//校验识别出来的名片名称与传入的客户名称是否一致
			if len(companyNameSlice) > 0 && crmConfig.ConfigValue == "true" {
				isCompanyNameFlag := false //是否成功匹配客户名称
				//遍历识别出来的客户名称，然后与系统的客户名称做匹配（识别出来的名称包含系统名称的话，那么标记成功匹配）
				for _, tmpCompanyName := range companyNameSlice {
					//空串不处理
					if companyName == "" {
						continue
					}
					for _, analyzeName := range analyzeNameList {
						//如果分词出来的公司名称正好在识别出来的公司名称里面，那么就认为校验通过了
						if strings.Contains(tmpCompanyName, analyzeName) {
							isCompanyNameFlag = true
							break
						}
					}

					if isCompanyNameFlag {
						break
					}

				}
				//如果没有匹配到客户名称，那么就返回报错
				if !isCompanyNameFlag {
					br.Msg = "名片信息与公司名称不符"
					br.IsSendEmail = false
					return
				}
			}
		}
	}
	user := new(models.WxUser)
	user.RealName = utils.TrimStr(req.RealName)
	user.Sex = req.Sex
	user.CountryCode = utils.TrimStr(req.CountryCode)
	user.Mobile = utils.TrimStr(req.MobileOne)
	user.OutboundCountryCode = utils.TrimStr(req.CountryCode)
	user.OutboundMobile = utils.TrimStr(req.MobileOne)
	user.MobileTwo = utils.TrimStr(req.MobileTwo)
	user.Email = utils.TrimStr(req.Email)
	user.Position = req.Position
	user.IsMaker = req.IsMaker
	user.BusinessCardUrl = req.BusinessCardUrl
	user.CompanyId = req.CompanyId
	if req.CompanyId == 0 {
		user.CompanyId = 1
	}
	user.DepartmentName = req.DepartmentName
	user.CreatedTime = time.Now()
	//user.RegisterTime = time.Now()
	user.RegisterPlatform = 3

	newId, err := models.AddWxUser(user)
	user.UserId = newId
	if err != nil {
		br.Msg = "新增失败"
		br.ErrMsg = "新增失败,Err:" + err.Error()
		return
	}
	//如果有传入企业编号，那么需要将该联系人与销售员做绑定
	if len(companyProductList) > 0 {
		for _, companyProduct := range companyProductList {
			models.AddUserSellerRelation(newId, companyProduct.CompanyId, companyProduct.SellerId, companyProduct.ProductId, companyProduct.SellerName, req.MobileOne, req.Email)
		}
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{req.CompanyId})

	//联系人信息
	userInfo, _ := json.Marshal(user)
	go services.AddWxUserOpLog(company.WxUserOpLog{
		LogType:                "add",
		UserId:                 int(user.UserId),
		CompanyId:              user.CompanyId,
		Mobile:                 user.Mobile,
		Email:                  user.Email,
		OriginalUserInfo:       "",
		UserInfo:               string(userInfo),
		OriginalUserSellerInfo: "",
		UserSellerInfo:         "",
		OpUserId:               sysUser.AdminId,
		OpUserName:             sysUser.RealName,
		CreateTime:             time.Now(),
	})

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

// 获取当前操作员产品权限（所有产品数据）
func getSysCompanyProductList(productId, companyId int) (companyProduct []*company.CompanyProduct, err error) {
	if productId == 0 {
		tmpCompanyProduct, productErr := company.GetCompanyProductByCompanyIdAndProductId(companyId, 1)
		if productErr != nil && productErr.Error() != utils.ErrNoRow() {
			//sql异常
			err = productErr
			return
		}
		if tmpCompanyProduct != nil {
			companyProduct = append(companyProduct, tmpCompanyProduct)
		}

		tmpCompanyProduct, productErr = company.GetCompanyProductByCompanyIdAndProductId(companyId, 2)
		if productErr != nil && productErr.Error() != utils.ErrNoRow() {
			//sql异常
			err = productErr
			return
		}
		if tmpCompanyProduct != nil {
			companyProduct = append(companyProduct, tmpCompanyProduct)
		}
	} else {
		tmpCompanyProduct, productErr := company.GetCompanyProductByCompanyIdAndProductId(companyId, productId)
		if productErr != nil && productErr.Error() != utils.ErrNoRow() {
			//sql异常
			err = productErr
			return
		}
		if tmpCompanyProduct != nil {
			companyProduct = append(companyProduct, tmpCompanyProduct)
		}
	}
	return
}

// 校验用户与销售信息
func checkUserSellerRelation(companyProductList []*company.CompanyProduct, companyUser *company.CompanyUser, req *company.AddUserReq, br *models.BaseResponse) (isHas bool) {
	for _, companyProduct := range companyProductList {
		_, relationErr := models.GetUserSellerRelation(companyUser.UserId, companyProduct.SellerId)

		//找到数据了
		if relationErr == nil {
			isHas = true
			continue
		}

		//没找到数据，不存在关系
		//如果不存在关系，那么直接添加关系就好了，其他操作不做
		if relationErr.Error() == utils.ErrNoRow() {
			//添加用户与联系人的关系
			models.AddUserSellerRelation(companyUser.UserId, companyProduct.CompanyId, companyProduct.SellerId, companyProduct.ProductId, companyProduct.SellerName, companyUser.Mobile, companyUser.Email)
		} else {
			//sql异常
			br.Msg = "新增失败"
			br.ErrMsg = "判断手机号或邮箱是否存在关联关系,Err:" + relationErr.Error()
			return
		}

		//对老数据做字段数据新增处理，如果该字段已有数据则不做处理start
		{
			mobileOne := companyUser.Mobile
			mobileTwo := companyUser.MobileTwo
			email := companyUser.Email
			businessCardUrl := companyUser.BusinessCardUrl

			if req.MobileOne != "" && companyUser.Mobile == "" {
				mobileOne = utils.TrimStr(req.MobileOne)
			}
			if req.MobileTwo != "" && companyUser.MobileTwo == "" {
				mobileTwo = utils.TrimStr(req.MobileTwo)
			}
			if req.Email != "" && companyUser.Email == "" {
				email = utils.TrimStr(req.Email)
			}
			if req.BusinessCardUrl != "" && companyUser.BusinessCardUrl == "" {
				businessCardUrl = strings.Replace(req.BusinessCardUrl, " ", "", -1)
			}
			_ = company.EditCompanyUserContact(companyUser.UserId, mobileOne, mobileTwo, email, businessCardUrl)
		}
		//对老数据做字段数据新增处理，如果该字段已有数据则不做处理start

		br.Ret = 200
		br.Success = true
		br.Msg = "新增成功"
		br.Data = companyUser.UserId
		return
	}
	return
}

// 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 *CompanyUserController) 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")
	companyId, _ := this.GetInt("CompanyId")
	keyWord := utils.TrimStr(this.GetString("KeyWord"))
	productType, _ := this.GetInt("ProductType")
	ybProductId, _ := this.GetInt("ProductId")
	isSubscribe, _ := this.GetInt("IsSubscribe", -1)
	isSubscribeHzyj, _ := this.GetInt("IsSubscribeHzyj", -1)
	isSubscribeCygx, _ := this.GetInt("IsSubscribeCygx", -1)

	// 默认是问答社区
	if productType <= 0 {
		productType = 3
	}

	if companyId <= 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 (a.real_name LIKE '%` + keyWord + `%' OR a.mobile LIKE '%` + keyWord + `%' OR a.email LIKE '%` + keyWord + `%') `
	}
	// 是否关注公众号
	if isSubscribe == 0 {
		condition += ` AND (c.subscribe = 0 OR ISNULL(c.subscribe)) `
	}
	if isSubscribe == 1 {
		condition += ` AND c.subscribe = 1 `
	}

	// 是否关注弘则研究公众号
	if isSubscribeHzyj == 0 {
		condition += ` AND (c.subscribe = 0 OR ISNULL(c.subscribe)) `
	}
	if isSubscribeHzyj == 1 {
		condition += ` AND c.subscribe = 1 `
	}

	// 是否关注弘则研究公众号
	if isSubscribeCygx == 0 {
		condition += ` AND (a.cygx_subscribe = 0 OR ISNULL(a.cygx_subscribe)) `
	}
	if isSubscribeCygx == 1 {
		condition += ` AND a.cygx_subscribe = 1 `
	}

	//非管理员，那么只能看到该产品下的联系人
	if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
		productId := services.GetProductId(sysUser.RoleTypeCode)
		condition += ` AND b.product_id = ? `
		pars = append(pars, productId)

		//流失客户（除非是超级管理员或者是部门管理员，要不然不允许看对应的联系人）
		//var companyProduct *company.CompanyProduct
		//当前是ficc权限，且非ficc管理员
		//if productId == 1 && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_FICC_ADMIN {
		//	tmpCompanyProduct, _ := company.GetCompanyProductByCompanyIdAndProductId(companyId, 1)
		//	companyProduct = tmpCompanyProduct
		//}

		//权益销售查看流失客户时，可以看到非本人名下流失客户的联系人需求池 930 2024-03-25
		//if productId == 2 && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_ADMIN {
		//	// 当前是权益权限，且非 权益管理员
		//	tmpCompanyProduct, _ := company.GetCompanyProductByCompanyIdAndProductId(companyId, 2)
		//	companyProduct = tmpCompanyProduct
		//	if companyProduct != nil && companyProduct.Status == utils.COMPANY_STATUS_LOSE {
		//		condition += ` AND seller_id=? `
		//		pars = append(pars, sysUser.AdminId)
		//	}
		//}
	}

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

	list, err := company.GetCompanyUserListV2(condition, pars, companyId, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}

	//获取企业客户信息
	companyInfo, err := company.GetCompanyById(companyId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取客户信息失败，Err:" + err.Error()
		return
	}

	lenList := len(list)
	if lenList > 0 {
		userIdSlice := make([]string, 0)
		mobilesSlice := make([]string, 0)
		emailsSlice := make([]string, 0)
		userIds := make([]int, 0)
		for _, v := range list {
			userIdSlice = append(userIdSlice, strconv.Itoa(int(v.UserId)))
			userIds = append(userIds, int(v.UserId))
			if v.Mobile != "" {
				mobilesSlice = append(mobilesSlice, v.Mobile)
			} else if v.Email != "" {
				emailsSlice = append(emailsSlice, v.Email)
			}
		}

		//用户浏览数据
		userIdStr := strings.Join(userIdSlice, ",")
		mobileStr := strings.Join(mobilesSlice, "','")
		mobileStr = "'" + mobileStr + "'"
		emailStr := strings.Join(emailsSlice, "','")
		emailStr = "'" + emailStr + "'"

		//userViewTotalList, _ := models.GetCountUserViewHistoryByUserIds(userIdStr)
		//userViewTotalMap := make(map[int]*models.UserViewTotalSlice)
		//for _, userView := range userViewTotalList {
		//	userViewTotalMap[userView.UserId] = userView
		//}

		//用户日评浏览数据
		//userReportViewTotalList, _ := models.GetReportViewMaxTimeByUserIds(userIdStr)
		//userReportViewTotalMap := make(map[int]*models.ReportViewRecord)
		//for _, userReportView := range userReportViewTotalList {
		//	userReportViewTotalMap[userReportView.UserId] = userReportView
		//}

		//报告统计删除晨报部分统计加入每日资讯 2021-4-9
		////手机号
		//userViewMobileTotalMap := make(map[string]*models.UserViewMobileTotalSlice)
		//userReportViewMobileTotalMap := make(map[string]*models.ReportViewMobileRecord)
		//userAdvisoryViewMobileTotalMap := make(map[string]*advisory.UserViewMobileTotalSlice)
		//userCygxArticleHistoryRecordViewMobileTotalMap := make(map[string]*models.UserViewMobileTotalSlice)
		//if len(mobilesSlice) > 0 {
		//	//用户浏览数据
		//	userViewMobileTotalList, _ := models.GetCountUserViewHistoryByMobiles(mobileStr)
		//	for _, userViewMobile := range userViewMobileTotalList {
		//		userViewMobileTotalMap[userViewMobile.Mobile] = userViewMobile
		//	}
		//
		//	//每日点评手机号数据
		//	userReportViewMobileTotalList, _ := models.GetReportViewMaxTimeByMobiles(mobileStr)
		//	for _, userReportViewMobile := range userReportViewMobileTotalList {
		//		userReportViewMobileTotalMap[userReportViewMobile.Mobile] = userReportViewMobile
		//	}
		//
		//	//每日资讯
		//	userAdvisoryViewMobileTotalList, _ := advisory.GetCountUserViewHistoryByMobiles(mobileStr)
		//	//fmt.Println(userAdvisoryViewMobileTotalList)
		//	for _, userAdvisoryViewMobile := range userAdvisoryViewMobileTotalList {
		//		userAdvisoryViewMobileTotalMap[userAdvisoryViewMobile.Mobile] = userAdvisoryViewMobile
		//	}
		//	//查研观向
		//	userCygxArticleHistoryRecordViewMobileTotalList, _ := models.GetCountCygxArticleHistoryRecordByMobiles(mobileStr)
		//	for _, userCygxArticleHistoryRecordViewMobile := range userCygxArticleHistoryRecordViewMobileTotalList {
		//		userCygxArticleHistoryRecordViewMobileTotalMap[userCygxArticleHistoryRecordViewMobile.Mobile] = userCygxArticleHistoryRecordViewMobile
		//	}
		//}

		////邮箱
		//userViewEmailTotalMap := make(map[string]*models.UserViewEmailTotalSlice)
		//userReportViewEmailTotalMap := make(map[string]*models.ReportViewEmailRecord)
		//userAdvisoryViewEmailTotalMap := make(map[string]*advisory.UserViewEmailTotalSlice)
		//userCygxViewEmailTotalMap := make(map[string]*models.UserViewEmailTotalSlice)
		//if len(emailsSlice) > 0 {
		//	//用户浏览数据
		//	userViewEmailTotalList, _ := models.GetCountUserViewHistoryByEmails(emailStr)
		//	for _, userViewEmail := range userViewEmailTotalList {
		//		userViewEmailTotalMap[userViewEmail.Email] = userViewEmail
		//	}
		//	//每日点评手机号数据
		//	userReportViewEmailTotalList, _ := models.GetReportViewMaxTimeByEmails(emailStr)
		//	for _, userReportViewEmail := range userReportViewEmailTotalList {
		//		userReportViewEmailTotalMap[userReportViewEmail.Email] = userReportViewEmail
		//	}
		//	//每日资讯
		//	userAdvisoryViewEmailTotalList, _ := advisory.GetCountUserViewHistoryByEmails(emailStr)
		//	for _, userAdvisoryViewEmail := range userAdvisoryViewEmailTotalList {
		//		userAdvisoryViewEmailTotalMap[userAdvisoryViewEmail.Email] = userAdvisoryViewEmail
		//	}
		//	//查研观向
		//	userCygxViewEmailTotalList, _ := models.GetCountCygxArticleHistoryRecordByEmails(emailStr)
		//	for _, userCygxReportViewEmail := range userCygxViewEmailTotalList {
		//		userCygxViewEmailTotalMap[userCygxReportViewEmail.Email] = userCygxReportViewEmail
		//	}
		//}

		//获取联系人关联产品的条数
		userSellerRelationTotalSlice, err := models.GetUserSellerRelationCountByUserIds(userIdStr)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取联系人与销售员信息失败，Err:" + err.Error()
			return
		}
		userSellerRelationTotalMap := make(map[int]*models.UserSellerRelationSlice)
		for _, userSellerRelationTotal := range userSellerRelationTotalSlice {
			userSellerRelationTotalMap[userSellerRelationTotal.UserId] = userSellerRelationTotal
		}
		userRecordRegisterMap := make(map[int]time.Time)
		if len(userIdSlice) > 0 {
			//用户绑定注册数据
			userRecordRegisterList, _ := models.GetUserRecordRegisterByUserIds(userIdStr)
			for _, userRecordRegister := range userRecordRegisterList {
				userRecordRegisterMap[userRecordRegister.UserId] = userRecordRegister.CreateTime
			}
		}

		// 用户图表权限设置信息
		userChartPermissionMap := make(map[int]*company_user.ChartClassifyPermission)
		userChartPermissionList, err := company_user.GetChartClassifyPermissionListByUserIds(userIdStr)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取联系人图表权限信息失败, Err:" + err.Error()
			return
		}
		for i := 0; i < len(userChartPermissionList); i++ {
			userChartPermissionMap[userChartPermissionList[i].UserId] = userChartPermissionList[i]
		}

		// 获取admin列表-匹配联系人是否为admin用户
		sysUserList, err := system.GetAdminList()
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取admin列表失败, Err:" + err.Error()
			return
		}
		sysUserMobileMap := make(map[string]int, 0)
		for i := 0; i < len(sysUserList); i++ {
			sysUserMobile := sysUserList[i].Mobile
			if sysUserMobile != "" {
				sysUserMobileMap[sysUserList[i].Mobile] = 1
			}
		}

		// 获取研报分产品统计
		//ybViewsList, e := yb.GetCompanyUserYbProductVisitCount(userIds)
		ybViewsList, e := yb.GetCompanyUserYbProductVisitCountByProductType(userIds, productType, ybProductId)
		if e != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取分产品阅读统计失败, Err:" + e.Error()
			return
		}
		userYbViewsMap := make(map[int]int)
		for _, v := range ybViewsList {
			userYbViewsMap[v.UserId] = v.VisitCount
		}
		userHaveMoveMap := services.GetWxUserHaveMoveMap(mobilesSlice) // 处理用户是否移动过按钮回显
		for i := 0; i < lenList; i++ {
			item := list[i]
			//企业名称
			list[i].CompanyName = companyInfo.CompanyName

			if item.OpenId != "" {
				list[i].IsRegister = true
			} else {
				if item.RegisterPlatform == 2 {
					if item.Mobile != "" || item.Email != "" {
						list[i].IsRegister = true
					}
				} else if item.RegisterTime != "" {
					list[i].IsRegister = true
				} else {
					list[i].IsRegister = false
				}
			}

			////手机号用户累计浏览次数
			//if userView, ok := userViewMobileTotalMap[item.Mobile]; ok {
			//	list[i].ViewTotal += userView.Total
			//	if userView.CreatedTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = userView.CreatedTime
			//		list[i].LastViewTimeStr = userView.CreatedTime.Format(utils.FormatDateTime)
			//	}
			//}
			////邮箱用户累计浏览次数
			//if userView, ok := userViewEmailTotalMap[item.Email]; ok {
			//	//总共浏览的报表数据需要调整为（手机号用户浏览晨报数+邮箱号用户浏览晨报数）
			//	list[i].ViewTotal += userView.Total
			//	if userView.CreatedTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = userView.CreatedTime
			//		list[i].LastViewTimeStr = userView.CreatedTime.Format(utils.FormatDateTime)
			//	}
			//}
			////如果存在手机号用户日评数据，那么需要做处理
			//if reportView, ok := userReportViewMobileTotalMap[item.Mobile]; ok {
			//	//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
			//	if reportView.LastViewTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = reportView.LastViewTime
			//		list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
			//	list[i].ViewTotal += reportView.ViewTotal
			//}
			////如果存在手机号用户日评数据，那么需要做处理
			//if reportView, ok := userReportViewEmailTotalMap[item.Email]; ok {
			//	//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
			//	if reportView.LastViewTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = reportView.LastViewTime
			//		list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
			//	list[i].ViewTotal += reportView.ViewTotal
			//}
			//
			////如果存在手机号用户每日资讯，那么需要做处理
			//if advisoryView, ok := userAdvisoryViewMobileTotalMap[item.Mobile]; ok {
			//	//fmt.Println("蝴蝶眨几次眼睛")
			//	//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
			//	if advisoryView.CreatedTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = advisoryView.CreatedTime
			//		list[i].LastViewTimeStr = advisoryView.CreatedTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数）
			//	list[i].ViewTotal += advisoryView.Total
			//}
			////如果存在邮箱号用户每日资讯，那么需要做处理
			//if advisoryView, ok := userAdvisoryViewEmailTotalMap[item.Email]; ok {
			//	//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
			//	if advisoryView.CreatedTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = advisoryView.CreatedTime
			//		list[i].LastViewTimeStr = advisoryView.CreatedTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数）
			//	list[i].ViewTotal += advisoryView.Total
			//}
			//
			////如果存在手机号用户查研观向，那么需要做处理
			//if cygxView, ok := userCygxArticleHistoryRecordViewMobileTotalMap[item.Mobile]; ok {
			//	//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
			//	if cygxView.CreatedTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = cygxView.CreatedTime
			//		list[i].LastViewTimeStr = cygxView.CreatedTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数+查研观向）
			//	list[i].ViewTotal += cygxView.Total
			//}
			////如果存在邮箱号用户查研观向，那么需要做处理
			//if cygxView, ok := userCygxViewEmailTotalMap[item.Email]; ok {
			//	//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
			//	if cygxView.CreatedTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = cygxView.CreatedTime
			//		list[i].LastViewTimeStr = cygxView.CreatedTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数+查研观向）
			//	list[i].ViewTotal += cygxView.Total
			//}
			///*if reportView, ok := userReportViewTotalMap[int(item.UserId)]; ok {
			//	//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
			//	if reportView.LastViewTime.After(list[i].LastViewTime) {
			//		list[i].LastViewTime = reportView.LastViewTime
			//		list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
			//	}
			//	//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
			//	list[i].ViewTotal += reportView.ViewTotal
			//}*/

			list[i].ViewTotal = list[i].FiccViewTotal + list[i].RaiViewTotal
			var tmpLastViewTime time.Time
			tmpLastViewTime = list[i].FiccLastViewTime

			if !list[i].RaiLastViewTime.IsZero() {
				if tmpLastViewTime.IsZero() || list[i].RaiLastViewTime.After(tmpLastViewTime) {
					tmpLastViewTime = list[i].RaiLastViewTime
				}
			}

			list[i].LastViewTime = tmpLastViewTime
			if !tmpLastViewTime.IsZero() {
				list[i].LastViewTimeStr = tmpLastViewTime.Format(utils.FormatDateTime)
			}

			if list[i].LastViewTime.Before(time.Now().AddDate(0, 0, -7)) && list[i].IsFollow == 1 {
				list[i].NotRead = true
			}

			//如果有绑定数据，那么将数据返回对应的注册绑定数据
			if _, ok := userRecordRegisterMap[int(item.UserId)]; ok {
				list[i].IsRegister = true
				//list[i].RegisterTime = userRecordRegisterTime.Format(utils.FormatDateTime)
			}
			//是否共享联系人
			if userSellerRelationTotal, ok := userSellerRelationTotalMap[int(item.UserId)]; ok {
				//条数大于1，代表这是共享联系人
				//if userSellerRelationTotal.Total > 1 {
				//	list[i].IsShared = true
				//}
				list[i].ProductIds = userSellerRelationTotal.ProductIds
			}

			// 图表权限
			if _, isAdmin := sysUserMobileMap[list[i].Mobile]; isAdmin {
				list[i].IsChartPermissionSetting = 2
			} else {
				if _, ok := userChartPermissionMap[int(item.UserId)]; ok {
					list[i].IsChartPermissionSetting = 1
				}
			}
			// 分产品阅读统计
			list[i].YbProductViewTotal = userYbViewsMap[int(item.UserId)]
			//list[i].LastViewTimeStr = list[i].RaiLastViewTime.Format(utils.FormatDateTime)

			if item.Mobile != "" {
				list[i].HaveMoveButton = userHaveMoveMap[item.Mobile]
			}
		}

		isUserYanXuanButtonShow, err := services.CheckCompanyUserYanXuanButton(sysUser.RoleTypeCode, sysUser.Mobile)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取失败 CheckCompanyUserYanXuanButton ，Err:" + err.Error()
			return
		}

		if isUserYanXuanButtonShow {
			userYanxuanPermissionMap := cygxService.GetCygxUserYanxuanPermissionMapItem(userIds) // 如果是权益部门下的人，则展示研选相关的信息
			userInteractionNumMap := cygxService.GetUserInteractionNumMap(userIds)               // 如果是权益部门下的人，展示互动量相关的信息

			mfyxuserRecordRegisterMap := make(map[int]string)
			mfyxuserRecordRegisterTimeMap := make(map[int]time.Time)
			if len(userIdSlice) > 0 {
				//用户查研观向网页版注册时间
				clptuserRecordRegisterList, err := cygx.GetCygxClptSessionrByUserIdsMyfx(userIdStr)
				if err != nil {
					br.Msg = "获取失败"
					br.ErrMsg = "获取失败，GetCygxClptSessionrByUserIdsMyfx Err:" + err.Error()
					return
				}
				for _, userRecordRegister := range clptuserRecordRegisterList {
					mfyxuserRecordRegisterTimeMap[userRecordRegister.UserId] = userRecordRegister.CreateTime
					mfyxuserRecordRegisterMap[userRecordRegister.UserId] = userRecordRegister.CreateTime.Format(utils.FormatDateTime)
				}

				//买方研选网页版注册时间
				mfyxwebRecordRegisterList, err := cygx.GetCygxMfyxWebSessionByUserIdsMyfx(userIdStr)
				if err != nil {
					br.Msg = "获取失败"
					br.ErrMsg = "获取失败，GetCygxMfyxWebSessionByUserIdsMyfx Err:" + err.Error()
					return
				}
				for _, userRecordRegister := range mfyxwebRecordRegisterList {
					//如果注册时间早于查研观向网页版的，或者没有注册，就用这里的时间替换
					if userRecordRegister.CreateTime.Before(mfyxuserRecordRegisterTimeMap[userRecordRegister.UserId]) || mfyxuserRecordRegisterMap[userRecordRegister.UserId] == "" {
						mfyxuserRecordRegisterTimeMap[userRecordRegister.UserId] = userRecordRegister.CreateTime
						mfyxuserRecordRegisterMap[userRecordRegister.UserId] = userRecordRegister.CreateTime.Format(utils.FormatDateTime)
					}
				}

				mfyxuserRecordRegisterList, err := models.GetUserRecordRegisterByUserIdsMyfx(userIdStr)
				if err != nil {
					br.Msg = "获取失败"
					br.ErrMsg = "获取失败 GetUserRecordRegisterByUserIdsMyfx ，Err:" + err.Error()
					return
				}
				for _, userRecordRegister := range mfyxuserRecordRegisterList {
					//如果注册时间早于网页版的，或者网页版没有注册，就用这里的时间替换
					if userRecordRegister.CreateTime.Before(mfyxuserRecordRegisterTimeMap[userRecordRegister.UserId]) || mfyxuserRecordRegisterMap[userRecordRegister.UserId] == "" {
						mfyxuserRecordRegisterMap[userRecordRegister.UserId] = userRecordRegister.CreateTime.Format(utils.FormatDateTime)
					}
				}
			}

			for i := 0; i < lenList; i++ {
				item := list[i]
				// 分产品阅读统计
				//list[i].YbProductViewTotal = userYbViewsMap[int(item.UserId)]
				list[i].MfyxInteractionNum = userInteractionNumMap[int(item.UserId)]
				//权益销售查看用户研选的信息
				if userYanxuanPermissionMap[int(item.UserId)] != nil {
					mfyxItem := userYanxuanPermissionMap[int(item.UserId)]
					list[i].MfyxStatus = mfyxItem.Status
					list[i].MfyxStartDate = mfyxItem.StartDate
					list[i].MfyxEndDate = mfyxItem.EndDate
				} else {
					list[i].MfyxStatus = "未开通"
				}
				if mfyxuserRecordRegisterMap[int(item.UserId)] != "" {
					list[i].MfyxIsBinding = true
					list[i].MfyxBindingTime = mfyxuserRecordRegisterMap[int(item.UserId)]
				}
				//list[i].LastViewTimeStr = list[i].RaiLastViewTime.Format(utils.FormatDateTime)
			}
		}
	}

	page := paging.GetPaging(currentIndex, pageSize, total)
	resp := new(company.CompanyUserListResp)
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

func (this *CompanyUserController) List2() {
	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")
	companyId, _ := this.GetInt("CompanyId")
	keyWord := this.GetString("KeyWord")

	if companyId <= 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 (a.real_name LIKE '%` + keyWord + `%' OR a.mobile LIKE '%` + keyWord + `%' OR a.email LIKE '%` + keyWord + `%') `
	}

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

	list, err := company.GetCompanyUserList(condition, pars, companyId, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}

	lenList := len(list)
	for i := 0; i < lenList; i++ {
		item := list[i]
		if item.OpenId != "" {
			list[i].IsRegister = true
		} else {
			if item.RegisterPlatform == 2 {
				if item.Mobile != "" || item.Email != "" {
					list[i].IsRegister = true
				}
			} else {
				list[i].IsRegister = false
			}
		}
		reportView, err := models.GetReportViewMaxTime(int(item.UserId))
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取GetReportViewMaxTime失败，Err:" + err.Error()
			return
		}
		if reportView.LastViewTime.After(list[i].LastViewTime) {
			list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
		} else {
			list[i].LastViewTimeStr = list[i].LastViewTime.Format(utils.FormatDateTime)
		}
		list[i].ViewTotal += reportView.ViewTotal
	}
	page := paging.GetPaging(currentIndex, pageSize, total)
	resp := new(company.CompanyUserListResp)
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 获取客户名下联系人数量（根据当前账号角色区分）
// @Description 获取客户名下联系人数量（根据当前账号角色区分）接口
// @Param   CompanyId   query   int  true       "客户id"
// @Param   ProductId   query   int  true       "产品权限id"
// @Success 200 {object} company.CompanyUserTotal
// @router /company_user/total [get]
func (this *CompanyUserController) GetUserCountByCompanyId() {
	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
	}
	companyId, _ := this.GetInt("CompanyId")
	if companyId <= 0 {
		br.Msg = "参数错误"
		return
	}
	productId, _ := this.GetInt("ProductId")
	//如果没有传入，那么去根据权限来获取id
	if productId <= 0 {
		productId = services.GetProductId(sysUser.RoleTypeCode)
	}

	total, err := services.GetUserCountByCompanyId(companyId, productId)
	if err != nil {
		br.Msg = "获取失败"
		br.Msg = "获取联系人总数失败,Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = company.CompanyUserTotal{
		Total: total,
	}
}

// @Title 删除客户联系人
// @Description 删除客户联系人接口
// @Param	request	body company.DeleteUserReq true "type json string"
// @router /user/delete [post]
func (this *CompanyUserController) 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 company.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.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.Msg = "获取联系人异常！"
		br.ErrMsg = "获取联系人异常，Err:" + err.Error()
		return
	}
	//产品权限
	productId := services.GetProductId(sysUser.RoleTypeCode)

	//操作权限校验
	errMsg, err := checkOpCompanyUserByUserId(req.UserId, productId, sysUser.AdminId, sysUser.RoleTypeCode)
	if err != nil {
		br.Msg = "删除失败！" + errMsg
		br.ErrMsg = "删除失败，Err:" + err.Error()
		return
	}

	userRelationList := make([]*models.UserSellerRelation, 0)
	//如果不是超管权限，那么删除的时候，需要获取下联系人归属销售信息
	if productId != 0 {
		tmpUserRelationList, err := models.GetUserSellerRelationList(req.UserId)
		if err != nil {
			br.Msg = "删除失败"
			br.ErrMsg = "获取数据总数失败，Err:" + err.Error()
			return
		}
		if len(tmpUserRelationList) > 0 {
			userRelationList = append(userRelationList, tmpUserRelationList...)
		}
	}
	//联系人与销售的关系
	userSellerRelationList, err := models.GetUserSellerRelationList(int(userInfo.UserId))
	if err != nil {
		return
	}
	userSellerRelationInfo, _ := json.Marshal(userSellerRelationList)

	//删除所有的标识，并真正删除数据
	_ = models.DeleteUserSellerRelationByProductId(req.UserId, 1)
	_ = models.DeleteUserSellerRelationByProductId(req.UserId, 2)
	//真正删除用户
	err = services.DeleteWxUser(req.UserId)
	if err != nil {
		br.Msg = "删除失败！"
		br.ErrMsg = "删除失败，Err:" + err.Error()
		return
	}

	if len(userRelationList) > 0 {
		companyInfo, err := company.GetCompanyById(userRelationList[0].CompanyId)
		if err != nil {
			return
		}
		content := fmt.Sprint("联系人:", userInfo.RealName, "被删除")
		if companyInfo != nil {
			content = fmt.Sprint(companyInfo.CompanyName, "：", content)
		}
		for _, userRelation := range userRelationList {
			if userRelation.ProductId != productId {
				go services.AddCompanyMessage(sysUser.AdminId, userRelation.SellerId, userRelation.CompanyId, 0, 1, companyInfo.CompanyName, content, content)
			}

		}
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{userInfo.CompanyId})

	//联系人信息
	originalUserInfo, _ := json.Marshal(userInfo)
	go services.AddWxUserOpLog(company.WxUserOpLog{
		LogType:                "delete",
		UserId:                 int(userInfo.UserId),
		CompanyId:              userInfo.CompanyId,
		Mobile:                 userInfo.Mobile,
		Email:                  userInfo.Email,
		OriginalUserInfo:       string(originalUserInfo),
		UserInfo:               "",
		OriginalUserSellerInfo: string(userSellerRelationInfo),
		UserSellerInfo:         "",
		OpUserId:               sysUser.AdminId,
		OpUserName:             sysUser.RealName,
		CreateTime:             time.Now(),
	})

	// 若该联系人为弘则研究公司下的，则同步禁用手机号关联的系统管理员
	if userInfo.CompanyId == 16 {
		go services.ForbiddenSysUserByMobile(userInfo.Mobile)
	}

	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 *CompanyUserController) 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 company.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.MobileOne = utils.TrimStr(req.MobileOne)
	req.MobileTwo = utils.TrimStr(req.MobileTwo)
	req.Email = utils.TrimStr(req.Email)
	req.RealName = utils.TrimStr(req.RealName)

	productId := services.GetProductId(sysUser.RoleTypeCode)

	//操作权限校验
	wxUser, err := models.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.ErrMsg = "获取信息失败，Err:" + err.Error()
		br.Msg = "获取信息失败"
		return
	}

	//获取当前操作员产品权限
	companyProductList, productErr := getSysCompanyProductList(productId, wxUser.CompanyId)
	if productErr != nil {
		br.Msg = "编辑失败！获取当前操作员产品权限异常"
		br.ErrMsg = "获取当前操作员产品权限异常，Err:" + productErr.Error()
		return
	}
	if companyProductList == nil {
		br.Msg = "编辑失败！获取当前操作员找不到产品权限"
		br.ErrMsg = "获取当前操作员找不到产品权限"
		return
	}

	//操作权限校验
	for _, v := range companyProductList {
		companyUserStatus := services.CheckCompanyUserButton(sysUser.RoleTypeCode, v.SellerId, sysUser.AdminId, v.ProductId, v.ShareSellerId, v.Status)
		if v.ShareSellerId == sysUser.AdminId {
			companyUserStatus = true
		}
		if companyUserStatus == false {
			br.Msg = "没有操作权限"
			br.ErrMsg = "没有操作权限"
			return
		}
	}

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

	oldWxUser := *wxUser //旧的联系人信息（赋值，而不是赋址）

	if req.MobileOne == "" && req.Email == "" {
		br.Msg = "请输入手机号或邮箱"
		return
	}

	//不是管理员的情况下：//手机号邮箱填写校验
	if productId != 0 {
		companyInfo, err := company.GetCompanyById(req.CompanyId)
		if err != nil {
			br.ErrMsg = "获取客户信息失败，Err:" + err.Error()
			br.Msg = "获取客户信息失败"
			return
		}

		for _, v := range companyProductList {
			//权益（海外）客户，需要有提示
			if v.ProductId == 2 && companyInfo.RegionType == "海外" {
				if req.MobileOne == "" {
					br.Msg = "请输入手机号"
				}
				if req.Email == "" {
					br.Msg = "请输入邮箱"
					br.ErrMsg = "请输入邮箱"
					return
				}
			}
		}
	}

	if req.MobileOne != "" && req.MobileOne != wxUser.Mobile {
		mobileOneItem, err := company.GetUserCountByMobile(req.MobileOne)
		if err != nil && err.Error() == utils.ErrNoRow() {
			mobileOneItem, err = company.CheckCompanyUserCountByMobileTwo(req.MobileOne)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "编辑失败"
				br.ErrMsg = "判断手机号是否存在,Err:" + err.Error()
				return
			}
		}

		if mobileOneItem != nil {
			if mobileOneItem.UserId > 0 {
				if req.CompanyId > 0 {
					//获取联系人分组信息
					userSellerGroupInfo, err := models.GetUserGroupSellerByUserId(int(mobileOneItem.UserId))
					if err != nil && err.Error() != utils.ErrNoRow() {
						br.Msg = "查询信息异常"
						br.Success = true
						br.Data = mobileOneItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}

					if req.CompanyId == mobileOneItem.CompanyId {

						//修改返回给前端用户的信息
						if userSellerGroupInfo != nil {
							mobileOneItem.SellerRealName = userSellerGroupInfo.SellerRealName
							mobileOneItem.Status = userSellerGroupInfo.Status
						}

						br.Msg = "手机号1已存在"
						br.Success = true
						br.Data = mobileOneItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					} else {
						hasMove := true //是否可移动

						//如果是大于 1 的客户，那么就是非潜在客户，需要去查询对应的销售
						if mobileOneItem.CompanyId > 1 {
							//获取联系人分组信息
							userSellerGroupInfoList, err := models.GetUserGroupSellersByUserId(int(mobileOneItem.UserId))

							//根据分组校验
							if err == nil && len(userSellerGroupInfoList) > 0 {
								sellerMap := make(map[int]string)    //销售信息map
								sellerNameSlice := make([]string, 0) //销售姓名切片
								statusNameSlice := make([]string, 0) //客户状态姓名切片
								for _, v := range userSellerGroupInfoList {
									if v.Status != utils.COMPANY_STATUS_LOSE && v.Status != utils.COMPANY_STATUS_FOREVER && hasMove == true {
										hasMove = false
									}
									statusNameSlice = append(statusNameSlice, v.Status)
									if _, ok := sellerMap[v.SellerId]; ok {
										continue
									}
									sellerMap[v.SellerId] = v.SellerRealName
									sellerNameSlice = append(sellerNameSlice, v.SellerRealName)
								}
								mobileOneItem.SellerRealName = strings.Join(sellerNameSlice, "/")
								mobileOneItem.Status = strings.Join(statusNameSlice, "/")
							}
						}
						//是否可移动
						mobileOneItem.HasMove = hasMove

						br.Msg = "手机号1已存在"
						br.Success = true
						br.Data = mobileOneItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}
				} else {
					if strings.Contains(mobileOneItem.Status, "/") {
						if strings.Contains(mobileOneItem.Status, "正式") || strings.Contains(mobileOneItem.Status, "试用") {
							mobileOneItem.HasMove = false
						} else {
							mobileOneItem.HasMove = true
						}
					} else {
						if mobileOneItem.Status == utils.COMPANY_STATUS_FREEZE || //冻结
							mobileOneItem.Status == utils.COMPANY_STATUS_LOSE || //流失
							mobileOneItem.Status == utils.COMPANY_STATUS_POTENTIAL || //潜在
							mobileOneItem.Status == utils.COMPANY_STATUS_FOREVER { //永续
							mobileOneItem.HasMove = true
						}
					}
					br.Msg = "手机号1已存在"
					br.Success = true
					br.Data = mobileOneItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				}
			}
		}
	}

	//手机号2校验（不需要修改，修改时间：2021年03月09日11:23:37）
	/*if req.MobileTwo != "" && req.MobileTwo != wxUser.MobileTwo {
		mobileTwoItem, err := company.GetUserCountByMobile(req.MobileTwo)
		if err != nil && err.Error() == utils.ErrNoRow() {
			mobileTwoItem, err = company.CheckCompanyUserCountByMobileTwo(req.MobileTwo)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "编辑失败"
				br.ErrMsg = "判断手机号2是否存在,Err:" + err.Error()
				return
			}
		}
		if mobileTwoItem != nil {
			if mobileTwoItem.UserId > 0 {
				if req.CompanyId > 0 {
					if req.CompanyId == mobileTwoItem.CompanyId {
						br.Msg = "手机号2已存在"
						br.Success = true
						br.Data = mobileTwoItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					} else {
						if strings.Contains(mobileTwoItem.Status, "/") {
							if strings.Contains(mobileTwoItem.Status, "正式") || strings.Contains(mobileTwoItem.Status, "试用") {
								mobileTwoItem.HasMove = false
							} else {
								mobileTwoItem.HasMove = true
							}
						} else {
							if mobileTwoItem.Status == utils.COMPANY_STATUS_FREEZE || //冻结
								mobileTwoItem.Status == utils.COMPANY_STATUS_LOSE || //流失
								mobileTwoItem.Status == utils.COMPANY_STATUS_POTENTIAL || //潜在
								mobileTwoItem.Status == utils.COMPANY_STATUS_FOREVER { //永续
								mobileTwoItem.HasMove = true
							}
						}
						br.Msg = "手机号2已存在"
						br.Success = true
						br.Data = mobileTwoItem
						br.IsSendEmail = false
						br.Ret = 600
						return
					}
				} else {
					if strings.Contains(mobileTwoItem.Status, "/") {
						if strings.Contains(mobileTwoItem.Status, "正式") || strings.Contains(mobileTwoItem.Status, "试用") {
							mobileTwoItem.HasMove = false
						} else {
							mobileTwoItem.HasMove = true
						}
					} else {
						if mobileTwoItem.Status == utils.COMPANY_STATUS_FREEZE || //冻结
							mobileTwoItem.Status == utils.COMPANY_STATUS_LOSE || //流失
							mobileTwoItem.Status == utils.COMPANY_STATUS_POTENTIAL || //潜在
							mobileTwoItem.Status == utils.COMPANY_STATUS_FOREVER { //永续
							mobileTwoItem.HasMove = true
						}
					}
					br.Msg = "手机号2已存在"
					br.Success = true
					br.Data = mobileTwoItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				}
			}
		}
	}*/

	if req.Email != "" && req.Email != wxUser.Email {
		emailItem, err := company.CheckCompanyUserCountByEmail(req.Email)
		if err != nil && err.Error() != utils.ErrNoRow() {
			br.Msg = "编辑失败"
			br.ErrMsg = "编辑失败,Err:" + err.Error()
			return
		}
		if emailItem != nil {
			if emailItem.UserId > 0 {
				//获取联系人分组信息
				userSellerGroupInfo, err := models.GetUserGroupSellerByUserId(int(emailItem.UserId))
				if err != nil && err.Error() != utils.ErrNoRow() {
					br.Msg = "查询信息异常"
					br.Success = true
					br.Data = emailItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				}

				if req.CompanyId == emailItem.CompanyId {
					//修改返回给前端用户的信息
					if userSellerGroupInfo != nil {
						emailItem.SellerRealName = userSellerGroupInfo.SellerRealName
						emailItem.Status = userSellerGroupInfo.Status
					}

					br.Msg = "邮箱已存在"
					br.Success = true
					br.Data = emailItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				} else {
					hasMove := true //是否可移动

					//如果是大于 1 的客户，那么就是非潜在客户，需要去查询对应的销售
					if emailItem.CompanyId > 1 {
						//获取联系人分组信息
						userSellerGroupInfoList, err := models.GetUserGroupSellersByUserId(int(emailItem.UserId))

						//根据分组校验
						if err == nil && len(userSellerGroupInfoList) > 0 {
							sellerMap := make(map[int]string)    //销售信息map
							sellerNameSlice := make([]string, 0) //销售姓名切片
							statusNameSlice := make([]string, 0) //客户状态姓名切片
							for _, v := range userSellerGroupInfoList {
								if v.Status != utils.COMPANY_STATUS_LOSE && v.Status != utils.COMPANY_STATUS_FOREVER && hasMove == true {
									hasMove = false
								}
								statusNameSlice = append(statusNameSlice, v.Status)
								if _, ok := sellerMap[v.SellerId]; ok {
									continue
								}
								sellerMap[v.SellerId] = v.SellerRealName
								sellerNameSlice = append(sellerNameSlice, v.SellerRealName)
							}
							emailItem.SellerRealName = strings.Join(sellerNameSlice, "/")
							emailItem.Status = strings.Join(statusNameSlice, "/")
						}
					}
					//是否可移动
					emailItem.HasMove = hasMove

					br.Msg = "邮箱已存在"
					br.Success = true
					br.Data = emailItem
					br.IsSendEmail = false
					br.Ret = 600
					return
				}
			} else {
				if strings.Contains(emailItem.Status, "/") {
					if strings.Contains(emailItem.Status, "正式") || strings.Contains(emailItem.Status, "试用") {
						emailItem.HasMove = false
					} else {
						emailItem.HasMove = true
					}
				} else {
					if emailItem.Status == utils.COMPANY_STATUS_FREEZE || //冻结
						emailItem.Status == utils.COMPANY_STATUS_LOSE || //流失
						emailItem.Status == utils.COMPANY_STATUS_POTENTIAL || //潜在
						emailItem.Status == utils.COMPANY_STATUS_FOREVER { //永续
						emailItem.HasMove = true
					}
				}
				br.Msg = "邮箱已存在"
				br.Success = true
				br.Data = emailItem
				br.IsSendEmail = false
				br.Ret = 600
				return
			}
		}
	}
	//if wxUser.BusinessCardUrl != req.BusinessCardUrl && utils.RunMode == "release" {

	if wxUser.BusinessCardUrl != req.BusinessCardUrl {
		// 获取图片识别客户名称的配置
		crmConfig, err := company.GetConfigDetailByCode("card_recognition_company_name")
		if err != nil {
			br.Msg = "获取配置失败"
			br.ErrMsg = "获取配置失败"
			br.IsSendEmail = false
			return
		}
		// 获取图片识别手机号的配置
		crmConfig2, err := company.GetConfigDetailByCode("card_recognition_tel")
		if err != nil {
			br.Msg = "获取配置失败"
			br.ErrMsg = "获取配置失败"
			br.IsSendEmail = false
			return
		}
		if crmConfig.ConfigValue == "true" || crmConfig2.ConfigValue == "true" {
			//companyName := wxUser.CompanyName
			//if companyName == "" {
			companyInfo, err := company.GetCompanyById(req.CompanyId)
			if err != nil {
				br.Msg = "查找客户失败"
				br.ErrMsg = "查找客户失败,err:" + err.Error()
				return
			}
			companyName := companyInfo.CompanyName
			//}
			companyName = utils.TrimStr(companyName)
			tmpCompanyNameList, err := elastic.Analyze(companyName)
			if err != nil {
				br.Msg = "添加失败"
				br.ErrMsg = "客户名称分词失败,Err:" + err.Error()
				return
			}
			//公司名称切片
			analyzeNameList := []string{companyName}
			for _, v := range tmpCompanyNameList {
				if v == "" {
					continue
				}
				ignoreStrs := []string{"", "有限", "投资", "资本", "管理", "贸易", "资产", "公司", "股份", "集团", "有限公司"}
				if !strings.Contains(strings.Join(ignoreStrs, ","), v) && utf8.RuneCount([]byte(v)) > 1 {
					//不在上面的过滤字里面，且切出来的字符大于1位
					analyzeNameList = append(analyzeNameList, v)
				}
			}

			//名片识别出来的客户名称切片
			companyNameSlice := make([]string, 0)
			card, err := services.GetBusinessCard(req.BusinessCardUrl)
			if err != nil {
				br.Msg = "名片识别失败"
				br.ErrMsg = "名片识别失败,Err:" + err.Error()
				return
			}
			//if card.Errno != 0 {
			//	br.Msg = "您上传了非名片图片，请重新上传"
			//	br.ErrMsg = "名片识别失败,ErrMsg:" + card.ErrorMsg + ";errCode:" + strconv.Itoa(card.Errno)
			//	return
			//}
			//var mobileStr string
			//for _, v := range card.WordsResult {
			//	mobileStr += v.Words + ","
			//}
			isFlag := false
			if len(card.WordsResult.MOBILE) > 0 {
				mobileStr := strings.Join(card.WordsResult.MOBILE, ",")
				//if req.MobileOne != "" {
				//	if strings.Contains(mobileStr, req.MobileOne) || mobileStr == "" {
				//		isFlag = true
				//	} else {
				//		isFlag = false
				//	}
				//}
				//
				//if isFlag == false && req.MobileTwo != "" {
				//	if strings.Contains(mobileStr, req.MobileTwo) {
				//		isFlag = true
				//	} else {
				//		isFlag = false
				//	}
				//}
				if req.MobileOne != "" && strings.Contains(mobileStr, req.MobileOne) {
					isFlag = true
				}
				if req.MobileTwo != "" && strings.Contains(mobileStr, req.MobileTwo) {
					isFlag = true
				}
				//如果百度识别出来了客户名称，那么将识别出来的客户名称添加到待校验客户名称切片中
				if len(card.WordsResult.COMPANY) > 0 && card.WordsResult.COMPANY[0] != "" {
					companyNameSlice = card.WordsResult.COMPANY
				}
			}
			//如果百度未识别出来手机号或者公司名称，那么进行阿里识别
			if !isFlag || (len(companyNameSlice) == 0 && crmConfig.ConfigValue == "true") {
				//阿里云识别
				aliyunResult, errMsg, err := services.AliyunOcrBusinessCard(req.BusinessCardUrl)
				if err != nil {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败,Err:" + err.Error()
					return
				}
				if !aliyunResult.Success {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败"
					return
				}
				if errMsg != "" {
					br.Msg = errMsg
					return
				}
				//如果百度没有识别出来手机号，那么还需要阿里识别出来的手机号校验下
				if !isFlag {
					if len(aliyunResult.TelCell) > 0 {
						mobileStr := strings.Join(aliyunResult.TelCell, ",")
						if req.MobileOne != "" {
							if strings.Contains(mobileStr, req.MobileOne) {
								isFlag = true
							} else {
								isFlag = false
							}
						}
					} else {
						isFlag = true
					}
				}
				//如果阿里云识别出来了客户名称，那么将识别出来的客户名称添加到待校验客户名称切片中
				if len(aliyunResult.Company) > 0 {
					companyNameSlice = append(companyNameSlice, aliyunResult.Company...)
				}
			}

			if !isFlag && crmConfig2.ConfigValue == "true" {
				br.Msg = "名片信息与联系人手机号不符"
				br.IsSendEmail = false
				return
			}

			//校验识别出来的名片名称与传入的客户名称是否一致
			if len(companyNameSlice) > 0 && crmConfig.ConfigValue == "true" {
				isCompanyNameFlag := false //是否成功匹配客户名称
				//遍历识别出来的客户名称，然后与系统的客户名称做匹配（识别出来的名称包含系统名称的话，那么标记成功匹配）
				for _, tmpCompanyName := range companyNameSlice {
					//空串不处理
					if companyName == "" {
						continue
					}
					for _, analyzeName := range analyzeNameList {
						//如果分词出来的公司名称正好在识别出来的公司名称里面，那么就认为校验通过了
						if strings.Contains(tmpCompanyName, analyzeName) {
							isCompanyNameFlag = true
							break
						}
					}

					if isCompanyNameFlag {
						break
					}

				}
				//如果没有匹配到客户名称，那么就返回报错
				if !isCompanyNameFlag {
					br.Msg = "名片信息与公司名称不符"
					br.IsSendEmail = false
					return
				}
			}
		}
	}

	//UPDATE  wx_user
	//			SET
	//			  last_updated_time = NOW(),
	//			  position = ?,
	//			  is_maker = ?,
	//			  business_card_url = ?,
	//			  mobile_two= ?,
	//			  department_name=?,
	//              company_id=?,country_code=?

	//待更新字段
	updateCol := []string{"RealName", "Mobile", "MobileTwo", "Email", "Sex", "LastUpdatedTime", "Position", "IsMaker", "BusinessCardUrl", "DepartmentName", "CompanyId", "CountryCode"}
	//外呼手机号、外呼手机号区号
	if wxUser.OutboundMobile == "" || wxUser.OutboundMobile == wxUser.Mobile {
		wxUser.OutboundMobile = req.MobileOne
		wxUser.OutboundCountryCode = req.CountryCode
		//外呼字段数据修改
		updateCol = append(updateCol, "OutboundMobile", "OutboundCountryCode")
	}
	wxUser.RealName = req.RealName
	wxUser.Mobile = req.MobileOne
	wxUser.MobileTwo = req.MobileTwo
	wxUser.Email = req.Email
	wxUser.Sex = req.Sex
	wxUser.LastUpdatedTime = time.Now()
	wxUser.Position = req.Position
	wxUser.IsMaker = req.IsMaker
	wxUser.BusinessCardUrl = req.BusinessCardUrl
	wxUser.DepartmentName = req.DepartmentName
	wxUser.CompanyId = req.CompanyId
	wxUser.CountryCode = req.CountryCode
	fmt.Println("wxUser 2", wxUser)
	err = wxUser.Update(updateCol)
	//err = company.EditCompanyUser(&req)
	if err != nil {
		br.Msg = "编辑失败！"
		br.ErrMsg = "编辑失败，Err:" + err.Error()
		return
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{wxUser.CompanyId})

	//联系人信息
	originalUserInfo, _ := json.Marshal(oldWxUser)
	userInfo, _ := json.Marshal(wxUser)
	go services.AddWxUserOpLog(company.WxUserOpLog{
		LogType:                "edit",
		UserId:                 int(wxUser.UserId),
		CompanyId:              wxUser.CompanyId,
		Mobile:                 wxUser.Mobile,
		Email:                  wxUser.Email,
		OriginalUserInfo:       string(originalUserInfo),
		UserInfo:               string(userInfo),
		OriginalUserSellerInfo: "",
		UserSellerInfo:         "",
		OpUserId:               sysUser.AdminId,
		OpUserName:             sysUser.RealName,
		CreateTime:             time.Now(),
	})

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

// @Title 潜在用户列表
// @Description 潜在用户列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   ApplyMethod   query   int  true       "申请方式，0：全部，1:未申请，2:已付费客户申请试用，3:非客户申请试用"
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success 200 {object} models.PotentialUserListResp
// @router /potential/user/list [get]
func (this *CompanyController) PotentialUserList() {
	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")
	keyWord := this.GetString("KeyWord")
	applyMethod, _ := this.GetInt("ApplyMethod")

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = utils.StartIndex(currentIndex, pageSize)

	var condition string
	var pars []interface{}
	if applyMethod > 0 {
		condition += ` AND apply_method=? `
		pars = append(pars, applyMethod-1)
	}

	if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_SELLER || sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER {
		condition += ` AND apply_method=? `
		pars = append(pars, 1)
	}

	//非管理员不让看数据
	if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
		list := make([]*models.PotentialUserItem, 0)
		page := paging.GetPaging(currentIndex, pageSize, 0)
		resp := new(models.PotentialUserListResp)
		resp.List = list
		resp.Paging = page
		br.Ret = 200
		br.Success = true
		br.Msg = "获取成功"
		br.Data = resp
		return
	}

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

	total, err := models.GetPotentialUserListCount(condition, pars)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取分页数据失败，Err:" + err.Error()
		return
	}
	list, err := models.GetPotentialUserList(condition, pars, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取失败，Err:" + err.Error()
		return
	}
	listLen := len(list)

	mobilesSlice := make([]string, 0)
	emailsSlice := make([]string, 0)
	for _, v := range list {
		if v.Mobile != "" {
			mobilesSlice = append(mobilesSlice, v.Mobile)
		} else if v.Email != "" {
			emailsSlice = append(emailsSlice, v.Email)
		}
	}

	//用户浏览数据
	mobileStr := strings.Join(mobilesSlice, "','")
	mobileStr = "'" + mobileStr + "'"
	emailStr := strings.Join(emailsSlice, "','")
	emailStr = "'" + emailStr + "'"

	//userViewTotalList, _ := models.GetCountUserViewHistoryByUserIds(userIdStr)
	//userViewTotalMap := make(map[int]*models.UserViewTotalSlice)
	//for _, userView := range userViewTotalList {
	//	userViewTotalMap[userView.UserId] = userView
	//}

	//用户日评浏览数据
	//userReportViewTotalList, _ := models.GetReportViewMaxTimeByUserIds(userIdStr)
	//userReportViewTotalMap := make(map[int]*models.ReportViewRecord)
	//for _, userReportView := range userReportViewTotalList {
	//	userReportViewTotalMap[userReportView.UserId] = userReportView
	//}
	//手机号
	userViewMobileTotalMap := make(map[string]*models.UserViewMobileTotalSlice)
	userReportViewMobileTotalMap := make(map[string]*models.ReportViewMobileRecord)
	if len(mobilesSlice) > 0 {
		//用户浏览数据
		userViewMobileTotalList, _ := models.GetCountUserViewHistoryByMobiles(mobileStr)
		for _, userViewMobile := range userViewMobileTotalList {
			userViewMobileTotalMap[userViewMobile.Mobile] = userViewMobile
		}

		//每日点评手机号数据
		userReportViewMobileTotalList, _ := models.GetReportViewMaxTimeByMobiles(mobileStr)
		for _, userReportViewMobile := range userReportViewMobileTotalList {
			userReportViewMobileTotalMap[userReportViewMobile.Mobile] = userReportViewMobile
		}
	}

	//邮箱
	userViewEmailTotalMap := make(map[string]*models.UserViewEmailTotalSlice)
	userReportViewEmailTotalMap := make(map[string]*models.ReportViewEmailRecord)
	if len(emailsSlice) > 0 {
		//用户浏览数据
		userViewEmailTotalList, _ := models.GetCountUserViewHistoryByEmails(emailStr)
		for _, userViewEmail := range userViewEmailTotalList {
			userViewEmailTotalMap[userViewEmail.Email] = userViewEmail
		}
		//每日点评手机号数据
		userReportViewEmailTotalList, _ := models.GetReportViewMaxTimeByEmails(emailStr)
		for _, userReportViewEmail := range userReportViewEmailTotalList {
			userReportViewEmailTotalMap[userReportViewEmail.Email] = userReportViewEmail
		}
	}

	for i := 0; i < listLen; i++ {
		item := list[i]
		//item, err := models.GetReportViewMaxTime(list[i].UserId)
		//if err != nil {
		//	br.Msg = "获取失败"
		//	br.ErrMsg = "获取GetReportViewMaxTime失败，Err:" + err.Error()
		//	return
		//}
		//list[i].ViewTotal += item.ViewTotal

		//手机号用户累计浏览次数
		if userView, ok := userViewMobileTotalMap[item.Mobile]; ok {
			list[i].ViewTotal += userView.Total
			if userView.CreatedTime.After(list[i].LastViewTime) {
				list[i].LastViewTime = userView.CreatedTime
				list[i].LastViewTimeStr = userView.CreatedTime.Format(utils.FormatDateTime)
			}
		}
		//邮箱用户累计浏览次数
		if userView, ok := userViewEmailTotalMap[item.Email]; ok {
			//总共浏览的报表数据需要调整为（手机号用户浏览晨报数+邮箱号用户浏览晨报数）
			list[i].ViewTotal += userView.Total
			if userView.CreatedTime.After(list[i].LastViewTime) {
				list[i].LastViewTime = userView.CreatedTime
				list[i].LastViewTimeStr = userView.CreatedTime.Format(utils.FormatDateTime)
			}
		}

		//如果存在手机号用户日评数据，那么需要做处理
		if reportView, ok := userReportViewMobileTotalMap[item.Mobile]; ok {
			//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
			if reportView.LastViewTime.After(list[i].LastViewTime) {
				list[i].LastViewTime = reportView.LastViewTime
				list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
			}
			//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
			list[i].ViewTotal += reportView.ViewTotal
		}
		//如果存在手机号用户日评数据，那么需要做处理
		if reportView, ok := userReportViewEmailTotalMap[item.Email]; ok {
			//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
			if reportView.LastViewTime.After(list[i].LastViewTime) {
				list[i].LastViewTime = reportView.LastViewTime
				list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
			}
			//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
			list[i].ViewTotal += reportView.ViewTotal
		}
	}
	page := paging.GetPaging(currentIndex, pageSize, total)
	resp := new(models.PotentialUserListResp)
	resp.List = list
	resp.Paging = page
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 标记潜在用户
// @Description 标记潜在用户接口
// @Param	request	body models.PotentialUserDealReq true "type json string"
// @Success Ret=200 标记成功
// @router /potential/user/deal [post]
func (this *CompanyController) PotentialUserDeal() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var req models.PotentialUserDealReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	// 标记处理
	err = services.DealPotentialUser(req.UserId, sysUser.AdminId)
	if err != nil {
		br.Msg = "标记失败"
		br.ErrMsg = "标记失败,Err:" + err.Error()
		return
	}

	br.Ret = 200
	br.Success = true
	br.Msg = "标记成功"
}

// @Title 删除潜在用户
// @Description 删除潜在用户接口
// @Param	request	body models.PotentialUserDeleteReq true "type json string"
// @Success Ret=200 删除成功
// @router /potential/user/delete [post]
func (this *CompanyController) PotentialUserDelete() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var req models.PotentialUserDeleteReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	//删除用户
	err = services.DeleteWxUser(req.UserId)
	if err != nil {
		br.Msg = "删除失败"
		br.ErrMsg = "删除失败,Err:" + err.Error()
		return
	}
	br.Ret = 200
	br.Success = true
	br.Msg = "删除成功"
}

// @Title 移动潜在用户
// @Description 移动潜在用户接口
// @Param	request	body models.PotentialUserMoveReq true "type json string"
// @Success Ret=200 移动成功
// @router /potential/user/move [post]
func (this *CompanyController) PotentialUserMove() {
	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.PotentialUserMoveReq
	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 = "参数错误"
		br.ErrMsg = "客户id错误"
		return
	}

	//如果移动客户编号小于等于0，那么移动到潜在客户
	if req.CompanyId <= 0 {
		req.CompanyId = 1
	}
	wxUser, err := models.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.Msg = "移动失败"
		br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
		return
	}
	oldWxUser := *wxUser

	if req.Mobile == "" {
		req.Mobile = wxUser.Mobile
	}
	if req.Email == "" {
		req.Email = wxUser.Email
	}
	if req.Mobile == "" && req.Email == "" {
		br.Msg = "手机号和邮箱不能同时为空"
		return
	}
	//校验手机号
	if req.Mobile != "" && wxUser.Mobile != req.Mobile {
		count, err := models.CheckUserMobileIsRegister(req.UserId, req.Mobile)
		if err != nil {
			br.Msg = "校验数据失败"
			br.ErrMsg = "校验数据失败，Err:" + err.Error()
			return
		}
		if count > 0 {
			br.Msg = "该手机号已经注册过用户"
			return
		}
	}
	//校验邮箱
	if req.Email != "" && wxUser.Email != req.Email {
		if !utils.ValidateEmailFormatat(req.Email) {
			br.Msg = "请输入正确的邮箱（包含@）"
			return
		}
		count, err := models.CheckUserEmailIsRegister(req.UserId, req.Email)
		if err != nil {
			br.Msg = "校验数据失败"
			br.ErrMsg = "校验数据失败，Err:" + err.Error()
			return
		}
		if count > 0 {
			br.Msg = "该邮箱已经注册过用户"
			br.IsSendEmail = false
			return
		}
	}

	updateCol := make([]string, 0)

	if wxUser.OutboundMobile == "" || wxUser.Mobile == wxUser.OutboundMobile {
		wxUser.OutboundMobile = req.Mobile
		wxUser.OutboundCountryCode = req.CountryCode
		updateCol = append(updateCol, "OutboundMobile", "OutboundCountryCode")
	}
	if req.Email != "" {
		wxUser.Email = req.Email
		updateCol = append(updateCol, "Email")
	}
	if req.RealName != "" {
		wxUser.RealName = req.RealName
		updateCol = append(updateCol, "RealName")
	}
	if req.Mobile != "" {
		wxUser.Mobile = req.Mobile
		updateCol = append(updateCol, "Mobile")
	}
	if req.CountryCode != "" {
		wxUser.CountryCode = req.CountryCode
		updateCol = append(updateCol, "CountryCode")
	}
	if req.Position != "" {
		wxUser.Position = req.Position
		updateCol = append(updateCol, "Position")
	}
	if wxUser.DepartmentName == "" && req.DepartmentName != "" {
		wxUser.DepartmentName = req.DepartmentName
		updateCol = append(updateCol, "DepartmentName")
	}
	wxUser.Sex = req.Sex
	wxUser.IsMaker = req.IsMaker
	updateCol = append(updateCol, "Sex", "IsMaker")

	//名片匹配
	if req.BusinessCardUrl != "" {
		//if req.BusinessCardUrl != "" && utils.RunMode == "release" {
		// 获取图片识别手机号的配置
		crmConfig2, err := company.GetConfigDetailByCode("card_recognition_tel")
		if err != nil {
			br.Msg = "获取配置失败"
			br.ErrMsg = "获取配置失败"
			br.IsSendEmail = false
			return
		}
		if crmConfig2.ConfigValue == "true" {
			card, err := services.GetBusinessCard(req.BusinessCardUrl)
			if err != nil {
				br.Msg = "名片识别失败"
				br.ErrMsg = "名片识别失败,Err:" + err.Error()
				return
			}
			isFlag := false
			if len(card.WordsResult.MOBILE) > 0 {
				mobileStr := strings.Join(card.WordsResult.MOBILE, ",")
				//if req.Mobile != "" {
				//	if strings.Contains(mobileStr, req.Mobile) || mobileStr == "" {
				//		isFlag = true
				//	} else {
				//		isFlag = false
				//	}
				//}
				if req.Mobile != "" && strings.Contains(mobileStr, req.Mobile) {
					isFlag = true
				}
			}
			if !isFlag {
				//阿里云识别
				//if utils.RunMode == "release" {
				aliyunResult, errMsg, err := services.AliyunOcrBusinessCard(req.BusinessCardUrl)
				if err != nil {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败,Err:" + err.Error()
					return
				}
				if !aliyunResult.Success {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败"
					return
				}
				if errMsg != "" {
					br.Msg = errMsg
					return
				}
				if len(aliyunResult.TelCell) > 0 {
					mobileStr := strings.Join(aliyunResult.TelCell, ",")
					if req.Mobile != "" {
						if strings.Contains(mobileStr, req.Mobile) {
							isFlag = true
						} else {
							isFlag = false
						}
					}
				} else {
					isFlag = true
				}
				//}
			}

			if !isFlag && crmConfig2.ConfigValue == "true" {
				br.Msg = "名片信息与联系人手机号不符"
				return
			}
		}

		wxUser.BusinessCardUrl = req.BusinessCardUrl
		updateCol = append(updateCol, "BusinessCardUrl")
	}

	productId := services.GetProductId(sysUser.RoleTypeCode)
	companyProductList, _ := getSysCompanyProductList(productId, req.CompanyId)

	//联系人与销售的关系
	userSellerRelationList, err := models.GetUserSellerRelationList(int(wxUser.UserId))
	if err != nil {
		return
	}
	userSellerRelationInfo, _ := json.Marshal(userSellerRelationList)

	err = services.MovePotentialUser(req.UserId, req.CompanyId, req.RealName, req.Mobile, req.Email, req.Remark, companyProductList, wxUser, updateCol)
	//err = models.MovePotentialUser(req.UserId, req.CompanyId, req.RealName, req.Mobile, req.Email, req.Remark)
	if err != nil {
		br.Msg = "移动失败"
		br.ErrMsg = "移动失败,Err:" + err.Error()
		return
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{req.CompanyId})

	//联系人信息
	originalUserInfo, _ := json.Marshal(oldWxUser)
	userInfo, _ := json.Marshal(wxUser)
	go services.AddWxUserOpLog(company.WxUserOpLog{
		LogType:                "move",
		UserId:                 int(wxUser.UserId),
		CompanyId:              wxUser.CompanyId,
		Mobile:                 wxUser.Mobile,
		Email:                  wxUser.Email,
		OriginalUserInfo:       string(originalUserInfo),
		UserInfo:               string(userInfo),
		OriginalUserSellerInfo: string(userSellerRelationInfo),
		UserSellerInfo:         "",
		OpUserId:               sysUser.AdminId,
		OpUserName:             sysUser.RealName,
		CreateTime:             time.Now(),
	})
	go services.AddWxUserMoveLog(wxUser, sysUser, req.CompanyId) // 添加用户移动日志记录
	br.Ret = 200
	br.Success = true
	br.Msg = "移动成功"
}

// @Title 移动联系人
// @Description 移动联系接口，将联系人从自己名下移动到另一个客户销售名下
// @Param	request	body models.UserMoveReq true "type json string"
// @Success Ret=200 移动成功
// @router /user/move [post]
func (this *CompanyController) UserMove() {
	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.UserMoveReq
	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 = "参数错误"
		br.ErrMsg = "联系人id错误"
		return
	}
	if req.CompanyId <= 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "客户id错误"
		return
	}
	if req.SellerId < 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "销售id错误"
		return
	}

	wxUser, err := models.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.Msg = "移动失败"
		br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
		return
	}
	oldWxUser := *wxUser
	if wxUser.CompanyId == req.CompanyId {
		br.Msg = "移动失败"
		br.ErrMsg = "该联系人属于该客户"
		return
	}
	//产品id
	productId := services.GetProductId(sysUser.RoleTypeCode)
	//操作权限校验
	errMsg, err := checkOpCompanyUserByCompanyId(wxUser.CompanyId, productId, sysUser.AdminId, sysUser.RoleTypeCode)
	if err != nil {
		br.Msg = "移动失败！" + errMsg
		br.ErrMsg = "移动失败，Err:" + err.Error()
		return
	}

	//联系人与销售的关系
	userSellerRelationList, err := models.GetUserSellerRelationList(int(wxUser.UserId))
	if err != nil {
		return
	}
	userSellerRelationInfo, _ := json.Marshal(userSellerRelationList)

	err = services.MoveUser(req.UserId, req.CompanyId, req.SellerId, wxUser, sysUser.AdminId)
	//err = models.MovePotentialUser(req.UserId, req.CompanyId, req.RealName, req.Mobile, req.Email, req.Remark)
	if err != nil {
		br.Msg = "移动失败"
		br.ErrMsg = "移动失败,Err:" + err.Error()
		return
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{wxUser.CompanyId, req.CompanyId})

	//联系人信息
	originalUserInfo, _ := json.Marshal(oldWxUser)
	userInfo, _ := json.Marshal(wxUser)
	{
		// 最新的联系人信息
		newWxUser, err := models.GetWxUserByUserId(req.UserId)
		if err == nil {
			userInfo, _ = json.Marshal(newWxUser)
		}
	}
	go services.AddWxUserOpLog(company.WxUserOpLog{
		LogType:                "move",
		UserId:                 int(wxUser.UserId),
		CompanyId:              wxUser.CompanyId,
		Mobile:                 wxUser.Mobile,
		Email:                  wxUser.Email,
		OriginalUserInfo:       string(originalUserInfo),
		UserInfo:               string(userInfo),
		OriginalUserSellerInfo: string(userSellerRelationInfo),
		UserSellerInfo:         "",
		OpUserId:               sysUser.AdminId,
		OpUserName:             sysUser.RealName,
		CreateTime:             time.Now(),
	})

	go services.AddWxUserMoveLog(wxUser, sysUser, req.CompanyId) // 添加用户移动日志记录

	br.Ret = 200
	br.Success = true
	br.Msg = "移动成功"
	br.IsAddLog = true
}

// @Title 搜索客户
// @Description 搜索客户接口
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success 200 {object} company.CompanySearchResp
// @router /potential/company/search [get]
func (this *CompanyUserController) CompanySearch() {
	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 err error
	keyWord := this.GetString("KeyWord")
	item := make([]*company.CompanyItem, 0)
	if keyWord != "" {
		item, err = company.GetCompanyBySearch(keyWord)
		if err != nil && err.Error() != utils.ErrNoRow() {
			br.Msg = "获取失败"
			br.ErrMsg = "获取数据失败，Err:" + err.Error()
			return
		}
	}
	resp := new(company.CompanySearchResp)
	resp.List = item
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 企查查模糊查询客户接口
// @Description 企查查模糊查询客户
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success 200 {object} services.Result
// @router /potential/company/qccSearch [get]
func (this *CompanyUserController) CompanyQCCSearch() {
	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 err error
	var results []services.Result
	keyWord := this.GetString("KeyWord")
	if keyWord != "" {
		results, err = services.QCCFuzzySearch(keyWord)
		if err != nil {
			br.Data = results
			br.Msg = "获取数据失败," + err.Error()
			br.Ret = 200
			br.Success = true
			return
		}
	}
	br.Data = results
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
}

// @Title 检测客户名称或社会信用码重复
// @Description 检测客户名称或社会信用码重复接口(新增/编辑客户页面使用)
// @Param   CompanyName   query   string  true       "客户名称"
// @Param   CreditCode   query   string  true       "社会统一信用码"
// @Success 200 {object} company.CheckCompanyInfoRepeatResp
// @router /check/RepeatCompanyInfo [get]
func (this *CompanyController) CheckCompanyInfoRepeat() {
	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
	}
	roleTypeCode := sysUser.RoleTypeCode
	productId := services.GetProductId(roleTypeCode)
	companyName := this.GetString("CompanyName")
	creditCode := this.GetString("CreditCode")
	var status, comanyId, repeatStatus int
	var productName string

	if productId == 0 {
		productId = 1
		checkProductId := 2

		if creditCode != "" {
			codeItem, err := company.CheckCompanyProductByCreditCode(creditCode, productId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验社会信用码是否存在失败"
				br.ErrMsg = "校验社会信用码是否存在失败,Err:" + err.Error()
				return
			}
			//存在ficc权限
			if codeItem != nil && codeItem.CompanyId > 0 {
				repeatStatus = 1
				goto Loop
			}
			codeCheckItem, err := company.CheckCompanyProductByCreditCode(creditCode, checkProductId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验社会信用码是否存在失败"
				br.ErrMsg = "校验社会信用码是否存在失败,Err:" + err.Error() + " productId:" + strconv.Itoa(productId) + ";checkProductId:" + strconv.Itoa(checkProductId)
				return
			}
			if codeCheckItem != nil && codeCheckItem.CompanyId > 0 {
				status = 1
				repeatStatus = 1
				productName = codeCheckItem.ProductName
				comanyId = codeCheckItem.CompanyId
				goto Loop
			}
		}

		if companyName != "" {
			nameItem, err := company.CheckCompanyProductByName(companyName, productId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验客户名称是否存在失败"
				br.ErrMsg = "校验客户名称是否存在失败,Err:" + err.Error()
				return
			}
			if nameItem != nil && nameItem.CompanyId > 0 {
				repeatStatus = 2
				goto Loop
			}
			nameCheckItem, err := company.CheckCompanyProductByName(companyName, checkProductId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验客户名称是否存在失败"
				br.ErrMsg = "校验客户名称是否存在失败,Err:" + err.Error() + " productId:" + strconv.Itoa(productId) + ";checkProductId:" + strconv.Itoa(checkProductId)
				return
			}
			if nameCheckItem != nil && nameCheckItem.CompanyId > 0 {
				status = 1
				repeatStatus = 2
				productName = nameCheckItem.ProductName
				comanyId = nameCheckItem.CompanyId
				goto Loop
			}
		}

		productId = 2
		checkProductId = 1

		if creditCode != "" {
			codeItem, err := company.CheckCompanyProductByCreditCode(creditCode, productId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验社会信用码是否存在失败"
				br.ErrMsg = "校验社会信用码是否存在失败,Err:" + err.Error()
				return
			}
			if codeItem != nil && codeItem.CompanyId > 0 {
				repeatStatus = 1
				goto Loop
			}
			codeCheckItem, err := company.CheckCompanyProductByCreditCode(creditCode, checkProductId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验社会信用码是否存在失败"
				br.ErrMsg = "校验社会信用码是否存在失败,Err:" + err.Error() + " productId:" + strconv.Itoa(productId) + ";checkProductId:" + strconv.Itoa(checkProductId)
				return
			}
			if codeCheckItem != nil && codeCheckItem.CompanyId > 0 {
				status = 1
				repeatStatus = 1
				productName = codeCheckItem.ProductName
				comanyId = codeCheckItem.CompanyId
				goto Loop
			}
		}

		if companyName != "" {
			nameItem, err := company.CheckCompanyProductByName(companyName, productId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验客户名称是否存在失败"
				br.ErrMsg = "校验客户名称是否存在失败,Err:" + err.Error()
				return
			}
			if nameItem != nil && nameItem.CompanyId > 0 {
				repeatStatus = 2
				goto Loop
			}
			nameCheckItem, err := company.CheckCompanyProductByName(companyName, checkProductId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验客户名称是否存在失败"
				br.ErrMsg = "校验客户名称是否存在失败,Err:" + err.Error() + " productId:" + strconv.Itoa(productId) + ";checkProductId:" + strconv.Itoa(checkProductId)
				return
			}
			if nameCheckItem != nil && nameCheckItem.CompanyId > 0 {
				status = 1
				repeatStatus = 2
				productName = nameCheckItem.ProductName
				comanyId = nameCheckItem.CompanyId
				goto Loop
			}
		}

	} else {
		checkProductId := 0
		if productId == 1 {
			checkProductId = 2
		} else if productId == 2 {
			checkProductId = 1
		}
		if creditCode != "" {
			codeItem, err := company.CheckCompanyProductByCreditCode(creditCode, productId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验社会信用码是否存在失败"
				br.ErrMsg = "校验社会信用码是否存在失败,Err:" + err.Error()
				return
			}
			if codeItem != nil && codeItem.CompanyId > 0 {
				repeatStatus = 1
				goto Loop
			}
			codeCheckItem, err := company.CheckCompanyProductByCreditCode(creditCode, checkProductId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验社会信用码是否存在失败"
				br.ErrMsg = "校验社会信用码是否存在失败,Err:" + err.Error() + " productId:" + strconv.Itoa(productId) + ";checkProductId:" + strconv.Itoa(checkProductId)
				return
			}
			if codeCheckItem != nil && codeCheckItem.CompanyId > 0 {
				status = 1
				repeatStatus = 1
				productName = codeCheckItem.ProductName
				comanyId = codeCheckItem.CompanyId
				goto Loop
			}
		}
		if companyName != "" {
			nameItem, err := company.CheckCompanyProductByName(companyName, productId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验客户名称是否存在失败"
				br.ErrMsg = "校验客户名称是否存在失败,Err:" + err.Error()
				return
			}
			if nameItem != nil && nameItem.ProductName != "" {
				repeatStatus = 2
				goto Loop
			}
			nameCheckoutItem, err := company.CheckCompanyProductByName(companyName, checkProductId)
			if err != nil && err.Error() != utils.ErrNoRow() {
				br.Msg = "校验客户名称是否存在失败"
				br.ErrMsg = "校验客户名称是否存在失败,Err:" + err.Error() + " productId:" + strconv.Itoa(productId) + ";checkProductId:" + strconv.Itoa(checkProductId)
				return
			}
			if nameCheckoutItem != nil && nameCheckoutItem.CompanyId > 0 {
				status = 1
				repeatStatus = 2
				productName = nameCheckoutItem.ProductName
				comanyId = nameCheckoutItem.CompanyId
				goto Loop
			}
		}

	}
Loop:
	resp := new(company.CheckCompanyInfoRepeatResp)
	resp.Status = status
	resp.RepeatStatus = repeatStatus
	resp.ProductName = productName
	resp.CompanyId = comanyId
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// ViewReportList
// @Title 联系人阅读报告记录
// @Description 联系人阅读报告记录
// @Param   UserId   query   int  true       "用户id"
// @Param   TxtType   query   int  true       "类型0全部，1权益，2ficc"
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   LastViewTime   query   string  true       "最近一次的阅读时间，没有的话，那就是获取最新数据"
// @Success 200 {object} company.ViewReportListResp
// @router /view/report/list [get]
func (this *CompanyUserController) ViewReportList() {
	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
	}
	userId, _ := this.GetInt("UserId")
	txtType, _ := this.GetInt("TxtType")
	pageSize, _ := this.GetInt("PageSize")
	lastViewTime := this.GetString("LastViewTime")
	if userId <= 0 {
		br.Msg = "参数错误"
		return
	}
	// 默认20条数据
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if userId > 0 {

	}
	item, err := models.GetWxUserByUserId(userId)
	if err != nil {
		br.Msg = "获取失败"
		br.Msg = "获取联系人信息失败,Err:" + err.Error()
		return
	}

	var lastViewTimeT time.Time
	if lastViewTime != `` {
		lastViewTimeT, err = time.ParseInLocation(utils.FormatDateTime, lastViewTime, time.Local)
		if err != nil {
			br.Msg = "获取失败"
			br.Msg = "最近一次阅读时间转换异常,Err:" + err.Error()
			return
		}
	}

	list := make([]*company.ViewReportList, 0)
	recordList := make([]*models.UserReportViewRecord, 0)

	obj := models.UserReportViewRecord{}

	var baseCondition string // 基础条件
	var basePars []interface{}
	if item.Mobile != "" {
		baseCondition = ` AND mobile = ? `
		basePars = append(basePars, item.Mobile)
	} else if item.Email == "" {
		baseCondition = ` AND email = ? `
		basePars = append(basePars, item.Email)
	}

	// 阅读记录汇总数
	total := item.FiccViewTotal + item.RaiViewTotal

	switch txtType {
	case 1:
		baseCondition += ` AND source = ? `
		basePars = append(basePars, 4)

		total = item.RaiViewTotal
		if lastViewTimeT.IsZero() {
			if item.RaiLastViewTime != `` && item.RaiLastViewTime != `0000-00-00 00:00:00` {
				lastViewTimeT, _ = time.ParseInLocation(utils.FormatDateTime, item.RaiLastViewTime, time.Local)
			} else {
				lastViewTimeT = time.Now()
			}
			// 默认要把最新的记录列出来，所以往后加1s
			lastViewTime = lastViewTimeT.Add(1 * time.Second).Format(utils.FormatDateTime)
		}
	// 权益
	case 2: // ficc
		baseCondition += ` AND source in (?,?,?) `
		basePars = append(basePars, 1, 2, 3)
		total = item.FiccViewTotal

		if lastViewTimeT.IsZero() {
			if item.FiccLastViewTime != `` && item.FiccLastViewTime != `0000-00-00 00:00:00` {
				lastViewTimeT, _ = time.ParseInLocation(utils.FormatDateTime, item.FiccLastViewTime, time.Local)
			} else {
				lastViewTimeT = time.Now()
			}
			// 默认要把最新的记录列出来，所以往后加1s
			lastViewTime = lastViewTimeT.Add(1 * time.Second).Format(utils.FormatDateTime)
		}
	default:
		if lastViewTimeT.IsZero() {
			var ficcViewTime, raiViewTime time.Time
			if item.FiccLastViewTime != `` && item.FiccLastViewTime != `0000-00-00 00:00:00` {
				ficcViewTime, _ = time.ParseInLocation(utils.FormatDateTime, item.FiccLastViewTime, time.Local)
			}
			if item.RaiLastViewTime != `` && item.RaiLastViewTime != `0000-00-00 00:00:00` {
				raiViewTime, _ = time.ParseInLocation(utils.FormatDateTime, item.RaiLastViewTime, time.Local)
			}

			// 如果两个都没有值的话，那么就是当前时间
			if ficcViewTime.IsZero() && raiViewTime.IsZero() {
				lastViewTimeT = time.Now()
			} else if !ficcViewTime.IsZero() && !raiViewTime.IsZero() {
				if ficcViewTime.After(raiViewTime) {
					lastViewTimeT = ficcViewTime
				} else {
					lastViewTimeT = raiViewTime
				}
			} else if !ficcViewTime.IsZero() {
				lastViewTimeT = ficcViewTime
			} else {
				lastViewTimeT = raiViewTime
			}
			// 默认要把最新的记录列出来，所以往后加1s
			lastViewTime = lastViewTimeT.Add(1 * time.Second).Format(utils.FormatDateTime)
		}
	}

	// 开始实际的查询
	{
		condition := baseCondition
		pars := basePars

		condition += `AND create_time <  ?`
		pars = append(pars, lastViewTime)

		total, items, err := obj.GetViewReportList(lastViewTimeT.Year(), condition, pars, pageSize)
		if err != nil {
			br.Msg = "获取失败"
			br.Msg = "获取失败,Err:" + err.Error()
			return
		}

		recordList = append(recordList, items...)

		// 查询去年的表
		if total < int64(pageSize) {
			secondCondition := baseCondition
			secondPars := basePars

			secondCondition += `AND create_time <  ?`
			secondPars = append(secondPars, lastViewTime)

			_, items, err = obj.GetViewReportList(lastViewTimeT.Year()-1, secondCondition, secondPars, pageSize-int(total))
			if err != nil {
				br.Msg = "获取失败"
				br.Msg = "获取失败,Err:" + err.Error()
				return
			}

			recordList = append(recordList, items...)
		}
	}

	viewReportMap := make(map[string]company.ViewReportList) // 阅读记录map
	sourceReportIdListMap := make(map[int8][]int)

	for _, v := range recordList {
		tmpList, ok := sourceReportIdListMap[v.Source]
		if !ok {
			tmpList = make([]int, 0)
		}
		tmpList = append(tmpList, v.ReportId)
		sourceReportIdListMap[v.Source] = tmpList

		tmpTxtType := `ficc`
		if v.Source == 4 {
			tmpTxtType = `rights`
		}
		stopTime := `--`
		if v.StopTime > 0 {
			stopTime = fmt.Sprint(stopTime)
		}
		viewReportMap[fmt.Sprint(v.Source, "_", v.ReportId)] = company.ViewReportList{
			ResearchReportName: "",
			ReportType:         "",
			CreatedTime:        v.CreateTime,
			TxtType:            tmpTxtType,
			MatchTypeName:      "--",
			StopTime:           stopTime,
		}
	}

	// 获取报告详情
	for source, reportIdList := range sourceReportIdListMap {
		switch source {
		case 1: // rddp报告
			tmpReportList, err := models.GetReportByIdList(reportIdList)
			if err != nil {
				br.Msg = "获取失败"
				br.Msg = "获取weekly报告详情失败,Err:" + err.Error()
				return
			}
			for _, v := range tmpReportList {
				tmpKey := fmt.Sprint(source, "_", v.Id)
				if tmpInfo, ok := viewReportMap[tmpKey]; ok {
					tmpInfo.ResearchReportName = v.Title
					tmpInfo.ReportType = `rddp`
					tmpInfo.MatchTypeName = v.ClassifyNameFirst
					viewReportMap[tmpKey] = tmpInfo
				}
			}
		case 2: // weekly报告
			tmpReportList, err := models.GetResearchReportListByIdList(reportIdList)
			if err != nil {
				br.Msg = "获取失败"
				br.Msg = "获取weekly报告详情失败,Err:" + err.Error()
				return
			}
			for _, v := range tmpReportList {
				tmpKey := fmt.Sprint(source, "_", v.ResearchReportId)
				if tmpInfo, ok := viewReportMap[tmpKey]; ok {
					tmpInfo.ResearchReportName = v.ResearchReportName
					tmpInfo.ReportType = v.Type
					viewReportMap[tmpKey] = tmpInfo
				}
			}
		case 3: // weekly_report商品的报告（应该是作废了）；
			tmpReportList, err := models.GetChartPermissionByIdList(reportIdList)
			if err != nil {
				br.Msg = "获取失败"
				br.Msg = "获取weekly报告详情失败,Err:" + err.Error()
				return
			}
			for _, v := range tmpReportList {
				tmpKey := fmt.Sprint(source, "_", v.ChartPermissionId)
				if tmpInfo, ok := viewReportMap[tmpKey]; ok {
					tmpInfo.ResearchReportName = v.ChartPermissionName
					tmpInfo.ReportType = `advisory`
					tmpInfo.MatchTypeName = v.ClassifyName
					viewReportMap[tmpKey] = tmpInfo
				}
			}
		case 4: // 察研观向的报告
			tmpReportList, err := cygx.GetArticleListByIdList(reportIdList)
			if err != nil {
				br.Msg = "获取失败"
				br.Msg = "获取weekly报告详情失败,Err:" + err.Error()
				return
			}
			for _, v := range tmpReportList {
				tmpKey := fmt.Sprint(source, "_", v.ArticleId)
				if tmpInfo, ok := viewReportMap[tmpKey]; ok {
					tmpInfo.ResearchReportName = v.Title
					tmpInfo.ReportType = `cygx`
					tmpInfo.MatchTypeName = v.MatchTypeName
					viewReportMap[tmpKey] = tmpInfo
				}
			}

		}
	}

	// 报告标题处理
	for _, v := range recordList {
		tmpKey := fmt.Sprint(v.Source, "_", v.ReportId)
		if tmpInfo, ok := viewReportMap[tmpKey]; ok {
			stopTime := `--`
			if v.StopTime > 0 {
				stopTime = fmt.Sprint(v.StopTime)
			}
			list = append(list, &company.ViewReportList{
				ResearchReportName: tmpInfo.ResearchReportName,
				ReportType:         tmpInfo.ReportType,
				CreatedTime:        v.CreateTime,
				TxtType:            tmpInfo.TxtType,
				MatchTypeName:      tmpInfo.MatchTypeName,
				StopTime:           stopTime,
			})
		}
	}

	// 类型处理
	for k, v := range list {
		if v.ReportType == "day" {
			list[k].MatchTypeName = "晨报"
		} else if v.ReportType == "week" {
			list[k].MatchTypeName = "周报"
		} else if v.ReportType == "two_week" {
			list[k].MatchTypeName = "双周报"
		} else if v.ReportType == "month" {
			list[k].MatchTypeName = "月报"
		} else if v.ReportType == "rddp" {
			//list[k].MatchTypeName = "日评"
			createdTime := utils.StrTimeToTime(v.CreatedTime)
			monthStr := createdTime.Format("01")
			dayStr := strconv.Itoa(createdTime.Day())
			if len(dayStr) == 1 {
				dayStr = "0" + dayStr
			}
			list[k].ResearchReportName += "(" + monthStr + dayStr + ")"
		}
		if v.StopTime != "--" {
			list[k].StopTime += "s"
		}
	}
	resp := new(company.ViewReportListResp)
	resp.List = list
	resp.Total = total
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 导出潜在用户
// @Description 导出潜在用户接口
// @Param   ApplyMethod   query   int  true       "申请方式，0：全部，1:未申请，2:已付费客户申请试用，3:非客户申请试用"
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success Ret=200 导出成功
// @router /potential/user/export [get]
func (this *CompanyUserController) PotentialUserExport() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	keyWord := this.GetString("KeyWord")
	applyMethod, _ := this.GetInt("ApplyMethod")

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	list := make([]*models.PotentialUserItem, 0)
	//管理员才让导出数据
	if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN {
		var condition string
		var pars []interface{}
		if applyMethod > 0 {
			condition += ` AND apply_method=? `
			pars = append(pars, applyMethod-1)
		}
		if keyWord != "" {
			condition += ` AND (a.nick_name LIKE '%` + keyWord + `%' OR a.mobile LIKE '%` + keyWord + `%' OR a.email LIKE '%` + keyWord + `%') `
		}
		tmpList, err := models.GetPotentialUserListExport(condition, pars)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取失败，Err:" + err.Error()
			return
		}
		list = tmpList
	}

	dir, err := os.Executable()
	exPath := filepath.Dir(dir)
	downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
	xlsxFile := xlsx.NewFile()
	if err != nil {
		br.Msg = "生成文件失败"
		br.ErrMsg = "生成文件失败"
		return
	}
	style := xlsx.NewStyle()
	alignment := xlsx.Alignment{
		Horizontal: "center",
		Vertical:   "center",
		WrapText:   true,
	}

	style.Alignment = alignment
	style.ApplyAlignment = true

	sheel, err := xlsxFile.AddSheet("客户数据")
	if err != nil {
		br.Msg = "新增Sheet失败"
		br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
		return
	}
	titleRow := sheel.AddRow()
	titleRow.AddCell().SetValue("姓名")
	titleRow.AddCell().SetValue("手机号")
	titleRow.AddCell().SetValue("邮箱")
	titleRow.AddCell().SetValue("注册时间")
	titleRow.AddCell().SetValue("公司")
	titleRow.AddCell().SetValue("申请类型")
	titleRow.AddCell().SetValue("累计阅读次数")
	titleRow.AddCell().SetValue("最后一次阅读时间")

	for _, v := range list {
		dataRow := sheel.AddRow()
		dataRow.SetHeight(20)
		dataRow.AddCell().SetString(v.RealName)
		dataRow.AddCell().SetString(v.Mobile)
		dataRow.AddCell().SetString(v.Email)
		dataRow.AddCell().SetString(v.CreatedTime)
		dataRow.AddCell().SetString(v.CompanyName)
		if v.ApplyMethod == 0 {
			dataRow.AddCell().SetString("未申请")
		} else if v.ApplyMethod == 1 {
			dataRow.AddCell().SetString("已付费客户申请试用")
		} else {
			dataRow.AddCell().SetString("非客户申请试用")
		}
		reportView, err := models.GetReportViewMaxTime(int(v.UserId))
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "获取GetReportViewMaxTime失败，Err:" + err.Error()
			return
		}
		if reportView.LastViewTime.After(v.LastViewTime) {
			v.LastViewTimeStr = v.LastViewTime.Format(utils.FormatDateTime)
		} else {
			v.LastViewTimeStr = v.LastViewTime.Format(utils.FormatDateTime)
		}
		v.ViewTotal += reportView.ViewTotal
		dataRow.AddCell().SetInt(v.ViewTotal)
		if v.LastViewTimeStr == "0001-01-01 00:00:00" {
			v.LastViewTimeStr = ""
		}
		dataRow.AddCell().SetString(v.LastViewTimeStr)
	}

	err = xlsxFile.Save(downLoadnFilePath)
	if err != nil {
		br.Msg = "保存文件失败"
		br.ErrMsg = "保存文件失败"
		return
	}
	randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
	downloadFileName := "潜在用户列表_" + randStr + ".xlsx"
	this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
	defer func() {
		os.Remove(downLoadnFilePath)
	}()
	br.Ret = 200
	br.Success = true
	br.Msg = "导出成功"
}

// @Title 获取批量导入联系人数据
// @Description 获取批量导入联系人数据
// @Param   File   query   file  true       "文件"
// @Param   CompanyId   query   file  true       "客户id"
// @Success 200 {object} models.ImportListResp
// @router /import/list [post]
func (this *CompanyUserController) 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
	}
	companyId, _ := this.GetInt("CompanyId")
	if companyId <= 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "客户id为0"
		return
	}

	//产品id
	productId := services.GetProductId(sysUser.RoleTypeCode)

	//操作权限校验
	errMsg, err := checkOpCompanyUserByCompanyId(companyId, productId, sysUser.AdminId, sysUser.RoleTypeCode)
	if err != nil {
		br.Msg = "导入失败！" + errMsg
		br.ErrMsg = "导入失败，Err:" + err.Error()
		return
	}
	//userBusinessCardCount := 0
	//if productId > 0 {
	//	tmpUserBusinessCardCount, err := models.GetCompanyUserBusinessCardCountByProductId(companyId, productId)
	//	if err != nil {
	//		br.Msg = "导入失败"
	//		br.ErrMsg = "判断是否已经存在上传名片联系人失败,err:" + err.Error()
	//		return
	//	}
	//	userBusinessCardCount = tmpUserBusinessCardCount
	//} else {
	//	tmpUserBusinessCardCount, err := company.GetCompanyUserBusinessCardCount(companyId)
	//	if err != nil {
	//		br.Msg = "导入失败"
	//		br.ErrMsg = "判断是否已经存在上传名片联系人失败,err:" + err.Error()
	//		return
	//	}
	//	userBusinessCardCount = tmpUserBusinessCardCount
	//}
	//
	//if userBusinessCardCount <= 0 {
	//	br.Msg = "请先至少添加一位名片联系人"
	//	return
	//}

	//客户信息
	companyInfo, err := company.GetCompanyById(companyId)
	if err != nil {
		br.Msg = "导入异常"
		br.Msg = "导入异常：" + err.Error()
		return
	}

	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.WxUser, 0)

	//excel中已经存在的数据，用来判断excel中是否存在相同手机号/邮箱，避免重复提交
	excelData := make(map[string]string)
	//重复数据
	repeatUser := make([]*models.WxUser, 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 == 0 {
				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, "国际区号（中国大陆填写：86）") {
							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 >= 1 {
				row := sheet.Row(i)
				cells := row.Cells
				var userName, sex, countryCode, mobileOne, email, isMaker, position, departmentName string
				for k, cell := range cells {
					if k == 0 {
						userName = cell.String()
					}
					if k == 1 {
						sex = cell.String()
					}
					if k == 2 {
						countryCode = cell.String()
					}
					if k == 3 {
						mobileOne = cell.String()
					}
					if k == 4 {
						email = cell.String()
					}
					if k == 5 {
						isMaker = cell.String()
					}
					if k == 6 {
						position = cell.String()
					}
					if k == 7 {
						departmentName = cell.String()
					}
				}

				//移除空格
				mobileOne = utils.TrimStr(mobileOne)
				email = utils.TrimStr(email)

				//这些字段都没有的话，系统认为excel到底了
				if userName == "" && sex == "" && mobileOne == "" {
					break
				}
				if userName == "" {
					continue
				}

				//如果手机号或者邮箱都没有填写的情况下
				if mobileOne == "" && email == "" {
					continue
				}
				if mobileOne != "" && countryCode == "" {
					br.Msg = "导入数据中存在【国际区号】为空的联系人，请检查"
					return
				}
				//如果是权益，且是海外用户的情况下，那么手机号、邮箱有一个没有填写的情况下，那么退出当前循环
				if productId == 2 && companyInfo.RegionType == "海外" && (mobileOne == "" || email == "") {
					continue
				}

				item := new(models.WxUser)
				item.CountryCode = countryCode
				item.RealName = userName
				if sex == "男" {
					item.Sex = 1
				} else if sex == "女" {
					item.Sex = 2
				} else {
					item.Sex = 0
				}
				item.Mobile = mobileOne
				item.Email = email
				if isMaker == "是" {
					item.IsMaker = 1
				} else {
					item.IsMaker = 0
				}
				item.Position = position
				item.DepartmentName = departmentName

				if mobileOne != "" {
					if _, ok := excelData[mobileOne]; ok {
						//将用户插入其中，然后退出当前循环，进入下一循环
						repeatUser = append(repeatUser, item)
						continue
					}
					excelData[mobileOne] = ""
				}
				if email != "" {
					if _, ok := excelData[email]; ok {
						//将用户插入其中，然后退出当前循环，进入下一循环
						repeatUser = append(repeatUser, item)
						continue
					}
					excelData[mobileOne] = ""
				}

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

	//defer func() {
	//	os.Remove(path)
	//}()
	br.Msg = "获取成功"
	br.Ret = 200
	br.Success = true
	br.Data = models.ImportListResp{
		ValidUser:  existUser,
		RepeatUser: repeatUser,
	}
}

// 需要更新的联系人数据实体
type UpdateWxUser struct {
	OldWxUser models.WxUser  `description:"旧的联系人数据orm实体（未变更前的）"`
	WxUser    *models.WxUser `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 /import [post]
func (this *CompanyUserController) 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
	}
	companyId, _ := this.GetInt("CompanyId")
	if companyId <= 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "客户id为0"
		return
	}
	//产品id
	productId := services.GetProductId(sysUser.RoleTypeCode)

	//操作权限校验
	errMsg, err := checkOpCompanyUserByCompanyId(companyId, productId, sysUser.AdminId, sysUser.RoleTypeCode)
	if err != nil {
		br.Msg = "导入失败！" + errMsg
		br.ErrMsg = "导入失败，Err:" + err.Error()
		return
	}
	//userBusinessCardCount := 0
	//if productId > 0 {
	//	tmpUserBusinessCardCount, err := models.GetCompanyUserBusinessCardCountByProductId(companyId, productId)
	//	if err != nil {
	//		br.Msg = "导入失败"
	//		br.ErrMsg = "判断是否已经存在上传名片联系人失败,err:" + err.Error()
	//		return
	//	}
	//	userBusinessCardCount = tmpUserBusinessCardCount
	//} else {
	//	tmpUserBusinessCardCount, err := company.GetCompanyUserBusinessCardCount(companyId)
	//	if err != nil {
	//		br.Msg = "导入失败"
	//		br.ErrMsg = "判断是否已经存在上传名片联系人失败,err:" + err.Error()
	//		return
	//	}
	//	userBusinessCardCount = tmpUserBusinessCardCount
	//}
	//
	//if userBusinessCardCount <= 0 {
	//	br.Msg = "请先至少添加一位名片联系人"
	//	return
	//}

	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()
		return
	}

	//获取当前操作员产品权限列表
	companyProductList, productErr := getSysCompanyProductList(productId, companyId)
	if productErr != nil {
		br.Msg = "新增失败"
		br.ErrMsg = "新增失败，获取当前操作员产品权限异常,Err:" + productErr.Error()
		return
	}
	if companyProductList == nil {
		br.Msg = "新增失败"
		br.ErrMsg = "新增失败，获取当前操作员找不到产品权限"
		return
	}

	//客户信息
	companyInfo, err := company.GetCompanyById(companyId)
	if err != nil {
		br.Msg = "导入异常"
		br.Msg = "导入异常：" + err.Error()
		return
	}

	//已存在联系人的切片
	existUser := make([]*company.CompanyUser, 0)
	//待添加销售员与联系人关系的切片
	notRelationUser := make([]map[int]*company.CompanyUser, 0)
	//允许添加的联系人
	needAddUser := make([]*models.WxUserDetail, 0)

	//excel中已经存在的数据，用来判断excel中是否存在相同手机号/邮箱，避免重复提交
	excelData := make(map[string]string)

	//需要更新的数据实体切片
	updateWxUserSlice := make([]UpdateWxUser, 0)

	// 遍历sheet页读取
	for _, sheet := range xlFile.Sheets {
		//遍历行读取
		maxRow := sheet.MaxRow
		for i := 0; i < maxRow; i++ {
			if i == 0 {
				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, "国际区号（中国大陆填写：86）") {
							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 >= 1 {
				row := sheet.Row(i)
				cells := row.Cells
				var userName, sex, countryCode, mobileOne, email, isMaker, position, departmentName string
				for k, cell := range cells {
					if k == 0 {
						userName = cell.String()
					}
					if k == 1 {
						sex = cell.String()
					}
					if k == 2 {
						countryCode = strings.Replace(cell.String(), "+", "", -1)
						countryCode = strings.Replace(countryCode, "-", "", -1)
						countryCode = strings.Replace(countryCode, " ", "", -1)
					}
					if k == 3 {
						mobileOne = cell.String()
					}
					if k == 4 {
						email = cell.String()
					}
					if k == 5 {
						isMaker = cell.String()
					}
					if k == 6 {
						position = cell.String()
					}
					if k == 7 {
						departmentName = cell.String()
					}
				}

				//移除空格
				mobileOne = utils.TrimStr(mobileOne)
				email = utils.TrimStr(email)

				//这些字段都没有的话，系统认为excel到底了
				if userName == "" && sex == "" && mobileOne == "" {
					break
				}

				if userName == "" {
					br.Msg = "导入数据中存在【姓名】为空的联系人，请检查"
					return
				}
				if sex == "" {
					br.Msg = "导入数据中存在【性别】为空的联系人，请检查"
					return
				}
				if mobileOne != "" && countryCode == "" {
					br.Msg = "导入数据中存在【国际区号】为空的联系人，请检查"
					return
				}
				// 大陆区号校验手机号
				if mobileOne != "" && (countryCode == "86" || countryCode == "086" || countryCode == "+86" || countryCode == "+086") {
					if !utils.ValidateMobileFormatat(mobileOne) {
						br.Msg = "导入数据中存在【大陆手机号】格式有误的联系人，请检查"
						return
					}
				}

				//如果手机号或者邮箱都没有填写的情况下
				if mobileOne == "" && email == "" {
					continue
				}
				//如果是权益，且是海外用户的情况下，那么手机号、邮箱有一个没有填写的情况下，那么退出当前循环
				if productId == 2 && companyInfo.RegionType == "海外" && (mobileOne == "" || email == "") {
					continue
				}
				if isMaker == "" {
					br.Msg = "导入数据中存在【决策人】为空的联系人，请检查"
					return
				}

				item := new(models.WxUserDetail)

				item.RealName = userName
				if sex == "男" {
					item.Sex = 1
				} else if sex == "女" {
					item.Sex = 2
				} else {
					item.Sex = 0
				}
				item.Mobile = mobileOne
				item.Email = email
				if isMaker == "是" {
					item.IsMaker = 1
				} else {
					item.IsMaker = 0
				}
				item.Position = position
				item.DepartmentName = departmentName
				item.SellerRealName = companyProductList[0].SellerName
				item.CompanyName = companyProductList[0].CompanyName

				var mobileOneItem, emailItem *company.CompanyUser
				var mobileNotRelationUserMap, emailNotRelationUserMap map[int]*company.CompanyUser

				//手机号校验
				if mobileOne != "" {
					if _, ok := excelData[mobileOne]; ok {
						br.Msg = "excel表数据异常，存在重复的手机号:" + mobileOne + "，请检查excel表格数据"
						br.ErrMsg = "excel表数据异常，存在重复的手机号:" + mobileOne + "，请检查excel表格数据"
						return
					}
					excelData[mobileOne] = ""

					tmpMobileOneItem, err := company.GetUserCountByMobile(mobileOne)
					if err != nil && err.Error() != utils.ErrNoRow() {
						br.Msg = "新增失败"
						br.ErrMsg = "判断手机号1是否存在,Err:" + err.Error()
						return
					}
					mobileOneItem = tmpMobileOneItem

					if mobileOneItem != nil {
						if mobileOneItem.UserId > 0 {
							hasMove := true //是否可移动

							//如果是大于 1 的客户，那么就是非潜在客户，需要去查询对应的销售
							if mobileOneItem.CompanyId > 1 {
								//获取联系人分组信息
								userSellerGroupInfoList, err := models.GetUserGroupSellersByUserId(int(mobileOneItem.UserId))

								//根据分组校验
								if err == nil && len(userSellerGroupInfoList) > 0 {
									sellerMap := make(map[int]string)    //销售信息map
									sellerNameSlice := make([]string, 0) //销售姓名切片
									for _, v := range userSellerGroupInfoList {
										if v.Status != utils.COMPANY_STATUS_LOSE && v.Status != utils.COMPANY_STATUS_FOREVER && hasMove == true {
											hasMove = false
										}
										if _, ok := sellerMap[v.SellerId]; ok {
											continue
										}
										sellerMap[v.SellerId] = v.SellerRealName
										sellerNameSlice = append(sellerNameSlice, v.SellerRealName)
									}
									mobileOneItem.SellerRealName = strings.Join(sellerNameSlice, "/")
								}
							}

							item.SellerRealName = mobileOneItem.SellerRealName

							item.CompanyName = mobileOneItem.CompanyName

							//判断该联系人的 客户企业编号 是否与 当前客户编号 一致，如果不一致，那么将该联系人加入到已经存在的联系人列表中去，并终止当前循环，进入下一循环。
							if mobileOneItem.CompanyId != companyId {
								mobileOneItem.HasMove = hasMove //是否可移动

								if hasMove {
									if mobileOneItem.RealName != item.RealName {
										mobileOneItem.RealName = item.RealName
									}
									if mobileOneItem.DepartmentName != item.DepartmentName {
										mobileOneItem.DepartmentName = item.DepartmentName
									}
									if mobileOneItem.RealName != item.RealName {
										mobileOneItem.RealName = item.RealName
									}
								}
								mobileOneItem.CountryCode = countryCode
								existUser = append(existUser, mobileOneItem)
								continue
							}

							//判断该用户与当前账号是否存在关系，如果没有关系，那么直接返回
							notRelationUserMap, checkErr := checkProductListUser(*item, mobileOneItem, companyProductList)
							//sql异常
							if checkErr != nil && checkErr.Error() != utils.ErrNoRow() {
								br.Msg = "新增失败"
								br.ErrMsg = "新增失败,Err:" + checkErr.Error()
								return
							}
							mobileNotRelationUserMap = notRelationUserMap
						}
					}
				}
				//邮箱校验
				if email != "" {
					if _, ok := excelData[email]; ok {
						br.Msg = "excel表数据异常，存在重复的邮箱:" + email + "，请检查excel表格数据"
						br.ErrMsg = "excel表数据异常，存在重复的邮箱:" + email + "，请检查excel表格数据"
						return
					}
					excelData[email] = ""

					tmpEmailItem, err := company.CheckCompanyUserCountByEmail(email)
					if err != nil && err.Error() != utils.ErrNoRow() {
						br.Msg = "新增失败"
						br.ErrMsg = "新增失败,Err:" + err.Error()
						return
					}
					emailItem = tmpEmailItem
					if emailItem != nil {
						if emailItem.UserId > 0 {
							hasMove := true //是否可移动

							//如果是大于 1 的客户，那么就是非潜在客户，需要去查询对应的销售
							if emailItem.CompanyId > 1 {
								//获取联系人分组信息
								userSellerGroupInfoList, err := models.GetUserGroupSellersByUserId(int(emailItem.UserId))

								//根据分组校验
								if err == nil && len(userSellerGroupInfoList) > 0 {
									sellerMap := make(map[int]string)    //销售信息map
									sellerNameSlice := make([]string, 0) //销售姓名切片
									for _, v := range userSellerGroupInfoList {
										if v.Status != utils.COMPANY_STATUS_LOSE && v.Status != utils.COMPANY_STATUS_FOREVER && hasMove == true {
											hasMove = false
										}
										if _, ok := sellerMap[v.SellerId]; ok {
											continue
										}
										sellerMap[v.SellerId] = v.SellerRealName
										sellerNameSlice = append(sellerNameSlice, v.SellerRealName)
									}
									emailItem.SellerRealName = strings.Join(sellerNameSlice, "/")
								}
							}

							item.SellerRealName = emailItem.SellerRealName

							item.CompanyName = emailItem.CompanyName

							//判断该联系人的 客户企业编号 是否与 当前客户编号 一致，如果不一致，那么将该联系人加入到已经存在的联系人列表中去，并终止当前循环，进入下一循环。
							if emailItem.CompanyId != companyId {
								emailItem.HasMove = hasMove //是否可移动

								if hasMove {
									if emailItem.RealName != item.RealName {
										emailItem.RealName = item.RealName
									}
									if emailItem.DepartmentName != item.DepartmentName {
										emailItem.DepartmentName = item.DepartmentName
									}
									if emailItem.RealName != item.RealName {
										emailItem.RealName = item.RealName
									}
								}
								emailItem.CountryCode = countryCode
								existUser = append(existUser, emailItem)
								continue
							}

							//判断该用户与当前账号是否存在关系，如果没有关系，那么直接返回
							notRelationUserMap, checkErr := checkProductListUser(*item, emailItem, companyProductList)
							//sql异常
							if checkErr != nil && checkErr.Error() != utils.ErrNoRow() {
								br.Msg = "新增失败"
								br.ErrMsg = "新增失败,Err:" + checkErr.Error()
								return
							}
							//判断该用户与销售是否存在关系，如果不存在，那么加入到 待添加关系 的切片中
							emailNotRelationUserMap = notRelationUserMap
						}
					}
				}

				//如果系统已存在该联系人，那么逻辑处理后退出当前循环，进入下一循环
				if mobileOneItem != nil || emailItem != nil {
					//如果既存在该手机号联系人，也存在该邮箱联系人；那么需要去判断 这 两个 联系人 是不是同一个，
					//如果不是同一个联系人的话，那么只添加对应的关系，不去修改对应的数据
					var wxUserItem *models.WxUser
					var oldTmpWxUserItem models.WxUser
					cols := make([]string, 0)

					if mobileOneItem != nil && emailItem != nil {
						//如果两个联系人 不是 同一个
						if mobileOneItem.UserId != emailItem.UserId {
							notRelationUser = append(notRelationUser, mobileNotRelationUserMap, emailNotRelationUserMap)
							//wxUserItem = mobileOneItem
						} else {
							//如果两个联系人 是 同一个
							notRelationUser = append(notRelationUser, mobileNotRelationUserMap)

							tmpWxUserItem, err := models.GetWxUserByUserId(int(mobileOneItem.UserId))
							if err != nil {
								br.Msg = "导入失败"
								br.ErrMsg = "查询联系人信息失败,Err:" + err.Error()
								return
							}
							oldTmpWxUserItem := *tmpWxUserItem
							if tmpWxUserItem.IsMaker != item.IsMaker {
								tmpWxUserItem.IsMaker = item.IsMaker
								cols = append(cols, "IsMaker")
							}
							if tmpWxUserItem.DepartmentName != item.DepartmentName {
								tmpWxUserItem.DepartmentName = item.DepartmentName
								cols = append(cols, "DepartmentName")
							}
							if tmpWxUserItem.RealName != item.RealName {
								tmpWxUserItem.RealName = item.RealName
								cols = append(cols, "RealName")
							}
							if len(cols) > 0 {
								updateWxUser := UpdateWxUser{
									OldWxUser: oldTmpWxUserItem,
									WxUser:    tmpWxUserItem,
									Cols:      cols,
								}
								updateWxUserSlice = append(updateWxUserSlice, updateWxUser)
							}
							wxUserItem = tmpWxUserItem
						}
					} else if mobileOneItem != nil {
						//如果只存在 手机号联系人
						notRelationUser = append(notRelationUser, mobileNotRelationUserMap)

						//获取联系人orm实体类
						tmpWxUserItem, err := models.GetWxUserByUserId(int(mobileOneItem.UserId))
						if err != nil {
							br.Msg = "导入失败"
							br.ErrMsg = "查询联系人信息失败,Err:" + err.Error()
							return
						}
						oldTmpWxUserItem = *tmpWxUserItem
						if tmpWxUserItem.IsMaker != item.IsMaker {
							tmpWxUserItem.IsMaker = item.IsMaker
							cols = append(cols, "IsMaker")
						}
						if tmpWxUserItem.DepartmentName != item.DepartmentName && item.DepartmentName != "" {
							tmpWxUserItem.DepartmentName = item.DepartmentName
							cols = append(cols, "DepartmentName")
						}
						if tmpWxUserItem.RealName != item.RealName && item.RealName != "" {
							tmpWxUserItem.RealName = item.RealName
							cols = append(cols, "RealName")
						}
						if tmpWxUserItem.Email != item.Email && item.Email != "" {
							tmpWxUserItem.Email = item.Email
							cols = append(cols, "Email")
						}
						wxUserItem = tmpWxUserItem
					} else if emailItem != nil {
						//如果只存在 邮箱联系人
						notRelationUser = append(notRelationUser, emailNotRelationUserMap)

						//获取联系人orm实体类
						tmpWxUserItem, err := models.GetWxUserByUserId(int(emailItem.UserId))
						if err != nil {
							br.Msg = "导入失败"
							br.ErrMsg = "查询联系人信息失败,Err:" + err.Error()
							return
						}
						oldTmpWxUserItem = *tmpWxUserItem
						if tmpWxUserItem.IsMaker != item.IsMaker {
							tmpWxUserItem.IsMaker = item.IsMaker
							cols = append(cols, "IsMaker")
						}
						if tmpWxUserItem.DepartmentName != item.DepartmentName && item.DepartmentName != "" {
							tmpWxUserItem.DepartmentName = item.DepartmentName
							cols = append(cols, "DepartmentName")
						}
						if tmpWxUserItem.RealName != item.RealName && item.RealName != "" {
							tmpWxUserItem.RealName = item.RealName
							cols = append(cols, "RealName")
						}
						if tmpWxUserItem.Email != item.Email && item.Email != "" {
							tmpWxUserItem.Email = item.Email
							cols = append(cols, "Email")
						}
						wxUserItem = tmpWxUserItem
					}

					//如果变更字段数量大于0
					if len(cols) > 0 {
						updateWxUser := UpdateWxUser{
							OldWxUser: oldTmpWxUserItem,
							WxUser:    wxUserItem,
							Cols:      cols,
						}
						updateWxUserSlice = append(updateWxUserSlice, updateWxUser)
					}
					continue
				}

				//确实系统中不存在该用户
				item.CountryCode = countryCode
				needAddUser = append(needAddUser, item)
			}
		}
	}

	fmt.Println("表格中用户与系统中存在用户没有冲突")
	//如果表格中用户与系统中存在用户 没有冲突，那么继续执行
	for _, user := range needAddUser {
		if user.RealName != "" && (user.Mobile != "" || user.Email != "") {
			userData := new(models.WxUser)
			userData.RealName = user.RealName
			userData.Sex = user.Sex
			userData.Mobile = user.Mobile
			userData.CountryCode = user.CountryCode
			userData.OutboundMobile = user.Mobile
			userData.OutboundCountryCode = user.CountryCode
			userData.Email = user.Email
			userData.Position = user.Position
			userData.IsMaker = user.IsMaker
			userData.CompanyId = companyId
			userData.DepartmentName = user.DepartmentName
			userData.CountryCode = user.CountryCode

			//判断该手机号、邮箱是否已经添加，如果已经添加，那么就不再添加
			var key string
			if user.Mobile != "" {
				key = "wx_user:mobile:" + userData.Mobile
			} else {
				key = "wx_user:email:" + userData.Email
			}
			isHas := utils.Rc.IsExist(key)
			if isHas == false {
				newId, err := models.AddWxUser(userData)
				userData.UserId = newId
				if err != nil {
					br.Msg = "导入失败"
					br.ErrMsg = "导入失败,Err:" + err.Error()
					return
				}
				//添加联系人与销售员的关系
				for _, companyProduct := range companyProductList {
					models.AddUserSellerRelation(newId, companyProduct.CompanyId, companyProduct.SellerId, companyProduct.ProductId, companyProduct.SellerName, user.Mobile, user.Email)
				}

				//联系人信息
				userInfo, _ := json.Marshal(userData)
				go services.AddWxUserOpLog(company.WxUserOpLog{
					LogType:                "import",
					UserId:                 int(userData.UserId),
					CompanyId:              userData.CompanyId,
					Mobile:                 userData.Mobile,
					Email:                  userData.Email,
					OriginalUserInfo:       "",
					UserInfo:               string(userInfo),
					OriginalUserSellerInfo: "",
					UserSellerInfo:         "",
					OpUserId:               sysUser.AdminId,
					OpUserName:             sysUser.RealName,
					CreateTime:             time.Now(),
				})
			}
		}
	}

	//添加已经存在的联系人与销售员关系
	fmt.Println("开始添加已经存在的联系人与销售员关系")
	for _, notRelationUserMap := range notRelationUser {
		if item, ok := notRelationUserMap[1]; ok {
			//添加联系人与销售员的关系
			mobileOne := item.Mobile
			mobileTwo := item.MobileTwo
			email := item.Email
			businessCardUrl := item.BusinessCardUrl
			//对老数据做新增字段处理
			_ = company.EditCompanyUserContact(item.UserId, mobileOne, mobileTwo, email, businessCardUrl)

			models.AddUserSellerRelation(item.UserId, item.CompanyId, item.SellerId, 1, item.SellerName, item.Mobile, item.Email)
		}

		if item, ok := notRelationUserMap[2]; ok {
			//添加联系人与销售员的关系
			mobileOne := item.Mobile
			mobileTwo := item.MobileTwo
			email := item.Email
			businessCardUrl := item.BusinessCardUrl
			//对老数据做新增字段处理
			_ = company.EditCompanyUserContact(item.UserId, mobileOne, mobileTwo, email, businessCardUrl)

			models.AddUserSellerRelation(item.UserId, item.CompanyId, item.SellerId, 2, item.SellerName, item.Mobile, item.Email)
		}
	}

	fmt.Println("开始更新联系人信息")
	for _, updateWxUser := range updateWxUserSlice {
		_ = updateWxUser.WxUser.Update(updateWxUser.Cols)

		//联系人信息
		originalUserInfo, _ := json.Marshal(updateWxUser.OldWxUser)
		userInfo, _ := json.Marshal(updateWxUser.WxUser)
		go services.AddWxUserOpLog(company.WxUserOpLog{
			LogType:                "import",
			UserId:                 int(updateWxUser.WxUser.UserId),
			CompanyId:              updateWxUser.WxUser.CompanyId,
			Mobile:                 updateWxUser.WxUser.Mobile,
			Email:                  updateWxUser.WxUser.Email,
			OriginalUserInfo:       string(originalUserInfo),
			UserInfo:               string(userInfo),
			OriginalUserSellerInfo: "",
			UserSellerInfo:         "",
			OpUserId:               sysUser.AdminId,
			OpUserName:             sysUser.RealName,
			CreateTime:             time.Now(),
		})
	}

	defer func() {
		os.Remove(path)
	}()

	if len(existUser) > 0 {
		br.Ret = 600
		br.Msg = "系统中已存在用户"
		br.IsSendEmail = false
		br.Data = existUser
		return
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{companyId})

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

// @Title 客户的联系人导出
// @Description 客户的联系人导出接口
// @Param   CompanyId   query   int  true       "公司id，必填"
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success 200 {object} company.CompanyUserListResp
// @router /user/exportByCompanyId [get]
func (this *CompanyUserController) Export() {
	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
	}
	companyId, _ := this.GetInt("CompanyId")
	keyWord := utils.TrimStr(this.GetString("KeyWord"))

	if companyId <= 0 {
		br.Msg = "请选择客户"
		br.ErrMsg = "客户参数错误"
		return
	}

	var startSize int

	var condition string
	var pars []interface{}

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

	//非管理员，那么只能看到该产品下的联系人
	if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
		productId := services.GetProductId(sysUser.RoleTypeCode)
		condition += ` AND b.product_id = ? `
		pars = append(pars, productId)
	}

	list, err := company.GetCompanyUserListV2(condition, pars, companyId, startSize, 100000)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}

	//获取企业客户信息
	companyInfo, err := company.GetCompanyById(companyId)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取客户信息失败，Err:" + err.Error()
		return
	}

	lenList := len(list)
	if lenList > 0 {
		userIdSlice := make([]string, 0)
		mobilesSlice := make([]string, 0)
		emailsSlice := make([]string, 0)
		for _, v := range list {
			userIdSlice = append(userIdSlice, strconv.Itoa(int(v.UserId)))
			if v.Mobile != "" {
				mobilesSlice = append(mobilesSlice, v.Mobile)
			} else if v.Email != "" {
				emailsSlice = append(emailsSlice, v.Email)
			}
		}

		//用户浏览数据
		userIdStr := strings.Join(userIdSlice, ",")
		mobileStr := strings.Join(mobilesSlice, "','")
		mobileStr = "'" + mobileStr + "'"
		emailStr := strings.Join(emailsSlice, "','")
		emailStr = "'" + emailStr + "'"

		//userViewTotalList, _ := models.GetCountUserViewHistoryByUserIds(userIdStr)
		//userViewTotalMap := make(map[int]*models.UserViewTotalSlice)
		//for _, userView := range userViewTotalList {
		//	userViewTotalMap[userView.UserId] = userView
		//}

		//用户日评浏览数据
		//userReportViewTotalList, _ := models.GetReportViewMaxTimeByUserIds(userIdStr)
		//userReportViewTotalMap := make(map[int]*models.ReportViewRecord)
		//for _, userReportView := range userReportViewTotalList {
		//	userReportViewTotalMap[userReportView.UserId] = userReportView
		//}

		//报告统计删除晨报部分统计加入每日资讯 2021-4-9
		//手机号
		userViewMobileTotalMap := make(map[string]*models.UserViewMobileTotalSlice)
		userReportViewMobileTotalMap := make(map[string]*models.ReportViewMobileRecord)
		userAdvisoryViewMobileTotalMap := make(map[string]*advisory.UserViewMobileTotalSlice)
		userCygxArticleHistoryRecordViewMobileTotalMap := make(map[string]*models.UserViewMobileTotalSlice)
		if len(mobilesSlice) > 0 {
			//用户浏览数据
			userViewMobileTotalList, _ := models.GetCountUserViewHistoryByMobiles(mobileStr)
			for _, userViewMobile := range userViewMobileTotalList {
				userViewMobileTotalMap[userViewMobile.Mobile] = userViewMobile
			}

			//每日点评手机号数据
			userReportViewMobileTotalList, _ := models.GetReportViewMaxTimeByMobiles(mobileStr)
			for _, userReportViewMobile := range userReportViewMobileTotalList {
				userReportViewMobileTotalMap[userReportViewMobile.Mobile] = userReportViewMobile
			}

			//每日资讯
			userAdvisoryViewMobileTotalList, _ := advisory.GetCountUserViewHistoryByMobiles(mobileStr)
			//fmt.Println(userAdvisoryViewMobileTotalList)
			for _, userAdvisoryViewMobile := range userAdvisoryViewMobileTotalList {
				userAdvisoryViewMobileTotalMap[userAdvisoryViewMobile.Mobile] = userAdvisoryViewMobile
			}
			//查研观向
			userCygxArticleHistoryRecordViewMobileTotalList, _ := models.GetCountCygxArticleHistoryRecordByMobiles(mobileStr)
			for _, userCygxArticleHistoryRecordViewMobile := range userCygxArticleHistoryRecordViewMobileTotalList {
				userCygxArticleHistoryRecordViewMobileTotalMap[userCygxArticleHistoryRecordViewMobile.Mobile] = userCygxArticleHistoryRecordViewMobile
			}
		}

		//邮箱
		userViewEmailTotalMap := make(map[string]*models.UserViewEmailTotalSlice)
		userReportViewEmailTotalMap := make(map[string]*models.ReportViewEmailRecord)
		userAdvisoryViewEmailTotalMap := make(map[string]*advisory.UserViewEmailTotalSlice)
		userCygxViewEmailTotalMap := make(map[string]*models.UserViewEmailTotalSlice)
		if len(emailsSlice) > 0 {
			//用户浏览数据
			userViewEmailTotalList, _ := models.GetCountUserViewHistoryByEmails(emailStr)
			for _, userViewEmail := range userViewEmailTotalList {
				userViewEmailTotalMap[userViewEmail.Email] = userViewEmail
			}
			//每日点评手机号数据
			userReportViewEmailTotalList, _ := models.GetReportViewMaxTimeByEmails(emailStr)
			for _, userReportViewEmail := range userReportViewEmailTotalList {
				userReportViewEmailTotalMap[userReportViewEmail.Email] = userReportViewEmail
			}
			//每日资讯
			userAdvisoryViewEmailTotalList, _ := advisory.GetCountUserViewHistoryByEmails(emailStr)
			for _, userAdvisoryViewEmail := range userAdvisoryViewEmailTotalList {
				userAdvisoryViewEmailTotalMap[userAdvisoryViewEmail.Email] = userAdvisoryViewEmail
			}
			//查研观向
			userCygxViewEmailTotalList, _ := models.GetCountCygxArticleHistoryRecordByEmails(emailStr)
			for _, userCygxReportViewEmail := range userCygxViewEmailTotalList {
				userCygxViewEmailTotalMap[userCygxReportViewEmail.Email] = userCygxReportViewEmail
			}
		}

		//获取联系人关联产品的条数
		//userSellerRelationTotalSlice, err := models.GetUserSellerRelationCountByUserIds(userIdStr)
		//if err != nil {
		//	br.Msg = "获取失败"
		//	br.ErrMsg = "获取联系人与销售员信息失败，Err:" + err.Error()
		//	return
		//}
		//userSellerRelationTotalMap := make(map[int]*models.UserSellerRelationSlice)
		//for _, userSellerRelationTotal := range userSellerRelationTotalSlice {
		//	userSellerRelationTotalMap[userSellerRelationTotal.UserId] = userSellerRelationTotal
		//}

		userRecordRegisterMap := make(map[int]time.Time)
		if len(userIdSlice) > 0 {
			//用户绑定注册数据
			userRecordRegisterList, _ := models.GetUserRecordRegisterByUserIds(userIdStr)
			for _, userRecordRegister := range userRecordRegisterList {
				userRecordRegisterMap[userRecordRegister.UserId] = userRecordRegister.CreateTime
			}
		}
		for i := 0; i < lenList; i++ {
			item := list[i]
			//企业名称
			list[i].CompanyName = companyInfo.CompanyName
			//手机号用户累计浏览次数
			if userView, ok := userViewMobileTotalMap[item.Mobile]; ok {
				list[i].ViewTotal += userView.Total
				if userView.CreatedTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = userView.CreatedTime
					list[i].LastViewTimeStr = userView.CreatedTime.Format(utils.FormatDateTime)
				}
			}
			//邮箱用户累计浏览次数
			if userView, ok := userViewEmailTotalMap[item.Email]; ok {
				//总共浏览的报表数据需要调整为（手机号用户浏览晨报数+邮箱号用户浏览晨报数）
				list[i].ViewTotal += userView.Total
				if userView.CreatedTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = userView.CreatedTime
					list[i].LastViewTimeStr = userView.CreatedTime.Format(utils.FormatDateTime)
				}
			}

			if item.OpenId != "" {
				list[i].IsRegister = true
			} else {
				if item.RegisterPlatform == 2 {
					if item.Mobile != "" || item.Email != "" {
						list[i].IsRegister = true
					}
				} else if item.RegisterTime != "" {
					list[i].IsRegister = true
				} else {
					list[i].IsRegister = false
				}
			}
			//如果存在手机号用户日评数据，那么需要做处理
			if reportView, ok := userReportViewMobileTotalMap[item.Mobile]; ok {
				//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
				if reportView.LastViewTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = reportView.LastViewTime
					list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
				list[i].ViewTotal += reportView.ViewTotal
			}
			//如果存在手机号用户日评数据，那么需要做处理
			if reportView, ok := userReportViewEmailTotalMap[item.Email]; ok {
				//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
				if reportView.LastViewTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = reportView.LastViewTime
					list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
				list[i].ViewTotal += reportView.ViewTotal
			}

			//如果存在手机号用户每日资讯，那么需要做处理
			if advisoryView, ok := userAdvisoryViewMobileTotalMap[item.Mobile]; ok {
				//fmt.Println("蝴蝶眨几次眼睛")
				//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
				if advisoryView.CreatedTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = advisoryView.CreatedTime
					list[i].LastViewTimeStr = advisoryView.CreatedTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数）
				list[i].ViewTotal += advisoryView.Total
			}
			//如果存在邮箱号用户每日资讯，那么需要做处理
			if advisoryView, ok := userAdvisoryViewEmailTotalMap[item.Email]; ok {
				//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
				if advisoryView.CreatedTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = advisoryView.CreatedTime
					list[i].LastViewTimeStr = advisoryView.CreatedTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数）
				list[i].ViewTotal += advisoryView.Total
			}

			//如果存在手机号用户查研观向，那么需要做处理
			if cygxView, ok := userCygxArticleHistoryRecordViewMobileTotalMap[item.Mobile]; ok {
				//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
				if cygxView.CreatedTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = cygxView.CreatedTime
					list[i].LastViewTimeStr = cygxView.CreatedTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数+查研观向）
				list[i].ViewTotal += cygxView.Total
			}
			//如果存在邮箱号用户查研观向，那么需要做处理
			if cygxView, ok := userCygxViewEmailTotalMap[item.Email]; ok {
				//对每日资讯数据做校验，每日资讯时间晚日评报时间，那么将最近一次浏览时间替换
				if cygxView.CreatedTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = cygxView.CreatedTime
					list[i].LastViewTimeStr = cygxView.CreatedTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数+每日资讯数+查研观向）
				list[i].ViewTotal += cygxView.Total
			}
			/*if reportView, ok := userReportViewTotalMap[int(item.UserId)]; ok {
				//对日评数据做校验，日评时间晚于晨报时间，那么将最近一次浏览时间替换
				if reportView.LastViewTime.After(list[i].LastViewTime) {
					list[i].LastViewTime = reportView.LastViewTime
					list[i].LastViewTimeStr = reportView.LastViewTime.Format(utils.FormatDateTime)
				}
				//总共浏览的报表数据需要调整为（浏览晨报数+浏览日评数）
				list[i].ViewTotal += reportView.ViewTotal
			}*/

			//如果有绑定数据，那么将数据返回对应的注册绑定数据
			if _, ok := userRecordRegisterMap[int(item.UserId)]; ok {
				list[i].IsRegister = true
				//list[i].RegisterTime = userRecordRegisterTime.Format(utils.FormatDateTime)
			}
			//是否共享联系人
			//if userSellerRelationTotal, ok := userSellerRelationTotalMap[int(item.UserId)]; ok {
			//	//条数大于1，代表这是共享联系人
			//	if userSellerRelationTotal.Total > 1 {
			//		list[i].IsShared = true
			//	}
			//}
		}
	}

	dir, err := os.Executable()
	exPath := filepath.Dir(dir)
	downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
	xlsxFile := xlsx.NewFile()
	if err != nil {
		br.Msg = "生成文件失败"
		br.ErrMsg = "生成文件失败"
		return
	}
	style := xlsx.NewStyle()
	alignment := xlsx.Alignment{
		Horizontal: "center",
		Vertical:   "center",
		WrapText:   true,
	}

	style.Alignment = alignment
	style.ApplyAlignment = true

	sheel, err := xlsxFile.AddSheet("联系人数据")
	if err != nil {
		br.Msg = "新增Sheet失败"
		br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
		return
	}
	sheel.SetColWidth(0, 0, 18)
	sheel.SetColWidth(1, 2, 24)
	sheel.SetColWidth(3, 3, 20)
	sheel.SetColWidth(4, 4, 40)

	titleRow := sheel.AddRow()

	cellName := titleRow.AddCell()
	cellName.SetStyle(style)
	cellName.SetValue("姓名")

	cellMobile := titleRow.AddCell()
	cellMobile.SetStyle(style)
	cellMobile.SetValue("手机号")

	cellEmail := titleRow.AddCell()
	cellEmail.SetStyle(style)
	cellEmail.SetValue("邮箱")

	cellMark := titleRow.AddCell()
	cellMark.SetStyle(style)
	cellMark.SetValue("是否决策人")

	cellCompanyName := titleRow.AddCell()
	cellCompanyName.SetStyle(style)
	cellCompanyName.SetValue("客户名称")

	for _, v := range list {
		dataRow := sheel.AddRow()
		dataRow.SetHeight(20)

		isMark := "否"
		if v.IsMaker == 1 {
			isMark = "是"
		}

		cellDataName := dataRow.AddCell()
		cellDataName.SetStyle(style)
		cellDataName.SetValue(v.RealName)

		cellDataMobile := dataRow.AddCell()
		cellDataMobile.SetStyle(style)
		cellDataMobile.SetValue(v.Mobile)

		cellDataEmail := dataRow.AddCell()
		cellDataEmail.SetStyle(style)
		cellDataEmail.SetValue(v.Email)

		cellDataMark := dataRow.AddCell()
		cellDataMark.SetStyle(style)
		cellDataMark.SetValue(isMark)

		cellDataCompanyName := dataRow.AddCell()
		cellDataCompanyName.SetStyle(style)
		cellDataCompanyName.SetValue(companyInfo.CompanyName)

	}
	err = xlsxFile.Save(downLoadnFilePath)
	if err != nil {
		br.Msg = "保存文件失败"
		br.ErrMsg = "保存文件失败"
		return
	}
	randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
	downloadFileName := "联系人列表_" + randStr + ".xlsx"
	this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
	defer func() {
		os.Remove(downLoadnFilePath)
	}()
	br.Ret = 200
	br.Success = true
	br.Msg = "导出成功"
}

// 检测产品
func checkProductListUser(item models.WxUserDetail, companyUser *company.CompanyUser, companyProductList []*company.CompanyProduct) (notRelationUserMap map[int]*company.CompanyUser, err error) {
	notRelationUserMap = make(map[int]*company.CompanyUser)
	//判断该用户与当前账号是否存在关系，如果没有关系，那么直接返回
	for _, companyProduct := range companyProductList {
		_, relationErr := models.GetUserSellerRelation(companyUser.UserId, companyProduct.SellerId)
		//找到数据了
		if relationErr == nil {
			continue
		}

		//sql异常
		if relationErr.Error() != utils.ErrNoRow() {
			err = relationErr
			return
		}

		//没找到数据，不存在关系
		//如果不存在关系，那么直接添加关系就好了，其他操作不做
		if relationErr.Error() == utils.ErrNoRow() {
			if item.Mobile != "" && companyUser.Mobile == "" {
				companyUser.Mobile = strings.Replace(item.Mobile, " ", "", -1)
			}
			if item.Email != "" && companyUser.Email == "" {
				companyUser.Email = strings.Replace(companyUser.Email, " ", "", -1)
			}
			companyUser.SellerId = companyProduct.SellerId
			companyUser.SellerName = companyProduct.SellerName
			companyUser.DepartmentId = companyProduct.DepartmentId
			companyUser.GroupId = companyProduct.GroupId

			notRelationUserMap[companyProduct.ProductId] = companyUser
		}
	}
	return
}

// @Title 下载模板
// @Description 下载模板
// @Success 200
// @router /template [get]
func (this *CompanyUserController) TemplateDownload() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	this.Ctx.Output.Download("./static/导入联系人模板.xlsx", "导入联系人模板.xlsx")
	br.Ret = 200
	br.Success = true
	br.Msg = "下载成功"
}

//百度
//func init() {
//	fmt.Println("start")
//	businessCardUrl := `https://hongze.oss-accelerate.aliyuncs.com/static/images/202101/20210111/wB3ELOuH8AxTvrIDXHaFTn9Z0WXB.jpg`
//	services.GetBdGeneralBasic(businessCardUrl)
//	fmt.Println("end")
//}

//阿里云
//func init() {
//	fmt.Println("start")
//	businessCardUrl := `https://hongze.oss-accelerate.aliyuncs.com/static/images/202101/20210111/wB3ELOuH8AxTvrIDXHaFTn9Z0WXB.jpg`
//	aliyunResult, err := services.AliyunBusinessCardOcr(businessCardUrl)
//
//	if err != nil {
//		fmt.Println("line 1026")
//		return
//	}
//	if !aliyunResult.Success {
//		fmt.Println("line 1026")
//		return
//	}
//
//	mobileStr := strings.Join(aliyunResult.TelCell, ",")
//	mobileOne:="18366208402"
//	if strings.Contains(mobileStr, mobileOne) {
//		fmt.Println("true")
//	} else {
//		fmt.Println("false")
//	}
//	fmt.Println("end")
//}

// 获取是否拥有操作权限
func checkOpCompanyUserByUserId(userId, productId, opId int, roleTypeCode string) (errMsg string, err error) {
	userInfo, userErr := models.GetWxUserByUserId(userId)
	if userErr != nil {
		errMsg = "查询用户信息失败"
		err = errors.New("查询用户信息失败，Err:" + userErr.Error())
		return
	}
	//产品权限

	//获取当前操作员产品权限
	companyProductList, productErr := getSysCompanyProductList(productId, userInfo.CompanyId)
	if productErr != nil {
		errMsg = "获取当前操作员产品权限异常"
		err = errors.New("删除失败，获取当前操作员产品权限异常，Err:" + productErr.Error())
		return
	}
	if companyProductList == nil {
		errMsg = "删除失败"
		err = errors.New("删除失败，获取当前操作员找不到产品权限")
		return
	}

	//操作权限校验
	for _, v := range companyProductList {
		companyUserStatus := services.CheckCompanyUserButton(roleTypeCode, v.SellerId, opId, v.ProductId, v.ShareSellerId, v.Status)
		if companyUserStatus == false {
			errMsg = "没有操作权限"
			err = errors.New("没有操作权限")
			return
		}
	}
	return
}

// 获取是否拥有操作权限
func checkOpCompanyUserByCompanyId(companyId, productId, opId int, roleTypeCode string) (errMsg string, err error) {
	//获取当前操作员产品权限
	companyProductList, productErr := getSysCompanyProductList(productId, companyId)
	if productErr != nil {
		errMsg = "获取当前操作员产品权限异常"
		err = errors.New("删除失败，获取当前操作员产品权限异常，Err:" + productErr.Error())
		return
	}
	if companyProductList == nil {
		errMsg = "删除失败"
		err = errors.New("删除失败，获取当前操作员找不到产品权限")
		return
	}
	//操作权限校验
	for _, v := range companyProductList {
		companyUserStatus := services.CheckCompanyUserButton(roleTypeCode, v.SellerId, opId, v.ProductId, v.ShareSellerId, v.Status)
		if companyUserStatus == false {
			errMsg = "没有操作权限"
			err = errors.New("没有操作权限")
			return
		}
	}
	return
}

// @Title FICC申请单-移动潜在用户
// @Description FICC申请单移动潜在用户接口
// @Param	request	body models.ApplyRecordPotentialUserMoveReq true "type json string"
// @Success Ret=200 移动成功
// @router /potential/user/moveByApplyRecord [post]
func (this *CompanyController) ApplyRecordPotentialUserMove() {
	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.ApplyRecordPotentialUserMoveReq
	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 = "参数错误"
		br.ErrMsg = "客户id错误"
		return
	}
	wxUser, err := models.GetWxUserByUserId(req.UserId)

	//如果移动客户编号小于等于0，那么移动到潜在客户
	if req.CompanyId <= 0 {
		req.CompanyId = 1
	}

	if err != nil {
		br.Msg = "移动失败，该潜在用户已被删除"
		br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
		return
	}
	if req.Mobile == "" {
		req.Mobile = wxUser.Mobile
	}
	if req.Email == "" {
		req.Email = wxUser.Email
	}
	if req.Mobile == "" && req.Email == "" {
		br.Msg = "手机号和邮箱不能同时为空"
		return
	}
	//校验手机号
	if req.Mobile != "" && wxUser.Mobile != req.Mobile {
		count, err := models.CheckUserMobileIsRegister(req.UserId, req.Mobile)
		if err != nil {
			br.Msg = "校验数据失败"
			br.ErrMsg = "校验数据失败，Err:" + err.Error()
			return
		}
		if count > 0 {
			br.Msg = "该手机号已经注册过用户"
			return
		}
	}
	//校验邮箱
	if req.Email != "" && wxUser.Email != req.Email {
		if !utils.ValidateEmailFormatat(req.Email) {
			br.Msg = "请输入正确的邮箱（包含@）"
			return
		}
		count, err := models.CheckUserEmailIsRegister(req.UserId, req.Email)
		if err != nil {
			br.Msg = "校验数据失败"
			br.ErrMsg = "校验数据失败，Err:" + err.Error()
			return
		}
		if count > 0 {
			br.Msg = "该邮箱已经注册过用户"
			br.IsSendEmail = false
			return
		}
	}

	updateCol := make([]string, 0)

	if wxUser.OutboundMobile == "" || wxUser.Mobile == wxUser.OutboundMobile {
		wxUser.OutboundMobile = req.Mobile
		wxUser.OutboundCountryCode = req.CountryCode
		updateCol = append(updateCol, "OutboundMobile", "OutboundCountryCode")
	}
	if req.Email != "" {
		wxUser.Email = req.Email
		updateCol = append(updateCol, "Email")
	}
	if req.RealName != "" {
		wxUser.RealName = req.RealName
		updateCol = append(updateCol, "RealName")
	}
	if req.Mobile != "" {
		wxUser.Mobile = req.Mobile
		updateCol = append(updateCol, "Mobile")
	}
	if req.CountryCode != "" {
		wxUser.CountryCode = req.CountryCode
		updateCol = append(updateCol, "CountryCode")
	}
	if req.Position != "" {
		wxUser.Position = req.Position
		updateCol = append(updateCol, "Position")
	}
	if wxUser.DepartmentName == "" && req.DepartmentName != "" {
		wxUser.DepartmentName = req.DepartmentName
		updateCol = append(updateCol, "DepartmentName")
	}
	wxUser.Sex = req.Sex
	wxUser.IsMaker = req.IsMaker
	updateCol = append(updateCol, "Sex", "IsMaker")

	//名片匹配
	if req.BusinessCardUrl != "" {
		//if req.BusinessCardUrl != "" && utils.RunMode == "release" {
		// 获取图片识别手机号的配置
		crmConfig2, err := company.GetConfigDetailByCode("card_recognition_tel")
		if err != nil {
			br.Msg = "获取配置失败"
			br.ErrMsg = "获取配置失败"
			br.IsSendEmail = false
			return
		}
		if crmConfig2.ConfigValue == "true" {
			card, err := services.GetBusinessCard(req.BusinessCardUrl)
			if err != nil {
				br.Msg = "名片识别失败"
				br.ErrMsg = "名片识别失败,Err:" + err.Error()
				return
			}
			isFlag := false
			if len(card.WordsResult.MOBILE) > 0 {
				mobileStr := strings.Join(card.WordsResult.MOBILE, ",")
				//if req.Mobile != "" {
				//	if strings.Contains(mobileStr, req.Mobile) || mobileStr == "" {
				//		isFlag = true
				//	} else {
				//		isFlag = false
				//	}
				//}

				if req.Mobile != "" && strings.Contains(mobileStr, req.Mobile) {
					isFlag = true
				}
			}

			if !isFlag {
				//阿里云识别
				//if utils.RunMode == "release" {
				aliyunResult, errMsg, err := services.AliyunOcrBusinessCard(req.BusinessCardUrl)
				if err != nil {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败,Err:" + err.Error()
					return
				}
				if !aliyunResult.Success {
					br.Msg = "识别失败"
					br.ErrMsg = "识别失败"
					return
				}
				if errMsg != "" {
					br.Msg = errMsg
					return
				}
				if len(aliyunResult.TelCell) > 0 {
					mobileStr := strings.Join(aliyunResult.TelCell, ",")
					if req.Mobile != "" {
						if strings.Contains(mobileStr, req.Mobile) {
							isFlag = true
						} else {
							isFlag = false
						}
					}
				} else {
					isFlag = true
				}
				//}
			}

			if !isFlag && crmConfig2.ConfigValue == "true" {
				br.Msg = "名片信息与联系人手机号不符"
				return
			}
		}

		wxUser.BusinessCardUrl = req.BusinessCardUrl
		updateCol = append(updateCol, "BusinessCardUrl")
	}

	productId := services.GetProductId(sysUser.RoleTypeCode)
	companyProductList, _ := getSysCompanyProductList(productId, req.CompanyId)

	err = services.MovePotentialUserByApplyRecord(sysUser.AdminId, req.UserId, req.CompanyId, req.ApplyRecordId, req.RealName, req.Mobile, req.Email, req.Remark, companyProductList, wxUser, updateCol)
	if err != nil {
		br.Msg = "移动失败"
		br.ErrMsg = "移动失败,Err:" + err.Error()
		return
	}

	//更新客户最近阅读次数以及最近阅读时间
	go services.ModifyCompanyProductLastViewData([]int{req.CompanyId})

	br.Ret = 200
	br.Success = true
	br.Msg = "移动成功"
	br.IsAddLog = true
}

// @Title 新增联系人图表分类权限
// @Description 新增联系人图表分类权限接口
// @Param	request	body request.SaveCompanyUserChartClassifyPermissionReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /user/addChartClassifyPermission [post]
func (this *CompanyUserController) AddCompanyUserChartClassifyPermission() {
	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 request.SaveCompanyUserChartClassifyPermissionReq
	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 = "参数丢失：联系人ID"
		br.ErrMsg = "参数丢失，联系人ID"
		return
	}

	if req.StartTime == "" || req.EndTime == "" {
		br.Msg = "请选择开始结束时间"
		br.ErrMsg = "请选择开始结束时间"
		br.IsSendEmail = false
		return
	}

	startTime, err := time.Parse(utils.FormatDate, req.StartTime)
	if err != nil {
		br.Msg = "开始时间格式有误"
		br.ErrMsg = "开始时间转换失败, Err:" + err.Error()
		return
	}
	endTime, err := time.Parse(utils.FormatDate, req.EndTime)
	if err != nil {
		br.Msg = "结束时间格式有误"
		br.ErrMsg = "结束时间转换失败, Err:" + err.Error()
		return
	}

	if startTime.After(endTime) {
		br.Msg = "结束时间不能小于开始时间"
		br.ErrMsg = "结束时间不能小于开始时间"
		br.IsSendEmail = false
		return
	}

	_, err = company_user.GetChartClassifyPermissionByUserId(req.UserId)
	if err == nil {
		br.Msg = "请勿重复设置图表权限"
		br.ErrMsg = "请勿重复设置图表权限"
		br.IsSendEmail = false
		return
	}

	// 判断是否允许设置
	userInfo, err := models.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.Msg = "联系人信息有误"
		br.ErrMsg = "联系人信息有误, Err: " + err.Error()
		return
	}
	companyInfo, err := company.GetCompanyById(userInfo.CompanyId)
	if err != nil {
		br.Msg = "获取客户信息失败"
		br.ErrMsg = "获取客户信息失败, Err: " + err.Error()
		return
	}
	companyProductInfo, err := company.GetCompanyProductByCompanyIdAndProductId(userInfo.CompanyId, 1)
	if err != nil {
		br.Msg = "获取客户产品信息失败"
		br.ErrMsg = "获取客户产品信息失败, Err: " + err.Error()
		return
	}
	companyStatus := companyProductInfo.Status
	if companyStatus != utils.COMPANY_STATUS_FOREVER {
		// 非永续客户
		if companyStatus == utils.COMPANY_STATUS_TRY_OUT || companyStatus == utils.COMPANY_STATUS_FORMAL {
			// 正式/试用
			expireTimeStr := companyProductInfo.EndDate
			expireTime, _ := time.ParseInLocation(utils.FormatDate, expireTimeStr, time.Local)
			// 服务结束时间小于设置的结束时间则不允许设置
			if endTime.After(expireTime.AddDate(0, 0, 1)) {
				br.Msg = "终止日期不允许超过服务日期, 服务终止日期为: " + expireTimeStr
				br.IsSendEmail = false
				return
			}
		} else {
			br.Msg = "当前客户不允许设置图表权限, 客户状态为: " + companyStatus
			br.IsSendEmail = false
			return
		}
	}

	item := &company_user.ChartClassifyPermission{
		UserId:     req.UserId,
		CompanyId:  companyInfo.CompanyId,
		StartTime:  startTime,
		EndTime:    endTime,
		Enabled:    req.Enabled,
		CreateTime: time.Now(),
	}
	_, err = company_user.AddChartClassifyPermission(item)
	if err != nil {
		br.Msg = "新增图表权限失败"
		br.ErrMsg = "新增图表权限失败, Err:" + err.Error()
		return
	}

	// 操作记录
	{
		record := &company_user.CompanyUserChartPermissionOperationRecord{
			Type:       1,
			CompanyId:  companyInfo.CompanyId,
			UserId:     req.UserId,
			AdminId:    sysUser.AdminId,
			StartTime:  startTime,
			EndTime:    endTime,
			Enabled:    req.Enabled,
			CreateTime: time.Now(),
		}
		go company_user.AddChartPermissionOperationRecord(record)
	}

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

// @Title 编辑联系人图表分类权限
// @Description 编辑联系人图表分类权限接口
// @Param	request	body request.SaveCompanyUserChartClassifyPermissionReq true "type json string"
// @Success 200 Ret=200 操作成功
// @router /user/editChartClassifyPermission [post]
func (this *CompanyUserController) EditCompanyUserChartClassifyPermission() {
	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 request.SaveCompanyUserChartClassifyPermissionReq
	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 = "参数丢失：联系人ID"
		br.ErrMsg = "参数丢失，联系人ID"
		return
	}

	if req.StartTime == "" || req.EndTime == "" {
		br.Msg = "请选择开始结束时间"
		br.ErrMsg = "请选择开始结束时间"
		br.IsSendEmail = false
		return
	}

	startTime, err := time.Parse(utils.FormatDate, req.StartTime)
	if err != nil {
		br.Msg = "开始时间格式有误"
		br.ErrMsg = "开始时间转换失败, Err:" + err.Error()
		return
	}
	endTime, err := time.Parse(utils.FormatDate, req.EndTime)
	if err != nil {
		br.Msg = "结束时间格式有误"
		br.ErrMsg = "结束时间转换失败, Err:" + err.Error()
		return
	}

	if startTime.After(endTime) {
		br.Msg = "结束时间不能小于开始时间"
		br.ErrMsg = "结束时间不能小于开始时间"
		br.IsSendEmail = false
		return
	}

	// 判断是否允许设置
	userInfo, err := models.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.Msg = "联系人信息有误"
		br.ErrMsg = "联系人信息有误, Err: " + err.Error()
		return
	}
	companyInfo, err := company.GetCompanyById(userInfo.CompanyId)
	if err != nil {
		br.Msg = "获取客户信息失败"
		br.ErrMsg = "获取客户信息失败, Err: " + err.Error()
		return
	}
	companyProductInfo, err := company.GetCompanyProductByCompanyIdAndProductId(userInfo.CompanyId, 1)
	if err != nil {
		br.Msg = "获取客户产品信息失败"
		br.ErrMsg = "获取客户产品信息失败, Err: " + err.Error()
		return
	}
	companyStatus := companyProductInfo.Status
	if companyStatus != utils.COMPANY_STATUS_FOREVER {
		// 非永续客户
		if companyStatus == utils.COMPANY_STATUS_TRY_OUT || companyStatus == utils.COMPANY_STATUS_FORMAL {
			// 正式/试用
			expireTimeStr := companyProductInfo.EndDate
			expireTime, _ := time.ParseInLocation(utils.FormatDate, expireTimeStr, time.Local)
			// 服务结束时间小于设置的结束时间则不允许设置
			if endTime.After(expireTime.AddDate(0, 0, 1)) {
				br.Msg = "终止日期不允许超过服务日期, 服务终止日期为: " + expireTimeStr
				br.IsSendEmail = false
				return
			}
		} else {
			br.Msg = "当前客户不允许设置图表权限, 客户状态为: " + companyStatus
			br.IsSendEmail = false
			return
		}
	}

	permissionInfo, err := company_user.GetChartClassifyPermissionByUserId(req.UserId)
	if err != nil {
		br.Msg = "获取联系人图表分类权限失败"
		br.ErrMsg = "获取联系人图表分类权限失败, Err:" + err.Error()
		return
	}

	permissionInfo.CompanyId = companyInfo.CompanyId
	permissionInfo.Enabled = req.Enabled
	permissionInfo.StartTime = startTime
	permissionInfo.EndTime = endTime
	permissionInfo.UpdateTime = time.Now()
	err = permissionInfo.Update([]string{"CompanyId", "Enabled", "StartTime", "EndTime", "UpdateTime"})
	if err != nil {
		br.Msg = "编辑联系人图表分类权限失败"
		br.ErrMsg = "编辑联系人图表分类权限失败, Err:" + err.Error()
		return
	}

	// 操作记录
	{
		record := &company_user.CompanyUserChartPermissionOperationRecord{
			Type:       2,
			CompanyId:  companyInfo.CompanyId,
			UserId:     req.UserId,
			AdminId:    sysUser.AdminId,
			StartTime:  startTime,
			EndTime:    endTime,
			Enabled:    req.Enabled,
			CreateTime: time.Now(),
		}
		go company_user.AddChartPermissionOperationRecord(record)
	}

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

// @Title 获取联系人图表分类权限详情
// @Description 获取联系人图表分类权限详情接口
// @Param	UserId   query   int   true   "联系人ID，必填"
// @Success 200 {object} response.CompanyUserChartClassifyPermissionDetailResp
// @router /user/getChartClassifyPermissionDetail [get]
func (this *CompanyUserController) GetCompanyUserChartClassifyPermissionDetail() {
	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
	}

	reqUserId := this.GetString("UserId", "")
	userId, _ := strconv.Atoi(reqUserId)
	if userId <= 0 {
		br.Msg = "参数丢失：联系人ID"
		return
	}
	userInfo, err := models.GetWxUserByUserId(userId)
	if err != nil {
		br.Msg = "联系人信息有误"
		br.ErrMsg = "联系人信息有误, Err: " + err.Error()
		return
	}

	permissionInfo, err := company_user.GetChartClassifyPermissionByUserId(userId)
	if err != nil && err.Error() != utils.ErrNoRow() {
		br.Msg = "获取联系人图表分类权限失败"
		br.ErrMsg = "获取联系人图表分类权限失败, Err:" + err.Error()
		return
	}

	resp := new(response.CompanyUserChartClassifyPermissionDetailResp)

	// 客户服务日期
	companyProductInfo, err := company.GetCompanyProductByCompanyIdAndProductId(userInfo.CompanyId, 1)
	if err != nil {
		br.Msg = "获取客户产品信息失败"
		br.ErrMsg = "获取客户产品信息失败, Err: " + err.Error()
		return
	}
	companyStatus := companyProductInfo.Status
	// 0-不允许设置 1-允许设置最大90天 2-90天
	nowTime := time.Now()
	free := 0
	if companyStatus == utils.COMPANY_STATUS_FOREVER {
		// 永续客户
		free = 2
		resp.ExpireDay = "2199-12-31"
	} else if companyStatus == utils.COMPANY_STATUS_TRY_OUT || companyStatus == utils.COMPANY_STATUS_FORMAL {
		free = 1
		resp.ExpireDay = companyProductInfo.EndDate
	} else {
		resp.ExpireDay = nowTime.Format(utils.FormatDate)
	}

	var startTime, endTime time.Time
	if permissionInfo != nil {
		// 已设置
		startTime = permissionInfo.StartTime
		endTime = permissionInfo.EndTime
		resp.ChartPermissionId = permissionInfo.Id
		resp.UserId = permissionInfo.UserId
		resp.StartTime = permissionInfo.StartTime.Format(utils.FormatDate)
		resp.EndTime = permissionInfo.EndTime.Format(utils.FormatDate)
		resp.Enabled = permissionInfo.Enabled
	} else {
		// 初次设置
		startTime = nowTime
		endTime = startTime.Add(89 * 24 * time.Hour) // 实际验证时以结束日期的23时59分为过期时间所以此处日期-1
		if free == 0 {
			endTime = nowTime
		} else if free == 1 {
			expireTime, _ := time.ParseInLocation(utils.FormatDate, companyProductInfo.EndDate, time.Local)
			sub := expireTime.Sub(nowTime)
			diff := int(sub.Hours() / 24)
			if diff < 90 {
				// 小于90天则终止时间为服务结束时间
				endTime = expireTime
			}
		}

		resp.StartTime = startTime.Format(utils.FormatDate)
		resp.EndTime = endTime.Format(utils.FormatDate)
		resp.UserId = userId
		resp.Enabled = 0 // 默认关闭
	}
	// 计算阅读时长天数
	subDuration := endTime.Sub(startTime)
	subHours := subDuration.Hours()
	subDays := int(subHours / 24)
	resp.DayDuration = subDays + 1

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

// GetOtherProduct
// @Title 获取其他分产品的筛选列表
// @Description 获取联系人图表分类权限详情接口
// @Param	UserId   query   int   true   "联系人ID，必填"
// @Success 200 {object} response.CompanyUserChartClassifyPermissionDetailResp
// @router /user/otherProductList [get]
func (this *CompanyUserController) GetOtherProduct() {
	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
	}

	resp := make([]response.OtherProductTypeListResp, 0)
	statisticFlag, _ := this.GetBool("StatisticFlag")

	questionItem := response.OtherProductTypeListResp{
		ProductId:   0,
		ProductType: 3,
		ProductName: "问答社区",
	}
	roadVideoItem := response.OtherProductTypeListResp{
		ProductId:   2,
		ProductType: 2,
		ProductName: "线上路演",
	}
	videoItem := response.OtherProductTypeListResp{
		ProductId:   1,
		ProductType: 2,
		ProductName: "5分钟小视频",
	}
	if !statisticFlag {
		resp = append(resp, questionItem, roadVideoItem, videoItem)
	}

	voiceSectionList, err := yb.GetAllEnableVoiceSectionList()
	if err != nil {
		br.Msg = "获取数据失败"
		br.ErrMsg = "获取语音播报版块, Err: " + err.Error()
		return
	}
	for _, v := range voiceSectionList {
		resp = append(resp, response.OtherProductTypeListResp{
			ProductId:   v.SectionId,
			ProductType: 1,
			ProductName: v.SectionName,
		})
	}
	if statisticFlag {
		resp = append(resp, questionItem, roadVideoItem, videoItem)
	}

	// 全部
	resp = append(resp, response.OtherProductTypeListResp{
		ProductId:   0,
		ProductType: 99,
		ProductName: "全部",
	})

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

//func init() {
//	BusinessCardUrl := `https://hongze.oss-accelerate.aliyuncs.com/static/images/202107/20210715/R5xT6jw331gPwHZlsIg90cuSbuFW.jpeg`
//	BusinessCardUrl = `https://hongze.oss-accelerate.aliyuncs.com/static/images/202102/20210224/Bdr3Dv8oZDvsAnkzUpx8uA3S4odB.jpg`
//	BusinessCardUrl = `https://hongze.oss-accelerate.aliyuncs.com/static/images/202202/20220215/0glY7kgE07OLBHTnxxwS6u2cAxRx.png`
//	BusinessCardUrl = `https://hongze.oss-accelerate.aliyuncs.com/static/images/202206/20220614/ZHEUpbNtUfE09ZVp6qfQxSPUrLfS.jpg`
//	card, err := services.GetBusinessCard(BusinessCardUrl)
//	if err != nil {
//		fmt.Println("名片识别失败,Err:" + err.Error())
//		return
//	}
//	fmt.Println(card)
//
//	fmt.Println("company:", card.WordsResult.COMPANY)
//	fmt.Println("===================")
//
//	{
//		aliyunResult, err := services.AliyunBusinessCardOcr(BusinessCardUrl)
//		if err != nil {
//			fmt.Println("名片识别失败2,Err:" + err.Error())
//			return
//		}
//		fmt.Println(aliyunResult)
//		fmt.Println("company:", aliyunResult.Company)
//	}
//
//}

// @Title 联系人名单匹配导入
// @Description 联系人名单匹配导入
// @Param   File  query  file  true  "文件"
// @Success 200 {object} company.UserImportMatchResp
// @router /list/match/import [post]
func (this *CompanyUserController) ImportListMatch() {
	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
	}
	defer func() {
		_ = file.Close()
	}()
	ext := path.Ext(h.Filename)
	if ext != ".xlsx" && ext != ".xls" {
		br.Msg = "请上传Excel文件"
		return
	}

	uploadDir := "static/xls"
	err = os.MkdirAll(uploadDir, 766)
	if err != nil {
		br.Msg = "存储目录创建失败"
		br.ErrMsg = "存储目录创建失败,Err:" + err.Error()
		return
	}
	uploadPath := uploadDir + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + h.Filename
	err = this.SaveToFile("File", uploadPath)
	if err != nil {
		br.Msg = "文件保存失败"
		br.ErrMsg = "文件保存失败，Err:" + err.Error()
		return
	}
	defer func() {
		_ = os.Remove(uploadPath)
	}()
	xlFile, err := xlsx.OpenFile(uploadPath)
	if err != nil {
		br.Msg = "文件导入失败"
		br.ErrMsg = "文件导入失败，Err:" + err.Error()
		return
	}

	dataList := make([]*company.UserImportMatch, 0)
	mobileArr := make([]string, 0)

	// 遍历sheet页读取
	for _, sheet := range xlFile.Sheets {
		// 遍历行读取
		maxRow := sheet.MaxRow
		for i := 0; i < maxRow; i++ {
			// 首行
			if i == 0 {
				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 text != "国际（区号）" {
							br.Msg = "匹配失败, 请按模板导入"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 2 {
						if text != "手机号" {
							br.Msg = "匹配失败, 请按模板导入"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
					if k == 3 {
						if text != "客户公司" {
							br.Msg = "匹配失败, 请按模板导入"
							br.ErrMsg = "模板格式错误，title:" + text
							return
						}
					}
				}
			}
			// 数据行
			if i >= 1 {
				row := sheet.Row(i)
				cells := row.Cells
				var userName, countryCode, mobile, companyName string
				for k, cell := range cells {
					if k == 0 {
						userName = utils.TrimStr(cell.String())
					}
					if k == 1 {
						countryCode = utils.TrimStr(cell.String())
					}
					if k == 2 {
						mobile = utils.TrimStr(cell.String())
					}
					if k == 3 {
						companyName = utils.TrimStr(cell.String())
					}
				}
				// 手机号为空则读取下一行
				if mobile == "" {
					continue
				}
				// mobile列存在"86-11位手机号"这种格式
				if strings.Contains(mobile, "-") {
					mobileArr := strings.Split(mobile, "-")
					if len(mobileArr) == 2 {
						countryCode = mobileArr[0]
						mobile = mobileArr[1]
					}
				}

				mobileArr = append(mobileArr, mobile)
				item := &company.UserImportMatch{
					UserName:    userName,
					CountryCode: countryCode,
					Mobile:      mobile,
					CompanyName: companyName,
				}
				dataList = append(dataList, item)
			}
		}
	}
	mobileLen := len(mobileArr)
	if mobileLen == 0 {
		br.Msg = "匹配失败, 无有效数据"
		br.ErrMsg = "匹配失败, 无有效数据"
		return
	}

	// 根据手机号查询联系人信息
	var userCond string
	var userPars []interface{}
	userCond += ` AND mobile IN (` + utils.GetOrmInReplace(mobileLen) + `)`
	userPars = append(userPars, mobileArr)
	userList, e := company.GetCompanyUsersByCondition(userCond, userPars)
	if e != nil {
		br.Msg = "匹配失败, 请按模板导入"
		br.ErrMsg = "匹配失败, 获取联系人信息失败, Err: " + e.Error()
		return
	}
	companyIds := make([]int, 0)
	mobileCompanyIdMap := make(map[string]int, 0)
	for i := range userList {
		companyIds = append(companyIds, userList[i].CompanyId)
		mobileCompanyIdMap[userList[i].Mobile] = userList[i].CompanyId
	}
	companyLen := len(companyIds)

	// 查询客户、客户产品
	var productCond string
	var productPars []interface{}
	if companyLen > 0 {
		productCond += ` AND a.company_id IN (` + utils.GetOrmInReplace(companyLen) + `)`
		productPars = append(productPars, companyIds)
	}
	productList, e := company.GetCompanyProductsByCondition(productCond, productPars)
	if e != nil {
		br.Msg = "匹配失败, 请按模板导入"
		br.ErrMsg = "匹配失败, 获取客户产品信息失败, Err: " + e.Error()
		return
	}
	ficcProductMap := make(map[int]*company.CompanyProduct, 0)
	raiProductMap := make(map[int]*company.CompanyProduct, 0)
	for i := range productList {
		if productList[i].ProductId == 1 {
			ficcProductMap[productList[i].CompanyId] = productList[i]
		} else {
			raiProductMap[productList[i].CompanyId] = productList[i]
		}
	}

	// 根据客户信息返回数据
	for i := range dataList {
		companyId := mobileCompanyIdMap[dataList[i].Mobile]
		if companyId == 0 {
			continue
		}
		ficc := ficcProductMap[companyId]
		if ficc != nil {
			dataList[i].SysCompanyName = ficc.CompanyName
			dataList[i].FiccStatus = ficc.Status
			dataList[i].FiccSeller = ficc.SellerName
		}
		rai := raiProductMap[companyId]
		if rai != nil {
			dataList[i].SysCompanyName = rai.CompanyName
			dataList[i].RaiStatus = rai.Status
			dataList[i].RaiSeller = rai.SellerName
		}
	}

	// 缓存导入数据, 导出时用缓存数据生成Excel
	var code, cacheKey string
	dataJson, e := json.Marshal(dataList)
	if e == nil {
		code = fmt.Sprint(time.Now().UnixNano())
		cacheKey = utils.CACHE_KEY_COMPANY_MATCH_PRE + code
		_ = utils.Rc.Put(cacheKey, string(dataJson), time.Minute*30)
	}

	resp := new(company.UserImportMatchResp)
	resp.List = dataList
	resp.Code = code

	br.Data = resp
	br.Msg = "匹配成功"
	br.Ret = 200
	br.Success = true
}

// @Title 联系人名单匹配结果下载
// @Description 联系人名单匹配结果下载
// @Param   Code  query  string  true  "导入时返回的Code"
// @Success 200 Ret=200 匹配成功
// @router /list/match/download [get]
func (this *CompanyUserController) ImportListMatchDownload() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请重新登录"
		return
	}
	code := this.GetString("Code")
	if code == "" {
		br.Msg = "参数有误"
		return
	}
	cacheKey := utils.CACHE_KEY_COMPANY_MATCH_PRE + code

	// 获取导入时的缓存数据
	dataJson, e := utils.Rc.RedisString(cacheKey)
	if e != nil {
		br.Msg = "获取导出数据失败"
		br.ErrMsg = "获取导出数据失败, Err: " + e.Error()
		return
	}
	if dataJson == "" {
		br.Msg = "匹配数据已失效, 请重新匹配"
		return
	}
	dataList := make([]*company.UserImportMatch, 0)
	if e = json.Unmarshal([]byte(dataJson), &dataList); e != nil {
		br.Msg = "匹配数据已失效, 请重新匹配"
		return
	}
	if len(dataList) == 0 {
		br.Msg = "匹配数据已失效, 请重新匹配"
		return
	}

	// 生成Excel表格
	dir, err := os.Executable()
	exPath := filepath.Dir(dir)
	downloadPath := exPath + "/company_match_" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
	excelFile := xlsx.NewFile()
	if err != nil {
		br.Msg = "生成文件失败"
		br.ErrMsg = "生成文件失败"
		return
	}
	style := xlsx.NewStyle()
	alignment := xlsx.Alignment{
		Horizontal: "center",
		Vertical:   "center",
		WrapText:   true,
	}
	style.Alignment = alignment
	style.ApplyAlignment = true

	// 新增Sheet和表头
	sheet, err := excelFile.AddSheet("客户名单")
	if err != nil {
		br.Msg = "新增Sheet失败"
		br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
		return
	}
	titleRow := sheet.AddRow()
	titleRow.AddCell().SetValue("姓名")
	titleRow.AddCell().SetValue("国际（区号）")
	titleRow.AddCell().SetValue("手机号")
	titleRow.AddCell().SetValue("客户公司")
	titleRow.AddCell().SetValue("系统客户")
	titleRow.AddCell().SetValue("FICC状态")
	titleRow.AddCell().SetValue("FICC销售")
	titleRow.AddCell().SetValue("权益状态")
	titleRow.AddCell().SetValue("权益销售")

	// 表格赋值
	for _, v := range dataList {
		dataRow := sheet.AddRow()
		dataRow.SetHeight(20)
		dataRow.AddCell().SetString(v.UserName)
		dataRow.AddCell().SetString(v.CountryCode)
		dataRow.AddCell().SetString(v.Mobile)
		dataRow.AddCell().SetString(v.CompanyName)
		dataRow.AddCell().SetString(v.SysCompanyName)
		dataRow.AddCell().SetString(v.FiccStatus)
		dataRow.AddCell().SetString(v.FiccSeller)
		dataRow.AddCell().SetString(v.RaiStatus)
		dataRow.AddCell().SetString(v.RaiSeller)
	}

	// 输出Excel
	if e = excelFile.Save(downloadPath); e != nil {
		br.Msg = "保存文件失败"
		br.ErrMsg = "保存文件失败"
		return
	}
	defer func() {
		_ = os.Remove(downloadPath)
	}()
	suffix := time.Now().Format(utils.FormatDateTimeUnSpace)
	downloadFileName := "客户名单匹配_" + suffix + ".xlsx"
	this.Ctx.Output.Download(downloadPath, downloadFileName)

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

// Follow
// @Title 关注联系人
// @Description 关注联系人
// @Param	request	body request.ApplyMarkReq true "type json string"
// @Success 200 {object} 标记处理成功
// @router /follow [post]
func (this *CompanyUserController) Follow() {
	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 request.FollowReq
	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 = "用户ID异常"
		br.ErrMsg = "用户ID异常"
		return
	}

	// 查公司里有多少已关注，上限三个
	count, err := models.GetCompanyFollowCount(req.CompanyId)
	if err != nil {
		br.Msg = "操作失败！ "
		br.ErrMsg = "操作失败，Err:" + err.Error()
		return
	}
	if count == 3 && req.Type == 1 {
		br.Msg = "关注失败，特别关注已达上限（上限三个）"
		br.ErrMsg = "关注失败，特别关注已达上限（上限三个）"
		return
	}

	// 关注或取关
	err = models.SetUserFollow(req.UserId, req.Type)
	if err != nil {
		br.Msg = "操作失败！ "
		br.ErrMsg = "操作失败，Err:" + err.Error()
		return
	}

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

// @Title 开通或者关闭用户研选权限
// @Description 开通或者关闭用户研选权限
// @Param	request	body request.ApplyMarkReq true "type json string"
// @Success 200 {object} 操作成功
// @router /update/user/yananxuan/permission [post]
func (this *CompanyUserController) UpadteUserYanxuanPermission() {
	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 cygx.UpdateUserYanxuanPermissionReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	userId := req.UserId
	if userId <= 0 {
		br.Msg = "用户ID异常"
		br.ErrMsg = "用户ID异常"
		return
	}

	//获取联系人详情
	userInfo, err := models.GetWxUserByUserId(req.UserId)
	if err != nil {
		br.Msg = "获取联系人异常！"
		br.ErrMsg = "获取联系人异常，Err:" + err.Error()
		return
	}

	if userInfo.BusinessCardUrl == "" {
		br.Msg = "该联系人尚未添加名片，请点击编辑，上传名片后再开通试用"
		return
	}

	companyInfo, err := company.GetCompanyById(userInfo.CompanyId)
	if err != nil {
		br.Msg = "查找客户失败"
		br.ErrMsg = "查找客户失败,err:" + err.Error()
		return
	}

	// 查询用户是否开通过
	count, err := cygx.GetCygxUserYanxuanPermissionCountByUserId(userId)
	if err != nil {
		br.Msg = "操作失败！ "
		br.ErrMsg = "操作失败，Err:" + err.Error()
		return
	}

	item := new(cygx.CygxUserYanxuanPermission)
	if req.Type == 0 {
		item.Status = "未开通"
	} else {
		item.Status = "试用"
	}
	item.UserId = userId
	item.CompanyId = companyInfo.CompanyId
	item.CompanyName = companyInfo.CompanyName
	item.StartDate = time.Now().Format(utils.FormatDate)
	item.EndDate = time.Now().AddDate(0, 2, 0).Format(utils.FormatDate) // 试用期两个月
	item.Mobile = userInfo.Mobile
	item.Email = userInfo.Email
	item.RealName = userInfo.RealName
	item.AdminId = sysUser.AdminId
	item.AdminRealName = sysUser.RealName
	item.CreatedTime = time.Now()
	item.LastUpdatedTime = time.Now()
	item.ModifyTime = time.Now()
	if count == 0 {
		_, err = cygx.AddCygxUserYanxuanPermission(item) // 添加
	} else {
		if req.Type == 0 {
			err = cygx.UpdateCygxUserYanxuanPermissionClose(userId) // 关闭
		} else {
			err = cygx.UpdateCygxUserYanxuanPermissionOpen(item) // 开通
		}
	}
	if err != nil {
		br.Msg = "操作失败！ "
		br.ErrMsg = "操作失败，Err:" + err.Error()
		return
	}
	go cygxService.AddCygxUserYanxuanPermissionLog(item)
	br.Ret = 200
	br.Success = true
	br.Msg = "操作成功"
}

// ListByReport
// @Title 联系人列表
// @Description 联系人列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   CompanyId   query   int  true       "公司id，必填"
// @Param   SortParam	query	int	false	"排序字段：1-点击量；2-点击时间"
// @Param   SortType	query	int	false	"排序方式：1-倒序；2-正序"
// @Success 200 {object} company.CompanyUserListResp
// @router /user/listByReport [get]
func (this *CompanyUserController) ListByReport() {
	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")
	companyId, _ := this.GetInt("CompanyId")

	sortParam, _ := this.GetInt("SortParam", 2)
	sortType, _ := this.GetInt("SortType", 1)

	if companyId <= 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 order string
	sortArr := []int{1, 2}
	if utils.InArrayByInt(sortArr, sortParam) && utils.InArrayByInt(sortArr, sortType) {
		pMap := map[int]string{1: "ficc_view_total", 2: "ficc_last_view_time"}
		tMap := map[int]string{1: "DESC", 2: "ASC"}
		order = fmt.Sprintf(` ORDER BY %s %s`, pMap[sortParam], tMap[sortType])
	}

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

	list, err := company.GetCompanyUserListByReport(companyId, startSize, pageSize, order)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}

	respList := make([]*company.CompanyViewResp, 0)
	for i := range list {
		v := &company.CompanyViewResp{
			UserId:       int(list[i].UserId),
			UserName:     list[i].RealName,
			Mobile:       list[i].Mobile,
			Email:        list[i].Email,
			ViewTotal:    list[i].FiccViewTotal,
			LastViewTime: list[i].FiccLastViewTime.Format(utils.FormatDateTime),
		}
		if v.LastViewTime == "0001-01-01 00:00:00" {
			v.LastViewTime = ""
		}
		respList = append(respList, v)
	}

	page := paging.GetPaging(currentIndex, pageSize, total)
	resp := &company.CompanyViewPageListResp{
		Paging: page,
		List:   respList,
	}

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

// listMoveLog
// @Title 联系人移动记录列表
// @Description 联系人移动记录列表接口
// @Param   Mobile   query   string  true       "手机号"
// @Success 200 {object} company.CompanyUserListResp
// @router /user/listMoveLog [get]
func (this *CompanyUserController) ListMoveLog() {
	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
	}
	mobile := this.GetString("Mobile")
	if mobile == "" {
		br.Msg = "手机号不能为空"
		return
	}
	list, err := company.GetWxUserMoveLogListmByMobile(mobile)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	respList := make([]*company.WxUserMoveLogResp, 0)
	for _, v := range list {
		item := new(company.WxUserMoveLogResp)
		item.UserName = v.RealName
		item.Mobile = v.Mobile
		item.Email = v.Email
		item.CompanyId = v.CompanyId
		item.CompanyName = v.CompanyName
		item.CompanyIdMove = v.CompanyIdMove
		item.CompanyNameMove = v.CompanyNameMove
		item.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
		respList = append(respList, item)
	}
	resp := &company.WxUserMoveLogListResp{
		List: respList,
	}
	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 修改联系人外呼手机号
// @Description 修改联系人外呼手机号接口
// @Param	request	body models.PotentialUserDealReq true "type json string"
// @Success Ret=200 修改成功
// @router /user/edit/outbound_mobile [post]
func (this *CompanyController) EditUserOutboundMobile() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	var req models.EditUserOutboundMobileReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}

	if req.OutboundMobile == "" {
		br.Msg = "手机号不能为空"
		return
	}
	//if !utils.ValidateMobileFormatat(req.OutboundMobile) {
	//	br.Msg = "手机号格式有误"
	//	return
	//}
	err = models.UpdateUserOutboundMobile(req.OutboundMobile, req.OutboundCountryCode, req.UserId)
	br.Ret = 200
	br.Success = true
	br.Msg = "标记成功"
}