根据合同查询所有设置人员

backend/xyst.dinas.biz/src/main/java/com/xyst/dinas/biz/warn/dao/WarnSettingDao.java

 package com.xyst.dinas.biz.warn.dao;
 
+import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Date;
 import java.util.List;
 import java.util.UUID;
+import java.util.stream.Collectors;
 
+import javax.persistence.Tuple;
+
+import org.apache.commons.lang3.StringUtils;
+import org.hibernate.HibernateException;
+import org.hibernate.Session;
 import org.hibernate.query.Query;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.orm.hibernate5.HibernateCallback;
 import org.springframework.orm.hibernate5.HibernateOperations;
 import org.springframework.stereotype.Repository;
 
+import com.beecode.amino.common.Convert;
 import com.beecode.bcp.type.KObject;
 import com.xyst.dinas.biz.warn.WarnExeRecord;
 import com.xyst.dinas.biz.warn.WarnSetting;
@@ -127,5 +137,30 @@ public class WarnSettingDao {
 		});
 	}
 
+	private static final String queryWarnSettingStaffSql = "SELECT  DISTINCT(GROUP_CONCAT(personnel)) FROM xyst_dinas_warn_setting WHERE HEX(bill_id) =:contractId";
+
+	public List<String> queryWarnSettingStaffByContractId(String contractId) {
+		return template.execute(new HibernateCallback<List<String>>() {
+            //List<UUID> uuids = new ArrayList<>();
+            List<String> personnelIdList = new ArrayList<>();
+			@Override
+			public List<String> doInHibernate(Session session) throws HibernateException {
+				//List<Tuple> uuids1 = session.createSQLQuery(queryStaffSql).addEntity(Tuple.class).setParameter("postId", postId).list();
+				Query<Tuple> query = session.createNativeQuery(queryWarnSettingStaffSql, Tuple.class);
+				query.setParameter("contractId", contractId.replaceAll("-", ""));
+				List<Tuple> result = query.getResultList();
+				for (Tuple tuple : result) {
+					String personnelIds = tuple.get(0, String.class);
+					if (StringUtils.isNotEmpty(personnelIds)) {
+						personnelIdList = Arrays.asList(personnelIds.split(","));
+					}
+					//uuids.add(Convert.toUUID(tuple.get(0)));
+				}
+				List<String> collect = personnelIdList.stream().distinct().collect(Collectors.toList());
+				return collect;
+			}
+		});
+	}
+	
 
 }

backend/xyst.dinas.contract/src/main/java/com/xyst/dinas/contract/internal/service/ContractServiceImpl.java

@@ -16,6 +16,7 @@ import org.springframework.transaction.annotation.Transactional;
 
 import com.beecode.bcp.core.context.AminoContextHolder;
 import com.beecode.bcp.type.KObject;
+import com.beecode.inz.basis.team.pojo.ResponseObj;
 import com.beecode.inz.common.BaseConstants;
 import com.beecode.inz.workflow.service.InzWorkflowService;
 import com.xyst.dinas.biz.dao.DinasOrganizationDao;
@@ -296,5 +297,11 @@ public class ContractServiceImpl implements ContractService {
 		return map;
 	}
 
+	@Override
+	public Object queryWarnSettingStaffByContractId(String contractId) {
+		List<String> staffIds = warnSettingDao.queryWarnSettingStaffByContractId(contractId);
+		return ResponseObj.success("查询成功", staffIds);
+	}
+	
 
 }

backend/xyst.dinas.contract/src/main/java/com/xyst/dinas/contract/service/ContractService.java

@@ -70,4 +70,6 @@ public interface ContractService {
 	void afterChangeApproved(KObject object);
 
 	Object queryWarnSettingById(UUID id);
+
+	Object queryWarnSettingStaffByContractId(String fromString);
 }

backend/xyst.dinas.contract/src/main/java/com/xyst/dinas/contract/web/ContractController.java

@@ -168,4 +168,16 @@ public class ContractController {
 		return contractService.queryWarnSettingById(id);
 	}
 	
+	/**  
+	 * @Description: 根据合同查询预警设置中所有人员
+	 * @param id
+	 * @return return_type
+	 * @throws   
+	 */
+	@GetMapping("/contract/queryWarnSettingStaffByContractId/{contractId}")
+	public Object queryWarnSettingStaffByContractId(@PathVariable String contractId) {
+		Assert.notNull(contractId,"The id must not be null");
+		return contractService.queryWarnSettingStaffByContractId(contractId);
+	}
+
 }
\ No newline at end of file