#include<stdio.h>
#include<stdlib.h>
#include<getch.h>
#include<string.h>
#include<stdbool.h>
#include<sys/ipc.h>
#include<sys/msg.h>
#include"struct.h"
#include"tools.h"

void save_server(void)
{

	//获取消息队列
	int cgid = msgget(ftok(".",500),0);
	
	//接收消息
	C_to_s c = {};
	while(1)
	{
		msgrcv(cgid,&c,sizeof(C_to_s),104,0);	
		if(104 == c.type)
			break;
	}	
	
	//创建消息队列
	int sgid = msgget(ftok(".",520),IPC_CREAT|0644);
	//发送消息
	S_to_c s = {c.user.pid};
	
	char buf[256] = {};
	sprintf(buf,"%s%d",ACC_PATH,c.user.id);
	FILE* frp = fopen(buf,"rb+");
	
	C_to_s c1 = {};
	fread(&c1,sizeof(C_to_s),1,frp);
	
	c1.user.money += c.user.money;
	rewind(frp);
	fwrite(&c1,sizeof(C_to_s),1,frp);	
	fclose(frp);frp = NULL;
	strcpy(s.buf,"存钱成功!");
	msgsnd(sgid,&s,sizeof(S_to_c)-sizeof(s.type),0);
}

int main()
{
	while(1)
	{
		save_server();
	}
	return 0;
}