堃博OA对接宁波银行

This commit is contained in:
yuqh 2024-07-22 11:27:59 +08:00
parent 07c2854ab4
commit 62387004d6
2 changed files with 8 additions and 5 deletions

View File

@ -65,7 +65,7 @@ public class KunBNingBBankPluginInitializer extends PluginBaseEntity{
String dataSourceCode = "KUNBOA"; String dataSourceCode = "KUNBOA";
oaBillEntity.setDataSourceCode(dataSourceCode); oaBillEntity.setDataSourceCode(dataSourceCode);
StringBuffer stringBuffer = new StringBuffer(); StringBuffer stringBuffer = new StringBuffer();
stringBuffer.append("select field0001 as serialNo,field0031 as corpCode,field0012 as rcvAcc,'' as rcvBankName,field0030 as payAcc,field0032 as rcvBankNo,field0012 as rcvName,field0033 as purpose,field0008 as amt,'field0034' as fieldName,'formmain_0020' as tableName, as field0036 payMsg from formmain_0020 where field0034 = '1' and field0012 is not null and field0030 is not null"); stringBuffer.append("select * from v_hzya_pay where payState ='1'");
try { try {
List<HashMap<String, Object>> hashMaps = payBillDao.getOaBillData(stringBuffer.toString(),oaBillEntity); List<HashMap<String, Object>> hashMaps = payBillDao.getOaBillData(stringBuffer.toString(),oaBillEntity);
if(CollectionUtils.isNotEmpty(hashMaps)){ if(CollectionUtils.isNotEmpty(hashMaps)){

View File

@ -80,7 +80,7 @@ public class KunBPayBillPluginInitializer extends PluginBaseEntity{
String code = requestJson.getString("code"); String code = requestJson.getString("code");
sb.append(" and id = '"+rootAppPk+"'"); sb.append(" and id = '"+rootAppPk+"'");
}else{ }else{
sb.append(" and subState is null"); sb.append(" and payState is null");
} }
PayBillEntity oaBillEntity = new PayBillEntity(); PayBillEntity oaBillEntity = new PayBillEntity();
@ -89,7 +89,7 @@ public class KunBPayBillPluginInitializer extends PluginBaseEntity{
StringBuffer stringBuffer = new StringBuffer(); StringBuffer stringBuffer = new StringBuffer();
//备用金申请单 //备用金申请单
stringBuffer.append("select * from v_hzya_pay" ); stringBuffer.append("select * from v_hzya_pay where 1=1 " );
stringBuffer.append(sb.toString()); stringBuffer.append(sb.toString());
List<HashMap<String, Object>> hashMaps = payBillDao.getOaBillData(stringBuffer.toString(),oaBillEntity); List<HashMap<String, Object>> hashMaps = payBillDao.getOaBillData(stringBuffer.toString(),oaBillEntity);
if(CollectionUtils.isNotEmpty(hashMaps)){ if(CollectionUtils.isNotEmpty(hashMaps)){
@ -116,6 +116,7 @@ public class KunBPayBillPluginInitializer extends PluginBaseEntity{
String fieldName = main.getString("fieldName"); String fieldName = main.getString("fieldName");
String tableName = main.getString("tableName"); String tableName = main.getString("tableName");
String payMsg = main.getString("payMsg"); String payMsg = main.getString("payMsg");
// String subMsg = main.getString("subMsg");
String str = ""; String str = "";
String sync_flag = ""; String sync_flag = "";
try { try {
@ -126,6 +127,7 @@ public class KunBPayBillPluginInitializer extends PluginBaseEntity{
taskLivingDetailsService.saveLogToSuccess(logDetails); taskLivingDetailsService.saveLogToSuccess(logDetails);
}else{ }else{
subState = "2"; subState = "2";
sync_flag = " ,"+payMsg+" = '"+attribute+"'";
taskLivingDetailsService.saveLogToFail(logDetails); taskLivingDetailsService.saveLogToFail(logDetails);
} }
}else{ }else{
@ -136,14 +138,15 @@ public class KunBPayBillPluginInitializer extends PluginBaseEntity{
taskLivingDetailsService.saveLogFailToSuccess(logDetails); taskLivingDetailsService.saveLogFailToSuccess(logDetails);
}else{ }else{
subState = "2"; subState = "2";
sync_flag = " ,"+payMsg+" = '"+attribute+"'";
taskLivingDetailsService.updateLogFailToSuccess(logDetails); taskLivingDetailsService.updateLogFailToSuccess(logDetails);
} }
} }
str = "update "+tableName+" set " + fieldName + "= '" +subState+"'," +"subMsg = '"+attribute+"'"+sync_flag+"where id = '"+main.getString("id")+"'"; str = "update "+tableName+" set " + fieldName + "= '" +subState+"'" +sync_flag+"where id = '"+main.getString("id")+"'";
} catch (Exception e) { } catch (Exception e) {
subState = "N"; subState = "N";
str = "update "+tableName+" set " + fieldName + "= '" +subState+"'," +"subMsg = '"+attribute+"' "+"where id = '"+main.getString("id")+"'"; str = "update "+tableName+" set " + fieldName + "= '" +subState+"'" +payMsg+" = '"+attribute+"' "+"where id = '"+main.getString("id")+"'";
logger.info("保存日志失败"+e.getMessage()); logger.info("保存日志失败"+e.getMessage());
oaBillEntity.setSql(str); oaBillEntity.setSql(str);
payBillDao.updateStateForId(str,oaBillEntity); payBillDao.updateStateForId(str,oaBillEntity);