diff --git a/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java b/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java index 8e62b124a..7c2495272 100644 --- a/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java +++ b/emis-biz-web/src/main/java/com/xdadan/erp/web/emis/EmisCommonController.java @@ -553,6 +553,34 @@ public class EmisCommonController extends EmisBaseController } + /** + * 单独查询状态 + * @return + */ + @GetMapping("/redoQueryInvoiceStatus") + public AjaxResult redoQueryInvoiceStatus(String seqNo){ + String lockKey="redoQueryInvoiceStatus:"+seqNo; + // 加锁查询 + redissonService.lock(lockKey,300); + try{ + emisSettleInvoiceChRecordService.doQueryAndUpdateChOpenBillStatus(seqNo); + } + catch (Exception ex){ + redissonService.unlock(lockKey); + + ex.printStackTrace(); + // 返回子定义异常 + if(ex instanceof EmisBizError){ + return AjaxResult.error(ex.getMessage(),((EmisBizError)ex).getErrorCode()); + } + + return AjaxResult.error("确认异常,联系客服"); + } + redissonService.unlock(lockKey); + return AjaxResult.success("发送成功"); + + } + /** * 单独出账 * @return diff --git a/emis-biz/src/main/java/com/xdadan/erp/emis/service/IEmisSettleInvoiceChRecordService.java b/emis-biz/src/main/java/com/xdadan/erp/emis/service/IEmisSettleInvoiceChRecordService.java index 8f5e013c8..b9780dbdf 100644 --- a/emis-biz/src/main/java/com/xdadan/erp/emis/service/IEmisSettleInvoiceChRecordService.java +++ b/emis-biz/src/main/java/com/xdadan/erp/emis/service/IEmisSettleInvoiceChRecordService.java @@ -80,4 +80,6 @@ public interface IEmisSettleInvoiceChRecordService public int sendHXToOpen(Long id) throws EmisBizError; public void autoDoQueryOpenBillStatus(); + + public void doQueryAndUpdateChOpenBillStatus(String reqNo); } diff --git a/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisSettleInvoiceChRecordServiceImpl.java b/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisSettleInvoiceChRecordServiceImpl.java index ef1a307f1..c5844035a 100644 --- a/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisSettleInvoiceChRecordServiceImpl.java +++ b/emis-biz/src/main/java/com/xdadan/erp/emis/service/impl/EmisSettleInvoiceChRecordServiceImpl.java @@ -260,12 +260,13 @@ public class EmisSettleInvoiceChRecordServiceImpl implements IEmisSettleInvoiceC } + @Override public void autoDoQueryOpenBillStatus(){ List listWaitQuery=emisSettleInvoiceChRecordMapper.selectWaitQueryStatusList(); for (EmisSettleInvoiceChRecord itemRecord:listWaitQuery) { try { - doQueryAndUpdateChOpenBillStatus(itemRecord); + doQueryAndUpdateChOpenBillStatus(itemRecord.getReqNo()); }catch (Exception ex){ ex.printStackTrace(); } @@ -273,7 +274,11 @@ public class EmisSettleInvoiceChRecordServiceImpl implements IEmisSettleInvoiceC } - private void doQueryAndUpdateChOpenBillStatus(EmisSettleInvoiceChRecord itemRecord){ + @Override + public void doQueryAndUpdateChOpenBillStatus(String reqNo) + { + + EmisSettleInvoiceChRecord itemRecord=emisSettleInvoiceChRecordMapper.selectEmisSettleInvoiceChRecordByReqNo(reqNo); EmisBaseInvoiceChInfo emisBaseInvoiceChInfo = emisBaseInvoiceChInfoMapper.selectEmisBaseInvoiceChInfoByTaxNo(itemRecord.getSalerCompanyTaxNo());