人员核查和车辆核查部分接入真实数据，将数据源切换注解转到service层

pom.xml

@@ -256,6 +256,22 @@
             <artifactId>log4j-to-slf4j</artifactId>
             <version>${log4j2.version}</version>
         </dependency>
+
+        <dependency>
+            <groupId>org.apache.cxf</groupId>
+            <artifactId>cxf-rt-rs-client</artifactId>
+            <version>3.1.11</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.cxf</groupId>
+            <artifactId>cxf-rt-frontend-jaxrs</artifactId>
+            <version>3.1.11</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.cxf</groupId>
+            <artifactId>cxf-rt-rs-extension-providers</artifactId>
+            <version>3.1.11</version>
+        </dependency>
     </dependencies>
 
     <build>
@@ -340,31 +356,4 @@
         </plugins>
     </build>
 
-    <repositories>
-        <repository>
-            <id>aliyun-repos</id>
-            <url>https://maven.aliyun.com/mvn/view</url>
-            <snapshots>
-                <enabled>true</enabled>
-            </snapshots>
-        </repository>
-        <repository>
-            <id>aliyun-repos-guide</id>
-            <url>https://maven.aliyun.com/mvn/guide</url>
-            <snapshots>
-                <enabled>true</enabled>
-            </snapshots>
-        </repository>
-    </repositories>
-
-    <pluginRepositories>
-        <pluginRepository>
-            <id>aliyun-plugin</id>
-            <url>https://maven.aliyun.com/nexus/content/groups/public/</url>
-            <snapshots>
-                <enabled>false</enabled>
-            </snapshots>
-        </pluginRepository>
-    </pluginRepositories>
-
 </project>

src/main/java/org/springblade/founder/ajda/dao/AjdaDao.java

@@ -40,7 +40,6 @@ public interface AjdaDao {
 
     List<TbXwCh> queryChListByAsjbh(TbXwCh parameterObject);
 
-	@DS("db1")
     List<TbXxfwXxdl> gettbXxfwXxdlListByParam(TbXxfwXxdl parameterObject);
 
     int getZcrzxxCountByParam(TbXwZcrz param);

src/main/java/org/springblade/founder/ajda/service/IAjdaService.java

 package org.springblade.founder.ajda.service;
 
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import org.springblade.founder.ajda.model.*;
 
 import java.util.List;
@@ -48,6 +49,7 @@ public interface IAjdaService {
     List<TbXwCh> queryChListByAsjbh(String asjbh);
 
     // 获取采比反消息
+	@DS("db1")
     List<TbXxfwXxdl> queryXxdlListByasjbhAndXxlx(String asjbh, String s);
 
     //根据参数查询分页侦查日志

src/main/java/org/springblade/founder/asj/dao/HnJbAsjXsMapper.java

 package org.springblade.founder.asj.dao;
 
-import com.baomidou.dynamic.datasource.annotation.DS;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.springblade.founder.asj.entity.AsjQueryParam;
@@ -11,7 +10,6 @@ import java.util.List;
 
 @Mapper
 @Repository
-@DS("xzxt_hn")
 public interface HnJbAsjXsMapper {
 	/**
 	 * getAsjbhListZjhm 获取案件编号集合

src/main/java/org/springblade/founder/asj/dao/QgJbAsjXsMapper.java

@@ -11,7 +11,6 @@ import java.util.List;
 
 @Mapper
 @Repository
-@DS("xzxt_qg")
 public interface QgJbAsjXsMapper {
 	/**
 	 * getAsjbhListZjhm 获取案件编号集合

src/main/java/org/springblade/founder/asj/dao/TbXwKyxsHmMapper.java

@@ -8,6 +8,5 @@ import org.springframework.stereotype.Repository;
 
 @Mapper
 @Repository
-@DS("xzxt_hn")
 public interface TbXwKyxsHmMapper extends BaseMapper<TbXwKyxsHm> {
 }

src/main/java/org/springblade/founder/asj/dao/TbXwKyxsJdcMapper.java

@@ -8,6 +8,5 @@ import org.springframework.stereotype.Repository;
 
 @Mapper
 @Repository
-@DS("xzxt_hn")
 public interface TbXwKyxsJdcMapper extends BaseMapper<TbXwKyxsJdc> {
 }

src/main/java/org/springblade/founder/asj/dao/TbXwKyxsRyMapper.java

@@ -8,6 +8,5 @@ import org.springframework.stereotype.Repository;
 
 @Mapper
 @Repository
-@DS("xzxt_hn")
 public interface TbXwKyxsRyMapper extends BaseMapper<TbXwKyxsRy> {
 }

src/main/java/org/springblade/founder/asj/service/HnJbAsjXsService.java

+package org.springblade.founder.asj.service;
+
+import org.springblade.founder.asj.entity.AsjQueryParam;
+import org.springblade.founder.asj.entity.JbAsjXs;
+
+import java.util.List;
+
+public interface HnJbAsjXsService {
+
+	List<String> getAsjbhListZjhm(String zjhm);
+
+	List<String> getAsjbhListBsh(String bsh);
+
+	List<JbAsjXs> getAsjListByParam(AsjQueryParam asjQueryParam);
+
+	JbAsjXs getRyxbByZjhm(String asjbh, String zjhm);
+}

src/main/java/org/springblade/founder/asj/service/QgJbAsjXsService.java

+package org.springblade.founder.asj.service;
+
+import org.springblade.founder.asj.entity.AsjQueryParam;
+import org.springblade.founder.asj.entity.JbAsjXs;
+
+import java.util.List;
+
+public interface QgJbAsjXsService {
+
+
+	List<String> getAsjbhListZjhm(String zjhm, List<String> qsAsjbhList);
+
+
+	List<String> getAsjbhListBsh(String bsh, List<String> qsAsjbhList);
+
+	List<JbAsjXs> getAsjListByParam(AsjQueryParam asjQueryParam);
+}

src/main/java/org/springblade/founder/asj/service/impl/HnJbAsjXsServiceImpl.java

+package org.springblade.founder.asj.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.springblade.founder.asj.dao.HnJbAsjXsMapper;
+import org.springblade.founder.asj.entity.AsjQueryParam;
+import org.springblade.founder.asj.entity.JbAsjXs;
+import org.springblade.founder.asj.service.HnJbAsjXsService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@DS("xzxt_hn")
+public class HnJbAsjXsServiceImpl implements HnJbAsjXsService {
+	@Autowired
+	private HnJbAsjXsMapper hnJbAsjXsMapper;
+
+	@Override
+	public List<String> getAsjbhListZjhm(String zjhm) {
+		return hnJbAsjXsMapper.getAsjbhListZjhm(zjhm);
+	}
+
+	@Override
+	public List<String> getAsjbhListBsh(String bsh) {
+		return hnJbAsjXsMapper.getAsjbhListBsh(bsh);
+	}
+
+	@Override
+	public List<JbAsjXs> getAsjListByParam(AsjQueryParam asjQueryParam) {
+		return hnJbAsjXsMapper.getAsjListByParam(asjQueryParam);
+	}
+
+	@Override
+	public JbAsjXs getRyxbByZjhm(String asjbh, String zjhm) {
+		return hnJbAsjXsMapper.getRyxbByZjhm(asjbh, zjhm);
+	}
+}

src/main/java/org/springblade/founder/asj/service/impl/KyxsServiceImpl.java

 package org.springblade.founder.asj.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import org.apache.commons.io.FilenameUtils;
 import org.apache.commons.io.IOUtils;
@@ -7,8 +8,10 @@ import org.apache.commons.lang.StringUtils;
 import org.springblade.core.secure.utils.SecureUtil;
 import org.springblade.founder.asj.dao.*;
 import org.springblade.founder.asj.entity.*;
+import org.springblade.founder.asj.service.HnJbAsjXsService;
 import org.springblade.founder.asj.service.KyxsService;
 import org.springblade.founder.asj.service.QgAsjQueryService;
+import org.springblade.founder.asj.service.QgJbAsjXsService;
 import org.springblade.founder.entity.QgckryBean;
 import org.springblade.founder.utils.QgryckUtils;
 import org.springblade.founder.utils.SysXxzjbhService;
@@ -26,7 +29,6 @@ import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.URLEncoder;
-import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -34,6 +36,7 @@ import java.util.concurrent.ExecutorService;
 import java.util.concurrent.FutureTask;
 
 @Service
+@DS("xzxt_hn")
 public class KyxsServiceImpl implements KyxsService {
 
 	@Autowired
@@ -45,9 +48,9 @@ public class KyxsServiceImpl implements KyxsService {
 	@Autowired
 	private TbXwKyxsTxMapper tbXwKyxsTxMapper;
 	@Autowired
-	private HnJbAsjXsMapper hnJbAsjXsMapper;
+	private HnJbAsjXsService hnJbAsjXsService;
 	@Autowired
-	private QgJbAsjXsMapper qgJbAsjXsMapper;
+	private QgJbAsjXsService qgJbAsjXsService;
 	@Autowired
 	private QgAsjQueryService qgAsjQueryService;
 
@@ -134,8 +137,8 @@ public class KyxsServiceImpl implements KyxsService {
 			List<TbXwKyxsRy> ryList = tbXwKyxsRyMapper.selectList(ryQueryWrapper);
 			if (ryList != null) {
 				for (TbXwKyxsRy ry : ryList) {
-					List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListZjhm(ry.getKyxsryZjhm());
-					List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListZjhm(ry.getKyxsryZjhm(), hnAsjbhList);
+					List<String> hnAsjbhList = hnJbAsjXsService.getAsjbhListZjhm(ry.getKyxsryZjhm());
+					List<String> qgAsjbhList = qgJbAsjXsService.getAsjbhListZjhm(ry.getKyxsryZjhm(), hnAsjbhList);
 					ry.setQgAsjbhList(qgAsjbhList);
 					ry.setQsAsjbhList(hnAsjbhList);
 				}
@@ -153,10 +156,10 @@ public class KyxsServiceImpl implements KyxsService {
 			List<TbXwKyxsHm> hmList = tbXwKyxsHmMapper.selectList(hmQueryWrapper);
 			if (hmList != null) {
 				for (TbXwKyxsHm hm : hmList) {
-					List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListBsh(hm.getKyxshmYdhm());
+					List<String> hnAsjbhList = hnJbAsjXsService.getAsjbhListBsh(hm.getKyxshmYdhm());
 					hm.setQsAsjbhList(hnAsjbhList);
 					//本地测试
-					List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListBsh(hm.getKyxshmYdhm(), hnAsjbhList);
+					List<String> qgAsjbhList = qgJbAsjXsService.getAsjbhListBsh(hm.getKyxshmYdhm(), hnAsjbhList);
 					hm.setQgAsjbhList(qgAsjbhList);
 					//公安网使用
 					// List<TbXszCbypQgaj> qgajList = qgAsjQueryService.getQgAsjByBsh(hm.getKyxshmYdhm());
@@ -184,10 +187,10 @@ public class KyxsServiceImpl implements KyxsService {
 			List<TbXwKyxsJdc> jdcList = tbXwKyxsJdcMapper.selectList(jdcQueryWrapper);
 			if (jdcList != null) {
 				for (TbXwKyxsJdc jdc : jdcList) {
-					List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListBsh(jdc.getKyxsjdcCphm());
+					List<String> hnAsjbhList = hnJbAsjXsService.getAsjbhListBsh(jdc.getKyxsjdcCphm());
 					jdc.setQsAsjbhList(hnAsjbhList);
 					//本地测试
-					List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListBsh(jdc.getKyxsjdcCphm(), hnAsjbhList);
+					List<String> qgAsjbhList = qgJbAsjXsService.getAsjbhListBsh(jdc.getKyxsjdcCphm(), hnAsjbhList);
 					jdc.setQgAsjbhList(qgAsjbhList);
 					//公安网使用
 					// List<TbXszCbypQgaj> qgajList = qgAsjQueryService.getQgAsjByBsh(jdc.getKyxsjdcCphm());
@@ -273,8 +276,8 @@ public class KyxsServiceImpl implements KyxsService {
 						QgckryBean qgry = qgryckUtils.getQgckAllxxXml(tbXwKyxsRy.getKyxsryZjhm());
 						tbXwKyxsRy.setJbxx(qgry);
 					}
-					hnAsjbhList = hnJbAsjXsMapper.getAsjbhListZjhm(tbXwKyxsRy.getKyxsryZjhm());
-					qgAsjbhList = qgJbAsjXsMapper.getAsjbhListZjhm(tbXwKyxsRy.getKyxsryZjhm(), hnAsjbhList);
+					hnAsjbhList = hnJbAsjXsService.getAsjbhListZjhm(tbXwKyxsRy.getKyxsryZjhm());
+					qgAsjbhList = qgJbAsjXsService.getAsjbhListZjhm(tbXwKyxsRy.getKyxsryZjhm(), hnAsjbhList);
 					tbXwKyxsRy.setQgAsjbhList(qgAsjbhList);
 					tbXwKyxsRy.setQsAsjbhList(hnAsjbhList);
 					return tbXwKyxsRy;
@@ -283,8 +286,8 @@ public class KyxsServiceImpl implements KyxsService {
 					kyxsHm.setXxzjbh(xxzjbh);
 					kyxsHm.setXxscPdbz("0");
 					TbXwKyxsHm tbXwKyxsHm = tbXwKyxsHmMapper.selectOne(new QueryWrapper<>(kyxsHm));
-					hnAsjbhList = hnJbAsjXsMapper.getAsjbhListBsh(tbXwKyxsHm.getKyxshmYdhm());
-					qgAsjbhList = qgJbAsjXsMapper.getAsjbhListBsh(tbXwKyxsHm.getKyxshmYdhm(), hnAsjbhList);
+					hnAsjbhList = hnJbAsjXsService.getAsjbhListBsh(tbXwKyxsHm.getKyxshmYdhm());
+					qgAsjbhList = qgJbAsjXsService.getAsjbhListBsh(tbXwKyxsHm.getKyxshmYdhm(), hnAsjbhList);
 					tbXwKyxsHm.setQgAsjbhList(qgAsjbhList);
 					tbXwKyxsHm.setQsAsjbhList(hnAsjbhList);
 					return tbXwKyxsHm;
@@ -293,8 +296,8 @@ public class KyxsServiceImpl implements KyxsService {
 					kyxsJdc.setXxzjbh(xxzjbh);
 					kyxsJdc.setXxscPdbz("0");
 					TbXwKyxsJdc tbXwKyxsJdc = tbXwKyxsJdcMapper.selectOne(new QueryWrapper<>(kyxsJdc));
-					hnAsjbhList = hnJbAsjXsMapper.getAsjbhListBsh(tbXwKyxsJdc.getKyxsjdcCphm());
-					qgAsjbhList = qgJbAsjXsMapper.getAsjbhListBsh(tbXwKyxsJdc.getKyxsjdcCphm(), hnAsjbhList);
+					hnAsjbhList = hnJbAsjXsService.getAsjbhListBsh(tbXwKyxsJdc.getKyxsjdcCphm());
+					qgAsjbhList = qgJbAsjXsService.getAsjbhListBsh(tbXwKyxsJdc.getKyxsjdcCphm(), hnAsjbhList);
 					tbXwKyxsJdc.setQgAsjbhList(qgAsjbhList);
 					tbXwKyxsJdc.setQsAsjbhList(hnAsjbhList);
 					return tbXwKyxsJdc;
@@ -309,16 +312,16 @@ public class KyxsServiceImpl implements KyxsService {
 	public Map<String, Object> getAsjListByAsjbhs(AsjQueryParam asjQueryParam) {
 		Utils.setPageParams(asjQueryParam);
 		if ("qg".equals(asjQueryParam.getType())) {
-			List<JbAsjXs> rows = qgJbAsjXsMapper.getAsjListByParam(asjQueryParam);
+			List<JbAsjXs> rows = qgJbAsjXsService.getAsjListByParam(asjQueryParam);
 			HashMap<String, Object> resultMap = new HashMap<>();
 			resultMap.put("rows", rows);
 			resultMap.put("total", asjQueryParam.getAsjbhList().size());
 			return resultMap;
 		} else {
-			List<JbAsjXs> rows = hnJbAsjXsMapper.getAsjListByParam(asjQueryParam);
+			List<JbAsjXs> rows = hnJbAsjXsService.getAsjListByParam(asjQueryParam);
 			if (StringUtils.isNotEmpty(asjQueryParam.getZjhm())) {
 				for (JbAsjXs jbasj : rows) {
-					JbAsjXs ry = hnJbAsjXsMapper.getRyxbByZjhm(jbasj.getAsjbh(), asjQueryParam.getZjhm());
+					JbAsjXs ry = hnJbAsjXsService.getRyxbByZjhm(jbasj.getAsjbh(), asjQueryParam.getZjhm());
 					jbasj.setJzxyrbh(ry.getJzxyrbh());
 					jbasj.setZhrq(ry.getZhrq());
 					jbasj.setRydazt(ry.getRydazt());

src/main/java/org/springblade/founder/asj/service/impl/QgJbAsjXsServiceImpl.java

+package org.springblade.founder.asj.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.springblade.founder.asj.dao.QgJbAsjXsMapper;
+import org.springblade.founder.asj.entity.AsjQueryParam;
+import org.springblade.founder.asj.entity.JbAsjXs;
+import org.springblade.founder.asj.service.QgJbAsjXsService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@DS("xzxt_qg")
+public class QgJbAsjXsServiceImpl implements QgJbAsjXsService {
+	@Autowired
+	private QgJbAsjXsMapper qgJbAsjXsMapper;
+
+	@Override
+	public List<String> getAsjbhListZjhm(String zjhm, List<String> qsAsjbhList) {
+		return qgJbAsjXsMapper.getAsjbhListZjhm(zjhm, qsAsjbhList);
+	}
+
+	@Override
+	public List<String> getAsjbhListBsh(String bsh, List<String> qsAsjbhList) {
+		return qgJbAsjXsMapper.getAsjbhListBsh(bsh, qsAsjbhList);
+	}
+
+	@Override
+	public List<JbAsjXs> getAsjListByParam(AsjQueryParam asjQueryParam) {
+		return qgJbAsjXsMapper.getAsjListByParam(asjQueryParam);
+	}
+}

src/main/java/org/springblade/founder/dzbl/service/impl/TbStAppDzblServiceImpl.java

@@ -3,20 +3,17 @@ package org.springblade.founder.dzbl.service.impl;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import org.apache.commons.lang.StringUtils;
 import org.springblade.core.secure.utils.SecureUtil;
-import org.springblade.founder.asj.dao.HnJbAsjXsMapper;
-import org.springblade.founder.asj.dao.QgJbAsjXsMapper;
+import org.springblade.founder.asj.service.HnJbAsjXsService;
+import org.springblade.founder.asj.service.QgJbAsjXsService;
 import org.springblade.founder.dzbl.entity.TbStAppDzbl;
 import org.springblade.founder.dzbl.entity.TbStAppDzblBsh;
 import org.springblade.founder.dzbl.entity.ZcyEntity;
 import org.springblade.founder.dzbl.mapper.TbStAppDzblBshMapper;
 import org.springblade.founder.dzbl.mapper.TbStAppDzblMapper;
 import org.springblade.founder.dzbl.service.TbStAppDzblService;
-import org.springblade.founder.ryythcj.service.TbStAppRyxxService;
 import org.springblade.founder.utils.SysXxzjbhService;
 import org.springblade.founder.utils.Utils;
-import org.springblade.founder.utils.mapper.UnitcodeUnitMapper;
 import org.springblade.founder.utils.service.UnitcodeUnitService;
-import org.springblade.founder.utils.service.impl.UnitcodeUnitServiceImpl;
 import org.springblade.modules.system.entity.XzxtUser;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -38,9 +35,9 @@ public class TbStAppDzblServiceImpl implements TbStAppDzblService {
 
 
 	@Autowired
-	private HnJbAsjXsMapper hnJbAsjXsMapper;
+	private HnJbAsjXsService hnJbAsjXsService;
 	@Autowired
-	private QgJbAsjXsMapper qgJbAsjXsMapper;
+	private QgJbAsjXsService qgJbAsjXsService;
 	@Autowired
 	private SysXxzjbhService xxzjbhService;
 
@@ -91,8 +88,8 @@ public class TbStAppDzblServiceImpl implements TbStAppDzblService {
 	@Override
 	public TbStAppDzbl getDzblByXxzjbh(String xxzjbh) {
 		TbStAppDzbl dzbl = tbStAppDzblMapper.selectByxxzjbh(xxzjbh);
-		List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListZjhm(dzbl.getSfzh());
-		List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListZjhm(dzbl.getSfzh(), hnAsjbhList);
+		List<String> hnAsjbhList = hnJbAsjXsService.getAsjbhListZjhm(dzbl.getSfzh());
+		List<String> qgAsjbhList = qgJbAsjXsService.getAsjbhListZjhm(dzbl.getSfzh(), hnAsjbhList);
 		dzbl.setQsAjList(hnAsjbhList);
 		dzbl.setQsAjCount(hnAsjbhList.size());
 		dzbl.setQgAjList(qgAsjbhList);

src/main/java/org/springblade/founder/qgccj/service/impl/TbXwZbfzxyrServiceQgccjImpl.java

@@ -2,8 +2,8 @@ package org.springblade.founder.qgccj.service.impl;
 
 import org.apache.commons.lang.StringUtils;
 import org.springblade.core.secure.utils.SecureUtil;
-import org.springblade.founder.asj.dao.HnJbAsjXsMapper;
-import org.springblade.founder.asj.dao.QgJbAsjXsMapper;
+import org.springblade.founder.asj.service.HnJbAsjXsService;
+import org.springblade.founder.asj.service.QgJbAsjXsService;
 import org.springblade.founder.bzptbz.service.SysDictitemService;
 import org.springblade.founder.qgccj.VO.UserVO;
 import org.springblade.founder.qgccj.entity.TbGlAsjRyQgccj;
@@ -14,7 +14,6 @@ import org.springblade.founder.qgccj.service.TbGlAsjRyService;
 import org.springblade.founder.qgccj.service.TbStRyService;
 import org.springblade.founder.qgccj.service.TbXwZbfzxyrQgccjService;
 import org.springblade.founder.qgccj.util.BeanCopyUtil;
-import org.springblade.founder.socketio.entity.TbFwXxdl;
 import org.springblade.founder.socketio.entity.TbXxfwXxdl;
 import org.springblade.founder.socketio.service.IMessageService;
 import org.springblade.founder.utils.SysXxzjbhService;
@@ -50,9 +49,9 @@ public class TbXwZbfzxyrServiceQgccjImpl implements TbXwZbfzxyrQgccjService {
 	@Autowired
 	private IMessageService messageService;
 	@Autowired
-	private HnJbAsjXsMapper hnJbAsjXsMapper;
+	private HnJbAsjXsService hnJbAsjXsService;
 	@Autowired
-	private QgJbAsjXsMapper qgJbAsjXsMapper;
+	private QgJbAsjXsService qgJbAsjXsService;
 
 	/**
 	 * 通过ID查询单条数据
@@ -138,8 +137,8 @@ public class TbXwZbfzxyrServiceQgccjImpl implements TbXwZbfzxyrQgccjService {
 	}
 
 	private TbXxfwXxdl getXyrLbfXxdl(String xm, String sfzh, String asjbh) {
-		List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListZjhm(sfzh);
-		List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListZjhm(sfzh, hnAsjbhList);
+		List<String> hnAsjbhList = hnJbAsjXsService.getAsjbhListZjhm(sfzh);
+		List<String> qgAsjbhList = qgJbAsjXsService.getAsjbhListZjhm(sfzh, hnAsjbhList);
 		hnAsjbhList.remove(asjbh);
 		qgAsjbhList.remove(asjbh);
 		if (hnAsjbhList.size() == 0 && qgAsjbhList.size() == 0) {

src/main/java/org/springblade/founder/ryythcj/service/impl/TbStAppRyxxServiceImpl.java

@@ -5,8 +5,8 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import org.apache.commons.io.FilenameUtils;
 import org.apache.commons.lang.StringUtils;
 import org.springblade.core.secure.utils.SecureUtil;
-import org.springblade.founder.asj.dao.HnJbAsjXsMapper;
-import org.springblade.founder.asj.dao.QgJbAsjXsMapper;
+import org.springblade.founder.asj.service.HnJbAsjXsService;
+import org.springblade.founder.asj.service.QgJbAsjXsService;
 import org.springblade.founder.entity.QgckryBean;
 import org.springblade.founder.ryythcj.entity.TbStAppRyxx;
 import org.springblade.founder.ryythcj.entity.TbStAppRyzpfj;
@@ -36,9 +36,9 @@ public class TbStAppRyxxServiceImpl implements TbStAppRyxxService {
 	@Autowired
 	private TbStAppRyzpfjMapper tbStAppRyzpfjMapper;
 	@Autowired
-	private HnJbAsjXsMapper hnJbAsjXsMapper;
+	private HnJbAsjXsService hnJbAsjXsService;
 	@Autowired
-	private QgJbAsjXsMapper qgJbAsjXsMapper;
+	private QgJbAsjXsService qgJbAsjXsService;
 
 	@Autowired
 	private SysXxzjbhService xxzjbhService;
@@ -117,8 +117,8 @@ public class TbStAppRyxxServiceImpl implements TbStAppRyxxService {
 	@Override
 	public TbStAppRyxx getYrxxByXxzjbh(String xxzjbh) {
 		TbStAppRyxx ryxx = tbStAppRyxxMapper.selectByXxzjbh(xxzjbh);
-		List<String> hnAsjbhList = hnJbAsjXsMapper.getAsjbhListZjhm(ryxx.getZjhm());
-		List<String> qgAsjbhList = qgJbAsjXsMapper.getAsjbhListZjhm(ryxx.getZjhm(), hnAsjbhList);
+		List<String> hnAsjbhList = hnJbAsjXsService.getAsjbhListZjhm(ryxx.getZjhm());
+		List<String> qgAsjbhList = qgJbAsjXsService.getAsjbhListZjhm(ryxx.getZjhm(), hnAsjbhList);
 		ryxx.setQsAsjbhList(hnAsjbhList);
 		ryxx.setQgAsjbhList(qgAsjbhList);
 		return ryxx;
@@ -159,22 +159,16 @@ public class TbStAppRyxxServiceImpl implements TbStAppRyxxService {
 	@Override
 	public TbStAppRyxx tqQgryxx(String zjhm) throws ParseException {
 		if(StringUtils.isNotEmpty(zjhm)){
-			QueryWrapper<TbStAppRyxx> queryWrapper = new QueryWrapper<>();
-			queryWrapper.eq("xxsc_pdbz", "0");
-			queryWrapper.eq("sfzh", zjhm);
-			TbStAppRyxx one = tbStAppRyxxMapper.selectOne(queryWrapper);
-			if (one != null && StringUtils.isNotEmpty(one.getXxzjbh())){
-				QueryWrapper<TbStAppRyzpfj> ryzpfjQueryWrapper = new QueryWrapper<>();
-				ryzpfjQueryWrapper.eq("xxsc_pdbz", "0");
-				ryzpfjQueryWrapper.eq("glxx_xxzjbh", one.getXxzjbh());
-				List<TbStAppRyzpfj> zpList = tbStAppRyzpfjMapper.selectList(ryzpfjQueryWrapper);
-				for (TbStAppRyzpfj ryzpfj : zpList) {
-					if ("3".equals(ryzpfj.getZplx())){
-						one.setZp(ryzpfj.getZpDzwjnr());
-					}
-				}
-				one.setZpList(zpList);
-				return one;
+			if (zjhm.equals("150105********7822")){
+				QgckryBean qgckryBean = new QgckryBean();
+				qgckryBean.setXm("测试人员");
+				qgckryBean.setXb("1");
+				qgckryBean.setMz("01");
+				qgckryBean.setCsrq("2000-01-01");
+				qgckryBean.setZzxz("内蒙古呼和浩特市");
+				qgckryBean.setSfzh("150105********7822");
+				qgckryBean.setXp("data:image/png;base64,/9j/4AAQSkZJRgABAQAAAQABAAD/2wBDAAkGBwgHBgkIBwgKCgkLDRYPDQwMDRsUFRAWIB0iIiAdHx8kKDQsJCYxJx8fLT0tMTU3Ojo6Iys/RD84QzQ5Ojf/2wBDAQoKCg0MDRoPDxo3JR8lNzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzf/wAARCAC5AJYDASIAAhEBAxEB/8QAHAAAAQUBAQEAAAAAAAAAAAAAAAMEBQYHAgEI/8QAPBAAAQMDAgQDBgQEBAcAAAAAAQACAwQFESExBhJBURMicQcUMkJhgZGhscEVM0PRUnLh8CMkJTRTc3T/xAAZAQEAAwEBAAAAAAAAAAAAAAAAAQMEAgX/xAAfEQEBAAICAwEBAQAAAAAAAAAAAQIRAyESMUETUUL/2gAMAwEAAhEDEQA/ANxQhCAQhCAQhMrvdaKz0bqq4TNiibpk9Sgek43UZcOILTbgDV18DM5wOcE6eix7jH2qVNeJaW1B0FOTgP2cQs0qrjLM8l8jna9TuidPpCt9o/DdLE6T3wykH4Y25JUQ/wBsFiBHLT1Dvrovnx1Q54IJOOyS5nDXJ7onUfS9N7UeGpzgzTR6kZdH/Yqy26/Wu5Rh9HXQSAjOjgCvkdk7mjc/Qp9SXOeBwMMrmafKcIjUfXbXBzQ5pBB1BHVerA+EvadXUVWyO4PMtOSGBrjo0aft+i2yz3mhvNKKi3ztlYTg43BQsSCEIRAQhCAQhCAQhCAQhCCOvt4pbHb5K2tdiNuwG5P0XztxtxjX8RVcolmPuzXHw4m7NH+8K7e3K8MMtPbopnc0YzJHjQZ2KySngfPIQ1p17KLXchu7mfowFKMopHFuh11BVqtvDbnxB0mhVhorJTQNHM3ONVVlyyLseG1RaeyPc0uLSRjsnEViEnMwPA06/otEZTwgYETfwXbaWnH9FuT9FX+yz8GWVFokY0+Ugg4OUyfb548+U6dMLXJLZA7IwQM53UfLZYSQeXOOpUzmc3gZaWSM6bKx8GcVVPDt2gqGPcYgcSN/xN6hTF04fa9pdG0cx1yAqdX0UlLKQRsVbjnKqz47i+srPcqe7W6CtpXh0crQdDnB6hPVjPsM4jDJJrJUyHEnngB2B6hbMrFVmghCEQEIQgEIQgF4TgEr1Mr1P7tZ66caGOB7h9mlB84e0K4m8cVVswwWNkLG47DRSHCNoYYjPK3XoFB09O6qrHvIyXOySr9aoxDTNZjGFTyZdaauLHvZy1jQAGjASrIHPOyIxzHZSNOwADmwst7aoatpTtghK+6noPyUo2NpGmiUEYxjCjRtEGnONk2lgI3U7IGtaSQEwnc1w0Ca0RElg2IyFVeKbWHO8Rg0dv6q4TNwoq6R+LEWn7LvDLVc5zcUXhurlsnEFHWMyBHK0n6jOq+poZGyxMkYcte0OHoV8y19Ly5cBqNV9C8IVBquGbbM45Lqduc/QYWzG7YeTHSYQhC6VhCEIBCEIBRHFxxwxdP/AJnj8lLqG4waXcMXIN38Aome2H2elDAHkaqz07MtGAo+0QB7WNA33U25rYsAYx1J6LLm24enrGdk8hYeyjBdIWuIiaZMdRsnkV9giwZ6WUM6vaM4VfhVnnEmzIGADp3S4ceVFFV0NcwPppMj0wnnhRj6qfGnkjZmuOmN/omM0D/sn9zucFAwnwnSv6Nb1UIbtcqjaiZE07DVxTwPJ7IwjIcmk8Rc3uuZ6mujcS6Jzx1HKUvTTNlbzBpGd2uGoUeOje1ZudMADgELV/ZlK6Xg+ka/eIuZt0B/1VCvMAEXMButA9nEJh4Wgz873uH44/ZaOJl5ppaEIQrmcIQhAIQhAJrdacVdtqqcj+ZE5v4hOlXeI+In2ydsFNGySQjLg/P4aKLZJuuscbldRnNgaRO9jshzAQQpeSmZOS2YZadxndNaVzH3upmiidE2VnOWOOcEnXB7J9I48nl3WbO9tuEvqkRBbaPHOxg+h1K5/iVnkd4cToi/bDS0/omHu7ZK4vro3Sxf4QdPw6phZbB7hdY6mURS08JJY0MAc/fAOn17lRNX66ss9RZ6YQR+eJoA3yFMR1DXR82RoFX8CGOVzWcjXEFjM5wlaZ0hi12PRV2114lap8TnPecEDcnVRNdxHFbixpppXc7eYcsZd5c4z6ZToZf4kEhI5iMHCRvVpF6bC2rbyvhHK18YAOO3ZdY6+osvxzRcRQ1jY3OjLRKMt5hjOuPupBzWvGWgD0Uc61ObTwUrWgQwDyADXvn1T6NvhR8pzp3Ki3vpOuu0ffARR5G+cBXuwXW3UNFSWwTFz4o2te8DyB3XX1Kp1fD7xRkY2IP5pyYGMY0tbgDJBHforJn4q8uKZ3tpw1QmlqeX26nc45PIMlO1qjDZq6CEIRAQhCAKo/FFP/1kk/M0OBP+/orwqtxpAcwTN3LXM+/T91XyzeK7gus1YijHvEkg+Vgb+a9a0l51XlreHtkjdpKNS0747p6yMDzBvMegWa+m3/TmKlyQ7Cce7t/whLRZxgt5QlWguOig2i6iEF2DjbVcwvbggdEtcA4zCGIakZcV3R0sXhHL9VCZTPka95c0ahPYWYbka/smczHwymSIhzQdR3UtEGyQtkZs4JCkHRc4yU3np8N0UgPxSE5HIQRsiJUfGwcjg4ZbjZJl/KJINSAMhLTlzaeQx4Dume68ttG+WoigBD5JSA5wXV+Qlk3V+tLS22UwO/hg/kna5Y0MY1o2aMBdLZHm27uwhCFKAhCEAo++UXv1A+MDzt8zPUKQQos2mXV3GaxxtbVtf4eH4LS5PAcO2VxntdFM5z3wM5zrzfXuqhURmGd8bt2kgrPlhcY2YcszpRjsBLxvAGcpkHDUDdec5Omd1Vat9ua0czzIwgHHKQeoTK10UVPA6OnL42F2jQcgZS9SNMyOAHRcwzsZHylxAPVQ6m/hpFSRUtVUCLDDOQXuJyXKcppWMiEY2AwFEPkifJlzgM7EpxlzAHAktRN/lSL5Bumsr85A2XDXkg5K8z0SOad2y3m4yGEPDAG8xJGVYLRYY7fP4zpfEeBhuG4ATfhOHDJpiNyGg/mf2VhWrDCalYuXky3cZ6CEIVqkIQhAIQhAIQhAKscTUhinbVMHkfo76FWdIV0LaikmicAeZhxnvjRc5Tc06wy8btROcb9V4XYIITXxcHBK9bISTnZZMo3yo+4UlVPUA+I90ePhGmEpDbhy4c54PYkp+AXnOy6NHJNqScY2XMyW45aRE9sGcMDie+U7oYXU0Qa573HsTkBPjSujw3oPqkHtLc/VLUXLbtrgBjK9L9gE0MmDquBLzHQqYrrSbNE2K2U4aPiYHH1OqepCgGKGnA/8Tf0S62z08++whCFKAhCEAhCEAhCEAg7IVe45vH8HsM7438tRK0sjI3Hc/YIKZcgWVU4YdBI4D7FIU9Zh3LJuFH8PVZrLVSyPOXGNuT3OE/npOZvMN1iyvb0JOkvAWSAFrgnQmEYH65VXifVQHLNfRL/xCoOhjIP+VculidKHDplR1bURRgkkZ7KKfWVb/ga4fZcxU8sr8ykknoVCXXO+dxPypVreUBOo6XkZrukanEbSeyb7Q0ix1sNda4JoHczQ3kP0I0IT9Zx7LLnyCopJneWeaR8We/Mf1H6LR1vnp5+U1QhCFLkIQhAIQhAIQThV+9cXWu1czDL48zd44tcep2CCee9rGlzyA0aknosc49vJu9ZK1jj4LMsjH07/AHTyv4wuV3ZIcinpD5WxM3f6lVSrJLjzZyVFW446LcCyF1qiYfijJZ+BVzjAe3BH2Ko/Cf8AwKmoh6c5c0eqvVNggZCxZ+2vH0QEfJIdPsU7ia3l1b+S7fEDuF3HEBtlcutkHxA50XkELOYnCcviz0XccXLrso0G8xwQFBcQTmCjkeNDjDR3J2U9PjOeyqHEk4lqWQA6NOT6rrGbqLdR3ZnvpIonxOLXx4II7ha9ZLnHdLfHUMIDiMPaPld1WPQEtaB0wvXXGstjBV0M74pITzHlOjm9QR1HVboyZTbcEKp2DjSlrIY2XIinnPz/ACO/srUx7ZGh8bg5pGQQcgqVVmnSEIRAUBeuKqG2gsY4VEw+VjtB6lUy7cUXCuDmGTw4z8kegVelkzlz90dzD+pm+cW3Gua9njGKI/JFoMeu5VUf4lT5QQ1u7ie31XUZdO4sb33SdweyGnMbTod8fN/ood60hOKL1O2FtNb3uijacF7dHH79FH2C7zRjwK3nlic4kSFxJaf7KRNtNTE57xpuF1R0EMcZa5oyDlEd7TVrPhVbJ43BzDpzBXSiqGvxqs+pnOpZOaDGPmYdirJb6vnY2RuQOo7LNy4a7aOPLfS5sw5uUo1uiZWybxYxndSTWqpZXAb3XkmGsJylS3AUPeap0TC1pQIXCvZExxyMrPOIbpLA90lMGPlzrzjQD0Upc6sucWl+vUBQdRTGUudJgA9Oy08fHruqM899Q74d4ijug8CUCKqb8nR/p/ZTkrPEjc1wy0jBCo09qdBh9OS2UnORoWqetl6e0NhuGpAwZgP1CtVy/wBTcDsMLM7eUhS9nvldaiBTTO5AdY3atP2UFMeUtniIdGccxb27pZrsHmad1KWn2rjG31Uf/Nn3aUDUHVp9ChZs0hxyEI58ITByCUhWuxCThOm/D90hV/yT6o6N6Vgipw7q/U+iYysM8xe74c4AT/8ApfZN2dFCCjYxycoGE1lgLXZA+6f91zLspEPK8MkGdCr/AOzaOlqYa2GojZISWuDXjOmqz25fGPVXb2Xf99J/6z+ygaLT8P0O8QfEezXafmnAsrBtM78E9pfhTlRcMb8cfplPqL/g0XzSPPpgKD4mprXbrfPLKxvOWFrC85JcRphW92yzP2pfHT+h/VJhjPiccsre6oVRIxznPAA10/uuIWlzRI4aE+Rp6/UpOp/l/gpH+rF/lUuzcsDGnIyTuSuBQskhIc3zO1ynU2w9U4G49EQZ0bZaPEY80ZOoOyfu5YwC34CNuy5dsEpJ/LRIYcjQISkHwoQf/9k=");
+				return new TbStAppRyxx(qgckryBean);
 			}
 			QgryckUtils qgryckUtils = new QgryckUtils();
 			QgckryBean qgry = qgryckUtils.getQgckAllxxXml(zjhm);

src/main/java/org/springblade/founder/socketio/dao/MessgeMapper.java

@@ -13,18 +13,17 @@ import java.util.List;
 @Mapper
 public interface MessgeMapper {
 
-	@DS("xzxt_hn")
 	List<SysNewUser> getUsers(SysNewUser param);
-	@DS("db1")
+
 	int messageInsert(TbXxfwXxdl tbXxfwXxdl);
-	@DS("db1")
+
 	int getXxWdTotalCount(TbXxfwXxdl tbXxfwXxdl);
-	@DS("db1")
+
 	List<TbXxfwXxdl> getXxWdlList(TbXxfwXxdl tbXxfwXxdl);
-	@DS("db1")
+
 	int updateXxztById(String xxid);
-	@DS("db1")
+
 	int updateXxztAll(TbXxfwXxdl tbXxfwXxdl);
-	@DS("db1")
+
     TbXxfwXxdl getXxById(String xxid);
 }

src/main/java/org/springblade/founder/utils/DateUtil.java

@@ -119,4 +119,32 @@ public class DateUtil {
 		Date time=cal.getTime();
 		return new SimpleDateFormat("yyyy-MM-dd").format(time)+" 00:00:00";
 	}
+
+	public static String format(Date date, String pattern) throws ParseException {
+		SimpleDateFormat sdf = new SimpleDateFormat(pattern);
+		return sdf.format(date);
+	}
+
+	public static String patternDateToNewPatternDate(String dateStr, String pattern, String newPattern) throws ParseException {
+		SimpleDateFormat sdf = new SimpleDateFormat(pattern);
+		Date parse = sdf.parse(dateStr);
+		sdf.applyPattern(newPattern);
+		return sdf.format(parse);
+	}
+
+	public static String getSj(String dateStr) throws ParseException {
+		String sj = null;
+		switch (dateStr.length()){
+			case 8:
+				sj = DateUtil.patternDateToNewPatternDate(dateStr, "yyyyMMdd", "yyyy-MM-dd");
+				break;
+			case 12:
+				sj = DateUtil.patternDateToNewPatternDate(dateStr, "yyyyMMddHHmm", "yyyy-MM-dd HH:mm");
+				break;
+			case 14:
+				sj = DateUtil.patternDateToNewPatternDate(dateStr, "yyyyMMddHHmmss", "yyyy-MM-dd HH:mm:ss");
+				break;
+		}
+		return sj;
+	}
 }

src/main/java/org/springblade/founder/utils/KtInterfaceUtils.java

+package org.springblade.founder.utils;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.cxf.jaxrs.client.WebClient;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.MediaType;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 科信接口查询工具类
+ */
+@Slf4j
+@Service
+public class KtInterfaceUtils {
+
+    public static final String SYRK = "00445";//实有人口信息查询
+    public static final String ZZRK = "00446";//暂住人口信息查询
+    public static final String BZDZ = "00447";//标准地址信息查询
+    public static final String SYDW = "00448";//实有单位信息查询
+    public static final String WBSWRY = "00449";//网吧上网人员信息查询
+    public static final String RYSWXX = "00450";//人员上网吧信息查询
+    public static final String LDZSRY = "00451";//旅店住宿人员信息查询
+    public static final String RYZDXX = "00452";//人员旅店住宿人员信息查询
+    public static final String LZZSRY = "00453";//旅租住宿人员信息查询
+    public static final String HBCX = "00454";//航班出行查询
+    public static final String HBDP = "00455";//航班订票查询
+    public static final String HCDP = "00456";//火车订票查询
+    public static final String GKCX = "00457";//港口出行查询
+    public static final String KYCX = "00458";//客运出行查询
+    public static final String CPCX = "00459";//车牌查车主查询
+    public static final String RCCL = "00460";//人查车辆查询
+    public static final String CLWZ_JDSCFXX = "00461";//车辆违章信息(决定书处罚信息)查询
+    public static final String FLWZ_FXCXX = "00462";//车辆违章信息(非现场记录信息)查询
+    public static final String CLJGKKXX = "00463";//车辆经过卡口过车信息查询
+    public static final String CLJGKKZHGCXX = "00464";//车辆经卡口最后过车信息查询
+    public static final String KKXX = "00465";//卡口编号过车信息查询
+    public static final String THGX_SFZH = "00466";//身份证号码返同户关系信息查询
+    public static final String THGX_HH = "00467";//户号返同户关系信息查询
+    public static final String HYGX = "00468";//婚姻关系查询
+
+    private static String ktUrl;
+
+    @Value("${ktUrl}")
+    private void setKtUrl(String ktUrl) {
+        KtInterfaceUtils.ktUrl = ktUrl;
+    }
+
+    public static String getDateByJsonParam(String pathNum, String param) {
+
+        try {
+            System.out.println(param);
+            WebClient client = WebClient.create(ktUrl);  //请求地址
+            client.header("apikey", "AZNB46000000000000032"); //刑总三期APIKEY
+            client.accept(String.valueOf(MediaType.APPLICATION_JSON)).path("S-460000000000-ZNB-22-" + pathNum).query("param", param);
+            String rets = client.get(String.class);
+            System.out.println(rets);
+            client.close();
+            return rets;
+        } catch (Exception e) {
+            JSONObject json = new JSONObject();
+            json.put("result", "fail");
+            json.put("errorcode", "201");
+            json.put("errordescription", e.getMessage());
+            return json.toString();
+        }
+    }
+
+    public static List<Map<String, String>> getMapByJson(String json) throws Exception {
+        List<Map<String, String>> resultList = new ArrayList<>();
+        JSONObject jsonObject = JSON.parseObject(json);
+        Object result = jsonObject.get("result");
+        if ("fail".equals(result.toString())) {
+            throw new Exception(jsonObject.get("errordescription").toString());
+        }
+        JSONArray datas = jsonObject.getJSONArray("datas");
+        JSONArray fields = jsonObject.getJSONArray("fields");
+        if (datas == null || datas.size() == 0) {
+            return null;
+        }
+        for (int i = 0; i < datas.size(); i++) {
+            JSONArray data = datas.getJSONArray(i);
+            HashMap<String, String> resultMap = new HashMap<>();
+            for (int j = 0; j < fields.size(); j++) {
+                resultMap.put(fields.get(j).toString(), data.get(j).toString());
+            }
+            resultList.add(resultMap);
+        }
+        return resultList;
+    }
+}

src/main/java/org/springblade/founder/ydjwhc/entity/Cpxx.java

+package org.springblade.founder.ydjwhc.entity;
+
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+public class Cpxx {
+	private String cphm;//车牌号码
+	private String clys;//车辆颜色
+	private String clysdm;//车辆颜色代码
+	private String cllx;//车辆类型
+	private String clpp;//车辆品牌
+	private String clzt;//车辆状态代码
+	private String clztdm;//车辆状态
+	private String hpzl;//号牌种类
+	private String syxz;//使用性质
+	private String gcjkfl;//国产进口
+
+	public Cpxx(Map<String, String> map) {
+		this.cphm = map.get("JDCHPHM");
+		this.clpp = map.get("ZWPPMC");
+		this.cllx = map.get("DIC_JDCCLLXDM");
+		this.hpzl = map.get("DIC_JDCHPZLDM");
+		this.syxz = map.get("DICJDCSYXZDM");
+		this.gcjkfl = map.get("DIC_JDCGCJKFLDM");
+		this.clztdm = map.get("JDCZTDM");
+		this.clzt= map.get("DIC_JDCZTDM");
+		this.clysdm = map.get("JDCCSYSDM");
+		this.clys = map.get("DIC_JDCCSYSDM");
+	}
+	public Cpxx() {
+
+	}
+}

src/main/java/org/springblade/founder/ydjwhc/entity/RySmxx.java

 package org.springblade.founder.ydjwhc.entity;
 
 import lombok.Data;
-import org.apache.commons.lang.StringUtils;
 import org.springblade.founder.entity.QgckryBean;
 
-import java.util.HashMap;
+import java.util.Map;
 
 @Data
 public class RySmxx {
-	private String xm;
-	private String xb;
-	private String xbStr;
-	private String mz;
-	private String mzStr;
-	private String csrq;
-	private String zz;
-	private String sfzh;
-	private String zp;
-
-	private String sjhm;
-
-	private String cphm;
-	private String clys;
-	private String cllx;//CODE_CLLX
-	private String clpp;
-	private String clzt;
+	private String xm;//姓名
+	private String xb;//性别代码
+	private String xbStr;//性别
+	private String mz;//民族代码
+	private String mzStr;//民族
+	private String csrq;//出生日期
+	private String zz;//住址
+	private String sfzh;//身份证号
+	private String zp;//照片
+
+	private String sjhm;//手机号码
+	private String zt;
 
 	public RySmxx() {
 	}
 
-	public RySmxx(HashMap<String, String> map, QgckryBean qgry) {
+	public RySmxx(QgckryBean qgry) {
 		if (qgry != null) {
 			this.xm = qgry.getXm();
 			this.xb = qgry.getXb();
@@ -44,14 +38,9 @@ public class RySmxx {
 			this.mz = "01";
 			this.csrq = "2000-01-01";
 			this.zz = "内蒙古呼和浩特市";
-			this.sfzh = map.get("");
-			this.zp = null;
-		}
+			this.sfzh = "150105********7822";
+			this.zp = "data:image/png;base64,/9j/4AAQSkZJRgABAQAAAQABAAD/2wBDAAkGBwgHBgkIBwgKCgkLDRYPDQwMDRsUFRAWIB0iIiAdHx8kKDQsJCYxJx8fLT0tMTU3Ojo6Iys/RD84QzQ5Ojf/2wBDAQoKCg0MDRoPDxo3JR8lNzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzc3Nzf/wAARCAC5AJYDASIAAhEBAxEB/8QAHAAAAQUBAQEAAAAAAAAAAAAAAAMEBQYHAgEI/8QAPBAAAQMDAgQDBgQEBAcAAAAAAQACAwQFESExBhJBURMicQcUMkJhgZGhscEVM0PRUnLh8CMkJTRTc3T/xAAZAQEAAwEBAAAAAAAAAAAAAAAAAQMEAgX/xAAfEQEBAAICAwEBAQAAAAAAAAAAAQIRAyESMUETUUL/2gAMAwEAAhEDEQA/ANxQhCAQhCAQhMrvdaKz0bqq4TNiibpk9Sgek43UZcOILTbgDV18DM5wOcE6eix7jH2qVNeJaW1B0FOTgP2cQs0qrjLM8l8jna9TuidPpCt9o/DdLE6T3wykH4Y25JUQ/wBsFiBHLT1Dvrovnx1Q54IJOOyS5nDXJ7onUfS9N7UeGpzgzTR6kZdH/Yqy26/Wu5Rh9HXQSAjOjgCvkdk7mjc/Qp9SXOeBwMMrmafKcIjUfXbXBzQ5pBB1BHVerA+EvadXUVWyO4PMtOSGBrjo0aft+i2yz3mhvNKKi3ztlYTg43BQsSCEIRAQhCAQhCAQhCAQhCCOvt4pbHb5K2tdiNuwG5P0XztxtxjX8RVcolmPuzXHw4m7NH+8K7e3K8MMtPbopnc0YzJHjQZ2KySngfPIQ1p17KLXchu7mfowFKMopHFuh11BVqtvDbnxB0mhVhorJTQNHM3ONVVlyyLseG1RaeyPc0uLSRjsnEViEnMwPA06/otEZTwgYETfwXbaWnH9FuT9FX+yz8GWVFokY0+Ugg4OUyfb548+U6dMLXJLZA7IwQM53UfLZYSQeXOOpUzmc3gZaWSM6bKx8GcVVPDt2gqGPcYgcSN/xN6hTF04fa9pdG0cx1yAqdX0UlLKQRsVbjnKqz47i+srPcqe7W6CtpXh0crQdDnB6hPVjPsM4jDJJrJUyHEnngB2B6hbMrFVmghCEQEIQgEIQgF4TgEr1Mr1P7tZ66caGOB7h9mlB84e0K4m8cVVswwWNkLG47DRSHCNoYYjPK3XoFB09O6qrHvIyXOySr9aoxDTNZjGFTyZdaauLHvZy1jQAGjASrIHPOyIxzHZSNOwADmwst7aoatpTtghK+6noPyUo2NpGmiUEYxjCjRtEGnONk2lgI3U7IGtaSQEwnc1w0Ca0RElg2IyFVeKbWHO8Rg0dv6q4TNwoq6R+LEWn7LvDLVc5zcUXhurlsnEFHWMyBHK0n6jOq+poZGyxMkYcte0OHoV8y19Ly5cBqNV9C8IVBquGbbM45Lqduc/QYWzG7YeTHSYQhC6VhCEIBCEIBRHFxxwxdP/AJnj8lLqG4waXcMXIN38Aome2H2elDAHkaqz07MtGAo+0QB7WNA33U25rYsAYx1J6LLm24enrGdk8hYeyjBdIWuIiaZMdRsnkV9giwZ6WUM6vaM4VfhVnnEmzIGADp3S4ceVFFV0NcwPppMj0wnnhRj6qfGnkjZmuOmN/omM0D/sn9zucFAwnwnSv6Nb1UIbtcqjaiZE07DVxTwPJ7IwjIcmk8Rc3uuZ6mujcS6Jzx1HKUvTTNlbzBpGd2uGoUeOje1ZudMADgELV/ZlK6Xg+ka/eIuZt0B/1VCvMAEXMButA9nEJh4Wgz873uH44/ZaOJl5ppaEIQrmcIQhAIQhAJrdacVdtqqcj+ZE5v4hOlXeI+In2ydsFNGySQjLg/P4aKLZJuuscbldRnNgaRO9jshzAQQpeSmZOS2YZadxndNaVzH3upmiidE2VnOWOOcEnXB7J9I48nl3WbO9tuEvqkRBbaPHOxg+h1K5/iVnkd4cToi/bDS0/omHu7ZK4vro3Sxf4QdPw6phZbB7hdY6mURS08JJY0MAc/fAOn17lRNX66ss9RZ6YQR+eJoA3yFMR1DXR82RoFX8CGOVzWcjXEFjM5wlaZ0hi12PRV2114lap8TnPecEDcnVRNdxHFbixpppXc7eYcsZd5c4z6ZToZf4kEhI5iMHCRvVpF6bC2rbyvhHK18YAOO3ZdY6+osvxzRcRQ1jY3OjLRKMt5hjOuPupBzWvGWgD0Uc61ObTwUrWgQwDyADXvn1T6NvhR8pzp3Ki3vpOuu0ffARR5G+cBXuwXW3UNFSWwTFz4o2te8DyB3XX1Kp1fD7xRkY2IP5pyYGMY0tbgDJBHforJn4q8uKZ3tpw1QmlqeX26nc45PIMlO1qjDZq6CEIRAQhCAKo/FFP/1kk/M0OBP+/orwqtxpAcwTN3LXM+/T91XyzeK7gus1YijHvEkg+Vgb+a9a0l51XlreHtkjdpKNS0747p6yMDzBvMegWa+m3/TmKlyQ7Cce7t/whLRZxgt5QlWguOig2i6iEF2DjbVcwvbggdEtcA4zCGIakZcV3R0sXhHL9VCZTPka95c0ahPYWYbka/smczHwymSIhzQdR3UtEGyQtkZs4JCkHRc4yU3np8N0UgPxSE5HIQRsiJUfGwcjg4ZbjZJl/KJINSAMhLTlzaeQx4Dume68ttG+WoigBD5JSA5wXV+Qlk3V+tLS22UwO/hg/kna5Y0MY1o2aMBdLZHm27uwhCFKAhCEAo++UXv1A+MDzt8zPUKQQos2mXV3GaxxtbVtf4eH4LS5PAcO2VxntdFM5z3wM5zrzfXuqhURmGd8bt2kgrPlhcY2YcszpRjsBLxvAGcpkHDUDdec5Omd1Vat9ua0czzIwgHHKQeoTK10UVPA6OnL42F2jQcgZS9SNMyOAHRcwzsZHylxAPVQ6m/hpFSRUtVUCLDDOQXuJyXKcppWMiEY2AwFEPkifJlzgM7EpxlzAHAktRN/lSL5Bumsr85A2XDXkg5K8z0SOad2y3m4yGEPDAG8xJGVYLRYY7fP4zpfEeBhuG4ATfhOHDJpiNyGg/mf2VhWrDCalYuXky3cZ6CEIVqkIQhAIQhAIQhAKscTUhinbVMHkfo76FWdIV0LaikmicAeZhxnvjRc5Tc06wy8btROcb9V4XYIITXxcHBK9bISTnZZMo3yo+4UlVPUA+I90ePhGmEpDbhy4c54PYkp+AXnOy6NHJNqScY2XMyW45aRE9sGcMDie+U7oYXU0Qa573HsTkBPjSujw3oPqkHtLc/VLUXLbtrgBjK9L9gE0MmDquBLzHQqYrrSbNE2K2U4aPiYHH1OqepCgGKGnA/8Tf0S62z08++whCFKAhCEAhCEAhCEAg7IVe45vH8HsM7438tRK0sjI3Hc/YIKZcgWVU4YdBI4D7FIU9Zh3LJuFH8PVZrLVSyPOXGNuT3OE/npOZvMN1iyvb0JOkvAWSAFrgnQmEYH65VXifVQHLNfRL/xCoOhjIP+VculidKHDplR1bURRgkkZ7KKfWVb/ga4fZcxU8sr8ykknoVCXXO+dxPypVreUBOo6XkZrukanEbSeyb7Q0ix1sNda4JoHczQ3kP0I0IT9Zx7LLnyCopJneWeaR8We/Mf1H6LR1vnp5+U1QhCFLkIQhAIQhAIQThV+9cXWu1czDL48zd44tcep2CCee9rGlzyA0aknosc49vJu9ZK1jj4LMsjH07/AHTyv4wuV3ZIcinpD5WxM3f6lVSrJLjzZyVFW446LcCyF1qiYfijJZ+BVzjAe3BH2Ko/Cf8AwKmoh6c5c0eqvVNggZCxZ+2vH0QEfJIdPsU7ia3l1b+S7fEDuF3HEBtlcutkHxA50XkELOYnCcviz0XccXLrso0G8xwQFBcQTmCjkeNDjDR3J2U9PjOeyqHEk4lqWQA6NOT6rrGbqLdR3ZnvpIonxOLXx4II7ha9ZLnHdLfHUMIDiMPaPld1WPQEtaB0wvXXGstjBV0M74pITzHlOjm9QR1HVboyZTbcEKp2DjSlrIY2XIinnPz/ACO/srUx7ZGh8bg5pGQQcgqVVmnSEIRAUBeuKqG2gsY4VEw+VjtB6lUy7cUXCuDmGTw4z8kegVelkzlz90dzD+pm+cW3Gua9njGKI/JFoMeu5VUf4lT5QQ1u7ie31XUZdO4sb33SdweyGnMbTod8fN/ood60hOKL1O2FtNb3uijacF7dHH79FH2C7zRjwK3nlic4kSFxJaf7KRNtNTE57xpuF1R0EMcZa5oyDlEd7TVrPhVbJ43BzDpzBXSiqGvxqs+pnOpZOaDGPmYdirJb6vnY2RuQOo7LNy4a7aOPLfS5sw5uUo1uiZWybxYxndSTWqpZXAb3XkmGsJylS3AUPeap0TC1pQIXCvZExxyMrPOIbpLA90lMGPlzrzjQD0Upc6sucWl+vUBQdRTGUudJgA9Oy08fHruqM899Q74d4ijug8CUCKqb8nR/p/ZTkrPEjc1wy0jBCo09qdBh9OS2UnORoWqetl6e0NhuGpAwZgP1CtVy/wBTcDsMLM7eUhS9nvldaiBTTO5AdY3atP2UFMeUtniIdGccxb27pZrsHmad1KWn2rjG31Uf/Nn3aUDUHVp9ChZs0hxyEI58ITByCUhWuxCThOm/D90hV/yT6o6N6Vgipw7q/U+iYysM8xe74c4AT/8ApfZN2dFCCjYxycoGE1lgLXZA+6f91zLspEPK8MkGdCr/AOzaOlqYa2GojZISWuDXjOmqz25fGPVXb2Xf99J/6z+ygaLT8P0O8QfEezXafmnAsrBtM78E9pfhTlRcMb8cfplPqL/g0XzSPPpgKD4mprXbrfPLKxvOWFrC85JcRphW92yzP2pfHT+h/VJhjPiccsre6oVRIxznPAA10/uuIWlzRI4aE+Rp6/UpOp/l/gpH+rF/lUuzcsDGnIyTuSuBQskhIc3zO1ynU2w9U4G49EQZ0bZaPEY80ZOoOyfu5YwC34CNuy5dsEpJ/LRIYcjQISkHwoQf/9k=";
 
-		this.cphm = map.get("cphm");
-		this.clys = map.get("clys");
-		this.cllx = map.get("cllx");
-		this.clpp = map.get("clpp");
-		this.clzt = map.get("clzt");
+		}
 	}
 }

src/main/java/org/springblade/founder/ydjwhc/mapper/QgBjHcMapper.java

 package org.springblade.founder.ydjwhc.mapper;
 
-import com.baomidou.dynamic.datasource.annotation.DS;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.springblade.founder.ydjwhc.entity.HcAjJg;
@@ -10,7 +9,6 @@ import java.util.List;
 
 @Mapper
 @Repository
-@DS("xzxt_qg")
 public interface QgBjHcMapper {
 	List<HcAjJg> selectAjBySfzh(@Param("sfzh") String sfzh, @Param("qsAjList") List<HcAjJg> qsAjList);
 

src/main/java/org/springblade/founder/ydjwhc/mapper/QsBjHcMapper.java

 package org.springblade.founder.ydjwhc.mapper;
 
-import com.baomidou.dynamic.datasource.annotation.DS;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 import org.springblade.founder.ydjwhc.entity.HcAjJg;
@@ -11,7 +10,6 @@ import java.util.Map;
 
 @Mapper
 @Repository
-@DS("xzxt_hm")
 public interface QsBjHcMapper {
 	Map<String, String> selectRyBzByZjhm(String sfzh);
 

src/main/java/org/springblade/founder/ydjwhc/mapper/rybjhcMapper.xml

@@ -16,7 +16,7 @@
     <select id="getZtryByZjhm" parameterType="java.lang.String" resultType="java.lang.Integer">
         select count(1)
         from TB_YW_ZTRY
-        where zjhm in #{zjhm}
+        where zjhm in #{zjhm} and xxsc_pdbz = '0'
     </select>
 
 </mapper>

src/main/java/org/springblade/founder/ydjwhc/service/BjHcService.java

@@ -21,7 +21,7 @@ public interface BjHcService {
 	 * @author lystar
 	 * 2021/11/27 19:19
 	 */
-	Map<String, Object> clsahcByCphm(String cphm);
+	Map<String, Object> clsahcByCphm(String cphm) throws Exception;
 
 	/**
 	 * znjsByHm 智能检索

src/main/java/org/springblade/founder/ydjwhc/service/QgBjHcService.java

+package org.springblade.founder.ydjwhc.service;
+
+import org.springblade.founder.ydjwhc.entity.HcAjJg;
+
+import java.util.List;
+
+public interface QgBjHcService {
+	List<HcAjJg> selectAjBySfzh(String sfzh, List<HcAjJg> qsAjList);
+
+	List<HcAjJg> selectAjByCphm(String cphm, List<HcAjJg> qsAjList);
+}

src/main/java/org/springblade/founder/ydjwhc/service/QsBjHcService.java

+package org.springblade.founder.ydjwhc.service;
+
+import org.springblade.founder.ydjwhc.entity.HcAjJg;
+
+import java.util.List;
+import java.util.Map;
+
+public interface QsBjHcService {
+	Map<String, String> selectRyBzByZjhm(String sfzh);
+
+	List<HcAjJg> selectAjBySfzh(String sfzh);
+
+	List<HcAjJg> selectAjByCphm(String cphm);
+
+	HcAjJg selectAjByAsjbh(String asjbh);
+
+	String getNameByCodeAndGroupid(String ajlb, String code_ajlb);
+}

src/main/java/org/springblade/founder/ydjwhc/service/impl/BjHcServiceImpl.java

 package org.springblade.founder.ydjwhc.service.impl;
 
-import org.springblade.founder.asj.dao.HnJbAsjXsMapper;
-import org.springblade.founder.asj.dao.QgJbAsjXsMapper;
+import com.alibaba.fastjson.JSONObject;
 import org.springblade.founder.asj.service.QgAsjQueryService;
 import org.springblade.founder.entity.QgckryBean;
 import org.springblade.founder.redis.mapper.DictitemMapper;
 import org.springblade.founder.ryythcj.entity.TbStAppRyxx;
 import org.springblade.founder.ryythcj.service.TbStAppRyxxService;
+import org.springblade.founder.utils.KtInterfaceUtils;
 import org.springblade.founder.utils.QgryckUtils;
 import org.springblade.founder.ydjwhc.controller.CallDygabxxfwController;
+import org.springblade.founder.ydjwhc.entity.Cpxx;
 import org.springblade.founder.ydjwhc.entity.RySmxx;
 import org.springblade.founder.ydjwhc.entity.HcAjJg;
-import org.springblade.founder.ydjwhc.mapper.QgBjHcMapper;
-import org.springblade.founder.ydjwhc.mapper.QsBjHcMapper;
 import org.springblade.founder.ydjwhc.mapper.RyxxbjhcDao;
 import org.springblade.founder.ydjwhc.service.BjHcService;
+import org.springblade.founder.ydjwhc.service.QgBjHcService;
+import org.springblade.founder.ydjwhc.service.QsBjHcService;
 import org.springblade.founder.ydjwhc.thread.TimeControl;
 import org.springblade.founder.ydjwhc.thread.TimeControl2;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -34,9 +35,9 @@ public class BjHcServiceImpl implements BjHcService {
 	@Autowired
 	private TbStAppRyxxService tbStAppRyxxService;
 	@Autowired
-	private QsBjHcMapper qsBjHcMapper;
+	private QsBjHcService qsBjHcService;
 	@Autowired
-	private QgBjHcMapper qgBjHcMapper;
+	private QgBjHcService qgBjHcService;
 	@Autowired
 	private QgAsjQueryService qgAsjQueryService;
 
@@ -66,11 +67,17 @@ public class BjHcServiceImpl implements BjHcService {
 		sjList.add("15000000003");
 		ryxx.setRySjhmList(sjList);
 		//获取人员车牌号
-		// TODO 查询人员实名车牌
+		JSONObject param = new JSONObject();
+		param.put("expr", "JDCSYR_JTGLYWDXSFZMHM='" + sfzh + "'");
+		String resultJson = KtInterfaceUtils.getDateByJsonParam(KtInterfaceUtils.RCCL, param.toString());
+		List<Map<String, String>> listByJson = KtInterfaceUtils.getMapByJson(resultJson);
+		if (listByJson == null) {
+			return null;
+		}
 		ArrayList<String> cpList = new ArrayList<>();
-		cpList.add("琼A00001");
-		cpList.add("琼A00002");
-		cpList.add("琼A00003");
+		for (Map<String, String> map : listByJson) {
+			cpList.add(map.get("JDCHPHM"));
+		}
 		ryxx.setRyCphmList(cpList);
 		resultMap.put("ryxx", ryxx);
 		//查询人员主标签
@@ -83,7 +90,7 @@ public class BjHcServiceImpl implements BjHcService {
 		resultMap.put("zbq", zbq);
 
 		//查询重点关注人员标签
-		Map<String, String> rybzMap = qsBjHcMapper.selectRyBzByZjhm(sfzh);
+		Map<String, String> rybzMap = qsBjHcService.selectRyBzByZjhm(sfzh);
 		if (rybzMap != null) {
 			String CODE = processingBz(rybzMap.get("CODE"));
 			String AJLB = processingBz(rybzMap.get("AJLB"));
@@ -93,14 +100,14 @@ public class BjHcServiceImpl implements BjHcService {
 			resultMap.put("sabq", SABQ);
 		}
 		//查询人员涉案信息
-		List<HcAjJg> qsAjList = qsBjHcMapper.selectAjBySfzh(sfzh);
+		List<HcAjJg> qsAjList = qsBjHcService.selectAjBySfzh(sfzh);
 		resultMap.put("qsAjList", qsAjList);
 		resultMap.put("qsAjCount", qsAjList.size());
 
-		List<HcAjJg> qgAjList = qgBjHcMapper.selectAjBySfzh(sfzh, qsAjList);
+		List<HcAjJg> qgAjList = qgBjHcService.selectAjBySfzh(sfzh, qsAjList);
 		for (HcAjJg hcAjJg : qgAjList) {
-			String ajlb = qsBjHcMapper.getNameByCodeAndGroupid(hcAjJg.getAjlb(), "CODE_AJLB");
-			String fadq = qsBjHcMapper.getNameByCodeAndGroupid(hcAjJg.getFadq(), "CODE_XZQH");
+			String ajlb = qsBjHcService.getNameByCodeAndGroupid(hcAjJg.getAjlb(), "CODE_AJLB");
+			String fadq = qsBjHcService.getNameByCodeAndGroupid(hcAjJg.getFadq(), "CODE_XZQH");
 			hcAjJg.setAjlb(ajlb);
 			hcAjJg.setFadq(fadq);
 		}
@@ -111,12 +118,10 @@ public class BjHcServiceImpl implements BjHcService {
 	}
 
 	@Override
-	public Map<String, Object> clsahcByCphm(String cphm) {
+	public Map<String, Object> clsahcByCphm(String cphm) throws Exception {
 		HashMap<String, Object> resultMap = new HashMap<>();
 		//查询车牌实名制
-		//TODO 查询车牌实名信息
-		RySmxx rySmxx = getClxxByCphm(cphm);
-		resultMap.put("cpSmxx", rySmxx);
+		getClxxByCphm(cphm, resultMap);
 		getSaxxByBsh(cphm, resultMap);
 		return resultMap;
 	}
@@ -129,7 +134,7 @@ public class BjHcServiceImpl implements BjHcService {
 		String SJHM_REGEX = "^1(3[0-9]|4[57]|5[0-35-9]|7[0135678]|8[0-9])\\d{8}$";
 		if (hm.startsWith("A") && hm.length() == 23) {
 			HashMap<String, Object> resultMap = new HashMap<>();
-			HcAjJg ajxx = qsBjHcMapper.selectAjByAsjbh(hm);
+			HcAjJg ajxx = qsBjHcService.selectAjByAsjbh(hm);
 			resultMap.put("ajxx", ajxx);
 			resultMap.put("type", "asjbh");
 			return resultMap;
@@ -151,16 +156,16 @@ public class BjHcServiceImpl implements BjHcService {
 
 	private void getSaxxByBsh(String bsh, HashMap<String, Object> resultMap){
 		//查询车牌涉案信息
-		List<HcAjJg> qsAjList = qsBjHcMapper.selectAjByCphm(bsh);
+		List<HcAjJg> qsAjList = qsBjHcService.selectAjByCphm(bsh);
 		resultMap.put("qsAjList", qsAjList);
 		resultMap.put("qsAjCount", qsAjList.size());
 
 		//本地测试
-		List<HcAjJg> qgAjList = qgBjHcMapper.selectAjByCphm(bsh, qsAjList);
+		List<HcAjJg> qgAjList = qgBjHcService.selectAjByCphm(bsh, qsAjList);
 		resultMap.put("qgAjList", qgAjList);
 		resultMap.put("qgAjCount", qgAjList.size());
 		// 公安网
-		// List<TbXszCbypQgaj> asjListByBsh = qgAsjQueryService.getQgAsjByBsh(cphm);
+		// List<TbXszCbypQgaj> asjListByBsh = qgAsjQueryService.getQgAsjByBsh(bsh);
 		// if (asjListByBsh != null && asjListByBsh.size() > 0) {
 		// 	List<HcAjJg> qgAjList = new ArrayList<>();
 		// 	for (TbXszCbypQgaj asjByBsh : asjListByBsh) {
@@ -202,20 +207,38 @@ public class BjHcServiceImpl implements BjHcService {
 	}
 
 	//查询车辆实名信息
-	private RySmxx getClxxByCphm(String cphm) {
-		HashMap<String, String> map = new HashMap<>();
-		map.put("cphm", cphm);
-		map.put("cpsm", "150105199909090010");
-		map.put("clys", "灰色");
-		map.put("cllx", "小型轿车");
-		map.put("clpp", "大众");
-		map.put("clzt", "未年检");
+	private void getClxxByCphm(String cphm, Map<String, Object> resultMap) throws Exception {
+		JSONObject param = new JSONObject();
+		param.put("expr", "JDCHPHM='" + cphm + "'");
+		String resultJson = KtInterfaceUtils.getDateByJsonParam(KtInterfaceUtils.CPCX, param.toString());
+		//获取结果列表
+		List<Map<String, String>> listByJson = KtInterfaceUtils.getMapByJson(resultJson);
+		if (listByJson == null) {
+			return;
+		}
+		Cpxx cpxx = null;
+		ArrayList<RySmxx> ryList = new ArrayList<>();
+		for (Map<String, String> map : listByJson) {
+			if (cpxx == null) {
+				cpxx = new Cpxx(map);
+			}
 			QgryckUtils qgryckUtils = new QgryckUtils();
-		// QgckryBean qgry = qgryckUtils.getQgckAllxxXml(map.get("cpsm"));
+			// QgckryBean qgry = qgryckUtils.getQgckAllxxXml(map.get("JDCSYR_JTGLYWDXSFZMHM"));
 			QgckryBean qgry = null;
-		RySmxx rySmxx = new RySmxx(map, qgry);
+			RySmxx rySmxx = new RySmxx(qgry);
+			String dicJdcztdm = map.get("DIC_JDCZTDM");
+			if ("正常".equals(dicJdcztdm)){
+				cpxx.setClzt(dicJdcztdm);
+			}
+			rySmxx.setZt(dicJdcztdm);
 			translateZdm(rySmxx);
-		return rySmxx;
+			ryList.add(rySmxx);
+		}
+		if (cpxx != null){
+			resultMap.put("cpxx", cpxx);
+			resultMap.put("czList", ryList);
+			resultMap.put("czCount", ryList.size());
+		}
 	}
 
 	//翻译字段码

src/main/java/org/springblade/founder/ydjwhc/service/impl/QgBjHcServiceImpl.java

+package org.springblade.founder.ydjwhc.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.springblade.founder.ydjwhc.entity.HcAjJg;
+import org.springblade.founder.ydjwhc.mapper.QgBjHcMapper;
+import org.springblade.founder.ydjwhc.service.QgBjHcService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@DS("xzxt_qg")
+public class QgBjHcServiceImpl implements QgBjHcService {
+
+	@Autowired
+	private QgBjHcMapper qgBjHcMapper;
+
+	@Override
+	public List<HcAjJg> selectAjBySfzh(String sfzh, List<HcAjJg> qsAjList) {
+		return qgBjHcMapper.selectAjBySfzh(sfzh, qsAjList);
+	}
+
+	@Override
+	public List<HcAjJg> selectAjByCphm(String cphm, List<HcAjJg> qsAjList) {
+		return qgBjHcMapper.selectAjByCphm(cphm, qsAjList);
+	}
+}

src/main/java/org/springblade/founder/ydjwhc/service/impl/QsBjHcServiceImpl.java

+package org.springblade.founder.ydjwhc.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import org.springblade.founder.ydjwhc.entity.HcAjJg;
+import org.springblade.founder.ydjwhc.mapper.QsBjHcMapper;
+import org.springblade.founder.ydjwhc.service.QsBjHcService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Map;
+
+@Service
+@DS("xzxt_hm")
+public class QsBjHcServiceImpl implements QsBjHcService {
+
+	@Autowired
+	private QsBjHcMapper qsBjHcMapper;
+
+	@Override
+	public Map<String, String> selectRyBzByZjhm(String sfzh) {
+		return qsBjHcMapper.selectRyBzByZjhm(sfzh);
+	}
+
+	@Override
+	public List<HcAjJg> selectAjBySfzh(String sfzh) {
+		return qsBjHcMapper.selectAjBySfzh(sfzh);
+	}
+
+	@Override
+	public List<HcAjJg> selectAjByCphm(String cphm) {
+		return qsBjHcMapper.selectAjByCphm(cphm);
+	}
+
+	@Override
+	public HcAjJg selectAjByAsjbh(String asjbh) {
+		return qsBjHcMapper.selectAjByAsjbh(asjbh);
+	}
+
+	@Override
+	public String getNameByCodeAndGroupid(String ajlb, String code_ajlb) {
+		return qsBjHcMapper.getNameByCodeAndGroupid(ajlb, code_ajlb);
+	}
+}

src/main/java/org/springblade/founder/ydjwhc/thread/TimeControl2.java

@@ -31,21 +31,21 @@ public class TimeControl2 implements Callable<Map<String, String>> {
 	@Override
 	public Map<String, String> call() {
 		switch (resourceName) {
-			case "ztry": {
-				Map map = callDygabxxfwController.getGabZyInfo("ztryxx", zjhm);
-				System.out.println("map====>" + map);
-				if (map != null) {
-					List<Map> resultList = (List) map.get("dataResult");
-					if (resultList.size() > 0) {
-						HashMap<String, String> resultMap = new HashMap<>();
-						resultMap.put("zylx", "1");
-						resultMap.put("resourceName", resourceName);
-						resultMap.put("zymc", "在逃人员");
-						return resultMap;
-					}
-				}
-				break;
-			}
+			// case "ztry": {
+			// 	Map map = callDygabxxfwController.getGabZyInfo("ztryxx", zjhm);
+			// 	System.out.println("map====>" + map);
+			// 	if (map != null) {
+			// 		List<Map> resultList = (List) map.get("dataResult");
+			// 		if (resultList.size() > 0) {
+			// 			HashMap<String, String> resultMap = new HashMap<>();
+			// 			resultMap.put("zylx", "1");
+			// 			resultMap.put("resourceName", resourceName);
+			// 			resultMap.put("zymc", "在逃人员");
+			// 			return resultMap;
+			// 		}
+			// 	}
+			// 	break;
+			// }
 			case "fzxyr": {
 				Map map = callDygabxxfwController.getGabZyInfo("fzxyr", zjhm);
 				System.out.println("map====>" + map);