增加对撤销结果处理

src/main/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImpl.java

@@ -30,9 +30,9 @@ public class GoodsTaskServiceImpl implements GoodsTaskService {
     @Override
     public void getRevocationGoods() {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-
+        //获取接口数据
         JSONObject recvjson = SzwhApiUtils.revocationGoods();
-        //JSONObject dataJson = recvjson.getJSONObject("data");
+        //提取返回数据中的data 字段
         String datajsonStr= recvjson.getString("data");
         if(StringUtils.isNotBlank(datajsonStr)){
             JSONArray jsonArray = JSONArray.parseArray(datajsonStr);
@@ -41,6 +41,7 @@ public class GoodsTaskServiceImpl implements GoodsTaskService {
                 String islicode = jitem.getString("isliCode");
                 //查询是否存在商品
                 Goods dbgoods =goodsMapper.getGoodsByIsliCode(islicode);
+                // 如果商品存在，执行撤销操作
                 if(dbgoods!=null){
                     //更新状态
                     goodsMapper.updateRevocationGoods(islicode);
@@ -61,10 +62,12 @@ public class GoodsTaskServiceImpl implements GoodsTaskService {
     @Override
     public void queryRevocationGoods() {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
+        // 接口查询撤销数据
         JSONObject recvjson = SzwhApiUtils.queryGoodsStatus();
-        JSONObject dataJson = recvjson.getJSONObject("data");
+        //提取返回数据中的data 字段
-        if(!dataJson.isEmpty()){
+        String datajsonStr= recvjson.getString("data");
-            JSONArray jsonArray = JSONArray.parseArray(dataJson.toJSONString());
+        if(StringUtils.isNotBlank(datajsonStr)){
+            JSONArray jsonArray = JSONArray.parseArray(datajsonStr);
             for(int i=0;i<jsonArray.size();i++){
                 JSONObject jitem = (JSONObject) jsonArray.get(i);
                 String islicode = jitem.getString("isliCode");

src/test/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImplTest.java

@@ -0,0 +1,36 @@
+package cn.chjyj.szwh.service.impl;
+
+import cn.chjyj.szwh.service.GoodsTaskService;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+import static org.junit.Assert.*;
+
+/**
+ * 商品服务任务测试用例
+ */
+@SpringBootTest
+@RunWith(SpringJUnit4ClassRunner.class)
+public class GoodsTaskServiceImplTest {
+    @Autowired
+    private GoodsTaskService goodsTaskService;
+
+    /**
+     * 获取撤销数据
+     */
+    @Test
+    public void getRevocationGoods() {
+        goodsTaskService.getRevocationGoods();
+    }
+
+    /**
+     * 查询撤销数据
+     */
+    @Test
+    public void queryRevocationGoods() {
+        goodsTaskService.queryRevocationGoods();
+    }
+}