请教如下代码如何重构，ruby 代码被我写成了 php

注意

不是简单的拆分成多个函数避免一个方法内容超过 10 行代码, 理想情况下, 大多数方法内容应该少于5行。空行不算进 LOC 里，if 嵌套里面得逻辑是层层递进的。

def create
  @msg = Msg.new(msg_params)
  article_ids = params[:article_ids]
  weixin_ids = params[:weixin_ids]

  if article_ids.length > 1
    @msg.is_multi = 1
  else
    @msg.is_multi = 0
  end

  if @msg.save
    article_ids.each do |a_id|
      MsgArticle.create({msg_id: @msg.id, article_id: a_id})
    end
    weixin_arr = []
    weixin_ids.each do |w_id|
      sleep 2
      weixin = Weixin.find w_id
      arr = [weixin.username, weixin.password]
      weixin_arr.push arr
      wx_ext = WxExt::WeiXin.new arr[0], arr[1]
      flag = wx_ext.init
      if flag
        puts "===" * 20
        articles = @msg.articles

        upload_msg_params = {
            AppMsgId: '',
            ajax: 1,
            count: article_ids.length,
            f: 'json',
            lang: 'zh_CN',
            random: rand,
            token: wx_ext.token,
            vid: ''
        }

        articles.each_with_index do |a, i|
          sleep 2
          puts "==start#{i}" * 5

          file_path = a.img.current_path
          file = File.new(file_path, 'rb')
          file_hash = wx_ext.upload_file(file, File.basename(file_path))

          if file_path["base_resp"]["ret"].to_s == '0'
            file_id = file_hash["content"]

            puts "=file_id=" * 5
            puts file_id

            article_param = {
                "author#{i}".to_sym => "#{a.author}",
                "title#{i}".to_sym => "#{a.title}",
                "sourceurl#{i}".to_sym => "#{a.sourceurl}",
                "fileid#{i}".to_sym => file_id,
                "digest#{i}".to_sym => "#{a.summary}",
                "content#{i}".to_sym => "#{a.content}",
                "show_cover_pic#{i}".to_sym => 1
            }
            upload_msg_params = upload_msg_params.merge article_param
          else
            flash[:notice] = '图文消息创建失败'
            return
          end
        end
        upload_msg_hash = wx_ext.upload_multi_msg(upload_msg_params)

        if upload_msg_hash["ret"].to_s == '0'
          puts "=upload_msg_hash_all=" * 2
          puts upload_msg_hash

          msg_list_hash = wx_ext.get_app_msg_list

          if msg_list_hash["base_resp"]["ret"].to_s == '0'
            puts "=msg_list_hash=" * 3
            puts msg_list_hash
            app_msg_id = msg_list_hash["app_msg_info"]["item"][0]["app_id"]
            puts "=app_msg_id=" * 3
            puts app_msg_id

            brondcast_msg_params = {
                ajax: 1,
                appmsgid: app_msg_id, # 图文appid
                cardlimit: 1, # 发送限制条数
                city: '',
                country: '',
                province: '',
                f: 'json',
                groupid: '-1',
                imgcode: '',
                lang: 'zh_CN',
                operation_seq: wx_ext.operation_seq, #
                random: rand,
                sex: 0,
                synctxweibo: 0,
                token: wx_ext.token,
                type: 10
            }
            brondcast_msg_hash = wx_ext.broadcast_msg(brondcast_msg_params)
            if brondcast_msg_hash["ret"].to_s == '0'
              puts "brondcast_msg_hash" * 3
              puts brondcast_msg_hash

              WeixinMsg.create({weixin_id: w_id, msg_id: @msg.id, publish_time: Time.now, is_sent: 1})

              flash[:notice] = '图文消息创建成功'
            else
              flash[:notice] = '图文消息创建失败'
              return
            end
          else
            flash[:notice] = '图文消息创建失败'
            return
          end
        else
          flash[:notice] = '图文消息创建失败'
          return
        end
      else
        puts "==" * 20
        puts "weixin.init failed"
        flash[:notice] = '图文消息创建失败'
        return
      end
    end
  end

  respond_with(@msg)
end