diff --git a/ecs/jskult-batch-daily/Pipfile b/ecs/jskult-batch-daily/Pipfile
index a5d5dddd..1e6adf91 100644
--- a/ecs/jskult-batch-daily/Pipfile
+++ b/ecs/jskult-batch-daily/Pipfile
@@ -18,6 +18,7 @@ autopep8 = "*"
 flake8 = "*"
 pytest = "*"
 pytest-cov = "*"
+boto3 = "*"
 
 [requires]
 python_version = "3.9"
diff --git a/ecs/jskult-batch-daily/Pipfile.lock b/ecs/jskult-batch-daily/Pipfile.lock
index 519c60a0..10b5f555 100644
--- a/ecs/jskult-batch-daily/Pipfile.lock
+++ b/ecs/jskult-batch-daily/Pipfile.lock
@@ -1,7 +1,7 @@
 {
     "_meta": {
         "hash": {
-            "sha256": "9bce8f43bcad5d6ae8e5a558b8ade00a83f6e1671993e91b0a883fffa6b95df9"
+            "sha256": "df8b09869c6ad0daff24cf808bac56f528d8ae5835fe70a50d58c2bed724e717"
         },
         "pipfile-spec": 6,
         "requires": {
@@ -18,19 +18,19 @@
     "default": {
         "boto3": {
             "hashes": [
-                "sha256:816a198a6cc4f283af6b21439d85be6dbe4b73c2232dd906c6bafb4fece28d19",
-                "sha256:9de90a2c0b853f84436b032b28947fc8a765dc462573a8d543b13f16c6579b40"
+                "sha256:2da4a4caa789312ae73d29be9d3e79ce3328e3aaf7e9de0da6f243455ad3aae6",
+                "sha256:a49b47621c71adfa952127222809ae50867ae4fd249bb932eb1a98519baefa40"
             ],
             "index": "pypi",
-            "version": "==1.26.107"
+            "version": "==1.26.134"
         },
         "botocore": {
             "hashes": [
-                "sha256:ee1e43e6cd0864cc6811ba3f05123647612ee3f07a286a4c94f5885aa86d6922",
-                "sha256:f63942b4b7248c0b3d6ecbc2852cf0787c23ace2a91a012f7ee0b3ae3eb08f4f"
+                "sha256:0e907b0cab771ab7c9e25efd6b6bc0041ec1b17eb0bab316fd012ef2f8fd99ba",
+                "sha256:8a070ee14a430bd3c9cd16fd142e5c2900749060490698b2b981d6d9dadf5f1f"
             ],
             "markers": "python_version >= '3.7'",
-            "version": "==1.29.107"
+            "version": "==1.29.134"
         },
         "greenlet": {
             "hashes": [
@@ -124,11 +124,11 @@
         },
         "s3transfer": {
             "hashes": [
-                "sha256:06176b74f3a15f61f1b4f25a1fc29a4429040b7647133a463da8fa5bd28d5ecd",
-                "sha256:2ed07d3866f523cc561bf4a00fc5535827981b117dd7876f036b0c1aca42c947"
+                "sha256:3c0da2d074bf35d6870ef157158641178a4204a6e689e82546083e31e0311346",
+                "sha256:640bb492711f4c0c0905e1f62b6aaeb771881935ad27884852411f8e9cacbca9"
             ],
             "markers": "python_version >= '3.7'",
-            "version": "==0.6.0"
+            "version": "==0.6.1"
         },
         "six": {
             "hashes": [
@@ -140,50 +140,50 @@
         },
         "sqlalchemy": {
             "hashes": [
-                "sha256:07950fc82f844a2de67ddb4e535f29b65652b4d95e8b847823ce66a6d540a41d",
-                "sha256:0a865b5ec4ba24f57c33b633b728e43fde77b968911a6046443f581b25d29dd9",
-                "sha256:0b49f1f71d7a44329a43d3edd38cc5ee4c058dfef4487498393d16172007954b",
-                "sha256:13f984a190d249769a050634b248aef8991acc035e849d02b634ea006c028fa8",
-                "sha256:1b69666e25cc03c602d9d3d460e1281810109e6546739187044fc256c67941ef",
-                "sha256:1d06e119cf79a3d80ab069f064a07152eb9ba541d084bdaee728d8a6f03fd03d",
-                "sha256:246712af9fc761d6c13f4f065470982e175d902e77aa4218c9cb9fc9ff565a0c",
-                "sha256:34eb96c1de91d8f31e988302243357bef3f7785e1b728c7d4b98bd0c117dafeb",
-                "sha256:4c3020afb144572c7bfcba9d7cce57ad42bff6e6115dffcfe2d4ae6d444a214f",
-                "sha256:4f759eccb66e6d495fb622eb7f4ac146ae674d829942ec18b7f5a35ddf029597",
-                "sha256:68ed381bc340b4a3d373dbfec1a8b971f6350139590c4ca3cb722fdb50035777",
-                "sha256:6b72dccc5864ea95c93e0a9c4e397708917fb450f96737b4a8395d009f90b868",
-                "sha256:6e84ab63d25d8564d7a8c05dc080659931a459ee27f6ed1cf4c91f292d184038",
-                "sha256:734805708632e3965c2c40081f9a59263c29ffa27cba9b02d4d92dfd57ba869f",
-                "sha256:78612edf4ba50d407d0eb3a64e9ec76e6efc2b5d9a5c63415d53e540266a230a",
-                "sha256:7e472e9627882f2d75b87ff91c5a2bc45b31a226efc7cc0a054a94fffef85862",
-                "sha256:865392a50a721445156809c1a6d6ab6437be70c1c2599f591a8849ed95d3c693",
-                "sha256:8d118e233f416d713aac715e2c1101e17f91e696ff315fc9efbc75b70d11e740",
-                "sha256:8d3ece5960b3e821e43a4927cc851b6e84a431976d3ffe02aadb96519044807e",
-                "sha256:93c78d42c14aa9a9e0866eacd5b48df40a50d0e2790ee377af7910d224afddcf",
-                "sha256:95719215e3ec7337b9f57c3c2eda0e6a7619be194a5166c07c1e599f6afc20fa",
-                "sha256:9838bd247ee42eb74193d865e48dd62eb50e45e3fdceb0fdef3351133ee53dcf",
-                "sha256:aa5c270ece17c0c0e0a38f2530c16b20ea05d8b794e46c79171a86b93b758891",
-                "sha256:ac6a0311fb21a99855953f84c43fcff4bdca27a2ffcc4f4d806b26b54b5cddc9",
-                "sha256:ad5363a1c65fde7b7466769d4261126d07d872fc2e816487ae6cec93da604b6b",
-                "sha256:b3e5864eba71a3718236a120547e52c8da2ccb57cc96cecd0480106a0c799c92",
-                "sha256:bbda1da8d541904ba262825a833c9f619e93cb3fd1156be0a5e43cd54d588dcd",
-                "sha256:c6e27189ff9aebfb2c02fd252c629ea58657e7a5ff1a321b7fc9c2bf6dc0b5f3",
-                "sha256:c8239ce63a90007bce479adf5460d48c1adae4b933d8e39a4eafecfc084e503c",
-                "sha256:d209594e68bec103ad5243ecac1b40bf5770c9ebf482df7abf175748a34f4853",
-                "sha256:d5327f54a9c39e7871fc532639616f3777304364a0bb9b89d6033ad34ef6c5f8",
-                "sha256:db4bd1c4792da753f914ff0b688086b9a8fd78bb9bc5ae8b6d2e65f176b81eb9",
-                "sha256:e4780be0f19e5894c17f75fc8de2fe1ae233ab37827125239ceb593c6f6bd1e2",
-                "sha256:e4a019f723b6c1e6b3781be00fb9e0844bc6156f9951c836ff60787cc3938d76",
-                "sha256:e62c4e762d6fd2901692a093f208a6a6575b930e9458ad58c2a7f080dd6132da",
-                "sha256:e730603cae5747bc6d6dece98b45a57d647ed553c8d5ecef602697b1c1501cf2",
-                "sha256:ebc4eeb1737a5a9bdb0c24f4c982319fa6edd23cdee27180978c29cbb026f2bd",
-                "sha256:ee2946042cc7851842d7a086a92b9b7b494cbe8c3e7e4627e27bc912d3a7655e",
-                "sha256:f005245e1cb9b8ca53df73ee85e029ac43155e062405015e49ec6187a2e3fb44",
-                "sha256:f49c5d3c070a72ecb96df703966c9678dda0d4cb2e2736f88d15f5e1203b4159",
-                "sha256:f61ab84956dc628c8dfe9d105b6aec38afb96adae3e5e7da6085b583ff6ea789"
+                "sha256:0aa2cbde85a6eab9263ab480f19e8882d022d30ebcdc14d69e6a8d7c07b0a871",
+                "sha256:0d6979c9707f8b82366ba34b38b5a6fe32f75766b2e901f9820e271e95384070",
+                "sha256:0eb14a386a5b610305bec6639b35540b47f408b0a59f75999199aed5b3d40079",
+                "sha256:2424a84f131901fbb20a99844d47b38b517174c6e964c8efb15ea6bb9ced8c2b",
+                "sha256:2ad9688debf1f0ae9c6e0706a4e2d33b1a01281317cee9bd1d7eef8020c5baac",
+                "sha256:2f0a355264af0952570f18457102984e1f79510f856e5e0ae652e63316d1ca23",
+                "sha256:31f72bb300eed7bfdb373c7c046121d84fa0ae6f383089db9505ff553ac27cef",
+                "sha256:375b7ba88f261dbd79d044f20cbcd919d88befb63f26af9d084614f10cdf97a6",
+                "sha256:37de4010f53f452e94e5ed6684480432cfe6a7a8914307ef819cd028b05b98d5",
+                "sha256:49c138856035cb97f0053e5e57ba90ec936b28a0b8b0020d44965c7b0c0bf03a",
+                "sha256:4f9832815257969b3ca9bf0501351e4c02c8d60cbd3ec9f9070d5b0f8852900e",
+                "sha256:566a0ac347cf4632f551e7b28bbd0d215af82e6ffaa2556f565a3b6b51dc3f81",
+                "sha256:6777673d346071451bf7cccf8d0499024f1bd6a835fc90b4fe7af50373d92ce6",
+                "sha256:72746ec17a7d9c5acf2c57a6e6190ceba3dad7127cd85bb17f24e90acc0e8e3f",
+                "sha256:755f653d693f9b8f4286d987aec0d4279821bf8d179a9de8e8a5c685e77e57d6",
+                "sha256:7612a7366a0855a04430363fb4ab392dc6818aaece0b2e325ff30ee77af9b21f",
+                "sha256:7ad24c85f2a1caf0cd1ae8c2fdb668777a51a02246d9039420f94bd7dbfd37ed",
+                "sha256:881cc388dded44ae6e17a1666364b98bd76bcdc71b869014ae725f06ba298e0e",
+                "sha256:8d97b37b4e60073c38bcf94e289e3be09ef9be870de88d163f16e08f2b9ded1a",
+                "sha256:9119795d2405eb23bf7e6707e228fe38124df029494c1b3576459aa3202ea432",
+                "sha256:9136d596111c742d061c0f99bab95c5370016c4101a32e72c2b634ad5e0757e6",
+                "sha256:9ad883ac4f5225999747f0849643c4d0ec809d9ffe0ddc81a81dd3e68d0af463",
+                "sha256:a25b4c4fdd633501233924f873e6f6cd8970732859ecfe4ecfb60635881f70be",
+                "sha256:a30e4db983faa5145e00ef6eaf894a2d503b3221dbf40a595f3011930d3d0bac",
+                "sha256:a5e9e78332a5d841422b88b8c490dfd7f761e64b3430249b66c05d02f72ceab0",
+                "sha256:b4e08e3831671008888bad5d160d757ef35ce34dbb73b78c3998d16aa1334c97",
+                "sha256:bf1aae95e80acea02a0a622e1c12d3fefc52ffd0fe7bda70a30d070373fbb6c3",
+                "sha256:c61b89803a87a3b2a394089a7dadb79a6c64c89f2e8930cc187fec43b319f8d2",
+                "sha256:cdf80359b641185ae7e580afb9f88cf560298f309a38182972091165bfe1225d",
+                "sha256:d93ebbff3dcf05274843ad8cf650b48ee634626e752c5d73614e5ec9df45f0ce",
+                "sha256:db24d2738add6db19d66ca820479d2f8f96d3f5a13c223f27fa28dd2f268a4bd",
+                "sha256:e0d20f27edfd6f35b388da2bdcd7769e4ffa374fef8994980ced26eb287e033a",
+                "sha256:e2f3b5236079bc3e318a92bab2cc3f669cc32127075ab03ff61cacbae1c392b8",
+                "sha256:e481e54db8cec1457ee7c05f6d2329e3298a304a70d3b5e2e82e77170850b385",
+                "sha256:e5e5dc300a0ca8755ada1569f5caccfcdca28607dfb98b86a54996b288a8ebd3",
+                "sha256:ec2f525273528425ed2f51861b7b88955160cb95dddb17af0914077040aff4a5",
+                "sha256:f234ba3bb339ad17803009c8251f5ee65dcf283a380817fe486823b08b26383d",
+                "sha256:f463598f9e51ccc04f0fe08500f9a0c3251a7086765350be418598b753b5561d",
+                "sha256:f717944aee40e9f48776cf85b523bb376aa2d9255a268d6d643c57ab387e7264",
+                "sha256:fd0febae872a4042da44e972c070f0fd49a85a0a7727ab6b85425f74348be14e",
+                "sha256:fec56c7d1b6a22c8f01557de3975d962ee40270b81b60d1cfdadf2a105d10e84"
             ],
             "index": "pypi",
-            "version": "==2.0.9"
+            "version": "==2.0.13"
         },
         "tenacity": {
             "hashes": [
@@ -211,14 +211,6 @@
         }
     },
     "develop": {
-        "attrs": {
-            "hashes": [
-                "sha256:29e95c7f6778868dbd49170f98f8818f78f3dc5e0e37c0b1f474e3561b240836",
-                "sha256:c9227bfc2f01993c03f68db37d1d15c9690188323c067c641f1a35ca58185f99"
-            ],
-            "markers": "python_version >= '3.6'",
-            "version": "==22.2.0"
-        },
         "autopep8": {
             "hashes": [
                 "sha256:86e9303b5e5c8160872b2f5ef611161b2893e9bfe8ccc7e2f76385947d57a2f1",
@@ -227,65 +219,89 @@
             "index": "pypi",
             "version": "==2.0.2"
         },
+        "boto3": {
+            "hashes": [
+                "sha256:2da4a4caa789312ae73d29be9d3e79ce3328e3aaf7e9de0da6f243455ad3aae6",
+                "sha256:a49b47621c71adfa952127222809ae50867ae4fd249bb932eb1a98519baefa40"
+            ],
+            "index": "pypi",
+            "version": "==1.26.134"
+        },
+        "botocore": {
+            "hashes": [
+                "sha256:0e907b0cab771ab7c9e25efd6b6bc0041ec1b17eb0bab316fd012ef2f8fd99ba",
+                "sha256:8a070ee14a430bd3c9cd16fd142e5c2900749060490698b2b981d6d9dadf5f1f"
+            ],
+            "markers": "python_version >= '3.7'",
+            "version": "==1.29.134"
+        },
+        "colorama": {
+            "hashes": [
+                "sha256:08695f5cb7ed6e0531a20572697297273c47b8cae5a63ffc6d6ed5c201be6e44",
+                "sha256:4f1d9991f5acc0ca119f9d443620b77f9d6b33703e51011c16baf57afb285fc6"
+            ],
+            "markers": "sys_platform == 'win32'",
+            "version": "==0.4.6"
+        },
         "coverage": {
             "extras": [
                 "toml"
             ],
             "hashes": [
-                "sha256:006ed5582e9cbc8115d2e22d6d2144a0725db542f654d9d4fda86793832f873d",
-                "sha256:046936ab032a2810dcaafd39cc4ef6dd295df1a7cbead08fe996d4765fca9fe4",
-                "sha256:0484d9dd1e6f481b24070c87561c8d7151bdd8b044c93ac99faafd01f695c78e",
-                "sha256:0ce383d5f56d0729d2dd40e53fe3afeb8f2237244b0975e1427bfb2cf0d32bab",
-                "sha256:186e0fc9cf497365036d51d4d2ab76113fb74f729bd25da0975daab2e107fd90",
-                "sha256:2199988e0bc8325d941b209f4fd1c6fa007024b1442c5576f1a32ca2e48941e6",
-                "sha256:299bc75cb2a41e6741b5e470b8c9fb78d931edbd0cd009c58e5c84de57c06731",
-                "sha256:3668291b50b69a0c1ef9f462c7df2c235da3c4073f49543b01e7eb1dee7dd540",
-                "sha256:36dd42da34fe94ed98c39887b86db9d06777b1c8f860520e21126a75507024f2",
-                "sha256:38004671848b5745bb05d4d621526fca30cee164db42a1f185615f39dc997292",
-                "sha256:387fb46cb8e53ba7304d80aadca5dca84a2fbf6fe3faf6951d8cf2d46485d1e5",
-                "sha256:3eb55b7b26389dd4f8ae911ba9bc8c027411163839dea4c8b8be54c4ee9ae10b",
-                "sha256:420f94a35e3e00a2b43ad5740f935358e24478354ce41c99407cddd283be00d2",
-                "sha256:4ac0f522c3b6109c4b764ffec71bf04ebc0523e926ca7cbe6c5ac88f84faced0",
-                "sha256:4c752d5264053a7cf2fe81c9e14f8a4fb261370a7bb344c2a011836a96fb3f57",
-                "sha256:4f01911c010122f49a3e9bdc730eccc66f9b72bd410a3a9d3cb8448bb50d65d3",
-                "sha256:4f68ee32d7c4164f1e2c8797535a6d0a3733355f5861e0f667e37df2d4b07140",
-                "sha256:4fa54fb483decc45f94011898727802309a109d89446a3c76387d016057d2c84",
-                "sha256:507e4720791977934bba016101579b8c500fb21c5fa3cd4cf256477331ddd988",
-                "sha256:53d0fd4c17175aded9c633e319360d41a1f3c6e352ba94edcb0fa5167e2bad67",
-                "sha256:55272f33da9a5d7cccd3774aeca7a01e500a614eaea2a77091e9be000ecd401d",
-                "sha256:5764e1f7471cb8f64b8cda0554f3d4c4085ae4b417bfeab236799863703e5de2",
-                "sha256:57b77b9099f172804e695a40ebaa374f79e4fb8b92f3e167f66facbf92e8e7f5",
-                "sha256:5afdad4cc4cc199fdf3e18088812edcf8f4c5a3c8e6cb69127513ad4cb7471a9",
-                "sha256:5cc0783844c84af2522e3a99b9b761a979a3ef10fb87fc4048d1ee174e18a7d8",
-                "sha256:5e1df45c23d4230e3d56d04414f9057eba501f78db60d4eeecfcb940501b08fd",
-                "sha256:6146910231ece63facfc5984234ad1b06a36cecc9fd0c028e59ac7c9b18c38c6",
-                "sha256:797aad79e7b6182cb49c08cc5d2f7aa7b2128133b0926060d0a8889ac43843be",
-                "sha256:7c20b731211261dc9739bbe080c579a1835b0c2d9b274e5fcd903c3a7821cf88",
-                "sha256:817295f06eacdc8623dc4df7d8b49cea65925030d4e1e2a7c7218380c0072c25",
-                "sha256:81f63e0fb74effd5be736cfe07d710307cc0a3ccb8f4741f7f053c057615a137",
-                "sha256:872d6ce1f5be73f05bea4df498c140b9e7ee5418bfa2cc8204e7f9b817caa968",
-                "sha256:8c99cb7c26a3039a8a4ee3ca1efdde471e61b4837108847fb7d5be7789ed8fd9",
-                "sha256:8dbe2647bf58d2c5a6c5bcc685f23b5f371909a5624e9f5cd51436d6a9f6c6ef",
-                "sha256:8efb48fa743d1c1a65ee8787b5b552681610f06c40a40b7ef94a5b517d885c54",
-                "sha256:92ebc1619650409da324d001b3a36f14f63644c7f0a588e331f3b0f67491f512",
-                "sha256:9d22e94e6dc86de981b1b684b342bec5e331401599ce652900ec59db52940005",
-                "sha256:ba279aae162b20444881fc3ed4e4f934c1cf8620f3dab3b531480cf602c76b7f",
-                "sha256:bc4803779f0e4b06a2361f666e76f5c2e3715e8e379889d02251ec911befd149",
-                "sha256:bfe7085783cda55e53510482fa7b5efc761fad1abe4d653b32710eb548ebdd2d",
-                "sha256:c448b5c9e3df5448a362208b8d4b9ed85305528313fca1b479f14f9fe0d873b8",
-                "sha256:c90e73bdecb7b0d1cea65a08cb41e9d672ac6d7995603d6465ed4914b98b9ad7",
-                "sha256:d2b96123a453a2d7f3995ddb9f28d01fd112319a7a4d5ca99796a7ff43f02af5",
-                "sha256:d52f0a114b6a58305b11a5cdecd42b2e7f1ec77eb20e2b33969d702feafdd016",
-                "sha256:d530191aa9c66ab4f190be8ac8cc7cfd8f4f3217da379606f3dd4e3d83feba69",
-                "sha256:d683d230b5774816e7d784d7ed8444f2a40e7a450e5720d58af593cb0b94a212",
-                "sha256:db45eec1dfccdadb179b0f9ca616872c6f700d23945ecc8f21bb105d74b1c5fc",
-                "sha256:db8c2c5ace167fd25ab5dd732714c51d4633f58bac21fb0ff63b0349f62755a8",
-                "sha256:e2926b8abedf750c2ecf5035c07515770944acf02e1c46ab08f6348d24c5f94d",
-                "sha256:e627dee428a176ffb13697a2c4318d3f60b2ccdde3acdc9b3f304206ec130ccd",
-                "sha256:efe1c0adad110bf0ad7fb59f833880e489a61e39d699d37249bdf42f80590169"
+                "sha256:0342a28617e63ad15d96dca0f7ae9479a37b7d8a295f749c14f3436ea59fdcb3",
+                "sha256:066b44897c493e0dcbc9e6a6d9f8bbb6607ef82367cf6810d387c09f0cd4fe9a",
+                "sha256:10b15394c13544fce02382360cab54e51a9e0fd1bd61ae9ce012c0d1e103c813",
+                "sha256:12580845917b1e59f8a1c2ffa6af6d0908cb39220f3019e36c110c943dc875b0",
+                "sha256:156192e5fd3dbbcb11cd777cc469cf010a294f4c736a2b2c891c77618cb1379a",
+                "sha256:1637253b11a18f453e34013c665d8bf15904c9e3c44fbda34c643fbdc9d452cd",
+                "sha256:292300f76440651529b8ceec283a9370532f4ecba9ad67d120617021bb5ef139",
+                "sha256:30dcaf05adfa69c2a7b9f7dfd9f60bc8e36b282d7ed25c308ef9e114de7fc23b",
+                "sha256:338aa9d9883aaaad53695cb14ccdeb36d4060485bb9388446330bef9c361c252",
+                "sha256:373ea34dca98f2fdb3e5cb33d83b6d801007a8074f992b80311fc589d3e6b790",
+                "sha256:38c0a497a000d50491055805313ed83ddba069353d102ece8aef5d11b5faf045",
+                "sha256:40cc0f91c6cde033da493227797be2826cbf8f388eaa36a0271a97a332bfd7ce",
+                "sha256:4436cc9ba5414c2c998eaedee5343f49c02ca93b21769c5fdfa4f9d799e84200",
+                "sha256:509ecd8334c380000d259dc66feb191dd0a93b21f2453faa75f7f9cdcefc0718",
+                "sha256:5c587f52c81211d4530fa6857884d37f514bcf9453bdeee0ff93eaaf906a5c1b",
+                "sha256:5f3671662dc4b422b15776cdca89c041a6349b4864a43aa2350b6b0b03bbcc7f",
+                "sha256:6599bf92f33ab041e36e06d25890afbdf12078aacfe1f1d08c713906e49a3fe5",
+                "sha256:6e8a95f243d01ba572341c52f89f3acb98a3b6d1d5d830efba86033dd3687ade",
+                "sha256:706ec567267c96717ab9363904d846ec009a48d5f832140b6ad08aad3791b1f5",
+                "sha256:780551e47d62095e088f251f5db428473c26db7829884323e56d9c0c3118791a",
+                "sha256:7ff8f3fb38233035028dbc93715551d81eadc110199e14bbbfa01c5c4a43f8d8",
+                "sha256:828189fcdda99aae0d6bf718ea766b2e715eabc1868670a0a07bf8404bf58c33",
+                "sha256:857abe2fa6a4973f8663e039ead8d22215d31db613ace76e4a98f52ec919068e",
+                "sha256:883123d0bbe1c136f76b56276074b0c79b5817dd4238097ffa64ac67257f4b6c",
+                "sha256:8877d9b437b35a85c18e3c6499b23674684bf690f5d96c1006a1ef61f9fdf0f3",
+                "sha256:8e575a59315a91ccd00c7757127f6b2488c2f914096077c745c2f1ba5b8c0969",
+                "sha256:97072cc90f1009386c8a5b7de9d4fc1a9f91ba5ef2146c55c1f005e7b5c5e068",
+                "sha256:9a22cbb5ede6fade0482111fa7f01115ff04039795d7092ed0db43522431b4f2",
+                "sha256:a063aad9f7b4c9f9da7b2550eae0a582ffc7623dca1c925e50c3fbde7a579771",
+                "sha256:a08c7401d0b24e8c2982f4e307124b671c6736d40d1c39e09d7a8687bddf83ed",
+                "sha256:a0b273fe6dc655b110e8dc89b8ec7f1a778d78c9fd9b4bda7c384c8906072212",
+                "sha256:a2b3b05e22a77bb0ae1a3125126a4e08535961c946b62f30985535ed40e26614",
+                "sha256:a66e055254a26c82aead7ff420d9fa8dc2da10c82679ea850d8feebf11074d88",
+                "sha256:aa387bd7489f3e1787ff82068b295bcaafbf6f79c3dad3cbc82ef88ce3f48ad3",
+                "sha256:ae453f655640157d76209f42c62c64c4d4f2c7f97256d3567e3b439bd5c9b06c",
+                "sha256:b5016e331b75310610c2cf955d9f58a9749943ed5f7b8cfc0bb89c6134ab0a84",
+                "sha256:b9a4ee55174b04f6af539218f9f8083140f61a46eabcaa4234f3c2a452c4ed11",
+                "sha256:bd3b4b8175c1db502adf209d06136c000df4d245105c8839e9d0be71c94aefe1",
+                "sha256:bebea5f5ed41f618797ce3ffb4606c64a5de92e9c3f26d26c2e0aae292f015c1",
+                "sha256:c10fbc8a64aa0f3ed136b0b086b6b577bc64d67d5581acd7cc129af52654384e",
+                "sha256:c2c41c1b1866b670573657d584de413df701f482574bad7e28214a2362cb1fd1",
+                "sha256:cf97ed82ca986e5c637ea286ba2793c85325b30f869bf64d3009ccc1a31ae3fd",
+                "sha256:d1f25ee9de21a39b3a8516f2c5feb8de248f17da7eead089c2e04aa097936b47",
+                "sha256:d2fbc2a127e857d2f8898aaabcc34c37771bf78a4d5e17d3e1f5c30cd0cbc62a",
+                "sha256:dc945064a8783b86fcce9a0a705abd7db2117d95e340df8a4333f00be5efb64c",
+                "sha256:ddc5a54edb653e9e215f75de377354e2455376f416c4378e1d43b08ec50acc31",
+                "sha256:e8834e5f17d89e05697c3c043d3e58a8b19682bf365048837383abfe39adaed5",
+                "sha256:ef9659d1cda9ce9ac9585c045aaa1e59223b143f2407db0eaee0b61a4f266fb6",
+                "sha256:f6f5cab2d7f0c12f8187a376cc6582c477d2df91d63f75341307fcdcb5d60303",
+                "sha256:f81c9b4bd8aa747d417407a7f6f0b1469a43b36a85748145e144ac4e8d303cb5",
+                "sha256:f99ef080288f09ffc687423b8d60978cf3a465d3f404a18d1a05474bd8575a47"
             ],
             "markers": "python_version >= '3.7'",
-            "version": "==7.2.2"
+            "version": "==7.2.5"
         },
         "exceptiongroup": {
             "hashes": [
@@ -311,6 +327,14 @@
             "markers": "python_version >= '3.7'",
             "version": "==2.0.0"
         },
+        "jmespath": {
+            "hashes": [
+                "sha256:02e2e4cc71b5bcab88332eebf907519190dd9e6e82107fa7f83b1003a6252980",
+                "sha256:90261b206d6defd58fdd5e85f478bf633a2901798906be2ad389150c5c60edbe"
+            ],
+            "markers": "python_version >= '3.7'",
+            "version": "==1.0.1"
+        },
         "mccabe": {
             "hashes": [
                 "sha256:348e0240c33b60bbdf4e523192ef919f28cb2c3d7d5c7794f74009290f236325",
@@ -321,11 +345,11 @@
         },
         "packaging": {
             "hashes": [
-                "sha256:714ac14496c3e68c99c29b00845f7a2b85f3bb6f1078fd9f72fd20f0570002b2",
-                "sha256:b6ad297f8907de0fa2fe1ccbd26fdaf387f5f47c7275fedf8cce89f99446cf97"
+                "sha256:994793af429502c4ea2ebf6bf664629d07c1a9fe974af92966e4b8d2df7edc61",
+                "sha256:a392980d2b6cffa644431898be54b0045151319d1e7ec34f0cfed48767dd334f"
             ],
             "markers": "python_version >= '3.7'",
-            "version": "==23.0"
+            "version": "==23.1"
         },
         "pluggy": {
             "hashes": [
@@ -353,11 +377,11 @@
         },
         "pytest": {
             "hashes": [
-                "sha256:130328f552dcfac0b1cec75c12e3f005619dc5f874f0a06e8ff7263f0ee6225e",
-                "sha256:c99ab0c73aceb050f68929bc93af19ab6db0558791c6a0715723abe9d0ade9d4"
+                "sha256:3799fa815351fea3a5e96ac7e503a96fa51cc9942c3753cda7651b93c1cfa362",
+                "sha256:434afafd78b1d78ed0addf160ad2b77a30d35d4bdf8af234fe621919d9ed15e3"
             ],
             "index": "pypi",
-            "version": "==7.2.2"
+            "version": "==7.3.1"
         },
         "pytest-cov": {
             "hashes": [
@@ -367,6 +391,30 @@
             "index": "pypi",
             "version": "==4.0.0"
         },
+        "python-dateutil": {
+            "hashes": [
+                "sha256:0123cacc1627ae19ddf3c27a5de5bd67ee4586fbdd6440d9748f8abb483d3e86",
+                "sha256:961d03dc3453ebbc59dbdea9e4e11c5651520a876d0f4db161e8674aae935da9"
+            ],
+            "markers": "python_version >= '2.7' and python_version not in '3.0, 3.1, 3.2, 3.3'",
+            "version": "==2.8.2"
+        },
+        "s3transfer": {
+            "hashes": [
+                "sha256:3c0da2d074bf35d6870ef157158641178a4204a6e689e82546083e31e0311346",
+                "sha256:640bb492711f4c0c0905e1f62b6aaeb771881935ad27884852411f8e9cacbca9"
+            ],
+            "markers": "python_version >= '3.7'",
+            "version": "==0.6.1"
+        },
+        "six": {
+            "hashes": [
+                "sha256:1e61c37477a1626458e36f7b1d82aa5c9b094fa4802892072e49de9c60c4c926",
+                "sha256:8abb2f1d86890a2dfb989f9a77cfcfd3e47c2a354b01111771326f8aa26e0254"
+            ],
+            "markers": "python_version >= '2.7' and python_version not in '3.0, 3.1, 3.2, 3.3'",
+            "version": "==1.16.0"
+        },
         "tomli": {
             "hashes": [
                 "sha256:939de3e7a6161af0c887ef91b7d41a53e7c5a1ca976325f429cb46ea9bc30ecc",
@@ -374,6 +422,14 @@
             ],
             "markers": "python_version < '3.11'",
             "version": "==2.0.1"
+        },
+        "urllib3": {
+            "hashes": [
+                "sha256:8a388717b9476f934a21484e8c8e61875ab60644d29b9b39e11e4b9dc1c6b305",
+                "sha256:aa751d169e23c7479ce47a0cb0da579e3ede798f994f5816a74e4f4500dcea42"
+            ],
+            "markers": "python_version >= '2.7' and python_version not in '3.0, 3.1, 3.2, 3.3, 3.4, 3.5'",
+            "version": "==1.26.15"
         }
     }
 }
diff --git a/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/conftest.py b/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/conftest.py
new file mode 100644
index 00000000..c341b2e8
--- /dev/null
+++ b/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/conftest.py
@@ -0,0 +1,1226 @@
+"""vjsk_file_cheak用テストフィクスチャoverride"""
+
+
+import os
+
+import boto3
+import pytest
+
+
+@pytest.fixture
+def s3_client():
+    conn = boto3.client('s3')
+    yield conn
+
+
+@pytest.fixture
+def bucket_name():
+    return os.environ["JSKULT_DATA_BUCKET"]
+
+
+@pytest.fixture
+def receive_folder():
+    return os.environ["JSKULT_DATA_FOLDER_RECV"]
+
+
+@pytest.fixture
+def init_check_received_files_ok1(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ok2(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng01(s3_client, bucket_name, receive_folder):
+    # setup
+
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng02(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng03(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng04(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng05(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng06(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng07(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng08(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng09(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng10(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng11(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng12(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng13(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng14(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
+
+
+@pytest.fixture
+def init_check_received_files_ng15(s3_client, bucket_name, receive_folder):
+    # setup
+
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/stock_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/hld_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/fcl_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/phm_price_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    s3_client.put_object(Bucket=bucket_name,
+                         Key=f'{receive_folder}/bio_slip_data_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+    # s3_client.put_object(Bucket=bucket_name,
+    #                      Key=f'{receive_folder}/lot_num_mst_00000000000000.gz', Body=b'aaaaaaaaaaaaaaa')
+
+    yield
+
+    # treadown
+
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/stock_slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/slip_data_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/org_cnv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/vop_hco_merge_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/hld_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/fcl_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mkr_org_horizon_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/tran_kbn_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_prd_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/phm_price_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/whs_customer_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/mdb_conv_mst_00000000000000.gz')
+    s3_client.delete_object(Bucket=bucket_name,
+                            Key=f'{receive_folder}/bio_slip_data_00000000000000.gz')
+    # s3_client.delete_object(Bucket=bucket_name,
+    #                         Key=f'{receive_folder}/lot_num_mst_00000000000000.gz')
diff --git a/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/test_vjsk_file_check.py b/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/test_vjsk_file_check.py
index e9f88d81..44ece095 100644
--- a/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/test_vjsk_file_check.py
+++ b/ecs/jskult-batch-daily/tests/batch/vjsk/vjsk_file_check/test_vjsk_file_check.py
@@ -1,6 +1,267 @@
-def test1():
-    pass
+import pytest
+
+from src.batch.common.batch_context import BatchContext
+from src.batch.vjsk.vjsk_importer import _check_received_files
+from src.error.exceptions import BatchOperationException
 
 
-def test2():
-    pass
+def test_check_received_files_ok1(init_check_received_files_ok1):
+    """
+    観点
+        正常系 : 卸在庫データ取込対象日
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    received_s3_files = _check_received_files()
+
+    assert received_s3_files is not None
+
+
+def test_check_received_files_ok2(init_check_received_files_ok2):
+    """
+    観点
+        正常系 : 卸在庫データ取込対象日以外
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = False
+
+    received_s3_files = _check_received_files()
+    # with pytest.raises(BatchOperationException):
+    #     received_s3_files = _check_received_files()
+
+    assert received_s3_files is not None
+
+
+def test_check_received_files_ng01(init_check_received_files_ng01):
+    """
+    観点
+        異常系 : 卸在庫データファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("卸在庫データファイルがありません") > 0
+
+
+def test_check_received_files_ng02(init_check_received_files_ng02):
+    """
+    観点
+        異常系 : 卸販売データファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("卸販売データファイルがありません") > 0
+
+
+def test_check_received_files_ng03(init_check_received_files_ng03):
+    """
+    観点
+        異常系 : 卸組織変換マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("卸組織変換マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng04(init_check_received_files_ng04):
+    """
+    観点
+        異常系 : 施設統合マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("施設統合マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng05(init_check_received_files_ng05):
+    """
+    観点
+        異常系 : 卸マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("卸マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng06(init_check_received_files_ng06):
+    """
+    観点
+        異常系 : 卸ホールディングスマスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("卸ホールディングスマスタファイルがありません") > 0
+
+
+def test_check_received_files_ng07(init_check_received_files_ng07):
+    """異常系 : 施設マスタファイルが欠落"""
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("施設マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng08(init_check_received_files_ng08):
+    """
+    観点
+        異常系 : メーカー卸組織展開表ファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("メーカー卸組織展開表ファイルがありません") > 0
+
+
+def test_check_received_files_ng09(init_check_received_files_ng09):
+    """異常系 : 取引区分マスタファイルが欠落"""
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("取引区分マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng10(init_check_received_files_ng10):
+    """
+    観点
+        異常系 : 製品マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("製品マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng11(init_check_received_files_ng11):
+    """
+    観点
+        異常系 : 製品価格マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("製品価格マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng12(init_check_received_files_ng12):
+    """
+    観点
+        異常系 : 卸得意先情報マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("卸得意先情報マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng13(init_check_received_files_ng13):
+    """
+    観点
+        異常系 : MDBコード変換マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("MDBコード変換マスタファイルがありません") > 0
+
+
+def test_check_received_files_ng14(init_check_received_files_ng14):
+    """
+    観点
+        異常系 : 生物由来データファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("生物由来データファイルがありません") > 0
+
+
+def test_check_received_files_ng15(init_check_received_files_ng15):
+    """
+    観点
+        異常系 : 製造ロット番号マスタファイルが欠落
+    期待値
+        例外が発生する
+    """
+    batch_context = BatchContext.get_instance()
+    batch_context.is_vjsk_stock_import_day = True
+
+    with pytest.raises(BatchOperationException) as e:
+        _check_received_files()
+
+    assert str(e.value).startswith("製造ロット番号マスタファイルがありません") > 0
diff --git a/ecs/jskult-batch-daily/tests/conftest.py b/ecs/jskult-batch-daily/tests/conftest.py
index a03a8638..d2afff68 100644
--- a/ecs/jskult-batch-daily/tests/conftest.py
+++ b/ecs/jskult-batch-daily/tests/conftest.py
@@ -1,11 +1 @@
 """共通テストフィクスチャ"""
-
-import pytest
-
-from src.db.database import Database
-
-
-@pytest.fixture
-def database() -> Database:
-    """データベース接続モジュールを作成"""
-    return Database.get_instance()