iailab-plat.git

liriming

2024-08-26 aecc4908e1f2861d2dab1929a88f9053238b2dd2

提交 \| 用户 \| 时间
a6de49	1	package com.iailab.module.data.ind.service.impl;
H	2
	3	import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
	4	import com.baomidou.mybatisplus.core.metadata.IPage;
	5	import com.iailab.framework.common.constant.Constant;
	6	import com.iailab.module.data.common.enums.CommonConstant;
	7	import com.iailab.module.data.common.enums.IsEnableEnum;
	8	import com.iailab.framework.common.page.PageData;
	9	import com.iailab.framework.common.service.impl.BaseServiceImpl;
	10	import com.iailab.framework.common.util.object.ConvertUtils;
	11	import com.iailab.module.data.ind.dto.IndItemAtomDTO;
	12	import com.iailab.module.data.ind.service.IndItemCalService;
	13	import com.iailab.module.data.ind.service.IndItemService;
	14	import com.iailab.module.data.ind.common.IndItemTypeEnum;
	15	import com.iailab.module.data.ind.dao.IndItemDao;
	16	import com.iailab.module.data.ind.dto.IndItemCalDTO;
	17	import com.iailab.module.data.ind.dto.IndItemDTO;
	18	import com.iailab.module.data.ind.entity.IndItemEntity;
	19	import com.iailab.module.data.ind.service.IndItemAtomService;
	20	import org.apache.commons.lang3.StringUtils;
	21	import javax.annotation.Resource;
	22	import org.springframework.stereotype.Service;
	23	import org.springframework.transaction.annotation.Transactional;
	24	import org.springframework.util.CollectionUtils;
	25
	26	import java.util.*;
	27
	28	/**
	29	* @author PanZhibao
	30	* @Description
	31	* @createTime 2024年05月25日
	32	*/
	33	@Service
	34	public class IndItemServiceImpl extends BaseServiceImpl<IndItemDao, IndItemEntity> implements IndItemService {
	35
	36	@Resource
	37	private IndItemAtomService indItemAtomService;
	38
	39	@Resource
	40	private IndItemCalService indItemCalService;
	41
	42	@Override
	43	public PageData<IndItemDTO> page(Map<String, Object> params) {
	44	IPage<IndItemEntity> page = baseDao.selectPage(
	45	getPage(params, Constant.CREATE_TIME, false),
	46	getWrapper(params)
	47	);
	48	return getPageData(page, IndItemDTO.class);
	49	}
	50
	51	@Override
	52	public List<IndItemDTO> getList(Map<String, Object> params) {
	53	List<IndItemEntity> list = baseDao.selectList(getWrapper(params));
	54	return ConvertUtils.sourceToTarget(list, IndItemDTO.class);
	55	}
	56
	57	@Override
	58	public void enableByIds(String[] ids) {
	59	if (CollectionUtils.isEmpty(Arrays.asList(ids))) {
	60	return;
	61	}
	62	Arrays.asList(ids).forEach(item -> {
	63	IndItemEntity entity = new IndItemEntity();
	64	entity.setId(item);
	65	entity.setIsEnable(IsEnableEnum.ENABLE.value());
	66	baseDao.updateById(entity);
	67	});
	68	}
	69
	70	@Override
	71	public void disableByIds(String[] ids) {
	72	if (CollectionUtils.isEmpty(Arrays.asList(ids))) {
	73	return;
	74	}
	75	Arrays.asList(ids).forEach(item -> {
	76	IndItemEntity entity = new IndItemEntity();
	77	entity.setId(item);
	78	entity.setIsEnable(IsEnableEnum.DISABLE.value());
	79	baseDao.updateById(entity);
	80	});
	81	}
	82
	83	@Override
	84	public IndItemDTO getItemByItemNo(String itemNo) {
	85	QueryWrapper<IndItemEntity> wrapper = new QueryWrapper<>();
	86	wrapper.eq("item_no", itemNo);
	87	return ConvertUtils.sourceToTarget(baseDao.selectOne(wrapper),IndItemDTO.class);
	88	}
	89
	90	private QueryWrapper<IndItemEntity> getWrapper(Map<String, Object> params){
	91	String itemNo = (String)params.get("itemNo");
	92
	93	QueryWrapper<IndItemEntity> wrapper = new QueryWrapper<>();
	94	wrapper.like(StringUtils.isNotBlank(itemNo), "item_no", itemNo);
	95
	96	return wrapper;
	97	}
	98
	99	@Override
	100	public IndItemDTO get(String id) {
	101	IndItemEntity entity = baseDao.selectById(id);
	102	if (entity == null) {
	103	return null;
	104	}
	105	IndItemDTO result = ConvertUtils.sourceToTarget(entity, IndItemDTO.class);
	106	if (IndItemTypeEnum.ATOM_ITEM.getCode().equals(result.getItemType())) {
	107	IndItemAtomDTO dto = indItemAtomService.getItemId(id);
	108	result.setIndItemAtom(dto);
	109	} else if (IndItemTypeEnum.CAL_ITEM.getCode().equals(result.getItemType())) {
	110	IndItemCalDTO dto = indItemCalService.getItemId(id);
	111	result.setIndItemCal(dto);
	112	}
	113	return result;
	114	}
	115
	116	@Override
	117	public void save(IndItemDTO dto) {
	118	IndItemEntity entity = ConvertUtils.sourceToTarget(dto, IndItemEntity.class);
	119	entity.setId(UUID.randomUUID().toString());
	120	if (IndItemTypeEnum.ATOM_ITEM.getName().equals(entity.getItemType())) {
	121	IndItemAtomDTO indItemAtomDTO = new IndItemAtomDTO();
	122	indItemAtomDTO.setId(UUID.randomUUID().toString());
	123	indItemAtomDTO.setItemId(entity.getId());
	124	indItemAtomDTO.setDataSource(dto.getDataSource());
	125	indItemAtomDTO.setQuerySql(dto.getQuerySql());
	126	indItemAtomService.save(indItemAtomDTO);
	127	}else if (IndItemTypeEnum.CAL_ITEM.getName().equals(entity.getItemType())){
	128	IndItemCalDTO indItemCalDTO = new IndItemCalDTO();
	129	indItemCalDTO.setId(UUID.randomUUID().toString());
	130	indItemCalDTO.setItemId(entity.getId());
	131	indItemCalDTO.setExpression(dto.getExpression());
	132	indItemCalService.save(indItemCalDTO);
	133	}
	134	entity.setIsEnable(CommonConstant.IS_ENABLE);
	135	entity.setCreateTime(new Date());
	136	insert(entity);
	137	}
	138
	139	@Override
	140	public void update(IndItemDTO dto) {
	141	IndItemEntity entity = ConvertUtils.sourceToTarget(dto, IndItemEntity.class);
	142	entity.setUpdateTime(new Date());
	143	updateById(entity);
	144	System.out.println(IndItemTypeEnum.ATOM_ITEM.getName()+IndItemTypeEnum.CAL_ITEM.getName());
	145	if (IndItemTypeEnum.ATOM_ITEM.getName().equals(entity.getItemType())) {
	146	dto.getIndItemAtom().setDataSource(dto.getDataSource());
	147	dto.getIndItemAtom().setQuerySql(dto.getQuerySql());
	148	indItemAtomService.update(dto.getIndItemAtom());
	149	}else if (IndItemTypeEnum.CAL_ITEM.getName().equals(entity.getItemType())){
	150	dto.getIndItemCal().setExpression(dto.getExpression());
	151	indItemCalService.update(dto.getIndItemCal());
	152	}
	153	}
	154
	155	@Override
	156	@Transactional(rollbackFor = Exception.class)
	157	public void delete(String[] ids) {
	158	baseDao.deleteBatchIds(Arrays.asList(ids));
	159	indItemAtomService.deleteByItemId(ids);
	160	indItemCalService.deleteByItemId(ids);
	161	}
	162
	163	@Override
	164	public List<IndItemDTO> getItemAtom(List<String> itemNos) {
	165	Map<String, Object> params = new HashMap<>();
	166	params.put("itemType", IndItemTypeEnum.ATOM_ITEM.getCode());
	167	params.put("isEnable", CommonConstant.IS_ENABLE);
	168	params.put("itemNos", itemNos);
	169	return baseDao.getItemAtom(params);
	170	}
	171
	172	@Override
	173	public IndItemDTO getItemAtom(String itemNo) {
	174	IndItemDTO result = null;
	175	Map<String, Object> params = new HashMap<>();
	176	params.put("itemType", IndItemTypeEnum.ATOM_ITEM.getCode());
	177	params.put("isEnable", CommonConstant.IS_ENABLE);
	178	params.put("itemNo", itemNo);
	179	List<IndItemDTO> list = baseDao.getItemAtom(params);
	180	if (!CollectionUtils.isEmpty(list)) {
	181	result = list.get(0);
	182	}
	183	return result;
	184	}
	185
	186	@Override
	187	public List<IndItemDTO> getItemCal(List<String> itemNos) {
	188	Map<String, Object> params = new HashMap<>();
	189	params.put("itemType", IndItemTypeEnum.CAL_ITEM.getCode());
	190	params.put("isEnable", CommonConstant.IS_ENABLE);
	191	params.put("itemNos", itemNos);
	192	return baseDao.getItemCal(params);
	193	}
	194
	195	@Override
	196	public IndItemDTO getItemCal(String itemNo) {
	197	IndItemDTO result = null;
	198	Map<String, Object> params = new HashMap<>();
	199	params.put("itemType", IndItemTypeEnum.CAL_ITEM.getCode());
	200	params.put("isEnable", CommonConstant.IS_ENABLE);
	201	params.put("itemNo", itemNo);
	202	List<IndItemDTO> list = baseDao.getItemCal(params);
	203	if (!CollectionUtils.isEmpty(list)) {
	204	result = list.get(0);
	205	}
	206	return result;
	207	}
	208	}