add grpc repo

This commit is contained in:
Mohammad Amin 2026-04-07 17:19:14 +03:30
parent 564b021a7c
commit 01909b366a
3 changed files with 45 additions and 19 deletions

View File

@ -8,9 +8,10 @@ import (
func NewPatientAnalyticRouter(s *echo.Group) { func NewPatientAnalyticRouter(s *echo.Group) {
repo := mysql.NewPatientRepo() mysqlRepo := mysql.NewPatientRepo()
//rpcRepo := grpc.NewPatientRepo()
analyticService := analytic2.NewPatientAnalyticService(repo) analyticService := analytic2.NewPatientAnalyticService(mysqlRepo)
h := NewHandler(analyticService) h := NewHandler(analyticService)

View File

@ -0,0 +1,35 @@
package grpc
import (
"context"
"git.gocasts.ir/ebhomengo/niki/patientapp/service/analytic"
"git.gocasts.ir/ebhomengo/niki/patientapp/service/entity"
)
type AnalyticRepository struct{}
func NewPatientRepo() *AnalyticRepository {
return &AnalyticRepository{}
}
func (db *AnalyticRepository) GetPatients(ctx context.Context, f analytic.PatientFilter) ([]entity.Patient, error) {
return nil, nil
}
func (db *AnalyticRepository) CountPatients(ctx context.Context, f analytic.PatientFilter) (int, error) {
return 0, nil
}
func (db *AnalyticRepository) SummaryByCity(ctx context.Context, provinceID uint, f analytic.PatientMapFilter) (map[uint][]entity.MapSummaryItem, error) {
return nil, nil
}
func (db *AnalyticRepository) SummaryByProvince(ctx context.Context, f analytic.PatientMapFilter) (map[uint][]entity.MapSummaryItem, error) {
return nil, nil
}

View File

@ -7,40 +7,30 @@ import (
"git.gocasts.ir/ebhomengo/niki/patientapp/service/entity" "git.gocasts.ir/ebhomengo/niki/patientapp/service/entity"
) )
type DataBase struct { type DataBase struct{}
//conn *mysql.DB
patients []entity.Patient
}
func NewPatientRepo( /*conn *mysql.DB*/ ) *DataBase { func NewPatientRepo() *DataBase {
patients := make([]entity.Patient, 0)
return &DataBase{ return &DataBase{}
//conn: conn,
patients: patients,
}
} }
func (db *DataBase) GetPatients(ctx context.Context, f analytic.PatientFilter) ([]entity.Patient, error) { func (db *DataBase) GetPatients(ctx context.Context, f analytic.PatientFilter) ([]entity.Patient, error) {
return db.patients, nil return nil, nil
} }
func (db *DataBase) CountPatients(ctx context.Context, f analytic.PatientFilter) (int, error) { func (db *DataBase) CountPatients(ctx context.Context, f analytic.PatientFilter) (int, error) {
return len(db.patients), nil return 0, nil
} }
func (db *DataBase) SummaryByCity(ctx context.Context, provinceID uint, f analytic.PatientMapFilter) (map[uint][]entity.MapSummaryItem, error) { func (db *DataBase) SummaryByCity(ctx context.Context, provinceID uint, f analytic.PatientMapFilter) (map[uint][]entity.MapSummaryItem, error) {
var out map[uint][]entity.MapSummaryItem return nil, nil
return out, nil
} }
func (db *DataBase) SummaryByProvince(ctx context.Context, f analytic.PatientMapFilter) (map[uint][]entity.MapSummaryItem, error) { func (db *DataBase) SummaryByProvince(ctx context.Context, f analytic.PatientMapFilter) (map[uint][]entity.MapSummaryItem, error) {
result := make(map[uint][]entity.MapSummaryItem, 0)
return result, nil return nil, nil
} }