script.go 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. package service
  2. import (
  3. "context"
  4. "fmt"
  5. "strings"
  6. "youngee_b_api/db"
  7. "youngee_b_api/model/gorm_model"
  8. "youngee_b_api/model/http_model"
  9. "github.com/sirupsen/logrus"
  10. )
  11. var Script *script
  12. type script struct {
  13. }
  14. // ScriptOpinion 在上传脚本表上提交修改意见
  15. func (*script) ScriptOpinion(ctx context.Context, request http_model.ScriptOpinionRequest) (*http_model.ScriptOpinionData, error) {
  16. Script := gorm_model.YounggeeScriptInfo{
  17. TaskID: request.TaskID,
  18. ReviseOpinion: request.ScriptOpinion,
  19. }
  20. err := db.ScriptOpinion(ctx, Script.TaskID, Script.ReviseOpinion)
  21. if err != nil {
  22. logrus.WithContext(ctx).Errorf("[Script service] call CreateScript error,err:%+v", err)
  23. return nil, err
  24. }
  25. // 记录任务日志
  26. err = db.CreateTaskLog(ctx, Script.TaskID, "脚本驳回")
  27. if err != nil {
  28. logrus.WithContext(ctx).Errorf("[Script service] call CreateTaskLog error,err:%+v", err)
  29. return nil, err
  30. }
  31. err = db.CreateMessageByTaskId(ctx, 16, 3, Script.TaskID)
  32. if err != nil {
  33. logrus.WithContext(ctx).Errorf("[Script service] call CreateMessageByTaskId error,err:%+v", err)
  34. return nil, err
  35. }
  36. res := &http_model.ScriptOpinionData{
  37. TaskID: Script.TaskID,
  38. }
  39. return res, nil
  40. }
  41. // AcceptScript
  42. func (*script) AcceptScript(ctx context.Context, request http_model.AcceptScriptRequest) (*http_model.AcceptScriptData, error) {
  43. var TaskIDList []string
  44. TaskIDs := strings.Split(request.TaskIds, ",")
  45. for _, taskId := range TaskIDs {
  46. TaskIDList = append(TaskIDList, taskId)
  47. }
  48. fmt.Printf("acc request %+v", TaskIDList)
  49. err := db.AcceptScript(ctx, TaskIDList)
  50. if err != nil {
  51. logrus.WithContext(ctx).Errorf("[Script service] call CreateScript error,err:%+v", err)
  52. return nil, err
  53. }
  54. // 记录任务日志
  55. for _, taskId := range TaskIDList {
  56. err = db.CreateTaskLog(ctx, taskId, "脚本通过")
  57. if err != nil {
  58. logrus.WithContext(ctx).Errorf("[Script service] call CreateTaskLog error,err:%+v", err)
  59. return nil, err
  60. }
  61. err = db.CreateMessageByTaskId(ctx, 2, 1, taskId)
  62. if err != nil {
  63. logrus.WithContext(ctx).Errorf("[Script service] call CreateTaskLog error,err:%+v", err)
  64. return nil, err
  65. }
  66. }
  67. res := &http_model.AcceptScriptData{
  68. TaskIds: TaskIDList,
  69. }
  70. return res, nil
  71. }