|
@@ -33,6 +33,7 @@ import org.springframework.scheduling.annotation.Async;
|
|
import org.springframework.scheduling.annotation.AsyncResult;
|
|
import org.springframework.scheduling.annotation.AsyncResult;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
|
|
+import javax.annotation.Resource;
|
|
import java.util.ArrayList;
|
|
import java.util.ArrayList;
|
|
import java.util.Date;
|
|
import java.util.Date;
|
|
import java.util.List;
|
|
import java.util.List;
|
|
@@ -51,20 +52,20 @@ import java.util.stream.Collectors;
|
|
@Slf4j
|
|
@Slf4j
|
|
@DependsOn("itfwServer")
|
|
@DependsOn("itfwServer")
|
|
public class RshyJkManagerImpl implements RshyJkManager {
|
|
public class RshyJkManagerImpl implements RshyJkManager {
|
|
- @Autowired
|
|
|
|
|
|
+ @Resource
|
|
private YituFaceServer yituFaceServer;
|
|
private YituFaceServer yituFaceServer;
|
|
- @Autowired
|
|
|
|
|
|
+ @Resource
|
|
private ItfwServer itfwServer;
|
|
private ItfwServer itfwServer;
|
|
@Autowired
|
|
@Autowired
|
|
private VIIDServer viidServer;
|
|
private VIIDServer viidServer;
|
|
- @Autowired
|
|
|
|
|
|
+ @Resource
|
|
private StringRedisTemplate stringRedisTemplate;
|
|
private StringRedisTemplate stringRedisTemplate;
|
|
|
|
|
|
@Override
|
|
@Override
|
|
@Async("hstTaskExecutor")
|
|
@Async("hstTaskExecutor")
|
|
public Future<RshyVo> getRshyInfo(RshyParam rshyParam) {
|
|
public Future<RshyVo> getRshyInfo(RshyParam rshyParam) {
|
|
- // timeout 转成毫秒 这里考虑到网络传输延时等原因,减去200ms
|
|
|
|
- rshyParam.setTimeout((int) TimeUnit.MILLISECONDS.convert(rshyParam.getTimeout(), TimeUnit.SECONDS) - 200);
|
|
|
|
|
|
+ // timeout 转成毫秒 这里考虑到网络传输延时等原因,减去300ms
|
|
|
|
+ rshyParam.setTimeout(rshyParam.getTimeout() * 1000 - 300);
|
|
int jkmTimeout = rshyParam.getTimeout();
|
|
int jkmTimeout = rshyParam.getTimeout();
|
|
RshyVo rshyVo = new RshyVo();
|
|
RshyVo rshyVo = new RshyVo();
|
|
PctgkryDTO gkryDTO = new PctgkryDTO();
|
|
PctgkryDTO gkryDTO = new PctgkryDTO();
|
|
@@ -89,10 +90,10 @@ public class RshyJkManagerImpl implements RshyJkManager {
|
|
|
|
|
|
rshyParam.setSfzh(jkmInfo.getId_num());
|
|
rshyParam.setSfzh(jkmInfo.getId_num());
|
|
rshyVo.setSfzh(jkmInfo.getId_num()).setXm(jkmInfo.getUser_name()).setHealthCode(jkmInfo.getColor_code_label()).setPhone(jkmInfo.getPn());
|
|
rshyVo.setSfzh(jkmInfo.getId_num()).setXm(jkmInfo.getUser_name()).setHealthCode(jkmInfo.getColor_code_label()).setPhone(jkmInfo.getPn());
|
|
- int jkmElapsedTime = (int) DateUtil.between(beginDate, DateTime.now(), DateUnit.MS);
|
|
|
|
- System.out.println("健康码接口用时: " + jkmElapsedTime + "毫秒");
|
|
|
|
|
|
+ int jkmUsedTime = (int) DateUtil.between(beginDate, DateTime.now(), DateUnit.MS);
|
|
|
|
+ System.out.println("健康码接口用时: " + jkmUsedTime + "毫秒");
|
|
|
|
|
|
- rshyParam.setTimeout(rshyParam.getTimeout() - jkmElapsedTime - 50);
|
|
|
|
|
|
+ rshyParam.setTimeout(rshyParam.getTimeout() - jkmUsedTime - 300);
|
|
//剩余时间不到10ms,直接返回
|
|
//剩余时间不到10ms,直接返回
|
|
if (rshyParam.getTimeout() <= 10) {
|
|
if (rshyParam.getTimeout() <= 10) {
|
|
return new AsyncResult<>(rshyVo);
|
|
return new AsyncResult<>(rshyVo);
|