sgj
2026-03-20 58f63e3a124680d0b1f571f5d0a1e3ed308d43be
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;
    /**
     *
@@ -50,8 +55,10 @@
     * @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);
@@ -81,6 +88,9 @@
            foodPriceMapper.insert( data);
        }else {
            foodPriceMapper.updateById( data);
            //更新时,执行还款提醒重新判断
            log.info("---------粮食单价更新时,执行还款提醒重新判断单价id{}---------",data.getId());
            jobWarnService.doExe(data.getBankId());
        }
    }