diff --git a/docs/database/patbond_postgresql.sql b/docs/database/patbond_postgresql.sql new file mode 100644 index 0000000..8f0c49b --- /dev/null +++ b/docs/database/patbond_postgresql.sql @@ -0,0 +1,1950 @@ +/* + Patbond PostgreSQL bootstrap schema + Version: 1.0 + Target: PostgreSQL 16+ + + Execute on an empty database: + psql -v ON_ERROR_STOP=1 -d patbond -f docs/database/patbond_postgresql.sql + + Design source: the current Flutter home, creation, pet-health, marketplace, + post-detail and profile pages. This is a one-time bootstrap file, not a + repeatable migration. After backend development starts, split it into owned + Flyway migrations and never edit an already released migration. + + This file is the reviewed target schema. Backend delivery should still be + phased: identity/media -> pet health -> community -> creation -> marketplace. + A table appearing here does not require generating every repository in V1. + + Logical ownership: + identity account, credentials, refresh sessions, profile preferences + media object-storage metadata; binary content is never stored here + pet_health pets, weights, vaccinations, reminders, health timeline + community posts, media, flat comments, likes, bookmarks, follows, topics + creation asynchronous AI generation jobs and configurable catalog + marketplace providers, offerings, reservable resources and bookings + platform regions, notifications and transactional outbox + + Important projections which are intentionally NOT stored as source facts: + - "2小时前/刚刚": format timestamptz in the API/client. + - provider distance: calculate from coordinates; never store "1.2km". + - weather and pet advice: external weather API + Redis TTL cache. + - vaccine progress/next dose: aggregate vaccination fact rows. + - profile post/follower/like counts: aggregate relation tables/read model. + - age and monthly spend: derive from birth_date and completed expenses. + + JSONB is restricted to variable AI parameters and outbox event payloads. + Core account, pet, community and booking facts remain relational. + + UUID note: gen_random_uuid() is a safe database fallback. At production write + volume, applications should generate time-ordered UUIDv7 values to reduce + B-tree page churn while retaining globally unique public IDs. + + Nearby search note: this portable bootstrap uses region + latitude/longitude + bounding-box indexes and a Haversine function. If nearby search becomes a core + large-scale workload (roughly >1,000 providers per region or radius paging), + migrate the coordinates to PostGIS geography(Point,4326) with a GiST index. +*/ + +BEGIN; + +CREATE EXTENSION IF NOT EXISTS pgcrypto; +CREATE EXTENSION IF NOT EXISTS citext; +CREATE EXTENSION IF NOT EXISTS pg_trgm; +CREATE EXTENSION IF NOT EXISTS btree_gist; + +CREATE SCHEMA platform; +CREATE SCHEMA identity; +CREATE SCHEMA media; +CREATE SCHEMA pet_health; +CREATE SCHEMA community; +CREATE SCHEMA creation; +CREATE SCHEMA marketplace; + +COMMENT ON SCHEMA platform IS 'Shared reference data, notifications and reliable outbox'; +COMMENT ON SCHEMA identity IS 'Accounts, credentials, sessions and user preferences'; +COMMENT ON SCHEMA media IS 'Metadata for objects stored in S3/OSS/MinIO or external fixtures'; +COMMENT ON SCHEMA pet_health IS 'Pet profile, health facts, vaccines and reminders'; +COMMENT ON SCHEMA community IS 'Posts and social interaction facts'; +COMMENT ON SCHEMA creation IS 'Asynchronous AI image/video generation'; +COMMENT ON SCHEMA marketplace IS 'Provider catalog, scheduling resources and bookings'; + +CREATE FUNCTION platform.set_updated_at() +RETURNS trigger +LANGUAGE plpgsql +AS $$ +BEGIN + NEW.updated_at := clock_timestamp(); + RETURN NEW; +END; +$$; + +CREATE FUNCTION platform.distance_km( + latitude_a numeric, + longitude_a numeric, + latitude_b numeric, + longitude_b numeric +) +RETURNS double precision +LANGUAGE sql +IMMUTABLE +PARALLEL SAFE +RETURNS NULL ON NULL INPUT +AS $$ + SELECT 6371.0088 * 2 * asin( + sqrt( + least(1.0, greatest(0.0, + power(sin(radians(($3 - $1)::double precision) / 2), 2) + + cos(radians($1::double precision)) * + cos(radians($3::double precision)) * + power(sin(radians(($4 - $2)::double precision) / 2), 2) + )) + ) + ) +$$; + +-- Flat selectable region rows avoid recursive province/city/district queries. +CREATE TABLE platform.regions ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + code varchar(32) NOT NULL UNIQUE, + country_code char(2) NOT NULL DEFAULT 'CN', + province_name varchar(64) NOT NULL, + city_name varchar(64) NOT NULL, + district_name varchar(64) NOT NULL, + latitude numeric(9,6) NOT NULL, + longitude numeric(9,6) NOT NULL, + timezone varchar(64) NOT NULL DEFAULT 'Asia/Shanghai', + enabled boolean NOT NULL DEFAULT true, + created_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_regions_code CHECK (code = btrim(code) AND char_length(code) BETWEEN 2 AND 32), + CONSTRAINT ck_regions_latitude CHECK (latitude BETWEEN -90 AND 90), + CONSTRAINT ck_regions_longitude CHECK (longitude BETWEEN -180 AND 180) +); + +CREATE INDEX ix_regions_city_district + ON platform.regions (city_name, district_name) + WHERE enabled; + +CREATE TABLE identity.users ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + username citext NOT NULL UNIQUE, + nickname varchar(32), + phone_e164 varchar(16), + email citext, + bio varchar(300), + avatar_asset_id uuid, + status varchar(16) NOT NULL DEFAULT 'active', + phone_verified_at timestamptz, + email_verified_at timestamptz, + last_login_at timestamptz, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + deleted_at timestamptz, + version integer NOT NULL DEFAULT 0, + CONSTRAINT ck_users_username CHECK ( + username::text = btrim(username::text) + AND char_length(username::text) BETWEEN 3 AND 32 + ), + CONSTRAINT ck_users_nickname CHECK ( + nickname IS NULL OR (nickname = btrim(nickname) AND char_length(nickname) BETWEEN 1 AND 32) + ), + CONSTRAINT ck_users_phone CHECK ( + phone_e164 IS NULL OR phone_e164 ~ '^\+[1-9][0-9]{7,14}$' + ), + CONSTRAINT ck_users_status CHECK (status IN ('active', 'locked', 'disabled', 'deleted')), + CONSTRAINT ck_users_version CHECK (version >= 0), + CONSTRAINT ck_users_deleted_state CHECK ((status = 'deleted') = (deleted_at IS NOT NULL)) +); + +CREATE UNIQUE INDEX uq_users_phone + ON identity.users (phone_e164) + WHERE phone_e164 IS NOT NULL AND status <> 'deleted'; + +CREATE UNIQUE INDEX uq_users_email + ON identity.users (email) + WHERE email IS NOT NULL AND status <> 'deleted'; + +CREATE INDEX ix_users_avatar_asset ON identity.users (avatar_asset_id); + +CREATE TABLE identity.user_credentials ( + user_id uuid PRIMARY KEY REFERENCES identity.users(id) ON DELETE RESTRICT, + password_hash varchar(255) NOT NULL, + hash_algorithm varchar(16) NOT NULL DEFAULT 'bcrypt', + password_changed_at timestamptz NOT NULL DEFAULT now(), + failed_login_count integer NOT NULL DEFAULT 0, + failure_window_started_at timestamptz, + last_failed_at timestamptz, + locked_until timestamptz, + updated_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_credentials_algorithm CHECK (hash_algorithm IN ('bcrypt', 'argon2id')), + CONSTRAINT ck_credentials_failed_count CHECK (failed_login_count >= 0), + CONSTRAINT ck_credentials_hash CHECK (char_length(password_hash) BETWEEN 20 AND 255) +); + +CREATE TABLE identity.auth_sessions ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + token_family_id uuid NOT NULL, + refresh_token_hash bytea NOT NULL UNIQUE, + access_token_jti varchar(64), + device_id varchar(128), + device_name varchar(128), + user_agent varchar(512), + ip_address inet, + created_at timestamptz NOT NULL DEFAULT now(), + last_seen_at timestamptz NOT NULL DEFAULT now(), + expires_at timestamptz NOT NULL, + revoked_at timestamptz, + revoke_reason varchar(128), + rotated_at timestamptz, + replaced_by_session_id uuid REFERENCES identity.auth_sessions(id) ON DELETE SET NULL, + UNIQUE (replaced_by_session_id), + CONSTRAINT ck_sessions_refresh_hash CHECK (octet_length(refresh_token_hash) = 32), + CONSTRAINT ck_sessions_expiry CHECK (expires_at > created_at), + CONSTRAINT ck_sessions_revoked_at CHECK (revoked_at IS NULL OR revoked_at >= created_at), + CONSTRAINT ck_sessions_rotation CHECK ( + replaced_by_session_id IS NULL + OR (replaced_by_session_id <> id AND revoked_at IS NOT NULL AND rotated_at IS NOT NULL) + ) +); + +CREATE INDEX ix_auth_sessions_user_created + ON identity.auth_sessions (user_id, created_at DESC); +CREATE INDEX ix_auth_sessions_active_expiry + ON identity.auth_sessions (expires_at) + WHERE revoked_at IS NULL; +CREATE INDEX ix_auth_sessions_family + ON identity.auth_sessions (token_family_id, created_at DESC); +CREATE UNIQUE INDEX uq_auth_sessions_access_jti + ON identity.auth_sessions (access_token_jti) + WHERE access_token_jti IS NOT NULL; + +CREATE TABLE identity.user_addresses ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + region_id uuid NOT NULL REFERENCES platform.regions(id) ON DELETE RESTRICT, + label varchar(32) NOT NULL, + recipient_name varchar(64), + recipient_phone_e164 varchar(16), + address_line varchar(300) NOT NULL, + latitude numeric(9,6), + longitude numeric(9,6), + is_default boolean NOT NULL DEFAULT false, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + deleted_at timestamptz, + CONSTRAINT ck_user_addresses_label CHECK (label = btrim(label) AND char_length(label) BETWEEN 1 AND 32), + CONSTRAINT ck_user_addresses_line CHECK (address_line = btrim(address_line) AND char_length(address_line) BETWEEN 3 AND 300), + CONSTRAINT ck_user_addresses_phone CHECK ( + recipient_phone_e164 IS NULL OR recipient_phone_e164 ~ '^\+[1-9][0-9]{7,14}$' + ), + CONSTRAINT ck_user_addresses_coordinates CHECK ( + (latitude IS NULL AND longitude IS NULL) + OR ( + latitude IS NOT NULL AND longitude IS NOT NULL + AND latitude BETWEEN -90 AND 90 + AND longitude BETWEEN -180 AND 180 + ) + ) +); + +CREATE INDEX ix_user_addresses_user ON identity.user_addresses (user_id); +CREATE INDEX ix_user_addresses_region ON identity.user_addresses (region_id); +CREATE UNIQUE INDEX uq_user_addresses_default + ON identity.user_addresses (user_id) + WHERE is_default AND deleted_at IS NULL; + +CREATE TABLE identity.user_preferences ( + user_id uuid PRIMARY KEY REFERENCES identity.users(id) ON DELETE CASCADE, + default_region_id uuid REFERENCES platform.regions(id) ON DELETE SET NULL, + locale varchar(16) NOT NULL DEFAULT 'zh-CN', + timezone varchar(64) NOT NULL DEFAULT 'Asia/Shanghai', + allow_precise_location boolean NOT NULL DEFAULT false, + marketing_notifications boolean NOT NULL DEFAULT false, + community_notifications boolean NOT NULL DEFAULT true, + health_reminders boolean NOT NULL DEFAULT true, + updated_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_user_preferences_locale CHECK (char_length(locale) BETWEEN 2 AND 16), + CONSTRAINT ck_user_preferences_timezone CHECK (char_length(timezone) BETWEEN 3 AND 64) +); + +CREATE INDEX ix_user_preferences_region ON identity.user_preferences (default_region_id); + +CREATE TABLE media.assets ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + owner_user_id uuid REFERENCES identity.users(id) ON DELETE RESTRICT, + kind varchar(16) NOT NULL, + purpose varchar(32) NOT NULL, + storage_type varchar(16) NOT NULL DEFAULT 'object', + bucket varchar(63), + object_key varchar(1024), + external_url varchar(1024), + mime_type varchar(127) NOT NULL, + byte_size bigint, + sha256 bytea, + width_px integer, + height_px integer, + duration_ms bigint, + status varchar(16) NOT NULL DEFAULT 'uploading', + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + ready_at timestamptz, + deleted_at timestamptz, + CONSTRAINT ck_media_kind CHECK (kind IN ('image', 'video', 'document')), + CONSTRAINT ck_media_storage_type CHECK (storage_type IN ('object', 'external')), + CONSTRAINT ck_media_location CHECK ( + ( + storage_type = 'object' AND bucket IS NOT NULL + AND object_key IS NOT NULL AND char_length(btrim(object_key)) > 0 + AND external_url IS NULL + ) + OR ( + storage_type = 'external' + AND external_url IS NOT NULL AND char_length(btrim(external_url)) > 0 + AND bucket IS NULL AND object_key IS NULL + ) + ), + CONSTRAINT ck_media_size CHECK (byte_size IS NULL OR byte_size >= 0), + CONSTRAINT ck_media_hash CHECK (sha256 IS NULL OR octet_length(sha256) = 32), + CONSTRAINT ck_media_dimensions CHECK ( + (width_px IS NULL OR width_px > 0) + AND (height_px IS NULL OR height_px > 0) + AND (duration_ms IS NULL OR duration_ms >= 0) + ), + CONSTRAINT ck_media_status CHECK (status IN ('uploading', 'ready', 'failed', 'deleted')), + CONSTRAINT ck_media_ready CHECK (status <> 'ready' OR ready_at IS NOT NULL), + CONSTRAINT ck_media_deleted CHECK (status <> 'deleted' OR deleted_at IS NOT NULL) +); + +CREATE UNIQUE INDEX uq_media_object + ON media.assets (bucket, object_key) + WHERE storage_type = 'object'; +CREATE UNIQUE INDEX uq_media_external_url + ON media.assets (external_url) + WHERE storage_type = 'external'; +CREATE INDEX ix_media_owner_created ON media.assets (owner_user_id, created_at DESC); +CREATE INDEX ix_media_uploading_created + ON media.assets (created_at) + WHERE status = 'uploading'; + +ALTER TABLE identity.users + ADD CONSTRAINT fk_users_avatar_asset + FOREIGN KEY (avatar_asset_id) REFERENCES media.assets(id) ON DELETE SET NULL; + +CREATE TABLE pet_health.breeds ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + species varchar(16) NOT NULL, + code varchar(64) NOT NULL UNIQUE, + display_name varchar(64) NOT NULL, + enabled boolean NOT NULL DEFAULT true, + sort_order integer NOT NULL DEFAULT 0, + created_at timestamptz NOT NULL DEFAULT now(), + UNIQUE (id, species), + CONSTRAINT ck_breeds_species CHECK (species IN ('dog', 'cat', 'other')), + CONSTRAINT ck_breeds_names CHECK ( + code = btrim(code) AND display_name = btrim(display_name) + AND char_length(code) BETWEEN 2 AND 64 + AND char_length(display_name) BETWEEN 1 AND 64 + ) +); + +CREATE INDEX ix_breeds_species_order ON pet_health.breeds (species, sort_order, id) WHERE enabled; + +CREATE TABLE pet_health.pets ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + name varchar(64) NOT NULL, + species varchar(16) NOT NULL, + breed_id uuid, + custom_breed_name varchar(64), + sex varchar(8) NOT NULL DEFAULT 'unknown', + birth_date date, + birth_date_estimated boolean NOT NULL DEFAULT false, + personality varchar(64), + avatar_asset_id uuid REFERENCES media.assets(id) ON DELETE SET NULL, + microchip_no citext, + sterilized_on date, + status varchar(16) NOT NULL DEFAULT 'active', + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + deleted_at timestamptz, + version integer NOT NULL DEFAULT 0, + CONSTRAINT ck_pets_name CHECK (name = btrim(name) AND char_length(name) BETWEEN 1 AND 64), + CONSTRAINT ck_pets_species CHECK (species IN ('dog', 'cat', 'other')), + CONSTRAINT ck_pets_sex CHECK (sex IN ('male', 'female', 'unknown')), + FOREIGN KEY (breed_id, species) + REFERENCES pet_health.breeds(id, species) ON DELETE RESTRICT, + CONSTRAINT ck_pets_breed CHECK ( + (breed_id IS NOT NULL AND custom_breed_name IS NULL) + OR ( + breed_id IS NULL AND custom_breed_name IS NOT NULL + AND char_length(btrim(custom_breed_name)) BETWEEN 1 AND 64 + ) + ), + CONSTRAINT ck_pets_birth_date CHECK (birth_date IS NULL OR birth_date >= DATE '1990-01-01'), + CONSTRAINT ck_pets_status CHECK (status IN ('active', 'lost', 'deceased', 'archived', 'deleted')), + CONSTRAINT ck_pets_version CHECK (version >= 0), + CONSTRAINT ck_pets_deleted CHECK ((status = 'deleted') = (deleted_at IS NOT NULL)) +); + +CREATE UNIQUE INDEX uq_pets_microchip + ON pet_health.pets (microchip_no) + WHERE microchip_no IS NOT NULL; +CREATE INDEX ix_pets_breed_species ON pet_health.pets (breed_id, species); +CREATE INDEX ix_pets_avatar ON pet_health.pets (avatar_asset_id); +CREATE INDEX ix_pets_active_updated ON pet_health.pets (updated_at DESC, id) WHERE status = 'active'; + +CREATE TABLE pet_health.pet_owners ( + pet_id uuid NOT NULL REFERENCES pet_health.pets(id) ON DELETE CASCADE, + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE RESTRICT, + role varchar(16) NOT NULL DEFAULT 'owner', + is_primary boolean NOT NULL DEFAULT false, + created_at timestamptz NOT NULL DEFAULT now(), + PRIMARY KEY (pet_id, user_id), + CONSTRAINT ck_pet_owners_role CHECK (role IN ('owner', 'caregiver', 'viewer')) +); + +CREATE INDEX ix_pet_owners_user ON pet_health.pet_owners (user_id, pet_id); +CREATE UNIQUE INDEX uq_pet_primary_owner + ON pet_health.pet_owners (pet_id) + WHERE is_primary; + +CREATE TABLE pet_health.pet_weight_records ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + pet_id uuid NOT NULL REFERENCES pet_health.pets(id) ON DELETE CASCADE, + weight_kg numeric(6,2) NOT NULL, + measured_at timestamptz NOT NULL, + source varchar(16) NOT NULL DEFAULT 'manual', + note varchar(500), + created_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_pet_weight CHECK (weight_kg > 0 AND weight_kg <= 500), + CONSTRAINT ck_pet_weight_source CHECK (source IN ('manual', 'clinic', 'device')) +); + +CREATE INDEX ix_pet_weight_pet_measured + ON pet_health.pet_weight_records (pet_id, measured_at DESC, id DESC); + +CREATE TABLE pet_health.vaccine_catalog ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + code varchar(64) NOT NULL UNIQUE, + name varchar(128) NOT NULL, + species varchar(16) NOT NULL, + description varchar(500), + enabled boolean NOT NULL DEFAULT true, + created_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_vaccine_species CHECK (species IN ('dog', 'cat', 'other')), + CONSTRAINT ck_vaccine_names CHECK ( + code = btrim(code) AND name = btrim(name) + AND char_length(code) BETWEEN 2 AND 64 + AND char_length(name) BETWEEN 1 AND 128 + ) +); + +CREATE INDEX ix_vaccine_catalog_species ON pet_health.vaccine_catalog (species, name) WHERE enabled; + +CREATE TABLE pet_health.pet_vaccinations ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + pet_id uuid NOT NULL REFERENCES pet_health.pets(id) ON DELETE CASCADE, + vaccine_id uuid NOT NULL REFERENCES pet_health.vaccine_catalog(id) ON DELETE RESTRICT, + series_key varchar(64) NOT NULL, + dose_no smallint NOT NULL, + dose_label varchar(64), + status varchar(16) NOT NULL DEFAULT 'scheduled', + planned_on date, + administered_on date, + next_due_on date, + provider_id uuid, + provider_name_snapshot varchar(128), + manufacturer varchar(128), + batch_no varchar(64), + certificate_asset_id uuid REFERENCES media.assets(id) ON DELETE SET NULL, + booking_id uuid, + notes varchar(1000), + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + version integer NOT NULL DEFAULT 0, + CONSTRAINT ck_vaccination_series CHECK (series_key = btrim(series_key) AND char_length(series_key) BETWEEN 1 AND 64), + CONSTRAINT ck_vaccination_dose CHECK (dose_no > 0), + CONSTRAINT ck_vaccination_status CHECK (status IN ('scheduled', 'completed', 'cancelled')), + CONSTRAINT ck_vaccination_dates CHECK ( + (status = 'completed' AND administered_on IS NOT NULL) + OR (status = 'scheduled' AND administered_on IS NULL AND planned_on IS NOT NULL) + OR (status = 'cancelled' AND administered_on IS NULL) + ), + CONSTRAINT ck_vaccination_next_due CHECK ( + next_due_on IS NULL OR administered_on IS NULL OR next_due_on >= administered_on + ), + CONSTRAINT ck_vaccination_version CHECK (version >= 0) +); + +CREATE UNIQUE INDEX uq_pet_vaccination_dose + ON pet_health.pet_vaccinations (pet_id, vaccine_id, series_key, dose_no) + WHERE status <> 'cancelled'; +CREATE INDEX ix_vaccinations_pet ON pet_health.pet_vaccinations (pet_id); +CREATE INDEX ix_vaccinations_vaccine ON pet_health.pet_vaccinations (vaccine_id); +CREATE INDEX ix_vaccinations_certificate ON pet_health.pet_vaccinations (certificate_asset_id); +CREATE INDEX ix_vaccinations_provider ON pet_health.pet_vaccinations (provider_id); +CREATE INDEX ix_vaccinations_booking ON pet_health.pet_vaccinations (booking_id); +CREATE INDEX ix_vaccinations_pet_completed + ON pet_health.pet_vaccinations (pet_id, administered_on DESC, id DESC) + WHERE status = 'completed'; +CREATE INDEX ix_vaccinations_due + ON pet_health.pet_vaccinations (planned_on, pet_id) + WHERE status = 'scheduled'; + +CREATE TABLE pet_health.health_events ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + pet_id uuid NOT NULL REFERENCES pet_health.pets(id) ON DELETE CASCADE, + event_type varchar(24) NOT NULL, + occurred_at timestamptz NOT NULL, + title varchar(160) NOT NULL, + notes text, + amount_cents bigint, + provider_id uuid, + provider_name_snapshot varchar(128), + booking_id uuid, + created_by_user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE RESTRICT, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + version integer NOT NULL DEFAULT 0, + CONSTRAINT ck_health_event_type CHECK ( + event_type IN ('medical', 'feeding', 'deworming', 'grooming', 'measurement', 'note') + ), + CONSTRAINT ck_health_event_title CHECK (title = btrim(title) AND char_length(title) BETWEEN 1 AND 160), + CONSTRAINT ck_health_event_amount CHECK (amount_cents IS NULL OR amount_cents >= 0), + CONSTRAINT ck_health_event_version CHECK (version >= 0) +); + +CREATE INDEX ix_health_events_pet_time ON pet_health.health_events (pet_id, occurred_at DESC, id DESC); +CREATE INDEX ix_health_events_creator ON pet_health.health_events (created_by_user_id, created_at DESC); +CREATE INDEX ix_health_events_provider ON pet_health.health_events (provider_id); +CREATE INDEX ix_health_events_booking ON pet_health.health_events (booking_id); + +CREATE TABLE pet_health.health_event_media ( + health_event_id uuid NOT NULL REFERENCES pet_health.health_events(id) ON DELETE CASCADE, + position smallint NOT NULL, + asset_id uuid NOT NULL REFERENCES media.assets(id) ON DELETE RESTRICT, + document_type varchar(32), + issued_on date, + PRIMARY KEY (health_event_id, position), + UNIQUE (health_event_id, asset_id), + CONSTRAINT ck_health_event_media_position CHECK (position >= 0) +); + +CREATE INDEX ix_health_event_media_asset ON pet_health.health_event_media (asset_id); + +CREATE TABLE pet_health.care_reminders ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + pet_id uuid NOT NULL REFERENCES pet_health.pets(id) ON DELETE CASCADE, + reminder_type varchar(24) NOT NULL, + title varchar(160) NOT NULL, + due_at timestamptz NOT NULL, + status varchar(16) NOT NULL DEFAULT 'pending', + completed_at timestamptz, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_care_reminder_type CHECK ( + reminder_type IN ('deworming', 'checkup', 'medication', 'other') + ), + CONSTRAINT ck_care_reminder_status CHECK (status IN ('pending', 'completed', 'dismissed')), + CONSTRAINT ck_care_reminder_completed CHECK ((status = 'completed') = (completed_at IS NOT NULL)) +); + +CREATE INDEX ix_care_reminders_pet ON pet_health.care_reminders (pet_id); +CREATE INDEX ix_care_reminders_due + ON pet_health.care_reminders (due_at, pet_id) + WHERE status = 'pending'; + +CREATE TABLE creation.generation_models ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + code varchar(64) NOT NULL, + display_name varchar(128) NOT NULL, + provider_code varchar(64) NOT NULL, + provider_model_name varchar(128) NOT NULL, + media_kind varchar(16) NOT NULL, + enabled boolean NOT NULL DEFAULT true, + sort_order integer NOT NULL DEFAULT 0, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + UNIQUE (code, media_kind), + UNIQUE (id, media_kind), + CONSTRAINT ck_generation_models_kind CHECK (media_kind IN ('image', 'video')), + CONSTRAINT ck_generation_models_names CHECK ( + code = btrim(code) AND char_length(code) BETWEEN 2 AND 64 + AND char_length(btrim(display_name)) BETWEEN 1 AND 128 + ) +); + +CREATE INDEX ix_generation_models_kind_order + ON creation.generation_models (media_kind, sort_order, id) + WHERE enabled; + +CREATE TABLE creation.generation_styles ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + code varchar(64) NOT NULL, + title varchar(64) NOT NULL, + subtitle varchar(128), + media_kind varchar(16) NOT NULL, + preview_asset_id uuid REFERENCES media.assets(id) ON DELETE SET NULL, + enabled boolean NOT NULL DEFAULT true, + sort_order integer NOT NULL DEFAULT 0, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + UNIQUE (code, media_kind), + UNIQUE (id, media_kind), + CONSTRAINT ck_generation_styles_kind CHECK (media_kind IN ('image', 'video')), + CONSTRAINT ck_generation_styles_names CHECK ( + code = btrim(code) AND char_length(code) BETWEEN 2 AND 64 + AND char_length(btrim(title)) BETWEEN 1 AND 64 + ) +); + +CREATE INDEX ix_generation_styles_preview ON creation.generation_styles (preview_asset_id); +CREATE INDEX ix_generation_styles_kind_order + ON creation.generation_styles (media_kind, sort_order, id) + WHERE enabled; + +CREATE TABLE creation.generation_jobs ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE RESTRICT, + pet_id uuid REFERENCES pet_health.pets(id) ON DELETE SET NULL, + media_kind varchar(16) NOT NULL, + model_id uuid NOT NULL, + style_id uuid, + input_asset_id uuid NOT NULL REFERENCES media.assets(id) ON DELETE RESTRICT, + output_asset_id uuid REFERENCES media.assets(id) ON DELETE SET NULL, + prompt varchar(10000), + negative_prompt varchar(3000), + width_px integer, + height_px integer, + duration_ms bigint, + upscale boolean NOT NULL DEFAULT false, + parameters jsonb NOT NULL DEFAULT '{}'::jsonb, + provider_code_snapshot varchar(64) NOT NULL, + provider_model_snapshot varchar(128) NOT NULL, + model_version_snapshot varchar(64) NOT NULL, + style_code_snapshot varchar(64), + status varchar(16) NOT NULL DEFAULT 'queued', + progress smallint NOT NULL DEFAULT 0, + priority smallint NOT NULL DEFAULT 0, + attempt_count smallint NOT NULL DEFAULT 0, + max_attempts smallint NOT NULL DEFAULT 3, + provider_request_id varchar(128), + error_code varchar(64), + error_message varchar(1000), + idempotency_key varchar(128) NOT NULL, + request_hash bytea NOT NULL, + next_attempt_at timestamptz NOT NULL DEFAULT now(), + lease_owner varchar(128), + lease_expires_at timestamptz, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + started_at timestamptz, + completed_at timestamptz, + version integer NOT NULL DEFAULT 0, + UNIQUE (user_id, idempotency_key), + FOREIGN KEY (model_id, media_kind) + REFERENCES creation.generation_models(id, media_kind) ON DELETE RESTRICT, + FOREIGN KEY (style_id, media_kind) + REFERENCES creation.generation_styles(id, media_kind) ON DELETE RESTRICT, + CONSTRAINT ck_generation_jobs_kind CHECK (media_kind IN ('image', 'video')), + CONSTRAINT ck_generation_jobs_dimensions CHECK ( + (width_px IS NULL OR width_px BETWEEN 64 AND 8192) + AND (height_px IS NULL OR height_px BETWEEN 64 AND 8192) + AND (duration_ms IS NULL OR duration_ms > 0) + ), + CONSTRAINT ck_generation_jobs_parameters CHECK (jsonb_typeof(parameters) = 'object'), + CONSTRAINT ck_generation_jobs_idempotency CHECK ( + idempotency_key = btrim(idempotency_key) + AND char_length(idempotency_key) BETWEEN 1 AND 128 + AND octet_length(request_hash) = 32 + ), + CONSTRAINT ck_generation_jobs_status CHECK ( + status IN ('queued', 'running', 'succeeded', 'failed', 'cancelled') + ), + CONSTRAINT ck_generation_jobs_progress CHECK (progress BETWEEN 0 AND 100), + CONSTRAINT ck_generation_jobs_attempts CHECK ( + attempt_count >= 0 AND max_attempts > 0 AND attempt_count <= max_attempts + ), + CONSTRAINT ck_generation_jobs_state CHECK ( + ( + status = 'queued' AND progress = 0 AND started_at IS NULL AND completed_at IS NULL + AND output_asset_id IS NULL AND error_code IS NULL + AND lease_owner IS NULL AND lease_expires_at IS NULL + ) + OR ( + status = 'running' AND started_at IS NOT NULL AND completed_at IS NULL + AND output_asset_id IS NULL AND error_code IS NULL + AND lease_owner IS NOT NULL AND lease_expires_at IS NOT NULL + ) + OR ( + status = 'succeeded' AND progress = 100 AND started_at IS NOT NULL + AND completed_at IS NOT NULL AND output_asset_id IS NOT NULL AND error_code IS NULL + AND lease_owner IS NULL AND lease_expires_at IS NULL + ) + OR ( + status = 'failed' AND completed_at IS NOT NULL AND error_code IS NOT NULL + AND output_asset_id IS NULL AND lease_owner IS NULL AND lease_expires_at IS NULL + ) + OR ( + status = 'cancelled' AND completed_at IS NOT NULL + AND lease_owner IS NULL AND lease_expires_at IS NULL + ) + ), + CONSTRAINT ck_generation_jobs_lease CHECK ( + (lease_owner IS NULL) = (lease_expires_at IS NULL) + AND (lease_expires_at IS NULL OR started_at IS NULL OR lease_expires_at > started_at) + ), + CONSTRAINT ck_generation_jobs_version CHECK (version >= 0) +); + +CREATE UNIQUE INDEX uq_generation_jobs_provider_request + ON creation.generation_jobs (provider_code_snapshot, provider_request_id) + WHERE provider_request_id IS NOT NULL; +CREATE INDEX ix_generation_jobs_user_created + ON creation.generation_jobs (user_id, created_at DESC, id DESC); +CREATE INDEX ix_generation_jobs_pet ON creation.generation_jobs (pet_id); +CREATE INDEX ix_generation_jobs_model ON creation.generation_jobs (model_id); +CREATE INDEX ix_generation_jobs_style ON creation.generation_jobs (style_id); +CREATE INDEX ix_generation_jobs_model_kind ON creation.generation_jobs (model_id, media_kind); +CREATE INDEX ix_generation_jobs_style_kind ON creation.generation_jobs (style_id, media_kind); +CREATE INDEX ix_generation_jobs_input ON creation.generation_jobs (input_asset_id); +CREATE INDEX ix_generation_jobs_output ON creation.generation_jobs (output_asset_id); +CREATE INDEX ix_generation_jobs_queue + ON creation.generation_jobs (priority DESC, next_attempt_at, created_at, id) + WHERE status = 'queued'; +CREATE INDEX ix_generation_jobs_running + ON creation.generation_jobs (lease_expires_at, id) + WHERE status = 'running'; + +CREATE TABLE community.posts ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + author_user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE RESTRICT, + pet_id uuid REFERENCES pet_health.pets(id) ON DELETE SET NULL, + generation_job_id uuid REFERENCES creation.generation_jobs(id) ON DELETE SET NULL, + category varchar(24) NOT NULL DEFAULT 'general', + title varchar(120), + content text NOT NULL, + status varchar(16) NOT NULL DEFAULT 'draft', + visibility varchar(16) NOT NULL DEFAULT 'public', + region_id uuid REFERENCES platform.regions(id) ON DELETE SET NULL, + location_text_snapshot varchar(128), + like_count bigint NOT NULL DEFAULT 0, + comment_count bigint NOT NULL DEFAULT 0, + bookmark_count bigint NOT NULL DEFAULT 0, + idempotency_key varchar(128), + request_hash bytea, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + published_at timestamptz, + deleted_at timestamptz, + version integer NOT NULL DEFAULT 0, + CONSTRAINT uq_posts_author_idempotency UNIQUE (author_user_id, idempotency_key), + CONSTRAINT ck_posts_category CHECK (category IN ('general', 'help', 'ai_creation')), + CONSTRAINT ck_posts_title CHECK (title IS NULL OR char_length(btrim(title)) BETWEEN 1 AND 120), + CONSTRAINT ck_posts_content CHECK (char_length(btrim(content)) BETWEEN 1 AND 10000), + CONSTRAINT ck_posts_status CHECK (status IN ('draft', 'published', 'hidden', 'archived')), + CONSTRAINT ck_posts_visibility CHECK (visibility IN ('public', 'followers', 'private')), + CONSTRAINT ck_posts_publish_state CHECK ( + (status = 'published' AND published_at IS NOT NULL AND deleted_at IS NULL) + OR status <> 'published' + ), + CONSTRAINT ck_posts_counts CHECK (like_count >= 0 AND comment_count >= 0 AND bookmark_count >= 0), + CONSTRAINT ck_posts_idempotency CHECK ( + (idempotency_key IS NULL AND request_hash IS NULL) + OR ( + idempotency_key = btrim(idempotency_key) + AND char_length(idempotency_key) BETWEEN 1 AND 128 + AND octet_length(request_hash) = 32 + ) + ), + CONSTRAINT ck_posts_version CHECK (version >= 0) +); + +CREATE INDEX ix_posts_feed + ON community.posts (published_at DESC, id DESC) + WHERE status = 'published' AND visibility = 'public'; +CREATE INDEX ix_posts_author_created + ON community.posts (author_user_id, created_at DESC, id DESC); +CREATE INDEX ix_posts_pet_created ON community.posts (pet_id, created_at DESC); +CREATE INDEX ix_posts_generation_job ON community.posts (generation_job_id); +CREATE INDEX ix_posts_region_feed + ON community.posts (region_id, published_at DESC, id DESC) + WHERE status = 'published' AND visibility = 'public'; +CREATE INDEX ix_posts_region ON community.posts (region_id); +CREATE INDEX ix_posts_content_trgm + ON community.posts USING gin (content gin_trgm_ops) + WHERE status = 'published'; + +CREATE TABLE community.post_media ( + post_id uuid NOT NULL REFERENCES community.posts(id) ON DELETE CASCADE, + position smallint NOT NULL, + asset_id uuid NOT NULL REFERENCES media.assets(id) ON DELETE RESTRICT, + is_cover boolean NOT NULL DEFAULT false, + caption varchar(300), + PRIMARY KEY (post_id, position), + UNIQUE (post_id, asset_id), + CONSTRAINT ck_post_media_position CHECK (position >= 0) +); + +CREATE INDEX ix_post_media_asset ON community.post_media (asset_id); +CREATE UNIQUE INDEX uq_post_media_cover + ON community.post_media (post_id) + WHERE is_cover; + +-- Comments are deliberately one flat level. reply_to_user_id supports @ replies +-- without parent_comment_id, recursive queries, or unbounded comment nesting. +CREATE TABLE community.comments ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + post_id uuid NOT NULL REFERENCES community.posts(id) ON DELETE CASCADE, + author_user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE RESTRICT, + reply_to_user_id uuid REFERENCES identity.users(id) ON DELETE SET NULL, + content varchar(2000) NOT NULL, + status varchar(16) NOT NULL DEFAULT 'visible', + client_request_id varchar(128), + request_hash bytea, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + deleted_at timestamptz, + UNIQUE (author_user_id, client_request_id), + CONSTRAINT ck_comments_content CHECK (char_length(btrim(content)) BETWEEN 1 AND 2000), + CONSTRAINT ck_comments_status CHECK (status IN ('visible', 'hidden', 'deleted')), + CONSTRAINT ck_comments_idempotency CHECK ( + (client_request_id IS NULL AND request_hash IS NULL) + OR ( + client_request_id = btrim(client_request_id) + AND char_length(client_request_id) BETWEEN 1 AND 128 + AND octet_length(request_hash) = 32 + ) + ), + CONSTRAINT ck_comments_deleted CHECK ((status = 'deleted') = (deleted_at IS NOT NULL)) +); + +CREATE INDEX ix_comments_post_created + ON community.comments (post_id, created_at DESC, id DESC); +CREATE INDEX ix_comments_author_created + ON community.comments (author_user_id, created_at DESC, id DESC); +CREATE INDEX ix_comments_reply_user + ON community.comments (reply_to_user_id, created_at DESC); + +CREATE TABLE community.post_likes ( + post_id uuid NOT NULL REFERENCES community.posts(id) ON DELETE CASCADE, + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + created_at timestamptz NOT NULL DEFAULT now(), + PRIMARY KEY (post_id, user_id) +); + +CREATE INDEX ix_post_likes_user_created + ON community.post_likes (user_id, created_at DESC, post_id); + +CREATE TABLE community.post_bookmarks ( + post_id uuid NOT NULL REFERENCES community.posts(id) ON DELETE CASCADE, + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + created_at timestamptz NOT NULL DEFAULT now(), + PRIMARY KEY (post_id, user_id) +); + +CREATE INDEX ix_post_bookmarks_user_created + ON community.post_bookmarks (user_id, created_at DESC, post_id); + +CREATE TABLE community.user_follows ( + follower_user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + followee_user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + created_at timestamptz NOT NULL DEFAULT now(), + PRIMARY KEY (follower_user_id, followee_user_id), + CONSTRAINT ck_user_follows_self CHECK (follower_user_id <> followee_user_id) +); + +CREATE INDEX ix_user_follows_followee + ON community.user_follows (followee_user_id, created_at DESC, follower_user_id); + +CREATE TABLE community.topics ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + name citext NOT NULL UNIQUE, + description varchar(300), + status varchar(16) NOT NULL DEFAULT 'active', + created_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_topics_name CHECK (name::text = btrim(name::text) AND char_length(name::text) BETWEEN 1 AND 32), + CONSTRAINT ck_topics_status CHECK (status IN ('active', 'hidden')) +); + +CREATE TABLE community.post_topics ( + post_id uuid NOT NULL REFERENCES community.posts(id) ON DELETE CASCADE, + topic_id uuid NOT NULL REFERENCES community.topics(id) ON DELETE CASCADE, + PRIMARY KEY (post_id, topic_id) +); + +CREATE INDEX ix_post_topics_topic ON community.post_topics (topic_id, post_id); + +CREATE TABLE marketplace.providers ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + owner_user_id uuid REFERENCES identity.users(id) ON DELETE SET NULL, + kind varchar(16) NOT NULL, + slug varchar(128) NOT NULL UNIQUE, + name varchar(128) NOT NULL, + description text NOT NULL, + phone_e164 varchar(16), + region_id uuid NOT NULL REFERENCES platform.regions(id) ON DELETE RESTRICT, + address_line varchar(300) NOT NULL, + latitude numeric(9,6) NOT NULL, + longitude numeric(9,6) NOT NULL, + cover_asset_id uuid REFERENCES media.assets(id) ON DELETE SET NULL, + verification_status varchar(16) NOT NULL DEFAULT 'unverified', + verified_at timestamptz, + is_24h boolean NOT NULL DEFAULT false, + rating_avg numeric(3,2) NOT NULL DEFAULT 0, + rating_count integer NOT NULL DEFAULT 0, + status varchar(16) NOT NULL DEFAULT 'pending', + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + version integer NOT NULL DEFAULT 0, + CONSTRAINT ck_providers_kind CHECK (kind IN ('hospital', 'grooming', 'personal')), + CONSTRAINT ck_providers_slug CHECK (slug = lower(btrim(slug)) AND slug ~ '^[a-z0-9][a-z0-9-]{1,127}$'), + CONSTRAINT ck_providers_name CHECK (name = btrim(name) AND char_length(name) BETWEEN 1 AND 128), + CONSTRAINT ck_providers_description CHECK (char_length(btrim(description)) BETWEEN 1 AND 5000), + CONSTRAINT ck_providers_phone CHECK (phone_e164 IS NULL OR phone_e164 ~ '^\+[1-9][0-9]{7,14}$'), + CONSTRAINT ck_providers_coordinates CHECK (latitude BETWEEN -90 AND 90 AND longitude BETWEEN -180 AND 180), + CONSTRAINT ck_providers_verification CHECK ( + verification_status IN ('unverified', 'pending', 'verified', 'rejected', 'expired') + AND (verification_status <> 'verified' OR verified_at IS NOT NULL) + ), + CONSTRAINT ck_providers_rating CHECK (rating_avg BETWEEN 0 AND 5 AND rating_count >= 0), + CONSTRAINT ck_providers_status CHECK (status IN ('pending', 'active', 'suspended', 'closed')), + CONSTRAINT ck_providers_version CHECK (version >= 0) +); + +CREATE INDEX ix_providers_owner ON marketplace.providers (owner_user_id); +CREATE INDEX ix_providers_region_location + ON marketplace.providers (region_id, latitude, longitude) + WHERE status = 'active'; +CREATE INDEX ix_providers_region ON marketplace.providers (region_id); +CREATE INDEX ix_providers_kind_rating + ON marketplace.providers (kind, rating_avg DESC, id) + WHERE status = 'active'; +CREATE INDEX ix_providers_cover ON marketplace.providers (cover_asset_id); +CREATE INDEX ix_providers_name_trgm + ON marketplace.providers USING gin (name gin_trgm_ops) + WHERE status = 'active'; +CREATE INDEX ix_providers_description_trgm + ON marketplace.providers USING gin (description gin_trgm_ops) + WHERE status = 'active'; + +CREATE TABLE marketplace.provider_tags ( + provider_id uuid NOT NULL REFERENCES marketplace.providers(id) ON DELETE CASCADE, + tag citext NOT NULL, + PRIMARY KEY (provider_id, tag), + CONSTRAINT ck_provider_tags_value CHECK ( + tag::text = btrim(tag::text) AND char_length(tag::text) BETWEEN 1 AND 32 + ) +); + +CREATE INDEX ix_provider_tags_search + ON marketplace.provider_tags USING gin ((tag::text) gin_trgm_ops); + +CREATE TABLE marketplace.service_offerings ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + provider_id uuid NOT NULL REFERENCES marketplace.providers(id) ON DELETE RESTRICT, + category varchar(24) NOT NULL, + name varchar(128) NOT NULL, + description text, + base_price_cents bigint NOT NULL, + currency char(3) NOT NULL DEFAULT 'CNY', + pricing_unit varchar(24) NOT NULL DEFAULT 'service', + duration_minutes smallint, + status varchar(16) NOT NULL DEFAULT 'active', + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + version integer NOT NULL DEFAULT 0, + UNIQUE (id, provider_id), + UNIQUE (provider_id, name), + CONSTRAINT ck_service_offerings_category CHECK ( + category IN ('feeding', 'walking', 'bathing', 'grooming', 'boarding', 'transport', 'hospital', 'adoption', 'other') + ), + CONSTRAINT ck_service_offerings_name CHECK (name = btrim(name) AND char_length(name) BETWEEN 1 AND 128), + CONSTRAINT ck_service_offerings_price CHECK (base_price_cents >= 0), + CONSTRAINT ck_service_offerings_currency CHECK (currency ~ '^[A-Z]{3}$'), + CONSTRAINT ck_service_offerings_duration CHECK (duration_minutes IS NULL OR duration_minutes BETWEEN 5 AND 1440), + CONSTRAINT ck_service_offerings_status CHECK (status IN ('active', 'inactive')), + CONSTRAINT ck_service_offerings_version CHECK (version >= 0) +); + +CREATE INDEX ix_service_offerings_provider + ON marketplace.service_offerings (provider_id, category, id); +CREATE INDEX ix_service_offerings_category_price + ON marketplace.service_offerings (category, base_price_cents, id) + WHERE status = 'active'; +CREATE INDEX ix_service_offerings_name_trgm + ON marketplace.service_offerings USING gin (name gin_trgm_ops) + WHERE status = 'active'; + +CREATE TABLE marketplace.service_resources ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + provider_id uuid NOT NULL REFERENCES marketplace.providers(id) ON DELETE RESTRICT, + name varchar(128) NOT NULL, + resource_type varchar(24) NOT NULL, + status varchar(16) NOT NULL DEFAULT 'active', + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + UNIQUE (id, provider_id), + UNIQUE (provider_id, name), + CONSTRAINT ck_service_resources_name CHECK (name = btrim(name) AND char_length(name) BETWEEN 1 AND 128), + CONSTRAINT ck_service_resources_type CHECK (resource_type IN ('person', 'room', 'vehicle', 'capacity_unit')), + CONSTRAINT ck_service_resources_status CHECK (status IN ('active', 'inactive')) +); + +CREATE INDEX ix_service_resources_provider ON marketplace.service_resources (provider_id, id); + +CREATE TABLE marketplace.offering_resources ( + provider_id uuid NOT NULL, + offering_id uuid NOT NULL, + resource_id uuid NOT NULL, + created_at timestamptz NOT NULL DEFAULT now(), + PRIMARY KEY (offering_id, resource_id), + UNIQUE (offering_id, resource_id, provider_id), + FOREIGN KEY (offering_id, provider_id) + REFERENCES marketplace.service_offerings(id, provider_id) ON DELETE CASCADE, + FOREIGN KEY (resource_id, provider_id) + REFERENCES marketplace.service_resources(id, provider_id) ON DELETE CASCADE +); + +CREATE INDEX ix_offering_resources_resource ON marketplace.offering_resources (resource_id, offering_id); +CREATE INDEX ix_offering_resources_provider ON marketplace.offering_resources (provider_id, offering_id); +CREATE INDEX ix_offering_resources_offering_provider + ON marketplace.offering_resources (offering_id, provider_id); +CREATE INDEX ix_offering_resources_resource_provider + ON marketplace.offering_resources (resource_id, provider_id); + +CREATE TABLE marketplace.bookings ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + customer_user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE RESTRICT, + pet_id uuid REFERENCES pet_health.pets(id) ON DELETE RESTRICT, + provider_id uuid NOT NULL REFERENCES marketplace.providers(id) ON DELETE RESTRICT, + offering_id uuid NOT NULL, + resource_id uuid, + scheduled_start_at timestamptz, + scheduled_end_at timestamptz, + service_window tstzrange GENERATED ALWAYS AS ( + CASE + WHEN scheduled_start_at IS NULL OR scheduled_end_at IS NULL THEN NULL + ELSE tstzrange(scheduled_start_at, scheduled_end_at, '[)') + END + ) STORED, + status varchar(16) NOT NULL DEFAULT 'pending', + hold_expires_at timestamptz, + provider_name_snapshot varchar(128) NOT NULL, + service_name_snapshot varchar(128) NOT NULL, + pet_name_snapshot varchar(64), + address_snapshot varchar(300) NOT NULL, + base_amount_cents bigint NOT NULL, + discount_amount_cents bigint NOT NULL DEFAULT 0, + payable_amount_cents bigint NOT NULL, + currency char(3) NOT NULL DEFAULT 'CNY', + customer_note varchar(500), + idempotency_key varchar(128) NOT NULL, + request_hash bytea NOT NULL, + created_at timestamptz NOT NULL DEFAULT now(), + updated_at timestamptz NOT NULL DEFAULT now(), + cancelled_at timestamptz, + completed_at timestamptz, + version integer NOT NULL DEFAULT 0, + UNIQUE (customer_user_id, idempotency_key), + FOREIGN KEY (offering_id, provider_id) + REFERENCES marketplace.service_offerings(id, provider_id) ON DELETE RESTRICT, + FOREIGN KEY (offering_id, resource_id, provider_id) + REFERENCES marketplace.offering_resources(offering_id, resource_id, provider_id) ON DELETE RESTRICT, + CONSTRAINT ck_bookings_status CHECK ( + status IN ('pending', 'held', 'confirmed', 'in_service', 'completed', 'cancelled', 'rejected', 'expired') + ), + CONSTRAINT ck_bookings_schedule CHECK ( + (scheduled_start_at IS NULL AND scheduled_end_at IS NULL) + OR (scheduled_start_at IS NOT NULL AND scheduled_end_at IS NOT NULL AND scheduled_start_at < scheduled_end_at) + ), + CONSTRAINT ck_bookings_active_schedule CHECK ( + status NOT IN ('held', 'confirmed', 'in_service') + OR (resource_id IS NOT NULL AND scheduled_start_at IS NOT NULL AND scheduled_end_at IS NOT NULL) + ), + CONSTRAINT ck_bookings_amount CHECK ( + base_amount_cents >= 0 + AND discount_amount_cents >= 0 + AND discount_amount_cents <= base_amount_cents + AND payable_amount_cents = base_amount_cents - discount_amount_cents + ), + CONSTRAINT ck_bookings_currency CHECK (currency ~ '^[A-Z]{3}$'), + CONSTRAINT ck_bookings_idempotency CHECK ( + idempotency_key = btrim(idempotency_key) + AND char_length(idempotency_key) BETWEEN 1 AND 128 + AND octet_length(request_hash) = 32 + ), + CONSTRAINT ck_bookings_completion CHECK ((status = 'completed') = (completed_at IS NOT NULL)), + CONSTRAINT ck_bookings_cancellation CHECK ((status = 'cancelled') = (cancelled_at IS NOT NULL)), + CONSTRAINT ck_bookings_hold_expiry CHECK ( + (status = 'held') = (hold_expires_at IS NOT NULL) + AND (hold_expires_at IS NULL OR hold_expires_at > created_at) + ), + CONSTRAINT ck_bookings_version CHECK (version >= 0) +); + +ALTER TABLE marketplace.bookings + ADD CONSTRAINT ex_bookings_resource_overlap + EXCLUDE USING gist ( + resource_id WITH =, + service_window WITH && + ) + WHERE (status IN ('held', 'confirmed', 'in_service')) + DEFERRABLE INITIALLY IMMEDIATE; + +CREATE INDEX ix_bookings_customer_created + ON marketplace.bookings (customer_user_id, created_at DESC, id DESC); +CREATE INDEX ix_bookings_pet ON marketplace.bookings (pet_id); +CREATE INDEX ix_bookings_provider_schedule + ON marketplace.bookings (provider_id, scheduled_start_at, id); +CREATE INDEX ix_bookings_offering_schedule + ON marketplace.bookings (offering_id, scheduled_start_at, id); +CREATE INDEX ix_bookings_resource ON marketplace.bookings (resource_id); +CREATE INDEX ix_bookings_offering_provider + ON marketplace.bookings (offering_id, provider_id); +CREATE INDEX ix_bookings_offering_resource_provider + ON marketplace.bookings (offering_id, resource_id, provider_id); +CREATE INDEX ix_bookings_held_expiry + ON marketplace.bookings (hold_expires_at, id) + WHERE status = 'held'; + +CREATE TABLE marketplace.booking_status_history ( + id bigint GENERATED ALWAYS AS IDENTITY PRIMARY KEY, + booking_id uuid NOT NULL REFERENCES marketplace.bookings(id) ON DELETE CASCADE, + from_status varchar(16), + to_status varchar(16) NOT NULL, + actor_user_id uuid REFERENCES identity.users(id) ON DELETE SET NULL, + reason varchar(500), + created_at timestamptz NOT NULL DEFAULT now(), + CONSTRAINT ck_booking_history_status CHECK ( + (from_status IS NULL OR from_status IN ('pending', 'held', 'confirmed', 'in_service', 'completed', 'cancelled', 'rejected', 'expired')) + AND to_status IN ('pending', 'held', 'confirmed', 'in_service', 'completed', 'cancelled', 'rejected', 'expired') + AND from_status IS DISTINCT FROM to_status + ) +); + +CREATE INDEX ix_booking_history_booking + ON marketplace.booking_status_history (booking_id, created_at, id); +CREATE INDEX ix_booking_history_actor ON marketplace.booking_status_history (actor_user_id); + +CREATE FUNCTION marketplace.validate_booking_transition() +RETURNS trigger +LANGUAGE plpgsql +AS $$ +BEGIN + IF NEW.status IS NOT DISTINCT FROM OLD.status THEN + RETURN NEW; + END IF; + + IF NOT ( + (OLD.status = 'pending' AND NEW.status IN ('held', 'confirmed', 'rejected', 'cancelled', 'expired')) + OR (OLD.status = 'held' AND NEW.status IN ('confirmed', 'cancelled', 'expired')) + OR (OLD.status = 'confirmed' AND NEW.status IN ('in_service', 'cancelled')) + OR (OLD.status = 'in_service' AND NEW.status IN ('completed', 'cancelled')) + ) THEN + RAISE EXCEPTION 'illegal booking status transition: % -> %', OLD.status, NEW.status + USING ERRCODE = 'check_violation'; + END IF; + + RETURN NEW; +END; +$$; + +CREATE TRIGGER trg_bookings_validate_transition + BEFORE UPDATE OF status ON marketplace.bookings + FOR EACH ROW EXECUTE FUNCTION marketplace.validate_booking_transition(); + +ALTER TABLE pet_health.pet_vaccinations + ADD CONSTRAINT fk_vaccinations_provider + FOREIGN KEY (provider_id) REFERENCES marketplace.providers(id) ON DELETE SET NULL, + ADD CONSTRAINT fk_vaccinations_booking + FOREIGN KEY (booking_id) REFERENCES marketplace.bookings(id) ON DELETE SET NULL; + +ALTER TABLE pet_health.health_events + ADD CONSTRAINT fk_health_events_provider + FOREIGN KEY (provider_id) REFERENCES marketplace.providers(id) ON DELETE SET NULL, + ADD CONSTRAINT fk_health_events_booking + FOREIGN KEY (booking_id) REFERENCES marketplace.bookings(id) ON DELETE SET NULL; + +CREATE TABLE platform.notifications ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + user_id uuid NOT NULL REFERENCES identity.users(id) ON DELETE CASCADE, + notification_type varchar(64) NOT NULL, + title varchar(160) NOT NULL, + body varchar(1000) NOT NULL, + target_type varchar(64), + target_id uuid, + created_at timestamptz NOT NULL DEFAULT now(), + read_at timestamptz, + archived_at timestamptz, + CONSTRAINT ck_notifications_type CHECK (notification_type = btrim(notification_type) AND char_length(notification_type) BETWEEN 2 AND 64), + CONSTRAINT ck_notifications_title CHECK (char_length(btrim(title)) BETWEEN 1 AND 160), + CONSTRAINT ck_notifications_body CHECK (char_length(btrim(body)) BETWEEN 1 AND 1000) +); + +CREATE INDEX ix_notifications_user_created + ON platform.notifications (user_id, created_at DESC, id DESC); +CREATE INDEX ix_notifications_user_unread + ON platform.notifications (user_id, created_at DESC, id DESC) + WHERE read_at IS NULL AND archived_at IS NULL; + +CREATE TABLE platform.outbox_events ( + id uuid PRIMARY KEY DEFAULT gen_random_uuid(), + aggregate_type varchar(64) NOT NULL, + aggregate_id uuid NOT NULL, + aggregate_version bigint NOT NULL, + event_type varchar(128) NOT NULL, + schema_version smallint NOT NULL DEFAULT 1, + payload jsonb NOT NULL, + occurred_at timestamptz NOT NULL DEFAULT now(), + available_at timestamptz NOT NULL DEFAULT now(), + published_at timestamptz, + attempt_count integer NOT NULL DEFAULT 0, + max_attempts integer NOT NULL DEFAULT 12, + last_error varchar(1000), + locked_at timestamptz, + locked_by varchar(128), + dead_lettered_at timestamptz, + UNIQUE (aggregate_type, aggregate_id, aggregate_version, event_type), + CONSTRAINT ck_outbox_names CHECK ( + char_length(btrim(aggregate_type)) BETWEEN 2 AND 64 + AND char_length(btrim(event_type)) BETWEEN 2 AND 128 + ), + CONSTRAINT ck_outbox_payload CHECK (jsonb_typeof(payload) = 'object'), + CONSTRAINT ck_outbox_versions CHECK (aggregate_version >= 0 AND schema_version > 0), + CONSTRAINT ck_outbox_attempts CHECK (attempt_count >= 0 AND max_attempts > 0), + CONSTRAINT ck_outbox_lock CHECK ((locked_at IS NULL) = (locked_by IS NULL)), + CONSTRAINT ck_outbox_terminal CHECK (published_at IS NULL OR dead_lettered_at IS NULL) +); + +CREATE INDEX ix_outbox_unpublished + ON platform.outbox_events (available_at, occurred_at, id) + WHERE published_at IS NULL AND dead_lettered_at IS NULL; +CREATE INDEX ix_outbox_aggregate + ON platform.outbox_events (aggregate_type, aggregate_id, occurred_at); + +-- Automatic updated_at maintenance. Business version increments remain explicit +-- so optimistic locking stays visible in repository update statements. +CREATE TRIGGER trg_users_updated_at BEFORE UPDATE ON identity.users + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_credentials_updated_at BEFORE UPDATE ON identity.user_credentials + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_addresses_updated_at BEFORE UPDATE ON identity.user_addresses + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_preferences_updated_at BEFORE UPDATE ON identity.user_preferences + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_media_updated_at BEFORE UPDATE ON media.assets + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_pets_updated_at BEFORE UPDATE ON pet_health.pets + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_vaccinations_updated_at BEFORE UPDATE ON pet_health.pet_vaccinations + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_health_events_updated_at BEFORE UPDATE ON pet_health.health_events + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_reminders_updated_at BEFORE UPDATE ON pet_health.care_reminders + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_generation_models_updated_at BEFORE UPDATE ON creation.generation_models + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_generation_styles_updated_at BEFORE UPDATE ON creation.generation_styles + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_generation_jobs_updated_at BEFORE UPDATE ON creation.generation_jobs + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_posts_updated_at BEFORE UPDATE ON community.posts + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_comments_updated_at BEFORE UPDATE ON community.comments + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_providers_updated_at BEFORE UPDATE ON marketplace.providers + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_offerings_updated_at BEFORE UPDATE ON marketplace.service_offerings + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_resources_updated_at BEFORE UPDATE ON marketplace.service_resources + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); +CREATE TRIGGER trg_bookings_updated_at BEFORE UPDATE ON marketplace.bookings + FOR EACH ROW EXECUTE FUNCTION platform.set_updated_at(); + +/* ------------------------------------------------------------------------- + Development fixture data + + The following rows mirror the Flutter demo enough to exercise all page data + paths. Remove this section from the production Flyway baseline. All fixture + accounts use the password: Patbond@123 +--------------------------------------------------------------------------- */ + +INSERT INTO platform.regions + (id, code, province_name, city_name, district_name, latitude, longitude) +VALUES + ('10000000-0000-7000-8000-000000000001', 'CN-BJ-CY', '北京市', '北京', '朝阳区', 39.921900, 116.443550), + ('10000000-0000-7000-8000-000000000002', 'CN-SH-PD', '上海市', '上海', '浦东新区', 31.221140, 121.544090), + ('10000000-0000-7000-8000-000000000003', 'CN-GD-SZ-NS', '广东省', '深圳', '南山区', 22.533320, 113.930410), + ('10000000-0000-7000-8000-000000000004', 'CN-SC-CD-GX', '四川省', '成都', '高新区', 30.544730, 104.069760), + ('10000000-0000-7000-8000-000000000005', 'CN-ZJ-HZ-XH', '浙江省', '杭州', '西湖区', 30.259610, 120.130260), + ('10000000-0000-7000-8000-000000000006', 'CN-HLJ-HEB-DL', '黑龙江省', '哈尔滨', '道里区', 45.755020, 126.616990); + +INSERT INTO identity.users + (id, username, nickname, phone_e164, bio, status, created_at) +VALUES + ('11000000-0000-7000-8000-000000000001', 'demo_user', '豆豆的妈妈', '+8613800000001', 'Patbond 社区创作达人', 'active', now() - interval '180 days'), + ('11000000-0000-7000-8000-000000000002', 'corgi_lover', 'CorgiLover99', '+8613800000002', NULL, 'active', now() - interval '120 days'), + ('11000000-0000-7000-8000-000000000003', 'milo_cat', 'MiloDaCat', '+8613800000003', NULL, 'active', now() - interval '90 days'); + +INSERT INTO identity.user_credentials (user_id, password_hash, hash_algorithm) +VALUES + ('11000000-0000-7000-8000-000000000001', '$2y$12$UYCn5ZmWnouv7BFyuvsTD.NvcA/A/VhHdCePbeIrvcsI4JoRBbmYq', 'bcrypt'), + ('11000000-0000-7000-8000-000000000002', '$2y$12$UYCn5ZmWnouv7BFyuvsTD.NvcA/A/VhHdCePbeIrvcsI4JoRBbmYq', 'bcrypt'), + ('11000000-0000-7000-8000-000000000003', '$2y$12$UYCn5ZmWnouv7BFyuvsTD.NvcA/A/VhHdCePbeIrvcsI4JoRBbmYq', 'bcrypt'); + +INSERT INTO identity.auth_sessions + (id, user_id, token_family_id, refresh_token_hash, access_token_jti, device_id, device_name, expires_at) +VALUES + ( + '11100000-0000-7000-8000-000000000001', + '11000000-0000-7000-8000-000000000001', + '11100000-0000-7000-9000-000000000001', + decode(repeat('ab', 32), 'hex'), + 'fixture-access-token-jti', + 'fixture-device-1', + 'Flutter test device', + now() + interval '30 days' + ); + +INSERT INTO identity.user_preferences + (user_id, default_region_id, allow_precise_location) +VALUES + ('11000000-0000-7000-8000-000000000001', '10000000-0000-7000-8000-000000000001', false), + ('11000000-0000-7000-8000-000000000002', '10000000-0000-7000-8000-000000000001', false), + ('11000000-0000-7000-8000-000000000003', '10000000-0000-7000-8000-000000000002', false); + +INSERT INTO identity.user_addresses + (id, user_id, region_id, label, recipient_name, recipient_phone_e164, address_line, latitude, longitude, is_default) +VALUES + ( + '11200000-0000-7000-8000-000000000001', + '11000000-0000-7000-8000-000000000001', + '10000000-0000-7000-8000-000000000001', + '家', '豆豆家长', '+8613800000001', '示例路 88 号', 39.922100, 116.443900, true + ); + +INSERT INTO media.assets + (id, owner_user_id, kind, purpose, storage_type, external_url, mime_type, width_px, height_px, duration_ms, status, ready_at) +VALUES + ('12000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000001', 'image', 'user_avatar', 'external', 'https://images.unsplash.com/photo-1494790108377-be9c29b29330?auto=format&fit=crop&w=300&q=80', 'image/jpeg', 300, 300, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000002', '11000000-0000-7000-8000-000000000002', 'image', 'user_avatar', 'external', 'https://images.unsplash.com/photo-1534528741775-53994a69daeb?auto=format&fit=crop&w=200&q=80', 'image/jpeg', 200, 200, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000003', '11000000-0000-7000-8000-000000000003', 'image', 'user_avatar', 'external', 'https://images.unsplash.com/photo-1535713875002-d1d0cf377fde?auto=format&fit=crop&w=200&q=80', 'image/jpeg', 200, 200, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000004', '11000000-0000-7000-8000-000000000001', 'image', 'pet_avatar', 'external', 'https://images.unsplash.com/photo-1552053831-71594a27632d?auto=format&fit=crop&w=600&q=85', 'image/jpeg', 600, 600, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000005', '11000000-0000-7000-8000-000000000001', 'image', 'generation_output', 'external', 'https://images.unsplash.com/photo-1605568427561-40dd23c2acea?auto=format&fit=crop&w=1200&q=85', 'image/jpeg', 1200, 900, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000006', '11000000-0000-7000-8000-000000000003', 'image', 'post', 'external', 'https://images.unsplash.com/photo-1574158622682-e40e69881006?auto=format&fit=crop&w=1200&q=85', 'image/jpeg', 1200, 900, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000007', '11000000-0000-7000-8000-000000000001', 'image', 'provider_cover', 'external', 'https://images.unsplash.com/photo-1628009368231-7bb7cfcb0def?auto=format&fit=crop&w=900&q=85', 'image/jpeg', 900, 500, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000008', '11000000-0000-7000-8000-000000000002', 'image', 'provider_cover', 'external', 'https://images.unsplash.com/photo-1516734212186-a967f81ad0d7?auto=format&fit=crop&w=900&q=85', 'image/jpeg', 900, 500, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000009', '11000000-0000-7000-8000-000000000003', 'image', 'provider_cover', 'external', 'https://images.unsplash.com/photo-1601758228041-f3b2795255f1?auto=format&fit=crop&w=900&q=85', 'image/jpeg', 900, 500, NULL, 'ready', now()), + ('12000000-0000-7000-8000-000000000010', '11000000-0000-7000-8000-000000000001', 'document', 'health_certificate', 'external', 'https://example.invalid/fixtures/doudou-vaccine-certificate.pdf', 'application/pdf', NULL, NULL, NULL, 'ready', now()); + +UPDATE identity.users SET avatar_asset_id = '12000000-0000-7000-8000-000000000001' +WHERE id = '11000000-0000-7000-8000-000000000001'; +UPDATE identity.users SET avatar_asset_id = '12000000-0000-7000-8000-000000000002' +WHERE id = '11000000-0000-7000-8000-000000000002'; +UPDATE identity.users SET avatar_asset_id = '12000000-0000-7000-8000-000000000003' +WHERE id = '11000000-0000-7000-8000-000000000003'; + +INSERT INTO pet_health.breeds (id, species, code, display_name, sort_order) +VALUES + ('13000000-0000-7000-8000-000000000001', 'dog', 'shiba-inu', '柴犬', 10), + ('13000000-0000-7000-8000-000000000002', 'dog', 'golden-retriever', '金毛寻回犬', 20), + ('13000000-0000-7000-8000-000000000003', 'dog', 'corgi', '柯基', 30), + ('13000000-0000-7000-8000-000000000004', 'cat', 'british-shorthair', '英国短毛猫', 10); + +INSERT INTO pet_health.pets + (id, name, species, breed_id, sex, birth_date, personality, avatar_asset_id, microchip_no, sterilized_on) +VALUES + ( + '14000000-0000-7000-8000-000000000001', '豆豆', 'dog', + '13000000-0000-7000-8000-000000000001', 'male', DATE '2024-05-15', '活泼', + '12000000-0000-7000-8000-000000000004', 'CHIP-DEMO-0001', DATE '2025-01-10' + ); + +INSERT INTO pet_health.pet_owners (pet_id, user_id, role, is_primary) +VALUES + ('14000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000001', 'owner', true); + +INSERT INTO pet_health.pet_weight_records + (id, pet_id, weight_kg, measured_at, source, note) +VALUES + ('14100000-0000-7000-8000-000000000001', '14000000-0000-7000-8000-000000000001', 4.80, now() - interval '90 days', 'manual', '成长记录'), + ('14100000-0000-7000-8000-000000000002', '14000000-0000-7000-8000-000000000001', 5.20, now() - interval '1 day', 'manual', '当前体重'); + +INSERT INTO marketplace.providers + (id, owner_user_id, kind, slug, name, description, region_id, address_line, latitude, longitude, + cover_asset_id, verification_status, verified_at, is_24h, rating_avg, rating_count, status) +VALUES + ( + '16000000-0000-7000-8000-000000000001', NULL, 'hospital', 'anchong-animal-hospital', + '安宠动物医院（朝阳旗舰店）', '猫科内科 · 骨外科 · 预防医学 · 24H急诊', + '10000000-0000-7000-8000-000000000001', '示例医疗街 10 号', 39.927800, 116.450900, + '12000000-0000-7000-8000-000000000007', + 'verified', now() - interval '1 year', true, 4.90, 138, 'active' + ), + ( + '16000000-0000-7000-8000-000000000002', NULL, 'grooming', 'pawspa-chaoyang', + 'PawSpa 高级宠物沙龙', '资深美容师主理 · 环境静音 · 猫咪免应激', + '10000000-0000-7000-8000-000000000001', '示例商业街 28 号', 39.915900, 116.430800, + '12000000-0000-7000-8000-000000000008', + 'verified', now() - interval '200 days', false, 4.90, 86, 'active' + ), + ( + '16000000-0000-7000-8000-000000000003', '11000000-0000-7000-8000-000000000003', 'personal', 'sunny-dog-walker', + '阳光遛狗员－阿健', '资深铲屎官，提供耐心、安全的上门遛狗服务。', + '10000000-0000-7000-8000-000000000001', '朝阳区上门服务', 39.919500, 116.439200, + '12000000-0000-7000-8000-000000000009', + 'verified', now() - interval '100 days', false, 4.90, 42, 'active' + ); + +INSERT INTO marketplace.provider_tags (provider_id, tag) +VALUES + ('16000000-0000-7000-8000-000000000001', '猫专科认证'), + ('16000000-0000-7000-8000-000000000001', '24H急诊'), + ('16000000-0000-7000-8000-000000000002', '日系精修'), + ('16000000-0000-7000-8000-000000000002', '猫咪免应激'), + ('16000000-0000-7000-8000-000000000003', '实时定位'), + ('16000000-0000-7000-8000-000000000003', '自带清洁包'), + ('16000000-0000-7000-8000-000000000003', '只接中小型犬'); + +INSERT INTO marketplace.service_offerings + (id, provider_id, category, name, description, base_price_cents, pricing_unit, duration_minutes) +VALUES + ('16100000-0000-7000-8000-000000000001', '16000000-0000-7000-8000-000000000001', 'hospital', '宠物基础问诊', '基础体格检查与问诊', 29900, 'visit', 30), + ('16100000-0000-7000-8000-000000000002', '16000000-0000-7000-8000-000000000002', 'grooming', '宠物精洗美容', '洗护及基础造型', 15800, 'service', 90), + ('16100000-0000-7000-8000-000000000003', '16000000-0000-7000-8000-000000000003', 'walking', '上门遛狗 60 分钟', '实时定位并反馈照片', 4500, 'hour', 60); + +INSERT INTO marketplace.service_resources + (id, provider_id, name, resource_type) +VALUES + ('16200000-0000-7000-8000-000000000001', '16000000-0000-7000-8000-000000000001', '问诊室 A', 'room'), + ('16200000-0000-7000-8000-000000000002', '16000000-0000-7000-8000-000000000002', '美容师小林', 'person'), + ('16200000-0000-7000-8000-000000000003', '16000000-0000-7000-8000-000000000003', '阿健', 'person'); + +INSERT INTO marketplace.offering_resources (provider_id, offering_id, resource_id) +VALUES + ('16000000-0000-7000-8000-000000000001', '16100000-0000-7000-8000-000000000001', '16200000-0000-7000-8000-000000000001'), + ('16000000-0000-7000-8000-000000000002', '16100000-0000-7000-8000-000000000002', '16200000-0000-7000-8000-000000000002'), + ('16000000-0000-7000-8000-000000000003', '16100000-0000-7000-8000-000000000003', '16200000-0000-7000-8000-000000000003'); + +INSERT INTO marketplace.bookings + (id, customer_user_id, pet_id, provider_id, offering_id, resource_id, + scheduled_start_at, scheduled_end_at, status, + provider_name_snapshot, service_name_snapshot, pet_name_snapshot, address_snapshot, + base_amount_cents, discount_amount_cents, payable_amount_cents, idempotency_key, request_hash) +VALUES + ( + '16300000-0000-7000-8000-000000000001', + '11000000-0000-7000-8000-000000000001', '14000000-0000-7000-8000-000000000001', + '16000000-0000-7000-8000-000000000003', '16100000-0000-7000-8000-000000000003', + '16200000-0000-7000-8000-000000000003', + timestamptz '2030-08-20 09:00:00+08', timestamptz '2030-08-20 10:00:00+08', 'confirmed', + '阳光遛狗员－阿健', '上门遛狗 60 分钟', '豆豆', '北京市朝阳区上门服务', + 4500, 2000, 2500, 'fixture-booking-1', decode(repeat('31', 32), 'hex') + ); + +INSERT INTO marketplace.booking_status_history + (booking_id, from_status, to_status, actor_user_id, reason) +VALUES + ('16300000-0000-7000-8000-000000000001', NULL, 'confirmed', '11000000-0000-7000-8000-000000000001', '开发测试预约'); + +INSERT INTO pet_health.vaccine_catalog (id, code, name, species) +VALUES + ('15000000-0000-7000-8000-000000000001', 'dog-combo-5', '犬五联', 'dog'), + ('15000000-0000-7000-8000-000000000002', 'rabies', '狂犬疫苗', 'dog'); + +INSERT INTO pet_health.pet_vaccinations + (id, pet_id, vaccine_id, series_key, dose_no, dose_label, status, planned_on, administered_on, + next_due_on, provider_id, provider_name_snapshot, certificate_asset_id) +VALUES + ( + '15100000-0000-7000-8000-000000000001', '14000000-0000-7000-8000-000000000001', + '15000000-0000-7000-8000-000000000001', '2025-primary', 1, '第1针', 'completed', + DATE '2025-05-12', DATE '2025-05-12', DATE '2025-07-15', + '16000000-0000-7000-8000-000000000001', '安宠动物医院（朝阳旗舰店）', + '12000000-0000-7000-8000-000000000010' + ), + ( + '15100000-0000-7000-8000-000000000002', '14000000-0000-7000-8000-000000000001', + '15000000-0000-7000-8000-000000000002', '2025-rabies', 1, '年度接种', 'completed', + DATE '2025-06-15', DATE '2025-06-15', DATE '2026-06-15', + '16000000-0000-7000-8000-000000000001', '安宠动物医院（朝阳旗舰店）', NULL + ), + ( + '15100000-0000-7000-8000-000000000003', '14000000-0000-7000-8000-000000000001', + '15000000-0000-7000-8000-000000000001', '2025-primary', 2, '加强针', 'scheduled', + DATE '2026-08-15', NULL, NULL, NULL, NULL, NULL + ); + +INSERT INTO pet_health.health_events + (id, pet_id, event_type, occurred_at, title, notes, amount_cents, provider_id, provider_name_snapshot, created_by_user_id) +VALUES + ( + '15200000-0000-7000-8000-000000000002', '14000000-0000-7000-8000-000000000001', + 'feeding', timestamptz '2025-05-20 18:00:00+08', '更换幼犬粮', '体重增长稳定', 20000, + NULL, NULL, '11000000-0000-7000-8000-000000000001' + ); + +INSERT INTO pet_health.care_reminders + (id, pet_id, reminder_type, title, due_at) +VALUES + ( + '15300000-0000-7000-8000-000000000002', '14000000-0000-7000-8000-000000000001', + 'deworming', '安排体内外驱虫', timestamptz '2026-08-16 09:00:00+08' + ); + +INSERT INTO creation.generation_models + (id, code, display_name, provider_code, provider_model_name, media_kind, sort_order) +VALUES + ('17000000-0000-7000-8000-000000000001', 'patbond-v1', 'Patbond-V1', 'fixture', 'patbond-image-v1', 'image', 10), + ('17000000-0000-7000-8000-000000000002', 'patbond-v1', 'Patbond-V1', 'fixture', 'patbond-video-v1', 'video', 10); + +INSERT INTO creation.generation_styles + (id, code, title, subtitle, media_kind, preview_asset_id, sort_order) +VALUES + ('17100000-0000-7000-8000-000000000001', 'healing', '治愈动画', '梦幻动漫感', 'image', '12000000-0000-7000-8000-000000000005', 10), + ('17100000-0000-7000-8000-000000000002', '3d-cartoon', '3D 卡通', '经典渲染', 'image', '12000000-0000-7000-8000-000000000005', 20), + ('17100000-0000-7000-8000-000000000003', 'comic', '漫画风', '帅气网格', 'image', '12000000-0000-7000-8000-000000000005', 30), + ('17100000-0000-7000-8000-000000000004', 'watercolor', '水彩', '柔和手绘质感', 'image', '12000000-0000-7000-8000-000000000005', 40), + ('17100000-0000-7000-8000-000000000005', 'healing', '治愈短片', '梦幻动态效果', 'video', '12000000-0000-7000-8000-000000000005', 10); + +INSERT INTO creation.generation_jobs + (id, user_id, pet_id, media_kind, model_id, style_id, input_asset_id, output_asset_id, + prompt, width_px, height_px, upscale, parameters, status, progress, attempt_count, + provider_code_snapshot, provider_model_snapshot, model_version_snapshot, style_code_snapshot, + provider_request_id, idempotency_key, request_hash, created_at, started_at, completed_at) +VALUES + ( + '17200000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000001', + '14000000-0000-7000-8000-000000000001', 'image', + '17000000-0000-7000-8000-000000000001', '17100000-0000-7000-8000-000000000001', + '12000000-0000-7000-8000-000000000004', '12000000-0000-7000-8000-000000000005', + '把豆豆生成治愈系插画', 1920, 1080, true, '{}'::jsonb, + 'succeeded', 100, 1, 'fixture', 'patbond-image-v1', '1.0', 'healing', + 'fixture-provider-job-1', 'fixture-generation-1', decode(repeat('41', 32), 'hex'), + now() - interval '3 hours', now() - interval '2 hours 59 minutes', now() - interval '2 hours 55 minutes' + ); + +INSERT INTO community.posts + (id, author_user_id, pet_id, generation_job_id, category, title, content, status, visibility, + region_id, location_text_snapshot, like_count, comment_count, bookmark_count, + idempotency_key, request_hash, created_at, published_at) +VALUES + ( + '18000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000001', + '14000000-0000-7000-8000-000000000001', '17200000-0000-7000-8000-000000000001', + 'ai_creation', '豆豆的治愈动画冒险', + '用 AI 把豆豆生成了治愈系插画，太可爱了吧！大家也快去试试创作功能！✨', + 'published', 'public', '10000000-0000-7000-8000-000000000001', '北京市 · 朝阳区', + 2, 2, 1, 'fixture-post-1', decode(repeat('51', 32), 'hex'), + now() - interval '2 hours', now() - interval '2 hours' + ), + ( + '18000000-0000-7000-8000-000000000002', '11000000-0000-7000-8000-000000000003', + NULL, NULL, 'help', NULL, '猫咪最近总是挠耳朵，有懂的朋友吗？', + 'published', 'public', '10000000-0000-7000-8000-000000000002', '上海市 · 浦东新区', + 1, 1, 0, 'fixture-post-2', decode(repeat('52', 32), 'hex'), + now() - interval '5 hours', now() - interval '5 hours' + ); + +INSERT INTO community.post_media (post_id, position, asset_id, is_cover) +VALUES + ('18000000-0000-7000-8000-000000000001', 0, '12000000-0000-7000-8000-000000000005', true), + ('18000000-0000-7000-8000-000000000002', 0, '12000000-0000-7000-8000-000000000006', true); + +INSERT INTO community.comments + (id, post_id, author_user_id, content, client_request_id, request_hash, created_at) +VALUES + ( + '18100000-0000-7000-8000-000000000001', '18000000-0000-7000-8000-000000000001', + '11000000-0000-7000-8000-000000000002', '这也太像了吧！求教程怎么生成的？', 'fixture-comment-1', decode(repeat('61', 32), 'hex'), + now() - interval '1 hour' + ), + ( + '18100000-0000-7000-8000-000000000002', '18000000-0000-7000-8000-000000000001', + '11000000-0000-7000-8000-000000000003', '好可爱的画风，豆豆真上镜！', 'fixture-comment-2', decode(repeat('62', 32), 'hex'), + now() - interval '45 minutes' + ), + ( + '18100000-0000-7000-8000-000000000003', '18000000-0000-7000-8000-000000000002', + '11000000-0000-7000-8000-000000000002', '建议先去医院检查耳道，不要自行用药哦。', 'fixture-comment-3', decode(repeat('63', 32), 'hex'), + now() - interval '4 hours' + ); + +INSERT INTO community.post_likes (post_id, user_id, created_at) +VALUES + ('18000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000002', now() - interval '1 hour'), + ('18000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000003', now() - interval '30 minutes'), + ('18000000-0000-7000-8000-000000000002', '11000000-0000-7000-8000-000000000001', now() - interval '3 hours'); + +INSERT INTO community.post_bookmarks (post_id, user_id) +VALUES + ('18000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000002'); + +INSERT INTO community.user_follows (follower_user_id, followee_user_id) +VALUES + ('11000000-0000-7000-8000-000000000002', '11000000-0000-7000-8000-000000000001'), + ('11000000-0000-7000-8000-000000000003', '11000000-0000-7000-8000-000000000001'); + +INSERT INTO community.topics (id, name) +VALUES + ('18200000-0000-7000-8000-000000000001', 'AI创作'), + ('18200000-0000-7000-8000-000000000002', '柴犬'), + ('18200000-0000-7000-8000-000000000003', 'Patbond'), + ('18200000-0000-7000-8000-000000000004', '猫咪健康'), + ('18200000-0000-7000-8000-000000000005', '求助'); + +INSERT INTO community.post_topics (post_id, topic_id) +VALUES + ('18000000-0000-7000-8000-000000000001', '18200000-0000-7000-8000-000000000001'), + ('18000000-0000-7000-8000-000000000001', '18200000-0000-7000-8000-000000000002'), + ('18000000-0000-7000-8000-000000000001', '18200000-0000-7000-8000-000000000003'), + ('18000000-0000-7000-8000-000000000002', '18200000-0000-7000-8000-000000000004'), + ('18000000-0000-7000-8000-000000000002', '18200000-0000-7000-8000-000000000005'); + +INSERT INTO platform.notifications + (id, user_id, notification_type, title, body, target_type, target_id) +VALUES + ( + '19000000-0000-7000-8000-000000000001', '11000000-0000-7000-8000-000000000001', + 'health.reminder', '豆豆的健康提醒', '犬五联加强针将在 2026-08-15 到期。', + 'vaccination', '15100000-0000-7000-8000-000000000003' + ); + +INSERT INTO platform.outbox_events + (id, aggregate_type, aggregate_id, aggregate_version, event_type, payload) +VALUES + ( + '19100000-0000-7000-8000-000000000001', 'generation_job', + '17200000-0000-7000-8000-000000000001', 1, 'creation.generation_succeeded', + '{"fixture":true,"outputAssetId":"12000000-0000-7000-8000-000000000005"}'::jsonb + ); + +ANALYZE; + +/* ------------------------------------------------------------------------- + Executable integrity checks. Any unexpected condition aborts the transaction. +--------------------------------------------------------------------------- */ + +DO $$ +DECLARE + rejected boolean := false; +BEGIN + BEGIN + INSERT INTO identity.users (username, nickname) VALUES ('DEMO_USER', '重复用户名'); + EXCEPTION WHEN unique_violation THEN + rejected := true; + END; + IF NOT rejected THEN + RAISE EXCEPTION 'validation failed: username uniqueness is not case-insensitive'; + END IF; +END; +$$; + +DO $$ +DECLARE + rejected boolean := false; +BEGIN + BEGIN + INSERT INTO pet_health.pet_weight_records (pet_id, weight_kg, measured_at) + VALUES ('14000000-0000-7000-8000-000000000001', -1, now()); + EXCEPTION WHEN check_violation THEN + rejected := true; + END; + IF NOT rejected THEN + RAISE EXCEPTION 'validation failed: negative pet weight was accepted'; + END IF; +END; +$$; + +DO $$ +DECLARE + rejected boolean := false; +BEGIN + BEGIN + INSERT INTO identity.user_addresses + (user_id, region_id, label, address_line, latitude, longitude) + VALUES + ( + '11000000-0000-7000-8000-000000000001', + '10000000-0000-7000-8000-000000000001', + '错误坐标', '只填写经度的地址', NULL, 116.443550 + ); + EXCEPTION WHEN check_violation THEN + rejected := true; + END; + IF NOT rejected THEN + RAISE EXCEPTION 'validation failed: one-sided coordinates were accepted'; + END IF; +END; +$$; + +DO $$ +DECLARE + rejected boolean := false; +BEGIN + BEGIN + INSERT INTO creation.generation_jobs + (user_id, media_kind, model_id, style_id, input_asset_id, + provider_code_snapshot, provider_model_snapshot, model_version_snapshot, style_code_snapshot, + idempotency_key, request_hash) + VALUES + ( + '11000000-0000-7000-8000-000000000001', 'video', + '17000000-0000-7000-8000-000000000001', + '17100000-0000-7000-8000-000000000005', + '12000000-0000-7000-8000-000000000004', + 'fixture', 'wrong-kind-test', '1.0', 'healing', + 'fixture-wrong-kind-must-fail', decode(repeat('71', 32), 'hex') + ); + EXCEPTION WHEN foreign_key_violation THEN + rejected := true; + END; + IF NOT rejected THEN + RAISE EXCEPTION 'validation failed: AI job accepted a model of the wrong media kind'; + END IF; +END; +$$; + +DO $$ +BEGIN + IF EXISTS ( + SELECT 1 + FROM community.posts p + LEFT JOIN LATERAL ( + SELECT count(*) AS value FROM community.post_likes l WHERE l.post_id = p.id + ) likes ON true + LEFT JOIN LATERAL ( + SELECT count(*) AS value FROM community.comments c + WHERE c.post_id = p.id AND c.status = 'visible' + ) comments ON true + LEFT JOIN LATERAL ( + SELECT count(*) AS value FROM community.post_bookmarks b WHERE b.post_id = p.id + ) bookmarks ON true + WHERE p.like_count <> likes.value + OR p.comment_count <> comments.value + OR p.bookmark_count <> bookmarks.value + ) THEN + RAISE EXCEPTION 'validation failed: post counter cache does not match relation facts'; + END IF; +END; +$$; + +DO $$ +DECLARE + rejected boolean := false; +BEGIN + BEGIN + INSERT INTO marketplace.bookings + (customer_user_id, pet_id, provider_id, offering_id, resource_id, + scheduled_start_at, scheduled_end_at, status, + provider_name_snapshot, service_name_snapshot, pet_name_snapshot, address_snapshot, + base_amount_cents, discount_amount_cents, payable_amount_cents, idempotency_key, request_hash) + VALUES + ( + '11000000-0000-7000-8000-000000000001', '14000000-0000-7000-8000-000000000001', + '16000000-0000-7000-8000-000000000003', '16100000-0000-7000-8000-000000000003', + '16200000-0000-7000-8000-000000000003', + timestamptz '2030-08-20 09:30:00+08', timestamptz '2030-08-20 10:30:00+08', 'confirmed', + '阳光遛狗员－阿健', '上门遛狗 60 分钟', '豆豆', '北京市朝阳区上门服务', + 4500, 0, 4500, 'fixture-overlap-must-fail', decode(repeat('72', 32), 'hex') + ); + EXCEPTION WHEN exclusion_violation THEN + rejected := true; + END; + IF NOT rejected THEN + RAISE EXCEPTION 'validation failed: overlapping booking was accepted'; + END IF; +END; +$$; + +DO $$ +DECLARE + inserted_id uuid; +BEGIN + INSERT INTO marketplace.bookings + (customer_user_id, pet_id, provider_id, offering_id, resource_id, + scheduled_start_at, scheduled_end_at, status, + provider_name_snapshot, service_name_snapshot, pet_name_snapshot, address_snapshot, + base_amount_cents, discount_amount_cents, payable_amount_cents, idempotency_key, request_hash) + VALUES + ( + '11000000-0000-7000-8000-000000000001', '14000000-0000-7000-8000-000000000001', + '16000000-0000-7000-8000-000000000003', '16100000-0000-7000-8000-000000000003', + '16200000-0000-7000-8000-000000000003', + timestamptz '2030-08-20 10:00:00+08', timestamptz '2030-08-20 11:00:00+08', 'confirmed', + '阳光遛狗员－阿健', '上门遛狗 60 分钟', '豆豆', '北京市朝阳区上门服务', + 4500, 0, 4500, 'fixture-adjacent-booking', decode(repeat('73', 32), 'hex') + ) + RETURNING id INTO inserted_id; + + DELETE FROM marketplace.bookings WHERE id = inserted_id; +END; +$$; + +DO $$ +DECLARE + missing_indexes text; +BEGIN + WITH foreign_keys AS ( + SELECT c.oid, c.conname, c.conrelid, c.conkey + FROM pg_constraint c + JOIN pg_namespace n ON n.oid = c.connamespace + WHERE c.contype = 'f' + AND n.nspname IN ('platform', 'identity', 'media', 'pet_health', 'community', 'creation', 'marketplace') + ), missing AS ( + SELECT fk.conname + FROM foreign_keys fk + WHERE NOT EXISTS ( + SELECT 1 + FROM pg_index i + WHERE i.indrelid = fk.conrelid + AND i.indisvalid + AND i.indpred IS NULL + AND fk.conkey = ( + SELECT array_agg(k.attnum ORDER BY k.ordinality)::smallint[] + FROM unnest(i.indkey) WITH ORDINALITY AS k(attnum, ordinality) + WHERE k.ordinality <= cardinality(fk.conkey) + ) + ) + ) + SELECT string_agg(conname, ', ' ORDER BY conname) INTO missing_indexes FROM missing; + + IF missing_indexes IS NOT NULL THEN + RAISE EXCEPTION 'validation failed: foreign keys without leading indexes: %', missing_indexes; + END IF; +END; +$$; + +COMMIT; + +/* ------------------------------------------------------------------------- + Reference queries for the future API repositories +--------------------------------------------------------------------------- */ + +-- Pet health summary: latest weight + vaccine progress + next scheduled dose. +SELECT + p.id, + p.name, + latest_weight.weight_kg, + vaccine_summary.completed_doses, + vaccine_summary.total_doses, + vaccine_summary.next_planned_on +FROM pet_health.pets p +LEFT JOIN LATERAL ( + SELECT w.weight_kg + FROM pet_health.pet_weight_records w + WHERE w.pet_id = p.id + ORDER BY w.measured_at DESC, w.id DESC + LIMIT 1 +) latest_weight ON true +LEFT JOIN LATERAL ( + SELECT + count(*) FILTER (WHERE v.status = 'completed') AS completed_doses, + count(*) FILTER (WHERE v.status <> 'cancelled') AS total_doses, + min(v.planned_on) FILTER (WHERE v.status = 'scheduled') AS next_planned_on + FROM pet_health.pet_vaccinations v + WHERE v.pet_id = p.id +) vaccine_summary ON true +WHERE p.status = 'active'; + +-- Nearby providers: first use the indexed bounding box, then exact Haversine. +-- The +/- 0.10 degree fixture box is illustrative; the API must calculate a +-- latitude-aware box from the requested radius before binding these values. +WITH candidates AS ( + SELECT + p.id, + p.name, + p.kind, + p.rating_avg, + platform.distance_km(39.921900, 116.443550, p.latitude, p.longitude) AS distance_km + FROM marketplace.providers p + WHERE p.status = 'active' + AND p.region_id = '10000000-0000-7000-8000-000000000001' + AND p.latitude BETWEEN 39.821900 AND 40.021900 + AND p.longitude BETWEEN 116.343550 AND 116.543550 +) +SELECT id, name, kind, rating_avg, distance_km +FROM candidates +WHERE distance_km <= 10.0 +ORDER BY distance_km, rating_avg DESC, id +LIMIT 20; + +-- Cursor feed query; never use deep OFFSET pagination. +SELECT p.* +FROM community.posts p +WHERE p.status = 'published' + AND p.visibility = 'public' + AND (p.published_at, p.id) < (now(), 'ffffffff-ffff-ffff-ffff-ffffffffffff'::uuid) +ORDER BY p.published_at DESC, p.id DESC +LIMIT 20; + +/* + Atomic like write used by the backend (placeholders intentionally commented): + + WITH inserted AS ( + INSERT INTO community.post_likes(post_id, user_id) + VALUES (:post_id, :user_id) + ON CONFLICT DO NOTHING + RETURNING post_id + ) + UPDATE community.posts p + SET like_count = p.like_count + 1 + FROM inserted i + WHERE p.id = i.post_id + RETURNING p.like_count; + + AI worker claim pattern for multiple concurrent workers: + + WITH picked AS ( + SELECT id + FROM creation.generation_jobs + WHERE status = 'queued' + AND attempt_count < max_attempts + AND next_attempt_at <= now() + ORDER BY priority DESC, next_attempt_at, created_at, id + FOR UPDATE SKIP LOCKED + LIMIT 1 + ) + UPDATE creation.generation_jobs j + SET status = 'running', started_at = now(), progress = 1, + attempt_count = attempt_count + 1, + lease_owner = :worker_id, lease_expires_at = now() + interval '2 minutes', + version = version + 1 + FROM picked + WHERE j.id = picked.id + RETURNING j.*; + + Held-booking sweeper. This worker is mandatory because CHECK constraints must + not use volatile now() in a partial index or exclusion predicate: + + WITH expired AS ( + SELECT id + FROM marketplace.bookings + WHERE status = 'held' AND hold_expires_at <= now() + ORDER BY hold_expires_at, id + FOR UPDATE SKIP LOCKED + LIMIT 100 + ) + UPDATE marketplace.bookings b + SET status = 'expired', hold_expires_at = NULL, version = version + 1 + FROM expired e + WHERE b.id = e.id + RETURNING b.id; + + Pet authorization is a domain rule, not implied by a pet foreign key. Before + creating a post, AI job, or booking, the service must require an allowed row: + + SELECT 1 + FROM pet_health.pet_owners po + WHERE po.pet_id = :pet_id + AND po.user_id = :authenticated_user_id + AND po.role IN ('owner', 'caregiver'); + + Business aggregate updates use explicit optimistic compare-and-swap. High + frequency counters do not increment the content version: + + UPDATE pet_health.pets + SET name = :name, version = version + 1 + WHERE id = :pet_id AND version = :expected_version + RETURNING version; +*/