package com.product.admin.controller;

import com.product.admin.config.CmnConst;
import com.product.admin.config.SystemCode;
import com.product.admin.service.PublicService;
import com.product.admin.service.SystemMenusService;
import com.product.common.lang.StringUtils;
import com.product.core.config.CoreConst;
import com.product.core.controller.support.AbstractBaseController;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.entity.RequestParameterEntity;
import com.product.core.exception.BaseException;
import com.product.core.permission.PermissionService;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.module.sys.config.SystemErrorCode;
import com.product.module.sys.version.ApiVersion;
import com.product.util.BaseUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * @Author cheng
 * @Description 快速入口Controller
 * @Date 2021/6/2 14:35
 * @Version 1.0
 */
@RequestMapping("/api/quick/entry")
@RestController
public class QuickEntryController extends AbstractBaseController {

    @Autowired
    PublicService publicService;

    @Autowired
    PermissionService permissionService;
    @Autowired
    SystemMenusService systemMenusService;

    /**
     * 查询顶级菜单下的所有功能
     *
     * @param request
     * @return
     */
    @PostMapping("/menu-top-function/{version}")
    @ApiVersion(1)
    public String getTopMenuFunction(HttpServletRequest request) {
        try {
            return BaseUtil.success(systemMenusService.getMenuTopFunction(), null);
        } catch (BaseException e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.GET_LIST_DATA_FIAL.getValue(), SystemCode.GET_LIST_DATA_FIAL.getText() + e.getMessage());
        }
    }

    /**
     * 修改排序
     *
     * @param request
     * @return
     */
    @PostMapping("/update-sequence/{version}")
    @ApiVersion(1)
    public String updateSequence(HttpServletRequest request) {
        try {
            FieldSetEntity fse = null;
            Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
            if (bean != null) {
                RequestParameterEntity reqp = (RequestParameterEntity) bean;
                fse = reqp.getFormData();
            }
            if (bean == null || fse == null) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
                return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
            }

            // 判断表名是否正常
            if (StringUtils.isEmpty(fse.getTableName()) && !CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG.equals(fse.getTableName())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
                return this.error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
            }
            DataTableEntity subDataTable = fse.getSubDataTable(CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG);
            // 判断表名是否正常
            if (BaseUtil.dataTableIsEmpty(subDataTable)) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
                return this.error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
            }
            List<Object> params = new ArrayList<>();
            StringBuilder sql = new StringBuilder();
            sql.append(" update " + CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG);
            sql.append(" SET ");
            sql.append(CmnConst.UPDATED_UTC_DATETIME);
            sql.append(" =now(), ");
            sql.append(CmnConst.UPDATED_BY);
            sql.append(" =?, ");
            sql.append(CmnConst.SEQUENCE);
            sql.append(" =(case  ");
            params.add(SpringMVCContextHolder.getCurrentUser().getUser_id());
            for (int i = 0; i < subDataTable.getRows(); i++) {
                sql.append(" when uuid=? then ? ");
                params.add(subDataTable.getString(i, CmnConst.UUID));
                params.add(subDataTable.getString(i, CmnConst.SEQUENCE));
            }
            params.addAll(Arrays.asList(subDataTable.getUuids()));
            sql.append(" else null end) where ");
            sql.append(BaseUtil.buildQuestionMarkFilter("uuid", subDataTable.getRows(), true));
            return publicService.getBaseDao().executeUpdate(sql.toString(), params.toArray()) ? OK() : error(SystemCode.UPDATE_SEQUENCE_FIAL.getValue(), SystemCode.UPDATE_SEQUENCE_FIAL.getText());
        } catch (BaseException e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.UPDATE_SEQUENCE_FIAL.getValue(), SystemCode.UPDATE_SEQUENCE_FIAL.getText() + e.getMessage());
        }
    }

    /**
     * 获取入口列表
     *
     * @param request
     * @return
     */
    @PostMapping("/get-list/{version}")
    @ApiVersion(1)
    public String getList(HttpServletRequest request) {
        try {
            FieldSetEntity fse = null;
            Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
            if (bean != null) {
                RequestParameterEntity reqp = (RequestParameterEntity) bean;
                fse = reqp.getFormData();
            }
            if (bean == null || fse == null) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
                return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
            }

            // 判断表名是否正常
            if (StringUtils.isEmpty(fse.getTableName()) && !CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG.equals(fse.getTableName())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
                return this.error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
            }

            fse.setValue(CmnConst.CPAGE, 1);
            fse.setValue(CmnConst.PAGESIZE, Integer.MAX_VALUE);
            // 判断分页参数是否正常
            if (StringUtils.isEmpty(fse.getString(CmnConst.PAGESIZE))
                    || StringUtils.isEmpty(fse.getString(CmnConst.CPAGE))) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText());
                return this.error(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText());
            }
            String dataFilter = permissionService.getDataFilter(fse.getTableName(), CmnConst.CREATED_BY);
//            if (!StringUtils.isEmpty(dataFilter)) {
//                dataFilter += " AND ";
//            } else if (dataFilter == null) {
//                dataFilter = "";
//            }
            dataFilter+=" ";
            fse.setValue("filter", dataFilter);
            fse.setValue("orderby", "sequence");
            return OK_List(publicService.listTable(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.GET_LIST_DATA_FIAL.getValue(), SystemCode.GET_LIST_DATA_FIAL.getText() + e.getMessage());
        }
    }

    /**
     * 查询入口详情
     *
     * @param request
     * @return
     */
    @PostMapping("/find-data/{version}")
    @ApiVersion(1)
    public String findData(HttpServletRequest request) {
        try {
            FieldSetEntity fse = null;
            Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
            if (bean != null) {
                RequestParameterEntity reqp = (RequestParameterEntity) bean;
                fse = reqp.getFormData();
            }
            if (bean == null || fse == null) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
                return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
            }
            // 判断表名是否正常
            if (StringUtils.isEmpty(fse.getTableName()) && !CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG.equals(fse.getTableName())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
                return this.error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
            }
            // 判断分页参数是否正常
            if (StringUtils.isEmpty(fse.getUUID())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText());
                return this.error(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText());
            }
            //数据权限验证
            if (permissionService.validDataPermission(fse, CoreConst.DATA_PERMISSION_VALID_TYPE_USER)) {
                SpringMVCContextHolder.getSystemLogger().error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(),
                        SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
                return this.error(SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getValue(), SystemErrorCode.SYSTEM_NOT_OPER_PERMISSION.getText());
            }
            return OK_List(publicService.getFieldSetEntity(fse, true));
        } catch (BaseException e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.GET_INFO_DATA_FIAL.getValue(), SystemCode.GET_INFO_DATA_FIAL.getText() + e.getMessage());
        }
    }

    /**
     * 保存入口
     *
     * @param request
     * @return
     */
    @PostMapping("/save-data/{version}")
    @ApiVersion(1)
    public String saveData(HttpServletRequest request) {
        try {
            FieldSetEntity fse = null;
            Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
            if (bean != null) {
                RequestParameterEntity reqp = (RequestParameterEntity) bean;
                fse = reqp.getFormData();
            }
            if (bean == null || fse == null) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
                return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
            }
            // 判断表名是否正常
            if (StringUtils.isEmpty(fse.getTableName()) && !CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG.equals(fse.getTableName())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
                return this.error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
            }
            return OK_Add(publicService.saveFieldSetEntity(fse));
        } catch (BaseException e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.SAVE_DATA_FIAL.getValue(), SystemCode.SAVE_DATA_FIAL.getText() + e.getMessage());
        }
    }

    /**
     * 删除入口
     *
     * @param request
     * @return
     */
    @PostMapping("/del-data/{version}")
    @ApiVersion(1)
    public String delData(HttpServletRequest request) {
        try {
            FieldSetEntity fse = null;
            Object bean = request.getAttribute(CoreConst.API_POST_REQUEST_DATA);
            if (bean != null) {
                RequestParameterEntity reqp = (RequestParameterEntity) bean;
                fse = reqp.getFormData();
            }
            if (bean == null || fse == null) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
                return this.error(SystemCode.SYSTEM_FORM_NODATA.getValue(), SystemCode.SYSTEM_FORM_NODATA.getText());
            }
            // 判断表名是否正常
            if (StringUtils.isEmpty(fse.getTableName()) && !CmnConst.PRODUCT_SYS_QUICK_ENTRY_CONFIG.equals(fse.getTableName())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
                return this.error(SystemCode.SYSTEM_TABLE_NODATA.getValue(), SystemCode.SYSTEM_TABLE_NODATA.getText());
            }
            // 判断参数是否正常
            if (StringUtils.isEmpty(fse.getUUID())) {
                SpringMVCContextHolder.getSystemLogger().error(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText());
                return this.error(SystemCode.SYSTEM_FORM_COUNT.getValue(), SystemCode.SYSTEM_FORM_COUNT.getText());
            }
            return publicService.delete(fse) ? OK() : error(SystemCode.DEL_DATA_FIAL.getValue(), SystemCode.DEL_DATA_FIAL.getText());
        } catch (BaseException e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(e);
        } catch (Exception e) {
            e.printStackTrace();
            SpringMVCContextHolder.getSystemLogger().error(e);
            return error(SystemCode.DEL_DATA_FIAL.getValue(), SystemCode.DEL_DATA_FIAL.getText() + e.getMessage());
        }
    }

}