package com.finstone.gjj.common.bspt; import com.fin.tycpb.funs.MathTools; import com.fins.common.exception.BusException; import com.fins.html.view.data.OutData; import com.fins.jdbc.DataSourceRoute; import com.fins.modules.dao.DataBaseHelper; import com.finstone.framework.support.IUser; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; @Service public class BsptLwyw { @Autowired private JdbcTemplate jdbcTemplate; public OutData getBsywpcdata(Map p, IUser user) { OutData data = new OutData(); String bszt = p.get("BSZT") == null?"":p.get("BSZT").toString(); String zxbh = p.get("zxbh") == null?"":p.get("zxbh").toString(); String zt = p.get("ZT") == null?"":p.get("ZT").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); int total = 0; String bs_sql = ""; String ls_sql = " SELECT \'发送\' cz,a.bsid,a.zxbh,a.bslx,decode(a.bslx,\'ALL\',\'全量\',\'ADD\',\'增量\') bslxmc,g_b_sys_dict.f_get_dict_name(\'BS_YWZT\', a.bszt) bsztmc,a.bszt,decode(a.pctype,\'00\',\'日间批\',\'01\',\'日终批\') pctypemc,to_char(a.lasttime,\'yyyy-mm-dd hh24:mi:ss\') lasttime,a.pctype FROM bs_ywpc a where 1=1 "; ArrayList resultsMap = new ArrayList(); if(!zxbh.equals("")) { ls_sql = ls_sql + " and a.zxbh = \'" + zxbh + "\' "; } if(!bszt.equals("") && zt.equals("1")) { ls_sql = ls_sql + " and a.bszt in (select column_value from table(g_b_app_func.f_get_split(\'" + bszt + "\', \',\')))"; } List bsptResult = DataBaseHelper.queryForList(ls_sql, new Object[0]); DataSourceRoute.putAppId("sjjh"); for(int i = 0; i < bsptResult.size(); ++i) { String bsid = ((Map)bsptResult.get(i)).get("bsid") == null?"":((Map)bsptResult.get(i)).get("bsid").toString(); String zxbh1 = ((Map)bsptResult.get(i)).get("zxbh") == null?"":((Map)bsptResult.get(i)).get("zxbh").toString(); String bslx = ((Map)bsptResult.get(i)).get("bslx") == null?"":((Map)bsptResult.get(i)).get("bslx").toString(); String bslxmc = ((Map)bsptResult.get(i)).get("bslxmc") == null?"":((Map)bsptResult.get(i)).get("bslxmc").toString(); String bszt1 = ((Map)bsptResult.get(i)).get("bszt") == null?"":((Map)bsptResult.get(i)).get("bszt").toString(); String bsztmc = ((Map)bsptResult.get(i)).get("bsztmc") == null?"":((Map)bsptResult.get(i)).get("bsztmc").toString(); String pctypemc = ((Map)bsptResult.get(i)).get("pctypemc") == null?"":((Map)bsptResult.get(i)).get("pctypemc").toString(); String lasttime = ((Map)bsptResult.get(i)).get("lasttime") == null?"":((Map)bsptResult.get(i)).get("lasttime").toString(); String pctype = ((Map)bsptResult.get(i)).get("pctype") == null?"":((Map)bsptResult.get(i)).get("pctype").toString(); List lstResult; int j; HashMap rowMap; if(zt.equals("1")) { bs_sql = " SELECT decode(nvl(a.status,\'00\'),\'00\',\'发送\',\'01\',\'待返回\',\'11\',\'待返回\',\'22\',\'异常处理\') cz,to_char(a.rq,\'yyyy-mm-dd hh24:mi:ss\') cxsj,a.transcode,a.tablename,a.pcid FROM js_zjsf a,(select ? as bsid from dual) b where a.ywid(+) = b.bsid and a.transcode(+) = ? "; lstResult = DataBaseHelper.queryForList(bs_sql, new Object[]{bsid, bszt1, bsid, bszt1, bsid, transcode}); for(j = 0; j < lstResult.size(); ++j) { rowMap = new HashMap(); rowMap.put("BSID", bsid); rowMap.put("ZXBH", zxbh1); rowMap.put("BSLX", bslx); rowMap.put("BSLXMC", bslxmc); rowMap.put("BSZT", bszt1); rowMap.put("BSZTMC", bsztmc); rowMap.put("PCTYPEMC", pctypemc); rowMap.put("LASTTIME", lasttime); rowMap.put("PCTYPE", pctype); rowMap.put("CZ", ((Map)lstResult.get(j)).get("CZ") == null?"":((Map)lstResult.get(j)).get("CZ").toString()); rowMap.put("CXSJ", ((Map)lstResult.get(j)).get("CXSJ") == null?"":((Map)lstResult.get(j)).get("CXSJ").toString()); rowMap.put("TRANSCODE", ((Map)lstResult.get(j)).get("TRANSCODE") == null?"":((Map)lstResult.get(j)).get("TRANSCODE").toString()); rowMap.put("TABLENAME", ((Map)lstResult.get(j)).get("TABLENAME") == null?"":((Map)lstResult.get(j)).get("TABLENAME").toString()); rowMap.put("PCID", ((Map)lstResult.get(j)).get("PCID") == null?"":((Map)lstResult.get(j)).get("PCID").toString()); resultsMap.add(rowMap); ++total; } } else if(zt.equals("2")) { bs_sql = "SELECT a.rq cxsj,\t\t\tdecode(a.transcode,\'BDC701\',decode(nvl(a.c3, \'00\'), \'00\', \'下载成功\', \'01\', \'下载中\',\'02\',\'下载失败\'),\'BDC712\',decode(nvl(a.c3, \'00\'), \'00\', \'下载成功\', \'01\', \'下载中\',\'02\',\'下载失败\'),\t\t\t\t \'BDC702\',decode(nvl(a.c3, \'00\'),\'00\',\'校验已完成\',\'01\', \'校验中\',\'02\',\'校验未通过\'),\'BDC713\',decode(nvl(a.c3, \'00\'),\'00\',\'校验已完成\',\'01\', \'校验中\',\'02\',\'校验未通过\')) as sqclzt,\t\t\t\t a.c4 sbyy,a.transcode,a.id\t\t\t\t FROM js_temp_import a\t\t\t where (a.c1||a.c2 = ? or a.c1||a.c6 = ?)"; if(transcode.equals("BDC701")) { bs_sql = bs_sql + "\t\t\t\t and a.transcode in (\'BDC701\',\'BDC712\')"; } else { bs_sql = bs_sql + "\t\t\t\t and a.transcode in (\'BDC702\',\'BDC713\')"; } bs_sql = bs_sql + "\t\t\torder by a.id desc"; lstResult = DataBaseHelper.queryForList(bs_sql, new Object[]{bsid, bsid}); for(j = 0; j < lstResult.size(); ++j) { rowMap = new HashMap(); rowMap.put("BSID", bsid); rowMap.put("ZXBH", zxbh1); rowMap.put("BSLX", bslx); rowMap.put("BSLXMC", bslxmc); rowMap.put("BSZT", bszt1); rowMap.put("BSZTMC", bsztmc); rowMap.put("PCTYPEMC", pctypemc); rowMap.put("LASTTIME", lasttime); rowMap.put("PCTYPE", pctype); rowMap.put("CXSJ", ((Map)lstResult.get(j)).get("CXSJ") == null?"":((Map)lstResult.get(j)).get("CXSJ").toString()); rowMap.put("TRANSCODE", ((Map)lstResult.get(j)).get("TRANSCODE") == null?"":((Map)lstResult.get(j)).get("TRANSCODE").toString()); rowMap.put("SQCLZT", ((Map)lstResult.get(j)).get("SQCLZT") == null?"":((Map)lstResult.get(j)).get("SQCLZT").toString()); rowMap.put("SBYY", ((Map)lstResult.get(j)).get("SBYY") == null?"":((Map)lstResult.get(j)).get("SBYY").toString()); rowMap.put("ID", ((Map)lstResult.get(j)).get("ID") == null?"":((Map)lstResult.get(j)).get("ID").toString()); resultsMap.add(rowMap); ++total; } } } data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(String.valueOf(total))); data.setData(resultsMap); DataSourceRoute.putAppId("default"); return data; } public OutData getZjsfxx(Map p, IUser user) { OutData data = new OutData(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String c1 = ""; String c2 = ""; String c3 = ""; String c4 = ""; String c5 = ""; String c6 = ""; String c7 = ""; if(!transcode.equals("") && transcode.equals("BDC703")) { c2 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); c3 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); c4 = p.get("JKHTBH") == null?"":p.get("JKHTBH").toString(); c1 = p.get("XINGMING") == null?"":p.get("XINGMING").toString(); } if(!transcode.equals("") && transcode.equals("BDC704")) { c1 = p.get("KSRQ") == null?"":p.get("KSRQ").toString().replace(".", ""); c2 = p.get("JSRQ") == null?"":p.get("JSRQ").toString().replace(".", ""); c3 = p.get("CXLX") == null?"":p.get("CXLX").toString(); c4 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); c5 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); c6 = p.get("SQBM") == null?"":p.get("SQBM").toString(); c7 = p.get("GRZH") == null?"":p.get("GRZH").toString(); } if(!transcode.equals("") && transcode.equals("BDC705")) { c1 = p.get("KSRQ") == null?"":p.get("KSRQ").toString().replace(".", ""); c2 = p.get("JSRQ") == null?"":p.get("JSRQ").toString().replace(".", ""); c3 = p.get("CXLX") == null?"":p.get("CXLX").toString(); c4 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); c5 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); c6 = p.get("SQBM") == null?"":p.get("SQBM").toString(); c7 = p.get("DKZH") == null?"":p.get("DKZH").toString(); } if(!transcode.equals("") && transcode.equals("BDC706")) { c4 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); c5 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); c7 = p.get("XINGMING") == null?"":p.get("XINGMING").toString(); } String pageSize = p.get("pageSize") == null?"":p.get("pageSize").toString(); String pageIndex = p.get("pageIndex") == null?"":p.get("pageIndex").toString(); DataSourceRoute.putAppId("sjjh"); String ls_sql = "select pcid,transcode,tablename,to_char(rq,\'yyyy-mm-dd hh24:mi:ss\') as rq ,to_char(exception_date,\'yyyy-mm-dd hh24:mi:ss\') as ycrq,exception_msg as ycxx,status jszt, decode(\'BDC703\',decode(c3,\'00\',\'个人查询\',\'01\',\'公积金中心查询\'),\'BDC704\',decode(c3,\'00\',\'归集余额查询\',\'01\',\'缴存明细查询\'),\'BDC705\',decode(c3,\'00\',\'贷款信息查询\',\'01\',\'贷款明细查询\',\'02\',\'贷款逾期信息查询\')) cxlxmc,decode(status,\'01\',\'待返回\',\'11\',\'待返回\',\'21\',\'返回成功\',\'22\',\'异常处理\') cz,c1 as KSRQ,c2 as JSRQ,c3 as cxlx,c4 as ZJLX,c5 as ZJHM,c6 as SQBM,c7 as XINGMING,c7 as grzh,c7 as dkzh, decode(c3,\'00\',\'个人信息查询\',\'01\',\'归集余额查询\',\'02\',\'缴存明细查询\') as CXLXMC4,decode(c3,\'00\',\'贷款信息查询\',\'01\',\'贷款账户查询\',\'02\',\'贷款明细查询\',\'03\',\'贷款逾期信息查询\') as CXLXMC5,decode(c4,\'01\',\'身份证\',\'02\',\'军官证\',\'03\',\'护照\',\'04\',\'外国人永久居留证\',\'71\',\'港澳通行证\',\'72\',\'台湾通行证\',\'99\',\'其它\') as ZJLXMC,decode(c2,\'01\',\'身份证\',\'02\',\'军官证\',\'03\',\'护照\',\'04\',\'外国人永久居留证\',\'71\',\'港澳通行证\',\'72\',\'台湾通行证\',\'99\',\'其它\') as ZJLXMC3,c1 as jkrxm,c3 as zjhm3,c4 as jkhtbh from v_js_zjsf where transcode = ? "; if(!c1.equals("")) { ls_sql = ls_sql + " and c1 = \'" + c1 + "\' "; } if(!c2.equals("")) { ls_sql = ls_sql + " and c2 = \'" + c2 + "\' "; } if(!c3.equals("")) { ls_sql = ls_sql + " and c3 = \'" + c3 + "\' "; } if(!c4.equals("")) { ls_sql = ls_sql + " and c4 = \'" + c4 + "\' "; } if(!c5.equals("")) { ls_sql = ls_sql + " and c5 = \'" + c5 + "\' "; } if(!c6.equals("")) { ls_sql = ls_sql + " and c6 = \'" + c6 + "\' "; } if(!c7.equals("")) { ls_sql = ls_sql + " and c7 = \'" + c7 + "\' "; } ls_sql = ls_sql + " order by pcid desc "; Map page = DataBaseHelper.queryForMap("select count(1) TOTAL from ( " + ls_sql + " )", new Object[]{transcode}); long v_start_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex), Double.parseDouble(pageSize)) + 1); long v_end_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex) + 1.0D, Double.parseDouble(pageSize))); String sql = "select * from (select row_.*, rownum rownum_ from (" + ls_sql + ") row_) where rownum_ <= " + v_end_row + " and rownum_ >= " + v_start_row; List lstResult = DataBaseHelper.queryForList(sql, new Object[]{transcode}); if(lstResult != null && lstResult.size() > 0) { data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(page.get("TOTAL").toString())); data.setData(lstResult); } else { data.setCode(-1); } DataSourceRoute.putAppId("default"); return data; } public OutData getBdc702Back(Map p, IUser user) { OutData data = new OutData(); String pcid = p.get("ID") == null?"":p.get("ID").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String pageSize = p.get("pageSize") == null?"":p.get("pageSize").toString(); String pageIndex = p.get("pageIndex") == null?"":p.get("pageIndex").toString(); String ls_sql = "select * from (select dbms_lob.substr(substr(filemx,0,instr(filemx,\'|\',1,1)-1)) s1, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,1)+1,instr(filemx,\'|\',1,2)-instr(filemx,\'|\',1,1)-1)) s2, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,2)+1,instr(filemx,\'|\',1,3)-instr(filemx,\'|\',1,2)-1)) s3, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,3)+1,instr(filemx,\'|\',1,4)-instr(filemx,\'|\',1,3)-1)) s4, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,4)+1,instr(filemx,\'|\',1,5)-instr(filemx,\'|\',1,4)-1)) s5, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,5)+1,instr(filemx,\'|\',1,6)-instr(filemx,\'|\',1,5)-1)) s6, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,6)+1,instr(filemx,\'|\',1,7)-instr(filemx,\'|\',1,6)-1)) s7, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,7)+1,instr(filemx,\'|\',1,8)-instr(filemx,\'|\',1,7)-1)) s8, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,8)+1,instr(filemx,\'|\',1,9)-instr(filemx,\'|\',1,8)-1)) s9, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,9)+1,instr(filemx,\'|\',1,10)-instr(filemx,\'|\',1,9)-1)) s10, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,10)+1,instr(filemx,\'|\',1,11)-instr(filemx,\'|\',1,10)-1)) s11, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,11)+1,instr(filemx,\'|\',1,12)-instr(filemx,\'|\',1,11)-1)) s12, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,12)+1,instr(filemx,\'|\',1,13)-instr(filemx,\'|\',1,12)-1)) s13, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,13)+1,instr(filemx,\'|\',1,14)-instr(filemx,\'|\',1,13)-1)) s14, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,14)+1,instr(filemx,\'|\',1,15)-instr(filemx,\'|\',1,14)-1)) s15, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,15)+1,instr(filemx,\'|\',1,16)-instr(filemx,\'|\',1,15)-1)) s16, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,16)+1,instr(filemx,\'|\',1,17)-instr(filemx,\'|\',1,16)-1)) s17, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,17)+1,instr(filemx,\'|\',1,18)-instr(filemx,\'|\',1,17)-1)) s18, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,18)+1,instr(filemx,\'|\',1,19)-instr(filemx,\'|\',1,18)-1)) s19, dbms_lob.substr(substr(filemx,instr(filemx,\'|\',1,19)+1,instr(filemx,\'|\',1,20)-instr(filemx,\'|\',1,19)-1)) s20 from (select dbms_lob.substr(filemx) filemx from (select id, regexp_substr(filemx, \'[^\' || chr(10) || \']+\', 1, level) filemx, level lv\t\t\t\tfrom (select id,filemx from js_temp_import where id = ? and transcode = ?) CONNECT BY id = PRIOR id AND PRIOR DBMS_RANDOM.VALUE IS NOT NULL AND LEVEL <= regexp_count(filemx, chr(10)) + 1) where trim(dbms_lob.substr(filemx)) is not null)) where 1=1 "; DataSourceRoute.putAppId("sjjh"); Map page = DataBaseHelper.queryForMap("select count(1) TOTAL from ( " + ls_sql + " )", new Object[]{pcid, transcode}); long v_start_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex), Double.parseDouble(pageSize)) + 1); long v_end_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex) + 1.0D, Double.parseDouble(pageSize))); String sql = "select * from (select row_.*, rownum rownum_ from (" + ls_sql + ") row_) where rownum_ <= " + v_end_row + " and rownum_ >= " + v_start_row; List lstResult = DataBaseHelper.queryForList(sql, new Object[]{pcid, transcode}); if(lstResult != null && lstResult.size() > 0) { data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(page.get("TOTAL").toString())); data.setData(lstResult); } else { data.setCode(-1); } DataSourceRoute.putAppId("default"); return data; } public OutData getDtGrid(Map p, IUser user) { OutData data = new OutData(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); if(transcode.equals("BDC703")) { data = this.getBdc703Back(p, user); } if(transcode.equals("BDC704")) { data = this.getBdc704Back(p, user); } if(transcode.equals("BDC705")) { data = this.getBdc705Back(p, user); } if(transcode.equals("BDC706")) { data = this.getBdc706Back(p, user); } return data; } public OutData getBdc703Back(Map p, IUser user) { OutData data = new OutData(); String pcid = p.get("PCID") == null?"":p.get("PCID").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String pageSize = p.get("pageSize") == null?"":p.get("pageSize").toString(); String pageIndex = p.get("pageIndex") == null?"":p.get("pageIndex").toString(); String tbname = p.get("TBNAME") == null?"":p.get("TBNAME").toString(); String ls_sql = "select * from (select dbms_lob.substr(substr(filemx,0,instr(filemx,\'|@|\',1,1)-1)) s1, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,1)+3,instr(filemx,\'|@|\',1,2)-instr(filemx,\'|@|\',1,1)-3)) s2, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,2)+3,instr(filemx,\'|@|\',1,3)-instr(filemx,\'|@|\',1,2)-3)) s3, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,3)+3,instr(filemx,\'|@|\',1,4)-instr(filemx,\'|@|\',1,3)-3)) s4, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,4)+3,instr(filemx,\'|@|\',1,5)-instr(filemx,\'|@|\',1,4)-3)) s5, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,5)+3,instr(filemx,\'|@|\',1,6)-instr(filemx,\'|@|\',1,5)-3)) s6, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,6)+3,instr(filemx,\'|@|\',1,7)-instr(filemx,\'|@|\',1,6)-3)) s7, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,7)+3,instr(filemx,\'|@|\',1,8)-instr(filemx,\'|@|\',1,7)-3)) s8, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,8)+3,instr(filemx,\'|@|\',1,9)-instr(filemx,\'|@|\',1,8)-3)) s9, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,9)+3,instr(filemx,\'|@|\',1,10)-instr(filemx,\'|@|\',1,9)-3)) s10, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,10)+3,instr(filemx,\'|@|\',1,11)-instr(filemx,\'|@|\',1,10)-3)) s11, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,11)+3,instr(filemx,\'|@|\',1,12)-instr(filemx,\'|@|\',1,11)-3)) s12, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,12)+3,instr(filemx,\'|@|\',1,13)-instr(filemx,\'|@|\',1,12)-3)) s13, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,13)+3,instr(filemx,\'|@|\',1,14)-instr(filemx,\'|@|\',1,13)-3)) s14, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,14)+3,instr(filemx,\'|@|\',1,15)-instr(filemx,\'|@|\',1,14)-3)) s15, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,15)+3,instr(filemx,\'|@|\',1,16)-instr(filemx,\'|@|\',1,15)-3)) s16, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,16)+3,instr(filemx,\'|@|\',1,17)-instr(filemx,\'|@|\',1,16)-3)) s17, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,17)+3,instr(filemx,\'|@|\',1,18)-instr(filemx,\'|@|\',1,17)-3)) s18, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,18)+3,instr(filemx,\'|@|\',1,19)-instr(filemx,\'|@|\',1,18)-3)) s19, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,19)+3,instr(filemx,\'|@|\',1,20)-instr(filemx,\'|@|\',1,19)-3)) s20 from (select dbms_lob.substr(filemx) filemx from (select pcid, regexp_substr(filemx, \'[^\' || chr(10) || \']+\', 1, level) filemx, level lv\t\t\t\tfrom (select pcid,filemx from js_zjsf where pcid = ? and transcode = ? and tablename = ?) CONNECT BY pcid = PRIOR pcid AND PRIOR DBMS_RANDOM.VALUE IS NOT NULL AND LEVEL <= regexp_count(filemx, chr(10)) + 1) where trim(dbms_lob.substr(filemx)) is not null)) where 1=1 "; String grxm = p.get("GRXM") == null?"":p.get("GRXM").toString(); String grzjh = p.get("GRZJH") == null?"":p.get("GRZJH").toString(); String gtjkrxm = p.get("GTJKRXM") == null?"":p.get("GTJKRXM").toString(); String gtjkrzjh = p.get("GTJKRZJH") == null?"":p.get("GTJKRZJH").toString(); if(!grxm.equals("")) { ls_sql = ls_sql + " and grxm = \'" + grxm + "\' "; } if(!grzjh.equals("")) { ls_sql = ls_sql + " and grzjh = \'" + grzjh + "\' "; } if(!gtjkrxm.equals("")) { ls_sql = ls_sql + " and gtjkrxm = \'" + gtjkrxm + "\' "; } if(!gtjkrzjh.equals("")) { ls_sql = ls_sql + " and gtjkrzjh = \'" + gtjkrzjh + "\' "; } DataSourceRoute.putAppId("sjjh"); Map page = DataBaseHelper.queryForMap("select count(1) TOTAL from ( " + ls_sql + " )", new Object[]{pcid, transcode, tbname}); long v_start_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex), Double.parseDouble(pageSize)) + 1); long v_end_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex) + 1.0D, Double.parseDouble(pageSize))); String sql = "select * from (select row_.*, rownum rownum_ from (" + ls_sql + ") row_) where rownum_ <= " + v_end_row + " and rownum_ >= " + v_start_row; List lstResult = DataBaseHelper.queryForList(sql, new Object[]{pcid, transcode, tbname}); if(lstResult != null && lstResult.size() > 0) { data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(page.get("TOTAL").toString())); data.setData(lstResult); } else { data.setCode(-1); } DataSourceRoute.putAppId("default"); return data; } public OutData getBdc704Back(Map p, IUser user) { OutData data = new OutData(); String pcid = p.get("PCID") == null?"":p.get("PCID").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String pageSize = p.get("pageSize") == null?"":p.get("pageSize").toString(); String pageIndex = p.get("pageIndex") == null?"":p.get("pageIndex").toString(); String tbname = p.get("TBNAME") == null?"":p.get("TBNAME").toString(); if(p.get("CXLX") == null) { String var10000 = ""; } else { p.get("CXLX").toString(); } String ls_sql = ""; ls_sql = "select * from (select dbms_lob.substr(substr(filemx,0,instr(filemx,\'|@|\',1,1)-1)) s1, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,1)+3,instr(filemx,\'|@|\',1,2)-instr(filemx,\'|@|\',1,1)-3)) s2, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,2)+3,instr(filemx,\'|@|\',1,3)-instr(filemx,\'|@|\',1,2)-3)) s3, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,3)+3,instr(filemx,\'|@|\',1,4)-instr(filemx,\'|@|\',1,3)-3)) s4, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,4)+3,instr(filemx,\'|@|\',1,5)-instr(filemx,\'|@|\',1,4)-3)) s5, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,5)+3,instr(filemx,\'|@|\',1,6)-instr(filemx,\'|@|\',1,5)-3)) s6, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,6)+3,instr(filemx,\'|@|\',1,7)-instr(filemx,\'|@|\',1,6)-3)) s7, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,7)+3,instr(filemx,\'|@|\',1,8)-instr(filemx,\'|@|\',1,7)-3)) s8, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,8)+3,instr(filemx,\'|@|\',1,9)-instr(filemx,\'|@|\',1,8)-3)) s9, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,9)+3,instr(filemx,\'|@|\',1,10)-instr(filemx,\'|@|\',1,9)-3)) s10, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,10)+3,instr(filemx,\'|@|\',1,11)-instr(filemx,\'|@|\',1,10)-3)) s11, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,11)+3,instr(filemx,\'|@|\',1,12)-instr(filemx,\'|@|\',1,11)-3)) s12, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,12)+3,instr(filemx,\'|@|\',1,13)-instr(filemx,\'|@|\',1,12)-3)) s13, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,13)+3,instr(filemx,\'|@|\',1,14)-instr(filemx,\'|@|\',1,13)-3)) s14, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,14)+3,instr(filemx,\'|@|\',1,15)-instr(filemx,\'|@|\',1,14)-3)) s15, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,15)+3,instr(filemx,\'|@|\',1,16)-instr(filemx,\'|@|\',1,15)-3)) s16, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,16)+3,instr(filemx,\'|@|\',1,17)-instr(filemx,\'|@|\',1,16)-3)) s17, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,17)+3,instr(filemx,\'|@|\',1,18)-instr(filemx,\'|@|\',1,17)-3)) s18, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,18)+3,instr(filemx,\'|@|\',1,19)-instr(filemx,\'|@|\',1,18)-3)) s19, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,19)+3,instr(filemx,\'|@|\',1,20)-instr(filemx,\'|@|\',1,19)-3)) s20 "; ls_sql = ls_sql + " from (select dbms_lob.substr(filemx) filemx from (select pcid, regexp_substr(filemx, \'[^\' || chr(10) || \']+\', 1, level) filemx, level lv\t\t\t\tfrom (select pcid,filemx from js_zjsf where pcid = ? and transcode = ? and tablename = ?) CONNECT BY pcid = PRIOR pcid AND PRIOR DBMS_RANDOM.VALUE IS NOT NULL AND LEVEL <= regexp_count(filemx, chr(10)) + 1) where trim(dbms_lob.substr(filemx)) is not null)) where 1=1 "; String jzrq = p.get("JZRQ") == null?"":p.get("JZRQ").toString(); String zhye1 = p.get("ZHYEKS") == null?"":p.get("ZHYEKS").toString(); String zhye2 = p.get("ZHYEJS") == null?"":p.get("ZHYEJS").toString(); if(!jzrq.equals("")) { ls_sql = ls_sql + " and jzrq = \'" + jzrq + "\' "; } if(!zhye1.equals("")) { ls_sql = ls_sql + " and grzhye >= \'" + zhye1 + "\' "; } if(!zhye2.equals("")) { ls_sql = ls_sql + " and grzhye <= \'" + zhye2 + "\' "; } DataSourceRoute.putAppId("sjjh"); Map page = DataBaseHelper.queryForMap("select count(1) TOTAL from ( " + ls_sql + " )", new Object[]{pcid, transcode, tbname}); long v_start_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex), Double.parseDouble(pageSize)) + 1); long v_end_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex) + 1.0D, Double.parseDouble(pageSize))); String sql = "select * from (select row_.*, rownum rownum_ from (" + ls_sql + ") row_) where rownum_ <= " + v_end_row + " and rownum_ >= " + v_start_row; List lstResult = DataBaseHelper.queryForList(sql, new Object[]{pcid, transcode, tbname}); if(lstResult != null && lstResult.size() > 0) { data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(page.get("TOTAL").toString())); data.setData(lstResult); } else { data.setCode(-1); } DataSourceRoute.putAppId("default"); return data; } public OutData getBdc705Back(Map p, IUser user) { OutData data = new OutData(); String pcid = p.get("PCID") == null?"":p.get("PCID").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String pageSize = p.get("pageSize") == null?"":p.get("pageSize").toString(); String pageIndex = p.get("pageIndex") == null?"":p.get("pageIndex").toString(); String tbname = p.get("TBNAME") == null?"":p.get("TBNAME").toString(); if(p.get("CXLX") == null) { String var10000 = ""; } else { p.get("CXLX").toString(); } String ls_sql = ""; ls_sql = "select * from (select dbms_lob.substr(substr(filemx,0,instr(filemx,\'|@|\',1,1)-1)) s1, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,1)+3,instr(filemx,\'|@|\',1,2)-instr(filemx,\'|@|\',1,1)-3)) s2, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,2)+3,instr(filemx,\'|@|\',1,3)-instr(filemx,\'|@|\',1,2)-3)) s3, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,3)+3,instr(filemx,\'|@|\',1,4)-instr(filemx,\'|@|\',1,3)-3)) s4, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,4)+3,instr(filemx,\'|@|\',1,5)-instr(filemx,\'|@|\',1,4)-3)) s5, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,5)+3,instr(filemx,\'|@|\',1,6)-instr(filemx,\'|@|\',1,5)-3)) s6, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,6)+3,instr(filemx,\'|@|\',1,7)-instr(filemx,\'|@|\',1,6)-3)) s7, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,7)+3,instr(filemx,\'|@|\',1,8)-instr(filemx,\'|@|\',1,7)-3)) s8, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,8)+3,instr(filemx,\'|@|\',1,9)-instr(filemx,\'|@|\',1,8)-3)) s9, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,9)+3,instr(filemx,\'|@|\',1,10)-instr(filemx,\'|@|\',1,9)-3)) s10, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,10)+3,instr(filemx,\'|@|\',1,11)-instr(filemx,\'|@|\',1,10)-3)) s11, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,11)+3,instr(filemx,\'|@|\',1,12)-instr(filemx,\'|@|\',1,11)-3)) s12, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,12)+3,instr(filemx,\'|@|\',1,13)-instr(filemx,\'|@|\',1,12)-3)) s13, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,13)+3,instr(filemx,\'|@|\',1,14)-instr(filemx,\'|@|\',1,13)-3)) s14, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,14)+3,instr(filemx,\'|@|\',1,15)-instr(filemx,\'|@|\',1,14)-3)) s15, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,15)+3,instr(filemx,\'|@|\',1,16)-instr(filemx,\'|@|\',1,15)-3)) s16, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,16)+3,instr(filemx,\'|@|\',1,17)-instr(filemx,\'|@|\',1,16)-3)) s17, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,17)+3,instr(filemx,\'|@|\',1,18)-instr(filemx,\'|@|\',1,17)-3)) s18, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,18)+3,instr(filemx,\'|@|\',1,19)-instr(filemx,\'|@|\',1,18)-3)) s19, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,19)+3,instr(filemx,\'|@|\',1,20)-instr(filemx,\'|@|\',1,19)-3)) s20 "; ls_sql = ls_sql + " from (select dbms_lob.substr(filemx) filemx from (select pcid, regexp_substr(filemx, \'[^\' || chr(10) || \']+\', 1, level) filemx, level lv\t\t\t\tfrom (select pcid,filemx from js_zjsf where pcid = ? and transcode = ? and tablename = ?) CONNECT BY pcid = PRIOR pcid AND PRIOR DBMS_RANDOM.VALUE IS NOT NULL AND LEVEL <= regexp_count(filemx, chr(10)) + 1) where trim(dbms_lob.substr(filemx)) is not null)) where 1=1 "; DataSourceRoute.putAppId("sjjh"); Map page = DataBaseHelper.queryForMap("select count(1) TOTAL from ( " + ls_sql + " )", new Object[]{pcid, transcode, tbname}); long v_start_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex), Double.parseDouble(pageSize)) + 1); long v_end_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex) + 1.0D, Double.parseDouble(pageSize))); String sql = "select * from (select row_.*, rownum rownum_ from (" + ls_sql + ") row_) where rownum_ <= " + v_end_row + " and rownum_ >= " + v_start_row; List lstResult = DataBaseHelper.queryForList(sql, new Object[]{pcid, transcode, tbname}); if(lstResult != null && lstResult.size() > 0) { data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(page.get("TOTAL").toString())); data.setData(lstResult); } else { data.setCode(-1); } DataSourceRoute.putAppId("default"); return data; } public OutData getBdc706Back(Map p, IUser user) { OutData data = new OutData(); String pcid = p.get("PCID") == null?"":p.get("PCID").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String pageSize = p.get("pageSize") == null?"":p.get("pageSize").toString(); String pageIndex = p.get("pageIndex") == null?"":p.get("pageIndex").toString(); String tbname = p.get("TBNAME") == null?"":p.get("TBNAME").toString(); String ls_sql = "select * from (select dbms_lob.substr(substr(filemx,0,instr(filemx,\'|@|\',1,1)-1)) s1, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,1)+3,instr(filemx,\'|@|\',1,2)-instr(filemx,\'|@|\',1,1)-3)) s2, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,2)+3,instr(filemx,\'|@|\',1,3)-instr(filemx,\'|@|\',1,2)-3)) s3, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,3)+3,instr(filemx,\'|@|\',1,4)-instr(filemx,\'|@|\',1,3)-3)) s4, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,4)+3,instr(filemx,\'|@|\',1,5)-instr(filemx,\'|@|\',1,4)-3)) s5, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,5)+3,instr(filemx,\'|@|\',1,6)-instr(filemx,\'|@|\',1,5)-3)) s6, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,6)+3,instr(filemx,\'|@|\',1,7)-instr(filemx,\'|@|\',1,6)-3)) s7, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,7)+3,instr(filemx,\'|@|\',1,8)-instr(filemx,\'|@|\',1,7)-3)) s8, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,8)+3,instr(filemx,\'|@|\',1,9)-instr(filemx,\'|@|\',1,8)-3)) s9, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,9)+3,instr(filemx,\'|@|\',1,10)-instr(filemx,\'|@|\',1,9)-3)) s10, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,10)+3,instr(filemx,\'|@|\',1,11)-instr(filemx,\'|@|\',1,10)-3)) s11, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,11)+3,instr(filemx,\'|@|\',1,12)-instr(filemx,\'|@|\',1,11)-3)) s12, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,12)+3,instr(filemx,\'|@|\',1,13)-instr(filemx,\'|@|\',1,12)-3)) s13, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,13)+3,instr(filemx,\'|@|\',1,14)-instr(filemx,\'|@|\',1,13)-3)) s14, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,14)+3,instr(filemx,\'|@|\',1,15)-instr(filemx,\'|@|\',1,14)-3)) s15, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,15)+3,instr(filemx,\'|@|\',1,16)-instr(filemx,\'|@|\',1,15)-3)) s16, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,16)+3,instr(filemx,\'|@|\',1,17)-instr(filemx,\'|@|\',1,16)-3)) s17, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,17)+3,instr(filemx,\'|@|\',1,18)-instr(filemx,\'|@|\',1,17)-3)) s18, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,18)+3,instr(filemx,\'|@|\',1,19)-instr(filemx,\'|@|\',1,18)-3)) s19, dbms_lob.substr(substr(filemx,instr(filemx,\'|@|\',1,19)+3,instr(filemx,\'|@|\',1,20)-instr(filemx,\'|@|\',1,19)-3)) s20 from (select dbms_lob.substr(filemx) filemx from (select pcid, regexp_substr(filemx, \'[^\' || chr(10) || \']+\', 1, level) filemx, level lv\t\t\t\tfrom (select pcid,filemx from js_zjsf where pcid = ? and transcode = ? and tablename = ?) CONNECT BY pcid = PRIOR pcid AND PRIOR DBMS_RANDOM.VALUE IS NOT NULL AND LEVEL <= regexp_count(filemx, chr(10)) + 1) where trim(dbms_lob.substr(filemx)) is not null)) where 1=1 "; DataSourceRoute.putAppId("sjjh"); Map page = DataBaseHelper.queryForMap("select count(1) TOTAL from ( " + ls_sql + " )", new Object[]{pcid, transcode, tbname}); long v_start_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex), Double.parseDouble(pageSize)) + 1); long v_end_row = (long)((int)MathTools.mul(Double.parseDouble(pageIndex) + 1.0D, Double.parseDouble(pageSize))); String sql = "select * from (select row_.*, rownum rownum_ from (" + ls_sql + ") row_) where rownum_ <= " + v_end_row + " and rownum_ >= " + v_start_row; List lstResult = DataBaseHelper.queryForList(sql, new Object[]{pcid, transcode, tbname}); if(lstResult != null && lstResult.size() > 0) { data.setCode(0); data.setMsg("-"); data.setTotal(Long.parseLong(page.get("TOTAL").toString())); data.setData(lstResult); } else { data.setCode(-1); } DataSourceRoute.putAppId("default"); return data; } @Transactional( propagation = Propagation.NOT_SUPPORTED ) public void addBdc701(Map p, IUser user) { DataSourceRoute.putAppId("sjjh"); String bsid = p.get("BSID") == null?"":p.get("BSID").toString(); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String c1 = bsid.substring(0, 8); String c6 = bsid.substring(8, 14); String pcid = ""; String ywlsh = ""; String userid = user.getId(); List lstResult = DataBaseHelper.queryForList("SELECT SEQ_JS_ZJSF_PCID.nextval as PCID,SEQ_JS_ZJSF_YWLSH.nextval as YWLSH FROM dual", new Object[0]); if(lstResult != null && lstResult.size() > 0) { pcid = ((Map)lstResult.get(0)).get("PCID").toString(); ywlsh = ((Map)lstResult.get(0)).get("YWLSH").toString(); this.jdbcTemplate.update("insert into js_zjsf(transcode,status,pcid,ywlsh,tablename,ywid,ocid,resultflag,suino,rq,c1,c6) values(?,\'01\',?,?,\'BS_YWPC\',?,\'105000\',\'0\',?,sysdate,?,?) ", new Object[]{transcode, pcid, ywlsh, bsid, userid, c1, c6}); this.jdbcTemplate.update("commit "); DataSourceRoute.putAppId("default"); } else { throw new BusException("未能正确生成PCID或YWLSH,请检查!"); } } public void addBdc703(Map p, IUser user) { DataSourceRoute.putAppId("sjjh"); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String c2 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); String c3 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); String c4 = p.get("JKHTBH") == null?"":p.get("JKHTBH").toString(); String c1 = p.get("XINGMING") == null?"":p.get("XINGMING").toString(); String pcid = ""; String ywlsh = ""; String userid = user.getId(); List lstResult = DataBaseHelper.queryForList("SELECT SEQ_JS_ZJSF_PCID.nextval as PCID,SEQ_JS_ZJSF_YWLSH.nextval as YWLSH FROM dual", new Object[0]); if(lstResult != null && lstResult.size() > 0) { pcid = ((Map)lstResult.get(0)).get("PCID").toString(); ywlsh = ((Map)lstResult.get(0)).get("YWLSH").toString(); this.jdbcTemplate.update("insert into js_zjsf(transcode,status,pcid,ywlsh,tablename,ywid,ocid,resultflag,suino,rq,c1,c2,c3,c4) values(?,\'01\',?,?,\'BSXX\',\'0\',\'105000\',\'0\',?,sysdate,?,?,?,?) ", new Object[]{transcode, pcid, ywlsh, userid, c1, c2, c3, c4}); this.jdbcTemplate.update("commit "); DataSourceRoute.putAppId("default"); } else { throw new BusException("未能正确生成PCID或YWLSH,请检查!"); } } public void addBdc704(Map p, IUser user) { DataSourceRoute.putAppId("sjjh"); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String c1 = ""; String c2 = ""; String c3 = ""; String c4 = ""; String c5 = ""; String c6 = ""; String c7 = ""; c1 = p.get("KSRQ") == null?"":p.get("KSRQ").toString().replace(".", ""); c2 = p.get("JSRQ") == null?"":p.get("JSRQ").toString().replace(".", ""); c3 = p.get("CXLX") == null?"":p.get("CXLX").toString(); c4 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); c5 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); c6 = p.get("SQBM") == null?"":p.get("SQBM").toString(); c7 = p.get("GRZH") == null?"":p.get("GRZH").toString(); String pcid = ""; String ywlsh = ""; String userid = user.getId(); List lstResult = DataBaseHelper.queryForList("SELECT SEQ_JS_ZJSF_PCID.nextval as PCID,SEQ_JS_ZJSF_YWLSH.nextval as YWLSH FROM dual", new Object[0]); if(lstResult != null && lstResult.size() > 0) { pcid = ((Map)lstResult.get(0)).get("PCID").toString(); ywlsh = ((Map)lstResult.get(0)).get("YWLSH").toString(); this.jdbcTemplate.update("insert into js_zjsf(transcode,status,pcid,ywlsh,tablename,ywid,ocid,resultflag,suino,rq,c1,c2,c3,c4,c5,c6,c7) values(?,\'01\',?,?,\'GRXX\',\'0\',\'105000\',\'0\',?,sysdate,?,?,?,?,?,?,?) ", new Object[]{transcode, pcid, ywlsh, userid, c1, c2, c3, c4, c5, c6, c7}); this.jdbcTemplate.update("commit "); DataSourceRoute.putAppId("default"); } else { throw new BusException("未能正确生成PCID或YWLSH,请检查!"); } } public void addBdc705(Map p, IUser user) { DataSourceRoute.putAppId("sjjh"); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String c1 = p.get("KSRQ") == null?"":p.get("KSRQ").toString().replace(".", ""); String c2 = p.get("JSRQ") == null?"":p.get("JSRQ").toString().replace(".", ""); String c3 = p.get("CXLX") == null?"":p.get("CXLX").toString(); String c4 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); String c5 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); String c6 = p.get("SQBM") == null?"":p.get("SQBM").toString(); String c7 = p.get("DKZH") == null?"":p.get("DKZH").toString(); String pcid = ""; String ywlsh = ""; String userid = user.getId(); List lstResult = DataBaseHelper.queryForList("SELECT SEQ_JS_ZJSF_PCID.nextval as PCID,SEQ_JS_ZJSF_YWLSH.nextval as YWLSH FROM dual", new Object[0]); if(lstResult != null && lstResult.size() > 0) { pcid = ((Map)lstResult.get(0)).get("PCID").toString(); ywlsh = ((Map)lstResult.get(0)).get("YWLSH").toString(); this.jdbcTemplate.update("insert into js_zjsf(transcode,status,pcid,ywlsh,tablename,ywid,ocid,resultflag,suino,rq,c1,c2,c3,c4,c5,c6,c7) values(?,\'01\',?,?,\'GRDKXX\',\'0\',\'105000\',\'0\',?,sysdate,?,?,?,?,?,?,?) ", new Object[]{transcode, pcid, ywlsh, userid, c1, c2, c3, c4, c5, c6, c7}); this.jdbcTemplate.update("commit "); DataSourceRoute.putAppId("default"); } else { throw new BusException("未能正确生成PCID或YWLSH,请检查!"); } } public void addBdc706(Map p, IUser user) { DataSourceRoute.putAppId("sjjh"); String transcode = p.get("TRANSCODE") == null?"":p.get("TRANSCODE").toString(); String c7 = p.get("XINGMING") == null?"":p.get("XINGMING").toString(); String c4 = p.get("ZJLX") == null?"":p.get("ZJLX").toString(); String c5 = p.get("ZJHM") == null?"":p.get("ZJHM").toString(); String pcid = ""; String ywlsh = ""; String userid = user.getId(); List lstResult = DataBaseHelper.queryForList("SELECT SEQ_JS_ZJSF_PCID.nextval as PCID,SEQ_JS_ZJSF_YWLSH.nextval as YWLSH FROM dual", new Object[0]); if(lstResult != null && lstResult.size() > 0) { pcid = ((Map)lstResult.get(0)).get("PCID").toString(); ywlsh = ((Map)lstResult.get(0)).get("YWLSH").toString(); this.jdbcTemplate.update("insert into js_zjsf(transcode,status,pcid,ywlsh,tablename,ywid,ocid,resultflag,suino,rq,c4,c5,c7) values(?,\'01\',?,?,\'HMDXX\',\'0\',\'105000\',\'0\',?,sysdate,?,?,?) ", new Object[]{transcode, pcid, ywlsh, userid, c4, c5, c7}); this.jdbcTemplate.update("commit "); DataSourceRoute.putAppId("default"); } else { throw new BusException("未能正确生成PCID或YWLSH,请检查!"); } } }