<?php

namespace app\action;

use libs\listener\Event;
use libs\db\Db;
use Exception;

class SetTrayRebatch
{
    /*
        {
            "action":"set_tray_rebatch",
            "param":{
                "tray":"",
                "workingsubclass":""
            }
        }
        
        1、判断托盘是否存在tray_map表
        2、判断托盘内电池是否存在NG,需要判断托盘next_process_code和电池next_process_code一致（不一致电池默认已被其他工序取出）；不存NG电池则不允许再投
        3、copy再投工序之前工序所有数据
        4、之前工序所有数据新增到bkv表、battery_map表、process_log表
        5、更改之前tray_map表托盘、bkv表电池状态为未激活；process_log表last_status=0
    */
    public function execute($post)
    {
        // 验证数据
        $param = check_valid($post['action'], [
            ['tray', 'string', '托盘号'],
            ['workingsubclass', 'string', '工序单元']
        ], $post['param']);

        try {
            // 1、判断托盘是否存在tray_map表
            $sql = sprintf(
                "SELECT a.tray,a.lot,a.batch,a.subbatch,a.active,a.next_process_code,a.date_log,b.flow_id,c.process
                    FROM hf_mes_production_tray_map AS a
                    INNER JOIN hf_mes_production_planning_management_batch AS b ON b.batch = a.batch
                    INNER JOIN hf_mes_technology_flow AS c ON b.flow_id=c.id
                    WHERE a.tray='%s' ORDER BY a.id DESC LIMIT 1;",
                $param['tray']
            );
            $ret = Db::fetch($sql);
            if (empty($ret)) {
                throw new Exception("托盘[{$param['tray']}]不存在");
            }

            list($tray, $lot, $batch, $subbatch, $active, $next_process_code, $flow_id, $date_log, $workingsubclass, $process) = [
                $ret['tray'],
                $ret['lot'],
                $ret['batch'],
                $ret['subbatch'],
                $ret['active'],
                $ret['next_process_code'],
                $ret['flow_id'],
                json_decode($ret['date_log'], true),
                $param['workingsubclass'],
                json_decode($ret['process'],true)
            ];

            // 2、判断托盘内电池是否存在NG,需要判断托盘next_process_code和电池next_process_code一致（不一致电池默认已被其他工序取出）；不存NG电池则不允许再投
            $sql     = sprintf(
                "SELECT battery_id,class
                    FROM \"%s\"
                    WHERE tray='%s' AND lot='%s' AND next_process_code='%s' ORDER BY id ASC;",
                config('app.bkv_prefix') . $subbatch,
                $tray,
                $lot,
                $next_process_code
            );
            $bkv_ret = Db::fetchAll($sql);
            if (empty($bkv_ret)) {
                throw new Exception("托盘[{$tray}]内不存在电池数据，不允许再投");
            }
            if(!in_array("NG",array_column($bkv_ret, 'class'))){
                throw new Exception("托盘[{$tray}]内不存在NG电池，不允许再投");
            }
            // 筛选出应该再投的电池ID
            $rebatch_battery_ids = array_column($bkv_ret, 'battery_id');

            // 3、copy再投工序之前工序所有数据
            $is_workingsubclass_exist = 0;
            foreach ($process as $process_data) {
                if ($process_data[4] == $workingsubclass) {
                    $is_workingsubclass_exist = 1;
                }
            }

            if($is_workingsubclass_exist == 0){
                throw new Exception("需要再投工序单元[{$workingsubclass}]不存在托盘工艺流程内");
            }
            
            $new_process_code = "";
            $new_process_idx = -1;
            $new_next_process_code = "";
            //获取除当前工序所有process_id的参数
            $process_param = [];
            foreach($process as $key=>$val){
                if($workingsubclass == $val[4]){
                    $new_process_code = $process[$key-1][2];
                    $new_process_idx = $process[$key-1][0];
                    $new_next_process_code = $val[2];
                    break;
                }
                $sql = "SELECT code FROM hf_mes_technology_process_result_param 
                        WHERE process_id=".$val[1];
                $ret = Db::fetchAll($sql);
                if(empty($ret)){
                    continue;
                }
                foreach($ret as $k => $v){
                    $process_param[] = '"'.$val[2].'.'.$v['code'].'"';
                }
            }

            // 修改tray_map表的date_log
            foreach ($date_log as $k => $v) {
                if ($k > $new_process_idx) {
                    $date_log[$k]['beginTime'] = "";
                    $date_log[$k]['endTime']     = "";
                    $date_log[$k]['device_code'] = "";
                }
            }

        } catch (Exception $e) {
            throw new Exception($e->getMessage());
        }

        // 开启事务
        Db::beginTrans();

        try {
            // 4、之前工序所有数据新增到bkv表、battery_map表、tray_map表、process_log表
            // 4.1、针对tray_map表拿之前的数据，除lot、active、process_code、process_idx、next_process_code、date_log、tray_unique_value、create_time，其他沿用原来的
            
            $sql = "SELECT column_name FROM information_schema.COLUMNS WHERE TABLE_NAME = 'hf_mes_production_tray_map' AND column_name <> 'id' ORDER BY ordinal_position";
            $ret = Db::fetchAll($sql);
            $key_str = implode(",",array_column($ret, 'column_name'));
            $sql = "SELECT $key_str FROM hf_mes_production_tray_map WHERE tray='$tray' AND lot='$lot' AND batch='$batch' LIMIT 1";
            $ret = Db::fetch($sql);
            if(empty($ret)){
                throw new Exception("查找tray_map数据失败");
            }
            
            $new_log = time();
            
            $ret['lot'] = $new_log;
            $ret['active'] = 1;
            $ret['process_code'] = $new_process_code;
            $ret['process_idx'] = $new_process_idx;
            $ret['next_process_code'] = $new_next_process_code;
            $ret['date_log'] = json_encode($date_log, JSON_UNESCAPED_UNICODE);
            $ret['tray_unique_value'] = "{$batch}_{$subbatch}_{$tray}_{$new_log}";
            $ret['create_time'] = date("Y-m-d H:i:s");
            $k_str = "";
            $v_str = "";
           
            foreach($ret as $k => $v){
                $k_str .= "$k,";
                if($v === '' || $v === NULL){
                    $v_str .= "Null,";
                }else{
                    $v_str .= "'$v',";
                }
            }
           
            $k_str = rtrim($k_str, ",");
            $v_str = rtrim($v_str, ",");
            
           // 写入tray_map数据
           $sql = sprintf(
                "INSERT INTO \"%s\" %s VALUES %s;",
                'hf_mes_production_tray_map',
                "({$k_str})",
                "({$v_str})"
            );
            $row = Db::query($sql);
            if ($row === NULL) {
                throw new Exception("写入tray_map数据失败");
            }


            // 4.2、针对battery_map表拿之前的数据，除lot、battery_unique_value、workingsubclass，其他沿用原来的
            
            $sql = "SELECT column_name FROM information_schema.COLUMNS WHERE TABLE_NAME = 'hf_mes_production_battery_map' AND column_name <> 'id' ORDER BY ordinal_position";
            $ret = Db::fetchAll($sql);
            $key_str = implode(",",array_column($ret, 'column_name'));
            $sql = "SELECT $key_str FROM hf_mes_production_battery_map WHERE tray='$tray' AND lot='$lot' AND batch='$batch' ORDER BY id ASC";
            $ret = Db::fetchAll($sql);
            if(empty($ret)){
                throw new Exception("查找battery_map数据失败");
            }
            $batterys_v_str = "";
            foreach($ret as $val){
                $v_str = "";
                // 如果电池ID在再投电池内，则复制原来的数据
                if(in_array($val['battery_id'],$rebatch_battery_ids)){
                    foreach($val as $k => $v){
                        if($k == 'battery_unique_value'){
                            $v_str .= "'{$batch}_{$subbatch}_{$tray}_{$new_log}_{$val['battery_id']}',";
                        }else if($k == 'lot'){
                            $v_str .= "'$new_log',";
                        }else if($k == 'workingsubclass'){
                            $v_str .= "'$workingsubclass',";
                        }else{
                            if($v === '' || $v === NULL){
                                $v_str .= "Null,";
                            }else{
                                $v_str .= "'$v',";
                            }
                        }
                    }

                }
                // else{
                //     // 电池不需要再投，默认是0
                //     foreach($val as $k => $v){
                //         if($k == 'battery_id'){
                //             $v_str .= "'0',";
                //         }else if($k == 'battery_unique_value'){
                //             $v_str .= "'{$batch}_{$subbatch}_{$tray}_{$new_log}_0',";
                //         }else if($k == 'lot'){
                //             $v_str .= "'$new_log',";
                //         }else if($k == 'workingsubclass'){
                //             $v_str .= "'$workingsubclass',";
                //         }else if($k == 'batch' || $k == 'subbatch' || $k == 'tray'){
                //             $v_str .= "'$v',";
                //         }else{
                //             $v_str .= "Null,";
                //         }
                //     }
                // }
                if($v_str != ""){
                    $v_str = rtrim($v_str, ",");
                    $batterys_v_str .= "({$v_str}),";
                }
            }
            $batterys_v_str = rtrim($batterys_v_str, ",");
            
           // 写入battery_map数据
           $sql = sprintf(
                "INSERT INTO \"%s\" %s VALUES %s;",
                'hf_mes_production_battery_map',
                "({$key_str})",
                "{$batterys_v_str}"
            );
            $row = Db::query($sql);
            if ($row === NULL) {
                throw new Exception("写入battery_map数据失败");
            }

            // 4.3、针对bkv表拿之前的数据，除lot、class、classname、process_code、process_idx、next_process_code、工序NG，其他沿用原来的
            
            $sql = "SELECT column_name FROM information_schema.COLUMNS WHERE TABLE_NAME = 'hf_mes_tmp_bkv_".$subbatch."' AND column_name <> 'id' AND column_name NOT LIKE '%.%' ORDER BY ordinal_position";
            $ret = Db::fetchAll($sql);
            // 合并再投工序之前工序结果参数字段
            $key_str = implode(",",array_merge(array_column($ret, 'column_name'),$process_param));
            $sql = "SELECT $key_str FROM \"hf_mes_tmp_bkv_".$subbatch."\" WHERE tray='$tray' AND lot='$lot' ORDER BY id ASC";
            $ret = Db::fetchAll($sql);
            if(empty($ret)){
                throw new Exception("查找bkv表数据失败");
            }
            $batterys_v_str = "";
            foreach($ret as $val){
                $v_str = "";
                // 如果电池ID在再投电池内，则复制原来的数据
                if(in_array($val['battery_id'],$rebatch_battery_ids)){
                    foreach($val as $k => $v){
                        if($k == 'lot'){
                            $v_str .= "'$new_log',";
                        }else if($k == 'process_code'){
                            $v_str .= "'$new_process_code',";
                        }else if($k == 'process_idx'){
                            $v_str .= "'$new_process_idx',";
                        }else if($k == 'next_process_code'){
                            $v_str .= "'$new_next_process_code',";
                        }else if($k == 'class' || $k == 'classname' || strpos($k, '.NG') !== false){
                            // 清掉class、classname、工序NG
                            $v_str .= "Null,";
                        }else{
                            if($v === '' || $v === NULL){
                                $v_str .= "Null,";
                            }else{
                                $v_str .= "'$v',";
                            }
                        }
                    }

                }else{
                    // 电池不需要再投，默认是0
                    foreach($val as $k => $v){
                        if($k == 'battery_id'){
                            $v_str .= "'0',";
                        }else if($k == 'lot'){
                            $v_str .= "'$new_log',";
                        }else if($k == 'tray'){
                            $v_str .= "'$v',";
                        }else{
                            $v_str .= "Null,";
                        }
                    }
                }
                $v_str = rtrim($v_str, ",");
                $batterys_v_str .= "({$v_str}),";
            }
            $batterys_v_str = rtrim($batterys_v_str, ",");
            
            // 写入bkv表数据
            $sql = sprintf(
                "INSERT INTO \"%s\" %s VALUES %s;",
                config('app.bkv_prefix') . $subbatch,
                "({$key_str})",
                "{$batterys_v_str}"
            );
            $row = Db::query($sql);
            if ($row === NULL) {
                throw new Exception("写入bkv表数据失败");
            }

            // 4.4、针对process_log表拿之前的数据，除lot、class、classname、ng_code、last_status，其他沿用原来的
            
            $sql = "SELECT column_name FROM information_schema.COLUMNS WHERE TABLE_NAME = 'hf_mes_bkv_batch_process_log' AND column_name <> 'id' ORDER BY ordinal_position";
            $ret = Db::fetchAll($sql);
            $key_str = implode(",",array_column($ret, 'column_name'));
            // 在再投电池内，找出电池最后一条process_log数据（兼容是跳工序做的电池场景）
            $batterys_v_str = "";
            foreach($rebatch_battery_ids as $battery_id){
                $sql = "SELECT $key_str FROM hf_mes_bkv_batch_process_log WHERE item_id='$battery_id' ORDER BY id DESC LIMIT 1";
                $ret = Db::fetch($sql);
                if(empty($ret)){
                    throw new Exception("查找process_log表数据失败");
                }
                $v_str = "";
                foreach($ret as $k => $v){
                    if($k == 'lot'){
                        $v_str .= "'$new_log',";
                    }else if($k == 'class' || $k == 'classname'){
                        // 清掉工序NG
                        $v_str .= "Null,";
                    }else if($k == 'ng_code'){
                        // 清掉工序NG
                        $v_str .= "0,";
                    }else if($k == 'last_status'){
                        $v_str .= "1,";
                    }else{
                        if($v === '' || $v === NULL){
                            $v_str .= "Null,";
                        }else{
                            $v_str .= "'$v',";
                        }
                    }
                }
                $v_str = rtrim($v_str, ",");
                $batterys_v_str .= "({$v_str}),";
            }
            $batterys_v_str = rtrim($batterys_v_str, ",");
            // 写入process_log表数据
            $sql = sprintf(
                "INSERT INTO \"%s\" %s VALUES %s;",
                'hf_mes_bkv_batch_process_log',
                "({$key_str})",
                "{$batterys_v_str}"
            );
            $row = Db::query($sql);
            if ($row === NULL) {
                throw new Exception("写入process_log表数据失败");
            }

            // 5、更改之前tray_map表托盘、bkv表电池状态为未激活；process_log表last_status=0
            // 5.1、更改之前tray_map表托盘状态为未激活
            $sql = sprintf(
                "UPDATE \"%s\" SET active=0 WHERE batch='%s' AND tray='%s' AND lot='%s'",
                'hf_mes_production_tray_map',
                $batch,
                $tray,
                $lot
            );
            $row = Db::query($sql);
            if ($row === NULL) {
                throw new Exception("更新tray_map表数据失败");
            }
            // 5.2、更改之前bkv表电池状态为未激活
            $sql = sprintf(
                "UPDATE \"%s\" SET active=0 WHERE tray='%s' AND lot='%s'",
                config('app.bkv_prefix') . $subbatch,
                $tray,
                $lot
            );
            $row = Db::query($sql);
            if ($row === NULL) {
                throw new Exception("更新bkv表数据失败");
            }
            // 5.3、更改之前process_log表last_status=0
            foreach($rebatch_battery_ids as $battery_id){
                $sql = sprintf(
                    "UPDATE \"%s\" SET last_status=0 WHERE item_id='%s' AND tray='%s' AND lot='%s'",
                    'hf_mes_bkv_batch_process_log',
                    $battery_id,
                    $tray,
                    $lot
                );
                $row = Db::query($sql);
                if ($row === NULL) {
                    throw new Exception("更新process_log表数据失败");
                }
            }

        } catch (Exception $e) {
            Db::rollBackTrans();
            throw new Exception($e->getMessage());
        }

        Db::commitTrans();

        return '';
    }
}