Function TD_ParseChunckedJson(s,endS,AllData,unStr,subData,fieldName);
begin
//将订阅中分段接收的json串解析成天软数组---舍头保尾
//输入：s json串，endS 分割符
//输出：AllData能完整解析的数据组合，subData解析后的"CmdData"子项或指定项的数据组合,
//unStr为尾巴上未解析的串
   strEs:=s[length(s)-length(endS):];
   subArr:=str2array(s,endS);//分割
   unStr:='';//未处理部分
   AllData:=array();
   tArr:=subArr;
   if strEs<>endS then begin
    if length(subArr)>=2 then tArr:=subArr[:length(subArr)-2];
    else tArr:=array();
    unStr:=subArr[length(subArr)-1];//最后一行
   end
   tArr::
    try
      AllData&=array(importjsonstring(mcell));
    except
      echo "解析失败：mrow(",mrow,")->",mcell,"\r\m";
    end;
   if ifnil(subData) then return AllData;//不合并子集
   subData:=array();
   if ifnil(fieldName) then fieldName:="CmdData";//行情订阅的下标
   if fieldName not in mcols(AllData,1) then return AllData;//fieldName不存在
   //-------合并子集-------
   for i,r in AllData do subData&=r[fieldName];
   return AllData;
end

url:='https://opi.tinysoft.com.cn/Service/Subscription/';
tbody:=array("Type":1,"IDs":("SH600519","SZ000002"),"SUBs":("date_s","price"));
body:=ExportJsonString(tbody);
//TS-BOUNDARY设置分割符
headArr:=array("Connection: keep-alive","Content-Type: application/json","JSON-Encode: gbk","TS-BOUNDARY: end");
header:=array2str(headArr,"\r\n");
sid:=CreateHttpSession();
sethttpMode(sid,1);//设置chunked模式（分段模式）,分段输出模式
echo "\r\n";
tuser:="user"; //用户账号
tpassw:="password"; //用户密码
rt:=array();
while timeof(now())<strtotime("15:01:00") do //到15:01 收盘后停止接收行情
begin
  r:=InternetRequest(sid,url,"",header,body,tuser,tpassw,0,res,resp,30000);
  echo "->excute:",r," resp->",resp," res->",res,"\r\n";
//--分段模式下数据拼接与标准化处理
  if resp=200 or resp=1000 then begin
    dS:=ifstring(unStr)?(unStr+res):res;
    TD_ParseChunckedJson(dS,"end",AllData,unStr,subData);
    rt&=subData;
    echo "subData->",length(subData),"\r\n";
    echo "unStr->",unStr,"\r\n";
  end
end
DestroyHttpSession(sid);//销毁该会话
ret:=ExportFile(ftXLS(),"","D:\\Downloads\\行情订阅_"$datetoint(today())$".xlsx",rt);
echo rt;
return ;

Function TD_ParseChunckedJson(s,endS,AllData,unStr,subData,fieldName);
begin
   strEs:=s[length(s)-length(endS):];
   subArr:=str2array(s,endS);//分割
   unStr:='';//未处理部分
   AllData:=array();
   tArr:=subArr;
   if strEs<>endS then begin
    if length(subArr)>=2 then tArr:=subArr[:length(subArr)-2];
    else tArr:=array();
    unStr:=subArr[length(subArr)-1];//最后一行
   end
   tArr::
    try
      AllData&=array(importjsonstring(mcell));
    except
      echo "解析失败：mrow(",mrow,")->",mcell,"\r\m";
    end;
   if ifnil(subData) then return AllData;//不合并子集
   subData:=array();
   if ifnil(fieldName) then fieldName:="CmdData";//行情订阅的下标
   if fieldName not in mcols(AllData,1) then return AllData;//fieldName不存在
   //-------合并子集-------
   for i,r in AllData do subData&=r[fieldName];
   return AllData;
end