package com.product.org.admin.service;

import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.util.ArrayList;
import java.util.Date;
import java.util.LinkedList;
import java.util.List;
import java.util.Random;


import com.product.admin.config.SystemCode;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import com.alibaba.druid.util.StringUtils;
import com.product.org.admin.config.CmnConst;
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.permission.PermissionService;
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.org.admin.service.idel.IOperationReplaceService;
import com.product.util.BaseUtil;

/**
 * 
 * Copyright LX-BASE
 * 
 * @Title: OperationReplaceService
 * @Project: LX-BASE-SERVER
 * @Date: 2020年5月29日 上午10:59:05
 * @Author: 郑盟
 * @Description:业务代理设置，对应业务代理表
 */
@Component
public class OperationReplaceService extends AbstractBaseService implements IOperationReplaceService {
	@Autowired
	public BaseDao baseDao;
	@Autowired
	PermissionService permissionService;
	@Autowired
	public QueryFilterService queryFilterService;

	/**
	 * 业务操作代替列表查询
	 */
	public DataTableEntity listReplace(FieldSetEntity fs) throws BaseException {
		String dataFilter = permissionService.getDataFilter(CmnConst.ORG_LEVEL_UUID);
		// 郑盟 2020年12月22日 下午18:34
		String queryFilter = "";
		if (!BaseUtil.dataTableIsEmpty(fs.getSubDataTable("systemSeniorQueryString"))) {
			if (!StringUtils.isEmpty(dataFilter)) {
				queryFilter = " and" + queryFilterService.getQueryFilter(fs);
			} else {
				queryFilter = queryFilterService.getQueryFilter(fs);
			}
		}
		return baseDao.listTable(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF, dataFilter + queryFilter, new String[] {},
				new String[] {}, null, fs.getInteger("pagesize"), fs.getInteger("cpage"));
	}

	/**
	 * 业务操作代替详情查询
	 */
	public FieldSetEntity findReplace(FieldSetEntity fs) throws BaseException {
		return baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF, fs.getString("uuid"), true);

	}

	/**
	 * 业务操作代替新增
	 */
	@Transactional
	public String addReplaceList(FieldSetEntity fs) throws BaseException {
		fs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
		fs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
		String org_level_uuid = fs.getString(CmnConst.ORG_LEVEL_UUID);
		if (StringUtils.isEmpty(org_level_uuid)) {
			fs.setValue(CmnConst.ORG_LEVEL_UUID, SpringMVCContextHolder.getCurrentUser().getOrg_level_uuid());
		}
		//罗鑫2021年3月1日 开始时间不能大于结束时间
		String effective_utc_start_date = fs.getString("effective_utc_start_date");
		if(BaseUtil.strIsNull(effective_utc_start_date)){
			throw new BaseException(SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getValue(), SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getText(),this.getClass(),"public String addReplaceList(FieldSetEntity fs) throws BaseException");
		}
		String effective_utc_end_date = fs.getString("effective_utc_end_date");
		if(!BaseUtil.strIsNull(effective_utc_end_date)) {
			if (BaseUtil.temporalComparison(effective_utc_start_date, effective_utc_end_date)) {
				throw new BaseException(SystemCode.SYSTEM_VALID_TIME_FAIL.getValue(), SystemCode.SYSTEM_VALID_TIME_FAIL.getText(), this.getClass(), "public String addReplaceList(FieldSetEntity fs) throws BaseException");
			}
		}
//			DataTableEntity subDataTable = fs.getSubDataTable(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF_DETAILS);
//		DataTableEntity subDataTable = fs.getSubDataTable(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF_DETAILS);
//		if (subDataTable != null) {
//			for (int i = 0; i < subDataTable.getRows(); i++) {
//				FieldSetEntity subfs = subDataTable.getFieldSetEntity(i);
//				subfs.setValue(CmnConst.ORG_LEVEL_UUID, fs.getString(CmnConst.ORG_LEVEL_UUID));
//				String addReplaceSubRelation = addReplaceSubRelation(subfs, fs.getString(CmnConst.EFFECTIVE_UTC_START_DATE),
//						fs.getString(CmnConst.EFFECTIVE_UTC_END_DATE));
//				if (addReplaceSubRelation == null)
//					return null;
//			}
//		}

		return baseDao.add(fs);
	}

	/**
	 * 业务操作代替修改
	 * 
	 * @param fs
	 * @return boolean
	 */
	@Transactional
	public boolean updateReplaceList(FieldSetEntity fs) throws BaseException {
//		DataTableEntity subDataTable = fs.getSubDataTable(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF_DETAILS);
//		for (int i = 0; i < subDataTable.getRows(); i++) {
//			FieldSetEntity subfs = subDataTable.getFieldSetEntity(i);
//			FieldSetEntity exampleSubFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF_DETAILS,
//					subfs.getString("uuid"), false);
//			if (exampleSubFs == null) {
//				// 新增子表
//				subfs.setValue(CmnConst.ORG_LEVEL_UUID, fs.getString(CmnConst.ORG_LEVEL_UUID));
//				String addReplaceSubRelation = addReplaceSubRelation(subfs, fs.getString(CmnConst.EFFECTIVE_UTC_START_DATE),
//						fs.getString(CmnConst.EFFECTIVE_UTC_END_DATE));
//				if (addReplaceSubRelation == null)
//					return false;
//				continue;
//			}
//			String type = subfs.getString("~type~");
//			if (type != null && "del".equals(type)) {
//				// 删除子表
//				boolean delReplaceSubRelation = delReplaceSubRelation(exampleSubFs);
//				if (!delReplaceSubRelation)
//					return false;
//				continue;
//			}
//			String role_uuid = exampleSubFs.getString(CmnConst.ROLE_UUID);
//			boolean forRoleUuidArr = forRoleUuidArr(role_uuid, i, fs, subfs);
//			// 前端发过啊里的修改后的数据替换人uuid
//			boolean forStaff = forStaff(exampleSubFs, subfs, role_uuid);
//			if (!forStaff||!forRoleUuidArr)
//				return false;
//			subfs.setValue(CmnConst.ROLE_UUID, role_uuid);
//		}
		//罗鑫2021年3月1日 开始时间不能大于结束时间
		String effective_utc_start_date = fs.getString("effective_utc_start_date");
		if(BaseUtil.strIsNull(effective_utc_start_date)){
			throw new BaseException(SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getValue(), SystemCode.SYSTEM_VALID_TIME_WE_FAIL.getText(),this.getClass(),"public boolean updateReplaceList(FieldSetEntity fs) throws BaseException");
		}
		String effective_utc_end_date = fs.getString("effective_utc_end_date");
		if(!BaseUtil.strIsNull(effective_utc_end_date)) {
			if (BaseUtil.temporalComparison(effective_utc_start_date, effective_utc_end_date)) {
				throw new BaseException(SystemCode.SYSTEM_VALID_TIME_FAIL.getValue(), SystemCode.SYSTEM_VALID_TIME_FAIL.getText(), this.getClass(), "public boolean updateReplaceList(FieldSetEntity fs) throws BaseException");
			}
		}
		return updateReplaceTime(fs);
	}

	private boolean forStaff(FieldSetEntity exampleSubFs, FieldSetEntity subfs, String role_uuid) {
		// 修改替换人后staffs表role_uuids的处理
		String replace_staff_uuid = exampleSubFs.getString(CmnConst.ON_BEHALF_STAFF_UUID);
		String staff_uuid_arr = subfs.getString(CmnConst.ON_BEHALF_STAFF_UUID);
		String[] role_uuid_arr = role_uuid.split(",");
		if (!replace_staff_uuid.equals(staff_uuid_arr)) {
			String[] split = replace_staff_uuid.split(",");
			for (int j = 0; j < split.length; j++) {
				String staff_uuid = split[j];
				FieldSetEntity staffsFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staff_uuid, false);
				String[] delArrVal = delArrVal(staffsFs.getString(CmnConst.ROLE_UUIDS).split(","), role_uuid_arr);
				String sqls = "UPDATE product_sys_staffs SET  role_uuids = ? where uuid=?";
				boolean staffUpdate = baseDao.executeUpdate(sqls,
						new String[] { String.join(",", delArrVal), staff_uuid });
				if (!staffUpdate)
					return staffUpdate;
			}
			String[] split2 = staff_uuid_arr.split(",");
			for (int j = 0; j < split2.length; j++) {
				String staff_uuid = split2[j];
				ArrayList<String> list = new ArrayList<>();
				FieldSetEntity staffsFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staff_uuid, false);
				list.add(staffsFs.getString(CmnConst.ROLE_UUIDS));
				list.add(role_uuid);
				String sqls = "UPDATE product_sys_staffs SET  role_uuids = ? where uuid=?";
				boolean staffUpdate = baseDao.executeUpdate(sqls, new String[] { String.join(",", list), staff_uuid });
				if (!staffUpdate)
					return staffUpdate;
			}

		}
		return true;
	}

	private boolean forRoleUuidArr(String role_uuid, int i, FieldSetEntity fs, FieldSetEntity subfs) {
		fs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
		fs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
		String[] role_uuid_arr = role_uuid.split(",");
		String sql = "UPDATE product_sys_role SET effective_start_date = ?,effective_end_date=? where uuid =?";
		for (int j = 0; j < role_uuid_arr.length; j++) {
			boolean executeUpdate = baseDao.executeUpdate(sql, new String[] { fs.getString(CmnConst.EFFECTIVE_UTC_START_DATE),
					fs.getString(CmnConst.EFFECTIVE_UTC_END_DATE), role_uuid_arr[i] });
			if (!executeUpdate)
				return executeUpdate;
			// 保存角色权限表表
			FieldSetEntity fun_permissionFs = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION,
					"role_uuid=?", new String[] { role_uuid_arr[i] }, false);
			fun_permissionFs.setValue(CmnConst.FUNCTION_UUID, subfs.getString(CmnConst.FUNCTION_UUID));
			fun_permissionFs.setValue(CmnConst.BUTTON_UUID, subfs.getString(CmnConst.BUTTON_UUID));
			fun_permissionFs.setValue(CmnConst.ORG_LEVEL_UUID, fs.getString(CmnConst.ORG_LEVEL_UUID));
			fun_permissionFs.setValue(CmnConst.UPDATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
			fun_permissionFs.setValue(CmnConst.UPDATED_UTC_DATETIME, new Date());
			// 保存功能许可表
			boolean permissionUpdate = baseDao.update(fun_permissionFs);
			if (!permissionUpdate)
				return permissionUpdate;
		}
		return true;
	}

	private boolean updateReplaceTime(FieldSetEntity fs) {
		String start_time = fs.getString("effective_start_time_zone");
		// 郑盟 2020年12月17日 下午16:05
		if (StringUtils.isEmpty(start_time)) {
			fs.setValue("effective_start_time_zone", null);
		}
		String end_time = fs.getString("effective_end_time_zone");
		// 郑盟 2020年12月17日 下午16:05
		if (StringUtils.isEmpty(end_time)) {
			fs.setValue("effective_end_time_zone", null);
		}
		return baseDao.update(fs);
	}

	@Transactional
	public boolean deleteReplaceList(FieldSetEntity fs) throws BaseException {
//		String uuid = fs.getString("uuid");
//		FieldSetEntity fss = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF, uuid, true);
//		DataTableEntity subDataTable = fss.getSubDataTable(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF_DETAILS);
		boolean delete = baseDao.delete(CmnConst.PRODUCT_SYS_APPLY_ON_BEHALF, "uuid=?", new String[] { fs.getString("uuid") });
//		for (int i = 0; i < subDataTable.getRows(); i++) {
//			FieldSetEntity detailsFs = subDataTable.getFieldSetEntity(i);
//			boolean delReplaceSubRelation = delReplaceSubRelation(detailsFs);
//			if (!delReplaceSubRelation)
//				return false;
//		}
		return delete;
	}

	/**
	 * 新增子表
	 * 
	 * @param detailsFs
	 * @return
	 * @throws BaseException
	 */
	public String addReplaceSubRelation(FieldSetEntity detailsFs, String effective_start, String effective_end)
			throws BaseException {
		String staff_uuid_arr = detailsFs.getString(CmnConst.ON_BEHALF_STAFF_UUID);
		if (staff_uuid_arr == null) {
			return null;
		}
		String[] split = staff_uuid_arr.split(",");
		String add = null;

		StringBuilder str = new StringBuilder();// 定义变长字符串
		Random random = null;
		try {
			random = SecureRandom.getInstanceStrong();
		} catch (NoSuchAlgorithmException e) {
			e.printStackTrace();
			SpringMVCContextHolder.getSystemLogger().error(e);
			return null;
		}
		// 随机生成源数字，并添知加到字符串
		for (int j = 0; j < 8; j++) {
			if (random != null) {
				str.append(random.nextInt(10));
			}
		}
		FieldSetEntity roleFs = new FieldSetEntity();
		FieldMetaEntity fm = new FieldMetaEntity();
		fm.setTableName(new Object[] { CmnConst.PRODUCT_SYS_ROLE });
		roleFs.setMeta(fm);
		roleFs.setValue("role_description", "业务操作代替创建role_" + str.toString());
		roleFs.setValue(CmnConst.IS_USED, "1");
		roleFs.setValue(CmnConst.ORG_LEVEL_UUID, detailsFs.getString(CmnConst.ORG_LEVEL_UUID));
		roleFs.setValue(CmnConst.EFFECTIVE_START_DATE, effective_start);
		roleFs.setValue(CmnConst.EFFECTIVE_END_DATE, effective_end);

		roleFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
		roleFs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());

		String default_language = SpringMVCContextHolder.getCurrentUser().getDefault_language();
		DataTableEntity languageDt = parseInternational("role_name", default_language, "role_" + str.toString());
		roleFs.addSubDataTable(languageDt);
		String roleAdd = baseDao.add(roleFs);
		// 保存角色权限表表

		FieldSetEntity fun_permissionFs = new FieldSetEntity();
		fm.setTableName(new Object[] { CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION });
		fun_permissionFs.setMeta(fm);
		fun_permissionFs.setValue(CmnConst.ROLE_UUID, roleAdd);
		fun_permissionFs.setValue(CmnConst.FUNCTION_UUID, detailsFs.getString(CmnConst.FUNCTION_UUID));
		fun_permissionFs.setValue(CmnConst.BUTTON_UUID, detailsFs.getString(CmnConst.BUTTON_UUID));
		fun_permissionFs.setValue(CmnConst.ORG_LEVEL_UUID, detailsFs.getString(CmnConst.ORG_LEVEL_UUID));
		fun_permissionFs.setValue(CmnConst.CREATED_BY, SpringMVCContextHolder.getCurrentUser().getUser_id());
		fun_permissionFs.setValue(CmnConst.CREATED_UTC_DATETIME, new Date());
		add = baseDao.add(fun_permissionFs);
		if (add == null) {
			return add;
		}
		// 保存功能许可表
		for (int i = 0; i < split.length; i++) {
			String staff_uuid = split[i];
			FieldSetEntity staffsFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, staff_uuid, false);
			if (staffsFs == null || staffsFs.getString("uuid") == null) {
				return null;
			}
			String role_uuids = staffsFs.getString(CmnConst.ROLE_UUIDS);
			ArrayList<String> list = new ArrayList<>();
			list.add(role_uuids);
			list.add(roleAdd);
			String role_uuidarr = String.join(",", list);
			String sql = "UPDATE product_sys_staffs SET  role_uuids = ? where uuid=?";
			boolean executeUpdate = baseDao.executeUpdate(sql, new String[] { role_uuidarr, staff_uuid });
			// 将新增的权限放进
			if (!executeUpdate)
				return null;
		}
		detailsFs.setValue(CmnConst.ROLE_UUID, roleAdd);
		return add;
	}

	/**
	 * 删除子表以及还原其他表单数据
	 * 
	 * @param detailsFs
	 * @return
	 * @throws BaseException
	 */
	public boolean delReplaceSubRelation(FieldSetEntity detailsFs) throws BaseException {
		String role_uuid = detailsFs.getString(CmnConst.ROLE_UUID);
		String[] role_uuid_arr = role_uuid.split(",");
		String replace_staff_uuid_arr = detailsFs.getString(CmnConst.ON_BEHALF_STAFF_UUID);
		String[] split = replace_staff_uuid_arr.split(",");
		boolean executeUpdate = false;
		for (int i = 0; i < split.length; i++) {
			String replace_staff_uuid = split[i];
			FieldSetEntity replace_staffsFs = baseDao.getFieldSetEntity(CmnConst.PRODUCT_SYS_STAFFS, replace_staff_uuid, false);
			if (null == replace_staffsFs) {
				continue;
			}
			String role_uuids = replace_staffsFs.getString(CmnConst.ROLE_UUIDS);
			String[] role_uuidArr = role_uuids.split(",");
			String[] delArrVal = delArrVal(role_uuidArr, role_uuid_arr);
			String join = String.join(",", delArrVal);

			String sql = "UPDATE product_sys_staffs SET  role_uuids = ? where uuid =?";
			executeUpdate = baseDao.executeUpdate(sql, new String[] { join, replace_staffsFs.getString("uuid") });
			if (!executeUpdate)
				return executeUpdate;
		}

		boolean delPermission = baseDao.delete(CmnConst.PRODUCT_SYS_FUNCTION_PERMISSION,
				BaseUtil.buildQuestionMarkFilter(CmnConst.ROLE_UUID, role_uuid_arr.length, true), role_uuid_arr);
		if (!delPermission)
			return false;
		return baseDao.delete(CmnConst.PRODUCT_SYS_ROLE,
				BaseUtil.buildQuestionMarkFilter("uuid", role_uuid_arr.length, true), role_uuid_arr);
	}

//删除数组中指定元素
	public String[] delArrVal(String[] arr, String[] val) {
		List<String> list = new LinkedList<>();
		for (String str : arr) { // 处理第一个数组,list里面的值为1,2,3,4
			if (!list.contains(str.trim())) {
				list.add(str.trim());
			}
		}
		for (String str : val) { // 如果第二个数组存在和第一个数组相同的值，就删除
			if (list.contains(str.trim())) {
				list.remove(str.trim());
			}
		}
		String[] result = {}; // 创建空数组
		return list.toArray(result); // List to Array
	}

	/**
	 * 国际化封装
	 * 
	 * @param currentField  当前字段
	 * @param language_code 语言代码
	 * @param languageValue 语言内容
	 * @return
	 * @throws BaseException
	 */
	public DataTableEntity parseInternational(String currentField, String language_code, String languageValue)
			throws BaseException {
		FieldSetEntity fseLanguage = new FieldSetEntity();
		fseLanguage.setTableName(currentField);
		fseLanguage.setValue(language_code, languageValue);
		DataTableEntity languageDt = new DataTableEntity();
		languageDt.addFieldSetEntity(fseLanguage);
		return languageDt;
	}
}