add comfch and comfnd

Isaac Lewis
1 parent 96149efa
Showing 12 changed files with 261 additions and 15 deletions Show diff stats
lib/syspro.rb
lib/syspro/api_operations/query.rb
lib/syspro/business_objects/combrw.rb
lib/syspro/business_objects/comfch.rb
lib/syspro/business_objects/comfnd.rb
lib/syspro/business_objects/parsers/combrw_parser.rb
lib/syspro/business_objects/parsers/comfch_parser.rb
lib/syspro/business_objects/parsers/comfnd_parser.rb
lib/syspro/business_objects/schemas/combrw.xml.erb
lib/syspro/business_objects/schemas/comfch.xml.erb
lib/syspro/business_objects/schemas/comfnd.xml.erb
test/query_test.rb
@@ -21,8 +21,12 @@ require &quot;syspro/api_operations/request&quot;
 require "syspro/api_operations/query"
 require "syspro/business_objects/combrw"
+require "syspro/business_objects/comfch"
+require "syspro/business_objects/comfnd"
 require "syspro/business_objects/parsers/combrw_parser"
+require "syspro/business_objects/parsers/comfch_parser"
+require "syspro/business_objects/parsers/comfnd_parser"
 module Syspro
   @api_base = "http://syspro.wildlandlabs.com:90/SYSPROWCFService/Rest"
@@ -8,10 +8,12 @@ module Syspro
           request(:get, "/Query/Browse", params)
         end
-        def fetch
+        def fetch(params)
+          request(:get, "/Query/Fetch", params)
         end
-        def query
+        def query(params)
+          request(:get, "/Query/Query", params)
         end
         def find
@@ -23,7 +23,8 @@ module Syspro
       def parse_response(resp)
         handle_errors(resp)
-        ComBrwParser.parse(resp[0].data)
+        parser = ComBrwParser.new(resp[0].data)
+        parser.parse
       end
       def handle_errors(resp)
+require "syspro/business_objects/parsers/comfch_parser"
+require "erb"
+
+module Syspro
+  module BusinessObjects
+    class ComFch < ApiResource
+      include Syspro::ApiOperations::Query
+      include Syspro::BusinessObjects::Parsers
+
+      attr_accessor :table_name, :key, :optional_keys, :full_key_provided,
+                    :default_type, :espresso_fetch
+
+      def call(user_id)
+        xml_in = template.result(binding)
+        params = { "UserId" => user_id, "XmlIn" => xml_in }
+        resp = ComFch.fetch(params)
+        parse_response(resp)
+      end
+
+      def template
+        ERB.new File.read(File.expand_path("schemas/comfch.xml.erb", File.dirname(__FILE__))), nil, "%"
+      end
+
+      def parse_response(resp)
+        handle_errors(resp)
+        parser = ComFchParser.new(resp[0].data)
+        parser.parse
+      end
+
+      def handle_errors(resp)
+        body = resp[0].http_body
+        if body.match(/^(ERROR)/)
+          raise SysproError, body
+        end
+      end
+    end
+  end
+end
+
+require "syspro/business_objects/parsers/comfnd_parser"
+require "erb"
+
+module Syspro
+  module BusinessObjects
+    class ComFnd < ApiResource
+      include Syspro::ApiOperations::Query
+      include Syspro::BusinessObjects::Parsers
+
+      attr_accessor :table_name, :return_rows, :columns, :expressions,
+                    :order_by
+
+      def call(user_id)
+        xml_in = template.result(binding)
+        business_object = "COMFND"
+        params = { "UserId" => user_id, "BusinessObject" => business_object, "XmlIn" => xml_in }
+        resp = ComFnd.query(params)
+        parse_response(resp)
+      end
+
+      def template
+        ERB.new File.read(File.expand_path("schemas/comfnd.xml.erb", File.dirname(__FILE__))), nil, "%"
+      end
+
+      def parse_response(resp)
+        handle_errors(resp)
+        parser = ComFndParser.new(resp[0].data)
+        parser.parse
+      end
+
+      def handle_errors(resp)
+        body = resp[0].http_body
+        if body.match(/^(ERROR)/)
+          raise SysproError, body
+        end
+      end
+    end
+  end
+end
+
@@ -2,8 +2,13 @@ module Syspro
   module BusinessObjects
     module Parsers
       class ComBrwParser
+        attr_reader :doc
-        def self.parse(doc)
+        def initialize(doc)
+          @doc = doc
+        end
+
+        def parse
           next_prev_key = doc.first_element_child.xpath("NextPrevKey")
           next_prev_key_obj = next_prev_key.children.map { |el|
             if el.name == "text"
@@ -28,11 +33,11 @@ module Syspro
           rows = doc.first_element_child.xpath('Row')
           rows_obj = rows.map { |el|
-            el.elements.map { |el|
+            el.elements.map { |inner|
               {
-                name: el.name,
-                value: el.xpath('Value').text,
-                data_type: el.xpath('DataType').text
+                name: inner.name,
+                value: inner.xpath('Value').text,
+                data_type: inner.xpath('DataType').text
               }
             }
           }.flatten(1).compact
+module Syspro
+  module BusinessObjects
+    module Parsers
+      class ComFchParser
+        attr_reader :doc
+
+        def initialize(doc)
+          @doc = doc
+        end
+
+        def parse
+          table_name = doc.first_element_child.name
+          columns = doc.first_element_child.elements
+          columns_obj = columns.map { |el|
+            { name: el.name, value: el.children.text }
+          }.compact
+
+          FetchObject.new(
+            table_name,
+            columns_obj
+          )
+        end
+
+        FetchObject = Struct.new(:table_name, :columns)
+      end
+    end
+  end
+end
+
+module Syspro
+  module BusinessObjects
+    module Parsers
+      class ComFndParser
+        attr_reader :doc
+
+        def initialize(doc)
+          @doc = doc
+        end
+
+        def parse
+          header_details = doc.first_element_child.xpath("HeaderDetails")
+          header_details_obj = header_details.children.map { |el|
+            if el.name == "text"
+              next
+            end
+            {
+              name: el.name,
+              text: el.text
+            }
+          }.compact
+
+          rows = doc.first_element_child.xpath('Row')
+          rows_obj = rows.map { |el|
+            el.elements.map { |inner|
+              {
+                name: inner.name,
+                value: inner.children.text
+              }
+            }
+          }.flatten(1).compact
+
+          FindObject.new(
+            header_details_obj,
+            rows_obj,
+            doc.first_element_child.xpath('//RowsReturned').text.to_i
+          )
+        end
+
+        FindObject = Struct.new(:header_details, :rows, :row_count)
+      end
+    end
+  end
+end
+
 <?xml version="1.0" encoding="Windows-1252"?>
-<!-- Copyright 1994-2014 SYSPRO Ltd.-->
-<!-- 
-     Sample XML for the Generic Browse Object
--->
 <Browse xmlns:xsd="http://www.w3.org/2001/XMLSchema-instance" xsd:noNamespaceSchemaLocation="COMBRW.XSD">
   <BrowseName><%= @browse_name %></BrowseName>
   <StartAtKey/>
+<?xml version="1.0" encoding="Windows-1252"?>
+<Fetch xmlns:xsd="http://www.w3.org/2001/XMLSchema-instance" xsd:noNamespaceSchemaLocation="COMFCH.XSD">
+  <TableName><%= @table_name %></TableName>
+  <Key><%= @key %></Key>
+  <% unless @optional_keys.empty? %>
+    <% @optional_keys.each_with_index do |key, i| %>
+      <<%= "OptionalKey#{ i + 1 }" %>><%= key[:value] %></<%= "OptionalKey#{ i + 1 }" %>>
+    <% end %>
+  <% end %>
+  <FullKeyProvided><%= @full_key_provided ? "N" : "Y" %></FullKeyProvided>
+  <DefaultType><%= @default_type %></DefaultType>
+  <EspressoFetch><%= @espresso_fetch ? "N" : "Y" %></EspressoFetch>
+</Fetch>
+
+<?xml version="1.0" encoding="Windows-1252"?>
+<Query xmlns:xsd="http://www.w3.org/2001/XMLSchema-instance" xsd:noNamespaceSchemaLocation="COMFND.XSD">
+  <TableName><%= @table_name %></TableName>
+  <ReturnRows><%= @return_rows %></ReturnRows>
+  <Columns>
+    <% for column in @columns %>
+      <Column><%= column[:name] %></Column>
+    <% end %>
+  </Columns>
+  <% unless @expressions.empty? %>
+    <Where>
+      <% for expression in @expressions %>
+        <Expression>
+          <OpenBracket>(</OpenBracket>
+          <% unless expression[:andor].nil? %>
+            <AndOr><%= expression[:andor] %></AndOr>
+          <% end %>
+          <Column><%= expression[:column] %></Column>
+          <Condition><%= expression[:condition] %></Condition>
+          <Value><%= expression[:value] %></Value>
+          <CloseBracket>)</CloseBracket>
+        </Expression>
+      <% end %>
+    </Where>
+  <% end %>
+  <OrderBy>
+    <Column><%= @order_by %></Column>
+  </OrderBy>
+</Query>
 require "test_helper"
 class QueryTest < Minitest::Test
-  def test_query
+  def test_query_browse
     user_id = Syspro::Logon.logon("wland", "piperita2016", "L", "")
     combrw = Syspro::BusinessObjects::ComBrw.new
@@ -15,8 +15,50 @@ class QueryTest &lt; Minitest::Test
       {name: "StockCode"}
     ]
-    query_result = combrw.call(user_id.guid)
+    browse_result = combrw.call(user_id.guid)
-    refute_nil query_result
+    refute_nil browse_result
+  end
+
+  def test_query_query
+    user_id = Syspro::Logon.logon("wland", "piperita2016", "L", "")
+
+    comfnd = Syspro::BusinessObjects::ComFnd.new
+    comfnd.table_name = "InvMaster"
+    comfnd.return_rows = 5
+    comfnd.columns = [
+      {
+        name: "StockCode"
+      }
+    ]
+    comfnd.expressions = [
+      {
+        andor: "And",
+        column: "StockCode",
+        condition: "EQ",
+        value: "02"
+      }
+    ]
+    comfnd.order_by = "StockCode"
+
+    find_result = comfnd.call(user_id.guid)
+
+    refute_nil find_result
+  end
+
+  def test_query_fetch
+    user_id = Syspro::Logon.logon("wland", "piperita2016", "L", "")
+
+    comfch = Syspro::BusinessObjects::ComFch.new
+    comfch.table_name = "InvMaster"
+    comfch.key = "02"
+    comfch.optional_keys = []
+    comfch.full_key_provided = false
+    comfch.default_type = ""
+    comfch.espresso_fetch = true
+
+    fetch_result = comfch.call(user_id.guid)
+
+    refute_nil fetch_result
   end
 end