Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public static void sendMessagesConsumptie(int orderIdFromTrigger) throws XmlRpcException, ParseException, IOException, TimeoutException {
- final String url = "http://10.3.50.39:8069",
- db = "kassagroepb",
- username = "matheo.dexelle@student.ehb.be",
- password = "admin";
- final XmlRpcClient client = new XmlRpcClient();
- final XmlRpcClientConfigImpl common_config = new XmlRpcClientConfigImpl();
- common_config.setServerURL(new URL(String.format("%s/xmlrpc/2/common", url)));
- int uid;
- uid = (int)client.execute(common_config, "authenticate", Arrays.asList(db, username, password, Collections.emptyMap()));
- XmlRpcClient models = null;
- try {
- models = new XmlRpcClient() {
- {
- setConfig (new XmlRpcClientConfigImpl() {
- {
- setServerURL(new URL (String.format("%s/xmlrpc/2/object", url)));
- }
- });
- }
- };
- } catch (MalformedURLException e) {
- e.printStackTrace();
- }
- final List orderinfo = Arrays.asList((Object[])models.execute(
- "execute_kw", Arrays.asList(
- db, uid, password,
- "pos.order", "search_read",
- Arrays.asList(Arrays.asList(
- Arrays.asList("id","=", orderIdFromTrigger)
- )), new HashMap() {
- {
- put("fields", Arrays.asList(/*"amount_paid",*/
- "id",
- "amount_paid",
- "partner_id",
- "user_id",
- "x_UUIDMedewerker"));
- //bepalen info van de order
- }
- })));
- String getId = String.valueOf(orderinfo);
- int startId;
- int eindId;
- startId = getId.indexOf(", id=")+5;
- eindId = getId.indexOf(", x_UUIDMedewerker");
- String orderIdS = getId.substring(startId, eindId);
- int orderId = Integer.parseInt(orderIdS);
- final List orderlineinfo = Arrays.asList((Object[])models.execute(
- "execute_kw", Arrays.asList(
- db, uid, password,
- "pos.order.line", "search_read",
- Arrays.asList(Arrays.asList(
- //bepalen welke payment
- Arrays.asList("order_id", "=", orderId)
- )), new HashMap( ) {
- {
- put("fields", Arrays.asList("id",
- "product_id",
- "qty",
- "order_id",
- "price_subtotal_incl"));
- //info per verkocht product
- }
- })));
- System.out.println(orderlineinfo);
- System.out.println(orderinfo);
- HashMap tempOrderInfo = (HashMap) orderinfo.get(0);
- List orderKlant = Arrays.asList((Object[]) tempOrderInfo.get("partner_id"));
- List orderSales = Arrays.asList((Object[]) tempOrderInfo.get("user_id"));
- System.out.println(orderSales.get(0));
- final List userinfo = Arrays.asList((Object[])models.execute(
- "execute_kw", Arrays.asList(
- db, uid, password,
- "res.users", "search_read",
- Arrays.asList(Arrays.asList(
- Arrays.asList("id", "=", orderSales.get(0))
- )), new HashMap( ) {
- {
- put("fields", Arrays.asList("id","x_UUIDbezoeker", "x_UUIDMedewerker"));
- }
- })));
- HashMap tempUserInfo = (HashMap) userinfo.get(0);
- System.out.println("test" + userinfo);
- List medUUID = Arrays.asList((String) tempUserInfo.get("x_UUIDMedewerker"));
- //List medNaam = Arrays.asList((String) tempUserInfo.get("name"));
- List medLocalId = Arrays.asList((int) tempUserInfo.get("id"));
- final List klantinfo = Arrays.asList((Object[])models.execute(
- "execute_kw", Arrays.asList(
- db, uid, password,
- "res.partner", "search_read",
- Arrays.asList(Arrays.asList(
- Arrays.asList("id", "=", orderKlant.get(0))
- )), new HashMap( ) {
- {
- put("fields", Arrays.asList("id","x_UUIDbezoeker","name", "email"));
- }
- })));
- HashMap tempKlantInfo = (HashMap) klantinfo.get(0);
- List klantUUID = Arrays.asList((String) tempKlantInfo.get("x_UUIDbezoeker"));
- List klantOfArt = Arrays.asList((String) tempKlantInfo.get("x_isStudent"));
- ArrayList<String> allMessages = new ArrayList<String>();
- for(int i = 0; i < orderlineinfo.size(); i++) {
- HashMap tempOrderLineInfo = (HashMap) orderlineinfo.get(i);
- List prodInOrderLine = Arrays.asList((Object[]) tempOrderLineInfo.get("product_id"));
- List qtyProds = Arrays.asList((double) tempOrderLineInfo.get("qty"));
- List orderSubTotal = Arrays.asList((double) tempOrderLineInfo.get("price_subtotal_incl"));
- final List prodinfo = Arrays.asList((Object[])models.execute(
- "execute_kw", Arrays.asList(
- db, uid, password,
- "product.product", "search_read",
- Arrays.asList(Arrays.asList(
- Arrays.asList("id", "=", (int)prodInOrderLine.get(0))
- )), new HashMap( ) {
- {
- put("fields", Arrays.asList("x_Soort", "x_UUIDProduct"));
- }
- })));
- HashMap tempProdInfo = (HashMap) prodinfo.get(0);
- System.out.println(tempProdInfo);
- List prodSoort= Arrays.asList((String) tempProdInfo.get("x_Soort"));
- List prodUUID = Arrays.asList((String) tempProdInfo.get("x_UUIDProduct"));
- Item item = new Item();
- String valuesBez = String.valueOf(userinfo);
- String valuesOrd = String.valueOf(orderinfo);
- String valuesOLI = String.valueOf(orderlineinfo);
- int startpositie;
- int eindpositie;
- item.setUUIDAankoop("" + orderIdS + "");
- try {
- item.setUUIDBezoeker(klantUUID.get(0).toString());
- }catch(NullPointerException e) {
- item.setUUIDArtiest(klantUUID.get(0).toString());
- }
- item.setUUIDMedewerker(medUUID.get(0).toString());
- item.setUUIDProduct((String)prodUUID.get(0));
- item.setSoort((String) prodSoort.get(0));
- double aantal = (double) qtyProds.get(0);
- item.setAantal(aantal);
- item.setTotalePrijs((double)orderSubTotal.get(0));
- item.setTimestamp(convertToFormat(getTodayDate()));
- ConnectionFactory factory = new ConnectionFactory();
- factory.setHost("10.3.50.39");
- factory.setPort(5672);
- factory.setUsername("radmin");
- factory.setPassword("radmin1");
- Connection connection = factory.newConnection();
- Channel channel = connection.createChannel();
- channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.FANOUT);
- String message = javaNaarXml(item);
- channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes("UTF-8"));
- System.out.println(" [x] Sent '" + message + "'");
- channel.close();
- connection.close();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement