package foundation.org;

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

import foundation.data.entity.Entity;
import foundation.data.entity.EntitySet;
import foundation.data.object.DataObject;
import foundation.json.IJSONProvider;
import foundation.json.IJSONWriter;
import foundation.persist.NamedSQL;
import foundation.persist.SQLRunner;
import foundation.util.MapList;
import foundation.util.Util;

public class Employee implements IJSONProvider {

	protected static Logger logger;
	private String id;
	private String code;
	private String name;
	private String phone;
	private String email;
	private Org org;
	private MapList<String, Position> positions;
	
	static {
		logger = LogManager.getLogger(Employee.class); 
	}
	
	private Employee() {
		positions = new MapList<String, Position>();
	}

	public static Employee getInstance(String employeeId) throws Exception {
		if (Util.isEmpty(employeeId)) {
			return null;
		}
		
		//1. 加载员工本身
		DataObject dataObject = DataObject.getInstance("md_employee");
		Entity entity = dataObject.getTableEntity(employeeId);
		
		if (entity == null) {
			logger.error("员工不存在：{}", employeeId);
			return null;
		}
		
		Employee employee = new Employee();
		employee.load(entity);
		
		//2. 加载员工关联的岗位
		NamedSQL namedSQL = NamedSQL.getInstance("getEmployeePositions");
		namedSQL.setParam("employeeId", employeeId);
		EntitySet entitySet = SQLRunner.getEntitySet(namedSQL);
		
		for (Entity ponsitionEntity: entitySet) {
			Position position = new Position();
			position.load(ponsitionEntity);
			employee.loadOnePosition(position.getId(), position);
		}
		
		return employee;
	}
	
	public void load(Entity entity) throws Exception {
		id = entity.getString("id");
		code = entity.getString("code");
		name = entity.getString("name");
		phone = entity.getString("phone");
		email = entity.getString("email");
	}

	private void loadOnePosition(String positionId, Position position) {
		if (positions.contains(positionId)) {
			return;
		}
		
		positions.add(positionId, position);
	}
	
	public String getId() {
		return id;
	}

	public String getCode() {
		return code;
	}

	public String getName() {
		return name;
	}
	
	public String getPhone() {
		return phone;
	}

	public String getEmail() {
		return email;
	}

	public void setOrg(Org org) {
		this.org = org;
	}
	
	public Org getOrg() {
		return org;
	}

	public MapList<String, Position> getPositions() {
		return positions;
	}

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

	public void writeJSONBody(IJSONWriter writer) {
		//1. body
		writer.write("id", id);
		writer.write("code", code);
		writer.write("name", name);
		
		//2. positions
		writer.beginArray("positions");
		
		for (Position position: positions) {
			position.writeJSON(writer);
		}
		
		writer.endArray();
	}

}