# Process Interface file.

import os
import sys
from sys import platform
import shutil
import glob
import time
import datetime

# Get Current Path
dir_path = os.path.dirname(os.path.realpath(__file__))

# Import VIMS .py
import default_setting
import idocin
import edi_order
import excel_order
import asnupload
import vimsftp
import vimsftpstonebranch
import vimsftpput
import tt_ran_order
import tt_ran_allocate
import lr_order
import receipt
import receiptcsv
import order
import receiptidoc
import pickidoc
import idocout
import transactionhistoryvendor
import orderpartid
import logfileappend
import logfileappendtext

def archive(file):
    file_path_archive = os.path.join(dir_path, '../vimsarchive/')

def main():
    print("Main-Start..")
    # global switches for ftp & order
    ftpFlag = "N"
    orderFlag = "Y"
    ediOrderFlag = "Y"
    as400Flag = "N"
    # get Upload Directories from company settings
    defaults = default_setting.defaultSettings()
    uploadDirs = default_setting.companySettings(defaults)

    # Get OS
    # linux
    if platform == "linux" or platform == "linux2":
        pass
    # OS X
    elif platform == "darwin":
        pass
    # Windows...
    elif platform == "win32":
        pass
    #       uploadDirs['interfacein'] = 'c:/rrfiles/input'
    #       uploadDirs['interfaceout'] = 'c:/rrfiles/output'

    #   print(uploadDirs['interfacein'])
    sys.stdout.write("\r")
    sys.stdout.write(uploadDirs['interfacein'])
    sys.stdout.flush()
# ---------------------------------------------------------------------------------------------------   
# Process Confirmed Receipts
    if (1 != 1):
# Create IDOCS & Flag Receipt Header
        receiptidoc.main()
# Read IDOCS
        for idoc in glob.glob(os.path.join(dir_path, '../vimsin/rcp*.txt')):
# split out directory & filename
            path, fileName = os.path.split(idoc)
            file_path_in_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
            file_path_out_txt = os.path.join(dir_path, '../vimsout/idoctranout.txt')
            shutil.copy(idoc, file_path_in_txt)
# Archive
            shutil.copy(idoc, os.path.join(dir_path, '../vimsarchive/idoc_'+fileName))
# Network Folder for RRMC Vims
            shpName = "SHP"+fileName[3:]
            shutil.copy(idoc, os.path.join("r:/output/"+shpName))
# Format as SAP fixed-length text
            idocout.main()
            shutil.copy(file_path_out_txt, os.path.join(dir_path, '../vimsout/'+fileName))
#            shutil.copy(file_path_out_txt, os.path.join("\\\\172.16.1.193\\share\\rrfiles\\output\\"+fileName))
# Archive
            shutil.copy(file_path_out_txt, os.path.join(dir_path, '../vimsarchive/'+fileName))
# remove processed file
            if os.path.exists(idoc):
                os.remove(idoc)     
# ---------------------------------------------------------------------------------------------------   
# Process Confirmed Picks
    if (1 != 1):
# Create IDOCS & Flag Pick Header
        pickidoc.main()
# Read IDOCS
        for idoc in glob.glob(os.path.join(dir_path, '../vimsin/pck*.txt')):
# split out directory & filename
            path, fileName = os.path.split(idoc)
            file_path_in_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
            file_path_out_txt = os.path.join(dir_path, '../vimsout/idoctranout.txt')
            shutil.copy(idoc, file_path_in_txt)
# Archive
            shutil.copy(idoc, os.path.join(dir_path, '../vimsarchive/idoc_'+fileName))
# Network Folder for RRMC Vims
            pckName = "PCK"+fileName[3:]
            shutil.copy(idoc, os.path.join("r:/output/"+pckName))
# Format as SAP fixed-length text
            idocout.main()
            shutil.copy(file_path_out_txt, os.path.join(dir_path, '../vimsout/'+fileName))
#            shutil.copy(file_path_out_txt, os.path.join("\\\\172.16.1.193\\share\\rrfiles\\output\\"+fileName))
# Archive
            shutil.copy(file_path_out_txt, os.path.join(dir_path, '../vimsarchive/'+fileName))
# remove processed file
            if os.path.exists(idoc):
                os.remove(idoc)     
# ---------------------------------------------------------------------------------------------------           
# process IDOC PCKs from upload directory
    file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
    for pck in glob.glob(uploadDirs['interfacein']+"\\xxxPCK*.txt"):
# split out directory & filename
        path, fileName = os.path.split(pck)
# Archive
        shutil.copy(pck, os.path.join(dir_path, '../vimsarchive/'+fileName))
# Create JSON Format
        shutil.copy(pck, file_path_out_txt)
        idocin.main()
# Create JSON Format
        file_path_in_json = os.path.join(dir_path, '../vimsjson/idoctranout.json')
        for idoc in glob.glob(os.path.join(dir_path, '../vimsjson/idocmsgin*.json')):
            shutil.copy(idoc, file_path_in_json)
# Create / Update Order
            order.main()
# remove processed file
            if os.path.exists(idoc):
                os.remove(idoc)
            
        if os.path.exists(pck):
            os.remove(pck)
# ---------------------------------------------------------------------------------------------------                       
# process IDOC ASNs from upload directory
    file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
    for asn in glob.glob(uploadDirs['interfacein']+"\\ASN*.txt"):
        print(asn)
# split out directory & filename
        path, fileName = os.path.split(asn)
# Archive
        shutil.copy(asn, os.path.join(dir_path, '../vimsarchive/'+fileName))
# Create JSON Format
        shutil.copy(asn, file_path_out_txt)
        idocin.main()
        # Create JSON Format
        file_path_in_json = os.path.join(dir_path, '../vimsjson/idoctranout.json')
        for idoc in glob.glob(os.path.join(dir_path, '../vimsjson/idocmsgin*.json')):
            shutil.copy(idoc, file_path_in_json)
# Create / Update Receipt
            receipt.main()
# remove processed file
            if os.path.exists(idoc):
                os.remove(idoc)
            
        receiptcsv.main()
                
        if os.path.exists(asn):
            os.remove(asn)
#       continue
# ---------------------------------------------------------------------------------------------------               
# process ASNs from upload directory
    file_path_xls = os.path.join(dir_path, '../vimsin/asn.xlsx')
    for asn in glob.glob(uploadDirs['interfacein']+"\\ASN*.xlsx"):
        print(asn)
        shutil.copy(asn, file_path_xls)
        asnupload.main()
        if os.path.exists(asn):
            os.remove(asn)
#       continue

# ---------------------------------------------------------------------------------------------------   
# Process NMUK Inteface Files   
    vimsftpstonebranch.main()
# Create JSON Format
    file_path_in_txt = os.path.join(dir_path, '../vimsin/*.*')
    file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
# loop through order*.txt files
    for in_file in glob.glob(file_path_in_txt):
# split out directory & filename
        path, fileName = os.path.split(in_file)
        if (fileName == "idoctranin.txt"):
            continue
        shutil.copy(in_file, file_path_out_txt)
# Archive
        shutil.copy(in_file, os.path.join(dir_path, '../vimsarchive/'+fileName))
# remap as JSON format
        logfileappendtext.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt','AS400 IN - '+str(in_file))
        idocin.main()
        time.sleep(2)
# remove processed file
        if os.path.exists(in_file):
            os.remove(in_file)
# Process LRO Message
    in_file = os.path.join(dir_path, '../vimsjson/LROMSGIN.json')
    if os.path.exists(in_file):
            os.remove(in_file)
    in_file = os.path.join(dir_path, '../vimsjson/lromsgin.json')
    if os.path.exists(in_file):
            os.remove(in_file)
    file_path_json = os.path.join(dir_path, '../vimsjson/LROMSGIN*.json')
    file_path_out = os.path.join(dir_path, '../vimsjson/lromsgin.json')
    for in_file in glob.glob(file_path_json):
# split out directory & filename
        path, fileName = os.path.split(in_file)
        if (in_file != file_path_out):
            try:
                shutil.copy(in_file, file_path_out)
            except:
                pass
        logfileappendtext.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt','LRO - '+str(in_file))
        lr_order.main()
        logfileappend.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt',in_file)
        if os.path.exists(in_file):
            os.remove(in_file)
# Process TTO Message
    in_file = os.path.join(dir_path, '../vimsjson/TTOMSGIN.json')
    if os.path.exists(in_file):
            os.remove(in_file)
    in_file = os.path.join(dir_path, '../vimsjson/ttomsgin.json')
    if os.path.exists(in_file):
            os.remove(in_file)
    file_path_json = os.path.join(dir_path, '../vimsjson/SUPPORDRMSGIN*.json')
    file_path_out = os.path.join(dir_path, '../vimsjson/ttomsgin.json')
    for in_file in glob.glob(file_path_json):
# split out directory & filename
        path, fileName = os.path.split(in_file)
        if (in_file != file_path_out):
            shutil.copy(in_file, file_path_out)
        tt_ran_order.main()
        logfileappend.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt',in_file)
        if os.path.exists(in_file):
            os.remove(in_file)
# populate Inventory with TT-RAN
    tt_ran_allocate.main()

    
# Process NMUK AS400 Inteface Files 
    if (as400Flag == "Y"):
        vimsftp.main()
# Create JSON Format
        file_path_in_txt = os.path.join(dir_path, '../vimsin/*.*')
        file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
# loop through order*.txt files
        for in_file in glob.glob(file_path_in_txt):
# split out directory & filename
            path, fileName = os.path.split(in_file)
            if (fileName == "idoctranin.txt"):
                continue
            shutil.copy(in_file, file_path_out_txt)
# Archive
            shutil.copy(in_file, os.path.join(dir_path, '../vimsarchive/'+fileName))
# remap as JSON format
            logfileappendtext.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt','AS400 IN - '+str(in_file))
            idocin.main()
            time.sleep(2)
# remove processed file
            if os.path.exists(in_file):
                os.remove(in_file)
# Process LRO Message
        in_file = os.path.join(dir_path, '../vimsjson/LROMSGIN.json')
        if os.path.exists(in_file):
                os.remove(in_file)
        in_file = os.path.join(dir_path, '../vimsjson/lromsgin.json')
        if os.path.exists(in_file):
                os.remove(in_file)
        file_path_json = os.path.join(dir_path, '../vimsjson/LROMSGIN*.json')
        file_path_out = os.path.join(dir_path, '../vimsjson/lromsgin.json')
        for in_file in glob.glob(file_path_json):
# split out directory & filename
            path, fileName = os.path.split(in_file)
            if (in_file != file_path_out):
                try:
                    shutil.copy(in_file, file_path_out)
                except:
                    pass
            logfileappendtext.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt','LRO - '+str(in_file))
            lr_order.main()
            logfileappend.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt',in_file)
            if os.path.exists(in_file):
                os.remove(in_file)
# Process TTO Message
        in_file = os.path.join(dir_path, '../vimsjson/TTOMSGIN.json')
        if os.path.exists(in_file):
                os.remove(in_file)
        in_file = os.path.join(dir_path, '../vimsjson/ttomsgin.json')
        if os.path.exists(in_file):
                os.remove(in_file)
        file_path_json = os.path.join(dir_path, '../vimsjson/SUPPORDRMSGIN*.json')
        file_path_out = os.path.join(dir_path, '../vimsjson/ttomsgin.json')
        for in_file in glob.glob(file_path_json):
# split out directory & filename
            path, fileName = os.path.split(in_file)
            if (in_file != file_path_out):
                shutil.copy(in_file, file_path_out)
            tt_ran_order.main()
            logfileappend.fileappend('c:/xampp/htdocs/vimslog/vimsupload.txt',in_file)
            if os.path.exists(in_file):
                os.remove(in_file)
# populate Inventory with TT-RAN
        tt_ran_allocate.main()
# ---------------------------------------------------------------------------------------------------
# FTP Put to Stonebranch server - from outout folder
    vimsftpput.main()
#               
# ---------------------------------------------------------------------------------------------------
                
# Create JSON Format
    file_path_in_txt = os.path.join(dir_path, '../vimsin/order*.txt')
    file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
# loop through order*.txt files
    for in_file in glob.glob(file_path_in_txt):
        shutil.copy(in_file, file_path_out_txt)
# split out directory & filename
        path, fileName = os.path.split(in_file)
# Archive
        shutil.copy(in_file, os.path.join(dir_path, '../vimsarchive/'+fileName))
# remap as JSON format
        idocin.main()
# remove processed file
        if os.path.exists(in_file):
            os.remove(in_file)
            
# move JSON files to interface output directory
    file_path_json = os.path.join(dir_path, '../vimsjson/order*.json')
    for in_file in glob.glob(file_path_json):
# split out directory & filename
        path, fileName = os.path.split(in_file)
        shutil.copy(in_file, uploadDirs['interfaceout']+"\\"+fileName)
        if os.path.exists(in_file):
            os.remove(in_file)
            
# ---------------------------------------------------------------------------------------------------
# Get All remaining files in upload Directory
    directory = uploadDirs['interfacein']           
    for fileName in os.listdir(directory):
        file_path = os.path.join(directory, fileName)
        if not os.path.isfile(file_path):
            continue
            
        print(file_path)
# Process pick-order excel Files to create .txt files
        file_path_xls = os.path.join(dir_path, '../vimsin/order.xlsx')
        if fileName.lower().endswith(('.xlsx', '.xls')):
# Copy & Rename File
            shutil.copy(file_path, file_path_xls)
# Format .xls data to .txt format
            excel_order.main()          
# Delete processed Input File
        if os.path.exists(file_path_xls):
            os.remove(file_path_xls)
        if os.path.exists(file_path):
            os.remove(file_path)
            
# ---------------------------------------------------------------------------------------------------   
    if (orderFlag == "Y"):
    # process orders from upload directory
        file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
        file_path_txt = os.path.join(dir_path, '../vimsin/order*.txt')
        for pck in glob.glob(file_path_txt):
    # split out directory & filename
            path, fileName = os.path.split(pck)
    # Create JSON Format
            shutil.copy(pck, file_path_out_txt)
            idocin.main()

            if os.path.exists(pck):
                os.remove(pck)  
# Create JSON Format
    file_path_in_json = os.path.join(dir_path, '../vimsjson/idoctranout.json')
    for idoc in glob.glob(os.path.join(dir_path, '../vimsjson/vimsormsgin*.json')):
        shutil.copy(idoc, file_path_in_json)
# Create / Update Order
        order.main()
# remove processed file
        if os.path.exists(idoc):
            os.remove(idoc)

# ---------------------------------------------------------------------------------------------------   
# process EDI orders from ORDERR directory
    if (ediOrderFlag == "Y"):
        file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
        for pck in glob.glob(uploadDirs['interfacein']+"/EDI_ORDERR/*.*"):
# split out directory & filename
            path, fileName = os.path.split(pck)
# Create JSON Format Files
            shutil.copy(pck, file_path_out_txt)
            edi_order.main()
# Process JSON ordermsgin Files
            file_path_in_json = os.path.join(dir_path, '../vimsjson/idoctranout.json')
            for idoc in glob.glob(os.path.join(dir_path, '../vimsjson/ordermsgin*.json')):
                shutil.copy(idoc, file_path_in_json)
# Create / Update Order
                order.main()
# remove processed file
                if os.path.exists(idoc):
                    os.remove(idoc)
            if os.path.exists(pck):
                os.remove(pck)          
# ---------------------------------------------------------------------------------------------------   
# process orders from upload directory
    file_path_out_txt = os.path.join(dir_path, '../vimsin/idoctranin.txt')
    for pck in glob.glob(uploadDirs['interfacein']+"\\orders*.txt"):
# split out directory & filename
        path, fileName = os.path.split(pck)
# Create JSON Format
        shutil.copy(pck, file_path_out_txt)
        idocin.main()
# Create JSON Format
        file_path_in_json = os.path.join(dir_path, '../vimsjson/idoctranout.json')
        for idoc in glob.glob(os.path.join(dir_path, '../vimsjson/idocmsgin*.json')):
            shutil.copy(idoc, file_path_in_json)
# Create / Update Order
            order.main()
# remove processed file
            if os.path.exists(idoc):
                os.remove(idoc)
            
        if os.path.exists(pck):
            os.remove(pck)  
# ---------------------------------------------------------------------------------------------------
# populate vendor_code on transaction_history
    transactionhistoryvendor.main()
# populate order_body part_id
    orderpartid.main()
# ---------------------------------------------------------------------------------------------------                                                                                       
if __name__ == '__main__':
    while True:
        print("Start..")
        try:
            main()
        except Exception as err:
            print("INTERFACE ERROR -",str(err))
            time.sleep(5)
            pass
        try:    
            sys.stdout.write("\r")
            sys.stdout.flush()
            dots = "..........................................................."
            for remaining in range(60, 0, -1):
                dots = dots[0:remaining]+" "
                sys.stdout.write("\r")
                sys.stdout.write("{:2d} seconds remaining".format(remaining)+dots)
                sys.stdout.flush()
                time.sleep(1)
        except Exception as err:
            pass