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

Merge branch 'feature/push_record' into test

Browse Source
release
wangrangrang 2 years ago
parent a28a8424b4 9df4d38002
commit bf368d532b
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

@ -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());
}
}

Write Preview
Loading…
Cancel
Save