From 7702ccf5e43965aae28687eb13a248c12ced6665 Mon Sep 17 00:00:00 2001 From: huxin Date: Fri, 9 May 2025 21:11:27 +0800 Subject: [PATCH] =?UTF-8?q?=E9=A2=84=E8=AD=A6=E4=BF=A1=E6=81=AF=E7=AE=A1?= =?UTF-8?q?=E7=90=86=E5=8A=9F=E8=83=BD=E5=BC=80=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/IDklMonitoringPointsService.java | 127 +++++ .../impl/DklMonitoringPointsServiceImpl.java | 504 ++++++++++++++++++ 2 files changed, 631 insertions(+) create mode 100644 Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/IDklMonitoringPointsService.java create mode 100644 Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java diff --git a/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/IDklMonitoringPointsService.java b/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/IDklMonitoringPointsService.java new file mode 100644 index 0000000..4162a4c --- /dev/null +++ b/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/IDklMonitoringPointsService.java @@ -0,0 +1,127 @@ +package com.dkl.large.service; + +import java.util.List; + +import com.koal.kms.sdk.ed.KmsSdkException; +import com.dkl.large.domain.DklActivity; +import com.dkl.large.domain.DklMonitoringCameraData; +import com.dkl.large.domain.DklMonitoringPoints; +import com.dkl.large.domain.vo.DklMonitoringCameraDataVo; +import com.dkl.large.domain.vo.HeatVo; +import com.dkl.large.domain.vo.RegionalVo; +import com.dkl.large.domain.vo.RiskVo; + +/** + * 监控点信息Service接口 + * + * @author Dkl + * @date 2025-06-10 + */ +public interface IDklMonitoringPointsService +{ + /** + * 查询监控点信息 + * + * @param id 监控点信息主键 + * @return 监控点信息 + */ + public DklMonitoringPoints selectDklMonitoringPointsById(Long id) throws KmsSdkException; + + /** + * 查询监控点信息列表 + * + * @param dklMonitoringPoints 监控点信息 + * @return 监控点信息集合 + */ + + public List selectDklMonitoringPointsList(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException; + public String selectDklMonitoringPointsListMeaasge(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException; + /** + * 新增监控点信息 + * + * @param dklMonitoringPoints 监控点信息 + * @return 结果 + */ + public int insertDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException; + + /** + * 修改监控点信息 + * + * @param dklMonitoringPoints 监控点信息 + * @return 结果 + */ + public int updateDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException; + + /** + * 批量删除监控点信息 + * + * @param ids 需要删除的监控点信息主键集合 + * @return 结果 + */ + public int deleteDklMonitoringPointsByIds(int[] ids); + + /** + * 删除监控点信息信息 + * + * @param id 监控点信息主键 + * @return 结果 + */ + public int deleteDklMonitoringPointsById(Long id); + + /** + * 监控点热力图 + * + * @param dataVo + * @return 结果 + */ + public List heatMap(HeatVo dataVo); + + /** + * 大客流总数区域展示图 + * + * @param regionalVo + * @return 结果 + */ + public List regionalStatistics(RegionalVo regionalVo); + + /** + * 大客流总数区域数据 + * + * @param regionalVo + * @return 结果 + */ + public List regionalDataList(RegionalVo regionalVo) throws KmsSdkException; + + /** + * 大客流风险预警信息 + * + * @param riskVo + * @return 结果 + */ + public List riskDataList(RiskVo riskVo); + /** + * @Author :rq + * @Description : + * @Date :2025/07/11 10:42 + **/ + public List homePointsStatistics(RiskVo riskVo); + + /** + * @Author :rq + * @Description :大客流基础信息统计首页 + * @Date :2025/07/11 10:42 + **/ + public List homePointsStatisticsPeople(RiskVo riskVo); + + /** + * 导入数据 + * + * @param dklMonitoringPointsList 数据列表 + * @param operName 操作用户 + * @return 结果 + */ + public String importDate(List dklMonitoringPointsList, String operName) throws KmsSdkException; + + public boolean checkPointsNameUnique(DklMonitoringPoints dklMonitoringPoints); +} + diff --git a/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java b/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java new file mode 100644 index 0000000..84772b0 --- /dev/null +++ b/Dkl-Vue-master/dkl-large/src/main/java/com/dkl/large/service/impl/DklMonitoringPointsServiceImpl.java @@ -0,0 +1,504 @@ +package com.dkl.large.service.impl; + +import java.util.Collection; +import java.util.Collections; +import java.util.Date; +import java.util.List; +import java.util.regex.Pattern; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +import com.koal.kms.sdk.ed.KmsSdkException; +import com.dkl.common.constant.UserConstants; +import com.dkl.common.core.domain.entity.SysDept; +import com.dkl.common.core.domain.entity.SysDictData; +import com.dkl.common.exception.ServiceException; +import com.dkl.common.utils.DateUtils; +import com.dkl.common.utils.StringUtils; +import com.dkl.large.domain.DklActivity; +import com.dkl.large.domain.DklMonitoringCameraData; +import com.dkl.large.domain.vo.DklMonitoringCameraDataVo; +import com.dkl.large.domain.vo.HeatVo; +import com.dkl.large.domain.vo.RegionalVo; +import com.dkl.large.domain.vo.RiskVo; +import com.dkl.large.utli.EnciphermentUtil; +import com.dkl.system.mapper.SysDictDataMapper; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.dkl.large.mapper.DklMonitoringPointsMapper; +import com.dkl.large.domain.DklMonitoringPoints; +import com.dkl.large.service.IDklMonitoringPointsService; + +import static com.dkl.common.utils.SecurityUtils.getDeptId; +import static com.dkl.common.utils.SecurityUtils.getUsername; +import static org.springframework.util.SerializationUtils.serialize; + +/** + * 监控点信息Service业务层处理 + * + * @author Dkl + * @date 2025-06-10 + */ +@Service +public class DklMonitoringPointsServiceImpl implements IDklMonitoringPointsService +{ + @Autowired + private DklMonitoringPointsMapper dklMonitoringPointsMapper; + @Autowired + private SysDictDataMapper sysDictDataMapper; + //手机号正则 + private static final String PHONE_REGEX = "^((0\\d{2,3}-\\d{7,8})|(1[3456789]\\d{9}))$"; + //经度 + private static final String LNG_REGEX = "^-?\\d{1,3}(\\.\\d+)?$"; + //维度 + private static final String LAT_REGEX = "^-?\\d{1,2}(\\.\\d+)?$"; + /** + * 查询监控点信息 + * + * @param id 监控点信息主键 + * @return 监控点信息 + */ + @Override + public DklMonitoringPoints selectDklMonitoringPointsById(Long id) throws KmsSdkException { + DklMonitoringPoints dklMonitoringPoints = dklMonitoringPointsMapper.selectDklMonitoringPointsById(id); + if (StringUtils.isNotEmpty(dklMonitoringPoints.getDutyPeople())&&StringUtils.isNotEmpty(dklMonitoringPoints.getDutyPhone())) { + String dutyPeople = dklMonitoringPoints.getDutyPeople(); + String dutyPhone = dklMonitoringPoints.getDutyPhone(); + dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople)); + dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone)); + } + return dklMonitoringPoints; + } + + /** + * 查询监控点信息列表 + * + * @param dklMonitoringPoints 监控点信息 + * @return 监控点信息 + */ + @Override + public List selectDklMonitoringPointsList(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException { + List list = dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoints); + + + + for (DklMonitoringPoints dklMonitoringPointsInfo : list) { + if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPeople())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) { + String dutyPeople = dklMonitoringPointsInfo.getDutyPeople(); + dklMonitoringPointsInfo.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople)); + } + if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPhone())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) { + String dutyPhone = dklMonitoringPointsInfo.getDutyPhone(); + dklMonitoringPointsInfo.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone)); + } + } + return list; + } + + @Override + public String selectDklMonitoringPointsListMeaasge(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException { + StringBuilder successMsg = new StringBuilder(); + List list = dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoints); + for (DklMonitoringPoints dklMonitoringPointsInfo : list) { + if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPeople())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) { + String dutyPeople = dklMonitoringPointsInfo.getDutyPeople(); + dklMonitoringPointsInfo.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople)); + } + if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPhone())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) { + String dutyPhone = dklMonitoringPointsInfo.getDutyPhone(); + dklMonitoringPointsInfo.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone)); + } + byte[] bytes = serialize(dklMonitoringPointsInfo.getDutyPeople()+","+dklMonitoringPointsInfo.getDutyPhone()); + String isor = EnciphermentUtil.kmsSign(bytes); + if (!isor.equals(dklMonitoringPointsInfo.getSigenCode())) { + successMsg.append("名称为"+dklMonitoringPointsInfo.getPointName()+"的数据被篡改"); + } + } + + // List list = dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoints); + + + +// for (DklMonitoringPoints dklMonitoringPointsInfo : list) { +// String dutyPeople = null; +// String dutyPhone = null; +// if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPeople())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) { +// dutyPeople = EnciphermentUtil.kmsDencrypt(dklMonitoringPointsInfo.getDutyPeople()); +// } +// if (StringUtils.isNotEmpty(dklMonitoringPointsInfo.getDutyPhone())&&("0").equals(dklMonitoringPointsInfo.getDelFlag())) { +// dutyPhone = EnciphermentUtil.kmsDencrypt(dklMonitoringPointsInfo.getDutyPhone()); +// } +// // （序列化） +// byte[] bytes = serialize(dutyPeople+","+dutyPhone); +// String sigenCode = EnciphermentUtil.kmsSign(bytes); +// dklMonitoringPointsInfo.setSigenCode(sigenCode); +// dklMonitoringPointsMapper.updateDklMonitoringPoints(dklMonitoringPointsInfo); +// } + + return successMsg.toString(); +} + + /** + * 新增监控点信息 + * + * @param dklMonitoringPoints 监控点信息 + * @return 结果 + */ + @Override + public int insertDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException { + dklMonitoringPoints.setCreateTime(DateUtils.getNowDate()); + String dutyPeople = dklMonitoringPoints.getDutyPeople(); + String dutyPhone = dklMonitoringPoints.getDutyPhone(); + dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsEncrypt(dutyPeople)); + dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsEncrypt(dutyPhone)); + // （序列化） + byte[] bytes = serialize(dutyPeople+","+dutyPhone); + String sigenCode = EnciphermentUtil.kmsSign(bytes); + dklMonitoringPoints.setSigenCode(sigenCode); + return dklMonitoringPointsMapper.insertDklMonitoringPoints(dklMonitoringPoints); + } + + /** + * 修改监控点信息 + * + * @param dklMonitoringPoints 监控点信息 + * @return 结果 + */ + @Override + public int updateDklMonitoringPoints(DklMonitoringPoints dklMonitoringPoints) throws KmsSdkException { + dklMonitoringPoints.setUpdateTime(DateUtils.getNowDate()); + String dutyPeople = dklMonitoringPoints.getDutyPeople(); + String dutyPhone = dklMonitoringPoints.getDutyPhone(); + dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsEncrypt(dutyPeople)); + dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsEncrypt(dutyPhone)); + // （序列化） + byte[] bytes = serialize(dutyPeople+","+dutyPhone); + String sigenCode = EnciphermentUtil.kmsSign(bytes); + dklMonitoringPoints.setSigenCode(sigenCode); + return dklMonitoringPointsMapper.updateDklMonitoringPoints(dklMonitoringPoints); + } + + /** + * 批量删除监控点信息 + * + * @param ids 需要删除的监控点信息主键 + * @return 结果 + */ + @Override + public int deleteDklMonitoringPointsByIds(int[] ids) + { + return dklMonitoringPointsMapper.deleteDklMonitoringPointsByIds(ids); + } + + /** + * 删除监控点信息信息 + * + * @param id 监控点信息主键 + * @return 结果 + */ + @Override + public int deleteDklMonitoringPointsById(Long id) + { + return dklMonitoringPointsMapper.deleteDklMonitoringPointsById(id); + } + + + /** + * 监控点热力图 + * + * @param dataVo + * @return 结果 + */ + @Override + public List heatMap(HeatVo dataVo) { + return dklMonitoringPointsMapper.heatMap(dataVo); + } + + /** + * 大客流总数区域展示图 + * + * @param regionalVo + * @return 结果 + */ + @Override + public List regionalStatistics(RegionalVo regionalVo) { + return dklMonitoringPointsMapper.regionalStatistics(regionalVo); + } + + /** + * 大客流总数区域数据 + * + * @param regionalVo + * @return 结果 + */ + @Override + public List regionalDataList(RegionalVo regionalVo) throws KmsSdkException { + List list = dklMonitoringPointsMapper.regionalDataList(regionalVo); + for (DklMonitoringPoints dklMonitoringPointsInfo : list) { + String dutyPeople = dklMonitoringPointsInfo.getDutyPeople(); + String dutyPhone = dklMonitoringPointsInfo.getDutyPhone(); + dklMonitoringPointsInfo.setDutyPeople(EnciphermentUtil.kmsDencrypt(dutyPeople)); + dklMonitoringPointsInfo.setDutyPhone(EnciphermentUtil.kmsDencrypt(dutyPhone)); + } + return list; + } + + /** + * 大客流风险预警信息 + * + * @param riskVo + * @return 结果 + */ + @Override + public List riskDataList(RiskVo riskVo) { + return dklMonitoringPointsMapper.riskDataList(riskVo); + } + + @Override + public List homePointsStatistics(RiskVo riskVo) { + return dklMonitoringPointsMapper.homePointsStatistics(riskVo); + } + + @Override + public List homePointsStatisticsPeople(RiskVo riskVo) { + return dklMonitoringPointsMapper.homePointsStatisticsPeople(riskVo); + } + + @Override + public String importDate(List dklMonitoringPointsList, String operName) throws KmsSdkException { + //区域集合 + List areaDict=sysDictDataMapper.selectDictDataByType("activity_area"); + //区监控点类型 + List pointType=sysDictDataMapper.selectDictDataByType("monitoring_point_type"); + //所有大客流活动 + DklMonitoringPoints dklMonitoringPoint = new DklMonitoringPoints(); + dklMonitoringPoint.setDelFlag("0"); + List dklMonitoringPointAll= dklMonitoringPointsMapper.selectDklMonitoringPointsList(dklMonitoringPoint); + if (StringUtils.isNull(dklMonitoringPointsList) || dklMonitoringPointsList.size() == 0) { + throw new ServiceException("导入数据不能为空！"); + } + int successNum = 0; + int failureNum = 0; + StringBuilder successMsg = new StringBuilder(); + StringBuilder failureMsg = new StringBuilder(); + for (int i = 0; i < dklMonitoringPointsList.size(); i++) { + try + { + //名称 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getPointName())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据名称为空"); + }else{ + if (dklMonitoringPointsList.get(i).getPointName().length()>=30){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据名称长度过长"); + } + } + + + //地址 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getPointAddress())){ + failureNum++; + failureMsg.append("
第" + (i+1)+ "条数据地址为空"); + }else{ + if (dklMonitoringPointsList.get(i).getPointAddress().length()>=50){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据地址长度过长"); + } + } + + //区域 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getRegionname())){ + failureNum++; + failureMsg.append("
第" + (i+1)+ "条数据区域为空"); + }else{ + if (dklMonitoringPointsList.get(i).getRegionname().length()>=30){ + failureNum++; + failureMsg.append("
第" +(i+1) + "条数据区域长度过长"); + }else{ + for (SysDictData sysDictData : areaDict) { + if (sysDictData.getDictLabel().equals(dklMonitoringPointsList.get(i).getRegionname())) { + dklMonitoringPointsList.get(i).setPointRegion(sysDictData.getDictValue()); + break; + } + + } + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getPointRegion())){ + failureNum++; + failureMsg.append("
第" +(i+1) + "条数据区域未找到"); + } + } + } + + //监控点类型 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getMonitoringTypeName())){ + failureNum++; + failureMsg.append("
第" + (i+1)+ "条数据监控点类型为空"); + }else{ + if (dklMonitoringPointsList.get(i).getMonitoringTypeName().length()>=30){ + failureNum++; + failureMsg.append("
第" +(i+1) + "条数据监控点类型长度过长"); + }else{ + for (SysDictData sysDictData : pointType) { + if (sysDictData.getDictLabel().equals(dklMonitoringPointsList.get(i).getMonitoringTypeName())) { + dklMonitoringPointsList.get(i).setMonitoringType(sysDictData.getDictValue()); + break; + } + } + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getMonitoringType())){ + failureNum++; + failureMsg.append("
第" +(i+1) + "条数据监控点类型未找到"); + } + } + } + + //值班人员 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getDutyPeople())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值班人员为空"); + }else{ + if (dklMonitoringPointsList.get(i).getDutyPeople().length()>=30){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值班人员长度过长"); + } + } + + //值班联系方式 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getDutyPhone())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值班联系方式为空"); + }else{ + if (dklMonitoringPointsList.get(i).getDutyPhone().length()>=30){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值班联系方式长度过长"); + }else if (!Pattern.matches(PHONE_REGEX, dklMonitoringPointsList.get(i).getDutyPhone())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值班联系方式有误"); + } + } + + + //经度 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getLng())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据经度为空"); + }else{ + if (dklMonitoringPointsList.get(i).getLng().length()>=30){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据经度长度过长"); + }else if (!Pattern.matches(LNG_REGEX, dklMonitoringPointsList.get(i).getLng())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值经度有误"); + } + } + + //纬度 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getLat())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据纬度为空"); + }else{ + if (dklMonitoringPointsList.get(i).getLat().length()>=30){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据纬度长度过长"); + }else if (!Pattern.matches(LAT_REGEX, dklMonitoringPointsList.get(i).getLat())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据值纬度有误"); + } + } + + //最大承载量 + if (dklMonitoringPointsList.get(i).getLoadBearingMax()<=0){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据最大承载量为空"); + }else{ + if (dklMonitoringPointsList.get(i).getLoadBearingMax()>=999999999){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据最大承载量长度过长"); + } + } + + + //风险点 + if (StringUtils.isEmpty(dklMonitoringPointsList.get(i).getIsRisk())){ + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据是否风险点为空"); + }else{ + if (dklMonitoringPointsList.get(i).getIsRisk().length()>=30){ + failureNum++; + failureMsg.append("
第" +(i+1)+ "条数据是否风险点长度过长"); + }else{ + if (!("Y").equals(dklMonitoringPointsList.get(i).getIsRisk())&&!("N").equals(dklMonitoringPointsList.get(i).getIsRisk())) { + failureNum++; + failureMsg.append("
第" + (i+1) + "条数据是否风险点长有误"); + } + } + } + + + } + catch (Exception e) + { + failureNum++; + String msg = "
" + failureNum + "导入失败："; + failureMsg.append(msg + e.getMessage()); + } + + } + if (failureNum > 0) + { + failureMsg.insert(0, "很抱歉，导入失败！共 " + failureNum + " 条数据格式不正确，错误如下："); + throw new ServiceException(failureMsg.toString()); + } + else { + + List lists = Stream.of(dklMonitoringPointAll, dklMonitoringPointsList) + .flatMap(Collection::stream) + .collect(Collectors.toList()); + + boolean hasDuplicates = lists.stream() + .map(DklMonitoringPoints::getPointName) + .distinct() + .count() != lists.size(); + if (hasDuplicates) { + failureMsg.insert(0, "很抱歉，导入失败！共导入数据中有和系统原数据名称相同的数据"); + throw new ServiceException(failureMsg.toString()); + + } else { + for (DklMonitoringPoints dklMonitoringPoints : dklMonitoringPointsList) { + //添加系统信息 + dklMonitoringPoints.setDelFlag("0"); + dklMonitoringPoints.setCreateTime(new Date()); + dklMonitoringPoints.setCreateBy(getUsername()); + dklMonitoringPoints.setDeptId(getDeptId()); + dklMonitoringPoints.setUpdateTime(new Date()); + dklMonitoringPoints.setUpdateBy(getUsername()); + String dutyPeople = dklMonitoringPoints.getDutyPeople(); + String dutyPhone = dklMonitoringPoints.getDutyPhone(); + dklMonitoringPoints.setDutyPeople(EnciphermentUtil.kmsEncrypt(dutyPeople)); + dklMonitoringPoints.setDutyPhone(EnciphermentUtil.kmsEncrypt(dutyPhone)); + // （序列化） + byte[] bytes = serialize(dutyPeople+","+dutyPhone); + String sigenCode = EnciphermentUtil.kmsSign(bytes); + dklMonitoringPoints.setSigenCode(sigenCode); + dklMonitoringPointsMapper.insertDklMonitoringPoints(dklMonitoringPoints); + } + successMsg.insert(0, "恭喜您，数据已全部导入成功！"); + } + } + + return successMsg.toString(); + } + + @Override + public boolean checkPointsNameUnique(DklMonitoringPoints dklMonitoringPoints) { + Long deptId = StringUtils.isNull(dklMonitoringPoints.getId()) ? -1L : dklMonitoringPoints.getId(); + DklMonitoringPoints info = dklMonitoringPointsMapper.checkPointsNameUnique(dklMonitoringPoints.getPointName()); + if (StringUtils.isNotNull(info) && info.getId() != deptId.longValue()) + { + return UserConstants.NOT_UNIQUE; + } + return UserConstants.UNIQUE; + } + + +}