package com.taoke.autopay.controller.client.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.entity.ClientAdditionalInfo;
import com.taoke.autopay.entity.js2.OrderTask;
import com.taoke.autopay.entity.js2.OrderTaskExecutionDetail;
import com.taoke.autopay.factory.js2.OrderTaskExecutionDetailFactory;
import com.taoke.autopay.service.ClientAdditionalInfoService;
import com.taoke.autopay.service.ClientInfoService;
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.OrderTaskExecutionDetailVO;
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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.StringUtil;

import javax.annotation.Resource;
import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * 手机客户端下单任务控制器
 */
@Controller
@RequestMapping("api/client/js2/task")
public class OrderTaskController {

    private Logger loggerDoOrder = LoggerFactory.getLogger("doOrderLogger");

    @Resource
    private ClientAdditionalInfoService clientAdditionalInfoService;

    private Logger loggerTask = LoggerFactory.getLogger("taskLogger");

    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 OrderTaskExecutionDetailService orderTaskExecutionDetailService;

    @Resource
    private OrderTaskService orderTaskService;

    @Resource
    private ClientInfoService clientInfoService;

    /**
     * 获取设备可执行的任务列表
     *
     * @param uid      客户端ID
     * @param page     页码
     * @param pageSize 每页数量
     * @return 任务列表
     */
    @ResponseBody
    @RequestMapping("list")
    public String list(Long uid, int page, int pageSize) {
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }
            clientInfoService.setActiveTime(uid, new Date());
            List<OrderTaskExecutionDetailVO> voList = new ArrayList<>();
            List<OrderTaskExecutionDetail> list = orderTaskExecutionDetailService.listCanExcuteTaskDetail(uid, (page - 1) * pageSize, pageSize);
            if (!list.isEmpty()) {
                List<Long> taskIds = new ArrayList<>();
                for (OrderTaskExecutionDetail detail : list) {
                    if (taskIds.contains(detail.getTaskId())) {
                        continue;
                    }
                    taskIds.add(detail.getTaskId());
                }
                // 获取手机号与支付宝账号信息
                ClientAdditionalInfo clientAdditionalInfo = clientAdditionalInfoService.getClientAdditionalInfoByClientId(uid);
                List<OrderTask> orderTaskList = orderTaskService.getOrderTaskByIds(taskIds);
                Map<Long, OrderTask> orderTaskMap = new HashMap<>();
                for (OrderTask task : orderTaskList) {
                    orderTaskMap.put(task.getId(), task);
                }
                for (OrderTaskExecutionDetail detail : list) {
                    OrderTaskExecutionDetailVO vo = OrderTaskExecutionDetailFactory.createOrderTaskExecutionDetailVO(orderTaskMap.get(detail.getTaskId()), detail, clientAdditionalInfo);
                    voList.add(vo);
                }
            }
            voList.sort((o1, o2) -> (int) (o1.getCreateTime().getTime() - o2.getCreateTime().getTime()));
            long count = orderTaskExecutionDetailService.countCanExcuteTaskDetail(uid);
            JSONObject data = new JSONObject();
            data.put("list", gson.toJson(voList));
            data.put("count", count);
            return JsonUtil.loadTrueResult(data);
        } catch (Exception e) {
            e.printStackTrace();
            loggerTask.error("获取任务列表失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }


    @ResponseBody
    @RequestMapping("canOrder")
    public String canOrder(Long uid, String id) {
        if (uid == null) {
            return JsonUtil.loadFalseResult("客户端ID不能为空");
        }

        if (StringUtil.isNullOrEmpty(id)) {
            return JsonUtil.loadFalseResult("任务ID不能为空");
        }

        OrderTaskExecutionDetail detail = orderTaskExecutionDetailService.getOrderTaskExecutionDetailByIdForUpdate(id);
        if (detail == null || detail.getExecutionStatus() != OrderTaskExecutionDetail.STATUS_NOT_ORDERED) {
            return JsonUtil.loadFalseResult("任务不存在或已执行");
        }
        return JsonUtil.loadTrueResult("");
    }

    /**
     * 下单成功
     *
     * @param uid          客户端ID
     * @param id
     * 任务执行详情ID
     * @param orderNo      订单号
     * @param productTitle 商品标题
     * @param shopName     店铺名称
     * @param orderTimeStr 下单时间字符串
     * @return 操作结果
     */
    @ResponseBody
    @RequestMapping("orderSuccess")
    public String orderSuccess(Long uid, String id, String orderNo, String productTitle, String shopName, String orderTimeStr) {
        loggerDoOrder.info("下单成功[{}]: {}-{}-{}-{}-{}", uid, id, orderNo, productTitle, shopName, orderTimeStr);
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(orderNo)) {
                return JsonUtil.loadFalseResult("订单号不能为空");
            }


            orderNo = orderNo.split("订单编号")[1];

            Date orderTime = null;
            if (!StringUtil.isNullOrEmpty(orderTimeStr)) {
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                orderTime = sdf.parse(orderTimeStr);
            } else {
                orderTime = new Date();
            }

            orderTaskExecutionDetailService.orderSuccess(id, orderNo, productTitle, shopName, orderTime);
            return JsonUtil.loadTrueResult("");
        } catch (ParseException e) {
            loggerTask.error("下单成功处理失败，时间格式错误: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("时间格式错误");
        } catch (Exception e) {
            loggerTask.error("下单成功处理失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 下单失败，上传失败原因
     *
     * @param uid           客户端ID
     * @param id            任务执行详情ID
     * @param failureReason 失败原因
     * @return 操作结果
     */
    @ResponseBody
    @RequestMapping("orderFailure")
    public String orderFailure(Long uid, String id, String failureReason) {
        loggerDoOrder.info("下单失败[{}]: {}-{}", uid, id, failureReason);
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(failureReason)) {
                return JsonUtil.loadFalseResult("失败原因不能为空");
            }

            orderTaskExecutionDetailService.orderFailure(id, failureReason);
            return JsonUtil.loadTrueResult("");
        } catch (Exception e) {
            loggerTask.error("下单失败处理失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 确认收货成功，上传券码
     *
     * @param uid        客户端ID
     * @param id         任务执行详情ID
     * @param couponCode 券码
     * @return 操作结果
     */
    @ResponseBody
    @RequestMapping("confirmReceiptSuccess")
    public String confirmReceiptSuccess(Long uid, String id, String couponCode) {
        loggerDoOrder.info("确认收货成功[{}]: {}-{}", uid, id, couponCode);
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(couponCode)) {
                return JsonUtil.loadFalseResult("券码不能为空");
            }

            orderTaskExecutionDetailService.confirmReceiptSuccess(id, couponCode);
            return JsonUtil.loadTrueResult("");
        } catch (Exception e) {
            loggerTask.error("确认收货成功处理失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 确认收货失败，上传失败原因
     *
     * @param uid    客户端ID
     * @param id     任务执行详情ID
     * @param reason 失败原因
     * @return 操作结果
     */
    @ResponseBody
    @RequestMapping("confirmReceiptFailure")
    public String confirmReceiptFailure(Long uid, String id, String reason) {
        loggerDoOrder.info("确认收货失败[{}]: {}-{}", uid, id, reason);
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(reason)) {
                return JsonUtil.loadFalseResult("失败原因不能为空");
            }

            orderTaskExecutionDetailService.confirmReceiptFailure(id, reason);
            return JsonUtil.loadTrueResult("");
        } catch (Exception e) {
            loggerTask.error("确认收货失败处理失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 评价成功
     *
     * @param uid 客户端ID
     * @param id  任务执行详情ID
     * @return 操作结果
     */
    @ResponseBody
    @RequestMapping("reviewSuccess")
    public String reviewSuccess(Long uid, String id) {
        loggerDoOrder.info("评价成功[{}]: {}", uid, id);
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }

            orderTaskExecutionDetailService.reviewSuccess(id);
            return JsonUtil.loadTrueResult("");
        } catch (Exception e) {
            loggerTask.error("评价成功处理失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }

    /**
     * 评价失败，上传失败原因
     *
     * @param uid    客户端ID
     * @param id     任务执行详情ID
     * @param reason 失败原因
     * @return 操作结果
     */
    @ResponseBody
    @RequestMapping("reviewFailure")
    public String reviewFailure(Long uid, String id, String reason) {
        loggerDoOrder.info("评价失败[{}]: {}-{}", uid, id, reason);
        try {
            if (uid == null) {
                return JsonUtil.loadFalseResult("客户端ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(id)) {
                return JsonUtil.loadFalseResult("任务ID不能为空");
            }

            if (StringUtil.isNullOrEmpty(reason)) {
                return JsonUtil.loadFalseResult("失败原因不能为空");
            }

            orderTaskExecutionDetailService.reviewFailure(id, reason);
            return JsonUtil.loadTrueResult("");
        } catch (Exception e) {
            loggerTask.error("评价失败处理失败: {}", e.getMessage(), e);
            return JsonUtil.loadFalseResult("系统异常：" + e.getMessage());
        }
    }
}