package com.shlanbao.tzsc.pms.msg.info.service.impl;
|
|
import java.util.*;
|
|
import com.google.gson.Gson;
|
import com.shlanbao.tzsc.init.BaseParams;
|
import com.shlanbao.tzsc.pms.md.eqp.beans.EquipmentsBean;
|
import com.shlanbao.tzsc.pms.sys.user.beans.UserBean;
|
import com.shlanbao.tzsc.pms.websocket.WebSocketMessage;
|
import com.shlanbao.tzsc.pms.websocket.WebSocketSessionUtils;
|
import com.shlanbao.tzsc.utils.tools.FillUserInfoUtil;
|
import com.shlanbao.tzsc.utils.tools.LogAnno;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.shlanbao.tzsc.base.dao.MsgInfoDaoI;
|
import com.shlanbao.tzsc.base.mapping.MdEquipment;
|
import com.shlanbao.tzsc.base.mapping.MsgInfo;
|
import com.shlanbao.tzsc.base.mapping.SysUser;
|
import com.shlanbao.tzsc.base.model.DataGrid;
|
import com.shlanbao.tzsc.base.model.Json;
|
import com.shlanbao.tzsc.base.model.PageParams;
|
import com.shlanbao.tzsc.base.model.SessionInfo;
|
import com.shlanbao.tzsc.base.service.BaseService;
|
import com.shlanbao.tzsc.pms.md.eqp.service.EquipmentsServiceI;
|
import com.shlanbao.tzsc.pms.msg.info.beans.MsgInfoBean;
|
import com.shlanbao.tzsc.pms.msg.info.beans.MsgOperatorBean;
|
import com.shlanbao.tzsc.pms.msg.info.service.MsgInfoServiceI;
|
import com.shlanbao.tzsc.pms.sys.role.beans.RoleBean;
|
import com.shlanbao.tzsc.pms.sys.user.service.UserServiceI;
|
import com.shlanbao.tzsc.utils.tools.StringUtil;
|
import com.shlanbao.tzsc.utils.tools.WebContextUtil;
|
import org.springframework.util.StringUtils;
|
import org.springframework.web.socket.TextMessage;
|
import org.springframework.web.socket.WebSocketSession;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
@Service
|
public class MsgInfoServiceImpl extends BaseService implements MsgInfoServiceI{
|
@Autowired
|
protected EquipmentsServiceI equipmentService;
|
@Autowired
|
protected MsgInfoDaoI msgInfoDao;
|
@Autowired
|
protected UserServiceI userService;
|
@Autowired
|
private HttpServletRequest request;
|
/**
|
* 该方法只是进行保存添加或者修改的数据
|
*/
|
@LogAnno(operateType = "新增或编辑机台通知信息")
|
@Override
|
public Json addMsgInfo(MsgInfo info) throws Exception {
|
Json json=new Json();
|
SessionInfo sessionInfo = (SessionInfo) WebContextUtil.getObjectFromSession();
|
|
MsgInfo temp = info;
|
//当Id不等于空时，则证明是新增的消息，否则为修改的消息
|
if(sessionInfo.getUser()!=null){
|
if(StringUtil.notNull(info.getId())){
|
//修改
|
info = msgInfoDao.findById(MsgInfo.class, info.getId());
|
info.setTime(new Date());
|
info.setFlag(1l);
|
info.setTitle(temp.getTitle());
|
info.setContent(temp.getContent());
|
info.setEid(temp.getEid()); //设置推送机台
|
info.setSendFlag(temp.getSendFlag()); //设置推送标记
|
info.setSendType(temp.getSendType()); //设置推送类型
|
info.setApproveTime(new Date()); //设置推送时间
|
FillUserInfoUtil.fillUpdateUserInfo(info,request);
|
}else{
|
//设置发起人
|
info.setSysUserByInitiator(new SysUser(sessionInfo.getUser().getId()));
|
info.setDel(0L);
|
info.setId(null);
|
info.setTime(new Date());
|
info.setFlag(1l);
|
//推送到机台
|
FillUserInfoUtil.fillCreateUserInfo(info,request);
|
}
|
msgInfoDao.saveOrUpdate(info);
|
json.setMsg("操作成功");
|
json.setSuccess(true);
|
}else{
|
json.setMsg("用户未登录");
|
json.setSuccess(false);
|
}
|
|
return json;
|
}
|
|
/**
|
* 该方法用于审批保存数据
|
*/
|
@Override
|
public void saveMsgInfo(MsgInfo msgInfo) throws Exception {
|
MsgInfo info=msgInfoDao.findById(MsgInfo.class, msgInfo.getId());
|
info.setApproveContent(msgInfo.getApproveContent());
|
info.setFlag(msgInfo.getFlag());
|
msgInfoDao.saveOrUpdate(info);
|
}
|
|
@Override
|
public DataGrid queryMsgInfo(MsgInfoBean msgInfo, PageParams pageParams)throws Exception {
|
String hql = "from MsgInfo o where 1=1 and o.del=0 and o.msgInfo.id is null";
|
String params = "";
|
if(StringUtil.notNull(msgInfo.getTitle())){
|
params+=" and o.title like '%"+msgInfo.getTitle()+"%'";
|
}
|
if(msgInfo.getSendFlag()!=null){
|
params+=" and o.sendFlag = '"+msgInfo.getSendFlag()+"'";
|
}
|
//时间
|
if(!StringUtils.isEmpty(msgInfo.getTime())&&!StringUtils.isEmpty(msgInfo.getApproveTime()))
|
params+=StringUtil.OraclefmtDateBetweenParams("o.time", msgInfo.getTime() +" 00:00:00", msgInfo.getApproveTime()+" 23:59:59");
|
|
List<MsgInfo> infos = msgInfoDao.queryByPage(hql.concat(params), pageParams);
|
String sqlHql = "select count(*) " + hql;
|
long total = msgInfoDao.queryTotal(sqlHql.concat(params));
|
// List<MsgInfo> infos2=msgInfoDao.query(hql);
|
List<MsgInfoBean> infoBeans=new ArrayList<MsgInfoBean>();
|
for (MsgInfo msgInfo2 : infos) {
|
MsgInfoBean infoBean=beanConvertor.copyProperties(msgInfo2, MsgInfoBean.class);
|
/*if(msgInfo2.getSysUserByApproval()!=null){
|
infoBean.setApprovalName(msgInfo2.getSysUserByApproval().getName());
|
infoBean.setApproval(msgInfo2.getSysUserByApproval().getId());
|
}*/
|
|
if(msgInfo2.getSysUserByInitiator()!=null){
|
infoBean.setInitiatorName(msgInfo2.getSysUserByInitiator().getName());
|
infoBean.setInitiator(msgInfo2.getSysUserByInitiator().getId());
|
}
|
/*if(msgInfo2.getSysUserByIssuer()!=null){
|
infoBean.setIssuerName(msgInfo2.getSysUserByIssuer().getName());
|
infoBean.setIssuer(msgInfo2.getSysUserByIssuer().getId());
|
}*/
|
FillUserInfoUtil.fillCreateAndUpdateUserInfo(msgInfo2,infoBean);
|
infoBeans.add(infoBean);
|
}
|
|
return new DataGrid(infoBeans, total);
|
}
|
|
@LogAnno(operateType = "删除当前机台通知信息")
|
@Override
|
public void deleteMsgInfoById(String id) throws Exception {
|
msgInfoDao.findById(MsgInfo.class, id).setDel(1L);
|
}
|
|
@Override
|
public MsgOperatorBean getCurrUserOperator() throws Exception {
|
SessionInfo sessionInfo = (SessionInfo) WebContextUtil.getObjectFromSession();
|
//判断发起人的角色是否和审批人的角色一致
|
List<RoleBean> roleBeans = sessionInfo.getRoles();
|
List<String> roleNames = new ArrayList<String>();
|
for (RoleBean roleBean : roleBeans) {
|
if(roleBean.isChecked())
|
roleNames.add(roleBean.getName());
|
}
|
MsgOperatorBean msgOperatorBean = new MsgOperatorBean();
|
if(roleNames.contains("设备管理员")) //审批
|
msgOperatorBean.setName("APPROVE");
|
if(roleNames.contains("车间主任")) //签发
|
msgOperatorBean.setName("ISSUER");
|
msgOperatorBean.setOperId(sessionInfo.getUser().getId());
|
return msgOperatorBean;
|
}
|
|
@Override
|
public MsgInfoBean getMsgInfoBeanById(String id) throws Exception {
|
MsgInfo msgInfo = msgInfoDao.findById(MsgInfo.class, id);
|
MsgInfoBean bean = beanConvertor.copyProperties(msgInfo, MsgInfoBean.class);
|
if(msgInfo.getSysUserByInitiator()!=null){
|
bean.setInitiatorName(msgInfo.getSysUserByInitiator().getName());
|
}
|
return bean;
|
}
|
|
@Override
|
public List<MsgInfoBean> getMsgInfo() throws Exception {
|
String hql="from MsgInfo o where 1=1 and o.del=0 and o.flag=3 and o.msgInfo is null order by o.time desc";
|
//插叙前5条数据
|
List<MsgInfo> msgInfos = msgInfoDao.queryByPage(hql, 1, 5, new Object[]{});
|
List<MsgInfoBean> beans = beanConvertor.copyList(msgInfos, MsgInfoBean.class);
|
return beans;
|
}
|
|
@Override
|
public List<MsgInfoBean> getMsgInfoApprove(String id) throws Exception {
|
String hql = "from MsgInfo o where 1=1 and o.del=0 and o.msgInfo.id='" + id + "'";
|
List<MsgInfo> infos = msgInfoDao.query(hql, new Object[]{});
|
List<MsgInfoBean> beans = new ArrayList<MsgInfoBean>();
|
for (MsgInfo info : infos) {
|
MsgInfoBean bean = beanConvertor.copyProperties(info, MsgInfoBean.class);
|
if(StringUtil.notNull(bean.getInitiator()))
|
bean.setInitiatorName(userService.getSysUserById(bean.getInitiator()).getName());
|
if(StringUtil.notNull(bean.getApproval()))
|
bean.setApprovalName(userService.getSysUserById(bean.getApproval()).getName());
|
if(StringUtil.notNull(bean.getIssuer()))
|
bean.setIssuerName(userService.getSysUserById(bean.getIssuer()).getName());
|
if(info.getMsgInfo() != null){
|
bean.setPid(info.getMsgInfo().getId());
|
bean.setpName(info.getMsgInfo().getTitle());
|
}
|
beans.add(bean);
|
}
|
return beans;
|
}
|
|
@Override
|
public MsgInfoBean getMsgInfoById(String id) throws Exception {
|
MsgInfo info=msgInfoDao.findById(MsgInfo.class, id);
|
MsgInfoBean infoBean=beanConvertor.copyProperties(info, MsgInfoBean.class);
|
if(info.getSysUserByApproval()!=null){
|
infoBean.setApprovalName(info.getSysUserByApproval().getName());
|
infoBean.setApproval(info.getSysUserByApproval().getId());
|
}
|
if(info.getSysUserByIssuer()!=null){
|
infoBean.setIssuerName(info.getSysUserByIssuer().getName());
|
infoBean.setIssuer(info.getSysUserByIssuer().getId());
|
}
|
return infoBean;
|
}
|
|
@Override
|
public List<MdEquipment> queryMdequipment() {
|
try {
|
StringBuffer sb=new StringBuffer();
|
sb.append(" select t1.* from ( ");
|
sb.append(" select c.code,a.equipment_code,a.equipment_name,to_number(a.EQUIPMENT_CODE) as num ,a.id From MD_EQUIPMENT a,MD_EQP_TYPE b,MD_EQP_CATEGORY c where a.eqp_type_id=b.id and b.cid=c.id and a.del=0 ");
|
sb.append(" ) t1 order by t1.num");
|
List<?> list=msgInfoDao.queryBySql(sb.toString());
|
if(list!=null && list.size()>0){
|
List<MdEquipment> listMe=new ArrayList<MdEquipment>();
|
for(Object o:list){
|
MdEquipment ecrb=new MdEquipment();
|
Object[] temp=(Object[]) o;
|
ecrb.setId(StringUtil.convertObjToString(temp[0]));
|
ecrb.setEquipmentCode(StringUtil.convertObjToString(temp[1]));
|
ecrb.setEquipmentName(StringUtil.convertObjToString(temp[2]));
|
ecrb.setAttr2(StringUtil.convertObjToString(temp[4]));
|
listMe.add(ecrb);
|
}
|
return listMe;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
@Override
|
public void saveMsgSend(MsgInfo msgInfo) {
|
|
try {
|
msgInfoDao.update(msgInfo);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
|
|
|
}
|
|
@Override
|
public List<MdEquipment> getEquInfo(UserBean userBean) {
|
try {
|
List<MdEquipment> equList=new ArrayList<MdEquipment>();
|
StringBuilder sb = new StringBuilder();
|
sb.append("SELECT a.ID,a.EQUIPMENT_NAME,a.EQUIPMENT_CODE, c.CODE FROM MD_EQUIPMENT a " +
|
"LEFT JOIN MD_EQP_TYPE b on a.EQP_TYPE_ID = b.id " +
|
"LEFT JOIN MD_EQP_CATEGORY c on b.CID = c.id " +
|
"WHERE a.DEL = 0 ");
|
if(userBean!=null&& !StringUtils.isEmpty(userBean.getName())){
|
sb.append("AND a.EQUIPMENT_NAME LIKE '%"+userBean.getName()+"%' ");
|
}
|
if(userBean!=null&& !StringUtils.isEmpty(userBean.getGender())){
|
sb.append(" AND c.CODE = "+userBean.getGender()+" ");
|
}
|
sb.append("ORDER BY a.EQUIPMENT_CODE");
|
List<?> list=msgInfoDao.queryBySql(sb.toString());
|
if(list!=null && list.size()>0){
|
|
for(Object o:list){
|
MdEquipment equ=new MdEquipment();
|
Object[] temp=(Object[]) o;
|
equ.setId(StringUtil.convertObjToString(temp[0]));
|
equ.setEquipmentName(StringUtil.convertObjToString(temp[1]));
|
equ.setEquipmentCode(StringUtil.convertObjToString(temp[2]));
|
equ.setAttr2(StringUtil.convertObjToString(temp[0]));
|
equList.add(equ);
|
}
|
}
|
return equList;
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
|
return null;
|
}
|
|
|
/**
|
* 回写通知告警下选择的设备
|
*/
|
public void getMsgEqu(MsgInfoBean msgInfoById ,List<MdEquipment> mdEquipments){
|
//获取告警信息下已保存的设备id
|
String eid = msgInfoById.getEid();
|
//保存的是设备id 回写的是name，根据设备id查询设备的name
|
if(!StringUtils.isEmpty(eid)){
|
String[] split = eid.split(",");
|
StringBuilder sb = new StringBuilder();
|
for (int i = 0 ; i < split.length;i++){
|
for (int j = 0 ; j<mdEquipments.size();j++){
|
MdEquipment mdEquipment = mdEquipments.get(j);
|
if(split[i].equals(mdEquipment.getAttr2())){
|
sb.append(mdEquipment.getEquipmentName()+",");
|
mdEquipments.get(j).setAttr1("select"); //设置选择标记
|
}
|
}
|
}
|
//编辑状态下回写的设备名
|
msgInfoById.setIssuerName(sb.toString());
|
}
|
}
|
|
@Override
|
public List<MdEquipment> getWctOnlineEqu() {
|
//wct所有在线设备
|
List<MdEquipment> root = new ArrayList<>();
|
try {
|
Map<String, WebSocketSession> clients = WebSocketSessionUtils.getInstance().getClients();
|
if(clients!=null){
|
//wct配置 用户名下对应的设备
|
Map<String, List<MdEquipment>> wctEquMap = BaseParams.getWctEquMap();
|
//需要判断client是属于pms 还是wct。 wct的客户端存在的登录名，pms客户端存的是id
|
for (Map.Entry<String, WebSocketSession> entry : clients.entrySet()) {
|
//判断是否wct登录的客户端
|
if(!entry.getKey().startsWith("das")) continue;
|
|
List<MdEquipment> mdEquipments = wctEquMap.get(entry.getKey());
|
if(mdEquipments==null||mdEquipments.size()<1) continue;
|
//判断设备类型
|
for (int i= 0 ;i<mdEquipments.size();i++){
|
String substring = mdEquipments.get(i).getEquipmentCode().substring(0, 1);
|
if(Integer.parseInt(substring)<7){
|
MdEquipment mdEquipment = mdEquipments.get(i);
|
mdEquipment.setId(mdEquipment.getEquipmentCode());
|
//设置设备在wct的登录名 方便推送
|
mdEquipment.setAttr1(entry.getKey());
|
root.add(mdEquipment);
|
}
|
}
|
|
}
|
}
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
return root;
|
}
|
|
@LogAnno(operateType = "推送消息到wct或pms")
|
@Override
|
public boolean pushToWctOrPms(Map<String, Object> param) {
|
|
try {
|
|
//需要推送的设备,用逗号拼接
|
String eid = (String) param.get("eid");
|
//需要推送的消息
|
MsgInfo msg = (MsgInfo) param.get("msg");
|
//推送的类型 0-pms和wct 1-pms 2-wct
|
Long type = (Long) param.get("type");
|
//设置消息标记，方便js中解析
|
msg.setApproveContent("PMS");
|
|
String[] split = eid.split(",");
|
if (type == 0) {
|
pushToWct(split, msg);
|
pushToPms(msg);
|
} else if (type == 1) {
|
pushToPms(msg);
|
} else if (type == 2) {
|
pushToWct(split, msg);
|
}
|
|
|
}catch (Exception e){
|
e.printStackTrace();
|
return false;
|
}
|
|
|
return true;
|
}
|
|
@Override
|
public void batchDeleteMsgInfo(String ids) {
|
String[] split = ids.split(",");
|
for (int i = 0; i < split.length; i++) {
|
msgInfoDao.findById(MsgInfo.class, split[i]).setDel(1L);
|
}
|
}
|
|
/**
|
* 将通知推送到wct
|
* @param split 推送的机台code
|
* @param msg 推送消息的json
|
*/
|
private void pushToWct(String[] split, MsgInfo msg ){
|
//需要推送的机台 通过设备code找出wct的登录名
|
Map<String,Object> map = new HashMap<>();
|
Map<String, List<MdEquipment>> wctEquMap = BaseParams.getWctEquMap();
|
for (int i = 0;i<split.length;i++){
|
for (Map.Entry<String, List<MdEquipment>> entry : wctEquMap.entrySet()) {
|
if(entry.getValue()==null) continue;
|
for (int j =0;j<entry.getValue().size();j++){
|
if(split[i].equals(entry.getValue().get(j).getEquipmentCode())){
|
map.put(entry.getValue().get(j).getAttr1(),"");
|
}
|
}
|
|
}
|
|
}
|
//推送到wct
|
if(!map.isEmpty()){
|
for (Map.Entry<String, Object> entry : map.entrySet()) {
|
String key = entry.getKey();
|
Map<String, WebSocketSession> clients = WebSocketSessionUtils.getInstance().getClients();
|
if(clients.containsKey(key)){
|
WebSocketMessage webSocketMessage = new WebSocketMessage();
|
webSocketMessage.setTitle(msg.getTitle());
|
webSocketMessage.setContent(msg.getContent());
|
webSocketMessage.setType("0");
|
webSocketMessage.setService("pms");
|
Gson g = new Gson();
|
String s = g.toJson(webSocketMessage);
|
TextMessage returnMessage = new TextMessage(s);
|
if(key.startsWith("das")||key.startsWith("admin"))
|
WebSocketSessionUtils.getInstance().sendMessageToTarget(key,returnMessage);
|
}
|
|
}
|
}
|
|
}
|
|
/**
|
* 推送消息到pms客户端
|
* @param msg 推送的消息json
|
*/
|
private void pushToPms(MsgInfo msg ){
|
WebSocketMessage webSocketMessage = new WebSocketMessage();
|
webSocketMessage.setTitle(msg.getTitle());
|
webSocketMessage.setContent(msg.getContent());
|
webSocketMessage.setType("0");
|
webSocketMessage.setService("pms");
|
Gson g = new Gson();
|
String s = g.toJson(webSocketMessage);
|
TextMessage returnMessage = new TextMessage(s);
|
Map<String, WebSocketSession> clients = WebSocketSessionUtils.getInstance().getClients();
|
for (Map.Entry<String, WebSocketSession> entry : clients.entrySet()) {
|
//wct 存储的是用户登录的winUname pms存储的是登录的id
|
if(!entry.getKey().startsWith("das")&&!entry.getKey().startsWith("admin")){
|
WebSocketSessionUtils.getInstance().sendMessageToTarget(entry.getKey(),returnMessage);
|
}
|
}
|
|
}
|
|
|
|
}
|
