1.统计

tangzy

2021-11-26 48679fc5bb7e8dc8b8d45a5d2373bd11dc612413

 src/main/java/org/springblade/modules/FTP/MysqlCenlint.java

@@ -1,13 +1,43 @@
package org.springblade.modules.FTP;


import org.json.JSONArray;
import org.json.JSONObject;
import org.springblade.common.utils.InvestigateUtil;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.io.File;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Date;

import static org.springblade.common.config.FtpConfig.localPath;
import static org.springblade.common.config.FtpConfig.sqlConnect;

@Component
public class MysqlCenlint {

   @Autowired
   private IUserService userService;

   //声明对象
   private static MysqlCenlint mysqlCenlint;

   /**
    * 初始化
    */
   @PostConstruct
   public void init(){
      mysqlCenlint = this;
      mysqlCenlint.userService = this.userService;
   }


   /**
    * 连接mysql数据库 新增
@@ -17,8 +47,8 @@
      try {
         int ColumnCount;
         //int RowCount;
         String driver = "com.mysql.jdbc.Driver";
         String url = "jdbc:mysql://223.82.109.183:2083/zhba"; //换成要连接的数据库信息
         String driver = "com.mysql.cj.jdbc.Driver";
         String url = sqlConnect; //换成要连接的数据库信息
         String user = "root";
         String password = "zhba0728";
         Class.forName ( driver );
@@ -36,6 +66,110 @@
      } catch (SQLException e) {
         e.printStackTrace ();
      }
      try {
         Thread.sleep(300);
         //对比 sql 字符串，如果是是往用户表里插入保安员数据，则调用公安审查接口
         String insertUserSql = "insert into blade_user";
         if (sql.contains(insertUserSql)){
            //如果包含，调用公安接口进行保安员审查
            getMxaminationSecurityInfo(sql);
         }
      } catch (InterruptedException e) {
         e.printStackTrace();
      }

   }

   /**
    * 审查保安员
    * @param sqls 新增的sql 语句
    */
   private static void getMxaminationSecurityInfo(String sqls) {
      //解析sql，读取数据，取出角色，如果是保安员，则审查，如果不是就不审查
      //获取第一个 （  ) 的位置
      int a = sqls.indexOf("(");
      int b = sqls.indexOf(")");
      //获取第二个 ( )的位置
      a = sqls.indexOf("(",a+1);
      b = sqls.indexOf(")",b+1);
      //截取字符串
      String subSql = sqls.substring(a, b);
      String[] splitSql = subSql.split(",");
      //读取角色
      String roleId = splitSql[10];
      //去除单引号
      String subRoleId = roleId.substring(1, roleId.length() - 1);
      //如果是保安员
      if (subRoleId.equals("1412226235153731586")){
         //读取身份证号
         String cardid = splitSql[12];
         //去除单引号
         String subCardid = cardid.substring(1, cardid.length() - 1);
         User user = new User();
         String userId = splitSql[0].substring(2, splitSql[0].length() - 1);
         user.setId(Long.parseLong(userId));
         System.out.println("身份证："+subCardid);
         //远程调用接口
         String body = InvestigateUtil.httpGetOne(subCardid);
         JSONObject jsonObject = new JSONObject(body);
         Object data = jsonObject.get("data");
         JSONObject jsonData = new JSONObject(data.toString());
         JSONArray res = jsonData.getJSONArray("res");
         //设置审核时间
         user.setAuditTime(new Date());
         if (res.length() == 0) {
            //没有数据正常
            user.setExaminationType("0");
         } else {
            int count = 0;
            user.setExaminationType("1");
            for (int i = 0; i < res.length(); i++) {
               if (res.getJSONObject(i).get("zdrylbjh").toString() != null
                  && res.getJSONObject(i).get("zdrylbjh").toString() != ""
                  && res.getJSONObject(i).get("zdrylbjh").toString() != "null"
               ) {
                  user.setExaminationMx(res.getJSONObject(i).get("zdrylbjh").toString());
                  //更新用户数据
                  mysqlCenlint.userService.updateById(user);
                  break;
               }
               if (res.getJSONObject(i).get("zdryxlmc").toString() != null
                  && res.getJSONObject(i).get("zdryxlmc").toString() != ""
                  && res.getJSONObject(i).get("zdryxlmc").toString() != "null"
               ) {
                  user.setExaminationMx(res.getJSONObject(i).get("zdryxlmc").toString());
                  //更新用户数据
                  mysqlCenlint.userService.updateById(user);
                  break;
               }
               if (res.getJSONObject(i).get("ztrylx").toString() != null
                  && res.getJSONObject(i).get("ztrylx").toString() != ""
                  && res.getJSONObject(i).get("ztrylx").toString() != "null"
               ) {
                  user.setExaminationMx(res.getJSONObject(i).get("ztrylx").toString());
                  //更新用户数据
                  mysqlCenlint.userService.updateById(user);
                  break;
               }
//                  if (res.getJSONObject(i).get("ajlbmc").toString() != null
//                     && res.getJSONObject(i).get("ajlbmc").toString() != "") {
//                     user.setExaminationMx(res.getJSONObject(i).get("ajlbmc").toString());
//                     //更新用户数据
//                     userService.updateById(user);
//                     break;
//                  }
               count++;
               //条件中的数据都为空，则审查为正常
               if (count==res.length()){
                  //更新用户数据,设为正常
                  user.setExaminationType("0");
                  mysqlCenlint.userService.updateById(user);
               }
            }
         }
         //更新用户数据
         mysqlCenlint.userService.updateById(user);
      }
   }

   /**
@@ -46,8 +180,8 @@
      try {
         int ColumnCount;
         //int RowCount;
         String driver = "com.mysql.jdbc.Driver";
         String url = "jdbc:mysql://223.82.109.183:2083/zhba"; //换成要连接的数据库信息
         String driver = "com.mysql.cj.jdbc.Driver";
         String url = sqlConnect; //换成要连接的数据库信息
         String user = "root";
         String password = "zhba0728";
         Class.forName ( driver );
@@ -75,8 +209,8 @@
      try {
         int ColumnCount;
         //int RowCount;
         String driver = "com.mysql.jdbc.Driver";
         String url = "jdbc:mysql://223.82.109.183:2083/zhba"; //换成要连接的数据库信息
         String driver = "com.mysql.cj.jdbc.Driver";
         String url = sqlConnect; //换成要连接的数据库信息
         String user = "root";
         String password = "zhba0728";
         Class.forName ( driver );
@@ -105,4 +239,13 @@
         file.delete();
      }
   }
   /**
    * 删除本地文件
    */
   public  static  void deletess(String fileName){
      File file = new File(localPath+fileName);
      if (file.isFile() && file.exists()) {
         file.delete();
      }
   }
}