历史排班

controllers/manager_center_api_controller.go

@@ -234,6 +234,10 @@ func (c *ManagerCenterApiController) CreateBaseDrugLib() {
 	count := service.FindBaseDrugLibRecordCountOne(drugLib)
 
 	if count == 0 {
+		if adminInfo.CurrentOrgId == 10206 || adminInfo.CurrentOrgId == 10344 {
+
+			drugLib.DrugSpec = drugLib.Dose + drugLib.DoseUnit + "*" + string(drugLib.MinNumber) + drugLib.MinUnit + "/" + drugLib.MaxUnit
+		}
 		err := service.CreateBaseDrugLib(drugLib)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
@@ -399,6 +403,10 @@ func (c *ManagerCenterApiController) EditBaseDrugLib() {
 		SumInCount:                  sum_in_count,
 		IsPharmacy:                  is_pharmacy,
 	}
+	if adminInfo.CurrentOrgId == 10206 || adminInfo.CurrentOrgId == 10344 {
+
+		drugLib.DrugSpec = drugLib.Dose + drugLib.DoseUnit + "*" + string(drugLib.MinNumber) + drugLib.MinUnit + "/" + drugLib.MaxUnit
+	}
 
 	err := service.UpdateBaseDrugLib(drugLib)
 

controllers/mobile_api_controllers/dialysis_api_controller.go

@@ -6157,6 +6157,396 @@ func (c *DialysisAPIController) CreateStockOutInfo() {
 	//去重
 	consumables = RemoveRepeatedGood(consumables)
 
+	if adminInfo.Org.Id == 9919 {
+		houseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+		//查询是否有库存
+		for _, item := range consumables {
+			warehouse, _ := service.FindFirstWarehousingInfoByStockTwo(item.GoodId, item.GoodTypeId, houseConfig.StorehouseOutInfo)
+
+			if item.Count > warehouse.Count {
+				goodErrcode := models.XtGoodErrcode{
+					UserOrgId:      item.UserOrgId,
+					Errcode:        "自动出库库存不足",
+					GoodId:         item.GoodId,
+					Status:         1,
+					Ctime:          time.Now().Unix(),
+					Mtime:          0,
+					Count:          0,
+					StockCount:     0,
+					Creater:        creator,
+					BatchNumberId:  warehouse.ID,
+					WarehouseOutId: 0,
+				}
+				service.CreateGoodErrcode(goodErrcode)
+
+				goodObj, _ := service.GetGoodInformationByGoodId(item.GoodId)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"message":            "1",
+					"good_name":          goodObj.GoodName,
+					"specification_name": goodObj.SpecificationName,
+				})
+				return
+			}
+		}
+
+		//查询是否有出库单
+		out, err := service.FindStockOutByIsSys(adminInfo.Org.Id, 1, record_time)
+		if err == gorm.ErrRecordNotFound {
+			//没有记录，则创建出库单
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := service.FindAllWarehouseOut(adminInfo.Org.Id)
+			total = total + 1
+			warehousing_out_order := strconv.FormatInt(adminInfo.Org.Id, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
+			number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
+			number = number + total
+			warehousing_out_order = "CKD" + strconv.FormatInt(number, 10)
+			creater := adminInfo.AdminUser.Id
+			warehouseOut := models.WarehouseOut{
+				WarehouseOutOrderNumber: warehousing_out_order,
+				OperationTime:           time.Now().Unix(),
+				OrgId:                   adminInfo.Org.Id,
+				Creater:                 creater,
+				Ctime:                   time.Now().Unix(),
+				Status:                  1,
+				WarehouseOutTime:        record_time,
+				Dealer:                  0,
+				Manufacturer:            0,
+				Type:                    1,
+				IsSys:                   1,
+				StorehouseId:            houseConfig.StorehouseOutInfo,
+				IsCheck:                 1,
+			}
+			err := service.AddSigleWarehouseOut(&warehouseOut)
+			if err != nil {
+				goodErrcode := models.XtGoodErrcode{
+					UserOrgId:      adminInfo.Org.Id,
+					Errcode:        "创建出库单失败",
+					GoodId:         0,
+					Status:         1,
+					Ctime:          time.Now().Unix(),
+					Mtime:          0,
+					Count:          0,
+					StockCount:     0,
+					Creater:        creator,
+					BatchNumberId:  0,
+					WarehouseOutId: 0,
+				}
+				service.CreateGoodErrcode(goodErrcode)
+				utils.TraceLog("创建出库单失败 err = %v", err)
+
+			} else {
+
+				for _, item := range consumables {
+					//出库
+					err := service.ConsumablesGoodDelivery(item.UserOrgId, patient_id, record_time, item, &warehouseOut, item.Count)
+
+					//err := service.ConsumableMobileDelivery(item.UserOrgId, patient_id, record_time, item, &warehouseOut, adminInfo.AdminUser.Id, item.Count)
+
+					if err == nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      adminInfo.Org.Id,
+							Errcode:        "自动出库接口报错",
+							GoodId:         0,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creator,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+						utils.TraceLog("创建出库单失败 err = %v", err)
+					}
+
+					//查询
+
+					//出库数量相加
+					errs := service.ModifyGoodSumCount(houseConfig.StorehouseOutInfo, item.Count, item.UserOrgId, item.GoodId)
+					if errs != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      item.UserOrgId,
+							Errcode:        "创建剩余库存字段报错",
+							GoodId:         item.GoodId,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creater,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+				}
+
+				list, _ := service.GetAutoReduceRecordInfoByPatientId(adminInfo.Org.Id, patient_id, record_time)
+				if len(list) == 0 {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+					return
+				}
+				for _, item := range list {
+					prepare := models.DialysisBeforePrepare{
+						UserOrgId:    adminInfo.Org.Id,
+						PatientId:    patient_id,
+						RecordDate:   record_time,
+						GoodId:       item.GoodId,
+						GoodTypeId:   item.GoodTypeId,
+						Count:        item.Count,
+						Creater:      adminInfo.AdminUser.Id,
+						Status:       1,
+						Ctime:        time.Now().Unix(),
+						StorehouseId: houseConfig.StorehouseOutInfo,
+					}
+					//清空准备表数据
+					err := service.DeleteDialysisBefor(adminInfo.Org.Id, patient_id, record_time, item.GoodId, item.GoodTypeId)
+					if err != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      item.OrgId,
+							Errcode:        "自动出库清空准备表数据报错",
+							GoodId:         item.GoodId,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creater,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+					errs := service.CreateDialysisBeforePrepareOne(&prepare)
+					if errs != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      item.OrgId,
+							Errcode:        "自动出库创建准备表数据报错",
+							GoodId:         item.GoodId,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creater,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+
+					//查询默认仓库
+					storeHouseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+					stockList, _ := service.GetStockCountByGoodId(item.GoodId, storeHouseConfig.StorehouseOutInfo, adminInfo.Org.Id)
+					var total_count int64
+					for _, it := range stockList {
+						total_count += it.StockCount
+					}
+					//基础库插入数据
+					errcodes := service.UpdateGoodInfoReduceSumCount(item.GoodId, total_count, adminInfo.Org.Id)
+					if errcodes != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      item.OrgId,
+							Errcode:        "自动出库基础库插入数据",
+							GoodId:         item.GoodId,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creater,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+
+					goodList, _ := service.GetSumGoodList(adminInfo.Org.Id, storeHouseConfig.StorehouseOutInfo, item.GoodId)
+					var flush_count int64
+					for _, it := range goodList {
+						flush_count += it.StockCount
+					}
+
+					errsss := service.UpdateSumGood(adminInfo.Org.Id, storeHouseConfig.StorehouseOutInfo, item.GoodId, flush_count)
+					if errsss != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      item.OrgId,
+							Errcode:        "自动出库剩余库存更新数据",
+							GoodId:         item.GoodId,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creater,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+				}
+			}
+			//
+		} else if err == nil {
+			for _, item := range consumables {
+				//出库
+				err := service.ConsumablesGoodDelivery(item.UserOrgId, patient_id, record_time, item, &out, item.Count)
+				//err := service.ConsumableMobileDelivery(item.UserOrgId, patient_id, record_time, item, &out, adminInfo.AdminUser.Id, item.Count)
+				if err != nil {
+					goodErrcode := models.XtGoodErrcode{
+						UserOrgId:      adminInfo.Org.Id,
+						Errcode:        "自动出库接口报错",
+						GoodId:         0,
+						Status:         1,
+						Ctime:          time.Now().Unix(),
+						Mtime:          0,
+						Count:          0,
+						StockCount:     0,
+						Creater:        creator,
+						BatchNumberId:  0,
+						WarehouseOutId: 0,
+					}
+					service.CreateGoodErrcode(goodErrcode)
+				}
+
+				//出库数量相加
+				errss := service.ModifyGoodSumCount(houseConfig.StorehouseOutInfo, item.Count, item.UserOrgId, item.GoodId)
+				if errss != nil {
+					goodErrcode := models.XtGoodErrcode{
+						UserOrgId:      item.UserOrgId,
+						Errcode:        "创建剩余库存字段报错",
+						GoodId:         item.GoodId,
+						Status:         1,
+						Ctime:          time.Now().Unix(),
+						Mtime:          time.Now().Unix(),
+						Count:          0,
+						StockCount:     0,
+						Creater:        item.Creater,
+						BatchNumberId:  0,
+						WarehouseOutId: 0,
+					}
+					service.CreateGoodErrcode(goodErrcode)
+				}
+
+				list, _ := service.GetAutoReduceRecordInfoByPatientId(adminInfo.Org.Id, patient_id, record_time)
+				if len(list) == 0 {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+					return
+				}
+				for _, item := range list {
+					prepare := models.DialysisBeforePrepare{
+						UserOrgId:    adminInfo.Org.Id,
+						PatientId:    patient_id,
+						RecordDate:   record_time,
+						GoodId:       item.GoodId,
+						GoodTypeId:   item.GoodTypeId,
+						Count:        item.Count,
+						Creater:      adminInfo.AdminUser.Id,
+						Status:       1,
+						Ctime:        time.Now().Unix(),
+						StorehouseId: houseConfig.StorehouseOutInfo,
+					}
+
+					//清空准备表数据
+					errs := service.DeleteDialysisBefor(adminInfo.Org.Id, patient_id, record_time, item.GoodId, item.GoodTypeId)
+					if errs != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      adminInfo.Org.Id,
+							Errcode:        "自动出库清空准备表数据报错",
+							GoodId:         0,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creator,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+					errcodes := service.CreateDialysisBeforePrepareOne(&prepare)
+					if errcodes != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      adminInfo.Org.Id,
+							Errcode:        "自动出库创建准备表数据报错",
+							GoodId:         0,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creator,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+
+					//查询默认仓库
+					storeHouseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+					stockList, _ := service.GetStockCountByGoodId(item.GoodId, storeHouseConfig.StorehouseOutInfo, adminInfo.Org.Id)
+					var total_count int64
+					for _, it := range stockList {
+						total_count += it.StockCount
+					}
+					//基础库插入数据
+					errcodes = service.UpdateGoodInfoReduceSumCount(item.GoodId, total_count, adminInfo.Org.Id)
+					if errcodes != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      adminInfo.Org.Id,
+							Errcode:        "自动出库基础库插入数据报错",
+							GoodId:         0,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creator,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+
+					goodList, _ := service.GetSumGoodList(adminInfo.Org.Id, storeHouseConfig.StorehouseOutInfo, item.GoodId)
+					var flush_count int64
+					for _, it := range goodList {
+						flush_count += it.StockCount
+					}
+
+					errss := service.UpdateSumGood(adminInfo.Org.Id, storeHouseConfig.StorehouseOutInfo, item.GoodId, flush_count)
+					creater := c.GetMobileAdminUserInfo().AdminUser.Id
+					if errss != nil {
+						goodErrcode := models.XtGoodErrcode{
+							UserOrgId:      item.OrgId,
+							Errcode:        "自动出库剩余库存更新数据",
+							GoodId:         item.GoodId,
+							Status:         1,
+							Ctime:          time.Now().Unix(),
+							Mtime:          0,
+							Count:          0,
+							StockCount:     0,
+							Creater:        creater,
+							BatchNumberId:  0,
+							WarehouseOutId: 0,
+						}
+						service.CreateGoodErrcode(goodErrcode)
+					}
+
+				}
+			}
+		}
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg":                "提交成功",
+			"message":            "2",
+			"good_name":          "",
+			"specification_name": "",
+		})
+		return
+	}
 	if record.IsOpen == 1 {
 		houseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
 		//查询是否有库存

controllers/mobile_api_controllers/patient_api_controller.go

@@ -2649,8 +2649,8 @@ func (c *PatientApiController) EditAssessmentBeforeDislysis() {
 	// 插入透析处方
 	if dialysisPrescribe == nil && dialysisSolution != nil {
 		var newprescribe models.DialysisPrescription
-		newprescribe.UserOrgId = dialysisSolution.UserOrgId
-		newprescribe.PatientId = dialysisSolution.PatientId
+		newprescribe.UserOrgId = adminUserInfo.Org.Id
+		newprescribe.PatientId = id
 		newprescribe.Anticoagulant = dialysisSolution.Anticoagulant
 		newprescribe.AnticoagulantShouji = dialysisSolution.AnticoagulantShouji
 		newprescribe.AnticoagulantWeichi = dialysisSolution.AnticoagulantWeichi
@@ -2812,8 +2812,8 @@ func (c *PatientApiController) EditAssessmentBeforeDislysis() {
 	if dialysisPrescribe == nil && dialysisSolution == nil {
 		if lastDialysisPrescribe != nil {
 			var newprescribe models.DialysisPrescription
-			newprescribe.UserOrgId = lastDialysisPrescribe.UserOrgId
-			newprescribe.PatientId = lastDialysisPrescribe.PatientId
+			newprescribe.UserOrgId = adminUserInfo.Org.Id
+			newprescribe.PatientId = id
 			newprescribe.Anticoagulant = lastDialysisPrescribe.Anticoagulant
 			newprescribe.AnticoagulantShouji = lastDialysisPrescribe.AnticoagulantShouji
 			newprescribe.AnticoagulantWeichi = lastDialysisPrescribe.AnticoagulantWeichi
@@ -2966,7 +2966,7 @@ func (c *PatientApiController) EditAssessmentBeforeDislysis() {
 		} else if system_dialysisPrescribe != nil {
 
 			var newprescribe models.DialysisPrescription
-			newprescribe.UserOrgId = system_dialysisPrescribe.UserOrgId
+			newprescribe.UserOrgId = adminUserInfo.Org.Id
 			newprescribe.PatientId = id
 			newprescribe.Anticoagulant = system_dialysisPrescribe.Anticoagulant
 			newprescribe.AnticoagulantShouji = system_dialysisPrescribe.AnticoagulantShouji
@@ -3133,7 +3133,10 @@ func (c *PatientApiController) EditAssessmentBeforeDislysis() {
 			newprescribe.Status = 1
 
 			_, dialysisPrescription := service.FindDialysisPrescriptionByReordDate(id, theAssessmentDateTime, adminUserInfo.Org.Id)
-			newprescribe.ID = dialysisPrescription.ID
+			if dialysisPrescription.ID > 0 {
+				newprescribe.ID = dialysisPrescription.ID
+			}
+
 			if dialysisPrescription.ID == 0 {
 				if adminUserInfo.Org.Id == 10340 {
 					newprescribe.Sodium = 138

service/warhouse_service.go

@@ -622,10 +622,20 @@ func HisDrugsDelivery(orgID int64, creater int64, advice *models.HisDoctorAdvice
 			BloodHisDrugDeliverInfo(orgID, prescribingNumber, &out, &drup, advice, prescribingNumber, advice.PrescribingNumberUnit)
 
 			//查询今日出库的数据
-			//if orgID == 10188 || orgID == 10217 || orgID == 10344 {
-			//	//查询这个患者今日用过的总数量
-			//	GetDrugFlowByWatch(advice.PatientId, advice.DrugId, advice.AdviceDate, advice.UserOrgId)
-			//}
+			if orgID == 10188 || orgID == 10217 || orgID == 10344 {
+				//查询这个患者今日用过的总数量
+				listDrugFlow, _ := GetDrugFlowByWatch(advice.PatientId, advice.DrugId, advice.AdviceDate, advice.UserOrgId)
+				for _, item := range listDrugFlow {
+
+					outInfor, _ := GetDrugWarehouseOutInfor(item.WarehouseOutDetailId, item.UserOrgId)
+					if item.MaxUnit == outInfor.CountUnit {
+						if item.Count != outInfor.Count {
+							UpdateDrugWarehouseOutInfoById(outInfor.ID, item.Count)
+						}
+					}
+
+				}
+			}
 
 		} else {
 			return errors.New("药品信息不存在")
@@ -636,9 +646,24 @@ func HisDrugsDelivery(orgID int64, creater int64, advice *models.HisDoctorAdvice
 	return
 }
 
-//func GetDrugFlowByWatch(patient_id int64, drug_id int64, advice_date) {
-//
-//}
+func GetDrugFlowByWatch(patient_id int64, drug_id int64, advice_date int64, user_org_id int64) (list []*models.DrugFlow, err error) {
+
+	err = XTReadDB().Where("patient_id = ? and drug_id = ? and system_time = ? and user_org_id = ? and status =1 and consumable_type = 3", patient_id, drug_id, advice_date, user_org_id).Find(&list).Error
+	return list, err
+}
+
+func GetDrugWarehouseOutInfor(id int64, user_org_id int64) (models.DrugWarehouseOutInfo, error) {
+
+	outInfo := models.DrugWarehouseOutInfo{}
+	err := XTReadDB().Where("id = ? and user_org_id = ?", id, user_org_id).Find(&outInfo).Error
+	return outInfo, err
+}
+
+func UpdateDrugWarehouseOutInfoById(id int64, count int64) error {
+
+	err := XTWriteDB().Model(&models.DrugWarehouseOutInfo{}).Where("id = ? and status =1", id).Updates(map[string]interface{}{"count": count}).Error
+	return err
+}
 
 // 药品出库 递归方式
 func HisDrugDeliverInfo(orgID int64, prescribingNumber float64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.HisDoctorAdviceInfo) (err error) {