package fr.inria.jessy.benchmark.tpcc;

import fr.inria.jessy.Jessy;
import fr.inria.jessy.benchmark.tpcc.entities.*;
import fr.inria.jessy.transaction.ExecutionHistory;
import fr.inria.jessy.transaction.Transaction;

import java.util.*;
import java.util.Random;

/**
 * @author WANG Haiyun & ZHAO Guang
 * 
 */

public class StockLevel extends Transaction {
	
	private String W_ID;
	private String D_W_ID;
	private String D_ID;
	private String OL_O_ID;

	public StockLevel(Jessy jessy) throws Exception {
		super(jessy);
	}

	@Override
	public ExecutionHistory execute() {	
		
		try {
			District district;
			Order order;
			Order_line ol = null;
			Stock stock;
			int threshold;
			int low_stock = 0;
			int i,j;
			
			/* value of (W_ID, D_ID) is constant */
			W_ID = "1";
			D_ID = "1";
			this.D_W_ID = W_ID;
			
			/* Selection District */
			district = read(District.class, "D_W_"+ W_ID + "_" + "D_"+ D_ID);
			
			Random rand = new Random(System.currentTimeMillis());
			threshold = rand.nextInt(20-10)+10; /* The threshold of minimum quantity in stock (threshold ) is selected at random within [10 .. 20] */
			
			List<String> listItems = new ArrayList<String>();
			
			for(i=district.getD_NEXT_O()-20; i<district.getD_NEXT_O();i++) {
				/* Selection Order */
				order = read(Order.class, "O_W_"+ W_ID + "_" + "O_D_"+ D_ID + "_" + "O_"+ i);
				for(j=1;j<=order.getO_OL_CNT();j++) {
					/* Selection Order_line */
					ol = read(Order_line.class, "OL_W_"+W_ID + "_" + "OL_D_"+D_ID + "_" + "OL_O_"+OL_O_ID +"_" + "OL_"+j);
					/* Stocks must be counted only for distinct items */
					if(!listItems.contains(ol.getOL_I_ID())) {
						/* add into the item list */
						listItems.add(ol.getOL_I_ID());
						/* Selection Stock */
						stock = read(Stock.class, "S_W_"+ W_ID + "_" + "S_I_" + ol.getOL_I_ID());
						if(stock.getS_QUANTITY()<threshold)
							low_stock++;
					}
					
				}
				
			}

			return commitTransaction();	
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return null;
	}

}

package fr.inria.jessy.benchmark.tpcc;

import fr.inria.jessy.Jessy;
import fr.inria.jessy.benchmark.tpcc.entities.*;
import fr.inria.jessy.transaction.ExecutionHistory;
import fr.inria.jessy.transaction.Transaction;

import java.util.*;
import java.util.Random;

/**
 * @author WANG Haiyun & ZHAO Guang
 * 
 */

public class StockLevel extends Transaction {
	
	private String W_ID;
	private String D_ID;

	public StockLevel(Jessy jessy) throws Exception {
		super(jessy);
	}

	@Override
	public ExecutionHistory execute() {	
		
		try {
			District district;
			Order order;
			Order_line ol = null;
			Stock stock;
			int threshold;
			int low_stock = 0;
			int i,j;
			
			/* value of (W_ID, D_ID) is constant */
			W_ID = "1";
			D_ID = "1";
			
			/* Selection District */
			district = read(District.class, "D_W_"+ W_ID + "_" + "D_"+ D_ID);
			
			Random rand = new Random(System.currentTimeMillis());
			threshold = rand.nextInt(20-10)+10; /* The threshold of minimum quantity in stock (threshold ) is selected at random within [10 .. 20] */
			
			List<String> listItems = new ArrayList<String>();
			
			for(i=district.getD_NEXT_O()-20; i<district.getD_NEXT_O();i++) {
				/* Selection Order */
				order = read(Order.class, "O_W_"+ W_ID + "_" + "O_D_"+ D_ID + "_" + "O_"+ i);
				for(j=1;j<=order.getO_OL_CNT();j++) {
					/* Selection Order_line */
					ol = read(Order_line.class, "OL_W_"+W_ID + "_" + "OL_D_"+D_ID + "_" + "OL_O_"+order.getO_ID() +"_" + "OL_"+j);
					/* Stocks must be counted only for distinct items */
					if(!listItems.contains(ol.getOL_I_ID())) {
						/* add into the item list */
						listItems.add(ol.getOL_I_ID());
						/* Selection Stock */
						stock = read(Stock.class, "S_W_"+ W_ID + "_" + "S_I_" + ol.getOL_I_ID());
						if(stock.getS_QUANTITY()<threshold)
							low_stock++;
					}
					
				}
				
			}

			return commitTransaction();	
			
		} catch (Exception e) {
			e.printStackTrace();
		}
		
		return null;
	}

}

modify a tiny error in StockLevel transaction