package com.taoke.autopay.controller.admin;

import com.alibaba.excel.EasyExcel;
import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.TypeAdapter;
import com.google.gson.stream.JsonReader;
import com.google.gson.stream.JsonWriter;
import com.taoke.autopay.dao.KeyOrderMapper;
import com.taoke.autopay.dao.agent.ChannelAgentMapper;
import com.taoke.autopay.dto.admin.OrderExcelDataDto;
import com.taoke.autopay.entity.ClientInfo;
import com.taoke.autopay.entity.KeyOrder;
import com.taoke.autopay.entity.OrderChannelEnum;
import com.taoke.autopay.entity.SystemConfigKeyEnum;
import com.taoke.autopay.entity.agent.ChannelAgent;
import com.taoke.autopay.entity.agent.ChannelAgentSettings;
import com.taoke.autopay.entity.agent.ChannelAgentSharingRatio;
import com.taoke.autopay.exception.ChannelAgentException;
import com.taoke.autopay.factory.AgentFactory;
import com.taoke.autopay.factory.OrderFactory;
import com.taoke.autopay.manager.ChannelAgentManager;
import com.taoke.autopay.service.ClientInfoService;
import com.taoke.autopay.service.KeyOrderService;
import com.taoke.autopay.service.SystemConfigService;
import com.taoke.autopay.service.agent.ChannelAgentService;
import com.taoke.autopay.service.agent.ChannelAgentSettingService;
import com.taoke.autopay.service.agent.ChannelAgentSharingRatioService;
import com.taoke.autopay.utils.Constant;
import com.taoke.autopay.utils.TimeUtil;
import com.taoke.autopay.vo.admin.AdminChannelAgentVO;
import com.taoke.autopay.vo.admin.AdminOrderVO;
import com.taoke.autopay.vo.admin.AgentSearchVO;
import com.taoke.autopay.vo.admin.OrderSearchVO;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.NumberUtil;
import org.yeshi.utils.StringUtil;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.math.BigDecimal;
import java.net.URLEncoder;
import java.util.*;

@Controller
@RequestMapping("/admin/api/agent")
public class AdminAgentController {

    private Gson gson = new GsonBuilder().registerTypeAdapter(Date.class, new TypeAdapter<Date>() {
        @Override
        public void write(JsonWriter out, Date value) throws IOException {
            String desc = "";
            if (value != null) {
                // 判断是否是同一天
                desc = TimeUtil.getGernalTime(value.getTime(), "yyyy-MM-dd HH:mm:ss");
                out.value(desc);
            } else {
                out.value("");
            }
        }

        @Override
        public Date read(JsonReader in) throws IOException {
            return new Date();
        }
    }).create();

    @Resource
    private ChannelAgentService channelAgentService;

    @Resource
    private ChannelAgentSettingService channelAgentSettingService;

    @Resource
    private ChannelAgentSharingRatioService channelAgentSharingRatioService;

    @Resource
    private SystemConfigService systemConfigService;


    @ResponseBody
    @RequestMapping("list")
    public String listAgent(AgentSearchVO search, int page, int limit) {
        //先查询所有的数据
        ChannelAgentMapper.DaoQuery query = new ChannelAgentMapper.DaoQuery();
        query.searchKey = search.getKey();
        query.sortList = Arrays.asList(new String[]{"_create_time desc"});
        query.start = (long) (page - 1) * limit;
        query.count = limit;

        if (!StringUtil.isNullOrEmpty(search.getStartDate())) {
            query.minCreateTime = new Date(TimeUtil.convertToTimeTemp(search.getStartDate(), "yyyy-MM-dd"));
        }
        if (!StringUtil.isNullOrEmpty(search.getEndDate())) {
            query.maxCreateTime = TimeUtil.getNextDay(1, new Date(TimeUtil.convertToTimeTemp(search.getEndDate(), "yyyy-MM-dd")).getTime());
        }

        List<ChannelAgent> agentList = channelAgentService.list(query);
        List<Long> agentIds = new ArrayList<>();
        for (ChannelAgent agent : agentList) {
            agentIds.add(agent.getId());
        }
        List<ChannelAgentSettings> settings = channelAgentSettingService.listByIds(agentIds);
        Map<Long, ChannelAgentSettings> settingsMap = new HashMap<>();
        for (ChannelAgentSettings setting : settings) {
            settingsMap.put(setting.getId(), setting);
        }

        long count = channelAgentService.count(query);
        // 转vo
        List<AdminChannelAgentVO> voList = new ArrayList<>();
        String baseSubmitKeyLink = systemConfigService.getValueCache(SystemConfigKeyEnum.AGENT_SUBMIT_KEY_LINK);
        for (ChannelAgent agent : agentList) {
            voList.add(AgentFactory.create(agent, settingsMap.get(agent.getId()), null, baseSubmitKeyLink));
        }
        JSONObject data = new JSONObject();
        data.put("count", count);
        data.put("list", gson.toJson(voList));
        return JsonUtil.loadTrueResult(data);
    }


    @Resource
    private ChannelAgentManager channelAgentManager;

    @ResponseBody
    @RequestMapping("add")
    public String addAgent(AdminChannelAgentVO vo) {

        try {
            ChannelAgent agent=  channelAgentManager.addAgent(vo);
            return JsonUtil.loadTrueResult(agent);
        } catch (ChannelAgentException e) {
            return JsonUtil.loadFalseResult(e.getMessage());
        }
    }

    @ResponseBody
    @RequestMapping("update")
    public String update(AdminChannelAgentVO vo) {
        // 创建代理
        ChannelAgent agent = ChannelAgent.builder()
                .id(vo.getId())
                .name(vo.getName())
                .account(vo.getAccount())
                .pwd(StringUtil.isNullOrEmpty(vo.getPwd()) ? null :StringUtil.Md5(vo.getPwd()))
                .alipayAccount(StringUtil.isNullOrEmpty(vo.getAlipayAccount()) ? null : vo.getAlipayAccount())
                .alipayName(StringUtil.isNullOrEmpty(vo.getAlipayName()) ? null : vo.getAlipayName())
                .shieldedAreas(vo.getShieldedAreas())
                .build();
        channelAgentService.updateSelective(agent);
        // 添加设置
        ChannelAgentSettings settings = ChannelAgentSettings.builder()
                .id(agent.getId())
                .startSubmitTime(StringUtil.isNullOrEmpty(vo.getStartSubmitTime()) ? null : vo.getStartSubmitTime())
                .endSubmitTime(StringUtil.isNullOrEmpty(vo.getEndSubmitTime()) ? null : vo.getEndSubmitTime())
                .maxKeyCountPerDay(StringUtil.isNullOrEmpty(vo.getMaxKeyCountPerDay()) ? null : Long.parseLong(vo.getMaxKeyCountPerDay()))
                .maxPayMoneyPerDay(StringUtil.isNullOrEmpty(vo.getMaxPayMoneyPerDay()) ? null : new BigDecimal(vo.getMaxPayMoneyPerDay()))
                .creditEnable(vo.getCreditEnable() != null && vo.getCreditEnable() > 0)
                .build();
        channelAgentSettingService.add(settings);
        // 添加分成比例设置
        if (!StringUtil.isNullOrEmpty(vo.getShareRatioInfos())) {
            JSONObject shareRatioData = JSONObject.fromObject(vo.getShareRatioInfos());
            for (Object key : shareRatioData.keySet()) {
                String value = shareRatioData.optString(key.toString());
                OrderChannelEnum channel = OrderChannelEnum.valueOf(key.toString());
                if (!StringUtil.isNullOrEmpty(value)) {
                    channelAgentSharingRatioService.setShareRatio(ChannelAgentSharingRatio.builder().agengId(agent.getId()).orderChannel(channel).shareType(ChannelAgentSharingRatio.SHARE_TYPE_MONEY).shareValue(new BigDecimal(value)).build());
                }
            }
        }
        return JsonUtil.loadTrueResult(agent);
    }


    @ResponseBody
    @RequestMapping("delete")
    public String delete(Long id){
        // 删除agent
        channelAgentService.delete(id);
        return JsonUtil.loadTrueResult("");
    }

    @ResponseBody
    @RequestMapping("getDetail")
    public String getDetail(Long id) {

        ChannelAgent agent = channelAgentService.selectByPrimaryKey(id);
        if (agent == null) {
            return JsonUtil.loadFalseResult("代理ID不存在");
        }
        Map<OrderChannelEnum, BigDecimal> shareRatio = channelAgentSharingRatioService.getShareMoneyMap(id);
        ChannelAgentSettings settings = channelAgentSettingService.selectByAgentId(id);
        if(settings.getStartSubmitTime()==null||settings.getEndSubmitTime()==null){
            String timeStr =   systemConfigService.getValueCache(SystemConfigKeyEnum.KEY_SUBMIT_TIME_RANGE);
            settings.setStartSubmitTime(timeStr.split(",")[0]);
            settings.setEndSubmitTime(timeStr.split(",")[1]);
        }
        String baseSubmitKeyLink = systemConfigService.getValueCache(SystemConfigKeyEnum.AGENT_SUBMIT_KEY_LINK);
        AdminChannelAgentVO vo = AgentFactory.create(agent, settings, shareRatio, baseSubmitKeyLink);
        return JsonUtil.loadTrueResult(gson.toJson(vo));
    }

    /**
     * 获取订单所有的渠道
     *
     * @return
     */
    @ResponseBody
    @RequestMapping("getAgentOrderChannels")
    public String getAgentOrderChannels() {
        JSONArray array = new JSONArray();
        for (OrderChannelEnum channel : OrderChannelEnum.values()) {
            JSONObject item = new JSONObject();
            item.put("label", channel.getName());
            item.put("name", channel.name());
            array.add(item);
        }
        return JsonUtil.loadTrueResult(array);
    }
}