From 9bcc375433355c15e5379fb8de462f0a6f01ff94 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 10:01:34 +0800 Subject: [PATCH 01/10] tt --- mallinkService/src/main/resources/mapper/TtCouponMapper.xml | 5 ++++- .../java/com/iformall/controller/tt/TtCouponController.java | 4 ++-- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/mallinkService/src/main/resources/mapper/TtCouponMapper.xml b/mallinkService/src/main/resources/mapper/TtCouponMapper.xml index d22b3554e..27c63bb90 100644 --- a/mallinkService/src/main/resources/mapper/TtCouponMapper.xml +++ b/mallinkService/src/main/resources/mapper/TtCouponMapper.xml @@ -57,7 +57,10 @@ - where c.`is_del` = 0 and c.`type` != 3 + where c.`is_del` = 0 + + and c.`type` != 3 + and c.`id` = #{id} diff --git a/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java b/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java index dac463e2c..502911e74 100644 --- a/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java +++ b/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java @@ -124,7 +124,7 @@ public class TtCouponController extends BaseController { VideUploadResult result = videoFactory.getExcutor(videoType).getVideoDetail(record.getVideoId()); if(result.isSuccess()){ record.setVideoTime(result.getDuration()); - record.setVideoUrl(result.getVideoUrl()); +// record.setVideoUrl(result.getVideoUrl()); TtVideoLibrary video = new TtVideoLibrary(); video.updateTenantInfo(tenantEntity); video.setVideoId(record.getVideoId()); @@ -145,7 +145,7 @@ public class TtCouponController extends BaseController { VideUploadResult result = videoFactory.getExcutor(videoType).getVideoDetail(ttc.getVideoId()); if(result.isSuccess()){ ttc.setVideoTime(result.getDuration()); - ttc.setVideoUrl(result.getVideoUrl()); +// ttc.setVideoUrl(result.getVideoUrl()); TtVideoLibrary video = new TtVideoLibrary(); video.updateTenantInfo(tenantEntity); video.setVideoId(record.getVideoId()); From 9d98f53b6f908aa33fc2ce9b8a43d93e7f94fea5 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 10:14:03 +0800 Subject: [PATCH 02/10] tt --- mallinkService/src/main/resources/mapper/TtCouponMapper.xml | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/mallinkService/src/main/resources/mapper/TtCouponMapper.xml b/mallinkService/src/main/resources/mapper/TtCouponMapper.xml index 27c63bb90..f001e9c32 100644 --- a/mallinkService/src/main/resources/mapper/TtCouponMapper.xml +++ b/mallinkService/src/main/resources/mapper/TtCouponMapper.xml @@ -77,6 +77,10 @@ and c.`type` = #{type} + + and c.`column_id` = #{columnId} + + and c.`title` like concat('%', #{title},'%') From e4e2211615011ac6a8c0c86b98f353b94dc9b1da Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 10:49:11 +0800 Subject: [PATCH 03/10] tt --- .../iformall/service/tt/TtCouponService.java | 4 +++ .../service/tt/impl/TtCouponServiceImpl.java | 30 +++++++++++++++++++ .../controller/tt/TtCouponController.java | 28 +++++++++++++++-- 3 files changed, 60 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java b/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java index 3ab92b7f7..c848b132b 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java @@ -48,4 +48,8 @@ public interface TtCouponService { @Async void collectCoupon(TenantEntity tenantEntity,Long memberId, Long id); + + ResultData auditPass(Long id); + + ResultData auditRejected(Long id); } diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java index 2f0d9ca46..75f3f885c 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java @@ -189,4 +189,34 @@ public class TtCouponServiceImpl implements TtCouponService { // e.printStackTrace(); } } + + @Override + public ResultData auditPass(Long id) { + TtCoupon byId = this.getById(id); + if(byId == null){ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"未找到课程"); + } + if(!byId.getStatus().equals(EnumTtCouponStatus.TTCOUPON_STATUS_EXAMINE.getCode())){ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"此课程状态不在审核中"); + } + byId.setStatus(EnumTtCouponStatus.TTCOUPON_STATUS_BEFOR_SHELF.getCode()); + byId.setUpdateDate(new Date()); + ttCouponMapper.updateById(byId); + return new ResultData(); + } + + @Override + public ResultData auditRejected(Long id) { + TtCoupon byId = this.getById(id); + if(byId == null){ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"未找到课程"); + } + if(!byId.getStatus().equals(EnumTtCouponStatus.TTCOUPON_STATUS_EXAMINE.getCode())){ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"此课程状态不在审核中"); + } + byId.setStatus(EnumTtCouponStatus.TTCOUPON_STATUS_REJECT.getCode()); + byId.setUpdateDate(new Date()); + ttCouponMapper.updateById(byId); + return new ResultData(); + } } diff --git a/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java b/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java index 502911e74..4f1158933 100644 --- a/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java +++ b/mallinkTTAdmin/src/main/java/com/iformall/controller/tt/TtCouponController.java @@ -281,10 +281,10 @@ public class TtCouponController extends BaseController { @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) @SystemControllerLog(description = "") public ResultData puton(@RequestParam Long id) { - logger.debug("[" + getIpAddr() + "] TtCouponController::findById");if (id == null) { + logger.debug("[" + getIpAddr() + "] TtCouponController::findById"); + if (id == null) { return new ResultData(ResultData.ERROR, "缺少id"); } - return ttCouponService.puton(id); } @@ -300,4 +300,28 @@ public class TtCouponController extends BaseController { return ttCouponService.putoff(id); } + @ApiOperation("审批通过") + @GetMapping("/auditPass") + @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) + @SystemControllerLog(description = "") + public ResultData auditPass(@RequestParam Long id) { + logger.debug("[" + getIpAddr() + "] TtCouponController::auditPass"); + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + return ttCouponService.auditPass(id); + } + + @ApiOperation("审批拒绝") + @PostMapping("/auditRejected") + @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) + @SystemControllerLog(description = "") + public ResultData auditRejected(@RequestBody TtCoupon record) { + logger.debug("[" + getIpAddr() + "] TtCouponController::auditRejected"); + if (record.getId() == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + return ttCouponService.auditRejected(record.getId()); + } + } From e17e7e37b1ab4b519fffe6eaae5fc8d6aae17efb Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 11:26:54 +0800 Subject: [PATCH 04/10] tt --- .../java/com/iformall/service/tt/impl/TtCouponServiceImpl.java | 1 - .../main/java/com/iformall/controller/TtCouponController.java | 2 ++ 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java index 75f3f885c..accecc40f 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java @@ -7,7 +7,6 @@ import com.github.pagehelper.PageInfo; import com.iformall.common.ErrorCode; import com.iformall.common.IdWorker; import com.iformall.common.ResultData; -import com.iformall.domain.po.WxMerchant; import com.iformall.domain.po.base.TenantEntity; import com.iformall.domain.po.tt.TtCoupon; import com.iformall.domain.po.tt.TtUserCollect; diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java index dc95afb1f..e3a82e02e 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java @@ -3,6 +3,7 @@ package com.iformall.controller; import com.iformall.common.ErrorCode; import com.iformall.common.ResultData; import com.iformall.domain.po.tt.TtCoupon; +import com.iformall.enums.EnumTtCouponStatus; import com.iformall.exception.MallinkException; import com.iformall.service.tt.TtCouponService; import io.swagger.annotations.Api; @@ -32,6 +33,7 @@ public class TtCouponController extends BaseController { public ResultData list(@ModelAttribute TtCoupon record, Integer pageNum, Integer pageSize, Integer dataType) { logger.debug("[" + getIpAddr() + "] TtCouponController::list"); if (record == null) record = new TtCoupon(); + record.setStatus(EnumTtCouponStatus.TTCOUPON_STATUS_SHELFING.getCode()); return new ResultData(ttCouponService.listAsPage(record, pageNum, pageSize)); } From 84b7a41c1f58d80705db810aa01fc3df443630f7 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 14:03:22 +0800 Subject: [PATCH 05/10] tt --- .../iformall/service/WxMerchantService.java | 3 + .../service/impl/WxMerchantServiceImpl.java | 22 ++++- .../service/tt/impl/TtCouponServiceImpl.java | 2 + .../controller/TtCouponController.java | 4 +- .../controller/WxMerchantController.java | 99 +++++++++++++++++++ 5 files changed, 127 insertions(+), 3 deletions(-) create mode 100644 mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java diff --git a/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java b/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java index 9d31c435b..c0124ddc7 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java @@ -13,6 +13,7 @@ import com.iformall.domain.vo.WxMerchantTradeVo; import com.iformall.domain.vo.WxMerchantVo; import com.iformall.enums.EnumPayWay; +import org.springframework.scheduling.annotation.Async; import org.springframework.web.bind.annotation.ModelAttribute; import javax.servlet.http.HttpServletRequest; @@ -160,4 +161,6 @@ public interface WxMerchantService { List getMerchantShopIds(Long merchantId); + @Async + void collectCoupon(TenantEntity tenantInfo, Long memberId, Long id); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java index 4a9243fd2..6e0d6a434 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java @@ -12,13 +12,13 @@ import com.iformall.domain.dto.WxMerchantDto; import com.iformall.domain.po.*; import com.iformall.domain.po.base.BaseEntity; import com.iformall.domain.po.base.TenantEntity; +import com.iformall.domain.po.tt.TtUserFollow; import com.iformall.domain.vo.*; import com.iformall.enums.*; import com.iformall.exception.MallinkException; import com.iformall.mapper.*; import com.iformall.service.*; import com.iformall.utils.DateUtils; -import com.iformall.utils.EventUtil; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; @@ -102,6 +102,9 @@ public class WxMerchantServiceImpl implements WxMerchantService { @Autowired WxPropertyContractService wxPropertyContractService; + @Autowired + TtUserFollowMapper ttUserFollowMapper; + @Override public PageInfo listAsPage(WxMerchant record, Integer pageIndex, Integer pageSize) { PageHelper.startPage(pageIndex, pageSize); @@ -940,4 +943,21 @@ public class WxMerchantServiceImpl implements WxMerchantService { public List getMerchantShopIds(Long merchantId) { return wxMerchantShopMapper.findShopIds(merchantId); } + + @Override + public void collectCoupon(TenantEntity tenantEntity, Long memberId, Long id) { + final IdWorker idWorker = IdWorker.get(); + TtUserFollow userFollow = new TtUserFollow(); + userFollow.setId(idWorker.nextId()); + userFollow.updateTenantInfo(tenantEntity); + userFollow.setUserId(memberId); + userFollow.setMerchernId(id); + userFollow.setCreateDate(new Date()); + userFollow.setUpdateDate(new Date()); + try { + ttUserFollowMapper.insert(userFollow); + } catch (Exception e) { +// e.printStackTrace(); + } + } } diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java index accecc40f..2033efb7b 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java @@ -173,6 +173,7 @@ public class TtCouponServiceImpl implements TtCouponService { } @Override +// @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) public void collectCoupon(TenantEntity tenantEntity,Long memberId, Long id) { final IdWorker idWorker = IdWorker.get(); TtUserCollect userCollect = new TtUserCollect(); @@ -187,6 +188,7 @@ public class TtCouponServiceImpl implements TtCouponService { } catch (Exception e) { // e.printStackTrace(); } + ttCouponMapper.addCollectCount(id); } @Override diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java index e3a82e02e..d34abf45f 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java @@ -16,7 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.*; @RestController -@RequestMapping("ttCoupon") +@RequestMapping("api/ttCoupon") @Api(description = "") public class TtCouponController extends BaseController { @@ -52,7 +52,7 @@ public class TtCouponController extends BaseController { @GetMapping("/collectCoupon") @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) public ResultData collectCoupon(@RequestParam Long id) { - logger.debug("[" + getIpAddr() + "] TtCouponController::findById"); + logger.debug("[" + getIpAddr() + "] TtCouponController::collectCoupon"); if (id == null) { return new ResultData(ResultData.ERROR, "缺少id"); } diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java new file mode 100644 index 000000000..048a4be48 --- /dev/null +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java @@ -0,0 +1,99 @@ +package com.iformall.controller; + +import com.iformall.common.ErrorCode; +import com.iformall.common.ResultData; +import com.iformall.domain.dto.WxMerchantDto; +import com.iformall.domain.po.WxMerchant; +import com.iformall.domain.po.base.TenantEntity; +import com.iformall.domain.vo.WxMerchantVo; +import com.iformall.enums.EnumMerchantPublic; +import com.iformall.enums.EnumMerchantStatus; +import com.iformall.exception.MallinkException; +import com.iformall.service.WxMerchantService; +import com.iformall.utils.HashUtil; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiImplicitParams; +import io.swagger.annotations.ApiOperation; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.HashMap; + +/** + * @author Stormeye + */ +@RestController +@RequestMapping("/api/merchant") +public class WxMerchantController extends BaseController { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private WxMerchantService wxMerchantService; + + @ApiOperation("分页列表接口") + @GetMapping("list") + @ApiImplicitParams({ + @ApiImplicitParam(name = "pageNum", value = "页数", dataType = "int", paramType = "query", required = true), + @ApiImplicitParam(name = "pageSize", value = "每页条数", dataType = "int", paramType = "query", required = true)}) + public ResultData list(@ModelAttribute WxMerchantDto wxMerchantDto, Integer pageNum, Integer pageSize) { + logger.debug("[" + getIpAddr() + "] WxMerchantController::list"); + if (null == wxMerchantDto) wxMerchantDto = new WxMerchantDto(); + wxMerchantDto.updateTenantInfo(getTenantInfo()); + wxMerchantDto.setMerchantStatus(EnumMerchantStatus.VALID.getCode()); + wxMerchantDto.setIsPublic(EnumMerchantPublic.PUBLIC.getCode()); + return new ResultData(wxMerchantService.listAsPageCVo(wxMerchantDto, pageNum, pageSize)); + } + + @ApiOperation("根据code查询接口") + @GetMapping("/findByCode") + @ApiImplicitParam(name = "merchantCode", value = "merchantCode", dataType = "String", paramType = "query", required = true) + public ResultData findByCode(String merchantCode) { + logger.debug("[" + getIpAddr() + "] WxMerchantController::findByCode"); + if(merchantCode == null) { + return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL); + } + String codeMD5 = HashUtil.DecodeByMD5(merchantCode); + if(StringUtils.isBlank(codeMD5)) { + return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL); + } + HashMap params = new HashMap(); + TenantEntity tenantEntity = getTenantInfo(); + params.put("tenantId", tenantEntity.getTenantId()); + if (StringUtils.isNotBlank(tenantEntity.getParentTenantId())) { + params.put("parentTenantId", tenantEntity.getParentTenantId()); + } + params.put("merchantCode", codeMD5); + WxMerchantVo wxMerchant = wxMerchantService.getMerchantInfo(params); + return new ResultData(wxMerchant); + } + + + + + @ApiOperation("关注") + @GetMapping("/collectCoupon") + @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) + public ResultData collectCoupon(@RequestParam Long id) { + logger.debug("[" + getIpAddr() + "] WxMerchantController::collectCoupon"); + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + WxMerchant byId = wxMerchantService.getById(id); + if(byId == null){ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"找不到数据"); + } + Long memberId; + try { + memberId = getMemberId(); + } catch (MallinkException e) { + return new ResultData(e.getErrorCode(), e.getMessage()); + } + + wxMerchantService.collectCoupon(getTenantInfo(),memberId,byId.getId()); + return new ResultData(); + } + +} From 9114767dafef95b404c034b5cc1bcc0ae1045ae8 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 14:21:27 +0800 Subject: [PATCH 06/10] tt --- .../main/java/com/iformall/utils/AppTest.java | 26 ++++++++++--------- .../iformall/mapper/TtUserFollowMapper.java | 2 +- .../iformall/service/WxMerchantService.java | 2 +- .../service/impl/WxMerchantServiceImpl.java | 2 +- .../controller/TtCouponController.java | 2 +- .../controller/WxMerchantController.java | 2 +- 6 files changed, 19 insertions(+), 17 deletions(-) diff --git a/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java b/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java index 8326f2e25..7d247e337 100644 --- a/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java +++ b/mallinkPublicApi/src/main/java/com/iformall/utils/AppTest.java @@ -40,21 +40,21 @@ public class AppTest { * 查询用户详细信息 参数 */ // paramMap.put("phone","18872592633"); - paramMap.put("openId","opvcM5A41kbQF_NY8k3LMDqxCDUM"); +// paramMap.put("openId","opvcM5A41kbQF_NY8k3LMDqxCDUM"); /** * 创建交易信息 参数 */ -// IdWorker idWorker = IdWorker.get(); -// paramMap.put("transactionId",String.valueOf(idWorker.nextId()));//***订单Id -// paramMap.put("shopNumber","1001");//***门店唯一标识 对应双方平台门店 -// paramMap.put("shopName","百丽");//门店名称 -// paramMap.put("userNumber","546907706202185728");//***会员Id -// paramMap.put("userPhone","18872592633");//会员手机号 -// paramMap.put("timeEnd","2021-04-27 11:43:00");//***付款时间(yyyy-MM-dd HH:mm:ss) -// paramMap.put("amount","1000");//***付款金额(分) -// paramMap.put("summary","我要加积分");//付款摘要 + IdWorker idWorker = IdWorker.get(); + paramMap.put("transactionId",String.valueOf(idWorker.nextId()));//***订单Id + paramMap.put("shopNumber","1001");//***门店唯一标识 对应双方平台门店 + paramMap.put("shopName","百丽");//门店名称 + paramMap.put("userNumber","546907706202185728");//***会员Id + paramMap.put("userPhone","18872592633");//会员手机号 + paramMap.put("timeEnd","2021-04-27 11:43:00");//***付款时间(yyyy-MM-dd HH:mm:ss) + paramMap.put("amount","1100");//***付款金额(分) + paramMap.put("summary","我要加积分");//付款摘要 /** * 交易退款信息 参数 @@ -96,13 +96,15 @@ public class AppTest { /** * 注册并查询用户详细信息 接口 */ - String s = HttpUtil.doPost("https://openapitest.malls.iformall.com/api/userInfo/get", headMap, JSON.toJSONString(paramMap)); +// String s = HttpUtil.doPost("https://openapitest.malls.iformall.com/api/userInfo/get", headMap, JSON.toJSONString(paramMap)); /** * 创建交易信息 接口 */ -// String s = HttpUtil.doPost("https://openapitest.malls.iformall.com/api/thirdCircle/order", headMap, JSON.toJSONString(paramMap)); + String s = HttpUtil.doPost("https://openapitest.malls.iformall.com/api/thirdCircle/order", headMap, JSON.toJSONString(paramMap)); +// String s = HttpUtil.doPost("http://localhost:7070/public/api/thirdCircle/order", headMap, JSON.toJSONString(paramMap)); + /** * 交易退款 接口 diff --git a/mallinkService/src/main/java/com/iformall/mapper/TtUserFollowMapper.java b/mallinkService/src/main/java/com/iformall/mapper/TtUserFollowMapper.java index c8622e054..4eb740a96 100644 --- a/mallinkService/src/main/java/com/iformall/mapper/TtUserFollowMapper.java +++ b/mallinkService/src/main/java/com/iformall/mapper/TtUserFollowMapper.java @@ -7,7 +7,7 @@ import java.util.List; public interface TtUserFollowMapper extends CommonMapper { - List findList(TtUserFollow collect); + List findList(TtUserFollow follow); int deleteById(Long id); diff --git a/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java b/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java index c0124ddc7..8f74a22c3 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java @@ -162,5 +162,5 @@ public interface WxMerchantService { List getMerchantShopIds(Long merchantId); @Async - void collectCoupon(TenantEntity tenantInfo, Long memberId, Long id); + void followMerchern(TenantEntity tenantInfo, Long memberId, Long id); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java index 6e0d6a434..c18b86ddf 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java @@ -945,7 +945,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { } @Override - public void collectCoupon(TenantEntity tenantEntity, Long memberId, Long id) { + public void followMerchern(TenantEntity tenantEntity, Long memberId, Long id) { final IdWorker idWorker = IdWorker.get(); TtUserFollow userFollow = new TtUserFollow(); userFollow.setId(idWorker.nextId()); diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java index d34abf45f..4e9615294 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java @@ -30,7 +30,7 @@ public class TtCouponController extends BaseController { @ApiImplicitParams({ @ApiImplicitParam(name = "pageNum", value = "页数", dataType = "int", paramType = "query", required = true), @ApiImplicitParam(name = "pageSize", value = "每页条数", dataType = "int", paramType = "query", required = true)}) - public ResultData list(@ModelAttribute TtCoupon record, Integer pageNum, Integer pageSize, Integer dataType) { + public ResultData list(@ModelAttribute TtCoupon record, Integer pageNum, Integer pageSize) { logger.debug("[" + getIpAddr() + "] TtCouponController::list"); if (record == null) record = new TtCoupon(); record.setStatus(EnumTtCouponStatus.TTCOUPON_STATUS_SHELFING.getCode()); diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java index 048a4be48..1bc37ce8d 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java @@ -92,7 +92,7 @@ public class WxMerchantController extends BaseController { return new ResultData(e.getErrorCode(), e.getMessage()); } - wxMerchantService.collectCoupon(getTenantInfo(),memberId,byId.getId()); + wxMerchantService.followMerchern(getTenantInfo(),memberId,byId.getId()); return new ResultData(); } From 73d5f0d4ace7a8fe3c4ea4c81f45d5a4f15e09fe Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 14:55:38 +0800 Subject: [PATCH 07/10] tt --- .../iformall/service/WxMerchantService.java | 2 -- .../service/impl/WxMerchantServiceImpl.java | 22 ++----------- .../controller/WxBusinessController.java | 31 +++++++++++++++++++ .../controller/WxMerchantController.java | 25 --------------- 4 files changed, 33 insertions(+), 47 deletions(-) create mode 100644 mallinkTTCApi/src/main/java/com/iformall/controller/WxBusinessController.java diff --git a/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java b/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java index 8f74a22c3..ff75194a9 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxMerchantService.java @@ -161,6 +161,4 @@ public interface WxMerchantService { List getMerchantShopIds(Long merchantId); - @Async - void followMerchern(TenantEntity tenantInfo, Long memberId, Long id); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java index c18b86ddf..73a729fdc 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java @@ -12,7 +12,6 @@ import com.iformall.domain.dto.WxMerchantDto; import com.iformall.domain.po.*; import com.iformall.domain.po.base.BaseEntity; import com.iformall.domain.po.base.TenantEntity; -import com.iformall.domain.po.tt.TtUserFollow; import com.iformall.domain.vo.*; import com.iformall.enums.*; import com.iformall.exception.MallinkException; @@ -24,6 +23,7 @@ import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.context.annotation.Lazy; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Isolation; import org.springframework.transaction.annotation.Propagation; @@ -85,6 +85,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { WxCouponMerchantMapper wxCouponMerchantMapper; @Autowired + @Lazy WxRentContractService wxRentContractService; @Autowired @@ -102,9 +103,6 @@ public class WxMerchantServiceImpl implements WxMerchantService { @Autowired WxPropertyContractService wxPropertyContractService; - @Autowired - TtUserFollowMapper ttUserFollowMapper; - @Override public PageInfo listAsPage(WxMerchant record, Integer pageIndex, Integer pageSize) { PageHelper.startPage(pageIndex, pageSize); @@ -944,20 +942,4 @@ public class WxMerchantServiceImpl implements WxMerchantService { return wxMerchantShopMapper.findShopIds(merchantId); } - @Override - public void followMerchern(TenantEntity tenantEntity, Long memberId, Long id) { - final IdWorker idWorker = IdWorker.get(); - TtUserFollow userFollow = new TtUserFollow(); - userFollow.setId(idWorker.nextId()); - userFollow.updateTenantInfo(tenantEntity); - userFollow.setUserId(memberId); - userFollow.setMerchernId(id); - userFollow.setCreateDate(new Date()); - userFollow.setUpdateDate(new Date()); - try { - ttUserFollowMapper.insert(userFollow); - } catch (Exception e) { -// e.printStackTrace(); - } - } } diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/WxBusinessController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/WxBusinessController.java new file mode 100644 index 000000000..870298919 --- /dev/null +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/WxBusinessController.java @@ -0,0 +1,31 @@ +package com.iformall.controller; + +import com.iformall.annotation.RedisCache; +import com.iformall.common.ResultData; +import com.iformall.service.WxBusinessService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +@RestController +@RequestMapping("/api/wxBusiness") +@Api(description = "业态查询接口") +public class WxBusinessController extends BaseController { + private final Logger logger = LoggerFactory.getLogger(this.getClass()); + + @Autowired + private WxBusinessService wxBusinessService; + + @RedisCache + @ApiOperation("业态全列表接口") + @GetMapping("listAll") + public ResultData listAll(Integer filter) { + return new ResultData(wxBusinessService.findListAll(getTenantInfo(),filter)); + } + +} diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java index 1bc37ce8d..4f75a17d3 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/WxMerchantController.java @@ -71,29 +71,4 @@ public class WxMerchantController extends BaseController { } - - - @ApiOperation("关注") - @GetMapping("/collectCoupon") - @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) - public ResultData collectCoupon(@RequestParam Long id) { - logger.debug("[" + getIpAddr() + "] WxMerchantController::collectCoupon"); - if (id == null) { - return new ResultData(ResultData.ERROR, "缺少id"); - } - WxMerchant byId = wxMerchantService.getById(id); - if(byId == null){ - return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"找不到数据"); - } - Long memberId; - try { - memberId = getMemberId(); - } catch (MallinkException e) { - return new ResultData(e.getErrorCode(), e.getMessage()); - } - - wxMerchantService.followMerchern(getTenantInfo(),memberId,byId.getId()); - return new ResultData(); - } - } From ebe1456da47427f61b7f1e52659ed264424d2cf2 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 16:14:18 +0800 Subject: [PATCH 08/10] tt --- .../service/impl/WxMerchantServiceImpl.java | 1 - .../iformall/service/tt/TtCouponService.java | 6 ++ .../service/tt/impl/TtCouponServiceImpl.java | 40 +++++++++++ .../service/tt/impl/TtOrderServiceImpl.java | 56 +++++++++------- .../iformall/controller/BaseController.java | 13 ++-- .../controller/TtCouponController.java | 66 ++++++++++++++++++- .../controller/TtOrderController.java | 2 - 7 files changed, 152 insertions(+), 32 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java index 73a729fdc..ad79dfc48 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java @@ -85,7 +85,6 @@ public class WxMerchantServiceImpl implements WxMerchantService { WxCouponMerchantMapper wxCouponMerchantMapper; @Autowired - @Lazy WxRentContractService wxRentContractService; @Autowired diff --git a/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java b/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java index c848b132b..7ede74487 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/TtCouponService.java @@ -48,8 +48,14 @@ public interface TtCouponService { @Async void collectCoupon(TenantEntity tenantEntity,Long memberId, Long id); + void cancelCollect(Long memberId, Long id); + + @Async + void followMerchant(TenantEntity tenantEntity, Long memberId, Long id); + void cancelFollow(Long memberId, Long id); ResultData auditPass(Long id); ResultData auditRejected(Long id); + } diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java index 2033efb7b..6451dee0e 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java @@ -10,6 +10,7 @@ import com.iformall.common.ResultData; import com.iformall.domain.po.base.TenantEntity; import com.iformall.domain.po.tt.TtCoupon; import com.iformall.domain.po.tt.TtUserCollect; +import com.iformall.domain.po.tt.TtUserFollow; import com.iformall.enums.EnumTtCouponStatus; import com.iformall.enums.EnumTtCouponType; import com.iformall.enums.EnumYesOrNo; @@ -42,6 +43,9 @@ public class TtCouponServiceImpl implements TtCouponService { @Autowired TtUserCollectMapper ttUserCollectMapper; + @Autowired + TtUserFollowMapper ttUserFollowMapper; + @Override public PageInfo listAsPage(TtCoupon record, Integer pageIndex, Integer pageSize) { @@ -191,6 +195,42 @@ public class TtCouponServiceImpl implements TtCouponService { ttCouponMapper.addCollectCount(id); } + @Override + public void cancelCollect(Long memberId, Long id) { + TtUserCollect userCollect = new TtUserCollect(); + userCollect.setUserId(memberId); + userCollect.setCouponId(id); + int delete = ttUserCollectMapper.delete(new QueryWrapper<>(userCollect)); + if(delete > 0){ + ttCouponMapper.reduceCollectCount(id); + } + } + + @Override + public void followMerchant(TenantEntity tenantEntity, Long memberId, Long id) { + final IdWorker idWorker = IdWorker.get(); + TtUserFollow userFollow = new TtUserFollow(); + userFollow.setId(idWorker.nextId()); + userFollow.updateTenantInfo(tenantEntity); + userFollow.setUserId(memberId); + userFollow.setMerchernId(id); + userFollow.setCreateDate(new Date()); + userFollow.setUpdateDate(new Date()); + try { + ttUserFollowMapper.insert(userFollow); + } catch (Exception e) { +// e.printStackTrace(); + } + } + + @Override + public void cancelFollow(Long memberId, Long id) { + TtUserFollow userFollow = new TtUserFollow(); + userFollow.setUserId(memberId); + userFollow.setMerchernId(id); + int delete = ttUserFollowMapper.delete(new QueryWrapper<>(userFollow)); + } + @Override public ResultData auditPass(Long id) { TtCoupon byId = this.getById(id); diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtOrderServiceImpl.java index 7bae86752..960352abf 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtOrderServiceImpl.java @@ -7,6 +7,7 @@ import com.iformall.common.IdWorker; import com.iformall.common.ResultData; import com.iformall.domain.po.*; import com.iformall.domain.po.base.TenantEntity; +import com.iformall.domain.po.tt.TtCUser; import com.iformall.domain.po.tt.TtCoupon; import com.iformall.domain.po.tt.TtOrder; import com.iformall.douyin.pay.DouYinPayHelper; @@ -16,6 +17,7 @@ import com.iformall.douyin.pay.preOrder.DouYinCreatePreOrder; import com.iformall.enums.*; import com.iformall.exception.MallinkException; import com.iformall.mapper.*; +import com.iformall.service.TtCUserService; import com.iformall.service.WxAppinfoService; import com.iformall.service.WxCUserBasicInfoService; import com.iformall.service.tt.TtCouponService; @@ -41,8 +43,11 @@ public class TtOrderServiceImpl implements TtOrderService { @Autowired private TtCouponService ttCouponService; +// @Autowired +// private WxCUserBasicInfoService wxCUserBasicInfoService; + @Autowired - private WxCUserBasicInfoService wxCUserBasicInfoService; + private TtCUserService ttCUserService; @Autowired private WxAppinfoService wxAppinfoService; @@ -55,8 +60,10 @@ public class TtOrderServiceImpl implements TtOrderService { @Override public ResultData saveOrder(Long couponId,Long cUserId,EnumPayWay payWay,TenantEntity tenantEntity) { logger.info("OrderSave: couponId:" + couponId + "---cUserId:"+cUserId); - WxCUserBasicInfo wxCUserBasicInfo = wxCUserBasicInfoService.getById(cUserId,tenantEntity.getFinalTenantId()); - if(wxCUserBasicInfo == null){ + TtCUser byId = ttCUserService.getById(cUserId, tenantEntity.getTenantId()); +// WxCUserBasicInfo wxCUserBasicInfo = wxCUserBasicInfoService.getById(cUserId,tenantEntity.getFinalTenantId()); +// if(wxCUserBasicInfo == null){ + if(byId == null){ return new ResultData(ErrorCode.USER_IS_EMPTY); } TtOrder orderQ = new TtOrder(); @@ -71,10 +78,10 @@ public class TtOrderServiceImpl implements TtOrderService { return new ResultData(ErrorCode.ORDER_IS_FIND); } - if (wxCUserBasicInfo.getStatus().equals(EnumCUserBasicInfoStatus.LOCKED.getCode())) { - logger.info("会员权益被锁定:cUserId:" + cUserId); - return new ResultData(ErrorCode.MEMBER_IS_LOCKED); - } +// if (wxCUserBasicInfo.getStatus().equals(EnumCUserBasicInfoStatus.LOCKED.getCode())) { +// logger.info("会员权益被锁定:cUserId:" + cUserId); +// return new ResultData(ErrorCode.MEMBER_IS_LOCKED); +// } TtCoupon coupon = ttCouponService.getById(couponId); if (null == coupon) { return new ResultData(ErrorCode.TTCOUPON_IS_EMPTY); @@ -93,7 +100,7 @@ public class TtOrderServiceImpl implements TtOrderService { TtOrder order = new TtOrder(); order.setId(idWorker.nextId()); order.updateTenantInfo(tenantEntity); - order.setCUserId(wxCUserBasicInfo.getId()); + order.setCUserId(cUserId); order.setProductId(coupon.getId()); order.setType(payWay.getCode()); order.setPaymentType(EnumPayType.PAY_PAYMENT.getCode()); @@ -176,14 +183,17 @@ public class TtOrderServiceImpl implements TtOrderService { if(!order.getCUserId().equals(memberId)){ return new ResultData(ErrorCode.ORDER_USER_NOT_MATCH); } - WxCUserBasicInfo wxCUserBasicInfo = wxCUserBasicInfoService.getById(memberId,tenantEntity.getFinalTenantId()); - if ( null == wxCUserBasicInfo) { - logger.error("会员用户不存在."+memberId); - return new ResultData(ErrorCode.USER_IS_EMPTY.getCode(),"会员用户不存在."+memberId); - } - if (null != wxCUserBasicInfo && EnumCreditLockedStatus.CLOSE.getCode().equals(wxCUserBasicInfo.getStatus())) { - return new ResultData(ErrorCode.MEMBER_IS_LOCKED); + TtCUser byId = ttCUserService.getById(memberId, tenantEntity.getTenantId()); +// WxCUserBasicInfo wxCUserBasicInfo = wxCUserBasicInfoService.getById(memberId,tenantEntity.getFinalTenantId()); +// if ( null == wxCUserBasicInfo) { + if ( byId == null) { + logger.error("用户不存在."+memberId); + return new ResultData(ErrorCode.USER_IS_EMPTY.getCode(),"用户不存在."+memberId); } +// if (null != wxCUserBasicInfo && EnumCreditLockedStatus.CLOSE.getCode().equals(wxCUserBasicInfo.getStatus())) { +// return new ResultData(ErrorCode.MEMBER_IS_LOCKED); +// } + // WxAppinfo appInfo = wxAppinfoService.getByAppId(appId); if(appInfo == null) { return new ResultData(ErrorCode.APP_ID_NOT_FOUND); @@ -258,14 +268,16 @@ public class TtOrderServiceImpl implements TtOrderService { if(!order.getCUserId().equals(memberId)){ return new ResultData(ErrorCode.ORDER_USER_NOT_MATCH); } - WxCUserBasicInfo wxCUserBasicInfo = wxCUserBasicInfoService.getById(memberId,tenantEntity.getFinalTenantId()); - if ( null == wxCUserBasicInfo) { - logger.error("会员用户不存在."+memberId); - return new ResultData(ErrorCode.USER_IS_EMPTY.getCode(),"会员用户不存在."+memberId); - } - if (null != wxCUserBasicInfo && EnumCreditLockedStatus.CLOSE.getCode().equals(wxCUserBasicInfo.getStatus())) { - return new ResultData(ErrorCode.MEMBER_IS_LOCKED); + TtCUser byId = ttCUserService.getById(memberId, tenantEntity.getTenantId()); +// WxCUserBasicInfo wxCUserBasicInfo = wxCUserBasicInfoService.getById(memberId,tenantEntity.getFinalTenantId()); +// if ( null == wxCUserBasicInfo) { + if ( byId == null) { + logger.error("用户不存在."+memberId); + return new ResultData(ErrorCode.USER_IS_EMPTY.getCode(),"用户不存在."+memberId); } +// if (null != wxCUserBasicInfo && EnumCreditLockedStatus.CLOSE.getCode().equals(wxCUserBasicInfo.getStatus())) { +// return new ResultData(ErrorCode.MEMBER_IS_LOCKED); +// } // WxAppinfo appInfo = wxAppinfoService.getByAppId(appId); if(appInfo == null) { return new ResultData(ErrorCode.APP_ID_NOT_FOUND); diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/BaseController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/BaseController.java index b46c99732..825ca6728 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/BaseController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/BaseController.java @@ -233,12 +233,13 @@ public class BaseController { } public Long getMemberId() { - HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); - Long memberId = (Long) request.getAttribute(Constant.LOGIN_MEMBER_KEY); - if(memberId == null){ - throw new MallinkException(ErrorCode.USER_IS_NOT_MEMBER); - } - return memberId; +// HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); +// Long memberId = (Long) request.getAttribute(Constant.LOGIN_MEMBER_KEY); +// if(memberId == null){ +// throw new MallinkException(ErrorCode.USER_IS_NOT_MEMBER); +// } +// return memberId; + return getTtCUser().getId(); } public String getIpAddr() { diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java index 4e9615294..ec4952c76 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/TtCouponController.java @@ -2,9 +2,11 @@ package com.iformall.controller; import com.iformall.common.ErrorCode; import com.iformall.common.ResultData; +import com.iformall.domain.po.WxMerchant; import com.iformall.domain.po.tt.TtCoupon; import com.iformall.enums.EnumTtCouponStatus; import com.iformall.exception.MallinkException; +import com.iformall.service.WxMerchantService; import com.iformall.service.tt.TtCouponService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; @@ -25,6 +27,9 @@ public class TtCouponController extends BaseController { @Autowired private TtCouponService ttCouponService; + @Autowired + private WxMerchantService wxMerchantService; + @ApiOperation("分页列表接口") @GetMapping("list") @ApiImplicitParams({ @@ -58,7 +63,7 @@ public class TtCouponController extends BaseController { } TtCoupon byId = ttCouponService.getById(id); if(byId == null){ - return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"找不到课程"); + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"找不到数据"); } Long memberId; try { @@ -70,4 +75,63 @@ public class TtCouponController extends BaseController { return new ResultData(); } + @ApiOperation("取消收藏") + @GetMapping("/cancelCollect") + @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) + public ResultData cancelCollect(@RequestParam Long id) { + logger.debug("[" + getIpAddr() + "] TtCouponController::collectCoupon"); + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + Long memberId; + try { + memberId = getMemberId(); + } catch (MallinkException e) { + return new ResultData(e.getErrorCode(), e.getMessage()); + } + ttCouponService.cancelCollect(memberId,id); + return new ResultData(); + } + + + @ApiOperation("关注") + @GetMapping("/followMerchant") + @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) + public ResultData followMerchant(@RequestParam Long id) { + logger.debug("[" + getIpAddr() + "] TtCouponController::followMerchant"); + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + WxMerchant byId = wxMerchantService.getById(id); + if(byId == null){ + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR,"找不到数据"); + } + Long memberId; + try { + memberId = getMemberId(); + } catch (MallinkException e) { + return new ResultData(e.getErrorCode(), e.getMessage()); + } + ttCouponService.followMerchant(getTenantInfo(),memberId,byId.getId()); + return new ResultData(); + } + + @ApiOperation("取消关注") + @GetMapping("/cancelFollow") + @ApiImplicitParam(name = "id", value = "id", dataType = "Long", paramType = "query", required = true) + public ResultData cancelFollow(@RequestParam Long id) { + logger.debug("[" + getIpAddr() + "] TtCouponController::cancelFollow"); + if (id == null) { + return new ResultData(ResultData.ERROR, "缺少id"); + } + Long memberId; + try { + memberId = getMemberId(); + } catch (MallinkException e) { + return new ResultData(e.getErrorCode(), e.getMessage()); + } + ttCouponService.cancelFollow(memberId,id); + return new ResultData(); + } + } diff --git a/mallinkTTCApi/src/main/java/com/iformall/controller/TtOrderController.java b/mallinkTTCApi/src/main/java/com/iformall/controller/TtOrderController.java index 7901cb2d6..cb0843a60 100644 --- a/mallinkTTCApi/src/main/java/com/iformall/controller/TtOrderController.java +++ b/mallinkTTCApi/src/main/java/com/iformall/controller/TtOrderController.java @@ -35,8 +35,6 @@ public class TtOrderController extends BaseController { @Autowired private WxAppinfoService wxAppinfoService; - @Autowired - private WxCUserBasicInfoService wxCUserBasicInfoService; @ApiOperation("分页订单列表接口") @GetMapping("list") From a300afab1c25d42c0a9f0fafd6d7cbf3b79361f0 Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 17:28:15 +0800 Subject: [PATCH 09/10] tt --- .../iformall/domain/po/tt/TtUpSettlein.java | 61 +++++++++++++ .../iformall/mapper/TtUpSettleinMapper.java | 13 +++ .../service/tt/impl/TtCouponServiceImpl.java | 3 +- .../main/resources/mapper/TtCUserMapper.xml | 13 +-- .../main/resources/mapper/TtOrderMapper.xml | 8 +- .../resources/mapper/TtUpSettleinMapper.xml | 90 +++++++++++++++++++ 6 files changed, 174 insertions(+), 14 deletions(-) create mode 100644 mallinkService/src/main/java/com/iformall/domain/po/tt/TtUpSettlein.java create mode 100644 mallinkService/src/main/java/com/iformall/mapper/TtUpSettleinMapper.java create mode 100644 mallinkService/src/main/resources/mapper/TtUpSettleinMapper.xml diff --git a/mallinkService/src/main/java/com/iformall/domain/po/tt/TtUpSettlein.java b/mallinkService/src/main/java/com/iformall/domain/po/tt/TtUpSettlein.java new file mode 100644 index 000000000..f3cd6b1f9 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/domain/po/tt/TtUpSettlein.java @@ -0,0 +1,61 @@ +package com.iformall.domain.po.tt; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.iformall.domain.po.base.TenantEntity; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.ToString; + +import java.util.Date; + +@TableName(value = "tt_up_settlein") +@Data +@ToString(callSuper = true) +@EqualsAndHashCode(callSuper = true) +public class TtUpSettlein extends TenantEntity { + + protected Long id; + + private Long cuserId; + + @io.swagger.annotations.ApiModelProperty(value="邀请码",name="invitationCode") + private String invitationCode; + @io.swagger.annotations.ApiModelProperty(value="联系人",name="liaisonMan") + private String liaisonMan; + @io.swagger.annotations.ApiModelProperty(value="联系电话",name="liaisonPhone") + private String liaisonPhone; + + @io.swagger.annotations.ApiModelProperty(value="抖音号",name="name") + private String ttUserName; + @io.swagger.annotations.ApiModelProperty(value="",name="ttCountFans") + private String ttCountFans; + + @io.swagger.annotations.ApiModelProperty(value="类型",name="bussinessTypes") + private String bussinessTypes; + + @io.swagger.annotations.ApiModelProperty(value="说明",name="explain") + private String explain; + + @io.swagger.annotations.ApiModelProperty(value = "处理状态0:未处理,1已处理", name = "handleStatus") + private Integer handleStatus; + @io.swagger.annotations.ApiModelProperty(value="备注",name="remark") + private String remark; + + @io.swagger.annotations.ApiModelProperty(value="创建时间",name="createDate") + private Date createDate; + @io.swagger.annotations.ApiModelProperty(value="更新时间",name="updateDate") + private Date updateDate; + + @io.swagger.annotations.ApiModelProperty(value = "是否删除1是0否", name = "isDel") + private Integer isDel; + + @TableField(exist = false) + @io.swagger.annotations.ApiModelProperty(value="查询-起始时间",name="startdate") + private Date startdate; + + @TableField(exist = false) + @io.swagger.annotations.ApiModelProperty(value="查询-结束时间",name="enddate") + private Date enddate; + +} diff --git a/mallinkService/src/main/java/com/iformall/mapper/TtUpSettleinMapper.java b/mallinkService/src/main/java/com/iformall/mapper/TtUpSettleinMapper.java new file mode 100644 index 000000000..77f9e4337 --- /dev/null +++ b/mallinkService/src/main/java/com/iformall/mapper/TtUpSettleinMapper.java @@ -0,0 +1,13 @@ +package com.iformall.mapper; + + +import com.iformall.common.CommonMapper; +import com.iformall.domain.po.tt.TtUpSettlein; + +import java.util.List; + +public interface TtUpSettleinMapper extends CommonMapper { + + List findList(TtUpSettlein record); + +} diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java index 6451dee0e..32d41671b 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java @@ -7,6 +7,7 @@ import com.github.pagehelper.PageInfo; import com.iformall.common.ErrorCode; import com.iformall.common.IdWorker; import com.iformall.common.ResultData; +import com.iformall.domain.po.WxMerchant; import com.iformall.domain.po.base.TenantEntity; import com.iformall.domain.po.tt.TtCoupon; import com.iformall.domain.po.tt.TtUserCollect; @@ -135,7 +136,7 @@ public class TtCouponServiceImpl implements TtCouponService { // WxMerchant author = wxMerchantService.getById(byId.getMerchantId()); // byId.setMerchantName(author.getName()); // byId.setMerchantPic(author.getImgUrl()); -// byId.setAuthor(wxMerchantService.getById(byId.getMerchantId())); + byId.setAuthor(wxMerchantService.getById(byId.getMerchantId())); if(byId.getType().equals(EnumTtCouponType.COUPON_COLUMN.getCode())){ TtCoupon couponQ = new TtCoupon(); couponQ.setColumnId(productId); diff --git a/mallinkService/src/main/resources/mapper/TtCUserMapper.xml b/mallinkService/src/main/resources/mapper/TtCUserMapper.xml index 28a889b18..2bc3c2e2b 100644 --- a/mallinkService/src/main/resources/mapper/TtCUserMapper.xml +++ b/mallinkService/src/main/resources/mapper/TtCUserMapper.xml @@ -150,12 +150,11 @@ and `score` = #{score} - - and `update_date` = #{updateDate} + + and `create_date` >= #{startdate} - - - and `create_date` = #{createDate} + + and `create_date` <= #{enddate} @@ -166,10 +165,6 @@ and `token` like concat('%', #{token},'%') - - and `expire_time` = #{expireTime} - - and `latitude` = #{latitude} diff --git a/mallinkService/src/main/resources/mapper/TtOrderMapper.xml b/mallinkService/src/main/resources/mapper/TtOrderMapper.xml index 5bfbf940b..9821b3635 100644 --- a/mallinkService/src/main/resources/mapper/TtOrderMapper.xml +++ b/mallinkService/src/main/resources/mapper/TtOrderMapper.xml @@ -108,19 +108,19 @@ order by o.`update_date` desc - select - from wx_order o + from tt_order o left join tt_c_user u on o.c_user_id = u.id left join tt_coupon c on o.product_id = c.id left join wx_merchant m on c.merchant_id = m.id - select count(1) - from wx_order + from tt_order where 1 = 1 and `tenant_id` = #{tenantId} diff --git a/mallinkService/src/main/resources/mapper/TtUpSettleinMapper.xml b/mallinkService/src/main/resources/mapper/TtUpSettleinMapper.xml new file mode 100644 index 000000000..79997028b --- /dev/null +++ b/mallinkService/src/main/resources/mapper/TtUpSettleinMapper.xml @@ -0,0 +1,90 @@ + + + + + + + + + + + + + + + + + + + + + + + + `id`,`tenant_id`,`parent_tenant_id`,`cuser_id`,`invitation_code`,`liaison_man`,`liaison_phone`, + `tt_user_name`,`tt_count_fans`,`bussiness_types`,`explain`, + `remark`,`handle_status`,`create_date`,`update_date` + + + + where `is_del` = 0 + + + and `id` = #{id} + + + + and `tenant_id` = #{tenantId} + + + and `parent_tenant_id` = #{parentTenantId} + + + + and `cuser_id` = #{cuserId} + + + + and `invitation_code` = #{invitationCode} + + + + and `liaison_man` like concat('%', #{liaisonMan},'%') + + + + and `liaison_phone` like concat('%', #{liaisonPhone},'%') + + + + and `tt_user_name` like concat('%', #{ttUserName},'%') + + + + and `handle_status` = #{handleStatus} + + + + and `create_date` >= #{startdate} + + + and `create_date` <= #{enddate} + + + + and `id` in + + #{idItem} + + + order by ${sortColumns} + + + + + From 6976fc68aecc7d48f68808485194abbd6c9e785b Mon Sep 17 00:00:00 2001 From: xhxu Date: Mon, 24 May 2021 18:19:21 +0800 Subject: [PATCH 10/10] tt --- .../com/iformall/service/tt/impl/TtCouponServiceImpl.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java index 32d41671b..e9a8abc68 100644 --- a/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/tt/impl/TtCouponServiceImpl.java @@ -16,7 +16,6 @@ import com.iformall.enums.EnumTtCouponStatus; import com.iformall.enums.EnumTtCouponType; import com.iformall.enums.EnumYesOrNo; import com.iformall.mapper.*; -import com.iformall.service.WxMerchantService; import com.iformall.service.tt.TtCouponService; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; @@ -39,7 +38,7 @@ public class TtCouponServiceImpl implements TtCouponService { TtCouponMapper ttCouponMapper; @Autowired - WxMerchantService wxMerchantService; + WxMerchantMapper wxMerchantMapper; @Autowired TtUserCollectMapper ttUserCollectMapper; @@ -133,10 +132,11 @@ public class TtCouponServiceImpl implements TtCouponService { if(byId == null){ return byId; } -// WxMerchant author = wxMerchantService.getById(byId.getMerchantId()); +// WxMerchant author = wxMerchantMapper.selectById(byId.getMerchantId()); // byId.setMerchantName(author.getName()); // byId.setMerchantPic(author.getImgUrl()); - byId.setAuthor(wxMerchantService.getById(byId.getMerchantId())); + + byId.setAuthor(wxMerchantMapper.selectById(byId.getMerchantId())); if(byId.getType().equals(EnumTtCouponType.COUPON_COLUMN.getCode())){ TtCoupon couponQ = new TtCoupon(); couponQ.setColumnId(productId);