package foundation.user;

import java.util.List;
import java.util.Set;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.capacity.Actor;
import foundation.capacity.ActorBucket;
import foundation.capacity.ActorTarget;
import foundation.capacity.ActorType;
import foundation.capacity.ActorsRuntime;
import foundation.capacity.sight.Sight;
import foundation.dao.Filter;
import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.object.DataObject;
import foundation.data.object.EntitySaver;
import foundation.json.IJSONProvider;
import foundation.json.IJSONWriter;
import foundation.json.JSONReader;
import foundation.org.Employee;
import foundation.org.Employees;
import foundation.org.Org;
import foundation.org.OrgAccount;
import foundation.org.Position;
import foundation.token.IOnlineUser;
import foundation.token.IUser;
import foundation.util.CaseInsensitiveSet;
import foundation.util.MapList;
import foundation.variant.provider.DataEvent;
import foundation.variant.provider.VariantProviderType;

public class User extends IUser implements IJSONProvider {
	
	protected static Logger logger;
	private static Set<String> adminSet;
	private String id;
	private String name;
	private String password;
	private boolean passNeedChange;
	private String remark;
	private String employeeId;
	private String orgId;
	private Org org;
	private Employees employees;
	private MapList<String, Position> positions;
	private MapList<String, ActorTarget> actors;
	private ActorsRuntime actorsRuntime;
	private boolean built;
	
	
	static {
		logger = LogManager.getLogger(User.class); 
		adminSet = new CaseInsensitiveSet();
		adminSet.add("admin");
	}
	
	public User() {
		actors = new MapList<String, ActorTarget>();
		actorsRuntime = new ActorsRuntime();
		passNeedChange = false;
		built = false;
	}
	
	public static User getInstance(String userId) {
		UserBucket userBucket = UserBucket.getInstance();
		User user = userBucket.getOrLoad(userId);
		
		return user;
	}
	
	public void load(Entity entity) {
		id = entity.getString("id");
		name = entity.getString("name");
		password = entity.getString("password");
		passNeedChange = entity.getBoolean("pass_need_change", true);
		remark = entity.getString("remark");
		orgId = entity.getString("org_id");
	}

	public void loadHierarchyAndCapacitys() {
		try {
			actorsRuntime.clear();
			
			//1. 加载公司、员工、岗位
			loadHierarchys();
			
			//2. 获取角色列表，创建Runtime
			collectActors();
			
			built = true;
		}
		catch (Exception e) {
			e.printStackTrace();
		}		
	}
	
	private void loadHierarchys() throws Exception {
		//1. 加载用户关联的公司
		org = Org.getInstance(orgId);
		
		//2. 加载用户关联的员工（包含员工关联的岗位）
		employees = Employees.getInstance(id);

		positions = employees.getPositions();
	}

	private void collectActors() throws Exception {
		//1. 获取员工自己的权限
		doCollectActors(ActorType.User, this, id);
		
		//2. 加载员工的角色
		for(Employee employee : employees) {
			doCollectActors(ActorType.Employee, employee, employee.getId());
		}
		
		//3. 加载岗位权限
		if (positions != null) {
			for (Position position: positions) {
				doCollectActors(ActorType.Position, position, position.getId());
			}
		}
		
		//4. 加载授予给公司的角色（以后这里要去掉，先给公司重的管理员，然后再分配）
		if (org != null) {
			List<OrgAccount> orgAccounts = org.getOrgAccounts();
			
			if (orgAccounts != null) {
				for (OrgAccount orgAccount: orgAccounts) {
					doCollectActors(ActorType.OrgAccount, orgAccount, orgAccount.getId());
				}
			}
		}
	}

	private void doCollectActors(ActorType type, Object sender, String targetId) throws Exception {
		//1. 获取 Actor 配置
		DataObject dataObject = DataObject.getInstance("sys_right_actor_target");
		Filter filter = new Filter("target_id", targetId);
		EntitySet entitySet = dataObject.getTableEntitySet(filter);
		
		if (entitySet.isEmpty()) {
			return;
		}
		
		//2. 加载 Actor
		ActorBucket actorBucket = ActorBucket.getInstance();
		
		for (Entity entity: entitySet) {
			ActorTarget target = new ActorTarget();
			target.load(entity);
			
			String actorId = entity.getString("actor_id");
			Actor actor = actorBucket.get(actorId);
			
			if (actor == null) {
				logger.error("actor not exists: {}", actorId);
				continue;
			}
			
			target.setActor(actor);
			
			if (ActorType.Position == type) {
				Position position = (Position)sender;
				target.setPosition(position);
			}
			else if (ActorType.OrgAccount == type) {
				target.loadAccount();
			}
			
			actors.add(target.getId(), target);
			actorsRuntime.loadOne(target);
		}
	}

	public String getPassword() {
		return password;
	}

	public synchronized void chagnePassword(String newPass) throws Exception {
		DataObject dataObject = DataObject.getInstance("sys_user");
		
		EntitySaver saver = dataObject.createEntitySaver(id);
		saver.set("password", newPass);
		saver.set("pass_need_change", "F");
		saver.update();				
		
		password = newPass;
		passNeedChange = false;
	}

	public void checkBuild() {
		if (built) {
			return;
		}
		
		synchronized (this) {
			if (built) {
				return;
			}
			
			loadHierarchyAndCapacitys();
		}
	}
	
	public boolean isOrgFrozen() {
		if (org == null) {
			return false;
		}
		
		return org.isFrozen();
	}
	
	public boolean isAdmin() {
		return adminSet.contains(name);
	}
	
	public String getId() {
		return id;
	}

	public String getName() {
		return name;
	}

	public String getRemark() {
		return remark;
	}

	@Override
	public String getEmployeeId() {
		Employee employee = getCurrentEmployee();
		
		if (employee != null) {
			return employee.getId();
		}
		
		return null;
	}
	
	@Override
	public String getEmployeeName() {
		Employee employee = getCurrentEmployee();
		if (employee != null) {
			return employee.getName();
		}
		return name;
	}

	public String getOrgId() {
		return orgId;
	}
	
	public Org getOrg() {
		return org;
	}

	public Sight getCurrentSight(String onlineCode) throws Exception {
		//1. 如果没有计算角色，先计算角色（如果计算不会执行）
		checkBuild();
		
		//2.
		ActorTarget actorTarget = actorsRuntime.getCurrent(onlineCode);
		
		if (actorTarget == null) {
			return null;
		}
		
		return actorTarget.getSightRuntime();
	}

	public ActorTarget getCurrentActor(String onlineCode) throws Exception {
		//1. 如果没有计算角色，先计算角色（如果计算不会执行）
		checkBuild();
		
		//2.
		return actorsRuntime.getCurrent(onlineCode);
	}
	
	public ActorTarget changeCurrentActor(String onlineCode, String actorId) throws Exception {
		//1. 如果没有计算角色，先计算角色（如果计算不会执行）
		checkBuild();
		
		//2.
		return actorsRuntime.changeCurrent(onlineCode, actorId);
	}

	public Position getPosition(String onlineCode) throws Exception {
		//1. 如果没有计算角色，先计算角色（如果计算不会执行）
		checkBuild();
		
		//2.		
		ActorTarget actorRuntime = actorsRuntime.getCurrent(onlineCode);
		return actorRuntime.getPosition();
	}
	
	public ActorTarget getCapacity(String actorId) {
		return actorsRuntime.get(actorId);
	}
	
	public void saveCapacitys(JSONReader capacitys) {
		actorsRuntime.saveChanges(capacitys);
	}

	public ActorsRuntime getActorsRuntime() {
		return actorsRuntime;
	}

	@Override
	public boolean isAnymous() {
		return false;
	}
	
	@Override
	public String getProviderName() {
		return ProviderName;
	}

	@Override
	public VariantProviderType getProviderType() {
		return VariantProviderType.Transiant;
	}
	
	@Override
	public Object getVariantValue(DataEvent dataEvent, String variantName) {
		if ("user.id".equalsIgnoreCase(variantName)) {
			return id;
		}
		else if ("user.name".equalsIgnoreCase(variantName)) {
			return name;
		}
		else if ("user.employee_id".equalsIgnoreCase(variantName)) {
			Employee employee = getCurrentEmployee();
			
			if (employee != null) {
				return employee.getId();
			}
			
			return id;
		}
		else if ("user.employee_code".equalsIgnoreCase(variantName)) {
			Employee employee = getCurrentEmployee();
			
			if (employee != null) {
				return employee.getCode();
			}
			
			return null;
		}
		else if ("user.employee_name".equalsIgnoreCase(variantName)) {
			Employee employee = getCurrentEmployee();
			
			if (employee != null) {
				return employee.getName();
			}
			
			return name;
		}
		else if ("user.position_id".equalsIgnoreCase(variantName)) {
			Position position = getCurrentPosition();
			
			if (position != null) {
				return position.getId();
			}
			
			return null;
		}
		else if ("user.position_level_field".equalsIgnoreCase(variantName)) {
			Position position = getCurrentPosition();
			
			if (position != null) {
				return position.getLevelField();
			}
			
			return null;
		}
		
		return null;
	}
	
	public Position getCurrentPosition() {
		IOnlineUser onlineUser = IOnlineUser.getInstance();
		ActorTarget actor = actorsRuntime.getCurrent(onlineUser.getCode());
		
		if (actor == null) {
			return null;
		}
		
		Position position = actor.getPosition();
		return position;
	}

	public Employee getCurrentEmployee() {
		IOnlineUser onlineUser = IOnlineUser.getInstance();
		ActorTarget actor = actorsRuntime.getCurrent(onlineUser.getCode());
		
		if (actor == null) {
			return null;
		}
		
		Position position = actor.getPosition();
		if (employees.isEmpty()) {
			return null;
		}
		Employee employee = employees.getEmployeeByPositionId(position.getId());
		return employee;
	}
	
	public static EntitySet calculateUser(String actorTypeCode, String actorId, String id) throws Exception {
		ActorType actorType = ActorType.parse(actorTypeCode);
		DataObject dataObject;
		
		if (ActorType.User == actorType) {
			dataObject = DataObject.getInstance("actor_target_user");
			EntitySet entitySet = dataObject.getBrowseEntitySet(new Filter("sys_user.id", id));
			return entitySet;
		}
		else if (ActorType.OrgAccount == actorType) {
			dataObject = DataObject.getInstance("md_org_account_user");
			EntitySet entitySet = dataObject.getBrowseEntitySet(new Filter("md_org_account.id", id));
			return entitySet;
			
		}
		else if (ActorType.Position == actorType) {
			String positionId = id;
			
			if ("Actor-Sales-Leader".equalsIgnoreCase(actorId)) {
				dataObject = DataObject.getInstance("md_position_hierarchy");
				Entity entity = dataObject.getTableEntity(new Filter("position_id", id));
				positionId = entity.getString("level2");
			}
			else if ("Actor-Sales-Direction".equalsIgnoreCase(actorId)) {
				dataObject = DataObject.getInstance("md_position_hierarchy");
				Entity entity = dataObject.getTableEntity(new Filter("position_id", id));
				positionId = entity.getString("level1");
			}

			dataObject = DataObject.getInstance("md_position_user");
			EntitySet positionSet = dataObject.getBrowseEntitySet(new Filter("md_position_employee.position_id", positionId));
			return positionSet;
		}
		else if(ActorType.Employee == actorType) {
			// 运营, 商务, 总经理, 财务.....
			dataObject = DataObject.getInstance("actor_target_position");
			EntitySet entitySet = dataObject.getBrowseEntitySet(new Filter("sys_right_actor_target.actor_id", actorId));
			return entitySet;
		}
		
		return null;
	}

	@Override
	public void writeJSON(IJSONWriter writer) {
		writer.beginObject();
		writeJSONBody(writer); 
		writer.endObject();
	}

	protected void writeJSONBody(IJSONWriter writer) {
		//1. body
		writer.write("id", id);
		writer.write("name", name);
		writer.write("pass_need_change", passNeedChange);
		
		//2. employee
		if (employees != null) {
			employees.writeJSON(writer);
		}
		
		//3. organization
		if (org != null) {
			org.writeJSON(writer);
		}		
		
		//4. capacity
		writer.beginArray("actors");
		
		for (ActorTarget actor: actorsRuntime) {
			actor.writeJSON(writer);
		}
		
		writer.endArray();
	}
	
}