1
4 天以前 803659e33b12c2a089ed25754a2b3a7bca30a9d6
lsh#
1个文件已添加
1个文件已修改
55 ■■■■■ 已修改文件
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskCacheLocSchedules.java 48 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
rsf-server/src/main/java/com/vincent/rsf/server/system/utils/SerialRuleUtils.java 7 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/TaskCacheLocSchedules.java
New file
@@ -0,0 +1,48 @@
package com.vincent.rsf.server.manager.schedules;
import com.vincent.rsf.server.manager.service.*;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
/**
 * @author Munch D. Luffy
 * @date 2026/01/15
 * 缓存区域任务自动触发
 */
@Slf4j
@Component
public class TaskCacheLocSchedules {
    public static Logger logger = LoggerFactory.getLogger(TaskCacheLocSchedules.class);
    @Autowired
    private TaskService taskService;
    /**
     * @author Munch D. Luffy
     * @date 2026/01/15
     * @description: 缓存区域自动生成移库任务
     * @version 1.0
     */
    @Scheduled(cron = "0/3 * * * * ?")
    public void startCacheInLocStock() throws Exception {
    }
    /**
     * @author Munch D. Luffy
     * @date 2026/01/15
     * @description: 缓存区域自动生成空货架出库任务
     * @version 1.0
     */
    @Scheduled(cron = "0/5 * * * * ?  ")
    @Transactional(rollbackFor = Exception.class)
    public void complateOutStock() throws Exception {
    }
}
rsf-server/src/main/java/com/vincent/rsf/server/system/utils/SerialRuleUtils.java
@@ -5,6 +5,7 @@
import com.vincent.rsf.framework.common.SpringUtils;
import com.vincent.rsf.framework.exception.CoolException;
import com.vincent.rsf.server.common.utils.DateUtils;
import com.vincent.rsf.server.system.constant.SerialRuleCode;
import com.vincent.rsf.server.system.entity.SerialRule;
import com.vincent.rsf.server.system.entity.SerialRuleItem;
import com.vincent.rsf.server.system.enums.SerialRuleReset;
@@ -55,6 +56,12 @@
            throw new CoolException("编码规则明细为空!!");
        }
        //银座特供
        if (code.equals(SerialRuleCode.SYS_ASN_ORDER)){
            StringBuffer buffer = new StringBuffer();
            Object poCode = objectToMap(obj).get("poCode");
            return poCode == null ? "" : buffer.append(poCode).toString();
        }
        StringBuffer buffer = new StringBuffer();
        ruleItems.forEach(rule -> {
            if (rule.getWkType().equals(SerialRuleType.WK_CONSTANT.wkType)) {