From b5e9de29cb94b4f654573060146285d55c04f17e Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 11 May 2022 15:42:03 +0800 Subject: [PATCH 1/5] //update push --- .../douyin/miniApp/TtMiniAppPayAdapterService.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java b/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java index 52296242a..28c2e97e6 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.iformall.domain.po.*; +import com.iformall.domain.vo.WxMerchantVo; import com.iformall.domain.vo.WxOrderCouponVo; import com.iformall.douyin.miniapp.api.TtMaService; import com.iformall.douyin.pay.DouYinPayHelper; @@ -29,6 +30,8 @@ import org.springframework.stereotype.Service; import java.io.File; import java.util.*; +import static java.util.stream.Collectors.toList; + @Slf4j @Service public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implements CDrivingPayService{ @@ -117,6 +120,7 @@ public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implemen } //目前订单都是一笔一笔同步,暂不支持购物车 WxOrderCouponVo wxOrderCouponVo = batchOrder.getOrders().get(0); + List merchantList = wxOrderCouponVo.getMerchantVoList().stream().sorted(Comparator.comparing(m -> m.getTtPoi(), Comparator.nullsLast(String::compareTo))).collect(toList()); TtMaService ttappService = maUtil.getTtMaService(appInfo); // map.put("access_token",appInfo.getAccessToken());//后面会自动加上 @@ -126,7 +130,7 @@ public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implemen map.put("payment_order_no", payOrder.getTransactionId()); if(isPoiOrder){ map.put("client_key",clientKey);//第三方在开放平台申请的 ClientKey(生活服务订单必传) - map.put("ext_shop_id",wxOrderCouponVo.getMerchantVoList().get(0).getId());//生活服务外部商户 id,购买店铺 id (生活服务订单必传) + map.put("ext_shop_id",merchantList.get(0).getId().toString());//生活服务外部商户 id,购买店铺 id (生活服务订单必传) map.put("order_type",9101); }else{ map.put("order_type",0); @@ -142,7 +146,7 @@ public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implemen if(isPoiOrder){ orderDetail.put("ext_order_id",payOrder.getPayOrderNo()); orderDetail.put("status", getTtPoiOrderStatus(wxOrderCouponVo.getOrderStatus(),wxOrderCouponVo.getCouponOrderStatus()).getCode()); - orderDetail.put("shop_name",wxOrderCouponVo.getMerchantVoList().get(0).getMerchantName()); + orderDetail.put("shop_name",merchantList.get(0).getMerchantName()); orderDetail.put("entry_type",2); orderDetail.put("entry_schema",getOrderEntrySchema(appInfo.getAppId(),batchOrder.getId())); orderDetail.put("create_order_time",batchOrder.getCreateDate().getTime()); @@ -153,13 +157,13 @@ public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implemen } if(EnumCouponOrderStatus.COUPON_ORDER_USED.getCode().equals(wxOrderCouponVo.getCouponOrderStatus()) && wxOrderCouponVo.getBMerchantId() != null){ - orderDetail.put("ext_valid_shop_id",wxOrderCouponVo.getBMerchantId()); + orderDetail.put("ext_valid_shop_id",wxOrderCouponVo.getBMerchantId().toString()); TtMerchantPoi merchantPoi = ttMerchantPoiMapper.selectById(wxOrderCouponVo.getBMerchantId()); if(merchantPoi != null){ orderDetail.put("valid_poi_id_str",merchantPoi.getPoiId()); } } - orderDetail.put("ext_goods_id",wxOrderCouponVo.getCouponChannelId()); + orderDetail.put("ext_goods_id",wxOrderCouponVo.getCouponChannelId().toString()); orderDetail.put("goods_name",wxOrderCouponVo.getTitle()); // orderDetail.put("goods_info","");//商品描述信息。向用户介绍商品,最多120字。 orderDetail.put("goods_cover_image",wxOrderCouponVo.getCoverImg()); From 67287c76b3dd3a6d983b7066139c2b2db897d60f Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 11 May 2022 15:44:53 +0800 Subject: [PATCH 2/5] //update push --- .../pay/douyin/miniApp/TtMiniAppPayAdapterService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java b/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java index 28c2e97e6..c698ab0af 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java @@ -120,8 +120,8 @@ public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implemen } //目前订单都是一笔一笔同步,暂不支持购物车 WxOrderCouponVo wxOrderCouponVo = batchOrder.getOrders().get(0); - List merchantList = wxOrderCouponVo.getMerchantVoList().stream().sorted(Comparator.comparing(m -> m.getTtPoi(), Comparator.nullsLast(String::compareTo))).collect(toList()); - +// List merchantList = wxOrderCouponVo.getMerchantVoList().stream().sorted(Comparator.comparing(m -> m.getTtPoi(), Comparator.nullsLast(String::compareTo))).collect(toList()); + List merchantList = wxOrderCouponVo.getMerchantVoList(); TtMaService ttappService = maUtil.getTtMaService(appInfo); // map.put("access_token",appInfo.getAccessToken());//后面会自动加上 Map map = new HashMap<>(); From e5993a5cb5741a89baee7d65fd8c57cc559138ec Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 11 May 2022 16:17:25 +0800 Subject: [PATCH 3/5] //update poi --- .../controller/WxCouponController.java | 33 +++++++++++++++++++ .../com/iformall/domain/po/WxMerchant.java | 4 +++ .../com/iformall/domain/vo/WxMerchantVo.java | 5 +++ .../web/api/impl/TtWebProductServiceImpl.java | 9 +++-- .../com/iformall/service/WxCouponService.java | 3 ++ .../impl/TtMerchantPoiServiceImpl.java | 6 ++-- .../service/impl/WxCouponServiceImpl.java | 24 ++++++++++++-- .../service/impl/WxMerchantServiceImpl.java | 4 +++ .../miniApp/TtMiniAppPayAdapterService.java | 4 +-- .../java/com/iformall/utils/Constant.java | 3 ++ 10 files changed, 86 insertions(+), 9 deletions(-) diff --git a/mallinkCApi/src/main/java/com/iformall/controller/WxCouponController.java b/mallinkCApi/src/main/java/com/iformall/controller/WxCouponController.java index 5e1f83a65..16097f9e9 100644 --- a/mallinkCApi/src/main/java/com/iformall/controller/WxCouponController.java +++ b/mallinkCApi/src/main/java/com/iformall/controller/WxCouponController.java @@ -7,7 +7,10 @@ import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; +import com.iformall.domain.po.WxMerchant; +import com.iformall.domain.po.WxMiniappThemeValue; import com.iformall.enums.EnumCouponType; +import com.iformall.utils.RedisCacheUtils; import org.apache.commons.beanutils.BeanUtils; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; @@ -56,6 +59,10 @@ public class WxCouponController extends BaseController { @Qualifier("couponDetailRedisTemplate") RedisTemplate cdRedisTemplate; + @Autowired + @Qualifier("objectCommonRedisTemplate") + RedisTemplate objectCommonRedisTemplate; + @ApiOperation("根据id(couponChannel)查询接口") @GetMapping("/detail") @ApiImplicitParams({ @@ -201,6 +208,32 @@ public class WxCouponController extends BaseController { return new ResultData(wxCouponCVo); } + +// @ApiOperation("根据id(couponId)查询接口") +// @GetMapping("/getMerchantList") +// @ApiImplicitParams({ +// @ApiImplicitParam(name = "couponId", value = "couponId", dataType = "String", paramType = "query", required = true) +// }) +// public ResultData getMerchantList(Long couponId) { +// +// if (couponId == null) { +// return new ResultData(ErrorCode.SYS_PARAMETER_NOT_NULL); +// } +// +// String key = Constant.coupon_merchants_key+getTenantInfo().getTenantId()+":"+couponId; +// +// List valueList = RedisCacheUtils.getCacheListObject(objectCommonRedisTemplate, key, WxMerchantVo.class); +// if(valueList != null && valueList.size() > 0){ +// return new ResultData(valueList); +// } +// valueList = couponService.getCouponMerchantList(getTenantInfo(),couponId); +// if(valueList == null || valueList.size() == 0){ +// return new ResultData(ErrorCode.SYS_PARAMETER_ERROR); +// } +// +// RedisCacheUtils.cache(objectCommonRedisTemplate,key,valueList,3600l); +// return new ResultData(valueList); +// } private WxCouponCVo generateWxCouponCVo(Long couponChannelIdL,String tenantId) { WxCouponChannel cc = wxCouponChannelService.getById(couponChannelIdL,tenantId); diff --git a/mallinkService/src/main/java/com/iformall/domain/po/WxMerchant.java b/mallinkService/src/main/java/com/iformall/domain/po/WxMerchant.java index b26ca9f64..413c1d7f6 100644 --- a/mallinkService/src/main/java/com/iformall/domain/po/WxMerchant.java +++ b/mallinkService/src/main/java/com/iformall/domain/po/WxMerchant.java @@ -346,6 +346,10 @@ public class WxMerchant extends TenantEntity { @TableField(exist = false) private String addr; + @io.swagger.annotations.ApiModelProperty(value="ttPoi",name="ttPoi") + @TableField(exist = false) + private String ttPoi; + @io.swagger.annotations.ApiModelProperty(value="经度",name="longitude") @TableField(exist = false) private BigDecimal longitude; diff --git a/mallinkService/src/main/java/com/iformall/domain/vo/WxMerchantVo.java b/mallinkService/src/main/java/com/iformall/domain/vo/WxMerchantVo.java index 99b3a4a6d..9d62e49f4 100644 --- a/mallinkService/src/main/java/com/iformall/domain/vo/WxMerchantVo.java +++ b/mallinkService/src/main/java/com/iformall/domain/vo/WxMerchantVo.java @@ -101,6 +101,10 @@ public class WxMerchantVo extends TenantEntity { @io.swagger.annotations.ApiModelProperty(value = "置顶时间", name = "topTime") private Date topTime; + @io.swagger.annotations.ApiModelProperty(value="ttPoi",name="ttPoi") + @TableField(exist = false) + private String ttPoi; + @io.swagger.annotations.ApiModelProperty(value="经度",name="longitude") @TableField(exist = false) private BigDecimal longitude; @@ -128,6 +132,7 @@ public class WxMerchantVo extends TenantEntity { this.linkLinePhone = m.getLinkLinePhone(); this.topTime = m.getTopTime(); this.addr = m.getAddr(); + this.ttPoi = m.getTtPoi(); this.longitude = m.getLongitude(); this.latitude = m.getLatitude(); } diff --git a/mallinkService/src/main/java/com/iformall/douyin/web/api/impl/TtWebProductServiceImpl.java b/mallinkService/src/main/java/com/iformall/douyin/web/api/impl/TtWebProductServiceImpl.java index c2b68ac9f..925f79660 100644 --- a/mallinkService/src/main/java/com/iformall/douyin/web/api/impl/TtWebProductServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/douyin/web/api/impl/TtWebProductServiceImpl.java @@ -76,10 +76,15 @@ public class TtWebProductServiceImpl implements TtWebProductService { String apiUrl = this.service.getTtWebConfig().getApiBegin().getPrefix() + this.POST_SPU_STOCK_UPDATE; String result = this.service.execute(executor, apiUrl, spuStockSync.toJson()); JSONObject jsonObject = JSONObject.parseObject(result); - String spuExtId = jsonObject.getString("spu_ext_id"); - if(spuStockSync.getSpuExtId().equals(spuExtId)){ + Integer error_code = jsonObject.getInteger("error_code"); + if(error_code.intValue() == 0){ return true; } + +// String spuExtId = jsonObject.getString("spu_ext_id"); +// if(spuStockSync.getSpuExtId().equals(spuExtId)){ +// return true; +// } return false; } } diff --git a/mallinkService/src/main/java/com/iformall/service/WxCouponService.java b/mallinkService/src/main/java/com/iformall/service/WxCouponService.java index ce9f5cb7f..50d54cfb1 100644 --- a/mallinkService/src/main/java/com/iformall/service/WxCouponService.java +++ b/mallinkService/src/main/java/com/iformall/service/WxCouponService.java @@ -11,6 +11,7 @@ import com.iformall.domain.po.WxCoupon; import com.iformall.domain.po.base.TenantEntity; import com.iformall.domain.vo.WxCouponCVo; import com.iformall.domain.vo.WxCouponStatisVo; +import com.iformall.domain.vo.WxMerchantVo; public interface WxCouponService { @@ -261,4 +262,6 @@ public interface WxCouponService { Map getCouponMerchantMap(List couponIds,TenantEntity tenantEntity,boolean onlyOneMerchantCoupons); Map getCouponMap(List couponIds, TenantEntity tenantEntity); + + List getCouponMerchantList(TenantEntity tenantInfo, Long couponId); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/TtMerchantPoiServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/TtMerchantPoiServiceImpl.java index 65a71a0aa..4490a9dfa 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/TtMerchantPoiServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/TtMerchantPoiServiceImpl.java @@ -593,11 +593,11 @@ public class TtMerchantPoiServiceImpl implements TtMerchantPoiService { poi.setSyncStatus(EnumSupplierSyncStatus.sync_success.getCode()); List poiList = ttMerchantPoiMapper.findList(poi); if(poiList == null || poiList.isEmpty()){ - return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),"未查询到可用poi"); + return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),"未查询到匹配的poi"); } - List collect = poiList.stream().map(p -> p.getId()).collect(Collectors.toList()); +// List collect = poiList.stream().map(p -> p.getId()).collect(Collectors.toList()); - String spuId = spuSync(coupon,couponChannel,collect); + String spuId = spuSync(coupon,couponChannel,couponMerchantIds); if(StringUtils.isBlank(spuId)){ return new ResultData(ErrorCode.SYS_PARAMETER_ERROR.getCode(),"同步失败"); } diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java index a832cafeb..036e7376a 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java @@ -48,6 +48,8 @@ import java.util.stream.Collectors; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; +import static java.util.stream.Collectors.toList; + @Service public class WxCouponServiceImpl implements WxCouponService { @@ -154,7 +156,7 @@ public class WxCouponServiceImpl implements WxCouponService { return new ResultData(page); } - List ids = wxCouponList.stream().map(p -> p.getId()).collect(Collectors.toList()); + List ids = wxCouponList.stream().map(p -> p.getId()).collect(toList()); WxCouponChannel wxCouponChannel = new WxCouponChannel(); wxCouponChannel.updateTenantInfo(wxCoupon); wxCouponChannel.setCouponIds(ids); @@ -249,7 +251,7 @@ public class WxCouponServiceImpl implements WxCouponService { if (merchantList != null) { merchantList = merchantList.stream().filter( m->m.getMerchantStatus().equals(EnumMerchantStatus.VALID.getCode())) - .collect(Collectors.toList()); + .collect(toList()); } wxCouponCVo.setMerchantVoList(merchantList); if(EnumCouponType.COUPON_GIFT.getCode().equals(wxCouponCVo.getType())){ @@ -1101,5 +1103,23 @@ public class WxCouponServiceImpl implements WxCouponService { return couponMap; } + @Override + public List getCouponMerchantList(TenantEntity tenantInfo, Long couponId) { + List couponIdList = new ArrayList(); + couponIdList.add(couponId); + Map> couponMerchantVoMap = wxMerchantService.findCouponMerchantVoList(couponIdList, tenantInfo,true); + + List merchantList = couponMerchantVoMap.get(couponId); + if (merchantList != null) { + + merchantList = merchantList.stream().sorted(Comparator.comparing(m -> m.getTtPoi(), Comparator.nullsLast(String::compareTo))).collect(toList()); + + merchantList = merchantList.stream().filter( + m->m.getMerchantStatus().equals(EnumMerchantStatus.VALID.getCode())) + .collect(toList()); + } + return merchantList; + } + } 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 9576c7413..20376b7a5 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java @@ -1251,6 +1251,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { TtMerchantPoi poi = poiMap.get(m.getId()); if(null != poi){ m.setAddr(poi.getAddress()); + m.setTtPoi(poi.getPoiId()); m.setLongitude(poi.getLongitude()); m.setLatitude(poi.getLatitude()); } @@ -1318,6 +1319,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { vo.setShopVoList(merchantShopVoList.get(vo.getId())); } vo.setAddr(m.getAddr()); + vo.setTtPoi(m.getTtPoi()); vo.setLongitude(m.getLongitude()); vo.setLatitude(m.getLatitude()); return vo; @@ -1630,6 +1632,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { TtMerchantPoi poi = poiMap.get(m.getId()); if(null != poi){ m.setAddr(poi.getAddress()); + m.setTtPoi(poi.getPoiId()); m.setLongitude(poi.getLongitude()); m.setLatitude(poi.getLatitude()); } @@ -1654,6 +1657,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { vo.setId(m.getId()); vo.setAddr(m.getAddr()); + vo.setTtPoi(m.getTtPoi()); vo.setLongitude(m.getLongitude()); vo.setLatitude(m.getLatitude()); vo.setMerchantImgUrl(m.getImgUrl()); diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java b/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java index c698ab0af..28c2e97e6 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/pay/douyin/miniApp/TtMiniAppPayAdapterService.java @@ -120,8 +120,8 @@ public class TtMiniAppPayAdapterService extends BaseTtPayAdapterService implemen } //目前订单都是一笔一笔同步,暂不支持购物车 WxOrderCouponVo wxOrderCouponVo = batchOrder.getOrders().get(0); -// List merchantList = wxOrderCouponVo.getMerchantVoList().stream().sorted(Comparator.comparing(m -> m.getTtPoi(), Comparator.nullsLast(String::compareTo))).collect(toList()); - List merchantList = wxOrderCouponVo.getMerchantVoList(); + List merchantList = wxOrderCouponVo.getMerchantVoList().stream().sorted(Comparator.comparing(m -> m.getTtPoi(), Comparator.nullsLast(String::compareTo))).collect(toList()); + TtMaService ttappService = maUtil.getTtMaService(appInfo); // map.put("access_token",appInfo.getAccessToken());//后面会自动加上 Map map = new HashMap<>(); diff --git a/mallinkService/src/main/java/com/iformall/utils/Constant.java b/mallinkService/src/main/java/com/iformall/utils/Constant.java index 03acec2cc..c1ad6fbe3 100644 --- a/mallinkService/src/main/java/com/iformall/utils/Constant.java +++ b/mallinkService/src/main/java/com/iformall/utils/Constant.java @@ -85,6 +85,9 @@ public class Constant { public static final String importMemPrev = "importmem:"; public static final String importInvestCustomerPrev = "importinvestcustomer:"; + //商品门店 + public static final String coupon_merchants_key = "coupon:merchants:"; + //限制接口访问次数 public static final String INTERFACE_VISIT_LIMIT_KEY = "INTERFACE:LIMIT:"; From b086658873b6e58a59d7628883bd3a13893e3219 Mon Sep 17 00:00:00 2001 From: xhxu Date: Wed, 11 May 2022 17:54:29 +0800 Subject: [PATCH 4/5] //update merchantlist --- .../com/iformall/service/impl/WxMerchantServiceImpl.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) 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 20376b7a5..5eb3ac0fd 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxMerchantServiceImpl.java @@ -1011,7 +1011,11 @@ public class WxMerchantServiceImpl implements WxMerchantService { Long floor = record.getFloor(); List floorMerchantIds = getFloorBuildMerchantIds(record, floorRule, building, floor, 0, 0); if (null != floorMerchantIds) { - merchantIds.retainAll(floorMerchantIds); + if(merchantIds.size() > 0){ + merchantIds.retainAll(floorMerchantIds); + }else{ + merchantIds.addAll(floorMerchantIds); + } } if (merchantIds.size() > 0 ) { record.setIds(merchantIds); @@ -1065,6 +1069,7 @@ public class WxMerchantServiceImpl implements WxMerchantService { floorMerchantIds.add(-999L); return floorMerchantIds; } + return floorMerchantIds; } return null; } From 401ad675eaa4872ad76a15748a9f171eeda3b29f Mon Sep 17 00:00:00 2001 From: winter Date: Thu, 12 May 2022 19:49:56 +0800 Subject: [PATCH 5/5] =?UTF-8?q?fix=20=E5=BE=AE=E4=BF=A1=E5=88=86=E8=B4=A6?= =?UTF-8?q?=E5=AE=8C=E7=BB=93bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../schedule/CouponOrderExpiringSchedule.java | 16 ++++++++-------- .../pay/service/share/wx/WxPayShareService.java | 2 +- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java index 11f15e373..a4d39e6f8 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/CouponOrderExpiringSchedule.java @@ -215,14 +215,14 @@ public class CouponOrderExpiringSchedule { wxSharingOrderDto.setPayTimeEnd(wxPayOrder.getPayTimeEnd()); wxSharingOrderDto.updateTenantInfo(wxPayOrder); wxSharingOrderDto.setTransactionId(wxPayOrder.getTransactionId()); -// if (wxPayOrder.getChildOrderShare(co.getOrderId()).getRateAmount() != null) { -// // 实际分账金额为 分账金额 + 通道费差 -// wxSharingOrderDto.setShareAmount(wxPayOrder.getChildOrderShare(co.getOrderId()).getShareAmount()+wxPayOrder.getChildOrderShare(co.getOrderId()).getRateAmount()); -// } else { -// // 未设置通道费差 -// wxSharingOrderDto.setShareAmount(wxPayOrder.getChildOrderShare(co.getOrderId()).getShareAmount()); -// } - wxSharingOrderDto.setShareAmount(wxPayOrder.getPayAmount()); + if (wxPayOrder.getChildOrderShare(co.getOrderId()).getRateAmount() != null) { + // 实际分账金额为 分账金额 + 通道费差 + wxSharingOrderDto.setShareAmount(wxPayOrder.getChildOrderShare(co.getOrderId()).getShareAmount()+wxPayOrder.getChildOrderShare(co.getOrderId()).getRateAmount()); + } else { + // 未设置通道费差 + wxSharingOrderDto.setShareAmount(wxPayOrder.getChildOrderShare(co.getOrderId()).getShareAmount()); + } + //wxSharingOrderDto.setShareAmount(wxPayOrder.getPayAmount()); wxProfitSharingOrderService.finishSharingOrder(wxSharingOrderDto,wxPayOrder.getPayVendor(),wxPayOrder.getShare()); } diff --git a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/WxPayShareService.java b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/WxPayShareService.java index f7423dcf9..f257d481a 100644 --- a/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/WxPayShareService.java +++ b/mallinkService/src/main/java/com/iformall/service/pay/service/share/wx/WxPayShareService.java @@ -82,7 +82,7 @@ public class WxPayShareService extends PayShareBaseAdapterService{ psFCmd.setNonce_str(Utility.generate32UUID()); psFCmd.setTransaction_id(transcationId); psFCmd.setOut_order_no(record.getId().toString()); - psFCmd.setAmount(amount); + //psFCmd.setAmount(amount); psFCmd.setDescription("分账已完结"); psFCmd.setSign_type("HMAC-SHA256");