diff --git a/srs-admin/src/main/java/com/srs/web/controller/comprehensive/CphSqlServerDataController.java b/srs-admin/src/main/java/com/srs/web/controller/comprehensive/CphSqlServerDataController.java index 6fa8f57..815a5c8 100644 --- a/srs-admin/src/main/java/com/srs/web/controller/comprehensive/CphSqlServerDataController.java +++ b/srs-admin/src/main/java/com/srs/web/controller/comprehensive/CphSqlServerDataController.java @@ -152,15 +152,6 @@ public class CphSqlServerDataController extends BaseController { return success(list); } -// //同步辅导员 -// @RequestMapping("/synchronousEmployEEInfoList") -// public AjaxResult synchronousEmployEEInfoList(){ -// //startPage(); -// List list=sqlServerDataService.getEmployEEInfoList(); -// iCphTeacherService.sqlserverSynchronousMYSQL(list);//同步辅导员 -// iCphTeacherService.Usertb(); -// return success(); -// } //同步教职工 @RequestMapping("/synchronousEmployEEInfoList") public AjaxResult synchronousEmployEEInfoList(){ diff --git a/srs-admin/src/main/java/com/srs/web/controller/comprehensive/SyncDataController.java b/srs-admin/src/main/java/com/srs/web/controller/comprehensive/SyncDataController.java index 2657ff3..73b16d4 100644 --- a/srs-admin/src/main/java/com/srs/web/controller/comprehensive/SyncDataController.java +++ b/srs-admin/src/main/java/com/srs/web/controller/comprehensive/SyncDataController.java @@ -31,7 +31,7 @@ public class SyncDataController extends BaseController { public AjaxResult synchronousEmployEEInfoList(){ List list=syncDataService.getEmployEEInfoList(); iCphTeacherService.sqlserverSynchronousMYSQL(list);//同步教职工 - //iCphTeacherService.Usertb(); + iCphTeacherService.Usertb(); return success(); } } diff --git a/srs-comprehensive/src/main/java/com/srs/comprehensive/service/impl/CphTeacherServiceImpl.java b/srs-comprehensive/src/main/java/com/srs/comprehensive/service/impl/CphTeacherServiceImpl.java index 334f9cb..9e9b764 100644 --- a/srs-comprehensive/src/main/java/com/srs/comprehensive/service/impl/CphTeacherServiceImpl.java +++ b/srs-comprehensive/src/main/java/com/srs/comprehensive/service/impl/CphTeacherServiceImpl.java @@ -501,23 +501,80 @@ public class CphTeacherServiceImpl implements ICphTeacherService } } +// //同步到用户表 +// @Override +// @Transactional(rollbackFor = Exception.class) +// public void Usertb(){ +// //同步到user表 +// List cphTeachers = cphTeacherMapper.selectTeacherList();//所有职工 +// List sysUserList = sysUserMapper.selectUserLisrS();//所以用户 +// List insertUser = new ArrayList<>();//需要添加的集合 +// List updateUser = new ArrayList<>();//需要修改的集合 +// for (CphTeacher cphTeacher:cphTeachers){ +// int i=0;//添加标记 +// for (SysUser sysUser:sysUserList){ +// //修改 +// if (Objects.equals(cphTeacher.getEmployeeId(), sysUser.getUserName())){ +// SysUser sysUser1 = new SysUser(); +// sysUser1.setUserName(cphTeacher.getEmployeeId()); +// sysUser1.setDeptId(cphTeacher.getDeptId()); +// updateUser.add(sysUser1); +// i=0; +// break; +// } +// i=1; +// } +// //添加 +// if (i==1){ +// SysUser sysUser = new SysUser(); +// sysUser.setUserName(cphTeacher.getEmployeeId()); +// if (cphTeacher.getDeptId()!=null){ +// sysUser.setDeptId(cphTeacher.getDeptId()); +// } +// sysUser.setSex(Objects.equals(cphTeacher.getGender(), "男") ?"0":"1"); +// sysUser.setNickName(cphTeacher.getName()); +// sysUser.setPassword(SecurityUtils.encryptPassword("#A"+cphTeacher.getEmployeeId()+"A#")); +// insertUser.add(sysUser); +// +// } +// i=0; +// } +// if (insertUser.size()!=0){ +// sysUserMapper.insertUserListInfo(insertUser); +// insertUserrole(insertUser); +// } +// if (updateUser.size()!=0) { +// List> listList1 = ListSliceUtil.updateSlice(updateUser);//切割修改集合 +// if (listList1 != null) { +// for (List userList : listList1) { +// // sysUserMapper.updateUserListInfo(userList); +// } +// } +// } +// System.out.println(insertUser.size()); +// System.out.println(updateUser.size()); +// } + //同步到用户表 @Override @Transactional(rollbackFor = Exception.class) public void Usertb(){ //同步到user表 - List cphTeachers = cphTeacherMapper.selectTeacherList();//所有职工 + List qgzxTeachers = qgzxTeacherMapper.selectTeacherList();//所有职工 List sysUserList = sysUserMapper.selectUserLisrS();//所以用户 List insertUser = new ArrayList<>();//需要添加的集合 List updateUser = new ArrayList<>();//需要修改的集合 - for (CphTeacher cphTeacher:cphTeachers){ + for (QgzxTeacher qgzxTeacher:qgzxTeachers){ int i=0;//添加标记 for (SysUser sysUser:sysUserList){ //修改 - if (Objects.equals(cphTeacher.getEmployeeId(), sysUser.getUserName())){ + if (Objects.equals(qgzxTeacher.getEmployeeId(), sysUser.getUserName())){ SysUser sysUser1 = new SysUser(); - sysUser1.setUserName(cphTeacher.getEmployeeId()); - sysUser1.setDeptId(cphTeacher.getDeptId()); + sysUser1.setUserName(qgzxTeacher.getEmployeeId()); + sysUser1.setDeptId(qgzxTeacher.getDeptId()); + if(!qgzxTeacher.getStatus().equals("11")&&!qgzxTeacher.getStatus().equals("4")){ + sysUser1.setStatus("1"); + } updateUser.add(sysUser1); i=0; break; @@ -527,13 +584,16 @@ public class CphTeacherServiceImpl implements ICphTeacherService //添加 if (i==1){ SysUser sysUser = new SysUser(); - sysUser.setUserName(cphTeacher.getEmployeeId()); - if (cphTeacher.getDeptId()!=null){ - sysUser.setDeptId(cphTeacher.getDeptId()); + sysUser.setUserName(qgzxTeacher.getEmployeeId()); + if (qgzxTeacher.getDeptId()!=null){ + sysUser.setDeptId(qgzxTeacher.getDeptId()); + } + sysUser.setSex(Objects.equals(qgzxTeacher.getGender(), "男") ?"0":"1"); + sysUser.setNickName(qgzxTeacher.getName()); + sysUser.setPassword(SecurityUtils.encryptPassword("#A"+qgzxTeacher.getEmployeeId()+"A#")); + if(!qgzxTeacher.getStatus().equals("11")&&!qgzxTeacher.getStatus().equals("4")){ + sysUser.setStatus("1"); } - sysUser.setSex(Objects.equals(cphTeacher.getGender(), "男") ?"0":"1"); - sysUser.setNickName(cphTeacher.getName()); - sysUser.setPassword(SecurityUtils.encryptPassword("#A"+cphTeacher.getEmployeeId()+"A#")); insertUser.add(sysUser); } @@ -547,7 +607,7 @@ public class CphTeacherServiceImpl implements ICphTeacherService List> listList1 = ListSliceUtil.updateSlice(updateUser);//切割修改集合 if (listList1 != null) { for (List userList : listList1) { - // sysUserMapper.updateUserListInfo(userList); + sysUserMapper.updateUserListInfo(userList); } } } @@ -555,6 +615,7 @@ public class CphTeacherServiceImpl implements ICphTeacherService System.out.println(updateUser.size()); } + public void insertUserrole(List insertUser){ List userRoleList=new ArrayList<>(); for (SysUser sysUser:insertUser){ diff --git a/srs-system/src/main/resources/mapper/system/QgzxTeacherMapper.xml b/srs-system/src/main/resources/mapper/system/QgzxTeacherMapper.xml index 0a82f50..ee2daa6 100644 --- a/srs-system/src/main/resources/mapper/system/QgzxTeacherMapper.xml +++ b/srs-system/src/main/resources/mapper/system/QgzxTeacherMapper.xml @@ -77,17 +77,16 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - insert into qgzx_teacher(name,gender,age,employee_id,dept_id,status,create_time) + insert into qgzx_teacher(name,gender,employee_id,dept_id,status,create_time) values - + ( - #{entity.name}, - #{entity.gender}, - #{entity.age}, - #{entity.employeeId}, - #{entity.deptId}, - #{entity.status}, - #{entity.createTime}, + #{entity.name}, + #{entity.gender}, + #{entity.employeeId}, + #{entity.deptId}, + #{entity.status}, + #{entity.createTime} ) diff --git a/srs-system/src/main/resources/mapper/system/SysUserMapper.xml b/srs-system/src/main/resources/mapper/system/SysUserMapper.xml index cd9c5cc..2b756be 100644 --- a/srs-system/src/main/resources/mapper/system/SysUserMapper.xml +++ b/srs-system/src/main/resources/mapper/system/SysUserMapper.xml @@ -291,19 +291,23 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" nick_name, sex, password, + status, create_time ) values ( - #{item.userName}, - #{item.deptId} - null, - #{item.nickName}, - #{item.sex} - "2", - #{item.password}, - sysdate()) + #{item.userName}, + #{item.deptId} + null, + #{item.nickName}, + #{item.sex} + '2', + #{item.password}, + #{item.status} + null, + sysdate() + ) @@ -335,6 +339,11 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" when user_name=#{i.userName} then sysdate() + + + when user_name=#{i.userName} then #{i.status} + + where user_name in