diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java index 2cfdf82..be753f2 100644 --- a/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java @@ -12,6 +12,7 @@ import com.ycwl.basic.service.pc.ScenicService; import com.ycwl.basic.storage.StorageFactory; import com.ycwl.basic.storage.adapters.IStorageAdapter; import com.ycwl.basic.storage.exceptions.StorageUnsupportedException; +import com.ycwl.basic.util.ScenicConfigManager; import com.ycwl.basic.utils.ApiResponse; import com.ycwl.basic.utils.JacksonUtil; import lombok.extern.slf4j.Slf4j; @@ -43,11 +44,11 @@ public class ScenicServiceImpl implements ScenicService { public IStorageAdapter getScenicStorageAdapter(Long scenicId) { return scenicStorageAdapterMap.computeIfAbsent(scenicId, (key) -> { IStorageAdapter adapter; - ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); - if (scenicConfig != null && scenicConfig.getStoreType() != null) { + ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(scenicId); + if (scenicConfig.getString("store_type") != null) { try { - adapter = StorageFactory.get(scenicConfig.getStoreType()); - adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); + adapter = StorageFactory.get(scenicConfig.getString("store_type")); + adapter.loadConfig(scenicConfig.getObject("store_config_json", Map.class)); } catch (StorageUnsupportedException ignored) { return StorageFactory.use("video"); } @@ -62,11 +63,11 @@ public class ScenicServiceImpl implements ScenicService { public IStorageAdapter getScenicTmpStorageAdapter(Long scenicId) { return scenicTmpStorageAdapterMap.computeIfAbsent(scenicId, (key) -> { IStorageAdapter adapter; - ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); - if (scenicConfig != null && scenicConfig.getTmpStoreType() != null) { + ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(scenicId); + if (scenicConfig.getString("tmp_store_type") != null) { try { - adapter = StorageFactory.get(scenicConfig.getTmpStoreType()); - adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getTmpStoreConfigJson(), Map.class)); + adapter = StorageFactory.get(scenicConfig.getString("tmp_store_type")); + adapter.loadConfig(scenicConfig.getObject("tmp_store_config_json", Map.class)); } catch (StorageUnsupportedException ignored) { return getScenicStorageAdapter(scenicId); } @@ -81,11 +82,11 @@ public class ScenicServiceImpl implements ScenicService { public IStorageAdapter getScenicLocalStorageAdapter(Long scenicId) { return scenicLocalStorageAdapterMap.computeIfAbsent(scenicId, (key) -> { IStorageAdapter adapter; - ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); - if (scenicConfig != null && scenicConfig.getLocalStoreType() != null) { + ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(scenicId); + if (scenicConfig.getString("local_store_type") != null) { try { - adapter = StorageFactory.get(scenicConfig.getLocalStoreType()); - adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getLocalStoreConfigJson(), Map.class)); + adapter = StorageFactory.get(scenicConfig.getString("local_store_type")); + adapter.loadConfig(scenicConfig.getObject("local_store_config_json", Map.class)); } catch (StorageUnsupportedException ignored) { return getScenicStorageAdapter(scenicId); } @@ -101,10 +102,10 @@ public class ScenicServiceImpl implements ScenicService { public IFaceBodyAdapter getScenicFaceBodyAdapter(Long scenicId) { return scenicFaceBodyAdapterMap.computeIfAbsent(scenicId, (key) -> { IFaceBodyAdapter adapter; - ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); - if (scenicConfig != null && scenicConfig.getFaceType() != null) { - adapter = FaceBodyFactory.getAdapter(scenicConfig.getFaceType()); - adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); + ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(scenicId); + if (scenicConfig.getString("face_type") != null) { + adapter = FaceBodyFactory.getAdapter(scenicConfig.getString("face_type")); + adapter.loadConfig(scenicConfig.getObject("face_config_json", Map.class)); } else { adapter = FaceBodyFactory.use(); } @@ -117,10 +118,10 @@ public class ScenicServiceImpl implements ScenicService { public IPayAdapter getScenicPayAdapter(Long scenicId) { return scenicPayAdapterMap.computeIfAbsent(scenicId, (key) -> { IPayAdapter adapter; - ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); - if (scenicConfig != null && scenicConfig.getPayType() != null) { - adapter = PayFactory.getAdapter(scenicConfig.getPayType()); - adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getPayConfigJson(), Map.class)); + ScenicConfigManager scenicConfig = scenicRepository.getScenicConfigManager(scenicId); + if (scenicConfig.getString("pay_type") != null) { + adapter = PayFactory.getAdapter(scenicConfig.getString("pay_type")); + adapter.loadConfig(scenicConfig.getObject("pay_config_json", Map.class)); } else { adapter = PayFactory.use(); }