XinYu_LZMES/.svn/pristine/4f/4f95246b6cfa24ab3f9b4cb8e43b1cf13e144ba8.svn-base

package UIE.NIE01;

import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;

import org.springframework.jdbc.support.rowset.SqlRowSet;

import UIB.COM.XmlSqlParsersFactory;

import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;

public class SaveOrdDet extends CoreIComponent {
	String V_TABLE_ID      = "" ;
	String V_TABLE_MODE    = "" ;
	String V_ERR_DESC      = "" ; 
	String V_RTN_NAME      = "" ;
	
	String V_PROC_CD       = "" ;
	String V_PROD_END_GP   = "" ;
	String P_PROD_END_GP   = "" ;
	String V_PROD_END_DATE = "" ;
	String P_PROD_END_DATE = "" ;
	String V_SHIP_END_DATE = "" ;
	String V_ORD_PROG_CD   = "" ;
	String V_PROD_HOLD_CD   =  "" ;
		
	long V_TOT_WGT         = 0 ;
	long V_INS_WGT         = 0 ;
	long V_WRK_WGT         = 0 ;
	long V_EST_WGT         = 0 ;
	long V_END_WGT         = 0 ;
	long V_ORD_PRC_WGT     = 0 ;
	long V_PROD_END_WGT    = 0 ;
	long V_ORD_REM_WGT     = 0 ;
	long V_SHIP_END_WGT    = 0 ;
	long V_ORD_WGT         = 0 ;
	long V_WGT_ACVAL_MAX   = 0 ;
	
	String P_ORD_NO        ;
	String P_ORD_SEQ       ;
	String P_PROG_CD       ;
	Number P_WGT           ;
	String P_BEF_PROG_CD   ;
	Number P_BEF_WGT       ;
	String P_PGMID         ;
	String P_REG_ID        ;
	
	CoreReturnObject	cro		=	new CoreReturnObject();
	public SaveOrdDet(String ORD_NO,String ORD_SEQ,String PROG_CD,Number WGT
						,String BEF_PROG_CD,Number BEF_WGT,String PGMID,String REG_ID){
		P_ORD_NO        = ORD_NO;
		P_ORD_SEQ       = ORD_SEQ;
		P_PROG_CD       = PROG_CD;
		P_WGT           = WGT;
		P_BEF_PROG_CD   = BEF_PROG_CD;
		P_BEF_WGT       = BEF_WGT;
		P_PGMID         = PGMID;
		P_REG_ID        = REG_ID;
	}
	
	public void ordDetUpdt() throws Exception{
		try{	
			DateFormat formatter = new SimpleDateFormat("yyyyMMdd");
    		String currDate = formatter.format(new Date());
    		
    		String sqlstr = XmlSqlParsersFactory.getSql("NIE042020_OrdPrcINf.select");
    		
    		cro = this.getDao("KgDao").ExecutequeryForRowSet(sqlstr,new Object[]{P_ORD_NO,P_ORD_SEQ});
    		SqlRowSet	srs	=	(SqlRowSet)cro.getResult();
    		
    		while(srs.next()){
    			V_ORD_WGT        =  Long.parseLong(srs.getObject("ORD_WGT").toString());
		    	V_WGT_ACVAL_MAX  =  Long.parseLong((srs.getObject("WGT_ACVAL_MAX")==null? "0":srs.getObject("WGT_ACVAL_MAX")).toString());
		    	V_ORD_PROG_CD    =  (String)srs.getObject("ORD_PROG_CD");
		    	P_PROD_END_GP    =  (String)srs.getObject("PROD_END_GP");
		    	P_PROD_END_DATE  =  (String)srs.getObject("PROD_END_DATE");
		    	V_PROD_HOLD_CD   =  (String)srs.getObject("PROD_HOLD_CD");
		    	V_SHIP_END_DATE   =  (String)srs.getObject("SHIP_END_DATE");
		    	V_PROD_END_DATE   =  (String)srs.getObject("PROD_END_DATE");
		    	
		    	V_ORD_REM_WGT    =  V_ORD_WGT;
		    	if (V_WGT_ACVAL_MAX == 0) {
		    		
		    		V_WGT_ACVAL_MAX  =  V_ORD_WGT;
		    		
		    	}else{
		    		throw new Exception("SaveOrdPrcDet --> NOT FOUND SELECT TBE02_ORD_PRC");
		    	}
		    	
		    	if (P_PROG_CD != null && !P_PROG_CD.equals("")) {
		    		sqlstr = XmlSqlParsersFactory.getSql("NIE042020_OrdPrcDetPk.select");
		    		cro = this.getDao("KgDao").ExecutequeryForRowSet(sqlstr,new Object[]{P_ORD_NO,P_ORD_SEQ,P_PROG_CD.substring(0, 2)});
		    		srs	=	(SqlRowSet)cro.getResult();
					if (srs.next()) {
						sqlstr = XmlSqlParsersFactory.getSql("NIE042020_OrdPrcDet.insert");
//						cro = this.getDao("KgDao").ExcuteNonQueryById(sqlstr,new Object[]{P_ORD_NO,P_ORD_SEQ,P_PROG_CD.substring(0, 2)});
					}
			    }
		    	
		    	V_ORD_PRC_WGT   =  0;
				V_PROD_END_WGT  =  0;
				V_SHIP_END_WGT  =  0;
				
				//SELECT FROM TBE02_ORD_PRC_DET 
				sqlstr = XmlSqlParsersFactory.getSql("NIE042020_OrdPrcDet.select");
	    		cro = this.getDao("KgDao").ExecutequeryForRowSet(sqlstr,new Object[]{P_ORD_NO,P_ORD_SEQ});
	    		srs	=	(SqlRowSet)cro.getResult();
	    		
	    		while(srs.next()){
	    			V_PROC_CD  =  (String)srs.getObject("PROC_CD");
			    	V_TOT_WGT  =  Long.parseLong((srs.getObject("TOT_WGT")==null? "0":srs.getObject("TOT_WGT")).toString());
			    	V_INS_WGT  =  Long.parseLong((srs.getObject("INS_WGT")==null? "0":srs.getObject("INS_WGT")).toString());
			    	V_WRK_WGT  =  Long.parseLong((srs.getObject("WRK_WGT")==null? "0":srs.getObject("WRK_WGT")).toString());
			    	V_EST_WGT  =  Long.parseLong((srs.getObject("EST_WGT")==null? "0":srs.getObject("EST_WGT")).toString());
			    	V_END_WGT  =  Long.parseLong((srs.getObject("END_WGT")==null? "0":srs.getObject("END_WGT")).toString());		    	
			    	
			    	if (P_PROG_CD != null && !P_PROG_CD.equals("")) {
			    		
				    	if (V_PROC_CD.equals(P_PROG_CD.substring(0, 2))) {
				    		
				    		if (P_PROG_CD.substring(2, 3).equals("A")) {           
				    			
				    			V_INS_WGT = Long.parseLong(P_WGT.toString());
				    			
				    		} else if (P_PROG_CD.substring(2, 3).equals("B")) {    
			
				    			V_WRK_WGT = Long.parseLong(P_WGT.toString());
				    			
				    		} else if (P_PROG_CD.substring(2, 3).equals("D")) {    
				    			
				    			V_EST_WGT = Long.parseLong(P_WGT.toString());
				    			
				    		} else if (P_PROG_CD.substring(2, 3).equals("F")) {    
				    			
				    			V_END_WGT = Long.parseLong(P_WGT.toString());
				    			
				    		}
				    	}
			    	}
			    	
			    	if (P_BEF_PROG_CD != null && !P_BEF_PROG_CD.equals("") ) {
			    		
				    	if (V_PROC_CD.equals(P_BEF_PROG_CD.substring(0, 2))) {
				    		
				    		if (P_BEF_PROG_CD.substring(2, 3).equals("A")) {           
				    			
				    			V_INS_WGT = Long.parseLong(P_BEF_WGT.toString());
				    			
				    		} else if (P_BEF_PROG_CD.substring(2, 3).equals("B")) {    
			
				    			V_WRK_WGT = Long.parseLong(P_BEF_WGT.toString());
				    			
				    		} else if (P_BEF_PROG_CD.substring(2, 3).equals("D")) {    
				    			
				    			V_EST_WGT = Long.parseLong(P_BEF_WGT.toString());
				    			
				    		} else if (P_BEF_PROG_CD.substring(2, 3).equals("F")) {    
				    			
				    			V_END_WGT = Long.parseLong(P_BEF_WGT.toString());
				    			
				    		}
				    	}
			    	}
			    	
					//PRODUCT PROGRESS / END WEIGHT
					if (V_PROC_CD.equals("SF")) {
						
						V_PROD_END_WGT = V_INS_WGT + V_WRK_WGT;                  
						V_SHIP_END_WGT = V_END_WGT;
						
						//V_ORD_PRC_WGT = V_ORD_PRC_WGT + V_INS_WGT + V_WRK_WGT;
						V_TOT_WGT     = V_INS_WGT     + V_WRK_WGT + V_END_WGT;
						//V_ORD_REM_WGT = V_ORD_WGT - (V_ORD_PRC_WGT + V_SHIP_END_WGT);
						
					} else {
						
						V_ORD_PRC_WGT = V_ORD_PRC_WGT + V_INS_WGT + 
						                V_WRK_WGT     + V_EST_WGT + V_END_WGT; 
						V_TOT_WGT     = V_INS_WGT     + V_WRK_WGT + V_EST_WGT + V_END_WGT;
						//V_ORD_REM_WGT = V_ORD_WGT - (V_ORD_PRC_WGT + V_PROD_END_WGT + V_SHIP_END_WGT);
						
					}
	    			
					//UPDATE FROM TBE02_ORD_PRC_DET
					sqlstr = XmlSqlParsersFactory.getSql("NIE042020_OrdPrcDet.update");
//					cro = this.getDao("KgDao").ExcuteNonQueryById(sqlstr,new Object[]{String.valueOf(V_TOT_WGT)
//																		,String.valueOf(V_INS_WGT)
//																		,String.valueOf(V_WRK_WGT)
//																		,String.valueOf(V_EST_WGT)
//																		,String.valueOf(V_EST_WGT)
//																		,P_PGMID,P_ORD_NO,P_ORD_SEQ,V_PROC_CD});
						
//					if (UpdCnt1 == 0 ) {
//						
//						V_TABLE_ID    =  "TBE02_ORD_PRC_DET";
//						V_TABLE_MODE  =  "U";
//						V_ERR_DESC    =  "TBE02_ORD_PRC_DET UPDATE COUNT IS ZERO";
//						V_RTN_NAME    =  "SaveOrdPrcDet TBE02_ORD_PRC_DET UPDATE1 " + P_ORD_NO + P_ORD_SEQ;
//						
//						LogGpError.logMessageToDB("SaveOrdPrcDet", V_TABLE_ID, V_TABLE_MODE, V_ERR_DESC, V_RTN_NAME);
//						throw new PosException(V_RTN_NAME);
//						
//					}
	    		}
    		} //while end
    		
    		V_ORD_REM_WGT = V_ORD_WGT - (V_ORD_PRC_WGT + V_PROD_END_WGT + V_SHIP_END_WGT);
		    
		    //如果没有人工指定时对订单状态进行整理
		    if(("".equals(P_PROD_END_GP) || P_PROD_END_GP == null) && (!"Y".equals(V_PROD_HOLD_CD) && !"R".equals(V_PROD_HOLD_CD)))
		    {
		    	//如果订单重量小于或者等于发货完成重量
		    	if(V_WGT_ACVAL_MAX <= V_SHIP_END_WGT)
		    	{
		    		V_ORD_PROG_CD    =  "G"; //发货完成
		    		//TL 091229 发货完成的时候，自动给出发货结束时间
		    		if(V_SHIP_END_DATE == null || V_SHIP_END_DATE.equals("")){
		    			V_SHIP_END_DATE  =  currDate;
		    		}
		    	}
		    	//如果订单重量大于发货重量，小于发货重量＋生产完成重量 
		    	else if(V_WGT_ACVAL_MAX > V_SHIP_END_WGT && V_WGT_ACVAL_MAX <= (V_PROD_END_WGT+V_SHIP_END_WGT))
		    	{
		    		V_ORD_PROG_CD    =  "F"; //生产完成
		    		//TL 091229 生产完成的时候，自动给出生产结束时间
		    		if(V_PROD_END_DATE == null || V_PROD_END_DATE.equals("")){
		    			V_PROD_END_DATE  =  currDate;
		    		}
		    	}
		    	//如果订单重量大于生产完成重量＋发货完成重量，并且小于等于生产进行重量＋生产完成重量＋发货完成重量
		    	else if(V_WGT_ACVAL_MAX > (V_PROD_END_WGT+V_SHIP_END_WGT) && V_WGT_ACVAL_MAX <= (V_ORD_PRC_WGT + V_PROD_END_WGT + V_SHIP_END_WGT))
		    	{
		    		V_ORD_PROG_CD    =  "E"; //生产进行
		    		V_PROD_END_DATE = "";
		    		V_SHIP_END_DATE = "";
		    	}
		    	//如果订单重量大于生产进行重量＋生产完成重量＋发货完成重量，并且生产进行重量＋生产完成重量＋发货完成重量不等于0
		    	else if(V_WGT_ACVAL_MAX > (V_ORD_PRC_WGT + V_PROD_END_WGT + V_SHIP_END_WGT) && (V_ORD_PRC_WGT + V_PROD_END_WGT + V_SHIP_END_WGT)!=0)
		    	{
		    		V_ORD_PROG_CD    =  "E"; //生产进行
		    		V_PROD_END_DATE = "";
		    		V_SHIP_END_DATE = "";
		    	}
		    	else if((V_ORD_PRC_WGT + V_PROD_END_WGT + V_SHIP_END_WGT) == 0)//如果订单重量＝订单剩余重量
		    	{
		    		if (V_ORD_PROG_CD.compareTo("D") >= 0) 
	    			{
			    		V_ORD_PROG_CD  =  "D";//订单投入确定
			    	}
		    	}
		    }
		    else//如果人工指定了订单关闭，生产完成，发货结束则不更改订单的状态，保持原状！
		    {
		    	V_PROD_END_GP = P_PROD_END_GP;
		    	//V_PROD_END_DATE = P_PROD_END_DATE;
		    }
		    
		    //UPDATE FROM TBE02_ORD_PRC
		    ArrayList<String> paramArray = new ArrayList<String>();
		    sqlstr = XmlSqlParsersFactory.getSql("NIE042020_OrdPrc.update");
		    paramArray.add(V_ORD_PROG_CD);                     
		    paramArray.add(V_PROD_END_GP);                      
		    paramArray.add(V_PROD_END_DATE);                    
		    paramArray.add(String.valueOf(V_ORD_PRC_WGT));      
		    paramArray.add(String.valueOf(V_ORD_REM_WGT));      
		    paramArray.add(String.valueOf(V_PROD_END_WGT));     
		    paramArray.add(String.valueOf(V_SHIP_END_WGT));      
		    paramArray.add(V_SHIP_END_DATE);                    
		    paramArray.add(P_REG_ID);                           
		    paramArray.add(P_PGMID);                            
		    paramArray.add(P_ORD_NO);                           
		    paramArray.add(P_ORD_SEQ);   
//		    cro = this.getDao("KgDao").ExcuteNonQueryById(sqlstr,paramArray.toArray());
			
//			if (UpdCnt2 == 0) {
//				
//				V_TABLE_ID    =  "TBE02_ORD_PRC_DET";
//				V_TABLE_MODE  =  "U";
//				V_ERR_DESC    =  "TBE02_ORD_PRC_DET UPDATE COUNT IS ZERO";
//				V_RTN_NAME    =  "SaveOrdPrcDet TBE02_ORD_PRC_DET UPDATE2 " + P_ORD_NO + P_ORD_SEQ;
//				
//				LogGpError.logMessageToDB("SaveOrdPrcDet", V_TABLE_ID, V_TABLE_MODE, V_ERR_DESC, V_RTN_NAME);
//				throw new PosException(V_RTN_NAME);
//			}
		}catch(Exception ex){
	    	throw ex;
		}
	}
}