1.商品不推送修复
This commit is contained in:
parent
3807eb43ce
commit
fcaba6d511
|
|
@ -66,4 +66,7 @@ public interface TbProductRepository extends JpaRepository<TbProduct, Integer>,
|
||||||
@Query(value = "select b.* from tb_product_sku as a left join tb_product as b on a.product_id=b.id where a.id=:skuId", nativeQuery = true)
|
@Query(value = "select b.* from tb_product_sku as a left join tb_product as b on a.product_id=b.id where a.id=:skuId", nativeQuery = true)
|
||||||
TbProduct selectBySkuId(@Param("skuId") Integer skuId);
|
TbProduct selectBySkuId(@Param("skuId") Integer skuId);
|
||||||
|
|
||||||
|
@Query(value = "select * from tb_product_sku as a where a.id=:skuId", nativeQuery = true)
|
||||||
|
TbProduct selectById(@Param("skuId") Integer skuId);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -365,7 +365,7 @@ public class StockServiceImpl implements StockService {
|
||||||
break;
|
break;
|
||||||
case "pauseSale":
|
case "pauseSale":
|
||||||
sqlQuery.append(" set is_pause_sale = ").append(updateValueVO.getUpdateValue());
|
sqlQuery.append(" set is_pause_sale = ").append(updateValueVO.getUpdateValue());
|
||||||
TbProduct product1 = tbProductRepository.selectBySkuId(Integer.valueOf(updateValueVO.getTargetId()));
|
TbProduct product1 = tbProductRepository.selectById(Integer.valueOf(updateValueVO.getTargetId()));
|
||||||
// 推送微信操作消息
|
// 推送微信操作消息
|
||||||
if (product1 != null) {
|
if (product1 != null) {
|
||||||
wxMsgUtils.aboardOperationMsg(("0".equals(updateValueVO.getUpdateValue()) ? "关闭售罄: " : "开启售罄: ") + product1.getName(), Integer.valueOf(updateValueVO.getShopId()));
|
wxMsgUtils.aboardOperationMsg(("0".equals(updateValueVO.getUpdateValue()) ? "关闭售罄: " : "开启售罄: ") + product1.getName(), Integer.valueOf(updateValueVO.getShopId()));
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue