hongze_cygx/services/yidong.go

package services

import (
	"context"
	"encoding/json"
	"fmt"
	"hongze/hongze_cygx/models"
	"hongze/hongze_cygx/utils"
	"io/ioutil"
	"net/http"
	"strings"
	"time"
)

//GetActivityTypeIdWithYiDong 根据易董同步过来的活动类型，自动匹配行业
func GetActivityTypeIdWithYiDong(industrySwName string) (chartPermissionId int) {
	mapIndustrySwName := map[string]int{
		"家用电器": utils.XIAO_FEI_ID,
		"纺织服饰": utils.XIAO_FEI_ID,
		"休闲服务": utils.XIAO_FEI_ID,
		"食品饮料": utils.XIAO_FEI_ID,
		"美容护理": utils.XIAO_FEI_ID,
		//消费

		"汽车":   utils.ZHI_ZAO_ID,
		"机械设备": utils.ZHI_ZAO_ID,
		"电力设备": utils.ZHI_ZAO_ID,
		//智造

		"电子":  utils.KE_JI_ID,
		"计算机": utils.KE_JI_ID,
		"通信":  utils.KE_JI_ID,
		//科技

		"医药生物": utils.YI_YAO_ID,
		//医药

		"策略": utils.CE_LUE_ID,
		//策略

		"非银金融": utils.CHART_PERMISSION_ID_YANXUAN,
		"建筑装饰": utils.CHART_PERMISSION_ID_YANXUAN,
		"基础化工": utils.CHART_PERMISSION_ID_YANXUAN,
		"农林牧渔": utils.CHART_PERMISSION_ID_YANXUAN,
		"传媒":   utils.CHART_PERMISSION_ID_YANXUAN,
		"公用事业": utils.CHART_PERMISSION_ID_YANXUAN,
		"建筑材料": utils.CHART_PERMISSION_ID_YANXUAN,
		"房地产":  utils.CHART_PERMISSION_ID_YANXUAN,
		"采掘":   utils.CHART_PERMISSION_ID_YANXUAN,
		"轻工制造": utils.CHART_PERMISSION_ID_YANXUAN,
		"钢铁":   utils.CHART_PERMISSION_ID_YANXUAN,
		"交通运输": utils.CHART_PERMISSION_ID_YANXUAN,
		"国防军工": utils.CHART_PERMISSION_ID_YANXUAN,
		"银行":   utils.CHART_PERMISSION_ID_YANXUAN,
		"有色金属": utils.CHART_PERMISSION_ID_YANXUAN,
		"综合":   utils.CHART_PERMISSION_ID_YANXUAN,
		"商业贸易": utils.CHART_PERMISSION_ID_YANXUAN,

		"宏观":   utils.CHART_PERMISSION_ID_YANXUAN,
		"金融工程": utils.CHART_PERMISSION_ID_YANXUAN,
		"商贸零售": utils.CHART_PERMISSION_ID_YANXUAN,
		"社会服务": utils.CHART_PERMISSION_ID_YANXUAN,
		"煤炭":   utils.CHART_PERMISSION_ID_YANXUAN,
		"石油石化": utils.CHART_PERMISSION_ID_YANXUAN,
		"环保":   utils.CHART_PERMISSION_ID_YANXUAN,
		//研选
	}
	chartPermissionId = mapIndustrySwName[industrySwName]
	return
}

//GetActivityTypeIdWithYiDong 根据易董同步过来的活动类型，自动匹配行业
func GetActivityTypeNameWithYiDong(industrySwName string) (chartPermissionName string) {
	mapIndustrySwName := map[string]string{
		"家用电器": utils.XIAO_FEI_NAME,
		"纺织服饰": utils.XIAO_FEI_NAME,
		"休闲服务": utils.XIAO_FEI_NAME,
		"食品饮料": utils.XIAO_FEI_NAME,
		"美容护理": utils.XIAO_FEI_NAME,
		//消费

		"汽车":   utils.ZHI_ZAO_NAME,
		"机械设备": utils.ZHI_ZAO_NAME,
		"电力设备": utils.ZHI_ZAO_NAME,
		//智造

		"电子":  utils.KE_JI_NAME,
		"计算机": utils.KE_JI_NAME,
		"通信":  utils.KE_JI_NAME,
		//科技

		"医药生物": utils.YI_YAO_NAME,
		//医药

		"策略": utils.CE_LUE_NAME,
		//策略

		"非银金融": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"建筑装饰": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"基础化工": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"农林牧渔": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"传媒":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"公用事业": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"建筑材料": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"房地产":  utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"采掘":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"轻工制造": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"钢铁":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"交通运输": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"国防军工": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"银行":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"有色金属": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"综合":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"商业贸易": utils.CHART_PERMISSION_NAME_MF_YANXUAN,

		"宏观":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"金融工程": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"商贸零售": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"社会服务": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"煤炭":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"石油石化": utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		"环保":   utils.CHART_PERMISSION_NAME_MF_YANXUAN,
		//研选
	}
	chartPermissionName = mapIndustrySwName[industrySwName]
	return
}

//获取易董token
func GetYiDongToken() (token string, err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			utils.FileLog.Info(err.Error())
		}
	}()
	cacheKey := utils.YD_TOKEN
	ttlTime := utils.Rc.GetRedisTTL(cacheKey)
	if ttlTime > 0 {
		token, _ = utils.Rc.RedisString(cacheKey)
	}
	if token == "" {
		url := utils.YiDongZhengTongYunUrl + "oauth/token?grant_type=client_credentials&response_type=token&client_id=" + utils.YiDongZhengTongYunAppid + "&client_secret=" + utils.YiDongZhengTongYunSecret
		method := "GET"
		client := &http.Client{}
		req, errReq := http.NewRequest(method, url, nil)
		if errReq != nil {
			err = errReq
			return
		}
		res, errReq := client.Do(req)
		if errReq != nil {
			err = errReq
			return
		}
		defer res.Body.Close()

		type Ydtoklen struct {
			Success     bool   `json:"success"`
			ExpiresIn   int    `json:"expires_in"`
			AccessToken string `json:"access_token"`
		}
		var ydtoklen Ydtoklen
		body, errReq := ioutil.ReadAll(res.Body)
		if errReq != nil {
			err = errReq
			return
		}
		errReq = json.Unmarshal(body, &ydtoklen)
		if errReq != nil {
			err = errReq
			return
		}
		token = ydtoklen.AccessToken
		utils.Rc.Put(cacheKey, ydtoklen.AccessToken, time.Second*7000)
	}
	return
}

//获取易董活动列表
func GetYiDongActivity(cont context.Context) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			utils.FileLog.Info(err.Error())
		}
	}()
	var token string
	token, _ = GetYiDongToken()
	url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getRoadshowList?access_token=" + token
	method := "POST"
	payload := strings.NewReader(`{
    "meetingStatus": "0"
}`)
	client := &http.Client{}
	req, err := http.NewRequest(method, url, payload)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	req.Header.Add("Content-Type", "application/json")

	res, err := client.Do(req)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	defer res.Body.Close()
	var ApifoxModal *models.ApifoxModal
	body, err := ioutil.ReadAll(res.Body)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}

	//添加请求日志记录
	itemApiLog := new(models.CygxThreeApiLog)
	itemApiLog.CreateTime = time.Now()
	itemApiLog.Source = 1
	itemApiLog.Url = url
	itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(payload))
	itemApiLog.Result = string(body)
	go models.AddCygxThreeApiLog(itemApiLog)

	err = json.Unmarshal(body, &ApifoxModal)
	if err != nil {
		fmt.Println("Getres.PublicGetDate Err:", err.Error())
		utils.FileLog.Info(err.Error())
		return
	}
	OldActYIdongList, err := models.GetActivityListByYiDong()
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(string(err.Error()))
		return
	}
	mapOldYiDong := make(map[string]string)
	mapOldYiDongBody := make(map[string]string)
	for _, v := range OldActYIdongList {
		mapOldYiDong[v.YidongActivityId] = v.YidongActivityId
		mapOldYiDongBody[v.YidongActivityId] = fmt.Sprint(v.ActivityName, v.Label, v.ChartPermissionId, v.ActivityTime, v.YidongActivityEndTime, v.DistinguishedGuest)
	}
	var itemsAdd []*models.CygxActivity
	if len(ApifoxModal.Result) > 0 {
		actList := ApifoxModal.Result
		for _, v := range actList {
			var item = new(models.CygxActivity)
			item.YidongActivityId = v.ID
			item.ActivityTypeId = 3
			item.ActivityTypeName = "公司调研电话会"
			item.ActivityName = v.CompanyInfo + v.Title
			item.Label = v.CompanyInfo
			item.TemporaryLabel = v.CompanyInfo
			item.ChartPermissionId = GetActivityTypeIdWithYiDong(v.IndustrySwName)
			item.ChartPermissionName = GetActivityTypeNameWithYiDong(v.IndustrySwName)
			item.ChartPermissionNames = GetActivityTypeNameWithYiDong(v.IndustrySwName)
			item.ActivityTime = v.Start
			item.YidongActivityEndTime = v.End
			item.YidongSignUpStart = v.SignUpStart
			item.YidongSignUpEnd = v.SignUpEnd
			item.YidongActivityEndTime = v.End
			item.ActivityTimeText = GetActivityTextTime(v.Start)
			item.YidongActivityUrl = v.URL
			item.ActivityJoinType = v.ActivityJoinType
			detailYidng, err := GetYiDongActivityDetail(v.ID)
			if err != nil {
				return err
			}
			detailList := detailYidng.Resultdetail.GuestPersonList
			for _, vdetail := range detailList {
				item.DistinguishedGuest += vdetail.PersonName + ","
			}
			item.DistinguishedGuest = strings.TrimRight(item.DistinguishedGuest, ",")
			item.Body = "<p>" + "【" + v.CompanyInfo + v.Title + "】" + "<p>时间：" + v.Start + "</p>嘉宾：" + item.DistinguishedGuest + "</p>"
			if mapOldYiDong[v.ID] == "" {
				itemsAdd = append(itemsAdd, item)
				newId, err := models.AddCygxActivity(item)
				if err != nil {
					fmt.Println(err)
					utils.FileLog.Info(string(err.Error()))
					return err
				}

				//把公司名称当做标的 对活动进行产业标的的关联
				YidongActivityGroup(v.CompanyInfo, int(newId))
			} else {
				//如果内容主体有做变更，就修改内容
				if mapOldYiDongBody[v.ID] != fmt.Sprint(item.ActivityName, item.Label, item.ChartPermissionId, item.ActivityTime, item.YidongActivityEndTime, item.DistinguishedGuest) {
					updateParams := make(map[string]interface{})
					updateParams["ActivityName"] = item.ActivityName
					updateParams["Label"] = item.Label
					updateParams["TemporaryLabel"] = item.TemporaryLabel
					updateParams["DistinguishedGuest"] = item.DistinguishedGuest
					updateParams["ChartPermissionId"] = item.ChartPermissionId
					updateParams["ChartPermissionName"] = item.ChartPermissionName
					updateParams["ChartPermissionNames"] = item.ChartPermissionNames
					updateParams["ActivityTime"] = item.ActivityTime
					updateParams["YidongActivityEndTime"] = item.YidongActivityEndTime
					updateParams["ActivityTimeText"] = item.ActivityTimeText
					updateParams["YidongActivityUrl"] = item.YidongActivityUrl
					updateParams["ActivityJoinType"] = item.ActivityJoinType
					updateParams["YidongSignUpStart"] = item.YidongSignUpStart
					updateParams["YidongSignUpEnd"] = item.YidongSignUpEnd
					whereParam := map[string]interface{}{"yidong_activity_id": item.YidongActivityId}
					err = models.UpdateByExpr(models.CygxActivity{}, whereParam, updateParams)
					if err != nil {
						return err
					}
				}
			}
		}
	}
	return
}

//获取易董活动详情
func GetYiDongActivityDetail(activityId string) (detail *models.ApifoxModaldetail, err error) {
	defer func() {
		if err != nil {
			go utils.SendAlarmMsg("获取易董活动详情失败："+err.Error(), 2)
		}
	}()
	var token string
	token, _ = GetYiDongToken()
	url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getRoadshowDetail?access_token=" + token
	method := "POST"
	payload := strings.NewReader(`{"activityId":"` + activityId + `"}`)
	client := &http.Client{}
	req, err := http.NewRequest(method, url, payload)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	req.Header.Add("Content-Type", "application/json")
	res, err := client.Do(req)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	defer res.Body.Close()
	var ApifoxModal *models.ApifoxModaldetail
	body, err := ioutil.ReadAll(res.Body)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}

	//添加请求日志记录
	//itemApiLog := new(models.CygxThreeApiLog)
	//itemApiLog.CreateTime = time.Now()
	//itemApiLog.Source = 1
	//itemApiLog.Url = url
	//itemApiLog.Body = utils.ReplaceSpaceAndWrap(fmt.Sprint(payload))
	//itemApiLog.Result = string(body)
	//go models.AddCygxThreeApiLog(itemApiLog)

	err = json.Unmarshal(body, &ApifoxModal)
	if err != nil {
		fmt.Println("Getres.PublicGetDate Err:", err.Error())
		utils.FileLog.Info(err.Error())
		return
	}
	detail = ApifoxModal
	return
}

//生成用户相关信息接口 获取用户tgc
func GetYiDongCreateUserInfo(user *models.WxUserItem) (userTgc string, err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			utils.FileLog.Info(err.Error())
		}
	}()
	url := utils.YiDongHuaWeiYunUrl + "app/hz/createUserInfo"
	method := "POST"
	payload := strings.NewReader(`{
  "phone": "` + user.Mobile + `",
  "personName": "` + user.RealName + `",
  "companyName": "` + user.CompanyName + `",
  "jobName": "` + user.Position + `",
  "mobileCountryCode": "+` + user.CountryCode + `",
  "sourceFrom": "01"
}`)
	client := &http.Client{}
	req, err := http.NewRequest(method, url, payload)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	req.Header.Add("Content-Type", "application/json")
	res, err := client.Do(req)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	defer res.Body.Close()
	var ApifoxModal *models.ApifoxModalUserTgc
	body, err := ioutil.ReadAll(res.Body)
	if err != nil {
		fmt.Println(err)
		utils.FileLog.Info(err.Error())
		return
	}
	err = json.Unmarshal(body, &ApifoxModal)
	if err != nil {
		fmt.Println("Getres.PublicGetDate Err:", err.Error())
		utils.FileLog.Info(err.Error())
		return
	}
	userTgc = ApifoxModal.Result.Tgc
	return
}

//处理易董这边过来的时间格式
func GetActivityTextTime(timeYidong string) (timeText string) {
	strTime := timeYidong
	startTime := utils.StrTimeToTime(strTime)
	week := utils.StrDateTimeToWeek(strTime)
	timeStrYmd := startTime.Format(utils.FormatDate)
	timeStrHmm := startTime.Format(utils.FormatTime)
	timeYmd := utils.StrTimeToTime(timeStrYmd + " 12:00:00") //拼接当天中午12点的时间
	var amOrPm string
	if startTime.After(timeYmd) {
		amOrPm = " PM"
	} else {
		amOrPm = " AM"
	}
	timeText = timeStrYmd + "（" + week + "）" + timeStrHmm + amOrPm
	return
}

func init232() {
	//YidongActivityGroup("美团", 1623)
	//GetYiDongActivityMeeting()
	//GetYiDongActivity()
	//var timeText string
	//strTime := "2022-08-18 12:34:00"
	//startTime := utils.StrTimeToTime(strTime)
	//week := utils.StrDateTimeToWeek(strTime)
	//timeStrYmd := startTime.Format(utils.FormatDate)
	//timeStrHmm := startTime.Format(utils.FormatTime)
	//timeYmd := utils.StrTimeToTime(timeStrYmd + " 12:00:00") //拼接当天中午12点的时间
	//var amOrPm string
	//if startTime.After(timeYmd) {
	//	amOrPm = " PM"
	//} else {
	//	amOrPm = " AM"
	//}
	//timeText = timeStrYmd + "（" + week + "）" + timeStrHmm
	//fmt.Println(week)
	//fmt.Println(amOrPm)
	//fmt.Println(strTime)
	//fmt.Println(timeText)
}

//GetYiDongActivityMeeting获取易董到会详情
func GetYiDongActivityMeeting(cont context.Context) (err error) {
	var condition string

	startDate := time.Now().AddDate(0, 0, -2).Format(utils.FormatDateTime)
	endDate := time.Now().Add(-time.Minute * 120).Format(utils.FormatDateTime)
	condition += ` AND   activity_time > ` + "'" + startDate + "'"
	condition += ` AND  activity_time < ` + "'" + endDate + "'"
	//fmt.Println(startDate)
	//fmt.Println(endDate)
	artivityListYidong, err := models.GetActivityListByYidong(condition)
	if err != nil {
		fmt.Println("GetActivityListByYidong Err:", err.Error())
		return err
	}
	//return err
	if len(artivityListYidong) == 0 {
		return err
	}
	var token string
	token, _ = GetYiDongToken()

	for _, v := range artivityListYidong {
		defer func() {
			if err != nil {
				go utils.SendAlarmMsg("获取易董到会详情失败："+err.Error(), 2)
			}
		}()

		url := utils.YiDongZhengTongYunUrl + "interact/activityManageApi/getAttendPersonList?access_token=" + token
		method := "POST"
		payload := strings.NewReader(`{"activityId":"` + v.YidongActivityId + `"}`)
		client := &http.Client{}
		req, err := http.NewRequest(method, url, payload)
		if err != nil {
			fmt.Println(err)
			utils.FileLog.Info(err.Error())
			return err
		}
		req.Header.Add("Content-Type", "application/json")
		res, err := client.Do(req)
		if err != nil {
			fmt.Println(err)
			utils.FileLog.Info(err.Error())
			return err
		}
		defer res.Body.Close()
		var ApifoxModal *models.ApifoxModaluser
		body, err := ioutil.ReadAll(res.Body)
		if err != nil {
			fmt.Println(err)
			utils.FileLog.Info(err.Error())
			return err
		}
		//utils.FileLog.Info(string(body))
		//fmt.Println(string(body))
		err = json.Unmarshal(body, &ApifoxModal)
		if err != nil {
			fmt.Println("Getres.PublicGetDate Err:", err.Error())
			utils.FileLog.Info(err.Error())
			return err
		}

		//跟易董返回的用户状态修改活动以提交到会状态
		err = models.UpdateCygxActivitySubmitMeetingByYidong(v.YidongActivityId)
		if err != nil {
			fmt.Println("UpdateCygxActivitySubmitMeetingByYidong Err:", err.Error())
			return err
		}
		if len(ApifoxModal.Result) > 0 {
			itemlog := new(models.CygxYidongActivityMeetingApiLog)
			itemlog.YidongActivityId = v.YidongActivityId
			itemlog.Data = string(body)
			itemlog.CreateTime = time.Now()
			err = models.AddCygxYidongActivityMeetingApiLog(itemlog)
			if err != nil {
				fmt.Println("AddCygxYidongActivityMeetingApiLog Err:", err.Error())
				return err
			}
			for _, vresult := range ApifoxModal.Result {
				if vresult.EndTime != "" {
					err = models.UpdateCygxActivitySignupisMeet(v.ActivityId, vresult.PersonTelephone)
					if err != nil {
						fmt.Println("UpdateCygxActivitySignupisMeet Err:", err.Error())
						return err
					}
				}
			}
		}
	}
	return
}

//YidongActivityGroup 添加活动与产业标的的关联
func YidongActivityGroup(subjectName string, activityId int) (err error) {
	subjectList, err := models.GetCygxIndustrialSubjectList(subjectName)
	if err != nil {
		fmt.Println(err)
		return err
	}
	if len(subjectList) == 0 {
		return err
	}
	err = models.UpdateActivityshowSubject(activityId)
	if err != nil {
		go utils.SendAlarmMsg("UpdateActivityshowSubject ：根据易董推过来的匹配信息，判断临时标签是否展示失败"+err.Error(), 2)
	}
	var industrialActivityItems []*models.CygxIndustrialActivityGroupManagement
	var subjectActivityItems []*models.CygxIndustrialActivityGroupSubject
	mapSubjectName := make(map[string]string)
	for _, v := range subjectList {
		industrialActivityItem := new(models.CygxIndustrialActivityGroupManagement)
		subjectActivityItem := new(models.CygxIndustrialActivityGroupSubject)

		industrialActivityItem.ActivityId = activityId
		industrialActivityItem.IndustrialManagementId = v.IndustrialManagementId
		industrialActivityItem.Source = 1
		industrialActivityItem.CreateTime = time.Now()
		industrialActivityItems = append(industrialActivityItems, industrialActivityItem)

		subjectActivityItem.ActivityId = activityId
		subjectActivityItem.IndustrialSubjectId = v.IndustrialSubjectId
		subjectActivityItem.Source = 1
		subjectActivityItem.CreateTime = time.Now()

		if mapSubjectName[v.SubjectName] == "" {
			subjectActivityItems = append(subjectActivityItems, subjectActivityItem)
			mapSubjectName[v.SubjectName] = v.SubjectName
		}
	}
	err = models.AddCygxActiuvityGroupMulti(industrialActivityItems, subjectActivityItems)
	if err != nil {
		go utils.SendAlarmMsg("AddCygxActiuvityGroupMulti ：批量添加易董活动关联的活动标签失败"+err.Error(), 2)
	}
	return
}