| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550 |
- 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<String> paramArray = new ArrayList<String>();
- 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<String> paramArray,String thk_grp_cd,String wth_grp_cd) throws Exception
- {
- ArrayList<String> 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<String> paramArray,String thk_grp_cd,String wth_grp_cd) throws Exception
- {
- ArrayList<String> 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;
- }
- }
- }
|