hongze_cygx/services/activity_signin.go

package services

import (
	"errors"
	"fmt"
	"hongze/hongze_cygx/models"
	"hongze/hongze_cygx/utils"
	"strconv"
	"time"
)

// AddCygxActivitySigninLog 扫码签到日志记录
func AddCygxActivitySigninLog(item *models.CygxActivitySignin) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg("扫码签到日志记录，失败,活动ID："+strconv.Itoa(item.ActivityId)+err.Error(), 2)
		}
	}()
	//添加日志记录
	itemLog := new(models.CygxActivitySigninLog)
	itemLog.ActivityId = item.ActivityId
	itemLog.UserId = item.UserId
	itemLog.Mobile = item.Mobile
	itemLog.Email = item.Email
	itemLog.CompanyId = item.CompanyId
	itemLog.RealName = item.RealName
	itemLog.CompanyName = item.CompanyName
	itemLog.IsSignup = item.IsSignup
	itemLog.BusinessCard = item.BusinessCard
	itemLog.CountryCode = item.CountryCode
	itemLog.OpenId = item.OpenId
	itemLog.CreateTime = time.Now()
	err = models.AddCygxActivitySigninLog(itemLog)
	if err != nil {
		return
	}

	err = models.UpdatedateCygxActivitySignin(item)
	return
}

// AddCygxActivityOfflineMeetingDetail 扫码签到日志记录
func AddCygxActivityOfflineMeetingDetail(activityid int, user *models.WxUserItem) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg("扫码签到日志记录，失败,活动ID："+strconv.Itoa(activityid)+err.Error(), 2)
		}
	}()

	var condition string
	var pars []interface{}

	condition = `  AND activity_id = ?`
	pars = append(pars, activityid)
	listOfflineMeeting, err := models.GetOfflineMeetingList(condition, pars)
	if err != nil {
		err = errors.New("GetOfflineMeetingList, Err: " + err.Error())
		return
	}
	mapOfflineMeeting := make(map[int]bool)
	for _, v := range listOfflineMeeting {
		mapOfflineMeeting[v.UserId] = true
	}
	pars = make([]interface{}, 0)
	condition = ` AND do_fail_type = 0 AND activity_id  = ?`
	pars = append(pars, activityid)
	listSignup, e := models.GetActivitySignupList(condition, pars)
	if e != nil {
		err = errors.New("GetResourceDataList, Err: " + e.Error())
		return
	}

	var items []*models.CygxActivityOfflineMeetingDetail
	for _, v := range listSignup {
		if !mapOfflineMeeting[v.UserId] {
			item := new(models.CygxActivityOfflineMeetingDetail)
			item.UserId = v.UserId
			item.ActivityId = v.ActivityId
			item.CreateTime = v.CreateTime
			item.Mobile = v.Mobile
			item.CompanyId = v.CompanyId
			item.CompanyName = v.CompanyName
			if user.UserId == v.UserId {
				item.IsMeeting = 1
				item.SigninTime = time.Now().Format(utils.FormatDateTime)
			}
			items = append(items, item)
		}
	}

	//添加线下到会信息记录
	_, err = models.AddCygxActivityOfflineMeetingDetailList(items)
	if err != nil {
		err = errors.New("AddCygxActivityOfflineMeetingDetailList, Err: " + err.Error())
		return
	}

	//修改活动是否提交到会状态
	err = models.UpdateCygxActivitySubmitMeetingByActivityId(activityid)
	if err != nil {
		err = errors.New("UpdateCygxActivitySubmitMeetingByActivityId, Err: " + err.Error())
		return
	}

	//修改签到时间
	err = models.UpdateCygxActivityOfflineMeetingDetailSigninTime(activityid, user.UserId)
	if err != nil {
		err = errors.New("UpdateCygxActivityOfflineMeetingDetailSigninTime, Err: " + err.Error())
		return
	}

	return

}