package com.product.badge.service;

import com.product.badge.config.BadgeCode;
import com.product.badge.config.CmnConst;
import com.product.badge.service.idel.IBadgeBorrowService;
import com.product.common.lang.StringUtils;
import com.product.core.cache.DataPoolCacheImpl;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.service.support.QueryFilterService;
import com.product.core.spring.context.SpringMVCContextHolder;
import com.product.core.transfer.Transactional;
import com.product.module.sys.entity.SystemUser;
import com.product.util.BaseUtil;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.Date;

/**
 * @Date: 2021-06-03 08:37
 * @Description: 证章借用
 */
@Service
public class BadgeBorrowService extends AbstractBaseService implements IBadgeBorrowService {
    @Autowired
    public BaseDao baseDao;
    @Autowired
    public QueryFilterService queryFilterService;

    /**
     * 借用
     * @param fse
     * @return
     */
    @Transactional
    @Override
    public String borrow(FieldSetEntity fse) {
        SystemUser curUser = SpringMVCContextHolder.getCurrentUser();
        if (StringUtils.isEmpty(fse.getUUID())) {
            // 新增
            BaseUtil.createCreatorAndCreationTime(curUser, fse);
        } else {
            // 修改
            BaseUtil.updatedRegeneratorAndUpdateTime(curUser, fse);
        }
        fse.setValue(CmnConst.FIELD_ORG_LEVEL_UUID, SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid());
        fse.setValue(CmnConst.FIELD_DEPT_UUID, SpringMVCContextHolder.getCurrentUser().getDept_uuid());
        FieldSetEntity tempFse;
        DataTableEntity dte = fse.getSubDataTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL);
        fse.removeSubData(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL);
        DataTableEntity subDte = new DataTableEntity();
        FieldSetEntity subFse;
        String[] arr;
        for (int i = 0;i < dte.getRows();i++) {
            tempFse = dte.getFieldSetEntity(i);
            arr = tempFse.getString(CmnConst.FIELD_BADGE_UUID).split(",");
            for (String badgeUUID : arr) {
                subFse = tempFse.clones();
                subFse.setValue(CmnConst.FIELD_BADGE_UUID, badgeUUID);
                subDte.addFieldSetEntity(subFse);
            }
        }
        fse.addSubDataTable(subDte);
        baseDao.saveFieldSetEntity(fse);
        return fse.getUUID();
    }

    /**
     * 借用-获取借用详情
     * @param fse
     * @return
     */
    public FieldSetEntity findBadgeBorrowInfo(FieldSetEntity fse) {
        FieldSetEntity recordFse = baseDao.getFieldSetEntity(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD, fse.getUUID(), false);
        StringBuilder sql = new StringBuilder(128);
        sql.append("select badge_level,badge_type,GROUP_CONCAT(badge_uuid) badge_uuid")
                .append("\nfrom product_oa_badge_borrow_detail")
                .append("\nwhere record_uuid=?")
                .append("\ngroup by badge_level,badge_type");
        DataTableEntity detailDte = baseDao.listTable(sql.toString(), new Object[]{fse.getUUID()});
        recordFse.addSubDataTable(detailDte);
        return recordFse;
    }

    /**
     * 归还-列表
     * @param fse
     * @return
     */
    public DataTableEntity getGiveBackList(FieldSetEntity fse) {
        StringBuilder sql = new StringBuilder(128);
        sql.append("select * from product_oa_badge_borrow_record r")
                .append("\ninner join (")
                .append("\n    select distinct record_uuid from product_oa_badge_borrow_detail")
                .append("\n    where return_date is null")
                .append("\n) d on r.uuid=d.record_uuid");
        int pageSize = fse.getInteger(CmnConst.PAGE_SIZE) == null ? Integer.MAX_VALUE : fse.getInteger(CmnConst.PAGE_SIZE);
        int curPage = fse.getInteger(CmnConst.CUR_PAGE) == null ? 1 : fse.getInteger(CmnConst.CUR_PAGE);
        DataTableEntity dte = baseDao.listTable(sql.toString(), new Object[]{}, pageSize, curPage);
        baseDao.loadPromptData(dte);
        return dte;
    }

    /**
     * 归还-部分归还-获取借用列表详情
     * @param fse
     * @return
     */
    public FieldSetEntity partGiveBackFind(FieldSetEntity fse) {
        String recordUUID = fse.getUUID();
        DataTableEntity detailDte = baseDao.listTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL, "return_date is null and record_uuid=?", new Object[]{recordUUID});
        baseDao.loadPromptData(detailDte);
        FieldSetEntity recordFse = baseDao.getFieldSetEntity(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD, recordUUID, false);
        baseDao.loadPromptData(recordFse);
        recordFse.addSubDataTable(detailDte);
        return recordFse;
    }

    /**
     * 归还
     * @param fse
     */
    public void giveBack(FieldSetEntity fse) {
        String uuids = fse.getUUID();
        if (StringUtils.isEmpty(uuids)) {
            return;
        }
        SystemUser curUser = SpringMVCContextHolder.getCurrentUser();
        String tableName = fse.getTableName();
        DataTableEntity dte = null;
        if (CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD.equalsIgnoreCase(tableName)) {
            // 归还所有
            dte = baseDao.listTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL, "record_uuid=? and return_date is null", new Object[]{uuids});
        }
        if (CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL.equalsIgnoreCase(tableName)) {
            // 部分归还
            String[] uuidArr = uuids.split(",");
            String filter = BaseUtil.buildQuestionMarkFilter(CmnConst.FIELD_UUID, uuidArr.length, true);
            dte = baseDao.listTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL, filter, uuidArr);
        }
        if (!BaseUtil.dataTableIsEmpty(dte)) {
            FieldSetEntity tempFse;
            for (int i = 0; i < dte.getRows(); i++) {
                tempFse = dte.getFieldSetEntity(i);
                tempFse.setValue(CmnConst.FIELD_BADGE_BORROW_RETURN_DATE, new Date());
                tempFse.setValue(CmnConst.FIELD_BADGE_BORROW_RETURN_BY, curUser.getUser_id());
                baseDao.saveFieldSetEntity(tempFse);
            }
        }
    }

    /**
     * 证章借用看板
     * @param fse
     * @return
     */
    public DataTableEntity borrowBoard(FieldSetEntity fse) {
        StringBuilder sql = new StringBuilder();
        sql.append("\nselect d.table_uuid,d.uuid,table_name,c.org_level_name org_level_uuid,badge_name,type_name,cp.dict_label badge_type,holder,ifnull(badge_status,'未借出') badge_status,borrow_by,borrow_time,return_date,useful_life ");
        sql.append("\nfrom ( ");
        sql.append("\n	select '725928d8-a0ed-4f68-9e1d-87f66d899df0' table_uuid,'product_oa_badge_awards' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'获奖信息证章' type_name,holder,'永久' useful_life from product_oa_badge_awards ");
        sql.append("\n	union all ");
        sql.append("\n	select '66d5e271-41bc-48c3-a0f5-6d696c70a036' table_uuid,'product_oa_badge_company' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'公司证章' type_name,holder,'永久' useful_life from product_oa_badge_company ");
        sql.append("\n	union all ");
        sql.append("\n	select '6468cd40-c9c9-41ff-b819-d670e3af9cee' table_uuid,'product_oa_badge_company_qualification' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'公司资质证章' type_name,holder,useful_life from product_oa_badge_company_qualification ");
        sql.append("\n	union all ");
        sql.append("\n	select 'a743e548-7b49-4f45-a072-acc03b873bdd' table_uuid,'product_oa_badge_constructor' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'建造师证章' type_name,holder,'永久' useful_life from product_oa_badge_constructor ");
        sql.append("\n	union all ");
        sql.append("\n	select 'c07d0bcd-3e2d-43b9-9df0-ae60c6d57577' table_uuid,'product_oa_badge_cost_officer' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'造价人员证章' type_name,holder,useful_life from product_oa_badge_cost_officer ");
        sql.append("\n	union all ");
        sql.append("\n	select '3d6d8e93-f347-4a07-abb0-c6ec7ccf907b' table_uuid,'product_oa_badge_finance_manage' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'财务管理证章' type_name,holder,'永久' useful_life from product_oa_badge_finance_manage ");
        sql.append("\n	union all ");
        sql.append("\n	select '4cca65f6-dc58-443a-abb1-222524930d4c' table_uuid,'product_oa_badge_manager' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'管理人员证章' type_name,holder,useful_life from product_oa_badge_manager ");
        sql.append("\n	union all ");
        sql.append("\n	select 'a980ba45-e286-4e5d-ba39-a28d7a0de3dc' table_uuid,'product_oa_badge_safety_officer' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'安全人员证章' type_name,holder,'永久' useful_life from product_oa_badge_safety_officer ");
        sql.append("\n	union all ");
        sql.append("\n	select '53dc61c1-70d3-493b-b271-b886f723e50d' table_uuid,'product_oa_badge_scene_manage' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'现场管理证章' type_name,holder,'永久' useful_life from product_oa_badge_scene_manage ");
        sql.append("\n	union all ");
        sql.append("\n	select '0761488e-d10f-4c25-8b57-469114d9b7b4' table_uuid,'product_oa_badge_scene_officer' table_name,org_level_uuid,badge_level,badge_type,badge_name,uuid,'现场工人证章' type_name,holder,'永久' useful_life from product_oa_badge_scene_officer ");
        sql.append("\n) d ");
        sql.append("\nleft join ( ");
        sql.append("\n	select b.* from ( ");
        sql.append("\n		select s.uuid,u.user_name borrow_by,m.created_utc_datetime borrow_time,s.return_by,s.return_date,badge_uuid, ");
        sql.append("\n					case when s.return_by is null or s.return_by='' then '借出' else '归还' END badge_status ");
        sql.append("\n		from product_oa_badge_borrow_record m ");
        sql.append("\n		left join product_oa_badge_borrow_detail s on m.uuid=s.record_uuid ");
        sql.append("\n		inner join product_sys_users u on u.user_id=m.created_by ");
        sql.append("\n	) b ");
        sql.append("\n	inner join ( ");
        sql.append("\n		select uuid,max(created_utc_datetime) last_borrow_time ");
        sql.append("\n		from ( ");
        sql.append("\n			select s.uuid,m.created_utc_datetime ");
        sql.append("\n			from product_oa_badge_borrow_record m ");
        sql.append("\n			left join product_oa_badge_borrow_detail s ");
        sql.append("\n			on m.uuid=s.record_uuid ");
        sql.append("\n		) b ");
        sql.append("\n		group by uuid ");
        sql.append("\n	) t ");
        sql.append("\n	on b.uuid=t.uuid and b.borrow_time=t.last_borrow_time ");
        sql.append("\n) b ");
        sql.append("\non d.uuid=b.badge_uuid ");
        sql.append("\ninner join ( ");
        sql.append("\n	select * FROM product_sys_dict where dict_name='badge_common_type' ");
        sql.append("\n) cp on d.badge_type=cp.dict_value ");
        sql.append("\ninner join product_sys_org_levels c on c.uuid=d.org_level_uuid ");

        String queryFilter = queryFilterService.getQueryFilter(fse);
        if (!StringUtils.isEmpty(queryFilter)) {
            sql.append("\nwhere ").append(queryFilter);
        }

        int pageSize = fse.getInteger(CmnConst.PAGE_SIZE) == null ? Integer.MAX_VALUE : fse.getInteger(CmnConst.PAGE_SIZE);
        int curPage = fse.getInteger(CmnConst.CUR_PAGE) == null ? 1 : fse.getInteger(CmnConst.CUR_PAGE);
        DataTableEntity dte = baseDao.listTable(sql.toString(), new Object[]{}, pageSize, curPage);
        dte.getMeta().addAliasTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD,"m");
        dte.getMeta().addAliasTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL, "s");
        dte.getMeta().addAliasField(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD + ".created_utc_datetime","borrow_time");
        baseDao.loadPromptData(dte);
        return dte;
    }

    /**
     * 证章借还记录
     * @param fse
     * @return
     */
    public DataTableEntity getBadgeBorrowAndReturnRecord(FieldSetEntity fse) {
        String tableUUID = fse.getString(CmnConst.FIELD_TABLE_UUID);
        DataTableEntity tableCacheDte = DataPoolCacheImpl.getInstance().getCacheData(CmnConst.CACHE_TABLE, new String[]{tableUUID});
        if (BaseUtil.dataTableIsEmpty(tableCacheDte)) {
            throw new BaseException(BadgeCode.BADGE_GET_BORROW_AND_RETURN_TABLE_NAME_FAIL.getValue(), BadgeCode.BADGE_GET_BORROW_AND_RETURN_TABLE_NAME_FAIL.getText());
        }
        FieldSetEntity tableCacheFse = tableCacheDte.getFieldSetEntity(0);
        String tableName = tableCacheFse.getString(CmnConst.FIELD_TABLE_NAME);
        String badgeUUID = fse.getUUID();
        StringBuilder sql = new StringBuilder(512);
        sql.append("\nselect b.*,org_level_uuid,badge_name,badge_level,badge_type,holder from ( ");
        sql.append("\n	select s.uuid,m.created_by borrow_by,m.created_utc_datetime borrow_time,s.return_by,s.return_date,badge_uuid ");
        sql.append("\n	from product_oa_badge_borrow_record m ");
        sql.append("\n	left join product_oa_badge_borrow_detail s ");
        sql.append("\n	on m.uuid=s.record_uuid ");
        sql.append("\n) b ");
        sql.append("\ninner join ").append(tableName).append(" d ");
        sql.append("\non b.badge_uuid=d.uuid ");
        sql.append("\nwhere d.uuid=?");

        int pageSize = fse.getInteger(CmnConst.PAGE_SIZE) == null ? Integer.MAX_VALUE : fse.getInteger(CmnConst.PAGE_SIZE);
        int curPage = fse.getInteger(CmnConst.CUR_PAGE) == null ? 1 : fse.getInteger(CmnConst.CUR_PAGE);
        DataTableEntity dte = baseDao.listTable(sql.toString(), new Object[]{badgeUUID}, pageSize, curPage);
        dte.getMeta().addAliasTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD, "m");
        dte.getMeta().addAliasTable(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_DETAIL, "s");
        dte.getMeta().addAliasField(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD + ".created_by","borrow_by");
        dte.getMeta().addAliasField(CmnConst.TABLE_PRODUCT_OA_BADGE_BORROW_RECORD + ".created_utc_datetime","borrow_time");
        baseDao.loadPromptData(dte);
        return dte;
    }
}