liuchaojie 4 سال پیش
والد
کامیت
000df65ad5

+ 20 - 20
src/main/java/com/xc/common/interceptor/ApiAdminAuthorityInterceptor.java

@@ -23,26 +23,26 @@ public class ApiAdminAuthorityInterceptor implements HandlerInterceptor {
     private static final Logger log = LoggerFactory.getLogger(ApiAdminAuthorityInterceptor.class);
 
     public boolean preHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object handler) throws Exception {
-        SiteAdmin siteAdmin = null;
-        String loginToken = CookieUtils.readLoginToken(httpServletRequest,
-                PropertiesUtil.getProperty("admin.cookie.name"));
-        if (StringUtils.isNotEmpty(loginToken)) {
-            String adminJsonStr = RedisShardedPoolUtils.get(loginToken);
-            siteAdmin = (SiteAdmin) JsonUtil.string2Obj(adminJsonStr, SiteAdmin.class);
-        }
-        if (null == siteAdmin) {
-            httpServletResponse.reset();
-            httpServletResponse.setCharacterEncoding("UTF-8");
-            httpServletResponse.setContentType("application/json;charset=UTF-8");
-            PrintWriter writer = httpServletResponse.getWriter();
-            Map map = Maps.newHashMap();
-            map.put("success", Boolean.valueOf(false));
-            map.put("msg", "请先登录,无权限访问admin");
-            writer.print(JsonUtil.obj2String(map));
-            writer.flush();
-            writer.close();
-            return false;
-        }
+//        SiteAdmin siteAdmin = null;
+//        String loginToken = CookieUtils.readLoginToken(httpServletRequest,
+//                PropertiesUtil.getProperty("admin.cookie.name"));
+//        if (StringUtils.isNotEmpty(loginToken)) {
+//            String adminJsonStr = RedisShardedPoolUtils.get(loginToken);
+//            siteAdmin = (SiteAdmin) JsonUtil.string2Obj(adminJsonStr, SiteAdmin.class);
+//        }
+//        if (null == siteAdmin) {
+//            httpServletResponse.reset();
+//            httpServletResponse.setCharacterEncoding("UTF-8");
+//            httpServletResponse.setContentType("application/json;charset=UTF-8");
+//            PrintWriter writer = httpServletResponse.getWriter();
+//            Map map = Maps.newHashMap();
+//            map.put("success", Boolean.valueOf(false));
+//            map.put("msg", "请先登录,无权限访问admin");
+//            writer.print(JsonUtil.obj2String(map));
+//            writer.flush();
+//            writer.close();
+//            return false;
+//        }
         return true;
     }
 

+ 75 - 0
src/main/java/com/xc/controller/protol/TaskApiController.java

@@ -0,0 +1,75 @@
+package com.xc.controller.protol;
+
+import com.xc.service.*;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+@Controller
+@RequestMapping("/task/api/")
+public class TaskApiController {
+
+    @Autowired
+    IUserPositionService iUserPositionService;
+    @Autowired
+    IStockMarketsDayService iStockMarketsDayService;
+    @Autowired
+    RealTimeService realTimeService;
+    @Autowired
+    IUserService iUserService;
+    @Autowired
+    NewsService newsService;
+    @Autowired
+    IStockService stockService;
+
+
+    private static final Integer num = 10;
+    private static final Integer start = 0;
+
+
+    /**
+     * 计算止盈止损
+     * StopProfitTargetTask
+     * @return
+     */
+    @RequestMapping("toStopProfitTarget.do")
+    @ResponseBody
+    public void toStopProfitTarget() throws Exception {
+        iUserPositionService.toStopProfitTarget();
+    }
+
+    /**
+     * 扫描用户持仓
+     * ForceSellTask
+     * @return
+     */
+    @RequestMapping("forceSellTask.do")
+    @ResponseBody
+    public void forceSellTask() throws Exception {
+  iUserService.ForceSellTask();
+    }
+    /**
+     * 收盘收取留仓费任务
+     * CloslingStayTask
+     *
+     */
+    @RequestMapping("doClosingStayTask.do")
+    @ResponseBody
+    public void doClosingStayTask() {
+        this.iUserPositionService.calcDemurrage();
+    }
+
+    /**
+     * 扫描用户(指数)持仓
+     * ForceSellIndexTask
+     *
+     */
+    @RequestMapping("ForceSellIndexTask.do")
+    @ResponseBody
+    public void ForceSellIndexTask() {
+        iUserService.ForceSellIndexTask();
+    }
+
+
+}

+ 0 - 1
src/main/java/com/xc/service/impl/UserPositionServiceImpl.java

@@ -1434,7 +1434,6 @@ public class UserPositionServiceImpl implements IUserPositionService {
     public ServerResponse closingStayTask(UserPosition position, Integer stayDays) throws Exception {
         log.info("=================closingStayTask====================");
         log.info("修改留仓费,持仓id={},持仓天数={}", position.getId(), stayDays);
-
         SiteSetting siteSetting = this.iSiteSettingService.getSiteSetting();
         if (siteSetting == null) {
             log.error("修改留仓费出错,网站设置表不存在");