get_employee_detail_logic.go 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138
  1. package employee
  2. import (
  3. "context"
  4. "github.com/suyuan32/simple-admin-common/msg/errormsg"
  5. "github.com/suyuan32/simple-admin-common/utils/pointy"
  6. "wechat-api/ent/employee"
  7. "wechat-api/ent/employeeconfig"
  8. "wechat-api/internal/utils/dberrorhandler"
  9. "wechat-api/internal/svc"
  10. "wechat-api/internal/types"
  11. "github.com/zeromicro/go-zero/core/logx"
  12. )
  13. type GetEmployeeDetailLogic struct {
  14. logx.Logger
  15. ctx context.Context
  16. svcCtx *svc.ServiceContext
  17. }
  18. func NewGetEmployeeDetailLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GetEmployeeDetailLogic {
  19. return &GetEmployeeDetailLogic{
  20. Logger: logx.WithContext(ctx),
  21. ctx: ctx,
  22. svcCtx: svcCtx}
  23. }
  24. func (l *GetEmployeeDetailLogic) GetEmployeeDetail(req *types.IDReq) (*types.EmployeeInfoResp, error) {
  25. //organizationId := l.ctx.Value("organizationId").(uint64)
  26. data, err := l.svcCtx.DB.Employee.Query().WithEmWorkExperiences().WithEmTutorial().Where(employee.ID(req.Id)).Only(l.ctx)
  27. if err != nil {
  28. return nil, dberrorhandler.DefaultEntError(l.Logger, err, req)
  29. }
  30. workExperience := make([]types.WorkExperienceInfo, 0, len(data.Edges.EmWorkExperiences))
  31. for _, work := range data.Edges.EmWorkExperiences {
  32. workExperience = append(workExperience, types.WorkExperienceInfo{
  33. BaseIDInfo: types.BaseIDInfo{
  34. Id: &work.ID,
  35. CreatedAt: pointy.GetPointer(work.CreatedAt.UnixMilli()),
  36. UpdatedAt: pointy.GetPointer(work.UpdatedAt.UnixMilli()),
  37. },
  38. EmployeeId: &work.EmployeeID,
  39. Company: &work.Company,
  40. StartDate: pointy.GetPointer(work.StartDate.UnixMilli()),
  41. StartDateStr: pointy.GetPointer(work.StartDate.Format("2006-01-02 15:04:05")),
  42. EndDate: pointy.GetPointer(work.EndDate.UnixMilli()),
  43. EndDateStr: pointy.GetPointer(work.EndDate.Format("2006-01-02 15:04:05")),
  44. Experience: &work.Experience,
  45. })
  46. }
  47. tutorial := make([]types.TutorialInfo, 0, len(data.Edges.EmTutorial))
  48. for _, tt := range data.Edges.EmTutorial {
  49. tutorial = append(tutorial, types.TutorialInfo{
  50. BaseIDInfo: types.BaseIDInfo{
  51. Id: &tt.ID,
  52. CreatedAt: pointy.GetPointer(tt.CreatedAt.UnixMilli()),
  53. UpdatedAt: pointy.GetPointer(tt.UpdatedAt.UnixMilli()),
  54. },
  55. EmployeeId: &tt.EmployeeID,
  56. Content: &tt.Content,
  57. Title: &tt.Title,
  58. Index: &tt.Index,
  59. })
  60. }
  61. // 分别获得 scene 和 switch_in 的列表
  62. sceneList := getEmployeeDetail(l, data.Scene)
  63. switchInList := getEmployeeDetail(l, data.SwitchIn)
  64. return &types.EmployeeInfoResp{
  65. BaseDataInfo: types.BaseDataInfo{
  66. Code: 0,
  67. Msg: errormsg.Success,
  68. },
  69. Data: types.EmployeeInfo{
  70. BaseIDInfo: types.BaseIDInfo{
  71. Id: &data.ID,
  72. CreatedAt: pointy.GetPointer(data.CreatedAt.UnixMilli()),
  73. UpdatedAt: pointy.GetPointer(data.UpdatedAt.UnixMilli()),
  74. },
  75. Title: &data.Title,
  76. Avatar: &data.Avatar,
  77. Tags: &data.Tags,
  78. HireCount: &data.HireCount,
  79. ServiceCount: &data.ServiceCount,
  80. AchievementCount: &data.AchievementCount,
  81. Intro: &data.Intro,
  82. Estimate: &data.Estimate,
  83. Skill: &data.Skill,
  84. AbilityType: &data.AbilityType,
  85. Scene: &data.Scene,
  86. SceneList: sceneList,
  87. Tutorial: tutorial,
  88. SwitchIn: &data.SwitchIn,
  89. SwitchInList: switchInList,
  90. VideoUrl: &data.VideoURL,
  91. WorkExperience: workExperience,
  92. CategoryId: &data.CategoryID,
  93. ChatUrl: &data.ChatURL,
  94. },
  95. }, nil
  96. }
  97. func getEmployeeDetail(l *GetEmployeeDetailLogic, ids string) []types.EmployeeConfigInfo {
  98. sceneList := make([]types.EmployeeConfigInfo, 0)
  99. sceneIds := FormatIds(ids)
  100. if len(sceneIds) == 0 {
  101. return sceneList
  102. }
  103. employeeConfigList, err := l.svcCtx.DB.EmployeeConfig.Query().Where(
  104. employeeconfig.IDIn(sceneIds...),
  105. ).All(l.ctx)
  106. if err == nil && len(employeeConfigList) > 0 {
  107. for _, val := range employeeConfigList {
  108. sceneList = append(sceneList, types.EmployeeConfigInfo{
  109. BaseIDInfo: types.BaseIDInfo{
  110. Id: &val.ID,
  111. CreatedAt: pointy.GetPointer(val.CreatedAt.UnixMilli()),
  112. UpdatedAt: pointy.GetPointer(val.UpdatedAt.UnixMilli()),
  113. },
  114. Stype: &val.Stype,
  115. Title: &val.Title,
  116. Photo: &val.Photo,
  117. })
  118. }
  119. }
  120. return sceneList
  121. }