Merge branch '20230223_xt_api_new_branch' of http://git.shengws.com/csx/XT_New into 20230223_xt_api_new_branch

controllers/mobile_api_controllers/patient_api_controller.go

@@ -685,7 +685,7 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 		privateDrugConfig, _ := service.GetDrugSetByUserOrgId(adminUserInfo.Org.Id)
 
 		storeHouseConfig, _ := service.GetAllStoreHouseConfig(adminUserInfo.Org.Id)
-		fmt.Println("drugStockConfig.IsOpen32232323232", drugStockConfig.IsOpen)
+
 		if drugStockConfig.IsOpen == 1 {
 			if groupno > 0 {
 				advices, _ := service.FindAllDoctorAdviceByGoroupNo(adminUserInfo.Org.Id, groupno)
@@ -1253,9 +1253,38 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 								if config.IsOpen != 1 {
 									if pharmacyConfig.IsOpen == 1 && medical.IsPharmacy == 0 {
 										service.HisDrugsDelivery(adminInfo.Org.Id, creater, &advice)
+										fmt.Println("处方1111111111111")
+										if adminInfo.Org.Id == 3877 || adminInfo.Org.Id == 10265 {
+											//查询该药品是否有出库记录
+											flowMap, _ := service.GetDrugFLowByAdviceById(advice.DrugId, advice.PatientId, advice.UserOrgId, advice.AdviceDate)
+											if len(flowMap) == 0 {
+												service.UpdateHisAdviceById(advice.ID)
+												c.ServeSuccessJSON(map[string]interface{}{
+													"msg":    "6",
+													"advice": advice,
+													"ids":    ids,
+												})
+												return
+											}
+										}
 									}
 									if pharmacyConfig.IsOpen != 1 {
+										fmt.Println("处方我33333333323")
 										service.HisDrugsDelivery(adminInfo.Org.Id, creater, &advice)
+										if adminInfo.Org.Id == 3877 || adminInfo.Org.Id == 10265 {
+											//查询该药品是否有出库记录
+											flowMap, _ := service.GetDrugFLowByAdviceById(advice.DrugId, advice.PatientId, advice.UserOrgId, advice.AdviceDate)
+											fmt.Println("flowMap----------", flowMap)
+											if len(flowMap) == 0 {
+												service.UpdateHisAdviceById(advice.ID)
+												c.ServeSuccessJSON(map[string]interface{}{
+													"msg":    "6",
+													"advice": advice,
+													"ids":    ids,
+												})
+												return
+											}
+										}
 									}
 
 									//更新字典里面的库存
@@ -1275,6 +1304,7 @@ func (c *PatientApiController) ExecDoctorAdvice() {
 							}
 						}
 					}
+
 					//
 					//if config.IsOpen == 1 && item.UserOrgId == 10088 {
 					//

service/warhouse_service.go

@@ -7477,3 +7477,15 @@ func UpdateAutomaticReduce(patient_id int64, record_date int64, good_id int64, p
 	err := XTWriteDB().Model(&models.AutomaticReduceDetail{}).Where("patient_id = ? and record_time =? and good_id = ? and project_id = ? and status = 1", patient_id, record_date, good_id, project_id).Update(map[string]interface{}{"status": 0}).Error
 	return err
 }
+
+func GetDrugFLowByAdviceById(drug_id int64, patient_id int64, user_org_id int64, advice_date int64) (outInfo []*models.DrugWarehouseOutInfo, err error) {
+
+	err = XTReadDB().Where("drug_id = ? and patient_id = ? and org_id = ? and sys_record_time = ? and status= 1", drug_id, patient_id, user_org_id, advice_date).Find(&outInfo).Error
+	return outInfo, err
+}
+
+func UpdateHisAdviceById(id int64) error {
+
+	err := XTWriteDB().Model(&models.HisDoctorAdviceInfo{}).Where("id = ?", id).Updates(map[string]interface{}{"execution_time": "", "execution_staff": "", "execution_state": 2}).Error
+	return err
+}