11月8日库存管理

controllers/dialysis_record_api_controller.go

@@ -806,11 +806,18 @@ func (this *DialysisRecordAPIController) StartDialysis() {
 		// 修改了床位逻辑
 		daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, patientID)
 		if daySchedule.ID > 0 {
-			daySchedule.PartitionId = deviceNumber.ZoneID
-			daySchedule.BedId = bedID
-			daySchedule.ScheduleType = schedual_type
-			daySchedule.UpdatedTime = time.Now().Unix()
-			err := service.UpdateSchedule(&daySchedule)
+			//daySchedule.PartitionId = deviceNumber.ZoneID
+			//daySchedule.BedId = bedID
+			//daySchedule.ScheduleType = schedual_type
+			//daySchedule.UpdatedTime = time.Now().Unix()
+			//err := service.UpdateSchedule(&daySchedule)
+			xtSchedule := models.Schedule{
+				PartitionId:  deviceNumber.ZoneID,
+				BedId:        bedID,
+				ScheduleType: schedual_type,
+				UpdatedTime:  time.Now().Unix(),
+			}
+			service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 			if err != nil {
 				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 				return
@@ -828,11 +835,18 @@ func (this *DialysisRecordAPIController) StartDialysis() {
 				} else {
 					daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, patientID)
 					if daySchedule.ID > 0 {
-						daySchedule.PartitionId = deviceNumber.ZoneID
-						daySchedule.BedId = bedID
-						daySchedule.ScheduleType = schedual_type
-						daySchedule.UpdatedTime = time.Now().Unix()
-						err := service.UpdateSchedule(&daySchedule)
+						//daySchedule.PartitionId = deviceNumber.ZoneID
+						//daySchedule.BedId = bedID
+						//daySchedule.ScheduleType = schedual_type
+						//daySchedule.UpdatedTime = time.Now().Unix()
+						//err := service.UpdateSchedule(&daySchedule)
+						xtSchedule := models.Schedule{
+							PartitionId:  deviceNumber.ZoneID,
+							BedId:        bedID,
+							ScheduleType: schedual_type,
+							UpdatedTime:  time.Now().Unix(),
+						}
+						service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 						if err != nil {
 							this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 							return
@@ -842,11 +856,18 @@ func (this *DialysisRecordAPIController) StartDialysis() {
 			} else if order_err == gorm.ErrRecordNotFound { //该床位没被占用
 				daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, patientID)
 				if daySchedule.ID > 0 {
-					daySchedule.PartitionId = deviceNumber.ZoneID
-					daySchedule.BedId = bedID
-					daySchedule.ScheduleType = schedual_type
-					daySchedule.UpdatedTime = time.Now().Unix()
-					err := service.UpdateSchedule(&daySchedule)
+					//daySchedule.PartitionId = deviceNumber.ZoneID
+					//daySchedule.BedId = bedID
+					//daySchedule.ScheduleType = schedual_type
+					//daySchedule.UpdatedTime = time.Now().Unix()
+					//err := service.UpdateSchedule(&daySchedule)
+					xtSchedule := models.Schedule{
+						PartitionId:  deviceNumber.ZoneID,
+						BedId:        bedID,
+						ScheduleType: schedual_type,
+						UpdatedTime:  time.Now().Unix(),
+					}
+					service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 					if err != nil {
 						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 						return
@@ -984,6 +1005,20 @@ func (this *DialysisRecordAPIController) StartDialysis() {
 			UpdatedTime:           time.Now().Unix(),
 		}
 
+		//只针对广慈医院
+		if template.TemplateId == 26 || template.TemplateId == 25 || template.TemplateId == 28 || adminUserInfo.CurrentOrgId == 9987 || adminUserInfo.CurrentOrgId == 9526 || template.TemplateId == 32 || adminUserInfo.CurrentOrgId == 9918 || adminUserInfo.CurrentOrgId == 9671 || adminUserInfo.CurrentOrgId == 3877 || adminUserInfo.CurrentOrgId == 4 {
+			// 查询病人是否有透前评估数据
+			befor, errcode := service.GetAssessmentBefor(adminUserInfo.CurrentOrgId, patientID, recordDate.Unix())
+			//如果有数据就插入
+			if errcode == nil {
+				record.SystolicBloodPressure = befor.SystolicBloodPressure
+				record.DiastolicBloodPressure = befor.DiastolicBloodPressure
+				record.BreathingRate = befor.BreathingRate
+				record.PulseFrequency = befor.PulseFrequency
+				record.Temperature = befor.Temperature
+			}
+		}
+
 		// 如果当天有插入数据，则不再往透析纪录里插入数据
 		if newdialysisRecord.ID > 0 {
 			err := service.CreateMonitor(&record)
@@ -1375,11 +1410,18 @@ func (this *DialysisRecordAPIController) ModifyStartDialysis() {
 			// 修改了床位逻辑
 			daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
 			if daySchedule.ID > 0 {
-				daySchedule.BedId = bedID
-				daySchedule.PartitionId = deviceNumber.ZoneID
-				daySchedule.ScheduleType = schedual_type
-				daySchedule.UpdatedTime = time.Now().Unix()
-				err := service.UpdateSchedule(&daySchedule)
+				//daySchedule.BedId = bedID
+				//daySchedule.PartitionId = deviceNumber.ZoneID
+				//daySchedule.ScheduleType = schedual_type
+				//daySchedule.UpdatedTime = time.Now().Unix()
+				//err := service.UpdateSchedule(&daySchedule)
+				xtSchedule := models.Schedule{
+					PartitionId:  deviceNumber.ZoneID,
+					BedId:        bedID,
+					ScheduleType: schedual_type,
+					UpdatedTime:  time.Now().Unix(),
+				}
+				service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 				if err != nil {
 					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 					return
@@ -1390,12 +1432,19 @@ func (this *DialysisRecordAPIController) ModifyStartDialysis() {
 			if schedule.ID > 0 && schedule.DialysisOrder.ID == 0 { //有排班没上机记录
 				daySchedule, _ := service.GetDaySchedule(adminUserInfo.CurrentOrgId, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
 				if daySchedule.ID > 0 {
-					daySchedule.BedId = bedID
-					daySchedule.PartitionId = deviceNumber.ZoneID
-
-					daySchedule.ScheduleType = schedual_type
-					daySchedule.UpdatedTime = time.Now().Unix()
-					err := service.UpdateSchedule(&daySchedule)
+					//daySchedule.BedId = bedID
+					//daySchedule.PartitionId = deviceNumber.ZoneID
+					//
+					//daySchedule.ScheduleType = schedual_type
+					//daySchedule.UpdatedTime = time.Now().Unix()
+					//err := service.UpdateSchedule(&daySchedule)
+					xtSchedule := models.Schedule{
+						PartitionId:  deviceNumber.ZoneID,
+						BedId:        bedID,
+						ScheduleType: schedual_type,
+						UpdatedTime:  time.Now().Unix(),
+					}
+					service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 					if err != nil {
 						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 						return

controllers/drug_stock_api_contorller.go

@@ -1921,6 +1921,10 @@ func (c *StockDrugApiController) EditDrugWarehouseOut() {
 			////比较当前出库数量 和 最后一次出库数量,正常出库
 			if max_number <= min_number {
 				errs = service.UpDateDrugWarehouseOutInfo(item)
+				flow := models.DrugFlow{
+					Count: item.Count,
+				}
+				service.UpdateDrugFlowSix(item.WarehouseOutId, item.DrugId, item.WarehouseOutOrderNumber, flow)
 				cha_number = min_number - max_number
 
 				if item.CountUnit == medical.MaxUnit {
@@ -1987,7 +1991,10 @@ func (c *StockDrugApiController) EditDrugWarehouseOut() {
 				if all_number > cha_number {
 
 					errs = service.UpDateDrugWarehouseOutInfo(item)
-
+					flow := models.DrugFlow{
+						Count: item.Count,
+					}
+					service.UpdateDrugFlowSix(item.WarehouseOutId, item.DrugId, item.WarehouseOutOrderNumber, flow)
 					if item.CountUnit == medical.MaxUnit {
 						maxNumber = cha_number / medical.MinNumber
 

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -2078,7 +2078,13 @@ func (this *DialysisAPIController) StartDialysis() {
 			daySchedule.BedId = bedID
 			daySchedule.ScheduleType = schedual_type
 			daySchedule.UpdatedTime = time.Now().Unix()
-			err := service.UpdateSchedule(&daySchedule)
+			xtSchedule := models.Schedule{
+				PartitionId:  deviceNumber.ZoneID,
+				BedId:        bedID,
+				ScheduleType: schedual_type,
+				UpdatedTime:  time.Now().Unix(),
+			}
+			service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 			if err != nil {
 				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 				return
@@ -2096,11 +2102,18 @@ func (this *DialysisAPIController) StartDialysis() {
 				} else {
 					daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, patientID)
 					if daySchedule.ID > 0 {
-						daySchedule.PartitionId = deviceNumber.ZoneID
-						daySchedule.BedId = bedID
-						daySchedule.ScheduleType = schedual_type
-						daySchedule.UpdatedTime = time.Now().Unix()
-						err := service.UpdateSchedule(&daySchedule)
+						//daySchedule.PartitionId = deviceNumber.ZoneID
+						//daySchedule.BedId = bedID
+						//daySchedule.ScheduleType = schedual_type
+						//daySchedule.UpdatedTime = time.Now().Unix()
+						//err := service.UpdateSchedule(&daySchedule)
+						xtSchedule := models.Schedule{
+							PartitionId:  deviceNumber.ZoneID,
+							BedId:        bedID,
+							ScheduleType: schedual_type,
+							UpdatedTime:  time.Now().Unix(),
+						}
+						service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 						if err != nil {
 							this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 							return
@@ -2110,11 +2123,18 @@ func (this *DialysisAPIController) StartDialysis() {
 			} else if order_err == gorm.ErrRecordNotFound { //该床位没被占用
 				daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, patientID)
 				if daySchedule.ID > 0 {
-					daySchedule.PartitionId = deviceNumber.ZoneID
-					daySchedule.BedId = bedID
-					daySchedule.ScheduleType = schedual_type
-					daySchedule.UpdatedTime = time.Now().Unix()
-					err := service.UpdateSchedule(&daySchedule)
+					//daySchedule.PartitionId = deviceNumber.ZoneID
+					//daySchedule.BedId = bedID
+					//daySchedule.ScheduleType = schedual_type
+					//daySchedule.UpdatedTime = time.Now().Unix()
+					//err := service.UpdateSchedule(&daySchedule)
+					xtSchedule := models.Schedule{
+						PartitionId:  deviceNumber.ZoneID,
+						BedId:        bedID,
+						ScheduleType: schedual_type,
+						UpdatedTime:  time.Now().Unix(),
+					}
+					service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 					if err != nil {
 						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 						return
@@ -2247,7 +2267,7 @@ func (this *DialysisAPIController) StartDialysis() {
 	}
 
 	//只针对广慈医院
-	if template.TemplateId == 26 || template.TemplateId == 25 || template.TemplateId == 28 || adminUserInfo.Org.Id == 9987 || adminUserInfo.Org.Id == 9526 || template.TemplateId == 32 {
+	if template.TemplateId == 26 || template.TemplateId == 25 || template.TemplateId == 28 || adminUserInfo.Org.Id == 9987 || adminUserInfo.Org.Id == 9526 || template.TemplateId == 32 || adminUserInfo.Org.Id == 9918 || adminUserInfo.Org.Id == 9671 || adminUserInfo.Org.Id == 3877 || adminUserInfo.Org.Id == 4 {
 		// 查询病人是否有透前评估数据
 		befor, errcode := service.GetAssessmentBefor(adminUserInfo.Org.Id, patientID, recordDate.Unix())
 		//如果有数据就插入
@@ -2939,11 +2959,18 @@ func (this *DialysisAPIController) ModifyStartDialysisOrder() {
 			// 修改了床位逻辑
 			daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
 			if daySchedule.ID > 0 {
-				daySchedule.BedId = bedID
-				daySchedule.PartitionId = deviceNumber.ZoneID
-				daySchedule.ScheduleType = schedual_type
-				daySchedule.UpdatedTime = time.Now().Unix()
-				err := service.UpdateSchedule(&daySchedule)
+				//daySchedule.BedId = bedID
+				//daySchedule.PartitionId = deviceNumber.ZoneID
+				//daySchedule.ScheduleType = schedual_type
+				//daySchedule.UpdatedTime = time.Now().Unix()
+				//err := service.UpdateSchedule(&daySchedule)
+				xtSchedule := models.Schedule{
+					PartitionId:  deviceNumber.ZoneID,
+					BedId:        bedID,
+					ScheduleType: schedual_type,
+					UpdatedTime:  time.Now().Unix(),
+				}
+				service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 				if err != nil {
 					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 					return
@@ -2954,12 +2981,19 @@ func (this *DialysisAPIController) ModifyStartDialysisOrder() {
 			if schedule.ID > 0 && schedule.DialysisOrder.ID == 0 { //有排班没上机记录
 				daySchedule, _ := service.GetDaySchedule(adminUserInfo.Org.Id, schedulestartTime, scheduleendTime, tempDialysisRecord.PatientId)
 				if daySchedule.ID > 0 {
-					daySchedule.BedId = bedID
-					daySchedule.PartitionId = deviceNumber.ZoneID
-
-					daySchedule.ScheduleType = schedual_type
-					daySchedule.UpdatedTime = time.Now().Unix()
-					err := service.UpdateSchedule(&daySchedule)
+					//daySchedule.BedId = bedID
+					//daySchedule.PartitionId = deviceNumber.ZoneID
+					//
+					//daySchedule.ScheduleType = schedual_type
+					//daySchedule.UpdatedTime = time.Now().Unix()
+					//err := service.UpdateSchedule(&daySchedule)
+					xtSchedule := models.Schedule{
+						PartitionId:  deviceNumber.ZoneID,
+						BedId:        bedID,
+						ScheduleType: schedual_type,
+						UpdatedTime:  time.Now().Unix(),
+					}
+					service.UpdateScheduleOne(daySchedule.ID, xtSchedule)
 					if err != nil {
 						this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 						return

controllers/new_mobile_api_controllers/staff_schedule_api_controller.go

@@ -688,12 +688,10 @@ func (c *StaffScheduleApiController) CreateMobileSchedulePatient() {
 	}
 
 	redis := service.RedisClient()
-	defer redis.Close()
 	err = service.CreateSchedule(&schedule)
-
 	key := "scheduals_" + scheduleDate + "_" + strconv.FormatInt(adminUserInfo.Org.Id, 10)
 	redis.Set(key, "", time.Second)
-
+	defer redis.Close()
 	fmt.Println(err)
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateScheduleFail)

controllers/patient_api_controller.go

@@ -2514,6 +2514,10 @@ func (c *PatientApiController) DeleteDoctorAdvice() {
 
 	err := service.DeleteDoctorAdvice(&advice)
 	redis := service.RedisClient()
+	keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(advice.PatientId, 10) + ":" + strconv.FormatInt(advice.AdviceDate, 10) + ":doctor_advices"
+
+	redis.Set(keyOne, "", time.Second)
+
 	key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(advice.AdviceDate, 10) + ":advice_list_all"
 	redis.Set(key, "", time.Second)
 	redis.Close()
@@ -2556,12 +2560,14 @@ func (c *PatientApiController) DeleteGroupAdvice() {
 	//}
 
 	err := service.DeleteGroupAdvice(adminUserInfo.CurrentOrgId, groupNo, adminUserInfo.AdminUser.Id)
+
 	key := strconv.FormatInt(advice.UserOrgId, 10) + ":" + strconv.FormatInt(advice.PatientId, 10) + ":" + strconv.FormatInt(advice.AdviceDate, 10) + ":doctor_advices"
 	redis := service.RedisClient()
 
 	redis.Set(key, "", time.Second)
 	keyOne := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(advice.AdviceDate, 10) + ":advice_list_all"
 	redis.Set(keyOne, "", time.Second)
+
 	defer redis.Close()
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDeleteAdviceFail)

service/schedule_service.go

@@ -208,6 +208,13 @@ func UpdateSchedule(m *models.Schedule) error {
 	return err
 }
 
+func UpdateScheduleOne(id int64, schedule models.Schedule) error {
+	utx := XTWriteDB().Begin()
+	err := XTWriteDB().Where("id = ? and status = 1", id).Updates(map[string]interface{}{"partition_id": schedule.PartitionId, "bed_id": schedule.BedId, "schedule_type": schedule.ScheduleType}).Error
+	utx.Commit()
+	return err
+}
+
 func GetPatientScheduleFormToday(orgId, id, start int64) (schedules []*models.PatientSchedule, err error) {
 
 	err = readDb.Table("xt_schedule as s").

service/stock_service.go

@@ -2193,6 +2193,12 @@ func UpDateDrugWarehouseOutInfo(info *models.DrugWarehouseOutInfo) (err error) {
 	return err
 }
 
+func UpdateDrugFlowSix(warehousoutid int64, drugid int64, warehouse_out_order_number string, flow models.DrugFlow) error {
+
+	err := XTWriteDB().Model(&flow).Where("warehouse_out_id = ? and drug_id = ? and warehouse_out_order_number = ?", warehousoutid, drugid, warehouse_out_order_number).Updates(map[string]interface{}{"count": flow.Count}).Error
+	return err
+}
+
 func FindAllCancelList(orgId int64, page int64, limit int64, startTime int64, endTime int64, types int64, keywords string) (list []*models.CancelStock, total int64, err error) {
 	db := readDb.Model(&models.CancelStock{})
 	db = db.Where("xt_cancel_stock.org_id = ? AND xt_cancel_stock.status = 1 AND xt_cancel_stock.type = ?", orgId, types)
@@ -3469,7 +3475,7 @@ func GetStockDrugCount(startime int64, endtime int64, orgid int64) (info []*mode
 }
 
 func GetAutoDiallysisBefor(startime int64, endtime int64, orgid int64) (info []*models.VmWarehouseInfo, err error) {
-	db := XTReadDB().Table("xt_warehouse_out_info as x").Where("x.status = 1 and is_sys = 0")
+	db := XTReadDB().Table("xt_warehouse_out_info as x").Where("x.status = 1")
 	if startime > 0 {
 		db = db.Where("x.ctime >=?", startime)
 	}