YtiotTOutcryPackageServicesImpl.java 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711
  1. package cn.com.usky.iot.outcrypackage.service;
  2. import java.text.SimpleDateFormat;
  3. import java.util.Date;
  4. import java.util.HashMap;
  5. import java.util.List;
  6. import java.util.Map;
  7. import cn.com.usky.iot.entity.YtiotTcAlarmPackages;
  8. import cn.com.usky.iot.entity.YtiotTcAlarmPackagesZb;
  9. //import cn.com.usky.iot.entity.YtiotTcOutgoingAlarm;
  10. import cn.com.usky.iot.entity.YtiotVCompany;
  11. import cn.com.usky.iot.entity.YtiotVCompanyId;
  12. import cn.com.usky.iot.alarmpackages.dao.YtiotTcAlarmPackagesDao;
  13. import cn.com.usky.iot.alarmpackageszb.dao.YtiotTcAlarmPackagesZbDao;
  14. //import cn.com.usky.iot.outgoingalarm.dao.YtiotTcOutgoingAlarmDao;
  15. import cn.com.usky.iot.company.dao.YtiotVCompanyDao;
  16. import cn.com.usky.utils.DaoResult;
  17. import net.sf.json.JSONArray;
  18. import net.sf.json.JSONObject;
  19. public class YtiotTOutcryPackageServicesImpl implements YtiotTOutcryPackageService {
  20. private YtiotTcAlarmPackagesDao ytiotTcAlarmPackagesDao;
  21. private YtiotTcAlarmPackagesZbDao ytiotTcAlarmPackagesZbDao;
  22. // private YtiotTcOutgoingAlarmDao ytiotTcOutgoingAlarmDao;
  23. private YtiotVCompanyDao ytiotVCompanyDao;
  24. public YtiotVCompanyDao getYtiotVCompanyDao() {
  25. return ytiotVCompanyDao;
  26. }
  27. public void setYtiotVCompanyDao(YtiotVCompanyDao ytiotVCompanyDao) {
  28. this.ytiotVCompanyDao = ytiotVCompanyDao;
  29. }
  30. public YtiotTcAlarmPackagesDao getYtiotTcAlarmPackagesDao() {
  31. return ytiotTcAlarmPackagesDao;
  32. }
  33. public void setYtiotTcAlarmPackagesDao(YtiotTcAlarmPackagesDao ytiotTcAlarmPackagesDao) {
  34. this.ytiotTcAlarmPackagesDao = ytiotTcAlarmPackagesDao;
  35. }
  36. public YtiotTcAlarmPackagesZbDao getYtiotTcAlarmPackagesZbDao() {
  37. return ytiotTcAlarmPackagesZbDao;
  38. }
  39. public void setYtiotTcAlarmPackagesZbDao(YtiotTcAlarmPackagesZbDao ytiotTcAlarmPackagesZbDao) {
  40. this.ytiotTcAlarmPackagesZbDao = ytiotTcAlarmPackagesZbDao;
  41. }
  42. // public YtiotTcOutgoingAlarmDao getYtiotTcOutgoingAlarmDao() {
  43. // return ytiotTcOutgoingAlarmDao;
  44. // }
  45. //
  46. // public void setYtiotTcOutgoingAlarmDao(YtiotTcOutgoingAlarmDao ytiotTcOutgoingAlarmDao) {
  47. // this.ytiotTcOutgoingAlarmDao = ytiotTcOutgoingAlarmDao;
  48. // }
  49. public boolean chk_string_param(String param) {
  50. if(param==null)
  51. return true;
  52. if(param.indexOf("=")>=0)
  53. return false;
  54. if(param.indexOf("\'")>=0)
  55. return false;
  56. if(param.indexOf("\"")>=0)
  57. return false;
  58. return true;
  59. }
  60. public String chkhw(String hqlwhere){
  61. if(hqlwhere==null)
  62. return " where ";
  63. else
  64. return hqlwhere+" and ";
  65. }
  66. public String fieldname(String field){
  67. if(field.equals("UQ_SETMREAL_ID"))
  68. return "uqSetmrealId";
  69. if(field.equals("I_ORDER_IDX"))
  70. return "IOrderIdx";
  71. if(field.equals("UQ_COMPANY_ID"))
  72. return "uqCompanyId";
  73. if(field.equals("D_START_STORETIME"))
  74. return "DStartStoretime";
  75. if(field.equals("D_END_STORETIME"))
  76. return "DEndStoretime";
  77. if(field.equals("UQ_SETMREAL_ZB_ID"))
  78. return "uqSetmrealZbId";
  79. if(field.equals("UQ_CATEGORY"))
  80. return "uqCategory";
  81. if(field.equals("I_NUMBER_OF_BARS"))
  82. return "INumberOfBars";
  83. if(field.equals("I_CYCLE"))
  84. return "ICycle";
  85. if(field.equals("V_COMPANY_NAME"))
  86. return "VCompanyName";
  87. if(field.equals("owner_id"))
  88. return "ownerId";
  89. if(field.equals("owner_name"))
  90. return "ownerName";
  91. if(field.equals("V_PHONE"))
  92. return "VPhone";
  93. if(field.equals("E_STATUS"))
  94. return "EStatus";
  95. return null;
  96. }
  97. @Override
  98. public String appendOutcryPackage(String queryJson) throws Exception {
  99. // TODO Auto-generated method stub
  100. SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
  101. String UQ_SETMREAL_ID = null;
  102. String UQ_COMPANY_ID = null;
  103. String D_START_STORETIME = null;
  104. String D_END_STORETIME = null;
  105. String UQ_SETMREAL_ZB_ID = null;
  106. String UQ_CATEGORY = null;
  107. String I_NUMBER_OF_BARS = null;
  108. String I_CYCLE = null;
  109. String V_PHONE = null;
  110. String E_STATUS = null;
  111. JSONObject q_json = null;
  112. JSONArray jSONArray = new JSONArray();
  113. JSONObject json = new JSONObject();
  114. json.put("action", "appendOutcryPackage");
  115. if(queryJson!=null) {
  116. q_json = JSONObject.fromObject(queryJson);
  117. UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
  118. UQ_CATEGORY = q_json.has("UQ_CATEGORY")?q_json.getString("UQ_CATEGORY"):null;
  119. D_START_STORETIME = q_json.has("D_START_STORETIME")?q_json.getString("D_START_STORETIME"):null;
  120. D_END_STORETIME = q_json.has("D_END_STORETIME")?q_json.getString("D_END_STORETIME"):null;
  121. I_NUMBER_OF_BARS = q_json.has("I_NUMBER_OF_BARS")?q_json.getString("I_NUMBER_OF_BARS"):null;
  122. I_CYCLE = q_json.has("I_CYCLE")?q_json.getString("I_CYCLE"):null;
  123. V_PHONE = q_json.has("V_PHONE")?q_json.getString("V_PHONE"):null;
  124. //json.put("query", queryJson);
  125. }
  126. if(chk_string_param(UQ_COMPANY_ID)&&chk_string_param(UQ_CATEGORY)&&chk_string_param(D_START_STORETIME)
  127. &&chk_string_param(D_END_STORETIME)&&chk_string_param(I_NUMBER_OF_BARS)
  128. &&chk_string_param(I_CYCLE)) {
  129. YtiotTcAlarmPackages o = new YtiotTcAlarmPackages();
  130. o.setUqCompanyId(UQ_COMPANY_ID);
  131. o.setVPhone(V_PHONE);
  132. o.setDStartStoretime(formatter.parse(D_START_STORETIME));
  133. o.setDEndStoretime(formatter.parse(D_END_STORETIME));
  134. DaoResult ret = ytiotTcAlarmPackagesDao.add(o);
  135. YtiotTcAlarmPackagesZb o1 = new YtiotTcAlarmPackagesZb();
  136. o1.setUqSetmrealId(o.getUqSetmrealId());
  137. o1.setUqCategory(UQ_CATEGORY);
  138. o1.setINumberOfBars(I_NUMBER_OF_BARS);
  139. o1.setICycle(I_CYCLE);
  140. o1.setEStatus("1");
  141. DaoResult ret1 = ytiotTcAlarmPackagesZbDao.add(o1);
  142. json.put("success", ret1.isSuccess());
  143. json.put("Msg", ret1.getResult());
  144. }else {
  145. json.put("success", false);
  146. json.put("Msg", "参数验证错误");
  147. }
  148. return json.toString();
  149. }
  150. @Override
  151. public String updateOutcryPackage(String queryJson) throws Exception {
  152. // TODO Auto-generated method stub
  153. SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
  154. String UQ_SETMREAL_ID = null;
  155. String UQ_COMPANY_ID = null;
  156. String UQ_COMPANY_ID1 = null;
  157. String D_START_STORETIME = null;
  158. String D_END_STORETIME = null;
  159. String UQ_SETMREAL_ZB_ID = null;
  160. String UQ_CATEGORY = null;
  161. String I_NUMBER_OF_BARS = null;
  162. String I_CYCLE = null;
  163. String V_PHONE = null;
  164. String E_STATUS = null;
  165. JSONObject q_json = null;
  166. JSONArray jSONArray = new JSONArray();
  167. JSONObject json = new JSONObject();
  168. json.put("action", "updateOutcryPackage");
  169. if(queryJson!=null) {
  170. q_json = JSONObject.fromObject(queryJson);
  171. UQ_SETMREAL_ID = q_json.has("UQ_SETMREAL_ID")?q_json.getString("UQ_SETMREAL_ID"):null;
  172. UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
  173. D_START_STORETIME = q_json.has("D_START_STORETIME")?q_json.getString("D_START_STORETIME"):null;
  174. D_END_STORETIME = q_json.has("D_END_STORETIME")?q_json.getString("D_END_STORETIME"):null;
  175. V_PHONE = q_json.has("V_PHONE")?q_json.getString("V_PHONE"):null;
  176. UQ_SETMREAL_ZB_ID = q_json.has("UQ_SETMREAL_ZB_ID")?q_json.getString("UQ_SETMREAL_ZB_ID"):null;
  177. UQ_CATEGORY = q_json.has("UQ_CATEGORY")?q_json.getString("UQ_CATEGORY"):null;
  178. I_NUMBER_OF_BARS = q_json.has("I_NUMBER_OF_BARS")?q_json.getString("I_NUMBER_OF_BARS"):null;
  179. I_CYCLE = q_json.has("I_CYCLE")?q_json.getString("I_CYCLE"):null;
  180. E_STATUS = q_json.has("E_STATUS")?q_json.getString("E_STATUS").toUpperCase():null;
  181. //json.put("query", queryJson);
  182. }
  183. if(chk_string_param(UQ_COMPANY_ID)&&chk_string_param(D_START_STORETIME)&&chk_string_param(D_END_STORETIME)
  184. &&chk_string_param(UQ_CATEGORY)&&chk_string_param(I_NUMBER_OF_BARS)&&chk_string_param(I_CYCLE)
  185. &&chk_string_param(UQ_SETMREAL_ID)&&chk_string_param(UQ_SETMREAL_ZB_ID)&&chk_string_param(V_PHONE)&&chk_string_param(E_STATUS)) {
  186. if(UQ_SETMREAL_ID!=null&&UQ_SETMREAL_ZB_ID!=null) {
  187. List list = ytiotTcAlarmPackagesDao.query(" where u."+fieldname("UQ_SETMREAL_ID")+" ='"+UQ_SETMREAL_ID+"' ", null, null, null, null);
  188. List list1 = ytiotTcAlarmPackagesZbDao.query(" where u."+fieldname("UQ_SETMREAL_ZB_ID")+" ='"+UQ_SETMREAL_ZB_ID+"' ", null, null, null, null);
  189. if(list.size()>0&&list1.size()>0) {
  190. // System.out.println("测试1"+UQ_SETMREAL_ID);
  191. // System.out.println("测试1"+UQ_SETMREAL_ZB_ID);
  192. YtiotTcAlarmPackages o = (YtiotTcAlarmPackages) list.get(0);
  193. YtiotTcAlarmPackagesZb o1 = (YtiotTcAlarmPackagesZb) list1.get(0);
  194. if(UQ_COMPANY_ID!=null) {
  195. List list3 = ytiotVCompanyDao.query(" where u.id."+fieldname("owner_name")+" ='"+UQ_COMPANY_ID+"' ", null, null, null, null);
  196. if(list3.size()>0) {
  197. YtiotVCompany o3 = (YtiotVCompany)list3.get(0);
  198. YtiotVCompanyId oid1 = o3.getId();
  199. o.setUqCompanyId(oid1.getOwnerId());
  200. }
  201. }
  202. if(D_START_STORETIME!=null)
  203. o.setDStartStoretime(formatter.parse(D_START_STORETIME));
  204. if(D_END_STORETIME!=null)
  205. o.setDEndStoretime(formatter.parse(D_END_STORETIME));
  206. if(V_PHONE!=null)
  207. o.setVPhone(V_PHONE);
  208. if(UQ_CATEGORY!=null)
  209. o1.setUqCategory(UQ_CATEGORY);
  210. if(I_NUMBER_OF_BARS!=null)
  211. o1.setINumberOfBars(I_NUMBER_OF_BARS);
  212. if(I_CYCLE!=null)
  213. o1.setICycle(I_CYCLE);
  214. o1.setEStatus(E_STATUS);
  215. DaoResult ret = ytiotTcAlarmPackagesDao.update(o);
  216. DaoResult ret1 = ytiotTcAlarmPackagesZbDao.update(o1);
  217. json.put("success", ret1.isSuccess());
  218. json.put("MSG", ret1.getResult());
  219. }else {
  220. json.put("success", false);
  221. json.put("MSG", "需要编辑的权限记录不存在");
  222. }
  223. }else {
  224. json.put("success", false);
  225. json.put("MSG", "记录ID不能为空");
  226. }
  227. }else {
  228. json.put("success", false);
  229. json.put("MSG", "参数验证错误");
  230. }
  231. return json.toString();
  232. }
  233. @Override
  234. public String deleteOutcryPackage(String queryJson) throws Exception {
  235. // TODO Auto-generated method stub
  236. //String UQ_COMPANY_ID = null;
  237. JSONObject q_json = null;
  238. JSONArray jSONArray = new JSONArray();
  239. JSONArray jsonCompanyList = new JSONArray();
  240. JSONObject json = new JSONObject();
  241. json.put("action", "deleteOutcryPackage");
  242. if(queryJson!=null) {
  243. q_json = JSONObject.fromObject(queryJson);
  244. if(q_json.has("UQ_SETMREAL_ZB_ID_LIST")) {
  245. jsonCompanyList = q_json.getJSONArray("UQ_SETMREAL_ZB_ID_LIST");
  246. // System.out.println("测试:111111111111111");
  247. for(int i=0;i<jsonCompanyList.size();i++) {
  248. // System.out.println("测试:2222222222222");
  249. JSONObject j_temp = jsonCompanyList.getJSONObject(i);
  250. if(j_temp.has("UQ_SETMREAL_ZB_ID")) {
  251. // System.out.println("测试:5555555555555");
  252. List list = ytiotTcAlarmPackagesZbDao.query(" where u."+fieldname("UQ_SETMREAL_ZB_ID")+" ='"+j_temp.getString("UQ_SETMREAL_ZB_ID")+"' ", null, null, null, null);
  253. // System.out.println("测试:444444444444");
  254. if(list.size()>0) {
  255. // System.out.println("测试:33333333333333");
  256. for(int j=0;j<list.size();j++) {
  257. YtiotTcAlarmPackagesZb o = (YtiotTcAlarmPackagesZb) list.get(j);
  258. o.setEStatus("3");
  259. ytiotTcAlarmPackagesZbDao.delect(o);
  260. // System.out.println("测试:6666666666666");
  261. }
  262. }
  263. }
  264. }
  265. }
  266. }
  267. return json.toString();
  268. }
  269. @Override
  270. public String getOutcryPackageList(String queryJson, String page, String start, String limit, String sort) throws Exception {
  271. // TODO Auto-generated method stub
  272. // SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  273. SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
  274. String UQ_SETMREAL_ID = null;
  275. String UQ_COMPANY_ID = null;
  276. String UQ_COMPANY_ID1 = null;
  277. String D_START_STORETIME = null;
  278. String D_END_STORETIME = null;
  279. String UQ_SETMREAL_ZB_ID = null;
  280. String UQ_CATEGORY = null;
  281. String I_NUMBER_OF_BARS = null;
  282. String I_CYCLE = null;
  283. String I_ORDER_IDX = null;
  284. String owner_id = null;
  285. String owner_name = null;
  286. String UQ_SETMREAL_ID_LIST = null;
  287. String UQ_SETMREAL_ID_LIST1 = null;
  288. String UQ_SETMREAL_ID_LIST2 = null;
  289. String V_PHONE = null;
  290. String V_PHONE_LIST = null;
  291. String Page = null;
  292. String Start = null;
  293. JSONArray Sort = null;
  294. String Limit = null;
  295. String hqlwhere = null;
  296. String hqlwhere1 = null;
  297. String order = null;
  298. String dir = null;
  299. String order_str = null;
  300. JSONObject q_json = null;
  301. JSONArray jSONArray = new JSONArray();
  302. JSONObject json = new JSONObject();
  303. json.put("action", "getOutcryPackageList");
  304. if(queryJson!=null) {
  305. q_json = JSONObject.fromObject(queryJson);
  306. I_ORDER_IDX = q_json.has("I_ORDER_IDX")?q_json.getString("I_ORDER_IDX"):null;
  307. UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
  308. D_START_STORETIME = q_json.has("D_START_STORETIME")?q_json.getString("D_START_STORETIME"):null;
  309. D_END_STORETIME = q_json.has("D_END_STORETIME")?q_json.getString("D_END_STORETIME"):null;
  310. V_PHONE = q_json.has("V_PHONE")?q_json.getString("V_PHONE"):null;
  311. UQ_CATEGORY = q_json.has("UQ_CATEGORY")?q_json.getString("UQ_CATEGORY"):null;
  312. I_NUMBER_OF_BARS = q_json.has("I_NUMBER_OF_BARS")?q_json.getString("I_NUMBER_OF_BARS"):null;
  313. I_CYCLE = q_json.has("I_CYCLE")?q_json.getString("I_CYCLE"):null;
  314. order = q_json.has("order")?q_json.getString("order"):null;
  315. dir = q_json.has("dir")?q_json.getString("dir"):null;
  316. Start = q_json.has("start")?q_json.getString("start"):(start!=null)?start:"0";
  317. Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
  318. Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
  319. //json.put("query", queryJson);
  320. }
  321. // System.out.println();
  322. if(sort!=null) {
  323. Sort = JSONArray.fromObject(sort);
  324. if((Sort.isArray())&&(Sort.size()>0)) {
  325. JSONObject s_json = Sort.getJSONObject(0);
  326. order = s_json.has("property")?s_json.getString("property"):order;
  327. dir = s_json.has("direction")?s_json.getString("direction"):dir;
  328. }
  329. json.put("sort", sort);
  330. }
  331. Start = start;
  332. Limit = limit;
  333. Page = page;
  334. if(UQ_COMPANY_ID!=null) {
  335. List list3 = ytiotVCompanyDao.query(" where u.id."+fieldname("owner_name")+" ='"+UQ_COMPANY_ID+"' ", null, null, null, null);
  336. if(list3.size()>0) {
  337. YtiotVCompany o3 = (YtiotVCompany)list3.get(0);
  338. YtiotVCompanyId oid1 = o3.getId();
  339. // System.out.println("测试2");
  340. List list6 = ytiotTcAlarmPackagesDao.query(" where u."+fieldname("UQ_COMPANY_ID")+" ='"+oid1.getOwnerId()+"' ", null, null, null, null);
  341. if(list6.size()>0) {
  342. if(list6.size()==1) {
  343. YtiotTcAlarmPackages o6 = (YtiotTcAlarmPackages)list6.get(0);
  344. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+" ='"+o6.getUqSetmrealId()+"'";
  345. }else {
  346. for(int i=0;i<list6.size();i++) {
  347. // System.out.println("测试3");
  348. YtiotTcAlarmPackages o6 = (YtiotTcAlarmPackages)list6.get(i);
  349. if(i==0)
  350. UQ_SETMREAL_ID_LIST2 = "'"+o6.getUqSetmrealId()+"'";
  351. else
  352. UQ_SETMREAL_ID_LIST2 += ",'"+o6.getUqSetmrealId()+"'";
  353. }
  354. // System.out.println("测试4");
  355. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+" in("+UQ_SETMREAL_ID_LIST2+")";
  356. // System.out.println("测试1");
  357. }
  358. }
  359. }
  360. }
  361. if(D_START_STORETIME!=null) {
  362. List list4 = ytiotTcAlarmPackagesDao.query(" where u."+fieldname("D_START_STORETIME")+" ='"+D_START_STORETIME+"' ", null, null, null, null);
  363. if(list4.size()>0) {
  364. if(list4.size()==1) {
  365. YtiotTcAlarmPackages o4 = (YtiotTcAlarmPackages)list4.get(0);
  366. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+"='"+o4.getUqSetmrealId()+"'";
  367. }else {
  368. for(int i=0;i<list4.size();i++) {
  369. YtiotTcAlarmPackages o4 = (YtiotTcAlarmPackages)list4.get(i);
  370. if(i==0)
  371. UQ_SETMREAL_ID_LIST = "'"+o4.getUqSetmrealId()+"'";
  372. else
  373. UQ_SETMREAL_ID_LIST += ",'"+o4.getUqSetmrealId()+"'";
  374. }
  375. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+" in("+UQ_SETMREAL_ID_LIST+")";
  376. }
  377. }
  378. }
  379. if(D_END_STORETIME!=null) {
  380. List list5 = ytiotTcAlarmPackagesDao.query(" where u."+fieldname("D_END_STORETIME")+" ='"+D_END_STORETIME+"' ", null, null, null, null);
  381. if(list5.size()>0) {
  382. if(list5.size()==1) {
  383. YtiotTcAlarmPackages o5 = (YtiotTcAlarmPackages)list5.get(0);
  384. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+"='"+o5.getUqSetmrealId()+"'";
  385. }else {
  386. for(int i=0;i<list5.size();i++) {
  387. YtiotTcAlarmPackages o5 = (YtiotTcAlarmPackages)list5.get(i);
  388. if(i==0)
  389. UQ_SETMREAL_ID_LIST1 = "'"+o5.getUqSetmrealId()+"'";
  390. else
  391. UQ_SETMREAL_ID_LIST1 += ",'"+o5.getUqSetmrealId()+"'";
  392. }
  393. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+" in("+UQ_SETMREAL_ID_LIST1+")";
  394. }
  395. }
  396. }
  397. if(V_PHONE!=null) {
  398. List list8 = ytiotTcAlarmPackagesDao.query(" where u."+fieldname("V_PHONE")+" ='"+V_PHONE+"' ", null, null, null, null);
  399. if(list8.size()>0) {
  400. if(list8.size()==1) {
  401. YtiotTcAlarmPackages o8 = (YtiotTcAlarmPackages)list8.get(0);
  402. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+"='"+o8.getUqSetmrealId()+"'";
  403. }else {
  404. for(int i=0;i<list8.size();i++) {
  405. YtiotTcAlarmPackages o8 = (YtiotTcAlarmPackages)list8.get(i);
  406. if(i==0)
  407. V_PHONE_LIST = "'"+o8.getUqSetmrealId()+"'";
  408. else
  409. V_PHONE_LIST += ",'"+o8.getUqSetmrealId()+"'";
  410. }
  411. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_SETMREAL_ID")+" in("+V_PHONE_LIST+")";
  412. }
  413. }
  414. }
  415. if(UQ_CATEGORY!=null)
  416. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_CATEGORY")+"='"+UQ_CATEGORY+"'";
  417. if(I_NUMBER_OF_BARS!=null)
  418. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("I_NUMBER_OF_BARS")+"='"+I_NUMBER_OF_BARS+"'";
  419. if(I_CYCLE!=null)
  420. hqlwhere = chkhw(hqlwhere) + "u."+fieldname("I_CYCLE")+"='"+I_CYCLE+"'";
  421. if(order!=null)
  422. order_str = " order by u."+fieldname(order);
  423. else
  424. order_str = " order by u."+fieldname("I_ORDER_IDX");
  425. // System.out.println(hqlwhere);
  426. int totalCount = ytiotTcAlarmPackagesZbDao.getCount(hqlwhere);
  427. //System.out.println(totalCount);
  428. json.put("totalCount", totalCount);
  429. if(Start!=null){
  430. if(Integer.parseInt(Start)>totalCount){
  431. Start = "0";
  432. Page = "0";
  433. }
  434. if(page==null)
  435. Page="0";
  436. }else{
  437. Start = "0";
  438. Page = "0";
  439. }
  440. json.put("page", Page);
  441. json.put("start", Start);
  442. json.put("limit", Limit);
  443. if(totalCount>0) {
  444. List list = ytiotTcAlarmPackagesZbDao.query(hqlwhere, order_str, dir, Start, Limit);
  445. if(list.size()>0) {
  446. for(int i=0;i<list.size();i++) {
  447. YtiotTcAlarmPackagesZb o = (YtiotTcAlarmPackagesZb)list.get(i);
  448. Map map = new HashMap();
  449. // int a=Integer.parseInt(o.getEStatus());
  450. if(o.getUqSetmrealId()!=null) {
  451. List list1 = ytiotTcAlarmPackagesDao.query(" where u."+fieldname("UQ_SETMREAL_ID")+" ='"+o.getUqSetmrealId()+"' ", null, null, null, null);
  452. if(list1.size()>0) {
  453. YtiotTcAlarmPackages o1 = (YtiotTcAlarmPackages)list1.get(0);
  454. map.put("UQ_COMPANY_ID", o1.getUqCompanyId());
  455. map.put("V_PHONE", o1.getVPhone());
  456. map.put("D_START_STORETIME", formatter.format(o1.getDStartStoretime()));
  457. map.put("D_END_STORETIME",formatter.format(o1.getDEndStoretime()));
  458. if(o1.getUqCompanyId()!=null){
  459. List list2 = ytiotVCompanyDao.query(" where u.id."+fieldname("owner_id")+" ='"+o1.getUqCompanyId()+"' ", null, null, null, null);
  460. if(list2.size()>0) {
  461. YtiotVCompany o2 = (YtiotVCompany)list2.get(0);
  462. YtiotVCompanyId oid = o2.getId();
  463. map.put("V_COMPANY_NAME", oid.getOwnerName());
  464. }
  465. }
  466. }
  467. }
  468. map.put("I_ORDER_IDX", o.getIOrderIdx());
  469. map.put("UQ_SETMREAL_ZB_ID", o.getUqSetmrealZbId());
  470. if(Integer.parseInt(o.getUqCategory())==1) {
  471. map.put("UQ_CATEGORY1", o.getUqCategory());
  472. map.put("UQ_CATEGORY", "火系统报警");
  473. }else if(Integer.parseInt(o.getUqCategory())==2) {
  474. map.put("UQ_CATEGORY1", o.getUqCategory());
  475. map.put("UQ_CATEGORY", "水系统报警");
  476. }else if(Integer.parseInt(o.getUqCategory())==3) {
  477. map.put("UQ_CATEGORY1", o.getUqCategory());
  478. map.put("UQ_CATEGORY", "烟感报警");
  479. }else if(Integer.parseInt(o.getUqCategory())==4) {
  480. map.put("UQ_CATEGORY1", o.getUqCategory());
  481. map.put("UQ_CATEGORY", "消防栓报警");
  482. }else if(Integer.parseInt(o.getUqCategory())==5) {
  483. map.put("UQ_CATEGORY1", o.getUqCategory());
  484. map.put("UQ_CATEGORY", "液位报警");
  485. }else if(Integer.parseInt(o.getUqCategory())==6) {
  486. map.put("UQ_CATEGORY1", o.getUqCategory());
  487. map.put("UQ_CATEGORY", "RTU报警");
  488. }else if(Integer.parseInt(o.getUqCategory())==7) {
  489. map.put("UQ_CATEGORY1", o.getUqCategory());
  490. map.put("UQ_CATEGORY", "电气火灾报警");
  491. }else if(Integer.parseInt(o.getUqCategory())==8) {
  492. map.put("UQ_CATEGORY", o.getUqCategory());
  493. map.put("UQ_CATEGORY", "离线报警");
  494. }
  495. if(Integer.parseInt(o.getICycle())==0) {
  496. map.put("I_CYCLE1", o.getICycle());
  497. map.put("I_CYCLE", "天");
  498. }else if(Integer.parseInt(o.getICycle())==1) {
  499. map.put("I_CYCLE1", o.getICycle());
  500. map.put("I_CYCLE", "月");
  501. }else if(Integer.parseInt(o.getICycle())==2) {
  502. map.put("I_CYCLE1", o.getICycle());
  503. map.put("I_CYCLE", "年");
  504. }
  505. int a=Integer.parseInt(o.getEStatus());
  506. if(a==0) {
  507. map.put("E_STATUS", "待开通");
  508. }
  509. if(a==1) {
  510. map.put("E_STATUS", "已开通");
  511. }
  512. if(a==2) {
  513. map.put("E_STATUS", "已锁定");
  514. }
  515. if(a==3) {
  516. map.put("E_STATUS", "注销");
  517. }
  518. // map.put("UQ_CATEGORY", o.getUqCategory());
  519. map.put("I_NUMBER_OF_BARS", o.getINumberOfBars());
  520. map.put("UQ_SETMREAL_ID", o.getUqSetmrealId());
  521. JSONObject jSONObject = JSONObject.fromObject(map);
  522. jSONArray.add(jSONObject);
  523. }
  524. json.put("RESULT", jSONArray);
  525. }
  526. }
  527. return json.toString();
  528. }
  529. // @Override
  530. // public String getCompanyVerList(String queryJson, String page, String start, String limit, String sort) throws Exception {
  531. // // TODO Auto-generated method stub
  532. // SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  533. // String UQ_COMPANY_ID = null;
  534. // String V_COMPANY_NAME = null;
  535. // String V_COMPANY_ADDRESS_0 = null;
  536. // String E_STATUS = null;
  537. //// String UQ_ADMIN_ID = null;
  538. // String D_STORETIME = null;
  539. //
  540. // String hqlwhere = null;
  541. // String order = null;
  542. // String dir = null;
  543. // String Start = null;
  544. // String Limit = null;
  545. // String Page = null;
  546. // String order_str = null;
  547. // JSONObject q_json = null;
  548. // JSONArray Sort = null;
  549. // JSONArray jSONArray = new JSONArray();
  550. // JSONObject json = new JSONObject();
  551. // json.put("action", "getCompanyVerList");
  552. // if(queryJson!=null) {
  553. // q_json = JSONObject.fromObject(queryJson);
  554. // UQ_COMPANY_ID = q_json.has("UQ_COMPANY_ID")?q_json.getString("UQ_COMPANY_ID"):null;
  555. // V_COMPANY_NAME = q_json.has("V_COMPANY_NAME")?q_json.getString("V_COMPANY_NAME"):null;
  556. //// UQ_ADMIN_ID = q_json.has("UQ_ADMIN_ID")?q_json.getString("UQ_ADMIN_ID"):null;
  557. // V_COMPANY_ADDRESS_0 = q_json.has("V_COMPANY_ADDRESS_0")?q_json.getString("V_COMPANY_ADDRESS_0"):null;
  558. // E_STATUS = q_json.has("E_STATUS")?q_json.getString("E_STATUS"):null;
  559. //// System.out.println("测试"+E_STATUS);
  560. //// int a=Integer.parseInt("E_STATUS");
  561. //// if(a ==10) {
  562. //// E_STATUS=null;
  563. //// }
  564. //// System.out.println("测试1"+E_STATUS);
  565. //
  566. // order = q_json.has("order")?q_json.getString("order"):null;
  567. // dir = q_json.has("dir")?q_json.getString("dir"):null;
  568. // Start = q_json.has("start")?q_json.getString("start"):(start!=null)?start:"0";
  569. // Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
  570. // Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
  571. // json.put("query", queryJson);
  572. // }
  573. //// System.out.println();
  574. // if(sort!=null) {
  575. // Sort = JSONArray.fromObject(sort);
  576. // if((Sort.isArray())&&(Sort.size()>0)) {
  577. // JSONObject s_json = Sort.getJSONObject(0);
  578. // order = s_json.has("property")?s_json.getString("property"):order;
  579. // dir = s_json.has("direction")?s_json.getString("direction"):dir;
  580. // }
  581. // json.put("sort", sort);
  582. // }
  583. //
  584. //
  585. // Start = start;
  586. // Limit = limit;
  587. // Page = page;
  588. //
  589. //
  590. // if(UQ_COMPANY_ID!=null)
  591. // hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_COMPANY_ID")+"='"+UQ_COMPANY_ID+"'";
  592. // if(V_COMPANY_NAME!=null)
  593. // hqlwhere = chkhw(hqlwhere) + "u."+fieldname("V_COMPANY_NAME")+" like '%"+V_COMPANY_NAME+"%'";
  594. //// if(UQ_ADMIN_ID!=null)
  595. //// hqlwhere = chkhw(hqlwhere) + "u."+fieldname("UQ_ADMIN_ID")+"='"+UQ_ADMIN_ID+"'";
  596. // if(V_COMPANY_ADDRESS_0!=null)
  597. // hqlwhere = chkhw(hqlwhere) + "u."+fieldname("V_COMPANY_ADDRESS_0")+" like '%"+V_COMPANY_ADDRESS_0+"%'";
  598. //// if(E_STATUS!=null)
  599. //// hqlwhere = chkhw(hqlwhere) + "u."+fieldname("E_STATUS")+"='"+E_STATUS+"'";
  600. // if(order!=null)
  601. // order_str = " order by u."+fieldname(order);
  602. // else
  603. // order_str = " order by u."+fieldname("I_COMPANYVER_ID");
  604. //
  605. // //System.out.println(hqlwhere);
  606. //// System.out.println(order_str);
  607. // int totalCount = ytiotTCompanyVerDao.getCount(hqlwhere);
  608. // json.put("totalCount", totalCount);
  609. // if(Start!=null){
  610. // if(Integer.parseInt(Start)>totalCount){
  611. // Start = "0";
  612. // Page = "0";
  613. // }else if(page==null)
  614. // Page="0";
  615. // }else{
  616. // Start = "0";
  617. // Page = "0";
  618. // }
  619. // json.put("page", Page);
  620. // json.put("start", Start);
  621. // json.put("limit", Limit);
  622. // if(totalCount>0) {
  623. // List list = ytiotTCompanyVerDao.query(hqlwhere, order_str, dir, Start, Limit);
  624. //// System.out.println(list);
  625. // if(list.size()>0) {
  626. // for(int i=0;i<list.size();i++) {
  627. // YtiotTCompanyVer o = (YtiotTCompanyVer)list.get(i);
  628. // Map map = new HashMap();
  629. // int a=Integer.parseInt(o.getEStatus());
  630. // if(a==0) {
  631. // map.put("E_STATUS", "待开通");
  632. // }
  633. // if(a==1) {
  634. // map.put("E_STATUS", "已开通");
  635. // }
  636. // if(a==2) {
  637. // map.put("E_STATUS", "已锁定");
  638. // }
  639. // if(a==3) {
  640. // map.put("E_STATUS", "注销");
  641. // }
  642. // map.put("I_VERSION", o.getIVersion());
  643. // map.put("V_COMPANY_NAME", o.getVCompanyName());
  644. //// map.put("E_STATUS", o.getEStatus());
  645. // map.put("V_COMMENT", o.getVComment());
  646. // map.put("D_STORETIME", formatter.format(o.getDStoretime()));
  647. // map.put("UQ_COMPANY_ID", o.getUqCompanyId());
  648. //// map.put("UQ_ADMIN_ID", o.getUqAdminId());
  649. // map.put("V_COMPANY_ADDRESS_0", o.getVCompanyAddress0());
  650. // JSONObject jSONObject = JSONObject.fromObject(map);
  651. // jSONArray.add(jSONObject);
  652. // }
  653. // json.put("RESULT", jSONArray);
  654. // }
  655. // }
  656. // return json.toString();
  657. //
  658. // }
  659. }