修改店铺信息发送跟新mq

This commit is contained in:
张松
2025-12-02 15:10:29 +08:00
parent 1958ddfadf
commit d05f1f1caf

View File

@@ -10,6 +10,7 @@ import com.czg.account.entity.*;
import com.czg.account.enums.BranchDataSyncMethodEnum;
import com.czg.account.enums.ShopTypeEnum;
import com.czg.account.service.*;
import com.czg.config.RabbitPublisher;
import com.czg.config.RedisCst;
import com.czg.enums.StatusEnum;
import com.czg.enums.YesNoEnum;
@@ -55,6 +56,8 @@ import java.util.stream.Collectors;
@DubboService
@CacheConfig(cacheNames = "shopInfo")
public class ShopInfoServiceImpl extends ServiceImpl<ShopInfoMapper, ShopInfo> implements ShopInfoService {
@Resource
private RabbitPublisher rabbitPublisher;
@Resource
private SysUserService sysUserService;
@Resource
@@ -315,6 +318,9 @@ public class ShopInfoServiceImpl extends ServiceImpl<ShopInfoMapper, ShopInfo> i
}
return true;
}
rabbitPublisher.sendOrderDetailStatusMsg(shopInfo.getId().toString());
return false;
}