@@ -75,7 +75,7 @@ def test_paymentStatus(self, spark):
7575 ("7" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # EA Case with ReferringTransactionId = TransactionId with Type in 6 - 'Paid'
7676 ("8" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # EA Case with ReferringTransactionId = TransactionId with Type in 19 - 'Paid'
7777 ("9" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # SUM(AMOUNT) > 0 = 'Payment pending'
78- ("10" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # SUM(AMOUNT) = 0 AND TransactionTypeId = 19 for MAX(TransactionId), = 'Paid' -> if Sum(Amount) = 0 then default to 'Paid '
78+ ("10" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # SUM(AMOUNT) = 0 AND TransactionTypeId = 19 for MAX(TransactionId), = 'Payment pending '
7979 ("11" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # SUM(AMOUNT) = 0 AND TransactionTypeId = 1 for MAX(TransactionId), = 'Paid'
8080 ("12" , "EA" , "AIP" , 0 , datetime (2000 , 1 , 1 )), # Referring TransactionId matches, but TransactionTypeId = 19 for MAX(TransactionId) is SumBalance = 0, = 'Paid'
8181 ]
@@ -98,15 +98,6 @@ def test_paymentStatus(self, spark):
9898 ("12" , 8 , 1 , 100.0 , True , False , 0 ), # Case 12 - TransactionTypeId = 1, TransactionId = 8
9999 ("12" , 9 , 19 , 0.0 , False , False , 8 ) # Case 12 - TransactionTypeId = 19, TransactionId = 9, ReferringTransaction 8, SumBalance = 0
100100 ]
101- # SILVER_M4_SCHEMA = StructType([
102- # StructField("CaseNo", StringType()),
103- # StructField("TransactionId", IntegerType()),
104- # StructField("TransactionTypeId", IntegerType()),
105- # StructField("Amount", DoubleType()),
106- # StructField("SumBalance", BooleanType()),
107- # StructField("SumTotalPay", BooleanType()),
108- # StructField("ReferringTransactionId", IntegerType())
109- # ])
110101
111102 silver_m1 = spark .createDataFrame (m1_data , self .SILVER_M1_SCHEMA )
112103 silver_m4 = spark .createDataFrame (m4_data , self .SILVER_M4_SCHEMA )
0 commit comments