記一次使用hutool的http工具調(diào)用外部接口同步人員信息

這篇具有很好參考價(jià)值的文章主要介紹了記一次使用hutool的http工具調(diào)用外部接口同步人員信息。希望對(duì)大家有所幫助。如果存在錯(cuò)誤或未考慮完全的地方，請(qǐng)大家不吝賜教，您也可以點(diǎn)擊"舉報(bào)違法"按鈕提交疑問(wèn)。

首先引入hutool依賴

<dependency>
    <groupId>cn.hutool</groupId>
    <artifactId>hutool-all</artifactId>
    <version>4.1.2</version>
</dependency>

編寫調(diào)用外部接口的工具類

package com.donlim.fms.common.utils;

import cn.hutool.http.HttpRequest;
import cn.hutool.json.JSONObject;
import com.donlim.fms.common.dto.Dto;
import com.donlim.fms.model.ESB;
import com.donlim.fms.model.Org;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.DecoderException;
import org.apache.commons.lang3.ObjectUtils;
import org.apache.commons.lang3.StringUtils;

import java.security.NoSuchAlgorithmException;
import java.security.spec.InvalidKeySpecException;
import java.util.ArrayList;
import java.util.List;

/**
 * @ClassName HttpUtil
 * @Description TODO
 * @Author 李安山
 * @DATE 2023/2/15 11:44
 * <p>
 * Version 1.0
 **/

@Slf4j
public class HttpUtil {

    // 人員信息同步接口
    private static  final String url = "http://************:7080/HTTP/DONLIM/ESB/DONLIM_HRMS_QUERYSYNC";

    public static  List<ESB>  getEmployeeList(Dto dto){
        //封裝請(qǐng)求參數(shù),以下參數(shù)是此接口必須的參數(shù)
        JSONObject params = new JSONObject();
        params.put("SOURCEID","FMS");
        params.put("DESTINATIONID","ESB");
        params.put("TYPE","FMS");
        params.put("IPADDRESS","192.168.119.30");
        params.put("BO","syncEmployeeInfoToFms");
        if (dto==null){
            params.put("starttime","2020-01-01");
            params.put("endtime","2023-02-16");
        }else {
            if (ObjectUtils.isEmpty(dto.getDate("startTime")) ||ObjectUtils.isEmpty(dto.getDate("endTime"))){
                params.put("starttime","2020-01-01");
                params.put("endtime","2023-02-16");
            }else {
                String date1 = dto.getDate("startTime").toString();
                String date2 = dto.getDate("endTime").toString();
                params.put("starttime",date1);
                params.put("endtime",date2);
            }
        }
        //調(diào)用HttpRequest.put方法
        String result = HttpRequest.put(url)
                .header("Content-Type", "application/json")//頭信息，多個(gè)頭信息多次調(diào)用此方法即可
                .header("UrlType", "1")//頭信息，多個(gè)頭信息多次調(diào)用此方法即可
                .body(params.toString())//設(shè)置請(qǐng)求參數(shù)
                .execute().body();
        //根據(jù)結(jié)果獲取請(qǐng)求的數(shù)據(jù)，一般在[]之中
        result = result.substring(result.indexOf("["),result.lastIndexOf("]")+1);
//        log.info("result==>{}",result);
        //下面為hrms系統(tǒng)人員信息轉(zhuǎn)換成fms人員信息
        List<ESB> emp = new ArrayList<>();
        List<ESB> employeeList = com.alibaba.fastjson.JSONObject.parseArray(result, ESB.class);
        for (int j = 0; j < employeeList.size(); j++) {
            emp.add(employeeList.get(j));
        }
//        log.debug("時(shí)間段共{}個(gè)員工信息",employeeList.size());
        String company_id = dto.getString("company_id");
        boolean f = StringUtils.isNotBlank(company_id);
        emp.stream().forEach(esb -> {
            esb.setCard_Number(esb.getID_Number());
            try {
                esb.setSalt(PBKD2FUtils.getSalt());
                esb.setPassword(PBKD2FUtils.getPBKDF2(esb.getCard_Number(), esb.getSalt()));
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            } catch (DecoderException e) {
                e.printStackTrace();
            } catch (InvalidKeySpecException e) {
                e.printStackTrace();
            }

        });
        return emp;
    }
    public static List<Org> getOrgList(){
        JSONObject params = new JSONObject();
        params.put("SOURCEID","FMS");
        params.put("DESTINATIONID","ESB");
        params.put("TYPE","FMS");
        params.put("IPADDRESS","192.168.119.30");
        params.put("BO","syncORGInfoToFms");
        String result = HttpRequest.put(url)
                .header("Content-Type", "application/json")//頭信息，多個(gè)頭信息多次調(diào)用此方法即可
                .header("UrlType", "2")//頭信息，多個(gè)頭信息多次調(diào)用此方法即可
                .body(params.toString())
                .execute().body();

        result = result.substring(result.indexOf("["),result.length()-17);
//        System.out.println(result);
        List<Org> emp = new ArrayList<>();
        List<Org> employeeList = com.alibaba.fastjson.JSONObject.parseArray(result, Org.class);

        for (int j = 0; j < employeeList.size(); j++) {
            emp.add(employeeList.get(j));
        }
        System.out.println("共"+emp.size());
//        emp.stream().forEach(System.out::println);
        return emp;
    }
}

根據(jù)返回的包含id和父id的集合，自動(dòng)構(gòu)建目錄樹(shù)工具類

首先是TreeNodeVo實(shí)體

package com.donlim.fms.common.helper;

import lombok.Data;
import lombok.experimental.Accessors;

import java.io.Serializable;
import java.util.List;

/**
 * @ClassName TreeNodeVo
 * @Description TODO
 * @Author 李安山
 * @DATE 2023/2/16 11:47
 * <p>
 * Version 1.0
 **/
@Data
@Accessors(chain = true)
public class TreeNodeVO implements Serializable {

    private static final long serialVersionUID = 1L;

    // 節(jié)點(diǎn)ID
    private String id;
    private String value;

    // 父節(jié)點(diǎn)ID
    private String pId;

    // 節(jié)點(diǎn)名稱
    private String label;

    // 節(jié)點(diǎn)復(fù)選框選中狀態(tài)
//    private Boolean checked;

    //節(jié)點(diǎn)圖標(biāo)樣式類
    private String icon;

    //URL鏈接
//    private String url;

    private int sort_no;

//    private String is_enable;

    private Integer size;

    // 子孫節(jié)點(diǎn)集合
    private List<TreeNodeVO> children;
}

package com.donlim.fms.common.helper;

import com.alibaba.fastjson.JSON;
import com.google.common.collect.Lists;
import lombok.Getter;
import lombok.Setter;

import java.util.List;

/**
 * @ClassName TreeBuilder
 * @Description TODO
 * @Author 李安山
 * @DATE 2023/2/16 11:49
 * <p>
 * Version 1.0
 **/

public class TreeBuilder {
    @Getter
    @Setter
    List<TreeNodeVO> nodeVOs = Lists.newArrayList();

    public TreeBuilder() {
    }

    public TreeBuilder(List<TreeNodeVO> nodeVOs) {
        super();
        this.nodeVOs = nodeVOs;
    }

    public String buildJSONTree() {
        List<TreeNodeVO> nodeTree = buildTree();
        return JSON.toJSONString(nodeTree);
    }

    public List<TreeNodeVO> buildTree() {
        List<TreeNodeVO> treeNodeVOs = Lists.newArrayList();
        List<TreeNodeVO> rootTreeNodeVOs = getParentTreeNodes();
        for (TreeNodeVO rootTreeNodeVO : rootTreeNodeVOs) {
            buildChildTreeNodes(rootTreeNodeVO);
            treeNodeVOs.add(rootTreeNodeVO);
        }
        return treeNodeVOs;
    }

    private void buildChildTreeNodes(TreeNodeVO node) {
        List<TreeNodeVO> children = getChildTreeNodes(node);
        if (!children.isEmpty()) {
            for (TreeNodeVO child : children) {
                buildChildTreeNodes(child);
            }
            node.setChildren(children);
        }
    }

    public List<TreeNodeVO> getChildTreeNodes(TreeNodeVO pnode) {
        List<TreeNodeVO> childTreeNodeVOs = Lists.newArrayList();
        for (TreeNodeVO nodeVO : nodeVOs) {
            if (pnode.getId().equals(nodeVO.getPId())) {
                childTreeNodeVOs.add(nodeVO);
            }
        }
        return childTreeNodeVOs;
    }

    private boolean isParentNode(TreeNodeVO node) {
        boolean isParentNode = true;
        for (TreeNodeVO nodeVO : nodeVOs) {
            if (node.getPId().equals(nodeVO.getId())) {
                isParentNode = false;
                break;
            }
        }
        return isParentNode;
    }

    public List<TreeNodeVO> getParentTreeNodes() {
        List<TreeNodeVO> rootTreeNodeVOs = Lists.newArrayList();
        for (TreeNodeVO nodeVO : nodeVOs) {
            if (isParentNode(nodeVO)) {
                rootTreeNodeVOs.add(nodeVO);
            }
        }
        return rootTreeNodeVOs;
    }

}

最后根據(jù)返回的集合生成目錄結(jié)構(gòu)，主要設(shè)置treenodevo對(duì)象的id，pid,value,lable參數(shù)


    @Override
    public List<TreeNodeVO> getOrgInfo() {
        List<Org> orgList = HttpUtil.getOrgList();
        List<TreeNodeVO> treeNodeVOS = new ArrayList<>();
        for (int i = 0; i < orgList.size(); i++) {
            Org o = orgList.get(i);
            String orgName = o.getOrgName();
            TreeNodeVO treeNodeVO = new TreeNodeVO();
            treeNodeVO.setId(o.getOrgId());
            treeNodeVO.setValue(o.getOrgId());
            treeNodeVO.setPId(o.getSuperId());
            treeNodeVO.setLabel(orgName.substring(orgName.lastIndexOf("-")+1));
            treeNodeVOS.add(treeNodeVO);
        }
        treeNodeVOS = new TreeBuilder(treeNodeVOS).buildTree();
        return treeNodeVOS;
    }

controller類

package com.donlim.fms.controller.hrms;

import com.donlim.fms.common.dto.Dtos;
import com.donlim.fms.common.helper.TreeNodeVO;
import com.donlim.fms.service.EmployeeSyncService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import java.util.List;

/**
 * @ClassName EmployeeSyncController
 * @Description TODO
 * @Author 李安山
 * @DATE 2023/2/16 8:53
 * <p>
 * Version 1.0
 **/
@RestController
@Slf4j
@Api(tags = "總線人員組織同步接口")
@RequestMapping("/api")
public class EmployeeSyncController {
    @Autowired
    private EmployeeSyncService employeeSyncService;

    @PostMapping("/employSync")
    @ApiOperation("人員同步接口")
    public String employeeSync(HttpServletRequest request) {
        return employeeSyncService.employeeSync(Dtos.newDto(request));
    }

    @GetMapping("/getOrg")
    @ApiOperation("人員同步接口")
    public List<TreeNodeVO> getOrg(HttpServletRequest request) {
        return employeeSyncService.getOrgInfo();
    }
    @GetMapping("/updateNullPassword")
    @ApiOperation("員工密碼初始化")
    public void updatePassword(HttpServletRequest request) {
         employeeSyncService.updatePassword();
    }
}

前端vue+elementui,用級(jí)聯(lián)選擇器顯示目錄樹(shù)

 <el-form-item label="選擇同步組織">
      <div class="block">
        <el-cascader
          v-model="syncParams.id"
          :options="treeNodeVos"
          @change="handleChange"></el-cascader>
      </div>
 </el-form-item>

data中添加treeNodeVos對(duì)象

treeNodeVos:[],

methods中添加后臺(tái)調(diào)用方法，此方法可以在點(diǎn)擊頁(yè)面加載時(shí)調(diào)用，看自己，還有

handleChange(value) {
  console.log(value);
},
getOrgs() {
  this.company_id = '';
  this.$fetch("/api/getOrg", null).then(re => {
    this.treeNodeVos= re;
  });
},

對(duì)應(yīng)處理時(shí)間較長(zhǎng)的接口，使用@Async注解，需要在啟動(dòng)類上加@EnableAsync

 @Override
    @Async
    public String employeeSync(Dto dto){
        List<ESB> employeeList = HttpUtil.getEmployeeList(dto);
        String id = dto.getString("id").substring(dto.getString("id").lastIndexOf(",")+1,dto.getString("id").lastIndexOf("]"));
        log.info("id==>{}",id);
        log.info("查詢到{}個(gè)員工",employeeList.size());
        for (int i = 0; i <employeeList.size() ; i++) {
            ESB e = employeeList.get(i);
            if (ObjectUtils.isNotEmpty(e)){
                if (StringUtils.isNotBlank(e.getORGID())){
                    if(!e.getORGID().equals(id)){
                        employeeList.remove(e);
                    }
                }
            }
        }
        if (employeeList.size()==0){
            return "沒(méi)有要新增的員工";
        }
        int sum = 0;
        if (employeeList.size()>1000){
            for (int i = 0; i < employeeList.size()/300; i++) {
                if ((i+1)*300>employeeList.size()){
                    sum+= esbMapper.insertESB(employeeList.subList(i*300,employeeList.size()));
                }
                sum+= esbMapper.insertESB(employeeList.subList(i*300,(i+1)*300+1));
            }
        }else {
            sum= esbMapper.insertESB(employeeList);
        }
        log.info("新增{}個(gè)員工",sum);
        return "新增"+sum+"個(gè)員工";
    }

總結(jié)：使用第三方工具類，開(kāi)發(fā)簡(jiǎn)單不少，好用的工具類大大提高開(kāi)發(fā)效率。文章來(lái)源地址http://www.zghlxwxcb.cn/news/detail-752932.html

到了這里，關(guān)于記一次使用hutool的http工具調(diào)用外部接口同步人員信息的文章就介紹完了。如果您還想了解更多內(nèi)容，請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！