Java代码

1. Protocol easyhttps = new Protocol("https", new EasySSLProtocolSocketFactory(), 443);
2. Protocol.registerProtocol("https", easyhttps);
4. HttpClient httpClient = new HttpClient();
5. //字符编码
6. httpClient.getParams().setContentCharset("gbk");
8. HostConfiguration hc = new HostConfiguration();
9. hc.setHost("www.uqbook.cn", 80, easyhttps);
11. String configId = "200011111111444444";
12. String agent = "Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN; rv:1.9.2.13) Gecko/20101203 Firefox/3.6.13";
13. String refer = "https://www.uqbook.cn/sec_initListInfo.action";
14. String contentType = "application/x-www-form-urlencoded; charset=UTF-8";
15. //Cookie
16. String cookie = "JSESSIONID1=pkfXNQDY0DTKRpch4ngp62hD1LNmcp5Jpn8G2R2LQVylxHcH1hpr!-595124091";
18. String inputsubje = "";//答案一
19. String inputArith = "68";//答案二
20. int i = 1;
21. boolean isFirstIn = true;
23. while (true) {
25. if(isFirstIn){
26. //进入页面
27. GetMethod inMethod = new GetMethod("https://www.uqbook.cn/initInfo.action");
28. // 设置参数
29. inMethod.setRequestHeader("User-Agent", agent);
30. inMethod.setRequestHeader("Referer", refer);
31. inMethod.setRequestHeader("Cookie", cookie);
32. try {
33. int codeCode = httpClient.executeMethod(hc, inMethod);
35. InputStream inResp = inMethod.getResponseBodyAsStream();
37. //循环读取每一行
38. BufferedReader reader = new BufferedReader(new InputStreamReader(inResp));
39. String line = null;
40. String sysCurrentTime = "";
41. String secondTt = "";
42. while ((line = reader.readLine())!=null){
43. //对读取的数据进行编码转换
44. line = new String(line.getBytes(),"gb2312");
45. line = line.trim();
46. if(line.startsWith("var sysCurrentTime")){
47. sysCurrentTime = line.substring(line.indexOf("\"")+1, line.lastIndexOf("\""));
48. }else if(line.startsWith("var secondTt")){
49. secondTt = line.substring(line.indexOf("‘")+1, line.lastIndexOf("‘"));
50. }
51. //logger.info(line);
52. if(sysCurrentTime!="" && secondTt!=""){
53. break;
54. }
55. }
56. reader.close();
58. logger.info("服务器时间：sysCurrentTime="+sysCurrentTime);
60. logger.info("本机时间："+DateUtil.getCurrentDateStr(DateUtil.C_TIME_PATTON_DEFAULT));
62. logger.info("还没到点...等待"+secondTt+"秒...");
63. Thread.sleep(Integer.parseInt(secondTt));
65. } catch (Exception e) {
66. e.printStackTrace();
67. logger.error("进入页面得到倒计时间异常：" + e);
68. continue;//继续来一次
69. }
70. }
71. isFirstIn = false;
73. // 1、取问题及答案
74. PostMethod subInfoMethod = new PostMethod("https://www.uqbook.cn/getSubjectInfo.action");
75. // 设置参数
76. subInfoMethod.setRequestHeader("User-Agent", agent);
77. subInfoMethod.setRequestHeader("Referer", refer);
78. subInfoMethod.setRequestHeader("Cookie", cookie);
80. subInfoMethod.addParameter("timeStamp", ""+System.currentTimeMillis());
81. subInfoMethod.addParameter("configId", configId);
83. try {
84. int subInfoCode = httpClient.executeMethod(hc, subInfoMethod);
85. String subInfoResp = subInfoMethod.getResponseBodyAsString();
87. if (subInfoResp == null || "".equals(subInfoResp)) {
88. logger.info("还没有发布安全问题及答案，本次退出，继续执行下一次！");
89. continue;
90. }
92. logger.info("安全问题及答案解码：" + EscapeUnescape.unescape(subInfoResp));
94. // 解析 JSON
95. JSONArray array = JSON.parseArray(subInfoResp);
96. JSONObject object = (JSONObject) array.get(0);
97. String content = object.getString("subjectContent");
98. inputArith = object.getString("arithmeticAnswer");
100. content = EscapeUnescape.unescape(content).replace("@", " ");
102. Parser parser = new Parser();
103. parser.setInputHTML(content);
104. parser.elements();
105. for (NodeIterator it = parser.elements(); it.hasMoreNodes();) {
106. Node node = it.nextNode();
107. if (node instanceof TagNode) {
108. TagNode tag = (TagNode) node;
109. if ("ttwrsnspysk".equalsIgnoreCase(tag
110. .getAttribute("id"))) {
111. inputsubje = tag.toPlainTextString().trim();
112. }
113. }
114. ;
115. }
117. } catch (Exception e) {
118. e.printStackTrace();
119. }
121. inputArith = "27";
123. if (inputsubje == null || "".equals(inputsubje)
124. || inputArith == null || "".equals(inputArith)) {
125. logger.info("获安全问题及答案时可能发生异常了，本次退出，继续执行下一次！");
126. continue;
127. }
129. //2、判断 是否参加过
130. PostMethod judgementSecSalMethod = new PostMethod("https://www.uqbook.cn/judgement.action");
131. // 设置参数
132. judgementSecSalMethod.setRequestHeader("User-Agent", agent);
133. judgementSecSalMethod.setRequestHeader("Referer", refer);
134. judgementSecSalMethod.setRequestHeader("Cookie", cookie);
136. judgementSecSalMethod.addParameter("timeStamp", ""+System.currentTimeMillis());
137. judgementSecSalMethod.addParameter("configId", configId);
139. try {
140. int judgementSecSalCode = httpClient.executeMethod(hc, judgementSecSalMethod);
141. String judgementSecSalResp = judgementSecSalMethod.getResponseBodyAsString();
142. } catch (Exception e) {
143. e.printStackTrace();
144. }
146. //3、验证问题和答案是否正确
147. PostMethod checkMethod = new PostMethod("https://www.uqbook.cn/judgementAnswer.action");
148. // 设置参数
149. checkMethod.setRequestHeader("User-Agent", agent);
150. checkMethod.setRequestHeader("Content-Type", contentType);
151. checkMethod.setRequestHeader("Referer", refer);
152. checkMethod.setRequestHeader("Cookie", cookie);
154. checkMethod.addParameter("timeStamp", ""+System.currentTimeMillis());
155. String tempInputsubje = inputsubje;
157. try {
158. tempInputsubje = URLEncoder.encode(inputsubje, "utf-8");
159. } catch (UnsupportedEncodingException e1) {
160. // TODO Auto-generated catch block
161. e1.printStackTrace();
162. }
164. checkMethod.addParameter("inputsubje", tempInputsubje);
165. checkMethod.addParameter("inputArith", inputArith);
167. try {
168. int checkCode = httpClient.executeMethod(hc, checkMethod);
169. String checkResp = checkMethod.getResponseBodyAsString();
170. } catch (Exception e) {
171. e.printStackTrace();
172. }
175. // 3、提交抢购！
176. PostMethod submitMethod = new PostMethod("https://www.uqbook.cn/submit.action");
177. // 设置参数
178. submitMethod.setRequestHeader("User-Agent", agent);
179. submitMethod.setRequestHeader("Referer", refer);
180. submitMethod.setRequestHeader("Cookie", cookie);
182. submitMethod.addParameter("timeStamp", ""+System.currentTimeMillis());
183. submitMethod.addParameter("inputsubje", EscapeUnescape.escape(inputsubje));// 编一下码
184. submitMethod.addParameter("inputArith", inputArith);
185. submitMethod.addParameter("configId", configId);
187. try {
189. int submitCode = httpClient.executeMethod(hc, submitMethod);
190. String submitResp = submitMethod.getResponseBodyAsString();
192. JSONArray array = JSON.parseArray(submitResp);
193. JSONObject object = (JSONObject) array.get(0);
194. String sign = object.getString("sign");
195. if ("yes".equals(sign)) {
196. logger.info("抢购登记成功, 退出程序！");
197. break;
198. }
199. logger.info("抢购登记失败，继续...");
201. } catch (Exception e) {
202. logger.error("提交抢购异常：" + e);
203. }
205. subInfoMethod.releaseConnection();
206. submitMethod.releaseConnection();
207. break;
208. }
209.  

     一、题目

     这是一个秒杀系统，即大量用户抢有限的商品，先到先得
     用户并发访问流量非常大，需要分布式的机器集群处理请求
     系统实现使用Java

     二、模块设计

     1、用户请求分发模块：使用Nginx或Apache将用户的请求分发到不同的机器上。

     2、用户请求预处理模块：判断商品是不是还有剩余来决定是不是要处理该请求。

     3、用户请求处理模块：把通过预处理的请求封装成事务提交给数据库，并返回是否成功。

     4、数据库接口模块：该模块是数据库的唯一接口，负责与数据库交互，提供RPC接口供查询是否秒杀结束、剩余数量等信息。

     第一部分就不多说了，配置HTTP服务器即可，这里主要谈谈后面的模块。

     用户请求预处理模块：

     经过HTTP服务器的分发后，单个服务器的负载相对低了一些，但总量依然可能很大，如果后台商品已经被秒杀完毕，那么直接给后来的请求返回秒杀失败即可，不必再进一步发送事务了，示例代码可以如下所示：

     1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38

     package seckill; import org.apache.http.HttpRequest; /** * 预处理阶段，把不必要的请求直接驳回，必要的请求添加到队列中进入下一阶段. */ public class PreProcessor { // 商品是否还有剩余 private static boolean reminds = true; private static void forbidden() { // Do something. } public static boolean checkReminds() { if (reminds) { // 远程检测是否还有剩余，该RPC接口应由数据库服务器提供，不必完全严格检查. if (!RPC.checkReminds()) { reminds = false; } } return reminds; } /** * 每一个HTTP请求都要经过该预处理. */ public static void preProcess(HttpRequest request) { if (checkReminds()) { // 一个并发的队列 RequestQueue.queue.add(request); } else { // 如果已经没有商品了，则直接驳回请求即可. forbidden(); } } }

     并发队列的选择

     Java的并发包提供了三个常用的并发队列实现，分别是：ConcurrentLinkedQueue 、 LinkedBlockingQueue 和 ArrayBlockingQueue。

     ArrayBlockingQueue是初始容量固定的阻塞队列，我们可以用来作为数据库模块成功竞拍的队列，比如有10个商品，那么我们就设定一个10大小的数组队列。

     ConcurrentLinkedQueue使用的是CAS原语无锁队列实现，是一个异步队列，入队的速度很快，出队进行了加锁，性能稍慢。

     LinkedBlockingQueue也是阻塞的队列，入队和出队都用了加锁，当队空的时候线程会暂时阻塞。

     由于我们的系统入队需求要远大于出队需求，一般不会出现队空的情况，所以我们可以选择ConcurrentLinkedQueue来作为我们的请求队列实现：

     1 2 3 4 5 6 7 8 9 10 11

     package seckill; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ConcurrentLinkedQueue; import org.apache.http.HttpRequest; public class RequestQueue { public static ConcurrentLinkedQueue<HttpRequest> queue = new ConcurrentLinkedQueue<HttpRequest>(); }

     用户请求模块

     1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25

     package seckill; import org.apache.http.HttpRequest; public class Processor { /** * 发送秒杀事务到数据库队列. */ public static void kill(BidInfo info) { DB.bids.add(info); } public static void process() { BidInfo info = new BidInfo(RequestQueue.queue.poll()); if (info != null) { kill(info); } } } class BidInfo { BidInfo(HttpRequest request) { // Do something. } }

     数据库模块：

     数据库主要是使用一个ArrayBlockingQueue来暂存有可能成功的用户请求。

     1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27

     package seckill; import java.util.concurrent.ArrayBlockingQueue; /** * DB应该是数据库的唯一接口. */ public class DB { public static int count = 10; public static ArrayBlockingQueue<BidInfo> bids = new ArrayBlockingQueue<BidInfo>(10); public static boolean checkReminds() { // TODO return true; } // 单线程操作 public static void bid() { BidInfo info = bids.poll(); while (count-- > 0) { // insert into table Bids values(item_id, user_id, bid_date, other) // select count(id) from Bids where item_id = ? // 如果数据库商品数量大约总数，则标志秒杀已完成，设置标志位reminds = false. info = bids.poll(); } } }

     三、结语

     看起来大体这样应该就可以了，当然还有细节可以优化，比如数据库请求可以都做成异步的等等。

import java.util.ArrayList;

public class Util {
public static void print(Object o){
System.out.print(o);
}
public static void println(Object o){
if(null==o)
System.out.println();
else
System.out.println(o);
}
public static ArrayList<Integer> toArrayList(int[] ints){
if(ints.length==0)
return null;
ArrayList<Integer> al=new ArrayList<Integer>();
for(int i=0;i<ints.length;i++){
al.add(ints[i]);
}
return al;
}
}

public class Miaosha360buy {
java.util.concurrent.CountDownLatch t= new java.util.concurrent.CountDownLatch(1);

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println(Thread.currentThread().getName() + "开始");
Miaosha360buy ms360=new Miaosha360buy();
new ThreadOne360buy(ms360.t).start();
while(true){
try {
ms360.t.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
Thread.sleep(1000*60);//间隔1分钟调用一次？
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
ms360.t=new java.util.concurrent.CountDownLatch(1);
new ThreadOne360buy(ms360.t).start();
System.out.println("New Tread in while..");
}
}

}

public class Miaosha360buy {
java.util.concurrent.CountDownLatch t= new java.util.concurrent.CountDownLatch(1);

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
System.out.println(Thread.currentThread().getName() + "开始");
Miaosha360buy ms360=new Miaosha360buy();
new ThreadOne360buy(ms360.t).start();
while(true){
try {
ms360.t.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
try {
Thread.sleep(1000*60);//间隔1分钟调用一次？
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
ms360.t=new java.util.concurrent.CountDownLatch(1);
new ThreadOne360buy(ms360.t).start();
System.out.println("New Tread in while..");
}
}

}

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;
import org.jsoup.Jsoup;
import org.jsoup.nodes.Document;
import org.jsoup.nodes.Element;
import org.jsoup.select.Elements;

import view.Util.Util;

public class ThreadOne360buy extends Thread{
java.util.concurrent.CountDownLatch c;
ArrayList al;//记录秒杀产品页面
float price=0.0f;//商品价格
float discount=0.0f;//商品折扣

//用于保存线程信息，在这个项目里用处不大
private static List<Thread> runningThreads = new ArrayList<Thread>();

//这个是一个计数器（不太会用，线程这方面一直感觉是比较复杂的）
public ThreadOne360buy(java.util.concurrent.CountDownLatch c) {
this.c=c;
}

@Override
public void run() {
regist(this);// 线程开始时注册
// 打印开始标记
System.out.println(Thread.currentThread().getName() + "开始...");
try {
//抓取京东手机秒杀页面
this.getMessage("http://sale.360buy.com/act/8VTHFGr10CjMDyZ.html#01");

} catch (ClientProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
c.countDown();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
c.countDown();
}
c.countDown();
unRegist(this);// 线程结束时取消注册
// 打印结束标记
System.out.println(Thread.currentThread().getName() + "结束.");
}

public void regist(Thread t) {
synchronized (runningThreads) {
runningThreads.add(t);
}
}

public void unRegist(Thread t) {
synchronized (runningThreads) {
runningThreads.remove(t);
}
}

public static boolean hasThreadRunning() {
// 通过判断runningThreads是否为空就能知道是否还有线程未执行完
return (runningThreads.size() > 0);
}
/**
* 从手机秒杀页面获取 prodcut链接,product skuid,skuidkey,price,store信息
* @param url：手机秒杀页面
* @throws ClientProtocolException
* @throws IOException
*/
public void getMessage(String url) throws ClientProtocolException, IOException{
al=getMainUrl(down(url));

Util.println(al);
if(al.size()==0){
c.countDown();
System.exit(0);
return;
}

for(int i=0;i<al.size();i++){
StringBuffer sb=new StringBuffer();
StringBuffer openUrl = new StringBuffer();
openUrl.append("http://www.360buy.com/product/");
openUrl.append(al.get(i).toString().subSequence(al.get(i).toString().lastIndexOf(‘/‘)+1, al.get(i).toString().lastIndexOf(‘.‘)));
openUrl.append(".html");
// 557673
sb.append("http://d.360buy.com/fittingInfo/get?skuId=");
sb.append(al.get(i).toString().subSequence(al.get(i).toString().lastIndexOf(‘/‘)+1, al.get(i).toString().lastIndexOf(‘.‘)));
sb.append("&callback=Recommend.cbRecoFittings");
Util.println(sb.toString());
//map中保存的是产品name,price,折扣信息
Util.println("Al("+i+") down:"+sb.toString());
HashMap<String, String> hm=parseProduct(down(sb.toString()));
//用来匹配价格信息。匹配库存信息
filter(hm,openUrl.toString());//过滤价格,如果条件符合就打开浏览器
}
}
/**
* 一个验证方法
* @param hm 保存着价格信息
* @param url 产品页面
*/
public void filter(HashMap<String, String> hm,String url){//url既是产品页面
// view.Util.oenCMD.openWinExe(null,url);
// 是不是应该先查看库存？
String skuidkey=parseSkuidkey(url);
if(!hasStore(skuidkey)){
Util.println("-------------------------------------");
Util.println("没有库存了！");
Util.println("-------------------------------------");
//减掉计数，以便主线程判断
c.countDown();
//应该结束子线程哦？
return;
}

if(hm.get("skuid").equals("201602")){//判断//摩托罗拉skuid=201602
//这里的价格是写死了，运行前得改过来才行。
this.setPrice(499.0f);
//是不是应该打开控制台？
if(Float.parseFloat(hm.get("price"))<=this.getPrice()){
view.Util.oenCMD.openWinExe(null,url);
}
}else if(hm.get("skuid").equals("675647")){//天语skuid=675647
// //这里的价格是写死了，运行前得改过来才行。
// this.setPrice(699.0f);
// //是不是应该打开控制台？
// if(Float.parseFloat(hm.get("price"))<=this.getPrice()){
// view.Util.oenCMD.openWinExe(null,url);
// }
}

}
/**
* 解析了产品页面中name,skuid，price信息
* @param doc
* @return
*/
public static HashMap<String, String> parseProduct(Document doc){
String text=doc.text();
String docc=text.substring(text.indexOf("master")+9,text.indexOf("fittings")-3).replaceAll("[\\s]", "");
String[] ss=docc.split(",");
HashMap<String, String> hm=new HashMap<String, String>();
for(String it: ss){
String string=it.replaceAll("\"", "");
if(string.contains("\\u"))
string=unicodeDecode(string);

String[] str=string.split(":");
hm.put(str[0], str[1]);
}
Util.println(hm);
return hm;
}
/**
* 处理unicode字符，转换成显示字符（汉字），不太通用
* @param it: \u6a5d
* @return
*/
public static String unicodeDecode(String it){//有个缺点，就是前面的字符无法去掉
Util.println(it);
String regex="(\\\\u[0-9a-f]{4})";
Pattern pt= Pattern.compile(regex);
Matcher mc;
StringBuffer sb;
StringBuffer sba=new StringBuffer();
mc=pt.matcher(it);
while(mc.find()){
sb=new StringBuffer();
mc.appendReplacement(sba,sb.append((char )Integer.parseInt((mc.group(1).substring(2)), 16)).toString());
}
return sba.toString();
}
/**
* 返回文档对象（下载内容）
* @param url 下载页面
* @return
* @throws ClientProtocolException
* @throws IOException
*/
public static Document down(String url) throws ClientProtocolException, IOException{
Document doc = null;
DefaultHttpClient httpClient=new DefaultHttpClient();
Util.println("DownLoad:"+url);
HttpGet get=new HttpGet(url);
HttpResponse response;
response = httpClient.execute(get);
HttpEntity entity = response.getEntity();
doc = Jsoup.parse(entity.getContent(), "utf-8","");
//释放资源
EntityUtils.consume(entity);
//关闭连接
httpClient.getConnectionManager().shutdown();
return doc;
}
/**
* 加入了编码控制信息
* @param url 待下载页面
* @param code 编码
* @return
* @throws ClientProtocolException
* @throws IOException
*/
public static Document down(String url,String code) throws ClientProtocolException, IOException{
Document doc = null;
DefaultHttpClient httpClient=new DefaultHttpClient();
Util.println("DownLoad:"+url);
HttpGet get=new HttpGet(url);
HttpResponse response;
response = httpClient.execute(get);
HttpEntity entity = response.getEntity();
doc = Jsoup.parse(entity.getContent(), code,"");
//释放资源
EntityUtils.consume(entity);
//关闭连接
httpClient.getConnectionManager().shutdown();
return doc;
}
/**
* 用来解析 秒杀页面中的产品（收集）链接
* @param doc
* @return
*/
public static ArrayList<String> getMainUrl(Document doc){
if(doc.equals("")||doc==null)
return null;
try {
Thread.sleep(50);
} catch (InterruptedException e1) {
// TODO Auto-generated catch block
e1.printStackTrace();
}
ArrayList<String> urls=new ArrayList<String>();
String rule="map[name=Map] >area[href~=product]";
/**
* 开始解析
*/
Elements elements=doc.select(rule);
for (Element e : elements) {
// Util.println(e.absUrl("abs:href"));
urls.add(e.absUrl("abs:href"));
}
return urls;
}
/**
* 获取skuidkey,用于查询商品库存信息
* @param url
* @return
*/
public static String parseSkuidkey(String url){
Document doc=null;
try {
doc=down(url,"gb2312");
} catch (ClientProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// Util.println(doc.select("script"));
String text = null;
for(Element e : doc.select("script")){
if(e.data().contains("skuidkey:")){
text=e.data();
break;
}
}
//skuidkey:‘7D45919EA8242511DAA5CC7C6D7B351C‘
text=text.substring(text.indexOf("skuidkey:")+10, text.indexOf("skuidkey:")+42);
Util.println("---------------------------------");
Util.println(text);
return text;
}
/**
* 查看库存信息
* @param skuidkey
* @return
*/
public static boolean hasStore(String skuidkey){//这个地方没有处理，直接提取浏览器中的信息
String address = null;
boolean hasStore=false;
if(skuidkey!=null && !"".equals(skuidkey))
address="http://price.360buy.com/stocksoa/StockHandler.ashx?callback=getProvinceStockCallback&type=pcastock&skuid="+skuidkey+"&provinceid=1&cityid=2800&areaid=2850";
else{
Util.println("解析skuidkey错误");
}
try {
if(parseStore(down(address))){
hasStore=true;
}
} catch (ClientProtocolException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return hasStore;
}
/* if(array[1]=="34"||array[1]=="18"){
changeCart(false);
djdarea.stockInfoDom.html("<strong class=‘store-over‘>无货</strong>");
}
else if(array[1]=="0"){
changeCart(false);
djdarea.stockInfoDom.html("<strong class=‘store-over‘>无货</strong>");
}
else if(array[2]=="0"&&array[4]!="2"){
changeCart(false);
djdarea.stockInfoDom.html("很抱歉，该商品无法送至您选择的区域");
}
else if(array[1]=="33"||array[1]=="5"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>现货</strong>"+(array[4]=="1"?"，该区域"+(array[3]=="0"?"不":"")+"支持货到付款":"")+cashdesc);
}
else if(array[1]=="36"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>预订</strong>"+(array[4]=="1"?"，该区域"+(array[3]=="0"?"不":"")+"支持货到付款":"")+cashdesc);
}
else if(array[1]=="39"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>在途</strong>"+(array[4]=="1"?"，该区域"+(array[3]=="0"?"不":"")+"支持货到付款":"")+cashdesc);
}
else if(array[1]=="40"){
changeCart(true);
djdarea.stockInfoDom.html("<strong>可配货</strong>"+(array[4]=="1"?"，该区域"+(array[3]=="0"?"不":"")+"支持货到付款":"")+cashdesc);
}
*/
/**
* 解析库存信息
* @param doc
* @return
*/
public static boolean parseStore(Document doc){
String text=doc.text();
String docc=text.substring(text.indexOf("-")-1,text.lastIndexOf(",")-1);
Util.println(docc);
String[] store=docc.split("-");
if(store[1].equals("34") || store[1].equals("18")){
//无货
Util.println("此地无货");
return false;
}else if(store[1].equals("33") || store[1].equals("5")){
//现货
Util.println("此地现货");
return true;
}
Util.println(store[1]);
return false;
}
//几个bean方法
public float getPrice() {
return price;
}
public void setPrice(float price) {
this.price = price;
}
public float getDiscount() {
return discount;
}
public void setDiscount(float discount) {
this.discount = discount;
}

}

public class oenCMD {
// public static void main(String[] args) {
//// openWinExe(null);
// openExe(null,"http://www.baidu.com");
// }
//用 Java 调用windows系统的exe文件，比如notepad，calc之类
public static void openWinExe(String command,String url) {
if(command==null ||command.equals("")){
command = "chrome "+url;
}
Runtime rn = Runtime.getRuntime();
Process p = null;
try {

p = rn.exec(command);
} catch (Exception e) {
System.out.println("Error win exec!");
}
}
//调用其他的可执行文件，例如：自己制作的exe，或是 下载 安装的软件.
public static void openExe(String pathAndName,String url) {
if(pathAndName==null || pathAndName.equals("")){
pathAndName="C:\\Users\\Administrator\\AppData\\Local\\Google\\Chrome\\Application\\chrome.exe";
}
if(url!=null && !url.equals("")){
pathAndName+=" ";
pathAndName+=url;
}
Runtime rn = Runtime.getRuntime();
Process p = null;
try {
p = rn.exec(pathAndName);
} catch (Exception e) {
System.out.println("Error exec!");
}
}
}