ariesy 去掉切换数据源代码

dxhy-customs/src/main/java/com/dxhy/customs/controller/CustomsRecordRzdkController.java

@@ -231,8 +231,6 @@ public class CustomsRecordRzdkController extends AbstractController {
                     //如果是空，撤销成功，删除异常表中对应数据
                     if(StringUtils.isEmpty(jsonObject.getString("message"))){
                         log.info("海关缴款书撤销抵扣或不抵扣，成功后，删除lqcustomFpycxx表数据");
-                        DynamicContextHolder
-                                .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
                         for (String idstr : dto.getIds()) {
                             TdxCustomsRecord byId = customsRecordDao.selectById(idstr);
                             LambdaQueryWrapper<TdxLqDkCustomFpycxx> fpycxxWrapper = new LambdaQueryWrapper<>();

dxhy-customs/src/main/java/com/dxhy/customs/service/impl/CustomsRecordDkrzServiceImpl.java

@@ -88,8 +88,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
      */
     @Override
     public String querySgByPage(Page page, TdxCustomsRecordModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -265,8 +263,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
         sb3.append("以下税号本月发票可认证总税额超限：税号\n");
 
         // 1.查询数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<TdxCustomsRecord> records = new ArrayList<>();
         // 2.校验
         List<String> dkList = new ArrayList<>();
@@ -424,9 +420,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
             }
         }
         // 3.更新数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_WRITE);
-
         for (TdxCustomsRecord record : records) {
             total++;
             hjse = hjse.add(new BigDecimal(record.getTaxAmount()));
@@ -880,8 +873,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
 
     @Override
     public String queryBdkByPage(Page page, TdxCustomsRecordModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -1064,8 +1055,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
         sb3.append("以下缴款书的税款所属期不是当前属期：发票\n ");
 
         // 1.查询数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<TdxCustomsRecord> records = new ArrayList<>();
         // 2.校验
         List<CustomsLog> logList = new ArrayList<>();
@@ -1142,8 +1131,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
             }
         }
         // 3.更新数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_WRITE);
         for (TdxCustomsRecord record : records) {
             total++;
             hjse = hjse.add(new BigDecimal(record.getTaxAmount()));
@@ -1172,8 +1159,6 @@ public class CustomsRecordDkrzServiceImpl extends MpBaseServiceImpl<CustomsRecor
 
     @Override
     public String queryRzcxByPage(Page page, TdxCustomsRecordModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
         List<Business> businesses = userInfo.getBusiness();
 

dxhy-customs/src/main/java/com/dxhy/customs/service/impl/CustomsSignServiceImpl.java

@@ -138,8 +138,6 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
 
     @Override
     public String batchSign(String costomsInfo, UserInfo userInfo) {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         JSONObject jsonObject = JSONObject.parseObject(costomsInfo);
         JSONArray jsonArray = jsonObject.getJSONArray("ids");
         String businessCode = jsonObject.getString("businessCode");
@@ -317,15 +315,9 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
                 customs.setQsDate(DateUtils.getSqlDateLong());
                 customs.setQsType(QsfsEnum.DRQS.getQsfsDm());
                 if (tDxCustoms == null) {
-                    DynamicContextHolder
-                        .push(StringUtils.defaultString(ObjectUtil.fixNull(userInfo.getDbName()), "business")
-                            + DbConstant.BUSINESS_WRITE);
                     customsService.save(customs);
                 } else {
                     customs.setId(tDxCustoms.getId());
-                    DynamicContextHolder
-                        .push(StringUtils.defaultString(ObjectUtil.fixNull(userInfo.getDbName()), "business")
-                            + DbConstant.BUSINESS_WRITE);
                     customsService.updateById(customs);
                 }
                 signToVO(customs, param, true);
@@ -579,8 +571,6 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
 
     @Override
     public String cancelSign(List<String> idList, UserInfo userInfo) {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         int i = 0, fail = 0;
         if (idList != null && idList.size() > 0) {
             List<CustomsLog> logList = new ArrayList<>();
@@ -623,8 +613,6 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
 
     @Override
     public String changeBusiness(TdxCustomsRecordDTO entity, UserInfo userInfo) {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<String> idList = entity.getIds();
         if (idList != null && idList.size() > 0) {
             for (String id : idList) {
@@ -656,8 +644,6 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
 
     @Override
     public String changeRemark(TdxCustomsRecordDTO entity, UserInfo userInfo) {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<String> idList = entity.getIds();
         if (idList != null && idList.size() > 0) {
             for (String id : idList) {
@@ -674,8 +660,6 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
 
     @Override
     public String scanBatchSign(List<String> idList, UserInfo userInfo) {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         int i = 0, fail = 0;
         List<String> gfshAll = UserInfoUtil.getGfshAll(userInfo.getOrg());
         if (idList != null && idList.size() > 0) {
@@ -1231,10 +1215,6 @@ public class CustomsSignServiceImpl extends MpBaseServiceImpl<CustomsRecordDao,
                     customs.setQsDate(DateUtils.getSqlDateLong());
                     customs.setQsType(QsfsEnum.DRQS.getQsfsDm());
                     if (tDxCustoms == null) {
-
-                        DynamicContextHolder
-                            .push(StringUtils.defaultString(ObjectUtil.fixNull(userInfo.getDbName()), "business")
-                                + DbConstant.BUSINESS_WRITE);
                         customsService.save(customs);
                     }
                     signToVO(customs, param, true);

dxhy-export-domestic/src/main/java/com/dxhy/domestic/service/ckzrz/impl/DomesticExportCustomsCkServiceImpl.java

@@ -68,8 +68,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
 
     @Override
     public String querySgByPage(Page page, TdxExportCustomsModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -206,8 +204,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
         sb3.append("以下税号本月缴款书可认证总税额超限：税号\n");
 
         // 1.查询数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<TdxExportCustoms> records = new ArrayList<>();
         // 2.校验
         List<String> dkList = new ArrayList<>();
@@ -360,8 +356,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
             }
         }
         // 3.更新数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_WRITE);
 
         if (!flag && !flag1 && !flag2 && !flag3) {
             for (TdxExportCustoms record : records) {
@@ -403,8 +397,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
 
     @Override
     public String queryBdkByPage(Page page, TdxExportCustomsModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -525,8 +517,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
 
     @Override
     public String queryRzcxByPage(Page page, TdxExportCustomsModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -672,8 +662,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
         sb3.append("以下缴款书的税款所属期不是当前属期：缴款书号\n ");
 
         // 1.查询数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<TdxExportCustoms> records = new ArrayList<>();
         // 2.校验
         List<String> dkList = new ArrayList<>();
@@ -751,8 +739,6 @@ public class DomesticExportCustomsCkServiceImpl extends ServiceImpl<DomesticExpo
             }
         }
         // 3.更新数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_WRITE);
         for (TdxExportCustoms record : records) {
 
             total++;

dxhy-export-domestic/src/main/java/com/dxhy/domestic/service/ckzrz/impl/DomesticExportInvoiceCkServiceImpl.java

@@ -61,8 +61,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
 
     @Override
     public String queryVatSgrz(Page page, TdxExportInvoiceModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -184,8 +182,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
         sb3.append("以下税号本月发票可认证总税额超限：税号\n");
 
         // 1.查询数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<TdxExportInvoice> records = new ArrayList<>();
         // 2.校验
         List<String> dkList = new ArrayList<>();
@@ -336,8 +332,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
             }
         }
         // 3.更新数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_WRITE);
         if (!flag && !flag1 && !flag2 && !flag3) {
             for (TdxExportInvoice record : records) {
 
@@ -377,8 +371,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
 
     @Override
     public String queryVatBdk(Page page, TdxExportInvoiceModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         JSONObject tabulateMenu = tabulateRedisService.getTabulateMenu(dto.getCompany(), dto.getMenuId());
@@ -498,8 +490,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
 
     @Override
     public String queryVatRzcx(Page page, TdxExportInvoiceModelDTO dto, UserInfo userInfo) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, userInfo);
 
         ResultData<Object> resultData = new ResultData<>();
@@ -636,8 +626,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
         sb3.append("以下发票的税款所属期不是当前属期：发票\n ");
 
         // 1.查询数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_READ);
         List<TdxExportInvoice> records = new ArrayList<>();
         List<InvoiceLog> logList = new ArrayList<>();
         // 2.校验
@@ -717,8 +705,6 @@ public class DomesticExportInvoiceCkServiceImpl extends ServiceImpl<DomesticExpo
             }
         }
         // 3.更新数据
-        DynamicContextHolder
-            .push(StringUtils.defaultString(userInfo.getDbName(), "business") + DbConstant.BUSINESS_WRITE);
         for (TdxExportInvoice record : records) {
             total++;
             hjje = hjje.add(record.getExportAmount());

dxhy-export-domestic/src/main/java/com/dxhy/domestic/service/count/impl/DomesticCustomsExportCountServiceImpl.java

@@ -41,8 +41,6 @@ public class DomesticCustomsExportCountServiceImpl extends MpBaseServiceImpl<Dom
 
     @Override
     public String queryExportCustomsList(Page page, TdxExportCustomsModelDTO dto) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(dto.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, dto.getUserInfo());
 
         ResultData<Object> resultData = new ResultData<>();

dxhy-export-domestic/src/main/java/com/dxhy/domestic/service/count/impl/DomesticInvoiceExportCountServiceImpl.java

@@ -48,8 +48,6 @@ public class DomesticInvoiceExportCountServiceImpl extends MpBaseServiceImpl<Dom
 
     @Override
     public String queryExportInvoiceList(Page page, TdxExportInvoiceModelDTO dto) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(dto.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         dto.setParam(page, dto.getUserInfo());
 
         ResultData<Object> resultData = new ResultData<>();

dxhy-export-domestic/src/main/java/com/dxhy/domestic/service/customsrefund/impl/DomesticCustomsRefundServiceImpl.java

@@ -70,8 +70,6 @@ public class DomesticCustomsRefundServiceImpl extends MpBaseServiceImpl<Domestic
 
     @Override
     public String queryManualConfirmList(Page page, BaseCustomsVO entity) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(entity.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         entity.setParam(page);
         ResultData<Object> resultData = new ResultData<>();
 
@@ -240,8 +238,6 @@ public class DomesticCustomsRefundServiceImpl extends MpBaseServiceImpl<Domestic
 
     @Override
     public String importConfirmList(BaseCustomsVO reqVO) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(reqVO.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         // 需要设置返回列表标题时调用
         // JSONObject json = super.setTitleList(DicProp.CUSTOMS_REFUND_IMPORT_CONFIRM_LIST_TITLE,
         // DicProp.CUSTOMS_REFUND_IMPORT_CONFIRM_LIST_PROP);
@@ -470,8 +466,6 @@ public class DomesticCustomsRefundServiceImpl extends MpBaseServiceImpl<Domestic
 
     @Override
     public String queryConfirmList(Page page, BaseCustomsVO entity) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(entity.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         entity.setParam(page);
         double amountTotal = 0.0;
         ResultData resultData = new ResultData();
@@ -545,8 +539,6 @@ public class DomesticCustomsRefundServiceImpl extends MpBaseServiceImpl<Domestic
 
     @Override
     public String queryRefundCountList(Page page, BaseCustomsVO entity) throws Exception {
-        DynamicContextHolder
-            .push(StringUtils.defaultString(entity.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         if ("99".equals(entity.getGfsh())) {
             entity.setGfsh(null);
             entity.setGfTaxNo(UserInfoUtil.getGfshAll(entity.getUserInfo().getOrg()));
@@ -582,8 +574,6 @@ public class DomesticCustomsRefundServiceImpl extends MpBaseServiceImpl<Domestic
     @Override
     public String queryRefundCountDetailPage(Page page, BaseCustomsVO entity) throws Exception {
         // List<DictdetaModel> fplxModels = dictdetaServcice.selectDictdeta("INVOICE_TYPE");
-        DynamicContextHolder
-            .push(StringUtils.defaultString(entity.getUserInfo().getDbName(), "business") + DbConstant.BUSINESS_READ);
         Page<Map> result = this.baseMapper.queryRefundCountDetailPage(page, entity);
         if (CollectionUtils.isEmpty(result.getRecords()) || result.getRecords().size() < 4) {
             if (CollectionUtils.isEmpty(result.getRecords())) {