分析算法

WebRoot/WEB-INF/spring-servlet.xml

@@ -1296,7 +1296,13 @@
 			<ref bean="daoQuery"/>
 		</property>
     </bean>
-	
+
+	<bean id="ytiotTEfAnalysisService" class="cn.com.usky.iot.EfAnalysis.service.YtiotTEfAnalysisServicesImpl">
+		<property name="ytiotTEfAnalysisDao">
+			<ref bean="ytiotTEfAnalysisDao"/>
+		</property>
+	</bean>
+
 	 <bean id="ytiotTAdminStateEntityDao" class="cn.com.usky.iot.userstatus.dao.YtiotTAdminStateEntityDaoImpl">
         <property name="hibernateTemplate">
 			<ref bean="hibernateTemplate"/>

src/cn/com/usky/iot/EfAnalysis/service/YtiotTEfAnalysisService.java

@@ -0,0 +1,6 @@
+package cn.com.usky.iot.EfAnalysis.service;
+
+public interface YtiotTEfAnalysisService {
+	public String getEfAnalysisList(String queryJson, String page, String start, String limit, String sort) throws Exception;
+	public String getWaterAnalysisList(String queryJson, String page, String start, String limit, String sort) throws Exception;
+}

src/cn/com/usky/iot/EfAnalysis/service/YtiotTEfAnalysisServicesImpl.java

@@ -0,0 +1,271 @@
+package cn.com.usky.iot.EfAnalysis.service;
+
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import cn.com.usky.iot.entity.YtiotTEfAnalysis;
+import cn.com.usky.iot.entity.YtiotTWaterAnalysis;
+import cn.com.usky.iot.EfAnalysis.dao.YtiotTEfAnalysisDao;
+import cn.com.usky.utils.DaoResult;
+import net.sf.json.JSONArray;
+import net.sf.json.JSONObject;
+
+public class YtiotTEfAnalysisServicesImpl implements YtiotTEfAnalysisService {
+	private YtiotTEfAnalysisDao ytiotTEfAnalysisDao;
+
+	public YtiotTEfAnalysisDao getYtiotTEfAnalysisDao() {
+		return ytiotTEfAnalysisDao;
+	}
+
+	public void setYtiotTEfAnalysisDao(YtiotTEfAnalysisDao ytiotTEfAnalysisDao) {
+		this.ytiotTEfAnalysisDao = ytiotTEfAnalysisDao;
+	}
+
+	public boolean chk_string_param(String param) {
+		if(param==null)
+			return true;
+		if(param.indexOf("=")>=0)
+			return false;
+		if(param.indexOf("\'")>=0)
+			return false;
+		if(param.indexOf("\"")>=0)
+			return false;
+		return true;
+	}
+	
+	public String chkhw(String hqlwhere){
+		if(hqlwhere==null)
+			return " where ";
+		else
+			return hqlwhere+" and ";
+	}
+	public String fieldname(String field){
+		if(field.equals("company_code"))
+			return "companyCode";
+		if(field.equals("generation_time"))
+			return "generationTime";
+		if(field.equals("I_ORDER_IDX"))
+			return "IOrderIdx";
+		if(field.equals("UQ_PARENT_ID"))
+			return "uqParentId";
+		if(field.equals("UQ_PARENT_COMPANY_ID"))
+			return "uqParentCompanyId";
+		if(field.equals("V_COMPANY_NAME"))
+			return "VCompanyName";
+		if(field.equals("V_COMPANY_ADDRESS_0"))
+			return "VCompanyAddress0";
+		if(field.equals("V_COMPANY_ADDRESS_1"))
+			return "VCompanyAddress1";
+		if(field.equals("V_COMPANY_ADDRESS_2"))
+			return "VCompanyAddress2";
+		if(field.equals("E_STATUS"))
+			return "EStatus";
+		if(field.equals("UQ_ADMIN_ID"))
+			return "uqAdminId";
+		if(field.equals("I_VERSION"))
+			return "IVersion";
+		if(field.equals("D_STORETIME"))
+			return "DStoretime";
+		if(field.equals("V_COMMENT"))
+			return "VComment";
+		return null;
+	}
+
+	@Override
+	public String getEfAnalysisList(String queryJson, String page, String start, String limit, String sort) throws Exception {
+		// TODO Auto-generated method stub
+		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");	
+		String generation_time = null;
+		
+		String V_COMPANY_NAME=null;//单位名称
+		String V_COMPANY_ADDRESS_0=null;//单位地址_1
+		String I_VERSION=null;//当前记录版本
+		String D_STORETIME=null;//记录存储时间
+		String UQ_ADMIN_ID=null;//信息录入人ID\
+		String E_STATUS=null;//当前状态，0为待开通服务，1为已开通服务，2为服务锁定，3为已注销，4、5留用
+		String V_COMMENT  = null;//注册/修改说明
+		String company_code  = null;//单位编号
+		String Page = null;
+		String Start = null;
+		JSONArray Sort = null;
+		String Limit = null;
+		
+		String hqlwhere = null;
+		String order = null;
+		String dir = null;		
+		String order_str = null;
+		JSONObject q_json = null;		
+		JSONArray jSONArray = new JSONArray();
+		JSONObject json = new JSONObject();
+		json.put("action", "getEfAnalysisList");
+		if(queryJson!=null) {
+			q_json = JSONObject.fromObject(queryJson);
+			company_code= q_json.has("company_code")?q_json.getString("company_code"):null;
+			generation_time = q_json.has("generation_time")?q_json.getString("generation_time"):null;
+			
+			order = q_json.has("order")?q_json.getString("order"):null;
+			dir = q_json.has("dir")?q_json.getString("dir"):null;
+			Start = q_json.has("start")?q_json.getString("start"):(start!=null)?start:"0";
+			Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
+			Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
+		}
+//		System.out.println();
+		if(sort!=null) {
+			Sort = JSONArray.fromObject(sort);
+			if((Sort.isArray())&&(Sort.size()>0)) {
+				JSONObject s_json = Sort.getJSONObject(0);
+				order = s_json.has("property")?s_json.getString("property"):order;
+				dir = s_json.has("direction")?s_json.getString("direction"):dir;
+			}
+			json.put("sort", sort);
+		}
+		Start = start;
+		Limit = limit;
+		Page = page;
+		if(company_code!=null)
+			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+"='"+company_code+"'";
+		if(generation_time!=null)
+			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("generation_time")+"='"+generation_time+"'";
+		
+		int totalCount = ytiotTEfAnalysisDao.getCount(hqlwhere);
+		//System.out.println(totalCount);
+		json.put("totalCount", totalCount);
+		if(Start!=null){
+			if(Integer.parseInt(Start)>totalCount){
+				Start = "0";
+				Page = "0";
+			}
+			if(page==null)
+				Page="0";
+		}else{
+			Start = "0";
+			Page = "0";
+		}
+		json.put("page", Page);
+		json.put("start", Start);
+		json.put("limit", Limit);
+		if(totalCount>0) {
+			List list = ytiotTEfAnalysisDao.query(hqlwhere, order_str, dir, Start, Limit);
+			if(list.size()>0) {
+				for(int i=0;i<list.size();i++) {
+					YtiotTEfAnalysis o = (YtiotTEfAnalysis)list.get(i);
+					Map map = new HashMap();
+					map.put("data_statistics", o.getDataStatistics());
+					map.put("dispersion_rate", o.getDispersionRate());
+					map.put("electrical_aging", o.getElectricalAging());
+					map.put("equipment_list", o.getEquipmentList());
+					map.put("project_situation", o.getProjectSituation());
+					map.put("statistical_period", o.getStatisticalPeriod());
+					map.put("thermal_aging", o.getThermalAging());
+					map.put("creat_time", formatter.format(o.getCreatTime()));
+					map.put("generation_time", o.getGenerationTime());
+					JSONObject jSONObject = JSONObject.fromObject(map);
+					jSONArray.add(jSONObject);
+				}
+				json.put("RESULT", jSONArray);
+			}
+		}
+		return json.toString();
+	}
+	
+	@Override
+	public String getWaterAnalysisList(String queryJson, String page, String start, String limit, String sort) throws Exception {
+		// TODO Auto-generated method stub
+		SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");	
+		String company_code = null;
+		
+		String generation_time=null;//单位名称
+		String V_COMPANY_ADDRESS_0=null;//单位地址_1
+		String I_VERSION=null;//当前记录版本
+		String D_STORETIME=null;//记录存储时间
+		String UQ_ADMIN_ID=null;//信息录入人ID\
+		String E_STATUS=null;//当前状态，0为待开通服务，1为已开通服务，2为服务锁定，3为已注销，4、5留用
+		String V_COMMENT  = null;//注册/修改说明
+		String I_ORDER_IDX  = null;//序号
+		String Page = null;
+		String Start = null;
+		JSONArray Sort = null;
+		String Limit = null;
+		
+		String hqlwhere = null;
+		String order = null;
+		String dir = null;		
+		String order_str = null;
+		JSONObject q_json = null;		
+		JSONArray jSONArray = new JSONArray();
+		JSONObject json = new JSONObject();
+		json.put("action", "getCompanyList");
+		if(queryJson!=null) {
+			q_json = JSONObject.fromObject(queryJson);
+			company_code= q_json.has("company_code")?q_json.getString("company_code"):null;
+			generation_time = q_json.has("generation_time")?q_json.getString("generation_time"):null;
+			
+			order = q_json.has("order")?q_json.getString("order"):null;
+			dir = q_json.has("dir")?q_json.getString("dir"):null;
+			Start = q_json.has("start")?q_json.getString("start"):(start!=null)?start:"0";
+			Limit = q_json.has("limit")?q_json.getString("limit"):(limit!=null)?limit:null;
+			Page = q_json.has("page")?q_json.getString("page"):(page!=null)?page:"0";
+			json.put("query", queryJson);
+		}
+//		System.out.println();
+		if(sort!=null) {
+			Sort = JSONArray.fromObject(sort);
+			if((Sort.isArray())&&(Sort.size()>0)) {
+				JSONObject s_json = Sort.getJSONObject(0);
+				order = s_json.has("property")?s_json.getString("property"):order;
+				dir = s_json.has("direction")?s_json.getString("direction"):dir;
+			}
+			json.put("sort", sort);
+		}
+		Start = start;
+		Limit = limit;
+		Page = page;
+		if(company_code!=null)
+			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("company_code")+"='"+company_code+"'";
+		if(generation_time!=null)
+			hqlwhere = chkhw(hqlwhere) + "u."+fieldname("generation_time")+"='"+generation_time+"'";
+		int totalCount = ytiotTEfAnalysisDao.getWaterCount(hqlwhere);
+		//System.out.println(totalCount);
+		json.put("totalCount", totalCount);
+		if(Start!=null){
+			if(Integer.parseInt(Start)>totalCount){
+				Start = "0";
+				Page = "0";
+			}
+			if(page==null)
+				Page="0";
+		}else{
+			Start = "0";
+			Page = "0";
+		}
+		json.put("page", Page);
+		json.put("start", Start);
+		json.put("limit", Limit);
+		if(totalCount>0) {
+			List list = ytiotTEfAnalysisDao.queryWater(hqlwhere, order_str, dir, Start, Limit);
+			if(list.size()>0) {
+				for(int i=0;i<list.size();i++) {
+					YtiotTWaterAnalysis o = (YtiotTWaterAnalysis)list.get(i);
+					Map map = new HashMap();
+					map.put("data_statistics", o.getDataStatistics());
+					map.put("dispersion_rate", o.getDispersionRate());
+					map.put("leakage_investigation", o.getLeakageInvestigation());
+					map.put("equipment_list", o.getEquipmentList());
+					map.put("project_situation", o.getProjectSituation());
+					map.put("statistical_period", o.getStatisticalPeriod());
+					map.put("device_association", o.getDeviceAssociation());
+					map.put("data_fluctuation", o.getDataFluctuation());
+					map.put("creat_time", formatter.format(o.getCreatTime()));
+					map.put("generation_time", o.getGenerationTime());
+					JSONObject jSONObject = JSONObject.fromObject(map);
+					jSONArray.add(jSONObject);
+				}
+				json.put("RESULT", jSONArray);
+			}
+		}
+		return json.toString();
+	}
+}

src/cn/com/usky/iot/controller/AnalysisViewController.java

@@ -0,0 +1,80 @@
+package cn.com.usky.iot.controller;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.servlet.ModelAndView;
+
+import cn.com.usky.iot.EfAnalysis.service.YtiotTEfAnalysisService;
+
+@Controller
+@RequestMapping("/iot/analysis/view")
+public class AnalysisViewController {
+	
+	@Resource
+	private YtiotTEfAnalysisService ytiotTEfAnalysisService;
+	private static AnalysisViewController analysisViewController;
+	
+	@PostConstruct
+	 public void init() {
+		analysisViewController = this;
+		analysisViewController.ytiotTEfAnalysisService = this.ytiotTEfAnalysisService;
+	}
+	
+	@RequestMapping(value="/getEfAnalysisList",method= {RequestMethod.GET,RequestMethod.POST})
+	public static ModelAndView  getEfAnalysisList(@RequestParam(value = "queryJson", required = false) String queryJson,
+			@RequestParam(value = "page", required = false) String page,
+			@RequestParam(value = "start", required = false) String start,
+			@RequestParam(value = "limit", required = false) String limit,
+			@RequestParam(value = "sort", required = false) String sort) {
+		// TODO Auto-generated constructor stub
+		ModelAndView mav = new ModelAndView();
+		mav.setViewName("return");
+//		System.out.println(queryJson);
+		try {
+//			System.out.println(queryJson);
+			if(analysisViewController.ytiotTEfAnalysisService==null)
+			{
+				System.out.println("Service is NULL");
+			}
+			String ret = analysisViewController.ytiotTEfAnalysisService.getEfAnalysisList(queryJson,page,start,limit,sort);
+//			System.out.println(ret);
+			mav.addObject("ret_str", ret);
+			
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return mav;
+	}
+	@RequestMapping(value="/getWaterAnalysisList",method= {RequestMethod.GET,RequestMethod.POST})
+	public static ModelAndView  getWaterAnalysisList(@RequestParam(value = "queryJson", required = false) String queryJson,
+			@RequestParam(value = "page", required = false) String page,
+			@RequestParam(value = "start", required = false) String start,
+			@RequestParam(value = "limit", required = false) String limit,
+			@RequestParam(value = "sort", required = false) String sort) {
+		// TODO Auto-generated constructor stub
+		ModelAndView mav = new ModelAndView();
+		mav.setViewName("return");
+//		System.out.println(queryJson);
+		try {
+//			System.out.println(queryJson);
+			if(analysisViewController.ytiotTEfAnalysisService==null)
+			{
+				System.out.println("Service is NULL");
+			}
+			String ret = analysisViewController.ytiotTEfAnalysisService.getWaterAnalysisList(queryJson,page,start,limit,sort);
+//			System.out.println(ret);
+			mav.addObject("ret_str", ret);
+			
+		} catch (Exception e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		return mav;
+	}
+}