fengxiang
2018-02-06 7014fd76c199e676159ac30da6f4dbb91e3a137e
src/main/java/com/moral/controller/ScreenController.java
@@ -6,21 +6,22 @@
import static com.moral.common.util.WebUtils.getParametersStartingWith;
import java.io.*;
import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.*;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.*;
import com.moral.common.bean.JsonData;
import com.moral.common.bean.PageResult;
import com.moral.common.xml.Version;
import com.moral.entity.Account;
import com.moral.entity.Device;
import com.moral.entity.MapBounds;
import com.moral.entity.MonitorPoint;
import com.moral.service.*;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang.ArrayUtils;
import org.apache.commons.net.ftp.FTPClient;
import org.apache.log4j.Logger;
import org.dom4j.Document;
@@ -32,11 +33,9 @@
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.*;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONReader;
import com.alibaba.fastjson.TypeReference;
import com.moral.common.bean.ResultBean;
import com.moral.common.util.ValidateUtil;
import org.springframework.web.servlet.ModelAndView;
import org.xml.sax.InputSource;
/**
@@ -151,7 +150,7 @@
   /**
    * Gets the standard by sensor.获取某传感器标准值
    *
    * @param request
    * @param macKey
    *            the request
    * @return the standard by sensor
    */
@@ -276,9 +275,19 @@
      }
      return version;
   }
   /**
    * 地图接口
    * 开始
    */
   /**
    * 地图主页
    * @param model
    * @param code
    * @param accountId
    * @return
    */
   @RequestMapping(value = "/map-page", method = RequestMethod.GET)
   public String map(Model model, @RequestParam("areaCode")int code, @RequestParam("accountId")int accountId){
   public ModelAndView map(ModelAndView model, @RequestParam("areaCode")int code, @RequestParam("accountId")int accountId){
      Account account = accountService.getAccountById(accountId);
      String regionName = areaService.selectFullNameByCode(code);
      if(account!=null&&regionName!=null){
@@ -290,8 +299,9 @@
         params.put("orgId", account.getOrganizationId());
         params.put("sensors", sensors);
         String paramsJson = params.toJSONString();
         model.addAttribute("mapParams",paramsJson);
         return "map";
         model.addObject("mapParams",paramsJson);
         model.setViewName("map");
         return model;
      } else {
         StringBuilder msg = new StringBuilder();
         msg.append(" param[0] areaCode:");
@@ -299,7 +309,8 @@
         msg.append(" param[0] accountId:");
         msg.append(accountId);
         log.warn(msg);
         return "401";
         model.setViewName("401");
         return model;
      }
   }
   @RequestMapping(value="/get-monitorpoints",method = RequestMethod.GET)
@@ -314,6 +325,18 @@
      resultBean.setCode(ResultBean.SUCCESS);
      return resultBean;
   }
   @RequestMapping(value="/get-devices",method = RequestMethod.GET)
   @ResponseBody
   public ResultBean getDevices(@RequestParam("orgId")Integer orgId,MapBounds mapBounds){
      ResultBean<List<Device>> resultBean = new ResultBean();
      Map<String,Object> paramMap = new HashMap<String, Object>();
      paramMap.put("orgId", orgId);
      paramMap.put("mapBounds",mapBounds);
      List<Device> list = deviceService.query(paramMap);
      resultBean.setData(list);
      resultBean.setCode(ResultBean.SUCCESS);
      return resultBean;
   }
   @RequestMapping(value = "get-devices-for-popup",method = RequestMethod.GET)
   @ResponseBody
   public PageResult getDevicesForPopup(
@@ -324,4 +347,47 @@
   ){
      return  deviceService.query(orgId,name,pageSize,pageNo);
   }
   @RequestMapping(value = "get-devices-by-mid-oid",method = RequestMethod.GET)
   @ResponseBody
   public PageResult getDevicesByMidOid(
         @RequestParam("orgId")Integer orgId,
         @RequestParam("mpId")Integer mpId,
         Integer pageSize,
         Integer pageNo
   ){
      return deviceService.query(orgId,mpId,pageSize,pageNo);
   }
   @RequestMapping(value="/get-real-state-data",method = RequestMethod.POST)
   @ResponseBody
   public JsonData getRealStateAndData(@RequestBody JSONObject paramMap){
      JsonData jsonData = new JsonData();
      Map<String,Object> returnMap = new HashMap<String, Object>();
      returnMap.put("layer", paramMap.getString("layer"));
      //覆盖控件的数据刷新
      if(!CollectionUtils.isEmpty(paramMap.getJSONArray("markerKeys"))) {
         JSONArray markerKeys = paramMap.getJSONArray("markerKeys");
         List<Map<String, String>> markers = null;
         if("equipments".equals(paramMap.getString("layer"))) {
            markers = deviceService.queryDevicesState(markerKeys.toJavaList(String.class),true);
         }else {//返回监控点id和state
            String orgId= paramMap.getString("orgId");
            String areaCode= paramMap.getString("areaCode");
            for(Object mPointId:markerKeys) {
               markers = monitorPointService.queryMonitroPointsState(markerKeys.toJavaList(Integer.class));
            }
         }
         returnMap.put("markers", markers);
      }
      if(paramMap.getJSONArray("popupEquMacs")!=null&&paramMap.getJSONArray("popupEquMacs").size()>0) {
         JSONArray popupEquMacs = paramMap.getJSONArray("popupEquMacs");
         List<Map<String, String>> popupEquWithStates = null;
         for(Object mac:popupEquMacs) {
            popupEquWithStates = deviceService.queryDevicesState(popupEquMacs.toJavaList(String.class),false);
         }
         //返回搜索结果的状态
         returnMap.put("popupEquStates", popupEquWithStates);
      }
      jsonData.setExtData(returnMap);
      return jsonData;
   }
}