Icon

FEATURE_​TRANSACTION_​047

UPDATE FEATURE_TRANSACTION_046

SET

FEATURE_TRANSACTION_0047 = CASE WHEN FEATURE_TRANSACTION_0047 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0047 END,

FEATURE_TRANSACTION_0048 = CASE WHEN FEATURE_TRANSACTION_0048 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0048 END,

FEATURE_TRANSACTION_0049 = CASE WHEN FEATURE_TRANSACTION_0049 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0049 END,

FEATURE_TRANSACTION_0050 = CASE WHEN FEATURE_TRANSACTION_0050 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0050 END,

FEATURE_TRANSACTION_0079 = CASE WHEN FEATURE_TRANSACTION_0079 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0079 END,

FEATURE_TRANSACTION_0080 = CASE WHEN FEATURE_TRANSACTION_0080 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0080 END,

FEATURE_TRANSACTION_0081 = CASE WHEN FEATURE_TRANSACTION_0081 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0081 END,

FEATURE_TRANSACTION_0082 = CASE WHEN FEATURE_TRANSACTION_0082 IS NULL THEN 0 ELSE FEATURE_TRANSACTION_0082 END;

UPDATE FEATURE_TRANSACTION_046

SET

FEATURE_TRANSACTION_0047 = ABS(FEATURE_TRANSACTION_0047),

FEATURE_TRANSACTION_0048 = ABS(FEATURE_TRANSACTION_0048),

FEATURE_TRANSACTION_0049 = ABS(FEATURE_TRANSACTION_0049),

FEATURE_TRANSACTION_0050 = ABS(FEATURE_TRANSACTION_0050),

FEATURE_TRANSACTION_0079 = ABS(FEATURE_TRANSACTION_0079),

FEATURE_TRANSACTION_0080 = ABS(FEATURE_TRANSACTION_0080),

FEATURE_TRANSACTION_0081 = ABS(FEATURE_TRANSACTION_0081),

FEATURE_TRANSACTION_0082 = ABS(FEATURE_TRANSACTION_0082);

ALTER TABLE FEATURE_TRANSACTION_046

ADD "Số lần giao dịch chủ động chiều đi" FLOAT;

ALTER TABLE FEATURE_TRANSACTION_046

ADD "Khối lượng giao dịch chủ động chiều đi" FLOAT;

ALTER TABLE FEATURE_TRANSACTION_046

ADD "Số lần giao dịch chủ động chiều đến" FLOAT;

ALTER TABLE FEATURE_TRANSACTION_046

ADD "Khối lượng giao dịch chủ động chiều đến" FLOAT;

UPDATE FEATURE_TRANSACTION_046

SET "Số lần giao dịch chủ động chiều đi" = FEATURE_TRANSACTION_0047 + FEATURE_TRANSACTION_0049;

UPDATE FEATURE_TRANSACTION_046

SET "Khối lượng giao dịch chủ động chiều đi" = FEATURE_TRANSACTION_0048 + FEATURE_TRANSACTION_0050;

UPDATE FEATURE_TRANSACTION_046

SET "Số lần giao dịch chủ động chiều đến" = FEATURE_TRANSACTION_0080 + FEATURE_TRANSACTION_0082;

UPDATE FEATURE_TRANSACTION_046

SET "Khối lượng giao dịch chủ động chiều đến" = FEATURE_TRANSACTION_0079 + FEATURE_TRANSACTION_0081;

CREATE OR REPLACE TABLE FEATURE_TRANSACTION_047 AS

WITH ranked AS (

SELECT

CUSTOMER_ID,

DAY_ID,

"Số lần giao dịch chủ động chiều đi",

"Khối lượng giao dịch chủ động chiều đi",

ROW_NUMBER() OVER (

PARTITION BY CUSTOMER_ID

ORDER BY DAY_ID DESC

) AS rn

FROM FEATURE_TRANSACTION_046

WHERE "Số lần giao dịch chủ động chiều đi" > 0

)

SELECT

CUSTOMER_ID,

DAY_ID AS 'Ngày giao dịch cuối chiều đi',

"Số lần giao dịch chủ động chiều đi" AS 'Số lần giao dịch chủ động chiều đi',

"Khối lượng giao dịch chủ động chiều đi" AS 'Khối lượng giao dịch chủ động chiều đi',

CASE

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 1 MONTH THEN 1

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 4 MONTH THEN 2

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 7 MONTH THEN 3

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 10 MONTH THEN 4

ELSE 5

END AS "Nhóm khách hàng theo recency (chiều đi)"

FROM ranked

WHERE rn = 1;

SELECT CAST("Nhóm khách hàng theo recency (chiều đi)" AS INT) FROM FEATURE_TRANSACTION_047;

ALTER TABLE FEATURE_TRANSACTION_047

ADD "Nhóm khách hàng theo frequency (chiều đi)" INT;

WITH sums AS (

SELECT CUSTOMER_ID, SUM("Số lần giao dịch chủ động chiều đi") AS sum_val

FROM FEATURE_TRANSACTION_046

GROUP BY CUSTOMER_ID

)

UPDATE FEATURE_TRANSACTION_047 t

SET "Nhóm khách hàng theo frequency (chiều đi)" = CASE

WHEN s.sum_val = 0 THEN 1

WHEN s.sum_val BETWEEN 1 AND 2 THEN 2

WHEN s.sum_val BETWEEN 3 AND 9 THEN 3

WHEN s.sum_val BETWEEN 10 AND 29 THEN 4

ELSE 5

END

FROM sums s

WHERE t.CUSTOMER_ID = s.CUSTOMER_ID;

ALTER TABLE FEATURE_TRANSACTION_047

ADD "Nhóm khách hàng theo monetary (chiều đi)" INT;

WITH sums AS (

SELECT CUSTOMER_ID, SUM("Khối lượng giao dịch chủ động chiều đi") AS sum_val

FROM FEATURE_TRANSACTION_046

GROUP BY CUSTOMER_ID

)

UPDATE FEATURE_TRANSACTION_047 t

SET "Nhóm khách hàng theo monetary (chiều đi)" = CASE

WHEN s.sum_val = 0 THEN 1

WHEN s.sum_val BETWEEN 1 AND 2706945 THEN 2

WHEN s.sum_val BETWEEN 2706946 AND 15442000 THEN 3

WHEN s.sum_val BETWEEN 2706946 AND 70083072 THEN 4

ELSE 5

END

FROM sums s

WHERE t.CUSTOMER_ID = s.CUSTOMER_ID;

ALTER TABLE FEATURE_TRANSACTION_047

RENAME COLUMN "Số lần giao dịch chủ động chiều đi" TO FEATURE_TRANSACTION_1176;

ALTER TABLE FEATURE_TRANSACTION_047

RENAME COLUMN "Khối lượng giao dịch chủ động chiều đi" TO FEATURE_TRANSACTION_1177;

ALTER TABLE FEATURE_TRANSACTION_047

RENAME COLUMN "Nhóm khách hàng theo recency (chiều đi)" TO FEATURE_TRANSACTION_1178;

ALTER TABLE FEATURE_TRANSACTION_047

RENAME COLUMN "Nhóm khách hàng theo frequency (chiều đi)" TO FEATURE_TRANSACTION_1179;

ALTER TABLE FEATURE_TRANSACTION_047

RENAME COLUMN "Nhóm khách hàng theo monetary (chiều đi)" TO FEATURE_TRANSACTION_1180;

CREATE OR REPLACE TABLE FEATURE_TRANSACTION_048 AS

WITH ranked AS (

SELECT

CUSTOMER_ID,

DAY_ID,

"Số lần giao dịch chủ động chiều đến",

"Khối lượng giao dịch chủ động chiều đến",

ROW_NUMBER() OVER (

PARTITION BY CUSTOMER_ID

ORDER BY DAY_ID DESC

) AS rn

FROM FEATURE_TRANSACTION_046

WHERE "Số lần giao dịch chủ động chiều đến" > 0

)

SELECT

CUSTOMER_ID,

DAY_ID AS 'Ngày giao dịch cuối chiều đến',

"Số lần giao dịch chủ động chiều đến" AS 'Số lần giao dịch chủ động chiều đến',

"Khối lượng giao dịch chủ động chiều đến" AS 'Khối lượng giao dịch chủ động chiều đến',

CASE

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 1 MONTH THEN 1

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 4 MONTH THEN 2

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 7 MONTH THEN 3

WHEN DAY_ID >= '$${Sdate-input}$$'::date - INTERVAL 10 MONTH THEN 4

ELSE 5

END AS "Nhóm khách hàng theo recency (chiều đến)"

FROM ranked

WHERE rn = 1;

SELECT CAST("Nhóm khách hàng theo recency (chiều đến)" AS INT) FROM FEATURE_TRANSACTION_048;

ALTER TABLE FEATURE_TRANSACTION_048

ADD "Nhóm khách hàng theo frequency (chiều đến)" INT;

WITH sums AS (

SELECT CUSTOMER_ID, SUM("Số lần giao dịch chủ động chiều đến") AS sum_val

FROM FEATURE_TRANSACTION_046

GROUP BY CUSTOMER_ID

)

UPDATE FEATURE_TRANSACTION_048 t

SET "Nhóm khách hàng theo frequency (chiều đến)" = CASE

WHEN s.sum_val = 0 THEN 1

WHEN s.sum_val BETWEEN 1 AND 2 THEN 2

WHEN s.sum_val BETWEEN 3 AND 5 THEN 3

WHEN s.sum_val BETWEEN 6 AND 14 THEN 4

ELSE 5

END

FROM sums s

WHERE t.CUSTOMER_ID = s.CUSTOMER_ID;

ALTER TABLE FEATURE_TRANSACTION_048

ADD "Nhóm khách hàng theo monetary (chiều đến)" INT;

WITH sums AS (

SELECT CUSTOMER_ID, SUM("Khối lượng giao dịch chủ động chiều đến") AS sum_val

FROM FEATURE_TRANSACTION_046

GROUP BY CUSTOMER_ID

)

UPDATE FEATURE_TRANSACTION_048 t

SET "Nhóm khách hàng theo monetary (chiều đến)" = CASE

WHEN s.sum_val = 0 THEN 1

WHEN s.sum_val BETWEEN 1 AND 2894500 THEN 2

WHEN s.sum_val BETWEEN 2894501 AND 15173608 THEN 3

WHEN s.sum_val BETWEEN 15173609 AND 67059100 THEN 4

ELSE 5

END

FROM sums s

WHERE t.CUSTOMER_ID = s.CUSTOMER_ID;

ALTER TABLE FEATURE_TRANSACTION_048

RENAME COLUMN "Số lần giao dịch chủ động chiều đến" TO FEATURE_TRANSACTION_1181;

ALTER TABLE FEATURE_TRANSACTION_048

RENAME COLUMN "Khối lượng giao dịch chủ động chiều đến" TO FEATURE_TRANSACTION_1182;

ALTER TABLE FEATURE_TRANSACTION_048

RENAME COLUMN "Nhóm khách hàng theo recency (chiều đến)" TO FEATURE_TRANSACTION_1183;

ALTER TABLE FEATURE_TRANSACTION_048

RENAME COLUMN "Nhóm khách hàng theo frequency (chiều đến)" TO FEATURE_TRANSACTION_1184;

ALTER TABLE FEATURE_TRANSACTION_048

RENAME COLUMN "Nhóm khách hàng theo monetary (chiều đến)" TO FEATURE_TRANSACTION_1185;

duckdb memory
DB Writer
DB SQL Executor
DB Connector
DB SQL Executor
DB Connection Extractor
Date&Time Configuration
copy "main"."FEATURE_TRANSACTION_048"to 'C:\Users\ASUS\Downloads\FEATURE_TRANSACTION_048_$${Sdate-input}$$.parquet';
DB SQL Executor
ALTER TABLE FEATURE_TRANSACTION_046ALTER COLUMN DAY_ID TYPE DATEUSING CAST(DAY_ID AS DATE);
DB SQL Executor
DB Writer
DB Connection Extractor
DB SQL Executor
DB SQL Executor
DB SQL Executor
DB SQL Executor
DB Connector
CREATE OR REPLACE TABLE FEATURE_TRANSACTION_046 ASSELECT *FROM read_parquet("C:\Users\ASUS\Downloads\FEATURE_TRANSACTION_002.parquet")
DB SQL Executor
copy "main"."FEATURE_TRANSACTION_047"to 'C:\Users\ASUS\Downloads\FEATURE_TRANSACTION_047_$${Sdate-input}$$.parquet';
DB SQL Executor
Thống kê của các biến
Statistics View
DB SQL Executor
SELECT * FROM FEATURE_TRANSACTION_047;
DB Query Reader
DB SQL Executor
K-means clustering RFM chiều đến
k-Means
K-means clustering RFM chiều đi
k-Means
DB SQL Executor
Write file parquet FEATURE_TRANSACTION_048
Parquet Writer
DB SQL Executor
SELECT * FROM FEATURE_TRANSACTION_046;
DB Query Reader
DB SQL Executor
SELECT * FROM FEATURE_TRANSACTION_048;
DB Query Reader

Nodes

Extensions

Links