package com.product.org.admin.service;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Iterator;
import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.product.org.admin.config.CmnConst;
import com.product.common.lang.StringUtils;
import com.product.core.dao.BaseDao;
import com.product.core.entity.DataTableEntity;
import com.product.core.entity.FieldMetaEntity;
import com.product.core.entity.FieldSetEntity;
import com.product.core.exception.BaseException;
import com.product.core.service.support.AbstractBaseService;
import com.product.core.transfer.Transactional;
import com.product.org.admin.service.idel.ICompanyPropertyService;

/**
 * Copyright LX-BASE
 * 
 * @Title: CompanyPropertyService
 * @Project: LX-BASE-SERVER
 * @Date: 2020年5月29日 上午11:07:26
 * @Author:
 * @Description:公司属性配置，对应公司属性表
 */
@Component
public class CompanyPropertyService extends AbstractBaseService implements ICompanyPropertyService {

	@Autowired
	public BaseDao baseDao;

	/**
	 * 公司属性列表
	 * 
	 * @param uuid
	 * @return
	 * @throws BaseException
	 */
	public JSONObject lisCompanytPropperty(String uuid) throws BaseException {
		DataTableEntity dtCompanyProperty = baseDao.listTable(CmnConst.PRODUCT_SYS_COMPANY_PROPERTY, "org_level_uuid=?",
				new Object[] { uuid });
		if (dtCompanyProperty == null || dtCompanyProperty.getRows() == 0) {

			FieldSetEntity fseCompany = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_ORG_LEVELS, uuid, false);
			if (fseCompany == null) {
				throw new BaseException("", "");
			}

			DataTableEntity dtCompanyPropertyMaster = baseDao.listTable(CmnConst.PRODUCT_SYS_COMPANY_PROPERTY_MASTER);
			DataTableEntity dtNew = new DataTableEntity();
			FieldMetaEntity fseMate = new FieldMetaEntity();
			dtNew.setMeta(fseMate);
			fseMate.setTableName(new Object[] { CmnConst.PRODUCT_SYS_COMPANY_PROPERTY });

			for (int i = 0; i < dtCompanyPropertyMaster.getRows(); i++) {
				FieldSetEntity fseCOmpanyPropertyMaster = dtCompanyPropertyMaster.getFieldSetEntity(i);
				FieldSetEntity fseNew = new FieldSetEntity();
				fseNew.setMeta(fseMate);
				fseNew.setValue(CmnConst.ORG_LEVEL_UUID, uuid);
				fseNew.setValue(CmnConst.COMPANY_PROPERTY_MASTER_UUID, fseCOmpanyPropertyMaster.getString("uuid"));
				fseNew.setValue(CmnConst.COMPANY_PROPERTY_MASTER_CODE,
						fseCOmpanyPropertyMaster.getString(CmnConst.COMPANY_PROPERTY_MASTER_CODE));
				dtNew.addFieldSetEntity(fseNew);
			}
			if (dtCompanyPropertyMaster.getRows()>0) {
				baseDao.add(dtNew);
			}
		}

		JSONObject jsonStaffProperty = new JSONObject();
		StringBuilder sqlCommon = new StringBuilder();

		sqlCommon.append(" SELECT ");
		sqlCommon.append(" d.uuid,d.company_property_id,d.org_level_uuid,e.uuid company_property_master_uuid,e.company_property_master_code,d.value,d.effective_utc_datetime, ");
		sqlCommon.append(" e.uuid,e.company_property_master_name,e.prompt_name,e.data_type ");
		sqlCommon.append(" FROM ( ");
		sqlCommon.append(" SELECT a.company_property_id,a.uuid,a.org_level_uuid,a.company_property_master_uuid,a.company_property_master_code,a.value,a.effective_utc_datetime, ");
		sqlCommon.append(" CASE WHEN LOCATE( '|', a.company_property_master_code) THEN REVERSE(SUBSTR(REVERSE(a.company_property_master_code) FROM INSTR(REVERSE( a.company_property_master_code ), '|' ) + 1 )) END AS parent_code ");
		sqlCommon.append(" FROM product_sys_company_property AS a,( ");
		sqlCommon.append(" SELECT company_property_master_uuid,MAX(effective_utc_datetime) AS effective_utc_datetime ");
		sqlCommon.append(" FROM product_sys_company_property WHERE effective_utc_datetime <= NOW() AND org_level_uuid = ? GROUP BY company_property_master_uuid ");
		sqlCommon.append(" UNION ALL ");
		sqlCommon.append(" SELECT company_property_master_uuid,MIN(effective_utc_datetime) AS effective_utc_datetime ");
		sqlCommon.append(" FROM product_sys_company_property WHERE org_level_uuid= ? ");
		sqlCommon.append(" GROUP BY company_property_master_uuid ");
		sqlCommon.append(" HAVING MIN(effective_utc_datetime) > NOW() ");
		sqlCommon.append(" UNION ALL ");
		sqlCommon.append(" SELECT company_property_master_uuid,NULL ");
		sqlCommon.append(" FROM product_sys_company_property WHERE effective_utc_datetime IS NULL AND value IS NULL AND org_level_uuid=? ");
		sqlCommon.append(" GROUP BY company_property_master_uuid ");

		sqlCommon.append(" ) AS c ");
		sqlCommon.append(" WHERE a.company_property_master_uuid = c.company_property_master_uuid AND (a.effective_utc_datetime=c.effective_utc_datetime OR c.effective_utc_datetime IS NULL)  AND a.org_level_uuid = ? ");
		sqlCommon.append(" ) AS d ");
		sqlCommon.append(" RIGHT JOIN product_sys_company_property_master AS e ON d.company_property_master_uuid = e.uuid AND d.company_property_master_code=e.company_property_master_code "); //杜洪波 updateTime 2020-01-06 11:40:00 属性显示异常

		String sqlParent=sqlCommon+" WHERE d.parent_code IS NULL ORDER BY e.sequence";
		String sqlSub=sqlCommon+" WHERE d.parent_code IS NOT NULL ORDER BY e.sequence";

		// 根属性
		DataTableEntity dtParent = baseDao.listTable(sqlParent, new Object[] { uuid, uuid, uuid, uuid });
		// 子属性
		DataTableEntity dtSub = baseDao.listTable(sqlSub, new Object[] { uuid, uuid, uuid, uuid });

		baseDao.listInternationDataTable(dtParent, null);
		baseDao.listInternationDataTable(dtSub, null);

		if (dtParent.getRows() > 0) {
			// 装载属性
			JSONArray json = sysPropertyParent(dtParent, dtSub);
			jsonStaffProperty.put(CmnConst.PRODUCT_SYS_STAFF_PROPERTY, json);
		}
		return jsonStaffProperty;
	}

	/**
	 * 公司属性详情
	 * 
	 * @param org_level_uuid
	 * @param master_uuid
	 * @return
	 * @throws BaseException
	 */
	public DataTableEntity findCompanyProperty(String org_level_uuid, String master_uuid) throws BaseException {

		StringBuilder sql = new StringBuilder();
		sql.append(" SELECT a.uuid, ");
		sql.append(
				" a.company_property_id,a.company_uuid,a.company_property_master_uuid,a.company_property_master_code,a.value, ");
		sql.append(" a.effective_utc_datetime,a.org_level_uuid,b.prompt_name,b.data_type ");
		sql.append(" FROM product_sys_company_property a ");
		sql.append(" LEFT JOIN product_sys_company_property_master b ");
		sql.append(
				" ON a.company_property_master_uuid=b.uuid AND a.company_property_master_code=b.company_property_master_code ");
		sql.append(" WHERE a.org_level_uuid=? and a.company_property_master_uuid=?  ");
		return baseDao.listInternationDataTable(
				baseDao.listTable(sql.toString(), new Object[] { org_level_uuid, master_uuid }), null);
	}

	/**
	 * 公司属性修改
	 * 
	 * @param fse
	 * @return
	 * @throws BaseException
	 */
	@Transactional
	public boolean updateCompanyProperty(FieldSetEntity fse) throws BaseException {
		DataTableEntity dtCompanyProperty = fse.getSubDataTable(CmnConst.PRODUCT_SYS_COMPANY_PROPERTY);
		if (dtCompanyProperty != null && dtCompanyProperty.getRows() > 0) {
			int delCount = 0;
			int rowCount = dtCompanyProperty.getRows();
			for (int i = 0; i < rowCount; i++) {
				FieldSetEntity fseDefaultProperty = dtCompanyProperty.getFieldSetEntity(i);
				String doMethod = fseDefaultProperty.getString("~type~");
				if (doMethod != null && "del".equals(doMethod)) {
					delCount++;
				}
			}
			if (delCount == rowCount) {
				FieldSetEntity fseSaveDefaultProperty = dtCompanyProperty.getFieldSetEntity(0);
				baseDao.executeUpdate(
						"update product_sys_company_property set effective_utc_datetime = NULL,value=NULL where uuid=?",
						new Object[] { fseSaveDefaultProperty.getUUID() });
				dtCompanyProperty.removeFieldSetEntity(0);
			}
			if (dtCompanyProperty.getRows() == 0) {
				return true;
			} else {
				return baseDao.update(dtCompanyProperty);
			}
		} else {
			return true;
		}
	}

	/**
	 * 属性封装根属性
	 * 
	 * @param dataParent
	 * @param dataSub
	 * @return
	 * @throws BaseException
	 */

	public JSONArray sysPropertyParent(DataTableEntity dataParent, DataTableEntity dataSub) throws BaseException {
		JSONArray propertyArray = new JSONArray();
		// 遍历根属性
		for (int i = 0; i < dataParent.getRows(); i++) {
			JSONObject sysProperty = new JSONObject();
			FieldSetEntity fs = dataParent.getFieldSetEntity(i);
			if (!StringUtils.isEmpty(fs.getString("company_property_master_code"))) { // 杜洪波 updateTime 2020-01-05
																						// 14:43:00 树形 列表显示错误
				sysProperty.put("uuid", dataParent.getString(i, "uuid"));
				sysProperty.put(CmnConst.COMPANY_PROPERTY_MASTER_UUID,
						dataParent.getString(i, CmnConst.COMPANY_PROPERTY_MASTER_UUID)); // uuid
				sysProperty.put(CmnConst.COMPANY_PROPERTY_MASTER_CODE,
						dataParent.getString(i, CmnConst.COMPANY_PROPERTY_MASTER_CODE)); // 编码code
				sysProperty.put(CmnConst.VALUE, dataParent.getString(i, CmnConst.VALUE)); // 默认值
				sysProperty.put(CmnConst.EFFECTIVE_UTC_DATETIME,
						dataParent.getString(i, CmnConst.EFFECTIVE_UTC_DATETIME));
				sysProperty.put(CmnConst.ORG_LEVEL_UUID, dataParent.getString(i, CmnConst.ORG_LEVEL_UUID));
				sysProperty.put(CmnConst.DATA_TYPE, dataParent.getString(i, CmnConst.DATA_TYPE)); // 数据类型
				sysProperty.put(CmnConst.PARENT_CODE, dataParent.getString(i, CmnConst.PARENT_CODE)); // 父级编码code
				sysProperty.put(CmnConst.PROMPT_NAME, dataParent.getString(i, CmnConst.PROMPT_NAME)); // 参照名
				sysProperty.put(CmnConst.COMPANY_PROPERTY_MASTER_NAME,
						fs.getString(CmnConst.COMPANY_PROPERTY_MASTER_NAME)); // 属性名称

				// 获取当前根属性的子属性
				JSONArray moduleChild = sysPropertySub(dataSub, fs.getString(CmnConst.COMPANY_PROPERTY_MASTER_CODE));
				sysProperty.put("children", moduleChild);
				propertyArray.add(sysProperty);
			}
		}
		return propertyArray;
	}

	/**
	 * 属性封装后代属性
	 * 
	 * @param dataSub
	 * @param tricode_parent
	 * @return
	 * @throws BaseException
	 */
	public JSONArray sysPropertySub(DataTableEntity dataSub, String tricode_parent) throws BaseException {
		JSONArray propertyArray = new JSONArray();
		// 遍历子属性
		for (int i = 0; i < dataSub.getRows(); i++) {
			JSONObject sysProperty = new JSONObject();
			FieldSetEntity fs = dataSub.getFieldSetEntity(i);
			// 匹配子属性
			if (tricode_parent.equals(dataSub.getString(i, CmnConst.PARENT_CODE))) {
				// 装载属性
				sysProperty.put("uuid", dataSub.getString(i, "uuid"));
				sysProperty.put(CmnConst.COMPANY_PROPERTY_MASTER_UUID,
						dataSub.getString(i, CmnConst.COMPANY_PROPERTY_MASTER_UUID)); // uuid
				sysProperty.put(CmnConst.COMPANY_PROPERTY_MASTER_CODE,
						dataSub.getString(i, CmnConst.COMPANY_PROPERTY_MASTER_CODE)); // 编码code
				sysProperty.put(CmnConst.VALUE, dataSub.getString(i, CmnConst.VALUE)); // 默认值
				sysProperty.put(CmnConst.EFFECTIVE_UTC_DATETIME, dataSub.getString(i, CmnConst.EFFECTIVE_UTC_DATETIME));
				sysProperty.put(CmnConst.ORG_LEVEL_UUID, dataSub.getString(i, CmnConst.ORG_LEVEL_UUID));
				sysProperty.put(CmnConst.DATA_TYPE, dataSub.getString(i, CmnConst.DATA_TYPE)); // 数据类型
				sysProperty.put(CmnConst.PARENT_CODE, dataSub.getString(i, CmnConst.PARENT_CODE)); // 父级编码code
				sysProperty.put(CmnConst.PROMPT_NAME, dataSub.getString(i, CmnConst.PROMPT_NAME)); // 参照名
//				sysProperty.put("company_property_master_name", getPropertyNameLanguage(fs.getSubDataTable("company_property_master_name")));	//属性名称
				sysProperty.put(CmnConst.COMPANY_PROPERTY_MASTER_NAME,
						fs.getString(CmnConst.COMPANY_PROPERTY_MASTER_NAME)); // 属性名称

				JSONArray jsonSub = sysPropertySub(dataSub,
						dataSub.getString(i, CmnConst.COMPANY_PROPERTY_MASTER_CODE));
				if (!jsonSub.isEmpty()) {
					sysProperty.put("children", jsonSub);
				}
				propertyArray.add(sysProperty);
			}
		}
		return propertyArray;
	}

	/**
	 * 	获取属性名称国际化
	 * @param dtPropertyLanguage
	 * @return
	 * @throws BaseException
	 */
	public List<JSONObject> getPropertyNameLanguage(DataTableEntity dtPropertyLanguage) throws BaseException {
		List<JSONObject>listPropertyName=new ArrayList<>();
		if (dtPropertyLanguage!=null && dtPropertyLanguage.getRows()>0) {
			//遍历获取语言代码和国际化值
			forDtPropertyLanguage(dtPropertyLanguage,listPropertyName);
		}
		return listPropertyName;
	}

	private void forDtPropertyLanguage(DataTableEntity dtPropertyLanguage, List<JSONObject> listPropertyName) {
		FieldMetaEntity meta = dtPropertyLanguage.getMeta();
		Object[] fields12 = meta.getFields();
		List<Object> asList = new ArrayList<>();
		asList.addAll(Arrays.asList(fields12));
		Iterator<Object> iterator = asList.iterator();
		for (int i = 0; i < dtPropertyLanguage.getRows(); i++) {
			while (iterator.hasNext()) {
				Object next = iterator.next();
				if (!next.toString().equals("uuid") && !next.toString().equals("language_code")) {
					String string = dtPropertyLanguage.getString(i, next.toString());
					if (!StringUtils.isEmpty(string)) {
						JSONObject propertyName = new JSONObject();
						propertyName.put(next.toString(), string);
						listPropertyName.add(propertyName);
						iterator.remove();
						break;
					}
				} else {
					iterator.remove();
				}
			}
		}
	}
}