#openttdcoop

import math
import time
import datetime
import os
from os import remove
from PIL import Image
from multiprocessing import Pool
import multiprocessing

#starting message
print("-"*79)
print("Starting...")

#path definition
diskPath = 'D:/OpenTTD_repositories/BRIX/scripts/' #"C:/Users/Pavel/Downloads/scripts/"#"E:/_BRIX/_BRIX-repository/scripts/"
inputFolder = diskPath + "input/"
outputFolder = diskPath + "output/"

#printing path just to check
print("inputFolder is " + inputFolder)
print("outputFolder is " + outputFolder)

#started time
tt = time.time()
startedTime = datetime.datetime.fromtimestamp(tt).strftime('%H:%M:%S')

#open palette image
palette = Image.open(inputFolder + "openttd-palette-dos.png")
print("Opening and loading palette: " + "openttd-palette-dos.png")

p=[]

for b in range(0,palette.height):
  for a in range(0, palette.width):
    p.append(palette.getpixel((a,b)))
    
print('Palette loaded.')

# ----------------------------------------------------------------------------------------------------------------
# ----------------------------------------------------------------------------------------------------------------
# ----------------------------------------------------------------------------------------------------------------

def rgb2palette(input_image, x_start, x_end):
  #open input image
  i = Image.open(inputFolder + input_image + ".png")
  print("Opening: " + input_image + ".png")  
  
  #create new empty image for output
  imageOutput = Image.new("RGBA", (i.width,i.height), color=(0,0,0,0))
  
  for y in range (0, i.height):
    #timeStamp
    ts = time.time()
    timeStamp = datetime.datetime.fromtimestamp(ts).strftime('%H:%M:%S')
    #print(timeStamp + " - " + input_image + " row {}".format(y))
    for x in range (x_start, x_end):
      print(timeStamp + " - " + input_image + " row {}".format(x))
      #defining winner variables
      winnerDistance = 100000000
      winnerID = 0
      
      #loading pixel from image and separating RGBA
      pixelNumber = x + (y * i.width)
      pix = i.getpixel((x,y))
      pixRed = pix[0]
      pixGreen = pix[1]
      pixBlue = pix[2]
      pixAlpha = pix[3]
            
      #check Alpha in pixel, and output alpha/color offset
      if pixAlpha < 128:
        finalAlpha = 0
        colorOffset = 0
      if pixAlpha >= 128 and pixAlpha < 178:
        finalAlpha = 255
        colorOffset = 1
      if pixAlpha >= 178 and pixAlpha < 230:
        finalAlpha = 255
        colorOffset = 2
      if pixAlpha >= 230:
        finalAlpha = 255
        colorOffset = 0
      
      #if alpha above 50%, do colour comparing to palette
      if pixAlpha >= 128:
        for z, (r1, g1, b1, ca) in enumerate(p):
          #dr = pixRed - cr
          #dg = pixGreen - cg
          #db = pixBlue - cb
          #distance = dr*dr + dg*dg + db*db
          l1 = (r1*299 + g1*587 + b1*114) / 255000
          l2 = (pixRed*299 + pixGreen*587 + pixBlue*114) / 255000
          dL = l1-l2
          dR = (r1-pixRed)/255
          dG = (g1-pixGreen)/255
          dB = (b1-pixBlue)/255
          distance = (dR*dR*0.299 + dG*dG*0.587 + dB*dB*0.114)*0.75 + dL*dL
          
          if distance < winnerDistance:
            winnerDistance = distance
            winnerID = z
    
      #compare input RGB channels and output highest value
      if pixRed >= pixGreen and pixRed >= pixBlue:
        highestValue = pixRed
      if pixGreen >= pixRed and pixGreen >= pixBlue:
        highestValue = pixGreen
      if pixBlue >= pixRed and pixBlue >= pixGreen:
        highestValue = pixBlue     
      # set color offset +/- based on colour value
      if highestValue < 128:
        negation = -1
        colorOffset = colorOffset * negation
      #print("colorOffset is ... " + str(colorOffset) )
      
      #final color changed by colorOffset
      finalColor = p[winnerID - colorOffset]
      
      finalR = finalColor[0]
      finalG = finalColor[1]
      finalB = finalColor[2]
      #finalAlpha taken from the if output above palette colour comparing
      
      #put the final pixel into the output picture
      imageOutput.putpixel((x,y),(finalR,finalG,finalB,finalAlpha))
      #print("Pixel " + str(pixelNumber) + ": R= " + str(finalR) + ", G= " + str(finalG) + ", B= " + str(finalB) + ", A= "  + str(finalAlpha)   )

def run():
  # ----------------------------------------------------------------------------------------------------------------
  #VARIABLES
  # ----------------------------------------------------------------------------------------------------------------
  job_list = [
      'test0'
      #'BRIDGES_0000',
      #'LAND_OUTPUT_0000'
      ]
  # ----------------------------------------------------------------------------------------------------------------
  thread_count = 16
  # ----------------------------------------------------------------------------------------------------------------
  # ----------------------------------------------------------------------------------------------------------------
  # ----------------------------------------------------------------------------------------------------------------

for job in job_list:
    all_jobs = []
    job_chunks = []
    queue = []

extra = 0
    chunk_image = Image.open(inputFolder + job + ".png")
    chunk_average_size = math.floor(chunk_image.width/thread_count)
    chunk_modulo_size = chunk_image.width % thread_count 
    for thread in range(0, thread_count):
      start = chunk_average_size * thread
      end = (chunk_average_size * (thread+1)) -1

start += extra
      if thread < chunk_modulo_size:   
        extra += 1
      end += extra

start_and_end = [job, start, end]
      
      job_chunks.append(start_and_end)

queue.append( [job, start, end] )
      #print(str(queue))

all_jobs.append(job_chunks)

for a_job in all_jobs:
      #print('-'*32)
      thread_id = 0
      for b_thread in a_job:
        if thread_id == 0:
          thread_id += 1
          print('Job: ' + str(b_thread[0]))#
          print(' '*10 + 'Start, ' + 'End')#
          print('Thread ' + str(thread_id) + ': ' + str(b_thread[1]) + ', ' + str(b_thread[2]))#
        
        
    
    #print(all_jobs)
    
    # ----------------------------------------------------------------------------------------------------------------
    # PROCESS
    # ----------------------------------------------------------------------------------------------------------------
    
    pool = multiprocessing.Pool(processes = thread_count)
    for q in queue:
      pool.apply_async(rgb2palette, args=(q[0], q[1], q[2], ) )
    pool.close()
    pool.join()

os.makedirs(outputFolder, exist_ok = True)
    imageOutput.save(outputFolder + input_image[-5:] + "_8bpp.png") #assumes _#### frame number format (removes last 5 characters)
    
    #finished time
    tx = time.time()
    finishedTime = datetime.datetime.fromtimestamp(tx).strftime('%H:%M:%S')
    
    print("Started:  " + startedTime)
    print("Finished: " + finishedTime)

run()

if __name__ == '__main__':
  #freeze_support()
  run()

Mark as private