gogs
/
truckstop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

store jobinfo in db

master
Bel LaPointe 2022-01-14 08:38:11 -05:00
parent 800f14a355
commit 003388c847
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
broker/ntgvision.go
View File

@ -61,7 +61,7 @@ func (ji ntgVisionJobInfo) String() string {
return out return out
} }
return fmt.Sprintf( return fmt.Sprintf(
"%s Pickup:{Hours:%s Notes:%s, DropTrailer:%s} Dropoff:{Appointment:%s Notes:%s}", "%s Pickup:{Hours:%s Notes:%s, DropTrailer:%v} Dropoff:{Appointment:%s Notes:%s}",
out, out,
ji.StopsInfo[0].StopHours, ji.StopsInfo[0].StopHours,
ji.StopsInfo[0].Instructions, ji.StopsInfo[0].Instructions,
@ -78,6 +78,12 @@ func (ntgJob *ntgVisionJob) JobInfo() (ntgVisionJobInfo, error) {
if !ntgJob.jobinfo.IsZero() { if !ntgJob.jobinfo.IsZero() {
return ntgJob.jobinfo, nil return ntgJob.jobinfo, nil
} }
db := config.Get().DB()
key := fmt.Sprintf("ntg_job_info_%v", ntgJob.ID)
if b, err := db.Get(key); err != nil {
} else if err := json.Unmarshal(b, &ntgJob.jobinfo); err == nil {
return ntgJob.jobinfo, nil
}
ji, err := ntgJob.jobInfo() ji, err := ntgJob.jobInfo()
if err == ErrNoAuth { if err == ErrNoAuth {
if err := NewNTGVision().refreshAuth(); err != nil { if err := NewNTGVision().refreshAuth(); err != nil {
@ -85,7 +91,13 @@ func (ntgJob *ntgVisionJob) JobInfo() (ntgVisionJobInfo, error) {
} }
ji, err = ntgJob.jobInfo() ji, err = ntgJob.jobInfo()
} }
ntgJob.jobinfo = ji if err == nil {
ntgJob.jobinfo = ji
b, err := json.Marshal(ntgJob.jobinfo)
if err == nil {
db.Set(key, b)
}
}
return ji, err return ji, err
} }