关联员工工资优化

application/api/controller/RelatedSalaryAccounting.php

@@ -88,56 +88,80 @@ class RelatedSalaryAccounting extends Api
             ->join('人事_基本资料 n', 'n.员工编号 = r.关联员工')
             ->where('r.日期', 'between', [$start_time, $end_time])
             ->where('n.所在部门', $req['department'])
-            ->group('LEFT(j.sczl_rq, 10), j.bh')
-            ->column('CONCAT(j.bh, "-", DATE_FORMAT(j.sczl_rq,"%Y.%m.%d")) AS rq_bh,r.关联员工, j.bh, sum(j.个人计件工资) as 个人计件工资, sum(j.个人加班工资) as 个人加班工资,
+            ->group('LEFT(j.sczl_rq, 10), j.bh , r.关联员工')
+            ->column('CONCAT(j.bh, "-", DATE_FORMAT(j.sczl_rq,"%Y.%m.%d"),"-",r.关联员工) AS rq_bh,r.关联员工, j.bh, sum(j.个人计件工资) as 个人计件工资, sum(j.个人加班工资) as 个人加班工资,
             sum(j.异常停机工时) as 异常停机工时, DATE_FORMAT(j.sczl_rq,"%Y.%m.%d") as 日期');
 
-        $arr = [];
+//        $arr = [];
+//        $columns = ['wgjs_bh1', 'wgjs_bh2', 'wgjs_bh3', 'wgjs_bh4', 'wgjs_bh5', 'wgjs_bh6'];
+//        for ($i = 1; $i <= 6; $i++) {
+//            $column = $columns[$i-1];
+//            $r = db('db_wgjs')
+//                ->field("DATE_FORMAT(wgjs_rq,'%Y.%m.%d') as wgjs_rq, $column as wgjs_bh, 人事_关联工资设置.关联员工, wgjs_js$i as wgjs_js, wgjs_冲定额$i as wgjs_冲定额")
+//                ->join('人事_关联工资设置', "人事_关联工资设置.被关联员工=db_wgjs.$column and 人事_关联工资设置.日期 = db_wgjs.wgjs_rq")
+//                ->join('人事_基本资料', "人事_基本资料.员工编号=人事_关联工资设置.关联员工")
+//                ->where(['人事_关联工资设置.日期' => ['between', "$start_time,$end_time"], '人事_基本资料.所在部门' => $req['department']])
+//                ->group('wgjs_rq,人事_关联工资设置.关联员工,wgjs_bh')
+//                ->select();
+//            $arr = array_merge($arr, $r);
+//        }
+
+        $unionQueries = [];
         $columns = ['wgjs_bh1', 'wgjs_bh2', 'wgjs_bh3', 'wgjs_bh4', 'wgjs_bh5', 'wgjs_bh6'];
-        for ($i = 1; $i <= 6; $i++) {
-            $column = $columns[$i-1];
-            $r = db('db_wgjs')
-                ->field("DATE_FORMAT(wgjs_rq,'%Y.%m.%d') as wgjs_rq, $column as wgjs_bh, 人事_关联工资设置.关联员工, wgjs_js$i as wgjs_js, wgjs_冲定额$i as wgjs_冲定额")
-                ->join('人事_关联工资设置', "人事_关联工资设置.被关联员工=db_wgjs.$column and 人事_关联工资设置.日期 = db_wgjs.wgjs_rq")
-                ->join('人事_基本资料', "人事_基本资料.员工编号=人事_关联工资设置.关联员工")
-                ->where(['人事_关联工资设置.日期' => ['between', "$start_time,$end_time"], '人事_基本资料.所在部门' => $req['department']])
-                ->select();
-            // $r = db('db_wgjs')
-            //     ->field("DATE_FORMAT(wgjs_rq,'%Y.%m.%d') as wgjs_rq, $column as wgjs_bh, 人事_关联工资设置.关联员工, wgjs_js$i as wgjs_js, wgjs_冲定额$i as wgjs_冲定额")
-            //     ->join('人事_基本资料', "人事_基本资料.员工编号=db_wgjs.$column")
-            //     ->join('人事_关联工资设置', "人事_关联工资设置.被关联员工=db_wgjs.$column and 人事_关联工资设置.日期 = db_wgjs.wgjs_rq")
-            //     ->where(['wgjs_rq' => ['between', "$start_time,$end_time"], '人事_基本资料.所在部门' => ['like', $req['department'] . '%']])
-            //     ->select();
-            $arr = array_merge($arr, $r);
+
+        foreach ($columns as $index => $column) {
+            $i = $index + 1;
+            $query = db('db_wgjs')
+                ->field("
+            DATE_FORMAT(wgjs_rq,'%Y.%m.%d') as wgjs_rq, 
+            $column as wgjs_bh, 
+            人事_关联工资设置.关联员工, 
+            wgjs_js{$i} as wgjs_js, 
+            wgjs_冲定额{$i} as wgjs_冲定额
+        ")
+                ->join('人事_关联工资设置', "人事_关联工资设置.被关联员工 = db_wgjs.{$column} and 人事_关联工资设置.日期 = db_wgjs.wgjs_rq")
+                ->join('人事_基本资料', "人事_基本资料.员工编号 = 人事_关联工资设置.关联员工")
+                ->where([
+                    '人事_关联工资设置.日期' => ['between', "$start_time,$end_time"],
+                    '人事_基本资料.所在部门' => $req['department']
+                ])
+                ->group('wgjs_rq, 人事_关联工资设置.关联员工, wgjs_bh')
+                ->buildSql();
+
+            $unionQueries[] = $query;
         }
-        
+
+        $sql = implode(' UNION ALL ', $unionQueries);
+        $arr = db()->query($sql);
+
+
         //wgjs员工每日时长统计
         $list = [];
         foreach($arr as $v){
-            if(isset($list[$v['wgjs_bh'].'-'.$v['wgjs_rq']])){
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['异常停机工时']+=$v['wgjs_js'];
+            if(isset($list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']])){
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['异常停机工时']+=$v['wgjs_js'];
             }else{
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['关联员工']=$v['关联员工'];
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['bh']=$v['wgjs_bh'];
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['个人计件工资']=0;
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['个人加班工资']=0;
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['异常停机工时']=$v['wgjs_js'];
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['日期']=$v['wgjs_rq'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['关联员工']=$v['关联员工'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['bh']=$v['wgjs_bh'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['个人计件工资']=0;
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['个人加班工资']=0;
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['异常停机工时']=$v['wgjs_js'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['日期']=$v['wgjs_rq'];
             }
         };
-        
+
         //wgjs员工冲定额时长统计
         $list1 = [];
         foreach($arr as $v){
-            if(isset($list1[$v['wgjs_bh']])){
+            if(isset($list1[$v['wgjs_bh'].'-'.$v['关联员工']])){
                 if($v['wgjs_冲定额']=='是'){
-                    $list1[$v['wgjs_bh']] += $v['wgjs_js'];
+                    $list1[$v['wgjs_bh'].'-'.$v['关联员工']] += $v['wgjs_js'];
                 }
             }else{
                 if($v['wgjs_冲定额']=='是'){
-                    $list1[$v['wgjs_bh']] = $v['wgjs_js'];
+                    $list1[$v['wgjs_bh'].'-'.$v['关联员工']] = $v['wgjs_js'];
                 }else{
-                    $list1[$v['wgjs_bh']] = 0;
+                    $list1[$v['wgjs_bh'].'-'.$v['关联员工']] = 0;
                 }
             }
         };
@@ -173,7 +197,7 @@ class RelatedSalaryAccounting extends Api
             ->where(['r.所在部门'=>['like',$req['department'].'%']])
             ->group('j.bh,j.sczl_rq,j.sczl_gdbh')
             ->select();
-            
+
         //计算每条记录的计时补差
         $brr = [];
         foreach($arr2 as $v){
@@ -182,7 +206,7 @@ class RelatedSalaryAccounting extends Api
             $yjsss = $yjsss1 + $yjsss2;
 
             $a = $yjsss/$arr1[$v['bh']]/11*0.6*$v['达标定额']*$v['Rate']*0.5/1000*$v['千件工价'];
-                
+
             if(array_key_exists($v['bh'].'-'.$v['sczl_rq'],$brr)){
                 $brr[$v['bh'].'-'.$v['sczl_rq']] += $a;
             }else{
@@ -190,6 +214,7 @@ class RelatedSalaryAccounting extends Api
             }
         }
 
+
         $data = [];
         foreach($gz as $v){
             if (!isset($data[$v['关联员工']][$v['日期']])) {
@@ -204,13 +229,14 @@ class RelatedSalaryAccounting extends Api
             $data[$v['关联员工']][$v['日期']]['个人加班工资'] += (float) $v['个人加班工资'];
             
             $data[$v['关联员工']][$v['日期']]['定额补差'] += array_key_exists($v['bh'].'-'.$v['日期'],$brr) ? floatval(number_format($brr[$v['bh'].'-'.$v['日期']],2, '.', '')) : 0;
-            if(array_key_exists($v['bh'].'-'.$v['日期'],$list)){
-                $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format(($v['异常停机工时'] + $list[$v['bh'].'-'.$v['日期']]['异常停机工时'])*9.5,2, '.', ''));
+            if(array_key_exists($v['bh'].'-'.$v['日期'].'-'.$v['关联员工'],$list)){
+                $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format(($v['异常停机工时'] + $list[$v['bh'].'-'.$v['日期'].'-'.$v['关联员工']]['异常停机工时'])*9.5,2, '.', ''));
                 unset($list[$v['bh'].'-'.$v['日期']]);
             }else{
                 $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format($v['异常停机工时']*9.5,2, '.', ''));
             }
         }
+
         foreach($list as $v){
             if(array_key_exists($v['关联员工'],$data) && array_key_exists($v['日期'],$data[$v['关联员工']])){
                 $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format($v['异常停机工时']*9.5,2, '.', ''));
@@ -231,6 +257,7 @@ class RelatedSalaryAccounting extends Api
             ->where(['日期'=>['between',"$start_time,$end_time"],'人事_基本资料.所在部门'=>['like',$req['department'].'%']])
             ->order('关联员工,日期')
             ->select();
+
         foreach($res as $k=>&$v){
             if(isset($data[$v['员工编号']][$v['日期']])){
                 $v['关联计件工资'] = floatval(number_format($data[$v['员工编号']][$v['日期']]['个人计件工资']/$v['关联人数']*$v['关联系数'],2, '.', ''));
@@ -238,15 +265,18 @@ class RelatedSalaryAccounting extends Api
                 $v['关联定额补差'] = floatval(number_format($data[$v['员工编号']][$v['日期']]['定额补差']/$v['关联人数']*$v['关联系数'],2, '.', ''));
                 $v['关联计时工资'] = floatval(number_format($data[$v['员工编号']][$v['日期']]['计时工资']/$v['关联人数']*$v['关联系数'],2, '.', ''));
                 $v['关联工资合计'] = floatval(number_format(
-                    ($data[$v['员工编号']][$v['日期']]['个人计件工资'] + 
-                    $data[$v['员工编号']][$v['日期']]['个人加班工资'] +
-                    $data[$v['员工编号']][$v['日期']]['定额补差'] + 
-                    $data[$v['员工编号']][$v['日期']]['计时工资']
+                    ($data[$v['员工编号']][$v['日期']]['个人计件工资'] +
+                        $data[$v['员工编号']][$v['日期']]['个人加班工资'] +
+                        $data[$v['员工编号']][$v['日期']]['定额补差'] +
+                        $data[$v['员工编号']][$v['日期']]['计时工资']
                     )/$v['关联人数']*$v['关联系数'],2, '.', ''));
             }else{
                 unset($res[$k]);
             }
+
+
         }
+
         $res = array_values($res);
         if($res===false){
             $this->error('失败');
@@ -368,7 +398,7 @@ class RelatedSalaryAccounting extends Api
             $yjsss = $yjsss1 + $yjsss2;
 
             $a = $yjsss/$arr1[$v['bh']]/11*0.6*$v['达标定额']*$v['Rate']*0.5/1000*$v['千件工价'];
-                
+
             if(array_key_exists($v['bh'].'-'.$v['sczl_rq'],$brr)){
                 $brr[$v['bh'].'-'.$v['sczl_rq']] += $a;
             }else{
@@ -493,7 +523,7 @@ class RelatedSalaryAccounting extends Api
             ->where('n.所在部门', 'like', $req['department'] . '%')
             ->where('r.关联员工', 'like', '%' . $req['search'] . '%')
             ->group('LEFT(j.sczl_rq, 10), j.bh')
-            ->column('CONCAT(j.bh, "-", DATE_FORMAT(j.sczl_rq,"%Y.%m.%d")) AS rq_bh,r.关联员工, j.bh, sum(j.个人计件工资) as 个人计件工资, sum(j.个人加班工资) as 个人加班工资,
+            ->column('CONCAT(j.bh, "-", DATE_FORMAT(j.sczl_rq,"%Y.%m.%d"),"-",r.关联员工 ) AS rq_bh,r.关联员工, j.bh, sum(j.个人计件工资) as 个人计件工资, sum(j.个人加班工资) as 个人加班工资,
             sum(j.异常停机工时) as 异常停机工时, DATE_FORMAT(j.sczl_rq,"%Y.%m.%d") as 日期');
         $arr = [];
         $columns = ['wgjs_bh1', 'wgjs_bh2', 'wgjs_bh3', 'wgjs_bh4', 'wgjs_bh5', 'wgjs_bh6'];
@@ -505,27 +535,21 @@ class RelatedSalaryAccounting extends Api
                 ->join('人事_基本资料', "人事_基本资料.员工编号=人事_关联工资设置.关联员工")
                 ->where(['人事_关联工资设置.日期' => ['between', "$start_time,$end_time"], '人事_基本资料.所在部门' => ['like', $req['department'] . '%']])
                 ->select();
-            // $r = db('db_wgjs')
-            //     ->field("DATE_FORMAT(wgjs_rq,'%Y.%m.%d') as wgjs_rq, $column as wgjs_bh, 人事_关联工资设置.关联员工, wgjs_js$i as wgjs_js, wgjs_冲定额$i as wgjs_冲定额")
-            //     ->join('人事_基本资料', "人事_基本资料.员工编号=db_wgjs.$column")
-            //     ->join('人事_关联工资设置', "人事_关联工资设置.被关联员工=db_wgjs.$column and 人事_关联工资设置.日期 = db_wgjs.wgjs_rq")
-            //     ->where(['wgjs_rq' => ['between', "$start_time,$end_time"], '人事_基本资料.所在部门' => ['like', $req['department'] . '%']])
-            //     ->select();
             $arr = array_merge($arr, $r);
         }
         
         //wgjs员工每日时长统计
         $list = [];
         foreach($arr as $v){
-            if(isset($list[$v['wgjs_bh'].'-'.$v['wgjs_rq']])){
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['异常停机工时']+=$v['wgjs_js'];
+            if(isset($list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']])){
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['异常停机工时']+=$v['wgjs_js'];
             }else{
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['关联员工']=$v['关联员工'];
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['bh']=$v['wgjs_bh'];
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['个人计件工资']=0;
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['个人加班工资']=0;
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['异常停机工时']=$v['wgjs_js'];
-                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq']]['日期']=$v['wgjs_rq'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['关联员工']=$v['关联员工'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['bh']=$v['wgjs_bh'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['个人计件工资']=0;
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['个人加班工资']=0;
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['异常停机工时']=$v['wgjs_js'];
+                $list[$v['wgjs_bh'].'-'.$v['wgjs_rq'].'-'.$v['关联员工']]['日期']=$v['wgjs_rq'];
             }
         };
         
@@ -607,8 +631,8 @@ class RelatedSalaryAccounting extends Api
             $data[$v['关联员工']][$v['日期']]['个人加班工资'] += (float) $v['个人加班工资'];
             
             $data[$v['关联员工']][$v['日期']]['定额补差'] += array_key_exists($v['bh'].'-'.$v['日期'],$brr) ? floatval(number_format($brr[$v['bh'].'-'.$v['日期']],2, '.', '')) : 0;
-            if(array_key_exists($v['bh'].'-'.$v['日期'],$list)){
-                $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format(($v['异常停机工时'] + $list[$v['bh'].'-'.$v['日期']]['异常停机工时'])*9.5,2, '.', ''));
+            if(array_key_exists($v['bh'].'-'.$v['日期'].'-'.$v['关联员工'],$list)){
+                $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format(($v['异常停机工时'] + $list[$v['bh'].'-'.$v['日期'].'-'.$v['关联员工']]['异常停机工时'])*9.5,2, '.', ''));
                 unset($list[$v['bh'].'-'.$v['日期']]);
             }else{
                 $data[$v['关联员工']][$v['日期']]['计时工资'] += floatval(number_format($v['异常停机工时']*9.5,2, '.', ''));