上报次数修改

skyouc

2 天以前 8c5b4882879c11321e1a0e18bb1c2c89f34e8c45

上报次数修改

 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReportMsgServiceImpl.java

@@ -71,8 +71,10 @@
     * @author Ryan
     * @description 上报质检列表
     * @params [items 列表]
     *
     * @return boolean
     * @time 2025/3/7 09:12
     * 11
     */
    @Override
    @Transactional(rollbackFor = Exception.class)

 rsf-server/src/main/java/com/vincent/rsf/server/manager/entity/WkOrder.java

@@ -113,6 +113,9 @@
    @ApiModelProperty("上报状态 0：未上报, 1：已上报")
    private Integer ntyStatus;

    @ApiModelProperty("上报次数")
    private Integer reportOnce;

    /**
     * 释放状态 0:  正常   1:  已释放
     */

 rsf-server/src/main/java/com/vincent/rsf/server/manager/schedules/AsnOrderLogSchedule.java

@@ -116,7 +116,10 @@
     */
    @Transactional(rollbackFor = Exception.class)
    public void reportOrders(List<WkOrder> orders) {
        orders.forEach(order -> {
        for (WkOrder order : orders) {
            if (order.getReportOnce() > 4) {
                continue;
            }
            ReportParams params = new ReportParams();
            List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, order.getId()));
            if (orderItems.isEmpty()) {
@@ -188,10 +191,10 @@

            R reported = reportMsgService.uploadReportOrders(params);
            if (reported.get("code").equals(200)) {
               order.setNtyStatus(1);
               if (!asnOrderService.updateById(order)) {
                   throw new CoolException("上报状态修改失败！！");
               }
                order.setNtyStatus(1);
                if (!asnOrderService.updateById(order)) {
                    throw new CoolException("上报状态修改失败！！");
                }
            }
            try {
                //休眠3秒
@@ -199,8 +202,7 @@
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }

        });
        }
    }