anpeng/apzl_leasing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

凭证相关--接口回执信息处理逻辑优化

Browse Source
This commit is contained in:
xiezhiwen 2019-03-12 19:58:33 +08:00
parent 495ecdf948
commit 04296f6072
4 changed files with 85 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src_core/com/tenwa/voucher/serviceImp/VoucherToNCforAssistContract.java
View File

@ -360,7 +360,7 @@ public class VoucherToNCforAssistContract implements Job{
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;";
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<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
@ -373,12 +373,27 @@ public class VoucherToNCforAssistContract implements Job{
Sqlca.executeSQL(updateSql);
}
}
// count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增
// 如果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("本批次包含失败数据 !");
int con=0;
// 查询本批次错误数据
String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+batch+"' GROUP BY BATCH;";
List<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
// 如果有数据, 统计, 失败记录
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
}
// 如果con等于0, 说明没有失败记录, 插入成功记录
if(con==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+"','Y','"+count+"','"+con+"','导入成功 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次传输成功!");
// 如果con不等于0, 记录含失败记录的数据如总表
}else {
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+"','"+con+"','含失败记录 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次包含失败数据 !");
}
}
// 状态为Y表示, 本次导入全部成功

29
src_core/com/tenwa/voucher/serviceImp/VoucherToNCforCustomer.java
View File

@ -429,7 +429,7 @@ public class VoucherToNCforCustomer implements Job{
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;";
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<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
@ -442,12 +442,27 @@ public class VoucherToNCforCustomer implements Job{
Sqlca.executeSQL(updateSql);
}
}
// count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增
// 如果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("本批次包含失败数据 !");
int con=0;
// 查询本批次错误数据
String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+batch+"' GROUP BY BATCH;";
List<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
// 如果有数据, 统计, 失败记录
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
}
// 如果con等于0, 说明没有失败记录, 插入成功记录
if(con==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+"','Y','"+count+"','"+con+"','导入成功 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次传输成功!");
// 如果con不等于0, 记录含失败记录的数据如总表
}else {
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+"','"+con+"','含失败记录 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次包含失败数据 !");
}
}
// 状态为Y表示, 本次导入全部成功
@ -485,4 +500,4 @@ public class VoucherToNCforCustomer implements Job{
logger.info("未找到successful属性");
}
}
}
}

27
src_core/com/tenwa/voucher/serviceImp/VoucherToNCforDistributor.java
View File

@ -505,7 +505,7 @@ public class VoucherToNCforDistributor implements Job{
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;";
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<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
@ -518,12 +518,27 @@ public class VoucherToNCforDistributor implements Job{
Sqlca.executeSQL(updateSql);
}
}
// count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增
// 如果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("本批次包含失败数据 !");
int con=0;
// 查询本批次错误数据
String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+batch+"' GROUP BY BATCH;";
List<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
// 如果有数据, 统计, 失败记录
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
}
// 如果con等于0, 说明没有失败记录, 插入成功记录
if(con==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+"','Y','"+count+"','"+con+"','导入成功 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次传输成功!");
// 如果con不等于0, 记录含失败记录的数据如总表
}else {
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+"','"+con+"','含失败记录 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次包含失败数据 !");
}
}
// 状态为Y表示, 本次导入全部成功

27
src_core/com/tenwa/voucher/serviceImp/VoucherToNCforVoucherPZ.java
View File

@ -689,7 +689,7 @@ public class VoucherToNCforVoucherPZ implements Job{
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;";
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<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
@ -702,12 +702,27 @@ public class VoucherToNCforVoucherPZ implements Job{
Sqlca.executeSQL(updateSql);
}
}
// count不等于0说明有新数据, 否则就只有旧的错误数据, 不需要新增
// 如果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("本批次包含失败数据 !");
int con=0;
// 查询本批次错误数据
String selectSql="SELECT BATCH,COUNT(BILLID) CON FROM ncxml_detail_records WHERE flag !=1 AND xml_type='"+type+"' AND BATCH='"+batch+"' GROUP BY BATCH;";
List<Map<String,String>> dataList=DataOperatorUtil.getDataBySql(Sqlca, selectSql,null);
// 如果有数据, 统计, 失败记录
if(dataList!=null && dataList.size()>0) {
con=Integer.valueOf(dataList.get(0).get("CON"));
}
// 如果con等于0, 说明没有失败记录, 插入成功记录
if(con==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+"','Y','"+count+"','"+con+"','导入成功 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次传输成功!");
// 如果con不等于0, 记录含失败记录的数据如总表
}else {
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+"','"+con+"','含失败记录 !','"+formatter2.format(new Date())+"')";
Sqlca.executeSQL(insertSql);
logger.info("本批次包含失败数据 !");
}
}
// 状态为Y表示, 本次导入全部成功