From deb8a2c32ba0cb7a88819b54d720418cdc2f7ebb Mon Sep 17 00:00:00 2001
From: sgj <1442489573@qq.com>
Date: 星期二, 24 三月 2026 16:58:53 +0800
Subject: [PATCH] 粮情报表，数量监测报表，库区回显错误纠正
---
fzzy-igdss-core/src/main/java/com/fzzy/igds/service/FoodPriceService.java | 34 ++++++++++++++++++++++++++++++++--
1 files changed, 32 insertions(+), 2 deletions(-)
diff --git a/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/FoodPriceService.java b/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/FoodPriceService.java
index d4e02e3..a00bc2d 100644
--- a/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/FoodPriceService.java
+++ b/fzzy-igdss-core/src/main/java/com/fzzy/igds/service/FoodPriceService.java
@@ -2,15 +2,16 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.fzzy.igds.constant.Constant;
-import com.fzzy.igds.domain.Company;
import com.fzzy.igds.domain.FoodPrice;
import com.fzzy.igds.mapper.FoodPriceMapper;
+import com.fzzy.igds.timer.JobWarnService;
import com.fzzy.igds.utils.ContextUtil;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.utils.StringUtils;
+import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
+
import javax.annotation.Resource;
-import java.util.ArrayList;
import java.util.Date;
import java.util.List;
@@ -19,11 +20,15 @@
* @Author CZT
* @Date 2026/01/22 09:04
*/
+@Slf4j
@Service
public class FoodPriceService {
@Resource
private FoodPriceMapper foodPriceMapper;
+
+ @Resource
+ private JobWarnService jobWarnService;
/**
*
@@ -44,6 +49,28 @@
}
/**
+ * 鏍规嵁閾惰鍙婂搧绉嶏紝鏌ヨ鍗曚环淇℃伅
+ * @param bankId
+ * @param foodVariety
+ * @return
+ */
+ public FoodPrice getDataByBankAndFood(String bankId, String foodVariety) {
+ if(StringUtils.isBlank(bankId) || StringUtils.isBlank(foodVariety) ){
+ return null;
+ }
+ SysUser user = ContextUtil.getLoginUser();
+ QueryWrapper<FoodPrice> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("bank_id", bankId);
+ queryWrapper.eq("food_variety", foodVariety);
+
+ List<FoodPrice> foodPrices = foodPriceMapper.selectList(queryWrapper);
+ if(null == foodPrices){
+ return null;
+ }
+ return foodPrices.get(0);
+ }
+
+ /**
* 鏇存柊鎴栦繚瀛樹俊鎭�
* @param data
* @return
@@ -61,6 +88,9 @@
foodPriceMapper.insert( data);
}else {
foodPriceMapper.updateById( data);
+ //鏇存柊鏃讹紝鎵ц杩樻鎻愰啋閲嶆柊鍒ゆ柇
+ log.info("---------绮鍗曚环鏇存柊鏃讹紝鎵ц杩樻鎻愰啋閲嶆柊鍒ゆ柇鍗曚环id{}---------",data.getId());
+ jobWarnService.doExe(data.getBankId());
}
}
--
Gitblit v1.9.3