From 52cffc4ab8e9787a6f233295502c7c9788dddae1 Mon Sep 17 00:00:00 2001
From: fxl <473369119@qq.com>
Date: 星期二, 07 三月 2023 10:45:17 +0800
Subject: [PATCH] 3.7
---
src/main/java/com/hxzkoa/services/WarningService.java | 646 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 639 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/hxzkoa/services/WarningService.java b/src/main/java/com/hxzkoa/services/WarningService.java
index 2d12aab..34c5415 100644
--- a/src/main/java/com/hxzkoa/services/WarningService.java
+++ b/src/main/java/com/hxzkoa/services/WarningService.java
@@ -14,7 +14,11 @@
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_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;
@@ -51,7 +55,7 @@
public List<tb_warning> getWarningSummary(int page) {
String sql = null;
Query query = null;
- sql = "SELECT id,type,objectid,`status`,time FROM tb_warning ORDER BY id DESC LIMIT :start,:end";
+ 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")));
@@ -66,6 +70,32 @@
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> 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_warning> tb_warningList = new ArrayList<tb_warning>();
+ if (resultList.size() > 0) {
+ 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]);
+ 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);
}
}
@@ -83,7 +113,7 @@
public List<tb_warning> searchWarningSummary(String input) {
String sql = null;
Query query = null;
- sql = "SELECT id,type,objectid,`status`,time FROM tb_warning WHERE objectid = :objectid";
+ 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();
@@ -97,6 +127,7 @@
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);
}
}
@@ -176,6 +207,29 @@
}
return tb_realinwarningList;
}
+
+ public List<tb_realinwarning> 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_realinwarning> tb_realinwarningList = new ArrayList<tb_realinwarning>();
+ if (resultList.size() > 0) {
+ 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]);
+ 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;
@@ -192,11 +246,26 @@
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";
cs.tb_caozuo("tb_realinwarning", 2);
query = this.em.createNativeQuery(sql);
query.setParameter("id", id);
query.executeUpdate();
}
+ return aaa;
}
@Transactional
@@ -208,11 +277,22 @@
query = this.em.createNativeQuery(sql);
query.executeUpdate();
}
+
+ @Transactional
+ public int realinWarning_deleteAlla() {
+ String sql = null;
+ Query query = null;
+ sql = "DELETE FROM tb_realinwarning";
+ cs.tb_caozuo("tb_realinwarning", 2);
+ query = this.em.createNativeQuery(sql);
+ int aaa = query.executeUpdate();
+ return aaa;
+ }
public List<tb_realinwarning> searchRealinWarning(String input) {
String sql = null;
Query query = null;
- sql = "SELECT id,area,name,bumen,tagid,intime FROM tb_realinwarning WHERE tagid = :tag_id";
+ 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();
@@ -285,6 +365,32 @@
}
return tb_historyinwarningList;
}
+
+ public List<tb_historyinwarning> 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_historyinwarning> tb_historyinwarningList = new ArrayList<tb_historyinwarning>();
+ if (resultList.size() > 0) {
+ for (int i = 0; i < resultList.size(); i++) {
+ Object[] obj = (Object[]) resultList.get(i);
+ tb_historyinwarning historyinwarning = new tb_historyinwarning();
+ historyinwarning.setId((int) 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;
@@ -309,6 +415,22 @@
}
@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";
+ 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;
@@ -321,6 +443,22 @@
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";
+ cs.tb_caozuo("tb_warning", 2);
+ query = this.em.createNativeQuery(sql);
+ query.setParameter("id", id);
+ query.executeUpdate();
+ }
+ return aaa;
+ }
@Transactional
public void historicalWarning_deleteAll() {
@@ -333,6 +471,17 @@
}
@Transactional
+ public int historicalWarning_deleteAlla() {
+ String sql = null;
+ Query query = null;
+ sql = "DELETE FROM tb_historyinwarning";
+ 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;
@@ -343,9 +492,32 @@
}
@Transactional
- public void historicalWarning_handle(String[] checkVal) {
+ public int Warning_deleteAlla() {
String sql = null;
Query query = null;
+ sql = "DELETE FROM tb_warning";
+ 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";
+ 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";
@@ -354,16 +526,18 @@
query.setParameter("id", id);
query.executeUpdate();
}
+ return aaa;
}
@Transactional
- public void historicalWarning_handleAll() {
+ public int historicalWarning_handleAll() {
String sql = null;
Query query = null;
sql = "UPDATE tb_warning SET status='宸插鐞�'";
cs.tb_caozuo("tb_warning", 3);
query = this.em.createNativeQuery(sql);
- query.executeUpdate();
+ int aaa = query.executeUpdate();
+ return aaa;
}
@Transactional
@@ -379,7 +553,7 @@
public List<tb_historyinwarning> searchHistoricalWarning(String input) {
String sql = null;
Query query = null;
- sql = "SELECT id,area,'name',bumen,tagid,intime,outtime,alltime,beizhu FROM tb_historyinwarning WHERE tagid = :tag_id";
+ 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();
@@ -428,4 +602,462 @@
query.setParameter("tagid", realinwarning.getTagid());
query.executeUpdate();
}
+
+ public List<tb_warning> 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_warning> tb_warningList = new ArrayList<tb_warning>();
+ if (resultList.size() > 0) {
+ 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]);
+ 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> 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_warning> tb_warningList = new ArrayList<tb_warning>();
+ if (resultList.size() > 0) {
+ 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]);
+ 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> 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_warning> tb_warningList = new ArrayList<tb_warning>();
+ if (resultList.size() > 0) {
+ 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]);
+ 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_tag> 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_tag> tb_tagList = new ArrayList<tb_tag>();
+ if (resultList.size() > 0) {
+ for (int i = 0; i < resultList.size(); i++) {
+ Object[] obj = (Object[]) resultList.get(i);
+ tb_tag tag = new tb_tag();
+ tag.setId((int) 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<tb_tag> 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_tag> tb_tagList = new ArrayList<tb_tag>();
+ if (resultList.size() > 0) {
+ for (int i = 0; i < resultList.size(); i++) {
+ Object[] obj = (Object[]) resultList.get(i);
+ tb_tag tag = new tb_tag();
+ tag.setId((int) 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<tb_permission> 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<tb_permission> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_permission per = new tb_permission();
+ per.setId((int)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<tb_permission> 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<tb_permission> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_permission per = new tb_permission();
+ per.setId((int)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<tb_message_history> 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage")));
+ List resultlist = query.getResultList();
+ 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);
+ tb_message_history per = new tb_message_history();
+ per.setId((int)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<tb_message_history> 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<tb_message_history> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_message_history per = new tb_message_history();
+ per.setId((int)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<tb_message_history> 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<tb_message_history> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_message_history per = new tb_message_history();
+ per.setId((int)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<tb_lixianrecord> 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", Integer.parseInt(ModifyConfig.readData(Config.getPageConfig(), "perPage")));
+ List resultlist = query.getResultList();
+ List<tb_lixianrecord> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_lixianrecord per = new tb_lixianrecord();
+ per.setId((int)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<tb_lixianrecord> 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<tb_lixianrecord> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_lixianrecord per = new tb_lixianrecord();
+ per.setId((int)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<tb_lixianrecord> 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<tb_lixianrecord> permissions = new ArrayList<>();
+ if (resultlist.size() > 0) {
+ for (int i=0; i<resultlist.size(); i++) {
+ Object[] obj = (Object[])resultlist.get(i);
+ tb_lixianrecord per = new tb_lixianrecord();
+ per.setId((int)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;
+ }
}
--
Gitblit v1.10.0