|
|
@@ -30,92 +30,4 @@ import java.util.stream.Collectors;
|
|
|
@Slf4j
|
|
|
public class TbSceneProServiceImpl extends ServiceImpl<ITbSceneProMapper, TbScenePro> implements ITbSceneProService {
|
|
|
|
|
|
-
|
|
|
- @Value("${db1.fyun.host}")
|
|
|
- private String db1Host;
|
|
|
- @Value("${db2.fyun.host}")
|
|
|
- private String db2Host;
|
|
|
- @Value("${db1.main}")
|
|
|
- private String db1main;
|
|
|
- @Value("${db2.main}")
|
|
|
- private String db2main;
|
|
|
-
|
|
|
- @Autowired
|
|
|
- ITbUserService tbUserService;
|
|
|
- @Autowired
|
|
|
- ITbCameraInstanceService tbCameraInstanceService;
|
|
|
- @Autowired
|
|
|
- ITbSceneProEditService tbSceneProEditService;
|
|
|
-
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<TbScenePro> getByNumList(List<String> numList) {
|
|
|
- if(numList.size() >0){
|
|
|
- LambdaQueryWrapper<TbScenePro> wrapper = new LambdaQueryWrapper<>();
|
|
|
- wrapper.in(TbScenePro::getNum,numList);
|
|
|
- return this.list(wrapper);
|
|
|
- }
|
|
|
- return new ArrayList<>();
|
|
|
- }
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
- @Override
|
|
|
- public List<TbScenePro> saveDb(List<ScenePro> scenePros, List<SceneProEdit> sceneProEdits, String zfbPhone, String zfbSnCode) {
|
|
|
-
|
|
|
- TbUser tbUser = tbUserService.getByUserName(zfbPhone);
|
|
|
- if(tbUser == null){
|
|
|
- log.info("db2-user-not-exist--zfbPhone:{}",zfbPhone);
|
|
|
- return null;
|
|
|
- }
|
|
|
- TbCameraInstance cameraInstance = tbCameraInstanceService.getBySnCode(zfbSnCode);
|
|
|
- if(cameraInstance == null){
|
|
|
- log.info("db2-cameraInstance-not-exist--zfbSnCode:{}",zfbSnCode);
|
|
|
- return null;
|
|
|
- }
|
|
|
- HashMap<Long,SceneProEdit> editMap = new HashMap<>();
|
|
|
- sceneProEdits.forEach(entity -> editMap.put(entity.getProId(),entity));
|
|
|
-
|
|
|
- List<String> numList = scenePros.stream().map(ScenePro::getNum).collect(Collectors.toList());
|
|
|
-
|
|
|
- List<TbScenePro> zfbSceneList = this.getByNumList(numList);
|
|
|
- HashMap<String,TbScenePro> tbMap = new HashMap<>();
|
|
|
- zfbSceneList.forEach(entity -> tbMap.put(entity.getNum(),entity));
|
|
|
-
|
|
|
- List<String> zfbNumList = zfbSceneList.stream().map(TbScenePro::getNum).collect(Collectors.toList());
|
|
|
- List<TbScenePro> list = new ArrayList<>();
|
|
|
- for (ScenePro scenePro : scenePros) {
|
|
|
- if(zfbNumList.contains(scenePro.getNum())){
|
|
|
- log.info("zfb-db-exist:num:{}",scenePro.getNum());
|
|
|
- TbScenePro tbScenePro = tbMap.get(scenePro.getNum());
|
|
|
- if(tbScenePro == null){
|
|
|
- log.info("zfb-db-map-noexist:num:{}",scenePro.getNum());
|
|
|
- continue;
|
|
|
- }
|
|
|
- list.add(tbScenePro);
|
|
|
- continue;
|
|
|
- }
|
|
|
- TbScenePro tbScenePro = new TbScenePro();
|
|
|
- BeanUtils.copyProperties(scenePro,tbScenePro);
|
|
|
- tbScenePro.setWebSite(scenePro.getWebSite().replaceAll(db1main,db2main));
|
|
|
- tbScenePro.setVideos(scenePro.getVideos().replaceAll(db1main,db2main));
|
|
|
- tbScenePro.setId(null);
|
|
|
- tbScenePro.setUserId(tbUser.getId());
|
|
|
- tbScenePro.setCameraId(cameraInstance.getId());
|
|
|
- tbScenePro.setDataSource(scenePro.getDataSource());
|
|
|
- tbScenePro.setStatus(0);
|
|
|
- this.save(tbScenePro);
|
|
|
- list.add(tbScenePro);
|
|
|
-
|
|
|
-
|
|
|
- SceneProEdit sceneProEdit = editMap.get(scenePro.getId());
|
|
|
- TbSceneProEdit tbSceneProEdit = new TbSceneProEdit();
|
|
|
- BeanUtils.copyProperties(sceneProEdit,tbSceneProEdit);
|
|
|
- tbSceneProEdit.setId(null);
|
|
|
- tbSceneProEdit.setProId(tbScenePro.getId());
|
|
|
- tbSceneProEditService.save(tbSceneProEdit);
|
|
|
-
|
|
|
- }
|
|
|
- return list;
|
|
|
- }
|
|
|
}
|
lyhzzz