fyy 删除 还有测试 传感器设备的代码

app/Http/Controllers/Api/DeleteOrderController.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+
+use App\Service\DeleteOrderService;
+use Illuminate\Http\Request;
+use Symfony\Component\Process\Process;
+
+
+class DeleteOrderController extends BaseController
+{
+    public function del(Request $request)
+    {
+        $service = new DeleteOrderService();
+        list($status,$data) = $service->del($request->all());
+
+        if($status){
+            return $this->json_return(200,'',$data);
+        }else{
+            return $this->json_return(201,$data);
+        }
+    }
+
+    public function test(){
+        ini_set('default_charset', 'UTF-8');
+        $process = Process::fromShellCommandline('php D:\phpstudy_pro\WWW\cs.php');
+        //$process->run();//等待外部命令执行完毕
+        $process->start();
+        dump("直接输出222不等待！");
+
+        if ($process->isSuccessful()) {
+            dump($process->getOutput() . '1');
+        } else {
+            dump($process->getErrorOutput() . '2');
+        }dump(1);die;
+    }
+}

app/Http/Controllers/Api/TestController.php

@@ -6,6 +6,7 @@ namespace App\Http\Controllers\Api;
 use App\Model\BoxDetail;
 use App\Service\MeasureService;
 use Illuminate\Http\Request;
+use Illuminate\Support\Facades\DB;
 
 
 class TestController extends BaseController
@@ -63,7 +64,14 @@ class TestController extends BaseController
 //    }
 
 
-
+public function testData(Request $request){
+        date_default_timezone_set('PRC');
+        $arr = ['title' => json_encode($request->all()),
+            'crt_time' => date('Y-m-d H:i:s')
+        ];
+        DB::table('test_shebei')->insert($arr);
+//        DB::table('test_shebei')->insert(['title' => '2223354']);
+}
 
 
 

app/Service/DeleteOrderService.php

@@ -0,0 +1,306 @@
+<?php
+
+namespace App\Service;
+
+use App\Model\Dispatch;
+use App\Model\DispatchSub;
+use App\Model\FinishedOrder;
+use App\Model\FinishedOrderScrapp;
+use App\Model\FinishedOrderSub;
+use App\Model\Orders;
+use App\Model\OrdersProduct;
+use App\Model\OrdersProductBom;
+use App\Model\OrdersProductMain;
+use App\Model\OrdersProductProcess;
+use App\Model\SaleOrdersProduct;
+use Illuminate\Support\Facades\DB;
+
+class DeleteOrderService extends Service
+{
+    public function del($data){
+        if($this->isEmpty($data,'id')) return [false,'数据必须选择！'];
+        if($this->isEmpty($data,'type')) return [false,'单据类型不能为空！'];
+
+        switch ($data['type']){
+            case 1:
+                list($status,$msg) = $this->delSaleOrdersProduct($data['id']);
+                break;
+            case 2:
+                list($status,$msg) = $this->delOrdersProduct($data['id']);
+                break;
+            case 3:
+                list($status,$msg) = $this->delDispatch($data['id']);
+                break;
+            case 4:
+                list($status,$msg) = $this->delFinished($data['id']);
+                break;
+            default:
+                list($status,$msg) = [false,'删除失败！'];
+        }
+
+        return [$status,$msg];
+    }
+
+    //销售订单删除
+    public function delSaleOrdersProduct($id){
+        $bool = OrdersProduct::where('del_time',0)
+            ->whereIn('sale_orders_product_id',$id)
+            ->exists();
+        if($bool) return [false,'销售订单已生成生产订单，删除失败！'];
+
+        try {
+            DB::beginTransaction();
+
+            //销售订单
+            SaleOrdersProduct::whereIn('id',$id)->update([
+                'del_time' => time()
+            ]);
+
+            //内部订单号与销售订单关联表
+            $subquery = DB::table('sale_orders_product')
+                ->select('order_no')
+                ->whereIn('id',$id);
+            $order_no = DB::table('sale_orders_product')
+                ->select('order_no','del_time')
+                ->joinSub($subquery, 'sub', function ($join) {
+                    $join->on('sale_orders_product.order_no', '=', 'sub.order_no');
+                })->get()->toArray();
+            $update_order = [];
+            if(! empty($order_no)){
+                $tmp = [];
+                foreach ($order_no as $value){
+                    if($value['del_time'] == 0){
+                        $tmp[] = $value['order_no'];
+                    }else{
+                        $update_order[] = $value['order_no'];
+                    }
+                }
+                $tmp = array_unique($tmp);
+                $update_order = array_unique($update_order);
+                $update_order = array_diff($update_order, $tmp);
+            }
+            if(! empty($update_order)) Orders::whereIn('order_no',$update_order)->update(['del_time' => time()]);
+
+            DB::commit();
+        }catch (\Throwable $e){
+            DB::rollBack();
+            return [false,$e->getMessage()];
+        }
+
+        return [true,''];
+    }
+
+    //生产订单删除
+    public function delOrdersProduct($id){
+        $bool = DispatchSub::where('del_time',0)
+            ->whereIn('order_product_id',$id)
+            ->exists();
+        if($bool) return [false,'生产订单已生成派工单，删除失败！'];
+
+        try {
+            DB::beginTransaction();
+
+            //生产订单
+            OrdersProduct::whereIn('id',$id)->update([
+                'del_time' => time()
+            ]);
+
+            //生产订单主表
+            $subquery = DB::table('orders_product')
+                ->select('production_no')
+                ->whereIn('id',$id);
+            $order_no = DB::table('orders_product')
+                ->select('production_no','del_time')
+                ->joinSub($subquery, 'sub', function ($join) {
+                    $join->on('orders_product.production_no', '=', 'sub.production_no');
+                })->get()->toArray();
+            $update_order = [];
+            if(! empty($order_no)){
+                $tmp = [];
+                foreach ($order_no as $value){
+                    if($value['del_time'] == 0){
+                        $tmp[] = $value['production_no'];
+                    }else{
+                        $update_order[] = $value['production_no'];
+                    }
+                }
+                $tmp = array_unique($tmp);
+                $update_order = array_unique($update_order);
+                $update_order = array_diff($update_order, $tmp);
+            }
+            if(! empty($update_order)) OrdersProductMain::whereIn('production_no',$update_order)->update(['del_time' => time()]);
+
+            //生产订单子表
+            $message = OrdersProduct::whereIn('id',$id)->select('out_order_no_time','sale_orders_product_id')->get()->toArray();
+            $time = array_unique(array_column($message,'out_order_no_time'));
+            $arr_time = [];
+            if(! empty($time)){
+                date_default_timezone_set("PRC");
+                foreach ($time as $value){
+                    $time_tmp = date("Ymd", $value);
+                    if(! in_array($time_tmp,$arr_time)) $arr_time[] = $time_tmp;
+                }
+            }
+            if(! empty($arr_time)){
+                foreach ($arr_time as $value){
+                    $modelBom = new OrdersProductBom(['channel'=> $value]);
+                    $modelBom->where('order_product_id',$id)->update(['del_time' => time()]);
+
+                    $modelProcess = new OrdersProductProcess(['channel' => $value]);
+                    $modelProcess->where('order_product_id',$id)->update(['del_time' => time()]);
+                }
+            }
+
+            //销售订单里的已生产数量
+            (new ProductionOrderService())->writeProductionQuantity(array_column($message,'sale_orders_product_id'));
+
+            DB::commit();
+        }catch (\Throwable $e){
+            DB::rollBack();
+            return [false,$e->getMessage()];
+        }
+
+        return [true,''];
+    }
+
+    //派工单删除
+    public function delDispatch($id){
+        $bool = FinishedOrderSub::where('del_time',0)
+            ->whereIn('dispatch_id',$id)
+            ->exists();
+        if($bool) return [false,'工序派工单已生成工序完工单，删除失败！'];
+
+        try {
+            DB::beginTransaction();
+
+            //工序派工单
+            DispatchSub::whereIn('id',$id)->update([
+                'del_time' => time()
+            ]);
+
+            //工序派工单主表
+            $subquery = DB::table('dispatch_sub')
+                ->select('dispatch_no')
+                ->whereIn('id',$id);
+            $order_no = DB::table('dispatch_sub')
+                ->select('dispatch_no','del_time')
+                ->joinSub($subquery, 'sub', function ($join) {
+                    $join->on('dispatch_sub.dispatch_no', '=', 'sub.dispatch_no');
+                })->get()->toArray();
+            $update_order = [];
+            if(! empty($order_no)){
+                $tmp = [];
+                foreach ($order_no as $value){
+                    if($value['del_time'] == 0){
+                        $tmp[] = $value['dispatch_no'];
+                    }else{
+                        $update_order[] = $value['dispatch_no'];
+                    }
+                }
+                $tmp = array_unique($tmp);
+                $update_order = array_unique($update_order);
+                $update_order = array_diff($update_order, $tmp);
+            }
+            if(! empty($update_order)) Dispatch::whereIn('dispatch_no',$update_order)->update(['del_time' => time()]);
+
+            //工序表
+            $message = DispatchSub::whereIn('id',$id)->select('out_order_no_time','sale_orders_product_id','dispatch_no','dispatch_quantity','order_product_id','process_id')->get()->toArray();
+            if(! empty($message)){
+                date_default_timezone_set("PRC");
+                foreach ($message as $value){
+                    $tmp_time = date('Ymd',$value['out_order_no_time']);
+                    $modelProcess = new OrdersProductProcess(['channel' => $tmp_time]);
+                    $modelProcess->where('order_product_id',$value['order_product_id'])
+                        ->where('process_id',$value['process_id'])
+                        ->where('dispatch_no',$value['dispatch_no'])
+                        ->take($value['dispatch_quantity'])
+                        ->update([
+                            'dispatch_no' => '',
+                            'status' => 0
+                        ]);
+                }
+            }
+
+            //已派工数量
+            (new DispatchService())->writeDispatchQuantity(array_column($message,'order_product_id'));
+
+            DB::commit();
+        }catch (\Throwable $e){
+            DB::rollBack();
+            return [false,$e->getMessage()];
+        }
+
+        return [true,''];
+    }
+
+    //完工单删除
+    public function delFinished($id){
+        try {
+            DB::beginTransaction();
+
+            //工序完工单
+            FinishedOrderSub::whereIn('id',$id)->update([
+                'del_time' => time()
+            ]);
+
+            //工序完工单主表
+            $subquery = DB::table('finished_order_sub')
+                ->select('finished_no')
+                ->whereIn('id',$id);
+            $order_no = DB::table('finished_order_sub')
+                ->select('finished_no','del_time')
+                ->joinSub($subquery, 'sub', function ($join) {
+                    $join->on('finished_order_sub.finished_no', '=', 'sub.finished_no');
+                })->get()->toArray();
+            $update_order = [];
+            if(! empty($order_no)){
+                $tmp = [];
+                foreach ($order_no as $value){
+                    if($value['del_time'] == 0){
+                        $tmp[] = $value['finished_no'];
+                    }else{
+                        $update_order[] = $value['finished_no'];
+                    }
+                }
+                $tmp = array_unique($tmp);
+                $update_order = array_unique($update_order);
+                $update_order = array_diff($update_order, $tmp);
+            }
+            if(! empty($update_order)) {
+                FinishedOrder::from('finished_order as a')
+                    ->leftJoin('finished_order_scrapp as b','b.finished_order_id','a.id')
+                    ->whereIn('a.finished_no',$update_order)
+                    ->update(['a.del_time' => time(),'b.del_time' => time()]);
+            }
+
+            //工序表
+            $message = FinishedOrderSub::whereIn('id',$id)->select('out_order_no_time','finished_no','finished_num','order_product_id','process_id','dispatch_no','sale_orders_product_id')->get()->toArray();
+            if(! empty($message)){
+                date_default_timezone_set("PRC");
+                foreach ($message as $value){
+                    $tmp_time = date('Ymd',$value['out_order_no_time']);
+                    $modelProcess = new OrdersProductProcess(['channel' => $tmp_time]);
+                    $modelProcess->where('order_product_id',$value['order_product_id'])
+                        ->where('process_id',$value['process_id'])
+                        ->where('finished_no',$value['finished_no'])
+                        ->where('dispatch_no',$value['dispatch_no'])
+                        ->take($value['finished_num'])
+                        ->update([
+                            'finished_no' => '',
+                            'status' => 1
+                        ]);
+                }
+            }
+
+            //已完工数量
+            (new FinishedOrderService())->writeFinishedQuantity(array_column($message,'sale_orders_product_id'));
+
+            DB::commit();
+        }catch (\Throwable $e){
+            DB::rollBack();
+            return [false,$e->getMessage()];
+        }
+
+        return [true,''];
+    }
+}

app/Service/FinishedOrderService.php

@@ -83,8 +83,6 @@ class FinishedOrderService extends Service
                         'finished_no' => $finished_no,
                         'status' => 2
                     ]);
-
-                unset($result[$key]['order_product_id']);
             }
 
             FinishedOrderSub::insert($result);

routes/api.php

@@ -20,6 +20,7 @@ Route::middleware('auth:api')->get('/user', function (Request $request) {
 Route::any('login', 'Api\LoginController@login');
 Route::any('loginMobile', 'Api\LoginController@loginMobile');
 Route::any('test', 'Api\TestController@aa');
+Route::any('testData','Api\TestController@testData');
 Route::any('getHeaderWord', 'Api\HeaderWordController@getHeaderWord');
 Route::any('deviceList', 'Api\Device\DeviceController@deviceList');
 Route::group(['middleware'=> ['checkLogin']],function ($route){
@@ -130,6 +131,9 @@ Route::group(['middleware'=> ['checkLogin']],function ($route){
     $route->any('finishedOrderDel', 'Api\FinishedOrderController@del');
     $route->any('finishedOrderList', 'Api\FinishedOrderController@orderList');
 
+    //删除单据统一入口
+    $route->any('delOrders','Api\DeleteOrderController@del');
+
     $route->any('productList', 'Api\MaterialController@productList');
     $route->any('productEdit', 'Api\MaterialController@edit');
     $route->any('productAdd', 'Api\MaterialController@edd');