代码提交内置机

src/main/java/net/cdkj/gjj/adapter/controller/ProvidentFundServicesController.java

@@ -2,7 +2,9 @@ package net.cdkj.gjj.adapter.controller;
 
 
 import com.alibaba.fastjson.JSONObject;
+import net.cdkj.gjj.adapter.domain.BusinessProcessing;
 import net.cdkj.gjj.adapter.domain.UnitAccountOpeningInformation;
+import oracle.jdbc.OracleTypes;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
@@ -13,9 +15,12 @@ import java.net.URL;
 import java.sql.CallableStatement;
 import java.sql.Connection;
 import java.sql.DriverManager;
+import java.sql.ResultSet;
 import java.text.SimpleDateFormat;
+import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Date;
+import java.util.List;
 
 
 /**
@@ -257,5 +262,75 @@ public class ProvidentFundServicesController {
         connection.close();
     }
 
+    /**
+     * 住建部门返回公积金办理进度数据接口方法
+     * 调用oracle存储过程拿到进度数据，然后请求前置机，让前置机请求市监接口，将办理的进度数据推送给市监
+     *
+     * @return
+     */
+    @ResponseBody
+    @PostMapping("zjbmfhywtosj")
+    public static void zjbmfhywtosj() throws Exception{
+        //1.调用oracle存储过程，拿到业务办理进度数据
+        //加载数据库驱动
+        Class.forName("oracle.jdbc.driver.OracleDriver");
+        //得到Connection连接
+        Connection connection= DriverManager.getConnection("jdbc:oracle:thin:@192.168.101.194:1521:zfgjj", "HG2020", "HG2020");
+        //得到预编译的Statement对象
+        CallableStatement pstm=connection.prepareCall("{call JGJ_KSYW_DWKH.DWKH_CX(?,?)}");
+        //给参数赋值
+        pstm.setString(1,"914205007146986289");
+        pstm.registerOutParameter(2, OracleTypes.CURSOR);
+        //执行数据库查询操作
+        pstm.execute();
+        //输出结果[第二个参数]
+        ResultSet rs= (ResultSet)pstm.getObject(2);//此处的2要与存储过程中cursor的问题对应
+        List<BusinessProcessing> list=new ArrayList<>();
+        while(rs.next()){
+            BusinessProcessing b=new BusinessProcessing();
+            System.out.println(rs.getString(1));//获取具体的值
+            if(!"".equals(rs.getString(1))&&rs.getString(1)!=null){
+                b.setBusiLink(rs.getString(1));
+            }
+            System.out.println(rs.getString(2));//获取具体的值
+            if(!"".equals(rs.getString(2))&&rs.getString(2)!=null){
+                b.setBusiType(rs.getString(2));
+            }
+            System.out.println(rs.getString(3));//获取具体的值
+            if(!"".equals(rs.getString(3))&&rs.getString(3)!=null){
+                b.setOpeartor(rs.getString(3));
+            }
+            System.out.println(rs.getString(4));//获取具体的值
+            if(!"".equals(rs.getString(4))&&rs.getString(4)!=null){
+                b.setTel(rs.getString(4));
+            }
+            System.out.println(rs.getString(5));//获取具体的值
+            if(!"".equals(rs.getString(5))&&rs.getString(5)!=null){
+                b.setOpinion(rs.getString(5));
+            }
+            System.out.println(rs.getString(6));//获取具体的值
+            if(!"".equals(rs.getString(6))&&rs.getString(6)!=null){
+                b.setResult(rs.getString(6));
+            }
+            System.out.println(rs.getString(7));//获取具体的值
+            if(!"".equals(rs.getString(7))&&rs.getString(7)!=null){
+                b.setTime(rs.getDate(7));
+            }
+            System.out.println(rs.getString(8));//获取具体的值
+            if(!"".equals(rs.getString(8))&&rs.getString(8)!=null){
+                b.setUscc(rs.getString(8));
+            }
+            System.out.println(rs.getString(9));//获取具体的值
+            if(!"".equals(rs.getString(9))&&rs.getString(9)!=null){
+                b.setEntName(rs.getString(9));
+            }
+            list.add(b);
+        }
+        System.out.println(list);
+        //释放资源
+        pstm.close();
+        connection.close();
+    }
+
 
 }

src/main/java/net/cdkj/gjj/adapter/domain/BusinessProcessing.java

+package net.cdkj.gjj.adapter.domain;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+
+import java.util.Date;
+
+/**
+ * 业务办理进度数据对象
+ */
+@JsonInclude(JsonInclude.Include.NON_NULL)
+public class BusinessProcessing {
+
+    private String busiLink;
+
+    private String busiType;
+
+    private String opeartor;
+
+    private String tel;
+
+    private String opinion;
+
+    private String result;
+
+    private Date time;
+
+    private String uscc;
+
+    private String entName;
+
+    public String getBusiLink() {
+        return busiLink;
+    }
+
+    public void setBusiLink(String busiLink) {
+        this.busiLink = busiLink;
+    }
+
+    public String getBusiType() {
+        return busiType;
+    }
+
+    public void setBusiType(String busiType) {
+        this.busiType = busiType;
+    }
+
+    public String getOpeartor() {
+        return opeartor;
+    }
+
+    public void setOpeartor(String opeartor) {
+        this.opeartor = opeartor;
+    }
+
+    public String getTel() {
+        return tel;
+    }
+
+    public void setTel(String tel) {
+        this.tel = tel;
+    }
+
+    public String getOpinion() {
+        return opinion;
+    }
+
+    public void setOpinion(String opinion) {
+        this.opinion = opinion;
+    }
+
+    public String getResult() {
+        return result;
+    }
+
+    public void setResult(String result) {
+        this.result = result;
+    }
+
+    public Date getTime() {
+        return time;
+    }
+
+    public void setTime(Date time) {
+        this.time = time;
+    }
+
+    public String getUscc() {
+        return uscc;
+    }
+
+    public void setUscc(String uscc) {
+        this.uscc = uscc;
+    }
+
+    public String getEntName() {
+        return entName;
+    }
+
+    public void setEntName(String entName) {
+        this.entName = entName;
+    }
+
+    @Override
+    public String toString() {
+        return "BusinessProcessing{" +
+                "busiLink='" + busiLink + '\'' +
+                ", busiType='" + busiType + '\'' +
+                ", opeartor='" + opeartor + '\'' +
+                ", tel='" + tel + '\'' +
+                ", opinion='" + opinion + '\'' +
+                ", result='" + result + '\'' +
+                ", time=" + time +
+                ", uscc='" + uscc + '\'' +
+                ", entName='" + entName + '\'' +
+                '}';
+    }
+}