From 0ad29052ebd31e6ee5b7dadd1f323bc8660b76fc Mon Sep 17 00:00:00 2001 From: xiezhiwen Date: Tue, 26 Feb 2019 18:29:14 +0800 Subject: [PATCH] =?UTF-8?q?=E5=87=AD=E8=AF=81=E7=9B=B8=E5=85=B3=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../VoucherToNCforAssistContract.java | 122 ++++++-- .../serviceImp/VoucherToNCforCustomer.java | 125 ++++++-- .../serviceImp/VoucherToNCforDistributor.java | 121 ++++++-- .../serviceImp/VoucherToNCforVoucherPZ.java | 279 ++++++++++++------ 4 files changed, 495 insertions(+), 152 deletions(-) diff --git a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforAssistContract.java b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforAssistContract.java index ff443943e..ca5b753f0 100644 --- a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforAssistContract.java +++ b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforAssistContract.java @@ -11,6 +11,7 @@ import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; @@ -31,6 +32,7 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import com.amarsoft.are.ARE; +import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; @@ -41,6 +43,8 @@ import com.tenwa.comm.util.date.DateAssistant; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.util.SerialNumberUtil; +import jbo.voucher.NCXML_DETAIL_RECORDS; + public class VoucherToNCforAssistContract implements Job{ private static Log logger=ARE.getLog(); /** @@ -105,9 +109,13 @@ public class VoucherToNCforAssistContract implements Job{ String year_month_day = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date());// 年月日时分秒 // 明细表记录时间 String year_month_days = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());// 年月日时分秒 + // 记录当前批次传输总量 + int count=0; + // 记录历史批次号 + List batchList= new ArrayList(); // 获取未传输及之前传输失败的数据 - String sql="SELECT CONTRACT_NUMBER FROM LB_CONTRACT_INFO WHERE CONTRACT_NUMBER NOT IN(SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG = '1' AND XML_TYPE='"+type+"')"; + String sql="SELECT id,CONTRACT_NUMBER FROM LB_CONTRACT_INFO WHERE CONTRACT_NUMBER NOT IN(SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG = '1' AND XML_TYPE='"+type+"')"; List> rs = DataOperatorUtil.getDataBySql(Sqlca,sql,null); if(rs!=null && rs.size()>0) { // 生成xml头 @@ -130,8 +138,9 @@ public class VoucherToNCforAssistContract implements Job{ for (Map map : rs) { contract_number=(map.get("CONTRACT_NUMBER")==null)?"":map.get("CONTRACT_NUMBER"); Element bill = root.addElement("bill"); - uuid=UUID.randomUUID().toString().replace("-", ""); - bill.addAttribute("id", uuid); + //uuid=UUID.randomUUID().toString().replace("-", ""); + uuid=map.get("id"); + bill.addAttribute("id",uuid); Element billhead = bill.addElement("billhead"); Element pk_defdoclist = billhead.addElement("pk_defdoclist");// 自定义档案列表主键,最大长度为20,类型为:String pk_defdoclist.setText("ct01"); @@ -153,10 +162,24 @@ public class VoucherToNCforAssistContract implements Job{ pid.setText(""); Element memo = billhead.addElement("memo");// 备注,最大长度为200,类型为:String memo.setText(""); - // 将记录写入辅助合同日志表 - insertSql="INSERT INTO NCXML_DETAIL_RECORDS(BILLID,XML_TYPE,TABLE_NUM,FLAG,CREATE_TIME,BATCH) VALUES('"+uuid+"','"+type+"','"+contract_number+"','1','"+year_month_days+"','"+batch+"')"; - Sqlca.executeSQL(insertSql); - logger.info("辅助合同记录语句: " + insertSql); + + // 根据id查询记录表是否已经记录过, 没有记录过使用当前批次号记录, 如果已经记录了, 则不操作 + BizObject record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+uuid+"'").getSingleResult(false); + // 等于null说明新数据, 新增入记录表 + if(record==null || "".equals(record)) { + insertSql="INSERT INTO NCXML_DETAIL_RECORDS(BILLID,XML_TYPE,TABLE_NUM,FLAG,CREATE_TIME,BATCH) VALUES('"+uuid+"','"+type+"','"+contract_number+"','1','"+year_month_days+"','"+batch+"')"; + Sqlca.executeSQL(insertSql); + logger.info("辅助合同记录语句: " + insertSql); + count++; + }else { + String updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='1',ERR_DESCRIBE=null,CREATE_TIME='"+year_month_days+"' WHERE BILLID='"+uuid+"' AND XML_TYPE= '"+type+"'"; + Sqlca.executeSQL(updSql); + logger.info("就批次号记录: "+updSql); + String batch1= record.getAttribute("BATCH").getString(); + if(batchList.indexOf(batch1) == -1) { + batchList.add(batch1); + } + } } String URL="//data//files//apzl_leasing//tmp//XZW//APleasing_Defdoc_"+year_month_day+".xml"; // String URL="D:\\voucherXml_NC\\APleasing_Defdoc_"+year_month_day+".xml"; @@ -165,7 +188,7 @@ public class VoucherToNCforAssistContract implements Job{ writer.setEscapeText(false);// 字符是否转义,默认true writer.write(document); writer.close(); - InterActionToNC(Sqlca,URL,type,batch,rs.size()); + InterActionToNC(Sqlca,URL,type,batch,count,batchList); Sqlca.commit(); } QuartzUtil.insertLog(plan_date,"com.tenwa.voucher.serviceImp.VoucherToNCforAssistContract", "success", "成功",curUserId); @@ -192,7 +215,8 @@ public class VoucherToNCforAssistContract implements Job{ /** * 像NC传输xml, 获取NC回执xml信息, 根据回执信息更改状态 */ - public static void InterActionToNC(Transaction Sqlca,String inputURL,String type,String batch,int count) throws Exception { + public static void InterActionToNC(Transaction Sqlca,String inputURL,String type,String batch,int count,List batchList) throws Exception { + String updSql=""; // 更新历史记录 String updateSql = ""; // 更新sql对象 String insertSql = ""; // 新增SQL对象 String resultcode= ""; // 单条返回结果 @@ -201,7 +225,7 @@ public class VoucherToNCforAssistContract implements Job{ /** * 获取对方post连接 */ - String url = "http://172.16.0.88:9990/service/XChangeServlet?account=bq1217&groupcode=06"; + String url = "http://172.16.0.88:9990/service/XChangeServlet?account=8&groupcode=06"; URL realURL = new URL(url); HttpURLConnection connection = (HttpURLConnection)realURL.openConnection(); connection.setDoOutput(true); @@ -251,7 +275,7 @@ public class VoucherToNCforAssistContract implements Job{ SimpleDateFormat formatter2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 回执信息存放路径 String resFile = "//data//files//apzl_leasing//tmp//WEN//APleasing_"+type+""+fmt.format(new Date())+".xml"; - // String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; + //String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; StreamResult result = new StreamResult(new File(resFile)); // 将回执信息转化为xml transformer.transform(source,result); @@ -264,6 +288,8 @@ public class VoucherToNCforAssistContract implements Job{ Element root= doc.getRootElement(); // 根据successful判断是否有失败的, 有则为N, 全部成功为Y String resSuc = root.attributeValue("successful"); + + // 创建 if(null != resSuc){ // 状态为N说明本批次传输有失败的 if("N".equals(resSuc)){ @@ -293,24 +319,84 @@ public class VoucherToNCforAssistContract implements Job{ resultdescription = el.getStringValue(); } } + + /*// 查询不是本批次号的bdocid, 如果有值说明是之前传输错误的数据 + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH !='"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record !=null || !"".equals(old_record)) { + // 如果状态为1, 说明已经变更, 传输成功. 执行upddate操作, 变更记录状态 + if(resultcode=="1" || "1".equals(resultcode)) { + updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE=null,CREATE_TIME='"+formatter2+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; + } + }*/ + // 判断, 若失败, 更新错误录入明细表 if(!"1".equals(resultcode)) { // 如果回执状态不等于1, 说明有误, 更新到记录字表并记录错误信息 updateSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE='"+resultdescription+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; Sqlca.executeSQL(updateSql); logger.info("根据回执信息, 修改传输失败状态, 记录错误信息"+updateSql); - failed_count++; + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH <> '"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record ==null) { + failed_count++; + } } } - insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+count+"','本次共导入: "+count+"条, 失败: "+failed_count+"条 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql); - logger.info("本批次包含失败数据 !"); + + // 判断集合为否为null, 不为空遍历集合, 获取旧数据的批次号 + if(batchList != null || batchList.size()>0) { + // 定义当前批次, 错误记录数 + int con=0; + for (String old_batch : batchList) { + // 查询集合, 获取旧批次的失败总数 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } + + // count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增 + if(count != 0 ) { + insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+failed_count+"','含失败记录 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql); + logger.info("本批次包含失败数据 !"); + } + // 状态为Y表示, 本次导入全部成功 }else if(resSuc.equals("Y")){ logger.info("导入成功"); - // 将本次导入信息记录入记录总表 - String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','导入成功 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql1); + // count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增 + if(count != 0 ) { + // 将本次导入信息记录入记录总表 + String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','导入成功 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql1); + } + // 判断集合为否为null, 不为空遍历集合, 获取旧数据的批次号 + if(batchList != null) { + // 定义当前批次, 错误记录数 + int con=0; + for (String old_batch : batchList) { + // 查询集合, 获取旧批次的失败总数 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } }else{ logger.info("出现未知错误"); } diff --git a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforCustomer.java b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforCustomer.java index fea1a230f..069b95df3 100644 --- a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforCustomer.java +++ b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforCustomer.java @@ -11,6 +11,7 @@ import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; @@ -33,6 +34,7 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import com.amarsoft.are.ARE; +import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; @@ -43,6 +45,8 @@ import com.tenwa.comm.util.date.DateAssistant; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.util.SerialNumberUtil; +import jbo.voucher.NCXML_DETAIL_RECORDS; + public class VoucherToNCforCustomer implements Job{ private static Log logger=ARE.getLog(); /** @@ -124,9 +128,13 @@ public class VoucherToNCforCustomer implements Job{ String year_month_days = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); // 查询为传输或之前传输失败的数据 - String sql="SELECT cif.customer_num,MAX(cif.customername)customername,MAX(cif.customertype)customertype,MAX(cif.customerid) customerid FROM CUSTOMER_INFO cif LEFT JOIN lb_union_lessee lul ON lul.customer_id=cif.customerid LEFT JOIN lb_contract_info lci ON lci.id=lul.contract_id WHERE lci.contract_status >='31' AND cif.customer_num NOT IN (SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG = '1' AND XML_TYPE = '"+type+"') GROUP BY CIF.CUSTOMER_NUM "; + String sql="SELECT max(cif.customerid) id,cif.customer_num,MAX(cif.customername)customername,MAX(cif.customertype)customertype,MAX(cif.customerid) customerid FROM CUSTOMER_INFO cif LEFT JOIN lb_union_lessee lul ON lul.customer_id=cif.customerid LEFT JOIN lb_contract_info lci ON lci.id=lul.contract_id WHERE lci.contract_status >='31' AND cif.customer_num NOT IN (SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG = '1' AND XML_TYPE = '"+type+"') GROUP BY CIF.CUSTOMER_NUM "; List> rs = DataOperatorUtil.getDataBySql(Sqlca,sql,null); if(rs != null && rs.size()>0) { + // 记录历史批次号 + List batchList= new ArrayList(); + // 记录当前批次传输总量 + int count=0; // 生成xml头 document= DocumentHelper.createDocument(); Element root = document.addElement("ufinterface"); @@ -141,16 +149,16 @@ public class VoucherToNCforCustomer implements Job{ root.addAttribute("replace", replace); root.addAttribute("roottag", ""); root.addAttribute("sender", sender); - - String batch = SerialNumberUtil.getVoucherPCNumber(Sqlca);// 生成批次号 - + // 生成批次号 + String batch = SerialNumberUtil.getVoucherPCNumber(Sqlca); // 遍历要传输的结果集 for(int i=0;i batchList) throws Exception { + String updSql=""; // 更新历史记录 String updateSql = ""; // 更新sql对象 String insertSql = ""; // 新增SQL对象 String resultcode= ""; // 单条返回结果 @@ -270,7 +293,7 @@ public class VoucherToNCforCustomer implements Job{ /** * 获取对方post连接 */ - String url = "http://172.16.0.88:9990/service/XChangeServlet?account=bq1217&groupcode=06"; + String url = "http://172.16.0.88:9990/service/XChangeServlet?account=8&groupcode=06"; URL realURL = new URL(url); HttpURLConnection connection = (HttpURLConnection)realURL.openConnection(); connection.setDoOutput(true); @@ -320,7 +343,7 @@ public class VoucherToNCforCustomer implements Job{ SimpleDateFormat formatter2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 回执信息存放路径 String resFile = "//data//files//apzl_leasing//tmp//WEN//APleasing_"+type+""+fmt.format(new Date())+".xml"; - // String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; + //String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; StreamResult result = new StreamResult(new File(resFile)); // 将回执信息转化为xml transformer.transform(source,result); @@ -333,6 +356,8 @@ public class VoucherToNCforCustomer implements Job{ Element root= doc.getRootElement(); // 根据successful判断是否有失败的, 有则为N, 全部成功为Y String resSuc = root.attributeValue("successful"); + + // 创建 if(null != resSuc){ // 状态为N说明本批次传输有失败的 if("N".equals(resSuc)){ @@ -362,24 +387,84 @@ public class VoucherToNCforCustomer implements Job{ resultdescription = el.getStringValue(); } } + + /*// 查询不是本批次号的bdocid, 如果有值说明是之前传输错误的数据 + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH !='"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record !=null || !"".equals(old_record)) { + // 如果状态为1, 说明已经变更, 传输成功. 执行upddate操作, 变更记录状态 + if(resultcode=="1" || "1".equals(resultcode)) { + updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE=null,CREATE_TIME='"+formatter2+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; + } + }*/ + // 判断, 若失败, 更新错误录入明细表 if(!"1".equals(resultcode)) { // 如果回执状态不等于1, 说明有误, 更新到记录字表并记录错误信息 updateSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE='"+resultdescription+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; Sqlca.executeSQL(updateSql); logger.info("根据回执信息, 修改传输失败状态, 记录错误信息"+updateSql); - failed_count++; + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH <> '"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record ==null) { + failed_count++; + } } } - insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+count+"','本次共导入: "+count+"条, 失败: "+failed_count+"条 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql); - logger.info("本批次包含失败数据 !"); + + // 判断集合为否为null, 不为空遍历集合, 获取旧数据的批次号 + if(batchList != null || batchList.size()>0) { + // 定义当前批次, 错误记录数 + int con=0; + for (String old_batch : batchList) { + // 查询集合, 获取旧批次的失败总数 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } + + // count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增 + if(count != 0 ) { + insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+failed_count+"','含失败记录 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql); + logger.info("本批次包含失败数据 !"); + } + // 状态为Y表示, 本次导入全部成功 }else if(resSuc.equals("Y")){ logger.info("导入成功"); - // 将本次导入信息记录入记录总表 - String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','导入成功 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql1); + // count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增 + if(count != 0 ) { + // 将本次导入信息记录入记录总表 + String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','导入成功 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql1); + } + // 判断集合为否为null, 不为空遍历集合, 获取旧数据的批次号 + if(batchList != null) { + // 定义当前批次, 错误记录数 + int con=0; + for (String old_batch : batchList) { + // 查询集合, 获取旧批次的失败总数 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } }else{ logger.info("出现未知错误"); } diff --git a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforDistributor.java b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforDistributor.java index 7167dc7dd..5c3c2c42a 100644 --- a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforDistributor.java +++ b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforDistributor.java @@ -11,6 +11,7 @@ import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.Date; import java.util.List; import java.util.Map; @@ -33,6 +34,7 @@ import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import com.amarsoft.are.ARE; +import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.JBOException; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.are.jbo.JBOTransaction; @@ -44,6 +46,8 @@ import com.tenwa.comm.util.date.DateAssistant; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.util.SerialNumberUtil; +import jbo.voucher.NCXML_DETAIL_RECORDS; + public class VoucherToNCforDistributor implements Job{ private static Log logger=ARE.getLog(); /** @@ -126,12 +130,16 @@ public class VoucherToNCforDistributor implements Job{ String insertSql=""; // 新增语句 String uuid=""; // uuid String MBAFC_EARLYDISBURSEMENT_TYPE="";// 资金类型/支付类型 + // 记录历史批次号 + List batchList= new ArrayList(); + // 记录当前批次传输总量 + int count=0; // 获取特定日期 String year_month_day = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()); String year_month_days = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); // 获取未传输及以前传输失败的数据 - String sql="SELECT DISTRIBUTOR_NAME,DISTRIBUTOR_CODING,DISTRIBUTOR_ADDRESS,FACT_ADDR,PROVINCES,POSTCODE,REGISTERED_ADDR,BUSINESS_SCOPE,SUBSIDIARY_COMPANY,TYPE,BUSINESS_LICENSE_NO,DISTRIBUTOR_STATUS,E_MAIL,FAX_NUMBER,REGISTERED_ASSET,DISTRIBUTORER,MBAFC_EARLYDISBURSEMENT_TYPE,URL FROM DISTRIBUTOR_INFO WHERE (DISTRIBUTOR_CODING NOT IN(SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG ='1' AND XML_TYPE='"+type+"') and DISTRIBUTOR_CODING not in(SELECT cust_id FROM customer_list)) and DISTRIBUTOR_STATUS='distributor_status04' "; + String sql="SELECT id,DISTRIBUTOR_NAME,DISTRIBUTOR_CODING,DISTRIBUTOR_ADDRESS,FACT_ADDR,PROVINCES,POSTCODE,REGISTERED_ADDR,BUSINESS_SCOPE,SUBSIDIARY_COMPANY,TYPE,BUSINESS_LICENSE_NO,DISTRIBUTOR_STATUS,E_MAIL,FAX_NUMBER,REGISTERED_ASSET,DISTRIBUTORER,MBAFC_EARLYDISBURSEMENT_TYPE,URL FROM DISTRIBUTOR_INFO WHERE (DISTRIBUTOR_CODING NOT IN(SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG ='1' AND XML_TYPE='"+type+"') and DISTRIBUTOR_CODING not in(SELECT cust_id FROM customer_list)) and DISTRIBUTOR_STATUS='distributor_status04' "; List> rs = DataOperatorUtil.getDataBySql(Sqlca,sql,null); if(rs !=null && rs.size()>0) { // 设置xml标签头 @@ -172,7 +180,8 @@ public class VoucherToNCforDistributor implements Job{ region = NameManager.getItemName("AreaCode",DISTRIBUTOR_ADDRESS); // 获取地区 Element bill = root.addElement("bill"); - uuid=UUID.randomUUID().toString().replace("-", ""); + //uuid=UUID.randomUUID().toString().replace("-", ""); + uuid=rs.get(i).get("id"); bill.addAttribute("id",uuid); Element billhead = bill.addElement("billhead"); Element pk_group1 = billhead.addElement("pk_group"); // 所属集团,最大长度为20,类型为:String @@ -300,19 +309,32 @@ public class VoucherToNCforDistributor implements Job{ Element corpaddress = billhead.addElement("corpaddress"); // 企业地址主键,最大长度为20,类型为:String corpaddress.setText((FACT_ADDR==null)?"":FACT_ADDR);*/ - // 像记录表添加数据 - insertSql="INSERT INTO NCXML_DETAIL_RECORDS(BILLID,XML_TYPE,TABLE_NUM,FLAG,CREATE_TIME,BATCH) VALUES('"+uuid+"','"+type+"','"+DISTRIBUTOR_CODING+"','1','"+year_month_days+"','"+batch+"')"; - Sqlca.executeSQL(insertSql); - logger.info("经销商记录语句: "+ insertSql); + // 根据id查询记录表是否已经记录过, 没有记录过使用当前批次号记录, 如果已经记录了, 则不操作 + BizObject record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+uuid+"'").getSingleResult(false); + // 等于null说明新数据, 新增入记录表 + if(record==null || "".equals(record)) { + insertSql="INSERT INTO NCXML_DETAIL_RECORDS(BILLID,XML_TYPE,TABLE_NUM,FLAG,CREATE_TIME,BATCH) VALUES('"+uuid+"','"+type+"','"+DISTRIBUTOR_CODING+"','1','"+year_month_days+"','"+batch+"')"; + Sqlca.executeSQL(insertSql); + logger.info("经销商记录语句: "+ insertSql); + count++; + }else { + String updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='1',ERR_DESCRIBE=null,CREATE_TIME='"+year_month_days+"' WHERE BILLID='"+uuid+"' AND XML_TYPE= '"+type+"'"; + Sqlca.executeSQL(updSql); + logger.info("旧批次号记录: "+updSql); + String batch1= record.getAttribute("BATCH").getString(); + if(batchList.indexOf(batch1) == -1) { + batchList.add(batch1); + } + } } - // String f="D:\\voucherXml_NC\\APleasing_Supplier_"+year_month_day+".xml"; + //String f="D:\\voucherXml_NC\\APleasing_Supplier_"+year_month_day+".xml"; String f="//data//files//apzl_leasing//tmp//XZW//APleasing_Supplier_"+year_month_day+".xml"; file=new File(f); writer = new XMLWriter(new FileOutputStream(file), OutputFormat.createPrettyPrint()); writer.setEscapeText(false);// 字符是否转义,默认true writer.write(document); writer.close(); - InterActionToNC(Sqlca,f,type,batch,rs.size()); + InterActionToNC(Sqlca,f,type,batch,count,batchList); Sqlca.commit(); QuartzUtil.insertLog(plan_date,"com.tenwa.voucher.serviceImp.VoucherToNCforDistributor", "success", "成功",curUserId); } @@ -340,7 +362,8 @@ public class VoucherToNCforDistributor implements Job{ /** * 像NC传输xml, 获取NC回执xml信息, 根据回执信息更改状态 */ - public static void InterActionToNC(Transaction Sqlca,String inputURL,String type,String batch,int count) throws Exception { + public static void InterActionToNC(Transaction Sqlca,String inputURL,String type,String batch,int count,List batchList) throws Exception { + String updSql=""; // 更新历史记录 String updateSql = ""; // 更新sql对象 String insertSql = ""; // 新增SQL对象 String resultcode= ""; // 单条返回结果 @@ -349,7 +372,7 @@ public class VoucherToNCforDistributor implements Job{ /** * 获取对方post连接 */ - String url = "http://172.16.0.88:9990/service/XChangeServlet?account=bq1217&groupcode=06"; + String url = "http://172.16.0.88:9990/service/XChangeServlet?account=8&groupcode=06"; URL realURL = new URL(url); HttpURLConnection connection = (HttpURLConnection)realURL.openConnection(); connection.setDoOutput(true); @@ -399,7 +422,7 @@ public class VoucherToNCforDistributor implements Job{ SimpleDateFormat formatter2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 回执信息存放路径 String resFile = "//data//files//apzl_leasing//tmp//WEN//APleasing_"+type+""+fmt.format(new Date())+".xml"; - // String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; + //String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; StreamResult result = new StreamResult(new File(resFile)); // 将回执信息转化为xml transformer.transform(source,result); @@ -412,6 +435,8 @@ public class VoucherToNCforDistributor implements Job{ Element root= doc.getRootElement(); // 根据successful判断是否有失败的, 有则为N, 全部成功为Y String resSuc = root.attributeValue("successful"); + + // 创建 if(null != resSuc){ // 状态为N说明本批次传输有失败的 if("N".equals(resSuc)){ @@ -441,24 +466,84 @@ public class VoucherToNCforDistributor implements Job{ resultdescription = el.getStringValue(); } } + + /*// 查询不是本批次号的bdocid, 如果有值说明是之前传输错误的数据 + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH !='"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record !=null || !"".equals(old_record)) { + // 如果状态为1, 说明已经变更, 传输成功. 执行upddate操作, 变更记录状态 + if(resultcode=="1" || "1".equals(resultcode)) { + updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE=null,CREATE_TIME='"+formatter2+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; + } + }*/ + // 判断, 若失败, 更新错误录入明细表 if(!"1".equals(resultcode)) { // 如果回执状态不等于1, 说明有误, 更新到记录字表并记录错误信息 updateSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE='"+resultdescription+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; Sqlca.executeSQL(updateSql); logger.info("根据回执信息, 修改传输失败状态, 记录错误信息"+updateSql); - failed_count++; + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH <> '"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record ==null) { + failed_count++; + } } } - insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+count+"','本次共导入: "+count+"条, 失败: "+failed_count+"条 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql); - logger.info("本批次包含失败数据 !"); + + // 判断集合为否为null, 不为空遍历集合, 获取旧数据的批次号 + if(batchList != null || batchList.size()>0) { + // 定义当前批次, 错误记录数 + int con=0; + for (String old_batch : batchList) { + // 查询集合, 获取旧批次的失败总数 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } + + // count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增 + if(count != 0 ) { + insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+failed_count+"','含失败记录 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql); + logger.info("本批次包含失败数据 !"); + } + // 状态为Y表示, 本次导入全部成功 }else if(resSuc.equals("Y")){ logger.info("导入成功"); - // 将本次导入信息记录入记录总表 - String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','导入成功 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql1); + // count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增 + if(count != 0 ) { + // 将本次导入信息记录入记录总表 + String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','导入成功 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql1); + } + // 判断集合为否为null, 不为空遍历集合, 获取旧数据的批次号 + if(batchList != null) { + // 定义当前批次, 错误记录数 + int con=0; + for (String old_batch : batchList) { + // 查询集合, 获取旧批次的失败总数 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } }else{ logger.info("出现未知错误"); } diff --git a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforVoucherPZ.java b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforVoucherPZ.java index 4e9c7a9d8..f95b61ee4 100644 --- a/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforVoucherPZ.java +++ b/src_core/com/tenwa/voucher/serviceImp/VoucherToNCforVoucherPZ.java @@ -11,6 +11,7 @@ import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.URL; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; @@ -44,7 +45,10 @@ import com.tenwa.comm.util.date.DateAssistant; import com.tenwa.comm.util.jboutil.DataOperatorUtil; import com.tenwa.util.SerialNumberUtil; +import jbo.com.tenwa.entity.comm.own.OWN_ACCOUNT; +import jbo.sys.USER_INFO; import jbo.voucher.LV_STACTS_CONFIG; +import jbo.voucher.NCXML_DETAIL_RECORDS; public class VoucherToNCforVoucherPZ implements Job{ private static Log logger=ARE.getLog(); @@ -167,9 +171,9 @@ public class VoucherToNCforVoucherPZ implements Job{ String year_month_days = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()); // 鏌ヨ鍑瘉瑙嗗浘, 鑾峰彇姣忔潯鍑瘉 - String sql = "SELECT F3,F60,ID,MODULE_NAME,DEPT_NAME,F1,F15,V8_STATUS,F5,GENERATE_DATE FROM VI_VOUCHER_V8 WHERE F3 NOT IN(SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG = '1' AND XML_TYPE='"+type+"') AND DATE_FORMAT(f1,'%Y-%m')>=DATE_FORMAT('2019-01-11','%Y-%m')"; + String sql = "SELECT id,F3,F60,ID,MODULE_NAME,DEPT_NAME,F1,F15,V8_STATUS,F5,GENERATE_DATE FROM VI_VOUCHER_V8 WHERE F3 NOT IN(SELECT TABLE_NUM FROM NCXML_DETAIL_RECORDS WHERE FLAG = '1' AND XML_TYPE='"+type+"') AND DATE_FORMAT(f1,'%Y-%m')>=DATE_FORMAT('2019-01-11','%Y-%m') AND F3 IN('k5031','k5032','k5033')"; List> list = DataOperatorUtil.getDataBySql(Sqlca, sql, null);// 灏嗘墍鏈夊嚟璇佸彿灏佽鍒發ist闆嗗悎涓 - + // v8瑙嗗浘鎬绘暟鎹噺/ xml涓敓鎴愮殑鎬绘潯鏁 int a = list.size(); // 璁剧疆褰撳墠xml鐢熸垚鐨勬潯鏁 @@ -178,8 +182,9 @@ public class VoucherToNCforVoucherPZ implements Job{ int c = (int)(a / b); for (int i = 0; i <=c && a>0; i++) { // 璁板綍褰撳墠鎵规浼犺緭鎬婚噺 - int count=0; - Sqlca = Transaction.createTransaction(tx); + int count=0; + // 璁板綍鍘嗗彶鎵规鍙 + List batchList= new ArrayList(); document = DocumentHelper.createDocument(); // 鍒涘缓Document瀵硅薄 // 璁剧疆xml澶 Element root = document.addElement("ufinterface"); @@ -220,9 +225,10 @@ public class VoucherToNCforVoucherPZ implements Job{ // 鑾峰彇鏈柟淇℃伅 //BizObject own = JBOFactory.createBizObjectQuery(OWN_INFO.CLASS_NAME, "id=:OWNED_COMPANY").setParameter("OWNED_COMPANY", OWNED_COMPANY).getSingleResult(false); - uuid=UUID.randomUUID().toString().replace("-", ""); + //uuid=UUID.randomUUID().toString().replace("-", ""); + uuid=list.get(x).get("id"); Element voucher = root.addElement("voucher"); - voucher.addAttribute("id", uuid); + voucher.addAttribute("id",uuid); Element voucherHead = voucher.addElement("voucher_head"); Element pkVoucher = voucherHead.addElement("pk_voucher");// 鍑瘉涓婚敭/闈炵┖ // pkVoucher.setText(uuid); @@ -283,11 +289,13 @@ public class VoucherToNCforVoucherPZ implements Job{ SUBJECT_ID=v8Lend.get("f6"); f5 = v8Lend.get("f5"); BizObject subject = JBOFactory.createBizObjectQuery(LV_STACTS_CONFIG.CLASS_NAME, "ID=:ID").setParameter("ID", SUBJECT_ID).getSingleResult(false); + // 鑾峰彇杈呭姪鏍哥畻id + String ids=subject.getAttribute("AUXILIARY_TYPE").getString(); Element item1 = details.addElement("item"); // 鍊熸柟 Element detailindex1 = item1.addElement("detailindex");// 鍒嗗綍鍙/闈炵┖ detailindex1.setText((v8Lend.get("f59")==null)?"":v8Lend.get("f59"));//------------------------------------ Element explanation1 = item1.addElement("explanation");// 鎽樿/闈炵┖ - explanation1.setText(F3+"-"+f5); + explanation1.setText(F3+"-"+f5+"66"); Element verifydate1 = item1.addElement("verifydate");// 涓氬姟鏃ユ湡/鍙┖ verifydate1.setText(""); Element price1 = item1.addElement("price");// 鍗曚环/鍙┖ @@ -315,44 +323,50 @@ public class VoucherToNCforVoucherPZ implements Job{ pk_unit_v1.setText("");//------------------------------------------------- Element ass1 = item1.addElement("ass");// 閲戦蹇呴』鏈変竴鏂逛笉涓虹┖ // 瀹㈠晢杈呭姪鏍哥畻 - if(v8Lend.get("f65")!=null && !"".equals(v8Lend.get("f65"))) { - Element ass_item1 = ass1.addElement("item"); - Element pk_Checktype1 = ass_item1.addElement("pk_Checktype"); - pk_Checktype1.setText("瀹㈠晢"); - Element pk_Checkvalue1 = ass_item1.addElement("pk_Checkvalue"); - pk_Checkvalue1.setText((v8Lend.get("f65")==null)?"鏃":v8Lend.get("f65")); + if(ids.contains("185b89e22dba458491306a647468d2a5")) { + Element ass_item1 = ass1.addElement("item"); + Element pk_Checktype1 = ass_item1.addElement("pk_Checktype"); + pk_Checktype1.setText("瀹㈠晢"); + Element pk_Checkvalue1 = ass_item1.addElement("pk_Checkvalue"); + //pk_Checkvalue1.setText("APZL0201000000"); + pk_Checkvalue1.setText((v8Lend.get("f65")==null)?"APZL0201000000":v8Lend.get("f65")); } + // 鍚堝悓鍙疯緟鍔╂牳绠 - if(v8Lend.get("f60")!=null && !"".equals(v8Lend.get("f60"))) {// 閮ㄩ棬鍚嶇О - Element ass_item2 = ass1.addElement("item"); - Element pk_Checktype2 = ass_item2.addElement("pk_Checktype"); - pk_Checktype2.setText("鍚堝悓鍙"); - Element pk_Checkvalue2 = ass_item2.addElement("pk_Checkvalue"); - pk_Checkvalue2.setText((v8Lend.get("f60")==null)?"鏃":v8Lend.get("f60")); + if(ids.contains("1869733a51f1486a97df402e8d899980")) { + Element ass_item2 = ass1.addElement("item"); + Element pk_Checktype2 = ass_item2.addElement("pk_Checktype"); + pk_Checktype2.setText("鍚堝悓鍙"); + Element pk_Checkvalue2 = ass_item2.addElement("pk_Checkvalue"); + //pk_Checkvalue2.setText("ap0000"); + pk_Checkvalue2.setText((v8Lend.get("f60")==null)?"ap0000":v8Lend.get("f60")); } + // 涓昏惀绫诲瀷杈呭姪鏍哥畻 - if(v8Lend.get("f73")!=null && !"".equals(v8Lend.get("f73"))) { - Element ass_item3 = ass1.addElement("item"); - Element pk_Checktype3 = ass_item3.addElement("pk_Checktype"); - pk_Checktype3.setText("涓昏惀绫诲瀷"); - Element pk_Checkvalue3 = ass_item3.addElement("pk_Checkvalue"); - pk_Checkvalue3.setText((v8Lend.get("f73")==null)?"鏃":v8Lend.get("f73")); + if(ids.contains("1c981e6e47c24d069f9a2e08db819c4c")) { + if(v8Lend.get("f73")!=null && !"".equals(v8Lend.get("f73"))) { + Element ass_item3 = ass1.addElement("item"); + Element pk_Checktype3 = ass_item3.addElement("pk_Checktype"); + pk_Checktype3.setText("涓昏惀绫诲瀷"); + Element pk_Checkvalue3 = ass_item3.addElement("pk_Checkvalue"); + pk_Checkvalue3.setText((v8Lend.get("f73")==null)?"":v8Lend.get("f73")); + } } //鐜伴噾娴侀噺椤圭洰杈呭姪鏍哥畻 - if(v8Lend.get("f74")!=null && !"".equals(v8Lend.get("f74"))) { - Element ass_item4 = ass1.addElement("item"); - Element pk_Checktype4 = ass_item4.addElement("pk_Checktype"); - pk_Checktype4.setText("鐜伴噾娴侀噺椤圭洰"); - Element pk_Checkvalue4 = ass_item4.addElement("pk_Checkvalue"); - pk_Checkvalue4.setText((v8Lend.get("f74")==null)?"鏃":v8Lend.get("f74")); + if(ids.contains("3f0177c4295d4ed99ef18adb37c3e79f")) { + Element ass_item4 = ass1.addElement("item"); + Element pk_Checktype4 = ass_item4.addElement("pk_Checktype"); + pk_Checktype4.setText("鐜伴噾娴侀噺椤圭洰"); + Element pk_Checkvalue4 = ass_item4.addElement("pk_Checkvalue"); + pk_Checkvalue4.setText((v8Lend.get("f74")==null)?"":v8Lend.get("f74")); } //閾惰璐︽埛杈呭姪鏍哥畻 - if(v8Lend.get("f75")!=null && !"".equals(v8Lend.get("f75"))) { - Element ass_item5 = ass1.addElement("item"); - Element pk_Checktype5 = ass_item5.addElement("pk_Checktype"); - pk_Checktype5.setText("閾惰璐︽埛"); - Element pk_Checkvalue5 = ass_item5.addElement("pk_Checkvalue"); - pk_Checkvalue5.setText((v8Lend.get("f75")==null)?"鏃":v8Lend.get("f75")); + if(ids.contains("5d241cc0d2794ef7943df15c5f97976a")) { + Element ass_item5 = ass1.addElement("item"); + Element pk_Checktype5 = ass_item5.addElement("pk_Checktype"); + pk_Checktype5.setText("閾惰璐︽埛"); + Element pk_Checkvalue5 = ass_item5.addElement("pk_Checkvalue"); + pk_Checkvalue5.setText((v8Lend.get("f75")==null)?"":v8Lend.get("f75")); } Element cashFlow = item1.addElement("cashFlow"); Element cashFlow_item1 = cashFlow.addElement("item"); @@ -377,6 +391,8 @@ public class VoucherToNCforVoucherPZ implements Job{ // 鏍规嵁绉戠洰id, 鑾峰彇褰撳墠鏁版嵁瀵瑰簲鐨勭鐩俊鎭 SUBJECT_ID=v8loan.get("f6"); BizObject subject = JBOFactory.createBizObjectQuery(LV_STACTS_CONFIG.CLASS_NAME, "ID=:ID").setParameter("ID", SUBJECT_ID).getSingleResult(false); + // 鑾峰彇杈呭姪鏍哥畻id + String ids=subject.getAttribute("AUXILIARY_TYPE").getString(); Element item2 = details.addElement("item"); // 璐锋柟閲戦 Element creditquantity2 = item2.addElement("creditquantity");// 璐锋柟鏁伴噺 鍙┖ creditquantity2.setText(v2.size()+""); @@ -391,7 +407,7 @@ public class VoucherToNCforVoucherPZ implements Job{ Element detailindex2 = item2.addElement("detailindex");// 鍒嗗綍鍙 闈炵┖ detailindex2.setText((v8loan.get("f59")==null)?"":v8loan.get("f59"));//------------------------------------- Element explanation2 = item2.addElement("explanation");// 鎽樿 闈炵┖ - explanation2.setText((v8loan.get("f5")==null)?"":v8loan.get("f5")); + explanation2.setText(F3+"-"+f5+"66"); Element verifydate2 = item2.addElement("verifydate");// 涓氬姟鏃ユ湡 鍙┖ verifydate2.setText(timeAll); Element price2 = item2.addElement("price");// 鍗曚环 鍙┖ @@ -409,44 +425,48 @@ public class VoucherToNCforVoucherPZ implements Job{ pk_unit_v2.setText("");//----------------------------------------------- Element ass2 = item2.addElement("ass");// // 瀹㈠晢杈呭姪鏍哥畻 - if(v8loan.get("f65")!=null && !"".equals(v8loan.get("f65"))) { - Element ass_item1 = ass2.addElement("item"); - Element pk_Checktype1 = ass_item1.addElement("pk_Checktype"); - pk_Checktype1.setText("瀹㈠晢"); - Element pk_Checkvalue1 = ass_item1.addElement("pk_Checkvalue"); - pk_Checkvalue1.setText((v8loan.get("f65")==null)?"鏃":v8loan.get("f65")); + if(ids.contains("185b89e22dba458491306a647468d2a5")) { + if(v8loan.get("f65")!=null && !"".equals(v8loan.get("f65"))) { + Element ass_item1 = ass2.addElement("item"); + Element pk_Checktype1 = ass_item1.addElement("pk_Checktype"); + pk_Checktype1.setText("瀹㈠晢"); + Element pk_Checkvalue1 = ass_item1.addElement("pk_Checkvalue"); + //pk_Checkvalue1.setText("APZL0201000000"); + pk_Checkvalue1.setText((v8loan.get("f65")==null)?"APZL0201000000":v8loan.get("f65")); + } } // 鍚堝悓鍙疯緟鍔╂牳绠 - if(v8loan.get("f60")!=null && !"".equals(v8loan.get("f60"))) {// 閮ㄩ棬鍚嶇О - Element ass_item2 = ass2.addElement("item"); - Element pk_Checktype2 = ass_item2.addElement("pk_Checktype"); - pk_Checktype2.setText("鍚堝悓鍙"); - Element pk_Checkvalue2 = ass_item2.addElement("pk_Checkvalue"); - pk_Checkvalue2.setText((v8loan.get("f60")==null)?"鏃":v8loan.get("f60")); + if(ids.contains("1869733a51f1486a97df402e8d899980")) { + Element ass_item2 = ass2.addElement("item"); + Element pk_Checktype2 = ass_item2.addElement("pk_Checktype"); + pk_Checktype2.setText("鍚堝悓鍙"); + Element pk_Checkvalue2 = ass_item2.addElement("pk_Checkvalue"); + //pk_Checkvalue2.setText("ap0000"); + pk_Checkvalue2.setText((v8loan.get("f60")==null)?"ap0000":v8loan.get("f60")); } // 涓昏惀绫诲瀷杈呭姪鏍哥畻 - if(v8loan.get("f73")!=null && !"".equals(v8loan.get("f73"))) { - Element ass_item3 = ass2.addElement("item"); - Element pk_Checktype3 = ass_item3.addElement("pk_Checktype"); - pk_Checktype3.setText("涓昏惀绫诲瀷"); - Element pk_Checkvalue3 = ass_item3.addElement("pk_Checkvalue"); - pk_Checkvalue3.setText((v8loan.get("f73")==null)?"鏃":v8loan.get("f73")); + if(ids.contains("1c981e6e47c24d069f9a2e08db819c4c")) { + Element ass_item3 = ass2.addElement("item"); + Element pk_Checktype3 = ass_item3.addElement("pk_Checktype"); + pk_Checktype3.setText("涓昏惀绫诲瀷"); + Element pk_Checkvalue3 = ass_item3.addElement("pk_Checkvalue"); + pk_Checkvalue3.setText((v8loan.get("f73")==null)?"":v8loan.get("f73")); } //鐜伴噾娴侀噺椤圭洰杈呭姪鏍哥畻 - if(v8loan.get("f74")!=null && !"".equals(v8loan.get("f74"))) { - Element ass_item4 = ass2.addElement("item"); - Element pk_Checktype4 = ass_item4.addElement("pk_Checktype"); - pk_Checktype4.setText("鐜伴噾娴侀噺椤圭洰"); - Element pk_Checkvalue4 = ass_item4.addElement("pk_Checkvalue"); - pk_Checkvalue4.setText((v8loan.get("f74")==null)?"鏃":v8loan.get("f74")); + if(ids.contains("3f0177c4295d4ed99ef18adb37c3e79f")) { + Element ass_item4 = ass2.addElement("item"); + Element pk_Checktype4 = ass_item4.addElement("pk_Checktype"); + pk_Checktype4.setText("鐜伴噾娴侀噺椤圭洰"); + Element pk_Checkvalue4 = ass_item4.addElement("pk_Checkvalue"); + pk_Checkvalue4.setText((v8loan.get("f74")==null)?"":v8loan.get("f74")); } //閾惰璐︽埛杈呭姪鏍哥畻 - if(v8loan.get("f75")!=null && !"".equals(v8loan.get("f75"))) { - Element ass_item5 = ass2.addElement("item"); - Element pk_Checktype5 = ass_item5.addElement("pk_Checktype"); - pk_Checktype5.setText("閾惰璐︽埛"); - Element pk_Checkvalue5 = ass_item5.addElement("pk_Checkvalue"); - pk_Checkvalue5.setText((v8loan.get("f75")==null)?"鏃":v8loan.get("f75")); + if(ids.contains("5d241cc0d2794ef7943df15c5f97976a")) { + Element ass_item5 = ass2.addElement("item"); + Element pk_Checktype5 = ass_item5.addElement("pk_Checktype"); + pk_Checktype5.setText("閾惰璐︽埛"); + Element pk_Checkvalue5 = ass_item5.addElement("pk_Checkvalue"); + pk_Checkvalue5.setText((v8loan.get("f75")==null)?"":v8loan.get("f75")); } Element item2_cashFlow = item2.addElement("cashFlow"); Element cashflowitem2 = item2_cashFlow.addElement("item"); @@ -465,23 +485,33 @@ public class VoucherToNCforVoucherPZ implements Job{ Element pk_innercorp2 = cashflowitem2.addElement("pk_innercorp");// 鍐呴儴鍗曚綅涓婚敭,鏈澶ч暱搴︿负64,绫诲瀷涓:String pk_innercorp2.setText(""); } - // 鏂板褰撴潯鍑瘉淇℃伅鍏ヨ褰曞瓧琛 - //insertSql="INSERT INTO VOUCHER_LOG(BILLID,F3,FLAG,CREATE_TIME,BATCH) VALUES('"+str+"','"+F3+"','1','"+year_month_days+"','"+batch+"')"; - insertSql="INSERT INTO NCXML_DETAIL_RECORDS(BILLID,XML_TYPE,TABLE_NUM,FLAG,CREATE_TIME,BATCH) VALUES('"+uuid+"','"+type+"','"+F3+"','1','"+year_month_days+"','"+batch+"')"; - //sqlObject = new SqlObject(insertSql); - //Sqlca.executeSQL(sqlObject); - Sqlca.executeSQL(insertSql); - logger.info("鍑瘉璁板綍琛ㄦ彃鍏ヨ鍙: "+insertSql); - count++; + + // 鏍规嵁id鏌ヨ璁板綍琛ㄦ槸鍚﹀凡缁忚褰曡繃, 娌℃湁璁板綍杩囦娇鐢ㄥ綋鍓嶆壒娆″彿璁板綍, 濡傛灉宸茬粡璁板綍浜, 鍒欎笉鎿嶄綔 + BizObject record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+uuid+"'").getSingleResult(false); + if(record==null || "".equals(record)) { + // 绛変簬null璇存槑鏂版暟鎹, 鏂板鍏ヨ褰曡〃 + insertSql="INSERT INTO NCXML_DETAIL_RECORDS(BILLID,XML_TYPE,TABLE_NUM,FLAG,CREATE_TIME,BATCH) VALUES('"+uuid+"','"+type+"','"+F3+"','1','"+year_month_days+"','"+batch+"')"; + Sqlca.executeSQL(insertSql); + logger.info("鍑瘉璁板綍琛ㄦ彃鍏ヨ鍙: "+insertSql); + count++; + }else { + String updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='1',ERR_DESCRIBE=null,CREATE_TIME='"+year_month_days+"' WHERE BILLID='"+uuid+"' AND XML_TYPE= '"+type+"'"; + Sqlca.executeSQL(updSql); + logger.info("灏辨壒娆″彿璁板綍: "+updSql); + String batch1= record.getAttribute("BATCH").getString(); + if(batchList.indexOf(batch1) == -1) { + batchList.add(batch1); + } + } } - //String URL="//data//files//apzl_leasing//tmp//XZW//APleasing_VOUCHER_"+year_month_day+".xml"; - String URL="D:\\voucherXml_NC\\APleasing_VOUCHER_"+year_month_day+".xml"; + String URL="//data//files//apzl_leasing//tmp//XZW//APleasing_VOUCHER_"+year_month_day+".xml"; + //String URL="D:\\voucherXml_NC\\APleasing_VOUCHER_"+year_month_day+".xml"; file=new File(URL); writer = new XMLWriter(new FileOutputStream(file), OutputFormat.createPrettyPrint()); writer.setEscapeText(false);// 瀛楃鏄惁杞箟,榛樿true writer.write(document); writer.close(); - InterActionToNC(Sqlca,URL,type,batch,count); + InterActionToNC(Sqlca,URL,type,batch,count,batchList); Sqlca.commit(); } } catch (Exception e) { @@ -492,12 +522,6 @@ public class VoucherToNCforVoucherPZ implements Job{ e1.printStackTrace(); } returns="false"; - try { - Sqlca.rollback(); - } catch (JBOException e1) { - e1.printStackTrace(); - } - e.printStackTrace(); }finally { if(Sqlca!=null) { try { @@ -514,7 +538,8 @@ public class VoucherToNCforVoucherPZ implements Job{ /** * 鍍廚C浼犺緭xml, 鑾峰彇NC鍥炴墽xml淇℃伅, 鏍规嵁鍥炴墽淇℃伅鏇存敼鐘舵 */ - public static void InterActionToNC(Transaction Sqlca,String inputURL,String type,String batch,int count) throws Exception { + public static void InterActionToNC(Transaction Sqlca,String inputURL,String type,String batch,int count,List batchList) throws Exception { + String updSql=""; // 鏇存柊鍘嗗彶璁板綍 String updateSql = ""; // 鏇存柊sql瀵硅薄 String insertSql = ""; // 鏂板SQL瀵硅薄 String resultcode= ""; // 鍗曟潯杩斿洖缁撴灉 @@ -523,7 +548,7 @@ public class VoucherToNCforVoucherPZ implements Job{ /** * 鑾峰彇瀵规柟post杩炴帴 */ - String url = "http://172.16.0.88:9990/service/XChangeServlet?account=bq1217&groupcode=06"; + String url = "http://172.16.0.88:9990/service/XChangeServlet?account=8&groupcode=06"; URL realURL = new URL(url); HttpURLConnection connection = (HttpURLConnection)realURL.openConnection(); connection.setDoOutput(true); @@ -572,8 +597,8 @@ public class VoucherToNCforVoucherPZ implements Job{ // 琛ㄦ暟鎹褰曟棩鏈 SimpleDateFormat formatter2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 鍥炴墽淇℃伅瀛樻斁璺緞 - //String resFile = "//data//files//apzl_leasing//tmp//WEN//APleasing_"+type+""+fmt.format(new Date())+".xml"; - String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; + String resFile = "//data//files//apzl_leasing//tmp//WEN//APleasing_"+type+""+fmt.format(new Date())+".xml"; + //String resFile = "D:\\VOUCHER_RECEIPT\\APleasing_"+type+""+fmt.format(new Date())+".xml"; StreamResult result = new StreamResult(new File(resFile)); // 灏嗗洖鎵т俊鎭浆鍖栦负xml transformer.transform(source,result); @@ -586,6 +611,8 @@ public class VoucherToNCforVoucherPZ implements Job{ Element root= doc.getRootElement(); // 鏍规嵁successful鍒ゆ柇鏄惁鏈夊け璐ョ殑, 鏈夊垯涓篘, 鍏ㄩ儴鎴愬姛涓篩 String resSuc = root.attributeValue("successful"); + + // 鍒涘缓 if(null != resSuc){ // 鐘舵佷负N璇存槑鏈壒娆′紶杈撴湁澶辫触鐨 if("N".equals(resSuc)){ @@ -615,24 +642,84 @@ public class VoucherToNCforVoucherPZ implements Job{ resultdescription = el.getStringValue(); } } + + /*// 鏌ヨ涓嶆槸鏈壒娆″彿鐨刡docid, 濡傛灉鏈夊艰鏄庢槸涔嬪墠浼犺緭閿欒鐨勬暟鎹 + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH !='"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record !=null || !"".equals(old_record)) { + // 濡傛灉鐘舵佷负1, 璇存槑宸茬粡鍙樻洿, 浼犺緭鎴愬姛. 鎵цupddate鎿嶄綔, 鍙樻洿璁板綍鐘舵 + if(resultcode=="1" || "1".equals(resultcode)) { + updSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE=null,CREATE_TIME='"+formatter2+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; + } + }*/ + // 鍒ゆ柇, 鑻ュけ璐, 鏇存柊閿欒褰曞叆鏄庣粏琛 if(!"1".equals(resultcode)) { // 濡傛灉鍥炴墽鐘舵佷笉绛変簬1, 璇存槑鏈夎, 鏇存柊鍒拌褰曞瓧琛ㄥ苟璁板綍閿欒淇℃伅 updateSql=" UPDATE NCXML_DETAIL_RECORDS SET FLAG='"+resultcode+"',ERR_DESCRIBE='"+resultdescription+"' WHERE BILLID='"+bdocid+"' AND XML_TYPE= '"+type+"'"; Sqlca.executeSQL(updateSql); logger.info("鏍规嵁鍥炴墽淇℃伅, 淇敼浼犺緭澶辫触鐘舵, 璁板綍閿欒淇℃伅"+updateSql); - failed_count++; + BizObject old_record=JBOFactory.createBizObjectQuery(NCXML_DETAIL_RECORDS.CLASS_NAME, "BILLID='"+bdocid+"' AND BATCH <> '"+batch+"' AND XML_TYPE= '"+type+"'").getSingleResult(false); + if(old_record ==null) { + failed_count++; + } } } - insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+count+"','鏈鍏卞鍏: "+count+"鏉, 澶辫触: "+failed_count+"鏉 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql); - logger.info("鏈壒娆″寘鍚け璐ユ暟鎹 !"); + + // 鍒ゆ柇闆嗗悎涓哄惁涓簄ull, 涓嶄负绌洪亶鍘嗛泦鍚, 鑾峰彇鏃ф暟鎹殑鎵规鍙 + if(batchList != null || batchList.size()>0) { + // 瀹氫箟褰撳墠鎵规, 閿欒璁板綍鏁 + int con=0; + for (String old_batch : batchList) { + // 鏌ヨ闆嗗悎, 鑾峰彇鏃ф壒娆＄殑澶辫触鎬绘暟 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } + + // count涓嶇瓑浜0璇存槑鏈夋柊鏁版嵁, 鍚﹀垯灏卞彧鏈夋棫鐨勯敊璇暟鎹, 涓嶉渶瑕佹柊澧 + if(count != 0 ) { + insertSql = "INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','"+failed_count+"','鍚け璐ヨ褰 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql); + logger.info("鏈壒娆″寘鍚け璐ユ暟鎹 !"); + } + // 鐘舵佷负Y琛ㄧず, 鏈瀵煎叆鍏ㄩ儴鎴愬姛 }else if(resSuc.equals("Y")){ logger.info("瀵煎叆鎴愬姛"); - // 灏嗘湰娆″鍏ヤ俊鎭褰曞叆璁板綍鎬昏〃 - String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','瀵煎叆鎴愬姛 !','"+formatter2.format(new Date())+"')"; - Sqlca.executeSQL(insertSql1); + // count涓嶇瓑浜0璇存槑鏈夋柊鏁版嵁, 鍚﹀垯灏卞彧鏈夋棫鐨勯敊璇暟鎹, 涓嶉渶瑕佹柊澧 + if(count != 0 ) { + // 灏嗘湰娆″鍏ヤ俊鎭褰曞叆璁板綍鎬昏〃 + String insertSql1="INSERT INTO NCXML_TOTAL_RECORDS(ID,BATCH,XML_TYPE,FLAG_,COUNT_,FAILED_COUNT,ERR_DESCRIBE,CREATETIME) VALUES('"+UUID.randomUUID().toString().replace("-", "")+"','"+batch+"','"+type+"','"+resSuc+"','"+count+"','0','瀵煎叆鎴愬姛 !','"+formatter2.format(new Date())+"')"; + Sqlca.executeSQL(insertSql1); + } + // 鍒ゆ柇闆嗗悎涓哄惁涓簄ull, 涓嶄负绌洪亶鍘嗛泦鍚, 鑾峰彇鏃ф暟鎹殑鎵规鍙 + if(batchList != null) { + // 瀹氫箟褰撳墠鎵规, 閿欒璁板綍鏁 + int con=0; + for (String old_batch : batchList) { + // 鏌ヨ闆嗗悎, 鑾峰彇鏃ф壒娆＄殑澶辫触鎬绘暟 + String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+old_batch+"' GROUP BY BATCH;"; + List> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null); + if(dataList!=null && dataList.size()>0) { + con=Integer.valueOf(dataList.get(0).get("CON")); + } + if(con==0) { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FLAG_='Y',FAILED_COUNT='0',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + }else { + updateSql="UPDATE NCXML_TOTAL_RECORDS SET FAILED_COUNT='"+con+"',CREATETIME='"+formatter2.format(new Date())+"' WHERE XML_TYPE='"+type+"' AND BATCH='"+old_batch+"'"; + } + Sqlca.executeSQL(updateSql); + } + } }else{ logger.info("鍑虹幇鏈煡閿欒"); }