1
import {
2
  WritableStream,
3
} from 'web-streams-polyfill/ponyfill';
4
import StreamSaver from 'streamsaver';
5

6
const handleFileDownLoad = async (url, username, password, filename) => {
7
    const tempHeader = new Headers();
8
    tempHeader.append('Authorization', `Basic ${Base64.encode(`${username}:${password}`)}`);
9
    fetch(`${url}?pipelineDownLoad=true`, {
10
      method: 'GET',
11
      headers: tempHeader,
12
      // mode: 'no-cors',
13
      // redirect: 'manual',
14
    })
15
      .then((response) => {
16
        console.log(response);
17
        if (!window.WritableStream) {
18
          StreamSaver.WritableStream = WritableStream;
19
          window.WritableStream = WritableStream;
20
        }
21
        const fileStream = StreamSaver.createWriteStream(filename, {
22
          writableStrategy: true,
23
          readableStrategy: true,
24
        });
25
        const readableStream = response.body;
26
        if (window.WritableStream && readableStream?.pipeTo) {
27
          return readableStream.pipeTo(fileStream).then(() => {
28
            message.success('下载成功');
29
          });
30
        }
31

32
        const writer = fileStream.getWriter();
33
        window.writer = writer;
34

35
        const reader = response.body?.getReader();
36
        const pump = () => reader?.read()
37
          .then((res) => (res.done
38
            ? writer.close()
39
            : writer.write(res.value).then(pump)));
40
        pump();
41
        // message.success('下载成功');
42
        return true;
43
      }).catch((error) => {
44
        throw new Error(error);
45
      });
46
  };