caojiahao/dev_caojiahao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aop积分日志记录兼容问题处理

Browse Source
This commit is contained in:
Chopper 2021-06-29 11:15:27 +08:00
parent 5a415ffc77
commit 39e851ee78
2 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
consumer/src/main/java/cn/lili/event/impl/NoticeMessageExecute.java
View File

@ -148,11 +148,14 @@ public class NoticeMessageExecute implements TradeEvent, OrderStatusChangeEvent,
@Override @Override
public void memberPointChange(MemberPointMessage memberPointMessage) { public void memberPointChange(MemberPointMessage memberPointMessage) {
if (memberPointMessage == null) {
return;
}
//组织站内信参数 //组织站内信参数
NoticeMessageDTO noticeMessageDTO = new NoticeMessageDTO(); NoticeMessageDTO noticeMessageDTO = new NoticeMessageDTO();
noticeMessageDTO.setMemberId(memberPointMessage.getMemberId()); noticeMessageDTO.setMemberId(memberPointMessage.getMemberId());
Map<String, String> params = new HashMap<>(); Map<String, String> params = new HashMap<>();
if (memberPointMessage.getType().equals(1)) { if (memberPointMessage.getType()) {
params.put("expenditure_points", "0"); params.put("expenditure_points", "0");
params.put("income_points", memberPointMessage.getPoint().toString()); params.put("income_points", memberPointMessage.getPoint().toString());
} else { } else {

8
framework/src/main/java/cn/lili/modules/member/entity/aop/interceptor/PointLogInterceptor.java
View File

@ -40,9 +40,9 @@ public class PointLogInterceptor {
point = Long.valueOf(obj[0].toString()); point = Long.valueOf(obj[0].toString());
} }
//变动类型 //变动类型
Integer type = 0; Boolean type = false;
if (obj[1] != null) { if (obj[1] != null) {
type = Integer.valueOf(obj[1].toString()); type = Boolean.valueOf(obj[1].toString());
} }
//会员ID //会员ID
String memberId = ""; String memberId = "";
@ -55,7 +55,7 @@ public class PointLogInterceptor {
MemberPointsHistory memberPointsHistory = new MemberPointsHistory(); MemberPointsHistory memberPointsHistory = new MemberPointsHistory();
memberPointsHistory.setMemberId(member.getId()); memberPointsHistory.setMemberId(member.getId());
memberPointsHistory.setMemberName(member.getUsername()); memberPointsHistory.setMemberName(member.getUsername());
memberPointsHistory.setPointType(type); memberPointsHistory.setPointType(type ? 1 : 0);
memberPointsHistory.setVariablePoint(point); memberPointsHistory.setVariablePoint(point);
memberPointsHistory.setBeforePoint(new Double(CurrencyUtil.sub(member.getPoint(), point)).longValue()); memberPointsHistory.setBeforePoint(new Double(CurrencyUtil.sub(member.getPoint(), point)).longValue());
memberPointsHistory.setPoint(member.getPoint()); memberPointsHistory.setPoint(member.getPoint());
@ -64,7 +64,7 @@ public class PointLogInterceptor {
memberPointsHistoryService.save(memberPointsHistory); memberPointsHistoryService.save(memberPointsHistory);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("积分操作错误",e); log.error("积分操作错误", e);
} }