|
|
@@ -2,6 +2,7 @@ package services
|
|
|
|
|
|
import (
|
|
|
"context"
|
|
|
+ "encoding/json"
|
|
|
"errors"
|
|
|
"fmt"
|
|
|
"hongze/hongze_cygx/models/order"
|
|
|
@@ -42,3 +43,270 @@ func CancelCygxOrder(cont context.Context) (err error) {
|
|
|
}
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+func GetQueryOrderByOutTradeNoTask(cont context.Context) (err error) {
|
|
|
+
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err)
|
|
|
+ go utils.SendAlarmMsg(fmt.Sprint("自动取消十分钟之内没有付款的的订单 CancelCygxOrder ，err：", err.Error()), 2)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+ endTime := time.Now().Add(-10 * time.Minute)
|
|
|
+ condition = ` AND order_status = 1 AND create_time > ? `
|
|
|
+ pars = append(pars, endTime)
|
|
|
+ orderList, e := order.GetCygxOrderList(condition, pars, 0, 999)
|
|
|
+ if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
+ err = errors.New("GetCygxOrderList, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ fmt.Println(len(orderList))
|
|
|
+ if len(orderList) == 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range orderList {
|
|
|
+ tradeState, statusCode, itemResp := GetQueryOrderByOutTradeNo(v.OrderCode)
|
|
|
+ if tradeState == "SUCCESS" && statusCode == 200 {
|
|
|
+ go HandleOrderHandle(itemResp)
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func HandleOrderHandle(itemCallback *Transaction) {
|
|
|
+ var err error
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err)
|
|
|
+ go utils.SendAlarmMsg(fmt.Sprint("手动处理支付订单回调失败 HandleOrderHandle, err：", err.Error()), 2)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ outTradeNo := itemCallback.OutTradeNo
|
|
|
+ orderDetail, e := order.GetCygxOrderDetailByOrderCode(outTradeNo)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("GetCygxOrderDetailByOrderCode, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ go AddCygxOrderPayment(itemCallback)
|
|
|
+
|
|
|
+ if itemCallback.TradeState != "SUCCESS" {
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("支付失败, OrderCode: " + outTradeNo)
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ if orderDetail.OrderStatus == 2 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ itemOrder := new(order.CygxOrder)
|
|
|
+ itemOrder.OrderCode = itemCallback.OutTradeNo
|
|
|
+ itemOrder.PayTime = itemCallback.SuccessTime
|
|
|
+ itemOrder.PayMoney = float64(float64(itemCallback.Amount.PayerTotal) / 100)
|
|
|
+ itemOrder.OrderStatus = 2
|
|
|
+ itemOrder.OutTradeCode = itemCallback.TransactionId
|
|
|
+
|
|
|
+
|
|
|
+ if orderDetail.OrderType == 1 {
|
|
|
+ itemUserCard := new(order.CygxOrderUserCard)
|
|
|
+ itemUserCard.OrderCode = orderDetail.OrderCode
|
|
|
+ itemUserCard.UserId = orderDetail.UserId
|
|
|
+ itemUserCard.Mobile = orderDetail.Mobile
|
|
|
+ itemUserCard.Email = orderDetail.Email
|
|
|
+ itemUserCard.CompanyId = orderDetail.CompanyId
|
|
|
+ itemUserCard.CompanyName = orderDetail.CompanyName
|
|
|
+ itemUserCard.RealName = orderDetail.RealName
|
|
|
+ itemUserCard.SellerName = orderDetail.SellerName
|
|
|
+ itemUserCard.CreateTime = time.Now()
|
|
|
+ itemUserCard.ModifyTime = time.Now()
|
|
|
+ itemUserCard.RegisterPlatform = orderDetail.RegisterPlatform
|
|
|
+
|
|
|
+ if orderDetail.GoodsId == 1 {
|
|
|
+ itemUserCard.StartDate = itemOrder.PayTime
|
|
|
+ itemUserCard.EndDate = itemOrder.PayTime.AddDate(0, 0, 1)
|
|
|
+ itemUserCard.CardType = "日卡"
|
|
|
+ } else {
|
|
|
+ now := time.Now()
|
|
|
+ itemUserCard.StartDate = time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, time.Local)
|
|
|
+ itemUserCard.EndDate = itemUserCard.StartDate.AddDate(0, 1, 0)
|
|
|
+ itemUserCard.CardType = "月卡"
|
|
|
+ }
|
|
|
+ e = order.AddCygxOrderUserCard(itemUserCard, itemOrder)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("AddCygxOrderUserCard, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ } else if orderDetail.OrderType == 2 {
|
|
|
+
|
|
|
+ itemOrderVirtualAsset := new(order.CygxOrderVirtualAsset)
|
|
|
+ itemOrderVirtualAsset.OrderCode = orderDetail.OrderCode
|
|
|
+ itemOrderVirtualAsset.UserId = orderDetail.UserId
|
|
|
+ itemOrderVirtualAsset.Mobile = orderDetail.Mobile
|
|
|
+ itemOrderVirtualAsset.Email = orderDetail.Email
|
|
|
+ itemOrderVirtualAsset.CompanyId = orderDetail.CompanyId
|
|
|
+ itemOrderVirtualAsset.CompanyName = orderDetail.CompanyName
|
|
|
+ itemOrderVirtualAsset.RealName = orderDetail.RealName
|
|
|
+ itemOrderVirtualAsset.SellerName = orderDetail.SellerName
|
|
|
+ itemOrderVirtualAsset.Source = orderDetail.Source
|
|
|
+ itemOrderVirtualAsset.SourceId = orderDetail.SourceId
|
|
|
+ itemOrderVirtualAsset.CreateTime = time.Now()
|
|
|
+ itemOrderVirtualAsset.ModifyTime = time.Now()
|
|
|
+ e = order.AddCygxOrderVirtualAsset(itemOrderVirtualAsset, itemOrder)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("AddCygxOrderVirtualAsset, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func AddCygxOrderPayment(itemCallback *Transaction) {
|
|
|
+ var err error
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err)
|
|
|
+ go utils.SendAlarmMsg(fmt.Sprint("处理订单回调信息失败 HandleOrderHandle, err：", err.Error()), 2)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ itemPay := new(order.CygxOrderPayment)
|
|
|
+ itemPay.OrderCode = itemCallback.OutTradeNo
|
|
|
+ itemPay.OutTradeCode = itemCallback.TransactionId
|
|
|
+ itemPay.PayBody = itemCallback.TradeStateDesc
|
|
|
+ jsonData, _ := json.Marshal(itemCallback)
|
|
|
+ itemPay.PayDetail = string(jsonData)
|
|
|
+ itemPay.PayMoney = float64(float64(itemCallback.Amount.PayerTotal) / 100)
|
|
|
+ itemPay.PayStatus = itemCallback.TradeState
|
|
|
+ itemPay.CreateTime = time.Now()
|
|
|
+ itemPay.PaymentType = 1
|
|
|
+ e := order.AddCygxOrderPayment(itemPay)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("AddCygxOrderPayment, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func HandleOrderRefundHandleask(cont context.Context) (err error) {
|
|
|
+
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err)
|
|
|
+ go utils.SendAlarmMsg(fmt.Sprint("自动取消十分钟之内没有付款的的订单 CancelCygxOrder ，err：", err.Error()), 2)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ var condition string
|
|
|
+ var pars []interface{}
|
|
|
+
|
|
|
+ condition = ` AND order_status = 4 `
|
|
|
+
|
|
|
+ orderList, e := order.GetCygxOrderList(condition, pars, 0, 999)
|
|
|
+ if e != nil && e.Error() != utils.ErrNoRow() {
|
|
|
+ err = errors.New("GetCygxOrderList, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ fmt.Println(len(orderList))
|
|
|
+ if len(orderList) == 0 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ for _, v := range orderList {
|
|
|
+ tradeState, statusCode, itemResp := GetQueryOrderByOutTradeNo(v.OrderCode)
|
|
|
+ if tradeState == "REFUND" && statusCode == 200 {
|
|
|
+ go HandleOrderRefundHandle(itemResp)
|
|
|
+ }
|
|
|
+
|
|
|
+ }
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+func HandleOrderRefundHandle(itemCallback *Transaction) {
|
|
|
+ var err error
|
|
|
+ defer func() {
|
|
|
+ if err != nil {
|
|
|
+ fmt.Println(err)
|
|
|
+ go utils.SendAlarmMsg(fmt.Sprint("处理退款订单回调信息失败 HandleOrderRefundHandle, err：", err.Error()), 2)
|
|
|
+ }
|
|
|
+ }()
|
|
|
+ outTradeNo := itemCallback.OutTradeNo
|
|
|
+ orderDetail, e := order.GetCygxOrderDetailByOrderCode(outTradeNo)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("GetCygxOrderDetailByOrderCode, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ if orderDetail.OrderStatus == 3 {
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ itemOrder := new(order.CygxOrder)
|
|
|
+ itemOrder.OrderCode = itemCallback.OutTradeNo
|
|
|
+ itemOrder.RefundTime = itemCallback.SuccessTime
|
|
|
+ itemOrder.RefundMoney = float64(float64(itemCallback.Amount.PayerTotal) / 100)
|
|
|
+ itemOrder.OrderStatus = 3
|
|
|
+
|
|
|
+
|
|
|
+ if orderDetail.OrderType == 1 {
|
|
|
+ itemUserCard := new(order.CygxOrderUserCard)
|
|
|
+ itemUserCard.OrderCode = orderDetail.OrderCode
|
|
|
+ itemUserCard.UserId = orderDetail.UserId
|
|
|
+ itemUserCard.Mobile = orderDetail.Mobile
|
|
|
+ itemUserCard.Email = orderDetail.Email
|
|
|
+ itemUserCard.CompanyId = orderDetail.CompanyId
|
|
|
+ itemUserCard.CompanyName = orderDetail.CompanyName
|
|
|
+ itemUserCard.RealName = orderDetail.RealName
|
|
|
+ itemUserCard.SellerName = orderDetail.SellerName
|
|
|
+ itemUserCard.CreateTime = time.Now()
|
|
|
+ itemUserCard.ModifyTime = time.Now()
|
|
|
+ itemUserCard.RegisterPlatform = orderDetail.RegisterPlatform
|
|
|
+
|
|
|
+ if orderDetail.GoodsId == 1 {
|
|
|
+ itemUserCard.CardType = "日卡"
|
|
|
+ } else {
|
|
|
+ itemUserCard.CardType = "月卡"
|
|
|
+ }
|
|
|
+ e = order.RemoveCygxOrderUserCard(itemUserCard, itemOrder)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("RemoveCygxOrderUserCard, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ } else if orderDetail.OrderType == 2 {
|
|
|
+
|
|
|
+ itemOrderVirtualAsset := new(order.CygxOrderVirtualAsset)
|
|
|
+ itemOrderVirtualAsset.OrderCode = orderDetail.OrderCode
|
|
|
+ itemOrderVirtualAsset.UserId = orderDetail.UserId
|
|
|
+ itemOrderVirtualAsset.Mobile = orderDetail.Mobile
|
|
|
+ itemOrderVirtualAsset.Email = orderDetail.Email
|
|
|
+ itemOrderVirtualAsset.CompanyId = orderDetail.CompanyId
|
|
|
+ itemOrderVirtualAsset.CompanyName = orderDetail.CompanyName
|
|
|
+ itemOrderVirtualAsset.RealName = orderDetail.RealName
|
|
|
+ itemOrderVirtualAsset.SellerName = orderDetail.SellerName
|
|
|
+ itemOrderVirtualAsset.Source = orderDetail.Source
|
|
|
+ itemOrderVirtualAsset.SourceId = orderDetail.SourceId
|
|
|
+ itemOrderVirtualAsset.CreateTime = time.Now()
|
|
|
+ itemOrderVirtualAsset.ModifyTime = time.Now()
|
|
|
+ e = order.RemoveCygxOrderVirtualAsset(itemOrderVirtualAsset, itemOrder)
|
|
|
+ if e != nil {
|
|
|
+ err = errors.New("AddCygxOrderVirtualAsset, Err: " + e.Error())
|
|
|
+ return
|
|
|
+ }
|
|
|
+ }
|
|
|
+ fmt.Println(orderDetail.Source)
|
|
|
+ return
|
|
|
+}
|
xingzai