XT_New/service/new_stock_medical_insurance...

package service

import "XT_New/models"

func FindAllDrugWarehousingInfo(org_id int64, is_pc int64, is_bg int64, start_time int64, end_time int64) (list []*models.DrugWarehouseInfoTenOne, err error) {
	db := readDb.Model(&models.DrugWarehouseInfoTenOne{}).Preload("BaseDrugLib", "org_id = ?", org_id)
	if is_pc != 0 {
		db = db.Where("is_pc = ?", is_pc)
	}
	if is_bg != 0 {
		db = db.Where("is_bg = ?", is_bg)
	}
	if start_time != 0 {
		db = db.Where("ctime >= ?", start_time)

	}
	if end_time != 0 {
		db = db.Where("ctime <= ?", end_time)

	}

	err = db.Where("status = 1 and org_id = ?", org_id).Find(&list).Error
	return list, err
}

func GetNewDrugFlow(orgid int64, limit int64, page int64, startTime int64, endTime int64) (drug_flow []*models.NewDrugFlow, total int64, err error) {

	offset := (page - 1) * limit
	db := XTReadDB().Model(drug_flow).Where("status = 1")
	if orgid > 0 {
		db = db.Where("user_org_id = ?", orgid)
	}
	if startTime > 0 {
		db = db.Where("ctime >=? ", startTime)
	}
	if endTime > 0 {
		db = db.Where("ctime<=?", endTime)
	}
	//if stock_type > 0 {

	//手动入库
	//if stock_type == 1 {
	db = db.Where("consumable_type <> 1")
	//}

	//}
	err = db.Count(&total).Offset(offset).Limit(limit).Order("id desc").Preload("BaseDrugLib", "status = 1").Preload("DrugWarehouseInfo", "status = 1").Preload("XtDrugWarehouseOutInfo", "status = 1").Find(&drug_flow).Error

	return drug_flow, total, err
}