nizongfeng
/
ZZCX_yii
1
0
Çatalla 0
Kod Konular 0 Değişiklik İstekleri 0 Sürümler 0 Wiki Aktivite
25'ten fazla konu seçemezsiniz Konular bir harf veya rakamla başlamalı, kısa çizgiler ('-') içerebilir ve en fazla 35 karakter uzunluğunda olabilir.
3 İşleme
1 Dal
96 MiB
 
 
 
 
 
 
Dal: master
Dallar Biçim İmleri
${ item.name }
${ searchTerm } dalı oluştur
'master'den
${ noResults }
ZZCX_yii/backend/modules/api/models/RunBusExpenses.php

817 satır
32 KiB
Ham Kalıcı Bağlantı Suçlama Geçmiş 

  1. <?php

  2. 

  3. namespace backend\modules\api\models;

  4. 

  5. use yii\db\ActiveRecord;

  6. use Yii;

  7. use yii\base\Exception;

  8. use backend\modules\zzcs\models\OrderSendMessage;

  9. use backend\modules\motorcade\models\BusOilDoc;

  10. use backend\modules\motorcade\models\BusDocLog;

  11. 

  12. /**

  13.  * This is the model class for table "run_bus_expenses".

  14.  *

  15.  * @property integer $ID

  16.  * @property integer $create_user_id

  17.  * @property string $create_time

  18.  * @property integer $update_user_id

  19.  * @property string $update_time

  20.  * @property integer $cancel_flag

  21.  * @property integer $bus_number

  22.  * @property integer $use_bus_org_id

  23.  * @property string $run_date

  24.  * @property integer $bus_res_id

  25.  * @property integer $bus_driver_res_id

  26.  * @property integer $expense_subject_id

  27.  * @property integer $expense_type

  28.  * @property string $expense_value

  29.  * @property string $start_value

  30.  * @property string $end_value

  31.  * @property string $doc_log_id

  32.  */

  33. class RunBusExpenses extends ActiveRecord

  34. {

  35.     /**

  36.      * @inheritdoc

  37.      */

  38.     public static function tableName()

  39.     {

  40.         return 'run_bus_expenses';

  41.     }

  42. 

  43.     /**

  44.      * @inheritdoc

  45.      */

  46.     public function rules()

  47.     {

  48.         return [

  49.             [['create_user_id', 'create_time', 'run_date'], 'required'],

  50.             [['create_user_id', 'update_user_id', 'cancel_flag', 'bus_number', 'use_bus_org_id', 'bus_res_id', 'bus_driver_res_id', 'expense_subject_id', 'expense_type'], 'integer'],

  51.             [['update_time'], 'safe'],

  52.             [['expense_value', 'start_value', 'end_value', 'doc_log_id'], 'number'],

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

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

  55.         ];

  56.     }

  57. 

  58.     /**

  59.      * @inheritdoc

  60.      */

  61.     public function attributeLabels()

  62.     {

  63.         return [

  64.             'ID' => 'ID',

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

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

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

  68.             'update_time' => 'Update Time',

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

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

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

  72.             'run_date' => '出车日期',

  73.             'bus_res_id' => '车辆res_id',

  74.             'bus_driver_res_id' => '司机res_id',

  75.             'expense_subject_id' => '支出科目   对应dict_type.id',

  76.             'expense_type' => '支出方式 对应dict_type.id',

  77.             'expense_value' => '支出金额',

  78.             'start_value' => '科目为邮电费时对应开始时的里程数,为路桥费时对应ETC充值卡开始时的金额',

  79.             'end_value' => '科目为邮电费时对应结束时的里程数,为路桥费时对应ETC充值卡结束时的金额',

  80.             'doc_log_id' => '对应bus_doc_log 表中的id',

  81.         ];

  82.     }

  83. 

  84.     /**

  85.      * Function Description:获取司机的总里程数

  86.      * Function Name: getTotalMileageByDriver

  87.      * @param int $driver_id 司机id

  88.      *

  89.      * @return array|int|mixed|null|ActiveRecord

  90.      *

  91.      * @author 张帅

  92.      */

  93.     public function getTotalMileageByDriver($driver_id)

  94.     {

  95.         $result = self::find()

  96.             ->select("sum(end_value-start_value) as total_mileage")

  97.             ->where([

  98.                 'and',

  99.                 ['=', 'bus_driver_res_id', $driver_id],

  100.                 ['=', 'expense_subject_id', 462],

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

  102.                 ['!=', 'end_value', 0],

  103.             ])

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

  105.         $result = ($result['total_mileage'] == null ? 0 : $result['total_mileage']);

  106.         return $result;

  107.     }

  108. 

  109.     /**

  110.      * Function Description:出行开始

  111.      * Function Name: runStart

  112.      * @param $bus_number

  113.      * @param $postage

  114.      * @param $toll_charge

  115.      *

  116.      * @return bool

  117.      *

  118.      * @author 张帅

  119.      */

  120.     public function runStart($bus_number, $postage, $toll_charge)

  121.     {

  122.         #region 1.通过出车单号获取行程详情

  123.         $bus_order_info = BusOrder::find()

  124.             ->select([

  125.                 'bus_number',//出车单号

  126.                 'use_bus_org_id',//用车单位

  127.                 'run_date',//出车日期

  128.                 'bus_res_id' => 'send_bus_res_id',//所用车辆

  129.                 'bus_driver_res_id' => 'send_bus_driver_res_id',//出车司机

  130.             ])

  131.             ->where([

  132.                 'bus_number' => $bus_number,

  133.                 'cancel_flag' => 0,

  134.             ])

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

  136.         #endregion

  137. 

  138.         #region 2.获取要添加的出行任务费用数据

  139.         $expenses_value[] = $bus_order_info + [

  140.                 'create_user_id' => $bus_order_info['bus_driver_res_id'],

  141.                 'create_time' => date('Y-m-d H:i:s', time()),

  142.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  143.                 'update_time' => date('Y-m-d H:i:s', time()),

  144.                 'cancel_flag' => 0,

  145.                 'expense_subject_id' => 462,

  146.                 'expense_type' => 0,

  147.                 'expense_value' => 0,

  148.                 'start_value' => $postage,

  149.             ];

  150.         $expenses_value[] = $bus_order_info + [

  151.                 'create_user_id' => $bus_order_info['bus_driver_res_id'],

  152.                 'create_time' => date('Y-m-d H:i:s', time()),

  153.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  154.                 'update_time' => date('Y-m-d H:i:s', time()),

  155.                 'cancel_flag' => 0,

  156.                 'expense_subject_id' => 463,

  157.                 'expense_type' => 473,

  158.                 'expense_value' => 0,

  159.                 'start_value' => $toll_charge,

  160.             ];

  161.         #endregion

  162. 

  163.         #region 3.修改数据

  164.         $transaction = Yii::$app->db->beginTransaction();

  165.         try {

  166.             //插入添加的出行任务费用

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

  168.                 ['bus_number', 'use_bus_org_id', 'run_date', 'bus_res_id', 'bus_driver_res_id', 'create_user_id', 'create_time', 'update_user_id', 'update_time', 'cancel_flag', 'expense_subject_id', 'expense_type', 'expense_value', 'start_value'],

  169.                 $expenses_value)->execute();

  170.             if (!$res) {

  171.                 throw new Exception('输入数据不符合格式');

  172.             }

  173.             //修改出车状态

  174.             $bus_order_one = BusOrder::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0]);

  175.             $bus_order_one->attributes = ['update_user_id' => $bus_order_info['bus_driver_res_id'], 'update_time' => date('Y-m-d H:i:s', time()), 'run_status' => 437];

  176.             $res = $bus_order_one->update();

  177.             if (!$res) {

  178.                 throw new Exception('输入数据不符合格式');

  179.             }

  180.             $transaction->commit();

  181.             $result = true;

  182.         } catch (Exception $e) {

  183.             # 回滚事务

  184.             $result = false;

  185.         }

  186.         return $result;

  187.         #endregion

  188.     }

  189. 

  190.     /**

  191.      * Function Description:任务结束

  192.      * Function Name: runEnd

  193.      * @param $bus_number

  194.      * @param $postage

  195.      * @param $toll_charge

  196.      *

  197.      * @return bool

  198.      *

  199.      * @author 张帅

  200.      */

  201.     public function runEnd($bus_number, $postage, $toll_charge, $diff_distance = 0)

  202.     {

  203.         #region 1.通过出车单号获取行程详情

  204.         $bus_order_info = BusOrder::find()

  205.             ->select([

  206.                 'bus_number',//出车单号

  207.                 'use_bus_org_id',//用车单位

  208.                 'run_date',//出车日期

  209.                 'bus_res_id' => 'send_bus_res_id',//所用车辆

  210.                 'bus_driver_res_id' => 'send_bus_driver_res_id',//出车司机

  211.             ])

  212.             ->where([

  213.                 'bus_number' => $bus_number,

  214.                 'cancel_flag' => 0,

  215.             ])

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

  217.         #endregion

  218. 

  219. 

  220.         #region 2.修改数据

  221.         $transaction = Yii::$app->db->beginTransaction();

  222.         try {

  223.             //(1)修改邮电费

  224.             $postage_one = self::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0, 'expense_subject_id' => 462]);

  225.             $postage_start_value = $postage_one->start_value;

  226.             if ($postage < $postage_start_value) {

  227.                 throw new Exception('请认真填写');

  228.             }

  229. 

  230.             #region 获取参考油价

  231.             $bus_postage = BaseBus::find()->select('mpg,oil_price,fuel_form')->where(['bus_id' => $bus_order_info['bus_res_id']])->asArray()->one();

  232.             if (count($bus_postage) == 0 || empty($bus_postage['mpg']) || $bus_postage['mpg'] == 0) {//升/百公里   度/百公里

  233.                 $mpg = $bus_postage['fuel_form'] == 487 ? 82 : 25;

  234.             } else {

  235.                 $mpg = $bus_postage['mpg'];

  236.             }

  237.             if (count($bus_postage) == 0 || empty($bus_postage['oil_price']) || $bus_postage['oil_price'] == 0) {// 元/升   元/度

  238.                 $oil_price = $bus_postage['fuel_form'] == 487 ? 2.2 : 6.11;

  239.             } else {

  240.                 $oil_price = $bus_postage['oil_price'];

  241.             }

  242.             #endregion

  243. 

  244.             $expense_value = round((($postage - $postage_start_value) / 100 * $mpg * $oil_price), 2);//油耗费或者电耗费用

  245. 

  246.             $postage_value = [

  247.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  248.                 'update_time' => date('Y-m-d H:i:s', time()),

  249.                 'expense_value' => $expense_value,

  250.                 'end_value' => $postage,

  251.             ];

  252.             $postage_one->attributes = $postage_value;

  253.             $res = $postage_one->update();

  254.             if (!$res) {

  255.                 throw new Exception('输入数据不符合格式');

  256.             }

  257. 

  258.             //(2)修改路桥费

  259.             $toll_charge_one = self::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0, 'expense_subject_id' => 463]);

  260.             $toll_charge_start_value = $toll_charge_one->start_value;

  261.             $expense_value = $toll_charge_start_value - $toll_charge;

  262. 

  263.             //插入ETC记录

  264.             $doc_log_id = 0;

  265.             $bus_oil_doc_info = BusOilDoc::findOne(['BIND_BUS' => $bus_order_info['bus_res_id'], 'CARD_TYPE' => 2]);

  266.             if (false != $bus_oil_doc_info && isset($bus_oil_doc_info["ID"])) {

  267.                 $card_balance = $bus_oil_doc_info["CARD_BALANCE"] - $expense_value;

  268.                 $bus_doc_log = new BusDocLog();

  269.                 $bus_doc_log->attributes = [

  270.                     'CREATE_USER_ID' => $bus_order_info['bus_driver_res_id'],

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

  272.                     'UPDATE_USER_ID' => $bus_order_info['bus_driver_res_id'],

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

  274.                     'CARD_ID' => $bus_oil_doc_info["ID"],

  275.                     'BUS_ID' => $bus_oil_doc_info['BIND_BUS'],

  276.                     'OPERATION_TYPE' => 601,

  277.                     'OPERATION_DRIVER' => $bus_order_info['bus_driver_res_id'],

  278.                     'OPERATION_DATE' => date("Y-m-d"),

  279.                     'VALUE' => $expense_value,

  280.                     'VALUE_OLD' => $bus_oil_doc_info["CARD_BALANCE"],

  281.                     'NOTE' => "APP司机出车报账"

  282.                 ];

  283.                 $bus_doc_log->save();

  284.                 $doc_log_id = $bus_doc_log->attributes['ID'];

  285. 

  286.                 if ($expense_value > 0) {

  287.                     $bus_oil_doc_info->attributes = ['CARD_BALANCE' => $card_balance, 'UPDATE_TIME' => date('Y-m-d H:i:s', time()), 'UPDATE_USER_ID' => $bus_order_info['bus_driver_res_id']];

  288.                     $res = $bus_oil_doc_info->update();

  289.                 }

  290.             }

  291. 

  292. 

  293.             $toll_charge_value = [

  294.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  295.                 'update_time' => date('Y-m-d H:i:s', time()),

  296.                 'expense_value' => $expense_value,

  297.                 'end_value' => $toll_charge,

  298.                 'doc_log_id' => $doc_log_id,

  299.             ];

  300. 

  301.             $toll_charge_one->attributes = $toll_charge_value;

  302.             $res = $toll_charge_one->update();

  303.             if (!$res) {

  304.                 throw new Exception('输入数据不符合格式');

  305.             }

  306. 

  307.             //修改出车状态

  308.             $bus_order_one = BusOrder::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0]);

  309.             $bus_order_one->attributes = ['update_user_id' => $bus_order_info['bus_driver_res_id'], 'update_time' => date('Y-m-d H:i:s', time()), 'run_status' => 438];

  310.             $res = $bus_order_one->update();

  311.             if (!$res) {

  312.                 throw new Exception('输入数据不符合格式');

  313.             }

  314.             //以下为给乘客发送短信

  315. //            $bus_order = new BusOrder();

  316. //            $order_send_message = new OrderSendMessage();

  317. //            $order_check_ticket = new OrderCheckTickets();

  318. //            // 根据bus_number查询到run_id，为了进一步查询到检票的乘客作准备

  319. //            $result = $bus_order->getRunIdByBusNumber($bus_number);

  320. //            $customer_phone_list = $order_check_ticket->getCustomerMobile($result['run_id'],$result['bus_order_id']);

  321. //            if(!empty($customer_phone_list)){

  322. //                foreach($customer_phone_list as $k => $customer_phone){

  323. //                    $res_send_message = $order_send_message->sendTelMessage($customer_phone['customer_mobile'], '感谢您乘坐蜘蛛出行巴士旅游专线，祝您游玩愉快，如有门票、旅游直通车预订需求，请关注(蜘蛛行)公众号，有返佣哦！如对这次乘坐有任何建议，请拨打021-33280519进行反馈');

  324. //                    //短信记录插入order_send_message表

  325. //                    $current_time = date("Y-m-d H:i:s");

  326. //                    $send_msg_values = [

  327. //                        'ORDER_ID' => $customer_phone['order_id'],

  328. //                        'SEND_MOBILE' => $customer_phone['customer_mobile'],

  329. //                        'SEND_MESSAGE' => '【蜘蛛行】感谢您乘坐蜘蛛出行巴士旅游专线，祝您游玩愉快，如有门票、旅游直通车预订需求，请关注(蜘蛛行)公众号，有返佣哦！如对这次乘坐有任何建议，请拨打021-33280519进行反馈',

  330. //                        'SEND_TIME' => $current_time,

  331. //                        'SEND_ERROR' => $res_send_message,

  332. //                        'CREATE_USER_ID' => 2,

  333. //                        'CREATE_TIME' => $current_time,

  334. //                        'UPDATE_USER_ID' => 2,

  335. //                        'UPDATE_TIME' => $current_time,

  336. //                    ];

  337. //                    $msgRecord = new OrderSendMessage();

  338. //                    $msgRecord->attributes = $send_msg_values;

  339. //                    $res = $msgRecord->insert();

  340. ////                    if (!$res) {

  341. ////                        throw new Exception('插入失败');

  342. ////                    }

  343. //                }

  344. //            }

  345. 

  346. 

  347.             //司贴

  348. //            $expenses_value[] = $bus_order_info + [

  349. //                    'create_user_id' => $bus_order_info['bus_driver_res_id'],

  350. //                    'create_time' => date('Y-m-d H:i:s', time()),

  351. //                    'update_user_id' => $bus_order_info['bus_driver_res_id'],

  352. //                    'update_time' => date('Y-m-d H:i:s', time()),

  353. //                    'cancel_flag' => 0,

  354. //                    'expense_subject_id' => 464,

  355. //                    'expense_type' => 474,

  356. //                    'expense_value' => $diff_distance*0.6,

  357. //                ];

  358. //            $res = Yii::$app->db->createCommand()->batchInsert(self::tableName(),

  359. //                ['bus_number', 'use_bus_org_id', 'run_date', 'bus_res_id', 'bus_driver_res_id', 'create_user_id', 'create_time', 'update_user_id', 'update_time', 'cancel_flag', 'expense_subject_id', 'expense_type', 'expense_value'],

  360. //                $expenses_value)->execute();

  361. 

  362.             $transaction->commit();

  363.             $result = true;

  364.         } catch (Exception $e) {

  365.             # 回滚事务

  366.             $result = false;

  367.         }

  368.         #endregion

  369. 

  370.         return $result;

  371.     }

  372. 

  373.     /**

  374.      * Function Description:获取邮电费和路桥费

  375.      * Function Name: getRunOrderExpenses

  376.      * @param $bus_number

  377.      *

  378.      * @return array

  379.      *

  380.      * @author 张帅

  381.      */

  382.     public function getRunOrderExpenses($bus_number)

  383.     {

  384.         #region 1.从数据库获取任务邮电费和路桥费费用

  385.         $expenses_list = self::find()

  386.             ->select([

  387.                 'e.bus_number',

  388.                 'e.expense_subject_id',//支出科目

  389.                 'e.expense_value',//支出金额

  390.                 'e.start_value',

  391.                 'e.end_value',

  392.                 'e.run_date',//报账日期

  393.                 'task_name' => 'o.itinerary_name',

  394.             ])

  395.             ->from(self::tableName() . ' as e')

  396.             ->leftJoin(BusOrder::tableName() . ' as o', 'o.bus_number = e.bus_number')

  397.             ->where([

  398.                 'and',

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

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

  401.                 ['in', 'e.expense_subject_id', [462, 463]],

  402.                 ['in', 'e.bus_number', $bus_number],

  403.             ])

  404.             ->asArray()

  405.             ->all();

  406.         #endregion

  407. 

  408.         #region 2.整理数据

  409.         $result = [];

  410.         foreach ($expenses_list as $key => $vel) {

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

  412.                 $result['bus_number'] = $vel['bus_number'];//出行单号

  413.                 $result['run_date'] = $vel['run_date'];//出行日期

  414.                 $result['task_name'] = $vel['task_name'];//任务名称

  415.             }

  416.             if ($vel['expense_subject_id'] == 462) {

  417.                 $result['mileage'] = $vel['end_value'] - $vel['start_value'];//行驶里程

  418.             }

  419.             if ($vel['expense_subject_id'] == 463) {

  420.                 $result['toll_charge'] = $vel['expense_value'];//路桥费

  421.             }

  422.         }

  423.         #endregion

  424. 

  425.         return $result;

  426.     }

  427. 

  428.     /**

  429.      * Function Description:提交报账

  430.      * Function Name: getSubmitFinance

  431.      * @param $bus_number

  432.      * @param $food_expense

  433.      * @param $hotel_expense

  434.      * @param $park_expense

  435.      *

  436.      * @return bool

  437.      *

  438.      * @author 张帅

  439.      */

  440.     public function getSubmitFinance($bus_number, $food_expense, $hotel_expense, $park_expense)

  441.     {

  442.         #region 1.通过出车单号获取行程详情

  443.         $bus_order_info = BusOrder::find()

  444.             ->select([

  445.                 'bus_number',//出车单号

  446.                 'use_bus_org_id',//用车单位

  447.                 'run_date',//出车日期

  448.                 'bus_res_id' => 'send_bus_res_id',//所用车辆

  449.                 'bus_driver_res_id' => 'send_bus_driver_res_id',//出车司机

  450.             ])

  451.             ->where([

  452.                 'bus_number' => $bus_number,

  453.                 'cancel_flag' => 0,

  454.             ])

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

  456.         #endregion

  457. 

  458.         #region 2.获取要添加的出行任务费用数据

  459.         //(1)餐饮费

  460.         $expenses_value[] = $bus_order_info + [

  461.                 'create_user_id' => $bus_order_info['bus_driver_res_id'],

  462.                 'create_time' => date('Y-m-d H:i:s', time()),

  463.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  464.                 'update_time' => date('Y-m-d H:i:s', time()),

  465.                 'cancel_flag' => 0,

  466.                 'expense_subject_id' => 466,

  467.                 'expense_type' => 475,

  468.                 'expense_value' => $food_expense,

  469.             ];

  470.         //(2)住宿费

  471.         $expenses_value[] = $bus_order_info + [

  472.                 'create_user_id' => $bus_order_info['bus_driver_res_id'],

  473.                 'create_time' => date('Y-m-d H:i:s', time()),

  474.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  475.                 'update_time' => date('Y-m-d H:i:s', time()),

  476.                 'cancel_flag' => 0,

  477.                 'expense_subject_id' => 467,

  478.                 'expense_type' => 475,

  479.                 'expense_value' => $hotel_expense,

  480.             ];

  481.         //(3)停车费

  482.         $expenses_value[] = $bus_order_info + [

  483.                 'create_user_id' => $bus_order_info['bus_driver_res_id'],

  484.                 'create_time' => date('Y-m-d H:i:s', time()),

  485.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  486.                 'update_time' => date('Y-m-d H:i:s', time()),

  487.                 'cancel_flag' => 0,

  488.                 'expense_subject_id' => 465,

  489.                 'expense_type' => 475,

  490.                 'expense_value' => $park_expense,

  491.             ];

  492.         #endregion

  493.         //(4)司贴

  494. 

  495.         $expenses_value[] = $bus_order_info + [

  496.                 'create_user_id' => $bus_order_info['bus_driver_res_id'],

  497.                 'create_time' => date('Y-m-d H:i:s', time()),

  498.                 'update_user_id' => $bus_order_info['bus_driver_res_id'],

  499.                 'update_time' => date('Y-m-d H:i:s', time()),

  500.                 'cancel_flag' => 0,

  501.                 'expense_subject_id' => 464,

  502.                 'expense_type' => 474,

  503.                 'expense_value' => 0,

  504.             ];

  505. 

  506.         #endregion

  507. 

  508.         #region 3.修改数据

  509.         $transaction = Yii::$app->db->beginTransaction();

  510.         try {

  511.             //插入添加的出行任务费用

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

  513.                 ['bus_number', 'use_bus_org_id', 'run_date', 'bus_res_id', 'bus_driver_res_id', 'create_user_id', 'create_time', 'update_user_id', 'update_time', 'cancel_flag', 'expense_subject_id', 'expense_type', 'expense_value'],

  514.                 $expenses_value)->execute();

  515.             if (!$res) {

  516.                 throw new Exception('输入数据不符合格式');

  517.             }

  518.             //修改报账状态

  519.             $bus_order_one = BusOrder::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0]);

  520.             $bus_order_one->attributes = ['update_user_id' => $bus_order_info['bus_driver_res_id'], 'update_time' => date('Y-m-d H:i:s', time()), 'finance_status' => 445];

  521.             $res = $bus_order_one->update();

  522.             if (!$res) {

  523.                 throw new Exception('输入数据不符合格式');

  524.             }

  525.             $transaction->commit();

  526.             $result = true;

  527.         } catch (Exception $e) {

  528.             # 回滚事务

  529.             $result = false;

  530.         }

  531.         #endregion

  532. 

  533.         return $result;

  534.     }

  535. 

  536.     /**

  537.      * Function Description:获取费用详情

  538.      * Function Name: getFinanceDetail

  539.      * @param string $bus_number 出行单号

  540.      *

  541.      * @return array

  542.      *

  543.      * @author 张帅

  544.      */

  545.     public function getFinanceDetail($bus_number)

  546.     {

  547.         #region 1.从数据库获取任务费用

  548.         $expenses_list = self::find()

  549.             ->select([

  550.                 'e.bus_number',

  551.                 'e.expense_subject_id',//支出科目

  552.                 'e.expense_value',//支出金额

  553.                 'e.start_value',

  554.                 'e.end_value',

  555.                 'e.run_date',//报账日期

  556.                 'task_name' => 'o.itinerary_name',

  557.             ])

  558.             ->from(self::tableName() . ' as e')

  559.             ->leftJoin(BusOrder::tableName() . ' as o', 'o.bus_number = e.bus_number')

  560.             ->where([

  561.                 'and',

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

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

  564.                 ['in', 'e.expense_subject_id', [462, 463, 465, 466, 467]],

  565.                 ['in', 'e.bus_number', $bus_number],

  566.             ])

  567.             ->asArray()

  568.             ->all();

  569.         #endregion

  570. 

  571.         #region 2.整理数据

  572.         $result = [];

  573.         foreach ($expenses_list as $key => $vel) {

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

  575.                 $result['bus_number'] = $vel['bus_number'];//出行单号

  576.                 $result['run_date'] = $vel['run_date'];//出行日期

  577.                 $result['task_name'] = $vel['task_name'];//任务名称

  578.             }

  579.             if ($vel['expense_subject_id'] == 462) {

  580.                 $result['mileage'] = $vel['end_value'] - $vel['start_value'];//行驶里程

  581.             }

  582.             if ($vel['expense_subject_id'] == 463) {

  583.                 $result['toll_charge'] = $vel['expense_value'];//路桥费

  584.             }

  585.             if ($vel['expense_subject_id'] == 465) {

  586.                 $result['food_expense'] = $vel['expense_value'];//餐饮费

  587.             }

  588.             if ($vel['expense_subject_id'] == 466) {

  589.                 $result['hotel_expense'] = $vel['expense_value'];//住宿费

  590.             }

  591.             if ($vel['expense_subject_id'] == 467) {

  592.                 $result['park_expense'] = $vel['expense_value'];//停车费

  593.             }

  594.         }

  595.         #endregion

  596.         return $result;

  597.     }

  598. 

  599.     /**

  600.      * Function Description:重新报账

  601.      * Function Name: getResubmitFinance

  602.      * @param $bus_number

  603.      * @param $food_expense

  604.      * @param $hotel_expense

  605.      * @param $park_expense

  606.      *

  607.      * @return bool

  608.      *

  609.      * @author 张帅

  610.      */

  611.     public function getResubmitFinance($bus_number, $food_expense, $hotel_expense, $park_expense)

  612.     {

  613.         #region 1.修改数据

  614.         $transaction = Yii::$app->db->beginTransaction();

  615.         try {

  616.             //(1)修改餐饮费

  617.             $food_one = self::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0, 'expense_subject_id' => 465]);

  618.             $food_one->attributes = ['update_time' => date('Y-m-d H:i:s', time()), 'expense_value' => $food_expense,];

  619.             $res = $food_one->update();

  620.             if (!$res) {

  621.                 throw new Exception('输入数据不符合格式1');

  622.             }

  623. 

  624.             //(2)修改住宿费

  625.             $hotel_one = self::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0, 'expense_subject_id' => 466]);

  626.             $hotel_one->attributes = ['update_time' => date('Y-m-d H:i:s', time()), 'expense_value' => $hotel_expense,];

  627.             $res = $hotel_one->update();

  628.             if (!$res) {

  629.                 throw new Exception('输入数据不符合格式2');

  630.             }

  631. 

  632.             //(3)修改停车费

  633.             $park_one = self::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0, 'expense_subject_id' => 467]);

  634.             $park_one->attributes = ['update_time' => date('Y-m-d H:i:s', time()), 'expense_value' => $park_expense,];

  635.             $res = $park_one->update();

  636.             if (!$res) {

  637.                 throw new Exception('输入数据不符合格式3');

  638.             }

  639. 

  640.             //(4)修改报账状态

  641.             $bus_order_one = BusOrder::findOne(['bus_number' => $bus_number, 'cancel_flag' => 0]);

  642.             $bus_order_one->attributes = ['update_time' => date('Y-m-d H:i:s', time()), 'finance_status' => 445];

  643.             $res = $bus_order_one->update();

  644.             if (!$res) {

  645.                 throw new Exception('输入数据不符合格式4');

  646.             }

  647.             $transaction->commit();

  648.             $result = true;

  649.         } catch (Exception $e) {

  650.             # 回滚事务

  651.             $result = false;

  652.         }

  653.         #endregion

  654.         return $result;

  655.     }

  656. 

  657.     /**

  658.      * Function Description:获取结束最大值

  659.      * Function Name: getExpenseMaxEndValue

  660.      * @param int $bus_res_id 巴士资源id

  661.      * @param int $expense_subject_id 费用类型id

  662.      *

  663.      * @return mixed

  664.      *

  665.      * @author 邱颂

  666.      */

  667.     public function getExpenseMaxEndValue($bus_res_id, $expense_subject_id)

  668.     {

  669. //        $expense_info = self::find()

  670. //            ->select([

  671. //                'MAX(end_value) as max_value'

  672. //            ])

  673. //            ->where([

  674. //                'and',

  675. //                ['=', 'bus_res_id', $bus_res_id],

  676. //                ['=', 'expense_subject_id', $expense_subject_id],

  677. //            ])

  678. //            ->groupBy(['bus_res_id', 'expense_subject_id'])

  679. //            ->asArray()

  680. //            ->one();

  681. //        return $expense_info["max_value"];

  682.         $end_milege = self::find()

  683.             ->select('rbe.end_value')

  684.             ->from(RunBusExpenses::tableName() . ' as rbe')

  685.             ->innerJoin(BusOrder::tableName() . ' as bo', 'rbe.bus_number = bo.bus_number')

  686.             ->where(['and', ['=', 'rbe.cancel_flag', '0'], ['=', 'bo.cancel_flag', '0'], ['=', 'rbe.bus_res_id', $bus_res_id], ['=', 'rbe.expense_subject_id', $expense_subject_id], ['=', 'bo.run_status', '438']])

  687.             ->orderBy(['bo.run_date' => SORT_DESC, 'bo.start_time' => SORT_DESC])

  688.             ->asArray()

  689.             ->one();

  690.         return ($end_milege == false || !isset($end_milege['end_value'])) ? false : intval($end_milege['end_value']);

  691.     }

  692. 

  693.     /**

  694.      * Function Description:获取上个月与本月的司贴列表

  695.      * Function Name: getDriverSubsidyList

  696.      * @param int $driver_id 司机id

  697.      *

  698.      * @return array

  699.      *

  700.      * @author 张帅

  701.      */

  702.     public function getDriverSubsidyList($driver_id)

  703.     {

  704.         #region 要返回的数组

  705.         $result = [

  706.             'pre' => [

  707.                 'day_name' => date('n', strtotime("-1 month")) . '月',

  708.                 'total_expense_value' => 0,

  709.                 'subsidy_list' => [],

  710.             ],

  711.             'now' => [

  712.                 'day_name' => date('n') . '月',

  713.                 'total_expense_value' => 0,

  714.                 'subsidy_list' => [],

  715.             ],

  716.         ];

  717.         #endregion

  718. 

  719.         #region 获取司贴列表

  720.         $driver_subsidy_list = self::find()

  721.             ->select([

  722.                 'run_date',

  723.                 'bus_number',

  724.                 'task_name' => BusOrder::find()->select('itinerary_name')->where('bus_number = e.bus_number')->limit(1),//任务名称

  725.                 'expense_value',

  726.             ])

  727.             ->where([

  728.                 'and',

  729.                 ['=', 'bus_driver_res_id', $driver_id],

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

  731.                 ['=', 'expense_subject_id', 464],

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

  733.             ])

  734.             ->from(self::tableName() . ' as e')

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

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

  737.         #endregion

  738. 

  739.         #region 分组装入

  740.         if (count($driver_subsidy_list) > 0) {

  741.             foreach ($driver_subsidy_list as $key => $vel) {

  742.                 $vel_month = date('n', strtotime($vel['run_date']));

  743.                 $vel_day = date('j', strtotime($vel['run_date']));

  744.                 $vel['run_day'] = $vel_day . '日';

  745.                 $arr_key = $vel_month != date('n') ? 'pre' : 'now';

  746.                 $result[$arr_key]['subsidy_list'][] = $vel;

  747.                 $result[$arr_key]['total_expense_value'] += $vel['expense_value'];

  748.             }

  749.         }

  750.         #endregion

  751. 

  752.         return $result;

  753.     }

  754. 

  755.     /**

  756.      * 通过车辆的资源id获取到结束的最大公里数

  757.      * @param $bus_res_id 司机资源id

  758.      * @author 傅冬荣

  759.      */

  760.     public function getLastMilegeByBusResId($bus_res_id)

  761.     {

  762. //        $end_milege = self::find()

  763. //            ->select('MAX(end_value) as end_value')

  764. //            ->where(['and',['=','cancel_flag',0],['=','bus_res_id',$bus_res_id],['=','expense_subject_id',462]])

  765. //            ->asArray()

  766. //            ->one();

  767.         $end_milege = self::find()

  768.             ->select('rbe.end_value')

  769.             ->from(RunBusExpenses::tableName() . ' as rbe')

  770.             ->innerJoin(BusOrder::tableName() . ' as bo', 'rbe.bus_number = bo.bus_number')

  771.             ->where(['and', ['=', 'rbe.cancel_flag', '0'], ['=', 'bo.cancel_flag', '0'], ['=', 'rbe.bus_res_id', $bus_res_id], ['=', 'rbe.expense_subject_id', '462'], ['=', 'bo.run_status', '438']])

  772.             ->orderBy(['bo.run_date' => SORT_DESC, 'TIME_FORMAT(bo.start_time,"%H:%i")' => SORT_DESC])

  773.             ->asArray()

  774.             ->all();

  775. 

  776.         return !$end_milege ? 0 : intval($end_milege[0]['end_value']);

  777.     }

  778. 

  779.     /**

  780.      * 通过bus_number获取到该行程的开始里程数

  781.      * @author 傅冬荣

  782.      */

  783.     public function getStartMilegeByBusNumber($bus_number)

  784.     {

  785.         $start_value = self::find()

  786.             ->select('start_value')

  787.             ->where(['and', ['=', 'cancel_flag', 0], ['=', 'bus_number', $bus_number], ['=', 'expense_subject_id', 462]])

  788.             ->asArray()

  789.             ->one();

  790.         return intval($start_value['start_value']);

  791.     }

  792. 

  793.     /**

  794.      * 通过司机姓名或者日期来获取报账列表

  795.      * @param $driver_name 司机姓名

  796.      * @param $bus_no 车牌号

  797.      * @param $run_date 开车日期

  798.      * * @author 傅冬荣

  799.      */

  800.     public function getExpensesListByBusNumber($bus_number)

  801.     {

  802. 

  803.         $filter = ['and', ['=', 'rbe.cancel_flag', 0]];

  804.         $filter[] = ['=', 'rbe.bus_number', $bus_number];

  805.         $expenses_list = self::find()

  806.             ->select(['rbe.update_time', 'rbe.update_user_id', 'rbe.run_date', 'rbe.bus_number', 'rbe.bus_res_id', 'rbe.bus_driver_res_id', 'dt.type_name', 'expense_subject_id', 'expense_value', 'start_value', 'end_value'])

  807.             ->from(RunBusExpenses::tableName() . ' as rbe')

  808.             ->innerJoin(DictType::tableName() . ' as dt', 'rbe.expense_subject_id = dt.id')

  809.             ->filterWhere($filter)

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

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

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

  813. 

  814.         return $expenses_list;

  815.     }

  816. }