Browse Source

feat(prodIoPay): 更新付款记录同步更新对账明细

hejq 7 years ago
parent
commit
ef7d1926cc

+ 49 - 0
src/main/java/com/uas/platform/b2b/erp/service/impl/ProdIoPayServiceImpl.java

@@ -108,6 +108,12 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and aa_ordercode = '" + pay.getPiCode() + "'" +
                 " and aa_detno = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `purc$apbilladjustment` on pai_sourcetable = 'purc$apbilladjustment' and pai_sourceid = aa_id" +
+                " set pai_payment = " + pay.getAmount() +
+                " where aa_ordercode = '" + pay.getPiCode() + "' and aa_detno = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
@@ -130,6 +136,13 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and mr_code = '" + pay.getPiCode() + "'" +
                 " and mri_number = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `make$returnitem` on pai_sourcetable = 'purc$badinitem' and pai_sourceid = mri_id" +
+                " right join `make$return` on mri_paid = mr_id" +
+                " set pai_payment = " + pay.getAmount() +
+                " where mr_code = '" + pay.getPiCode() + "' and mri_number = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
@@ -152,6 +165,13 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and ma_code = '" + pay.getPiCode() + "'" +
                 " and mai_number = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `make$acceptitem` on pai_sourcetable = 'purc$badinitem' and pai_sourceid = mai_id" +
+                " right join `make$accept` on mai_paid = ma_id" +
+                " set pai_payment = " + pay.getAmount() +
+                " where ma_code = '" + pay.getPiCode() + "' and mai_number = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
@@ -174,6 +194,13 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and po_code = '" + pay.getPiCode() + "'" +
                 " and poi_number = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `purc$badoutitem` on pai_sourcetable = 'purc$badinitem' and pai_sourceid = poi_id" +
+                " right join `purc$badout` on poi_poid = po_id" +
+                " set pai_payment = " + pay.getAmount() +
+                " where po_code = '" + pay.getPiCode() + "' and poi_number = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
@@ -196,6 +223,13 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and pb_code = '" + pay.getPiCode() + "'" +
                 " and pbi_number = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `purc$badinitem` on pai_sourcetable = 'purc$badinitem' and pai_sourceid = pbi_id" +
+                " right join `purc$badin` on pbi_pbid = pb_id" +
+                " set pai_payment = " + pay.getAmount() +
+                " where pb_code = '" + pay.getPiCode() + "' and pbi_number = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
@@ -218,6 +252,13 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and purc$return.pr_code = '" + pay.getPiCode() + "'" +
                 " and pri_number = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `purc$returnitem` on pai_sourcetable = 'purc$returnitem' and pai_sourceid = pri_id" +
+                " right join `purc$return` on pri_prid = pr_id" +
+                " set pai_payment = " + pay.getAmount() +
+                " where purc$return.pr_code = '" + pay.getPiCode() + "' and pri_number = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
@@ -240,7 +281,15 @@ public class ProdIoPayServiceImpl implements ProdIoPayService {
                 " and pa_code = '" + pay.getPiCode() + "'" +
                 " and pai_number = " + pay.getPiDetNo();
             sqlList.add(sql);
+            // 更新对账单明细
+            String checkSql = "update purc$apcheckitem " +
+                " left join `purc$acceptitem` on pai_sourcetable = 'purc$acceptitem' and pai_sourceid = purc$acceptitem.pai_id " +
+                " right join `purc$accept` on purc$acceptitem.pai_paid = pa_id" +
+                " set purc$apcheckitem.pai_payment = " + pay.getAmount() +
+                " where pa_code = '" + pay.getPiCode() + "' and purc$acceptitem.pai_number = " + pay.getPiDetNo();
+            sqlList.add(checkSql);
         });
         return sqlList;
     }
+
 }