交易与账户数据模型

// Constraints
CREATE CONSTRAINT customer_id IF NOT EXISTS
FOR (c:Customer) REQUIRE c.customerId IS NODE KEY;

CREATE CONSTRAINT email_address IF NOT EXISTS
FOR (e:Email) REQUIRE e.address IS NODE KEY;

CREATE CONSTRAINT phone_number IF NOT EXISTS
FOR (p:Phone) REQUIRE p.number IS NODE KEY;

CREATE CONSTRAINT passport_composite IF NOT EXISTS
FOR (p:Passport) REQUIRE (p.passportNumber, p.issuingCountry) IS NODE KEY;

CREATE CONSTRAINT driving_license_composite IF NOT EXISTS
FOR (d:DrivingLicense) REQUIRE (d.licenseNumber, d.issuingCountry) IS NODE KEY;

CREATE CONSTRAINT device_id IF NOT EXISTS
FOR (d:Device) REQUIRE d.deviceId IS NODE KEY;

CREATE CONSTRAINT ip_address IF NOT EXISTS
FOR (i:IP) REQUIRE i.ipAddress IS NODE KEY;

CREATE CONSTRAINT session_id IF NOT EXISTS
FOR (s:Session) REQUIRE s.sessionId IS NODE KEY;

CREATE CONSTRAINT account_number IF NOT EXISTS
FOR (a:Account) REQUIRE a.accountNumber IS NODE KEY;

CREATE CONSTRAINT transaction_id IF NOT EXISTS
FOR (t:Transaction) REQUIRE t.transactionId IS NODE KEY;

CREATE CONSTRAINT face_id IF NOT EXISTS
FOR (f:Face) REQUIRE f.faceId IS NODE KEY;

CREATE CONSTRAINT counterparty_id IF NOT EXISTS
FOR (cp:Counterparty) REQUIRE cp.counterpartyId IS NODE KEY;

CREATE CONSTRAINT movement_id IF NOT EXISTS
FOR (m:Movement) REQUIRE m.movementId IS NODE KEY;

CREATE CONSTRAINT isp_name IF NOT EXISTS
FOR (i:ISP) REQUIRE i.name IS NODE KEY;

CREATE CONSTRAINT country_code IF NOT EXISTS
FOR (c:Country) REQUIRE c.code IS NODE KEY;

CREATE CONSTRAINT address_composite IF NOT EXISTS
FOR (a:Address) REQUIRE (a.addressLine1, a.postTown, a.postCode) IS NODE KEY;

// Proposed: Fraud investigation constraints
CREATE CONSTRAINT alert_id IF NOT EXISTS
FOR (a:Alert) REQUIRE a.alertId IS NODE KEY;

CREATE CONSTRAINT case_id IF NOT EXISTS
FOR (c:Case) REQUIRE c.caseId IS NODE KEY;

// Additional Indexes

CREATE INDEX transaction_date_idx IF NOT EXISTS FOR (t:Transaction) ON (t.date);
CREATE INDEX transaction_amount_idx IF NOT EXISTS FOR (t:Transaction) ON (t.amount);

// Vector index for face embeddings (used for biometric matching)
CALL db.index.vector.createNodeIndex(
  'face_embedding_idx',
  'Face',
  'embedding',
  1536,  // dimensionality of the face embeddings (typical range: 512-1536)
  'cosine'  // similarity metric for comparing facial features
);

// Full Text Search

// Full-text index for customer name search
CREATE FULLTEXT INDEX customer_name_idx IF NOT EXISTS FOR (c:Customer) ON EACH [c.firstName, c.lastName, c.middleName];

//--------------------
// Create base countries
//--------------------
CREATE (uk:Country {code: "GB", name: "United Kingdom"})
CREATE (us:Country {code: "US", name: "United States"})

//--------------------
// Create customer and their identity information
//--------------------
// Create main customer node
CREATE (c:Customer {
    customerId: "CUS001",
    firstName: "John",
    middleName: "Michael",
    lastName: "Smith",
    dateOfBirth: date("1990-01-01"),
    placeOfBirth: "Manchester",
    countryOfBirth: "GB"
})

// Create customer's address
CREATE (addr:Address {
    addressLine1: "123 High Street",
    addressLine2: "Flat 4B",
    postTown: "London",
    postCode: "SW1A 1AA",
    region: "Greater London",
    latitude: 51.5074,
    longitude: -0.1278,
    createdAt: datetime("2024-01-01T00:00:00")
})

// Create customer's contact information
CREATE (e:Email {
    address: "john@example.com",
    domain: "example.com",
    createdAt: datetime("2024-01-01T00:00:00")
})
CREATE (ph:Phone {
    number: "447971020304",
    countryCode: "+44",
    createdAt: datetime("2024-01-01T00:00:00")
})

// Create customer's identity documents
CREATE (p:Passport {
    passportNumber: "123456789",
    issueDate: date("2020-01-01"),
    expiryDate: date("2030-01-01"),
    issuingCountry: "GB",
    nationality: "British",
    createdAt: datetime("2024-01-01T00:00:00")
})
CREATE (dl:DrivingLicense {
    licenseNumber: "SMITH901011J99AB",
    issueDate: date("2018-01-01"),
    expiryDate: date("2028-01-01"),
    issuingCountry: "GB",
    createdAt: datetime("2024-01-01T00:00:00")
})

// Create customer's face biometric
CREATE (f:Face {
    faceId: "FACE001",
    embedding: [0.153, 0.254, 0.255, 0.0, 0.0, 0.253, 0.200, 0.252, 0.254, 0.100, 0.253],  // Truncated example of 1536-dimension vector
    createdAt: datetime("2024-01-01T00:00:00")
})

//--------------------
// Create all identity relationships
//--------------------
// Link customer to their identity information
CREATE (c)-[:HAS_ADDRESS {
    addedAt: datetime("2024-01-01T00:00:00"),
    lastChangedAt: datetime("2024-01-01T00:00:00"),
    isCurrent: true
}]->(addr)
CREATE (addr)-[:LOCATED_IN]->(uk)
CREATE (c)-[:HAS_EMAIL {since: datetime("2024-01-01T00:00:00")}]->(e)
CREATE (c)-[:HAS_PHONE {since: datetime("2024-01-01T00:00:00")}]->(ph)
CREATE (c)-[:HAS_NATIONALITY]->(uk)

// Link customer to their identity documents
CREATE (c)-[:HAS_PASSPORT {
    verificationDate: datetime("2024-01-01T00:00:00"),
    verificationMethod: "VIDEO_KYC",
    verificationStatus: "VERIFIED"
}]->(p)
CREATE (c)-[:HAS_DRIVING_LICENSE {
    verificationDate: datetime("2024-01-01T00:00:00"),
    verificationMethod: "BRANCH_VERIFIED",
    verificationStatus: "VERIFIED"
}]->(dl)
CREATE (c)-[:HAS_FACE {
    verificationDate: datetime("2024-01-01T00:00:00"),
    verificationMethod: "SELFIE",
    verificationStatus: "VERIFIED"
}]->(f)

//--------------------
// Create digital access nodes
//--------------------
// Create device, IP, ISP, and session information
CREATE (d:Device {
    deviceId: "DEV001",
    deviceType: "desktop",
    userAgent: "Mozilla/5.0 Chrome/91.0",
    createdAt: datetime("2024-01-01T00:00:00")
})
CREATE (ip:IP {ipAddress: "192.168.1.1", createdAt: datetime("2024-01-01T00:00:00")})
CREATE (isp:ISP {name: "BT", createdAt: datetime("2024-01-01T00:00:00")})
CREATE (loc:Location {
    city: "London",
    postCode: "SW1A",
    country: "GB",
    latitude: 51.5074,
    longitude: -0.1278,
    createdAt: datetime("2024-01-01T00:00:00")
})
CREATE (s:Session {
    sessionId: "SESS001",
    status: "success",
    createdAt: datetime("2024-03-01T10:00:00")
})

// Create digital access relationships
CREATE (d)-[:USED_BY {lastUsed: datetime("2024-03-01T10:00:00")}]->(c)
CREATE (s)-[:USES_IP]->(ip)
CREATE (ip)-[:IS_ALLOCATED_TO {createdAt: datetime("2024-01-01T00:00:00")}]->(isp)
CREATE (ip)-[:LOCATED_IN {createdAt: datetime("2024-01-01T00:00:00")}]->(loc)
CREATE (loc)-[:LOCATED_IN]->(uk)
CREATE (s)-[:SESSION_USES_DEVICE]->(d)

//--------------------
// Create banking nodes
//--------------------
// Create internal and external accounts
CREATE (a:Account:Internal {
    accountNumber: "ACC001",
    accountType: "CURRENT",
    openedDate: datetime("2024-01-01T00:00:00"),
    closedDate: null,
    suspendedDate: null
})
CREATE (a2:Account:External:HighRiskJurisdiction {
    accountNumber: "ACC002",
    accountType: null,
    openedDate: null,
    closedDate: null,
    suspendedDate: null
})

// Create transaction
CREATE (t1:Transaction {
    transactionId: "TXN001",
    amount: 1000.00,
    currency: "GBP",
    date: datetime("2024-03-01T11:00:00"),
    message: "Payment for services",
    type: "SWIFT"
})

//--------------------
// Create banking relationships
//--------------------
// Link accounts to customer and countries
CREATE (c)-[:HAS_ACCOUNT {role: "OWNER", since: datetime("2024-01-01T00:00:00")}]->(a)
CREATE (a)-[:IS_HOSTED]->(uk)
CREATE (a2)-[:IS_HOSTED]->(us)

// Create transaction flow
CREATE (a)-[:PERFORMS]->(t1)-[:BENEFITS_TO]->(a2)

//--------------------
// Create movements for transaction (example: insurance claim paid in instalments)
//--------------------
// Create movements
CREATE (m1:Movement {
    movementId: "MOV001",
    amount: 400.00,
    currency: "GBP",
    date: datetime("2024-03-05T10:00:00"),
    description: "Insurance claim payment 1 of 3",
    status: "COMPLETED",
    sequenceNumber: 1,
    authorisedBy: "USER001",
    validatedBy: "MANAGER001",
    createdAt: datetime("2024-03-01T11:00:00")
})
CREATE (m2:Movement {
    movementId: "MOV002",
    amount: 400.00,
    currency: "GBP",
    date: datetime("2024-03-12T10:00:00"),
    description: "Insurance claim payment 2 of 3",
    status: "COMPLETED",
    sequenceNumber: 2,
    authorisedBy: "USER001",
    validatedBy: "MANAGER002",
    createdAt: datetime("2024-03-01T11:00:00")
})
CREATE (m3:Movement {
    movementId: "MOV003",
    amount: 200.00,
    currency: "GBP",
    date: datetime("2024-03-19T10:00:00"),
    description: "Insurance claim payment 3 of 3",
    sequenceNumber: 3,
    authorisedBy: "USER001",
    validatedBy: null,
    createdAt: datetime("2024-03-01T11:00:00")
})

// Link transaction to movements
CREATE (t1)-[:IMPLIED {totalMovements: 3}]->(m1)
CREATE (t1)-[:IMPLIED {totalMovements: 3}]->(m2)
CREATE (t1)-[:IMPLIED {totalMovements: 3}]->(m3)

//--------------------
// Create counterparty
//--------------------
// Create counterparty and their address
CREATE (cp:Counterparty {
    counterpartyId: "CP001",
    name: "ACME Corporation Ltd",
    type: "BUSINESS",
    registrationNumber: "12345678",
    createdAt: datetime("2024-02-01T00:00:00")
})
CREATE (cpAddr:Address {
    addressLine1: "456 Business Park",
    addressLine2: "Suite 100",
    postTown: "Birmingham",
    postCode: "B1 1AA",
    region: "West Midlands",
    latitude: 52.4862,
    longitude: -1.8904,
    createdAt: datetime("2024-02-01T00:00:00")
})

// Link counterparty to address and account
CREATE (cp)-[:HAS_ADDRESS {
    since: datetime("2024-02-01T00:00:00"),
    isCurrent: true
}]->(cpAddr)
CREATE (cpAddr)-[:LOCATED_IN]->(uk)
CREATE (cp)-[:HAS_ACCOUNT {
    since: datetime("2024-02-01T00:00:00")
}]->(a2)

//--------------------
// Create fraud investigation example
//--------------------
// Create a flagged account (demonstrates label-based fraud detection)
CREATE (a3:Account:Internal:Flagged {
    accountNumber: "ACC003",
    accountType: "CURRENT",
    openedDate: datetime("2023-06-15T00:00:00"),
    closedDate: null,
    suspendedDate: null
})
CREATE (a3)-[:IS_HOSTED]->(uk)

// Create a second customer who owns the flagged account
CREATE (c2:Customer {
    customerId: "CUS002",
    firstName: "Jane",
    lastName: "Doe",
    dateOfBirth: date("1985-05-15"),
    placeOfBirth: "Birmingham",
    countryOfBirth: "GB"
})
CREATE (c2)-[:HAS_ACCOUNT {role: "OWNER", since: datetime("2023-06-15T00:00:00")}]->(a3)

// Create transaction from flagged account to high-risk jurisdiction
CREATE (t2:Transaction {
    transactionId: "TXN002",
    amount: 15000.00,
    currency: "GBP",
    date: datetime("2024-03-10T14:30:00"),
    message: "Large transfer",
    type: "SWIFT"
})
CREATE (a3)-[:PERFORMS]->(t2)-[:BENEFITS_TO]->(a2)

// Create alerts that triggered for this account
CREATE (alert1:Alert {
    alertId: "ALERT001",
    ruleName: "Large Transaction to High Risk Jurisdiction",
    ruleId: "RULE_FR_001",
    severity: "HIGH",
    triggeredAt: datetime("2024-03-10T14:35:00")
})
CREATE (alert2:Alert {
    alertId: "ALERT002",
    ruleName: "Unusual Transaction Pattern",
    ruleId: "RULE_FR_015",
    severity: "MEDIUM",
    triggeredAt: datetime("2024-03-10T15:00:00")
})

// Create investigation case (demonstrates production case pattern)
CREATE (case1:Case {
    caseId: "CASE001",
    status: "UNDER_INVESTIGATION",
    outcome: null,
    financialStakes: 15000.00,
    investigatedBy: "FRAUD_TEAM_001",
    createdAt: datetime("2024-03-10T16:00:00"),
    closedAt: null
})

// Link alerts to the case
CREATE (alert1)-[:TRIGGERED]->(case1)
CREATE (alert2)-[:TRIGGERED]->(case1)

// Link account and customer to the investigation case
CREATE (a3)-[:SUBJECT_OF]->(case1)
CREATE (c2)-[:SUBJECT_OF]->(case1)