package com.engine.organization.service.impl;

import com.api.browser.bean.BrowserBean;
import com.api.browser.bean.SearchConditionGroup;
import com.api.browser.bean.SearchConditionItem;
import com.api.browser.bean.SearchConditionOption;
import com.cloudstore.eccom.result.WeaResultMsg;
import com.engine.core.impl.Service;
import com.engine.organization.component.OrganizationWeaTable;
import com.engine.organization.entity.QueryParam;
import com.engine.organization.entity.staff.bo.StaffPlanBO;
import com.engine.organization.entity.staff.param.StaffPlanSearchParam;
import com.engine.organization.entity.staff.po.StaffPlanPO;
import com.engine.organization.entity.staff.vo.StaffPlanTableVO;
import com.engine.organization.mapper.comp.CompMapper;
import com.engine.organization.mapper.staff.StaffPlanMapper;
import com.engine.organization.service.StaffPlanService;
import com.engine.organization.util.MenuBtn;
import com.engine.organization.util.OrganizationAssert;
import com.engine.organization.util.OrganizationFormItemUtil;
import com.engine.organization.util.db.DBType;
import com.engine.organization.util.db.MapperProxyFactory;
import org.apache.commons.lang3.StringUtils;
import weaver.conn.RecordSet;
import weaver.general.StringUtil;
import weaver.general.Util;

import java.util.*;

/**
 * @description: TODO
 * @author:dxfeng
 * @createTime: 2022/05/25
 * @version: 1.0
 */
public class StaffPlanServiceImpl extends Service implements StaffPlanService {

    private StaffPlanMapper getStaffPlanMapper() {
        return MapperProxyFactory.getProxy(StaffPlanMapper.class);
    }

    private CompMapper getCompMapper() {
        return MapperProxyFactory.getProxy(CompMapper.class);
    }

    @Override
    public Map<String, Object> listPage(StaffPlanSearchParam params) {
        OrganizationWeaTable<StaffPlanTableVO> table = new OrganizationWeaTable<>(user, StaffPlanTableVO.class);
        StaffPlanPO staffPlanPO = StaffPlanBO.convertParamToPO(params, (long) user.getUID());
        String sqlWhere = buildSqlWhere(staffPlanPO);
        table.setSqlwhere(sqlWhere);
        WeaResultMsg result = new WeaResultMsg(false);
        result.putAll(table.makeDataResult());
        result.success();
        return result.getResultMap();
    }

    @Override
    public int saveStaffPlan(StaffPlanSearchParam param) {
        List<StaffPlanPO> list = getStaffPlanMapper().listByNo(Util.null2String(param.getPlanNo()));
        OrganizationAssert.isEmpty(list, "编号不允许重复");
        StaffPlanPO staffPlanPO = StaffPlanBO.convertParamToPO(param, (long) user.getUID());
        return getStaffPlanMapper().insertIgnoreNull(staffPlanPO);
    }

    @Override
    public int updateStaffPlan(StaffPlanSearchParam param) {
        StaffPlanPO staffPlanPO = StaffPlanBO.convertParamToPO(param, (long) user.getUID());
        return getStaffPlanMapper().updateStaffPlan(staffPlanPO);
    }

    @Override
    public int updateForbiddenTagById(StaffPlanSearchParam params) {
        StaffPlanPO staffPlanPO = StaffPlanPO.builder().id(params.getId()).forbiddenTag(params.getForbiddenTag() ? 0 : 1).build();
        return getStaffPlanMapper().updateForbiddenTagById(staffPlanPO);
    }

    @Override
    public int deleteByIds(Collection<Long> ids) {
        OrganizationAssert.notEmpty(ids, "请选择要删除的数据");
        return getStaffPlanMapper().deleteByIds(ids);
    }

    @Override
    public Map<String, Object> getSearchCondition(Map<String, Object> params) {
        Map<String, Object> apiDatas = new HashMap<>();
        List<SearchConditionGroup> addGroups = new ArrayList<>();
        List<SearchConditionItem> conditionItems = new ArrayList<>();
        // 编号
        SearchConditionItem planNoItem = OrganizationFormItemUtil.inputItem(user, 2, 16, 2, 50, "编号", "planNo");
        // 名称
        SearchConditionItem planNameItem = OrganizationFormItemUtil.inputItem(user, 2, 16, 2, 50, "名称", "planName");
        // 年度
        SearchConditionItem planYearItem = OrganizationFormItemUtil.datePickerItem(user, 2, 16, false, 2, "年度", "planYear");
        planYearItem.setFormat("YYYY");
        // 时间开始
        SearchConditionItem timeStartItem = OrganizationFormItemUtil.datePickerItem(user, 2, 16, false, 2, "时间开始", "timeStart");
        // 时间结束
        SearchConditionItem timeEndItem = OrganizationFormItemUtil.datePickerItem(user, 2, 16, false, 2, "时间结束", "timeEnd");
        // 适用公司
        SearchConditionItem companyIdtItem = OrganizationFormItemUtil.browserItem(user, 2, 16, 2, false, "适用公司", "162", "companyId", "compBrowser");
        // 说明
        SearchConditionItem descriptionItem = OrganizationFormItemUtil.inputItem(user, 2, 16, 2, 50, "说明", "description");
        // 状态
        List<SearchConditionOption> selectOptions = new ArrayList<>();
        SearchConditionOption enableOption = new SearchConditionOption("true", "启用");
        SearchConditionOption disableOption = new SearchConditionOption("false", "禁用");
        selectOptions.add(enableOption);
        selectOptions.add(disableOption);
        SearchConditionItem forbiddenTagItem = OrganizationFormItemUtil.selectItem(user, selectOptions, 2, 16, 6, false, "禁用标记", "forbiddenTag");


        conditionItems.add(planNoItem);
        conditionItems.add(planNameItem);
        conditionItems.add(planYearItem);
        conditionItems.add(timeStartItem);
        conditionItems.add(timeEndItem);
        conditionItems.add(companyIdtItem);
        conditionItems.add(descriptionItem);
        conditionItems.add(forbiddenTagItem);
        addGroups.add(new SearchConditionGroup("高级搜索条件", true, conditionItems));
        apiDatas.put("conditions", addGroups);
        return apiDatas;
    }

    @Override
    public Map<String, Object> getForm(Map<String, Object> params) {
        Map<String, Object> apiDatas = new HashMap<>();
        List<SearchConditionItem> selectItems = new ArrayList<>();
        List<SearchConditionGroup> addGroups = new ArrayList<>();
        // 编号
        SearchConditionItem planNoItem = OrganizationFormItemUtil.inputItem(user, 2, 16, 3, 50, "编号", "planNo");
        planNoItem.setRules("required|string");
        // 名称
        SearchConditionItem planNameItem = OrganizationFormItemUtil.inputItem(user, 2, 16, 3, 50, "名称", "planName");
        planNameItem.setRules("required|string");
        // 年度
        SearchConditionItem planYearItem = OrganizationFormItemUtil.datePickerItem(user, 2, 16, false, 3, "年度", "planYear");
        planYearItem.setFormat("YYYY");
        planYearItem.setRules("required|string");
        // 时间开始
        SearchConditionItem timeStartItem = OrganizationFormItemUtil.datePickerItem(user, 2, 16, false, 3, "时间开始", "timeStart");
        timeStartItem.setRules("required|string");
        // 时间结束
        SearchConditionItem timeEndItem = OrganizationFormItemUtil.datePickerItem(user, 2, 16, false, 3, "时间结束", "timeEnd");
        timeEndItem.setRules("required|string");
        // 适用公司
        SearchConditionItem companyIdtItem = OrganizationFormItemUtil.browserItem(user, 2, 16, 3, false, "适用公司", "162", "companyId", "compBrowser");
        companyIdtItem.setRules("required|string");
        // 说明
        SearchConditionItem descriptionItem = OrganizationFormItemUtil.inputItem(user, 2, 16, 2, 50, "说明", "description");

        // 编辑状态下赋值操作
        String id = Util.null2String(params.get("id"));
        if (!StringUtil.isEmpty(id)) {
            StaffPlanPO staffPlanPO = getStaffPlanMapper().getStaffPlanByID(Integer.parseInt(id));
            OrganizationAssert.notNull(staffPlanPO, "选择的数据不存在，或数据已删除");
            planNoItem.setValue(staffPlanPO.getPlanNo());
            planNameItem.setValue(staffPlanPO.getPlanName());
            planYearItem.setValue(staffPlanPO.getPlanYear());
            timeStartItem.setValue(staffPlanPO.getTimeStart());
            timeEndItem.setValue(staffPlanPO.getTimeEnd());

            BrowserBean browserBean = companyIdtItem.getBrowserConditionParam();
            List<Map<String, Object>> maps = getCompMapper().listCompsByIds(QueryParam.builder().ids(staffPlanPO.getCompanyId()).build().getIds());
            browserBean.setReplaceDatas(maps);
            companyIdtItem.setBrowserConditionParam(browserBean);

            descriptionItem.setValue(staffPlanPO.getDescription());

            // 编辑状态下,编号只读
            planNoItem.setViewAttr(1);
        }

        selectItems.add(planNoItem);
        selectItems.add(planNameItem);
        selectItems.add(planYearItem);
        selectItems.add(timeStartItem);
        selectItems.add(timeEndItem);
        selectItems.add(companyIdtItem);
        selectItems.add(descriptionItem);
        addGroups.add(new SearchConditionGroup("基本信息", true, selectItems));
        apiDatas.put("condition", addGroups);
        return apiDatas;
    }

    @Override
    public Map<String, Object> getHasRight() {
        return MenuBtn.getCommonBtnDatas();
    }


    /**
     * 查询条件
     *
     * @param staffPlanPO
     * @return
     */
    private String buildSqlWhere(StaffPlanPO staffPlanPO) {
        DBType dbType = DBType.get(new RecordSet().getDBType());
        String sqlWhere = " where t.delete_type ='0' ";
        String planNo = staffPlanPO.getPlanNo();
        if (StringUtils.isNotBlank(planNo)) {
            sqlWhere += " AND t.plan_no " + dbType.like(planNo);
        }
        String planName = staffPlanPO.getPlanName();
        if (StringUtils.isNotBlank(planName)) {
            sqlWhere += " AND t.plan_name " + dbType.like(planName);
        }
        Integer planYear = staffPlanPO.getPlanYear();
        if (null != planYear) {
            sqlWhere += " AND t.plan_year = '" + planYear + "'";
        }
        Date timeStart = staffPlanPO.getTimeStart();
        if (null != timeStart) {
            sqlWhere += " AND t.time_start = '" + timeStart + "'";
        }
        Date timeEnd = staffPlanPO.getTimeEnd();
        if (null != timeEnd) {
            sqlWhere += " AND t.time_end = '" + timeEnd + "'";
        }
        String companyId = staffPlanPO.getDescription();
        if (StringUtils.isNotBlank(companyId)) {
            sqlWhere += " AND t.companyId = '" + companyId + "'";
        }

        String description = staffPlanPO.getDescription();
        if (StringUtils.isNotBlank(description)) {
            sqlWhere += " AND t.description " + dbType.like(description);
        }
        Integer forbiddenTag = staffPlanPO.getForbiddenTag();
        if (null != forbiddenTag) {
            sqlWhere += " AND t.forbidden_tag = '" + forbiddenTag + "'";
        }
        return sqlWhere;
    }
}