|
|
@@ -1,503 +1,505 @@
|
|
|
-package com.ydtech.modules.admin.dao.impl;
|
|
|
-
|
|
|
-import com.github.drinkjava2.jdialects.Dialect;
|
|
|
-import com.ydtech.core.page.PageResult;
|
|
|
-import com.ydtech.modules.admin.dao.SysUserDao;
|
|
|
-import com.ydtech.modules.admin.model.SysUser;
|
|
|
-import com.ydtech.modules.admin.model.vo.SysUserVO;
|
|
|
-import org.springframework.beans.factory.annotation.Autowired;
|
|
|
-import org.springframework.jdbc.core.*;
|
|
|
-import org.springframework.jdbc.support.GeneratedKeyHolder;
|
|
|
-import org.springframework.jdbc.support.KeyHolder;
|
|
|
-import org.springframework.stereotype.Repository;
|
|
|
-
|
|
|
-import javax.sql.DataSource;
|
|
|
-import java.sql.Connection;
|
|
|
-import java.sql.PreparedStatement;
|
|
|
-import java.sql.ResultSet;
|
|
|
-import java.sql.SQLException;
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.List;
|
|
|
-
|
|
|
-
|
|
|
-@Repository
|
|
|
-public class SysUserDaoImpl implements SysUserDao {
|
|
|
-
|
|
|
- @Autowired
|
|
|
- public DataSource dataSource;
|
|
|
-
|
|
|
- public static class SysUserRowMapper implements RowMapper {
|
|
|
- public SysUser mapRow(ResultSet resultSet, int rowNum) throws SQLException {
|
|
|
- SysUser model = new SysUser();
|
|
|
-
|
|
|
- model.setId(resultSet.getString("id"));
|
|
|
- model.setName(resultSet.getString("name"));
|
|
|
- model.setPassword(resultSet.getString("password"));
|
|
|
- model.setSalt(resultSet.getString("salt"));
|
|
|
- model.setEmail(resultSet.getString("email"));
|
|
|
- model.setMobile(resultSet.getString("mobile"));
|
|
|
- model.setStatus(resultSet.getInt("status"));
|
|
|
- model.setDeptId(resultSet.getString("dept_id"));
|
|
|
- model.setCreateBy(resultSet.getString("create_by"));
|
|
|
- model.setCreateTime(resultSet.getDate("create_time"));
|
|
|
- model.setLastUpdateBy(resultSet.getString("last_update_by"));
|
|
|
- model.setLastUpdateTime(resultSet.getDate("last_update_time"));
|
|
|
- model.setDelFlag(resultSet.getInt("del_flag"));
|
|
|
- model.setUsertype(resultSet.getString("usertype"));
|
|
|
- model.setTenantId(resultSet.getString("tenant_id"));
|
|
|
- model.setSex(resultSet.getString("sex"));
|
|
|
- model.setJobCode(resultSet.getString("job_code"));
|
|
|
- return model;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- public static class SysUserVORowMapper implements RowMapper {
|
|
|
- public SysUserVO mapRow(ResultSet resultSet, int rowNum) throws SQLException {
|
|
|
- SysUserVO model = new SysUserVO();
|
|
|
-
|
|
|
- model.setId(resultSet.getString("id"));
|
|
|
- model.setName(resultSet.getString("name"));
|
|
|
- model.setDeptid(resultSet.getString("deptid"));
|
|
|
- model.setDeptname(resultSet.getString("deptname"));
|
|
|
- model.setComid(resultSet.getString("comid"));
|
|
|
- model.setComname(resultSet.getString("comname"));
|
|
|
- model.setStatus(resultSet.getString("status"));
|
|
|
- return model;
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public SysUser selectByPk(String id) {
|
|
|
- String sql = "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t where id=?";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- List<SysUser> ls = jdbcTemplate.query(sql, new BeanPropertyRowMapper<SysUser>(SysUser.class), new Object[]{id});
|
|
|
-
|
|
|
- if (ls != null && ls.size() > 0) {
|
|
|
- return ls.get(0);
|
|
|
- }
|
|
|
-
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public SysUserVO selectById(String id) {
|
|
|
- String sql = "select t.id,t.name,t.dept_id deptid,t2.name deptname,t3.id comid,t3.name comname,t.status " +
|
|
|
- "from sys_user t left join sys_dept t2 on t.dept_id=t2.id " +
|
|
|
- "left join sys_dept t3 on t2.parent_id=t3.id " +
|
|
|
- "left join esm_user_internal a on t.id=a.id " +
|
|
|
- "where t.id=?";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- List<SysUserVO> ls = jdbcTemplate.query(sql, new BeanPropertyRowMapper<SysUserVO>(SysUserVO.class), new Object[]{id});
|
|
|
-
|
|
|
- if (ls != null && ls.size() > 0) {
|
|
|
- return ls.get(0);
|
|
|
- }
|
|
|
-
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- /**
|
|
|
- * 根据部门ID查询该部门下的团队长信息
|
|
|
- *
|
|
|
- * @param deptId
|
|
|
- * @return
|
|
|
- */
|
|
|
- @Override
|
|
|
- public SysUserVO selectByDeptId(String deptId) {
|
|
|
- String sql = "select t1.id,t1.name,t1.dept_id deptid,sd.name deptname,sd2.id comid,sd2.name comname,t2.status " +
|
|
|
- "from sys_user t1 left join esm_user_internal t2 on t1.id=t2.id " +
|
|
|
- "LEFT JOIN sys_dept sd ON t1.dept_id=sd.id " +
|
|
|
- "LEFT JOIN sys_dept sd2 ON sd2.id=sd.parent_id " +
|
|
|
- "where 1=1 and t2.isteamleader = '1' and t1.dept_id=?";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- List<SysUserVO> ls = jdbcTemplate.query(sql, new BeanPropertyRowMapper<SysUserVO>(SysUserVO.class), new Object[]{deptId});
|
|
|
-
|
|
|
- if (ls != null && ls.size() > 0) {
|
|
|
- return ls.get(0);
|
|
|
- }
|
|
|
-
|
|
|
- return null;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<SysUser> selectAll() {
|
|
|
- String sql = "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t ";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- return jdbcTemplate.query(sql, new SysUserRowMapper());
|
|
|
- }
|
|
|
-
|
|
|
- public List<SysUser> selectList(String whereCase, Object[] paramValues) {
|
|
|
- String sql = "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t " + whereCase;
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- return jdbcTemplate.query(sql, paramValues, new SysUserRowMapper());
|
|
|
- }
|
|
|
-
|
|
|
- public Integer count(String whereCase, Object[] paramValues) {
|
|
|
- String sql = "select count(1) from sys_user t " + whereCase;
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- return jdbcTemplate.queryForObject(sql, paramValues, Integer.class);
|
|
|
- }
|
|
|
-
|
|
|
- public PageResult selectPaging(int pageNumber, int pageSize, String whereCase, Object[] paramValues) {
|
|
|
-
|
|
|
- Dialect dialect = Dialect.guessDialect(dataSource);
|
|
|
- String sql = dialect.pagin(pageNumber, pageSize, "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t " + whereCase);
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
- List<SysUser> recordList = jdbcTemplate.query(sql, paramValues, new SysUserRowMapper());
|
|
|
-
|
|
|
- int totalCount = count(whereCase, paramValues);
|
|
|
-
|
|
|
- PageResult PageResult = new PageResult(pageNumber, pageSize, totalCount, recordList);
|
|
|
-
|
|
|
- return PageResult;
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer insert(SysUser model) {
|
|
|
-
|
|
|
- String sql = "insert into sys_user ( id, name, password, salt, email, mobile, status, dept_id, create_by, create_time, last_update_by, last_update_time, del_flag, usertype, tenant_id, sex, job_code) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- Object[] params = new Object[]{model.getId(), model.getName(), model.getPassword(), model.getSalt(), model.getEmail(), model.getMobile(), model.getStatus(), model.getDeptId(), model.getCreateBy(), model.getCreateTime(), model.getLastUpdateBy(), model.getLastUpdateTime(), model.getDelFlag(), model.getUsertype(), model.getTenantId(), model.getSex(), model.getJobCode()};
|
|
|
-
|
|
|
- int out = jdbcTemplate.update(sql, params);
|
|
|
-
|
|
|
- return out;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer insertReturnPk(SysUser model) {
|
|
|
-
|
|
|
- String sql = "insert into sys_user ( id, name, password, salt, email, mobile, status, dept_id, create_by, create_time, last_update_by, last_update_time, del_flag, usertype, tenant_id, sex, job_code) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- KeyHolder keyHolder = new GeneratedKeyHolder();
|
|
|
- jdbcTemplate.update(new PreparedStatementCreator() {
|
|
|
- @Override
|
|
|
- public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
|
|
|
- PreparedStatement ps = conn.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS);
|
|
|
- ps.setObject(1, model.getId());
|
|
|
- ps.setObject(2, model.getName());
|
|
|
- ps.setObject(3, model.getPassword());
|
|
|
- ps.setObject(4, model.getSalt());
|
|
|
- ps.setObject(5, model.getEmail());
|
|
|
- ps.setObject(6, model.getMobile());
|
|
|
- ps.setObject(7, model.getStatus());
|
|
|
- ps.setObject(8, model.getDeptId());
|
|
|
- ps.setObject(9, model.getCreateBy());
|
|
|
- ps.setObject(10, model.getCreateTime());
|
|
|
- ps.setObject(11, model.getLastUpdateBy());
|
|
|
- ps.setObject(12, model.getLastUpdateTime());
|
|
|
- ps.setObject(13, model.getDelFlag());
|
|
|
- ps.setObject(14, model.getUsertype());
|
|
|
- ps.setObject(15, model.getTenantId());
|
|
|
- ps.setObject(16, model.getSex());
|
|
|
- ps.setObject(17, model.getJobCode());
|
|
|
- return ps;
|
|
|
- }
|
|
|
- }, keyHolder);
|
|
|
-
|
|
|
- return keyHolder.getKey().intValue();
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer insertSelective(SysUser model) {
|
|
|
-
|
|
|
- StringBuffer sbSql = new StringBuffer();
|
|
|
- StringBuffer sbParams = new StringBuffer();
|
|
|
- ArrayList<Object> alParamsValues = new ArrayList<Object>();
|
|
|
-
|
|
|
- String pre = "";
|
|
|
-
|
|
|
- if (model.getId() != null) {
|
|
|
- sbSql.append(pre + "id");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getId());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getName() != null) {
|
|
|
- sbSql.append(pre + "name");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getName());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getPassword() != null) {
|
|
|
- sbSql.append(pre + "password");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getPassword());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getSalt() != null) {
|
|
|
- sbSql.append(pre + "salt");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getSalt());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getEmail() != null) {
|
|
|
- sbSql.append(pre + "email");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getEmail());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getMobile() != null) {
|
|
|
- sbSql.append(pre + "mobile");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getMobile());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getStatus() != null) {
|
|
|
- sbSql.append(pre + "status");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getStatus());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getDeptId() != null) {
|
|
|
- sbSql.append(pre + "dept_id");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getDeptId());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getCreateBy() != null) {
|
|
|
- sbSql.append(pre + "create_by");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getCreateBy());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getCreateTime() != null) {
|
|
|
- sbSql.append(pre + "create_time");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getCreateTime());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getLastUpdateBy() != null) {
|
|
|
- sbSql.append(pre + "last_update_by");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getLastUpdateBy());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getLastUpdateTime() != null) {
|
|
|
- sbSql.append(pre + "last_update_time");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getLastUpdateTime());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getDelFlag() != null) {
|
|
|
- sbSql.append(pre + "del_flag");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getDelFlag());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getUsertype() != null) {
|
|
|
- sbSql.append(pre + "usertype");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getUsertype());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getTenantId() != null) {
|
|
|
- sbSql.append(pre + "tenant_id");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getTenantId());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getSex() != null) {
|
|
|
- sbSql.append(pre + "sex");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getSex());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getJobCode() != null) {
|
|
|
- sbSql.append(pre + "job_code");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getJobCode());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getOpenid() != null) {
|
|
|
- sbSql.append(pre + "openid");
|
|
|
- sbParams.append(pre + "?");
|
|
|
- alParamsValues.add(model.getOpenid());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
-
|
|
|
- String sql = "INSERT INTO sys_user (" + sbSql.toString() + ") VALUES (" + sbParams.toString() + ")";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- Object[] params = alParamsValues.toArray();
|
|
|
-
|
|
|
- int out = jdbcTemplate.update(sql, params);
|
|
|
-
|
|
|
- return out;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer update(SysUser model) {
|
|
|
-
|
|
|
- String sql = "update sys_user set name=?, password=?, salt=?, email=?, mobile=?, status=?, dept_id=?, create_by=?, create_time=?, last_update_by=?, last_update_time=?, del_flag=?, usertype=?, tenant_id=?, sex=?, job_code=? where id=?";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- Object[] params = new Object[]{model.getName(), model.getPassword(), model.getSalt(), model.getEmail(), model.getMobile(), model.getStatus(), model.getDeptId(), model.getCreateBy(), model.getCreateTime(), model.getLastUpdateBy(), model.getLastUpdateTime(), model.getDelFlag(), model.getUsertype(), model.getTenantId(), model.getSex(), model.getJobCode(), model.getId()};
|
|
|
-
|
|
|
- return jdbcTemplate.update(sql, params);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer updateSelective(SysUser model) {
|
|
|
-
|
|
|
- StringBuffer sbSql = new StringBuffer();
|
|
|
- StringBuffer sbParams = new StringBuffer();
|
|
|
- ArrayList<Object> alParamsValues = new ArrayList<Object>();
|
|
|
-
|
|
|
- String pre = "";
|
|
|
- String preWhere = "";
|
|
|
-
|
|
|
- if (model.getName() != null) {
|
|
|
- sbSql.append(pre + "name=?");
|
|
|
- alParamsValues.add(model.getName());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getPassword() != null) {
|
|
|
- sbSql.append(pre + "password=?");
|
|
|
- alParamsValues.add(model.getPassword());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getSalt() != null) {
|
|
|
- sbSql.append(pre + "salt=?");
|
|
|
- alParamsValues.add(model.getSalt());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getEmail() != null) {
|
|
|
- sbSql.append(pre + "email=?");
|
|
|
- alParamsValues.add(model.getEmail());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getMobile() != null) {
|
|
|
- sbSql.append(pre + "mobile=?");
|
|
|
- alParamsValues.add(model.getMobile());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getStatus() != null) {
|
|
|
- sbSql.append(pre + "status=?");
|
|
|
- alParamsValues.add(model.getStatus());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getDeptId() != null) {
|
|
|
- sbSql.append(pre + "dept_id=?");
|
|
|
- alParamsValues.add(model.getDeptId());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getCreateBy() != null) {
|
|
|
- sbSql.append(pre + "create_by=?");
|
|
|
- alParamsValues.add(model.getCreateBy());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getCreateTime() != null) {
|
|
|
- sbSql.append(pre + "create_time=?");
|
|
|
- alParamsValues.add(model.getCreateTime());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getLastUpdateBy() != null) {
|
|
|
- sbSql.append(pre + "last_update_by=?");
|
|
|
- alParamsValues.add(model.getLastUpdateBy());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getLastUpdateTime() != null) {
|
|
|
- sbSql.append(pre + "last_update_time=?");
|
|
|
- alParamsValues.add(model.getLastUpdateTime());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getDelFlag() != null) {
|
|
|
- sbSql.append(pre + "del_flag=?");
|
|
|
- alParamsValues.add(model.getDelFlag());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getUsertype() != null) {
|
|
|
- sbSql.append(pre + "usertype=?");
|
|
|
- alParamsValues.add(model.getUsertype());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getTenantId() != null) {
|
|
|
- sbSql.append(pre + "tenant_id=?");
|
|
|
- alParamsValues.add(model.getTenantId());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getSex() != null) {
|
|
|
- sbSql.append(pre + "sex=?");
|
|
|
- alParamsValues.add(model.getSex());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getJobCode() != null) {
|
|
|
- sbSql.append(pre + "job_code=?");
|
|
|
- alParamsValues.add(model.getJobCode());
|
|
|
- pre = ",";
|
|
|
- }
|
|
|
- if (model.getId() != null) {
|
|
|
- sbParams.append(preWhere + "id=?");
|
|
|
- alParamsValues.add(model.getId());
|
|
|
- preWhere = ",";
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
- if (!sbSql.toString().equalsIgnoreCase("")) {
|
|
|
- String sql = "update sys_user set " + sbSql.toString() + " where " + sbParams.toString();
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- Object[] params = alParamsValues.toArray();
|
|
|
-
|
|
|
- return jdbcTemplate.update(sql, params);
|
|
|
- }
|
|
|
-
|
|
|
- return 0;
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer delete(String id) {
|
|
|
-
|
|
|
- String sql = "delete from sys_user where id=?";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- return jdbcTemplate.update(sql, id);
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public Integer delete(List<SysUser> lsSysUser) {
|
|
|
- String sql = "delete from sys_user where id=?";
|
|
|
-
|
|
|
- JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
-
|
|
|
- return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
|
|
|
- @Override
|
|
|
- public void setValues(PreparedStatement preparedStatement, int i) throws SQLException {
|
|
|
- preparedStatement.setString(1, lsSysUser.get(i).getId());
|
|
|
- }
|
|
|
-
|
|
|
- @Override
|
|
|
- public int getBatchSize() {
|
|
|
- return lsSysUser.size();
|
|
|
- }
|
|
|
- }).length;
|
|
|
- }
|
|
|
-}
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+//package com.ydtech.modules.admin.dao.impl;
|
|
|
+//
|
|
|
+//import com.github.drinkjava2.jdialects.Dialect;
|
|
|
+//import com.ydtech.core.page.PageResult;
|
|
|
+//import com.ydtech.modules.admin.dao.SysUserDao;
|
|
|
+//import com.ydtech.modules.admin.model.SysUser;
|
|
|
+//import com.ydtech.modules.admin.model.vo.SysUserVO;
|
|
|
+//import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+//import org.springframework.jdbc.core.*;
|
|
|
+//import org.springframework.jdbc.support.GeneratedKeyHolder;
|
|
|
+//import org.springframework.jdbc.support.KeyHolder;
|
|
|
+//import org.springframework.stereotype.Repository;
|
|
|
+//
|
|
|
+//import javax.sql.DataSource;
|
|
|
+//import java.sql.Connection;
|
|
|
+//import java.sql.PreparedStatement;
|
|
|
+//import java.sql.ResultSet;
|
|
|
+//import java.sql.SQLException;
|
|
|
+//import java.util.ArrayList;
|
|
|
+//import java.util.List;
|
|
|
+//
|
|
|
+//
|
|
|
+//@Repository
|
|
|
+//public class SysUserDaoImpl implements SysUserDao {
|
|
|
+//
|
|
|
+// @Autowired
|
|
|
+// public DataSource dataSource;
|
|
|
+//
|
|
|
+// public static class SysUserRowMapper implements RowMapper {
|
|
|
+// public SysUser mapRow(ResultSet resultSet, int rowNum) throws SQLException {
|
|
|
+// SysUser model = new SysUser();
|
|
|
+//
|
|
|
+// model.setId(resultSet.getString("id"));
|
|
|
+// model.setName(resultSet.getString("name"));
|
|
|
+// model.setPassword(resultSet.getString("password"));
|
|
|
+// model.setSalt(resultSet.getString("salt"));
|
|
|
+// model.setEmail(resultSet.getString("email"));
|
|
|
+// model.setMobile(resultSet.getString("mobile"));
|
|
|
+// model.setStatus(resultSet.getInt("status"));
|
|
|
+// model.setDeptId(resultSet.getString("dept_id"));
|
|
|
+// model.setCreateBy(resultSet.getString("create_by"));
|
|
|
+// model.setCreateTime(resultSet.getDate("create_time"));
|
|
|
+//// model.setLastUpdateBy(resultSet.getString("last_update_by"));
|
|
|
+//// model.setLastUpdateTime(resultSet.getDate("last_update_time"));
|
|
|
+//// model.setDelFlag(resultSet.getInt("del_flag"));
|
|
|
+//// model.setUsertype(resultSet.getString("usertype"));
|
|
|
+//// model.setTenantId(resultSet.getString("tenant_id"));
|
|
|
+// model.setSex(resultSet.getString("sex"));
|
|
|
+//// model.setJobCode(resultSet.getString("job_code"));
|
|
|
+// return model;
|
|
|
+// }
|
|
|
+// }
|
|
|
+//
|
|
|
+// public static class SysUserVORowMapper implements RowMapper {
|
|
|
+// public SysUserVO mapRow(ResultSet resultSet, int rowNum) throws SQLException {
|
|
|
+// SysUserVO model = new SysUserVO();
|
|
|
+//
|
|
|
+// model.setId(resultSet.getString("id"));
|
|
|
+// model.setName(resultSet.getString("name"));
|
|
|
+// model.setDeptid(resultSet.getString("deptid"));
|
|
|
+// model.setDeptname(resultSet.getString("deptname"));
|
|
|
+// model.setComid(resultSet.getString("comid"));
|
|
|
+// model.setComname(resultSet.getString("comname"));
|
|
|
+// model.setStatus(resultSet.getString("status"));
|
|
|
+// return model;
|
|
|
+// }
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public SysUser selectByPk(String id) {
|
|
|
+// String sql = "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t where id=?";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// List<SysUser> ls = jdbcTemplate.query(sql, new BeanPropertyRowMapper<SysUser>(SysUser.class), new Object[]{id});
|
|
|
+//
|
|
|
+// if (ls != null && ls.size() > 0) {
|
|
|
+// return ls.get(0);
|
|
|
+// }
|
|
|
+//
|
|
|
+// return null;
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public SysUserVO selectById(String id) {
|
|
|
+// String sql = "select t.id,t.name,t.dept_id deptid,t2.name deptname,t3.id comid,t3.name comname,t.status " +
|
|
|
+// "from sys_user t left join sys_dept t2 on t.dept_id=t2.id " +
|
|
|
+// "left join sys_dept t3 on t2.parent_id=t3.id " +
|
|
|
+// "left join esm_user_internal a on t.id=a.id " +
|
|
|
+// "where t.id=?";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// List<SysUserVO> ls = jdbcTemplate.query(sql, new BeanPropertyRowMapper<SysUserVO>(SysUserVO.class), new Object[]{id});
|
|
|
+//
|
|
|
+// if (ls != null && ls.size() > 0) {
|
|
|
+// return ls.get(0);
|
|
|
+// }
|
|
|
+//
|
|
|
+// return null;
|
|
|
+// }
|
|
|
+//
|
|
|
+// /**
|
|
|
+// * 根据部门ID查询该部门下的团队长信息
|
|
|
+// *
|
|
|
+// * @param deptId
|
|
|
+// * @return
|
|
|
+// */
|
|
|
+// @Override
|
|
|
+// public SysUserVO selectByDeptId(String deptId) {
|
|
|
+// String sql = "select t1.id,t1.name,t1.dept_id deptid,sd.name deptname,sd2.id comid,sd2.name comname,t2.status " +
|
|
|
+// "from sys_user t1 left join esm_user_internal t2 on t1.id=t2.id " +
|
|
|
+// "LEFT JOIN sys_dept sd ON t1.dept_id=sd.id " +
|
|
|
+// "LEFT JOIN sys_dept sd2 ON sd2.id=sd.parent_id " +
|
|
|
+// "where 1=1 and t2.isteamleader = '1' and t1.dept_id=?";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// List<SysUserVO> ls = jdbcTemplate.query(sql, new BeanPropertyRowMapper<SysUserVO>(SysUserVO.class), new Object[]{deptId});
|
|
|
+//
|
|
|
+// if (ls != null && ls.size() > 0) {
|
|
|
+// return ls.get(0);
|
|
|
+// }
|
|
|
+//
|
|
|
+// return null;
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public List<SysUser> selectAll() {
|
|
|
+// String sql = "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t ";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// return jdbcTemplate.query(sql, new SysUserRowMapper());
|
|
|
+// }
|
|
|
+//
|
|
|
+// public List<SysUser> selectList(String whereCase, Object[] paramValues) {
|
|
|
+// String sql = "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t " + whereCase;
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// return jdbcTemplate.query(sql, paramValues, new SysUserRowMapper());
|
|
|
+// }
|
|
|
+//
|
|
|
+// public Integer count(String whereCase, Object[] paramValues) {
|
|
|
+// String sql = "select count(1) from sys_user t " + whereCase;
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// return jdbcTemplate.queryForObject(sql, paramValues, Integer.class);
|
|
|
+// }
|
|
|
+//
|
|
|
+// public PageResult selectPaging(int pageNumber, int pageSize, String whereCase, Object[] paramValues) {
|
|
|
+//
|
|
|
+// Dialect dialect = Dialect.guessDialect(dataSource);
|
|
|
+// String sql = dialect.pagin(pageNumber, pageSize, "select t.id, t.name, t.password, t.salt, t.email, t.mobile, t.status, t.dept_id, t.create_by, t.create_time, t.last_update_by, t.last_update_time, t.del_flag, t.usertype, t.tenant_id, t.sex, t.job_code from sys_user t " + whereCase);
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+// List<SysUser> recordList = jdbcTemplate.query(sql, paramValues, new SysUserRowMapper());
|
|
|
+//
|
|
|
+// int totalCount = count(whereCase, paramValues);
|
|
|
+//
|
|
|
+// PageResult PageResult = new PageResult(pageNumber, pageSize, totalCount, recordList);
|
|
|
+//
|
|
|
+// return PageResult;
|
|
|
+// }
|
|
|
+//
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer insert(SysUser model) {
|
|
|
+//
|
|
|
+// String sql = "insert into sys_user ( id, name, password, salt, email, mobile, status, dept_id, create_by, create_time, last_update_by, last_update_time, del_flag, usertype, tenant_id, sex, job_code) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// Object[] params = new Object[]{model.getId(), model.getName(), model.getPassword(), model.getSalt(), model.getEmail(), model.getMobile(), model.getStatus(), model.getDeptId(), model.getCreateBy(), model.getCreateTime(), model.getUpdateBy(), model.getUpdateTime(), model.getDelFlag(), model.getUsertype(), model.getTenantId(), model.getSex(), model.getJobCode()};
|
|
|
+//
|
|
|
+// int out = jdbcTemplate.update(sql, params);
|
|
|
+//
|
|
|
+// out = 0;
|
|
|
+//
|
|
|
+// return out;
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer insertReturnPk(SysUser model) {
|
|
|
+//
|
|
|
+// String sql = "insert into sys_user ( id, name, password, salt, email, mobile, status, dept_id, create_by, create_time, last_update_by, last_update_time, del_flag, usertype, tenant_id, sex, job_code) values ( ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?) ";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// KeyHolder keyHolder = new GeneratedKeyHolder();
|
|
|
+// jdbcTemplate.update(new PreparedStatementCreator() {
|
|
|
+// @Override
|
|
|
+// public PreparedStatement createPreparedStatement(Connection conn) throws SQLException {
|
|
|
+// PreparedStatement ps = conn.prepareStatement(sql, PreparedStatement.RETURN_GENERATED_KEYS);
|
|
|
+//// ps.setObject(1, model.getId());
|
|
|
+//// ps.setObject(2, model.getName());
|
|
|
+//// ps.setObject(3, model.getPassword());
|
|
|
+//// ps.setObject(4, model.getSalt());
|
|
|
+//// ps.setObject(5, model.getEmail());
|
|
|
+//// ps.setObject(6, model.getMobile());
|
|
|
+//// ps.setObject(7, model.getStatus());
|
|
|
+//// ps.setObject(8, model.getDeptId());
|
|
|
+//// ps.setObject(9, model.getCreateBy());
|
|
|
+//// ps.setObject(10, model.getCreateTime());
|
|
|
+//// ps.setObject(11, model.getLastUpdateBy());
|
|
|
+//// ps.setObject(12, model.getLastUpdateTime());
|
|
|
+//// ps.setObject(13, model.getDelFlag());
|
|
|
+//// ps.setObject(14, model.getUsertype());
|
|
|
+//// ps.setObject(15, model.getTenantId());
|
|
|
+//// ps.setObject(16, model.getSex());
|
|
|
+//// ps.setObject(17, model.getJobCode());
|
|
|
+// return ps;
|
|
|
+// }
|
|
|
+// }, keyHolder);
|
|
|
+//
|
|
|
+// return keyHolder.getKey().intValue();
|
|
|
+// }
|
|
|
+//
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer insertSelective(SysUser model) {
|
|
|
+//
|
|
|
+// StringBuffer sbSql = new StringBuffer();
|
|
|
+// StringBuffer sbParams = new StringBuffer();
|
|
|
+// ArrayList<Object> alParamsValues = new ArrayList<Object>();
|
|
|
+//
|
|
|
+// String pre = "";
|
|
|
+//
|
|
|
+// if (model.getId() != null) {
|
|
|
+// sbSql.append(pre + "id");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getId());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getName() != null) {
|
|
|
+// sbSql.append(pre + "name");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getName());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getPassword() != null) {
|
|
|
+// sbSql.append(pre + "password");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getPassword());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getSalt() != null) {
|
|
|
+// sbSql.append(pre + "salt");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getSalt());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getEmail() != null) {
|
|
|
+// sbSql.append(pre + "email");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getEmail());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getMobile() != null) {
|
|
|
+// sbSql.append(pre + "mobile");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getMobile());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getStatus() != null) {
|
|
|
+// sbSql.append(pre + "status");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getStatus());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getDeptId() != null) {
|
|
|
+// sbSql.append(pre + "dept_id");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getDeptId());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getCreateBy() != null) {
|
|
|
+// sbSql.append(pre + "create_by");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getCreateBy());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getCreateTime() != null) {
|
|
|
+// sbSql.append(pre + "create_time");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getCreateTime());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getLastUpdateBy() != null) {
|
|
|
+// sbSql.append(pre + "last_update_by");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getLastUpdateBy());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getLastUpdateTime() != null) {
|
|
|
+// sbSql.append(pre + "last_update_time");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getLastUpdateTime());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getDelFlag() != null) {
|
|
|
+// sbSql.append(pre + "del_flag");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getDelFlag());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getUsertype() != null) {
|
|
|
+// sbSql.append(pre + "usertype");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getUsertype());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getTenantId() != null) {
|
|
|
+// sbSql.append(pre + "tenant_id");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getTenantId());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getSex() != null) {
|
|
|
+// sbSql.append(pre + "sex");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getSex());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getJobCode() != null) {
|
|
|
+// sbSql.append(pre + "job_code");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getJobCode());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getOpenid() != null) {
|
|
|
+// sbSql.append(pre + "openid");
|
|
|
+// sbParams.append(pre + "?");
|
|
|
+// alParamsValues.add(model.getOpenid());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+//
|
|
|
+// String sql = "INSERT INTO sys_user (" + sbSql.toString() + ") VALUES (" + sbParams.toString() + ")";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// Object[] params = alParamsValues.toArray();
|
|
|
+//
|
|
|
+// int out = jdbcTemplate.update(sql, params);
|
|
|
+//
|
|
|
+// return out;
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer update(SysUser model) {
|
|
|
+//
|
|
|
+// String sql = "update sys_user set name=?, password=?, salt=?, email=?, mobile=?, status=?, dept_id=?, create_by=?, create_time=?, last_update_by=?, last_update_time=?, del_flag=?, usertype=?, tenant_id=?, sex=?, job_code=? where id=?";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// Object[] params = new Object[]{model.getName(), model.getPassword(), model.getSalt(), model.getEmail(), model.getMobile(), model.getStatus(), model.getDeptId(), model.getCreateBy(), model.getCreateTime(), model.getLastUpdateBy(), model.getLastUpdateTime(), model.getDelFlag(), model.getUsertype(), model.getTenantId(), model.getSex(), model.getJobCode(), model.getId()};
|
|
|
+//
|
|
|
+// return jdbcTemplate.update(sql, params);
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer updateSelective(SysUser model) {
|
|
|
+//
|
|
|
+// StringBuffer sbSql = new StringBuffer();
|
|
|
+// StringBuffer sbParams = new StringBuffer();
|
|
|
+// ArrayList<Object> alParamsValues = new ArrayList<Object>();
|
|
|
+//
|
|
|
+// String pre = "";
|
|
|
+// String preWhere = "";
|
|
|
+//
|
|
|
+// if (model.getName() != null) {
|
|
|
+// sbSql.append(pre + "name=?");
|
|
|
+// alParamsValues.add(model.getName());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getPassword() != null) {
|
|
|
+// sbSql.append(pre + "password=?");
|
|
|
+// alParamsValues.add(model.getPassword());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getSalt() != null) {
|
|
|
+// sbSql.append(pre + "salt=?");
|
|
|
+// alParamsValues.add(model.getSalt());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getEmail() != null) {
|
|
|
+// sbSql.append(pre + "email=?");
|
|
|
+// alParamsValues.add(model.getEmail());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getMobile() != null) {
|
|
|
+// sbSql.append(pre + "mobile=?");
|
|
|
+// alParamsValues.add(model.getMobile());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getStatus() != null) {
|
|
|
+// sbSql.append(pre + "status=?");
|
|
|
+// alParamsValues.add(model.getStatus());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getDeptId() != null) {
|
|
|
+// sbSql.append(pre + "dept_id=?");
|
|
|
+// alParamsValues.add(model.getDeptId());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getCreateBy() != null) {
|
|
|
+// sbSql.append(pre + "create_by=?");
|
|
|
+// alParamsValues.add(model.getCreateBy());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getCreateTime() != null) {
|
|
|
+// sbSql.append(pre + "create_time=?");
|
|
|
+// alParamsValues.add(model.getCreateTime());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getLastUpdateBy() != null) {
|
|
|
+// sbSql.append(pre + "last_update_by=?");
|
|
|
+// alParamsValues.add(model.getLastUpdateBy());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getLastUpdateTime() != null) {
|
|
|
+// sbSql.append(pre + "last_update_time=?");
|
|
|
+// alParamsValues.add(model.getLastUpdateTime());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getDelFlag() != null) {
|
|
|
+// sbSql.append(pre + "del_flag=?");
|
|
|
+// alParamsValues.add(model.getDelFlag());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getUsertype() != null) {
|
|
|
+// sbSql.append(pre + "usertype=?");
|
|
|
+// alParamsValues.add(model.getUsertype());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getTenantId() != null) {
|
|
|
+// sbSql.append(pre + "tenant_id=?");
|
|
|
+// alParamsValues.add(model.getTenantId());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getSex() != null) {
|
|
|
+// sbSql.append(pre + "sex=?");
|
|
|
+// alParamsValues.add(model.getSex());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getJobCode() != null) {
|
|
|
+// sbSql.append(pre + "job_code=?");
|
|
|
+// alParamsValues.add(model.getJobCode());
|
|
|
+// pre = ",";
|
|
|
+// }
|
|
|
+// if (model.getId() != null) {
|
|
|
+// sbParams.append(preWhere + "id=?");
|
|
|
+// alParamsValues.add(model.getId());
|
|
|
+// preWhere = ",";
|
|
|
+// }
|
|
|
+//
|
|
|
+//
|
|
|
+// if (!sbSql.toString().equalsIgnoreCase("")) {
|
|
|
+// String sql = "update sys_user set " + sbSql.toString() + " where " + sbParams.toString();
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// Object[] params = alParamsValues.toArray();
|
|
|
+//
|
|
|
+// return jdbcTemplate.update(sql, params);
|
|
|
+// }
|
|
|
+//
|
|
|
+// return 0;
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer delete(String id) {
|
|
|
+//
|
|
|
+// String sql = "delete from sys_user where id=?";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// return jdbcTemplate.update(sql, id);
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public Integer delete(List<SysUser> lsSysUser) {
|
|
|
+// String sql = "delete from sys_user where id=?";
|
|
|
+//
|
|
|
+// JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
|
|
|
+//
|
|
|
+// return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
|
|
|
+// @Override
|
|
|
+// public void setValues(PreparedStatement preparedStatement, int i) throws SQLException {
|
|
|
+// preparedStatement.setString(1, lsSysUser.get(i).getId());
|
|
|
+// }
|
|
|
+//
|
|
|
+// @Override
|
|
|
+// public int getBatchSize() {
|
|
|
+// return lsSysUser.size();
|
|
|
+// }
|
|
|
+// }).length;
|
|
|
+// }
|
|
|
+//}
|
|
|
+//
|
|
|
+//
|
|
|
+//
|
|
|
+//
|