feat: 订单查询

2024-11-07 10:13:15 +08:00 · 2024-11-07 10:13:15 +08:00 · ad517b9d56
parent 5e8d35df25
commit ad517b9d56
16 changed files with 1637 additions and 519 deletions
--- a/5
+++ b/5
@ -13,6 +13,11 @@ RUN go build -ldflags="-s -w" -o /src/cmd/api/yl cmd/api/yl.go

 FROM registry.cn-chengdu.aliyuncs.com/go_ls/alpha:v1 AS runtime

+RUN echo 'http://mirrors.ustc.edu.cn/alpine/v3.5/main' > /etc/apk/repositories \
+&& echo 'http://mirrors.ustc.edu.cn/alpine/v3.5/community' >>/etc/apk/repositories \
+&& apk update && apk add tzdata \
+&& ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime \
+&& echo "Asia/Shanghai" > /etc/timezone


 COPY --from=builder /etc/ssl/certs/ca-certificates.crt /etc/ssl/certs/ca-certificates.crt
--- a/cmd/api/config/config.yaml
+++ b/cmd/api/config/config.yaml
@ -6,9 +6,21 @@ Cache:
    Pass: lansexiongdi@666
 Nacos:
  Endpoints:
-    - transfer_middleware:10001
+    - 120.55.12.245:10001
 Sys:
  PrimaryKey: "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQC5FGH7Tq5u7pA/eh6AjAS0InykvWDJt095go8yK3w7+TRIhSYDdbRHlTgOQm4nWuMPfz3U2Rs1vJQwyyEYdylcYJ2zFLr7Vb1BdvkJ3Kz/2yJ6sz3BNq6xAHaeCKzA/WZxnc/ypfkGlrmfr2tNqCM9CUHUWryihBjLxwRiWLmo0aKgYpKLKYNixLgyqUYAifD3APncAduv6sSjUPMTyXMOlP1DXgVwX6IaUG/yV8/56Ew72Vdi/y4qZmCKMmXq4PovWrs8ISOEuhxbfLrGWbGCAVYPq7d7XaH+AOY4dhJZm7OZ43UGWw80QKGEPkvU4Oquzu8BqBh12md7Zsd6r0XzAgMBAAECggEAcLgTPKUc437z51UOwqeELdlbJFIaYn/8LTrwz1NgpH4P86L0FeNX2sjsjPK0d8+IvmV2WO2o/r9NWbI9A9N/Iz3MjcawYmZDj11QK0t1KZZil2wWzlfpaO+pTnJmFFvASq4ceeHPms2tW63QokkmvQOoTha9EBV3rJQW/XagDEolty57kkfmB31cQHJuAt+BF5EzBqv3q3jnqhsj8J/ddT0hadyKq65u85VomLH92asu/KKMKYYXC8aHjgX48chAmQUAHGM/HCD2owLHwtei2kPWNDx85ecBsglIX3wy0yhH1dnL+o3eeskVLl89ye3QCJPHJBaNUUfbgucgWT0bsQKBgQD1pPMAe31ZXajl9WlHMtn8qhpAGzi/GiiH6YrrHMQECC2GGuAakBko1Vhc+2HU35gwlPOhwMIOCapB0cCqcZVo3+71AKo78YvZLQ7yMuSsp0/Wn2N79NZ6+++wtHGPP9eHrLuWm23l15W7W0RcQptTaQupbculMQZ8b6cAjh6d1QKBgQDA4c4Xl2ePbQdgMMOuKTPPKF3QI1VhCVtxSV+Gj9MZBZedstz9+ZO3oxHhy8D5S9it1hE6dn6/a+7OWibZ/gBr1S0+11LcwKDb7q30dimr9bQs/srIywpoIIN8wVEkX4P9JLOWgQeAtq53IMba+cElef916aqyJpXuIek9lvUQpwKBgQCD7alNMwWpf3H8v4dhY+BLoRgkIfqiOGxYQogHqhVkjPfWNIzz9zxr/9lLZv+uEsBsJzOKRjpyy6ITY5H0eLhj8REnqMnFE/+mDlsenVLPn7Rzcns90ct3leOvpdnvs7wP9CdzxdqKPPUAAQ5/9o3xiFNpFbzv5Zq0LkslMy8iWQKBgQCiRJWctUxzllcRLpVBTPqAOkaKV195zmR2rzLFQvRmZZUDH7nZlQEYCgF+Q2tqj8uPm7tMwumo4wW55pAu7witr19sMbxNaWUrAeao9kvilkfpXsV9HYv4w/m6l+xKvGyPKDRJ1u1X9Nhb8mA5UsqSW8t2CIoJbHrQJwlRPlGXmwKBgQDg4rcsM2PmShOg8lSrHXPATXiZyyqpPJLpXbV6DRKyt7U6KWjyrplQN7yOoIUgsuD2OC/q67y7w1P3OY7X0RDnMr6MtIV0JyBJHg24eyBTqeLai2DqoHlsBOSvpJDZf+g/DXCjvHMWp1h0wqdj3aLthmU0dHM/CEqr/o7d8GwrGQ=="
  Url: "http://pre.22233.cn/"
  KEY: "da4953198bce4bc8eca9ff7101ae7eb8"
-YouleHost: https://vshopmain.sdycsdyc.cn
+YouleHost: https://vshopmain.sdycsdyc.cn
+
+MarketConfig:
+  AppId: "2783278"
+  PosId: "2783278"
+  SupplierSkuId:
+    872: "yl20240730"
+
+DB:
+  Master:
+    DataSource: root:lansexiongdi6,@tcp(47.97.27.195:3306)/transfer?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai
+  Slave:
+    DataSource: root:lansexiongdi6,@tcp(47.97.27.195:3306)/transfer?charset=utf8mb4&parseTime=true&loc=Asia%2FShanghai
--- a/cmd/api/internal/config/config.go
+++ b/cmd/api/internal/config/config.go
@ -16,6 +16,14 @@ type Config struct {
 	}
 	YouleHost    string
 	MarketConfig MarketConfig
+	DB           struct {
+		Master struct {
+			DataSource string
+		}
+		Slave struct {
+			DataSource string
+		}
+	}
 }

 type Rpc struct {
--- a/cmd/api/internal/handler/yl/getOrderHandler.go
+++ b/cmd/api/internal/handler/yl/getOrderHandler.go
@ -0,0 +1,36 @@
+package yl
+
+import (
+	"errors"
+	"net/http"
+	"rs/genModel"
+	"rs/untils/response"
+
+	"github.com/zeromicro/go-zero/rest/httpx"
+	"rs/cmd/api/internal/logic/yl"
+	"rs/cmd/api/internal/svc"
+	"rs/cmd/api/internal/types"
+)
+
+// 订单查询接口
+func GetOrderHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req types.GetOrderReq
+		if err := httpx.Parse(r, &req); err != nil {
+			httpx.ErrorCtx(r.Context(), w, err)
+			return
+		}
+
+		l := yl.NewGetOrderLogic(r.Context(), svcCtx)
+		resp, err := l.GetOrder(&req)
+		if err != nil {
+			if errors.Is(err, genModel.ErrNotFound) {
+				response.Err(w, response.HTTP_REUEST_NOT_FOUND, "")
+			} else {
+				response.Err(w, response.HTTP_REUEST_FAIL, err.Error())
+			}
+		} else {
+			response.Suc(w, response.HTTP_SUCCESS, resp)
+		}
+	}
+}
--- a/cmd/api/internal/handler/yl/ylAsyncHandler.go
+++ b/cmd/api/internal/handler/yl/ylAsyncHandler.go
@ -2,6 +2,7 @@ package yl

 import (
 	"net/http"
+	"rs/untils/response"

 	"github.com/zeromicro/go-zero/rest/httpx"
 	"rs/cmd/api/internal/logic/yl"
@ -21,9 +22,9 @@ func YlAsyncHandler(svcCtx *svc.ServiceContext) http.HandlerFunc {
 		l := yl.NewYlAsyncLogic(r.Context(), svcCtx)
 		resp, err := l.YlAsync(&req)
 		if err != nil {
-			httpx.ErrorCtx(r.Context(), w, err)
+			response.Err(w, response.HTTP_REUEST_FAIL, err.Error())
 		} else {
-			httpx.OkJsonCtx(r.Context(), w, resp)
+			response.Suc(w, response.HTTP_SUCCESS, resp)
 		}
 	}
 }
--- a/cmd/api/internal/logic/yl/getOrderLogic.go
+++ b/cmd/api/internal/logic/yl/getOrderLogic.go
@ -0,0 +1,110 @@
+package yl
+
+import (
+	"context"
+	"encoding/json"
+	"fmt"
+	"github.com/zeromicro/go-zero/core/logx"
+	"rs/cmd/api/internal/logic/vo"
+	"rs/cmd/api/internal/svc"
+	"rs/cmd/api/internal/types"
+	"rs/rpc/transfer"
+	"strconv"
+	"time"
+)
+
+type GetOrderLogic struct {
+	logx.Logger
+	ctx    context.Context
+	svcCtx *svc.ServiceContext
+}
+
+// 订单查询接口
+func NewGetOrderLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetOrderLogic {
+	return &GetOrderLogic{
+		Logger: logx.WithContext(ctx),
+		ctx:    ctx,
+		svcCtx: svcCtx,
+	}
+}
+
+func (l *GetOrderLogic) GetOrder(req *types.GetOrderReq) (resp *types.GetOrderRsp, err error) {
+	var (
+		status int
+	)
+
+	order, err := l.svcCtx.BaseServiceContext.YlOrderMarketRepo.FindOneByDeliverOrderNoSupplierOrderNo(l.ctx, req.DeliverOrderNo, req.SupplierOrderNo)
+	if err != nil {
+		return
+	}
+
+	data := transfer.MarketKeySendRes{}
+	err = json.Unmarshal([]byte(order.Resp), &data)
+	if err != nil {
+		return
+	}
+
+	if data.Data.ShortUrl != "" {
+		status = 1
+	}
+	accouont, _ := strconv.Atoi(order.Account)
+	supplierId, _ := strconv.Atoi(order.SupplierId)
+	resp = &types.GetOrderRsp{
+		DeliverOrderNo:  req.DeliverOrderNo,
+		SupplierOrderNo: req.SupplierOrderNo,
+		SupplierSkuId:   order.SupplierSkuId,
+		Account:         int64(accouont),
+		SendStatus:      status,
+		Price:           0,
+		StatusTime:      order.UpdateTime.Unix(),
+		Msg:             "",
+		SupplierId:      int64(supplierId),
+		CardNo:          "",
+		CardKey:         "",
+		CardExpireTime:  "",
+		CardExchangeUrl: data.Data.ShortUrl,
+	}
+
+	return
+}
+
+func (l *GetOrderLogic) GetOrder2(req *types.GetOrderReq) (resp *types.GetOrderRsp, err error) {
+	request := transfer.MarketQueryReq{
+		AppId: l.svcCtx.Config.MarketConfig.AppId,
+		//Sign:        "",
+		ReqCode:     "voucher.query",
+		MemId:       fmt.Sprintf("%d", req.SupplierId),
+		ReqSerialNo: req.DeliverOrderNo,
+		Timestamp:   time.Unix(req.RequestTime, 0).Format("20060102150405"),
+		VoucherId:   "",
+		VoucherCode: req.SupplierOrderNo,
+	}
+
+	request.Sign = l.svcCtx.Config.Sys.PrimaryKey
+
+	result, err := l.svcCtx.TransferRpc.MarketQuery(l.ctx, &request)
+	if err != nil {
+		return
+	}
+	if result.ErrCode != vo.RES_SUCCESS {
+		return nil, fmt.Errorf("请求失败:%v", result.Msg)
+	}
+
+	resp = &types.GetOrderRsp{
+		DeliverOrderNo:  req.DeliverOrderNo,
+		SupplierOrderNo: req.SupplierOrderNo,
+		//SupplierSkuId:   req,
+		//Count:           req.,
+		SendStatus:      1,
+		Price:           0,
+		StatusTime:      0,
+		Msg:             "",
+		SupplierId:      0,
+		CardNo:          "",
+		CardKey:         "",
+		CardExpireTime:  "",
+		CardExchangeUrl: result.Data.VoucherCode,
+	}
+
+	return
+}
--- a/cmd/api/internal/logic/yl/ylAsyncLogic.go
+++ b/cmd/api/internal/logic/yl/ylAsyncLogic.go
@ -2,9 +2,12 @@ package yl

 import (
 	"context"
+	"database/sql"
 	"encoding/json"
+	"errors"
 	"fmt"
 	"github.com/bytedance/sonic"
+	"rs/genModel"
 	"rs/untils/sign"

 	"rs/cmd/api/internal/logic/vo"
@ -77,16 +80,19 @@ func (l *YlAsyncLogic) YlAsync(req *types.AsyncReq) (resp *types.AsyncResp, err
 		return nil, fmt.Errorf("请求失败:%v", result.Msg)
 	}

-	supplierOrderNo := l.getExchangeCode(result.Data.VoucherCode)
-	if supplierOrderNo == "" {
+	if result.Data.VoucherCode == "" {
 		return nil, fmt.Errorf("请求失败未取到数据:%v", result.Msg)
 	}
+	supplierOrderNo := req.DeliverOrderNo
 	// 异步通知
 	go func() {
 		time.Sleep(2 * time.Second)
 		l.asyncSendMarket(supplierOrderNo, req, result.Data)
 	}()

+	// 记录订单
+	l.saveOrder(req, result, supplierOrderNo, VoucherId)
+
 	return &types.AsyncResp{
 		Msg:             "",
 		Status:          0,
@ -115,7 +121,7 @@ func (l *YlAsyncLogic) asyncSendMarket(supplierOrderNo string, asyncReq *types.A
 			SupplierSkuId:   asyncReq.SupplierSkuId,
 			RequestTime:     time.Now().Unix(),
 			Account:         asyncReq.Account,
-			Status:          2,
+			Status:          1,
 			Msg:             "",
 			Price:           asyncReq.Price,
 			SupplierId:      asyncReq.SupplierId,
@ -132,7 +138,7 @@ func (l *YlAsyncLogic) asyncSendMarket(supplierOrderNo string, asyncReq *types.A
 	if err != nil {
 		return
 	}
-	req.Sign, err = sign.GetSign(reqDataMap, l.svcCtx.Config.Sys.PrimaryKey)
+	req.Sign, err = sign.GetSign(reqDataMap, l.svcCtx.Config.Sys.Key)
 	if err != nil {
 		l.Logger.Errorf("签名失败:%v", err.Error())
 		return
@ -153,3 +159,40 @@ func (l *YlAsyncLogic) asyncSendMarket(supplierOrderNo string, asyncReq *types.A

 	return
 }
+
+func (l *YlAsyncLogic) saveOrder(req *types.AsyncReq, rsp *transfer.MarketKeySendRes, supplierOrderNo, VoucherId string) {
+
+	order, err := l.svcCtx.BaseServiceContext.YlOrderMarketRepo.FindOneByDeliverOrderNoSupplierOrderNo(l.ctx, req.DeliverOrderNo, supplierOrderNo)
+	if err != nil {
+		if !errors.Is(err, genModel.ErrNotFound) {
+			l.Logger.Errorf("data = %s 查询订单失败:%v", order, err.Error())
+		}
+	}
+	if order != nil {
+		l.Logger.Errorf("DeliverOrderNo = %s 订单已存在", order.DeliverOrderNo)
+		return
+	}
+
+	b, _ := json.Marshal(rsp)
+	data := &genModel.YlOrderMarket{
+		DeliverOrderNo:  req.DeliverOrderNo,
+		SupplierOrderNo: supplierOrderNo,
+		SupplierId:      fmt.Sprintf("%d", req.SupplierId),
+		Price:           req.Price,
+		SkuId:           req.SkuId,
+		SupplierSkuId:   req.SupplierSkuId,
+		Account:         req.Account,
+		VoucherId: sql.NullString{
+			String: VoucherId,
+			Valid:  true,
+		},
+		Resp:   string(b),
+		Status: 1,
+		//CreateTime: time.Now(),
+	}
+
+	_, err = l.svcCtx.BaseServiceContext.YlOrderMarketRepo.Insert(l.ctx, data)
+	if err != nil {
+		l.Logger.Errorf("data = %s 插入订单失败:%v", data, err.Error())
+	}
+}
--- a/cmd/api/internal/svc/serviceContext.go
+++ b/cmd/api/internal/svc/serviceContext.go
@ -1,12 +1,14 @@
 package svc

 import (
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
 	"github.com/zeromicro/go-zero/rest"
 	"github.com/zeromicro/go-zero/zrpc"
 	_ "github.com/zeromicro/zero-contrib/zrpc/registry/nacos"
 	"rs/cmd/api/internal/config"
 	"rs/cmd/api/internal/middleware"
 	"rs/cmd/api/internal/types"
+	"rs/genModel"
 	"rs/rpc/transferClient"
 )

@ -20,9 +22,12 @@ func NewServiceContext(c config.Config) *ServiceContext {
 		Endpoints: c.Nacos.Endpoints,
 	}))

+	sqlConn := sqlx.NewMysql(c.DB.Master.DataSource)
+
 	base := types.BaseServiceContext{
-		Config:      c,
-		TransferRpc: client,
+		Config:            c,
+		TransferRpc:       client,
+		YlOrderMarketRepo: genModel.NewYlOrderMarketModel(sqlConn, c.Cache),
 	}
 	return &ServiceContext{
 		BaseServiceContext: &base,
--- a/cmd/api/internal/types/extraTypes.go
+++ b/cmd/api/internal/types/extraTypes.go
@ -13,6 +13,7 @@ type BaseServiceContext struct {
 	Merchant            genModel.MerchantModel
 	TransferOrder       genModel.ServerOrderModel
 	MerchantWechat      genModel.MerchantWechatModel
+	YlOrderMarketRepo   genModel.YlOrderMarketModel
 }

 type DecryptReqData struct {
@ -42,7 +43,7 @@ type NotifyReq struct {
 	SupplierOrderNo string `json:"supplierOrderNo"` // 供货商订单号
 	SupplierSkuId   int64  `json:"supplierSkuId"`   // 供货商sku
 	RequestTime     int64  `json:"requestTime"`     // 请求时间
-	Account         string `json:"thirdSkuId"`      // 充值账号
+	Account         string `json:"account"`         // 充值账号
 	Status          int    `json:"status"`          //错误码: 1-发货成功 2-发货失败
 	Msg             string `json:"msg"`             // 错误信息
 	Price           int64  `json:"price"`           //结算价格(单位:厘)
--- a/cmd/api/internal/types/types.go
+++ b/cmd/api/internal/types/types.go
@ -38,7 +38,7 @@ type GetOrderRsp struct {
 	DeliverOrderNo  string `json:"deliverOrderNo"`  // 平台订单号
 	SupplierOrderNo string `json:"supplierOrderNo"` // 供货商订单号
 	SupplierSkuId   int64  `json:"supplierSkuId"`   // 供货商sku
-	Count           int64  `json:"count"`           //数量（此字段只目前支持是金豆，积分等虚拟资产，其他商品不支持）
+	Account         int64  `json:"account"`         //充值账号
 	SendStatus      int    `json:"sendStatus"`      // 发货状态: 0-发货中 1-发货成功 2-发货失败
 	Price           int64  `json:"price"`           //结算价格(单位:厘)
 	StatusTime      int64  `json:"statusTime"`      // 成功/失败时间
--- a/genModel/ylOrderMarketModel.go
+++ b/genModel/ylOrderMarketModel.go
@ -0,0 +1,27 @@
+package genModel
+
+import (
+	"github.com/zeromicro/go-zero/core/stores/cache"
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
+)
+
+var _ YlOrderMarketModel = (*customYlOrderMarketModel)(nil)
+
+type (
+	// YlOrderMarketModel is an interface to be customized, add more methods here,
+	// and implement the added methods in customYlOrderMarketModel.
+	YlOrderMarketModel interface {
+		ylOrderMarketModel
+	}
+
+	customYlOrderMarketModel struct {
+		*defaultYlOrderMarketModel
+	}
+)
+
+// NewYlOrderMarketModel returns a model for the database table.
+func NewYlOrderMarketModel(conn sqlx.SqlConn, c cache.CacheConf, opts ...cache.Option) YlOrderMarketModel {
+	return &customYlOrderMarketModel{
+		defaultYlOrderMarketModel: newYlOrderMarketModel(conn, c, opts...),
+	}
+}
--- a/genModel/ylOrderMarketModel_gen.go
+++ b/genModel/ylOrderMarketModel_gen.go
@ -0,0 +1,157 @@
+// Code generated by goctl. DO NOT EDIT.
+// versions:
+//  goctl version: 1.7.2
+
+package genModel
+
+import (
+	"context"
+	"database/sql"
+	"fmt"
+	"strings"
+	"time"
+
+	"github.com/zeromicro/go-zero/core/stores/builder"
+	"github.com/zeromicro/go-zero/core/stores/cache"
+	"github.com/zeromicro/go-zero/core/stores/sqlc"
+	"github.com/zeromicro/go-zero/core/stores/sqlx"
+	"github.com/zeromicro/go-zero/core/stringx"
+)
+
+var (
+	ylOrderMarketFieldNames          = builder.RawFieldNames(&YlOrderMarket{})
+	ylOrderMarketRows                = strings.Join(ylOrderMarketFieldNames, ",")
+	ylOrderMarketRowsExpectAutoSet   = strings.Join(stringx.Remove(ylOrderMarketFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), ",")
+	ylOrderMarketRowsWithPlaceHolder = strings.Join(stringx.Remove(ylOrderMarketFieldNames, "`id`", "`create_at`", "`create_time`", "`created_at`", "`update_at`", "`update_time`", "`updated_at`"), "=?,") + "=?"
+
+	cacheTransferYlOrderMarketIdPrefix                            = "cache:transfer:ylOrderMarket:id:"
+	cacheTransferYlOrderMarketDeliverOrderNoSupplierOrderNoPrefix = "cache:transfer:ylOrderMarket:deliverOrderNo:supplierOrderNo:"
+)
+
+type (
+	ylOrderMarketModel interface {
+		Insert(ctx context.Context, data *YlOrderMarket) (sql.Result, error)
+		FindOne(ctx context.Context, id uint64) (*YlOrderMarket, error)
+		FindOneByDeliverOrderNoSupplierOrderNo(ctx context.Context, deliverOrderNo string, supplierOrderNo string) (*YlOrderMarket, error)
+		Update(ctx context.Context, data *YlOrderMarket) error
+		Delete(ctx context.Context, id uint64) error
+	}
+
+	defaultYlOrderMarketModel struct {
+		sqlc.CachedConn
+		table string
+	}
+
+	YlOrderMarket struct {
+		Id              uint64         `db:"id"`
+		DeliverOrderNo  string         `db:"deliverOrderNo"`  // 平台订单号
+		SupplierOrderNo string         `db:"supplierOrderNo"` // 供货商订单号
+		SupplierId      string         `db:"supplierId"`      // 供货商id
+		Price           int64          `db:"price"`           // 结算价格(单位:厘)
+		SkuId           int64          `db:"skuId"`           // 平台sku
+		SupplierSkuId   int64          `db:"supplierSkuId"`   // 供货商sku
+		Account         string         `db:"account"`         // 充值账号
+		Resp            string         `db:"resp"`            // 响应数据
+		CreateTime      time.Time      `db:"create_time"`
+		UpdateTime      time.Time      `db:"update_time"`
+		Status          int64          `db:"status"`    // 状态
+		VoucherId       sql.NullString `db:"VoucherId"` // 批次号
+	}
+)
+
+func newYlOrderMarketModel(conn sqlx.SqlConn, c cache.CacheConf, opts ...cache.Option) *defaultYlOrderMarketModel {
+	return &defaultYlOrderMarketModel{
+		CachedConn: sqlc.NewConn(conn, c, opts...),
+		table:      "`yl_order_market`",
+	}
+}
+
+func (m *defaultYlOrderMarketModel) Delete(ctx context.Context, id uint64) error {
+	data, err := m.FindOne(ctx, id)
+	if err != nil {
+		return err
+	}
+
+	transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey := fmt.Sprintf("%s%v:%v", cacheTransferYlOrderMarketDeliverOrderNoSupplierOrderNoPrefix, data.DeliverOrderNo, data.SupplierOrderNo)
+	transferYlOrderMarketIdKey := fmt.Sprintf("%s%v", cacheTransferYlOrderMarketIdPrefix, id)
+	_, err = m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := fmt.Sprintf("delete from %s where `id` = ?", m.table)
+		return conn.ExecCtx(ctx, query, id)
+	}, transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey, transferYlOrderMarketIdKey)
+	return err
+}
+
+func (m *defaultYlOrderMarketModel) FindOne(ctx context.Context, id uint64) (*YlOrderMarket, error) {
+	transferYlOrderMarketIdKey := fmt.Sprintf("%s%v", cacheTransferYlOrderMarketIdPrefix, id)
+	var resp YlOrderMarket
+	err := m.QueryRowCtx(ctx, &resp, transferYlOrderMarketIdKey, func(ctx context.Context, conn sqlx.SqlConn, v any) error {
+		query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", ylOrderMarketRows, m.table)
+		return conn.QueryRowCtx(ctx, v, query, id)
+	})
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}
+}
+
+func (m *defaultYlOrderMarketModel) FindOneByDeliverOrderNoSupplierOrderNo(ctx context.Context, deliverOrderNo string, supplierOrderNo string) (*YlOrderMarket, error) {
+	transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey := fmt.Sprintf("%s%v:%v", cacheTransferYlOrderMarketDeliverOrderNoSupplierOrderNoPrefix, deliverOrderNo, supplierOrderNo)
+	var resp YlOrderMarket
+	err := m.QueryRowIndexCtx(ctx, &resp, transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey, m.formatPrimary, func(ctx context.Context, conn sqlx.SqlConn, v any) (i any, e error) {
+		query := fmt.Sprintf("select %s from %s where `deliverOrderNo` = ? and `supplierOrderNo` = ? limit 1", ylOrderMarketRows, m.table)
+		if err := conn.QueryRowCtx(ctx, &resp, query, deliverOrderNo, supplierOrderNo); err != nil {
+			return nil, err
+		}
+		return resp.Id, nil
+	}, m.queryPrimary)
+	switch err {
+	case nil:
+		return &resp, nil
+	case sqlc.ErrNotFound:
+		return nil, ErrNotFound
+	default:
+		return nil, err
+	}
+}
+
+func (m *defaultYlOrderMarketModel) Insert(ctx context.Context, data *YlOrderMarket) (sql.Result, error) {
+	transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey := fmt.Sprintf("%s%v:%v", cacheTransferYlOrderMarketDeliverOrderNoSupplierOrderNoPrefix, data.DeliverOrderNo, data.SupplierOrderNo)
+	transferYlOrderMarketIdKey := fmt.Sprintf("%s%v", cacheTransferYlOrderMarketIdPrefix, data.Id)
+	ret, err := m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := fmt.Sprintf("insert into %s (%s) values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)", m.table, ylOrderMarketRowsExpectAutoSet)
+		return conn.ExecCtx(ctx, query, data.DeliverOrderNo, data.SupplierOrderNo, data.SupplierId, data.Price, data.SkuId, data.SupplierSkuId, data.Account, data.Resp, data.Status, data.VoucherId)
+	}, transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey, transferYlOrderMarketIdKey)
+	return ret, err
+}
+
+func (m *defaultYlOrderMarketModel) Update(ctx context.Context, newData *YlOrderMarket) error {
+	data, err := m.FindOne(ctx, newData.Id)
+	if err != nil {
+		return err
+	}
+
+	transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey := fmt.Sprintf("%s%v:%v", cacheTransferYlOrderMarketDeliverOrderNoSupplierOrderNoPrefix, data.DeliverOrderNo, data.SupplierOrderNo)
+	transferYlOrderMarketIdKey := fmt.Sprintf("%s%v", cacheTransferYlOrderMarketIdPrefix, data.Id)
+	_, err = m.ExecCtx(ctx, func(ctx context.Context, conn sqlx.SqlConn) (result sql.Result, err error) {
+		query := fmt.Sprintf("update %s set %s where `id` = ?", m.table, ylOrderMarketRowsWithPlaceHolder)
+		return conn.ExecCtx(ctx, query, newData.DeliverOrderNo, newData.SupplierOrderNo, newData.SupplierId, newData.Price, newData.SkuId, newData.SupplierSkuId, newData.Account, newData.Resp, newData.Status, newData.VoucherId, newData.Id)
+	}, transferYlOrderMarketDeliverOrderNoSupplierOrderNoKey, transferYlOrderMarketIdKey)
+	return err
+}
+
+func (m *defaultYlOrderMarketModel) formatPrimary(primary any) string {
+	return fmt.Sprintf("%s%v", cacheTransferYlOrderMarketIdPrefix, primary)
+}
+
+func (m *defaultYlOrderMarketModel) queryPrimary(ctx context.Context, conn sqlx.SqlConn, v, primary any) error {
+	query := fmt.Sprintf("select %s from %s where `id` = ? limit 1", ylOrderMarketRows, m.table)
+	return conn.QueryRowCtx(ctx, v, query, primary)
+}
+
+func (m *defaultYlOrderMarketModel) tableName() string {
+	return m.table
+}
--- a/rpc/transfer.proto
+++ b/rpc/transfer.proto
@ -79,7 +79,7 @@ message MarketQueryRes {

 message MarketQueryReq {
  string app_id = 1;
-  uint64 sign = 2;
+  string sign = 2;
  string req_code = 3;
  string mem_id = 4;
  string req_serial_no = 5;
@ -103,7 +103,7 @@ message MarketKeyDiscardRes {

 message MarketKeyDiscardReq {
  string app_id = 1;
-  uint64 sign = 2;
+  string sign = 2;
  string req_code = 3;
  string mem_id = 4;
  string req_serial_no = 5;
--- a/rpc/transfer/transfer.pb.go
+++ b/rpc/transfer/transfer.pb.go
--- a/rpc/transfer/transfer_grpc.pb.go
+++ b/rpc/transfer/transfer_grpc.pb.go
@ -1,7 +1,7 @@
 // Code generated by protoc-gen-go-grpc. DO NOT EDIT.
 // versions:
-// - protoc-gen-go-grpc v1.3.0
-// - protoc             v3.6.1
+// - protoc-gen-go-grpc v1.4.0
+// - protoc             (unknown)
 // source: transfer.proto

 package transfer
@ -15,8 +15,8 @@ import (

 // This is a compile-time assertion to ensure that this generated file
 // is compatible with the grpc package it is being compiled against.
-// Requires gRPC-Go v1.32.0 or later.
-const _ = grpc.SupportPackageIsVersion7
+// Requires gRPC-Go v1.62.0 or later.
+const _ = grpc.SupportPackageIsVersion8

 const (
 	Transfer_ZltxOrderRecharge_FullMethodName      = "/transfer.Transfer/zltxOrderRecharge"
@ -31,6 +31,9 @@ const (
 	Transfer_MarketKeyDiscard_FullMethodName       = "/transfer.Transfer/marketKeyDiscard"
 	Transfer_MarketQuery_FullMethodName            = "/transfer.Transfer/marketQuery"
 	Transfer_RsCouponGrant_FullMethodName          = "/transfer.Transfer/rsCouponGrant"
+	Transfer_NewMarketOrder_FullMethodName         = "/transfer.Transfer/newMarketOrder"
+	Transfer_NewMarketQuery_FullMethodName         = "/transfer.Transfer/newMarketQuery"
+	Transfer_NewMarketDiscard_FullMethodName       = "/transfer.Transfer/newMarketDiscard"
 )

 // TransferClient is the client API for Transfer service.
@ -49,6 +52,9 @@ type TransferClient interface {
 	MarketKeyDiscard(ctx context.Context, in *MarketKeyDiscardReq, opts ...grpc.CallOption) (*MarketKeyDiscardRes, error)
 	MarketQuery(ctx context.Context, in *MarketQueryReq, opts ...grpc.CallOption) (*MarketQueryRes, error)
 	RsCouponGrant(ctx context.Context, in *RsCouponGrantReq, opts ...grpc.CallOption) (*RsCouponGrantRes, error)
+	NewMarketOrder(ctx context.Context, in *NewMarketOrderReq, opts ...grpc.CallOption) (*NewMarketOrderRes, error)
+	NewMarketQuery(ctx context.Context, in *NewMarketQueryReq, opts ...grpc.CallOption) (*NewMarketOrderRes, error)
+	NewMarketDiscard(ctx context.Context, in *NewMarketDiscardReq, opts ...grpc.CallOption) (*NewMarketDiscardRes, error)
 }

 type transferClient struct {
@ -60,8 +66,9 @@ func NewTransferClient(cc grpc.ClientConnInterface) TransferClient {
 }

 func (c *transferClient) ZltxOrderRecharge(ctx context.Context, in *ZltxOrderRechargeReq, opts ...grpc.CallOption) (*DefaultRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(DefaultRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxOrderRecharge_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxOrderRecharge_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -69,8 +76,9 @@ func (c *transferClient) ZltxOrderRecharge(ctx context.Context, in *ZltxOrderRec
 }

 func (c *transferClient) ZltxOrderRechargeQuery(ctx context.Context, in *ZltxOrderRechargeQueryReq, opts ...grpc.CallOption) (*ZltxOrderRechargeQueryRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(ZltxOrderRechargeQueryRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxOrderRechargeQuery_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxOrderRechargeQuery_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -78,8 +86,9 @@ func (c *transferClient) ZltxOrderRechargeQuery(ctx context.Context, in *ZltxOrd
 }

 func (c *transferClient) ZltxOrderCard(ctx context.Context, in *ZltxOrderCardReq, opts ...grpc.CallOption) (*DefaultRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(DefaultRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxOrderCard_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxOrderCard_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -87,8 +96,9 @@ func (c *transferClient) ZltxOrderCard(ctx context.Context, in *ZltxOrderCardReq
 }

 func (c *transferClient) ZltxOrderCardQuery(ctx context.Context, in *ZltxOrderCardQueryReq, opts ...grpc.CallOption) (*ZltxOrderCardQueryRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(ZltxOrderCardQueryRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxOrderCardQuery_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxOrderCardQuery_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -96,8 +106,9 @@ func (c *transferClient) ZltxOrderCardQuery(ctx context.Context, in *ZltxOrderCa
 }

 func (c *transferClient) ZltxOrderSms(ctx context.Context, in *ZltxOrderSmsReq, opts ...grpc.CallOption) (*ZltxOrderSmsRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(ZltxOrderSmsRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxOrderSms_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxOrderSms_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -105,8 +116,9 @@ func (c *transferClient) ZltxOrderSms(ctx context.Context, in *ZltxOrderSmsReq,
 }

 func (c *transferClient) ZltxRechargeInfo(ctx context.Context, in *DefaultReq, opts ...grpc.CallOption) (*ZltxRechargeInfoRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(ZltxRechargeInfoRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxRechargeInfo_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxRechargeInfo_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -114,8 +126,9 @@ func (c *transferClient) ZltxRechargeInfo(ctx context.Context, in *DefaultReq, o
 }

 func (c *transferClient) ZltxRechargeProduct(ctx context.Context, in *DefaultReq, opts ...grpc.CallOption) (*ZltxRechargeProductRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(ZltxRechargeProductRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxRechargeProduct_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxRechargeProduct_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -123,8 +136,9 @@ func (c *transferClient) ZltxRechargeProduct(ctx context.Context, in *DefaultReq
 }

 func (c *transferClient) ZltxRsMiXue(ctx context.Context, in *RsCouponGrantReq, opts ...grpc.CallOption) (*RsCouponGrantRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(RsCouponGrantRes)
-	err := c.cc.Invoke(ctx, Transfer_ZltxRsMiXue_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_ZltxRsMiXue_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -132,8 +146,9 @@ func (c *transferClient) ZltxRsMiXue(ctx context.Context, in *RsCouponGrantReq,
 }

 func (c *transferClient) MarketKeySend(ctx context.Context, in *MarketKeySendReq, opts ...grpc.CallOption) (*MarketKeySendRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(MarketKeySendRes)
-	err := c.cc.Invoke(ctx, Transfer_MarketKeySend_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_MarketKeySend_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -141,8 +156,9 @@ func (c *transferClient) MarketKeySend(ctx context.Context, in *MarketKeySendReq
 }

 func (c *transferClient) MarketKeyDiscard(ctx context.Context, in *MarketKeyDiscardReq, opts ...grpc.CallOption) (*MarketKeyDiscardRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(MarketKeyDiscardRes)
-	err := c.cc.Invoke(ctx, Transfer_MarketKeyDiscard_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_MarketKeyDiscard_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -150,8 +166,9 @@ func (c *transferClient) MarketKeyDiscard(ctx context.Context, in *MarketKeyDisc
 }

 func (c *transferClient) MarketQuery(ctx context.Context, in *MarketQueryReq, opts ...grpc.CallOption) (*MarketQueryRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(MarketQueryRes)
-	err := c.cc.Invoke(ctx, Transfer_MarketQuery_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_MarketQuery_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -159,8 +176,39 @@ func (c *transferClient) MarketQuery(ctx context.Context, in *MarketQueryReq, op
 }

 func (c *transferClient) RsCouponGrant(ctx context.Context, in *RsCouponGrantReq, opts ...grpc.CallOption) (*RsCouponGrantRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
 	out := new(RsCouponGrantRes)
-	err := c.cc.Invoke(ctx, Transfer_RsCouponGrant_FullMethodName, in, out, opts...)
+	err := c.cc.Invoke(ctx, Transfer_RsCouponGrant_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *transferClient) NewMarketOrder(ctx context.Context, in *NewMarketOrderReq, opts ...grpc.CallOption) (*NewMarketOrderRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(NewMarketOrderRes)
+	err := c.cc.Invoke(ctx, Transfer_NewMarketOrder_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *transferClient) NewMarketQuery(ctx context.Context, in *NewMarketQueryReq, opts ...grpc.CallOption) (*NewMarketOrderRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(NewMarketOrderRes)
+	err := c.cc.Invoke(ctx, Transfer_NewMarketQuery_FullMethodName, in, out, cOpts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+func (c *transferClient) NewMarketDiscard(ctx context.Context, in *NewMarketDiscardReq, opts ...grpc.CallOption) (*NewMarketDiscardRes, error) {
+	cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
+	out := new(NewMarketDiscardRes)
+	err := c.cc.Invoke(ctx, Transfer_NewMarketDiscard_FullMethodName, in, out, cOpts...)
 	if err != nil {
 		return nil, err
 	}
@ -183,6 +231,9 @@ type TransferServer interface {
 	MarketKeyDiscard(context.Context, *MarketKeyDiscardReq) (*MarketKeyDiscardRes, error)
 	MarketQuery(context.Context, *MarketQueryReq) (*MarketQueryRes, error)
 	RsCouponGrant(context.Context, *RsCouponGrantReq) (*RsCouponGrantRes, error)
+	NewMarketOrder(context.Context, *NewMarketOrderReq) (*NewMarketOrderRes, error)
+	NewMarketQuery(context.Context, *NewMarketQueryReq) (*NewMarketOrderRes, error)
+	NewMarketDiscard(context.Context, *NewMarketDiscardReq) (*NewMarketDiscardRes, error)
 	mustEmbedUnimplementedTransferServer()
 }

@ -226,6 +277,15 @@ func (UnimplementedTransferServer) MarketQuery(context.Context, *MarketQueryReq)
 func (UnimplementedTransferServer) RsCouponGrant(context.Context, *RsCouponGrantReq) (*RsCouponGrantRes, error) {
 	return nil, status.Errorf(codes.Unimplemented, "method RsCouponGrant not implemented")
 }
+func (UnimplementedTransferServer) NewMarketOrder(context.Context, *NewMarketOrderReq) (*NewMarketOrderRes, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method NewMarketOrder not implemented")
+}
+func (UnimplementedTransferServer) NewMarketQuery(context.Context, *NewMarketQueryReq) (*NewMarketOrderRes, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method NewMarketQuery not implemented")
+}
+func (UnimplementedTransferServer) NewMarketDiscard(context.Context, *NewMarketDiscardReq) (*NewMarketDiscardRes, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method NewMarketDiscard not implemented")
+}
 func (UnimplementedTransferServer) mustEmbedUnimplementedTransferServer() {}

 // UnsafeTransferServer may be embedded to opt out of forward compatibility for this service.
@ -455,6 +515,60 @@ func _Transfer_RsCouponGrant_Handler(srv interface{}, ctx context.Context, dec f
 	return interceptor(ctx, in, info, handler)
 }

+func _Transfer_NewMarketOrder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(NewMarketOrderReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(TransferServer).NewMarketOrder(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Transfer_NewMarketOrder_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(TransferServer).NewMarketOrder(ctx, req.(*NewMarketOrderReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Transfer_NewMarketQuery_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(NewMarketQueryReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(TransferServer).NewMarketQuery(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Transfer_NewMarketQuery_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(TransferServer).NewMarketQuery(ctx, req.(*NewMarketQueryReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+func _Transfer_NewMarketDiscard_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(NewMarketDiscardReq)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(TransferServer).NewMarketDiscard(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: Transfer_NewMarketDiscard_FullMethodName,
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(TransferServer).NewMarketDiscard(ctx, req.(*NewMarketDiscardReq))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
 // Transfer_ServiceDesc is the grpc.ServiceDesc for Transfer service.
 // It's only intended for direct use with grpc.RegisterService,
 // and not to be introspected or modified (even as a copy)
@ -510,6 +624,18 @@ var Transfer_ServiceDesc = grpc.ServiceDesc{
 			MethodName: "rsCouponGrant",
 			Handler:    _Transfer_RsCouponGrant_Handler,
 		},
+		{
+			MethodName: "newMarketOrder",
+			Handler:    _Transfer_NewMarketOrder_Handler,
+		},
+		{
+			MethodName: "newMarketQuery",
+			Handler:    _Transfer_NewMarketQuery_Handler,
+		},
+		{
+			MethodName: "newMarketDiscard",
+			Handler:    _Transfer_NewMarketDiscard_Handler,
+		},
 	},
 	Streams:  []grpc.StreamDesc{},
 	Metadata: "transfer.proto",
--- a/untils/response/code.go
+++ b/untils/response/code.go
@ -1,13 +1,15 @@
 package response

 const (
-	HTTP_SUCCESS     = "000000"
-	HTTP_AUTH_FAIL   = "000101"
-	HTTP_REUEST_FAIL = "000102"
+	HTTP_SUCCESS          = "000000"
+	HTTP_AUTH_FAIL        = "000101"
+	HTTP_REUEST_FAIL      = "000102"
+	HTTP_REUEST_NOT_FOUND = "100030"
 )

 var CodeMsg = map[string]string{
-	HTTP_SUCCESS:     "操作成功",
-	HTTP_AUTH_FAIL:   "验签失败",
-	HTTP_REUEST_FAIL: "操作失败",
+	HTTP_SUCCESS:          "操作成功",
+	HTTP_AUTH_FAIL:        "验签失败",
+	HTTP_REUEST_FAIL:      "操作失败",
+	HTTP_REUEST_NOT_FOUND: "订单不存在",
 }