package com.yeshi.buwan.controller.admin.api;

import com.google.gson.*;
import com.google.gson.reflect.TypeToken;
import com.yeshi.buwan.domain.live.TVLiveCategoryChannelMap;
import com.yeshi.buwan.domain.live.TVLiveChannel;
import com.yeshi.buwan.domain.live.TVLiveChannelResourceMap;
import com.yeshi.buwan.domain.live.TVLiveResource;
import com.yeshi.buwan.service.imp.SystemService;
import com.yeshi.buwan.service.inter.live.TVLiveCategoryChannelService;
import com.yeshi.buwan.service.inter.live.TVLiveChannelResourceService;
import com.yeshi.buwan.service.inter.live.TVLiveChannelService;
import com.yeshi.buwan.util.Constant;
import com.yeshi.buwan.util.JsonUtil;
import com.yeshi.buwan.util.StringUtil;
import com.yeshi.buwan.util.TimeUtil;
import com.yeshi.buwan.vo.tvlive.TVLiveChannelResourceMapAdminVO;
import com.yeshi.buwan.web.tag.PageEntity;
import net.sf.json.JSONObject;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;

import javax.annotation.Resource;
import javax.servlet.http.HttpSession;
import java.io.PrintWriter;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

@Controller
@RequestMapping("admin/new/api/tvlive/channel")
public class TVLiveChannelAdminController {

    @Resource
    private TVLiveChannelService tvLiveChannelService;

    @Resource
    private TVLiveCategoryChannelService tvLiveCategoryChannelService;

    @Resource
    private SystemService systemService;

    @Resource
    private TVLiveChannelResourceService tvLiveChannelResourceService;

    private Gson gson = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {

        @Override
        public JsonElement serialize(Date src, Type typeOfSrc, JsonSerializationContext context) {
            return src == null ? new JsonPrimitive("") : new JsonPrimitive(TimeUtil.getGernalTime(src.getTime(), "yyyy.MM.dd HH:mm"));
        }
    }).create();

    @RequestMapping(value = "/getChannelList", method = RequestMethod.POST)
    public void getChannelList(HttpSession session, String categoryId, String key, Integer state, int page, PrintWriter out) {

        List<TVLiveChannel> channelList;
        long count;
        if (StringUtil.isNullOrEmpty(categoryId)) {
            channelList = tvLiveChannelService.list(key, state, page, Constant.pageCount);
            count = tvLiveChannelService.count(key, state);
        } else {
            channelList = tvLiveCategoryChannelService.listChannelByCid(categoryId, key, page, Constant.pageCount);
            count = tvLiveCategoryChannelService.countChannelByCid(categoryId, key);
        }
        JSONObject data = new JSONObject();
        data.put("pageEntity", new PageEntity(page, Constant.pageCount, (int) count));
        data.put("data", gson.toJson(channelList));
        out.print(JsonUtil.loadTrueAdmin(data.toString()));
    }

    @RequestMapping(value = "/addChannel", method = RequestMethod.POST)
    public void addChannel(TVLiveChannel channel, HttpSession session, PrintWriter out) {
        if (StringUtil.isNullOrEmpty(channel.getName()) || StringUtil.isNullOrEmpty(channel.gethPicture())) {
            out.print(JsonUtil.loadFalseAdmin("数据不完整"));
            return;
        }
        channel.setState(TVLiveChannel.STATE_NORMAL);
        try {
            tvLiveChannelService.addChannel(channel);
            out.print(JsonUtil.loadTrueAdmin(""));
        } catch (Exception e) {
            out.print(JsonUtil.loadFalseAdmin(e.getMessage()));
            return;
        }


    }


    @RequestMapping(value = "/addCategoryChannel", method = RequestMethod.POST)
    public void addCategoryChannel(String categoryId, String channelIds, Integer weight, HttpSession session, PrintWriter out) {

        if (StringUtil.isNullOrEmpty(categoryId) || StringUtil.isNullOrEmpty(channelIds)) {
            out.print(JsonUtil.loadFalseAdmin("数据不完整"));
            return;
        }

        String[] channelIdArray = channelIds.split(",");
        for (String channelId : channelIdArray) {
            TVLiveCategoryChannelMap map = new TVLiveCategoryChannelMap();
            map.setWeight(weight);
            map.setCategoryId(categoryId);
            map.setChannelId(channelId);
            tvLiveCategoryChannelService.addMap(map);
        }

        out.print(JsonUtil.loadTrueAdmin(""));
    }

    @RequestMapping(value = "/deleteCategoryChannel", method = RequestMethod.POST)
    public void deleteCategoryChannel(String categoryId, String channelIds, HttpSession session, PrintWriter out) {

        if (StringUtil.isNullOrEmpty(categoryId) || StringUtil.isNullOrEmpty(channelIds)) {
            out.print(JsonUtil.loadFalseAdmin("数据不完整"));
            return;
        }

        String[] channelIdArray = channelIds.split(",");
        for (String channelId : channelIdArray) {
            TVLiveCategoryChannelMap map = tvLiveCategoryChannelService.selectByCategoryIdAndChannelId(categoryId, channelId);
            if (map != null)
                tvLiveCategoryChannelService.deleteByPrimaryKey(map.getId());
        }
        out.print(JsonUtil.loadTrueAdmin(""));
    }


    @RequestMapping(value = "/updateCategoryChannelWeight", method = RequestMethod.POST)
    public void updateCategoryChannelWeight(String categoryId, String channelId, Integer weight, HttpSession session, PrintWriter out) {
        TVLiveCategoryChannelMap oldMap = tvLiveCategoryChannelService.selectByCategoryIdAndChannelId(categoryId, channelId);
        if (oldMap == null) {
            out.print(JsonUtil.loadFalseAdmin("分类的频道不存在"));
            return;
        }

        TVLiveCategoryChannelMap map = new TVLiveCategoryChannelMap();
        map.setId(oldMap.getId());
        map.setWeight(weight);
        tvLiveCategoryChannelService.update(map);
        out.print(JsonUtil.loadTrueAdmin(""));
    }

    //获取频道资源

    /**
     * 获取频道的播放资源
     *
     * @param session
     * @param id
     * @param out
     */
    @RequestMapping(value = "/getChannelResourceList", method = RequestMethod.POST)
    public void getChannelResourceList(HttpSession session, String id, PrintWriter out) {

        if (StringUtil.isNullOrEmpty(id)) {
            out.print(JsonUtil.loadFalseAdmin("频道ID不能为空"));
            return;
        }


        List<TVLiveChannelResourceMap> mapList = tvLiveChannelResourceService.listByChannelId(id);
        List<TVLiveChannelResourceMapAdminVO> voList = new ArrayList<>();
        if (mapList != null)
            for (TVLiveChannelResourceMap map : mapList) {
                voList.add(TVLiveChannelResourceMapAdminVO.create(map));
            }

        JSONObject data = new JSONObject();
        data.put("data", gson.toJson(voList));
        data.put("channelId", id);
        out.print(JsonUtil.loadTrueAdmin(data.toString()));
    }


    /**
     * 更新频道播放资源
     *
     * @param session
     * @param id
     * @param resources
     * @param out
     */
    @RequestMapping(value = "/updateChannelResources", method = RequestMethod.POST)
    public void updateChannelResources(HttpSession session, String id, String resources, PrintWriter out) {

        if (StringUtil.isNullOrEmpty(id)) {
            out.print(JsonUtil.loadFalseAdmin("频道ID不能为空"));
            return;
        }

        Type type = new TypeToken<List<TVLiveChannelResourceMapAdminVO>>() {
        }.getType();

        List<TVLiveChannelResourceMapAdminVO> voList = gson.fromJson(resources, type);

        List<TVLiveChannelResourceMap> list = new ArrayList<>();

        for (TVLiveChannelResourceMapAdminVO vo : voList) {
            TVLiveChannelResourceMap map = new TVLiveChannelResourceMap();
            map.setId(vo.getId());
            map.setWeight(vo.getWeight());
            map.setChannelId(id);
            map.setPlayUrl(vo.getPlayUrl());
            map.setSubResourceName(vo.getName());
            list.add(map);
        }
        List<TVLiveChannelResourceMap> originMapList = tvLiveChannelResourceService.listByChannelId(id);
        if (originMapList == null)
            originMapList = new ArrayList<>();

        List<String> originMapIds = new ArrayList<>();
        for (TVLiveChannelResourceMap map : originMapList) {
            originMapIds.add(map.getId());
        }

        //更新需要更新的
        for (int i = 0; i < list.size(); i++) {
            if (list.get(i).getId() != null && originMapIds.contains(list.get(i).getId())) {
                originMapIds.remove(list.get(i).getId());
                tvLiveChannelResourceService.update(list.get(i));
                list.remove(i--);
            }
        }
        //删除不需要更新的
        for (String mid : originMapIds) {
            tvLiveChannelResourceService.delete(mid);
        }

        //添加新的
        for (TVLiveChannelResourceMap map : list) {
            //咪咕不能手动添加
            map.setResource(TVLiveResource.other);
            tvLiveChannelResourceService.add(map);
        }
        out.print(JsonUtil.loadTrueAdmin(""));
    }


}