From 030f7971cee2aa77408678f51b2f11e1a451fbb7 Mon Sep 17 00:00:00 2001 From: MrShi <1878285526@qq.com> Date: 星期二, 14 十月 2025 18:26:22 +0800 Subject: [PATCH] 钉钉通知 --- server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsPushController.java | 66 ++++++++++++--------------------- 1 files changed, 24 insertions(+), 42 deletions(-) diff --git a/server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsPushController.java b/server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsPushController.java index b526e8e..41bc9e3 100644 --- a/server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsPushController.java +++ b/server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsPushController.java @@ -4,38 +4,21 @@ import com.doumee.api.BaseController; import com.doumee.core.annotation.pr.PreventRepeat; import com.doumee.core.exception.BusinessException; -import com.doumee.core.haikang.model.param.request.AcsDeviceListRequest; -import com.doumee.core.haikang.model.param.request.EventSubRequest; -import com.doumee.core.haikang.model.param.request.ParkListRequest; -import com.doumee.core.haikang.model.param.request.PrivilegeGroupRequest; -import com.doumee.core.haikang.model.param.request.event.acs.EventAcsRequest; -import com.doumee.core.haikang.model.param.request.event.parks.EventParkRequest; -import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest; -import com.doumee.core.model.ApiResponse; import com.doumee.core.utils.Constants; import com.doumee.core.wms.model.request.WmsActionNoticeRequest; +import com.doumee.core.wms.model.request.WmsBaseRequest; import com.doumee.core.wms.model.request.WmsInboundNoticeRequest; import com.doumee.core.wms.model.request.WmsOutboundNoticeRequest; import com.doumee.core.wms.model.response.WmsBaseResponse; -import com.doumee.service.business.WmsService; -import com.doumee.service.business.impl.hksync.HkSyncDeviceServiceImpl; -import com.doumee.service.business.impl.hksync.HkSyncParkServiceImpl; -import com.doumee.service.business.impl.hksync.HkSyncPrivilegeServiceImpl; -import com.doumee.service.business.impl.hksync.HkSyncPushServiceImpl; +import com.doumee.service.business.third.WmsService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; -import org.apache.commons.lang3.StringUtils; -import org.apache.shiro.authz.annotation.RequiresPermissions; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; - -import javax.servlet.http.HttpServletRequest; -import javax.servlet.http.HttpServletResponse; -import java.util.List; /** * @author 姹熻箘韫� @@ -51,64 +34,63 @@ private WmsService wmsService; @PreventRepeat - @ApiOperation("銆怌MS銆戞帹閫佸叆搴撳崟閫氱煡浠诲姟") + @ApiOperation("銆怶MS銆戞帹閫佸叆搴撳崟閫氱煡浠诲姟") @PostMapping("/push/inboundNotice") - public WmsBaseResponse inboundNotice(@RequestBody List<WmsInboundNoticeRequest> param) { + public WmsBaseResponse inboundNotice(@RequestBody WmsBaseRequest<WmsInboundNoticeRequest> param) { int success = Constants.ZERO; WmsBaseResponse result =null; try { result = wmsService.inboundNotice(param); }catch (BusinessException e){ - log.error("銆怌MS銆戞帹閫佸叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); success = Constants.ONE; }catch (Exception e){ - log.error("銆怌MS銆戞帹閫佸叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); e.printStackTrace(); success = Constants.ONE; }finally { wmsService.saveInterfaceLog("/wms/push/inboundNotice", "鎺ㄩ�佸叆搴撳崟閫氱煡浠诲姟",JSONObject.toJSONString(param), success, JSONObject.toJSONString(result),Constants.ONE); } - return result; } @PreventRepeat - @ApiOperation("銆怌MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟") + @ApiOperation("銆怶MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟") @PostMapping("/push/outboundNotice") - public WmsBaseResponse outboundNotice(@RequestBody List<WmsOutboundNoticeRequest> param) { + public WmsBaseResponse outboundNotice(@RequestBody WmsBaseRequest<WmsOutboundNoticeRequest> param) { int success = Constants.ZERO; WmsBaseResponse result =null; try { result = wmsService.outboundNotice(param); }catch (BusinessException e){ - log.error("銆怌MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); success = Constants.ONE; }catch (Exception e){ - log.error("銆怌MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); e.printStackTrace(); success = Constants.ONE; }finally { - wmsService.saveInterfaceLog("/wms/push/outboundNotice", "鎺ㄩ�佸嚭搴撳崟閫氱煡浠诲姟",JSONObject.toJSONString(param),success + wmsService.saveInterfaceLog("/wms/push/outboundNotice", "銆怶MS銆戞帹閫佸嚭搴撳崟閫氱煡浠诲姟",JSONObject.toJSONString(param),success , JSONObject.toJSONString(result),Constants.ONE); } return result; } @PreventRepeat - @ApiOperation("銆怌MS銆戞帹閫佸彇娑堝叆搴撳崟閫氱煡浠诲姟") + @ApiOperation("銆怶MS銆戞帹閫佸彇娑堝叆搴撳崟閫氱煡浠诲姟") @PostMapping("/push/cancelInbound") - public WmsBaseResponse cancelInbound(@RequestBody List<WmsActionNoticeRequest> param) { + public WmsBaseResponse cancelInbound(@RequestBody WmsBaseRequest<WmsActionNoticeRequest> param) { int success = Constants.ZERO; WmsBaseResponse result =null; try { result = wmsService.cancelInbound(param); }catch (BusinessException e){ - log.error("銆怌MS銆戞帹閫佸彇娑堝叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸彇娑堝叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); success = Constants.ONE; }catch (Exception e){ - log.error("銆怌MS銆戞帹閫佸彇娑堝叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸彇娑堝叆搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); e.printStackTrace(); success = Constants.ONE; }finally { @@ -118,39 +100,39 @@ return result; } @PreventRepeat - @ApiOperation("銆怌MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟") + @ApiOperation("銆怶MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟") @PostMapping("/push/cancelOutbound") - public WmsBaseResponse cancelOutbound(@RequestBody List<WmsActionNoticeRequest> param) { + public WmsBaseResponse cancelOutbound(@RequestBody WmsBaseRequest<WmsActionNoticeRequest> param) { int success = Constants.ZERO; WmsBaseResponse result =null; try { result = wmsService.cancelOutbound(param); }catch (BusinessException e){ - log.error("銆怌MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); success = Constants.ONE; }catch (Exception e){ - log.error("銆怌MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); e.printStackTrace(); success = Constants.ONE; }finally { - wmsService.saveInterfaceLog("/wms/push/cancelOutbound", "鎺ㄩ�佸彇娑堝嚭搴撳崟閫氱煡浠诲姟", + wmsService.saveInterfaceLog("/wms/push/cancelOutbound", "銆怲MS銆戞帹閫佸彇娑堝嚭搴撳崟閫氱煡浠诲姟", JSONObject.toJSONString(param), success, JSONObject.toJSONString(result),Constants.ONE); } return result; } @PreventRepeat - @ApiOperation("銆怌MS銆戞帹閫佸嚭鍏ュ簱浣滀笟瀹屾垚閫氱煡浠诲姟") + @ApiOperation("銆怶MS銆戞帹閫佸嚭鍏ュ簱浣滀笟瀹屾垚閫氱煡浠诲姟") @PostMapping("/push/doneTask") - public WmsBaseResponse doneTask(@RequestBody List<WmsActionNoticeRequest> param) { + public WmsBaseResponse doneTask(@RequestBody WmsBaseRequest<WmsActionNoticeRequest> param) { int success = Constants.ZERO; WmsBaseResponse result =null; try { result = wmsService.doneTask(param); }catch (BusinessException e){ - log.error("銆怌MS銆戞帹閫佸嚭鍏ュ簱浣滀笟瀹屾垚閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸嚭鍏ュ簱浣滀笟瀹屾垚閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); success = Constants.ONE; }catch (Exception e){ - log.error("銆怌MS銆戞帹閫佸嚭鍏ュ簱浣滀笟瀹屾垚閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); + log.error("銆怶MS銆戞帹閫佸嚭鍏ュ簱浣滀笟瀹屾垚閫氱煡浠诲姟===澶辫触锛�"+e.getMessage()); e.printStackTrace(); success = Constants.ONE; }finally { -- Gitblit v1.9.3