diff --git a/src/main/java/cn/chjyj/szwh/controller/api/OrderController.java b/src/main/java/cn/chjyj/szwh/controller/api/OrderController.java
index 39be3b8..e092217 100644
--- a/src/main/java/cn/chjyj/szwh/controller/api/OrderController.java
+++ b/src/main/java/cn/chjyj/szwh/controller/api/OrderController.java
@@ -1,13 +1,17 @@
 package cn.chjyj.szwh.controller.api;
 
 import cn.chjyj.szwh.bean.Order;
+import cn.chjyj.szwh.bean.User;
 import cn.chjyj.szwh.controller.BaseController;
 import cn.chjyj.szwh.service.OrderService;
+import cn.chjyj.szwh.service.UserService;
+import cn.chjyj.szwh.utils.RedisUtils;
 import com.alibaba.fastjson2.JSONObject;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -21,6 +25,8 @@ import java.util.Map;
 public class OrderController extends BaseController {
     @Autowired
     private OrderService orderService;
+    @Autowired
+    private UserService userService;
 
     /**
      * 获取订单信息
@@ -80,10 +86,21 @@ public class OrderController extends BaseController {
      * @return
      */
     @RequestMapping("/createOrder")
-    public JSONObject createOrder(@RequestBody String reqString) {
+    public JSONObject createOrder(@RequestBody String reqString, HttpServletRequest request) {
+        String msg="";
+        int code=400;
+        String sign = request.getHeader("sign");
+        //redis中是否存在
+        String r_key="createOrder_"+sign;
+        if(StringUtils.isNotEmpty(RedisUtils.get(r_key))){
+            msg="请勿重复提交";
+            code=400;
+        }
         if(StringUtils.isBlank(reqString)){
             JSONObject json = JSONObject.parseObject(reqString);
-
+            String user_isli = json.getString("user_isli");
+            //查找对应的用户
+            User dbuser = userService.getUserByIsli(user_isli);
         }
         return jsonObject;
     }
diff --git a/src/main/java/cn/chjyj/szwh/task/TaskInit.java b/src/main/java/cn/chjyj/szwh/task/TaskInit.java
index 79a87f6..84f5964 100644
--- a/src/main/java/cn/chjyj/szwh/task/TaskInit.java
+++ b/src/main/java/cn/chjyj/szwh/task/TaskInit.java
@@ -1,6 +1,7 @@
 package cn.chjyj.szwh.task;
 
 import cn.chjyj.szwh.job.OrderJob;
+import cn.chjyj.szwh.job.QueryRevoGoodsStatus;
 import cn.chjyj.szwh.job.SzwhJob;
 import cn.chjyj.szwh.job.SzwhRevocationGoodsJob;
 import org.quartz.*;
@@ -41,6 +42,18 @@ public class TaskInit implements ApplicationRunner {
         scheduler.scheduleJob(jobDetail, trigger);
 
         //获取商品的撤销状态
+        JobDetail qrevoJob = JobBuilder.newJob(QueryRevoGoodsStatus.class)
+                .withIdentity(sid+"queryRevojob")
+                .storeDurably()
+                .build();
+        Trigger qrevoTriger =TriggerBuilder.newTrigger()
+                .forJob(qrevoJob)
+                .withIdentity(sid+"queryRevojobTrigger")
+                .withSchedule(CronScheduleBuilder.cronSchedule("0/15 * * * * ? * "))
+                .startNow()
+                .build();
+
+        // 批量处理撤销商品状态
         JobDetail revojob = JobBuilder.newJob(SzwhRevocationGoodsJob.class)
                 .withIdentity(sid+"02")
                 .storeDurably()