diff --git a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java index 50073dc..130f9e2 100644 --- a/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java +++ b/bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/canteen/core/account/service/impl/AccInfoServiceImpl.java @@ -177,9 +177,10 @@ public class AccInfoServiceImpl implements IAccInfoService { public int deleteAccInfoByUserIds(List users) { int count = 0; for (int i = 0; i < users.size(); i++) { - accWalletInfoService.deleteAccWalletInfoByUserId(users.get(i).getUserId()); - //MqUtil.sendDataChange(userId, LeMqConstant.DataChangeType.REMOVE, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER); - count += accInfoMapper.deleteAccInfoByUserId(users.get(i).getUserId()); + Long userId = users.get(i).getUserId(); + accWalletInfoService.deleteAccWalletInfoByUserId(userId); + MqUtil.sendDataChange(userId, LeMqConstant.DataChangeType.REMOVE, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER); + count += accInfoMapper.deleteAccInfoByUserId(userId); } return count; } diff --git a/bonus-modules/bonus-smart-canteen/src/main/resources/mapper/account/AccTradeMapper.xml b/bonus-modules/bonus-smart-canteen/src/main/resources/mapper/account/AccTradeMapper.xml index 5a2c57f..0a35f31 100644 --- a/bonus-modules/bonus-smart-canteen/src/main/resources/mapper/account/AccTradeMapper.xml +++ b/bonus-modules/bonus-smart-canteen/src/main/resources/mapper/account/AccTradeMapper.xml @@ -40,7 +40,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" - select trade_id, trade_time, user_id, dept_id, trade_type, actual_amount, amount, wallet_bal_total, acc_all_bal, pay_channel, pay_type, pay_state, trade_state, third_trade_no, machine_sn, batch_num, le_ord_no, origin_trade_id, sub_time_rule_id, manage_cost, withdraw_source, recharge_source, canteen_id, machine_type, fail_reason, recharge_operate, psn_type, operate_source, batch_import_id, create_by, create_time, update_by, update_time from acc_trade + select trade_id, trade_time, user_id, dept_id, trade_type, actual_amount, amount, wallet_bal_total, + acc_all_bal, pay_channel, pay_type, pay_state, trade_state, third_trade_no, machine_sn, + batch_num, order_no, origin_trade_id, sub_time_rule_id, manage_cost, withdraw_source, + recharge_source, canteen_id, machine_type, fail_reason, recharge_operate, psn_type, + operate_source, batch_import_id, create_by, create_time, update_by, update_time + from acc_trade - where order_no = #{orderNo}