add_mkt_logic.go 2.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  1. package logic
  2. import (
  3. "context"
  4. "database/sql"
  5. "git.i2edu.net/i2/i2-bill-erp/internal/svc"
  6. "git.i2edu.net/i2/i2-bill-erp/internal/utils"
  7. "git.i2edu.net/i2/i2-bill-erp/model"
  8. "git.i2edu.net/i2/i2-bill-erp/transform"
  9. "git.i2edu.net/i2/go-zero/core/logx"
  10. "git.i2edu.net/i2/go-zero/core/stores/sqlc"
  11. )
  12. type AddMktLogic struct {
  13. ctx context.Context
  14. svcCtx *svc.ServiceContext
  15. logx.Logger
  16. }
  17. func NewAddMktLogic(ctx context.Context, svcCtx *svc.ServiceContext) *AddMktLogic {
  18. return &AddMktLogic{
  19. ctx: ctx,
  20. svcCtx: svcCtx,
  21. Logger: logx.WithContext(ctx),
  22. }
  23. }
  24. func (l *AddMktLogic) AddMkt(in *transform.MktReq) (*transform.MktRes, error) {
  25. old := model.MktResource{}
  26. err := l.svcCtx.SqlConn.QueryRowPartial(&old, "select id from mkt_resource where `stu_phone` = ? and del_flag!=1 limit 1", in.StuPhone)
  27. if err == sqlc.ErrNotFound {
  28. mkt := model.MktResource{}
  29. mkt.DelFlag = 0
  30. mkt.CreateBy = sql.NullString{String: in.MkId}
  31. mkt.CreateTime = sql.NullTime{Time: utils.ParseTime(in.CreateTime)}
  32. mkt.LastUpdateTime = sql.NullTime{Time: utils.ParseTime(in.CreateTime)}
  33. mkt.LastUpdateBy = sql.NullString{String: in.MkId}
  34. mkt.StuName = sql.NullString{String: in.StuName}
  35. mkt.StuLinkPerson = sql.NullString{String: in.StuLinkPerson}
  36. mkt.StuPhone = sql.NullString{String: in.StuPhone}
  37. mkt.SchId = sql.NullInt64{Int64: in.SchId}
  38. mkt.StuAddress = sql.NullString{String: in.Address}
  39. mkt.AgeGroup = sql.NullInt64{Int64: in.AgeGroup}
  40. mkt.StuType = 8
  41. mkt.NetworkDetail = sql.NullInt64{Int64: in.NetworkDetailId}
  42. mkt.CallType = sql.NullInt64{Int64: in.CallType}
  43. mkt.MaType = sql.NullInt64{Int64: in.MaType}
  44. mkt.QuaoYji = sql.NullInt64{Int64: in.QuaoYji}
  45. mkt.LoadUser = sql.NullString{String: in.MkId}
  46. _, err = l.svcCtx.MktResourceModel.Insert(mkt)
  47. if err != nil {
  48. l.Logger.Error(err)
  49. return &transform.MktRes{Status: 500}, nil
  50. }
  51. return &transform.MktRes{Status: 200}, nil
  52. }
  53. if old.Id != 0 {
  54. // 已经存在不处理
  55. return &transform.MktRes{Status: 201}, nil
  56. }
  57. return &transform.MktRes{Status: 500}, nil
  58. }