|
|
@ -372,6 +372,7 @@ 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){ |
|
|
|
|
|
|
|
try { |
|
|
|
PushInfoRecord pushInfoRecord = new PushInfoRecord(); |
|
|
|
PushInfoRecord pushInfoRecord = new PushInfoRecord(); |
|
|
|
pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); |
|
|
|
pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); |
|
|
|
pushInfoRecord.setRetryCount(0); |
|
|
|
pushInfoRecord.setRetryCount(0); |
|
|
@ -394,9 +395,13 @@ public class PushInvoiceServiceImpl implements PushInvoiceService { |
|
|
|
}else { |
|
|
|
}else { |
|
|
|
pushInfoRecordMapper.insert(pushInfoRecord); |
|
|
|
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){ |
|
|
|
|
|
|
|
try { |
|
|
|
PushInfoRecord pushInfoRecord = new PushInfoRecord(); |
|
|
|
PushInfoRecord pushInfoRecord = new PushInfoRecord(); |
|
|
|
pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); |
|
|
|
pushInfoRecord.setId(Long.parseLong(DistributedKeyMaker.generateShotKey())); |
|
|
|
pushInfoRecord.setRetryCount(0); |
|
|
|
pushInfoRecord.setRetryCount(0); |
|
|
@ -419,6 +424,9 @@ public class PushInvoiceServiceImpl implements PushInvoiceService { |
|
|
|
}else { |
|
|
|
}else { |
|
|
|
pushInfoRecordMapper.insert(pushInfoRecord); |
|
|
|
pushInfoRecordMapper.insert(pushInfoRecord); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} catch (NumberFormatException e) { |
|
|
|
|
|
|
|
log.error("记录推送失败日志出错,"+e.getMessage()); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private R commonPush(CommonTsMqData fpTsMqData) { |
|
|
|
private R commonPush(CommonTsMqData fpTsMqData) { |
|
|
|