|
|
@@ -122,7 +122,7 @@ public class SaveDataServiceImpl implements SaveDataService {
|
|
|
TaskNotice taskNotice = JSONUtil.toBean(data, TaskNotice.class);
|
|
|
SiteInfo siteInfo = siteInfoMapper.queryBySiteCode(taskNotice.getId());
|
|
|
if (siteInfo == null) {
|
|
|
- log.error("查询站点失败入库失败 站码:{}", taskNotice.getId());
|
|
|
+ log.error("开始测流 查询站点失败 Id:{}", taskNotice.getId());
|
|
|
return;
|
|
|
}
|
|
|
taskNotice.setStartId(0L);
|
|
|
@@ -138,12 +138,17 @@ public class SaveDataServiceImpl implements SaveDataService {
|
|
|
taskNoticeMapper.insert(taskNotice);
|
|
|
//新建结果报告 状态设置为测流中
|
|
|
TaskResult taskResult = new TaskResult();
|
|
|
+ taskResult.setTaskid(taskNotice.getTaskid());
|
|
|
+ taskResult.setSiteId(siteInfo.getSiteId());
|
|
|
+ //查询有无重复taskId
|
|
|
+ if (taskResultMapper.count(taskResult) > 0){
|
|
|
+ log.error("开始测流 新建报告taskId重复 Id:{}", taskNotice.getId());
|
|
|
+ return;
|
|
|
+ }
|
|
|
taskResult.setType(0); // 移动测流
|
|
|
taskResult.setPlanid(taskNotice.getPlanid());
|
|
|
taskResult.setResultId(0L);
|
|
|
- taskResult.setTaskid(taskNotice.getTaskid());
|
|
|
taskResult.setStatus(0);
|
|
|
- taskResult.setSiteId(siteInfo.getSiteId());
|
|
|
taskResult.setCreateTime(new Date());
|
|
|
taskResultMapper.insert(taskResult);
|
|
|
} catch (Exception e) {
|
