fix(asms): 同步问题调整
This commit is contained in:
+6
-2
@@ -207,7 +207,7 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
|
|||||||
|
|
||||||
lawsAsmsOpenApiList.forEach(lawsAsmsOpenApi -> {
|
lawsAsmsOpenApiList.forEach(lawsAsmsOpenApi -> {
|
||||||
|
|
||||||
Map<String, String> map = null;
|
Map<String, String> map = new HashMap<>();
|
||||||
if (StringUtils.isNotBlank(lawsAsmsOpenApi.getQueryParamJson())) {
|
if (StringUtils.isNotBlank(lawsAsmsOpenApi.getQueryParamJson())) {
|
||||||
map = (Map<String, String>) JSON.parse(lawsAsmsOpenApi.getQueryParamJson());
|
map = (Map<String, String>) JSON.parse(lawsAsmsOpenApi.getQueryParamJson());
|
||||||
}
|
}
|
||||||
@@ -573,7 +573,9 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
|
|||||||
queryWrapper1.eq(OSSFile::getStandardFileType, "publish_of_original");
|
queryWrapper1.eq(OSSFile::getStandardFileType, "publish_of_original");
|
||||||
queryWrapper1.like(OSSFile::getFileName, ".docx");
|
queryWrapper1.like(OSSFile::getFileName, ".docx");
|
||||||
OSSFile ossFile = ossFileService.getOne(queryWrapper1);
|
OSSFile ossFile = ossFileService.getOne(queryWrapper1);
|
||||||
|
if (Objects.isNull(ossFile)){
|
||||||
|
return;
|
||||||
|
}
|
||||||
SarFileSplitInfoEO sarFileSplitInfoEO = new SarFileSplitInfoEO();
|
SarFileSplitInfoEO sarFileSplitInfoEO = new SarFileSplitInfoEO();
|
||||||
sarFileSplitInfoEO.setStandardId(lawsDomesticStandard.getId());
|
sarFileSplitInfoEO.setStandardId(lawsDomesticStandard.getId());
|
||||||
sarFileSplitInfoEO.setSerialNumber(lawsDomesticStandard.getStandardNumber());
|
sarFileSplitInfoEO.setSerialNumber(lawsDomesticStandard.getStandardNumber());
|
||||||
@@ -585,6 +587,8 @@ public class LawsAsmsOpenApiServiceImpl extends ServiceImpl<LawsAsmsOpenApiMappe
|
|||||||
sarFileSplitInfoEO.setCreateTime(getSimpleDate2(eMap.get("createTime")));
|
sarFileSplitInfoEO.setCreateTime(getSimpleDate2(eMap.get("createTime")));
|
||||||
sarFileSplitInfoEO.setUpdateTime(getSimpleDate2(eMap.get("updateTime")));
|
sarFileSplitInfoEO.setUpdateTime(getSimpleDate2(eMap.get("updateTime")));
|
||||||
sarFileSplitInfoEO.setIsAsmsImport("1");
|
sarFileSplitInfoEO.setIsAsmsImport("1");
|
||||||
|
sarFileSplitInfoEO.setAuthor("云平台");
|
||||||
|
sarFileSplitInfoEO.setSplitResult("成功");
|
||||||
|
|
||||||
sarFileSplitInfoService.save(sarFileSplitInfoEO);
|
sarFileSplitInfoService.save(sarFileSplitInfoEO);
|
||||||
});
|
});
|
||||||
|
|||||||
+1
@@ -341,6 +341,7 @@ public class SynchronizationAsmsService {
|
|||||||
sarFileSplitInfoEO.setUpdateTime(getSimpleDate2(eMap.get("updateTime")));
|
sarFileSplitInfoEO.setUpdateTime(getSimpleDate2(eMap.get("updateTime")));
|
||||||
sarFileSplitInfoEO.setIsAsmsImport("1");
|
sarFileSplitInfoEO.setIsAsmsImport("1");
|
||||||
sarFileSplitInfoEO.setAuthor("云平台");
|
sarFileSplitInfoEO.setAuthor("云平台");
|
||||||
|
sarFileSplitInfoEO.setSplitResult("成功");
|
||||||
|
|
||||||
sarFileSplitInfoEO.setId(UUIDUtils.randomUUID20());
|
sarFileSplitInfoEO.setId(UUIDUtils.randomUUID20());
|
||||||
|
|
||||||
|
|||||||
-3
@@ -16,10 +16,7 @@ import org.springframework.stereotype.Component;
|
|||||||
import org.springframework.web.client.RestTemplate;
|
import org.springframework.web.client.RestTemplate;
|
||||||
|
|
||||||
import java.io.ByteArrayInputStream;
|
import java.io.ByteArrayInputStream;
|
||||||
import java.io.File;
|
|
||||||
import java.io.IOException;
|
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
||||||
import java.nio.file.Files;
|
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|||||||
-1
@@ -1,6 +1,5 @@
|
|||||||
package com.jero.modules.laws.documenttool.controller;
|
package com.jero.modules.laws.documenttool.controller;
|
||||||
|
|
||||||
import cn.hutool.core.util.PageUtil;
|
|
||||||
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
||||||
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
||||||
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
|
||||||
|
|||||||
+3
-1
@@ -1360,10 +1360,12 @@ public class DocumentSplitServiceImpl implements IDocumentSplitService {
|
|||||||
}
|
}
|
||||||
LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
LoginUser loginUser = (LoginUser) SecurityUtils.getSubject().getPrincipal();
|
||||||
// 发布的只有自己可见,发布的数据所有人可见
|
// 发布的只有自己可见,发布的数据所有人可见
|
||||||
|
String roleIds = loginUser.getRoleIds();
|
||||||
queryWrapper.and(qw ->
|
queryWrapper.and(qw ->
|
||||||
qw.and(qwi -> qwi.eq(SPLIT_STATUS, DocumentSplitCommon.SPLIT_STATUS1)
|
qw.and(qwi -> qwi.eq(SPLIT_STATUS, DocumentSplitCommon.SPLIT_STATUS1)
|
||||||
.eq("author", loginUser.calcNameWorkNo()))
|
.eq("author", loginUser.calcNameWorkNo()))
|
||||||
.or().eq(SPLIT_STATUS, DocumentSplitCommon.SPLIT_STATUS2));
|
.or().eq(SPLIT_STATUS, DocumentSplitCommon.SPLIT_STATUS2)
|
||||||
|
.or().eq(roleIds.contains("admin"), "author", "云平台"));
|
||||||
// 逻辑删除
|
// 逻辑删除
|
||||||
queryWrapper.eq("del_flag", 0);
|
queryWrapper.eq("del_flag", 0);
|
||||||
// 排序
|
// 排序
|
||||||
|
|||||||
Reference in New Issue
Block a user