diff --git a/internal/tools/zltx/excute_test.go b/internal/tools/zltx/excute_test.go new file mode 100644 index 0000000..3f8460d --- /dev/null +++ b/internal/tools/zltx/excute_test.go @@ -0,0 +1,19 @@ +package zltx + +import ( + config2 "ai_scheduler/internal/config" + "ai_scheduler/internal/entitys" + "context" + "testing" +) + +func Test_task(t *testing.T) { + c := NewZltxOrderDetailTool(config2.ToolConfig{}, nil) + err := + c.Execute(context.Background(), &entitys.Recognize{ + Match: &entitys.Match{ + Parameters: `{"order_number": 859393216068067329}`, + }, + }) + t.Log(err) +} diff --git a/internal/tools/zltx/zltx_order_detail.go b/internal/tools/zltx/zltx_order_detail.go index 235d40c..47574a3 100644 --- a/internal/tools/zltx/zltx_order_detail.go +++ b/internal/tools/zltx/zltx_order_detail.go @@ -98,11 +98,17 @@ func (w *ZltxOrderDetailTool) Execute(ctx context.Context, rec *entitys.Recogniz // getMockZltxOrderDetail 获取模拟直连天下订单详情数据 func (w *ZltxOrderDetailTool) getZltxOrderDetail(rec *entitys.Recognize, number interface{}) (err error) { - log.Infof("订单编号:%v", number) + log.Infof("订单编号:%v,类型:%v") + var orderNum string switch number.(type) { case int, int32, int64: - number = fmt.Sprintf("%d", number) + orderNum = fmt.Sprintf("%d", number) + case float64: + orderNum = fmt.Sprintf("%d", int(number.(float64))) + case string: + orderNum = number.(string) default: + orderNum = fmt.Sprintf("%v", number) } ext, err := rec_extra.GetTaskRecExt(rec) @@ -111,7 +117,7 @@ func (w *ZltxOrderDetailTool) getZltxOrderDetail(rec *entitys.Recognize, number } //查询订单详情 req := l_request.Request{ - Url: fmt.Sprintf(w.config.BaseURL, number), + Url: fmt.Sprintf(w.config.BaseURL, orderNum), Headers: map[string]string{ "Authorization": fmt.Sprintf("Bearer %s", ext.Auth), },