package com.taoke.autopay.controller.admin.js2;

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.OrderTaskExecutionDetailMapper;
import com.taoke.autopay.dao.OrderTaskMapper;
import com.taoke.autopay.entity.js2.OrderTask;
import com.taoke.autopay.entity.js2.OrderTaskExecutionDetail;
import com.taoke.autopay.exception.OrderTaskException;
import com.taoke.autopay.factory.js2.OrderTaskFactory;
import com.taoke.autopay.service.js2.OrderTaskExecutionDetailService;
import com.taoke.autopay.service.js2.OrderTaskService;
import com.taoke.autopay.utils.TimeUtil;
import com.taoke.autopay.vo.admin.js2.OrderTaskVO;
import net.sf.json.JSONObject;
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.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.yeshi.utils.JsonUtil;
import org.yeshi.utils.StringUtil;

import javax.annotation.Resource;
import java.io.IOException;
import java.sql.Time;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.Calendar;
import java.util.ArrayList;

/**
 * 下单任务管理
 */
@Controller
@RequestMapping("/admin/api/ordertask/js2")
public class AdminOrderTaskController {

    @Resource
    private OrderTaskService orderTaskService;
    
    @Resource
    private OrderTaskExecutionDetailMapper orderTaskExecutionDetailMapper;

    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();
    @Autowired
    private OrderTaskExecutionDetailService orderTaskExecutionDetailService;

    /**
     * 任务列表查询（按照关键字，日期查询）
     */
    @ResponseBody
    @RequestMapping("list")
    public String list(String keyword, String startDate, String endDate, Integer status, int page, int limit) {
        try {
            OrderTaskMapper.DaoQuery query = new OrderTaskMapper.DaoQuery();
            if (!StringUtil.isNullOrEmpty(keyword)) {
                query.keywordContent = keyword;
            }
            
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
            if (!StringUtil.isNullOrEmpty(startDate)) {
                query.minCreateTime = sdf.parse(startDate);
            }
            
            if (!StringUtil.isNullOrEmpty(endDate)) {
                Date end = sdf.parse(endDate);
                // 设置为当天的最后时刻
                Calendar cal = Calendar.getInstance();
                cal.setTime(end);
                cal.set(Calendar.HOUR_OF_DAY, 23);
                cal.set(Calendar.MINUTE, 59);
                cal.set(Calendar.SECOND, 59);
                query.maxCreateTime = cal.getTime();
            }
            
            if (status != null) {
                query.status = status;
            }
            
            query.sortList = Arrays.asList(new String[]{"create_time desc"});
            query.start = (page - 1) * limit;
            query.count = limit;
            
            List<OrderTask> list = orderTaskService.listOrderTasks(query, page, limit);
            long count = orderTaskService.countOrderTasks(query);
            
            // 转换为VO对象
            List<OrderTaskVO> voList = new ArrayList<>();
            for (OrderTask orderTask : list) {
                voList.add(OrderTaskFactory.createOrderTaskVO(orderTask));
            }
            
            JSONObject data = new JSONObject();
            data.put("list", gson.toJson(voList));
            data.put("count", count);
            return JsonUtil.loadTrueResult(data);
        } catch (ParseException e) {
            return JsonUtil.loadFalseResult("日期格式错误");
        } catch (Exception e) {
            return JsonUtil.loadFalseResult(e.getMessage());
        }
    }

    /**
     * 获取单个任务信息
     */
    @ResponseBody
    @RequestMapping("get")
    public String get(Long id) {
        try {
            if (id == null) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }
            
            OrderTask orderTask = orderTaskService.getOrderTaskById(id);
            if (orderTask == null) {
                return JsonUtil.loadFalseResult("任务不存在");
            }
            
            OrderTaskVO orderTaskVO = OrderTaskFactory.createOrderTaskVO(orderTask);
            return JsonUtil.loadTrueResult(gson.toJson(orderTaskVO));
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 新增任务
     */
    @ResponseBody
    @RequestMapping("add")
    public String add(OrderTaskVO orderTaskVO) {
        try {
            if (orderTaskVO == null) {
                return JsonUtil.loadFalseResult("任务信息不能为空");
            }
            
            // 将VO转换为实体
            OrderTask orderTask = OrderTaskFactory.createOrderTask(orderTaskVO);
            OrderTask result = orderTaskService.createOrderTask(orderTask);
            OrderTaskVO resultVO = OrderTaskFactory.createOrderTaskVO(result);
            return JsonUtil.loadTrueResult(gson.toJson(resultVO));
        } catch (ParseException e) {
            return JsonUtil.loadFalseResult("日期格式错误：" + e.getMessage());
        } catch (OrderTaskException e) {
            return JsonUtil.loadFalseResult(e.getMessage());
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 删除任务
     */
    @ResponseBody
    @RequestMapping("delete")
    public String delete(Long id) {
        try {
            if (id == null) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }
            
            orderTaskService.deleteOrderTask(id);
            return JsonUtil.loadTrueResult("");
        } catch (OrderTaskException e) {
            return JsonUtil.loadFalseResult(e.getMessage());
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 修改任务
     */
    @ResponseBody
    @RequestMapping("update")
    public String update(OrderTaskVO orderTaskVO) {
        try {
            if (orderTaskVO == null || orderTaskVO.getId() == null) {
                return JsonUtil.loadFalseResult("任务信息不完整");
            }
            
            // 先从数据库获取原始任务信息
            OrderTask orderTask = orderTaskService.getOrderTaskByIdForUpdate(orderTaskVO.getId());
            if (orderTask == null) {
                return JsonUtil.loadFalseResult("任务不存在");
            }
            OrderTask newOrderTask = OrderTaskFactory.createOrderTask(orderTaskVO);
            newOrderTask.setUpdateTime(new Date());
            orderTaskService.updateOrderTask(newOrderTask);
            return JsonUtil.loadTrueResult("");
        } catch (ParseException e) {
            return JsonUtil.loadFalseResult("日期格式错误：" + e.getMessage());
        } catch (OrderTaskException e) {
            return JsonUtil.loadFalseResult(e.getMessage());
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 任务客户端分配
     */
    @ResponseBody
    @RequestMapping("assign")
    public String assign(Long taskId) {
        try {
            if (taskId == null) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }
            
            int result = orderTaskService.assignTask(taskId);
            JSONObject data = new JSONObject();
            data.put("result", result);
            return JsonUtil.loadTrueResult(data);
        } catch (OrderTaskException e) {
            return JsonUtil.loadFalseResult(e.getMessage());
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }
    
    /**
     * 查询任务已分配的客户端列表
     */
    @ResponseBody
    @RequestMapping("assignedClients")
    public String assignedClients(Long taskId, int page, int limit) {
        try {
            if (taskId == null) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }
            
            OrderTaskExecutionDetailMapper.DaoQuery query = new OrderTaskExecutionDetailMapper.DaoQuery();
            query.taskId = taskId;
            query.start = (page - 1) * limit;
            query.count = limit;
            query.sortList = Arrays.asList("create_time desc");
            
            List<OrderTaskExecutionDetail> list = orderTaskExecutionDetailMapper.list(query);
            long count = orderTaskExecutionDetailMapper.count(query);
            
            JSONObject data = new JSONObject();
            data.put("list", gson.toJson(list));
            data.put("count", count);
            return JsonUtil.loadTrueResult(data);
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    @ResponseBody
    @RequestMapping("updateExpectedReviewTime")
    public String updateExpectedReviewTime(String id, String expectedReviewTime) {
        try {
            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("ID不能为空");
            }

            OrderTaskExecutionDetail update =  OrderTaskExecutionDetail.builder()
                    .id( id)
                    .expectedReviewTime(new Date(TimeUtil.convertToTimeTemp(expectedReviewTime, "yyyy-MM-dd HH:mm:ss")))
                    .updateTime(new Date())
                    .build();
            orderTaskExecutionDetailService.updateOrderTaskExecutionDetail(update);
            return JsonUtil.loadTrueResult("");
        } catch (Exception e) {
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }


}