bonus
/
Bonus-Cloud-Smart-Canteen
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

upby修改 删除多余的AccSendMq.java

This commit is contained in:
tqzhang 2025-02-14 09:21:56 +08:00
parent afb72d28db
commit b928929990
2 changed files with 4 additions and 48 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/account/v3/mq/send/model/AccSendMq.java
View File

@ -1,46 +0,0 @@
package com.bonus.core.account.v3.mq.send.model;
import com.bonus.core.account.v3.constants.AccStatusEnum;
import com.bonus.core.account.v3.mapper.AccInfoMapper;
import com.bonus.core.common.utils.JacksonUtil;
import com.bonus.core.common.utils.TenantContextHolder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Lazy;
import org.springframework.context.i18n.LocaleContextHolder;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.function.Function;
import java.util.stream.Collectors;
@Component
public class AccSendMq {
private static final Logger log = LoggerFactory.getLogger(AccSendMq.class);
@Autowired
@Lazy
private AccInfoMapper accInfoMapper;
public void accChangeSendHandle(List<Long> custIdList, Integer accStatus) {
if (AccStatusEnum.sendMqStatus().contains(accStatus)) {
log.info("账户状态变动发送mq_入参人员数量={},accStatus={}", custIdList.size(), accStatus);
List<AccStatusChangeModel> resultList = this.accInfoMapper.queryAccStatusByCustIdList(custIdList);
Long tenantId = TenantContextHolder.getTenantId();
LocalDateTime now = LocalDateTime.now();
resultList.forEach((item) -> {
item.setMerchantId(tenantId);
item.setAccStatus(accStatus);
item.setUpDateTime(now);
log.info("账户状态变动发送mq内容：{}", JacksonUtil.writeValueAsString(item));
//MqUtil.send(JacksonUtil.writeValueAsString(item), LeMqConstant.Topic.ACC_STATUS_CHANGE);
});
}
}
}

6
bonus-modules/bonus-smart-canteen/src/main/java/com/bonus/core/customer/v4/mobile/service/impl/CustPhotoServiceImpl.java
View File

@ -7,6 +7,7 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.bonus.common.core.exception.ServiceException;
import com.bonus.common.core.web.domain.AjaxResult;
import com.bonus.common.redis.service.RedisService;
import com.bonus.common.security.utils.SecurityUtils;
import com.bonus.core.account.v3.constants.AccStatusEnum;
import com.bonus.core.allocation.api.GlobalMetadataApi;
@ -79,6 +80,8 @@ public class CustPhotoServiceImpl extends ServiceImpl<CustPhotoMapper, CustPhoto
@Resource
private DelayedMessageSender delayedMessageSender;
@Resource
private RedisService redisService;
@Resource
DcPushUserDataServiceApi dcPushUserDataServiceApi;
@Value("${system.sysfile.max-upload-file-size}")
@ -194,9 +197,8 @@ public class CustPhotoServiceImpl extends ServiceImpl<CustPhotoMapper, CustPhoto
}
this.custInfoService.updateCustPhotoUrl(custId, cutPath);
//TODO 替换 123 -> 当前登录人的手机号
this.custAccTempService.update(
new CustAccTemp().setCustId(custId).setCustPhotoUrl(cutPath).setUpby("123"),
new CustAccTemp().setCustId(custId).setCustPhotoUrl(cutPath).setUpby(SecurityUtils.getLoginUser().getSysUser().getPhonenumber()),
new LambdaQueryWrapper<CustAccTemp>().eq(CustAccTemp::getCustId, custId)
);
this.delayedMessageSender.asyncDelaySendToDevice(DelayedMessageTypeEnum.PHOTO);