package foxpay import ( "errors" "fmt" "net/http" "server/modules/pay/base" "server/modules/pay/values" "server/pb" "server/util" "time" "github.com/gogo/protobuf/proto" "github.com/liangdas/mqant/log" ) func NewSub(b *base.Base) { sub := &Sub{ Base: b, } b.SignKey = key b.HttpType = base.HttpTypeForm // b.ShouldSignUpper = true if b.Opt == base.OPTPay { b.Resp = new(PayResp) b.ReqURL = baseURL + payURL } else if b.Opt == base.OPTWithdraw { b.Resp = new(WithdrawResp) b.ReqURL = baseURL + withdrawURL } else if b.Opt == base.OPTPayCB { b.SignPassStr = []string{"sign"} b.CallbackResp.Msg = "success" b.CallbackReq = new(PayCallbackReq) } else if b.Opt == base.OPTWithdrawCB { b.SignPassStr = []string{"sign"} b.CallbackResp.Msg = "success" b.CallbackReq = new(WithdrawCallbackReq) } else if b.Opt == base.OPTQueryWithdraw { b.Resp = new(QueryWithdrawResp) b.ReqURL = baseURL + queryWithdrawURL } else if b.Opt == base.OPTQueryPay { b.Resp = new(QueryPayResp) b.ReqURL = baseURL + queryPayURL } b.Sub = sub } type Sub struct { Base *base.Base } func (s *Sub) PackHeader(header http.Header) { } func (s *Sub) PackReq() interface{} { if s.Base.Opt == base.OPTPay { return s.PackPayReq() } else if s.Base.Opt == base.OPTWithdraw { return s.PackWithdrawReq() } else if s.Base.Opt == base.OPTQueryWithdraw { return s.PackQueryWithdrawReq() } else if s.Base.Opt == base.OPTQueryPay { return s.PackQueryPayReq() } return nil } func (s *Sub) GetResp() (proto.Message, error) { if s.Base.Opt == 1 { resp := s.Base.Resp.(*PayResp) if resp.Code != "0000" || resp.PaymentUrl == "" { return nil, errors.New("pay fail") } return &pb.InnerRechargeResp{APIOrderID: resp.OrderNo, URL: resp.PaymentUrl, Channel: uint32(values.FoxPay)}, nil } else if s.Base.Opt == base.OPTWithdraw { resp := s.Base.Resp.(*WithdrawResp) if s.Base.Status == 0 && resp.Code != "0000" { return nil, errors.New("withdraw fail") } return &pb.InnerWithdrawResp{APIOrderID: resp.OrderNo, Channel: uint32(values.FoxPay), Status: uint32(s.Base.Status)}, nil } else if s.Base.Opt == base.OPTQueryWithdraw { resp := s.Base.Resp.(*QueryWithdrawResp) log.Debug("QueryWithdrawResp:%+v", resp) ret := &pb.InnerQueryWithdrawResp{OrderID: resp.MchOrderNo} s.Base.QueryWithdrawResp.OrderID = resp.MchOrderNo if s.Base.Status == 0 { if resp.Code == "0000" { if resp.Status == "PAID" { s.Base.QueryWithdrawResp.Status = base.QueryStatusOrderSuccess } else if resp.Status == "PROCESSED" || resp.Status == "PAYING" { s.Base.QueryWithdrawResp.Status = base.QueryStatusSuccess } } else { if resp.Status == "UN_SUBMITTED" || resp.Status == "SUBMITTED_FAILED" || resp.Status == "PAY_FAILED" || resp.Status == "CANCEL_PAY" { s.Base.QueryWithdrawResp.Status = base.QueryStatusFail } } } if s.Base.QueryWithdrawResp.Status == 0 { s.Base.QueryWithdrawResp.Status = base.QueryStatusUnknown } return ret, nil } else if s.Base.Opt == base.OPTQueryPay { resp := s.Base.Resp.(*QueryPayResp) log.Debug("QueryPayResp:%+v", resp) ret := &pb.InnerQueryWithdrawResp{OrderID: resp.MchOrderNo} s.Base.QueryPayResp.OrderID = resp.MchOrderNo if s.Base.Status == 0 { if resp.Code == "0000" && resp.Status == "PAID" { s.Base.QueryPayResp.Status = base.QueryStatusOrderSuccess } } if s.Base.QueryPayResp.Status == 0 { s.Base.QueryPayResp.Status = base.QueryStatusUnknown } return ret, nil } return nil, fmt.Errorf("unknow opt") } func (s *Sub) PackPayReq() interface{} { r := s.Base.PayReq send := &PayReq{ Amount: r.Amount, AisleCode: payNo, MchOrderNo: r.OrderID, UId: fmt.Sprintf("%d", r.UID), // UbAccount: , UName: r.Name, UPhone: r.Phone, UEmail: r.Email, NotifyUrl: s.Base.GetPayCallbackURL(), ReqTime: time.Now().Unix(), ReturnUrl: values.GetFrontCallback(), MchNo: mid, UIp: r.IP, UdId: r.DeviceID, } send.Sign = s.Base.SignMD5(send) return send } func (s *Sub) PackWithdrawReq() interface{} { r := s.Base.WithdrawReq send := &WithdrawReq{ Amount: r.Amount, AisleCode: withdrawNo, MchNo: mid, MchOrderNo: r.OrderID, // PayType: , // UbAccount: , // IfscCode: , UName: r.Name, UPhone: r.Phone, UEmail: r.Email, NotifyUrl: s.Base.GetWithdrawCallbackURL(), ReqTime: time.Now().Unix(), } //if fmt.Sprintf("%d", r.PayType) == common.WithdrawTypeBank { send.PayType = "IMPS" send.UbAccount = r.CardNo send.IfscCode = r.PayCode //} else if fmt.Sprintf("%d", r.PayType) == common.WithdrawTypeUPI { // send.PayType = "UPI" // send.UbAccount = r.PayCode //} else { // return nil //} send.Sign = s.Base.SignMD5(send) return send } func (s *Sub) PackQueryWithdrawReq() interface{} { r := s.Base.QueryWithdrawReq send := &QueryWithdrawReq{ MchNo: mid, OrderNo: r.APIOrderID, MchOrderNo: r.OrderID, } send.Sign = s.Base.SignMD5(send) return send } func (s *Sub) PackQueryPayReq() interface{} { r := s.Base.QueryPayReq send := &QueryPayReq{ MchNo: mid, OrderNo: r.APIOrderID, } send.Sign = s.Base.SignMD5(send) return send } func (s *Sub) CheckSign(str string) bool { str += "&key=" + key checkSign := "" // s.Base.CallbackResp.Msg = "success" mySign := util.CalculateMD5(str) if s.Base.Opt == base.OPTPayCB { req := s.Base.CallbackReq.(*PayCallbackReq) log.Debug("checkSign pay:%+v", *req) if req.Status == "UN_PAYD" { return false } checkSign = req.Sign s.Base.CallbackResp.OrderID = req.MchOrderNo s.Base.CallbackResp.Success = req.Status == "PAID" // mySign = s.Base.SignMD5(req) } else if s.Base.Opt == base.OPTWithdrawCB { req := s.Base.CallbackReq.(*WithdrawCallbackReq) log.Debug("checkSign withdraw:%+v", *req) if req.Status == "UN_PAYD" { return false } checkSign = req.Sign s.Base.CallbackResp.OrderID = req.MchOrderNo s.Base.CallbackResp.Success = req.Status == "PAID" s.Base.CallbackResp.FailMessage = req.Msg // mySign = s.Base.SignMD5(req) } return mySign == checkSign }