|
|
|
@ -1,6 +1,12 @@
|
|
|
|
|
package com.ruoyi.traceability.service.impl;
|
|
|
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
import com.ruoyi.common.core.domain.entity.SysUser;
|
|
|
|
|
import com.ruoyi.common.exception.ServiceException;
|
|
|
|
|
import com.ruoyi.common.utils.StringUtils;
|
|
|
|
|
import com.ruoyi.common.utils.bean.BeanValidators;
|
|
|
|
|
import com.ruoyi.common.utils.security.Md5Utils;
|
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
|
import org.springframework.stereotype.Service;
|
|
|
|
|
import com.ruoyi.traceability.mapper.BaseAlarminfoMapper;
|
|
|
|
@ -91,4 +97,58 @@ public class BaseAlarminfoServiceImpl implements IBaseAlarminfoService
|
|
|
|
|
{
|
|
|
|
|
return baseAlarminfoMapper.deleteBaseAlarminfoByObjId(objId);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public String importAlarmInfo(List<BaseAlarminfo> alarminfoList, Boolean isUpdateSupport, String operName) {
|
|
|
|
|
if (StringUtils.isNull(alarminfoList) || alarminfoList.size() == 0)
|
|
|
|
|
{
|
|
|
|
|
throw new ServiceException("导入用户数据不能为空!");
|
|
|
|
|
}
|
|
|
|
|
int successNum = 0;
|
|
|
|
|
int failureNum = 0;
|
|
|
|
|
StringBuilder successMsg = new StringBuilder();
|
|
|
|
|
StringBuilder failureMsg = new StringBuilder();
|
|
|
|
|
for (BaseAlarminfo alarminfo : alarminfoList)
|
|
|
|
|
{
|
|
|
|
|
try
|
|
|
|
|
{
|
|
|
|
|
BaseAlarminfo info = baseAlarminfoMapper.selectBaseAlarmInfoByAlarmCode(alarminfo.getAlarmCode());
|
|
|
|
|
if (StringUtils.isNull(info))
|
|
|
|
|
{
|
|
|
|
|
this.insertBaseAlarminfo(alarminfo);
|
|
|
|
|
successNum++;
|
|
|
|
|
successMsg.append("<br/>" + successNum + "、编号 " + alarminfo.getAlarmCode() + " 导入成功");
|
|
|
|
|
}
|
|
|
|
|
else if (isUpdateSupport)
|
|
|
|
|
{
|
|
|
|
|
info.setAlarmMessage(alarminfo.getAlarmMessage());
|
|
|
|
|
info.setAlarmPropose(alarminfo.getAlarmPropose());
|
|
|
|
|
this.updateBaseAlarminfo(info);
|
|
|
|
|
successNum++;
|
|
|
|
|
successMsg.append("<br/>" + successNum + "、编号 " + info.getAlarmCode() + " 更新成功");
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
failureNum++;
|
|
|
|
|
failureMsg.append("<br/>" + failureNum + "、编号 " + info.getAlarmCode() + " 已存在");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
catch (Exception e)
|
|
|
|
|
{
|
|
|
|
|
failureNum++;
|
|
|
|
|
String msg = "<br/>" + failureNum + "、编号 " + alarminfo.getAlarmCode() + " 导入失败:";
|
|
|
|
|
failureMsg.append(msg + e.getMessage());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
if (failureNum > 0)
|
|
|
|
|
{
|
|
|
|
|
failureMsg.insert(0, "很抱歉,导入失败!共 " + failureNum + " 条数据格式不正确,错误如下:");
|
|
|
|
|
throw new ServiceException(failureMsg.toString());
|
|
|
|
|
}
|
|
|
|
|
else
|
|
|
|
|
{
|
|
|
|
|
successMsg.insert(0, "恭喜您,数据已全部导入成功!共 " + successNum + " 条,数据如下:");
|
|
|
|
|
}
|
|
|
|
|
return successMsg.toString();
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|