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 paramArray = new ArrayList(); 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; } } }