From e7927865072c261525271cad44569b911462dd40 Mon Sep 17 00:00:00 2001 From: xhxu Date: Tue, 6 Sep 2022 11:30:08 +0800 Subject: [PATCH 1/4] =?UTF-8?q?//=20=E5=88=86=E8=B4=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/iformall/service/impl/WxOrderServiceImpl.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java index 83631f404..41a2104de 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java @@ -2601,13 +2601,14 @@ public class WxOrderServiceImpl implements WxOrderService { sharingOrder.updateTenantInfo(wxPayOrder); sharingOrder.setTransactionId(wxPayOrder.getTransactionId()); wxProfitSharingOrderService.createSharingOrder(sharingOrder,wxPayOrder); - - + } else { logger.error("微信分账: 未找到payorder or merchant at orderid-" + orderId); } } catch (MallinkException e) { logger.error("微信分账: " + e.getMessage(),e); + } catch (Exception e){ + logger.error("微信分账"+e.getMessage(),e); } } From 1580abd51ee0a6dad3f427bf3560abb8eb541ef5 Mon Sep 17 00:00:00 2001 From: xhxu Date: Tue, 6 Sep 2022 11:43:51 +0800 Subject: [PATCH 2/4] =?UTF-8?q?//=20=E5=88=86=E8=B4=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/iformall/service/impl/WxOrderServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java index 41a2104de..5d987703c 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxOrderServiceImpl.java @@ -2588,7 +2588,7 @@ public class WxOrderServiceImpl implements WxOrderService { sharingOrder.setMerchantId(wxMerchantBUser.getMerchantId()); sharingOrder.setType(EnumProfitSharingOrderType.PROFIT_SHARING_SINGLE.getCode()); sharingOrder.setPayAmount(wxPayOrder.getPayAmount()); - WxComposeChildOrderShare share = wxPayOrder.getChildOrderShare(orderId); + WxComposeChildOrderShare share = wxPayOrder.getChildOrderShare(wxOrder.getId()); sharingOrder.setMerchantShareAmount(share.getShareAmount()); sharingOrder.setMallRealRateAmount(share.getRateAmount()); sharingOrder.setRealRateAmount(share.getRealRateAmount()); From 15aab75a2491e58e0f43bfd50d232a7640a8e800 Mon Sep 17 00:00:00 2001 From: xhxu Date: Tue, 6 Sep 2022 13:55:00 +0800 Subject: [PATCH 3/4] =?UTF-8?q?//=20=E5=88=86=E8=B4=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/pay/service/share/douyin/TtPayShareService.java | 3 ++- .../service/pay/service/share/wx/v2/WxPayShareService.java | 3 ++- .../pay/service/share/wx/v3/WxPayShareV3Service.java | 6 +++--- 3 files changed, 7 insertions(+), 5 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/share/douyin/TtPayShareService.java b/mallinkService/src/main/java/com/iformall/service/pay/service/share/douyin/TtPayShareService.java index 039541c0e..bd94ef3ad 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/share/douyin/TtPayShareService.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/share/douyin/TtPayShareService.java @@ -442,7 +442,8 @@ public class TtPayShareService extends PayShareBaseAdapterService{ List list = wxProfitSharingReceiverMapper.findList(psReceiverQ); if(list == null || list.isEmpty()){ - throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_INVALID.getCode(),"该商户未未进件."+payMsg); + return null; +// throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_INVALID.getCode(),"该商户未未进件."+payMsg); } if(list.size() > 1){ throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_UNKNOWN.getCode(),"该商户分账帐号异常."); diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v2/WxPayShareService.java b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v2/WxPayShareService.java index 2b9295262..353e49ab2 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v2/WxPayShareService.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v2/WxPayShareService.java @@ -405,7 +405,8 @@ public class WxPayShareService extends PayShareBaseAdapterService{ psReceiverQ.setPlat(EnumAppPlat.WX.getCode()); List psReceiverList = wxProfitSharingReceiverMapper.findList(psReceiverQ); if (null == psReceiverList || psReceiverList.size() == 0) { - throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_INVALID.getCode(),"该商户未设置分账账号."); + return null; +// throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_INVALID.getCode(),"该商户未设置分账账号."); }else { for (WxProfitSharingReceiver receiver:psReceiverList) { if (EnumProfitSharingReceiverType.PROFIT_SHARING_RECEIVER_PERSONAL_WECHATID.getCode().intValue() diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java index 16f9c61ec..f18c91537 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/v3/WxPayShareV3Service.java @@ -149,9 +149,9 @@ public class WxPayShareV3Service extends PayShareBaseAdapterService{ }else if (EnumPayMchType.TOTAL.getCode() == mchType) { receiver = wxProfitSharingReceiverService.findReceiver(tenantEntity, merchantId,EnumAppPlat.WX,EnumProfitSharingType.PROFIT_SHARING_TYPE_WECHAT); } - if (null == receiver) { - throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_INVALID.getCode(),"该商户未设置分账账号."); - } +// if (null == receiver) { +// throw new MallinkException(ErrorCode.PROFIT_SHARING_RECEIVER_INVALID.getCode(),"该商户未设置分账账号."); +// } return receiver; } From 050bd6149a18589db0aa2e49727baf06fd8e0e85 Mon Sep 17 00:00:00 2001 From: zhengfangyuan Date: Tue, 6 Sep 2022 15:15:09 +0800 Subject: [PATCH 4/4] fix bug --- .../market/WxPressBatchController.java | 11 +++++++++++ .../iformall/service/WxPressBatchService.java | 2 ++ .../service/impl/WxPressBatchServiceImpl.java | 17 +++++++++++++++-- .../resources/mapper/WxPressBatchItemMapper.xml | 2 +- 4 files changed, 29 insertions(+), 3 deletions(-) diff --git a/mallinkAdmin/src/main/java/com/iformall/controller/market/WxPressBatchController.java b/mallinkAdmin/src/main/java/com/iformall/controller/market/WxPressBatchController.java index 7ae3ace2b..141253078 100644 --- a/mallinkAdmin/src/main/java/com/iformall/controller/market/WxPressBatchController.java +++ b/mallinkAdmin/src/main/java/com/iformall/controller/market/WxPressBatchController.java @@ -134,6 +134,17 @@ public class WxPressBatchController extends BaseController { wxPressBatchService.deleteItemById(record.getId(), getTenantInfo().getTenantId()); return new ResultData(); } + + @ApiOperation("详情接口") + @PostMapping("updateStatus") + public ResultData updateStatus(@RequestBody WxPressBatch record) { + if (null == record.getId() || null == record.getStatus()) { + return new ResultData(Result.ERROR,"参数错误"); + } + record.updateTenantInfo(getTenantInfo()); + wxPressBatchService.updateStatus(record); + return new ResultData(); + } diff --git a/mallinkService/src/main/java/com/iformall/service/WxPressBatchService.java b/mallinkService/src/main/java/com/iformall/service/WxPressBatchService.java index c44102679..970a2629c 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxPressBatchService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxPressBatchService.java @@ -47,6 +47,8 @@ public interface WxPressBatchService { void deleteItemById(Long itemId,String tenantId); void deleteItemByBatchId(Long batchId,String tenantId); + void updateStatus(WxPressBatch pressBatch); + //验证砍价人规则 ResultData checkBargainerPressBatchRule(WxOrder order, Long cUserId); diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxPressBatchServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxPressBatchServiceImpl.java index 267eb4072..bd7cfa1bb 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxPressBatchServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxPressBatchServiceImpl.java @@ -4,6 +4,7 @@ import com.aliyun.openservices.shade.org.apache.commons.lang3.StringUtils; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; +import com.iformall.common.IdWorker; import com.iformall.common.Result; import com.iformall.common.ResultData; import com.iformall.domain.po.*; @@ -69,6 +70,8 @@ public class WxPressBatchServiceImpl implements WxPressBatchService { @Override public void saveOrUpdate(WxPressBatch record) { if (null == record.getId()) { + final IdWorker idWorker = IdWorker.get(); + record.setId(idWorker.nextId()); record.setCreateDate(new Date()); record.setUpdateDate(new Date()); wxPressBatchMapper.insert(record); @@ -106,8 +109,8 @@ public class WxPressBatchServiceImpl implements WxPressBatchService { } } - @Override @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) + @Override public void deleteBatch(Long id, String tenantId) { wxPressBatchMapper.deleteById(id, tenantId); deleteItemByBatchId(id, tenantId); @@ -128,6 +131,17 @@ public class WxPressBatchServiceImpl implements WxPressBatchService { iteq.setPressBatchId(batchId); wxPressBatchItemMapper.deleteAllItem(iteq); } + + @Transactional(propagation = Propagation.REQUIRED, readOnly = false, rollbackFor = {Exception.class}) + @Override + public void updateStatus(WxPressBatch pressBatch) { + wxPressBatchMapper.updateWxPressBatchStatus(pressBatch); + WxPressBatchItem item = new WxPressBatchItem(); + item.updateTenantInfo(pressBatch); + item.setPressBatchId(pressBatch.getId()); + item.setPressBatchStatus(pressBatch.getStatus()); + wxPressBatchItemMapper.updateWxPressBatchStatus(item); + } @Override public ResultData checkBargainerPressBatchRule(WxOrder order, Long cUserId) { @@ -202,5 +216,4 @@ public class WxPressBatchServiceImpl implements WxPressBatchService { } return null; } - } diff --git a/mallinkService/src/main/resources/mapper/WxPressBatchItemMapper.xml b/mallinkService/src/main/resources/mapper/WxPressBatchItemMapper.xml index 29ff0ef35..b3121f7d1 100644 --- a/mallinkService/src/main/resources/mapper/WxPressBatchItemMapper.xml +++ b/mallinkService/src/main/resources/mapper/WxPressBatchItemMapper.xml @@ -79,7 +79,7 @@ - update wx_press_batch_item set press_batch_status = #{status} where `press_batch_id` = #{pressBatchId} and tenant_id=#{tenantId} + update wx_press_batch_item set press_batch_status = #{pressBatchStatus} where `press_batch_id` = #{pressBatchId} and tenant_id=#{tenantId}