job.go 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. package orm
  2. import (
  3. "fmt"
  4. "net/http"
  5. "time"
  6. "github.com/jinzhu/gorm"
  7. "gogs.carduccidante.edu.it/karmen/core/renderer"
  8. )
  9. type Log struct {
  10. gorm.Model
  11. Content string
  12. JobID uint
  13. }
  14. type Job struct {
  15. gorm.Model
  16. Name string
  17. Document *Document
  18. Logs []*Log
  19. DocumentID uint
  20. Files []*File
  21. Start time.Time
  22. End time.Time
  23. }
  24. func (s *Job) GetID() uint { return s.ID }
  25. func (j *Job) String() string { return fmt.Sprintf("Lavoro ID %d", j.ID) }
  26. func (j *Job) Create(args map[string]string, r *http.Request) (interface{}, error) {
  27. return nil, fmt.Errorf("Not implemented")
  28. }
  29. func (j *Job) Read(args map[string]string, r *http.Request) (interface{}, error) {
  30. var job Job
  31. if err := DB().Preload("Document").Preload("Files").Preload("Logs").First(&job, args["id"]).Error; err != nil {
  32. return nil, err
  33. }
  34. return &job, nil
  35. }
  36. func (j *Job) ReadAll(args map[string]string, r *http.Request) (interface{}, error) {
  37. var jobs []*Job
  38. if err := DB().Preload("Document").Order("start DESC").Find(&jobs).Error; err != nil {
  39. return nil, err
  40. }
  41. return jobs, nil
  42. }
  43. func (j *Job) Update(args map[string]string, r *http.Request) (interface{}, error) {
  44. if r.Method == "GET" {
  45. result, err := j.Read(args, r)
  46. if err != nil {
  47. return nil, err
  48. }
  49. job := result.(*Job)
  50. return job, nil
  51. } else {
  52. job, err := j.Read(args, r)
  53. if err != nil {
  54. return nil, err
  55. }
  56. err = renderer.Decode(job, r)
  57. if err != nil {
  58. return nil, err
  59. }
  60. _, err = SaveJob(job)
  61. if err != nil {
  62. return nil, err
  63. }
  64. job, err = j.Read(args, r)
  65. if err != nil {
  66. return nil, err
  67. }
  68. return job.(*Job), nil
  69. }
  70. }
  71. func (j *Job) Delete(args map[string]string, r *http.Request) (interface{}, error) {
  72. job, err := j.Read(args, r)
  73. if err != nil {
  74. return nil, err
  75. }
  76. if err := DB().Unscoped().Delete(job.(*Job)).Error; err != nil {
  77. return nil, err
  78. }
  79. return job.(*Job), nil
  80. }
  81. func SaveJob(job interface{}) (interface{}, error) {
  82. if err := DB().Save(job).Error; err != nil {
  83. return nil, err
  84. }
  85. return job, nil
  86. }