From 9852b8534beaf77e0556b332f68c4a2786c33e0b Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E7=90=A6?= Date: Wed, 29 Apr 2026 16:52:58 +0800 Subject: [PATCH] =?UTF-8?q?=E9=BB=98=E8=AE=A4=E5=89=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controllers/PrescripDetailController.php | 389 ++++++++++++++++-- .../v1/controllers/PrescriptionController.php | 33 +- 2 files changed, 387 insertions(+), 35 deletions(-) diff --git a/service/modules/v1/controllers/PrescripDetailController.php b/service/modules/v1/controllers/PrescripDetailController.php index e6902cd..1866510 100644 --- a/service/modules/v1/controllers/PrescripDetailController.php +++ b/service/modules/v1/controllers/PrescripDetailController.php @@ -4,15 +4,21 @@ namespace service\modules\v1\controllers; use common\core\BaseAppController; use common\helpers\FuncHelper; +use common\models\oldDb\PackageMethod; use common\models\oldDb\ChineseRepice; +use common\models\oldDb\Drug; use common\models\oldDb\GranularRepice; +use common\models\oldDb\ProcessRule; +use common\models\oldDb\ProcessRuleNote; use common\models\oldDb\Prescription; use common\models\oldDb\PrescriptionChinese; use common\models\oldDb\PrescriptionGranular; use common\models\oldDb\PrescriptionWest; use common\models\oldDb\WestRepice; +use common\modelsgii\oldDb\ChineseMedicine; use common\services\PrescriptionService; use yii\base\Exception; +use yii\helpers\Json; /** * @doc-module 处方详情 @@ -103,6 +109,354 @@ class PrescripDetailController extends BaseAppController * 开处方-常用方 */ public function actionCommonUse() + { + return $this->commonUseResponseLikeXkApi(\Yii::$app->request->post()); + } + + /** + * @doc-name 开处方-常用方详情(中药) + * @doc-param int id 处方id + */ + public function actionCommonChinese() + { + return $this->commonChineseDetailLikeXkApi(\Yii::$app->request->post()); + } + + /** + * @doc-name 开处方-常用方详情(颗粒药) + * @doc-param int id 处方id + */ + public function actionCommonGranular() + { + return $this->commonGranularDetailLikeXkApi(\Yii::$app->request->post()); + } + + + /** + * @doc-name 开处方-常用方详情（西药） + * @doc-param int id 处方id + */ + public function actionCommonWest() + { + return $this->commonWestDetailLikeXkApi(\Yii::$app->request->post()); + } + + protected function commonUseResponseLikeXkApi(array $post): array + { + $this->requestValidate($post, [ + ['store_id', 'required'], + ]); + $storeId = (int) $post['store_id']; +// $checkPrice = !isset($post['check_price']) || (int) $post['check_price'] === 1; + $checkPrice = 1; + + $chinese = PrescriptionChinese::find()->where([ + 'type' => 2, + 'store_id' => $storeId, + ])->andWhere(['su_id' => \Yii::$app->user->identity->id])->asArray()->all(); + $west = PrescriptionWest::find()->where([ + 'type' => 2, + 'store_id' => $storeId, + ])->andWhere(['su_id' => \Yii::$app->user->identity->id])->asArray()->all(); + $granular = PrescriptionGranular::find()->where([ + 'type' => 2, + 'store_id' => $storeId, + ])->andWhere(['su_id' => \Yii::$app->user->identity->id])->asArray()->all(); + if (!$chinese && !$west && !$granular) { + throw new Exception('没有常用方'); + } + + $chineseRepice = []; + foreach ($chinese as &$chineseRow) { + $ids = array_filter(explode(',', (string) $chineseRow['cr_ids'])); + $recipes = ChineseRepice::find()->where(['in', 'id', $ids])->asArray()->all(); + $syncResult = $this->syncChineseCommonRecipesWithStorePrices($storeId, $chineseRow, $recipes, $checkPrice); + $recipes = $syncResult['recipes']; + $chineseRow['price_adjusted'] = $syncResult['price_adjusted'] ? 1 : 0; + if (!empty($recipes[0])) { + $this->attachChineseMetaForList($chineseRow, $recipes[0]); + } + foreach ($recipes as &$recipeRow) { + $recipeRow = $this->normalizeChineseRecipeRow($recipeRow); + } + unset($recipeRow); + $chineseRepice[] = $recipes; + } + unset($chineseRow); + + $westRepice = []; + foreach ($west as $westRow) { + $ids = array_filter(explode(',', (string) $westRow['wr_ids'])); + $recipes = WestRepice::find()->where(['in', 'id', $ids]) + ->with(['usetime', 'usetype', 'frequency', 'westUnit']) + ->asArray()->all(); + $westRepice[] = $this->buildCommonWestRecipeRowsLikeXkApi($recipes); + } + + $granularRepice = []; + foreach ($granular as $granularRow) { + $ids = array_filter(explode(',', (string) $granularRow['gr_ids'])); + $recipes = GranularRepice::find()->where(['in', 'id', $ids])->asArray()->all(); + $granularRepice[] = $this->buildCommonGranularRecipeRowsLikeXkApi($recipes); + } + + return [ + 'chin_prescription' => $chinese, + 'chinese' => $chineseRepice, + 'west_prescription' => $west, + 'west' => $westRepice, + 'granular_prescription' => $granular, + 'granular' => $granularRepice, + ]; + } + + protected function commonChineseDetailLikeXkApi(array $post): array + { + $this->requestValidate($post, [ + ['id', 'required'], + ['store_id', 'required'], + ]); + $chinese = PrescriptionChinese::find()->where([ + 'id' => $post['id'], + 'store_id' => $post['store_id'], + ])->andWhere(['type' => 2])->asArray()->one(); + if (!$chinese) { + throw new Exception('没有该处方'); + } + + $ids = array_filter(explode(',', (string) $chinese['cr_ids'])); + $recipes = ChineseRepice::find()->where(['in', 'id', $ids])->asArray()->all(); + $syncResult = $this->syncChineseCommonRecipesWithStorePrices((int) $chinese['store_id'], $chinese, $recipes, true); + $recipes = $syncResult['recipes']; + foreach ($recipes as &$recipeRow) { + $recipeRow = $this->normalizeChineseRecipeRow($recipeRow); + } + unset($recipeRow); + + return $recipes; + } + + protected function commonGranularDetailLikeXkApi(array $post): array + { + $this->requestValidate($post, [ + ['id', 'required'], + ['store_id', 'required'], + ]); + $granular = PrescriptionGranular::find()->where([ + 'id' => $post['id'], + 'store_id' => $post['store_id'], + ])->andWhere(['type' => 2])->asArray()->one(); + if (!$granular) { + throw new Exception('没有该处方'); + } + $ids = array_filter(explode(',', (string) $granular['gr_ids'])); + $recipes = GranularRepice::find()->where(['in', 'id', $ids])->asArray()->all(); + return $this->buildCommonGranularRecipeRowsLikeXkApi($recipes); + } + + protected function commonWestDetailLikeXkApi(array $post): array + { + $this->requestValidate($post, [ + ['id', 'required'], + ['store_id', 'required'], + ]); + $west = PrescriptionWest::find()->where([ + 'id' => $post['id'], + 'store_id' => $post['store_id'], + ])->andWhere(['type' => 2])->asArray()->one(); + if (!$west) { + throw new Exception('没有该处方'); + } + $ids = array_filter(explode(',', (string) $west['wr_ids'])); + $recipes = WestRepice::find()->where(['in', 'id', $ids]) + ->with(['usetime', 'usetype', 'frequency', 'westUnit']) + ->asArray()->all(); + return $this->buildCommonWestRecipeRowsLikeXkApi($recipes); + } + + protected function syncChineseCommonRecipesWithStorePrices(int $storeId, array $prescriptionRow, array $recipeRows, bool $persist): array + { + $priceAdjusted = false; + if (empty($recipeRows)) { + return ['recipes' => $recipeRows, 'price_adjusted' => false]; + } + + $time = time(); + $transaction = \Yii::$app->db->beginTransaction(); + try { + foreach ($recipeRows as &$recipeRow) { + $contentList = Json::decode($recipeRow['content'] ?? '', true); + if (!is_array($contentList)) { + continue; + } + $cmIds = array_values(array_filter(explode(',', (string) ($recipeRow['cm_id'] ?? '')))); + $dosage = max(1, (int) ($recipeRow['dosage'] ?? 1)); + $drugTotal = 0.0; + $recipeChanged = false; + foreach ($contentList as $idx => &$drugRow) { + $drugRow = $this->normalizeChineseDrugRow($drugRow); + $drugId = (int) ($drugRow['drug_id'] ?? $drugRow['id'] ?? 0); + $price = (float) ($drugRow['price'] ?? 0); + $buyPrice = (float) ($drugRow['buy_price'] ?? 0); + if ($drugId > 0) { + $drug = Drug::find()->alias('d')->select('d.*')->where([ + 'd.id' => $drugId, + ])->joinWith(['drugStoreDrug dsd' => function ($q) { + $q->andWhere(['dsd.status' => 2]); + }])->joinWith(['drugStoreRelation dsr' => function ($q) use ($storeId) { + $q->andWhere(['dsr.store_id' => $storeId]); + $q->andWhere(['dsr.status' => 2]); + }])->asArray()->one(); + if ($drug && !empty($drug['drugStoreRelation'])) { + $latestPrice = (float) $drug['drugStoreRelation']['price']; + $latestBuyPrice = (float) $drug['drugStoreRelation']['buy_price']; + if ($latestPrice !== $price || $latestBuyPrice !== $buyPrice) { + $priceAdjusted = true; + $recipeChanged = true; + } + $price = $latestPrice; + $buyPrice = $latestBuyPrice; + $drugRow['price'] = $latestPrice; + $drugRow['buy_price'] = $latestBuyPrice; + if ($persist && isset($cmIds[$idx]) && is_numeric($cmIds[$idx])) { + ChineseMedicine::updateAll([ + 'price' => $latestPrice, + 'buy_price' => $latestBuyPrice, + 'updated_at' => $time, + ], ['id' => (int) $cmIds[$idx]]); + } + } + } + $drugTotal += (float) ($drugRow['number'] ?? 0) * $price * $dosage; + } + unset($drugRow); + + if ($persist && $recipeChanged) { + $recipeRow['content'] = Json::encode($contentList); + $recipeRow['total_price'] = round($drugTotal, 4); + ChineseRepice::updateAll([ + 'content' => $recipeRow['content'], + 'total_price' => $recipeRow['total_price'], + 'updated_at' => $time, + ], ['id' => $recipeRow['id']]); + } else { + $recipeRow['content'] = Json::encode($contentList); + $recipeRow['total_price'] = round($drugTotal, 4); + } + } + unset($recipeRow); + + if ($persist && $priceAdjusted && !empty($prescriptionRow['id'])) { + PrescriptionChinese::updateAll(['updated_at' => $time], ['id' => $prescriptionRow['id']]); + } + $transaction->commit(); + return ['recipes' => $recipeRows, 'price_adjusted' => $priceAdjusted]; + } catch (\Throwable $e) { + $transaction->rollBack(); + throw $e; + } + } + + protected function normalizeChineseRecipeRow(array $recipeRow): array + { + $contentList = Json::decode($recipeRow['content'] ?? '', true); + if (is_array($contentList)) { + foreach ($contentList as &$drugRow) { + $drugRow = $this->normalizeChineseDrugRow($drugRow); + } + unset($drugRow); + $recipeRow['content'] = Json::encode($contentList); + } + return $recipeRow; + } + + protected function normalizeChineseDrugRow(array $drugRow): array + { + $name = $drugRow['drug_name'] ?? ($drugRow['name'] ?? ''); + $drugRow['name'] = $name; + $drugRow['drug_name'] = $name; + if (isset($drugRow['way_id']) && !isset($drugRow['order'])) { + $drugRow['order'] = $drugRow['way_id']; + } + if (isset($drugRow['order']) && !isset($drugRow['way_id'])) { + $drugRow['way_id'] = $drugRow['order']; + } + if (!isset($drugRow['unit']) || empty($drugRow['unit'])) { + $drugRow['unit'] = ['name' => 'g']; + } + return $drugRow; + } + + protected function attachChineseMetaForList(array &$prescriptionRow, array $firstRecipeRow): void + { + $prescriptionRow['rule_type'] = (int) ($firstRecipeRow['deployment'] ?? 1); + $prescriptionRow['dosage'] = (int) ($firstRecipeRow['dosage'] ?? 7); + $prescriptionRow['day_dosage'] = (int) ($firstRecipeRow['consumption'] ?? 2); + $prescriptionRow['process_rule_id'] = (int) ($firstRecipeRow['process_rule_id'] ?? 0); + $prescriptionRow['process_rule_note'] = $firstRecipeRow['process_rule_note'] ?? ''; + $prescriptionRow['package_method_id'] = (int) ($firstRecipeRow['package_method_id'] ?? 0); + + if ($prescriptionRow['process_rule_id']) { + $processRule = ProcessRule::findOne($prescriptionRow['process_rule_id']); + $prescriptionRow['process_rule_name'] = $processRule ? $processRule->name : ''; + } + if ($prescriptionRow['process_rule_note']) { + $processRuleNote = ProcessRuleNote::find()->where(['note' => $prescriptionRow['process_rule_note']])->one(); + $prescriptionRow['process_rule_note_name'] = $processRuleNote ? $processRuleNote->note : $prescriptionRow['process_rule_note']; + } + if ($prescriptionRow['package_method_id']) { + $packageMethod = PackageMethod::findOne($prescriptionRow['package_method_id']); + $prescriptionRow['package_method_name'] = $packageMethod ? $packageMethod->name : ''; + } + } + + protected function buildCommonWestRecipeRowsLikeXkApi(array $recipeRows): array + { + foreach ($recipeRows as &$recipeRow) { + $content = Json::decode($recipeRow['content'] ?? '', true); + if (is_array($content)) { + $recipeRow['drug_name'] = $content['drug_name'] ?? ''; + $recipeRow['drug_id'] = $content['id'] ?? 0; + $recipeRow['image'] = $content['image'] ?? ''; + $recipeRow['price'] = $content['price'] ?? ($recipeRow['total_price'] ?? 0); + } + $recipeRow['frequency_id'] = $recipeRow['f_id'] ?? 0; + $recipeRow['unit_id'] = $recipeRow['wu_id'] ?? 0; + $recipeRow['number'] = $recipeRow['grain_number'] ?? ($recipeRow['number'] ?? 1); + } + unset($recipeRow); + return $recipeRows; + } + + protected function buildCommonGranularRecipeRowsLikeXkApi(array $recipeRows): array + { + foreach ($recipeRows as &$recipeRow) { + $contentList = Json::decode($recipeRow['content'] ?? '', true); + if (!is_array($contentList)) { + continue; + } + foreach ($contentList as &$drugRow) { + $name = $drugRow['drug_name'] ?? ($drugRow['name'] ?? ''); + $drugRow['name'] = $name; + $drugRow['drug_name'] = $name; + if (isset($drugRow['way_id']) && !isset($drugRow['order'])) { + $drugRow['order'] = $drugRow['way_id']; + } + if (isset($drugRow['order']) && !isset($drugRow['way_id'])) { + $drugRow['way_id'] = $drugRow['order']; + } + if (!isset($drugRow['unit']) || empty($drugRow['unit'])) { + $drugRow['unit'] = ['name' => 'g']; + } + } + unset($drugRow); + $recipeRow['content'] = Json::encode($contentList); + } + unset($recipeRow); + return $recipeRows; + } + + protected function actionCommonUseLegacy() { $post = \YII::$app->request->post(); @@ -134,14 +488,14 @@ class PrescripDetailController extends BaseAppController $westRepice[] = WestRepice::find()->where(['in', 'id', $ids])->with(['usetime', 'usetype', 'frequency', 'westUnit'])->asArray()->all(); } } - + if($granular){ foreach ($granular as $value) { $ids = explode(',', $value['gr_ids']); $granularRepice[] = GranularRepice::find()->where(['in', 'id', $ids])->asArray()->all(); } } - + return [ 'chin_prescription' => $chinese, 'chinese' => $chineseRepice, @@ -152,11 +506,7 @@ class PrescripDetailController extends BaseAppController ]; } - /** - * @doc-name 开处方-常用方详情(中药) - * @doc-param int id 处方id - */ - public function actionCommonChinese() + protected function actionCommonChineseLegacy() { $post = \Yii::$app->request->post(); $this->requestValidate($post,[ @@ -170,16 +520,10 @@ class PrescripDetailController extends BaseAppController throw new Exception('没有该处方'); } $ids = explode(',', $chinese['cr_ids']); - - $recipe = ChineseRepice::find()->where(['in', 'id', $ids])->asArray()->all(); - return $recipe; + return ChineseRepice::find()->where(['in', 'id', $ids])->asArray()->all(); } - /** - * @doc-name 开处方-常用方详情(颗粒药) - * @doc-param int id 处方id - */ - public function actionCommonGranular() + protected function actionCommonGranularLegacy() { $post = \Yii::$app->request->post(); $this->requestValidate($post,[ @@ -193,17 +537,10 @@ class PrescripDetailController extends BaseAppController throw new Exception('没有该处方'); } $ids = explode(',', $granular['gr_ids']); - - $recipe = GranularRepice::find()->where(['in', 'id', $ids])->asArray()->all(); - return $recipe; + return GranularRepice::find()->where(['in', 'id', $ids])->asArray()->all(); } - - /** - * @doc-name 开处方-常用方详情（西药） - * @doc-param int id 处方id - */ - public function actionCommonWest() + protected function actionCommonWestLegacy() { $post = \Yii::$app->request->post(); $this->requestValidate($post,[ @@ -217,9 +554,7 @@ class PrescripDetailController extends BaseAppController throw new Exception('没有该处方'); } $ids = explode(',', $west['wr_ids']); - - $recipe = WestRepice::find()->where(['in', 'id', $ids])->with(['usetime', 'usetype', 'frequency', 'westUnit'])->asArray()->all(); - return $recipe; + return WestRepice::find()->where(['in', 'id', $ids])->with(['usetime', 'usetype', 'frequency', 'westUnit'])->asArray()->all(); } /** diff --git a/service/modules/v1/controllers/PrescriptionController.php b/service/modules/v1/controllers/PrescriptionController.php index 0b7be98..7d54f4e 100644 --- a/service/modules/v1/controllers/PrescriptionController.php +++ b/service/modules/v1/controllers/PrescriptionController.php @@ -871,25 +871,42 @@ class PrescriptionController extends BaseAppController $drug_ids_str=implode(',',$drug_ids); $totalNum = 0; - foreach ($medicine as $value){ + $time = time(); + foreach ($medicine as &$value) { $drug = Drug::find()->alias('d')->select('d.*')->where([ - 'd.id' => $value['drug_id'] - ])->joinWith(['drugStoreDrug dsd' => function($q){ + 'd.id' => $value['drug_id'], + ])->joinWith(['drugStoreDrug dsd' => function ($q) { $q->andWhere(['dsd.status' => 2]); - }])->joinWith(['drugStoreRelation dsr' => function ($q) use ($store_id){ + }])->joinWith(['drugStoreRelation dsr' => function ($q) use ($store_id) { $q->andWhere(['dsr.store_id' => $store_id]); $q->andWhere(['dsr.status' => 2]); }])->asArray()->one(); - if(!$drug){ + if (!$drug) { throw new Exception('药品库存数据错误'); } + if (empty($drug['drugStoreRelation'])) { + throw new Exception('药品暂不售卖'); + } + $salePrice = $drug['drugStoreRelation']['price']; + $buyPrice = $drug['drugStoreRelation']['buy_price']; + ChineseMedicine::updateAll( + [ + 'price' => $salePrice, + 'buy_price' => $buyPrice, + 'updated_at' => $time, + ], + ['id' => $value['id']], + ); + $value['price'] = $salePrice; + $value['buy_price'] = $buyPrice; $drugNumber = (int) $value['number'] * (int) $param['dosage']; - if($drug['drugStoreDrug']['stock'] < $drugNumber){ - throw new Exception($value['name'].'库存数量不足'); + if ($drug['drugStoreDrug']['stock'] < $drugNumber) { + throw new Exception($value['name'] . '库存数量不足'); } $totalNum += $drugNumber; - $price+=$value['number'] * $value['price'] * $param['dosage']; + $price += $value['number'] * $salePrice * $param['dosage']; } + unset($value); $process_price = 0; $processRuleContent = '';