LaborReportsCountingRecordService.php 5.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160
  1. <?php
  2. namespace App\Services;
  3. use App\LaborReport;
  4. use Carbon\Carbon;
  5. use DateTime;
  6. use Illuminate\Support\Facades\Auth;
  7. use Illuminate\Support\Facades\Cache;
  8. use Illuminate\Support\Str;
  9. use Ramsey\Uuid\Type\Integer;
  10. class LaborReportsCountingRecordService
  11. {
  12. public function userGroupsCount($start, $end)
  13. {
  14. $resultByCache = Cache::remember('userGroupsCount_' . $start . '_' . $end, 600, function () use ($start, $end) {
  15. return LaborReport::query()->selectRaw('user_workgroup_id,count(user_workgroup_id) amount')
  16. ->with('userWorkgroup', 'laborReportStatus')
  17. ->whereDate('created_at', '>=', $start)
  18. ->whereDate('created_at', '<', $end)
  19. ->groupBy('user_workgroup_id')->get();
  20. });
  21. $resultByCache = $resultByCache->filter(function ($item) {
  22. return $item->amount != 0;
  23. });
  24. $result = collect();
  25. $resultByCache->each(function ($item) use (&$result) {
  26. $result->push(
  27. [
  28. 'value' => $item->amount,
  29. 'name' => $item->userWorkgroup->name,
  30. 'id' => $item->userWorkgroup->id,
  31. ]
  32. );
  33. });
  34. return $result->sortBy('id');
  35. }
  36. public function get($start, $end, $unit = '日')
  37. {
  38. $resultByCache = $this->getByCache($start, $end, $unit);
  39. if ($resultByCache['dateList'] == []) {
  40. return $resultByCache['dataList'];
  41. } else {
  42. $this->syncDBToCache($resultByCache['dateList'], $unit);
  43. return $this->getByCache($start, $end, $unit)['dataList'];
  44. }
  45. }
  46. public function getByCache($start, $end, $unit)
  47. {
  48. $dataList = collect();
  49. $dateList = collect($this->periodDateToArray($start, $end, $unit));
  50. $result = [];
  51. foreach ($dateList as $date) {
  52. $key = 'laborReportsCountingRecords_' . $date . '_' . $unit;
  53. $item = Cache::get($key);
  54. if ($item) {
  55. $dataList->push($item);
  56. $dateList = $dateList->reject(function ($value) use ($date) {
  57. return $value == $date;
  58. });
  59. }
  60. }
  61. $result['dataList'] = $dataList;
  62. $result['dateList'] = $dateList->toArray();
  63. return $result;
  64. }
  65. /**
  66. * @param $start
  67. * @param $end
  68. * @param string $unit
  69. * @return array
  70. */
  71. private function periodDateToArray($start, $end, $unit = '日')
  72. {
  73. $dataArray = [];
  74. switch ($unit) {
  75. case '日';
  76. foreach (Carbon::parse($start)->daysUntil($end, 1)->toArray() as $item) {
  77. $dataArray[] = $item->toDateString();
  78. }
  79. break;
  80. case '月';
  81. foreach (Carbon::parse($start)->monthsUntil($end, 1)->toArray() as $item) {
  82. $dataArray[] = $item->year . '-' . $item->format('m') . '';
  83. }
  84. break;
  85. case '年';
  86. foreach (Carbon::parse($start)->yearsUntil($end, 1)->toArray() as $item) {
  87. $dataArray[] = $item->year.'';
  88. }
  89. break;
  90. default:
  91. break;
  92. }
  93. return $dataArray;
  94. }
  95. private function syncDBToCache($dateList, $unit)
  96. {
  97. switch ($unit) {
  98. case '日':
  99. $query = LaborReport::query()
  100. ->selectRaw("DATE_FORMAT(created_at,'%Y-%m-%d') as date_target, count(DISTINCT enter_number ) as counter");
  101. foreach ($dateList as $startOfWeek) {
  102. $query->orWhere(function ($query) use ($startOfWeek) {
  103. $query->whereDate('created_at', $startOfWeek);
  104. });
  105. }
  106. $dataList = $query->groupBy('date_target')->get();
  107. $dataList->each(function ($item) use ($unit) {
  108. $date = $item->date_target;
  109. $key = 'laborReportsCountingRecords_' . $date . '_' . $unit;
  110. Cache::put($key, $item);
  111. });
  112. break;
  113. case '月':
  114. $query = LaborReport::query()->selectRaw("DATE_FORMAT(created_at,'%Y-%m') as date_target, count(DISTINCT enter_number ) as counter");
  115. foreach ($dateList as $date) {
  116. $query->orWhere(function ($query) use ($date) {
  117. $year = Str::of($date)->explode('-')[0];
  118. $month = Str::of($date)->explode('-')[1];
  119. $query->whereYear('created_at', $year)->whereMonth('created_at', $month);
  120. });
  121. }
  122. $dataList = $query->groupBy('date_target')->get();
  123. $dataList->each(function ($item) use ($unit) {
  124. $date = $item->date_target;
  125. $key = 'laborReportsCountingRecords_' . $date . '_' . $unit;
  126. Cache::put($key, $item);
  127. });
  128. break;
  129. case '年':
  130. $query = LaborReport::query()->selectRaw("DATE_FORMAT(created_at,'%Y') as date_target, count(DISTINCT enter_number ) as counter");
  131. foreach ($dateList as $date) {
  132. $query->orWhere(function ($query) use ($date) {
  133. $year = Str::of($date)->explode('-')[0];
  134. $query->whereYear('created_at', $year)->whereYear('created_at', $year);
  135. });
  136. }
  137. $dataList = $query->groupBy('date_target')->get();
  138. $dataList->each(function ($item) use ($unit) {
  139. $date = $item->date_target;
  140. $key = 'laborReportsCountingRecords_' . $date . '_' . $unit;
  141. Cache::put($key, $item);
  142. });
  143. break;
  144. default:
  145. break;
  146. }
  147. }
  148. }