OrderController.php 35 KB

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