From 4592e16ddf0d523dc0487d16b1bf4132fbc586ae Mon Sep 17 00:00:00 2001
From: tuqiang <437016993@qq.com>
Date: Wed, 3 Apr 2024 14:13:26 +0800
Subject: [PATCH] =?UTF-8?q?add:=E6=96=B0=E5=A2=9E=E6=89=8B=E6=8C=81?=
 =?UTF-8?q?=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 acs2/nladmin-system/nlsso-server/pom.xml      |   5 +
 .../BoxPackageManipulatorDeviceDriver.java    |  20 +-
 .../InteractionJsonDTO.java                   |   5 +
 .../box_package_manipulator/ItemProtocol.java |  11 +-
 .../StandardStackerDeviceDriver.java          |   2 +-
 .../SlitTwoManipulatorDeviceDriver.java       |   5 +-
 .../ext/wms/data/CreateHandTaskRequest.java   |  26 +++
 .../ext/wms/data/CreateHandTaskResponse.java  |   9 +
 .../main/java/org/nl/hand/dto/HeadDto.java    |  33 ++++
 .../main/java/org/nl/hand/dto/RegionDto.java  |  17 ++
 .../java/org/nl/hand/rest/HandController.java |  70 +++++++
 .../rest/MobileAuthorizationController.java   |  87 ++++++++
 .../java/org/nl/hand/service/HandService.java |  30 +++
 .../nl/hand/service/impl/HandServiceImpl.java | 187 ++++++++++++++++++
 .../monitor/two_device/two_device.properties  |   2 +-
 .../two_device/two_device_en_US.properties    |   1 +
 .../two_device/two_device_in_ID.properties    |   1 +
 .../two_device/two_device_zh_CN.properties    |   1 +
 .../src/test/java/org/nl/ApplicationTest.java |  40 +++-
 19 files changed, 542 insertions(+), 10 deletions(-)
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskRequest.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskResponse.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/HeadDto.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/RegionDto.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/HandController.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/MobileAuthorizationController.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/HandService.java
 create mode 100644 acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/impl/HandServiceImpl.java

diff --git a/acs2/nladmin-system/nlsso-server/pom.xml b/acs2/nladmin-system/nlsso-server/pom.xml
index ee3e714ea..210d346cb 100644
--- a/acs2/nladmin-system/nlsso-server/pom.xml
+++ b/acs2/nladmin-system/nlsso-server/pom.xml
@@ -440,6 +440,11 @@
             <artifactId>spring-retry</artifactId>
             <version>1.2.5.RELEASE</version>
         </dependency>
+        <dependency>
+            <groupId>io.swagger</groupId>
+            <artifactId>swagger-annotations</artifactId>
+            <version>1.5.22</version>
+        </dependency>
         <!--<dependency>
             <groupId>xerces</groupId>
             <artifactId>xercesImpl</artifactId>
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/BoxPackageManipulatorDeviceDriver.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/BoxPackageManipulatorDeviceDriver.java
index 92cc3f01a..779c290bd 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/BoxPackageManipulatorDeviceDriver.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/BoxPackageManipulatorDeviceDriver.java
@@ -111,6 +111,9 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
     int to_last = 0;
     int last_to_last = 0;
 
+    int to_len = 0;
+    int last_to_len = 0;
+
     Boolean isonline = true;
     int hasGoods = 0;
     String message = "";
@@ -177,7 +180,7 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
             to_max_no = this.itemProtocol.getTo_max_no();
             to_direction = this.itemProtocol.getTo_direction();
             to_last = this.itemProtocol.getTo_last();
-
+            to_len = this.itemProtocol.getTo_len();
 
             if (mode != last_mode) {
 
@@ -251,6 +254,7 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
         last_to_onset = to_onset;
         last_to_seq = to_seq;
         last_to_last = to_last;
+        last_to_len = to_len;
         last_to_direction = to_direction;
         last_to_max_no = to_max_no;
     }
@@ -359,8 +363,9 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
                         Map<String, Object> map7 = new HashMap<>();
                         Map<String, Object> map8 = new HashMap<>();
                         Map<String, Object> map9 = new HashMap<>();
+                        Map<String, Object> map10 = new HashMap<>();
                         try {
-                            pushPLC(map1, map2, next_addr, map3, start_addr, map4, instruction.getInstruction_code(), interactionJsonDTO, map5, map6, map7, map8,map9);
+                            pushPLC(map1, map2, next_addr, map3, start_addr, map4, instruction.getInstruction_code(), interactionJsonDTO, map5, map6, map7, map8,map9,map10);
                         } catch (Exception e) {
 
                             logServer.deviceExecuteLog(device_code, "", "", "当前设备:" + device_code + ",下发指令:"
@@ -437,8 +442,9 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
                         Map<String, Object> map7 = new HashMap<>();
                         Map<String, Object> map8 = new HashMap<>();
                         Map<String, Object> map9 = new HashMap<>();
+                        Map<String, Object> map10 = new HashMap<>();
                         try {
-                            pushPLC(map1, map2, next_addr, map3, start_addr, map4, instdto.getInstruction_code(), interactionJsonDTO, map5, map6, map7, map8,map9);
+                            pushPLC(map1, map2, next_addr, map3, start_addr, map4, instdto.getInstruction_code(), interactionJsonDTO, map5, map6, map7, map8,map9,map10);
                         } catch (Exception e) {
                             logServer.deviceExecuteLog(device_code, "", "", "当前设备:" + device_code + ",下发指令:"
                                     + instdto.getInstruction_code() + ",指令起点:" + instdto.getStart_device_code()
@@ -456,7 +462,7 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
 
     }
 
-    private void pushPLC(Map<String, Object> map1, Map<String, Object> map2, String next_addr, Map<String, Object> map3, String start_addr, Map<String, Object> map4, String task, InteractionJsonDTO interactionJsonDTO, Map<String, Object> map5, Map<String, Object> map6, Map<String, Object> map7, Map<String, Object> map8,Map<String, Object> map9) {
+    private void pushPLC(Map<String, Object> map1, Map<String, Object> map2, String next_addr, Map<String, Object> map3, String start_addr, Map<String, Object> map4, String task, InteractionJsonDTO interactionJsonDTO, Map<String, Object> map5, Map<String, Object> map6, Map<String, Object> map7, Map<String, Object> map8,Map<String, Object> map9,Map<String, Object> map10) {
         List list = new ArrayList();
         map1.put("code", "to_command");
         map1.put("value", 1);
@@ -492,6 +498,12 @@ public class BoxPackageManipulatorDeviceDriver extends AbstractOpcDeviceDriver i
                 map9.put("value", interactionJsonDTO.getBarcode());
                 list.add(map9);
             }
+
+            if (ObjectUtil.isNotEmpty(interactionJsonDTO.getLen())) {
+                map10.put("code", "to_len");
+                map10.put("value", interactionJsonDTO.getLen());
+                list.add(map10);
+            }
         }
         this.writing(list);
     }
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/InteractionJsonDTO.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/InteractionJsonDTO.java
index 2e45f015c..f6dbff375 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/InteractionJsonDTO.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/InteractionJsonDTO.java
@@ -26,4 +26,9 @@ public class InteractionJsonDTO {
      *子卷号
      */
     private String barcode;
+
+    /**
+     *子卷长度
+     */
+    private String len;
 }
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/ItemProtocol.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/ItemProtocol.java
index 9f26e9490..4764e03de 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/ItemProtocol.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/one_manipulator/box_package_manipulator/ItemProtocol.java
@@ -101,6 +101,11 @@ public class ItemProtocol {
      */
     public static String item_to_barcode = "to_barcode";
 
+    /**
+     *下发子卷长度
+     */
+    public static String item_to_len = "to_len";
+
 
     private BoxPackageManipulatorDeviceDriver driver;
 
@@ -174,6 +179,10 @@ public class ItemProtocol {
         return this.getOpcIntegerValue(item_to_last_one);
     }
 
+    public int getTo_len(){
+        return this.getOpcIntegerValue(item_to_len);
+    }
+
 
     Boolean isonline;
 
@@ -243,8 +252,8 @@ public class ItemProtocol {
         list.add(new ItemDto(item_to_direction, "子卷摆放方向", "DB2.D10"));
         list.add(new ItemDto(item_to_seq, "下发木箱工位顺序", "DB2.W12"));
         list.add(new ItemDto(item_to_last_one, "下发是否最后子卷", "DB2.W14"));
+        list.add(new ItemDto(item_to_len, "下发子卷长度", "DB2.W16"));
         list.add(new ItemDto(item_to_barcode, "下发木箱条码", "DB601.STRING1.50"));
-
         return list;
     }
 }
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/stacker/standard_stacker/StandardStackerDeviceDriver.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/stacker/standard_stacker/StandardStackerDeviceDriver.java
index f38f85748..5de581358 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/stacker/standard_stacker/StandardStackerDeviceDriver.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/stacker/standard_stacker/StandardStackerDeviceDriver.java
@@ -359,7 +359,7 @@ public class StandardStackerDeviceDriver extends AbstractOpcDeviceDriver impleme
             count = 0;
         }
 
-        if (mode != 3 || requireSucess) {
+        if (mode != 3 && requireSucess) {
             message = "one_message7";
 
         } else if (error != 0) {
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/two_conveyor/slit_two_manipulator/SlitTwoManipulatorDeviceDriver.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/two_conveyor/slit_two_manipulator/SlitTwoManipulatorDeviceDriver.java
index 4c1504068..4764c0828 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/two_conveyor/slit_two_manipulator/SlitTwoManipulatorDeviceDriver.java
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/device_driver/two_conveyor/slit_two_manipulator/SlitTwoManipulatorDeviceDriver.java
@@ -332,7 +332,7 @@ public class SlitTwoManipulatorDeviceDriver extends AbstractOpcDeviceDriver impl
                     taskDtos = this.sortTask(taskDtos);
                     TaskDto taskDto = taskDtos.get(0);
                     truss_type = taskDto.getTruss_type();
-                    // 9 行架任务
+                    //查询任务是行架任务
                     if (!StrUtil.equals(taskDto.getTask_type(), "6")) {
                         taskDto = null;
                         continue;
@@ -661,7 +661,6 @@ public class SlitTwoManipulatorDeviceDriver extends AbstractOpcDeviceDriver impl
         String action = "";
         String walk_y = "";
         String mode = "";
-        String status = "";
         String is_disable = "";
 
 
@@ -704,6 +703,8 @@ public class SlitTwoManipulatorDeviceDriver extends AbstractOpcDeviceDriver impl
             action = LangProcess.msg("two_action7");
         } else if (this.getAction() == 8) {
             action = LangProcess.msg("two_action8");
+        } else if (this.getAction() == 9) {
+            action = LangProcess.msg("two_action9");
         }
 
 
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskRequest.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskRequest.java
new file mode 100644
index 000000000..1e87c7c12
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskRequest.java
@@ -0,0 +1,26 @@
+package org.nl.acs.ext.wms.data;
+
+import lombok.Data;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 12:17
+ */
+@Data
+public class CreateHandTaskRequest extends BaseRequest {
+
+    /**
+     * 取货点
+     */
+    String start_device_code;
+
+    /**
+     * 放货点
+     */
+    String next_device_code;
+
+    /**
+     * 任务类型
+     */
+    String task_type;
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskResponse.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskResponse.java
new file mode 100644
index 000000000..16cafbf95
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/acs/ext/wms/data/CreateHandTaskResponse.java
@@ -0,0 +1,9 @@
+package org.nl.acs.ext.wms.data;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 12:19
+ */
+public class CreateHandTaskResponse extends BaseResponse {
+
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/HeadDto.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/HeadDto.java
new file mode 100644
index 000000000..f6c362196
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/HeadDto.java
@@ -0,0 +1,33 @@
+package org.nl.hand.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 16:54
+ */
+@Data
+public class HeadDto implements Serializable {
+
+    /**
+     * 起始设备编码
+     */
+    private String start_device_code;
+
+    /**
+     * 目标设备编码
+     */
+    private String next_device_code;
+
+    /**
+     * 任务类型
+     */
+    private String task_type;
+
+    /**
+     * 关键字 可为载具号、指令号、agv车号
+     */
+    private String keyword;
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/RegionDto.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/RegionDto.java
new file mode 100644
index 000000000..9d3ea0308
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/dto/RegionDto.java
@@ -0,0 +1,17 @@
+package org.nl.hand.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 16:50
+ */
+@Data
+public class RegionDto implements Serializable {
+    /**
+     * 区域编号
+     */
+    private String region_code;
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/HandController.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/HandController.java
new file mode 100644
index 000000000..db5bd5cae
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/HandController.java
@@ -0,0 +1,70 @@
+package org.nl.hand.rest;
+
+import cn.dev33.satoken.annotation.SaIgnore;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.common.logging.annotation.Log;
+import org.nl.hand.dto.HeadDto;
+import org.nl.hand.dto.RegionDto;
+import org.nl.hand.service.HandService;
+import org.nl.system.service.dict.dao.Dict;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 10:18
+ */
+
+@RestController
+@RequiredArgsConstructor
+@Api(tags = "手持接口")
+@RequestMapping("api/hand")
+@Slf4j
+public class HandController {
+    @Autowired
+    private HandService handService;
+
+    @PostMapping("/queryArea")
+    @Log("查询区域")
+    @ApiOperation("查询区域")
+    @SaIgnore
+    //@PreAuthorize("@el.check('sect:list')")
+    public ResponseEntity<Object> queryArea() {
+        return new ResponseEntity<>(handService.queryArea(), HttpStatus.OK);
+    }
+
+    @PostMapping("/queryPointByArea")
+    @Log("根据区域编码查点位")
+    @ApiOperation("根据区域编码查点位")
+    @SaIgnore
+    //@PreAuthorize("@el.check('sect:list')")
+    public ResponseEntity<Object> queryPointByArea(@RequestBody RegionDto dto) {
+        String region_code = dto.getRegion_code();
+        return new ResponseEntity<>(handService.queryPointByArea(region_code), HttpStatus.OK);
+    }
+
+    @PostMapping("/callTask")
+    @Log("手持创建任务")
+    @ApiOperation("手持创建任务")
+    @SaIgnore
+    //@PreAuthorize("@el.check('sect:list')")
+    public ResponseEntity<Object> callTask(@RequestBody HeadDto dto) {
+        return new ResponseEntity<>(handService.callTask(dto), HttpStatus.OK);
+    }
+
+    @GetMapping("/insts")
+    @Log("查询未完成指令")
+    @ApiOperation("查询未完成指令")
+    @SaIgnore
+    //@PreAuthorize("@el.check('sect:list')")
+    public ResponseEntity<Object> queryInst(@RequestBody HeadDto dto) {
+        return new ResponseEntity<>(handService.queryInst(dto), HttpStatus.OK);
+    }
+
+
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/MobileAuthorizationController.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/MobileAuthorizationController.java
new file mode 100644
index 000000000..678b72841
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/rest/MobileAuthorizationController.java
@@ -0,0 +1,87 @@
+package org.nl.hand.rest;
+
+import cn.dev33.satoken.annotation.SaIgnore;
+import cn.dev33.satoken.secure.SaSecureUtil;
+import cn.dev33.satoken.stp.SaLoginModel;
+import cn.dev33.satoken.stp.StpUtil;
+import cn.hutool.core.util.ObjectUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.common.exception.BadRequestException;
+import org.nl.common.utils.RsaUtils;
+import org.nl.common.utils.dto.CurrentUser;
+import org.nl.config.RsaProperties;
+import org.nl.system.service.role.ISysRoleService;
+import org.nl.system.service.secutiry.dto.AuthUserDto;
+import org.nl.system.service.user.ISysUserService;
+import org.nl.system.service.user.dao.SysUser;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.annotation.Validated;
+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 java.util.List;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 16:00
+ */
+@Slf4j
+@RestController
+@RequestMapping("/mobile/auth")
+public class MobileAuthorizationController {
+    @Autowired
+    private ISysUserService userService;
+    @Autowired
+    private ISysRoleService roleService;
+
+    @PostMapping(value = "/login")
+    @SaIgnore
+    public ResponseEntity<Object> login(@Validated @RequestBody AuthUserDto authUser, HttpServletRequest request) throws Exception {
+        // 密码解密 - 前端的加密规则: encrypt（根据实际更改）
+        String password = RsaUtils.decryptByPrivateKey(RsaProperties.privateKey, authUser.getPassword());
+        // 校验数据库
+        // 根据用户名查询，在比对密码
+        // 拿到多个已经抛出异常
+        SysUser userInfo = userService.getOne(new LambdaQueryWrapper<SysUser>()
+                .eq(SysUser::getUsername, authUser.getUsername()));
+        // 这里需要密码加密
+        if (ObjectUtil.isEmpty(userInfo) || !userInfo.getPassword().equals(SaSecureUtil.md5BySalt(password, "salt"))) {
+            throw new BadRequestException("账号或密码错误！");
+        }
+        // 获取权限列表 - 登录查找权限
+        List<String> permissionList = roleService.getPermissionList((JSONObject) JSON.toJSON(userInfo));
+
+        // 登录输入，登出删除
+        CurrentUser user = new CurrentUser();
+        user.setId(userInfo.getUser_id());
+        user.setUsername(userInfo.getUsername());
+        user.setPresonName(userInfo.getPerson_name());
+        user.setUser(userInfo);
+        user.setPermissions(permissionList);
+
+        // SaLoginModel 配置登录相关参数
+        StpUtil.login(userInfo.getUser_id(), new SaLoginModel()
+                // 此次登录的客户端设备类型, 用于[同端互斥登录]时指定此次登录的设备类型
+                .setDevice("PE")
+                // Token挂载的扩展参数 （此方法只有在集成jwt插件时才会生效）
+                .setExtra("loginInfo", user)
+        );
+
+        // 返回 token 与 用户信息
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.put("user", userInfo);
+        JSONObject authInfo = new JSONObject(2) {{
+            put("token", "Bearer " + StpUtil.getTokenValue());
+            put("user", jsonObject);
+        }};
+
+        return ResponseEntity.ok(authInfo);
+    }
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/HandService.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/HandService.java
new file mode 100644
index 000000000..a96834471
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/HandService.java
@@ -0,0 +1,30 @@
+package org.nl.hand.service;
+
+
+import com.alibaba.fastjson.JSONArray;
+import org.nl.acs.ext.wms.data.CreateHandTaskResponse;
+import org.nl.hand.dto.HeadDto;
+
+import java.util.Map;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 10:19
+ */
+public interface HandService {
+
+
+    Map<String, Object> queryPointByArea(String region_code);
+
+    /**
+     * 手持创建任务
+     *
+     * @param dto
+     * @return
+     */
+    Map<String, Object> callTask(HeadDto dto);
+
+    Map<String, Object> queryArea();
+
+    Map<String, Object> queryInst(HeadDto dto);
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/impl/HandServiceImpl.java b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/impl/HandServiceImpl.java
new file mode 100644
index 000000000..b18fa2b2e
--- /dev/null
+++ b/acs2/nladmin-system/nlsso-server/src/main/java/org/nl/hand/service/impl/HandServiceImpl.java
@@ -0,0 +1,187 @@
+package org.nl.hand.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.IdUtil;
+import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.nl.acs.common.base.CommonFinalParam;
+import org.nl.acs.device.domain.Device;
+import org.nl.acs.device.service.DeviceService;
+import org.nl.acs.ext.wms.data.CreateHandTaskRequest;
+import org.nl.acs.ext.wms.data.CreateHandTaskResponse;
+import org.nl.acs.ext.wms.data.JsonUtl;
+import org.nl.acs.task.service.TaskService;
+import org.nl.acs.task.service.dto.TaskDto;
+import org.nl.common.exception.BadRequestException;
+import org.nl.common.utils.CodeUtil;
+import org.nl.hand.dto.HeadDto;
+import org.nl.hand.service.HandService;
+import org.nl.system.service.dict.ISysDictService;
+import org.nl.system.service.dict.dao.Dict;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpStatus;
+import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author : TuQiang
+ * @create 2024/4/2 10:20
+ */
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class HandServiceImpl implements HandService {
+
+    @Autowired
+    private DeviceService deviceService;
+    @Autowired
+    private TaskService taskserver;
+    @Autowired
+    private ISysDictService dictService;
+
+    @Override
+    public Map<String, Object> queryPointByArea(String region_code) {
+        JSONArray data = new JSONArray();
+        if (StrUtil.isEmpty(region_code)) {
+            throw new BadRequestException("区域编码不能为空！");
+        }
+
+        //根据区域编码查询所有设备
+        List<Device> list = deviceService.lambdaQuery()
+                .eq(Device::getRegion, region_code)
+                .list();
+        if (CollectionUtil.isEmpty(list)) {
+            throw new BadRequestException("未查到该区域的设备！");
+        }
+        for (int i = 0; i < list.size(); i++) {
+            JSONObject jo = new JSONObject();
+            Device device = list.get(i);
+            String device_id = device.getDevice_id();
+            String device_code = device.getDevice_code();
+            String device_name = device.getDevice_name();
+            BigDecimal seq_num = device.getSeq_num();
+            jo.put("device_id", device_id);
+            jo.put("device_code", device_code);
+            jo.put("device_name", device_name);
+            jo.put("seq_num", seq_num);
+            data.add(jo);
+        }
+        JSONObject resultJson = new JSONObject();
+        resultJson.put("message", "操作成功");
+        resultJson.put("data", data);
+        return resultJson;
+    }
+
+    @Override
+    public Map<String, Object> callTask(HeadDto dto) {
+        JSONArray errArr = new JSONArray();
+        String start_device_code = dto.getStart_device_code();
+        String next_device_code = dto.getNext_device_code();
+        String task_type = dto.getTask_type();
+
+        if (StrUtil.isEmpty(start_device_code)) {
+            JSONObject json = new JSONObject();
+            json.put("message", "起点不能为空");
+            errArr.add(json);
+        }
+        if (StrUtil.isEmpty(next_device_code)) {
+            JSONObject json = new JSONObject();
+            json.put("message", "终点不能为空");
+            errArr.add(json);
+        }
+        if (StrUtil.isEmpty(task_type)) {
+            JSONObject json = new JSONObject();
+            json.put("message", "任务类型不能为空");
+            errArr.add(json);
+        }
+
+        String start_device_code2 = "";
+        String next_device_code2 = "";
+        JSONObject jo = new JSONObject();
+        if (StrUtil.equals(task_type, CommonFinalParam.TYPE_ONE)) {
+            String s = start_device_code.substring(9);
+            if (StrUtil.equals("K", s)) {
+                start_device_code2 = next_device_code.substring(0, 10) + "M";
+                next_device_code2 = start_device_code.substring(0, 9) + "M";
+                jo.put("start_device_code2", start_device_code2);
+                jo.put("next_device_code2", next_device_code2);
+                jo.put("start_point_code2", start_device_code2);
+                jo.put("next_point_code2", next_device_code2);
+            }
+        } else if (StrUtil.equals(task_type, CommonFinalParam.TYPE_TWO)) {
+            start_device_code2 = next_device_code.substring(0, 9) + "K";
+            next_device_code2 = start_device_code.substring(0, 9) + "K";
+            jo.put("start_device_code2", start_device_code2);
+            jo.put("next_device_code2", next_device_code2);
+            jo.put("start_point_code2", start_device_code2);
+            jo.put("next_point_code2", next_device_code2);
+        }
+        jo.put("start_device_code", start_device_code);
+        jo.put("next_device_code", next_device_code);
+        jo.put("start_point_code", start_device_code);
+        jo.put("next_point_code", next_device_code);
+        jo.put("task_type", task_type);
+        jo.put("agv_system_type", "2");
+        jo.put("priority", "1");
+
+        TaskDto task_dto = jo.toJavaObject(TaskDto.class);
+        try {
+            taskserver.create(task_dto);
+        } catch (Exception e) {
+//                    e.printStackTrace();
+            JSONObject json = new JSONObject();
+            json.put("message", e.getMessage());
+            errArr.add(json);
+        }
+        JSONArray data = new JSONArray();
+        JSONObject resultJson = new JSONObject();
+        if (ObjectUtil.isEmpty(errArr)) {
+            resultJson.put("message", "操作成功");
+            resultJson.put("data", data);
+        } else {
+            resultJson.put("message", "操作失败");
+            resultJson.put("data", data);
+        }
+        return resultJson;
+    }
+
+    @Override
+    public Map<String, Object> queryArea() {
+        JSONArray data = new JSONArray();
+        List<Dict> list = dictService.lambdaQuery()
+                .eq(Dict::getCode, "region_type")
+                .list();
+        if (CollectionUtil.isEmpty(list)) {
+            throw new BadRequestException("未查到该区域的设备！");
+        }
+        for (int i = 0; i < list.size(); i++) {
+            JSONObject jo = new JSONObject();
+            Dict dict = list.get(i);
+            String region_id = dict.getDict_id();
+            String region_code = dict.getCode();
+            String region_name = dict.getName();
+            jo.put("region_id", region_id);
+            jo.put("region_code", region_code);
+            jo.put("region_name", region_name);
+            data.add(jo);
+        }
+        JSONObject resultJson = new JSONObject();
+        resultJson.put("message", "操作成功");
+        resultJson.put("data", data);
+        return resultJson;
+    }
+
+    @Override
+    public Map<String, Object> queryInst(HeadDto dto) {
+        return null;
+    }
+}
diff --git a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device.properties b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device.properties
index a1443cc99..e65c1e183 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device.properties
+++ b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device.properties
@@ -26,4 +26,4 @@ two_action5=\u540E\u5DE5\u4F4D\u53D6\u8D27\u4E2D
 two_action6=\u540E\u5DE5\u4F4D\u53D6\u8D27\u5B8C\u6210
 two_action7=\u540E\u5DE5\u4F4D\u53D6\u8D27\u4E2D
 two_action8=\u540E\u5DE5\u4F4D\u653E\u8D27\u5B8C\u6210
-
+two_action9=\u4EFB\u52A1\u5B8C\u6210
diff --git a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_en_US.properties b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_en_US.properties
index 79c23e40c..8545e9f3b 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_en_US.properties
+++ b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_en_US.properties
@@ -26,5 +26,6 @@ two_action5=Pick-up at the post-station
 two_action6=After the station pick-up is completed
 two_action7=Pick-up at the post-station
 two_action8=After the station is released, the goods are completed
+two_action9=Mission accomplished
 
 
diff --git a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_in_ID.properties b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_in_ID.properties
index f8607cfb1..76be7af5b 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_in_ID.properties
+++ b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_in_ID.properties
@@ -26,3 +26,4 @@ two_action5=Penjemputan di stasiun pos
 two_action6=Setelah penjemputan stasiun selesai
 two_action7=Penjemputan di stasiun pos
 two_action8=Setelah stasiun dilepaskan, barang selesai
+two_action9=Misi tercapai
diff --git a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_zh_CN.properties b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_zh_CN.properties
index a1443cc99..2ec949054 100644
--- a/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_zh_CN.properties
+++ b/acs2/nladmin-system/nlsso-server/src/main/resources/language/monitor/two_device/two_device_zh_CN.properties
@@ -26,4 +26,5 @@ two_action5=\u540E\u5DE5\u4F4D\u53D6\u8D27\u4E2D
 two_action6=\u540E\u5DE5\u4F4D\u53D6\u8D27\u5B8C\u6210
 two_action7=\u540E\u5DE5\u4F4D\u53D6\u8D27\u4E2D
 two_action8=\u540E\u5DE5\u4F4D\u653E\u8D27\u5B8C\u6210
+two_action9=\u4EFB\u52A1\u5B8C\u6210
 
diff --git a/acs2/nladmin-system/nlsso-server/src/test/java/org/nl/ApplicationTest.java b/acs2/nladmin-system/nlsso-server/src/test/java/org/nl/ApplicationTest.java
index 63063203c..76c4d83da 100644
--- a/acs2/nladmin-system/nlsso-server/src/test/java/org/nl/ApplicationTest.java
+++ b/acs2/nladmin-system/nlsso-server/src/test/java/org/nl/ApplicationTest.java
@@ -2,8 +2,13 @@ package org.nl;
 
 import org.junit.jupiter.api.Test;
 import org.nl.system.service.user.ISysUserService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.scheduling.annotation.Scheduled;
+
+import java.util.Scanner;
 
 /**
  * @Author: lyd
@@ -14,8 +19,41 @@ import org.springframework.boot.test.context.SpringBootTest;
 public class ApplicationTest {
     @Autowired
     private ISysUserService userService;
+
+    private Logger logger = LoggerFactory.getLogger(ApplicationTest.class);
+
     @Test
     void contextLoads() {
-        System.out.println(userService.list());
+        Scanner scanner = new Scanner(System.in);
+        System.out.println("请输入第一个数：");
+        int a = scanner.nextInt();
+        System.out.println("请输入第一个数：");
+        int b = scanner.nextInt();
+        System.out.println("请输入第一个数：");
+        int c = scanner.nextInt();
+        //求最小值
+        int min = (((a < b) ? a : b) < c) ?((a < b) ? a : b):c;
+        //求最大值
+        int max = (((a > b) ? a : b) > c) ?((a > b) ? a : b):c;
+        //求中间值
+        int mid = a + b + c - max - min;
+        //排序
+        System.out.println("最小值为：" + min + "中间值为：" + mid + "最大值为：" + max);
+
+
     }
+
+    @Test
+    @Scheduled(cron = "0/5 * * * * ?")
+    void testOrderTask() {
+        logger.info(Thread.currentThread().getName() + "===task run");
+    }
+
+
+    @org.testng.annotations.Test
+    void demo1() {
+
+
+    }
+
 }