package com.yami.trading.service.system.impl;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.google.common.collect.Lists;
|
import com.yami.trading.bean.Tip;
|
import com.yami.trading.common.constants.RedisKeys;
|
import com.yami.trading.common.constants.TipConstants;
|
import com.yami.trading.dao.tip.TipMapper;
|
import com.yami.trading.service.RealNameAuthRecordService;
|
import com.yami.trading.service.syspara.SysparaService;
|
import com.yami.trading.service.system.TipService;
|
import com.yami.trading.service.tradeview.SymbolTradeViewData;
|
import com.yami.trading.service.tradeview.SymbolTradeViewDataHolder;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.collections.CollectionUtils;
|
import org.apache.commons.collections.Predicate;
|
import org.apache.commons.lang3.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.redis.core.HashOperations;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.*;
|
|
@Service
|
@Slf4j
|
public class TipServiceImpl extends ServiceImpl<TipMapper, Tip> implements TipService {
|
private static Logger logger = LoggerFactory.getLogger(TipServiceImpl.class);
|
|
public final static String TIPLIST = RedisKeys.TIPLIST;
|
|
Map<String, List<Map<String, String>>> randomTip = new HashMap<>();
|
|
/**
|
* key：业务id
|
*/
|
@Autowired
|
private SysparaService sysparaService;
|
|
@Autowired
|
RedisTemplate redisTemplate;
|
|
@Autowired
|
RealNameAuthRecordService realNameAuthRecordService;
|
|
/**
|
* 初始化数据
|
*/
|
public void init() {
|
// HashOperations hashOps = redisTemplate.opsForHash();
|
redisTemplate.delete(TIPLIST);
|
|
List<Tip> list = this.list();
|
for (Tip tip : list) {
|
// System.out.println(tip.getBusinessId()+"->"+tip.getModel());
|
// if (tip.getModel().equals(TipConstants.KYC)){
|
// RealNameAuthRecord realNameAuthRecord= realNameAuthRecordService.getById(tip.getBusinessId());
|
// if (realNameAuthRecord==null){
|
// deleteTip(tip.getBusinessId());
|
// }
|
// else {
|
// put(tip.getBusinessId(), tip);
|
// }
|
// }//else {
|
|
put(tip.getBusinessId(), tip);
|
//}
|
}
|
}
|
|
/**
|
* 新增通知
|
*
|
* @param businessId 业务id(唯一性)
|
* @param model 模块
|
*/
|
public void saveTip(String businessId, String model) {
|
try {
|
Tip tip = get(businessId);
|
if (null == tip) {
|
tip = new Tip();
|
}
|
|
tip.setBusinessId(businessId);
|
tip.setCreateTime(new Date());
|
tip.setModel(model);
|
tip.setTimeStamp(new Date().getTime());
|
|
saveOrUpdate(tip);
|
put(businessId, tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId:{" + businessId + "},model:{" + model + "},e:{}", e);
|
}
|
}
|
|
|
public void saveTip(String businessId, String model,String userId) {
|
try {
|
Tip tip = get(businessId);
|
if (null == tip) {
|
tip = new Tip();
|
}
|
|
tip.setBusinessId(businessId);
|
tip.setCreateTime(new Date());
|
tip.setModel(model);
|
tip.setTimeStamp(new Date().getTime());
|
tip.setSendUserId(userId);
|
saveOrUpdate(tip);
|
put(businessId, tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId:{" + businessId + "},model:{" + model + "},e:{}", e);
|
}
|
}
|
|
public void put(String businessId,Tip tip) {
|
try {
|
HashOperations hashOps = redisTemplate.opsForHash();
|
hashOps.put(TIPLIST, businessId, tip);
|
|
// String json= (String) redisTemplate.opsForValue().get(TIPLIST);
|
// if (StrUtil.isNotBlank(json)){
|
// Map<String,Tip> tipMap= new Gson().fromJson(json,new TypeToken<Map<String,Tip>>(){}.getType());
|
// tipMap.put(businessId,tip);
|
// redisTemplate.opsForValue().set(TIPLIST,new Gson().toJson(tipMap));
|
//
|
// }
|
} catch (Exception e) {
|
|
}
|
}
|
|
public void remove(String businessId){
|
try {
|
HashOperations hashOps = redisTemplate.opsForHash();
|
hashOps.delete(TIPLIST,businessId);
|
|
// String json= (String) redisTemplate.opsForValue().get(TIPLIST);
|
// if (StrUtil.isNotBlank(json)){
|
// Map<String,Tip> tipMap= new Gson().fromJson(json,new TypeToken<Map<String,Tip>>(){}.getType());
|
// tipMap.remove(businessId);
|
// redisTemplate.opsForValue().set(TIPLIST,new Gson().toJson(tipMap));
|
//
|
// }
|
} catch (Exception e) {
|
|
}
|
}
|
|
public Tip get(String businessId) {
|
|
try {
|
HashOperations hashOps = redisTemplate.opsForHash();
|
return (Tip) hashOps.get(TIPLIST,businessId);
|
|
// String json= (String) redisTemplate.opsForValue().get(TIPLIST);
|
// if (StrUtil.isNotBlank(json)){
|
// Map<String,Tip> tipMap= new Gson().fromJson(json,new TypeToken<Map<String,Tip>>(){}.getType());
|
// return tipMap.get(businessId);
|
// }
|
} catch (Exception e) {
|
|
}
|
|
return null;
|
}
|
|
public List<Tip> values() {
|
try {
|
List<Tip> list = redisTemplate.opsForHash().values(TIPLIST);
|
return list;
|
} catch (Exception e) {
|
|
}
|
|
return null;
|
}
|
|
/**
|
* 新增通知
|
*
|
* @param tip 消息通知
|
*/
|
public void saveTip(Tip tip) {
|
try {
|
tip.setCreateTime(new Date());
|
tip.setTimeStamp(new Date().getTime());
|
save(tip);
|
put(tip.getBusinessId(), tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId:{" + tip.getBusinessId() + "},model:{" + tip.getModel() + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 移除通知
|
*
|
* @param businessId
|
*/
|
public void deleteTip(String businessId) {
|
try {
|
Tip tip = get(businessId);
|
if (tip != null) {
|
removeById(tip);
|
remove(businessId);
|
}
|
} catch (Exception e) {
|
logger.error("fail remove tip businessId:{" + businessId + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 批量移除通知
|
*
|
*/
|
public void deleteTip(List<String> businessIds) {
|
deleteBatchTip(businessIds);// 解决幂等性性问题
|
for (String id : businessIds) {
|
remove(id);
|
}
|
}
|
|
/**
|
* 批量更新订单收益
|
*
|
*/
|
protected void deleteBatchTip(final List<String> idList) {
|
remove(Wrappers.<Tip>query().lambda().in(Tip::getBusinessId,idList));
|
}
|
|
/**
|
* 获取总数 数据
|
*
|
* @param username
|
* @return
|
*/
|
public List<Map<String, Object>> cacheSumTips(String username,List<String> userIds) {
|
|
List<Map<String, Object>> result = new LinkedList<Map<String, Object>>();
|
|
// 根据权限列表，判定是否有模块的通知权限
|
List<String> resourceIds = this.userAuth(username);
|
List<Tip> filterTips = filterTips(username, null);
|
if (CollectionUtils.isEmpty(filterTips)) {
|
// logger.info("根据用户名获取的通知数据:{}", filterTips);
|
return result;
|
}
|
// 构建模块的通知数据
|
Map<String, List<Tip>> modelMap = modelData(filterTips,userIds);
|
//logger.info("构建模块的通知数据:{}", modelMap);
|
|
for (Map.Entry<String, List<Tip>> entry : modelMap.entrySet()) {
|
// if(resourceIds==null){
|
// Map<String, Object> map = tipData(entry.getKey(), entry.getValue());
|
// result.add(map);
|
// } else if (resourceIds.contains(entry.getKey())) {// 有权限则返回通知
|
// Map<String, Object> map = tipData(entry.getKey(), entry.getValue());
|
// result.add(map);
|
// }
|
|
Map<String, Object> map = tipData(entry.getKey(), entry.getValue());
|
result.add(map);
|
}
|
// logger.info("返回数据:{}", result);
|
return result;
|
}
|
|
/**
|
* 获取指定模块的新通知数据
|
*
|
* @param username
|
* @return
|
*/
|
public List<Map<String, Object>> cacheNewTipsByModel(String username, Long lastTimeStamp, String model,List<String> userIds) {
|
|
List<Map<String, Object>> result = new LinkedList<Map<String, Object>>();
|
|
// 根据权限列表，判定是否有模块的通知权限
|
List<String> resourceIds = this.userAuth(username);
|
List<Tip> filterNewTips = filterTips(username, lastTimeStamp);
|
|
if (CollectionUtils.isEmpty(filterNewTips)) {
|
return result;
|
}
|
// 构建模块的通知数据
|
Map<String, List<Tip>> modelMap = modelData(filterNewTips,userIds);
|
List<Tip> tipList = modelMap.get(model);
|
if (CollectionUtils.isEmpty(tipList)) {
|
return result;
|
} else {
|
result.add(tipNewData(model, tipList,userIds));
|
}
|
return result;
|
}
|
|
|
/**
|
* 新增通知
|
*
|
* @param businessId 业务id(唯一性)
|
* @param model 模块
|
*/
|
public void saveNewTip(String businessId, String model,String remark) {
|
try {
|
Tip tip = get(businessId);
|
if (null == tip) {
|
tip = new Tip();
|
}
|
|
tip.setBusinessId(businessId);
|
tip.setCreateTime(new Date());
|
tip.setModel(model);
|
tip.setTimeStamp(new Date().getTime());
|
tip.setTargetUsername(remark);
|
saveOrUpdate(tip);
|
put(businessId, tip);
|
} catch (Exception e) {
|
logger.error("fail put tip businessId22:{" + businessId + "},model:{" + model + "},e:{}", e);
|
}
|
}
|
|
/**
|
* 获取新通知数据
|
*
|
* @param username
|
* @return
|
*/
|
public List<Map<String, Object>> cacheNewTips(String username, Long lastTimeStamp,List<String> userIds) {
|
|
List<Map<String, Object>> result = new LinkedList<Map<String, Object>>();
|
|
// 根据权限列表，判定是否有模块的通知权限
|
List<Tip> filterNewTips = filterTips(username, lastTimeStamp);
|
|
// System.out.println("username = " + username);
|
// System.out.println("resourceIds = " + resourceIds);
|
// System.out.println("filterNewTips = " + filterNewTips);
|
|
if (CollectionUtils.isEmpty(filterNewTips)) {
|
return result;
|
}
|
// 构建模块的通知数据
|
Map<String, List<Tip>> modelMap = modelData(filterNewTips,userIds);
|
|
for (Map.Entry<String, List<Tip>> entry : modelMap.entrySet()) {
|
// if(resourceIds==null){
|
Map<String, Object> map = tipNewData(entry.getKey(), entry.getValue(),userIds);
|
result.add(map);
|
// }
|
// else if (resourceIds.contains(entry.getKey())) {// 有权限则返回通知
|
// Map<String, Object> map = tipNewData(entry.getKey(), entry.getValue());
|
// result.add(map);
|
// }
|
}
|
return result;
|
}
|
|
private List<Tip> filterTips(final String username, final Long lastTimeStamp) {
|
ArrayList<Tip> tipList = new ArrayList<Tip>(values());
|
CollectionUtils.filter(tipList, new Predicate() {// 过滤查找新生成的通知数据
|
@Override
|
public boolean evaluate(Object paramObject) {
|
// TODO Auto-generated method stub
|
Tip tip = (Tip) paramObject;
|
if (TipConstants.MUST_USERNAME_MODEL.containsKey(tip.getModel())) {
|
if (StringUtils.isNotEmpty(tip.getTargetUsername()) && username.equals(tip.getTargetUsername())) {
|
return lastTimeStamp == null || tip.getTimeStamp() > lastTimeStamp;// 时间戳为空则直接返回
|
} else {
|
return false;
|
}
|
}
|
else if (TipConstants.AGENT_MODEL.containsKey(tip.getModel())) {
|
// if(ch){
|
//
|
// }
|
}
|
return lastTimeStamp == null || ((Tip) paramObject).getTimeStamp() > lastTimeStamp;
|
}
|
});
|
return tipList;
|
}
|
|
private String getPath(HttpServletRequest request) {
|
return String.format("%s://%s:%s%s", request.getScheme(), request.getServerName(), request.getServerPort(),
|
request.getContextPath());
|
}
|
|
/**
|
* 用户权限列表，根据权限判定对应的模块提醒
|
*
|
* @param username
|
* @return
|
*/
|
private List<String> userAuth(String username) {
|
// 这块可做成缓存
|
// SecUser user = this.secUserService.findUserByLoginName(username);
|
// Role role = user.getRoles().toArray(new Role[0])[0];
|
// Set<Resource> resources = role.getResources();
|
// List<String> resourceIds = new ArrayList<String>();
|
// for (Resource r : resources) {
|
// resourceIds.add(r.getId().toString());
|
// }
|
// return resourceIds;
|
return null;
|
}
|
|
/**
|
* 每个模块对应的提醒数据
|
*
|
* @return
|
*/
|
private Map<String, List<Tip>> modelData(Collection<Tip> tips,List<String> userIds) {
|
// 构建需要返回对应权限的数据
|
ArrayList<Tip> tipList = new ArrayList<Tip>(tips);
|
Map<String, List<Tip>> modelMap = new HashMap<String, List<Tip>>();
|
// 构建各个模块的数据
|
for (Tip tip : tipList) {
|
List<Tip> list = modelMap.get(tip.getModel());
|
if (list == null) {
|
list = new ArrayList<Tip>();
|
}
|
if (CollectionUtil.isNotEmpty(userIds)){
|
if (userIds.contains(tip.getSendUserId())){
|
list.add(tip);
|
}
|
}
|
else {
|
list.add(tip);
|
}
|
modelMap.put(tip.getModel(), list);
|
}
|
return modelMap;
|
}
|
|
/**
|
* 构建模块的通知数据
|
*
|
* @param model 模块
|
* @param list 模块列表数据
|
* @return
|
*/
|
private Map<String, Object> tipNewData(String model, List<Tip> list,
|
List<String> userIds) {
|
Map<String, Object> resultMap = new HashMap<String, Object>();
|
List<Tip> tipList=new ArrayList<>();
|
if (CollectionUtil.isNotEmpty(userIds)){
|
for (Tip t:list){
|
log.info(userIds.contains(t.getSendUserId())+"======"+t.getSendUserId());
|
if (userIds.contains(t.getSendUserId())){
|
tipList.add(t);
|
}
|
}
|
list=tipList;
|
}
|
|
// 模块新增数
|
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()));
|
String htmlMessage = TipConstants.MESSAGE_MAP.get(model);
|
if(list.size() > 0 && htmlMessage != null){
|
htmlMessage = htmlMessage.replace("{0}","<span style='color:#E05561'>"+list.size()+"</span>");
|
}
|
// 模块提示消息
|
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",isShowTip(model));
|
// 提示类型
|
resultMap.put("tip_type",TipConstants.MESSAGE_TYPE.get(model));
|
return resultMap;
|
}
|
/**
|
* 是否右下角提示，true：是，false：否
|
* @param model
|
* @return
|
*/
|
private boolean isShowTip(String model) {
|
String value = sysparaService.find("tip_noshow_models").getSvalue();
|
return value.indexOf(model)==-1;
|
}
|
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 List<Map<String,String>> getRandom() {
|
String[] strName = {
|
// Technology Services
|
"ruanjianhefuwu",
|
// Electronic Technology
|
"kejishebei",
|
// Finance
|
"yinhanghetouzifuwu",
|
// Health Technology
|
"yiliaofuwu",
|
// Industrial Services,
|
"gongyepin",
|
// Consumer Durables
|
"baihuolingshou",
|
// Finance
|
"yinhanghetouzifuwu",
|
"shiwuheyinliao",
|
"zhouqixingxiaofeipin",
|
"baoxian",
|
"qichejilingjian",
|
"gngyeheshangyefuwu",
|
"huashilianliao",
|
"zouqixingfuwu",
|
"dianxinfuwu",
|
"gongyongshiye",
|
"fangdichan",
|
"kuangchanziyuan",
|
"huaxuepin",
|
"xiaofeipin"
|
};
|
|
randomTip.clear();
|
List<Map<String, String>> arr = new ArrayList<>();
|
String[] strValues = new String[strName.length];
|
strValues[0] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Technology Services", "-") + "%";
|
strValues[1] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Electronic Technology", "-") + "%";
|
strValues[2] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Finance", "-") + "%";
|
strValues[3] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Health Technology", "-") + "%";
|
strValues[4] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Industrial Services", "-") + "%";
|
strValues[5] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Consumer Durables", "-") + "%";
|
strValues[6] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Finance", "-") + "%";
|
strValues[7] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Energy Minerals", "-") + "%";
|
strValues[8] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Producer Manufacturing", "-") + "%";
|
strValues[9] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Commercial Services", "-") + "%";
|
strValues[10] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Utilities", "-") + "%";
|
strValues[11] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Non-Energy Minerals", "-") + "%";
|
strValues[12] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Transportation", "-") + "%";
|
strValues[13] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Distribution Services", "-") + "%";
|
strValues[14] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Process Industries", "-") + "%";
|
strValues[15] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Communications", "-") + "%";
|
strValues[16] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Communications", "-") + "%";
|
strValues[17] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Communications", "-") + "%";
|
strValues[18] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Retail Trade", "-") + "%";
|
strValues[19] = SymbolTradeViewDataHolder.industryMap.getOrDefault("Communications", "-") + "%";
|
|
for (int i = 0; i < strName.length; i++) {
|
Map<String, String> map1 = new HashMap<>();
|
map1.put("key", strName[i]);
|
map1.put("value", strValues[i]);
|
arr.add(map1);
|
}
|
|
return arr;
|
}
|
|
@Override
|
public List<Map<String, String>> getRandom(String type) {
|
List<SymbolTradeViewData> symbolTradeViewData = SymbolTradeViewDataHolder.typeList.get(type);
|
if(CollectionUtils.isEmpty(symbolTradeViewData)){
|
return Lists.newArrayList();
|
}
|
int size = symbolTradeViewData.size();
|
List<Map<String, String>> arr = new ArrayList<>();
|
for (int i = 0; i < size; i++) {
|
Map<String, String> map1 = new HashMap<>();
|
map1.put("key", symbolTradeViewData.get(i).getSymbol());
|
map1.put("value", symbolTradeViewData.get(i).getRate().toString() +"%");
|
arr.add(map1);
|
}
|
return arr;
|
}
|
|
}
|
