package com.product.administration.service;

import com.alibaba.fastjson.JSONObject;
import com.product.admin.service.PublicService;
import com.product.administration.controller.CooperateModelController;
import com.product.common.lang.StringUtils;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.service.support.AbstractBaseService;
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.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicReference;

/**
 * Copyright © 6c
 *
 * @Date: 2022-03-17 17:37
 * @Author: 6c
 * @Description:
 */
@Service
public class CooperateModelService extends AbstractBaseService implements CooperateModelController.ICooperateModelService {
    @Autowired
    public BaseDao baseDao;


    @Autowired
    PublicService publicService;

    /**
     * 列表-模板
     *
     * @param fse type    0-个人模板，1-共享模板，2-公共模板
     * @return
     */
    public DataTableEntity listModel(FieldSetEntity fse) {
        String curUserID = SpringMVCContextHolder.getCurrentUserId();
        StringBuilder sql = new StringBuilder(256);
        sql.append("\nselect uuid,name,date_format(created_utc_datetime,'%Y-%m-%d %H:%i:%s') created_utc_datetime,created_by,type from (");
        sql.append("\n    select uuid,name,created_utc_datetime,created_by,0 type from product_oa_cooperates_template where created_by=? and created_by<>1");
        sql.append("\n    union all");
        sql.append("\n    select uuid,name,created_utc_datetime,created_by,1 type from product_oa_cooperates_template where find_in_set(?,share_user)>0 and created_by<>1 and created_by<>?");
        sql.append("\n    union all");
        sql.append("\n    select uuid,name,created_utc_datetime,created_by,2 type from product_oa_cooperates_template where created_by=1");
        sql.append("\n) t");
        sql.append("\norder by created_utc_datetime desc");
        return baseDao.listTable(sql.toString(), new Object[]{curUserID, curUserID, curUserID});
    }

    /**
     * 查询模板详情
     *
     * @param fse
     * @return
     */
    @Transactional
    @Override
    public void saveTemplateInfo(FieldSetEntity fse) {
        if (!StringUtils.isEmpty(fse.getUUID())) {
            delete("product_oa_cooperate_flow_node_template", "master_uuid=?", new String[]{fse.getUUID()});
        }
        publicService.saveFieldSetEntity(fse);
    }

    /**
     * 查询模板详情
     *
     * @param fse
     * @return
     */
    public FieldSetEntity findTemplateInfo(FieldSetEntity fse) {
        fse = getBaseDao().getFieldSetEntity(fse.getTableName(), fse.getUUID(), false);
        StringBuilder sql = new StringBuilder();
        sql.append(" SELECT ");
        sql.append(" case when grade=1 then receiver else concat(tricode,'-',receiver) end as `code`, ");
        sql.append(" receiver,");
        sql.append(" sender , grade,");
        sql.append(" uuid() `key`,user_id id, ");
        sql.append(" tricode, ");
        sql.append(" b.user_name label ");
        sql.append(" FROM ");
        sql.append(" product_oa_cooperate_flow_node_template a ");
        sql.append(" JOIN product_sys_users b ON a.receiver=b.user_id  ");
        sql.append(" WHERE ");
        sql.append(" master_uuid =? ");
        sql.append(" ORDER BY ");
        sql.append(" grade ");
        DataTableEntity subData = getBaseDao().listTable(sql.toString(), new Object[]{fse.getUUID()});
        if (!DataTableEntity.isEmpty(subData)) {
            SystemUser currentUser = SpringMVCContextHolder.getCurrentUser();
            AtomicBoolean flag = new AtomicBoolean(false);
            AtomicReference<String> sponsorUser = new AtomicReference<>();
            AtomicBoolean gradeTop = new AtomicBoolean(false);
            fse.setValue("document_process", BaseUtil.dataTableToTreeData(subData, "code", "tricode", f -> {
                JSONObject jsonObject = f[0];
                //层级
                String grade = jsonObject.getString("grade");
                //接收人
                String receiver = jsonObject.getString("receiver");
                if ("1".equals(grade)) {
                    gradeTop.set(true);
                }
                if ("1".equals(grade) && !receiver.equals(currentUser.getUser_id())) {
                    flag.set(true);
                    sponsorUser.set(receiver);
                }
                if (flag.get()) {
                    //模板发起人不是当前人
                    if ("1".equals(grade)) {
                        receiver = currentUser.getUser_id() + "";
                        jsonObject.put("receiver", currentUser.getUser_id());
                        jsonObject.put("label", currentUser.getUser_name());
                        jsonObject.put("sender", currentUser.getUser_id());
                    }
                    String tricode = jsonObject.getString("tricode");
                    if (!StringUtils.isEmpty(tricode)) {
                        // 层级 2
                        if (tricode.indexOf("-") == -1) {
                            jsonObject.put("sender", currentUser.getUser_id());
                        }
                        tricode = currentUser.getUser_id() + tricode.substring(sponsorUser.get().length());
                        jsonObject.put("tricode", tricode);
                    }
                    jsonObject.put("code", "1".equals(grade) ? receiver : tricode + "-" + receiver);
                }

            }, true));
            if (!gradeTop.get()) {
                fse.remove("document_process");
            }
        }
        return fse;
    }


}