reservation.go 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663
  1. package reservation
  2. import (
  3. "context"
  4. "database/sql"
  5. "errors"
  6. "fmt"
  7. "lims_adapter/common"
  8. meeting2 "lims_adapter/dao/meeting"
  9. "lims_adapter/model"
  10. meeting3 "lims_adapter/model/meeting"
  11. "lims_adapter/service"
  12. "lims_adapter/service/meeting"
  13. "lims_adapter/service/srv"
  14. "strconv"
  15. "strings"
  16. "time"
  17. "dashoo.cn/common_definition/admin/user_def"
  18. "dashoo.cn/micro_libary/micro_srv"
  19. "dashoo.cn/micro_libary/myerrors"
  20. "dashoo.cn/micro_libary/request"
  21. "github.com/gogf/gf/frame/g"
  22. "github.com/gogf/gf/os/gtime"
  23. "github.com/gogf/gf/util/gconv"
  24. )
  25. // Service ReservationService 预约
  26. type Service struct {
  27. Dao *meeting2.MeetingReservationDao
  28. Tenant string
  29. }
  30. // NewSrv 服务初始化
  31. func NewSrv(tenant string) Service {
  32. return Service{Dao: meeting2.NewMeetingReservationDao(tenant), Tenant: tenant}
  33. }
  34. // List 预约列表
  35. func (s Service) List(req model.ListReq, userInfo request.UserInfo) ([]meeting3.List, int, error) {
  36. entityModel := s.Dao.M
  37. if req.Entity != nil {
  38. entity := new(meeting3.ReservationReq)
  39. gconv.Struct(req.Entity, entity)
  40. tableSql := s.Dao.Table + "."
  41. if entity.Title != "" {
  42. entityModel = entityModel.WhereLike(tableSql+s.Dao.Columns.Title, "%"+entity.Title+"%")
  43. }
  44. if entity.EntityId != 0 {
  45. entityModel = entityModel.Where(tableSql+s.Dao.Columns.EntityId, entity.EntityId)
  46. }
  47. if entity.UserName != "" {
  48. entityModel = entityModel.WhereLike(tableSql+s.Dao.Columns.UserName, "%"+entity.UserName+"%")
  49. }
  50. if entity.Mine {
  51. entityModel = entityModel.Where(tableSql+s.Dao.Columns.UserId, userInfo.Id)
  52. }
  53. // 预约状态(1:预定 2:取消)
  54. if entity.Status != 0 {
  55. entityModel = entityModel.Where(tableSql+s.Dao.Columns.Status, entity.Status)
  56. }
  57. // 预约时间
  58. if len(entity.TimeSplit) == 2 {
  59. entityModel = entityModel.WhereBetween(tableSql+s.Dao.Columns.StartTime, entity.TimeSplit[0], entity.TimeSplit[1])
  60. }
  61. }
  62. total, err := entityModel.Count()
  63. if err != nil {
  64. return nil, 0, err
  65. }
  66. if total == 0 {
  67. return nil, 0, nil
  68. }
  69. if req.Value != "" {
  70. entityModel = entityModel.Order(s.Dao.Table+"."+common.Snake2Orm(meeting3.MeetingReservation{}, req.Value), req.Type)
  71. } else {
  72. entityModel = entityModel.Order(s.Dao.Table+"."+s.Dao.Columns.CreatedAt, "DESC")
  73. }
  74. res, err := entityModel.Page(req.Current, req.Size).
  75. Fields("meeting_reservation.*", "meeting.Name", "base_user.DepartmentName").
  76. LeftJoin("meeting", "meeting.Id = meeting_reservation.EntityId").
  77. LeftJoin("base_user", "base_user.Id = meeting_reservation.UserId").
  78. FindAll()
  79. if err != nil {
  80. return nil, 0, err
  81. }
  82. if res.IsEmpty() {
  83. return nil, 0, nil
  84. }
  85. list := make([]meeting3.List, 0)
  86. res.Structs(&list)
  87. return list, total, nil
  88. }
  89. // Add 添加预约
  90. func (s Service) Add(userInfo request.UserInfo, req meeting3.ReservationReq) error {
  91. entity := new(meeting3.MeetingReservation)
  92. err := s.check(req)
  93. if err != nil {
  94. return err
  95. }
  96. gconv.Struct(req, entity)
  97. service.SetCreate(&userInfo, entity)
  98. entity.UserName = userInfo.RealName
  99. entity.UserId = int(userInfo.Id)
  100. entity.DepartmentId = gconv.Int(userInfo.DeptId)
  101. entity.RealEndTimeNode = req.EndTime
  102. res, err := s.Dao.M.Insert(entity)
  103. if err != nil {
  104. return err
  105. }
  106. id, _ := res.LastInsertId()
  107. // 延迟消息
  108. go AutoProcess(int(id), s.Tenant, req.EndTime.Sub(gtime.Now()))
  109. return nil
  110. }
  111. const PermissionCancelAnyMeetingReservation = "meeting:cancel:any"
  112. // Cancel 取消预约 预约状态(1:预定 2:取消)
  113. func (s Service) Cancel(userInfo request.UserInfo, id int) error {
  114. // 判断当前用户是否是预约人
  115. entity, err := s.Dao.WherePri(id).FindOne()
  116. if err != nil {
  117. return err
  118. }
  119. if entity == nil {
  120. return errors.New("未找到当前预约信息,请重试")
  121. }
  122. allow, err := common.Allow(s.Tenant, userInfo.Uuid, PermissionCancelAnyMeetingReservation)
  123. if err != nil {
  124. return err
  125. }
  126. if allow {
  127. updatedMap := service.SetUpdatedMap(&userInfo)
  128. updatedMap["Status"] = 2
  129. _, err = s.Dao.M.Data(updatedMap).WherePri(id).Update()
  130. if err != nil {
  131. return err
  132. }
  133. return nil
  134. }
  135. if int32(entity.UserId) != userInfo.Id {
  136. return errors.New("当前预约只能由预约人取消")
  137. }
  138. if entity.StartTime.Sub(gtime.Now()) <= 0 {
  139. return errors.New("预约开始不允许取消")
  140. }
  141. updatedMap := service.SetUpdatedMap(&userInfo)
  142. updatedMap["Status"] = 2
  143. _, err = s.Dao.M.Data(updatedMap).WherePri(id).Update()
  144. if err != nil {
  145. return err
  146. }
  147. return nil
  148. }
  149. // OverviewList 预约概况
  150. func (s Service) OverviewList(req meeting3.OverviewReq) (g.Map, error) {
  151. dates := getCurrentWeekDay(req.Date)
  152. meetingList, err := meeting.NewSrv(s.Tenant).ShortList()
  153. if err != nil {
  154. return nil, err
  155. }
  156. reservationList, err := s.shortList(req.Date)
  157. if err != nil {
  158. return nil, err
  159. }
  160. return g.Map{
  161. "dates": dates,
  162. "meeting": meetingList,
  163. "reservation": reservationList,
  164. }, nil
  165. }
  166. func (s Service) AppointTimeSplit() int {
  167. return g.Cfg().GetInt("reservation.time_split", 30)
  168. }
  169. type AppointTimeInfoAppoint struct {
  170. Id int `json:"id"`
  171. Title string `json:"title"`
  172. Start string `json:"start"`
  173. End string `json:"end"`
  174. Status int `json:"status"`
  175. Uid int `json:"uid"`
  176. Uname string `json:"uname"`
  177. Tel string `json:"tel"`
  178. Dept string `json:"dept"`
  179. }
  180. type AppointTimeInfoInstrument struct {
  181. Id int
  182. Weekday string
  183. BeginAt *gtime.Time
  184. EndAt *gtime.Time
  185. IsAppointAvailable int // 是否默认可预约 1是 2否
  186. }
  187. type TimeSpan struct {
  188. Start *gtime.Time `json:"start"`
  189. End *gtime.Time `json:"end"`
  190. }
  191. // 获取指定仪器预约信息
  192. func (s Service) AppointTimeInfo(req *meeting3.AppointTimeInfoReq, userinfo request.UserInfo) (map[string]interface{}, error) {
  193. if req.MeetingId == 0 {
  194. return nil, myerrors.NewMsgError(nil, "会议室 Id 不能为空")
  195. }
  196. if req.Date == nil {
  197. return nil, myerrors.NewMsgError(nil, "日期不能为空")
  198. }
  199. timesplit := s.AppointTimeSplit()
  200. days := common.Weekday(req.Date.Time)
  201. mettingSrv := meeting.NewSrv(s.Tenant)
  202. m, err := mettingSrv.Dao.Where("Id = ?", req.MeetingId).One()
  203. if err != nil {
  204. return nil, err
  205. }
  206. var appointInfo []AppointTimeInfoAppoint
  207. err = s.Dao.DB.Table("meeting_reservation a").LeftJoin("base_user b", "a.UserId=b.Id").Unscoped().
  208. Where("a.DeletedAt IS NULL").
  209. Where("a.EntityId", req.MeetingId).
  210. WherePri("a.Status", 1).
  211. Where("a.EndTime > ?", days[0]).
  212. Where("a.EndTime <= ?", days[6].Add(time.Hour*24)).
  213. Fields("a.Id, a.Title, a.StartTime as Start, a.EndTime as End, a.Status, a.UserId as Uid, b.Realname as Uname, b.Mobile as Tel, b.DepartmentName as Dept").
  214. Structs(&appointInfo)
  215. if err == sql.ErrNoRows {
  216. err = nil
  217. }
  218. if err != nil {
  219. return nil, err
  220. }
  221. reservationBeginStr := g.Cfg().GetString("reservation.begin", 30)
  222. reservationEndStr := g.Cfg().GetString("reservation.end", 30)
  223. reservationWeekdayStr := g.Cfg().GetString("reservation.weekday", 30)
  224. instrWeekStr := strings.Split(reservationWeekdayStr, ",")
  225. instrWeek := []int{}
  226. for _, i := range instrWeekStr {
  227. d, err := strconv.Atoi(i)
  228. if err != nil {
  229. continue
  230. }
  231. instrWeek = append(instrWeek, d)
  232. }
  233. toRemoveDay := []int{}
  234. for i := 1; i <= 7; i++ {
  235. if !common.SliceIntcontains(instrWeek, i) {
  236. toRemoveDay = append(toRemoveDay, i)
  237. }
  238. }
  239. reservationBegin, err := time.Parse("15:04:05", reservationBeginStr)
  240. if err != nil {
  241. return nil, err
  242. }
  243. reservationEnd, err := time.Parse("15:04:05", reservationEndStr)
  244. if err != nil {
  245. return nil, err
  246. }
  247. if m.BeginAt == nil {
  248. m.BeginAt = gtime.NewFromTime(reservationBegin)
  249. }
  250. if m.EndAt == nil {
  251. m.EndAt = gtime.NewFromTime(reservationEnd)
  252. }
  253. unavailable := []TimeSpan{}
  254. // 仪器设置的可预约范围外
  255. for i, d := range days {
  256. if common.SliceIntcontains(toRemoveDay, i+1) {
  257. unavailable = append(unavailable, TimeSpan{
  258. Start: gtime.NewFromTime(d),
  259. End: gtime.NewFromTime(d.Add(24 * time.Hour)),
  260. })
  261. continue
  262. }
  263. if m.BeginAt.Hour() != 0 || m.BeginAt.Minute() != 0 {
  264. end := d.Add(
  265. time.Hour*time.Duration(m.BeginAt.Hour()) +
  266. time.Minute*time.Duration(m.BeginAt.Minute()))
  267. unavailable = append(unavailable, TimeSpan{
  268. Start: gtime.NewFromTime(d),
  269. End: gtime.NewFromTime(end),
  270. })
  271. }
  272. endat := m.EndAt.Add(time.Minute * time.Duration(timesplit))
  273. if endat.Hour() != 0 || endat.Minute() != 0 {
  274. start := d.Add(
  275. time.Hour*time.Duration(endat.Hour()) +
  276. time.Minute*time.Duration(endat.Minute()))
  277. unavailable = append(unavailable, TimeSpan{
  278. Start: gtime.NewFromTime(start),
  279. End: gtime.NewFromTime(d.Add(time.Hour * 24)),
  280. })
  281. }
  282. }
  283. return map[string]interface{}{
  284. "begin_at": m.BeginAt.Time.Format("15:04:05"),
  285. "ent_at": m.EndAt.Time.Format("15:04:05"),
  286. "time_split": timesplit,
  287. "unavailable": unavailable,
  288. "appoint": appointInfo,
  289. }, nil
  290. }
  291. // OverviewListByDay 按天预约概况
  292. func (s Service) OverviewListByDay(ctx context.Context, req meeting3.OverviewReq) (g.Map, error) {
  293. beginAt := g.Cfg().GetString("reservation.begin")
  294. endAt := g.Cfg().GetString("reservation.end")
  295. defaultPeriod := s.getCurrentPeriod(beginAt, endAt)
  296. dates := getCurrentWeekDay(req.Date)
  297. meetingList, err := meeting.NewSrv(s.Tenant).ShortList()
  298. if err != nil {
  299. return nil, err
  300. }
  301. reservationList, err := s.getCurrentDayReservation(ctx, meetingList, req.Date)
  302. if err != nil {
  303. return nil, err
  304. }
  305. // for i := range meetingList {
  306. // begin, end := beginAt, endAt
  307. // if meetingList[i].BeginAt != nil && meetingList[i].EndAt != nil {
  308. // begin = meetingList[i].BeginAt.Time.Format("15:04:05")
  309. // end = meetingList[i].EndAt.Time.Format("15:04:05")
  310. // }
  311. // fmt.Println(meetingList[i].Id, meetingList[i].Name)
  312. // period := s.getCurrentPeriod(begin, end)
  313. // meetingList[i].Period = period
  314. // }
  315. return g.Map{
  316. "period": defaultPeriod,
  317. "dates": dates,
  318. "meeting": meetingList,
  319. "reservation": reservationList,
  320. }, nil
  321. }
  322. // ReserveInfo 预约信息
  323. func (s Service) ReserveInfo(ctx context.Context, req meeting3.ReserveReq) (g.Map, error) {
  324. // 常规信息
  325. beginAt := g.Cfg().GetString("reservation.begin_at")
  326. endAt := g.Cfg().GetString("reservation.end_at")
  327. period := s.getCurrentPeriod(beginAt, endAt)
  328. dates := getCurrentWeekDay(req.Date)
  329. weekday := g.Cfg().GetString("reservation.weekday")
  330. // 预约信息
  331. list, err := s.getCurrentWeekReservation(ctx, req)
  332. if err != nil {
  333. return nil, err
  334. }
  335. return g.Map{
  336. "period": period,
  337. "dates": dates,
  338. "weekday": weekday,
  339. "reservation": list,
  340. }, nil
  341. }
  342. // Ending 结束会议
  343. func (s Service) Ending(ctx context.Context, req meeting3.EndingReq) error {
  344. // 先查询预约记录
  345. entity, err := s.Dao.WherePri(req.Id).FindOne()
  346. if err != nil {
  347. return err
  348. }
  349. if entity == nil {
  350. return errors.New("未找到当前预约信息")
  351. }
  352. if entity.SignOutTime.String() != "" {
  353. return errors.New("当前预约已提前结束")
  354. }
  355. // 校验日期是不是同一天(24:00除外) 校验日期是不是在预约开始时间之后
  356. if req.Date.Sub(entity.StartTime) <= 0 {
  357. return errors.New("结束时间不能早于会议预约时间")
  358. }
  359. if req.Date.Format("Y-m-d") != entity.StartTime.Format("Y-m-d") &&
  360. req.Date.Hour() != 0 && req.Date.Minute() != 0 {
  361. return errors.New("结束时间必须为当天时间")
  362. }
  363. if (req.Date.Day()-1) != entity.StartTime.Day() && req.Date.Hour() == 0 && req.Date.Minute() == 0 {
  364. return errors.New("当前结束时间错误,请重试")
  365. }
  366. if req.Date.Sub(entity.EndTime) > 0 {
  367. return errors.New("预约时间正常结束的会议无需再次结束")
  368. }
  369. userInfo, err := micro_srv.GetUserInfo(ctx)
  370. if err != nil {
  371. return err
  372. }
  373. if userInfo.Id != int32(entity.UserId) {
  374. return errors.New("当前预约只能由本人结束")
  375. }
  376. // 更新实际结束时间
  377. updatedMap := service.SetUpdatedMap(&userInfo)
  378. updatedMap[s.Dao.Columns.SignOutTime] = req.Date
  379. updatedMap[s.Dao.Columns.RealEndTimeNode] = common.GetNextTimeNode(req.Date)
  380. _, err = s.Dao.M.WherePri(req.Id).Update(updatedMap)
  381. if err != nil {
  382. return err
  383. }
  384. return nil
  385. }
  386. func (s Service) AutoEnding(id int) error {
  387. entity, err := s.Dao.WherePri(id).FindOne()
  388. if err != nil {
  389. return err
  390. }
  391. if entity == nil {
  392. return nil
  393. }
  394. if entity.SignOutTime != nil && entity.SignOutTime.String() != "" {
  395. return nil
  396. }
  397. _, err = s.Dao.WherePri(id).Update(g.Map{s.Dao.Columns.SignOutTime: entity.EndTime})
  398. if err != nil {
  399. return err
  400. }
  401. return nil
  402. }
  403. // Check 预约校验
  404. func (s Service) check(req meeting3.ReservationReq) error {
  405. // 校验开始结束时间不能跨天
  406. if req.StartTime.Format("Y-m-d") != req.EndTime.Format("Y-m-d") &&
  407. req.EndTime.Hour() != 0 && req.EndTime.Minute() != 0 {
  408. return errors.New("预约时间必须是同一天")
  409. }
  410. // 校验开始时间是否小于结束时间
  411. if req.EndTime.Sub(req.StartTime) <= 0 {
  412. return errors.New("预约结束时候必须大于开始时间")
  413. }
  414. // // 时间间隔不能小于30分钟 todo:可以加到配置参数中
  415. // if req.EndTime.Sub(req.StartTime).Minutes() < 30 {
  416. // return errors.New("预约时间最小为30分钟")
  417. // }
  418. // 校验是否是过期时间
  419. if req.StartTime.Sub(gtime.Now()) < 0 {
  420. return errors.New("当前预约时间已过期")
  421. }
  422. // 校验时间内是否有 预约
  423. entityModel := s.Dao.M.
  424. Where(s.Dao.Columns.EntityId, req.EntityId).
  425. Where(s.Dao.Columns.Status, 1).
  426. Where(s.Dao.Columns.StartTime+">= ? AND "+s.Dao.Columns.StartTime+"< ?", req.StartTime, req.EndTime)
  427. entityModel = entityModel.
  428. WhereOr(s.Dao.Columns.EntityId+"= ? AND "+s.Dao.Columns.Status+" = 1 AND "+
  429. s.Dao.Columns.RealEndTimeNode+"> ? AND "+s.Dao.Columns.RealEndTimeNode+"<= ?",
  430. req.EntityId, req.StartTime, req.EndTime)
  431. entityModel = entityModel.
  432. WhereOr(s.Dao.Columns.EntityId+"= ? AND "+s.Dao.Columns.Status+" = 1 AND "+
  433. s.Dao.Columns.RealEndTimeNode+">= ? AND "+s.Dao.Columns.StartTime+"<= ?",
  434. req.EntityId, req.EndTime, req.StartTime)
  435. exist, err := entityModel.Count()
  436. if err != nil {
  437. return err
  438. }
  439. if exist > 0 {
  440. return errors.New("当前时间段内已有预约记录,请刷新后重试")
  441. }
  442. // 校验会议室是否存在
  443. err = meeting.NewSrv(s.Tenant).Exists(req.EntityId)
  444. if err != nil {
  445. return err
  446. }
  447. return nil
  448. }
  449. // getCurrentWeekDay 返回当前日期的周信息
  450. func getCurrentWeekDay(current *gtime.Time) []meeting3.CurrentDate {
  451. startOfWeek := common.GetCNStartOfWeek(current)
  452. dates := make([]meeting3.CurrentDate, 0)
  453. for i := 0; i <= 6; i++ {
  454. times := startOfWeek.AddDate(0, 0, 1*i)
  455. dates = append(dates, meeting3.CurrentDate{
  456. Date: times.Format("Y-m-d"),
  457. Day: times.Day(),
  458. })
  459. }
  460. return dates
  461. }
  462. func (s Service) shortList(date *gtime.Time) ([]meeting3.ShortList, error) {
  463. sTime := common.GetCNStartOfWeek(date)
  464. eTime := common.GetCNEndOfWeek(date)
  465. list := make([]meeting3.ShortList, 0)
  466. res, err := s.Dao.M.WhereBetween(s.Dao.Columns.StartTime, sTime, eTime).
  467. Where(s.Dao.Columns.Status, 1).FindAll()
  468. if err != nil {
  469. return nil, err
  470. }
  471. if res.IsEmpty() {
  472. return nil, nil
  473. }
  474. res.Structs(&list)
  475. for k, _ := range list {
  476. // 当签退时间小于预约结束时间,使用签退时间
  477. if list[k].SignOutTime.String() != "" && list[k].EndTime.Sub(list[k].SignOutTime) > 0 {
  478. list[k].EndTime = common.GetNextTimeNode(list[k].SignOutTime)
  479. }
  480. }
  481. return list, nil
  482. }
  483. // getCurrentDayTimeQuantum 获取当前的时间段
  484. func (s Service) getCurrentPeriod(entityBeginAt, entityEndAt string) [][]string {
  485. now := gtime.Now()
  486. startTime, _ := gtime.StrToTime(entityBeginAt)
  487. //endTime, _ := gtime.StrToTime(entityEndAt)
  488. startAtStr := fmt.Sprintf("%v-%.2v-%.2v %.2v:%.2v:%.2v",
  489. now.Year(), int(now.Month()), now.Day(),
  490. startTime.Hour(), startTime.Minute(), startTime.Second())
  491. startAt, _ := gtime.StrToTime(startAtStr)
  492. endAtStr := fmt.Sprintf("%v-%.2v-%.2v %s",
  493. now.Year(), int(now.Month()), now.Day(), entityEndAt)
  494. endAt, _ := gtime.StrToTime(endAtStr)
  495. timeLong := endAt.Sub(startAt).Hours()
  496. grids := int(timeLong * 2)
  497. fmt.Println(startAt, endAt)
  498. var timeQuantum [][]string
  499. for i := 0; i < grids; i++ {
  500. times := make([]string, 0)
  501. timeSplit := g.Cfg().GetInt("reservation.time_split")
  502. // 开始时间
  503. startAt := startAt.Add(time.Duration(i*timeSplit) * time.Minute)
  504. startTime := startAt.Format("H:i")
  505. // 结束时间
  506. endAt := startAt.Add(time.Duration(timeSplit) * time.Minute).Format("H:i")
  507. if startAt.Hour() == 23 && startAt.Minute() == 30 {
  508. endAt = "24:00"
  509. }
  510. times = append(times, startTime, endAt)
  511. timeQuantum = append(timeQuantum, times)
  512. }
  513. return timeQuantum
  514. }
  515. // getCurrentWeekReservation 返回本周预约信息
  516. func (s Service) getCurrentWeekReservation(ctx context.Context, req meeting3.ReserveReq) ([]meeting3.ReservationList, error) {
  517. // 获取符合条件的预约信息
  518. list, err := s.Dao.Where(s.Dao.Columns.EntityId, req.EntityId).
  519. Where(s.Dao.Columns.Status, 1).
  520. Where(s.Dao.Columns.StartTime+">=", common.GetCNStartOfWeek(req.Date)).
  521. Where(s.Dao.Columns.StartTime+"<=", common.GetCNEndOfWeek(req.Date)).
  522. FindAll()
  523. if err != nil {
  524. return nil, err
  525. }
  526. if len(list) == 0 {
  527. return nil, nil
  528. }
  529. uIds := make([]int64, 0)
  530. uMap := make(map[int]struct{})
  531. for _, v := range list {
  532. if _, ok := uMap[v.UserId]; !ok {
  533. uIds = append(uIds, int64(v.UserId))
  534. uMap[v.UserId] = struct{}{}
  535. }
  536. }
  537. // 获取用户信息
  538. userList, err := srv.GetUserList(ctx, uIds, s.Tenant)
  539. usersMap := make(map[int]user_def.UserInfoList)
  540. for _, v := range userList {
  541. usersMap[v.Id] = v
  542. }
  543. resultList := make([]meeting3.ReservationList, 0)
  544. for _, v := range list {
  545. timeLong := v.EndTime.Sub(v.StartTime).Hours()
  546. if v.SignOutTime.String() != "" && v.EndTime.Sub(v.SignOutTime) > 0 {
  547. timeLong = common.GetNextTimeNode(v.SignOutTime).Sub(v.StartTime).Hours()
  548. }
  549. grid := timeLong * 2
  550. for i := 0; i < int(grid); i++ {
  551. startAt := v.StartTime.Add(time.Duration(i) * 30 * time.Minute)
  552. resultList = append(resultList, meeting3.ReservationList{
  553. ReservationId: int(v.Id),
  554. Day: v.StartTime.Day(),
  555. Dept: usersMap[v.UserId].DepartmentName,
  556. StartTime: fmt.Sprintf("%.2v:%.2v", startAt.Hour(), startAt.Minute()),
  557. Tel: usersMap[v.UserId].Mobile,
  558. Uid: v.UserId,
  559. Uname: usersMap[v.UserId].Realname,
  560. Week: common.GetCNWeekday(v.StartTime),
  561. })
  562. }
  563. }
  564. return resultList, nil
  565. }
  566. // getCurrentWeekReservation 返回本周预约信息
  567. func (s Service) getCurrentDayReservation(ctx context.Context, meetingList []meeting3.ShortMeeting, reqDate *gtime.Time) ([]meeting3.ReservationList, error) {
  568. // 获取符合条件的预约信息
  569. resultList := make([]meeting3.ReservationList, 0)
  570. for _, value := range meetingList {
  571. list, err := s.Dao.Where(s.Dao.Columns.EntityId, value.Id).
  572. Where(s.Dao.Columns.Status, 1).
  573. Where(s.Dao.Columns.StartTime+">=", reqDate).
  574. Where(s.Dao.Columns.EndTime+"<=", reqDate.AddDate(0, 0, 1)).
  575. FindAll()
  576. if err != nil {
  577. g.Log().Info("getCurrentDayReservation err:", err)
  578. return nil, err
  579. }
  580. if len(list) == 0 {
  581. continue
  582. }
  583. uIds := make([]int64, 0)
  584. uMap := make(map[int]struct{})
  585. for _, v := range list {
  586. if _, ok := uMap[v.UserId]; !ok {
  587. uIds = append(uIds, int64(v.UserId))
  588. uMap[v.UserId] = struct{}{}
  589. }
  590. }
  591. // 获取用户信息
  592. userList, err := srv.GetUserList(ctx, uIds, s.Tenant)
  593. usersMap := make(map[int]user_def.UserInfoList)
  594. for _, v := range userList {
  595. usersMap[v.Id] = v
  596. }
  597. for _, v := range list {
  598. timeLong := v.EndTime.Sub(v.StartTime).Hours()
  599. if v.SignOutTime.String() != "" && v.EndTime.Sub(v.SignOutTime) > 0 {
  600. timeLong = common.GetNextTimeNode(v.SignOutTime).Sub(v.StartTime).Hours()
  601. }
  602. grid := timeLong * 2
  603. for i := 0; i < int(grid); i++ {
  604. startAt := v.StartTime.Add(time.Duration(i) * 30 * time.Minute)
  605. resultList = append(resultList, meeting3.ReservationList{
  606. EntityId: value.Id,
  607. ReservationId: int(v.Id),
  608. Title: v.Title,
  609. Day: v.StartTime.Day(),
  610. Dept: usersMap[v.UserId].DepartmentName,
  611. StartTime: fmt.Sprintf("%.2v:%.2v", startAt.Hour(), startAt.Minute()),
  612. Tel: usersMap[v.UserId].Mobile,
  613. Uid: v.UserId,
  614. Uname: usersMap[v.UserId].Realname,
  615. Week: common.GetCNWeekday(v.StartTime),
  616. ReservationStartTime: v.StartTime.String(),
  617. ReservationEndTime: v.EndTime.String(),
  618. })
  619. }
  620. }
  621. }
  622. return resultList, nil
  623. }