drb/app/Service/OaService.php

<?php

namespace App\Service;


use App\Model\BasicRollFilm;
use App\Model\Construction;
use App\Model\Depart;
use App\Model\Employee;
use App\Model\EmployeeDepartPermission;
use App\Model\EmployeeTeamPermission;
use App\Model\Oa;
use App\Model\OaOrder;
use App\Model\OaOrderSub;
use App\Model\OaOrderSubEmployee;
use App\Model\OaReportOrder;
use App\Model\OaReportOrderEmployee;
use App\Model\OaSub;
use App\Model\OaSubEmployee;
use App\Model\OaSubReportEmployee;
use App\Model\OaSubRule;
use App\Model\PurchaseOrderSpecial;
use App\Model\RollFilm;
use App\Model\RollFilmCombine;
use App\Model\RollFilmCompany;
use App\Model\SysMenu;
use App\Model\Team;
use App\Service\Weixin\WxSendMessageService;
use App\Service\Wx\WxService;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Route;

/**
 * bom相关
 * @package App\Models
 */
class OaService extends Service
{
    public $user;

    public function __construct($user = '')
    {
        parent::__construct();
        $this->user = $user;
    }

    public function oaList($data,$user)
    {
        $list = Oa::from('oa as o')
            ->leftjoin('sys_menu as s', 's.id', 'o.menu_id')
            ->select('o.id', 'o.menu_id', 'o.crt_time', 's.title','o.channel')
            ->where('o.del_time', 0);

        if(! empty($data['top_depart_id'])) {
            $list->where('o.channel', $data['top_depart_id']);
        }else{
            if(! $user['is_all_depart']){
                $top_depart_id = $user['depart_top'][0]['depart_id'] ?? 0;
                $list->where('o.channel', $top_depart_id);
            }
        }

        $list = $this->limit($list, '', $data);
        $list = $this->fillData($list);

        return [true, $list];
    }

    public function fillData($data) {
        if (empty($data['data'])) return $data;

        $depart = Depart::whereIn('id',array_column($data['data'],'channel'))
            ->pluck('title','id')
            ->toArray();
        foreach ($data['data'] as $key => $value){
            $data['data'][$key]['top_depart_title'] = $depart[$value['channel']] ?? '';
        }
        return $data;
    }

    public function oaDetail($data)
    {

        $id = $data['id'];
        $oa = Oa::where('id', $id)->first();
        $list = OaSub::where('oa_id', $id)->where('del_time', 0)->get()->toArray();
        $oa_sub_ids = [];
        foreach ($list as $v) {
            $oa_sub_ids[] = $v['id'];
        }
        $oaRule = OaSubRule::wherein('oa_sub_id', $oa_sub_ids)->get()->toArray();
        $oaEmployee = OaSubEmployee::wherein('oa_sub_id', $oa_sub_ids)->get()->toArray();
        $oaReportEmployee = OaSubReportEmployee::wherein('oa_sub_id', $oa_sub_ids)->get()->toArray();
        $oaRuleKey = [];
        $oaEmployeeKey = [];
        $oaReportEmployeeKey = [];
        foreach ($oaRule as $v) {
            $oaRuleKey[$v['oa_sub_id']][] = [
                'value' => $v['value'],
                'key' => $v['key'],
                'opera' => $v['formula'] == '==' ? '==' : $v['formula'],
            ];
        }
        $employee_key_list = Employee::pluck('emp_name', 'id')->toArray();
        foreach ($oaEmployee as $v) {
            $oaEmployeeKey[$v['oa_sub_id']][] = [
                'id' => $v['employee_id'],
                'emp_name' => $employee_key_list[$v['employee_id']],
            ];
        }
        foreach ($oaReportEmployee as $v) {
            $oaReportEmployeeKey[$v['oa_sub_id']][] = [
                'id' => $v['employee_id'],
                'emp_name' => $employee_key_list[$v['employee_id']],
            ];
        }
        $return = [];
        foreach ($list as $v) {
            $return[$v['sort']][] = [
                'emp_id' => $oaEmployeeKey[$v['id']],
                'copy_id' => $oaReportEmployeeKey[$v['id']] ?? [],
                'is_copy' => isset($oaReportEmployeeKey[$v['id']]) && !empty($oaReportEmployeeKey[$v['id']]),
                'index' => $v['h5_key'],
                'set' => isset($oaRuleKey[$v['id']]) ? $oaRuleKey[$v['id']] : [],
            ];
        }
        $detail = [];
        foreach ($return as $k => $v) {
            $children = [];
            foreach ($v as $vv) {
                $children[] = [
                    'set' => $vv['set'],
                    'emp_id' => $vv['emp_id'],
                    'copy_id' => $vv['copy_id'],
                    'is_copy' => $vv['is_copy'],
                    'index' => $vv['index'],
                ];
            }
            $detail[] = ['children' => $children];
        }
        return [true, ['data' => $detail, 'menu_id' => $oa->menu_id, 'title' => $oa->title]];

    }

    public function oaUserDetail($data)
    {

        $detail = [
            'detail' => [
                [
                    'key' => 'area',
                    'value' => '南区',
                    'formula' => 'dengyu',
                ], [
                    'key' => 'num',
                    'value' => '40',
                    'formula' => 'dayu',
                ], [
                    'key' => 'brand',
                    'value' => 'A,B,C',
                    'formula' => 'baohan',
                ],
            ],
            'click' => [
                'area',
                'num',
                'brand',
            ],
            'string' => '(area 并且 num) 或者 num'
        ];
        return [true, $detail];
    }

    public function oaParam($data)
    {
        $detail = [
            [
                'key' => 'area',
                'value' => '地区',
            ], [
                'key' => 'num',
                'value' => '数量',
            ], [
                'key' => 'brand',
                'value' => '品牌',
            ],
        ];
        return [true, $detail];
    }

    public function oaFormula($data)
    {
        $detail = [
            [
                'key' => 'dengyu',
                'value' => '等于',
            ], [
                'key' => 'dayu',
                'value' => '大于',
            ], [
                'key' => 'baohan',
                'value' => '包含',
            ],
        ];
        return [true, $detail];
    }

    public function oaAdd($data)
    {
        $oa = new Oa();
        try {
            DB::beginTransaction();
            $oa->menu_id = $data['menu_id'];
            $oa->type = $data['type'];
            $oa->title = $data['title'] ?? '';
            $oa->channel = $this->user['depart_top'][0]['depart_id'];
            $oa->save();
            $id = $oa->id;
            $insert = [];
            foreach ($data['detail'] as $v) {
                foreach ($v['employee_list'] as $vv) {
                    $insert[] = [
                        'oa_id' => $id,
                        'remark' => $v['remark'],
                        'employee_id' => $vv['employee_id'],
                        'sort' => $v['sort'],
                        'type' => $v['type'],
                        'crt_time' => time(),
                        'upd_time' => time(),
                        'area_id' => $vv['area_id'],
                    ];
                }

            }
            OaSub::insert($insert);
            DB::commit();
        } catch (\Exception $e) {
            DB::rollBack();
            return [false, $e->getLine() . ':' . $e->getMessage()];
        }

        return [true, '保存成功！'];

    }

    public function oaEdit($data, $user)
    {
        $first = Oa::where('del_time', 0)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('menu_id', $data['menu_id']);
        if (isset($data['id'])) $first = $first->where('id', '<>', $data['id']);
        if (isset($data['type'])) $first = $first->where('type', $data['type']);
        $first = $first->first();
        if ($first) return [false, '该菜单对应审批流已存在'];

        try {
            DB::beginTransaction();
            if (isset($data['id'])) $oa = Oa::where('id', $data['id'])->first();
            else $oa = new Oa();
            $oa->menu_id = $data['menu_id'];
            $oa->crt_employee_id = $user['id'];
            $oa->type = $data['type'] ?? 0;
            $oa->title = $data['title'] ?? '';
            $oa->channel = $this->user['depart_top'][0]['depart_id'];
            $oa->save();
            $id = $oa->id;
            $insert = [];

            $oa_sub_id = OaSub::where('oa_id', $id)->where('del_time',0)->pluck('id')->toArray();
            OaSub::where('oa_id', $id)->update([
                'del_time' => time()
            ]);
            //处理前端数据
            $this->dealOaData($data, $id, $oa_sub_id);
            DB::commit();
        } catch (\Exception $e) {
            DB::rollBack();
            return [false, $e->getLine() . $e->getMessage()];
        }

        return [true, '更新成功'];
    }

    public function dealOaData($data, $id, $oa_sub_id)
    {
        $data = $data['approval'];
        $detail = [];
        $sort = 0;
        foreach ($data as $v) {
            $sort++;
            foreach ($v['children'] as $vv) {
                $detail[] = [
                    'h5_key' => $vv['index'],
                    'emp_id' => $vv['emp_id'],
                    'copy_id' => $vv['copy_id'] ?? [],
                    'set' => $vv['set'],
                    'sort' => $sort,
                ];
            }
        }
        $oa_subs = [];
        foreach ($detail as $v) {
            $oa_subs[] = [
                'crt_time' => time(),
                'upd_time' => time(),
                'sort' => $v['sort'],
                'sub_id' => -1,
                'remark' => '',
                'oa_id' => $id,
                'type' => 1,
                'parent_id' => 0,
                'h5_key' => $v['h5_key'],
            ];
        }
        OaSub::insert($oa_subs);
        $oa_sub = OaSub::where('oa_id', $id)->get()->toArray();
        $list_key = [];
        foreach ($oa_sub as $v) {
            $list_key[$v['h5_key']] = $v;
        }
        foreach ($list_key as $k => $v) {
            if ($v['sort'] == 1) continue;
            $len = strlen($k);
            foreach ($list_key as $kk => $vv) {
                if (strlen($kk) == ($len - 2) && substr($k, 0, $len - 2) == $kk) {
                    $list_key[$k]['parent_id'] = $vv['id'];
                }
            }
        }
        $employee_list = [];
        $set_list = [];
        $report_list = [];
        foreach ($detail as $v) {
            if (isset($v['copy_id'])) {
                foreach ($v['copy_id'] as $vv) {
                    $report_list[] = [
                        'employee_id' => $vv,
                        'oa_sub_id' => $list_key[$v['h5_key']]['id'],
                    ];
                }
            }

            foreach ($v['emp_id'] as $vv) {
                $employee_list[] = [
                    'employee_id' => $vv,
                    'oa_sub_id' => $list_key[$v['h5_key']]['id'],
                ];
            }
            $n = 1;
            foreach ($v['set'] as $vv) {
                if ($vv['opera'] == '=') $v['opera'] = '==';
                if ($n > 1) $right_formula = '&&';
                else $right_formula = '';
                $set_list[] = [
                    'oa_sub_id' => $list_key[$v['h5_key']]['id'],
                    'key' => $vv['key'],
                    'value' => $vv['value'],
                    'sort' => $n,
                    'formula' => $vv['opera'],
                    'right_formula' => $right_formula,
                ];
                $n++;
            }
        }
        OaSubRule::wherein('oa_sub_id', $oa_sub_id)->delete();
        OaSubEmployee::wherein('oa_sub_id', $oa_sub_id)->delete();
        OaSubRule::insert($set_list);
        OaSubEmployee::insert($employee_list);
        if (!empty($report_list)) OaSubReportEmployee::insert($report_list);
        foreach ($list_key as $v) {
            if ($v['parent_id'] > 0) OaSub::where('id', $v['id'])->update([
                'parent_id' => $v['parent_id']
            ]);
        }
    }

    public function oaDel($data)
    {
        $id = $data['id'];
        Oa::where('id', $id)->update([
            'del_time' => time(),
        ]);

        OaSub::where('oa_id', $id)->update([
            'del_time' => time(),
        ]);

        return [true, '删除成功'];
    }

    public function oaSubType($data)
    {
        $service = new CheckService();
        $list = $service->map;

        $return = [];
        foreach ($list as $k => $v) {
            $return[] = [
                'id' => $k,
                'title' => $v,
            ];
        }

        return [true, $return];
    }

    public function createOaOrder($data)
    {
        Log::channel('request')->info('request', ['param' => $data]);
        if (!isset($data['order_number'])) $data['order_number'] = $data['order_no'];
        $orderObject = $data['order_number'];
        $menu_id = $data['menu_id'];
        $order_no = $data['order_number'];
        $type = isset($data['opt_case']) ? $data['opt_case'] : 0;

        //如果是虚拟采购单 自动生成
        if($menu_id == PurchaseOrderSpecial::menu_id){
            list($status, $msg) = $this->createPurchaseSpecial($data);
            return [$status, $msg];
        }else{
            //是否存在工作流
            $bool = $this->getOaProcessIsset($menu_id);
            if(! $bool){
                list($parent_status,$parent_msg) = $this->returnOa($order_no, 1, $type);
                if(! $parent_status) return [false, $parent_msg];
                return [true, ''];
            }

            try {
                DB::beginTransaction();

                list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($menu_id, ['order_number' => $orderObject], 1,0, $this->user);
                if (empty($employee_ids)) {
                    list($parent_status,$parent_msg) = $this->returnOa($order_no, 1, $type);
                    if(! $parent_status) {
                        DB::rollBack();
                        return [false, $parent_msg];
                    }

                    DB::commit();
                    return [true, ''];
                }

                $order = new OaOrder();
                $order->menu_id = $menu_id;
                $order->order_no = $order_no;
                $order->opt_case = $type;
                $order->channel = $this->user['depart_top'][0]['depart_id'];
                $order->save();
                $id = $order->id;

                $oa_order_sub = new OaOrderSub();
                $oa_order_sub->oa_order_id = $id;
                $oa_order_sub->sort = 1;
                $oa_order_sub->remark = '';
                $oa_order_sub->type = 1;
                $oa_order_sub->oa_sub_id = $oa_sub_id;
                $oa_order_sub->save();
                $oa_order_sub_id = $oa_order_sub->id;

                //组织数据
                $insert = $send_data = [];
                $emp_map = Employee::whereIn('id',$employee_ids)->pluck('emp_name','id')->toArray();
                $sys_menu = SysMenu::where('id', $menu_id)->value('title') ?? "";
                foreach ($employee_ids as $employee_id) {
                    $emp_tmp = $emp_map[$employee_id] ?? "";
                    $send_data[] = [
                        'employee_id' => $employee_id,
                        'type' => 1,
                        'state' => 0,
                        'menu_id' => $menu_id,
                        'order_number' => $order_detail['order_number'],
                        'tmp_data' => [
                            $order_detail['order_number'],
                            $order_detail['crt_name'].'('.$sys_menu.')',
                            $emp_tmp,
                            date('Y-m-d H:i:s'),
                        ],
                    ];
                    $insert[] = [
                        'oa_order_id' => $id,
                        'oa_order_sub_id' => $oa_order_sub_id,
                        'employee_id' => $employee_id,
                    ];
                }
                OaOrderSubEmployee::insert($insert);
                DB::commit();

                //发送消息
                $this->sendWxOaCheckMessage($send_data);

                return [true, ''];
            } catch (\Exception $e) {
                DB::rollBack();
                $this->returnOa($order_no, 2, $type);
                return [false, $e->getFile() . ':' .$e->getLine() . ':' . $e->getMessage()];
            }
        }
    }

    public function createPurchaseSpecial($data){
        try {
            $order = $data['order'] ?? [];

            $depart = Depart::where('id', $order['supplier'])->first();
            if(empty($depart) || empty($depart->notify_id)) {
                //不存在直接审核通过
                list($parent_status,$parent_msg) = $this->returnOa($data['order_number'], 1, $data['opt_case']);
                if(!$parent_status) return [false, $parent_msg];
                return [true, ''];
            }
            $employee_ids = [$depart->notify_id];

            DB::beginTransaction();

            $order = new OaOrder();
            $order->menu_id = $data['menu_id'];
            $order->order_no = $data['order_number'];
            $order->opt_case = $data['opt_case'];
            $order->save();
            $id = $order->id;

            $oa_order_sub = new OaOrderSub();
            $oa_order_sub->oa_order_id = $id;
            $oa_order_sub->sort = 1;
            $oa_order_sub->remark = '';
            $oa_order_sub->type = 1;
            $oa_order_sub->oa_sub_id = 0;
            $oa_order_sub->save();
            $oa_order_sub_id = $oa_order_sub->id;

            //组织数据
            $insert = $send_data = [];
            $emp_map = Employee::whereIn('id',$employee_ids)->pluck('emp_name','id')->toArray();
            $sys_menu = SysMenu::where('id', $data['menu_id'])->value('title') ?? "";
            foreach ($employee_ids as $employee_id) {
                $emp_tmp = $emp_map[$employee_id] ?? "";
                $send_data[] = [
                    'employee_id' => $employee_id,
                    'type' => 1,
                    'state' => 0,
                    'menu_id' => $data['menu_id'],
                    'order_number' => $data['order_number'],
                    'tmp_data' => [
                        $data['order_number'],
                        "系统生成".'('.$sys_menu.')',
                        $emp_tmp,
                        date('Y-m-d H:i:s'),
                    ],
                ];
                $insert[] = [
                    'oa_order_id' => $id,
                    'oa_order_sub_id' => $oa_order_sub_id,
                    'employee_id' => $employee_id,
                ];
            }
            OaOrderSubEmployee::insert($insert);

            DB::commit();

            //发送消息
            $this->sendWxOaCheckMessage($send_data);

            return [true, ''];
        } catch (\Exception $e) {
            DB::rollBack();
            $this->returnOa($data['order_number'], 2, $data['opt_case']);
            return [false, $e->getFile() . ':' .$e->getLine() . ':' . $e->getMessage()];
        }
    }

    //判断工作流是否存在
    public function getOaProcessIsset($menu_id){
        //特殊的审批 分社采购单
        $bool = Oa::from('oa as o')
            ->leftJoin('oa_sub as os', 'os.oa_id', 'o.id')
            ->select('os.sort', 'os.type', 'os.sub_id')
            ->where('o.del_time', 0)
            ->where('o.sub_type', Oa::sub_type_two)
            ->where('os.del_time', 0)
            ->where('o.menu_id', $menu_id)
            ->orderBy('os.sort')
            ->exists();
        if(! $bool){
            //其它
            $bool = Oa::from('oa as o')
                ->leftJoin('oa_sub as os', 'os.oa_id', 'o.id')
                ->select('os.sort', 'os.type', 'os.sub_id')
                ->where('o.del_time', 0)
                ->where('os.del_time', 0)
                ->where('o.channel', $this->user['depart_top'][0]['depart_id'])
                ->where('o.menu_id', $menu_id)
                ->orderBy('os.sort')
                ->exists();
        }

        return $bool;
    }

    //获取OA的id
    public function getOaId($menu_id){
        //特殊的审批 分社采购单
        $oa_id = Oa::where('menu_id',$menu_id)
            ->where('del_time', 0)
            ->where('sub_type',Oa::sub_type_two)
            ->value('id');
        if(empty($oa_id)) {
            //其它
            $oa_id = Oa::where('menu_id', $menu_id)
                ->where('del_time', 0)
                ->where('channel',$this->user['depart_top'][0]['depart_id'])
                ->value('id');
        }

        return $oa_id;
    }

    //获取oaOrder
    public function getOaOrder($menu_id, $order_no){
        $oa_id = Oa::where('menu_id',$menu_id)
            ->where('del_time', 0)
            ->where('sub_type',Oa::sub_type_two)
            ->exists();
        if($oa_id){
            //特殊的审批 分社采购单
            $detail = OaOrder::where('order_no', $order_no)
                ->orderBy('id', 'desc')
                ->where('menu_id', $menu_id)
                ->first();
        }else{
            //其它
            $detail = OaOrder::where('order_no', $order_no)
                ->where('channel',$this->user['depart_top'][0]['depart_id'])
                ->orderBy('id', 'desc')
                ->where('menu_id', $menu_id)
                ->first();
        }

        return $detail;
    }

    public function oaCommon($menu_id, $param, $sort = 1, $parent_id = 0,$user='')
    {
        //创建request副本对象 没有参数让检索出来的数据为空数组
        $result_one['id'] = $param['id'] ?? -1;
        $result_one['order_number'] = $param['order_number'] ?? "-1";
        $currentRequest = request();
        $request = $currentRequest->duplicate(
            $result_one,
            null,
            [],
            $currentRequest->cookies->all(),
            $currentRequest->files->all(),
            []
        );

        //获取具体业务单据数据
        $detail = $this->oaGetData($menu_id, $request,$user);

        //获取工作流ID
        $oa_id = $this->getOaId($menu_id);

        $parent_ids = [$parent_id, 0];
        if ($sort > 2) {
            $sorts = $sort - 1;
            $oa_sub_ids = OaSub::where('sort', '<', $sorts)
                ->where('del_time', 0)
                ->whereIn('parent_id', $parent_ids)
                ->pluck('id')
                ->toArray();
            $parent_ids = array_merge($parent_ids, $oa_sub_ids);
        }
        $list = OaSub::where('oa_id', $oa_id)
            ->where('del_time', 0)
            ->where('sort', $sort)
            ->whereIn('parent_id', $parent_ids)
            ->get()->toArray();
        if (empty($list)) return [[], '',$detail];
        $oa_sub_ids = [];
        $oa_sub_key = [];
        foreach ($list as $v) {
            $oa_sub_ids[] = $v['id'];
            $oa_sub_key[$v['id']] = $v;
            $rule_key_list[$v['id']] = [];
        }

        $rule_list = OaSubRule::whereIn('oa_sub_id', $oa_sub_ids)
            ->get()
            ->toArray();
        foreach ($rule_list as $v) {
            $rule_key_list[$v['oa_sub_id']][] = $v;
        }

        //规则开始判断
        $employee_ids = [];
        $oa_sub_id = 0;
        foreach ($rule_key_list as $k => $v) {
            $status = $this->formulaRule($v, $detail);
            if ($status) {
                if ($oa_sub_key[$k]['type'] == 2 && $oa_sub_key[$k]['sub_id'] > 0) {
                    $employee_ids = EmployeeTeamPermission::where('team_id', $oa_sub_key[$k]['sub_id'])->pluck('employee_id')->toArray();
                } elseif ($oa_sub_key[$k]['sub_id'] == -1) {
                    $employee_ids = OaSubEmployee::where('oa_sub_id', $oa_sub_key[$k]['id'])->pluck('employee_id')->toArray();
                } else {
                    $employee_ids[] = [$oa_sub_key[$k]['sub_id']];
                }
                $oa_sub_id = $k;
            }
        }

        return [$employee_ids, $oa_sub_id, $detail];
    }

    public function formulaRule($params, $detail)
    {
        $rule = '';
        if (empty($params)) return true;
        foreach ($params as $param) {
            if (!$param['key']) continue;
            if (!empty($param['right_formula'])) $rule .= ' ' . $param['right_formula'] . ' ';
            $rule .= '"' . $detail[$param['key']] . '"' . ' ' . $param['formula'] . ' ' . '"' . $param['value'] . '"';

        }
        if (empty($rule)) return true;
        if (eval("return  $rule;")) {
            return true;
        } else return false;
    }

    public function oaCheck($data, $user)
    {
        //校验
        list($status, $msg) = $this->oaCheckRule($data, $user);
        if(! $status) return [false, $msg];
        //参数
        $detail = $msg;
        $user_id = $user['id'];
        $id = $data['id'];
        $state = $data['state'];
        if ($state == 0) $state = 2;
        $remark = $data['remark'] ?? "";

        $oaOrder = OaOrder::where('id', $detail['oa_order_id'])->first();
        try {
            DB::beginTransaction();

            $sys_menu = SysMenu::where('id', $oaOrder->menu_id)->value('title') ?? "";
            $send_data = [];
            switch ($state) {
                //审核通过
                case 1:
                    $sort = $detail['sort'] + 1;
                    list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($oaOrder->menu_id, ['order_number' => $oaOrder->order_no], $sort, $detail['oa_sub_id'],$user);
                    if (empty($employee_ids)) {
                        $oaOrder->state = 2;
                        $oaOrder->save();

                        //直接完成审核
                        list($parent_status,$parent_msg) = $this->returnOa($oaOrder->order_no, 1, $oaOrder->opt_case);
                        if(! $parent_status){
                            DB::rollBack();
                            return [false, $parent_msg];
                        }

                        //审核通过 发送消息
                        $send_data[] = [
                            'employee_id' => $order_detail['crt_id'],
                            'type' => 2,
                            'state' => 0,
                            'menu_id' => $oaOrder->menu_id,
                            'order_number' => $order_detail['order_number'],
                            'tmp_data' => [
                                $order_detail['order_number'],
                                $sys_menu,
                                '通过',
                                Employee::where('id',$user_id)->value('emp_name'),
                                date('Y-m-d H:i:s'),
                            ],
                        ];
                        $this->sendWxOaCheckMessage($send_data);
                    } else {
                        $oaOrder->state = 1;
                        $oaOrder->save();
                        $oa_order_sub = new OaOrderSub();
                        $oa_order_sub->oa_order_id = $oaOrder->id;
                        $oa_order_sub->sort = $sort;
                        $oa_order_sub->remark = '';
                        $oa_order_sub->type = 1;
                        $oa_order_sub->oa_sub_id = $oa_sub_id;
                        $oa_order_sub->save();
                        $oa_order_sub_id = $oa_order_sub->id;

                        $insert = [];
                        $emp_map = Employee::whereIn('id',$employee_ids)->pluck('emp_name','id')->toArray();
                        foreach ($employee_ids as $employee_id) {
                            $emp_tmp = $emp_map[$employee_id] ?? "";
                            $insert[] = [
                                'oa_order_id' => $oaOrder->id,
                                'oa_order_sub_id' => $oa_order_sub_id,
                                'employee_id' => $employee_id,
                            ];
                            $send_data[] = [
                                'employee_id' => $employee_id,
                                'type' => 1,
                                'state' => 0,
                                'menu_id' => $oaOrder->menu_id,
                                'order_number' => $order_detail['order_number'],
                                'tmp_data' =>  [
                                    $order_detail['order_number'],
                                    $order_detail['crt_name'].'('.$sys_menu.')',
                                    $emp_tmp,
                                    date('Y-m-d H:i:s'),
                                ],
                            ];
                        }
                        OaOrderSubEmployee::insert($insert);

                        //发送消息
                        $this->sendWxOaCheckMessage($send_data);
                    }
                    break;

                //审核驳回
                case 2:
                    list($employee_ids, $oa_sub_id,$order_detail) = $this->oaCommon($oaOrder->menu_id, ['order_number' => $oaOrder->order_no], 1, $detail['oa_sub_id'],$user);
                    $tmp_data = [
                        $oaOrder['order_no'],
                        '拒绝',
                        $order_detail['crt_time'],
                        $remark ?? "(未填写原因)",
                    ];
                    if ($detail['sort'] == 1 || true) {
                        $oaOrder->state = 3;
                        $oaOrder->save();
                        list($parent_status,$parent_msg) = $this->returnOa($oaOrder->order_no, 2, $oaOrder->opt_case);
                        if(!$parent_status){
                            DB::rollBack();
                            return [false,$parent_msg];
                        }
                        $send_data[] = [
                            'employee_id' => $order_detail['crt_id'],
                            'type' => 3,
                            'state' => 2,
                            'menu_id' => $oaOrder->menu_id,
                            'order_number' => $oaOrder['order_no'],
                            'tmp_data' => $tmp_data,
                        ];
                    }else{
                        $id = OaOrderSub::where('sort', ($detail['sort'] - 1))->where('oa_order_id', $oaOrder->id)->value('id');
                        $employee_ids = OaOrderSubEmployee::where('oa_order_sub_id',$id)->pluck('employee_id')->toArray();
                        foreach ($employee_ids as $v){
                            $send_data[] = [
                                'employee_id' => $v,
                                'type' => 3,
                                'state' => 2,
                                'menu_id' => $oaOrder->menu_id,
                                'order_number' => $oaOrder['order_no'],
                                'tmp_data' => $tmp_data,
                            ];
                        }
                    }
                    OaOrderSub::where('sort', ($detail['sort'] - 1))->where('oa_order_id', $oaOrder->id)->update([
                        'state' => 0,
                        'remark' => $remark,
                    ]);

                    //发送消息
                    $this->sendWxOaCheckMessage($send_data);
                    break;
            }

            //更新状态
            OaOrderSub::where('id', $id)->update([
                'state' => $state,
                'remark' => $remark,
            ]);

            //抄送 以及 组织发送数据
            $send_data = $this->report($oaOrder, $detail['oa_sub_id'],$user_id,$sys_menu);

            //发送数据
            $this->sendWxOaCheckMessage($send_data);
            DB::commit();
            return [true, '操作成功！'];
        } catch (\Exception $e) {
            DB::rollBack();
            return [false, $e->getLine() . ':' . $e->getMessage()];
        }
    }

    private function oaCheckRule($data,$user){
        if(empty($data['id'])) return [false, "ID不能为空"];
        $detail = OaOrderSub::from('oa_order_sub as s')
            ->leftJoin('oa_order_sub_employee as e', 'e.oa_order_sub_id', 's.id')
            ->where('e.employee_id', $user['id'])
            ->where('s.id', $data['id'])
            ->where('s.state', 0)
            ->select('s.oa_order_id', 'sort', 'oa_sub_id', 's.id')
            ->first();
        if(empty($detail)) return [false, '无审核权限'];

        return [true, $detail->toArray()];
    }

    //发送公众号消息
    public function sendWxOaCheckMessage($send_data){
        if(empty($send_data)) return ;
        $config = config('morequery');
        $path = $config['detail_message'] ?? [];

        foreach ($send_data as $value) {
            //小程序详情页路径
            $tmp_path = $path[$value['menu_id']] ?? "";
            if(! empty($tmp_path)) $tmp_path .= $value['order_number'];
            $openid = $value['openid'] ?? "";
            $menu_id = $this->getSubstringBeforePipe($value['menu_id']);

            //发送
            $this->sendWxMsg($value['employee_id'],$value['type'],$value['state'],$menu_id,$value['tmp_data'],$tmp_path,$openid);
        }
    }

    function getSubstringBeforePipe($str) {
        // 检查字符串中是否存在竖线 '|'
        $pos = strpos($str, '|');

        // 如果存在竖线，则返回竖线之前的部分
        if ($pos !== false) {
            return substr($str, 0, $pos);
        } else {
            // 如果不存在竖线，则返回原始字符串
            return $str;
        }
    }

    public function report($oaOrder, $oa_sub_id,$user_id,$sys_menu)
    {
        $return = [];
        $oa_sub_report_employee = OaSubReportEmployee::where('oa_sub_id', $oa_sub_id)->select('*')->get()->toArray();
        if (! empty($oa_sub_report_employee)) {
            $list = [];
            $report = new OaReportOrder();
            $report->menu_id = $oaOrder->menu_id;
            $report->order_no = $oaOrder->order_no;
            $report->opt_case = $oaOrder->opt_case;
            $report->user_id = $user_id;
            $report->channel = $this->user['depart_top'][0]['depart_id'];
            $report->save();

            //公共发送参数
            $tmp_data = [
                $oaOrder->order_no,
                $sys_menu,
                '审核通过',
                Employee::where('id',$user_id)->value('emp_name'),
                date('Y-m-d H:i:s'),
            ];
            foreach ($oa_sub_report_employee as $v) {
                $list[] = [
                    'employee_id' => $v['employee_id'],
                    'oa_report_order_id' => $report->id,
                ];
                $return[] = [
                    'employee_id' => $v['employee_id'],
                    'type' => 2,
                    'state' => 0,
                    'menu_id' => $oaOrder->menu_id,
                    'order_number' => $oaOrder->order_no,
                    'tmp_data' => $tmp_data,
                ];
//                $this->sendWxMsg($v['employee_id'],2,0,$oaOrder->menu_id,$tmp_data);
            }
            OaReportOrderEmployee::insert($list);
        }

        return $return;
    }

    public function returnOa($order_no, $type, $opt_case)
    {
        $service = new CheckService();
        list($bool, $msg) = $service->createRecordAndInventory([
            'order_number' => $order_no,
            'type' => $type,
            'opt_case' => $opt_case,
            'user_data' => $this->user,
        ]);
        return [$bool, $msg];
    }

    public function oaGetData($menu_id, $request,$user='')
    {
        $api = SysMenu::where('id', $menu_id)->value('api');
        $param =  SysMenu::where('id', $menu_id)->value('api_params');
        $param =  json_decode($param,true);
//        $param['state'] = null;
        $param['menu_id'] = $menu_id;
//        $param['id'] = null;
        $request->merge($param);

        $path = $this->getMenu();
        $control = '\\' . $path[$api]["controller"];
        $act = $path[$api]["act"];
        $new = new $control();
        $detail = $new->$act($request);
//        if(!isset($detail['data']['data'][0])) $detail['data']['data'][0] = $detail['data'];
        return $detail['data']['data'][0];
    }

    public function getMenu()
    {
        $app = App();
        $routes = $app->routes->getRoutes();
        $path = [];
        foreach ($routes as $k => $value) {
            if (!isset($value->action['controller'])) continue;
            $act = explode('@', $value->action['controller']);
            if (!isset($act[1])) continue;
            $path[$value->uri]['act'] = $act[1];
            $path[$value->uri]['controller'] = $act[0];
        }

        return $path;
    }

    public function oaOrderList($data)
    {
        $order_no = $data['order_no'];
        $menu_id = $data['menu_id'];
        $oa = OaOrder::where('order_no', $order_no)->first();
        if (empty($oa)) return [false, '审核不存在'];
        $list = OaOrderSub::where('oa_order_id', $oa->id)->orderBy('sort', 'asc')->select('*')->get()->toArray();
        return [true, $list];
    }

    public function oaOrderState($data, $user)
    {
        $user_id = $user['id'];
        $order_no = $data['order_no'];
        $menu_id = $data['menu_id'];

        if($menu_id == PurchaseOrderSpecial::menu_id){
            //虚拟采购单
            list($status, $msg) = $this->oaOrderStatePurchase($data,$user);
            return [$status, $msg];
        }else{
            $detail = $this->getOaOrder($menu_id, $order_no);

            if (empty($detail))  return [true, ['state' => 0]];
            if ($detail->state == 2) return [true, ['state' => 0]];
            $oa_detail = OaOrderSubEmployee::where('employee_id', $user_id)
                ->where('oa_order_id', $detail->id)
                ->pluck('oa_order_sub_id')
                ->toArray();
            if (empty($oa_detail)) return [true, ['state' => 0]];
            $state = OaOrderSub::whereIn('id', $oa_detail)
                ->where('state', '<>', 2)
                ->orderBy('sort', 'desc')
                ->first();
            if (in_array($state->state, [0, 2])) return [true, ['state' => 1, 'id' => $state->id]];

            return [true, ['state' => 0]];
        }
    }

    public function oaOrderStatePurchase($data,$user){
        $detail = OaOrder::where('order_no', $data['order_no'])
            ->orderBy('id', 'desc')
            ->where('menu_id', $data['menu_id'])
            ->first();
        if (empty($detail))  return [true, ['state' => 0]];
        if ($detail->state == 2) return [true, ['state' => 0]];
        $oa_detail = OaOrderSubEmployee::where('employee_id', $user['id'])->where('oa_order_id', $detail->id)->pluck('oa_order_sub_id')->toArray();
        if (empty($oa_detail)) return [true, ['state' => 0]];
        $state = OaOrderSub::whereIn('id', $oa_detail)->where('state', '<>', 2)->orderBy('sort', 'desc')->first();
        if (in_array($state->state, [0, 2])) return [true, ['state' => 1, 'id' => $state->id]];

        return [true, ['state' => 0]];
    }

    public function checkAllOver($data)
    {
        $order_no = $data['order_number'];
        $menu_id = $data['menu_id'];
        $op_case = $data['opt_case'];
//        $oaOrder = OaOrder::where('order_no',$order_no)->first();
//        $id = OaOrderSub::where('oa_order_id',$oaOrder->id)->orderBy('id','desc')->value('id');
//        OaOrderSub::where('id',$id)->update([
//            'state' => 1
//        ]);
//        $oaOrder->state = 1;
//        $oaOrder->save();
        list($parent_status,$parent_msg) = $this->returnOa($order_no, 3, $op_case);
        if(!$parent_status) return [false,$parent_msg];

        return [true, ''];
    }

    public function oaCheckMove($data, $user_id)
    {
        $id = $data['id'];
        $employee_id = $data['employee_id'];
        if (empty($employee_id)) return [false, '用户不存在'];
        $oaOrderSub = OaOrderSub::where('id', $id)->first();
        OaOrderSubEmployee::where('oa_order_sub_id', $oaOrderSub->id)->delete();
        $add = [
            'oa_order_id' => $oaOrderSub->oa_order_id,
            'oa_order_sub_id' => $oaOrderSub->id,
            'employee_id' => $employee_id
        ];
        $oaOrder = OaOrder::where('id', $oaOrderSub->oa_order_id)->first();
        OaOrderSubEmployee::insert($add);
        Construction::where('order_number', $oaOrder->order_no)->update([
            'is_transfer' => 1
        ]);
//        $this->returnOa($order_no,3,$op_case);
        return [true, '转签成功'];

    }

    public function oaSubUserDetail($data)
    {
        $order_no = $data['order_no'];
        $first = OaOrder::where('order_no', $order_no)->first();
        if (empty($first)) return [true, []];
        $oa_order_id = $first->id;
        $oa_order_sub_id = OaOrderSub::where('oa_order_id', $oa_order_id)->orderBy('sort', 'desc')->value('id');
        $employee_list = Employee::pluck('emp_name', 'id')->toArray();
        $oa_order_sub_employee_ids = OaOrderSubEmployee::where('oa_order_sub_id', $oa_order_sub_id)->pluck('employee_id')->toArray();
        $list = [];
        foreach ($oa_order_sub_employee_ids as $v) {
            $list[] = $employee_list[$v];
        }
        return [true, $list];

    }

    public function oaGetTeamDetail($data)
    {
        $order_no = $data['order_no'];
        $oa_order_id = OaOrder::where('order_no', $order_no)->pluck('id')->toArray();
        if (empty($oa_order_id)) return [true, []];
//        $oa_order_id = $first->id;
        $list = OaOrderSub::wherein('oa_order_id', $oa_order_id)->select('*')->orderBy('id', 'asc')->get()->toArray();

        $subEmployeeList = OaOrderSubEmployee::wherein('oa_order_id', $oa_order_id)->select('*')->get()->toArray();
        $emp_id_key_list = [];
        $employee_key_list = Employee::pluck('emp_name', 'id')->toArray();
        foreach ($subEmployeeList as $v) {
            $emp_id_key_list[$v['oa_order_sub_id']][] = [
                'id' => $v['employee_id'],
                'emp_name' => $employee_key_list[$v['employee_id']] ?? '',
            ];
        }
        $return = [];
        foreach ($list as $v) {
            $return[] = [
                'sort' => $v['sort'],
                'team' => $emp_id_key_list[$v['id']],
                'remark' => $v['remark'] ?? '',
                'state' => $v['state'],
            ];
        }
//        $this->returnOa($order_no,3,$op_case);
        return [true, $return];

    }

    public function oaSubRemark($data)
    {
        $order_no = $data['order_no'];
        $first = OaOrder::where('del_time', 0)->where('channel',$this->user['depart_top'][0]['depart_id'])->where('order_no', $order_no)->orderBy('id', 'desc')->first();
        if (empty($first)) return [true, []];
        $oa_order_id = $first->id;
        $remark = OaOrderSub::where('oa_order_id', $oa_order_id)->orderBy('sort', 'desc')->value('remark');

//        $this->returnOa($order_no,3,$op_case);
        return [true, $remark];

    }

    public function reportList($data, $user)
    {
        $id = $user['id'];
        $list = OaReportOrder::from('oa_report_order_employee as e')
            ->leftJoin('oa_report_order as o','o.id','e.oa_report_order_id')
            ->leftJoin('oa_order as oo','oo.order_no','o.order_no')
            ->leftJoin('employee as ee','ee.id','o.user_id')
            ->where('e.employee_id',$id)
            ->where('o.channel',$this->user['depart_top'][0]['depart_id'])
            ->groupBy('oo.id')->orderBy('oo.id','desc')
            ->select('oo.*','o.id as sid','o.check','o.user_id','ee.emp_name');
        $list = $this->limit($list,'',$data);

        return [true,$list];

    }

    public function reportCheck($data){
        $id = $data['sid'];
        OaReportOrder::wherein('id',$id)->where('channel',$this->user['depart_top'][0]['depart_id'])->update([
            'check' => 1
        ]);
        return [true,''];
    }

    public function reportCount($data,$user){
        $id = $user['id'];
        $list = OaReportOrder::from('oa_report_order_employee as e')
            ->leftJoin('oa_report_order as o','o.id','e.oa_report_order_id')
            ->leftJoin('oa_order as oo','oo.order_no','o.order_no')
            ->where('oo.channel',$this->user['depart_top'][0]['depart_id'])
            ->where('e.employee_id',$id)
            ->where('o.check',0)
            ->groupBy('oo.id')->orderBy('oo.id','desc')
            ->select('oo.*','o.id as sid','o.check')->get()->toArray();
        return [true,['total'=>count($list),'list'=>$list]];
    }

    public function reportTime($data){
        return [true,['time'=>'20小时10分钟']];
    }

    public function sendWxMsg($user_id,$type,$state,$menu_id,$order_data,$pagepath = "", $openid = ""){
        $service = new WxSendMessageService();
        file_put_contents('msg_result.txt',date('Y-m-d H:i:s') . "入参：" . json_encode([$user_id,$type,$state,$menu_id,$order_data,$pagepath]). PHP_EOL,8);
        list($status, $msg) = $service->wx_sendMsg($user_id,$type,$state,$menu_id,$order_data,$pagepath,$openid);
        file_put_contents('msg_result.txt',date('Y-m-d H:i:s') . "结果：" .  $msg . PHP_EOL,8);
    }

    public function getConstructionOaOrderState($order_no, $user, $menu_id)
    {
        $user_id = $user['id'];
        $return = [];
        foreach ($order_no as $value){
            $return[$value] = ['oa_state' => 0];
        }
        $detail = OaOrder::whereIn('order_no', $order_no)
            ->where('channel',$user['depart_top'][0]['depart_id'])
            ->where('menu_id', $menu_id)
            ->where('del_time', 0)
            ->orderBy('id', 'desc')
            ->get()->toArray();
        if (empty($detail)) $return;
        $final_detail = $oa_order = $oa_order2 = $map = [];
        foreach ($detail as $value){
            if(! isset($final_detail[$value['order_no']])){
                $map[$value['id']] = $value['order_no'];
                if($value['state'] == 2) {
                    $oa_order[] = $value['id'];
                }else{
                    $oa_order2[] = $value['id'];
                }
                $final_detail[$value['order_no']] = $value['id'];
            }
        }
        if (count($oa_order) == count($final_detail)) return $return;

        $oa_detail = OaOrderSubEmployee::where('employee_id', $user_id)
            ->whereIn('oa_order_id', $oa_order2)
            ->pluck('oa_order_sub_id','oa_order_id')
            ->toArray();
        if(empty($oa_detail)) return $return;

        $oa_detail_map = array_flip($oa_detail);
        $oa_detail_value = array_values($oa_detail);
        $state = OaOrderSub::whereIn('id', $oa_detail_value)
            ->where('state', '<>', 2)
            ->orderBy('sort', 'desc')
            ->get()->toArray();
        foreach ($state as $value){
            $oa_order_id_tmp = $oa_detail_map[$value['id']];
            $order_no_tmp = $map[$oa_order_id_tmp];
            if (in_array($value['state'], [0, 2])) {
                $return[$order_no_tmp] = ['oa_state' => 1, 'oa_id' => $value['id']];
            }else{
                $return[$order_no_tmp] = ['oa_state' => 0];
            }
        }

        return $return;
    }

    //获取订单审核人员名称
    public function getOaTeamDetailList($order_no)
    {
        if(empty($order_no)) return [];
        $orderNoGroups = OaOrder::whereIn('order_no', $order_no)
            ->get()
            ->groupBy('order_no');
        $maxIds = $orderNoGroups->map(function ($group) {
            return $group->max('id');
        });
        $map = $maxIds->toArray();
        if(empty($map)) return [];
        $map2 = array_flip($map);

        $oa_order_id = array_values($map);
        $list = OaOrderSub::whereIn('oa_order_id', $oa_order_id)
            ->whereIn('state',[0,2])
            ->select('id','state','oa_order_id','remark')
            ->orderBy('id', 'desc')
            ->get()->toArray();
        $subEmployeeList = OaOrderSubEmployee::whereIn('oa_order_id', $oa_order_id)
            ->select('*')
            ->get()->toArray();
        //oa_order_sub 每条数据对应的人
        $emp_id_key_list = [];
        $employee_key_list = Employee::whereIn('id',array_unique(array_column($subEmployeeList,'employee_id')))
            ->pluck('emp_name', 'id')
            ->toArray();
        foreach ($subEmployeeList as $v) {
            $emp_id_key_list[$v['oa_order_sub_id']][] = [
                'id' => $v['employee_id'],
                'emp_name' => $employee_key_list[$v['employee_id']] ?? '',
            ];
        }

        $return = [];
        foreach ($list as $v) {
            $order_no_tmp = $map2[$v['oa_order_id']] ?? "";
            //不存在单号或者已存在单号返回数据
            if(empty($order_no_tmp) || isset($return[$order_no_tmp])) continue;
            //返回数据
            if($v['state'] == 0){
                //待审核（人的信息）
                $emp_tmp = $emp_id_key_list[$v['id']] ?? [];
                $emp_tmp_str = implode('|',array_column($emp_tmp,'emp_name'));
                $return[$order_no_tmp] = $emp_tmp_str;
            }else{
                //驳回（原因）
                $return[$order_no_tmp] = $v['remark'] ?? "(未填写原因)";
            }
        }

        return $return;
    }
}