diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java index 8f5bed88..e27143a4 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java @@ -372,52 +372,60 @@ public class PushInvoiceServiceImpl implements PushInvoiceService { } public void successPush(Long pushInfoRecordId,String content,String result,PushInfo pushInfo,String pushType){ - PushInfoRecord pushInfoRecord = new PushInfoRecord(); - pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); - pushInfoRecord.setRetryCount(0); - if(pushInfo!=null){ - pushInfoRecord.setPushInfoId(pushInfo.getId()); - pushInfoRecord.setQyType(pushInfo.getByzd1()); - } - if(pushInfoRecordId!=null){ - pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId); - pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1); - pushInfoRecordMapper.updateByPrimaryKeySelective(pushInfoRecord); - } - pushInfoRecord.setPushContent(content); - pushInfoRecord.setInterfacePushType(pushType); - pushInfoRecord.setPushStatus("success"); - pushInfoRecord.setResult(result); - pushInfoRecord.setCreateTime(new Date()); - if(pushInfoRecordId!=null){ - pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord); - }else { - pushInfoRecordMapper.insert(pushInfoRecord); + try { + PushInfoRecord pushInfoRecord = new PushInfoRecord(); + pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); + pushInfoRecord.setRetryCount(0); + if(pushInfo!=null){ + pushInfoRecord.setPushInfoId(pushInfo.getId()); + pushInfoRecord.setQyType(pushInfo.getByzd1()); + } + if(pushInfoRecordId!=null){ + pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId); + pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1); + pushInfoRecordMapper.updateByPrimaryKeySelective(pushInfoRecord); + } + pushInfoRecord.setPushContent(content); + pushInfoRecord.setInterfacePushType(pushType); + pushInfoRecord.setPushStatus("success"); + pushInfoRecord.setResult(result); + pushInfoRecord.setCreateTime(new Date()); + if(pushInfoRecordId!=null){ + pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord); + }else { + pushInfoRecordMapper.insert(pushInfoRecord); + } + } catch (Exception e) { + log.error("记录推送成功日志出错,"+e.getMessage()); } } public void failPush(Long pushInfoRecordId,String content,String result,String failReason,PushInfo pushInfo,String pushType){ - PushInfoRecord pushInfoRecord = new PushInfoRecord(); - pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); - pushInfoRecord.setRetryCount(0); - if(pushInfo!=null){ - pushInfoRecord.setPushInfoId(pushInfo.getId()); - pushInfoRecord.setQyType(pushInfo.getByzd1()); - } - if(pushInfoRecordId!=null){ - pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId); - pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1); - } - pushInfoRecord.setPushContent(content); - pushInfoRecord.setInterfacePushType(pushType); - pushInfoRecord.setPushStatus("fail"); - pushInfoRecord.setResult(result); - pushInfoRecord.setFailReason(failReason); - pushInfoRecord.setCreateTime(new Date()); - if(pushInfoRecordId!=null){ - pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord); - }else { - pushInfoRecordMapper.insert(pushInfoRecord); + try { + PushInfoRecord pushInfoRecord = new PushInfoRecord(); + pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); + pushInfoRecord.setRetryCount(0); + if(pushInfo!=null){ + pushInfoRecord.setPushInfoId(pushInfo.getId()); + pushInfoRecord.setQyType(pushInfo.getByzd1()); + } + if(pushInfoRecordId!=null){ + pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId); + pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1); + } + pushInfoRecord.setPushContent(content); + pushInfoRecord.setInterfacePushType(pushType); + pushInfoRecord.setPushStatus("fail"); + pushInfoRecord.setResult(result); + pushInfoRecord.setFailReason(failReason); + pushInfoRecord.setCreateTime(new Date()); + if(pushInfoRecordId!=null){ + pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord); + }else { + pushInfoRecordMapper.insert(pushInfoRecord); + } + } catch (NumberFormatException e) { + log.error("记录推送失败日志出错,"+e.getMessage()); } }