wkcrm/application/common.php

<?php
error_reporting(E_ERROR | E_PARSE);
/**
 * 行为绑定
 */
\think\Hook::add('app_init', 'app\\common\\behavior\\InitConfigBehavior');

use app\common\adapter\AuthAdapter;
use app\admin\model\User as UserModel;
use app\admin\model\Field as FieldModel;
use think\Request;
use think\Db;
use extend\email\Email;
use think\Lang;
use think\helper\Time;
use com\IpLocation;
use app\crm\traits\DataTime;

/**
 * 对象 转 数组
 *
 * @param object $obj 对象
 * @return array
 */
function object_to_array($obj)
{
    $obj = (array)$obj;
    foreach ($obj as $k => $v) {
        if (gettype($v) == 'resource') {
            return;
        }
        if (gettype($v) == 'object' || gettype($v) == 'array') {
            $obj[$k] = (array)object_to_array($v);
        }
    }
    return $obj;
}

/**
 * 数组 转 对象
 *
 * @param array $arr 数组
 * @return object
 */
function array_to_object($arr)
{
    if (gettype($arr) != 'array') {
        return;
    }
    foreach ($arr as $k => $v) {
        if (gettype($v) == 'array' || getType($v) == 'object') {
            $arr[$k] = (object)array_to_object($v);
        }
    }
    return (object)$arr;
}

/**
 * 返回对象
 * @param array $array 响应数据
 */
function resultArray($array)
{
    if (isset($array['data'])) {
        $array['error'] = '';
        $code = 200;
    } elseif (is_array($array['error'])) {
        $code = 402; //返回数组格式
        $array['data'] = '';
    } elseif (isset($array['error'])) {
        $code = 400;
        $array['data'] = '';
    }
    return json([
        'code' => $code,
        'data' => $array['data'],
        'error' => $array['error']
    ]);
}

/**
 * 调试方法
 * @param array $data [description]
 */
function p($data, $die = 1)
{
    echo "<pre>";
    print_r($data);
    echo "</pre>";
    if ($die) die;
}

/**
 * 用户密码加密方法
 * @param string $str 加密的字符串
 * @param  [type] $auth_key 加密符
 * @param  [string] $username 用户名
 * @return string           加密后长度为32的字符串
 */
function user_md5($str, $auth_key = '', $username = '')
{
    return '' === $str ? '' : md5(sha1($str) . md5($str . $auth_key));
}

/**
 * 金额展示规则,超过1万时以万为单位，低于1万时以千为单位，低于1千时以元为单位
 * @param string $money 金额
 * @return string
 * @author Michael_xu
 */
function money_view($money)
{
    $data = '0元';
    if (($money / 10000) > 1) {
        $data = is_int($money / 10000) ? ($money / 10000) . '万' : rand(($money / 10000), 2) . '万';
    } elseif (($money / 1000) > 1) {
        $data = is_int($money / 1000) ? ($money / 1000) . '千' : rand(($money / 1000), 2) . '千';
    } else {
        $data = $money . '元';
    }
    return $data;
}

/**
 * 高级筛选条件
 * @param  $array 条件数组
 * @param  $module 相关模块
 * @return string
 * @author Michael_xu
 */
function where_arr($array = [], $m = '', $c = '', $a = '')
{
    $userModel = new UserModel();
    $checkStatusList = ['待审核', '审核中', '审核通过', '审核失败', '已撤回', '未提交', '已作废'];
    $checkStatusArray = ['待审核' => 0, '审核中' => 1, '审核通过' => 2, '审核失败' => 3, '已撤回' => 4, '未提交' => 5, '已作废' => 6];
    //查询自定义字段模块多选字段类型
    $check_field_arr = [];
    //特殊字段

    //过滤系统参数
    $unset_arr = ['page', 'limit', 'order_type', 'order_field'];
    if (!is_array($array)) {
        return [];
    }
    $types = $c;
    foreach ($array as $k => $v) {
        if (!in_array($k, $unset_arr)) {
            $c = $types . '.';
            if ($k == 'customer_name') {
                $k = 'name';
                $c = 'customer.';
            }
            if ($k == 'contract_name') {
                $k = 'name';
                $c = 'contract.';
            }
            if ($k == 'business_name') {
                $k = 'name';
                $c = 'business.';
            }
            if ($k == 'contacts_name') {
                $k = 'name';
                $c = 'contacts.';
            }
            if ($v['form_type'] == 'date') {
                if (!empty($v['start'])) $v['start'] = date('Y-m-d', $v['start']);
                if (!empty($v['end'])) $v['end'] = date('Y-m-d', $v['end']);
            }
            # 自定义字段的user team_id（非自定义字段）
            if ($v['form_type'] == 'user' && in_array($k, ['team_id'])) {
//                ro_user_id rw_user_id
                if ($v['condition'] == 'in') {
                    return "(" . $c . 'ro_user_id' . " like ',%" . $v['value'] . "OR " . $c . 'rw_user_id' . " like ',%" . $v['value'] . ")";
                } elseif ($v['condition'] == 'not in') {
                    return "(" . $c . $k . " not like ',%" . $v['value'][0] . "%,' OR " . $c . $k . " is null)";
                } elseif ($v['condition'] == 'isNull') {
                    return "(" . $c . 'ro_user_id' . "eq" . $v['value'] . "OR " . $c . 'rw_user_id' . " eq" . $v['value'] . ")";
                } elseif ($v['condition'] == 'isNotNull') {
                    return "(" . $c . 'ro_user_id' . "neq" . $v['value'] . "OR " . $c . 'rw_user_id' . " neq" . $v['value'] . ")";
                }
            }
            # 自定义字段的user、structure类型
            if (($v['form_type'] == 'user' && !in_array($k, ['create_user_id', 'owner_user_id'])) || $v['form_type'] == 'structure') {
                if ($v['condition'] == 'is') $v['condition'] = 'contains';
                if ($v['condition'] == 'isNot') {
                    return "(" . $c . $k . " not like ',%" . $v['value'][0] . "%,' OR " . $c . $k . " is null)";
                }
            }
            # 处理多选字段的精确搜索
            if ($v['form_type'] == 'checkbox' && !empty($v['value'])) {
                if ($v['condition'] == 'is' && count($v['value']) == 1) $v['value'][0] = ',' . $v['value'][0] . ',';
                if ($v['condition'] == 'is' && count($v['value']) > 1) {
                    $checkboxLike = '';
                    foreach ($v['value'] as $kk => $vv) {
                        $checkboxLike .= $c . $k . " like " . "',%" . $vv . "%,' AND ";
                    }
                    return "(" . $checkboxLike . "LENGTH(" . $c . $k . ") = LENGTH('" . arrayToString($v['value']) . "'))";
                }
            }
            if ($types == 'contract' && !empty($v['value'])) {
                switch ($k) {
                    case 'business_id' :
                        $k = 'name';
                        $c = 'business.';
                        break;
                    case 'contacts_id' :
                        $contactsIds = [];
                        foreach ($v['value'] as $kk => $vv) {
                            $contactsIdArray = db('crm_contacts')->whereLike('name', '%' . $vv . '%')->column('contacts_id');
                            foreach ($contactsIdArray as $kkk => $vvv) {
                                $contactsIds[] = $vvv;
                            }
                        }
                        $v['value'] = array_unique($contactsIds);
                        break;
                }
            }
            if ($types == 'receivables' && $v['name'] == '合同编号' && !empty($v['value'])) {
                $k = 'num';
                $c = 'contract.';
            }
            if ($types == 'receivables' && $k == 'plan_id' && !empty($v['value'])) {
                $planIds = [];
                foreach ($v['value'] as $kk => $vv) {
                    $planIdArray = db('crm_receivables_plan')->whereLike('num', '%' . $vv . '%')->column('plan_id');
                    foreach ($planIdArray as $kkk => $vvv) {
                        $planIds[] = $vvv;
                    }
                }
                $v['value'] = array_unique($planIds);
            }
            if ($types == 'invoice' && $v['type'] == 'invoice_status' && !empty($v['value'])) {
                foreach ($v['value'] as $kk => $vv) {
                    if ($vv == '已开票') $v['value'][$kk] = 1;
                    if ($vv == '未开票') $v['value'][$kk] = 0;
                }
            }
            if ($types == 'visit' && $v['type'] == 'contract_name' && !empty($v['value'])) {
                $k = 'num';
                $c = 'contract.';
            }
            if ($types == 'visit' && $v['type'] == 'contacts_name' && !empty($v['value'])) {
                $k = 'name';
                $c = 'contacts.';
            }
            if ($k == 'check_status' && is_array($v) && in_array($v['value'][0], $checkStatusList) && !empty($v['value'])) {
                $v['value'] = $checkStatusArray[$v['value'][0]] ?: '0';
            }
            if (is_array($v)) {
                if ($v['state']) {
                    $address_where[] = '%' . $v['state'] . '%';
                    if ($v['city']) {
                        $address_where[] = '%' . $v['city'] . '%';
                        if ($v['area']) {
                            $address_where[] = '%' . $v['area'] . '%';
                        }
                    }
                    if ($v['condition'] == 'not_contain') {
                        $where[$c . $k] = ['notlike', $address_where, 'OR'];
                    } else {
                        $where[$c . $k] = ['like', $address_where, 'AND'];
                    }
                } elseif (!empty($v['value']['state'])) {
                    $addressWhere[] = '%' . $v['value']['state'] . '%';
                    if (!empty($v['value']['city'])) $addressWhere[] = '%' . $v['value']['city'] . '%';
                    if (!empty($v['value']['area'])) $addressWhere[] = '%' . $v['value']['area'] . '%';
                    if ($v['condition'] == 'is') {
                        $where[$c . $k] = ['like', $addressWhere, 'AND'];
                    } else {
                        $where[$c . $k] = ['notlike', $addressWhere, 'OR'];
                    }
                } elseif (!empty($v['start']) || !empty($v['end'])) {
                    if ($v['start'] && $v['end']) {
                        $where[$c . $k] = ['between', [$v['start'], $v['end']]];
                    } elseif ($v['start']) {
                        $where[$c . $k] = ['egt', $v['start']];
                    } else {
                        $where[$c . $k] = ['elt', $v['end']];
                    }
                } elseif (!empty($v['start_date']) || !empty($v['end_date'])) {
                    if ($v['start_date'] && $v['end_date']) {
                        $where[$c . $k] = ['between', [$v['start_date'], $v['end_date']]];
                    } elseif ($v['start_date']) {
                        $where[$c . $k] = ['egt', $v['start_date']];
                    } else {
                        $where[$c . $k] = ['elt', $v['end_date']];
                    }
                } elseif (!empty($v['value']) || $v['value'] === '0') {
                    if (in_array($k, $check_field_arr)) {
                        $where[$c . $k] = field($v['value'], 'contains');
                    } else {
                        if ($v['condition'] == 'isNot' || $v['condition'] == 'notContains') {
                            $where[$c . $k] = [field($v['value'], $v['condition'], $k), ['null'], 'or'];
                        } else {
                            $where[$c . $k] = field($v['value'], $v['condition'], $k);
                        }
                    }
                } elseif (in_array($v['condition'], ['isNull', 'isNotNull', 'in'])) {
                    $where[$c . $k] = field($v['value'], $v['condition']);
                } else {
                    $where[$c . $k] = $v;
                }
            } elseif (!empty($v)) {
                $where[$c . $k] = field($v);
            } else {
                $where[$c . $k] = $v;
            }
        }
    }

    # 商机阶段为赢单、输单、无效的值保存在is_end中，将status_id改为is_end；
    if (!empty($where['business.status_id']) && in_array($where['business.status_id'][1], [1, 2, 3])) {
        $where['business.is_end'] = $where['business.status_id'];
        unset($where['business.status_id']);
    }

    return $where ?: [];
}

/**
 * 高级筛选
 *
 * @param array $param 搜索参数
 * @param string $m 模块：crm log work ...
 * @param string $c 栏目：leads customer ...
 * @param string $a 方法：index save ...
 * @return array
 * @since 2021-05-20
 * @author fanqi
 */
function advancedQuery($param, $m = '', $c = '', $a = '')
{
    // 结果数据
    $result = [];
    // 原始前缀
    $prefix = $c . '.';
    // 等于（时间段）类型
    $betweenType = [
        'year', 'lastYear', 'nextYear', 'firstHalfYear', 'nextHalfYear', 'quarter', 'lastQuarter',
        'nextQuarter', 'month', 'lastMonth', 'nextMonth', 'week', 'lastWeek', 'nextWeek', 'today',
        'yesterday', 'tomorrow', 'previous7day', 'previous30day', 'future7day', 'future30day'
    ];

    foreach ($param as $key => $value) {
        // 过滤不能参与搜索的字段类型
        if (!empty($value['form_type']) && in_array($value['form_type'], ['file', 'handwriting_sign', 'desc_text', 'detail_table', 'date_interval'])) continue;
        // 初始化前缀
        $c = $prefix;
        // 清除空格
        if (isset($value['condition'])) $value['condition'] = trim($value['condition']);
        // 处理表前缀和字段名称
        list($c, $key) = advancedQueryParam($c, $key, $value['name']);

        if ($key == 'check_status' && !is_array($value)) $result[$c . $key] = $value;
        if ($key == 'status_id' && !is_array($value)) $result[$c . $key] = $value;
        if ($key == 'customer_id' && !is_array($value)) $result['customer.' . $key] = $value;
        if ($key == 'contract_id' && !is_array($value)) $result['contract.' . $key] = $value;
        if ($key == 'business_id' && !is_array($value)) $result['business.' . $key] = $value;

        // 仪表盘参数
        if (!empty($value['value'][0]) && empty($value['condition'])) {
            $value['condition'] = 'is';
            $value['form_type'] = 'user';
        }
        if (!empty($value['start']) && !empty($value['end'])) {
            $value['value'][0] = date('Y-m-d H:i:s', $value['start']);
            $value['value'][1] = date('Y-m-d H:i:s', $value['end']);
            $value['form_type'] = 'datetime';
            $value['condition'] = 'between';
        }
        if ($key == 'check_status' && !is_array($value)) {
            unset($value);
            $value['value'][0] = '审核通过';
            $value['form_type'] = 'check_status';
            $value['name'] = '审核状态';
            $value['type'] = 'check_status';
            $value['condition'] = 'is';
        }

        // 代办事项
        if (isset($value) && !isset($value['condition']) && !isset($value['value']) && !isset($value['form_type'])) {
            $result[$c . $key] = is_array($value) ? $value : ['in', $value];
            continue;
        }

        // 等于（时间段）类型筛选
        if (!empty($value['value'][0]) && in_array($value['value'][0], $betweenType)) {
            $value = advancedQueryHandleDate($value);
        }

        // 创建人、负责人
        if (in_array($key, ['create_user_id', 'owner_user_id'])) {
            if($value['condition'] == 'contains'){
                $result[$c . $key] = ['in', $value['value']];
            }else if ($value['condition'] == 'notContains') {
               $result[$c . $key] = ['not in', $value['value']];
            }else if ($value['condition'] == 'isNull') {
               $result[$c . $key] = ['eq', ''];
            }else if ($value['condition'] == 'isNotNull') {
               $result[$c . $key] = ['neq', ''];
            }
        }
        // 模块、审核状态、成交状态、产品分类、单行文本、多行文本、网址、手机、邮箱、下拉框、布尔值、多选、定位、创建人、负责人
        if (isset($value['form_type']) && in_array($value['form_type'], ['module', 'check_status', 'deal_status', 'category', 'text', 'textarea', 'mobile', 'email', 'select', 'boolean_value', 'checkbox', 'location', 'website','user',])) {
            $res = advancedQueryFormatForCommon($value['value'], $value['condition'], $value['form_type'], $key);
            if($key == 'order_id'){
                $arr = [];
                if($c == 'outbound.'){
                    $retreatOutboundIds =  db('jxc_retreat')
                                    ->alias('a')
                                    ->join('jxc_outbound b','a.retreat_id = b.order_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.outbound_type', '采购退货出库')
                                    // ->fetchSql()
                                    ->column('outbound_id');
                    $saleOutboundIds =  db('jxc_sale')
                                    ->alias('a')
                                    ->join('jxc_outbound b','a.sale_id = b.order_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.outbound_type', '销售出库')
                                    // ->fetchSql()
                                    ->column('outbound_id');
                    $arr = empty($retreatOutboundIds) ? $saleOutboundIds : array_merge($retreatOutboundIds,$saleOutboundIds);
                    $result[$c . 'outbound_id'] = ['in', $arr];
                }elseif ($c == 'receipt.') {
                    $purchaseOutboundIds =  db('jxc_purchase')
                                    ->alias('a')
                                    ->join('jxc_receipt b','a.purchase_id = b.order_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.receipt_type', '采购入库')
                                    // ->fetchSql()
                                    ->column('b.receipt_id');
                    $salereturnOutboundIds =  db('jxc_salereturn')
                                    ->alias('a')
                                    ->join('jxc_receipt b','a.salereturn_id = b.order_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.receipt_type', '销售退货入库')
                                    // ->fetchSql()
                                    ->column('b.receipt_id');
                    $arr = empty($purchaseOutboundIds) ? $salereturnOutboundIds : array_merge($purchaseOutboundIds,$salereturnOutboundIds);
                    $result[$c . 'receipt_id'] = ['in', $arr];
                }
            }else if($key == 'related_id'){
                $arr = [];
                if($c == 'collection.'){
                    $retreatOutboundIds =  db('jxc_retreat')
                                    ->alias('a')
                                    ->join('jxc_collection b','a.retreat_id = b.related_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.collection_type', '采购退货')
                                    // ->fetchSql()
                                    ->column('collection_note_id');
                    $saleOutboundIds =  db('jxc_sale')
                                    ->alias('a')
                                    ->join('jxc_collection b','a.sale_id = b.related_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.collection_type', '销售回款')
                                    // ->fetchSql()
                                    ->column('collection_note_id');
                    $arr = empty($retreatOutboundIds) ? $saleOutboundIds : array_merge($retreatOutboundIds,$saleOutboundIds);
                    $result[$c . 'collection_note_id'] = ['in', $arr];
                }elseif ($c == 'payment.') {
                    $purchaseOutboundIds =  db('jxc_purchase')
                                    ->alias('a')
                                    ->join('jxc_payment b','a.purchase_id = b.related_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.payment_type', '采购')
                                    // ->fetchSql()
                                    ->column('b.payment_note_id');
                    $salereturnOutboundIds =  db('jxc_salereturn')
                                    ->alias('a')
                                    ->join('jxc_payment b','a.salereturn_id = b.related_id')
                                    ->where('a.order_number', [$res[0], $res[1]])
                                    ->where('b.payment_type', '销售退货')
                                    // ->fetchSql()
                                    ->column('b.payment_note_id');
                    $arr = empty($purchaseOutboundIds) ? $salereturnOutboundIds : array_merge($purchaseOutboundIds,$salereturnOutboundIds);
                    $result[$c . 'payment_note_id'] = ['in', $arr];
                }
            }else if($key == 'collection_object'){
                $arr = [];
                if($c == 'collection.'){
                    $supplierOutboundIds =  db('jxc_supplier')
                                    ->alias('a')
                                    ->join('jxc_collection b','a.supplier_id = b.collection_object')
                                    ->where('a.supplier_name', [$res[0], $res[1]])
                                    ->where('b.collection_type', '采购退货')
                                    // ->fetchSql()
                                    ->column('collection_note_id');
                    $customerOutboundIds =  db('crm_customer')
                                    ->alias('a')
                                    ->join('jxc_collection b','a.customer_id = b.collection_object')
                                    ->where('a.name', [$res[0], $res[1]])
                                    ->where('b.collection_type', '销售回款')
                                    // ->fetchSql()
                                    ->column('collection_note_id');
                    $arr = empty($supplierOutboundIds) ? $customerOutboundIds : array_merge($supplierOutboundIds,$customerOutboundIds);
                    $result[$c . 'collection_note_id'] = ['in', $arr];
                }elseif ($c == 'payment.') {
                    $supplierOutboundIds =  db('jxc_supplier')
                                    ->alias('a')
                                    ->join('jxc_payment b','a.supplier_id = b.collection_object')
                                    ->where('a.supplier_name', [$res[0], $res[1]])
                                    ->where('b.payment_type', '采购')
                                    // ->fetchSql()
                                    ->column('b.payment_note_id');
                    $customerOutboundIds =  db('crm_customer')
                                    ->alias('a')
                                    ->join('jxc_payment b','a.customer_id = b.collection_object')
                                    ->where('a.name', [$res[0], $res[1]])
                                    ->where('b.payment_type', '销售退货')
                                    // ->fetchSql()
                                    ->column('b.payment_note_id');
                    $arr = empty($supplierOutboundIds) ? $customerOutboundIds : array_merge($supplierOutboundIds,$customerOutboundIds);
                    $result[$c . 'payment_note_id'] = ['in', $arr];
                }
            // }else if($key == 'sp_data_value'){
            //     foreach ($res[1] as $key => $v) {
            //        $arr[] = '%'.$v.'%';
            //     }
            //     $w['sp_data_value'] = ['like', $arr, 'OR'];
            //     $product_ids = db('jxc_product')->where($w)->fetchSql()->column('product_id');
            //     $result[$c . 'sp_data_value'] = [$res[0], $product_ids];
            }else{
                $result[$c . $key] = advancedQueryFormatForCommon($value['value'], $value['condition'], $value['form_type'], $key);
            }
        }

        // 日期、日期时间、数字、货币、百分数、下次联系时间
        if (isset($value['form_type']) && in_array($value['form_type'], ['date', 'datetime', 'number', 'floatnumber', 'percent', 'next_time'])) {
            $result[$c . $key] = advancedQueryFormatForDate($value);
        }

        // 地址（固定字段）、地址（自定义字段）
        if (isset($value['form_type']) && in_array($value['form_type'], ['map_address', 'position'])) {
            $result[$c . $key] = advancedQueryFormatForAddress($value['value'], $value['form_type']);
        }

        // 人员、部门
        if (isset($value['form_type']) && in_array($value['form_type'], ['user', 'structure', 'single_user']) && !in_array($key, ['create_user_id', 'owner_user_id']) && $value['type'] != 'team_id') {
            if ($value['type'] == 'owner_structure') { # 所属部门
                $userIds = db('admin_user')->whereIn('structure_id', implode(',', $value['value']))->column('id');
                $result[$c . 'owner_user_id'] = ['in', $userIds];
            } else {
                $result[$c . $key] = advancedQueryFormatForPersonnel($value['value'], $value['condition']);
            }
        }
        // 商机状态组
        if (isset($value['form_type']) && $value['form_type'] == 'business_type') {
            if (!empty($value['type_id'])) $result[$c . 'type_id'] = ['eq', $value['type_id']];
            if (!empty($value['status_id']) && in_array($value['status_id'], [1, 2, 3])) $result[$c . 'is_end'] = ['eq', $value['status_id']];
            if (!empty($value['status_id']) && !in_array($value['status_id'], [1, 2, 3])) $result[$c . 'status_id'] = ['eq', $value['status_id']];
        }

        // 回款计划
        if (isset($value['form_type']) && $value['form_type'] == 'receivables_plan' && !empty($value['value'])) {
            $result[$c . 'plan_id'] = advancedQueryFormatForPlan($value['value']);
        }
    }
    return $result;
}

/**
 * 处理高级筛选查询前缀、字段名称
 *
 * @param string $prefix 表前缀
 * @param string $field 字段名
 * @param string $name 字段中文名
 * @return array
 * @since 2021-05-22
 * @author fanqi
 */
function advancedQueryParam($prefix, $field, $name)
{
    // 要变更的前缀
    $prefixChange = [
        'customer_name' => 'customer.',
        'contacts_name' => 'contacts.',
        'business_name' => 'business.',
        'contract_name' => 'contract.',
        'business_id' => 'business.',
        'contacts_id' => 'contacts.',

        'supplier_id' => 'supplier.',
        'purchase_id' => 'purchase.',
        'sale_id' => 'sale.',
        'warehouse_id' => 'warehouse.',
        'original_warehouse_id' => 'warehouse.',
        'current_warehouse_id' => 'warehouse.',
    ];
    # 处理供应商
    if (in_array($field, ['supplier_id'])) {
        $prefix = $prefixChange[$field];
        $field = 'supplier_name';
    }
    # 处理仓库
    if (in_array($field, ['warehouse_id'])) {
        $prefix = $prefixChange[$field];
        $field = 'warehouse_name';
    }
    if (in_array($field, ['original_warehouse_id', 'current_warehouse_id'])) {
        $prefix = $prefixChange[$field];
        $field = 'warehouse_name';
    }
    # 采购单、销售单
    if (in_array($field, ['purchase_id', 'sale_id'])) {
        $prefix = $prefixChange[$field];
        $field = 'order_number';
    }

    // 处理客户名称、联系人名称、商机名称、合同名称字段
    if (in_array($field, ['customer_name', 'contacts_name', 'business_name', 'contract_name']) && $name != '合同编号') {
        $prefix = $prefixChange[$field];
        $field = 'name';
    }
    // 处理合同下的商机ID、客户ID字段
    if ($prefix == 'contract.' && in_array($field, ['business_id', 'contacts_id'])) {
        $prefix = $prefixChange[$field];
        $field = 'name';
    }
    // 处理回款、回访下的合同编号
    if (in_array($prefix, ['receivables.', 'visit.']) && $name == '合同编号') {
        $prefix = 'contract.';
        $field = 'num';
    }
    // 处理回访下的联系人
    if ($prefix == 'visit.' && $field == 'contacts_id') {
        $prefix = 'contacts.';
        $field = 'name';
    }

    return [$prefix, $field];
}

/**
 * 回款计划查询条件
 *
 * @param array $data 搜索参数
 * @return array
 * @since 2021-05-22
 * @author fanqi
 */
function advancedQueryFormatForPlan($data)
{
    $result = [];

    $planIds = db('crm_receivables_plan')->whereIn('num', $data)->column('plan_id');

    if (!empty($planIds)) $result = ['in', $planIds];

    return $result;
}

/**
 * 地址（固定字段）、地址（自定义字段）查询条件
 *
 * @param array $data 搜索参数
 * @param string $formType 字段类型
 * @return array
 * @since 2021-05-21
 * @author fanqi
 */
function advancedQueryFormatForAddress($data, $formType)
{
    if ($formType == 'map_address') $data = implode(chr(10), $data);
    if ($formType == 'position') {
        $data = array_filter(array_column($data[0], 'name'));
        $data = implode(',', $data);
    }

    return ['like', '%' . trim($data) . '%'];
}

/**
 * 人员、部门、回访人查询条件
 *
 * @param array $data 查询参数
 * @param string $condition 查询条件
 * @return array
 */
function advancedQueryFormatForPersonnel($data, $condition)
{
    // 处理查询条件
    if ($condition == 'is') $condition = 'contains';
    if ($condition == 'isNot') $condition = 'notContains';

    // 处理查询参数
    if (in_array($condition, ['contains', 'notContains'])) {
        array_walk($data, function ($value, $key) use (&$data) {
            $data[$key] = '%,' . $value . ',%';
        });
    }

    // 搜索条件
    return advancedQueryWhere($condition, $data);
}

/**
 * 日期、日期时间、数字、货币、百分数查询条件
 *
 * @param array $data 搜索参数、类型、条件
 * @return array
 * @since 2021-05-20
 * @author fanqi
 */
function advancedQueryFormatForDate($data)
{
    # 转换日期时间类型格式
    if (in_array($data['form_type'], ['datetime', 'next_time']) && !empty($data['value'][0])) $data['value'][0] = strtotime($data['value'][0]);
    if (in_array($data['form_type'], ['datetime', 'next_time']) && !empty($data['value'][1])) $data['value'][1] = strtotime($data['value'][1]);

    return advancedQueryWhere($data['condition'], count($data['value']) == 2 ? $data['value'] : $data['value'][0]);
}

/**
 * 模块、审核状态、成交状态、产品分类、单行文本、多行文本、网址、手机、邮箱、下拉框、布尔值、多选、定位、创建人、负责人
 *
 * @param array $data 要查询的数据
 * @param string $condition 查询方式
 * @param string $formType 字段类型
 * @return array
 * @since 2021-05-20
 * @author fanqi
 */
function advancedQueryFormatForCommon($data, $condition, $formType, $key)
{
    // 处理查询方式
    if (in_array($formType, ['checkbox']) && $condition == 'is') $condition = 'contains';
    if (in_array($formType, ['checkbox']) && $condition == 'isNot') $condition = 'notContains';

    // 处理查询参数
    if(in_array($condition, ['contains', 'notContains']) && in_array($key,['create_user_id','owner_user_id'])){
        $data = advancedQueryDataUserform($data, $condition);
    }elseif (in_array($condition, ['contains', 'notContains', 'startWith', 'endWith'])){
        $data = advancedQueryDataTransform($data, $condition);
    }

    // 处理回访形式
    if (in_array($key, ['shape', 'satisfaction'])) {
        array_walk($data, function ($value, $key) use (&$data) {
            $data[$key] = $value . "\r";
        });
    }

    // 处理审核状态
    if ($formType == 'check_status') {
        $data[0] = str_replace('待审核', 0, $data[0]);
        $data[0] = str_replace('审核中', 1, $data[0]);
        $data[0] = str_replace('审核通过', 2, $data[0]);
        $data[0] = str_replace('审核失败', 3, $data[0]);
        $data[0] = str_replace('已撤回', 4, $data[0]);
        $data[0] = str_replace('未提交', 5, $data[0]);
        $data[0] = str_replace('已作废', 6, $data[0]);
    }

    return advancedQueryWhere($condition, $data,$key);
}

/**
 * 设置搜索条件
 *
 * @param string $condition 查询方式
 * @param string|array $data 查询数据
 * @return array
 * @since 2021-05-22
 * @author fanqi
 */
function advancedQueryWhere($condition, $data, $key='')
{
    $result = [];

    // NULL(0)不存在、IS(1)等于、IS_NOT(2)不等于、CONTAINS(3)包含、NOT_CONTAINS(4)不包含、IS_NULL(5)为空、IS_NOT_NULL(6)不为空
    // GT(7)大于、EGT(8)大于等于、LT(9)小于、ELT(10)小于等于、ID(11)通过id、PREFIX(12) 前缀匹配、SUFFIX(13) 后缀匹配、RANGE(14) 数字区间

    if ($condition == "in") $result = ['in', $data];                      // 等于
    if ($condition == 'is') $result = ['in', $data];                      // 等于
    if ($condition == 'isNot') $result = [['notin', $data],['null'],'OR'];                   // 不等于
    if ($condition == 'contains') $result = ['like', $data, 'OR'];              // 包含
    if ($condition == 'notContains') $result = [['notlike', $data, 'AND'],['null'],'OR'];          // 不包含
    if ($condition == 'startWith') $result = ['like', $data, 'OR'];              // 开始于
    if ($condition == 'endWith') $result = ['like', $data, 'OR'];              // 结束于
    if ($condition == 'gt') $result = ['gt', $data];                      // 大于
    if ($condition == 'lt') $result = ['lt', $data];                      // 小于
    if ($condition == 'egt') $result = ['egt', $data];                     // 大于等于
    if ($condition == 'elt') $result = ['elt', $data];                     // 小于等于
    if ($condition == 'between') $result = ['between', $data];                 // 处于某个时间段
    if ($condition == 'range') $result = ['between', $data];                 // 处于某个时间段
    if ($condition == 'isNull') $result = [['eq', ''], ['null'], 'OR'];       // 为空
    if ($condition == 'isNotNull') $result = [['neq', ''], ['not null'], 'AND']; // 不为空
    if ($condition == 'contains' && in_array($key,['create_user_id','owner_user_id'])) $result = ['in', $data];              // 暂定为创建人 负责人 包含
    if ($condition == 'notContains' && in_array($key,['create_user_id','owner_user_id'])) $result = ['notin', $data];          // 暂定为创建人 负责人不包含
    return $result;
}

/**
 * 处理要查询的数据
 *
 * @param array $data 要查询的数据
 * @param string $condition 查询方式
 * @return mixed
 * @since 2021-05-20
 * @author fanqi
 */
function advancedQueryDataTransform($data, $condition)
{
    if (in_array($condition, ['contains', 'notContains'])) {
        array_walk($data, function ($value, $key) use (&$data) {
            $data[$key] = '%' . $value . '%';
        });
    }

    if ($condition == 'startWith') {
        array_walk($data, function ($value, $key) use (&$data) {
            $data[$key] = $value . '%';
        });
    }

    if ($condition == 'endWith') {
        array_walk($data, function ($value, $key) use (&$data) {
            $data[$key] = '%' . $value;
        });
    }

    return $data;
}

/**
 * 处理要查询的数据 包含不包含条件 数据为数字专用
 *
 * @param array $data 要查询的数据
 * @param string $condition 查询方式
 * @return mixed
 * @author: alvin guogaobo
 * @version: 11.1.0
 * Date: 2021/9/2 14:44
 */
function advancedQueryDataUserform($data, $condition){
    if (in_array($condition, ['contains', 'notContains'])) {
        array_walk($data, function ($value, $key) use (&$data) {
            $data[$key] = $value;
        });
    }
    return $data;
}
/**
 * 等于（时间段）数据处理
 *
 * @param $data
 * @return array
 * @since 2021-06-11
 * @author fanqi
 */
function advancedQueryHandleDate($data)
{
    // 本年度
    if ($data['value'][0] == 'year') {
        $arrTime = DataTime::year();
        $data['value'][0] = date('Y-m-d 00:00:00', $arrTime[0]);
        $data['value'][1] = date('Y-m-d 23:59:59', $arrTime[1]);
    }

    // 上一年度
    if ($data['value'][0] == 'lastYear') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '-1 year'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '-1 year'));
    }

    // 下一年度
    if ($data['value'][0] == 'nextYear') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '+1 year'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '+1 year'));
    }

    // 上半年
    if ($data['value'][0] == 'firstHalfYear') {
        $data['value'][0] = date('Y-01-01 00:00:00');
        $data['value'][1] = date('Y-06-30 23:59:59');
    }

    // 下半年
    if ($data['value'][0] == 'nextHalfYear') {
        $data['value'][0] = date('Y-07-01 00:00:00');
        $data['value'][1] = date('Y-12-31 23:59:59');
    }

    // 本季度
    if ($data['value'][0] == 'quarter') {
        $season = ceil((date('n')) / 3);
        $data['value'][0] = date('Y-m-d H:i:s', mktime(0, 0, 0, $season * 3 - 3 + 1, 1, date('Y')));
        $data['value'][1] = date('Y-m-d H:i:s', mktime(23, 59, 59, $season * 3, date('t', mktime(0, 0, 0, $season * 3, 1, date("Y"))), date('Y')));
    }

    // 上一季度
    if ($data['value'][0] == 'lastQuarter') {
        $season = ceil((date('n')) / 3) - 1;
        $data['value'][0] = date('Y-m-d H:i:s', mktime(0, 0, 0, $season * 3 - 3 + 1, 1, date('Y')));
        $data['value'][1] = date('Y-m-d H:i:s', mktime(23, 59, 59, $season * 3, date('t', mktime(0, 0, 0, $season * 3, 1, date("Y"))), date('Y')));
    }

    // 下一季度
    if ($data['value'][0] == 'nextQuarter') {
        $season = ceil((date('n')) / 3);
        $data['value'][0] = date('Y-m-d H:i:s', mktime(0, 0, 0, $season * 3 + 1, 1, date('Y')));
        $data['value'][1] = date('Y-m-d H:i:s', mktime(23, 59, 59, $season * 3 + 3, date('t', mktime(0, 0, 0, $season * 3, 1, date("Y"))), date('Y')));
    }

    // 本月
    if ($data['value'][0] == 'month') {
        $data['value'][0] = date('Y-m-01 00:00:00');
        $data['value'][1] = date('Y-m-31 23:59:59');
    }

    // 上月
    if ($data['value'][0] == 'lastMonth') {
        $data['value'][0] = date('Y-m-01 00:00:00', strtotime(date('Y-m-d') . '-1 month'));
        $data['value'][1] = date('Y-m-31 23:59:59', strtotime(date('Y-m-d') . '-1 month'));
    }

    // 下月
    if ($data['value'][0] == 'nextMonth') {
        $data['value'][0] = date('Y-m-01 00:00:00', strtotime(date('Y-m-d') . '+1 month'));
        $data['value'][1] = date('Y-m-31 23:59:59', strtotime(date('Y-m-d') . '+1 month'));
    }

    // 本周
    if ($data['value'][0] == 'week') {
        $data['value'][0] = date('Y-m-d 00:00:00', mktime(0, 0, 0, date('m'), date('d') - date('w') + 1, date('Y')));
        $data['value'][1] = date('Y-m-d 23:59:59', mktime(23, 59, 59, date('m'), date('d') - date('w') + 7, date('Y')));
    }

    // 上周
    if ($data['value'][0] == 'lastWeek') {
        $date = date("Y-m-d");
        $w = date("w", strtotime($date));
        $d = $w ? $w - 1 : 6;
        $start = date("Y-m-d", strtotime($date . " - " . $d . " days"));
        $data['value'][0] = date('Y-m-d', strtotime($start . " - 7 days"));
        $data['value'][1] = date('Y-m-d', strtotime($start . " - 1 days"));
    }

    // 下周
    if ($data['value'][0] == 'nextWeek') {
        $date = date("Y-m-d");
        $w = date("w", strtotime($date));
        $d = $w ? $w - 1 : 6;
        $start = date("Y-m-d", strtotime($date . " - " . $d . " days"));
        $data['value'][0] = date('Y-m-d', strtotime($start . " + 7 days"));
        $data['value'][1] = date('Y-m-d', strtotime($start . " + 13 days"));
    }

    // 今天
    if ($data['value'][0] == 'today') {
        $data['value'][0] = date('Y-m-d 00:00:00');
        $data['value'][1] = date('Y-m-d 23:59:59');
    }

    // 昨天
    if ($data['value'][0] == 'yesterday') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '-1 day'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '-1 day'));
    }

    // 明天
    if ($data['value'][0] == 'tomorrow') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '+1 day'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '+1 day'));
    }

    // 过去7天
    if ($data['value'][0] == 'previous7day') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '-7 day'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '-1 day'));
    }

    // 过去30天
    if ($data['value'][0] == 'previous30day') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '-30 day'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '-1 day'));
    }

    // 未来7天
    if ($data['value'][0] == 'future7day') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '+1 day'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '+7 day'));
    }

    // 未来30天
    if ($data['value'][0] == 'future30day') {
        $data['value'][0] = date('Y-m-d 00:00:00', strtotime(date('Y-m-d') . '+1 day'));
        $data['value'][1] = date('Y-m-d 23:59:59', strtotime(date('Y-m-d') . '+30 day'));
    }

    return $data;
}

/**
 * 根据搜索生成where条件
 *
 * @param string $search 搜索内容
 * @param $condition 搜索条件
 * @param $k 搜索字段
 * @return array|Closure|string[]
 */
function field($search, $condition = '', $k = '')
{
    switch (trim($condition)) {
        case "is" :
            $where = ['in', $search];
            break;
        case "isNot" :
            $where = ['notin', $search];
            break;
        case "contains" :
            $containsWhere = [];
            foreach ((array)$search as $key1 => $value1) $containsWhere[] = '%' . $value1 . '%';
            $where = ['like', $containsWhere, 'OR'];
            break;
        case "notContains" :
            $containsWhere = [];
            foreach ((array)$search as $key1 => $value1) $containsWhere[] = '%' . $value1 . '%';
            $where = ['notlike', $containsWhere, 'AND'];
            break;
        case "startWith" :
            $startWithWhere = [];
            foreach ((array)$search as $key1 => $value1) $startWithWhere[] = $value1 . '%';
            $where = ['like', $startWithWhere, 'OR'];
            break;
        case "endWith" :
            $endWithWhere = [];
            foreach ((array)$search as $key1 => $value1) $endWithWhere[] = '%' . $value1;
            $where = ['like', $endWithWhere, 'OR'];
            break;
        case "isNull" :
            $where = ['eq', ''];
            break;
        case "isNotNull" :
            $where = ['neq', ''];
            break;
        case "eq" :
            $where = function ($query) use ($search, $k) {
                foreach ((array)$search as $key1 => $value1) {
                    $query->whereOr($k, $value1);
                }
            };
            break;
        case "neq" :
            $where = function ($query) use ($search, $k) {
                foreach ((array)$search as $key1 => $value1) {
                    $query->whereOr($k, '<>', $value1);
                }
            };
            break;
        case "gt" :
            $where = function ($query) use ($search, $k) {
                foreach ((array)$search as $key1 => $value1) {
                    $query->whereOr($k, '>', $value1);
                }
            };
            break;
        case "egt" :
            $where = function ($query) use ($search, $k) {
                foreach ((array)$search as $key1 => $value1) {
                    $query->whereOr($k, '>=', $value1);
                }
            };
            break;
        case "lt" :
            $where = function ($query) use ($search, $k) {
                foreach ((array)$search as $key1 => $value1) {
                    $query->whereOr($k, '<', $value1);
                }
            };
            break;
        case "elt" :
            $where = function ($query) use ($search, $k) {
                foreach ((array)$search as $key1 => $value1) {
                    $query->whereOr($k, '<=', $value1);
                }
            };
            break;
        case "in" :
            $where = ['in', $search];
            break;
        default :
            $where = ['eq', $search];
            break;
    }
    return $where;
}

/**
 * 将单个搜索转换为高级搜索格式
 * @param string $value 搜索内容
 * @param  $condition 搜索条件
 * @return array
 * @author Michael_xu
 */
function field_arr($value, $condition = '')
{
    if (is_array($value)) {

    } else {
        $condition = $condition ?: 'eq';
        $where_arr = ['value' => $value, 'condition' => $condition];
    }

    return $where_arr;
}

/**
 * 记录操作日志
 * @param  $id array  操作对象id数组
 * @return
 * @author Michael_xu
 */
function actionLog($id, $join_user_ids = '', $structure_ids = '', $content = '')
{
    if (!is_array($id)) {
        $idArr[] = $id;
    } else {
        $idArr = $id;
    }
    $header = Request::instance()->header();
    $authKey = $header['authkey'];
    $cache = cache('Auth_' . $authKey);
    if (!$cache) {
        return false;
    }
    $userInfo = $cache['userInfo'];
    $category = $userInfo['id'] == 1 ? '管理员' : '员工';

    $request = request();
    $m = strtolower($request->module());
    $c = strtolower($request->controller());
    $a = strtolower($request->action());

    $res_action = true;
    foreach ($idArr as $v) {
        $data = [];
        $data['user_id'] = $userInfo['id'];
        $data['module_name'] = $module_name = $m;
        $data['controller_name'] = $controller_name = $c;
        $data['action_name'] = $action_name = $a;
        $data['action_id'] = $v;
        $data['create_time'] = time();
        $data['client_ip'] = request()->ip();
        $data['content'] = $content ?: lang('ACTIONLOG', [$category, $userInfo['realname'], date('Y-m-d H:i:s'), lang($action_name), $v, lang($controller_name)]);
        $data['join_user_ids'] = $join_user_ids ?: ''; //抄送人
        $data['structure_ids'] = $structure_ids ?: ''; //抄送部门
        if ($action_name == 'delete' || $action_name == 'commentdel') {
            $data['action_delete'] = 1;
        }
        if (!db('admin_action_log')->insert($data)) {
            $res_action = false;
        }

        # 数据操作日志
        db('admin_operation_log')->insert([
            'user_id' => $userInfo['id'],
            'client_ip' => request()->ip(),
            'module' => $m . '_' . $c,
            'action_id' => $v,
            'content' => $content,
            'create_time' => time()
        ]);
    }

    if ($res_action) {
        return true;
    } else {
        return false;
    }
}

/**
 * 判断操作权限
 * @param
 * @return
 * @author Michael_xu
 */
function checkPerByAction($m, $c, $a)
{
    /*获取头部信息*/
    $header = Request::instance()->header();
    $authKey = $header['authkey'];
    $cache = cache('Auth_' . $authKey);
    if (!$cache) {
        return false;
    }
    $userInfo = $cache['userInfo'];
    $adminTypes = adminGroupTypes($userInfo['id']);
    if (in_array(1, $adminTypes)) {
        return true;
    }
    if (empty($m) && empty($c) && empty($a)) {
        $request = Request::instance();
        $m = strtolower($request->module());
        $c = strtolower($request->controller());
        $a = strtolower($request->action());
    }
    $authAdapter = new AuthAdapter($authKey);
    $ruleName = $m . '-' . $c . '-' . $a;
    if (!$authAdapter->checkIntime($ruleName, $userInfo['id'])) {
        return false;
    }
    return true;
}

/**
 * 给树状菜单添加level并去掉没有子菜单的菜单项
 * @param array $data [description]
 * @param integer $root [description]
 * @param string $child [description]
 * @param string $level [description]
 */
function memuLevelClear($data, $root = 1, $child = 'children', $level = 'level')
{
    if (is_array($data)) {
        foreach ($data as $key => $val) {
            // $data[$key]['selected'] = false;
            $data[$key]['level'] = $root;
            if (!empty($val[$child]) && is_array($val[$child])) {
                $data[$key][$child] = memuLevelClear($val[$child], $root + 1);
            } else if ($root < 3 && $data[$key]['menu_type'] == 1) {
                unset($data[$key]);
            }
            if (empty($data[$key][$child]) && ($data[$key]['level'] == 1) && ($data[$key]['menu_type'] == 1)) {
                unset($data[$key]);
            }
        }
        return array_values($data);
    }
    return array();
}

/**
 * [rulesDeal 给树状规则表处理成 module-controller-action ]
 * @AuthorHTL
 * @DateTime
 * @param     [array]                   $data [树状规则数组]
 * @return    [array]                         [返回数组]
 */
function rulesDeal($data)
{
    if (is_array($data)) {
        $ret = [];
        foreach ($data as $k1 => $v1) {
            $str1 = $v1['name'];
            if (is_array($v1['children'])) {
                foreach ($v1['children'] as $k2 => $v2) {
                    $str2 = $str1 . '-' . $v2['name'];
                    if (is_array($v2['children'])) {
                        foreach ($v2['children'] as $k3 => $v3) {
                            $str3 = $str2 . '-' . $v3['name'];
                            $ret[] = $str3;
                        }
                    } else {
                        $ret[] = $str2;
                    }
                }
            } else {
                $ret[] = $str1;
            }
        }
        return $ret;
    }
    return [];
}

/**
 * 获取下属userId
 * @param $self == true  包含自己
 * @param $type == 0  下属userid
 * @param $type == 1  全部userid
 * @param $user_id 需要查询的user_id
 * @author Michael_xu
 */
function getSubUserId($self = true, $type = 0, $user_id = '')
{
    $request = Request::instance();
    $header = $request->header();
    $authKey = $header['authkey'];
    $cache = cache('Auth_' . $authKey);
    if (!$user_id) {
        if (!$cache) {
            return false;
        }
        $userInfo = $cache['userInfo'];
        $user_id = $userInfo['id'];
        $adminTypes = adminGroupTypes($user_id);

        if (in_array(1, $adminTypes)) {
            $type = 1;
        }
    }
    $belowIds = [];
    if (empty($type)) {

        if ($user_id) {
            $belowIds = getSubUser($user_id);
        }
    } else {
        $belowIds = getSubUser(0);
    }
    if ($self == true) {
        $belowIds[] = $user_id;
    } else {
        $belowIds = $belowIds ? array_diff($belowIds, array($user_id)) : [];
    }
    return array_unique($belowIds);
}

/**
 * 获取下属userId
 * @author Michael_xu
 */
function getSubUser($userId, $queried = [], $allUserList = [])
{
    if (empty($allUserList)) {
        $allUserList = db('admin_user')->field('id,parent_id')->select();
    }
    foreach ($allUserList as $k => $v) {
        if ($v['parent_id'] == $userId) {
            $sub_user[] = $v['id'];
        }
    }
    if ($sub_user) {
        foreach ($sub_user as $v) {
            if (in_array($v, $queried)) {
                continue;
            }
            $queried[] = $v;
            $son_user = [];
            $son_user = getSubUser($v, $queried, $allUserList);
            if (!empty($son_user)) {
                $sub_user = array_merge($sub_user, $son_user);
            }
        }
    }
    return $sub_user;
}

/**
 * 阿里大于短信发送
 * @param unknown $appkey
 * @param unknown $secret
 * @param unknown $signName 短信签名
 * @param unknown $smsParam
 * @param unknown $templateCode 短信模板
 * @param unknown $send_mobile 接收手机号
 * @param unknown $code 短信验证码
 * @param unknown $template_code 模板参数
 */
function aliSmsSend($send_mobile, $code, $signName, $templateCode)
{
    $appkey = '';
    $secret = '';
    import('alimsg.api.Sms', EXTEND_PATH);
    header('Content-Type: text/plain; charset=utf-8');
    $sms = new Sms($appkey, $secret);
    $template_code = array("code" => $code);
    $response = $sms->sendSms($signName, $templateCode, $send_mobile, $template_code);
    $data = object_to_array($response);
    if ($data['Message'] == 'OK' && $data['Code'] == "OK") {
        return true;
    } else {
        return false;
    }
}

/**
 * 发送邮件
 * @param unknown $toemail
 * @param unknown $title
 * @param unknown $content
 * @return boolean
 */
function emailSend($email_host, $email_id, $email_pass, $email_addr, $toemail, $title, $content)
{
    $result = false;
    try {
        $mail = new Email();
        $mail->setServer($email_host, $email_id, $email_pass);
        $mail->setFrom($email_addr);
        $mail->setReceiver($toemail);
        $mail->setMailInfo($title, $content);
        $result = $mail->sendMail();
    } catch (\Exception $e) {
        $result = false;
    }
    return $result;
}

/**
 * 发送站内信
 * @param  $user_id 接收人user_id
 * @param  $action_id 操作id
 * @param  $sysMessage 1为系统消息
 * @param  $content 消息内容
 * @return
 * @author Michael_xu
 */
function sendMessage($user_id, $content, $action_id, $sysMessage = 0)
{
    $content = trim($content);
    if (!$user_id) return false;
    if (!$content) return false;
    if (!is_array($user_id)) {
        $user_ids[] = $user_id;
    } else {
        $user_ids = $user_id;
    }
    $user_ids = array_unique(array_filter($user_ids));
    $request = request();
    $m = strtolower($request->module());
    $c = strtolower($request->controller());
    $a = strtolower($request->action());

    $userInfo = [];
    if ($sysMessage == 0) {
        $header = $request->header();
        $authkey = $header['authkey'];
        $cache = cache('Auth_' . $authkey);
        if (!$cache) {
            return false;
        }
        $userInfo = $cache['userInfo'];
    }
    foreach ($user_ids as $v) {
        $data = [];
        $data['content'] = $content;
        $data['from_user_id'] = $userInfo['id'] ?: 0;
        $data['to_user_id'] = $v;
        $data['read_time'] = 0;
        $data['send_time'] = time();
        $data['module_name'] = $m;
        $data['controller_name'] = $c;
        $data['action_name'] = $a;
        $data['action_id'] = $action_id;
        db('admin_message')->insert($data);
    }
    return true;
}

/**
 * 格式化字节大小
 * @param number $size 字节数
 * @param string $delimiter 数字和单位分隔符
 * @return string               格式化后的带单位的大小
 * @author
 */
function format_bytes($size, $delimiter = '')
{
    $units = array('B', 'KB', 'MB', 'GB', 'TB', 'PB');
    for ($i = 0; $size >= 1024 && $i < 5; $i++) $size /= 1024;
    return round($size, 2) . $delimiter . $units[$i];
}

/**
 * 数据修改日志
 * @param $types 类型
 * @param $action_id 操作ID
 * @param $newData 新数据
 * @param $newData 新数据
 * @return
 * @author Michael_xu
 */
function updateActionLog($user_id, $types, $action_id, $oldData = [], $newData = [], $content = '')
{
    # 转格式
    if (!empty($oldData['next_time']) && $oldData['next_time'] != strtotime($oldData['next_time'])) {
        $oldData['next_time'] = strtotime($oldData['next_time']);
    }

    if (is_array($oldData) && is_array($newData) && $user_id) {
        $differentData = array_diff_assoc($newData, $oldData);
        $fieldModel = new FieldModel();
        $userModel = new UserModel();
        $structureModel = new \app\admin\model\Structure();
        $field_arr = $fieldModel->getField(['types' => $types, 'unFormType' => ['file', 'form']]); //获取字段属性
        $newFieldArr = array();
        foreach ($field_arr as $k => $v) {
            $newFieldArr[$v['field']] = $v;
        }
        $unField = ['update_time', 'create_time']; //定义过滤字段
        $message = [];
        $un_form_type = ['file', 'form'];
        foreach ($differentData as $k => $v) {
            if ($newFieldArr[$k] && !in_array($newFieldArr[$k]['form_type'], $un_form_type)) {
                $field_name = '';
                $field_name = $newFieldArr[$k]['name'];
                $new_value = $v ?: '空';
                $old_value = $oldData[$k] ?: '空';
                if ($newFieldArr[$k]['form_type'] == 'datetime') {
                    $new_value = $v ? date('Y-m-d', $v) : '空';
                    if (date('Y-m-d H:i:s', strtotime($oldData[$k])) == $oldData[$k]) {
                        $old_value = !empty($oldData[$k]) ? $oldData[$k] : '空';
                    } else {
                        $old_value = !empty($oldData[$k]) ? date('Y-m-d', $oldData[$k]) : '空';
                    }
                    if (empty($v) && empty($oldData[$k])) continue;
                } elseif ($newFieldArr[$k]['form_type'] == 'user') {
                    $new_value = $v ? implode(',', $userModel->getUserNameByArr(stringToArray($v))) : '';
                    $old_value = $v ? implode(',', $userModel->getUserNameByArr(stringToArray($oldData[$k]))) : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'structure') {
                    $new_value = $v ? implode(',', $structureModel->getStructureNameByArr(stringToArray($v))) : '';
                    $old_value = $v ? implode(',', $structureModel->getStructureNameByArr(stringToArray($oldData[$k]))) : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'business_status') {
                    $new_value = $v ? db('crm_business_status')->where(['status_id' => $v])->value('name') : '';
                    $old_value = $v ? db('crm_business_status')->where(['status_id' => $oldData[$k]])->value('name') : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'business_type') {
                    $new_value = $v ? db('crm_business_type')->where(['type_id' => $v])->value('name') : '';
                    $old_value = $v ? db('crm_business_type')->where(['type_id' => $oldData[$k]])->value('name') : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'customer') {
                    $new_value = $v ? db('crm_customer')->where(['customer_id' => $v])->value('name') : '';
                    $old_value = $v ? db('crm_customer')->where(['customer_id' => $oldData[$k]])->value('name') : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'category') {
                    $new_value = $v ? db('crm_product_category')->where(['category_id' => $v])->value('name') : '';
                    $old_value = $v ? db('crm_product_category')->where(['category_id' => $oldData[$k]])->value('name') : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'business') {
                    $new_value = $v ? db('crm_business')->where(['business_id' => $v])->value('name') : '';
                    $old_value = $v ? db('crm_business')->where(['business_id' => $oldData[$k]])->value('name') : '';
                } elseif ($newFieldArr[$k]['field'] == 'check_status') {
                    $statusArr = ['0' => '待审核', '1' => '审核中', '2' => '审核通过', '3' => '已拒绝', '4' => '已撤回', '5' => '未提交'];
                    $new_value = $statusArr[$v];
                    $old_value = $statusArr[$oldData[$k]];
                } elseif ($newFieldArr[$k]['form_type'] == 'visit') {
                    $new_value = $v ? db('crm_visit')->where(['visit_id' => $v])->value('number') : '';
                    $old_value = $v ? db('crm_visit')->where(['visit_id' => $oldData[$k]])->value('number') : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'single_user') {
                    $new_value = $v ? db('admin_user')->where(['id' => $v])->value('realname') : '';
                    $old_value = $v ? db('admin_user')->where(['id' => $oldData['owner_user_id']])->value('realname') : '';
                } elseif ($newFieldArr[$k]['form_type'] == 'floatnumber') {
                    $new_value = $v ? number_format($v, 2) : '';
                }
                if ($old_value != $new_value) {
                    $message[] = '将 ' . "'" . $field_name . "'" . ' 由 ' . $old_value . ' 修改为 ' . $new_value;
                }
            }
        }
        if ($message) {
            $data = [];
            $data['user_id'] = $user_id;
            $data['create_time'] = time();
            $data['types'] = $types;
            $data['action_id'] = $action_id;
            $data['content'] = implode('.|.', $message);
            db('admin_action_record')->insert($data);
        }
    } elseif ($content) {
        $data = [];
        $data['user_id'] = $user_id;
        $data['create_time'] = time();
        $data['types'] = $types;
        $data['action_id'] = $action_id;
        $data['content'] = $content;
        db('admin_action_record')->insert($data);
    }
}

/**
 * 截取字符串
 * @param $start 开始截取位置
 * @param $length 截取长度
 * @return
 * @author Michael_xu
 */
function msubstr($str, $start = 0, $length, $charset = "utf-8", $suffix = true)
{
    if (function_exists("mb_substr")) {
        $slice = mb_substr($str, $start, $length, $charset);
    } elseif (function_exists('iconv_substr')) {
        $slice = iconv_substr($str, $start, $length, $charset);
        if (false === $slice) {
            $slice = '';
        }
    } else {
        $re['utf-8'] = "/[\x01-\x7f]|[\xc2-\xdf][\x80-\xbf]|[\xe0-\xef][\x80-\xbf]{2}|[\xf0-\xff][\x80-\xbf]{3}/";
        $re['gb2312'] = "/[\x01-\x7f]|[\xb0-\xf7][\xa0-\xfe]/";
        $re['gbk'] = "/[\x01-\x7f]|[\x81-\xfe][\x40-\xfe]/";
        $re['big5'] = "/[\x01-\x7f]|[\x81-\xfe]([\x40-\x7e]|\xa1-\xfe])/";
        preg_match_all($re[$charset], $str, $match);
        $slice = join("", array_slice($match[0], $start, $length));
    }
    if (utf8_strlen($str) < $length) $suffix = false;
    return $suffix ? $slice . '...' : $slice;
}

function utf8_strlen($string = null)
{
    preg_match_all("/./us", $string, $match);
    return count($match[0]);
}

/**
 * 合法性验证
 * @param client_sign 签名参数值，使用相同规则对提交参数进行加密验证
 * @return
 * @author Michael_xu
 */
function checkVerify($saftCode = '5kcrm@')
{
    $parmList = Request::instance()->post();
    $header = $request->header();
    $parmList['sessionId'] = $header['sessionId'];
    $authkey = $header['authKey'];
    $clientSign = $parmList['client_sign'];

    if ($clientSign) {
        unset($parmList['client_sign']);
        if (count($parmList) > 0) {
            // 对要签名参数按照签名格式组合
            foreach ($parmList as $key => $value) {
                if (isset($_POST[$key])) {
                    $parame[$key] = $key . '=' . trim($_POST[$key]);
                } else {
                    return false;
                }
            }
            ksort($parame); //参数排序
            $returnValue = implode("&", $parame); //拼接字符串
            if ($returnValue) {
                //base64加密
                $signCalc = base64_encode(hash_hmac("sha1", $returnValue, $saftCode . $authkey, $raw_output = false));
                // 检查参数签名是否一致
                if (trim($clientSign) != trim($signCalc)) {
                    return false;
                } else {
                    return true;
                }
            } else {
                return false;
            }
        } else {
            return false;
        }
    } else {
        //签名认证错误
        return false;
    }
}

/**
 * 数组转换字符串（以逗号隔开）
 * @param
 * @return
 * @author Michael_xu
 */
function arrayToString($array)
{
    if (!is_array($array)) {
        $data_arr[] = $array;
    } else {
        $data_arr = $array;
    }
    $data_arr = array_filter($data_arr); //数组去空
    $data_arr = array_unique($data_arr); //数组去重
    $data_arr = array_merge($data_arr);
    $string = $data_arr ? ',' . implode(',', $data_arr) . ',' : '';
    return $string ?: '';
}

/**
 * 字符串转换数组（以逗号隔开）
 * @param
 * @return
 * @author Michael_xu
 */
function stringToArray($string)
{
    if (is_array($string)) {
        $data_arr = array_unique(array_filter($string));
    } else {
        $data_arr = $string ? array_unique(array_filter(explode(',', $string))) : [];
    }
    $data_arr = $data_arr ? array_merge($data_arr) : [];
    return $data_arr ?: [];
}

/**
 * 根据时间戳获取星期几
 * @param $time 要转换的时间戳
 */
function getTimeWeek($time, $i = 0)
{
    $weekarray = array("日", "一", "二", "三", "四", "五", "六");
    $oneD = 24 * 60 * 60;
    return "星期" . $weekarray[date("w", $time + $oneD * $i)];
}

/**
 * 二维数组排序(选择)
 * @param $select 要进行排序的select结果集
 * @param $field  排序的字段
 * @param $order 排序方式1降序2升序
 */
function sort_select($select = array(), $field, $order = 1)
{
    $count = count($select);
    if ($order == 1) {
        for ($i = 0; $i < $count; $i++) {
            $k = $i;
            for ($j = $i; $j < $count; $j++) {
                if ($select[$k][$field] < $select[$j][$field]) {
                    $k = $j;
                }
            }
            $temp = $select[$i];
            $select[$i] = $select[$k];
            $select[$k] = $temp;
        }
        return $select;
    } else {
        for ($i = 0; $i < $count; $i++) {
            $k = $i;
            for ($j = $i; $j < $count; $j++) {
                if ($select[$k][$field] > $select[$j][$field]) {
                    $k = $j;
                }
            }
            $temp = $select[$i];
            $select[$i] = $select[$k];
            $select[$k] = $temp;
        }
        return $select;
    }
}

/**
 * 将秒数转换为时间 (年、天、小时、分、秒）
 * @param
 */
function getTimeBySec($time)
{
    if (is_numeric($time)) {
        $value = array(
            "years" => 0, "days" => 0, "hours" => 0,
            "minutes" => 0, "seconds" => 0,
        );
        if ($time >= 31556926) {
            $value["years"] = floor($time / 31556926);
            $time = ($time % 31556926);
            $t .= $value["years"] . "年";
        }
        if ($time >= 86400) {
            $value["days"] = floor($time / 86400);
            $time = ($time % 86400);
            $t .= $value["days"] . "天";
        }
        if ($time >= 3600) {
            $value["hours"] = floor($time / 3600);
            $time = ($time % 3600);
            $t .= $value["hours"] . "小时";
        }
        if ($time >= 60) {
            $value["minutes"] = floor($time / 60);
            $time = ($time % 60);
            $t .= $value["minutes"] . "分钟";
        }
        if ($time < 60) {
            $value["seconds"] = floor($time);
            $t .= $value["seconds"] . "秒";
        }
        return $t;
    } else {
        return (bool)FALSE;
    }
}

/*
 *根据年月计算有几天
 */
function getmonthByYM($param)
{
    $month = $param['month'] ? $param['month'] : date('m', time());
    $year = $param['year'] ? $param['year'] : date('Y', time());
    if (in_array($month, array('1', '3', '5', '7', '8', '01', '03', '05', '07', '08', '10', '12'))) {
        $days = '31';
    } elseif ($month == 2) {
        if ($year % 400 == 0 || ($year % 4 == 0 && $year % 100 !== 0)) {
            //判断是否是闰年  
            $days = '29';
        } else {
            $days = '28';
        }
    } else {
        $days = '30';
    }
    return $days;
}

/**
 * 根据时间戳计算当月天数
 * @param
 */
function getmonthdays($time)
{
    $month = date('m', $time);
    $year = date('Y', $time);
    if (in_array($month, array('1', '3', '5', '7', '8', '01', '03', '05', '07', '08', '10', '12'))) {
        $days = '31';
    } elseif ($month == 2) {
        if ($year % 400 == 0 || ($year % 4 == 0 && $year % 100 !== 0)) {
            //判断是否是闰年  
            $days = '29';
        } else {
            $days = '28';
        }
    } else {
        $days = '30';
    }
    return $days;
}

/**
 * 生成从开始时间到结束时间的日期数组
 * @param type，默认时间戳格式
 * @param type = 1 时，date格式
 * @param type = 2 时，获取每日开始、结束时间
 */
function dateList($start, $end, $type = 0)
{
    if (!is_numeric($start) || !is_numeric($end) || ($end <= $start)) return '';
    $i = 0;
    //从开始日期到结束日期的每日时间戳数组
    $d = array();
    if ($type == 1) {
        while ($start <= $end) {
            $d[$i] = date('Y-m-d', $start);
            $start = $start + 86400;
            $i++;
        }
    } else {
        while ($start <= $end) {
            $d[$i] = $start;
            $start = $start + 86400;
            $i++;
        }
    }
    if ($type == 2) {
        $list = array();
        foreach ($d as $k => $v) {
            $list[$k] = getDateRange($v);
        }
        return $list;
    } else {
        return $d;
    }
}

/**
 * 获取指定日期开始时间与结束时间
 */
function getDateRange($timestamp)
{
    $ret = array();
    $ret['sdate'] = strtotime(date('Y-m-d', $timestamp));
    $ret['edate'] = strtotime(date('Y-m-d', $timestamp)) + 86400;
    return $ret;
}

/**
 * 生成从开始月份到结束月份的月份数组
 * @param int $start 开始时间戳
 * @param int $end 结束时间戳
 */
function monthList($start, $end)
{
    if (!is_numeric($start) || !is_numeric($end) || ($end <= $start)) return '';
    $start = date('Y-m', $start);
    $end = date('Y-m', $end);
    //转为时间戳
    $start = strtotime($start . '-01');
    $end = strtotime($end . '-01');
    $i = 0;
    $d = array();
    while ($start <= $end) {
        //这里累加每个月的的总秒数 计算公式：上一月1号的时间戳秒数减去当前月的时间戳秒数
        $d[$i] = $start;
        $start += strtotime('+1 month', $start) - $start;
        $i++;
    }
    return $d;
}

/**
 * 人民币转大写
 * @param
 */
function cny($ns)
{
    static $cnums = array("零", "壹", "贰", "叁", "肆", "伍", "陆", "柒", "捌", "玖"),
    $cnyunits = array("圆", "角", "分"),
    $grees = array("拾", "佰", "仟", "万", "拾", "佰", "仟", "亿");
    list($ns1, $ns2) = explode(".", $ns, 2);
    $ns2 = array_filter(array($ns2[1], $ns2[0]));
    $ret = array_merge($ns2, array(implode("", _cny_map_unit(str_split($ns1), $grees)), ""));
    $ret = implode("", array_reverse(_cny_map_unit($ret, $cnyunits)));
    return str_replace(array_keys($cnums), $cnums, $ret);
}

function _cny_map_unit($list, $units)
{
    $ul = count($units);
    $xs = array();
    foreach (array_reverse($list) as $x) {
        $l = count($xs);
        if ($x != "0" || !($l % 4)) {
            $n = ($x == '0' ? '' : $x) . ($units[($l - 1) % $ul]);
        } else {
            $n = is_numeric($xs[0][0]) ? $x : '';
        }
        array_unshift($xs, $n);
    }
    return $xs;
}

/**
 * 根据类型获取上一类型时间戳数组
 */
function getLstTimeByType($type = 'today')
{
    switch ($type) {
        case 'yesterday' :
            $timeArr = Time::yesterday();
            break;
        case 'week' :
            $timeArr = Time::week();
            break;
        case 'lastWeek' :
            $timeArr = Time::lastWeek();
            break;
        case 'month' :
            $timeArr = Time::month();
            break;
        case 'lastMonth' :
            $timeArr = Time::lastMonth();
            break;
        case 'quarter' :
            //本季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $daterange_start_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-06-30 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-09-30 23:59:59"));
            } else {
                $daterange_start_time = strtotime(date('Y-10-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-12-31 23:59:59"));
            }
            $timeArr = array($daterange_start_time, $daterange_end_time);
            break;
        case 'lastQuarter' :
            //上季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $year = date('Y') - 1;
                $daterange_start_time = strtotime(date($year . '-10-01 00:00:00'));
                $daterange_end_time = strtotime(date($year . '-12-31 23:59:59'));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-06-30 23:59:59"));
            } else {
                $daterange_start_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-09-30 23:59:59"));
            }
            $timeArr = array($daterange_start_time, $daterange_end_time);
            break;
        case 'year' :
            $timeArr = Time::year();
            break;
        case 'lastYear' :
            $timeArr = Time::lastYear();
            break;
        default :
            $timeArr = Time::today();
            break;
    }
    return $timeArr;
}


/**
 * 根据类型获取开始结束时间戳数组
 * @param
 */
function getTimeByType($type = 'today', $is_last = false)
{
    $lastArr = [];
    switch ($type) {
        case 'yesterday' :
            $timeArr = Time::yesterday();
            break;
        case 'week' :
            $timeArr = Time::week();
            break;
        case 'lastWeek' :
            $timeArr = Time::lastWeek();
            break;
        case 'month' :
            $timeArr = Time::month();
            break;
        case 'lastMonth' :
            $timeArr = Time::lastMonth();
            break;
        case 'quarter' :
            //本季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $daterange_start_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-06-30 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-09-30 23:59:59"));
            } else {
                $daterange_start_time = strtotime(date('Y-10-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-12-31 23:59:59"));
            }
            $timeArr = array($daterange_start_time, $daterange_end_time);
            break;
        case 'lastQuarter' :
            //上季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $year = date('Y') - 1;
                $daterange_start_time = strtotime(date($year . '-10-01 00:00:00'));
                $daterange_end_time = strtotime(date($year . '-12-31 23:59:59'));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-06-30 23:59:59"));
            } else {
                $daterange_start_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-09-30 23:59:59"));
            }
            $timeArr = array($daterange_start_time, $daterange_end_time);
            break;
        case 'year' :
            $timeArr = Time::year();
            break;
        case 'lastYear' :
            $timeArr = Time::lastYear();
            break;
        default :
            $timeArr = Time::today();
            break;
    }
    if ($is_last) {
        return $lastArr;
    } else {
        return $timeArr;
    }
}

/**
 * 服务器附件完整路径处理
 * @param
 */
function getFullPath($path)
{
    if ($path) {
        $protocol = strpos(strtolower($_SERVER['REQUEST_SCHEME']), 'https') === false ? 'http' : 'https';
        return $protocol . '://' . $_SERVER['HTTP_HOST'] . substr($_SERVER["SCRIPT_NAME"], 0, -10) . substr(str_replace(DS, '/', $path), 1);
    } else {
        return '';
    }
}

/*取得文件后缀*/
function getExtension($filename)
{
    $mytext = substr($filename, strrpos($filename, '.') + 1);
    return $mytext;
}

/**
 * 生成编号
 * @param prefix 前缀
 * @return
 * @author Michael_xu
 */
function prefixNumber($prefix, $number_id = 0, $str = 5)
{
    return $prefixNumber = $prefix . str_pad($number_id, $str, 0, STR_PAD_LEFT); //填充字符串的左侧（将字符串填充为新的长度）
}

/**
 * curl 模拟GET请求
 * @author lee
 ***/
function curl_get($url)
{
    //初始化
    $ch = curl_init();
    //设置抓取的url
    curl_setopt($ch, CURLOPT_URL, $url);
    //设置获取的信息以文件流的形式返回，而不是直接输出。
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE); // https请求 不验证证书
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE); // https请求 不验证hosts 
    //执行命令
    $output = curl_exec($ch);
    curl_close($ch); //释放curl句柄
    return $output;
}

/**
 * 地址坐标转换
 * @param prefix 前缀
 * @return
 * @author Michael_xu
 */
function get_lng_lat($address)
{
    $map_ak = config('map_ak');
    $url = "http://api.map.baidu.com/geocoder/v2/?address=$address&output=json&ak=$map_ak&callback=showLocation";
    $ret_script = curl_get($url);
    preg_match_all("/\{.*?\}}/is", $ret_script, $matches);
    $ret_arr = json_decode($matches[0][0], true);
    if ($ret_arr['status'] == 0) { //成功
        $location['lng'] = $ret_arr['result']['location']['lng'];
        $location['lat'] = $ret_arr['result']['location']['lat'];
        return $location;
    } else {
        return false;
    }
}

/**
 * 导出数据为excel表格
 * @param $data    一个二维数组,结构如同从数据库查出来的数组
 * @param $title   excel的第一行标题,一个数组,如果为空则没有标题
 * @param $filename 下载的文件名
 * @param exportexcel($arr,array('id','账户','密码','昵称'),'文件名!');
 */
function exportexcel($data = array(), $title = array(), $filename = 'report')
{
    header("Content-type:application/octet-stream");
    header("Accept-Ranges:bytes");
    header("Content-type:application/vnd.ms-excel");
    header("Content-Disposition:attachment;filename=" . $filename . ".xls");
    header("Pragma: no-cache");
    header("Expires: 0");
    //导出xls 开始
    if (!empty($title)) {
        foreach ($title as $k => $v) {
            $title[$k] = iconv("UTF-8", "GB2312", $v);
        }
        $title = implode("\t", $title);
        echo "$title\n";
    }
    if (!empty($data)) {
        foreach ($data as $key => $val) {
            foreach ($val as $ck => $cv) {
                $data[$key][$ck] = iconv("UTF-8", "GB2312", $cv);
            }
            $data[$key] = implode("\t", $data[$key]);
        }
        echo implode("\n", $data);
    }
}

//根据数据库查询出来数组获取某个字段拼接字符串
function getFieldArray($array = array(), $field = '')
{
    if (is_array($array) && $field) {
        $ary = array();
        foreach ($array as $value) {
            $ary[] = $value[$field];
        }
        $str = implode(',', $ary);
        return $str;
    } else {
        return false;
    }
}

/**
 * 检查该字段若必填，加上"*"
 * @param is_null     是否为空 0否  1是
 * @param name 字段名称
 **/
function sign_required($is_null, $name)
{
    if ($is_null == 1) {
        return '*' . $name;
    } else {
        return $name;
    }
}

/**
 * [获取是否有管理员角色 adminGroupTypes]
 * @param user_id  当前人ID
 * @return
 */
function adminGroupTypes($user_id)
{
    $userModel = new UserModel();
    $groupsArr = $userModel->get($user_id)->groups;
    $groupids = [];
    if ($groupsArr) {
        foreach ($groupsArr as $key => $val) {
            $groupids[] = $val['id'];
        }
    }
    $types = db('admin_group')->where(['id' => ['in', $groupids]])->group('types')->column('types');
    if ($user_id == 1) {
        $types[] = 1;
    }
    return $types ?: [];
}

/**
 * [权限数组]
 * @param ruleIds 当前人权限id
 * @return
 */
function rulesListToArray($rulesList, $ruleIds = [])
{
    $newList = [];
    if (!is_array($rulesList)) {
        return array();
    } else {
        foreach ($rulesList as $k => $v) {
            if (!is_array($v['children'])) continue;
            foreach ($v['children'] as $k1 => $v1) {
                if (!is_array($v1['children'])) continue;
                foreach ($v1['children'] as $k2 => $v2) {
                    $check = false;
                    if (in_array($v2['id'], $ruleIds)) {
                        $check = true;
                    }
                    $newList[$v['name']][$v1['name']][$v2['name']] = $check;
                }
            }
        }
    }
    return $newList ?: [];
}

/**
 * [获取下一审批信息 nextCheckData]
 * @param user_id  审批申请人ID
 * @param flow_id  审批流ID
 * @param types 关联对象
 * @param types_id 联对象ID
 * @param order_id 审批排序ID
 * @return
 */
function nextCheckData($user_id, $flow_id, $types, $types_id, $order_id, $check_user_id)
{
    $new_order_id = $order_id;
    $max_order_id = db('admin_examine_step')->where(['flow_id' => $flow_id])->max('order_id'); //审批流最大排序ID
    $examineStepModel = new \app\admin\model\ExamineStep();

    $stepInfo = $examineStepModel->getStepByOrder($flow_id, $new_order_id); //审批步骤
    $next_user_ids = [];
    $is_end = 0; //审批结束
    //固定流程（status 1负责人主管，2指定用户（任意一人），3指定用户（多人会签），4上一级审批人主管）

    //当前步骤审批人user_id
    $step_user_ids = $examineStepModel->getUserByStep($stepInfo['step_id'], $user_id);
    if ($step_user_ids) {
        if (!$order_id) {
            //创建时使用
            $sub_user_ids = stringToArray($step_user_ids);
        } else {
            if ($stepInfo['status'] == 3) {
                //会签（并关系）
                //当前步骤已审批user_id
                $check_user_ids = $examineStepModel->getUserByCheck($types, $types_id, $new_order_id);
                $user_ids[] = $check_user_id;
                $check_user_ids = $check_user_ids ? array_merge($check_user_ids, $user_ids) : $user_ids;
                //剩余审批人user_id
                $sub_user_ids = $check_user_ids ? array_diff(explode(',', $step_user_ids), $check_user_ids) : $step_user_ids;
                $sub_user_ids = array_unique(array_filter($sub_user_ids));
                if (!$sub_user_ids) {
                    $is_end = 1;
                }
            } else {
                $is_end = 1;
            }
        }
    } else {
        $is_end = 1;
    }
    if ($is_end == 1) {
        $next_order_id = $new_order_id + 1;
    } else {
        $next_order_id = $new_order_id;
    }
    //当前审批步骤已结束
    if ($is_end == 1) {
        //当前审批流程是否结束
        $stepInfo = $examineStepModel->getStepByOrder($flow_id, $next_order_id); //审批步骤
        $next_step_user_ids = $examineStepModel->getUserByStep($stepInfo['step_id'], $user_id);
        $next_user_ids = stringToArray($next_step_user_ids);
    } else {
        $next_user_ids = array_unique(array_filter($sub_user_ids));
    }
    if (!$next_user_ids && $next_order_id <= $max_order_id) {
        $newRes = [];
        $newRes = nextCheckData($user_id, $flow_id, $types, $types_id, $next_order_id, $check_user_id);
        $next_user_ids = $newRes['next_user_ids'];
    }
    $data = [];
    $data['order_id'] = ($next_order_id <= $max_order_id) ? $next_order_id : $max_order_id;
    $data['next_user_ids'] = $next_user_ids ?: '';
    return $data;
}

/**
 * 解析获取php.ini 的upload_max_filesize（单位：byte）
 * @param $dec int 小数位数
 * @return float （单位：byte）
 * */
function get_upload_max_filesize_byte($dec = 2)
{
    $max_size = ini_get('upload_max_filesize');
    preg_match('/(^[0-9\.]+)(\w+)/', $max_size, $info);
    $size = $info[1];
    $suffix = strtoupper($info[2]);
    $a = array_flip(array("B", "KB", "MB", "GB", "TB", "PB"));
    $b = array_flip(array("B", "K", "M", "G", "T", "P"));
    $pos = $a[$suffix] && $a[$suffix] !== 0 ? $a[$suffix] : $b[$suffix];
    return round($size * pow(1024, $pos), $dec);
}

/**
 * 模拟post进行url请求
 * @param string $url
 * @param string $param
 */
function curl_post($url = '', $post = array())
{
    $curl = curl_init(); // 启动一个CURL会话
    curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 1); // 从证书中检查SSL加密算法是否存在
    curl_setopt($curl, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); // 模拟用户使用的浏览器
    curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); // 使用自动跳转
    curl_setopt($curl, CURLOPT_AUTOREFERER, 1); // 自动设置Referer
    curl_setopt($curl, CURLOPT_POST, 1); // 发送一个常规的Post请求
    curl_setopt($curl, CURLOPT_POSTFIELDS, $post); // Post提交的数据包
    curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
    curl_setopt($curl, CURLOPT_HEADER, 0); // 显示返回的Header区域内容
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); // 获取的信息以文件流的形式返回
    $res = curl_exec($curl); // 执行操作
    if (curl_errno($curl)) {
        echo 'Errno' . curl_error($curl);//捕抓异常
    }
    curl_close($curl); // 关闭CURL会话
    return $res; // 返回数据，json格式
}

/**
 * 输出json字符串，用于接口调试
 *
 * @return void
 * @author ymob
 */
function vdd()
{
    header('Content-Type: text/json; charset=utf-8');
    $args = func_get_args();
    foreach ($args as &$val) {
        if ($val instanceof think\Model) {
            $val = $val->getLastSql();
        }
    }
    if (count($args) < 2) {
        $args = array_shift($args);
    }
    die(json_encode($args));
}


/**
 * 根据时间查询参数返回时间条件 （用于统计分析模块）
 *
 * @param array $where
 * @param string $field
 * @return void
 * @author ymob
 */
function getWhereTimeByParam(&$where, $field = 'create_time')
{
    $param = request()->param();
    if (empty($param['type']) && empty($param['start_time'])) {
        $param['type'] = 'month';
    }
    if (!empty($param['start_time'])) {
        $where[$field] = ['between', [$param['start_time'], $param['end_time']]];
    } else {
        $timeRange = getTimeByType($param['type']);
        if ($timeRange) {
            $where[$field] = ['between', [$timeRange[0], $timeRange[1]]];
        }
    }
}

/**
 * 根据员工、部门查询参数返回员工、部门条件 （用于统计分析模块）
 *
 * @param array $where
 * @param string $field
 * @param string $m
 * @param string $c
 * @param string $a
 * @return void
 * @author ymob
 */
function getWhereUserByParam(&$where, $field = 'owner_user_id', $m = '', $c = '', $a = '')
{
    $param = request()->param();
    $userModel = new UserModel();

    $map_user_ids = [];
    if ($param['user_id']) {
        $map_user_ids = array($param['user_id']);
    } elseif ($param['structure_id']) {
        $map_user_ids = $userModel->getSubUserByStr($param['structure_id'], 2);
    } else {
        $map_user_ids = $userModel->getUserByPer($m, $c, $a);
        $where[$field] = array('in', $map_user_ids);
        return;
    }

    $perUserIds = $userModel->getUserByPer($m, $c, $a); //权限范围内userIds
    $userIds = array_intersect($map_user_ids, $perUserIds); //数组交集
    $where[$field] = array('in', $userIds);
}

/**
 * 获取客户浏览器类型
 */
function getBrowser()
{
    $Browser = $_SERVER['HTTP_USER_AGENT'];
    if (preg_match('/MSIE/i', $Browser)) {
        $Browser = 'MSIE';
    } elseif (preg_match('/Firefox/i', $Browser)) {
        $Browser = 'Firefox';
    } elseif (preg_match('/Chrome/i', $Browser)) {
        $Browser = 'Chrome';
    } elseif (preg_match('/Safari/i', $Browser)) {
        $Browser = 'Safari';
    } elseif (preg_match('/Opera/i', $Browser)) {
        $Browser = 'Opera';
    } else {
        $Browser = 'Other';
    }
    return $Browser;
}

/**
 * 获取客户端系统
 */
function getOS()
{
    $agent = $_SERVER['HTTP_USER_AGENT'];
    if (preg_match('/win/i', $agent)) {
        if (preg_match('/nt 6.1/i', $agent)) {
            $OS = 'Windows 7';
        } else if (preg_match('/nt 6.2/i', $agent)) {
            $OS = 'Windows 8';
        } else if (preg_match('/nt 10.0/i', $agent)) {
            $OS = 'Windows 10';
        } else {
            $OS = 'Windows';
        }
    } elseif (preg_match('/mac/i', $agent)) {
        $OS = 'MAC';
    } elseif (preg_match('/linux/i', $agent)) {
        $OS = 'Linux';
    } elseif (preg_match('/unix/i', $agent)) {
        $OS = 'Unix';
    } elseif (preg_match('/bsd/i', $agent)) {
        $OS = 'BSD';
    } else {
        $OS = 'Other';
    }
    return $OS;
}

/**
 * 根据IP获取地址
 */
function getAddress($ip)
{
    $res = file_get_contents("http://ip.360.cn/IPQuery/ipquery?ip=" . $ip);
    $res = json_decode($res, 1);
    if ($res && $res['errno'] == 0) {
        return explode("\t", $res['data'])[0];
    } else {
        return '';
    }
}

/**
 * 下载服务器文件
 *
 * @param string $file 文件路径
 * @param string $name 下载名称
 * @param boolean $del 下载后删除
 * @return void
 * @author Ymob
 */
function download($file, $name = '', $del = false)
{
    if (!file_exists($file)) {
        return resultArray([
            'error' => '文件不存在',
        ]);
    }
    // 仅允许下载 public 目录下文件
    $res = strpos(realpath($file), realpath('./public'));
    if ($res !== 0) {
        return resultArray([
            'error' => '文件路径错误',
        ]);
    }

    $fp = fopen($file, 'r');
    $size = filesize($file);

    //下载文件需要的头
    header("Content-type: application/octet-stream");
    header("Accept-Ranges: bytes");
    header('ResponseType: blob');
    header("Accept-Length: $size");
    $file_name = $name != '' ? $name : pathinfo($file, PATHINFO_BASENAME);
    // urlencode 处理中文乱码
    header("Content-Disposition:attachment; filename=" . urlencode($file_name));

    // 导出数据时  csv office Excel 需要添加bom头
    if (pathinfo($file, PATHINFO_EXTENSION) == 'csv') {
        echo "\xEF\xBB\xBF";    // UTF-8 BOM
    }

    $fileCount = 0;
    $fileUnit = 1024;
    while (!feof($fp) && $size - $fileCount > 0) {
        $fileContent = fread($fp, $fileUnit);
        echo $fileContent;
        $fileCount += $fileUnit;
    }
    fclose($fp);

    // 删除
    if ($del) @unlink($file);
    die();
}

/**
 * 临时目录生成文件名，并返回绝对路径
 *
 * @param string $ext 文件类型后缀
 * @param string $path 临时文件目录 默认 ./public/temp/
 * @return  string  $file_path 文件名称绝对路径
 * @author ymob
 */
function tempFileName($ext = '')
{
    // 临时目录
    $path = TEMP_DIR . date('Ymd') . DS;
    if (!file_exists($path)) {
        mkdir($path, 0777, true);
    }

    $ext = trim($ext, '.');
    do {
        $temp_file = md5(time() . rand(1000, 9999));
        $file_path = $path . $temp_file . '.' . $ext;
    } while (file_exists($file_path));
    return $file_path;
}

/**
 * 递归删除目录
 *
 * @param string $dir
 * @return void
 * @author Ymob
 */
function delDir($dir)
{
    $dh = opendir($dir);
    while ($file = readdir($dh)) {
        if ($file != "." && $file != "..") {
            $fullpath = $dir . "/" . $file;
            if (!is_dir($fullpath)) {
                @unlink($fullpath);
            } else {
                deldir($fullpath);
            }
        }
    }

    closedir($dh);
    //删除当前文件夹：
    @rmdir($dir);
}

/**
 * 商业智能 查询缓存
 *
 * @param string $sql Sql语句
 * @param int $bi_slow_query_time 慢查询时间(毫秒)，默认读取Config(bi_slow_query_time)
 * @return mixed
 * @author Ymob
 * @datetime 2019-11-21 17:36:50
 */
function queryCache($sql = '', $bi_slow_query_time = null)
{
    $key = 'BI_queryCache' . md5($sql);
    $val = cache($key);
    if (!$val) {
        $start_time = microtime(true) * 1000;
        $val = Db::query($sql);
        $end_time = microtime(true) * 1000;
        $slow_query = true;
        // 是否使用系统默认设置-慢查询时间
        if ($bi_slow_query_time === null) {
            $bi_slow_query_time = config('bi_slow_query_time');
        }
        if ($bi_slow_query_time > 0) {
            $slow_query = ($end_time - $start_time) > $bi_slow_query_time;
        }
        if ($slow_query && $val) {
            cache($key, $val, config('bi_cache_time'));
        }
    }
    return $val;
}

/**
 * 图表时间范围处理，按月/天返回时间段数组
 *
 * @param int $start 开始时间（时间戳）
 * @param int $end 结束时间（时间戳）
 * @return array
 * @author Ymob
 * @datetime 2019-11-18 09:25:09
 */
function getTimeArray($start = null, $end = null)
{
    if ($start == null || $end == null) {
        $param = request()->param();
        switch ($param['type']) {
            // 本年
            case 'year':
                $start = strtotime(date('Y-01-01'));
                $end = strtotime('+1 year', $start) - 1;
                break;
            // 去年
            case 'lastYear':
                $start = strtotime(date(date('Y') - 1 . '-01-01'));
                $end = strtotime('+1 year', $start) - 1;
                break;
            // 本季度、上季度
            case 'quarter':
            case 'lastQuarter':
                $t = intval((date('m') - 1) / 3);
                $start_y = ($t * 3) + 1;
                $start = strtotime(date("Y-{$start_y}-01"));
                if ($param['type'] == 'lastQuarter') {  // 上季度
                    $start = strtotime('-3 month', $start);
                }
                $end = strtotime('+3 month', $start) - 1;
                break;
            // 本月、上月
            case 'month':
            case 'lastMonth':
                $start = strtotime(date('Y-m-01'));
                if ($param['type'] == 'lastMonth') {
                    $start = strtotime('-1 month', $start);
                }
                $end = strtotime('+1 month', $start) - 1;
                break;
            // 本周、上周
            case 'week':
            case 'lastWeek':
                $start = strtotime('-' . (date('w') - 1) . 'day', strtotime(date('Y-m-d')));
                if ($param['type'] == 'lastWeek') {
                    $start = strtotime('-7 day', $start);
                }
                $end = strtotime('+7 day', $start) - 1;
                break;
            // 今天、昨天
            case 'today':
            case 'yesterday':
                $start = strtotime(date('Y-m-d'));
                if ($param['type'] == 'yesterday') {
                    $start = strtotime('-1 day', $start);
                }
                $end = strtotime('+1 day', $start) - 1;
                break;
            default:
                if ($param['start_time'] && $param['end_time']) {
                    $start = $param['start_time'];
                    $end = $param['end_time'];
                } else {
                    // 本年
                    $start = strtotime(date('Y-01-01'));
                    $end = strtotime('+1 year', $start) - 1;
                }
                break;
        }
    }

    $between = [$start, $end];
    $list = [];
    $len = ($end - $start) / 86400;
    // 大于30天 按月统计、小于按天统计
    if ($len > 31) {
        $time_format = '%Y-%m';
        while (true) {
            $start = strtotime(date('Y-m-01', $start));
            $item = [];
            $item['type'] = date('Y-m', $start);
            $item['start_time'] = $start;
            $item['end_time'] = strtotime('+1 month', $start) - 1;
            $list[] = $item;
            if ($item['end_time'] >= $end) break;
            $start = $item['end_time'] + 1;
        }
    } else {
        $time_format = '%Y-%m-%d';
        while (true) {
            $item = [];
            $item['type'] = date('Y-m-d', $start);
            $item['start_time'] = $start;
            $item['end_time'] = strtotime('+1 day', $start) - 1;
            $list[] = $item;
            if ($item['end_time'] >= $end) break;
            $start = $item['end_time'] + 1;
        }
    }

    return [
        'list' => $list,        // 时间段列表
        'time_format' => $time_format,      // 时间格式 mysql 格式化时间戳
        'between' => $between       // 开始结束时间
    ];
}

/**
 * 打印程序执行时间
 *
 * @param integer $s
 * @return void
 * @author Ymob
 * @datetime 2019-11-28 09:31:45
 */
function tt($s = 0)
{
    die((string)round(microtime(1) - ($s ?: THINK_START_TIME), 3));
}

/**
 * 数据库备份
 */
function DBBackup($file = '', $path = '')
{
    $type = config('database.type');
    $host = config('database.hostname');
    $port = config('database.hostport');
    $dbname = config('database.database');
    $username = config('database.username');
    $password = config('database.password');
    $dsn = "{$type}:host={$host};dbname={$dbname};port={$port}";


    if ($file == '') {
        $save_path = dirname(APP_PATH) . DS . 'data' . DS . date('Ym') . DS;
        if (!file_exists($save_path) && !mkdir($save_path, '0777', true)) {
            return 'data目录无写入权限';
        }
        $file = $save_path . date('d_H_i') . '_db_backup' . '.sql';
    }

    if (file_exists($file)) {
        return '数据库备份文件已存在（自动备份时间间隔需大于1分钟）。';
    }

    try {
        $backup = new \com\Mysqldump($dsn, $username, $password);
        $backup->start($file);
        return true;
    } catch (\Exception $e) {
        return '备份失败，请手动备份。错误原因：' . $e->getMessage();
    }

}

/**
 * 根据ip获取地址
 */
function getAddressById($data)
{
    $ip = new IpLocation();
    $ip_address = $ip->getlocation($data);
    return $ip_address;
}

if (!function_exists('isSuperAdministrators')) {
    /**
     * 判断是否是超级管理员
     *
     * @param $userId
     * @return bool
     */
    function isSuperAdministrators($userId)
    {
        $status = false;

        $apiCommon = new \app\admin\controller\ApiCommon();

        $userId = !empty($userId) ? $userId : $apiCommon->userInfo['id'];

        $data = db('admin_access')->where('user_id', $userId)->column('group_id');

        if ($userId == 1 || in_array(1, $data)) {
            $status = true;
        }

        return $status;
    }
}

if (!function_exists('getFieldGrantData')) {
    /**
     * 获取自动授权数据
     *
     * @return array
     */
    function getFieldGrantData($userId)
    {
        $result = [];

        $apiCommon = new \app\admin\controller\ApiCommon();

        $userId = !empty($userId) ? $userId : $apiCommon->userInfo['id'];

        $grantData = Db::query("
            SELECT 
                `grant`.`module`, `grant`.`column`, `grant`.`content` 
            FROM 
                `5kcrm_admin_access` AS `access` 
            LEFT JOIN 
                `5kcrm_admin_group` AS `group` ON `access`.`group_id` = `group`.`id` 
            LEFT JOIN 
                `5kcrm_admin_field_grant` AS `grant` ON `group`.`id` = `grant`.`role_id` 
            WHERE 
                `access`.`user_id` = 
        " . $userId);

        # 存在多角色多授权的情况
        foreach ($grantData as $key => $value) {
            if (empty($value['module']) || empty($value['column'])) continue;

            $result[$value['module'] . '_' . $value['column']][] = !empty($value['content']) ? unserialize($value['content']) : [];
        }

        return $result;
    }
}

if (!function_exists('getFieldGrantStatus')) {
    /**
     * 获取字段授权状态
     *
     * @param $field
     * @param $grantData
     * @return int[]
     */
    function getFieldGrantStatus($field, $grantData)
    {
        # 默认状态都是不能查看、不能编辑，通过配置来取最大权限。
        $result = ['read' => 0, 'write' => 0,'maskType'=>0];
        foreach ($grantData as $key => $value) {
            $fieldBool = false;

            foreach ($value as $ke => $va) {
                # 多个字段授权，只取最高的读权限
                if ($va['field'] == $field && $result['read'] == 0) {
                    $result['read'] = $va['read'] > $result['read'] ? $va['read'] : $result['read'];
                }

                # 多个字段授权，只取最高的写权限
                if ($va['field'] == $field && $result['write'] == 0) {
                    $result['write'] = $va['write'] > $result['write'] ? $va['write'] : $result['write'];
                }
                if ($va['field'] == $field && $va['maskType'] != 0) {
                    $result['maskType'] = !empty($va['maskType'])?$va['maskType']:0;
                }
                if ($va['field'] == $field) $fieldBool = true;
            }

            # 对于不在权限控制之内的字段，将状态都改为1。
            if (!$fieldBool) {

                $result['read'] = 1;
                $result['write'] = 1;

            }
        }
        return $result;
    }
}

/**
 * 仪表盘日志使用
 * 根据类型获取开始结束时间戳数组
 * @param
 */
function ByDateTime($type = 'today')
{
    switch ($type) {
        case 'yesterday' :
            $timeArr = DataTime::yesterday();
            $timeArr['last_time'] = DataTime::yesterday(1);
            break;
        case 'week' :
            $timeArr = DataTime::week();
            $timeArr['last_time'] = DataTime::lastWeek();
            break;
        case 'lastWeek' :
            $timeArr = DataTime::lastWeek();
            $timeArr['last_time'] = DataTime::lastWeek(1);
            break;
        case 'month' :
            $timeArr = DataTime::month();
            $timeArr['last_time'] = DataTime::lastMonth();
            break;
        case 'lastMonth' :
            $timeArr = DataTime::lastMonth();
            $timeArr['last_time'] = DataTime::lastMonth(1);
            break;
        case 'quarter' :
            //本季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $daterange_start_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-06-30 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-09-30 23:59:59"));
            } else {
                $daterange_start_time = strtotime(date('Y-10-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-12-31 23:59:59"));
            }

            //上季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $year = date('Y') - 1;
                $daterange_start_time_last_time = strtotime(date($year . '-10-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date($year . '-12-31 23:59:59'));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time_last_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time_last_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date("Y-06-30 23:59:59"));
            } else {
                $daterange_start_time_last_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date("Y-09-30 23:59:59"));
            }
            $timeArr = array($daterange_start_time, $daterange_end_time);
            $timeArr['last_time'] = array($daterange_start_time_last_time, $daterange_end_time_last_time);
            break;
        case 'lastQuarter' :
            //上季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $year = date('Y') - 1;
                $daterange_start_time = strtotime(date($year . '-10-01 00:00:00'));
                $daterange_end_time = strtotime(date($year . '-12-31 23:59:59'));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-06-30 23:59:59"));
            } else {
                $daterange_start_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time = strtotime(date("Y-09-30 23:59:59"));
            }
            //上季度
            $month = date('m');
            if ($month == 1 || $month == 2 || $month == 3) {
                $year = date('Y') - 2;
                $daterange_start_time_last_time = strtotime(date($year . '-10-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date($year . '-12-31 23:59:59'));
            } elseif ($month == 4 || $month == 5 || $month == 6) {
                $daterange_start_time_last_time = strtotime(date('Y-01-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date("Y-03-31 23:59:59"));
            } elseif ($month == 7 || $month == 8 || $month == 9) {
                $daterange_start_time_last_time = strtotime(date('Y-04-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date("Y-06-30 23:59:59"));
            } else {
                $daterange_start_time_last_time = strtotime(date('Y-07-01 00:00:00'));
                $daterange_end_time_last_time = strtotime(date("Y-09-30 23:59:59"));
            }
            $timeArr = array($daterange_start_time, $daterange_end_time);
            $timeArr['last_time'] = array($daterange_start_time_last_time, $daterange_end_time_last_time);
            break;
        case 'year' :
            $timeArr = DataTime::year();
            $timeArr['last_time'] = DataTime::lastYear();
            break;
        case 'lastYear' :
            $timeArr = DataTime::lastYear();
            $timeArr['last_time'] = DataTime::lastYear(1);
            break;
        case 'recent60' :
            $timeArr = DataTime::recent60();
            break;
        case 'recent30' :
            $timeArr = DataTime::recent30();
            break;
        default :
            $timeArr = DataTime::today();
            $timeArr['last_time'] = DataTime::yesterday();
            break;
    }
    return $timeArr;
}

/**
 * 系统操作日志
 * @param int $user_id 用户
 * @param string $types 方法所属模块
 * @param int $action_id 操作
 * @param string $module_name 模块
 * @param string $action_name 修改添加删除新建
 * @param array $oldData 旧数据
 * @param array $newData 新数据
 * @param string $target_name 被操作对象
 * @param string $content 添加时创建使用
 * @author      alvin guogaobo
 * @version     1.0 版本号
 * @since       2021/3/26 0026 15:10
 */
function SystemActionLog($user_id, $types, $module_name, $action_id, $action_name, $target_name, $oldData = [], $newData = [], $content = '')
{
    //action_name 修改添加删除新建 action_id 操作id client_ip ip create_time时间 content 操作记录 target_name 被操作对象 module_name 模块 系统管理 固定  user_id 用户
    $data = [];
    $data['user_id'] = $user_id;
    $data['create_time'] = time();
    $data['client_ip'] = request()->ip();
    $data['action_id'] = $action_id;
    $data['action_name'] = $action_name;
    $data['target_name'] = $target_name;
    $data['module_name'] = $module_name;
    $data['controller_name'] = $types;
    $data['content'] = $content;
    db('admin_system_log')->insert($data);
}

/**
 * 系统操作日志
 * @param int $user_id 用户
 * @param string $types 方法所属模块
 * @param string $action_name 修改添加删除新建
 * @param string $target_name 被操作对象
 * @param array $oldData 旧数据
 * @param array $newData 新数据
 * @param string $content 添加时创建使用
 * @author      alvin guogaobo
 * @version     1.0 版本号
 * @since       2021/4/2 0026 15:10
 */
function RecordActionLog($user_id, $types, $action_name, $target_name, $oldData = [], $newData = [], $content = '')
{
    //action_name 修改 添加 删除  client_ip ip create_time时间 content 操作记录 target_name 被操作对象 module 模块  user_id 用户
    if (is_array($oldData) && is_array($newData) && $user_id) {
        $differentData = array_diff_assoc($newData, $oldData);
        $fieldModel = new FieldModel();
        $userModel = new UserModel();
        $structureModel = new \app\admin\model\Structure();
        $field_arr = $fieldModel->getField(['types' => $types, 'unFormType' => ['file', 'form']]); //获取字段属性
        $newFieldArr = array();
        foreach ($field_arr as $k => $v) {
            $newFieldArr[$v['field']] = $v;
        }
        $unField = ['update_time', 'create_time']; //定义过滤字段
        $message = [];
        $un_form_type = ['file', 'form'];
        foreach ($differentData as $k => $v) {
            if ($newFieldArr[$k] && !in_array($newFieldArr[$k]['form_type'], $un_form_type)) {
                $field_name = '';
                $field_name = $newFieldArr[$k]['name'];
                $new_value = $v ?: '空';
                $old_value = $oldData[$k] ?: '空';
                switch ($newFieldArr[$k]['form_type']) {
                    case 'datetime' :
                        $new_value = $v ? date('Y-m-d', $v) : '';
                        $old_value = date('Y-m-d', $oldData[$k]);
                        if (!empty($v) && !empty($oldData[$k]))
                            break;
                    case 'user' :
                        $new_value = $v ? implode(',', $userModel->getUserNameByArr(stringToArray($v))) : '';
                        $old_value = $v ? implode(',', $userModel->getUserNameByArr(stringToArray($oldData[$k]))) : '';
                        break;
                    case 'structure' :
                        $new_value = $v ? implode(',', $structureModel->getStructureNameByArr(stringToArray($v))) : '';
                        $old_value = $v ? implode(',', $structureModel->getStructureNameByArr(stringToArray($oldData[$k]))) : '';
                        break;
                    case 'business_status' :
                        $new_value = $v ? db('crm_business_status')->where(['status_id' => $v])->value('name') : '';
                        $old_value = $v ? db('crm_business_status')->where(['status_id' => $oldData[$k]])->value('name') : '';
                        break;
                    case 'business_type' :
                        $new_value = $v ? db('crm_business_type')->where(['type_id' => $v])->value('name') : '';
                        $old_value = $v ? db('crm_business_type')->where(['type_id' => $oldData[$k]])->value('name') : '';
                        break;
                    case 'customer' :
                        $new_value = $v ? db('crm_customer')->where(['customer_id' => $v])->value('name') : '';
                        $old_value = $v ? db('crm_customer')->where(['customer_id' => $oldData[$k]])->value('name') : '';
                        break;
                    case 'category' :
                        $new_value = $v ? db('crm_product_category')->where(['category_id' => $v])->value('name') : '';
                        $old_value = $v ? db('crm_product_category')->where(['category_id' => $oldData[$k]])->value('name') : '';
                        break;
                    case 'business' :
                        $new_value = $v ? db('crm_business')->where(['business_id' => $v])->value('name') : '';
                        $old_value = $v ? db('crm_business')->where(['business_id' => $oldData[$k]])->value('name') : '';
                        break;
                    case 'visit' :
                        $new_value = $v ? db('crm_visit')->where(['visit_id' => $v])->value('number') : '';
                        $old_value = $v ? db('crm_visit')->where(['visit_id' => $oldData[$k]])->value('number') : '';
                        break;
                    case 'single_user' :
                        $new_value = $v ? db('admin_user')->where(['id' => $v])->value('realname') : '';
                        $old_value = $v ? db('admin_user')->where(['id' => $oldData['owner_user_id']])->value('realname') : '';
                        break;
                    case 'floatnumber' :
                        $new_value = $v ? number_format($v, 2) : '';
                        break;
                }
                if ($newFieldArr[$k]['field'] == 'check_status') {
                    $statusArr = ['0' => '待审核', '1' => '审核中', '2' => '审核通过', '3' => '已拒绝', '4' => '已撤回', '5' => '未提交'];
                    $new_value = $statusArr[$v];
                    $old_value = $statusArr[$oldData[$k]];
                }
                if ($old_value != $new_value) {
                    $message[] = '将 ' . "'" . $field_name . "'" . ' 由 ' . $old_value . ' 修改为 ' . $new_value;
                }
            }
        }
        if ($message) {
            $data = [];
            $data['user_id'] = $user_id;
            $data['create_time'] = time();
            $data['client_ip'] = request()->ip();
            $data['action_name'] = $action_name;
            $data['action_id'] = 1;
            $data['target_name'] = $target_name;
            $data['module'] = $types;  //子模块 客户线索
            $data['content'] = implode(',', $message);
            db('admin_operation_log')->insert($data);
        }
    } elseif ($content) {
        $data = [];
        $data['user_id'] = $user_id;
        $data['create_time'] = time();
        $data['client_ip'] = request()->ip();
        $data['action_name'] = $action_name;
        $data['target_name'] = $target_name;
        $data['action_id'] = 1;
        $data['module'] = $types;  //子模块 客户线索
        $data['content'] = $content;
        db('admin_operation_log')->insert($data);
    }
}

if (!function_exists('getFieldGroupOrderData')) {
    /**
     * 对自定义字段进行分组排序
     *
     * @param array $data 自定义字段数据
     * @return array
     * @since 2021-04-27
     * @author fanqi
     */
    function getFieldGroupOrderData($data)
    {
        $formPositionEmpty = [];
        $formPositionExist = [];
        $result = [];
        // 处理数据，将有位置信息和无位置信息的数据分开存放。
        foreach ($data as $key => $value) {
            if (empty($value['form_position'])) {
                $formPositionEmpty[] = $value;
                continue;
            }
            $formPositionArray = explode(',', $value['form_position']);
            $x = (int)$formPositionArray[0];
            $y = (int)$formPositionArray[1];

            if (!isset($value['xaxis'])) $value['xaxis'] = $x;
            if (!isset($value['yaxis'])) $value['yaxis'] = $y;
            if ($value['form_type'] == 'date_interval' && !is_array($value['default_value'])) {
                $value['default_value'] = !empty($value['default_value']) ? explode(',', $value['default_value']) : [];
            }
            $formPositionExist[$x][$y] = $value;

        }

        // 排序
        ksort($formPositionExist);
        // 处理有位置信息的数据
        foreach ($formPositionExist as $key => $value) {
            foreach ($value as $k => $v) {
                if (!empty($formPositionExist[$key][$k])) $result[$key][$k] = $v;

            }

            $result[$key] = array_values($result[$key]);
        }
        // 将无位置信息的数据放置尾端
        foreach ($formPositionEmpty as $key => $value) {
            $result[] = [$value];
        }

        return array_values($result);
    }
}

if (!function_exists('getPrimaryKeyName')) {
    /**
     * 获取主键
     *
     * @param string $types 栏目类型
     * @return string
     * @since 2021-05-18
     * @author fanqi
     */
    function getPrimaryKeyName($types)
    {
        $primaryKey = '';

        if ($types == 'crm_leads') $primaryKey = 'leads_id';
        if ($types == 'crm_customer') $primaryKey = 'customer_id';
        if ($types == 'crm_contacts') $primaryKey = 'contacts_id';
        if ($types == 'crm_business') $primaryKey = 'business_id';
        if ($types == 'crm_contract') $primaryKey = 'contract_id';
        if ($types == 'crm_receivables') $primaryKey = 'receivables_id';
        if ($types == 'crm_receivables_plan') $primaryKey = 'plan_id';
        if ($types == 'crm_visit') $primaryKey = 'visit_id';
        if ($types == 'crm_product') $primaryKey = 'product_id';
        if ($types == 'crm_invoice') $primaryKey = 'invoice_id';
        if ($types == 'oa_examine') $primaryKey = 'examine_id';
        if ($types == 'jxc_product') $primaryKey = 'product_id';
        if ($types == 'jxc_supplier') $primaryKey = 'supplier_id';
        if ($types == 'jxc_purchase') $primaryKey = 'purchase_id';
        if ($types == 'jxc_retreat') $primaryKey = 'retreat_id';
        if ($types == 'jxc_sale') $primaryKey = 'sale_id';
        if ($types == 'jxc_salereturn') $primaryKey = 'salereturn_id';
        if ($types == 'jxc_receipt') $primaryKey = 'receipt_id';
        if ($types == 'jxc_outbound') $primaryKey = 'outbound_id';
        if ($types == 'jxc_payment') $primaryKey = 'payment_note_id';
        if ($types == 'jxc_collection') $primaryKey = 'collection_note_id';
        if ($types == 'jxc_inventory') $primaryKey = 'inventory_id';
        if ($types == 'jxc_allocation') $primaryKey = 'allocation_id';

        return $primaryKey;
    }

}
function advancedQueryFormatForTeam($requestMap, $db, $db_id)
{
    // 处理查询条件
    foreach ($requestMap['team_id']['value'] as $v) {
        if ($requestMap['team_id']['condition'] == 'contains') {
            $date = function ($query) use ($v) {
                $query->where('FIND_IN_SET("' . $v . '", ro_user_id)')
                    ->whereOr('FIND_IN_SET("' . $v . '", rw_user_id)');
            };
        } elseif ($requestMap['team_id']['condition'] == 'notContains') {
            $date = function ($query) use ($v) {
                $query->where('FIND_IN_SET("' . $v . '", ro_user_id)')
                    ->where('FIND_IN_SET("' . $v . '", rw_user_id)');
            };
        } elseif ($requestMap['team_id']['condition'] == 'isNull') {
            $date = function ($query) {
                $query->where('ro_user_id', ['eq', ''])
                    ->whereOr('rw_user_id', 'null');
            };
        } elseif ($requestMap['team_id']['condition'] == 'isNotNull') {
            $date = function ($query) {
                $query->where('ro_user_id', ['neq', ''])
                    ->where('rw_user_id', ['not null']);
            };

        }
        $part[] = db($db)->where($date)->column($db_id);
    }
    $result = [];
    array_walk_recursive($part, function ($value) use (&$result) {
        array_push($result, $value);
    });
    $result = array_unique($result);
    $partMap['customer.customer_id'] = ['in', trim(arrayToString($result), ',')];
    return $partMap ?: [];
}