hongze_open_api/controllers/yidong.go

package controllers

import (
	"encoding/json"
	"fmt"
	"hongze/hongze_open_api/models/request/yidong"
	cygxActivity "hongze/hongze_open_api/models/tables/cygx_activity"
	"hongze/hongze_open_api/services/alarm_msg"
	servicesYidong "hongze/hongze_open_api/services/yidong"
	"hongze/hongze_open_api/utils"
	"math"
	"strconv"
	"strings"
	"time"
)

// 易董
type YiDongController struct {
	BaseCommon
}

// YiDongController
// @Title 易董提交报名用户审核接口
// @Description 易董提交报名用户审核接口
// @Param	request	body yidong.ActivityExamineReq true "type json string"
// @Success 200 创建成功
// @router /activity/examine/signup [post]
func (c *YiDongController) ActivityExamine() {
	var req yidong.ActivityExamineReq
	err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
	if err != nil {
		c.FailWithMessage("参数解析异常")
		return
	}
	activityIdYiDong := req.ActivityId
	timeInt := req.Time
	list := req.List
	appid := req.Appid
	timeUnix := time.Now().Unix() //当前格林威治时间，int64类型
	timestamp := int64(timeInt)
	if math.Abs(float64(timeUnix-timestamp)) > 600 {
		c.FailWithMessage("当前时间异常，请调整设备时间与北京时间一致：" + strconv.Itoa(timeInt))
		return
	}
	//校验 APPID 与ip白名单
	ip := c.Ctx.Input.IP()
	err = servicesYidong.CheckAppidAndIp(appid, ip)
	if err != nil {
		c.FailWithMessage(err.Error())
		return
	}
	//校验 签名

	signStr := servicesYidong.GetSign(activityIdYiDong, timeInt)
	fmt.Println("____")
	fmt.Println(signStr)
	ownSign := req.Sign
	if ownSign != signStr {
		c.FailWithMessage("签名错误！")
		return
	}
	activityInfo, err := cygxActivity.GetAddActivityInfoById(activityIdYiDong)
	if err != nil {
		c.FailWithMessage("会议id异常：" + activityIdYiDong)
		return
	}
	activityId := activityInfo.ActivityId
	signupList, err := cygxActivity.GetActivitySignupListByActivity(activityId)
	if err != nil {
		c.FailWithMessage("会议id异常：" + activityIdYiDong)
		return
	}
	mapSignUp := make(map[string]string)
	for _, v := range signupList {
		mapSignUp[v.Mobile] = v.Mobile
	}
	var examineMobile string
	for _, v := range list {
		var dateTxt = []byte(v.Mobile)
		resultDe := utils.DesBase64Decrypt(dateTxt)
		deMobile := string(resultDe)
		if deMobile == "" {
			go alarm_msg.SendAlarmMsg("加密手机号解密失败："+v.Mobile, 3)
			c.FailWithMessage("加密手机号解密失败：" + v.Mobile)
			return
		}
		examineMobile += "'" + deMobile + "'" + ","
	}
	examineMobile = strings.TrimRight(examineMobile, ",")
	userList, err := cygxActivity.GetUserListByMobile(examineMobile)
	if err != nil {
		c.FailWithMessage("操作失败，用户信息不存在")
		return
	}
	mapUserinfo := make(map[string]*cygxActivity.CygxActivitySignup)
	for _, v := range userList {
		item := new(cygxActivity.CygxActivitySignup)
		item.UserId = v.UserId
		item.RealName = v.RealName
		item.SellerName = v.SellerName
		item.ActivityId = activityId
		item.CreateTime = time.Now()
		item.Mobile = v.Mobile
		item.Email = v.Email
		item.CompanyId = v.CompanyId
		item.CompanyName = v.CompanyName
		item.Source = 3
		//优先绑定用户修改过的外呼手机号
		if v.OutboundMobile != "" {
			item.OutboundMobile = v.OutboundMobile
			if v.OutboundCountryCode == "" {
				item.CountryCode = "86"
			} else {
				item.CountryCode = v.OutboundCountryCode
			}
		} else {
			item.OutboundMobile = v.Mobile
			if v.CountryCode == "" {
				item.CountryCode = "86"
			} else {
				item.CountryCode = v.CountryCode
			}
		}
		item.SignupType = 1
		mapUserinfo[v.Mobile] = item
	}
	var items []*cygxActivity.ExamineStatusReq
	var itemsAdd []*cygxActivity.CygxActivitySignup

	for _, v := range list {
		item := new(cygxActivity.ExamineStatusReq)
		//encryptMobile := string(utils.DesBase64Encrypt([]byte(v.Mobile)))
		//fmt.Println(encryptMobile)
		//continue
		//encryptMobile := string(utils.DesBase64Encrypt([]byte(v.Mobile)))
		var dateTxt = []byte(v.Mobile)
		resultDe := utils.DesBase64Decrypt(dateTxt)
		deMobile := string(resultDe)
		if deMobile == "" {
			c.FailWithMessage("加密手机号解密失败：" + v.Mobile)
			go alarm_msg.SendAlarmMsg("加密手机号解密失败："+v.Mobile, 3)
			return
		}
		if mapSignUp[deMobile] != "" {
			item.ActivityId = activityId
			item.Mobile = deMobile
			item.ExamineStatus = v.ExamineStatus
			items = append(items, item)
		} else {
			if mapUserinfo[deMobile] != nil {
				mapUserinfo[deMobile].YidongExamineStatus = v.ExamineStatus
				itemsAdd = append(itemsAdd, mapUserinfo[deMobile])
			}
		}
	}
	err = cygxActivity.UpdateActivitySignupNumMulti(items)
	if err != nil {
		c.FailWithMessage("修改活动审核状态失败：" + activityIdYiDong)
		go alarm_msg.SendAlarmMsg("修改活动审核状态失败："+err.Error()+"活动ID"+activityIdYiDong, 3)
		return
	}
	err = cygxActivity.AddActivitySignupNumMulti(itemsAdd)
	if err != nil {
		c.FailWithMessage("修改活动审核状态失败：" + activityIdYiDong)
		go alarm_msg.SendAlarmMsg("修改活动审核状态失败："+err.Error()+"活动ID"+activityIdYiDong, 3)
		return
	}
	c.OkWithMessage("操作成功")
}

func init23() {
	//allow 59.46.229.165;
	//allow 123.185.222.0/24;
	//allow 123.185.223.0/24;
	//allow 59.36.22.17;
	//allow 120.86.187.82;
	//202.105.122.162

	//var ipstr string
	//var ipstrs string
	//ipstr = "123.185.223."
	//
	//for i := 0; i <= 24; i++ {
	//	fmt.Println(i)
	//	ipstrs += ipstr + strconv.Itoa(i) + ","
	//	//ipstr += ipstr + strconv.Itoa(i)
	//}
	//fmt.Println(ipstrs)
}

// YiDongController
// @Title 易董提交报名时，获取用户信息接口
// @Description 易董提交报名时，获取用户信息接口
// @Param	request	body yidong.ActivityExamineReq true "type json string"
// @Success 200 创建成功
// @router /activity/user/signup [post]
func (c *YiDongController) UserSignup() {
	var req yidong.ActivitySignUpReq
	err := json.Unmarshal(c.Ctx.Input.RequestBody, &req)
	if err != nil {
		c.FailWithMessage("参数解析异常")
		return
	}
	activityIdYiDong := req.ActivityId
	timeInt := req.Time
	appid := req.Appid
	mobile := req.Mobile
	timeUnix := time.Now().Unix() //当前格林威治时间，int64类型
	timestamp := int64(timeInt)
	if math.Abs(float64(timeUnix-timestamp)) > 600 {
		c.FailWithMessage("当前时间异常，请调整设备时间与北京时间一致：" + strconv.Itoa(timeInt))
		return
	}
	//校验 APPID 与ip白名单
	ip := c.Ctx.Input.IP()
	err = servicesYidong.CheckAppidAndIp(appid, ip)
	if err != nil {
		c.FailWithMessage(err.Error())
		return
	}
	//校验 签名

	signStr := servicesYidong.GetSign(activityIdYiDong, timeInt)
	fmt.Println("____")
	fmt.Println(signStr)
	ownSign := req.Sign
	if ownSign != signStr {
		c.FailWithMessage("签名错误！")
		return
	}
	activityInfo, err := cygxActivity.GetAddActivityInfoById(activityIdYiDong)
	if err != nil {
		c.FailWithMessage("会议id异常：" + activityIdYiDong)
		return
	}
	activityId := activityInfo.ActivityId

	var dateTxt = []byte(mobile)
	resultDe := utils.DesBase64Decrypt(dateTxt)
	deMobile := string(resultDe)
	if deMobile == "" {
		go alarm_msg.SendAlarmMsg("加密手机号解密失败："+mobile, 3)
		c.FailWithMessage("加密手机号解密失败：" + mobile)
		return
	}

	item := new(cygxActivity.CygxYidongActivitySignupLog)
	item.ActivityId = activityId
	item.YidongActivityId = activityIdYiDong
	item.CreateTime = time.Now()
	item.Mobile = deMobile

	err = cygxActivity.AddCygxYidongActivitySignupLog(item)
	if err != nil {
		fmt.Println(err)
		c.FailWithMessage("获取用户信息失败：" + activityIdYiDong)
		go alarm_msg.SendAlarmMsg("修改活动审核状态失败："+err.Error()+"活动ID"+activityIdYiDong, 3)
		return
	}
	userInfo, err := cygxActivity.GetAddActivityInfoByMobile(deMobile)
	if err != nil {
		fmt.Println(err)
		c.FailWithMessage("获取用户信息失败：" + activityIdYiDong)
		go alarm_msg.SendAlarmMsg("修改活动审核状态失败："+err.Error()+"活动ID"+activityIdYiDong, 3)
		return
	}
	c.OkDetailed(userInfo, "获取成功")
}