|
@@ -0,0 +1,81 @@
|
|
|
+package com.hb.proj.sys.service;
|
|
|
+
|
|
|
+import java.util.ArrayList;
|
|
|
+import java.util.Date;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+
|
|
|
+import org.apache.commons.lang3.StringUtils;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import com.hb.proj.model.User;
|
|
|
+import com.hb.proj.model.UserVO;
|
|
|
+import com.hb.xframework.dao.core.SpringJdbcDAO;
|
|
|
+import com.hb.xframework.dao.util.PageModel;
|
|
|
+import com.hb.xframework.dao.util.UUIDHexGenerator;
|
|
|
+
|
|
|
+@Service
|
|
|
+public class UserService {
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private SpringJdbcDAO dao;
|
|
|
+
|
|
|
+ public PageModel<Map<String,Object>> query(Map<String,Object> args,int pageNo,int pageSize){
|
|
|
+ List<Object> sqlParams=new ArrayList<Object>();
|
|
|
+ StringBuilder sql=new StringBuilder(100);
|
|
|
+ sql.append("select * ");
|
|
|
+ sql.append(" from tsys_user u ");
|
|
|
+ sql.append(" where del_if=false ");
|
|
|
+
|
|
|
+ if(args!=null&&StringUtils.isNotBlank((String)args.get("userName"))) {
|
|
|
+ sql.append(" and (real_name like ? or login_id like ?)");
|
|
|
+ sqlParams.add("%"+args.get("userName")+"%");
|
|
|
+ sqlParams.add("%"+args.get("userName")+"%");
|
|
|
+ }
|
|
|
+
|
|
|
+ sql.append(" order by login_id");
|
|
|
+
|
|
|
+ Object[] sqlArgs=sqlParams.size()>0?sqlParams.toArray():null;
|
|
|
+ return dao.queryForPagedData(sql.toString(),pageNo, pageSize,sqlArgs);
|
|
|
+ }
|
|
|
+
|
|
|
+ public String add(User user) {
|
|
|
+ UUIDHexGenerator uuid=UUIDHexGenerator.getInstance();
|
|
|
+ user.setUserId(uuid.generate());
|
|
|
+ user.setCreateTime(new Date());
|
|
|
+ user.setModifyTime(new Date());
|
|
|
+ user.setDelIf(false);
|
|
|
+ dao.insert(user,"tsys_user");
|
|
|
+ return user.getUserId();
|
|
|
+ }
|
|
|
+
|
|
|
+ public boolean delete(String userId) {
|
|
|
+ String sql="update tsys_user set del_if=true where user_id=?";
|
|
|
+ dao.exeUpdate(sql,userId);
|
|
|
+ return true;
|
|
|
+ }
|
|
|
+
|
|
|
+ public UserVO get(String userId) {
|
|
|
+ return dao.queryForPojo("select u.* from tsys_user u where del_if=false and user_id=?",UserVO.class,userId);
|
|
|
+ }
|
|
|
+
|
|
|
+ public boolean update(User user) {
|
|
|
+ user.setModifyTime(new Date());
|
|
|
+ return dao.update(user, "tsys_user", "user_id")>0;
|
|
|
+ }
|
|
|
+
|
|
|
+ public boolean updateByUsId(Map<String, Object> user){
|
|
|
+ user.put("modifyTime", new Date());
|
|
|
+ return dao.update(user,"tsys_user", "user_id")>0;
|
|
|
+ }
|
|
|
+
|
|
|
+ public User getByLoginId(String loginId) {
|
|
|
+ return dao.queryForPojo("select u.* from tsys_user u where login_id=? and del_if=false",User.class, loginId);
|
|
|
+ }
|
|
|
+
|
|
|
+ public boolean isLoginIdUsing(String loginId,String userId) {
|
|
|
+ Integer num=dao.queryForObject("select count(1) from tsys_user where del_if=false and login_id=? and user_id!=?", Integer.class, loginId,userId);
|
|
|
+ return num!=null&&num.intValue()>0;
|
|
|
+ }
|
|
|
+}
|