XT_New/service/pharmacy_service.go

package service

import (
	"XT_New/models"
	"XT_New/utils"
	"encoding/json"
	"fmt"
	"github.com/astaxie/beego/config"
	"github.com/astaxie/beego/context"
	"github.com/jinzhu/gorm"
	"math"
	"strconv"
	"strings"
	"time"
)
func SaveErrs(org_id int64,input *context.BeegoInput,err error){
	dataBody := make(map[string]interface{}, 0)
	json.Unmarshal(input.RequestBody, &dataBody)
	route := input.Context.Request.RequestURI
	parameter := MapToJson(dataBody)
	tmp := models.XtErrs{
		org_id,
		route,
		parameter,
		err.Error(),
	}
	XTWriteDB().Create(&tmp)
}

//
func SavePharmacy() (err error){
	var advice_info []*models.HisDoctorAdviceInfo
	err = XTReadDB().Raw("select * from xt_doctor_advice where id > 21780 and id < 21790").Scan(&advice_info).Error
	if err != nil {
		return
	}
	return nil
}

//查询药房中某一天的患者人数,is_medicine:0未发，1已发(改)
func GetTodayPharmacy(stime,etime,orgid,is_medicine int64) (num int, err error) {
	InitDrugidIsNil(orgid,stime,etime)
	var tmp []*models.TmpTTT
	err = XTReadDB().Raw("select distinct patient_id from his_doctor_advice_info where " +
		"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
		"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) " +
		"union " +
		"select distinct patient_id from xt_doctor_advice where " +
		"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
		"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) ",
		stime,etime,orgid,is_medicine,orgid,stime,etime,orgid,is_medicine,orgid).Scan(&tmp).Error
	if err != nil {
		return
	}
	return len(tmp),err

}
//(改)
func GetTodayDrug(stime,etime,orgid,is_medicine int64, keyword string)(list []*models.TmpPatient,err error){
	InitDrugidIsNil(orgid,stime,etime)
	//病人
	var tmp []*models.TmpTTT
	//tmp := make([]string,0)
	if keyword != ""{
		keyword = "%"+keyword+"%"
		err = XTReadDB().Raw("select distinct patient_id from his_doctor_advice_info where " +
			"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"patient_id in (select id from xt_patients where user_org_id = ? and name like ? or dialysis_no like ?) and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) " +
			"union " +
			"select distinct patient_id from xt_doctor_advice where " +
			"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"patient_id in (select id from xt_patients where user_org_id = ? and name like ? or dialysis_no like ?) and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) ",
			stime,etime,orgid,is_medicine,orgid,keyword,keyword,orgid,stime,etime,orgid,is_medicine,orgid,keyword,keyword,orgid).Scan(&tmp).Error
	}else {
		err = XTReadDB().Raw("select distinct patient_id from his_doctor_advice_info where " +
			"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) " +
			"union " +
			"select distinct patient_id from xt_doctor_advice where " +
			"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) ",
			stime,etime,orgid,is_medicine,orgid,stime,etime,orgid,is_medicine,orgid).Scan(&tmp).Error
	}

	if err != nil {
		return
	}
	tmp_s := make([]int64,0)
	for _,v := range tmp{
		tmp_s = append(tmp_s,v.PatientID)
	}
	list,err = GetManyUsers(tmp_s)
	return

}
//查询患者（改）
func GetManyUsers(tmp []int64) (list []*models.TmpPatient,err error){
	var tt []*models.Patients
	err = XTReadDB().Model(&models.Patients{}).Where("id in (?)",tmp).Find(&tt).Error
	for _,v := range tt{
		tmp_list := &models.TmpPatient{
			PatientID: v.ID,
			Name: v.Name,
			DialysisNo: v.DialysisNo,
		}
		list = append(list,tmp_list)
	}
	return
}

//查询患者当天时间段中的药,is_medicine:0未发，1已发(改)
func GetPatientMedication(orgid,patient_id,stime,etime,is_medicine int64)(pp []*models.PharmacyContent, err error){
	InitDrugidIsNil(orgid,stime,etime)
	var tmp []*models.HisDoctorAdviceInfoL
	err = XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where(
		"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and patient_id = ? and is_medicine = ? and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",stime,etime,orgid,patient_id,is_medicine,orgid).Find(&tmp).Error
	if err != nil{
		return pp, err
	}
	for _,v := range tmp{
		pp = append(pp,&models.PharmacyContent{
			Name: v.AdviceName,
			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
			Usage: v.DeliveryWay,
			Frequency: v.ExecutionFrequency,
			Days: config.ToString(v.Day)+"天",
			Total: config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
			Doctor: GetAdminUserName(v.AdviceDoctor,orgid),//开立医生
			DataSources: "his处方",
			Remarks: v.Remark,//备注
		})
	}

	var tmp_advice []*models.XtDoctorAdviceL
	err = XTReadDB().Model(&models.XtDoctorAdviceL{}).Where(
		"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and patient_id = ? and is_medicine = ? and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",stime,etime,orgid,patient_id,is_medicine,orgid).Find(&tmp_advice).Error
	if err != nil{
		return pp, err
	}
	for _,v := range tmp_advice{
		pp = append(pp,&models.PharmacyContent{
			Name: v.AdviceName,
			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
			Usage: v.DeliveryWay,
			Frequency: v.ExecutionFrequency,
			Days: "-",
			Total: config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
			Doctor: GetAdminUserName(v.AdviceDoctor,orgid),
			DataSources: "临时医嘱",
			Remarks: v.Remark,
		})
	}
	return
}

//获取创建者姓名(改)
func GetAdminUserName(doctor,orgid int64) string{
	var tmp models.VmUserAdminRole
	XTReadDB().Model(&models.VmUserAdminRole{}).Where("admin_user_id = ? and org_id = ? and status = 1",doctor,orgid).Find(&tmp)
	return tmp.UserName
}
//查询该机构的药房配置,true: 通过药房发药，false：不通过药房发药。如果没有该机构的信息则生成一条数据
func GetOrgIdPharmacyConfig(orgid int64) bool {
	var total int
	var tmp_pharmacy models.PharmacyConfig
	XTReadDB().Model(&models.PharmacyConfig{}).Where("user_org_id = ? and status = 1",orgid).Find(&tmp_pharmacy).Count(&total)
	if total > 0 {
		//有记录
		if tmp_pharmacy.IsOpen == 1{
			return true
		}else {
			return false
		}
	}else {
		//没有记录生成一条
		tmp := models.PharmacyConfig{
			UserOrgId: orgid,
			IsOpen: 2,
			Status: 1,
			Ctime: time.Now().Unix(),
			Mtime: time.Now().Unix(),
		}
		XTWriteDB().Create(&tmp)
		return false
	}
}
//修改该机构的药房配置
func ModifyPharmacyConfig(orgid,isopen int64)(err error){
	if isopen == 1 || isopen == 2 {
		err = XTWriteDB().Model(&models.PharmacyConfig{}).Where("user_org_id = ? and status = 1",orgid).Updates(map[string]interface{}{
			"mtime": time.Now().Unix(),
			"is_open": isopen,
		}).Error
	}else {
		err = fmt.Errorf("类型解析错误")
	}
	return
}
//查询该药品是否通过药房发药.0否；1是
func DrugAllocation(drug_id int64) (is_pharmacy int64,err error){
	tmp := models.BaseDrugLib{}
	err = XTReadDB().Model(&models.BaseDrugLib{}).Where("id = ?",drug_id).Find(&tmp).Error
	return tmp.IsPharmacy,err
}

//根据id查询该药是否发药
func MedicineState(id int64)(is_medicine models.HisDoctorAdviceInfoL,err error){
	tmp := models.HisDoctorAdviceInfoL{}
	err = XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id = ?",id).Find(&tmp).Error
	return tmp,err
}
//发药明细列表(
func DispensingDetailsList(stime,etime,orgid,page,limit int64,keyword string)(dislist []*models.DispensingList,total int64,err error){
	var fenye []*models.Pharmary//分页用的
	offset := (page - 1) * limit
	dbone := XTReadDB().Model(&models.Pharmary{}).Where("status = 1 and user_org_id = ? and record_date >= ? and record_date <= ?",orgid,stime,etime)
	if keyword != ""{
		var tmp_id []*models.TmpID
		keyword = "%"+keyword+"%"
		XTReadDB().Raw("select id from xt_patients where name like ? and user_org_id = ?",keyword,orgid).Scan(&tmp_id)
		tmp_ids := make([]int64,0)
		for _,v := range tmp_id{
			tmp_ids = append(tmp_ids,v.Id)
		}
		dbone = dbone.Where("patient_id in (?)",tmp_ids)
	}
	//查询出分页用的数据
	err = dbone.Count(&total).Offset(offset).Order("mtime desc").Limit(limit).Find(&fenye).Error
	if err != nil{
		return
	}
	for _,v := range fenye{
		tmp_doctorid,tmp_doctorname,errs := GetDoctorIds(v.PatientId,v.RecordDate,orgid)
		if errs != nil {
			err = errs
			return
		}
		pat,_ := GetPatientName(v.PatientId)
		dislist = append(dislist,&models.DispensingList{
			PatientID: v.PatientId,
			Name: pat.Name,
			DoctorId: tmp_doctorid,
			DoctorName: tmp_doctorname,
			RecordTime: v.RecordDate,
			RecordDate: fmt.Sprintf(time.Unix(v.RecordDate, 0).Format("2006-01-02 15:04:05")),
		})
	}
	return
}

//处方详情//////////////////////
func PrescriptionDetails(patient_id,record_date,orgid int64) (pre []*models.PrescripDetails,err error){
	var tmp []*models.HisDoctorAdviceInfoL
	err = XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where(
		"status = 1 and patient_id = ? and user_org_id = ? and dispensing_time = ? and is_medicine = 1 and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",patient_id,orgid,record_date,orgid).Find(&tmp).Error
	if err != nil{
		return
	}
	for _,v := range tmp{
		pre = append(pre,&models.PrescripDetails{
			Drugname:v.AdviceName,
			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
			Usage: v.DeliveryWay,
			Frequency: v.ExecutionFrequency,
			Days: config.ToString(v.Day) + "天",
			Total: config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
			UnitPrice:config.ToString(v.Price) + "元" ,
			Remarks: v.Remark,
		})
	}

	var tmp_advice []*models.XtDoctorAdviceL
	err = XTReadDB().Model(&models.XtDoctorAdviceL{}).Where(
		"status = 1 and (advice_type = 2 or advice_type = 3) and patient_id = ? and user_org_id = ? and dispensing_time = ? and is_medicine = 1 and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",patient_id,orgid,record_date,orgid).Find(&tmp_advice).Error
	if err != nil{
		return
	}
	for _,v := range tmp_advice{
		pre = append(pre,&models.PrescripDetails{
			Drugname:v.AdviceName,
			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
			Usage: v.DeliveryWay,
			Frequency: v.ExecutionFrequency,
			Days:"-",
			Total: config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
			UnitPrice:"-" ,
			Remarks: v.Remark,
		})
	}
	return
}

//查询病人的his id
func GetHisID(prescription_id,orgid int64)(id int64){
	var tmp models.HisPrintPrescription
	XTReadDB().Model(&models.HisPrintPrescription{}).Where("id = ?",prescription_id).Find(&tmp)
	var fin models.HisPrescriptionInfoTwo
	XTReadDB().Model(&models.HisPrescriptionInfoTwo{}).Where("prescription_number = ? and user_org_id = ?",tmp.PrescriptionNumber,orgid).Find(&fin)
	return fin.ID
}

//根据药品id获取药品信息
func GetDrugNameTX(id int64,tx *gorm.DB)(tmp models.SpBaseDrug,err error){
	err = tx.Model(&models.SpBaseDrug{}).Where("id = ? and status = 1",id).Find(&tmp).Error
	return
}
func GetXtManufacturer(id int64,tx *gorm.DB)(name string,err error){
	var tmp models.Manufacturer
	err = tx.Model(&models.Manufacturer{}).Where("id = ? and status = 1",id).Find(&tmp).Error
	name = tmp.ManufacturerName
	return
}
//查询药品（使用keyword）
func GetManyDrugs(orgid int64,keyword string) (map[int64]models.PharmacyBaseDrug,error){
	var tmp []*models.PharmacyBaseDrug
	tt := make(map[int64]models.PharmacyBaseDrug)
	err := XTReadDB().Model(&models.PharmacyBaseDrug{}).Where(" org_id = ? ",orgid).Where(" drug_name like ? ","%"+keyword+"%").Find(&tmp).Error
	for _,v := range tmp{
		tt[v.ID] = *v
	}
	return tt,err
}
//查询(
func GetTodayMedicine(stime,etime,orgid,is_medicine int64,keyword string)(finlly []*models.ListOfDrugs,err error){
	InitDrugidIsNil(orgid,stime,etime)
	var tmp []*models.TmpLLL
	if keyword != ""{
		keyword = "%"+keyword+"%"
		err = XTReadDB().Raw("select distinct drug_id from his_doctor_advice_info where " +
			"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and drug_name like ? and is_pharmacy = 1) " +
			"union " +
			"select distinct drug_id from xt_doctor_advice where " +
			"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and drug_name like ? and is_pharmacy = 1)",
			stime,etime,orgid,is_medicine,orgid,keyword,stime,etime,orgid,is_medicine,orgid,keyword).Scan(&tmp).Error
	}else{
		err = XTReadDB().Raw("select distinct drug_id from his_doctor_advice_info where " +
			"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) " +
			"union " +
			"select distinct drug_id from xt_doctor_advice where " +
			"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and is_medicine = ? and " +
			"drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) ",
			stime,etime,orgid,is_medicine,orgid,stime,etime,orgid,is_medicine,orgid).Scan(&tmp).Error
	}

	if err != nil {
		return
	}
	for _,v := range tmp{
		name,specifications := FindDrugSpecifications(v.DrugId)
		number,errs := GetInventoryQuantity(orgid,v.DrugId)
		if errs != nil{
			err = errs
			return
		}
		finlly = append(finlly,&models.ListOfDrugs{
			ID: v.DrugId,
			Name: name,
			Specifications: specifications,
			Stock: number,
		})
	}
	return
}
//根据药品id获取药品规格(
func FindDrugSpecifications(id int64)(name,specifications string){
	var tmp models.PharmacyBaseDrug
	XTReadDB().Model(&models.PharmacyBaseDrug{}).Where("id = ?",id).Find(&tmp)
	name = tmp.DrugName
	specifications = config.ToString(tmp.Dose)+tmp.DoseUnit+"*"+config.ToString(tmp.MinNumber)+tmp.MinUnit+"/"+config.ToString(tmp.MaxUnit)
	return
}
//根据药品id获取当前药品出库仓库的库存数量
func GetInventoryQuantity(orgid,drugid int64)(number string,err error){
	//获取药品拆零数量
	var phar models.PharmacyBaseDrug
	XTReadDB().Model(&models.PharmacyBaseDrug{}).Where("id = ?",drugid).Find(&phar)
	min_number := phar.MinNumber
	if min_number == 0{
		err = fmt.Errorf("药品拆零数量不能为零！")
		return
	}
	storeconfig,_ := FindStorehouseConfig(orgid)
	var tmp []models.SpDrugWarehouseInfo
	XTReadDB().Model(&models.SpDrugWarehouseInfo{}).Where("org_id = ? and drug_id = ? and storehouse_id = ? and status = 1",orgid,drugid,storeconfig.DrugStorehouseOut).Find(&tmp)
	max,min := int64(0),int64(0)
	for _,v := range tmp{
		max += v.StockMaxNumber
		min += v.StockMinNumber
	}
	max += min/min_number
	min = min%min_number
	if max != 0{
		number = config.ToString(max)+phar.MaxUnit
	}
	if min != 0{
		number = number+config.ToString(min)+phar.MinUnit
	}
	if number == ""{
		number = "0"
	}
	//number = config.ToString(max)+phar.MaxUnit+config.ToString(min)+phar.MinUnit
	return
}
//获取该药品的病人信息(
func FindMedicationList(orgid,drug_id,stime,etime,is_medicine int64)(pp []*models.PatientInformation,err error){///////////////
	InitDrugidIsNil(orgid,stime,etime)
	var tmp []*models.HisDoctorAdviceInfoL
	err = XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where(
		"status = 1 and created_time >= ? and created_time <= ? and user_org_id = ? and drug_id = ? and is_medicine = ?",stime,etime,orgid,drug_id,is_medicine).Find(&tmp).Error
	if err != nil{
		return pp, err
	}
	for _,v := range tmp{
		pp = append(pp,&models.PatientInformation{
			Id: "h"+config.ToString(v.ID),
			Name: FindUserName(v.PatientId),
			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
			Usage: v.DeliveryWay,
			Frequency: v.ExecutionFrequency,
			Days: config.ToString(v.Day)+"天",
			Total: config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
			DataSources: "his处方",
			People: GetUserAdminName(v.People,orgid),//领药人！！！！！！！！！！！！！！！！！！！！！！
		})
	}

	var tmp_advice []*models.XtDoctorAdviceL
	err = XTReadDB().Model(&models.XtDoctorAdviceL{}).Where(
		"status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and user_org_id = ? and drug_id = ? and is_medicine = ?",stime,etime,orgid,drug_id,is_medicine).Find(&tmp_advice).Error
	if err != nil{
		return pp, err
	}
	for _,v := range tmp_advice{
		pp = append(pp,&models.PatientInformation{
			Id: "x"+config.ToString(v.ID),
			Name: FindUserName(v.PatientId),
			SingleDosage: config.ToString(v.SingleDose) + v.SingleDoseUnit,
			Usage: v.DeliveryWay,
			Frequency: v.ExecutionFrequency,
			Days: "",
			Total: config.ToString(v.PrescribingNumber) + v.PrescribingNumberUnit,
			DataSources: "临时医嘱",
			People: GetUserAdminName(v.People,orgid),//领药人
		})
	}
	return
}
//患者发药按钮点击（
func DispensingMedicine(orgid,patient_id,stime,etime,creater int64)(err error){
	//开事务
	tx := XTWriteDB().Begin()
	defer func() {
		if err != nil {
			utils.ErrorLog("事务失败，原因为: %v", err)
			tx.Rollback()
		} else {
			tx.Commit()
		}
	}()
	time_now := time.Now().Unix()
	var hids []*models.TmpID
	var xids []*models.TmpID
	err = tx.Raw("select id from his_doctor_advice_info where status = 1 and created_time >= ? and created_time <= ? " +
		"and user_org_id = ? and patient_id = ? and is_medicine = 0 and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) ",stime,etime,orgid,patient_id,orgid).Scan(&hids).Error
	if err != nil {
		return
	}
	hid := make([]int64,0)
	for _,v := range hids{
		hid = append(hid,v.Id)
	}
	var advice_info []*models.HisDoctorAdviceInfo
	err = tx.Model(&models.HisDoctorAdviceInfo{}).Where("id in (?) and status = 1",hid).Find(&advice_info).Error
	if err != nil{
		return
	}
	for _,v := range advice_info{
		tmp_bool := IsPharmacyConfig(orgid)
		if tmp_bool{
			kou := FenDrugInventory(v,orgid)
			if !kou {
				err = fmt.Errorf(FindDrugsName(v.DrugId)+"库存不足")
				return
			}
			if PettyCash(v.DrugId){
				continue
			}
			//扣减库存
			err = FenStock(orgid,creater,v)
			if err != nil {
				err = fmt.Errorf("!:%v",err)
				return
			}
		}
	}
	//修改状态
	errs := XTWriteDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id in (?)",hid).Updates(map[string]interface{}{
		"is_medicine": 1,
		"people": 0,
		"dispensing_time": time_now,
		"updated_time": time.Now().Unix(),
	}).Error
	if errs != nil{
		return errs
	}
	err1 := ChangeHisPrescription(hid)
	if err1 != nil{
		return err1
	}


	err = tx.Raw("select id from xt_doctor_advice where status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and " +
		"user_org_id = ? and patient_id = ? and is_medicine = 0 and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",stime,etime,orgid,patient_id,orgid).Scan(&xids).Error
	if err != nil {
		return
	}
	xid := make([]int64,0)
	for _,v := range xids{
		xid = append(xid,v.Id)
	}
	var advice []*models.HisDoctorAdviceInfo
	err = tx.Raw("select * from xt_doctor_advice where id in (?) and status = 1",xid).Scan(&advice).Error
	if err != nil{
		return
	}
	for _,v := range advice{
		tmp_bool := IsPharmacyConfig(orgid)
		if tmp_bool{
			kou := FenDrugInventory(v,orgid)
			if !kou {
				err = fmt.Errorf(FindDrugsName(v.DrugId)+"库存不足")
				return
			}
			if PettyCash(v.DrugId){
				continue
			}
			//扣减库存
			err = FenStock(orgid,creater,v)
			if err != nil {
				err = fmt.Errorf("!:%v",err)
				return
			}
		}
	}
	//修改状态
	errs1 := XTWriteDB().Model(&models.XtDoctorAdviceL{}).Where("id in (?)",xid).Updates(map[string]interface{}{
		"is_medicine": 1,
		"people": 0,
		"dispensing_time": time_now,
		"updated_time": time.Now().Unix(),
	}).Error
	if errs1 != nil{
		return errs1
	}

	//生成明细记录
	tmp_ph := models.Pharmary{
		UserOrgId: orgid,
		PatientId: patient_id,
		Ctime: time.Now().Unix(),
		Mtime: time.Now().Unix(),
		Status: 1,
		RecordDate: time_now,
	}
	err = tx.Create(&tmp_ph).Error

	return
}
//患者退药按钮点击
func DrugWithdrawal(orgid,patient_id,stime,etime,creater int64)(err error){
	//开事务
	tx := XTWriteDB().Begin()
	defer func() {
		if err != nil {
			utils.ErrorLog("事务失败，原因为: %v", err)
			tx.Rollback()
		} else {
			tx.Commit()
		}
	}()
	map_time := make(map[int64]int64)
	var hids []*models.TmpID
	var xids []*models.TmpID
	//var hid,xid []int64//查询已发药的药品
	err = tx.Raw("select id,dispensing_time from his_doctor_advice_info where status = 1 and created_time >= ? and created_time <= ? " +
		"and user_org_id = ? and patient_id = ? and is_medicine = 1 and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",stime,etime,orgid,patient_id,orgid).Scan(&hids).Error
	if err != nil {
		return
	}
	hid := make([]int64,0)
	for _,v := range hids{
		hid = append(hid,v.Id)
		map_time[v.DispensingTime] = v.DispensingTime
	}
	//修改状态
	errs := XTWriteDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id in (?)",hid).Updates(map[string]interface{}{
		"is_medicine": 0,
		"people": creater,
		"dispensing_time": 0,
		"updated_time": time.Now().Unix(),
	}).Error
	if errs != nil{
		return errs
	}
	err1 := ChangeHisPrescriptionT(hid)
	if err1 != nil {
		return err1
	}
	var advice_info []*models.HisDoctorAdviceInfo
	err = tx.Model(&models.HisDoctorAdviceInfo{}).Where("id in (?) and status = 1",hid).Find(&advice_info).Error
	if err != nil{
		return
	}
	for _,v := range advice_info{
		//扣减库存
		err = DrugAutoAddCancelInfo(v,creater)
		if err != nil {
			err = fmt.Errorf("!:%v",err)
			return
		}
		drug, _ := FindBaseDrugLibRecordSeven(orgid, v.DrugId)
		//查询默认仓库
		storeHouseConfig, _ := GetAllStoreHouseConfig(orgid)
		//查询默认仓库剩余多少库存
		var sum_count int64
		stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, orgid, v.DrugId)
		for _, its := range stockInfo {
			sum_count += its.StockMaxNumber*drug.MinNumber + its.StockMinNumber
		}
		UpdateBaseDrugSumTwo(v.DrugId, sum_count, orgid)
	}


	err = tx.Raw("select id,dispensing_time from xt_doctor_advice where status = 1 and (advice_type = 2 or advice_type = 3) and created_time >= ? and created_time <= ? and " +
		"user_org_id = ? and patient_id = ? and is_medicine = 1 and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1)",stime,etime,orgid,patient_id,orgid).Scan(&xids).Error
	if err != nil {
		return
	}
	xid := make([]int64,0)
	for _,v := range xids{
		xid = append(xid,v.Id)
		map_time[v.DispensingTime] = v.DispensingTime
	}
	//修改状态
	errs1 := XTWriteDB().Model(&models.XtDoctorAdviceL{}).Where("id in (?)",xid).Updates(map[string]interface{}{
		"is_medicine": 0,
		"people": creater,
		"dispensing_time": 0,
		"updated_time": time.Now().Unix(),
	}).Error
	if errs1 != nil{
		return errs1
	}
	var advice []*models.HisDoctorAdviceInfo
	err = tx.Raw("select * from xt_doctor_advice where id in (?) and status = 1",xid).Scan(&advice).Error
	if err != nil{
		return
	}
	for _,v := range advice{
		//扣减库存
		err = DrugAutoAddCancelInfo(v,creater)
		if err != nil {
			err = fmt.Errorf("!:%v",err)
			return
		}
		drug, _ := FindBaseDrugLibRecordSeven(orgid, v.DrugId)
		//查询默认仓库
		storeHouseConfig, _ := GetAllStoreHouseConfig(orgid)
		//查询默认仓库剩余多少库存
		var sum_count int64
		stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, orgid, v.DrugId)
		for _, its := range stockInfo {
			sum_count += its.StockMaxNumber*drug.MinNumber + its.StockMinNumber
		}
		UpdateBaseDrugSumTwo(v.DrugId, sum_count, orgid)
	}

	//删除掉发药明细
	for k,_ := range map_time{
		err = tx.Model(&models.Pharmary{}).Where("user_org_id = ? and record_date = ? ",orgid,k).Updates(map[string]interface{}{
			"status": 0,
			"mtime": time.Now().Unix(),
		}).Error
		if err != nil{
			return
		}
	}
	return
}
//获取患者名称
func FindUserName(patient_id int64)(name string){
	var tmp models.GetHisName
	XTReadDB().Model(&models.GetHisName{}).Where("id = ?",patient_id).Find(&tmp)
	name = tmp.Name
	return
}
//获取药品名称
func FindDrugsName(drug_id int64)(name string){
	var tmp models.Drug
	XTReadDB().Model(&models.Drug{}).Where("id = ?",drug_id).Find(&tmp)
	name = tmp.DrugName
	return
}
//药品发药按钮点击(
func MedicineDeparture(ids string,creater,orgid int64)(err error){
	//开事务
	tx := XTWriteDB().Begin()
	defer func() {
		if err != nil {
			utils.ErrorLog("事务失败，原因为: %v", err)
			tx.Rollback()
		} else {
			tx.Commit()
		}
	}()
	//处理下字符串
	t_ids := ""
	if ids[len(ids)-1] == 44 {
		t_ids = ids[:len(ids)-1]
	} else {
		t_ids = ids
	}
	time_now := time.Now().Unix()
	tmp_id := strings.Split(t_ids, ",")
	var parameter string//测试
	patient_id := make(map[int64]int64)
	for _,v := range tmp_id{
		front := v[:1]
		after := v[1:]
		if front == "h" {
			var advice_info []*models.HisDoctorAdviceInfo
			err = tx.Model(&models.HisDoctorAdviceInfo{}).Where("id = ? and status = 1",after).Find(&advice_info).Error
			if err != nil{
				return
			}
			for _,v := range advice_info{
				if _,ok := patient_id[v.PatientId];!ok{
					patient_id[v.PatientId] = v.PatientId
				}
				tmp_bool := IsPharmacyConfig(orgid)
				if tmp_bool{
					kou := FenDrugInventory(v,orgid)
					if !kou {
						err = fmt.Errorf(FindDrugsName(v.DrugId)+"库存不足")
						tmp := models.XtErrs{
							OrgId: orgid,
							Route: "creater:"+config.ToString(creater),
							Parameter: parameter,
							Text_err: err.Error(),
						}
						XTWriteDB().Create(&tmp)
						return
					}else{
						tmps ,_ := json.Marshal(advice_info)//
						parameter = parameter+string(tmps)//
					}
					if PettyCash(v.DrugId){
						continue
					}
					//扣减库存
					err = FenStock(orgid,creater,v)
					if err != nil {
						err = fmt.Errorf("!:%v",err)
						return
					}
				}
			}
			//修改状态
			errs := XTWriteDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id = ?",after).Updates(map[string]interface{}{
				"is_medicine": 1,
				"people": creater,
				"dispensing_time": time_now,
				"updated_time": time.Now().Unix(),
			}).Error
			if errs != nil{
				return errs
			}
			err1 := ChangeHisPrescriptionid(after)
			if err1 != nil{
				return err1
			}
		}else{
			var advice []*models.HisDoctorAdviceInfo
			err = tx.Raw("select * from xt_doctor_advice where id = ? and status = 1 and (advice_type = 2 or advice_type = 3)",after).Scan(&advice).Error
			if err != nil{
				return
			}
			for _,v := range advice{
				if _,ok := patient_id[v.PatientId];!ok{
					patient_id[v.PatientId] = v.PatientId
				}
				tmp_bool := IsPharmacyConfig(orgid)
				if tmp_bool{
					kou := FenDrugInventory(v,orgid)
					if !kou {
						err = fmt.Errorf(FindDrugsName(v.DrugId)+"库存不足")
						tmp := models.XtErrs{
							OrgId: orgid,
							Route: "creater:"+config.ToString(creater),
							Parameter: parameter,
							Text_err: err.Error(),
						}
						XTWriteDB().Create(&tmp)
						return
					}else{
						tmps ,_ := json.Marshal(advice)//
						parameter = parameter+string(tmps)//
					}
					if PettyCash(v.DrugId){
						continue
					}
					//扣减库存
					err = FenStock(orgid,creater,v)
					if err != nil {
						err = fmt.Errorf("!:%v",err)
						return
					}
				}
			}
			//修改状态
			errs1 := XTWriteDB().Model(&models.XtDoctorAdviceL{}).Where("id = ?",after).Updates(map[string]interface{}{
				"is_medicine": 1,
				"people": creater,
				"dispensing_time": time_now,
				"updated_time": time.Now().Unix(),
			}).Error
			if errs1 != nil{
				return errs1
			}
		}
	}

	for _,v := range patient_id{
		//生成明细记录
		tmp_ph := models.Pharmary{
			UserOrgId: orgid,
			PatientId: v,
			Ctime: time.Now().Unix(),
			Mtime: time.Now().Unix(),
			Status: 1,
			RecordDate: time_now,
		}
		err = tx.Create(&tmp_ph).Error
		if err != nil{
			return err
		}
	}

	return
}
//获取领药人姓名（
func GetUserAdminName(id,orgID int64) string {
	var tmp models.XTSgjUserAdminRole
	XTReadDB().Model(&models.XTSgjUserAdminRole{}).Where("admin_user_id = ? and org_id = ?",id,orgID).Find(&tmp)
	return tmp.UserName
}

//根据id查询是否已发药,true已发药，false未发药
func GiveTheMedicine(id int64)bool{
	var xue models.PharmacyDoctorAdvice
	XTReadDB().Model(&models.PharmacyDoctorAdvice{}).Where("id = ?",id).Find(&xue)
	if xue.IsMedicine == 1 {
		return true
	}
	return false
}

//查询改组中的药品是否包含已发药的，true已发药，false未发药
func GiveGroupMedicine(orgid,groupNo int64) bool {
	var total int
	XTReadDB().Model(&models.DoctorAdvice{}).Where("user_org_id = ? and groupno = ? and status = 1 and is_medicine = 1",orgid,groupNo).Count(&total)
	if total > 0{
		return true
	}
	return false
}
//查询处方中是否包含已发药的
func GiveChuMedicine(id int64)bool{
	var total int
	XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where("prescription_id = ? and status = 1 and is_medicine = 1",id).Count(&total)
	if total > 0{
		return true
	}
	return false
}
//根据处方id查找该处方中是否存在已发药的药品
func IsChuIssuedDrugs(prescription_id int64) bool{
	var total int
	XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where("prescription_id = ? and status = 1 and is_medicine = 1",prescription_id).Count(&total)
	if total > 0{
		return true
	}
	return false
}
//判断该药品是否通过药房管理出库，true是，false否
//id 药品id,org_id 机构id
func IsPharmacyDelivery(id,org_id int64) bool{
	//判断药品是否通过药房管理
	var total01 int
	XTReadDB().Model(&models.PharmacyBaseDrug{}).Where("id = ? and is_pharmacy = 1",id).Count(&total01)
	//判断该机构是否通过药房管理出库
	var total02 int
	XTReadDB().Model(&models.PharmacyConfig{}).Where("user_org_id = ? and is_open = 1",org_id).Count(&total02)
	if total01 > 0 && total02 > 0 {
		return true
	}
	return false
}
//判断机构是否通过药房管理出库
func IsPharmacyConfig(orgid int64)(bo bool){
	var total int
	XTReadDB().Model(&models.PharmacyConfig{}).Where("user_org_id = ? and is_open = 1 and status = 1",orgid).Count(&total)
	if total > 0 {
		return true
	}
	return false
}

//根据患者id和发药时间，获取医生的id和姓名
func GetDoctorIds(id,recordtime,orgid int64)(doctor_id int64,doctor_name string,err error){
	var tmp []*models.TmpAdviceDoctor
	//var tmp []int64
	err = XTReadDB().Raw("select distinct advice_doctor from his_doctor_advice_info where " +
		"status = 1 and dispensing_time = ? and user_org_id = ? and is_medicine = 1 and patient_id = ? and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) " +
		"union " +
		"select distinct advice_doctor from xt_doctor_advice where " +
		"status = 1 and (advice_type = 2 or advice_type = 3) and dispensing_time = ? and user_org_id = ? and is_medicine = 1 and patient_id = ? and drug_id in (select id from xt_base_drug where org_id = ? and is_pharmacy = 1) ",
		recordtime,orgid,id,orgid,recordtime,orgid,id,orgid).Scan(&tmp).Error
	if err != nil || len(tmp) == 0 {
		return
	}
	doctor_id = tmp[0].AdviceDoctor
	doctor_name = GetUserAdminName(doctor_id,orgid)
	return
}

func MapToJson(param map[string]interface{}) string{
	dataType , _ := json.Marshal(param)
	dataString := string(dataType)
	return dataString
}

//封装扣减库存
func FenStock(orgid,creater int64,v *models.HisDoctorAdviceInfo)(err error){
	err = HisDrugsDelivery(orgid,creater,v)
	if err != nil {
		err = fmt.Errorf("!:%v",err)
		return
	}
	drug, _ := FindBaseDrugLibRecordSeven(orgid, v.DrugId)
	//查询默认仓库
	storeHouseConfig, _ := GetAllStoreHouseConfig(orgid)
	//查询默认仓库剩余多少库存
	var sum_count int64
	stockInfo, _ := GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, orgid, v.DrugId)
	for _, its := range stockInfo {
		sum_count += its.StockMaxNumber*drug.MinNumber + its.StockMinNumber
	}
	UpdateBaseDrugSumTwo(v.DrugId, sum_count, orgid)
	return
}
//封装查询药品库存是否足够
func FenDrugInventory(item *models.HisDoctorAdviceInfo,orgid int64)(bool){
	var total int64
	var prescribing_number_total int64
	houseConfig, _ := GetAllStoreHouseConfig(orgid)
	////查询该药品是否有库存
	list, _ := GetDrugTotalCountTwenty(item.DrugId, item.UserOrgId, houseConfig.DrugStorehouseOut)
	////查询改药品信息
	medical, _ := GetBaseDrugMedical(item.DrugId)
	////判断单位是否相等
	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 prescribing_number_total <= total {
		//可以扣减
		return  true
	}else{
		//不可扣减
		return false
	}

}
func GetAdviceIds1(ids []string,orgid,execution_staff int64,thetime time.Time)(tmp []string,err error){
	var advice []*models.DoctorAdvice
	err = readDb.Model(&models.DoctorAdvice{}).Where("id IN (?) AND status = 1", ids).Find(&advice).Error
	if err != nil{
		return
	}
	for _,v := range advice{
		if !IsPharmacyDelivery(v.DrugId,orgid){
			tmp = append(tmp,config.ToString(v.ID))
		}else{
			err = XTWriteDB().Model(&models.DoctorAdvice{}).Where("id = ? ",v.ID).Updates(map[string]interface{}{
				"execution_staff": execution_staff,
				"execution_time": thetime.Unix(),
				"updated_time": time.Now().Unix(),
			}).Error
			if err != nil{
				return
			}
		}
	}
	return
}
func GetAdviceIds2(ids []string,orgid,execution_staff int64,thetime time.Time)(tmp []string,err error){
	var advice []*models.HisDoctorAdviceInfoL
	err = readDb.Model(&models.HisDoctorAdviceInfoL{}).Where("id IN (?) AND status = 1", ids).Find(&advice).Error
	if err != nil{
		return
	}
	for _,v := range advice{
		if !IsPharmacyDelivery(v.DrugId,orgid){
			tmp = append(tmp,config.ToString(v.ID))
		}else{
			err = XTWriteDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id = ? ",v.ID).Updates(map[string]interface{}{
				"execution_staff": execution_staff,
				"execution_time": thetime.Unix(),
				"updated_time": time.Now().Unix(),
			}).Error
			if err != nil{
				return
			}
		}
	}
	return
}
func GetAdviceId1(id,orgid,execution_staff int64,thetime time.Time)(bo bool,err error){
	var advice models.DoctorAdvice
	err = readDb.Model(&models.DoctorAdvice{}).Where("id = ? AND status = 1", id).Find(&advice).Error
	if err != nil{
		return false,err
	}
	if IsPharmacyDelivery(advice.DrugId,orgid){
		err = XTWriteDB().Model(&models.DoctorAdvice{}).Where("id = ? ",id).Updates(map[string]interface{}{
			"execution_staff": execution_staff,
			"execution_time": thetime.Unix(),
			"updated_time": time.Now().Unix(),
		}).Error
		if err != nil{
			return false,err
		}
		return true,err
	}
	return false,err
}
func GetAdviceId2(id,orgid,execution_staff int64,thetime time.Time)(bo bool,err error){
	var advice models.HisDoctorAdviceInfoL
	err = readDb.Model(&models.HisDoctorAdviceInfoL{}).Where("id = ? AND status = 1", id).Find(&advice).Error
	if err != nil{
		return false,err
	}
	if IsPharmacyDelivery(advice.DrugId,orgid){
		err = XTWriteDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id = ? ",id).Updates(map[string]interface{}{
			"execution_staff": execution_staff,
			"execution_time": thetime.Unix(),
			"updated_time": time.Now().Unix(),
		}).Error
		if err != nil{
			return false,err
		}
		return true,err
	}
	return false,err
}

//判断药品是否零用
func PettyCash(id int64)bool{
	drug := models.XtBaseDrug{}
	XTReadDB().Model(&drug).Where("id = ? and status = 1", id).Find(&drug)
	if drug.IsUse == 1{
		return true
	}
	return false
}
//初始化
func InitDrugidIsNil(orgid,stime,etime int64)(){
	var advice []*models.DoctorAdvice
	XTReadDB().Model(&models.DoctorAdvice{}).Where("drug_id = 0 and user_org_id = ? and status = 1 and created_time >= ? and created_time <= ?", orgid,stime,etime).Find(&advice)
	for _,v := range advice{
		XTWriteDB().Exec("update xt_doctor_advice set drug_id = (select id from xt_base_drug where drug_name = ? and org_id = ?) where id = ?",v.AdviceName,v.UserOrgId,v.ID)
	}
}

//改变处方状态(发药
func ChangeHisPrescription(tmp []int64)(err error){
	var advice_info []*models.HisDoctorAdviceInfo
	err = XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("id in (?) and status = 1",tmp).Find(&advice_info).Error
	if err != nil{
		if err == gorm.ErrRecordNotFound{
			return nil
		}
		return
	}

	tmp_id := make(map[int64]int64)
	for _,v := range advice_info{
		tmp_id[v.PrescriptionId] = v.PrescriptionId
	}
	for k,_ := range tmp_id{
		err = XTWriteDB().Model(&models.HisPrintPrescription{}).Where("id = ?",k).Updates(map[string]interface{}{
			"is_medicine": 1,
			"mtime": time.Now().Unix(),
		}).Error
		if err != nil{
			return
		}
	}
	return
}
//改变处方状态(退药
func ChangeHisPrescriptionT(tmp []int64)(err error){
	var advice_info []*models.HisDoctorAdviceInfo
	err = XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("id in (?) and status = 1",tmp).Find(&advice_info).Error
	if err != nil{
		if err == gorm.ErrRecordNotFound{
			return nil
		}
		return
	}

	tmp_id := make(map[int64]int64)
	for _,v := range advice_info{
		tmp_id[v.PrescriptionId] = v.PrescriptionId
	}
	for k,_ := range tmp_id{
		var total int
		//查询退药的
		XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("prescription_id = ? and status = 1 and is_medicine = 1",k).Count(&total)
		if total == 0{
			err = XTWriteDB().Model(&models.HisPrintPrescription{}).Where("id = ?",k).Updates(map[string]interface{}{
				"is_medicine": 0,
				"mtime": time.Now().Unix(),
			}).Error
			if err != nil{
				return
			}
		}
	}
	return
}
//改变处方状态
func ChangeHisPrescriptionid(id string)(err error){
	var advice models.HisDoctorAdviceInfo
	err = XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("id = ? and status = 1",id).Find(&advice).Error
	if err != nil {
		if err == gorm.ErrRecordNotFound{
			return nil
		}
		return
	}
	err = XTWriteDB().Model(&models.HisPrintPrescription{}).Where("id = ?",advice.PrescriptionId).Updates(map[string]interface{}{
		"is_medicine": 1,
		"mtime": time.Now().Unix(),
	}).Error
	if err != nil{
		return
	}
	return
}