对于一个学校项目,我们必须在elixir中创建一个网店,该网店可以通过上传csv文件来创建新产品。我们尝试通过以下操作来实现这一点:如何使用elixir/phoenix从csv文件导入用户?但我们总是会出错(见标题(
有人能帮我们吗?这是我们的代码:
表单
<%= form_for @changeset, @action, [multipart: true], fn f -> %>
<div class="form-group">
<label>File</label>
<%= file_input f, :file, class: "form-control" %>
</div>
<div class="form-group">
<%= submit "Submit", class: "btn btn-primary" %>
</div>
<% end %>
渲染
<%= render "bulkform.html", changeset: @changeset, action: Routes.product_path(@conn, :createBulk) %>
路线
post "/productsBulk", ProductController, :createBulk
架构
schema "products" do
field :color, :string
field :size, :string
field :description, :string
field :price, :decimal
field :title, :string
timestamps()
end
@doc false
def changeset(product, attrs) do
product
|> cast(attrs, [:title, :description, :size, :color, :price, :stock])
|> validate_required([:title, :description, :size, :color, :price, :stock])
|> unique_constraint(:title, name: :unique_products_index, message:
"Title already in use.")
end
控制器
def createBulk(conn, %{"product" => product_params}) do
product_params["file"].path
|> File.stream!()
|> CSV.decode
|> Enum.each(fn(product) -> Product.changeset(%Product{}, %{title: Enum.at(product, 0), description:
Enum.at(product, 1), size: Enum.at(product, 2), color: Enum.at(product, 3), price: Enum.at(product, 4)})
|> Repo.insert() end)
conn
|> put_flash(:info, "Imported")
|> redirect(to: Routes.product_path(conn, :overview))
end
如果您完整地包含错误消息,并且可以向我们准确地显示错误消息中提到的行,那将更有帮助。
然而,正如Aleksei已经指出的那样,我怀疑你的问题是,当你应该传递列表时,你却在向Enum.each/1
传递元组。换句话说:
Enum.each({:ok, [1, 2, 3]}, fn x -> IO.puts(x) end)
** (Protocol.UndefinedError) protocol Enumerable not implemented for ...
而这很好:
Enum.each([1, 2, 3], fn x -> IO.puts(x) end)
因此,CSV.decode
的输出不能直接通过管道传输到Enum
函数中,因为它返回一个元组,但使用CSV.decode!
应该返回原始列表,代码应该可以工作。