dingding/application/api/controller/Common.php

<?php

namespace app\api\controller;

use app\common\constant\CommonConstant;
use app\common\constant\MaintainConstant;
use app\common\model\Goods;
use app\common\service\ApproveInfoService;
use app\common\service\CommonService;
use app\common\service\GoodsCategoryService;
use app\common\service\UserService;
use hg\apidoc\annotation as Apidoc;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;
use PhpOffice\PhpSpreadsheet\Reader\Csv;
use PhpOffice\PhpSpreadsheet\Reader\Xls;
use PhpOffice\PhpSpreadsheet\Reader\Xlsx;
use think\db\exception\BindParamException;
use think\Exception;
use think\exception\PDOException;
use think\Db;

/**
 * @Apidoc\Title("公用")
 * @Apidoc\Group("api")
 * @Apidoc\Sort("4")
 */
class Common extends Base
{
    // 需要登录
    protected $need_login = ['get_user_list'];

    public function initialize()
    {
        parent::initialize();
    }

    /**
     * 类型数据
     *
     * @Apidoc\Method("POST")
     * @Apidoc\Returned("module_list", type="array", desc="模块列表")
     * @Apidoc\Returned("degree_list", type="array", desc="缓急程度列表")
     * @Apidoc\Returned("pay_type_list", type="array", desc="采购支付方式列表")
     * @Apidoc\Returned("time_list", type="array", desc="请假周期列表")
     * @Apidoc\Returned("data1", type="array", desc="采购类型列表")
     * @Apidoc\Returned("data2", type="array", desc="呈批类型列表")
     * @Apidoc\Returned("data5", type="array", desc="出差类型列表")
     * @Apidoc\Returned("data6", type="array", desc="请假类型列表")
     * @Apidoc\Returned("data8", type="array", desc="维修类型列表")
     * @Apidoc\Returned("data9", type="array", desc="合同类型列表")
     */
    public function get_type_list()
    {
        $data = CommonService::get_data();
        $this->success('类型数据', $data);
    }

    /**
     * 发起人列表
     *
     * @Apidoc\Desc("入库模块")
     * @Apidoc\Method("POST")
     * @Apidoc\Param("page", type="integer",require=true, desc="页数")
     * @Apidoc\Param("page_num", type="integer", require=true, desc="每页数量")
     * @Apidoc\Returned("userid", type="string", desc="userid")
     * @Apidoc\Returned("name", type="string", desc="姓名")
     **/
    public function get_user_list()
    {
        $offset = $this->off_set;
        $length = $this->page_num;
        $user = $this->user;
        $list = UserService::get_list(0,$offset, $length);
        $this->success('发起人列表', $list);
    }

    /**
     * 维修人员列表
     *
     * @Apidoc\Desc("维修模块")
     * @Apidoc\Method("POST")
     * @Apidoc\Param("type", type="integer", require=true, desc="类型:1=物业主管,2=信息负责人")
     **/
    public function get_maintain_user(){
        $type = $this->request->post('type');
        if (!array_key_exists($type, MaintainConstant::get_type_list())) {
            $this->success('维修人员列表.');
        }
        $list = UserService::get_maintain_user($type);
        $this->success('维修人员列表',$list);
    }

    /**
     * 获取导入模板
     *
     * @Apidoc\Desc("申购模块,入库模块,领用模块")
     * @Apidoc\Method("POST")
     * @Apidoc\Param("module", type="integer", require=true, desc="模块类型:1=申购申请,3=入库申请,4=领用申请")
     * @Apidoc\Returned("url", type="string", desc="导入模板路径")
     **/
    public function get_import_template(){
        $module = $this->request->post('module');
        if (!in_array($module, [CommonConstant::MODULE_1, CommonConstant::MODULE_3, CommonConstant::MODULE_4])) {
            $this->error('请选择正确的模块类型');
        }
        switch ($module){
            case CommonConstant::MODULE_1:
                $url = $this->request->domain().'/导入模板-采购物品.xlsx';
                break;
            case CommonConstant::MODULE_3:
                $url = $this->request->domain().'/导入模板-入库物品.xlsx';
                break;
            case CommonConstant::MODULE_4:
                $url = $this->request->domain().'/导入模板-领用物品.xlsx';
                break;
        }
        $data = compact("url");
        $this->success('导入模板',$data);
    }

    /**
     * 导入
     *
     * @Apidoc\Desc("申购模块,入库模块,领用模块")
     * @Apidoc\Method("POST")
     * @Apidoc\Param("module", type="integer", require=true, desc="模块类型:1=申购申请,3=入库申请,4=领用申请")
     * @Apidoc\Param("file", type="string", require=true, desc="上传后的文件路径")
     * @return void
     * @throws PDOException
     * @throws BindParamException
     */
    public function import()
    {
        $module = $this->request->post('module');
        $file = $this->request->post('file');
        if (!in_array($module, [CommonConstant::MODULE_1, CommonConstant::MODULE_3, CommonConstant::MODULE_4])) {
            $this->error('请选择正确的模块类型');
        }
        if (!$file) {
            $this->error('请选择文件');
        }
        $filePath = $_SERVER['DOCUMENT_ROOT'] . '/' . $file;
        if (!is_file($filePath)) {
            $this->error('文件未找到');
        }
        //实例化reader
        $ext = pathinfo($filePath, PATHINFO_EXTENSION);
        if (!in_array($ext, ['csv', 'xls', 'xlsx'])) {
            $this->error('未知的数据格式');
        }
        if ($ext === 'csv') {
            $file = fopen($filePath, 'r');
            $filePath = tempnam(sys_get_temp_dir(), 'import_csv');
            $fp = fopen($filePath, 'w');
            $n = 0;
            while ($line = fgets($file)) {
                $line = rtrim($line, "\n\r\0");
                $encoding = mb_detect_encoding($line, ['utf-8', 'gbk', 'latin1', 'big5']);
                if ($encoding !== 'utf-8') {
                    $line = mb_convert_encoding($line, 'utf-8', $encoding);
                }
                if ($n == 0 || preg_match('/^".*"$/', $line)) {
                    fwrite($fp, $line . "\n");
                } else {
                    fwrite($fp, '"' . str_replace(['"', ','], ['""', '","'], $line) . "\"\n");
                }
                $n++;
            }
            fclose($file) || fclose($fp);

            $reader = new Csv();
        } elseif ($ext === 'xls') {
            $reader = new Xls();
        } else {
            $reader = new Xlsx();
        }

        //加载文件
        $insert = [];
        $data = []; // 导入的同一一级分类和二级分类和商品名称的数组
        $category_first_data = []; // 导入的分类数组
        $use_data = []; // 筛选后的领用数组
        $apply_goods_data = []; // 返回的数组
        $error_data = []; // 错误提示数组
        $flag = 2; // 默认批量导入
        try {
            if (!$PHPExcel = $reader->load($filePath)) {
                $this->error('未知的数据格式!');
            }
            $currentSheet = $PHPExcel->getSheet(0);  //读取文件中的第一个工作表
            $allColumn = $currentSheet->getHighestDataColumn(); //取得最大的列号
            $allRow = $currentSheet->getHighestRow(); //取得一共有多少行
            $maxColumnNumber = Coordinate::columnIndexFromString($allColumn);

            if ($module == CommonConstant::MODULE_4) {
                $fields = ['goods_no', 'goods_category_first', 'goods_category_id', 'goods_name', 'goods_sku_value', 'stock'];
            } else {
                $fields = ['goods_no', 'goods_category_first', 'goods_category_id', 'goods_brand', 'goods_name', 'goods_sku_value', 'stock', 'price', 'total_price'];
            }

            for ($currentRow = 2; $currentRow <= $allRow; $currentRow++) {
                $values = [];
                for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                    $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                    $values[] = is_null($val) ? '' : trim($val); // 消除空格
                }
                $values = array_filter($values); // 过滤空值
                $temp = array_combine($fields, $values); // 合并两个数组来创建一个新数组，其中的一个数组元素为键名，另一个数组元素为键值
                if ($temp) {
                    $insert[] = $temp;

                    if ($module == CommonConstant::MODULE_4) {
                        $data[$values[1] . ',' . $values[2] . ',' . $values[3]][] = $temp;
                        $category_first_data[$values[1]][$values[2]] = $values[2];
                    } else {
                        $data[$values[1] . ',' . $values[2] . ',' . $values[4]][] = $temp;
                    }

                }
            }
        } catch (Exception $exception) {
            $this->error('出现错误：' . $exception->getMessage());
        }
        if (!$insert) {
            $this->error('记录未找到');
        }

        if ($module == CommonConstant::MODULE_4) {
            $category_first_list = GoodsCategoryService::get_list([['name', 'in', array_keys($category_first_data)]],1);
            $category_first_object = $category_first_list ? array_column($category_first_list->toArray(), null, 'name') : [];

            $msg = '导入的物品：';
            foreach ($data as $key => $value) {
                $arr = explode(',', $key);
                $goods_name = $arr[2];
                if(array_key_exists($arr[0],$category_first_object)){
                    // 一级里有该商品分类
                    $category_first_info = $category_first_object[$arr[0]];
                    $goods_category_first_id = $category_first_info['id'];
                    $category_second_object = $category_first_info['childlist'] ? array_column($category_first_info['childlist'], null, 'name') : [];
                    if(array_key_exists($arr[1],$category_second_object)){
                        // 二级里有该商品分类
                        $category_second_info = $category_second_object[$arr[1]];
                        $goods_category_id = $category_second_info['id'];
                        $goods_info = Goods::field('status,is_deleted,create_at', true)
                            ->where('goods_category_first', $goods_category_first_id)
                            ->where('goods_category_id', $goods_category_id)
                            ->where('goods_name', $goods_name)
                            ->where('is_deleted', CommonConstant::IS_DELETED_0)
                            ->with([
                                'goodsStock',
                            ])
                            ->find();
                        if ($goods_info) {
                            // 商品库里有该商品
                            $goods_info = $goods_info->toArray();
                            $goods_stock_object = array_column($goods_info['goods_stock'], null, 'name');
                            foreach ($value as $kk=>$val) {
                                if (array_key_exists($val['goods_sku_value'], $goods_stock_object)) {
                                    // 商品库里有该商品规格
                                    $goods_stock_info = $goods_stock_object[$val['goods_sku_value']];
                                    $total_stock = $goods_stock_info['stock']; // 商品库的库存
                                    $stock = isset($val['stock']) && $val['stock'] > 0 ? $val['stock'] : 0; // 要领用的数量
                                    $lack_stock = $stock - $total_stock;
                                    if($total_stock > 0){
                                        // 商品规格有库存
                                        $use_data[$key][] = $val;
                                        $use_data[$key][$kk]['goods_id'] = $goods_info['id'];
                                        $use_data[$key][$kk]['goods_category_first'] = $goods_category_first_id;
                                        $use_data[$key][$kk]['goods_category_id'] = $goods_category_id;
                                        $use_data[$key][$kk]['id'] = $goods_stock_info['id'];
                                        if($lack_stock > 0){
                                            // 商品规格库存不足
                                            $use_data[$key][$kk]['stock'] = $total_stock; // 替换库存
                                            $error_data[] = [
                                                'msg' => $msg . $goods_name . '-' . $val['goods_sku_value'] . '库存不足，缺少' . $lack_stock . '件',
                                            ];
                                        }
                                    } else{
                                        $error_data[] = [
                                            'msg' => $msg . $goods_name . '-' . $val['goods_sku_value'] . '库存不足，缺少' . $lack_stock . '件',
                                        ];
                                    }
                                } else {
                                    // 商品库里没有该商品规格
                                    $error_data[] = [
                                        'msg' => $msg . $goods_name . '-' . $val['goods_sku_value'] . '商品库不存在',
                                    ];
                                }
                            }
                        } else {
                            // 商品库里没有该商品
                            $error_data[] = [
                                'msg' => $msg . $goods_name . '商品库不存在',
                            ];
                        }
                    } else{
                        // 二级里没有该商品分类
                        $error_data[] = [
                            'msg' => $msg . $goods_name . '商品库不存在',
                        ];
                    }
                } else{
                    // 一级里没有该商品分类
                    $error_data[] = [
                        'msg' => $msg . $goods_name . '商品库不存在',
                    ];
                }
            }
            $data = $use_data;
            $flag = 3; // 商品库选择
        }

        foreach ($data as $key => $value) {
            // 商品
            $goods_data = [];
            $goods_stock_data = [];
            $total_price = 0;
            foreach ($value as $kk => $val) {
                // 规格值
                $stock = isset($val['stock']) && $val['stock'] > 0 ? $val['stock'] : 0;
                $price = isset($val['price']) && $val['price'] > 0 ? $val['price'] : 0;
                $total_price = bcadd($total_price, $stock * $price, 2);
                $goods_stock_data[] = [
                    'id' => isset($val['id']) ? $val['id'] : 0,
                    'name' => $val['goods_sku_value'],
                    'stock' => $stock,
                    'price' => $price,
                ];
                $goods_data = [
                    'goods_id' => isset($val['goods_id']) ? $val['goods_id'] : 0,
                    'goods_category_first' => $val['goods_category_first'],
                    'goods_category_id' => $val['goods_category_id'],
                    'goods_no' => $val['goods_no'],
                    'goods_name' => $val['goods_name'],
                    'goods_brand' => isset($val['goods_brand']) ? $val['goods_brand'] : '',
                ];
            }
            $goods_data['flag'] = $flag;
            $goods_data['total_price'] = $total_price;
            $goods_data['goods_stock'] = $goods_stock_data;
            $apply_goods_data[] = $goods_data;
        }

        $data = compact("apply_goods_data", "error_data");
        $error_data ? $this->success('领用物品提示', $data) : $this->success('导入成功', $data);
    }

    /**
     * 导入1
     */
    public function import1()
    {
        $file = $this->request->post('file');
        if (!$file) {
            $this->error('请选择文件');
        }
        $filePath = $_SERVER['DOCUMENT_ROOT'] . '/' . $file;
        if (!is_file($filePath)) {
            $this->error('文件未找到');
        }
        //实例化reader
        $ext = pathinfo($filePath, PATHINFO_EXTENSION);
        if (!in_array($ext, ['csv', 'xls', 'xlsx'])) {
            $this->error('未知的数据格式');
        }
        if ($ext === 'csv') {
            $file = fopen($filePath, 'r');
            $filePath = tempnam(sys_get_temp_dir(), 'import_csv');
            $fp = fopen($filePath, 'w');
            $n = 0;
            while ($line = fgets($file)) {
                $line = rtrim($line, "\n\r\0");
                $encoding = mb_detect_encoding($line, ['utf-8', 'gbk', 'latin1', 'big5']);
                if ($encoding !== 'utf-8') {
                    $line = mb_convert_encoding($line, 'utf-8', $encoding);
                }
                if ($n == 0 || preg_match('/^".*"$/', $line)) {
                    fwrite($fp, $line . "\n");
                } else {
                    fwrite($fp, '"' . str_replace(['"', ','], ['""', '","'], $line) . "\"\n");
                }
                $n++;
            }
            fclose($file) || fclose($fp);

            $reader = new Csv();
        } elseif ($ext === 'xls') {
            $reader = new Xls();
        } else {
            $reader = new Xlsx();
        }

        //加载文件
        $insert = [];
        try {
            if (!$PHPExcel = $reader->load($filePath)) {
                $this->error('未知的数据格式!');
            }
            $currentSheet = $PHPExcel->getSheet(0);  //读取文件中的第一个工作表
            $allColumn = $currentSheet->getHighestDataColumn(); //取得最大的列号
            $allRow = $currentSheet->getHighestRow(); //取得一共有多少行
            $maxColumnNumber = Coordinate::columnIndexFromString($allColumn);

            for ($currentRow = 2; $currentRow <= $allRow; $currentRow++) {
                $values = [];
                for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                    $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                    $values[] = is_null($val) ? '' : trim($val); // 消除空格
                }
                $values = array_filter($values); // 过滤空值

                $first[$values[0]] = $values[0];
                $second[$values[0]][$values[1]] = $values[1];
                $third[$values[1]][$values[2]] = $values[2];
            }
        } catch (Exception $exception) {
            $this->error('出现错误：' . $exception->getMessage());
        }
//        p($first);
//        p($second);
//        p($third);
//        exit;
        foreach ($first as $key=>$val){
            if(array_key_exists($val,$second)){
                $first1 = Db::table('dd_category_job')->insertGetId(['name'=>$val]);
                $second_list = $second[$val];
                foreach ($second_list as $v){
                    if(array_key_exists($v,$third)){
                        $second1 = Db::table('dd_category_job')->insertGetId(['pid'=>$first1,'name'=>$v]);
                        $third_list = $third[$v];
                        foreach ($third_list as $vv){
                            Db::table('dd_category_job')->insertGetId(['pid'=>$second1,'name'=>$vv]);
                        }
                    }
                }
            }
        }
        $this->success('导入成功');
    }

    /**
     * 重置合同编号(定时任务 每年1月1日0点1分执行)
     *
     * @Apidoc\Method("POST")
     **/
    public function change_contract_no(){
        $data = date('md') == '0101' ? CommonService::change_contract_no() : [];
        $this->success('重置合同编号成功',$data);
    }

    /**
     * 测试
     *
     * @Apidoc\Method("POST")
     * @Apidoc\Param("id", type="integer",require=true, desc="ID")
     */
    public function test()
    {
        $id = input('id') ?: 0;
        $data = '';
        $name = '';
        $html = ApproveInfoService::get_html($data);
        $realpath = ApproveInfoService::getPath($name);
        $pdf = new \TCPDF();
        $pdf = ApproveInfoService::setPdfAttr($pdf);
        ApproveInfoService::exportPdf($pdf, $html, $realpath);
        $this->success('success',['url' => $realpath, 'fullurl' => 'https://' . $_SERVER['HTTP_HOST'] . $realpath]);
    }

}