package rechargectrl import ( "bytes" "errors" "fmt" "net/http" "strconv" "time" "91porn-server/common/log" "91porn-server/common/rchgutil" "91porn-server/web/service/rechargeser" "github.com/gin-gonic/gin" ) // GoldfishPlusCallBack 金鱼结构回调函数 func GoldfishPlusCallBack(ctx *gin.Context) { if err := func() error { rchg := rchgutil.GoldfishPlusRes{} g := rchgutil.GoldfishPlus{} if err := ctx.ShouldBindJSON(&rchg); err != nil { log.Error(fmt.Sprintf("GoldfishPlus callback parameter bind fail error:%+v:", err)) return err } log.Info(fmt.Sprintf("GoldfishPlus callback parameter data:%+v:", rchg)) buf := bytes.Buffer{} buf.WriteString(strconv.Itoa(rchg.Code)) buf.WriteString(rchg.MercID) buf.WriteString(rchg.OID) buf.WriteString(rchg.PayMoney) buf.WriteString(rchg.TradeNo) buf.WriteString(g.GetAppSecret()) if !rchgutil.VerifySign(rchg.Sign, buf.String()) { log.Error("GoldfishPlus callback sign verify fail") return errors.New("check sign fail") } payMoneyf, err := strconv.ParseFloat(rchg.PayMoney, 64) if err != nil { log.Error(fmt.Sprintf("GoldfishPlus callback ParseFloat fail error:%+v:", err)) return fmt.Errorf("invalid payMoney %s", rchg.PayMoney) } payMoneyf = payMoneyf * 100 payMoney := int64(payMoneyf) g.TradeNo = rchg.TradeNo msg, err := g.QueryOrder() if err != nil { return err } if msg.PayTime == "" { return errors.New("querry order err,no payTime") } loc, _ := time.LoadLocation("Local") paymentAt, err := time.ParseInLocation("2006-01-02T15:04:05Z07:00", msg.PayTime, loc) if err != nil { return err } if err = rechargeser.RechargeCallBack(ctx, rchg.OID, payMoney, rchg.TradeNo, rchg.Code, paymentAt); err != nil { log.Error(fmt.Sprintf("GoldfishPlus RechargeCallBack fail error:%+v:", err)) } return err }(); err != nil { ctx.String(http.StatusBadRequest, "fail") return } ctx.String(http.StatusOK, "success") }