# 數(shù)據(jù)處理
import os
import torch
from torch.utils import data
from PIL import Image
import numpy as np
from torchvision import transforms

transform = transforms.Compose([
 transforms.ToTensor(), # 將圖片轉(zhuǎn)換為Tensor,歸一化至[0,1]
 # transforms.Normalize(mean=[.5, .5, .5], std=[.5, .5, .5]) # 標(biāo)準(zhǔn)化至[-1,1]
])

#定義自己的數(shù)據(jù)集合
class FlameSet(data.Dataset):
 def __init__(self,root):
  # 所有圖片的絕對(duì)路徑
  imgs=os.listdir(root)
  self.imgs=[os.path.join(root,k) for k in imgs]
  self.transforms=transform

 def __getitem__(self, index):
  img_path = self.imgs[index]
  pil_img = Image.open(img_path)
  if self.transforms:
   data = self.transforms(pil_img)
  else:
   pil_img = np.asarray(pil_img)
   data = torch.from_numpy(pil_img)
  return data

 def __len__(self):
  return len(self.imgs)

if __name__ == '__main__':
 dataSet=FlameSet('./test')
 print(dataSet[0])

# # 訓(xùn)練數(shù)據(jù)和測(cè)試數(shù)據(jù)的下載
# 訓(xùn)練數(shù)據(jù)和測(cè)試數(shù)據(jù)的下載
trainDataset = torchvision.datasets.MNIST( # torchvision可以實(shí)現(xiàn)數(shù)據(jù)集的訓(xùn)練集和測(cè)試集的下載
  root="./data", # 下載數(shù)據(jù)，并且存放在data文件夾中
  train=True, # train用于指定在數(shù)據(jù)集下載完成后需要載入哪部分?jǐn)?shù)據(jù)，如果設(shè)置為True，則說(shuō)明載入的是該數(shù)據(jù)集的訓(xùn)練集部分；如果設(shè)置為False，則說(shuō)明載入的是該數(shù)據(jù)集的測(cè)試集部分。
  transform=transforms.ToTensor(), # 數(shù)據(jù)的標(biāo)準(zhǔn)化等操作都在transforms中，此處是轉(zhuǎn)換
  download=True # 瞎子啊過(guò)程中如果中斷，或者下載完成之后再次運(yùn)行，則會(huì)出現(xiàn)報(bào)錯(cuò)
)

testDataset = torchvision.datasets.MNIST(
  root="./data",
  train=False,
  transform=transforms.ToTensor(),
  download=True
)

class DealDataset(Dataset):
  """
    讀取數(shù)據(jù)、初始化數(shù)據(jù)
  """
  def __init__(self, folder, data_name, label_name,transform=None):
    (train_set, train_labels) = load_minist_data.load_data(folder, data_name, label_name) # 其實(shí)也可以直接使用torch.load(),讀取之后的結(jié)果為torch.Tensor形式
    self.train_set = train_set
    self.train_labels = train_labels
    self.transform = transform

  def __getitem__(self, index):

    img, target = self.train_set[index], int(self.train_labels[index])
    if self.transform is not None:
      img = self.transform(img)
    return img, target

  def __len__(self):
    return len(self.train_set)

def load_data(data_folder, data_name, label_name):
 """
    data_folder: 文件目錄
    data_name： 數(shù)據(jù)文件名
    label_name：標(biāo)簽數(shù)據(jù)文件名
  """
 with gzip.open(os.path.join(data_folder,label_name), 'rb') as lbpath: # rb表示的是讀取二進(jìn)制數(shù)據(jù)
  y_train = np.frombuffer(lbpath.read(), np.uint8, offset=8)

 with gzip.open(os.path.join(data_folder,data_name), 'rb') as imgpath:
  x_train = np.frombuffer(
    imgpath.read(), np.uint8, offset=16).reshape(len(y_train), 28, 28)
 return (x_train, y_train)

# 實(shí)例化這個(gè)類，然后我們就得到了Dataset類型的數(shù)據(jù)，記下來(lái)就將這個(gè)類傳給DataLoader，就可以了。
trainDataset = DealDataset('MNIST_data/', "train-images-idx3-ubyte.gz","train-labels-idx1-ubyte.gz",transform=transforms.ToTensor())
testDataset = DealDataset('MNIST_data/', "t10k-images-idx3-ubyte.gz","t10k-labels-idx1-ubyte.gz",transform=transforms.ToTensor())

# 訓(xùn)練數(shù)據(jù)和測(cè)試數(shù)據(jù)的裝載
train_loader = dataloader.DataLoader(
  dataset=trainDataset,
  batch_size=100, # 一個(gè)批次可以認(rèn)為是一個(gè)包，每個(gè)包中含有100張圖片
  shuffle=False,
)

test_loader = dataloader.DataLoader(
  dataset=testDataset,
  batch_size=100,
  shuffle=False,
)

class NeuralNet(nn.Module):

  def __init__(self, input_num, hidden_num, output_num):
    super(NeuralNet, self).__init__()
    self.fc1 = nn.Linear(input_num, hidden_num)
    self.fc2 = nn.Linear(hidden_num, output_num)
    self.relu = nn.ReLU()

  def forward(self,x):
    x = self.fc1(x)
    x = self.relu(x)
    y = self.fc2(x)
    return y

# 參數(shù)初始化
epoches = 5
lr = 0.001
input_num = 784
hidden_num = 500
output_num = 10
device = torch.device("cuda" if torch.cuda.is_available() else "cpu")

# 產(chǎn)生訓(xùn)練模型對(duì)象以及定義損失函數(shù)和優(yōu)化函數(shù)
model = NeuralNet(input_num, hidden_num, output_num)
model.to(device)
criterion = nn.CrossEntropyLoss() # 使用交叉熵作為損失函數(shù)
optimizer = optim.Adam(model.parameters(), lr=lr)

# 開始循環(huán)訓(xùn)練
for epoch in range(epoches): # 一個(gè)epoch可以認(rèn)為是一次訓(xùn)練循環(huán)
  for i, data in enumerate(train_loader):
    (images, labels) = data
    images = images.reshape(-1, 28*28).to(device)
    labels = labels.to(device)
    output = model(images) # 經(jīng)過(guò)模型對(duì)象就產(chǎn)生了輸出
    loss = criterion(output, labels.long()) # 傳入的參數(shù): 輸出值(預(yù)測(cè)值), 實(shí)際值(標(biāo)簽)
    optimizer.zero_grad() # 梯度清零
    loss.backward()
    optimizer.step()

    if (i+1) % 100 == 0: # i表示樣本的編號(hào)
      print('Epoch [{}/{}], Loss: {:.4f}'
         .format(epoch + 1, epoches, loss.item())) # {}里面是后面需要傳入的變量
                              # loss.item
# 開始測(cè)試
with torch.no_grad():
  correct = 0
  total = 0
  for images, labels in test_loader:
    images = images.reshape(-1, 28*28).to(device) # 此處的-1一般是指自動(dòng)匹配的意思, 即不知道有多少行，但是確定了列數(shù)為28 * 28
                           # 其實(shí)由于此處28 * 28本身就已經(jīng)等于了原tensor的大小，所以，行數(shù)也就確定了，為1
    labels = labels.to(device)
    output = model(images)
    _, predicted = torch.max(output, 1)
    total += labels.size(0) # 此處的size()類似numpy的shape: np.shape(train_images)[0]
    correct += (predicted == labels).sum().item()
  print("The accuracy of total {} images: {}%".format(total, 100 * correct/total))