药房

conf/app.conf

 appname = 血透
 httpport = 9531
-runmode =prod
+runmode =dev
 #dev/prod
 
 #

controllers/pharmacy_controller.go

 	keyword := this.GetString("keyword", "")
 	times := this.GetString("time", "")
 	orgid := this.GetAdminUserInfo().CurrentOrgId
+	shift, err := this.GetInt64("shift", 0) //班次
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	partition, err := this.GetInt64("partition", 0) //分区
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 	var stime, etime int64
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
+	listt, err := service.PartitionAndLayout(stime, etime, orgid, shift, partition, flist)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": flist,
+		"list": listt,
 	})
 	return
 }
 	}()
 	keyword := this.GetString("keyword", "")
 	times := this.GetString("time", "")
+	shift, err := this.GetInt64("shift", 0) //班次
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	partition, err := this.GetInt64("partition", 0) //分区
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	orgid := this.GetAdminUserInfo().CurrentOrgId
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
+	listt, err := service.PartitionAndLayout(stime, etime, orgid, shift, partition, flist)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": flist,
+		"list": listt,
 	})
 	return
 }
 	orgid := this.GetAdminUserInfo().CurrentOrgId
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
+	deliveryway := this.GetString("deliveryway", "")
 	var stime, etime int64
 	if times == "" {
 		stime, etime = service.GetNowTime()
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
 		return
 	}
+	llist, err := service.Administration(deliveryway, orgid, flist)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": flist,
+		"list": llist,
 	})
 	return
 }
 	orgid := this.GetAdminUserInfo().CurrentOrgId
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
+	deliveryway := this.GetString("deliveryway", "")
 	var stime, etime int64
 	if times == "" {
 		stime, etime = service.GetNowTime()
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
+	llist, err := service.Administration(deliveryway, orgid, flist)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": flist,
+		"list": llist,
 	})
 	return
 }
 	is_medicine, _ := this.GetInt64("is_medicine", 0) //0：待发药，1：已发药
 	times := this.GetString("time", "")
 	orgid := this.GetAdminUserInfo().CurrentOrgId
+	deliveryway := this.GetString("deliveryway", "")
+	if deliveryway == "" {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	shift, err := this.GetInt64("shift", 0) //班次
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	partition, err := this.GetInt64("partition", 0) //分区
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 	var stime, etime int64
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 	}
+	listll, err := service.PartitionAndLayoutDrug(deliveryway, stime, etime, orgid, shift, partition, list)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	total, err := service.CalculateTheTotalAmount(listll, drug_id)
+	if err != nil {
+		utils.ErrorLog(err.Error())
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": list,
+		"list":  listll,
+		"total": total,
 	})
 	return
 }
 		}
 	}()
 	orgid := this.GetAdminUserInfo().CurrentOrgId
-	list, err := service.GetAllValidDeviceZones(orgid)
+	tmp := []*models.DeviceZone{{ID: 0, Name: "全部分区"}}
+	list, err := service.GetAllValidDeviceZones02(orgid)
 	if err != nil {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
 		return
 	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": list,
+		"list": append(tmp, list...),
 	})
 	return
 }
 		}
 	}()
 	orgid := this.GetAdminUserInfo().CurrentOrgId
+	tmp := []*models.DrugwayDic{{ID: 0, Name: "全部"}}
 	list, _, err := service.GetDrugWayDics(orgid)
 	if err != nil {
 		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
 		return
 	}
 	this.ServeSuccessJSON(map[string]interface{}{
-		"list": list,
+		"list": append(tmp, list...),
 	})
 	return
 }

models/pharmacy_models.go

 //病人信息
 type PatientInformation struct {
 	Id           string `json:"id"`            //hid表示his_doctor_advice_info的id ,xid表示xt_doctor_advice的id
+	PatientId    int64  `json:"patient_id"`    //患者id
 	Name         string `json:"name"`          //患者姓名
 	SingleDosage string `json:"single_dosage"` //单次用量
 	Usage        string `json:"usage"`         //用法
 	Total        string `json:"total"`         //总量
 	DataSources  string `json:"data_sources"`  //数据来源
 	People       string `json:"people"`        //领药人
+	Quantity     int64  `json:"quantity"`      //总量拆分——数据部分
+	Unit         string `json:"unit"`          //总量拆分——单位部分
 }
 type HisDoctorAdviceInfoL struct {
 	ID                    int64   `gorm:"column:id" json:"id" form:"id"`

service/pharmacy_service.go

 		pp = append(pp, &models.PatientInformation{
 			Id:           "h" + config.ToString(v.ID),
 			Name:         FindUserName(v.PatientId),
+			PatientId:    v.PatientId,
 			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
 			Usage:        v.DeliveryWay,
 			Frequency:    v.ExecutionFrequency,
 			Total:        config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
 			DataSources:  "his处方",
 			People:       GetUserAdminName(v.People, orgid), //领药人！！！！！！！！！！！！！！！！！！！！！！
+			Quantity:     int64(v.PrescribingNumber),
+			Unit:         v.PrescribingNumberUnit,
 		})
 	}
 
 			Total:        config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
 			DataSources:  "临时医嘱",
 			People:       GetUserAdminName(v.People, orgid), //领药人
+			Quantity:     int64(v.PrescribingNumber),
+			Unit:         v.PrescribingNumberUnit,
 		})
 	}
 	return
 
 	return
 }
+
+//分区和收费(患者发药
+func PartitionAndLayout(stime, etime, orgid, shift, partition int64, flist []*models.TmpPatient) (tmp []*models.TmpPatient, err error) {
+	//获取排班
+	var sch []*models.XtScheduleTwo
+	ma := make(map[int64]int64)
+	s := "user_org_id = ? and status = 1 and schedule_date >= ? and schedule_date <= ?"
+	if shift != 0 {
+		s = s + " and schedule_type = " + config.ToString(shift)
+	}
+	if partition != 0 {
+		s = s + " and partition_id = " + config.ToString(partition)
+	}
+	if shift == 0 && partition == 0 {
+		return flist, nil
+	}
+	err = XTWriteDB().Model(&models.XtScheduleTwo{}).Where(s, orgid, stime, etime).Find(&sch).Error
+	if err != nil {
+		return
+	}
+	for _, v := range sch {
+		ma[v.PatientId] = v.PatientId
+	}
+	for _, v := range flist {
+		if _, ok := ma[v.PatientID]; ok {
+			tmp = append(tmp, v)
+		}
+	}
+	return
+}
+
+//分区和收费(药品发药
+func PartitionAndLayoutDrug(deliveryway string, stime, etime, orgid, shift, partition int64, flist []*models.PatientInformation) (tmp []*models.PatientInformation, err error) {
+	//获取排班
+	var sch []*models.XtScheduleTwo
+	ma := make(map[int64]int64)
+	s := "user_org_id = ? and status = 1 and schedule_date >= ? and schedule_date <= ?"
+	if shift != 0 {
+		s = s + " and schedule_type = " + config.ToString(shift)
+	}
+	if partition != 0 {
+		s = s + " and partition_id = " + config.ToString(partition)
+	}
+	if shift == 0 && partition == 0 {
+		for _, v := range flist {
+			ma[v.PatientId] = v.PatientId
+		}
+		for _, v := range flist {
+			if _, ok := ma[v.PatientId]; ok && (v.Usage == deliveryway || deliveryway == "全部") {
+				tmp = append(tmp, v)
+			}
+		}
+		return tmp, nil
+	}
+	err = XTWriteDB().Model(&models.XtScheduleTwo{}).Where(s, orgid, stime, etime).Find(&sch).Error
+	if err != nil {
+		return
+	}
+	for _, v := range sch {
+		ma[v.PatientId] = v.PatientId
+	}
+
+	for _, v := range flist {
+		if _, ok := ma[v.PatientId]; ok && (v.Usage == deliveryway || deliveryway == "全部") {
+			tmp = append(tmp, v)
+		}
+	}
+	return
+}
+
+//给药途径
+func Administration(deliveryway string, orgid int64, flist []*models.ListOfDrugs) (tmp []*models.ListOfDrugs, err error) {
+	//查询药品
+	var pp []*models.PharmacyBaseDrug
+	s := "org_id = ? and status = 1"
+	if deliveryway == "全部" {
+		tmp = flist
+		return
+	} else {
+		s = s + " and delivery_way = '" + deliveryway + "'"
+	}
+	err = XTReadDB().Model(&models.PharmacyBaseDrug{}).Where(s, orgid).Find(&pp).Error
+	if err != nil {
+		return
+	}
+	ma := make(map[int64]int64)
+	for _, v := range pp {
+		ma[v.ID] = v.ID
+	}
+	for _, v := range flist {
+		if _, ok := ma[v.ID]; ok {
+			tmp = append(tmp, v)
+		}
+	}
+	return
+}
+
+//计算总量
+func CalculateTheTotalAmount(tmp []*models.PatientInformation, drug_id int64) (total string, err error) {
+	//获取药品信息
+	var t models.SpBaseDrug
+	err = XTReadDB().Model(&models.SpBaseDrug{}).Where("id = ?", drug_id).Find(&t).Error
+	if err != nil {
+		return
+	}
+	terr, maxunit, minunit := int64(0), int64(0), int64(0) //terr异常的单位数量，maxunit包装单位数量，minunit拆零单位数量
+	minmunber := t.MinNumber                               //拆零数量
+	terrUnit := ""
+	for _, v := range tmp {
+		switch v.Unit {
+		case t.MaxUnit:
+			maxunit = v.Quantity
+		case t.MinUnit:
+			minunit = v.Quantity
+		default:
+			terr = v.Quantity
+			terrUnit = v.Unit
+		}
+	}
+	if minunit > minmunber {
+		if minmunber == 0 {
+			err = fmt.Errorf("拆零数量不能为零")
+			return
+		}
+		maxunit = maxunit + minunit/minmunber
+		minunit = minunit % minmunber
+
+	}
+	if terr > 0 {
+		total = total + config.ToString(terr) + terrUnit
+	}
+	if maxunit > 0 {
+		total = total + config.ToString(maxunit) + t.MaxUnit
+	}
+	if minunit > 0 {
+		total = total + config.ToString(minunit) + t.MinUnit
+	}
+
+	return
+}
+func GetAllValidDeviceZones02(orgID int64) ([]*models.DeviceZone, error) {
+	var zones []*models.DeviceZone
+	err := readDb.Model(&models.DeviceZone{}).Where("org_id = ? and status = 1", orgID).Find(&zones).Error
+	if err != nil {
+		return nil, err
+	}
+	return zones, nil
+}