账户:订单结束,在快速、购药类型下,不统计坐班医生收益

This commit is contained in:
wucongxing 2024-01-19 14:25:45 +08:00
parent 8393a73c41
commit 53bfdc1c99

View File

@ -93,6 +93,14 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
return Result::DROP; return Result::DROP;
} }
// 获取医生数据
$params = array();
$params['doctor_id'] = $order_inquiry['doctor_id'];
$user_doctor = UserDoctor::getOne($params);
if (empty($user_doctor)){
Log::getInstance("queue-AutoFinishInquiry")->error("医生为空");
return Result::DROP;
}
Db::beginTransaction(); Db::beginTransaction();
try { try {
@ -110,22 +118,28 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
return Result::ACK; return Result::ACK;
} }
// 处理统计问题 /**
* 处理统计问题。规则:
* 1、金额大于0
* 2、快速、购药类型下非坐班医生
*/
if ($order_inquiry['amount_total'] > 0) { if ($order_inquiry['amount_total'] > 0) {
// 处理医生账户总表 if (in_array($order_inquiry['inquiry_type'],[1,3]) && $user_doctor['is_platform_deep_cooperation'] == 0){
$res = $this->handleDoctorAccount($order_inquiry); // 处理医生账户总表
if (!$res) { $res = $this->handleDoctorAccount($order_inquiry);
Db::rollBack(); if (!$res) {
Log::getInstance("queue-AutoFinishInquiry")->error("处理医生账户总表失败"); Db::rollBack();
return Result::REQUEUE; Log::getInstance("queue-AutoFinishInquiry")->error("处理医生账户总表失败");
} return Result::REQUEUE;
}
// 处理医生账户表-日 // 处理医生账户表-日
$res = $this->handleDoctorAccountDay($order_inquiry); $res = $this->handleDoctorAccountDay($order_inquiry);
if (!$res) { if (!$res) {
Db::rollBack(); Db::rollBack();
Log::getInstance("queue-AutoFinishInquiry")->error("处理医生账户表-日失败"); Log::getInstance("queue-AutoFinishInquiry")->error("处理医生账户表-日失败");
return Result::REQUEUE; return Result::REQUEUE;
}
} }
} }
@ -187,6 +201,8 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
*/ */
protected function handleDoctorAccount(array|object $order_inquiry): bool protected function handleDoctorAccount(array|object $order_inquiry): bool
{ {
$amount_total = bcmul($order_inquiry['amount_total'],0.75,8);
$params = array(); $params = array();
$params['doctor_id'] = $order_inquiry['doctor_id']; $params['doctor_id'] = $order_inquiry['doctor_id'];
$doctor_account = DoctorAccount::getOne($params); $doctor_account = DoctorAccount::getOne($params);
@ -194,8 +210,8 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
// 首次 // 首次
$data = array(); $data = array();
$data['doctor_id'] = $order_inquiry['doctor_id']; $data['doctor_id'] = $order_inquiry['doctor_id'];
$data['total_amount'] = $order_inquiry['amount_total'] * 0.75; $data['total_amount'] = $amount_total;
$data['balance_account'] = $order_inquiry['amount_total'] * 0.75; $data['balance_account'] = $amount_total;
$data['applied_withdrawal_amount'] = 0; $data['applied_withdrawal_amount'] = 0;
$data['actual_withdrawal_amount'] = 0; $data['actual_withdrawal_amount'] = 0;
$data['income_tax'] = 0; $data['income_tax'] = 0;
@ -206,12 +222,13 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
} else { } else {
// 非首次 // 非首次
// 总金额(已结束订单的总金额) // 总金额(已结束订单的总金额)
$params = array(); $params = array();
$params['account_id'] = $doctor_account['account_id']; $params['account_id'] = $doctor_account['account_id'];
DoctorAccount::inc($params, 'total_amount', $order_inquiry['amount_total'] * 0.75); DoctorAccount::inc($params, 'total_amount', (float)$amount_total);
// 账户余额 // 账户余额
DoctorAccount::inc($params, 'balance_account', $order_inquiry['amount_total'] * 0.75); DoctorAccount::inc($params, 'balance_account', (float)$amount_total);
} }
return true; return true;
} }
@ -223,6 +240,8 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
*/ */
protected function handleDoctorAccountDay(array|object $order_inquiry): bool protected function handleDoctorAccountDay(array|object $order_inquiry): bool
{ {
$amount_total = bcmul($order_inquiry['amount_total'],0.75,8);
$params = array(); $params = array();
$params['doctor_id'] = $order_inquiry['doctor_id']; $params['doctor_id'] = $order_inquiry['doctor_id'];
$params['date'] = date('Y-m-d', strtotime($order_inquiry['created_at'])); $params['date'] = date('Y-m-d', strtotime($order_inquiry['created_at']));
@ -235,7 +254,7 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
$data['month'] = date('m', strtotime($order_inquiry['created_at'])); $data['month'] = date('m', strtotime($order_inquiry['created_at']));
$data['day'] = date('d', strtotime($order_inquiry['created_at'])); $data['day'] = date('d', strtotime($order_inquiry['created_at']));
$data['date'] = date('Y-m-d', strtotime($order_inquiry['created_at'])); $data['date'] = date('Y-m-d', strtotime($order_inquiry['created_at']));
$data['total_amount'] = $order_inquiry['amount_total'] * 0.75; $data['total_amount'] = $amount_total;
$doctor_account_day = DoctorAccountDay::addDoctorAccountDay($data); $doctor_account_day = DoctorAccountDay::addDoctorAccountDay($data);
if (empty($doctor_account_day)) { if (empty($doctor_account_day)) {
return false; return false;
@ -244,7 +263,7 @@ class AutoFinishInquiryDelayDirectConsumer extends ConsumerMessage
// 非当日首次 // 非当日首次
$params = array(); $params = array();
$params['account_detail_id'] = $doctor_account_day['account_detail_id']; $params['account_detail_id'] = $doctor_account_day['account_detail_id'];
DoctorAccountDay::inc($params, 'total_amount', $order_inquiry['amount_total'] * 0.75); DoctorAccountDay::inc($params, 'total_amount', (float)$amount_total);
} }
return true; return true;