diff --git a/share-space-admin/src/main/java/com/ruoyi/web/controller/Tst.java b/share-space-admin/src/main/java/com/ruoyi/web/controller/Tst.java new file mode 100644 index 0000000..a25acd6 --- /dev/null +++ b/share-space-admin/src/main/java/com/ruoyi/web/controller/Tst.java @@ -0,0 +1,38 @@ +package com.ruoyi.web.controller; + +import cn.hutool.core.lang.Validator; +import cn.hutool.core.net.url.UrlBuilder; +import cn.hutool.core.util.ReUtil; +import cn.hutool.http.HttpRequest; +import cn.hutool.http.HttpUtil; + +public class Tst { + + public static void main(String[] args) { + + /** + author:157239486 优惠券 核销 writeOff 团购 + * 输码校验 encrypted_data + */ + + String uri = "https://open.douyin.com/goodlife/v1/fulfilment/certificate/prepare/"; + + //二维码扫描出来的短链 + String tempUri = "https://v.douyin.com/i5WxdEgD/"; + + String res = HttpUtil.get(tempUri); + //获取objectId + String encryptedDataUri = ReUtil.getGroup0(Validator.URL, res); + String objectId = UrlBuilder.of(encryptedDataUri).getQuery().get("object_id").toString(); + System.out.println(objectId); + +// String result = HttpRequest.get(uri) +// .contentType("application/json") +// .header("access-token", "clt.2515da8e47993967e30d85fbe8265abaFlf7gCwUaEIsjwtfJtopESDVXLH5_lf") +// .form("encrypted_data", objectId).execute().body(); + +// System.out.println(result); + + + } +} diff --git a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardController.java b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardController.java index e08019e..af2b8d3 100644 --- a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardController.java +++ b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardController.java @@ -3,6 +3,8 @@ package com.ruoyi.web.controller.system; import java.util.List; import javax.servlet.http.HttpServletResponse; +import com.alibaba.fastjson2.JSON; +import com.ruoyi.ss.card.domain.GroupBuyingDTO; import com.ruoyi.ss.card.service.ISsCardAssembler; import org.springframework.security.access.prepost.PreAuthorize; import org.springframework.beans.factory.annotation.Autowired; @@ -36,10 +38,10 @@ import com.ruoyi.common.core.page.TableDataInfo; public class CardController extends BaseController { @Autowired - private ISsCardService ssCardService; + private ISsCardService cardService; @Autowired - private ISsCardAssembler ssCardAssembler; + private ISsCardAssembler cardAssembler; /** @@ -51,8 +53,8 @@ public class CardController extends BaseController { startPage(); startOrderBy(); - List list = ssCardService.selectSsCardList(query); - ssCardAssembler.assembleInfo(list); + List list = cardService.selectSsCardList(query); + cardAssembler.assembleInfo(list); return getDataTable(list); } @@ -64,7 +66,7 @@ public class CardController extends BaseController @PostMapping("/export") public void export(HttpServletResponse response, SsCardQuery query) { - List list = ssCardService.selectSsCardList(query); + List list = cardService.selectSsCardList(query); ExcelUtil util = new ExcelUtil(SsCardVO.class); util.exportExcel(response, list, "卡券数据"); } @@ -76,7 +78,7 @@ public class CardController extends BaseController @GetMapping(value = "/{couponId}") public AjaxResult getInfo(@PathVariable("couponId") Long couponId) { - return success(ssCardService.selectSsCardByCouponId(couponId)); + return success(cardService.selectSsCardByCouponId(couponId)); } /** @@ -87,7 +89,7 @@ public class CardController extends BaseController @PostMapping public AjaxResult add(@RequestBody SsCard ssCard) { - return toAjax(ssCardService.insertSsCard(ssCard)); + return toAjax(cardService.insertSsCard(ssCard)); } /** @@ -98,7 +100,7 @@ public class CardController extends BaseController @PutMapping public AjaxResult edit(@RequestBody SsCard ssCard) { - return toAjax(ssCardService.updateSsCard(ssCard)); + return toAjax(cardService.updateSsCard(ssCard)); } /** @@ -109,6 +111,18 @@ public class CardController extends BaseController @DeleteMapping("/{couponIds}") public AjaxResult remove(@PathVariable Long[] couponIds) { - return toAjax(ssCardService.deleteSsCardByCouponIds(couponIds)); + return toAjax(cardService.deleteSsCardByCouponIds(couponIds)); } + + /** + * 验券 + */ + @Log(title = "验券", businessType = BusinessType.PREPARE) + @GetMapping("/prepare") + public AjaxResult prepare(GroupBuyingDTO dto) + { + logger.info("验券：{}", JSON.toJSON(dto)); + return toAjax(cardService.prepare(dto)); + } + } diff --git a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardGetRecordsController.java b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardGetRecordsController.java new file mode 100644 index 0000000..8eaff34 --- /dev/null +++ b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CardGetRecordsController.java @@ -0,0 +1,107 @@ +package com.ruoyi.web.controller.system; + +import java.util.List; +import javax.servlet.http.HttpServletResponse; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecords; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsVO; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsQuery; +import com.ruoyi.ss.cardGetRecords.service.ICardGetRecordsService; +import com.ruoyi.common.utils.poi.ExcelUtil; +import com.ruoyi.common.core.page.TableDataInfo; + +/** + * 卡券领取（购买）记录Controller + * + * @author qzz + * @date 2025-03-19 + */ +@RestController +@RequestMapping("/system/getRecords") +public class CardGetRecordsController extends BaseController +{ + @Autowired + private ICardGetRecordsService cardGetRecordsService; + + /** + * 查询卡券领取（购买）记录列表 + */ + @PreAuthorize("@ss.hasPermi('system:getRecords:list')") + @GetMapping("/list") + public TableDataInfo list(CardGetRecordsQuery query) + { + startPage(); + startOrderBy(); + List list = cardGetRecordsService.selectCardGetRecordsList(query); + return getDataTable(list); + } + + /** + * 导出卡券领取（购买）记录列表 + */ + @PreAuthorize("@ss.hasPermi('system:getRecords:export')") + @Log(title = "卡券领取（购买）记录", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, CardGetRecordsQuery query) + { + List list = cardGetRecordsService.selectCardGetRecordsList(query); + ExcelUtil util = new ExcelUtil(CardGetRecordsVO.class); + util.exportExcel(response, list, "卡券领取（购买）记录数据"); + } + + /** + * 获取卡券领取（购买）记录详细信息 + */ + @PreAuthorize("@ss.hasPermi('system:getRecords:query')") + @GetMapping(value = "/{recordId}") + public AjaxResult getInfo(@PathVariable("recordId") Long recordId) + { + return success(cardGetRecordsService.selectCardGetRecordsByRecordId(recordId)); + } + + /** + * 新增卡券领取（购买）记录 + */ + @PreAuthorize("@ss.hasPermi('system:getRecords:add')") + @Log(title = "卡券领取（购买）记录", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody CardGetRecords cardGetRecords) + { + return toAjax(cardGetRecordsService.insertCardGetRecords(cardGetRecords)); + } + + /** + * 修改卡券领取（购买）记录 + */ + @PreAuthorize("@ss.hasPermi('system:getRecords:edit')") + @Log(title = "卡券领取（购买）记录", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody CardGetRecords cardGetRecords) + { + return toAjax(cardGetRecordsService.updateCardGetRecords(cardGetRecords)); + } + + /** + * 删除卡券领取（购买）记录 + */ + @PreAuthorize("@ss.hasPermi('system:getRecords:remove')") + @Log(title = "卡券领取（购买）记录", businessType = BusinessType.DELETE) + @DeleteMapping("/{recordIds}") + public AjaxResult remove(@PathVariable Long[] recordIds) + { + return toAjax(cardGetRecordsService.deleteCardGetRecordsByRecordIds(recordIds)); + } +} diff --git a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CheckoffRecordsController.java b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CheckoffRecordsController.java new file mode 100644 index 0000000..4cb9af8 --- /dev/null +++ b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/CheckoffRecordsController.java @@ -0,0 +1,107 @@ +package com.ruoyi.web.controller.system; + +import java.util.List; +import javax.servlet.http.HttpServletResponse; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.ss.checkoff.domain.CheckoffRecords; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsVO; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsQuery; +import com.ruoyi.ss.checkoff.service.ICheckoffRecordsService; +import com.ruoyi.common.utils.poi.ExcelUtil; +import com.ruoyi.common.core.page.TableDataInfo; + +/** + * 核销记录Controller + * + * @author qzz + * @date 2025-03-18 + */ +@RestController +@RequestMapping("/system/records") +public class CheckoffRecordsController extends BaseController +{ + @Autowired + private ICheckoffRecordsService checkoffRecordsService; + + /** + * 查询核销记录列表 + */ + @PreAuthorize("@ss.hasPermi('system:records:list')") + @GetMapping("/list") + public TableDataInfo list(CheckoffRecordsQuery query) + { + startPage(); + startOrderBy(); + List list = checkoffRecordsService.selectCheckoffRecordsList(query); + return getDataTable(list); + } + + /** + * 导出核销记录列表 + */ + @PreAuthorize("@ss.hasPermi('system:records:export')") + @Log(title = "核销记录", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, CheckoffRecordsQuery query) + { + List list = checkoffRecordsService.selectCheckoffRecordsList(query); + ExcelUtil util = new ExcelUtil(CheckoffRecordsVO.class); + util.exportExcel(response, list, "核销记录数据"); + } + + /** + * 获取核销记录详细信息 + */ + @PreAuthorize("@ss.hasPermi('system:records:query')") + @GetMapping(value = "/{checkoffId}") + public AjaxResult getInfo(@PathVariable("checkoffId") Long checkoffId) + { + return success(checkoffRecordsService.selectCheckoffRecordsByCheckoffId(checkoffId)); + } + + /** + * 新增核销记录 + */ + @PreAuthorize("@ss.hasPermi('system:records:add')") + @Log(title = "核销记录", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody CheckoffRecords checkoffRecords) + { + return toAjax(checkoffRecordsService.insertCheckoffRecords(checkoffRecords)); + } + + /** + * 修改核销记录 + */ + @PreAuthorize("@ss.hasPermi('system:records:edit')") + @Log(title = "核销记录", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody CheckoffRecords checkoffRecords) + { + return toAjax(checkoffRecordsService.updateCheckoffRecords(checkoffRecords)); + } + + /** + * 删除核销记录 + */ + @PreAuthorize("@ss.hasPermi('system:records:remove')") + @Log(title = "核销记录", businessType = BusinessType.DELETE) + @DeleteMapping("/{checkoffIds}") + public AjaxResult remove(@PathVariable Long[] checkoffIds) + { + return toAjax(checkoffRecordsService.deleteCheckoffRecordsByCheckoffIds(checkoffIds)); + } +} diff --git a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/StoreMappingController.java b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/StoreMappingController.java new file mode 100644 index 0000000..25ef7e0 --- /dev/null +++ b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/StoreMappingController.java @@ -0,0 +1,107 @@ +package com.ruoyi.web.controller.system; + +import java.util.List; +import javax.servlet.http.HttpServletResponse; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.PutMapping; +import org.springframework.web.bind.annotation.DeleteMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; +import com.ruoyi.common.annotation.Log; +import com.ruoyi.common.core.controller.BaseController; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.enums.BusinessType; +import com.ruoyi.ss.mapping.domain.StoreMapping; +import com.ruoyi.ss.mapping.domain.StoreMappingVO; +import com.ruoyi.ss.mapping.domain.StoreMappingQuery; +import com.ruoyi.ss.mapping.service.IStoreMappingService; +import com.ruoyi.common.utils.poi.ExcelUtil; +import com.ruoyi.common.core.page.TableDataInfo; + +/** + * 系统与第三方店铺映射关系Controller + * + * @author qzz + * @date 2025-03-18 + */ +@RestController +@RequestMapping("/system/mapping") +public class StoreMappingController extends BaseController +{ + @Autowired + private IStoreMappingService storeMappingService; + + /** + * 查询系统与第三方店铺映射关系列表 + */ + @PreAuthorize("@ss.hasPermi('system:mapping:list')") + @GetMapping("/list") + public TableDataInfo list(StoreMappingQuery query) + { + startPage(); + startOrderBy(); + List list = storeMappingService.selectStoreMappingList(query); + return getDataTable(list); + } + + /** + * 导出系统与第三方店铺映射关系列表 + */ + @PreAuthorize("@ss.hasPermi('system:mapping:export')") + @Log(title = "系统与第三方店铺映射关系", businessType = BusinessType.EXPORT) + @PostMapping("/export") + public void export(HttpServletResponse response, StoreMappingQuery query) + { + List list = storeMappingService.selectStoreMappingList(query); + ExcelUtil util = new ExcelUtil(StoreMappingVO.class); + util.exportExcel(response, list, "系统与第三方店铺映射关系数据"); + } + + /** + * 获取系统与第三方店铺映射关系详细信息 + */ + @PreAuthorize("@ss.hasPermi('system:mapping:query')") + @GetMapping(value = "/{storeId}") + public AjaxResult getInfo(@PathVariable("storeId") Long storeId) + { + return success(storeMappingService.selectStoreMappingByStoreId(storeId)); + } + + /** + * 新增系统与第三方店铺映射关系 + */ + @PreAuthorize("@ss.hasPermi('system:mapping:add')") + @Log(title = "系统与第三方店铺映射关系", businessType = BusinessType.INSERT) + @PostMapping + public AjaxResult add(@RequestBody StoreMapping storeMapping) + { + return toAjax(storeMappingService.insertStoreMapping(storeMapping)); + } + + /** + * 修改系统与第三方店铺映射关系 + */ + @PreAuthorize("@ss.hasPermi('system:mapping:edit')") + @Log(title = "系统与第三方店铺映射关系", businessType = BusinessType.UPDATE) + @PutMapping + public AjaxResult edit(@RequestBody StoreMapping storeMapping) + { + return toAjax(storeMappingService.updateStoreMapping(storeMapping)); + } + + /** + * 删除系统与第三方店铺映射关系 + */ + @PreAuthorize("@ss.hasPermi('system:mapping:remove')") + @Log(title = "系统与第三方店铺映射关系", businessType = BusinessType.DELETE) + @DeleteMapping("/{storeIds}") + public AjaxResult remove(@PathVariable Long[] storeIds) + { + return toAjax(storeMappingService.deleteStoreMappingByStoreIds(storeIds)); + } +} diff --git a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/UserController.java b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/UserController.java index bf59d5f..715c850 100644 --- a/share-space-admin/src/main/java/com/ruoyi/web/controller/system/UserController.java +++ b/share-space-admin/src/main/java/com/ruoyi/web/controller/system/UserController.java @@ -7,6 +7,7 @@ import com.ruoyi.common.core.domain.AjaxResult; import com.ruoyi.common.core.domain.dto.ModifyBalanceDTO; import com.ruoyi.common.core.domain.entity.User; import com.ruoyi.common.utils.ServiceUtil; +import com.ruoyi.ss.cardGetRecords.service.ICardGetRecordsService; import com.ruoyi.ss.changeBalance.service.IChangeBalanceService; import com.ruoyi.ss.user.domain.UserVO; import com.ruoyi.common.core.page.TableDataInfo; @@ -44,6 +45,9 @@ public class UserController extends BaseController @Autowired private IChangeBalanceService changeBalanceService; + @Autowired + private ICardGetRecordsService cardGetRecordsService; + /** * 获取用户列表 */ @@ -194,5 +198,16 @@ public class UserController extends BaseController return toAjax(i); } + /** + * 获取用户可用卡券 + */ + @Log(title = "获取可用卡券", businessType = BusinessType.PREPARE) + @GetMapping("/getAvailableCard") + public AjaxResult getAvailableCard() + { + logger.info("获取可用卡券"); + return success(cardGetRecordsService.getAvailableCard(getUserId())); + } + } diff --git a/share-space-admin/src/main/resources/application.yml b/share-space-admin/src/main/resources/application.yml index 8136ebe..bb2bdbc 100644 --- a/share-space-admin/src/main/resources/application.yml +++ b/share-space-admin/src/main/resources/application.yml @@ -241,3 +241,6 @@ e: password: admin12311111 yp: apikey: 69d42dc4f806b9cbd5de48459353602f +douyin: + appKey: awitlgmafy1n6hmp + secret: f8b69e946746b8e82d0ade3a31123055 diff --git a/share-space-common/src/main/java/com/ruoyi/common/constant/ServiceConstants.java b/share-space-common/src/main/java/com/ruoyi/common/constant/ServiceConstants.java index 2315426..76a1a3d 100644 --- a/share-space-common/src/main/java/com/ruoyi/common/constant/ServiceConstants.java +++ b/share-space-common/src/main/java/com/ruoyi/common/constant/ServiceConstants.java @@ -1207,6 +1207,51 @@ public class ServiceConstants { /**----------------------------充值渠道类型end----------------------------*/ + /**----------------------------状态类型 start----------------------------*/ + + /** + * 状态: 1-未使用 + */ + public static final String CARD_STATUS_UNUSED = "1"; + + /** + * 状态: 2-已使用 + */ + public static final String CARD_STATUS_USED = "2"; + + /** + * 状态: 3-已过期 + */ + public static final String CARD_STATUS_EXPIRED = "3"; + + /**----------------------------状态类型 end----------------------------*/ + + /**----------------------------卡券获取方式 start----------------------------*/ + + /** + * 卡券获取方式: 1-手动领取 + */ + public static final String COUPON_GET_MANUAL = "1"; + + /** + * 卡券获取方式: 2-后台发放 + */ + public static final String COUPON_GET_ADMIN = "2"; + + /** + * 卡券获取方式: 3-平台购买 + */ + public static final String COUPON_GET_PLATFORM_PURCHASE = "3"; + + /** + * 卡券获取方式: 4-第三方购买 + */ + public static final String COUPON_GET_THIRD_PARTY_PURCHASE = "4"; + + /**----------------------------卡券获取方式 end----------------------------*/ + + + // /**----------------------------对账类型start----------------------------*/ // // /** diff --git a/share-space-common/src/main/java/com/ruoyi/common/enums/BusinessType.java b/share-space-common/src/main/java/com/ruoyi/common/enums/BusinessType.java index db327ea..6c04469 100644 --- a/share-space-common/src/main/java/com/ruoyi/common/enums/BusinessType.java +++ b/share-space-common/src/main/java/com/ruoyi/common/enums/BusinessType.java @@ -212,6 +212,13 @@ public enum BusinessType /** * 修改余额 */ - MODIFYBALANCE - + MODIFYBALANCE, + /** + * 验签准备 + */ + PREPARE, + /** + * 验签 + */ + VERIFY } diff --git a/share-space-common/src/main/java/com/ruoyi/common/utils/dy/DouYinAccessTokenUtil.java b/share-space-common/src/main/java/com/ruoyi/common/utils/dy/DouYinAccessTokenUtil.java new file mode 100644 index 0000000..55930a8 --- /dev/null +++ b/share-space-common/src/main/java/com/ruoyi/common/utils/dy/DouYinAccessTokenUtil.java @@ -0,0 +1,50 @@ +package com.ruoyi.common.utils.dy; + +import cn.hutool.http.HttpUtil; +import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONObject; +import lombok.SneakyThrows; +import lombok.extern.slf4j.Slf4j; + +import java.util.HashMap; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.TimeUnit; + +@Slf4j +public class DouYinAccessTokenUtil { + + // 存储每个租户的token和过期时间 + private static final ConcurrentHashMap cachedTokens = new ConcurrentHashMap<>(); + private static final ConcurrentHashMap tokenExpirationTimes = new ConcurrentHashMap<>(); + + @SneakyThrows + public static String getToken(String appId, String appsecret) { + String cacheKey = appId+ ":" + appsecret; + if (isTokenExpired(cacheKey)) { + log.info("token已过期，重新获取"); + String uri = "https://open.douyin.com/oauth/client_token/"; + + HashMap paramMap = new HashMap<>(); + paramMap.put("client_key", appId); + paramMap.put("client_secret", appsecret); + paramMap.put("grant_type", "client_credential"); + + String result= HttpUtil.post(uri, paramMap); + JSONObject jsonObject = JSON.parseObject(result); + JSONObject data = jsonObject.getJSONObject("data"); + String accessToken = data.getString("access_token"); + // 更新缓存 + cachedTokens.put(cacheKey, accessToken); + tokenExpirationTimes.put(cacheKey, System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(3600L)); + return accessToken; + } + log.info("token未过期，直接使用"); + return cachedTokens.get(cacheKey); + } + + /**判断token是否过期*/ + private static boolean isTokenExpired(String cacheKey) { + Long expirationTime = tokenExpirationTimes.get(cacheKey); + return expirationTime == null || System.currentTimeMillis() > expirationTime; + } +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/card/domain/GroupBuyingDTO.java b/share-space-system/src/main/java/com/ruoyi/ss/card/domain/GroupBuyingDTO.java new file mode 100644 index 0000000..ac120c7 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/card/domain/GroupBuyingDTO.java @@ -0,0 +1,23 @@ +package com.ruoyi.ss.card.domain; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.NotBlank; +import javax.validation.constraints.NotNull; + +@Data +public class GroupBuyingDTO { + + @NotNull(message = "店铺ID不能为空") + @ApiModelProperty("店铺id") + private Long storeId; + + @ApiModelProperty("加密数据") +// @NotBlank(message = "加密数据不能为空") + private String encryptedData; + + @ApiModelProperty("卡券码") + private String code; + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/card/domain/SsCard.java b/share-space-system/src/main/java/com/ruoyi/ss/card/domain/SsCard.java index 92a2aed..fa2545e 100644 --- a/share-space-system/src/main/java/com/ruoyi/ss/card/domain/SsCard.java +++ b/share-space-system/src/main/java/com/ruoyi/ss/card/domain/SsCard.java @@ -101,5 +101,9 @@ public class SsCard extends BaseEntity{ @ApiModelProperty("可用时间开始") private LocalTime availableTimeStart; + @Excel(name = "skuId") + @ApiModelProperty("skuId") + private String skuId; + } diff --git a/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.java b/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.java index 7905991..124a618 100644 --- a/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.java +++ b/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.java @@ -61,4 +61,10 @@ public interface SsCardMapper * @return 结果 */ public int deleteSsCardByCouponIds(Long[] couponIds); + + + /** + * 根据skuId查询卡券 + */ + SsCardVO selectSsCardBySkuId(String skuId); } diff --git a/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.xml b/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.xml index a0ba893..3649970 100644 --- a/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.xml +++ b/share-space-system/src/main/java/com/ruoyi/ss/card/mapper/SsCardMapper.xml @@ -32,7 +32,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" c.available_week, c.available_time_end, c.available_time_start, - c.merchant_id + c.merchant_id, + c.sku_id from ss_card c left join ss_store s on c.store_id = s.store_id @@ -54,6 +55,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" and c.original_price = #{query.originalPrice} and c.available_rooms = #{query.availableRooms} and c.available_week = #{query.availableWeek} + and c.sku_id = #{query.skuId} + + insert into ss_card @@ -91,6 +98,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" available_week, available_time_end, available_time_start, + sku_id, #{name}, @@ -113,6 +121,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" #{availableWeek,typeHandler=com.ruoyi.system.mapper.typehandler.StringSplitListTypeHandler}, #{availableTimeEnd}, #{availableTimeStart}, + #{skuId}, @@ -145,6 +154,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" available_week = #{data.availableWeek,typeHandler=com.ruoyi.system.mapper.typehandler.StringSplitListTypeHandler}, available_time_end = #{data.availableTimeEnd}, available_time_start = #{data.availableTimeStart}, + sku_id = #{data.skuId}, diff --git a/share-space-system/src/main/java/com/ruoyi/ss/card/service/ISsCardService.java b/share-space-system/src/main/java/com/ruoyi/ss/card/service/ISsCardService.java index c6b6379..2c740ad 100644 --- a/share-space-system/src/main/java/com/ruoyi/ss/card/service/ISsCardService.java +++ b/share-space-system/src/main/java/com/ruoyi/ss/card/service/ISsCardService.java @@ -1,6 +1,8 @@ package com.ruoyi.ss.card.service; import java.util.List; + +import com.ruoyi.ss.card.domain.GroupBuyingDTO; import com.ruoyi.ss.card.domain.SsCard; import com.ruoyi.ss.card.domain.SsCardVO; import com.ruoyi.ss.card.domain.SsCardQuery; @@ -21,6 +23,14 @@ public interface ISsCardService */ public SsCardVO selectSsCardByCouponId(Long couponId); + /** + * 根据skuId查询卡券 + * + * @param skuId skuId + * @return 卡券 + */ + public SsCardVO selectSsCardBySkuId(String skuId); + /** * 查询卡券列表 * @@ -60,4 +70,10 @@ public interface ISsCardService * @return 结果 */ public int deleteSsCardByCouponId(Long couponId); + + /** + * 验券 + */ + int prepare(GroupBuyingDTO dto); + } diff --git a/share-space-system/src/main/java/com/ruoyi/ss/card/service/impl/SsCardServiceImpl.java b/share-space-system/src/main/java/com/ruoyi/ss/card/service/impl/SsCardServiceImpl.java index fce3cbc..fc24daf 100644 --- a/share-space-system/src/main/java/com/ruoyi/ss/card/service/impl/SsCardServiceImpl.java +++ b/share-space-system/src/main/java/com/ruoyi/ss/card/service/impl/SsCardServiceImpl.java @@ -1,8 +1,31 @@ package com.ruoyi.ss.card.service.impl; import java.util.List; +import java.util.Optional; + +import cn.hutool.core.lang.Validator; +import cn.hutool.core.net.url.UrlBuilder; +import cn.hutool.core.util.ReUtil; +import cn.hutool.http.HttpRequest; +import cn.hutool.http.HttpUtil; +import com.alibaba.fastjson2.JSON; +import com.alibaba.fastjson2.JSONArray; +import com.alibaba.fastjson2.JSONObject; import com.ruoyi.common.utils.DateUtils; +import com.ruoyi.common.utils.SecurityUtils; +import com.ruoyi.common.utils.ServiceUtil; +import com.ruoyi.common.utils.dy.DouYinAccessTokenUtil; +import com.ruoyi.ss.card.domain.GroupBuyingDTO; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecords; +import com.ruoyi.ss.cardGetRecords.service.ICardGetRecordsService; +import com.ruoyi.ss.checkoff.domain.CheckoffRecords; +import com.ruoyi.ss.checkoff.service.ICheckoffRecordsService; +import com.ruoyi.ss.mapping.domain.StoreMappingVO; +import com.ruoyi.ss.mapping.service.IStoreMappingService; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import com.ruoyi.ss.card.mapper.SsCardMapper; import com.ruoyi.ss.card.domain.SsCard; @@ -10,6 +33,9 @@ import com.ruoyi.ss.card.domain.SsCardVO; import com.ruoyi.ss.card.domain.SsCardQuery; import com.ruoyi.ss.card.service.ISsCardService; +import static com.ruoyi.common.constant.ServiceConstants.CARD_STATUS_UNUSED; +import static com.ruoyi.common.constant.ServiceConstants.COUPON_GET_THIRD_PARTY_PURCHASE; + /** * 卡券Service业务层处理 * @@ -19,8 +45,25 @@ import com.ruoyi.ss.card.service.ISsCardService; @Service public class SsCardServiceImpl implements ISsCardService { + private static final Logger log = LoggerFactory.getLogger(SsCardServiceImpl.class); + @Autowired - private SsCardMapper ssCardMapper; + private SsCardMapper cardMapper; + + @Autowired + private IStoreMappingService storeMappingService; + + @Value("${douyin.appKey}") + private String appKey; + + @Value("${douyin.secret}") + private String appSecret; + + @Autowired + private ICheckoffRecordsService checkoffRecordsService; + + @Autowired + private ICardGetRecordsService cardGetRecordsService; /** * 查询卡券 @@ -31,7 +74,18 @@ public class SsCardServiceImpl implements ISsCardService @Override public SsCardVO selectSsCardByCouponId(Long couponId) { - return ssCardMapper.selectSsCardByCouponId(couponId); + return cardMapper.selectSsCardByCouponId(couponId); + } + + /** + * 根据skuId查询卡券 + * + * @param skuId skuId + * @return 卡券 + */ + @Override + public SsCardVO selectSsCardBySkuId(String skuId) { + return cardMapper.selectSsCardBySkuId(skuId); } /** @@ -43,7 +97,7 @@ public class SsCardServiceImpl implements ISsCardService @Override public List selectSsCardList(SsCardQuery ssCard) { - return ssCardMapper.selectSsCardList(ssCard); + return cardMapper.selectSsCardList(ssCard); } /** @@ -56,7 +110,7 @@ public class SsCardServiceImpl implements ISsCardService public int insertSsCard(SsCard ssCard) { ssCard.setCreateTime(DateUtils.getNowDate()); - return ssCardMapper.insertSsCard(ssCard); + return cardMapper.insertSsCard(ssCard); } /** @@ -68,7 +122,7 @@ public class SsCardServiceImpl implements ISsCardService @Override public int updateSsCard(SsCard ssCard) { - return ssCardMapper.updateSsCard(ssCard); + return cardMapper.updateSsCard(ssCard); } /** @@ -80,7 +134,7 @@ public class SsCardServiceImpl implements ISsCardService @Override public int deleteSsCardByCouponIds(Long[] couponIds) { - return ssCardMapper.deleteSsCardByCouponIds(couponIds); + return cardMapper.deleteSsCardByCouponIds(couponIds); } /** @@ -92,6 +146,144 @@ public class SsCardServiceImpl implements ISsCardService @Override public int deleteSsCardByCouponId(Long couponId) { - return ssCardMapper.deleteSsCardByCouponId(couponId); + return cardMapper.deleteSsCardByCouponId(couponId); } + + /** + * 验券准备 + */ + @Override + public int prepare(GroupBuyingDTO dto) { + StoreMappingVO storeMappingVO = storeMappingService.selectStoreMappingByStoreId(dto.getStoreId()); + String tpStoreId = storeMappingVO.getTpStoreId(); + String token = DouYinAccessTokenUtil.getToken(appKey, appSecret); + + String uri = "https://open.douyin.com/goodlife/v1/fulfilment/certificate/prepare/"; + + // 获取二维码的短链数据 + String res = HttpUtil.get(dto.getEncryptedData()); + String encryptedDataUri = ReUtil.getGroup0(Validator.URL, res); + + // 解析 object_id + String objectId = Optional.ofNullable(UrlBuilder.of(encryptedDataUri).getQuery().get("object_id")) + .map(Object::toString) + .orElseThrow(() -> new RuntimeException("二维码数据中未找到 object_id")); + + // 发起请求 + String result = HttpRequest.get(uri) + .contentType("application/json") + .header("access-token", token) + .form("encrypted_data", objectId) + .execute() + .body(); + + // 解析结果 + saveCheckoffRecords(result, tpStoreId, token); + return 1; + } + + private void saveCheckoffRecords(String result, String tpStoreId, String token) { + JSONObject jsonObject = JSON.parseObject(result); + JSONObject data = jsonObject.getJSONObject("data"); + + // 确保 data 存在 + ServiceUtil.assertion(data == null || !"0".equals(data.getString("error_code")), + "【验券准备】调用失败: " + (data != null ? data.getString("description") : "无错误描述")); + + JSONArray certificates = Optional.ofNullable(data.getJSONArray("certificates")) + .orElseGet(() -> { + log.error("未找到有效的 certificate 信息"); + return new JSONArray(); + }); + + if (certificates.isEmpty()) { + return; + } + + JSONObject firstCertificate = certificates.getJSONObject(0); + JSONObject amount = firstCertificate.getJSONObject("amount"); + + // 避免空指针异常 + Integer originalAmount = amount != null ? amount.getInteger("original_amount") : 0; + Integer listMarketAmount = amount != null ? amount.getInteger("list_market_amount") : 0; + Integer payAmount = amount != null ? amount.getInteger("pay_amount") : 0; + + String verifyToken = data.getString("verify_token"); + String encryptedCode = firstCertificate.getString("encrypted_code"); + + JSONObject sku = firstCertificate.getJSONObject("sku"); + String skuId = sku != null ? sku.getString("sku_id") : null; + + // 获取卡券信息 + SsCardVO ssCardVO = cardMapper.selectSsCardBySkuId(skuId); + ServiceUtil.assertion(ssCardVO == null, "【验券准备】根据 sku_id 未查询到卡券"); + + CheckoffRecords checkoffRecords = new CheckoffRecords(); + checkoffRecords.setCheckoffTime(DateUtils.getNowDate()); + checkoffRecords.setStatus("1"); + checkoffRecords.setEncryptedCode(encryptedCode); + checkoffRecords.setPoiId(tpStoreId); + checkoffRecords.setUserId(SecurityUtils.getUserId()); + checkoffRecords.setVerifyToken(verifyToken); + checkoffRecords.setResult(result); + checkoffRecords.setOriginalAmount(originalAmount); + checkoffRecords.setListMarketAmount(listMarketAmount); + checkoffRecords.setPayAmount(payAmount); + checkoffRecords.setCardId(ssCardVO.getCouponId()); + checkoffRecords.setSkuId(skuId); + + int insertResult = checkoffRecordsService.insertCheckoffRecords(checkoffRecords); + log.info("新建核销记录：{}", insertResult > 0 ? "成功" : "失败"); + ServiceUtil.assertion(insertResult == 0, "新建核销记录失败"); + + // 核销接口 + verifyCertificate(checkoffRecords, token); + + // 创建卡券领取记录 + CardGetRecords cardGetRecords = new CardGetRecords(); + cardGetRecords.setStatus(CARD_STATUS_UNUSED); + cardGetRecords.setUserId(SecurityUtils.getUserId()); + cardGetRecords.setCouponId(ssCardVO.getCouponId()); + cardGetRecords.setGetMethod(COUPON_GET_THIRD_PARTY_PURCHASE); + cardGetRecords.setReceiveTime(DateUtils.getNowDate()); + cardGetRecords.setStartTime(DateUtils.getNowDate()); + cardGetRecords.setEndTime(DateUtils.addYears(DateUtils.getNowDate(), 1)); + + int cardInsertResult = cardGetRecordsService.insertCardGetRecords(cardGetRecords); + log.info("新建卡券领取记录：{}", cardInsertResult > 0 ? "成功" : "失败"); + ServiceUtil.assertion(cardInsertResult == 0, "新建卡券领取记录失败"); + } + + private void verifyCertificate(CheckoffRecords checkoffRecords, String token) { + String uri = "https://open.douyin.com/goodlife/v1/fulfilment/certificate/verify/"; + + JSONObject verifyJson = new JSONObject(); + verifyJson.put("verify_token", checkoffRecords.getVerifyToken()); + verifyJson.put("poi_id", checkoffRecords.getPoiId()); + JSONArray encryptedCodeArray = new JSONArray(); + encryptedCodeArray.add(checkoffRecords.getEncryptedCode()); + + verifyJson.put("encrypted_codes", encryptedCodeArray); + log.info("verifyJson={}", JSON.toJSONString(verifyJson)); + + String verifyResult = HttpRequest.post(uri) + .contentType("application/json") + .header("access-token", token) + .body(verifyJson.toJSONString()) + .execute() + .body(); + + // 解析 JSON + JSONObject resultJson = JSONObject.parseObject(verifyResult); + JSONObject data1 = resultJson.getJSONObject("data"); + + // 确保 data1 存在 + int errorCode = (data1 != null) ? data1.getIntValue("error_code") : -1; + String errorMsg = (data1 != null) ? data1.getString("description") : "未知错误"; + + ServiceUtil.assertion(errorCode != 0, "调验券接口失败: " + errorMsg); + } + + + } diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecords.java b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecords.java new file mode 100644 index 0000000..c75f290 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecords.java @@ -0,0 +1,54 @@ +package com.ruoyi.ss.cardGetRecords.domain; + +import java.util.Date; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import com.ruoyi.common.annotation.Excel; +import com.ruoyi.common.core.domain.BaseEntity; + +/** + * 卡券领取（购买）记录对象 ss_card_records + * + * @author qzz + * @date 2025-03-19 + */ +@Data +public class CardGetRecords extends BaseEntity{ + + private static final long serialVersionUID = 1L; + + private Long recordId; + + @Excel(name = "领取人") + @ApiModelProperty("领取人") + private Long userId; + + @Excel(name = "卡券") + @ApiModelProperty("卡券") + private Long couponId; + + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "领取时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty("领取时间") + private Date receiveTime; + + @Excel(name = "获取方式") + @ApiModelProperty("获取方式") + private String getMethod; + + @Excel(name = "状态") + @ApiModelProperty("状态") + private String status; + + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "开始使用时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty("开始使用时间") + private Date startTime; + + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "结束使用时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty("结束使用时间") + private Date endTime; + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecordsQuery.java b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecordsQuery.java new file mode 100644 index 0000000..f70b555 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecordsQuery.java @@ -0,0 +1,7 @@ +package com.ruoyi.ss.cardGetRecords.domain; + +import lombok.Data; + +@Data +public class CardGetRecordsQuery extends CardGetRecords{ +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecordsVO.java b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecordsVO.java new file mode 100644 index 0000000..b44e3ce --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/domain/CardGetRecordsVO.java @@ -0,0 +1,14 @@ +package com.ruoyi.ss.cardGetRecords.domain; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +@Data +public class CardGetRecordsVO extends CardGetRecords{ + + @ApiModelProperty(value = "领取人姓名") + private String userName; + + @ApiModelProperty(value = "卡券名称") + private String cardName; +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/mapper/CardGetRecordsMapper.java b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/mapper/CardGetRecordsMapper.java new file mode 100644 index 0000000..ce48a47 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/mapper/CardGetRecordsMapper.java @@ -0,0 +1,64 @@ +package com.ruoyi.ss.cardGetRecords.mapper; + +import java.util.List; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecords; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsVO; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsQuery; +import org.apache.ibatis.annotations.Param; + +/** + * 卡券领取（购买）记录Mapper接口 + * + * @author qzz + * @date 2025-03-19 + */ +public interface CardGetRecordsMapper +{ + /** + * 查询卡券领取（购买）记录 + * + * @param recordId 卡券领取（购买）记录主键 + * @return 卡券领取（购买）记录 + */ + public CardGetRecordsVO selectCardGetRecordsByRecordId(Long recordId); + + /** + * 查询卡券领取（购买）记录列表 + * + * @param query 卡券领取（购买）记录 + * @return 卡券领取（购买）记录集合 + */ + public List selectCardGetRecordsList(@Param("query")CardGetRecordsQuery query); + + /** + * 新增卡券领取（购买）记录 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 结果 + */ + public int insertCardGetRecords(CardGetRecords cardGetRecords); + + /** + * 修改卡券领取（购买）记录 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 结果 + */ + public int updateCardGetRecords(@Param("data") CardGetRecords cardGetRecords); + + /** + * 删除卡券领取（购买）记录 + * + * @param recordId 卡券领取（购买）记录主键 + * @return 结果 + */ + public int deleteCardGetRecordsByRecordId(Long recordId); + + /** + * 批量删除卡券领取（购买）记录 + * + * @param recordIds 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteCardGetRecordsByRecordIds(Long[] recordIds); +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/mapper/CardGetRecordsMapper.xml b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/mapper/CardGetRecordsMapper.xml new file mode 100644 index 0000000..54dc789 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/mapper/CardGetRecordsMapper.xml @@ -0,0 +1,98 @@ + + + + + + + + select + cr.record_id, + cr.user_id, + u.user_name as userName, + cr.coupon_id, + c.name as cardName, + cr.receive_time, + cr.get_method, + cr.status, + cr.start_time, + cr.end_time + from ss_card_records cr + left join ss_user u on cr.user_id = u.user_id + left join ss_card c on cr.coupon_id = c.coupon_id + + + + and cr.user_id = #{query.userId} + and cr.coupon_id = #{query.couponId} + and cr.receive_time = #{query.receiveTime} + and cr.get_method = #{query.getMethod} + and cr.status = #{query.status} + and cr.start_time = #{query.startTime} + and cr.end_time = #{query.endTime} + + + + + + + + insert into ss_card_records + + user_id, + coupon_id, + receive_time, + get_method, + status, + start_time, + end_time, + + + #{userId}, + #{couponId}, + #{receiveTime}, + #{getMethod}, + #{status}, + #{startTime}, + #{endTime}, + + + + + update ss_card_records + + + + where record_id = #{data.recordId} + + + + user_id = #{data.userId}, + coupon_id = #{data.couponId}, + receive_time = #{data.receiveTime}, + get_method = #{data.getMethod}, + status = #{data.status}, + start_time = #{data.startTime}, + end_time = #{data.endTime}, + + + + delete from ss_card_records where record_id = #{recordId} + + + + delete from ss_card_records where record_id in + + #{recordId} + + + diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/service/ICardGetRecordsService.java b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/service/ICardGetRecordsService.java new file mode 100644 index 0000000..a2ea19e --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/service/ICardGetRecordsService.java @@ -0,0 +1,68 @@ +package com.ruoyi.ss.cardGetRecords.service; + +import java.util.List; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecords; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsVO; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsQuery; + +/** + * 卡券领取（购买）记录Service接口 + * + * @author qzz + * @date 2025-03-19 + */ +public interface ICardGetRecordsService +{ + /** + * 查询卡券领取（购买）记录 + * + * @param recordId 卡券领取（购买）记录主键 + * @return 卡券领取（购买）记录 + */ + public CardGetRecordsVO selectCardGetRecordsByRecordId(Long recordId); + + /** + * 查询卡券领取（购买）记录列表 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 卡券领取（购买）记录集合 + */ + public List selectCardGetRecordsList(CardGetRecordsQuery cardGetRecords); + + /** + * 新增卡券领取（购买）记录 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 结果 + */ + public int insertCardGetRecords(CardGetRecords cardGetRecords); + + /** + * 修改卡券领取（购买）记录 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 结果 + */ + public int updateCardGetRecords(CardGetRecords cardGetRecords); + + /** + * 批量删除卡券领取（购买）记录 + * + * @param recordIds 需要删除的卡券领取（购买）记录主键集合 + * @return 结果 + */ + public int deleteCardGetRecordsByRecordIds(Long[] recordIds); + + /** + * 删除卡券领取（购买）记录信息 + * + * @param recordId 卡券领取（购买）记录主键 + * @return 结果 + */ + public int deleteCardGetRecordsByRecordId(Long recordId); + + /** + * 获取用户可用卡券 + */ + List getAvailableCard(Long userId); +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/service/impl/CardGetRecordsServiceImpl.java b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/service/impl/CardGetRecordsServiceImpl.java new file mode 100644 index 0000000..122178f --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/cardGetRecords/service/impl/CardGetRecordsServiceImpl.java @@ -0,0 +1,108 @@ +package com.ruoyi.ss.cardGetRecords.service.impl; + +import java.util.List; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.ruoyi.ss.cardGetRecords.mapper.CardGetRecordsMapper; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecords; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsVO; +import com.ruoyi.ss.cardGetRecords.domain.CardGetRecordsQuery; +import com.ruoyi.ss.cardGetRecords.service.ICardGetRecordsService; + +import static com.ruoyi.common.constant.ServiceConstants.CARD_STATUS_UNUSED; + +/** + * 卡券领取（购买）记录Service业务层处理 + * + * @author qzz + * @date 2025-03-19 + */ +@Service +public class CardGetRecordsServiceImpl implements ICardGetRecordsService +{ + @Autowired + private CardGetRecordsMapper cardGetRecordsMapper; + + /** + * 查询卡券领取（购买）记录 + * + * @param recordId 卡券领取（购买）记录主键 + * @return 卡券领取（购买）记录 + */ + @Override + public CardGetRecordsVO selectCardGetRecordsByRecordId(Long recordId) + { + return cardGetRecordsMapper.selectCardGetRecordsByRecordId(recordId); + } + + /** + * 查询卡券领取（购买）记录列表 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 卡券领取（购买）记录 + */ + @Override + public List selectCardGetRecordsList(CardGetRecordsQuery cardGetRecords) + { + return cardGetRecordsMapper.selectCardGetRecordsList(cardGetRecords); + } + + /** + * 新增卡券领取（购买）记录 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 结果 + */ + @Override + public int insertCardGetRecords(CardGetRecords cardGetRecords) + { + return cardGetRecordsMapper.insertCardGetRecords(cardGetRecords); + } + + /** + * 修改卡券领取（购买）记录 + * + * @param cardGetRecords 卡券领取（购买）记录 + * @return 结果 + */ + @Override + public int updateCardGetRecords(CardGetRecords cardGetRecords) + { + return cardGetRecordsMapper.updateCardGetRecords(cardGetRecords); + } + + /** + * 批量删除卡券领取（购买）记录 + * + * @param recordIds 需要删除的卡券领取（购买）记录主键 + * @return 结果 + */ + @Override + public int deleteCardGetRecordsByRecordIds(Long[] recordIds) + { + return cardGetRecordsMapper.deleteCardGetRecordsByRecordIds(recordIds); + } + + /** + * 删除卡券领取（购买）记录信息 + * + * @param recordId 卡券领取（购买）记录主键 + * @return 结果 + */ + @Override + public int deleteCardGetRecordsByRecordId(Long recordId) + { + return cardGetRecordsMapper.deleteCardGetRecordsByRecordId(recordId); + } + + /** + * 获取用户可用卡券 + */ + @Override + public List getAvailableCard(Long userId) { + CardGetRecordsQuery cardGetRecordsQuery = new CardGetRecordsQuery(); + cardGetRecordsQuery.setUserId(userId); + cardGetRecordsQuery.setStatus(CARD_STATUS_UNUSED); + return cardGetRecordsMapper.selectCardGetRecordsList(cardGetRecordsQuery); + } +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecords.java b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecords.java new file mode 100644 index 0000000..980bcbb --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecords.java @@ -0,0 +1,75 @@ +package com.ruoyi.ss.checkoff.domain; + +import java.math.BigDecimal; +import java.util.Date; +import com.fasterxml.jackson.annotation.JsonFormat; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.ruoyi.common.annotation.Excel; +import com.ruoyi.common.core.domain.BaseEntity; + +/** + * 核销记录对象 ss_checkoff_records + * + * @author qzz + * @date 2025-03-18 + */ +@Data +public class CheckoffRecords extends BaseEntity{ + + private static final long serialVersionUID = 1L; + + private Long checkoffId; + + @Excel(name = "加密码") + @ApiModelProperty("加密码") + private String encryptedCode; + + @Excel(name = "token") + @ApiModelProperty("token") + private String verifyToken; + + @Excel(name = "抖音核销门店id") + @ApiModelProperty("抖音核销门店id") + private String poiId; + + @Excel(name = "卡id") + @ApiModelProperty("卡id") + private Long cardId; + + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @Excel(name = "核销时间", width = 30, dateFormat = "yyyy-MM-dd HH:mm:ss") + @ApiModelProperty("核销时间") + private Date checkoffTime; + + @Excel(name = "用户id") + @ApiModelProperty("用户id") + private Long userId; + + @Excel(name = "状态") + @ApiModelProperty("状态") + private String status; + + @Excel(name = "验签结果") + @ApiModelProperty("验签结果") + private String result; + + @Excel(name = "原价") + @ApiModelProperty("原价") + private Integer originalAmount; + + @Excel(name = "划线价") + @ApiModelProperty("划线价") + private Integer listMarketAmount; + + @Excel(name = "实际支付金额") + @ApiModelProperty("实际支付金额") + private Integer payAmount; + + @Excel(name = "skuId") + @ApiModelProperty("skuId") + private String skuId; + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecordsQuery.java b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecordsQuery.java new file mode 100644 index 0000000..8255ce2 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecordsQuery.java @@ -0,0 +1,8 @@ +package com.ruoyi.ss.checkoff.domain; + +import lombok.Data; + +@Data +public class CheckoffRecordsQuery extends CheckoffRecords{ + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecordsVO.java b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecordsVO.java new file mode 100644 index 0000000..6c94b3d --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/domain/CheckoffRecordsVO.java @@ -0,0 +1,15 @@ +package com.ruoyi.ss.checkoff.domain; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +@Data +public class CheckoffRecordsVO extends CheckoffRecords{ + + @ApiModelProperty("卡名称") + private String cardName; + + @ApiModelProperty("用户名") + private String userName; + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/mapper/CheckoffRecordsMapper.java b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/mapper/CheckoffRecordsMapper.java new file mode 100644 index 0000000..f3965fc --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/mapper/CheckoffRecordsMapper.java @@ -0,0 +1,74 @@ +package com.ruoyi.ss.checkoff.mapper; + +import java.util.List; +import com.ruoyi.ss.checkoff.domain.CheckoffRecords; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsVO; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsQuery; +import org.apache.ibatis.annotations.Param; + +/** + * 核销记录Mapper接口 + * + * @author qzz + * @date 2025-03-18 + */ +public interface CheckoffRecordsMapper +{ + /** + * 查询核销记录 + * + * @param checkoffId 核销记录主键 + * @return 核销记录 + */ + public CheckoffRecordsVO selectCheckoffRecordsByCheckoffId(Long checkoffId); + + /** + * 最后一条核销记录 + * + * @param cardId 卡券id + * @return 结果 + */ + CheckoffRecords selectCheckoffRecordsByCardId(Long cardId); + + /** + * 查询核销记录列表 + * + * @param query 核销记录 + * @return 核销记录集合 + */ + public List selectCheckoffRecordsList(@Param("query")CheckoffRecordsQuery query); + + /** + * 新增核销记录 + * + * @param checkoffRecords 核销记录 + * @return 结果 + */ + public int insertCheckoffRecords(CheckoffRecords checkoffRecords); + + /** + * 修改核销记录 + * + * @param checkoffRecords 核销记录 + * @return 结果 + */ + public int updateCheckoffRecords(@Param("data") CheckoffRecords checkoffRecords); + + /** + * 删除核销记录 + * + * @param checkoffId 核销记录主键 + * @return 结果 + */ + public int deleteCheckoffRecordsByCheckoffId(Long checkoffId); + + /** + * 批量删除核销记录 + * + * @param checkoffIds 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteCheckoffRecordsByCheckoffIds(Long[] checkoffIds); + + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/mapper/CheckoffRecordsMapper.xml b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/mapper/CheckoffRecordsMapper.xml new file mode 100644 index 0000000..02cdd26 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/mapper/CheckoffRecordsMapper.xml @@ -0,0 +1,125 @@ + + + + + + + + select + cr.checkoff_id, + cr.encrypted_code, + cr.verify_token, + cr.poi_id, + cr.card_id, + c.name as cardName, + cr.checkoff_time, + cr.user_id, + u.user_name userName, + cr.status, + cr.result, + cr.original_amount, + cr.list_market_amount, + cr.pay_amount, + cr.sku_id + from ss_checkoff_records cr + left join ss_card c on cr.card_id = c.coupon_id + left join ss_user u on cr.user_id = u.user_id + + + + and encrypted_code = #{query.encryptedCode} + and verify_token = #{query.verifyToken} + and poi_id = #{query.poiId} + and card_id = #{query.cardId} + and checkoff_time = #{query.checkoffTime} + and user_id = #{query.userId} + and status = #{query.status} + + + + + + + + + + insert into ss_checkoff_records + + checkoff_id, + encrypted_code, + verify_token, + poi_id, + card_id, + checkoff_time, + user_id, + status, + result, + original_amount, + list_market_amount, + pay_amount, + sku_id, + + + #{checkoffId}, + #{encryptedCode}, + #{verifyToken}, + #{poiId}, + #{cardId}, + #{checkoffTime}, + #{userId}, + #{status}, + #{result}, + #{originalAmount}, + #{listMarketAmount}, + #{payAmount}, + #{skuId}, + + + + + update ss_checkoff_records + + + + where checkoff_id = #{data.checkoffId} + + + + encrypted_code = #{data.encryptedCode}, + verify_token = #{data.verifyToken}, + poi_id = #{data.poiId}, + card_id = #{data.cardId}, + checkoff_time = #{data.checkoffTime}, + user_id = #{data.userId}, + status = #{data.status}, + original_amount = #{data.originalAmount}, + list_market_amount = #{data.listMarketAmount}, + pay_amount = #{data.payAmount}, + sku_id = #{data.skuId}, + + + + delete from ss_checkoff_records where checkoff_id = #{checkoffId} + + + + delete from ss_checkoff_records where checkoff_id in + + #{checkoffId} + + + diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/service/ICheckoffRecordsService.java b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/service/ICheckoffRecordsService.java new file mode 100644 index 0000000..a10e58d --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/service/ICheckoffRecordsService.java @@ -0,0 +1,71 @@ +package com.ruoyi.ss.checkoff.service; + +import java.util.List; +import com.ruoyi.ss.checkoff.domain.CheckoffRecords; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsVO; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsQuery; + +/** + * 核销记录Service接口 + * + * @author qzz + * @date 2025-03-18 + */ +public interface ICheckoffRecordsService +{ + /** + * 查询核销记录 + * + * @param checkoffId 核销记录主键 + * @return 核销记录 + */ + public CheckoffRecordsVO selectCheckoffRecordsByCheckoffId(Long checkoffId); + + /** + * 查询核销记录列表 + * + * @param checkoffRecords 核销记录 + * @return 核销记录集合 + */ + public List selectCheckoffRecordsList(CheckoffRecordsQuery checkoffRecords); + + /** + * 新增核销记录 + * + * @param checkoffRecords 核销记录 + * @return 结果 + */ + public int insertCheckoffRecords(CheckoffRecords checkoffRecords); + + /** + * 修改核销记录 + * + * @param checkoffRecords 核销记录 + * @return 结果 + */ + public int updateCheckoffRecords(CheckoffRecords checkoffRecords); + + /** + * 批量删除核销记录 + * + * @param checkoffIds 需要删除的核销记录主键集合 + * @return 结果 + */ + public int deleteCheckoffRecordsByCheckoffIds(Long[] checkoffIds); + + /** + * 删除核销记录信息 + * + * @param checkoffId 核销记录主键 + * @return 结果 + */ + public int deleteCheckoffRecordsByCheckoffId(Long checkoffId); + + /** + * 最后一条核销记录 + * + * @param cardId 卡券id + * @return 结果 + */ + CheckoffRecords selectCheckoffRecordsByCardId(Long cardId); +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/checkoff/service/impl/CheckoffRecordsServiceImpl.java b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/service/impl/CheckoffRecordsServiceImpl.java new file mode 100644 index 0000000..84423f5 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/checkoff/service/impl/CheckoffRecordsServiceImpl.java @@ -0,0 +1,106 @@ +package com.ruoyi.ss.checkoff.service.impl; + +import java.util.List; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.ruoyi.ss.checkoff.mapper.CheckoffRecordsMapper; +import com.ruoyi.ss.checkoff.domain.CheckoffRecords; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsVO; +import com.ruoyi.ss.checkoff.domain.CheckoffRecordsQuery; +import com.ruoyi.ss.checkoff.service.ICheckoffRecordsService; + +/** + * 核销记录Service业务层处理 + * + * @author qzz + * @date 2025-03-18 + */ +@Service +public class CheckoffRecordsServiceImpl implements ICheckoffRecordsService +{ + @Autowired + private CheckoffRecordsMapper checkoffRecordsMapper; + + /** + * 查询核销记录 + * + * @param checkoffId 核销记录主键 + * @return 核销记录 + */ + @Override + public CheckoffRecordsVO selectCheckoffRecordsByCheckoffId(Long checkoffId) + { + return checkoffRecordsMapper.selectCheckoffRecordsByCheckoffId(checkoffId); + } + + /** + * 查询核销记录列表 + * + * @param checkoffRecords 核销记录 + * @return 核销记录 + */ + @Override + public List selectCheckoffRecordsList(CheckoffRecordsQuery checkoffRecords) + { + return checkoffRecordsMapper.selectCheckoffRecordsList(checkoffRecords); + } + + /** + * 新增核销记录 + * + * @param checkoffRecords 核销记录 + * @return 结果 + */ + @Override + public int insertCheckoffRecords(CheckoffRecords checkoffRecords) + { + return checkoffRecordsMapper.insertCheckoffRecords(checkoffRecords); + } + + /** + * 修改核销记录 + * + * @param checkoffRecords 核销记录 + * @return 结果 + */ + @Override + public int updateCheckoffRecords(CheckoffRecords checkoffRecords) + { + return checkoffRecordsMapper.updateCheckoffRecords(checkoffRecords); + } + + /** + * 批量删除核销记录 + * + * @param checkoffIds 需要删除的核销记录主键 + * @return 结果 + */ + @Override + public int deleteCheckoffRecordsByCheckoffIds(Long[] checkoffIds) + { + return checkoffRecordsMapper.deleteCheckoffRecordsByCheckoffIds(checkoffIds); + } + + /** + * 删除核销记录信息 + * + * @param checkoffId 核销记录主键 + * @return 结果 + */ + @Override + public int deleteCheckoffRecordsByCheckoffId(Long checkoffId) + { + return checkoffRecordsMapper.deleteCheckoffRecordsByCheckoffId(checkoffId); + } + + /** + * 最后一条核销记录 + * + * @param cardId 卡券id + * @return 结果 + */ + @Override + public CheckoffRecords selectCheckoffRecordsByCardId(Long cardId) { + return checkoffRecordsMapper.selectCheckoffRecordsByCardId(cardId); + } +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMapping.java b/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMapping.java new file mode 100644 index 0000000..5230d2b --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMapping.java @@ -0,0 +1,31 @@ +package com.ruoyi.ss.mapping.domain; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; +import org.apache.commons.lang3.builder.ToStringBuilder; +import org.apache.commons.lang3.builder.ToStringStyle; +import com.ruoyi.common.annotation.Excel; +import com.ruoyi.common.core.domain.BaseEntity; + +/** + * 系统与第三方店铺映射关系对象 ss_store_mapping + * + * @author qzz + * @date 2025-03-18 + */ +@Data +public class StoreMapping extends BaseEntity{ + + private static final long serialVersionUID = 1L; + + private Long storeId; + + @Excel(name = "第三方店铺id") + @ApiModelProperty("第三方店铺id") + private String tpStoreId; + + @Excel(name = "1-抖音；2-美团") + @ApiModelProperty("1-抖音；2-美团") + private String type; + +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMappingQuery.java b/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMappingQuery.java new file mode 100644 index 0000000..6968738 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMappingQuery.java @@ -0,0 +1,7 @@ +package com.ruoyi.ss.mapping.domain; + +import lombok.Data; + +@Data +public class StoreMappingQuery extends StoreMapping{ +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMappingVO.java b/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMappingVO.java new file mode 100644 index 0000000..89bcf5e --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/domain/StoreMappingVO.java @@ -0,0 +1,11 @@ +package com.ruoyi.ss.mapping.domain; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +@Data +public class StoreMappingVO extends StoreMapping{ + + @ApiModelProperty("店铺名称") + private String storeName; +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/mapper/StoreMappingMapper.java b/share-space-system/src/main/java/com/ruoyi/ss/mapping/mapper/StoreMappingMapper.java new file mode 100644 index 0000000..ec49052 --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/mapper/StoreMappingMapper.java @@ -0,0 +1,64 @@ +package com.ruoyi.ss.mapping.mapper; + +import java.util.List; +import com.ruoyi.ss.mapping.domain.StoreMapping; +import com.ruoyi.ss.mapping.domain.StoreMappingVO; +import com.ruoyi.ss.mapping.domain.StoreMappingQuery; +import org.apache.ibatis.annotations.Param; + +/** + * 系统与第三方店铺映射关系Mapper接口 + * + * @author qzz + * @date 2025-03-18 + */ +public interface StoreMappingMapper +{ + /** + * 查询系统与第三方店铺映射关系 + * + * @param storeId 系统与第三方店铺映射关系主键 + * @return 系统与第三方店铺映射关系 + */ + public StoreMappingVO selectStoreMappingByStoreId(Long storeId); + + /** + * 查询系统与第三方店铺映射关系列表 + * + * @param query 系统与第三方店铺映射关系 + * @return 系统与第三方店铺映射关系集合 + */ + public List selectStoreMappingList(@Param("query")StoreMappingQuery query); + + /** + * 新增系统与第三方店铺映射关系 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 结果 + */ + public int insertStoreMapping(StoreMapping storeMapping); + + /** + * 修改系统与第三方店铺映射关系 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 结果 + */ + public int updateStoreMapping(@Param("data") StoreMapping storeMapping); + + /** + * 删除系统与第三方店铺映射关系 + * + * @param storeId 系统与第三方店铺映射关系主键 + * @return 结果 + */ + public int deleteStoreMappingByStoreId(Long storeId); + + /** + * 批量删除系统与第三方店铺映射关系 + * + * @param storeIds 需要删除的数据主键集合 + * @return 结果 + */ + public int deleteStoreMappingByStoreIds(Long[] storeIds); +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/mapper/StoreMappingMapper.xml b/share-space-system/src/main/java/com/ruoyi/ss/mapping/mapper/StoreMappingMapper.xml new file mode 100644 index 0000000..9410f2c --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/mapper/StoreMappingMapper.xml @@ -0,0 +1,76 @@ + + + + + + + + select + sm.store_id, + sm.tp_store_id, + s.name as storeName, + sm.type, + sm.create_time + from ss_store_mapping sm + left join ss_store s on sm.store_id = s.store_id + + + + and sm.tp_store_id = #{query.tpStoreId} + and sm.type = #{query.type} + + + + + + + + insert into ss_store_mapping + + store_id, + tp_store_id, + type, + create_time, + + + #{storeId}, + #{tpStoreId}, + #{type}, + #{createTime}, + + + + + update ss_store_mapping + + + + where store_id = #{data.storeId} + + + + tp_store_id = #{data.tpStoreId}, + type = #{data.type}, + + + + delete from ss_store_mapping where store_id = #{storeId} + + + + delete from ss_store_mapping where store_id in + + #{storeId} + + + diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/service/IStoreMappingService.java b/share-space-system/src/main/java/com/ruoyi/ss/mapping/service/IStoreMappingService.java new file mode 100644 index 0000000..9ee962f --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/service/IStoreMappingService.java @@ -0,0 +1,63 @@ +package com.ruoyi.ss.mapping.service; + +import java.util.List; +import com.ruoyi.ss.mapping.domain.StoreMapping; +import com.ruoyi.ss.mapping.domain.StoreMappingVO; +import com.ruoyi.ss.mapping.domain.StoreMappingQuery; + +/** + * 系统与第三方店铺映射关系Service接口 + * + * @author qzz + * @date 2025-03-18 + */ +public interface IStoreMappingService +{ + /** + * 查询系统与第三方店铺映射关系 + * + * @param storeId 系统与第三方店铺映射关系主键 + * @return 系统与第三方店铺映射关系 + */ + public StoreMappingVO selectStoreMappingByStoreId(Long storeId); + + /** + * 查询系统与第三方店铺映射关系列表 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 系统与第三方店铺映射关系集合 + */ + public List selectStoreMappingList(StoreMappingQuery storeMapping); + + /** + * 新增系统与第三方店铺映射关系 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 结果 + */ + public int insertStoreMapping(StoreMapping storeMapping); + + /** + * 修改系统与第三方店铺映射关系 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 结果 + */ + public int updateStoreMapping(StoreMapping storeMapping); + + /** + * 批量删除系统与第三方店铺映射关系 + * + * @param storeIds 需要删除的系统与第三方店铺映射关系主键集合 + * @return 结果 + */ + public int deleteStoreMappingByStoreIds(Long[] storeIds); + + /** + * 删除系统与第三方店铺映射关系信息 + * + * @param storeId 系统与第三方店铺映射关系主键 + * @return 结果 + */ + public int deleteStoreMappingByStoreId(Long storeId); +} diff --git a/share-space-system/src/main/java/com/ruoyi/ss/mapping/service/impl/StoreMappingServiceImpl.java b/share-space-system/src/main/java/com/ruoyi/ss/mapping/service/impl/StoreMappingServiceImpl.java new file mode 100644 index 0000000..eef514d --- /dev/null +++ b/share-space-system/src/main/java/com/ruoyi/ss/mapping/service/impl/StoreMappingServiceImpl.java @@ -0,0 +1,98 @@ +package com.ruoyi.ss.mapping.service.impl; + +import java.util.List; + +import com.ruoyi.common.utils.DateUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import com.ruoyi.ss.mapping.mapper.StoreMappingMapper; +import com.ruoyi.ss.mapping.domain.StoreMapping; +import com.ruoyi.ss.mapping.domain.StoreMappingVO; +import com.ruoyi.ss.mapping.domain.StoreMappingQuery; +import com.ruoyi.ss.mapping.service.IStoreMappingService; + +/** + * 系统与第三方店铺映射关系Service业务层处理 + * + * @author qzz + * @date 2025-03-18 + */ +@Service +public class StoreMappingServiceImpl implements IStoreMappingService +{ + @Autowired + private StoreMappingMapper storeMappingMapper; + + /** + * 查询系统与第三方店铺映射关系 + * + * @param storeId 系统与第三方店铺映射关系主键 + * @return 系统与第三方店铺映射关系 + */ + @Override + public StoreMappingVO selectStoreMappingByStoreId(Long storeId) + { + return storeMappingMapper.selectStoreMappingByStoreId(storeId); + } + + /** + * 查询系统与第三方店铺映射关系列表 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 系统与第三方店铺映射关系 + */ + @Override + public List selectStoreMappingList(StoreMappingQuery storeMapping) + { + return storeMappingMapper.selectStoreMappingList(storeMapping); + } + + /** + * 新增系统与第三方店铺映射关系 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 结果 + */ + @Override + public int insertStoreMapping(StoreMapping storeMapping) + { + storeMapping.setCreateTime(DateUtils.getNowDate()); + return storeMappingMapper.insertStoreMapping(storeMapping); + } + + /** + * 修改系统与第三方店铺映射关系 + * + * @param storeMapping 系统与第三方店铺映射关系 + * @return 结果 + */ + @Override + public int updateStoreMapping(StoreMapping storeMapping) + { + return storeMappingMapper.updateStoreMapping(storeMapping); + } + + /** + * 批量删除系统与第三方店铺映射关系 + * + * @param storeIds 需要删除的系统与第三方店铺映射关系主键 + * @return 结果 + */ + @Override + public int deleteStoreMappingByStoreIds(Long[] storeIds) + { + return storeMappingMapper.deleteStoreMappingByStoreIds(storeIds); + } + + /** + * 删除系统与第三方店铺映射关系信息 + * + * @param storeId 系统与第三方店铺映射关系主键 + * @return 结果 + */ + @Override + public int deleteStoreMappingByStoreId(Long storeId) + { + return storeMappingMapper.deleteStoreMappingByStoreId(storeId); + } +}