activity_sign.go 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "hongze/hongze_cygx/models"
  5. "hongze/hongze_cygx/services"
  6. "hongze/hongze_cygx/utils"
  7. "strconv"
  8. "time"
  9. )
  10. // 活动
  11. type ActivitySignCoAntroller struct {
  12. BaseAuthController
  13. }
  14. // @Title 活动扫码自动签到
  15. // @Description 活动扫码签到接口
  16. // @Param ActivityId query int true "活动ID"
  17. // @Success Ret=200 {object} models.CygxActivityResp
  18. // @router /detail [get]
  19. func (this *ActivitySignCoAntroller) Detail() {
  20. br := new(models.BaseResponse).Init()
  21. defer func() {
  22. this.Data["json"] = br
  23. this.ServeJSON()
  24. }()
  25. user := this.User
  26. if user == nil {
  27. br.Msg = "请登录"
  28. br.ErrMsg = "请登录,用户信息为空"
  29. br.Ret = 408
  30. return
  31. }
  32. uid := user.UserId
  33. activityId, _ := this.GetInt("ActivityId")
  34. if activityId < 1 {
  35. br.Msg = "请输入活动ID"
  36. return
  37. }
  38. resp := new(models.CygxActivitySigninDetailResp)
  39. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  40. if err != nil && err.Error() != utils.ErrNoRow() {
  41. br.Msg = "获取信息失败"
  42. br.ErrMsg = "获取活动详情信息失败,Err:" + err.Error()
  43. return
  44. }
  45. if activityInfo == nil {
  46. br.Msg = "活动不存在"
  47. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  48. return
  49. }
  50. totalMySuccess, err := models.GetActivitySignupCount(uid, activityId)
  51. if err != nil {
  52. br.Msg = "获取失败"
  53. br.ErrMsg = "获取失败,Err:" + err.Error()
  54. return
  55. }
  56. detail := new(models.CygxActivitySigninResp)
  57. if totalMySuccess > 0 {
  58. detail.IsSignup = true
  59. }
  60. var condition string
  61. var pars []interface{}
  62. condition = " AND open_id = ? AND activity_id = ? "
  63. pars = append(pars, user.OpenId, activityId)
  64. total, err := models.GetCygxActivitySigninCount(condition, pars)
  65. if err != nil {
  66. br.Msg = "获取失败"
  67. br.ErrMsg = "获取失败,Err:" + err.Error()
  68. return
  69. }
  70. item := new(models.CygxActivitySignin)
  71. item.ActivityId = activityId
  72. item.UserId = user.UserId
  73. item.Mobile = user.Mobile
  74. item.Email = user.Email
  75. item.CompanyId = user.CompanyId
  76. item.RealName = user.RealName
  77. item.CompanyName = user.CompanyName
  78. item.IsSignup = totalMySuccess
  79. item.CountryCode = user.CountryCode
  80. item.OpenId = user.OpenId
  81. item.CreateTime = time.Now()
  82. if total == 0 && user.Mobile != "" {
  83. err = models.AddCygxActivitySignin(item)
  84. if err != nil {
  85. br.Msg = "签到失败"
  86. br.ErrMsg = "获取失败,Err:" + err.Error()
  87. return
  88. }
  89. }
  90. //记录签到信息到用户到会表
  91. if user.CompanyId > 1 {
  92. pars = make([]interface{}, 0)
  93. condition = " AND user_id = ? AND activity_id = ? "
  94. pars = append(pars, user.UserId, activityId)
  95. totalOfflineMeeting, err := models.GetCygxActivityOfflineMeetingDetailCount(condition, pars)
  96. if err != nil {
  97. br.Msg = "获取失败"
  98. br.ErrMsg = "获取失败,Err:" + err.Error()
  99. return
  100. }
  101. if totalOfflineMeeting == 0 {
  102. itemOfflineMeeting := new(models.CygxActivityOfflineMeetingDetail)
  103. itemOfflineMeeting.UserId = user.UserId
  104. itemOfflineMeeting.ActivityId = activityId
  105. itemOfflineMeeting.CreateTime = time.Now()
  106. itemOfflineMeeting.Mobile = user.Mobile
  107. itemOfflineMeeting.CompanyId = user.CompanyId
  108. itemOfflineMeeting.CompanyName = user.CompanyName
  109. itemOfflineMeeting.IsMeeting = 1
  110. err = models.AddCygxActivityOfflineMeetingDetail(itemOfflineMeeting)
  111. if err != nil {
  112. br.Msg = "签到失败"
  113. br.ErrMsg = "获取失败AddCygxActivityOfflineMeetingDetail,Err:" + err.Error()
  114. return
  115. }
  116. }
  117. //添加日志记录
  118. go services.AddCygxActivitySigninLog(item)
  119. //把报名信息写入签到到会表
  120. go services.AddCygxActivityOfflineMeetingDetail(activityId, user)
  121. }
  122. if user.Mobile != "" || total > 0 {
  123. resp.IsBindingMobile = true
  124. }
  125. if user.CompanyId == 1 {
  126. detail.IsNewUser = true
  127. }
  128. detail.ActivityId = activityId
  129. detail.ActivityName = activityInfo.ActivityName
  130. detail.Mobile = user.Mobile
  131. detail.RealName = user.RealName
  132. detail.CompanyName = user.CompanyName
  133. //用于前端二次回显
  134. if user.RealName == "" {
  135. pars = make([]interface{}, 0)
  136. condition = " AND open_id = ? AND activity_id = ? "
  137. pars = append(pars, user.OpenId, activityId)
  138. signinDetail, err := models.GetCygxActivitySigninDetail(condition, pars)
  139. if err != nil && err.Error() != utils.ErrNoRow() {
  140. br.Msg = "签到失败"
  141. br.ErrMsg = "获取失败GetCygxActivitySigninDetail,Err:" + err.Error()
  142. return
  143. }
  144. if signinDetail != nil {
  145. detail.BusinessCard = signinDetail.BusinessCard
  146. detail.Mobile = signinDetail.Mobile
  147. detail.RealName = signinDetail.RealName
  148. detail.CompanyName = signinDetail.CompanyName
  149. }
  150. }
  151. resp.Detail = detail
  152. br.Ret = 200
  153. br.Success = true
  154. br.Msg = "获取成功"
  155. br.Data = resp
  156. }
  157. // @Title 活动扫码手动签到
  158. // @Description 活动扫码手动签到接口
  159. // @Param ActivityId query int true "活动ID"
  160. // @Success Ret=200 {object} models.CygxActivityResp
  161. // @router /byHand [post]
  162. func (this *ActivitySignCoAntroller) ByHand() {
  163. br := new(models.BaseResponse).Init()
  164. defer func() {
  165. this.Data["json"] = br
  166. this.ServeJSON()
  167. }()
  168. user := this.User
  169. if user == nil {
  170. br.Msg = "请登录"
  171. br.ErrMsg = "请登录,用户信息为空"
  172. br.Ret = 408
  173. return
  174. }
  175. uid := user.UserId
  176. resp := new(models.CygxActivitySigninDetailResp)
  177. var req models.CygxActivitySigninReq
  178. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  179. if err != nil {
  180. br.Msg = "参数解析异常!"
  181. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  182. return
  183. }
  184. signinType := req.SigninType
  185. activityId := req.ActivityId
  186. CountryCode := req.CountryCode
  187. Mobile := req.Mobile
  188. CompanyName := req.CompanyName
  189. BusinessCard := req.BusinessCard
  190. RealName := req.RealName
  191. if activityId < 1 {
  192. br.Msg = "请输入活动ID"
  193. return
  194. }
  195. user.RealName = RealName
  196. user.CompanyName = CompanyName
  197. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  198. if err != nil && err.Error() != utils.ErrNoRow() {
  199. br.Msg = "获取信息失败"
  200. br.ErrMsg = "获取活动详情信息失败,Err:" + err.Error()
  201. return
  202. }
  203. if activityInfo == nil {
  204. br.Msg = "活动不存在"
  205. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  206. return
  207. }
  208. totalMySuccess, err := models.GetActivitySignupCount(uid, activityId)
  209. if err != nil {
  210. br.Msg = "获取失败"
  211. br.ErrMsg = "获取失败,Err:" + err.Error()
  212. return
  213. }
  214. item := new(models.CygxActivitySignin)
  215. var condition string
  216. var pars []interface{}
  217. condition = " AND open_id = ? AND activity_id = ? "
  218. pars = append(pars, user.OpenId, activityId)
  219. total, err := models.GetCygxActivitySigninCount(condition, pars)
  220. if err != nil {
  221. br.Msg = "获取失败"
  222. br.ErrMsg = "获取失败,Err:" + err.Error()
  223. return
  224. }
  225. if signinType == 1 {
  226. if req.Mobile == "" {
  227. br.Msg = "参数错误"
  228. br.ErrMsg = "参数错误,手机号为空 为空"
  229. return
  230. }
  231. itemMsgCode, err := models.GetMsgCode(req.Mobile, req.VCode)
  232. if err != nil {
  233. if err.Error() == utils.ErrNoRow() {
  234. br.Msg = "验证码错误,请重新输入"
  235. br.ErrMsg = "校验验证码失败,Err:" + err.Error()
  236. return
  237. } else {
  238. br.Msg = "验证码错误,请重新输入"
  239. br.ErrMsg = "校验验证码失败,Err:" + err.Error()
  240. return
  241. }
  242. }
  243. if itemMsgCode == nil {
  244. br.Msg = "验证码错误,请重新输入"
  245. return
  246. }
  247. userMobile, err := models.GetWxUserItemByMobile(Mobile)
  248. if err != nil && err.Error() != utils.ErrNoRow() {
  249. br.Msg = "签到失败"
  250. br.ErrMsg = "获取失败,Err:" + err.Error()
  251. return
  252. }
  253. if userMobile != nil {
  254. user = userMobile
  255. }
  256. } else {
  257. if BusinessCard == "" {
  258. br.Msg = "签到失败"
  259. br.ErrMsg = "签到失败名片地址为空,Err:"
  260. return
  261. }
  262. item.BusinessCard = BusinessCard
  263. }
  264. item.ActivityId = activityId
  265. item.UserId = user.UserId
  266. item.Mobile = Mobile
  267. item.CountryCode = CountryCode
  268. item.Email = user.Email
  269. item.CompanyId = user.CompanyId
  270. item.RealName = user.RealName
  271. item.CompanyName = user.CompanyName
  272. item.IsSignup = totalMySuccess
  273. item.BusinessCard = BusinessCard
  274. item.OpenId = user.OpenId
  275. item.CreateTime = time.Now()
  276. if total == 0 {
  277. err = models.AddCygxActivitySignin(item)
  278. if err != nil {
  279. br.Msg = "签到失败"
  280. br.ErrMsg = "获取失败,Err:" + err.Error()
  281. return
  282. }
  283. } else {
  284. pars = make([]interface{}, 0)
  285. condition = " AND open_id = ? AND activity_id = ? "
  286. pars = append(pars, user.OpenId, activityId)
  287. signinDetail, err := models.GetCygxActivitySigninDetail(condition, pars)
  288. if err != nil {
  289. br.Msg = "签到失败"
  290. br.ErrMsg = "获取失败GetCygxActivitySigninDetail,Err:" + err.Error()
  291. return
  292. }
  293. item.Id = signinDetail.Id
  294. err = models.UpdateCygxActivitySignin(item)
  295. if err != nil {
  296. br.Msg = "签到失败"
  297. br.ErrMsg = "获取失败,UpdateCygxActivitySignin,Err:" + err.Error()
  298. return
  299. }
  300. }
  301. detail := new(models.CygxActivitySigninResp)
  302. if totalMySuccess > 0 {
  303. detail.IsSignup = true
  304. }
  305. //添加日志记录
  306. go services.AddCygxActivitySigninLog(item)
  307. if user.CompanyId <= 1 {
  308. detail.IsNewUser = true
  309. }
  310. detail.ActivityId = activityId
  311. detail.ActivityName = activityInfo.ActivityName
  312. detail.Mobile = Mobile
  313. detail.RealName = RealName
  314. detail.CompanyName = CompanyName
  315. resp.Detail = detail
  316. resp.IsBindingMobile = true
  317. br.Ret = 200
  318. br.Success = true
  319. br.Msg = "获取成功"
  320. br.Data = resp
  321. }