fyy

app/Service/FyyOrderService.php

@@ -442,11 +442,9 @@ class FyyOrderService extends Service
 
         $sqlServerModel = new FyySqlServerService($user);
         if($sqlServerModel->error) return [false,$sqlServerModel->error];
-
         //映射ip是否通畅
         $bool = $this->isDomainAvailable($sqlServerModel->host);
         if(! $bool) return [false, "U8程序外部域名不可达,请重新操作"];
-
         $result = $sqlServerModel->getDataFromDispatchListPage($data);
 
         return [true,$result];

app/Service/FyySqlServerService.php

@@ -31,64 +31,65 @@ class FyySqlServerService extends Service
 
     public function __construct($user_id = [])
     {
-        //用户信息校验
-        if(empty($user_id['id'])) {
-            $this->error = '福羊羊数据库连接用户参数不能为空！';
-            return;
-        }
-        //账套
-        $zt = Request()->header('zt');
-        if(! $zt && isset($user_id['zt'])) $zt = $user_id['zt'];
-        $this->database = $this->database_select[$zt] ?? '';
-        $this->sAccID = '(default)@' . $zt;
-
-        //获取用友账号密码
-        if(isset($user_id['zt'])){
-            $database = (new FinishedOrderService())->getConnectionName($user_id['zt']);
-            $model = new Employee();
-            $model->setConnection($database);
-            $emp = $model->where('id',$user_id['id'])->select('sqlserver_account','sqlserver_password')->first();
-        }else{
-            $emp = Employee::where('id',$user_id['id'])->select('sqlserver_account','sqlserver_password')->first();
-        }
-        if(empty($emp)) {
-            $this->error = '福羊羊连接构造失败！';
-            return;
-        }
-        //用友接口统一登录账号密码
-        $this->sUserID = $emp->sqlserver_account ?? '';
-        $this->sPassword = $emp->sqlserver_password ?? '';
-
-        //之前测试留下的入口  现在没用
-        $key = 'fyy_sql_server' . $user_id['id'];
-        $fyy_array = Redis::get($key);
-        if(! empty($fyy_array)) {
-            $fyy_array = json_decode($fyy_array,true);
-            if(! empty($fyy_array['sqlserver_database'])) $this->database = $this->database_select[$fyy_array['sqlserver_zt']];
-            if(! empty($fyy_array['sqlserver_zt'])) $this->sAccID = '(default)@' . $fyy_array['sqlserver_zt'];
-            if(! empty($fyy_array['sqlserver_host'])) $this->host = $fyy_array['sqlserver_host'];
-            if(! empty($fyy_array['sqlserver_host_api'])) $this->host_api = $fyy_array['sqlserver_host_api'];
-            if(! empty($fyy_array['sqlserver_port'])) $this->port = $fyy_array['sqlserver_port'];
-            if(! empty($fyy_array['sqlserver_account'])) $this->sUserID = $fyy_array['sqlserver_account'];
-            if(! empty($fyy_array['sqlserver_password'])) $this->sPassword = $fyy_array['sqlserver_password'];
-        }
-        $this->url = $this->host_api . "/U8Sys/U8API";
-        //----------
-
-        if(! $this->db){
-            $config = [
-                'driver' => 'sqlsrv',
-                'host' =>  $this->host,
-                'port' => $this->port,
-                'database' => $this->database,
-                'username' => env('SQLSRV_USERNAME'),
-                'password' => env('SQLSRV_PASSWORD'),
-            ];
+        try {
+            //用户信息校验
+            if (empty($user_id['id'])) {
+                $this->error = '福羊羊数据库连接用户参数不能为空！';
+                return;
+            }
+            //账套
+            $zt = Request()->header('zt');
+            if (!$zt && isset($user_id['zt'])) $zt = $user_id['zt'];
+            $this->database = $this->database_select[$zt] ?? '';
+            $this->sAccID = '(default)@' . $zt;
+
+            //获取用友账号密码
+            if (isset($user_id['zt'])) {
+                $database = (new FinishedOrderService())->getConnectionName($user_id['zt']);
+                $model = new Employee();
+                $model->setConnection($database);
+                $emp = $model->where('id', $user_id['id'])->select('sqlserver_account', 'sqlserver_password')->first();
+            } else {
+                $emp = Employee::where('id', $user_id['id'])->select('sqlserver_account', 'sqlserver_password')->first();
+            }
+            if (empty($emp)) {
+                $this->error = '福羊羊连接构造失败！';
+                return;
+            }
+            //用友接口统一登录账号密码
+            $this->sUserID = $emp->sqlserver_account ?? '';
+            $this->sPassword = $emp->sqlserver_password ?? '';
+
+            //之前测试留下的入口  现在没用
+            $key = 'fyy_sql_server' . $user_id['id'];
+            $fyy_array = Redis::get($key);
+            if (!empty($fyy_array)) {
+                $fyy_array = json_decode($fyy_array, true);
+                if (!empty($fyy_array['sqlserver_database'])) $this->database = $this->database_select[$fyy_array['sqlserver_zt']];
+                if (!empty($fyy_array['sqlserver_zt'])) $this->sAccID = '(default)@' . $fyy_array['sqlserver_zt'];
+                if (!empty($fyy_array['sqlserver_host'])) $this->host = $fyy_array['sqlserver_host'];
+                if (!empty($fyy_array['sqlserver_host_api'])) $this->host_api = $fyy_array['sqlserver_host_api'];
+                if (!empty($fyy_array['sqlserver_port'])) $this->port = $fyy_array['sqlserver_port'];
+                if (!empty($fyy_array['sqlserver_account'])) $this->sUserID = $fyy_array['sqlserver_account'];
+                if (!empty($fyy_array['sqlserver_password'])) $this->sPassword = $fyy_array['sqlserver_password'];
+            }
+            $this->url = $this->host_api . "/U8Sys/U8API";
+            //----------
+
+            if (!$this->db) {
+                $config = [
+                    'driver' => 'sqlsrv',
+                    'host' => $this->host,
+                    'port' => $this->port,
+                    'database' => $this->database,
+                    'username' => env('SQLSRV_USERNAME'),
+                    'password' => env('SQLSRV_PASSWORD'),
+                ];
+
+                // 进行数据库连接
+                Config::set('database.connections.sqlsrvs', $config);
 
-            // 进行数据库连接
-            Config::set('database.connections.sqlsrvs', $config);
 
-            try {
                 $pdo = DB::connection('sqlsrvs')->getPdo();
                 if ($pdo instanceof \PDO) {
                     // 连接成功的逻辑代码
@@ -97,15 +98,15 @@ class FyySqlServerService extends Service
                     $this->error = '连接失败！';
                     return;
                 }
-
-            } catch (\Throwable $e) {
-                $this->error = $e->getMessage();
             }
+        } catch (\Throwable $e) {
+            $this->error = $e->getMessage();
         }
     }
 
     //假数据
-    private function fakeData(){
+    private function fakeData()
+    {
         $return = [
             [
                 'out_order_no' => '001',
@@ -174,7 +175,8 @@ class FyySqlServerService extends Service
         return $return;
     }
 
-    public function is_same_month($timestamp1,$timestamp2){
+    public function is_same_month($timestamp1, $timestamp2)
+    {
 
 
         // 格式化时间戳为年份和月份
@@ -192,43 +194,44 @@ class FyySqlServerService extends Service
     }
 
     //获取数据（点击引入）
-    public function getDataFromSqlServer($data){
-        if(! empty($this->error)) return [false,$this->error,''];
+    public function getDataFromSqlServer($data)
+    {
+        if (!empty($this->error)) return [false, $this->error, ''];
 
-        if(empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false,'制单日期不能为空！',''];
-        $bool = $this->is_same_month($data['out_order_no_time'][0],$data['out_order_no_time'][1]);
-        if(! $bool) return [false,'制单日期必须同月！',''];
+        if (empty($data['out_order_no_time'][0]) || empty($data['out_order_no_time'][1])) return [false, '制单日期不能为空！', ''];
+        $bool = $this->is_same_month($data['out_order_no_time'][0], $data['out_order_no_time'][1]);
+        if (!$bool) return [false, '制单日期必须同月！', ''];
 
         //查询产品主表副表数据
 
-        $start = date('Y-m-d H:i:s.000',$data['out_order_no_time'][0]);
-        $end = date('Y-m-d H:i:s.000',$data['out_order_no_time'][1]);
+        $start = date('Y-m-d H:i:s.000', $data['out_order_no_time'][0]);
+        $end = date('Y-m-d H:i:s.000', $data['out_order_no_time'][1]);
         $model = $this->db->table('SO_SOMain as a')
-            ->leftJoin('SO_SODetails as b','b.cSOCode','a.cSOCode')
-            ->whereBetween('a.dDate',[$start, $end])
+            ->leftJoin('SO_SODetails as b', 'b.cSOCode', 'a.cSOCode')
+            ->whereBetween('a.dDate', [$start, $end])
             ->whereNotNull('a.cVerifier')
-            ->select('a.cSOCode as out_order_no','a.dDate as out_order_no_time','a.cCusCode as customer_no','a.cCusName as customer_name','a.cMemo as table_header_mark','a.cMaker as out_crt_man','a.cVerifier as out_checker_man','a.dverifydate as out_checker_time','b.cInvCode as product_no','b.iQuantity as order_quantity','b.cDefine28 as technology_material','b.cFree1 as technology_name','b.cFree2 as wood_name','b.cDefine30 as process_mark','b.cMemo as table_body_mark','b.iTaxUnitPrice as price');
-
-        if(! empty($data['out_order_no'])) $model->where('a.cSOCode', 'LIKE', '%'.$data['out_order_no'].'%');
-        if(! empty($data['customer_no'])) $model->where('a.cCusCode', 'LIKE', '%'.$data['customer_no'].'%');
-        if(! empty($data['customer_name'])) $model->where('a.cCusName', 'LIKE', '%'.$data['customer_name'].'%');
-        if(! empty($data['table_header_mark'])) $model->where('a.cMemo', 'LIKE', '%'.$data['table_header_mark'].'%');
-        if(! empty($data['out_crt_man'])) $model->where('a.cMaker', 'LIKE', '%'.$data['out_crt_man'].'%');
-        if(! empty($data['out_checker_man'])) $model->where('a.cVerifier', 'LIKE', '%'.$data['out_checker_man'].'%');
-        if(! empty($data['out_checker_time'][0]) && ! empty($data['out_checker_time'][1])) {
-            $start1 = date('Y-m-d H:i:s.000',$data['out_checker_time'][0]);
-            $end1 = date('Y-m-d H:i:s.000',$data['out_checker_time'][1]);
-            $model->whereBetween('a.dverifydate',[$start1, $end1]);
+            ->select('a.cSOCode as out_order_no', 'a.dDate as out_order_no_time', 'a.cCusCode as customer_no', 'a.cCusName as customer_name', 'a.cMemo as table_header_mark', 'a.cMaker as out_crt_man', 'a.cVerifier as out_checker_man', 'a.dverifydate as out_checker_time', 'b.cInvCode as product_no', 'b.iQuantity as order_quantity', 'b.cDefine28 as technology_material', 'b.cFree1 as technology_name', 'b.cFree2 as wood_name', 'b.cDefine30 as process_mark', 'b.cMemo as table_body_mark', 'b.iTaxUnitPrice as price');
+
+        if (!empty($data['out_order_no'])) $model->where('a.cSOCode', 'LIKE', '%' . $data['out_order_no'] . '%');
+        if (!empty($data['customer_no'])) $model->where('a.cCusCode', 'LIKE', '%' . $data['customer_no'] . '%');
+        if (!empty($data['customer_name'])) $model->where('a.cCusName', 'LIKE', '%' . $data['customer_name'] . '%');
+        if (!empty($data['table_header_mark'])) $model->where('a.cMemo', 'LIKE', '%' . $data['table_header_mark'] . '%');
+        if (!empty($data['out_crt_man'])) $model->where('a.cMaker', 'LIKE', '%' . $data['out_crt_man'] . '%');
+        if (!empty($data['out_checker_man'])) $model->where('a.cVerifier', 'LIKE', '%' . $data['out_checker_man'] . '%');
+        if (!empty($data['out_checker_time'][0]) && !empty($data['out_checker_time'][1])) {
+            $start1 = date('Y-m-d H:i:s.000', $data['out_checker_time'][0]);
+            $end1 = date('Y-m-d H:i:s.000', $data['out_checker_time'][1]);
+            $model->whereBetween('a.dverifydate', [$start1, $end1]);
         }
 
         $result = $model->get()->toArray();
-        if(empty($result)) return [false,'暂无数据，更新结束！',''];
-        list($status,$msg) = $this->orderRule($result);
-        if(empty($msg)) return [false,'暂无数据，更新结束！',''];
+        if (empty($result)) return [false, '暂无数据，更新结束！', ''];
+        list($status, $msg) = $this->orderRule($result);
+        if (empty($msg)) return [false, '暂无数据，更新结束！', ''];
         $result = $msg;
 
         //查询附带的一些信息（比较少）
-        $product_no = array_filter(array_column($result,'product_no'));
+        $product_no = array_filter(array_column($result, 'product_no'));
         $chunkSize = 1000; // 每个子集的大小
         $chunks = array_chunk($product_no, $chunkSize); // 将原始数组拆分成多个较小的子数组
 
@@ -245,34 +248,34 @@ class FyySqlServerService extends Service
                 ->toArray();
             $results = array_merge($results, $tmp); // 将每个子集的结果合并到总结果数组中
         }
-        $messageMap = array_column($results,null,'product_no');
+        $messageMap = array_column($results, null, 'product_no');
         unset($results);
 
         //现存量查询开始 ---组织查询条件
         $args = '';
-        foreach ($result as $value){
+        foreach ($result as $value) {
             $product = $value->product_no;
             $technology_name = $value->technology_name ?? '';
             $wood_name = $value->wood_name ?? '';
             $args .= "(a.cInvCode = '{$product}' and a.cFree1 = '{$technology_name}' and a.cFree2 = '{$wood_name}') OR ";
         }
-        $args = rtrim($args,'OR ');
+        $args = rtrim($args, 'OR ');
 
         $messageTwo = $this->db->table('CurrentStock as a')
-            ->leftJoin('Warehouse as b','b.cWhCode','a.cWhCode')
+            ->leftJoin('Warehouse as b', 'b.cWhCode', 'a.cWhCode')
             ->whereRaw("($args)")
-            ->where('a.iQuantity','>',0)
-            ->select('a.iQuantity as product_quantity_on_hand','a.cInvCode as product_no','a.cFree1 as technology_name','a.cFree2 as wood_name','b.cWhName as warehouse_name')
+            ->where('a.iQuantity', '>', 0)
+            ->select('a.iQuantity as product_quantity_on_hand', 'a.cInvCode as product_no', 'a.cFree1 as technology_name', 'a.cFree2 as wood_name', 'b.cWhName as warehouse_name')
             ->get()->toArray();
 
-        if(! empty($messageTwo)){
-            foreach ($messageTwo as $key => $value){
+        if (!empty($messageTwo)) {
+            foreach ($messageTwo as $key => $value) {
                 $messageTwo[$key] = (array)$value;
             }
         }
         //现存量查询结束
 
-        foreach ($result as $key => $value){
+        foreach ($result as $key => $value) {
             $result[$key]->technology_material = $value->technology_material ?? '';
             $result[$key]->technology_name = $value->technology_name ?? '';
             $result[$key]->wood_name = $value->wood_name ?? '';
@@ -289,231 +292,238 @@ class FyySqlServerService extends Service
             $result[$key] = (array)$value;
         }
 
-        return [true,$result,$messageTwo];
+        return [true, $result, $messageTwo];
     }
 
-    public function orderRule($data){
-        $result = Orders::where('del_time',0)
-            ->whereIn('out_order_no',array_column($data,'out_order_no'))
+    public function orderRule($data)
+    {
+        $result = Orders::where('del_time', 0)
+            ->whereIn('out_order_no', array_column($data, 'out_order_no'))
             ->select('out_order_no')
             ->get()->toArray();
-        $out_order_no = array_column($result,'out_order_no');
-        if(! empty($out_order_no)) {
-            foreach ($data as $key => $value){
-                if(in_array($value->out_order_no,$out_order_no)){
+        $out_order_no = array_column($result, 'out_order_no');
+        if (!empty($out_order_no)) {
+            foreach ($data as $key => $value) {
+                if (in_array($value->out_order_no, $out_order_no)) {
                     unset($data[$key]);
                 }
             }
         }
 
-        return [true,$data];
+        return [true, $data];
     }
 
     //获取数据（刷新现存量）
-    public function getDataFromSqlServerForOnHand($data){
-        if(! empty($this->error)) return [false,$this->error,''];
+    public function getDataFromSqlServerForOnHand($data)
+    {
+        if (!empty($this->error)) return [false, $this->error, ''];
 
-        if(empty($data['id'])) return [false,'数据不能为空！',''];
+        if (empty($data['id'])) return [false, '数据不能为空！', ''];
 
-        $product = SaleOrdersProduct::whereIn('id',$data['id'])
-            ->select('product_no','technology_name','wood_name')
+        $product = SaleOrdersProduct::whereIn('id', $data['id'])
+            ->select('product_no', 'technology_name', 'wood_name')
             ->get()->toArray();
 
         //现存量查询开始 ---组织查询条件
         $args = '';
-        foreach ($product as $value){
+        foreach ($product as $value) {
             $args .= "(a.cInvCode = '{$value['product_no']}' and a.cFree1 = '{$value['technology_name']}' and a.cFree2 = '{$value['wood_name']}') OR ";
         }
-        $args = rtrim($args,'OR ');
+        $args = rtrim($args, 'OR ');
 
         $message = $this->db->table('CurrentStock as a')
-            ->leftJoin('Warehouse as b','b.cWhCode','a.cWhCode')
+            ->leftJoin('Warehouse as b', 'b.cWhCode', 'a.cWhCode')
             ->whereRaw("($args)")
-            ->where('a.iQuantity','>',0)
-            ->select('a.iQuantity as product_quantity_on_hand','a.cInvCode as product_no','a.cFree1 as technology_name','a.cFree2 as wood_name','b.cWhName as warehouse_name')
+            ->where('a.iQuantity', '>', 0)
+            ->select('a.iQuantity as product_quantity_on_hand', 'a.cInvCode as product_no', 'a.cFree1 as technology_name', 'a.cFree2 as wood_name', 'b.cWhName as warehouse_name')
             ->get()->toArray();
 
-        if(! empty($message)){
-            foreach ($message as $key => $value){
+        if (!empty($message)) {
+            foreach ($message as $key => $value) {
                 $message[$key] = (array)$value;
             }
         }
         //现存量查询结束
 
-        return [true,$message,$product];
+        return [true, $message, $product];
     }
 
     //产成品入库单保存接口以及审核
-    public function U8Rdrecord10Save($data,$bredvouch = 0){
-        if(! empty($this->error)) return [false,$this->error];
+    public function U8Rdrecord10Save($data, $bredvouch = 0)
+    {
+        if (!empty($this->error)) return [false, $this->error];
 
-        if($bredvouch){
+        if ($bredvouch) {
             $cmemo = '来源:福羊羊完工操作撤回';
-        }else{
-            $cmemo = '来源:福羊羊完工操作 派工单号:'. $data['dispatch_no'];
+        } else {
+            $cmemo = '来源:福羊羊完工操作 派工单号:' . $data['dispatch_no'];
         }
 
         //数据
         $bodys[] = [
-            "cinvcode"=> $data["product_no"],
-            "cposition"=> "",
-            "cbatch"=> "",
-            "iquantity"=> $data["quantity"],
-            "inum"=> $data["quantity"],
-            "iunitcost"=> $data["price"] * 0.95,
-            "iprice"=> $data["price"] * 0.95 * $data['quantity'],
-            "iinvexchrate"=> "1.00",
-            "impoids"=> "",
-            "cmocode"=> "",
-            "imoseq"=> "",
-            "cbmemo"=> "",
-            "cfree1"=> $data['technology_name'],
-            "cfree2"=> $data['wood_name'],
+            "cinvcode" => $data["product_no"],
+            "cposition" => "",
+            "cbatch" => "",
+            "iquantity" => $data["quantity"],
+            "inum" => $data["quantity"],
+            "iunitcost" => $data["price"] * 0.95,
+            "iprice" => $data["price"] * 0.95 * $data['quantity'],
+            "iinvexchrate" => "1.00",
+            "impoids" => "",
+            "cmocode" => "",
+            "imoseq" => "",
+            "cbmemo" => "",
+            "cfree1" => $data['technology_name'],
+            "cfree2" => $data['wood_name'],
             "cdefine28" => $data['technology_material'],
         ];
         $post = [
-            "password"=>"cloud@123456",
-            "entity"=>"U8Rdrecord10Save",
-            "login"=>[
-                "sAccID"=> $this->sAccID,
-                "sDate"=> date("Y-m-d"),
-                "sServer"=> '127.0.0.1',
-                "sUserID"=> $this->sUserID,
-                "sSerial"=> "",
-                "sPassword"=> $this->sPassword
+            "password" => "cloud@123456",
+            "entity" => "U8Rdrecord10Save",
+            "login" => [
+                "sAccID" => $this->sAccID,
+                "sDate" => date("Y-m-d"),
+                "sServer" => '127.0.0.1',
+                "sUserID" => $this->sUserID,
+                "sSerial" => "",
+                "sPassword" => $this->sPassword
             ],
-            "data"=>[
-                "ccode"=>'',
-                "ddate"=>date("Y-m-d"),
-                "cmaker"=>$this->sUserID,
-                "dnmaketime"=> date("Y-m-d"),
-                "IsExamine"=>true,
-                "bredvouch"=> $bredvouch,
-                "cwhcode"=>"02",
-                "cdepcode"=>"06",
-                "crdcode"=>"102", //生产入库
-                "cmemo"=> $cmemo,
+            "data" => [
+                "ccode" => '',
+                "ddate" => date("Y-m-d"),
+                "cmaker" => $this->sUserID,
+                "dnmaketime" => date("Y-m-d"),
+                "IsExamine" => true,
+                "bredvouch" => $bredvouch,
+                "cwhcode" => "02",
+                "cdepcode" => "06",
+                "crdcode" => "102", //生产入库
+                "cmemo" => $cmemo,
                 "cdefine10" => $data['customer_name'], //客户名称
-                "bodys"=>$bodys
+                "bodys" => $bodys
             ]
-        ];        file_put_contents('record_ss.txt',json_encode($post) . PHP_EOL,8);
+        ];
+        file_put_contents('record_ss.txt', json_encode($post) . PHP_EOL, 8);
 
-        $return = $this->post_helper($this->url,json_encode($post), ['Content-Type:application/json']);
-        file_put_contents('record_ss.txt',json_encode($return). PHP_EOL,8);
+        $return = $this->post_helper($this->url, json_encode($post), ['Content-Type:application/json']);
+        file_put_contents('record_ss.txt', json_encode($return) . PHP_EOL, 8);
 
-        if(empty($return))  return [false, '异常错误，请确认请求接口地址！'];
+        if (empty($return)) return [false, '异常错误，请确认请求接口地址！'];
         return [$return['flag'], $return['msg']];
     }
 
     //销售出库单保存接口给以及审核
-    public function U8Rdrecord32Save($data,$bredvouch = 0){
-        if(! empty($this->error)) return [false,$this->error];
+    public function U8Rdrecord32Save($data, $bredvouch = 0)
+    {
+        if (!empty($this->error)) return [false, $this->error];
 
-        if($bredvouch){
+        if ($bredvouch) {
             $cmemo = '来源:福羊羊';
-        }else{
+        } else {
             $cmemo = '来源:福羊羊发货出库操作';
         }
 
         $new = [];
-        foreach ($data as $value){
+        foreach ($data as $value) {
             $keys = $value['id'] . $value['cwhcode'];
             $new[$keys][] = $value;
         }
 
-        foreach ($new as $value){
+        foreach ($new as $value) {
             $main_tmp = $value[0];
             $bodys_tmp = [];
-            foreach ($value as $val){
+            foreach ($value as $val) {
                 $bodys_tmp[] = [
-                    "idlsid"=>$val['idlsid'],
-                    "cdlcode"=>"",
-                    "dlrowno"=>"",
-                    "cbdlcode"=>"",
-                    "cinvcode"=>$val['cinvcode'],
-                    "cposition"=>$val['cposition'] ?? "",
-                    "cbatch"=>$val['cbatch'] ?? "",
-                    "iquantity"=>$val['iquantity'],
-                    "inum"=>$val['inum'],
-                    "iinvexchrate"=> $val['iinvexchrate'] ?? 0,
-                    "iunitcost"=>$val['iunitcost'] * 0.95,
-                    "iprice"=>$val['iunitcost'] * 0.95 * $val['iquantity'],
-                    "cbmemo"=>"",
-                    "cfree1"=> $val['cfree1'],
-                    "cfree2"=> $val['cfree2'],
+                    "idlsid" => $val['idlsid'],
+                    "cdlcode" => "",
+                    "dlrowno" => "",
+                    "cbdlcode" => "",
+                    "cinvcode" => $val['cinvcode'],
+                    "cposition" => $val['cposition'] ?? "",
+                    "cbatch" => $val['cbatch'] ?? "",
+                    "iquantity" => $val['iquantity'],
+                    "inum" => $val['inum'],
+                    "iinvexchrate" => $val['iinvexchrate'] ?? 0,
+                    "iunitcost" => $val['iunitcost'] * 0.95,
+                    "iprice" => $val['iunitcost'] * 0.95 * $val['iquantity'],
+                    "cbmemo" => "",
+                    "cfree1" => $val['cfree1'],
+                    "cfree2" => $val['cfree2'],
                     "cdefine28" => $val['technology_material'],
                     "cdefine30" => $val['process_mark'],
                 ];
             }
             $post_tmp = [
-                "password"=>"cloud@123456",
-                "entity"=>"U8Rdrecord32Save",
-                "login"=>[
-                    "sAccID"=> $this->sAccID,
-                    "sDate"=> date("Y-m-d"),
-                    "sServer"=> '127.0.0.1',
-                    "sUserID"=> $this->sUserID,
-                    "sSerial"=> "",
-                    "sPassword"=> $this->sPassword
+                "password" => "cloud@123456",
+                "entity" => "U8Rdrecord32Save",
+                "login" => [
+                    "sAccID" => $this->sAccID,
+                    "sDate" => date("Y-m-d"),
+                    "sServer" => '127.0.0.1',
+                    "sUserID" => $this->sUserID,
+                    "sSerial" => "",
+                    "sPassword" => $this->sPassword
                 ],
-                "data"=>[
-                    "ccode"=>'',
-                    "ddate"=>date("Y-m-d"),
-                    "cmaker"=>$this->sUserID,
-                    "dnmaketime"=> date("Y-m-d"),
-                    "IsExamine"=>true,
-                    "bredvouch"=> $bredvouch,
-                    "cwhcode"=>$main_tmp['cwhcode'],
-                    "cdepcode"=>$main_tmp['cdepcode'],
-                    "ccuscode"=>$main_tmp['cuscode'],
-                    "crdcode"=>'202',
-                    "cmemo"=> $cmemo,
+                "data" => [
+                    "ccode" => '',
+                    "ddate" => date("Y-m-d"),
+                    "cmaker" => $this->sUserID,
+                    "dnmaketime" => date("Y-m-d"),
+                    "IsExamine" => true,
+                    "bredvouch" => $bredvouch,
+                    "cwhcode" => $main_tmp['cwhcode'],
+                    "cdepcode" => $main_tmp['cdepcode'],
+                    "ccuscode" => $main_tmp['cuscode'],
+                    "crdcode" => '202',
+                    "cmemo" => $cmemo,
                     "cdefine10" => $main_tmp['customer_name'], //客户名称
-                    "bodys"=>$bodys_tmp,
+                    "bodys" => $bodys_tmp,
                 ]
             ];
 
-            $return = $this->post_helper($this->url,json_encode($post_tmp), ['Content-Type:application/json']);
-            file_put_contents('record.txt',json_encode($new). PHP_EOL .json_encode($post_tmp) . PHP_EOL,8);
+            $return = $this->post_helper($this->url, json_encode($post_tmp), ['Content-Type:application/json']);
+            file_put_contents('record.txt', json_encode($new) . PHP_EOL . json_encode($post_tmp) . PHP_EOL, 8);
 
-            if(empty($return))  return [false, '异常错误，请确认请求接口地址！'];
-            if(! $return['flag']) return [false,$return['msg']];
+            if (empty($return)) return [false, '异常错误，请确认请求接口地址！'];
+            if (!$return['flag']) return [false, $return['msg']];
         }
 
-        return [true,''];
+        return [true, ''];
     }
 
-    public function getBoxData($data){
+    public function getBoxData($data)
+    {
         $boxData = BoxDetail::from('box_detail as a')
-            ->leftJoin('sale_orders_product as b','b.id','a.top_id')
-            ->where('a.del_time',0)
-            ->where('a.order_no',$data['order_number']) //包装单号
-            ->select('a.num as iquantity','b.product_no as cinvcode','b.technology_name as cfree1','b.wood_name as cfree2','b.out_order_no as cSOCode');
+            ->leftJoin('sale_orders_product as b', 'b.id', 'a.top_id')
+            ->where('a.del_time', 0)
+            ->where('a.order_no', $data['order_number']) //包装单号
+            ->select('a.num as iquantity', 'b.product_no as cinvcode', 'b.technology_name as cfree1', 'b.wood_name as cfree2', 'b.out_order_no as cSOCode');
 
         return $boxData;
     }
 
     //获取发货单数据 还没发的
-    public function getDataFromDispatchList($data){
+    public function getDataFromDispatchList($data)
+    {
         $model = $this->db->table('DispatchList as a')
-            ->leftJoin('DispatchLists as b','b.DLID','a.DLID')
-            ->leftJoin('Inventory as c','c.cInvCode','b.cInvCode')
+            ->leftJoin('DispatchLists as b', 'b.DLID', 'a.DLID')
+            ->leftJoin('Inventory as c', 'c.cInvCode', 'b.cInvCode')
             ->whereNotNull('a.cVerifier');
 //            ->whereColumn('b.iQuantity', '>', 'b.fOutQuantity');
 
         //检索条件
-        if(! empty($data['time'][0]) && ! empty($data['time'][1])) {
-            $model->where('a.dDate','>=',$data['time'][0]);
-            $model->where('a.dDate','<=',$data['time'][1]);
+        if (!empty($data['time'][0]) && !empty($data['time'][1])) {
+            $model->where('a.dDate', '>=', $data['time'][0]);
+            $model->where('a.dDate', '<=', $data['time'][1]);
         }
-        if(! empty($data['order_no'])) $model->where('b.cSOcode',$data['order_no']);
-        if(! empty($data['out_order_no'])) $model->where('b.cSOcode',$data['out_order_no']);
+        if (!empty($data['order_no'])) $model->where('b.cSOcode', $data['order_no']);
+        if (!empty($data['out_order_no'])) $model->where('b.cSOcode', $data['out_order_no']);
 
-        $message = $model->select('a.cDLCode as cdlcode','a.DLID as id','a.cDefine10 as customer_name','b.cSOCode as csocode','a.cDepCode as cdepcode','a.cCusCode as cuscode','b.iDLsID as idlsid','b.cWhCode as cwhcode','b.cInvCode as cinvcode','b.cInvName as product_title','b.cFree1 as cfree1','b.cFree2 as cfree2','b.cPosition as cposition','b.cBatch as cbatch','b.iQuantity as iquantity','b.iNum as inum','b.iInvExchRate as iinvexchrate','b.fOutQuantity as out_quantity','b.iUnitPrice as iunitcost','b.iMoney as imoney','b.cDefine28 as technology_material','b.cDefine30 as process_mark','c.cInvStd as product_size')
+        $message = $model->select('a.cDLCode as cdlcode', 'a.DLID as id', 'a.cDefine10 as customer_name', 'b.cSOCode as csocode', 'a.cDepCode as cdepcode', 'a.cCusCode as cuscode', 'b.iDLsID as idlsid', 'b.cWhCode as cwhcode', 'b.cInvCode as cinvcode', 'b.cInvName as product_title', 'b.cFree1 as cfree1', 'b.cFree2 as cfree2', 'b.cPosition as cposition', 'b.cBatch as cbatch', 'b.iQuantity as iquantity', 'b.iNum as inum', 'b.iInvExchRate as iinvexchrate', 'b.fOutQuantity as out_quantity', 'b.iUnitPrice as iunitcost', 'b.iMoney as imoney', 'b.cDefine28 as technology_material', 'b.cDefine30 as process_mark', 'c.cInvStd as product_size')
             ->get()->toArray();
 
-        if(! empty($message)){
-            foreach ($message as $key => $value){
+        if (!empty($message)) {
+            foreach ($message as $key => $value) {
 //                $message[$key]->iquantity = $value->iquantity - $value->out_quantity;
                 $message[$key] = (array)$value;
             }
@@ -523,110 +533,114 @@ class FyySqlServerService extends Service
     }
 
     //产成品入库单单据号
-    public function createOrderNumberAboutSCRK(){
+    public function createOrderNumberAboutSCRK()
+    {
 
 
         $current_month = date('m'); // 获取当前月份
-        $date1 = date('y') . $current_month  ; // 格式 "2307"
+        $date1 = date('y') . $current_month; // 格式 "2307"
         $date2 = date('Y') . $current_month; // 格式 "202307"
 
         $record = $this->db->table('VoucherHistory')
-            ->where('CardNumber','0411')
+            ->where('CardNumber', '0411')
             ->whereRaw("(cSeed = '{$date1}' or cSeed = '{$date2}')")
             ->select('cNumber')
             ->first();
         $record = (array)$record;
-        if(empty($record)) return [false,'未找到产成品入库当月流水号信息！'];
+        if (empty($record)) return [false, '未找到产成品入库当月流水号信息！'];
 
         $tmp = $record['cNumber'] + 1;
-        if(strlen($tmp) > 4) return [false,'产成品入库当月流水号超过四位数！'];
+        if (strlen($tmp) > 4) return [false, '产成品入库当月流水号超过四位数！'];
 
-        $number = str_pad($tmp,4,'0',STR_PAD_LEFT);
+        $number = str_pad($tmp, 4, '0', STR_PAD_LEFT);
         $number = $tmp . $number;
         $ccode = "SCRK" . $date2 . $number;
 
-        return [true,$ccode];
+        return [true, $ccode];
     }
 
     //销售出库单单据号
-    public function createOrderNumberAboutXC(){
+    public function createOrderNumberAboutXC()
+    {
 
 
         $current_month = date('m'); // 获取当前月份
-        $date1 = date('y') . $current_month  ; // 格式 "2307"
+        $date1 = date('y') . $current_month; // 格式 "2307"
         $date2 = date('Y') . $current_month; // 格式 "202307"
 
         $record = $this->db->table('VoucherHistory')
-            ->where('CardNumber','0303')
+            ->where('CardNumber', '0303')
             ->whereRaw("(cSeed = '{$date1}' or cSeed = '{$date2}')")
             ->select('cNumber')
             ->first();
         $record = (array)$record;
-        if(empty($record)) return [false,'未找到销售出库单当月流水号信息！'];
+        if (empty($record)) return [false, '未找到销售出库单当月流水号信息！'];
 
         $tmp = $record['cNumber'] + 1;
-        if(strlen($tmp) > 4) return [false,'销售出库单当月流水号超过四位数！'];
+        if (strlen($tmp) > 4) return [false, '销售出库单当月流水号超过四位数！'];
 
-        $number = str_pad($tmp,4,'0',STR_PAD_LEFT);
+        $number = str_pad($tmp, 4, '0', STR_PAD_LEFT);
         $number = $tmp . $number;
         $ccode = "XC" . $date2 . $number;
 
-        return [true,$ccode];
+        return [true, $ccode];
     }
 
-    public function post_helper($url, $data,$header = [],$timeout = 60){
+    public function post_helper($url, $data, $header = [], $timeout = 60)
+    {
         $ch = curl_init();
         curl_setopt($ch, CURLOPT_URL, $url);
-        curl_setopt($ch,  CURLOPT_RETURNTRANSFER, true);
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
         curl_setopt($ch, CURLOPT_ENCODING, '');
         curl_setopt($ch, CURLOPT_POST, 1);
         curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
         curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
         curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
         curl_setopt($ch, CURLOPT_TIMEOUT, $timeout);
-        if(!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
+        if (!is_null($data)) curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
         $r = curl_exec($ch);
         curl_close($ch);
         return json_decode($r, true);
     }
 
     //获取发货单数据 还没发的 分页
-    public function getDataFromDispatchListPage($data){
+    public function getDataFromDispatchListPage($data)
+    {
         //检索条件
-        if(empty($data['time'][0]) || empty($data['time'][1])) return [false,'时间不能为空'];
+        if (empty($data['time'][0]) || empty($data['time'][1])) return [false, '时间不能为空'];
 
         $model = $this->db->table('DispatchList as a')
-            ->leftJoin('DispatchLists as b','b.DLID','a.DLID')
-            ->leftJoin('Inventory as c','c.cInvCode','b.cInvCode')
-            ->select('a.cDLCode as cdlcode','a.DLID as id','a.cDefine10 as customer_name','b.cSOCode as csocode','a.cDepCode as cdepcode','a.cCusCode as cuscode','a.dDate as date','b.iDLsID as idlsid','b.cWhCode as cwhcode','b.cInvCode as cinvcode','b.cInvName as product_title','b.cFree1 as cfree1','b.cFree2 as cfree2','b.cPosition as cposition','b.cBatch as cbatch','b.iQuantity as iquantity','b.iNum as inum','b.iInvExchRate as iinvexchrate','b.fOutQuantity as out_quantity','b.iUnitPrice as iunitcost','b.iMoney as imoney','b.cDefine28 as technology_material','b.cDefine30 as process_mark','c.cInvStd as product_size',DB::raw('(b.iQuantity - b.fOutQuantity) as quantity'),'a.cMemo as table_header_mark','b.cMemo as table_body_mark')
+            ->leftJoin('DispatchLists as b', 'b.DLID', 'a.DLID')
+            ->leftJoin('Inventory as c', 'c.cInvCode', 'b.cInvCode')
+            ->select('a.cDLCode as cdlcode', 'a.DLID as id', 'a.cDefine10 as customer_name', 'b.cSOCode as csocode', 'a.cDepCode as cdepcode', 'a.cCusCode as cuscode', 'a.dDate as date', 'b.iDLsID as idlsid', 'b.cWhCode as cwhcode', 'b.cInvCode as cinvcode', 'b.cInvName as product_title', 'b.cFree1 as cfree1', 'b.cFree2 as cfree2', 'b.cPosition as cposition', 'b.cBatch as cbatch', 'b.iQuantity as iquantity', 'b.iNum as inum', 'b.iInvExchRate as iinvexchrate', 'b.fOutQuantity as out_quantity', 'b.iUnitPrice as iunitcost', 'b.iMoney as imoney', 'b.cDefine28 as technology_material', 'b.cDefine30 as process_mark', 'c.cInvStd as product_size', DB::raw('(b.iQuantity - b.fOutQuantity) as quantity'), 'a.cMemo as table_header_mark', 'b.cMemo as table_body_mark')
             ->whereNotNull('a.cVerifier')
 //            ->whereColumn('b.iQuantity', '>', 'b.fOutQuantity')
-            ->where('a.dDate','>=',$data['time'][0])
-            ->where('a.dDate','<=',$data['time'][1]);
-
-        if(! empty($data['cdlcode'])) $model->where('a.cDLCode','Like','%'. $data['cdlcode'] . '%');
-        if(! empty($data['cinvcode'])) $model->where('b.cInvCode','Like','%'. $data['cinvcode'] . '%');
-        if(! empty($data['product_title'])) $model->where('b.cInvName','Like','%'. $data['product_title'] . '%');
-        if(! empty($data['product_size'])) $model->where('c.cInvStd','Like','%'. $data['product_size'] . '%');
-        if(! empty($data['technology_material'])) $model->where('b.cDefine28','Like','%'. $data['technology_material'] . '%');
-        if(! empty($data['cfree1'])) $model->where('b.cFree1','Like','%'. $data['cfree1'] . '%');
-        if(! empty($data['cfree2'])) $model->where('b.cFree2','Like','%'. $data['cfree2'] . '%');
-        if(! empty($data['process_mark'])) $model->where('b.cDefine30','Like','%'. $data['process_mark'] . '%');
-
-        $list = $this->limit($model,'',$data);
-
-        if(! empty($list['data'])){
-            $product_no = array_unique(array_column($list['data'],'cinvcode'));
+            ->where('a.dDate', '>=', $data['time'][0])
+            ->where('a.dDate', '<=', $data['time'][1]);
+
+        if (!empty($data['cdlcode'])) $model->where('a.cDLCode', 'Like', '%' . $data['cdlcode'] . '%');
+        if (!empty($data['cinvcode'])) $model->where('b.cInvCode', 'Like', '%' . $data['cinvcode'] . '%');
+        if (!empty($data['product_title'])) $model->where('b.cInvName', 'Like', '%' . $data['product_title'] . '%');
+        if (!empty($data['product_size'])) $model->where('c.cInvStd', 'Like', '%' . $data['product_size'] . '%');
+        if (!empty($data['technology_material'])) $model->where('b.cDefine28', 'Like', '%' . $data['technology_material'] . '%');
+        if (!empty($data['cfree1'])) $model->where('b.cFree1', 'Like', '%' . $data['cfree1'] . '%');
+        if (!empty($data['cfree2'])) $model->where('b.cFree2', 'Like', '%' . $data['cfree2'] . '%');
+        if (!empty($data['process_mark'])) $model->where('b.cDefine30', 'Like', '%' . $data['process_mark'] . '%');
+
+        $list = $this->limit($model, '', $data);
+
+        if (!empty($list['data'])) {
+            $product_no = array_unique(array_column($list['data'], 'cinvcode'));
             $messageMap = $this->db->table('Inventory as a')
                 ->join('ComputationUnit as b', function ($join) {
                     $join->on('a.cGroupCode', '=', 'b.cGroupCode')
                         ->on('a.cComUnitCode', '=', 'b.cComUnitCode');
                 }, null, null, 'left')
                 ->whereIn('a.cInvCode', $product_no)
-                ->pluck( 'b.cComUnitName as product_unit','a.cInvCode')
+                ->pluck('b.cComUnitName as product_unit', 'a.cInvCode')
                 ->toArray();
 
-            foreach ($list['data'] as $key => $value){
+            foreach ($list['data'] as $key => $value) {
                 $list['data'][$key] = (array)$value;
                 $list['data'][$key]['unit'] = $messageMap[$value->cinvcode] ?? '';
                 $list['data'][$key]['iquantity'] = intval($value->iquantity);