package com.adc.da.search;

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;
import com.adc.da.slrs.sarStandardsInfo.entity.SarStandardsInfoEOPage;
import com.adc.da.util.http.ResponseMessage;
import com.adc.da.util.http.Result;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;
import java.util.Map;

@RestController
@RequestMapping("/${restPath}/search/resetSearchCenter")
@Api(tags = "搜索中心重置索引及数据")
public class ResetSearchCenterController extends BaseController<Map<String, Object>> {

    private static final Logger logger = LoggerFactory.getLogger(ResetSearchCenterController.class);

    @Autowired
    private ResetSearchCenterService resetSearchCenterService;

    @ApiOperation(value = "|Search|ES规则排序字段重置数据维护ES")
    @PostMapping(value = "/resetALLSearchCenterToFields")
    public ResponseMessage resetALLSearchCenterToFields(@RequestBody SearchFields searchFields) throws Exception {

        return resetSearchCenterService.resetALLSearchCenterToFields(searchFields);
    }

    @ApiOperation(value = "|Search|文本条件搜索更新标准数据索引")
    @PostMapping(value = "/resetALLSearchCenterToSearch")
    public ResponseMessage resetALLSearchCenterToSearch(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        return resetSearchCenterService.resetALLSearchCenterToSearch(searchCenter);
    }

    @ApiOperation(value = "|SearchCenter|重新创建ALL标准数据索引")
    @PostMapping(value = "/resetALLSearchCenter")
    public ResponseMessage resetALLSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        return resetSearchCenterService.resetALLSearchCenter(searchCenter);
    }


    @ApiOperation(value = "|SearchCenter|重新创建ALL标准数据索引")
    @PostMapping(value = "/resetALLSearchCenterForExits")
    public ResponseMessage resetALLSearchCenterForExits(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        return resetSearchCenterService.resetALLSearchCenterForExits(searchCenter);
    }


    @ApiOperation(value = "|SearchCenter|手动重新创建（---7天内---）ALL标准数据索引（凌晨有自动程序会跑）")
    @PostMapping(value = "/manualResetALLSearchCenter")
    public ResponseMessage manualResetALLSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        return resetSearchCenterService.syncResetALLSearchCenter(searchCenter);
    }

    @ApiOperation(value = "|SearchCenter|手动重新创建   ALL标准数据索引（凌晨有自动程序会跑）")
    @PostMapping(value = "/manualResetALLSearchCenter1")
    public ResponseMessage manualResetALLSearchCenter1(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        return resetSearchCenterService.syncResetALLSearchCenter1(searchCenter);
    }

    private ResponseMessage verifySearchCenter(SearchCenter searchCenter) {
        if (searchCenter.getExecType() == null || "".equals(searchCenter.getExecType())) {
            return Result.error("执行参数 ALL 存在更新 不存在新增 ,UPD 只 更新存在 es 里的标准 ,ADD 只新增不存在 es 的标准, DEL 只删除不存在标准库的数据");
        }

        return null;
    }

    @ApiOperation(value = "|SearchCenter|重新创建国内外标准数据索引")
    @PostMapping(value = "/resetAStandSearchCenter")
    public ResponseMessage resetStandSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        SarStandardsInfoEOPage sarStandardsInfoEOPage = new SarStandardsInfoEOPage();
        return resetSearchCenterService.resetStandSearchCenter(sarStandardsInfoEOPage, searchCenter);
    }

    @ApiOperation(value = "|SearchCenter|重新创建国内外政策数据索引")
    @PostMapping(value = "/resetBLawsSearchCenter")
    public ResponseMessage resetLawsSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        SarLawsStandInfoPage sarLawsInfoEOPage = new SarLawsStandInfoPage();
        return resetSearchCenterService.resetLawsSearchCenter(sarLawsInfoEOPage, searchCenter);
    }

    @ApiOperation(value = "|SearchCenter|重新创建企业标准数据索引")
    @PostMapping(value = "/resetCBussStandSearchCenter")
    public ResponseMessage resetBussStandSearchCenter(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        SarBussionessStandEOPage sarBussionessStandEOPage = new SarBussionessStandEOPage();
        return resetSearchCenterService.resetBussStandSearchCenter(sarBussionessStandEOPage, searchCenter);
    }

    /**
     * 根据资源ID对搜索中心数据进行处理
     * @param standId
     * @param dataType(STAND BUSS)
     * @return
     */
    @ApiOperation(value = "|SearchCenter|根据资源ID对搜索中心数据进行处理")
    @GetMapping(value = "/syncSearchCenterData")
    public ResponseMessage syncSearchCenterData(@RequestParam("standId") String standId,
                                                @RequestParam("dataType") String dataType) {
        if (StringUtils.isNotBlank(standId) && StringUtils.isNotBlank(dataType)) {
            try {
                if ("STAND".equals(dataType)) {
                    resetSearchCenterService.syncStandSearchCenterData(standId);
                } else if ("BUSS".equals(dataType)) {
                    resetSearchCenterService.syncBussStandSearchCenterData(standId);
                } else {
                    return Result.error("-1", "资源类型错误，请检查", null);
                }
                return Result.success("200", "开始同步", null);
            } catch (Exception e) {
                logger.error(e.getMessage(), e);
                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);
    }

    @ApiOperation(value = "|SearchCenter|手动删除ES中国内外和企标数据")
    @PostMapping(value = "/deleteES")
    public ResponseMessage deleteES(@RequestBody SearchCenter searchCenter) throws Exception {
        ResponseMessage x = verifySearchCenter(searchCenter);
        if (x != null) {
            return x;
        }
        return resetSearchCenterServiceTemp.deleteES(searchCenter);
    }
}