mongoconnector.rb in imperituroard-0.3.3

- old
+ new

@@ -21,12 +21,11 @@
   end
 
   def audit_logger(proc_name, src_ip, input_json, output_json, real_ip)
     out_resp = {}
     begin
-      d = DateTime.now
-      current = d.strftime("%d/%m/%Y %H:%M:%S")
+      current = DateTime.now
       collection = client[:audit]
       doc = {
           :proc_name => proc_name,
           :date => current,
           :sender => {:src_ip => src_ip, :real_ip => real_ip},
@@ -211,11 +210,11 @@
     not_ex = imei_list - res_exists
     p "not_ex"
     p not_ex
     p res_exists
     out_resp = {:code => 200, :result => "check_imei_exists: Request completed successfully",
-     :body => {:exists => res_exists, :not_exists => not_ex}}
+                :body => {:exists => res_exists, :not_exists => not_ex}}
     internal_func.printer_texter(out_resp, "debug")
     out_resp
   end
 
 
@@ -236,11 +235,11 @@
         }
         result = collection.insert_one(l)
         p result
       end
     rescue
-      continue
+      nil
     end
   end
 
 
   def imei_insert_list2(imei_list)
@@ -260,14 +259,26 @@
         }
         result = collection.insert_one(l)
         p result
       end
     rescue
-      continue
+      nil
     end
   end
 
+
+  def imei_insert_model(model)
+    begin
+      collection = client[:device_types]
+      result = collection.insert_one(model)
+      p result
+    rescue
+      nil
+    end
+  end
+
+
   def get_profile_name_from_imei(imei)
     out_resp = {}
     begin
       id = ""
       begin
@@ -378,9 +389,31 @@
       app_id = result_ps[0][:iot_data][:app_id]
       secret = result_ps[0][:iot_data][:secret]
       out_resp = {:code => 200, :result => "get_iot_oceanconnect_credent: Request completed successfully", :body => {:app_id => app_id, :secret => secret}}
     rescue
       out_resp = {:code => 500, :result => "get_iot_oceanconnect_credent: Process failed"}
+    end
+    internal_func.printer_texter(out_resp, "debug")
+    out_resp
+  end
+
+
+  def get_device_type_info_by_model(device_model)
+    out_resp = {}
+    begin
+      result_ps = []
+      collection = client[:device_types]
+      collection.find({"model" => device_model}).each {|row|
+        result_ps.append(row)
+      }
+      dattaa = result_ps[0]
+      if dattaa!=nil
+        out_resp = {:code => 200, :result => "get_device_type_info_by_model: Request completed successfully", :body => dattaa}
+      else
+        out_resp = {:code => 404, :result => "get_device_type_info_by_model: Device info not found", :body => {"model" => device_model, "ManufacturerID" => "unknown", "ManufacturerNAME" => "unknown", "device_type" => "unknown"}}
+      end
+    rescue
+      out_resp = {:code => 500, :result => "get_device_type_info_by_model: procedure error", :body => {"model" => device_model, "ManufacturerID" => "unknown", "ManufacturerNAME" => "unknown", "device_type" => "unknown"}}
     end
     internal_func.printer_texter(out_resp, "debug")
     out_resp
   end
 
\ No newline at end of file