<?php
// +----------------------------------------------------------------------
// | ThinkCMF [ WE CAN DO IT MORE SIMPLE ]
// +----------------------------------------------------------------------
// | Copyright (c) 2013-2019 http://www.thinkcmf.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: Powerless < wzxaini9@gmail.com>
// +----------------------------------------------------------------------

namespace app\portal\controller;

use api\home\controller\CommonController;
use cmf\controller\AdminBaseController;
use app\portal\model\InspectModel;
use think\Db;
use think\db\Query;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\IOFactory;
use ZipArchive;
use PhpOffice\PhpSpreadsheet\Worksheet\Drawing;
//甲方巡检列表
class AdminCommonController extends AdminBaseController
{
    //甲方服务列表
    const serviceAList = [
        ['id' => 4, 'service_name' => '报修'],
        ['id' => 3, 'service_name' => '改造'],
        ['id' => 5, 'service_name' => '培训'],
        ['id' => 6, 'service_name' => '演习'],
    ];
    //乙方服务列表
    const serviceBList = [
        ['id' => 2, 'service_name' => '月检'],
        ['id' => 4, 'service_name' => '报修'],
        ['id' => 3, 'service_name' => '改造'],
    ];

    //所有服务列表
    const serviceList = [
        ['id' => 2, 'service_name' => '月检'],
        ['id' => 4, 'service_name' => '报修'],
        ['id' => 3, 'service_name' => '改造'],
        ['id' => 5, 'service_name' => '培训'],
        ['id' => 6, 'service_name' => '演习'],
    ];

    //根据项目id，甲方或者乙方查询正常巡检天数
    public function normalTime($where){
        $time = $this->inspectDays($where);
        //查询巡检点总数
        $count = $this->pointCount($where['project_id']);
        //正常状态
        $where['status'] = 0;
        $day = 0;
        foreach($time as $value){
            $days = $this->inspect($where,$value);
            if($days == $count){
                $day++;
            }
        }
        return $day;
    }

    //根据项目id，甲方或者乙方查询故障巡检天数
    public function breakTime($where){
        $time = $this->inspectDays($where);
        //查询巡检点总数
        $count = $this->pointCount($where['project_id']);
        //正常状态
        $where['status'] = 0;
        $day = 0;
        foreach($time as $value){
            $days = $this->inspect($where,$value);
            if($days < $count){
                $day++;
            }
        }
        return $day;
    }

    //根据项目id,查询巡检天数
    public function inspectDays($where){
        $res = Db::name('inspect')
            ->where($where)
            ->field('id,create_time')
            ->group("DATE_FORMAT(FROM_UNIXTIME(create_time),'%Y-%m-%d')")
            ->select()
            ->toArray();
        $time = array_column($res,'create_time');
        return $time;
    }

    //根据项目id，甲方或者乙方查巡检总数，来判断正常，故障
    public function inspect($where,$time){
        $time1 = date('Y-m-d',$time);
        $time2 = date('Y-m-d',$time+86400);
        $count = Db::name('inspect')
            ->where($where)
            ->whereTime('create_time',[$time1,$time2])
            ->count();
        return $count;
    }

    //根据项目id查询巡检点个数
    public function pointCount($project_id){
        $count = Db::name('point')
            ->where('p_id',$project_id)
            ->count();
        return $count;
    }

    //查询所有的项目，以及对应的乙方公司
    public function getCompanyBList(){
        $res = Db::name('project')
            ->alias('p')
            ->join('company c','p.b_cid = c.id')
            ->field('p.id,p.name project_name,c.company_name,c.id company_id,p.create_time')
            ->order('p.id desc')
            ->paginate(10);
        return $res;
    }

    //计算运行天数
    public function runTime($time){
        $currentTime = time();
        $cnt=$currentTime-$time;
        $days = floor($cnt/(3600*24));//算出天数
        return $days+1;
    }

    //按照条件查询次数
    public function getCount($table,$where){
        $count = Db::name($table)
            ->where($where)
            ->count();
        return $count;
    }

    //根据uid查询用户正常考勤日期
    public function getNormalWork($uid){
        //聚合相同日期
        $res = Db::name('work')
            ->where(['uid'=>$uid])
            ->field('id,uid,create_time')
            ->group("DATE_FORMAT(FROM_UNIXTIME(create_time),'%Y-%m-%d')")
            ->select()
            ->toArray();
        $normal = 0;
        $not_normal = 0;
        $arr = [];
        foreach($res as $value){
            $count = $this->getWorkCount($value['uid'],$value['create_time']);
            if($count == 2){
                //正常
                $arr['normal'] = ++$normal;
            }else{
                //缺卡
                $arr['not_normal'] = ++$not_normal;
            }
        }
        return $arr;
    }

    //根据uid获取是否含有上班，下班
    public function getWorkCount($uid,$create_time){
        $time = date('Y-m-d',$create_time);
        $time1 = date('Y-m-d',$create_time+86400);
        //查询所有记录
        $count = Db::name('work')
            ->where(['uid'=>$uid])
            ->whereTime('create_time',[$time,$time1])
            ->count();
        return $count;
    }

    //查询甲方人员id
    public function getPartA(){
        $staff = Db::name('company')
            ->where(['pid'=>0])
            ->field('id,company_name,u_s_id,u_l_id,u_ls_id,is_children,company_name_head')
            ->select()
            ->toArray();
        return $staff;
    }

    //查询乙方员工id
    public function getPartB(){
        $staff = Db::name('company')
            ->where('pid','<>',0)
            ->field('id,company_name,u_s_id,u_l_id,u_ls_id')
            ->select()
            ->toArray();
        return $staff;
    }

    //查找甲方员工所在的项目组
    public function getProjectA($company_id,$uid){
        $res = Db::name('project')
            ->where(['a_cid'=>$company_id])
            ->field('id,a_sid,name project_name,create_time')
            ->select()
            ->toArray();
        $arr = [];
        $common = new AdminCommonController();
        foreach($res as $value){
            $a_sid = explode(',',trim($value['a_sid'],','));
            if(in_array($uid,$a_sid)){
                $arr['project_name'] = $value['project_name'];
                $arr['run_time'] = $common->runTime($value['create_time']);
            }
        }
        return $arr;
    }

    //查找乙方员工所在的项目组
    public function getProjectB($company_id,$uid){
        $res = Db::name('project')
            ->where(['b_cid'=>$company_id])
            ->field('id,b_sid,name project_name,create_time')
            ->select()
            ->toArray();
        $arr = [];
        $common = new AdminCommonController();
        foreach($res as $value){
            $a_sid = explode(',',trim($value['b_sid'],','));
            if(in_array($uid,$a_sid)){
                $arr['project_name'] = $value['project_name'];
                $arr['run_time'] = $common->runTime($value['create_time']);
            }
        }
        return $arr;
    }

    //根据服务查询完成情况
    public function getServiceCount($table,$where){
        $count = Db::name($table)
            ->where($where)
            ->count();
        return $count;
    }

    /*
     * 导出表格适用于报表绘制表格
     */
    public function send_export($arr){
        $spreadsheet = new Spreadsheet();
        $sheet = $spreadsheet->getActiveSheet();
        $xlsName = $arr['time'];
        //设置sheet名称
        $name = '报表';
        $name = $this->iconv_to_utf8($name);

        $sheet->setTitle($xlsName.$name);
        //合并单元格
        $sheet->mergeCells('B1:J1');
        $sheet->mergeCells('B3:B4');
        $sheet->mergeCells('B6:D6');
        $sheet->mergeCells('B7:D7');
        $sheet->mergeCells('C3:D3');
        $sheet->mergeCells('C4:D4');
        $sheet->mergeCells('F3:F4');
        $sheet->mergeCells('G3:I3');
        $sheet->mergeCells('G4:I4');

        $spreadsheet->getDefaultStyle()->getFont()->setName('微软雅黑');//字体

        //设置默认宽
        $sheet->getDefaultColumnDimension()->setWidth(8);
        //设置高度
        $sheet->getRowDimension(1)->setRowHeight(45);
//        $sheet->getRowDimension(2)->setRowHeight(55);


        //***********************画出单元格边框*****************************
//        $styleArray = [
//            'borders' => [
//                'outline' => [
//                    'borderStyle' => \PhpOffice\PhpSpreadsheet\Style\Border::BORDER_THICK,
//                    'color' => ['argb' => 'FFFF0000'],
//                ],
//            ],
//        ];
//        $sheet->getStyle('A1:M26')->applyFromArray($styleArray);
        //***********************画出单元格边框结束*****************************

        //***********************背景填充颜色*****************************
        $sheet->getStyle( 'A1:M8')->getFill()->setFillType(\PHPExcel_Style_Fill::FILL_SOLID);
        $sheet->getStyle( 'A1:M8')->getFill()->getStartColor()->setRGB('222B35');//背景颜色
        //***********************画出单元格边框结束*****************************

        //标题
        $sheet->setCellValue('B1', $arr['title']);
        $sheet->getStyle('B1')->getFont()->setSize(18);//字体大小
        $sheet->getStyle('B1')->getFont()->getColor()->setRGB('FFFFFF');//设置颜色为白色
        $sheet->getStyle('B1')->getFont()->setBold(true);//字体加粗

        //甲方logo
        $imageA = $arr['a_company']['logo'];
        if(@fopen($imageA , 'r' ) ) {
            //这是一个坑,刚开始我把实例化图片类放在了循环外面,但是失败了,也就是每个图片都要实例化一次
            $imageADrawing = new Drawing();
            $imageADrawing->setPath($imageA);
            // 设置图片的宽度
            $imageADrawing->setResizeProportional(false);
            $imageADrawing->setWidthAndHeight(40,40);
            //图片显示在B3
            $imageADrawing->setCoordinates('B3');
            $imageADrawing->setWorksheet($sheet);
        }

        $sheet->getStyle('B3:G7')->getFont()->setSize(8);//字体大小
        $sheet->getStyle('C3:G3')->getFont()->getColor()->setRGB('949494');//设置颜色为灰色
        $sheet->getStyle('B6:G6')->getFont()->getColor()->setRGB('949494');//设置颜色为灰色
        $sheet->getStyle('C4:G4')->getFont()->getColor()->setRGB('FFFFFF');//设置颜色为白色
        $sheet->getStyle('B7:G7')->getFont()->getColor()->setRGB('FFFFFF');//设置颜色为白色

        //甲方公司
        $sheet->setCellValue('C3', '甲方公司');
        //甲方公司名称
        $sheet->setCellValue('C4', $arr['a_company']['company_name']);

        //乙方logo
        $imageB = $arr['b_company']['logo'];
        if(@fopen($imageB , 'r' ) ) {
            //这是一个坑,刚开始我把实例化图片类放在了循环外面,但是失败了,也就是每个图片都要实例化一次
            $objDrawing = new Drawing();
            $objDrawing->setPath($imageB);
            // 设置图片的宽度
            $objDrawing->setResizeProportional(false);
            $objDrawing->setWidthAndHeight(40,40);
            //图片显示在F3
            $objDrawing->setCoordinates('F3');
            $objDrawing->setWorksheet($sheet);
        }

        //乙方公司
        $sheet->setCellValue('G3', '乙方公司');
        //乙方公司名称
        $sheet->setCellValue('G4', $arr['b_company']['company_name']);

        //项目组
        $sheet->setCellValue('B6', '项目组');
        //项目组名称
        $sheet->setCellValue('B7', $arr['group_name']);

        //巡检日期
        $sheet->setCellValue('E6', '巡检日期');
        //巡检日期名称
        $sheet->setCellValue('E7', $arr['create_time']);

        //巡检状态
        $sheet->setCellValue('G6', '巡检状态');
        //巡检状态名称
        $sheet->setCellValue('G7', $arr['inspect_status']);

        //循环开始

        $cols = 10;
        $cells = ['C','E','G','I','K'];
        foreach($arr['point'] as $value){
            $cols += 0;
            //巡检点名称
            $sheet->setCellValue('B'.$cols, $value['point_name']);
            $sheet->getStyle('B'.$cols)->getAlignment()->setVertical(\PHPExcel_Style_Alignment::VERTICAL_CENTER);//垂直居中
            //获取图片个数
            $length = count($value['images']);
            $col = ceil($length/5);
            for($i=0;$i<$col;$i++){
                $col_i = $cols+$i;
                $sheet->getRowDimension($col_i)->setRowHeight(105);
                $sheet->mergeCells('C'.$col_i.':D'.$col_i);
                $sheet->mergeCells('E'.$col_i.':F'.$col_i);
                $sheet->mergeCells('G'.$col_i.':H'.$col_i);
                $sheet->mergeCells('I'.$col_i.':J'.$col_i);
                $sheet->mergeCells('K'.$col_i.':L'.$col_i);
                $key = 0;
                foreach($value['images'] as $k=>$image_value){
                    $pre = $i+4*$i;
                    $next = $i+1+4*($i+1);
                    if($k>=$pre && $k<$next){
                        //巡检图片
                        $image = $image_value['image_url'];
                        if(@fopen($image , 'r' ) ) {
                            //这是一个坑,刚开始我把实例化图片类放在了循环外面,但是失败了,也就是每个图片都要实例化一次
                            $obj = new Drawing();
                            $obj->setPath($image);
                            // 设置图片的宽度
                            $obj->setResizeProportional(false);
                            $obj->setWidthAndHeight(105,130);
                            //图片显示在F3
                            $obj->setCoordinates($cells[$key].$col_i);
                            $obj->setWorksheet($sheet);
                        }
                        $key++;
                    }
                }
            }

            $cols += $col+1;
        }
        $sheet->getStyle( 'A9:M'.$cols)->getFill()->setFillType(\PHPExcel_Style_Fill::FILL_SOLID);
        $sheet->getStyle( 'A9:M'.$cols)->getFill()->getStartColor()->setRGB('F3F3F4');//背景颜色浅灰色


        $objWrite = IOFactory::createWriter($spreadsheet, 'Xls');

        //直接从浏览器中输出star
//        header('pragma:public');
//        header("Content-Disposition:attachment;filename=出货装箱单.xls");
//        $objWrite->save('php://output');
//        exit;
        //直接从浏览器中输出end

        $file_name = $xlsName.'.xls';

        $files_url = ROOT_PATH . '/public/upload/export';
        if(!is_dir($files_url)){
            mkdir($files_url);
        }
        $file_url = ROOT_PATH . '/public/upload/export/'.$file_name;
        $objWrite->save($file_url);
        chmod($file_url, 0777);
        //相对路径
        $url = 'upload/export/'.$file_name;
        return $url;
    }

    /*
     * 导出表格适用于普通有规律的数据
     * param xlsName:title名称
     * param xlsCell:二维数据xlsCell = array(
            array('id','序号'),
            array('user_nickname','昵称'),
            array('mobile','手机号'),
            array('create_time','注册时间'),
            array('last_login_time','最后登录时间'),
            array('user_status','状态'),
        );
     * param xlsData：数据库数据
     */
    public function exportExcel($xlsName,$xlsCell,$xlsData){
        $topNumber = 1;//表头有几行占用
        $starData = $topNumber+1;//数据开始行起
        $cellKey = [
            'A','B','C','D','E','F','G','H','I','J','K','L','M',
            'N','O','P','Q','R','S','T','U','V','W','X','Y','Z',
            'AA','AB','AC','AD','AE','AF','AG','AH','AI','AJ','AK','AL','AM',
            'AN','AO','AP','AQ','AR','AS','AT','AU','AV','AW','AX','AY','AZ'
        ];
        vendor("PHPExcel");

        $spreadsheet = new Spreadsheet();
        $sheet = $spreadsheet->getActiveSheet();
        $sheet->setTitle($xlsName);
        //处理表头
        foreach ($xlsCell as $k=>$v) {
            $sheet->setCellValue($cellKey[$k].$topNumber, $v[1]);//设置表头数据
            $sheet->getStyle($cellKey[$k].$topNumber)->getFont()->setBold(true);//设置是否加粗
        }
        //设置单元格居中显示
        $styleArray = [
            'alignment' => [
                'horizontal' => \PhpOffice\PhpSpreadsheet\Style\Alignment::HORIZONTAL_CENTER,
            ],
        ];
        //表头居中
        foreach ($xlsCell as $k2=>$v2) {
            $sheet->getStyle($cellKey[$k2].'1')->applyFromArray($styleArray);
        }
        //处理数据
        foreach ($xlsData as $k=>$v) {
            foreach ($xlsCell as $k1=>$v1) {
                //设置每列数据
                $sheet->setCellValue($cellKey[$k1].($k+$starData), $v[$v1[0]]);
                //每列宽度
                $sheet->getColumnDimension($cellKey[$k1])->setWidth(30);
                //设置居中显示
                $sheet->getStyle($cellKey[$k1].($k+$starData))->applyFromArray($styleArray);
            }
        }
        $file_name = $xlsName.'.xls';
//        ob_end_clean();//清除缓冲区,避免乱码
//        header('Content-Type: application/vnd.ms-excel');//告诉浏览器将要输出excel03文件
//        header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet');//告诉浏览器数据excel07文件
//        header('Content-Disposition: attachment;filename='.$file_name);
//        header('Cache-Control: max-age=0');
//        $writer = new Xlsx($spreadsheet);
        $writer = IOFactory::createWriter($spreadsheet, 'Xls'); //按照指定格式生成Excel文件
//        $writer->save('php://output');直接输入到浏览器下载
        //绝对路径，不存在则创建目录
        $files_url = ROOT_PATH . '/public/upload/export';
        if(!is_dir($files_url)){
            mkdir($files_url);
        }
        $file_url = ROOT_PATH . '/public/upload/export/'.$file_name;
//        chmod(ROOT_PATH . '/public/upload/export/', 0777);
        $writer->save($file_url);
        //相对路径
        $url = 'upload/export/'.$file_name;
        return $url;
    }

    /*
     * 添加文件路径到压缩包中
     * param files：可以为二维数组
     * array=>[
            [
                0 => string 'upload/export/2019-06-29.xls'
                1 => string 'upload/export/2019-06-30.xls'
            ],
            [
                0 => string 'upload/export/2019-06-29.xls'
                1 => string 'upload/export/2019-06-30.xls'
            ]
     * ]
     * param files:也可一维数组
     * array=>[
        0 => string 'upload/export/2019-06-29.xls'
        1 => string 'upload/export/2019-06-30.xls'
     * ]
     * param zipName:压缩包路径名称（upload/zipName.zip）
    */
    public function zip(array $files,$zipName,$arr_time,$flag='',$xlsName=''){
        //设置脚本的最大执行时间，设置为0则无时间限制
        set_time_limit(0);
        ini_set('max_execution_time', '0');
        $zip = new ZipArchive();//使用本类，linux需开启zlib，windows需取消php_zip.dll前的注释
        /*
         * 参考链接https://blog.csdn.net/weixin_34354945/article/details/91330692
         * 通过ZipArchive的对象处理zip文件
         * $zip->open这个方法如果对zip文件对象操作成功，$zip->open这个方法会返回TRUE
         * $zip->open这个方法第一个参数表示处理的zip文件名。
         * 这里重点说下第二个参数，它表示处理模式
         * ZipArchive::OVERWRITE 总是以一个新的压缩包开始，此模式下如果已经存在则会被覆盖。
         * ZIPARCHIVE::CREATE 如果不存在则创建一个zip压缩包，若存在系统就会往原来的zip文件里添加内容。
         *
         * 这里不得不说一个大坑。
         * 我的应用场景是需要每次都是创建一个新的压缩包，如果之前存在，则直接覆盖，不要追加
         * so，根据官方文档和参考其他代码，$zip->open的第二个参数我应该用 ZipArchive::OVERWRITE
         * 问题来了，当这个压缩包不存在的时候，会报错：ZipArchive::addFile(): Invalid or uninitialized Zip object
         * 也就是说，通过我的测试发现，ZipArchive::OVERWRITE 不会新建，只有当前存在这个压缩包的时候，它才有效
         * 所以我的解决方案是 $zip->open($zipName, \ZIPARCHIVE::OVERWRITE | \ZIPARCHIVE::CREATE)
         *
         * 以上总结基于我当前的运行环境来说
         * */
        if ($zip->open($zipName, \ZIPARCHIVE::OVERWRITE | \ZIPARCHIVE::CREATE)!==TRUE) {
            exit('无法打开文件，或者文件创建失败');
        }
        if($flag != ''){
            //二维数组
            if($flag == 'month'){
                //月
                foreach($files as $key=>$val){
                    foreach ($val as $k => $v) {
                        if(file_exists($v)){
                            $zip->addFromString($xlsName.'/'.$key.'/'.$arr_time[$key][$k], file_get_contents($v));//第一个参数：文件路径（含文件夹），第二个参数文件名称
                        }
                    }
                }
            }else{
                //年
                foreach($files as $key=>$val){
                    foreach($val as $key1=>$val1){
                        foreach ($val1 as $key2 => $val2) {
                            if(file_exists($val2)){
                                $zip->addFromString($xlsName.'/'.$key.'年/'.$key1.'/'.$arr_time[$key][$key1][$key2], file_get_contents($val2));
                            }
                        }
                    }
                }
            }
        }else{
            //一维数组
            foreach($files as $key=>$val){
                //addFile函数首个参数如果带有路径，则压缩的文件里包含的是带有路径的文件压缩
                //若不希望带有路径，则需要该函数的第二个参数
                if(file_exists($val)){
                    $zip->addFile($val, $arr_time[$key]);//含中文
                    //$zip->addFile($val, basename($val));//不含中文，第二个参数是放在压缩包中的文件名称，如果文件可能会有重复，就需要注意一下
                }
            }
        }
        $zip->close();//关闭

        chmod($zipName, 0777);

//        if(!file_exists($zipName)){
//            exit("无法找到文件"); //即使创建，仍有可能失败
//        }

        //如果不要下载，下面这段删掉即可，如需返回压缩包下载链接，只需 return $zipName;

        //中文导出需要转码
        $zipName=iconv('UTF-8','GB2312',$zipName);

        header("Cache-Control: public");//任何情况下都可以得到资源参考：https://blog.csdn.net/u012375924/article/details/82806617
        header("Content-Description: File Transfer");
        header('Content-disposition: attachment; filename='.basename($zipName)); //文件名
        header("Content-Type: application/zip"); //zip格式的
        header("Content-Transfer-Encoding: Binary"); //告诉浏览器，这是二进制文件
        header('Content-Length: '. filesize($zipName)); //告诉浏览器，文件大小
        var_dump(2222);exit;
        ob_clean();//清楚缓存
        flush();//刷新缓冲区的内容,输出
        readfile($zipName);
        //unlink($zipName); //删除压缩包临时文件
        //$this->delDirAndFile('upload/export',1);
        exit;
    }

    //删除目录及目录下文件
    public function delDirAndFile($dirName,$delDir=''){
        if ($handle = opendir($dirName)) {
            while (false !== ($item = readdir($handle))) {
                if ($item != "." && $item != "..") {
                    if (is_dir( $dirName.'/'.$item) ) {
                        $this->delDirAndFile( $dirName.'/'.$item);
                    }else{
                        unlink($dirName.'/'.$item);//删除目录下文件
                    }
                }
            }
            closedir($handle);
            if(empty($delDir)){
                rmdir($dirName);//删除目录
            }
        }
    }

    //转化编码值UFT-8
    public function iconv_to_utf8($keyword, $to='UTF-8'){
        $encode = mb_detect_encoding($keyword, array('ASCII','UTF-8','GBK','GB2312'));
        if($encode != $to){
            $keyword = iconv($encode, $to, $keyword);
        }
        return $keyword;
    }

    //根据项目id获取项目名称，甲方公司名称，logo，乙方公司名称，logo
    public function getCompanyName($project_id){
        //获取甲方id,乙方id
        $arr = [];
        $project = $this->getProject(['id'=>$project_id],'id,a_cid,b_cid,name');
        if($project){
            //甲方公司
            $a_company = $this->getCompany(['id'=>$project['a_cid']],'id,company_name,logo');
            $arr['a_company']['company_name'] = !empty($a_company['company_name'])?$a_company['company_name']:'';
            $arr['a_company']['logo'] = !empty($a_company['logo'])?'upload/'.$a_company['logo']:'';
            //乙方公司
            $b_company = $this->getCompany(['id'=>$project['b_cid']],'id,company_name,logo');
            $arr['b_company']['company_name'] = !empty($b_company['company_name'])?$b_company['company_name']:'';
            $arr['b_company']['logo'] = !empty($b_company['logo'])?'upload/'.$b_company['logo']:'';
            //报表标题
            $arr['title'] = $project['name'].'报修表';
        }
        return $arr;
    }

    //获取项目相关信息
    public function getProject($where,$field){
        $res = Db::name('project')
            ->where($where)
            ->field($field)
            ->order('id desc')
            ->find();
        return $res;
    }

    //获取企业相关信息
    public function getCompany($where,$field){
        $res = Db::name('company')
            ->where($where)
            ->field($field)
            ->order('id desc')
            ->find();
        return $res;
    }

    //根据项目id获取乙方项目组人员
    public function getBUserByProject($project_id,$field,$flag = ''){
        $users = Db::name('project')
            ->where('id',$project_id)
            ->field($field)
            ->find();
        $b_sid = explode(',',trim($users['b_sid'],','));
        $user_login = Db::name('user')
            ->whereIn('id',$b_sid)
            ->where('user_status',1)
            ->field('id,user_login')
            ->select()
            ->toArray();
        if(!empty($flag)){
            $users = trim(implode(array_column($user_login,'user_login'),'、'),'、');
        }else{
            $users = trim(implode(array_column($user_login,'user_login'),'/'),'/');
        }
        return $users;
    }

    //根据项目id获取甲方项目组人员
    public function getAUserByProject($project_id,$field){
        $users = Db::name('project')
            ->where('id',$project_id)
            ->field($field)
            ->find();
        $a_sid = explode(',',trim($users['a_sid'],','));
        $user_login = Db::name('user')
            ->whereIn('id',$a_sid)
            ->where('user_status',1)
            ->field('id,user_login')
            ->select()
            ->toArray();
        $group_name = trim(implode(array_column($user_login,'user_login'),'、'),'、');
        return $group_name;
    }

    //查询巡检正常或故障
    public function insStatus($where,$time,$time1){
        //查询总巡检点个数
        $point_count = Db::name('point')
            ->where(['p_id'=>$where['project_id']])
            ->count();
        //查询每天的正常巡检点个数
        $inspect_count = Db::name('inspect')
            ->where($where)
            ->whereTime('create_time', [$time,$time1])
            ->count();
        if($inspect_count < $point_count){
            $status = '故障';
        }else{
            $status = '正常';
        }
        return $status;
    }

    //获取巡检点相关的信息
    public function getPoint($where,$time,$time1){
        $point = Db::name('point')
            ->where('p_id',$where['project_id'])
            ->select()
            ->toArray();

        //查找以巡检的数据
        $inspect = Db::name('inspect')
            ->where($where)
            ->whereTime('create_time', [$time,$time1])
            ->field('id,point_id,images')
            ->select()
            ->toArray();
        //巡检名称，巡检人员，巡检图片
        foreach ($point as &$value1){
            $value1['images'] = [];
            foreach ($inspect as $ins_value){
                if($value1['id'] == $ins_value['point_id']){
                    $value1['images'] = $this->exportUrl($ins_value['images']);
                }
            }
        }
        return $point;
    }

    //相对路径转绝对路径
    public function exportUrl($images){
        if(!empty($images)){
            $images = unserialize($images);
            if(is_array($images)){
                foreach($images as &$value){
                    $value['image_url'] = substr($value['image_url'],1);;
                }
            }
        }
        return $images;
    }

    //获取导出巡检列表
    public function inspectList($party,$param){
        $res_ins = Db::name('inspect')
            ->alias('i')
            ->join('project p','i.project_id = p.id','LEFT')
            ->where(['i.party'=>$party])
            ->where(function (Query $query) use ($param){
                if (!empty($param['name'])) {
                    $keyword = $param['name'];
                    $query->where('p.name', 'like', "%$keyword%");
                }
                $startTime = empty($param['start_time']) ? 0 : strtotime($param['start_time']);
                $endTime   = empty($param['end_time']) ? 0 : strtotime($param['end_time']);
                if (!empty($startTime)) {
                    $query->where('i.create_time', '>=', $startTime);
                }
                if (!empty($endTime)) {
                    $query->where('i.create_time', '<=', $endTime);
                }

            })
            ->field('i.id,i.create_time,i.project_id,p.name project_name')
            ->group("DATE_FORMAT(FROM_UNIXTIME(i.create_time),'%Y-%m-%d')")
            ->select()->toArray();
        return $res_ins;
    }

    /**
     *  API返回信息格式函数 ；0失败，1成功
     * @param string $code
     * @param string $message
     * @param array $data
     */
    public function apiResponse($code = '', $msg = '',$data = array()){
        header('Access-Control-Allow-Origin: *');
        header('Content-Type:application/json; charset=utf-8');
        $result = array(
            'code'=>$code,
            'msg'=>$msg,
            'data'=>$data,
        );
        die(json_encode($result,JSON_UNESCAPED_UNICODE));
    }

}