{
 "cells": [
  {
   "cell_type": "code",
   "execution_count": 1,
   "metadata": {},
   "outputs": [
    {
     "ename": "KeyboardInterrupt",
     "evalue": "",
     "output_type": "error",
     "traceback": [
      "\u001b[1;31m---------------------------------------------------------------------------\u001b[0m",
      "\u001b[1;31mKeyboardInterrupt\u001b[0m                         Traceback (most recent call last)",
      "\u001b[1;32m<ipython-input-1-0012a02fedf2>\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[1;32m----> 1\u001b[1;33m \u001b[1;32mimport\u001b[0m \u001b[0mpandas\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0mpd\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m      2\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mpandas\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0mpd\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      3\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mnumpy\u001b[0m \u001b[1;32mas\u001b[0m \u001b[0mnp\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      4\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mrequests\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      5\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mjson\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\__init__.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m     48\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mconfig_init\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     49\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m---> 50\u001b[1;33m from pandas.core.api import (\n\u001b[0m\u001b[0;32m     51\u001b[0m     \u001b[1;31m# dtype\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     52\u001b[0m     \u001b[0mInt8Dtype\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\core\\api.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m     27\u001b[0m     \u001b[0mvalue_counts\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     28\u001b[0m )\n\u001b[1;32m---> 29\u001b[1;33m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0marrays\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mCategorical\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m     30\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0marrays\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mboolean\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mBooleanDtype\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     31\u001b[0m from pandas.core.arrays.floating import (\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\core\\arrays\\__init__.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m      4\u001b[0m     \u001b[0mExtensionScalarOpsMixin\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      5\u001b[0m )\n\u001b[1;32m----> 6\u001b[1;33m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0marrays\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mboolean\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mBooleanArray\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m      7\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0marrays\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcategorical\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mCategorical\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      8\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0marrays\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mdatetimes\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mDatetimeArray\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\core\\arrays\\boolean.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m     34\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     35\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mops\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m---> 36\u001b[1;33m from pandas.core.arrays.masked import (\n\u001b[0m\u001b[0;32m     37\u001b[0m     \u001b[0mBaseMaskedArray\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     38\u001b[0m     \u001b[0mBaseMaskedDtype\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\core\\arrays\\masked.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m     44\u001b[0m )\n\u001b[0;32m     45\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m---> 46\u001b[1;33m from pandas.core import (\n\u001b[0m\u001b[0;32m     47\u001b[0m     \u001b[0mmissing\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     48\u001b[0m     \u001b[0mnanops\u001b[0m\u001b[1;33m,\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\core\\nanops.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m     57\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mpandas\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mcore\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mconstruction\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mextract_array\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     58\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m---> 59\u001b[1;33m \u001b[0mbn\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mimport_optional_dependency\u001b[0m\u001b[1;33m(\u001b[0m\u001b[1;34m\"bottleneck\"\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0merrors\u001b[0m\u001b[1;33m=\u001b[0m\u001b[1;34m\"warn\"\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m     60\u001b[0m \u001b[0m_BOTTLENECK_INSTALLED\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mbn\u001b[0m \u001b[1;32mis\u001b[0m \u001b[1;32mnot\u001b[0m \u001b[1;32mNone\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     61\u001b[0m \u001b[0m_USE_BOTTLENECK\u001b[0m \u001b[1;33m=\u001b[0m \u001b[1;32mFalse\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\pandas\\compat\\_optional.py\u001b[0m in \u001b[0;36mimport_optional_dependency\u001b[1;34m(name, extra, errors, min_version)\u001b[0m\n\u001b[0;32m    113\u001b[0m     )\n\u001b[0;32m    114\u001b[0m     \u001b[1;32mtry\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m--> 115\u001b[1;33m         \u001b[0mmodule\u001b[0m \u001b[1;33m=\u001b[0m \u001b[0mimportlib\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mimport_module\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mname\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m    116\u001b[0m     \u001b[1;32mexcept\u001b[0m \u001b[0mImportError\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m    117\u001b[0m         \u001b[1;32mif\u001b[0m \u001b[0merrors\u001b[0m \u001b[1;33m==\u001b[0m \u001b[1;34m\"raise\"\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\__init__.py\u001b[0m in \u001b[0;36mimport_module\u001b[1;34m(name, package)\u001b[0m\n\u001b[0;32m    125\u001b[0m                 \u001b[1;32mbreak\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m    126\u001b[0m             \u001b[0mlevel\u001b[0m \u001b[1;33m+=\u001b[0m \u001b[1;36m1\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m--> 127\u001b[1;33m     \u001b[1;32mreturn\u001b[0m \u001b[0m_bootstrap\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0m_gcd_import\u001b[0m\u001b[1;33m(\u001b[0m\u001b[0mname\u001b[0m\u001b[1;33m[\u001b[0m\u001b[0mlevel\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m]\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mpackage\u001b[0m\u001b[1;33m,\u001b[0m \u001b[0mlevel\u001b[0m\u001b[1;33m)\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m    128\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m    129\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\bottleneck\\__init__.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m     30\u001b[0m     )\n\u001b[0;32m     31\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m---> 32\u001b[1;33m     \u001b[1;32mfrom\u001b[0m \u001b[1;33m.\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[0mslow\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m     33\u001b[0m \u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m     34\u001b[0m \u001b[1;32mexcept\u001b[0m \u001b[0mImportError\u001b[0m\u001b[1;33m:\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\site-packages\\bottleneck\\slow\\__init__.py\u001b[0m in \u001b[0;36m<module>\u001b[1;34m\u001b[0m\n\u001b[0;32m      3\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mbottleneck\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mslow\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mreduce\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[1;33m*\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0;32m      4\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mbottleneck\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mslow\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mnonreduce\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[1;33m*\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[1;32m----> 5\u001b[1;33m \u001b[1;32mfrom\u001b[0m \u001b[0mbottleneck\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mslow\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mnonreduce_axis\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[1;33m*\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n\u001b[0m\u001b[0;32m      6\u001b[0m \u001b[1;32mfrom\u001b[0m \u001b[0mbottleneck\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mslow\u001b[0m\u001b[1;33m.\u001b[0m\u001b[0mmove\u001b[0m \u001b[1;32mimport\u001b[0m \u001b[1;33m*\u001b[0m\u001b[1;33m\u001b[0m\u001b[1;33m\u001b[0m\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap.py\u001b[0m in \u001b[0;36m_find_and_load\u001b[1;34m(name, import_)\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap.py\u001b[0m in \u001b[0;36m_find_and_load_unlocked\u001b[1;34m(name, import_)\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap.py\u001b[0m in \u001b[0;36m_find_spec\u001b[1;34m(name, path, target)\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap_external.py\u001b[0m in \u001b[0;36mfind_spec\u001b[1;34m(cls, fullname, path, target)\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap_external.py\u001b[0m in \u001b[0;36m_get_spec\u001b[1;34m(cls, fullname, path, target)\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap_external.py\u001b[0m in \u001b[0;36mfind_spec\u001b[1;34m(self, fullname, target)\u001b[0m\n",
      "\u001b[1;32mc:\\Users\\admin\\.conda\\envs\\F6processing\\lib\\importlib\\_bootstrap_external.py\u001b[0m in \u001b[0;36m_path_stat\u001b[1;34m(path)\u001b[0m\n",
      "\u001b[1;31mKeyboardInterrupt\u001b[0m: "
     ]
    }
   ],
   "source": [
    "import pandas as pd\n",
    "import pandas as pd\n",
    "import numpy as np\n",
    "import requests\n",
    "import json\n",
    "import time\n",
    "import re\n",
    "from datetime import datetime\n",
    "from dateutil.relativedelta import relativedelta\n",
    "from pathlib import Path\n",
    "from urllib.parse import quote\n",
    "from io import BytesIO\n",
    "\n",
    "ROOT = Path('.').absolute()  # 当前工作目录\n",
    "\n",
    "def generateToken() -> str:\n",
    "    \"\"\" 生成 token \"\"\"\n",
    "\n",
    "    token_api = 'https://api.dingtalk.com/v1.0/oauth2/accessToken'\n",
    "\n",
    "    # 该信息在钉钉开放应用中\n",
    "    data = {\n",
    "        \"appKey\": \"ding5kqocon5s9oph5uq\",\n",
    "        \"appSecret\": 'HL1jgsIIfLAC0eTH0A1m4mwxUDqbgsiPeCCGGE3ocM6qJBTIW7Ivt9drxF_Z4Kb_'\n",
    "    }\n",
    "\n",
    "    res = requests.post(token_api, json=data)\n",
    "    token = res.json()['accessToken']\n",
    "\n",
    "    return token\n",
    "\n",
    "def read_processes_instances(token, formUuid, createFromTimeGMT, createToTimeGMT, page, n):\n",
    "    \"\"\" 函数功能：读取流程表单的所有数据 \"\"\"\n",
    "\n",
    "    api = f'https://api.dingtalk.com/v1.0/yida/processes/instances?pageNumber={page}&pageSize={n}'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    formData = {\n",
    "        \"appType\": \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\": \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\": \"yida_pub_account\",  # 超级管理员账号\n",
    "        \"language\": \"zh_CN\",\n",
    "        \"formUuid\": formUuid,\n",
    "        \"createFromTimeGMT\": createFromTimeGMT,\n",
    "        \"createToTimeGMT\": createToTimeGMT,\n",
    "        # \"searchFieldJson\": json.dumps(searchField), # 如果增加上这一项会要求升级宜搭存储\n",
    "        \"instanceStatus\": \"RUNNING\"\n",
    "    }\n",
    "\n",
    "    res = requests.post(api, headers=headers, json=formData)\n",
    "    return res.json()\n",
    "\n",
    "def read_instances(token, formUuid, page, n):\n",
    "    \"\"\" 函数功能：读取流程表单的所有数据 \"\"\"\n",
    "\n",
    "    api = f'https://api.dingtalk.com//v1.0/yida/forms/instances/search?pageNumber={page}&pageSize={n}'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    formData = {\n",
    "        \"appType\": \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\": \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\": \"yida_pub_account\",  # 超级管理员账号\n",
    "        \"language\": \"zh_CN\",\n",
    "        \"formUuid\": formUuid,\n",
    "        # \"searchFieldJson\": json.dumps(searchField), # 如果增加上这一项会要求升级宜搭存储\n",
    "        \"instanceStatus\": \"RUNNING\"\n",
    "    }\n",
    "\n",
    "    res = requests.post(api, headers=headers, json=formData)\n",
    "    return res.json()\n",
    "\n",
    "def timeStamp(timeNum):\n",
    "    \"\"\" 函数功能：将时间戳(毫秒) 转化为时间日期格式\"\"\"\n",
    "    timeStamp = float(timeNum/1000)\n",
    "    timeArray = time.localtime(timeStamp)\n",
    "    otherStyleTime = time.strftime(\"%Y-%m-%d %H:%M:%S\", timeArray)\n",
    "    return otherStyleTime\n",
    "\n",
    "def get_time_range_minute(n):\n",
    "    \"\"\" 获取近n分钟的时间戳(单位是毫秒)\"\"\"\n",
    "\n",
    "    def delay_time(time_str, years=0, months=0, days=0, hours=0, minutes=0, seconds=0):\n",
    "        if type(time_str) == str:\n",
    "            time_str = datetime.strptime(time_str, '%Y-%m-%d %H:%M:%S')\n",
    "        ret = time_str + relativedelta(years=years, months=months, days=days, hours=hours, minutes=minutes, seconds=seconds)\n",
    "        return ret\n",
    "\n",
    "    # 获得当前时间\n",
    "    now_time = datetime.now()\n",
    "    endTime = int(time.mktime(time.strptime(now_time.strftime('%Y/%m/%d %H:%M:%S'), '%Y/%m/%d %H:%M:%S'))) * 1000 - 1000\n",
    "    # n小时前的时间\n",
    "    ret2 = delay_time(now_time, minutes=-n)\n",
    "    startTime = int(time.mktime(time.strptime(ret2.strftime('%Y/%m/%d %H:%M:%S'), '%Y/%m/%d %H:%M:%S'))) * 1000\n",
    "\n",
    "    # print(f'时间区间:[{startTime}-{endTime}]')\n",
    "    return startTime, endTime\n",
    "\n",
    "def get_approval_records(token: str, processInstanceId: str):\n",
    "    \"\"\" 函数功能：获取流程表单的审批记录   --F6客户服务 应用    \"\"\"\n",
    "    appType = \"APP_TNVBVZ3K8G56HG03Z45Q\"\n",
    "    systemToken = \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\"\n",
    "    userId = \"yida_pub_account\"\n",
    "\n",
    "    api = f'https://api.dingtalk.com/v1.0/yida/processes/operationRecords?appType={appType}&systemToken={systemToken}&userId={userId}&language=zh_CN&processInstanceId={processInstanceId}'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    res = requests.get(api, headers=headers)\n",
    "    print('获取流程表单的审批记录')\n",
    "    return res.json()\n",
    "\n",
    "def forms_isDone(TOKEN: str, FORMID: str, CREATE_FROM, CREATE_TO,PAGES,processInstanceId,isDone_id):\n",
    "    '''\n",
    "    返回isDone_id 对应的控件内容\n",
    "    '''\n",
    "    for i in range(1, PAGES+1):\n",
    "        form_data = read_processes_instances(token=TOKEN, formUuid=FORMID, page=i, n=100)\n",
    "        for data in form_data.get('data'):\n",
    "            processInstanceId_1 = data.get('processInstanceId')\n",
    "            if processInstanceId_1 == processInstanceId:\n",
    "                isDone = data.get('data').get(isDone_id)\n",
    "    return isDone\n",
    "\n",
    "def aggree_approval(token: str, taskId: str, processInstanceId: str, formData: dict):\n",
    "    \"\"\" 函数功能：同意审批节点   --F6客户服务 应用    \"\"\"\n",
    "    api = f'https://api.dingtalk.com/v1.0/yida/tasks/execute'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    payload = {\n",
    "        \"outResult\": \"AGREE\",\n",
    "        \"appType\": \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\": \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"remark\": \"同意(接口自动)\",\n",
    "        \"formDataJson\": json.dumps(formData, cls=NpEncoder),\n",
    "        \"processInstanceId\": processInstanceId,\n",
    "        # \"userId\": \"yida_pub_account\",\n",
    "        \"userId\": \"2268275546837446\", \n",
    "        \"language\": \"zh_CN\",\n",
    "        \"taskId\": int(taskId)\n",
    "    }\n",
    "\n",
    "    res = requests.post(api, headers=headers, json=payload)\n",
    "    print('同意审批节点')\n",
    "    return res\n",
    "\n",
    "def switch(token: str, processInstanceId: str, formData: dict):\n",
    "    \"\"\" 函数说明：\n",
    "        开关 程序调用时避免 重复进行（执行间隔 小于 单次执行时间时 发送 重复处理）\n",
    "    \"\"\"\n",
    "    api = f'https://api.dingtalk.com//v1.0/yida/forms/instances'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    payload = {\n",
    "        \"appType\" : \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\" : \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\" : \"yida_pub_account\",  # 管理员\n",
    "        \"language\" :  \"zh_CN\",\n",
    "        \"useLatestVersion\" : \"false\",\n",
    "        \"formInstanceId\" : processInstanceId,\n",
    "        \"updateFormDataJson\" : json.dumps(formData, cls=NpEncoder),\n",
    "        }\n",
    "\n",
    "    res = requests.put(api, headers=headers, json=payload)\n",
    "    print('开关 程序调用时避免 重复进行（执行间隔 小于 单次执行时间时 发送 重复处理）')\n",
    "\n",
    "def update_form_staff(TOKEN: str,processInstanceId,staff_id,ModifiedField_value):\n",
    "    \"\"\" 函数功能：员工更新表单内容       \"\"\"\n",
    "    api = f'https://api.dingtalk.com//v1.0/yida/forms/instances'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": TOKEN\n",
    "    }\n",
    "    data_new = {\n",
    "        ModifiedField_value:[staff_id]\n",
    "            }\n",
    "    payload = {\n",
    "        \"appType\" : \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\" : \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\" : \"yida_pub_account\",  # 曹伟 id\n",
    "        \"language\" :  \"zh_CN\",\n",
    "        \"useLatestVersion\" : \"false\",\n",
    "        \"formInstanceId\" : processInstanceId,\n",
    "        \"updateFormDataJson\" : json.dumps(data_new, cls=NpEncoder),\n",
    "        }\n",
    "\n",
    "    res = requests.put(api, headers=headers, json=payload)\n",
    "    print('员工更新表单内容')\n",
    "    return res\n",
    "\n",
    "def get_staffID(TOKEN: str,staff_name):\n",
    "    \"\"\" 函数功能：通过员工名称获取员工id\"\"\"\n",
    "    # 读取员工对应关系：宜搭员工-ID对应表\n",
    "    TOKEN = generateToken()\n",
    "    FORMID = \"FORM-EA866E715PF9YA7ECCAGSABX91Q72PVA3WRFL6\"  # 宜搭员工-ID对应表  FORM-EA866E715PF9YA7ECCAGSABX91Q72PVA3WRFL6\n",
    "    # 读取流程表单数据\n",
    "    form_data = read_instances(token=TOKEN, formUuid=FORMID, page=1, n=100)\n",
    "    PAGES = form_data.get('totalCount')//100 + 1\n",
    "\n",
    "    ALL_DATA_staff = []\n",
    "    \"\"\"  获取全量数据  \"\"\"\n",
    "    for i in range(1, PAGES+1):\n",
    "        # form_data = read_processes_instances(token=TOKEN, formUuid=FORMID, createFromTimeGMT=CREATE_FROM, createToTimeGMT=CREATE_TO, page=i, n=100, searchField={'textField_l7if5ff9': '否'})\n",
    "        form_data = read_instances(token=TOKEN, formUuid=FORMID, page=i, n=100)\n",
    "        for data in form_data.get('data'):\n",
    "            ALL_DATA_staff.append(data)\n",
    "    res_new = [v['formData']['textField_lfrw3u59'] for v in ALL_DATA_staff if v['formData']['textField_lfrw3u58']== staff_name]\n",
    "    print('通过员工名称获取员工id')\n",
    "    return res_new\n",
    "\n",
    "def get_type(TOKEN: str,ModifiedField_value,Form_id):\n",
    "    \"\"\" 函数功能：通过唯一标识获取控件类型\"\"\"\n",
    "    api = f'https://api.dingtalk.com/v1.0/yida/forms/formFields?appType=APP_TNVBVZ3K8G56HG03Z45Q&systemToken=CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1&formUuid='+Form_id+'&userId=yida_pub_account'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": TOKEN\n",
    "    }\n",
    "\n",
    "\n",
    "    res = requests.get(api, headers=headers)\n",
    "    cnew = res.json().get('result')\n",
    "    componentName = [i.get('componentName') for i in cnew if i.get('fieldId')== ModifiedField_value ]\n",
    "    print('通过唯一标识获取控件类型')\n",
    "    return componentName\n",
    "\n",
    "def update_text(TOKEN: str, processInstanceId, formData):\n",
    "    \"\"\" 函数说明：更新单行文本控件内容\n",
    "    \"\"\"\n",
    "    api = f'https://api.dingtalk.com//v1.0/yida/forms/instances'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": TOKEN\n",
    "    }\n",
    "    payload = {\n",
    "        \"appType\" : \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\" : \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\" : \"yida_pub_account\",  # 管理员\n",
    "        \"language\" :  \"zh_CN\",\n",
    "        \"useLatestVersion\" : \"false\",\n",
    "        \"formInstanceId\" : processInstanceId,\n",
    "        \"updateFormDataJson\" : json.dumps(formData, cls=NpEncoder),\n",
    "        }\n",
    "\n",
    "    res = requests.put(api, headers=headers, json=payload)\n",
    "    print('更新单行文本控件内容')\n",
    "    return res\n",
    "def read_instances_V2(token, formUuid, createFromTimeGMT, createToTimeGMT, page, n):\n",
    "    \"\"\" 函数功能：读取流程表单的所有数据 \"\"\"\n",
    "\n",
    "    api = f'https://api.dingtalk.com//v1.0/yida/forms/instances/search'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    formData = {\n",
    "        \"appType\": \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\": \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\": \"yida_pub_account\",  # 超级管理员账号\n",
    "        \"language\": \"zh_CN\",\n",
    "        \"formUuid\": formUuid,\n",
    "        'pageNumber':page,\n",
    "        'pageSize':n,\n",
    "        # \"searchFieldJson\": json.dumps(searchField), # 如果增加上这一项会要求升级宜搭存储\n",
    "        \"instanceStatus\": \"RUNNING\"\n",
    "    }\n",
    "\n",
    "    res = requests.post(api, headers=headers, json=formData)\n",
    "    return res.json()\n",
    "\n",
    "def pass_on(TOKEN: str,taskId, processInstanceId, staffid):\n",
    "    \"\"\" 函数功能：转交审批节点   \"\"\"\n",
    "    api = f'https://api.dingtalk.com//v1.0/yida/tasks/redirect'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": TOKEN\n",
    "    }\n",
    "    payload = {\n",
    "        \"processInstanceId\" : processInstanceId,\n",
    "        \"byManager\" : \"y\",\n",
    "        \"appType\" : \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\" : \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"language\": \"zh_CN\",\n",
    "        \"remark\" : \"转交(接口自动)\",\n",
    "        \"nowActionExecutorId\" : staffid,\n",
    "        \"userId\" : \"2268275546837446\",\n",
    "        \"taskId\" : int(taskId)\n",
    "    }\n",
    "\n",
    "    res = requests.post(api, headers=headers, json=payload)\n",
    "    print('转交审批节点')\n",
    "    return res\n",
    "\n",
    "def read_instances_new(token, formUuid, createFromTimeGMT, createToTimeGMT, page, n):\n",
    "    \"\"\" 函数功能：读取流程表单的所有数据 \"\"\"\n",
    "\n",
    "    api = f'https://api.dingtalk.com/v1.0/yida/forms/instances/search'\n",
    "\n",
    "    headers = {\n",
    "        \"Content-Type\": \"application/json\",\n",
    "        \"x-acs-dingtalk-access-token\": token\n",
    "    }\n",
    "\n",
    "    formData = {\n",
    "        \"appType\": \"APP_TNVBVZ3K8G56HG03Z45Q\",\n",
    "        \"systemToken\": \"CH7669818R0WN18TYTYJ42PE6GY22WZN0BYWKD1\",\n",
    "        \"userId\": \"yida_pub_account\",  # 超级管理员账号\n",
    "        \"language\": \"zh_CN\",\n",
    "        \"formUuid\": formUuid,\n",
    "        # \"searchFieldJson\": json.dumps(searchField), # 如果增加上这一项会要求升级宜搭存储\n",
    "        'currentPage':page,\n",
    "        'pageSize':n\n",
    "    }\n",
    "\n",
    "    res = requests.post(api, headers=headers, json=formData)\n",
    "    return res.json()\n",
    "\n",
    "class NpEncoder(json.JSONEncoder):\n",
    "    def default(self, obj):\n",
    "        if isinstance(obj, np.integer):\n",
    "            return int(obj)\n",
    "        elif isinstance(obj, np.floating):\n",
    "            return float(obj)\n",
    "        elif isinstance(obj, np.ndarray):\n",
    "            return obj.tolist()\n",
    "        else:\n",
    "            return super(NpEncoder, self).default(obj)\n",
    "\n",
    "\"\"\"  处理流程开始   \"\"\"\n",
    "TOKEN = generateToken()\n",
    "FORMID2 = \"FORM-W46663A1DNH4EKZI6WCEZCQNPZXQ2ZZB92I9LZ\"  \n",
    "# 10分钟时间间隔\n",
    "CREATE_FROM, CREATE_TO = [timeStamp(t) for t in get_time_range_minute(100000)]\n",
    "\n",
    "# 读取修改明细表全量数据\n",
    "form_data = read_instances_V2(token=TOKEN, formUuid=FORMID2, createFromTimeGMT=CREATE_FROM, createToTimeGMT=CREATE_TO, page=1, n=100)\n",
    "PAGES = form_data.get('totalCount')//100 + 1\n",
    "\n",
    "LIST_DATA = []\n",
    "\"\"\"  获取全量数据  \"\"\"\n",
    "for i in range(1, PAGES+1):\n",
    "    # form_data = read_processes_instances(token=TOKEN, formUuid=FORMID, createFromTimeGMT=CREATE_FROM, createToTimeGMT=CREATE_TO, page=i, n=100, searchField={'textField_l7if5ff9': '否'})\n",
    "    form_data = read_instances_new(token=TOKEN, formUuid=FORMID2, createFromTimeGMT=CREATE_FROM, createToTimeGMT=CREATE_TO, page=i, n=100)\n",
    "    for v in range(0,len(form_data.get('data'))):\n",
    "        formData = {'textField_lg1li3ez':'1'}\n",
    "        formInstanceId = form_data.get('data')[v]['formInstanceId']\n",
    "        update_text(TOKEN, formInstanceId, formData)"
   ]
  }
 ],
 "metadata": {
  "kernelspec": {
   "display_name": "F6processing",
   "language": "python",
   "name": "python3"
  },
  "language_info": {
   "codemirror_mode": {
    "name": "ipython",
    "version": 3
   },
   "file_extension": ".py",
   "mimetype": "text/x-python",
   "name": "python",
   "nbconvert_exporter": "python",
   "pygments_lexer": "ipython3",
   "version": "3.9.4"
  },
  "orig_nbformat": 4
 },
 "nbformat": 4,
 "nbformat_minor": 2
}