2024/6/17

controllers/base_api_controller.go

@@ -83,7 +83,7 @@ func (this *BaseAuthAPIController) Prepare() {
 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 10191 //机构id
+		subscibe.OrgId = 10278 //机构id
 		subscibe.PeriodStart = 1547447814
 		subscibe.PeriodEnd = 1550039814
 		subscibe.State = 1
@@ -93,7 +93,7 @@ func (this *BaseAuthAPIController) Prepare() {
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 10191 //机构id小英9675或4
+		adminUserInfo.CurrentOrgId = 10278 //机构id小英9675或4
 		adminUserInfo.CurrentAppId = 18470 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes
@@ -329,7 +329,7 @@ func (this *BaseServeAPIController) Prepare() {
 		userAdmin.ModifyTime = 1530786071
 		var subscibe models.ServeSubscibe
 		subscibe.ID = 11
-		subscibe.OrgId = 10191 //机构id小英9675或4
+		subscibe.OrgId = 10278 //机构id小英9675或4
 		subscibe.PeriodStart = 1538035409
 		subscibe.PeriodEnd = 1569571409
 		subscibe.State = 1
@@ -339,7 +339,7 @@ func (this *BaseServeAPIController) Prepare() {
 		subscibes := make(map[int64]*models.ServeSubscibe, 0)
 		subscibes[4] = &subscibe
 		var adminUserInfo service.AdminUserInfo
-		adminUserInfo.CurrentOrgId = 10191 //机构id小英9675或4
+		adminUserInfo.CurrentOrgId = 10278 //机构id小英9675或4
 		adminUserInfo.CurrentAppId = 18470 //4
 		adminUserInfo.AdminUser = &userAdmin
 		adminUserInfo.Subscibes = subscibes

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -3957,6 +3957,40 @@ func (this *DialysisAPIController) StartDialysis() {
 				ultrafiltration_rate = ultrafiltration_rate / 1000
 			}
 
+			if adminUserInfo.Org.Id == 10721 {
+				if prescription.ModeId == 2 {
+					totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+					if totalMin == 0 {
+						totalMin = 240
+					}
+					if prescription.ReplacementTotal == 0 {
+						prescription.ReplacementTotal = 15
+					}
+
+					//乘10 除10是为了保留一位小数
+					replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+				}
+			}
+
+		}
+	}
+
+	if adminUserInfo.Org.Id == 10172 {
+		if prescription.ID == 0 {
+
+			if prescription.ModeId == 2 {
+				totalMin := prescription.DialysisDurationHour*60 + prescription.DialysisDurationMinute
+				if totalMin == 0 {
+					totalMin = 240
+				}
+				if prescription.ReplacementTotal == 0 {
+					prescription.ReplacementTotal = 15
+				}
+
+				//乘10 除10是为了保留一位小数
+				replacement_rate = math.Floor(prescription.ReplacementTotal*1000/float64(totalMin)*10) / 10
+			}
+
 		}
 	}
 

controllers/new_mobile_api_controllers/new_dialysis_api_controller.go

@@ -1478,6 +1478,26 @@ func (this *NewDialysisApiController) UpdatedPatient() {
 			PatientType:       patient_type_one,
 		}
 		err = service.UpdatedPatient(patients, patient.BloodId)
+
+		record := models.XtPatientLaspseRecord{
+			PatientId:     patients.ID,
+			RecordDate:    time.Now().Unix(),
+			LapseDate:     time.Now().Unix(),
+			LapseType:     lapseto,
+			LapseClass:    0,
+			LapseReason:   "",
+			AdminUserId:   adminInfo.AdminUser.Id,
+			Remark:        "",
+			UserOrgId:     orgid,
+			Ctime:         time.Now().Unix(),
+			Mtime:         time.Now().Unix(),
+			Status:        1,
+			LapseTypeName: "转入",
+			HisType:       0,
+			HisZone:       "",
+			HisBed:        "",
+		}
+		service.CreatePatientRecord(record)
 		key := strconv.FormatInt(orgid, 10) + ":" + strconv.FormatInt(patient.BloodId, 10) + ":patient_info"
 		redis := service.RedisClient()
 		defer redis.Close()

controllers/schedule_api_controller.go

@@ -5501,7 +5501,6 @@ func (c *ScheduleApiController) ChangeScheduleTen() {
 
 			//查询该床位今天是否存在排班
 			sch, _ := service.GetScheduleByBedId(bed_id, schedule_type, adminINfo.CurrentOrgId, schedule.ScheduleDate)
-			fmt.Println("schwowowoowowowowowo", sch.ID, sch.PatientId)
 
 			if sch.ID == 0 {
 				////删除排班
@@ -5579,7 +5578,6 @@ func (c *ScheduleApiController) ChangeScheduleTen() {
 		if bed_id != schedule.BedId {
 			//查询该床位今天是否存在排班
 			sch, _ := service.GetScheduleByBedId(bed_id, schedule_type, adminINfo.CurrentOrgId, schedule.ScheduleDate)
-			fmt.Println("schwowowoowowowowowo", sch.ID, sch.PatientId)
 
 			if sch.ID == 0 {
 				////删除排班
@@ -5624,7 +5622,6 @@ func (c *ScheduleApiController) ChangeScheduleTen() {
 					IsExport:            8888,
 					DialysisMachineName: "",
 				}
-				fmt.Println("idwoowowowowowowoowowowowo", id)
 
 				//赵云的ID
 				// 该床位存在的患者

service/mobile_dialysis_service.go

@@ -3318,7 +3318,11 @@ func GetAllHisDoctorAdvice(orgid int64, patientid int64, recorddate int64) (his
 
 	if orgid == 10721 {
 		if len(his_doctor_advice_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
-			err = readDb.Model(&models.HisDoctorAdviceInfo{}).Where("patient_id = ? AND user_org_id = ? AND status=1 AND record_date = ? and execution_frequency!='上机前' and delivery_way!='口服' ", patientid, orgid, recorddate).Order("created_time asc").Find(&his).Error
+
+			var keyword = "胰岛素"
+
+			keyword = "%" + keyword + "%"
+			err = readDb.Model(&models.HisDoctorAdviceInfo{}).Where("patient_id = ? AND user_org_id = ? AND status=1 AND record_date = ? and execution_frequency!='上机前' and delivery_way!='口服' and advice_name not like ?", patientid, orgid, recorddate, keyword).Order("created_time asc").Find(&his).Error
 			if err != nil {
 				if err == gorm.ErrRecordNotFound {
 					if len(his) <= 0 {

service/patient_service.go

@@ -513,8 +513,12 @@ func GetAllHisAdvicesByList(orgID int64, scheduleDate int64) (hisAdvices []VMHis
 
 	if orgID == 10721 {
 
+		var keyword = "胰岛素"
+
+		keyword = "%" + keyword + "%"
+
 		if len(his_advices_all) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
-			err = readDb.Model(&VMHisDoctorAdviceInfo{}).Where("status = 1 AND user_org_id = ? AND advice_date = ? and execution_frequency !='上机前' and delivery_way!='口服' ", orgID, scheduleDate).Find(&hisAdvices).Error
+			err = readDb.Model(&VMHisDoctorAdviceInfo{}).Where("status = 1 AND user_org_id = ? AND advice_date = ? and execution_frequency !='上机前' and delivery_way!='口服' and advice_name not like ? ", orgID, scheduleDate, keyword).Find(&hisAdvices).Error
 			if err != nil {
 				if err == gorm.ErrRecordNotFound {
 					if len(hisAdvices) <= 0 {

service/schedule_service.go

@@ -351,27 +351,6 @@ func ModeFyScheduleById(schedule_date int64, bedid int64, scheduletype int64, or
 	return err
 }
 
-func ModeScheduleByTime(startime int64, endtime int64, orgid int64) error {
-
-	schedule := models.XtSchedule{}
-
-	err := XTWriteDB().Model(&schedule).Where("schedule_date >? and schedule_date<=? and status = 1 and user_org_id = ?", startime, endtime, orgid).Updates(map[string]interface{}{"status": 0}).Error
-	return err
-}
-
-func ModeScheduleByTimeOne(startime int64, endtime int64, orgid int64) error {
-
-	schedule := models.XtSchedule{}
-
-	err := XTWriteDB().Model(&schedule).Where("schedule_date >=? and schedule_date<=? and status = 1 and user_org_id = ?", startime, endtime, orgid).Updates(map[string]interface{}{"status": 0}).Error
-	return err
-}
-
-func UpdateScheduleByOrgId(patientid int64, scheduledate int64, orgid int64, mode_id int64, schedule_type int64, sch *models.XtSchedule) error {
-	err := XTWriteDB().Model(&sch).Where("patient_id = ? and schedule_date= ? and user_org_id = ? and status = 1 and mode_id = ? and schedule_type = ?", patientid, scheduledate, orgid, mode_id, schedule_type).Updates(map[string]interface{}{"partition_id": sch.PartitionId, "bed_id": sch.BedId, "schedule_type": sch.ScheduleType, "schedule_week": sch.ScheduleWeek, "mode_id": sch.ModeId, "updated_time": time.Now().Unix()}).Error
-	return err
-}
-
 func UpdateScheduleByOrgIdOne(patientid int64, scheduledate int64, orgid int64, sch *models.XtSchedule) error {
 	err := XTWriteDB().Model(&sch).Where("patient_id = ? and schedule_date= ? and user_org_id = ? and status = 1", patientid, scheduledate, orgid).Updates(map[string]interface{}{"partition_id": sch.PartitionId, "bed_id": sch.BedId, "schedule_type": sch.ScheduleType, "schedule_week": sch.ScheduleWeek, "mode_id": sch.ModeId, "updated_time": time.Now().Unix(), "dialysis_machine_name": sch.DialysisMachineName}).Error
 	return err
@@ -1918,7 +1897,7 @@ func UpdateRepeatSchStatus(user_org_id int64, schedule_date int64) {
 
 	for _, schedule := range schedules {
 		// Update records with status = 0 where id is less than max_id
-		XTReadDB().Model(&models.XtSchedule{}).Where("patient_id = ? AND schedule_date = ? AND id < ?", schedule.PatientId, schedule.ScheduleDate, schedule.MaxId).Update("status", 0)
+		XTReadDB().Model(&models.XtSchedule{}).Where("patient_id = ? AND schedule_date = ? AND id < ?", schedule.PatientId, schedule.ScheduleDate, schedule.MaxId).Update("status", 0, "remark", "去除重复排班")
 
 	}