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,请检查!");
}
}
}