package UIF.UIF04; import java.sql.SQLException; import java.util.ArrayList; import UIB.COM.XmlSqlParsersFactory; import CoreFS.SA01.CoreIComponent; import CoreFS.SA06.CoreReturnObject; public class UIF042010 extends CoreIComponent { public CoreReturnObject query01() throws SQLException { CoreReturnObject cro=new CoreReturnObject(); StringBuffer str = new StringBuffer(); str.append("SELECT \n"); str.append(" '' WTH_GRP_CD --轧制单元号 \n"); str.append(" ,0 WTH_MINI --单元内序号 \n"); str.append(" ,0 WTH_MAXI --轧制序号 \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T01',MINI,0)) T01_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T01',MAXI,0)) T01_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T02',MINI,0)) T02_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T02',MAXI,0)) T02_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T03',MINI,0)) T03_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T03',MAXI,0)) T03_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T04',MINI,0)) T04_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T04',MAXI,0)) T04_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T05',MINI,0)) T05_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T05',MAXI,0)) T05_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T06',MINI,0)) T06_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T06',MAXI,0)) T06_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T07',MINI,0)) T07_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T07',MAXI,0)) T07_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T08',MINI,0)) T08_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T08',MAXI,0)) T08_WGT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T09',MINI,0)) T09_CNT \n"); str.append(" ,SUM(DECODE(THK_GRP_CD,'T09',MAXI,0)) T09_WGT \n"); str.append(" ,0 MINI \n"); str.append(" ,0 MAXI \n"); str.append("FROM TBF02_ROLL_THK_GRP \n"); str.append("WHERE PLT = 'C' \n"); str.append("UNION ALL \n"); str.append(" \n"); str.append(" \n"); str.append("SELECT C.WTH_GRP_CD, --宽度组 \n"); str.append(" C.MINI WTH_MINI, --宽度组下限 \n"); str.append(" C.MAXI WTH_MAXI, --宽度组上限 \n"); str.append(" A.T01_CNT, --已编制板坯数量 \n"); str.append(" A.T01_WGT, --已编制板坯质量 \n"); str.append(" A.T02_CNT, --已编制板坯数量 \n"); str.append(" A.T02_WGT, --已编制板坯质量 \n"); str.append(" A.T03_CNT, --已编制板坯数量 \n"); str.append(" A.T03_WGT, --已编制板坯质量 \n"); str.append(" A.T04_CNT, --已编制板坯数量 \n"); str.append(" A.T04_WGT, --已编制板坯质量 \n"); str.append(" A.T05_CNT, --已编制板坯数量 \n"); str.append(" A.T05_WGT, --已编制板坯质量 \n"); str.append(" A.T06_CNT, --已编制板坯数量 \n"); str.append(" A.T06_WGT, --已编制板坯质量 \n"); str.append(" A.T07_CNT, --已编制板坯数量 \n"); str.append(" A.T07_WGT, --已编制板坯质量 \n"); str.append(" A.T08_CNT, --已编制板坯数量 \n"); str.append(" A.T08_WGT, --已编制板坯质量 \n"); str.append(" A.T09_CNT, --已编制板坯数量 \n"); str.append(" A.T09_WGT, --已编制板坯质量 \n"); str.append(" --A.MILL_LEN, --轧制长度 \n"); str.append(" D.MINI, --编制量下限 \n"); str.append(" D.MAXI --编制量上限 \n"); str.append(" -- A.ROLL_DTIME, --注册时间 \n"); str.append(" -- C.WTH_GRP_CD CD_SEQ --宽度组排序序号 \n"); str.append("FROM (SELECT DISTINCT WTH_GRP_CD \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T01',ROLL_COIL_CNT,0)) T01_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T01',ROLL_COIL_WGT,0)) T01_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T02',ROLL_COIL_CNT,0)) T02_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T02',ROLL_COIL_WGT,0)) T02_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T03',ROLL_COIL_CNT,0)) T03_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T03',ROLL_COIL_WGT,0)) T03_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T04',ROLL_COIL_CNT,0)) T04_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T04',ROLL_COIL_WGT,0)) T04_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T05',ROLL_COIL_CNT,0)) T05_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T05',ROLL_COIL_WGT,0)) T05_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T06',ROLL_COIL_CNT,0)) T06_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T06',ROLL_COIL_WGT,0)) T06_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T07',ROLL_COIL_CNT,0)) T07_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T07',ROLL_COIL_WGT,0)) T07_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T08',ROLL_COIL_CNT,0)) T08_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T08',ROLL_COIL_WGT,0)) T08_WGT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T09',ROLL_COIL_CNT,0)) T09_CNT \n"); str.append(" ,sum(DECODE(THK_GRP_CD , 'T09',ROLL_COIL_WGT,0)) T09_WGT \n"); str.append(" FROM C_TBF03_SCH_ROLL \n"); str.append(" group by wth_grp_cd \n"); str.append(" order by wth_grp_cd) A , \n"); str.append(" TBF02_ROLL_WTH_GRP C , \n"); str.append(" TBF02_ROLL_WTH D \n"); str.append("WHERE '1' = '1' \n"); str.append(" AND C.PLT = 'C' \n"); str.append(" AND C.WTH_GRP_CD = A.WTH_GRP_CD(+) \n"); str.append(" AND C.WTH_GRP_CD = D.WTH_GRP_CD(+) \n"); str.append(" ORDER BY WTH_GRP_CD \n"); String sql = str.toString(); cro=this.getDao("KgDao").ExcuteQuery(sql); System.out.println(cro); return cro; } public CoreReturnObject query02(String curLoc,String ordNO,String ordSeq,String entryTime ,String exshapeGrd,String stlGrd,String prodLine,String thkMin ,String thkMax,String wthMin,String wthMax) throws SQLException { CoreReturnObject cro=new CoreReturnObject(); ArrayList paramArray = new ArrayList(); StringBuffer str = new StringBuffer(); str.append("select A.COIL_NO --基料卷号 \n"); str.append(" ,D.H_SPEC_STL_GRD --基料卷牌号 \n"); str.append(" ,D.C_SPEC_STL_GRD --酸轧卷牌号 \n"); str.append(" ,A.ORD_NO --合同号 \n"); str.append(" ,A.ORD_SEQ --订单号 \n"); str.append(" ,A.COIL_THK --基料卷厚度 \n"); str.append(" ,A.COIL_WTH --基料卷宽度 \n"); str.append(" ,A.COIL_LEN --基料卷长度 \n"); str.append(" ,A.ACT_WGT --基料卷重量 \n"); str.append(" ,A.INSTR_COIL_THK --订单厚度 \n"); str.append(" ,A.INSTR_COIL_WTH --订单宽度 \n"); str.append(" ,B.ORD_LEN --订单长度 \n"); str.append(" ,B.ORD_WGT --订单重量 \n"); str.append(" ,A.CUR_LOAD_LOC --堆放位置 \n"); str.append(" ,A.YARD_ENTRY_DTIME --入库时间 \n"); str.append(" ,A.EXTSHAPE_DEC_GRD --表面等级 \n"); str.append(" ,DECODE(B.DIVID_YN,1,'N','Y') DIVID_YN --是否分卷 \n"); str.append(" ,D.DEL_TO_DATE --交货期 \n"); str.append(" ,NVL(D.EMGMTR_NMG_CLF,'N') EMGMTR_NMG_CLF --紧急材代码 \n"); str.append(" ,D.PROD_LINE --产线 \n"); str.append("from c_tbk02_coil_comm a \n"); str.append(" ,(select coil_no,count(1) divid_yn,sum(ord_len) ord_len,sum(ord_wgt) ord_wgt \n"); str.append(" from c_tbk02_coil_comm_d group by coil_no) b \n"); str.append(" --,tbb01_ord_prod c 待确认 \n"); str.append(" ,tbe02_ord_prc d \n"); str.append("where a.coil_no = b.coil_no \n"); str.append("and a.ord_no = d.ord_no \n"); str.append("and a.ord_seq = d.ord_seq \n"); str.append("AND A.CUR_PROG_CD = 'PCA' \n"); str.append("AND A.COIL_STAT = '2' \n"); str.append("AND A.ORD_FL = '1' \n"); str.append("and A.COIL_NO NOT IN (SELECT COIL_NO FROM C_TBF03_SCH_MILL) \n"); if(!curLoc.equals("")){ paramArray.add(curLoc); str.append("and a.cur_load_loc||'&' like :1||'%' \n"); } if(!ordNO.equals("")){ paramArray.add(ordNO); str.append("and a.ord_no = nvl(:2,a.ord_no) \n"); } if(!ordSeq.equals("")){ paramArray.add(ordSeq); str.append("and a.ord_seq = nvl(:3,a.ord_seq) \n"); } if(!entryTime.equals("")){ paramArray.add(entryTime); str.append("and a.yard_entry_dtime >= :4 \n"); } if(!exshapeGrd.equals("")){ paramArray.add(curLoc); str.append("and a.extshape_dec_grd = nvl(:5,a.extshape_dec_grd) \n"); } if(!stlGrd.equals("")){ paramArray.add(stlGrd); str.append("and d.h_stl_grd = nvl(:6,d.h_stl_grd) \n"); } if(!prodLine.equals("")){ paramArray.add(prodLine); str.append("and d.prod_line = nvl(:7,d.prod_line) \n"); } paramArray.add(thkMin); paramArray.add(thkMax); paramArray.add(wthMin); paramArray.add(wthMax); str.append("and a.INSTR_COIL_THK >= :8 \n"); str.append("and a.INSTR_COIL_THK < :9 \n"); str.append("and a.INSTR_COIL_WTH >= :10 \n"); str.append("and a.INSTR_COIL_WTH < :11 \n"); String sql = str.toString(); System.out.println(thkMin); cro=this.getDao("KgDao").ExcuteQuery(sql,paramArray.toArray()); System.out.println(cro); return cro; } public CoreReturnObject query03(String thkGrpCD,String WthGrpCD) throws SQLException { CoreReturnObject cro=new CoreReturnObject(); StringBuffer str = new StringBuffer(); str.append("select a.COIL_NO \n"); str.append(" ,c.H_SPEC_STL_GRD \n"); str.append(" ,c.C_SPEC_STL_GRD \n"); str.append(" ,a.ORD_NO \n"); str.append(" ,a.ORD_SEQ \n"); str.append(" ,a.COIL_THK \n"); str.append(" ,a.COIL_WTH \n"); str.append(" ,a.COIL_LEN \n"); str.append(" ,a.COIL_WGT \n"); str.append(" ,a.ORD_THK \n"); str.append(" ,a.ORD_WGT \n"); str.append(" ,b.CUR_LOAD_LOC \n"); str.append(" ,b.YARD_ENTRY_DTIME \n"); str.append(" ,b.EXTSHAPE_DEC_GRD \n"); str.append(" ,a.DIVID_YN \n"); str.append(" ,c.DEL_TO_DATE \n"); str.append(" ,c.EMGMTR_NMG_CLF \n"); str.append(" ,c.PROD_LINE \n"); str.append("from c_tbf03_sch_mill a \n"); str.append(" ,c_tbk02_coil_comm b \n"); str.append(" ,tbe02_ord_prc c \n"); str.append("where a.COIL_NO = b.COIL_NO \n"); str.append("and a.ORD_NO = c.ORD_NO \n"); str.append("and a.ORD_SEQ = c.ORD_SEQ \n"); str.append("and a.THK_GRP_CD = :1 \n"); str.append("and a.WTH_GRP_CD = :2 \n"); String sql = str.toString(); cro=this.getDao("KgDao").ExcuteQuery(sql,new Object[]{thkGrpCD,WthGrpCD}); System.out.println(cro); return cro; } public CoreReturnObject update01(ArrayList paramArray,String thk_grp_cd,String wth_grp_cd) throws Exception { ArrayList coilNo = paramArray; CoreReturnObject cro=new CoreReturnObject(); String sql = ""; StringBuffer str = new StringBuffer(); str.append("insert into c_tbf03_sch_mill ( \n"); str.append(" COIL_EDT_SEQ --编制顺序号 \n"); str.append(" ,COIL_NO --基料卷号 \n"); str.append(" ,C_COIL_NO --酸轧卷号 \n"); str.append(" ,ROLL_NO --轧制单元号 \n"); str.append(" ,ROLL_COIL_SEQ --轧制单元内顺序号 \n"); str.append(" ,PRODNM_CD --产品代码 \n"); str.append(" ,STL_GRD --基料卷牌号 \n"); str.append(" ,STL_GRP_CD --牌号组 \n"); str.append(" ,COIL_THK --基料卷厚度 \n"); str.append(" ,COIL_WTH --基料卷宽度 \n"); str.append(" ,COIL_LEN --基料卷长度 \n"); str.append(" ,COIL_WGT --基料卷重量 \n"); str.append(" ,THK_GRP_CD --产品宽度组 \n"); str.append(" ,WTH_GRP_CD --产品厚度组 \n"); str.append(" ,THK_AIM --产品目标厚度 \n"); str.append(" ,THK_MIN --产品最小厚度 \n"); str.append(" ,THK_MAX --产品最大厚度 \n"); str.append(" ,WTH_AIM --产品目标宽度 \n"); str.append(" ,WTH_MIN --产品最小宽度 \n"); str.append(" ,WTH_MAX --产品最大宽度 \n"); str.append(" \n"); str.append(" ,ORD_NO --合同号 \n"); str.append(" ,ORD_SEQ --订单号 \n"); str.append(" ,ORD_USEAGE_CD --订单用途代码 \n"); str.append(" ,SPEC_ABBSYM --标准号 \n"); str.append(" ,ORD_CUST_CD --客户代码 \n"); str.append(" ,CUST_CD --客户代码 \n"); str.append(" ,DEST_CD --目的地代码 \n"); str.append(" ,DELV_REQ_DATE --交货期 \n"); str.append(" ,PROD_LINE --去向 \n"); str.append(" \n"); str.append(" ,ORD_THK --订单厚度 \n"); str.append(" ,ORD_WTH --订单宽度 \n"); str.append(" ,ORD_WGT --订单重量 \n"); str.append(" ,ORD_WGT_MIN --订单单重下限 \n"); str.append(" ,ORD_WGT_MAX --订单单重上限 \n"); str.append(" ,ORD_INDIA --订单内径 \n"); str.append(" ,ORD_OUTDIA --订单外径 \n"); str.append(" \n"); str.append(" ,PACK_METHOD --包装方法 \n"); str.append(" ,PATH_MILL_CD --轧制工艺流程 \n"); str.append(" ,DIVID_YN --是否分卷 \n"); str.append(" ,COIL_CUT_CNT --分卷数 \n"); str.append(" ,STATUS_CD --状态 \n"); str.append(" ,FL --编制区分 \n"); str.append(" ) \n"); str.append(" select (SELECT NVL(MAX(ROLL_COIL_SEQ),0) + 1 FROM C_TBF03_SCH_MILL ) COIL_EDT_SEQ \n"); str.append(" ,a.COIL_NO \n"); str.append(" ,'' c_coil_no \n"); str.append(" ,'A0001' \n"); str.append(" ,(SELECT NVL(MAX(ROLL_COIL_SEQ),0) + 1 FROM C_TBF03_SCH_MILL ) ROLL_COIL_SEQ \n"); str.append(" ,A.PRODNM_CD \n"); str.append(" ,A.H_SPEC_STL_GRD STL_GRD \n"); str.append(" ,'' STL_GRP_CD --牌号组 \n"); str.append(" ,A.COIL_THK \n"); str.append(" ,A.COIL_WTH \n"); str.append(" ,A.COIL_LEN \n"); str.append(" ,A.ACT_WGT \n"); str.append(" ,:1 THK_GRP_CD --产品宽度组 \n"); str.append(" ,:2 WTH_GRP_CD --产品厚度组 \n"); str.append(" ,'' THK_AIM --产品目标厚度 \n"); str.append(" ,'' THK_MIN --产品最小厚度 \n"); str.append(" ,'' THK_MAX --产品最大厚度 \n"); str.append(" ,'' WTH_AIM --产品目标宽度 \n"); str.append(" ,'' WTH_MIN --产品最小宽度 \n"); str.append(" ,'' WTH_MAX --产品最大宽度 \n"); str.append(" \n"); str.append(" \n"); str.append(" ,A.ORD_NO \n"); str.append(" ,A.ORD_SEQ \n"); str.append(" ,A.ORD_USE_CD \n"); str.append(" ,A.SPEC_ABBSYM \n"); str.append(" ,'' --客户代码 \n"); str.append(" ,A.CUST_CD \n"); str.append(" ,A.DEST_CD \n"); str.append(" ,C.DEL_TO_DATE \n"); str.append(" ,C.PROD_LINE \n"); str.append(" ,C.ORD_THK \n"); str.append(" ,C.ORD_WTH \n"); str.append(" ,C.ORD_WGT \n"); str.append(" ,'' ORD_WGT_MIN \n"); str.append(" ,'' ORD_WGT_MAX \n"); str.append(" ,C.ORD_INDIA \n"); str.append(" ,C.ORD_OUTDIA \n"); str.append(" \n"); str.append(" ,C.PACK_METHOD \n"); str.append(" ,'' PATH_MILL_CD --轧制工艺流程 \n"); str.append(" ,'' DIVID_YN --是否分卷 \n"); str.append(" ,'' COIL_CUT_CNT --分卷数 \n"); str.append(" ,'' STATUS_CD --状态 \n"); str.append(" ,'' FL --编制区分 \n"); str.append(" from c_tbk02_coil_comm a \n"); str.append(" ,C_TBK02_COIL_COMM_D B \n"); str.append(" ,TBE02_ORD_PRC C \n"); str.append(" WHERE A.COIL_NO = :3 \n"); str.append(" AND A.COIL_NO = B.COIL_NO \n"); str.append(" AND A.ORD_NO = C.ORD_NO \n"); str.append(" AND A.ORD_SEQ = C.ORD_SEQ \n"); str.append(" AND A.CUR_PROG_CD = 'PCA' \n"); str.append(" AND A.COIL_STAT = '2' \n"); str.append(" AND A.ORD_FL = '1' \n"); sql = str.toString(); for(int i = 0 ; i < coilNo.size();i++){ cro=this.getDao("KgDao").ExcuteNonQuery(sql,new Object[]{thk_grp_cd,wth_grp_cd,coilNo.get(i)}); } System.out.println(cro); str = new StringBuffer(); str.append("INSERT INTO C_TBF03_SCH_MILL_D ( \n"); str.append(" COIL_EDT_SEQ \n"); str.append(" ,COIL_CUT_SEQ \n"); str.append(" ,ORD_THK \n"); str.append(" ,ORD_WTH \n"); str.append(" ,ORD_LEN \n"); str.append(" ,ORD_WGT \n"); str.append(" ,ORD_WGT_MIN \n"); str.append(" ,ORD_WGT_MAX \n"); str.append(" ,ORD_INDIA \n"); str.append(" ,ORD_OUTDIA \n"); str.append(" ,ORD_NO \n"); str.append(" ,ORD_SEQ \n"); str.append(" ,ORD_FL \n"); str.append(")( \n"); str.append(" SELECT B.COIL_EDT_SEQ \n"); str.append(" ,A.CUT_SEQ \n"); str.append(" ,A.ORD_THK \n"); str.append(" ,A.ORD_WTH \n"); str.append(" ,A.ORD_LEN \n"); str.append(" ,A.ORD_WGT \n"); str.append(" ,A.ORD_WGT_MIN \n"); str.append(" ,A.ORD_WGT_MAX \n"); str.append(" ,A.ORD_INDIA \n"); str.append(" ,A.ORD_OUTDIA \n"); str.append(" ,A.ORD_NO \n"); str.append(" ,A.ORD_SEQ \n"); str.append(" ,A.ORD_FL \n"); str.append(" FROM C_TBK02_COIL_COMM_D A, \n"); str.append(" (SELECT T.COIL_NO,T.COIL_EDT_SEQ \n"); str.append(" FROM C_TBF03_SCH_MILL T \n"); str.append(" WHERE T.COIL_EDT_SEQ IN \n"); str.append(" (SELECT COIL_EDT_SEQ \n"); str.append(" FROM C_TBF03_SCH_MILL \n"); str.append(" WHERE COIL_EDT_SEQ NOT IN \n"); str.append(" (SELECT COIL_EDT_SEQ FROM C_TBF03_SCH_MILL_D))) B, \n"); str.append(" C_TBK02_COIL_COMM C \n"); str.append(" WHERE '1' = '1' \n"); str.append(" AND A.COIL_NO = C.COIL_NO \n"); str.append(" AND A.COIL_NO = B.COIL_NO \n"); str.append(" ) \n"); sql = str.toString(); cro=this.getDao("KgDao").ExcuteNonQuery(sql); sql = " delete from c_tbf03_sch_roll "; cro=this.getDao("KgDao").ExcuteNonQuery(sql); str = new StringBuffer(); str.append("INSERT INTO C_TBF03_SCH_ROLL \n"); str.append(" ( ROLL_NO \n"); str.append(" ,WTH_GRP_CD \n"); str.append(" ,WTH_MINI \n"); str.append(" ,WTH_MAXI \n"); str.append(" ,THK_GRP_CD \n"); str.append(" ,THK_MINI \n"); str.append(" ,THK_MAXI \n"); str.append(" ,STL_GRD \n"); str.append(" ,ROLL_COIL_CNT \n"); str.append(" ,ROLL_COIL_WGT \n"); str.append(" ,MILL_LEN \n"); str.append(" ,ROLL_DTIME \n"); str.append(" ,FL \n"); str.append(" ) \n"); str.append(" (SELECT A.ROLL_NO \n"); str.append(" ,A.WTH_GRP_CD \n"); str.append(" ,C.MINI \n"); str.append(" ,C.MAXI \n"); str.append(" ,A.THK_GRP_CD \n"); str.append(" ,D.MINI \n"); str.append(" ,D.MAXI \n"); str.append(" ,'' \n"); str.append(" ,COUNT(A.COIL_EDT_SEQ) \n"); str.append(" ,SUM(A.COIL_WGT) \n"); str.append(" ,SUM(B.ORD_LEN) \n"); str.append(" ,TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS') \n"); str.append(" ,'' \n"); str.append(" FROM C_TBF03_SCH_MILL A \n"); str.append(" ,(SELECT COIL_NO,SUM(ORD_LEN) ORD_LEN \n"); str.append(" FROM C_TBK02_COIL_COMM_D \n"); str.append(" GROUP BY COIL_NO)B \n"); str.append(" ,TBF02_ROLL_WTH_GRP C \n"); str.append(" ,TBF02_ROLL_THK_GRP D \n"); str.append(" WHERE A.COIL_NO = B.COIL_NO \n"); str.append(" AND A.WTH_GRP_CD = C.WTH_GRP_CD \n"); str.append(" AND A.THK_GRP_CD = D.THK_GRP_CD \n"); str.append(" AND C.PLT = 'C' \n"); str.append(" AND D.PLT = 'C' \n"); str.append(" GROUP BY (A.ROLL_NO,A.WTH_GRP_CD,C.MINI,C.MAXI,A.THK_GRP_CD,D.MINI,D.MAXI) \n"); str.append(" \n"); str.append(" \n"); str.append(" ) \n"); sql = str.toString(); cro=this.getDao("KgDao").ExcuteNonQuery(sql); return cro; } public CoreReturnObject update02(ArrayList paramArray,String thk_grp_cd,String wth_grp_cd) throws Exception { ArrayList coilNo = paramArray; CoreReturnObject cro=new CoreReturnObject(); String sql = "delete from c_tbf03_sch_mill where coil_no = :1"; for(int i = 0 ; i < coilNo.size();i++){ cro=this.getDao("KgDao").ExcuteNonQuery(sql,new Object[]{coilNo.get(i)}); } sql = "delete from c_tbf03_sch_mill_d where coil_edt_seq not in (select coil_edt_seq from c_tbf03_sch_mill )"; cro=this.getDao("KgDao").ExcuteNonQuery(sql); sql = " delete from c_tbf03_sch_roll "; cro=this.getDao("KgDao").ExcuteNonQuery(sql); return cro; } public CoreReturnObject update03() throws Exception { String sql = "delete from c_tbf03_sch_mill where coil_no = :1"; String name = "{call C_PKG_NIF043010.PLTCM_INDICATION(?,?)}"; CoreReturnObject cro=new CoreReturnObject(); cro=this.getDao("KgDao").ExcuteNonQuery(sql); return cro; } //根据条件得到待轧辊制定的基料卷信息 public CoreReturnObject Query_HCoil_Info(String _Condition) { try { CoreReturnObject rtnobj=new CoreReturnObject(); String Sql = XmlSqlParsersFactory.getSql("UIF041011.Query_HCoil_List"); Sql = Sql + "AND A.FL='0' " + _Condition ; rtnobj=this.getDao("KgDao").ExcuteQuery(Sql); return rtnobj; } catch(Exception ex) { CoreReturnObject err = new CoreReturnObject(); err.SetErrInfo(ex.toString()); return err; } } //根据条件得到已制定的轧制计划明细信息 public CoreReturnObject Query_RollPlan_List() { try { CoreReturnObject rtnobj=new CoreReturnObject(); String Sql = XmlSqlParsersFactory.getSql("UIF042010.Query_RollPlan_List"); rtnobj=this.getDao("KgDao").ExcuteQuery(Sql); return rtnobj; } catch(Exception ex) { CoreReturnObject err = new CoreReturnObject(); err.SetErrInfo(ex.toString()); return err; } } //根据条件得到已制定的轧制计划汇总信息 public CoreReturnObject Query_RollPlan_Info() { try { CoreReturnObject rtnobj=new CoreReturnObject(); String Sql = XmlSqlParsersFactory.getSql("UIF042010.Query_RollPlan_Info"); rtnobj=this.getDao("KgDao").ExcuteQuery(Sql); return rtnobj; } catch(Exception ex) { CoreReturnObject err = new CoreReturnObject(); err.SetErrInfo(ex.toString()); return err; } } //新增轧制计划制定信息 public CoreReturnObject Add_RollPlan_List(String CoilNOS,int Coil_NUM,String User) { try { //CoreReturnObject rtnobj=new CoreReturnObject(); //rtnobj=this.getDao("KgDao").ExcuteProcedure(name, sqltypes, sqlparams); return null; } catch(Exception ex) { CoreReturnObject err = new CoreReturnObject(); err.SetErrInfo(ex.toString()); return err; } } }