123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116 |
- 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
- }
|