package com.ibeetl.admin.console.service;


import com.ibeetl.admin.console.dao.OrderManageDao;
import com.ibeetl.admin.console.dao.XzxOrderComplaintDao;
import com.ibeetl.admin.console.model.XzxOrderComplaintModel;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.entity.XzxOrderComplaint;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.service.CorePlatformService;
import com.ibeetl.admin.core.util.PlatformException;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.beetl.sql.core.engine.PageQuery;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;


/**
 * XzxOrderComplaint Service
 */

@Service
@Transactional
public class XzxOrderComplaintService extends CoreBaseService<XzxOrderComplaint>{

    @Autowired private XzxOrderComplaintDao xzxOrderComplaintDao;
    final Base64 base64 = new Base64();
    @Autowired
    CorePlatformService platformService;
    @Autowired
    XzxCityPartnerService cityPartnerService;
    @Autowired
    OrderManageDao orderManageDao;
    public PageQuery<XzxOrderComplaint>queryByCondition(PageQuery query){
        PageQuery ret =  xzxOrderComplaintDao.queryByCondition(query);
        queryListAfter(ret.getList());
        return ret;
    }

    public void batchDelXzxOrderComplaint(List<Long> ids){
        try {
            xzxOrderComplaintDao.batchDelXzxOrderComplaintByIds(ids);
        } catch (Exception e) {
            throw new PlatformException("批量删除XzxOrderComplaint失败", e);
        }
    }

    /**
     * 根据条件查询投诉列表
     * @param model
     * @return
     */
    public Map<String, Object> queryComplaintApiList(XzxOrderComplaintModel model) {
        String afterSaleFlag = model.getAfterSaleFlag();
        String startTime = model.getStartTime();
        String endTime = model.getEndTime();
        int p = (model.getPage() - 1) * model.getLimit();
        Map<String, Object> m = new HashMap<>();
        String[] x = null;
        if (!StringUtils.isEmpty(afterSaleFlag)) {
            if (afterSaleFlag.equals("1")) {
                //完成包含 1 未处理 2 取消订单 3重新派单
                afterSaleFlag = "1,2,3";
            }
            x = afterSaleFlag.split(",");
        }
        if (null != startTime && !"".equals(startTime)) {
            startTime = startTime + " 00:00:00";
        }
        if (null != endTime && !"".equals(endTime)) {
            endTime = endTime + " 23:59:59";
        }
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        List<XzxOrderComplaintModel> list =xzxOrderComplaintDao.queryComplaintApiList(x, startTime, endTime, p, model.getLimit(),model.getOrderId(),model.getUserPhone(),model.getCollectorName(),model.getCollectorPhone(),partnerIds);
        for (XzxOrderComplaintModel orderModel:list) {
            if(orderModel.getNickName()!=null&&!"".equals(orderModel.getNickName())){
                String nickName ="";
                try {
                    nickName =new String(base64.decode(orderModel.getNickName()), "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
                orderModel.setNickName(nickName);
            }
            if(orderModel.getComplaintReason()!=null&&!"".equals(orderModel.getComplaintReason())){
                String complaintReason ="";
                try {
                    complaintReason =new String(base64.decode(orderModel.getComplaintReason()), "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
                orderModel.setComplaintReason(complaintReason);
            }

        }
        m.put("data", list);
        m.put("count", xzxOrderComplaintDao.queryComplaintApiCount(x, startTime, endTime,model.getOrderId(),model.getUserPhone(),model.getCollectorName(),model.getCollectorPhone(),partnerIds));
        m.put("code", 0);
        return m;
    }

    /**
     * 根据ID更新投诉单状态
     * @param model
     */
    public int updateComplaintFlagApi(XzxOrderComplaintModel model){
        // OrderManageService为2是取消订单，需要更新订单状态为6
        if(model.getAfterSaleFlag().equals("2")){
            orderManageDao.updateOrderStatus(model.getOrderId(), null, "6");
        }
        return xzxOrderComplaintDao.updateComplaintFlagApi(model.getId().toString(), model.getComplaintPlan(), model.getAfterSaleFlag());
    }
}