dongfeng-pay/boss/service/queryService.go

package service

import (
	"boss/datas"
	"boss/models/order"
	"boss/models/payfor"
	"fmt"
	"github.com/beego/beego/v2/client/httplib"
	"github.com/beego/beego/v2/core/logs"
	"github.com/beego/beego/v2/server/web"
)

type QueryService struct {
}

func OrderQuery(bankOrderId string) string {

	orderInfo := order.GetOrderByBankOrderId(bankOrderId)

	if orderInfo.BankOrderId == "" || len(orderInfo.BankOrderId) == 0 {
		logs.Error("不存在这样的订单，订单查询结束")
		return "不存在这样的订单"
	}

	if orderInfo.Status != "" && orderInfo.Status != "wait" {
		logs.Error(fmt.Sprintf("该订单=%s，已经处理完毕，", bankOrderId))
		return "该订单已经处理完毕"
	}

	// 向gateway发送请求，请求上游的支付结果
	gUrl, _ := web.AppConfig.String("gateway::host")
	gUrl = gUrl + "supplier/order/query" + "?" + "bankOrderId=" + bankOrderId
	res, err := httplib.Get(gUrl).String()
	if err != nil {
		logs.Error("获取gateway上游订单查询结果失败：" + err.Error())
	}

	if res == "success" {
		return res
	}

	return "fail"

}

func (c *QueryService) SupplierOrderQuery(bankOrderId string) *datas.KeyDataJSON {

	keyDataJSON := new(datas.KeyDataJSON)
	keyDataJSON.Code = 200
	exist := order.BankOrderIdIsEixst(bankOrderId)
	if !exist {
		keyDataJSON.Msg = "该订单不存在"
		keyDataJSON.Code = -1
	}

	msg := OrderQuery(bankOrderId)

	keyDataJSON.Msg = msg
	return keyDataJSON
}

func (c *QueryService) SupplierPayForQuery(bankOrderId string) *datas.KeyDataJSON {
	keyDataJSON := new(datas.KeyDataJSON)
	keyDataJSON.Code = 200

	if bankOrderId == "" {
		keyDataJSON.Code = -1
		keyDataJSON.Msg = "不存在这样的代付订单"
	} else {
		payFor := payfor.GetPayForByBankOrderId(bankOrderId)
		if payFor.RoadUid == "" {
			keyDataJSON.Msg = "该代付订单没有对应的通道uid"
		} else {
			result := querySupplierPayForResult(bankOrderId)
			if result {
				keyDataJSON.Msg = "处理成功！"
			} else {
				keyDataJSON.Msg = "处理失败！"
			}
		}
	}
	return keyDataJSON
}

func querySupplierPayForResult(bankOrderId string) bool {
	payforUrl, _ := web.AppConfig.String("gateway::host")
	u := payforUrl + "gateway/supplier/payfor/query" + "?bankOrderId=" + bankOrderId
	s, err := httplib.Get(u).String()
	if err != nil {
		logs.Error("处理代付查询请求gateway失败：", err)
		return false
	}
	if s == "fail" {
		return false
	} else {
		return true
	}
}