| | |
| | | // |
| | | // Source code recreated from a .class file by IntelliJ IDEA |
| | | // (powered by FernFlower decompiler) |
| | | // |
| | | |
| | | package com.hxzkoa.services; |
| | | |
| | | 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; |
| | | |
| | | import com.hxzkoa.json.tb_historyinwarning; |
| | | import com.hxzkoa.json.tb_lixianrecord; |
| | | import com.hxzkoa.json.tb_message_history; |
| | |
| | | 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 { |
| | |
| | | @Autowired |
| | | private CaozuoService cs; |
| | | |
| | | public WarningService() { |
| | | } |
| | | |
| | | public List<tb_warning> 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_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | |
| | | 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); |
| | | query.setParameter("end", 50); |
| | | List resultList = query.getResultList(); |
| | | List<tb_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | | public List<tb_warning> 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_warning> 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<tb_warning> 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_warning> 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; |
| | | } |
| | | |
| | |
| | | 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_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("objectid", input); |
| | | List resultList = query.getResultList(); |
| | | List<tb_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("str", str); |
| | | List resultList = query.getResultList(); |
| | | Map<String, Integer> reMap = new HashMap<String, Integer>(); |
| | | int warningSummaryCount = getWarningSummaryCount(); |
| | | Map<String, Integer> reMap = new HashMap(); |
| | | int warningSummaryCount = this.getWarningSummaryCount(); |
| | | int i; |
| | | Object[] obj; |
| | | if (resultList.size() > 3) { |
| | | for (int i = 0; i < 3; i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | for(i = 0; i < 3; ++i) { |
| | | obj = (Object[])((Object[])resultList.get(i)); |
| | | reMap.put(obj[0].toString(), Integer.parseInt(obj[1].toString())); |
| | | warningSummaryCount = warningSummaryCount - Integer.parseInt(obj[1].toString()); |
| | | warningSummaryCount -= Integer.parseInt(obj[1].toString()); |
| | | } |
| | | |
| | | reMap.put("其他", warningSummaryCount); |
| | | } else { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | 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; |
| | | } |
| | | |
| | |
| | | sql = "SELECT id,area,name,bumen,tagid,intime FROM tb_realinwarning"; |
| | | query = this.em.createNativeQuery(sql); |
| | | List resultList = query.getResultList(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList<tb_realinwarning>(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_realinwarning realinwarning = new tb_realinwarning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | realinwarning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_realinwarningList.add(realinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_realinwarningList; |
| | | } |
| | | |
| | |
| | | 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); |
| | | query.setParameter("end", 50); |
| | | List resultList = query.getResultList(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList<tb_realinwarning>(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_realinwarning realinwarning = new tb_realinwarning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | realinwarning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_realinwarningList.add(realinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_realinwarningList; |
| | | } |
| | | |
| | |
| | | sql = "SELECT id,area,name,bumen,tagid,intime FROM tb_realinwarning"; |
| | | query = this.em.createNativeQuery(sql); |
| | | List resultList = query.getResultList(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList<tb_realinwarning>(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_realinwarning realinwarning = new tb_realinwarning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | realinwarning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_realinwarningList.add(realinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_realinwarningList; |
| | | } |
| | | |
| | |
| | | public void realinWarning_delete(String[] checkVal) { |
| | | String sql = null; |
| | | Query query = null; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | 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 |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | int aaa = checkVal.length; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | for(int i = 0; i < checkVal.length; ++i) { |
| | | int id = Integer.parseInt(checkVal[i]); |
| | | sql = "DELETE FROM tb_realinwarning WHERE id = :id"; |
| | | cs.tb_caozuo("tb_realinwarning", 2); |
| | | this.cs.tb_caozuo("tb_realinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("id", id); |
| | | query.executeUpdate(); |
| | | } |
| | | |
| | | return aaa; |
| | | } |
| | | |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_realinwarning"; |
| | | cs.tb_caozuo("tb_realinwarning", 2); |
| | | this.cs.tb_caozuo("tb_realinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.executeUpdate(); |
| | | } |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_realinwarning"; |
| | | cs.tb_caozuo("tb_realinwarning", 2); |
| | | this.cs.tb_caozuo("tb_realinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | int aaa = query.executeUpdate(); |
| | | return aaa; |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("tag_id", input); |
| | | List resultList = query.getResultList(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList<tb_realinwarning>(); |
| | | List<tb_realinwarning> tb_realinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_realinwarning realinwarning = new tb_realinwarning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | 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()); |
| | |
| | | tb_realinwarningList.add(realinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_realinwarningList; |
| | | } |
| | | |
| | |
| | | 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_historyinwarning> tb_historyinwarningList = new ArrayList<tb_historyinwarning>(); |
| | | List<tb_historyinwarning> tb_historyinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultList.get(i)); |
| | | tb_historyinwarning historyinwarning = new tb_historyinwarning(); |
| | | historyinwarning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_historyinwarningList.add(historyinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_historyinwarningList; |
| | | } |
| | | |
| | |
| | | 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); |
| | | query.setParameter("end", 50); |
| | | List resultList = query.getResultList(); |
| | | List<tb_historyinwarning> tb_historyinwarningList = new ArrayList<tb_historyinwarning>(); |
| | | List<tb_historyinwarning> tb_historyinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultList.get(i)); |
| | | tb_historyinwarning historyinwarning = new tb_historyinwarning(); |
| | | historyinwarning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_historyinwarningList.add(historyinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_historyinwarningList; |
| | | } |
| | | |
| | |
| | | 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_historyinwarning> tb_historyinwarningList = new ArrayList<tb_historyinwarning>(); |
| | | List<tb_historyinwarning> tb_historyinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultList.get(i)); |
| | | tb_historyinwarning historyinwarning = new tb_historyinwarning(); |
| | | historyinwarning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_historyinwarningList.add(historyinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_historyinwarningList; |
| | | } |
| | | |
| | |
| | | public void historicalWarning_delete(String[] checkVal) { |
| | | String sql = null; |
| | | Query query = null; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | for(int i = 0; i < checkVal.length; ++i) { |
| | | int id = Integer.parseInt(checkVal[i]); |
| | | sql = "DELETE FROM tb_historyinwarning WHERE id = :id"; |
| | | cs.tb_caozuo("tb_historyinwarning", 2); |
| | | this.cs.tb_caozuo("tb_historyinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("id", id); |
| | | query.executeUpdate(); |
| | | } |
| | | |
| | | } |
| | | |
| | | @Transactional |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | int aaa = checkVal.length; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | for(int i = 0; i < checkVal.length; ++i) { |
| | | int id = Integer.parseInt(checkVal[i]); |
| | | sql = "DELETE FROM tb_historyinwarning WHERE id = :id"; |
| | | cs.tb_caozuo("tb_historyinwarning", 2); |
| | | this.cs.tb_caozuo("tb_historyinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("id", id); |
| | | query.executeUpdate(); |
| | | } |
| | | |
| | | return aaa; |
| | | } |
| | | |
| | |
| | | public void Warning_delete(String[] checkVal) { |
| | | String sql = null; |
| | | Query query = null; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | for(int i = 0; i < checkVal.length; ++i) { |
| | | int id = Integer.parseInt(checkVal[i]); |
| | | sql = "DELETE FROM tb_warning WHERE id = :id"; |
| | | cs.tb_caozuo("tb_warning", 2); |
| | | this.cs.tb_caozuo("tb_warning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("id", id); |
| | | query.executeUpdate(); |
| | | } |
| | | |
| | | } |
| | | |
| | | @Transactional |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | int aaa = checkVal.length; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | for(int i = 0; i < checkVal.length; ++i) { |
| | | int id = Integer.parseInt(checkVal[i]); |
| | | sql = "DELETE FROM tb_warning WHERE id = :id"; |
| | | cs.tb_caozuo("tb_warning", 2); |
| | | this.cs.tb_caozuo("tb_warning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("id", id); |
| | | query.executeUpdate(); |
| | | } |
| | | |
| | | return aaa; |
| | | } |
| | | |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_historyinwarning"; |
| | | cs.tb_caozuo("tb_historyinwarning", 2); |
| | | this.cs.tb_caozuo("tb_historyinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.executeUpdate(); |
| | | } |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_historyinwarning"; |
| | | cs.tb_caozuo("tb_historyinwarning", 2); |
| | | this.cs.tb_caozuo("tb_historyinwarning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | int aaa = query.executeUpdate(); |
| | | return aaa; |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_warning"; |
| | | cs.tb_caozuo("tb_warning", 2); |
| | | this.cs.tb_caozuo("tb_warning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.executeUpdate(); |
| | | } |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_warning"; |
| | | cs.tb_caozuo("tb_warning", 2); |
| | | this.cs.tb_caozuo("tb_warning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | int aaa = query.executeUpdate(); |
| | | return aaa; |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "DELETE FROM tb_warning WHERE type=:fenlei"; |
| | | cs.tb_caozuo("tb_warning", 2); |
| | | this.cs.tb_caozuo("tb_warning", 2); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("fenlei", fenlei); |
| | | query.executeUpdate(); |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | int aaa = checkVal.length; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | for(int i = 0; i < checkVal.length; ++i) { |
| | | int id = Integer.parseInt(checkVal[i]); |
| | | sql = "UPDATE tb_warning SET status='已处理' WHERE objectid = :id"; |
| | | cs.tb_caozuo("tb_warning", 3); |
| | | this.cs.tb_caozuo("tb_warning", 3); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("id", id); |
| | | query.executeUpdate(); |
| | | } |
| | | |
| | | return aaa; |
| | | } |
| | | |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "UPDATE tb_warning SET status='已处理'"; |
| | | cs.tb_caozuo("tb_warning", 3); |
| | | this.cs.tb_caozuo("tb_warning", 3); |
| | | query = this.em.createNativeQuery(sql); |
| | | int aaa = query.executeUpdate(); |
| | | return aaa; |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "UPDATE tb_realpositoin SET sos='0'"; |
| | | cs.tb_caozuo("tb_realpositoin", 3); |
| | | this.cs.tb_caozuo("tb_realpositoin", 3); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.executeUpdate(); |
| | | } |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("tag_id", input); |
| | | List resultList = query.getResultList(); |
| | | List<tb_historyinwarning> tb_historyinwarningList = new ArrayList<tb_historyinwarning>(); |
| | | List<tb_historyinwarning> tb_historyinwarningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | 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()); |
| | |
| | | tb_historyinwarningList.add(historyinwarning); |
| | | } |
| | | } |
| | | |
| | | return tb_historyinwarningList; |
| | | } |
| | | |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "INSERT tb_warning (type,objectid,status,time) VALUES (:type,:objectid,:status,now())"; |
| | | cs.tb_caozuo("tb_warning", 1); |
| | | this.cs.tb_caozuo("tb_warning", 1); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("type", warning.getType().toString()); |
| | | query.setParameter("objectid", warning.getObjectid()); |
| | |
| | | String sql = null; |
| | | Query query = null; |
| | | sql = "INSERT tb_realinwarning (area,name,bumen,tagid,intime) VALUES (:area,:name,:bumen,:tagid,now())"; |
| | | cs.tb_caozuo("tb_realinwarning", 1); |
| | | this.cs.tb_caozuo("tb_realinwarning", 1); |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("area", realinwarning.getArea()); |
| | | query.setParameter("name", realinwarning.getName()); |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("fenlei", fenlei); |
| | | List resultList = query.getResultList(); |
| | | List<tb_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("fenlei", fenlei); |
| | | List resultList = query.getResultList(); |
| | | List<tb_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | |
| | | query.setParameter("fenlei", fenlei); |
| | | query.setParameter("fenlei2", fenlei2); |
| | | List resultList = query.getResultList(); |
| | | List<tb_warning> tb_warningList = new ArrayList<tb_warning>(); |
| | | List<tb_warning> tb_warningList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | tb_warning warning = new tb_warning(); |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | warning.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_warningList.add(warning); |
| | | } |
| | | } |
| | | |
| | | return tb_warningList; |
| | | } |
| | | |
| | |
| | | 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_tag> tb_tagList = new ArrayList<tb_tag>(); |
| | | List<tb_tag> tb_tagList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultList.get(i)); |
| | | tb_tag tag = new tb_tag(); |
| | | tag.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_tagList.add(tag); |
| | | } |
| | | } |
| | | |
| | | return tb_tagList; |
| | | } |
| | | |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("tagid", tagid); |
| | | List resultList = query.getResultList(); |
| | | List<tb_tag> tb_tagList = new ArrayList<tb_tag>(); |
| | | List<tb_tag> tb_tagList = new ArrayList(); |
| | | if (resultList.size() > 0) { |
| | | for (int i = 0; i < resultList.size(); i++) { |
| | | Object[] obj = (Object[]) resultList.get(i); |
| | | for(int i = 0; i < resultList.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultList.get(i)); |
| | | tb_tag tag = new tb_tag(); |
| | | tag.setId((int) obj[0]); |
| | | 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()); |
| | |
| | | tb_tagList.add(tag); |
| | | } |
| | | } |
| | | |
| | | return tb_tagList; |
| | | } |
| | | |
| | |
| | | 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_permission> permissions = new ArrayList<>(); |
| | | List<tb_permission> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | for(int i = 0; i < resultlist.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultlist.get(i)); |
| | | tb_permission per = new tb_permission(); |
| | | per.setId((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("tagid", tagid); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_permission> permissions = new ArrayList<>(); |
| | | List<tb_permission> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | for(int i = 0; i < resultlist.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultlist.get(i)); |
| | | tb_permission per = new tb_permission(); |
| | | per.setId((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); |
| | | query.setParameter("end", 50); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_message_history> permissions = new ArrayList<>(); |
| | | List<tb_message_history> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | 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((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | sql = "select * from tb_message_history ORDER BY sendtime DESC"; |
| | | query = this.em.createNativeQuery(sql); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_message_history> permissions = new ArrayList<>(); |
| | | List<tb_message_history> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | 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((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | public void message_delete(String[] checkVal) { |
| | | String sql = null; |
| | | Query query = null; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | 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 |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("input", input); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_message_history> permissions = new ArrayList<>(); |
| | | List<tb_message_history> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | 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((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage"))); |
| | | query.setParameter("end", 50); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_lixianrecord> permissions = new ArrayList<>(); |
| | | List<tb_lixianrecord> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | for(int i = 0; i < resultlist.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultlist.get(i)); |
| | | tb_lixianrecord per = new tb_lixianrecord(); |
| | | per.setId((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | sql = "select * from tb_lixianrecord_0829 ORDER BY time DESC"; |
| | | query = this.em.createNativeQuery(sql); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_lixianrecord> permissions = new ArrayList<>(); |
| | | List<tb_lixianrecord> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | for(int i = 0; i < resultlist.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultlist.get(i)); |
| | | tb_lixianrecord per = new tb_lixianrecord(); |
| | | per.setId((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | |
| | |
| | | public void lixian_delete(String[] checkVal) { |
| | | String sql = null; |
| | | Query query = null; |
| | | for (int i = 0; i < checkVal.length; i++) { |
| | | |
| | | 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 |
| | |
| | | query = this.em.createNativeQuery(sql); |
| | | query.setParameter("input", input); |
| | | List resultlist = query.getResultList(); |
| | | List<tb_lixianrecord> permissions = new ArrayList<>(); |
| | | List<tb_lixianrecord> permissions = new ArrayList(); |
| | | if (resultlist.size() > 0) { |
| | | for (int i=0; i<resultlist.size(); i++) { |
| | | Object[] obj = (Object[])resultlist.get(i); |
| | | for(int i = 0; i < resultlist.size(); ++i) { |
| | | Object[] obj = (Object[])((Object[])resultlist.get(i)); |
| | | tb_lixianrecord per = new tb_lixianrecord(); |
| | | per.setId((int)obj[0]); |
| | | 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()); |
| | |
| | | permissions.add(per); |
| | | } |
| | | } |
| | | |
| | | return permissions; |
| | | } |
| | | } |