将查询结果json保存到数据库

src/main/java/com/uas/credit/controller/ErpQueryController.java

@@ -1,9 +1,6 @@
 package com.uas.credit.controller;
 
-import com.uas.credit.model.EnterpriseQuery;
-import com.uas.credit.model.EnterpriseQueryResult;
-import com.uas.credit.model.PersonQuery;
-import com.uas.credit.model.PersonQueryResult;
+import com.uas.credit.model.*;
 import com.uas.credit.model.abnormalinfo.AbnormalRoot;
 import com.uas.credit.model.corpcreditinfo.EncreditinfoRoot;
 import com.uas.credit.model.corpriskinfo.EnRiskInfoRoot;
@@ -43,6 +40,12 @@ public class ErpQueryController {
     @Autowired
     private PersonCorporationService personCorporationService;
 
+    @Autowired
+    private PersonJsonService personJsonService;
+
+    @Autowired
+    private EnterpriseJsonService enterpriseJsonService;
+
     /**
      * ERP对企业进行查询
      */
@@ -64,6 +67,10 @@ public class ErpQueryController {
             enQuery.setEnrisk(enRiskInfoRoot);
             enQuery.setEncredit(encreditinfoRoot);
 
+            // 将调用接口返回数据保存到数据库
+            String json = FlexJsonUtils.toJson(enQuery);
+            EnterpriseJson enterpriseJson = new EnterpriseJson(json);
+            enterpriseJsonService.save(enterpriseJson);
         }
         return enQuery;
     }
@@ -82,6 +89,10 @@ public class ErpQueryController {
             PersonCorporationRoot personCorporationRoot = personCorporationService.queryAndSave(erpQuery);
             result.setPnidentity(policeCheckRoot);
             result.setPnshareholder(personCorporationRoot);
+
+            String json = FlexJsonUtils.toJson(result);
+            PersonJson personJson = new PersonJson(json);
+            personJsonService.save(personJson);
         }
         return result;
     }

src/main/java/com/uas/credit/dao/EnterpriseJsonDao.java

@@ -0,0 +1,16 @@
+package com.uas.credit.dao;
+
+import com.uas.credit.model.EnterpriseJson;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:18
+ */
+@Repository
+public interface EnterpriseJsonDao extends JpaRepository<EnterpriseJson, Long> {
+
+    EnterpriseJson findByCreateTime();
+
+}

src/main/java/com/uas/credit/dao/PersonJsonDao.java

@@ -0,0 +1,13 @@
+package com.uas.credit.dao;
+
+import com.uas.credit.model.PersonJson;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:19
+ */
+@Repository
+public interface PersonJsonDao extends JpaRepository<PersonJson, Long> {
+}

src/main/java/com/uas/credit/model/EnterpriseJson.java

@@ -0,0 +1,58 @@
+package com.uas.credit.model;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:04
+ */
+@Entity
+@Table(name = "enterprise$json")
+public class EnterpriseJson implements Serializable {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private Long id;
+
+    @Lob
+    @Column(name = "json", columnDefinition="TEXT")
+    private String json;
+
+    @Column(name = "createTime")
+    @Temporal(TemporalType.DATE)
+    private Date createTime = new Date();
+
+    public EnterpriseJson() {
+    }
+
+    public EnterpriseJson(String json) {
+        this.json = json;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getJson() {
+        return json;
+    }
+
+    public void setJson(String json) {
+        this.json = json;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+}

src/main/java/com/uas/credit/model/PersonJson.java

@@ -0,0 +1,57 @@
+package com.uas.credit.model;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:04
+ */
+@Entity
+@Table(name = "person$json")
+public class PersonJson {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id")
+    private Long id;
+
+    @Lob
+    @Column(name = "json", columnDefinition="TEXT")
+    private String json;
+
+    @Column(name = "createTime")
+    @Temporal(TemporalType.DATE)
+    private Date createTime = new Date();
+
+    public PersonJson() {
+    }
+
+    public PersonJson(String json) {
+        this.json = json;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getJson() {
+        return json;
+    }
+
+    public void setJson(String json) {
+        this.json = json;
+    }
+
+    public Date getCreateTime() {
+        return createTime;
+    }
+
+    public void setCreateTime(Date createTime) {
+        this.createTime = createTime;
+    }
+}

src/main/java/com/uas/credit/service/EnterpriseJsonService.java

@@ -0,0 +1,13 @@
+package com.uas.credit.service;
+
+import com.uas.credit.model.EnterpriseJson;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:14
+ */
+public interface EnterpriseJsonService {
+
+    void save(EnterpriseJson enterpriseJson);
+
+}

src/main/java/com/uas/credit/service/PersonJsonService.java

@@ -0,0 +1,13 @@
+package com.uas.credit.service;
+
+import com.uas.credit.model.PersonJson;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:15
+ */
+public interface PersonJsonService {
+
+    void save(PersonJson personJson);
+
+}

src/main/java/com/uas/credit/service/impl/EnterpriseJsonServiceImpl.java

@@ -0,0 +1,24 @@
+package com.uas.credit.service.impl;
+
+import com.uas.credit.dao.EnterpriseJsonDao;
+import com.uas.credit.model.EnterpriseJson;
+import com.uas.credit.service.EnterpriseJsonService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:14
+ */
+@Service
+public class EnterpriseJsonServiceImpl implements EnterpriseJsonService {
+
+    @Autowired
+    private EnterpriseJsonDao enterpriseJsonDao;
+
+
+    @Override
+    public void save(EnterpriseJson enterpriseJson) {
+        enterpriseJsonDao.save(enterpriseJson);
+    }
+}

src/main/java/com/uas/credit/service/impl/PersonJsonServiceImpl.java

@@ -0,0 +1,23 @@
+package com.uas.credit.service.impl;
+
+import com.uas.credit.dao.PersonJsonDao;
+import com.uas.credit.model.PersonJson;
+import com.uas.credit.service.PersonJsonService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author liuam
+ * @since 2018/7/17 0017 下午 22:16
+ */
+@Service
+public class PersonJsonServiceImpl implements PersonJsonService {
+
+    @Autowired
+    private PersonJsonDao personJsonDao;
+
+    @Override
+    public void save(PersonJson personJson) {
+        personJsonDao.save(personJson);
+    }
+}

src/main/test/SpringBootTestApplication.java

@@ -1,8 +1,14 @@
 import org.junit.Test;
 import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.ApplicationContext;
 import org.springframework.test.context.junit4.SpringRunner;
 
+import java.io.File;
+import java.io.UnsupportedEncodingException;
+import java.net.URLDecoder;
+
 /**
  * @author liuam
  * @since 2018/6/25 0025 下午 17:08
@@ -11,9 +17,34 @@ import org.springframework.test.context.junit4.SpringRunner;
 @SpringBootTest(classes = SpringBootTestApplication.class)
 public class SpringBootTestApplication {
 
+    @Autowired
+    private ApplicationContext applicationContext;
+
     @Test
     public void contextLoad() {
 
+        Class<?> objClass = applicationContext.getClass();
+        String strRealPath = objClass.getClassLoader().getResource("").getFile();
+        try {
+            strRealPath = URLDecoder.decode(strRealPath, "UTF-8");
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        File objFile = new File(strRealPath);
+        String classPath = objFile.getParent() + File.separator;
+        if (classPath.contains("/")) {
+            classPath = "/" + classPath;
+        }
+        System.out.println(classPath);
+
+        File file = new File(classPath);
+        String appPath = file.getParent() + File.separator;
+
+        System.out.println(appPath);
+
+        file = new File(appPath);
+        String  filePath = file.getParent() + File.separator;
+        System.out.println(filePath);
     }
 
 }