|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
break; |
|
|
break; |
|
|
case BLACKHIS_CARD_SYNC: |
|
|
case BLACKHIS_CARD_SYNC: |
|
|
for (TransactionStatus list : lists) { |
|
|
|
|
|
QtkBlackCard blackCard = blackCardRepo.findById(list.getBusinessId()).orElse(null); |
|
|
|
|
|
if (blackCard == null) { |
|
|
|
|
|
transactionStatusRepo.deleteBy(list.getId()); |
|
|
|
|
|
continue; |
|
|
|
|
|
} |
|
|
|
|
|
OisBasicDataUpdateRequest request = new OisBasicDataUpdateRequest(); |
|
|
|
|
|
request.setBlackCard(blackCard); |
|
|
|
|
|
//不管成功失败都删除 |
|
|
|
|
|
try { |
|
|
|
|
|
jsonPostRepeat(request); |
|
|
|
|
|
transactionStatusRepo.deleteBy(list.getId()); |
|
|
|
|
|
} catch (Exception e) { |
|
|
|
|
|
logger.error("同步业务id:{}出错,需人工介入",list.getId(),e); |
|
|
|
|
|
transactionStatusRepo.deleteBy(list.getId()); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
break; |
|
|
|
|
|
case BLACKHIS_CARD_DELETESYNC: |
|
|
|
|
|
for (TransactionStatus list : lists) { |
|
|
for (TransactionStatus list : lists) { |
|
|
QtkBlackCardHis blackCardHis = blackCardHisRepo.findById(list.getBusinessId()).orElse(null); |
|
|
QtkBlackCardHis blackCardHis = blackCardHisRepo.findById(list.getBusinessId()).orElse(null); |
|
|
if (blackCardHis == null) { |
|
|
if (blackCardHis == null) { |
|
|
|
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
break; |
|
|
break; |
|
|
|
|
|
|
|
|
|
|
|
// 这里应该有问题,先注了 |
|
|
|
|
|
case BLACKHIS_CARD_DELETESYNC: |
|
|
|
|
|
// for (TransactionStatus list : lists) { |
|
|
|
|
|
// QtkBlackCardHis blackCardHis = blackCardHisRepo.findById(list.getBusinessId()).orElse(null); |
|
|
|
|
|
// if (blackCardHis == null) { |
|
|
|
|
|
// transactionStatusRepo.deleteBy(list.getId()); |
|
|
|
|
|
// continue; |
|
|
|
|
|
// } |
|
|
|
|
|
// OisBasicDataUpdateRequest request = new OisBasicDataUpdateRequest(); |
|
|
|
|
|
// request.setBlackCardHis(blackCardHis); |
|
|
|
|
|
// //不管成功失败都删除 |
|
|
|
|
|
// try { |
|
|
|
|
|
// jsonPostRepeat(request); |
|
|
|
|
|
// transactionStatusRepo.deleteBy(list.getId()); |
|
|
|
|
|
// } catch (Exception e) { |
|
|
|
|
|
// logger.error("同步业务id:{}出错,需人工介入",list.getId(),e); |
|
|
|
|
|
// transactionStatusRepo.deleteBy(list.getId()); |
|
|
|
|
|
// } |
|
|
|
|
|
// } |
|
|
|
|
|
break; |
|
|
case BLACK_OBU_SYNC: |
|
|
case BLACK_OBU_SYNC: |
|
|
for (TransactionStatus list : lists) { |
|
|
for (TransactionStatus list : lists) { |
|
|
QtkBlackObu blackObu = blackObuRepo.findById(list.getBusinessId()).orElse(null); |
|
|
QtkBlackObu blackObu = blackObuRepo.findById(list.getBusinessId()).orElse(null); |
|
|
|
|
|
|
|
|
break; |
|
|
break; |
|
|
case BLACKHIS_OBU_SYNC: |
|
|
case BLACKHIS_OBU_SYNC: |
|
|
for (TransactionStatus list : lists) { |
|
|
for (TransactionStatus list : lists) { |
|
|
QtkBlackObuHis blackObu = blackObuHisRepo.findById(list.getBusinessId()).orElse(null); |
|
|
|
|
|
|
|
|
QtkBlackObu blackObu = blackObuRepo.findById(list.getBusinessId()).orElse(null); |
|
|
if (blackObu == null) { |
|
|
if (blackObu == null) { |
|
|
transactionStatusRepo.deleteBy(list.getId()); |
|
|
transactionStatusRepo.deleteBy(list.getId()); |
|
|
continue; |
|
|
continue; |
|
|
} |
|
|
} |
|
|
QtkBlackObu blackObuHis = copyProperties(blackObu, new QtkBlackObu()); |
|
|
QtkBlackObu blackObuHis = copyProperties(blackObu, new QtkBlackObu()); |
|
|
|
|
|
blackObuHis.setStatus(2); |
|
|
OisBasicDataUpdateRequest request = new OisBasicDataUpdateRequest(); |
|
|
OisBasicDataUpdateRequest request = new OisBasicDataUpdateRequest(); |
|
|
request.setQtkBlackObu(blackObuHis); |
|
|
request.setQtkBlackObu(blackObuHis); |
|
|
//不管成功失败都删除 |
|
|
//不管成功失败都删除 |