diff --git a/alert_function.sql b/alert_function.sql
new file mode 100644
index 0000000..bdb018d
--- /dev/null
+++ b/alert_function.sql
@@ -0,0 +1,61 @@
+-- =======================================
+-- 药品库存智能预警功能数据库脚本
+-- =======================================
+
+-- 1. 为药品信息表添加最低库存阈值字段
+ALTER TABLE `yaopinxinxi` 
+ADD COLUMN `low_stock_threshold` INT(11) NULL DEFAULT 10 COMMENT '最低库存阈值' AFTER `beizhu`;
+
+-- 2. 创建库存预警记录表
+DROP TABLE IF EXISTS `stock_alert`;
+CREATE TABLE `stock_alert` (
+  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `addtime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `yaopin_id` bigint(20) NOT NULL COMMENT '药品ID',
+  `yaopinmingcheng` varchar(200) NOT NULL COMMENT '药品名称',
+  `current_stock` int(11) NOT NULL COMMENT '当前库存',
+  `low_stock_threshold` int(11) NOT NULL COMMENT '最低库存阈值',
+  `alert_level` int(11) DEFAULT 1 COMMENT '预警级别(1:低库存预警, 2:紧急预警)',
+  `status` int(11) DEFAULT 0 COMMENT '处理状态(0:未处理, 1:已处理)',
+  `handler_id` bigint(20) DEFAULT NULL COMMENT '处理人ID',
+  `handler_name` varchar(200) DEFAULT NULL COMMENT '处理人姓名',
+  `handle_time` timestamp NULL DEFAULT NULL COMMENT '处理时间',
+  `handle_note` varchar(500) DEFAULT NULL COMMENT '处理备注',
+  PRIMARY KEY (`id`),
+  KEY `idx_yaopin_id` (`yaopin_id`),
+  KEY `idx_status` (`status`),
+  KEY `idx_addtime` (`addtime`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='库存预警记录表';
+
+-- 3. 创建药品采购建议表
+DROP TABLE IF EXISTS `purchase_suggestion`;
+CREATE TABLE `purchase_suggestion` (
+  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主键',
+  `addtime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间',
+  `yaopin_id` bigint(20) NOT NULL COMMENT '药品ID',
+  `yaopinmingcheng` varchar(200) NOT NULL COMMENT '药品名称',
+  `guige` varchar(200) DEFAULT NULL COMMENT '规格',
+  `current_stock` int(11) NOT NULL COMMENT '当前库存',
+  `low_stock_threshold` int(11) NOT NULL COMMENT '最低库存阈值',
+  `suggested_quantity` int(11) NOT NULL COMMENT '建议采购数量',
+  `suggested_min_quantity` int(11) DEFAULT NULL COMMENT '建议最小采购量',
+  `suggested_max_quantity` int(11) DEFAULT NULL COMMENT '建议最大采购量',
+  `avg_monthly_usage` int(11) DEFAULT NULL COMMENT '月平均使用量',
+  `lead_time_days` int(11) DEFAULT NULL COMMENT '采购提前期(天)',
+  `urgency_level` int(11) DEFAULT 1 COMMENT '紧急程度(1:一般, 2:紧急, 3:非常紧急)',
+  `status` int(11) DEFAULT 0 COMMENT '状态(0:待审核, 1:已采纳, 2:已拒绝)',
+  `creator_id` bigint(20) DEFAULT NULL COMMENT '创建人ID',
+  `creator_name` varchar(200) DEFAULT NULL COMMENT '创建人姓名',
+  `remark` varchar(500) DEFAULT NULL COMMENT '备注',
+  PRIMARY KEY (`id`),
+  KEY `idx_yaopin_id` (`yaopin_id`),
+  KEY `idx_status` (`status`),
+  KEY `idx_urgency_level` (`urgency_level`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci COMMENT='药品采购建议表';
+
+-- 4. 初始化现有药品的最低库存阈值为10
+UPDATE `yaopinxinxi` SET `low_stock_threshold` = 10 WHERE `low_stock_threshold` IS NULL;
+
+-- 5. 创建索引优化查询
+CREATE INDEX idx_yaopin_kucun ON yaopinxinxi(kucun);
+CREATE INDEX idx_yaopin_threshold ON yaopinxinxi(low_stock_threshold);
diff --git a/manage_code/src/views/yaopinxinxi/list.vue b/manage_code/src/views/yaopinxinxi/list.vue
index 63ffcb5..2287c16 100644
--- a/manage_code/src/views/yaopinxinxi/list.vue
+++ b/manage_code/src/views/yaopinxinxi/list.vue
@@ -29,6 +29,14 @@
                     <el-button class="statis_btn" type="warning" @click="echartClick1" v-if="btnAuth('yaopinxinxi','药品库存统计')">
                         <i class="iconfont icon-bar-chart--line"></i>
                         药品库存统计
+                    </el-button>
+                    <el-button class="statis_btn" type="info" @click="checkStockAlertHandler" v-if="btnAuth('yaopinxinxi','库存预警检查')">
+                        <i class="iconfont icon-tishi"></i>
+                        库存预警检查
+                    </el-button>
+                    <el-button class="statis_btn" type="primary" @click="generatePurchaseSuggestionsHandler" v-if="btnAuth('yaopinxinxi','采购建议')">
+                        <i class="iconfont icon-dingdan3"></i>
+                        生成采购建议
                     </el-button>
 				</div>
 			</div>
@@ -101,16 +109,29 @@
 					</template>
 				</el-table-column>
 				<el-table-column min-width="140"
-					:resizable='true'
-					:sortable='true'
-					align="left"
-					header-align="left"
-					prop="kucun"
-					label="库存">
-					<template #default="scope">
+				:resizable='true'
+				:sortable='true'
+				align="left"
+				header-align="left"
+				prop="kucun"
+				label="库存">
+				<template #default="scope">
+					<el-tag :type="scope.row.kucun < scope.row.lowStockThreshold ? 'danger' : 'success'" size="small">
 						{{scope.row.kucun}}
-					</template>
-				</el-table-column>
+					</el-tag>
+				</template>
+			</el-table-column>
+			<el-table-column min-width="140"
+				:resizable='true'
+				:sortable='true'
+				align="left"
+				header-align="left"
+				prop="lowStockThreshold"
+				label="最低库存阈值">
+				<template #default="scope">
+					{{scope.row.lowStockThreshold || '-'}}
+				</template>
+			</el-table-column>
 				<el-table-column min-width="140"
 					:resizable='true'
 					:sortable='true'
@@ -150,9 +171,13 @@
 							入库
 						</el-button>
 						<el-button class="cross_btn" v-if="btnAuth('yaopinxinxi','出库')" type="success" @click="chukujiluCrossAddOrUpdateHandler(scope.row,'cross','','','','')">
-							<i class="iconfont icon-dingdan3"></i>
-							出库
-						</el-button>
+						<i class="iconfont icon-dingdan3"></i>
+						出库
+					</el-button>
+					<el-button class="cross_btn" v-if="btnAuth('yaopinxinxi','设置阈值')" type="info" @click="setThresholdHandler(scope.row)">
+						<i class="iconfont icon-xiugai5"></i>
+						设置阈值
+					</el-button>
 					</template>
 				</el-table-column>
 			</el-table>
@@ -182,6 +207,77 @@
 		</el-dialog>
 		<rukujiluFormModel ref="rukujiluFormModelRef" @formModelChange="formModelChange"></rukujiluFormModel>
 		<chukujiluFormModel ref="chukujiluFormModelRef" @formModelChange="formModelChange"></chukujiluFormModel>
+		<!-- 设置阈值对话框 -->
+		<el-dialog v-model="thresholdDialogVisible" title="设置最低库存阈值" width="500px">
+			<el-form :model="thresholdForm" label-width="120px">
+				<el-form-item label="药品名称">
+					{{thresholdForm.yaopinmingcheng}}
+				</el-form-item>
+				<el-form-item label="当前库存">
+					{{thresholdForm.kucun}}
+				</el-form-item>
+				<el-form-item label="最低库存阈值" required>
+					<el-input-number v-model="thresholdForm.lowStockThreshold" :min="0" :max="10000" style="width: 100%;" />
+				</el-form-item>
+			</el-form>
+			<template #footer>
+				<span class="formModel_btn_box">
+					<el-button class="cancel_btn" @click="thresholdDialogVisible=false">取消</el-button>
+					<el-button class="confirm_btn" type="primary" @click="saveThresholdHandler">确定</el-button>
+				</span>
+			</template>
+		</el-dialog>
+		<!-- 库存预警记录对话框 -->
+		<el-dialog v-model="stockAlertDialogVisible" title="库存预警记录" width="80%">
+			<el-table :data="stockAlertList" border v-loading="stockAlertLoading">
+				<el-table-column prop="yaopinmingcheng" label="药品名称" min-width="150" />
+				<el-table-column prop="currentStock" label="当前库存" min-width="120" />
+				<el-table-column prop="lowStockThreshold" label="最低阈值" min-width="120" />
+				<el-table-column prop="alertLevel" label="预警级别" min-width="120">
+					<template #default="scope">
+						<el-tag :type="scope.row.alertLevel === 1 ? 'warning' : 'danger'" size="small">
+							{{scope.row.alertLevel === 1 ? '轻度预警' : '重度预警'}}
+						</el-tag>
+					</template>
+				</el-table-column>
+				<el-table-column prop="status" label="状态" min-width="100">
+					<template #default="scope">
+						<el-tag :type="scope.row.status === 0 ? 'info' : 'success'" size="small">
+							{{scope.row.status === 0 ? '未处理' : '已处理'}}
+						</el-tag>
+					</template>
+				</el-table-column>
+				<el-table-column prop="addtime" label="预警时间" min-width="180" />
+			</el-table>
+			<template #footer>
+				<span class="formModel_btn_box">
+					<el-button class="cancel_btn" @click="stockAlertDialogVisible=false">关闭</el-button>
+				</span>
+			</template>
+		</el-dialog>
+		<!-- 采购建议对话框 -->
+		<el-dialog v-model="purchaseSuggestionDialogVisible" title="药品采购建议" width="80%">
+			<el-table :data="purchaseSuggestionList" border v-loading="purchaseSuggestionLoading">
+				<el-table-column prop="yaopinmingcheng" label="药品名称" min-width="150" />
+				<el-table-column prop="suggestedQuantity" label="建议采购数量" min-width="120" />
+				<el-table-column prop="urgencyLevel" label="紧急程度" min-width="120">
+					<template #default="scope">
+						<el-tag :type="scope.row.urgencyLevel === 1 ? 'success' : (scope.row.urgencyLevel === 2 ? 'warning' : 'danger')" size="small">
+							{{scope.row.urgencyLevel === 1 ? '正常' : (scope.row.urgencyLevel === 2 ? '紧急' : '非常紧急')}}
+						</el-tag>
+					</template>
+				</el-table-column>
+				<el-table-column prop="estimatedUsageDays" label="预计可用天数" min-width="120" />
+				<el-table-column prop="lastPurchaseQuantity" label="上次采购量" min-width="120" />
+				<el-table-column prop="remark" label="备注" min-width="200" show-overflow-tooltip />
+				<el-table-column prop="addtime" label="生成时间" min-width="180" />
+			</el-table>
+			<template #footer>
+				<span class="formModel_btn_box">
+					<el-button class="cancel_btn" @click="purchaseSuggestionDialogVisible=false">关闭</el-button>
+				</span>
+			</template>
+		</el-dialog>
 	</div>
 </template>
 <script setup>
@@ -471,6 +567,102 @@
 			chukujiluFormModelRef.value.init(row.id,'cross','出库',row,'yaopinxinxi',statusColumnName,tips,statusColumnValue)
 		})
     }
+	// 设置阈值
+	const thresholdDialogVisible = ref(false)
+	const thresholdForm = ref({
+		id: null,
+		yaopinmingcheng: '',
+		kucun: 0,
+		lowStockThreshold: 0
+	})
+	const setThresholdHandler = (row) => {
+		thresholdForm.value = {
+			id: row.id,
+			yaopinmingcheng: row.yaopinmingcheng,
+			kucun: row.kucun,
+			lowStockThreshold: row.lowStockThreshold || 0
+		}
+		thresholdDialogVisible.value = true
+	}
+	const saveThresholdHandler = () => {
+		if(thresholdForm.value.lowStockThreshold === undefined || thresholdForm.value.lowStockThreshold < 0) {
+			context?.$toolUtil.message('请输入有效的最低库存阈值','error')
+			return
+		}
+		context.$http({
+			url: `${tableName}/setThreshold`,
+			method: 'post',
+			data: {
+				id: thresholdForm.value.id,
+				lowStockThreshold: thresholdForm.value.lowStockThreshold
+			}
+		}).then(res => {
+			context?.$toolUtil.message('设置成功','success')
+			thresholdDialogVisible.value = false
+			getList()
+		})
+	}
+	// 库存预警检查
+	const checkStockAlertHandler = () => {
+		context.$http({
+			url: `${tableName}/checkStockAlert`,
+			method: 'post'
+		}).then(res => {
+			if(res.data.data && res.data.data.alertCount > 0) {
+				context?.$alert(`发现${res.data.data.alertCount}条库存预警，请查看预警记录`)
+				// 自动打开预警记录对话框
+				getStockAlertList()
+			} else {
+				context?.$toolUtil.message('库存检查完成，暂无预警','success')
+			}
+		})
+	}
+	// 库存预警记录
+	const stockAlertDialogVisible = ref(false)
+	const stockAlertList = ref([])
+	const stockAlertLoading = ref(false)
+	const getStockAlertList = () => {
+		stockAlertLoading.value = true
+		context.$http({
+			url: 'stockalert/list',
+			method: 'get',
+			params: { status: 0 }
+		}).then(res => {
+			stockAlertLoading.value = false
+			stockAlertList.value = res.data.data
+			stockAlertDialogVisible.value = true
+		})
+	}
+	// 生成采购建议
+	const generatePurchaseSuggestionsHandler = () => {
+		context.$http({
+			url: `${tableName}/generatePurchaseSuggestions`,
+			method: 'post'
+		}).then(res => {
+			if(res.data.data && res.data.data.suggestionCount > 0) {
+				context?.$alert(`已生成${res.data.data.suggestionCount}条采购建议，请查看`)
+				// 自动打开采购建议对话框
+				getPurchaseSuggestionList()
+			} else {
+				context?.$toolUtil.message('暂无需要采购的药品','success')
+			}
+		})
+	}
+	// 采购建议列表
+	const purchaseSuggestionDialogVisible = ref(false)
+	const purchaseSuggestionList = ref([])
+	const purchaseSuggestionLoading = ref(false)
+	const getPurchaseSuggestionList = () => {
+		purchaseSuggestionLoading.value = true
+		context.$http({
+			url: 'purchasesuggestion/list',
+			method: 'get'
+		}).then(res => {
+			purchaseSuggestionLoading.value = false
+			purchaseSuggestionList.value = res.data.data
+			purchaseSuggestionDialogVisible.value = true
+		})
+	}
 	//初始化
 	const init = () => {
 		let urlkucun = 'yaopinxinxi/remind/kucun/1'
diff --git a/server_code/src/main/java/com/cl/controller/PurchaseSuggestionController.java b/server_code/src/main/java/com/cl/controller/PurchaseSuggestionController.java
new file mode 100644
index 0000000..5ab081c
--- /dev/null
+++ b/server_code/src/main/java/com/cl/controller/PurchaseSuggestionController.java
@@ -0,0 +1,97 @@
+package com.cl.controller;
+
+import java.util.*;
+import javax.servlet.http.HttpServletRequest;
+
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.cl.annotation.IgnoreAuth;
+import com.cl.annotation.SysLog;
+
+import com.cl.entity.PurchaseSuggestionEntity;
+
+import com.cl.service.PurchaseSuggestionService;
+import com.cl.service.TokenService;
+import com.cl.utils.PageUtils;
+import com.cl.utils.R;
+import com.cl.utils.MPUtil;
+
+@RestController
+@RequestMapping("/purchasesuggestion")
+public class PurchaseSuggestionController {
+    @Autowired
+    private PurchaseSuggestionService purchaseSuggestionService;
+
+    @RequestMapping("/page")
+    public R page(@RequestParam Map<String, Object> params,PurchaseSuggestionEntity purchaseSuggestion,
+        HttpServletRequest request){
+        EntityWrapper<PurchaseSuggestionEntity> ew = new EntityWrapper<PurchaseSuggestionEntity>();
+        PageUtils page = purchaseSuggestionService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, purchaseSuggestion), params), params));
+        return R.ok().put("data", page);
+    }
+
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params,PurchaseSuggestionEntity purchaseSuggestion,
+        HttpServletRequest request){
+        EntityWrapper<PurchaseSuggestionEntity> ew = new EntityWrapper<PurchaseSuggestionEntity>();
+        PageUtils page = purchaseSuggestionService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, purchaseSuggestion), params), params));
+        return R.ok().put("data", page);
+    }
+
+    @RequestMapping("/lists")
+    public R list( PurchaseSuggestionEntity purchaseSuggestion){
+        EntityWrapper<PurchaseSuggestionEntity> ew = new EntityWrapper<PurchaseSuggestionEntity>();
+        ew.allEq(MPUtil.allEQMapPre( purchaseSuggestion, "purchaseSuggestion")); 
+        return R.ok().put("data", purchaseSuggestionService.selectListView(ew));
+    }
+
+    @RequestMapping("/query")
+    public R query(PurchaseSuggestionEntity purchaseSuggestion){
+        EntityWrapper< PurchaseSuggestionEntity> ew = new EntityWrapper< PurchaseSuggestionEntity>();
+        ew.allEq(MPUtil.allEQMapPre( purchaseSuggestion, "purchaseSuggestion"));
+        PurchaseSuggestionEntity purchaseSuggestionView = purchaseSuggestionService.selectView(ew);
+        return R.ok("查询采购建议成功").put("data", purchaseSuggestionView);
+    }
+
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Long id){
+        PurchaseSuggestionEntity purchaseSuggestion = purchaseSuggestionService.selectById(id);
+        return R.ok().put("data", purchaseSuggestion);
+    }
+
+    @RequestMapping("/detail/{id}")
+    public R detail(@PathVariable("id") Long id){
+        PurchaseSuggestionEntity purchaseSuggestion = purchaseSuggestionService.selectById(id);
+        return R.ok().put("data", purchaseSuggestion);
+    }
+
+    @RequestMapping("/save")
+    @SysLog("新增采购建议")
+    public R save(@RequestBody PurchaseSuggestionEntity purchaseSuggestion, HttpServletRequest request){
+        purchaseSuggestionService.insert(purchaseSuggestion);
+        return R.ok();
+    }
+
+    @RequestMapping("/update")
+    @SysLog("修改采购建议")
+    public R update(@RequestBody PurchaseSuggestionEntity purchaseSuggestion, HttpServletRequest request){
+        purchaseSuggestionService.updateById(purchaseSuggestion);
+        return R.ok();
+    }
+
+    @RequestMapping("/delete")
+    @SysLog("删除采购建议")
+    public R delete(@RequestBody Long[] ids){
+        purchaseSuggestionService.deleteBatchIds(Arrays.asList(ids));
+        return R.ok();
+    }
+
+}
diff --git a/server_code/src/main/java/com/cl/controller/StockAlertController.java b/server_code/src/main/java/com/cl/controller/StockAlertController.java
new file mode 100644
index 0000000..ef49c2f
--- /dev/null
+++ b/server_code/src/main/java/com/cl/controller/StockAlertController.java
@@ -0,0 +1,97 @@
+package com.cl.controller;
+
+import java.util.*;
+import javax.servlet.http.HttpServletRequest;
+
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.cl.annotation.IgnoreAuth;
+import com.cl.annotation.SysLog;
+
+import com.cl.entity.StockAlertEntity;
+
+import com.cl.service.StockAlertService;
+import com.cl.service.TokenService;
+import com.cl.utils.PageUtils;
+import com.cl.utils.R;
+import com.cl.utils.MPUtil;
+
+@RestController
+@RequestMapping("/stockalert")
+public class StockAlertController {
+    @Autowired
+    private StockAlertService stockAlertService;
+
+    @RequestMapping("/page")
+    public R page(@RequestParam Map<String, Object> params,StockAlertEntity stockAlert,
+        HttpServletRequest request){
+        EntityWrapper<StockAlertEntity> ew = new EntityWrapper<StockAlertEntity>();
+        PageUtils page = stockAlertService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, stockAlert), params), params));
+        return R.ok().put("data", page);
+    }
+
+    @RequestMapping("/list")
+    public R list(@RequestParam Map<String, Object> params,StockAlertEntity stockAlert,
+        HttpServletRequest request){
+        EntityWrapper<StockAlertEntity> ew = new EntityWrapper<StockAlertEntity>();
+        PageUtils page = stockAlertService.queryPage(params, MPUtil.sort(MPUtil.between(MPUtil.likeOrEq(ew, stockAlert), params), params));
+        return R.ok().put("data", page);
+    }
+
+    @RequestMapping("/lists")
+    public R list( StockAlertEntity stockAlert){
+        EntityWrapper<StockAlertEntity> ew = new EntityWrapper<StockAlertEntity>();
+        ew.allEq(MPUtil.allEQMapPre( stockAlert, "stockAlert")); 
+        return R.ok().put("data", stockAlertService.selectListView(ew));
+    }
+
+    @RequestMapping("/query")
+    public R query(StockAlertEntity stockAlert){
+        EntityWrapper< StockAlertEntity> ew = new EntityWrapper< StockAlertEntity>();
+        ew.allEq(MPUtil.allEQMapPre( stockAlert, "stockAlert"));
+        StockAlertEntity stockAlertView = stockAlertService.selectView(ew);
+        return R.ok("查询库存预警成功").put("data", stockAlertView);
+    }
+
+    @RequestMapping("/info/{id}")
+    public R info(@PathVariable("id") Long id){
+        StockAlertEntity stockAlert = stockAlertService.selectById(id);
+        return R.ok().put("data", stockAlert);
+    }
+
+    @RequestMapping("/detail/{id}")
+    public R detail(@PathVariable("id") Long id){
+        StockAlertEntity stockAlert = stockAlertService.selectById(id);
+        return R.ok().put("data", stockAlert);
+    }
+
+    @RequestMapping("/save")
+    @SysLog("新增库存预警")
+    public R save(@RequestBody StockAlertEntity stockAlert, HttpServletRequest request){
+        stockAlertService.insert(stockAlert);
+        return R.ok();
+    }
+
+    @RequestMapping("/update")
+    @SysLog("修改库存预警")
+    public R update(@RequestBody StockAlertEntity stockAlert, HttpServletRequest request){
+        stockAlertService.updateById(stockAlert);
+        return R.ok();
+    }
+
+    @RequestMapping("/delete")
+    @SysLog("删除库存预警")
+    public R delete(@RequestBody Long[] ids){
+        stockAlertService.deleteBatchIds(Arrays.asList(ids));
+        return R.ok();
+    }
+
+}
diff --git a/server_code/src/main/java/com/cl/controller/YaopinxinxiController.java b/server_code/src/main/java/com/cl/controller/YaopinxinxiController.java
index 1729cb2..82f398b 100644
--- a/server_code/src/main/java/com/cl/controller/YaopinxinxiController.java
+++ b/server_code/src/main/java/com/cl/controller/YaopinxinxiController.java
@@ -29,6 +29,7 @@
 
 import com.cl.service.YaopinxinxiService;
 import com.cl.service.TokenService;
+import com.cl.service.StockAlertTaskService;
 import com.cl.utils.PageUtils;
 import com.cl.utils.R;
 import com.cl.utils.MPUtil;
@@ -48,6 +49,9 @@ public class YaopinxinxiController {
     @Autowired
     private YaopinxinxiService yaopinxinxiService;
 
+    @Autowired
+    private StockAlertTaskService stockAlertTaskService;
+
 
 
 
@@ -226,10 +230,36 @@ public R remindCount(@PathVariable("columnName") String columnName, HttpServletR
 		int count = yaopinxinxiService.selectCount(wrapper);
 		return R.ok().put("count", count);
 	}
-	
 
+    @RequestMapping("/setThreshold")
+    @SysLog("设置药品最低库存阈值")
+    public R setThreshold(@RequestBody Map<String, Object> params, HttpServletRequest request) {
+        Long id = Long.parseLong(params.get("id").toString());
+        Integer threshold = Integer.parseInt(params.get("lowStockThreshold").toString());
 
+        YaopinxinxiEntity medicine = yaopinxinxiService.selectById(id);
+        if (medicine == null) {
+            return R.error("药品不存在");
+        }
 
+        medicine.setLowStockThreshold(threshold);
+        yaopinxinxiService.updateById(medicine);
+        return R.ok("最低库存阈值设置成功");
+    }
+
+    @RequestMapping("/checkStockAlert")
+    @SysLog("手动触发库存预警检查")
+    public R checkStockAlert(HttpServletRequest request) {
+        stockAlertTaskService.checkStockAndAlert();
+        return R.ok("库存预警检查已执行");
+    }
+
+    @RequestMapping("/generatePurchaseSuggestions")
+    @SysLog("手动生成采购建议")
+    public R generatePurchaseSuggestions(HttpServletRequest request) {
+        stockAlertTaskService.generatePurchaseSuggestions();
+        return R.ok("采购建议已生成");
+    }
 
 
     /**
diff --git a/server_code/src/main/java/com/cl/dao/PurchaseSuggestionDao.java b/server_code/src/main/java/com/cl/dao/PurchaseSuggestionDao.java
new file mode 100644
index 0000000..d112568
--- /dev/null
+++ b/server_code/src/main/java/com/cl/dao/PurchaseSuggestionDao.java
@@ -0,0 +1,29 @@
+package com.cl.dao;
+
+import com.cl.entity.PurchaseSuggestionEntity;
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+import java.util.List;
+import java.util.Map;
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.plugins.pagination.Pagination;
+
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * 采购建议
+ */
+public interface PurchaseSuggestionDao extends BaseMapper<PurchaseSuggestionEntity> {
+    
+    List<PurchaseSuggestionEntity> selectListView(@Param("ew") Wrapper<PurchaseSuggestionEntity> wrapper);
+
+    List<PurchaseSuggestionEntity> selectListView(Pagination page,@Param("ew") Wrapper<PurchaseSuggestionEntity> wrapper);
+    
+    PurchaseSuggestionEntity selectView(@Param("ew") Wrapper<PurchaseSuggestionEntity> wrapper);
+
+    List<Map<String, Object>> selectValue(@Param("params") Map<String, Object> params,@Param("ew") Wrapper<PurchaseSuggestionEntity> wrapper);
+
+    List<Map<String, Object>> selectTimeStatValue(@Param("params") Map<String, Object> params,@Param("ew") Wrapper<PurchaseSuggestionEntity> wrapper);
+
+    List<Map<String, Object>> selectGroup(@Param("params") Map<String, Object> params,@Param("ew") Wrapper<PurchaseSuggestionEntity> wrapper);
+
+}
diff --git a/server_code/src/main/java/com/cl/dao/StockAlertDao.java b/server_code/src/main/java/com/cl/dao/StockAlertDao.java
new file mode 100644
index 0000000..ff2b284
--- /dev/null
+++ b/server_code/src/main/java/com/cl/dao/StockAlertDao.java
@@ -0,0 +1,29 @@
+package com.cl.dao;
+
+import com.cl.entity.StockAlertEntity;
+import com.baomidou.mybatisplus.mapper.BaseMapper;
+import java.util.List;
+import java.util.Map;
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.plugins.pagination.Pagination;
+
+import org.apache.ibatis.annotations.Param;
+
+/**
+ * 库存预警记录
+ */
+public interface StockAlertDao extends BaseMapper<StockAlertEntity> {
+    
+    List<StockAlertEntity> selectListView(@Param("ew") Wrapper<StockAlertEntity> wrapper);
+
+    List<StockAlertEntity> selectListView(Pagination page,@Param("ew") Wrapper<StockAlertEntity> wrapper);
+    
+    StockAlertEntity selectView(@Param("ew") Wrapper<StockAlertEntity> wrapper);
+
+    List<Map<String, Object>> selectValue(@Param("params") Map<String, Object> params,@Param("ew") Wrapper<StockAlertEntity> wrapper);
+
+    List<Map<String, Object>> selectTimeStatValue(@Param("params") Map<String, Object> params,@Param("ew") Wrapper<StockAlertEntity> wrapper);
+
+    List<Map<String, Object>> selectGroup(@Param("params") Map<String, Object> params,@Param("ew") Wrapper<StockAlertEntity> wrapper);
+
+}
diff --git a/server_code/src/main/java/com/cl/entity/PurchaseSuggestionEntity.java b/server_code/src/main/java/com/cl/entity/PurchaseSuggestionEntity.java
new file mode 100644
index 0000000..70f7499
--- /dev/null
+++ b/server_code/src/main/java/com/cl/entity/PurchaseSuggestionEntity.java
@@ -0,0 +1,156 @@
+package com.cl.entity;
+
+import com.baomidou.mybatisplus.annotations.TableId;
+import com.baomidou.mybatisplus.annotations.TableName;
+import com.baomidou.mybatisplus.enums.IdType;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 采购建议
+ */
+@TableName("purchase_suggestion")
+public class PurchaseSuggestionEntity<T> implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	public PurchaseSuggestionEntity() {
+	}
+
+	public PurchaseSuggestionEntity(T t) {
+		this.yaopinId = (Long) t;
+	}
+
+	/**
+	 * 主键id
+	 */
+	@TableId(type = IdType.AUTO)
+	private Long id;
+
+	/**
+	 * 药品ID
+	 */
+	private Long yaopinId;
+
+	/**
+	 * 药品名称
+	 */
+	private String yaopinmingcheng;
+
+	/**
+	 * 建议采购数量
+	 */
+	private Integer suggestedQuantity;
+
+	/**
+	 * 紧急程度(1:一般, 2:紧急, 3:非常紧急)
+	 */
+	private Integer urgencyLevel;
+
+	/**
+	 * 预计使用天数
+	 */
+	private Integer estimatedUsageDays;
+
+	/**
+	 * 上次采购数量
+	 */
+	private Integer lastPurchaseQuantity;
+
+	/**
+	 * 备注
+	 */
+	private String remark;
+
+	/**
+	 * 状态(0:待处理, 1:已采购, 2:已取消)
+	 */
+	private Integer status;
+
+	@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd HH:mm:ss")
+	@DateTimeFormat
+	private Date addtime;
+
+	public Date getAddtime() {
+		return addtime;
+	}
+
+	public void setAddtime(Date addtime) {
+		this.addtime = addtime;
+	}
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public Long getYaopinId() {
+		return yaopinId;
+	}
+
+	public void setYaopinId(Long yaopinId) {
+		this.yaopinId = yaopinId;
+	}
+
+	public String getYaopinmingcheng() {
+		return yaopinmingcheng;
+	}
+
+	public void setYaopinmingcheng(String yaopinmingcheng) {
+		this.yaopinmingcheng = yaopinmingcheng;
+	}
+
+	public Integer getSuggestedQuantity() {
+		return suggestedQuantity;
+	}
+
+	public void setSuggestedQuantity(Integer suggestedQuantity) {
+		this.suggestedQuantity = suggestedQuantity;
+	}
+
+	public Integer getUrgencyLevel() {
+		return urgencyLevel;
+	}
+
+	public void setUrgencyLevel(Integer urgencyLevel) {
+		this.urgencyLevel = urgencyLevel;
+	}
+
+	public Integer getEstimatedUsageDays() {
+		return estimatedUsageDays;
+	}
+
+	public void setEstimatedUsageDays(Integer estimatedUsageDays) {
+		this.estimatedUsageDays = estimatedUsageDays;
+	}
+
+	public Integer getLastPurchaseQuantity() {
+		return lastPurchaseQuantity;
+	}
+
+	public void setLastPurchaseQuantity(Integer lastPurchaseQuantity) {
+		this.lastPurchaseQuantity = lastPurchaseQuantity;
+	}
+
+	public String getRemark() {
+		return remark;
+	}
+
+	public void setRemark(String remark) {
+		this.remark = remark;
+	}
+
+	public Integer getStatus() {
+		return status;
+	}
+
+	public void setStatus(Integer status) {
+		this.status = status;
+	}
+}
diff --git a/server_code/src/main/java/com/cl/entity/StockAlertEntity.java b/server_code/src/main/java/com/cl/entity/StockAlertEntity.java
new file mode 100644
index 0000000..1bff272
--- /dev/null
+++ b/server_code/src/main/java/com/cl/entity/StockAlertEntity.java
@@ -0,0 +1,130 @@
+package com.cl.entity;
+
+import com.baomidou.mybatisplus.annotations.TableId;
+import com.baomidou.mybatisplus.annotations.TableName;
+import com.baomidou.mybatisplus.enums.IdType;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 库存预警记录
+ */
+@TableName("stock_alert")
+public class StockAlertEntity<T> implements Serializable {
+	private static final long serialVersionUID = 1L;
+
+	public StockAlertEntity() {
+	}
+
+	public StockAlertEntity(T t) {
+		this.yaopinId = (Long) t;
+	}
+
+	/**
+	 * 主键id
+	 */
+	@TableId(type = IdType.AUTO)
+	private Long id;
+
+	/**
+	 * 药品ID
+	 */
+	private Long yaopinId;
+
+	/**
+	 * 药品名称
+	 */
+	private String yaopinmingcheng;
+
+	/**
+	 * 当前库存
+	 */
+	private Integer currentStock;
+
+	/**
+	 * 最低库存阈值
+	 */
+	private Integer lowStockThreshold;
+
+	/**
+	 * 预警级别(1:低库存预警, 2:紧急预警)
+	 */
+	private Integer alertLevel;
+
+	/**
+	 * 处理状态(0:未处理, 1:已处理)
+	 */
+	private Integer status;
+
+	@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd HH:mm:ss")
+	@DateTimeFormat
+	private Date addtime;
+
+	public Date getAddtime() {
+		return addtime;
+	}
+
+	public void setAddtime(Date addtime) {
+		this.addtime = addtime;
+	}
+
+	public Long getId() {
+		return id;
+	}
+
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+	public Long getYaopinId() {
+		return yaopinId;
+	}
+
+	public void setYaopinId(Long yaopinId) {
+		this.yaopinId = yaopinId;
+	}
+
+	public String getYaopinmingcheng() {
+		return yaopinmingcheng;
+	}
+
+	public void setYaopinmingcheng(String yaopinmingcheng) {
+		this.yaopinmingcheng = yaopinmingcheng;
+	}
+
+	public Integer getCurrentStock() {
+		return currentStock;
+	}
+
+	public void setCurrentStock(Integer currentStock) {
+		this.currentStock = currentStock;
+	}
+
+	public Integer getLowStockThreshold() {
+		return lowStockThreshold;
+	}
+
+	public void setLowStockThreshold(Integer lowStockThreshold) {
+		this.lowStockThreshold = lowStockThreshold;
+	}
+
+	public Integer getAlertLevel() {
+		return alertLevel;
+	}
+
+	public void setAlertLevel(Integer alertLevel) {
+		this.alertLevel = alertLevel;
+	}
+
+	public Integer getStatus() {
+		return status;
+	}
+
+	public void setStatus(Integer status) {
+		this.status = status;
+	}
+}
diff --git a/server_code/src/main/java/com/cl/entity/YaopinxinxiEntity.java b/server_code/src/main/java/com/cl/entity/YaopinxinxiEntity.java
index e971761..c0d5073 100644
--- a/server_code/src/main/java/com/cl/entity/YaopinxinxiEntity.java
+++ b/server_code/src/main/java/com/cl/entity/YaopinxinxiEntity.java
@@ -100,9 +100,15 @@ public YaopinxinxiEntity(T t) {
 	/**
 	 * 备注
 	 */
-					
+							
 	private String beizhu;
 	
+	/**
+	 * 最低库存阈值
+	 */
+							
+	private Integer lowStockThreshold;
+	
 
 	@JsonFormat(locale="zh", timezone="GMT+8", pattern="yyyy-MM-dd HH:mm:ss")
 	@DateTimeFormat
@@ -217,5 +223,17 @@ public void setBeizhu(String beizhu) {
 	public String getBeizhu() {
 		return beizhu;
 	}
+	/**
+	 * 设置：最低库存阈值
+	 */
+	public void setLowStockThreshold(Integer lowStockThreshold) {
+		this.lowStockThreshold = lowStockThreshold;
+	}
+	/**
+	 * 获取：最低库存阈值
+	 */
+	public Integer getLowStockThreshold() {
+		return lowStockThreshold;
+	}
 
 }
diff --git a/server_code/src/main/java/com/cl/service/PurchaseSuggestionService.java b/server_code/src/main/java/com/cl/service/PurchaseSuggestionService.java
new file mode 100644
index 0000000..328d4b5
--- /dev/null
+++ b/server_code/src/main/java/com/cl/service/PurchaseSuggestionService.java
@@ -0,0 +1,27 @@
+package com.cl.service;
+
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.service.IService;
+import com.cl.utils.PageUtils;
+import com.cl.entity.PurchaseSuggestionEntity;
+import java.util.List;
+import java.util.Map;
+
+public interface PurchaseSuggestionService extends IService<PurchaseSuggestionEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+    
+    List<PurchaseSuggestionEntity> selectListView(Wrapper<PurchaseSuggestionEntity> wrapper);
+    
+    PurchaseSuggestionEntity selectView(Wrapper<PurchaseSuggestionEntity> wrapper);
+    
+    PageUtils queryPage(Map<String, Object> params,Wrapper<PurchaseSuggestionEntity> wrapper);
+    
+    
+    List<Map<String, Object>> selectValue(Map<String, Object> params,Wrapper<PurchaseSuggestionEntity> wrapper);
+
+    List<Map<String, Object>> selectTimeStatValue(Map<String, Object> params,Wrapper<PurchaseSuggestionEntity> wrapper);
+
+    List<Map<String, Object>> selectGroup(Map<String, Object> params,Wrapper<PurchaseSuggestionEntity> wrapper);
+
+}
diff --git a/server_code/src/main/java/com/cl/service/StockAlertService.java b/server_code/src/main/java/com/cl/service/StockAlertService.java
new file mode 100644
index 0000000..9c0bfb0
--- /dev/null
+++ b/server_code/src/main/java/com/cl/service/StockAlertService.java
@@ -0,0 +1,27 @@
+package com.cl.service;
+
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.service.IService;
+import com.cl.utils.PageUtils;
+import com.cl.entity.StockAlertEntity;
+import java.util.List;
+import java.util.Map;
+
+public interface StockAlertService extends IService<StockAlertEntity> {
+
+    PageUtils queryPage(Map<String, Object> params);
+    
+    List<StockAlertEntity> selectListView(Wrapper<StockAlertEntity> wrapper);
+    
+    StockAlertEntity selectView(Wrapper<StockAlertEntity> wrapper);
+    
+    PageUtils queryPage(Map<String, Object> params,Wrapper<StockAlertEntity> wrapper);
+    
+    
+    List<Map<String, Object>> selectValue(Map<String, Object> params,Wrapper<StockAlertEntity> wrapper);
+
+    List<Map<String, Object>> selectTimeStatValue(Map<String, Object> params,Wrapper<StockAlertEntity> wrapper);
+
+    List<Map<String, Object>> selectGroup(Map<String, Object> params,Wrapper<StockAlertEntity> wrapper);
+
+}
diff --git a/server_code/src/main/java/com/cl/service/StockAlertTaskService.java b/server_code/src/main/java/com/cl/service/StockAlertTaskService.java
new file mode 100644
index 0000000..e128499
--- /dev/null
+++ b/server_code/src/main/java/com/cl/service/StockAlertTaskService.java
@@ -0,0 +1,171 @@
+package com.cl.service;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.cl.entity.YaopinxinxiEntity;
+import com.cl.entity.StockAlertEntity;
+import com.cl.entity.PurchaseSuggestionEntity;
+import com.cl.entity.ChukujiluEntity;
+import com.cl.entity.RukujiluEntity;
+
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class StockAlertTaskService {
+
+    @Autowired
+    private YaopinxinxiService yaopinxinxiService;
+
+    @Autowired
+    private StockAlertService stockAlertService;
+
+    @Autowired
+    private PurchaseSuggestionService purchaseSuggestionService;
+
+    @Autowired
+    private ChukujiluService chukujiluService;
+
+    @Autowired
+    private RukujiluService rukujiluService;
+
+    @Transactional
+    public void checkStockAndAlert() {
+        EntityWrapper<YaopinxinxiEntity> ew = new EntityWrapper<>();
+        ew.ge("lowStockThreshold", 0);
+        List<YaopinxinxiEntity> medicines = yaopinxinxiService.selectList(ew);
+
+        for (YaopinxinxiEntity medicine : medicines) {
+            if (medicine.getLowStockThreshold() == null || medicine.getKucun() == null) {
+                continue;
+            }
+
+            if (medicine.getKucun() <= medicine.getLowStockThreshold()) {
+                int alertLevel = 1;
+                if (medicine.getKucun() <= medicine.getLowStockThreshold() * 0.5) {
+                    alertLevel = 2;
+                }
+
+                EntityWrapper<StockAlertEntity> alertEw = new EntityWrapper<>();
+                alertEw.eq("yaopin_id", medicine.getId());
+                alertEw.eq("status", 0);
+                List<StockAlertEntity> existingAlerts = stockAlertService.selectList(alertEw);
+
+                if (existingAlerts.isEmpty()) {
+                    StockAlertEntity alert = new StockAlertEntity();
+                    alert.setYaopinId(medicine.getId());
+                    alert.setYaopinmingcheng(medicine.getYaopinmingcheng());
+                    alert.setCurrentStock(medicine.getKucun());
+                    alert.setLowStockThreshold(medicine.getLowStockThreshold());
+                    alert.setAlertLevel(alertLevel);
+                    alert.setStatus(0);
+                    stockAlertService.insert(alert);
+                }
+            }
+        }
+    }
+
+    @Transactional
+    public void generatePurchaseSuggestions() {
+        EntityWrapper<YaopinxinxiEntity> ew = new EntityWrapper<>();
+        ew.le("kucun", "lowStockThreshold");
+        List<YaopinxinxiEntity> lowStockMedicines = yaopinxinxiService.selectList(ew);
+
+        for (YaopinxinxiEntity medicine : lowStockMedicines) {
+            EntityWrapper<PurchaseSuggestionEntity> suggestEw = new EntityWrapper<>();
+            suggestEw.eq("yaopin_id", medicine.getId());
+            suggestEw.eq("status", 0);
+            List<PurchaseSuggestionEntity> existingSuggestions = purchaseSuggestionService.selectList(suggestEw);
+
+            if (existingSuggestions.isEmpty()) {
+                int avgMonthlyUsage = calculateAverageMonthlyUsage(medicine.getId());
+                int suggestedQuantity = calculateSuggestedQuantity(medicine, avgMonthlyUsage);
+                int urgencyLevel = calculateUrgencyLevel(medicine);
+                int estimatedUsageDays = calculateEstimatedUsageDays(medicine, avgMonthlyUsage);
+                int lastPurchaseQuantity = getLastPurchaseQuantity(medicine.getId());
+
+                PurchaseSuggestionEntity suggestion = new PurchaseSuggestionEntity();
+                suggestion.setYaopinId(medicine.getId());
+                suggestion.setYaopinmingcheng(medicine.getYaopinmingcheng());
+                suggestion.setSuggestedQuantity(suggestedQuantity);
+                suggestion.setUrgencyLevel(urgencyLevel);
+                suggestion.setEstimatedUsageDays(estimatedUsageDays);
+                suggestion.setLastPurchaseQuantity(lastPurchaseQuantity);
+                suggestion.setStatus(0);
+
+                String remark = "基于历史出库数据自动生成的采购建议";
+                if (urgencyLevel >= 2) {
+                    remark += " - 紧急采购";
+                }
+                suggestion.setRemark(remark);
+
+                purchaseSuggestionService.insert(suggestion);
+            }
+        }
+    }
+
+    private int calculateAverageMonthlyUsage(Long medicineId) {
+        EntityWrapper<ChukujiluEntity> ew = new EntityWrapper<>();
+        ew.eq("yaopin_id", medicineId);
+        ew.ge("addtime", new Date(System.currentTimeMillis() - 90L * 24 * 60 * 60 * 1000));
+        List<ChukujiluEntity> records = chukujiluService.selectList(ew);
+
+        int totalUsage = 0;
+        for (ChukujiluEntity record : records) {
+            if (record.getShuliang() != null) {
+                totalUsage += record.getShuliang();
+            }
+        }
+
+        return records.size() > 0 ? (totalUsage / 3) : 30;
+    }
+
+    private int calculateSuggestedQuantity(YaopinxinxiEntity medicine, int avgMonthlyUsage) {
+        int deficit = medicine.getLowStockThreshold() - medicine.getKucun();
+        int suggestedQuantity = avgMonthlyUsage + deficit;
+        
+        if (suggestedQuantity < avgMonthlyUsage * 0.5) {
+            suggestedQuantity = avgMonthlyUsage;
+        }
+        
+        return Math.max(suggestedQuantity, 10);
+    }
+
+    private int calculateUrgencyLevel(YaopinxinxiEntity medicine) {
+        int currentStock = medicine.getKucun();
+        int threshold = medicine.getLowStockThreshold();
+
+        if (currentStock <= threshold * 0.3) {
+            return 3;
+        } else if (currentStock <= threshold * 0.6) {
+            return 2;
+        } else {
+            return 1;
+        }
+    }
+
+    private int calculateEstimatedUsageDays(YaopinxinxiEntity medicine, int avgMonthlyUsage) {
+        if (avgMonthlyUsage <= 0) {
+            return 30;
+        }
+        return (medicine.getKucun() * 30) / avgMonthlyUsage;
+    }
+
+    private int getLastPurchaseQuantity(Long medicineId) {
+        EntityWrapper<RukujiluEntity> ew = new EntityWrapper<>();
+        ew.eq("yaopin_id", medicineId);
+        ew.orderBy("addtime", false);
+        ew.last("LIMIT 1");
+        
+        List<RukujiluEntity> records = rukujiluService.selectList(ew);
+        if (records != null && !records.isEmpty()) {
+            RukujiluEntity lastRecord = records.get(0);
+            return lastRecord.getShuliang() != null ? lastRecord.getShuliang() : 0;
+        }
+        return 0;
+    }
+
+}
diff --git a/server_code/src/main/java/com/cl/service/impl/PurchaseSuggestionServiceImpl.java b/server_code/src/main/java/com/cl/service/impl/PurchaseSuggestionServiceImpl.java
new file mode 100644
index 0000000..c91adb2
--- /dev/null
+++ b/server_code/src/main/java/com/cl/service/impl/PurchaseSuggestionServiceImpl.java
@@ -0,0 +1,63 @@
+package com.cl.service.impl;
+
+import org.springframework.stereotype.Service;
+import java.util.Map;
+import java.util.List;
+
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.cl.utils.PageUtils;
+import com.cl.utils.Query;
+
+import com.cl.dao.PurchaseSuggestionDao;
+import com.cl.entity.PurchaseSuggestionEntity;
+import com.cl.service.PurchaseSuggestionService;
+
+@Service("purchaseSuggestionService")
+public class PurchaseSuggestionServiceImpl extends ServiceImpl<PurchaseSuggestionDao, PurchaseSuggestionEntity> implements PurchaseSuggestionService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        Page<PurchaseSuggestionEntity> page = this.selectPage(
+                new Query<PurchaseSuggestionEntity>(params).getPage(),
+                new EntityWrapper<PurchaseSuggestionEntity>()
+        );
+        return new PageUtils(page);
+    }
+    
+    @Override
+	public PageUtils queryPage(Map<String, Object> params, Wrapper<PurchaseSuggestionEntity> wrapper) {
+		  Page<PurchaseSuggestionEntity> page =new Query<PurchaseSuggestionEntity>(params).getPage();
+        page.setRecords(baseMapper.selectListView(page,wrapper));
+	    PageUtils pageUtil = new PageUtils(page);
+	    return pageUtil;
+ }
+    
+	@Override
+	public List<PurchaseSuggestionEntity> selectListView(Wrapper<PurchaseSuggestionEntity> wrapper) {
+		return baseMapper.selectListView(wrapper);
+	}
+
+	@Override
+	public PurchaseSuggestionEntity selectView(Wrapper<PurchaseSuggestionEntity> wrapper) {
+		return baseMapper.selectView(wrapper);
+	}
+    
+    @Override
+    public List<Map<String, Object>> selectValue(Map<String, Object> params, Wrapper<PurchaseSuggestionEntity> wrapper) {
+        return baseMapper.selectValue(params, wrapper);
+    }
+
+    @Override
+    public List<Map<String, Object>> selectTimeStatValue(Map<String, Object> params, Wrapper<PurchaseSuggestionEntity> wrapper) {
+        return baseMapper.selectTimeStatValue(params, wrapper);
+    }
+
+    @Override
+    public List<Map<String, Object>> selectGroup(Map<String, Object> params, Wrapper<PurchaseSuggestionEntity> wrapper) {
+        return baseMapper.selectGroup(params, wrapper);
+    }
+
+}
diff --git a/server_code/src/main/java/com/cl/service/impl/StockAlertServiceImpl.java b/server_code/src/main/java/com/cl/service/impl/StockAlertServiceImpl.java
new file mode 100644
index 0000000..c5fd2cd
--- /dev/null
+++ b/server_code/src/main/java/com/cl/service/impl/StockAlertServiceImpl.java
@@ -0,0 +1,63 @@
+package com.cl.service.impl;
+
+import org.springframework.stereotype.Service;
+import java.util.Map;
+import java.util.List;
+
+import com.baomidou.mybatisplus.mapper.Wrapper;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.baomidou.mybatisplus.plugins.Page;
+import com.baomidou.mybatisplus.service.impl.ServiceImpl;
+import com.cl.utils.PageUtils;
+import com.cl.utils.Query;
+
+import com.cl.dao.StockAlertDao;
+import com.cl.entity.StockAlertEntity;
+import com.cl.service.StockAlertService;
+
+@Service("stockAlertService")
+public class StockAlertServiceImpl extends ServiceImpl<StockAlertDao, StockAlertEntity> implements StockAlertService {
+
+    @Override
+    public PageUtils queryPage(Map<String, Object> params) {
+        Page<StockAlertEntity> page = this.selectPage(
+                new Query<StockAlertEntity>(params).getPage(),
+                new EntityWrapper<StockAlertEntity>()
+        );
+        return new PageUtils(page);
+    }
+    
+    @Override
+	public PageUtils queryPage(Map<String, Object> params, Wrapper<StockAlertEntity> wrapper) {
+		  Page<StockAlertEntity> page =new Query<StockAlertEntity>(params).getPage();
+        page.setRecords(baseMapper.selectListView(page,wrapper));
+	    PageUtils pageUtil = new PageUtils(page);
+	    return pageUtil;
+ }
+    
+	@Override
+	public List<StockAlertEntity> selectListView(Wrapper<StockAlertEntity> wrapper) {
+		return baseMapper.selectListView(wrapper);
+	}
+
+	@Override
+	public StockAlertEntity selectView(Wrapper<StockAlertEntity> wrapper) {
+		return baseMapper.selectView(wrapper);
+	}
+    
+    @Override
+    public List<Map<String, Object>> selectValue(Map<String, Object> params, Wrapper<StockAlertEntity> wrapper) {
+        return baseMapper.selectValue(params, wrapper);
+    }
+
+    @Override
+    public List<Map<String, Object>> selectTimeStatValue(Map<String, Object> params, Wrapper<StockAlertEntity> wrapper) {
+        return baseMapper.selectTimeStatValue(params, wrapper);
+    }
+
+    @Override
+    public List<Map<String, Object>> selectGroup(Map<String, Object> params, Wrapper<StockAlertEntity> wrapper) {
+        return baseMapper.selectGroup(params, wrapper);
+    }
+
+}
diff --git a/server_code/src/main/java/com/cl/task/StockAlertTask.java b/server_code/src/main/java/com/cl/task/StockAlertTask.java
new file mode 100644
index 0000000..61abb15
--- /dev/null
+++ b/server_code/src/main/java/com/cl/task/StockAlertTask.java
@@ -0,0 +1,41 @@
+package com.cl.task;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.cl.service.StockAlertTaskService;
+
+@Component
+public class StockAlertTask {
+
+    private static final Logger logger = LoggerFactory.getLogger(StockAlertTask.class);
+
+    @Autowired
+    private StockAlertTaskService stockAlertTaskService;
+
+    @Scheduled(cron = "0 0 9 * * ?")
+    public void checkStockAlertsDaily() {
+        logger.info("开始执行每日库存预警检查任务");
+        try {
+            stockAlertTaskService.checkStockAndAlert();
+            logger.info("每日库存预警检查任务执行完成");
+        } catch (Exception e) {
+            logger.error("每日库存预警检查任务执行失败", e);
+        }
+    }
+
+    @Scheduled(cron = "0 0 10 * * MON")
+    public void generatePurchaseSuggestionsWeekly() {
+        logger.info("开始执行每周采购建议生成任务");
+        try {
+            stockAlertTaskService.generatePurchaseSuggestions();
+            logger.info("每周采购建议生成任务执行完成");
+        } catch (Exception e) {
+            logger.error("每周采购建议生成任务执行失败", e);
+        }
+    }
+
+}