OrderController.php 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Http\Requests\CreteTtnRequest;
  4. use App\Http\Requests\ExportScheduleRequest;
  5. use App\Http\Requests\Order\StoreOrderRequest;
  6. use App\Jobs\ExportOneOrderJob;
  7. use App\Jobs\ExportOrdersJob;
  8. use App\Jobs\ExportScheduleJob;
  9. use App\Jobs\GenerateFilesPack;
  10. use App\Jobs\GenerateHandoverPack;
  11. use App\Jobs\GenerateInstallationPack;
  12. use App\Jobs\GenerateTtnPack;
  13. use App\Models\Dictionary\Area;
  14. use App\Models\Dictionary\District;
  15. use App\Models\File;
  16. use App\Models\MafOrder;
  17. use App\Models\ObjectType;
  18. use App\Models\Order;
  19. use App\Models\OrderStatus;
  20. use App\Models\OrderView;
  21. use App\Models\ProductSKU;
  22. use App\Models\Role;
  23. use App\Models\Schedule;
  24. use App\Models\Ttn;
  25. use App\Models\User;
  26. use App\Services\FileService;
  27. use App\Services\NotificationService;
  28. use Illuminate\Http\RedirectResponse;
  29. use Illuminate\Http\Request;
  30. use Illuminate\Support\Facades\DB;
  31. use Illuminate\Support\Str;
  32. use Illuminate\Support\Facades\Storage;
  33. use Symfony\Component\HttpFoundation\BinaryFileResponse;
  34. use Throwable;
  35. use ZipArchive;
  36. class OrderController extends Controller
  37. {
  38. protected array $data = [
  39. 'active' => 'orders',
  40. 'title' => 'Заказы',
  41. 'id' => 'orders',
  42. 'header' => [
  43. 'id' => 'ID',
  44. 'name' => 'Название',
  45. 'user_name' => 'Менеджер',
  46. 'district_name' => 'Округ',
  47. 'area_name' => 'Район',
  48. 'object_address' => 'Адрес объекта',
  49. 'object_type_name' => 'Тип объекта',
  50. 'comment' => 'Комментарий',
  51. 'products_total' => 'Всего МАФ',
  52. 'installation_date' => 'Дата выхода на монтаж',
  53. 'ready_date' => 'Дата готовности площадки',
  54. 'brigadier_name' => 'Бригадир',
  55. 'order_status_name' => 'Статус',
  56. 'tg_group_name' => 'Имя группы в ТГ',
  57. 'tg_group_link' => 'Ссылка на группу в ТГ',
  58. 'products_with_count' => 'МАФы',
  59. 'ready_to_mount' => 'Все МАФы на складе',
  60. ],
  61. 'searchFields' => [
  62. 'name',
  63. 'user_name',
  64. 'district_name',
  65. 'area_name',
  66. 'object_type_name',
  67. 'comment',
  68. 'object_address',
  69. 'installation_date',
  70. 'tg_group_name',
  71. 'tg_group_link',
  72. ],
  73. ];
  74. public function __construct()
  75. {
  76. $this->data['districts'] = District::query()->get()->pluck('name', 'id');
  77. $this->data['areas'] = Area::query()->get()->pluck('name', 'id');
  78. $this->data['objectTypes'] = ObjectType::query()->get()->pluck('name', 'id');
  79. $this->data['orderStatuses'] =OrderStatus::query()->get()->pluck('name', 'id');
  80. $this->data['brigadiers'] = User::query()->where('role', Role::BRIGADIER)->get()->pluck('name', 'id');
  81. $this->data['users'] = User::query()->whereIn('role', [Role::MANAGER, Role::ADMIN])->get()->pluck('name', 'id');
  82. }
  83. /**
  84. * Display a listing of the resource.
  85. */
  86. public function index(Request $request)
  87. {
  88. session(['gp_orders' => $request->all()]);
  89. $model = new OrderView;
  90. // fill filters
  91. $this->createFilters($model, 'user_name', 'district_name', 'area_name', 'object_type_name', 'brigadier_name', 'order_status_name', 'ready_to_mount');
  92. $this->createDateFilters($model, 'installation_date', 'ready_date');
  93. $this->data['ranges'] = [];
  94. $q = $model::query();
  95. $this->acceptFilters($q, $request);
  96. $this->acceptSearch($q, $request);
  97. $this->setSortAndOrderBy($model, $request);
  98. if(hasRole('brigadier')) {
  99. $q->where('brigadier_id', auth()->id())
  100. ->whereIn('order_status_id', Order::visibleStatusIdsForBrigadier());
  101. }
  102. if(hasRole(Role::WAREHOUSE_HEAD)) {
  103. $q->whereNotNull('brigadier_id');
  104. $q->whereNotNull('installation_date');
  105. }
  106. $this->data['filtered_orders_count'] = (clone $q)->count();
  107. $this->data['filtered_products_total'] = (clone $q)->sum('products_total');
  108. $this->applyStableSorting($q);
  109. $this->data['orders'] = $q->paginate($this->data['per_page'])->withQueryString();
  110. foreach ($this->data['orders'] as $order) {
  111. Order::where('id', $order->id)->first()?->recalculateReadyToMount();
  112. }
  113. $this->data['statuses'] = OrderStatus::query()->get()->pluck('name', 'id');
  114. return view('orders.index', $this->data);
  115. }
  116. /**
  117. * Show the form for creating a new resource.
  118. */
  119. public function create(Request $request)
  120. {
  121. $this->data['previous_url'] = $this->resolvePreviousUrl(
  122. $request,
  123. 'previous_url_orders',
  124. route('order.index', session('gp_orders'))
  125. );
  126. return view('orders.edit', $this->data);
  127. }
  128. /**
  129. * Store a newly created resource in storage.
  130. */
  131. public function store(StoreOrderRequest $request, NotificationService $notificationService)
  132. {
  133. $data = $request->validated();
  134. $products = $request->validated('products');
  135. $quantities = $request->validated('quantity');
  136. unset($data['products']);
  137. if(isset($data['id'])) {
  138. $order = Order::query()->where('id', $data['id'])->first();
  139. $status = $order->order_status_id;
  140. $order->update($data);
  141. $order->refresh();
  142. if($order->order_status_id != $status) {
  143. $notificationService->notifyOrderStatusChanged($order, auth()->user());
  144. }
  145. } else {
  146. $data['order_status_id'] = Order::STATUS_NEW;
  147. $order = Order::query()->create($data);
  148. $tg_group_name = '/' . $order->district->shortname
  149. . ' ' . $order->object_address
  150. . ' (' . $order->area->name . ')'
  151. . ' - ' . $order->user->name;
  152. $order->update(['tg_group_name' => $tg_group_name]);
  153. $notificationService->notifyOrderCreated($order, auth()->user());
  154. }
  155. // меняем список товаров заказа только если статус новый
  156. if($products && $quantities && ($order->order_status_id == 1)) {
  157. $desiredCounts = [];
  158. foreach ($products as $key => $productId) {
  159. $quantity = (int)($quantities[$key] ?? 0);
  160. if ($quantity < 1) {
  161. continue;
  162. }
  163. if (!isset($desiredCounts[$productId])) {
  164. $desiredCounts[$productId] = 0;
  165. }
  166. $desiredCounts[$productId] += $quantity;
  167. }
  168. $attachedSkus = ProductSKU::query()
  169. ->where('order_id', $order->id)
  170. ->whereNotNull('maf_order_id')
  171. ->with('product:id,article')
  172. ->get();
  173. $attachedByProduct = [];
  174. foreach ($attachedSkus as $sku) {
  175. if (!isset($attachedByProduct[$sku->product_id])) {
  176. $attachedByProduct[$sku->product_id] = 0;
  177. }
  178. $attachedByProduct[$sku->product_id]++;
  179. }
  180. $currentCounts = ProductSKU::query()
  181. ->where('order_id', $order->id)
  182. ->selectRaw('product_id, COUNT(*) as cnt')
  183. ->groupBy('product_id')
  184. ->pluck('cnt', 'product_id')
  185. ->map(fn ($count) => (int)$count)
  186. ->toArray();
  187. $errors = [];
  188. foreach ($attachedByProduct as $productId => $attachedCount) {
  189. $desiredCount = $desiredCounts[$productId] ?? 0;
  190. if ($desiredCount < $attachedCount) {
  191. $article = $attachedSkus->firstWhere('product_id', $productId)?->product?->article ?? ('ID ' . $productId);
  192. $errors[] = "Нельзя удалить привязанные МАФ {$article}: привязано {$attachedCount} шт.";
  193. }
  194. }
  195. // Если есть хотя бы один привязанный МАФ, запрещаем добавлять новые позиции/количество.
  196. if (!empty($attachedByProduct)) {
  197. foreach ($desiredCounts as $productId => $desiredCount) {
  198. $currentCount = $currentCounts[$productId] ?? 0;
  199. if ($desiredCount > $currentCount) {
  200. $errors[] = 'Нельзя добавлять новые позиции МАФ, пока на площадке есть привязанные МАФ.';
  201. break;
  202. }
  203. }
  204. }
  205. if (!empty($errors)) {
  206. return redirect()->back()->withInput()->with(['danger' => $errors]);
  207. }
  208. // Удаляем только непривязанные SKU и пересоздаём их по новому списку.
  209. ProductSKU::query()
  210. ->where('order_id', $order->id)
  211. ->whereNull('maf_order_id')
  212. ->delete();
  213. foreach ($desiredCounts as $productId => $desiredCount) {
  214. $attachedCount = $attachedByProduct[$productId] ?? 0;
  215. $toCreate = $desiredCount - $attachedCount;
  216. for ($i = 0; $i < $toCreate; $i++) {
  217. ProductSKU::query()->create([
  218. 'order_id' => $order->id,
  219. 'product_id' => $productId,
  220. 'status' => 'требуется'
  221. ]);
  222. }
  223. }
  224. }
  225. $order->refresh();
  226. $order->autoChangeStatus();
  227. return redirect()->route('order.show', ['order' => $order, 'previous_url' => $request->get('previous_url')]);
  228. }
  229. /**
  230. * Display the specified resource.
  231. */
  232. public function show(Request $request, int $order)
  233. {
  234. $this->data['order'] = Order::query()
  235. ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
  236. ->with([
  237. 'chatMessages.user',
  238. 'chatMessages.targetUser',
  239. 'chatMessages.notifiedUsers',
  240. 'chatMessages.files',
  241. ])
  242. ->find($order);
  243. if ($request->boolean('sync_year') && $this->data['order']) {
  244. $previousYear = year();
  245. $targetYear = (int)$this->data['order']->year;
  246. if ($previousYear !== $targetYear) {
  247. session(['year' => $targetYear]);
  248. session()->flash('warning', "Год переключен: {$previousYear} → {$targetYear} (по году площадки).");
  249. }
  250. }
  251. if (hasRole('brigadier') && $this->data['order']) {
  252. $canView = (int)$this->data['order']->brigadier_id === (int)auth()->id()
  253. && in_array((int)$this->data['order']->order_status_id, Order::visibleStatusIdsForBrigadier(), true);
  254. if (!$canView) {
  255. abort(403);
  256. }
  257. }
  258. $this->data['previous_url'] = $this->resolvePreviousUrl(
  259. $request,
  260. 'previous_url_orders',
  261. route('order.index', session('gp_orders'))
  262. );
  263. $orderModel = $this->data['order'];
  264. $chatUsers = User::query()->orderBy('name')->get(['id', 'name', 'role']);
  265. $responsibleUserIds = User::query()
  266. ->where('role', Role::ADMIN)
  267. ->pluck('id')
  268. ->map(static fn ($id) => (int) $id)
  269. ->all();
  270. $responsibleUserIds = array_values(array_unique(array_filter(array_merge($responsibleUserIds, [
  271. $orderModel?->user_id ? (int) $orderModel->user_id : null,
  272. $orderModel?->brigadier_id ? (int) $orderModel->brigadier_id : null,
  273. ]))));
  274. $this->data['chatUsers'] = $chatUsers->map(fn ($u) => [
  275. 'id' => $u->id,
  276. 'name' => $u->name,
  277. 'role' => $u->role,
  278. ])->keyBy('id');
  279. $this->data['chatResponsibleUserIds'] = $responsibleUserIds;
  280. $this->data['chatManagerUserId'] = $orderModel?->user_id ? (int) $orderModel->user_id : null;
  281. $this->data['chatBrigadierUserId'] = $orderModel?->brigadier_id ? (int) $orderModel->brigadier_id : null;
  282. return view('orders.show', $this->data);
  283. }
  284. /**
  285. * Show the form for editing the specified resource.
  286. */
  287. public function edit(Request $request, Order $order)
  288. {
  289. $this->data['order'] = $order;
  290. $this->data['previous_url'] = $this->resolvePreviousUrl(
  291. $request,
  292. 'previous_url_orders',
  293. route('order.index', session('gp_orders'))
  294. );
  295. return view('orders.edit', $this->data);
  296. }
  297. /**
  298. * Привязка товаров к заказу
  299. * @param Order $order
  300. * @return RedirectResponse
  301. * @throws Throwable
  302. */
  303. public function getMafToOrder(Order $order)
  304. {
  305. $attached = 0;
  306. $missingByProduct = [];
  307. DB::transaction(function () use ($order, &$attached, &$missingByProduct) {
  308. foreach ($order->products_sku as $productSku) {
  309. // Уже привязан, пропускаем
  310. if ($productSku->maf_order_id) {
  311. continue;
  312. }
  313. $mafOrder = MafOrder::query()
  314. ->where('product_id', $productSku->product_id)
  315. ->where('in_stock', '>', 0)
  316. ->orderBy('created_at')
  317. ->lockForUpdate()
  318. ->first();
  319. if (!$mafOrder) {
  320. $article = $productSku->product?->article ?? ('ID ' . $productSku->product_id);
  321. if (!isset($missingByProduct[$productSku->product_id])) {
  322. $missingByProduct[$productSku->product_id] = ['article' => $article, 'count' => 0];
  323. }
  324. $missingByProduct[$productSku->product_id]['count']++;
  325. continue;
  326. }
  327. $productSku->update(['maf_order_id' => $mafOrder->id, 'status' => 'отгружен']);
  328. $mafOrder->decrement('in_stock');
  329. $attached++;
  330. }
  331. });
  332. $order->autoChangeStatus();
  333. $success = [];
  334. $danger = [];
  335. if ($attached > 0) {
  336. $success[] = "Привязано МАФ: {$attached}.";
  337. }
  338. foreach ($missingByProduct as $missing) {
  339. $danger[] = "Не удалось привязать {$missing['count']} шт. МАФ {$missing['article']}: нет остатка на складе.";
  340. }
  341. if ($attached === 0 && empty($danger)) {
  342. $danger[] = 'Нет МАФ для привязки: все МАФы на площадке уже привязаны.';
  343. }
  344. $flash = [];
  345. if (!empty($success)) {
  346. $flash['success'] = $success;
  347. }
  348. if (!empty($danger)) {
  349. $flash['danger'] = $danger;
  350. }
  351. return redirect()->route('order.show', $order)->with($flash);
  352. }
  353. /**
  354. * @param Order $order
  355. * @return RedirectResponse
  356. */
  357. public function destroy(Order $order)
  358. {
  359. Order::query()->where('id', $order->id)->delete();
  360. ProductSKU::query()->where('order_id', $order->id)->delete();
  361. return redirect()->route('order.index', session('gp_orders'));
  362. }
  363. public function revertMaf(Order $order)
  364. {
  365. $detached = 0;
  366. $notFoundMafOrders = 0;
  367. DB::transaction(function () use ($order, &$detached, &$notFoundMafOrders) {
  368. foreach ($order->products_sku as $maf) {
  369. if (!$maf->maf_order_id) {
  370. continue;
  371. }
  372. $affectedRows = MafOrder::query()
  373. ->where('id', $maf->maf_order_id)
  374. ->lockForUpdate()
  375. ->increment('in_stock');
  376. if (!$affectedRows) {
  377. $notFoundMafOrders++;
  378. continue;
  379. }
  380. $maf->update(['maf_order_id' => null, 'status' => 'требуется']);
  381. $detached++;
  382. }
  383. });
  384. $order->autoChangeStatus();
  385. $success = [];
  386. $danger = [];
  387. if ($detached > 0) {
  388. $success[] = "Отвязано МАФ: {$detached}.";
  389. }
  390. if ($notFoundMafOrders > 0) {
  391. $danger[] = "Не удалось отвязать {$notFoundMafOrders} шт. МАФ: связанный заказ МАФ не найден.";
  392. }
  393. if ($detached === 0 && empty($danger)) {
  394. $danger[] = 'Нет МАФ для отвязки: на площадке нет привязанных МАФ.';
  395. }
  396. $flash = [];
  397. if (!empty($success)) {
  398. $flash['success'] = $success;
  399. }
  400. if (!empty($danger)) {
  401. $flash['danger'] = $danger;
  402. }
  403. return redirect()->route('order.show', $order)->with($flash);
  404. }
  405. public function moveMaf(Request $request)
  406. {
  407. $data = $request->validate([
  408. 'new_order_id' => 'required',
  409. 'ids' => 'required|json',
  410. ]);
  411. $ids = json_decode($data['ids'], true);
  412. $updated = [];
  413. foreach ($ids as $mafId) {
  414. $maf = ProductSKU::query()
  415. ->where('id', $mafId)
  416. ->first();
  417. if($maf) {
  418. $comment = $maf->comment . "\n" . date('Y-m-d H:i') . ' Перенесено с площадки: ' . $maf->order->common_name;
  419. $maf->update(['order_id' => $data['new_order_id'], 'comment' => $comment]);
  420. $updated[] = $maf;
  421. }
  422. }
  423. return response()->json(['success' => true]);
  424. }
  425. public function search(Request $request): array
  426. {
  427. $ret = [];
  428. $s = $request->get('s');
  429. $currentOrderId = $request->integer('current_order_id');
  430. $searchFields = $this->data['searchFields'];
  431. $result = OrderView::query();
  432. if($s) {
  433. $result->where(function ($query) use ($searchFields, $s) {
  434. foreach ($searchFields as $searchField) {
  435. $query->orWhere($searchField, 'LIKE', '%' . $s . '%');
  436. }
  437. });
  438. }
  439. if ($currentOrderId > 0) {
  440. $result->where('id', '!=', $currentOrderId);
  441. }
  442. $result->orderBy('object_address');
  443. foreach ($result->get() as $p) {
  444. $ret[$p->id] = $p->move_maf_name;
  445. }
  446. return $ret;
  447. }
  448. public function uploadPhoto(Request $request, Order $order, FileService $fileService)
  449. {
  450. $data = $request->validate([
  451. 'photo.*' => 'mimes:jpeg,jpg,png,webp',
  452. ]);
  453. try {
  454. $f = [];
  455. foreach ($data['photo'] as $photo) {
  456. $f[] = $fileService->saveUploadedFile('orders/' . $order->id . '/photo', $photo);
  457. }
  458. $order->photos()->syncWithoutDetaching($f);
  459. } catch (Throwable $e) {
  460. report($e);
  461. return redirect()->route('order.show', $order)
  462. ->with(['error' => 'Ошибка загрузки фотографий. Проверьте имя файла и повторите попытку.']);
  463. }
  464. return redirect()->route('order.show', $order)->with(['success' => 'Фотографии успешно загружены!']);
  465. }
  466. public function deletePhoto(Order $order, File $file, FileService $fileService)
  467. {
  468. $order->photos()->detach($file);
  469. Storage::disk('public')->delete($file->path);
  470. $file->delete();
  471. return redirect()->route('order.show', $order);
  472. }
  473. public function deleteAllPhotos(Order $order)
  474. {
  475. $files = $order->photos;
  476. $order->photos()->detach();
  477. foreach ($files as $file) {
  478. Storage::disk('public')->delete($file->path);
  479. $file->delete();
  480. }
  481. return redirect()->route('order.show', $order);
  482. }
  483. public function uploadDocument(Request $request, Order $order, FileService $fileService)
  484. {
  485. $data = $request->validate([
  486. 'document.*' => 'file',
  487. ]);
  488. try {
  489. $f = [];
  490. $i = 0;
  491. foreach ($data['document'] as $document) {
  492. if ($i++ >= 5) break;
  493. $f[] = $fileService->saveUploadedFile('orders/' . $order->id . '/document', $document);
  494. }
  495. $order->documents()->syncWithoutDetaching($f);
  496. } catch (Throwable $e) {
  497. report($e);
  498. return redirect()->route('order.show', $order)
  499. ->with(['error' => 'Ошибка загрузки документов. Проверьте имя файла и повторите попытку.']);
  500. }
  501. return redirect()->route('order.show', $order)->with(['success' => 'Документы успешно загружены!']);
  502. }
  503. public function deleteDocument(Order $order, File $file)
  504. {
  505. $order->documents()->detach($file);
  506. Storage::disk('public')->delete($file->path);
  507. $file->delete();
  508. return redirect()->route('order.show', $order);
  509. }
  510. public function deleteAllDocuments(Order $order)
  511. {
  512. $files = $order->documents;
  513. $order->documents()->detach();
  514. foreach ($files as $file) {
  515. Storage::disk('public')->delete($file->path);
  516. $file->delete();
  517. }
  518. return redirect()->route('order.show', $order);
  519. }
  520. public function uploadStatement(Request $request, Order $order, FileService $fileService)
  521. {
  522. $data = $request->validate([
  523. 'statement.*' => 'file',
  524. ]);
  525. try {
  526. $f = [];
  527. $i = 0;
  528. foreach ($data['statement'] as $statement) {
  529. if ($i++ >= 5) break;
  530. $f[] = $fileService->saveUploadedFile('orders/' . $order->id . '/statement', $statement);
  531. }
  532. $order->statements()->syncWithoutDetaching($f);
  533. } catch (Throwable $e) {
  534. report($e);
  535. return redirect()->route('order.show', $order)
  536. ->with(['error' => 'Ошибка загрузки ведомостей. Проверьте имя файла и повторите попытку.']);
  537. }
  538. return redirect()->route('order.show', $order)->with(['success' => 'Ведомости успешно загружены!']);
  539. }
  540. public function deleteStatement(Order $order, File $file)
  541. {
  542. $order->statements()->detach($file);
  543. Storage::disk('public')->delete($file->path);
  544. $file->delete();
  545. return redirect()->route('order.show', $order);
  546. }
  547. public function deleteAllStatements(Order $order)
  548. {
  549. $files = $order->statements;
  550. $order->statements()->detach();
  551. foreach ($files as $file) {
  552. Storage::disk('public')->delete($file->path);
  553. $file->delete();
  554. }
  555. return redirect()->route('order.show', $order);
  556. }
  557. public function generateInstallationPack(Order $order)
  558. {
  559. $errors = $order->isAllMafConnected();
  560. if($errors) {
  561. return redirect()->route('order.show', $order)->with(['danger' => $errors]);
  562. }
  563. GenerateInstallationPack::dispatch($order, auth()->user()->id);
  564. return redirect()->route('order.show', $order)->with(['success' => 'Задача генерации документов создана!']);
  565. }
  566. public function generateHandoverPack(Order $order)
  567. {
  568. if($errors = $order->canCreateHandover()) {
  569. return redirect()->route('order.show', $order)->with(['danger' => $errors]);
  570. }
  571. GenerateHandoverPack::dispatch($order, auth()->user()->id);
  572. return redirect()->route('order.show', $order)->with(['success' => 'Задача генерации документов создана!']);
  573. }
  574. public function generatePhotosPack(Order $order)
  575. {
  576. GenerateFilesPack::dispatch($order, $order->photos, auth()->user()->id, 'Фото');
  577. return redirect()->back()->with(['success' => 'Задача архивации создана!']);
  578. }
  579. public function createTtn(CreteTtnRequest $request)
  580. {
  581. $ttn = Ttn::query()->create([
  582. 'year' => date('Y'),
  583. 'ttn_number' => Ttn::getTtnNumber() + 1,
  584. 'ttn_number_suffix' => 'И',
  585. 'order_number' => $request->order_number,
  586. 'order_date' => $request->order_date,
  587. 'order_sum' => $request->order_sum,
  588. 'skus' => json_encode($request->skus),
  589. ]);
  590. GenerateTtnPack::dispatch($ttn, auth()->user()->id);
  591. return redirect()->back()->with(['success' => 'Задача формирования ТН создана!']);
  592. }
  593. public function export(Request $request)
  594. {
  595. $request->validate([
  596. 'withFilter' => 'nullable',
  597. 'filters' => 'nullable|array',
  598. 's' => 'nullable|string',
  599. ]);
  600. $orders = Order::query();
  601. if ($request->boolean('withFilter')) {
  602. $filterRequest = new Request(array_filter([
  603. 'filters' => $request->input('filters', []),
  604. 's' => $request->input('s'),
  605. 'sortBy' => $request->input('sortBy'),
  606. 'order' => $request->input('order'),
  607. ], static fn ($value) => $value !== null));
  608. $model = new OrderView;
  609. $this->createFilters($model, 'user_name', 'district_name', 'area_name', 'object_type_name', 'brigadier_name', 'order_status_name', 'ready_to_mount');
  610. $this->createDateFilters($model, 'installation_date', 'ready_date');
  611. $this->data['ranges'] = [];
  612. $q = $model::query();
  613. $this->acceptFilters($q, $filterRequest);
  614. $this->acceptSearch($q, $filterRequest);
  615. $this->setSortAndOrderBy($model, $filterRequest);
  616. if (hasRole('brigadier')) {
  617. $q->where('brigadier_id', auth()->id())
  618. ->whereIn('order_status_id', Order::visibleStatusIdsForBrigadier());
  619. }
  620. if (hasRole(Role::WAREHOUSE_HEAD)) {
  621. $q->whereNotNull('brigadier_id');
  622. $q->whereNotNull('installation_date');
  623. }
  624. $this->applyStableSorting($q);
  625. $orderIds = $q->pluck('id');
  626. $orders = Order::query()
  627. ->whereIn('id', $orderIds)
  628. ->get()
  629. ->sortBy(static fn (Order $order) => $orderIds->search($order->id))
  630. ->values();
  631. } else {
  632. $orders = $orders->get();
  633. }
  634. ExportOrdersJob::dispatch($orders, $request->user()->id);
  635. return redirect()->route('order.index', session('gp_orders'))
  636. ->with(['success' => 'Задача выгрузки создана!']);
  637. }
  638. public function exportOne(Order $order, Request $request)
  639. {
  640. ExportOneOrderJob::dispatch($order, $request->user()->id);
  641. return redirect()->route('order.show', $order->id)
  642. ->with(['success' => 'Задача выгрузки создана!']);
  643. }
  644. public function downloadTechDocs(Order $order): BinaryFileResponse
  645. {
  646. $techDocsPath = public_path('images/tech-docs');
  647. $articles = $order->products_sku
  648. ->pluck('product.article')
  649. ->unique()
  650. ->filter()
  651. ->values();
  652. if ($articles->isEmpty()) {
  653. abort(404, 'Нет МАФов на площадке');
  654. }
  655. $tempFile = tempnam(sys_get_temp_dir(), 'tech_docs_');
  656. if ($tempFile === false) {
  657. abort(500, 'Не удалось создать временный файл архива');
  658. }
  659. $zip = new ZipArchive();
  660. $result = $zip->open($tempFile, ZipArchive::CREATE | ZipArchive::OVERWRITE);
  661. if ($result !== true) {
  662. @unlink($tempFile);
  663. abort(500, 'Не удалось создать архив документации');
  664. }
  665. $filesAdded = 0;
  666. foreach ($articles as $article) {
  667. $articlePath = $techDocsPath . '/' . $article;
  668. if (!is_dir($articlePath)) {
  669. continue;
  670. }
  671. $files = new \RecursiveIteratorIterator(
  672. new \RecursiveDirectoryIterator($articlePath, \RecursiveDirectoryIterator::SKIP_DOTS),
  673. \RecursiveIteratorIterator::LEAVES_ONLY
  674. );
  675. foreach ($files as $file) {
  676. if ($file->isFile()) {
  677. $relativePath = $article . '/' . $file->getFilename();
  678. $zip->addFile($file->getRealPath(), $relativePath);
  679. $filesAdded++;
  680. }
  681. }
  682. }
  683. if (!$filesAdded) {
  684. $zip->addFromString('readme.txt', 'Нет документации для этих МАФ!');
  685. }
  686. $zip->close();
  687. // WebView clients are more reliable with ASCII attachment names.
  688. $archiveName = 'tech_docs_order_' . $order->id . '_' . Str::slug((string)$order->object_address) . '.zip';
  689. $archiveName = trim($archiveName, '._');
  690. if ($archiveName === '.zip' || $archiveName === 'zip' || $archiveName === '') {
  691. $archiveName = 'tech_docs_order_' . $order->id . '.zip';
  692. }
  693. return response()->download($tempFile, $archiveName, [
  694. 'Content-Type' => 'application/zip',
  695. ])->deleteFileAfterSend(true);
  696. }
  697. }