package com.ruoyi.sales;
|
|
import com.ruoyi.RuoYiApplication;
|
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.condition.EnabledIf;
|
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.jdbc.core.namedparam.MapSqlParameterSource;
|
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
|
import org.springframework.test.annotation.Rollback;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.sql.DataSource;
|
import java.util.Collections;
|
import java.util.List;
|
|
/**
|
* 数据修复：当销售订单主表发货状态为「已发货」时，将下属销售产品行的<b>产品出库审批状态</b>
|
* {@code sales_ledger_product.approve_status} 统一为<b>已出库</b>。
|
* <p>
|
* 与 {@code product-inventory-management-hbtmblc.sql} 中字段注释一致：
|
* {@code sales_ledger.delivery_status} {@code tinyint(1) NOT NULL DEFAULT '0'}：
|
* 发货状态：1-未发货，2-审批中，3-审批不通过，4-审批通过，5-已发货。本任务仅在 {@code 5-已发货} 时同步产品行。
|
* {@code sales_ledger_product.approve_status}：0-未出库，1-已出库，2-待审核，3-审核完成，4-审核失败。
|
* <p>
|
* 仅处理 {@code type = 1} 的销售产品行；仅更新当前 {@code approve_status} 不是 {@code 1}（已出库）的行，避免无意义写库。
|
* <p>
|
* <b>执行前必须</b>：{@code -Druoyi.salesProductApproveStatus.sync.commit=true} 或环境变量
|
* {@code RUOYI_SALES_PRODUCT_APPROVE_STATUS_SYNC_COMMIT=true}。未开启时本用例跳过。
|
*/
|
@SpringBootTest(classes = RuoYiApplication.class)
|
class SalesProductApproveStatusSyncTest {
|
|
private static final Logger log = LoggerFactory.getLogger(SalesProductApproveStatusSyncTest.class);
|
|
/**
|
* 与库注释一致：1 = 已出库
|
*/
|
private static final int APPROVE_STATUS_SHIPPED_OUT = 1;
|
|
/**
|
* 视为「订单已发货、需同步产品状态」的主表 {@code delivery_status}；默认仅 {@code 5}（已发货）。
|
*/
|
private static final List<Integer> DELIVERY_STATUS_TRIGGER_SYNC = Collections.singletonList(5);
|
|
/**
|
* 仅同步这些销售台账主键；空表示全部符合条件的订单。
|
*/
|
private static final List<Long> ONLY_SALES_LEDGER_IDS = Collections.emptyList();
|
|
@SuppressWarnings("unused")
|
static boolean syncCommitEnabled() {
|
String p = System.getProperty("ruoyi.salesProductApproveStatus.sync.commit");
|
if (p != null && "true".equalsIgnoreCase(p.trim())) {
|
return true;
|
}
|
String e = System.getenv("RUOYI_SALES_PRODUCT_APPROVE_STATUS_SYNC_COMMIT");
|
return e != null && "true".equalsIgnoreCase(e.trim());
|
}
|
|
@Autowired
|
private DataSource dataSource;
|
|
@Test
|
@EnabledIf("com.ruoyi.sales.SalesProductApproveStatusSyncTest#syncCommitEnabled")
|
@Transactional
|
@Rollback(false)
|
void syncSalesProductApproveStatusWhenOrderShipped() {
|
NamedParameterJdbcTemplate named = new NamedParameterJdbcTemplate(dataSource);
|
|
MapSqlParameterSource p = new MapSqlParameterSource();
|
p.addValue("outStatus", APPROVE_STATUS_SHIPPED_OUT);
|
p.addValue("dstats", DELIVERY_STATUS_TRIGGER_SYNC);
|
p.addValue("ptype", 1);
|
|
StringBuilder sql = new StringBuilder(
|
"UPDATE sales_ledger_product slp "
|
+ "INNER JOIN sales_ledger sl ON slp.sales_ledger_id = sl.id "
|
+ "SET slp.approve_status = :outStatus "
|
+ "WHERE sl.delivery_status IN (:dstats) "
|
+ "AND slp.type = :ptype "
|
+ "AND (slp.approve_status IS NULL OR slp.approve_status <> :outStatus) ");
|
if (!ONLY_SALES_LEDGER_IDS.isEmpty()) {
|
sql.append("AND sl.id IN (:slids) ");
|
p.addValue("slids", ONLY_SALES_LEDGER_IDS);
|
}
|
|
int updated = named.update(sql.toString(), p);
|
log.warn(
|
"[销售产品 approve_status 同步] 已发货订单 delivery_status in {}，将销售产品 approve_status 置为 {}（已出库），更新行数={}",
|
DELIVERY_STATUS_TRIGGER_SYNC, APPROVE_STATUS_SHIPPED_OUT, updated);
|
}
|
}
|
