package com.shlanbao.tzsc.data.runtime.handler;
|
|
import com.shlanbao.tzsc.base.dao.BaseDaoI;
|
import com.shlanbao.tzsc.base.interceptor.PMSXmlDataInterceptor;
|
import com.shlanbao.tzsc.data.webservice.client.SendMessageClient;
|
import com.shlanbao.tzsc.utils.tools.DateUtil;
|
import com.shlanbao.tzsc.utils.tools.RedisUtil;
|
import org.apache.commons.lang.StringUtils;
|
import org.dom4j.Document;
|
import org.dom4j.DocumentHelper;
|
import org.dom4j.Element;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @ClassName WsjInfoToMES
|
* @Description 定时处理喂丝机设备连接关系，当联接关系变化时封装xml发送给MES
|
* @Author bsw
|
* @Date 2020/8/30 23:55
|
* @Version 1.0
|
**/
|
public class WsjInfoToMES {
|
Logger logger = LoggerFactory.getLogger(this.getClass());
|
// 存放上次变化的数据
|
private static Map oldMap = null;
|
|
@Autowired
|
private BaseDaoI<Object> baseDao;
|
|
public void sendInfoToMes() {
|
|
Map shiftMap = RedisUtil.getMap("shift");
|
if(shiftMap == null) return ;
|
String shift = (String) shiftMap.get("ID");
|
if(shift==null) return ;
|
|
// 获取新的设备关系数据 key例: 1603
|
Map info = RedisUtil.getMap(shift+"603");
|
if (info==null) return;
|
// 去除实时变化的更新时间字段
|
info.remove("DacUpTime");
|
|
if (oldMap==null) {
|
oldMap = RedisUtil.getMap("oldMap");
|
}
|
// 判断数据是否变化
|
if (!info.equals(oldMap)){
|
// 存放1#喂丝机对应卷接机组 下同
|
List fs1 = new ArrayList();
|
List fs2 = new ArrayList();
|
List fs3 = new ArrayList();
|
List fs4 = new ArrayList();
|
// 存放喂丝机对应储丝柜
|
List cgl = new ArrayList();
|
|
// 循环获取12个卷接机组对应的喂丝机
|
for (int i = 1; i <=12 ; i++) {
|
|
String is = i<10?"0"+i:i+"";
|
|
Object roller = info.get("pipe"+is);
|
if (roller == null || roller.equals("0") || roller.toString().length()<2) continue;
|
|
// 例： 【12】 1 喂丝机 2 管道号 --第一个字符是1 则连接至1#喂丝机，将当前机组存入1#喂丝机所对应卷接机组的集合
|
if ( roller.toString().substring(0,1).equals("1")){
|
fs1.add(is);
|
} else if ( roller.toString().substring(0,1).equals("2")){
|
fs2.add(is);
|
}else if ( roller.toString().substring(0,1).equals("3")){
|
fs3.add(is);
|
}else if ( roller.toString().substring(0,1).equals("4")){
|
fs4.add(is);
|
}
|
|
}
|
Document document;
|
document= DocumentHelper.createDocument();
|
Element dataset = document.addElement("dataset");
|
// 循环封装4台喂丝机对应的卷接机组和储丝柜关系
|
for (int i = 1; i <= 4 ; i++) {
|
Element data = dataset.addElement("data");
|
Element name = data.addElement("WsCode");
|
name.setText("FS"+i);
|
Element equipments = data.addElement("JbCode");
|
// 1#喂丝机 对应 fs1 集合中的卷接组机
|
if (i==1){
|
equipments.setText(StringUtils.join(fs1.toArray(),","));
|
} else if (i==2){
|
equipments.setText(StringUtils.join(fs2.toArray(),","));
|
} else if (i==3){
|
equipments.setText(StringUtils.join(fs3.toArray(),","));
|
} else if (i==4){
|
equipments.setText(StringUtils.join(fs4.toArray(),","));
|
}
|
|
Element cg = data.addElement("CsCode");
|
cgl.clear();
|
|
// 每个喂丝机分别可以同时连接两个储丝柜，获取对应的第一个储丝柜；
|
if (info.get("fs" + i + "1") != null && !"0".equals(info.get("fs" + i + "1")) && !"".equals(info.get("fs" + i + "1").toString().trim())) {
|
cgl.add(info.get("fs" + i + "1").toString().substring(2));
|
}
|
// 获取对应的第二个储丝柜
|
if (info.get("fs" + i + "2") != null && !"0".equals(info.get("fs" + i + "2")) && !"".equals(info.get("fs" + i + "2").toString().trim())) {
|
cgl.add(info.get("fs" + i + "2").toString().substring(2));
|
}
|
cg.setText(StringUtils.join(cgl.toArray(),","));
|
Element ConnTime = data.addElement("ConnTime");
|
ConnTime.setText(DateUtil.getNowDateTime("yyyy-MM-dd HH:mm:ss"));
|
String insertSql = "INSERT INTO SCH_ROLLER_PIPE (ID, WS, JB, CS, DAT) select SYS_GUID(), '"+name.getText()+"', '"+equipments.getText()+"', '"+cg.getText()+"', sysDate from dual";
|
baseDao.updateBySql(insertSql,null);
|
|
}
|
String xml = document.asXML();
|
// logger.info(xml);
|
SendMessageClient.SendEqpConnToMES(xml);
|
PMSXmlDataInterceptor.getInstance().addLog(true,"发送设备联接关系", 1, xml);
|
oldMap = info;
|
RedisUtil.setMap("oldMap",oldMap);
|
}
|
|
}
|
|
|
}
|
