package chat.user;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;

import chat.module.ConcurrentMapList;
import chat.module.ModuleLoader;
import chat.module.UserMessageList;
import chat.module.entity.FriendRequest;
import chat.module.entity.FriendShip;
import chat.module.entity.MessageContainer;
import chat.module.entity.MessageRecord;
import chat.module.entity.MessageRelation;
import chat.module.entity.MessageType;
import chat.module.entity.PrivateFriend;
import chat.module.entity.PublishOperator;
import chat.module.friendcircle.FriendCircle;
import chat.server.call.IJSONWriter;
import chat.server.call.IJsonProvider;
import chat.server.im.DataPool;
import chat.server.im.IMTopic;
import chat.util.MessageShardingUtil;
import cn.wildfirechat.proto.ProtoConstants;
import cn.wildfirechat.proto.WFCMessage;
import cn.wildfirechat.proto.WFCMessage.HandleFriendRequest;
import cn.wildfirechat.proto.WFCMessage.Message;
import cn.wildfirechat.proto.WFCMessage.Message.Builder;
import frame.object.data.Entity;
import frame.object.data.ID;
import frame.persist.NamedSQL;
import frame.persist.SQLRunner;

public class User implements IJsonProvider {

	private String id;
	private String mobile;
	private String name;
	private String displayName;
	private String portrait;
	private String password;
	private int gender;
	private boolean stranger;
	private String roletype;
	private long timestamp;
	private String bizid;
	private String extra;
	private String rejectreason;
	
	private WFCMessage.UserResult userResult;
    private Set<Client> clientSet;
    
	protected ConcurrentMapList<List<FriendShip>> friendShipList;
	protected ConcurrentMapList<List<FriendShip>> pushFriendList;
	//protected ConcurrentMapList<FriendShip> pushFriendList;
	private UserMessageList messageList;
	private FriendCircle friendCircle;
	
	public User() {}
	
    public User(String id) {
    	clientSet = new HashSet<Client>();
    	friendShipList = new ConcurrentMapList<List<FriendShip>>();
    	pushFriendList = new ConcurrentMapList<List<FriendShip>>();
    	messageList = new UserMessageList();
    	friendCircle = new FriendCircle();
    }

	public static User getInstance(String userId) {
		User result = UserStore.getById(userId);
		return result;
	}
	
	public static User setUserInfo(NotifyContentDetail contentDetail) {
		String rejectReasonMerge = "";
		User user = new User();
		user.setId(ID.newValue());
		user.setBizid(contentDetail.getDoctorId());
		user.setName(contentDetail.getName());
		user.setDisplayName(contentDetail.getName());
		user.setPortrait(contentDetail.getPortrait());
		user.setMobile(contentDetail.getMobile());
		user.setRoletype(contentDetail.getRoletype());
		user.setExtra(contentDetail.getDoctorId());
		if (contentDetail.getRejectreason() == null) {
			rejectReasonMerge = "";
		} else {
			for (String rejectReason : contentDetail.getRejectreason()) {
				 rejectReasonMerge = rejectReasonMerge + rejectReason + "#separate#";
			}			
		}

		user.setRejectreason(suitableStr(rejectReasonMerge, "#separate#"));
		return user;
	}
	
	public static String suitableStr(String body, String sep) {
		String result = "";
		if (body == null || body.equals("")) {
			return "";
		}
		int index = body.lastIndexOf(sep);
		result = body.substring(0, index);
		return result;
	}
	
	public static User getInstance(Client client) throws Exception {
		String userId = client.getUserId();
		
		if (userId == null) {
			return null;
		}
		
		NamedSQL namedSQL = NamedSQL.getInstance("getOneUserByClientId");
		namedSQL.setParam("clientId", client.getId());
		
		Entity entity = namedSQL.getEntity();
		
		User user = new User(userId);
		user.load(entity);
		
		return user;
	}

	public void createInitFrieldShip(User user) {
		// TODO Auto-generated method stub
		try {
			 FriendShip friendShip = new FriendShip();
			 User friend =  UserStore.getById("user004");
			
			 friendShip = new FriendShip(user, "user004", "open");
			 friendShip.addFriendShipToDataBase();
			 user.addOneFrieldShip(user.getId(), friendShip);
			
			 friendShip = friendShip.getReverseInstance();
			 friend.addOneFrieldShip(friendShip.getUserid(), friendShip);
		} catch(Exception e) {
			 e.printStackTrace();
		}
	}
	
	public void modifyFrieldShipStatus(FriendShip friendShip, String status) {
		try {
			 friendShip.updateFriendShipToDataBase("open");
		} catch(Exception e) {
			 e.printStackTrace();
		}
	}
	
    public Client getClient(String userId) {
    	Client clientReturn = null;
    	if (userId == null || ("").equals(userId)) {
    		return clientReturn;
    	}
    	for (Client client:clientSet) {
    		 if (client.getUser().getId().equals(userId)) {
    			 clientReturn = client;
    			 break;
    		 }
    	}
		return clientReturn;
	}

	public void load(DataPool dataPool) {
		try {
			 mobile = dataPool.getString("mobile");
			 if (mobile == null) {
				 mobile = dataPool.getPhone();
			 }
		} catch (Exception e) {
			 mobile = dataPool.getPhone();
		} finally {
			if (dataPool.getString("roletype") != null) {
				if (dataPool.getString("roletype").equals("doctor")) {
					roletype = "1";
				}
				else if  (dataPool.getString("roletype").equals("")) {
					roletype = "2";
				}
			}
		}
	}
	
	public void reLoad(User user) {
		
		name = user.getName();
		portrait = user.getPortrait();
		roletype = user.getRoletype();
		mobile = user.getMobile();
		displayName = user.getDisplayName();
		gender = user.getGender();
		rejectreason = user.getRejectreason();
			
	}
	
	public void load(Entity entity) {
		if (entity == null) {
			return;
		}
		
		id = entity.getString("id");
		mobile = entity.getString("mobile");
		name = entity.getString("name");
		displayName = entity.getString("displayName");
		portrait = entity.getString("portrait");
		password = entity.getString("password");
		stranger = entity.getBoolean("stranger", false);
		roletype = entity.getString("roletype");
		extra = entity.getString("extra");
		bizid = entity.getString("bizid");
		rejectreason = entity.getString("rejectreason");
		
		userResult = null;
	}
	
	//将没有接收到的消息放入消息队列中
	public void addOneUnreceivedMessage(MessageRelation messageRelation) {
		// TODO Auto-generated method stub
		if (messageRelation == null) {
			return;
		}
		
		if (MessageType.unreceived == MessageType.parse(messageRelation.getStatuscode())) {
			messageRelation.getMessageRecord().setMessage(createOneMessage(messageRelation.getMessageRecord(), messageRelation));
			messageList.getMessageList().add(messageRelation);
			
		} 
		else if (MessageType.received == MessageType.parse(messageRelation.getStatuscode())){
			messageList.setPos(messageList.getPos() + 1);
		}
	}
	
	public WFCMessage.Message createOneMessage(MessageRecord message, MessageRelation messageRelation) {
		WFCMessage.Message messageWFC = null;
		
		try {
			 WFCMessage.Message.Builder builder = WFCMessage.Message.newBuilder();
			 builder.setMessageId(message.getMessageid());
			 builder.setServerTimestamp(message.getTimestamp());
			 builder.setFromUser(message.getSenderId());
			 
			 WFCMessage.Conversation.Builder cb = WFCMessage.Conversation.newBuilder();
			 cb.setType(messageRelation.getType());
			 cb.setTarget(messageRelation.getTargetid());
			 cb.setLine(messageRelation.getLine());
			 builder.setConversation(cb.build());
			 
			 WFCMessage.MessageContent.Builder contentBuilder = WFCMessage.MessageContent.newBuilder();
			 contentBuilder.setType(message.getType());
			 contentBuilder.setSearchableContent(message.getContent());
			 contentBuilder.setMediaType(0);
			 contentBuilder.setPersistFlag(message.getPersistflag());
	         contentBuilder.setExpireDuration(0);
	         contentBuilder.setMentionedType(0);
	         
	         WFCMessage.MessageContent messageContent = contentBuilder.build();
	         
	         builder.setContent(messageContent);
	         
	         messageWFC = builder.build();
			 
		} catch(Exception e) {
			 e.printStackTrace();
		}
		return messageWFC;
	}	

	public void addOneFrieldShip(String friendId, FriendShip friendShip) {
		List<FriendShip> friendShipS = friendShipList.get(friendId);
		if (friendShipS == null) {
			friendShipS = new ArrayList<FriendShip>();
		}
		
		friendShipS.add(friendShip);
		friendShipList.addMapList(friendId, friendShipS);
	}
	
	public void addOnePushFriendShip(String friendId, FriendShip friendShip) {
		List<FriendShip> friendShipS = pushFriendList.get(friendId);
		if (friendShipS == null) {
			friendShipS = new ArrayList<FriendShip>();
		}
		
		friendShipS.add(friendShip);
		pushFriendList.addMapList(friendId, friendShipS);
	}
	
	//增加朋友请求消息
	public void addUserFriendShip(String userid, WFCMessage.AddFriendRequest request) {
		long[] head = new long[1];
		
		WFCMessage.FriendRequest.Builder friendRequestBuilder = WFCMessage.FriendRequest.newBuilder();
		friendRequestBuilder.setFromUid(userid);
		friendRequestBuilder.setToUid(request.getTargetUid());
		friendRequestBuilder.setReason(request.getReason());
		friendRequestBuilder.setStatus(ProtoConstants.FriendRequestStatus.RequestStatus_Sent);
		friendRequestBuilder.setToReadStatus(false);
		friendRequestBuilder.setUpdateDt(System.currentTimeMillis());
		WFCMessage.FriendRequest friendRequest = friendRequestBuilder.build();
		
		FriendShip friendShip = new FriendShip(UserStore.getById(userid), request.getTargetUid(), "apply");
		friendShip.setFriendRequest(friendRequest);
		
		friendShip.addFriendShipToDataBase();
		
		UserStore.getById(userid).addOnePushFriendShip(userid, friendShip);
		UserStore.getById(request.getTargetUid()).addOnePushFriendShip(request.getTargetUid(), friendShip);
		
		head[0] = System.currentTimeMillis();
		//发通知
		FriendRequest friendData = new FriendRequest(userid, request.getTargetUid());
		ModuleLoader.getImBusinessScheduler().execute(() -> friendData.notifyOneFriendRequest(IMTopic.NotifyFriendRequestTopic, request, head[0], userid));
	}
	
	//添加朋友的对方，接受请求
	public void handleFriendRequest(String userId, WFCMessage.HandleFriendRequest request, WFCMessage.Message.Builder msgBuilder, long[] heads) {
		// TODO Auto-generated method stub
		if (request.getStatus() != ProtoConstants.FriendRequestStatus.RequestStatus_Accepted) {
			return;
		}
		
		List<FriendShip> friendShipList = getApplyFriendShip(userId);
		FriendShip loadFriendShip = null;
		MessageContainer messageContainer;
		
		WFCMessage.FriendRequest existRequest = null;
		
		try {
			 for (FriendShip friendShip : friendShipList) {
			 	  if (friendShip.getUserid().equals(request.getTargetUid()) && friendShip.getFriendid().equals(userId)) {
			 	 	  existRequest = friendShip.getFriendRequest();
			 	 	  loadFriendShip = friendShip;
			 	 	  break;
			 	  }
			 }
			 
			 if (existRequest != null) {
			 	 existRequest = existRequest.toBuilder().setStatus(request.getStatus()).setUpdateDt(System.currentTimeMillis()).build();
			 	 
			 	 //1.创建chatspace 单聊
			 	 PrivateFriend privateGroup = new PrivateFriend(UserStore.getById(request.getTargetUid()).getName() + "--" + UserStore.getById(userId).getName(), UserStore.getById(request.getTargetUid()));
			 	 privateGroup.createPrivateFriend();
			 	 ModuleLoader.getPrivateFriendBucket().addOne(privateGroup.getId(), privateGroup);
			 	 
			 	 //2.创建member
			 	 List<String> userList = new ArrayList<String>();
			 	 userList.add(request.getTargetUid());
			 	 userList.add(userId);
			 	 messageContainer = ModuleLoader.getPrivateFriendBucket().getOne(privateGroup.getId());
			 	 messageContainer.addInitMembers(privateGroup.getId(), userList);
			 	 
			 	 //3.修改frienship中的状态，将申请(apply)状态修改成通过(open)状态
			 	 modifyFrieldShipStatus(loadFriendShip, "open");
			 	 
			 	 //4.将申请状态中的记录删除
			 	 delApplyFriendShip(request.getTargetUid());
			 	 getApplyFriendShip(userId);
			 	 
			 	 //5.将双方加入friendship关系中
			 	 addOneFrieldShip(request.getTargetUid(), loadFriendShip);
                 heads[0] = System.currentTimeMillis();
			 	 loadFriendShip = loadFriendShip.getReverseInstance();
				 addOneFrieldShip(userId, loadFriendShip);
				 heads[1] = System.currentTimeMillis();
				 
                 msgBuilder.setConversation(WFCMessage.Conversation.newBuilder().setTarget(userId).setLine(0).setType(ProtoConstants.ConversationType.ConversationType_Private).build());
                 msgBuilder.setContent(WFCMessage.MessageContent.newBuilder().setType(1).setSearchableContent(existRequest.getReason()).build());				 
			 }
		} catch(Exception e) {
			 e.printStackTrace();
		}
	}

	public void pushTo(Entity entity) throws Exception {
		String id = ID.newValue();
		entity.set("id", id);
		setId(id);
		entity.set("mobile", mobile);
		entity.set("name", name);
		entity.set("displayName", displayName);
		entity.set("portrait", portrait);
		entity.set("password", password);
		entity.set("roletype", roletype);
		entity.set("extra", extra);
		entity.set("bizid", bizid);
		entity.set("rejectreason", rejectreason);
	}
	
	public void pushToModify(Entity entity) throws Exception {
		entity.set("id", id);
		entity.set("mobile", mobile);
		entity.set("name", name);
		entity.set("displayName", displayName);
		entity.set("portrait", portrait);
		entity.set("password", password);
		entity.set("roletype", roletype);
		entity.set("extra", extra);
		entity.set("bizid", bizid);
		entity.set("rejectreason", rejectreason);
	}	
	
	public void updateDoctorId() throws Exception {
		
	}
	
	public WFCMessage.UserResult toWFCUserResult() {
		if (userResult != null) {
			return userResult;
		}
		
		WFCMessage.User wfcUser = toWFCUser();
		
		WFCMessage.UserResult.Builder resultBuilder = WFCMessage.UserResult.newBuilder();
        resultBuilder.setUser(wfcUser);
        resultBuilder.setCode(ProtoConstants.UserResultCode.Success);
        
        userResult = resultBuilder.build();
        
        return userResult;
	}
	
	public WFCMessage.User toWFCUser() {
		WFCMessage.User.Builder userBuilder = WFCMessage.User.newBuilder();
		userBuilder.setUid(id);
		userBuilder.setName(name);
		userBuilder.setDisplayName(displayName);
		
		userBuilder.setPortrait(portrait);
		userBuilder.setMobile(mobile);
		
		if (extra != null && !extra.equals("")) {
			userBuilder.setExtra(extra);
		} else {
			userBuilder.setExtra("");
		}
		
		return userBuilder.build();
	}

	/**
	  * 将消息关系挂到接收客户下面
	 * @param relation
	 * private UserMessageList messageList;
	 */
	public void pushOneMessageRelation(MessageRelation relation) {
		// TODO Auto-generated method stub
		this.messageList.getMessageList().add(relation);
	}

	public List<Message> getUnreceivedMessageList() throws Exception {
		List<Message> result = new ArrayList<WFCMessage.Message>();
		
		int pos = messageList.getPos() ; 
		int size = messageList.getMessageList().size();
		
		//add one message
		for (int i = pos; i < size; i++) {
			//1.
			MessageRelation relation = messageList.getMessageList().get(i);
			result.add(relation.getMessageRecord().getMessage());
			
			//2. update state
			relation.updateStatusToDataBase(relation, "received");
			
			//3.修改已读下标指针
			messageList.setPos(pos+1);
		}
		
		return result;
	}

	public void addClient(Client client) {
		for (Client clientP: clientSet) {
			 if (clientP.getId().equals(client.getId())) {
				 clientSet.remove(clientP);
				 break;
			 }
		}
		clientSet.add(client);
	}

	public void setDefaultValues() throws Exception {
		//1. name 
		NamedSQL namedSQL = NamedSQL.getInstance("nextval");
		namedSQL.setParam("name", "usr");
		int value = SQLRunner.getInteger(namedSQL);
		
		name = "User" + value;
		displayName = name;
		
		//2. 
		portrait = "http://cdn2.wildfirechat.cn/robot.png";

		//3.
		stranger = true;
		timestamp = System.currentTimeMillis();
//		if (!roletype.equals("")) {
//			this.extra = getRoleUserId(mobile, roletype);
//		}
	}
	
	public Map<String, String> getRoleUserId(String phone, String roleType) throws Exception {
		String strSQL = "";
		Map<String, String> returnMap = new HashMap<String, String>();
		if (roletype.equals("1")) {
			strSQL = " select id, doctor_name as name from medo_doctor where doctor_mobile = '"+phone+"' ";
		} else if (roletype.equals("2")) {
			strSQL = " select id, client_name from as name from medeasy_client.mecl_client where mobile = '"+phone+"' ";
		}
		
		PreparedStatement st = ModuleLoader.connDB.prepareStatement(strSQL);
		ResultSet rs = st.executeQuery();
		while(rs.next()){
			 returnMap.put("id", rs.getString("id"));
			 returnMap.put("name", rs.getString("name"));
		}
		return returnMap;
	}
	
	/**
	 * 
	 * @param 查询关键字
	 * @param fuzzy  0  模糊查询
	 * @param page  页数
	 * @author hefeixia 20210216
	 * @return
	 */
	public List<cn.wildfirechat.proto.WFCMessage.User> searchUser(String keyword, int searchType, int page) {
		// TODO Auto-generated method stub
		ArrayList<WFCMessage.User> outUser = new ArrayList<WFCMessage.User>();
		
		Map<String, User> userAll = UserStore.getIdUserMap();
		
		for (User user : userAll.values()) {
			 if (user.name.contains(keyword) || user.mobile.contains(keyword) || user.displayName.contains(keyword)) {
				 WFCMessage.User.Builder builder = WFCMessage.User.newBuilder();
				 builder.setUid(user.getId());
				 builder.setName(user.getName());
				 builder.setPortrait(user.getPortrait());
				 builder.setMobile(user.getMobile());
				 builder.setDisplayName(user.getDisplayName());
				 builder.setExtra(user.getExtra());
				 
				 WFCMessage.User usr = builder.build();
				 outUser.add(usr);
			 }
		}
		
		return outUser;
	}	
	
	@Override
	public void writeJSONObject(IJSONWriter writer) {
		writer.beginObject();
		writeJSONData(writer);
		writer.endObject();
	}

	@Override
	public void writeJSONData(IJSONWriter writer) {
		writer.write("userId", id);
		writer.write("name", name);
		writer.write("displayName", displayName);
		writer.write("portrait", portrait);
		writer.write("gender", gender);
		writer.write("mobile", mobile);
		writer.write("roletype", roletype);
		writer.write("extra", extra);
		writer.write("email", "");
		writer.write("roletype", 1);
		writer.write("bizid", bizid);
		writer.write("rejectreason", rejectreason);
	}
	
	@Override
	public int hashCode() {
		if (id == null) {
			return 0;
		}
		
		return id.hashCode();
	}

	public String getDisplayName() {
		return displayName;
	}

	public void setDisplayName(String displayName) {
		this.displayName = displayName;
	}

	public int getGender() {
		return gender;
	}

	public void setGender(int gender) {
		this.gender = gender;
	}

	public void setId(String id) {
		this.id = id;
	}

	public void setMobile(String mobile) {
		this.mobile = mobile;
	}

	public void setName(String name) {
		this.name = name;
	}

	public void setPortrait(String portrait) {
		this.portrait = portrait;
	}

	public void setPassword(String password) {
		this.password = password;
	}
	
	public List<FriendShip> getFriendship(String userId) {
		List<FriendShip> result = friendShipList.get(userId);
		return result;
	}
	
	public List<FriendShip> getApplyFriendShip(String userId) {
		List<FriendShip> result = pushFriendList.get(userId);
		return result;		
	}
	
	public void delApplyFriendShip(String userId) {
		pushFriendList.delete(userId);
	}

	public String getExtra() {
		return extra;
	}

	public void setExtra(String extra) {
		this.extra = extra;
	}
	
	public String getId() {
		return id;
	}

	public String getName() {
		return name;
	}

	public String getPassword() {
		return password;
	}

	public String getPortrait() {
		return portrait;
	}

	public String getMobile() {
		return mobile;
	}

	public Set<Client> getClientSet() {
		return clientSet;
	}

	public void notify(PublishOperator operator) {

	}

	public boolean isStranger() {
		return stranger;
	}

	public void setStranger(boolean stranger) {
		this.stranger = stranger;
	}

	public long getUpdateDt() {
		return timestamp;
	}

	public String getRejectreason() {
		return rejectreason;
	}

	public void setRejectreason(String rejectreason) {
		this.rejectreason = rejectreason;
	}

	public String getBizid() {
		return bizid;
	}

	public void setBizid(String bizid) {
		this.bizid = bizid;
	}

	public String getRoletype() {
		return roletype;
	}

	public void setRoletype(String roletype) {
		this.roletype = roletype;
	}
	
	public FriendCircle getFriendCircle() {
		return friendCircle;
	}

}