Updated - Data Correction

Populate data as per EMP_CODE 

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

webitm-dashboard/ibase/dashboard/module-resource/scm/SUN - Sales Trends/sql/2. DWH_INV_SRET_SUM_Procedure.sql

-CREATE OR REPLACE PROCEDURE SUNERP.DWH_INV_SRET(
+CREATE OR REPLACE PROCEDURE SUNERP.DWH_INV_SRET_EMP(
     AS_FR_DATE DATE,
     AS_TO_DATE DATE,
-    AS_ITEM_SER CHAR)
+    AS_EMP_CODE CHAR)
 AS
 BEGIN
   IF (AS_TO_DATE >= AS_FR_DATE) THEN
-    /*========== DELETE for DWH_INV_SRET_SUM Started ==========*/
-     
-    /*
-    DELETE FROM DWH_INV_SRET_SUM WHERE TRAN_DATE BETWEEN AS_FR_DATE AND AS_TO_DATE;
-    COMMIT ;
-	*/
-
-    /*========== INSERT for DWH_INV_SRET_SUM End ==========*/
 
     /*========== INSERT for DWH_INV_SRET_SUM Started ==========*/
 
@@ -51,7 +43,7 @@ BEGIN
   WITH 
   ORG AS
   (
-    SELECT EMP_CODE,
+    SELECT 
     VERSION_ID, 
     TABLE_NO, 
     POOL_CODE AS LEVEL_CODE, 
@@ -60,17 +52,18 @@ BEGIN
     FROM
     (
       SELECT *
-      FROM ORG_STRUCTURE A
-      WHERE A.VERSION_ID = (SELECT MAX(Q.VERSION_ID) FROM VERSION Q WHERE TRUNC(SYSDATE) BETWEEN Q.EFF_FROM AND Q.VALID_UPTO)
-      AND A.TABLE_NO = AS_ITEM_SER
+      FROM ORG_STRUCTURE A,
+      	SALES_PERS B
+      WHERE B.EMP_CODE = AS_EMP_CODE
+      AND A.VERSION_ID = (SELECT MAX(Q.VERSION_ID) FROM VERSION Q WHERE TRUNC(SYSDATE) BETWEEN Q.EFF_FROM AND Q.VALID_UPTO)
+      AND A.TABLE_NO = B.ITEM_SER
       AND A.ACTIVE = 'Y'
     ) ORG_STRUCTURE 
-    START WITH ORG_STRUCTURE.POS_CODE in( 
+    START WITH ORG_STRUCTURE.POS_CODE = ( 
       SELECT ( CASE WHEN J.STATE_CODE = 'XX' THEN 'ABC' ELSE Q.POS_CODE END ) AS POS_CODE 
       FROM EMPLOYEE Q, 
       STATION J
-      WHERE Q.EMP_CODE in (select emp_code from sales_pers where  item_ser = AS_ITEM_SER)
-      AND Q.POS_CODE IS NOT NULL
+      WHERE Q.EMP_CODE = AS_EMP_CODE
       AND Q.STAN_CODE__HQ = J.STAN_CODE
     )
     CONNECT BY PRIOR ORG_STRUCTURE.POS_CODE = ORG_STRUCTURE.POS_CODE__REPTO
@@ -79,7 +72,6 @@ BEGIN
   (
     SELECT X.VERSION_ID,
         X.TABLE_NO,
-        X.EMP_CODE,
         A.LEVEL_CODE  AS ZONE_CODE,
         A.LEVEL_DESCR AS ZONE_DESCR,
         B.LEVEL_CODE  AS REGION_CODE,
@@ -101,14 +93,12 @@ BEGIN
         (
           SELECT VERSION_ID,
             TABLE_NO,
-            LEVEL_CODE,
-            EMP_CODE
+            LEVEL_CODE
           FROM ORG
           WHERE LEVEL_NO = 4
           GROUP BY VERSION_ID,
             TABLE_NO,
-            LEVEL_CODE,
-            EMP_CODE
+            LEVEL_CODE
         ) X
       WHERE E.TABLE_NO = X.TABLE_NO
       AND E.VERSION_ID = X.VERSION_ID
@@ -144,7 +134,7 @@ BEGIN
   )
    SELECT 
       INV_SRET.TRAN_DATE                                AS TRAN_DATE,
-      NVL(HIERARCHY.EMP_CODE,'VAC')                     AS EMP_CODE,
+      AS_EMP_CODE					                    AS EMP_CODE,
       INV_SRET.INVOICE_ITEM_SER                         AS DIV_CODE,
       MAX((SELECT Q.SH_DESCR FROM ITEMSER Q WHERE Q.ITEM_SER = INV_SRET.INVOICE_ITEM_SER ))  AS DIV,
       NVL(HIERARCHY.ZONE_CODE,'NA')                    AS ZONE_CODE,
@@ -335,7 +325,7 @@ BEGIN
     ) INV_SRET
     LEFT OUTER JOIN --FOLLOWING PART IS FOR HIERARCHY and BRAND DESCRIPTION
     (
-        SELECT EMP_CODE,
+        SELECT
           STATION_CODE,
           STATION_DESCR,
           TABLE_NO,
@@ -350,7 +340,7 @@ BEGIN
           ZONE_CODE,
           ZONE_DESCR
         FROM STN
-    ) HIERARCHY ON INV_SRET.INVOICE_ITEM_SER = HIERARCHY.TABLE_NO AND INV_SRET.CUST_STAN_CODE  = HIERARCHY.STAN_CODE AND HIERARCHY.EMP_CODE IS NOT NULL
+    ) HIERARCHY ON INV_SRET.INVOICE_ITEM_SER = HIERARCHY.TABLE_NO AND INV_SRET.CUST_STAN_CODE  = HIERARCHY.STAN_CODE
     LEFT OUTER JOIN 
     ( 
         SELECT FLD_VALUE,
@@ -371,7 +361,6 @@ BEGIN
       NVL(HIERARCHY.TERR_CODE,'NA'),
       NVL(HIERARCHY.TERR_DESCR,'UN ATTACHED TERRITORY'),
       HIERARCHY.SANC_STRENGTH,
-      NVL(HIERARCHY.EMP_CODE,'VAC'),
       INV_SRET.SGRP_CODE,
       GENCODES.DESCR;
       
@@ -380,6 +369,30 @@ BEGIN
     END IF;
 EXCEPTION
 WHEN OTHERS THEN
-  dbms_output.put_line(' Error occured ');
+  DBMS_OUTPUT.PUT_LINE(' Error occured in DWH_INV_SRET_EMP for From Date = ' || AS_FR_DATE || ' To Date = ' || AS_TO_DATE || ' Employee Code = ' || AS_EMP_CODE );
+END; 
+/
+
+CREATE OR REPLACE PROCEDURE SUNERP.DWH_INV_SRET(
+    AS_FR_DATE DATE,
+    AS_TO_DATE DATE,
+    AS_ITEM_SER CHAR)
+AS
+BEGIN
+  IF (AS_TO_DATE >= AS_FR_DATE) THEN
+
+	FOR AS_SALE_PERS IN (
+    	SELECT * FROM SALES_PERS
+	    WHERE ITEM_SER = AS_ITEM_SER
+	)
+  	LOOP
+   		DWH_INV_SRET_EMP(AS_FR_DATE, AS_TO_DATE, AS_SALE_PERS.EMP_CODE );
+  	END LOOP;
+
+  END IF;
+  EXCEPTION
+  WHEN OTHERS THEN
+  DBMS_OUTPUT.PUT_LINE(' Error occured in DWH_INV_SRET for From Date = ' || AS_FR_DATE || ' To Date = ' || AS_TO_DATE || ' Item Series = ' || AS_ITEM_SER );
+  
 END; 
 /
\ No newline at end of file