member_user.go

package logic

import (
	"crm-server/internal/common"
	"crm-server/internal/dao"
	"crm-server/internal/model"
	"crm-server/internal/service"
	"fmt"
	"regexp"
	"strconv"
	"strings"
)

//会员系统的用户逻辑
var(
	adtag = ""
	ptag = ""
	refer = ""
)
const(
	AdtagRex = "adtag=.*"
	PtagRex = "ptag=.*"
	ReferRex = "refer=.*"
)


//获取会员系统的用户数据sql
const GETMEMBERUSER  = "select `lie_u`.`user_id`, `lie_u`.`mobile`, `lie_u`.`user_name`, `lie_u`.`email`," +
	" `lie_u`.`reg_remark`, `lie_u`.`create_device`, `lie_u`.`create_time`, `lie_c`.`com_id`, `lie_c`.`type_id`," +
	" `lie_c`.`com_name`, `lie_c`.`com_desc`, `lie_c`.`com_province_id`, `lie_c`.`com_city_id`, `lie_c`.`com_area_id`," +
	" `lie_c`.`com_address`, `lie_c`.`com_telphone`, `lie_c`.`com_fax`, `lie_c`.`brand_list`, `lie_i`.`work_function`," +
	" `lie_i`.`user_type`, `lie_i`.`sale_id` as `userinfo_sale_id` from `lie_user_main` as `lie_u` left join `lie_user_info` as " +
	"`lie_i` on `lie_u`.`user_id` = `lie_i`.`user_id` left join `lie_user_company` as `lie_c` on `lie_u`.`user_id` = `lie_c`.`user_id`" +
	" where  `lie_u`.`is_test` = 0 and `lie_u`.`is_type` = 0 and `lie_u`.`user_id` = ? and `lie_u`.`create_device` not in (3, 20)"


//获取会员系统的用户数据sql
func GetMemberUserInfo(memberId int) model.MemberAddUserData {

	var MemberUserInfo model.MemberAddUserData

	err := dao.GetLiexinDb().QueryRowx(GETMEMBERUSER,memberId).StructScan(&MemberUserInfo)
	if err != nil {
		service.WriteErr(err)
	}

	return MemberUserInfo
}

//查找对应tag得到的客服
func SetTagSale(tag string,memberInfo *model.MemberAddUserData){
	//查找交易员
	var saleId int
	err := dao.GetDb().QueryRowx("select sale_id from lie_sale_tag where `is_del` = 0  and (`adtag` = ? or `ptag` = ?)",tag,tag).Scan(&saleId)
	if err != nil {
		service.WriteErr(err)
	}
	if saleId != 0 {
		memberInfo.Sale_Id = saleId
	}
}

//处理基本的原始数据
func HandleData(MemberUserInfo model.MemberAddUserData) model.MemberAddUserData{

	var saleId = 0
	//查找交易员
	err := dao.GetLiexinDb().QueryRowx("select sale_id from lie_order where user_id = ? order by create_time desc",MemberUserInfo.User_Id).Scan(&saleId)
	if err != nil {
		service.WriteErr(err)
	}

	if saleId != 0 {
		MemberUserInfo.Sale_Id = saleId
	}

	if MemberUserInfo.Userinfo_Sale_Id != 0{
		MemberUserInfo.Sale_Id = MemberUserInfo.Userinfo_Sale_Id
	}


	// 个人转化为贸易商
	if MemberUserInfo.Type_Id == 0 {
		MemberUserInfo.Type_Id = 5
	}

	//来源
	if MemberUserInfo.Create_Device != 2 {
		MemberUserInfo.Source = 1
	}else{
		MemberUserInfo.Source = 2
	}

	// 客户身份
	if MemberUserInfo.Work_Function != 0 {
		MemberUserInfo.Customer_identity = MemberUserInfo.Work_Function
	}

	//获取oems数据


	//抓取adtag和ptag，refer
	adtag = regexp.MustCompile(AdtagRex).FindString(MemberUserInfo.Reg_Remark)
	ptag = regexp.MustCompile(PtagRex).FindString(MemberUserInfo.Reg_Remark)
	refer = regexp.MustCompile(ReferRex).FindString(MemberUserInfo.Reg_Remark)


	if refer != ""{
		refer = strings.Split(refer,",")[0]
		//如果是以上refer则为自营样片
		if strings.Contains(refer,"sample") {
			MemberUserInfo.Channel_source = 10
		}
	}
	
	if ptag != "" {
		ptag = strings.Split(ptag,",")[0]
		MemberUserInfo.Ptag = strings.Split(ptag,",")[0]
		switch ptag {
		case "ptag=activity-140":
		case "ptag=activity-141":
		case "ptag=activity-143":
		case "ptag=activity-144":
			MemberUserInfo.Customer_identity = 2//如果是以上ptag则为采购用户
			MemberUserInfo.Channel_source = 9//如果是以上ptag则为展会用户
			break
		case "ptag=activity-142":
		case "ptag=activity-145":
			MemberUserInfo.Customer_identity = 1//如果是以上ptag则为工程师
			MemberUserInfo.Channel_source = 9//如果是以上ptag则为展会用户
			break
		case "ptag=sample":
		case "ptag=sample-pop":
		case "ptag=samplereg":
		case "ptag=sample-stopnav":
			MemberUserInfo.Channel_source = 10//如果是以上ptag则为自营样片
			break
		case "ptag=jr":
			MemberUserInfo.Channel_source = 11//如果是以上ptag则为信用金融
			break
		case "ptag=edcp":
			MemberUserInfo.Channel_source = 12//如果是以上ptag则为信用贷测评
			break
		}
		SetTagSale(ptag,&MemberUserInfo)
	}

	if adtag != "" {
		adtag = strings.Split(adtag,",")[0]
		MemberUserInfo.Adtag = adtag
		if adtag == "adtag=bps" {
			MemberUserInfo.Channel_source = 13//如果是以上adtag则为白皮书下载用户
		}
		if adtag == "adtag=findchips" {
			MemberUserInfo.Channel_source = 14//如果是以上adtagfindchips广告
		}

		SetTagSale(adtag,&MemberUserInfo)
	}

	//地址
	if MemberUserInfo.Com_Province_Id != 0 && MemberUserInfo.Com_City_Id != 0 && MemberUserInfo.Com_Area_Id != 0  {
		MemberUserInfo.Com_Full_addr = common.AllCity[strconv.Itoa(MemberUserInfo.Com_Province_Id)] + common.AllCity[strconv.Itoa(MemberUserInfo.Com_City_Id)] + common.AllCity[strconv.Itoa(MemberUserInfo.Com_Area_Id)] + MemberUserInfo.Com_Address
	}

	//oems信息
	var oems model.OemsUserinfo
	dao.GetDb().QueryRowx("select contract,contract_name,note,outter_uid from lie_oems_userinfo where outter_uid = ?",&oems.Outter_Uid)
	if oems.Outter_Uid != 0 {
		fmt.Println(oems)
		if MemberUserInfo.Mobile == "" {
			MemberUserInfo.Mobile = oems.Contact
		}
		MemberUserInfo.User_Name = oems.Contact_Name
		MemberUserInfo.Channel_source = 8
		MemberUserInfo.Remark = oems.Note
	}

	//判断是否下单
	var orderId int
	err = dao.GetLiexinDb().QueryRowx("select order_id from lie_order where user_id = ?",MemberUserInfo.User_Id).Scan(orderId);
	if orderId != 0  {
		 MemberUserInfo.No_Create_Order = 2
	}else{
		MemberUserInfo.No_Create_Order = 1
	}



	return MemberUserInfo
}