package com.product.data.center.controller;

import com.product.admin.service.PublicService;
import com.product.core.controller.support.AbstractBaseController;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
import com.product.data.center.config.CmnConst;
import com.product.data.center.config.ErrorCode;
import com.product.data.center.service.SyncDelRecordService;
import com.product.data.center.service.ide.ICommonService;
import com.product.module.sys.version.ApiVersion;
import com.product.util.BaseUtil;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

/**
 * @Author cheng
 * @Date 2022/7/21 13:23
 * @Desc
 */
@RestController
@RequestMapping("/api")
public class CommonController extends AbstractBaseController {


    @Resource
    ICommonService dataCommonService;

    @Resource
    PublicService publicService;
    @Resource
    SyncDelRecordService syncDelRecordService;



    @PostMapping("/mes-sync/save/{version}")
    @ApiVersion(1)
    public String saveMesSyncDataConfig(HttpServletRequest request) {
        try {

            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request, "product_sys_data_sync_mes");
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            service.saveMesSyncDataConfig(fse);

            return OK_List(publicService.getFieldSetEntity(fse, true));
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_MES_SYNC_CONFIG_FAIL);
        }
    }

    /**
     * 采集配置保存
     *
     * @param request
     * @return
     */
    @PostMapping("/collect/save/{version}")
    @ApiVersion(1)
    public String saveCollectConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            String uuid = service.saveCollectConfig(fse);
            //创建触发器 2子库删除数据， 同步主库
//            syncDelRecordService.createTrigger(fse);
            return OK_Add(uuid);
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 采集配置详情
     *
     * @param request
     * @return
     */
    @PostMapping("/collect/find/{version}")
    @ApiVersion(1)
    public String findCollectConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            return OK_List(dataCommonService.findCollectConfig(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 采集配置删除
     *
     * @param request
     * @return
     */
    @PostMapping("/collect/del/{version}")
    @ApiVersion(1)
    public String delCollectConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            service.delCollectConfig(fse);
            //删除对应的触发器
            syncDelRecordService.deleteTrigger(fse);
            return OK();
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 提取配置保存
     *
     * @param request
     * @return
     */
    @PostMapping("/extract/save/{version}")
    @ApiVersion(1)
    public String saveExtractConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            return OK_Add(service.saveExtractConfig(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 提取配置查询
     *
     * @param request
     * @return
     */
    @PostMapping("/extract/find/{version}")
    @ApiVersion(1)
    public String findExtractConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            return OK_List(dataCommonService.findExtractConfig(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 提取配置删除
     *
     * @param request
     * @return
     */
    @PostMapping("/extract/del/{version}")
    @ApiVersion(1)
    public String delExtractConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            service.delExtractConfig(fse);
            return OK();
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 归档配置保存
     *
     * @param request
     * @return
     */
    @PostMapping("/archiving/save/{version}")
    @ApiVersion(1)
    public String saveArchivingConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            return OK_Add(service.saveArchivingConfig(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 归档配置详情
     *
     * @param request
     * @return
     */
    @PostMapping("/archiving/find/{version}")
    @ApiVersion(1)
    public String findArchivingConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            return OK_List(dataCommonService.findArchivingConfig(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 归档配置删除
     *
     * @param request
     * @return
     */
    @PostMapping("/archiving/del/{version}")
    @ApiVersion(1)
    public String delArchivingConfig(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            service.delArchivingConfig(fse);
            return OK();
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_COLLECT_CONFIG_FAIL);
        }
    }

    /**
     * 订单数据验证配置
     *
     * @param request
     * @return
     */
    @PostMapping("/order-data-verification/save/{version}")
    @ApiVersion(1)
    public String orderDataVerification(HttpServletRequest request) {
        try {
            FieldSetEntity fse = BaseUtil.getFieldSetEntity(request, CmnConst.PRODUCT_SYS_ORDER_DATA_VERIFICATION);
            ICommonService service = (ICommonService) getProxyInstance(dataCommonService);
            String uuid = service.saveOrderDataVerification(fse);
            return OK_Add(uuid);
        } catch (BaseException e) {
            e.printStackTrace();
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            return error(ErrorCode.SAVE_ORDER_DATA_VERIFY_CONFIG_FAIL);
        }
    }
}