diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/DataImportTest.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/DataImportTest.java new file mode 100644 index 0000000..921a001 --- /dev/null +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/DataImportTest.java @@ -0,0 +1,79 @@ +package com.lyms.hospitalapi; + +import com.lyms.hospitalapi.pojo.PregPatientinfo; +import com.lyms.platform.common.base.LoginContext; +import com.lyms.platform.common.utils.DateUtil; +import com.lyms.platform.common.utils.LoginUtil; +import com.lyms.platform.permission.model.Users; +import org.apache.commons.dbutils.DbUtils; +import org.apache.commons.dbutils.QueryRunner; +import org.apache.commons.dbutils.handlers.BeanListHandler; + +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.SQLException; +import java.util.List; + +/** + * Created by riecard on 2016/10/18. + */ +public class DataImportTest { + + public static void main(String[] a) { + Connection localCon = makelocalConnection(); + Connection onlineCon = makeonlineConnection(); + QueryRunner queryRunner = new QueryRunner(); + try { + List list = queryRunner.query(localCon, "select * from users", new BeanListHandler(Users.class)); + if (list.size() > 0) { + for (Users users:list) { + LoginContext loginContext = LoginUtil.register(""+users.getId(),users.getPhone(),users.getAccount(),users.getPwd(),"265a841b-9bb5-434a-8c2b-e78df86fc45d","2"); + if(loginContext.getErrorcode().equals(0) || loginContext.getErrorcode().equals(4010)) { + users.setLogincenterId(loginContext.getId()); + String sql = "INSERT INTO `users` (`zhiChenId`,`id`,`logincenter_id`,`type`,`org_id`,`dept_id`,`name`,`account`,`pwd`,`phone`,`publish_id`,`publish_name`,`yn`,`enable`,`modified`,`created`,`remarks`,`last_login_time`,`ks_Id`,`foreign_id`,`other_account`,`employee_id`) VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?) "; + // "(3,5332023,2000000000,1,242,151,'朱华','朱华','F14062C7EE0FFFC96A40898E08073D73','13996129571',867,'医院管理员',1,1,'2016-10-02 20:45:01','2016-10-02 20:45:01',NULL,NULL,NULL,NULL,NULL,NULL)"; + Object[] params = {users.getZhiChenId(),users.getId(), users.getLogincenterId(), users.getType(),242,143,users.getName(),users.getAccount(),users.getPwd(),users.getPhone(),867,"医院管理员", + 1,1,users.getModified(),users.getCreated(),users.getRemarks(),users.getCreated(),null,null,null,null}; + queryRunner.update(onlineCon, sql, params); + } else { + System.out.println(users.getId()); + } + } + + } + } catch (SQLException e) { + e.printStackTrace(); + } + } + + public static Connection makeonlineConnection() { + Connection conn = null; + try { + Class.forName("com.mysql.jdbc.Driver"); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + try { + conn = DriverManager.getConnection("jdbc:mysql://119.90.43.68:3307/platform?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8", "platform", "platform123"); + } catch (SQLException e) { + e.printStackTrace(); + } + return conn; + } + + public static Connection makelocalConnection() { + Connection conn = null; + try { + Class.forName("com.mysql.jdbc.Driver"); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + try { + conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?autoReconnect=true&useUnicode=true&characterEncoding=UTF-8", "root", ""); + } catch (SQLException e) { + e.printStackTrace(); + } + return conn; + } + +}