spring boot下java調用遠程接口，get方式和post方式

package net.vtstar.cloudmes.business.herc.service;

import com.alibaba.fastjson.JSONObject;
import net.vtstar.cloudmes.business.herc.domain.Oee;
import net.vtstar.cloudmes.business.herc.domain.OeeResult;
import net.vtstar.cloudmes.business.herc.domain.SyncProgram;
import net.vtstar.cloudmes.business.herc.properties.HercProperties;
import net.vtstar.cloudmes.business.mobileterminal.domain.ProductionCompleteVO;
import net.vtstar.utils.DateUtils;
import net.vtstar.utils.asserts.ParamAssert;
import net.vtstar.utils.domain.Return;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.io.FileSystemResource;
import org.springframework.http.*;
import org.springframework.stereotype.Service;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import org.springframework.web.util.UriComponentsBuilder;

import java.io.File;
import java.lang.reflect.Field;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;


@Service
public class HercService {

    @Autowired
    private HercProperties hercProperties;

    @Autowired
    private RestTemplate restTemplate;

    private static final String DATE_FORMAT = "yyyy-MM-dd HH:mm:ss";

    /**
     * @param syncProgram 同步程序需要的參數
     */
    public void syncProgram(SyncProgram syncProgram) {
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.MULTIPART_FORM_DATA);
        headers.setAccept(Collections.singletonList(MediaType.APPLICATION_JSON_UTF8));

        MultiValueMap<String, Object> body = getMultiValueMap(syncProgram);

        HttpEntity<MultiValueMap<String, Object>> httpEntity = new HttpEntity<>(body, headers);
        ResponseEntity<Return> responseEntity = restTemplate.exchange(hercProperties.getSyncProgram(), HttpMethod.POST, httpEntity, Return.class);
        ParamAssert.state(responseEntity.getStatusCode() == HttpStatus.OK, "同步程序異常");
        Return r = responseEntity.getBody();
        ParamAssert.state(600 == r.getCode(), r.getMessage());
    }

    /**
     * 獲取herc系統中oee內容
     */
    public OeeResult getTimePerformanceYieldRateOee(Oee oee) {
        // url采用了參數解析的方式, 參考herc.url.time-performance-yield-rate-oee
        ResponseEntity<Return> response = restTemplate.getForEntity(hercProperties.getTimePerformanceYieldRateOee(), Return.class, getValueMap(oee));
        ParamAssert.state(response.getStatusCode() == HttpStatus.OK, "獲取oee失敗");
        Return r = response.getBody();
        ParamAssert.state(600 == r.getCode(), r.getMessage());
        Map<String, Object> map = (Map<String, Object>) r.getData();
        return new JSONObject(map).toJavaObject(OeeResult.class);
    }

    /**
     * 將派工單報工同步到herc系統
     */
    public void syncDispatchListData(ProductionCompleteVO productionCompleteVO) {
        HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.setContentType(MediaType.APPLICATION_JSON_UTF8);
        RequestEntity<ProductionCompleteVO> requestEntity;
        try {
            requestEntity = new RequestEntity<>(productionCompleteVO, httpHeaders, HttpMethod.POST, new URI(hercProperties.getSyncDispatchListData()));
        } catch (URISyntaxException e) {
            e.printStackTrace();
            throw new IllegalStateException("同步程序url配置錯誤，請聯系管理員");
        }
        ResponseEntity<Return> responseEntity = restTemplate.exchange(requestEntity, Return.class);
        ParamAssert.state(responseEntity.getStatusCode() == HttpStatus.OK, "同步派工單參數失敗");
        Return r = responseEntity.getBody();
        ParamAssert.state(600 == r.getCode(), r.getMessage());
    }

    /**
     * 用戶同步派工單接口
     */
    public Map getUserPlanning(String equipNo) {
        HttpHeaders httpHeaders = new HttpHeaders();
        httpHeaders.setContentType(MediaType.APPLICATION_JSON_UTF8);

        RequestEntity<MultiValueMap<String, Object>> requestEntity = null;

        UriComponentsBuilder requestUri = UriComponentsBuilder.fromUri(URI.create(hercProperties.getSyncWorkOrderCount()))
                .queryParam("empNo", equipNo);

        ResponseEntity<Return> r = restTemplate.getForEntity(requestUri.toUriString(), Return.class);
        Map<String, Object> map = (Map<String, Object>) r.getBody().getData();
        return map;
    }


    /**
     * 將object轉換成HashMap封裝的對象
     * 用於 HTTP GET請求填充參數時使用
     * HTTP GET 請求uri類型   /api/xxxx/{x1}/{x2} , 或 /api/xxxx?x1={x1}&x2={x2}
     */
    private Map<String, Object> getValueMap(Object object) {
        Class objClass = object.getClass();
        Map<String, Object> result = new HashMap<>();

        Field[] fields = objClass.getDeclaredFields();
        for (Field field : fields) {
            field.setAccessible(true);
            try {
                if (field.getType() == Date.class) {
                    result.put(field.getName(), DateUtils.parseDateToString((Date) field.get(object), DATE_FORMAT));
                } else {
                    result.put(field.getName(), field.get(object));
                }
            } catch (IllegalAccessException e) {
                e.printStackTrace();
            }
        }
        return result;
    }

    /**
     * 將object轉換成MultiValueMap封裝的對象
     */
    private MultiValueMap<String, Object> getMultiValueMap(Object object) {
        Class objClass = object.getClass();
        MultiValueMap<String, Object> result = new LinkedMultiValueMap<>();

        Field[] fields = objClass.getDeclaredFields();
        for (Field field : fields) {
            field.setAccessible(true);
            try {
                if (field.getType() == File.class) {
                    FileSystemResource resource = new FileSystemResource((File) field.get(object));
                    result.add(field.getName(), resource);
                } else if (field.getType() == File[].class) {
                    File[] files = (File[]) field.get(object);
                    for (File file : files) {
                        FileSystemResource fileSystemResources = new FileSystemResource(file);
                        result.add(field.getName(), fileSystemResources);
                    }
                } else {
                    result.add(field.getName(), field.get(object));
                }
            } catch (IllegalAccessException e) {
                e.printStackTrace();
            }
        }
        return result;
    }

}

以上是核心業務代碼，使用

restTemplate方式調用遠程java接口

package net.vtstar.cloudmes.business.herc.properties;

import lombok.Getter;
import lombok.Setter;
import org.springframework.boot.context.properties.ConfigurationProperties;

@ConfigurationProperties(prefix = "herc.url")
public class HercProperties {

    @Getter
    @Setter
    // 程序同步
    private String syncProgram;

    @Getter
    @Setter
    // 獲取oee、時間稼動率、性能稼動率、良品率、OEE
    private String timePerformanceYieldRateOee;


    @Getter
    @Setter
    //將提交程序同步到herc系統
    private String syncDispatchListData;

    @Getter
    @Setter
    //用戶派工單接口
    private String syncWorkOrderCount;

}

 

herc.url.sync-program=http://22b1964l16.iok.la/api/CNCSystem/ProgramSynchronization
herc.url.time-performance-yield-rate-oee=http://22b1964l16.iok.la/api/CNCSystem/OEE?processDur={processDur}&startTime={startTime}&endTime={endTime}&equipNo={equipNo}
herc.url.sync-dispatch-list-data=http://22b1964l16.iok.la/api/CNCSystem/WorkOrderData
herc.url.sync-work-order-count=http://22b1964l16.iok.la/api/CNCSystem/WorkOrderCount

 

以上是配置遠程接口