FT/foton-slrs-system-rest
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

临时手动更新ALL标准数据索引

Browse Source
This commit is contained in:
liyawei
2022-12-08 14:41:18 +08:00
parent 372408ac30
commit 95884095fb
2 changed files with 850 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files
adc-da-slrs/src/main/java/com/adc/da/search/ResetSearchCenterController.java
+55 -43
View File
@@ -4,6 +4,7 @@ import com.adc.da.base.web.BaseController;
import com.adc.da.search.bean.SearchCenter;
import com.adc.da.search.bean.SearchFields;
import com.adc.da.search.server.ResetSearchCenterService;
import com.adc.da.search.server.ResetSearchCenterServiceTemp;
import com.adc.da.slrs.sarLawsInfo.page.SarLawsInfoEOPage;
import com.adc.da.slrs.sarLawsStandInfo.entity.SarLawsStandInfoPage;
import com.adc.da.slrs.sarStandardsInfo.entity.SarBussionessStandEOPage;
@@ -41,20 +42,20 @@ public class ResetSearchCenterController extends BaseController<Map<String, Obje
}
@ApiOperation(value = "|Search|文本条件搜索更新标准数据索引")
@PostMapping(value="/resetALLSearchCenterToSearch")
public ResponseMessage resetALLSearchCenterToSearch(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/resetALLSearchCenterToSearch")
public ResponseMessage resetALLSearchCenterToSearch(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
return resetSearchCenterService.resetALLSearchCenterToSearch(searchCenter);
}
@ApiOperation(value = "|SearchCenter|重新创建ALL标准数据索引")
@PostMapping(value="/resetALLSearchCenter")
public ResponseMessage resetALLSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/resetALLSearchCenter")
public ResponseMessage resetALLSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
return resetSearchCenterService.resetALLSearchCenter(searchCenter);
@@ -62,10 +63,10 @@ public class ResetSearchCenterController extends BaseController<Map<String, Obje
@ApiOperation(value = "|SearchCenter|重新创建ALL标准数据索引")
@PostMapping(value="/resetALLSearchCenterForExits")
public ResponseMessage resetALLSearchCenterForExits(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/resetALLSearchCenterForExits")
public ResponseMessage resetALLSearchCenterForExits(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
return resetSearchCenterService.resetALLSearchCenterForExits(searchCenter);
@@ -73,27 +74,27 @@ public class ResetSearchCenterController extends BaseController<Map<String, Obje
@ApiOperation(value = "|SearchCenter|手动重新创建（---7天内---）ALL标准数据索引（凌晨有自动程序会跑）")
@PostMapping(value="/manualResetALLSearchCenter")
public ResponseMessage manualResetALLSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/manualResetALLSearchCenter")
public ResponseMessage manualResetALLSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
return resetSearchCenterService.syncResetALLSearchCenter(searchCenter);
}
@ApiOperation(value = "|SearchCenter|手动重新创建 ALL标准数据索引（凌晨有自动程序会跑）")
@PostMapping(value="/manualResetALLSearchCenter1")
public ResponseMessage manualResetALLSearchCenter1(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/manualResetALLSearchCenter1")
public ResponseMessage manualResetALLSearchCenter1(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
return resetSearchCenterService.syncResetALLSearchCenter1(searchCenter);
}
private ResponseMessage verifySearchCenter(SearchCenter searchCenter) {
if(searchCenter.getExecType() == null || "".equals(searchCenter.getExecType())){
if (searchCenter.getExecType() == null || "".equals(searchCenter.getExecType())) {
return Result.error("执行参数 ALL 存在更新 不存在新增 ,UPD 只 更新存在 es 里的标准 ,ADD 只新增不存在 es 的标准, DEL 只删除不存在标准库的数据");
}
@@ -101,66 +102,77 @@ public class ResetSearchCenterController extends BaseController<Map<String, Obje
}
@ApiOperation(value = "|SearchCenter|重新创建国内外标准数据索引")
@PostMapping(value="/resetAStandSearchCenter")
public ResponseMessage resetStandSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/resetAStandSearchCenter")
public ResponseMessage resetStandSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
SarStandardsInfoEOPage sarStandardsInfoEOPage = new SarStandardsInfoEOPage();
return resetSearchCenterService.resetStandSearchCenter(sarStandardsInfoEOPage,searchCenter);
return resetSearchCenterService.resetStandSearchCenter(sarStandardsInfoEOPage, searchCenter);
}
@ApiOperation(value = "|SearchCenter|重新创建国内外政策数据索引")
@PostMapping(value="/resetBLawsSearchCenter")
public ResponseMessage resetLawsSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/resetBLawsSearchCenter")
public ResponseMessage resetLawsSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
SarLawsStandInfoPage sarLawsInfoEOPage = new SarLawsStandInfoPage();
return resetSearchCenterService.resetLawsSearchCenter(sarLawsInfoEOPage,searchCenter);
SarLawsStandInfoPage sarLawsInfoEOPage = new SarLawsStandInfoPage();
return resetSearchCenterService.resetLawsSearchCenter(sarLawsInfoEOPage, searchCenter);
}
@ApiOperation(value = "|SearchCenter|重新创建企业标准数据索引")
@PostMapping(value="/resetCBussStandSearchCenter")
public ResponseMessage resetBussStandSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception{
@PostMapping(value = "/resetCBussStandSearchCenter")
public ResponseMessage resetBussStandSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null){
if (x != null) {
return x;
}
SarBussionessStandEOPage sarBussionessStandEOPage = new SarBussionessStandEOPage();
return resetSearchCenterService.resetBussStandSearchCenter(sarBussionessStandEOPage,searchCenter);
SarBussionessStandEOPage sarBussionessStandEOPage = new SarBussionessStandEOPage();
return resetSearchCenterService.resetBussStandSearchCenter(sarBussionessStandEOPage, searchCenter);
}
/**
* 根据资源ID对搜索中心数据进行处理
* @param standId
* @param dataType(STAND BUSS)
* @param dataType(STAND BUSS)
* @return
*/
@ApiOperation(value = "|SearchCenter|根据资源ID对搜索中心数据进行处理")
@GetMapping(value="/syncSearchCenterData")
@GetMapping(value = "/syncSearchCenterData")
public ResponseMessage syncSearchCenterData(@RequestParam("standId") String standId,
@RequestParam("dataType") String dataType){
if(StringUtils.isNotBlank(standId) && StringUtils.isNotBlank(dataType)){
@RequestParam("dataType") String dataType) {
if (StringUtils.isNotBlank(standId) && StringUtils.isNotBlank(dataType)) {
try {
if("STAND".equals(dataType)){
if ("STAND".equals(dataType)) {
resetSearchCenterService.syncStandSearchCenterData(standId);
}else if("BUSS".equals(dataType)){
} else if ("BUSS".equals(dataType)) {
resetSearchCenterService.syncBussStandSearchCenterData(standId);
}else{
return Result.error("-1","资源类型错误，请检查",null);
} else {
return Result.error("-1", "资源类型错误，请检查", null);
}
return Result.success("200","开始同步",null);
return Result.success("200", "开始同步", null);
} catch (Exception e) {
logger.error(e.getMessage(),e);
return Result.error("-1","请求错误，请检查",null);
logger.error(e.getMessage(), e);
return Result.error("-1", "请求错误，请检查", null);
}
}else{
return Result.error("-1","参数有误，请检查",null);
} else {
return Result.error("-1", "参数有误，请检查", null);
}
}
@Autowired
private ResetSearchCenterServiceTemp resetSearchCenterServiceTemp;
@ApiOperation(value = "|SearchCenter|临时手动更新ALL标准数据索引")
@PostMapping(value = "/manualResetALLSearchCenterTemp")
public ResponseMessage manualResetALLSearchCenterTemp(@RequestBody SearchCenter searchCenter) throws Exception {
ResponseMessage x = verifySearchCenter(searchCenter);
if (x != null) {
return x;
}
return resetSearchCenterServiceTemp.syncResetALLSearchCenter(searchCenter);
}
}