czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

通知中心接口完善

Browse Source
This commit is contained in:
张松
2025-04-07 10:34:35 +08:00
parent 379163dae8
commit 821d67c527
4 changed files with 38 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
cash-common/cash-common-service/src/main/java/com/czg/account/entity/SyncNotice.java
View File

@@ -62,6 +62,15 @@ public class SyncNotice implements Serializable {
* 店铺id
*/
private Long shopId;
/**
* 操作类型 0 新增 1 修改
*/
private Integer operationType;
/**
* 消息内容
*/
private String content;
/**
* 创建时间

3
cash-common/cash-common-service/src/main/java/com/czg/account/service/SyncNoticeService.java
View File

@@ -21,8 +21,9 @@ public interface SyncNoticeService extends IService<SyncNotice> {
* @param name 商品/耗材名称
* @param id 商品/耗材id
* @param type 0-商品 1-耗材
* @param operationType 0-新增 1-修改
*/
void addNotice(Long shopId, Long sysUserId, String name, Long id, Integer type);
void addNotice(Long shopId, Long sysUserId, String name, Long id, Integer type, Integer operationType);
Page<SyncNotice> pageInfo(Long shopId, String name, String startTime, String endTime, Integer type, Integer isRead);

23
cash-service/account-service/src/main/java/com/czg/service/account/service/impl/SyncNoticeServiceImpl.java
View File

@@ -10,6 +10,7 @@ import com.mybatisflex.spring.service.impl.ServiceImpl;
import com.czg.account.entity.SyncNotice;
import com.czg.account.service.SyncNoticeService;
import com.czg.service.account.mapper.SyncNoticeMapper;
import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Service;
import java.util.List;
@@ -20,17 +21,35 @@ import java.util.List;
* @author zs
* @since 2025-04-07
*/
@Service
@DubboService
public class SyncNoticeServiceImpl extends ServiceImpl<SyncNoticeMapper, SyncNotice> implements SyncNoticeService {
@Override
public void addNotice(Long shopId, Long sysUserId, String name, Long id, Integer type) {
public void addNotice(Long shopId, Long sysUserId, String name, Long id, Integer type, Integer operationType) {
SyncNotice syncNotice = new SyncNotice();
syncNotice.setShopId(shopId);
syncNotice.setSysUserId(sysUserId);
syncNotice.setName(name);
syncNotice.setSourceId(id);
syncNotice.setType(type);
syncNotice.setOperationType(operationType);
String content = switch (operationType) {
case 0 -> "新增";
case 1 -> "修改";
default -> "";
};
switch (type) {
case 0:
content += "商品";
break;
case 1:
content += "耗材";
break;
}
content = StrUtil.format("{}: {}({}), 请及时确认;", content, name, id);
syncNotice.setContent(content);
save(syncNotice);
}

7
cash-service/product-service/src/main/java/com/czg/service/product/service/impl/ConsInfoServiceImpl.java
View File

@@ -3,6 +3,7 @@ package com.czg.service.product.service.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import com.czg.account.service.SyncNoticeService;
import com.czg.enums.CrudEnum;
import com.czg.enums.StatusEnum;
import com.czg.enums.YesNoEnum;
@@ -26,6 +27,7 @@ import com.mybatisflex.core.query.QueryWrapper;
import com.mybatisflex.core.update.UpdateChain;
import com.mybatisflex.spring.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@@ -48,6 +50,9 @@ public class ConsInfoServiceImpl extends ServiceImpl<ConsInfoMapper, ConsInfo> i
private final ConsGroupMapper consGroupMapper;
private final ConsStockFlowMapper consStockFlowMapper;
@DubboReference
private SyncNoticeService syncNoticeService;
private QueryWrapper buildQueryWrapper(ConsInfoDTO param) {
QueryWrapper queryWrapper = PageUtil.buildSortQueryWrapper();
if (ObjUtil.isNotNull(param.getConsGroupId())) {
@@ -204,4 +209,4 @@ public class ConsInfoServiceImpl extends ServiceImpl<ConsInfoMapper, ConsInfo> i
return data;
}
}
}