查询商品撤销状态

src/main/java/cn/chjyj/szwh/job/QueryRevoGoodsStatus.java

@@ -0,0 +1,33 @@
+package cn.chjyj.szwh.job;
+
+import cn.chjyj.szwh.service.GoodsTaskService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.Calendar;
+
+/**
+ * 定时查询撤销结果
+ */
+public class QueryRevoGoodsStatus extends QuartzJobBean {
+    private static Log log = LogFactory.getLog(SzwhRevocationGoodsJob.class);
+
+    @Autowired
+    private GoodsTaskService goodsTaskService;
+
+    @Override
+    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
+        Calendar cal = Calendar.getInstance();
+        LocalDateTime localDateTime = LocalDateTime.now();
+        String nowstr = localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+        log.info("查询撤销结果:"+nowstr);
+        //
+        goodsTaskService.getRevocationGoods();
+    }
+}

src/main/java/cn/chjyj/szwh/job/SzwhRevocationGoodsJob.java

@@ -12,6 +12,9 @@ import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.Calendar;
 
+/**
+ * 定时获取撤销数据
+ */
 public class SzwhRevocationGoodsJob extends QuartzJobBean {
     private static Log log = LogFactory.getLog(SzwhRevocationGoodsJob.class);
 

src/main/java/cn/chjyj/szwh/service/GoodsTaskService.java

@@ -8,4 +8,9 @@ public interface GoodsTaskService {
      * 获取撤销委托信息
      */
     public void getRevocationGoods();
+
+    /**
+     * 查询撤销结果
+     */
+    public void queryRevocationGoods();
 }

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

@@ -47,7 +47,51 @@ public class GoodsTaskServiceImpl implements GoodsTaskService {
                     oplog.setMessage(sdf.format(new Date())+" 发布投送系统撤销委托");
                     operationLogMapper.addLog(oplog);
                 }
+            }
+        }
+    }
 
+    /**
+     * 查询撤销状态
+     */
+    @Override
+    public void queryRevocationGoods() {
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
+        JSONObject recvjson = SzwhApiUtils.queryGoodsStatus();
+        JSONObject dataJson = recvjson.getJSONObject("data");
+        if(!dataJson.isEmpty()){
+            JSONArray jsonArray = JSONArray.parseArray(dataJson.toJSONString());
+            for(int i=0;i<jsonArray.size();i++){
+                JSONObject jitem = (JSONObject) jsonArray.get(i);
+                String islicode = jitem.getString("isliCode");
+                //1:委托自己撤销,2:交易撤销
+                int revokeStatus= jitem.getInteger("revokeStatus");
+                //审核状态：0,未审核,1，通过；2，不通过
+                int verifyStatus=jitem.getInteger("verifyStatus");
+                if(verifyStatus==0){ //待审核
+                    continue;
+                }
+                //查询是否存在商品
+                Goods dbgoods =goodsMapper.getGoodsByIsliCode(islicode);
+                if(dbgoods!=null){
+                    String opmsg=sdf.format(new Date())+" ";
+                    //审核通过,更新对应的状态
+                    if(verifyStatus==1){
+                        int apout = dbgoods.getApplyOut()==1?1:0;
+                        String tmsg =(apout==1)?"申请撤销委托审核通过":"委托系统撤销委托";
+                        opmsg=opmsg+"";
+                    }else{
+                        opmsg=opmsg+"委托系统撤销委托";
+                    }
+                    //更新状态
+                    goodsMapper.updateRevocationGoods(islicode);
+                    //构建操作日志
+                    OperationLog oplog = new OperationLog();
+                    oplog.setType("goods");
+                    oplog.setLogid(dbgoods.getId());
+                    oplog.setMessage(opmsg);
+                    operationLogMapper.addLog(oplog);
+                }
             }
         }
     }