added validation for required columns in the Customer Preferred

Distributor.

Saburi/27-02-26#CUSTOMER_PREF_DIST/java file/CustomerPrefDistIC.java

@@ -93,6 +93,7 @@ public class CustomerPrefDistIC extends ValidatorEJB implements ValidatorLocal,V
 		String stockCustName = "";
 		String distCustName = "";
 		String distSiteCode = "";
+		String errString= "";
 
 		try
 		{
@@ -217,6 +218,27 @@ public class CustomerPrefDistIC extends ValidatorEJB implements ValidatorLocal,V
 
 		            if (currentColumn.equalsIgnoreCase("cust_code"))
 		            {
+		                int custCount = 0;
+
+		                if (custCode != null && custCode.trim().length() > 0)
+		                {
+		                    String sqlType = "SELECT COUNT(*) AS CUST_CODE_COUNT FROM CUSTOMER WHERE CUST_CODE = ?";
+		                    pstmt = conn.prepareStatement(sqlType);
+		                    pstmt.setString(1, custCode);
+		                    rs = pstmt.executeQuery();
+
+		                    if (rs.next())
+		                    {
+		                        custCount = rs.getInt("CUST_CODE_COUNT");
+		                    }
+		                }
+
+		                if (custCount == 0)
+		                {
+		                    errString = itmDBAccessEJB.getErrorString("", "VCCUSTCODE", "", "", conn);
+		                    return errString;
+		                }
+
 		                valueXmlString.append("<cust_name>")
 		                    .append("<![CDATA[" + custName + "]]>")
 		                    .append("</cust_name>");
@@ -226,10 +248,29 @@ public class CustomerPrefDistIC extends ValidatorEJB implements ValidatorLocal,V
 		                    .append("</city>");
 		            }
 		            
+		            if (currentColumn.equalsIgnoreCase("cust_code__stk"))
+		            {
+		                String custTypeStk = "";
 
+		                if (custCodeStk != null && custCodeStk.trim().length() > 0)
+		                {
+		                    String sqlType = "SELECT CUST_TYPE FROM CUSTOMER WHERE CUST_CODE = ?";
+		                    pstmt = conn.prepareStatement(sqlType);
+		                    pstmt.setString(1, custCodeStk);
+		                    rs = pstmt.executeQuery();
 
-		            if (currentColumn.equalsIgnoreCase("cust_code__stk"))
+		                    if (rs.next())
 		                    {
+		                        custTypeStk = rs.getString("CUST_TYPE");
+		                    }
+		                }
+
+		                if (!"S".equalsIgnoreCase(custTypeStk))
+		                {
+		                    errString = itmDBAccessEJB.getErrorString("", "VCCUSTSTK", "", "", conn);
+		                   return errString;
+		                }
+
 		                valueXmlString.append("<cust_name_1>")
 		                    .append("<![CDATA[" + stockCustName + "]]>")
 		                    .append("</cust_name_1>");
@@ -237,6 +278,27 @@ public class CustomerPrefDistIC extends ValidatorEJB implements ValidatorLocal,V
 
 		            if (currentColumn.equalsIgnoreCase("cust_code__dist"))
 		            {
+		                String custTypeDist = "";
+
+		                if (custCodeDist != null && custCodeDist.trim().length() > 0)
+		                {
+		                    String sqlType = "SELECT CUST_TYPE FROM CUSTOMER WHERE CUST_CODE = ?";
+		                    pstmt = conn.prepareStatement(sqlType);
+		                    pstmt.setString(1, custCodeDist);
+		                    rs = pstmt.executeQuery();
+
+		                    if (rs.next())
+		                    {
+		                        custTypeDist = rs.getString("CUST_TYPE");
+		                    }
+		                }
+
+		                if (!"D".equalsIgnoreCase(custTypeDist))
+		                {
+		                    errString = itmDBAccessEJB.getErrorString("", "VCUSTDIST", "", "", conn);
+		                    return errString;
+		                }
+
 		                valueXmlString.append("<cust_name_2>")
 		                    .append("<![CDATA[" + distCustName + "]]>")
 		                    .append("</cust_name_2>");