场站ListId查询批量User

backend/inz.basis/src/main/java/com/beecode/inz/basis/dao/WarehouseUserDao.java

@@ -14,6 +14,7 @@ public interface WarehouseUserDao extends BaseDao {
 	KObject findByUsernameOrTelephone(String username);
 
 	List<KObject> findAllByStationId(UUID stationId);
+	List<String> findAllByStationListId(List<String> stationListId);
 
 	List<KObject> queryPositionByName(String phone);
 

backend/inz.basis/src/main/java/com/beecode/inz/basis/internal/dao/WarehouseUserDaoImpl.java

 package com.beecode.inz.basis.internal.dao;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
+import java.util.stream.Collectors;
+
+import javax.persistence.Tuple;
 
 import org.hibernate.HibernateException;
 import org.hibernate.Session;
@@ -11,18 +15,19 @@ import org.springframework.orm.hibernate5.HibernateCallback;
 import org.springframework.orm.hibernate5.HibernateTemplate;
 import org.springframework.stereotype.Repository;
 
+import com.beecode.amino.common.Convert;
 import com.beecode.bcp.type.KObject;
 import com.beecode.inz.basis.config.constants.WarehouseUserConstants;
 import com.beecode.inz.basis.dao.WarehouseUserDao;
 
 @Repository
 public class WarehouseUserDaoImpl extends AbstractBaseDao implements WarehouseUserDao {
-	
+
 	@Autowired
 	private HibernateTemplate template;
-	
-	public WarehouseUserDaoImpl(){
-		
+
+	public WarehouseUserDaoImpl() {
+
 	}
 
 	@Override
@@ -38,12 +43,13 @@ public class WarehouseUserDaoImpl extends AbstractBaseDao implements WarehouseUs
 	@Override
 	public KObject findByUsernameOrTelephone(String username) {
 		return getHibernateTemplate().execute(session -> {
-			StringBuffer sql = new StringBuffer("FROM " + getModelName() + " WHERE (username = :username OR telephone = :username) AND enabled = 1 AND discard = 0 ");
-			//创建查询
+			StringBuffer sql = new StringBuffer("FROM " + getModelName()
+					+ " WHERE (username = :username OR telephone = :username) AND enabled = 1 AND discard = 0 ");
+			// 创建查询
 			Query<KObject> query = session.createQuery(sql.toString(), KObject.class);
 			query.setParameter("username", username);
 			List<KObject> result = query.getResultList();
-			if(result != null && result.size() > 0) {
+			if (result != null && result.size() > 0) {
 				return result.get(0);
 			}
 			return null;
@@ -56,8 +62,9 @@ public class WarehouseUserDaoImpl extends AbstractBaseDao implements WarehouseUs
 	@Override
 	public List<KObject> findAllByStationId(UUID stationId) {
 		return getHibernateTemplate().execute(session -> {
-			StringBuffer sql = new StringBuffer("FROM " + getModelName() + " WHERE stationId = :stationId AND enabled = 1 AND discard = 0 ");
-			//创建查询
+			StringBuffer sql = new StringBuffer(
+					"FROM " + getModelName() + " WHERE stationId = :stationId AND enabled = 1 AND discard = 0 ");
+			// 创建查询
 			Query<KObject> query = session.createQuery(sql.toString(), KObject.class);
 			query.setParameter("stationId", stationId);
 			return query.getResultList();
@@ -68,7 +75,7 @@ public class WarehouseUserDaoImpl extends AbstractBaseDao implements WarehouseUs
 	public List<KObject> listByUserName(String username) {
 		return listByAttributes(buildSingleMap(WarehouseUserConstants.USERNAME, username));
 	}
-	
+
 	@Override
 	public List<KObject> listByTelephone(String telephone) {
 		return listByAttributes(buildSingleMap(WarehouseUserConstants.TELEPHONE, telephone));
@@ -76,11 +83,14 @@ public class WarehouseUserDaoImpl extends AbstractBaseDao implements WarehouseUs
 
 	@Override
 	public List<KObject> queryPositionByName(String phone) {
-		return (List<KObject>)template.execute(new HibernateCallback<List<KObject>>() {
+		return (List<KObject>) template.execute(new HibernateCallback<List<KObject>>() {
 			@SuppressWarnings("unchecked")
 			@Override
 			public List<KObject> doInHibernate(Session session) throws HibernateException {
-				Query<KObject> query = session.createQuery("from " + WarehouseUserConstants.ENTITY + " where (discard is null or discard = 0) and (enabled = 1) and telephone =:phone ", KObject.class);
+				Query<KObject> query = session.createQuery(
+						"from " + WarehouseUserConstants.ENTITY
+								+ " where (discard is null or discard = 0) and (enabled = 1) and telephone =:phone ",
+						KObject.class);
 				query.setParameter("phone", phone);
 				return query.getResultList();
 			}
@@ -89,15 +99,39 @@ public class WarehouseUserDaoImpl extends AbstractBaseDao implements WarehouseUs
 
 	@Override
 	public List<KObject> userNameRepeatCheck(String username) {
-		return (List<KObject>)template.execute(new HibernateCallback<List<KObject>>() {
+		return (List<KObject>) template.execute(new HibernateCallback<List<KObject>>() {
 			@SuppressWarnings("unchecked")
 			@Override
 			public List<KObject> doInHibernate(Session session) throws HibernateException {
-				Query<KObject> query = session.createQuery("from " + WarehouseUserConstants.ENTITY + " where (discard is null or discard = 0) and (enabled = 1) and username =:username ", KObject.class);
+				Query<KObject> query = session.createQuery(
+						"from " + WarehouseUserConstants.ENTITY
+								+ " where (discard is null or discard = 0) and (enabled = 1) and username =:username ",
+						KObject.class);
 				query.setParameter("username", username);
 				return query.getResultList();
 			}
 		});
 	}
 
+	@Override
+	public List<String> findAllByStationListId(List<String> stationListId) {
+		List<String> params = stationListId.stream().map(station -> station = station.replaceAll("-", "")).collect(Collectors.toList());
+		
+		  return getHibernateTemplate().execute(session -> { //
+           StringBuffer sql = new StringBuffer("select warehouseUser.id as id  FROM xyst_dinas_basis_warehouse_user AS warehouseUser  WHERE hex(warehouseUser.station_Id)  in (:stationId) AND warehouseUser.enabled = 1 AND warehouseUser.discard = 0"); //创建查询 
+		  Query<Tuple> query = session.createNativeQuery(sql.toString(), Tuple.class);
+		  query.setParameterList("stationId", params); 
+		  List<Tuple> resultList =  query.getResultList(); 
+		  if (resultList.isEmpty()) {
+				return null;
+				}
+		  List<String> resultUserList = new ArrayList<String>();
+		  for (Tuple resule : resultList) {
+			  resultUserList.add(Convert.toUUID(resule.get(0)).toString());
+		  }
+		 
+		  return resultUserList; 
+		  });
+	}
+
 }

backend/inz.basis/src/main/java/com/beecode/inz/basis/internal/service/WarehouseUserServiceImpl.java

@@ -219,6 +219,12 @@ public class WarehouseUserServiceImpl implements WarehouseUserService {
 		}
 		return flag;
 	}
+
+	@Override
+	public List<String> getAllByStationListId(List<String> stationListId) {
+		// TODO Auto-generated method stub
+		return dao.findAllByStationListId(stationListId);
+	}
 	
 
 

backend/inz.basis/src/main/java/com/beecode/inz/basis/service/WarehouseUserService.java

@@ -62,6 +62,7 @@ public interface WarehouseUserService {
 	 * @return
 	 */
 	List<KObject> getAllByStationId(UUID stationId);
+	List<String> getAllByStationListId(List<String> stationListId);
 
 	Boolean phoneRepeatCheck(String parameter);
 

backend/inz.basis/src/main/java/com/beecode/inz/basis/web/WarehouseUserController.java

 package com.beecode.inz.basis.web;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
 
 import javax.servlet.http.HttpServletRequest;
 
+import org.json.JSONArray;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -27,6 +29,7 @@ import com.beecode.inz.basis.pojo.WarehouseUser;
 import com.beecode.inz.basis.service.WarehouseUserService;
 import com.beecode.inz.basis.team.pojo.ResponseObj;
 import com.beecode.inz.basis.util.JsonUtil;
+
 import com.beecode.xlib.json.JSONException;
 import com.beecode.xlib.json.JSONObject;
 import com.beecode.xlib.runtime.Assert;
@@ -97,6 +100,30 @@ public class WarehouseUserController {
 	}
 	
 	/**
+	 * 创建场站用户
+	 * @param obj
+	 * @return
+	 */
+	@PostMapping("/warehouse/user/stationList")
+	public Object getByStationListId( @RequestBody List<String> stationListId) {
+		
+		if(stationListId.size()<0) {
+			return ResponseObj.error("stationListId不能为空");
+		}
+		try {
+			List<String> list = warehouseUserService.getAllByStationListId(stationListId);
+			return ResponseObj.success("操作成功", list);
+		} catch (IllegalArgumentException e) {
+			e.printStackTrace();
+			return ResponseObj.error("stationId错误");
+		} catch (Exception e) {
+			e.printStackTrace();
+			return ResponseObj.error("操作失败");
+		}
+	}
+	
+	
+	/**
 	 * 根据id查询用户
 	 * @param obj
 	 * @return