package com.xiaopeng.operation.utils;

import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson2.JSON;
import com.xiaopeng.api.dto.account.UcUserInfo;
import com.xiaopeng.api.feignClient.account.UserResourcesClient;
import com.xiaopeng.api.model.operation.XpOfficialPartner;
import com.xiaopeng.api.model.order.XpOrder;
import com.xiaopeng.api.vo.operation.OfficialPartnerResult;
import com.xiaopeng.common.core.domain.R;
import com.xiaopeng.common.core.exception.ServiceException;
import com.xiaopeng.operation.service.IXpOfficialPartnerService;
import com.xiaopeng.operation.vo.PushNewOrderVo;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.time.format.DateTimeFormatter;

/**
 * 合作商工具类
 */
@Component
public class OfficialPartnerUtil {

    @Resource
    private IXpOfficialPartnerService xpOfficialPartnerService;

    @Resource
    private UserResourcesClient userResourcesClient;




    /**
     * 推送新的订单给合作商
     * @param officialPartnerId
     * @return
     */
    public R<?> pushNewOrder(Integer officialPartnerId, XpOrder xpOrder) {
        XpOfficialPartner xpOfficialPartner = xpOfficialPartnerService.getById(officialPartnerId);
        String createOrderUrl = xpOfficialPartner.getCreateOrderUrl();
        PushNewOrderVo pushNewOrderVo = buildNewOrder(xpOrder);
        HttpRequest post = HttpUtil.createPost(createOrderUrl);
        post.body(JSON.toJSONString(pushNewOrderVo));
        HttpResponse execute = post.execute();
        if(!execute.isOk()){
            throw new ServiceException("[" + xpOfficialPartner.getName() + "]调用合作商接口失败-通知新订单接口");
        }
        OfficialPartnerResult officialPartnerResult = JSON.parseObject(execute.body(), OfficialPartnerResult.class);
        if(0 == officialPartnerResult.getCode()){
            return R.ok();
        }
        throw new ServiceException("[" + xpOfficialPartner.getName() + "]" + officialPartnerResult.getMsg());
    }


    /**
     * 构建推送订单数据
     * @param xpOrder
     * @return
     */
    private PushNewOrderVo buildNewOrder(XpOrder xpOrder){
        PushNewOrderVo vo = new PushNewOrderVo();
        vo.setOrderNum(xpOrder.getOrderNumber());
        vo.setVehicleModelId(null);
        vo.setVehicleModelName("");
        vo.setPlacementLongitude(xpOrder.getPlacementLon());
        vo.setPlacementLatitude(xpOrder.getPlacementLat());
        vo.setPlacementAddress(xpOrder.getPlacementAddress());
        vo.setStartLongitude(xpOrder.getStartLon());
        vo.setStartLatitude(xpOrder.getStartLat());
        vo.setStartAddress(xpOrder.getStartAddress());
        vo.setEndLongitude(xpOrder.getEndLon());
        vo.setEndLatitude(xpOrder.getEndLat());
        vo.setEndAddress(xpOrder.getEndAddress());
        vo.setUserId(xpOrder.getAppUserId());
        UcUserInfo ucUserInfo = userResourcesClient.getBaseUserByUid(xpOrder.getAppUserId().toString());
        if(ucUserInfo != null){
            vo.setUserPhone(ucUserInfo.getMobile());
        }
        vo.setCreateTime(xpOrder.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
        return vo;

    }

}