package com.qxueyou.scc.msg.service.impl;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSON;
|
import com.qxueyou.scc.base.model.Pager;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.impl.CommonAppService;
|
import com.qxueyou.scc.base.util.ClientUtils;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.msg.model.MsgInfo;
|
import com.qxueyou.scc.msg.service.IMsgInfoService;
|
|
/**
|
* 消息服务
|
*
|
* @author kevin
|
*
|
*/
|
@Service
|
public class MsgInfoService extends CommonAppService implements IMsgInfoService {
|
|
@Override
|
public List<MsgInfo> list(Short type, Integer pageSize, Integer pageNum) {
|
StringBuffer hql = new StringBuffer();
|
hql.append("from MsgInfo where receiverId=? ");
|
List<Object> params =CollectionUtils.newList(ClientUtils.getUserId());
|
|
if(type!=null){
|
hql.append(" and type = ? ");
|
params.add(type);
|
}
|
|
hql.append(" and deleteFlag is false order by createTime desc");
|
|
return findList(hql.toString(),new Pager(pageSize, pageNum),params, MsgInfo.class);
|
}
|
|
@Override
|
public int listCount(Short type) {
|
StringBuffer hql = new StringBuffer();
|
hql.append("from MsgInfo where receiverId=? ");
|
List<Object> params =CollectionUtils.newList(ClientUtils.getUserId());
|
|
if(type!=null){
|
hql.append(" and type = ? ");
|
params.add(type);
|
}
|
|
hql.append(" and deleteFlag is false");
|
|
return findCount(hql.toString(),params);
|
}
|
|
@Override
|
public Result deleteUserMsg(String [] msgId) {
|
return bulkUpdateInLoop("update MsgInfo set deleteFlag = true where msgId=?", msgId);
|
}
|
|
@Override
|
public Result deleteAllUserMsg(Short type) {
|
return this.bulkUpdate("update MsgInfo set deleteFlag = true where deleteFlag is false and receiverId=? and type=?",
|
new Object[]{ClientUtils.getUserId(),type==null?10000:type});
|
}
|
|
@Override
|
public Result updateReadStatus(String [] msgIds) {
|
return bulkUpdateInLoop("update MsgInfo set readFlag = 1 where msgId=?", msgIds);
|
}
|
|
@Override
|
public Result updateUserAllReadStatus(Short type) {
|
return this.bulkUpdate("update MsgInfo set readFlag = 1 where deleteFlag is false and receiverId=? and type=?",
|
new Object[]{ClientUtils.getUserId(),type==null?10000:type});
|
}
|
|
@Override
|
public Result doSendTextMsgToUsers(String[] userIdsToArr,short type,String msg) {
|
return doSendTextMsgToUsers(userIdsToArr,type,msg,CollectionUtils.newStringMap("msg",msg));
|
}
|
|
@Override
|
public Result doSendTextMsgToUsers(String[] userIdsToArr,short type,String msg,Map<String,String> attrs) {
|
return doSendtMsgToTargets(userIdsToArr,type,attrs,CollectionUtils.newStringMap("msg",msg));
|
}
|
|
|
/**
|
* 给指定目标发送消息
|
* @param userIdFrom
|
* @param targetIdsToArr
|
* @param msg
|
* @param attrs
|
* @param targetType
|
* @param msgInfo
|
* @return
|
*/
|
private Result doSendtMsgToTargets(String[] targetIdsToArr,short type,Map<String, String> attrs,Map<String,String> msgInfo){
|
if(targetIdsToArr== null || targetIdsToArr.length==0){
|
return new Result(false,"参数错误");
|
}
|
|
List<MsgInfo> lstMsg = new ArrayList<MsgInfo>(targetIdsToArr.length);
|
for(String receiverId:targetIdsToArr){
|
MsgInfo tempInfo = new MsgInfo();
|
tempInfo.setType(type);
|
tempInfo.setReadFlag(String.valueOf(MsgInfo.READ_NOT));
|
tempInfo.setContent(JSON.toJSONString(CollectionUtils.newObjectMap("ext", attrs,"msg", msgInfo)));
|
tempInfo.setReceiverId(receiverId);
|
TraceUtils.setCreateTrace(tempInfo);
|
lstMsg.add(tempInfo);
|
}
|
return this.saveOrUpdateAll(lstMsg);
|
}
|
|
|
/**
|
* 分批发送通知
|
*
|
* @param userIdList
|
* @param msg
|
* @param extra
|
* @return
|
*/
|
public void doSendTextMsgToUsersLoop(List<String> userIdList,short type,String msg, Map<String,String> extra) {
|
if(userIdList==null || userIdList.size()==0){
|
return ;
|
}
|
String [] targetIds = null;
|
for(int i=0;i<userIdList.size();i+=20){
|
if((userIdList.size()-i)>20){
|
targetIds = userIdList.subList(i, i+20).toArray(new String [20]);
|
}else{
|
targetIds = userIdList.subList(i,userIdList.size()).toArray(new String[userIdList.size()-i]);
|
}
|
this.doSendtMsgToTargets(targetIds,type,extra,CollectionUtils.newStringMap("msg",msg));
|
}
|
}
|
|
@Override
|
public MsgInfo readLastRemindMsg(){
|
return this.findUnique("from MsgInfo where receiverId=? and type=? and deleteFlag is false order by createTime desc",
|
CollectionUtils.newList(ClientUtils.getUserId(),MsgInfo.TYPE_REMIND), MsgInfo.class);
|
}
|
|
@Override
|
public Map<String,Object> queryUnReadMsgCountByType(){
|
List<Map<String,Object>> resultList = this.findListWithMapByHql("select type as type ,count(1) as count from MsgInfo where receiverId=:receiverId and readFlag=:readFlag and deleteFlag is false group by type",
|
CollectionUtils.newObjectMap("receiverId",ClientUtils.getUserId(),"readFlag",String.valueOf(MsgInfo.READ_NOT)));
|
|
Map<String,Object> result = null;
|
if(resultList != null && resultList.size()>0){
|
result = new HashMap<String,Object>(resultList.size());
|
for(Map<String,Object> map:resultList){
|
result.put(String.valueOf(map.get("type")), map.get("count"));
|
}
|
}
|
|
return result;
|
}
|
|
@Override
|
public int queryUnReadTotalCount(){
|
return this.findCountByComplexHql("from MsgInfo where receiverId=:receiverId and readFlag=:readFlag and deleteFlag is false",
|
CollectionUtils.newObjectMap("receiverId",ClientUtils.getUserId(),"readFlag",String.valueOf(MsgInfo.READ_NOT)));
|
}
|
|
}
|
