医保对接

controllers/drug_stock_api_contorller.go

 				}
 				price, _ := strconv.ParseFloat(items["price"].(string), 64)
 
-				//if items["last_price"] == nil || reflect.TypeOf(items["last_price"]).String() != "string" {
-				//	utils.ErrorLog("last_price")
-				//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-				//	return
-				//}
-				//last_price, _ := strconv.ParseFloat(items["last_price"].(string), 64)
-				//fmt.Println(last_price)
 				count, _ := strconv.ParseInt(items["count"].(string), 10, 64)
 
 				total := float64(count) * price
 					}
 
 				}
-
+				fmt.Println("孟子", warehouseOut.ID)
 				warehouseOutInfo := &models.DrugWarehouseOutInfo{
+
 					WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 					WarehouseOutId:          warehouseOut.ID,
 					DrugId:                  drug_id,
 					WarehouseInfoId:         warehouse_info_id,
 				}
 				warehousingOutInfo = append(warehousingOutInfo, warehouseOutInfo)
+				fmt.Println("hhhhhhhhhhhhhhhh", warehouseOut.ID)
 
 				drugflow := &models.DrugFlow{
 					WarehouseOutId:          warehouseOut.ID,
-					WarehouseOutOrderNumber: warehousing_out_order,
+					WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 					DrugId:                  drug_id,
 					Number:                  number,
 					ProductDate:             productDates,
 			return
 		} else {
 			service.AddSigleDrugWarehouseOut(&warehouseOut)
+			list, _ := service.GetLastWarehouseOut(adminUserInfo.CurrentOrgId)
+			for _, item := range drugFlow {
+				item.WarehouseOutId = list.ID
+			}
 			service.CreateDrugFlow(drugFlow)
 			// 出库流程
 			// 1.查询改药品在药品库的规格信息，并将处方里的规格进行换算（尽量将拆零单位转换成包装单位）
 				batch_number := items["batch_number"].(string)
 				max_unit := items["max_unit"].(string)
 				batch_number_id := int64(items["batch_number_id"].(float64))
-
+				var manufacturer_id int64
+				var dealer_id int64
+				manufacturerList, _ := service.GetAllManufacturerList(adminUserInfo.CurrentOrgId)
+				dealerList, _ := service.GetAllDealerList(adminUserInfo.CurrentOrgId)
+				for _, item := range manufacturerList {
+					if manufacturer == item.ManufacturerName {
+						manufacturer_id = item.ID
+					}
+				}
+				for _, item := range dealerList {
+					if dealer == item.DealerName {
+						dealer_id = item.ID
+					}
+				}
 				fmt.Println("99999999999999999999", batch_number_id)
 				cancelStockInfo := &models.DrugCancelStockInfo{
 					OrderNumber:      cancelStock.OrderNumber,
 					IsEdit:                  0,
 					CancelStockId:           cancelStock.ID,
 					CancelOrderNumber:       cancelStock.OrderNumber,
-					Manufacturer:            0,
-					Dealer:                  0,
+					Manufacturer:            manufacturer_id,
+					Dealer:                  dealer_id,
 					Creator:                 adminUserInfo.AdminUser.Id,
 					UpdateCreator:           0,
 					Status:                  1,
 	adminUserInfo := c.GetAdminUserInfo()
 	orgId := adminUserInfo.CurrentOrgId
 	if order_type == 2 {
-		//list, err := service.GetDrugOutOrderPrint(startTime, endTime, orgId)
-		list, err := service.GetDrugOutOrderPrintList(startTime, endTime, orgId)
+		list, err := service.GetDrugOutOrderInfoPrintList(startTime, endTime, orgId)
+		//list, err := service.GetDrugOutOrderPrintList(startTime, endTime, orgId)
 		if err == nil {
 			c.ServeSuccessJSON(map[string]interface{}{
 				"list": list,

controllers/gobal_config_api_controller.go

 	keyword := c.GetString("keyword")
 	limit, _ := c.GetInt64("limit")
 	page, _ := c.GetInt64("page")
+	orderPrint, _ := service.GetDrugCancelOrderPrint(startTime, endTime, adminInfo.CurrentOrgId, order_type, manufacturer_id, keyword)
 	order, total, err := service.GetDrugCancelOrder(startTime, endTime, adminInfo.CurrentOrgId, order_type, manufacturer_id, keyword, page, limit)
+
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateConfig)
 		return
 	}
 	c.ServeSuccessJSON(map[string]interface{}{
-		"order": order,
-		"total": total,
+		"order":      order,
+		"total":      total,
+		"orderPrint": orderPrint,
 	})
 }
 
 	}
 	adminUserInfo := c.GetAdminUserInfo()
 
-	//查询入库数量
-	//list, total, err := service.GetDrugStockList(page, limit, keyword, drug_type, startTime, endTime, adminUserInfo.CurrentOrgId)
-
 	list, total, err := service.GetAllBaseDurgListCount(page, limit, keyword, drug_type, startTime, endTime, adminUserInfo.CurrentOrgId)
 	fmt.Println("total232323232323232232323", total)
 	manufacturerList, _ := service.GetAllManufacturerList(adminUserInfo.CurrentOrgId)
 	start_time, _ := c.GetInt64("start_time")
 	orgId := c.GetAdminUserInfo().CurrentOrgId
 	list, err := service.GetSingleOrderDetail(id, orgId)
-	outList, err := service.GetAllSingleDrugDetail(id, orgId)
 	dealerList, err := service.GetAllDealerList(orgId)
 	manufacturerList, err := service.GetAllManufacturerList(orgId)
 	drugFlowList, _ := service.GetDrugStockFlowDetail(start_time, orgId)
+
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateConfig)
 		return
 		"list":             list,
 		"dealerList":       dealerList,
 		"manufacturerList": manufacturerList,
-		"outList":          outList,
 		"drugFlowList":     drugFlowList,
 	})
 }
 	ids := strings.Split(id, ",")
 	admin := c.GetAdminUserInfo()
 	info, _ := service.FindeDrugWarehouseOutOrder(ids, admin.CurrentOrgId)
+	//info, _ := service.GetExportOutOrderDrugListOne(ids)
 	manufacturerList, _ := service.GetAllManufacturerList(admin.CurrentOrgId)
-	warehousing, _ := service.FindeDrugWarehouseOutDetail(ids, admin.CurrentOrgId)
+	//warehousing, _ := service.FindeDrugWarehouseOutDetail(ids, admin.CurrentOrgId)
+	warehousing, _ := service.GetExportOutOrderDrugListOne(ids)
 	c.ServeSuccessJSON(map[string]interface{}{
 		"info":             info,
 		"warehousing":      warehousing,
 	orderId := c.GetString("order_id")
 	ids := strings.Split(orderId, ",")
 	orgId := c.GetAdminUserInfo().CurrentOrgId
-	list, _ := service.GetExportOutOrderDrugList(ids)
+	//list, _ := service.GetExportOutOrderDrugList(ids)
+	list, _ := service.GetExportOutOrderDrugListOne(ids)
 	manufacturerList, _ := service.GetAllManufacturerList(orgId)
 	dealerList, _ := service.GetAllDealerList(orgId)
 	c.ServeSuccessJSON(map[string]interface{}{

controllers/mobile_api_controllers/dialysis_api_controller.go

 	change_nurse, _ := this.GetInt64("change_nurse")
 	difficult_puncture_nurse, _ := this.GetInt64("difficult_puncture_nurse")
 	new_fistula_nurse, _ := this.GetInt64("new_fistula_nurse")
+	zone_id, _ := this.GetInt64("zone_id")
+	fmt.Println("zone23333232323232232332232323", zone_id)
 	if patientID <= 0 || len(recordDateStr) == 0 || nurseID <= 0 || bedID <= 0 {
 		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 		return
 		ChangeNurse:            change_nurse,
 		DifficultPunctureNurse: difficult_puncture_nurse,
 		NewFistulaNurse:        new_fistula_nurse,
+		ZoneId:                 zone_id,
+	}
+	//查询该床位是否有人用了
+	_, errorscode := service.GetDialysisOrderByBedId(adminUserInfo.Org.Id, schedulestartTime, bedID, schedual_type)
+	if errorscode == gorm.ErrRecordNotFound {
+		createErr := service.MobileCreateDialysisOrder(adminUserInfo.Org.Id, patientID, dialysisRecord)
+		if createErr != nil {
+			this.ErrorLog("上机失败：%v", createErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
 	}
 
-	createErr := service.MobileCreateDialysisOrder(adminUserInfo.Org.Id, patientID, dialysisRecord)
 	newdialysisRecord, getRecordErr := service.MobileGetDialysisRecord(adminUserInfo.Org.Id, patientID, recordDate.Unix())
 
 	var tempdispose string
 		http.PostForm(api, values)
 	}()
 
-	if createErr != nil {
-		this.ErrorLog("上机失败：%v", createErr)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
-	}
 	this.ServeSuccessJSON(map[string]interface{}{
 		"dialysis_order": newdialysisRecord,
 		"monitor":        record,

controllers/print_data_api_controller.go

 
 	//出库详情
 	if types == 2 {
-		list, err := service.GetWarehouseOutInfoGoodDetailPrintList(adminUserInfo.CurrentOrgId, startTime, endTime, limit, page)
+		//list, err := service.GetWarehouseOutInfoGoodDetailPrintList(adminUserInfo.CurrentOrgId, startTime, endTime, limit, page)
+		list, _ := service.GetWarehouseOutInfoPrintList(adminUserInfo.CurrentOrgId, startTime, endTime)
 		stockTotal, err := service.GetOutStockTotalCountTwo(startTime, endTime, adminUserInfo.CurrentOrgId)
 		if err != nil {
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 		})
 	}
 
+	//退库详情
+	if types == 4 {
+
+		list, _ := service.GetWarehouseCancelPrintList(adminUserInfo.CurrentOrgId, startTime, endTime)
+		this.ServeSuccessJSON(map[string]interface{}{
+			"list": list,
+		})
+	}
+
 }

controllers/self_drug_api_congtroller.go

 	beego.Router("/api/drug/savedrugcheckinventory", &SelfDrugApiController{}, "Get:SaveDrugCheckInventory")
 	beego.Router("/api/drug/getdruginventorydetail", &SelfDrugApiController{}, "Get:GetDrugInventoryDetail")
 	beego.Router("/api/drug/modifyinventory", &SelfDrugApiController{}, "Get:ModifyInventory")
-	beego.Router("/api/drug/deletedruginventory", &SelfDrugApiController{}, "Delete:DeleteDrugInventory")
+	beego.Router("/api/drug/deletedruginventory", &SelfDrugApiController{}, "Get:DeleteDrugInventory")
 	beego.Router("/api/drug/getdruginventoryprintlist", &SelfDrugApiController{}, "Get:GetDrugInventoryPrintList")
 	beego.Router("/api/drug/getinventorydetaillist", &SelfDrugApiController{}, "Get:GetDrugInventoryDetailList")
 	beego.Router("/api/drug/savedrugproofinventory", &SelfDrugApiController{}, "Get:SaveDrugProofInventory")
 
 			numbers := items["number"].(string)
 
-			//if items["batch_number"] == nil || reflect.TypeOf(items["batch_number"]).String() != "string" {
-			//	utils.ErrorLog("batch_number")
-			//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-			//	return
-			//}
-			//
-			//batch_number := items["batch_number"].(string)
-
 			if items["warehouse_info_id"] == nil || reflect.TypeOf(items["warehouse_info_id"]).String() != "float64" {
 				utils.ErrorLog("warehouse_info_id")
 				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
 			}
 
 			total := items["total"].(string)
+
+			drug_origin_place := items["drug_origin_place"].(string)
+
+			min_count := int64(items["min_count"].(float64))
+			min_unit := items["min_unit"].(string)
 			inventory := models.XtDrugInventory{
 
 				DrugName:          drug_name,
 				//BatchNumber:       batch_number,
 				Total:           total,
 				WarehouseInfoId: warehouse_info_id,
+				DrugOriginPlace: drug_origin_place,
+				MinUnit:         min_unit,
+				MinCount:        min_count,
 			}
 			err = service.CreateDrugInventory(inventory)
 			fmt.Println(err)
 		lastInfo, _ := service.GetLastDrugWarehouseInfo(item.DrugId)
 		firstInfo, _ := service.GetFirstDrugWarehouseInfo(item.DrugId)
 		stock_total = info.StockMaxNumber*drug.MinNumber + info.StockMinNumber
-		proof_count = item.StockMaxNumber*drug.MinNumber + item.StockMinNumber
+		proof_count = item.Count*drug.MinNumber + item.MinCount
 
 		//判断 如果库存数量 大于盘点库存，则出库
 		if stock_total > proof_count {
 	stock_max_number, _ := this.GetInt64("stock_max_number")
 	stock_min_number, _ := this.GetInt64("stock_min_number")
 	warehouse_info_id, _ := this.GetInt64("warehouse_info_id")
+	min_count, _ := this.GetInt64("min_count")
+	min_unit := this.GetString("min_unit")
 	inventory := models.XtDrugInventory{
 		DrugName:          drug_name,
 		SpecificationName: specification_name,
 		StockMaxNumber:    stock_max_number,
 		StockMinNumber:    stock_min_number,
 		WarehouseInfoId:   warehouse_info_id,
+		MinCount:          min_count,
+		MinUnit:           min_unit,
 	}
 	err := service.ModifyDrugInventory(id, inventory)
 	if err != nil {

controllers/stock_in_api_controller.go

 		ReturnTime:  cancelStockDate.Unix(),
 		Type:        types,
 	}
-	service.AddSigleCancelStock(&cancelStock)
+
 	dataBody := make(map[string]interface{}, 0)
 	err := json.Unmarshal(c.Ctx.Input.RequestBody, &dataBody)
 	if err != nil {
 
 	for _, item := range cancelStockInfos {
 
-		////查找该耗材是否有出库记录
-		//_, errcode := service.GetWarehoureOutOrderInfo(item.GoodId, item.OrgId)
-		//if errcode == gorm.ErrRecordNotFound {
-		//	c.ServeSuccessJSON(map[string]interface{}{
-		//		"msg": "1",
-		//	})
-		//	return
-		//}
-
-		//统计该耗材的出库数量
-		info, _ := service.GetWarehoureOrderInfoCount(item.GoodId, item.OrgId)
+		//统计该批次耗材的出库数量
+		info, _ := service.GetWarehoureOrderInfoCount(item.GoodId, item.OrgId, item.WarehouseInfoId)
 		fmt.Println("2333223323322332233223322323", item.Count, info.Count)
 		if item.Count > info.Count {
 			service.UpdateCancelInfo(item.CancelStockId)
 		}
 
 		if item.Count <= infolist.WarehousingCount {
-
+			_, msgerrkonde := service.GetCancelStockDetailByOrderNumber(orderNumber, adminUserInfo.CurrentOrgId)
+			if msgerrkonde == gorm.ErrRecordNotFound {
+				service.AddSigleCancelStock(&cancelStock)
+			}
+			listcancel, _ := service.GetLastCancelStockById(adminUserInfo.CurrentOrgId)
+			for _, it := range cancelStockInfos {
+				it.CancelStockId = listcancel.ID
+			}
 			errs := service.CreateCancelStockInfo(cancelStockInfos)
 			if len(stockFLow) > 0 {
 				service.CreateStockFlow(stockFLow)
 			}
 			//更改入库数量
 			errs = service.UpdateWareInfoById(item.WarehouseInfoId, item.Count)
-
-			//查询该耗材的入库记录
-			//list, _ := service.GetWarehoureOrderInfoList(item.GoodId, item.OrgId)
-			////调用退库的方法
-			//parseDateErr := service.UpdateCancelOut(list, item.Count)
-			//fmt.Println("999999999999", parseDateErr)
 			break
 		}
 	}
 
 		for _, item := range cancelStockInfos {
 			//统计该耗材的出库数量
-			info, _ := service.GetWarehoureOrderInfoCount(item.GoodId, item.OrgId)
+			info, _ := service.GetWarehoureOrderInfoCount(item.GoodId, item.OrgId, item.WarehouseInfoId)
 			if item.Count > info.Count {
 				c.ServeSuccessJSON(map[string]interface{}{
 					"msg": "2",
 		}
 	} else if types == 4 {
 		list3, total, err = service.FindCancelDetailList(adminUserInfo.CurrentOrgId, page, limit, startTime, endTime, keywords, manufacturer, order_type, dealer)
+		listGroup, err := service.FindeCancelGroup(adminUserInfo.CurrentOrgId, startTime, endTime, keywords, manufacturer, order_type, dealer)
 		if err == nil {
 			this.ServeSuccessJSON(map[string]interface{}{
-				"list":  list3,
-				"total": total,
+				"list":      list3,
+				"total":     total,
+				"listgroup": listGroup,
 			})
 		} else {
 			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
 
 	if errcodes == gorm.ErrRecordNotFound {
 		service.AddSigleWarehouseOut(&warehouseOut)
+
 	}
+	out, _ := service.GetLastGoodWarehouseOut(adminUserInfo.CurrentOrgId)
 	manufacturerList, _ := service.GetAllManufacturerList(adminUserInfo.CurrentOrgId)
 	dealerList, _ := service.GetAllDealerList(adminUserInfo.CurrentOrgId)
 	var manufacturer_id int64
 				dealer_id = its.ID
 			}
 		}
+		goodinfo, _ := service.GetGoodInformationByGoodId(item.GoodId)
 		//插入出库单
 		warehouseOutInfo := &models.WarehouseOutInfo{
-			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
-			WarehouseOutId:          warehouseOut.ID,
+			WarehouseOutOrderNumber: out.WarehouseOutOrderNumber,
+			WarehouseOutId:          out.ID,
 			GoodId:                  item.GoodId,
 			Count:                   item.Count,
 			Price:                   item.PackingPrice,
 			ProductDate:             item.ProductDate,
 			Dealer:                  dealer_id,
 			LicenseNumber:           item.LicenseNumber,
+			GoodTypeId:              goodinfo.GoodTypeId,
 		}
 		errOne := service.AddSigleWarehouseOutInfo(warehouseOutInfo)
 		fmt.Println("99999999999999", errOne)
 			ConsumableType:          5,
 			IsSys:                   0,
 			WarehousingOrder:        "",
-			WarehouseOutId:          warehouseOutInfo.ID,
+			WarehouseOutId:          out.ID,
 			WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
 			IsEdit:                  0,
 			CancelStockId:           0,
 
 		//查询该耗材最后1条批次
 		info, _ := service.GetLastWarehouseInfo(item.GoodId)
+		good, _ := service.GetGoodInformationByGoodId(item.GoodId)
 		fmt.Println("总共", item.Count)
 		fmt.Println("数据", list.StockCount)
 		//盘点盘点库存和et实际库存的大小
 				StockCount:       item.Count - list.StockCount,
 				Dealer:           dealer_id,
 				LicenseNumber:    info.LicenseNumber,
+				WarehouseInfoId:  item.WarehousingInfoId,
+				GoodTypeId:       good.GoodTypeId,
 			}
 
 			flow := models.VmStockFlow{
 			}
 			err = service.CreateWarehouseOut(warehouseOut)
 			fmt.Println(err)
+			out, _ := service.GetLastGoodWarehouseOut(adminUserInfo.CurrentOrgId)
 			warehouseOutInfo := &models.WarehouseOutInfo{
-				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
-				WarehouseOutId:          warehouseOut.ID,
+				WarehouseOutOrderNumber: out.WarehouseOutOrderNumber,
+				WarehouseOutId:          out.ID,
 				GoodId:                  warehouseInfo.GoodId,
 				Count:                   list.StockCount - item.Count,
 				Price:                   warehouseInfo.Price,
 				ProductDate:             warehouseInfo.ProductDate,
 				Dealer:                  dealer_id,
 				LicenseNumber:           warehouseInfo.LicenseNumber,
+				GoodTypeId:              good.GoodTypeId,
 			}
 
 			stockFlow := models.VmStockFlow{
 				ConsumableType:          2,
 				IsSys:                   2,
 				WarehousingOrder:        "",
-				WarehouseOutId:          warehouseOut.ID,
+				WarehouseOutId:          out.ID,
 				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 				IsEdit:                  1,
 				CancelStockId:           0,
 				Mtime:                   0,
 				Price:                   warehouseInfo.Price,
 				WarehousingDetailId:     0,
-				WarehouseOutDetailId:    warehouseOutInfo.ID,
+				WarehouseOutDetailId:    out.ID,
 				CancelOutDetailId:       0,
 				ProductDate:             warehouseInfo.ProductDate,
 				ExpireDate:              warehouseInfo.ExpiryDate,

models/dialysis.go

 	ChangeNurse            int64         `gorm:"column:change_nurse" json:"change_nurse" form:"change_nurse"`
 	DifficultPunctureNurse int64         `gorm:"column:difficult_puncture_nurse" json:"difficult_puncture_nurse" form:"difficult_puncture_nurse"`
 	NewFistulaNurse        int64         `gorm:"column:new_fistula_nurse" json:"new_fistula_nurse" form:"new_fistula_nurse"`
+	ZoneId                 int64         `gorm:"column:zone_id" json:"zone_id" form:"zone_id"`
 }
 
 func (DialysisOrder) TableName() string {

models/self_drug_models.go

 	MinNumber        int64   `json:"min_number"`
 	Dose             float64 `json:"dose"`
 	DoseUnit         string  `json:"dose_unit"`
+	Unit             string  `json:"unit"`
 }
 
 type BloodDrugSalesReturnInfo struct {
 	ProofCount        int64   `gorm:"column:proof_count" json:"proof_count" form:"proof_count"`
 	StockMaxNumber    int64   `gorm:"column:stock_max_number" json:"stock_max_number" form:"stock_max_number"`
 	StockMinNumber    int64   `gorm:"column:stock_min_number" json:"stock_min_number" form:"stock_min_number"`
+	MinCount          int64   `gorm:"column:min_count" json:"min_count" form:"min_count"`
+	MinUnit           string  `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
 }
 
 func (XtDrugInventory) TableName() string {
 	DoseUnit          string  `gorm:"column:dose_unit" json:"dose_unit" form:"dose_unit"`
 	MaxUnit           string  `gorm:"column:max_unit" json:"max_unit" form:"max_unit"`
 	MinUnit           string  `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
+	MinCount          int64   `gorm:"column:min_count" json:"min_count" form:"min_count"`
 	Total             string  `gorm:"column:total" json:"total" form:"total"`
+	ExpiryDate        int64   `gorm:"column:expiry_date" json:"expiry_date" form:"expiry_date"`
+	ProductDate       int64   `gorm:"column:product_date" json:"product_date" form:"product_date"`
 	DrugOriginPlace   string  `gorm:"column:drug_origin_place" json:"drug_origin_place" form:"drug_origin_place"`
 }
+
+type SgjDrugWarehouseOutInfo struct {
+	ID                      int64      `gorm:"column:id" json:"id" form:"id"`
+	WarehouseOutId          int64      `gorm:"column:warehouse_out_id" json:"warehouse_out_id" form:"warehouse_out_id"`
+	DrugId                  int64      `gorm:"column:drug_id" json:"drug_id" form:"drug_id"`
+	WarehousingOutTarget    int64      `gorm:"column:warehousing_out_target" json:"warehousing_out_target" form:"warehousing_out_target"`
+	Count                   int64      `gorm:"column:count" json:"count" form:"count"`
+	CountUnit               string     `gorm:"column:count_unit" json:"count_unit" form:"count_unit"`
+	Price                   float64    `gorm:"column:price" json:"price" form:"price"`
+	TotalPrice              float64    `gorm:"column:total_price" json:"total_price" form:"total_price"`
+	ProductDate             int64      `gorm:"column:product_date" json:"product_date" form:"product_date"`
+	ExpiryDate              int64      `gorm:"column:expiry_date" json:"expiry_date" form:"expiry_date"`
+	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"`
+	Remark                  string     `gorm:"column:remark" json:"remark" form:"remark"`
+	IsCancel                int64      `gorm:"column:is_cancel" json:"is_cancel" form:"is_cancel"`
+	WarehouseOutOrderNumber string     `gorm:"column:warehouse_out_order_number" json:"warehouse_out_order_number" form:"warehouse_out_order_number"`
+	Type                    int64      `gorm:"column:type" json:"type" form:"type"`
+	Dealer                  int64      `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	Manufacturer            int64      `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
+	IsSys                   int64      `gorm:"column:is_sys" json:"is_sys" form:"is_sys"`
+	SysRecordTime           int64      `gorm:"column:sys_record_time" json:"sys_record_time" form:"sys_record_time"`
+	RetailPrice             float64    `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
+	RetailTotalPrice        float64    `gorm:"column:retail_total_price" json:"retail_total_price" form:"retail_total_price"`
+	WarehouseInfoId         int64      `gorm:"column:warehouse_info_id" json:"warehouse_info_id" form:"warehouse_info_id"`
+	Number                  string     `gorm:"column:number" json:"number" form:"number"`
+	BatchNumber             string     `gorm:"column:batch_number" json:"batch_number" form:"batch_number"`
+	PatientId               int64      `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	XtBaseDrug              XtBaseDrug `gorm:"ForeignKey:ID;AssociationForeignKey:DrugId" `
+}
+
+func (SgjDrugWarehouseOutInfo) TableName() string {
+	return "xt_drug_warehouse_out_info"
+}

models/stock_models.go

 	GoodInfo         GoodInfo    `gorm:"ForeignKey:ID;AssociationForeignKey:GoodId" `
 	Type             int64       `gorm:"column:type" json:"type"`
 	LicenseNumber    string      `gorm:"column:license_number" json:"license_number" form:"license_number"`
+	WarehouseInfoId  int64       `gorm:"column:warehouse_info_id" json:"warehouse_info_id" form:"warehouse_info_id"`
 }
 
 func (WarehousingInfo) TableName() string {
 func (XtStockCorrectRecord) TableName() string {
 	return "xt_stock_correct_record"
 }
+
+type SgjWarehouseOutInfo struct {
+	ID                      int64   `gorm:"column:id" json:"id" form:"id"`
+	WarehouseOutId          int64   `gorm:"column:warehouse_out_id" json:"warehouse_out_id" form:"warehouse_out_id"`
+	WarehouseInfoId         int64   `gorm:"column:warehouse_info_id" json:"warehouse_info_id" form:"warehouse_info_id"`
+	GoodId                  int64   `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	GoodTypeId              int64   `gorm:"column:good_type_id" json:"good_type_id" form:"good_type_id"`
+	WarehousingOutTarget    int64   `gorm:"column:warehousing_out_target" json:"warehousing_out_target" form:"warehousing_out_target"`
+	Count                   int64   `gorm:"column:count" json:"count" form:"count"`
+	Price                   float64 `gorm:"column:price" json:"price" form:"price"`
+	TotalPrice              float64 `gorm:"column:total_price" json:"total_price" form:"total_price"`
+	ProductDate             int64   `gorm:"column:product_date" json:"product_date" form:"product_date"`
+	ExpiryDate              int64   `gorm:"column:expiry_date" json:"expiry_date" form:"expiry_date"`
+	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"`
+	Remark                  string  `gorm:"column:remark" json:"remark" form:"remark"`
+	IsCancel                int64   `gorm:"column:is_cancel" json:"is_cancel" form:"is_cancel"`
+	WarehouseOutOrderNumber string  `gorm:"column:warehouse_out_order_number" json:"warehouse_out_order_number" form:"warehouse_out_order_number"`
+	Type                    int64   `gorm:"column:type" json:"type" form:"type"`
+	Dealer                  int64   `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	Manufacturer            int64   `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
+	IsSys                   int64   `gorm:"column:is_sys" json:"is_sys" form:"is_sys"`
+	SysRecordTime           int64   `gorm:"column:sys_record_time" json:"sys_record_time" form:"sys_record_time"`
+	PatientId               int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Number                  string  `gorm:"column:number" json:"number" form:"number"`
+	LicenseNumber           string  `gorm:"column:license_number" json:"license_number" form:"license_number"`
+	ConsumableType          int64   `gorm:"column:consumable_type" json:"consumable_type" form:"consumable_type"`
+	GoodName                string  `gorm:"column:good_name" json:"good_name"`
+	SpecificationName       string  `gorm:"column:specification_name" json:"specification_name" form:"specification_name"`
+	PackingUnit             string  `gorm:"column:packing_unit" json:"packing_unit" form:"packing_unit"`
+	RetailPrice             float64 `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
+	PackingPrice            float64 `gorm:"column:packing_price" json:"packing_price" form:"packing_price"`
+}
+
+type SgjCancelStockInfo struct {
+	ID                int64   `gorm:"column:id" json:"id" form:"id"`
+	GoodId            int64   `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	CancelStockId     int64   `gorm:"column:cancel_stock_id" json:"cancel_stock_id" form:"cancel_stock_id"`
+	GoodTypeId        int64   `gorm:"column:good_type_id" json:"good_type_id" form:"good_type_id"`
+	Count             int64   `gorm:"column:count" json:"count" form:"count"`
+	Price             float64 `gorm:"column:price" json:"price" form:"price"`
+	Total             float64 `gorm:"column:total" json:"total" form:"total"`
+	ProductDate       int64   `gorm:"column:product_date" json:"product_date" form:"product_date"`
+	ExpiryDate        int64   `gorm:"column:expiry_date" json:"expiry_date" form:"expiry_date"`
+	Ctime             int64   `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime             int64   `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status            int64   `gorm:"column:status" json:"status" form:"status"`
+	OrgId             int64   `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	OrderNumber       string  `gorm:"column:order_number" json:"order_number" form:"order_number"`
+	Type              int64   `gorm:"column:type" json:"type" form:"type"`
+	Dealer            string  `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	Manufacturer      string  `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
+	Number            string  `gorm:"column:number" json:"number" form:"number"`
+	RegisterAccount   string  `gorm:"column:register_account" json:"register_account" form:"register_account"`
+	Remark            string  `gorm:"column:remark" json:"remark" form:"remark"`
+	WarehouseInfoId   int64   `gorm:"column:warehouse_info_id" json:"warehouse_info_id" form:"warehouse_info_id"`
+	GoodName          string  `gorm:"column:good_name" json:"good_name"`
+	SpecificationName string  `gorm:"column:specification_name" json:"specification_name" form:"specification_name"`
+	PackingUnit       string  `gorm:"column:packing_unit" json:"packing_unit" form:"packing_unit"`
+	RetailPrice       float64 `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
+	PackingPrice      float64 `gorm:"column:packing_price" json:"packing_price" form:"packing_price"`
+}

service/app_version.go

 func GetHisPrescriptionTemplateTwo() (prescription []*HisPrescriptionInfoTemplateTwo, err error) {
 	err = readDb.Model(&HisPrescriptionInfoTemplateTwo{}).
 		Preload("HisPrescriptionAdviceTemplate", func(db *gorm.DB) *gorm.DB {
-			return db.Where("status = 1").Preload("Drug", "status=1")
+			return db.Where("status = 1")
 		}).
 		Where("status = 1 ").
 		Find(&prescription).Error

service/drug_stock_service.go

 	err = db.Preload("XtBaseDrug", "status = 1 and org_id = ?", orgid).Find(&list).Error
 	return list, err
 }
+
+func GetDrugOutOrderInfoPrintList(startime int64, endtime int64, orgid int64) (list []*models.SgjDrugWarehouseOutInfo, err error) {
+
+	db := XTReadDB().Table("xt_drug_warehouse_out_info").Where("status = 1")
+	if startime > 0 {
+		db = db.Where("ctime >=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("ctime<=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("org_id = ?", orgid)
+	}
+	err = db.Preload("XtBaseDrug", "status = 1 and org_id = ?", orgid).Find(&list).Error
+	return list, err
+}

service/gobal_config_service.go

 	return outinfo, total, err
 }
 
+func GetDrugCancelOrderPrint(startime int64, endtime int64, orgid int64, orderType int64, manufacturerId int64, keyword string) (info []*models.BloodDrugCancelStockInfo, err error) {
+	likeKey := "%" + keyword + "%"
+	db := XTReadDB().Table("xt_drug_cancel_stock_info as x").Where("x.status =1")
+	dbOne := XTReadDB().Table("xt_base_drug as s").Where("s.status =1")
+	dbTwo := XTReadDB().Table("xt_drug_cancel_stock as t").Where("t.status = 1")
+	fmt.Print(dbOne, dbTwo)
+	if startime > 0 {
+		db = db.Where("x.ctime >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.ctime<=?", endtime)
+	}
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if orderType > 0 {
+		db = db.Where("x.type = ? ", orderType)
+	}
+	if len(keyword) > 0 {
+		db = db.Where("x.order_number like ? or s.drug_spec like ? or t.creater like ?", likeKey, likeKey, likeKey)
+	}
+
+	if manufacturerId > 0 {
+		err = db.Select("x.id,x.max_unit as unit,x.drug_id,x.cancel_stock_id,x.count,x.price,x.total,x.product_date,x.expiry_date,x.ctime,x.org_id,x.order_number,x.type,x.dealer,x.manufacturer,x.retail_price,x.retail_total_price,x.number,s.drug_name,s.drug_type,s.drug_spec,s.min_unit,t.creater,s.dose,s.dose_unit,s.min_number,s.max_unit").Joins("left join xt_base_drug as s on s.id = x.drug_id and s.org_id = ? and s.status = 1", orgid).Joins("left join xt_drug_cancel_stock as t on t.id = x.cancel_stock_id and t.org_id = ? and t.status =1", orgid).Where("t.manufacturer = ?", manufacturerId).Order("x.ctime desc").Group("x.drug_id").Scan(&info).Error
+	} else {
+		err = db.Select("x.id,x.max_unit as unit,x.drug_id,x.cancel_stock_id,x.count,x.price,x.total,x.product_date,x.expiry_date,x.ctime,x.org_id,x.order_number,x.type,x.dealer,x.manufacturer,x.retail_price,x.retail_total_price,x.number,s.drug_name,s.drug_type,s.drug_spec,s.min_unit,t.creater,s.dose,s.dose_unit,s.min_number,s.max_unit").Joins("left join xt_base_drug as s on s.id = x.drug_id and s.org_id = ? and s.status = 1", orgid).Joins("left join xt_drug_cancel_stock as t on t.id = x.cancel_stock_id and t.org_id = ? and t.status =1", orgid).Order("x.ctime desc").Group("x.drug_id").Scan(&info).Error
+	}
+
+	return info, err
+}
+
 func GetDrugCancelOrder(startime int64, endtime int64, orgid int64, orderType int64, manufacturerId int64, keyword string, page int64, limit int64) (cancel []*models.BloodDrugCancelStockInfo, total int64, err error) {
 
 	likeKey := "%" + keyword + "%"
 	}
 
 	if manufacturerId > 0 {
-		err = db.Select("x.id,x.drug_id,x.cancel_stock_id,x.count,x.price,x.total,x.product_date,x.expiry_date,x.ctime,x.org_id,x.order_number,x.type,x.dealer,x.manufacturer,x.retail_price,x.retail_total_price,x.number,s.drug_name,s.drug_type,s.drug_spec,s.min_unit,t.creater,s.dose,s.dose_unit,s.min_number,s.max_unit").Joins("left join xt_base_drug as s on s.id = x.drug_id and s.org_id = ? and s.status = 1", orgid).Joins("left join xt_drug_cancel_stock as t on t.id = x.cancel_stock_id and t.org_id = ? and t.status =1", orgid).Where("t.manufacturer = ?", manufacturerId).Order("x.ctime desc").Count(&total).Offset(offset).Limit(limit).Scan(&cancel).Error
+		err = db.Select("x.id,x.max_unit as unit,x.drug_id,x.cancel_stock_id,x.count,x.price,x.total,x.product_date,x.expiry_date,x.ctime,x.org_id,x.order_number,x.type,x.dealer,x.manufacturer,x.retail_price,x.retail_total_price,x.number,s.drug_name,s.drug_type,s.drug_spec,s.min_unit,t.creater,s.dose,s.dose_unit,s.min_number,s.max_unit").Joins("left join xt_base_drug as s on s.id = x.drug_id and s.org_id = ? and s.status = 1", orgid).Joins("left join xt_drug_cancel_stock as t on t.id = x.cancel_stock_id and t.org_id = ? and t.status =1", orgid).Where("t.manufacturer = ?", manufacturerId).Order("x.ctime desc").Count(&total).Offset(offset).Limit(limit).Scan(&cancel).Error
 	} else {
-		err = db.Select("x.id,x.drug_id,x.cancel_stock_id,x.count,x.price,x.total,x.product_date,x.expiry_date,x.ctime,x.org_id,x.order_number,x.type,x.dealer,x.manufacturer,x.retail_price,x.retail_total_price,x.number,s.drug_name,s.drug_type,s.drug_spec,s.min_unit,t.creater,s.dose,s.dose_unit,s.min_number,s.max_unit").Joins("left join xt_base_drug as s on s.id = x.drug_id and s.org_id = ? and s.status = 1", orgid).Joins("left join xt_drug_cancel_stock as t on t.id = x.cancel_stock_id and t.org_id = ? and t.status =1", orgid).Order("x.ctime desc").Count(&total).Offset(offset).Limit(limit).Scan(&cancel).Error
+		err = db.Select("x.id,x.max_unit as unit,x.drug_id,x.cancel_stock_id,x.count,x.price,x.total,x.product_date,x.expiry_date,x.ctime,x.org_id,x.order_number,x.type,x.dealer,x.manufacturer,x.retail_price,x.retail_total_price,x.number,s.drug_name,s.drug_type,s.drug_spec,s.min_unit,t.creater,s.dose,s.dose_unit,s.min_number,s.max_unit").Joins("left join xt_base_drug as s on s.id = x.drug_id and s.org_id = ? and s.status = 1", orgid).Joins("left join xt_drug_cancel_stock as t on t.id = x.cancel_stock_id and t.org_id = ? and t.status =1", orgid).Order("x.ctime desc").Count(&total).Offset(offset).Limit(limit).Scan(&cancel).Error
 	}
 
 	return cancel, total, err
 	return info, err
 }
 
-func GetDrugStockFlowDetail(id int64, orgid int64) (drugflow []*models.XtDrugAutomaticReduceDetail, err error) {
+func GetDrugStockFlowDetail(record_time int64, orgid int64) (drugflow []*models.XtDrugAutomaticReduceDetail, err error) {
 
-	err = XTReadDB().Where("record_time = ? and org_id = ? and status = 1", id, orgid).Find(&drugflow).Error
+	err = XTReadDB().Where("record_time = ? and org_id = ? and status = 1", record_time, orgid).Preload("XtBaseDrug", "status = 1").Find(&drugflow).Error
 	return drugflow, err
 }
 

service/manage_service.go

 	if orgId > 0 {
 		db = db.Where("x.user_org_id = ?", orgId)
 	}
-	err = db.Group("x.id").Select("x.id,x.date,x.class,x.zone,x.bed_number,x.patient_id,x.contagion,x.dialysis_mode,x.start_time,x.end_time,x.dialysis_hour,x.hyperfiltratio,x.weight_loss,x.warning_value,x.user_total,x.move,x.failure_stage,x.fault_description,x.code_information,x.disinfect_type,x.disinfectant_type,x.disinfection,x.machine_run,x.fluid_path,x.disinfectant,x.disinfection_status,x.disinfection_residue,x.long_time,x.disinfec_startime,x.disinfec_endtime,x.dialysis_checked,x.dialysis_name,x.norms,x.dialysis_concentration,x.germ_checked,x.germ_name,x.germ_number,x.clean,x.sign_name,x.equiment_id,x.bed,p.name,r.user_name").Count(&total).Joins("Left Join sgj_xt.xt_patients as p on p.id = x.patient_id").Joins("Left Join sgj_user_admin_role as r on r.admin_user_id = x.sign_name").Offset(offset).Limit(limit).Scan(&infor).Error
+	err = db.Group("x.id").Select("x.id,x.date,x.class,x.zone,x.bed_number,x.patient_id,x.contagion,x.dialysis_mode,x.start_time,x.end_time,x.dialysis_hour,x.hyperfiltratio,x.weight_loss,x.warning_value,x.user_total,x.move,x.failure_stage,x.fault_description,x.code_information,x.disinfect_type,x.disinfectant_type,x.disinfection,x.machine_run,x.fluid_path,x.disinfectant,x.disinfection_status,x.disinfection_residue,x.long_time,x.disinfec_startime,x.disinfec_endtime,x.dialysis_checked,x.dialysis_name,x.norms,x.dialysis_concentration,x.germ_checked,x.germ_name,x.germ_number,x.clean,x.sign_name,x.equiment_id,x.bed,p.name,r.user_name").Count(&total).Joins("Left Join sgj_xt.xt_patients as p on p.id = x.patient_id").Joins("Left Join sgj_user_admin_role as r on r.admin_user_id = x.sign_name").Offset(offset).Limit(limit).Order("x.date desc").Scan(&infor).Error
 	if err != nil {
-
 		return
 	}
 	return

service/print_data_service/schedule_dialysis/print_schedule_dialysis_service.go

 	return auto, err
 
 }
+
+func GetWarehouseOutInfoPrintList(orgid int64, startime int64, endtime int64) (out []*models.SgjWarehouseOutInfo, err error) {
+
+	db := p_service.XTReadDB().Table("xt_warehouse_out_info as x").Where("x.status = 1")
+	table := p_service.XTReadDB().Table("xt_good_information as t").Where("t.status = 1")
+	fmt.Println(table)
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.ctime >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.ctime<=?", endtime)
+	}
+	err = db.Select("x.patient_id,x.sys_record_time,x.good_id,sum(x.count) as count,t.good_name,t.specification_name,t.packing_unit,t.retail_price,t.packing_price").Joins("left join xt_good_information as t on t.id = x.good_id").Group("x.good_id").Scan(&out).Error
+	return out, err
+}
+
+func GetWarehouseCancelPrintList(orgid int64, startime int64, endtime int64) (cancel []*models.SgjCancelStockInfo, err error) {
+
+	db := p_service.XTReadDB().Table("xt_cancel_stock_info as x").Where("x.status = 1")
+	table := p_service.XTReadDB().Table("xt_good_information as t").Where("t.status = 1")
+	fmt.Println(table)
+	if orgid > 0 {
+		db = db.Where("x.org_id = ?", orgid)
+	}
+	if startime > 0 {
+		db = db.Where("x.ctime >= ?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.ctime<=?", endtime)
+	}
+	err = db.Select("x.ctime,x.good_id,sum(x.count) as count,t.good_name,t.specification_name,t.packing_unit,t.retail_price,t.packing_price").Joins("left join xt_good_information as t on t.id = x.good_id").Group("x.good_id").Scan(&cancel).Error
+	return cancel, err
+}

service/self_drug_service.go

 }
 
 func GetDrugPriceList(startime int64, endtime int64, orgId int64, keyword string, limit int64, page int64) (adjust []*models.VmDrugAdjustPrice, total int64, err error) {
-	//likeKey := "%" + keyword + "%"
-	//offset := (page - 1) * limit
-	//db := XTReadDB().Model(&adjust).Where("status = 1")
-	//if startime > 0 {
-	//	db = db.Where("ctime >=?", startime)
-	//}
-	//if endtime > 0 {
-	//	db = db.Where("ctime<=?", endtime)
-	//}
-	//if orgId > 0 {
-	//	db = db.Where("user_org_id = ?", orgId)
-	//}
-	//if len(keyword) > 0 {
-	//	db = db.Where("warehousing_order like ?", likeKey)
-	//}
-	//err = db.Count(&total).Offset(offset).Limit(limit).Find(&adjust).Error
-	//return adjust, total, err
+
 	likeKey := "%" + keyword + "%"
 	offset := (page - 1) * limit
 	db := XTReadDB().Table("xt_drug_adjust_price as x").Where("x.status = 1")
 	if orgId > 0 {
 		db = db.Where("x.user_org_id = ?", orgId)
 	}
+	if startime > 0 {
+		db = db.Where("x.ctime>=?", startime)
+	}
+	if endtime > 0 {
+		db = db.Where("x.ctime<=?", endtime)
+	}
 	err = db.Group("x.id").Select("x.id,x.drug_name,x.specification_name,x.warehousing_unit,x.count,x.last_price,x.retail_price,x.new_price,x.manufacturer,x.dealer,x.remark,x.drug_id,x.warehousing_order,x.start_time,x.creater,x.checker,x.checker_status,x.checker_time,x.number").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.creater").Joins("left join xt_base_drug as t on t.id =x.drug_id").Count(&total).Offset(offset).Limit(limit).Scan(&adjust).Error
 	return adjust, total, err
 
 	if endtime > 0 {
 		db = db.Where("x.start_time<=?", endtime)
 	}
-	err = db.Select("x.id,x.drug_name,x.specification_name,x.warehousing_unit,x.count,x.last_price,x.retail_price,x.manufacturer,x.dealer,x.remark,x.drug_id,x.warehousing_order,x.number,x.batch_number,x.start_time,x.creater,x.checker,x.checker_status,x.checker_time,t.dose,t.dose_unit,t.max_unit,t.min_unit").Joins("left join sgj_users.sgj_user_admin_role as r on r.id = x.creater").Joins("left join xt_base_drug as t on t.id =x.drug_id").Count(&total).Offset(offset).Limit(limit).Scan(&list).Error
+	err = db.Select("x.id,x.drug_name,x.specification_name,x.warehousing_unit,x.count,x.last_price,x.retail_price,x.manufacturer,x.dealer,x.remark,x.drug_id,x.warehousing_order,x.number,x.batch_number,x.start_time,x.creater,x.checker,x.checker_status,x.checker_time,x.min_count,x.min_unit,t.dose,t.dose_unit,t.max_unit,t.min_unit").Joins("left join sgj_users.sgj_user_admin_role as r on r.id = x.creater").Joins("left join xt_base_drug as t on t.id =x.drug_id").Count(&total).Offset(offset).Limit(limit).Scan(&list).Error
 	return list, total, err
 }
 
 
 func ModifyDrugInventory(id int64, info models.XtDrugInventory) error {
 
-	err := XTWriteDB().Model(&info).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": info.DrugName, "specification_name": info.SpecificationName, "warehousing_unit": info.WarehousingUnit, "count": info.Count, "last_price": info.LastPrice, "manufacturer": info.Manufacturer, "remark": info.Remark, "drug_id": info.DrugId, "warehousing_order": info.WarehousingOrder, "number": info.Number, "total": info.Number, "drug_origin_place": info.DrugOriginPlace, "stock_max_number": info.StockMaxNumber, "stock_min_number": info.StockMinNumber, "warehouse_info_id": info.WarehouseInfoId}).Error
+	err := XTWriteDB().Model(&info).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": info.DrugName, "specification_name": info.SpecificationName, "warehousing_unit": info.WarehousingUnit, "count": info.Count, "last_price": info.LastPrice, "manufacturer": info.Manufacturer, "remark": info.Remark, "drug_id": info.DrugId, "warehousing_order": info.WarehousingOrder, "number": info.Number, "total": info.Number, "drug_origin_place": info.DrugOriginPlace, "stock_max_number": info.StockMaxNumber, "stock_min_number": info.StockMinNumber, "warehouse_info_id": info.WarehouseInfoId, "min_count": info.MinCount, "min_unit": info.MinUnit}).Error
 	return err
 }
 
 	if orgid > 0 {
 		db = db.Where("x.user_org_id = ?", orgid)
 	}
-	err = db.Select("x.id,x.drug_name,x.specification_name,x.warehousing_unit,x.count,x.last_price,x.retail_price,x.manufacturer,x.dealer,x.remark,x.drug_id,x.warehousing_order,x.number,x.batch_number,x.start_time,x.creater,x.checker,x.checker_status,x.checker_time,x.total,x.drug_origin_place,t.dose,t.dose_unit,t.max_unit,t.min_unit").Joins("left join sgj_users.sgj_user_admin_role as r on r.id = x.creater").Joins("left join xt_base_drug as t on t.id =x.drug_id").Count(&total).Offset(offset).Limit(limit).Scan(&list).Error
+	err = db.Select("x.id,x.drug_name,x.specification_name,x.warehousing_unit,x.count,x.last_price,x.retail_price,x.manufacturer,x.dealer,x.remark,x.drug_id,x.warehousing_order,x.number,x.batch_number,x.start_time,x.creater,x.checker,x.checker_status,x.checker_time,x.total,x.drug_origin_place,x.expiry_date,x.product_date,x.min_count,t.dose,t.dose_unit,t.max_unit,x.min_unit").Joins("left join sgj_users.sgj_user_admin_role as r on r.id = x.creater").Joins("left join xt_base_drug as t on t.id =x.drug_id").Count(&total).Offset(offset).Limit(limit).Scan(&list).Error
 	return list, total, err
 }
 

service/statistics_service/index_evaluation_service.go

 	var NewTotalSix int64
 	var NewTotalSeven int64
 	var NewTotalEight int64
+	var NewTotalNight int64
+	var NewTotalTen int64
 
 	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalOne)
 	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalFive)
 	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalSix)
 	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalSeven)
 	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalEight)
+	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalNight)
+	db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalTen)
 	db.Table("xt_monitoring_record as monitor ").Joins("join xt_schedule sch On sch.schedule_date = monitor.monitoring_date AND sch.patient_id = monitor.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("monitor.user_org_id = ? AND monitor.status = 1  AND monitor.monitoring_date >= ? AND monitor.monitoring_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalThree)
 	db.Table("xt_treatment_summary as summary").Joins("join xt_schedule sch On sch.schedule_date = summary.assessment_date AND sch.patient_id = summary.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("summary.user_org_id = ? AND summary.status = 1  AND summary.assessment_date >= ? AND summary.assessment_date <= ?", user_org_id, start_time, end_time).Count(&NewTotalFour)
 
 
 		}
 		break
+	case 8:
+		for _, item := range datas {
+			var Total int64
+			db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ? AND o.finish_nurse = ?", user_org_id, start_time, end_time, item.AdminUserId).Count(&Total)
+			item.FinshNurserCount = Total
+			if math.IsNaN(float64(item.FinshNurserCount) / float64(NewTotalNight)) {
+				item.FinshNurseRatio = "0.0"
+			} else {
+				float_value, _ := strconv.ParseFloat(fmt.Sprintf("%.1f", (float64(item.FinshNurserCount)/float64(NewTotalNight))*100), 64)
+				item.FinshNurseRatio = strconv.FormatFloat(float_value, 'f', 1, 32)
+			}
+
+		}
+		break
+	case 9:
+		for _, item := range datas {
+			var Total int64
+			db.Table("xt_dialysis_order as o").Joins("join xt_schedule sch On sch.schedule_date = o.dialysis_date AND sch.patient_id = o.patient_id AND sch.user_org_id = ? AND sch.status = 1", user_org_id).Where("o.user_org_id = ? AND o.status = 1  AND o.dialysis_date >= ? AND o.dialysis_date <= ? AND o.washpipe_nurse = ?", user_org_id, start_time, end_time, item.AdminUserId).Count(&Total)
+			item.WashpipeNurserCount = Total
+			if math.IsNaN(float64(item.WashpipeNurserCount) / float64(NewTotalTen)) {
+				item.WashpipeNurseRatio = "0.0"
+			} else {
+				float_value, _ := strconv.ParseFloat(fmt.Sprintf("%.1f", (float64(item.WashpipeNurserCount)/float64(NewTotalTen))*100), 64)
+				item.WashpipeNurseRatio = strconv.FormatFloat(float_value, 'f', 1, 32)
+			}
+
+		}
+		break
 
 	}
 

service/stock_service.go

 	return info, err
 }
 
+func GetLastWarehouseOut(orgid int64) (models.DrugWarehouseOut, error) {
+
+	out := models.DrugWarehouseOut{}
+	err := XTReadDB().Where("org_id = ? and status = 1", orgid).Last(&out).Error
+	return out, err
+}
+
 func CreateDrugFlow(drugflow []*models.DrugFlow) (err error) {
 	if len(drugflow) > 0 {
 		utx := writeDb.Begin()
 			insertParams := make([]string, 0)
 			insertData := make([]interface{}, 0)
 			for _, info := range drugflow {
+				fmt.Println("hhhhhh", info.WarehouseOutId)
 				insertParams = append(insertParams, "(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)")
 				insertData = append(insertData, info.WarehousingId)
 				insertData = append(insertData, info.DrugId)
 
 }
 
+func GetCancelStockDetailByOrderNumber(ordernumber string, orgid int64) (*models.CancelStock, error) {
+
+	stock := models.CancelStock{}
+	err := XTReadDB().Where("order_number = ? and org_id = ? and status = 1", ordernumber, orgid).Find(&stock).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &stock, nil
+}
+
 func AddSigleCancelStock(cancelStock *models.CancelStock) error {
 	err := writeDb.Create(&cancelStock).Error
 	return err
 
 }
 
+func GetLastCancelStockById(orgid int64) (models.CancelStock, error) {
+	stock := models.CancelStock{}
+	err := XTReadDB().Where("org_id = ? and status = 1", orgid).Last(&stock).Error
+	return stock, err
+}
+
 func AddSigleDrugCancelStock(cancelStock *models.DrugCancelStock) error {
 	err := writeDb.Create(&cancelStock).Error
 	return err
 	return
 }
 
+func FindeCancelGroup(orgId int64, startTime int64, endTime int64, keywords string, manufacturer int64, order_type int64, dealer int64) (list []*models.CancelStockInfo, err error) {
+	db := readDb.Model(&models.CancelStockInfo{})
+	db = db.Where("xt_cancel_stock_info.org_id = ? AND xt_cancel_stock_info.status = 1", orgId)
+	if len(keywords) > 0 {
+		likeKey := "%" + keywords + "%"
+		db = db.Joins("join xt_cancel_stock on xt_cancel_stock.id = xt_cancel_stock_info.cancel_stock_id AND xt_cancel_stock.return_time >=? AND xt_cancel_stock.return_time<= ? AND xt_cancel_stock.status = 1 AND xt_cancel_stock.org_id = ?", startTime, endTime, orgId)
+		db = db.Joins("join sgj_users.sgj_user_admin_role on sgj_user_admin_role.admin_user_id = xt_cancel_stock.creater")
+		db = db.Joins("join xt_good_information on xt_good_information.id = xt_cancel_stock_info.good_id")
+
+		db = db.Where("sgj_user_admin_role.user_name LIKE ? OR xt_cancel_stock_info.order_number LIKE ? OR xt_good_information.specification_name LIKE ?", likeKey, likeKey, likeKey).Group("xt_cancel_stock_info.id")
+	} else {
+		db = db.Joins("join xt_cancel_stock on xt_cancel_stock.id = xt_cancel_stock_info.cancel_stock_id AND xt_cancel_stock.return_time >=? AND xt_cancel_stock.return_time<= ? ", startTime, endTime)
+	}
+
+	if manufacturer > 0 {
+		db = db.Joins("join xt_cancel_stock as cs on cs.id = xt_cancel_stock_info.cancel_stock_id AND cs.manufacturer =?", manufacturer)
+	}
+
+	if order_type > 0 {
+		db = db.Where("xt_cancel_stock_info.type = ?", order_type)
+	}
+
+	db = db.Preload("CancelStock", "status = 1 AND org_id = ?", orgId)
+	db = db.Preload("GoodInfo", "status = 1 AND org_id = ?", orgId)
+
+	err = db.Group("xt_cancel_stock_info.good_id").Order("xt_cancel_stock_info.ctime desc").Find(&list).Error
+	return
+}
+
 func FindCancelDetailList(orgId int64, page int64, limit int64, startTime int64, endTime int64, keywords string, manufacturer int64, order_type int64, dealer int64) (list []*models.CancelStockInfo, total int64, err error) {
 	db := readDb.Model(&models.CancelStockInfo{})
 	db = db.Where("xt_cancel_stock_info.org_id = ? AND xt_cancel_stock_info.status = 1", orgId)
 	return &info, nil
 }
 
-func GetWarehoureOrderInfoCount(goodid int64, orgid int64) (info models.WarehouseOutInfo, err error) {
+func GetWarehoureOrderInfoCount(goodid int64, orgid int64, id int64) (info models.WarehouseOutInfo, err error) {
 
 	db := XTReadDB().Table("xt_warehouse_out_info as x").Where("x.status =1")
 	if goodid > 0 {
 	if orgid > 0 {
 		db = db.Where("x.org_id = ?", orgid)
 	}
+	if id > 0 {
+		db = db.Where("x.warehouse_info_id = ?", id)
+	}
 	err = db.Select("x.good_id,sum(x.count) as count").Scan(&info).Error
 	return info, err
 }
 	return out, err
 }
 
+func GetExportOutOrderDrugListOne(warehouse_out_id []string) (out []*models.StDrugWarehouseOutInfo, err error) {
+	db := XTReadDB().Table("xt_drug_flow as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_base_drug as b").Where("b.status = 1")
+	fmt.Println("table", table)
+	if len(warehouse_out_id) > 0 {
+		db = db.Where("x.warehouse_out_id in(?)", warehouse_out_id)
+	}
+	err = db.Select("x.id,x.warehouse_out_id,x.drug_id,x.count,x.max_unit as count_unit,x.price,x.product_date,x.expire_date as expire_date,x.warehouse_out_order_number,x.dealer,x.manufacturer,x.is_sys,x.number,x.batch_number,x.patient_id,b.dose,b.dose_unit,b.min_number,b.min_unit,b.max_unit,b.drug_name,b.drug_type,b.min_price").Joins("left join xt_base_drug as b on b.id = x.drug_id").Scan(&out).Error
+	return out, err
+}
+
 func GetLastGoodInformationByGoodId(goodid int64, warehouse_info_id int64, orgid int64) (models.WarehouseOutInfo, error) {
 
 	info := models.WarehouseOutInfo{}
 		db = db.Where("good_id = ?", good_id)
 	}
 
-	err = db.Count(&total).Offset(offset).Limit(limit).Find(&flow).Error
+	err = db.Count(&total).Offset(offset).Limit(limit).Order("ctime desc").Find(&flow).Error
 
 	return flow, total, err
 }
 	return err
 }
 
+func GetLastGoodWarehouseOut(orgid int64) (models.WarehouseOut, error) {
+	out := models.WarehouseOut{}
+	err := XTReadDB().Where("org_id = ? and status = 1", orgid).Find(&out).Error
+	return out, err
+}
+
 func CreateWarehouseInfo(info models.WarehousingInfo) error {
 
 	err := XTReadDB().Create(&info).Error
 	tab := UserReadDB().Table("sgj_user_admin_role as r").Where("r.status = 1")
 	fmt.Println(table, tab)
 	if startime > 0 {
-		db = db.Where("x.start_time>=?", startime)
+		db = db.Where("x.ctime>=?", startime)
 	}
 	if endtime > 0 {
-		db = db.Where("x.end_time<=?", endtime)
+		db = db.Where("x.ctime<=?", endtime)
 	}
 	if len(keyword) > 0 {
 		db = db.Where("x.warehousing_order like ? or r.user_name like ?", likeKey, likeKey)
 func GetWarehouseInfoById(id int64) (models.WarehousingInfo, error) {
 
 	info := models.WarehousingInfo{}
-	err := XTReadDB().Model(&info).Where("id = ? and status = 1", id).Find(&info).Error
+	//err := XTReadDB().Model(&info).Where("id = ? or warehouse_info_id and status = 1", id).Find(&info).Error
+	//return info, err
+
+	db := XTReadDB().Table("xt_warehouse_info as x").Where("x.status = 1")
+	if id > 0 {
+		db = db.Where("x.id = ? or x.warehouse_info_id = ?", id, id)
+	}
+	err := db.Select("sum(x.warehousing_count) as warehousing_count,sum(x.stock_count) as stock_count").Scan(&info).Error
 	return info, err
 }
 
 
 func GetWarehouseTotal(id int64) (models.WarehousingInfo, error) {
 	info := models.WarehousingInfo{}
-	err := XTReadDB().Where("id=? and status = 1", id).Find(&info).Error
+	//err := XTReadDB().Where("id=? and status = 1", id).Find(&info).Error
+	//return info, err
+
+	db := XTReadDB().Table("xt_warehouse_info as x").Where("x.status = 1")
+	if id > 0 {
+		db = db.Where("x.id = ? or x.warehouse_info_id = ?", id, id)
+	}
+	err := db.Select("sum(x.stock_count) as stock_count").Scan(&info).Error
 	return info, err
 }

service/warhouse_service.go

 
 	fmt.Println("单位1", advice.PrescribingNumber)
 	fmt.Println("单位2", drup.MaxUnit)
+	var drug_price float64
 	if advice.PrescribingNumberUnit == drup.MaxUnit {
 		deliver_number = count * drup.MinNumber
+
 	} else {
 		deliver_number = count
+
+	}
+
+	if advice.PrescribingNumberUnit == drup.MaxUnit {
+		drug_price = drup.RetailPrice
+	}
+
+	if advice.PrescribingNumberUnit == drup.MinUnit {
+		drug_price = drup.MinPrice
+	}
+
+	if advice.PrescribingNumberUnit != drup.MaxUnit || advice.PrescribingNumberUnit != drup.MinUnit {
+		drug_price = drup.RetailPrice
 	}
 
+	fmt.Println("hhhh233232322333232323332323323232323232323223", drug_price)
 	// 根据先进先出原则，查询最先入库的批次，进行出库
 	// 如果没有对应的库存，则报错
 	//开启事物
 	fmt.Println("deliver_number88888888888", deliver_number)
 
 	//查找药品信息
-	baseInfo, _ := FindBaseDrugLibRecord(advice.UserOrgId, advice.DrugId)
+	//baseInfo, _ := FindBaseDrugLibRecord(advice.UserOrgId, advice.DrugId)
 
 	// 当库存数量大于或等于出库数量的话，则正常出库该批次
 	if stock_number >= deliver_number {
 			DrugId:                  advice.DrugId,
 			Number:                  warehouse.Number,
 			BatchNumber:             warehouse.BatchNumber,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   drug_price,
 			CountUnit:               advice.PrescribingNumberUnit,
-			RetailPrice:             baseInfo.RetailPrice,
+			RetailPrice:             drug_price,
 			ProductDate:             warehouse.ProductDate,
 			ExpiryDate:              warehouse.ExpiryDate,
 			PatientId:               advice.PatientId,
 			ProductDate:             warehouse.ProductDate,
 			ExpireDate:              warehouse.ExpiryDate,
 			Count:                   count,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   drug_price,
 			Status:                  1,
 			Ctime:                   time.Now().Unix(),
 			UserOrgId:               orgID,
 			DrugId:                  advice.DrugId,
 			Number:                  warehouse.Number,
 			BatchNumber:             warehouse.BatchNumber,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   drug_price,
 			CountUnit:               advice.PrescribingNumberUnit,
 			ProductDate:             warehouse.ProductDate,
 			ExpiryDate:              warehouse.ExpiryDate,
 			ProductDate:             warehouse.ProductDate,
 			ExpireDate:              warehouse.ExpiryDate,
 			Count:                   stock_number,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   drug_price,
 			Status:                  1,
 			Ctime:                   time.Now().Unix(),
 			UserOrgId:               orgID,
 		deliver_number = count
 	}
 
+	var min_price float64
+
+	if advice.PrescribingNumberUnit == drup.MaxUnit {
+		min_price = drup.RetailPrice
+	}
+	if advice.PrescribingNumberUnit == drup.MinUnit {
+		min_price = drup.MinPrice
+	}
+
+	if advice.PrescribingNumberUnit != drup.MaxUnit && advice.PrescribingNumberUnit != drup.MinUnit {
+		min_price = drup.RetailPrice
+	}
+
 	// 根据先进先出原则，查询最先入库的批次，进行出库
 	// 如果没有对应的库存，则报错
 	//开启事物
 			DrugId:                  advice.DrugId,
 			Number:                  warehouse.Number,
 			BatchNumber:             warehouse.BatchNumber,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   min_price,
 			CountUnit:               baseInfo.MaxUnit,
-			RetailPrice:             baseInfo.RetailPrice,
+			RetailPrice:             min_price,
 			ProductDate:             warehouse.ProductDate,
 			ExpiryDate:              warehouse.ExpiryDate,
 			PatientId:               advice.PatientId,
 			ProductDate:             warehouse.ProductDate,
 			ExpireDate:              warehouse.ExpiryDate,
 			Count:                   count,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   min_price,
 			Status:                  1,
 			Ctime:                   time.Now().Unix(),
 			UserOrgId:               orgID,
 			DrugId:                  advice.DrugId,
 			Number:                  warehouse.Number,
 			BatchNumber:             warehouse.BatchNumber,
-			Price:                   baseInfo.RetailPrice,
-			RetailPrice:             baseInfo.RetailPrice,
+			Price:                   min_price,
+			RetailPrice:             min_price,
 			ProductDate:             warehouse.ProductDate,
 			ExpiryDate:              warehouse.ExpiryDate,
 			PatientId:               advice.PatientId,
 			ProductDate:             warehouse.ProductDate,
 			ExpireDate:              warehouse.ExpiryDate,
 			Count:                   stock_number,
-			Price:                   baseInfo.RetailPrice,
+			Price:                   min_price,
 			Status:                  1,
 			Ctime:                   time.Now().Unix(),
 			UserOrgId:               orgID,