ariesy 事务代码提交

release
yefei 2 years ago
parent 79c3790264
commit 9f87da0e7f
  1. 1
      dxhy-base/src/main/java/com/dxhy/base/service/fpcj/BaseFpcjmxServiceImpl.java
  2. 3
      dxhy-core/src/main/java/com/dxhy/core/job/service/impl/CheckTaskServiceImpl.java
  3. 3
      dxhy-core/src/main/java/com/dxhy/core/job/service/impl/DataPlatformCollectServiceImpl.java
  4. 4
      dxhy-core/src/main/java/com/dxhy/core/job/service/impl/InvoiceDownServiceImpl.java
  5. 3
      dxhy-core/src/main/java/com/dxhy/core/job/service/impl/InvoiceInterfaceServiceImpl.java
  6. 2
      dxhy-core/src/main/java/com/dxhy/core/service/invoicedetail/InvoiceDetailServiceImpl.java
  7. 1
      dxhy-core/src/main/java/com/dxhy/core/service/singletable/impl/CoreSaveInvoiceInfoServiceImpl.java
  8. 1
      dxhy-core/src/main/java/com/dxhy/core/service/singletable/impl/InvoiceDetailImpl.java
  9. 1
      dxhy-customs/src/main/java/com/dxhy/customs/service/impl/CustomsCustomsJkszhcxServiceImpl.java
  10. 4
      dxhy-erp/src/main/java/com/dxhy/erp/controller/SDNYMainProcessController.java
  11. 2
      dxhy-erp/src/main/java/com/dxhy/erp/service/SignedService.java
  12. 1
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/AllTaxesSaleServiceImpl.java
  13. 1
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/FEServiceImpl.java
  14. 2
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/GatherServiceImpl.java
  15. 2
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/InvoicePoolServiceImpl.java
  16. 1
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/MryxInterfaceServiceImpl.java
  17. 2
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/QsCheckTaskServiceImpl.java
  18. 1
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignDataServiceImpl.java
  19. 2
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignInvoiceDetailServiceImpl.java
  20. 1
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/SignSaveInvoiceInfoServiceImpl.java
  21. 1
      dxhy-erp/src/main/java/com/dxhy/erp/service/impl/TDxInvoiceReimburseServiceImpl.java
  22. 1
      dxhy-erp/src/main/java/com/dxhy/erp/utils/MyThread.java
  23. 1
      dxhy-extend/src/main/java/com/dxhy/extend/service/pool/ExtInvoicePoolServiceImpl.java
  24. 2
      dxhy-passengerTicket/src/main/java/com/dxhy/passengerticket/service/impl/PassengerReimbursementSystemServiceImpl.java
  25. 2
      dxhy-portrait/src/main/java/com/dxhy/portrait/business/service/impl/InvoiceDetailImpl.java
  26. 1
      dxhy-portrait/src/main/java/com/dxhy/portrait/business/service/impl/SaveInvoiceInfoServiceImpl.java
  27. 1
      dxhy-sign/src/main/java/com/dxhy/sign/service/fpqs/impl/SignFpqsServiceImpl.java
  28. 2
      dxhy-sign/src/main/java/com/dxhy/sign/service/singletable/impl/SignInvoiceDetailServiceImpl.java
  29. 1
      dxhy-sign/src/main/java/com/dxhy/sign/service/singletable/impl/SignSaveInvoiceInfoServiceImpl.java

@ -238,7 +238,6 @@ public class BaseFpcjmxServiceImpl extends MpBaseServiceImpl<BaseTDxRecordInvoic
// 专票和通行费发票货物可以是多条 // 专票和通行费发票货物可以是多条
if (FplxEnum.ZP.getFplxDm().equals(invoiceType) || FplxEnum.DZZP.getFplxDm().equals(invoiceType) if (FplxEnum.ZP.getFplxDm().equals(invoiceType) || FplxEnum.DZZP.getFplxDm().equals(invoiceType)
|| FplxEnum.TXF.getFplxDm().equals(invoiceType)) { || FplxEnum.TXF.getFplxDm().equals(invoiceType)) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
List<BaseTDxRecordInvoiceDetail> invoiceDetailList = new ArrayList<>(detailArray.size()); List<BaseTDxRecordInvoiceDetail> invoiceDetailList = new ArrayList<>(detailArray.size());
for (int i = 0; i < detailArray.size(); i++) { for (int i = 0; i < detailArray.size(); i++) {
JSONObject invoiceDetailJson = detailArray.getJSONObject(i); JSONObject invoiceDetailJson = detailArray.getJSONObject(i);

@ -208,20 +208,17 @@ public class CheckTaskServiceImpl implements CheckTaskService {
} }
private int getDetailCount(InvoiceCollectionInfo invoiceCollectionInfo, String db) { private int getDetailCount(InvoiceCollectionInfo invoiceCollectionInfo, String db) {
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
return tDxRecordInvoiceDetailDao return tDxRecordInvoiceDetailDao
.getDetailCount(invoiceCollectionInfo.getUuid()); .getDetailCount(invoiceCollectionInfo.getUuid());
} }
private void insertDetail(String db, List<InvoiceDetailInfo> invoiceDetailInfoList) { private void insertDetail(String db, List<InvoiceDetailInfo> invoiceDetailInfoList) {
if (invoiceDetailInfoList != null && invoiceDetailInfoList.size() > 0) { if (invoiceDetailInfoList != null && invoiceDetailInfoList.size() > 0) {
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
tDxRecordInvoiceDetailJobService.saveBatch(invoiceDetailInfoList); tDxRecordInvoiceDetailJobService.saveBatch(invoiceDetailInfoList);
} }
} }
private void deleteDetail(InvoiceDetailInfo invoiceDetail, String db) { private void deleteDetail(InvoiceDetailInfo invoiceDetail, String db) {
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
checkTaskDao.deleteDetail(invoiceDetail); checkTaskDao.deleteDetail(invoiceDetail);
} }

@ -551,7 +551,6 @@ public class DataPlatformCollectServiceImpl implements DataPlatformCollectServic
String invoiceCode = dataPlatformInvoiceInfo.getInvoiceCode(); String invoiceCode = dataPlatformInvoiceInfo.getInvoiceCode();
String invoiceNo = dataPlatformInvoiceInfo.getInvoiceNo(); String invoiceNo = dataPlatformInvoiceInfo.getInvoiceNo();
dataPlatformInvoiceInfo.setUuid(invoiceCode + invoiceNo); dataPlatformInvoiceInfo.setUuid(invoiceCode + invoiceNo);
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
// 插入明细 // 插入明细
List<DataPlatformInvoiceDetailInfo> detailList = dataPlatformInvoiceInfo.getDetailList(); List<DataPlatformInvoiceDetailInfo> detailList = dataPlatformInvoiceInfo.getDetailList();
// 进项发票入库 // 进项发票入库
@ -643,7 +642,6 @@ public class DataPlatformCollectServiceImpl implements DataPlatformCollectServic
String uuid = invoiceCode + invoiceNo; String uuid = invoiceCode + invoiceNo;
List<DataPlatformInvoiceDetailInfo> detailList = invoice.getDetailList(); List<DataPlatformInvoiceDetailInfo> detailList = invoice.getDetailList();
if (detailList != null && detailList.size() > 0) { if (detailList != null && detailList.size() > 0) {
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
if ("1".equals(tDxHttpLog.getSubject())) { if ("1".equals(tDxHttpLog.getSubject())) {
dataPlatformDao.delDetailIncome(invoiceCode + invoiceNo); dataPlatformDao.delDetailIncome(invoiceCode + invoiceNo);
for (DataPlatformInvoiceDetailInfo invoiceDetailInfo : detailList) { for (DataPlatformInvoiceDetailInfo invoiceDetailInfo : detailList) {
@ -663,7 +661,6 @@ public class DataPlatformCollectServiceImpl implements DataPlatformCollectServic
dataPlatformDao.insertDetailSales(invoiceDetailInfo); dataPlatformDao.insertDetailSales(invoiceDetailInfo);
} }
} }
DynamicContextHolder.push(db + DbConstant.DETAIL_READ);
int countDetail = dataPlatformDao.getDetailCount(invoiceCode + invoiceNo); int countDetail = dataPlatformDao.getDetailCount(invoiceCode + invoiceNo);
if (countDetail > 0) { if (countDetail > 0) {
invoice.setDetailYesorno("1"); invoice.setDetailYesorno("1");

@ -790,7 +790,6 @@ public class InvoiceDownServiceImpl implements InvoiceDownService {
String uuid = invoiceCode + invoiceNo; String uuid = invoiceCode + invoiceNo;
List<RecordInvoiceDetailModel> detailList = invoice.getDetailList(); List<RecordInvoiceDetailModel> detailList = invoice.getDetailList();
if (detailList != null && detailList.size() > 0) { if (detailList != null && detailList.size() > 0) {
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
if ("1".equals(tDxHttpLog.getDataType())) { if ("1".equals(tDxHttpLog.getDataType())) {
invoiceDownDao.delDetailIncome(invoiceCode + invoiceNo); invoiceDownDao.delDetailIncome(invoiceCode + invoiceNo);
for (RecordInvoiceDetailModel invoiceDetailInfo : detailList) { for (RecordInvoiceDetailModel invoiceDetailInfo : detailList) {
@ -813,7 +812,6 @@ public class InvoiceDownServiceImpl implements InvoiceDownService {
} }
if ("1".equals(tDxHttpLog.getDataType())) { if ("1".equals(tDxHttpLog.getDataType())) {
DynamicContextHolder.push(db + DbConstant.DETAIL_READ);
int countDetail = invoiceDownDao.getDetailCount(invoiceCode + invoiceNo, "t_dx_record_invoice_detail"); int countDetail = invoiceDownDao.getDetailCount(invoiceCode + invoiceNo, "t_dx_record_invoice_detail");
if (countDetail > 0) { if (countDetail > 0) {
invoice.setDetailYesorno("1"); invoice.setDetailYesorno("1");
@ -824,7 +822,6 @@ public class InvoiceDownServiceImpl implements InvoiceDownService {
invoiceDownDao.updateRecordInvoice(invoice); invoiceDownDao.updateRecordInvoice(invoice);
} }
if ("2".equals(tDxHttpLog.getDataType())) { if ("2".equals(tDxHttpLog.getDataType())) {
DynamicContextHolder.push(db + DbConstant.DETAIL_READ);
int countDetail = int countDetail =
invoiceDownDao.getDetailCount(invoiceCode + invoiceNo, "t_dx_record_invoice_detail_sales"); invoiceDownDao.getDetailCount(invoiceCode + invoiceNo, "t_dx_record_invoice_detail_sales");
if (countDetail > 0) { if (countDetail > 0) {
@ -878,7 +875,6 @@ public class InvoiceDownServiceImpl implements InvoiceDownService {
String invoiceCode = dataPlatformInvoiceInfo.getInvoiceCode(); String invoiceCode = dataPlatformInvoiceInfo.getInvoiceCode();
String invoiceNo = dataPlatformInvoiceInfo.getInvoiceNo(); String invoiceNo = dataPlatformInvoiceInfo.getInvoiceNo();
dataPlatformInvoiceInfo.setUuid(invoiceCode + invoiceNo); dataPlatformInvoiceInfo.setUuid(invoiceCode + invoiceNo);
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
// 插入明细 // 插入明细
List<RecordInvoiceDetailModel> detailList = dataPlatformInvoiceInfo.getDetailList(); List<RecordInvoiceDetailModel> detailList = dataPlatformInvoiceInfo.getDetailList();
// 进项发票入库 // 进项发票入库

@ -1205,10 +1205,9 @@ public class InvoiceInterfaceServiceImpl implements InvoiceInterfaceService {
invoiceDetailInfo.setSpecificationModel(null); invoiceDetailInfo.setSpecificationModel(null);
invoiceDetailInfo.setTaxCodeName(null); invoiceDetailInfo.setTaxCodeName(null);
} }
DynamicContextHolder.push(db + DbConstant.DETAIL_WRITE);
tDxRecordInvoiceDetailDao.delDetail(uuid); tDxRecordInvoiceDetailDao.delDetail(uuid);
tDxRecordInvoiceDetailJobService.saveBatch(detailList); tDxRecordInvoiceDetailJobService.saveBatch(detailList);
DynamicContextHolder.push(db + DbConstant.DETAIL_READ);
int countDetail = tDxRecordInvoiceDetailDao.getDetailCount(uuid); int countDetail = tDxRecordInvoiceDetailDao.getDetailCount(uuid);
if (countDetail > 0) { if (countDetail > 0) {
recordInvoices.setDetailYesorno("1"); recordInvoices.setDetailYesorno("1");

@ -71,7 +71,6 @@ public class InvoiceDetailServiceImpl extends MpBaseServiceImpl<TDxRecordInvoice
@Override @Override
public List<InvoiceDetails> selectInvoiceDetails(String invoiceNo, String invoiceCode, String dbName) { public List<InvoiceDetails> selectInvoiceDetails(String invoiceNo, String invoiceCode, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
Map<String, Object> map = new HashMap<>(3); Map<String, Object> map = new HashMap<>(3);
map.put("invoiceNo", invoiceNo); map.put("invoiceNo", invoiceNo);
map.put("invoiceCode", invoiceCode); map.put("invoiceCode", invoiceCode);
@ -123,7 +122,6 @@ public class InvoiceDetailServiceImpl extends MpBaseServiceImpl<TDxRecordInvoice
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
vehicleSaleInfo = jdcService.getOne(queryWrapper); vehicleSaleInfo = jdcService.getOne(queryWrapper);
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>(); QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
queryWrapper.orderByAsc("detail_no"); queryWrapper.orderByAsc("detail_no");

@ -86,7 +86,6 @@ public class CoreSaveInvoiceInfoServiceImpl extends MpBaseServiceImpl<TDxRecordI
if (recordInvoiceDetail != null && recordInvoiceDetail.size() > 0) { if (recordInvoiceDetail != null && recordInvoiceDetail.size() > 0) {
// 保存底账明细表数据 // 保存底账明细表数据
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
// 删除已存在的数据,防止数据重复 // 删除已存在的数据,防止数据重复
QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>(); QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);

@ -23,7 +23,6 @@ public class InvoiceDetailImpl extends MpBaseServiceImpl<TDxRecordInvoiceDetailD
@Override @Override
public List<TDxRecordInvoiceDetail> getSalesInvoiceDetail(String dbName, String uuid) { public List<TDxRecordInvoiceDetail> getSalesInvoiceDetail(String dbName, String uuid) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
return baseMapper.getSalesInvoiceDetail(uuid); return baseMapper.getSalesInvoiceDetail(uuid);
} }

@ -194,7 +194,6 @@ public class CustomsCustomsJkszhcxServiceImpl extends MpBaseServiceImpl<CustomsJ
private JSONObject createCustomsInfo(TdxCustomsRecord record, String dbName) { private JSONObject createCustomsInfo(TdxCustomsRecord record, String dbName) {
List<TdxCustomsDetail> detailList = null; List<TdxCustomsDetail> detailList = null;
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
QueryWrapper<TdxCustomsDetail> queryWrapper = new QueryWrapper<>(); QueryWrapper<TdxCustomsDetail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("customs_code", record.getCustomsCode()); queryWrapper.eq("customs_code", record.getCustomsCode());
detailList = customsCustomsDetailDao.selectList(queryWrapper); detailList = customsCustomsDetailDao.selectList(queryWrapper);

@ -272,7 +272,6 @@ public class SDNYMainProcessController extends AbstractController {
if ("10104".equals(pramsMap.get("invoiceType")) || "10105".equals(pramsMap.get("invoiceType"))) { if ("10104".equals(pramsMap.get("invoiceType")) || "10105".equals(pramsMap.get("invoiceType"))) {
vehicleList = snPushCheckRecordService.vihicleList(uuid); vehicleList = snPushCheckRecordService.vihicleList(uuid);
} else { } else {
DynamicContextHolder.push("business" + DbConstant.DETAIL_READ);
baseTDxRecordInvoiceDetail = baseTDxRecordInvoiceDetailDao.selectList(detailWrapper); baseTDxRecordInvoiceDetail = baseTDxRecordInvoiceDetailDao.selectList(detailWrapper);
} }
DynamicContextHolder.push("business" + DbConstant.BUSINESS_READ); DynamicContextHolder.push("business" + DbConstant.BUSINESS_READ);
@ -297,7 +296,6 @@ public class SDNYMainProcessController extends AbstractController {
if ("10104".equals(pramsMap.get("invoiceType")) || "10105".equals(pramsMap.get("invoiceType"))) { if ("10104".equals(pramsMap.get("invoiceType")) || "10105".equals(pramsMap.get("invoiceType"))) {
vehicleList = snPushCheckRecordService.vihicleList(uuid); vehicleList = snPushCheckRecordService.vihicleList(uuid);
} else { } else {
DynamicContextHolder.push("business" + DbConstant.DETAIL_READ);
baseTDxRecordInvoiceDetail = baseTDxRecordInvoiceDetailDao.selectList(detailWrapper); baseTDxRecordInvoiceDetail = baseTDxRecordInvoiceDetailDao.selectList(detailWrapper);
DynamicContextHolder.push("business" + DbConstant.BUSINESS_READ); DynamicContextHolder.push("business" + DbConstant.BUSINESS_READ);
} }
@ -357,7 +355,6 @@ public class SDNYMainProcessController extends AbstractController {
String invoiceNo = tdxSaleRecordInvoice.getInvoiceNo(); String invoiceNo = tdxSaleRecordInvoice.getInvoiceNo();
QueryWrapper<RecordInvoiceSaleDetailModel> saleDetailWrapper = new QueryWrapper<>(); QueryWrapper<RecordInvoiceSaleDetailModel> saleDetailWrapper = new QueryWrapper<>();
saleDetailWrapper.eq("invoice_no", invoiceNo); saleDetailWrapper.eq("invoice_no", invoiceNo);
DynamicContextHolder.push(DbConstant.DETAIL_READ);
List<RecordInvoiceSaleDetailModel> recordInvoiceSaleDetailModel = invoiceDownDetaiSaleInsertDao.selectList(saleDetailWrapper); List<RecordInvoiceSaleDetailModel> recordInvoiceSaleDetailModel = invoiceDownDetaiSaleInsertDao.selectList(saleDetailWrapper);
DynamicContextHolder.push(DbConstant.BUSINESS_READ); DynamicContextHolder.push(DbConstant.BUSINESS_READ);
@ -1304,7 +1301,6 @@ public class SDNYMainProcessController extends AbstractController {
if (StringUtils.isBlank(snInvoice.getInvoiceCode())) { if (StringUtils.isBlank(snInvoice.getInvoiceCode())) {
uuid = snInvoice.getInvoiceNumber(); uuid = snInvoice.getInvoiceNumber();
} }
DynamicContextHolder.push("business" + DbConstant.DETAIL_READ);
List<InvoiceDetailInfo> detailInfo = mryxInterfaceService.getDetailInfo(uuid); List<InvoiceDetailInfo> detailInfo = mryxInterfaceService.getDetailInfo(uuid);
if (invoiceLineList != null && invoiceLineList.size() > 0) { if (invoiceLineList != null && invoiceLineList.size() > 0) {

@ -297,7 +297,6 @@ public class SignedService {
log.debug("-------------------" + invoiceInfo); log.debug("-------------------" + invoiceInfo);
if ("01".equals(record.getInvoiceType()) || "08".equals(record.getInvoiceType())) { if ("01".equals(record.getInvoiceType()) || "08".equals(record.getInvoiceType())) {
try { try {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
detailList = signedDao.selectDetails(record.getInvoiceCode() + record.getInvoiceNo()); detailList = signedDao.selectDetails(record.getInvoiceCode() + record.getInvoiceNo());
log.debug("============" + detailList); log.debug("============" + detailList);
if (detailList.size() > 0) { if (detailList.size() > 0) {
@ -489,7 +488,6 @@ public class SignedService {
if (record != null) { if (record != null) {
invoiceInfo = getInvoiceInfo(record); invoiceInfo = getInvoiceInfo(record);
try { try {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
details = signedDao.selectDetails(data.getInvoiceCode() + data.getInvoiceNo()); details = signedDao.selectDetails(data.getInvoiceCode() + data.getInvoiceNo());
log.info("----------" + details); log.info("----------" + details);
if (details.size() > 0) { if (details.size() > 0) {

@ -352,7 +352,6 @@ public class AllTaxesSaleServiceImpl implements AllTaxesSaleService {
boolean isAdd = false; boolean isAdd = false;
// 遍历明细-判断明细行 // 遍历明细-判断明细行
String uuid = po.getUuid(); String uuid = po.getUuid();
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
List<SaleInvoiceDetailInfo> detailListByDb = allTaxesSaleDao.getInvoiceDetailByUuid(uuid); List<SaleInvoiceDetailInfo> detailListByDb = allTaxesSaleDao.getInvoiceDetailByUuid(uuid);
List<SaleInvoiceDetailInfo> detailListByDbLast = new ArrayList<>(detailListByDb); List<SaleInvoiceDetailInfo> detailListByDbLast = new ArrayList<>(detailListByDb);
Map<String, String> map = new HashMap<>(); Map<String, String> map = new HashMap<>();

@ -104,7 +104,6 @@ public class FEServiceImpl implements IFEService {
// 如果签收成功的 加入到SuccessList 并查询明细表 // 如果签收成功的 加入到SuccessList 并查询明细表
String invoiceCode =StringUtils.isEmpty(info.getInvoiceCode())?"":info.getInvoiceCode(); String invoiceCode =StringUtils.isEmpty(info.getInvoiceCode())?"":info.getInvoiceCode();
String uuid = invoiceCode+ info.getInvoiceNo(); String uuid = invoiceCode+ info.getInvoiceNo();
DynamicContextHolder.push("business" + DbConstant.DETAIL_READ);
String goodsName = tdxInvoiceDao.findDetailByUUid(uuid); String goodsName = tdxInvoiceDao.findDetailByUUid(uuid);
SuccessInvoice success = new SuccessInvoice(); SuccessInvoice success = new SuccessInvoice();
success.setInvoiceCode( success.setInvoiceCode(

@ -165,7 +165,6 @@ public class GatherServiceImpl extends MpBaseServiceImpl<TdxRecordInvoiceDao, Td
} }
} }
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
detailList = getDetailInfo(uuid); detailList = getDetailInfo(uuid);
List<InvoiceDetailInfo> listInfo = new ArrayList<>(); List<InvoiceDetailInfo> listInfo = new ArrayList<>();
if (detailList != null && detailList.size() > 0) { if (detailList != null && detailList.size() > 0) {
@ -419,7 +418,6 @@ public class GatherServiceImpl extends MpBaseServiceImpl<TdxRecordInvoiceDao, Td
} }
} }
}else { }else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
// detailList = getDetailInfo(recordInvoice.getInvoiceCode() + recordInvoice.getInvoiceNo()); // detailList = getDetailInfo(recordInvoice.getInvoiceCode() + recordInvoice.getInvoiceNo());
detailList = getDetailInfo(recordInvoice.getUuid()); detailList = getDetailInfo(recordInvoice.getUuid());
List<InvoiceDetailInfo> listInfo = new ArrayList<>(); List<InvoiceDetailInfo> listInfo = new ArrayList<>();

@ -610,7 +610,6 @@ public class InvoicePoolServiceImpl implements InvoicePoolService {
} }
} }
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
detailList = invoicePoolDao.listInvoiceDetail(data.getDataType(), uuid); detailList = invoicePoolDao.listInvoiceDetail(data.getDataType(), uuid);
List<InvoicePoolDetailInfo> listInfo = new ArrayList<>(); List<InvoicePoolDetailInfo> listInfo = new ArrayList<>();
if (detailList != null) { if (detailList != null) {
@ -1698,7 +1697,6 @@ public class InvoicePoolServiceImpl implements InvoicePoolService {
vehicle.setUuid(invoiceCode + invoiceNo); vehicle.setUuid(invoiceCode + invoiceNo);
vehicleSaleInvoiceDao.insert(vehicle); vehicleSaleInvoiceDao.insert(vehicle);
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
salesInvoiceDetailDao salesInvoiceDetailDao
.delete(new UpdateWrapper<InvoiceDetailInfo>().eq("uuid", invoiceCode + invoiceNo)); .delete(new UpdateWrapper<InvoiceDetailInfo>().eq("uuid", invoiceCode + invoiceNo));
List<InvoiceDetailInfo> details = infos.getDetailList(); List<InvoiceDetailInfo> details = infos.getDetailList();

@ -113,7 +113,6 @@ public class MryxInterfaceServiceImpl extends MpBaseServiceImpl<TdxRecordInvoice
} }
} }
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
detailList = getDetailInfo(uuid); detailList = getDetailInfo(uuid);
List<InvoiceDetailInfo> listInfo = new ArrayList<>(); List<InvoiceDetailInfo> listInfo = new ArrayList<>();
if (detailList != null && detailList.size() > 0) { if (detailList != null && detailList.size() > 0) {

@ -210,8 +210,6 @@ public class QsCheckTaskServiceImpl extends MpBaseServiceImpl<InvoiceElectronDao
public void insertInvoiceDetail(String invoiceCode, String invoiceNo, List<RecordInvoiceDetail> detailList, public void insertInvoiceDetail(String invoiceCode, String invoiceNo, List<RecordInvoiceDetail> detailList,
String dbName) throws Exception { String dbName) throws Exception {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
for (RecordInvoiceDetail recordInvoiceDetail : detailList) { for (RecordInvoiceDetail recordInvoiceDetail : detailList) {
recordInvoiceDetail.setUuid(invoiceCode + invoiceNo); recordInvoiceDetail.setUuid(invoiceCode + invoiceNo);
recordInvoiceDetail.setInvoiceCode(invoiceCode); recordInvoiceDetail.setInvoiceCode(invoiceCode);

@ -633,7 +633,6 @@ public class SignDataServiceImpl extends MpBaseServiceImpl<TdxInvoiceDao, Invoic
int insert = tDxrecordInvoiceDao.insert(insertRecord); int insert = tDxrecordInvoiceDao.insert(insertRecord);
if (insert > 0) { if (insert > 0) {
List<RecordInvoiceDetail> detailList = getRecordInvoiceDetail(checkResult); List<RecordInvoiceDetail> detailList = getRecordInvoiceDetail(checkResult);
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
invoiceDetailDao invoiceDetailDao
.delete(new QueryWrapper<RecordInvoiceDetail>().eq("uuid", uuid)); .delete(new QueryWrapper<RecordInvoiceDetail>().eq("uuid", uuid));
for (RecordInvoiceDetail detailInfo : detailList) { for (RecordInvoiceDetail detailInfo : detailList) {

@ -30,7 +30,6 @@ public class SignInvoiceDetailServiceImpl extends MpBaseServiceImpl<SignRecordIn
@Override @Override
public void saveInvoiceDetail(List<TDxRecordInvoiceDetail> details, String dbName) { public void saveInvoiceDetail(List<TDxRecordInvoiceDetail> details, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
this.insertDetail(details); this.insertDetail(details);
} }
@ -46,7 +45,6 @@ public class SignInvoiceDetailServiceImpl extends MpBaseServiceImpl<SignRecordIn
@Override @Override
public boolean deleteDetail(String uuid, String dbName) { public boolean deleteDetail(String uuid, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
return this.removeDetail(uuid); return this.removeDetail(uuid);
} }

@ -608,7 +608,6 @@ public class SignSaveInvoiceInfoServiceImpl extends MpBaseServiceImpl<SignRecord
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
vehicleSaleInfo = signJdcService.getOne(queryWrapper); vehicleSaleInfo = signJdcService.getOne(queryWrapper);
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>(); QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
queryWrapper.orderByAsc("detail_no"); queryWrapper.orderByAsc("detail_no");

@ -803,7 +803,6 @@ public class TDxInvoiceReimburseServiceImpl extends ServiceImpl<TDxInvoiceReimbu
} }
if (recordInvoiceDetails != null && recordInvoiceDetails.size() > 0) { if (recordInvoiceDetails != null && recordInvoiceDetails.size() > 0) {
for (RecordInvoiceDetail detail : recordInvoiceDetails) { for (RecordInvoiceDetail detail : recordInvoiceDetails) {
DynamicContextHolder.push(deptEntity.getDbName() + DbConstant.DETAIL_WRITE);
if(StringUtils.isNotBlank(detail.getTaxRate())){ if(StringUtils.isNotBlank(detail.getTaxRate())){
if(detail.getTaxRate().contains("%")){ if(detail.getTaxRate().contains("%")){
detail.setTaxRate(detail.getTaxRate().replace("%","")); detail.setTaxRate(detail.getTaxRate().replace("%",""));

@ -544,7 +544,6 @@ public class MyThread extends Thread {
public void insertInvoiceDetail(String invoiceCode, String invoiceNo, List<RecordInvoiceDetail> detailList) public void insertInvoiceDetail(String invoiceCode, String invoiceNo, List<RecordInvoiceDetail> detailList)
throws Exception { throws Exception {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
invoiceDetailDao.delete(new QueryWrapper<RecordInvoiceDetail>().eq("uuid", invoiceCode + invoiceNo)); invoiceDetailDao.delete(new QueryWrapper<RecordInvoiceDetail>().eq("uuid", invoiceCode + invoiceNo));
for (RecordInvoiceDetail recordInvoiceDetail : detailList) { for (RecordInvoiceDetail recordInvoiceDetail : detailList) {
recordInvoiceDetail.setUuid(invoiceCode + invoiceNo); recordInvoiceDetail.setUuid(invoiceCode + invoiceNo);

@ -547,7 +547,6 @@ public class ExtInvoicePoolServiceImpl extends MpBaseServiceImpl<ExtInvoicePoolD
@Override @Override
public Object incentiveFlagList(String dbName) { public Object incentiveFlagList(String dbName) {
JSONObject json = new JSONObject(); JSONObject json = new JSONObject();
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
List<String> incentiveFlagList = super.baseMapper.listIncentiveFlag(); List<String> incentiveFlagList = super.baseMapper.listIncentiveFlag();
json.put("incentiveFlagList", incentiveFlagList); json.put("incentiveFlagList", incentiveFlagList);
return super.responseResult(json); return super.responseResult(json);

@ -130,7 +130,6 @@ public class PassengerReimbursementSystemServiceImpl
@Override @Override
public void addInvoiceDetails(List<TdxRecordInvoiceDetail> tdxRecordInvoiceDetailList, String uuid, String dbName, public void addInvoiceDetails(List<TdxRecordInvoiceDetail> tdxRecordInvoiceDetailList, String uuid, String dbName,
String invoiceCode, String incoiceNo) { String invoiceCode, String incoiceNo) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
for (TdxRecordInvoiceDetail invoiceDetail : tdxRecordInvoiceDetailList) { for (TdxRecordInvoiceDetail invoiceDetail : tdxRecordInvoiceDetailList) {
invoiceDetail.setUuid(uuid); invoiceDetail.setUuid(uuid);
invoiceDetail.setInvoiceCode(invoiceCode); invoiceDetail.setInvoiceCode(invoiceCode);
@ -186,7 +185,6 @@ public class PassengerReimbursementSystemServiceImpl
@Override @Override
public void deleteInvoiceDetails(String uuid, String dbName) { public void deleteInvoiceDetails(String uuid, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
passengerReimbursementSystemDao.deleteInvoiceDetails(uuid); passengerReimbursementSystemDao.deleteInvoiceDetails(uuid);
} }

@ -31,7 +31,6 @@ public class InvoiceDetailImpl extends MpBaseServiceImpl<TDxRecordInvoiceDetailD
@Override @Override
public void saveInvoiceDetail(List<TDxRecordInvoiceDetail> details, String dbName) { public void saveInvoiceDetail(List<TDxRecordInvoiceDetail> details, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
this.insertDetail(details); this.insertDetail(details);
} }
@ -43,7 +42,6 @@ public class InvoiceDetailImpl extends MpBaseServiceImpl<TDxRecordInvoiceDetailD
@Override @Override
public boolean deleteDetail(String uuid, String dbName) { public boolean deleteDetail(String uuid, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
return this.removeDetail(uuid); return this.removeDetail(uuid);
} }

@ -457,7 +457,6 @@ public class SaveInvoiceInfoServiceImpl extends MpBaseServiceImpl<TDxRecordInvoi
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
vehicleSaleInfo = jdcService.getOne(queryWrapper); vehicleSaleInfo = jdcService.getOne(queryWrapper);
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>(); QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
queryWrapper.orderByAsc("detail_no"); queryWrapper.orderByAsc("detail_no");

@ -3150,7 +3150,6 @@ public class SignFpqsServiceImpl extends MpBaseServiceImpl<SignRecordInvoiceDao,
// 保存底账明细表数据 // 保存底账明细表数据
try { try {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
// 删除已存在的数据,防止数据重复 // 删除已存在的数据,防止数据重复
signInvoiceDetailService signInvoiceDetailService
.remove(new UpdateWrapper<TDxRecordInvoiceDetail>().eq("uuid", invoice.getUuid())); .remove(new UpdateWrapper<TDxRecordInvoiceDetail>().eq("uuid", invoice.getUuid()));

@ -32,7 +32,6 @@ public class SignInvoiceDetailServiceImpl extends MpBaseServiceImpl<SignRecordIn
@Override @Override
public void saveInvoiceDetail(List<TDxRecordInvoiceDetail> details, String dbName) { public void saveInvoiceDetail(List<TDxRecordInvoiceDetail> details, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
this.insertDetail(details); this.insertDetail(details);
} }
@ -48,7 +47,6 @@ public class SignInvoiceDetailServiceImpl extends MpBaseServiceImpl<SignRecordIn
@Override @Override
public boolean deleteDetail(String uuid, String dbName) { public boolean deleteDetail(String uuid, String dbName) {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_WRITE);
return this.removeDetail(uuid); return this.removeDetail(uuid);
} }

@ -478,7 +478,6 @@ public class SignSaveInvoiceInfoServiceImpl extends MpBaseServiceImpl<SignRecord
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
vehicleSaleInfo = signJdcService.getOne(queryWrapper); vehicleSaleInfo = signJdcService.getOne(queryWrapper);
} else { } else {
DynamicContextHolder.push(dbName + DbConstant.DETAIL_READ);
QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>(); QueryWrapper<TDxRecordInvoiceDetail> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("uuid", uuid); queryWrapper.eq("uuid", uuid);
queryWrapper.orderByAsc("detail_no"); queryWrapper.orderByAsc("detail_no");

Loading…
Cancel
Save