数据源为 CMS 后台维护的轮播组（cms_banner_group / cms_banner_item）， + * 运营在管理后台配置图片、跳转与生效时间即可生效，无需改前端代码。 + * 仅提供 GET，未登录也可访问（用于首页首屏）。
+ */ +@Tag(name = "汇吉采-首页轮播") +@RestController +@RequestMapping("/api/hjc/banner") +public class HjcBannerController extends BaseController { + + @Resource + private HjcBannerService hjcBannerService; + + @Operation(summary = "启用中的轮播图列表(C端)") + @GetMapping("/list") + public ApiResult为什么需要这个接口：客户端在 JSAPI/requestPayment 失败后只能看到一句错误 + * （用户取消、密码错、还是其实已经付成功了，前端分不清）。而「已支付」是事实， + * 应当以微信侧为准去查，而不是由前端调 {@code /mark-paid} 自说自话。
+ * + *为什么这里要写库（而不只是查）：汇吉采的支付结果回写完全依赖前端—— + * 微信回调 {@code PaymentNotifyController} 只做验签与应答，不认识 hjc 订单； + * 订单置为已支付只有 {@code /mark-paid} 一条路。于是「用户付了钱但页面被关掉/断网」 + * 就会留下一笔已收款却仍显示待支付的订单。这里是唯一以微信侧为准的入口， + * 因此在确认 {@code SUCCESS} 时就地调 {@code markPaid} 补齐状态（幂等，且会触发一站式推送）。
+ * + *安全性：查询前已做「必须登录 + 订单归属校验」，故不存在越权改他人订单状态的问题。
+ */ + @Operation(summary = "查询微信侧支付状态；已支付则顺势修复本单状态") + @GetMapping("/pay-status/{orderNo}") + public ApiResult payStatus(@PathVariable("orderNo") String orderNo) { + User loginUser = getLoginUser(); + if (loginUser == null) { + return HjcAuthResponses.unauthorized(); + } + HjcOrder order = hjcOrderService.getByOrderNo(orderNo); + if (order == null) { + return fail("订单不存在"); + } + ApiResult unreadable = checkReadable(loginUser, order); + if (unreadable != null) { + return unreadable; + } + try { + PaymentResponse resp = paymentService.queryPayment( + orderNo, PaymentType.WECHAT, order.getTenantId()); + String status = resp == null || resp.getPaymentStatus() == null + ? null : resp.getPaymentStatus().name(); + boolean repaired = false; + // 微信说成功了，本地还是未支付 —— 说明前端那次 mark-paid 没送达，这里补齐 + if (PaymentStatus.SUCCESS.name().equals(status) + && (order.getPayStatus() == null || order.getPayStatus() != 1)) { + try { + hjcBizService.markPaid(orderNo); + repaired = true; + log.info("HjcOrder: 查单发现微信已支付，已补写本地订单状态 orderNo={}", orderNo); + } catch (Exception e) { + // 补写失败不影响本次查询结论：前端仍会看到 SUCCESS + log.warn("HjcOrder: 补写本地订单状态失败 orderNo={}", orderNo, e); + } + } + Map两套配置分别来自 Redis：
+ *两套 openid 不可互用：小程序 openid 属于小程序 appid，公众号网页授权 openid 属于 + * 公众号 appid；微信支付 JSAPI 下单要求 openid 与商户号绑定的 appid 同源，故两条链路各自取各自的 + * openid，服务端不做换算。
* * @author WebSoft * @since 2026-09 */ @Tag(name = "汇吉采-微信公众号") +@Slf4j @RestController @RequestMapping("/api/hjc/wechat") public class HjcWechatController extends BaseController { @@ -43,14 +66,128 @@ public class HjcWechatController extends BaseController { private static final String JSAPI_TICKET_KEY = "wx:jsapi:ticket:"; private static final long EXPIRE_SECONDS = 7000L; + /** 小程序配置的 Redis 键前缀（与平台通用小程序配置一致，见 RedisConstants.MP_WX_KEY） */ + private static final String MP_SETTING_KEY_PREFIX = "mp-weixin:"; + /** 小程序在 sys_setting 里的 setting_key */ + private static final String MP_WEIXIN_SETTING_KEY = "mp-weixin"; + @Resource private StringRedisTemplate stringRedisTemplate; @Resource private ConfigProperties configProperties; + @Resource + private HjcAuthProperties hjcAuthProperties; + /** 自检用：读取支付配置（跨库 sys_payment）以核对 appId 一致性 */ + @Resource + private WxPayConfigService wxPayConfigService; + /** 用于回源读取跨库的 sys_setting（小程序配置在 Redis 缺失时的兜底） */ + @Resource + private DataSource dataSource; @Value("${spring.profiles.active:dev}") private String activeProfile; + @Operation(summary = "微信接入自检（只读；管理员；排查「配置到底缺哪一项」）") + @GetMapping("/readiness") + @PreAuthorize("@hjcGuard.isAdmin()") + public ApiResult readiness(@RequestParam(value = "probe", required = false) Boolean probe) { + Integer tenantId = hjcAuthProperties.getTenantId(); + List用 {@link HjcAuthProperties} 的租户 ID，而不是请求头里的 tenantId：小程序登录发生在业务请求 + * 之前，请求头里的租户是客户端可改的，而小程序 appId 只应对应汇吉采自己的那份配置。
+ * + *为什么要依次试三个来源：这套工程里小程序配置存在三套互不一致的键， + * 只认其中任意一个都会出现「后台明明配了、接口却说没配」：
+ *跨库直读用原生 JDBC，既不依赖 common 层那份带坏 JOIN 的旧 mapper（见 ADR-0006）， + * 也不受 MyBatis-Plus 多租户拦截器影响。
+ */ + private WxMpConfig loadMpConfig() { + Integer tenantId = hjcAuthProperties.getTenantId(); + String[] redisKeys = { + MP_SETTING_KEY_PREFIX + tenantId, + SETTING_KEY_PREFIX + ":" + MP_WEIXIN_SETTING_KEY + ":" + tenantId, + }; + for (String key : redisKeys) { + // 缓存读失败不能当成「未配置」：Redis 一次抖动（实测见过 Connection reset） + // 就会让 mp-appid/mp-login 整体失败，而数据库里本来就有一份可用配置。 + // 这里吞掉缓存异常，继续往下走到数据库回源。 + try { + WxMpConfig cfg = parseMpConfig(stringRedisTemplate.opsForValue().get(key)); + if (cfg != null) { + return cfg; + } + } catch (Exception e) { + log.warn("HjcWechat: 读取小程序配置缓存失败，转为回源数据库 key={}", key, e); + } + } + return parseMpConfig(queryMpSettingFromDb(tenantId)); + } + + /** 解析小程序配置 JSON（{@code {"appId":..,"appSecret":..}}），字段不全视为未配置 */ + private WxMpConfig parseMpConfig(String raw) { + if (raw == null || raw.isEmpty()) { + return null; + } + try { + JSONObject json = JSONObject.parseObject(raw); + if (json == null) { + return null; + } + WxMpConfig cfg = new WxMpConfig(); + cfg.appId = json.getString("appId"); + cfg.appSecret = json.getString("appSecret"); + if (cfg.appId == null || cfg.appSecret == null) { + return null; + } + return cfg; + } catch (Exception e) { + log.warn("HjcWechat: 小程序配置解析失败", e); + return null; + } + } + + /** + * 跨库回源读 {@code gxwebsoft_core.sys_setting} 里的小程序配置。 + * + *只读、失败不抛（返回 null 让上层给「未配置」的提示），避免把配置读取的异常 + * 变成小程序登录的整体不可用。
+ */ + private String queryMpSettingFromDb(Integer tenantId) { + String sql = "SELECT content FROM gxwebsoft_core.sys_setting WHERE setting_key = ? AND tenant_id = ? LIMIT 1"; + try (Connection conn = dataSource.getConnection(); + PreparedStatement ps = conn.prepareStatement(sql)) { + ps.setString(1, MP_WEIXIN_SETTING_KEY); + ps.setInt(2, tenantId); + try (ResultSet rs = ps.executeQuery()) { + if (rs.next()) { + return rs.getString(1); + } + } + } catch (Exception e) { + log.warn("HjcWechat: 回源查询小程序配置失败 tenantId={}", tenantId, e); + } + return null; + } + private static class WxOfficialConfig { String appId; String appSecret; } + + private static class WxMpConfig { + String appId; + String appSecret; + } } diff --git a/src/main/java/com/gxwebsoft/hjc/dto/CreatePurchaseDetails.java b/src/main/java/com/gxwebsoft/hjc/dto/CreatePurchaseDetails.java index 6e18c0c..fdb8dea 100644 --- a/src/main/java/com/gxwebsoft/hjc/dto/CreatePurchaseDetails.java +++ b/src/main/java/com/gxwebsoft/hjc/dto/CreatePurchaseDetails.java @@ -1,5 +1,6 @@ package com.gxwebsoft.hjc.dto; +import com.fasterxml.jackson.annotation.JsonInclude; import io.swagger.v3.oas.annotations.media.Schema; import lombok.Data; @@ -45,6 +46,14 @@ public class CreatePurchaseDetails { @Schema(description = "状态：PAID/REFUNDED") private String status; + @Schema(description = "退款时间，yyyy-MM-dd HH:mm:ss（仅 status=REFUNDED 时推送）") + @JsonInclude(JsonInclude.Include.NON_NULL) + private String refundTime; + + @Schema(description = "退款原因（仅 status=REFUNDED 时推送）") + @JsonInclude(JsonInclude.Include.NON_NULL) + private String refundReason; + @Schema(description = "开票状态：NONE/APPLIED/ISSUED") private String invoiceStatus; diff --git a/src/main/java/com/gxwebsoft/hjc/dto/HjcBannerVo.java b/src/main/java/com/gxwebsoft/hjc/dto/HjcBannerVo.java new file mode 100644 index 0000000..0261b8e --- /dev/null +++ b/src/main/java/com/gxwebsoft/hjc/dto/HjcBannerVo.java @@ -0,0 +1,46 @@ +package com.gxwebsoft.hjc.dto; + +import io.swagger.v3.oas.annotations.media.Schema; +import lombok.Data; + +import java.io.Serializable; + +/** + * 买家端轮播图（只读视图对象） + * + *数据来自 CMS 的「轮播组 + 轮播项」（cms_banner_group / cms_banner_item）， + * 已按「启用分组 + 未删除明细 + 生效时间窗口」过滤并扁平化，供 H5 首页直接渲染。 + * 本对象只读，不对应任何 hjc 表。
+ */ +@Data +@Schema(name = "HjcBannerVo", description = "买家端轮播图") +public class HjcBannerVo implements Serializable { + private static final long serialVersionUID = 1L; + + @Schema(description = "轮播项ID") + private Integer itemId; + + @Schema(description = "所属轮播组ID") + private Integer groupId; + + @Schema(description = "标题(轮播项未填时取组标题)") + private String title; + + @Schema(description = "副标题") + private String subtitle; + + @Schema(description = "图片地址") + private String image; + + @Schema(description = "跳转类型: 0无 1外链 2文章 3产品") + private Integer linkType; + + @Schema(description = "跳转地址(外链)") + private String linkUrl; + + @Schema(description = "跳转目标ID(文章/产品)") + private Integer linkTargetId; + + @Schema(description = "排序(组内，越小越靠前)") + private Integer sortNumber; +} diff --git a/src/main/java/com/gxwebsoft/hjc/entity/HjcOrder.java b/src/main/java/com/gxwebsoft/hjc/entity/HjcOrder.java index 027be86..b0005e2 100644 --- a/src/main/java/com/gxwebsoft/hjc/entity/HjcOrder.java +++ b/src/main/java/com/gxwebsoft/hjc/entity/HjcOrder.java @@ -74,6 +74,13 @@ public class HjcOrder implements Serializable { @Schema(description = "支付状态：0待支付 1支付成功 2支付失败 3已退款") private Integer payStatus; + @Schema(description = "退款时间") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + private LocalDateTime refundTime; + + @Schema(description = "退款原因") + private String refundReason; + @Schema(description = "订单状态：0待支付 1已完成 2已取消") private Integer orderStatus; diff --git a/src/main/java/com/gxwebsoft/hjc/mapper/HjcBannerMapper.java b/src/main/java/com/gxwebsoft/hjc/mapper/HjcBannerMapper.java new file mode 100644 index 0000000..ba15e0d --- /dev/null +++ b/src/main/java/com/gxwebsoft/hjc/mapper/HjcBannerMapper.java @@ -0,0 +1,22 @@ +package com.gxwebsoft.hjc.mapper; + +import com.gxwebsoft.hjc.dto.HjcBannerVo; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + * 买家端轮播图查询（只读 CMS 轮播组表） + * + *不继承 BaseMapper：本 Mapper 只做跨模块只读查询，不写任何表。 + * 租户隔离由 MyBatis-Plus 租户拦截器按请求头 tenantId 自动附加。
+ */ +public interface HjcBannerMapper { + + /** + * 查询启用中的轮播项（扁平化，已过滤停用/已删除/不在生效时间窗口内的数据） + * + * @param position 展示位置标识（如 home_slider），为空时不过滤位置 + */ + List为什么单独抽出来：这段逻辑的价值在于「配置缺哪一项」的判定与文案，而它天然是纯函数。 + * 抽成不依赖 Spring 的静态方法后可以直接单测——微信接入的排查成本很高（四套配置、三套 Redis 键、 + * 跨库 sys_payment、以及「支付 appId 必须与小程序 appId 同值」这条隐性约束）， + * 判定错了会把排查方向带偏，所以它值得有测试。
+ */ +public final class HjcWechatReadinessUtil { + + private HjcWechatReadinessUtil() { + } + + /** 追加一条自检项；返回该项是否通过，便于调用方累积总结果 */ + public static boolean addCheck(List自检结果会回给前端，即便调用者是管理员，也没有必要把完整 appId/商户号回显； + * 而 appSecret 这类密钥永不进入自检输出。
+ */ + public static String mask(String v) { + if (v == null) { + return null; + } + String s = v.trim(); + return s.length() <= 10 ? s : s.substring(0, 6) + "…" + s.substring(s.length() - 4); + } + + /** + * 支付 appId 是否与小程序 appId 同值。 + * + *这是本方案里最容易配错、且报错最难懂的一条：微信要求 JSAPI 的 openid 与 + * 「商户号绑定的 appid」同源，而本方案的 openid 来自小程序。两者不同值时， + * 下单会以 {@code APPID_MCHID_NOT_MATCH}（或 openid 与 appid 不匹配）失败， + * 表面看却像「商户号没绑定」。
+ * + *任一侧为空时返回 {@code false}——此时真正的问题在别处（配置缺失）， + * 由对应的单项检查去报，这里不应给出「一致」的假结论。
+ */ + public static boolean sameAppId(String payAppId, String mpAppId) { + return notBlank(payAppId) && notBlank(mpAppId) + && payAppId.trim().equalsIgnoreCase(mpAppId.trim()); + } + + /** 构造自检汇总：ready 为各单项的与，并给出统一说明 */ + public static Map只装配「数据源 + MyBatis-Plus（含租户拦截器）+ 轮播 Controller/Service」的最小上下文， + * 不启动整个应用（避免触发 socketio / 定时任务等副作用），因此不能用 {@code @SpringBootTest} 的默认主类扫描。
+ * + *依赖 dev 环境数据库与 Redis（与仓库其它集成测试一致）。
+ */ +@SpringBootTest(classes = HjcBannerApiTest.MinimalApp.class) +@AutoConfigureMockMvc +@ActiveProfiles("dev") +class HjcBannerApiTest { + + /** 最小装配：只加载轮播接口链路所需的 Bean */ + @SpringBootConfiguration + @EnableAutoConfiguration(exclude = SecurityAutoConfiguration.class) + @MapperScan("com.gxwebsoft.hjc.mapper") + @Import({MybatisPlusConfig.class, RedisUtil.class, HjcBannerServiceImpl.class, HjcBannerController.class}) + static class MinimalApp { + } + + @Autowired + private MockMvc mockMvc; + + @Test + @DisplayName("按租户返回启用中的首页轮播图，字段结构完整") + void listReturnsEnabledHomeSliderBanners() throws Exception { + mockMvc.perform(get("/api/hjc/banner/list").header("tenantId", "10626")) + .andExpect(status().isOk()) + .andExpect(jsonPath("$.code").value(0)) + .andExpect(jsonPath("$.data").isArray()) + // 有配置时每条都必须是「可渲染」的：有 itemId、有图片地址 + .andExpect(jsonPath("$.data[?(@.itemId == null)]").isEmpty()) + .andExpect(jsonPath("$.data[?(@.image == null || @.image == '')]").isEmpty()); + } + + @Test + @DisplayName("未配置轮播的租户返回空数组（不报错、不串租户）") + void listReturnsEmptyForTenantWithoutBanner() throws Exception { + mockMvc.perform(get("/api/hjc/banner/list").header("tenantId", "999999")) + .andExpect(status().isOk()) + .andExpect(jsonPath("$.code").value(0)) + .andExpect(jsonPath("$.data").isEmpty()); + } + + @Test + @DisplayName("position 参数生效：非首页位置不应返回首页轮播") + void listFiltersByPosition() throws Exception { + mockMvc.perform(get("/api/hjc/banner/list") + .header("tenantId", "10626") + .param("position", "inner_page")) + .andExpect(status().isOk()) + .andExpect(jsonPath("$.code").value(0)) + .andExpect(jsonPath("$.data").isEmpty()); + } +} diff --git a/src/test/java/com/gxwebsoft/hjc/service/impl/HjcBizServiceImplPushPayloadTest.java b/src/test/java/com/gxwebsoft/hjc/service/impl/HjcBizServiceImplPushPayloadTest.java new file mode 100644 index 0000000..8b940f0 --- /dev/null +++ b/src/test/java/com/gxwebsoft/hjc/service/impl/HjcBizServiceImplPushPayloadTest.java @@ -0,0 +1,168 @@ +package com.gxwebsoft.hjc.service.impl; + +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.gxwebsoft.hjc.entity.HjcOrder; +import com.gxwebsoft.hjc.entity.HjcOrderPushLog; +import com.gxwebsoft.hjc.service.HjcBidProjectService; +import com.gxwebsoft.hjc.service.HjcEnterpriseService; +import com.gxwebsoft.hjc.service.HjcOrderPushLogService; +import com.gxwebsoft.hjc.service.HjcOrderService; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.extension.ExtendWith; +import org.mockito.ArgumentCaptor; +import org.mockito.InjectMocks; +import org.mockito.Mock; +import org.mockito.Spy; +import org.mockito.junit.jupiter.MockitoExtension; +import org.springframework.web.client.RestTemplate; + +import java.math.BigDecimal; +import java.time.LocalDateTime; + +import static org.junit.jupiter.api.Assertions.assertEquals; +import static org.junit.jupiter.api.Assertions.assertFalse; +import static org.junit.jupiter.api.Assertions.assertNotNull; +import static org.junit.jupiter.api.Assertions.assertTrue; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.Mockito.never; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; + +/** + * 出向推送报文（createPurchaseDetails）字段测试：退款推送必须带「退款时间 + 退款原因」。 + * + *不启动 Spring 上下文、不连数据库：{@code hjc.one-stop.base-url} 未注入（为空）时 + * {@code doPush} 只落推送日志、不发 HTTP，因此可从推送日志的 payload 断言报文。
+ */ +@ExtendWith(MockitoExtension.class) +class HjcBizServiceImplPushPayloadTest { + + private static final ObjectMapper JSON = new ObjectMapper(); + + @Mock + private HjcBidProjectService hjcBidProjectService; + @Mock + private HjcEnterpriseService hjcEnterpriseService; + @Mock + private HjcOrderService hjcOrderService; + @Mock + private HjcOrderPushLogService hjcOrderPushLogService; + @Mock + private RestTemplate restTemplate; + /** 真实 ObjectMapper（序列化报文是断言目标，不能 mock 掉） */ + @Spy + private ObjectMapper objectMapper = new ObjectMapper(); + + @InjectMocks + private HjcBizServiceImpl hjcBizService; + + private HjcOrder paidOrder() { + HjcOrder order = new HjcOrder(); + order.setId(1); + order.setOrderNo("HJC2026080101ABCD"); + order.setProjectNo("ZB-2026-0001"); + order.setProjectName("xxx采购项目"); + order.setUnitPrice(new BigDecimal("500.00")); + order.setQuantity(1); + order.setTotalAmount(new BigDecimal("500.00")); + order.setPayMethod("WECHAT_NATIVE"); + order.setPayStatus(1); + order.setPayTime(LocalDateTime.of(2026, 8, 1, 10, 30, 0)); + order.setEnterpriseName("某某科技有限公司"); + return order; + } + + /** 取本次推送写进推送日志的报文（base-url 为空 → 只写日志不发送） */ + private JsonNode capturedPayload() throws Exception { + ArgumentCaptor这段逻辑决定「排查方向」：把「配置缺失」误判成「配置就绪」会让人去翻微信后台， + * 把「appId 不一致」漏掉则会得到一个看起来像「商户号没绑定」的报错。 + * 所以这几条判定都要钉住。
+ */ +class HjcWechatReadinessUtilTest { + + @Test + void addCheckShouldRecordPassAndReturnIt() { + List