去掉agv任务应用锁

src/main/java/com/gaotao/modules/autoWareHourceHaian/HAIAN_AI_CONTEXT.md

@@ -100,6 +100,7 @@
 - 海安 AGV 反馈接口 `POST /api/wms54/count/agvCallback` 必填 `site/wmsId/taskId/托盘号/targetPoint/targetArea/type`；托盘号兼容 `palletId` 与 `pallet`，两者都有时优先 `palletId`。`targetPoint` 命中三个端口时按 `site+A01` 解析区域，允许在途旧区域码但不依赖旧端口区域记录；其它点位仍按 `haian_area.wcs_area_code -> area_id` 转换后写明细 `to_area`，禁止改变车间等最终目的地。解析后的托盘号在“下达任务”场景写入明细 `pallet_id`；`comment` 在“下达任务”场景写 `source_bill_no`、在RFID复核场景保存复核备注 - rqrq
 - 海安 AGV 回调采用“两段式”：第一段接口仅写 `haian_wms_transport_task_detail(status=已录入)`；第二段由 `HaianWcsSchedule.scheduleAgvFeedback(3.1秒)` 乐观锁消费明细并驱动主任务/托盘状态（下达=calling_flag:Y并创建主任务含from_area、取货=托运中、放货完成=完成+按需移库+回写area/location_code且不改wcs_location、取消=已取消且calling_flag:N）。放货完成若按来源任务号或搬运任务号命中同site、同栈板、类型为“运输栈板”的立库任务，须在本次回调事务内完成该立库主单和明细；外部来源不联动。协议正式 type 只有 `放货完成`，旧名称 `送货完成` 入库/消费前归一成 `放货完成`；接收阶段不申请运输明细写入应用锁，仅按请求 `site+wmsId(taskNo)+type(action_type)` 查询在线表，任意状态已有记录即幂等跳过，不查询 `_history`。- rqrq
 - 海安同步 RFID 复核 `POST /api/wms54/inbound/verifyPalletRfid` 必填 `site=54/taskNo/palletId`；`taskNo` 原样对应 `haian_wms_transport_task_detail.task_no`，但不要求运输主表存在，也不校验任务与托盘的归属。仅按在线表 `site+taskNo+action_type=RFID复核` 判断幂等，不申请写入应用锁，不查询 `_history`；在线已有记录时返回首次响应。在线无记录时按site+palletId一致性读取标签并比较，写 `item_no=1/status=已录入/comment=通过或不通过/pallet_id`，失败再写 `error_code=复核失败/error_msg=原立库resMsg`，完整响应存 `rfid_verify_result_json`。字段及唯一索引升级脚本为 `sql/20261018_haian_rfid_verify_first_result.sql`，归档过程同步复制响应快照仅供追溯。- rqrq
+- 海安同步RFID复核每次调用（首次通过、不通过、在线幂等返回及异常）都通过 `haiAnLogCompleteCall` 独立写 `haian_interface_call_log`，`interface_name=HaiAnWmsMessageService/method_name=verifyInboundPalletRfid/business_key=taskNo`。业务由事务模板完成后记录完整请求、响应（含null字段）、状态及毫秒耗时；正常复核无论通过与否均为 `SUCCESS`，业务或提交异常为 `ERROR` 并保存原错误信息，日志故障不覆盖业务结果。- rqrq
 - 海安 RFID复核消费（`action_type=RFID复核`）只用明细 `site/task_no/pallet_id/comment`，不要求运输主表。`comment` 去空格后不等于 `通过`：先把明细改 `已完成` 并保留首次复核 `error_code/error_msg`，再调 `notifyOutboundPortRfidPalletAction(type=2)` 去异常位；等于 `通过`：先查 `haian_pallet_detail`；无标签则明细改 `已完成` 后再调 `type=1`；有标签且 `scheduler.haianAutoTask.autoIssue.enabled=true` 时，收集全部 `reserve_flag=Y` 且 `reserve_order_ref1` 能关联 `haian_SOIssueNotifyHeader(site+notify_no)` 且 `order_type=shoporder` 的预定标签：只要有一张命中，就写自动发料任务并调用现有海安移库入队，RFID 明细改 `待自动发料`（不进 AGV 定时扫描、不调立库）；开关关闭或未命中则明细改 `已完成` 后再调 `type=1`。立库接口返回仅供记录，托盘移动由定时消费后下发 `POST /api/wms/outbound/rfid-action`；WCS调用失败由明细事务回滚后重试。- rqrq
 - 海安自动发料移库目标区域写死 `HaiAnAreaStaticData.AUTO_ISSUE_TRANSFER_AREA = "A99"`，实际仓库/库位按显式site+A99查询haian_area配置，缺少映射中断建单。`HaiAnPalletTransferService.doWareHouseForPalletForAuto` 回参改为实体 `HaiAnPalletTransferEnqueueResult`（`queueIds`+`message`），无需搬库时 `queueIds` 为空列表并视为 IFS 已完成；三个原调用方仍忽略回参，禁止改 `haian_ifs_pallet_move_queue` 表结构，禁止改老模块 `WmsMessageService.doWareHouseForPalletForAuto` - rqrq
 - 海安自动发料定时任务只读 IFS 队列表：关联 `queueId` 存在 N/P 则继续等；全部关联队列均为Y后，任一条 `result_flag=F` 则不发料，任务与 RFID 明细都改 `已完成`，`error_code=移库失败`，覆盖写 `haian_pallet.remark` 与 RFID `error_msg`，再调立库 `type=2`。全部 `Y` 且全 `S`（或无队列）后：实时查 `handling_unit`，用 `haian_SOIssueNotifyOrderMaterialList_detail` 关联 `haian_SOIssueNotifyOrderList` 按 `site+soorder_no+release+sequence` 分组，经 `HaiAnProductionAutoIssueAdapter` 调用同事 `AutoIssueService.autoIssue`（不改同事方法，`labelCode` 空、`workOrderNo` 空、release/sequence 空填 `*`、`lineItemNo` 由 `BOM_item_no` 转 Integer 失败为 0、`issueQty=qty` 全发）。回参只有 failures，成功标签用送出清单减去失败 handlingUnitId 反推；全成功则解绑、`type=1`、不写失败码；只要有一张失败则成功的解绑、失败的不解绑、`type=2`、`error_code=发料失败`。不论成败先改本地再调立库。已 `issue_flag=S` 的标签禁止再送同事 - rqrq

src/main/java/com/gaotao/modules/autoWareHourceHaian/api/service/impl/HaiAnWmsMessageServiceImpl.java

@@ -1,6 +1,7 @@
 package com.gaotao.modules.autoWareHourceHaian.api.service.impl;
 
 import com.alibaba.fastjson2.JSONObject;
+import com.alibaba.fastjson2.JSONWriter;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.gaotao.modules.autoWareHourceHaian.staticData.HaiAnAgvCallbackTypeStaticData;
 import com.gaotao.modules.autoWareHourceHaian.staticData.HaiAnAreaStaticData;
@@ -47,7 +48,9 @@ import com.gaotao.modules.check.service.PhysicalInventoryService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.PlatformTransactionManager;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.support.TransactionTemplate;
 import org.springframework.util.StringUtils;
 
 import java.math.BigDecimal;
@@ -92,6 +95,10 @@ public class HaiAnWmsMessageServiceImpl implements HaiAnWmsMessageService {
     @Autowired
     private HaiAnInterfaceCallLogService haiAnInterfaceCallLogService;
 
+    /** RFID复核业务事务管理器；在事务提交或回滚后记录接口结果，避免把提交失败误记为调用成功。- rqrq */
+    @Autowired
+    private PlatformTransactionManager transactionManager;
+
     @Autowired
     private HaiAnSysErrorLogService haiAnSysErrorLogService;
 
@@ -185,11 +192,51 @@ public class HaiAnWmsMessageServiceImpl implements HaiAnWmsMessageService {
     /**
      * @Description 立库同步RFID复核：在线表同site+taskNo+RFID复核动作已有记录时复用首次结果，否则比对并写入已录入明细后返回立库报文。- rqrq
      * @param data site、搬运taskNo、palletId必填；rfidBarcodes空值按空盘比对，不要求运输主表已存在。- rqrq
-     * @return 首次响应的完整字段；重复调用返回已保存的首次响应，不因再次扫描改变运输动作。- rqrq
+     * @return 首次响应的完整字段；每次调用独立记录请求、完整响应或异常和耗时，重复调用仍返回已保存的首次响应。- rqrq
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
     public HaiAnInboundRfidVerifyResult verifyInboundPalletRfid(HaiAnInboundRfidVerifyRequest data) {
+        long startTime = System.currentTimeMillis();
+        // 日志以请求site及taskNo定位；缺site时仅日志归属回落54，业务事务仍严格校验原请求，禁止用日志兜底值执行业务。- rqrq
+        String logSite = resolveSite(data == null ? null : data.getSite());
+        String businessKey = data == null ? null : normalizeText(data.getTaskNo());
+        String requestJson = JSONObject.toJSONString(data);
+        HaiAnInboundRfidVerifyResult result = null;
+        String callStatus = "ERROR";
+        String errorMessage = null;
+        try {
+            // 每次调用新建事务模板，由模板统一提交或回滚复核明细；私有方法不依赖同类事务代理，提交失败进入异常日志分支。- rqrq
+            TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);
+            result = transactionTemplate.execute(transactionStatus -> verifyInboundPalletRfidInTransaction(data));
+            // verifyPassed=false是已完成的业务复核结论，调用状态仍为SUCCESS；标签差异保留在完整响应中供日志页面查看。- rqrq
+            callStatus = "SUCCESS";
+            return result;
+        } catch (RuntimeException ex) {
+            // 校验、数据库及事务提交异常保持原样抛给统一异常处理器；独立日志保存异常原因，不改变原接口错误协议。- rqrq
+            errorMessage = ex.getMessage();
+            throw ex;
+        } finally {
+            try {
+                // 每次首次复核或幂等返回均落一条完整海安日志；响应包含null字段，异常保存errorMessage，耗时包含业务事务提交。- rqrq
+                String responseJson = "SUCCESS".equals(callStatus)
+                        ? JSONObject.toJSONString(result, JSONWriter.Feature.WriteNulls) : null;
+                // 通过独立日志服务事务写haian_interface_call_log；业务回滚不丢失日志，日志事务异常仅告警，不覆盖原响应或异常。- rqrq
+                haiAnInterfaceCallLogService.haiAnLogCompleteCall(
+                        "HaiAnWmsMessageService", "verifyInboundPalletRfid", requestJson,
+                        responseJson, callStatus, errorMessage, System.currentTimeMillis() - startTime,
+                        logSite, businessKey, "海安入库RFID同步复核 /api/wms54/inbound/verifyPalletRfid");
+            } catch (RuntimeException logException) {
+                log.warn("海安RFID复核接口日志写入失败 - rqrq，site=" + logSite + "，taskNo=" + businessKey, logException);
+            }
+        }
+    }
+
+    /**
+     * @Description 在调用方事务模板内执行RFID复核与在线幂等判断；本方法不申请应用锁，不读取历史表，异常交由外层回滚并记接口日志。- rqrq
+     * @param data 原始立库请求，site、taskNo和palletId在本方法中校验，不使用日志兜底参数。- rqrq
+     * @return 已在线保存的首次完整复核响应；在线无记录时完成本次比对并写入明细。- rqrq
+     */
+    private HaiAnInboundRfidVerifyResult verifyInboundPalletRfidInTransaction(HaiAnInboundRfidVerifyRequest data) {
         if (data == null || !StringUtils.hasText(data.getSite())
                 || !StringUtils.hasText(data.getTaskNo())
                 || !StringUtils.hasText(data.getPalletId())) {