正在显示
1 个修改的文件
包含
4 行增加
和
1 行删除
| @@ -134,7 +134,10 @@ class TestKafkaSend extends BaseController | @@ -134,7 +134,10 @@ class TestKafkaSend extends BaseController | ||
| 134 | ]; | 134 | ]; |
| 135 | $typeMsg = 'link'; | 135 | $typeMsg = 'link'; |
| 136 | } else { | 136 | } else { |
| 137 | + trace('type: '.$type,'test_consumer'); | ||
| 138 | + trace('data数组 -> ts: '.$data[$ts],'test_consumer'); | ||
| 137 | $datatype = [$type => $data[$ts]]; | 139 | $datatype = [$type => $data[$ts]]; |
| 140 | + trace('datatype 数组: '.json_encode($datatype, JSON_UNESCAPED_UNICODE),'test_consumer'); | ||
| 138 | } | 141 | } |
| 139 | 142 | ||
| 140 | $postdata = [ | 143 | $postdata = [ |
| @@ -146,7 +149,7 @@ class TestKafkaSend extends BaseController | @@ -146,7 +149,7 @@ class TestKafkaSend extends BaseController | ||
| 146 | 'msg_platform' => $res['msg_platform'], | 149 | 'msg_platform' => $res['msg_platform'], |
| 147 | 'softname' => $res['softname'] | 150 | 'softname' => $res['softname'] |
| 148 | ]; | 151 | ]; |
| 149 | - // trace('postdata 数组 end: '.json_encode($postdata, JSON_UNESCAPED_UNICODE),'test_consumer'); | 152 | + trace('postdata 数组 end: '.json_encode($postdata, JSON_UNESCAPED_UNICODE),'test_consumer'); |
| 150 | $code = $this->postCurl($url, json_encode($postdata)); | 153 | $code = $this->postCurl($url, json_encode($postdata)); |
| 151 | 154 | ||
| 152 | if ($code == 200) { | 155 | if ($code == 200) { |
-
请 注册 或 登录 后发表评论