package com.vci.ubcs.code.service.impl; import com.vci.ubcs.code.mapper.DockingPreApplyDataInfoMapper; import com.vci.ubcs.code.entity.DockingPreApplyDataInfoDO; import com.vci.ubcs.code.service.DockingPreApplyDataInfoServiceI; import com.vci.starter.revision.service.RevisionModelUtil; import com.vci.starter.web.exception.VciBaseException; import com.vci.starter.web.pagemodel.BaseResult; import com.vci.starter.web.pagemodel.DataGrid; import com.vci.starter.web.pagemodel.PageHelper; import com.vci.starter.web.util.BeanUtilForVCI; import com.vci.starter.web.util.VciBaseUtil; import com.vci.web.pageModel.BatchCBO; import com.vci.web.service.WebBoServiceI; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.vci.ubcs.code.dto.DockingPreApplyDataInfoDTO; import com.vci.ubcs.code.vo.pagemodel.DockingPreApplyDataInfoVO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.util.*; import static com.vci.frameworkcore.constant.FrameWorkLangCodeConstant.*; /** * 记录工艺推送过来的数据信息服务 * @author weidy * @date 2022-04-05 */ @Service public class DockingPreApplyDataInfoServiceImpl implements DockingPreApplyDataInfoServiceI { /** * 日志 */ private Logger logger = LoggerFactory.getLogger(getClass()); /** * 数据操作层 */ @Resource private DockingPreApplyDataInfoMapper dockingPreApplyDataInfoMapper; /** * 业务类型操作的服务 */ @Autowired @Lazy private WebBoServiceI boService; /** * 对象的操作 */ @Autowired private RevisionModelUtil revisionModelUtil; /** * 查询所有的记录工艺推送过来的数据信息 * @param conditionMap 查询条件 * @param pageHelper 分页和排序 * @return 执行结果 * @throws VciBaseException 查询条件和分页出错的时候会抛出异常 */ @Override public DataGrid gridDockingPreApplyDataInfo(Map conditionMap, PageHelper pageHelper) throws VciBaseException{ if (pageHelper == null) { pageHelper = new PageHelper(-1); } pageHelper.addDefaultDesc("createTime"); List doList = dockingPreApplyDataInfoMapper.selectByCondition(conditionMap,pageHelper); DataGrid dataGrid=new DataGrid(); if (!CollectionUtils.isEmpty(doList)) { dataGrid.setData(dockingPreApplyDataInfoDO2VOs(doList)); dataGrid.setTotal(VciBaseUtil.getInt(String.valueOf(dockingPreApplyDataInfoMapper.countByCondition(conditionMap)))); } return dataGrid; } /** * 批量数据对象转换为显示对象 * @param dockingPreApplyDataInfoDOs 数据对象列表 * @return 显示对象 * @throws VciBaseException 参数为空或者不存在的时候会抛出异常 */ @Override public List dockingPreApplyDataInfoDO2VOs(Collection dockingPreApplyDataInfoDOs) throws VciBaseException{ List voList = new ArrayList(); if(!CollectionUtils.isEmpty(dockingPreApplyDataInfoDOs)){ for(DockingPreApplyDataInfoDO s: dockingPreApplyDataInfoDOs){ DockingPreApplyDataInfoVO vo = dockingPreApplyDataInfoDO2VO(s); if(vo != null){ voList.add(vo); } } } return voList; } /** * 数据对象转换为显示对象 * @param dockingPreApplyDataInfoDO 数据对象 * @return 显示对象 * @throws VciBaseException 拷贝属性出错的时候会抛出异常 */ @Override public DockingPreApplyDataInfoVO dockingPreApplyDataInfoDO2VO(DockingPreApplyDataInfoDO dockingPreApplyDataInfoDO) throws VciBaseException{ DockingPreApplyDataInfoVO vo = new DockingPreApplyDataInfoVO(); if(dockingPreApplyDataInfoDO != null){ BeanUtilForVCI.copyPropertiesIgnoreCase(dockingPreApplyDataInfoDO,vo); //如果有lcstatus的类的话 } return vo; } /** * 增加记录工艺推送过来的数据信息 * @param dockingPreApplyDataInfoDTO 记录工艺推送过来的数据信息数据传输对象 * @return 执行结果 * @throws VciBaseException 参数为空,唯一项,必输项不通过时会抛出异常 */ @Override public DockingPreApplyDataInfoVO addSave(DockingPreApplyDataInfoDTO dockingPreApplyDataInfoDTO) throws VciBaseException{ VciBaseUtil.alertNotNull(dockingPreApplyDataInfoDTO,"需要添加的数据对象"); //将DTO转换为DO DockingPreApplyDataInfoDO dockingPreApplyDataInfoDO = new DockingPreApplyDataInfoDO(); BeanUtilForVCI.copyPropertiesIgnoreCase(dockingPreApplyDataInfoDTO,dockingPreApplyDataInfoDO); dockingPreApplyDataInfoMapper.insert(dockingPreApplyDataInfoDO); return dockingPreApplyDataInfoDO2VO(dockingPreApplyDataInfoDO); } /** * 修改记录工艺推送过来的数据信息 * @param dockingPreApplyDataInfoDTO 记录工艺推送过来的数据信息数据传输对象 * @return 执行结果 * @throws VciBaseException 参数为空,唯一项,必输项不通过时会抛出异常 */ @Override public DockingPreApplyDataInfoVO editSave(DockingPreApplyDataInfoDTO dockingPreApplyDataInfoDTO) throws VciBaseException{ VciBaseUtil.alertNotNull(dockingPreApplyDataInfoDTO,"数据对象",dockingPreApplyDataInfoDTO.getOid(),"记录工艺推送过来的数据信息主键"); //将DTO转换为DO DockingPreApplyDataInfoDO dockingPreApplyDataInfoDO = selectByOid(dockingPreApplyDataInfoDTO.getOid()); revisionModelUtil.copyFromDTOIgnore(dockingPreApplyDataInfoDTO,dockingPreApplyDataInfoDO); dockingPreApplyDataInfoMapper.updateByPrimaryKey(dockingPreApplyDataInfoDO); return dockingPreApplyDataInfoDO2VO(dockingPreApplyDataInfoDO); } /** * 校验是否可以删除,如果存在下级,并且下级有数据引用则不能删除 * @param dockingPreApplyDataInfoDTO 数据传输对象 * @param dockingPreApplyDataInfoDO 数据库中的数据对象 * @return success为true为可以删除,false表示有数据引用,obj为true表示有下级 */ private BaseResult checkIsCanDeleteForDO(DockingPreApplyDataInfoDTO dockingPreApplyDataInfoDTO, DockingPreApplyDataInfoDO dockingPreApplyDataInfoDO) { DockingPreApplyDataInfoDO tsDO = new DockingPreApplyDataInfoDO(); BeanUtilForVCI.copyPropertiesIgnoreCase(dockingPreApplyDataInfoDTO,tsDO); boService.checkTs(tsDO); if(!checkIsLinked(dockingPreApplyDataInfoDO.getOid())) { return BaseResult.success(); }else{ return BaseResult.fail(DATA_LINKED_NOT_DELETE,new String[]{""}); } } /** * 校验是否被引用 * @param oid 主键 * @throws VciBaseException 被引用的时候会抛出异常 */ private boolean checkIsLinked(String oid) throws VciBaseException{ //TODO 添加需要校验引用的地方 return false; } /** * 删除记录工艺推送过来的数据信息 * @param dockingPreApplyDataInfoDTO 记录工艺推送过来的数据信息数据传输对象,oid和ts需要传输 * @return 删除结果反馈::success:成功,fail:失败 * @throws VciBaseException 参数为空,被引用时抛出异常 */ @Override public BaseResult deleteDockingPreApplyDataInfo(DockingPreApplyDataInfoDTO dockingPreApplyDataInfoDTO) throws VciBaseException{ VciBaseUtil.alertNotNull(dockingPreApplyDataInfoDTO,"记录工艺推送过来的数据信息数据对象",dockingPreApplyDataInfoDTO.getOid(),"记录工艺推送过来的数据信息的主键"); DockingPreApplyDataInfoDO dockingPreApplyDataInfoDO = selectByOid(dockingPreApplyDataInfoDTO.getOid()); BaseResult baseResult = checkIsCanDeleteForDO(dockingPreApplyDataInfoDTO,dockingPreApplyDataInfoDO); if(baseResult.isSuccess()) { }else{ return baseResult; } //执行删除操作 BatchCBO batchCBO = dockingPreApplyDataInfoMapper.deleteByPrimaryKey(dockingPreApplyDataInfoDO.getOid()); return (batchCBO!=null && batchCBO.getDeleteCbos() !=null &&batchCBO.getDeleteCbos().size() > 0)?BaseResult.successMsg(DELETE_SUCCESS):BaseResult.fail(DELETE_FAIL); } /** * 主键获取记录工艺推送过来的数据信息 * @param oid 主键 * @return 记录工艺推送过来的数据信息显示对象 * @throws VciBaseException 参数为空,数据不存在时会抛出异常 */ @Override public DockingPreApplyDataInfoVO getObjectByOid(String oid) throws VciBaseException{ return dockingPreApplyDataInfoDO2VO(selectByOid(oid)); } /** * 主键查询数据对象 * @param oid 主键 * @return 数据对象 * @throws VciBaseException 参数为空,并且数据不存在的时候会抛出异常 */ private DockingPreApplyDataInfoDO selectByOid(String oid) throws VciBaseException{ VciBaseUtil.alertNotNull(oid,"主键"); DockingPreApplyDataInfoDO dockingPreApplyDataInfoDO = dockingPreApplyDataInfoMapper.selectByPrimaryKey(oid.trim()); if(dockingPreApplyDataInfoDO == null || StringUtils.isBlank(dockingPreApplyDataInfoDO.getOid())){ throw new VciBaseException(DATA_OID_NOT_EXIST); } return dockingPreApplyDataInfoDO; } /** * 主键批量获取记录工艺推送过来的数据信息 * @param oidCollections 主键集合,但是受性能影响,建议一次查询不超过10000个 * @return 记录工艺推送过来的数据信息显示对象 * @throws VciBaseException 查询出现异常时会抛出 */ @Override public Collection listDockingPreApplyDataInfoByOids(Collection oidCollections) throws VciBaseException{ VciBaseUtil.alertNotNull(oidCollections,"数据对象主键集合"); List dockingPreApplyDataInfoDOList = listDockingPreApplyDataInfoDOByOidCollections(oidCollections); return dockingPreApplyDataInfoDO2VOs(dockingPreApplyDataInfoDOList); } /** * 使用主键集合查询数据对象 * @param oidCollections 主键的集合 * @return 数据对象列表 */ private List listDockingPreApplyDataInfoDOByOidCollections(Collection oidCollections){ List dockingPreApplyDataInfoDOList = new ArrayList(); if(!CollectionUtils.isEmpty(oidCollections)){ Collection> oidCollectionsList = VciBaseUtil.switchCollectionForOracleIn(oidCollections); for(Collection oids: oidCollectionsList){ List tempDOList = dockingPreApplyDataInfoMapper.selectByPrimaryKeyCollection(oids); if(!CollectionUtils.isEmpty(tempDOList)){ dockingPreApplyDataInfoDOList.addAll(tempDOList); } } } return dockingPreApplyDataInfoDOList; } /** * 参照记录工艺推送过来的数据信息列表 * @param conditionMap 查询条件 * @param pageHelper 分页和排序 * @return 记录工艺推送过来的数据信息显示对象列表,生效的内容 * @throws VciBaseException 查询条件和分页出错的时候会抛出异常 */ @Override public DataGrid refDataGridDockingPreApplyDataInfo(Map conditionMap, PageHelper pageHelper) throws VciBaseException{ if(conditionMap == null){ conditionMap = new HashMap(); } return gridDockingPreApplyDataInfo(conditionMap,pageHelper); } }