|
@@ -15,7 +15,7 @@ import com.fjhx.file.service.FileInfoService;
|
|
|
import com.obs.services.ObsClient;
|
|
|
import com.obs.services.model.PostSignatureRequest;
|
|
|
import com.obs.services.model.PostSignatureResponse;
|
|
|
-import com.ruoyi.common.constant.DatasourceConstant;
|
|
|
+import com.ruoyi.common.constant.BaseSourceConstant;
|
|
|
import com.ruoyi.common.core.domain.BaseIdPo;
|
|
|
import com.ruoyi.common.exception.ServiceException;
|
|
|
import com.ruoyi.common.utils.wrapper.IWrapper;
|
|
@@ -140,7 +140,7 @@ public class FileInfoServiceImpl extends ServiceImpl<FileInfoMapper, FileInfo> i
|
|
|
* @param businessType 业务文件类型
|
|
|
*/
|
|
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
|
|
- @DS(DatasourceConstant.BASE)
|
|
|
+ @DS(BaseSourceConstant.BASE)
|
|
|
@Override
|
|
|
public void saveFile(List<ObsFile> obsFileList, Long businessId, Integer businessType) {
|
|
|
// 切换到从库
|
|
@@ -165,7 +165,7 @@ public class FileInfoServiceImpl extends ServiceImpl<FileInfoMapper, FileInfo> i
|
|
|
* @param businessType 业务文件类型
|
|
|
*/
|
|
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
|
|
- @DS(DatasourceConstant.BASE)
|
|
|
+ @DS(BaseSourceConstant.BASE)
|
|
|
@Override
|
|
|
public void editFile(List<ObsFile> obsFileList, Long businessId, Integer businessType) {
|
|
|
if (obsFileList == null || obsFileList.size() == 0) {
|
|
@@ -187,7 +187,7 @@ public class FileInfoServiceImpl extends ServiceImpl<FileInfoMapper, FileInfo> i
|
|
|
* @param businessType 业务文件类型
|
|
|
*/
|
|
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
|
|
- @DS(DatasourceConstant.BASE)
|
|
|
+ @DS(BaseSourceConstant.BASE)
|
|
|
@Override
|
|
|
public void removeFile(Long businessId, Integer businessType) {
|
|
|
this.remove(q -> q
|
|
@@ -201,7 +201,7 @@ public class FileInfoServiceImpl extends ServiceImpl<FileInfoMapper, FileInfo> i
|
|
|
* @param businessId 业务id
|
|
|
*/
|
|
|
@Transactional(propagation = Propagation.REQUIRES_NEW)
|
|
|
- @DS(DatasourceConstant.BASE)
|
|
|
+ @DS(BaseSourceConstant.BASE)
|
|
|
@Override
|
|
|
public void removeFile(Long businessId) {
|
|
|
this.remove(q -> q.eq(FileInfo::getBusinessId, businessId));
|