wms / hhwms · Files

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


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;

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

@Service
public class StationInfoServiceImpl implements StationInfoService {

    @Autowired
    private AddressService addressService;

    /**
     * 站台信息查询
     * 1、判断非空字段
     * 2、实体转换
     * 3、发送数据
     * @param station
     * @return
     */
    @Override

    public AjaxResult StationInfo(String station, String warehouseCode, String area) {

        //1、判断非空字段
        if(StringUtils.isEmpty(station)){
            return AjaxResult.error("站台为空");
        }

        //2、实体转换

        Map<String , List> map =new HashMap<>();
        List list = new ArrayList();
        list.add(station);
        map.put("port",list);

        //3、发送数据

        String url = addressService.selectAddress(QuantityConstant.ADDRESS_WCS_STATION_INFOS,
                warehouseCode, area);

        String jsonParam = JSON.toJSONString(map);
        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;

    }
}