order.go 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hongze_web_mfyx/models"
  6. "hongze/hongze_web_mfyx/models/order"
  7. "hongze/hongze_web_mfyx/services"
  8. "hongze/hongze_web_mfyx/utils"
  9. "strings"
  10. "time"
  11. )
  12. // 订单
  13. type OrderController struct {
  14. BaseAuthController
  15. }
  16. // @Title 通过文章创建订单
  17. // @Description 通过文章创建订单接口
  18. // @Param request body models.ActivitySingnupRep true "type json string"
  19. // @Success Ret=200 {object} models.SignupStatus
  20. // @router /addByArticle [post]
  21. func (this *OrderController) AddByArticle() {
  22. br := new(models.BaseResponse).Init()
  23. defer func() {
  24. this.Data["json"] = br
  25. this.ServeJSON()
  26. }()
  27. user := this.User
  28. if user == nil {
  29. br.Msg = "请登录"
  30. br.ErrMsg = "请登录,用户信息为空"
  31. br.Ret = 408
  32. return
  33. }
  34. var req order.CygxOrderAddReq
  35. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  36. if err != nil {
  37. br.Msg = "参数解析异常!"
  38. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  39. return
  40. }
  41. uid := user.UserId
  42. goodsId := req.GoodsId
  43. sourceId := req.SourceId
  44. if goodsId == 0 {
  45. br.Msg = "支付失败"
  46. br.ErrMsg = "支付失败,goodsId 信息错误Err:" + err.Error()
  47. return
  48. }
  49. goodsDetail, err := order.GetCygxGoodsDetailByGoodsId(goodsId)
  50. if err != nil {
  51. br.Msg = "获取信息失败"
  52. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  53. return
  54. }
  55. var title string
  56. oldOrderCode := services.GetHaverEquallyOrderByUser10Min(uid, goodsId) //获取用户十分钟之内是否有相同的订单信息
  57. articleDetail, err := models.GetArticleDetailById(sourceId)
  58. if err != nil {
  59. br.Msg = "获取信息失败"
  60. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  61. return
  62. }
  63. title = articleDetail.Title
  64. item := new(order.CygxOrder)
  65. item.OrderCode = utils.GetOrdernum()
  66. item.OutTradeNo = "TRADE" + item.OrderCode
  67. item.GoodsName = goodsDetail.GoodsName
  68. item.GoodsId = goodsId
  69. item.GoodsMoney = goodsDetail.Price
  70. item.OrderMoney = goodsDetail.CurrentPrice
  71. item.SourceId = sourceId
  72. item.Source = utils.CYGX_OBJ_ARTICLE
  73. item.SourceTitle = title
  74. item.UserId = user.UserId
  75. item.Mobile = user.Mobile
  76. item.Email = user.Email
  77. item.CompanyId = user.CompanyId
  78. item.CompanyName = user.CompanyName
  79. item.RealName = user.RealName
  80. item.SellerName, item.SellerId = services.GetSellerName(user) // 销售姓名
  81. item.ShareName, item.ShareId = services.GetAdminByInviteShareCode(req.InviteShareCode) // 分享人信息
  82. item.CreateTime = time.Now()
  83. item.ModifyTime = time.Now()
  84. item.RegisterPlatform = utils.REGISTER_PLATFORM
  85. item.OrderType = 1
  86. //如果十分钟之内有相同的订单就修改,没有就新增
  87. if oldOrderCode == "" {
  88. err = order.AddCygxOrder(item)
  89. } else {
  90. item.OrderCode = oldOrderCode
  91. err = order.UpdateCygxOrder(item, oldOrderCode)
  92. }
  93. if err != nil {
  94. br.Msg = "创建订单信息失败"
  95. br.ErrMsg = "创建订单信息失败,Err:" + err.Error()
  96. return
  97. }
  98. codeUrl, err := services.ExampleNativeApiServicePrepay(item)
  99. if err != nil {
  100. br.Msg = "创建订单信息失败"
  101. br.ErrMsg = "创建订单信息失败,ExampleNativeApiServicePrepay:" + err.Error()
  102. return
  103. }
  104. resp := new(order.WxNativeApiResp)
  105. _, resp.PayTimeCountdown = services.GetHaverEquallyOrderByUser10MinByArticle(uid, sourceId, goodsId) //截止支付时间倒计时
  106. resp.CodeUrl = codeUrl
  107. resp.OrderCode = item.OrderCode
  108. br.Data = resp
  109. br.Ret = 200
  110. br.Success = true
  111. br.Msg = "操作成功"
  112. }
  113. // @Title 通过活动创建订单
  114. // @Description 通过活动创建订单接口
  115. // @Param request body models.ActivitySingnupRep true "type json string"
  116. // @Success Ret=200 {object} models.SignupStatus
  117. // @router /addByActivity [post]
  118. func (this *OrderController) AddByActivity() {
  119. br := new(models.BaseResponse).Init()
  120. defer func() {
  121. this.Data["json"] = br
  122. this.ServeJSON()
  123. }()
  124. user := this.User
  125. if user == nil {
  126. br.Msg = "请登录"
  127. br.ErrMsg = "请登录,用户信息为空"
  128. br.Ret = 408
  129. return
  130. }
  131. var req order.CygxOrderAddReq
  132. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  133. if err != nil {
  134. br.Msg = "参数解析异常!"
  135. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  136. return
  137. }
  138. uid := user.UserId
  139. goodsId := req.GoodsId
  140. sourceId := req.SourceId
  141. if goodsId == 0 {
  142. br.Msg = "支付失败"
  143. br.ErrMsg = "支付失败,goodsId 信息错误Err:" + err.Error()
  144. return
  145. }
  146. goodsDetail, err := order.GetCygxGoodsDetailByGoodsId(goodsId)
  147. if err != nil {
  148. br.Msg = "获取信息失败"
  149. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  150. return
  151. }
  152. activityDetail, err := models.GetAddActivityInfoById(sourceId)
  153. if err != nil {
  154. br.Msg = "获取信息失败"
  155. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  156. return
  157. }
  158. var title string
  159. var oldOrderCode string
  160. //var _ int
  161. item := new(order.CygxOrder)
  162. if (!activityDetail.IsResearchPoints && activityDetail.IsLimitPeople == 0) || activityDetail.YidongActivityId != "" { //易董的活动 或者(不扣点且不限制人数)走月卡日卡逻辑
  163. oldOrderCode = services.GetHaverEquallyOrderByUser10Min(uid, goodsId) //获取用户十分钟之内是否有相同的订单信息
  164. item.OrderType = 1
  165. } else {
  166. oldOrderCode, _ = services.GetHaverEquallyOrderByUser10MinByActivty(uid, sourceId)
  167. item.OrderType = 2
  168. }
  169. title = activityDetail.ActivityName
  170. item.OrderCode = utils.GetOrdernum()
  171. item.OutTradeNo = "TRADE" + item.OrderCode
  172. if activityDetail.ActivityTypeName == "买方线下交流" {
  173. item.GoodsName = "买方交流"
  174. }
  175. if activityDetail.ActivityTypeName == "专家电话会" || activityDetail.ActivityTypeName == "专家线下沙龙" {
  176. item.GoodsName = "专家调研"
  177. }
  178. if activityDetail.ActivityTypeName == "公司调研电话会" {
  179. item.GoodsName = "上市公司小范围"
  180. }
  181. switch goodsId {
  182. case 1:
  183. item.GoodsName = "日卡"
  184. case 2:
  185. item.GoodsName = "月卡"
  186. }
  187. //如果活动有自定义的价格就优先按照自定义的价格来
  188. if activityDetail.ActivityPrice > 0 {
  189. goodsDetail.CurrentPrice = activityDetail.ActivityPrice
  190. }
  191. //fmt.Println("item.GoodsName", item.GoodsName)
  192. //return
  193. item.GoodsId = goodsId
  194. item.GoodsMoney = goodsDetail.Price
  195. item.OrderMoney = goodsDetail.CurrentPrice
  196. item.SourceId = sourceId
  197. item.Source = utils.CYGX_OBJ_ACTIVITY
  198. item.SourceTitle = title
  199. item.UserId = user.UserId
  200. item.Mobile = user.Mobile
  201. item.Email = user.Email
  202. item.CompanyId = user.CompanyId
  203. item.CompanyName = user.CompanyName
  204. item.RealName = user.RealName
  205. item.SellerName, item.SellerId = services.GetSellerName(user) // 销售姓名
  206. item.ShareName, item.ShareId = services.GetAdminByInviteShareCode(req.InviteShareCode) // 分享人信息
  207. item.CreateTime = time.Now()
  208. item.ModifyTime = time.Now()
  209. item.RegisterPlatform = utils.REGISTER_PLATFORM
  210. //如果十分钟之内有相同的订单就修改,没有就新增
  211. if oldOrderCode == "" {
  212. err = order.AddCygxOrder(item)
  213. } else {
  214. item.OrderCode = oldOrderCode
  215. err = order.UpdateCygxOrder(item, oldOrderCode)
  216. }
  217. codeUrl, err := services.ExampleNativeApiServicePrepay(item)
  218. if err != nil {
  219. br.Msg = "创建订单信息失败"
  220. br.ErrMsg = "创建订单信息失败,ExampleNativeApiServicePrepay:" + err.Error()
  221. return
  222. }
  223. resp := new(order.WxNativeApiResp)
  224. _, resp.PayTimeCountdown = services.GetHaverEquallyOrderByUser10MinByActivty(uid, sourceId) //截止支付时间倒计时
  225. resp.CodeUrl = codeUrl
  226. resp.OrderCode = item.OrderCode
  227. br.Data = resp
  228. br.Ret = 200
  229. br.Success = true
  230. br.Msg = "操作成功"
  231. }
  232. // @Title 通过研选专栏创建订单
  233. // @Description 通过文章创建订单接口
  234. // @Param request body models.ActivitySingnupRep true "type json string"
  235. // @Success Ret=200 {object} models.SignupStatus
  236. // @router /addByYanxuanspecial [post]
  237. func (this *OrderController) AddByYanxuanspecial() {
  238. br := new(models.BaseResponse).Init()
  239. defer func() {
  240. this.Data["json"] = br
  241. this.ServeJSON()
  242. }()
  243. user := this.User
  244. if user == nil {
  245. br.Msg = "请登录"
  246. br.ErrMsg = "请登录,用户信息为空"
  247. br.Ret = 408
  248. return
  249. }
  250. var req order.CygxOrderAddReq
  251. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  252. if err != nil {
  253. br.Msg = "参数解析异常!"
  254. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  255. return
  256. }
  257. uid := user.UserId
  258. goodsId := req.GoodsId
  259. sourceId := req.SourceId
  260. if goodsId == 0 {
  261. br.Msg = "支付失败"
  262. br.ErrMsg = "支付失败,goodsId 信息错误Err:" + err.Error()
  263. return
  264. }
  265. goodsDetail, err := order.GetCygxGoodsDetailByGoodsId(goodsId)
  266. if err != nil {
  267. br.Msg = "获取信息失败"
  268. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  269. return
  270. }
  271. var title string
  272. oldOrderCode := services.GetHaverEquallyOrderByUser10Min(uid, goodsId) //获取用户十分钟之内是否有相同的订单信息
  273. // 研选专栏
  274. yanxuanSpecialBySpeciaDetail, err := models.GetYanxuanSpecialBySpecialId(sourceId)
  275. if err != nil {
  276. br.Msg = "获取信息失败"
  277. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  278. return
  279. }
  280. title = yanxuanSpecialBySpeciaDetail.Title
  281. item := new(order.CygxOrder)
  282. item.OrderCode = utils.GetOrdernum()
  283. item.OutTradeNo = "TRADE" + item.OrderCode
  284. item.GoodsName = goodsDetail.GoodsName
  285. item.GoodsId = goodsId
  286. item.GoodsMoney = goodsDetail.Price
  287. item.OrderMoney = goodsDetail.CurrentPrice
  288. item.SourceId = sourceId
  289. item.Source = utils.CYGX_OBJ_YANXUANSPECIAL
  290. item.SourceTitle = title
  291. item.UserId = user.UserId
  292. item.Mobile = user.Mobile
  293. item.Email = user.Email
  294. item.CompanyId = user.CompanyId
  295. item.CompanyName = user.CompanyName
  296. item.RealName = user.RealName
  297. item.SellerName, item.SellerId = services.GetSellerName(user) // 销售姓名
  298. item.ShareName, item.ShareId = services.GetAdminByInviteShareCode(req.InviteShareCode) // 分享人信息
  299. item.CreateTime = time.Now()
  300. item.ModifyTime = time.Now()
  301. item.RegisterPlatform = utils.REGISTER_PLATFORM
  302. item.OrderType = 1
  303. //如果十分钟之内有相同的订单就修改,没有就新增
  304. if oldOrderCode == "" {
  305. err = order.AddCygxOrder(item)
  306. } else {
  307. item.OrderCode = oldOrderCode
  308. err = order.UpdateCygxOrder(item, oldOrderCode)
  309. }
  310. if err != nil {
  311. br.Msg = "创建订单信息失败"
  312. br.ErrMsg = "创建订单信息失败,Err:" + err.Error()
  313. return
  314. }
  315. codeUrl, err := services.ExampleNativeApiServicePrepay(item)
  316. if err != nil {
  317. br.Msg = "创建订单信息失败"
  318. br.ErrMsg = "创建订单信息失败,ExampleNativeApiServicePrepay:" + err.Error()
  319. return
  320. }
  321. resp := new(order.WxNativeApiResp)
  322. _, resp.PayTimeCountdown = services.GetHaverEquallyOrderByUser10MinByArticle(uid, sourceId, goodsId) //截止支付时间倒计时
  323. resp.CodeUrl = codeUrl
  324. resp.OrderCode = item.OrderCode
  325. br.Data = resp
  326. br.Ret = 200
  327. br.Success = true
  328. br.Msg = "操作成功"
  329. }
  330. // @Title 用户订单列表
  331. // @Description 用户订单列表接口
  332. // @Param PageSize query int true "每页数据条数"
  333. // @Param CurrentIndex query int true "当前页页码,从1开始"
  334. // @Param OrderType query int false "订单类型 1:畅读卡订单,2:单场付费订单"
  335. // @Success 200 {object} models.SpecialListResp
  336. // @router /user/orderList [get]
  337. func (this *OrderController) UserOrderList() {
  338. br := new(models.BaseResponse).Init()
  339. defer func() {
  340. this.Data["json"] = br
  341. this.ServeJSON()
  342. }()
  343. user := this.User
  344. if user == nil {
  345. br.Msg = "请登录"
  346. br.ErrMsg = "请登录,用户信息为空"
  347. br.Ret = 408
  348. return
  349. }
  350. pageSize, _ := this.GetInt("PageSize")
  351. currentIndex, _ := this.GetInt("CurrentIndex")
  352. orderType, _ := this.GetInt("OrderType", 1)
  353. var startSize int
  354. if pageSize <= 0 {
  355. pageSize = utils.PageSize20
  356. }
  357. if currentIndex <= 0 {
  358. currentIndex = 1
  359. }
  360. startSize = utils.StartIndex(currentIndex, pageSize)
  361. resp := new(order.UserOrderListResp)
  362. var condition string
  363. var pars []interface{}
  364. userId := user.UserId
  365. if orderType > 0 {
  366. condition += ` AND order_type = ? `
  367. pars = append(pars, orderType)
  368. }
  369. condition += ` AND user_id = ? `
  370. pars = append(pars, userId)
  371. total, err := order.GetCygxOrderCount(condition, pars)
  372. if err != nil {
  373. br.Msg = "获取失败"
  374. br.ErrMsg = "获取失败, Err:" + err.Error()
  375. return
  376. }
  377. condition += ` ORDER BY order_id DESC `
  378. list, err := order.GetCygxOrderList(condition, pars, startSize, pageSize)
  379. if err != nil {
  380. br.Msg = "获取失败"
  381. br.ErrMsg = "获取失败, Err:" + err.Error()
  382. return
  383. }
  384. var activityIds []int
  385. for _, v := range list {
  386. if v.Source == utils.CYGX_OBJ_ACTIVITY {
  387. activityIds = append(activityIds, v.SourceId)
  388. }
  389. }
  390. activityLabelKeyword := services.GetActivityOrderListLabelKeywordByActivityIds(activityIds)
  391. for _, v := range list {
  392. item := new(order.OrderListResp)
  393. item.OrderCode = v.OrderCode
  394. item.OrderMoney = v.OrderMoney
  395. item.SourceId = v.SourceId
  396. item.Source = v.Source
  397. item.SourceTitle = v.SourceTitle
  398. item.OrderStatus = v.OrderStatus
  399. switch item.OrderStatus {
  400. case 0:
  401. item.OrderStatusText = "已取消"
  402. case 1:
  403. item.OrderStatusText = "待支付"
  404. case 2:
  405. item.OrderStatusText = "已支付"
  406. case 3:
  407. item.OrderStatusText = "退款成功"
  408. case 4:
  409. item.OrderStatusText = "退款处理中"
  410. case 5:
  411. item.OrderStatusText = "退款异常"
  412. case 6:
  413. item.OrderStatusText = "退款关闭"
  414. }
  415. if orderType == 1 {
  416. if v.GoodsId == 1 {
  417. item.LabelKeywordImgLink = utils.LABEL_ICO_7 //日卡图标
  418. item.LabelKeyword = "畅读日卡" //日卡图标
  419. item.StartDate = v.StartDate.Format(utils.FormatDateTime)
  420. item.EndDate = v.EndDate.Format(utils.FormatDateTime)
  421. } else if v.GoodsId == 2 {
  422. item.LabelKeywordImgLink = utils.LABEL_ICO_8 // 月卡图标
  423. item.LabelKeyword = "畅读月卡" //日卡图标
  424. item.StartDate = v.StartDate.Format(utils.FormatDate)
  425. item.EndDate = v.EndDate.Format(utils.FormatDate)
  426. }
  427. } else {
  428. item.LabelKeywordImgLink = utils.LABEL_ICO_3
  429. item.LabelKeyword = activityLabelKeyword[v.SourceId]
  430. }
  431. item.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
  432. resp.List = append(resp.List, item)
  433. }
  434. page := paging.GetPaging(currentIndex, pageSize, total)
  435. resp.Paging = page
  436. br.Data = resp
  437. br.Ret = 200
  438. br.Success = true
  439. br.Msg = "获取成功"
  440. }
  441. // @Title 订单支付详情
  442. // @Description 订单支付详情接口
  443. // @Param OrderCode query string false "订单号"
  444. // @Success 200 {object} models.SpecialListResp
  445. // @router /orderPay/detail [get]
  446. func (this *OrderController) OrderDetail() {
  447. br := new(models.BaseResponse).Init()
  448. defer func() {
  449. this.Data["json"] = br
  450. this.ServeJSON()
  451. }()
  452. user := this.User
  453. if user == nil {
  454. br.Msg = "请登录"
  455. br.ErrMsg = "请登录,用户信息为空"
  456. br.Ret = 408
  457. return
  458. }
  459. resp := new(order.PayEdOrderDetailResp)
  460. orderCode := this.GetString("OrderCode")
  461. orderDetail, err := order.GetCygxOrderDetailByOrderCode(orderCode)
  462. if err != nil {
  463. br.Msg = "获取失败"
  464. br.ErrMsg = "获取失败, Err:" + err.Error()
  465. return
  466. }
  467. if orderDetail.OrderType == 1 && orderDetail.OrderStatus == 2 {
  468. cardDetail, err := order.GetCygxOrderUserCardDetailByOrderCode(orderCode)
  469. if err != nil {
  470. br.Msg = "获取失败"
  471. br.ErrMsg = "获取失败, Err:" + err.Error()
  472. return
  473. }
  474. resp.EndDate = strings.Replace(cardDetail.EndDate.Format(utils.FormatDateTime), "00:00:00", "", -1)
  475. }
  476. resp.OrderCode = orderDetail.OrderCode
  477. resp.OrderType = orderDetail.OrderType
  478. resp.OrderStatus = orderDetail.OrderStatus
  479. resp.Source = orderDetail.Source
  480. resp.SourceId = orderDetail.SourceId
  481. if orderDetail.Source == utils.CYGX_OBJ_ACTIVITY {
  482. resp.IsPublicActivitie, resp.IsSignUp = services.GetActivityWechatPayMsg(orderDetail.SourceId) //如果是活动就要判断是否是公开活动,是否需要自动报名
  483. }
  484. br.Data = resp
  485. br.Ret = 200
  486. br.Success = true
  487. br.Msg = "获取成功"
  488. }
  489. // @Title 取消订单
  490. // @Description 取消订单接口
  491. // @Param request body models.ActivitySingnupRep true "type json string"
  492. // @Success Ret=200 {object} models.SignupStatus
  493. // @router /cancel [post]
  494. func (this *OrderController) Cancel() {
  495. br := new(models.BaseResponse).Init()
  496. defer func() {
  497. this.Data["json"] = br
  498. this.ServeJSON()
  499. }()
  500. user := this.User
  501. if user == nil {
  502. br.Msg = "请登录"
  503. br.ErrMsg = "请登录,用户信息为空"
  504. br.Ret = 408
  505. return
  506. }
  507. var req order.CygxOrderCancelReq
  508. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  509. if err != nil {
  510. br.Msg = "参数解析异常!"
  511. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  512. return
  513. }
  514. orderCode := req.OrderCode
  515. orderDetail, err := order.GetCygxOrderDetailByOrderCode(orderCode)
  516. if err != nil {
  517. br.Msg = "获取失败"
  518. br.ErrMsg = "获取失败, Err:" + err.Error()
  519. return
  520. }
  521. err = order.CancelCygxOrder(orderDetail)
  522. if err != nil {
  523. br.Msg = "取消订单失败"
  524. br.ErrMsg = "获取失败, Err:" + err.Error()
  525. return
  526. }
  527. br.Ret = 200
  528. br.Success = true
  529. br.Msg = "操作成功"
  530. }