From e66b0932eb782c6ec771ffaa9957e6d5d5361286 Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Tue, 07 Aug 2018 12:49:06 +0800
Subject: [PATCH] 增加 年查询

---
 src/main/java/com/moral/controller/ScreenController.java |   69 +++++++++++++++++++++++-----------
 1 files changed, 47 insertions(+), 22 deletions(-)

diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java
index b3d6354..286fa38 100644
--- a/src/main/java/com/moral/controller/ScreenController.java
+++ b/src/main/java/com/moral/controller/ScreenController.java
@@ -9,8 +9,9 @@
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 
-import com.alibaba.fastjson.JSONReader;
-import com.alibaba.fastjson.TypeReference;
+import com.alibaba.fastjson.*;
+import com.moral.common.util.ParameterUtils;
+import com.moral.common.util.StringUtils;
 import com.moral.entity.*;
 import com.moral.entity.alarm.AlarmConfig;
 import com.moral.entity.alarm.AlarmConfigValue;
@@ -28,18 +29,9 @@
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.util.ObjectUtils;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-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.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 import org.springframework.web.servlet.ModelAndView;
 import org.xml.sax.InputSource;
-import com.alibaba.fastjson.JSONArray;
-import com.alibaba.fastjson.JSONObject;
 import com.moral.common.bean.Constants;
 import com.moral.common.bean.JsonData;
 import com.moral.common.bean.PageResult;
@@ -58,9 +50,9 @@
  */
 @RestController
 @RequestMapping("/screen")
-//@CrossOrigin(origins = "*", maxAge = 3600)
+@CrossOrigin(origins = "*", maxAge = 3600)
 @SuppressWarnings({ "rawtypes", "unchecked", "unused" })
-@Api(tags = "Screen", description = "������������") 
+@Api(tags = "Screen", description = "������������") 
 public class ScreenController {
 	public  static Logger log = Logger.getLogger(ScreenController.class);
     @Resource
@@ -110,6 +102,10 @@
 	private OrganizationLayoutService orgLayoutService;
 	@Resource
 	private  DeviceVersionService dviceVersionService;
+	@Resource
+    private  OrganizationService organizationService;
+	@Resource
+    private  DictionaryDataService dictionaryDataService;
 	/**
 	 * Screen login. ������������
 	 * 
@@ -126,6 +122,30 @@
 			resultMap.put("accountId", -1);
 		} else {
 			resultMap = accountService.screenLogin(parameters);
+			// ������������������������������������������
+			Object orgId = resultMap.get("orgId");
+			if(resultMap.get("orgId")!=null && resultMap.get("orgId") instanceof Integer) {
+                StringBuilder areaNamesBuilder = new StringBuilder("������");
+                if((Integer) orgId != dictionaryDataService.querySupperOrgId()) {
+                    Organization organization = organizationService.getOrganizationById((Integer) orgId);
+                    if(organization.getAreaNames()!=null){
+                        AreaNames areaNames =  organization.getAreaNames();
+                        if(!StringUtils.isNullOrEmpty(areaNames.getProvinceName())){
+                            areaNamesBuilder.append("/");
+                            areaNamesBuilder.append(areaNames.getProvinceName());
+                            if(!StringUtils.isNullOrEmpty(areaNames.getCityName())){
+                                areaNamesBuilder.append("/");
+                                areaNamesBuilder.append(areaNames.getCityName());
+                                if(!StringUtils.isNullOrEmpty(areaNames.getAreaName())){
+                                    areaNamesBuilder.append("/");
+                                    areaNamesBuilder.append(areaNames.getAreaName());
+                                }
+                            }
+                        }
+                    }
+                }
+                resultMap.put("mapPath",areaNamesBuilder.toString());
+            }
 		}
 		return resultMap;
 	}
@@ -509,12 +529,10 @@
 	@GetMapping("report_avg_datas")
 	public ResultBean<List<Map<String, Object>>> getMonitorPointOrDeviceAvgData(HttpServletRequest request) throws Exception {
 		Map<String, Object> parameters = getParametersStartingWith(request, null);
-		parameters.put("type", "month");
+		ParameterUtils.getTimeType4Time(parameters);
 		parameters.put("monitorPointId", parameters.remove("monitorPoint"));
-		String sensorKey = parameters.remove("sensorKey").toString();
-		List<String> sensorKeys = new ArrayList<String>();
-		sensorKeys.add(sensorKey);
-		parameters.put("sensors", sensorKeys);
+		Object sensorKey = parameters.remove("sensorKey");
+		parameters.put("sensors", Arrays.asList(sensorKey));
 		List<Map<String, Object>> list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters);
 		
 		for (Map<String, Object> map : list) {
@@ -594,12 +612,14 @@
 				 DeviceVersion deviceVersion = deviceVersionService.queryVersionById(device.getDeviceVersionId());
 			     rtdLayout = orgLayoutService.queryRtdLayoutWithUnit(orgId,deviceVersion.getVersion());
 			}else {
-				return  ResultBean.fail();
+				String errMsg = "device ���������������"+ JSON.toJSONString(device);
+				log.warn(errMsg);
+				return  ResultBean.fail(errMsg);
 			}
 
 		} else {
 			MonitorPoint monitorPoint = monitorPointService.queryMonitorPointById(Integer.parseInt(primaryKey));
-			List<DeviceVersion> versionList = deviceVersionService.queryByOrgId(monitorPoint.getOrganizationId());
+			List<DeviceVersion> versionList = deviceVersionService.queryByMpointId(monitorPoint.getId());
 			if(versionList.size() > 0) {
 			List<Integer> versionNolist =	versionList.stream().map(item -> {
 					return  item.getVersion();
@@ -626,7 +646,7 @@
 	})
 	public ResultBean<List<Map<String, Object>>> getMonitorPointOrDeviceAvgDataBySensorKey(HttpServletRequest request) throws Exception {
 		Map<String, Object> parameters = getParametersStartingWith(request, null);
-		parameters.put("type", "month");
+		ParameterUtils.getTimeType4Time(parameters);
 		parameters.put("monitorPointId", parameters.remove("monitorPoint"));
 		String[] sensorKeys = parameters.remove("sensorKey").toString().split(",");
 		parameters.put("sensors", Arrays.asList(sensorKeys));
@@ -636,6 +656,11 @@
 			String time = map.get("time").toString();
 			time = time.substring(time.length() - 2);
 			map.put("time", Integer.valueOf(time));
+			List<Number> values = new ArrayList<Number>();
+			for (String string : sensorKeys) {
+				values.add((Number) map.remove(string));
+			}
+			map.put("values", values);
 		}
 		return new ResultBean<List<Map<String, Object>>>(list);
 	}

--
Gitblit v1.8.0