Commit 728c8b9b authored by duanruiming's avatar duanruiming

[update] 逻辑优化

parent 654d1918
...@@ -28,6 +28,7 @@ import org.springframework.beans.BeanUtils; ...@@ -28,6 +28,7 @@ import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional; import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
...@@ -352,7 +353,7 @@ public class PlanSendServiceImpl implements PlanSendService { ...@@ -352,7 +353,7 @@ public class PlanSendServiceImpl implements PlanSendService {
} }
@Override @Override
// @Transactional @Transactional
public JsonViewObject syncScheme(CrossIdDTO crossIdDTO) throws Exception { public JsonViewObject syncScheme(CrossIdDTO crossIdDTO) throws Exception {
String crossId = crossIdDTO.getCrossId(); String crossId = crossIdDTO.getCrossId();
CrossIdVO crossIdVO = new CrossIdVO(); CrossIdVO crossIdVO = new CrossIdVO();
...@@ -382,7 +383,9 @@ public class PlanSendServiceImpl implements PlanSendService { ...@@ -382,7 +383,9 @@ public class PlanSendServiceImpl implements PlanSendService {
// 保存旧方案ID // 保存旧方案ID
List<Integer> oldSchemeIds = baseCrossSchemeList.stream().map(BaseCrossSchemePO::getId).collect(Collectors.toList()); List<Integer> oldSchemeIds = baseCrossSchemeList.stream().map(BaseCrossSchemePO::getId).collect(Collectors.toList());
// 保存新方案ID // 保存新方案ID
baseCrossSchemeMapper.insertBatch(baseCrossSchemeList); if (!CollectionUtils.isEmpty(baseCrossSchemeList)) {
baseCrossSchemeMapper.insertBatch(baseCrossSchemeList);
}
List<Integer> newSchemeIds = baseCrossSchemeList.stream().map(BaseCrossSchemePO::getId).collect(Collectors.toList()); List<Integer> newSchemeIds = baseCrossSchemeList.stream().map(BaseCrossSchemePO::getId).collect(Collectors.toList());
// 生成新旧方案ID映射 // 生成新旧方案ID映射
...@@ -418,7 +421,9 @@ public class PlanSendServiceImpl implements PlanSendService { ...@@ -418,7 +421,9 @@ public class PlanSendServiceImpl implements PlanSendService {
TreeSet<BaseCrossLightsPO> crossLightsSet = distinctLightsNo(baseCrossLightsPOS); TreeSet<BaseCrossLightsPO> crossLightsSet = distinctLightsNo(baseCrossLightsPOS);
// 修改灯组数据内容 // 修改灯组数据内容
changeLightsType(crossLightsSet); changeLightsType(crossLightsSet);
baseCrossLightsMapper.insertBatch(crossLightsSet); if (!CollectionUtils.isEmpty(crossLightsSet)) {
baseCrossLightsMapper.insertBatch(crossLightsSet);
}
baseCrossPhaseLightsMapper.deleteByCrossId(crossId); baseCrossPhaseLightsMapper.deleteByCrossId(crossId);
baseCrossLaneLightsMapper.deleteByCrossId(crossId); baseCrossLaneLightsMapper.deleteByCrossId(crossId);
......
...@@ -100,7 +100,7 @@ public class StaticInfoServiceImpl implements StaticInfoService { ...@@ -100,7 +100,7 @@ public class StaticInfoServiceImpl implements StaticInfoService {
} else { } else {
// todo 其他厂商 // todo 其他厂商
// 默认万集标准服务 // 默认万集标准服务
// wanjiCommonStaticInfoService.schemePhaseLights(crossId, crossCode); wanjiCommonStaticInfoService.schemePhaseLights(crossId, crossCode);
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment