YtIoT/src/cn/com/usky/iot/controller/DataViewController.java

package cn.com.usky.iot.controller;

import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

import cn.com.usky.iot.auth.TokenAuthBO;
import cn.com.usky.iot.auth.TokenAuthService;
import cn.com.usky.iot.controller.login.Constants;
import cn.com.usky.iot.entity.YtiotTAdmin;
import cn.com.usky.utils.HttpServletRequestUtils;
import org.springframework.beans.factory.annotation.Autowired;
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.data.service.YtiotVDataService;

@Controller
@RequestMapping("/iot/data/view")
public class DataViewController {

    @Resource
    private YtiotVDataService ytiotVDataService;
    private static DataViewController dataViewController;

    @PostConstruct
    public void init() {
        dataViewController = this;
        dataViewController.ytiotVDataService = this.ytiotVDataService;
    }

    @Autowired
    private TokenAuthService tokenAuthService;

    @RequestMapping(value = "/getSyncPointVList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncPointVList(@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,
                                                 HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncPointVList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncDataVList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncDataVList(@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,
                                                HttpServletRequest request) {

        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncDataVList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncDataQList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncDataQList(@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,
                                                HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncDataQList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncwaterDataVList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncwaterDataVList(@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,
                                                     HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncwaterDataVList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncDataRList", method = {RequestMethod.GET, RequestMethod.POST})
    public ModelAndView getSyncDataRList(@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,
                                                HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncDataRList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncrtuDataVList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncrtuDataVList(@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,
                                                   HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncrtuDataVList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncDataFList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncDataFList(@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,
                                                HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncDataFList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncfireDataVList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncfireDataVList(@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,
                                                    HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncfireDataVList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncDataVListByCompany", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncDataVListByCompany(@RequestParam(value = "queryJson", required = false) String queryJson,
                                                         HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncDataVListByCompany(jsonObject.toString());
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

//	@RequestMapping(value="/getSyncDataFexcelList",method= {RequestMethod.GET,RequestMethod.POST})
//	public static ModelAndView  getSyncDataFexcelList(@RequestParam(value = "queryJson", required = false) String queryJson) {
//		ModelAndView mav = new ModelAndView();
//		mav.setViewName("return");
//		try {
//			String ret = dataViewController.ytiotVDataService.getSyncDataFexcelList(queryJson);
//			mav.addObject("ret_str", ret);
//		} catch (Exception e) {
//			// TODO Auto-generated catch block
//			e.printStackTrace();
//		}
//		return mav;
//	}

    @RequestMapping(value = "/getSyncDataByDays", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getConfirmStatusByDays(@RequestParam(value = "queryJson", required = false) String queryJson,
                                                      HttpServletRequest request) {
        // TODO Auto-generated constructor stub
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncDataByDays(jsonObject.toString());
//			System.out.println(ret);
            mav.addObject("ret_str", ret);

        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncStatusVList", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncStatusVList(@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,
                                                  HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncStatusVList(jsonObject.toString(), page, start, limit, sort);
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }

    @RequestMapping(value = "/getSyncStatusVListByCompany", method = {RequestMethod.GET, RequestMethod.POST})
    public  ModelAndView getSyncStatusVListByCompany(@RequestParam(value = "queryJson", required = false) String queryJson,
                                                           HttpServletRequest request) {
        ModelAndView mav = new ModelAndView();
        TokenAuthBO tokenAuthBO = HttpServletRequestUtils.tokenAuthForYT(request, tokenAuthService);
        boolean isAuth = tokenAuthBO.isAuthState();
        if (!isAuth) {
            com.alibaba.fastjson.JSONObject json = new com.alibaba.fastjson.JSONObject();
            json.put("check", false);
            json.put("errMsg", "权限错误，请重新登录");
            mav.addObject("ret_str", json.toJSONString());
        }
        mav.setViewName("return");
        //通过获取用户信息
        YtiotTAdmin o = (YtiotTAdmin) tokenAuthBO.getData().get(Constants.USER_INFO);
        com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(queryJson);
        jsonObject.put("V_LOGINNAME", o.getVLoginname());
        jsonObject.put("V_PASSWORD", o.getVPassword());
        try {
            String ret = dataViewController.ytiotVDataService.getSyncStatusVListByCompany(jsonObject.toString());
            mav.addObject("ret_str", ret);
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return mav;
    }
}