// // Source code recreated from a .class file by IntelliJ IDEA // (powered by FernFlower decompiler) // package com.hxzkoa.services; import com.hxzkoa.json.tb_historyinwarning; import com.hxzkoa.json.tb_lixianrecord; import com.hxzkoa.json.tb_message_history; import com.hxzkoa.json.tb_permission; import com.hxzkoa.json.tb_realinwarning; import com.hxzkoa.json.tb_tag; import com.hxzkoa.json.tb_warning; import com.hxzkoa.util.Config; import com.hxzkoa.util.ModifyConfig; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import javax.persistence.EntityManager; import javax.persistence.PersistenceContext; import javax.persistence.Query; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @Service public class WarningService { @PersistenceContext private EntityManager em; @Autowired private CaozuoService cs; public WarningService() { } public List getWarningSummary() { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time FROM tb_warning"; query = this.em.createNativeQuery(sql); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List getWarningSummary(int page) { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1 FROM tb_warning ORDER BY id DESC LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List iframeSoS(int page) { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1 FROM tb_warning WHERE type = 'SOS' ORDER BY id DESC LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List iframeDdl(int page) { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1 FROM tb_warning WHERE type = '低电量' ORDER BY id DESC LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List getWarningSummarya() { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1,baoliu2,baoliu3 FROM tb_warning ORDER BY id DESC"; query = this.em.createNativeQuery(sql); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); warning.setBaoliu2(obj[6] == null ? "" : obj[6].toString()); warning.setBaoliu3(obj[7] == null ? "" : obj[7].toString()); tb_warningList.add(warning); } } return tb_warningList; } public int getWarningSummaryCount() { String sql = null; Query query = null; sql = "SELECT count(1) FROM tb_warning"; query = this.em.createNativeQuery(sql); return Integer.parseInt(query.getSingleResult().toString()); } public List searchWarningSummary(String input) { String sql = null; Query query = null; sql = "SELECT w.id,w.type,w.objectid,w.`status`,w.time,w.baoliu1 FROM tb_warning w,tb_person p WHERE w.objectid = p.p_tagid AND p.p_name = :objectid OR w.objectid = p.p_tagid AND w.objectid = :objectid"; query = this.em.createNativeQuery(sql); query.setParameter("objectid", input); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public Map getWarningSummaryType() { String sql = null; Query query = null; String str = "未处理"; sql = "SELECT type,count(1) c FROM tb_warning WHERE status = :str GROUP BY type ORDER BY c DESC"; query = this.em.createNativeQuery(sql); query.setParameter("str", str); List resultList = query.getResultList(); Map reMap = new HashMap(); int warningSummaryCount = this.getWarningSummaryCount(); int i; Object[] obj; if (resultList.size() > 3) { for(i = 0; i < 3; ++i) { obj = (Object[])((Object[])resultList.get(i)); reMap.put(obj[0].toString(), Integer.parseInt(obj[1].toString())); warningSummaryCount -= Integer.parseInt(obj[1].toString()); } reMap.put("其他", warningSummaryCount); } else { for(i = 0; i < resultList.size(); ++i) { obj = (Object[])((Object[])resultList.get(i)); reMap.put(obj[0].toString(), Integer.parseInt(obj[1].toString())); } } return reMap; } public List getRealinWarning() { String sql = null; Query query = null; sql = "SELECT id,area,name,bumen,tagid,intime FROM tb_realinwarning"; query = this.em.createNativeQuery(sql); List resultList = query.getResultList(); List tb_realinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_realinwarning realinwarning = new tb_realinwarning(); Object[] obj = (Object[])((Object[])resultList.get(i)); realinwarning.setId((Integer)obj[0]); realinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); realinwarning.setName(obj[2] == null ? "" : obj[2].toString()); realinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); realinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); realinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); tb_realinwarningList.add(realinwarning); } } return tb_realinwarningList; } public List getRealinWarning(int page) { String sql = null; Query query = null; sql = "SELECT id,area,name,bumen,tagid,intime FROM tb_realinwarning LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultList = query.getResultList(); List tb_realinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_realinwarning realinwarning = new tb_realinwarning(); Object[] obj = (Object[])((Object[])resultList.get(i)); realinwarning.setId((Integer)obj[0]); realinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); realinwarning.setName(obj[2] == null ? "" : obj[2].toString()); realinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); realinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); realinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); tb_realinwarningList.add(realinwarning); } } return tb_realinwarningList; } public List getRealinWarninga() { String sql = null; Query query = null; sql = "SELECT id,area,name,bumen,tagid,intime FROM tb_realinwarning"; query = this.em.createNativeQuery(sql); List resultList = query.getResultList(); List tb_realinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_realinwarning realinwarning = new tb_realinwarning(); Object[] obj = (Object[])((Object[])resultList.get(i)); realinwarning.setId((Integer)obj[0]); realinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); realinwarning.setName(obj[2] == null ? "" : obj[2].toString()); realinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); realinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); realinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); tb_realinwarningList.add(realinwarning); } } return tb_realinwarningList; } public int getRealinWarningCount() { String sql = null; Query query = null; sql = "SELECT count(1) FROM tb_realinwarning"; query = this.em.createNativeQuery(sql); return Integer.parseInt(query.getSingleResult().toString()); } @Transactional public void realinWarning_delete(String[] checkVal) { String sql = null; Query query = null; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_realinwarning WHERE id = :id"; query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } } @Transactional public int realinWarning_deletea(String[] checkVal) { String sql = null; Query query = null; int aaa = checkVal.length; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_realinwarning WHERE id = :id"; this.cs.tb_caozuo("tb_realinwarning", 2); query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } return aaa; } @Transactional public void realinWarning_deleteAll() { String sql = null; Query query = null; sql = "DELETE FROM tb_realinwarning"; this.cs.tb_caozuo("tb_realinwarning", 2); query = this.em.createNativeQuery(sql); query.executeUpdate(); } @Transactional public int realinWarning_deleteAlla() { String sql = null; Query query = null; sql = "DELETE FROM tb_realinwarning"; this.cs.tb_caozuo("tb_realinwarning", 2); query = this.em.createNativeQuery(sql); int aaa = query.executeUpdate(); return aaa; } public List searchRealinWarning(String input) { String sql = null; Query query = null; sql = "SELECT w.id,w.area,w.name,w.bumen,w.tagid,w.intime FROM tb_realinwarning w,tb_person p WHERE w.tagid = p.p_tagid AND p.p_name = :tag_id OR w.tagid = p.p_tagid AND w.tagid = :tag_id"; query = this.em.createNativeQuery(sql); query.setParameter("tag_id", input); List resultList = query.getResultList(); List tb_realinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_realinwarning realinwarning = new tb_realinwarning(); Object[] obj = (Object[])((Object[])resultList.get(i)); realinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); realinwarning.setName(obj[2] == null ? "" : obj[2].toString()); realinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); realinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); realinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); tb_realinwarningList.add(realinwarning); } } return tb_realinwarningList; } public List getHistoricalWarning() { String sql = null; Query query = null; sql = "SELECT id,area,name,bumen,tagid,intime,outtime,alltime,beizhu FROM tb_historyinwarning"; query = this.em.createNativeQuery(sql); List resultList = query.getResultList(); List tb_historyinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { Object[] obj = (Object[])((Object[])resultList.get(i)); tb_historyinwarning historyinwarning = new tb_historyinwarning(); historyinwarning.setId((Integer)obj[0]); historyinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); historyinwarning.setName(obj[2] == null ? "" : obj[2].toString()); historyinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); historyinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); historyinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); historyinwarning.setOuttime(obj[6] == null ? "" : obj[6].toString()); historyinwarning.setAlltime(obj[7] == null ? "" : obj[7].toString()); historyinwarning.setBeizhu(obj[8] == null ? "" : obj[8].toString()); tb_historyinwarningList.add(historyinwarning); } } return tb_historyinwarningList; } public List getHistoricalWarning(int page) { String sql = null; Query query = null; sql = "SELECT id,area,name,bumen,tagid,intime,outtime,alltime,beizhu FROM tb_historyinwarning LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultList = query.getResultList(); List tb_historyinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { Object[] obj = (Object[])((Object[])resultList.get(i)); tb_historyinwarning historyinwarning = new tb_historyinwarning(); historyinwarning.setId((Integer)obj[0]); historyinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); historyinwarning.setName(obj[2] == null ? "" : obj[2].toString()); historyinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); historyinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); historyinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); historyinwarning.setOuttime(obj[6] == null ? "" : obj[6].toString()); historyinwarning.setAlltime(obj[7] == null ? "" : obj[7].toString()); historyinwarning.setBeizhu(obj[8] == null ? "" : obj[8].toString()); tb_historyinwarningList.add(historyinwarning); } } return tb_historyinwarningList; } public List getHistoricalWarninga() { String sql = null; Query query = null; sql = "SELECT id,area,name,bumen,tagid,intime,outtime,alltime,beizhu FROM tb_historyinwarning"; query = this.em.createNativeQuery(sql); List resultList = query.getResultList(); List tb_historyinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { Object[] obj = (Object[])((Object[])resultList.get(i)); tb_historyinwarning historyinwarning = new tb_historyinwarning(); historyinwarning.setId((Integer)obj[0]); historyinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); historyinwarning.setName(obj[2] == null ? "" : obj[2].toString()); historyinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); historyinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); historyinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); historyinwarning.setOuttime(obj[6] == null ? "" : obj[6].toString()); historyinwarning.setAlltime(obj[7] == null ? "" : obj[7].toString()); historyinwarning.setBeizhu(obj[8] == null ? "" : obj[8].toString()); tb_historyinwarningList.add(historyinwarning); } } return tb_historyinwarningList; } public int getHistoricalWarningCount() { String sql = null; Query query = null; sql = "SELECT count(1) FROM tb_historyinwarning"; query = this.em.createNativeQuery(sql); return Integer.parseInt(query.getSingleResult().toString()); } @Transactional public void historicalWarning_delete(String[] checkVal) { String sql = null; Query query = null; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_historyinwarning WHERE id = :id"; this.cs.tb_caozuo("tb_historyinwarning", 2); query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } } @Transactional public int historicalWarning_deletea(String[] checkVal) { String sql = null; Query query = null; int aaa = checkVal.length; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_historyinwarning WHERE id = :id"; this.cs.tb_caozuo("tb_historyinwarning", 2); query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } return aaa; } @Transactional public void Warning_delete(String[] checkVal) { String sql = null; Query query = null; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_warning WHERE id = :id"; this.cs.tb_caozuo("tb_warning", 2); query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } } @Transactional public int Warning_deletea(String[] checkVal) { String sql = null; Query query = null; int aaa = checkVal.length; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_warning WHERE id = :id"; this.cs.tb_caozuo("tb_warning", 2); query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } return aaa; } @Transactional public void historicalWarning_deleteAll() { String sql = null; Query query = null; sql = "DELETE FROM tb_historyinwarning"; this.cs.tb_caozuo("tb_historyinwarning", 2); query = this.em.createNativeQuery(sql); query.executeUpdate(); } @Transactional public int historicalWarning_deleteAlla() { String sql = null; Query query = null; sql = "DELETE FROM tb_historyinwarning"; this.cs.tb_caozuo("tb_historyinwarning", 2); query = this.em.createNativeQuery(sql); int aaa = query.executeUpdate(); return aaa; } @Transactional public void Warning_deleteAll() { String sql = null; Query query = null; sql = "DELETE FROM tb_warning"; this.cs.tb_caozuo("tb_warning", 2); query = this.em.createNativeQuery(sql); query.executeUpdate(); } @Transactional public int Warning_deleteAlla() { String sql = null; Query query = null; sql = "DELETE FROM tb_warning"; this.cs.tb_caozuo("tb_warning", 2); query = this.em.createNativeQuery(sql); int aaa = query.executeUpdate(); return aaa; } @Transactional public void Warning_deletefenlei(String fenlei) { String sql = null; Query query = null; sql = "DELETE FROM tb_warning WHERE type=:fenlei"; this.cs.tb_caozuo("tb_warning", 2); query = this.em.createNativeQuery(sql); query.setParameter("fenlei", fenlei); query.executeUpdate(); } @Transactional public int historicalWarning_handle(String[] checkVal) { String sql = null; Query query = null; int aaa = checkVal.length; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "UPDATE tb_warning SET status='已处理' WHERE objectid = :id"; this.cs.tb_caozuo("tb_warning", 3); query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } return aaa; } @Transactional public int historicalWarning_handleAll() { String sql = null; Query query = null; sql = "UPDATE tb_warning SET status='已处理'"; this.cs.tb_caozuo("tb_warning", 3); query = this.em.createNativeQuery(sql); int aaa = query.executeUpdate(); return aaa; } @Transactional public void historicalWarning_handleAll_realpositoin() { String sql = null; Query query = null; sql = "UPDATE tb_realpositoin SET sos='0'"; this.cs.tb_caozuo("tb_realpositoin", 3); query = this.em.createNativeQuery(sql); query.executeUpdate(); } public List searchHistoricalWarning(String input) { String sql = null; Query query = null; sql = "SELECT w.id,w.area,w.name,w.bumen,w.tagid,w.intime,w.outtime,w.alltime,w.beizhu FROM tb_historyinwarning w,tb_person p WHERE w.tagid = p.p_tagid AND p.p_name = :tag_id OR w.tagid = p.p_tagid AND w.tagid = :tag_id"; query = this.em.createNativeQuery(sql); query.setParameter("tag_id", input); List resultList = query.getResultList(); List tb_historyinwarningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { Object[] obj = (Object[])((Object[])resultList.get(i)); tb_historyinwarning historyinwarning = new tb_historyinwarning(); historyinwarning.setArea(obj[1] == null ? "" : obj[1].toString()); historyinwarning.setName(obj[2] == null ? "" : obj[2].toString()); historyinwarning.setBumen(obj[3] == null ? "" : obj[3].toString()); historyinwarning.setTagid(obj[4] == null ? "" : obj[4].toString()); historyinwarning.setIntime(obj[5] == null ? "" : obj[5].toString()); historyinwarning.setOuttime(obj[6] == null ? "" : obj[6].toString()); historyinwarning.setAlltime(obj[7] == null ? "" : obj[7].toString()); historyinwarning.setBeizhu(obj[8] == null ? "" : obj[8].toString()); tb_historyinwarningList.add(historyinwarning); } } return tb_historyinwarningList; } @Transactional public void warning_add(tb_warning warning) { String sql = null; Query query = null; sql = "INSERT tb_warning (type,objectid,status,time) VALUES (:type,:objectid,:status,now())"; this.cs.tb_caozuo("tb_warning", 1); query = this.em.createNativeQuery(sql); query.setParameter("type", warning.getType().toString()); query.setParameter("objectid", warning.getObjectid()); query.setParameter("status", warning.getStatus()); query.executeUpdate(); } @Transactional public void realinwarning_add(tb_realinwarning realinwarning) { String sql = null; Query query = null; sql = "INSERT tb_realinwarning (area,name,bumen,tagid,intime) VALUES (:area,:name,:bumen,:tagid,now())"; this.cs.tb_caozuo("tb_realinwarning", 1); query = this.em.createNativeQuery(sql); query.setParameter("area", realinwarning.getArea()); query.setParameter("name", realinwarning.getName()); query.setParameter("bumen", realinwarning.getBumen()); query.setParameter("tagid", realinwarning.getTagid()); query.executeUpdate(); } public List getleixing(String fenlei) { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1 FROM tb_warning WHERE type=:fenlei ORDER BY id DESC"; query = this.em.createNativeQuery(sql); query.setParameter("fenlei", fenlei); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List getzhuangtai(String fenlei) { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1 FROM tb_warning WHERE status=:fenlei ORDER BY id DESC"; query = this.em.createNativeQuery(sql); query.setParameter("fenlei", fenlei); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List getshuangshai(String fenlei, String fenlei2) { String sql = null; Query query = null; sql = "SELECT id,type,objectid,`status`,time,baoliu1 FROM tb_warning WHERE type=:fenlei and status=:fenlei2 ORDER BY id DESC"; query = this.em.createNativeQuery(sql); query.setParameter("fenlei", fenlei); query.setParameter("fenlei2", fenlei2); List resultList = query.getResultList(); List tb_warningList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { tb_warning warning = new tb_warning(); Object[] obj = (Object[])((Object[])resultList.get(i)); warning.setId((Integer)obj[0]); warning.setType(obj[1] == null ? "" : obj[1].toString()); warning.setObjectid(obj[2] == null ? "" : obj[2].toString()); warning.setStatus(obj[3] == null ? "" : obj[3].toString()); warning.setTime(obj[4] == null ? "" : obj[4].toString()); warning.setBaoliu1(obj[5] == null ? "" : obj[5].toString()); tb_warningList.add(warning); } } return tb_warningList; } public List getPermissionManagement(int page) { String sql = null; Query query = null; sql = "SELECT id,tag_id,state,power,status,gaodu,sudu,pinglv,sleep_satus,sleep_time,gongfang,dong_status,version,addtime,imu,baoliu18 FROM (SELECT t.id,t.tag_id,t.state,t.power,t.status,t.gaodu,t.sudu,t.pinglv,t.sleep_satus,t.sleep_time,t.gongfang,t.dong_status,t.version,t.addtime,t.imu,p.baoliu18 FROM tb_tag t,tb_person p WHERE t.tag_id = p.p_tagid ORDER BY t.id DESC) s LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); List resultList = query.getResultList(); List tb_tagList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { Object[] obj = (Object[])((Object[])resultList.get(i)); tb_tag tag = new tb_tag(); tag.setId((Integer)obj[0]); tag.setStatus(obj[4] == null ? "" : obj[4].toString()); tag.setTag_id(obj[1] == null ? "" : obj[1].toString()); tag.setState(obj[2] == null ? "" : obj[2].toString()); tag.setPower(obj[3] == null ? "" : obj[3].toString()); tag.setGaodu(obj[5] == null ? "" : obj[5].toString()); tag.setSudu(obj[6] == null ? "" : obj[6].toString()); tag.setPinglv(obj[7] == null ? "" : obj[7].toString()); tag.setVersion(obj[12] == null ? "" : obj[12].toString()); tag.setAddtime(obj[13] == null ? "" : obj[13].toString()); tag.setBaoliu18(obj[15] == null ? "" : obj[15].toString()); tb_tagList.add(tag); } } return tb_tagList; } @Transactional public int permissionupdate(String baoliu18, String tagid) { String sql = null; Query query = null; sql = "UPDATE tb_person SET baoliu18=:baoliu18 WHERE p_tagid = :tagid"; query = this.em.createNativeQuery(sql); query.setParameter("baoliu18", baoliu18); query.setParameter("tagid", tagid); int aaa = query.executeUpdate(); return aaa; } public List getPermissionid(String tagid) { String sql = null; Query query = null; sql = "SELECT id,tag_id,state,power,status,gaodu,sudu,pinglv,sleep_satus,sleep_time,gongfang,dong_status,version,addtime,imu,baoliu18 FROM (SELECT t.id,t.tag_id,t.state,t.power,t.status,t.gaodu,t.sudu,t.pinglv,t.sleep_satus,t.sleep_time,t.gongfang,t.dong_status,t.version,t.addtime,t.imu,p.baoliu18 FROM tb_tag t,tb_person p WHERE t.tag_id = p.p_tagid AND p.p_name = :tagid OR t.tag_id = p.p_tagid AND t.tag_id = :tagid ORDER BY t.id DESC) s"; query = this.em.createNativeQuery(sql); query.setParameter("tagid", tagid); List resultList = query.getResultList(); List tb_tagList = new ArrayList(); if (resultList.size() > 0) { for(int i = 0; i < resultList.size(); ++i) { Object[] obj = (Object[])((Object[])resultList.get(i)); tb_tag tag = new tb_tag(); tag.setId((Integer)obj[0]); tag.setStatus(obj[4] == null ? "" : obj[4].toString()); tag.setTag_id(obj[1] == null ? "" : obj[1].toString()); tag.setState(obj[2] == null ? "" : obj[2].toString()); tag.setPower(obj[3] == null ? "" : obj[3].toString()); tag.setGaodu(obj[5] == null ? "" : obj[5].toString()); tag.setSudu(obj[6] == null ? "" : obj[6].toString()); tag.setPinglv(obj[7] == null ? "" : obj[7].toString()); tag.setVersion(obj[12] == null ? "" : obj[12].toString()); tag.setAddtime(obj[13] == null ? "" : obj[13].toString()); tag.setBaoliu18(obj[15] == null ? "" : obj[15].toString()); tb_tagList.add(tag); } } return tb_tagList; } public List findpermission(int page) { String sql = null; Query query = null; sql = "select * from tb_permission ORDER BY addtime DESC LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_permission per = new tb_permission(); per.setId((Integer)obj[0]); per.setType(obj[1] == null ? null : obj[1].toString()); per.setName(obj[2] == null ? null : obj[2].toString()); per.setTagid(obj[3] == null ? null : obj[3].toString()); per.setEvent(obj[4] == null ? null : obj[4].toString()); per.setAddtime(obj[5] == null ? null : obj[5].toString()); per.setDetails(obj[6] == null ? null : obj[6].toString()); permissions.add(per); } } return permissions; } public int getperManagementCount() { String sql = null; Query query = null; sql = "SELECT count(1) FROM tb_permission"; query = this.em.createNativeQuery(sql); return Integer.parseInt(query.getSingleResult().toString()); } @Transactional public void Warning_deleteper(String id) { String sql = null; Query query = null; sql = "DELETE FROM tb_permission WHERE id=:id"; query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } @Transactional public void Warning_deleteper2() { String sql = null; Query query = null; sql = "DELETE FROM tb_permission"; query = this.em.createNativeQuery(sql); query.executeUpdate(); } public List findidpermission2(String tagid) { String sql = null; Query query = null; sql = "select * from tb_permission WHERE name = :tagid OR tagid = :tagid ORDER BY addtime DESC"; query = this.em.createNativeQuery(sql); query.setParameter("tagid", tagid); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_permission per = new tb_permission(); per.setId((Integer)obj[0]); per.setType(obj[1] == null ? null : obj[1].toString()); per.setName(obj[2] == null ? null : obj[2].toString()); per.setTagid(obj[3] == null ? null : obj[3].toString()); per.setEvent(obj[4] == null ? null : obj[4].toString()); per.setAddtime(obj[5] == null ? null : obj[5].toString()); per.setDetails(obj[6] == null ? null : obj[6].toString()); permissions.add(per); } } return permissions; } @Transactional public void permission_add(tb_permission permission) { String sql = null; Query query = null; sql = "INSERT tb_permission (type,name,tagid,event,addtime,details) VALUES (:type,:name,:tagid,:event,now(),:details)"; query = this.em.createNativeQuery(sql); query.setParameter("type", permission.getType()); query.setParameter("name", permission.getName()); query.setParameter("tagid", permission.getTagid()); query.setParameter("event", permission.getEvent()); query.setParameter("details", permission.getDetails()); query.executeUpdate(); } public List findmessage(int page) { String sql = null; Query query = null; sql = "select * from tb_message_history ORDER BY sendtime DESC LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_message_history per = new tb_message_history(); per.setId((Integer)obj[0]); per.setBianma(obj[1] == null ? null : obj[1].toString()); per.setTagid(obj[2] == null ? null : obj[2].toString()); per.setUsername(obj[3] == null ? null : obj[3].toString()); per.setInfo(obj[4] == null ? null : obj[4].toString()); per.setSendtime(obj[5] == null ? null : obj[5].toString()); per.setReplytime(obj[6] == null ? null : obj[6].toString()); per.setBaoliu1(obj[7] == null ? null : obj[7].toString()); per.setBaoliu2(obj[8] == null ? null : obj[8].toString()); per.setBaoliu3(obj[9] == null ? null : obj[9].toString()); per.setBaoliu4(obj[10] == null ? null : obj[10].toString()); per.setBaoliu5(obj[11] == null ? null : obj[11].toString()); permissions.add(per); } } return permissions; } public List findmessage2() { String sql = null; Query query = null; sql = "select * from tb_message_history ORDER BY sendtime DESC"; query = this.em.createNativeQuery(sql); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_message_history per = new tb_message_history(); per.setId((Integer)obj[0]); per.setBianma(obj[1] == null ? null : obj[1].toString()); per.setTagid(obj[2] == null ? null : obj[2].toString()); per.setUsername(obj[3] == null ? null : obj[3].toString()); per.setInfo(obj[4] == null ? null : obj[4].toString()); per.setSendtime(obj[5] == null ? null : obj[5].toString()); per.setReplytime(obj[6] == null ? null : obj[6].toString()); per.setBaoliu1(obj[7] == null ? null : obj[7].toString()); per.setBaoliu2(obj[8] == null ? null : obj[8].toString()); per.setBaoliu3(obj[9] == null ? null : obj[9].toString()); per.setBaoliu4(obj[10] == null ? null : obj[10].toString()); per.setBaoliu5(obj[11] == null ? null : obj[11].toString()); permissions.add(per); } } return permissions; } public int getmessageManagementCount() { String sql = null; Query query = null; sql = "SELECT count(1) FROM tb_message_history"; query = this.em.createNativeQuery(sql); return Integer.parseInt(query.getSingleResult().toString()); } @Transactional public void message_delete(String[] checkVal) { String sql = null; Query query = null; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_message_history WHERE id = :id"; query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } } @Transactional public void message_deletea() { String sql = null; Query query = null; sql = "DELETE FROM tb_message_history"; query = this.em.createNativeQuery(sql); query.executeUpdate(); } public List findmessage3(String input) { String sql = null; Query query = null; sql = "select * from tb_message_history WHERE tagid = :input OR baoliu1 = :input ORDER BY sendtime DESC"; query = this.em.createNativeQuery(sql); query.setParameter("input", input); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_message_history per = new tb_message_history(); per.setId((Integer)obj[0]); per.setBianma(obj[1] == null ? null : obj[1].toString()); per.setTagid(obj[2] == null ? null : obj[2].toString()); per.setUsername(obj[3] == null ? null : obj[3].toString()); per.setInfo(obj[4] == null ? null : obj[4].toString()); per.setSendtime(obj[5] == null ? null : obj[5].toString()); per.setReplytime(obj[6] == null ? null : obj[6].toString()); per.setBaoliu1(obj[7] == null ? null : obj[7].toString()); per.setBaoliu2(obj[8] == null ? null : obj[8].toString()); per.setBaoliu3(obj[9] == null ? null : obj[9].toString()); per.setBaoliu4(obj[10] == null ? null : obj[10].toString()); per.setBaoliu5(obj[11] == null ? null : obj[11].toString()); permissions.add(per); } } return permissions; } public List findlixian(int page) { String sql = null; Query query = null; sql = "select * from tb_lixianrecord_0829 ORDER BY time DESC LIMIT :start,:end"; query = this.em.createNativeQuery(sql); query.setParameter("start", (page - 1) * Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); query.setParameter("end", 50); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_lixianrecord per = new tb_lixianrecord(); per.setId((Integer)obj[0]); per.setTagid(obj[1] == null ? null : obj[1].toString()); per.setName(obj[2] == null ? null : obj[2].toString()); per.setBumen(obj[3] == null ? null : obj[3].toString()); per.setPhone(obj[4] == null ? null : obj[4].toString()); per.setTime(obj[5] == null ? null : obj[5].toString()); permissions.add(per); } } return permissions; } public List findlixian2() { String sql = null; Query query = null; sql = "select * from tb_lixianrecord_0829 ORDER BY time DESC"; query = this.em.createNativeQuery(sql); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_lixianrecord per = new tb_lixianrecord(); per.setId((Integer)obj[0]); per.setTagid(obj[1] == null ? null : obj[1].toString()); per.setName(obj[2] == null ? null : obj[2].toString()); per.setBumen(obj[3] == null ? null : obj[3].toString()); per.setPhone(obj[4] == null ? null : obj[4].toString()); per.setTime(obj[5] == null ? null : obj[5].toString()); permissions.add(per); } } return permissions; } public int getlixianManagementCount() { String sql = null; Query query = null; sql = "SELECT count(1) FROM tb_lixianrecord_0829"; query = this.em.createNativeQuery(sql); return Integer.parseInt(query.getSingleResult().toString()); } @Transactional public void lixian_delete(String[] checkVal) { String sql = null; Query query = null; for(int i = 0; i < checkVal.length; ++i) { int id = Integer.parseInt(checkVal[i]); sql = "DELETE FROM tb_lixianrecord_0829 WHERE id = :id"; query = this.em.createNativeQuery(sql); query.setParameter("id", id); query.executeUpdate(); } } @Transactional public void lixian_deletea() { String sql = null; Query query = null; sql = "DELETE FROM tb_lixianrecord_0829"; query = this.em.createNativeQuery(sql); query.executeUpdate(); } public List findlixian3(String input) { String sql = null; Query query = null; sql = "select * from tb_lixianrecord_0829 WHERE tagid = :input OR name = :input ORDER BY time DESC"; query = this.em.createNativeQuery(sql); query.setParameter("input", input); List resultlist = query.getResultList(); List permissions = new ArrayList(); if (resultlist.size() > 0) { for(int i = 0; i < resultlist.size(); ++i) { Object[] obj = (Object[])((Object[])resultlist.get(i)); tb_lixianrecord per = new tb_lixianrecord(); per.setId((Integer)obj[0]); per.setTagid(obj[1] == null ? null : obj[1].toString()); per.setName(obj[2] == null ? null : obj[2].toString()); per.setBumen(obj[3] == null ? null : obj[3].toString()); per.setPhone(obj[4] == null ? null : obj[4].toString()); per.setTime(obj[5] == null ? null : obj[5].toString()); permissions.add(per); } } return permissions; } }