package com.vci.web.dao.impl;
|
|
import com.vci.corba.omd.data.BusinessObject;
|
import com.vci.starter.web.constant.QueryOptionConstant;
|
import com.vci.starter.web.exception.VciBaseException;
|
import com.vci.starter.web.pagemodel.PageHelper;
|
import com.vci.starter.web.util.VciBaseUtil;
|
import com.vci.starter.web.wrapper.VciQueryWrapperForDO;
|
import com.vci.web.dao.OsCodeBreakCodeDaoI;
|
import com.vci.web.model.OsCodeBreakCodeDO;
|
import com.vci.web.pageModel.BatchCBO;
|
import com.vci.web.service.WebBoServiceI;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Repository;
|
import org.springframework.util.CollectionUtils;
|
|
import java.util.Collection;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import static com.vci.frameworkcore.constant.FrameWorkBusLangCodeConstant.DATA_OID_NOT_EXIST;
|
|
/**
|
* Description:断码内容数据操作层实现类
|
*
|
* @author Lihang
|
* @date 2021/10/15 11:49
|
*/
|
@Repository
|
public class OsCodeBreakCodeDaoImpl implements OsCodeBreakCodeDaoI {
|
/**
|
* 业务类型的服务
|
*/
|
@Autowired
|
private WebBoServiceI boService;
|
|
/**
|
* 使用主键删除
|
* @param oid 数据主键
|
* @return 执行结果
|
*/
|
@Override
|
public int deleteByPrimaryKey(String oid) {
|
VciBaseUtil.alertNotNull(oid,"主键");
|
OsCodeBreakCodeDO codeBreakCodeDO = selectByPrimaryKey(oid);
|
this.boService.delete(codeBreakCodeDO);
|
return 1;
|
}
|
|
/**
|
* 添加数据
|
* @param record 编码规则数据对象
|
* @return 执行结果
|
*/
|
@Override
|
public int insert(OsCodeBreakCodeDO record) {
|
VciBaseUtil.alertNotNull(record,"要添加的数据");
|
boService.addSave(record);
|
return 1;
|
}
|
|
/**
|
* 根据主键查询
|
* @param oid 数据主键
|
* @return 数据对象
|
*/
|
@Override
|
public OsCodeBreakCodeDO selectByPrimaryKey(String oid) {
|
VciBaseUtil.alertNotNull(oid,"主键");
|
OsCodeBreakCodeDO record = boService.selectByOid(oid, OsCodeBreakCodeDO.class);
|
if(record == null || StringUtils.isBlank(record.getOid())){
|
throw new VciBaseException(DATA_OID_NOT_EXIST);
|
}
|
return record;
|
}
|
|
/**
|
* 根据主键批量获取对象
|
* @param oids 主键，包含单引号,但是不能超过1000
|
* @return 数据对象列表
|
*/
|
@Override
|
public List<OsCodeBreakCodeDO> selectByPrimaryKeys(String oids) {
|
VciBaseUtil.alertNotNull(oids,"主键集合");
|
return boService.selectByOidCollection(VciBaseUtil.str2List(oids), OsCodeBreakCodeDO.class);
|
}
|
|
/**
|
* 根据主键批量查询对象
|
* @param oids 对象主键,使用逗号分隔，但是不能超过1000
|
* @return 业务对象
|
*/
|
@Override
|
public List<OsCodeBreakCodeDO> selectByPrimaryKeyCollection(Collection<String> oids) {
|
VciBaseUtil.alertNotNull(oids,"主键集合");
|
return boService.selectByOidCollection(oids, OsCodeBreakCodeDO.class);
|
}
|
|
/**
|
* 查询所有分类
|
* @return 查询结果
|
*/
|
@Override
|
public List<OsCodeBreakCodeDO> selectAll() {
|
return boService.queryObject(OsCodeBreakCodeDO.class,null);
|
}
|
|
/**
|
* 更新对象
|
* @param record 编码规则数据对象
|
* @return 执行结果
|
*/
|
@Override
|
public int updateByPrimaryKey(OsCodeBreakCodeDO record) {
|
VciBaseUtil.alertNotNull(record,"要修改的对象",record.getOid(),"主键");
|
boService.editSave(record);
|
return 1;
|
}
|
|
/**
|
* 根据查询条件查询数据
|
* @param condition 查询条件，
|
* @param pageHelper 包括分页，排序
|
* @return 数据对象列表
|
*/
|
@Override
|
public List<OsCodeBreakCodeDO> selectByCondition(Map<String, String> condition, PageHelper pageHelper) {
|
return boService.queryObject(OsCodeBreakCodeDO.class,condition,pageHelper);
|
}
|
|
/**
|
* 根据查询条件来查询总数
|
* @param condition 查询条件
|
* @return 总数
|
*/
|
@Override
|
public Long countByCondition(Map<String, String> condition) {
|
return VciBaseUtil.getLong(String.valueOf(boService.queryCount(OsCodeBreakCodeDO.class,condition)));
|
}
|
|
/**
|
* 根据主键获取名称
|
* @param oid 主键
|
* @return 中文名称
|
*/
|
@Override
|
public String selectNameByOid(String oid) {
|
return selectByPrimaryKey(oid).getName();
|
}
|
|
/**
|
* 批量删除对象
|
* @param oids 对象的主键集合
|
* @return 受影响的行数
|
*/
|
@Override
|
public long batchDeleteByOids(Collection<String> oids) {
|
List<OsCodeBreakCodeDO> dos = boService.selectByOidCollection(oids, OsCodeBreakCodeDO.class);
|
BatchCBO batchCBO = boService.batchDelete(dos);
|
return batchCBO.getDeleteCbos().size();
|
}
|
|
/**
|
* 查询断码的值
|
* @param ruleOid 编码规则主键
|
* @param serialAccord 流水依据
|
* @return 断码的值，取第一个
|
*/
|
@Override
|
public OsCodeBreakCodeDO selectByAccordingAndRuleOid(String ruleOid, String serialAccord) {
|
VciBaseUtil.alertNotNull(ruleOid,"规则分类",serialAccord,"流水依据");
|
Map<String,String> conditionMap = new HashMap<String, String>();
|
conditionMap.put("pkcoderule",ruleOid);
|
List<BusinessObject> queryList = this.boService.queryCBO("codebreakcode", conditionMap);
|
if (CollectionUtils.isEmpty(queryList)){
|
throw new VciBaseException("规则分类[{0}]在系统中不存在",new String[]{ruleOid});
|
}
|
conditionMap.clear();
|
String oid = "";
|
for (BusinessObject object : queryList) {
|
oid += object.oid + ",";
|
}
|
oid = "(" + oid.substring(0,oid.length() -1) + ")";
|
conditionMap.put("oid", QueryOptionConstant.IN + oid);
|
conditionMap.put("serialunit",serialAccord);
|
conditionMap.put("rownum","1");
|
List<OsCodeBreakCodeDO> codeDOList = this.boService.queryObject(OsCodeBreakCodeDO.class, conditionMap);
|
if (CollectionUtils.isEmpty(codeDOList)){
|
throw new VciBaseException("规则分类[{0}]下没有找到编号为{1}的流水依据",new String[]{ruleOid,serialAccord});
|
}
|
return codeDOList.get(0);
|
}
|
}
|
