123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628 |
- package com.yihu.ehr.analyze.controller.dataQuality;
- import com.yihu.ehr.analyze.common.AnalyzerApi;
- import com.yihu.ehr.analyze.feign.StandardServiceClient;
- import com.yihu.ehr.analyze.service.dataQuality.DqDatasetWarningService;
- import com.yihu.ehr.analyze.service.dataQuality.DqPaltformReceiveWarningService;
- import com.yihu.ehr.analyze.service.dataQuality.DqPaltformResourceWarningService;
- import com.yihu.ehr.analyze.service.dataQuality.DqPaltformUploadWarningService;
- import com.yihu.ehr.constants.ApiVersion;
- import com.yihu.ehr.constants.ServiceApi;
- import com.yihu.ehr.controller.EnvelopRestEndPoint;
- import com.yihu.ehr.entity.quality.DqDatasetWarning;
- import com.yihu.ehr.entity.quality.DqPaltformReceiveWarning;
- import com.yihu.ehr.entity.quality.DqPaltformResourceWarning;
- import com.yihu.ehr.entity.quality.DqPaltformUploadWarning;
- import com.yihu.ehr.model.quality.MDqDatasetWarning;
- import com.yihu.ehr.model.quality.MDqPaltformReceiveWarning;
- import com.yihu.ehr.model.quality.MDqPaltformResourceWarning;
- import com.yihu.ehr.model.quality.MDqPaltformUploadWarning;
- import com.yihu.ehr.util.rest.Envelop;
- import com.yihu.hos.model.standard.MStdDataSet;
- import com.yihu.hos.model.standard.MStdMetaData;
- import io.swagger.annotations.Api;
- import io.swagger.annotations.ApiOperation;
- import io.swagger.annotations.ApiParam;
- import jxl.Sheet;
- import jxl.Workbook;
- import org.apache.commons.collections.CollectionUtils;
- import org.apache.commons.lang.StringUtils;
- import org.springframework.beans.factory.annotation.Autowired;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.http.MediaType;
- import org.springframework.http.ResponseEntity;
- import org.springframework.web.bind.annotation.*;
- import org.springframework.web.multipart.MultipartFile;
- import java.util.ArrayList;
- import java.util.List;
- /**
- * @author yeshijie on 2018/5/28.
- */
- @RestController
- @RequestMapping(value = ApiVersion.Version1_0, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
- @Api(value = "WarningSettingEndPoint", description = "质控-预警设置", tags = {"档案分析服务-质控-预警设置"})
- public class WarningSettingEndPoint extends EnvelopRestEndPoint {
- @Autowired
- private DqDatasetWarningService dqDatasetWarningService;
- @Autowired
- private DqPaltformReceiveWarningService dqPaltformReceiveWarningService;
- @Autowired
- private DqPaltformResourceWarningService dqPaltformResourceWarningService;
- @Autowired
- private DqPaltformUploadWarningService dqPaltformUploadWarningService;
- @Value("${quality.orgCode}")
- private String defaultOrgCode;
- @Value("${quality.version}")
- private String defaultQualityVersion;
- @Autowired
- private StandardServiceClient standardServiceClient;
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarningList, method = RequestMethod.GET)
- @ApiOperation(value = "平台接收预警列表")
- public Envelop paltformReceiveWarningList(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "jkzl")
- @RequestParam(value = "orgCode", required = false) String orgCode,
- @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
- @RequestParam(value = "size", required = false) int size,
- @ApiParam(name = "page", value = "页码", defaultValue = "1")
- @RequestParam(value = "page", required = false) int page){
- Envelop envelop = new Envelop();
- try {
- String filters = null;
- if(StringUtils.isNotBlank(orgCode)){
- filters = "orgCode="+orgCode;
- }else {
- filters = "orgCode<>"+defaultOrgCode;
- }
- String sorts = "-updateTime";
- List<DqPaltformReceiveWarning> list = dqPaltformReceiveWarningService.search(null, filters, sorts, page, size);
- List<MDqPaltformReceiveWarning> warnings = (List<MDqPaltformReceiveWarning>)convertToModels(list, new ArrayList<>(list.size()), MDqPaltformReceiveWarning.class, null);
- return getPageResult(warnings, (int)dqPaltformReceiveWarningService.getCount(filters), page, size);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformResourceWarningList, method = RequestMethod.GET)
- @ApiOperation(value = "平台资源化预警列表")
- public Envelop paltformResourceWarningList(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "jkzl")
- @RequestParam(value = "orgCode", required = false) String orgCode,
- @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
- @RequestParam(value = "size", required = false) int size,
- @ApiParam(name = "page", value = "页码", defaultValue = "1")
- @RequestParam(value = "page", required = false) int page){
- Envelop envelop = new Envelop();
- try {
- String filters = null;
- if(StringUtils.isNotBlank(orgCode)){
- filters = "orgCode="+orgCode;
- }
- String sorts = "-updateTime";
- List<DqPaltformResourceWarning> list = dqPaltformResourceWarningService.search(null, filters, sorts, page, size);
- List<MDqPaltformResourceWarning> warnings = (List<MDqPaltformResourceWarning>)convertToModels(list, new ArrayList<>(list.size()), MDqPaltformResourceWarning.class, null);
- return getPageResult(warnings, (int)dqPaltformResourceWarningService.getCount(filters), page, size);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformUploadWarningList, method = RequestMethod.GET)
- @ApiOperation(value = "平台上传预警列表")
- public Envelop paltformUploadWarningList(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "jkzl")
- @RequestParam(value = "orgCode", required = false) String orgCode,
- @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
- @RequestParam(value = "size", required = false) int size,
- @ApiParam(name = "page", value = "页码", defaultValue = "1")
- @RequestParam(value = "page", required = false) int page) {
- Envelop envelop = new Envelop();
- try {
- String filters = null;
- if(StringUtils.isNotBlank(orgCode)){
- filters = "orgCode="+orgCode;
- }
- String sorts = "-updateTime";
- List<DqPaltformUploadWarning> list = dqPaltformUploadWarningService.search(null, filters, sorts, page, size);
- List<MDqPaltformUploadWarning> warnings = (List<MDqPaltformUploadWarning>)convertToModels(list, new ArrayList<>(list.size()), MDqPaltformUploadWarning.class, null);
- return getPageResult(warnings, (int)dqPaltformUploadWarningService.getCount(filters), page, size);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarningDefault, method = RequestMethod.GET)
- @ApiOperation(value = "查找默认的平台接收预警")
- public Envelop paltformReceiveWarningDefault() {
- Envelop envelop = new Envelop();
- try {
- DqPaltformReceiveWarning warning = dqPaltformReceiveWarningService.findByOrgCode(defaultOrgCode);
- List<DqDatasetWarning> warningList = dqDatasetWarningService.findByOrgCodeAndType(warning.getOrgCode(),"1");
- warning.setDatasetWarningNum(warningList.size());
- warning.setDatasetWarningList(warningList);
- return success(convertToModel(warning, MDqPaltformReceiveWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarning, method = RequestMethod.GET)
- @ApiOperation(value = "根据id查询平台接收预警")
- public Envelop getMDqPaltformReceiveWarningById(
- @ApiParam(name = "id", value = "id", defaultValue = "")
- @PathVariable(value = "id") Long id) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformReceiveWarning warning = dqPaltformReceiveWarningService.findById(id);
- List<DqDatasetWarning> warningList = dqDatasetWarningService.findByOrgCodeAndType(warning.getOrgCode(),"1");
- warning.setDatasetWarningNum(warningList.size());
- return success(convertToModel(warning, MDqPaltformReceiveWarning.class),warningList);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarningIsExist, method = RequestMethod.GET)
- @ApiOperation(value = "验证机构是否存在")
- public Envelop paltformReceiveWarningIsExist(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "")
- @RequestParam(value = "orgCode") String orgCode) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformReceiveWarning warning = dqPaltformReceiveWarningService.findByOrgCode(orgCode);
- if(warning!=null){
- return success(1);
- }else {
- return success(0);
- }
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformUploadWarningIsExist, method = RequestMethod.GET)
- @ApiOperation(value = "验证机构是否存在")
- public Envelop paltformUploadWarningIsExist(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "")
- @RequestParam(value = "orgCode") String orgCode) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformUploadWarning warning = dqPaltformUploadWarningService.findByOrgCode(orgCode);
- if(warning!=null){
- return success(1);
- }else {
- return success(0);
- }
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformResourceWarning, method = RequestMethod.GET)
- @ApiOperation(value = "根据id查询平台资源化预警")
- public Envelop getMDqPaltformResourceWarningById(
- @ApiParam(name = "id", value = "id", defaultValue = "")
- @PathVariable(value = "id") Long id) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformResourceWarning warning = dqPaltformResourceWarningService.findById(id);
- return success(convertToModel(warning, MDqPaltformResourceWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformUploadWarning, method = RequestMethod.GET)
- @ApiOperation(value = "根据id查询平台上传预警")
- public Envelop getMDqPaltformUploadWarningById(
- @ApiParam(name = "id", value = "id", defaultValue = "")
- @PathVariable(value = "id") Long id) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformUploadWarning warning = dqPaltformUploadWarningService.findById(id);
- List<DqDatasetWarning> warningList = dqDatasetWarningService.findByOrgCodeAndType(warning.getOrgCode(),"2");
- warning.setDatasetWarningNum(warningList.size());
- return success(convertToModel(warning, MDqPaltformUploadWarning.class),warningList);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.DatasetWarningListNoPage, method = RequestMethod.GET)
- @ApiOperation(value = "预警数据集列表(不分页)")
- public Envelop datasetWarningListNoPage(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "jkzl")
- @RequestParam(value = "orgCode", required = true) String orgCode,
- @ApiParam(name = "type", value = "类型(1平台接收,2平台上传)", defaultValue = "1")
- @RequestParam(value = "type", required = true) String type) throws Exception {
- Envelop envelop = new Envelop();
- try{
- List<DqDatasetWarning> list = dqDatasetWarningService.findByOrgCodeAndType(orgCode, type);
- List<MDqDatasetWarning> warnings = (List<MDqDatasetWarning>)convertToModels(list, new ArrayList<>(list.size()), MDqDatasetWarning.class, null);
- return success(warnings);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.DatasetWarningList, method = RequestMethod.GET)
- @ApiOperation(value = "预警数据集列表")
- public Envelop datasetWarningList(
- @ApiParam(name = "orgCode", value = "机构code", defaultValue = "jkzl")
- @RequestParam(value = "orgCode", required = true) String orgCode,
- @ApiParam(name = "type", value = "类型(1平台接收,2平台上传)", defaultValue = "1")
- @RequestParam(value = "type", required = true) String type,
- @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
- @RequestParam(value = "size", required = false) int size,
- @ApiParam(name = "page", value = "页码", defaultValue = "1")
- @RequestParam(value = "page", required = false) int page){
- Envelop envelop = new Envelop();
- try{
- String filters = "orgCode="+orgCode+";type="+type;
- String sorts = "-code";
- List<DqDatasetWarning> list = dqDatasetWarningService.search(null, filters, sorts, page, size);
- List<MDqDatasetWarning> warnings = (List<MDqDatasetWarning>)convertToModels(list, new ArrayList<>(list.size()), MDqDatasetWarning.class, null);
- return getPageResult(warnings,(int)dqDatasetWarningService.getCount(filters), page, size);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarningAdd, method = RequestMethod.POST)
- @ApiOperation(value = "新增平台接收预警")
- public Envelop paltformReceiveWarningAdd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformReceiveWarning warning = toEntity(jsonData, DqPaltformReceiveWarning.class);
- DqPaltformReceiveWarning oldWarning = dqPaltformReceiveWarningService.findByOrgCode(warning.getOrgCode());
- if(oldWarning!=null){
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg("该机构已存在预警记录");
- return envelop;
- }
- warning = dqPaltformReceiveWarningService.paltformReceiveWarningAdd(warning);
- return success(convertToModel(warning, MDqPaltformReceiveWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformResourceWarningAdd, method = RequestMethod.POST)
- @ApiOperation(value = "新增平台资源化预警")
- public Envelop paltformResourceWarningAdd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformResourceWarning warning = toEntity(jsonData, DqPaltformResourceWarning.class);
- warning = dqPaltformResourceWarningService.paltformResourceWarningAdd(warning);
- return success(convertToModel(warning, MDqPaltformResourceWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformUploadWarningAdd, method = RequestMethod.POST)
- @ApiOperation(value = "新增平台上传预警")
- public Envelop paltformUploadWarningAdd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData){
- Envelop envelop = new Envelop();
- try {
- DqPaltformUploadWarning warning = toEntity(jsonData, DqPaltformUploadWarning.class);
- DqPaltformUploadWarning oldWarning = dqPaltformUploadWarningService.findByOrgCode(warning.getOrgCode());
- if(oldWarning!=null){
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg("该机构已存在预警记录");
- return envelop;
- }
- warning = dqPaltformUploadWarningService.paltformUploadWarningAdd(warning);
- return success(convertToModel(warning, MDqPaltformUploadWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarningDel, method = RequestMethod.POST)
- @ApiOperation(value = "删除平台接收预警")
- public Envelop paltformReceiveWarningDel(
- @ApiParam(name = "id", value = "1", defaultValue = "")
- @RequestParam Long id) throws Exception {
- Envelop envelop = new Envelop();
- try {
- dqPaltformReceiveWarningService.deleteWarning(id);
- return success(null);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformResourceWarningDel, method = RequestMethod.POST)
- @ApiOperation(value = "删除平台资源化预警")
- public Envelop paltformResourceWarningDel(
- @ApiParam(name = "id", value = "1", defaultValue = "")
- @RequestParam Long id) throws Exception {
- Envelop envelop = new Envelop();
- try {
- dqPaltformResourceWarningService.delete(id);
- return success(null);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformUploadWarningDel, method = RequestMethod.POST)
- @ApiOperation(value = "删除平台上传预警")
- public Envelop paltformUploadWarningDel(
- @ApiParam(name = "id", value = "1", defaultValue = "")
- @RequestParam Long id) throws Exception {
- Envelop envelop = new Envelop();
- try {
- dqPaltformUploadWarningService.deleteWarning(id);
- return success(null);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformReceiveWarningUpd, method = RequestMethod.POST)
- @ApiOperation(value = "修改平台接收预警")
- public Envelop paltformReceiveWarningUpd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformReceiveWarning warning = toEntity(jsonData, DqPaltformReceiveWarning.class);
- warning = dqPaltformReceiveWarningService.paltformReceiveWarningUpd(warning);
- return success(convertToModel(warning, MDqPaltformReceiveWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformResourceWarningUpd, method = RequestMethod.POST)
- @ApiOperation(value = "修改平台资源化预警")
- public Envelop paltformResourceWarningUpd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformResourceWarning warning = toEntity(jsonData, DqPaltformResourceWarning.class);
- warning = dqPaltformResourceWarningService.paltformResourceWarningUpd(warning);
- return success(convertToModel(warning, MDqPaltformResourceWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.PaltformUploadWarningUpd, method = RequestMethod.POST)
- @ApiOperation(value = "修改平台上传预警")
- public Envelop paltformUploadWarningUpd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData) {
- Envelop envelop = new Envelop();
- try {
- DqPaltformUploadWarning warning = toEntity(jsonData, DqPaltformUploadWarning.class);
- warning = dqPaltformUploadWarningService.paltformUploadWarningUpd(warning);
- return success(convertToModel(warning, MDqPaltformUploadWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.DatasetWarningAdd, method = RequestMethod.POST)
- @ApiOperation(value = "新增数据集")
- public Envelop datasetWarningAdd(
- @ApiParam(name = "jsonData", value = "对象JSON结构体", defaultValue = "")
- @RequestParam(value = "jsonData", required = true) String jsonData) {
- Envelop envelop = new Envelop();
- try {
- DqDatasetWarning warning = toEntity(jsonData, DqDatasetWarning.class);
- warning = dqDatasetWarningService.save(warning);
- return success(convertToModel(warning, MDqDatasetWarning.class));
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.DatasetWarningDel, method = RequestMethod.POST)
- @ApiOperation(value = "删除数据集")
- public Envelop datasetWarningDel(
- @ApiParam(name = "id", value = "1", defaultValue = "")
- @RequestParam Long id) throws Exception {
- Envelop envelop = new Envelop();
- try {
- dqDatasetWarningService.delete(id);
- return success(null);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.Meta_datas, method = RequestMethod.GET)
- @ApiOperation(value = "获取数据元")
- public Envelop meta_datas(
- @ApiParam(name = "fields", value = "返回的字段,为空返回全部字段", defaultValue = "")
- @RequestParam(value = "fields", required = false) String fields,
- @ApiParam(name = "filters", value = "过滤器,为空检索所有条件", defaultValue = "")
- @RequestParam(value = "filters", required = false) String filters,
- @ApiParam(name = "datasetCode", value = "数据集编码", defaultValue = "")
- @RequestParam(value = "datasetCode", required = false) String datasetCode,
- @ApiParam(name = "sorts", value = "排序,规则参见说明文档", defaultValue = "")
- @RequestParam(value = "sorts", required = false) String sorts,
- @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
- @RequestParam(value = "size", required = false) int size,
- @ApiParam(name = "page", value = "页码", defaultValue = "1")
- @RequestParam(value = "page", required = false) int page) {
- Envelop envelop = new Envelop();
- try {
- String lastStandByOrgCode = standardServiceClient.getLastStandByOrgCode(defaultOrgCode);
- if(StringUtils.isNotBlank(datasetCode)){
- //查找datasetId
- String filter = "code="+datasetCode;
- ResponseEntity<List<MStdDataSet>> res = standardServiceClient.searchDataSets(null,filter,null,1,1,lastStandByOrgCode);
- List<MStdDataSet> mStdDataSetList = res.getBody();
- if(CollectionUtils.isNotEmpty(mStdDataSetList)){
- if(StringUtils.isNotBlank(filters)){
- filters = "dataSetId="+mStdDataSetList.get(0).getId()+";"+filters;
- }else{
- filters = "dataSetId="+mStdDataSetList.get(0).getId();
- }
- }
- }
- ResponseEntity<List<MStdMetaData>> res = standardServiceClient.searchOrgMetaDatas(fields,filters,sorts,size,page,lastStandByOrgCode);
- List<MStdMetaData> mStdDataSetList = res.getBody();
- int totalCount = getTotalCount(res);
- return getPageResult(mStdDataSetList,totalCount,page,size);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.DatasetList, method = RequestMethod.GET)
- @ApiOperation(value = "获取数据集")
- public Envelop datasetList(
- @ApiParam(name = "fields", value = "返回的字段,为空返回全部字段", defaultValue = "")
- @RequestParam(value = "fields", required = false) String fields,
- @ApiParam(name = "filters", value = "过滤器,为空检索所有条件", defaultValue = "")
- @RequestParam(value = "filters", required = false) String filters,
- @ApiParam(name = "sorts", value = "排序,规则参见说明文档", defaultValue = "")
- @RequestParam(value = "sorts", required = false) String sorts,
- @ApiParam(name = "size", value = "分页大小", defaultValue = "15")
- @RequestParam(value = "size", required = false) int size,
- @ApiParam(name = "page", value = "页码", defaultValue = "1")
- @RequestParam(value = "page", required = false) int page) {
- Envelop envelop = new Envelop();
- try {
- String lastStandByOrgCode = standardServiceClient.getLastStandByOrgCode(defaultOrgCode);
- ResponseEntity<List<MStdDataSet>> res = standardServiceClient.searchDataSets(fields,filters,sorts,size,page,lastStandByOrgCode);
- List<MStdDataSet> mStdDataSetList = res.getBody();
- int totalCount = getTotalCount(res);
- return getPageResult(mStdDataSetList,totalCount,page,size);
- }catch (Exception e){
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = ServiceApi.DataQuality.ImportDatasetExcel, method = RequestMethod.POST)
- @ApiOperation(value = "数据集导入")
- public Envelop importDatasetExcel(MultipartFile file) {
- Envelop envelop = new Envelop();
- try {
- Workbook wb = Workbook.getWorkbook(file.getInputStream());
- Sheet[] sheets = wb.getSheets();
- Sheet sheet = sheets[0];
- int rows = sheet.getRows();
- List<String> codeList = new ArrayList<>(rows);
- if(rows>1){
- for(int row = 1;row<rows;row++){
- String code = sheet.getCell(0, row).getContents();
- if(StringUtils.isNotBlank(code)){
- codeList.add(code);
- }
- }
- }
- List<DqDatasetWarning> list = dqDatasetWarningService.importDatasetExcel(codeList);
- List<MDqDatasetWarning> warnings = (List<MDqDatasetWarning>)convertToModels(list, new ArrayList<>(list.size()), MDqDatasetWarning.class, null);
- return success(warnings);
- } catch (Exception e) {
- e.printStackTrace();
- envelop.setSuccessFlg(false);
- envelop.setErrorMsg(e.getMessage());
- }
- return envelop;
- }
- @RequestMapping(value = AnalyzerApi.StandVersion.GetLastVersion, method = RequestMethod.GET)
- @ApiOperation(value = "获取某个机构已发布的最新版本号", notes = "获取某个机构已发布的最新版本号")
- public Envelop getLastStandByOrgCode(@ApiParam(value="机构code,不传则默认为jkzl",defaultValue = "jkzl")
- @RequestParam(value = "orgCode",required = false) String orgCode){
- if(StringUtils.isBlank(orgCode)){
- orgCode = defaultOrgCode;
- }
- String lastStandByOrgCode = standardServiceClient.getLastStandByOrgCode(orgCode);
- Envelop envelop = new Envelop();
- envelop.setSuccessFlg(true);
- envelop.setObj(lastStandByOrgCode);
- return envelop;
- }
- }
|