luminghui
/
sdny-order
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

处理异常，避免异常影响主逻辑

Browse Source
release
wangrangrang 2 years ago
parent 056c08e83b
commit 9df4d38002
1 changed files with 50 additions and 42 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 92
      order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java

92
order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java
Unescape View File

@ -364,52 +364,60 @@ public class PushInvoiceServiceImpl implements PushInvoiceService {
} }
public void successPush(Long pushInfoRecordId,String content,String result,PushInfo pushInfo,String pushType){ public void successPush(Long pushInfoRecordId,String content,String result,PushInfo pushInfo,String pushType){
PushInfoRecord pushInfoRecord = new PushInfoRecord(); try {
pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); PushInfoRecord pushInfoRecord = new PushInfoRecord();
pushInfoRecord.setRetryCount(0); pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey()));
if(pushInfo!=null){ pushInfoRecord.setRetryCount(0);
pushInfoRecord.setPushInfoId(pushInfo.getId()); if(pushInfo!=null){
pushInfoRecord.setQyType(pushInfo.getByzd1()); pushInfoRecord.setPushInfoId(pushInfo.getId());
} pushInfoRecord.setQyType(pushInfo.getByzd1());
if(pushInfoRecordId!=null){ }
pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId); if(pushInfoRecordId!=null){
pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1); pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId);
pushInfoRecordMapper.updateByPrimaryKeySelective(pushInfoRecord); pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1);
} pushInfoRecordMapper.updateByPrimaryKeySelective(pushInfoRecord);
pushInfoRecord.setPushContent(content); }
pushInfoRecord.setInterfacePushType(pushType); pushInfoRecord.setPushContent(content);
pushInfoRecord.setPushStatus("success"); pushInfoRecord.setInterfacePushType(pushType);
pushInfoRecord.setResult(result); pushInfoRecord.setPushStatus("success");
pushInfoRecord.setCreateTime(new Date()); pushInfoRecord.setResult(result);
if(pushInfoRecordId!=null){ pushInfoRecord.setCreateTime(new Date());
pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord); if(pushInfoRecordId!=null){
}else { pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord);
pushInfoRecordMapper.insert(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){ public void failPush(Long pushInfoRecordId,String content,String result,String failReason,PushInfo pushInfo,String pushType){
PushInfoRecord pushInfoRecord = new PushInfoRecord(); try {
pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); PushInfoRecord pushInfoRecord = new PushInfoRecord();
pushInfoRecord.setRetryCount(0); pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey()));
if(pushInfo!=null){ pushInfoRecord.setRetryCount(0);
pushInfoRecord.setPushInfoId(pushInfo.getId()); if(pushInfo!=null){
pushInfoRecord.setQyType(pushInfo.getByzd1()); pushInfoRecord.setPushInfoId(pushInfo.getId());
} pushInfoRecord.setQyType(pushInfo.getByzd1());
if(pushInfoRecordId!=null){ }
pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId); if(pushInfoRecordId!=null){
pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1); pushInfoRecord=pushInfoRecordMapper.selectByPrimaryKey(pushInfoRecordId);
} pushInfoRecord.setRetryCount(pushInfoRecord.getRetryCount()+1);
pushInfoRecord.setPushContent(content); }
pushInfoRecord.setInterfacePushType(pushType); pushInfoRecord.setPushContent(content);
pushInfoRecord.setPushStatus("fail"); pushInfoRecord.setInterfacePushType(pushType);
pushInfoRecord.setResult(result); pushInfoRecord.setPushStatus("fail");
pushInfoRecord.setFailReason(failReason); pushInfoRecord.setResult(result);
pushInfoRecord.setCreateTime(new Date()); pushInfoRecord.setFailReason(failReason);
if(pushInfoRecordId!=null){ pushInfoRecord.setCreateTime(new Date());
pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord); if(pushInfoRecordId!=null){
}else { pushInfoRecordMapper.updateByPrimaryKey(pushInfoRecord);
pushInfoRecordMapper.insert(pushInfoRecord); }else {
pushInfoRecordMapper.insert(pushInfoRecord);
}
} catch (NumberFormatException e) {
log.error("记录推送失败日志出错，"+e.getMessage());
} }
} }

Write Preview
Loading…
Cancel
Save