|

楼主 |
发表于 2017-11-2 15:24:32
|
显示全部楼层
public static void businessActivity5AfterAdvance() {
String fid = ProcessUtils.getProcessData1();
String FDCQ2_sql = "select j.BDCDYH from FDCQ2 j where j.SLSQZJ = '"+fid+"'";
Table table2_2 = KSQL.select(FDCQ2_sql, null, dataModel,null);
Iterator<Row> rows2_2 = table2_2.iterator();
String BDCDYH = null;
String sql ="";
if(rows2_2.hasNext()){
sql = "select j.YWH,j.BDCQZH,s.fCodeUrl from FDCQ2 j optional join SLSQ s on s = j.SLSQZJ where j.SLSQZJ = '"+fid+"' ";
}else{
String JSYDSYQ_sql = "select j.BDCDYH from JSYDSYQ j where j.SLSQZJ = '"+fid+"'";
Table table2_1 = KSQL.select(JSYDSYQ_sql, null, dataModel, null);
Iterator<Row> rows2_1 = table2_1.iterator();
if(rows2_1.hasNext()){
sql = "select j.YWH,j.BDCQZH,s.fCodeUrl from JSYDSYQ j optional join SLSQ s on s = j.SLSQZJ where j.SLSQZJ = '"+fid+"' ";
}
}
System.out.println("ywh:" + sql);
Table table = KSQL.select(sql, null, dataModel, null);
Iterator<Row> rows = table.iterator();
String YWH = null;
String BDCQZH = null;
String fCodeUrl = null;
if (rows.hasNext()) {
while (rows.hasNext()){
Row row = rows.next();
YWH = row.getString("YWH");
BDCQZH = row.getString("BDCQZH");
fCodeUrl = row.getString("fCodeUrl");
}
}
insertFZ(YWH,BDCQZH,"6004080000",fCodeUrl);
// String fid = ProcessUtils.getProcessData1();
//删除对应的状态表信息
String Ksql_delete_ZT = "delete from BDCZT BDCZT where BDCZT.SLSQZJ = '"+fid+"'";
KSQL.executeUpdate(Ksql_delete_ZT, null, dataModel, null);
}
//最新追加的方法 insertFZ , businessActivity6AfterAdvance 注意要素代码是不同的
public static void insertFZ(String YWH,String BDCQZH,String YSDM,String fCodeUrl){
//往发证表里新增一条记录 6004080000
//首先判断该业务号是否是否已经存在于当前数据表中,可能会出现回退的问题
String sql_talbe = "select t.HFZSH from FZGL t where t.YWH = '"+YWH+"'";
System.out.println("sql_table:" + sql_talbe);
String HFZSHS = null;
Table table = KSQL.select(sql_talbe, null, dataModel, null);
Iterator<Row> rows = table.iterator();
if (rows.hasNext()) {
while (rows.hasNext()) {
Row row = rows.next();
HFZSHS = row.getString("HFZSH");
}
}
String fID = UUID.randomUUID().toString();
String sql_fz = "insert into FZGL f(f,f.version,f.YWH,f.HFZSH,f.YSDM,f.ZT,f.fCodeUrl) values('"+fID.toUpperCase()+"',0,'"+YWH+"','"+BDCQZH+"','"+YSDM+"','未发证','"+fCodeUrl+"')";
String del_sql_fz = "delete from FZGL t where t.YWH = '"+YWH+"'";
if(HFZSHS != null){ //说明数据已经存在
KSQL.executeUpdate(del_sql_fz, null, dataModel, null);
KSQL.executeUpdate(sql_fz, null, dataModel, null);
}else{
KSQL.executeUpdate(sql_fz, null, dataModel, null);
}
} |
|