package com.shlanbao.tzsc.pms.sys.sourceDataMonitoring.service.impl; import com.shlanbao.tzsc.base.model.DataGrid; import com.shlanbao.tzsc.pms.sys.sourceDataMonitoring.beans.RedisBean; import com.shlanbao.tzsc.pms.sys.sourceDataMonitoring.beans.SysSourceDataBean; import com.shlanbao.tzsc.pms.sys.sourceDataMonitoring.beans.SysSourceDateParamBean; import com.shlanbao.tzsc.pms.sys.sourceDataMonitoring.service.MonitoringServiceI; import com.shlanbao.tzsc.utils.tools.RedisUtil; import com.shlanbao.tzsc.utils.tools.StringUtil; import org.springframework.stereotype.Service; import redis.clients.jedis.Jedis; import java.util.*; @Service public class MonitoringServiceImpl implements MonitoringServiceI { /** * 查询源数据信息 * @author sunzhen * @create 2019年9月16日下午15:30:05 * @param * @throws Exception */ @Override public DataGrid getAllDatas(SysSourceDateParamBean sourceDateParamBean) { //总记录数 long total=0; //存放源数据bean的list List lastRows = new ArrayList<>(); RedisBean bean=null; Map map = RedisUtil.getMap(sourceDateParamBean.getName()); Set keys = map.keySet(); for(String key : keys){ bean = new RedisBean(); bean.setKey(key); bean.setValue(map.get(key)); lastRows.add(bean); } total=lastRows.size(); return new DataGrid(lastRows, total); } /** * 查询源数据列表信息 * @author sunzhen * @create 2019年9月16日下午15:30:05 * @param * @throws Exception */ @Override public DataGrid querySourceDateList(SysSourceDateParamBean sourceDateParamBean) { //从Redis中获取所有的key值 Set keys = RedisUtil.keys("*"); System.out.println(keys); //总记录数 long total=0; //存放源数据bean的list List lastRows = new ArrayList(); SysSourceDataBean bean = null; //遍历所有的key值赋值到bean中并存放到lastRows中去 for (String key : keys) { //筛选符合查询条件的key值 if(checkEqpType(key,sourceDateParamBean.getEqpType())&&key.contains(sourceDateParamBean.getName())){ bean = new SysSourceDataBean(); bean.setName(key); bean.setDes(codeParsing(key)); lastRows.add(bean); } } total=lastRows.size(); return new DataGrid(lastRows, total); } /** * 将key值的解释从符号转换成中文 * @param key * @return */ private String codeParsing(String key) { /* 目前有以下几种种类： -----------4位数字------------- 1. 1101 2101 1401 -----------4位数字+1个字母------------- 2. 1102C 3. 1102J 4. 1102M 5. 1202G 6. 1401F 7. 1401Z 8. 1502X -----------3位数字+2个字母------------- 9. 101CC 102CC -----------其他------------- 10. converted-preview-pdf-file 11. converted-preview-pdfimgs-file 12. outputInput 13. shift 14. workorder 15. \xAC\xED\x00\x05t\x00\x04123M */ String des=""; switch(key.length()){ case 4: switch(key.substring(0,1)){ case "1": des+="早班"+key.substring(2,4)+"号"; des = parseEqpName(key, des, 1, 2); return des; case "2": des+="中班"+key.substring(2,4)+"号"; des = parseEqpName(key, des, 1, 2); return des; case "3": des+="晚班"+key.substring(2,4)+"号"; des = parseEqpName(key, des, 1, 2); return des; } break; case 5: if(key.endsWith("CC")){ //先对以CC结尾的key进行筛选，因为下面有以C结尾的情况 des+=key.substring(1,3)+"号"; des = parseEqpName(key, des, 0, 1); des+="辅料转换系数"; return des; }else{ //这里shift会进来，但下面会筛选掉 String str = key.substring(4, 5); if(str.equals("C")|| str.equals("J")|| str.equals("M") || str.equals("Z")|| str.equals("F")|| str.equals("G")|| str.equals("X")){ switch(key.substring(0,1)){ case "1": des+="早班"+key.substring(2,4)+"号"; des = parseEqpName(key, des, 1, 2); des+= str; return des; case "2": des+="中班"+key.substring(2,4)+"号"; des = parseEqpName(key, des, 1, 2); des+= str; return des; case "3": des+="晚班"+key.substring(2,4)+"号"; des = parseEqpName(key, des, 1, 2); des+= str; return des; } } } break; default: return "暂无信息"; } return "暂无信息"; } private String parseEqpName(String key, String des, int start, int end) { switch(key.substring(start,end)){ case "1": des+="卷烟机组"; break; case "2": des+="包装机组"; break; case "3": des+="装箱机组"; break; case "4": des+="成型机组"; break; case "5": des+="发射机组"; break; case "6": des+="提升机组"; break; } return des; } /** * 检查key值是否属于eqpType的机器类型 * @param key key值为被检查的值 * @param eqpType 机器类型为匹配的条件 * @return */ public boolean checkEqpType(String key,String eqpType){ /* 目前有以下几种种类： -----------4位数字------------- 1. 1101 2101 1401 -----------4位数字+1个字母------------- 2. 1102C 3. 1102J 4. 1102M 5. 1202G 6. 1401F 7. 1401Z 8. 1502X -----------3位数字+2个字母------------- 9. 101CC 102CC -----------其他------------- 10. converted-preview-pdf-file 11. converted-preview-pdfimgs-file 12. outputInput 13. shift 14. workorder 15. \xAC\xED\x00\x05t\x00\x04123M */ // 当机器类型为空时则满足所有任何条件，返回true if(!StringUtil.notNull(eqpType)){ return true; } //1. 首先根据机器类别筛选，分为六种类型：卷烟机、包装机、装封箱机、发射机、成型机、提升机 //2. 然后根据key值的长度进行筛选，分为两种情况：key值长度=4、key值长度=5 //3. 当key值长度=5时还分两种情况：以CC结尾的、不以CC结尾的 //4. 最后根据不同的情况，用key值中的某一位与代表机器类型的值进行匹配 switch(eqpType){ case "卷烟机": switch (key.length()){ case 4: if(key.charAt(1)=='1') return true; case 5: if(key.endsWith("CC")){ if(key.charAt(0)=='1') return true; }else{ if(key.charAt(1)=='1') return true; } } return false; case "包装机": switch (key.length()){ case 4: if(key.charAt(1)=='2') return true; case 5: if(key.endsWith("CC")){ if(key.charAt(0)=='2') return true; }else{ if(key.charAt(1)=='2') return true; } } return false; case "装封箱机": switch (key.length()){ case 4: if(key.charAt(1)=='3') return true; case 5: if(key.endsWith("CC")){ if(key.charAt(0)=='3') return true; }else{ if(key.charAt(1)=='3') return true; } } return false; case "发射机": switch (key.length()){ case 4: if(key.charAt(1)=='5') return true; case 5: if(key.endsWith("CC")){ if(key.charAt(0)=='5') return true; }else{ if(key.charAt(1)=='5') return true; } } return false; case "成型机": switch (key.length()){ case 4: if(key.charAt(1)=='4') return true; case 5: if(key.endsWith("CC")){ if(key.charAt(0)=='4') return true; }else{ if(key.charAt(1)=='4') return true; } } return false; case "提升机": switch (key.length()){ case 4: if(key.charAt(1)=='6') return true; case 5: if(key.endsWith("CC")){ if(key.charAt(0)=='6') return true; }else{ if(key.charAt(1)=='6') return true; } } return false; } return false; } }