order.go 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434
  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.GoodsName = goodsDetail.GoodsName
  67. item.GoodsId = goodsId
  68. item.GoodsMoney = goodsDetail.Price
  69. item.OrderMoney = goodsDetail.CurrentPrice
  70. item.SourceId = sourceId
  71. item.Source = utils.CYGX_OBJ_ARTICLE
  72. item.SourceTitle = title
  73. item.UserId = user.UserId
  74. item.Mobile = user.Mobile
  75. item.Email = user.Email
  76. item.CompanyId = user.CompanyId
  77. item.CompanyName = user.CompanyName
  78. item.RealName = user.RealName
  79. item.SellerName, item.SellerId = services.GetSellerName(user) // 销售姓名
  80. item.ShareName, item.ShareId = services.GetAdminByInviteShareCode(req.InviteShareCode) // 分享人信息
  81. item.CreateTime = time.Now()
  82. item.ModifyTime = time.Now()
  83. item.RegisterPlatform = utils.REGISTER_PLATFORM
  84. item.OrderType = 1
  85. //如果十分钟之内有相同的订单就修改,没有就新增
  86. if oldOrderCode == "" {
  87. err = order.AddCygxOrder(item)
  88. } else {
  89. item.OrderCode = oldOrderCode
  90. err = order.UpdateCygxOrder(item, oldOrderCode)
  91. }
  92. if err != nil {
  93. br.Msg = "创建订单信息失败"
  94. br.ErrMsg = "创建订单信息失败,Err:" + err.Error()
  95. return
  96. }
  97. codeUrl, err := services.ExampleNativeApiServicePrepay(item)
  98. if err != nil {
  99. br.Msg = "创建订单信息失败"
  100. br.ErrMsg = "创建订单信息失败,ExampleNativeApiServicePrepay:" + err.Error()
  101. return
  102. }
  103. resp := new(order.WxNativeApiResp)
  104. _, resp.PayTimeCountdown = services.GetHaverEquallyOrderByUser10MinByArticle(uid, sourceId) //截止支付时间倒计时
  105. resp.CodeUrl = codeUrl
  106. resp.OrderCode = item.OrderCode
  107. br.Data = resp
  108. br.Ret = 200
  109. br.Success = true
  110. br.Msg = "操作成功"
  111. }
  112. // @Title 通过活动创建订单
  113. // @Description 通过活动创建订单接口
  114. // @Param request body models.ActivitySingnupRep true "type json string"
  115. // @Success Ret=200 {object} models.SignupStatus
  116. // @router /addByActivity [post]
  117. func (this *OrderController) AddByActivity() {
  118. br := new(models.BaseResponse).Init()
  119. defer func() {
  120. this.Data["json"] = br
  121. this.ServeJSON()
  122. }()
  123. user := this.User
  124. if user == nil {
  125. br.Msg = "请登录"
  126. br.ErrMsg = "请登录,用户信息为空"
  127. br.Ret = 408
  128. return
  129. }
  130. var req order.CygxOrderAddReq
  131. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  132. if err != nil {
  133. br.Msg = "参数解析异常!"
  134. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  135. return
  136. }
  137. uid := user.UserId
  138. goodsId := req.GoodsId
  139. sourceId := req.SourceId
  140. if goodsId == 0 {
  141. br.Msg = "支付失败"
  142. br.ErrMsg = "支付失败,goodsId 信息错误Err:" + err.Error()
  143. return
  144. }
  145. goodsDetail, err := order.GetCygxGoodsDetailByGoodsId(goodsId)
  146. if err != nil {
  147. br.Msg = "获取信息失败"
  148. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  149. return
  150. }
  151. activityDetail, err := models.GetAddActivityInfoById(sourceId)
  152. if err != nil {
  153. br.Msg = "获取信息失败"
  154. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  155. return
  156. }
  157. var title string
  158. var oldOrderCode string
  159. //var _ int
  160. item := new(order.CygxOrder)
  161. if (!activityDetail.IsResearchPoints && activityDetail.IsLimitPeople == 0) || activityDetail.YidongActivityId != "" { //易董的活动 或者(不扣点且不限制人数)走月卡日卡逻辑
  162. oldOrderCode = services.GetHaverEquallyOrderByUser10Min(uid, goodsId) //获取用户十分钟之内是否有相同的订单信息
  163. item.OrderType = 1
  164. } else {
  165. oldOrderCode, _ = services.GetHaverEquallyOrderByUser10MinByActivty(uid, sourceId)
  166. item.OrderType = 2
  167. }
  168. title = activityDetail.ActivityName
  169. item.OrderCode = utils.GetOrdernum()
  170. if activityDetail.ActivityTypeName == "买方线下交流" {
  171. item.GoodsName = "买方交流"
  172. }
  173. if activityDetail.ActivityTypeName == "专家电话会" || activityDetail.ActivityTypeName == "专家线下沙龙" {
  174. item.GoodsName = "专家调研"
  175. }
  176. if activityDetail.ActivityTypeName == "公司调研电话会" {
  177. item.GoodsName = "买方交流"
  178. }
  179. //如果活动有自定义的价格就优先按照自定义的价格来
  180. if activityDetail.ActivityPrice > 0 {
  181. goodsDetail.CurrentPrice = activityDetail.ActivityPrice
  182. }
  183. //fmt.Println("item.GoodsName", item.GoodsName)
  184. //return
  185. item.GoodsId = goodsId
  186. item.GoodsMoney = goodsDetail.Price
  187. item.OrderMoney = goodsDetail.CurrentPrice
  188. item.SourceId = sourceId
  189. item.Source = utils.CYGX_OBJ_ACTIVITY
  190. item.SourceTitle = title
  191. item.UserId = user.UserId
  192. item.Mobile = user.Mobile
  193. item.Email = user.Email
  194. item.CompanyId = user.CompanyId
  195. item.CompanyName = user.CompanyName
  196. item.RealName = user.RealName
  197. item.SellerName, item.SellerId = services.GetSellerName(user) // 销售姓名
  198. item.ShareName, item.ShareId = services.GetAdminByInviteShareCode(req.InviteShareCode) // 分享人信息
  199. item.CreateTime = time.Now()
  200. item.ModifyTime = time.Now()
  201. item.RegisterPlatform = utils.REGISTER_PLATFORM
  202. //如果十分钟之内有相同的订单就修改,没有就新增
  203. if oldOrderCode == "" {
  204. err = order.AddCygxOrder(item)
  205. } else {
  206. item.OrderCode = oldOrderCode
  207. err = order.UpdateCygxOrder(item, oldOrderCode)
  208. }
  209. codeUrl, err := services.ExampleNativeApiServicePrepay(item)
  210. if err != nil {
  211. br.Msg = "创建订单信息失败"
  212. br.ErrMsg = "创建订单信息失败,ExampleNativeApiServicePrepay:" + err.Error()
  213. return
  214. }
  215. resp := new(order.WxNativeApiResp)
  216. _, resp.PayTimeCountdown = services.GetHaverEquallyOrderByUser10MinByActivty(uid, sourceId) //截止支付时间倒计时
  217. resp.CodeUrl = codeUrl
  218. resp.OrderCode = item.OrderCode
  219. br.Data = resp
  220. br.Ret = 200
  221. br.Success = true
  222. br.Msg = "操作成功"
  223. }
  224. // @Title 用户订单列表
  225. // @Description 用户订单列表接口
  226. // @Param PageSize query int true "每页数据条数"
  227. // @Param CurrentIndex query int true "当前页页码,从1开始"
  228. // @Param OrderType query int false "订单类型 1:畅读卡订单,2:单场付费订单"
  229. // @Success 200 {object} models.SpecialListResp
  230. // @router /user/orderList [get]
  231. func (this *OrderController) UserOrderList() {
  232. br := new(models.BaseResponse).Init()
  233. defer func() {
  234. this.Data["json"] = br
  235. this.ServeJSON()
  236. }()
  237. user := this.User
  238. if user == nil {
  239. br.Msg = "请登录"
  240. br.ErrMsg = "请登录,用户信息为空"
  241. br.Ret = 408
  242. return
  243. }
  244. pageSize, _ := this.GetInt("PageSize")
  245. currentIndex, _ := this.GetInt("CurrentIndex")
  246. orderType, _ := this.GetInt("OrderType", 1)
  247. var startSize int
  248. if pageSize <= 0 {
  249. pageSize = utils.PageSize20
  250. }
  251. if currentIndex <= 0 {
  252. currentIndex = 1
  253. }
  254. startSize = utils.StartIndex(currentIndex, pageSize)
  255. resp := new(order.UserOrderListResp)
  256. var condition string
  257. var pars []interface{}
  258. userId := user.UserId
  259. if orderType > 0 {
  260. condition += ` AND order_type = ? `
  261. pars = append(pars, orderType)
  262. }
  263. condition += ` AND user_id = ? `
  264. pars = append(pars, userId)
  265. total, err := order.GetCygxOrderCount(condition, pars)
  266. if err != nil {
  267. br.Msg = "获取失败"
  268. br.ErrMsg = "获取失败, Err:" + err.Error()
  269. return
  270. }
  271. condition += ` ORDER BY order_id DESC `
  272. list, err := order.GetCygxOrderList(condition, pars, startSize, pageSize)
  273. if err != nil {
  274. br.Msg = "获取失败"
  275. br.ErrMsg = "获取失败, Err:" + err.Error()
  276. return
  277. }
  278. var activityIds []int
  279. for _, v := range list {
  280. if v.Source == utils.CYGX_OBJ_ACTIVITY {
  281. activityIds = append(activityIds, v.SourceId)
  282. }
  283. }
  284. activityLabelKeyword := services.GetActivityOrderListLabelKeywordByActivityIds(activityIds)
  285. for _, v := range list {
  286. item := new(order.OrderListResp)
  287. item.OrderCode = v.OrderCode
  288. item.OrderMoney = v.OrderMoney
  289. item.SourceId = v.SourceId
  290. item.Source = v.Source
  291. item.SourceTitle = v.SourceTitle
  292. item.OrderStatus = v.OrderStatus
  293. if v.OrderStatus == 0 {
  294. item.OrderStatusText = "已取消"
  295. } else if v.OrderStatus == 1 {
  296. item.OrderStatusText = "待支付"
  297. } else if v.OrderStatus == 2 {
  298. item.OrderStatusText = "已支付"
  299. }
  300. if orderType == 1 {
  301. if v.GoodsId == 1 {
  302. item.LabelKeywordImgLink = utils.LABEL_ICO_7 //日卡图标
  303. item.LabelKeyword = "畅读日卡" //日卡图标
  304. item.StartDate = v.StartDate.Format(utils.FormatDateTime)
  305. item.EndDate = v.EndDate.Format(utils.FormatDateTime)
  306. } else if v.GoodsId == 2 {
  307. item.LabelKeywordImgLink = utils.LABEL_ICO_8 // 月卡图标
  308. item.LabelKeyword = "畅读月卡" //日卡图标
  309. item.StartDate = v.StartDate.Format(utils.FormatDate)
  310. item.EndDate = v.EndDate.Format(utils.FormatDate)
  311. }
  312. } else {
  313. item.LabelKeywordImgLink = utils.LABEL_ICO_3
  314. item.LabelKeyword = activityLabelKeyword[v.SourceId]
  315. }
  316. item.CreateTime = v.CreateTime.Format(utils.FormatDateTime)
  317. resp.List = append(resp.List, item)
  318. }
  319. page := paging.GetPaging(currentIndex, pageSize, total)
  320. resp.Paging = page
  321. br.Data = resp
  322. br.Ret = 200
  323. br.Success = true
  324. br.Msg = "获取成功"
  325. }
  326. // @Title 订单支付详情
  327. // @Description 订单支付详情接口
  328. // @Param OrderCode query string false "订单号"
  329. // @Success 200 {object} models.SpecialListResp
  330. // @router /orderPay/detail [get]
  331. func (this *OrderController) OrderDetail() {
  332. br := new(models.BaseResponse).Init()
  333. defer func() {
  334. this.Data["json"] = br
  335. this.ServeJSON()
  336. }()
  337. user := this.User
  338. if user == nil {
  339. br.Msg = "请登录"
  340. br.ErrMsg = "请登录,用户信息为空"
  341. br.Ret = 408
  342. return
  343. }
  344. resp := new(order.PayEdOrderDetailResp)
  345. orderCode := this.GetString("OrderCode")
  346. orderDetail, err := order.GetCygxOrderDetailByOrderCode(orderCode)
  347. if err != nil {
  348. br.Msg = "获取失败"
  349. br.ErrMsg = "获取失败, Err:" + err.Error()
  350. return
  351. }
  352. if orderDetail.OrderType == 1 && orderDetail.OrderStatus == 2 {
  353. cardDetail, err := order.GetCygxOrderUserCardDetailByOrderCode(orderCode)
  354. if err != nil {
  355. br.Msg = "获取失败"
  356. br.ErrMsg = "获取失败, Err:" + err.Error()
  357. return
  358. }
  359. resp.EndDate = strings.Replace(cardDetail.EndDate.Format(utils.FormatDateTime), "00:00:00", "", -1)
  360. }
  361. resp.OrderCode = orderDetail.OrderCode
  362. resp.OrderType = orderDetail.OrderType
  363. resp.OrderStatus = orderDetail.OrderStatus
  364. resp.Source = orderDetail.Source
  365. resp.SourceId = orderDetail.SourceId
  366. br.Data = resp
  367. br.Ret = 200
  368. br.Success = true
  369. br.Msg = "获取成功"
  370. }
  371. // @Title 取消订单
  372. // @Description 取消订单接口
  373. // @Param request body models.ActivitySingnupRep true "type json string"
  374. // @Success Ret=200 {object} models.SignupStatus
  375. // @router /cancel [post]
  376. func (this *OrderController) Cancel() {
  377. br := new(models.BaseResponse).Init()
  378. defer func() {
  379. this.Data["json"] = br
  380. this.ServeJSON()
  381. }()
  382. user := this.User
  383. if user == nil {
  384. br.Msg = "请登录"
  385. br.ErrMsg = "请登录,用户信息为空"
  386. br.Ret = 408
  387. return
  388. }
  389. var req order.CygxOrderCancelReq
  390. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  391. if err != nil {
  392. br.Msg = "参数解析异常!"
  393. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  394. return
  395. }
  396. orderCode := req.OrderCode
  397. orderDetail, err := order.GetCygxOrderDetailByOrderCode(orderCode)
  398. if err != nil {
  399. br.Msg = "获取失败"
  400. br.ErrMsg = "获取失败, Err:" + err.Error()
  401. return
  402. }
  403. err = order.CancelCygxOrder(orderDetail)
  404. if err != nil {
  405. br.Msg = "取消订单失败"
  406. br.ErrMsg = "获取失败, Err:" + err.Error()
  407. return
  408. }
  409. br.Ret = 200
  410. br.Success = true
  411. br.Msg = "操作成功"
  412. }