package com.product.admin.service;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.product.admin.config.CmnConst;
|
import com.product.admin.config.SystemCode;
|
import com.product.common.lang.StringUtils;
|
import com.product.core.cache.util.RedisUtil;
|
import com.product.core.entity.DataTableEntity;
|
import com.product.core.entity.FieldMetaEntity;
|
import com.product.core.entity.FieldSetEntity;
|
import com.product.core.entity.RequestParameterEntity;
|
import com.product.core.exception.BaseException;
|
import com.product.core.service.support.AbstractBaseService;
|
import com.product.core.spring.context.SpringMVCContextHolder;
|
import com.product.file.service.FileManagerService;
|
import com.product.module.sys.entity.SystemUser;
|
import com.product.util.BaseUtil;
|
import org.apache.commons.codec.binary.Base64;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.io.File;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Service("userOperService")
|
public class UserService extends AbstractBaseService {
|
|
@Autowired
|
FileManagerService fileManagerService;
|
|
@Autowired
|
UpdateLoginUserInfoService updateLoginUserInfoService;
|
|
public static final String USER_SIGNATURE_KEY = "user:signature:";
|
|
public static final String USER_AVATAR_KEY = "user:avatar:";
|
|
/**
|
* 刷新所有缓存
|
*/
|
public void cacheUserAvatar() {
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT a.user_id,a.user_name,b.* FROM product_sys_users a ")
|
.append(" join product_sys_attachments b on ")
|
.append(" length(").append(CmnConst.THUMBNAIL_IMG)
|
.append(")>0 ")
|
.append(" and a.thumbnail_img = b.uuid ");
|
DataTableEntity dt = getBaseDao().listTable(sql.toString(), new Object[]{});
|
cacheUserAvatar(dt);
|
}
|
|
public void cacheUserAvatar(DataTableEntity dt) {
|
Map<String, String> map = new HashMap<>();
|
if (!DataTableEntity.isEmpty(dt)) {
|
for (int i = 0; i < dt.getRows(); i++) {
|
String user_id = dt.getString(i, CmnConst.USER_ID);
|
String img_uuid = dt.getString(i, CmnConst.UUID);
|
if (!StringUtils.isEmpty(user_id) && !StringUtils.isEmpty(img_uuid)) {
|
if (isExistAvatar(user_id, img_uuid)) {
|
dt.removeFieldSetEntity(i);
|
i--;
|
}
|
map.put(user_id, img_uuid);
|
}
|
}
|
if (!DataTableEntity.isEmpty(dt)) {
|
Map<String, String> userAvatar = getUserAvatar(dt);
|
if (userAvatar != null && !userAvatar.isEmpty()) {
|
userAvatar.forEach((k, v) -> {
|
String img_uuid = map.get(k);
|
if (img_uuid != null) {
|
setUserAvatar(k, v, img_uuid);
|
}
|
});
|
}
|
}
|
}
|
}
|
|
/**
|
* 刷新缓存
|
*
|
* @param uuid user表uuid
|
*/
|
public void cacheUserAvatar(String uuid) {
|
if (!StringUtils.isEmpty(uuid)) {
|
StringBuilder sql = new StringBuilder();
|
sql.append(" SELECT a.user_id,b.* FROM product_sys_users a ")
|
.append(" join product_sys_attachments b on ")
|
.append(" a.uuid=? ")
|
.append(" and a.thumbnail_img = b.uuid ");
|
DataTableEntity dt = getBaseDao().listTable(sql.toString(), new Object[]{uuid});
|
cacheUserAvatar(dt);
|
}
|
}
|
|
/**
|
* 将用户头衔存到redis 中
|
*
|
* @param user_id 用户id
|
* @param img 图片base64字符串
|
* @param imgUuid 头像附件表uuid
|
*/
|
private void setUserAvatar(String user_id, String img, String imgUuid) {
|
RedisUtil.set(this.USER_AVATAR_KEY + user_id, new String[]{img, imgUuid});
|
}
|
|
/**
|
* 在缓存中获取用户头像
|
*
|
* @param user_id 用户id
|
* @return
|
*/
|
public String getUserAvatar(String user_id) {
|
Object o = RedisUtil.get(this.USER_AVATAR_KEY + user_id);
|
if (o != null) {
|
String[] o1 = (String[]) o;
|
if (o1.length == 2) {
|
return o1[0];
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 判断用户头像是否存在
|
*
|
* @param user_id 用户id
|
* @param imgUuid 用户头像附件uuid
|
* @return
|
*/
|
public boolean isExistAvatar(String user_id, String imgUuid) {
|
if (!StringUtils.isEmpty(user_id) && !StringUtils.isEmpty(imgUuid)) {
|
Object o = RedisUtil.get(this.USER_AVATAR_KEY + user_id);
|
if (o != null) {
|
String[] o1 = (String[]) o;
|
if (o1.length == 2) {
|
return o1[1].equals(imgUuid);
|
}
|
}
|
}
|
return false;
|
}
|
|
public void initUserSignature() {
|
DataTableEntity dataTableEntity = getBaseDao().listTable(CmnConst.PRODUCT_SYS_USERS, "length(user_signature)>0", null, new Object[]{CmnConst.UUID, CmnConst.USER_ID, CmnConst.USER_SIGNATURE});
|
if (!BaseUtil.dataTableIsEmpty(dataTableEntity)) {
|
for (int i = 0; i < dataTableEntity.getRows(); i++) {
|
String user_id = dataTableEntity.getString(i, CmnConst.USER_ID);
|
String user_signature = dataTableEntity.getString(i, CmnConst.USER_SIGNATURE);
|
RedisUtil.set(USER_SIGNATURE_KEY + user_id, user_signature);
|
}
|
}
|
}
|
|
|
// /**
|
// * 获取用户头像
|
// *
|
// * @param user_id
|
// * @return
|
// * @throws BaseException
|
// */
|
// public String getUserAvatar(String user_id) throws BaseException {
|
// try {
|
// if (user_id.contains(",")) {
|
// return this.getUserAvatar(user_id.split(","));
|
// }
|
// FieldSetEntity fse = getBaseDao().getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_USERS, new String[]{CmnConst.THUMBNSIL_IMG, "user_id,uuid"}, "length(thumbnail_img)>0 and user_id=? ", new Object[]{user_id}, false, null);
|
// if (fse == null) {
|
// return null;
|
// }
|
// String bytes = Base64.encodeBase64String(fileManagerService.getFileContent(fse.getString(CmnConst.THUMBNSIL_IMG)));
|
// return "data:image/*;base64," + bytes;
|
// } catch (Exception e) {
|
// return null;
|
// }
|
// }
|
|
/**
|
* 通过用户id数组获取用户头像
|
*
|
* @return
|
* @throws BaseException
|
*/
|
public Map<String, String> getUserAvatar(DataTableEntity fileDt) throws BaseException {
|
Map<String, String> jsonObject = new HashMap<>();
|
if (DataTableEntity.isEmpty(fileDt)) {
|
return null;
|
}
|
DataTableEntity dataTableEntity = fileDt;
|
FieldMetaEntity f = new FieldMetaEntity();
|
f.setTableName(new String[]{CmnConst.PRODUCT_SYS_ATTACHMENTS});
|
for (int i = 0; i < dataTableEntity.getRows(); i++) {
|
try {
|
dataTableEntity.setMeta(f);
|
FieldSetEntity fse = dataTableEntity.getFieldSetEntity(i);
|
fse.setTableName(CmnConst.PRODUCT_SYS_ATTACHMENTS);
|
String userId = fse.getString(CmnConst.USER_ID);
|
String bytes = Base64.encodeBase64String(fileManagerService.getFileContent(fse));
|
jsonObject.put(userId, "data:image/*;base64," + bytes);
|
} catch (Exception e) {
|
|
}
|
}
|
return jsonObject;
|
}
|
|
/**
|
* 通过用户id数组获取用户头像
|
*
|
* @param user_ids
|
* @return
|
* @throws BaseException
|
*/
|
public String getUserAvatar(String[] user_ids) throws BaseException {
|
JSONObject jsonObject = new JSONObject();
|
if (user_ids == null || user_ids.length == 0) {
|
return jsonObject.toJSONString();
|
}
|
for (String user_id : user_ids) {
|
jsonObject.put(user_id, getUserAvatar(user_id));
|
}
|
return jsonObject.toJSONString();
|
}
|
|
/**
|
* 获取当前用户签名
|
*
|
* @param uuid 签名附件uuid
|
* @return
|
* @throws BaseException
|
*/
|
public String getUserSignature(String uuid) throws BaseException {
|
try {
|
String bytes = Base64.encodeBase64String(fileManagerService.getFileContent(uuid));
|
return "data:image/*;base64," + bytes;
|
} catch (Exception e) {
|
return null;
|
}
|
}
|
|
/**
|
* 获取当前用户签名
|
*
|
* @return
|
* @throws BaseException
|
*/
|
public Object getUserSignature() throws BaseException {
|
// FieldSetEntity userInfo = getBaseDao().getFieldSetEntity(CmnConst.PRODUCT_SYS_USERS, new String[]{CmnConst.UUID, CmnConst.USER_SIGNATURE}, getUUID(), false);
|
// String user_signature = userInfo.getString(CmnConst.USER_SIGNATURE);
|
//用户没有签名
|
if (!RedisUtil.exists(USER_SIGNATURE_KEY + getUserId())) {
|
throw new BaseException(SystemCode.USER_SIGNATURE_NOT_EXIST.getValue(), SystemCode.USER_SIGNATURE_NOT_EXIST.getText());
|
}
|
String bytes = Base64.encodeBase64String(fileManagerService.getFileContent((String) RedisUtil.get(USER_SIGNATURE_KEY + getUserId())));
|
if (bytes == null) {
|
return null;
|
}
|
JSONObject object = new JSONObject();
|
object.put("img", "data:image/*;base64," + bytes);
|
object.put(CmnConst.USER_SIGNATURE, RedisUtil.get(USER_SIGNATURE_KEY + getUserId()));
|
return object;
|
|
}
|
|
|
public void clearUserSignature() throws BaseException {
|
FieldSetEntity f = new FieldSetEntity();
|
f.setTableName(CmnConst.PRODUCT_SYS_USERS);
|
f.setValue(CmnConst.UUID, getUUID());
|
f.setValue(CmnConst.USER_SIGNATURE, null);
|
getBaseDao().update(f);
|
RedisUtil.del(USER_SIGNATURE_KEY + getUserId());
|
}
|
|
/**
|
* 上传用户签名
|
*
|
* @param rpe
|
* @throws BaseException
|
*/
|
public String uploadUserSignature(RequestParameterEntity rpe) throws BaseException {
|
Map<String, File> files = rpe.getFiles();
|
if (files == null || files.size() <= 0 || files.get(rpe.getFormData().getString(CmnConst.USER_SIGNATURE)) == null) {
|
throw new BaseException(SystemCode.GET_UPLOAD_SIGNATURE_FILE_FAIL.getValue(), SystemCode.GET_UPLOAD_SIGNATURE_FILE_FAIL.getText());
|
}
|
FieldSetEntity fieldSetEntity = fileManagerService.uploadFile(rpe);
|
fieldSetEntity.setValue(CmnConst.UUID, getUUID());
|
BaseUtil.createCreatorAndCreationTime(fieldSetEntity);
|
getBaseDao().update(fieldSetEntity);
|
RedisUtil.set(USER_SIGNATURE_KEY + getUserId(), fieldSetEntity.getString(CmnConst.USER_SIGNATURE));
|
return fieldSetEntity.getString(CmnConst.USER_SIGNATURE);
|
}
|
|
public String getUUID() {
|
return getCurrentUser().getUuid();
|
}
|
|
public int getUserId() {
|
return getCurrentUser().getUser_id();
|
}
|
|
public SystemUser getCurrentUser() {
|
return SpringMVCContextHolder.getCurrentUser();
|
}
|
|
|
}
|
