efunbox_audio/src/main/java/cn/efunbox/audio/controller/DeviceController.java

package cn.efunbox.audio.controller;

//import cn.efunbox.audio.clients.UserFeign;
import cn.efunbox.audio.clients.UserHttp;
import cn.efunbox.audio.entity.Channel;
import cn.efunbox.audio.entity.Device;
import cn.efunbox.audio.entity.Grouping;
import cn.efunbox.audio.service.ChannelService;
import cn.efunbox.audio.service.DeviceService;
import cn.efunbox.audio.utils.ApiCode;
import cn.efunbox.audio.utils.ApiResult;
import cn.efunbox.audio.utils.Common;
import cn.efunbox.audio.utils.HttpUtil;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.*;

/**
 * Created by yao on 17-9-26.
 */
@RestController
@Slf4j
@RequestMapping(value = "/device")
public class DeviceController {

    @Autowired
    DeviceService deviceService;

    @Autowired
    ChannelService channelService;

//    @Autowired
//    UserFeign userFeign;
    @Autowired
    UserHttp userHttp;

    @Value("${iaas.user.register}")
    private  String urlRegister;
    @Value("${iaas.user.audio.bizCode}")
    private String bizCode;
    @Value("${iaas.user.audio.appCode}")
    private String appCode;
    @Value("${iaas.user.audio.platform}")
    private String platform;
    @Value("${iaas.user.audio.os}")
    private String os;
    @Value("${iaas.user.audio.appVer}")
    private String appVer;
    @Value("${iaas.user.audio.terminal}")
    private String terminal;
    @Value("${iaas.user.audio.entryType}")
    private String entryType;

    @RequestMapping(value = "/feign")
    public void Feigh(HttpServletRequest request, HttpServletResponse response,
            @RequestParam("idChannel")String idChannel, @RequestParam("mobile")String mobile){
        String ip = HttpUtil.getIpAddress(request);
        System.out.println("start:"+ip);
        String res = userHttp.Register(UUID.randomUUID().toString().substring(0, 31),
                idChannel, ip, mobile, mobile);
//        String res = userFeign.Register(
////                "application/json",
//                bizCode,
////                UUID.randomUUID().toString().substring(0, 31),
//                "8723-4327-64238-asdkja",
//                appCode,
//                platform,
//                os,
//                "1111",
//                "123.126.111.3",
//                appVer,
//                terminal,
//                mobile,
//                entryType,
//                "123456",
//                "",
//                ""
//        );
//        System.out.println(res);
//        Map map = JSONObject.parseObject(res);
//        HttpUtil.responseOkData(request, response, map);
//        System.out.println("res:"+res);
//        String res = userFeign.getUser("c26ceb09-4e85-40ba-a81d-1535d142cc43");
//        System.out.println(res);
    }

    @RequestMapping(value = "/token" ,method = RequestMethod.POST)
    public Map Login(@RequestParam long id, @RequestParam String token){
        Map map = new HashMap<>();
        Device device = deviceService.Login(id, token);
        if(device==null){
            map.put("code", ApiCode.INVALID_TOKEN.getCode());
            map.put("msg", ApiCode.INVALID_TOKEN.getMessage());
            return map;
        }

        map.put("code", ApiCode.OK.getCode());
        Map data = new HashMap<>();
        data.put("id", device.getId());
        data.put("token", device.getTokenNew());
        map.put("data", data);

        return map;
    }

    @RequestMapping(value = "/register" ,method = RequestMethod.POST)
    public Map Register(HttpServletRequest request){
        Map map = new HashMap<>();
        String idChannel = request.getParameter("idChannel");
        String idDevice = request.getParameter("idDevice");
        if(idChannel==null || idDevice==null){
            map.put("code", ApiCode.PARAMETER_ERROR.getCode());
            map.put("msg", ApiCode.PARAMETER_ERROR.getMessage());
            return map;
        }
        if(deviceService.CheckRegister(Long.valueOf(idChannel), Long.valueOf(idDevice))) {
            map.put("code", ApiCode.RECORD_EXIST.getCode());
            map.put("msg", ApiCode.RECORD_EXIST.getMessage());
            return map;
        }
        List<Channel> channelList = channelService.SearchById(Long.valueOf(idChannel));
        if(channelList==null || channelList.size()<1){
            map.put("code", ApiCode.PARAMETER_ERROR.getCode());
            map.put("msg", ApiCode.PARAMETER_ERROR.getMessage());
            return map;
        }
        Device device = deviceService.Register(Long.valueOf(idChannel), Long.valueOf(idDevice));
        if(device!=null){
            map.put("code", ApiCode.OK.getCode());
            Map data = new HashMap<>();
            data.put("id", device.getId());
            data.put("token", device.getTokenNew());
            map.put("data", data);
        }

        return map;
    }

//    @RequestMapping(value = "/register" ,method = RequestMethod.POST)
//    public Map Register(HttpServletRequest request, @RequestBody Device device){
//        Map map = new HashMap<>();
//        if(device.getIdChannel()==null || device.getIdDevice()==null){
//            map.put("code", ApiCode.PARAMETER_ERROR.getCode());
//            map.put("msg", ApiCode.PARAMETER_ERROR.getMessage());
//            return map;
//        }
//        if(deviceService.CheckRegister(device.getIdChannel(), device.getIdDevice())){
//            map.put("code", ApiCode.RECORD_EXIST.getCode());
//            map.put("msg", ApiCode.RECORD_EXIST.getMessage());
//            return map;
//        }
//        List<Channel> channelList = channelService.SearchById(device.getIdChannel());
//        if(channelList==null || channelList.size()<1){
//            map.put("code", ApiCode.PARAMETER_ERROR.getCode());
//            map.put("msg", ApiCode.PARAMETER_ERROR.getMessage());
//            return map;
//        }
//        device = deviceService.Register(device.getIdChannel(), device.getIdDevice());
//        if(device!=null){
//            map.put("code", ApiCode.OK.getCode());
//            Map data = new HashMap<>();
//            data.put("id", device.getId());
//            data.put("token", device.getTokenNew());
//            map.put("data", data);
//        }
//
//        return map;
//    }


    /**
     * 搜索已注册的设备
     * @param request
     * @param response
     */
    @RequestMapping(value = "/search" ,method = RequestMethod.POST)
    public void Search(HttpServletRequest request, HttpServletResponse response){
        String idDevice = request.getParameter("idDevice");
        String idChannel = request.getParameter("idChannel");
        List<Device> list = new ArrayList<>();
        if((idDevice==null || idDevice.length()==0) && (idChannel==null || idChannel.length()==0))
            list = deviceService.SearchAll();
        else{
            if(idDevice==null || idDevice.length()==0)
                idDevice = "0";
            if(idChannel==null || idChannel.length()==0)
                idChannel = "0";
            list = deviceService.Search(Long.valueOf(idChannel), Long.valueOf(idDevice));
        }

        for(int i=0; i<list.size(); i++){
            list.get(i).setTokenNew("");
            list.get(i).setTokenOld("");
        }

        HttpUtil.responseOkData(request, response, list);
        return;
    }

//    @RequestMapping(value = "/update", method = RequestMethod.POST)
//    public void Update(HttpServletRequest request, HttpServletResponse response, @RequestBody Device device){
//        Device deviceOld = deviceService.GetOne(device.getId());
//        if(deviceOld==null){
//            HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
//            return;
//        }
//        device = (Device)Common.CopyValue(device, deviceOld);
//        device = deviceService.Update(device);
//        HttpUtil.responseOutWithJson(request, response, device);
//        return;
//    }
//
//    @RequestMapping(value = "/delete", method = RequestMethod.POST)
//    public void Delete(HttpServletRequest request, HttpServletResponse response){
//        String idDevice = request.getParameter("idDevice");
//        deviceService.Delete(Long.valueOf(idDevice));
//        HttpUtil.responseOk(request, response);
//        return;
//    }

}