| | |
| | | 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;
|
| | |
| | | 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;
|
| | |
| | | */
|
| | | @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
|
| | |
| | | private OrganizationLayoutService orgLayoutService;
|
| | | @Resource
|
| | | private DeviceVersionService dviceVersionService;
|
| | | @Resource
|
| | | private OrganizationService organizationService;
|
| | | @Resource
|
| | | private DictionaryDataService dictionaryDataService;
|
| | | /**
|
| | | * Screen login. 大屏登录
|
| | | *
|
| | |
| | | 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;
|
| | | }
|
| | |
| | | @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) {
|
| | |
| | | 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 {
|
| | |
| | | })
|
| | | 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));
|