历史排班

controllers/his_api_controller.go

@@ -106,7 +106,93 @@ func HisManagerApiRegistRouters() {
 
 	beego.Router("/api/getfapiaonumber", &HisApiController{}, "get:GetFaPiaoNumber")
 
+	//beego.Router("/api/associationprescription", &HisApiController{}, "get:AssociationHisPrescription")
+	//beego.Router("/api/checkhispatient", &HisApiController{}, "get:CheckHisPatient")
+
 }
+
+//func (c *HisApiController) CheckHisPatient() {
+//	record_date := c.GetString("record_date")
+//	patient_id, _ := c.GetInt64("patient_id")
+//
+//	timeLayout := "2006-01-02"
+//	loc, _ := time.LoadLocation("Local")
+//	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_date+" 00:00:00", loc)
+//	if err != nil {
+//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+//		return
+//	}
+//	recordDateTime := theTime.Unix()
+//	adminInfo := c.GetAdminUserInfo()
+//	patients, _ := service.GetHisPatientInfoTwo(adminInfo.CurrentOrgId, patient_id, recordDateTime)
+//	if len(patients) > 1 {
+//		ps, _ := service.GetHisPrescriptionByHisPatientID(recordDateTime, adminInfo.CurrentOrgId, patient_id)
+//		if len(ps) > 0 {
+//			c.ServeSuccessJSON(map[string]interface{}{
+//				"status": 1,
+//				"msg":    "关联",
+//				"ps":     ps,
+//			})
+//		} else {
+//			c.ServeSuccessJSON(map[string]interface{}{
+//				"status": 0,
+//				"msg":    "无需关联",
+//			})
+//		}
+//	} else {
+//		c.ServeSuccessJSON(map[string]interface{}{
+//			"status": 0,
+//			"msg":    "无需关联",
+//		})
+//		return
+//	}
+//}
+//func (c *HisApiController) AssociationHisPrescription() {
+//	record_date, _ := c.GetInt64("record_date")
+//	his_patient_id, _ := c.GetInt64("his_patient_id")
+//	patient_id, _ := c.GetInt64("patient_id")
+//	p_ids := c.GetString("p_ids")
+//	p_ids_arr := strings.Split(p_ids, ",")
+//	his_patient, _ := service.GetHisPatientByIdThree(his_patient_id)
+//	if his_patient_id == 0 || his_patient.ID == 0 {
+//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+//		return
+//	}
+//	err := service.UpdateHisPrescriptionHisIDByPID(his_patient_id, patient_id, record_date, c.GetAdminUserInfo().CurrentOrgId, p_ids_arr)
+//	if err == nil {
+//		c.ServeSuccessJSON(map[string]interface{}{
+//			"msg": "关联处方成功",
+//		})
+//		return
+//	} else {
+//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+//		return
+//	}
+//}
+
+//func (c *HisApiController) AssociationHisPrescription() {
+//	record_date, _ := c.GetInt64("record_date")
+//	his_patient_id, _ := c.GetInt64("his_patient_id")
+//	patient_id, _ := c.GetInt64("patient_id")
+//	p_ids := c.GetString("p_ids")
+//	p_ids_arr := strings.Split(p_ids, ",")
+//	his_patient, _ := service.GetHisPatientByIdThree(his_patient_id)
+//	if his_patient_id == 0 || his_patient.ID == 0 {
+//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+//		return
+//	}
+//	err := service.UpdateHisPrescriptionHisIDByPID(his_patient_id, patient_id, record_date, c.GetAdminUserInfo().CurrentOrgId, p_ids_arr)
+//	if err == nil {
+//		c.ServeSuccessJSON(map[string]interface{}{
+//			"msg": "关联处方成功",
+//		})
+//		return
+//	} else {
+//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+//		return
+//	}
+//}
+
 func (c *HisApiController) GetFaPiaoNumber() {
 	max_order, _ := service.GetLastHisOrderTwo(c.GetAdminUserInfo().CurrentOrgId)
 	count, _ := strconv.ParseInt(max_order.FaPiaoNumber, 10, 64)
@@ -1845,11 +1931,16 @@ func (c *HisApiController) CreateHisPrescription() {
 								//查询该药品是否存在开药记录
 								advicelist, _ := service.GetHisAdviceListByDrugIdEight(drug_id, patient_id, recordDateTime, adviceId)
 
+								fmt.Println("wooooooooooooo", advicelist.ID)
+								fmt.Println("prescribingNumberUnit", prescribingNumberUnit)
+								fmt.Println("prescribingNumberUnit", drug.MinUnit)
+								fmt.Println("prescribingNumberUnit", drug.MaxUnit)
 								//新增处方
 								if advicelist.ID == 0 {
 									all_count, _ := strconv.ParseFloat(totals, 64)
 									if prescribingNumberUnit == drug.MinUnit {
-
+										fmt.Println("prescribing_number", prescribing_number)
+										fmt.Println("all_count", all_count)
 										if drug.IsUse != 1 {
 											if drug.IsProject == 0 || drug.IsProject == 2 {
 												if all_count == 0 {
@@ -2307,7 +2398,7 @@ func (c *HisApiController) CreateHisPrescription() {
 															var sum_in_count int64
 															warehouseInfo, _ := service.FindLastDrugWarehousingInfoByID(drug_id, storeConfig.DrugStorehouseOut)
 															sum_in_count = warehouseInfo.StockMaxNumber*drug.MinNumber + warehouseInfo.StockMinNumber
-
+															fmt.Println("sum_in_count", sum_in_count)
 															//如果修改的数量大于有库存的第一个批次
 															if number_count > sum_in_count {
 																c.ServeDynamicFailJsonSend(drug.DrugName + "该批次剩余库存不足,剩余库存:" + strconv.FormatInt(warehouseInfo.StockMaxNumber, 10) + drug.MaxUnit + strconv.FormatInt(warehouseInfo.StockMinNumber, 10) + drug.MinUnit)
@@ -9088,7 +9179,7 @@ func (c *HisApiController) GetFaPiaoData() {
 		"name":                                order.PsnName,            //姓名
 		"gender":                              patient.Gender,           //性别
 		"psn_cash_money":                      order.PsnCashPay,         //个人支付
-		"pay_way":                             "门诊",                     //结算方式
+		"pay_way":                             "门诊",                   //结算方式
 		"medfee_sumamt":                       order.MedfeeSumamt,       //总费用
 		"admin_user_name":                     admin.UserName,           //收款员
 		"order":                               order,
@@ -10793,12 +10884,25 @@ func (c *HisApiController) GetHisMonthChargePatientInfo() {
 	case_history, _ := service.GetHisPatientCaseHistoryInfo(admin.CurrentOrgId, patient_id, recordDateTime)
 	patientPrescriptionInfo, _ := service.FindPatientPrescriptionInfo(admin.CurrentOrgId, patient_id, recordDateTime, p_type, his_patient_id)
 
+	month_p_info, _ := service.FindPatientPrescriptionInfoTen(admin.CurrentOrgId, patient_id, startRecordDateTime, endRecordDateTime, p_type)
+
 	lastPatientPrescriptionInfo, _ := service.FindLastPatientPrescriptionInfoTwo(admin.CurrentOrgId, patient_id, recordDateTime, p_type)
 
 	doctors, _ := service.GetHisAdminUserDoctors(admin.CurrentOrgId)
 	//获取所有科室信息
 	department, _ := service.GetAllDepartMent(admin.CurrentOrgId)
 
+	var dia string
+	for _, item := range month_p_info {
+		if len(dia) == 0 {
+			dia = item.Diagnosis
+		} else {
+			dia = dia + "," + item.Diagnosis
+		}
+	}
+
+	dia_arr := removeDuplicates(strings.Split(dia, ","))
+	dia_arr = removeEmptyStrings(dia_arr)
 	c.ServeSuccessJSON(map[string]interface{}{
 		"his_info":            his_patient_info,
 		"xt_info":             xt_patient_info,
@@ -10810,10 +10914,37 @@ func (c *HisApiController) GetHisMonthChargePatientInfo() {
 		"doctors":             doctors,
 		"department":          department,
 		"settle_total":        settle_total,
+		"dia_arr":             dia_arr,
 	})
 	return
 }
 
+func removeEmptyStrings(input []string) []string {
+	var output []string
+
+	for _, s := range input {
+		if s != "" {
+			output = append(output, s)
+		}
+	}
+
+	return output
+}
+
+func removeDuplicates(input []string) []string {
+	seen := make(map[string]bool)
+	output := []string{}
+
+	for _, s := range input {
+		if _, exists := seen[s]; !exists {
+			seen[s] = true
+			output = append(output, s)
+		}
+	}
+
+	return output
+}
+
 func (c *HisApiController) GetHisMonthPatientInfo() {
 	patient_id, _ := c.GetInt64("patient_id")
 	his_patient_id, _ := c.GetInt64("his_patient_id")

controllers/self_drug_api_congtroller.go

@@ -115,6 +115,11 @@ func SelfDrugRouters() {
 	beego.Router("/api/stock/getdrugovercount", &SelfDrugApiController{}, "Get:GetDrugOverCount")
 
 	beego.Router("/api/stock/getdruginfolist", &SelfDrugApiController{}, "Get:GetDrugInventoryWarehouseInfoList")
+
+	beego.Router("/api/drug/getdrugflowdetailbyid", &SelfDrugApiController{}, "Get:GetDrugFlowDetailById")
+
+	//康允新版本
+	beego.Router("/api/stock/getpurchaseDrugQueryList", &SelfDrugApiController{}, "Get:GetPurchaseDrugQueryList")
 }
 
 func (this *SelfDrugApiController) GetCurrentPatient() {
@@ -4091,3 +4096,162 @@ func (this *SelfDrugApiController) GetInventoryDetailPrintList() {
 		"inventoryList": inventoryList,
 	})
 }
+
+func (this *SelfDrugApiController) GetDrugFlowDetailById() {
+
+	drug_id, _ := this.GetInt64("drug_id")
+
+	list, _ := service.GetDrugFlowDetailById(drug_id)
+
+	drugMedical, _ := service.GetBaseDrugMedical(drug_id)
+
+	for index, _ := range list {
+		if list[index].ConsumableType == 3 || list[index].ConsumableType == 2 || list[index].ConsumableType == 11 || list[index].ConsumableType == 12 || list[index].ConsumableType == 15 {
+			var count int64
+			if list[index].MaxUnit == drugMedical.MaxUnit && list[index].MaxUnit != list[index].MinUnit {
+				list[index].Count = list[index].Count * drugMedical.MinNumber
+			}
+
+			if index == 0 {
+				count = list[index].FlushOverCount - list[index].Count
+				service.UpdateDrugOverCount(list[index+1].ID, count)
+			}
+
+			if index >= 1 {
+				lastStockFlow, _ := service.GetLastDrugOverCount(list[index-1].ID)
+				count = lastStockFlow.FlushOverCount - list[index].Count
+				service.UpdateDrugOverCount(list[index].ID, count)
+			}
+
+		}
+		if list[index].ConsumableType == 7 || list[index].ConsumableType == 4 || list[index].ConsumableType == 1 || list[index].ConsumableType == 10 || list[index].ConsumableType == 13 {
+			if list[index].MaxUnit == drugMedical.MaxUnit && list[index].MaxUnit != list[index].MinUnit {
+				list[index].Count = list[index].Count * drugMedical.MinNumber
+			}
+			if index == 0 {
+				var count int64
+				count = list[index].OverCount + list[index].Count
+				service.UpdateDrugOverCount(list[index+1].ID, count)
+			}
+
+			if index >= 1 {
+				var count int64
+				lastStockFlow, _ := service.GetLastDrugOverCount(list[index-1].ID)
+				count = lastStockFlow.FlushOverCount + list[index].Count
+				service.UpdateDrugOverCount(list[index].ID, count)
+			}
+
+		}
+
+	}
+}
+
+func (this *SelfDrugApiController) GetPurchaseDrugQueryList() {
+
+	good_type, _ := this.GetInt64("good_type")
+
+	keyword := this.GetString("keyword")
+
+	page, _ := this.GetInt64("page")
+
+	limit, _ := this.GetInt64("limit")
+
+	start_time := this.GetString("start_time")
+	end_time := this.GetString("end_time")
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+
+	var startTime int64
+
+	if len(start_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		startTime = theTime.Unix()
+	}
+
+	var endTime int64
+	if len(end_time) > 0 {
+		theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+		if err != nil {
+			utils.ErrorLog(err.Error())
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		endTime = theTime.Unix()
+	}
+	var ids []int64
+	var infoIds []int64
+
+	manufacturers, _ := service.GetManufacturerListByKeyword(orgId, keyword)
+	for _, it := range manufacturers {
+		ids = append(ids, it.ID)
+	}
+	infoList, _ := service.GetDrugWarehouseInfoByOrgIdTwo(orgId)
+	for _, it := range infoList {
+		infoIds = append(infoIds, it.DrugId)
+	}
+	manufacturerList, _ := service.GetAllManufacturerList(orgId)
+	list, total, err := service.GetDrugNewPurchaseStockQueryList(good_type, keyword, page, limit, orgId, startTime, endTime, ids, infoIds)
+
+	for _, item := range list {
+
+		//获取期初结余
+		flow, _ := service.GetDrugStartFlow(item.ID, orgId, startTime)
+
+		item.DrugStatFlow = flow
+
+		//获取期末结余
+		endFlow, _ := service.GetDrugEndFlow(item.ID, orgId, endTime)
+
+		item.DrugEndFlow = endFlow
+		//获取期初结余入库数量
+
+		//期中增加
+		drugWarehouse, _ := service.GetDrugWarehouseStartEnd(item.ID, orgId, startTime, endTime)
+		for _, it := range drugWarehouse {
+			item.DrugWarehouseInfoStartEnd = append(item.DrugWarehouseInfoStartEnd, it)
+		}
+
+		//期中减少
+		outInfo, _ := service.FindeDrugWarehouseOutInfo(item.ID, item.OrgId, startTime, endTime)
+		for _, it := range outInfo {
+			item.DrugWarehouseOutInfoStartEnd = append(item.DrugWarehouseOutInfoStartEnd, it)
+		}
+
+		//期中退库
+		cancelstartInfo, _ := service.FindStartEndDrugWarehouseOutInfo(item.ID, item.OrgId, startTime, endTime)
+		for _, it := range cancelstartInfo {
+			item.WareStartEndStockCancelInfo = append(item.WareStartEndStockCancelInfo, it)
+		}
+
+		//获取期中盘盈
+		profit, _ := service.GetDrugFlowStartEndProfit(item.ID, orgId, startTime, endTime)
+		for _, it := range profit {
+			item.WareStartEndStockInventoryProfit = append(item.WareStartEndStockInventoryProfit, it)
+		}
+
+		//获取期中盘亏
+		endLosses, _ := service.GetDrugFlowStartEndLosses(item.ID, orgId, startTime, endTime)
+		for _, it := range endLosses {
+			item.WareStartEndStockInventoryLosses = append(item.WareStartEndStockInventoryLosses, it)
+		}
+	}
+	if err != nil {
+		this.ServeFailJsonSend(enums.ErrorCodeDataException, "获取患者信息失败")
+		return
+	}
+	var drugType = "药品类型"
+	drugTypeParent, _ := service.GetDrugDataConfig(0, drugType)
+	drugTypeList, _ := service.GetParentDataConfig(drugTypeParent.ID, orgId)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list":             list,
+		"manufacturerList": manufacturerList,
+		"total":            total,
+		"drugTypeList":     drugTypeList,
+	})
+}

models/drug_stock.go

@@ -455,6 +455,7 @@ type DrugFlow struct {
 	RetailPrice               float64                `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
 	XtDrugWarehouseOutInfo    XtDrugWarehouseOutInfo `gorm:"ForeignKey:ID;AssociationForeignKey:WarehouseOutDetailId"json:"xt_drug_warehouse_out_info" `
 	OrderId                   int64                  `gorm:"column:order_id" json:"order_id" form:"order_id"`
+	FlushOverCount            int64                  `gorm:"column:flush_over_count" json:"flush_over_count" form:"flush_over_count"`
 }
 
 func (DrugFlow) TableName() string {

models/new_stock_models.go

@@ -402,6 +402,7 @@ type VmBaseDrugTwenty struct {
 	RetailPrice                      float64           `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
 	MinPrice                         float64           `gorm:"column:min_price" json:"min_price" form:"min_price"`
 	LastPrice                        float64           `gorm:"column:last_price" json:"last_price" form:"last_price"`
+	DrugAlias                        string            `gorm:"column:drug_alias" json:"drug_alias" form:"drug_alias"`
 	Manufacturer                     int64             `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
 	Dealer                           int64             `gorm:"column:dealer" json:"dealer" form:"dealer"`
 	Status                           int64             `gorm:"column:status" json:"status" form:"status"`

service/pharmacy_service.go

@@ -839,36 +839,38 @@ func DispensingMedicineOne(orgid, patient_id, stime, etime, creater int64) (err
 	}
 
 	advice, err := GetDocAdviceList(orgid, patient_id, stime, etime)
-
-	if len(advice) > 0 {
-		for _, item := range advice {
-			err = DrugsDelivery(item.UserOrgId, item.ExecutionStaff, item)
-			//查询默认仓库
-			storeHouseConfig, _ := GetAllStoreHouseConfig(orgid)
-			//查询默认仓库剩余多少库存
-			var sum_count int64
-			stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, orgid, item.DrugId)
-			for _, its := range stockInfo {
-				baseDrug, _ := GetBaseDrugMedical(its.DrugId)
-				if its.MaxUnit == baseDrug.MaxUnit {
-					its.StockMaxNumber = its.StockMaxNumber * baseDrug.MinNumber
+	//响水不走这里
+	if orgid != 10188 {
+		if len(advice) > 0 {
+			for _, item := range advice {
+				err = DrugsDelivery(item.UserOrgId, item.ExecutionStaff, item)
+				//查询默认仓库
+				storeHouseConfig, _ := GetAllStoreHouseConfig(orgid)
+				//查询默认仓库剩余多少库存
+				var sum_count int64
+				stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, orgid, item.DrugId)
+				for _, its := range stockInfo {
+					baseDrug, _ := GetBaseDrugMedical(its.DrugId)
+					if its.MaxUnit == baseDrug.MaxUnit {
+						its.StockMaxNumber = its.StockMaxNumber * baseDrug.MinNumber
+					}
+					sum_count += its.StockMaxNumber + its.StockMinNumber
 				}
-				sum_count += its.StockMaxNumber + its.StockMinNumber
-			}
-			UpdateBaseDrugSumTwo(item.DrugId, sum_count, orgid)
-			//扣减库存
-			UpdateDrugStockCount(item.DrugId, item.UserOrgId, storeHouseConfig.DrugStorehouseOut, sum_count)
+				UpdateBaseDrugSumTwo(item.DrugId, sum_count, orgid)
+				//扣减库存
+				UpdateDrugStockCount(item.DrugId, item.UserOrgId, storeHouseConfig.DrugStorehouseOut, sum_count)
 
-			over, _ := FindOverCount(item.DrugId, item.UserOrgId, storeHouseConfig.DrugStorehouseOut)
-			UpdateActOut(over.ID, over.SumInCount, over.FlushCount, over.SumCancelCount)
-			if err != nil {
-				err = fmt.Errorf("!:%v", err)
-				return
-			}
-			err = UpdateIsAdvice(item.ID)
-			if err != nil {
-				err = fmt.Errorf("!:%v", err)
-				return
+				over, _ := FindOverCount(item.DrugId, item.UserOrgId, storeHouseConfig.DrugStorehouseOut)
+				UpdateActOut(over.ID, over.SumInCount, over.FlushCount, over.SumCancelCount)
+				if err != nil {
+					err = fmt.Errorf("!:%v", err)
+					return
+				}
+				err = UpdateIsAdvice(item.ID)
+				if err != nil {
+					err = fmt.Errorf("!:%v", err)
+					return
+				}
 			}
 		}
 	}

service/secondary_service.go

@@ -1162,6 +1162,12 @@ func UpdateOverCount(id int64, count int64) (err error) {
 	return err
 }
 
+func UpdateDrugOverCount(id int64, count int64) (err error) {
+
+	err = XTWriteDB().Model(models.DrugFlow{}).Where("id = ? and status=1", id).Updates(map[string]interface{}{"flush_over_count": count}).Error
+	return err
+}
+
 func GetLastOverCount(id int64) (models.VmStockFlow, error) {
 
 	stockFlow := models.VmStockFlow{}
@@ -1170,3 +1176,12 @@ func GetLastOverCount(id int64) (models.VmStockFlow, error) {
 
 	return stockFlow, err
 }
+
+func GetLastDrugOverCount(id int64) (models.DrugFlow, error) {
+
+	stockFlow := models.DrugFlow{}
+
+	err := XTReadDB().Where("id=? and status=1", id).Find(&stockFlow).Error
+
+	return stockFlow, err
+}

service/self_drug_service.go

@@ -2881,6 +2881,30 @@ func GetDrugNewPurchaseStockQuery(good_type int64, keyword string, page int64, l
 	return druginfo, total, err
 }
 
+func GetDrugNewPurchaseStockQueryList(good_type int64, keyword string, page int64, limit int64, orgid int64, startime int64, endtime int64, ids []int64, infos []int64) (druginfo []*models.VmBaseDrugTwenty, total int64, err error) {
+
+	db := XTReadDB().Model(&druginfo).Where("status = 1")
+	offset := (page - 1) * limit
+	likeKey := "%" + keyword + "%"
+	if good_type > 0 {
+		db = db.Where("drug_type = ?", good_type)
+	}
+
+	if orgid > 0 {
+		db = db.Where("org_id = ?", orgid)
+	}
+
+	if len(keyword) > 0 {
+		db = db.Where("drug_name like ? or manufacturer in(?)", likeKey, ids)
+	}
+	if len(infos) > 0 {
+		db = db.Where("id in(?)", infos)
+	}
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("drug_alias desc").Find(&druginfo).Error
+
+	return druginfo, total, err
+}
+
 func GetDrugStartFlow(drug_id int64, user_org_id int64, startime int64) (models.DrugFlowTwenty, error) {
 
 	flow := models.DrugFlowTwenty{}

service/user_service.go

@@ -214,3 +214,10 @@ func GetAllHisDoctor(orgid int64) (appRole []*models.App_Role, err error) {
 	err = UserReadDB().Where("org_id = ?  AND status = 1 AND  (user_type = ? OR user_type = ?) ", orgid, 2, 1).Find(&appRole).Error
 	return appRole, err
 }
+
+func GetDrugFlowDetailById(drug_id int64) (flow []*models.DrugFlow, err error) {
+
+	err = XTReadDB().Model(&flow).Where("drug_id = ? and status =1 and user_org_id =10402", drug_id).Order("id asc").Find(&flow).Error
+
+	return flow, err
+}