cloud.lua

-- 云控对接
-- 为什么不用local，因为有些解释器的require有bug。
cloud = {}
m = cloud

m.deviceToken = ''
m.server = ''
m.heartBeatTid = -1
m.status = 1

m.setDeviceToken = function(deviceToken)
  deviceToken = strOr(deviceToken):trim()
  if #deviceToken < 5 then return end
  m.deviceToken = deviceToken
end

m.setServer = function(server)
  server = strOr(server):trim()
  server = server:gsub("/+$", '')
  if #server < 5 then return end
  m.server = server
end

m.setStatus = function(status) m.status = status end

m.enabled =
  function() return #strOr(m.server) > 0 and #strOr(m.deviceToken) > 0 end

m.getTaskEnabled = function() return cloud_get_task and m.enabled() end

m.heartBeat = function()
  -- log("32",32)
  local data = {status = m.status, deviceToken = m.deviceToken}
  local res, code = httpPost(m.server .. "/heartBeat", JsonEncode(data), 30,
                             "Content-Type: application/json")
  -- log("res,code", res, code)
  return res, code
end

m.getTask = function()
  -- log("40",40)
  local res, code = httpGet(m.server .. "/getTask?" .. "deviceToken=" ..
                              m.deviceToken, 30,
                            'Content-Type: application/json')
  return res, code
end

-- m.addLog = function(img, info)
--   -- log("48",48)
--   if not m.enabled() then return end
--   local x = cloud_task or {}
--   local data = {
--     id = x.id or 0,
--     level = 'INFO',
--     taskType = x.taskType or '',
--     title = info or '',
--     detail = info or '',
--     imageUrl = img or '',
--     from = x.from or '',
--     name = x.name or '',
--     account = x.account or '',
--     password = x.password or '',
--     server = x.server or '',
--     time = os.date("!%Y-%m-%dT%TZ"),
--   }
--   -- log("data",data)
--   local res, code = httpPost(
--                       m.server .. "/addLog?deviceToken=" .. m.deviceToken,
--                       JsonEncode(data), 30, 'Content-Type: application/json')
--   -- log("res,code", res, code)
--   return res, code
-- end

-- Standardized log
-- Author: DazeCake
m.addLog = function(log_level, log_title, log_detail, img_url)
  -- log("48",48)
  if not m.enabled() then return end
  local x = cloud_task or {}
  local data = {
    id = x.id or 0,
    level = log_level or 'INFO',
    taskType = x.taskType or '',
    title = log_title or '',
    detail = log_detail or '',
    imageUrl = img_url or '',
    from = x.from or '',
    name = x.name or '',
    account = x.account or '',
    password = '',
    server = x.server or '',
    time = os.date("!%Y-%m-%dT%TZ"),
  }
  -- log("data",data)
  local res, code = httpPost(
                      m.server .. "/addLog?deviceToken=" .. m.deviceToken,
                      JsonEncode(data), 30, 'Content-Type: application/json')
  -- log("res,code", res, code)
  return res, code
end

m.FAILTASK_LINEBUSY = 'lineBusy'
m.FAILTASK_ACCOUNTERROR = 'accountError'

m.failTask = function(imageUrl, type)
  -- log("73",73)
  if not m.getTaskEnabled() then return end
  imageUrl = imageUrl or ''
  type = type or ''
  local res, code = httpPost(m.server .. "/failTask?deviceToken=" ..
                               m.deviceToken .. "&imageUrl=" ..
                               encodeUrl(imageUrl) .. "&type=" .. type, '', 30,
                             'Content-Type: application/json')
  return res, code
end

m.completeTask = function(imageUrl)
  -- log("84",84)
  if not m.getTaskEnabled() then return end
  imageUrl = imageUrl or ''
  local res, code = httpPost(m.server .. "/completeTask?deviceToken=" ..
                               m.deviceToken .. "&imageUrl=" ..
                               encodeUrl(imageUrl), '', 30,
                             'Content-Type: application/json')
  return res, code
end

m.haltComplete = function()
  print("停机上报")
  local data = {status = m.status, deviceToken = m.deviceToken}
  local res, code = httpPost(m.server .. "/haltComplete", JsonEncode(data), 30,
                             "Content-Type: application/json")
  return res, code
end

m.solveTask = function(data) restartSimpleMode(data) end

m.fetchSolveTask = function()
  if not m.getTaskEnabled() then return end
  while true do
    local res, code = m.getTask()
    -- log("code", code)
    -- log("res", res)
    local status, data
    status, data = pcall(JsonDecode, res)
    log("data", data)
    if type(data) == 'table' and type(data.data) == 'table' then
      m.solveTask(data.data)
    end
    m.setStatus(1)
    ssleep(5)
  end
end

m.startHeartBeat = function()
  -- log("m.enabled()", m.enabled())
  if not m.enabled() then return end
  local f = function()
    while true do
      local res, code = m.heartBeat()
      local status, data = pcall(JsonDecode, res)
      if data.code == 500 then
        m.haltComplete()
        log("云控", "停机上报")
        -- 子线程不能直接stop 需要使用setTimer延时函数回调stop到主线程
        setTimer(stop, 100, "强制停机")
      end
      ssleep(5)
    end
  end
  m.heartBeatTid = beginThread(f)
end

m.stopHeartBeat = function() stopThread(m.heartBeatTid) end

m.sanReport = function()
  log("理智上报", m.enabled())
  -- if not m.enabled() then return true end
  local p = point["剩余理智"]
  local ocrHander = createOcr()
  local sanText = ocrText(ocrHander, p[1], p[2], p[3], p[4], "ffffff-a8a8a8") or "0/100"
  releaseOcr(ocrHander)
  sanText = string.match(sanText, "[%d]+[/][%d]+")
  local index = 1
  local san = {}
  log("理智", sanText)
  for word in string.gmatch(sanText, "%d+") do
    san[index] = word
    index = index + 1
  end
  local res, code = httpPost(m.server .. "/sanReport?san=" .. san[1] ..
                               "&maxSan=" .. san[2] .. "&deviceToken=" ..
                               m.deviceToken, '', 30,
                             'Content-Type: application/json')
end

restartSimpleMode = function(data)
  if not type(data) == 'table' then return end
  if not table.includes({"daily", "rogue"}, data.taskType) then return end
  local username = data.account
  local password = data.password
  local server = data.server
  local config = data.config
  local taskType = data.taskType
  -- local x
  -- set recommend config over default
  -- x = loadOneUIConfig("main")
  -- x["fight_ui"] = "jm hd ce ls ap pr"
  -- for i = 1, 12 do x["now_job_ui" .. i] = true end
  -- x["now_job_ui8"] = false
  -- x["crontab_text"] = "4:00 12:00 20:00"
  -- saveOneUIConfig("main", x)
  --
  -- x = loadOneUIConfig("debug")
  -- x["max_jmfight_times"] = "1"
  -- x["max_login_times_5min"] = "3"
  -- x["QQ"] = strOr(config.QQ) .. '#' .. strOr(config.deviceName)
  -- x["multi_account_choice_weekday_only"] =
  --   strOr(config.weekdayOnly, x["multi_account_choice_weekday_only"])
  --
  -- x["qqnotify_beforemail"] = true
  -- x["qqnotify_afterenter"] = true
  -- x["qqnotify_beforeleaving"] = true
  -- x["qqnotify_beforemission"] = true
  -- x["qqnotify_save"] = true
  -- x["collect_beforeleaving"] = true
  -- -- 一是完成日常任务，二是间隔时间最长可以11小时，提高容错
  -- x["zero_san_after_fight"] = true
  -- x["max_drug_times_" .. str(1) .. "day"] = "99"
  -- x["max_drug_times_" .. str(2) .. "day"] = "99"
  -- x["max_drug_times_" .. str(3) .. "day"] = "1"
  -- x["max_drug_times_" .. str(4) .. "day"] = "1"
  -- x["max_drug_times_" .. str(5) .. "day"] = "1"
  -- x["max_drug_times_" .. str(6) .. "day"] = "1"
  -- x["max_drug_times_" .. str(7) .. "day"] = "1"
  -- x["enable_log"] = false
  -- x["disable_killacc"] = false
  -- x["keepalive_interval"] = "900"
  -- saveOneUIConfig("debug", x)
  --
  -- x = loadOneUIConfig("multi_account")
  -- x["multi_account_end_closeotherapp"] = true
  -- x["multi_account_end_closeapp"] = true
  -- x["multi_account_choice"] = "1-30"
  -- x["multi_account_enable"] = true
  -- saveOneUIConfig("multi_account", x)

  -- log("64",64)
  -- set task config
  -- log("62",61)
  -- exit()
  if #strOr(username) == 0 or #strOr(password) == 0 then return end
  -- log("63",61)
  if not table.includes({0, 1}, server) then return end
  -- log("64",61)
  if not type(config) == 'table' then return end
  -- log("65",61)
  -- log("65", 64)

  local hook = [[
cloud_task=JsonDecode(]] .. string.format("%q", JsonEncode(data)) .. [[);
crontab_enable=false
multi_account_enable=false
username=]] .. string.format("%q", username) .. [[;
password=]] .. string.format("%q", password) .. [[;
server=]] .. server
  if taskType == 'rogue' then
    hook = hook .. [[;extra_mode="战略前瞻投资"]]
  end

  -- log("64",64)
  -- log("config",config)
  -- exit()
  -- 日常
  local x
  x = get(config, 'daily', 'fight')
  if istable(x) then
    local y = ''
    for _, v in pairs(x) do
      if get(v, 'num') == 1 then
        y = y .. str(get(v, 'level')) .. ' '
      else
        y = y .. str(get(v, 'level')) .. 'x' .. str2int(get(v, 'num')) .. ' '
      end
    end
    hook = hook .. [[;fight_ui=]] .. string.format("%q", y)
    hook = hook .. [[;now_job_ui2=]] .. str(#y > 0)
  end
  -- log("65",64)

  x = get(config, 'daily', 'sanity', 'drug')
  if x then hook = hook .. [[;max_drug_times=]] .. str2int(x) end

  x = get(config, 'daily', 'sanity', 'stone')
  if x then hook = hook .. [[;max_stone_times=]] .. str2int(x) end

  hook = hook .. [[;now_job_ui1=]] .. str(get(config, 'daily', 'mail'))
  hook = hook .. [[;now_job_ui3=]] .. str(get(config, 'daily', 'friend'))

  hook = hook .. [[;now_job_ui4=]] ..
           str(get(config, 'daily', 'infrastructure', 'harvest'))
  hook = hook .. [[;now_job_ui5=]] ..
           str(get(config, 'daily', 'infrastructure', 'shift'))
  hook = hook .. [[;now_job_ui6=]] ..
           str(get(config, 'daily', 'infrastructure', 'acceleration'))

  hook = hook .. [[;now_job_ui7=]] ..
           str(get(config, 'daily', 'infrastructure', 'communication'))
  hook = hook .. [[;now_job_ui8=]] ..
           str(get(config, 'daily', 'infrastructure', 'deputy'))
  hook = hook .. [[;now_job_ui9=]] .. str(get(config, 'daily', 'credit'))

  hook = hook .. [[;now_job_ui10=]] ..
           str(get(config, 'daily', 'offer', 'enable'))
  hook = hook .. [[;now_job_ui11=]] .. str(get(config, 'daily', 'task'))
  hook = hook .. [[;now_job_ui12=]] .. str(get(config, 'daily', 'activity'))

  hook = hook .. [[;auto_recruit0=]] ..
           str(get(config, 'daily', 'offer', 'other'))
  hook = hook .. [[;auto_recruit1=]] ..
           str(get(config, 'daily', 'offer', 'car'))
  hook = hook .. [[;auto_recruit4=]] ..
           str(get(config, 'daily', 'offer', 'star4'))
  hook = hook .. [[;auto_recruit5=]] ..
           str(get(config, 'daily', 'offer', 'star5'))
  hook = hook .. [[;auto_recruit6=]] ..
           str(get(config, 'daily', 'offer', 'star6'))

  -- 肉鸽
  hook = hook .. [[;zl_best_operator=]] ..
           str2int(get(config, 'rogue', 'operator', 'index'))
  hook = hook .. [[;zl_skill_times=]] ..
           str2int(get(config, 'rogue', 'operator', 'num'))
  hook = hook .. [[;zl_skill_idx=]] ..
           str2int(get(config, 'rogue', 'operator', 'skill'))
  hook = hook .. [[;zl_max_coin=]] .. str2int(get(config, 'rogue', 'coin'))
  hook = hook .. [[;zl_max_level=]] .. str2int(get(config, 'rogue', 'level'))
  hook = hook .. [[;zl_more_repertoire=false]]
  hook = hook .. [[;zl_more_experience=true]]
  hook = hook .. [[;zl_skip_coin=]] .. str(get(config, 'rogue', 'skip', 'coin'))
  hook = hook .. [[;zl_skip_hard=]] ..
           str(get(config, 'rogue', 'skip', 'beast'))
  hook = hook .. [[;zl_no_waste=]] ..
           str(not get(config, 'rogue', 'skip', 'daily'))
  hook = hook .. [[;zl_accept_mg=]] ..
           str(not get(config, 'rogue', 'skip', 'sensitive'))
  hook = hook .. [[;zl_accept_yx=]] ..
           str(not get(config, 'rogue', 'skip', 'illusion'))
  hook = hook .. [[;zl_accept_sc=]] ..
           str(not get(config, 'rogue', 'skip', 'survive'))

  -- --- TODO debug
  -- for i = 1,12 do
  --   hook = hook .. [[;now_job_ui]]..i .. [[=false]]
  -- end
  -- ---

  hook = hook .. [[;saveConfig("restart_mode_hook",]] ..
           string.format("%q", hook) .. ')'
  log("hook", hook)
  -- ssleep(1000)
  saveConfig("hideUIOnce", "true")
  saveConfig("restart_mode_hook", hook)
  restartPackage()
end