2024/6/17

controllers/base_api_controller.go

 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 10028 //机构id
+		subscibe.OrgId = 10644 //机构id
 		subscibe.PeriodStart = 1547447814
 		subscibe.PeriodEnd = 1550039814
 		subscibe.State = 1
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 10028 //机构id小英9675或4
+		adminUserInfo.CurrentOrgId = 10644 //机构id小英9675或4
 		adminUserInfo.CurrentAppId = 12123 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes
 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 10028 //机构id小英9675或4
+		subscibe.OrgId = 10644 //机构id小英9675或4
 		subscibe.PeriodStart = 1538035409
 		subscibe.PeriodEnd = 1569571409
 		subscibe.State = 1
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 10028 //机构id小英9675或4
+		adminUserInfo.CurrentOrgId = 10644 //机构id小英9675或4
 		adminUserInfo.CurrentAppId = 12123 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes

controllers/dialysis_api_controller.go

 	patient, _ := c.GetInt64("patient", 0)
 	recordDateStr := c.GetString("record_date")
 	record_time := c.GetString("record_time")
-	fmt.Println(recordDateStr)
+
 	if patient <= 0 {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 
 	startDate, _ := utils.ParseTimeStringToTime("2006-01-02 15:04", record_time)
 
-	fmt.Println("startDate0000000000000000000000000000", startDate.Unix())
-
 	// data := make(map[string]interface{}, 0)
 	var data models.AssessmentAfterDislysis
 	var err error
 			}
 
 			if adminInfo.CurrentOrgId == 10735 {
-				ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
-				record.UltrafiltrationVolume = ultrafiltration_volume / 2
+
+				ultrafiltration_volume := math.Floor(float64(record.OperateTime+1800-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
+				record.UltrafiltrationVolume = ultrafiltration_volume
+
 			}
 
 		}

controllers/dialysis_record_api_controller.go

 		service.CreateDialysisFinish(finishS)
 	}
 
-	if adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 9675 || adminUserInfo.CurrentOrgId == 10164 || adminUserInfo.CurrentOrgId == 10340 || adminUserInfo.CurrentOrgId == 10414 || adminUserInfo.CurrentOrgId == 10432 || adminUserInfo.CurrentOrgId == 10445 || adminUserInfo.CurrentOrgId == 9829 || adminUserInfo.CurrentOrgId == 10440 {
+	if adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 9675 || adminUserInfo.CurrentOrgId == 10164 || adminUserInfo.CurrentOrgId == 10340 || adminUserInfo.CurrentOrgId == 10414 || adminUserInfo.CurrentOrgId == 10432 || adminUserInfo.CurrentOrgId == 10445 || adminUserInfo.CurrentOrgId == 9829 || adminUserInfo.CurrentOrgId == 10440 || adminUserInfo.CurrentOrgId == 10735 {
 
 		evaluation, _ := service.MobileGetPredialysisEvaluationTwo(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
 		if evaluation.SystolicBloodPressure == 0 {

controllers/drug_stock_api_contorller.go

 	}
 
 	if warehouse_out_id == 0 {
-		service.AddSigleDrugWarehouseOut(&warehouseOut)
+		//查询是否生成出库单
+		outIsExit, _ := service.GetDrugWarehouseOutIsExit(adminUserInfo.CurrentOrgId, 0, operation_time, warehousing_out_order)
+		if outIsExit.ID == 0 {
+			service.AddSigleDrugWarehouseOut(&warehouseOut)
+		}
+
 	}
 	if warehouse_out_id > 0 {
 		service.UpdateSingleDrugWarehouseOut(warehouse_out_id, storehouse_id)
 	//调用出库逻辑
 	for _, item := range warehousingOutInfo {
 		if item.ID == 0 {
-			errOne := service.AddSigleDrugWarehouseOutInfo(item)
-			fmt.Println(errOne)
+			//查询改耗材是否出库
+			outInfo, _ := service.GetDrugsIsExsit(item.DrugId, item.SysRecordTime, item.OrgId, lastWarehouseOut.ID)
+			if outInfo.ID == 0 {
+				errOne := service.AddSigleDrugWarehouseOutInfo(item)
+				fmt.Println(errOne)
+			}
+
 		}
 		if item.ID > 0 {
 			service.UpdatedDrugWarehouseInfo(item, item.ID)

controllers/his_api_controller.go

 	var adviceList []models.HisDoctorAdviceInfo
 	var projectList []models.HisPrescriptionProject
 
-	if adminInfo.CurrentOrgId == 10489 || adminInfo.CurrentOrgId == 10510 || adminInfo.CurrentOrgId == 10164 || adminInfo.CurrentOrgId == 10478 || adminInfo.CurrentOrgId == 10318 || adminInfo.CurrentOrgId == 10480 || adminInfo.CurrentOrgId == 10633 || adminInfo.CurrentOrgId == 10610 || adminInfo.CurrentOrgId == 10402 || adminInfo.CurrentOrgId == 10138 || adminInfo.CurrentOrgId == 10278 || adminInfo.CurrentOrgId == 10537 || adminInfo.CurrentOrgId == 10265 || adminInfo.CurrentOrgId == 10644 || adminInfo.CurrentOrgId == 10635 || adminInfo.CurrentOrgId == 10598 || adminInfo.CurrentOrgId == 10028 || adminInfo.CurrentOrgId == 10721 || adminInfo.CurrentOrgId == 10726 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10571 || adminInfo.CurrentOrgId == 10724 || adminInfo.CurrentOrgId == 9671 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10653 {
+	if adminInfo.CurrentOrgId == 10489 || adminInfo.CurrentOrgId == 10510 || adminInfo.CurrentOrgId == 10164 || adminInfo.CurrentOrgId == 10478 || adminInfo.CurrentOrgId == 10318 || adminInfo.CurrentOrgId == 10480 || adminInfo.CurrentOrgId == 10633 || adminInfo.CurrentOrgId == 10610 || adminInfo.CurrentOrgId == 10402 || adminInfo.CurrentOrgId == 10138 || adminInfo.CurrentOrgId == 10278 || adminInfo.CurrentOrgId == 10537 || adminInfo.CurrentOrgId == 10265 || adminInfo.CurrentOrgId == 10644 || adminInfo.CurrentOrgId == 10635 || adminInfo.CurrentOrgId == 10598 || adminInfo.CurrentOrgId == 10028 || adminInfo.CurrentOrgId == 10721 || adminInfo.CurrentOrgId == 10726 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10571 || adminInfo.CurrentOrgId == 10724 || adminInfo.CurrentOrgId == 9671 || adminInfo.CurrentOrgId == 10731 || adminInfo.CurrentOrgId == 10653 || adminInfo.CurrentOrgId == 10567 {
 		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
 			prescriptions, _ := dataBody["prescriptions"].([]interface{})
 

controllers/mobile_api_controllers/check_weight_api_controller.go

 		}
 
 		//针对古镇乐生
-		if adminUserInfo.Org.Id == 10727 || adminUserInfo.Org.Id == 10731 {
+		if adminUserInfo.Org.Id == 10731 {
 
 			dewater_amount = (evaluation.WeightBefore - evaluation.DryWeight - evaluation.AdditionalWeight) * 1000
 			lastDialysisPrescription, _ := service.GetLastDialysisPrescription(id, adminUserInfo.Org.Id)

controllers/mobile_api_controllers/dialysis_api_controller.go

 
 	}
 
-	if adminUserInfo.Org.Id == 10101 || adminUserInfo.Org.Id == 9671 || adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 9675 || adminUserInfo.Org.Id == 10215 || adminUserInfo.Org.Id == 10233 || adminUserInfo.Org.Id == 10223 || adminUserInfo.Org.Id == 10243 || adminUserInfo.Org.Id == 10340 || adminUserInfo.Org.Id == 10414 || adminUserInfo.Org.Id == 10430 || adminUserInfo.Org.Id == 10432 || adminUserInfo.Org.Id == 10445 || adminUserInfo.Org.Id == 10223 || adminUserInfo.Org.Id == 9829 || adminUserInfo.Org.Id == 10432 || adminUserInfo.Org.Id == 10440 || adminUserInfo.Org.Id == 10469 || adminUserInfo.Org.Id == 10693 || adminUserInfo.Org.Id == 10702 {
+	if adminUserInfo.Org.Id == 10101 || adminUserInfo.Org.Id == 9671 || adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 9675 || adminUserInfo.Org.Id == 10215 || adminUserInfo.Org.Id == 10233 || adminUserInfo.Org.Id == 10223 || adminUserInfo.Org.Id == 10243 || adminUserInfo.Org.Id == 10340 || adminUserInfo.Org.Id == 10414 || adminUserInfo.Org.Id == 10430 || adminUserInfo.Org.Id == 10432 || adminUserInfo.Org.Id == 10445 || adminUserInfo.Org.Id == 10223 || adminUserInfo.Org.Id == 9829 || adminUserInfo.Org.Id == 10432 || adminUserInfo.Org.Id == 10440 || adminUserInfo.Org.Id == 10469 || adminUserInfo.Org.Id == 10693 || adminUserInfo.Org.Id == 10702 || adminUserInfo.Org.Id == 10735 {
 		evaluation, _ := service.MobileGetPredialysisEvaluationOne(adminUserInfo.Org.Id, id, recordDate.Unix())
 
 		if adminUserInfo.Org.Id != 10702 {
 		tempassessmentAfterDislysis.Temperature = endmonitorRecords.Temperature
 		tempassessmentAfterDislysis.BreathingRate = endmonitorRecords.BreathingRate
 	}
+	if endmonitorRecords.ID > 0 && adminUserInfo.Org.Id == 10735 {
+		tempassessmentAfterDislysis.SystolicBloodPressure = endmonitorRecords.SystolicBloodPressure
+		tempassessmentAfterDislysis.DiastolicBloodPressure = endmonitorRecords.DiastolicBloodPressure
+		tempassessmentAfterDislysis.Temperature = endmonitorRecords.Temperature
+		tempassessmentAfterDislysis.BreathingRate = endmonitorRecords.BreathingRate
+	}
 
 	if endmonitorRecords.ID > 0 && adminUserInfo.Org.Id == 10598 {
 		tempassessmentAfterDislysis.SystolicBloodPressure = 0
 			record.BloodFlowVolume = prescription.BloodFlowVolume
 		}
 
+		//胶州少海医院
+		if adminUserInfo.Org.Id == 10735 {
+			befor, _ := service.GetAssessmentBeforThrity(adminUserInfo.Org.Id, patientID, recordDate.Unix())
+			dialysisPrescription, _ := service.GetDialysisPrescription(patientID, adminUserInfo.Org.Id, recordDate.Unix())
+			record.BreathingRate = befor.BreathingRate
+			record.BloodFlowVolume = dialysisPrescription.BloodFlowVolume
+			record.Temperature = befor.Temperature
+			record.PulseFrequency = befor.PulseFrequency
+		}
+
 		if adminUserInfo.Org.Id != 10683 {
 			err = service.CreateMonitor(&record)
 		}
 
 			if adminInfo.Org.Id == 10206 {
 				ultrafiltration_rate = math.Floor(prescription.TargetUltrafiltration * 1000 / float64(totalMin) * 60 * 1000)
-				fmt.Println("ultrafiltration_rate------------------", ultrafiltration_rate)
+
 				record.UltrafiltrationRate = ultrafiltration_rate / 1000
 			}
 			//if template.TemplateId == 47 {
 			}
 			//胶州少海医院
 			if adminInfo.Org.Id == 10735 {
-				ultrafiltration_volume := math.Floor(float64(record.OperateTime+3600-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
-				record.UltrafiltrationVolume = ultrafiltration_volume / 2
+
+				lastMonitorRecordList, _ := service.GetLastMonitorRecordList(patientID, monitorDate, adminInfo.Org.Id)
+				if lastMonitorRecordList.ID > 0 {
+					record.UltrafiltrationRate = lastMonitorRecordList.UltrafiltrationRate
+					ultrafiltration_volume := math.Floor(float64(record.OperateTime+1800-fristrecord.OperateTime) / 3600 * lastMonitorRecordList.UltrafiltrationRate)
+
+					record.UltrafiltrationVolume = ultrafiltration_volume
+				} else {
+					ultrafiltration_volume := math.Floor(float64(record.OperateTime+1800-fristrecord.OperateTime) / 3600 * ultrafiltration_rate)
+
+					record.UltrafiltrationVolume = ultrafiltration_volume
+				}
+
 			}
 
 		}

controllers/mobile_api_controllers/patient_api_controller.go

 
 	}
 
+	//揭阳
+	if adminUserInfo.Org.Id == 10597 {
+		if evaluation.ID == 0 {
+			dialysisPrescribeOne, _ := service.MobileGetDialysisPrescribeOne(adminUserInfo.Org.Id, id, theAssessmentDateTime)
+			if dialysisPrescribeOne.ID > 0 && evaluation.ID > 0 {
+				dewater_amount = evaluation.WeightBefore - evaluation.DryWeight - evaluation.AdditionalWeight
+				service.UpdateMobileGetDialysisPrescribe(dialysisPrescribeOne.ID, dewater_amount)
+			}
+		}
+	}
+
 	err = service.UpadatePredialysisEvaluation(&evaluation)
 
 	//记录日志

controllers/patient_api_controller.go

 		}
 	}
 
-	err := service.DeleteGroupAdviceOne(adminUserInfo.CurrentOrgId, groupNo, adminUserInfo.AdminUser.Id)
+	err := service.DeleteGroupAdvice(adminUserInfo.CurrentOrgId, groupNo, adminUserInfo.AdminUser.Id)
 
 	byterequest, _ := json.Marshal(advice)
 	doctorAdviceLog := models.XtDoctorAdviceLog{
 	//获取透析处方
 	prescription, _ := service.GetAutoDialysisPrescription(patient_id, startTime, endTime, orgId)
 
+	maxPrescription, _ := service.GetAutoMaxDialysisPrescription(patient_id, startTime, endTime, orgId)
+
+	minPrescription, _ := service.GetAutoMinDialysisPrescription(patient_id, startTime, endTime, orgId)
+
 	berfor, _ := service.GetAutoAssessmentBefor(patient_id, startTime, endTime, orgId)
 
 	monitorList, _ := service.GetAutoMonitorList(patient_id, startTime, endTime, orgId)
 	longAdvice, _ := service.GetLongDoctorAdvice(orgId, patient_id, startTime, endTime)
 
 	this.ServeSuccessJSON(map[string]interface{}{
-		"prescription":  prescription,
-		"berfor":        berfor,
-		"monitorList":   monitorList,
-		"dryweightList": dryweightList,
-		"inpectionList": inpectionList,
-		"dialysisOrder": dialysisOrder,
-		"patient":       patient,
-		"longAdvice":    longAdvice,
+		"prescription":    prescription,
+		"berfor":          berfor,
+		"monitorList":     monitorList,
+		"dryweightList":   dryweightList,
+		"inpectionList":   inpectionList,
+		"dialysisOrder":   dialysisOrder,
+		"patient":         patient,
+		"longAdvice":      longAdvice,
+		"maxPrescription": maxPrescription,
+		"minPrescription": minPrescription,
 	})
 
 }

controllers/self_drug_api_congtroller.go

 	}
 	var ids []int64
 	var goodIds []int64
-	//infoList, _ := service.GetGoodWarehouseInfoByOrgIdTwo(orgId)
-	//for _, it := range infoList {
-	//	goodIds = append(goodIds, it.GoodId)
-	//}
 
 	if len(keyword) > 0 {
 		manufacturers, _ := service.GetManufacturerListByKeyword(orgId, keyword)
 			//期间减少
 			banceOutList, _ := service.GetInitOutBanceList(item.ID, orgId, startTime, endTime, storeConfig.StorehouseOutInfo)
 
-			//banceOutList, _ := service.GetInitOutBanceTenty(item.ID, orgId, startTime, endTime, storeConfig.StorehouseOutInfo)
 			for _, it := range banceOutList {
 				item.WarehouseOutInfoTenty = append(item.WarehouseOutInfoTenty, it)
 			}

models/new_stock_models.go

 	Price               float64            `gorm:"column:price" json:"price" form:"price"`
 	WarehousingDetailId int64              `gorm:"column:warehousing_detail_id" json:"warehousing_detail_id" form:"warehousing_detail_id"`
 	BuyPrice            float64            `gorm:"column:buy_price" json:"buy_price" form:"buy_price"`
-	IsRead              int64              `gorm:"column:is_read" json:"is_read" form:"is_read"`
 	OverCount           int64              `gorm:"column:over_count" json:"over_count" form:"over_count"`
 	Ctime               int64              `gorm:"column:ctime" json:"ctime" form:"ctime"`
 	StorehouseId        int64              `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`

models/stock_models.go

 }
 
 type StWarehousingInfoOne struct {
-	ID               int64  `gorm:"column:id" json:"id"`
-	GoodId           int64  `gorm:"column:good_id" json:"good_id"`
-	WarehousingCount int64  `gorm:"column:warehousing_count" json:"warehousing_count"`
-	WarehousingUnit  string `gorm:"column:warehousing_unit" json:"warehousing_unit"`
-	PackingUnit      string `json:"packing_unit"`
-	StorehouseId     int64  `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`
-	OrgId            int64  `gorm:"column:org_id" json:"org_id"`
+	ID               int64   `gorm:"column:id" json:"id"`
+	GoodId           int64   `gorm:"column:good_id" json:"good_id"`
+	WarehousingCount int64   `gorm:"column:warehousing_count" json:"warehousing_count"`
+	WarehousingUnit  string  `gorm:"column:warehousing_unit" json:"warehousing_unit"`
+	PackingUnit      string  `json:"packing_unit"`
+	StorehouseId     int64   `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`
+	OrgId            int64   `gorm:"column:org_id" json:"org_id"`
+	Price            float64 `gorm:"column:price" json:"price" form:"price"`
 }
 
 func (StWarehousingInfoOne) TableName() string {
 }
 
 type WarehouseOutInfoTenty struct {
-	ID            int64 `gorm:"column:id" json:"id" form:"id"`
-	GoodId        int64 `gorm:"column:good_id" json:"good_id" form:"good_id"`
-	Count         int64 `gorm:"column:count" json:"count" form:"count"`
-	Mtime         int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
-	Ctime         int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
-	Status        int64 `gorm:"column:status" json:"status" form:"status"`
-	OrgId         int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
-	SysRecordTime int64 `gorm:"column:sys_record_time" json:"sys_record_time" form:"sys_record_time"`
+	ID            int64   `gorm:"column:id" json:"id" form:"id"`
+	GoodId        int64   `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	Count         int64   `gorm:"column:count" json:"count" form:"count"`
+	Mtime         int64   `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Ctime         int64   `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Status        int64   `gorm:"column:status" json:"status" form:"status"`
+	OrgId         int64   `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	SysRecordTime int64   `gorm:"column:sys_record_time" json:"sys_record_time" form:"sys_record_time"`
+	Price         float64 `gorm:"column:price" json:"price" form:"price"`
 }
 
 func (WarehouseOutInfoTenty) TableName() string {

service/patient_service.go

 	return prescription, err
 }
 
+func GetAutoMaxDialysisPrescription(patient_id int64, start_time int64, end_time int64, org_id int64) (models.DialysisPrescription, error) {
+
+	prescription := models.DialysisPrescription{}
+	err := XTReadDB().Raw("select MAX(anticoagulant_zongliang) from xt_dialysis_prescripiton where patient_id = ? and record_date>=? and record_date<=? and org_id = ?", patient_id, start_time, end_time, org_id).Scan(&prescription).Error
+	return prescription, err
+}
+
+func GetAutoMinDialysisPrescription(patient_id int64, start_time int64, end_time int64, org_id int64) (models.DialysisPrescription, error) {
+	prescription := models.DialysisPrescription{}
+	err := XTReadDB().Raw("select Min(anticoagulant_zongliang) from xt_dialysis_prescripiton where patient_id = ? and record_date>=? and record_date<=? and org_id = ?", patient_id, start_time, end_time, org_id).Scan(&prescription).Error
+	return prescription, err
+}
+
 func GetAutoAssessmentBefor(patient_id int64, start_time int64, end_time int64, org_id int64) (berfor []*models.XtAssessmentBeforeDislysis, err error) {
 
 	db := XTReadDB().Model(&berfor).Where("status=1")

service/stock_service.go

 	return err
 }
 
+func GetDrugWarehouseOutIsExit(org_id int64, is_sys int, record_time int64, warehousing_out_order string) (models.DrugWarehouseOut, error) {
+
+	drugWarehouseOut := models.DrugWarehouseOut{}
+	err := XTReadDB().Where("is_sys = ? AND status = 1 AND org_id = ? AND warehouse_out_time = ? and warehouse_out_order_number = ?", is_sys, org_id, record_time, warehousing_out_order).Find(&drugWarehouseOut).Error
+
+	return drugWarehouseOut, err
+}
+
 func AddSigleDrugWarehouseOut(warehouseOut *models.DrugWarehouseOut) error {
 	err := writeDb.Create(&warehouseOut).Error
 	return err
 	return outInfo, err
 }
 
+func GetDrugsIsExsit(drug_id int64, sys_record_time int64, org_id int64, warehouse_out_id int64) (models.XtDrugWarehouseOutInfo, error) {
+
+	outInfo := models.XtDrugWarehouseOutInfo{}
+	err := XTReadDB().Where("drug_id = ? and sys_record_time = ? and org_id = ? and is_sys =0 and status = 1 and warehouse_out_id = ?", drug_id, sys_record_time, org_id, warehouse_out_id).Find(&outInfo).Error
+	return outInfo, err
+}
+
 func AddSigleWarehouseOutInfo(info *models.WarehouseOutInfo) error {
 
 	err := writeDb.Create(&info).Error