收藏本站
登录 立即注册 开启辅助访问 切换到窄版

搜索
萝卜头IT论坛»论坛 › 萝卜头IT技术 › 原创小软件 › CAB压缩/解压缩文件库
返回列表 发新帖
查看: 3443|回复: 0

CAB压缩/解压缩文件库

[复制链接]
20011010wo
发表于 2016-8-3 21:59:56 | 显示全部楼层 |阅读模式

  2. #pragma once

  4. #include <FCI.h>
  5. #include <FDI.h>

  7. #include <io.h>
  8. #include <fcntl.h>
  9. #include <errno.h>
  10. #include <sys/stat.h>
  11. #include <crtdefs.h>

  13. #include <Windows.h>

  15. #pragma warning( push )
  16. #pragma comment( lib , "Cabinet" )
  17. //==================================================================================================
  18. #define ASSERTEXPR(expr)  
  19. //==================================================================================================
  20. #define FOLDER_THRESHOLD    900000

  22. //==================================================================================================
  23. #ifndef CHK_EXP_RET
  24. #define CHK_EXP_RET( exp , ret ) if( exp ) { return ret ; }
  25. #endif

  27. //==================================================================================================
  28. namespace Cabinet
  29. {
  30.         //==============================================================================================
  31.         template< typename T > class CEncryptImpl
  32.         {
  33.         public:
  34.                 BOOL SetEncryptKey(LPVOID lpKey, DWORD dwSize)
  35.                 {
  36.                         return TRUE;
  37.                 }

  39.                 BOOL EncryptData(LPVOID lpData, DWORD dwData)
  40.                 {
  41.                         return TRUE;
  42.                 }
  43.         };

  45.         template< typename T > class CDecryptImpl
  46.         {
  47.         public:
  48.                 BOOL SetDecryptKey(LPVOID lpKey, DWORD dwSize)
  49.                 {
  50.                         return TRUE;
  51.                 }

  53.                 BOOL DecryptData(LPVOID lpData, DWORD dwData)
  54.                 {
  55.                         return TRUE;
  56.                 }
  57.         };

  59.         //==============================================================================================
  60.         template< typename T, typename EncryptT = CEncryptImpl<T> > class CPackageImpl : public EncryptT
  61.         {
  62.         public:
  63.                 CPackageImpl()
  64.                 {
  65.                         Initialize();
  66.                 }

  68.                 ~CPackageImpl()
  69.                 {
  70.                         DestroyContext();
  71.                 }

  73.         public:
  74.                 BOOL CreateContext(LPCSTR lpszPathFile, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  75.                 {
  76.                         // 校验输入参数
  77.                         CHK_EXP_RET(lpszPathFile == NULL, FALSE);
  78.                         CHK_EXP_RET(strlen(lpszPathFile) < 6, FALSE);
  79.                         CHK_EXP_RET(IsBadReadPtr(lpszPathFile, 6), FALSE);

  81.                         // 准备参数
  82.                         CHAR szPathFile[MAX_PATH] = { "" };
  83.                         strncpy(szPathFile, lpszPathFile, MAX_PATH);
  84.                         LPCSTR lpszFile = PathFindFileNameA(szPathFile);
  85.                         CHK_EXP_RET(lpszFile == szPathFile, ERROR_PATH_NOT_FOUND);

  87.                         // 处理数据并调用函数
  88.                         szPathFile[lpszFile - szPathFile - 1] = 0;
  89.                         return CreateContext(szPathFile, lpszFile, nSplitSize, wCabinetID);

  91.                 }

  93.                 BOOL CreateContext(LPCSTR lpszPath, LPCSTR lpszFile, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  94.                 {
  95.                         // 校验输入参数
  96.                         CHK_EXP_RET(lpszPath == NULL, FALSE);
  97.                         CHK_EXP_RET(lpszFile == NULL, FALSE);

  99.                         CHK_EXP_RET(strlen(lpszPath) < 2, FALSE);
  100.                         CHK_EXP_RET(strlen(lpszFile) < 2, FALSE);

  102.                         CHK_EXP_RET(IsBadReadPtr(lpszPath, 2), FALSE);
  103.                         CHK_EXP_RET(IsBadReadPtr(lpszFile, 2), FALSE);

  105.                         m_bAutoFlush = TRUE;
  106.                         m_bOperAbort = FALSE;

  108.                         T* pT = static_cast<T*>(this);
  109.                         CHK_EXP_RET(!pT->OnPrepareCreate(m_xPackage, lpszPath, lpszFile, nSplitSize, wCabinetID), FALSE);
  110.                         m_hContext = FCICreate(&m_xError, FCI_FilePlaced, FCI_Alloc, FCI_Free, FCI_Open, FCI_Read, FCI_Write,
  111.                                 FCI_Close, FCI_Seek, FCI_Delete, FCI_GetTempFile, &m_xPackage, this);
  112.                         return (m_hContext != NULL);
  113.                 }

  115.                 BOOL DestroyContext()
  116.                 {
  117.                         CHK_EXP_RET(m_hContext == NULL, TRUE);
  118.                         CHK_EXP_RET(m_bAutoFlush && !FlushCabinet(FALSE), FALSE);
  119.                         CHK_EXP_RET(!FCIDestroy(m_hContext), FALSE);
  120.                         m_hContext = NULL;
  121.                         return TRUE;
  122.                 }

  124.                 VOID AbortPackage()
  125.                 {
  126.                         m_bOperAbort = TRUE;
  127.                 }

  129.                 BOOL FlushFolder()
  130.                 {
  131.                         ASSERTEXPR(m_hContext != NULL);
  132.                         CHK_EXP_RET(m_hContext == NULL, FALSE);
  133.                         return FCIFlushFolder(m_hContext, FCI_GetNextCabinet, FCI_UpdateStatus);
  134.                 }

  136.                 BOOL FlushCabinet(BOOL bCreateNewCabinetFile = FALSE)
  137.                 {
  138.                         ASSERTEXPR(m_hContext != NULL);
  139.                         CHK_EXP_RET(m_hContext == NULL, FALSE);
  140.                         return FCIFlushCabinet(m_hContext, bCreateNewCabinetFile, FCI_GetNextCabinet, FCI_UpdateStatus);
  141.                 }

  143.                 BOOL AddFile(LPSTR szFileToAdd, LPSTR szNameInCab = NULL)
  144.                 {
  145.                         ASSERTEXPR(m_hContext != NULL);
  146.                         CHK_EXP_RET(m_hContext == NULL, FALSE);

  148.                         m_bAutoFlush = TRUE; // 必须刷新才行
  149.                         szNameInCab = szNameInCab ? szNameInCab : PathFindFileNameA(szFileToAdd);
  150.                         return FCIAddFile(m_hContext, szFileToAdd, szNameInCab, FALSE, FCI_GetNextCabinet, FCI_UpdateStatus, FCI_GetOpenInfo, tcompTYPE_MSZIP);
  151.                 }

  153.                 // nFolder 是压缩目录的根目录长度用来产生目录结构，外面调用不要设置该参数
  154.                 BOOL AddFolder(LPCSTR szFolder, LPCSTR szFilter = NULL, UINT nFolder = 0)
  155.                 {
  156.                         ASSERTEXPR(m_hContext != NULL);
  157.                         CHK_EXP_RET(m_hContext == NULL, FALSE);

  159.                         CHAR szPath[MAX_PATH] = { "" };
  160.                         strncpy(szPath, szFolder, MAX_PATH);
  161.                         PathAddBackslashA(szPath);

  163.                         // 计算根目录的长度并设置搜索路径
  164.                         UINT nSearch = strlen(szPath);
  165.                         nFolder = nFolder ? nFolder : nSearch;
  166.                         szFilter = szFilter ? szFilter : "*.*";
  167.                         strcat(szPath, szFilter);

  169.                         WIN32_FIND_DATAA datFinder;
  170.                         HANDLE hFinder = FindFirstFileA(szPath, &datFinder);
  171.                         CHK_EXP_RET(hFinder == INVALID_HANDLE_VALUE, FALSE);

  173.                         BOOL bFindFile = (hFinder != INVALID_HANDLE_VALUE);
  174.                         while (bFindFile)
  175.                         {
  176.                                 if (datFinder.cFileName[0] == '.')
  177.                                 {
  178.                                         bFindFile = FindNextFileA(hFinder, &datFinder);
  179.                                         continue;
  180.                                 }

  182.                                 strcpy(szPath + nSearch, datFinder.cFileName);

  184.                                 if (datFinder.dwFileAttributes & FILE_ATTRIBUTE_DIRECTORY)
  185.                                 {
  186.                                         if (!AddFolder(szPath, szFilter, nFolder))
  187.                                         {
  188.                                                 FindClose(hFinder);
  189.                                                 return FALSE;
  190.                                         }
  191.                                 }
  192.                                 else
  193.                                 {
  194.                                         if (!AddFile(szPath, szPath + nFolder))
  195.                                         {
  196.                                                 FindClose(hFinder);
  197.                                                 return FALSE;
  198.                                         }
  199.                                 }

  201.                                 // 搜索下一个文件
  202.                                 bFindFile = FindNextFileA(hFinder, &datFinder);
  203.                         }

  205.                         FindClose(hFinder);
  206.                         return TRUE;
  207.                 }

  209.                 BOOL SetTempDirectory(LPCSTR szTempDir)
  210.                 {
  211.                         ASSERTEXPR(szTempDir != NULL);

  213.                         INT nLength = strlen(szTempDir);
  214.                         CHK_EXP_RET(3 < nLength, FALSE);
  215.                         CHK_EXP_RET(nLength > MAX_PATH, FALSE);

  217.                         strncpy(m_szTempDir, szTempDir, MAX_PATH);
  218.                         PathAddBackslashA(m_szTempDir);
  219.                         return TRUE;
  220.                 }

  222.         public:
  223.                 // 使用下面的函数可以直接对一个目录下的特定文件或者一个文件进行打包
  224.                 BOOL PackageFolder(LPSTR szCabinet, LPSTR szFolder, LPSTR szFilter = NULL, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  225.                 {
  226.                         CHK_EXP_RET(!CreateContext(szCabinet, nSplitSize, wCabinetID), FALSE);
  227.                         CHK_EXP_RET(!AddFolder(szFolder, szFilter), (DestroyContext(), FALSE));
  228.                         return DestroyContext();
  229.                 }

  231.                 BOOL PackageFile(LPSTR szCabinet, LPSTR szFile, LPSTR szName = NULL, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  232.                 {
  233.                         CHK_EXP_RET(!CreateContext(szCabinet, nSplitSize, wCabinetID), FALSE);
  234.                         CHK_EXP_RET(!AddFile(szFile, szName), (DestroyContext(), FALSE));
  235.                         return DestroyContext();
  236.                 }

  238.         public:
  239.                 // 下面这些函数是为了在 UNICODE 版本中方便使用而做的参数类型转换
  240.                 BOOL CreateContext(LPCWSTR lpszPathFile, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  241.                 {
  242.                         USES_CONVERSION_EX; ASSERTEXPR(lpszPathFile != NULL);
  243.                         return CreateContext(W2A_EX(lpszPathFile, 0), nSplitSize, wCabinetID);
  244.                 }

  246.                 BOOL CreateContext(LPCWSTR lpszPath, LPCWSTR lpszFile, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  247.                 {
  248.                         USES_CONVERSION_EX; ASSERTEXPR(lpszPath != NULL); ASSERTEXPR(lpszFile != NULL);
  249.                         return CreateContext(W2A_EX(lpszPath, 0), W2A_EX(lpszFile, 0), nSplitSize, wCabinetID);
  250.                 }

  252.                 BOOL AddFile(LPWSTR szFileToAdd, LPWSTR szNameInCab = NULL)
  253.                 {
  254.                         USES_CONVERSION_EX; ASSERTEXPR(szFileToAdd != NULL);
  255.                         return AddFile(W2A_EX(szFileToAdd, 0), szNameInCab ? W2A_EX(szNameInCab, 0) : NULL);
  256.                 }

  258.                 BOOL AddFolder(LPCWSTR szFolder, LPCWSTR szFilter = NULL)
  259.                 {
  260.                         USES_CONVERSION_EX; ASSERTEXPR(szFolder != NULL);
  261.                         return AddFolder(W2A_EX(szFolder, 0), szFilter ? W2A_EX(szFilter, 0) : NULL);
  262.                 }

  264.                 BOOL SetTempDirectory(LPCWSTR szTempDir)
  265.                 {
  266.                         USES_CONVERSION_EX; ASSERTEXPR(szTempDir != NULL)
  267.                                 return SetTempDirectory(W2A_EX(szTempDir, 0));
  268.                 }

  270.                 BOOL PackageFolder(LPCWSTR szCabinet, LPCWSTR szFolder, LPCWSTR szFilter = NULL, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  271.                 {
  272.                         USES_CONVERSION_EX;
  273.                         return PackageFolder(W2A_EX(szCabinet, 0), W2A_EX(szFolder, 0), szFilter ? W2A_EX(szFilter, 0) : NULL, nSplitSize, wCabinetID);
  274.                 }

  276.                 BOOL PackageFile(LPCWSTR szCabinet, LPCWSTR szFile, LPCWSTR szName = NULL, UINT nSplitSize = INT_MAX, WORD wCabinetID = 0)
  277.                 {
  278.                         USES_CONVERSION_EX;
  279.                         return PackageFile(W2A_EX(szCabinet, 0), W2A_EX(szFile, 0), szName ? W2A_EX(szName, 0) : NULL, nSplitSize, wCabinetID);
  280.                 }

  282.         public:
  283.                 BOOL OnPrepareCreate(CCAB& rCab, LPCSTR lpszPath, LPCSTR lpszFile, UINT nSplitSize, WORD wCabinetID)
  284.                 {
  285.                         // 设置产生
  286.                         ZeroMemory(&rCab, sizeof(CCAB));
  287.                         strcpy(rCab.szCabPath, lpszPath);
  288.                         PathAddBackslashA(rCab.szCabPath);

  290.                         // FCI 内部处理是有符号的
  291.                         rCab.cb = nSplitSize & INT_MAX;
  292.                         rCab.cbFolderThresh = FOLDER_THRESHOLD;
  293.                         rCab.iCab = rCab.iDisk = 1;
  294.                         rCab.setID = wCabinetID;

  296.                         // 不需要任何的扩展空间
  297.                         rCab.cbReserveCFHeader = 0;
  298.                         rCab.cbReserveCFFolder = 0;
  299.                         rCab.cbReserveCFData = 0;

  301.                         // 格式化一个文件名称出来
  302.                         strcpy(m_szCabFileFormat, lpszFile);
  303.                         FCI_GetNextCabinet(&rCab, 0, this);
  304.                         return TRUE;
  305.                 }

  307.         public:
  308.                 // 在新的类中重新定义这两个静态函数可以使用不同的内存策略
  309.                 static LPVOID Alloc(ULONG nSize) { return malloc(nSize); }
  310.                 static void Free(LPVOID lpMemory) { free(lpMemory); }

  312.         public:
  313.                 // 下面的函数可以重新实现以实现不同的文件管理
  314.                 INT FilePlaced(PCCAB lpCabinet, LPSTR pszFile, LONG nFile, BOOL fContinuation, LPVOID pData = NULL)
  315.                 {
  316.                         return ERROR_SUCCESS;
  317.                 }

  319.                 INT_PTR Open(LPSTR pszFile, INT nOpenFlag, INT nMode, LPINT pError, LPVOID pData = NULL)
  320.                 {
  321.                         INT_PTR xResult = _open(pszFile, nOpenFlag, nMode);
  322.                         if (xResult == -1) *pError = errno;
  323.                         return xResult;
  324.                 }

  326.                 UINT Read(INT_PTR hFile, LPVOID lpMemory, UINT nSize, LPINT pError, LPVOID pData = NULL)
  327.                 {
  328.                         UINT result = (UINT)_read(hFile, lpMemory, nSize);
  329.                         if (result != nSize) *pError = errno;
  330.                         return result;
  331.                 }

  333.                 UINT Write(INT_PTR hFile, LPVOID lpMemory, UINT nSize, LPINT pError, LPVOID pData = NULL)
  334.                 {
  335.                         UINT result = (UINT)_write(hFile, lpMemory, nSize);
  336.                         if (result != nSize) *pError = errno;
  337.                         return result;
  338.                 }

  340.                 INT Close(INT_PTR hFile, LPINT pError, LPVOID pData = NULL)
  341.                 {
  342.                         INT result = _close(hFile);
  343.                         if (result != 0) *pError = errno;
  344.                         return result;
  345.                 }

  347.                 LONG Seek(INT_PTR hFile, LONG nDistance, INT nSeekType, LPINT pError, LPVOID pData = NULL)
  348.                 {
  349.                         LONG result = _lseek(hFile, nDistance, nSeekType);
  350.                         if (result == -1) *pError = errno;
  351.                         return result;
  352.                 }

  354.                 INT Delete(LPSTR pszFile, LPINT pError, LPVOID pData = NULL)
  355.                 {
  356.                         INT result = remove(pszFile);
  357.                         if (result != 0) *pError = errno;
  358.                         return result;
  359.                 }

  361.                 BOOL GetTempFile(LPSTR pszTempName, INT nTempName, LPVOID pData = NULL)
  362.                 {
  363.                         while (true)
  364.                         {
  365.                                 wsprintfA(pszTempName, "%sCab%05u", m_szTempDir, m_nTempCounter++);
  366.                                 CHK_EXP_RET(GetFileAttributesA(pszTempName) == INVALID_FILE_ATTRIBUTES, TRUE);
  367.                         }
  368.                         return FALSE;
  369.                 }

  371.         public:
  372.                 BOOL GetNextCabinet(PCCAB pCab, ULONG nPrevCab, LPVOID pData = NULL)
  373.                 {
  374.                         wsprintfA(pCab->szCab, m_szCabFileFormat, pCab->iCab);
  375.                         wsprintfA(pCab->szDisk, "Disk %d", pCab->iDisk++);

  377.                         // 如果需要修改其他参数
  378.                         // pCab->cbFolderThresh = xyz;
  379.                         // pCab->setID = xyz;
  380.                         // pCab->cb    = xyz;

  382.                         return TRUE;
  383.                 }

  385.                 INT_PTR GetOpenInfo(LPSTR pszName, USHORT *pDate, USHORT *pTime, USHORT *pAttribs, LPINT pError, LPVOID pData = NULL)
  386.                 {
  387.                         BY_HANDLE_FILE_INFORMATION    xFileInfo;
  388.                         FILETIME                    xFileTime;

  390.                         DWORD dwFileAttrib = FILE_ATTRIBUTE_NORMAL | FILE_FLAG_SEQUENTIAL_SCAN;
  391.                         HANDLE handle = CreateFileA(pszName, GENERIC_READ, FILE_SHARE_READ, NULL, OPEN_EXISTING, dwFileAttrib, NULL);
  392.                         if (handle == INVALID_HANDLE_VALUE)
  393.                         {
  394.                                 *pError = GetLastError();
  395.                                 return UINT_MAX;
  396.                         }

  398.                         if (!GetFileInformationByHandle(handle, &xFileInfo))
  399.                         {
  400.                                 *pError = GetLastError();
  401.                                 CloseHandle(handle);
  402.                                 return UINT_MAX;
  403.                         }

  405.                         FileTimeToLocalFileTime(&xFileInfo.ftLastWriteTime, &xFileTime);
  406.                         FileTimeToDosDateTime(&xFileTime, pDate, pTime);

  408.                         DWORD dwAttribs = GetFileAttributesA(pszName);
  409.                         if (dwAttribs == ULONG_MAX) *pAttribs = 0; // 失败了不要打断工作，设置空属性
  410.                         else *pAttribs = (INT)(dwAttribs & (_A_RDONLY | _A_SYSTEM | _A_HIDDEN | _A_ARCH));
  411.                         CloseHandle(handle);

  413.                         // 返回一个 _open 打开的文件句柄
  414.                         return _open(pszName, _O_RDONLY | _O_BINARY);

  416.                 }

  418.                 LONG UpdateStatus(UINT nTypes, ULONG nParam1, ULONG nParam2, LPVOID pData = NULL)
  419.                 {
  420.                         // 可以使用 ParseStatus 函数分析状态后直接使用结果
  421.                         return ERROR_SUCCESS;
  422.                 }

  424.         protected:
  425.                 // 下面的这些保护函数实现系统 FCI 回调
  426.                 static LPVOID DIAMONDAPI FCI_Alloc(ULONG nSize)
  427.                 {
  428.                         return T::Alloc(nSize);
  429.                 }

  431.                 static void DIAMONDAPI FCI_Free(LPVOID lpMemory)
  432.                 {
  433.                         return T::Free(lpMemory);
  434.                 }

  436.                 static int DIAMONDAPI FCI_FilePlaced(PCCAB lpCabinet, LPSTR pszFile, LONG nFile, BOOL fContinuation, LPVOID pData)
  437.                 {
  438.                         return static_cast<T*>((CPackageImpl<T>*)pData)->FilePlaced(lpCabinet, pszFile, nFile, fContinuation);
  439.                 }

  441.                 static INT_PTR DIAMONDAPI FCI_Open(LPSTR pszFile, INT nOpenFlag, INT nMode, LPINT pError, LPVOID pData)
  442.                 {
  443.                         return static_cast<T*>((CPackageImpl<T>*)pData)->Open(pszFile, nOpenFlag, nMode, pError);
  444.                 }

  446.                 static UINT DIAMONDAPI FCI_Read(INT_PTR hFile, LPVOID lpMemory, UINT nSize, LPINT pError, LPVOID pData)
  447.                 {
  448.                         return static_cast<T*>((CPackageImpl<T>*)pData)->Read(hFile, lpMemory, nSize, pError);
  449.                 }

  451.                 static UINT DIAMONDAPI FCI_Write(INT_PTR hFile, LPVOID lpMemory, UINT nSize, LPINT pError, LPVOID pData)
  452.                 {
  453.                         return static_cast<T*>((CPackageImpl<T>*)pData)->Write(hFile, lpMemory, nSize, pError);
  454.                 }

  456.                 static INT DIAMONDAPI FCI_Close(INT_PTR hFile, LPINT pError, LPVOID pData)
  457.                 {
  458.                         return static_cast<T*>((CPackageImpl<T>*)pData)->Close(hFile, pError);
  459.                 }

  461.                 static long DIAMONDAPI FCI_Seek(INT_PTR hFile, LONG nDistance, INT nSeekType, LPINT pError, LPVOID pData)
  462.                 {
  463.                         return static_cast<T*>((CPackageImpl<T>*)pData)->Seek(hFile, nDistance, nSeekType, pError);
  464.                 }

  466.                 static int DIAMONDAPI FCI_Delete(LPSTR pszFile, LPINT pError, LPVOID pData)
  467.                 {
  468.                         return static_cast<T*>((CPackageImpl<T>*)pData)->Delete(pszFile, pError);
  469.                 }

  471.                 static BOOL DIAMONDAPI FCI_GetTempFile(LPSTR pszTempName, INT nTempName, LPVOID pData)
  472.                 {
  473.                         return static_cast<T*>((CPackageImpl<T>*)pData)->GetTempFile(pszTempName, nTempName);
  474.                 }

  476.                 static BOOL DIAMONDAPI FCI_GetNextCabinet(PCCAB pCab, ULONG nPrevCab, LPVOID pData)
  477.                 {
  478.                         CPackageImpl<T>* pThis = (CPackageImpl<T>*)(pData);
  479.                         CHK_EXP_RET(pThis->m_bOperAbort, (TRUE == FALSE));
  480.                         return static_cast<T*>(pThis)->GetNextCabinet(pCab, nPrevCab);
  481.                 }

  483.                 static INT_PTR DIAMONDAPI FCI_GetOpenInfo(LPSTR pszName, USHORT *pDate, USHORT *pTime, USHORT *pAttribs, LPINT pError, LPVOID pData)
  484.                 {
  485.                         CPackageImpl<T>* pThis = (CPackageImpl<T>*)(pData);
  486.                         CHK_EXP_RET(pThis->m_bOperAbort, (INT_PTR)(UINT_MAX));
  487.                         return static_cast<T*>(pThis)->GetOpenInfo(pszName, pDate, pTime, pAttribs, pError);
  488.                 }

  490.                 static LONG DIAMONDAPI FCI_UpdateStatus(UINT nTypes, ULONG nParam1, ULONG nParam2, LPVOID pData)
  491.                 {
  492.                         CPackageImpl<T>* pThis = (CPackageImpl<T>*)(pData);
  493.                         CHK_EXP_RET(pThis->m_bOperAbort, (LONG)(ULONG_MAX));
  494.                         return static_cast<T*>(pThis)->UpdateStatus(nTypes, nParam1, nParam2);
  495.                 }

  497.         protected:
  498.                 VOID ParseStatus(UINT nTypes, ULONG nParam1, ULONG nParam2)
  499.                 {
  500.                         m_nParam1 = nParam1;
  501.                         m_nParam2 = nParam2;
  502.                         m_nFolderPercent = 0;

  504.                         if (statusFile == nTypes)
  505.                         {
  506.                                 m_nTotalCompressSize += nParam1;
  507.                                 m_nTotalUncompressSize += nParam2;
  508.                         }
  509.                         else if (statusFolder == nTypes)
  510.                         {
  511.                                 double nPercent = 100.0 * nParam1 / nParam2;
  512.                                 m_nFolderPercent = (ULONG)(nPercent);
  513.                         }
  514.                 }

  516.         protected:
  517.                 BOOL Initialize()
  518.                 {
  519.                         m_hContext = 0;
  520.                         m_xError.fError = FALSE;
  521.                         GetTempPathA(MAX_PATH, m_szTempDir);
  522.                         m_nTotalUncompressSize = 0;
  523.                         m_nTotalCompressSize = 0;
  524.                         m_nTempCounter = 1;
  525.                         return TRUE;
  526.                 }

  528.         protected:
  529.                 HFCI    m_hContext;
  530.                 CCAB    m_xPackage;
  531.                 ERF        m_xError;

  533.                 BOOL    m_bAutoFlush;
  534.                 BOOL    m_bOperAbort;

  536.                 LONG    m_nTempCounter;
  537.                 CHAR    m_szTempDir[MAX_PATH];

  539.                 CHAR    m_szCabFileFormat[CB_MAX_CABINET_NAME];

  541.                 // 下面是状态信息，可以用来处理用户界面
  542.                 ULONG    m_nTotalUncompressSize;
  543.                 ULONG    m_nTotalCompressSize;
  544.                 ULONG    m_nParam1, m_nParam2;
  545.                 ULONG    m_nFolderPercent;
  546.         };

  548.         //==============================================================================================
  549.         // 文件打包类，附加消息通知功能
  550.         class CFilePackage : public CPackageImpl< CFilePackage >
  551.         {
  552.         public:
  553.                 CFilePackage(HWND hWnd = NULL, UINT uMsg = WM_NULL) : m_hWnd(hWnd), m_uMsg(uMsg)
  554.                 {

  556.                 }

  558.         public:
  559.                 struct S_GetNextCabinet
  560.                 {
  561.                         PCCAB pCab;
  562.                         ULONG nPrevCab;
  563.                         LPVOID pData;
  564.                 };

  566.                 struct S_GetOpenInfo
  567.                 {
  568.                         LPSTR pszName;
  569.                         USHORT *pDate;
  570.                         USHORT *pTime;
  571.                         USHORT *pAttribs;
  572.                         LPINT pError;
  573.                         LPVOID pData;
  574.                 };

  576.                 struct S_UpdateStatus
  577.                 {
  578.                         ULONG    nTypes, nParam1, nParam2;
  579.                         ULONG    nTotalUncompressSize;
  580.                         ULONG    nTotalCompressSize;
  581.                         ULONG    nFolderPercent;
  582.                 };

  584.                 enum E_MessageNotify
  585.                 {
  586.                         EM_GET_NEXT_CAIBNET = 1,
  587.                         EM_GET_OPEN_INFO = 2,
  588.                         EM_UPDATE_STATUS = 3,
  589.                 };

  591.         public:
  592.                 // 重载回调函数，提供消息通知功能
  593.                 BOOL GetNextCabinet(PCCAB pCab, ULONG nPrevCab, LPVOID pData = NULL)
  594.                 {
  595.                         S_GetNextCabinet xParam = { pCab, nPrevCab, pData };
  596.                         SendMessage(m_hWnd, m_uMsg, EM_GET_NEXT_CAIBNET, reinterpret_cast<LPARAM>(&xParam));
  597.                         return CPackageImpl<CFilePackage>::GetNextCabinet(pCab, nPrevCab, pData);
  598.                 }

  600.                 INT_PTR GetOpenInfo(LPSTR pszName, USHORT *pDate, USHORT *pTime, USHORT *pAttribs, LPINT pError, LPVOID pData = NULL)
  601.                 {
  602.                         S_GetOpenInfo xParam = { pszName, pDate, pTime, pAttribs, pError, pData };
  603.                         SendMessage(m_hWnd, m_uMsg, EM_GET_OPEN_INFO, reinterpret_cast<LPARAM>(&xParam));
  604.                         return CPackageImpl<CFilePackage>::GetOpenInfo(pszName, pDate, pTime, pAttribs, pError, pData);
  605.                 }

  607.                 LONG UpdateStatus(UINT nTypes, ULONG nParam1, ULONG nParam2, LPVOID pData = NULL)
  608.                 {
  609.                         ParseStatus(nTypes, nParam1, nParam2);
  610.                         S_UpdateStatus xParam = { nTypes, nParam1, nParam2, m_nTotalUncompressSize, m_nTotalCompressSize, m_nFolderPercent };
  611.                         SendMessage(m_hWnd, m_uMsg, EM_UPDATE_STATUS, reinterpret_cast<LPARAM>(&xParam));
  612.                         return CPackageImpl<CFilePackage>::UpdateStatus(nTypes, nParam1, nParam2);
  613.                 }

  615.         protected:
  616.                 HWND m_hWnd;
  617.                 UINT m_uMsg;
  618.         };

  620.         //==============================================================================================
  621.         template <typename T, typename DecryptT = CDecryptImpl<T> > class CExtractImpl : public DecryptT
  622.         {
  623.         public:
  624.                 CExtractImpl()
  625.                 {
  626.                         Initialize();
  627.                 }

  629.                 ~CExtractImpl()
  630.                 {
  631.                         DestroyContext();
  632.                 }

  634.         public:
  635.                 BOOL CreateContext(INT nCpuType = cpu80386)
  636.                 {
  637.                         CHK_EXP_RET(m_hContext != NULL, FALSE);
  638.                         m_hContext = FDICreate(FDI_Alloc, FDI_Free, FDI_Open, FDI_Read, FDI_Write, FDI_Close, FDI_Seek, -1, &m_xError);
  639.                         return (m_hContext != NULL);
  640.                 }

  642.                 BOOL DestroyContext()
  643.                 {
  644.                         CHK_EXP_RET(m_hContext == NULL, TRUE);
  645.                         CHK_EXP_RET(!FDIDestroy(m_hContext), FALSE);
  646.                         m_hContext = NULL;
  647.                         return TRUE;
  648.                 }

  650.                 void AbortExtract()
  651.                 {
  652.                         m_bOperAbort = TRUE;
  653.                 }

  655.                 BOOL Extract(LPCSTR lpszCabinet, LPCSTR lpszTarget = NULL)
  656.                 {
  657.                         // 检查参数
  658.                         ASSERTEXPR(m_hContext != NULL);
  659.                         CHK_EXP_RET(m_hContext == NULL, FALSE);
  660.                         CHK_EXP_RET(strlen(lpszCabinet) > MAX_PATH, FALSE);
  661.                         CHK_EXP_RET(!T::IsCabinetFileName(lpszCabinet), FALSE);

  663.                         // 分析路径
  664.                         CHAR szPath[MAX_PATH] = { "" };
  665.                         strncpy(szPath, lpszCabinet, MAX_PATH);
  666.                         LPSTR lpszName = PathFindFileNameA(szPath);

  668.                         // 复制文件名
  669.                         CHAR szName[MAX_PATH] = { "" };
  670.                         strncpy(szName, lpszName, MAX_PATH);

  672.                         // 截取路径，注意保留结束的‘\’
  673.                         if (lpszName != szPath) lpszName[0] = 0;

  675.                         // 缓存目标路径
  676.                         ZeroMemory(m_szTargetDir, MAX_PATH);
  677.                         if (!IsBadReadPtr(lpszTarget, 3))
  678.                         {
  679.                                 strcpy(m_szTargetDir, lpszTarget);
  680.                                 PathAddBackslashA(m_szTargetDir);
  681.                         }
  682.                         else
  683.                         {
  684.                                 PSTR szFileName = PathFindFileNameA(lpszCabinet);
  685.                                 strncpy(m_szTargetDir, lpszCabinet, szFileName - lpszCabinet);
  686.                                 PathAddBackslashA(m_szTargetDir);
  687.                         }

  689.                         m_bOperAbort = FALSE;
  690.                         return FDICopy(m_hContext, szName, szPath, 0, FDI_Callback, NULL, this);
  691.                 }

  693.                 BOOL IsCabinet(INT hFile, PFDICABINETINFO lpCabInfo = NULL)
  694.                 {
  695.                         CHK_EXP_RET(m_hContext == NULL, FALSE);

  697.                         FDICABINETINFO xCabinetInfo;
  698.                         lpCabInfo = lpCabInfo ? lpCabInfo : &xCabinetInfo;
  699.                         return FDIIsCabinet(m_hContext, hFile, lpCabInfo);
  700.                 }

  702.                 BOOL IsCabinet(LPSTR szFileName, PFDICABINETINFO lpCabInfo = NULL)
  703.                 {
  704.                         INT nAttr = _O_BINARY | _O_RDONLY | _O_SEQUENTIAL;
  705.                         INT hCabinetFile = FDI_Open(szFileName, nAttr, 0);
  706.                         CHK_EXP_RET(hCabinetFile == -1, FALSE);

  708.                         BOOL bCabinet = IsCabinet(hCabinetFile, lpCabInfo);
  709.                         FDI_Close(hCabinetFile);
  710.                         return bCabinet;
  711.                 }

  713.                 BOOL ExtractFile(LPCSTR szCabinet, LPCSTR szTarget = NULL)
  714.                 {
  715.                         CHK_EXP_RET(!CreateContext(cpu80386), FALSE);
  716.                         BOOL bExtract = Extract(szCabinet, szTarget);
  717.                         return DestroyContext() && bExtract;
  718.                 }

  720.         public:
  721.                 // 下面的函数是为了 UNICODE 使用而做的类型转换
  722.                 BOOL Extract(LPCWSTR lpszCabinet, LPCWSTR lpszTarget = NULL)
  723.                 {
  724.                         USES_CONVERSION_EX; ASSERTEXPR(lpszCabinet != NULL);
  725.                         return Extract(W2A_EX(lpszCabinet, 0), lpszTarget ? W2A_EX(lpszTarget, 0) : NULL);
  726.                 }

  728.                 BOOL IsCabinet(LPCWSTR szFileName, PFDICABINETINFO lpCabInfo = NULL)
  729.                 {
  730.                         USES_CONVERSION_EX; ASSERTEXPR(szFileName != NULL);
  731.                         return IsCabinet(W2A_EX(szFileName, 0), lpCabInfo);
  732.                 }

  734.                 BOOL ExtractFile(LPCWSTR szCabinet, LPCWSTR szTarget = NULL)
  735.                 {
  736.                         USES_CONVERSION_EX; ASSERTEXPR(szCabinet != NULL);
  737.                         return ExtractFile(W2A_EX(szCabinet, 0), szTarget ? W2A_EX(szTarget, 0) : NULL);
  738.                 }

  740.         public:
  741.                 //    下面四个函数用来处理解压缩时的回调信息
  742.                 INT_PTR OnCabinetInfo(PFDINOTIFICATION pNotify, LPVOID lpData = NULL)
  743.                 {
  744.                         // pNotify->psz1 : szNextCabinet
  745.                         // pNotify->psz2 : szNextDisk
  746.                         // pNotify->psz3 : szCabPath
  747.                         return ERROR_SUCCESS;
  748.                 }

  750.                 INT_PTR OnNextCabinet(PFDINOTIFICATION pNotify, LPVOID lpData = NULL)
  751.                 {
  752.                         // pNotify->psz1 : szNextCabinet
  753.                         // pNotify->psz2 : szNextDisk
  754.                         // pNotify->psz3 : szCabPath
  755.                         return ERROR_SUCCESS;
  756.                 }

  758.                 INT_PTR OnCopyFile(PFDINOTIFICATION pNotify, LPVOID lpData = NULL)
  759.                 {
  760.                         char szPath[MAX_PATH] = { "" };
  761.                         strncpy(szPath, m_szTargetDir, MAX_PATH);
  762.                         strncat(szPath, pNotify->psz1, MAX_PATH);

  764.                         // 确保目录存在
  765.                         LPSTR lpszPath = strchr(szPath, '\\');
  766.                         while (lpszPath != NULL)
  767.                         {
  768.                                 // 构筑目录名称
  769.                                 INT nLength = lpszPath - szPath;
  770.                                 CHAR szFolder[MAX_PATH] = { "" };
  771.                                 strncpy(szFolder, szPath, nLength);
  772.                                 szFolder[nLength] = 0;

  774.                                 // 创建目录，并搜索下一个目录
  775.                                 CreateDirectoryA(szFolder, NULL);
  776.                                 lpszPath = strchr(lpszPath + 1, '\\');
  777.                         }

  779.                         WORD wAttr = _O_BINARY | _O_CREAT | _O_WRONLY | _O_SEQUENTIAL;
  780.                         return FDI_Open(szPath, wAttr, _S_IREAD | _S_IWRITE);
  781.                 }

  783.                 INT_PTR OnFileCopyComplete(PFDINOTIFICATION pNotify, LPVOID lpData = NULL)
  784.                 {
  785.                         FDI_Close(pNotify->hf);

  787.                         CHAR szPath[MAX_PATH] = { "" };
  788.                         strncpy(szPath, m_szTargetDir, MAX_PATH);
  789.                         strncat(szPath, pNotify->psz1, MAX_PATH);
  790.                         SetFileAttrDate(szPath, pNotify->date, pNotify->time, pNotify->attribs);
  791.                         return TRUE; // 返回该值让系统继续处理，否则系统停止处理下一个
  792.                 }

  794.         public:
  795.                 static BOOL IsCabinetFileName(LPCSTR szCabinetFile)
  796.                 {
  797.                         return PathFileExistsA(szCabinetFile);
  798.                 }

  800.         public:
  801.                 static LPVOID Alloc(ULONG nSize)
  802.                 {
  803.                         return malloc(nSize);
  804.                 }

  806.                 static void Free(LPVOID lpMemory)
  807.                 {
  808.                         return free(lpMemory);
  809.                 }

  811.         public:
  812.                 static INT_PTR Open(LPSTR pszFile, INT nOpenFlag, INT nMode)
  813.                 {
  814.                         return _open(pszFile, nOpenFlag, nMode);
  815.                 }

  817.                 static UINT Read(INT_PTR hFile, LPVOID lpMemory, UINT nSize)
  818.                 {
  819.                         return _read(hFile, lpMemory, nSize);
  820.                 }

  822.                 static UINT Write(INT_PTR hFile, LPVOID lpMemory, UINT nSize)
  823.                 {
  824.                         return _write(hFile, lpMemory, nSize);
  825.                 }

  827.                 static LONG Seek(INT_PTR hFile, LONG nDistance, INT nSeekType)
  828.                 {
  829.                         return _lseek(hFile, nDistance, nSeekType);
  830.                 }

  832.                 static INT Close(INT_PTR hFile)
  833.                 {
  834.                         return _close(hFile);
  835.                 }

  837.         protected:
  838.                 // 下面的这些保护函数实现系统 FDI 回调
  839.                 static LPVOID DIAMONDAPI FDI_Alloc(ULONG nSize)
  840.                 {
  841.                         return T::Alloc(nSize);
  842.                 }

  844.                 static void DIAMONDAPI FDI_Free(LPVOID lpMemory)
  845.                 {
  846.                         return T::Free(lpMemory);
  847.                 }

  849.         protected:
  850.                 static INT_PTR DIAMONDAPI FDI_Open(LPSTR pszFile, INT nOpenFlag, INT nMode)
  851.                 {
  852.                         return T::Open(pszFile, nOpenFlag, nMode);
  853.                 }

  855.                 static UINT DIAMONDAPI FDI_Read(INT_PTR hFile, LPVOID lpMemory, UINT nSize)
  856.                 {
  857.                         return T::Read(hFile, lpMemory, nSize);
  858.                 }

  860.                 static UINT DIAMONDAPI FDI_Write(INT_PTR hFile, LPVOID lpMemory, UINT nSize)
  861.                 {
  862.                         return T::Write(hFile, lpMemory, nSize);
  863.                 }

  865.                 static long DIAMONDAPI FDI_Seek(INT_PTR hFile, LONG nDistance, INT nSeekType)
  866.                 {
  867.                         return T::Seek(hFile, nDistance, nSeekType);
  868.                 }

  870.                 static INT DIAMONDAPI FDI_Close(INT_PTR hFile)
  871.                 {
  872.                         return T::Close(hFile);
  873.                 }

  875.         protected:
  876.                 static INT_PTR FDI_Callback(FDINOTIFICATIONTYPE eNotifyType, PFDINOTIFICATION pNotify)
  877.                 {
  878.                         CExtractImpl<T> * pThis = (CExtractImpl<T> *)(pNotify->pv);
  879.                         CHK_EXP_RET(pThis->m_bOperAbort, (INT_PTR)(UINT_MAX));

  881.                         T* pT = static_cast<T *>(pThis);
  882.                         CHK_EXP_RET(eNotifyType == fdintCOPY_FILE, pT->OnCopyFile(pNotify));
  883.                         CHK_EXP_RET(eNotifyType == fdintCABINET_INFO, pT->OnCabinetInfo(pNotify));
  884.                         CHK_EXP_RET(eNotifyType == fdintNEXT_CABINET, pT->OnNextCabinet(pNotify));
  885.                         CHK_EXP_RET(eNotifyType == fdintCLOSE_FILE_INFO, pT->OnFileCopyComplete(pNotify));
  886.                         return ERROR_SUCCESS; // 允许不支持的通知继续进行
  887.                 }

  889.                 static BOOL SetFileAttrDate(LPCSTR lpszFileName, WORD wDate, WORD wTime, WORD wAttribs)
  890.                 {
  891.                         SetFileAttributesA(lpszFileName, wAttribs & (FILE_ATTRIBUTE_READONLY | FILE_ATTRIBUTE_HIDDEN | FILE_ATTRIBUTE_ARCHIVE));
  892.                         HANDLE hFile = CreateFileA(lpszFileName, GENERIC_READ | GENERIC_WRITE, FILE_SHARE_READ, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
  893.                         CHK_EXP_RET(hFile == INVALID_HANDLE_VALUE, FALSE);

  895.                         FILETIME ftFile = { 0 , 0 }, ftLocal = { 0 , 0 };
  896.                         CHK_EXP_RET(!DosDateTimeToFileTime(wDate, wTime, &ftFile), (CloseHandle(hFile), FALSE));
  897.                         CHK_EXP_RET(!LocalFileTimeToFileTime(&ftFile, &ftLocal), (CloseHandle(hFile), FALSE));
  898.                         SetFileTime(hFile, &ftLocal, NULL, &ftLocal);
  899.                         CloseHandle(hFile);
  900.                         return TRUE;
  901.                 }

  903.         protected:
  904.                 VOID Initialize()
  905.                 {
  906.                         m_hContext = NULL;
  907.                         m_xError.fError = FALSE;
  908.                 }

  910.         protected:
  911.                 HFDI    m_hContext;
  912.                 ERF        m_xError;

  914.                 BOOL    m_bOperAbort;
  915.                 CHAR    m_szTargetDir[MAX_PATH];    //    临时存储解压缩的目标目录
  916.         };

  918. }
复制代码


评分

1

查看全部评分

回复

使用道具 举报

返回列表 发新帖

联系我们(Contact)|手机版|萝卜头IT论坛 ( 苏ICP备15050961号-1 )

GMT+8, 2024-11-21 22:27 , Processed in 0.104081 second(s), 20 queries , Gzip On.

Powered by Discuz! X3.5

© 2001-2024 Discuz! Team.

快速回复 返回顶部 返回列表