246 lines
10 KiB
Plaintext
246 lines
10 KiB
Plaintext
autoImport('HTTPRequest')
|
|
autoImport('XDCDNInfo')
|
|
autoImport('PhotoFileInfo')
|
|
autoImport('UpyunInfo')
|
|
|
|
NetIngScenicSpotPhoto = class('NetIngScenicSpotPhoto')
|
|
|
|
local gCachedDownloadTaskRecordID = {}
|
|
local gCachedUploadTaskRecordID = {}
|
|
|
|
function NetIngScenicSpotPhoto.Ins()
|
|
if NetIngScenicSpotPhoto.ins == null then
|
|
NetIngScenicSpotPhoto.ins = NetIngScenicSpotPhoto.new()
|
|
end
|
|
return NetIngScenicSpotPhoto.ins
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:Initialize()
|
|
EventManager.Me():AddEventListener(ServiceEvent.NUserUploadSceneryPhotoUserCmd, self.OnReceiveUploadSceneryPhotoUserCmd, self)
|
|
self.stopFormUploadFlag = {}
|
|
self.tabIsExist = {}
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:Download(scenic_spot_id, timestamp, progress_callback, success_callback, error_callback, o_or_t, extension)
|
|
print(string.format('NetIngScenicSpotPhoto:Download\nscenic_spot_id=%s', tostring(scenic_spot_id)))
|
|
local tempDownloadRootPath = ApplicationHelper.persistentDataPath .. '/' .. self:GetTempDownloadRootPathOfLocal()
|
|
if not FileHelper.ExistDirectory(tempDownloadRootPath) then
|
|
FileHelper.CreateDirectory(tempDownloadRootPath)
|
|
end
|
|
|
|
local path = ApplicationHelper.persistentDataPath .. '/' .. self:GetTempDownloadPathOfLocal(scenic_spot_id, o_or_t, extension)
|
|
local key = scenic_spot_id .. '_' .. (o_or_t and 'o' or 't')
|
|
if table.ContainsKey(gCachedDownloadTaskRecordID, key) then
|
|
local taskRecordID = gCachedDownloadTaskRecordID[key]
|
|
if self:IsDownloading(scenic_spot_id, o_or_t) then
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:RegisterCallback(taskRecordID, progress_callback, success_callback, error_callback)
|
|
else
|
|
if FileHelper.ExistFile(path) then
|
|
FileHelper.DeleteFile(path)
|
|
end
|
|
local fileServerURL = XDCDNInfo.GetFileServerURL()
|
|
local newURL = fileServerURL .. '/' .. self:GetPathOfServer(scenic_spot_id, extension) .. (o_or_t and '' or '') .. (timestamp > 0 and ('?t=' .. timestamp) or '')
|
|
local taskRecord = CloudFile.CloudFileManager.Ins._TaskRecordCenter:GetTaskRecord(taskRecordID)
|
|
taskRecord.URL = newURL
|
|
CloudFile.CloudFileManager.Ins:RestartTask(taskRecordID)
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:UnregisterCallback(taskRecordID)
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:RegisterCallback(taskRecordID, progress_callback, success_callback, error_callback)
|
|
end
|
|
else
|
|
if FileHelper.ExistFile(path) then
|
|
FileHelper.DeleteFile(path)
|
|
end
|
|
local fileServerURL = XDCDNInfo.GetFileServerURL()
|
|
local url = fileServerURL .. '/' .. self:GetPathOfServer(scenic_spot_id, extension) .. (o_or_t and '' or '') .. (timestamp > 0 and ('?t=' .. timestamp) or '')
|
|
local taskRecordID = nil
|
|
if not BackwardCompatibilityUtil.CompatibilityMode(BackwardCompatibilityUtil.V13) then
|
|
taskRecordID = CloudFile.CloudFileManager.Ins:Download(url, path, false, progress_callback ,success_callback, error_callback, nil)
|
|
else
|
|
taskRecordID = CloudFile.CloudFileManager.Ins:Download(url, path, false, progress_callback ,success_callback, error_callback)
|
|
end
|
|
if taskRecordID > 0 then
|
|
gCachedDownloadTaskRecordID[key] = taskRecordID
|
|
end
|
|
end
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:IsDownloading(scenic_spot_id, o_or_t)
|
|
local key = scenic_spot_id .. '_' .. (o_or_t and 'o' or 't')
|
|
local taskRecordID = gCachedDownloadTaskRecordID[key]
|
|
if taskRecordID ~= nil then
|
|
local taskRecord = CloudFile.CloudFileManager.Ins._TaskRecordCenter:GetTaskRecord(taskRecordID)
|
|
return taskRecord.State == CloudFile.E_TaskState.Progress or taskRecord.State == CloudFile.E_TaskState.None
|
|
end
|
|
return false
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:StopDownload(scenic_spot_id, o_or_t)
|
|
local key = scenic_spot_id .. '_' .. (o_or_t and 'o' or 't')
|
|
local taskRecordID = gCachedDownloadTaskRecordID[key]
|
|
if taskRecordID ~= nil then
|
|
CloudFile.CloudFileManager.Ins:StopTask(taskRecordID)
|
|
end
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:Upload(scenic_spot_id, progress_callback ,success_callback, error_callback)
|
|
if table.ContainsKey(gCachedUploadTaskRecordID, scenic_spot_id) then
|
|
local taskRecordID = gCachedUploadTaskRecordID[scenic_spot_id]
|
|
local taskRecord = CloudFile.CloudFileManager.Ins._TaskRecordCenter:GetTaskRecord(taskRecordID)
|
|
if taskRecord.State == CloudFile.E_TaskState.Progress then
|
|
CloudFile.CloudFileManager.Ins:StopTask(taskRecordID)
|
|
end
|
|
CloudFile.CloudFileManager.Ins:RestartTask(taskRecordID)
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:UnregisterCallback(taskRecordID)
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:RegisterCallback(taskRecordID, progress_callback, success_callback, error_callback)
|
|
else
|
|
local path = ApplicationHelper.persistentDataPath .. '/' .. self:GetTempUploadPathOfLocal(scenic_spot_id)
|
|
local url = UpyunInfo.GetNormalUploadURL() .. '/' .. self:GetPathOfServer(scenic_spot_id)
|
|
local taskRecordID = nil
|
|
if not BackwardCompatibilityUtil.CompatibilityMode(BackwardCompatibilityUtil.V13) then
|
|
taskRecordID = CloudFile.CloudFileManager.Ins:NormalUpload(path, url, progress_callback ,success_callback, error_callback, nil)
|
|
else
|
|
taskRecordID = CloudFile.CloudFileManager.Ins:NormalUpload(path, url, progress_callback ,success_callback, error_callback)
|
|
end
|
|
if taskRecordID > 0 then
|
|
gCachedUploadTaskRecordID[scenic_spot_id] = taskRecordID
|
|
end
|
|
end
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:StopUpload(scenic_spot_id)
|
|
local taskRecordID = gCachedUploadTaskRecordID[scenic_spot_id]
|
|
if taskRecordID ~= nil then
|
|
CloudFile.CloudFileManager.Ins:StopTask(taskRecordID)
|
|
end
|
|
end
|
|
|
|
local operatorName = 'roxdcdn'
|
|
local formUploadCallbacks = {}
|
|
function NetIngScenicSpotPhoto:FormUpload(scenic_spot_id, progress_callback, success_callback, error_callback)
|
|
formUploadCallbacks[scenic_spot_id] = {progressCallback = progress_callback, successCallback = success_callback, errorCallback = error_callback}
|
|
ServiceNUserProxy.Instance:CallUploadSceneryPhotoUserCmd(SceneUser2_pb.EALBUMTYPE_SCENERY, scenic_spot_id)
|
|
self.stopFormUploadFlag[scenic_spot_id] = false
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:OnReceiveUploadSceneryPhotoUserCmd(message)
|
|
print('NetIngScenicSpotPhoto:OnReceiveUploadSceneryPhotoUserCmd')
|
|
local eType = message.type
|
|
if eType == SceneUser2_pb.EALBUMTYPE_SCENERY then
|
|
local scenerySpotID = message.sceneryid
|
|
if not self.stopFormUploadFlag[scenerySpotID] then
|
|
local policy = message.policy
|
|
local signature = message.signature
|
|
local authorization = "UPYUN " .. operatorName .. ":" .. signature;
|
|
self:DoFormUpload(
|
|
scenerySpotID,
|
|
policy,
|
|
authorization,
|
|
formUploadCallbacks[scenerySpotID].progressCallback,
|
|
formUploadCallbacks[scenerySpotID].successCallback,
|
|
formUploadCallbacks[scenerySpotID].errorCallback
|
|
)
|
|
end
|
|
formUploadCallbacks[scenerySpotID] = nil
|
|
end
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:DoFormUpload(scenic_spot_id, policy, authorization, progress_callback, success_callback, error_callback)
|
|
if table.ContainsKey(gCachedUploadTaskRecordID, scenic_spot_id) then
|
|
local taskRecordID = gCachedUploadTaskRecordID[scenic_spot_id]
|
|
local taskRecord = CloudFile.CloudFileManager.Ins._TaskRecordCenter:GetTaskRecord(taskRecordID)
|
|
if taskRecord.State == CloudFile.E_TaskState.Progress then
|
|
CloudFile.CloudFileManager.Ins:StopTask(taskRecordID)
|
|
end
|
|
CloudFile.CloudFileManager.Ins:RestartTask(taskRecordID)
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:UnregisterCallback(taskRecordID)
|
|
CloudFile.CloudFileManager.Ins._CloudFileCallbacks:RegisterCallback(taskRecordID, progress_callback, success_callback, error_callback)
|
|
else
|
|
local path = ApplicationHelper.persistentDataPath .. '/' .. self:GetTempUploadPathOfLocal(scenic_spot_id)
|
|
local url = UpyunInfo.GetFormUploadURL()
|
|
local taskRecordID = CloudFile.CloudFileManager.Ins:FormUpload(path, url, policy, authorization, progress_callback ,success_callback, error_callback, nil)
|
|
if taskRecordID > 0 then
|
|
gCachedUploadTaskRecordID[scenic_spot_id] = taskRecordID
|
|
end
|
|
end
|
|
end
|
|
|
|
function NetIngPersonalPhoto:StopFormUpload(scenic_spot_id)
|
|
self.stopFormUploadFlag[scenic_spot_id] = true
|
|
self:StopUpload(scenic_spot_id)
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:SetUserPathOfServer(user_path)
|
|
self.userPathOfServer = user_path
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:GetPathOfServer(scenic_spot_id, pExtension)
|
|
return self:GetPathOfServerWithRoleID(Game.Myself.data.id, scenic_spot_id, pExtension)
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:GetPathOfServerWithRoleID(role_id, scenic_spot_id, pExtension)
|
|
local extension = PhotoFileInfo.Extension
|
|
if pExtension ~= nil then
|
|
extension = pExtension
|
|
end
|
|
return self.userPathOfServer .. '/' .. role_id .. '/' .. scenic_spot_id .. '.' .. extension
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:GetTempDownloadRootPathOfLocal()
|
|
return 'TempUsedToDownloadScenicSpot'
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:GetTempDownloadPathOfLocal(scenic_spot_id, o_or_t, pExtension)
|
|
local extension = PhotoFileInfo.Extension
|
|
if pExtension ~= nil then
|
|
extension = pExtension
|
|
end
|
|
return self:GetTempDownloadRootPathOfLocal() .. '/' .. scenic_spot_id .. '_' .. (o_or_t and 'o' or 't') .. '.' .. extension
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:GetTempUploadRootPathOfLocal()
|
|
return 'TempUsedToUploadScenicSpot'
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:GetTempUploadPathOfLocal(scenic_spot_id)
|
|
return self:GetTempUploadRootPathOfLocal() .. '/' .. scenic_spot_id .. '.' .. PhotoFileInfo.Extension
|
|
end
|
|
|
|
function NetIngScenicSpotPhoto:SetExist(role_id, scenic_spot_id)
|
|
if self.tabIsExist[role_id] == nil then
|
|
self.tabIsExist[role_id] = {}
|
|
end
|
|
self.tabIsExist[role_id][scenic_spot_id] = 0
|
|
end
|
|
|
|
local existResponseCode = {
|
|
[200] = 0,
|
|
}
|
|
function NetIngScenicSpotPhoto:CheckExist(role_id, scenic_spot_id, exist_callback, error_callback, extension)
|
|
local scenicSpotIsExist = self.tabIsExist[role_id]
|
|
if scenicSpotIsExist ~= nil then
|
|
if scenicSpotIsExist[scenic_spot_id] ~= nil then
|
|
if exist_callback ~= nil then
|
|
exist_callback()
|
|
end
|
|
return
|
|
end
|
|
end
|
|
|
|
local url = UpyunInfo.GetVisitURL() .. '/' .. self:GetPathOfServerWithRoleID(role_id, scenic_spot_id, extension)
|
|
HTTPRequest.Head(url, function (x)
|
|
local unityWebRequest = x
|
|
local responseCode = unityWebRequest.responseCode
|
|
-- HTTPRequest.BackUnityWebRequest(unityWebRequest)
|
|
-- unityWebRequest:Dispose()
|
|
-- unityWebRequest = nil
|
|
if existResponseCode[responseCode] == 0 then
|
|
if exist_callback ~= nil then
|
|
exist_callback()
|
|
end
|
|
else
|
|
if error_callback ~= nil then
|
|
error_callback()
|
|
end
|
|
end
|
|
end)
|
|
end |