From 66b84de58e3efae14c1e258ee716e02ad9557497 Mon Sep 17 00:00:00 2001 From: doum <doum> Date: 星期四, 09 十月 2025 08:48:50 +0800 Subject: [PATCH] 最新版本541200007 --- server/visits/admin_timer/src/main/java/com/doumee/api/PlatformJobController.java | 61 +++++++++++++++++++----------- 1 files changed, 38 insertions(+), 23 deletions(-) diff --git a/server/visits/admin_timer/src/main/java/com/doumee/api/PlatformJobController.java b/server/visits/admin_timer/src/main/java/com/doumee/api/PlatformJobController.java index 433cdd1..53bf7a9 100644 --- a/server/visits/admin_timer/src/main/java/com/doumee/api/PlatformJobController.java +++ b/server/visits/admin_timer/src/main/java/com/doumee/api/PlatformJobController.java @@ -1,31 +1,21 @@ package com.doumee.api; -import com.alibaba.fastjson.JSONObject; -import com.doumee.biz.system.SystemDictDataBiz; -import com.doumee.core.model.ApiResponse; -import com.doumee.core.utils.Constants; -import com.doumee.core.utils.HttpsUtil; -import com.doumee.core.wx.WXConstant; -import com.doumee.dao.system.model.SystemDictData; +import com.doumee.core.annotation.pr.PreventRepeat; +import com.doumee.service.business.third.model.ApiResponse; import com.doumee.service.business.PlatformJobService; -import com.doumee.service.system.SystemDictDataService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; -import org.apache.shiro.SecurityUtils; -import org.apache.shiro.mgt.DefaultSecurityManager; +import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; - -import java.util.Date; -import java.util.Objects; /** * @author 姹熻箘韫� * @date 2023/11/30 15:33 */ +@Slf4j @Api(tags = "鏈堝彴浣滀笟瀹氭椂") @RestController @RequestMapping("/timer/platformJob") @@ -34,21 +24,46 @@ @Autowired private PlatformJobService platformJobService; - @ApiOperation("瓒呮椂鎶ヨ鏁版嵁") - @GetMapping("/platformJobTimeOut") - public ApiResponse platformJobTimeOut() { + + @ApiOperation("鏈堝彴鍋滈潬瓒呮椂鎶ヨ涓氬姟") + @PostMapping("/platformJobTimer") + public ApiResponse platformJobTimer() { platformJobService.timeOutReport(); - return ApiResponse.success("瓒呮椂鎶ヨ鏁版嵁"); + return ApiResponse.success("鏈堝彴鍋滈潬瓒呮椂鎶ヨ涓氬姟"); + } + @ApiOperation("鏈堝彴浣滀笟妫�鏌ョ數瀛愰攣涓婇攣鐘舵��") + @PostMapping("/platformCheckWmsLockStatus") + public ApiResponse checkWmsLockStatus() { + platformJobService.checkWmsLockStatus(); + return ApiResponse.success("鏈堝彴鍋滈潬瓒呮椂鎶ヨ涓氬姟"); } - @ApiOperation("瓒呮椂鑷姩杩囧彿") - @GetMapping("/timeOutCallIn") - public ApiResponse timeOutCallIn() { + @ApiOperation("鏈堝彴浣滀笟瓒呮椂鎶ヨ涓氬姟") + @PostMapping("/platformJobWorkTimeOut") + public ApiResponse platformJobWorkTimeOut() { + platformJobService.timeOutWork(); + return ApiResponse.success("鏈堝彴浣滀笟瓒呮椂鎶ヨ涓氬姟"); + } + + + @ApiOperation("鏈堝彴绛夊緟浣滀笟瓒呮椂涓氬姟") + @PostMapping("/platformJobWaitTimeOut") + public ApiResponse platformJobWaitTimeOut() { platformJobService.timeOutCallIn(); - return ApiResponse.success("鑷姩杩囧彿"); + return ApiResponse.success("鏈堝彴绛夊緟浣滀笟瓒呮椂涓氬姟"); } + @PreventRepeat(interval = 2000) + @ApiOperation("鏈堝彴浠婃棩浣滀笟鏈畬鎴愰�氱煡瀹氭椂") + @PostMapping("/sendUnFinishNotice") + public synchronized ApiResponse sendUnFinishNotice() { + log.error("========鏈堝彴浠婃棩浣滀笟鏈畬鎴愰�氱煡瀹氭椂============寮�濮�"+System.currentTimeMillis()+""); + platformJobService.sendUnFinishNotice(); + log.error("========鏈堝彴浠婃棩浣滀笟鏈畬鎴愰�氱煡瀹氭椂============缁撴潫"+System.currentTimeMillis()+""); + return ApiResponse.success("鏈堝彴浠婃棩浣滀笟澶栧畬鎴愰�氱煡瀹氭椂"); + } + } -- Gitblit v1.9.3