For the sake of understanding, we will keep it simple and neglect a lot of things, which would be essential in a real world application.

Graph Structure

Graph structure

Schema for use case

The schema contains two streams: "Suppliers" and "Retailers" streams. The Supplier stream contains information about raw materials suppliers, suppliers and the product. The Retailer stream contains information about product, wholesaler and retailer.

To start, register the schema below

{
   "schema":"SupplyChain",
   "streams":[
      {
         "inpt":[
            
         ],
         "name":"Suppliers",
         "type":1,
         "swsz":86400,
         "attr":[
            {
               "name":"Product",
               "type":5
            },
            {
               "name":"P_lat",
               "type":11
            },
            {
               "name":"P_lon",
               "type":11
            },
            {
               "name":"P_waste",
               "type":9
            },
            {
               "name":"P_cost",
               "type":9
            },
            {
               "name":"P_time",
               "type":9
            },
            {
               "name":"Supplier",
               "type":5
            },
            {
               "name":"SUP_lat",
               "type":11
            },
            {
               "name":"SUP_lon",
               "type":11
            },
            {
               "name":"SUP_waste",
               "type":9
            },
            {
               "name":"SUP_cost",
               "type":9
            },
            {
               "name":"SUP_time",
               "type":9
            },
            {
               "name":"Rawsupplier",
               "type":5
            },
            {
               "name":"RAW_lat",
               "type":11
            },
            {
               "name":"RAW_lon",
               "type":11
            },
            {
               "name":"RAW_waste",
               "type":9
            },
            {
               "name":"RAW_cost",
               "type":9
            },
            {
               "name":"RAW_time",
               "type":9
            }
         ],
         "catr":[
            {
               "name":"P_SUP_dist",
               "type":11,
               "opnm":"GEO_DISTANCE",
               "iatr":[
                  "P_lat",
                  "P_lon",
                  "SUP_lat",
                  "SUP_lon"
               ]
            },
            {
               "name":"SUP_RAW_dist",
               "type":11,
               "opnm":"GEO_DISTANCE",
               "iatr":[
                  "SUP_lat",
                  "SUP_lon",
                  "RAW_lat",
                  "RAW_lon"
               ]
            },
            {
               "name":"Supply_time",
               "type":11,
               "opnm":"ADD",
               "iatr":[
                  "P_time",
                  "SUP_time",
                  "RAW_time"
               ]
            },
            {
               "name":"Supply_score",
               "type":11,
               "opnm":"MATH_EXP",
               "iatr":[
                  "((((($P_cost+$SUP_cost)+$RAW_cost)*0.6)+((($P_waste+$SUP_waste)+$RAW_waste)*0.2))+((($P_time+$SUP_time)+$RAW_time)*0.2))"
               ]
            },
            {
               "name":"Supply_dist",
               "type":11,
               "opnm":"ADD",
               "iatr":[
                  "P_SUP_dist",
                  "SUP_RAW_dist"
               ]
            }
         ],
         "rels":[
            {
               "sub":"Rawsupplier",
               "obj":"Supplier",
               "rel":"DELIVER_SUPPLIER",
               "sub_props":[
                  "RAW_lat",
                  "RAW_lon",
                  "RAW_waste",
                  "RAW_cost",
                  "RAW_time"
               ],
               "obj_props":[
                  "SUP_lat",
                  "SUP_lon",
                  "SUP_waste",
                  "SUP_cost",
                  "SUP_time"
               ],
               "rel_props":[
                  "SUP_RAW_dist"
               ]
            },
            {
               "sub":"Supplier",
               "obj":"Product",
               "rel":"DELIVER_PRODUCT",
               "obj_props":[
                  "P_lat",
                  "P_lon",
                  "P_waste",
                  "P_cost",
                  "P_time"
               ],
               "rel_props":[
                  "P_SUP_dist",
                  "Supply_dist",
                  "Supply_time",
                  "Supply_score"
               ]
            }
         ]
      },
      {
         "inpt":[
            
         ],
         "name":"Retailers",
         "type":1,
         "swsz":86400,
         "attr":[
            {
               "name":"Product",
               "type":5
            },
            {
               "name":"P_lat",
               "type":11
            },
            {
               "name":"P_lon",
               "type":11
            },
            {
               "name":"P_waste",
               "type":9
            },
            {
               "name":"P_cost",
               "type":9
            },
            {
               "name":"P_time",
               "type":9
            },
            {
               "name":"Wholesaler",
               "type":5
            },
            {
               "name":"W_lat",
               "type":11
            },
            {
               "name":"W_lon",
               "type":11
            },
            {
               "name":"W_waste",
               "type":9
            },
            {
               "name":"W_cost",
               "type":9
            },
            {
               "name":"W_time",
               "type":9
            },
            {
               "name":"Retailer",
               "type":5
            },
            {
               "name":"R_lat",
               "type":11
            },
            {
               "name":"R_lon",
               "type":11
            },
            {
               "name":"R_waste",
               "type":9
            },
            {
               "name":"R_cost",
               "type":9
            },
            {
               "name":"R_time",
               "type":9
            }
         ],
         "catr":[
            {
               "name":"P_W_dist",
               "type":11,
               "opnm":"GEO_DISTANCE",
               "iatr":[
                  "P_lat",
                  "P_lon",
                  "W_lat",
                  "W_lon"
               ]
            },
            {
               "name":"W_R_dist",
               "type":11,
               "opnm":"GEO_DISTANCE",
               "iatr":[
                  "W_lat",
                  "W_lon",
                  "R_lat",
                  "R_lon"
               ]
            },
            {
               "name":"Retailer_time",
               "type":11,
               "opnm":"ADD",
               "iatr":[
                  "P_time",
                  "W_time",
                  "R_time"
               ]
            },
            {
               "name":"Retailer_score",
               "type":11,
               "opnm":"MATH_EXP",
               "iatr":[
                  "((((($P_cost+$W_cost)+$R_cost)*0.6)+((($P_waste+$W_waste)+$R_waste)*0.2))+((($P_time+$W_time)+$R_time)*0.2))"
               ]
            },
            {
               "name":"Retailer_dist",
               "type":11,
               "opnm":"ADD",
               "iatr":[
                  "P_W_dist",
                  "W_R_dist"
               ]
            }
         ],
         "rels":[
            {
               "sub":"Product",
               "obj":"Wholesaler",
               "rel":"DELIVER_WHOLESALER",
               "obj_props":[
                  "W_lat",
                  "W_lon",
                  "W_waste",
                  "W_cost",
                  "W_time"
               ],
               "rel_props":[
                  "P_W_dist"
               ]
            },
            {
               "sub":"Wholesaler",
               "obj":"Retailer",
               "rel":"DELIVER_RETAILER",
               "obj_props":[
                  "R_lat",
                  "R_lon",
                  "R_waste",
                  "R_cost",
                  "R_time"
               ],
               "rel_props":[
                  "W_R_dist",
                  "Retailer_dist",
                  "Retailer_time",
                  "Retailer_score"
               ]
            }
         ]
      }
   ]
}

We are calculating Geo_distance between every node ( like Rawsuppler to supplier) using latitude and longitude.

We are calculating scores using formula :

(Waste produce*0.2) + (time*0.2) + (Cost*0.6)
for every (raw_supplier) -> (retailer) path.

Data

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierA0","SUP_lat":110.660283127047,"SUP_lon":21.574243546186,"SUP_waste":515,"SUP_cost":21,"SUP_time":3,"Rawsupplier":"RawsupplierA0","RAW_lat":98.6539252197985,"RAW_lon":107.907432903924,"RAW_waste":390,"RAW_cost":22,"RAW_time":1}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierA0","SUP_lat":110.660283127047,"SUP_lon":21.574243546186,"SUP_waste":515,"SUP_cost":21,"SUP_time":3,"Rawsupplier":"RawsupplierA2","RAW_lat":107.340609324664,"RAW_lon":100.076500620285,"RAW_waste":334,"RAW_cost":28,"RAW_time":4}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierA0","SUP_lat":110.660283127047,"SUP_lon":21.574243546186,"SUP_waste":515,"SUP_cost":21,"SUP_time":3,"Rawsupplier":"RawsupplierA4","RAW_lat":114.764040331065,"RAW_lon":20.7330090061881,"RAW_waste":252,"RAW_cost":27,"RAW_time":2}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierA1","SUP_lat":71.18497232919823,"SUP_lon":1.305450007902,"SUP_waste":264,"SUP_cost":23,"SUP_time":1,"Rawsupplier":"RawsupplierA1","RAW_lat":55.1809352284595,"RAW_lon":14.764481568444,"RAW_waste":270,"RAW_cost":27,"RAW_time":4}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierA1","SUP_lat":71.18497232919823,"SUP_lon":1.305450007902,"SUP_waste":264,"SUP_cost":23,"SUP_time":1,"Rawsupplier":"RawsupplierA3","RAW_lat":54.7975977591404,"RAW_lon":63.5836668672296,"RAW_waste":332,"RAW_cost":23,"RAW_time":3}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierB0","SUP_lat":139.312421505472,"SUP_lon":55.3139769562115,"SUP_waste":277,"SUP_cost":26,"SUP_time":2,"Rawsupplier":"RawsupplierB0","RAW_lat":139.945556614575,"RAW_lon":39.912938103419,"RAW_waste":436,"RAW_cost":35,"RAW_time":3}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierB0","SUP_lat":139.312421505472,"SUP_lon":55.3139769562115,"SUP_waste":277,"SUP_cost":26,"SUP_time":3,"Rawsupplier":"RawsupplierB1","RAW_lat":85.1953246573602,"RAW_lon":62.6767081938293,"RAW_waste":252,"RAW_cost":21,"RAW_time":4}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierB0","SUP_lat":139.312421505472,"SUP_lon":55.3139769562115,"SUP_waste":277,"SUP_cost":26,"SUP_time":2,"Rawsupplier":"RawsupplierB2","RAW_lat":117.83017215995,"RAW_lon":63.9601342330773,"RAW_waste":256,"RAW_cost":29,"RAW_time":2}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierB0","SUP_lat":139.312421505472,"SUP_lon":55.3139769562115,"SUP_waste":277,"SUP_cost":26,"SUP_time":3,"Rawsupplier":"RawsupplierB3","RAW_lat":92.1540045082611,"RAW_lon":61.0228953783365,"RAW_waste":2004,"RAW_cost":33,"RAW_time":3}

insert into SupplyChain.Suppliers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Supplier":"SupplierB0","SUP_lat":139.312421505472,"SUP_lon":55.3139769562115,"SUP_waste":277,"SUP_cost":26,"SUP_time":1,"Rawsupplier":"RawsupplierB4","RAW_lat":20.8551478417528,"RAW_lon":39.0235022177217,"RAW_waste":291,"RAW_cost":25,"RAW_time":4}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler0","W_lat":24.1496562226706,"W_lon":60.6662646306976,"W_waste":1719,"W_cost":31,"W_time":4,"Retailer":"Retailer0","R_lat":42.9124151808688,"R_lon":11.270867062432,"R_waste":396,"R_cost":24,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler0","W_lat":24.1496562226706,"W_lon":60.6662646306976,"W_waste":1719,"W_cost":31,"W_time":4,"Retailer":"Retailer1","R_lat":2.67642030370433,"R_lon":46.4589120323211,"R_waste":1162,"R_cost":22,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler0","W_lat":24.1496562226706,"W_lon":60.6662646306976,"W_waste":1719,"W_cost":31,"W_time":4,"Retailer":"Retailer2","R_lat":106.327472938397,"R_lon":39.9044877627902,"R_waste":253,"R_cost":26,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler0","W_lat":24.1496562226706,"W_lon":60.6662646306976,"W_waste":1719,"W_cost":31,"W_time":4,"Retailer":"Retailer3","R_lat":11.7695052738019,"R_lon":55.3097536366582,"R_waste":292,"R_cost":30,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler1","W_lat":16.3864259628063,"W_lon":56.5913607525871,"W_waste":256,"W_cost":22,"W_time":3,"Retailer":"Retailer4","R_lat":27.861155040609,"R_lon":22.5074480130039,"R_waste":261,"R_cost":36,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler1","W_lat":16.3864259628063,"W_lon":56.5913607525871,"W_waste":256,"W_cost":22,"W_time":3,"Retailer":"Retailer5","R_lat":41.9759160186316,"R_lon":11.0739455500895,"R_waste":356,"R_cost":21,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler1","W_lat":16.3864259628063,"W_lon":56.5913607525871,"W_waste":256,"W_cost":22,"W_time":3,"Retailer":"Retailer6","R_lat":8.82017868443289,"R_lon":48.8499595215361,"R_waste":254,"R_cost":22,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler1","W_lat":16.3864259628063,"W_lon":56.5913607525871,"W_waste":256,"W_cost":22,"W_time":3,"Retailer":"Retailer7","R_lat":30.4589698436766,"R_lon":67.4023712400302,"R_waste":257,"R_cost":22,"R_time":1}

insert into SupplyChain.Retailers values null {"Product":"Product0","P_lat":81.0716978,"P_lon":93.0065783,"P_waste":200,"P_cost":100,"P_time":1,"Wholesaler":"Wholesaler1","W_lat":16.3864259628063,"W_lon":56.5913607525871,"W_waste":256,"W_cost":22,"W_time":3,"Retailer":"Retailer8","R_lat":146.979359059592,"R_lon":130.456315605573,"R_waste":2687,"R_cost":24,"R_time":1}

Copy and paste the above insert command on Cli. The data used is not real and is produced randomly.

Performing graph queries

We first have to select the graph on which we want to perform queries.

Select the graph by using below command

USE GRAPH SupplyChain_graph

Listing all Wholesalers with the accumulated distance to every retailer

S=>(@w Wholesaler:*)-[@d DELIVER_RETAILER]->(@r Retailer:*); RETURN w.name AS Wholesaler, r.name AS Retailer, d.Retailer_dist AS Distance

Let's check the time required for the ingredients to reach production (Product).

S=>(@s Supplier:* {name = "SupplierA$%"})-[@d DELIVER_PRODUCT]->(@p Product:*); RETURN s.name AS Supplier, p.name AS product, d.Supply_time

Checking time required from production site to retailers

S=>(@w Wholesaler:*)-[@d DELIVER_RETAILER]->(@r Retailer:*); RETURN w.name AS Wholesaler, r.name AS Retailer, d.Retailer_time AS time

Checking supply chain from raw material supplier "RawsupplierB1"

S=>(@raw Rawsupplier:* {name = "RawsupplierB1"})-[@f DELIVER_SUPPLIER]->(@s Supplier:*)-[@d DELIVER_PRODUCT]->(@p Product:*)-[@i DELIVER_WHOLESALER]->(@w Wholesaler:*)-[@t DELIVER_RETAILER]->(@r Retailer:*); RETURN s.name AS Supplier, p.name AS product, w.name AS Wholesaler, r.name AS Retailer, raw.name AS Raw_matterial_supplier, d.Supply_time AS Supply_time, t.Retailer_time AS Retailer_time

Listing the product site that are less than same distance from the farmer

S=>(@raw Rawsupplier:*)-[@f DELIVER_SUPPLIER]->(@s Supplier:*)-[@d DELIVER_PRODUCT {Supply_dist < 5747127}]->(@p Product:*); RETURN d.Supply_dist AS distance, s.name AS supplier, raw.name AS RawMaterial_Supplier

Checking the scores, time and distance for Supply and Retailer chain

S=>(@raw Rawsupplier:*)-[@f DELIVER_SUPPLIER]->(@s Supplier:*)-[@d DELIVER_PRODUCT {Supply_dist < 5747127}]->(@p Product:*); RETURN d.Supply_dist AS distance, s.name AS supplier, raw.name AS RawMaterial_Supplier, d.Supply_time AS time,d.Supply_score AS Scores
S1=>(@p Product:*)-[@dw DELIVER_WHOLESALER]->(@w Wholesaler:*)-[@dr DELIVER_RETAILER]->(@r Retailer:*); RETURN p.name AS Product, w.name AS Wholesaler, dr.Retailer_dist AS Distance, dr.Retailer_time AS Time, dr.Retailer_score AS Scores, r.name AS Retailer