西藏关联关系接口处理

service/pom.xml

@@ -183,5 +183,9 @@
             <groupId>org.springframework.cloud</groupId>
             <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-mongodb</artifactId>
+        </dependency>
     </dependencies>
 </project>
\ No newline at end of file

service/publicapi/src/main/java/com/founder/publicapi/config/AbstractMongoConfig.java

+package com.founder.publicapi.config;
+
+import com.mongodb.MongoClientURI;
+import org.springframework.data.mongodb.MongoDbFactory;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
+
+public abstract class AbstractMongoConfig {
+    //连接MongoDB地址
+    private String uri;
+
+    /**
+     * 获取mongoDBTemplate对象
+     */
+    public abstract MongoTemplate getMongoTemplate() throws Exception;
+
+    /**
+     * 创建mongoDb工厂
+     */
+    public MongoDbFactory mongoDbFactory() throws Exception {
+        MongoClientURI mongoclienturi = new MongoClientURI(uri);
+        return new SimpleMongoDbFactory(mongoclienturi);
+    }
+
+    public String getUri() {
+        return uri;
+    }
+
+    public void setUri(String uri) {
+        this.uri = uri;
+    }
+}

service/publicapi/src/main/java/com/founder/publicapi/config/PrimaryMongoConfig.java

+package com.founder.publicapi.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.mongodb.core.MongoTemplate;
+
+@Configuration
+@ConfigurationProperties(prefix = "spring.data.mongodb.primary")
+public class PrimaryMongoConfig extends AbstractMongoConfig{
+    @Override
+    @Primary
+    @Bean(name = "primaryMongoTemplate")
+    public MongoTemplate getMongoTemplate() throws Exception {
+        return new MongoTemplate((mongoDbFactory()));
+    }
+}

service/publicapi/src/main/java/com/founder/publicapi/config/SecondaryMongoConfig.java

+package com.founder.publicapi.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Primary;
+import org.springframework.data.mongodb.core.MongoTemplate;
+
+@Configuration
+@ConfigurationProperties(prefix = "spring.data.mongodb.second")
+public class SecondaryMongoConfig extends AbstractMongoConfig{
+
+    @Override
+    @Primary
+    @Bean(name = "secondMongoTemplate")
+    public MongoTemplate getMongoTemplate() throws Exception {
+        return new MongoTemplate((mongoDbFactory()));
+    }
+}
\ No newline at end of file

service/publicapi/src/main/java/com/founder/publicapi/controller/SkDataOperation/SkRelatedResultController.java

@@ -15,6 +15,7 @@ import com.founder.publicapi.service.SkRelatedResultService;
 import com.founder.servicebase.service.SkDictionaryService;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
@@ -38,7 +39,8 @@ public class SkRelatedResultController extends ApiController {
     private SkRelatedResultService skRelatedResultService;
     @Autowired
     private SkDictionaryService skDictionaryService;
-
+    @Value("${environment}")
+    private String environment;
 
 
     /**
@@ -48,23 +50,25 @@ public class SkRelatedResultController extends ApiController {
     @ApiOperation(value = "查询关联关系列表信息")
     @OperLog(message = "查询关联关系列表信息", operation = OperationType.QUERY)
     public MapRestResult query(@RequestBody SkRelatedResultParam param) throws UnsupportedEncodingException {
-        Page page = new Page(param.getPage(), param.getPageSize());
-
-
-        QueryWrapper queryWrapper = new QueryWrapper();
-        if (param.getObjectvalue()!=null&& !"".equals(param.getObjectvalue())){
-            queryWrapper.like("objectValue",param.getObjectvalue());
-        }
-        if (param.getObjecttype()!=null&& !"".equals(param.getObjecttype())){
-            queryWrapper.eq("objectType",param.getObjecttype());
-        }
-        queryWrapper.eq("isDeleted", "0");
-        IPage page1 = skRelatedResultService.page(page, queryWrapper);
-        List<SkRelatedResult> list = page1.getRecords();
-        List<SkRelatedResultVO> newList = new ArrayList<>();
-        for (SkRelatedResult s :list) {
+        if("dev".equals(environment)) {
+
+            Page page = new Page(param.getPage(), param.getPageSize());
+            QueryWrapper queryWrapper = new QueryWrapper();
+            if (param.getObjectvalue() != null && !"".equals(param.getObjectvalue())) {
+                queryWrapper.like("objectValue", param.getObjectvalue());
+            }
+            if (param.getObjecttype() != null && !"".equals(param.getObjecttype())) {
+                queryWrapper.eq("objectType", param.getObjecttype());
+            }
+            queryWrapper.eq("isDeleted", "0");
+            IPage page1 = skRelatedResultService.page(page, queryWrapper);
+            List<SkRelatedResult> list = page1.getRecords();
+            List<SkRelatedResultVO> newList = new ArrayList<>();
+            for (SkRelatedResult s : list) {
 //            s.setResult(StringUtil.toUTF8(s.getResult()));
-            newList.add(new SkRelatedResultVO(s,skDictionaryService.findDmmcByDmAndDmlx(s.getObjecttype(),"ST")));
+                newList.add(new SkRelatedResultVO(s, skDictionaryService.findDmmcByDmAndDmlx(s.getObjecttype(), "ST")));
+            }
+            return new MapRestResult(200, "OK", page1.getTotal(), newList);
         }
         return new MapRestResult(200, "OK", page1.getTotal(), newList);
 

service/publicapi/src/main/java/com/founder/publicapi/controller/SkInterface/GlgxInterface.java

+package com.founder.publicapi.controller.SkInterface;
+
+import com.alibaba.fastjson.JSONObject;
+import com.founder.commonutils.model.newPublicEntity.MapRestResult;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Criteria;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.http.HttpEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import java.util.ArrayList;
+import java.util.LinkedHashMap;
+import java.util.List;
+
+@Service
+public class GlgxInterface {
+
+
+    @Qualifier("primaryMongoTemplate")
+    @Autowired
+    MongoTemplate primaryMongoTemplate;
+
+    @Qualifier("secondMongoTemplate")
+    @Autowired
+    MongoTemplate secondMongoTemplate;
+
+    public MapRestResult getXsSfXx(String objectType, String objectValue) {
+        Car resCar=null;
+         // 车牌号能够查出手机号还有身份证号码
+        if(objectType.equals("01")){
+            Query query = new Query();
+            Criteria criteria = Criteria.where("veco").is(objectValue);
+            query.addCriteria(criteria);
+            resCar = primaryMongoTemplate.findOne(query, Car.class,"wb0099carowner");
+            if(resCar==null){
+                ArrayList<PeopleInfo> res = new ArrayList<>();
+                return MapRestResult.build(200,"没有对应的数据!",res);
+            }
+            ArrayList<PeopleInfo> peopleInfos = new ArrayList<>();
+            if(resCar!=null){
+                Query phoneQuery = new Query();
+                Criteria phonecriteria=null;
+                if(resCar.getCeco().length()==15){
+                    phonecriteria = Criteria.where("ceco").is(resCar.getCeco());
+                }else if(resCar.getCeco().length()==18){
+                    phonecriteria = Criteria.where("cecoS").is(resCar.getCeco());
+                }
+                phoneQuery.addCriteria(phonecriteria);
+                Phone resPhone = secondMongoTemplate.findOne(phoneQuery, Phone.class, "wb0017mobilereg");
+                if(resPhone!=null){
+                    PeopleInfo phone = new PeopleInfo();
+                    phone.setObjectType("04");
+                    phone.setObjectValue(resPhone.getCote());
+                    peopleInfos.add(phone);
+                }
+            }
+
+            PeopleInfo peopleInfo = new PeopleInfo();
+            peopleInfo.setObjectType("03");
+            peopleInfo.setObjectValue(resCar.getCeco());
+
+            PeopleInfo self = new PeopleInfo();
+            self.setObjectType(objectType);
+            self.setObjectValue(objectValue);
+            peopleInfos.add(self);
+            peopleInfo.setChildren(peopleInfos);
+
+            ArrayList<PeopleInfo> res = new ArrayList<>();
+            res.add(peopleInfo);
+            return MapRestResult.build(200,"成功获取身份信息！",res);
+        }else if(objectType.equals("04")){
+            //手机号能够了查到身份证号还有车牌号
+            Query query = new Query();
+            Criteria criteria = Criteria.where("cote").is(objectValue);
+            query.addCriteria(criteria);
+            Phone resPhone = secondMongoTemplate.findOne(query, Phone.class, "wb0017mobilereg");
+            if(resPhone==null){
+                ArrayList<PeopleInfo> res = new ArrayList<>();
+                return MapRestResult.build(200,"没有对应的数据!",res);
+            }
+            ArrayList<PeopleInfo> peopleInfos = new ArrayList<>();
+            if(resPhone!=null){
+                Query carQuery = new Query();
+                Criteria carCriteria = Criteria.where("ceco").is(resPhone.getCecoS());
+                carQuery.addCriteria(carCriteria);
+                resCar = primaryMongoTemplate.findOne(carQuery, Car.class,"wb0099carowner");
+                if(resCar==null){
+                    Query c = new Query();
+                    Criteria ccarCriteria = Criteria.where("ceco").is(resPhone.getCeco());
+                    c.addCriteria(ccarCriteria);
+                    resCar = primaryMongoTemplate.findOne(c, Car.class,"wb0099carowner");
+                }
+
+                if(resCar!=null){
+                    PeopleInfo carInfo = new PeopleInfo();
+                    carInfo.setObjectType("01");
+                    carInfo.setObjectValue(resCar.getVeco());
+                    peopleInfos.add(carInfo);
+                }
+            }
+            PeopleInfo peopleInfo = new PeopleInfo();
+            peopleInfo.setObjectType("03");
+            peopleInfo.setObjectValue(resPhone.getCecoS()!=null?resPhone.getCecoS():resPhone.getCeco());
+            PeopleInfo self = new PeopleInfo();
+            self.setObjectType(objectType);
+            self.setObjectValue(objectValue);
+            peopleInfos.add(self);
+            peopleInfo.setChildren(peopleInfos);
+
+            ArrayList<PeopleInfo> res = new ArrayList<>();
+            res.add(peopleInfo);
+            return MapRestResult.build(200,"成功获取身份信息！",res);
+        }else if(objectType.equals("03")){
+            //身份证号查询出来车牌号还有手机号
+            Query query = new Query();
+            String searchTempValue="";
+            if(objectValue==null){
+                return MapRestResult.error("无法查询此标识号值");
+            }
+            if(objectValue.length()==15){
+                searchTempValue="ceco";
+            }else if(objectValue.length()==18){
+                searchTempValue="cecoS";
+            }else{
+                return MapRestResult.error("输入的证件号码有误");
+            }
+            Criteria criteria = Criteria.where(searchTempValue).is(objectValue);
+            query.addCriteria(criteria);
+            Phone resPhone = secondMongoTemplate.findOne(query, Phone.class, "wb0017mobilereg");
+            if(resPhone==null){
+                ArrayList<PeopleInfo> res = new ArrayList<>();
+                return MapRestResult.build(200,"没有对应的数据!",res);
+            }
+            PeopleInfo self = new PeopleInfo();
+            self.setObjectType(objectType);
+            self.setObjectValue(objectValue);
+
+            PeopleInfo peopleInfo = new PeopleInfo();
+            peopleInfo.setObjectType("04");
+            peopleInfo.setObjectValue(resPhone.getCote());
+
+            Query carQuery = new Query();
+            Criteria carCriteria = Criteria.where("ceco").is(objectValue);
+            carQuery.addCriteria(carCriteria);
+            resCar = primaryMongoTemplate.findOne(carQuery, Car.class,"wb0099carowner");
+            ArrayList<PeopleInfo> peopleInfos = new ArrayList<>();
+            if(resCar!=null){
+                PeopleInfo carInfo = new PeopleInfo();
+                carInfo.setObjectType("01");
+                carInfo.setObjectValue(resCar.getVeco());
+                peopleInfos.add(carInfo);
+            }
+            peopleInfos.add(peopleInfo);
+            self.setChildren(peopleInfos);
+            ArrayList<PeopleInfo> res = new ArrayList<>();
+            res.add(self);
+            return MapRestResult.build(200,"成功获取手机号码信息！",res);
+        }else{
+            return MapRestResult.error("无法查询此标识号类型");
+        }
+    }
+}

service/publicapi/src/main/resources/bootstrap-dev.properties

@@ -39,3 +39,8 @@ password=Cc150520
 #FTP服务器基础目录,/data2/images
 basePath=/data2/images
 imagesUrl=http://65.26.2.173:1008/images/
+
+#mongodb配置
+spring.data.mongodb.primary.uri=mongodb://localhost:27017/whale
+logging.level.org.springframework.data.mongodb.core=DEBUG
+spring.data.mongodb.second.uri=mongodb://localhost:27017/whale

service/publicapi/src/main/resources/bootstrap-prod.properties

@@ -38,4 +38,9 @@ usernameFtp=root
 password=Hnsgat12#$1
 #FTP服务器基础目录,/data2/images
 basePath=/data/hnxz/images
-imagesUrl=http://65.26.2.173:1008/images/
+imagesUrl=http://65.26.2.173:1008/images/
\ No newline at end of file
+
+#mongodb配置
+spring.data.mongodb.primary.uri=mongodb://localhost:27017/whale
+logging.level.org.springframework.data.mongodb.core=DEBUG
+spring.data.mongodb.second.uri=mongodb://localhost:27017/whale
\ No newline at end of file