最新版本

jiangping

2024-08-13 e669ae9c74cd808e7ca8fb066d59b47296467b0e

最新版本

 server/db/business.platform_reason.permissions.sql

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,6 @@
INSERT INTO `SYSTEM_PERMISSION`(`CODE`, `NAME`, `REMARK`, `FIXED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`) VALUES ('business:platformreason:create', '新建月台_入园原因信息表', '', 0, 1, CURRENT_TIMESTAMP, NULL, NULL, 0);
INSERT INTO `SYSTEM_PERMISSION`(`CODE`, `NAME`, `REMARK`, `FIXED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`) VALUES ('business:platformreason:delete', '删除月台_入园原因信息表', '', 0, 1, CURRENT_TIMESTAMP, NULL, NULL, 0);
INSERT INTO `SYSTEM_PERMISSION`(`CODE`, `NAME`, `REMARK`, `FIXED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`) VALUES ('business:platformreason:update', '修改月台_入园原因信息表', '', 0, 1, CURRENT_TIMESTAMP, NULL, NULL, 0);
INSERT INTO `SYSTEM_PERMISSION`(`CODE`, `NAME`, `REMARK`, `FIXED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`) VALUES ('business:platformreason:query', '查询月台_入园原因信息表', '', 0, 1, CURRENT_TIMESTAMP, NULL, NULL, 0);
INSERT INTO `SYSTEM_PERMISSION`(`CODE`, `NAME`, `REMARK`, `FIXED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`) VALUES ('business:platformreason:exportExcel', '导出月台_入园原因信息表(Excel)', '', 0, 1, CURRENT_TIMESTAMP, NULL, NULL, 0);


 server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/HkSyncController.java

@@ -7,6 +7,8 @@
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.parks.EventPlatCarstatusRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventPlatWorkstatusRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.model.ApiResponse;
import com.doumee.service.business.impl.hksync.HkSyncDeviceServiceImpl;
@@ -93,4 +95,16 @@
         hkSyncPushService.cancelEventSub();
        return ApiResponse.success(null);
    }
    @ApiOperation("【海康】月台工作状态事件推送")
    @PostMapping("/platform/workstatus")
    public ApiResponse workstatus(@RequestBody EventPlatWorkstatusRequest param, HttpServletResponse response) {
         hkSyncPushService.dealWorkstatusEvent(param,response);
        return ApiResponse.success(null);
    }
    @ApiOperation("【海康】月台车辆状态事件推送")
    @PostMapping("/platform/carstatus")
    public ApiResponse carstatus(@RequestBody EventPlatCarstatusRequest param, HttpServletResponse response) {
         hkSyncPushService.dealCarstatusEvent(param,response);
        return ApiResponse.success(null);
    }
}

 server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/PlatformReasonController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,90 @@
package com.doumee.api.business;

import com.doumee.api.BaseController;
import com.doumee.core.annotation.excel.ExcelExporter;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.PageData;
import com.doumee.dao.business.model.PlatformReason;
import com.doumee.service.business.PlatformReasonService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.shiro.authz.annotation.RequiresPermissions;    
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;

import java.util.ArrayList;
import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/13 14:08
 */
@Api(tags = "月台_入园原因信息表")
@RestController
@RequestMapping("/business/platformReason")
public class PlatformReasonController extends BaseController {

    @Autowired
    private PlatformReasonService platformReasonService;

    @PreventRepeat
    @ApiOperation("新建")
    @PostMapping("/create")
    @RequiresPermissions("business:platformreason:create")
    public ApiResponse create(@RequestBody PlatformReason platformReason) {
        return ApiResponse.success(platformReasonService.create(platformReason));
    }

    @ApiOperation("根据ID删除")
    @GetMapping("/delete/{id}")
    @RequiresPermissions("business:platformreason:delete")
    public ApiResponse deleteById(@PathVariable Integer id) {
        platformReasonService.deleteById(id);
        return ApiResponse.success(null);
    }

    @ApiOperation("批量删除")
    @GetMapping("/delete/batch")
    @RequiresPermissions("business:platformreason:delete")
    public ApiResponse deleteByIdInBatch(@RequestParam String ids) {
        String [] idArray = ids.split(",");
        List<Integer> idList = new ArrayList<>();
        for (String id : idArray) {
            idList.add(Integer.valueOf(id));
        }
        platformReasonService.deleteByIdInBatch(idList);
        return ApiResponse.success(null);
    }

    @ApiOperation("根据ID修改")
    @PostMapping("/updateById")
    @RequiresPermissions("business:platformreason:update")
    public ApiResponse updateById(@RequestBody PlatformReason platformReason) {
        platformReasonService.updateById(platformReason);
        return ApiResponse.success(null);
    }

    @ApiOperation("分页查询")
    @PostMapping("/page")
    @RequiresPermissions("business:platformreason:query")
    public ApiResponse<PageData<PlatformReason>> findPage (@RequestBody PageWrap<PlatformReason> pageWrap) {
        return ApiResponse.success(platformReasonService.findPage(pageWrap));
    }

    @ApiOperation("导出Excel")
    @PostMapping("/exportExcel")
    @RequiresPermissions("business:platformreason:exportExcel")
    public void exportExcel (@RequestBody PageWrap<PlatformReason> pageWrap, HttpServletResponse response) {
        ExcelExporter.build(PlatformReason.class).export(platformReasonService.findPage(pageWrap).getRecords(), "月台_入园原因信息表", response);
    }

    @ApiOperation("根据ID查询")
    @GetMapping("/{id}")
    @RequiresPermissions("business:platformreason:query")
    public ApiResponse findById(@PathVariable Integer id) {
        return ApiResponse.success(platformReasonService.findById(id));
    }
}

 server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsInterfaceLogController.java

ÎļþÃû´Ó server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/InterfaceLogController.java ÐÞ¸Ä
@@ -5,11 +5,14 @@
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.PageWrap;
import com.doumee.core.model.PageData;
import com.doumee.dao.business.WmsInterfaceLogMapper;
import com.doumee.dao.business.model.InterfaceLog;
import com.doumee.dao.business.model.WmsInterfaceLog;
import com.doumee.service.business.InterfaceLogService;
import com.doumee.service.business.WmsInterfaceLogService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.apache.shiro.authz.annotation.RequiresPermissions;    
import org.apache.shiro.authz.annotation.RequiresPermissions;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletResponse;
@@ -22,19 +25,19 @@
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
@Api(tags = "三方平台接口交互记录")
@Api(tags = "WMS平台接口交互记录")
@RestController
@RequestMapping("/business/interfaceLog")
public class InterfaceLogController extends BaseController {
@RequestMapping("/business/wmsInterfaceLog")
public class WmsInterfaceLogController extends BaseController {

    @Autowired
    private InterfaceLogService interfaceLogService;
    private WmsInterfaceLogService interfaceLogService;

    @PreventRepeat
    @ApiOperation("新建")
    @PostMapping("/create")
    @RequiresPermissions("business:interfacelog:create")
    public ApiResponse create(@RequestBody InterfaceLog interfaceLog) {
    public ApiResponse create(@RequestBody WmsInterfaceLog interfaceLog) {
        return ApiResponse.success(interfaceLogService.create(interfaceLog));
    }

@@ -62,7 +65,7 @@
    @ApiOperation("根据ID修改")
    @PostMapping("/updateById")
    @RequiresPermissions("business:interfacelog:update")
    public ApiResponse updateById(@RequestBody InterfaceLog interfaceLog) {
    public ApiResponse updateById(@RequestBody WmsInterfaceLog interfaceLog) {
        interfaceLogService.updateById(interfaceLog);
        return ApiResponse.success(null);
    }
@@ -70,21 +73,21 @@
    @ApiOperation("分页查询")
    @PostMapping("/page")
    @RequiresPermissions("business:interfacelog:query")
    public ApiResponse<PageData<InterfaceLog>> findPage (@RequestBody PageWrap<InterfaceLog> pageWrap) {
    public ApiResponse<PageData<WmsInterfaceLog>> findPage (@RequestBody PageWrap<WmsInterfaceLog> pageWrap) {
        return ApiResponse.success(interfaceLogService.findPage(pageWrap));
    }

    @ApiOperation("导出Excel")
    @PostMapping("/exportExcel")
    @RequiresPermissions("business:interfacelog:exportExcel")
    public void exportExcel (@RequestBody PageWrap<InterfaceLog> pageWrap, HttpServletResponse response) {
        ExcelExporter.build(InterfaceLog.class).export(interfaceLogService.findPage(pageWrap).getRecords(), "三方平台接口交互记录", response);
    public void exportExcel (@RequestBody PageWrap<WmsInterfaceLog> pageWrap, HttpServletResponse response) {
        ExcelExporter.build(WmsInterfaceLog.class).export(interfaceLogService.findPage(pageWrap).getRecords(), "三方平台接口交互记录", response);
    }

    @ApiOperation("根据ID查询")
    @GetMapping("/{id}")
    @RequiresPermissions("business:interfacelog:query")
    public ApiResponse findById(@PathVariable Integer id) {
    public ApiResponse<WmsInterfaceLog> findById(@PathVariable Integer id) {
        return ApiResponse.success(interfaceLogService.findById(id));
    }
}

 server/visits/dmvisit_admin/src/main/java/com/doumee/api/business/WmsPushController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,83 @@
package com.doumee.api.business;

import com.doumee.api.BaseController;
import com.doumee.core.annotation.pr.PreventRepeat;
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.wms.model.request.WmsActionNoticeRequest;
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 io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
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 æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
@Api(tags = "WMS平台数据推送接口")
@RestController
@RequestMapping("/wms")
public class WmsPushController extends BaseController {

    @Autowired
    private WmsService wmsService;

    @PreventRepeat
    @ApiOperation("【CMS】推送入库单通知任务")
    @PostMapping("/push/inboundNotice")
    public WmsBaseResponse inboundNotice(@RequestBody List<WmsInboundNoticeRequest> param) {
        WmsBaseResponse result = wmsService.inboundNotice(param);
        return result;
    }

    @PreventRepeat
    @ApiOperation("【CMS】推送出库单通知任务")
    @PostMapping("/push/outboundNotice")
    public WmsBaseResponse outboundNotice(@RequestBody List<WmsOutboundNoticeRequest> param) {
        WmsBaseResponse result = wmsService.outboundNotice(param);
        return result;
    }
    @PreventRepeat
    @ApiOperation("【CMS】推送取消入库单通知任务")
    @PostMapping("/push/cancelInbound")
    public WmsBaseResponse cancelInbound(@RequestBody List<WmsActionNoticeRequest> param) {
        WmsBaseResponse result = wmsService.cancelInbound(param);
        return result;
    }
    @PreventRepeat
    @ApiOperation("【CMS】推送取消出库单通知任务")
    @PostMapping("/push/cancelOutbound")
    public WmsBaseResponse cancelOutbound(@RequestBody List<WmsActionNoticeRequest> param) {
        WmsBaseResponse result = wmsService.cancelOutbound(param);
        return result;
    }
    @PreventRepeat
    @ApiOperation("【CMS】推送出入库作业完成通知任务")
    @PostMapping("/push/doneTask")
    public WmsBaseResponse doneTask(@RequestBody List<WmsActionNoticeRequest> param) {
        WmsBaseResponse result = wmsService.doneTask(param);
        return result;
    }
}

 server/visits/dmvisit_admin/src/main/java/com/doumee/cloud/admin/PlatformReasonCloudController.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,91 @@
package com.doumee.cloud.admin;

import com.doumee.api.BaseController;
import com.doumee.config.annotation.CloudRequiredPermission;
import com.doumee.core.annotation.excel.ExcelExporter;
import com.doumee.core.annotation.pr.PreventRepeat;
import com.doumee.core.model.ApiResponse;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.dao.business.model.PlatformReason;
import com.doumee.service.business.PlatformReasonService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import javax.servlet.http.HttpServletResponse;
import java.util.ArrayList;
import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/13 14:08
 */
@Api(tags = "月台_入园原因信息表")
@RestController
@RequestMapping(Constants.CLOUD_SERVICE_URL_INDEX+"/business/platformReason")
public class PlatformReasonCloudController extends BaseController {

    @Autowired
    private PlatformReasonService platformReasonService;

    @PreventRepeat
    @ApiOperation("新建")
    @PostMapping("/create")
    @CloudRequiredPermission("business:platformreason:create")
    public ApiResponse create(@RequestBody PlatformReason platformReason,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        return ApiResponse.success(platformReasonService.create(platformReason));
    }

    @ApiOperation("根据ID删除")
    @GetMapping("/delete/{id}")
    @CloudRequiredPermission("business:platformreason:delete")
    public ApiResponse deleteById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        platformReasonService.deleteById(id);
        return ApiResponse.success(null);
    }

    @ApiOperation("批量删除")
    @GetMapping("/delete/batch")
    @CloudRequiredPermission("business:platformreason:delete")
    public ApiResponse deleteByIdInBatch(@RequestParam String ids,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){
        String [] idArray = ids.split(",");
        List<Integer> idList = new ArrayList<>();
        for (String id : idArray) {
            idList.add(Integer.valueOf(id));
        }
        platformReasonService.deleteByIdInBatch(idList);
        return ApiResponse.success(null);
    }

    @ApiOperation("根据ID修改")
    @PostMapping("/updateById")
    @CloudRequiredPermission("business:platformreason:update")
    public ApiResponse updateById(@RequestBody PlatformReason platformReason,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        platformReasonService.updateById(platformReason);
        return ApiResponse.success(null);
    }

    @ApiOperation("分页查询")
    @PostMapping("/page")
    @CloudRequiredPermission("business:platformreason:query")
    public ApiResponse<PageData<PlatformReason>> findPage (@RequestBody PageWrap<PlatformReason> pageWrap,@RequestHeader(Constants.HEADER_USER_TOKEN) String token){
        return ApiResponse.success(platformReasonService.findPage(pageWrap));
    }

    @ApiOperation("导出Excel")
    @PostMapping("/exportExcel")
    @CloudRequiredPermission("business:platformreason:exportExcel")
    public void exportExcel (@RequestBody PageWrap<PlatformReason> pageWrap, HttpServletResponse response,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        ExcelExporter.build(PlatformReason.class).export(platformReasonService.findPage(pageWrap).getRecords(), "月台_入园原因信息表", response);
    }

    @ApiOperation("根据ID查询")
    @GetMapping("/{id}")
    @CloudRequiredPermission("business:platformreason:query")
    public ApiResponse findById(@PathVariable Integer id,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) {
        return ApiResponse.success(platformReasonService.findById(id));
    }
}

 server/visits/dmvisit_admin/src/main/java/com/doumee/service/impl/HkSyncEventServiceImpl.java

@@ -106,6 +106,17 @@
        HKService.cancelEventSub(param);//先取消
        HKService.eventSub(param);//门禁事件

        param.setEventDest(path+"/platform/workstatus");
        param.setEventTypes(new Integer[]{HKConstants.EventTypes.PLATFORM_WORKSTATUS.getKey()});
        HKService.cancelEventSub(param);//先取消
        HKService.eventSub(param);//月台工作状态事件


        param.setEventDest(path+"/platform/carstatus");
        param.setEventTypes(new Integer[]{HKConstants.EventTypes.PLATFORM_CAR_STATUS.getKey()});
        HKService.cancelEventSub(param);//先取消
        HKService.eventSub(param);//月台车辆状态事件

    }
    /**
     * å–消订阅门禁事件、访客事件、和停车场事件

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKConstants.java

@@ -236,7 +236,9 @@
        VISIT_SIGN_IN(1392513025, "访客登记"  ),
        VISIT_SIGN_OUT(1392513026, "访客签离"  ),
        DOOR_FACE_AUTH_FAIL(197163, "人脸认证失败"  ),
        DOOR_FACE_AUTH_SUCCESS(196893, "人脸认证通过"  )
        DOOR_FACE_AUTH_SUCCESS(196893, "人脸认证通过"  ),
        PLATFORM_WORKSTATUS(483329, "月台工作状态事件"  ),
        PLATFORM_CAR_STATUS(487425, "月台车辆状态事件"  )
        ;
        // æˆå‘˜å˜é‡
        private String name;

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/HKTools.java

@@ -324,7 +324,7 @@
     * @return
     */
    public static String acsDeviceTimeRangeList(String body) {
        return startDoPostStringArtemis(HKConstants.InterfacePath.acsDeviceList,body);
        return startDoPostStringArtemis(HKConstants.InterfacePath.acsDeviceTimeRangeList,body);
    }
    /**
     *    è®¿å®¢é¢„约

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/CustomBroadcastRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,18 @@
package com.doumee.core.haikang.model.param.request;

import lombok.Data;

import java.util.List;

@Data
public class CustomBroadcastRequest {
    private List<String> audioPointIndexCode    ;//Array    true    å¹¿æ’­ç‚¹å”¯ä¸€æ ‡è¯†ï¼Œæ”¯æŒå¤šä¸ª
    private Integer playDuration;//    Number    false    æ’­æ”¾æ—¶é•¿ï¼Œå•ä½ç§’，应大于0小于86399，设备最大支持为86399，播放时长只针对媒体文件播放模式有效
    private String broadCastMode;//    String    true    å¹¿æ’­æ¨¡å¼,media-音频文件、tts-自定义文字播报
    private String playTtsContent;//    String    false    è‡ªå®šä¹‰æ–‡å­—播放，tts模式，state为1时必传，media模式下不传，和媒体文件唯一标识二选一
    private String mediaIndexCode;//    String    false    æ’­æ”¾åª’体文件唯一标识，media模式下必传，tts模式下不传，和自定义文字二选一
    private Integer priority;//    Number    true    ä¼˜å…ˆçº§ï¼Œ1-15，高优先级打断低优先级
    private Integer state;//    Number    true    æ’­æ”¾/停止标识 1-播放，0-停止
    private String broadcastId;//    String    false    å¹¿æ’­æ’­æ”¾ä»»åŠ¡idtts模式下state为0时必填，tts模式下调用播放时，根据播放接口返回data中的广播任务唯一标识来调用停止媒体文件播放模式下，有返回brocastId时，停止必传

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/PlatformStatusRequest.java

@@ -4,6 +4,6 @@

@Data
public class PlatformStatusRequest {
    private String platformIds    ;//Query    String    false    æœˆå°ID
    private String platformIds    ;//Query    String    false    æœˆå°ID，月台序号，多个月台逗号隔开

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/parks/EventPlatCarstatusRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,13 @@
package com.doumee.core.haikang.model.param.request.event.parks;

import lombok.Data;

@Data
public class EventPlatCarstatusRequest {

//    private String  parkIndexCodes    ;//    string    False    åœè½¦åº“唯一标识集合  å¤šä¸ªå€¼ä½¿ç”¨è‹±æ–‡é€—号分隔，不超过1000个

    private String   method    ;//    String    æ–¹æ³•åï¼Œç”¨äºŽæ ‡è¯†æŠ¥æ–‡ç”¨é€”    æ˜¯    16    äº‹ä»¶å›ºå®šOnEventNotify
    private EventParkParamRequest params    ;//    Params    äº‹ä»¶å‚数信息    æ˜¯    ä¸é™    å…·ä½“参数信息

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/request/event/parks/EventPlatWorkstatusRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,13 @@
package com.doumee.core.haikang.model.param.request.event.parks;

import lombok.Data;

@Data
public class EventPlatWorkstatusRequest {

//    private String  parkIndexCodes    ;//    string    False    åœè½¦åº“唯一标识集合  å¤šä¸ªå€¼ä½¿ç”¨è‹±æ–‡é€—号分隔，不超过1000个

    private String   method    ;//    String    æ–¹æ³•åï¼Œç”¨äºŽæ ‡è¯†æŠ¥æ–‡ç”¨é€”    æ˜¯    16    äº‹ä»¶å›ºå®šOnEventNotify
    private EventParkParamRequest params    ;//    Params    äº‹ä»¶å‚数信息    æ˜¯    ä¸é™    å…·ä½“参数信息

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/model/param/respose/PlatformStatusInfoResponse.java

@@ -12,7 +12,7 @@
 private String  cameraIndexcode    ;//String    false    æœˆå°å…³è”监控点
 private String  plateNo    ;//String    false    è½¦ç‰Œå·
 private String  name;//    String    false    æœˆå°åç§°
 private String  status;//    Number    false    æœˆå°çŠ¶æ€
 private String  status;//    Number    false    æœˆå°çŠ¶æ€ 0-无车 1-有车 2-超时停靠 3-错误停靠
 private String   loadingRate    ;//String    false    æœˆå°æœ€æ–°çš„车辆装载率
 private String   doorState;//    String    false    æœˆå°ä½œä¸šè½¦è¾†çš„当前开关么状态
 private String  workingPerson;//    Number    false    æœˆå°çš„当前作业人数

 server/visits/dmvisit_service/src/main/java/com/doumee/core/haikang/service/HKService.java

@@ -1097,7 +1097,7 @@
     *用于设置广播的自定播放和停止
     * @return
     */
    public  static  BaseResponse<BaseListPageResponse<LedRecordsInfoResponse>>   customBroadcast(LedRecordsRequest param){
    public  static  BaseResponse<BaseListPageResponse<LedRecordsInfoResponse>>   customBroadcast(CustomBroadcastRequest param){
        log.info("【海康用于设置广播的自定播放和停止】================开始===="+JSONObject.toJSONString(param));
        try {
            String res = HKTools.customBroadcast(JSONObject.toJSONString(param));

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/request/WmsActionNoticeRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,17 @@
package com.doumee.core.wms.model.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("WMS任务取消或完成通知单推送请求信息")
public class WmsActionNoticeRequest extends WmsBaseRequest {
    @ApiModelProperty(value = "出/如库通知单号" ,example = "1")
    private String ioCode;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/request/WmsBaseRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,15 @@
package com.doumee.core.wms.model.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("wms请求公共参数")
public class WmsBaseRequest {

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/request/WmsInboundDetailRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,26 @@
package com.doumee.core.wms.model.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/12 14:03
 */
@Data
@ApiModel("WMS入库通知单明细请求信息")
public class WmsInboundDetailRequest {
    @ApiModelProperty(value = "入库通知单号" ,example = "1")
    private String ioCode;
    @ApiModelProperty(value = "物料名称" ,example = "1")
    private String materialName;
    @ApiModelProperty(value = "供应商" ,example = "1")
    private String inRepertotyCode;
    @ApiModelProperty(value = "计划收货数量" ,example = "1")
    private BigDecimal ioQty;
    @ApiModelProperty(value = "物料转换率" ,example = "1")
    private String rate;
}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/request/WmsInboundNoticeRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,33 @@
package com.doumee.core.wms.model.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("WMS入库通知单推送请求信息")
public class WmsInboundNoticeRequest extends WmsBaseRequest {
    @ApiModelProperty(value = "入库通知单号" ,example = "1")
    private String ioCode;
    @ApiModelProperty(value = "车牌号" ,example = "1")
    private String plateNumber;
    @ApiModelProperty(value = "司机电话" ,example = "1")
    private String driverPhone;
    @ApiModelProperty(value = "司机姓名" ,example = "1")
    private String driverName;
    @ApiModelProperty(value = "承运商" ,example = "1")
    private String carrierName;
    @ApiModelProperty(value = "承运单号" ,example = "1")
    private String carrierBillCode;
    @ApiModelProperty(value = "创建日期" ,example = "1")
    private String createDate;
    @ApiModelProperty(value = "入库通知行项目数据" ,example = "1")
    private List<WmsInboundDetailRequest> details;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/request/WmsOutboundDetailRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,25 @@
package com.doumee.core.wms.model.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/12 14:03
 */
@Data
@ApiModel("WMS出库通知单明细请求信息")
public class WmsOutboundDetailRequest {
    @ApiModelProperty(value = "出库通知单号" ,example = "1")
    private String ioCode;
    @ApiModelProperty(value = "物料名称" ,example = "1")
    private String materialName;
    @ApiModelProperty(value = "计划收货数量" ,example = "1")
    private BigDecimal ioQty;
    @ApiModelProperty(value = "物料转换率" ,example = "1")
    private String rate;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/request/WmsOutboundNoticeRequest.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,38 @@
package com.doumee.core.wms.model.request;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("WMS出库通知单推送请求信息")
public class WmsOutboundNoticeRequest extends WmsBaseRequest {
    @ApiModelProperty(value = "出库通知单号" ,example = "1")
    private String ioCode;
    @ApiModelProperty(value = "收货地" ,example = "1")
    private String repertotyAddress;
    @ApiModelProperty(value = "合同号" ,example = "1")
    private String contractNum;
    @ApiModelProperty(value = "车牌号" ,example = "1")
    private String plateNumber;
    @ApiModelProperty(value = "司机电话" ,example = "1")
    private String driverPhone;
    @ApiModelProperty(value = "司机姓名" ,example = "1")
    private String driverName;
    @ApiModelProperty(value = "承运商" ,example = "1")
    private String carrierName;
    @ApiModelProperty(value = "承运单号" ,example = "1")
    private String carrierBillCode;
    @ApiModelProperty(value = "创建日期" ,example = "1")
    private String createDate;

    @ApiModelProperty(value = "出库通知行项目数据" ,example = "1")
    private List<WmsOutboundDetailRequest> details;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/response/WmsBaseDataResponse.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,20 @@
package com.doumee.core.wms.model.response;

import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("WMS接口处理返回data参数")
public class WmsBaseDataResponse {

    @ApiModelProperty(value = "是否接收成功 1成功 -1 å¤±è´¥" ,example = "1")
    private String success;
    @ApiModelProperty(value = "消息描述" ,example = "1")
    private String msgDescr;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/core/wms/model/response/WmsBaseResponse.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,21 @@
package com.doumee.core.wms.model.response;

import com.doumee.core.haikang.model.param.BaseRequst;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.math.BigDecimal;
import java.util.List;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/23 14:03
 */
@Data
@ApiModel("WMS接口处理返回参数")
public class WmsBaseResponse {
    @ApiModelProperty(value = "返回参数" ,example = "1")
    private List<WmsBaseDataResponse> data;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/PlatformReasonMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,12 @@
package com.doumee.dao.business;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.PlatformReason;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/13 14:08
 */
public interface PlatformReasonMapper extends BaseMapper<PlatformReason> {

}

 server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/WmsInterfaceLogMapper.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,12 @@
package com.doumee.dao.business;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.doumee.dao.business.model.WmsInterfaceLog;

/**
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
public interface WmsInterfaceLogMapper extends BaseMapper<WmsInterfaceLog> {

}

 server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/ApproveTempl.java

@@ -60,6 +60,10 @@
    @ExcelColumn(name="名称")
    private String name;

    @ApiModelProperty(value = "关联对象编码（月台原因关联 platform_reason表)")
    @ExcelColumn(name="关联对象编码（月台原因关联 platform_reason表)")
    private Integer objId;

    @ApiModelProperty(value = "审批模版配置明细集合")
    @TableField(exist = false)
    private List<ApproveParam> paramList;

 server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/PlatformReason.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,75 @@
package com.doumee.dao.business.model;

import com.doumee.core.annotation.excel.ExcelColumn;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import com.fasterxml.jackson.annotation.JsonFormat;
import java.util.Date;
import java.math.BigDecimal;

/**
 * æœˆå°_入园原因信息表
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/13 14:08
 */
@Data
@ApiModel("月台_入园原因信息表")
@TableName("`platform_reason`")
public class PlatformReason {

    @TableId(type = IdType.AUTO)
    @ApiModelProperty(value = "主键", example = "1")
    @ExcelColumn(name="主键")
    private Integer id;

    @ApiModelProperty(value = "创建人编码", example = "1")
    @ExcelColumn(name="创建人编码")
    private Integer creator;

    @ApiModelProperty(value = "创建时间")
    @ExcelColumn(name="创建时间")
    @JsonFormat(pattern = "yyyy-MM-dd")
    private Date createDate;

    @ApiModelProperty(value = "更新人编码", example = "1")
    @ExcelColumn(name="更新人编码")
    private Integer editor;

    @ApiModelProperty(value = "更新时间")
    @ExcelColumn(name="更新时间")
    @JsonFormat(pattern = "yyyy-MM-dd")
    private Date editDate;

    @ApiModelProperty(value = "是否删除0否 1是", example = "1")
    @ExcelColumn(name="是否删除0否 1是")
    private Integer isdeleted;

    @ApiModelProperty(value = "备注")
    @ExcelColumn(name="备注")
    private String remark;

    @ApiModelProperty(value = "原因")
    @ExcelColumn(name="原因")
    private String reason;

    @ApiModelProperty(value = "通知单号")
    @ExcelColumn(name="通知单号")
    private String iocode;

    @ApiModelProperty(value = "关联月台组编码（关联platform_group表）", example = "1")
    @ExcelColumn(name="关联月台组编码（关联platform_group表）")
    private Long groupId;

    @ApiModelProperty(value = "作业限制量", example = "1")
    @ExcelColumn(name="作业限制量")
    private BigDecimal limitNum;

    @ApiModelProperty(value = "排序码", example = "1")
    @ExcelColumn(name="排序码")
    private Integer sortnum;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/dao/business/model/WmsInterfaceLog.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,99 @@
package com.doumee.dao.business.model;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.doumee.core.annotation.excel.ExcelColumn;
import com.doumee.core.model.LoginUserModel;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;

import java.util.Date;

/**
 * ä¸‰æ–¹å¹³å°æŽ¥å£äº¤äº’记录
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
@Data
@ApiModel("WMS平台接口交互记录")
@TableName("`wms_interface_log`")
public class WmsInterfaceLog extends LoginUserModel {

    @TableId(type = IdType.AUTO)
    @ApiModelProperty(value = "主键", example = "1")
    @ExcelColumn(name="主键")
    private Integer id;

    @ApiModelProperty(value = "创建人编码", example = "1")
    @ExcelColumn(name="创建人编码")
    private Integer creator;

    @ApiModelProperty(value = "创建时间")
    @ExcelColumn(name="创建时间")
    private Date createDate;

    @ApiModelProperty(value = "更新人编码", example = "1")
    @ExcelColumn(name="更新人编码")
    private Integer editor;

    @ApiModelProperty(value = "更新时间")
    @ExcelColumn(name="更新时间")
    private Date editDate;

    @ApiModelProperty(value = "是否删除0否 1是", example = "1")
    @ExcelColumn(name="是否删除0否 1是")
    private Integer isdeleted;

    @ApiModelProperty(value = "备注")
    @ExcelColumn(name="备注")
    private String remark;

    @ApiModelProperty(value = "类型 0调用 1推送接受", example = "1")
    @ExcelColumn(name="类型 0调用 1推送接受")
    private Integer type;

    @ApiModelProperty(value = "接口名称")
    @ExcelColumn(name="接口名称")
    private String name;

    @ApiModelProperty(value = "地址信息")
    @ExcelColumn(name="地址信息")
    private String url;

    @ApiModelProperty(value = "请求参数")
    @ExcelColumn(name="请求参数")
    private String request;

    @ApiModelProperty(value = "响应参数")
    @ExcelColumn(name="响应参数")
    private String repose;

    @ApiModelProperty(value = "调用结果 0成功 1失败", example = "1")
    @ExcelColumn(name="调用结果 0成功 1失败")
    private Integer success;

    @ApiModelProperty(value = "平台 0海康安防平台 1ERP系统", example = "1")
    @ExcelColumn(name="平台 0海康安防平台 1ERP系统")
    private Integer plat;

    @ApiModelProperty(value = "关联对象类型  0组织 1人员 2门禁事件 3设备", example = "1")
    @ExcelColumn(name="关联对象类型  0组织 1人员 2门禁事件 3设备")
    private Integer objType;

    @ApiModelProperty(value = "关联对象编码（多个用英文逗号隔开）")
    @ExcelColumn(name="关联对象编码（多个用英文逗号隔开）")
    private String objId;


    @ApiModelProperty(value = "开始时间")
    @TableField(exist = false)
    private Date startDate;

    @ApiModelProperty(value = "结束时间")
    @TableField(exist = false)
    private Date endDate;

}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/PlatformReasonService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,97 @@
package com.doumee.service.business;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.dao.business.model.PlatformReason;
import java.util.List;

/**
 * æœˆå°_入园原因信息表Service定义
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/13 14:08
 */
public interface PlatformReasonService {

    /**
     * åˆ›å»º
     * 
     * @param platformReason å®žä½“对象
     * @return Integer
     */
    Integer create(PlatformReason platformReason);

    /**
     * ä¸»é”®åˆ é™¤
     *
     * @param id ä¸»é”®
     */
    void deleteById(Integer id);

    /**
     * åˆ é™¤
     *
     * @param platformReason å®žä½“对象
     */
    void delete(PlatformReason platformReason);

    /**
     * æ‰¹é‡ä¸»é”®åˆ é™¤
     *
     * @param ids ä¸»é”®é›†
     */
    void deleteByIdInBatch(List<Integer> ids);

    /**
     * ä¸»é”®æ›´æ–°
     *
     * @param platformReason å®žä½“对象
     */
    void updateById(PlatformReason platformReason);

    /**
     * æ‰¹é‡ä¸»é”®æ›´æ–°
     *
     * @param platformReasons å®žä½“集
     */
    void updateByIdInBatch(List<PlatformReason> platformReasons);

    /**
     * ä¸»é”®æŸ¥è¯¢
     *
     * @param id ä¸»é”®
     * @return PlatformReason
     */
    PlatformReason findById(Integer id);

    /**
     * æ¡ä»¶æŸ¥è¯¢å•æ¡è®°å½•
     *
     * @param platformReason å®žä½“对象
     * @return PlatformReason
     */
    PlatformReason findOne(PlatformReason platformReason);

    /**
     * æ¡ä»¶æŸ¥è¯¢
     *
     * @param platformReason å®žä½“对象
     * @return List<PlatformReason>
     */
    List<PlatformReason> findList(PlatformReason platformReason);
  
    /**
     * åˆ†é¡µæŸ¥è¯¢
     *
     * @param pageWrap åˆ†é¡µå¯¹è±¡
     * @return PageData<PlatformReason>
     */
    PageData<PlatformReason> findPage(PageWrap<PlatformReason> pageWrap);

    /**
     * æ¡ä»¶ç»Ÿè®¡
     *
     * @param platformReason å®žä½“对象
     * @return long
     */
    long count(PlatformReason platformReason);
}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/WmsInterfaceLogService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,100 @@
package com.doumee.service.business;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.dao.business.model.WmsInterfaceLog;

import java.util.List;

/**
 * ä¸‰æ–¹å¹³å°æŽ¥å£äº¤äº’记录Service定义
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
public interface WmsInterfaceLogService {

    /**
     * åˆ›å»º
     * 
     * @param interfaceLog å®žä½“对象
     * @return Integer
     */
    Integer create(WmsInterfaceLog interfaceLog);

    /**
     * ä¸»é”®åˆ é™¤
     *
     * @param id ä¸»é”®
     */
    void deleteById(Integer id);

    /**
     * åˆ é™¤
     *
     * @param interfaceLog å®žä½“对象
     */
    void delete(WmsInterfaceLog interfaceLog);

    /**
     * æ‰¹é‡ä¸»é”®åˆ é™¤
     *
     * @param ids ä¸»é”®é›†
     */
    void deleteByIdInBatch(List<Integer> ids);

    /**
     * ä¸»é”®æ›´æ–°
     *
     * @param interfaceLog å®žä½“对象
     */
    void updateById(WmsInterfaceLog interfaceLog);

    /**
     * æ‰¹é‡ä¸»é”®æ›´æ–°
     *
     * @param interfaceLogs å®žä½“集
     */
    void updateByIdInBatch(List<WmsInterfaceLog> interfaceLogs);

    /**
     * ä¸»é”®æŸ¥è¯¢
     *
     * @param id ä¸»é”®
     * @return InterfaceLog
     */
    WmsInterfaceLog findById(Integer id);

    /**
     * æ¡ä»¶æŸ¥è¯¢å•æ¡è®°å½•
     *
     * @param interfaceLog å®žä½“对象
     * @return InterfaceLog
     */
    WmsInterfaceLog findOne(WmsInterfaceLog interfaceLog);

    /**
     * æ¡ä»¶æŸ¥è¯¢
     *
     * @param interfaceLog å®žä½“对象
     * @return List<InterfaceLog>
     */
    List<WmsInterfaceLog> findList(WmsInterfaceLog interfaceLog);
  
    /**
     * åˆ†é¡µæŸ¥è¯¢
     *
     * @param pageWrap åˆ†é¡µå¯¹è±¡
     * @return PageData<InterfaceLog>
     */
    PageData<WmsInterfaceLog> findPage(PageWrap<WmsInterfaceLog> pageWrap);

    /**
     * æ¡ä»¶ç»Ÿè®¡
     *
     * @param interfaceLog å®žä½“对象
     * @return long
     */
    long count(WmsInterfaceLog interfaceLog);

    void clearThreeMonthLog();
}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/WmsService.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,54 @@
package com.doumee.service.business;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.wms.model.request.WmsActionNoticeRequest;
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.dao.business.model.Platform;

import java.util.List;

/**
 * æœˆå°ä¿¡æ¯è¡¨Service定义
 * @author æ±Ÿè¹„蹄
 * @date 2024/06/28 10:03
 */
public interface WmsService {

    /**
     * å…¥åº“单批量通知
     * @param list å‚æ•°
     * @return WmsBaseResponse
     */
    WmsBaseResponse inboundNotice(List<WmsInboundNoticeRequest> list);

    /**
     * å‡ºåº“单批量通知
     * @param list å‚æ•°
     * @return WmsBaseResponse
     */
    WmsBaseResponse outboundNotice(List<WmsOutboundNoticeRequest> list);

    /**
     * å–消入库单通知
     * @param list å‚æ•°
     * @return WmsBaseResponse
     */
    WmsBaseResponse cancelInbound(List<WmsActionNoticeRequest> list);
    /**
     * å–消出库单通知
     * @param list å‚æ•°
     * @return WmsBaseResponse
     */
    WmsBaseResponse cancelOutbound(List<WmsActionNoticeRequest> list);
    /**
     * å‡ºå…¥åº“作业完成通知
     * @param list å‚æ•°
     * @return WmsBaseResponse
     */
    WmsBaseResponse doneTask(List<WmsActionNoticeRequest> list);


}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/ext/HkSyncService.java

@@ -3,6 +3,8 @@
import com.doumee.core.haikang.model.param.request.*;
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.parks.EventPlatCarstatusRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventPlatWorkstatusRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.haikang.model.param.respose.AppointmentInfoResponse;
import com.doumee.dao.business.model.ParkBook;
@@ -81,4 +83,8 @@

    void syncMemberDelData();
    String getServiceUrl(HKGetServiceLoginUrlRequest param);

    void dealWorkstatusEvent(EventPlatWorkstatusRequest param, HttpServletResponse response);

    void dealCarstatusEvent(EventPlatCarstatusRequest param, HttpServletResponse response);
}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/MemberCardServiceImpl.java

@@ -86,8 +86,8 @@
        }
        CardBingdingRequest param = new CardBingdingRequest();
        if(member.getStartTime() !=null && member.getEndTime()!=null){
            param.setStartDate(DateUtil.getISO8601Timestamp(member.getStartTime()));
            param.setEndDate(DateUtil.getISO8601Timestamp(member.getEndTime()));
            param.setStartDate(DateUtil.getShortTime(member.getStartTime()));
            param.setEndDate(DateUtil.getShortTime(member.getEndTime()));
        }
        CardInfoRequest cr = new CardInfoRequest();
        cr.setCardNo(memberCard.getCode());

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/PlatformReasonServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,145 @@
package com.doumee.service.business.impl;

import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.PlatformReasonMapper;
import com.doumee.dao.business.model.PlatformReason;
import com.doumee.service.business.PlatformReasonService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.List;

/**
 * æœˆå°_入园原因信息表Service实现
 * @author æ±Ÿè¹„蹄
 * @date 2024/08/13 14:08
 */
@Service
public class PlatformReasonServiceImpl implements PlatformReasonService {

    @Autowired
    private PlatformReasonMapper platformReasonMapper;

    @Override
    public Integer create(PlatformReason platformReason) {
        platformReasonMapper.insert(platformReason);
        return platformReason.getId();
    }

    @Override
    public void deleteById(Integer id) {
        platformReasonMapper.deleteById(id);
    }

    @Override
    public void delete(PlatformReason platformReason) {
        UpdateWrapper<PlatformReason> deleteWrapper = new UpdateWrapper<>(platformReason);
        platformReasonMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        platformReasonMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(PlatformReason platformReason) {
        platformReasonMapper.updateById(platformReason);
    }

    @Override
    public void updateByIdInBatch(List<PlatformReason> platformReasons) {
        if (CollectionUtils.isEmpty(platformReasons)) {
            return;
        }
        for (PlatformReason platformReason: platformReasons) {
            this.updateById(platformReason);
        }
    }

    @Override
    public PlatformReason findById(Integer id) {
        return platformReasonMapper.selectById(id);
    }

    @Override
    public PlatformReason findOne(PlatformReason platformReason) {
        QueryWrapper<PlatformReason> wrapper = new QueryWrapper<>(platformReason);
        return platformReasonMapper.selectOne(wrapper);
    }

    @Override
    public List<PlatformReason> findList(PlatformReason platformReason) {
        QueryWrapper<PlatformReason> wrapper = new QueryWrapper<>(platformReason);
        return platformReasonMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<PlatformReason> findPage(PageWrap<PlatformReason> pageWrap) {
        IPage<PlatformReason> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<PlatformReason> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(PlatformReason::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getCreator() != null) {
            queryWrapper.lambda().eq(PlatformReason::getCreator, pageWrap.getModel().getCreator());
        }
        if (pageWrap.getModel().getCreateDate() != null) {
            queryWrapper.lambda().ge(PlatformReason::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
            queryWrapper.lambda().le(PlatformReason::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
        }
        if (pageWrap.getModel().getEditor() != null) {
            queryWrapper.lambda().eq(PlatformReason::getEditor, pageWrap.getModel().getEditor());
        }
        if (pageWrap.getModel().getEditDate() != null) {
            queryWrapper.lambda().ge(PlatformReason::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
            queryWrapper.lambda().le(PlatformReason::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
        }
        if (pageWrap.getModel().getIsdeleted() != null) {
            queryWrapper.lambda().eq(PlatformReason::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getRemark() != null) {
            queryWrapper.lambda().eq(PlatformReason::getRemark, pageWrap.getModel().getRemark());
        }
        if (pageWrap.getModel().getReason() != null) {
            queryWrapper.lambda().eq(PlatformReason::getReason, pageWrap.getModel().getReason());
        }
        if (pageWrap.getModel().getIocode() != null) {
            queryWrapper.lambda().eq(PlatformReason::getIocode, pageWrap.getModel().getIocode());
        }
        if (pageWrap.getModel().getGroupId() != null) {
            queryWrapper.lambda().eq(PlatformReason::getGroupId, pageWrap.getModel().getGroupId());
        }
        if (pageWrap.getModel().getLimitNum() != null) {
            queryWrapper.lambda().eq(PlatformReason::getLimitNum, pageWrap.getModel().getLimitNum());
        }
        if (pageWrap.getModel().getSortnum() != null) {
            queryWrapper.lambda().eq(PlatformReason::getSortnum, pageWrap.getModel().getSortnum());
        }
        for(PageWrap.SortData sortData: pageWrap.getSorts()) {
            if (sortData.getDirection().equalsIgnoreCase(PageWrap.DESC)) {
                queryWrapper.orderByDesc(sortData.getProperty());
            } else {
                queryWrapper.orderByAsc(sortData.getProperty());
            }
        }
        return PageData.from(platformReasonMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(PlatformReason platformReason) {
        QueryWrapper<PlatformReason> wrapper = new QueryWrapper<>(platformReason);
        return platformReasonMapper.selectCount(wrapper);
    }
}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/WmsInterfaceLogServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,171 @@
package com.doumee.service.business.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.doumee.biz.system.SystemDictDataBiz;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.WmsInterfaceLogMapper;
import com.doumee.dao.business.model.WmsInterfaceLog;
import com.doumee.service.business.WmsInterfaceLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.List;

/**
 * ä¸‰æ–¹å¹³å°æŽ¥å£äº¤äº’记录Service实现
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
@Service
public class WmsInterfaceLogServiceImpl implements WmsInterfaceLogService {

    @Autowired
    private WmsInterfaceLogMapper interfaceLogMapper;
    @Autowired
    private SystemDictDataBiz systemDictDataBiz;

    @Override
    public Integer create(WmsInterfaceLog interfaceLog) {
        interfaceLogMapper.insert(interfaceLog);
        return interfaceLog.getId();
    }

    @Override
    public void deleteById(Integer id) {
        interfaceLogMapper.deleteById(id);
    }

    @Override
    public void delete(WmsInterfaceLog interfaceLog) {
        UpdateWrapper<WmsInterfaceLog> deleteWrapper = new UpdateWrapper<>(interfaceLog);
        interfaceLogMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        interfaceLogMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(WmsInterfaceLog interfaceLog) {
        interfaceLogMapper.updateById(interfaceLog);
    }

    @Override
    public void updateByIdInBatch(List<WmsInterfaceLog> interfaceLogs) {
        if (CollectionUtils.isEmpty(interfaceLogs)) {
            return;
        }
        for (WmsInterfaceLog interfaceLog: interfaceLogs) {
            this.updateById(interfaceLog);
        }
    }

    @Override
    public WmsInterfaceLog findById(Integer id) {
        return interfaceLogMapper.selectById(id);
    }

    @Override
    public WmsInterfaceLog findOne(WmsInterfaceLog interfaceLog) {
        QueryWrapper<WmsInterfaceLog> wrapper = new QueryWrapper<>(interfaceLog);
        return interfaceLogMapper.selectOne(wrapper);
    }

    @Override
    public List<WmsInterfaceLog> findList(WmsInterfaceLog interfaceLog) {
        QueryWrapper<WmsInterfaceLog> wrapper = new QueryWrapper<>(interfaceLog);
        return interfaceLogMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<WmsInterfaceLog> findPage(PageWrap<WmsInterfaceLog> pageWrap) {
        IPage<WmsInterfaceLog> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        QueryWrapper<WmsInterfaceLog> queryWrapper = new QueryWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        if (pageWrap.getModel().getId() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getId, pageWrap.getModel().getId());
        }
        if (pageWrap.getModel().getCreator() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getCreator, pageWrap.getModel().getCreator());
        }
        if (pageWrap.getModel().getCreateDate() != null) {
            queryWrapper.lambda().ge(WmsInterfaceLog::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
            queryWrapper.lambda().le(WmsInterfaceLog::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
        }
        if (pageWrap.getModel().getEditor() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getEditor, pageWrap.getModel().getEditor());
        }
        if (pageWrap.getModel().getEditDate() != null) {
            queryWrapper.lambda().ge(WmsInterfaceLog::getEditDate, Utils.Date.getStart(pageWrap.getModel().getEditDate()));
            queryWrapper.lambda().le(WmsInterfaceLog::getEditDate, Utils.Date.getEnd(pageWrap.getModel().getEditDate()));
        }

        if (pageWrap.getModel().getStartDate() != null) {
            queryWrapper.lambda().ge(WmsInterfaceLog::getCreateDate, pageWrap.getModel().getStartDate());
        }
        if (pageWrap.getModel().getEndDate() != null) {
            queryWrapper.lambda().le(WmsInterfaceLog::getCreateDate, pageWrap.getModel().getEndDate());
        }
        if (pageWrap.getModel().getIsdeleted() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getIsdeleted, pageWrap.getModel().getIsdeleted());
        }
        if (pageWrap.getModel().getRemark() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getRemark, pageWrap.getModel().getRemark());
        }
        if (pageWrap.getModel().getType() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getType, pageWrap.getModel().getType());
        }
        if (pageWrap.getModel().getName() != null) {
            queryWrapper.lambda().like(WmsInterfaceLog::getName, pageWrap.getModel().getName());
        }
        if (pageWrap.getModel().getUrl() != null) {
            queryWrapper.lambda().like(WmsInterfaceLog::getUrl, pageWrap.getModel().getUrl());
        }
        if (pageWrap.getModel().getRequest() != null) {
            queryWrapper.lambda().like(WmsInterfaceLog::getRequest, pageWrap.getModel().getRequest());
        }
        if (pageWrap.getModel().getRepose() != null) {
            queryWrapper.lambda().like(WmsInterfaceLog::getRepose, pageWrap.getModel().getRepose());
        }
        if (pageWrap.getModel().getSuccess() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getSuccess, pageWrap.getModel().getSuccess());
        }
        if (pageWrap.getModel().getPlat() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getPlat, pageWrap.getModel().getPlat());
        }
        if (pageWrap.getModel().getObjType() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getObjType, pageWrap.getModel().getObjType());
        }
        if (pageWrap.getModel().getObjId() != null) {
            queryWrapper.lambda().eq(WmsInterfaceLog::getObjId, pageWrap.getModel().getObjId());
        }
        queryWrapper.lambda().orderByDesc(WmsInterfaceLog::getCreateDate);
        return PageData.from(interfaceLogMapper.selectPage(page, queryWrapper));
    }

    @Override
    public long count(WmsInterfaceLog interfaceLog) {
        QueryWrapper<WmsInterfaceLog> wrapper = new QueryWrapper<>(interfaceLog);
        return interfaceLogMapper.selectCount(wrapper);
    }
    @Override
    public void clearThreeMonthLog() {
         int days =15;
         try {
             days = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.SYSTEM,Constants.HK_LOG_DEL_DAYS_LIMIT).getCode());
         }catch (Exception e){}
          interfaceLogMapper.delete(new UpdateWrapper<WmsInterfaceLog>().lambda()
                  .apply("to_days(create_date)+"+days+" < to_days(now())") );
    }
}

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/erp/ErpSyncServiceImpl.java

@@ -80,7 +80,6 @@
    @Autowired
    private VisitEventMapper visitEventMapper;


    @Autowired
    private VisitEventJoinMapper visitEventJoinMapper;


 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/hksync/HkSyncBaseServiceImpl.java

@@ -7,6 +7,8 @@
import com.doumee.core.haikang.model.param.request.*;
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.parks.EventPlatCarstatusRequest;
import com.doumee.core.haikang.model.param.request.event.parks.EventPlatWorkstatusRequest;
import com.doumee.core.haikang.model.param.request.event.visit.EventVisitRequest;
import com.doumee.core.haikang.model.param.respose.AppointmentInfoResponse;
import com.doumee.core.haikang.model.param.respose.TaskAdditionResponse;
@@ -49,6 +51,13 @@
//    @Async
    public  void syncParkRecords(Date date){
    }

    @Override
    public  void dealWorkstatusEvent(EventPlatWorkstatusRequest param, HttpServletResponse response){
    }
    @Override
    public  void dealCarstatusEvent(EventPlatCarstatusRequest param, HttpServletResponse response){
    }
    @Override
//    @Async
    public String syncDoors(DoorsListRequest param){

 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/wms/WmsServiceImpl.java

¶Ô±ÈÐÂÎļþ
@@ -0,0 +1,137 @@
package com.doumee.service.business.impl.wms;

import com.doumee.core.wms.model.request.WmsActionNoticeRequest;
import com.doumee.core.wms.model.request.WmsInboundNoticeRequest;
import com.doumee.core.wms.model.request.WmsOutboundNoticeRequest;
import com.doumee.core.wms.model.response.WmsBaseDataResponse;
import com.doumee.core.wms.model.response.WmsBaseResponse;
import com.doumee.dao.business.PlatformWmsDetailMapper;
import com.doumee.dao.business.PlatformWmsJobMapper;
import com.doumee.dao.business.model.PlatformWmsJob;
import com.doumee.service.business.WmsService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

/**
 * WMS平台对接Service实现
 * @author æ±Ÿè¹„蹄
 * @date 2023/11/30 15:33
 */
@Service
public class WmsServiceImpl implements WmsService {
    @Autowired
    private PlatformWmsJobMapper platformWmsJobMapper;
    @Autowired
    private PlatformWmsDetailMapper platformWmsDetailMapper;

    /**
     * å…¥åº“通知任务业务处理
     * @param list å‚æ•°
     * @return
     */
    @Override
    public WmsBaseResponse inboundNotice(List<WmsInboundNoticeRequest> list) {
        //TODO-------------------处理入库通知业务--------------------
        if(list ==null || list.size() ==0){
            return returnFailReuslt("请求参数不正确，参数不能为空");
        }
        WmsBaseResponse response = new WmsBaseResponse();
        response.setData(new ArrayList<>());

        return response;
    }



    /**
     * å‡ºåº“通知任务业务处理
     * @param list å‚æ•°
     * @return
     */
    @Override
    public WmsBaseResponse outboundNotice(List<WmsOutboundNoticeRequest> list) {
        //TODO-------------------处理出库通知业务--------------------
        if(list ==null || list.size() ==0){
            return returnFailReuslt("请求参数不正确，参数不能为空");
        }
        return null;
    }
    /**
     * å…¥åº“取消通知任务业务处理
     * @param list å‚æ•°
     * @return
     */
    @Override
    public WmsBaseResponse cancelInbound(List<WmsActionNoticeRequest> list) {
        //TODO-------------------处理入库取消通知业务--------------------
        if(list ==null || list.size() ==0){
            return returnFailReuslt("请求参数不正确，参数不能为空");
        }


        return returnSuccessReuslt(null);
    }
    /**
     * å‡ºåº“取消通知任务业务处理
     * @param list å‚æ•°
     * @return
     */
    @Override
    public WmsBaseResponse cancelOutbound(List<WmsActionNoticeRequest> list) {
        //TODO-------------------处理出库取消通知业务--------------------
        if(list ==null || list.size() ==0){
            return returnFailReuslt("请求参数不正确，参数不能为空");
        }

        return returnSuccessReuslt(null);
    }
    /**
     * ä½œä¸šå®Œæˆé€šçŸ¥ä»»åŠ¡ä¸šåŠ¡å¤„理
     * @param list å‚æ•°
     * @return
     */
    @Override
    public WmsBaseResponse doneTask(List<WmsActionNoticeRequest> list) {
        //TODO-------------------处理出入库作业完成通知业务--------------------
        if(list ==null || list.size() ==0){
            return returnFailReuslt("请求参数不正确，参数不能为空");
        }

        return returnSuccessReuslt(null);
    }

    /**
     * å°è£…错误返回对象
     * @param msg
     * @return
     */

    private WmsBaseResponse returnFailReuslt(String msg) {
        WmsBaseResponse response = new WmsBaseResponse();
        response.setData(new ArrayList<>());
        WmsBaseDataResponse rData = new WmsBaseDataResponse();
        rData.setMsgDescr(msg);
        rData.setSuccess("-1");
        response.getData().add(rData);
        return  response;
    }
    /**
     * å°è£…成功返回对象
     * @param msg
     * @return
     */

    private WmsBaseResponse returnSuccessReuslt(String msg) {
        WmsBaseResponse response = new WmsBaseResponse();
        response.setData(new ArrayList<>());
        WmsBaseDataResponse rData = new WmsBaseDataResponse();
        rData.setMsgDescr(StringUtils.defaultString(msg,"操作成功"));
        rData.setSuccess("1");
        response.getData().add(rData);
        return  response;
    }
}