Commit 0001e387 by 杨清松

根据当前登录人所在区域公司查询场站

parent 1573a8a7
...@@ -25,4 +25,6 @@ public interface StationDao extends BaseDao { ...@@ -25,4 +25,6 @@ public interface StationDao extends BaseDao {
void modify(KObject kobject); void modify(KObject kobject);
List<KObject> queryStationByRegionalCompany(UUID uuid);
} }
...@@ -14,6 +14,7 @@ import com.xyst.dinas.biz.dao.StationDao; ...@@ -14,6 +14,7 @@ import com.xyst.dinas.biz.dao.StationDao;
import org.hibernate.criterion.DetachedCriteria; import org.hibernate.criterion.DetachedCriteria;
import org.hibernate.criterion.Order; import org.hibernate.criterion.Order;
import org.hibernate.criterion.Restrictions; import org.hibernate.criterion.Restrictions;
import org.hibernate.query.Query;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.orm.hibernate5.HibernateTemplate; import org.springframework.orm.hibernate5.HibernateTemplate;
...@@ -185,4 +186,13 @@ public class StationDaoImpl extends AbstractBaseDao implements StationDao, Stat ...@@ -185,4 +186,13 @@ public class StationDaoImpl extends AbstractBaseDao implements StationDao, Stat
return StationConstant.ENTITY; return StationConstant.ENTITY;
} }
@Override
public List<KObject> queryStationByRegionalCompany(UUID id) {
return template.execute(session -> {
Query<KObject> query = session.createQuery("from " + StationConstant.ENTITY + " where regionalCompany.id=:id ", KObject.class);
query.setParameter("id", id);
return query.getResultList();
});
}
} }
package com.xyst.dinas.biz.internal.service; package com.xyst.dinas.biz.internal.service;
import com.beecode.bap.attachment.common.Page; import com.beecode.bap.attachment.common.Page;
import com.beecode.bap.staff.BapContext;
import com.beecode.bcp.type.KObject; import com.beecode.bcp.type.KObject;
import com.xyst.dinas.biz.dao.StationDao; import com.xyst.dinas.biz.dao.StationDao;
import com.xyst.dinas.biz.service.DinasOrganizationService;
import com.xyst.dinas.biz.service.StationService; import com.xyst.dinas.biz.service.StationService;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.json.JSONObject;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import java.util.List; import java.util.List;
import java.util.Map;
import java.util.UUID; import java.util.UUID;
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
...@@ -16,6 +20,12 @@ public class StationServiceImpl implements StationService { ...@@ -16,6 +20,12 @@ public class StationServiceImpl implements StationService {
@Autowired @Autowired
private StationDao stationDao; private StationDao stationDao;
@Autowired
public BapContext bapContext;
@Autowired
public DinasOrganizationService dinasOrganizationService;
@Override @Override
public Page<KObject> queryByPaging(Page<KObject> page, Integer stationStatus) throws Exception { public Page<KObject> queryByPaging(Page<KObject> page, Integer stationStatus) throws Exception {
...@@ -63,6 +73,18 @@ public class StationServiceImpl implements StationService { ...@@ -63,6 +73,18 @@ public class StationServiceImpl implements StationService {
public void deleteById(UUID id) { public void deleteById(UUID id) {
stationDao.deleteById(id); stationDao.deleteById(id);
} }
@Override
public List<KObject> queryStationByRegionalCompany() {
Map<String, String> map = bapContext.getCurrentUserDatas();
String currentRegionalCompany = map.get("currentRegionalCompany");
JSONObject obj = new JSONObject(currentRegionalCompany);
KObject regionalCompany = dinasOrganizationService.load(UUID.fromString(obj.getString("id")));
List<KObject> list = stationDao.queryStationByRegionalCompany(regionalCompany.getUuid("id"));
return list;
}
} }
...@@ -23,4 +23,6 @@ public interface StationService { ...@@ -23,4 +23,6 @@ public interface StationService {
void update(KObject kobject); void update(KObject kobject);
void deleteById(UUID id); void deleteById(UUID id);
List<KObject> queryStationByRegionalCompany();
} }
...@@ -14,6 +14,7 @@ import org.slf4j.LoggerFactory; ...@@ -14,6 +14,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.util.List;
import java.util.UUID; import java.util.UUID;
/** /**
...@@ -151,5 +152,16 @@ public class StationController { ...@@ -151,5 +152,16 @@ public class StationController {
} }
return ResponseObj.success(); return ResponseObj.success();
} }
/**
* 根据当前登录人所在区域公司查询场站
* @param id
* @return
*/
@GetMapping("/queryStationByRegionalCompany")
public Object queryStationByRegionalCompany(){
List<KObject> kObjects = stationService.queryStationByRegionalCompany();
return ResponseObj.success("success", kObjects);
}
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment