<?php

namespace app\mobile\controller\risk;

use app\admin\controller\Curd;
use app\admin\service\AdminService;
use support\spark\model\risk\Management;
use support\spark\model\risk\ManagementItem;
use support\spark\model\risk\Library;
use support\spark\model\risk\RiskAllot;#废弃
use support\spark\model\bomb\Patroltasks;
use support\spark\model\system\AdminOrg;
use support\spark\model\basicdata\Usedpart;
use support\Request;
use support\spark\model\safebasic\Engineering;

class AllotController extends Curd
{
  private $Patroltasks;
  public function __construct()
  {
    parent::__construct();
    $this->Patroltasks = new Patroltasks();
  }

  public function index()
  {
    $param = request()->get();
    $limit = $param['limit'] ?? 10;
    $where = [];
    if (!isset($param['user_id']) || empty($param['user_id'])) {
      return sparkSuccess(dataReturn(-1, '缺少参数user_id'));
    }
    $where[] = ['report_user_id', '=', $param['user_id']];
    $list = $this->Patroltasks
      ->select('start_date')
      ->where($where)
      ->orderBy('start_date', 'desc')
      ->distinct() // 去重
      ->groupBy('start_date')
      ->paginate($limit);
    foreach ($list as $key => $value) {
      // dump($list[$key]['children'], $value['date']);
      $list[$key]['children'] = $this->Patroltasks
        ->with([
          'Management' => function ($query) {
            $query->select('id', 'org_name as risk_org_name', 'name as risk_title'); // 选择要查询的字段
          }
        ])
        ->where($where)
        ->where('start_date', '=', $value['start_date'])
        ->get();
    }
    return sparkSuccess(dataReturn(0, 'success', $list));
  }
  public function getDayTaskPatrol()
  {
    $param = request()->get();
    $where = [];
    if (!isset($param['user_id']) || empty($param['user_id'])) {
      return sparkSuccess(dataReturn(-1, '缺少参数user_id'));
    }
    $where[] = ['report_user_id', '=', $param['user_id']];
    $where[] = ['start_date', '=', date('Y-m-d')];
    $list = $this->Patroltasks
      ->with([
        'Management' => function ($query) {
          $query->select('id', 'org_name as risk_org_name', 'name as risk_title'); // 选择要查询的字段
        }
      ])
      ->where($where)
      ->get();
    return sparkSuccess(dataReturn(0, '查询成功', $list));
  }
  /** 查询工程类型指定值 */
  public function getOnename($id)
  {
    $where = [['id', '=', $id]];
    $res = (new Engineering())->findOne($where, 'name');
    return $res['data']['name'];
  }
}