package com.huaheng.api.wcs.service.taskInfo;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.huaheng.api.wcs.domain.WcsTask;
import com.huaheng.common.constant.HttpConstant;
import com.huaheng.common.constant.QuantityConstant;
import com.huaheng.common.exception.service.ServiceException;
import com.huaheng.common.utils.StringUtils;
import com.huaheng.common.utils.http.HttpUtils;
import com.huaheng.common.utils.restful.RestUtil;
import com.huaheng.framework.web.domain.AjaxResult;
import com.huaheng.pc.config.address.service.AddressService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;

@Service
public class TaskInfoServiceImpl implements TaskInfoService {


    @Autowired
    private AddressService addressService;
    /**
     * 任务信息查询
     * 1、判断非空字段
     * 2、实体转换
     * 3、发送数据
     *
     * @param id
     * @return
     */
    @Override
    public AjaxResult taskInfo(String id, String warehouseCode, String area) {

        //1、判断非空字段
        if(id == null){
            return AjaxResult.error("任务号为空");
        }

        //2、实体转换
        WcsTask wcsTask =new WcsTask();
        wcsTask.setTaskNo(id.toString());

        //3、发送数据
        String url = addressService.selectAddress(QuantityConstant.ADDRESS_WCS_TASK_INFO, warehouseCode, area);
        String jsonParam = JSON.toJSONString(wcsTask);
        ResponseEntity<JSONObject> result = RestUtil.request_post(url, warehouseCode, jsonParam);
        if (result != null && result.getBody() != null) {
            String code = result.getBody().getString("code");
            String msg = result.getBody().getString("msg");
            if (!HttpConstant.isSuccess(Integer.parseInt(code))) {
                return AjaxResult.error(msg);
            }
        } else {
            throw new ServiceException("接口地址错误或返回为空");
        }
        String data = result.getBody().getString("data");
        AjaxResult ajaxResult = JSON.parseObject(data, AjaxResult.class);
        return ajaxResult;
    }
}