This commit is contained in:
sxu 2025-04-11 10:15:39 +08:00
parent 7605359104
commit dbacf19ad0
2 changed files with 11 additions and 5 deletions

View File

@ -177,9 +177,10 @@ public class AccInfoServiceImpl implements IAccInfoService {
public int deleteAccInfoByUserIds(List<SysUser> users) { public int deleteAccInfoByUserIds(List<SysUser> users) {
int count = 0; int count = 0;
for (int i = 0; i < users.size(); i++) { for (int i = 0; i < users.size(); i++) {
accWalletInfoService.deleteAccWalletInfoByUserId(users.get(i).getUserId()); Long userId = users.get(i).getUserId();
//MqUtil.sendDataChange(userId, LeMqConstant.DataChangeType.REMOVE, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER); accWalletInfoService.deleteAccWalletInfoByUserId(userId);
count += accInfoMapper.deleteAccInfoByUserId(users.get(i).getUserId()); MqUtil.sendDataChange(userId, LeMqConstant.DataChangeType.REMOVE, LeMqConstant.Topic.DATA_CHANGE_CUSTOMER);
count += accInfoMapper.deleteAccInfoByUserId(userId);
} }
return count; return count;
} }

View File

@ -40,7 +40,12 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
</resultMap> </resultMap>
<sql id="selectAccTradeVo"> <sql id="selectAccTradeVo">
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
</sql> </sql>
<select id="selectAccTradeList" parameterType="com.bonus.canteen.core.account.domain.AccTrade" resultMap="AccTradeResult"> <select id="selectAccTradeList" parameterType="com.bonus.canteen.core.account.domain.AccTrade" resultMap="AccTradeResult">
@ -82,7 +87,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
where trade_id = #{tradeId} where trade_id = #{tradeId}
</select> </select>
<select id="selectAccTradeByOrderNo" parameterType="Long" resultMap="AccTradeResult"> <select id="selectAccTradeByOrderNo" parameterType="String" resultMap="AccTradeResult">
<include refid="selectAccTradeVo"/> <include refid="selectAccTradeVo"/>
where order_no = #{orderNo} where order_no = #{orderNo}
</select> </select>