XT_New/controllers/pharmacy_controller.go

package controllers

import (
	"encoding/json"
	"fmt"
	"math"
	"strconv"
	"strings"
	"time"

	"XT_New/enums"
	"XT_New/models"
	"XT_New/service"
	"XT_New/utils"
	"github.com/astaxie/beego"
)

type PharmacyController struct {
	BaseAuthAPIController
}

func PharmacyApiRegistRouters() {
	beego.Router("/api/pharmacy/ceshili", &PharmacyController{}, "get:Tlili")
	beego.Router("/api/pharmacy/todaynumber", &PharmacyController{}, "get:TodayNumber")                     //查询今天的待发药，已发药人数（
	beego.Router("/api/pharmacy/waitingdrug", &PharmacyController{}, "get:WaitingDrug")                     //获取当天待发药的所有患者（
	beego.Router("/api/pharmacy/issueddrugs", &PharmacyController{}, "get:IssuedDrug")                      //获取当天已发药的所有患者（
	beego.Router("/api/pharmacy/getpharmacycontent", &PharmacyController{}, "get:GetPharmacyContent")       //获取当天该患者的所有信息（
	beego.Router("/api/pharmacy/dispensingmedicine", &PharmacyController{}, "get:DispensingMedicine")       //患者发药按钮点击（
	beego.Router("/api/pharmacy/drugwithdrawal", &PharmacyController{}, "get:DrugWithdrawal")               //退药按钮点击
	beego.Router("/api/pharmacy/dispensingdetails", &PharmacyController{}, "get:DispensingDetails")         //获取发药明细的患者列表(
	beego.Router("/api/pharmacy/prescriptiondetails", &PharmacyController{}, "get:PrescriptionDetails")     //发药明细-详情(
	beego.Router("/api/pharmacy/dispensemedicine", &PharmacyController{}, "get:DispenseMedicine")           //获取当天已发药的药品(
	beego.Router("/api/pharmacy/waitingmedicine", &PharmacyController{}, "get:WaitingMedicine")             //获取当天待发药的药品(
	beego.Router("/api/pharmacy/getpatientswithdrugs", &PharmacyController{}, "get:GetPatientsWithDrugs")   //获取当天该药品的所有患者(
	beego.Router("/api/pharmacy/medicinedeparture", &PharmacyController{}, "get:MedicineDeparture")         //药品发药按钮点击(
	beego.Router("/api/pharmacy/getcurrentname", &PharmacyController{}, "get:GetCurrentName")               //获取当前登录账号的名字(
	beego.Router("/api/pharmacy/getpartitionlist", &PharmacyController{}, "get:GetPartitionList")           //获取当前机构的分区列表
	beego.Router("/api/pharmacy/routeofadministration", &PharmacyController{}, "get:RouteOfAdministration") //获取当前机构的给药途径

	beego.Router("/api/pharmacy/getgoodinventorylist", &PharmacyController{}, "Get:GetGoodInventoryList")
	beego.Router("/api/pharmacy/getgoodinventorybygoodid", &PharmacyController{}, "Get:GetGoodInventoryByGoodId")
	beego.Router("/api/pharmacy/updateInventoryWarehouseInfo", &PharmacyController{}, "Get:UpdateInventoryWarehouseInfo")

	beego.Router("/api/pharmacy/getdrugnewinventoryList", &PharmacyController{}, "Get:GetDrugInventoryList")

	beego.Router("/api/pharmacy/getdruginventorybydrugid", &PharmacyController{}, "Get:GetDrugInventoryByDrugId")

	beego.Router("/api/pharmacy/updatedruginventorywarehouseinfo", &PharmacyController{}, "Get:UpdateDrugInventoryWarehouseInfo")

	beego.Router("/api/pharmacy/changedrugcode", &PharmacyController{}, "Post:ChangeDrugCode")

	beego.Router("/api/pharmacy/changeZeroFlag", &PharmacyController{}, "Get:ChangeZeroFlag")

	beego.Router("/api/pharmacy/getdrugtocalcount", &PharmacyController{}, "Get:GetDrugTocalCount")

}

// 测试
func (this *PharmacyController) Tlili() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	var list2 []*models.ReplacementDrugs
	list2, err = service.ReplacementDrugs(9675, false)
	if err != nil {
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
		return
	}
	this.ServeSuccessJSON(map[string]interface{}{
		"list": list2,
	})
	return
}
func (this *PharmacyController) GetCurrentName() {
	create := this.GetAdminUserInfo().AdminUser.Id
	this.ServeSuccessJSON(map[string]interface{}{
		"list": create,
	})
	return
}

// 查询今天的待发药，已发药人数
func (this *PharmacyController) TodayNumber() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	orgid := this.GetAdminUserInfo().CurrentOrgId
	times := this.GetString("time", "")
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")

	var stime, etime int64
	if times == "" {
		stime, etime = service.GetNowTime()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}

	//if orgid != 9671 && orgid != 10188 && orgid != 10217 && orgid != 3877 && orgid != 10164 && orgid != 10480 {
	//	//查询表里当天的数据
	//	var wtotal int
	//	wtotal, err = service.GetTodayPharmacy(stime, etime, orgid, 1)
	//
	//	if err != nil {
	//		utils.ErrorLog(err.Error())
	//		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
	//		return
	//	}
	//
	//	var itotal int
	//	itotal, err = service.GetTodayPharmacy(stime, etime, orgid, 0)
	//
	//	drug, _ := service.GetAllBaseDrugList(orgid)
	//	if err != nil {
	//		utils.ErrorLog(err.Error())
	//		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
	//		return
	//	}
	//	this.ServeSuccessJSON(map[string]interface{}{
	//		"wtotal": wtotal,
	//		"itotal": itotal,
	//		"drug":   drug,
	//	})
	//	return
	//}

	var wtotal int
	var itotal int
	//查找出库数量
	wtotal, _ = service.GetTodayAdviceCount(stime, etime, orgid, 1)

	itotal, _ = service.GetTodayAdviceCount(stime, etime, orgid, 0)

	//drug, _ := service.GetAllBaseDrugList(orgid)

	config, _ := service.GetDrugCodeConfig(orgid)
	this.ServeSuccessJSON(map[string]interface{}{
		"wtotal": wtotal,
		"itotal": itotal,
		//"drug":   drug,
		"config": config,
	})
	return

}
func (this *PharmacyController) IssuedDrug() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	keyword := this.GetString("keyword", "")
	fmt.Println(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 int64
	stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
	stime = stmp.Unix()
	is_medicine := 1
	fmt.Println(partition)
	w_his_advice_patient, _ := service.GetWaitPharmacyHISAdvicePatient(partition, shift, stime, orgid, keyword, is_medicine)
	w_xt_advice_patient, _ := service.GetWaitPharmacyXTPatient(partition, shift, stime, orgid, keyword, is_medicine)
	var patients []*models.PharmacyPatients
	patients = append(patients, w_his_advice_patient...)
	patients = append(patients, w_xt_advice_patient...)

	//good_info,_ := service.GetGoodCodeOpen(orgid)
	good_info, _ := service.GetGoodCodeOpen(orgid)
	if good_info.IsOpen == 1 {
		w_his_goods_patient, _ := service.GetWaitPharmacyHISGoodsPatient(partition, shift, stime, orgid, keyword, is_medicine)
		patients = append(patients, w_his_goods_patient...)
	}
	patients = RemoveRepeatedPurviewElement(patients)

	this.ServeSuccessJSON(map[string]interface{}{
		"user_patientList": patients,
	})

	//if orgid != 10164 && orgid == 3877 && orgid != 10188 && orgid != 10217 && orgid != 9671 && orgid != 10387 && orgid != 10375 && orgid != 10480 && orgid == 10344 {
	//	//查询表里当天的数据
	//	var flist []*models.TmpPatient
	//	flist, err = service.GetTodayDrug(stime, etime, orgid, 1, keyword)
	//	if err != nil {
	//		utils.ErrorLog(err.Error())
	//		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": listt,
	//	})
	//	return
	//}

}

func RemoveRepeatedPurviewElement(arr []*models.PharmacyPatients) (newArr []*models.PharmacyPatients) {
	newArr = make([]*models.PharmacyPatients, 0)
	for i := 0; i < len(arr); i++ {
		repeat := false
		for j := i + 1; j < len(arr); j++ {
			if arr[i].ID == arr[j].ID {
				repeat = true
				break
			}
		}
		if !repeat {
			newArr = append(newArr, arr[i])
		}
	}
	return
}

func (this *PharmacyController) WaitingDrug() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	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")
	var stime int64

	stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
	stime = stmp.Unix()

	var patients []*models.PharmacyPatients
	is_medicine := 0
	w_his_advice_patient, _ := service.GetWaitPharmacyHISAdvicePatient(partition, shift, stime, orgid, keyword, is_medicine)
	if orgid != 10217 {
		w_xt_advice_patient, _ := service.GetWaitPharmacyXTPatient(partition, shift, stime, orgid, keyword, is_medicine)
		patients = append(patients, w_xt_advice_patient...)
	}

	patients = append(patients, w_his_advice_patient...)
	good_info, _ := service.GetGoodCodeOpen(orgid)
	if good_info.IsOpen == 1 {
		w_his_goods_patient, _ := service.GetWaitPharmacyHISGoodsPatient(partition, shift, stime, orgid, keyword, is_medicine)
		patients = append(patients, w_his_goods_patient...)
	}
	patients = RemoveRepeatedPurviewElement(patients)

	this.ServeSuccessJSON(map[string]interface{}{
		"wait_patientList": patients,
	})
	return

}

func (this *PharmacyController) GetPharmacyContent() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	patient_id, _ := this.GetInt64("patient_id", 0)
	is_medicine, _ := this.GetInt64("is_medicine", 0) //0：待发药，1：已发药
	times := this.GetString("time", "")
	orgid := this.GetAdminUserInfo().CurrentOrgId
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	var stime, etime int64
	if times == "" {
		stime, etime = service.GetNowTime()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}
	var list []*models.PharmacyContent
	list, err = service.GetPatientMedication(orgid, patient_id, stime, etime, is_medicine)

	good_info, _ := service.GetGoodCodeOpen(orgid)
	if good_info.IsOpen == 1 {
		list_p, _ := service.GetPatientProject(orgid, patient_id, stime, etime, is_medicine)
		list = append(list, list_p...)
	}
	baseList, _ := service.GetAllBaseDrugListTwo(orgid)
	patients, _ := service.GetPatientByIDOne(orgid, patient_id)
	//zoneList, _ := service.GetAllZoneByList(orgid)
	appId := this.GetAdminUserInfo().CurrentAppId
	adminUserES, _ := service.GetAllAdminUserES(orgid, appId)
	allDoctor, _ := service.GetAllDoctor(orgid, appId)
	prescriptionListByToDay, _ := service.GetPrescriptionListByToDay(orgid, patient_id, stime)
	diagnose, _ := service.FindAllDiagnose(orgid)
	config, _ := service.GetDrugCodeConfig(orgid)
	if err != nil {
		utils.ErrorLog(err.Error())
		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
		return
	}
	return_value := make(map[string]interface{})
	return_value["list"] = list
	return_value["patients"] = patients
	return_value["adminUserES"] = adminUserES
	return_value["doctors"] = allDoctor
	return_value["prescription"] = prescriptionListByToDay
	return_value["diagnose"] = diagnose
	return_value["config"] = config
	return_value["baseList"] = baseList

	this.ServeSuccessJSON(return_value)
	return

}

//func (this *PharmacyController) GetNewPharmacyContent() {
//	patient_id, _ := this.GetInt64("patient_id", 0)
//	is_medicine, _ := this.GetInt64("is_medicine", 0) //0：待发药，1：已发药
//	times := this.GetString("time", "")
//	orgid := this.GetAdminUserInfo().CurrentOrgId
//	timeLayout := "2006-01-02"
//	loc, _ := time.LoadLocation("Local")
//	var stime, etime int64
//	if times == "" {
//		stime, etime = service.GetNowTime()
//	} else {
//		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
//		stime = stmp.Unix()
//		etime = stime + 86399
//	}
//	var list []*models.PharmacyContent
//	list, err = service.GetPatientMedication(orgid, patient_id, stime, etime, is_medicine)
//
//	baseList, _ := service.GetAllBaseDrugListTwo(orgid)
//
//	patients, _ := service.GetPatientByIDOne(orgid, patient_id)
//	order, _ := service.GetMobiledialysiOrder(orgid, patient_id, stime)
//	numberList, _ := service.GetAllBedNumberList(orgid)
//	zoneList, _ := service.GetAllZoneByList(orgid)
//
//	appId := this.GetAdminUserInfo().CurrentAppId
//	adminUserES, _ := service.GetAllAdminUserES(orgid, appId)
//	allDoctor, _ := service.GetAllDoctor(orgid, appId)
//
//	prescriptionListByToDay, _ := service.GetPrescriptionListByToDay(orgid, patient_id, stime)
//
//	diagnose, _ := service.FindAllDiagnose(orgid)
//
//	config, _ := service.GetDrugCodeConfig(orgid)
//	if err != nil {
//		utils.ErrorLog(err.Error())
//		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
//		return
//	}
//	return_value := make(map[string]interface{})
//	return_value["list"] = list
//	return_value["baseList"] = baseList
//	return_value["patients"] = patients
//	return_value["order"] = order
//	return_value["numberList"] = numberList
//	return_value["zoneList"] = zoneList
//	return_value["adminUserES"] = adminUserES
//	return_value["doctors"] = allDoctor
//	return_value["prescription"] = prescriptionListByToDay
//	return_value["diagnose"] = diagnose
//	return_value["config"] = config
//	//if is_medicine == 1{发药时间先不展示
//	//	return_value["time"] = time
//	//}
//	this.ServeSuccessJSON(return_value)
//	return
//
//}

// 发药按钮点击
func (this *PharmacyController) DispensingMedicine() {

	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	patient_id, _ := this.GetInt64("patient_id", 0)
	times := this.GetString("time", "")
	orgid := this.GetAdminUserInfo().CurrentOrgId
	creater := this.GetAdminUserInfo().AdminUser.Id
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	var stime, etime int64
	if times == "" {
		stime, etime = service.GetNowTime()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}
	tmp_bool := service.IsPharmacyConfig(orgid)
	codeConfig, _ := service.GetDrugCodeConfig(orgid)
	if tmp_bool == true {
		advicelist, _ := service.FindeHisAdviceDocAdvice(orgid, patient_id, stime, etime)
		if len(advicelist) > 0 {

			var total int64
			var prescribing_number_total int64
			for _, item := range advicelist {

				if codeConfig.IsOpen == 1 {
					if item.DrugCode == "" || len(item.DrugCode) == 0 {
						err := fmt.Errorf(service.FindDrugsName(item.DrugId) + "药品追溯码不能为空")
						if err != nil {
							utils.ErrorLog(err.Error())
							this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
							return
						}
					}
				}

				//查询改药品信息
				medical, _ := service.GetBaseDrugMedical(item.DrugId)
				//如果是药房发药的方式
				if medical.IsPharmacy == 1 {
					houseConfig, _ := service.GetAllStoreHouseConfig(orgid)
					//查询该药品是否有库存
					list, _ := service.GetDrugTotalCountTwenty(item.DrugId, item.UserOrgId, houseConfig.DrugStorehouseOut)

					//判断单位是否相等
					if medical.MaxUnit == item.PrescribingNumberUnit {
						prescribingNumber_temp := strconv.FormatFloat(math.Abs(item.PrescribingNumber), 'f', 0, 64)
						count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
						//转化为最小单位
						total = list.Count*medical.MinNumber + list.StockMinNumber
						prescribing_number_total = count * medical.MinNumber
					}
					if medical.MinUnit == item.PrescribingNumberUnit {
						prescribingNumber_temp := strconv.FormatFloat(math.Abs(item.PrescribingNumber), 'f', 0, 64)
						count, _ := strconv.ParseInt(prescribingNumber_temp, 10, 64)
						total = list.Count*medical.MinNumber + list.StockMinNumber
						prescribing_number_total = count
					}

					if medical.IsUse != 1 {
						//如果出库数量大于库存数量
						if prescribing_number_total > total {
							err := fmt.Errorf(service.FindDrugsName(item.DrugId) + "库存不足")
							if err != nil {
								utils.ErrorLog(err.Error())
								this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
								return
							}
						}
					}
				}

			}
		}
	}

	if orgid != 10480 && orgid != 10188 && orgid != 10217 && orgid != 10164 && orgid != 10666 {
		//发药
		err = service.DispensingMedicine(orgid, patient_id, stime, etime, creater)

		good_info, _ := service.GetGoodCodeOpen(orgid)
		if good_info.IsOpen == 1 {
			//list_p, _ := service.GetPatientProject(orgid, patient_id, stime, etime, is_medicine)
			//list = append(list, list_p...)
			err = service.DispensingGoods(orgid, patient_id, stime, etime, creater)

		}

		if err != nil {
			utils.ErrorLog(err.Error())
			this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
			return
		}

		this.ServeSuccessJSON(map[string]interface{}{
			"list": "操作成功",
		})
		return
	}

	if orgid == 10480 || orgid == 10188 || orgid == 10217 || orgid == 10164 || orgid == 10666 {
		//发药逻辑

		service.DispensingMedicineOne(orgid, patient_id, stime, etime, creater)
		//err = service.DispensingGoods(orgid, patient_id, stime, etime, creater)
		good_info, _ := service.GetGoodCodeOpen(orgid)
		if good_info.IsOpen == 1 {
			//list_p, _ := service.GetPatientProject(orgid, patient_id, stime, etime, is_medicine)
			//list = append(list, list_p...)
			err = service.DispensingGoods(orgid, patient_id, stime, etime, creater)

		}

		//针对桑植盛康
		if orgid == 10387 || orgid == 3877 {
			advicelist, _ := service.FindeHisAdviceDocAdvice(orgid, patient_id, stime, etime)
			if len(advicelist) > 0 {
				for _, item := range advicelist {
					//查询改药品信息
					medical, _ := service.GetBaseDrugMedical(item.DrugId)
					if medical.IsPharmacy == 1 {
						flow, _ := service.GetFlow(item.DrugId, item.AdviceDate, orgid, item.PatientId)
						if len(flow) > 0 {
							service.UpdateAdviceFlow(item.ID)
						}
					}
				}

			}
		}
		if err != nil {
			utils.ErrorLog(err.Error())
			this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
			return
		}

		this.ServeSuccessJSON(map[string]interface{}{
			"list": "操作成功",
		})
		return
	}

}

// 退药按钮点击
func (this *PharmacyController) DrugWithdrawal() {

	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	patient_id, _ := this.GetInt64("patient_id", 0)
	times := this.GetString("time", "")
	orgid := this.GetAdminUserInfo().CurrentOrgId
	creater := this.GetAdminUserInfo().AdminUser.Id
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	var stime, etime int64
	if times == "" {
		stime, etime = service.GetNowTime()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}
	err = service.DrugWithdrawal(orgid, patient_id, stime, etime, creater)
	err = service.DrugWithdrawalForGood(orgid, patient_id, stime, etime, creater)
	prescriptionList, _ := service.GetHisPrescriptionByStartTime(orgid, patient_id, stime, etime)
	if len(prescriptionList) > 0 {
		for _, item := range prescriptionList {
			service.ModiftyPrescpiton(item.ID)
		}
	}
	if err != nil {
		utils.ErrorLog(err.Error())
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
		return
	}
	this.ServeSuccessJSON(map[string]interface{}{
		"list": "操作成功",
	})
	return

}

// 发药明细列表
func (this *PharmacyController) DispensingDetails() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	keyword := this.GetString("keyword", "")       //患者名称
	start_time := this.GetString("start_time", "") //开始时间
	end_time := this.GetString("end_time", "")     //结束时间
	page, _ := this.GetInt64("page", 1)            //页码
	limit, _ := this.GetInt64("limit", 10)         //每一页查出来的条数
	orgid := this.GetAdminUserInfo().CurrentOrgId
	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	var stime, etime int64
	if start_time == "" {
		stime = 1
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
		stime = stmp.Unix()
	}
	if end_time == "" {
		_, etime = service.GetNowTime()
	} else {
		etmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
		etime = etmp.Unix()
	}
	var dislist []*models.DispensingList
	var total int64
	dislist, total, err = service.DispensingDetailsList(stime, etime, orgid, page, limit, keyword)

	if err != nil {
		utils.ErrorLog(err.Error())
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
		return
	}

	this.ServeSuccessJSON(map[string]interface{}{
		"list":  dislist,
		"total": total,
	})
	return
}

// 处方详情
func (this *PharmacyController) PrescriptionDetails() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	//患者姓名
	patient_id, _ := this.GetInt64("patient_id", 0)
	//发药时间
	record_date, _ := this.GetInt64("record_date", 0)
	orgid := this.GetAdminUserInfo().CurrentOrgId
	if record_date == 0 || patient_id == 0 {
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数不足")
		return
	}
	var list []*models.PrescripDetails
	list, err = service.PrescriptionDetails(patient_id, record_date, orgid)
	if err != nil {
		utils.ErrorLog(err.Error())
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
		return
	}
	this.ServeSuccessJSON(map[string]interface{}{
		"list": list,
	})
	return
}

// 已发药品的信息
func (this *PharmacyController) DispenseMedicine() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	keyword := this.GetString("keyword", "")
	times := this.GetString("time", "")
	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()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}
	//查询表里当天的数据
	var flist []*models.ListOfDrugs
	flist, err = service.GetTodayMedicine(stime, etime, orgid, 1, keyword)
	if err != nil {
		utils.ErrorLog(err.Error())
		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": llist,
	})
	return
}

// 待发药的药品信息
func (this *PharmacyController) WaitingMedicine() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	keyword := this.GetString("keyword", "")
	times := this.GetString("time", "")
	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()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}
	//查询表里当天的数据
	var flist []*models.ListOfDrugs
	flist, err = service.GetTodayMedicine(stime, etime, orgid, 0, keyword)
	if err != nil {
		utils.ErrorLog(err.Error())
		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": llist,
	})
	return
}

// 获取药品的所有患者信息
func (this *PharmacyController) GetPatientsWithDrugs() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	drug_id, _ := this.GetInt64("drug_id", 0)
	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
	if times == "" {
		stime, etime = service.GetNowTime()
	} else {
		stmp, _ := time.ParseInLocation(timeLayout+" 15:04:05", times+" 00:00:00", loc)
		stime = stmp.Unix()
		etime = stime + 86399
	}
	var list []*models.PatientInformation
	list, err = service.FindMedicationList(orgid, drug_id, stime, etime, is_medicine)
	if err != nil {
		utils.ErrorLog(err.Error())
		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":  listll,
		"total": total,
	})
	return
}

// 药品管理发药按钮点击
func (this *PharmacyController) MedicineDeparture() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	creater, _ := this.GetInt64("creater", 0) //领药人
	ids := this.GetString("ids", "")          //发药的数据
	orgid := this.GetAdminUserInfo().CurrentOrgId
	if ids == "" {
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, "参数不足")
		return
	}

	err = service.MedicineDeparture(ids, creater, orgid)
	if err != nil {
		this.ServeFailJsonSend(enums.ErrorCodeParamWrong, err.Error())
		return
	}
	this.ServeSuccessJSON(map[string]interface{}{
		"list": "修改成功",
	})
	return
}

func (this *PharmacyController) GetPartitionList() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	orgid := this.GetAdminUserInfo().CurrentOrgId
	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": append(tmp, list...),
	})
	return
}

func (this *PharmacyController) RouteOfAdministration() {
	var err error
	defer func() {
		if rec := recover(); rec != nil {
			err = fmt.Errorf("程序异常：%v", rec)
		}
		if err != nil {
			service.SaveErrs(this.GetAdminUserInfo().CurrentOrgId, this.Ctx.Input, err)
		}
	}()
	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": append(tmp, list...),
	})
	return
}

func (this *PharmacyController) GetGoodInventoryList() {

	keyword := this.GetString("keywords")
	orgId := this.GetAdminUserInfo().CurrentOrgId
	list, _ := service.GetGoodInventoryList(keyword, orgId)
	manufacturerList, _ := service.GetAllManufacturerList(orgId)
	this.ServeSuccessJSON(map[string]interface{}{
		"list":             list,
		"manufacturerList": manufacturerList,
	})
	return
}

func (this *PharmacyController) GetGoodInventoryByGoodId() {

	id, _ := this.GetInt64("id")

	infoList, _ := service.GetGoodInventoryByGoodId(id)

	this.ServeSuccessJSON(map[string]interface{}{
		"infoList": infoList,
	})
}

func (this *PharmacyController) UpdateInventoryWarehouseInfo() {

	id, _ := this.GetInt64("id")

	stock_count, _ := this.GetInt64("stock_count")

	last_stock_count, _ := this.GetInt64("last_stock_count")

	good_id, _ := this.GetInt64("good_id")

	orgId := this.GetAdminUserInfo().CurrentOrgId

	storehouse_id, _ := this.GetInt64("storehouse_id")

	is_type, _ := this.GetInt64("is_type")

	warehouseInfo, _ := service.GetInventoryWarehouseInfo(id)
	goodInfo, _ := service.GetGoodInformationByGoodIdThirty(good_id)

	manufacturer, _ := service.GetManufactureById(warehouseInfo.Manufacturer)

	//更新库存
	service.UpdateWarehouseInfoById(last_stock_count, id)
	recordDateStr := time.Now().Format("2006-01-02")
	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
	goodListOne, _ := service.GetSumGoodList(orgId, storehouse_id, good_id)
	var flush_count int64
	for _, it := range goodListOne {
		flush_count += it.StockCount
	}
	//盘盈
	if last_stock_count > stock_count {
		var total_count int64
		total_count = last_stock_count - stock_count
		creater := this.GetAdminUserInfo().AdminUser.Id
		inventory := models.XtStockInventory{
			GoodName:          goodInfo.GoodName,
			SpecificationName: goodInfo.SpecificationName,
			WarehousingUnit:   goodInfo.PackingUnit,
			Count:             total_count,
			BuyPrice:          goodInfo.BuyPrice,
			PackingPrice:      goodInfo.PackingPrice,
			NewPrice:          0,
			Manufacturer:      manufacturer.ManufacturerName,
			Dealer:            "",
			Remark:            "",
			GoodId:            good_id,
			UserOrgId:         orgId,
			Ctime:             time.Now().Unix(),
			Mtime:             0,
			Status:            1,
			WarehousingOrder:  warehouseInfo.WarehousingOrder,
			LicenseNumber:     warehouseInfo.LicenseNumber,
			StartTime:         time.Now().Unix(),
			Creater:           creater,
			Checker:           0,
			CheckerStatus:     0,
			CheckerTime:       0,
			Total:             0,
			Number:            warehouseInfo.Number,
			WarehousingInfoId: id,
			ExpireDate:        warehouseInfo.ExpiryDate,
			ProductDate:       warehouseInfo.ProductDate,
			GoodOriginPlace:   "",
			Type:              10,
			InventoryType:     is_type,
			LastStockCount:    last_stock_count,
			StockCount:        stock_count,
			StorehouseId:      storehouse_id,
			RecordDate:        recordDate.Unix(),
		}
		service.CreateInentory(inventory)

		stockFlow := models.VmStockFlow{
			WarehousingId:           0,
			GoodId:                  good_id,
			Number:                  warehouseInfo.Number,
			LicenseNumber:           "",
			Count:                   total_count,
			UserOrgId:               orgId,
			PatientId:               0,
			SystemTime:              recordDate.Unix(),
			ConsumableType:          10,
			IsSys:                   0,
			WarehousingOrder:        warehouseInfo.WarehousingOrder,
			WarehouseOutId:          0,
			WarehouseOutOrderNumber: "",
			IsEdit:                  0,
			CancelStockId:           0,
			CancelOrderNumber:       "",
			Manufacturer:            warehouseInfo.Manufacturer,
			Dealer:                  0,
			Creator:                 creater,
			UpdateCreator:           0,
			Status:                  1,
			Ctime:                   time.Now().Unix(),
			Mtime:                   0,
			Price:                   warehouseInfo.Price,
			WarehousingDetailId:     0,
			WarehouseOutDetailId:    0,
			CancelOutDetailId:       0,
			ProductDate:             warehouseInfo.ProductDate,
			ExpireDate:              warehouseInfo.ExpiryDate,
			ReturnCount:             0,
			StorehouseId:            storehouse_id,
			OverCount:               flush_count,
		}
		service.CreateStockFlowOne(stockFlow)

		service.ReduceSumOutCount(good_id, total_count, storehouse_id, orgId)
	}

	//盘亏
	if last_stock_count < stock_count {
		var total_count int64
		total_count = stock_count - last_stock_count
		creater := this.GetAdminUserInfo().AdminUser.Id
		inventory := models.XtStockInventory{
			GoodName:          goodInfo.GoodName,
			SpecificationName: goodInfo.SpecificationName,
			WarehousingUnit:   goodInfo.PackingUnit,
			Count:             total_count,
			BuyPrice:          goodInfo.BuyPrice,
			PackingPrice:      goodInfo.PackingPrice,
			NewPrice:          0,
			Manufacturer:      manufacturer.ManufacturerName,
			Dealer:            "",
			Remark:            "",
			GoodId:            good_id,
			UserOrgId:         orgId,
			Ctime:             time.Now().Unix(),
			Mtime:             0,
			Status:            1,
			WarehousingOrder:  warehouseInfo.WarehousingOrder,
			LicenseNumber:     warehouseInfo.LicenseNumber,
			StartTime:         time.Now().Unix(),
			Creater:           creater,
			Checker:           0,
			CheckerStatus:     0,
			CheckerTime:       0,
			Total:             0,
			Number:            warehouseInfo.Number,
			WarehousingInfoId: id,
			ExpireDate:        warehouseInfo.ExpiryDate,
			ProductDate:       warehouseInfo.ProductDate,
			GoodOriginPlace:   "",
			Type:              10,
			InventoryType:     is_type,
			LastStockCount:    last_stock_count,
			StockCount:        stock_count,
			StorehouseId:      storehouse_id,
			RecordDate:        recordDate.Unix(),
		}
		service.CreateInentory(inventory)

		stockFlow := models.VmStockFlow{
			WarehousingId:           0,
			GoodId:                  good_id,
			Number:                  warehouseInfo.Number,
			LicenseNumber:           "",
			Count:                   total_count,
			UserOrgId:               orgId,
			PatientId:               0,
			SystemTime:              recordDate.Unix(),
			ConsumableType:          11,
			IsSys:                   0,
			WarehousingOrder:        warehouseInfo.WarehousingOrder,
			WarehouseOutId:          0,
			WarehouseOutOrderNumber: "",
			IsEdit:                  0,
			CancelStockId:           0,
			CancelOrderNumber:       "",
			Manufacturer:            warehouseInfo.Manufacturer,
			Dealer:                  0,
			Creator:                 creater,
			UpdateCreator:           0,
			Status:                  1,
			Ctime:                   time.Now().Unix(),
			Mtime:                   0,
			Price:                   warehouseInfo.Price,
			WarehousingDetailId:     0,
			WarehouseOutDetailId:    0,
			CancelOutDetailId:       0,
			ProductDate:             warehouseInfo.ProductDate,
			ExpireDate:              warehouseInfo.ExpiryDate,
			ReturnCount:             0,
			StorehouseId:            storehouse_id,
			OverCount:               flush_count,
		}
		service.CreateStockFlowOne(stockFlow)
		service.ReduceSumInCount(good_id, total_count, storehouse_id, orgId)
	}

	//查询已审核单据的剩余库存
	goodList, _ := service.GetGoodSumCountByStoreId(storehouse_id, good_id, orgId)
	var sum_count int64
	var sum_in_count int64
	for _, item := range goodList {
		sum_count += item.StockCount
		sum_in_count += item.WarehousingCount
	}
	service.UpdateGoodByGoodId(good_id, sum_count, sum_in_count, orgId)

	service.UpdateSumGood(orgId, storehouse_id, good_id, flush_count)
	this.ServeSuccessJSON(map[string]interface{}{
		"msg": "msg",
	})

}

func (this *PharmacyController) GetDrugInventoryList() {

	keywords := this.GetString("keywords")
	orgId := this.GetAdminUserInfo().CurrentOrgId
	drugList, _ := service.GetDrugNewInventoryList(orgId, keywords)
	manufacturerList, _ := service.GetAllManufacturerList(orgId)
	this.ServeSuccessJSON(map[string]interface{}{
		"drugList":         drugList,
		"manufacturerList": manufacturerList,
	})
}

func (this *PharmacyController) GetDrugInventoryByDrugId() {

	orgId := this.GetAdminUserInfo().CurrentOrgId

	id, _ := this.GetInt64("id")

	infoList, _ := service.GetDrugInvetoryByDrugId(orgId, id)

	this.ServeSuccessJSON(map[string]interface{}{
		"infoList": infoList,
	})
}

func (this *PharmacyController) UpdateDrugInventoryWarehouseInfo() {

	id, _ := this.GetInt64("id")
	stock_max_number, _ := this.GetInt64("stock_max_number")
	stock_min_number, _ := this.GetInt64("stock_min_number")
	last_stock_max_number, _ := this.GetInt64("last_stock_max_number")
	last_stock_min_number, _ := this.GetInt64("last_stock_min_number")

	drug_id, _ := this.GetInt64("drug_id")
	storehouse_id, _ := this.GetInt64("storehouse_id")
	is_type, _ := this.GetInt64("is_type")

	specification_name := this.GetString("specification_name")
	orgId := this.GetAdminUserInfo().CurrentOrgId

	base, _ := service.GetBasedrugByIdOne(drug_id, orgId)

	var ord_total int64
	var new_total int64
	var consumable_count int64

	ord_total = stock_max_number*base.MinNumber + stock_min_number
	new_total = last_stock_max_number*base.MinNumber + last_stock_min_number

	//更新入库单
	service.UpdateNewDrugWarehouseInfoById(id, last_stock_max_number, last_stock_min_number)

	//查询默认仓库
	houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
	//查询默认仓库剩余多少库存
	list, _ := service.GetDrugSumCountByStorehouseId(houseConfig.DrugStorehouseOut, orgId, drug_id)
	var sum_count int64
	for _, it := range list {
		baseDrug, _ := service.GetBaseDrugMedical(it.DrugId)
		if it.MaxUnit == baseDrug.MaxUnit {
			it.StockMaxNumber = it.StockMaxNumber * baseDrug.MinNumber
			it.WarehousingCount = it.WarehousingCount * baseDrug.MinNumber
		}
		sum_count += it.StockMaxNumber + it.StockMinNumber

	}
	//更新剩余库存
	service.UpdateMedicalSumCountOne(drug_id, sum_count, orgId)

	//更新剩余库存
	service.UpdateDrugStockCount(drug_id, orgId, houseConfig.DrugStorehouseOut, sum_count)

	drugWarehouseInfoOne, _ := service.GetDrugWarehouseInfoOne(id)

	manufacturer, _ := service.GetManufactureById(drugWarehouseInfoOne.Manufacturer)

	recordDateStr := time.Now().Format("2006-01-02")

	recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)

	baseDrug, _ := service.GetBaseDrugMedical(drug_id)

	//盘亏
	if ord_total > new_total {

		consumable_count = ord_total - new_total

		inventory := models.XtDrugInventory{
			DrugName:           base.DrugName,
			SpecificationName:  specification_name,
			WarehousingUnit:    drugWarehouseInfoOne.MaxUnit,
			Count:              consumable_count,
			LastPrice:          drugWarehouseInfoOne.Price,
			RetailPrice:        drugWarehouseInfoOne.RetailPrice,
			NewPrice:           0,
			Manufacturer:       manufacturer.ManufacturerName,
			Dealer:             "",
			Remark:             "",
			DrugId:             drug_id,
			UserOrgId:          orgId,
			Ctime:              time.Now().Unix(),
			Mtime:              0,
			Status:             1,
			WarehousingOrder:   drugWarehouseInfoOne.WarehousingOrder,
			LicenseNumber:      "",
			StartTime:          recordDate.Unix(),
			Creater:            this.GetAdminUserInfo().AdminUser.Id,
			Checker:            0,
			CheckerStatus:      0,
			CheckerTime:        0,
			ExpiryDate:         drugWarehouseInfoOne.ExpiryDate,
			ProductDate:        drugWarehouseInfoOne.ProductDate,
			Number:             "",
			BatchNumber:        drugWarehouseInfoOne.BatchNumber,
			Total:              "",
			DrugOriginPlace:    "",
			WarehouseInfoId:    id,
			ProofCount:         0,
			StockMaxNumber:     stock_max_number,
			StockMinNumber:     stock_min_number,
			MinCount:           0,
			MinUnit:            baseDrug.MinUnit,
			LastStockMaxNumber: last_stock_max_number,
			LastStockMinNumber: last_stock_min_number,
			InventoryType:      11,
			Type:               is_type,
			StorehouseId:       storehouse_id,
			RecordDate:         recordDate.Unix(),
		}

		service.CreateDrugInventory(inventory)

		flow := models.DrugFlow{
			WarehousingId:           id,
			DrugId:                  drug_id,
			Number:                  "",
			BatchNumber:             drugWarehouseInfoOne.BatchNumber,
			Count:                   consumable_count,
			UserOrgId:               orgId,
			PatientId:               0,
			SystemTime:              recordDate.Unix(),
			ConsumableType:          11,
			IsSys:                   1,
			WarehousingOrder:        drugWarehouseInfoOne.WarehousingOrder,
			WarehouseOutId:          0,
			WarehouseOutOrderNumber: "",
			IsEdit:                  0,
			CancelStockId:           0,
			CancelOrderNumber:       "",
			Manufacturer:            manufacturer.ID,
			Dealer:                  0,
			Creator:                 this.GetAdminUserInfo().AdminUser.Id,
			UpdateCreator:           0,
			Status:                  1,
			Ctime:                   time.Now().Unix(),
			Mtime:                   0,
			Price:                   drugWarehouseInfoOne.Price,
			WarehousingDetailId:     id,
			WarehouseOutDetailId:    0,
			CancelOutDetailId:       0,
			ExpireDate:              drugWarehouseInfoOne.ExpiryDate,
			ProductDate:             0,
			MaxUnit:                 baseDrug.MinUnit,
			MinUnit:                 baseDrug.MinUnit,
			StorehouseId:            storehouse_id,
			OverCount:               sum_count,
		}
		service.CreateDrugFlowOne(flow)

		//添加出库数据
		service.AddDrugWarehouseOut(drug_id, consumable_count, storehouse_id, orgId)

	}

	//盘盈
	if ord_total < new_total {

		consumable_count = new_total - ord_total

		inventory := models.XtDrugInventory{
			DrugName:           base.DrugName,
			SpecificationName:  specification_name,
			WarehousingUnit:    drugWarehouseInfoOne.MinUnit,
			Count:              consumable_count,
			LastPrice:          drugWarehouseInfoOne.Price,
			RetailPrice:        drugWarehouseInfoOne.RetailPrice,
			NewPrice:           0,
			Manufacturer:       manufacturer.ManufacturerName,
			Dealer:             "",
			Remark:             "",
			DrugId:             drug_id,
			UserOrgId:          orgId,
			Ctime:              time.Now().Unix(),
			Mtime:              0,
			Status:             1,
			WarehousingOrder:   drugWarehouseInfoOne.WarehousingOrder,
			LicenseNumber:      "",
			StartTime:          recordDate.Unix(),
			Creater:            this.GetAdminUserInfo().AdminUser.Id,
			Checker:            0,
			CheckerStatus:      0,
			CheckerTime:        0,
			ExpiryDate:         drugWarehouseInfoOne.ExpiryDate,
			ProductDate:        drugWarehouseInfoOne.ProductDate,
			Number:             "",
			BatchNumber:        drugWarehouseInfoOne.BatchNumber,
			Total:              "",
			DrugOriginPlace:    "",
			WarehouseInfoId:    id,
			ProofCount:         0,
			StockMaxNumber:     stock_max_number,
			StockMinNumber:     stock_min_number,
			MinCount:           0,
			MinUnit:            baseDrug.MinUnit,
			LastStockMaxNumber: last_stock_max_number,
			LastStockMinNumber: last_stock_min_number,
			InventoryType:      10,
			Type:               is_type,
			StorehouseId:       storehouse_id,
			RecordDate:         recordDate.Unix(),
		}

		service.CreateDrugInventory(inventory)

		flow := models.DrugFlow{
			WarehousingId:           id,
			DrugId:                  drug_id,
			Number:                  "",
			BatchNumber:             drugWarehouseInfoOne.BatchNumber,
			Count:                   consumable_count,
			UserOrgId:               orgId,
			PatientId:               0,
			SystemTime:              recordDate.Unix(),
			ConsumableType:          10,
			IsSys:                   1,
			WarehousingOrder:        drugWarehouseInfoOne.WarehousingOrder,
			WarehouseOutId:          0,
			WarehouseOutOrderNumber: "",
			IsEdit:                  0,
			CancelStockId:           0,
			CancelOrderNumber:       "",
			Manufacturer:            manufacturer.ID,
			Dealer:                  0,
			Creator:                 this.GetAdminUserInfo().AdminUser.Id,
			UpdateCreator:           0,
			Status:                  1,
			Ctime:                   time.Now().Unix(),
			Mtime:                   0,
			Price:                   drugWarehouseInfoOne.Price,
			WarehousingDetailId:     id,
			WarehouseOutDetailId:    0,
			CancelOutDetailId:       0,
			ExpireDate:              drugWarehouseInfoOne.ExpiryDate,
			ProductDate:             0,
			MaxUnit:                 baseDrug.MinUnit,
			MinUnit:                 baseDrug.MinUnit,
			StorehouseId:            storehouse_id,
			OverCount:               sum_count,
		}
		service.CreateDrugFlowOne(flow)

		//减少出库数据
		service.ReduceDrugWarehouseOut(drug_id, consumable_count, storehouse_id, orgId)
	}

	this.ServeSuccessJSON(map[string]interface{}{
		"msg": "msg",
	})
}

func (this *PharmacyController) ChangeDrugCode() {

	orgId := this.GetAdminUserInfo().CurrentOrgId
	dataBody := make(map[string]interface{}, 0)
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &dataBody)
	fmt.Println("err", err)
	id := int64(dataBody["id"].(float64))

	data_source := int64(dataBody["data_source"].(float64))

	drug_code := dataBody["drug_code"].(string)

	//if dataBody["codeinfo"] != nil && reflect.TypeOf(dataBody["codeinfo"]).String() == "[]interface {}" {
	//	prescriptions, _ := dataBody["codeinfo"].([]interface{})
	//	if len(prescriptions) > 0 {
	//		for _, item := range prescriptions {
	//			var name string
	//			if item.(map[string]interface{})["name"] != nil || reflect.TypeOf(item.(map[string]interface{})["name"]).String() == "string" {
	//				name = item.(map[string]interface{})["name"].(string)
	//			}
	//			var count int64
	//			if item.(map[string]interface{})["count"] != nil || reflect.TypeOf(item.(map[string]interface{})["count"]).String() == "float64" {
	//				count = int64(item.(map[string]interface{})["count"].(float64))
	//			}
	//
	//			fmt.Println("name=====", name)
	//			fmt.Println("count====", count)
	//
	//			//hisPrescriptionProject, _ := service.GetHisPrescriptionByProject(id)
	//
	//			//查询这个耗材的已经扫码过的数据
	//			//service.GetWarehouseOoutInfo(name)
	//
	//		}
	//	}
	//}

	str := strings.Replace(drug_code, " ", "", -1)
	// 去除换行符
	str = strings.Replace(str, "\n", "", -1)

	if data_source == 1 {
		service.ChangeHisDrugCode(id, str, orgId)

	}

	if data_source == 2 {
		service.ChangeAdivceDrugCode(id, str, orgId)
	}

	//耗材
	if data_source == 3 {

		if orgId == 10164 {

			//fmt.Println("roleIds", role_ids)
			//for _, item := range role_ids {
			//	fmt.Println("item------", item)
			//}
		}
		service.ChangeHisProjectCode(id, str, orgId)
	}

	this.ServeSuccessJSON(map[string]interface{}{
		"msg": "msg",
	})
}

func CountOccurrences(roleIds []int64) []map[int64]int {
	// 创建一个map来记录每个值的出现次数
	countMap := make(map[int64]int)

	// 遍历数组，统计每个值的出现次数
	for _, id := range roleIds {
		countMap[id]++
	}

	// 将统计结果转换为数组对象
	var result []map[int64]int
	for id, count := range countMap {
		result = append(result, map[int64]int{id: count})
	}

	return result
}

func (this *PharmacyController) ChangeZeroFlag() {
	id, _ := this.GetInt64("id")
	orgId := this.GetAdminUserInfo().CurrentOrgId
	zero_flag, _ := this.GetInt64("zero_flag")
	fmt.Println(id)
	fmt.Println(zero_flag)
	service.ChangeAdivceZeroFlag(id, zero_flag, orgId)
	this.ServeSuccessJSON(map[string]interface{}{
		"msg": "msg",
	})

}

func (this *PharmacyController) GetDrugTocalCount() {

	timeLayout := "2006-01-02"
	loc, _ := time.LoadLocation("Local")
	drug_id, _ := this.GetInt64("drug_id")
	start_time := this.GetString("start_time")
	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 {
			fmt.Println(err)
			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
			return
		}
		startTime = theTime.Unix()
	}
	orgId := this.GetAdminUserInfo().CurrentOrgId

	adviceList, _ := service.GetDrugTocalCountByDrugId(drug_id, startTime, orgId)

	drug, _ := service.GetNewBaseDrugById(drug_id)

	this.ServeSuccessJSON(map[string]interface{}{
		"adviceList": adviceList,
		"drug":       drug,
	})
}