gjs
38e040af07
CI / changes (push) Successful in 37s
CI / ad (push) Successful in 29s
CI / admin (push) Successful in 17s
CI / bff (push) Successful in 13s
CI / chore (push) Successful in 15s
CI / equipment (push) Successful in 14s
CI / express (push) Successful in 14s
CI / product (push) Successful in 13s
CI / record (push) Successful in 13s
CI / sale (push) Successful in 13s
CI / task (push) Successful in 13s
CI / user (push) Successful in 14s
CI / wecom (push) Successful in 13s
101 lines
3.0 KiB
Go
101 lines
3.0 KiB
Go
package logic
|
|
|
|
import (
|
|
"context"
|
|
"lone-services/pkg/modelbase"
|
|
"lone-services/pkg/utils"
|
|
"lone-services/pkg/validate"
|
|
"lone-services/services/express/internal/dao"
|
|
"lone-services/services/express/internal/model"
|
|
"strconv"
|
|
|
|
"lone-services/rpc/express/pb"
|
|
"lone-services/services/express/internal/svc"
|
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
)
|
|
|
|
type ExpressApiQueryLogic struct {
|
|
ctx context.Context
|
|
svcCtx *svc.ServiceContext
|
|
logx.Logger
|
|
BaseLogic
|
|
}
|
|
|
|
func NewExpressApiQueryLogic(ctx context.Context, svcCtx *svc.ServiceContext) *ExpressApiQueryLogic {
|
|
return &ExpressApiQueryLogic{
|
|
ctx: ctx,
|
|
svcCtx: svcCtx,
|
|
Logger: logx.WithContext(ctx),
|
|
}
|
|
}
|
|
|
|
func (l *ExpressApiQueryLogic) ExpressApiQuery(in *express.IdApiRequest) (*express.Response, error) {
|
|
var v validate.InfoValidator
|
|
if fail := l.checkParams(in, &v); fail != nil {
|
|
return fail, nil
|
|
}
|
|
adminInfo := utils.GetUserFromCtx(l.ctx)
|
|
if adminInfo.ID < utils.NumberOne {
|
|
return l.fail(utils.ErrorNoLoginInfo)
|
|
}
|
|
w := modelbase.Params{Eq: map[string]string{"id": strconv.Itoa(int(in.Id))}}
|
|
var upData dao.DeliveryOrderUpTransit
|
|
err := model.DeliveryOrderModel{}.Init().GetOne(w, &upData)
|
|
if err != nil {
|
|
l.Logger.Error("没有找到快递数据", err)
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "没有找到快递数据"))
|
|
}
|
|
if upData.Id < utils.NumberZero {
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "没有找到快递数据"))
|
|
}
|
|
|
|
if upData.Status != dao.SendStatusOk {
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "没有发货"))
|
|
}
|
|
|
|
orderInfo := svc.GetOrderInfo(upData.OrderSn, in.Type, l.svcCtx.OrderSvcName)
|
|
if orderInfo.Id < utils.NumberOne {
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "没有找到订单信息"))
|
|
}
|
|
|
|
tw := modelbase.Params{Eq: map[string]string{"id": strconv.Itoa(upData.TransitId)}}
|
|
var transitInfo dao.ExpressSend
|
|
err = model.ExpressModel{}.Init().GetOne(tw, &transitInfo)
|
|
if err != nil {
|
|
l.Logger.Error("发货地址信息没有找到", upData.TransitId, err)
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "没有找到发货的快递信息"))
|
|
}
|
|
if transitInfo.Id < utils.NumberOne {
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "没有找到发货的快递信息"))
|
|
}
|
|
|
|
client, clientErr := svc.GetTransitInfo(transitInfo)
|
|
if clientErr != utils.Ok {
|
|
return l.fail(clientErr)
|
|
}
|
|
sn := upData.OrderSn
|
|
if transitInfo.TransitId == dao.ExpressCompanyJd {
|
|
sn = upData.TransitSn
|
|
}
|
|
res, err := client.Query(sn)
|
|
if err != nil || res.ErrorCode != utils.StringStatusOk {
|
|
l.Logger.Error("query transit err", err, res)
|
|
return l.fail(utils.SetError(utils.ErrorNotFund, "获取快递错误"))
|
|
}
|
|
|
|
if transitInfo.TransitId == dao.ExpressCompanyJd {
|
|
items, s := svc.QueryJdEdit(res.RequestQuery, &upData, l.svcCtx.OrderSvcName)
|
|
if s != utils.Ok {
|
|
return l.fail(s)
|
|
}
|
|
return l.ok(items)
|
|
}
|
|
|
|
items, s := svc.QueryEdit(res.RequestQuery, &upData, l.svcCtx.OrderSvcName)
|
|
if s != utils.Ok {
|
|
return l.fail(s)
|
|
}
|
|
return l.ok(items)
|
|
}
|