内部市场化

app/Console/Commands/Nbsch.php

@@ -48,184 +48,54 @@ class Nbsch extends Command
 
     public function nbschInsert()
     {
-//        $id_list_data =  DB::connection('mysql_nbsch')->select("SELECT ID
-//                FROM SYS_FLOW_SCHEME S
-//                WHERE EXISTS(
-//                    SELECT ID
-//                    FROM SYS_FLOW_MASTER M
-//                    WHERE EXISTS(
-//                        SELECT 1
-//                        FROM sys_flow_master_dept D
-//                        WHERE M.ID = D.PID
-//                    )
-//                    AND S.PID = M.ID
-//                    AND M.MENU_ID = '5ab7b937-19a0-47d4-b479-b9f58999abc8'
-//                )
-//                AND S.IS_DISABLE = 0");
-//        $id_list = [];
-//        if(count($id_list_data) > 0){
-//            for($i=0;$i<count($id_list_data);$i++){
-//                array_push($id_list,$id_list_data[$i]->ID);
-//            }
-//        }
-//        // dd($id_list);
-//        $bill_id_list = [];
-//        if($id_list > 0){
-//            for($i=0;$i<count($id_list);$i++){
-//                // for($i=0;$i<3;$i++){
-//                $bill_id_data = DB::connection('mysql_nbsch')->table('SYS_FLOW_APPROVAL_RECORD')->where('approve_scheme_id',$id_list[$i])->get(['bill_id', 'approve_node_name']);
-//                if(count($bill_id_data) > 0){
-//                    for($j=0;$j<count($bill_id_data);$j++){
-//                        array_push($bill_id_list,$bill_id_data[$j]);
-//                    }
-//                }
-//            }
-//        }
-//
-//        $grouped = [];
-//        foreach ($bill_id_list as $item) {
-//
-//            $billId = $item->bill_id;
-//
-//            if (!isset($grouped[$billId])) {
-//                $grouped[$billId] = [];
-//            }
-//
-//            $grouped[$billId][] = $item->approve_node_name;
-//        }
-//
-//        $bill_array = [];
-//        foreach ($grouped as $billId => $nodeNames) {
-//            $bill_array[] = [
-//                'bill_id' => $billId,
-//                'approve_flow' => implode(',', array_unique($nodeNames))
-//            ];
-//        }
-//// dd($bill_array);
-//        $filteredResult = array_filter($bill_array, function($item) {
-//            return strpos($item['approve_flow'], '被服务') === false;
-//        });
-//
-//
-//// 重置索引
-//        $filteredResult = array_values($filteredResult);
-//
-//        // dd($filteredResult);
-//        $id_list = [];
-//        foreach($filteredResult as $k=>$v){
-//            array_push($id_list,$v['bill_id']);
-//        }
-//        // dd($id_list);
-//        $master = DB::connection('mysql_nbsch')->table('RT_SERVICE_SETTLEMENT_MASTER')->where('DOCUMENT_DATE','like','%2025-06%')->where('APPROVE_NODE_NAME','已完成')->get(['ID','DOCUMENT_TYPE','DOCUMENT_DATE','SETTLEMENT_SUM_AMOUNT']);
-//
-//        if(count($master) > 0){
-//            for($i=0;$i<count($master);$i++){
-//                $master[$i]->BILL_ID = null;
-//                $master[$i]->isNull = 0;
-//                $master[$i]->riqi = '2025-06';
-//            }
-//            for($i=0;$i<count($master);$i++){
-//                if(count($id_list) > 0){
-//                    for($j=0;$j<count($id_list);$j++){
-//                        // dd($id_list[$j]);
-//                        // dd($master[$i]->ID);
-//                        if($master[$i]->ID == $id_list[$j]){
-//                            $master[$i]->BILL_ID = $id_list[$j];
-//                            $master[$i]->isNull = 1;
-//                        }
-//                    }
-//                }
-//            }
-//        }
-//
-//
-//        $groupedData = [];
-//
-//        foreach ($master as $item) {
-//
-//            $key = $item->DOCUMENT_TYPE;
-//
-//            if (!isset($groupedData[$key])) {
-//                $groupedData[$key] = [
-//                    'DOCUMENT_TYPE' => $item->DOCUMENT_TYPE,
-//                    'DOCUMENT_DATE' => $item->riqi,
-//                    'total_amount' => 0,
-//                    'normal_amount' => 0,
-//                    'null_amount' => 0
-//                ];
-//            }
-//
-//            $groupedData[$key]['total_amount'] += $item->SETTLEMENT_SUM_AMOUNT;
-//
-//            if ($item->isNull == 0) {
-//                $groupedData[$key]['normal_amount'] += $item->SETTLEMENT_SUM_AMOUNT;
-//            } else {
-//                $groupedData[$key]['null_amount'] += $item->SETTLEMENT_SUM_AMOUNT;
-//            }
-//        }
-//
-//        $result = [];
-//        foreach ($groupedData as $item) {
-//            $sptgl_val = $item['total_amount'] > 0 ?
-//                round($item['normal_amount'] / $item['total_amount'] * 100, 2) : 0;
-//
-//            $result[] = [
-//                'DOCUMENT_TYPE' => $item['DOCUMENT_TYPE'],
-//                'DOCUMENT_DATE' => $item['DOCUMENT_DATE'],
-//                'dyjsje' => round($item['total_amount'] / 10000, 2),
-//                'zcspje' => round($item['normal_amount'] / 10000, 2),
-//                'qtje' => round($item['null_amount'] / 10000, 2),
-//                'sptgl' => $sptgl_val . '%',
-//                'sptgl_val' => $sptgl_val
-//            ];
-//        }
-
-        $result = DB::connection('mysql_nbsch')->select("SELECT 
-    a.DOCUMENT_TYPE,
-    DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m') AS DOCUMENT_DATE,
-    ROUND(SUM(a.SETTLEMENT_SUM_AMOUNT) / 10000, 2) AS dyjsje,
-    ROUND((SUM(a.SETTLEMENT_SUM_AMOUNT) - SUM(CASE WHEN a.isNull = '1' THEN a.SETTLEMENT_SUM_AMOUNT ELSE 0 END)) / 10000, 2) AS zcspje,
-    ROUND(SUM(CASE WHEN a.isNull = '1' THEN a.SETTLEMENT_SUM_AMOUNT ELSE 0 END) / 10000, 2) AS qtje,
-    CONCAT(ROUND(SUM(CASE WHEN a.isNull = '0' THEN 1 ELSE 0 END) / COUNT(a.isNull) * 100, 2), '%') AS sptgl,
-    ROUND(SUM(CASE WHEN a.isNull = '0' THEN 1 ELSE 0 END) / COUNT(a.isNull) * 100, 2) AS sptgl_val
-FROM (
-    SELECT 
-        fwjs.*, 
-        (CASE WHEN lcjl.BILL_ID IS NOT NULL THEN '1' ELSE '0' END) AS isNull 
-    FROM RT_SERVICE_SETTLEMENT_MASTER fwjs
-    LEFT JOIN (
-        SELECT * FROM (
+        $result = DB::connection('mysql_nbsch')->select("
             SELECT 
-                BILL_ID,
-                GROUP_CONCAT(approve_node_name ORDER BY approve_node_name SEPARATOR ',') AS lcjdhub 
-            FROM SYS_FLOW_APPROVAL_RECORD 
-            WHERE approve_scheme_id IN (
-                SELECT ID 
-                FROM SYS_FLOW_SCHEME S 
-                WHERE EXISTS(
-                    SELECT ID 
-                    FROM SYS_FLOW_MASTER M 
-                    WHERE EXISTS(
-                        SELECT 1 
-                        FROM sys_flow_master_dept D 
-                        WHERE M.ID = D.PID
-                    ) 
-                    AND S.PID = M.ID 
-                    AND M.MENU_ID = '5ab7b937-19a0-47d4-b479-b9f58999abc8'
-                ) 
-                AND S.IS_DISABLE = 0
-            )
-            GROUP BY BILL_ID
-        ) t 
-        WHERE lcjdhub NOT REGEXP '被服务'
-    ) lcjl ON fwjs.id = lcjl.BILL_ID 
-    WHERE fwjs.APPROVE_NODE_NAME = '已完成' 
-) a 
-WHERE 1=1 AND DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m') = '2025-06'  -- 日期筛选条件
-GROUP BY a.DOCUMENT_TYPE, DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m')
-ORDER BY DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m') DESC");
+                a.DOCUMENT_TYPE,
+                DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m') AS DOCUMENT_DATE,
+                ROUND(SUM(a.SETTLEMENT_SUM_AMOUNT) / 10000, 2) AS dyjsje,
+                ROUND((SUM(a.SETTLEMENT_SUM_AMOUNT) - SUM(CASE WHEN a.isNull = '1' THEN a.SETTLEMENT_SUM_AMOUNT ELSE 0 END)) / 10000, 2) AS zcspje,
+                ROUND(SUM(CASE WHEN a.isNull = '1' THEN a.SETTLEMENT_SUM_AMOUNT ELSE 0 END) / 10000, 2) AS qtje,
+                CONCAT(ROUND(SUM(CASE WHEN a.isNull = '0' THEN 1 ELSE 0 END) / COUNT(a.isNull) * 100, 2), '%') AS sptgl,
+                ROUND(SUM(CASE WHEN a.isNull = '0' THEN 1 ELSE 0 END) / COUNT(a.isNull) * 100, 2) AS sptgl_val
+            FROM (
+                SELECT 
+                    fwjs.*, 
+                    (CASE WHEN lcjl.BILL_ID IS NOT NULL THEN '1' ELSE '0' END) AS isNull 
+                FROM RT_SERVICE_SETTLEMENT_MASTER fwjs
+                LEFT JOIN (
+                    SELECT * FROM (
+                        SELECT 
+                            BILL_ID,
+                            GROUP_CONCAT(approve_node_name ORDER BY approve_node_name SEPARATOR ',') AS lcjdhub 
+                        FROM SYS_FLOW_APPROVAL_RECORD 
+                        WHERE approve_scheme_id IN (
+                            SELECT ID 
+                            FROM SYS_FLOW_SCHEME S 
+                            WHERE EXISTS(
+                                SELECT ID 
+                                FROM SYS_FLOW_MASTER M 
+                                WHERE EXISTS(
+                                    SELECT 1 
+                                    FROM sys_flow_master_dept D 
+                                    WHERE M.ID = D.PID
+                                ) 
+                                AND S.PID = M.ID 
+                                AND M.MENU_ID = '5ab7b937-19a0-47d4-b479-b9f58999abc8'
+                            ) 
+                            AND S.IS_DISABLE = 0
+                        )
+                        GROUP BY BILL_ID
+                    ) t 
+                    WHERE lcjdhub NOT REGEXP '被服务'
+                ) lcjl ON fwjs.id = lcjl.BILL_ID 
+                WHERE fwjs.APPROVE_NODE_NAME = '已完成' 
+            ) a 
+            WHERE 1=1 AND DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m') = '2025-06'  -- 日期筛选条件
+            GROUP BY a.DOCUMENT_TYPE, DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m')
+            ORDER BY DATE_FORMAT(a.DOCUMENT_DATE, '%Y-%m') DESC
+        ");
 
-        Log::info(332211);
+        Log::info('654321');
         Log::info($result);
     }
 }