|
@@ -28,6 +28,7 @@ import com.fdkankan.external.httpclient.HttpClient;
|
|
|
import com.fdkankan.external.mapper.SceneOfflinePackagePushMapper;
|
|
|
import com.fdkankan.external.service.*;
|
|
|
import com.fdkankan.external.util.CmdUtils;
|
|
|
+import com.fdkankan.fyun.face.FYunFileServiceInterface;
|
|
|
import com.fdkankan.redis.constant.RedisKey;
|
|
|
import com.fdkankan.redis.util.RedisUtil;
|
|
|
import com.fdkankan.web.response.Result;
|
|
@@ -100,7 +101,8 @@ public class SceneOfflinePackagePushServiceImpl extends ServiceImpl<SceneOffline
|
|
|
private ICameraService cameraService;
|
|
|
@Resource
|
|
|
private RedisUtil redisUtil;
|
|
|
-
|
|
|
+ @Resource
|
|
|
+ private FYunFileServiceInterface fYunFileService;
|
|
|
|
|
|
|
|
|
@Override
|
|
@@ -181,9 +183,11 @@ public class SceneOfflinePackagePushServiceImpl extends ServiceImpl<SceneOffline
|
|
|
SceneOfflinePackagePush lastPush = sceneOfflinePackagePushService.getLastByCondition(condition);
|
|
|
|
|
|
//查询版本号
|
|
|
- String getInfo = fdkkSceneHost.concat(String.format(getInfoUrl, scenePlus.getNum()));
|
|
|
- ResultData<Map<String, Object>> mapResultData = httpClient.get(getInfo, new HashMap<>(), new SuccessCallback(), new ErrorCallback());
|
|
|
- int version = (int)mapResultData.getData().get("version");
|
|
|
+ String sceneJsonStr = fYunFileService.getFileContent("scene_view_data/" + scenePlus.getNum() + "/data/scene.json");
|
|
|
+// String getInfo = fdkkSceneHost.concat(String.format(getInfoUrl, scenePlus.getNum()));
|
|
|
+// ResultData<Map<String, Object>> mapResultData = httpClient.get(getInfo, new HashMap<>(), new SuccessCallback(), new ErrorCallback());
|
|
|
+ JSONObject sceneJson = JSON.parseObject(sceneJsonStr);
|
|
|
+ int version = sceneJson.getIntValue("version");
|
|
|
|
|
|
//如果没有推送过或者推送过但是版本号不一致,就需要推送
|
|
|
if(Objects.isNull(lastPush) || lastPush.getVersion() != version){
|