package com.qianwen.smartman.modules.smis.service;
|
|
import java.io.IOException;
|
import java.nio.charset.Charset;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
import org.apache.commons.io.IOUtils;
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.qianwen.core.mp.base.BaseServiceImpl;
|
import com.qianwen.smartman.modules.smis.entity.CollectDeviceType;
|
import com.qianwen.smartman.modules.smis.mapper.CollectDeviceTypeMapper;
|
import com.qianwen.smartman.modules.smis.vo.CollectDeviceTypeVO;
|
|
@Service
|
public class CollectDeviceTypeService extends BaseServiceImpl<CollectDeviceTypeMapper, CollectDeviceType> {
|
|
|
/**
|
* 新增或者更新模板
|
* @param tpl
|
*/
|
public List<CollectDeviceTypeVO> typeList() {
|
|
List<CollectDeviceType> list = this.baseMapper.selectList(Wrappers.emptyWrapper());
|
Charset utf8charset = Charset.forName("utf8");
|
String startJsonStr= "[]";
|
String endJsonStr = "[]";
|
try {
|
startJsonStr = IOUtils.resourceToString("/dp/dpstart.json", utf8charset);
|
endJsonStr = IOUtils.resourceToString("/dp/dpend.json", utf8charset);
|
} catch (IOException e) {
|
log.error("读取默认dpHead异常",e);
|
}
|
final String startStr = startJsonStr;
|
final String endStr = endJsonStr;
|
List<CollectDeviceTypeVO> voList = list.stream().map(t -> {
|
|
CollectDeviceTypeVO vo = new CollectDeviceTypeVO();
|
vo.setId(t.getId());
|
vo.setDpHead(t.getDpHead());
|
vo.setName(t.getName());
|
|
vo.setDpHeadFull(mergeJson(startStr,t.getDpHead(),endStr));
|
|
return vo;
|
}).collect(Collectors.toList());
|
|
return voList;
|
}
|
|
public static String mergeJson(String start,String dpHead,String end) {
|
JSONArray s = JSONArray.parseArray(start);
|
JSONArray h = JSONArray.parseArray(dpHead);
|
JSONArray e = JSONArray.parseArray(end);
|
|
s.addAll(h);
|
s.addAll(e);
|
|
return s.toJSONString();
|
}
|
|
}
|
