xioayue
/
szwh
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity
Browse Source

修正get请求方式

master
xyiege 3 years ago
parent
ef75f219e5
commit
8f5cd72dea
6 changed files with 99 additions and 94 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 163
      src/main/java/cn/chjyj/szwh/service/impl/GoodsServiceImpl.java
  2. 2
      src/main/java/cn/chjyj/szwh/service/impl/LoginServiceImpl.java
  3. 2
      src/main/java/cn/chjyj/szwh/service/impl/UserServiceImpl.java
  4. 18
      src/main/java/cn/chjyj/szwh/utils/RequestUtils.java
  5. 6
      src/main/java/cn/chjyj/szwh/utils/SzwhApiUtils.java
  6. 2
      src/test/java/cn/chjyj/szwh/ApiTest.java

163
src/main/java/cn/chjyj/szwh/service/impl/GoodsServiceImpl.java
View File

@ -84,95 +84,96 @@ public class GoodsServiceImpl implements GoodsService {
Map<String, Object> hmap = new HashMap();
hmap.put("entrust_token", sign);
// get 方式获取
JSONObject jsonObject = RequestUtils.GetData(apiurl, hmap);
// json的data节点
JSONArray jsonArray = jsonObject.getJSONArray("data");
JSONObject jsonObject = RequestUtils.GetData(apiurl, hmap,true);
// 产品详情地址
String gdurl = host + "/consign/exchange/v1/selectEntrustDetails";
// 循环查询商品的详情
for(int i=0;i<jsonArray.size();i++){
// 获取到sourceData字段信息
JSONObject sdjson = (JSONObject) jsonArray.get(i);
String nsdstr = sdjson.getString("sourceData");
if(nsdstr==null){
continue;
}else {
JSONObject nsdjson = JSONObject.parseObject(nsdstr);
// 从sourcedata节点中提取商品唯一编号
String goodsId = nsdjson.getString("identifier");
// 以identifier为主键查询详情
String gdetailUrl = gdurl + "/" + goodsId;
// 请求商品的详情
JSONObject gdJson = RequestUtils.GetData(gdetailUrl, hmap);
log.info(goodsId + "详情:" + gdJson);
//处理返回的结果
JSONArray gdArr = gdJson.getJSONArray("data");
// 如果goods表中存在记录，不进行操作
Goods tgoods = goodsMapper.getGoodsByIsli(goodsId);
if (tgoods != null) {
if(jsonObject!=null && jsonObject.containsKey("data") ) {
// json的data节点
JSONArray jsonArray = jsonObject.getJSONArray("data");
for (int i = 0; i < jsonArray.size(); i++) {
// 获取到sourceData字段信息
JSONObject sdjson = (JSONObject) jsonArray.get(i);
String nsdstr = sdjson.getString("sourceData");
if (nsdstr == null) {
continue;
}
// add goodsSource,循环插入 商品资源
for (int x = 0; x < gdArr.size(); x++) {
JSONObject gditem = (JSONObject) gdArr.get(x);
GoodsSource goodsSource = ApiGoodsUtils.jsonToGoodsSource(gditem, goodsId);
goodsSourceMapper.add(goodsSource);
}
// insertGoodsDetail
GoodsDetail goodsDetail = ApiGoodsUtils.jsonToGoodsDetail(nsdjson, sdjson);
// 返回商品详情
int gdid = goodsDetailMapper.add(goodsDetail);
//抽取target 字段中的json，转为jsonobject
JSONObject targetJson = nsdjson.getJSONObject("targetData");
//处理状态
int istatus = 0;
if (sdjson.getInteger("status") == 1 || sdjson.getInteger("status") == 4 ||
sdjson.getInteger("status") == 5) {
istatus = 1;
} else if (sdjson.getInteger("status") == 2) {
istatus = 2;
} else {
istatus = 4;
JSONObject nsdjson = JSONObject.parseObject(nsdstr);
// 从sourcedata节点中提取商品唯一编号
String goodsId = nsdjson.getString("identifier");
// 以identifier为主键查询详情
String gdetailUrl = gdurl + "/" + goodsId;
// 请求商品的详情
JSONObject gdJson = RequestUtils.GetData(gdetailUrl, hmap,true);
log.info(goodsId + "详情:" + gdJson);
//处理返回的结果
JSONArray gdArr = gdJson.getJSONArray("data");
// 如果goods表中存在记录，不进行操作
Goods tgoods = goodsMapper.getGoodsByIsli(goodsId);
if (tgoods != null) {
continue;
}
// add goodsSource,循环插入 商品资源
for (int x = 0; x < gdArr.size(); x++) {
JSONObject gditem = (JSONObject) gdArr.get(x);
GoodsSource goodsSource = ApiGoodsUtils.jsonToGoodsSource(gditem, goodsId);
goodsSourceMapper.add(goodsSource);
}
// insertGoodsDetail
GoodsDetail goodsDetail = ApiGoodsUtils.jsonToGoodsDetail(nsdjson, sdjson);
// 返回商品详情
int gdid = goodsDetailMapper.add(goodsDetail);
//抽取target 字段中的json，转为jsonobject
JSONObject targetJson = nsdjson.getJSONObject("targetData");
//处理状态
int istatus = 0;
if (sdjson.getInteger("status") == 1 || sdjson.getInteger("status") == 4 ||
sdjson.getInteger("status") == 5) {
istatus = 1;
} else if (sdjson.getInteger("status") == 2) {
istatus = 2;
} else {
istatus = 4;
}
//商品起止时间
String cstart = sdjson.getString("contractualPeriodStart");
String curTime = new SimpleDateFormat("HH:mm:ss").format(new Date());
String ncstart = cstart + " " + curTime;
//
String cend = nsdjson.getString("contractualPeriodEnd");
String ncend = cend + " 23:59:59";
Goods goods = new Goods();
//起止时间转为timestamp
goods.setContractualStartTime(Timestamp.valueOf(ncstart));
goods.setContractualtimeEndTime(Timestamp.valueOf(ncend));
goods.setGoodsDetailId(gdid);
goods.setContractStatus(nsdjson.getInteger("contractStatus"));
goods.setGoodsStatus(istatus);
goods.setOldStatus(0); // 默认为0
goods.setEntrustStatus(sdjson.getInteger("status"));
//
goods.setUserIslicode(targetJson.getString("identifier"));
goods.setUsername(targetJson.getString("titleName"));
goods.setIsLicode(sdjson.getString("isliCode"));
goods.setGoodsIslicode(nsdjson.getString("identifier"));
goods.setRecommendSort(1); // 默认排序1
// 添加,返回当前的编号
int ret_gid = goodsMapper.addGoods(goods);
//添加操作日志
OperationLog oplog = new OperationLog();
oplog.setLogid(goods.getId());
String nowStr = sdf.format(new Date());
String message = nowStr + " 发布标的成功";
oplog.setMessage(message);
oplog.setType("goods");
// 日志入库
operationLogMapper.addLog(oplog);
}
//商品起止时间
String cstart = sdjson.getString("contractualPeriodStart");
String curTime = new SimpleDateFormat("HH:mm:ss").format(new Date());
String ncstart = cstart + " " + curTime;
//
String cend = nsdjson.getString("contractualPeriodEnd");
String ncend = cend + " 23:59:59";
Goods goods = new Goods();
//起止时间转为timestamp
goods.setContractualStartTime(Timestamp.valueOf(ncstart));
goods.setContractualtimeEndTime(Timestamp.valueOf(ncend));
goods.setGoodsDetailId(gdid);
goods.setContractStatus(nsdjson.getInteger("contractStatus"));
goods.setGoodsStatus(istatus);
goods.setOldStatus(0); // 默认为0
goods.setEntrustStatus(sdjson.getInteger("status"));
//
goods.setUserIslicode(targetJson.getString("identifier"));
goods.setUsername(targetJson.getString("titleName"));
goods.setIsLicode(sdjson.getString("isliCode"));
goods.setGoodsIslicode(nsdjson.getString("identifier"));
goods.setRecommendSort(1); // 默认排序1
// 添加,返回当前的编号
int ret_gid = goodsMapper.addGoods(goods);
//添加操作日志
OperationLog oplog = new OperationLog();
oplog.setLogid(goods.getId());
String nowStr = sdf.format(new Date());
String message = nowStr + " 发布标的成功";
oplog.setMessage(message);
oplog.setType("goods");
// 日志入库
operationLogMapper.addLog(oplog);
// 计算器增加1
count++;
}
// 计算器增加1
count++;
}
return count;
}

2
src/main/java/cn/chjyj/szwh/service/impl/LoginServiceImpl.java
View File

@ -45,7 +45,7 @@ public class LoginServiceImpl implements LoginService {
hmap.put("Content-Type","application/json");
//执行请求
JSONObject jsonObject = RequestUtils.GetData(path,hmap);
JSONObject jsonObject = RequestUtils.GetData(path,hmap,true);
log.debug("request result:"+jsonObject.toString());
String code = jsonObject.getString("resultCode");

2
src/main/java/cn/chjyj/szwh/service/impl/UserServiceImpl.java
View File

@ -68,7 +68,7 @@ public class UserServiceImpl implements UserService {
//hmap.put("Content-Type","application/json");
//执行请求
JSONObject json = RequestUtils.GetData(userUrl,hmap);
JSONObject json = RequestUtils.GetData(userUrl,hmap,true);
log.info("request result:"+json);
// json 内容转为map
Map rmap = JSONObject.parseObject(json.getString("data"));

18
src/main/java/cn/chjyj/szwh/utils/RequestUtils.java
View File

@ -31,9 +31,10 @@ public class RequestUtils {
* 能设置请求头的get方式
* @param surl
* @param map
* @param wflag 是否写入json文件
* @return
*/
public static JSONObject GetData(String surl, Map<String,Object> map){
public static JSONObject GetData(String surl, Map<String,Object> map,boolean wflag){
JSONObject jsonObject = new JSONObject();
try{
URL url = new URL(surl);
@ -51,13 +52,16 @@ public class RequestUtils {
InputStream inputStream = httpcon.getInputStream();
//请求结果写入
String filename =String.valueOf(Calendar.getInstance().getTimeInMillis());
SzFileUtils.createFile(inputStream,filename);
//字节转为utf-8
String message=SzFileUtils.readJson(filename);
if(message!=null){
jsonObject = JSONObject.parseObject(message);
if(wflag){
SzFileUtils.createFile(inputStream,filename);
//字节转为utf-8
String message=SzFileUtils.readJson(filename);
if(message!=null){
jsonObject = JSONObject.parseObject(message);
logger.info("respone message :"+message);
}
logger.info("respone message is null");
}
logger.info("respone message :"+message);
}catch (IOException ex){
// 罗列出明细错误
logger.error("请求错误:"+ex);

6
src/main/java/cn/chjyj/szwh/utils/SzwhApiUtils.java
View File

@ -37,7 +37,7 @@ public class SzwhApiUtils {
hmap.put("token",sign);
hmap.put("Content-Type","application/json");
//执行请求
JSONObject json = RequestUtils.GetData(userUrl,hmap);
JSONObject json = RequestUtils.GetData(userUrl,hmap,false);
log.info("request result:"+json);
return json;
}
@ -78,7 +78,7 @@ public class SzwhApiUtils {
System.out.println("token :"+sign);
Map hmap = new HashMap();
hmap.put("entrust_token",sign);
JSONObject json = RequestUtils.GetData(url,hmap);
JSONObject json = RequestUtils.GetData(url,hmap,false);
return json;
}
@ -94,7 +94,7 @@ public class SzwhApiUtils {
String sign=SignUtils.createSign("entrust");
Map hmap = new HashMap();
hmap.put("entrust_token",sign);
JSONObject json = RequestUtils.GetData(url,hmap);
JSONObject json = RequestUtils.GetData(url,hmap,true);
return json;
}
/**

2
src/test/java/cn/chjyj/szwh/ApiTest.java
View File

@ -64,7 +64,7 @@ public class ApiTest {
// 请求头
Map<String, Object> hmap = new HashMap();
hmap.put("entrust_token", sign);
JSONObject jsonObject = RequestUtils.GetData(url, hmap);
JSONObject jsonObject = RequestUtils.GetData(url, hmap,true);
// 抽取data
// String data = jsonObject.getString("data");
JSONArray jsonArray = jsonObject.getJSONArray("data");

Write Preview
Loading…
Cancel
Save