package ${mapperImplPackage}; import ${doPackage}.${doClassName}; import com.vci.starter.web.wrapper.VciQueryWrapperForDO; import org.apache.commons.lang3.StringUtils; import com.vci.starter.web.util.*; import ${mapperPackage}.${className}DaoI; import com.vci.starter.web.exception.VciBaseException; import com.vci.starter.web.pagemodel.*; import com.vci.web.service.WebBoServiceI; import com.vci.web.service.OsLifeCycleServiceI; import com.vci.pagemodel.BatchCBO; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Repository; import org.springframework.util.CollectionUtils; import plm.bs.bom.clientobject.ClientBusinessObject; import java.util.Collection; import java.util.List; import java.util.Map; import java.util.HashMap; import java.util.ArrayList; import static com.vci.constant.FrameWorkBusLangCodeConstant.DATA_OID_NOT_EXIST; /** * ${comments}数据操作层实现类 * * @author ${author} * @date ${datetime} */ @Repository public class ${className}DaoImpl implements ${className}DaoI{ /** * 业务类型操作的服务 */ @Autowired private WebBoServiceI boService; /** * 生命周期的服务 */ @Autowired private OsLifeCycleServiceI lifeCycleService; /** * 使用主键删除 * @param oid 数据主键 * @return 执行结果 */ @Override public BatchCBO deleteByPrimaryKey(String oid){ VciBaseUtil.alertNotNull(oid,"主键"); ${className}DO ${classNameFristLowwer}DO = selectByPrimaryKey(oid); return boService.delete(${classNameFristLowwer}DO); } /** * 添加数据 * @param record ${comments}数据对象 * @return 执行结果 */ @Override public BatchCBO insert(${className}DO record){ VciBaseUtil.alertNotNull(record,"要添加的数据"); return boService.addSave(record); } /** * 批量添加数据 * @param records ${comments}数据对象集合 * @return 执行结果数 */ @Override public BatchCBO batchInsert(List<${className}DO> records){ VciBaseUtil.alertNotNull(records,"要添加的数据"); BatchCBO batchCBO = boService.batchAddSave(records); return batchCBO; } /** * 根据主键查询 * @param oid 数据主键 * @return 数据对象 */ @Override public ${className}DO selectByPrimaryKey(String oid){ VciBaseUtil.alertNotNull(oid,"主键"); ${className}DO record = boService.selectByOid(oid, ${className}DO.class); if(record == null || StringUtils.isBlank(record.getOid())){ throw new VciBaseException(DATA_OID_NOT_EXIST); } return record; } /** * 根据主键批量获取对象 * @param oids 主键,包含单引号,但是不能超过1000 * @return 数据对象列表 */ @Override public List<${className}DO> selectByPrimaryKeys(String oids){ VciBaseUtil.alertNotNull(oids,"主键集合"); return boService.selectByOidCollection(VciBaseUtil.str2List(oids), ${className}DO.class); } /** * 根据主键批量查询对象 * @param oids 对象主键,使用逗号分隔,但是不能超过1000 * @return 业务对象 */ @Override public List<${className}DO> selectByPrimaryKeyCollection(Collection oids){ VciBaseUtil.alertNotNull(oids,"主键集合"); return boService.selectByOidCollection(oids, ${className}DO.class); } /** * 查询所有分类 * @return 查询结果 */ @Override public List<${className}DO> selectAll(){ return boService.queryObject(${className}DO.class,null); } /** * 更新对象 * @param record ${comments}数据对象 * @return 执行结果 */ @Override public BatchCBO updateByPrimaryKey(${className}DO record){ VciBaseUtil.alertNotNull(record,"要修改的对象",record.getOid(),"主键"); return boService.editSave(record); } /** * 批量更新 * @param records ${comments}数据对象集合 * @return 执行结果行数 */ @Override public BatchCBO batchUpdate(List<${className}DO> records){ VciBaseUtil.alertNotNull(records,"要修改的对象"); BatchCBO batchCBO = boService.batchEditSave(records); return batchCBO; } /** * 根据查询条件查询数据 * @param conditionMap 查询条件, * @param pageHelper 包括分页,排序 * @return 数据对象列表 */ @Override public List<${className}DO> selectByCondition(Map< String,String> conditionMap, PageHelper pageHelper){ return boService.queryObject(${className}DO.class,conditionMap,pageHelper); } /** * 根据查询条件来查询总数 * @param conditionMap 查询条件 * @return 总数 */ @Override public Long countByCondition(Map< String,String> conditionMap){ return VciBaseUtil.getLong(String.valueOf(boService.queryCount(${className}DO.class,conditionMap))); } /** * 根据查询封装器来查询数据 * @param queryWrapper 查询封装器 * @return 数据对象列表 */ @Override public List<${className}DO> selectByWrapper(VciQueryWrapperForDO queryWrapper){ return boService.selectByQueryWrapper(queryWrapper,${className}DO.class); } /** * 根据查询封装器来查询总数 * @param queryWrapper 查询封装器 * @return 总数 */ @Override public Long countByWrapper(VciQueryWrapperForDO queryWrapper){ return VciBaseUtil.getLong(String.valueOf(boService.countByQueryWrapper(queryWrapper,${className}DO.class))); } /** * 根据主键获取名称 * @param oid 主键 * @return 中文名称 */ @Override public String selectNameByOid(String oid){ return selectByPrimaryKey(oid).getName(); } #if(${hasParentField}) /** * 获取所有层级下级的主键 * @param oid 数据主键 * @return 查询结果 */ @Override public List selectAllLevelChildOid(String oid){ String sql = "select oid from ${tableName} START WITH ${parentFieldName} = :oid CONNECT BY PRIOR OID= ${parentFieldName}"; Map< String,String> conditionMap = new HashMap< String,String>(); conditionMap.put("oid",oid); List dataList = boService.queryBySqlForMap(sql,conditionMap); List oidList = new ArrayList(); if(!CollectionUtils.isEmpty(dataList)){ for(Map data:dataList){ oidList.add(VciBaseUtil.getStringValueFromObject(data.get("oid"))); } } return oidList; } /** * 获取所有下级数据 * @param oid 数据主键 * @return 查询结果 */ @Override public List<${className}DO> selectAllLevelChild(String oid){ return boService.selectByOidCollection(selectAllLevelChildOid(oid),${className}DO.class); } /** * 查询某个节点的所有层级下级的个数 * @param oid 主键 * @return 总数 */ @Override public long countAllLevelChildOid(String oid){ String sql = "select count(OID) as countsize from ${tableName} START WITH ${parentFieldName} = :oid CONNECT BY PRIOR OID = ${parentFieldName}"; Map< String,String> conditionMap = new HashMap< String,String>(); conditionMap.put("oid",oid); List dataList = boService.queryBySqlForMap(sql,conditionMap); return !CollectionUtils.isEmpty(dataList)?VciBaseUtil.getInt(VciBaseUtil.getStringValueFromObject(dataList.get(0).get("countsize"))):0; } #end #if(${hasStatus}) /** * 批量修改生命周期的状态 * @param oids 主键集合,不能大于1000 * @param lcStatus 生命周期的值 * @return 执行的结果 */ @Override public long batchUpdateLcStatus(Collection oids, String lcStatus){ List cbos = boService.selectCBOByOidCollection(oids, "${btmTypeId}"); if(CollectionUtils.isEmpty(cbos)){ return 0; } lifeCycleService.transCboStatus(cbos,lcStatus); return cbos.size(); } /** * 根据主键更新状态 * @param oid 主键 * @param lcStatus 生命周期状态 * @return 受影响的行数 */ @Override public int updateLcStatus( String oid, String lcStatus){ ClientBusinessObject cbo = boService.selectCBOByOid(oid, "${btmTypeId}"); if(cbo == null || StringUtils.isBlank(cbo.getOid())){ return 0; } lifeCycleService.transStatus(cbo.getBusinessObject(),lcStatus); return 1; } #end /** * 批量删除对象 * @param oids 对象的主键集合 * @return 受影响的行数 */ @Override public BatchCBO batchDeleteByOids(Collection oids){ List<${className}DO> dos = boService.selectByOidCollection(oids, ${className}DO.class); BatchCBO batchCBO = boService.batchDelete(dos); return batchCBO; } }