gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增自动开具处方。修改ca对接

Browse Source
This commit is contained in:
wucongxing 2023-04-21 13:39:17 +08:00
parent 739286e54a
commit 298283b3fe
13 changed files with 682 additions and 121 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
app/Amqp/Consumer/AssignPharmacistConsumer.php
View File

@ -4,17 +4,23 @@ declare(strict_types=1);
namespace App\Amqp\Consumer;
use App\Model\OrderInquiry;
use App\Model\OrderPrescription;
use App\Model\UserDoctor;
use App\Model\UserPatient;
use App\Model\UserPharmacist;
use App\Services\MessagePush;
use App\Utils\Log;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db;
use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
/**
* 分配药师
* 分配药师-暂时废弃，现修改为创建处方时分配
*/
#[Consumer(exchange: 'amqp.direct', routingKey: 'AssignPharmacist', queue: 'assign.pharmacist.queue', nums: 1)]
class AssignPharmacistConsumer extends ConsumerMessage
@ -23,33 +29,52 @@ class AssignPharmacistConsumer extends ConsumerMessage
{
Log::getInstance()->error("开始执行 分配药师 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
Db::beginTransaction();
try {
// 获取订单-处方表数据
$params = array();
$params['order_prescription_id'] = $data['order_prescription_id'];
$order_prescription = OrderPrescription::getOne($params);
if (empty($order_prescription)) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行失败：未查询到对应处方订单数据");
Log::getInstance()->info("分配药师队列执行结束：未查询到对应处方订单数据");
return Result::DROP;// 销毁
}
// 检测处方状态（1:待审核 3:待使用 4:已失效 5:已使用）
if ($order_prescription['prescription_status'] != 1) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行失败：处方状态错误，当前为" .$order_prescription['prescription_status']);
Log::getInstance()->info("分配药师队列执行结束：处方状态非待审核，当前为" . $order_prescription['prescription_status']);
return Result::ACK;// 销毁
}
// 检测药师审核状态
if ($order_prescription['pharmacist_audit_status'] == 1) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行失败：药师审核状态为已通过");
Log::getInstance()->error("分配药师队列执行结束：药师审核状态为已通过");
return Result::ACK;// 销毁
}
// 获取医生数据
$params = array();
$params['doctor_id'] = $order_prescription['doctor_id'];
$user_doctor = UserDoctor::getOne($params);
if (empty($user_doctor)) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行结束：缺少医生数据");
return Result::ACK;// 销毁
}
// 获取用户数据
$params = array();
$params['patient_id'] = $order_prescription['patient_id'];
$user_patient = UserPatient::getOne($params);
if (empty($user_patient)) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行结束：缺少患者数据");
return Result::ACK;// 销毁
}
Db::beginTransaction();
try {
// 分配药师
$params = array();
$params['pharmacist_id'] = "534534546";
@ -57,6 +82,10 @@ class AssignPharmacistConsumer extends ConsumerMessage
if (empty($user_pharmacist)) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行失败：药师数据错误");
// 分配失败，按照驳回处理
$this->reject($data['order_prescription_id'], $user_doctor['user_id'], $user_patient['user_id'], $order_prescription['order_inquiry_id']);
return Result::DROP;// 销毁
}
@ -72,6 +101,10 @@ class AssignPharmacistConsumer extends ConsumerMessage
} catch (\Exception $e) {
Db::rollBack();
Log::getInstance()->error("分配药师队列执行失败原因：" . $e->getMessage());
// 分配失败，按照驳回处理
$this->reject($data['order_prescription_id'], $user_doctor['user_id'], $order_prescription['order_inquiry_id']);
return Result::DROP; // 重回队列
}
@ -79,4 +112,37 @@ class AssignPharmacistConsumer extends ConsumerMessage
return Result::ACK;
}
/**
* 分配失败
* @param string $order_prescription_id
* @param string $doctor_user_id
* @param string $order_inquiry_id
* @return void
*/
public function reject(string $order_prescription_id, string $doctor_user_id, string $patient_user_id, string $order_inquiry_id): void
{
try {
$params = array();
$params['order_prescription_id'] = $order_prescription_id;
$data = array();
$data['pharmacist_audit_status'] = 2;
$data['pharmacist_verify_time'] = date('Y-m-d H:i:s', time());
$data['pharmacist_fail_reason'] = "请联系平台客服，请勿重开处方";
OrderPrescription::edit($params, $data);
// 医生-开具的处方审核未通过
$MessagePush = new MessagePush($doctor_user_id, $order_inquiry_id);
$MessagePush->prescriptionVerifyFail($order_prescription_id);
// 患者-处方审核未通过
$MessagePush = new MessagePush($patient_user_id, $order_inquiry_id);
$MessagePush->patientPrescriptionVerifyFail();
} catch (\Exception $e) {
Log::getInstance()->error("分配药师队列执行失败原因：" . $e->getMessage());
}
}
}

360
app/Amqp/Consumer/AutoPharmacistCaVerifyConsumer.php
View File

@ -4,12 +4,30 @@ declare(strict_types=1);
namespace App\Amqp\Consumer;
use App\Amqp\Producer\PrescriptionExpiredDelayDirectProducer;
use App\Constants\HttpEnumCode;
use App\Exception\BusinessException;
use App\Model\OrderInquiry;
use App\Model\OrderPrescription;
use App\Model\OrderPrescriptionFile;
use App\Model\OrderPrescriptionProduct;
use App\Model\UserDoctor;
use App\Model\UserPatient;
use App\Model\UserPharmacist;
use App\Services\CaService;
use App\Services\ImService;
use App\Services\MessagePush;
use App\Services\OrderPrescriptionService;
use App\Utils\Log;
use Hyperf\Amqp\Producer;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db;
use Hyperf\Redis\Redis;
use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
/**
* 药师自动签章审核
@ -20,22 +38,199 @@ class AutoPharmacistCaVerifyConsumer extends ConsumerMessage
{
public function consumeMessage($data, AMQPMessage $message): string
{
Log::getInstance()->error("开始执行 药师自动签章审核 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
Log::getInstance("queue-AutoPharmacistCaVerify")->error("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE));
Db::beginTransaction();
try {
// 检测入参参数
$res = $this->checkParams($data);
if (!$res) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：执行参数错误");
return Result::ACK;
}
// 获取处方数据
$params = array();
$params['order_prescription_id'] = $data['order_prescription_id'];
$order_prescription = OrderPrescription::getOne($params);
if (empty($order_prescription)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：处方数据错误");
return Result::ACK;
}
// 检测处方数据
$res = $this->checkPrescriptionData($order_prescription);
if (!empty($res)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $res);
return Result::ACK;
}
// 获取问诊订单数据
$params = array();
$params['order_inquiry_id'] = $order_prescription['order_inquiry_id'];
$order_inquiry = OrderInquiry::getOne($params);
if (empty($order_inquiry)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：问诊订单数据错误");
return Result::ACK;
}
// 检测问诊订单数据
$res = $this->checkOrderInquiryData($order_inquiry);
if (!empty($res)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $res);
return Result::ACK;
}
// 获取医生数据
$params = array();
$params['doctor_id'] = $order_prescription['doctor_id'];
$user_doctor = UserDoctor::getOne($params);
if (empty($user_doctor)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：医生数据错误");
return Result::ACK;
}
// 获取用户数据
$params = array();
$params['patient_id'] = $order_prescription['patient_id'];
$user_patient = UserPatient::getOne($params);
if (empty($user_patient)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：患者数据错误");
return Result::ACK;
}
// 获取药师数据
$params = array();
$params['pharmacist_id'] = $order_prescription['pharmacist_id'];
$user_pharmacist = UserPharmacist::getOne($params);
if (empty($user_pharmacist)) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：药师数据错误");
return Result::ACK;
}
// 获取处方商品数据
$product_name = "";
$params = array();
$params['order_prescription_id'] = $order_prescription['order_prescription_id'];
$order_prescription_product = OrderPrescriptionProduct::getList($params);
if (!empty($order_prescription_product)){
$product_name = array_column($order_prescription_product->toArray(),'product_name');
if (count($product_name) > 1){
$product_name = implode('、',$product_name);
}else{
$product_name = $product_name[0];
}
}
// 订单-处方
$OrderPrescriptionService = new OrderPrescriptionService();
// 下载医生签章文件
Db::beginTransaction();
try {
// 检测执行次数
$res = $this->checkHandleNumber($data['prescription_file_id']);
if (!$res) {
// 超出最大执行次数或检测错误
// 自动驳回
$OrderPrescriptionService->rejectPrescription(
$data['order_prescription_id'],
$user_doctor['user_id'],
$user_patient['user_id'],
$order_prescription['order_inquiry_id'],
"请联系平台客服，请勿重开处方"
);
return Result::ACK;
}
// 获取处方文件数据
$params = array();
$params['prescription_file_id'] = $data['prescription_file_id'];
$params['order_prescription_id'] = $data['order_prescription_id'];
$order_prescription_file = OrderPrescriptionFile::getOne($params);
if (empty($order_prescription_file)) {
Db::rollBack();
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：处方文件数据错误");
return Result::REQUEUE;
}
// 检测处方文件数据
$res = $this->checkPrescriptionFileData($order_prescription_file);
if (!empty($res)) {
Db::rollBack();
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $res);
return Result::REQUEUE;
}
// 下载医生的签章pdf并上传至oss
$prescription_pdf_oss_path = $this->downCaPdfToOss($order_prescription, $user_doctor['user_id'],2,$order_prescription_file['doctor_ca_file_id']);
if (!$prescription_pdf_oss_path) {
Db::rollBack();
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $prescription_pdf_oss_path);
return Result::REQUEUE;
}
// 药师/医院签章
$OrderPrescriptionService = new OrderPrescriptionService();
$prescription_open_result = $OrderPrescriptionService->openPrescription($data['order_prescription_id'],$user_pharmacist['user_id'],);
if (empty($prescription_open_result['file_id'])){
Db::rollBack();
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：处方开具失败");
return Result::REQUEUE;
}
// 下载医院的签章pdf并上传至oss
$prescription_pdf_oss_path = $this->downCaPdfToOss($order_prescription, $user_doctor['user_id'],3,$prescription_open_result['file_id']);
if (!$prescription_pdf_oss_path) {
Db::rollBack();
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：" . $prescription_pdf_oss_path);
return Result::REQUEUE;
}
// 修改处方文件表，添加prescription_pdf_oss_path字段
$this->modifyOrderPrescriptionFile($data['prescription_file_id'],$prescription_pdf_oss_path,$prescription_open_result['file_id']);
Db::commit();
Log::getInstance()->error("药师自动签章审核 队列执行成功");
Log::getInstance("queue-AutoPharmacistCaVerify")->info("成功");
} catch (\Exception $e) {
Db::rollBack();
Log::getInstance()->error("药师自动签章审核 队列执行失败原因：" . $e->getMessage());
Log::getInstance("queue-AutoPharmacistCaVerify")->error("异常错误：" . $e->getMessage());
return Result::REQUEUE; // 重回队列
}
// 发送消息
try {
// 药师审核成功
// 发送IM消息-处方已开具
$imService = new ImService();
$imService->prescriptionIssued($order_inquiry,$user_doctor['user_id'],$order_inquiry['user_id'],$product_name,(string)$data['order_prescription_id'],7);
// 发送站内、短信消息-患者的处方被药师审核通过
$MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->patientPrescriptionVerifyPass();
// 站内、订阅失败发送短信-医生开具的处方审核通过
// 发送目标不同，重新实例化
$MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->prescriptionVerifySuccess();
// 添加处方过期队列
$data = array();
$data['order_prescription_id'] = (string)$order_prescription['order_prescription_id'];
$message = new PrescriptionExpiredDelayDirectProducer($data);
$message->setDelayMs(1000 * 60 * 10);
$producer = $this->container->get(Producer::class);
$res = $producer->produce($message);
if (!$res) {
Log::getInstance("queue-AutoPharmacistCaVerify")->error("添加处方过期队列失败！");
return Result::ACK;
}
}catch(\Exception $e){
Log::getInstance("queue-AutoPharmacistCaVerify")->error("发送消息异常错误：" . $e->getMessage());
return Result::ACK;
}
return Result::ACK;
}
@ -55,4 +250,157 @@ class AutoPharmacistCaVerifyConsumer extends ConsumerMessage
}
return true;
}
/**
* 检测处方数据
* @param array|object $order_prescription
* @return string
*/
protected function checkPrescriptionData(array|object $order_prescription): string
{
// 验证处方状态
if ($order_prescription['prescription_status'] == 2) {
// 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
return "处方已审核";
}
if ($order_prescription['prescription_status'] == 3) {
// 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
return "处方已审核并失效";
}
if ($order_prescription['prescription_status'] == 4) {
// 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
return "处方已审核并使用";
}
// 验证处方审核状态
if ($order_prescription['pharmacist_audit_status'] != 0) {
// 药师审核状态（0:审核中 1:审核成功 2:审核驳回）
return "处方已审核";
}
// 处方平台审核状态
if ($order_prescription['platform_audit_status'] != 0) {
// 处方平台审核状态（0:审核中 1:审核成功 2:审核驳回）
return "处方已审核";
}
return "";
}
/**
* 检测问诊订单数据
* @param array|object $order_inquiry
* @return string
*/
protected function checkOrderInquiryData(array|object $order_inquiry): string
{
if (in_array($order_inquiry['inquiry_status'], [1, 2, 3, 7])) {
// 问诊订单状态（1:待支付 2:待分配 3:待接诊 4:已接诊 5:已完成 6:已结束 7:已取消）
return "问诊订单状态错误，无法继续审核";
}
return "";
}
/**
* 检测处方文件数据
* @param array|object $order_prescription_file
* @return string
*/
protected function checkPrescriptionFileData(array|object $order_prescription_file): string
{
if (empty($order_prescription_file['doctor_ca_file_id'])) {
return "缺少医生签章pdf文件id";
}
return "";
}
/**
* 检测执行次数
* @param string $prescription_file_id
* @return bool
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/
protected function checkHandleNumber(string $prescription_file_id): bool
{
try {
$redis = $this->container->get(Redis::class);
$redis_key = "AutoPharmacistCaVerify" . $prescription_file_id;
$redis_value = $redis->get($redis_key);
if (empty($redis_value)) {
$redis->set($redis_key, 1, 60 * 60 * 24 * 5);
return true;
}
// 问诊订单执行退款次数过多
if ($redis_value > 3) {
// 加入短信队列,通知管理员
return false;
}
$redis->incr($redis_key);
} catch (\Exception $e) {
return false;
}
return true;
}
/**
* 下载签章pdf并上传至oss
* @param array|object $order_prescription
* @param string $user_id 用户id
* @param string|int $user_type 用户类型 1:患者 2：医生 3：药师
* @param string $file_id
* @return string|bool oss地址|false（存在异常时）
*/
protected function downCaPdfToOss(array|object $order_prescription, string $user_id, string|int $user_type, string $file_id): string|bool
{
try {
$user = array();
$user['user_id'] = $user_id;
$user['user_type'] = $user_type;
$CaService = new CaService($order_prescription, $user);
// 下载签章pdf并上传至oss
if ($user_type == 2){
return $CaService->downCaPdfToOss($file_id,1);
}else{
return $CaService->downCaPdfToOss($file_id,2);
}
} catch (\Exception $e) {
return false;
}
}
/**
* 修改处方文件表
* @param string $prescription_file_id 主键id
* @param string $prescription_pdf_oss_path pdf的oss地址
* @param string $hospital_ca_file_id 医院签章文件id
* @return void
*/
protected function modifyOrderPrescriptionFile(string $prescription_file_id,string $prescription_pdf_oss_path,string $hospital_ca_file_id): void
{
try {
$params = array();
$params['prescription_file_id'] = $prescription_file_id;
$data = array();
$data['hospital_ca_file_id'] = $hospital_ca_file_id;
$data['prescription_pdf_oss_path'] = $prescription_pdf_oss_path;
OrderPrescriptionFile::edit($params,$data);
}catch(\Exception $e){
// 失败不做处理
Log::getInstance("queue-AutoPharmacistCaVerify")->error("错误：修改处方文件表失败" . $e->getMessage());
}
}
}

2
app/Amqp/Producer/AssignPharmacistProducer.php
View File

@ -8,7 +8,7 @@ use Hyperf\Amqp\Annotation\Producer;
use Hyperf\Amqp\Message\ProducerMessage;
/**
* 分配药师
* 分配药师-暂时废弃，现修改为创建处方时分配
*/
#[Producer(exchange: 'amqp.direct', routingKey: 'AssignPharmacist')]
class AssignPharmacistProducer extends ProducerMessage

7
app/Controller/TestController.php
View File

@ -59,13 +59,13 @@ class TestController extends AbstractController
// $this->test_9();
// $this->test_10();
// $this->test_11();
$this->test_5();
// $this->test_5();
// $this->test_1();
// $this->test_11();
// $this->test_12();
// $this->test_13();
// $this->test_14();
// $this->test_15();
$this->test_15();
}
// 获取云证书-首次
@ -800,6 +800,9 @@ class TestController extends AbstractController
}
public function test_15(){
Log::getInstance("auto-pharmacist-ca-verify-queue")->info("ninhao");
dump(111);die;
$wg = new \Hyperf\Utils\WaitGroup();
$channel = new Channel();
$wg->add(2);

14
app/Model/OrderPrescriptionFile.php
View File

@ -14,14 +14,12 @@ use Hyperf\Snowflake\Concern\Snowflake;
* @property int $prescription_file_id 主键id
* @property int $order_prescription_id 订单-处方id
* @property string $doctor_ca_file_id 医生签章pdf文件id（可请求ca下载）
* @property string $doctor_pdf_oss_path 医生签章pdf文件oss路径（null表示未下载）
* @property int $doctor_pdf_down_status 签章文件下载状态（0:未下载 1:已下载 2:下载失败）
* @property string $doctor_pdf_down_fail_reason 下载失败原因
* @property string $doctor_img_oss_path 医生签章img文件oss路径
* @property string $hospital_ca_file_id 医院签章pdf文件id（可请求ca下载）
* @property string $hospital_pdf_oss_path 医院签章pdf文件oss路径（null表示未下载）
* @property int $hospital_pdf_down_status 签章文件下载状态（0:未下载 1:已下载 2:下载失败）
* @property string $hospital_pdf_down_fail_reason 下载失败原因
* @property string $prescription_img_oss_path 签章img文件oss路径
* @property string $prescription_pdf_oss_path 签章pdf文件oss路径
* @property string $doctor_sign_image_path 医生签名图片oss地址
* @property string $pharmacist_sign_image_path 药师签名图片oss地址
* @property string $hospital_sign_image_path 医院签名图片oss地址
* @property \Carbon\Carbon $created_at 创建时间
* @property \Carbon\Carbon $updated_at 修改时间
*/
@ -37,7 +35,7 @@ class OrderPrescriptionFile extends Model
/**
* The attributes that are mass assignable.
*/
protected array $fillable = ['prescription_file_id', 'order_prescription_id', 'doctor_ca_file_id', 'doctor_pdf_oss_path', 'doctor_pdf_down_status', 'doctor_pdf_down_fail_reason', 'doctor_img_oss_path', 'hospital_ca_file_id', 'hospital_pdf_oss_path', 'hospital_pdf_down_status', 'hospital_pdf_down_fail_reason', 'created_at', 'updated_at'];
protected array $fillable = ['prescription_file_id', 'order_prescription_id', 'doctor_ca_file_id', 'hospital_ca_file_id', 'prescription_img_oss_path', 'prescription_pdf_oss_path', 'doctor_sign_image_path', 'pharmacist_sign_image_path', 'hospital_sign_image_path', 'created_at', 'updated_at'];
protected string $primaryKey = "prescription_file_id";

99
app/Services/CaService.php
View File

@ -59,6 +59,13 @@ class CaService extends BaseService
// 信用代码
protected string $org_num;
// 处方pdf本地地址
protected string $prescription_pdf_local_path;
// 处方pdf oss地址
protected string $prescription_pdf_oss_path;
/**
* 初始化类，此处会获取基础数据
* @param array|object $order_prescription 处方表数据
@ -215,6 +222,12 @@ class CaService extends BaseService
// 关闭channel通道
$channel->close();
}
// 处方pdf本地地址
$this->prescription_pdf_local_path = "./runtime/file/prescription/" . $order_prescription_id . '.pdf';
// 处方pdf oss地址
$this->prescription_pdf_oss_path = "applet/prescription/" . $order_prescription_id. '.pdf';
}
/**
@ -382,8 +395,8 @@ class CaService extends BaseService
// 上传处方图片至oss
$oss = new Oss();
$prescription_img_oss_filename = "applet/prescription/" . $order_prescription['order_prescription_id'] . '.' . 'jpg';
$prescription_img_url = $oss->putObject($prescription_img_oss_filename, $img_result);
$prescription_img_url = '/' . $prescription_img_url;
$prescription_img_oss_path = $oss->putObject($prescription_img_oss_filename, $img_result);
$prescription_img_oss_path = '/' . $prescription_img_oss_path;
// 图片生成pdf
$pdf = new TCPDF('P', 'mm', 'A4', true, 'UTF-8', false);
@ -402,37 +415,78 @@ class CaService extends BaseService
// 图片生成的处方pdf存储为本地文件 runtime目录下
$pdf->Output($prescription_pdf_local_path . $prescription_pdf_local_filename, "F");
return $prescription_img_url;
return $prescription_img_oss_path;
}
/**
* 下载医生开具的处方pdf
* 下载Oss中处方pdf
* 存在：当次发版内医生开具后，药师再去开具
* 不存在：医生开具后，进行发版过,此时需重新下载
* @param string $order_prescription_id
* @param string $doctor_pdf_oss_path
* @return void
*/
public function downDoctorPrescriptionPdf(string $order_prescription_id,string $doctor_pdf_oss_path): void
public function downOssPdfToLocal(): void
{
$local_path = "./runtime/file/prescription/" . $order_prescription_id . '.' . 'pdf';
$res = file_exists($local_path);
$res = file_exists($this->prescription_pdf_local_path);
if (!$res){
// 去除第一个/ oss不识别
$prescription_pdf_path = substr($doctor_pdf_oss_path, 1, strlen($doctor_pdf_oss_path) - 1);
// $prescription_pdf_path = substr($doctor_pdf_oss_path, 1, strlen($doctor_pdf_oss_path) - 1);
$oss = new Oss();
$oss->getObjectToLocal($prescription_pdf_path, $local_path);
$oss->getObjectToLocal($this->prescription_pdf_oss_path, $this->prescription_pdf_local_path);
}
}
/**
* 下载CA中pdf至本地文件
* @param string $file_id
* @param int $type 类型 1：用户 2：医院
* @return void
*/
public function downCaPdfToLocal(string $file_id,int $type): void
{
$CaOnline = new CaOnline();
if ($type == 1){
// 用户
$prescription_pdf_result = $CaOnline->getSignedFile($this->user_entity_id, $file_id);
}else{
// 医院
$prescription_pdf_result = $CaOnline->getSignedFile($this->hospital_entity_id, $file_id);
}
$file = fopen($this->prescription_pdf_local_path, "w");
fwrite($file, $prescription_pdf_result);
fclose($file);
}
/**
* 下载CA中的pdf并上传至oss
* @param string $file_id
* @param int $type 类型 1：用户 2：医院
* @return string oss地址
*/
public function downCaPdfToOss(string $file_id,int $type): string
{
$CaOnline = new CaOnline();
if ($type == 1){
// 用户
$prescription_pdf_result = $CaOnline->getSignedFile($this->user_entity_id, $file_id);
}else{
// 医院
$prescription_pdf_result = $CaOnline->getSignedFile($this->hospital_entity_id, $file_id);
}
// 上传oss
$oss = new Oss();
return $oss->putObject($this->prescription_pdf_oss_path, $prescription_pdf_result);
}
/**
* 进行处方pdf签章
* @param array|object $order_prescription
* @param string $type 类型 1：医院 2：医生 3：药师
* @return string 文件id
*/
public function addSignPdf(array|object $order_prescription,string $type): string
public function addSignPdf(string $type): string
{
// 下载签名图片
if ($type == 1){
@ -529,9 +583,9 @@ class CaService extends BaseService
}
// 打开处方pdf文件
$pdf_file = fopen("./runtime/file/prescription/" . $order_prescription['order_prescription_id'] . ".pdf", 'r');
$pdf_file = fopen($this->prescription_pdf_local_path, 'r');
if (!$pdf_file) {
throw new BusinessException("处方图片打开失败");
throw new BusinessException("处方pdf打开失败");
}
// 处方pdf进行签章
@ -543,22 +597,9 @@ class CaService extends BaseService
throw new BusinessException("处方签章失败");
}
fclose($pdf_file);
return $sign_pdf_result[0]['fileId'];
}
/**
* 下载签章pdf图片
* @param string $file_id
* @param string $order_prescription_id
* @return void
*/
public function downCaPdf(string $file_id,string $order_prescription_id): void
{
$CaOnline = new CaOnline();
$prescription_pdf_result = $CaOnline->getSignedFile($this->user_entity_id, $file_id);
$file = fopen("./runtime/file/prescription/" . $order_prescription_id . '.pdf', "w");
fwrite($file, $prescription_pdf_result);
fclose($file);
}
}

4
app/Services/ImService.php
View File

@ -437,10 +437,10 @@ class ImService extends BaseService
* @param string $patient_user_id
* @param string $product_name
* @param string $order_prescription_id
* @param string $message_type 6/7
* @param string|int $message_type 6/7
* @return void
*/
public function prescriptionIssued(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id, string $product_name, string $order_prescription_id, string $message_type): void
public function prescriptionIssued(array|object $order_inquiry, string $doctor_user_id, string $patient_user_id, string $product_name, string $order_prescription_id, string|int $message_type): void
{
try {
// 发送消息

42
app/Services/MessagePush.php
View File

@ -450,6 +450,48 @@ class MessagePush extends BaseService
return true;
}
/**
* 患者-处方审核未通过
* 站内
* @return bool
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/
public function patientPrescriptionVerifyFail(): bool
{
try {
// 获取医生数据
$params = array();
$params['doctor_id'] = $this->order_inquiry['doctor_id'];
$user_doctor = UserDoctor::getOne($params);
if (empty($user_doctor)){
throw new BusinessException("加入推送队列失败:医生数据为空");
}
// 站内
// 服务消息
$data = array();
$data['user_id'] = $this->user['user_id'];
$data['notice_type'] = 3;
$data['notice_system_type'] = 1;
$data['from_name'] = "肝胆小秘书";
$data['notice_brief_title'] = "{$user_doctor['user_name']}医生为您开具的电子处方未通过审核，点击查看详情。";
$data['notice_title'] = "{$user_doctor['user_name']}医生为您开具的电子处方未通过审核，点击查看详情。";
$data['notice_content'] = "{$user_doctor['user_name']}医生为您开具的电子处方未通过审核，您可以稍后重新发起问诊申请开具处方。";
$message = new SendStationMessageProducer($data);
$producer = ApplicationContext::getContainer()->get(Producer::class);
$result = $producer->produce($message);
if (!$result) {
throw new BusinessException("加入推送队列失败" . json_encode($data,JSON_UNESCAPED_UNICODE));
}
} catch (\Exception $e) {
throw new BusinessException("加入推送队列失败" . $e->getMessage());
}
return true;
}
/**
* 优惠劵发放
* 站内

66
app/Services/OrderPrescriptionService.php
View File

@ -30,6 +30,8 @@ use Extend\Prescription\Prescription;
use Hyperf\Contract\LengthAwarePaginatorInterface;
use Hyperf\Utils\WaitGroup;
use Intervention\Image\ImageManager;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
use Swoole\Coroutine\Channel;
use TCPDF;
@ -127,11 +129,11 @@ class OrderPrescriptionService extends BaseService
* 开具处方
* 医生-正常开具
* 药师-先开具药师处方，再开具医院签章
* @param string $order_prescription_id
* @param string $user_id
* @param string $order_prescription_id 处方id
* @param string $user_id 用户id
* @return array
*/
public function openPrescription(string $order_prescription_id, string $user_id,string $doctor_pdf_oss_path = ""): array
public function openPrescription(string $order_prescription_id, string $user_id): array
{
try {
// 获取用户数据
@ -166,38 +168,34 @@ class OrderPrescriptionService extends BaseService
// 医生
if ($user['user_type'] == 2) {
// 生成处方图片+处方图片生成pdf
$prescription_img_url = $CaService->createPrescriptionImgPdf($order_prescription);
$prescription_img_oss_path = $CaService->createPrescriptionImgPdf($order_prescription);
}
// 药师
// 药师-医院签章
if ($user['user_type'] == 3) {
// 检测处方图片
if (empty($doctor_pdf_oss_path)){
throw new BusinessException("处方文件错误");
}
// 获取医院云证书签名+验证云证书签名
$CaService->getVerifyCertSign($order_prescription,2);
// 下载医生开具的处方pdf
$CaService->downDoctorPrescriptionPdf($order_prescription['order_prescription_id'],$doctor_pdf_oss_path);
// 下载医生开具的处方pdf至本地，文件存在时不进行下载
$CaService->downOssPdfToLocal();
}
// 进行处方pdf签章
$file_id = $CaService->addSignPdf($order_prescription,$user['user_type']);
$file_id = $CaService->addSignPdf($user['user_type']);
// 药师-医院签章
if ($user['user_type'] == 3) {
// 药师端时，需要进行系统签章
// 把药师签章的pdf存储至本地文件
// 下载药师签章pdf图片
$CaService->downCaPdf($file_id,$order_prescription['order_prescription_id']);
$CaService->downCaPdfToLocal($file_id,1);
// 进行处方pdf签章
$file_id = $CaService->addSignPdf($order_prescription,$user['user_type']);
$file_id = $CaService->addSignPdf($user['user_type']);
}
$result = array();
$result['prescription_img_url'] = $prescription_img_url ?? "";
$result['prescription_img_oss_path'] = $prescription_img_oss_path ?? "";
$result['file_id'] = $file_id;
return $result;
@ -481,4 +479,40 @@ class OrderPrescriptionService extends BaseService
return true;
}
/**
* 药师驳回处方
* @param string $order_prescription_id 处方id
* @param string $doctor_user_id 医生user_id
* @param string $patient_user_id 患者user_id
* @param string $order_inquiry_id 问诊订单id
* @param string $pharmacist_fail_reason 驳回原因
* @return void
*/
public function rejectPrescription(string $order_prescription_id, string $doctor_user_id, string $patient_user_id, string $order_inquiry_id,string $pharmacist_fail_reason = ""): void
{
try {
$params = array();
$params['order_prescription_id'] = $order_prescription_id;
$data = array();
$data['pharmacist_audit_status'] = 2;
$data['pharmacist_verify_time'] = date('Y-m-d H:i:s', time());
$data['pharmacist_fail_reason'] = $pharmacist_fail_reason;
OrderPrescription::edit($params, $data);
// 医生-开具的处方审核未通过
$MessagePush = new MessagePush($doctor_user_id, $order_inquiry_id);
$MessagePush->prescriptionVerifyFail($order_prescription_id);
// 患者-处方审核未通过
$MessagePush = new MessagePush($patient_user_id, $order_inquiry_id);
$MessagePush->patientPrescriptionVerifyFail();
} catch (\Exception $e) {
throw new BusinessException($e->getMessage());
} catch (NotFoundExceptionInterface|ContainerExceptionInterface $e) {
throw new BusinessException($e->getMessage());
}
}
}

12
app/Services/PatientOrderService.php
View File

@ -10,6 +10,7 @@ use App\Model\Hospital;
use App\Model\OrderInquiry;
use App\Model\OrderInquiryCase;
use App\Model\OrderPrescription;
use App\Model\OrderPrescriptionFile;
use App\Model\OrderPrescriptionProduct;
use App\Model\OrderProduct;
use App\Model\OrderProductItem;
@ -1199,7 +1200,6 @@ class PatientOrderService extends BaseService
$fields = [
'order_prescription_id',
'prescription_status',
'prescription_img',
'pharmacist_id',
'doctor_id',
];
@ -1214,7 +1214,15 @@ class PatientOrderService extends BaseService
return fail();
}
$order_prescription['prescription_img'] = addAliyunOssWebsite($order_prescription['prescription_img']);
// 获取处方文件数据
$params = array();
$params['order_prescription_id'] = $order_prescription_id;
$order_prescription_file = OrderPrescriptionFile::getOne($params);
if (empty($order_prescription_file)){
return fail();
}
$order_prescription['prescription_img_oss_path'] = addAliyunOssWebsite($order_prescription_file['prescription_img_oss_path']);
// 获取处方中医生签名
$params = array();

40
app/Services/UserDoctorService.php
View File

@ -1378,7 +1378,7 @@ class UserDoctorService extends BaseService
// 开具处方
$OrderPrescriptionService = new OrderPrescriptionService();
$prescription_open_result = $OrderPrescriptionService->openPrescription($order_prescription->order_prescription_id,$user_info['user_id']);
if (empty($prescription_open_result['prescription_img_url']) || empty($prescription_open_result['file_id'])){
if (empty($prescription_open_result['prescription_img_oss_path']) || empty($prescription_open_result['file_id'])){
Db::rollBack();
return fail(HttpEnumCode::SERVER_ERROR, "处方开具失败");
}
@ -1394,6 +1394,7 @@ class UserDoctorService extends BaseService
// 修改处方表
$data = array();
$data['pharmacist_id'] = "534534546"; // 药师id 现固定为此用户，后续可以考虑开启队列
$data['is_auto_phar_verify'] = $system_config['is_auto_phar_verify_prescription'];// 是否药师自动审核（0:否 1:是）
$data['doctor_created_time'] = date('Y-m-d H:i:s',time());
@ -1405,13 +1406,14 @@ class UserDoctorService extends BaseService
$data = array();
$data['order_prescription_id'] = $order_prescription->order_prescription_id;
$data['doctor_ca_file_id'] = $prescription_open_result['file_id'];
$data['doctor_img_oss_path'] = $prescription_open_result['prescription_img_url'];
$data['prescription_img_oss_path'] = $prescription_open_result['prescription_img_oss_path'];
$order_prescription_file = OrderPrescriptionFile::addOrderPrescriptionFile($data);
if (empty($order_prescription_file)){
Db::rollBack();
return fail(HttpEnumCode::SERVER_ERROR, "处方开具失败");
}
// 检测药师自动审核配置开启状态
if ($system_config['is_auto_phar_verify_prescription'] == 1){
// 添加药师自动签章审核队列
$data = array();
@ -1432,18 +1434,6 @@ class UserDoctorService extends BaseService
$ImService = new ImService();
$ImService->pharmacistVerify($order_inquiry,(string)$order_prescription->order_prescription_id,$product_name,$user_doctor['user_id'],$order_inquiry['user_id']);
// 加入分配药师队列
$data = array();
$data['order_prescription_id'] = $order_prescription['order_prescription_id'];
$message = new AssignPharmacistProducer($data);
$producer = ApplicationContext::getContainer()->get(Producer::class);
$result = $producer->produce($message);
if (!$result) {
Db::rollBack();
return fail(HttpEnumCode::SERVER_ERROR);
}
Db::commit();
} catch (\Exception $e) {
Db::rollBack();
@ -1671,14 +1661,7 @@ class UserDoctorService extends BaseService
$params['order_inquiry_id'] = $order_inquiry_id;
OrderInquiry::edit($params,$data);
// 发送IM消息-医生接诊
$imService = new ImService();
$imService->doctorInquiry($order_inquiry,$user_info['user_id'],$order_inquiry['user_id']);
// 发送站内、订阅、短信消息-医生已接诊
$MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->patientAcceptedInquiry();
// 添加自动完成队列
if ($order_inquiry['inquiry_type'] == 1 || $order_inquiry['inquiry_type'] == 3){
// 专家问诊-公益问诊
$time = 1000 * 60 * 60;
@ -1690,7 +1673,6 @@ class UserDoctorService extends BaseService
$time = 1000 * 60 * 30;
}
// 添加自动完成队列
$data = array();
$data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
@ -1708,6 +1690,18 @@ class UserDoctorService extends BaseService
return fail(HttpEnumCode::SERVER_ERROR, $e->getMessage());
}
try {
// 发送IM消息-医生接诊
$imService = new ImService();
$imService->doctorInquiry($order_inquiry,$user_info['user_id'],$order_inquiry['user_id']);
// 发送站内、订阅、短信消息-医生已接诊
$MessagePush = new MessagePush($order_inquiry['user_id'],$order_inquiry['order_inquiry_id']);
$MessagePush->patientAcceptedInquiry();
}catch(\Exception $e){
return success([],HttpEnumCode::HTTP_SUCCESS,$e->getMessage());
}
return success();
}

17
app/Services/UserPharmacistService.php
View File

@ -8,6 +8,7 @@ use App\Amqp\Producer\PrescriptionExpiredDelayDirectProducer;
use App\Constants\HttpEnumCode;
use App\Model\OrderInquiry;
use App\Model\OrderPrescription;
use App\Model\OrderPrescriptionFile;
use App\Model\OrderPrescriptionProduct;
use App\Model\User;
use App\Model\UserDoctor;
@ -100,7 +101,6 @@ class UserPharmacistService extends BaseService
"prescription_status",
"pharmacist_audit_status",
"platform_audit_status",
"prescription_img",
"doctor_id",
];
@ -112,6 +112,16 @@ class UserPharmacistService extends BaseService
return fail();
}
// 获取处方文件数据
$params = array();
$params['order_prescription_id'] = $order_prescription_id;
$order_prescription_file = OrderPrescriptionFile::getOne($params);
if (empty($order_prescription_file)){
return fail();
}
$order_prescription['prescription_img_oss_path'] = addAliyunOssWebsite($order_prescription_file['prescription_img_oss_path']);
$order_prescription['prescription_img'] = addAliyunOssWebsite($order_prescription['prescription_img']);
// 获取处方中医生签名
@ -134,6 +144,7 @@ class UserPharmacistService extends BaseService
*/
public function putPrescriptionVerify(): array
{
return fail(HttpEnumCode::SERVER_ERROR,"暂时无法人工审核");
$user_info = $this->request->getAttribute("userInfo") ?? [];
$order_prescription_id = $this->request->route('order_prescription_id');
@ -164,7 +175,7 @@ class UserPharmacistService extends BaseService
// 验证处方状态
if ($order_prescription['prescription_status'] != 1){
// 处方状态（1:待审核 3:待使用 4:已失效 5:已使用）
// 处方状态（1:待审核 2:待使用 3:已失效 4:已使用）
return fail(HttpEnumCode::HTTP_ERROR,"处方审核失败");
}
@ -332,4 +343,6 @@ class UserPharmacistService extends BaseService
return success($result);
}
}

14
extend/Alibaba/Oss.php
View File

@ -161,4 +161,18 @@ class Oss
}
}
/**
* 判断指定的文件是否存在
* @param string $filename
* @return bool
*/
public function doesObjectExist(string $filename): bool
{
try {
$ossClient = $this->createClient();
return $ossClient->doesObjectExist($this->config['bucket'], $filename);
}catch(\Exception $e) {
throw new BusinessException($e->getMessage());
}
}
}