修改稽查查询不走bi数据源问题

src/main/java/com/sfa/operation/domain/risk/dao/IRiskStoreTaskDao.java

 package com.sfa.operation.domain.risk.dao;
 
-import com.sfa.common.core.domain.dao.BaseDao;
 import com.sfa.common.core.web.domain.PageInfo;
 import com.sfa.operation.domain.risk.entity.RiskStoreTask;
 import com.sfa.operation.domain.risk.wq.RiskStoreTaskWq;
@@ -11,7 +10,7 @@ import com.sfa.operation.pojo.risk.response.RiskStoreTaskDto;
  * @date : 2025-08-27 20
  * @describe :
  */
-public interface IRiskStoreTaskDao  extends BaseDao<RiskStoreTask> {
+public interface IRiskStoreTaskDao  /*extends BaseDao<RiskStoreTask> */{
     RiskStoreTaskDto insert(RiskStoreTaskDto taskDto);
     PageInfo page(RiskStoreTaskWq wq);
     RiskStoreTaskDto updateInspectStore(RiskStoreTaskDto taskDto);
@@ -21,4 +20,6 @@ public interface IRiskStoreTaskDao  extends BaseDao<RiskStoreTask> {
     RiskStoreTaskDto.RiskStoreTaskDetailDto updateStoreDetail(RiskStoreTaskDto.RiskStoreTaskDetailDto riskStoreTaskDetailDto);
 
     void deleteStoreDetail(Long rstdId);
+
+    RiskStoreTask findById(Long rstId);
 }

src/main/java/com/sfa/operation/domain/risk/dao/impl/RiskStoreTaskDaoImpl.java

@@ -5,7 +5,6 @@ import com.alibaba.fastjson2.JSONObject;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.sfa.common.core.domain.dao.impl.BaseDaoImpl;
 import com.sfa.common.core.enums.ECode;
 import com.sfa.common.core.exception.WXLSQLException;
 import com.sfa.common.core.utils.bean.BeanUtils;
@@ -37,11 +36,13 @@ import java.util.stream.Collectors;
  */
 @DS("bi")
 @Repository
-public class RiskStoreTaskDaoImpl extends BaseDaoImpl<RiskStoreTask> implements IRiskStoreTaskDao {
+public class RiskStoreTaskDaoImpl /*extends BaseDaoImpl<RiskStoreTask,RiskStoreTaskMapper>*/ implements IRiskStoreTaskDao {
     @Autowired
     private RiskStoreTaskMapper riskStoreTaskMapper;
     @Autowired
     private RiskStoreTaskDetailMapper riskStoreTaskDetailMapper;
+
+
     @Override
     public RiskStoreTaskDto insert(RiskStoreTaskDto taskDto) {
         try {
@@ -126,6 +127,12 @@ public class RiskStoreTaskDaoImpl extends BaseDaoImpl<RiskStoreTask> implements
         updateDetail(detailDo.getRstId());
     }
 
+    @Override
+    public RiskStoreTask findById(Long rstId) {
+        // 获取任务
+        return riskStoreTaskMapper.selectById(rstId);
+    }
+
     private LambdaQueryWrapper<RiskStoreTask> buildWq(RiskStoreTaskWq wq) {
         LambdaQueryWrapper<RiskStoreTask> wqWrapper = new LambdaQueryWrapper<>();
         if (Objects.nonNull(wq.getRstId())){
@@ -277,5 +284,8 @@ public class RiskStoreTaskDaoImpl extends BaseDaoImpl<RiskStoreTask> implements
     }
 
 
-
+//    @Override
+//    public RiskStoreTaskMapper getBaseMapper() {
+//        return this.riskStoreTaskMapper;
+//    }
 }

src/main/java/com/sfa/operation/service/risk/impl/RiskStoreTaskCoreServiceImpl.java

@@ -13,7 +13,6 @@ import com.sfa.operation.service.risk.IRiskStoreCoreService;
 import com.sfa.operation.service.risk.IRiskStoreTaskCoreService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Transactional;
 
 import java.util.Objects;
 
@@ -44,7 +43,6 @@ public class RiskStoreTaskCoreServiceImpl implements IRiskStoreTaskCoreService {
         riskStoreTaskDao.deleteStoreDetail(rstdId);
     }
 
-    @Transactional(rollbackFor = Exception.class)
     @Override
     public RiskStoreTaskDto saveOrUpdateStore(RiskStoreTaskVo riskStoreTaskVo) {
         // 保存来源勤策的门店
@@ -61,7 +59,7 @@ public class RiskStoreTaskCoreServiceImpl implements IRiskStoreTaskCoreService {
             insertTaskDto.setCreateEmpNo(riskStoreTaskVo.getOperEmpNo());
             taskDto = riskStoreTaskDao.insert(insertTaskDto);
         } else {
-            RiskStoreTask riskStoreTask = riskStoreTaskDao.selectById(riskStoreTaskVo.getRstId());
+            RiskStoreTask riskStoreTask = riskStoreTaskDao.findById(riskStoreTaskVo.getRstId());
             if (Objects.isNull(riskStoreTask)) {
                 throw new ServiceException("售点任务不存在");
             }