valitydev/fraudbusters-compose
14
0
Fork 0
mirror of https://github.com/valitydev/fraudbusters-compose.git synced 2024-11-06 08:25:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix sql scripts

Browse Source
This commit is contained in:
k.struzhkin 2020-07-10 18:22:54 +03:00
parent 7309653e5f
commit 66cbb30b3a
2 changed files with 129 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

127
clickhouse/docker-entrypoint-initdb.d/init-db.sh
View File

@ -238,4 +238,131 @@ clickhouse client -n <<-EOSQL
) ENGINE = ReplacingMergeTree()
PARTITION BY toYYYYMM (timestamp)
ORDER BY (eventTimeHour, partyId, shopId, category, status, currency, providerId, fingerprint, cardToken, id, paymentId);
DROP TABLE IF EXISTS fraud.refund;
create table fraud.refund
(
timestamp Date,
eventTime UInt64,
eventTimeHour UInt64,
id String,
email String,
ip String,
fingerprint String,
bin String,
maskedPan String,
cardToken String,
paymentSystem String,
paymentTool String,
terminal String,
providerId String,
bankCountry String,
partyId String,
shopId String,
amount UInt64,
currency String,
status Enum8('pending' = 1, 'succeeded' = 2, 'failed' = 3),
errorReason String,
errorCode String,
paymentId String
) ENGINE = ReplacingMergeTree()
PARTITION BY toYYYYMM (timestamp)
ORDER BY (eventTimeHour, partyId, shopId, status, currency, providerId, fingerprint, cardToken, id, paymentId);
DROP TABLE IF EXISTS fraud.payment;
create table fraud.payment
(
timestamp Date,
eventTime UInt64,
eventTimeHour UInt64,
id String,
email String,
ip String,
fingerprint String,
bin String,
maskedPan String,
cardToken String,
paymentSystem String,
paymentTool String,
terminal String,
providerId String,
bankCountry String,
partyId String,
shopId String,
amount UInt64,
currency String,
status Enum8('pending' = 1, 'processed' = 2, 'captured' = 3, 'cancelled' = 4, 'failed' = 5),
errorReason String,
errorCode String,
paymentCountry String
) ENGINE = ReplacingMergeTree()
PARTITION BY toYYYYMM (timestamp)
ORDER BY (eventTimeHour, partyId, shopId, paymentTool, status, currency, providerId, fingerprint, cardToken, id);
DROP TABLE IF EXISTS fraud.chargeback;
create table fraud.chargeback
(
timestamp Date,
eventTime UInt64,
eventTimeHour UInt64,
id String,
email String,
ip String,
fingerprint String,
bin String,
maskedPan String,
cardToken String,
paymentSystem String,
paymentTool String,
terminal String,
providerId String,
bankCountry String,
partyId String,
shopId String,
amount UInt64,
currency String,
status Enum8('accepted' = 1, 'rejected' = 2, 'cancelled' = 3),
category Enum8('fraud' = 1, 'dispute' = 2, 'authorisation' = 3, 'processing_error' = 4),
chargebackCode String,
paymentId String
) ENGINE = ReplacingMergeTree()
PARTITION BY toYYYYMM (timestamp)
ORDER BY (eventTimeHour, partyId, shopId, category, status, currency, providerId, fingerprint, cardToken, id, paymentId);
ALTER TABLE fraud.events_unique ADD COLUMN payerType String;
ALTER TABLE fraud.events_unique ADD COLUMN tokenProvider String;
ALTER TABLE fraud.payment ADD COLUMN payerType String;
ALTER TABLE fraud.payment ADD COLUMN tokenProvider String;
ALTER TABLE fraud.refund ADD COLUMN payerType String;
ALTER TABLE fraud.refund ADD COLUMN tokenProvider String;
ALTER TABLE fraud.chargeback ADD COLUMN payerType String;
ALTER TABLE fraud.chargeback ADD COLUMN tokenProvider String;
EOSQL

4
docker-compose.yml
View File

@ -163,8 +163,8 @@ services:
depends_on:
- clickhouse
- broker
# - columbus
# - wblist
- columbus
- wblist
- kafka-setup
ports:
- 8999:8022