103 lines
3.5 KiB
Java
103 lines
3.5 KiB
Java
package com.czlis.interfaceCommon.utils;
|
||
|
||
import cn.hutool.http.HttpRequest;
|
||
import cn.hutool.http.HttpResponse;
|
||
import com.czlis.common.config.RuoYiConfig;
|
||
import com.czlis.common.core.domain.Result;
|
||
import com.czlis.interfaceCommon.mapper.LisInterfaceMapper;
|
||
import lombok.extern.slf4j.Slf4j;
|
||
import org.springframework.stereotype.Component;
|
||
import org.springframework.transaction.annotation.Transactional;
|
||
|
||
import javax.annotation.Resource;
|
||
import java.util.HashMap;
|
||
import java.util.Map;
|
||
|
||
@Slf4j
|
||
@Component
|
||
public class LisInterfaceUtil {
|
||
@Resource
|
||
LisInterfaceMapper lisInterfaceMapper;
|
||
|
||
public Result invokeLisInterface(String type,String inValue) {
|
||
String interfaceType = RuoYiConfig.getInterfaceType();
|
||
switch (interfaceType){
|
||
case "1": //存储过程
|
||
return invokeSP(type, inValue);
|
||
case "2": //http方式
|
||
return invokeHttp(type, inValue);
|
||
}
|
||
|
||
return new Result("-1","无效的接口方式,请检查配置文件的interfaceType！！");
|
||
}
|
||
|
||
/**
|
||
* 存储过程方式调用接口
|
||
* @param type
|
||
* @param inValue
|
||
* @return
|
||
*/
|
||
@Transactional(rollbackFor = Exception.class)
|
||
public Result invokeSP(String type,String inValue){
|
||
Map<String,Object> map = new HashMap<>();
|
||
map.put("invalue",inValue);
|
||
map.put("retcode","");
|
||
map.put("retmsg","");
|
||
switch (type){
|
||
case "getreqinterface":
|
||
lisInterfaceMapper.sp_lis_getreqinterface(map);
|
||
break;
|
||
case "setdict":
|
||
lisInterfaceMapper.sp_lis_setdict(map);
|
||
break;
|
||
case "setreport":
|
||
lisInterfaceMapper.sp_lis_setreport(map);
|
||
break;
|
||
case "setreqstatus":
|
||
lisInterfaceMapper.sp_lis_setreqstatus(map);
|
||
break;
|
||
case "daymessage":
|
||
lisInterfaceMapper.sp_lis_daymessage(map);
|
||
break;
|
||
}
|
||
String retCode = String.valueOf(map.get("retcode"));
|
||
String retMsg = String.valueOf(map.get("retmsg"));
|
||
log.info("调用存储过程{}返回值：{},{}",type,retCode,retMsg);
|
||
if(retCode.equals("0")){
|
||
return new Result("0","调用接口成功！");
|
||
}else{
|
||
return new Result("-1","调用接口失败！"+retMsg);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* http方式调用接口
|
||
* @param transCode
|
||
* @param jsonStr
|
||
* @return
|
||
*/
|
||
public Result invokeHttp(String transCode,String jsonStr){
|
||
String interfaceUrl = RuoYiConfig.getInterfaceUrl();
|
||
if(interfaceUrl == null || "".equals(interfaceUrl)) return new Result("-1","没有配置地址，请检查interfaceUrl配置项！！！");
|
||
interfaceUrl = interfaceUrl+"/"+transCode;
|
||
String retMsg = "";
|
||
try {
|
||
HttpRequest httpRequest = HttpRequest.post(interfaceUrl);
|
||
httpRequest.header("Content-Type","application/json");
|
||
HttpResponse httpResponse = httpRequest.body(jsonStr).execute();
|
||
int status = httpResponse.getStatus();
|
||
retMsg = httpResponse.body();
|
||
if (status != 200) {
|
||
log.info("调用http接口失败："+retMsg);
|
||
return new Result("-1","调用http接口失败："+retMsg);
|
||
}
|
||
}catch (Exception e){
|
||
e.printStackTrace();
|
||
log.error("调用lis的http接口出错：",e);
|
||
}
|
||
|
||
return new Result("0","调用接口成功！",retMsg);
|
||
}
|
||
}
|
||
|