|
|
|
@@ -93,7 +93,7 @@ func (ntgJob *ntgVisionJob) JobInfo() (ntgVisionJobInfo, error) {
|
|
|
|
key := fmt.Sprintf("ntg_job_info_%v", ntgJob.ID)
|
|
|
|
key := fmt.Sprintf("ntg_job_info_%v", ntgJob.ID)
|
|
|
|
if b, err := db.Get(key); err != nil {
|
|
|
|
if b, err := db.Get(key); err != nil {
|
|
|
|
} else if err := json.Unmarshal(b, &ntgJob.jobinfo); err == nil {
|
|
|
|
} else if err := json.Unmarshal(b, &ntgJob.jobinfo); err == nil {
|
|
|
|
return ntgJob.jobinfo, fmt.Errorf("failed to parse ntg job info from db: %w: %s", err, b)
|
|
|
|
return ntgJob.jobinfo, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ntg := NewNTGVision()
|
|
|
|
ntg := NewNTGVision()
|
|
|
|
ji, err := ntg.SearchJob(ntgJob.ID)
|
|
|
|
ji, err := ntg.SearchJob(ntgJob.ID)
|
|
|
|
@@ -305,7 +305,7 @@ func (ntg NTGVision) _search(states []config.State) (io.ReadCloser, error) {
|
|
|
|
|
|
|
|
|
|
|
|
func (ntg NTGVision) newRequest(states []config.State) (*http.Request, error) {
|
|
|
|
func (ntg NTGVision) newRequest(states []config.State) (*http.Request, error) {
|
|
|
|
body, err := json.Marshal(map[string]interface{}{
|
|
|
|
body, err := json.Marshal(map[string]interface{}{
|
|
|
|
"OriginFromDate": time.Now().UTC().Format("2006-01-02T15:04:05.000Z"),
|
|
|
|
"OriginFromDate": time.Now().Add(time.Hour * -24).UTC().Format("2006-01-02T15:04:05.000Z"),
|
|
|
|
"OriginToDate": time.Now().UTC().Add(time.Hour * 24 * 30).Format("2006-01-02T15:04:05.000Z"),
|
|
|
|
"OriginToDate": time.Now().UTC().Add(time.Hour * 24 * 30).Format("2006-01-02T15:04:05.000Z"),
|
|
|
|
"DestinationFromDate": nil,
|
|
|
|
"DestinationFromDate": nil,
|
|
|
|
"DestinationToDate": nil,
|
|
|
|
"DestinationToDate": nil,
|
|
|
|
|