changes in undo receivables adj process

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@198034 ce508802-f39f-4f6c-b175-0d175dae99d5

webitm-fin/ibase/webitm/ejb/fin/UndoRecievableAdjPrc.java

@@ -665,6 +665,8 @@ public class UndoRecievableAdjPrc extends ProcessEJB implements UndoRecievableAd
 								pstmtInsert = null;
 								
 							if(insert > 0)	
+							{
+								if(drAmt > 0)
 								{
 									sql1=" update receivables_adj set adj_amt= adj_amt - ? where ref_no= ? and ref_ser= ?";
 									pstmt1 = conn.prepareStatement(sql1);	
@@ -701,7 +703,7 @@ public class UndoRecievableAdjPrc extends ProcessEJB implements UndoRecievableAd
 									System.out.println("@@@updCnt========["+updCnt+"]");
 									
 									
-								System.out.println("Status Checking*********");
+									/*System.out.println("Status Checking*********");
 									sql1="select tot_amt,adj_amt,status from receivables  where ref_no= ? and tran_ser=?";
 									pstmt1 = conn.prepareStatement(sql1);
 									pstmt1.setString(1, refNo);
@@ -742,7 +744,7 @@ public class UndoRecievableAdjPrc extends ProcessEJB implements UndoRecievableAd
 									pstmt1.setString(3, tranSer);
 									updCnt = pstmt1.executeUpdate();
 									pstmt1.close();
-								pstmt1= null;
+									pstmt1= null;*/
 									
 									//update  end for inserted receivable_adj records 
 									sql1=" update receivables set adj_amt =adj_amt - ? where ref_no= ? and tran_ser=?";
@@ -780,8 +782,128 @@ public class UndoRecievableAdjPrc extends ProcessEJB implements UndoRecievableAd
 									pstmt= null;
 									System.out.println("@@@updCnt=== INVOICE ["+updCnt+"]");
 									
+							}
+							else
+							{
+								sql1=" update receivables_adj set adj_amt= adj_amt + ? where ref_no= ? and ref_ser= ?";
+								pstmt1 = conn.prepareStatement(sql1);	
+								//if( drAmt < headDrAmt  )
+								if( headDrAmt >= Math.abs(drAmt)   )
+								{
+									pstmt1.setDouble(1, drAmt * -1);
+								}
+								else
+								{
+									pstmt1.setDouble(1, headDrAmt);
+								}
+								pstmt1.setString(2, refNoHeader);
+								pstmt1.setString(3, adjTranSer);
+								updCnt = pstmt1.executeUpdate();
+								pstmt1.close();
+								pstmt1= null;
 								
+								sql1=" update receivables set adj_amt =adj_amt + ? where ref_no= ? and tran_ser=?";
+								pstmt1 = conn.prepareStatement(sql1);
+								if( headDrAmt >= Math.abs(drAmt)   )//if( drAmt < headDrAmt  )
+								{
+									pstmt1.setDouble(1, drAmt * -1);
+								}
+								else
+								{
+									pstmt1.setDouble(1, headDrAmt);
 								}
+								pstmt1.setString(2, refNo);
+								pstmt1.setString(3, tranSer);
+								
+								updCnt = pstmt1.executeUpdate();
+								pstmt1.close();
+								pstmt1 = null;
+								System.out.println("@@@updCnt========["+updCnt+"]");
+								
+								
+								
+								
+								//update  end for inserted receivable_adj records 
+								sql1=" update receivables set adj_amt =adj_amt + ? where ref_no= ? and tran_ser=?";
+								pstmt1 = conn.prepareStatement(sql1);
+								//if( drAmt < headDrAmt  )
+								if( headDrAmt >= Math.abs(drAmt)   )
+								{
+									pstmt1.setDouble(1, drAmt * -1);
+								}
+								else
+								{
+									pstmt1.setDouble(1, headDrAmt);
+								}
+								pstmt1.setString(2, refNoHeader);
+								pstmt1.setString(3, adjTranSer);
+								
+								updCnt = pstmt1.executeUpdate();
+								pstmt1.close();
+								pstmt1 = null;
+								System.out.println("@@@updCnt=receivables header=======["+updCnt+"]");
+								
+								sql1="update INVOICE set adj_amount= adj_amount + ? WHERE invoice_id= ?";
+								pstmt = conn.prepareStatement(sql1);							
+								//if( drAmt < headDrAmt  )
+								if( headDrAmt >= Math.abs(drAmt)   )
+								{
+									pstmt.setDouble(1, drAmt * -1);
+								}
+								else
+								{
+									pstmt.setDouble(1, headDrAmt);
+								}
+								pstmt.setString(2, refNoHeader);
+												
+								updCnt = pstmt.executeUpdate();
+								pstmt.close();
+								pstmt= null;
+								System.out.println("@@@updCnt=== INVOICE ["+updCnt+"]");
+								
+							}
+								System.out.println("Status Checking*********");
+								sql1="select tot_amt,adj_amt,status from receivables  where ref_no= ? and tran_ser=?";
+								pstmt1 = conn.prepareStatement(sql1);
+								pstmt1.setString(1, refNo);
+								pstmt1.setString(2, tranSer);
+								rs1 = pstmt1.executeQuery();
+								if(rs1.next())
+								{
+									totAmt=Math.abs(rs1.getDouble("tot_amt"));
+									adjAmt=Math.abs(rs1.getDouble("adj_amt"));
+									status=rs1.getString("status");
+								}						
+								rs1.close();
+								rs1 = null;
+								pstmt1.close();
+								pstmt1 = null;
+								System.out.println("totalAmt1============"+totAmt);
+								System.out.println("adjAmt1============"+adjAmt);
+								System.out.println("statusBef============"+status);
+								
+								 if(adjAmt==totAmt)
+								{
+									System.out.println("adjAmt1==totalAmt1*********");
+									status="A";								
+								}
+								else if(adjAmt!=0 && totAmt>adjAmt)
+								{
+									System.out.println("totalAmt1>adjAmt1*********");
+									status="P";								
+								}
+								
+								System.out.println("status=****-========="+status);
+								System.out.println("refNo=-========="+refNo);
+								System.out.println("refSer=-========="+tranSer);
+								sql1=" update receivables set status = ? where ref_no= ? and tran_ser=?";
+								pstmt1 = conn.prepareStatement(sql1);	
+								pstmt1.setString(1, status);
+								pstmt1.setString(2, refNo);
+								pstmt1.setString(3, tranSer);
+								updCnt = pstmt1.executeUpdate();
+								pstmt1.close();
+								pstmt1= null;
 							
 							headDrAmt=headDrAmt-drAmt;
 							}
@@ -830,7 +952,7 @@ public class UndoRecievableAdjPrc extends ProcessEJB implements UndoRecievableAd
 						updCnt = pstmt1.executeUpdate();
 						pstmt1.close();
 						pstmt1= null;
-						
+						}	
 						//end
 					errString =  itmDBAccessEJB.getErrorString("","VTCOMPL","","",conn);
 					if(conn != null){