hcsl/app/Service/FyySqlServerService.php

<?php

namespace App\Service;

use App\Model\Orders;
use App\Model\SaleOrdersProduct;
use Illuminate\Support\Facades\Config;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Redis;

class FyySqlServerService extends Service
{
    public $db = null;
    public $error = null;

    public function __construct()
    {
        $fyy_array = Redis::get('fyy_sql_server');
        if(empty($fyy_array)) {
            $this->error = 'SQLSERVER设置不存在！';
            return;
        }
        $fyy_array = json_decode($fyy_array,true);

        if(! $this->db){
            $config = [
                'driver' => 'sqlsrv',
                'host' =>  $fyy_array['sqlserver_host'] ?? '',
                'port' => $fyy_array['sqlserver_port'] ?? '',
                'database' => $fyy_array['sqlserver_database'] ?? '',
                'username' => env('SQLSRV_USERNAME'),
                'password' => env('SQLSRV_PASSWORD'),
            ];

            // 进行数据库连接
            Config::set('database.connections.sqlsrvs', $config);

            try {
                $pdo = DB::connection('sqlsrvs')->getPdo();
                if ($pdo instanceof \PDO) {
                    // 连接成功的逻辑代码
                    $this->db = DB::connection('sqlsrvs');
                } else {
                    $this->error = '连接失败！';
                    return;
                }

            } catch (\Throwable $e) {
                $this->error = $e->getMessage();
            }
        }
    }

    private function fakeData(){
        $return = [
            [
                'out_order_no' => '001',
                'out_order_no_time' => 1685928995,
                'customer_no' => '201603012',
                'customer_name' => '巴大胡',
                'table_header_mark' => '表头备注',
                'product_no' => '产品编码001',
                'product_title' => '产品名称001',
                'product_size' => '产品规格30c',
                'product_unit' => '产品单位米',
                'order_quantity' => 100,
                'product_quantity_on_hand' => 50,
                'technology_material' => '工艺材质',
                'technology_name' => '工艺名称：同命',
                'wood_name' => '木皮名称：梭梭树皮',
                'process_mark' => '加工备注',
                'table_body_mark' => '表体备注',
                'out_crt_man' => '外部人员一',
                'out_checker_man' => '外部人员二',
                'out_checker_time' => 1685928995,
            ],
            [
                'out_order_no' => '001',
                'out_order_no_time' => 1685928995,
                'customer_no' => '201603012',
                'customer_name' => '巴大胡',
                'table_header_mark' => '表头备注',
                'product_no' => '产品编码002',
                'product_title' => '产品名称002',
                'product_size' => '产品规格30d',
                'product_unit' => '产品单位米',
                'order_quantity' => 100,
                'product_quantity_on_hand' => 50,
                'technology_material' => '工艺材质',
                'technology_name' => '工艺名称：同命',
                'wood_name' => '木皮名称：梭梭树皮',
                'process_mark' => '加工备注',
                'table_body_mark' => '表体备注',
                'out_crt_man' => '外部人员一',
                'out_checker_man' => '外部人员二',
                'out_checker_time' => 1685928995,
            ],
            [
                'out_order_no' => '002',
                'out_order_no_time' => 1685928995,
                'customer_no' => '201603012',
                'customer_name' => '巴大胡',
                'table_header_mark' => '表头备注',
                'product_no' => '产品编码002',
                'product_title' => '产品名称002',
                'product_size' => '产品规格30d',
                'product_unit' => '产品单位米',
                'order_quantity' => 100,
                'product_quantity_on_hand' => 50,
                'technology_material' => '工艺材质',
                'technology_name' => '工艺名称：同命',
                'wood_name' => '木皮名称：梭梭树皮',
                'process_mark' => '加工备注',
                'table_body_mark' => '表体备注',
                'out_crt_man' => '外部人员一',
                'out_checker_man' => '外部人员二',
                'out_checker_time' => 1685928995,
            ],
        ];
        return $return;
    }

    public function is_same_month($timestamp1,$timestamp2){
        date_default_timezone_set("PRC");

        // 格式化时间戳为年份和月份
        $year1 = date('Y', $timestamp1);
        $month1 = date('m', $timestamp1);

        $year2 = date('Y', $timestamp2);
        $month2 = date('m', $timestamp2);

        if ($year1 === $year2 && $month1 === $month2) {
            return true;
        } else {
            return false;
        }
    }

    //获取数据（点击引入）
    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,'制单日期必须同月！',''];

        //查询产品主表副表数据
        date_default_timezone_set("PRC");
        $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])
            ->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');

        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(! $status) return [false,$msg,''];

        //查询附带的一些信息（比较少）
        $product_no = array_column($result,'product_no');
        $messageOne = $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)
            ->select('a.cInvCode as product_no','a.cInvName as product_title','a.cInvStd as product_size','b.cComUnitName as product_unit')
            ->get()->toArray();
        $messageMap = array_column($messageOne,null,'product_no');

        //现存量查询开始 ---组织查询条件
        $args = '';
        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 ');

        $messageTwo = $this->db->table('CurrentStock as a')
            ->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')
            ->get()->toArray();

        if(! empty($messageTwo)){
            foreach ($messageTwo as $key => $value){
                $messageTwo[$key] = (array)$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 ?? '';
            $result[$key]->process_mark = $value->process_mark ?? '';
            $result[$key]->table_body_mark = $value->table_body_mark ?? '';
            $result[$key]->table_header_mark = $value->table_header_mark ?? '';

            $keys = $value->product_no . $value->technology_name . $value->wood_name;
            $result[$key]->out_order_no_time = $value->out_order_no_time ? strtotime($value->out_order_no_time) : 0;
            $result[$key]->out_checker_time = $value->out_checker_time ? strtotime($value->out_checker_time) : 0;
            $result[$key]->product_title = $messageMap[$value->product_no]->product_title ?? '';
            $result[$key]->product_size = $messageMap[$value->product_no]->product_size ?? '';
            $result[$key]->product_unit = $messageMap[$value->product_no]->product_unit ?? '';
            $result[$key] = (array)$value;
        }

        return [true,$result,$messageTwo];
    }

    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();
        if(! empty($result))  return [false,'查询区间内销售订单号已存在'];

        return [true,''];
    }

    //获取数据（刷新现存量）
    public function getDataFromSqlServerForOnHand($data){
        if(! empty($this->error)) return [false,$this->error,''];

        if(empty($data['id'])) return [false,'数据不能为空！',''];

        $product = SaleOrdersProduct::whereIn('id',$data['id'])
            ->select('product_no','technology_name','wood_name')
            ->get()->toArray();

        //现存量查询开始 ---组织查询条件
        $args = '';
        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 ');

        $message = $this->db->table('CurrentStock as a')
            ->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')
            ->get()->toArray();

        if(! empty($message)){
            foreach ($message as $key => $value){
                $message[$key] = (array)$value;
            }
        }
        //现存量查询结束

        return [true,$message,$product];
    }
}