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

package cn.efunbox.audio.controller;

import cn.efunbox.audio.clients.AudioHttp;
import cn.efunbox.audio.consts.Status;
import cn.efunbox.audio.entity.*;
import cn.efunbox.audio.service.*;
import cn.efunbox.audio.utils.ApiCode;
import cn.efunbox.audio.utils.HttpUtil;
import cn.efunbox.audio.utils.Common;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
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.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
import java.sql.Timestamp;
import java.util.*;
import java.util.List;

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

    @Autowired
    AudioService audioService;
    @Autowired
    DeviceService deviceService;
    @Autowired
    RecordService recordService;
    @Autowired
    GroupingService groupingService;
    @Autowired
    RightsService rightsService;
    @Autowired
    AudioHttp audioHttp;

    /**
     * 管理员搜索接口
     * @param request
     * @param response
     */
    @RequestMapping(value = "/admsearch", method = RequestMethod.POST)
    public void AdminSearch(HttpServletRequest request, HttpServletResponse response){
        String name = request.getParameter("name");
        String album = request.getParameter("album");
        String idGroup = request.getParameter("idGroup");
        String page = request.getParameter("page");
        String size = request.getParameter("size");
        if(page==null || page.length()<1)
            page = "0";
        if(size==null || size.length()<1)
            size = "0";
        List<Audio> list = new ArrayList<>();
        if(idGroup!=null && idGroup.length()>0)
            list = audioService.SearchByIdGroup(Long.valueOf(idGroup), Integer.valueOf(page), Integer.valueOf(size));
        else if(name!=null && name.length()>0  && album!=null && album.length()>0)
            list = audioService.SearchByNameAlbum(name, album);
        else if(name!=null && name.length()>0)
            list = audioService.SearchByName(name);
        else if(album!=null && album.length()>0)
            list = audioService.SearchByAlbum(album);
        else
            list = audioService.SearchAll(Integer.valueOf(page), Integer.valueOf(size));

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

    /**
     * 用户搜索接口
     * @param request
     * @param response
     */
    @RequestMapping(value = "/search", method = RequestMethod.POST)
    public void Search(HttpServletRequest request, HttpServletResponse response){
        String id = request.getParameter("id");
        String name = request.getParameter("name");
        String album = request.getParameter("album");
        if(name==null && album==null){
            HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
            return;
        }
        if(id==null || id.length()==0)
            id = request.getHeader("id");
        List<Audio> list = null;
//        System.out.println("album:"+album+",name:"+name);
        if(name!=null && name.length()>0  && album!=null && album.length()>0)
            list = audioService.SearchByNameAlbum(name, album);
        else if(name!=null && name.length()>0)
            list = audioService.SearchByName(name);
        else
            list = audioService.SearchByAlbum(album);

        if(list==null || list.size()<1){
            HttpUtil.responseApiCode(request, response, ApiCode.NOT_FOUND);
            return;
        }
        Device device = deviceService.GetOne(Long.valueOf(id));
        if(device==null){
            HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
            return;
        }
        //搜素设备所属渠道具有哪些资源组的权限
        Long idChannel = device.getIdChannel();
        List<Rights> rightsList = rightsService.SearchByIdChannel(idChannel, 0, 0);
        if(rightsList==null || rightsList.size()<1){
            HttpUtil.responseApiCode(request, response, ApiCode.ACCESS_DENIED);
            return;
        }
        //过滤出有访问权限的音频列表
        List<Audio> audioList = FilterRights(list, rightsList);
        if(audioList==null || audioList.size()<1){
            HttpUtil.responseApiCode(request, response, ApiCode.ACCESS_DENIED);
            return;
        }
        //随机选择一个音频
        Random random = new Random();
        int r = Math.abs(random.nextInt())%audioList.size();
        Audio audio = audioList.get(r);
        if(audio.getIdResource()!=null && audio.getIdResource().length()>0){
            String res = audioHttp.GetResource(audio.getIdResource());
//        System.out.println(res);
            Map map = JSONObject.parseObject(res);
            try{
                if(map.get("code").toString().equalsIgnoreCase("200")){
                    map = JSONObject.parseObject(map.get("data").toString());
                    JSONArray array = JSONArray.parseArray(map.get("audios").toString());
                    map = JSONObject.parseObject(array.get(0).toString());
                    String path = map.get("path").toString();
                    path = path.replaceAll("\n","");
                    audio.setUrl(path);
//                    System.out.println(path);
                }
            }catch(Exception e){
                System.out.println(e.getMessage());
                audio.setUrl("fail to get resource uri");
            }
        }

        Record record = new Record();
        record.setIdDevice(device.getId());
        record.setIdChannel(device.getIdChannel());
        record.setIdAudio(audio.getId());
        record.setCreated(new Timestamp(new Date().getTime()));
        recordService.Insert(record);

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

//    @RequestMapping(value = "/insert", method = RequestMethod.POST)
//    public void Insert(HttpServletRequest request, HttpServletResponse response){
//        String gid = request.getParameter("gid");
//        String rid = request.getParameter("rid");
//        String album = request.getParameter("album");
//        String lesson = request.getParameter("lesson");
//        String name = request.getParameter("name");
//        String url = request.getParameter("url");
//        if(gid==null || rid==null || album==null || name==null){
//            HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
//            return;
//        }
//
//        Audio audio = new Audio();
//        audio.setIdGroup(Long.valueOf(gid));
//        audio.setIdResource(rid);
//        audio.setAlbum(album);
//        if(lesson!=null && lesson.length()>0)
//            audio.setLesson(Integer.valueOf(lesson));
//        audio.setName(name);
//        audio.setUrl(url);
//        audio.setCreated(new Date());
//        audio = audioService.Insert(audio);
//
//        HttpUtil.responseOutWithJson(request, response, audio);
//        return;
//    }

    @RequestMapping(value = "/insert", method = RequestMethod.POST)
    public void Insert(HttpServletRequest request, HttpServletResponse response, @RequestBody Audio audio){
        if(audio.getIdGroup()==null || audio.getIdResource()==null || audio.getName()==null){
            HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
            return;
        }
        audio.setStatus(Status.ONLINE.getCode());
        audio.setCreated(new Timestamp(new Date().getTime()));
        audio = audioService.Insert(audio);

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

    @RequestMapping(value = "/update", method = RequestMethod.POST)
    public void Update(HttpServletRequest request, HttpServletResponse response, @RequestBody Audio audio){
        if(audio.getId()==null){
            HttpUtil.responseApiCode(request, response, ApiCode.PARAMETER_ERROR);
            return;
        }
        System.out.println(audio.toString());
        Audio audioOld = audioService.GetOne(audio.getId());
        if(audioOld==null){
            HttpUtil.responseApiCode(request, response, ApiCode.NOT_FOUND);
            return;
        }

        audio = (Audio)Common.CopyValue(audio, audioOld);
        audio = audioService.Insert(audio);

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

    @RequestMapping(value = "/delete", method = RequestMethod.POST)
    public void Delete(HttpServletRequest request, HttpServletResponse response){
        String idAudio = request.getParameter("idAudio");
        audioService.Delete(Long.valueOf(idAudio));
        HttpUtil.responseOk(request, response);
        return;
    }

    /**
     * 过滤出渠道有访问权限的音频列表
     * @param audioList
     * @param rightsList
     * @return audioList
     */
    private List<Audio> FilterRights(List<Audio> audioList, List<Rights> rightsList){
        List<Audio> aList = new ArrayList<>();
        for(int i=0; i<audioList.size(); i++){
            for(int j=0; j<rightsList.size(); j++){
                if(audioList.get(i).getIdGroup() == rightsList.get(j).getIdGroup()){
                    aList.add(audioList.get(i));
                    break;
                }
            }
        }

        return aList;
    }

}