service

package io.wz.service;
import com.google.gson.Gson;
import io.wz.pojo.req.guest.GuestInfo;
import io.wz.pojo.req.guest.GuestRecord;
import io.wz.pojo.resp.guest.GuestResp;
import io.wz.pojo.resp.guest.GuestTokenResp;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
/** * 推送数据 */
@Service
public class GuestMachineService { 
    @Value("${guest.url}")
    private String url;
    @Value("${guest.loginName}")
    private String loginName;
    @Value("${guest.loginPassWord}")
    private String loginPassWord;
    private final String PARAM_TOKEN = "token";
    private final String PARAM_SOURCE = "source";
    private final String VALUE_SOURCE = "fk_server";
    @Autowired
    private RestTemplate restTemplate;
    /** * 获取token * https://blog.csdn.net/qq_26702601/article/details/91864118 */
    public GuestTokenResp getAccessToken() { 
        HttpHeaders headers = new HttpHeaders();
        headers.add(PARAM_SOURCE, VALUE_SOURCE);
        HttpEntity<String> requestEntity = new HttpEntity<>(null, headers);
        ResponseEntity<GuestTokenResp> exchange = restTemplate.exchange(
                url + "/user/login/" + loginName + "/" + loginPassWord,
                HttpMethod.GET, requestEntity, GuestTokenResp.class);
        return exchange.getBody();
    }
    /** * 更新或新增访客信息 * https://segmentfault.com/a/1190000021123356 */
    public GuestResp changeGusetInfo(GuestInfo guestInfo) { 
        HttpHeaders headers = new HttpHeaders();
        System.out.println("token=="+getAccessToken().getData().getToken());
        headers.add(PARAM_TOKEN, getAccessToken().getData().getToken());
        headers.add(PARAM_SOURCE, VALUE_SOURCE);
        System.out.println(new Gson().toJson(guestInfo));
        HttpEntity<GuestInfo> requestEntity = new HttpEntity<>(guestInfo, headers);
        GuestResp exchange = restTemplate.postForObject(url + "/fk/change/fkxx", requestEntity, GuestResp.class);
        return exchange;
    }
    /** * 新增访客访问记录 * @param guestRecord * @return */
    public GuestResp changeGusetRecord( GuestRecord guestRecord) { 
        HttpHeaders headers = new HttpHeaders();
        System.out.println("token=="+getAccessToken().getData().getToken());
        headers.add(PARAM_TOKEN, getAccessToken().getData().getToken());
        headers.add(PARAM_SOURCE, VALUE_SOURCE);
        System.out.println(new Gson().toJson(guestRecord));
        HttpEntity<GuestRecord> requestEntity = new HttpEntity<>(guestRecord, headers);
        GuestResp exchange = restTemplate.postForObject(url + "/fk/insert/fkd/cljl", requestEntity, GuestResp.class);
        return exchange;
    }
}

controller测试

import io.wz.pojo.req.guest.GuestInfo;
import io.wz.pojo.req.guest.GuestRecord;
import io.wz.pojo.resp.guest.GuestResp;
import io.wz.pojo.resp.guest.GuestTokenResp;
import io.wz.service.GuestMachineService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/** * api接口模拟调用 */
@RequestMapping("/guestMachine")
@RestController
public class GusetMachineController { 
    @Autowired
    private GuestMachineService guestMachineService;
    @GetMapping("/getToken")
    public GuestTokenResp getToken(){ 
        return guestMachineService.getAccessToken();
    }
    @PostMapping("/changeGusetInfo")
    public GuestResp changeGusetInfo(@RequestBody GuestInfo guestInfo){ 
        return guestMachineService.changeGusetInfo(guestInfo);
    }
    @PostMapping("/changeGusetRecord")
    public GuestResp changeGusetRecord(@RequestBody GuestRecord guestRecord){ 
        return guestMachineService.changeGusetRecord(guestRecord);
    }
}