SchoolPhysicalExamination/application/ZengJieCode/controller/app/Savemsg.php

<?php

namespace app\ZengJieCode\controller\app;

use think\Db;
use think\Cache;

class Savemsg extends Base{

    protected $default_head_pic = 'http://tc.pcxbc.com/tsf/head_pic.png';
    protected $max_box_num = 10;
    protected $name_list = [
        [
            'name'=>'LS-2502',
            'character_uuid'=>'2A25',
            'service_uuid'=>'180A'
        ],
        
    ];
    protected $name_default = 0;

    // 加 bcadd(,,20)
    // 减 bcsub(,,20)
    // 乘 bcmul(,,20)
    // 除 bcdiv(,,20)
    ################################################################百度接口################################################################
    ################################################################百度接口################################################################
    ################################################################百度接口################################################################

    // 获取配置信息
    public function config_msg(){
        try {  
            $result = $this->config_msg_action();
            return $this->msg($result);
        } catch (\Exception $e) {  
            // 捕获异常  
            $logContent["flie"] = $e->getFile();  
            $logContent["line"] = $e->getLine();  
            $logContent['all_content'] = "异常信息：\n";  
            $logContent['all_content'] .= "消息: " . $e->getMessage() . "\n";  
            $logContent['all_content'] .= "代码: " . $e->getCode() . "\n";  
            $logContent['all_content'] .= "文件: " . $e->getFile() . "\n";  
            $logContent['all_content'] .= "函数名: " . __FUNCTION__ . "\n";
            $logContent['all_content'] .= "行号: " . $e->getLine() . "\n";  
            $logContent['all_content'] .= "跟踪信息:\n" . $e->getTraceAsString() . "\n"; 
            $this->record_api_log($data, $logContent, null); 
            return $this->msg(99999);
        } 

    }

    public function save_sn_msg($data = ['sn_code'=>'564654564654654','mac_code'=>'ce:sh:yo:ng:d1','bl_name'=>'bl_5520']){
        try {  
            // 你的业务逻辑  
            if(count(input('post.')) > 0){
                $data = input('post.');
            }
            if(!array_key_exists('sn_code', $data)){ 
                return $this->msg(10001);
            }
            if(!array_key_exists('bl_name', $data)){ 
                return $this->msg(10001);
            }
            if(!array_key_exists('mac_code', $data)){ 
                return $this->msg(10001);
            }
            if(!$this->verify_data_is_ok($data['sn_code'],'str')){
                return $this->msg(10005);
            }
            if(!$this->verify_data_is_ok($data['bl_name'],'str')){
                return $this->msg(10005);
            }
            if(!$this->verify_data_is_ok($data['mac_code'],'str')){
                return $this->msg(10005);
            }
            $result = $this->save_sn_msg_action($data);
            return $result;
        } catch (\Exception $e) {  
            // 捕获异常  
            $logContent["flie"] = $e->getFile();  
            $logContent["line"] = $e->getLine();  
            $logContent['all_content'] = "异常信息：\n";  
            $logContent['all_content'] .= "消息: " . $e->getMessage() . "\n";  
            $logContent['all_content'] .= "代码: " . $e->getCode() . "\n";  
            $logContent['all_content'] .= "文件: " . $e->getFile() . "\n";  
            $logContent['all_content'] .= "函数名: " . __FUNCTION__ . "\n";
            $logContent['all_content'] .= "行号: " . $e->getLine() . "\n";  
            $logContent['all_content'] .= "跟踪信息:\n" . $e->getTraceAsString() . "\n"; 
            // dump($data);
            // die;
            $this->record_api_log($data, $logContent, null); 
            return $this->msg(99999);
        } 

    }

    public function save_box_msg($data = ['sn_code_all'=>'564654564654654,564654564654654','box_serial_number'=>'996589585']){
 
        try {  
            // 你的业务逻辑  
            if(count(input('post.')) > 0){
                $data = input('post.');
            }
            if(!array_key_exists('sn_code_all', $data)){ 
                return $this->msg(10001);
            }
            if(!array_key_exists('box_serial_number', $data)){ 
                return $this->msg(10001);
            }
            if(!$this->verify_data_is_ok($data['sn_code_all'],'str')){
                return $this->msg(10005);
            }
            if(!$this->verify_data_is_ok($data['box_serial_number'],'num&letter')){
                return $this->msg(10005);
            }
            $result = $this->save_box_msg_action($data);
            return $result;
        } catch (\Exception $e) {  
            // 捕获异常  
            $logContent["flie"] = $e->getFile();  
            $logContent["line"] = $e->getLine();  
            $logContent['all_content'] = "异常信息：\n";  
            $logContent['all_content'] .= "消息: " . $e->getMessage() . "\n";  
            $logContent['all_content'] .= "代码: " . $e->getCode() . "\n";  
            $logContent['all_content'] .= "文件: " . $e->getFile() . "\n";  
            $logContent['all_content'] .= "函数名: " . __FUNCTION__ . "\n";
            $logContent['all_content'] .= "行号: " . $e->getLine() . "\n";  
            $logContent['all_content'] .= "跟踪信息:\n" . $e->getTraceAsString() . "\n"; 
            // dump($data);
            // die;
            $this->record_api_log($data, $logContent, null); 
            return $this->msg(99999);
        } 

    }

    public function print_again($data = ['code'=>'564654564654654','type'=>'sn']){
        try {  
            // 你的业务逻辑  
            if(count(input('post.')) > 0){
                $data = input('post.');
            }
            if(!array_key_exists('code', $data)){ 
                return $this->msg(10001);
            }
            if(!array_key_exists('type', $data)){ 
                return $this->msg(10001);
            }
            if(!$this->verify_data_is_ok($data['code'],'str')){
                return $this->msg(10005);
            }
            if(!$this->verify_data_is_ok($data['type'],'str')){
                return $this->msg(10005);
            }
        
            $result = $this->print_again_action($data);
            return $result;
        } catch (\Exception $e) {  
            // 捕获异常  
            $logContent["flie"] = $e->getFile();  
            $logContent["line"] = $e->getLine();  
            $logContent['all_content'] = "异常信息：\n";  
            $logContent['all_content'] .= "消息: " . $e->getMessage() . "\n";  
            $logContent['all_content'] .= "代码: " . $e->getCode() . "\n";  
            $logContent['all_content'] .= "文件: " . $e->getFile() . "\n";  
            $logContent['all_content'] .= "函数名: " . __FUNCTION__ . "\n";
            $logContent['all_content'] .= "行号: " . $e->getLine() . "\n";  
            $logContent['all_content'] .= "跟踪信息:\n" . $e->getTraceAsString() . "\n"; 
            // dump($data);
            // die;
            $this->record_api_log($data, $logContent, null); 
            return $this->msg(99999);
        } 

    }
    



    ########################################################################action########################################################################
    ########################################################################action########################################################################
    ########################################################################action########################################################################

    public function config_msg_action(){
        // $length = strlen("0065601800007037");
        // // 生成200个随机数字字符串
        // $randomStrings = [];
        // for ($i = 0; $i < 200; $i++) {
        //     $randomString = '';
        //     for ($j = 0; $j < $length; $j++) {
        //         $randomString .= rand(0, 9); // 生成0-9的随机数字
        //     }
        //     $randomStrings[] = [
        //         'bluetooth_name'=>'bl_5520',
        //         'sn_code'=>$randomString,
        //         'create_time'=>date('Y-m-d H:i:s'),
        //     ];
        // }
        // $zengjie = Db::connect('zengjie_db');
        // $result = $zengjie->table('sn_code_all')->insertAll($randomStrings);
        // dump($result);
        // die;
        $data = [
            'max_box_num'=>$this->max_box_num,
            'name_list'=>$this->name_list,
            'name_default_key'=>$this->name_default,
            
        ];
        return $data;
    }

    public function save_sn_msg_action($data){
        $zengjie = Db::connect('zengjie_db');
        // $sn_code = $zengjie->table('sn_code_all')->where(['sn_code'=>$data['sn_code']])->count();
        // if($sn_code > 0){
        //     return $this->msg(10002,'该码已录入');
        // }
        $result = $zengjie->table('sn_code_all')->insert([
            'sn_code'=>$data['sn_code'],
            'bluetooth_name'=>$data['bl_name'],
            'mac_code'=>$data['mac_code'],
            'create_time'=>date('Y-m-d H:i:s'),
        ]);
        if($result){
            return $this->msg([]);
        }else{
            return $this->msg(10002,'录入失败');
        }
    }

    public function save_box_msg_action($data) {
        $zengjie = Db::connect('zengjie_db');
        
        // 1. 检查sn_code_all中是否有重复数据
        $snCodes = explode(',', $data['sn_code_all']);
        if (count($snCodes) !== count(array_unique($snCodes))) {
            return $this->msg(10003, 'SN码列表中存在重复数据');
        }
        
        // 2. 检查这些SN码是否都存在于sn_code_all表中
        $existCount = $zengjie->table('sn_code_all')
                    ->where('sn_code', 'in', $snCodes)
                    ->count();
        
        if ($existCount !== count($snCodes)) {
            return $this->msg(10004, '存在未登记的SN码');
        }
        Db::startTrans();
        try{
            $count = $zengjie->table('box_code_all')
                    ->where(['box_code'=>$data['box_serial_number']])
                    ->count();
            $num = $count + 1;

            $box_id = $zengjie->table('box_code_all')->insertGetId([
                'box_code' => $data['box_serial_number'],
                'box_num' => $num,
                'create_time' => date('Y-m-d H:i:s'),
                'content_str' => $data['sn_code_all'],
            ]);
            
            $affectedRows = $zengjie->table('sn_code_all')
                    ->where('sn_code', 'in', $snCodes)
                    ->update(['batch_id' => $box_id]);
            
            // 检查更新是否影响了预期的行数
            if ($affectedRows !== count($snCodes)) {
                throw new \Exception('更新SN码数量不匹配');
            }
            Db::commit();
            return $this->msg(['id'=>$box_id]); 
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            return $this->msg(10002, '录入失败: ' . $e->getMessage());
        }
        // // 显式事务控制
        // $zengjie->startTrans();
        // try {
        //     $count = $zengjie->table('box_code_all')
        //             ->where(['box_code'=>$data['box_serial_number']])
        //             ->count();
        //     $num = $count + 1;

        //     $box_id = $zengjie->table('box_code_all')->insertGetId([
        //         'box_code' => $data['box_serial_number'],
        //         'box_num' => $num,
        //         'create_time' => date('Y-m-d H:i:s'),
        //         'content_str' => $data['sn_code_all'],
        //     ]);
            
        //     $affectedRows = $zengjie->table('sn_code_all')
        //             ->where('sn_code', 'in', $snCodes)
        //             ->update(['batch_id' => $box_id]);
            
        //     // 检查更新是否影响了预期的行数
        //     if ($affectedRows !== count($snCodes)) {
        //         throw new \Exception('更新SN码数量不匹配');
        //     }
            
        //     $zengjie->commit();
        //     return $this->msg(['id'=>$box_id]); 
        // } catch (\Exception $e) {
        //     if ($zengjie->getPdo()->inTransaction()) {
        //         $zengjie->rollback();
        //     }
        //     trace('保存盒信息失败: ' . $e->getMessage(), 'error');
        //     return $this->msg(10002, '录入失败: ' . $e->getMessage());
        // }
    }


    public function print_again_action($data){
        $zengjie = Db::connect('zengjie_db');
        if($data['type'] == 'sn'){
            $result = $zengjie->table('sn_code_all')->where(['sn_code'=>$data['code']])->count();
        }else{
            $result = $zengjie->table('box_code_all')->where(['id'=>$data['code']])->count();
        }
        
        if($result <= 0){
            return $this->msg(10002,'未找到该码录入');
        }

        if($data['type'] == 'sn'){
            $result2 = $zengjie->table('sn_code_all')->where(['sn_code'=>$data['code']])->update([
                'is_print'=>3
            ]);
        }else{
            $result2 = $zengjie->table('box_code_all')->where(['id'=>$data['code']])->update([
                'is_print'=>0
            ]);
        }
        
        if($result){
            return $this->msg([]);
        }else{
            return $this->msg(10002,'打印失败');
        }
    }

    ######################################################测试#########################################################
    ######################################################测试#########################################################
    ######################################################测试#########################################################

    public function ceshiyong(){
        // // 添加测试一维码数据
        // $data = [];
        // for ($i = 0; $i < 500; $i++) {
        //     // 生成15位随机数字作为sn_code
        //     $sn_code = '';
        //     for ($j = 0; $j < 15; $j++) {
        //         $sn_code .= mt_rand(0, 9);
        //     }
            
        //     // 生成随机的MAC地址
        //     $mac_parts = [];
        //     for ($k = 0; $k < 6; $k++) {
        //         $mac_parts[] = sprintf('%02x', mt_rand(0, 255));
        //     }
        //     $mac_code = implode(':', $mac_parts);
            
        //     // 构建数据数组
        //     $data[] = [
        //         'sn_code' => $sn_code,
        //         'mac_code' => $mac_code,
        //         'create_time' => date('Y-m-d H:i:s'),
        //         'is_print' => 1,
        //         'bluetooth_name' => 'bl_5520'
        //     ];
        // }
        // $zengjie = Db::connect('zengjie_db');
        // $result = $zengjie->table('sn_code_all')->insertAll($data);
        // dump($result);
        // die;
        // // 添加测试一维码数据

        // 添加测试打包数据
        $zengjie = Db::connect('zengjie_db');
        $records = $zengjie->table('sn_code_all')
        ->where('batch_id', 'null')  // 或者使用 ->whereNull('batch_id')
        ->orderRaw('NEWID()')  // SQL Server的随机排序函数
        ->limit(10)
        ->select();
        $data['sn_code_all'] = [];
        $data['box_serial_number'] = '3ST011527003';
        for ($i=0; $i < count($records); $i++) { 
            $data['sn_code_all'][] = $records[$i]['sn_code'];
        }
        $data['sn_code_all'] = implode(',',$data['sn_code_all']);
        $result = $this->save_box_msg_action($data);
        dump($result);
        dump($data);
        // 添加测试打包数据
        // return $data;
    }
    
}