package chat.user;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
import chat.medeasy.HttpClientUtil;
|
import chat.module.ModuleLoader;
|
import chat.module.entity.Group;
|
import chat.module.entity.Member;
|
import chat.module.entity.MessageContainer;
|
import chat.module.entity.PrivateFriend;
|
import chat.redis.RedisUtil;
|
import frame.object.data.DataObject;
|
import frame.object.data.Entity;
|
import frame.persist.NamedSQL;
|
|
public class UserStore {
|
|
private static Map<String, User> idUserMap;
|
private static Map<String, User> phoneUserMap;
|
private static Map<String, User> extraUserMap;
|
private static User cachedUser;
|
private static String cachedUserId;
|
|
static {
|
init();
|
}
|
|
private static void init() {
|
idUserMap = new ConcurrentHashMap<String, User>();
|
phoneUserMap = new ConcurrentHashMap<String, User>();
|
extraUserMap = new ConcurrentHashMap<String, User>();
|
}
|
|
public static void loadOne(Entity entity) {
|
String id = entity.getString("id");
|
|
User user = new User(id);
|
user.load(entity);
|
|
addOne(user);
|
}
|
|
public static void addOne(User user) {
|
if (user == null) {
|
return;
|
}
|
|
String id = user.getId();
|
idUserMap.put(id, user);
|
|
String phone = user.getMobile();
|
if (phone != null) {
|
phoneUserMap.put(phone, user);
|
}
|
|
String extra = user.getExtra();
|
if (extra != null) {
|
extraUserMap.put(extra, user);
|
}
|
}
|
|
public static User getOrCreate(User user) throws Exception {
|
String userId = user.getId();
|
String phone = user.getMobile();
|
//String bizid = user.getBizid();
|
String flag = "";
|
|
User userResult = null;
|
|
//1. get user by id
|
if (userId != null) {
|
//1.1 get from cache
|
userResult = getById(userId);
|
|
//1.2 get from database
|
if (userResult == null) {
|
userResult = loadOneUserById(userId);
|
}
|
}
|
//2. get user by phone
|
else if (phone != null) {
|
//2.1 get from cache
|
userResult = getByPhone(phone);
|
|
//2.2 get from database
|
if (userResult == null) {
|
userResult = loadOneUserByPhone(phone);
|
}
|
}
|
|
//3. create new user
|
if (userResult == null) {
|
userResult = user;
|
|
userResult.setDefaultValues();
|
userResult = createOneUser(userResult);
|
|
//调用医视无忧接口，同步创建账号 需等接口调通 希望用调用修改
|
Map<String, String> heads = new HashMap<String, String>();
|
heads.put("Content-Type", "application/json");
|
String json = "{\"doctorMobile\":\""+phone+"\",\"certificateStatus\": 0,\"sourceType\": 2}";
|
HttpClientUtil.execHttpClient(json, "http://api-test.medeasy123.com/doctor/api/save", heads);
|
|
if (!userResult.getRoletype().equals("")) {
|
Map<String, String> userMap = user.getRoleUserId(userResult.getMobile(), userResult.getRoletype());
|
userResult.setExtra(userMap.get("id"));
|
userResult.setName(userMap.get("name"));
|
userResult.setDisplayName(userMap.get("name"));
|
}
|
|
//修改extra
|
int resultRecord = UserStore.modifyUser(userResult, "id", null);
|
|
if (user.getRoletype().equals("1")) {
|
flag = "doctor:id:" + user.getExtra();
|
} else if (user.getRoletype().equals("2")) {
|
flag = "client:id:" + user.getExtra();
|
}
|
String jsonStr = "{\"id\": \""+user.getExtra()+"\", \"name\" : \""+user.getName()+"\", \"portrait\": \""+user.getPortrait()+"\", \"roletype\": \""+user.getRoletype()+"\",\"mobile\": \""+user.getMobile()+"\"}";
|
RedisUtil.createRedisKey(flag, jsonStr);
|
|
UserStore.addOne(user);
|
}
|
|
return userResult;
|
}
|
|
public static User getCachedById(String userId) {
|
if (userId == null) {
|
return null;
|
}
|
|
if (userId.equals(cachedUserId)) {
|
return cachedUser;
|
}
|
|
cachedUserId = userId;
|
cachedUser = idUserMap.get(cachedUserId);
|
|
return cachedUser;
|
}
|
|
public static User getById(String userId) {
|
if (userId == null) {
|
return null;
|
}
|
|
return idUserMap.get(userId);
|
}
|
|
public static User getByExtra(String extra) {
|
if (extra == null) {
|
return null;
|
}
|
|
return extraUserMap.get(extra);
|
}
|
|
private static User getByPhone(String phone) {
|
if (phone == null) {
|
return null;
|
}
|
|
return phoneUserMap.get(phone);
|
}
|
|
private static User loadOneUserById(String userId) throws Exception {
|
if (userId == null) {
|
return null;
|
}
|
|
NamedSQL namedSQL = NamedSQL.getInstance("getOneUserById");
|
namedSQL.setParam("id", userId);
|
Entity entity = namedSQL.getEntity();
|
|
if (entity == null) {
|
return null;
|
}
|
|
User user = new User(userId);
|
user.load(entity);
|
|
return user;
|
}
|
|
private static User loadOneUserByPhone(String phone) throws Exception {
|
if (phone == null) {
|
return null;
|
}
|
|
NamedSQL namedSQL = NamedSQL.getInstance("getOneUserByPhone");
|
namedSQL.setParam("phone", phone);
|
Entity entity = namedSQL.getEntity();
|
|
if (entity == null) {
|
return null;
|
}
|
|
User user = new User(null);
|
user.load(entity);
|
|
return user;
|
}
|
|
public static User createOneUser(User user) {
|
String flag = "";
|
MessageContainer messageContainer;
|
try {
|
DataObject dataObject = DataObject.getInstance("usr");
|
|
Entity entity = dataObject.newEntity();
|
user.pushTo(entity);
|
dataObject.insertToDataBase(entity);
|
|
UserStore.addOne(user);
|
|
//1.创建chatspace 单聊
|
PrivateFriend privateGroup = new PrivateFriend("医生助理", user);
|
privateGroup.createPrivateFriend();
|
ModuleLoader.getPrivateFriendBucket().addOne(privateGroup.getId(), privateGroup);
|
|
//2.创建member
|
List<String> userList = new ArrayList<String>();
|
userList.add(user.getId());
|
userList.add("user004");
|
messageContainer = ModuleLoader.getPrivateFriendBucket().getOne(privateGroup.getId());
|
messageContainer.addInitMembers(privateGroup.getId(), userList);
|
|
//3?.需要发一条消息暂时需不需要
|
|
//4.创建frienship
|
user.createInitFrieldShip(user);
|
|
return user;
|
} catch(Exception e) {
|
return null;
|
}
|
}
|
|
public static int modifyUser(User user, String pointColumn) {
|
return modifyUser(user, pointColumn, null);
|
}
|
|
/**
|
*
|
* @param userId
|
* @return
|
*/
|
public static int modifyUser(User user, String pointColumn, Map<String, String> excludeColumn) {
|
if (user == null) {
|
return -2;
|
}
|
|
try {
|
DataObject dataObject = DataObject.getInstance("usr");
|
Entity entity = dataObject.newEntity();
|
user.pushToModify(entity);
|
int result = dataObject.updateToDateBaseWill(entity, pointColumn, excludeColumn);
|
|
return result;
|
} catch (Exception e) {
|
return 0;
|
}
|
}
|
|
public static boolean contains(String userId) {
|
if (userId == null) {
|
return false;
|
}
|
|
return idUserMap.containsKey(userId);
|
}
|
|
public static Map<String, User> getIdUserMap() {
|
return idUserMap;
|
}
|
|
}
|
