From 79243a38ffb959be94e1a81f922675d093850454 Mon Sep 17 00:00:00 2001 From: k94314517 <8417338+k94314517@user.noreply.gitee.com> Date: 星期日, 18 二月 2024 16:55:11 +0800 Subject: [PATCH] ERP接口 --- server/dmvisit_service/src/main/java/com/doumee/service/system/impl/SystemDictDataServiceImpl.java | 306 ++++++++++++++++++++++++++++++++++----------------- 1 files changed, 204 insertions(+), 102 deletions(-) diff --git a/server/dmvisit_service/src/main/java/com/doumee/service/system/impl/SystemDictDataServiceImpl.java b/server/dmvisit_service/src/main/java/com/doumee/service/system/impl/SystemDictDataServiceImpl.java index 1a7911d..76d4642 100644 --- a/server/dmvisit_service/src/main/java/com/doumee/service/system/impl/SystemDictDataServiceImpl.java +++ b/server/dmvisit_service/src/main/java/com/doumee/service/system/impl/SystemDictDataServiceImpl.java @@ -27,6 +27,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import org.springframework.util.CollectionUtils; +import org.springframework.util.StringUtils; import java.util.Date; import java.util.List; @@ -130,62 +131,111 @@ @Override public VisitConfigDTO getVisitConfigDTO() { - - try { - QueryWrapper<SystemDict> systemDictQuery = new QueryWrapper<>(); - systemDictQuery.lambda() - .eq(SystemDict::getDeleted,Boolean.FALSE) - .eq(SystemDict::getCode,Constants.VISIT_CONFIG); - SystemDict systemDict = systemDictMapper.selectOne(systemDictQuery); - - if (Objects.isNull(systemDict)){ - throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); - } - QueryWrapper<SystemDictData> wrapper = new QueryWrapper<>(); - wrapper.lambda() - .eq(SystemDictData::getDictId,systemDict.getId()); - List<SystemDictData> systemDictDatas = systemDictDataMapper.selectList(wrapper); - if (CollectionUtils.isEmpty(systemDictDatas)){ - throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀鍊间笉瀛樺湪"); - } - VisitConfigDTO visitConfigDTO = null; - for (SystemDictData obj:systemDictDatas) { - visitConfigDTO = new VisitConfigDTO(); - visitConfigDTO.setVisitConfigParam(JSONObject.parseObject(obj.getCode(),VisitConfigParam.class)); - visitConfigDTO.setDescription(obj.getRemark()); - visitConfigDTO.setTheme(obj.getLabel()); - } - return visitConfigDTO; - } catch (Exception e) { - throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"瀛楀吀鍊艰В鏋愭湁璇�"); + VisitConfigDTO visitConfigDTO = new VisitConfigDTO(); + SystemDict systemDict = systemDictMapper.selectOne(new QueryWrapper<SystemDict>().lambda().eq(SystemDict::getCode,Constants.SYSTEM)); + if(Objects.isNull(systemDict)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀绫讳笉瀛樺湪"); } + List<SystemDictData> systemDictList = systemDictDataMapper.selectList( + new QueryWrapper<SystemDictData>().lambda().eq(SystemDictData::getDictId,systemDict.getId())); + if(!com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictList)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); + } + SystemDictData reservationWay = systemDictList.stream().filter(m->m.getLabel().equals(Constants.MDJ_VISIT_REQUIRED)).findFirst().get(); + if(Objects.isNull(reservationWay)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮鏉ヨ棰勭害鏂瑰紡 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setReservationWay(Integer.valueOf(reservationWay.getCode())); + + SystemDictData checkVisit = systemDictList.stream().filter(m->m.getLabel().equals(Constants.BEVISITED_USER_VALID)).findFirst().get(); + if(Objects.isNull(checkVisit)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮琚浜烘牎楠屾柟寮� 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setCheckVisit(Integer.valueOf(checkVisit.getCode())); + SystemDictData healthCard = systemDictList.stream().filter(m->m.getLabel().equals(Constants.HEALTH_CARD)).findFirst().get(); + if(Objects.isNull(healthCard)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮鍋ュ悍璇佹槸鍚﹀繀濉� 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setHealthCard(Integer.valueOf(healthCard.getCode())); + SystemDictData isAnswer = systemDictList.stream().filter(m->m.getLabel().equals(Constants.PROBLEM_VISIT_REQUIRED)).findFirst().get(); + if(Objects.isNull(isAnswer)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮鏄惁闇�瑕佺瓟棰� 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setIsAnswer(Integer.valueOf(isAnswer.getCode())); + SystemDictData theme = systemDictList.stream().filter(m->m.getLabel().equals(Constants.THEME)).findFirst().get(); + if(Objects.isNull(theme)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮绛旈涓婚 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setTheme(theme.getCode()); + SystemDictData description = systemDictList.stream().filter(m->m.getLabel().equals(Constants.DESCRIPTION)).findFirst().get(); + if(Objects.isNull(description)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮绛旈璇存槑 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setDescription(description.getCode()); + return visitConfigDTO; } @Override - public void updateVisitConfig(VisitConfigDTO miniProgrammeDTO) { + public void updateVisitConfig(VisitConfigDTO visitConfigDTO) { + if(Objects.isNull(visitConfigDTO) + ||Objects.isNull(visitConfigDTO.getReservationWay()) + ||Objects.isNull(visitConfigDTO.getCheckVisit()) + ||Objects.isNull(visitConfigDTO.getHealthCard()) + ||Objects.isNull(visitConfigDTO.getIsAnswer()) + || StringUtils.isEmpty(visitConfigDTO.getTheme()) + || StringUtils.isEmpty(visitConfigDTO.getDescription()) + ){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + SystemDict systemDict = systemDictMapper.selectOne(new QueryWrapper<SystemDict>().lambda().eq(SystemDict::getCode,Constants.SYSTEM)); + if(Objects.isNull(systemDict)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀绫讳笉瀛樺湪"); + } + List<SystemDictData> systemDictList = systemDictDataMapper.selectList( + new QueryWrapper<SystemDictData>().lambda().eq(SystemDictData::getDictId,systemDict.getId())); + if(!com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictList)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); + } - QueryWrapper<SystemDict> systemDictQuery = new QueryWrapper<>(); - systemDictQuery.lambda() - .eq(SystemDict::getDeleted,Boolean.FALSE) - .eq(SystemDict::getCode,Constants.VISIT_CONFIG); - SystemDict systemDict = systemDictMapper.selectOne(systemDictQuery); + SystemDictData reservationWay = systemDictList.stream().filter(m->m.getLabel().equals(Constants.MDJ_VISIT_REQUIRED)).findFirst().get(); + if(Objects.isNull(reservationWay)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮鏉ヨ棰勭害鏂瑰紡 瀛楀吀涓嶅瓨鍦�"); + } + reservationWay.setCode(visitConfigDTO.getReservationWay().toString()); - if (Objects.isNull(systemDict)){ - throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); - } - QuerySystemDictDataDTO dictData = new QuerySystemDictDataDTO(); - dictData.setDictId((systemDict.getId())); - List<SystemDictDataListVO> systemDictDataListVOS = systemDictDataMapper.selectManageList(dictData); - SystemDictData systemDictData = getSystemDictDataListVO(systemDict); - systemDictData.setCode(JSON.toJSONString(miniProgrammeDTO.getVisitConfigParam())); - systemDictData.setLabel(miniProgrammeDTO.getTheme()); - systemDictData.setRemark(miniProgrammeDTO.getDescription()); - if(null != systemDictDataListVOS && systemDictDataListVOS.size() > 0) { - systemDictData.setId(systemDictDataListVOS.get(0).getId()); - systemDictDataMapper.updateById(systemDictData); - }else { - systemDictDataMapper.insert(systemDictData); - } + SystemDictData checkVisit = systemDictList.stream().filter(m->m.getLabel().equals(Constants.BEVISITED_USER_VALID)).findFirst().get(); + if(Objects.isNull(checkVisit)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮琚浜烘牎楠屾柟寮� 瀛楀吀涓嶅瓨鍦�"); + } + checkVisit.setCode(visitConfigDTO.getCheckVisit().toString()); + SystemDictData healthCard = systemDictList.stream().filter(m->m.getLabel().equals(Constants.HEALTH_CARD)).findFirst().get(); + if(Objects.isNull(healthCard)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮鍋ュ悍璇佹槸鍚﹀繀濉� 瀛楀吀涓嶅瓨鍦�"); + } + healthCard.setCode(visitConfigDTO.getHealthCard().toString()); + SystemDictData isAnswer = systemDictList.stream().filter(m->m.getLabel().equals(Constants.PROBLEM_VISIT_REQUIRED)).findFirst().get(); + if(Objects.isNull(isAnswer)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮鏄惁闇�瑕佺瓟棰� 瀛楀吀涓嶅瓨鍦�"); + } + isAnswer.setCode(visitConfigDTO.getIsAnswer().toString()); + SystemDictData theme = systemDictList.stream().filter(m->m.getLabel().equals(Constants.THEME)).findFirst().get(); + if(Objects.isNull(theme)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮绛旈涓婚 瀛楀吀涓嶅瓨鍦�"); + } + theme.setCode(visitConfigDTO.getTheme()); + SystemDictData description = systemDictList.stream().filter(m->m.getLabel().equals(Constants.DESCRIPTION)).findFirst().get(); + if(Objects.isNull(description)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"璁垮绛旈璇存槑 瀛楀吀涓嶅瓨鍦�"); + } + description.setCode(visitConfigDTO.getDescription()); + + systemDictDataMapper.updateById(reservationWay); + systemDictDataMapper.updateById(checkVisit); + systemDictDataMapper.updateById(healthCard); + systemDictDataMapper.updateById(isAnswer); + systemDictDataMapper.updateById(theme); + systemDictDataMapper.updateById(description); + } private SystemDictData getSystemDictDataListVO(SystemDict systemDict) { @@ -203,62 +253,114 @@ } @Override - public LaborConfigDTO getLaborConfigDTO() { - - try { - String jasonStr = Constants.toUnderlineJSONString(new LaborConfigDTO()); - JSONObject parse = (JSONObject) JSONObject.parse(jasonStr); - List<String> collect = parse.entrySet().stream().map(s -> s.getKey().toUpperCase()).collect(Collectors.toList()); - - QueryWrapper<SystemDict> systemDictQuery = new QueryWrapper<>(); - systemDictQuery.lambda() - .eq(SystemDict::getDeleted,Boolean.FALSE) - .eq(SystemDict::getCode,Constants.LABOR_CONFIG); - SystemDict systemDict = systemDictMapper.selectOne(systemDictQuery); - - if (Objects.isNull(systemDict)){ - throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); - } - QueryWrapper<SystemDictData> wrapper = new QueryWrapper<>(); - wrapper.lambda() - .eq(SystemDictData::getDictId,systemDict.getId()); - List<SystemDictData> systemDictDatas = systemDictDataMapper.selectList(wrapper); - LaborConfigDTO laborConfigDTO = null; - for (SystemDictData obj:systemDictDatas) { - laborConfigDTO = new LaborConfigDTO(); - laborConfigDTO.setLaborConfigParam(JSONObject.parseObject(obj.getCode(), LaborConfigParam.class)); - laborConfigDTO.setDescription(obj.getRemark()); - laborConfigDTO.setTheme(obj.getLabel()); - } - return laborConfigDTO; - } catch (Exception e) { - throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"瀛楀吀鍊艰В鏋愭湁璇�"); + public VisitConfigDTO getLaborConfigDTO() { + VisitConfigDTO visitConfigDTO = new VisitConfigDTO(); + SystemDict systemDict = systemDictMapper.selectOne(new QueryWrapper<SystemDict>().lambda().eq(SystemDict::getCode,Constants.SYSTEM)); + if(Objects.isNull(systemDict)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀绫讳笉瀛樺湪"); } + List<SystemDictData> systemDictList = systemDictDataMapper.selectList( + new QueryWrapper<SystemDictData>().lambda().eq(SystemDictData::getDictId,systemDict.getId())); + if(!com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictList)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); + } + SystemDictData reservationWay = systemDictList.stream().filter(m->m.getLabel().equals(Constants.MDJ_LW_REQUIRED)).findFirst().get(); + if(Objects.isNull(reservationWay)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮鏉ヨ棰勭害鏂瑰紡 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setReservationWay(Integer.valueOf(reservationWay.getCode())); + + SystemDictData checkVisit = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_BEVISITED_USER_VALID)).findFirst().get(); + if(Objects.isNull(checkVisit)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮琚浜烘牎楠屾柟寮� 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setCheckVisit(Integer.valueOf(checkVisit.getCode())); + + SystemDictData healthCard = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_HEALTH_CARD)).findFirst().get(); + if(Objects.isNull(healthCard)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮鍋ュ悍璇佹槸鍚﹀繀濉� 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setHealthCard(Integer.valueOf(healthCard.getCode())); + + SystemDictData isAnswer = systemDictList.stream().filter(m->m.getLabel().equals(Constants.PROBLEM_LW_REQUIRED)).findFirst().get(); + if(Objects.isNull(isAnswer)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮鏄惁闇�瑕佺瓟棰� 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setIsAnswer(Integer.valueOf(isAnswer.getCode())); + + SystemDictData theme = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_THEME)).findFirst().get(); + if(Objects.isNull(theme)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮绛旈涓婚 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setTheme(theme.getCode()); + + SystemDictData description = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_DESCRIPTION)).findFirst().get(); + if(Objects.isNull(description)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮绛旈璇存槑 瀛楀吀涓嶅瓨鍦�"); + } + visitConfigDTO.setDescription(description.getCode()); + return visitConfigDTO; } @Override - public void updateLaborConfigDTO(LaborConfigDTO miniProgrammeDTO) { - QueryWrapper<SystemDict> systemDictQuery = new QueryWrapper<>(); - systemDictQuery.lambda() - .eq(SystemDict::getDeleted,Boolean.FALSE) - .eq(SystemDict::getCode,Constants.LABOR_CONFIG); - SystemDict systemDict = systemDictMapper.selectOne(systemDictQuery); + public void updateLaborConfigDTO(VisitConfigDTO visitConfigDTO) { + if(Objects.isNull(visitConfigDTO) + ||Objects.isNull(visitConfigDTO.getReservationWay()) + ||Objects.isNull(visitConfigDTO.getCheckVisit()) + ||Objects.isNull(visitConfigDTO.getHealthCard()) + ||Objects.isNull(visitConfigDTO.getIsAnswer()) + || StringUtils.isEmpty(visitConfigDTO.getTheme()) + || StringUtils.isEmpty(visitConfigDTO.getDescription()) + ){ + throw new BusinessException(ResponseStatus.BAD_REQUEST); + } + SystemDict systemDict = systemDictMapper.selectOne(new QueryWrapper<SystemDict>().lambda().eq(SystemDict::getCode,Constants.SYSTEM)); + if(Objects.isNull(systemDict)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀绫讳笉瀛樺湪"); + } + List<SystemDictData> systemDictList = systemDictDataMapper.selectList( + new QueryWrapper<SystemDictData>().lambda().eq(SystemDictData::getDictId,systemDict.getId())); + if(!com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(systemDictList)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); + } - if (Objects.isNull(systemDict)){ - throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"瀛楀吀涓嶅瓨鍦�"); - } - QuerySystemDictDataDTO dictData = new QuerySystemDictDataDTO(); - dictData.setDictId((systemDict.getId())); - List<SystemDictDataListVO> systemDictDataListVOS = systemDictDataMapper.selectManageList(dictData); - SystemDictData systemDictData = getSystemDictDataListVO(systemDict); - systemDictData.setCode(JSON.toJSONString(miniProgrammeDTO.getLaborConfigParam())); - systemDictData.setLabel(miniProgrammeDTO.getTheme()); - systemDictData.setRemark(miniProgrammeDTO.getDescription()); - if(null != systemDictDataListVOS && systemDictDataListVOS.size() > 0) { - systemDictData.setId(systemDictDataListVOS.get(0).getId()); - systemDictDataMapper.updateById(systemDictData); - }else { - systemDictDataMapper.insert(systemDictData); - } + SystemDictData reservationWay = systemDictList.stream().filter(m->m.getLabel().equals(Constants.MDJ_LW_REQUIRED)).findFirst().get(); + if(Objects.isNull(reservationWay)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮鏉ヨ棰勭害鏂瑰紡 瀛楀吀涓嶅瓨鍦�"); + } + reservationWay.setCode(visitConfigDTO.getReservationWay().toString()); + + SystemDictData checkVisit = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_BEVISITED_USER_VALID)).findFirst().get(); + if(Objects.isNull(checkVisit)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮琚浜烘牎楠屾柟寮� 瀛楀吀涓嶅瓨鍦�"); + } + checkVisit.setCode(visitConfigDTO.getCheckVisit().toString()); + SystemDictData healthCard = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_HEALTH_CARD)).findFirst().get(); + if(Objects.isNull(healthCard)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮鍋ュ悍璇佹槸鍚﹀繀濉� 瀛楀吀涓嶅瓨鍦�"); + } + healthCard.setCode(visitConfigDTO.getHealthCard().toString()); + SystemDictData isAnswer = systemDictList.stream().filter(m->m.getLabel().equals(Constants.PROBLEM_LW_REQUIRED)).findFirst().get(); + if(Objects.isNull(isAnswer)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮鏄惁闇�瑕佺瓟棰� 瀛楀吀涓嶅瓨鍦�"); + } + isAnswer.setCode(visitConfigDTO.getIsAnswer().toString()); + SystemDictData theme = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_THEME)).findFirst().get(); + if(Objects.isNull(theme)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮绛旈涓婚 瀛楀吀涓嶅瓨鍦�"); + } + theme.setCode(visitConfigDTO.getTheme()); + SystemDictData description = systemDictList.stream().filter(m->m.getLabel().equals(Constants.LW_DESCRIPTION)).findFirst().get(); + if(Objects.isNull(description)){ + throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"鍔冲姟璁垮绛旈璇存槑 瀛楀吀涓嶅瓨鍦�"); + } + description.setCode(visitConfigDTO.getDescription()); + + systemDictDataMapper.updateById(reservationWay); + systemDictDataMapper.updateById(checkVisit); + systemDictDataMapper.updateById(healthCard); + systemDictDataMapper.updateById(isAnswer); + systemDictDataMapper.updateById(theme); + systemDictDataMapper.updateById(description); } } -- Gitblit v1.9.3