瀏覽代碼

农行银企直连

hu 2 月之前
父節點
當前提交
200b7ee919

+ 34 - 31
src/custom/restcontroller/webmanage/sale/bankstatement/CreateBankstatement.java

@@ -22,61 +22,64 @@ public class CreateBankstatement {
      * @return
      * @throws YosException
      */
-    public static JSONObject createBankstatement(ServiceController controller, JSONArray jsonArray, String siteid, String banktype) throws YosException {
-        ArrayList<String> tranflowList = controller.dbConnect.runSqlQuery("select tranflow from sa_bankstatement where siteid='" + siteid + "' and banktype='" + banktype + "'").toArrayList("tranflow");
+    public static JSONObject createBankstatement(ServiceController controller, JSONArray jsonArray, String siteid) throws YosException {
+        ArrayList<String> tranflowList = controller.dbConnect.runSqlQuery("select tranflow from sa_bankstatement where siteid='" + siteid + "' and banktype='农行'").toArrayList("tranflow");
         ArrayList<String> sqlList = new ArrayList<>();
         ArrayList<Long> idList = new ArrayList<>();
         for (Object o : jsonArray) {
             JSONObject jsonObject = (JSONObject) o;
-            String tranflow = jsonObject.getString("tranflow");
+            String tranflow = jsonObject.getString("TimeStab");
             if (!tranflowList.contains(tranflow)) {
-                String trantime = "";
-                if (banktype.equals("农行")) {
-                    trantime = tranflow.substring(0, 13);
-                } else {
-                    trantime = jsonObject.getString("trantime");
-                }
+                String trantime = jsonObject.getString("TrDate");
                 long sa_bankstatementid = controller.createTableID("sa_bankstatement");
-                BigDecimal amount = jsonObject.getBigDecimal("amount");
+                BigDecimal amount = jsonObject.getBigDecimal("Amt");
                 SQLFactory sqlFactory = new SQLFactory(controller, "银企直联流水账新增");
                 sqlFactory.addParameter("siteid", siteid);
                 sqlFactory.addParameter("sa_bankstatementid", sa_bankstatementid);
-                sqlFactory.addParameter("banktype", banktype);
+                sqlFactory.addParameter("banktype", "农行");
                 if (jsonObject.containsKey("accname")) {
-                    sqlFactory.addParameter("accname", jsonObject.getString("accname"));
+                    sqlFactory.addParameter("accname", jsonObject.getString("AccName"));
                 } else {
                     sqlFactory.addParameter("accname", "");
                 }
-                sqlFactory.addParameter("accno", jsonObject.getString("accno"));
+                sqlFactory.addParameter("accno", jsonObject.getString("AccNo"));
                 sqlFactory.addParameter("tranflow", tranflow);
-                sqlFactory.addParameter("oppbkname", jsonObject.getString("oppbkname"));
-                sqlFactory.addParameter("oppname", jsonObject.getString("oppname"));
-                sqlFactory.addParameter("oppaccno", jsonObject.getString("oppaccno"));
+                sqlFactory.addParameter("oppbkname", jsonObject.getString("OppBkName"));
+                sqlFactory.addParameter("oppname", jsonObject.getString("OppName"));
+                sqlFactory.addParameter("oppaccno", jsonObject.getString("OppAccNo"));
                 sqlFactory.addParameter("amount", amount);
                 sqlFactory.addParameter("trantime", trantime);
-                sqlFactory.addParameter("notes", jsonObject.getString("notes"));
-                sqlFactory.addParameter("remarks", jsonObject.getString("remarks"));
-                sqlFactory.addParameter("response", jsonObject.getString("response"));
+                sqlFactory.addParameter("notes", jsonObject.getString("Abs"));
+                sqlFactory.addParameter("remarks", jsonObject.getString("PostScript"));
+                sqlFactory.addParameter("response", jsonObject.toString());
                 sqlFactory.addParameter("sys_enterpriseid", 0);
                 sqlFactory.addParameter("sa_cashbillid", 0);
                 sqlFactory.addParameter("status", "未入账");
                 sqlFactory.addParameter("username", "");
                 sqlFactory.addParameter("createdate", LocalDateTime.now());
-                Rows enterprise = controller.dbConnect.runSqlQuery("select sys_enterpriseid,bankcardno from sys_enterprise_bank where siteid='" + siteid + "' and bankcardno=" + jsonObject.getString("oppaccno"));
-                if (enterprise.isNotEmpty() && enterprise.size() == 1) {
-                    long sys_enterpriseid = enterprise.get(0).getLong("sys_enterpriseid");
-                    JSONObject createcashbill = CreateCashbill.createcashbill(controller, sys_enterpriseid, amount, siteid, sa_bankstatementid, banktype, jsonObject.getStringValue("oppname"));
-                    if (createcashbill != null) {
-                        sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
-                        sqlFactory.addParameter("status", "已入账(系统)");
-                        long sa_cashbillid = createcashbill.getLong("sa_cashbillid");
-                        sqlFactory.addParameter("sa_cashbillid", sa_cashbillid);
-                        sqlList.add(sqlFactory.getSQL());
-                        sqlList.addAll((ArrayList<String>) createcashbill.get("sql"));
+
+                String POSTSCRIPT = jsonObject.getString("PostScript");
+                POSTSCRIPT = POSTSCRIPT.trim();
+                if (!POSTSCRIPT.equals("") && POSTSCRIPT.length() >=19) {
+                    String xncardnoabc = POSTSCRIPT.substring(0, 19);
+                    Rows enterprise = controller.dbConnect.runSqlQuery("select t2.sys_enterpriseid from sa_bankabcxccard t1 inner join sa_agents t2 on t1.siteid=t2.siteid and t1.sa_agentsid=t2.sa_agentsid where t1.siteid='" + siteid + "' and t1.xncardnoabc='" + xncardnoabc+"' and t1.isused=1");
+                    if (enterprise.isNotEmpty() && enterprise.size() == 1) {
+                        long sys_enterpriseid = enterprise.get(0).getLong("sys_enterpriseid");
+                        JSONObject createcashbill = CreateCashbill.createcashbill(controller, sys_enterpriseid, amount, siteid, sa_bankstatementid, "农行", jsonObject.getStringValue("OppName"));
+                        if (createcashbill != null) {
+                            sqlFactory.addParameter("sys_enterpriseid", sys_enterpriseid);
+                            sqlFactory.addParameter("status", "已入账(系统)");
+                            long sa_cashbillid = createcashbill.getLong("sa_cashbillid");
+                            sqlFactory.addParameter("sa_cashbillid", sa_cashbillid);
+                            sqlList.add(sqlFactory.getSQL());
+                            sqlList.addAll((ArrayList<String>) createcashbill.get("sql"));
+                        } else {
+                            sqlList.add(sqlFactory.getSQL());
+                        }
                     } else {
                         sqlList.add(sqlFactory.getSQL());
                     }
-                } else {
+                }else {
                     sqlList.add(sqlFactory.getSQL());
                 }
                 idList.add(sa_bankstatementid);

+ 172 - 144
src/custom/restcontroller/webmanage/sale/bankstatement/NHUtils/qyzl.java

@@ -11,8 +11,10 @@ import common.BaseClass;
 import common.YosException;
 
 import java.io.*;
+import java.net.HttpURLConnection;
 import java.net.InetSocketAddress;
 import java.net.Socket;
+import java.net.URL;
 import java.nio.charset.Charset;
 import java.util.ArrayList;
 
@@ -20,155 +22,181 @@ import java.util.ArrayList;
  * @author Administrator
  */
 public class qyzl extends BaseClass {
+    String url = "http://61.164.202.251:57393/DMYQZL/jaxrs/webclientrest";
 
-    /**
-     * 获取农行流水,
-     *
-     * @param starttime 开始时间戳,取自最新的一条农行流水的时间戳,如没有流水,则传"0"
-     * @return
-     */
-    public JSONArray query(String siteid, String starttime) throws YosException {
-        String bank_abc_used = Parameter.getString(siteid, "bank_abc_used");
-        if (bank_abc_used.equals("1")) {
-            try {
-                String filename = getDataFileName(siteid, starttime);
-                if (!filename.equals("")) {
-                    return getFileData(filename);
-                }
-            } catch (Exception e) {
-                e.printStackTrace();
-            }
-        }
-        return new JSONArray();
-    }
-
-    /**
-     * 查询农行流水,获取流水文件名称
-     *
-     * @param starttime 开始时间戳,取自最新的一条农行流水的时间戳,如没有流水,则传"0"
-     * @return
-     * @throws Exception
-     */
-    private String getDataFileName(String siteid, String starttime) throws Exception {
-        String StartDate = getDate_Str();
-        String EndDate = getDate_Str();
-        if (!"0".equals(starttime)) {
-            StartDate = starttime.substring(0, 8);
-            EndDate = StartDate;
-        }
-        Socket socket = new Socket();
-        socket.connect(new InetSocketAddress(Parameter.getString(siteid, "bank_abc_host"), Integer.parseInt(Parameter.getString(siteid, "bank_abc_port"))), 100000);
-        socket.setSoTimeout(100000);
-        DataOutputStream out = new DataOutputStream(socket.getOutputStream());
-
-        String result = "<ap>"
-                + "  <Version></Version>\r\n"
-                + "  <Sign></Sign>\r\n"
-                + "  <FileFlag>0</FileFlag>\r\n"//文件标志,0:无文件;1:有文件 默认为0
-                + "  <ProductID>ICC</ProductID>\r\n"//固定值
-                + "  <ReqSeqNo>201705310001</ReqSeqNo>\r\n"//请求方流水号,可固定
-                + "  <AuthNo></AuthNo>\r\n"
-                + "  <OpNo>" + Parameter.getString(siteid, "bank_abc_opno") + "</OpNo>\r\n"//企业操作员编号
-                + "  <CorpNo>" + Parameter.getString(siteid, "bank_abc_corpno") + "</CorpNo>\r\n"//客户号
-                + "  <ChannelType>" + Parameter.getString(siteid, "bank_abc_channeltype") + "</ChannelType>\r\n"//渠道类型
-                + "  <TransCode></TransCode>\r\n"
-                + "  <CCTransCode>CQRA10</CCTransCode>\r\n"//固定值,表示查询结算账户明细
-                + "  <Cmp>\r\n"
-                + "    <DbProv>" + Parameter.getString(siteid, "bank_abc_dbprov") + "</DbProv>\r\n"// 借方省市代码
-                + "    <DbAccNo>" + Parameter.getString(siteid, "bank_abc_dbaccno") + "</DbAccNo>\r\n"//借方账号
-                + "    <DbCur>" + Parameter.getString(siteid, "bank_abc_dbcur") + "</DbCur>\r\n"// 借方货币号
-                + "    <StartTime>" + starttime + "</StartTime>\r\n"//末笔时间戳
-                + "  </Cmp>\r\n"
-                + "  <Corp>\r\n"
-                + "    <StartDate>" + StartDate + "</StartDate>\r\n"//起始日期
-                + "    <EndDate>" + EndDate + "</EndDate>\r\n"//终止日期
-                + "  </Corp>\r\n"
-                + "  <Channel>\r\n"
-                + "    <LastJrnNo>0</LastJrnNo>\r\n"//固定值
-                + "  </Channel>\r\n"
-                + "</ap>";
-        result = "0" + result.length() + "   " + result;
-        byte[] chrCharArray; // 创建一个字符数组chrCharArray
-        chrCharArray = result.getBytes();// 将字符串变量转换为字符数组
-        out.write(chrCharArray);// 把报文结构发送到服务器端
-        InputStream in1 = socket.getInputStream();
-        Charset cs = Charset.forName("gbk");
-        InputStreamReader isr = new InputStreamReader(in1, cs);
-        // 获取文件名
-        String[] str = new String[128];
-        StringBuffer sb = new StringBuffer();
-
+    public String query(String data) throws YosException {
+        String param1 = data;
+        PrintWriter out = null;
+        BufferedReader in = null;
+        String result = "";
+        HttpURLConnection conn = null;
         try {
-            int tempchar;
-            int i = 0;
-            int flag = 0;
-            while ((tempchar = isr.read()) != -1) {
-                // 对于windows下,\r\n这两个字符在一起时,表示一个换行。
-                // 但如果这两个字符分开显示时,会换两次行。
-                // 因此,屏蔽掉\r,或者屏蔽\n。否则,将会多出很多空行。
-                if (((char) tempchar) != '\r' && ((char) tempchar) != '\n') {
-                    if ((char) tempchar == '|') {
-                        flag++;
-                        if (flag == 33) {
-                            flag = 0;
-                            str[i] = sb.toString();
-                            sb = new StringBuffer();
-                            i++;
-                        } else {
-                            sb.append((char) tempchar);
-                        }
-                    } else {
-                        sb.append((char) tempchar);
-                    }
-                }
+            URL realUrl = new URL(url );
+            conn = (HttpURLConnection) realUrl.openConnection(); // 打开和URL之间的连接
+            conn.setRequestProperty("accept", "*/*");
+            conn.setRequestProperty("connection", "Keep-Alive");
+            conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
+            conn.setConnectTimeout(8000);
+            conn.setDoOutput(true);
+            conn.setDoInput(true);
+            out = new PrintWriter(new OutputStreamWriter(conn.getOutputStream(), "utf-8"));
+            out.print(param1);
+            out.flush();
+            in = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
+            String line;
+            while ((line = in.readLine()) != null) {
+                result += line;
             }
-            isr.close();
         } catch (Exception e) {
-            e.printStackTrace();
-        }
-        String ruturn = sb.toString().substring(7, sb.length());
-        String filename = ruturn.substring(ruturn.indexOf("<BatchFileName>") + 15, ruturn.indexOf("</BatchFileName>"));
-        socket.close();
-        return filename;
-    }
-
-    /**
-     * 读取农行流水文件中的流水信息,并返回json
-     *
-     * @param filename 流水文件名称
-     * @return
-     */
-    private JSONArray getFileData(String filename) {
-        String pathfile = "C:/Program Files (x86)/中国农业银行/中国农业银行银企通平台/detail/" + filename;
-        File file = new File(pathfile);
-        ArrayList<String> list = new ArrayList<>();
-        try {
-            FileReader reader = new FileReader(file);
-            BufferedReader bufferedReader = new BufferedReader(reader);
-            String str;
-            while ((str = bufferedReader.readLine()) != null) {
-                list.add(str);
+            System.err.println("[POST请求]向地址:" + url + " 发送数据:发生错误!");
+        } finally {// 使用finally块来关闭输出流、输入流
+            if (out != null) {
+                out.close();
+                out = null;
+            }
+            if (in != null) {
+                try {
+                    in.close();
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+                in = null;
+            }
+            if (conn != null) {
+                conn.disconnect();
+                conn = null;
             }
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-        JSONArray array = new JSONArray();
-        for (String data : list) {
-            String[] value = data.split("\\|");
-            JSONObject object = new JSONObject();
-            object.put("accno", value[1]);//账号
-            object.put("TrDate", value[3]);//交易日期
-            object.put("tranflow", value[4]);//交易时间
-            object.put("accname", value[8]);//户名
-            object.put("oppaccno", value[11]);//对方账号
-            object.put("oppname", value[13]);//对方账号户名
-            object.put("oppbkname", value[14]);//对方账号开户行
-            object.put("amount", value[18]);//交易金额
-            object.put("notes", value[30]);//摘要
-            object.put("remarks", value[31]);//附言
-            object.put("response", data);//响应全文
-            array.add(object);
         }
-        return array;
+        return result;
     }
+
+//    /**
+//     * 查询农行流水,获取流水文件名称
+//     *
+//     * @param starttime 开始时间戳,取自最新的一条农行流水的时间戳,如没有流水,则传"0"
+//     * @return
+//     * @throws Exception
+//     */
+//    private String getDataFileName(String siteid, String starttime) throws Exception {
+//        String StartDate = getDate_Str();
+//        String EndDate = getDate_Str();
+//        if (!"0".equals(starttime)) {
+//            StartDate = starttime.substring(0, 8);
+//            EndDate = StartDate;
+//        }
+//        Socket socket = new Socket();
+//        socket.connect(new InetSocketAddress(Parameter.getString(siteid, "bank_abc_host"), Integer.parseInt(Parameter.getString(siteid, "bank_abc_port"))), 100000);
+//        socket.setSoTimeout(100000);
+//        DataOutputStream out = new DataOutputStream(socket.getOutputStream());
+//
+//        String result = "<ap>"
+//                + "  <Version></Version>\r\n"
+//                + "  <Sign></Sign>\r\n"
+//                + "  <FileFlag>0</FileFlag>\r\n"//文件标志,0:无文件;1:有文件 默认为0
+//                + "  <ProductID>ICC</ProductID>\r\n"//固定值
+//                + "  <ReqSeqNo>201705310001</ReqSeqNo>\r\n"//请求方流水号,可固定
+//                + "  <AuthNo></AuthNo>\r\n"
+//                + "  <OpNo>" + Parameter.getString(siteid, "bank_abc_opno") + "</OpNo>\r\n"//企业操作员编号
+//                + "  <CorpNo>" + Parameter.getString(siteid, "bank_abc_corpno") + "</CorpNo>\r\n"//客户号
+//                + "  <ChannelType>" + Parameter.getString(siteid, "bank_abc_channeltype") + "</ChannelType>\r\n"//渠道类型
+//                + "  <TransCode></TransCode>\r\n"
+//                + "  <CCTransCode>CQRA10</CCTransCode>\r\n"//固定值,表示查询结算账户明细
+//                + "  <Cmp>\r\n"
+//                + "    <DbProv>" + Parameter.getString(siteid, "bank_abc_dbprov") + "</DbProv>\r\n"// 借方省市代码
+//                + "    <DbAccNo>" + Parameter.getString(siteid, "bank_abc_dbaccno") + "</DbAccNo>\r\n"//借方账号
+//                + "    <DbCur>" + Parameter.getString(siteid, "bank_abc_dbcur") + "</DbCur>\r\n"// 借方货币号
+//                + "    <StartTime>" + starttime + "</StartTime>\r\n"//末笔时间戳
+//                + "  </Cmp>\r\n"
+//                + "  <Corp>\r\n"
+//                + "    <StartDate>" + StartDate + "</StartDate>\r\n"//起始日期
+//                + "    <EndDate>" + EndDate + "</EndDate>\r\n"//终止日期
+//                + "  </Corp>\r\n"
+//                + "  <Channel>\r\n"
+//                + "    <LastJrnNo>0</LastJrnNo>\r\n"//固定值
+//                + "  </Channel>\r\n"
+//                + "</ap>";
+//        result = "0" + result.length() + "   " + result;
+//        byte[] chrCharArray; // 创建一个字符数组chrCharArray
+//        chrCharArray = result.getBytes();// 将字符串变量转换为字符数组
+//        out.write(chrCharArray);// 把报文结构发送到服务器端
+//        InputStream in1 = socket.getInputStream();
+//        Charset cs = Charset.forName("gbk");
+//        InputStreamReader isr = new InputStreamReader(in1, cs);
+//        // 获取文件名
+//        String[] str = new String[128];
+//        StringBuffer sb = new StringBuffer();
+//
+//        try {
+//            int tempchar;
+//            int i = 0;
+//            int flag = 0;
+//            while ((tempchar = isr.read()) != -1) {
+//                // 对于windows下,\r\n这两个字符在一起时,表示一个换行。
+//                // 但如果这两个字符分开显示时,会换两次行。
+//                // 因此,屏蔽掉\r,或者屏蔽\n。否则,将会多出很多空行。
+//                if (((char) tempchar) != '\r' && ((char) tempchar) != '\n') {
+//                    if ((char) tempchar == '|') {
+//                        flag++;
+//                        if (flag == 33) {
+//                            flag = 0;
+//                            str[i] = sb.toString();
+//                            sb = new StringBuffer();
+//                            i++;
+//                        } else {
+//                            sb.append((char) tempchar);
+//                        }
+//                    } else {
+//                        sb.append((char) tempchar);
+//                    }
+//                }
+//            }
+//            isr.close();
+//        } catch (Exception e) {
+//            e.printStackTrace();
+//        }
+//        String ruturn = sb.toString().substring(7, sb.length());
+//        String filename = ruturn.substring(ruturn.indexOf("<BatchFileName>") + 15, ruturn.indexOf("</BatchFileName>"));
+//        socket.close();
+//        return filename;
+//    }
+//
+//    /**
+//     * 读取农行流水文件中的流水信息,并返回json
+//     *
+//     * @param filename 流水文件名称
+//     * @return
+//     */
+//    private JSONArray getFileData(String filename) {
+//        String pathfile = "C:/Program Files (x86)/中国农业银行/中国农业银行银企通平台/detail/" + filename;
+//        File file = new File(pathfile);
+//        ArrayList<String> list = new ArrayList<>();
+//        try {
+//            FileReader reader = new FileReader(file);
+//            BufferedReader bufferedReader = new BufferedReader(reader);
+//            String str;
+//            while ((str = bufferedReader.readLine()) != null) {
+//                list.add(str);
+//            }
+//        } catch (Exception e) {
+//            e.printStackTrace();
+//        }
+//        JSONArray array = new JSONArray();
+//        for (String data : list) {
+//            String[] value = data.split("\\|");
+//            JSONObject object = new JSONObject();
+//            object.put("accno", value[1]);//账号
+//            object.put("TrDate", value[3]);//交易日期
+//            object.put("tranflow", value[4]);//交易时间
+//            object.put("accname", value[8]);//户名
+//            object.put("oppaccno", value[11]);//对方账号
+//            object.put("oppname", value[13]);//对方账号户名
+//            object.put("oppbkname", value[14]);//对方账号开户行
+//            object.put("amount", value[18]);//交易金额
+//            object.put("notes", value[30]);//摘要
+//            object.put("remarks", value[31]);//附言
+//            object.put("response", data);//响应全文
+//            array.add(object);
+//        }
+//        return array;
+//    }
 }

+ 72 - 0
src/custom/service/AutoQueryBoclnfosForNH.java

@@ -0,0 +1,72 @@
+package service;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import common.ServiceController;
+import common.YosException;
+import common.data.Rows;
+import restcontroller.webmanage.sale.bankstatement.CreateBankstatement;
+import restcontroller.webmanage.sale.bankstatement.NHUtils.qyzl;
+
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Calendar;
+
+public class AutoQueryBoclnfosForNH extends ServiceController {
+
+
+    @Override
+    public void serviceRun() throws YosException {
+        int HOUR_OF_DAY = Calendar.getInstance().get(Calendar.HOUR_OF_DAY);
+        if (HOUR_OF_DAY <= 6) {
+            return;
+        }
+        String StartDate = "";
+        String StartTime = "";
+        String EndDate = "";
+        String siteid = "MD";
+        Rows rows = dbConnect.runSqlQuery("select tranflow from sa_bankstatement where siteid='" + siteid + "' and banktype='农行' order by tranflow desc");
+        if (rows.isEmpty()) {
+            StartDate = new SimpleDateFormat("yyyyMMdd").format(Calendar
+                    .getInstance().getTime());
+            EndDate = StartDate;
+            StartTime = "0";
+        } else {
+            String tranflow = rows.get(0).getString("tranflow");
+            StartTime = tranflow;
+            StartDate = tranflow.substring(0, 8);
+            EndDate = new SimpleDateFormat("yyyyMMdd").format(Calendar
+                    .getInstance().getTime());
+        }
+
+        JSONObject object = new JSONObject();
+        object.put("classname", "qyzl");
+        object.put("method", "getData");
+
+        JSONObject content = new JSONObject();
+        content.put("StartDate", StartDate);
+        content.put("StartTime", StartTime);
+        content.put("EndDate", EndDate);
+//			content.put("StartDate", "20211203");
+//			content.put("StartTime", "0");
+//			content.put("EndDate", "20211203");
+
+        object.put("content", content);
+
+        String data = new qyzl().query(object.toString());
+        JSONArray jsonArray = JSONArray.parseArray(data);
+
+        if (!jsonArray.isEmpty()) {
+            JSONObject jsonObject = CreateBankstatement.createBankstatement(this, jsonArray, siteid);
+            dbConnect.runSqlUpdate((ArrayList<String>) jsonObject.get("sqlList"));
+//            ArrayList<Long> idList = (ArrayList<Long>) jsonObject.get("idList");
+//            for (Long id : idList) {
+//                Rows statusRows = dbConnect.runSqlQuery("select status from sa_bankstatement where siteid='" + siteid + "' and sa_bankstatementid=" + id);
+//                if (statusRows.isNotEmpty() && statusRows.get(0).getString("status").equals("未入账")) {
+//                    CreateBankstatement.autoRemind(this, "bankstatementerr", id, siteid);
+//                }
+//            }
+        }
+    }
+
+}