baoshi-was/app/Http/Controllers/StoreCheckingReceiveController.php

<?php

namespace App\Http\Controllers;

use App\Imports\StoreCheckingReceiveImport;
use App\Services\CommodityService;
use App\Services\LogService;
use App\Services\OracleDocAsnDetailService;
use App\Services\StoreCheckingReceiveService;
use App\StoreCheckingReceive;
use Exception;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\Http;
use Maatwebsite\Excel\Facades\Excel;

class StoreCheckingReceiveController extends Controller
{
    public function mission(Request $request){
        if(!Gate::allows('入库管理-盘收一体-盘收-查看')){ return redirect(url('/'));  }
        /** @var StoreCheckingReceiveService $service */
        $service = app('storeCheckingReceiveService');

        $params = $request->input();
        $storeCheckingReceives = $service->paginate($params);
        $owners = app('ownerService')->getSelection();
        return view('store.checkingReceive.mission',compact('storeCheckingReceives','params','owners'));
    }

    public function import(Request $request){
        if(!Gate::allows('入库管理-盘收一体-盘收-编辑')){ return ['success'=>false, 'data'=>'无权操作！'];  }
        $fileSuffix=$request->file('file')->getClientOriginalExtension();
        if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
            return ['success'=>false,'data'=>'不支持该文件类型'];
        $isCovering = $request->input('isCovering');
        ini_set('max_execution_time',2500);
        ini_set('memory_limit','1526M');
        $fileSuffix = ucwords($fileSuffix);
        Excel::import(new StoreCheckingReceiveImport($isCovering),$request->file('file')->path(),null,$fileSuffix);
        if (Cache::has('storeCheckingReceive')){
            return Cache::pull('storeCheckingReceive');
        }
        return ["success"=>false, "data"=>"读取导入文件错误"];
    }

    public function show($id,Request $request){
        if(!Gate::allows('入库管理-盘收一体-盘收-查看')){ return redirect(url('/'));  }
        /** @var StoreCheckingReceiveService $service */
        $service = app('storeCheckingReceiveService');
        $storeCheckingReceive = $service->find($id);
        $is_show = $request->is_show ?? true;

        if ($storeCheckingReceive->owner ?? false){
            $commodityController = new CommodityController();
            $commodityController->syncOwnerCommodities($storeCheckingReceive->owner->id, $storeCheckingReceive->owner->code);
        }

        return view('store.checkingReceive.show',compact('storeCheckingReceive','is_show'));
    }

    public function insertItem(Request $request){
        if(!Gate::allows('入库管理-盘收一体-盘收-查看')){ return ['success'=>false, 'data'=>'无权操作！'];  }
        $mission_id = $request->mission_id ?? false;
        $goods = $request->goods ?? false;
        if (!($goods["amount"] ?? false))$goods["amount"] = 1;
        if (!$mission_id || !$goods)return ['success'=>false, 'data'=>'参数传递错误！'];
        $storeCheckingReceive = app('storeCheckingReceiveService')->find($mission_id);
        if (!$storeCheckingReceive)return ['success'=>false, 'data'=>'盘收任务不存在'];
        if ($storeCheckingReceive->status == '已收货')return ['success'=>false, 'data'=>'盘收任务已结束'];

        $storeCheckingReceiveItem = null;
        $is_receive_diff = "否";
        $is_asn_diff = "否";
        $is_inventory_complete = true;
        foreach ($storeCheckingReceive->storeCheckingReceiveItems as $item){
            if (!$item->commodity)continue;
            if (count($item->commodity->barcodes) < 1)continue;
            foreach ($item->commodity->barcodes as $barcode){
                if ($barcode->code == $goods['barcode']){
                    if ($goods['batch_number'] == $item->batch_code &&
                        $goods['produce_date'] == $item->produced_at &&
                        $goods['valid_date'] == $item->invalid_at){
                        $storeCheckingReceiveItem = $item;
                        break;
                    }
                }
            }
            if ($storeCheckingReceiveItem)continue;
            if ($item->imported_diff_amount > 0)$is_receive_diff = "是";
            if (!$item->counted_amount)$is_inventory_complete = false;
        }

        if ($storeCheckingReceiveItem){
            $counted_amount = $storeCheckingReceiveItem->counted_amount+$goods['amount'];
            $params = ['counted_amount'=>$counted_amount];
            if (!$storeCheckingReceiveItem->imported_amount){
                $params['imported_amount'] = 0;
                $params['imported_diff_amount'] = $counted_amount;
            }else $params['imported_diff_amount'] = abs($counted_amount-$storeCheckingReceiveItem->imported_amount);
            if ($storeCheckingReceiveItem->asn_amount)$params['asn_diff_amount'] = abs($counted_amount-$storeCheckingReceiveItem->asn_amount);
            if (!$storeCheckingReceiveItem->bin_number && $goods['bin_number'])$params['bin_number'] = $goods['bin_number'];

            if (isset($params['imported_diff_amount']) && $params['imported_diff_amount'] > 0)$is_receive_diff = "是";
            if (isset($params['asn_diff_amount']) && $params['asn_diff_amount'] > 0)$is_asn_diff = "是";
            $item = app('storeCheckingReceiveItemService')->updateFind($storeCheckingReceiveItem,$params);
            LogService::log(__METHOD__,"清点数量",json_encode($item,JSON_UNESCAPED_UNICODE));

            switch ($storeCheckingReceive->status){
                case '已导入':
                    $SCR = app('storeCheckingReceiveService')->updateFind($storeCheckingReceive,['status'=>'清点中']);
                    LogService::log(__METHOD__,"修改盘收任务状态为清点中",json_encode($SCR,JSON_UNESCAPED_UNICODE));
                    break;
                case '清点中':
                    $res = [];
                    if ($is_inventory_complete){
                        $res['status']='已清点';
                    }
                    //差异存在时 判断差异是否变化，变化则更新，差异不存在时 判断差异是否存在 存在则更新
                    if (($storeCheckingReceive->is_receive_diff && $storeCheckingReceive->is_receive_diff != $is_receive_diff)
                        || (!$storeCheckingReceive->is_receive_diff && isset($params['imported_diff_amount'])))
                        $res['is_receive_diff'] = $is_receive_diff;
                    if (($storeCheckingReceive->is_asn_diff && $storeCheckingReceive->is_asn_diff != $is_asn_diff)
                        || (!$storeCheckingReceive->is_asn_diff && isset($params['asn_diff_amount'])))
                        $res['is_receive_diff'] = $is_receive_diff;
                    if (count($res) > 0){
                        $SCR = app('storeCheckingReceiveService')->updateFind($storeCheckingReceive,$res);
                        LogService::log(__METHOD__,"修改盘收任务",json_encode($SCR,JSON_UNESCAPED_UNICODE));
                    }
                    break;
            }
            return ['success'=>true, 'type'=>"update", 'data'=>$item];
        }
        $commodity_barcode = app('commodityBarcodeService')->first([
            'code' => $goods['barcode'],
        ]);
        if (!$commodity_barcode) return ['success'=>false, 'data'=>'该条码未找到对应商品'];
        $item = app('storeCheckingReceiveItemService')->create([
            'store_checking_receive_id' => $mission_id,
            'bin_number' => $goods['bin_number'],
            'commodity_id' => $commodity_barcode->commodity_id,
            'imported_amount' => 0,
            'imported_diff_amount' => $goods['amount'],
            'produced_at' => $goods['produce_date'],
            'invalid_at' => $goods['valid_date'],
            'batch_code' => $goods['batch_number'],
            'counted_amount' => $goods['amount'],
        ]);
        $item->load(['commodity'=>function($query){
            $query->with('barcodes');
        }]);
        switch ($storeCheckingReceive->status){
            case '已导入':
                $SCR = app('storeCheckingReceiveService')->updateFind($storeCheckingReceive,['status'=>'清点中']);
                LogService::log(__METHOD__,"修改盘收任务状态为清点中",json_encode($SCR,JSON_UNESCAPED_UNICODE));
                break;
            case '清点中':
                $res = [];
                if ($is_inventory_complete){
                    $res['status']='已清点';
                }
                //差异存在时 判断差异是否变化，变化则更新，差异不存在时 判断差异是否存在 存在则更新
                if ($is_receive_diff == "否")$is_receive_diff = $item->imported_diff_amount>0 ? "是" : "否";
                if ($storeCheckingReceive->is_receive_diff != $is_receive_diff)
                    $res['is_receive_diff'] = $is_receive_diff;
                if ($storeCheckingReceive->is_asn_diff && ($storeCheckingReceive->is_asn_diff != $is_asn_diff))
                    $res['is_receive_diff'] = $is_receive_diff;
                if (count($res) > 0){
                    $SCR = app('storeCheckingReceiveService')->updateFind($storeCheckingReceive,$res);
                    LogService::log(__METHOD__,"修改盘收任务",json_encode($SCR,JSON_UNESCAPED_UNICODE));
                }
                break;
        }
        return ['success'=>true, 'type'=>'create', 'data'=>$item];
    }

    public function export(Request $request){
        if(!Gate::allows('入库管理-盘收一体-盘收-查看')){ return redirect(url('/'));  }
        $id = $request->mission_id ?? false;
        $storeCheckingReceive = app('storeCheckingReceiveService')->find($id);

        if (!$storeCheckingReceive) new \Exception('盘收任务不存在');

        $row = ['ID','格口号','商品名','商品条码','导入数量','实盘数量','ASN数量','导入差异数','ASN差异数','生产日期','有效日期','批次号','唯一码'];
        $list = [];
        foreach ($storeCheckingReceive->storeCheckingReceiveItems as $item){
            $code = '';
            foreach ($item->commodity ? $item->commodity->barcodes : [] as $barcode){
                $code .= $barcode->code;
            }
            $list[] = [
                $item->id,
                $item->bin_number,
                $item->commodity ? $item->commodity->name : '',
                $code,
                $item->imported_amount,
                $item->counted_amount,
                $item->asn_amount,
                $item->imported_diff_amount,
                $item->asn_diff_amount,
                $item->produced_at,
                $item->invalid_at,
                $item->batch_code,
                $item->unique_code,
            ];
        }
        $post = Http::post(config('go.export.url'),['type'=>'base','data'=>json_encode([
            'row'=>$row,'list'=>$list
        ],JSON_UNESCAPED_UNICODE)]);
        if ($post->status() == 500){
            throw new Exception($post->header("Msg"));
        }
        return response($post,200, [
            "Content-type"=>"application/octet-stream",
            "Content-Disposition"=>"attachment; filename=盘收任务详情-".date('ymdHis').'.xlsx',
        ]);
    }

    public function resetAmount(Request $request){
        if(!Gate::allows('入库管理-盘收一体-盘收-编辑')){ return ['success'=>false, 'data'=>'无权操作!'];  }
        $id = $request->mission_id ?? false;
        if (!$id) return ['success'=>false, 'data'=>'盘收任务不存在'];

        app('storeCheckingReceiveItemService')->update(['store_checking_receive_id'=>$id],[
            'counted_amount'=>0,
            'imported_diff_amount'=>null,
            'asn_diff_amount'=>null,
        ]);
        LogService::log(__METHOD__,"重置盘收任务所有数量","store_checking_receive_id:".$id);
        return ['success'=>true];
    }

    public function matchASN(Request $request){
        if(!Gate::allows('入库管理-快速入库-录入')){ return ['success'=>false, 'data'=>'无权操作!'];  }
        $asn = $request->asn ?? false;
        $id = $request->mission_id ?? false;
        if (!$asn || !$id)return ['success'=>false, 'data'=>'传递参数错误'];

        $storeCheckingReceive = app('storeCheckingReceiveService')->find($id);
        if (!$storeCheckingReceive) return ['success'=>false, 'data'=>'未找到此盘点任务!'];
        if ($storeCheckingReceive->status == '已收货')return ['success'=>false, 'data'=>'盘收任务已结束'];

        /** @var OracleDocAsnDetailService $oracleDocAsnDetailService */
        $oracleDocAsnDetailService = app('oracleDocAsnDetailService');
        $docAsnDetails = $oracleDocAsnDetailService->get([
            'asnno'=>$asn,
            'customerid'=>$storeCheckingReceive->owner ? $storeCheckingReceive->owner->code : null],[
                'asnno','customerid','asnlineno','sku','expectedqty'
        ]);
        if (count($docAsnDetails) < 1) return ['success'=>false, 'data'=>'该货主下此ASN号不存在'];

        $diffAmount = 0;
        $skus = [];
        foreach ($docAsnDetails as $detail){
            if ($skus[$detail->sku] ?? false) $skus[$detail->sku] += $detail->expectedqty;
            else $skus[$detail->sku] = $detail->expectedqty;
        }
        $deleteItems = [];
        $updateItems = [];
        $updateItems[] = ['id','asn_amount','asn_diff_amount'];
        foreach ($storeCheckingReceive->storeCheckingReceiveItems as $item){
            if (!($item->commodity ? $item->commodity->sku : null))continue;
            if ($storeCheckingReceive->asn && ($item->asn_amount != null)
                && (!($item->counted_amount ?? false))){
                $deleteItems[] = $item->id;
                continue;
            }
            if ($skus[$item->commodity->sku] ?? false){
                $asn_diff_amount = abs($skus[$item->commodity->sku] - $item->counted_amount);
                $updateItems[] = [
                    'id'=>$item->id,
                    'asn_amount'=>$skus[$item->commodity->sku],
                    'asn_diff_amount'=>$asn_diff_amount,
                ];
                $item->asn_diff_amount = $asn_diff_amount;
                unset($skus[$item->commodity->sku]);
            }
            $diffAmount += $item->asn_diff_amount;
        }
        if (count($updateItems) > 0){
            app('storeCheckingReceiveItemService')->batchUpdate($updateItems);
            LogService::log(__METHOD__,"匹配ASN-批量更新ASN数量",json_encode($updateItems));
        }

        if (count($deleteItems) > 0){
            app('storeCheckingReceiveItemService')->destroy($deleteItems);
            LogService::log(__METHOD__,"重新匹配ASN-删除原有ASN生成数据",json_encode($updateItems));
        }


        if (count($skus) > 0){
            $skuArr = array_keys($skus);
            /** @var CommodityService $commodityService */
            $commodityService = app('commodityService');
            $commodities = $commodityService->get(['owner_id'=>$storeCheckingReceive->owner ? $storeCheckingReceive->owner->id : null,'sku'=>$skuArr]);
            $createItems = [];
            foreach ($commodities as $commodity){
                $createItems[] = [
                    'store_checking_receive_id' => $storeCheckingReceive->id,
                    'commodity_id' => $commodity->id,
                    'imported_amount' => 0,
                    'counted_amount' => 0,
                    'asn_amount' => $skus[$commodity->sku],
                    'imported_diff_amount' => 0,
                    'asn_diff_amount' => $skus[$commodity->sku],
                ];
                $diffAmount += $skus[$commodity->sku];
            }

            if (count($createItems) > 0)app('storeCheckingReceiveItemService')->insert($createItems);
        }
        $data = app('storeCheckingReceiveService')->updateFind($storeCheckingReceive,[
            'asn'=>$asn,'is_asn_diff'=>$diffAmount==0 ? "否" : "是",'status'=>'已ASN入库'
        ]);
        LogService::log(__METHOD__,"修改盘收任务",json_encode($data,JSON_UNESCAPED_UNICODE));
        return ['success'=>true, 'data'=>$data];
    }

    public function receipt(Request $request){
        if(!Gate::allows('入库管理-快速入库-录入')){ return redirect(url('/'));  }
        $id = $request->id ?? false;

        /** @var StoreCheckingReceiveService $storeCheckingReceiveService */
        $storeCheckingReceiveService = app('storeCheckingReceiveService');
        /** @var StoreCheckingReceive $storeCheckingReceive */
        $storeCheckingReceive = $storeCheckingReceiveService->find($id);
        if (!$storeCheckingReceive)return ['success'=>false, 'data'=>'盘收任务不存在'];
        if ($storeCheckingReceive->status == '已收货')return ['success'=>false, 'data'=>'盘收任务已结束'];

        $storeController = new StoreController();
        $result = $storeController->quickStorage($storeCheckingReceive->asn,"正品",null);
        if ($result['success']) $data = $storeCheckingReceiveService->updateFind($storeCheckingReceive,['status'=>"已收货"]);
        else{
            $data = $storeCheckingReceiveService->updateFind($storeCheckingReceive,['status'=>"收货失败"]);
            LogService::log(__METHOD__,"盘收快速收货失败",json_encode($result['data'],JSON_UNESCAPED_UNICODE)." | ".json_encode($data,JSON_UNESCAPED_UNICODE));
        }
        return ['success'=>true, 'data'=>$data];
    }
}