nizongfeng
/
ZZCX_yii
1
0
Forka 0
Codice Problemi 0 Pull Requests 0 Rilasci 0 Wiki Attività
Non puoi selezionare più di 25 argomenti Gli argomenti devono iniziare con una lettera o un numero, possono includere trattini ('-') e possono essere lunghi fino a 35 caratteri.
3 Commit
1 Ramo (Branch)
96 MiB
 
 
 
 
 
 
Ramo (Branch): master
Rami (Branch) Tag
${ item.name }
Crea branch ${ searchTerm }
da 'master'
${ noResults }
ZZCX_yii/backend/modules/api/models/BusOrder.php

630 righe
25 KiB
Originale Permalink Blame Cronologia 

  1. <?php

  2. 

  3. namespace backend\modules\api\models;

  4. 

  5. use function GuzzleHttp\default_ca_bundle;

  6. use yii\db\ActiveRecord;

  7. use Yii;

  8. 

  9. /**

  10.  * This is the model class for table "bus_order".

  11.  *

  12.  * @property integer $id

  13.  * @property integer $bus_number

  14.  * @property integer $create_user_id

  15.  * @property string $create_time

  16.  * @property integer $update_user_id

  17.  * @property string $update_time

  18.  * @property integer $cancel_flag

  19.  * @property integer $use_bus_org_id

  20.  * @property string $run_date

  21.  * @property integer $run_bus_id

  22.  * @property integer $run_id

  23.  * @property integer $line_id

  24.  * @property string $start_time

  25.  * @property integer $bus_order_id

  26.  * @property integer $bus_type_res_id

  27.  * @property integer $seat_count

  28.  * @property integer $saled_count

  29.  * @property integer $itinerary_id

  30.  * @property string $itinerary_name

  31.  * @property integer $line_type

  32.  * @property integer $day_num

  33.  * @property integer $bus_cost_type

  34.  * @property string $bus_cost

  35.  * @property string $remark

  36.  * @property string $send_msg

  37.  * @property integer $send_type

  38.  * @property string $send_cost

  39.  * @property integer $send_bus_res_id

  40.  * @property integer $send_bus_driver_res_id

  41.  * @property integer $send_status

  42.  * @property integer $run_status

  43.  * @property integer $finance_status

  44.  * @property integer $end_status

  45.  * @property integer $line_status

  46.  * @property integer $safe

  47.  *

  48.  * @property BaseBus $sendBusRes

  49.  * @property BaseDriver $sendBusDriverRes

  50.  */

  51. class BusOrder extends ActiveRecord

  52. {

  53.     /**

  54.      * @inheritdoc

  55.      */

  56.     public static function tableName()

  57.     {

  58.         return 'bus_order';

  59.     }

  60. 

  61.     /**

  62.      * @inheritdoc

  63.      */

  64.     public function rules()

  65.     {

  66.         return [

  67.             [['bus_number', 'create_user_id', 'update_user_id', 'run_date', 'seat_count', 'saled_count', 'send_type'], 'required'],

  68.             [['bus_number', 'create_user_id', 'update_user_id', 'cancel_flag', 'use_bus_org_id', 'run_bus_id', 'run_id', 'line_id', 'bus_order_id', 'bus_type_res_id', 'seat_count', 'saled_count', 'itinerary_id', 'line_type', 'day_num', 'bus_cost_type', 'send_type', 'send_bus_res_id', 'send_bus_driver_res_id', 'send_status', 'run_status', 'finance_status', 'end_status', 'line_status', 'safe'], 'integer'],

  69.             [['update_time'], 'safe'],

  70.             [['bus_cost', 'send_cost'], 'number'],

  71.             [['create_time'], 'string', 'max' => 20],

  72.             [['run_date'], 'string', 'max' => 10],

  73.             [['start_time'], 'string', 'max' => 128],

  74.             [['itinerary_name'], 'string', 'max' => 50],

  75.             [['remark'], 'string', 'max' => 100],

  76.             [['send_msg'], 'string', 'max' => 1024],

  77.             [['send_bus_res_id'], 'exist', 'skipOnError' => true, 'targetClass' => BaseBus::className(), 'targetAttribute' => ['send_bus_res_id' => 'BUS_ID']],

  78.             [['send_bus_driver_res_id'], 'exist', 'skipOnError' => true, 'targetClass' => BaseDriver::className(), 'targetAttribute' => ['send_bus_driver_res_id' => 'DRIVER_ID']],

  79.         ];

  80.     }

  81. 

  82.     /**

  83.      * @inheritdoc

  84.      */

  85.     public function attributeLabels()

  86.     {

  87.         return [

  88.             'id' => '主键，自增',

  89.             'bus_number' => '出车单号',

  90.             'create_user_id' => 'Create User ID',

  91.             'create_time' => 'Create Time',

  92.             'update_user_id' => 'Update User ID',

  93.             'update_time' => '记录最后更新时间',

  94.             'cancel_flag' => 'Cancel Flag',

  95.             'use_bus_org_id' => '用车单位',

  96.             'run_date' => '用车日期',

  97.             'run_bus_id' => '车次ID，对应run_bus中的主键ID,用于派车时更新巴士系统车次库存',

  98.             'run_id' => '班次ID，供同步已有班次使用',

  99.             'line_id' => '线路ID，供同步数据使用',

  100.             'start_time' => 'Start Time',

  101.             'bus_order_id' => '车次号，供同步已有车次使用',

  102.             'bus_type_res_id' => '用车类型',

  103.             'seat_count' => '车座数',

  104.             'saled_count' => '乘客人数',

  105.             'itinerary_id' => '行程ID',

  106.             'itinerary_name' => '行程名称',

  107.             'line_type' => '行程类型，市内或省际 1为省际，2为市内',

  108.             'day_num' => '行程包含的行程天数',

  109.             'bus_cost_type' => '车辆计价方式 477为包车计价，478为人数计价',

  110.             'bus_cost' => '车辆计价金额',

  111.             'remark' => '用车备注',

  112.             'send_msg' => '调度原因等调度时候的信息',

  113.             'send_type' => '内部派车还是外部派车 0：内部 1：外部',

  114.             'send_cost' => '调派车辆时的价格',

  115.             'send_bus_res_id' => '调派车辆res_id',

  116.             'send_bus_driver_res_id' => '调派司机res_id',

  117.             'send_status' => '调度状态',

  118.             'run_status' => '出车状态',

  119.             'finance_status' => '报账状态',

  120.             'end_status' => '结算状态',

  121.             'line_status' => '线路牌  0为未亮起 1为亮起',

  122.             'safe' => '安检  0为未安检 1为已安检',

  123.         ];

  124.     }

  125. 

  126.     /**

  127.      * @return \yii\db\ActiveQuery

  128.      */

  129.     public function getSendBusRes()

  130.     {

  131.         return $this->hasOne(BaseBus::className(), ['BUS_ID' => 'send_bus_res_id']);

  132.     }

  133. 

  134.     /**

  135.      * @return \yii\db\ActiveQuery

  136.      */

  137.     public function getSendBusDriverRes()

  138.     {

  139.         return $this->hasOne(BaseDriver::className(), ['DRIVER_ID' => 'send_bus_driver_res_id']);

  140.     }

  141. 

  142.     /**

  143.      * Function Description:获取任务列表

  144.      * Function Name: getDriverTask

  145.      * @param int $driver_id 司机id

  146.      * @param string $run_date 日期

  147.      *

  148.      * @return array|\yii\db\ActiveRecord[]

  149.      *

  150.      * @author 张帅

  151.      */

  152.     public function getDriverTask($driver_id, $run_date)

  153.     {

  154.         #region 1.获取列表详情

  155.         $task_list = self::find()

  156.             ->select([

  157.                 'bo.contacts',//联系人姓名

  158.                 'bo.tels',//联系人号码

  159.                 'bo.run_bus_id',//车次id

  160.                 'bo.bus_number',//出车单号

  161.                 'bo.run_id',//班次id

  162.                 'bo.line_id',//线路id

  163.                 'run_date',//用车日期

  164.                 'run_status_id' => 'bo.run_status',

  165.                 'run_status' => DictType::find()->select('type_name')->where('id = bo.run_status')->limit(1),//班次状态

  166.                 'finance_status_id' => 'bo.finance_status',

  167.                 'finance_status' => DictType::find()->select('type_name')->where('id = bo.finance_status')->limit(1),//报账状态

  168.                 'bo.bus_order_id',//车次号

  169.                 'saled_count_bo'=>'bo.saled_count',//bus_order已售座位数

  170.                 'saled_count_rb'=>'rb.saled_count',//run_bus已售座位数

  171.                 'send_bus_no' => BaseBus::find()->select('bus_no')->where('bus_id = bo.send_bus_res_id'),//车牌号

  172.                 'itinerary_id',//行程id

  173.                 'start_time' => "str_to_date(start_time,'%H:%i')",

  174.             ])

  175.             ->from(self::tableName() . ' as bo')

  176.             ->leftJoin('run_bus as rb', 'bo.run_bus_id = rb.id')

  177.             ->where([

  178.                 'and',

  179.                 ['=', 'bo.cancel_flag', 0],

  180.                 ['=', 'bo.send_bus_driver_res_id', $driver_id],

  181.                 ['=', 'bo.run_date', $run_date],

  182.             ])

  183.             ->orderBy(['start_time' => SORT_ASC])

  184.             ->asArray()->all();

  185.         #endregion

  186. 

  187.         #region 2.获取上下站点及时间

  188.         //行程id数组

  189.         $itinerary_id = [];

  190.         foreach ($task_list as $key => $vel) {

  191.             $itinerary_id[] = $vel['itinerary_id'];

  192.             if($vel['run_id'] != 0){    //run_id不为0时从run_bus里面取

  193.                 $task_list[$key]['saled_count'] = $vel['saled_count_rb'];

  194.             }else{

  195.                 $task_list[$key]['saled_count'] = $vel['saled_count_bo'];

  196.             }

  197.         }

  198.         //行程列表

  199.         $itinerary_list = BusItinerary::find()

  200.             ->select('itinerary_id,station_name,day_seq_id,start_time')

  201.             ->where([

  202.                 'and',

  203.                 ['in', 'itinerary_id', $itinerary_id],

  204.                 ['=', 'cancel_flag', 0],

  205.             ])

  206.             ->orderBy(['itinerary_id' => SORT_ASC, 'station_seq_id' => SORT_ASC])

  207.             ->asArray()->all();

  208.         //分车次行程

  209.         $itinerary_bus_list = [];

  210.         foreach ($itinerary_list as $key => $vel) {

  211.             if (!isset($itinerary_bus_list[$vel['itinerary_id']])) {

  212.                 $itinerary_bus_list[$vel['itinerary_id']]['start_station'] = $vel['station_name'];

  213.                 $itinerary_bus_list[$vel['itinerary_id']]['run_time'] = $vel['start_time'];

  214.             } else {

  215.                 $itinerary_bus_list[$vel['itinerary_id']]['end_station'] = $vel['station_name'];

  216.                 if( $vel["day_seq_id"] == 1 ) {

  217.                     $itinerary_bus_list[$vel['itinerary_id']]['arrive_time'] = $vel['start_time'];

  218.                 } else {

  219.                     $start_date_disp = "";

  220.                     switch( $vel["day_seq_id"] ) {

  221.                         case 2:

  222.                             $start_date_disp = "次日";

  223.                             break;

  224.                         case 3:

  225.                             $start_date_disp = "第三日";

  226.                             break;

  227.                         case 4:

  228.                             $start_date_disp = "第四日";

  229.                             break;

  230.                         default:

  231.                             $start_date_disp = "第{$vel["day_seq_id"]}日";

  232.                             break;

  233.                     }

  234.                     $itinerary_bus_list[$vel['itinerary_id']]['arrive_time'] = $start_date_disp." ".$vel['start_time'];

  235.                 }

  236.             }

  237.         }

  238.         #endregion

  239. 

  240.         #region 3.整理任务列表

  241.         foreach ($task_list as $key => $vel) {

  242.             if( is_array($vel) && isset($itinerary_bus_list[$vel['itinerary_id']]) ) {

  243.                 $task_list[$key] = array_merge($vel, $itinerary_bus_list[$vel['itinerary_id']]);

  244.             } else {

  245.                 $task_list[$key]['start_station'] = '未设置';

  246.                 $task_list[$key]['run_time'] = '未设置';

  247.                 $task_list[$key]['end_station'] = '未设置';

  248.                 $task_list[$key]['arrive_time'] = '未设置';

  249.             }

  250.         }

  251.         #endregion

  252. 

  253.         return $task_list;

  254.     }

  255. 

  256.     /**

  257.      * Function Description:获取车次详情

  258.      * Function Name: getBusInfo

  259.      * @param int $bus_number 出车单号

  260.      *

  261.      * @return array|bool|null|ActiveRecord

  262.      *

  263.      * @author 张帅

  264.      */

  265.     public function getBusInfo($bus_number)

  266.     {

  267.         $result = self::find()

  268.             ->select([

  269.                 'bo.run_id',//班次id

  270.                 'bo.bus_order_id',//车次id

  271.                 'bo.bus_number',//出车单号

  272.                 'bus_no' => BaseBus::find()->select('bus_no')->where('bus_id = bo.send_bus_res_id'),//车牌号

  273.                 'bo.send_bus_res_id',

  274.                 'bo.run_date',

  275.                 'bo.send_bus_driver_res_id',

  276.                 'bo.itinerary_id',

  277.                 'order_seat_count' => 'bo.seat_count',//总座位数

  278.                 'order_saled_count' => 'bo.saled_count',//售出的座位数

  279.                 'bus_seat_count' => 'rb.seat_count',//总座位数

  280.                 'bus_saled_count' => 'rb.saled_count',//售出的座位数

  281.                 'run_status_id' => 'bo.run_status',

  282.                 'bus_status' => DictType::find()->select('type_name')->where('id = bo.run_status')->limit(1),//班次状态

  283.                 'finance_status_id' => 'bo.finance_status',

  284.                 'finance_status' => DictType::find()->select('type_name')->where('id = bo.finance_status')->limit(1),//报账状态

  285.             ])

  286.             ->from(self::tableName() . ' as bo')

  287.             ->leftJoin('run_bus as rb', 'bo.run_bus_id = rb.id')

  288.             ->where([

  289.                 'and',

  290.                 ['=', 'bo.cancel_flag', 0],

  291.                 ['=', 'bo.bus_number', $bus_number],

  292.             ])

  293.             ->asArray()->one();

  294. 

  295.         if (count($result) == 0) {

  296.             return false;

  297.         }

  298. 

  299.         //找到司机当天所有的可以开启的行程，并且正序排序

  300.         $is_line_now = self::find()

  301.             ->select(['bus_number','start_time'])

  302.             ->where(['and',['=','cancel_flag',0],['=','run_date',$result['run_date']],['=','send_bus_driver_res_id',$result['send_bus_driver_res_id']],['or',['=','run_status',435],['=','run_status',436]]])

  303.             ->orderBy(['start_time'=>SORT_ASC])

  304.             ->asArray()->all();

  305.         if($is_line_now){     //如果当天有结果并且当前的就是司机进入的，就返回true

  306.             if($is_line_now[0]['bus_number'] == $bus_number){

  307.                 $result['is_right'] = true;

  308.             }else{

  309.                 $result['is_right'] = false;

  310.             }

  311.             $result['right_task_time'] = $is_line_now[0]['start_time'];

  312.         }

  313.         if (empty($result['bus_seat_count']) && empty($result['bus_saled_count'])) {

  314.             $result['seat_count'] = $result['order_seat_count'];

  315.             $result['saled_count'] = $result['order_saled_count'];

  316.         } else {

  317.             $result['seat_count'] = $result['bus_seat_count'];

  318.             $result['saled_count'] = $result['bus_saled_count'];

  319.         }

  320. 

  321.         return $result;

  322.     }

  323. 

  324.     /**

  325.      * Function Description:获取出车详情

  326.      * Function Name: getRunBusStationOrderInfo

  327.      * @param $bus_info

  328.      * @param $station_info

  329.      * @param $order_info

  330.      *

  331.      * @return mixed

  332.      *

  333.      * @author 张帅

  334.      */

  335.     public function getRunBusStationOrderInfo($bus_info, $station_info, $order_info)

  336.     {

  337.         #region 1.获取车次信息

  338.         $start = reset($station_info);

  339.         $bus_info['start_station'] = $start['station_name'];

  340.         $bus_info['start_time'] = $start['start_time'];

  341. 

  342.         $end = end($station_info);

  343.         $bus_info['end_station'] = $end['station_name'];

  344.         $bus_info['end_time'] = $end['start_time'];

  345.         #endregion

  346. 

  347.         #region 2.获取每站信息

  348.         $i = 0;

  349.         $run_station_info = [];//站点数据

  350.         foreach ($station_info as $key => $vel) {

  351.             $vel['people_up_all_num'] = 0;//应上车总人数

  352.             $vel['people_down_all_num'] = 0;//应下车总人数

  353.             $vel['has_up_num'] = 0;//已上人数

  354.             $vel['not_up_num'] = 0;//未上人数

  355.             $vel['passengers'] = [];//上车乘客信息

  356.             $vel['down_passengers'] = [];//下车乘客信息

  357.             if ($vel['station_id'] == '') {

  358.                 $run_station_info[$i] = $vel;

  359.                 $i++;

  360.             } else {

  361.                 $run_station_info[$vel['station_id']] = $vel;

  362.             }

  363.             unset($run_station_info[$vel['station_id']]['run_id']);

  364.             unset($run_station_info[$vel['station_id']]['station_id']);

  365.         }

  366. 

  367.         if (count($order_info) > 0) {

  368.             foreach ($order_info as $key => $vel) {

  369.                 //$bus_info['saled_count'] += $vel['people_num'];//增加总乘客数

  370.                 $run_station_info[$vel['start_station_id']]['people_up_all_num'] += $vel['people_num'];//增加对应站应上车总人数

  371.                 $run_station_info[$vel['end_station_id']]['people_down_all_num'] += $vel['people_num'];//增加对应站应下车总人数

  372.                 if ($vel['check_status'] == 0) {

  373.                     $run_station_info[$vel['start_station_id']]['not_up_num'] += $vel['people_num'];//增加对应站未检票总人数

  374.                 } else {

  375.                     $run_station_info[$vel['start_station_id']]['has_up_num'] += $vel['people_num'];//增加对应站已检票总人数

  376.                 }

  377.                 $station_one = $vel;

  378.                 unset($station_one['start_station_id']);

  379.                 unset($station_one['end_station_id']);

  380.                 $run_station_info[$vel['start_station_id']]['passengers'][] = $station_one;//增加对应站上车订单

  381.                 $run_station_info[$vel['end_station_id']]['down_passengers'][] = $station_one;//增加对应站下车订单

  382.             }

  383.         }

  384.         #endregion

  385. 

  386.         $result['bus_info'] = $bus_info;

  387.         $result['station_info'] = array_merge($run_station_info);

  388.         return $result;

  389.     }

  390. 

  391.     /**

  392.      * Function Description:获取已完成的任务数量

  393.      * Function Name: getTaskComplete

  394.      * @param int $driver_id 司机id

  395.      *

  396.      * @return int|string

  397.      *

  398.      * @author 张帅

  399.      */

  400.     public function getTaskComplete($driver_id)

  401.     {

  402.         $result = self::find()

  403.             ->where([

  404.                 'and',

  405.                 ['=', 'send_bus_driver_res_id', $driver_id],

  406.                 ['=', 'cancel_flag', 0],

  407.                 ['=', 'run_status', 438]

  408.             ])->count();

  409. 

  410.         return $result;

  411.     }

  412. 

  413.     /**

  414.      * Function Description:通过司机获取报账列表

  415.      * Function Name: getFinanceListByDriver

  416.      * @param int $driver_id 司机id

  417.      *

  418.      * @return array|\yii\db\ActiveRecord[]

  419.      *

  420.      * @author 张帅

  421.      */

  422.     public function getFinanceListByDriver($driver_id)

  423.     {

  424.         #region 1.从数据库获取数据

  425.         $finance_list = self::find()

  426.             ->select([

  427.                 'o.bus_number',//任务单号

  428.                 'o.itinerary_name',//行程名称

  429.                 'o.run_date',//行程日期

  430.                 'finance_status_id' => 'o.finance_status',//报账状态代号

  431.                 'finance_status' => DictType::find()->select('type_name')->where('id = o.finance_status')->limit(1),//报账状态

  432.                 'finance_price' => 'e.expense_value',//报账金额

  433.                 'e.expense_subject_id',

  434.                 'run_status_id' => 'o.run_status',

  435.                 'run_status' => DictType::find()->select('type_name')->where('id = o.run_status')->limit(1),

  436.                 'finance_log' => BusOrderStatusLog::find()->select('msg')->where('bus_number = o.bus_number and type = 432 and after_status = o.finance_status')->orderBy(['id' => SORT_DESC])->limit(1),//日志

  437.             ])

  438.             ->from(self::tableName() . ' as o')

  439.             ->innerJoin(RunBusExpenses::tableName() . ' as e', 'o.bus_number = e.bus_number')

  440.             ->where([

  441.                 'and',

  442.                 ['=', 'o.send_bus_driver_res_id', $driver_id],

  443.                 ['<=', 'o.run_date', date('Y-m-d', time())],

  444.                 ['>=', 'o.run_date', date('Y-m-d', strtotime(" -1 month "))],

  445.                 ['=', 'o.cancel_flag', 0],

  446.                 ['=', 'e.cancel_flag', 0],

  447.                 ['=', 'run_status', 438],

  448.             ])

  449.             ->orderBy(['o.run_date' => SORT_DESC, 'o.start_time' => SORT_DESC])

  450.             ->asArray()->all();

  451.         #endregion

  452. 

  453.         #region 2.整理数据

  454.         $result = [];

  455.         foreach ($finance_list as $key => $vel) {

  456.             if (!isset($result[$vel['bus_number']])) {

  457.                 $result[$vel['bus_number']] = $vel;

  458.                 $result[$vel['bus_number']]['finance_price'] = 0;

  459.             }

  460.             if (in_array($vel['expense_subject_id'], [465, 466, 467])) {

  461.                 $result[$vel['bus_number']]['finance_price'] += $vel['finance_price'];

  462.             }

  463.         }

  464.         $result = array_merge($result);

  465.         #endregion

  466. 

  467.         return $result;

  468.     }

  469. 

  470.     /**

  471.      * Function Description:未报帐消息提醒

  472.      * Function Name: sendFinanceMsg

  473.      *

  474.      * @return array

  475.      *

  476.      * @author 张帅

  477.      */

  478.     public function sendFinanceMsg()

  479.     {

  480.         #region 1.找出需要报账提醒的行程

  481.         $itinerary_list = BusItinerary::find()

  482.             ->select('itinerary_id,max(station_seq_id) as station_seq_id')

  483.             ->where('cancel_flag = 0')

  484.             ->groupBy('itinerary_id');

  485. 

  486.         $itinerary_list = BusItinerary::find()

  487.             ->select('bi.itinerary_id,bi.station_seq_id,bi.start_time,bi.day_seq_id')

  488.             ->from(BusItinerary::tableName() . ' as bi')

  489.             ->innerJoin(['i1' => $itinerary_list], 'bi.itinerary_id = i1.itinerary_id and bi.station_seq_id = i1.station_seq_id')

  490.             ->where('cancel_flag = 0');

  491. 

  492.         $finance_list = self::find()

  493.             ->select([

  494.                 'o.bus_number',

  495.                 'o.finance_status',

  496.                 'driver_id' => 'o.send_bus_driver_res_id',

  497.                 'o.run_date',

  498.                 'i.start_time',

  499.                 'o.itinerary_id',

  500.                 'o.itinerary_name',

  501.                 'i.station_seq_id',

  502.             ])

  503.             ->from(self::tableName() . ' as o')

  504.             ->innerJoin(['i' => $itinerary_list], 'o.itinerary_id = i.itinerary_id')

  505.             ->where([

  506.                 'and',

  507.                 ['>=', 'i.start_time', date('H') . '00'],

  508.                 ['<', 'i.start_time', date('H', strtotime("+1 hours")) . '00'],

  509.                 [

  510.                     'or',

  511.                     [

  512.                         'and',

  513.                         ['=', 'day_seq_id', 1],

  514.                         ['=', 'o.run_date', date("Y-m-d", strtotime("-1 day"))],

  515.                     ],

  516.                     [

  517.                         'and',

  518.                         ['=', 'day_seq_id', 2],

  519.                         ['=', 'o.run_date', date("Y-m-d", strtotime("-2 day"))],

  520.                     ],

  521.                 ],

  522.                 ['=', 'o.finance_status', 444],

  523.                 ['!=', 'o.send_bus_driver_res_id', ''],

  524.                 ['=', 'o.cancel_flag', 0],

  525.                 ['=', 'o.run_status', 438],

  526.             ])

  527.             ->orderBy(['i.start_time' => SORT_ASC])

  528.             ->asArray()->all();

  529.         #endregion

  530. 

  531.         #region 2.插入信息表数据

  532.         if (count($finance_list) > 0) {

  533.             $msg_list = [];

  534.             foreach ($finance_list as $key => $vel) {

  535.                 $msg_list[] = [

  536.                     'CANCEL_FLAG' => 0,

  537.                     'CREATE_USER_ID' => 1,

  538.                     'CREATE_TIME' => date('Y-m-d H:i:s'),

  539.                     'UPDATE_USER_ID' => 1,

  540.                     'UPDATE_TIME' => date('Y-m-d H:i:s'),

  541.                     'BUS_NUMBER' => $vel['bus_number'],

  542.                     'DRIVER_ID' => $vel['driver_id'],//9181,

  543.                     'MSG_TYPE' => 490,

  544.                     'SEND_MESSAGE' => date('m', strtotime($vel['run_date'])) . '月' . date('d', strtotime($vel['run_date'])) . '日,(' . $vel['itinerary_name'] . ')的出车任务还未进行报账，请及时进行报账，点击进入相应任务的报账页面，该任务已报账，再次点击提示“该任务已完成报账”',

  545.                     'IS_READ' => 0,

  546.                 ];

  547.             };

  548. 

  549.             $res = Yii::$app->db->createCommand()->batchInsert(DriverMessage::tableName(),

  550.                 ['CANCEL_FLAG', 'CREATE_USER_ID', 'CREATE_TIME', 'UPDATE_USER_ID', 'UPDATE_TIME', 'BUS_NUMBER', 'DRIVER_ID', 'MSG_TYPE', 'SEND_MESSAGE', 'IS_READ'],

  551.                 $msg_list)->execute();

  552.             if ($res) {

  553.                 return $msg_list;

  554.             } else {

  555.                 return [];

  556.             }

  557.         } else {

  558.             return [];

  559.         }

  560.         #endregion

  561.     }

  562. 

  563.     public function countBusOrderFromStatus($driver_res_id, $run_date, $run_status)

  564.     {

  565.         $total_count = self::find()

  566.             ->from(self::tableName())

  567.             ->where(

  568.                 [

  569.                     'and',

  570.                     ['=', 'send_bus_driver_res_id', $driver_res_id],

  571.                     ['=', 'run_date', $run_date],

  572.                     ['=', 'run_status', $run_status]

  573.                 ]

  574.             )->count();

  575.         return $total_count;

  576.     }

  577. 

  578.     /**

  579.      * 根据司机、车辆、日期等信息模糊查询出任务列表信息

  580.      */

  581.     public function getTaskByParam($driver_name,$bus_no,$run_date){

  582.         $filter = ['and',['=','bo.cancel_flag',0]];

  583.         $filter[] = ['and',['=','bb.cancel_flag',0]];

  584.         $filter[] = ['and',['=','bd.cancel_flag',0]];

  585.         if($driver_name != ''){

  586.             //根据司机名字模糊查询出可能的司机资源id

  587.             $driver_id_list = BaseDriver::find()->select(['driver_id as send_bus_driver_res_id'])->where(['and',['=','cancel_flag',0],['like','driver_name',$driver_name]])->asArray()->all();

  588.             if(!$driver_id_list){   //没找到匹配的司机

  589.                 $filter[] = ['=','send_bus_driver_res_id','null'];

  590.             }else{

  591.                 $filter[] = ['in','send_bus_driver_res_id',$driver_id_list];

  592.             }

  593. 

  594. 

  595. 

  596.         }

  597. 

  598.         if($bus_no != ''){

  599.             //根据车牌号查询出可能的车辆资源id

  600.             $bus_id_list = BaseBus::find()->select('bus_id as send_bus_res_id')->where(['like','bus_no',$bus_no])->asArray()->all();

  601.             if(!$bus_id_list){  //如果输入了车牌号，并且没有该车牌号信息

  602.                 $filter[] = ['=','send_bus_res_id','null'];

  603.             }else{

  604.                 $filter[] = ['in','send_bus_res_id',$bus_id_list];

  605.             }

  606. 

  607. 

  608.         }

  609.         if($run_date != ''){

  610.             $filter[] = ['like','run_date',$run_date];

  611.         }

  612.         $task_list = self::find()

  613.             ->select(['bo.run_date','bo.bus_number','bo.run_id','bo.bus_order_id','bo.start_time','bo.saled_count','bo.itinerary_name','bb.bus_no','bd.driver_name','bo.run_status'])

  614.             ->from(BusOrder::tableName().' as bo')

  615.             ->innerJoin(BaseBus::tableName().' as bb','bo.send_bus_res_id = bb.bus_id' )

  616.             ->innerJoin(BaseDriver::tableName().' as bd','bo.send_bus_driver_res_id = bd.driver_id')

  617.             ->filterWhere($filter)

  618.             ->orderBy(['run_date'=>SORT_DESC])

  619.             ->asArray()->all();

  620.         // ->createCommand()->getRawSql();

  621. 

  622.         return $task_list;

  623.     }

  624. 

  625.     public function getRunIdByBusNumber($bus_number){

  626.         $result = self::find()->select("run_id,bus_order_id")->where(['bus_number' => $bus_number, 'cancel_flag' => 0])->asArray()->one();

  627.         return $result;

  628.     }

  629. }