ExportFileService.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363
  1. <?php
  2. namespace App\Service;
  3. use App\Exports\ExportOrder;
  4. use App\Exports\MultiSheetExport;
  5. use App\Model\CalendarDetails;
  6. use App\Model\Device;
  7. use App\Model\DeviceDetails;
  8. use App\Model\Employee;
  9. use App\Model\EmployeeRole;
  10. use App\Model\Item;
  11. use App\Model\ItemDetails;
  12. use App\Model\RevenueCost;
  13. use Maatwebsite\Excel\Facades\Excel;
  14. class ExportFileService extends Service
  15. {
  16. public static $filename = "";
  17. //导出的方式 0 选择导出的数据 1 查询后 导出指定的数据(最多每次一千条)
  18. public static $export_type = [
  19. 0,
  20. 1
  21. ];
  22. public $special_func = [
  23. 0 => 'five',
  24. 1 => 'six',
  25. ];
  26. public function exportAll($data,$user){
  27. if(empty($data['menu_id'])) return [false, '菜单ID不能为空'];
  28. list($function, $name) = EmployeeService::fillMenu2($data['menu_id'], $user);
  29. if (empty($function) || ! method_exists(self::class, $function)) return [false, "导出方法不存在,请联系开发"];
  30. self::$filename = $name;
  31. //特殊的导出
  32. if(in_array($function, $this->special_func)){
  33. list($status, $return) = $this->$function($data,$user);
  34. if(! $status) return [false, $return];
  35. return [true, $return];
  36. }
  37. $export_type = $data['export_type'] ?? 0;
  38. if(! isset(self::$export_type[$export_type])) return [false,'导出文件方式错误或者不存在'];
  39. if(empty($export_type)){
  40. if(empty($data['id'])) return [false,'请选择导出数据'];
  41. $search = $data;
  42. }else{
  43. if(empty($data['order_search'])) return [false,'搜索条件不能为空'];
  44. $search = $data['order_search'];
  45. if(empty($search['page_index'])) return [false,'请选择导出数据的开始页码'];
  46. if(empty($search['page_size'])) return [false,'请选择导出数据的条数'];
  47. if($search['page_size'] > 5000) return [false,'请选择导出数据的条数每次最多5000条'];
  48. $data['order_search']['menu_id'] = $data['menu_id'];
  49. $search = $data['order_search'];
  50. }
  51. list($status, $return) = $this->$function($search,$user);
  52. if(! $status) return [false, $return];
  53. return [true, $return];
  54. }
  55. private function fillData($data, $column, &$return)
  56. {
  57. // 预先创建包含默认值的键数组
  58. $default = array_fill_keys($column, '');
  59. foreach ($data as $value) {
  60. // 提取交集,并用默认值补充缺失的键
  61. $return[] = array_merge($default, array_intersect_key($value, $default));
  62. }
  63. }
  64. private function fillTotalData($data, $column, &$return){
  65. $tmp = [];
  66. foreach ($column as $value){
  67. $key = $value['key'];
  68. if(! empty($value['sum']) && isset($data[$value['key']])){
  69. $decimals = $col['decimals'] ?? 2;
  70. // $tmp[$value['key']] = $data[$value['key']];
  71. // 用 number_format 格式化输出(保持字符串形式,避免科学计数)
  72. $tmp[$key] = number_format((float)$data[$key], $decimals, '.', '');
  73. }else{
  74. $tmp[$value['key']] = "";
  75. }
  76. }
  77. $return[] = $tmp;
  78. }
  79. public function one($ergs, $user){
  80. $service = new EmployeeService();
  81. $model = $service->employeeCommon($ergs, $user);
  82. // 导出数据
  83. $return = [];
  84. $header_default = $user['e_header_default'];
  85. $column = array_column($header_default,'key');
  86. $header = array_column($header_default,'value');
  87. $model->chunk(500,function ($data) use(&$return,$column,$service){
  88. $data = $data->toArray();
  89. $list['data'] = $data;
  90. $list = $service->organizationEmployeeData($list);
  91. $this->fillData($list['data'], $column, $return);
  92. });
  93. return [true, $this->saveExportData($return,$header)];
  94. }
  95. public function two($ergs,$user){
  96. // 导出数据
  97. $return = [];
  98. $header_default = $user['e_header_default'];
  99. $column = array_column($header_default,'key');
  100. $header = array_column($header_default,'value');
  101. $service = new ItemService();
  102. $model = $service->itemCommon($ergs, $user);
  103. $model->chunk(500,function ($data) use(&$return,$column,$service){
  104. $data = $data->toArray();
  105. $list['data'] = $data;
  106. $list = $service->fillData($list);
  107. $this->fillData($list['data'], $column, $return);
  108. });
  109. return [true, $this->saveExportData($return,$header)];
  110. }
  111. public function three($ergs,$user){
  112. // 导出数据
  113. $return = [];
  114. $header_default = $user['e_header_default'];
  115. $column = array_column($header_default,'key');
  116. $header = array_column($header_default,'value');
  117. $service = new DeviceService();
  118. $model = $service->deviceCommon($ergs, $user);
  119. $model->chunk(500,function ($data) use(&$return, $service, $column){
  120. $data = $data->toArray();
  121. $list['data'] = $data;
  122. //订单数据
  123. $list = $service->fillData($list);
  124. //返回数据
  125. $this->fillData($list['data'], $column, $return);
  126. });
  127. return [true, $this->saveExportData($return,$header)];
  128. }
  129. public function four($ergs,$user){
  130. // 导出数据
  131. $return = [];
  132. $header_default = $user['e_header_default'];
  133. $column = array_column($header_default,'key');
  134. $header = array_column($header_default,'value');
  135. $service = new RDService();
  136. $model = $service->rdCommon($ergs, $user);
  137. $model->chunk(500,function ($data) use(&$return, $column, $service){
  138. $data = $data->toArray();
  139. $list['data'] = $data;
  140. //订单数据
  141. $list = $service->fillData($list);
  142. $this->fillData($list['data'], $column, $return);
  143. });
  144. //合计
  145. $total = $this->countTotal($return, $header_default);
  146. //填充合计
  147. $this->fillTotalData($total, $header_default, $return);
  148. return [true, $this->saveExportData($return,$header)];
  149. }
  150. public function five($ergs, $user) {
  151. $header_default = $user['e_header_default'];
  152. $column = array_column($header_default, 'key'); // 对应数据的键名
  153. $header = array_column($header_default, 'value'); // Excel 展现的中文表头
  154. array_unshift($column, 'index_no'); // 内部识别用的 key
  155. array_unshift($header, '序号'); // Excel 显示的表头
  156. $service = new StatisticsService();
  157. list($status, $res) = $service->statisticsEmployeeExportCommon($ergs, $user);
  158. if (!$status) return [false, $res];
  159. list($model, $timeRange, $totalWorkDays) = $res;
  160. $rawData = $model->get()->toArray();
  161. // 获取员工名单(避免在循环里重复查询)
  162. $employee_id = EmployeeRole::where('del_time', 0)
  163. ->where('role_id', 87)
  164. ->pluck('employee_id')
  165. ->toArray();
  166. $employee = Employee::where('del_time', 0)
  167. ->whereIn('id', $employee_id)
  168. ->where('id', '<>', Employee::SPECIAL_ADMIN)
  169. ->select('id', 'emp_name as name')
  170. ->get()->toArray();
  171. $item_total = Item::where('del_time', 0)->select('code', 'id','start_time','end_time')->get()->toArray();
  172. // 生成起止时间行
  173. $timeRow = $this->getItemTimeRow($column, $item_total);
  174. // 最终交给 MultiSheetExport 的数组
  175. $finalExportData = [];
  176. $month = date("Y.m", $timeRange[0]);
  177. // --- 1. 处理全月汇总 Sheet ---
  178. $summaryData = $service->statisticsEmployeeFillExportData($rawData, $timeRange, $totalWorkDays, $employee,$item_total);
  179. // 格式化数据:只取 header 中定义的列,并按顺序排列
  180. $finalExportData[$month . '合计'] = $this->formatSheetData($header, $column, $summaryData);
  181. // --- 2. 处理每日明细 Sheets ---
  182. $dataByDay = [];
  183. foreach ($rawData as $row) {
  184. $dateKey = date('Y-m-d', $row['order_time']);
  185. $dataByDay[$dateKey][] = $row;
  186. }
  187. foreach ($dataByDay as $date => $dayRows) {
  188. $dayTimestamp = strtotime($date);
  189. // 这里调用你的填充逻辑
  190. $dayResult = $service->statisticsEmployeeFillExportData($dayRows, [$dayTimestamp], 1, $employee, $item_total);
  191. // 格式化并存入结果集
  192. $finalExportData[date('Y.m.d',$dayTimestamp)] = $this->formatSheetData($header, $column, $dayResult);
  193. }
  194. // 3. 调用保存方法
  195. return [true, $this->saveExportData2($finalExportData,1,$column,$timeRow)];
  196. }
  197. public function six($ergs,$user){
  198. // 导出数据
  199. $header_default = $user['e_header_default'];
  200. $column = array_column($header_default,'key');
  201. $header = array_column($header_default,'value');
  202. array_unshift($column, 'index_no'); // 内部识别用的 key
  203. array_unshift($header, '序号'); // Excel 显示的表头
  204. $service = new StatisticsService();
  205. list($status, $result) = $service->statisticsDeviceExportCommon($ergs, $user);
  206. if(! $status) return [false, $result];
  207. list($model, $timeRange) = $result;
  208. $rawData = $model->get()->toArray();
  209. $device = Device::where('del_time',0)
  210. ->where('is_use',Device::type_one)
  211. ->select('id','title as name','code','type','type_2','power','in_time','number')
  212. ->get()->toArray();
  213. $item_total = Item::where('del_time', 0)->where('is_use', 1)->select('code', 'id','start_time','end_time')->get()->toArray();
  214. $time_array = DeviceDetails::where('del_time',0)
  215. ->where('time', strtotime($ergs['month'] . '-01'))
  216. ->pluck('total_hours', 'device_id')
  217. ->all();
  218. // 生成起止时间行
  219. $timeRow = $this->getItemTimeRow($column, $item_total);
  220. // 最终交给 MultiSheetExport 的数组
  221. $finalExportData = [];
  222. $month = date("Y.m", $timeRange[0]);
  223. // --- 1. 处理全月汇总 Sheet ---
  224. $summaryData = $service->statisticsDeviceFillExportData($rawData, $timeRange, $device, $item_total,true,$time_array);
  225. // 格式化数据:只取 header 中定义的列,并按顺序排列
  226. $finalExportData[$month . '合计'] = $this->formatSheetData($header, $column, $summaryData);
  227. // --- 2. 处理每日明细 Sheets ---
  228. $dataByDay = [];
  229. foreach ($rawData as $row) {
  230. $dateKey = date('Y-m-d', $row['order_time']);
  231. $dataByDay[$dateKey][] = $row;
  232. }
  233. foreach ($dataByDay as $date => $dayRows) {
  234. $dayTimestamp = strtotime($date);
  235. // 这里调用你的填充逻辑
  236. $dayResult = $service->statisticsDeviceFillExportData($dayRows, [$dayTimestamp], $device, $item_total,false, $time_array);
  237. // 格式化并存入结果集
  238. $finalExportData[date('Y.m.d',$dayTimestamp)] = $this->formatSheetData($header, $column, $dayResult);
  239. }
  240. // 3. 调用保存方法
  241. return [true, $this->saveExportData2($finalExportData, 2,$column,$timeRow)];
  242. }
  243. private function getItemTimeRow($column, $item_total) {
  244. $item_time_map = [];
  245. foreach ($item_total as $it) {
  246. $start = !empty($it['start_time']) ? date('Y.m', (int)$it['start_time']) : '';
  247. $end = !empty($it['end_time']) ? date('Y.m', (int)$it['end_time']) : '';
  248. $item_time_map[$it['id']] = ($start || $end) ? "{$start}-{$end}" : '';
  249. }
  250. $timeRow = [];
  251. foreach ($column as $key) {
  252. if (strpos($key, 'extra_') === 0) {
  253. $itemId = str_replace('extra_', '', $key);
  254. $timeRow[$key] = $item_time_map[$itemId] ?? '';
  255. } else {
  256. $timeRow[$key] = ''; // 其他字段(序号、设备名等)全为空
  257. }
  258. }
  259. return $timeRow;
  260. }
  261. /**
  262. * 辅助方法:将数据按表头顺序对齐,并把表头插入到第一行
  263. */
  264. private function formatSheetData($header, $column, $dataRows) {
  265. $sheet = [];
  266. $sheet[] = $header; // 第一行放入表头文字
  267. $count = 1; // 初始化序号计数器
  268. foreach ($dataRows as $row) {
  269. $temp = [];
  270. foreach ($column as $key) {
  271. if ($key === 'index_no') {
  272. $temp[] = $count; // 填充序号
  273. } else {
  274. $temp[] = $row[$key] ?? '';
  275. }
  276. }
  277. $sheet[] = $temp;
  278. $count++; // 序号自增
  279. }
  280. return $sheet;
  281. }
  282. public function saveExportData($data, $headers, $type = 'default',$file_name = ''){
  283. if(empty($file_name)) $file_name = self::$filename . "_". date("Y-m-d") . "_". rand(1000,9999);
  284. $filename = $file_name . '.' . 'xlsx';
  285. $bool = Excel::store(new ExportOrder($data,$type,$headers),"/public/export/{$filename}", null, 'Xlsx', []);
  286. return $filename;
  287. }
  288. public function saveExportData2($data,$type = 1,$column,$timeRow, $file_name = ''){
  289. if(empty($file_name)) $file_name = self::$filename . "_". date("Y-m-d") . "_". rand(1000,9999);
  290. $filename = $file_name . '.' . 'xlsx';
  291. \Maatwebsite\Excel\Facades\Excel::store(new MultiSheetExport($data, $type,$column,$timeRow),"/public/export/{$filename}", null, 'Xlsx', []);
  292. return $filename;
  293. }
  294. }