分账失败后,写入日志

This commit is contained in:
Jack 2025-06-24 23:02:46 +08:00
parent 7adbd801cd
commit cf2605ae64
5 changed files with 47 additions and 10 deletions

View File

@ -88,6 +88,9 @@ public class LklOrderSeparate {
@ApiModelProperty(value = "处理状态ACCEPTED-已受理, PROCESSING-处理中, FAIL-失败, SUCCESS-成功") @ApiModelProperty(value = "处理状态ACCEPTED-已受理, PROCESSING-处理中, FAIL-失败, SUCCESS-成功")
private String final_status; private String final_status;
@ApiModelProperty(value = "分账(失败后)的标记")
private String remark;
@ApiModelProperty(value = "新建时间") @ApiModelProperty(value = "新建时间")
private Date created_at; private Date created_at;

View File

@ -29,4 +29,13 @@ public interface LklOrderSeparateService extends IBaseService<LklOrderSeparate>
* @return * @return
*/ */
LklOrderSeparate getByOutTradeNo(String logNo, String outSeparateNo); LklOrderSeparate getByOutTradeNo(String logNo, String outSeparateNo);
/**
* 修改备注
*
* @param id
* @param remark
* @return
*/
Boolean updateRemark(Long id, String remark);
} }

View File

@ -1601,6 +1601,7 @@ public class LakalaApiServiceImpl implements LakalaApiService {
String errorMsg = String.format("店铺[%s]订单金额异常或运费过高,跳过分账", shopOrderLkl.getStore_id()); String errorMsg = String.format("店铺[%s]订单金额异常或运费过高,跳过分账", shopOrderLkl.getStore_id());
log.error(errorMsg); log.error(errorMsg);
errorMessages.append(errorMsg).append("; "); errorMessages.append(errorMsg).append("; ");
lklOrderSeparateService.updateRemark(lklOrderSeparateExist.getId(), errorMsg);
continue; continue;
} }
@ -1612,13 +1613,16 @@ public class LakalaApiServiceImpl implements LakalaApiService {
String errorMsg = String.format("店铺[%s]未绑定平台方接收账户,跳过分账", shopOrderLkl.getStore_id()); String errorMsg = String.format("店铺[%s]未绑定平台方接收账户,跳过分账", shopOrderLkl.getStore_id());
log.error(errorMsg); log.error(errorMsg);
errorMessages.append(errorMsg).append("; "); errorMessages.append(errorMsg).append("; ");
lklOrderSeparateService.updateRemark(lklOrderSeparateExist.getId(), errorMsg);
continue; continue;
} }
// 判断是否可以分账商家比例非100% // 判断是否可以分账商家比例非100%
boolean canSplit = splitRatioMch != null && splitRatioMch.compareTo(new BigDecimal("100")) < 0; boolean canSplit = splitRatioMch != null && splitRatioMch.compareTo(new BigDecimal("100")) < 0;
if (!canSplit) { if (!canSplit) {
log.warn("店铺[{}]分账比例为0仅扣除运费", shopOrderLkl.getStore_id()); String errorMsg = String.format("店铺[%s]分账比例为0仅扣除运费", shopOrderLkl.getStore_id());
log.error(errorMsg);
lklOrderSeparateService.updateRemark(lklOrderSeparateExist.getId(), errorMsg);
} }
// 构建分账请求对象 // 构建分账请求对象

View File

@ -81,4 +81,22 @@ public class LklOrderSeparateServiceImpl extends BaseServiceImpl<LklOrderSeparat
return null; return null;
} }
} }
/**
* 修改备注
*
* @param id
* @param remark
* @return
*/
@Override
public Boolean updateRemark(Long id, String remark) {
if (id == null || id <= 0 || StrUtil.isEmpty(remark)) {
return false;
}
LklOrderSeparate lklOrderSeparate = new LklOrderSeparate();
lklOrderSeparate.setId(id);
lklOrderSeparate.setRemark(remark);
return updateById(lklOrderSeparate);
}
} }

View File

@ -642,19 +642,22 @@ public class LklTkServiceImpl {
String mchMobile = shopEntry.getLogin_mobile(); String mchMobile = shopEntry.getLogin_mobile();
try { try {
// 包含了更改 merchEntryInfo 的状态
Pair<Integer, String> retPair = shopStoreBaseService.merchEntryInfo2StoreInfo(mchMobile, true); Pair<Integer, String> retPair = shopStoreBaseService.merchEntryInfo2StoreInfo(mchMobile, true);
if (retPair.getFirst() > 0) { if (retPair.getFirst() <= 0) {
boolean updateSuccess = shopMchEntryService.updateMulStatus(mchMobile, "", 0, 0, 1, 0, 0, 0, CommonConstant.MCH_APPR_STA_LKL_PADDING); logger.error("初始化店铺失败: mchMobile={}, reason={}", mchMobile, retPair.getSecond());
if (!updateSuccess) {
logger.warn("更新店铺状态失败: mchMobile={}", mchMobile);
} else {
logger.info("商家进件初始化店铺成功mchMobile={}", mchMobile);
}
} else {
logger.warn("初始化店铺失败: mchMobile={}, reason={}", mchMobile, retPair.getSecond());
} }
logger.info("商家进件初始化店铺成功mchMobile={}", mchMobile);
// boolean updateSuccess = shopMchEntryService.updateMulStatus(mchMobile, "", 0, 0, 1, 0, 0, 0, CommonConstant.MCH_APPR_STA_LKL_PADDING);
// if (!updateSuccess) {
// logger.warn("更新店铺状态失败: mchMobile={}", mchMobile);
// } else {
// logger.info("商家进件初始化店铺成功mchMobile={}", mchMobile);
// }
} catch (Exception e) { } catch (Exception e) {
// 捕获所有异常防止事务中断 // 捕获所有异常防止事务中断
logger.error("初始化店铺时发生异常", e); logger.error("初始化店铺时发生异常", e);