Merge branch 'developer' into 'master'

分享有礼补数据

See merge request !119

haoban-manage3-operation-web/src/main/java/com/gic/haoban/manage/web/controller/test/TestController.java

 package com.gic.haoban.manage.web.controller.test;
 
+import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.Page;
 import com.gic.commons.util.EntityUtil;
@@ -16,6 +17,7 @@ import com.gic.haoban.manage.web.qo.TestQo;
 import com.gic.haoban.manage.web.vo.TestVo;
 import com.gic.sharing.core.service.api.service.MqApiService;
 import org.apache.commons.lang3.StringUtils;
+import org.slf4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.RequestBody;
@@ -25,6 +27,8 @@ import org.springframework.web.bind.annotation.ResponseBody;
 import java.util.List;
 import java.util.Map;
 
+import static org.slf4j.LoggerFactory.getLogger;
+
 /**
  * Created 2018/12/17.
  *
@@ -34,7 +38,7 @@ import java.util.Map;
 @RequestMapping("/test")
 public class TestController extends WebBaseController {
 
-
+    private static final Logger logger = getLogger(TestController.class);
     @Autowired
     private TestApiService testApiService;
 
@@ -109,4 +113,26 @@ public class TestController extends WebBaseController {
         mqApiService.run(key);
         return resultResponse(HaoBanErrCode.ERR_1);
     }
+
+    /**
+     * 创建定时器
+     *
+     * @return
+     */
+    @RequestMapping("/sharing-import-batch")
+    @ResponseBody
+    public HaobanResponse sharingImportBatch(String key) {
+        if (StringUtils.isBlank(key)) {
+            return resultResponse(HaoBanErrCode.ERR_0);
+        }
+        JSONArray jsonArray = JSONArray.parseArray(key);
+        int num = jsonArray.size();
+        int i = 0;
+        for (Object obj : jsonArray) {
+            i = i + 1;
+            logger.info("执行num:" + i + ":total" + num);
+            mqApiService.run(JSONObject.toJSONString(obj));
+        }
+        return resultResponse(HaoBanErrCode.ERR_1);
+    }
 }