#include<stdio.h>
#include<unistd.h>
#include<pthread.h>
#include<stdlib.h>
#include<time.h>

pthread_t tid1, tid2, tid3, tid4, tid5, tid6, tid7, tid7, tid8, tid9, tid10, tid11;
pthread_mutex_t q, con, scp[5];

int queue[5], sIsIn[5], sP[5];

void GetDestination(int c, int* x, int* y)
{
    *y = 5;
    if (c == 1) *x = 4;
    if (c == 2) *x = 16;
    if (c == 3) *x = 27;
    if (c == 4) *x = 39;
    if (c == 5) *x = 52;
}

void Draw()
{
    int i;
    pthread_mutex_lock(&con);
    printf("\033[2J\n");
    printf("\033[4;4H\033[31mo");
    printf("\033[3;2H\033[0mOmsk");
    
    printf("\033[6;16H\033[33mo");
    printf("\033[7;14H\033[0mTara");
    
    printf("\033[4;27H\033[37mo");
    printf("\033[3;25H\033[0mTobolsk");    
    
    printf("\033[6;39H\033[39mo");
    printf("\033[7;36H\033[0mKhanty-Mansiisk");
    
    printf("\033[4;52H\033[36mo");
    printf("\033[3;50H\033[0mSalehard");
    printf("\033[5;0H\033[44m");
    for (i = 0; i < 55; ++i){ printf(" ");}
    printf("\033[0m");    
    fflush(stdout);
    pthread_mutex_unlock(&con);    
}

void ShowStatus(int f)
{
    int x = 0, y = 0;
    pthread_mutex_lock(&con);
    printf("\033[0m\n");
    fflush(stdout);
    if (f == 1)
    {
        GetDestination(1, &x, &y);
        printf("\033[%d;%dH", y - 1, x + 2);
        printf("   ");
        printf("\033[%d;%dH",y - 1, x + 2);
        printf("%d", queue[0]);
    }
    if (f == 1)
    {
        GetDestination(2, &x, &y);
        printf("\033[%d;%dH", y + 1, x - 3);
        printf("   ");
        printf("\033[%d;%dH",y + 1, x - 3);
        printf("%d", queue[1]);
    }
    if (f == 1)
    {
        GetDestination(3, &x, &y);
        printf("\033[%d;%dH", y - 1, x + 2);
        printf("   ");
        printf("\033[%d;%dH",y - 1, x + 2);
        printf("%d", queue[2]);
    }
    if (f == 1)
    {
        GetDestination(4, &x, &y);
        printf("\033[%d;%dH", y + 1, x + 2);
        printf("   ");
        printf("\033[%d;%dH",y + 1, x + 2);
        printf("%d", queue[3]);
    }
    if (f == 1)
    {
        GetDestination(5, &x, &y);
        printf("\033[%d;%dH", y - 1, x + 2);
        printf("   ");
        printf("\033[%d;%dH",y - 1, x + 2);
        printf("%d", queue[4]);    
    }
    fflush(stdout);
    pthread_mutex_unlock(&con);    
}

void* AddPeople(void* arg)
{    
    do
    {
        pthread_mutex_lock(&q);
        srand(time(NULL));
        queue[0] += rand()%7 + 2;
        queue[1] += rand()%7 + 2;
        queue[2] += rand()%7 + 1;
        queue[3] += rand()%7 + 3;
        queue[4] += rand()%7 + 1;
        ShowStatus(1);        
        ShowStatus(2);
        ShowStatus(3);
        ShowStatus(4);
        ShowStatus(5);
        pthread_mutex_unlock(&q);
        usleep(20000000);
    } while(1);
    
}

void prepare(int a, int b, int* dx)
{
    if (a > b) 
    {
        *dx = -1;
    }
    else
    {
        *dx = 1;    
    }
}

void go(int* x, int* y, int* dx, int a, int b, int n)
{
    int pos[2];
    GetDestination(a, x, y);
    GetDestination(b, &pos[0], &pos[1]);
    //printf("\033[0;10H\033[0m%d %d", pos[0], pos[1]);
    while(*x != pos[0])
    {
        pthread_mutex_lock(&con);        
        printf("\033[%d;%dH", *y, *x - 1);
        printf("\033[31;44m");
        printf("-%d", n);
        fflush(stdout);
        pthread_mutex_unlock(&con);
        usleep(200000);
        pthread_mutex_lock(&con);
        printf("\033[%d;%dH", *y, *x - 1);
        printf("\033[34;44m");    
        printf("-%d", n);
        fflush(stdout);
        pthread_mutex_unlock(&con);
        *x+=*dx;        
    }
}

void ship1(void* arg)
{
    int x, y, a, b, dx;
    a = 1;
    b = 5;
    while(1)
    {
        pthread_mutex_lock(&scp[0]);        
        prepare(a, b, &dx);
        go(&x, &y, &dx, a, b, 1);
        sIsIn[0] = b;
        a = b;
        pthread_mutex_unlock(&scp[0]);
        do
        {
            srand(time(NULL));
            b = rand()%4 +1;
        } while (a == b);
        usleep(200000);
    }
}



void PeopleSal(void* arg)
{
    int i;
    while(1)
    {
        for (i = 0; i < 5; ++i)
        {
            pthread_mutex_lock(&scp[4]);
            if (sIsIn[i] == 4)
            {
                sP[i] = 0;
                while ((sP[i] < 7) && (queue[4] > 0))
                {
                    queue[4]--;
                    ShowStatus(5);
                    sP[i]++;
                }
                sIsIn[i] = 0;
            }
            pthread_mutex_unlock(&scp[4]);    
        }
    }
}



void main()
{
    int i;
    printf("\033[2J\033[11;0H");
    for (i = 0; i < 5; ++i)
    {
        queue[i] = 20;
        sIsIn[i] = 0;
        sP[i] = 0;
    }   
    Draw(); 
    pthread_create(&tid1, NULL, AddPeople, (void*)1);
    pthread_create(&tid2, NULL, (void*)PeopleSal, (void*)2);
    pthread_create(&tid6, NULL, (void*)ship1, (void*)7);
    usleep(1000000);    
    pthread_mutex_init(&q, NULL);
    pthread_mutex_init(&con, NULL);    
    usleep(20000000);
    printf("\033[10;0H\033[0m"); 
}