package com.cxs.dao;

import com.cxs.model.entity.BillOfMaterial;
import com.cxs.utils.DBUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanListHandler;

import java.sql.Connection;
import java.sql.SQLException;
import java.util.List;

/**
 * @author cnmgb
 * @version 1.0
 * @date 2022/4/14
 **/
public class BillOfMaterialsDao {
  private QueryRunner queryRunner = new QueryRunner(DBUtils.getDs());

  public List<BillOfMaterial> queryBillOfMaterials() {
    try {
      return queryRunner.query("select id,billOfMaterialsName from billOfMaterials;",
          new BeanListHandler<>(BillOfMaterial.class));
    } catch (SQLException e) {
      e.printStackTrace();
    }
    return null;
  }
  public int addBillOfMaterials(String billOfMaterialName) {
    try {
      return queryRunner.update("insert into billOfMaterials (billOfMaterialsName) values (?);",
          billOfMaterialName);
    } catch (SQLException e) {
      e.printStackTrace();
    }
    return -1;
  }
  public int addReclamationBillOfMaterials(String projectNumber, List<String> billOfMaterialsList)
      throws SQLException {
    Connection con = DBUtils.getCon();
    int res = -1;
    for (String id : billOfMaterialsList) {
      res=queryRunner.update(con,
          "insert into project_billofmaterials (projectNumber, billOfMaterialsId) values (?,?);",
          projectNumber, id);
    }
    return res;


  }
}