package project.tip.internal;
|
|
import java.text.MessageFormat;
|
import java.util.ArrayList;
|
import java.util.Collection;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.LinkedList;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.Map.Entry;
|
import java.util.Set;
|
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.stream.Collectors;
|
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.collections.Predicate;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import kernel.util.StringUtils;
|
import kernel.web.ApplicationUtil;
|
import project.syspara.SysparaService;
|
import project.tip.TipConstants;
|
import project.tip.TipService;
|
import project.tip.model.Tip;
|
import security.SecUser;
|
import security.internal.SecUserService;
|
|
public class TipServiceImpl implements TipService {
|
|
private SecUserService secUserService;
|
|
private SysparaService sysparaService;
|
|
private Map<String, Tip> tipCache = new ConcurrentHashMap<String, Tip>();
|
|
private static final Logger logger=LoggerFactory.getLogger(TipServiceImpl.class);
|
|
/**
|
* 初始化数据
|
*/
|
public void init() {
|
List<Tip> list=ApplicationUtil.executeSelect(Tip.class);
|
if(null==list || list.isEmpty()) return;
|
list.forEach(tip->tipCache.put(tip.getBusiness_id(), tip));
|
}
|
|
/**
|
* 新增通知
|
* @param businessId 业务id(唯一性)
|
* @param model 模块
|
*/
|
public void saveTip(String businessId, String model) {
|
try {
|
Tip tip=tipCache.get(businessId);
|
if (null==tip) tip=new Tip();
|
|
tip.setBusiness_id(businessId);
|
tip.setCreate_time(new Date());
|
tip.setModel(model);
|
tip.setTime_stamp(new Date().getTime());
|
|
ApplicationUtil.executeSaveOrUpdate(tip);
|
tipCache.put(businessId, tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId:{" + businessId + "},model:{" + model + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 新增通知
|
* @param businessId 业务id(唯一性)
|
* @param model 模块
|
*/
|
public void saveNewTip(String businessId, String model,String remark) {
|
try {
|
Tip tip = tipCache.get(businessId);
|
if (null == tip) tip = new Tip();
|
|
tip.setBusiness_id(businessId);
|
tip.setCreate_time(new Date());
|
tip.setModel(model);
|
tip.setTime_stamp(new Date().getTime());
|
tip.setTarget_username(remark);
|
|
ApplicationUtil.executeSaveOrUpdate(tip);
|
tipCache.put(businessId, tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId22:{" + businessId + "},model:{" + model + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 新增通知
|
* @param tip 消息通知
|
*/
|
public void saveTip(Tip tip) {
|
try {
|
tip.setCreate_time(new Date());
|
tip.setTime_stamp(new Date().getTime());
|
|
ApplicationUtil.executeInsert(tip);
|
tipCache.put(tip.getBusiness_id(), tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId:{" + tip.getBusiness_id() + "},model:{" + tip.getModel() + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 移除通知
|
* @param businessId
|
*/
|
public void deleteTip(String businessId) {
|
try {
|
ApplicationUtil.executeDelete(Tip.class,"WHERE BUSINESS_ID=?",new Object[] {businessId});
|
tipCache.remove(businessId);
|
} catch (Exception e) {
|
logger.error("fail remove tip businessId:{" + businessId + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 批量移除通知
|
* @param businessId
|
*/
|
public void deleteTip(List<String> businessIds) {
|
if(null==businessIds || businessIds.isEmpty()) return;
|
List<Object[]> paramList=businessIds.stream().map(id->new Object[] {id}).collect(Collectors.toList());
|
ApplicationUtil.executeBatchDelete(Tip.class, "WHERE BUSINESS_ID=?", paramList);
|
for (String id : businessIds) tipCache.remove(id);
|
}
|
|
/**
|
* 获取总数 数据
|
* @param username
|
* @return
|
*/
|
public List<Map<String, Object>> cacheSumTips(String username) {
|
List<Map<String, Object>> result = new LinkedList<Map<String, Object>>();
|
|
//获取参数用户的所有提示记录
|
List<Tip> filterTips = filterTips(username, null);
|
if (CollectionUtils.isEmpty(filterTips)) return result;
|
|
//获取用户所有模块资源权限
|
Set<String> resourceIds = getPrivileges(username);
|
|
//将模块资源列表转换为模块到提示集合的映射字典
|
Map<String, List<Tip>> modelMap = modelData(filterTips);
|
for (Entry<String, List<Tip>> entry : modelMap.entrySet()) {
|
if (resourceIds.contains(entry.getKey())) {//有权限则返回通知
|
result.add(tipData(entry.getKey(), entry.getValue()));
|
}
|
}
|
|
return result;
|
}
|
|
/**
|
* 获取指定模块的新通知数据
|
* @param username
|
* @return
|
*/
|
public LinkedList<Map<String, Object>> cacheNewTipsByModel(String username, Long lastTimeStamp, String model) {
|
LinkedList<Map<String, Object>> result = new LinkedList<Map<String, Object>>();
|
|
//获取参数用户的所有提示记录
|
List<Tip> filterNewTips = filterTips(username, lastTimeStamp);
|
if (CollectionUtils.isEmpty(filterNewTips)) return result;
|
|
//将模块资源列表转换为模块到提示集合的映射字典
|
Map<String, List<Tip>> modelMap = modelData(filterNewTips);
|
List<Tip> tipList = modelMap.get(model);
|
|
if (CollectionUtils.isEmpty(tipList)) return result;
|
|
result.add(tipNewData(model, tipList));
|
return result;
|
}
|
|
/**
|
* 获取新通知数据
|
* @param username
|
* @return
|
*/
|
public LinkedList<Map<String, Object>> cacheNewTips(String username, Long lastTimeStamp) {
|
LinkedList<Map<String, Object>> result=new LinkedList<Map<String, Object>>();
|
|
//获取参数用户的所有提示记录
|
List<Tip> filterNewTips = filterTips(username, lastTimeStamp);
|
if (CollectionUtils.isEmpty(filterNewTips)) return result;
|
|
//获取用户所有模块资源权限
|
Set<String> resourceIds = getPrivileges(username);
|
|
//将模块资源列表转换为模块到提示集合的映射字典
|
Map<String, List<Tip>> modelMap = modelData(filterNewTips);
|
|
for (Entry<String, List<Tip>> entry : modelMap.entrySet()) {
|
if (resourceIds.contains(entry.getKey())) { //有权限则返回通知
|
result.add(tipNewData(entry.getKey(), entry.getValue()));
|
}
|
}
|
|
return result;
|
}
|
|
|
/**
|
* 获取用户所有权限集合
|
* @param username 用户名
|
* @return 权限字串集合
|
*/
|
private Set<String> getPrivileges(String username) {
|
SecUser user = this.secUserService.findUserByLoginName(username);
|
return user.getRoles().stream().flatMap(role->role.getResources().stream()).map(resource->resource.getId().toString()).collect(Collectors.toSet());
|
}
|
|
/**
|
* 过滤参数用户指定时间戳之后的提示记录
|
* @param username 用户名
|
* @param lastTimeStamp 时间戳
|
* @return 提示列表
|
*/
|
private List<Tip> filterTips(final String username, final Long lastTimeStamp) {
|
ArrayList<Tip> tipList = new ArrayList<Tip>(tipCache.values());
|
CollectionUtils.filter(tipList, new Predicate() { //过滤查找新生成的通知数据
|
@Override
|
public boolean evaluate(Object paramObject) {
|
Tip tip = (Tip) paramObject;
|
if (TipConstants.MUST_USERNAME_MODEL.containsKey(tip.getModel())) {
|
if (StringUtils.isNotEmpty(tip.getTarget_username()) && username.equals(tip.getTarget_username())) {
|
return lastTimeStamp == null || tip.getTime_stamp() > lastTimeStamp;
|
} else {
|
return false;
|
}
|
}
|
return lastTimeStamp == null || ((Tip) paramObject).getTime_stamp() > lastTimeStamp;
|
}
|
});
|
return tipList;
|
}
|
|
/**
|
* 每个模块对应的提醒数据列表
|
* @param tips 提醒数据列表
|
* @return 提醒数据字典
|
*/
|
private Map<String, List<Tip>> modelData(Collection<Tip> tips) {
|
HashMap<String, List<Tip>> modelMap = new HashMap<String, List<Tip>>();
|
|
for (Tip tip : tips) {
|
List<Tip> list = modelMap.get(tip.getModel());
|
if (null==list) modelMap.put(tip.getModel(),list=new ArrayList<Tip>());
|
list.add(tip);
|
}
|
|
return modelMap;
|
}
|
|
/**
|
* 构建模块的通知数据(New)
|
* @param model 模块
|
* @param list 模块列表数据
|
* @return 通知数据字典
|
*/
|
private Map<String, Object> tipNewData(String model, final List<Tip> list) {
|
Map<String, Object> resultMap = new HashMap<String, Object>();
|
// 模块提示数量
|
resultMap.put("tip_content_num", list.size());
|
// 生成html通知
|
String htmlMessage = MessageFormat.format(TipConstants.MESSAGE_MAP.get(model),MessageFormat.format("<span class=\"label label-danger\">{0}</span>", list.size()));
|
// 模块提示消息
|
resultMap.put("tip_message", list.size()>0? htmlMessage:"");
|
// 模块请求url
|
resultMap.put("tip_url", list.size()>0?TipConstants.ACTION_MAP.get(model) : "");
|
// 是否右下角提示
|
resultMap.put("tip_show",sysparaService.find("tip_noshow_models").getValue().indexOf(model)==-1);
|
return resultMap;
|
}
|
|
/**
|
* 构建模块的通知数据(New)
|
* @param model 模块
|
* @param list 模块列表数据
|
* @return 通知数据字典
|
*/
|
private Map<String, Object> tipData(String model, final List<Tip> list) {
|
Map<String, Object> resultMap = new HashMap<String, Object>();
|
// 页面上对应的classname(可自定义)
|
resultMap.put("tip_dom_name", TipConstants.DOM_MAP.get(model));
|
// 模块总数
|
resultMap.put("tip_content_sum", list.size());
|
// 模块新增数
|
return resultMap;
|
}
|
|
public void setSecUserService(SecUserService secUserService) {
|
this.secUserService = secUserService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
}
|
