diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/AppRun.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/AppRun.java index 0065f867..7a4df8e0 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/AppRun.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/AppRun.java @@ -3,6 +3,7 @@ package org.nl; import cn.dev33.satoken.annotation.SaIgnore; import org.dromara.dynamictp.core.spring.EnableDynamicTp; import org.mybatis.spring.annotation.MapperScan; +import org.nl.common.websocket.heartSocket.clientSocket.HeartClientServer; import org.springframework.boot.CommandLineRunner; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @@ -15,6 +16,8 @@ import org.springframework.transaction.annotation.EnableTransactionManagement; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RestController; +import java.net.InetSocketAddress; + /** * 开启审计功能 -> @EnableJpaAuditing * https://www.cnblogs.com/niceyoo/p/10908647.html @@ -30,7 +33,7 @@ import org.springframework.web.bind.annotation.RestController; @ServletComponentScan @EnableTransactionManagement @MapperScan("org.nl.**.mapper") -//@EnableDynamicTp +@EnableDynamicTp public class AppRun implements CommandLineRunner { public static void main(String[] args) { SpringApplication.run(AppRun.class, args); @@ -39,7 +42,7 @@ public class AppRun implements CommandLineRunner { @Override public void run(String... args) { -// HeartClientServer heartServer = new HeartClientServer(new InetSocketAddress("192.168.10.60", 20889)); + HeartClientServer heartServer = new HeartClientServer(new InetSocketAddress("192.168.8.218", 20889)); System.out.println("--------项目启动完成--------"); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/decisioner/impl/diy/PassRCLHandler.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/decisioner/impl/diy/PassRCLHandler.java index 3e6ce407..3d3dc768 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/decisioner/impl/diy/PassRCLHandler.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/decision_manage/handler/decisioner/impl/diy/PassRCLHandler.java @@ -21,7 +21,7 @@ import java.util.stream.Stream; * 手动过滤XYZ排信息 * {"y":[1,2,3,104,103,102]} */ -//@Service("passRCL") +@Service("passRCL") @Slf4j public class PassRCLHandler extends Decisioner { //现场1/4排深位 diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/AbstractTask.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/AbstractTask.java index d3c668ce..ca4445b1 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/AbstractTask.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/AbstractTask.java @@ -1,6 +1,7 @@ package org.nl.wms.dispatch_manage.task.handler; +import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; @@ -31,6 +32,7 @@ public abstract class AbstractTask { ISchBaseTaskService taskService = SpringContextHolder.getBean(ISchBaseTaskService.class); taskService.update(new UpdateWrapper() .set("status",data.getString("status")) + .set("update_time", DateUtil.now()) .eq("task_code",data.getString("task_code"))); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/OutStorageTask.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/OutStorageTask.java index 1a1f94ec..5f4a7630 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/OutStorageTask.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/handler/impl/OutStorageTask.java @@ -180,6 +180,7 @@ public class OutStorageTask extends AbstractTask { @Override public void cancel(JSONObject data) { this.updateTask(data); + //更新起点终点状态 } private static String getZdPoint(int row,String source_code) { diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dao/mapper/xml/SchBaseTaskMapper.xml b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dao/mapper/xml/SchBaseTaskMapper.xml index d808c3ab..b8b54a71 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dao/mapper/xml/SchBaseTaskMapper.xml +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dao/mapper/xml/SchBaseTaskMapper.xml @@ -26,8 +26,8 @@ AND t.create_time #{whereJson.end_time} - - AND t.create_time =]]> #{whereJson.begin_time} + + AND t.create_time =]]> #{whereJson.start_time} AND t.status IN diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dto/SchBaseTaskQuery.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dto/SchBaseTaskQuery.java index 7592d7d0..2b4dc518 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dto/SchBaseTaskQuery.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/dto/SchBaseTaskQuery.java @@ -13,7 +13,7 @@ public class SchBaseTaskQuery implements Serializable { private String task_code; private String vehicle_code; private String point_code; - private String begin_time; + private String start_time; private String end_time; private String more_status; private String unFinished; diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/impl/SchBaseTaskServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/impl/SchBaseTaskServiceImpl.java index 9980e8a3..f6a41979 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/impl/SchBaseTaskServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/dispatch_manage/task/service/impl/SchBaseTaskServiceImpl.java @@ -130,6 +130,9 @@ public class SchBaseTaskServiceImpl extends ServiceImpl().eq("task_code", task_code)); + if (task==null){ + return; + } if (task.getStatus().equals(StatusEnum.FORM_STATUS.code("完成"))) { throw new BadRequestException("当前任务已完成"); } @@ -194,8 +197,11 @@ public class SchBaseTaskServiceImpl extends ServiceImpl().eq("struct_code", struct_code)); - SchBaseTask task = this.getOne(new QueryWrapper().eq("task_code", task_code)); - + SchBaseTask task = this.getOne(new QueryWrapper() + .eq("task_code", task_code)); + if (task == null){ + return null; + } switch (type) { case "ck": MdPbVehicleMater vehicleCode = iMdPbVehicleMaterService.getOne(new QueryWrapper() @@ -210,6 +216,7 @@ public class SchBaseTaskServiceImpl extends ServiceImpl() .set("update_time", DateUtil.now()) .set("vehicle_code", null) + .set("lock_type", StatusEnum.LOCK.code("无锁")) .set("remark", struct_code + "空出异常") .eq("struct_code", struct_code)); this.update(new UpdateWrapper() @@ -222,7 +229,6 @@ public class SchBaseTaskServiceImpl extends ServiceImpl() .eq("vehicle_code", vehicleCode) - .isNull("proc_inst_id") .eq("is_delete", false)); if (vehicleMater == null){ throw new BadRequestException(String.format(vehicleCode+"载具组盘信息不存在")); diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java index 2928521f..71355f49 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/io/service/iostor/impl/StIvtIostorinvServiceImpl.java @@ -235,11 +235,16 @@ public class StIvtIostorinvServiceImpl extends ServiceImpl() + .set("lock_type",StatusEnum.LOCK.code("无锁")) + .in("vehicle_code", Arrays.asList(split)) + ); iStIvtIostorinvDtlService.update(new UpdateWrapper() .set("vehicle_code", null) .set("vehicle_id", null) .eq("id", form.getString("id"))); - this.update(new UpdateWrapper() .set("status", StatusEnum.FORM_STATUS.code("生成")) .eq("id", form.getString("inv_id"))); diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/pick/service/PickingService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/pick/service/PickingService.java index e1b0cd22..873244e5 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/pick/service/PickingService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/stor_manage/pick/service/PickingService.java @@ -112,6 +112,10 @@ public class PickingService { throw new BadRequestException("创建失败:未配置任务类型"); } String outbound = data.getForm_data().getString("outbound"); + String is_move = data.getForm_data().getString("is_move"); + if (StringUtils.isEmpty(is_move)){ + data.getForm_data().put("is_move","true"); + } if (task_type.equals("23") && StringUtils.isEmpty(outbound)){ throw new BadRequestException("创建失败:拣选出库未选择出库口"); } diff --git a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/system_manage/service/quartz/task/TaskScheduleService.java b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/system_manage/service/quartz/task/TaskScheduleService.java index bdd1fcee..2e110107 100644 --- a/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/system_manage/service/quartz/task/TaskScheduleService.java +++ b/wms_pro/hd/nladmin-system/src/main/java/org/nl/wms/system_manage/service/quartz/task/TaskScheduleService.java @@ -57,7 +57,6 @@ public class TaskScheduleService { public void taskPublish(){ boolean islock = lock.tryLock(); try { - log.info("111---执行定时任务:-----taskPublish-----"); if (islock){ //查询所有自动下发的任务 List list = iSchBaseTaskService.list(new QueryWrapper().eq("is_send", true) @@ -65,7 +64,7 @@ public class TaskScheduleService { if (!CollectionUtils.isEmpty(list)){ List taskCodes = list.stream().map(SchBaseTask::getTask_code).collect(Collectors.toList()); - log.info("222---执行定时任务:-----taskPublish-----"+ taskCodes); + log.info("---执行定时222任务:-----taskPublish-----"+ taskCodes); TableDataInfo response = wmsToAcsService.interationToExt(list, "createTask"); if (!response.getCode().equals(String.valueOf(HttpStatus.HTTP_OK))){ JSONArray results = (JSONArray)JSON.toJSON(response.getData()); @@ -83,7 +82,7 @@ public class TaskScheduleService { if (!CollectionUtils.isEmpty(taskCodes)){ iSchBaseTaskService.update(new UpdateWrapper() .set("status",StatusEnum.FORM_STATUS.code("下发")) - .in("task_codse",taskCodes)); + .in("task_code",taskCodes)); } } } diff --git a/wms_pro/hd/nladmin-system/src/main/resources/config/application-dev3.yml b/wms_pro/hd/nladmin-system/src/main/resources/config/application-dev3.yml index 78cb9ff3..424fb1af 100644 --- a/wms_pro/hd/nladmin-system/src/main/resources/config/application-dev3.yml +++ b/wms_pro/hd/nladmin-system/src/main/resources/config/application-dev3.yml @@ -7,21 +7,21 @@ spring: druid: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://${DB_HOST:192.168.1.218}:${DB_PORT:3306}/${DB_NAME:wms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + url: jdbc:mysql://${DB_HOST:192.168.8.218}:${DB_PORT:3306}/${DB_NAME:wms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false # url: jdbc:mysql://${DB_HOST:127.0.0.1}:${DB_PORT:3306}/${DB_NAME:wms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false username: ${DB_USER:root} password: ${DB_PWD:123456} # 初始连接数 - initial-size: 5 + initial-size: 15 # 最小连接数 - min-idle: 15 + min-idle: 25 # 最大连接数 - max-active: 30 + max-active: 40 # 是否自动回收超时连接 remove-abandoned: true # 超时时间(以秒数为单位) - remove-abandoned-timeout: 10 + remove-abandoned-timeout: 20 # 获取连接超时时间 max-wait: 9000 # 连接有效性检测时间 diff --git a/wms_pro/hd/nladmin-system/src/main/resources/config/application-prod.yml b/wms_pro/hd/nladmin-system/src/main/resources/config/application-prod.yml index a48dc0b4..d5b76700 100644 --- a/wms_pro/hd/nladmin-system/src/main/resources/config/application-prod.yml +++ b/wms_pro/hd/nladmin-system/src/main/resources/config/application-prod.yml @@ -1,29 +1,29 @@ server: - port: 8011 + port: 8012 + max-http-header-size: 65536 #配置数据源 spring: datasource: druid: db-type: com.alibaba.druid.pool.DruidDataSource driverClassName: com.mysql.cj.jdbc.Driver - url: jdbc:mysql://${DB_HOST:192.168.46.5}:${DB_PORT:3306}/${DB_NAME:hl_one_lms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false - # url: jdbc:log4jdbc:mysql://${DB_HOST:localhost}:${DB_PORT:3306}/${DB_NAME:hl_one_mes}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false +# url: jdbc:mysql://${DB_HOST:192.168.8.218}:${DB_PORT:3306}/${DB_NAME:wms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false + url: jdbc:mysql://${DB_HOST:127.0.0.1}:${DB_PORT:3306}/${DB_NAME:wms}?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true&allowPublicKeyRetrieval=true&useSSL=false username: ${DB_USER:root} - # password: ${DB_PWD:123456} password: ${DB_PWD:123456} # 初始连接数 - initial-size: 10 + initial-size: 15 # 最小连接数 - min-idle: 10 + min-idle: 25 # 最大连接数 - max-active: 100 + max-active: 40 # 是否自动回收超时连接 remove-abandoned: true # 超时时间(以秒数为单位) - remove-abandoned-timeout: 180 + remove-abandoned-timeout: 20 # 获取连接超时时间 - max-wait: 5000 + max-wait: 9000 # 连接有效性检测时间 time-between-eviction-runs-millis: 60000 # 连接在池中最小生存的时间 @@ -112,7 +112,6 @@ jwt: generator: enabled: true - # IP 本地解析 ip: local-parsing: true @@ -150,38 +149,9 @@ sa-token: jwt-secret-key: opsjajisdnnca0sdkksdfaaasdfwwq # token 前缀 token-prefix: - cookie: - # 配置 Cookie 作用域:根据二级域名实现sso登入如lms.sso.com;acs.sso.com - domain: is-read-cookie: false is-print: false - -#jetcache: -# defaultCacheType: LOCAL -# statIntervalMinutes: 15 -# areaInCacheName: false -# hiddenPackages: com.yb -# local: -# default: -# type: caffeine -# limit: 100 -# keyConvertor: fastjson -# expireAfterWriteInMillis: 60000 -# remote: -# default: -# type: redis.lettuce -# keyConvertor: fastjson -# valueEncoder: kryo -# valueDecoder: kryo -# poolConfig: -# minIdle: 5 -# maxIdle: 200 -# maxTotal: 1000 -# uri: -# - redis://127.0.0.1:6379 -es: - index: mes_log -schedulerFile: C:\lms\scheduler.xml +schedulerFile: /Users/mima0000/Desktop/scheduler.xml lucene: index: - path: E:\lms\lucene\index + path: D:\lms\lucene\index diff --git a/wms_pro/qd/src/views/wms/stor_manage/warehouse/pick/TaskDialog.vue b/wms_pro/qd/src/views/wms/stor_manage/warehouse/pick/TaskDialog.vue index d4ecadee..c17c58dd 100644 --- a/wms_pro/qd/src/views/wms/stor_manage/warehouse/pick/TaskDialog.vue +++ b/wms_pro/qd/src/views/wms/stor_manage/warehouse/pick/TaskDialog.vue @@ -9,45 +9,52 @@ @close="close" > - + - 保存 + 保存 关闭 - + - + - + - + - + - + - + - + - + - + @@ -92,20 +99,26 @@ size="mini" border :highlight-current-row="true" - @current-change="handleDtlCurrentChange" :header-cell-style="{background:'#f5f7fa',color:'#606266'}" + @current-change="handleDtlCurrentChange" > - - - - - - - + + + + + + + - + - - - - - + + + + + - - + +
作业明细 - + - - - - + + + + - + - + - + @@ -249,18 +284,17 @@