许可证到期提醒，系统30分钟无操作下线账号

pang.jiabao

2025-09-03 7ab7cb61536d59514d90b930fba0c5e2cef8f5ce

 src/main/java/com/zy/asrs/service/impl/OpenServiceImpl.java

@@ -1,58 +1,162 @@
package com.zy.asrs.service.impl;

import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.core.common.Cools;
import com.core.exception.CoolException;
import com.zy.asrs.domain.enums.WmsWrkStatusType;
import com.zy.asrs.entity.WmsWrk;
import com.zy.asrs.entity.param.WmsWrkCreateParam;
import com.zy.asrs.service.OpenService;
import com.zy.asrs.service.WmsWrkService;
import com.core.common.R;
import com.zy.asrs.domain.enums.TaskStatusType;
import com.zy.asrs.domain.enums.WorkNoType;
import com.zy.asrs.domain.param.ApplyInDevpDto;
import com.zy.asrs.entity.BasDevp;
import com.zy.asrs.entity.LocMast;
import com.zy.asrs.entity.TaskWrk;
import com.zy.asrs.entity.param.TaskCreateParam;
import com.zy.asrs.service.*;
import com.zy.asrs.utils.Utils;
import com.zy.common.service.CommonService;
import com.zy.core.DevpThread;
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.SlaveConnection;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.Task;
import com.zy.core.model.protocol.StaProtocol;
import com.zy.core.properties.SlaveProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;

import java.util.Date;
import java.util.HashMap;

@Service
public class OpenServiceImpl implements OpenService {

    @Autowired
    private WmsWrkService wmsWrkService;
    private TaskWrkService taskWrkService;
    @Autowired
    private SlaveProperties slaveProperties;
    @Autowired
    private ApiLogService apiLogService;
    @Autowired
    private StaDescService staDescService;
    @Autowired
    private CommonService commonService;
    @Autowired
    private LocMastService locMastService;
    @Autowired
    private BasDevpService basDevpService;
    @Value("${wms.url}")
    private String wmsUrl;

    @Override
    public void wmsWrkCreate(WmsWrkCreateParam param) {
        WmsWrk wmsWrk = wmsWrkService.selectByWmsWrkNo(param.getWmsWrkNo());
        if (wmsWrk != null) {
            throw new CoolException(param.getWmsWrkNo() + "任务已存在，请勿重复提交");
    public HashMap<String, Object> taskCreate(TaskCreateParam param) {
        HashMap<String, Object> map = new HashMap<>();
        TaskWrk taskWrk = taskWrkService.selectByTaskNo(param.getTaskNo());
        if (taskWrk != null) {
            map.put("Code", "0");
            map.put("Msg", param.getTaskNo() + "任务已经生成！");
            return map;
        }

        Date now = new Date();
        wmsWrk = new WmsWrk();
        wmsWrk.setWmsWrkNo(param.getWmsWrkNo());//WMS任务号
        wmsWrk.setWmsStatus(WmsWrkStatusType.RECEIVE.id);//WMS状态：接收
        wmsWrk.setCreateTime(now);
        wmsWrk.setAppeTime(now);
        wmsWrk.setAppeUser(9527L);
        wmsWrk.setIoType(param.getIoType());//任务类型
        wmsWrk.setIoPri(13D);//优先级
        wmsWrk.setBarcode(param.getBarcode());//条码
        if (!Cools.isEmpty(param.getLocNo())) {
            wmsWrk.setLocNo(param.getLocNo());//目标库位
        taskWrk = new TaskWrk();
        LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>().eq("loc_no", param.getStartPoint()));
        if (locMast == null) {
            map.put("Code", "0");
            map.put("Msg", param.getStartPoint() + "库位号有误");
            return map;
        }
        if (!Cools.isEmpty(param.getSourceLocNo())) {
            wmsWrk.setSourceLocNo(param.getSourceLocNo());//源库位
        int workNoType = WorkNoType.PAKOUT.type;
        // 2，3号堆垛机出库，需要通过条码区分大小托盘，16开头小托盘，18开头大托盘，任务号3001-6000为小托盘
        if (param.getIoType() == 2 && (locMast.getCrnNo() == 3 || locMast.getCrnNo() == 2) && locMast.getBarcode().startsWith("16")) {
            workNoType = WorkNoType.PICK.type;
        }
        if (!Cools.isEmpty(param.getStaNo())) {
            wmsWrk.setStaNo(param.getStaNo());//目标站
        }
        if (!Cools.isEmpty(param.getSourceStaNo())) {
            wmsWrk.setSourceStaNo(param.getSourceStaNo());//源站
        }
        if (!Cools.isEmpty(param.getMemo())) {
            wmsWrk.setMemo(param.getMemo());//备注
        int workNo1 = commonService.getWorkNo(workNoType);//获取入库工作号
        taskWrk.setTaskNo(param.getTaskNo());//任务号
        taskWrk.setWrkNo(workNo1);
        taskWrk.setStatus(TaskStatusType.RECEIVE.id);//任务状态：接收
        taskWrk.setCreateTime(now);
        taskWrk.setAssignTime(now);
        taskWrk.setIoType(param.getIoType());//任务类型
        taskWrk.setIoPri(param.getTaskPriority());//优先级
        taskWrk.setBarcode(param.getBarcode());//条码
        taskWrk.setCrnNo(locMast.getCrnNo());
        taskWrk.setType(param.getType());
        if (param.getIoType() == 1) {
            taskWrk.setWrkSts(1);
            if (!Cools.isEmpty(param.getTargetPoint())) {
                taskWrk.setTargetPoint(Utils.getWcsLocNo(param.getTargetPoint()));//终点
                taskWrk.setOriginTargetPoint(param.getTargetPoint());
            }

        } else if (param.getIoType() == 2) {
            taskWrk.setWrkSts(11);
//            if (!Cools.isEmpty(param.getStartPoint())) {
            taskWrk.setStartPoint(param.getStartPoint());//起点
            if (Integer.parseInt(param.getTargetPoint()) == 211 || Integer.parseInt(param.getTargetPoint()) == 206 || Integer.parseInt(param.getTargetPoint()) == 202) {
                taskWrk.setTargetPoint(String.valueOf(Integer.parseInt(param.getTargetPoint()) + 1));
            } else {
                taskWrk.setTargetPoint(String.valueOf(Integer.parseInt(param.getTargetPoint()) - 1));
            }
//            }
//            taskWrk.setTargetPoint(param.getTargetPoint());
        } else if (param.getIoType() == 3) {
            taskWrk.setWrkSts(11);
            if (!Cools.isEmpty(param.getStartPoint())) {
                taskWrk.setStartPoint(param.getStartPoint());//起点
                taskWrk.setTargetPoint(param.getTargetPoint());
            }
        }

        if (!wmsWrkService.insert(wmsWrk)) {
            throw new CoolException("生成任务失败，请联系管理员");

        if (!Cools.isEmpty(param.getMemo())) {
            taskWrk.setMemo(param.getMemo());//备注
        }

        if (!taskWrkService.insert(taskWrk)) {
            map.put("Code", "0");
            map.put("Msg", param.getTaskNo() + "创建任务失败！");
            return map;
        }
        map.put("Code", "1");
        map.put("Msg", "ok");
        return map;
    }

    @Override
    public R applyInDevp(ApplyInDevpDto param) {
        Integer sourceSite = param.getSourceSite();
        BasDevp basDevp = basDevpService.selectById(sourceSite);
        if (basDevp == null) {
            return R.error("源站点不存在:" + param);
        }
        DevpThread devpThread = (DevpThread) SlaveConnection.get(SlaveType.Devp, 2);
        StaProtocol staProtocol = devpThread.getStation().get(sourceSite);
        if (staProtocol == null) {
            return R.parse(sourceSite + "线程为空!");
        } else {
            staProtocol = staProtocol.clone();
        }
        StaProtocol staProtocol1 = devpThread.getStation().get(param.getTargetSite());
        if (staProtocol1 == null) {
            return R.parse(param.getTargetSite() + "线程为空!");
        } else {
            staProtocol1 = staProtocol1.clone();
        }
//        if (staProtocol1.isLoading()) {
//            return R.error(staProtocol1.getSiteId() + "站点有物!");
//        }

        if (!staProtocol.isAutoing()) {
            return R.error(staProtocol.getSiteId() + "站点fei自动");
        }
        staProtocol.setWorkNo((short) commonService.getWorkNo(param.getFlag()));
        staProtocol.setStaNo(param.getTargetSite().shortValue());
        basDevpService.updateById(basDevp);
        boolean result = MessageQueue.offer(SlaveType.Devp, 2, new Task(2, staProtocol));
        if (result) {
            return R.ok("成功");
        } else {
            return R.error("下发命令失败:" + param);
        }
    }
}