diff --git a/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java b/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java index caf41930..c8bfc484 100644 --- a/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java +++ b/dxhy-base/src/main/java/com/dxhy/base/controller/BaseInvoiceController.java @@ -1410,7 +1410,6 @@ public class BaseInvoiceController extends AbstractController { List uuidList = Arrays.asList(uuidArray); //查询库中是否包含对应数据 - DynamicContextHolder.push(getUserInfo().getDbName() + DbConstant.BUSINESS_READ); List list = baseIRzTDxRecordInvoiceService.findSuspendStatus(uuidList); if (list == null || list.isEmpty()) { return ResponseEntity.ok(R.error("没有可操作的数据")); diff --git a/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/InvoiceInterfaceServiceImpl.java b/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/InvoiceInterfaceServiceImpl.java index 4118f893..6ab6da0b 100644 --- a/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/InvoiceInterfaceServiceImpl.java +++ b/dxhy-core/src/main/java/com/dxhy/core/job/service/impl/InvoiceInterfaceServiceImpl.java @@ -733,7 +733,6 @@ public class InvoiceInterfaceServiceImpl implements InvoiceInterfaceService { flag = true; } if (flag) { - DynamicContextHolder.push(db + DbConstant.BUSINESS_WRITE); if (StringUtils.isBlank(entity.getInvoiceCode())) { entity.setInvoiceCode(""); } @@ -741,7 +740,6 @@ public class InvoiceInterfaceServiceImpl implements InvoiceInterfaceService { } // 艺龙推送数据 if (yLcompany.equals(company)) { - DynamicContextHolder.push(db + DbConstant.BUSINESS_READ); InvoiceScanEntity selectSign = tDxRecordInvoiceJobDao .selectByScan(entity.getInvoiceCode() + entity.getInvoiceNo(), dxhyAdmin); if (selectSign != null && "1".equals(selectSign.getQsStatus())) { @@ -759,7 +757,6 @@ public class InvoiceInterfaceServiceImpl implements InvoiceInterfaceService { record.setCollectFrom("0"); record.setCollectDate(new Date()); record.setPoolStatus("0"); - DynamicContextHolder.push(db + DbConstant.BUSINESS_WRITE); tDxRecordInvoiceJobDao.insert(record); } InvoiceLog invoiceLog = new InvoiceLog(); diff --git a/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/ImageSubmitServiceImpl.java b/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/ImageSubmitServiceImpl.java index 75cd0f67..c71e05a0 100644 --- a/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/ImageSubmitServiceImpl.java +++ b/dxhy-erp/src/main/java/com/dxhy/erp/service/impl/ImageSubmitServiceImpl.java @@ -65,7 +65,6 @@ public class ImageSubmitServiceImpl implements ImageSubmitService { uuidList.add(uuid); paramsInvoiceMap.put(uuid, item); }); - DynamicContextHolder.push(DbConstant.BUSINESS_WRITE); QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.in("uuid", uuidList); List invoicesList = tdxRecordInvoiceDao.selectList(queryWrapper); @@ -85,7 +84,6 @@ public class ImageSubmitServiceImpl implements ImageSubmitService { String errorMsg = msg.toString(); return R.error(500, "未查询到如下发票,请重新查验," + errorMsg); } - DynamicContextHolder.push(DbConstant.DETAIL_WRITE); QueryWrapper detailQueryWrapper = new QueryWrapper<>(); detailQueryWrapper.in("uuid", uuidList); List detailList = detailDao.selectList(detailQueryWrapper); @@ -128,7 +126,6 @@ public class ImageSubmitServiceImpl implements ImageSubmitService { invoicesList.stream().forEach(invoice -> { - DynamicContextHolder.push(DbConstant.BUSINESS_WRITE); SdnyTDxSaleRecordInvoice saleRecordInvoice = sdnyTDxSaleRecordInvoiceDao.selectOne(new QueryWrapper().eq("uuid", invoice.getUuid())); List salesDetailList = new ArrayList<>(); detailiMap.get(invoice.getUuid()).stream().forEach(item -> { @@ -140,9 +137,7 @@ public class ImageSubmitServiceImpl implements ImageSubmitService { // 新增 saleRecordInvoice = JsonUtils.getInstance().parseObject(JSONObject.toJSONString(invoice), SdnyTDxSaleRecordInvoice.class); saleRecordInvoice.setId(null); - DynamicContextHolder.push(DbConstant.BUSINESS_WRITE); sdnyTDxSaleRecordInvoiceDao.insert(saleRecordInvoice); - DynamicContextHolder.push(DbConstant.DETAIL_READ); detailSalesDao.deleteByUUid(invoice.getUuid()); detailSalesDao.batchInsert(salesDetailList); } else { @@ -150,7 +145,6 @@ public class ImageSubmitServiceImpl implements ImageSubmitService { saleRecordInvoice.setImageId(invoice.getImageId()); saleRecordInvoice.setBzdh(invoice.getBzdh()); saleRecordInvoice.setBzr(invoice.getBzr()); - DynamicContextHolder.push(DbConstant.BUSINESS_WRITE); sdnyTDxSaleRecordInvoiceDao.updateById(saleRecordInvoice); } saleRecordInvoice.setDetailList(salesDetailList); @@ -164,7 +158,6 @@ public class ImageSubmitServiceImpl implements ImageSubmitService { @Override public R salesInvoiceRollback(SNRequestObject params) { - DynamicContextHolder.push(DbConstant.BUSINESS_WRITE); List data = sdnyTDxSaleRecordInvoiceDao.selectList(new QueryWrapper().eq("image_id", params.getImageId())); if (data != null && data.size() > 0) { List uuidList = new ArrayList<>();