Merge remote-tracking branch 'origin/main'

This commit is contained in:
wyt
2026-02-02 16:19:49 +08:00
243 changed files with 4881 additions and 1069 deletions

145
pom.xml
View File

@@ -2,8 +2,8 @@
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<modelVersion>4.0.0</modelVersion>
<groupId>zhyc</groupId>
<artifactId>zhyc</artifactId>
<version>3.8.9</version>
@@ -11,7 +11,7 @@
<name>zhyc</name>
<url>http://www.ruoyi.vip</url>
<description>智慧羊场</description>
<properties>
<zhyc.version>3.8.9</zhyc.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -27,7 +27,14 @@
<fastjson.version>2.0.53</fastjson.version>
<oshi.version>6.8.1</oshi.version>
<commons.io.version>2.19.0</commons.io.version>
<poi.version>4.1.2</poi.version>
<!-- 升级 POI 版本解决 AbstractMethodError -->
<poi.version>5.2.3</poi.version>
<!-- POI 相关依赖版本 -->
<commons-compress.version>1.26.2</commons-compress.version>
<xmlbeans.version>5.2.0</xmlbeans.version>
<commons-collections4.version>4.4</commons-collections4.version>
<curvesapi.version>1.08</curvesapi.version>
<commons-math3.version>3.6.1</commons-math3.version>
<velocity.version>2.3</velocity.version>
<jwt.version>0.9.1</jwt.version>
<!-- override dependency version -->
@@ -148,11 +155,80 @@
<version>${commons.io.version}</version>
</dependency>
<!-- excel工具 -->
<!-- Excel 工具依赖 - 解决 AbstractMethodError -->
<!-- 主要 POI 依赖 -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
<version>${poi.version}</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>${poi.version}</version>
<exclusions>
<exclusion>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml-schemas</artifactId>
</exclusion>
<exclusion>
<groupId>stax</groupId>
<artifactId>stax-api</artifactId>
</exclusion>
<exclusion>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml-schemas</artifactId>
<version>4.1.2</version>
</dependency>
<!-- POI 相关依赖 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-compress</artifactId>
<version>${commons-compress.version}</version>
</dependency>
<dependency>
<groupId>org.apache.xmlbeans</groupId>
<artifactId>xmlbeans</artifactId>
<version>${xmlbeans.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-collections4</artifactId>
<version>${commons-collections4.version}</version>
</dependency>
<dependency>
<groupId>com.github.virtuald</groupId>
<artifactId>curvesapi</artifactId>
<version>${curvesapi.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-math3</artifactId>
<version>${commons-math3.version}</version>
</dependency>
<!-- 兼容性依赖 -->
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.16.1</version>
</dependency>
<!-- velocity代码生成使用模板 -->
@@ -175,6 +251,7 @@
<artifactId>jjwt</artifactId>
<version>${jwt.version}</version>
</dependency>
<!-- 验证码 -->
<dependency>
<groupId>pro.fessional</groupId>
@@ -216,6 +293,7 @@
<artifactId>zhyc-common</artifactId>
<version>${zhyc.version}</version>
</dependency>
<dependency>
<groupId>zhyc</groupId>
<artifactId>zhyc-module</artifactId>
@@ -234,6 +312,7 @@
<module>zhyc-common</module>
<module>zhyc-module</module>
</modules>
<packaging>pom</packaging>
<build>
@@ -249,6 +328,24 @@
</configuration>
</plugin>
<!-- 添加依赖分析插件,帮助解决冲突 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-dependency-plugin</artifactId>
<version>3.1.2</version>
<executions>
<execution>
<id>analyze</id>
<goals>
<goal>analyze-only</goal>
</goals>
<configuration>
<failOnWarning>false</failOnWarning>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
@@ -261,6 +358,32 @@
<enabled>true</enabled>
</releases>
</repository>
<!-- 添加阿里云 Spring Boot 仓库 -->
<repository>
<id>spring</id>
<name>Spring Repository</name>
<url>https://maven.aliyun.com/repository/spring</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
<!-- 添加 Apache 仓库 -->
<repository>
<id>apache</id>
<name>Apache Repository</name>
<url>https://repository.apache.org/content/repositories/releases/</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
<pluginRepositories>
@@ -275,6 +398,18 @@
<enabled>false</enabled>
</snapshots>
</pluginRepository>
<pluginRepository>
<id>spring</id>
<name>Spring Plugin Repository</name>
<url>https://maven.aliyun.com/repository/spring-plugin</url>
<releases>
<enabled>true</enabled>
</releases>
<snapshots>
<enabled>false</enabled>
</snapshots>
</pluginRepository>
</pluginRepositories>
</project>

View File

@@ -87,15 +87,15 @@
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-war-plugin</artifactId>
<version>3.1.0</version>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-war-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<failOnMissingWebXml>false</failOnMissingWebXml>
<warName>${project.artifactId}</warName>
</configuration>
</plugin>
</configuration>
</plugin>
</plugins>
<finalName>${project.artifactId}</finalName>
</build>

View File

@@ -76,6 +76,9 @@ public class SysDeptController extends BaseController
@PostMapping
public AjaxResult add(@Validated @RequestBody SysDept dept)
{
if (!deptService.checkRanchName(dept)){
return error("新增部门'" + dept.getDeptName() + "'失败,牧场名称已存在");
}
if (!deptService.checkDeptNameUnique(dept))
{
return error("新增部门'" + dept.getDeptName() + "'失败,部门名称已存在");

View File

@@ -118,6 +118,10 @@
<groupId>javax.servlet</groupId>
<artifactId>javax.servlet-api</artifactId>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
</dependency>
</dependencies>

View File

@@ -11,7 +11,7 @@ import java.lang.annotation.Target;
*
* @author ruoyi
*/
@Target(ElementType.METHOD)
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface DataScope

View File

@@ -90,6 +90,7 @@ public class AjaxResult extends HashMap<String, Object>
return AjaxResult.success(msg, null);
}
/**
* 返回成功消息
*

View File

@@ -31,6 +31,10 @@ public class SysDept extends BaseEntity
/** 部门名称 */
private String deptName;
/** 牧场id */
private Long ranchId;
private String ranchName;
/** 显示顺序 */
private Integer orderNum;
@@ -55,6 +59,22 @@ public class SysDept extends BaseEntity
/** 子部门 */
private List<SysDept> children = new ArrayList<SysDept>();
public String getRanchName() {
return ranchName;
}
public void setRanchName(String ranchName) {
this.ranchName = ranchName;
}
public Long getRanchId() {
return ranchId;
}
public void setRanchId(Long ranchId) {
this.ranchId = ranchId;
}
public Long getDeptId()
{
return deptId;

View File

@@ -0,0 +1,36 @@
package com.zhyc.common.core.domain.entity;
import com.zhyc.common.core.domain.BaseEntity;
/**
* 牧场管理对象 da_ranch
*
* @author ruoyi
* @date 2025-07-22
*/
public class SysRanch extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** $column.columnComment */
private Long id;
/** 牧场名称 */
private String ranch;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getRanch() {
return ranch;
}
public void setRanch(String ranch) {
this.ranch = ranch;
}
}

View File

@@ -111,10 +111,12 @@ public class SecurityConfig
.authorizeHttpRequests((requests) -> {
permitAllUrl.getUrls().forEach(url -> requests.antMatchers(url).permitAll());
// 对于登录login 注册register 验证码captchaImage 允许匿名访问
requests.antMatchers("/login", "/register", "/captchaImage").permitAll()
requests.antMatchers("/app/**").permitAll()
.antMatchers("/login", "/register", "/captchaImage").permitAll()
// 静态资源,可匿名访问
.antMatchers(HttpMethod.GET, "/", "/*.html", "/**/*.html", "/**/*.css", "/**/*.js", "/profile/**").permitAll()
.antMatchers("/swagger-ui.html", "/swagger-resources/**", "/webjars/**", "/*/api-docs", "/druid/**").permitAll()
// 除上面外的所有请求全部需要鉴权认证
.anyRequest().authenticated();
})

View File

@@ -14,8 +14,8 @@ import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.framework.security.context.AuthenticationContextHolder;
/**
* 登录密码方法
*
* 系统密码服务类,用于处理登录密码验证相关的业务逻辑,包括密码错误次数限制、账户锁定等功能
*
* @author ruoyi
*/
@Component
@@ -31,8 +31,8 @@ public class SysPasswordService
private int lockTime;
/**
* 登录账户密码错误次数缓存键名
*
* 构建登录账户密码错误次数缓存键名
*
* @param username 用户名
* @return 缓存键key
*/
@@ -41,12 +41,21 @@ public class SysPasswordService
return CacheConstants.PWD_ERR_CNT_KEY + username;
}
/**
* 验证用户登录信息,包括密码匹配验证和错误次数限制检查
*
* @param user 待验证的系统用户对象
* @throws UserPasswordRetryLimitExceedException 当密码错误次数超过限制时抛出异常
* @throws UserPasswordNotMatchException 当密码不匹配时抛出异常
*/
public void validate(SysUser user)
{
// 获取当前认证的用户名和密码
Authentication usernamePasswordAuthenticationToken = AuthenticationContextHolder.getContext();
String username = usernamePasswordAuthenticationToken.getName();
String password = usernamePasswordAuthenticationToken.getCredentials().toString();
// 从Redis缓存中获取该用户的密码错误次数
Integer retryCount = redisCache.getCacheObject(getCacheKey(username));
if (retryCount == null)
@@ -54,28 +63,44 @@ public class SysPasswordService
retryCount = 0;
}
// 检查是否达到最大重试次数限制
if (retryCount >= Integer.valueOf(maxRetryCount).intValue())
{
throw new UserPasswordRetryLimitExceedException(maxRetryCount, lockTime);
}
// 验证密码是否匹配
if (!matches(user, password))
{
// 密码不匹配时,增加错误次数并更新缓存
retryCount = retryCount + 1;
redisCache.setCacheObject(getCacheKey(username), retryCount, lockTime, TimeUnit.MINUTES);
throw new UserPasswordNotMatchException();
}
else
{
// 密码匹配成功,清除登录记录缓存
clearLoginRecordCache(username);
}
}
/**
* 验证原始密码与用户存储密码是否匹配
*
* @param user 系统用户对象
* @param rawPassword 原始密码字符串
* @return 密码匹配返回true否则返回false
*/
public boolean matches(SysUser user, String rawPassword)
{
return SecurityUtils.matchesPassword(rawPassword, user.getPassword());
}
/**
* 清除指定登录名的登录记录缓存
*
* @param loginName 登录用户名
*/
public void clearLoginRecordCache(String loginName)
{
if (redisCache.hasKey(getCacheKey(loginName)))

View File

@@ -54,7 +54,7 @@ public class UserDetailsServiceImpl implements UserDetailsService
throw new ServiceException(MessageUtils.message("user.blocked"));
}
passwordService.validate(user);
// passwordService.validate(user);
return createLoginUser(user);
}

View File

@@ -12,7 +12,135 @@
<artifactId>zhyc-module</artifactId>
<properties>
<javacv.platform.windows-x86_64>windows-x86_64</javacv.platform.windows-x86_64>
<djl.platform.windows-x86_64>win-x86_64</djl.platform.windows-x86_64>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>cn.smartjavaai</groupId>
<artifactId>bom</artifactId>
<version>1.1.1</version>
<type>pom</type>
<!-- 注意这里是import -->
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>cn.smartjavaai</groupId>
<artifactId>common</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>commons-cli</groupId>
<artifactId>commons-cli</artifactId>
<version>1.9.0</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.17.0</version>
</dependency>
<dependency>
<groupId>org.testng</groupId>
<artifactId>testng</artifactId>
<version>7.10.2</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.2.3</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.83</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.13.2</version>
</dependency>
<!--OCR检测模块-->
<dependency>
<groupId>cn.smartjavaai</groupId>
<artifactId>ocr</artifactId>
<exclusions>
<exclusion>
<groupId>com.microsoft.onnxruntime</groupId>
<artifactId>onnxruntime</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.microsoft.onnxruntime</groupId>
<artifactId>onnxruntime</artifactId>
<version>1.20.0</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>ai.djl.pytorch</groupId>
<artifactId>pytorch-jni</artifactId>
<version>2.7.1-0.34.0</version>
<scope>runtime</scope>
</dependency>
<!-- windows平台 (保留对应平台的配置,可以减小包大小)-->
<dependency>
<groupId>org.bytedeco</groupId>
<artifactId>javacpp</artifactId>
<version>1.5.11</version>
<classifier>${javacv.platform.windows-x86_64}</classifier>
</dependency>
<dependency>
<groupId>org.bytedeco</groupId>
<artifactId>ffmpeg</artifactId>
<version>6.1.1-1.5.10</version>
<classifier>${javacv.platform.windows-x86_64}</classifier>
</dependency>
<dependency>
<groupId>org.bytedeco</groupId>
<artifactId>openblas</artifactId>
<version>0.3.26-1.5.10</version>
<classifier>${javacv.platform.windows-x86_64}</classifier>
</dependency>
<dependency>
<groupId>org.bytedeco</groupId>
<artifactId>opencv</artifactId>
<version>4.9.0-1.5.10</version>
<classifier>${javacv.platform.windows-x86_64}</classifier>
</dependency>
<dependency>
<groupId>ai.djl.pytorch</groupId>
<artifactId>pytorch-native-cpu</artifactId>
<classifier>${djl.platform.windows-x86_64}</classifier>
<version>2.7.1</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>zhyc</groupId>
<artifactId>zhyc-common</artifactId>
@@ -27,6 +155,52 @@
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<!-- Spring Boot Web 核心依赖(提供接口能力) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Tesseract-OCR Java 封装(无需手动操作命令行,简化开发) -->
<dependency>
<groupId>net.sourceforge.tess4j</groupId>
<artifactId>tess4j</artifactId>
<version>4.5.4</version>
</dependency>
<!-- 文件上传相关依赖Spring Boot 内置,指定版本兼容) -->
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.4</version>
</dependency>
<!-- 可选lombok 简化实体类代码(无需手写 getter/setter -->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
</dependency>
<!-- Spring Boot 测试核心依赖(包含 @SpringBootTest 等注解) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope> <!-- 仅在测试环境生效,不打包到生产环境,不可省略 -->
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-test</artifactId>
</dependency>
</dependencies>
</project>

View File

@@ -0,0 +1,106 @@
package com.zhyc.module.app.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import com.zhyc.module.app.domain.AppErrorLog;
import com.zhyc.module.app.service.IAppErrorLogService;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
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.RestController;
import com.zhyc.common.annotation.Log;
import com.zhyc.common.core.controller.BaseController;
import com.zhyc.common.core.domain.AjaxResult;
import com.zhyc.common.enums.BusinessType;
import com.zhyc.common.utils.poi.ExcelUtil;
import com.zhyc.common.core.page.TableDataInfo;
/**
* App错误日志Controller
*
* @author ruoyi
* @date 2026-01-19
*/
@RestController
@RequestMapping("/app/error")
public class AppErrorLogController extends BaseController
{
@Autowired
private IAppErrorLogService appErrorLogService;
/**
* 查询App错误日志列表
*/
// @PreAuthorize("@ss.hasPermi('app:app:list')")
@GetMapping("/list")
public TableDataInfo list(AppErrorLog appErrorLog)
{
startPage();
List<AppErrorLog> list = appErrorLogService.selectAppErrorLogList(appErrorLog);
return getDataTable(list);
}
/**
* 导出App错误日志列表
*/
// @PreAuthorize("@ss.hasPermi('app:app:export')")
@Log(title = "App错误日志", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, AppErrorLog appErrorLog)
{
List<AppErrorLog> list = appErrorLogService.selectAppErrorLogList(appErrorLog);
ExcelUtil<AppErrorLog> util = new ExcelUtil<AppErrorLog>(AppErrorLog.class);
util.exportExcel(response, list, "App错误日志数据");
}
/**
* 获取App错误日志详细信息
*/
// @PreAuthorize("@ss.hasPermi('app:app:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
return success(appErrorLogService.selectAppErrorLogById(id));
}
/**
* 新增App错误日志
*/
// @PreAuthorize("@ss.hasPermi('app:app:add')")
@Log(title = "App错误日志", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody AppErrorLog appErrorLog)
{
return toAjax(appErrorLogService.insertAppErrorLog(appErrorLog));
}
/**
* 修改App错误日志
*/
// @PreAuthorize("@ss.hasPermi('app:app:edit')")
@Log(title = "App错误日志", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody AppErrorLog appErrorLog)
{
return toAjax(appErrorLogService.updateAppErrorLog(appErrorLog));
}
/**
* 删除App错误日志
*/
// @PreAuthorize("@ss.hasPermi('app:app:remove')")
@Log(title = "App错误日志", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
{
return toAjax(appErrorLogService.deleteAppErrorLogByIds(ids));
}
}

View File

@@ -0,0 +1,106 @@
package com.zhyc.module.app.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import com.zhyc.module.app.domain.AppSettings;
import com.zhyc.module.app.service.IAppSettingsService;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
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.RestController;
import com.zhyc.common.annotation.Log;
import com.zhyc.common.core.controller.BaseController;
import com.zhyc.common.core.domain.AjaxResult;
import com.zhyc.common.enums.BusinessType;
import com.zhyc.common.utils.poi.ExcelUtil;
import com.zhyc.common.core.page.TableDataInfo;
/**
* 应用设置Controller
*
* @author ruoyi
* @date 2026-01-20
*/
@RestController
@RequestMapping("/app/settings")
public class AppSettingsController extends BaseController
{
@Autowired
private IAppSettingsService appSettingsService;
/**
* 查询应用设置列表
*/
// @PreAuthorize("@ss.hasPermi('app:settings:list')")
@GetMapping("/list")
public TableDataInfo list(AppSettings appSettings)
{
startPage();
List<AppSettings> list = appSettingsService.selectAppSettingsList(appSettings);
return getDataTable(list);
}
/**
* 导出应用设置列表
*/
// @PreAuthorize("@ss.hasPermi('app:settings:export')")
@Log(title = "应用设置", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, AppSettings appSettings)
{
List<AppSettings> list = appSettingsService.selectAppSettingsList(appSettings);
ExcelUtil<AppSettings> util = new ExcelUtil<AppSettings>(AppSettings.class);
util.exportExcel(response, list, "应用设置数据");
}
/**
* 获取应用设置详细信息
*/
// @PreAuthorize("@ss.hasPermi('app:settings:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
return success(appSettingsService.selectAppSettingsById(id));
}
/**
* 新增应用设置
*/
// @PreAuthorize("@ss.hasPermi('app:settings:add')")
@Log(title = "应用设置", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody AppSettings appSettings)
{
return toAjax(appSettingsService.insertAppSettings(appSettings));
}
/**
* 修改应用设置
*/
// @PreAuthorize("@ss.hasPermi('app:settings:edit')")
@Log(title = "应用设置", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody AppSettings appSettings)
{
return toAjax(appSettingsService.updateAppSettings(appSettings));
}
/**
* 删除应用设置
*/
// @PreAuthorize("@ss.hasPermi('app:settings:remove')")
@Log(title = "应用设置", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
{
return toAjax(appSettingsService.deleteAppSettingsByIds(ids));
}
}

View File

@@ -0,0 +1,66 @@
package com.zhyc.module.app.controller;
import com.zhyc.common.config.RuoYiConfig;
import com.zhyc.common.core.domain.AjaxResult;
import com.zhyc.module.app.util.OcrRecognizeUtil;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
//图片返回base64
@RestController
@RequestMapping("/app/image")
public class ImageController {
@PostMapping
public AjaxResult getImageBase64(String path) {
// 添加空值检查
if (path == null || path.trim().isEmpty()) {
return AjaxResult.error("路径不能为空");
}
path = path.replace("/profile", "");
try {
// 构建完整的文件路径
String fullPath = RuoYiConfig.getProfile() + path;
// 读取文件并转换为字节数组
byte[] fileBytes = java.nio.file.Files.readAllBytes(java.nio.file.Paths.get(fullPath));
// 将字节数组转换为base64字符串
String base64String = java.util.Base64.getEncoder().encodeToString(fileBytes);
// 获取文件扩展名以确定MIME类型
String mimeType = getMimeType(path);
// 返回base64数据格式为 data:image/xxx;base64,xxxxx
String result = "data:" + mimeType + ";base64," + base64String;
return AjaxResult.success("操作成功",result);
} catch (Exception e) {
return AjaxResult.error("读取图片失败: " + e.getMessage());
}
}
/**
* 根据文件扩展名获取MIME类型
*/
private String getMimeType(String fileName) {
String extension = fileName.substring(fileName.lastIndexOf(".") + 1).toLowerCase();
switch (extension) {
case "jpg":
case "jpeg":
return "image/jpeg";
case "png":
return "image/png";
case "gif":
return "image/gif";
case "bmp":
return "image/bmp";
default:
return "image/jpeg"; // 默认返回jpeg类型
}
}
}

View File

@@ -0,0 +1,50 @@
package com.zhyc.module.app.controller;
import com.zhyc.common.config.RuoYiConfig;
import com.zhyc.common.core.domain.AjaxResult;
import com.zhyc.module.app.util.OcrRecognizeUtil;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.File;
//文字识别
@RestController
@RequestMapping("/ocr")
public class OrcController {
@PostMapping
public AjaxResult orcSheepNo(String path) {
// 添加空值检查
if (path == null || path.trim().isEmpty()) {
return AjaxResult.error("路径不能为空");
}
try {
OcrRecognizeUtil ocrRecognizeUtil = new OcrRecognizeUtil();
// 移除 /profile
path = path.replace("/profile", "");
path = RuoYiConfig.getProfile() + path;
// 验证文件是否存在
File file = new File(path);
if (!file.exists()) {
return AjaxResult.error("文件不存在: " + path);
}
if (!file.isFile()) {
return AjaxResult.error("路径不是一个有效文件: " + path);
}
if (!file.canRead()) {
return AjaxResult.error("无权限读取文件: " + path);
}
String recognize = ocrRecognizeUtil.recognizeTwo(path);
return AjaxResult.success("操作成功", recognize);
} catch (Exception e) {
return AjaxResult.error("OCR识别失败: " + e.getMessage());
}
}
}

View File

@@ -0,0 +1,96 @@
package com.zhyc.module.app.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.zhyc.common.annotation.Excel;
import com.zhyc.common.core.domain.BaseEntity;
/**
* App错误日志对象 app_error_log
*
* @author ruoyi
* @date 2026-01-19
*/
@EqualsAndHashCode(callSuper = true)
@Data
@AllArgsConstructor
@NoArgsConstructor
public class AppErrorLog extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** 主键ID自增 */
private Long id;
/** 设备唯一标识 */
@Excel(name = "设备唯一标识")
private String deviceId;
/** 用户ID */
@Excel(name = "用户ID")
private Long userId;
/** App版本号 */
@Excel(name = "App版本号")
private String appVersion;
/** App版本号 */
@Excel(name = "App版本号")
private Long appCode;
/** 平台类型 */
@Excel(name = "平台类型")
private String platform;
/** 操作系统版本 */
@Excel(name = "操作系统版本")
private String osVersion;
/** 错误类型分类 */
@Excel(name = "错误类型分类")
private String errorType;
/** 错误代码 */
@Excel(name = "错误代码")
private String errorCode;
/** 错误描述信息 */
@Excel(name = "错误描述信息")
private String errorMessage;
/** 错误堆栈跟踪 */
@Excel(name = "错误堆栈跟踪")
private String stackTrace;
/** 页面路径 */
@Excel(name = "页面路径")
private String pageUrl;
/** API接口地址 */
@Excel(name = "API接口地址")
private String apiUrl;
/** API调用参数 */
@Excel(name = "API调用参数")
private String apiParams;
/** 网络类型 */
@Excel(name = "网络类型")
private String networkType;
/** 屏幕宽度 */
@Excel(name = "屏幕宽度")
private Long screenWidth;
/** 屏幕高度 */
@Excel(name = "屏幕高度")
private Long screenHeight;
/** 自定义扩展数据JSON格式 */
@Excel(name = "自定义扩展数据JSON格式")
private String customData;
}

View File

@@ -0,0 +1,71 @@
package com.zhyc.module.app.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.zhyc.common.annotation.Excel;
import com.zhyc.common.core.domain.BaseEntity;
/**
* 应用设置对象 app_settings
*
* @author ruoyi
* @date 2026-01-20
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class AppSettings extends BaseEntity
{
private static final long serialVersionUID = 1L;
/** 主键ID */
private Long id;
/** 用户ID0为全局 */
@Excel(name = "用户ID0为全局")
private Long userId;
/** 设置键名 */
@Excel(name = "设置键名")
private String settingKey;
/** 设置 */
@Excel(name = "设置")
private String settingValue;
/** 值类型 */
@Excel(name = "值类型")
private String settingType;
/** 设置分组 */
@Excel(name = "设置分组")
private String settingGroup;
/** 设置描述 */
@Excel(name = "设置描述")
private String settingDesc;
/** 适用平台 */
@Excel(name = "适用平台")
private String platform;
/** 适用版本范围 */
@Excel(name = "适用版本范围")
private String versionRange;
/** 状态 */
@Excel(name = "状态")
private Integer status;
/** 逻辑位 */
@Excel(name = "逻辑位")
private Integer logical;
/** 自定义扩展数据JSON格式 */
@Excel(name = "自定义扩展数据JSON格式")
private String customData;
}

View File

@@ -0,0 +1,64 @@
package com.zhyc.module.app.mapper;
import java.util.List;
import com.zhyc.module.app.domain.AppErrorLog;
import org.apache.ibatis.annotations.Mapper;
/**
* App错误日志Mapper接口
*
* @author ruoyi
* @date 2026-01-19
*/
@Mapper
public interface AppErrorLogMapper
{
/**
* 查询App错误日志
*
* @param id App错误日志主键
* @return App错误日志
*/
public AppErrorLog selectAppErrorLogById(Long id);
/**
* 查询App错误日志列表
*
* @param appErrorLog App错误日志
* @return App错误日志集合
*/
public List<AppErrorLog> selectAppErrorLogList(AppErrorLog appErrorLog);
/**
* 新增App错误日志
*
* @param appErrorLog App错误日志
* @return 结果
*/
public int insertAppErrorLog(AppErrorLog appErrorLog);
/**
* 修改App错误日志
*
* @param appErrorLog App错误日志
* @return 结果
*/
public int updateAppErrorLog(AppErrorLog appErrorLog);
/**
* 删除App错误日志
*
* @param id App错误日志主键
* @return 结果
*/
public int deleteAppErrorLogById(Long id);
/**
* 批量删除App错误日志
*
* @param ids 需要删除的数据主键集合
* @return 结果
*/
public int deleteAppErrorLogByIds(Long[] ids);
}

View File

@@ -0,0 +1,62 @@
package com.zhyc.module.app.mapper;
import com.zhyc.module.app.domain.AppSettings;
import java.util.List;
/**
* 应用设置Mapper接口
*
* @author ruoyi
* @date 2026-01-20
*/
public interface AppSettingsMapper
{
/**
* 查询应用设置
*
* @param id 应用设置主键
* @return 应用设置
*/
public AppSettings selectAppSettingsById(Long id);
/**
* 查询应用设置列表
*
* @param appSettings 应用设置
* @return 应用设置集合
*/
public List<AppSettings> selectAppSettingsList(AppSettings appSettings);
/**
* 新增应用设置
*
* @param appSettings 应用设置
* @return 结果
*/
public int insertAppSettings(AppSettings appSettings);
/**
* 修改应用设置
*
* @param appSettings 应用设置
* @return 结果
*/
public int updateAppSettings(AppSettings appSettings);
/**
* 删除应用设置
*
* @param id 应用设置主键
* @return 结果
*/
public int deleteAppSettingsById(Long id);
/**
* 批量删除应用设置
*
* @param ids 需要删除的数据主键集合
* @return 结果
*/
public int deleteAppSettingsByIds(Long[] ids);
}

View File

@@ -0,0 +1,62 @@
package com.zhyc.module.app.service;
import com.zhyc.module.app.domain.AppErrorLog;
import java.util.List;
/**
* App错误日志Service接口
*
* @author ruoyi
* @date 2026-01-19
*/
public interface IAppErrorLogService
{
/**
* 查询App错误日志
*
* @param id App错误日志主键
* @return App错误日志
*/
public AppErrorLog selectAppErrorLogById(Long id);
/**
* 查询App错误日志列表
*
* @param appErrorLog App错误日志
* @return App错误日志集合
*/
public List<AppErrorLog> selectAppErrorLogList(AppErrorLog appErrorLog);
/**
* 新增App错误日志
*
* @param appErrorLog App错误日志
* @return 结果
*/
public int insertAppErrorLog(AppErrorLog appErrorLog);
/**
* 修改App错误日志
*
* @param appErrorLog App错误日志
* @return 结果
*/
public int updateAppErrorLog(AppErrorLog appErrorLog);
/**
* 批量删除App错误日志
*
* @param ids 需要删除的App错误日志主键集合
* @return 结果
*/
public int deleteAppErrorLogByIds(Long[] ids);
/**
* 删除App错误日志信息
*
* @param id App错误日志主键
* @return 结果
*/
public int deleteAppErrorLogById(Long id);
}

View File

@@ -0,0 +1,63 @@
package com.zhyc.module.app.service;
import com.zhyc.module.app.domain.AppSettings;
import java.util.List;
/**
* 应用设置Service接口
*
* @author ruoyi
* @date 2026-01-20
*/
public interface IAppSettingsService
{
/**
* 查询应用设置
*
* @param id 应用设置主键
* @return 应用设置
*/
public AppSettings selectAppSettingsById(Long id);
/**
* 查询应用设置列表
*
* @param appSettings 应用设置
* @return 应用设置集合
*/
public List<AppSettings> selectAppSettingsList(AppSettings appSettings);
/**
* 新增应用设置
*
* @param appSettings 应用设置
* @return 结果
*/
public int insertAppSettings(AppSettings appSettings);
/**
* 修改应用设置
*
* @param appSettings 应用设置
* @return 结果
*/
public int updateAppSettings(AppSettings appSettings);
/**
* 批量删除应用设置
*
* @param ids 需要删除的应用设置主键集合
* @return 结果
*/
public int deleteAppSettingsByIds(Long[] ids);
/**
* 删除应用设置信息
*
* @param id 应用设置主键
* @return 结果
*/
public int deleteAppSettingsById(Long id);
}

View File

@@ -0,0 +1,97 @@
package com.zhyc.module.app.service.impl;
import java.util.List;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.module.app.domain.AppErrorLog;
import com.zhyc.module.app.mapper.AppErrorLogMapper;
import com.zhyc.module.app.service.IAppErrorLogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* App错误日志Service业务层处理
*
* @author ruoyi
* @date 2026-01-19
*/
@Service
public class AppErrorLogServiceImpl implements IAppErrorLogService
{
@Autowired
private AppErrorLogMapper appErrorLogMapper;
/**
* 查询App错误日志
*
* @param id App错误日志主键
* @return App错误日志
*/
@Override
public AppErrorLog selectAppErrorLogById(Long id)
{
return appErrorLogMapper.selectAppErrorLogById(id);
}
/**
* 查询App错误日志列表
*
* @param appErrorLog App错误日志
* @return App错误日志
*/
@Override
public List<AppErrorLog> selectAppErrorLogList(AppErrorLog appErrorLog)
{
return appErrorLogMapper.selectAppErrorLogList(appErrorLog);
}
/**
* 新增App错误日志
*
* @param appErrorLog App错误日志
* @return 结果
*/
@Override
public int insertAppErrorLog(AppErrorLog appErrorLog)
{
appErrorLog.setCreateTime(DateUtils.getNowDate());
return appErrorLogMapper.insertAppErrorLog(appErrorLog);
}
/**
* 修改App错误日志
*
* @param appErrorLog App错误日志
* @return 结果
*/
@Override
public int updateAppErrorLog(AppErrorLog appErrorLog)
{
return appErrorLogMapper.updateAppErrorLog(appErrorLog);
}
/**
* 批量删除App错误日志
*
* @param ids 需要删除的App错误日志主键
* @return 结果
*/
@Override
public int deleteAppErrorLogByIds(Long[] ids)
{
return appErrorLogMapper.deleteAppErrorLogByIds(ids);
}
/**
* 删除App错误日志信息
*
* @param id App错误日志主键
* @return 结果
*/
@Override
public int deleteAppErrorLogById(Long id)
{
return appErrorLogMapper.deleteAppErrorLogById(id);
}
}

View File

@@ -0,0 +1,96 @@
package com.zhyc.module.app.service.impl;
import java.util.List;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.module.app.domain.AppSettings;
import com.zhyc.module.app.mapper.AppSettingsMapper;
import com.zhyc.module.app.service.IAppSettingsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* 应用设置Service业务层处理
*
* @author ruoyi
* @date 2026-01-20
*/
@Service
public class AppSettingsServiceImpl implements IAppSettingsService
{
@Autowired
private AppSettingsMapper appSettingsMapper;
/**
* 查询应用设置
*
* @param id 应用设置主键
* @return 应用设置
*/
@Override
public AppSettings selectAppSettingsById(Long id)
{
return appSettingsMapper.selectAppSettingsById(id);
}
/**
* 查询应用设置列表
*
* @param appSettings 应用设置
* @return 应用设置
*/
@Override
public List<AppSettings> selectAppSettingsList(AppSettings appSettings)
{
return appSettingsMapper.selectAppSettingsList(appSettings);
}
/**
* 新增应用设置
*
* @param appSettings 应用设置
* @return 结果
*/
@Override
public int insertAppSettings(AppSettings appSettings)
{
appSettings.setCreateTime(DateUtils.getNowDate());
return appSettingsMapper.insertAppSettings(appSettings);
}
/**
* 修改应用设置
*
* @param appSettings 应用设置
* @return 结果
*/
@Override
public int updateAppSettings(AppSettings appSettings)
{
appSettings.setUpdateTime(DateUtils.getNowDate());
return appSettingsMapper.updateAppSettings(appSettings);
}
/**
* 批量删除应用设置
*
* @param ids 需要删除的应用设置主键
* @return 结果
*/
@Override
public int deleteAppSettingsByIds(Long[] ids)
{
return appSettingsMapper.deleteAppSettingsByIds(ids);
}
/**
* 删除应用设置信息
*
* @param id 应用设置主键
* @return 结果
*/
@Override
public int deleteAppSettingsById(Long id)
{
return appSettingsMapper.deleteAppSettingsById(id);
}
}

View File

@@ -0,0 +1,257 @@
package com.zhyc.module.app.util;
import ai.djl.modality.cv.Image;
import cn.smartjavaai.common.cv.SmartImageFactory;
import cn.smartjavaai.common.enums.DeviceEnum;
import cn.smartjavaai.common.utils.ImageUtils;
import cn.smartjavaai.ocr.config.DirectionModelConfig;
import cn.smartjavaai.ocr.config.OcrDetModelConfig;
import cn.smartjavaai.ocr.config.OcrRecModelConfig;
import cn.smartjavaai.ocr.config.OcrRecOptions;
import cn.smartjavaai.ocr.entity.OcrInfo;
import cn.smartjavaai.ocr.enums.CommonDetModelEnum;
import cn.smartjavaai.ocr.enums.CommonRecModelEnum;
import cn.smartjavaai.ocr.enums.DirectionModelEnum;
import cn.smartjavaai.ocr.factory.OcrModelFactory;
import cn.smartjavaai.ocr.model.common.detect.OcrCommonDetModel;
import cn.smartjavaai.ocr.model.common.direction.OcrDirectionModel;
import cn.smartjavaai.ocr.model.common.recognize.OcrCommonRecModel;
import com.alibaba.fastjson.JSONObject;
import com.zhyc.common.config.RuoYiConfig;
import lombok.extern.slf4j.Slf4j;
import org.junit.BeforeClass;
import org.junit.Test;
import java.io.File;
import java.io.IOException;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.List;
/**
* OCR 文本识别 示例
* 模型下载地址https://pan.baidu.com/s/1MLfd73Vjdpnuls9-oqc9uw?pwd=1234 提取码: 1234
* 开发文档http://doc.smartjavaai.cn/
*/
/**
* OCR识别工具类
* 提供文本识别相关的功能,包括获取不同类型的识别模型、文本检测模型、方向检测模型等
* 支持普通识别、手写识别、带方向矫正的识别以及批量识别等功能
*/
@Slf4j
public class OcrRecognizeUtil {
//设备类型
public static DeviceEnum device =DeviceEnum.CPU;
/**
* 测试初始化方法,在所有测试用例执行前调用一次
* 设置SmartImageFactory使用的引擎为OpenCV并可选配置缓存路径
*
* @throws IOException 当初始化过程中发生IO异常时抛出
*/
@BeforeClass
public static void beforeAll() throws IOException {
SmartImageFactory.setEngine(SmartImageFactory.Engine.OPENCV);
//修改缓存路径
//Config.setCachePath("/Users/xxx/smartjavaai_cache");
}
/**
* 获取通用识别模型(高精确度模型)
* 注意事项:高精度模型,识别准确度高,速度慢
*
* @return 返回高精度的OCR通用识别模型实例
*/
public OcrCommonRecModel getProRecModel(){
OcrRecModelConfig recModelConfig = new OcrRecModelConfig();
//指定文本识别模型切换模型需要同时修改modelEnum及modelPath
recModelConfig.setRecModelEnum(CommonRecModelEnum.PP_OCR_V5_SERVER_REC_MODEL);
//指定识别模型位置,需要更改为自己的模型路径(下载地址请查看文档)
recModelConfig.setRecModelPath("C:/wwwroot/ocr/rec/PP-OCRv5_server_rec_infer/PP-OCRv5_server_rec.onnx");
recModelConfig.setDevice(device);
recModelConfig.setTextDetModel(getProDetectionModel());
recModelConfig.setDirectionModel(getDirectionModel());
return OcrModelFactory.getInstance().getRecModel(recModelConfig);
}
/**
* 获取通用识别模型(极速模型)
* 注意事项:极速模型,识别准确度低,速度快
*
* @return 返回极速的OCR通用识别模型实例
*/
public OcrCommonRecModel getFastRecModel(){
OcrRecModelConfig recModelConfig = new OcrRecModelConfig();
//指定文本识别模型切换模型需要同时修改modelEnum及modelPath
recModelConfig.setRecModelEnum(CommonRecModelEnum.PP_OCR_V5_MOBILE_REC_MODEL);
//指定识别模型位置,需要更改为自己的模型路径(下载地址请查看文档)
recModelConfig.setRecModelPath("C:/wwwroot/ocr/rec/PP-OCRv5_mobile_rec_infer/PP-OCRv5_mobile_rec_infer.onnx");
recModelConfig.setDevice(device);
recModelConfig.setTextDetModel(getFastDetectionModel());
recModelConfig.setDirectionModel(getDirectionModel()); // 添加方向模型配置
return OcrModelFactory.getInstance().getRecModel(recModelConfig);
}
/**
* 获取文本检测模型(极速模型)
* 注意事项:极速模型,识别准确度低,速度快
*
* @return 返回极速的OCR通用检测模型实例
*/
public OcrCommonDetModel getFastDetectionModel() {
OcrDetModelConfig config = new OcrDetModelConfig();
//指定检测模型切换模型需要同时修改modelEnum及modelPath
config.setModelEnum(CommonDetModelEnum.PP_OCR_V5_MOBILE_DET_MODEL);
//指定模型位置,需要更改为自己的模型路径(下载地址请查看文档)
config.setDetModelPath("C:/wwwroot/ocr/det/PP-OCRv5_mobile_det_infer/PP-OCRv5_mobile_det_infer.onnx");
config.setDevice(device);
return OcrModelFactory.getInstance().getDetModel(config);
}
/**
* 获取文本检测模型(高精确度模型)
* 注意事项:高精度模型,识别准确度高,速度慢
*
* @return 返回高精度的OCR通用检测模型实例
*/
public OcrCommonDetModel getProDetectionModel() {
OcrDetModelConfig config = new OcrDetModelConfig();
//指定检测模型切换模型需要同时修改modelEnum及modelPath
config.setModelEnum(CommonDetModelEnum.PP_OCR_V5_SERVER_DET_MODEL);
//指定模型位置,需要更改为自己的模型路径(下载地址请查看文档)
config.setDetModelPath("C:/wwwroot/ocr/det/PP-OCRv5_server_det_infer/PP-OCRv5_server_det.onnx");
config.setDevice(device);
return OcrModelFactory.getInstance().getDetModel(config);
}
/**
* 获取方向检测模型
*
* @return 返回OCR方向检测模型实例
*/
public OcrDirectionModel getDirectionModel(){
DirectionModelConfig directionModelConfig = new DirectionModelConfig();
//指定行文本方向检测模型切换模型需要同时修改modelEnum及modelPath
directionModelConfig.setModelEnum(DirectionModelEnum.PP_LCNET_X0_25);
//指定行文本方向检测模型路径,需要更改为自己的模型路径(下载地址请查看文档)
directionModelConfig.setModelPath("C:/wwwroot/ocr/ori/PP-LCNet_x0_25_textline_ori_infer.onnx");
directionModelConfig.setDevice(device);
return OcrModelFactory.getInstance().getDirectionModel(directionModelConfig);
}
/**
* 文本识别
* 支持简体中文、繁体中文、英文、日文四种主要语言,以及手写、竖版、拼音、生僻字
* 流程:文本检测 -> 文本识别
* 注意事项:
* 1、批量检测时模型应统一放在外层 try 中使用,避免重复加载,自动释放资源更安全。
* 2、模型文件需要放在单独文件夹
*/
public String recognize(String path){
try {
OcrCommonRecModel recModel = getFastRecModel();
//不带方向矫正,分行返回文本
OcrRecOptions options = new OcrRecOptions(false, true);
//创建Image对象可以从文件、url、InputStream创建、BufferedImage、Base64创建具体使用方法可以查看文档
Image image = SmartImageFactory.getInstance().fromFile(path);
OcrInfo ocrInfo = recModel.recognize(image, options);
log.info("OCR识别结果{}", JSONObject.toJSONString(ocrInfo.getFullText()));
// 识别成功后删除原图片
deleteFile(path);
return ocrInfo.getFullText();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 文本识别(手写字)
* 支持简体中文、繁体中文、英文、日文四种主要语言,以及手写、竖版、拼音、生僻字
* 流程:文本检测 -> 文本识别
* 注意事项:
* 1、批量检测时模型应统一放在外层 try 中使用,避免重复加载,自动释放资源更安全。
* 2、模型文件需要放在单独文件夹
* 3、识别完成后会删除原图片文件
*/
public void recognizeHandWriting(String path){
try {
OcrCommonRecModel recModel = getFastRecModel();
//创建Image对象可以从文件、url、InputStream创建、BufferedImage、Base64创建具体使用方法可以查看文档
Image image = SmartImageFactory.getInstance().fromFile(path);
OcrInfo ocrInfo = recModel.recognize(image, new OcrRecOptions());
log.info("OCR识别结果{}", JSONObject.toJSONString(ocrInfo));
// 识别成功后删除原图片
deleteFile(path);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 文本识别(带方向矫正)
* 支持简体中文、繁体中文、英文、日文四种主要语言,以及手写、竖版、拼音、生僻字
* 本方法支持多角度文字识别
* 流程:文本检测 -> 方向检测 -> 方向矫正 -> 文本识别
* 注意事项:
* 1、批量检测时模型应统一放在外层 try 中使用,避免重复加载,自动释放资源更安全。
* 2、模型文件需要放在单独文件夹
* 3、识别完成后会删除原图片文件
*/
public String recognizeTwo(String path){
try {
OcrCommonRecModel recModel = getFastRecModel();
//带方向矫正,分行返回文本
OcrRecOptions options = new OcrRecOptions(true, true);
//创建Image对象可以从文件、url、InputStream创建、BufferedImage、Base64创建具体使用方法可以查看文档
Image image = SmartImageFactory.getInstance().fromFile(path);
OcrInfo ocrInfo = recModel.recognize(image, options);
log.info("OCR识别结果{}", JSONObject.toJSONString(ocrInfo));
// 识别成功后删除原图片
deleteFile(path);
return ocrInfo.getFullText();
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 删除指定路径的文件
*
* @param filePath 要删除的文件路径
* @return 删除是否成功
*/
private boolean deleteFile(String filePath) {
try {
File file = new File(filePath);
if (file.exists()) {
boolean deleted = file.delete();
if (deleted) {
log.info("已删除文件: {}", filePath);
} else {
log.warn("删除文件失败: {}", filePath);
}
return deleted;
} else {
log.warn("文件不存在: {}", filePath);
return false;
}
} catch (Exception e) {
log.error("删除文件时发生异常: {}", filePath, e);
return false;
}
}
}

View File

@@ -46,6 +46,18 @@ public class BasSheepController extends BaseController {
return getDataTable(list);
}
//查询耳号列表
@GetMapping("/earNumbers")
public AjaxResult searchEarNumbers(@RequestParam("query") String query) {
try {
List<String> earNumbers =basSheepService.searchEarNumbers(query);
return success(earNumbers);
} catch (Exception e) {
logger.error("搜索耳号异常", e);
return error("搜索耳号失败:" + e.getMessage());
}
}
/**
* 导出羊只基本信息列表
*/

View File

@@ -41,7 +41,7 @@ public class BasSheepTypeController extends BaseController
/**
* 查询羊只类型列表
*/
@PreAuthorize("@ss.hasPermi('base:base:list')")
// @PreAuthorize("@ss.hasPermi('base:base:list')")
@GetMapping("/list")
public TableDataInfo list(BasSheepType basSheepType)
{
@@ -53,7 +53,7 @@ public class BasSheepTypeController extends BaseController
/**
* 导出羊只类型列表
*/
@PreAuthorize("@ss.hasPermi('base:base:export')")
// @PreAuthorize("@ss.hasPermi('base:base:export')")
@Log(title = "羊只类型", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, BasSheepType basSheepType)
@@ -66,7 +66,7 @@ public class BasSheepTypeController extends BaseController
/**
* 获取羊只类型详细信息
*/
@PreAuthorize("@ss.hasPermi('base:base:query')")
// @PreAuthorize("@ss.hasPermi('base:base:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Integer id)
{
@@ -76,7 +76,7 @@ public class BasSheepTypeController extends BaseController
/**
* 新增羊只类型
*/
@PreAuthorize("@ss.hasPermi('base:base:add')")
// @PreAuthorize("@ss.hasPermi('base:base:add')")
@Log(title = "羊只类型", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody BasSheepType basSheepType)
@@ -87,7 +87,7 @@ public class BasSheepTypeController extends BaseController
/**
* 修改羊只类型
*/
@PreAuthorize("@ss.hasPermi('base:base:edit')")
// @PreAuthorize("@ss.hasPermi('base:base:edit')")
@Log(title = "羊只类型", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody BasSheepType basSheepType)
@@ -98,7 +98,7 @@ public class BasSheepTypeController extends BaseController
/**
* 删除羊只类型
*/
@PreAuthorize("@ss.hasPermi('base:base:remove')")
// @PreAuthorize("@ss.hasPermi('base:base:remove')")
@Log(title = "羊只类型", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Integer[] ids)

View File

@@ -42,7 +42,7 @@ public class DaRanchController extends BaseController
/**
* 查询牧场管理列表
*/
@PreAuthorize("@ss.hasPermi('ranch:ranch:list')")
// @PreAuthorize("@ss.hasPermi('ranch:ranch:list')")
@GetMapping("/list")
public TableDataInfo list(DaRanch daRanch)
{
@@ -54,7 +54,7 @@ public class DaRanchController extends BaseController
/**
* 导出牧场管理列表
*/
@PreAuthorize("@ss.hasPermi('ranch:ranch:export')")
// @PreAuthorize("@ss.hasPermi('ranch:ranch:export')")
@Log(title = "牧场管理", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, DaRanch daRanch)
@@ -67,7 +67,7 @@ public class DaRanchController extends BaseController
/**
* 获取牧场管理详细信息
*/
@PreAuthorize("@ss.hasPermi('ranch:ranch:query')")
// @PreAuthorize("@ss.hasPermi('ranch:ranch:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -77,7 +77,7 @@ public class DaRanchController extends BaseController
/**
* 获取指定牧场下的所有羊只耳号
*/
@GetMapping("/getSheepByRanchId/{ranchId}")
// @GetMapping("/getSheepByRanchId/{ranchId}")
public AjaxResult getSheepByRanchId(@PathVariable Long ranchId) {
List<BasSheep> sheepList = basSheepService.getSheepByRanchId(ranchId);
return AjaxResult.success(sheepList);
@@ -87,7 +87,7 @@ public class DaRanchController extends BaseController
/**
* 新增牧场管理
*/
@PreAuthorize("@ss.hasPermi('ranch:ranch:add')")
// @PreAuthorize("@ss.hasPermi('ranch:ranch:add')")
@Log(title = "牧场管理", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody DaRanch daRanch)
@@ -98,7 +98,7 @@ public class DaRanchController extends BaseController
/**
* 修改牧场管理
*/
@PreAuthorize("@ss.hasPermi('ranch:ranch:edit')")
// @PreAuthorize("@ss.hasPermi('ranch:ranch:edit')")
@Log(title = "牧场管理", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody DaRanch daRanch)
@@ -109,7 +109,7 @@ public class DaRanchController extends BaseController
/**
* 删除牧场管理
*/
@PreAuthorize("@ss.hasPermi('ranch:ranch:remove')")
// @PreAuthorize("@ss.hasPermi('ranch:ranch:remove')")
@Log(title = "牧场管理", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)

View File

@@ -70,6 +70,15 @@ public interface BasSheepMapper
BasSheep selectBasSheepByManageTags(String manageTags);
/**
* 模糊查询母羊耳号列表
*
* @param query 查询关键字
* @return 耳号列表
*/
List<String> searchEarNumbers(@Param("query") String query);
List<BasSheep> selectBasSheepBySheepfold(String id);
// 根据牧场ID获取羊只列表

View File

@@ -28,6 +28,13 @@ public interface IBasSheepService
*/
public List<BasSheep> selectBasSheepList(BasSheep basSheep);
/**
* 羊只查询耳号信息
*
* @param earNumbers 耳号
* @return 结果
*/
public List<String> searchEarNumbers(String earNumbers);
/**
* 新增羊只基本信息
*

View File

@@ -1,6 +1,8 @@
package com.zhyc.module.base.service.impl;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.module.base.domain.BasSheep;
import com.zhyc.module.base.mapper.BasSheepMapper;
@@ -44,6 +46,17 @@ public class BasSheepServiceImpl implements IBasSheepService
return basSheepMapper.selectBasSheepList(basSheep);
}
/**
* 搜索羊只 earNumbers
*
* @param query
* @return
*/
@Override
@DataScope(deptAlias = "b", userAlias = "b")
public List<String> searchEarNumbers(String query) {
return basSheepMapper.searchEarNumbers(query);
}
/**
* 新增羊只基本信息
*

View File

@@ -78,7 +78,8 @@ public class DewormController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody Deworm deworm)
{
System.out.println(deworm);
deworm.setDeptId(getDeptId());
deworm.setUserId(getUserId());
return toAjax(dewormService.insertDeworm(deworm));
}

View File

@@ -77,6 +77,8 @@ public class DiagnosisController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody Diagnosis diagnosis)
{
diagnosis.setDeptId(getDeptId());
diagnosis.setUserId(getUserId());
return toAjax(diagnosisService.insertDiagnosis(diagnosis));
}

View File

@@ -78,6 +78,8 @@ public class DisinfectController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody Disinfect disinfect)
{
disinfect.setDeptId(getDeptId());
disinfect.setUserId(getUserId());
return toAjax(disinfectService.insertDisinfect(disinfect));
}

View File

@@ -79,6 +79,8 @@ public class HealthController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody Health health)
{
health.setDeptId(getDeptId());
health.setUserId(getUserId());
return toAjax(healthService.insertHealth(health));
}

View File

@@ -78,6 +78,8 @@ public class ImmunityController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody Immunity immunity)
{
immunity.setDeptId(getDeptId());
immunity.setUserId(getUserId());
return toAjax(immunityService.insertImmunity(immunity));
}

View File

@@ -78,6 +78,8 @@ public class QuarantineReportController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody QuarantineReport quarantineReport)
{
quarantineReport.setDeptId(getDeptId());
quarantineReport.setUserId(getUserId());
return toAjax(quarantineReportService.insertQuarantineReport(quarantineReport));
}

View File

@@ -37,7 +37,7 @@ public class SwDiseaseController extends BaseController
/**
* 查询疾病列表
*/
@PreAuthorize("@ss.hasPermi('disease:disease:list')")
@PreAuthorize("@ss.hasPermi('biosafety:disease:list')")
@GetMapping("/list")
public AjaxResult list(SwDisease swDisease)
{
@@ -48,7 +48,7 @@ public class SwDiseaseController extends BaseController
/**
* 导出疾病列表
*/
@PreAuthorize("@ss.hasPermi('disease:disease:export')")
@PreAuthorize("@ss.hasPermi('biosafety:disease:export')")
@Log(title = "疾病", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, SwDisease swDisease)
@@ -61,7 +61,7 @@ public class SwDiseaseController extends BaseController
/**
* 获取疾病详细信息
*/
@PreAuthorize("@ss.hasPermi('disease:disease:query')")
@PreAuthorize("@ss.hasPermi('biosafety:disease:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -71,7 +71,7 @@ public class SwDiseaseController extends BaseController
/**
* 新增疾病
*/
@PreAuthorize("@ss.hasPermi('disease:disease:add')")
@PreAuthorize("@ss.hasPermi('biosafety:disease:add')")
@Log(title = "疾病", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody SwDisease swDisease)
@@ -82,7 +82,7 @@ public class SwDiseaseController extends BaseController
/**
* 修改疾病
*/
@PreAuthorize("@ss.hasPermi('disease:disease:edit')")
@PreAuthorize("@ss.hasPermi('biosafety:disease:edit')")
@Log(title = "疾病", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody SwDisease swDisease)
@@ -93,7 +93,7 @@ public class SwDiseaseController extends BaseController
/**
* 删除疾病
*/
@PreAuthorize("@ss.hasPermi('disease:disease:remove')")
@PreAuthorize("@ss.hasPermi('biosafety:disease:remove')")
@Log(title = "疾病", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)

View File

@@ -84,6 +84,8 @@ public class SwMedicineUsageController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody SwMedicineUsage swMedicineUsage)
{
swMedicineUsage.setDeptId(getDeptId());
swMedicineUsage.setUserId(getUserId());
return toAjax(swMedicineUsageService.insertSwMedicineUsage(swMedicineUsage));
}

View File

@@ -78,6 +78,8 @@ public class TreatmentController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody Treatment treatment)
{
treatment.setDeptId(getDeptId());
treatment.setUserId(getUserId());
return toAjax(treatmentService.insertTreatment(treatment));
}

View File

@@ -34,6 +34,10 @@ public class Deworm extends BaseEntity
/** 羊只id */
@Excel(name = "羊只耳号")
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
@Excel(name = "品种")
private String variety;
@Excel(name = "羊只类别")
@@ -50,7 +54,8 @@ public class Deworm extends BaseEntity
@Excel(name = "胎次")
private Long parity;
private Long userId;
private Long deptId;
/** 药品使用记录 */
@Excel(name = "药品使用记录")
@@ -73,11 +78,9 @@ public class Deworm extends BaseEntity
@Excel(name = "备注")
private String comment;
// public void setGender(String gender) {
// this.gender = gender;
// this.genderName = Gender.getDescByCode(Integer.valueOf(gender));
// }
// 排序查询
private String orderByColumn;
private String isAsc;
}

View File

@@ -1,6 +1,8 @@
package com.zhyc.module.biosafety.domain;
import java.util.Date;
import java.util.List;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.zhyc.module.enums.Gender;
import lombok.AllArgsConstructor;
@@ -37,6 +39,10 @@ public class Diagnosis extends BaseEntity
/** 羊只id */
@Excel(name = "羊只耳号")
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
private Long sheepId;
@@ -96,12 +102,26 @@ public class Diagnosis extends BaseEntity
private Long sheepfoldId;
public void setGender(String gender) {
this.gender = gender;
this.genderName = Gender.getDescByCode(Integer.valueOf(gender));
}
// 排序查询
private String orderByColumn;
private String isAsc;
private Long userId;
private Long deptId;
public void setGender(String gender) {
this.gender = gender;
if (gender != null && !gender.trim().isEmpty()) {
try {
Integer genderCode = Integer.valueOf(gender.trim());
this.genderName = Gender.getDescByCode(genderCode);
} catch (NumberFormatException e) {
// 如果转换失败,设置为空或默认值
this.genderName = null;
}
} else {
this.genderName = null;
}
}
}

View File

@@ -61,6 +61,9 @@ public class Disinfect extends BaseEntity
/** 药品名称用于查询*/
private String mediName;
private Long userId;
private Long deptId;
// 药品使用
private List<SwMedicineUsageDetails> usageDetails;

View File

@@ -31,12 +31,16 @@ public class Health extends BaseEntity
/** 羊只id */
@Excel(name = "羊只id")
private Long sheepId;
private Integer[] sheepIds;
/** 羊只id */
@Excel(name = "羊只耳号")
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
@Excel(name = "品种")
private String variety;
@Excel(name = "羊只类别")
@@ -65,14 +69,29 @@ public class Health extends BaseEntity
@Excel(name = "备注")
private String comment;
private Long userId;
private Long deptId;
// 药品使用
private List<SwMedicineUsageDetails> usageDetails;
public void setGender(String gender) {
this.gender = gender;
this.genderName = Gender.getDescByCode(Integer.valueOf(gender));
}
// 排序查询
private String orderByColumn;
private String isAsc;
public void setGender(String gender) {
this.gender = gender;
if (gender != null && !gender.trim().isEmpty()) {
try {
Integer genderCode = Integer.valueOf(gender.trim());
this.genderName = Gender.getDescByCode(genderCode);
} catch (NumberFormatException e) {
// 如果转换失败,设置为空或默认值
this.genderName = null;
}
} else {
this.genderName = null;
}
}
}

View File

@@ -36,6 +36,11 @@ public class Immunity extends BaseEntity
/** 羊只id */
@Excel(name = "羊只耳号")
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
@Excel(name = "品种")
private String variety;
@@ -73,14 +78,29 @@ public class Immunity extends BaseEntity
@Excel(name = "备注")
private String comment;
private Long userId;
private Long deptId;
// 药品使用
private List<SwMedicineUsageDetails> usageDetails;
public void setGender(String gender) {
this.gender = gender;
this.genderName = Gender.getDescByCode(Integer.valueOf(gender));
}
// 排序查询
private String orderByColumn;
private String isAsc;
public void setGender(String gender) {
this.gender = gender;
if (gender != null && !gender.trim().isEmpty()) {
try {
Integer genderCode = Integer.valueOf(gender.trim());
this.genderName = Gender.getDescByCode(genderCode);
} catch (NumberFormatException e) {
// 如果转换失败,设置为空或默认值
this.genderName = null;
}
} else {
this.genderName = null;
}
}
}

View File

@@ -1,6 +1,8 @@
package com.zhyc.module.biosafety.domain;
import java.util.Date;
import java.util.List;
import com.fasterxml.jackson.annotation.JsonFormat;
import com.zhyc.module.enums.Gender;
import lombok.AllArgsConstructor;
@@ -36,6 +38,11 @@ public class QuarantineReport extends BaseEntity
@Excel(name = "羊只耳号")
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
@Excel(name = "羊只类别")
private String sheepType;
@Excel(name = "羊只性别")
@@ -91,6 +98,9 @@ public class QuarantineReport extends BaseEntity
@Excel(name = "备注")
private String comment;
private Long userId;
private Long deptId;
public void setGender(String gender) {
this.gender = gender;
this.genderName = Gender.getDescByCode(Integer.valueOf(gender));

View File

@@ -38,6 +38,11 @@ public class SwMedicineUsage extends BaseEntity
/** 耳号 */
@Excel(name = "耳号",width = 20, needMerge = true)
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
private Integer sheepId;
/** 使用时间 */
@JsonFormat(pattern = "yyyy-MM-dd")
@@ -48,6 +53,9 @@ public class SwMedicineUsage extends BaseEntity
@Excel(name = "使用类型",width = 20, needMerge = true)
private String useType;
private Long userId;
private Long deptId;
/** 药品使用记录详情信息 */
@Excel
private List<SwMedicineUsageDetails> swMedicineUsageDetailsList;

View File

@@ -32,6 +32,10 @@ public class Treatment extends BaseEntity
/** 羊只耳号 */
@Excel(name = "羊只耳号")
private String sheepNo;
private String[] sheepNos;
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
private Long sheepId;
// 用于批量新增
@@ -100,6 +104,9 @@ public class Treatment extends BaseEntity
@Excel(name = "药品使用记录id")
private Integer usageId;
private Long userId;
private Long deptId;
// 药品使用
private List<SwMedicineUsageDetails> usageDetails;

View File

@@ -1,7 +1,10 @@
package com.zhyc.module.biosafety.service.impl;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.common.utils.bean.BeanUtils;
@@ -57,8 +60,18 @@ public class DewormServiceImpl implements IDewormService
* @return 驱虫
*/
@Override
@DataScope(deptAlias = "s", userAlias = "s")
public List<Deworm> selectDewormList(Deworm deworm)
{
String[] sheepNos = null;
if (deworm.getSheepNo() != null && !deworm.getSheepNo().isEmpty()) {
if (deworm.getSheepNo().contains(" ")) {
sheepNos = deworm.getSheepNo().split(" ");
deworm.setSheepNos(sheepNos);
deworm.setSheepNo(null);
}
}
return dewormMapper.selectDewormList(deworm);
}
@@ -90,12 +103,12 @@ public class DewormServiceImpl implements IDewormService
Deworm dew = new Deworm();
BeanUtils.copyProperties(deworm, dew);
dew.setSheepId(Long.valueOf(sheepId));
dew.setVariety(sheepFile.getVariety());
dew.setSheepType(sheepFile.getName());
dew.setMonthAge(sheepFile.getMonthAge());
dew.setGender(String.valueOf(sheepFile.getGender()));
dew.setBreed(sheepFile.getBreed());
dew.setParity(sheepFile.getParity());
dew.setVariety(sheepFile.getVariety() != null ? sheepFile.getVariety() : "");
dew.setSheepType(sheepFile.getName() != null ? sheepFile.getName() : "");
dew.setMonthAge(sheepFile.getMonthAge() != null ? sheepFile.getMonthAge() : 0);
dew.setGender(sheepFile.getGender() != null ? String.valueOf(sheepFile.getGender()) : "");
dew.setBreed(sheepFile.getBreed() != null ? sheepFile.getBreed() : "");
dew.setParity(sheepFile.getParity() != null ? sheepFile.getParity() : 0);
medicineUsage.setSheepId(sheepId);
// 获取药品使用记录的id

View File

@@ -4,6 +4,7 @@ import java.util.Date;
import java.util.List;
import java.util.Objects;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.module.base.domain.BasSheep;
@@ -49,6 +50,7 @@ public class DiagnosisServiceImpl implements IDiagnosisService
@Override
public Diagnosis selectDiagnosisById(Long id)
{
return diagnosisMapper.selectDiagnosisById(id);
}
@@ -59,8 +61,16 @@ public class DiagnosisServiceImpl implements IDiagnosisService
* @return 诊疗结果
*/
@Override
@DataScope(deptAlias = "sd", userAlias = "sd")
public List<Diagnosis> selectDiagnosisList(Diagnosis diagnosis)
{
String[] sheepNos = null;
if (diagnosis.getSheepNo() != null && !diagnosis.getSheepNo().isEmpty()) {
if (diagnosis.getSheepNo().contains(" ")) {
sheepNos = diagnosis.getSheepNo().split(" ");
}
}
diagnosis.setSheepNos(sheepNos);
return diagnosisMapper.selectDiagnosisList(diagnosis);
}

View File

@@ -2,6 +2,8 @@ package com.zhyc.module.biosafety.service.impl;
import java.util.ArrayList;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.common.utils.bean.BeanUtils;
@@ -59,6 +61,7 @@ public class DisinfectServiceImpl implements IDisinfectService
* @return 消毒记录
*/
@Override
@DataScope(deptAlias = "sd", userAlias = "sd")
public List<Disinfect> selectDisinfectList(Disinfect disinfect)
{
return disinfectMapper.selectDisinfectList(disinfect);

View File

@@ -3,6 +3,9 @@ package com.zhyc.module.biosafety.service.impl;
import java.beans.Transient;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.common.utils.bean.BeanUtils;
@@ -60,8 +63,16 @@ public class HealthServiceImpl implements IHealthService
* @return 保健
*/
@Override
@DataScope(deptAlias = "s", userAlias = "s")
public List<Health> selectHealthList(Health health)
{
String[] sheepNos = null;
if (health.getSheepNo() != null && !health.getSheepNo().isEmpty()) {
if (health.getSheepNo().contains(" ")) {
sheepNos = health.getSheepNo().split(" ");
}
}
health.setSheepNos(sheepNos);
return healthMapper.selectHealthList(health);
}
@@ -92,12 +103,14 @@ public class HealthServiceImpl implements IHealthService
Health heal = new Health();
BeanUtils.copyProperties(health, heal);
heal.setSheepId(Long.valueOf(sheepId));
heal.setVariety(sheepFile.getVariety());
heal.setSheepType(sheepFile.getName());
heal.setMonthAge(sheepFile.getMonthAge());
heal.setGender(String.valueOf(sheepFile.getGender()));
heal.setBreed(sheepFile.getBreed());
heal.setParity(sheepFile.getParity());
// 处理数据为空的情况
heal.setVariety(sheepFile.getVariety() != null ? sheepFile.getVariety() : "");
heal.setSheepType(sheepFile.getName() != null ? sheepFile.getName() : "");
heal.setMonthAge(sheepFile.getMonthAge() != null ? sheepFile.getMonthAge() : 0);
heal.setGender(sheepFile.getGender() != null ? String.valueOf(sheepFile.getGender()) : "");
heal.setBreed(sheepFile.getBreed() != null ? sheepFile.getBreed() : "");
heal.setParity(sheepFile.getParity() != null ? sheepFile.getParity() : 0);
medicineUsage.setSheepId(sheepId);
// 获取药品使用记录的id

View File

@@ -2,6 +2,8 @@ package com.zhyc.module.biosafety.service.impl;
import java.util.ArrayList;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.common.utils.bean.BeanUtils;
@@ -61,8 +63,16 @@ public class ImmunityServiceImpl implements IImmunityService
* @return 免疫
*/
@Override
@DataScope(deptAlias = "s", userAlias = "s")
public List<Immunity> selectImmunityList(Immunity immunity)
{
String[] sheepNos = null;
if (immunity.getSheepNo() != null && !immunity.getSheepNo().isEmpty()) {
if (immunity.getSheepNo().contains(" ")) {
sheepNos = immunity.getSheepNo().split(" ");
}
}
immunity.setSheepNos(sheepNos);
return immunityMapper.selectImmunityList(immunity);
}
@@ -97,13 +107,12 @@ public class ImmunityServiceImpl implements IImmunityService
Immunity imm = new Immunity();
BeanUtils.copyProperties(immunity, imm);
imm.setSheepId(Long.valueOf(sheepId));
imm.setVariety(sheepFile.getVariety());
imm.setSheepType(sheepFile.getName());
imm.setMonthAge(sheepFile.getMonthAge());
imm.setGender(String.valueOf(sheepFile.getGender()));
imm.setBreed(sheepFile.getBreed());
imm.setParity(sheepFile.getParity());
imm.setVariety(sheepFile.getVariety() != null ? sheepFile.getVariety() : "");
imm.setSheepType(sheepFile.getName() != null ? sheepFile.getName() : "");
imm.setMonthAge(sheepFile.getMonthAge() != null ? sheepFile.getMonthAge() : 0);
imm.setGender(sheepFile.getGender() != null ? String.valueOf(sheepFile.getGender()) : "");
imm.setBreed(sheepFile.getBreed() != null ? sheepFile.getBreed() : "");
imm.setParity(sheepFile.getParity() != null ? sheepFile.getParity() : 0);
medicineUsage.setSheepId(sheepId);
// 获取药品使用记录的id
Integer usageId = medicineUsageService.insertSwMedicineUsage(medicineUsage);

View File

@@ -2,6 +2,7 @@ package com.zhyc.module.biosafety.service.impl;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.module.biosafety.domain.QuarantineItems;
import com.zhyc.module.biosafety.mapper.QuarantineItemsMapper;
import com.zhyc.module.biosafety.service.IQuarantineItemsService;

View File

@@ -2,6 +2,8 @@ package com.zhyc.module.biosafety.service.impl;
import java.util.ArrayList;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.common.utils.bean.BeanUtils;
@@ -46,8 +48,16 @@ public class QuarantineReportServiceImpl implements IQuarantineReportService
* @return 检疫记录
*/
@Override
@DataScope(deptAlias = "sqr", userAlias = "sqr")
public List<QuarantineReport> selectQuarantineReportList(QuarantineReport quarantineReport)
{
String[] sheepNos = null;
if (quarantineReport.getSheepNo() != null && !quarantineReport.getSheepNo().isEmpty()) {
if (quarantineReport.getSheepNo().contains(" ")) {
sheepNos = quarantineReport.getSheepNo().split(" ");
}
}
quarantineReport.setSheepNos(sheepNos);
return quarantineReportMapper.selectQuarantineReportList(quarantineReport);
}

View File

@@ -1,6 +1,8 @@
package com.zhyc.module.biosafety.service.impl;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.module.biosafety.service.ISwMedicineUsageService;
@@ -44,8 +46,17 @@ public class SwMedicineUsageServiceImpl implements ISwMedicineUsageService
* @return 药品使用记录
*/
@Override
@DataScope(deptAlias = "smu", userAlias = "smu")
public List<SwMedicineUsage> selectSwMedicineUsageList(SwMedicineUsage swMedicineUsage)
{
String[] sheepNos = null;
if (swMedicineUsage.getSheepNo() != null && !swMedicineUsage.getSheepNo().isEmpty()) {
if (swMedicineUsage.getSheepNo().contains(" ")) {
sheepNos = swMedicineUsage.getSheepNo().split(" ");
swMedicineUsage.setSheepNos(sheepNos);
swMedicineUsage.setSheepNo(null);
}
}
return swMedicineUsageMapper.selectSwMedicineUsageList(swMedicineUsage);
}

View File

@@ -2,6 +2,8 @@ package com.zhyc.module.biosafety.service.impl;
import java.util.ArrayList;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.DateUtils;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.common.utils.bean.BeanUtils;
@@ -65,8 +67,18 @@ public class TreatmentServiceImpl implements ITreatmentService
* @return 治疗记录
*/
@Override
@DataScope(deptAlias = "t", userAlias = "t")
public List<Treatment> selectTreatmentList(Treatment treatment)
{
String[] sheepNos = null;
if (treatment.getSheepNo() != null && !treatment.getSheepNo().isEmpty()) {
if (treatment.getSheepNo().contains(",")) {
sheepNos = treatment.getSheepNo().split(",");
} else {
sheepNos = new String[]{treatment.getSheepNo()};
}
}
treatment.setSheepNos(sheepNos);
return treatmentMapper.selectTreatmentList(treatment);
}

View File

@@ -26,13 +26,15 @@ public class UserPostController {
// 根据岗位编码获取用户
@GetMapping("/getUser")
public AjaxResult getUserPost(String postCode){
List<User> list = userService.getUserListByCode(postCode);
User user = new User();
user.setPostCode(postCode);
List<User> list = userService.getUserListByCode(user);
return AjaxResult.success(list);
}
// 获取岗位(部门)
@GetMapping("/getPost")
public AjaxResult getPost(){
public AjaxResult getPost(String postName){
List<Post> list = postService.selectPostList();
return AjaxResult.success(list);
}

View File

@@ -0,0 +1,22 @@
package com.zhyc.module.common.domain;
import com.zhyc.common.core.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Dept extends BaseEntity {
private Long deptId;
private Long parentId;
private String ancestors;
private String deptName;
private String orderNum;
private String leader;
private String phone;
private String email;
private String status;
private String delFlag;
}

View File

@@ -1,6 +1,7 @@
package com.zhyc.module.common.domain;
import com.zhyc.common.annotation.Excel;
import com.zhyc.common.core.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@@ -8,7 +9,7 @@ import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Post {
public class Post extends BaseEntity {
/** 岗位序号 */
@Excel(name = "岗位序号", cellType = Excel.ColumnType.NUMERIC)

View File

@@ -1,5 +1,6 @@
package com.zhyc.module.common.domain;
import com.zhyc.common.core.domain.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
@@ -7,9 +8,10 @@ import lombok.NoArgsConstructor;
@Data
@NoArgsConstructor
@AllArgsConstructor
public class User {
public class User extends BaseEntity {
// 用户id
private String userId;
private Long userId;
private Long deptId;
// 用户名
private String nickName;
// 岗位名称
@@ -17,4 +19,5 @@ public class User {
// 岗位编码
private String postCode;
}

View File

@@ -0,0 +1,15 @@
package com.zhyc.module.common.mapper;
import com.zhyc.module.common.domain.Dept;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Select;
import java.util.List;
@Mapper
public interface DeptMapper {
/**
* 根据部门ID查询其所属二级部门排除根部门
*/
Dept selectTopSecondLevelDept(Long deptId);
}

View File

@@ -7,6 +7,6 @@ import java.util.List;
public interface PostMapper {
@Select("select * from sys_post where status = '0' and post_name like '%部'")
@Select("select * from sys_post where status = '0'")
List<Post> selectPostList();
}

View File

@@ -8,5 +8,5 @@ import java.util.List;
@Mapper
public interface UserMapper {
List<User> getUserListByCode(String postCode);
List<User> getUserListByCode(User user);
}

View File

@@ -5,5 +5,5 @@ import com.zhyc.module.common.domain.User;
import java.util.List;
public interface UserService {
List<User> getUserListByCode(String postCode);
List<User> getUserListByCode(User postCode);
}

View File

@@ -1,6 +1,10 @@
package com.zhyc.module.common.service.impl;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.common.utils.SecurityUtils;
import com.zhyc.module.common.domain.Dept;
import com.zhyc.module.common.domain.User;
import com.zhyc.module.common.mapper.DeptMapper;
import com.zhyc.module.common.mapper.UserMapper;
import com.zhyc.module.common.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
@@ -12,9 +16,16 @@ import java.util.List;
public class UserPostServiceImpl implements UserService {
@Autowired
UserMapper userMapper;
@Autowired
DeptMapper deptMapper;
@Override
public List<User> getUserListByCode(String postCode) {
return userMapper.getUserListByCode(postCode);
public List<User> getUserListByCode(User user) {
Long deptId = SecurityUtils.getLoginUser().getUser().getDeptId();
Dept secondLevel = deptMapper.selectTopSecondLevelDept(deptId);
user.setDeptId(secondLevel.getDeptId());
System.out.println(secondLevel);
return userMapper.getUserListByCode(user);
}
}

View File

@@ -28,16 +28,35 @@ public class NpMilkProdClassesController extends BaseController {
public TableDataInfo list(
@RequestParam(required = false) Date datetimeStart,
@RequestParam(required = false) Date datetimeEnd,
@RequestParam(required = false) String manageEarNo, // 改为单个字符串,模糊
@RequestParam(required = false) List<String> allEarNumbers, // 修改处:接收多耳号数组
@RequestParam(required = false) String factory,
@RequestParam(required = false) Integer classes) {
startPage();
// 修改处:将参数封装进实体,以便 Service 和 Mapper 统一处理
NpMilkProdClasses params = new NpMilkProdClasses();
params.setAllEarNumbers(allEarNumbers);
params.setFactory(factory);
params.setClasses(classes);
List<NpMilkProdClasses> list = npMilkProdClassesService
.selectNpMilkProdClassesList(datetimeStart, datetimeEnd,
manageEarNo, factory, classes);
.selectNpMilkProdClassesList(params, datetimeStart, datetimeEnd);
return getDataTable(list);
}
/**
* 修改处:新增耳号模糊查询接口
*/
@PreAuthorize("@ss.hasPermi('milkProdclasses:milkProdclasses:list')")
@GetMapping("/search_ear_numbers")
public AjaxResult searchEarNumbers(@RequestParam("query") String query) {
try {
List<String> earNumbers = npMilkProdClassesService.searchEarNumbers(query);
return success(earNumbers);
} catch (Exception e) {
return error("搜索耳号失败:" + e.getMessage());
}
}
@PreAuthorize("@ss.hasPermi('milkProdclasses:milkProdclasses:import')")
@Log(title = "班次产奶", businessType = BusinessType.IMPORT)
@PostMapping("/import")
@@ -58,14 +77,19 @@ public class NpMilkProdClassesController extends BaseController {
public void export(HttpServletResponse response,
@RequestParam(required = false) Date datetimeStart,
@RequestParam(required = false) Date datetimeEnd,
@RequestParam(required = false) String manageEarNo,
@RequestParam(required = false) List<String> allEarNumbers, // 修改处:接收多耳号
@RequestParam(required = false) String factory,
@RequestParam(required = false) Integer classes) {
NpMilkProdClasses params = new NpMilkProdClasses();
params.setAllEarNumbers(allEarNumbers);
params.setFactory(factory);
params.setClasses(classes);
List<NpMilkProdClasses> list = npMilkProdClassesService.selectNpMilkProdClassesList(
datetimeStart, datetimeEnd, manageEarNo, factory, classes);
params, datetimeStart, datetimeEnd);
ExcelUtil<NpMilkProdClasses> util = new ExcelUtil<>(NpMilkProdClasses.class);
util.exportExcel(response, list, "班次产奶数据");
}
}
}

View File

@@ -15,7 +15,7 @@ import java.util.List;
/**
* 奶产量分析控制器
* 保留:分页列表(只读) + 单条查询 + 导出
* 保留:分页列表(只读) + 单条查询 + 导出 + 耳号模糊查询
*/
@RestController
@RequestMapping("/dairyProducts/sheepMilkAnalysis")
@@ -26,15 +26,36 @@ public class NpSheepMilkAnalysisController extends BaseController {
/**
* 查询奶产量分析列表(只读,分页)
* 支持参数 manageEarTag耳号模糊 和 screenDays筛选天数
* 支持参数 allEarNumbers多耳号 和 screenDays筛选天数
*/
@GetMapping("/list")
public TableDataInfo list(NpSheepMilkAnalysis analysis) {
startPage(); // 使用PageHelper分页注意service中第一个DB调用是distinct sheep id
public TableDataInfo list(
@RequestParam(required = false) List<String> allEarNumbers, // 修改处:接收多耳号参数
NpSheepMilkAnalysis analysis) {
startPage();
// 修改处:将接收到的 list 设置进对象
if (allEarNumbers != null && !allEarNumbers.isEmpty()) {
analysis.setAllEarNumbers(allEarNumbers);
}
List<NpSheepMilkAnalysis> list = npSheepMilkAnalysisService.selectNpSheepMilkAnalysisList(analysis);
return getDataTable(list);
}
/**
* 修改处:新增搜索耳号接口
*/
@GetMapping("/search_ear_numbers")
public AjaxResult searchEarNumbers(@RequestParam("query") String query) {
try {
List<String> earNumbers = npSheepMilkAnalysisService.searchEarNumbers(query);
return success(earNumbers);
} catch (Exception e) {
return error("搜索耳号失败:" + e.getMessage());
}
}
/**
* 获取单个分析记录详细信息按sheepId
*/
@@ -45,11 +66,18 @@ public class NpSheepMilkAnalysisController extends BaseController {
/**
* 导出奶产量分析记录Excel
* 支持manageEarTag与screenDays两个查询条件
* 支持 allEarNumbers 与 screenDays 两个查询条件
*/
@Log(title = "奶产量分析 导出", businessType = BusinessType.EXPORT)
@GetMapping("/export")
public AjaxResult export(NpSheepMilkAnalysis analysis) {
public AjaxResult export(
@RequestParam(required = false) List<String> allEarNumbers, // 修改处:接收多耳号参数
NpSheepMilkAnalysis analysis) {
if (allEarNumbers != null && !allEarNumbers.isEmpty()) {
analysis.setAllEarNumbers(allEarNumbers);
}
List<NpSheepMilkAnalysis> list = npSheepMilkAnalysisService.selectNpSheepMilkAnalysisForExport(analysis);
ExcelUtil<NpSheepMilkAnalysis> util = new ExcelUtil<>(NpSheepMilkAnalysis.class);
return util.exportExcel(list, "羊奶产量分析数据");

View File

@@ -2,20 +2,19 @@ package com.zhyc.module.dairyProducts.domain;
import java.io.Serializable;
import java.util.Date;
import java.util.List; // 引入 List
import com.fasterxml.jackson.annotation.JsonFormat;
import com.zhyc.common.annotation.Excel;
public class NpMilkProdClasses implements Serializable {
private static final long serialVersionUID = 1L;
private Long id; // 主键ID
private Date createTime; // 创建时间
private Date updateTime; // 更新时间
private Long id;
private Date createTime;
private Date updateTime;
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "日期", dateFormat = "yyyy-MM-dd") // 添加日期格式
@Excel(name = "日期", dateFormat = "yyyy-MM-dd")
private Date datetime;
@Excel(name = "管理耳号")
@@ -41,7 +40,19 @@ public class NpMilkProdClasses implements Serializable {
private String sheepId;
// 修改处:新增字段用于多耳号查询
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
// Getters and Setters
public List<String> getAllEarNumbers() {
return allEarNumbers;
}
public void setAllEarNumbers(List<String> allEarNumbers) {
this.allEarNumbers = allEarNumbers;
}
public Long getId() { return id; }
public void setId(Long id) { this.id = id; }

View File

@@ -2,6 +2,7 @@ package com.zhyc.module.dairyProducts.domain;
import com.zhyc.common.annotation.Excel;
import java.util.Date;
import java.util.List; // 导入List
public class NpSheepMilkAnalysis {
// 唯一键(可用于前端 row-key
@@ -12,6 +13,10 @@ public class NpSheepMilkAnalysis {
@Excel(name = "耳号")
private String manageEarTag;
// 修改处:新增多耳号字段
/** 全部羊耳号列表(用于多耳号查询) */
private List<String> allEarNumbers;
@Excel(name = "品种")
private String variety;
@@ -139,6 +144,16 @@ public class NpSheepMilkAnalysis {
private Date lastUpdate;
// getters and setters
// 修改处:添加 allEarNumbers 的 getter/setter
public List<String> getAllEarNumbers() {
return allEarNumbers;
}
public void setAllEarNumbers(List<String> allEarNumbers) {
this.allEarNumbers = allEarNumbers;
}
public String getSheepId() { return sheepId; }
public void setSheepId(String sheepId) { this.sheepId = sheepId; }

View File

@@ -6,12 +6,14 @@ import java.util.Date;
import java.util.List;
public interface NpMilkProdClassesMapper {
// 修改处:参数改为接收实体类
List<NpMilkProdClasses> selectNpMilkProdClassesList(
@Param("npMilkProdClasses") NpMilkProdClasses npMilkProdClasses,
@Param("datetimeStart") Date datetimeStart,
@Param("datetimeEnd") Date datetimeEnd,
@Param("manageEarNo") String manageEarNo,
@Param("factory") String factory,
@Param("classes") Integer classes);
@Param("datetimeEnd") Date datetimeEnd);
// 修改处:新增搜索方法
List<String> searchEarNumbers(@Param("query") String query);
int insertNpMilkProdClasses(NpMilkProdClasses row);

View File

@@ -20,8 +20,14 @@ public interface NpSheepMilkAnalysisMapper {
/**
* 根据管理耳标筛选返回distinct的sheepId列表
* 修改处:参数改为对象,支持 allEarNumbers
*/
List<String> selectDistinctSheepIds(@Param("manageEarTag") String manageEarTag);
List<String> selectDistinctSheepIds(NpSheepMilkAnalysis analysis);
/**
* 修改处:新增耳号模糊查询接口
*/
List<String> searchEarNumbers(@Param("query") String query);
/**
* 根据羊只ID查询羊只档案信息返回Map结构

View File

@@ -5,12 +5,14 @@ import java.util.List;
import com.zhyc.module.dairyProducts.domain.NpMilkProdClasses;
public interface INpMilkProdClassesService {
// 修改处:参数改为接收实体类,以包含多耳号列表
List<NpMilkProdClasses> selectNpMilkProdClassesList(
NpMilkProdClasses npMilkProdClasses,
Date datetimeStart,
Date datetimeEnd,
String manageEarNo, // 改为单个 String
String factory,
Integer classes);
Date datetimeEnd);
// 修改处:新增耳号搜索方法
List<String> searchEarNumbers(String query);
int importMilkProdClasses(List<NpMilkProdClasses> list);
}

View File

@@ -9,6 +9,9 @@ public interface INpSheepMilkAnalysisService {
List<NpSheepMilkAnalysis> selectNpSheepMilkAnalysisList(NpSheepMilkAnalysis analysis);
// 修改处:新增模糊查询方法定义
List<String> searchEarNumbers(String query);
/**
* 导出奶产量分析记录
*/

View File

@@ -16,26 +16,29 @@ public class NpMilkProdClassesServiceImpl implements INpMilkProdClassesService {
private NpMilkProdClassesMapper mapper;
@Override
public List<NpMilkProdClasses> selectNpMilkProdClassesList(Date datetimeStart, Date datetimeEnd,
String manageEarNo, String factory, Integer classes) {
return mapper.selectNpMilkProdClassesList(datetimeStart, datetimeEnd, manageEarNo, factory, classes);
public List<NpMilkProdClasses> selectNpMilkProdClassesList(NpMilkProdClasses npMilkProdClasses, Date datetimeStart, Date datetimeEnd) {
// 修改处:传递实体对象
return mapper.selectNpMilkProdClassesList(npMilkProdClasses, datetimeStart, datetimeEnd);
}
// 修改处:实现搜索方法
@Override
public List<String> searchEarNumbers(String query) {
return mapper.searchEarNumbers(query);
}
@Override
public int importMilkProdClasses(List<NpMilkProdClasses> list) {
int count = 0;
for (NpMilkProdClasses item : list) {
// 根据管理耳号查 sheep_id
String sheepId = mapper.selectSheepIdByManageEarNo(item.getManageEarNo());
if (sheepId == null) continue;
item.setSheepId(sheepId);
// 计算校正奶量
Double correctedMilk = calculateCorrectedMilk(item);
item.setCorrectedMilk(correctedMilk);
// 插入数据
count += mapper.insertNpMilkProdClasses(item);
}
return count;
@@ -45,15 +48,12 @@ public class NpMilkProdClassesServiceImpl implements INpMilkProdClassesService {
Double milk = item.getMilk();
if (milk == null) return null;
// 1. 称重矫正系数
Double weightCorrection = mapper.getWeightCorrection(item.getDatetime(), item.getFactory());
if (weightCorrection == null) weightCorrection = 1.0;
// 2. 胎次矫正系数
Double parityCorrection = mapper.getParityCorrection(item.getParity());
if (parityCorrection == null) parityCorrection = 1.0;
// 3. 干物质矫正系数
Double dryMatterCorrection = mapper.getDryMatterCorrection(item.getDatetime(), item.getFactory());
if (dryMatterCorrection == null) dryMatterCorrection = 1.0;

View File

@@ -47,12 +47,19 @@ public class NpSheepMilkAnalysisServiceImpl implements INpSheepMilkAnalysisServi
return ana;
}
// 修改处:新增模糊查询实现
@Override
public List<String> searchEarNumbers(String query) {
return npSheepMilkAnalysisMapper.searchEarNumbers(query);
}
@Override
public List<NpSheepMilkAnalysis> selectNpSheepMilkAnalysisList(NpSheepMilkAnalysis analysis) {
int screenDays = (analysis != null && analysis.getScreenDays() != null) ? analysis.getScreenDays() : 100;
String manageEarTagFilter = (analysis != null) ? analysis.getManageEarTag() : null;
List<String> sheepIds = npSheepMilkAnalysisMapper.selectDistinctSheepIds(manageEarTagFilter);
// 修改处:这里改为直接传 analysis 对象,以便 mapper 可以处理 allEarNumbers
List<String> sheepIds = npSheepMilkAnalysisMapper.selectDistinctSheepIds(analysis);
if (CollectionUtils.isEmpty(sheepIds)) return Collections.emptyList();
List<NpSheepMilkAnalysis> resultList = new ArrayList<>();

View File

@@ -0,0 +1,21 @@
package com.zhyc.module.feed.controller.Exception;
import com.zhyc.common.core.domain.AjaxResult;
import org.springframework.web.bind.annotation.ControllerAdvice;
import org.springframework.web.bind.annotation.ExceptionHandler;
import javax.servlet.http.HttpServletRequest;
@ControllerAdvice
public class MaterialExceptionHandler {
@ExceptionHandler({Exception.class, RuntimeException.class})
public AjaxResult handleException(HttpServletRequest request, Exception ex) {
AjaxResult ajaxResult = new AjaxResult();
ajaxResult.put("message", ex.getMessage());
ajaxResult.put("url", request.getRequestURL().toString());
ajaxResult.put("status", 500);
ajaxResult.put("error", "出现了一些错误");
return ajaxResult;
}
}

View File

@@ -109,6 +109,8 @@ public class SgFeedListController extends BaseController {
@Log(title = "配料清单", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody SgFeedList sgFeedList) {
sgFeedList.setDeptId(getDeptId());
sgFeedList.setUserId(getUserId());
return toAjax(sgFeedListService.insertSgFeedList(sgFeedList));
}

View File

@@ -79,6 +79,8 @@ public class SgFeedPlanController extends BaseController {
if (null == sgFeedPlan) {
throw new RuntimeException("数据为空");
}
sgFeedPlan.setDeptId(getDeptId());
sgFeedPlan.setUserId(getUserId());
sgFeedPlan.setCreateDate(new Date());
// 计算其他字段值
setPlan(sgFeedPlan);

View File

@@ -84,6 +84,8 @@ public class SgFeedStatisticController extends BaseController {
if (null == sgFeedStatistic.getFormulaId() && null == sgFeedStatistic.getFormulaBatchId()) {
throw new RuntimeException("ERROR: 数据为空");
}
sgFeedStatistic.setUserId(getUserId());
sgFeedStatistic.setDeptId(getDeptId());
List<SgFeedStatistic> isExist = sgFeedStatisticService.selectSgFeedStatisticList(sgFeedStatistic);
if (null != isExist && !isExist.isEmpty()) {
throw new RuntimeException("WARNING: 数据重复");

View File

@@ -79,6 +79,8 @@ public class SgFormulaListController extends BaseController
@PostMapping
public AjaxResult add(@RequestBody SgFormulaList sgFormulaList)
{
sgFormulaList.setUserId(getUserId());
sgFormulaList.setDeptId(getDeptId());
return toAjax(sgFormulaListService.insertSgFormulaList(sgFormulaList));
}

View File

@@ -95,6 +95,8 @@ public class SgFormulaManagementController extends BaseController {
public AjaxResult add(@RequestBody SgFormulaManagement sgFormulaManagement) {
if (null == sgFormulaManagement)
throw new RuntimeException("ERROR: 数据为空");
sgFormulaManagement.setUserId(getUserId());
sgFormulaManagement.setDeptId(getDeptId());
if (Objects.equals(sgFormulaManagement.getBatchId(), "0")) {
SgFormulaManagement exist = sgFormulaManagementService.selectSgFormulaManagementByFormulaId(sgFormulaManagement.getFormulaId());
if (exist != null) {

View File

@@ -2,7 +2,9 @@ package com.zhyc.module.feed.controller;
import java.util.List;
import javax.servlet.http.HttpServletResponse;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
@@ -24,25 +26,20 @@ import com.zhyc.common.core.page.TableDataInfo;
* 原料Controller
*
* @author HashMap
* @date 2025-08-11
* @date 2026-01-16
*/
@RestController
@RequestMapping("/feed/material")
public class SgMaterialController extends BaseController
{
private final ISgMaterialService sgMaterialService;
public SgMaterialController(ISgMaterialService sgMaterialService) {
this.sgMaterialService = sgMaterialService;
}
public class SgMaterialController extends BaseController {
@Autowired
private ISgMaterialService sgMaterialService;
/**
* 查询原料列表
*/
@PreAuthorize("@ss.hasPermi('feed:material:list')")
@GetMapping("/list")
public TableDataInfo list(SgMaterial sgMaterial)
{
public TableDataInfo list(SgMaterial sgMaterial) {
startPage();
List<SgMaterial> list = sgMaterialService.selectSgMaterialList(sgMaterial);
return getDataTable(list);
@@ -54,10 +51,9 @@ public class SgMaterialController extends BaseController
@PreAuthorize("@ss.hasPermi('feed:material:export')")
@Log(title = "原料", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, SgMaterial sgMaterial)
{
public void export(HttpServletResponse response, SgMaterial sgMaterial) {
List<SgMaterial> list = sgMaterialService.selectSgMaterialList(sgMaterial);
ExcelUtil<SgMaterial> util = new ExcelUtil<>(SgMaterial.class);
ExcelUtil<SgMaterial> util = new ExcelUtil<SgMaterial>(SgMaterial.class);
util.exportExcel(response, list, "原料数据");
}
@@ -66,8 +62,7 @@ public class SgMaterialController extends BaseController
*/
@PreAuthorize("@ss.hasPermi('feed:material:query')")
@GetMapping(value = "/{materialId}")
public AjaxResult getInfo(@PathVariable("materialId") String materialId)
{
public AjaxResult getInfo(@PathVariable("materialId") String materialId) {
return success(sgMaterialService.selectSgMaterialByMaterialId(materialId));
}
@@ -77,8 +72,9 @@ public class SgMaterialController extends BaseController
@PreAuthorize("@ss.hasPermi('feed:material:add')")
@Log(title = "原料", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody SgMaterial sgMaterial)
{
public AjaxResult add(@RequestBody SgMaterial sgMaterial) {
sgMaterial.setUserId(getUserId());
sgMaterial.setDeptId(getDeptId());
return toAjax(sgMaterialService.insertSgMaterial(sgMaterial));
}
@@ -88,8 +84,7 @@ public class SgMaterialController extends BaseController
@PreAuthorize("@ss.hasPermi('feed:material:edit')")
@Log(title = "原料", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody SgMaterial sgMaterial)
{
public AjaxResult edit(@RequestBody SgMaterial sgMaterial) {
return toAjax(sgMaterialService.updateSgMaterial(sgMaterial));
}
@@ -99,8 +94,7 @@ public class SgMaterialController extends BaseController
@PreAuthorize("@ss.hasPermi('feed:material:remove')")
@Log(title = "原料", businessType = BusinessType.DELETE)
@DeleteMapping("/{materialIds}")
public AjaxResult remove(@PathVariable String[] materialIds)
{
public AjaxResult remove(@PathVariable String[] materialIds) {
return toAjax(sgMaterialService.deleteSgMaterialByMaterialIds(materialIds));
}
}

View File

@@ -19,26 +19,36 @@ import com.zhyc.common.core.domain.BaseEntity;
*/
@Setter
@Getter
public class SgFeedList extends BaseEntity
{
public class SgFeedList extends BaseEntity {
private static final long serialVersionUID = 1L;
/** 序号 */
private Long userId;
private Long deptId;
/**
* 序号
*/
private Long id;
/** 配方编号 */
/**
* 配方编号
*/
@Excel(name = "配方编号")
private String formulaId;
/** 配方批号 */
/**
* 配方批号
*/
@Excel(name = "配方批号")
private String formulaBatchId;
/** 饲草班人员 */
/**
* 饲草班人员
*/
@Excel(name = "饲草班人员")
private String zookeeper;
/** 配料日期 */
/**
* 配料日期
*/
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "配料日期", width = 30, dateFormat = "yyyy-MM-dd")
private Date deployDate;
@@ -51,14 +61,14 @@ public class SgFeedList extends BaseEntity
private Double noonTotal;
private Double afternoonTotal;
private List<SgFormulaList> formulaList;
private List<SgFormulaList> formulaList;
private List<SgFeedPlan> planList;
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
.append("id", getId())
.append("formulaId", getFormulaId())
.append("formulaBatchId", getFormulaBatchId())

View File

@@ -1,6 +1,7 @@
package com.zhyc.module.feed.domain;
import java.util.Date;
import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Getter;
import lombok.Setter;
@@ -11,125 +12,144 @@ import com.zhyc.common.core.domain.BaseEntity;
/**
* 饲喂计划对象 sg_feed_plan
*
*
* @author HashMap
* @date 2025-08-14
*/
@Getter
@Setter
public class SgFeedPlan extends BaseEntity
{
public class SgFeedPlan extends BaseEntity {
private static final long serialVersionUID = 1L;
/** 创建日期 */
private Long userId;
private Long deptId;
/**
* 创建日期
*/
private Date createDate;
/** 配方编码 */
/**
* 配方编码
*/
@Excel(name = "配方编码")
private String formulaId;
/** 批号 */
/**
* 批号
*/
@Excel(name = "批号")
private String batchId;
/** 羊舍 */
/**
* 羊舍
*/
@Excel(name = "羊舍")
private Integer sheepHouseId;
/** 羊只数量 */
/**
* 羊只数量
*/
@Excel(name = "羊只数量")
private Integer sheepCount;
/** 日均计划量 */
/**
* 日均计划量
*/
@Excel(name = "日均计划量")
private Double planDailySize;
/** 饲喂比例(早) */
/**
* 饲喂比例(早)
*/
@Excel(name = "饲喂比例(早)")
private Double ratioMorning;
/** 饲喂比例(中) */
/**
* 饲喂比例(中)
*/
@Excel(name = "饲喂比例(中)")
private Double ratioNoon;
/** 饲喂比例(下) */
/**
* 饲喂比例(下)
*/
@Excel(name = "饲喂比例(下)")
private Double ratioAfternoon;
/** 计划量(早) */
/**
* 计划量(早)
*/
@Excel(name = "计划量(早)")
private Double planMorningSize;
/** 计划总量(早) */
/**
* 计划总量(早)
*/
@Excel(name = "计划总量(早)")
private Double planMorningTotal;
/** 实际量(早) */
/**
* 实际量(早)
*/
@Excel(name = "实际量(早)")
private Double actualMorningSize;
/** 计划量(中) */
/**
* 计划量(中)
*/
@Excel(name = "计划量(中)")
private Double planNoonSize;
/** 计划总量(中) */
/**
* 计划总量(中)
*/
@Excel(name = "计划总量(中)")
private Double planNoonTotal;
/** 实际量(中) */
/**
* 实际量(中)
*/
@Excel(name = "实际量(中)")
private Double actualNoonSize;
/** 计划量(下) */
/**
* 计划量(下)
*/
@Excel(name = "计划量(下)")
private Double planAfternoonSize;
/** 计划总量(下) */
/**
* 计划总量(下)
*/
@Excel(name = "计划总量(下)")
private Double planAfternoonTotal;
/** 实际量(下) */
/**
* 实际量(下)
*/
@Excel(name = "实际量(下)")
private Double actualAfternoonSize;
/** 计划饲喂总量 */
/**
* 计划饲喂总量
*/
@Excel(name = "计划饲喂总量")
private Double planFeedTotal;
/** 饲草班人员 */
/**
* 饲草班人员
*/
@Excel(name = "饲草班人员")
private String zookeeper;
/** 饲喂计划日期 */
/**
* 饲喂计划日期
*/
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "饲喂计划日期", width = 30, dateFormat = "yyyy-MM-dd")
private Date planDate;
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("createDate", getCreateDate())
.append("formulaId", getFormulaId())
.append("batchId", getBatchId())
.append("sheepHouseId", getSheepHouseId())
.append("sheepCount", getSheepCount())
.append("planDailySize", getPlanDailySize())
.append("ratioMorning", getRatioMorning())
.append("ratioNoon", getRatioNoon())
.append("ratioAfternoon", getRatioAfternoon())
.append("planMorningSize", getPlanMorningSize())
.append("planMorningTotal", getPlanMorningTotal())
.append("actualMorningSize", getActualMorningSize())
.append("planNoonSize", getPlanNoonSize())
.append("planNoonTotal", getPlanNoonTotal())
.append("actualNoonSize", getActualNoonSize())
.append("planAfternoonSize", getPlanAfternoonSize())
.append("planAfternoonTotal", getPlanAfternoonTotal())
.append("actualAfternoonSize", getActualAfternoonSize())
.append("planFeedTotal", getPlanFeedTotal())
.append("zookeeper", getZookeeper())
.append("planDate", getPlanDate())
.append("remark", getRemark())
.toString();
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE).append("createDate", getCreateDate()).append("formulaId", getFormulaId()).append("batchId", getBatchId()).append("sheepHouseId", getSheepHouseId()).append("sheepCount", getSheepCount()).append("planDailySize", getPlanDailySize()).append("ratioMorning", getRatioMorning()).append("ratioNoon", getRatioNoon()).append("ratioAfternoon", getRatioAfternoon()).append("planMorningSize", getPlanMorningSize()).append("planMorningTotal", getPlanMorningTotal()).append("actualMorningSize", getActualMorningSize()).append("planNoonSize", getPlanNoonSize()).append("planNoonTotal", getPlanNoonTotal()).append("actualNoonSize", getActualNoonSize()).append("planAfternoonSize", getPlanAfternoonSize()).append("planAfternoonTotal", getPlanAfternoonTotal()).append("actualAfternoonSize", getActualAfternoonSize()).append("planFeedTotal", getPlanFeedTotal()).append("zookeeper", getZookeeper()).append("planDate", getPlanDate()).append("remark", getRemark()).toString();
}
}

View File

@@ -23,7 +23,8 @@ import java.util.List;
@Getter
public class SgFeedStatistic extends BaseEntity {
private static final long serialVersionUID = 1L;
private Long userId;
private Long deptId;
/**
* UUID
*/

View File

@@ -9,33 +9,45 @@ import com.zhyc.common.core.domain.BaseEntity;
/**
* 配方列表对象 sg_formula_list
*
*
* @author HashMap
* @date 2025-08-09
*/
@Setter
@Getter
public class SgFormulaList extends BaseEntity
{
public class SgFormulaList extends BaseEntity {
private static final long serialVersionUID = 1L;
/** 序号 */
private Long userId;
private Long deptId;
/**
* 序号
*/
private Long code;
/** 配方编号 */
/**
* 配方编号
*/
private String formulaId;
/** 配方编号 */
/**
* 配方编号
*/
private String batchId;
/** 原料编号 */
/**
* 原料编号
*/
@Excel(name = "原料编号")
private String materialId;
/** 原料名称 */
/**
* 原料名称
*/
@Excel(name = "原料名称")
private String materialName;
/** 比例 */
/**
* 比例
*/
@Excel(name = "比例")
private Long ratio;
@@ -60,14 +72,14 @@ public class SgFormulaList extends BaseEntity
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("code", getCode())
.append("formulaId", getFormulaId())
.append("materialId", getMaterialId())
.append("materialName", getMaterialName())
.append("ratio", getRatio())
.append("isGranular", getIsGranular())
.append("isSupplement", getIsSupplement())
.toString();
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
.append("code", getCode())
.append("formulaId", getFormulaId())
.append("materialId", getMaterialId())
.append("materialName", getMaterialName())
.append("ratio", getRatio())
.append("isGranular", getIsGranular())
.append("isSupplement", getIsSupplement())
.toString();
}
}

View File

@@ -13,67 +13,87 @@ import com.zhyc.common.core.domain.BaseEntity;
/**
* 配方管理对象 sg_formula_management
*
*
* @author HashMap
* @date 2025-08-09
*/
@Setter
@Getter
public class SgFormulaManagement extends BaseEntity
{
public class SgFormulaManagement extends BaseEntity {
private static final long serialVersionUID = 1L;
/** 配方编号 */
private Long userId;
private Long deptId;
/**
* 配方编号
*/
private String formulaId;
/** 饲养阶段 */
/**
* 饲养阶段
*/
@Excel(name = "饲养阶段")
private String feedStage;
/** 批号 */
/**
* 批号
*/
@Excel(name = "批号")
private String batchId;
/** 开始使用时间 */
/**
* 开始使用时间
*/
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "开始使用时间", width = 30, dateFormat = "yyyy-MM-dd")
private Date useStartDate;
/** 结束使用时间 */
/**
* 结束使用时间
*/
@JsonFormat(pattern = "yyyy-MM-dd")
@Excel(name = "结束使用时间", width = 30, dateFormat = "yyyy-MM-dd")
private Date useEndDate;
/** 使用状态 */
/**
* 使用状态
*/
@Excel(name = "使用状态")
private String useState;
/** 备注 */
/**
* 备注
*/
@Excel(name = "备注")
private String remark;
/** 配方列表 */
private List<SgFormulaList> sgFormulaList;
/**
* 配方列表
*/
private List<SgFormulaList> sgFormulaList;
/** 子配方 */
/**
* 子配方
*/
private List<SgFormulaManagement> subFormulaList;
/** 查询类型 *
/**
* 查询类型 *
* Sub : 子配方查询
* query : 类型查询
* */
*
*/
private String queryType;
@Override
public String toString() {
return new ToStringBuilder(this,ToStringStyle.MULTI_LINE_STYLE)
.append("formulaId", getFormulaId())
.append("feedStage", getFeedStage())
.append("batchId", getBatchId())
.append("useStartDate", getUseStartDate())
.append("useEndDate", getUseEndDate())
.append("useState", getUseState())
.append("remark", getRemark())
.toString();
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
.append("formulaId", getFormulaId())
.append("feedStage", getFeedStage())
.append("batchId", getBatchId())
.append("useStartDate", getUseStartDate())
.append("useEndDate", getUseEndDate())
.append("useState", getUseState())
.append("remark", getRemark())
.toString();
}
}

View File

@@ -1,15 +1,66 @@
package com.zhyc.module.feed.domain;
import lombok.Data;
import org.apache.commons.lang3.builder.ToStringBuilder;
import org.apache.commons.lang3.builder.ToStringStyle;
import com.zhyc.common.annotation.Excel;
import com.zhyc.common.core.domain.BaseEntity;
import lombok.Getter;
import lombok.Setter;
@Setter
@Getter
/**
* 原料对象 sg_material
*
* @author HashMap
* @date 2026-01-16
*/
@Data
public class SgMaterial extends BaseEntity {
private static final long serialVersionUID = 1L;
private Long userId;
private Long deptId;
/**
* 原料编码
*/
@Excel(name = "原料编码")
private String materialId;
/**
* 原料名称
*/
@Excel(name = "原料名称")
private String materialName;
private String isGranular;
/**
* 颗粒料
*/
@Excel(name = "颗粒料")
private Integer isGranular;
public void setMaterialId(String materialId) {
this.materialId = materialId;
}
public String getMaterialId() {
return materialId;
}
public void setMaterialName(String materialName) {
this.materialName = materialName;
}
public String getMaterialName() {
return materialName;
}
public void setIsGranular(Integer isGranular) {
this.isGranular = isGranular;
}
public Integer getIsGranular() {
return isGranular;
}
@Override
public String toString() {
return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE).append("materialId", getMaterialId()).append("materialName", getMaterialName()).append("isGranular", getIsGranular()).toString();
}
}

View File

@@ -6,16 +6,16 @@ import org.apache.ibatis.annotations.Mapper;
/**
* 原料Mapper接口
*
*
* @author HashMap
* @date 2025-08-11
* @date 2026-01-16
*/
@Mapper
public interface SgMaterialMapper
public interface SgMaterialMapper
{
/**
* 查询原料
*
*
* @param materialId 原料主键
* @return 原料
*/
@@ -23,7 +23,7 @@ public interface SgMaterialMapper
/**
* 查询原料列表
*
*
* @param sgMaterial 原料
* @return 原料集合
*/
@@ -31,7 +31,7 @@ public interface SgMaterialMapper
/**
* 新增原料
*
*
* @param sgMaterial 原料
* @return 结果
*/
@@ -39,7 +39,7 @@ public interface SgMaterialMapper
/**
* 修改原料
*
*
* @param sgMaterial 原料
* @return 结果
*/
@@ -47,7 +47,7 @@ public interface SgMaterialMapper
/**
* 删除原料
*
*
* @param materialId 原料主键
* @return 结果
*/
@@ -55,7 +55,7 @@ public interface SgMaterialMapper
/**
* 批量删除原料
*
*
* @param materialIds 需要删除的数据主键集合
* @return 结果
*/

View File

@@ -5,57 +5,57 @@ import com.zhyc.module.feed.domain.SgMaterial;
/**
* 原料Service接口
*
*
* @author HashMap
* @date 2025-08-11
* @date 2026-01-16
*/
public interface ISgMaterialService
public interface ISgMaterialService
{
/**
* 查询原料
*
*
* @param materialId 原料主键
* @return 原料
*/
SgMaterial selectSgMaterialByMaterialId(String materialId);
public SgMaterial selectSgMaterialByMaterialId(String materialId);
/**
* 查询原料列表
*
*
* @param sgMaterial 原料
* @return 原料集合
*/
List<SgMaterial> selectSgMaterialList(SgMaterial sgMaterial);
public List<SgMaterial> selectSgMaterialList(SgMaterial sgMaterial);
/**
* 新增原料
*
*
* @param sgMaterial 原料
* @return 结果
*/
int insertSgMaterial(SgMaterial sgMaterial);
public int insertSgMaterial(SgMaterial sgMaterial);
/**
* 修改原料
*
*
* @param sgMaterial 原料
* @return 结果
*/
int updateSgMaterial(SgMaterial sgMaterial);
public int updateSgMaterial(SgMaterial sgMaterial);
/**
* 批量删除原料
*
*
* @param materialIds 需要删除的原料主键集合
* @return 结果
*/
int deleteSgMaterialByMaterialIds(String[] materialIds);
public int deleteSgMaterialByMaterialIds(String[] materialIds);
/**
* 删除原料信息
*
*
* @param materialId 原料主键
* @return 结果
*/
int deleteSgMaterialByMaterialId(String materialId);
public int deleteSgMaterialByMaterialId(String materialId);
}

View File

@@ -2,6 +2,7 @@ package com.zhyc.module.feed.service.impl;
import java.util.*;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.module.feed.domain.SgFeedPlan;
import com.zhyc.module.feed.domain.SgFormulaManagement;
import com.zhyc.module.feed.service.ISgFeedPlanService;
@@ -56,6 +57,7 @@ public class SgFeedListServiceImpl implements ISgFeedListService {
* @return 配料清单
*/
@Override
@DataScope(deptAlias = "sg_feed_list_alias", userAlias = "sg_feed_list_alias")
public List<SgFeedList> selectSgFeedListList(SgFeedList sgFeedList) {
return sgFeedListMapper.selectSgFeedListList(sgFeedList);
}

View File

@@ -3,6 +3,7 @@ package com.zhyc.module.feed.service.impl;
import java.util.Date;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import org.springframework.stereotype.Service;
import com.zhyc.module.feed.mapper.SgFeedPlanMapper;
import com.zhyc.module.feed.domain.SgFeedPlan;
@@ -11,14 +12,13 @@ import org.springframework.transaction.annotation.Transactional;
/**
* 饲喂计划Service业务层处理
*
*
* @author HashMap
* @date 2025-08-14
*/
@Service
@Transactional(rollbackFor=Exception.class)
public class SgFeedPlanServiceImpl implements ISgFeedPlanService
{
@Transactional(rollbackFor = Exception.class)
public class SgFeedPlanServiceImpl implements ISgFeedPlanService {
private final SgFeedPlanMapper sgFeedPlanMapper;
public SgFeedPlanServiceImpl(SgFeedPlanMapper sgFeedPlanMapper) {
@@ -27,73 +27,68 @@ public class SgFeedPlanServiceImpl implements ISgFeedPlanService
/**
* 查询饲喂计划
*
*
* @param createDate 饲喂计划主键
* @return 饲喂计划
*/
@Override
public SgFeedPlan selectSgFeedPlanByCreateDate(Date createDate)
{
public SgFeedPlan selectSgFeedPlanByCreateDate(Date createDate) {
return sgFeedPlanMapper.selectSgFeedPlanByCreateDate(createDate);
}
/**
* 查询饲喂计划列表
*
*
* @param sgFeedPlan 饲喂计划
* @return 饲喂计划
*/
@Override
public List<SgFeedPlan> selectSgFeedPlanList(SgFeedPlan sgFeedPlan)
{
@DataScope(deptAlias = "sg_feed_plan_alias", userAlias = "sg_feed_plan_alias")
public List<SgFeedPlan> selectSgFeedPlanList(SgFeedPlan sgFeedPlan) {
return sgFeedPlanMapper.selectSgFeedPlanList(sgFeedPlan);
}
/**
* 新增饲喂计划
*
*
* @param sgFeedPlan 饲喂计划
* @return 结果
*/
@Override
public int insertSgFeedPlan(SgFeedPlan sgFeedPlan)
{
public int insertSgFeedPlan(SgFeedPlan sgFeedPlan) {
return sgFeedPlanMapper.insertSgFeedPlan(sgFeedPlan);
}
/**
* 修改饲喂计划
*
*
* @param sgFeedPlan 饲喂计划
* @return 结果
*/
@Override
public int updateSgFeedPlan(SgFeedPlan sgFeedPlan)
{
public int updateSgFeedPlan(SgFeedPlan sgFeedPlan) {
return sgFeedPlanMapper.updateSgFeedPlan(sgFeedPlan);
}
/**
* 批量删除饲喂计划
*
*
* @param createDates 需要删除的饲喂计划主键
* @return 结果
*/
@Override
public int deleteSgFeedPlanByCreateDates(Date[] createDates)
{
public int deleteSgFeedPlanByCreateDates(Date[] createDates) {
return sgFeedPlanMapper.deleteSgFeedPlanByCreateDates(createDates);
}
/**
* 删除饲喂计划信息
*
*
* @param createDate 饲喂计划主键
* @return 结果
*/
@Override
public int deleteSgFeedPlanByCreateDate(Date createDate)
{
public int deleteSgFeedPlanByCreateDate(Date createDate) {
return sgFeedPlanMapper.deleteSgFeedPlanByCreateDate(createDate);
}

View File

@@ -3,6 +3,7 @@ package com.zhyc.module.feed.service.impl;
import java.util.List;
import java.util.stream.Collectors;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.module.base.domain.DaSheepfold;
import com.zhyc.module.feed.domain.SgFeedList;
import com.zhyc.module.feed.domain.SgFeedPlan;
@@ -51,6 +52,7 @@ public class SgFeedStatisticServiceImpl implements ISgFeedStatisticService {
* @return 饲喂量统计
*/
@Override
@DataScope(deptAlias = "sg_feed_statistic_alias", userAlias = "sg_feed_statistic_alias")
public List<SgFeedStatistic> selectSgFeedStatisticList(SgFeedStatistic sgFeedStatistic) {
return sgFeedStatisticMapper.selectSgFeedStatisticList(sgFeedStatistic);
}

View File

@@ -2,6 +2,7 @@ package com.zhyc.module.feed.service.impl;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import org.springframework.stereotype.Service;
import com.zhyc.module.feed.mapper.SgFormulaListMapper;
import com.zhyc.module.feed.domain.SgFormulaList;
@@ -41,6 +42,7 @@ public class SgFormulaListServiceImpl implements ISgFormulaListService {
* @return 配方列表
*/
@Override
@DataScope(deptAlias = "sg_formula_list_alias", userAlias = "sg_formula_list_alias")
public List<SgFormulaList> selectSgFormulaListList(SgFormulaList sgFormulaList) {
return sgFormulaListMapper.selectSgFormulaListList(sgFormulaList);
}

View File

@@ -4,6 +4,7 @@ import java.util.Iterator;
import java.util.List;
import java.util.Objects;
import com.zhyc.common.annotation.DataScope;
import com.zhyc.module.feed.domain.SgFormulaList;
import com.zhyc.module.feed.mapper.SgFormulaListMapper;
import org.springframework.stereotype.Service;
@@ -46,6 +47,7 @@ public class SgFormulaManagementServiceImpl implements ISgFormulaManagementServi
* @return 配方管理
*/
@Override
@DataScope(deptAlias = "sg_formula_management_alias", userAlias = "sg_formula_management_alias")
public List<SgFormulaManagement> selectSgFormulaManagementList(SgFormulaManagement sgFormulaManagement) {
List<SgFormulaManagement> sgFormulaManagements =
sgFormulaManagementMapper.selectSgFormulaManagementList(sgFormulaManagement);

View File

@@ -2,6 +2,8 @@ package com.zhyc.module.feed.service.impl;
import java.util.List;
import com.zhyc.common.annotation.DataScope;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.zhyc.module.feed.mapper.SgMaterialMapper;
import com.zhyc.module.feed.domain.SgMaterial;
@@ -11,16 +13,12 @@ import com.zhyc.module.feed.service.ISgMaterialService;
* 原料Service业务层处理
*
* @author HashMap
* @date 2025-08-11
* @date 2026-01-16
*/
@Service
public class SgMaterialServiceImpl implements ISgMaterialService
{
private final SgMaterialMapper sgMaterialMapper;
public SgMaterialServiceImpl(SgMaterialMapper sgMaterialMapper) {
this.sgMaterialMapper = sgMaterialMapper;
}
public class SgMaterialServiceImpl implements ISgMaterialService {
@Autowired
private SgMaterialMapper sgMaterialMapper;
/**
* 查询原料
@@ -29,8 +27,7 @@ public class SgMaterialServiceImpl implements ISgMaterialService
* @return 原料
*/
@Override
public SgMaterial selectSgMaterialByMaterialId(String materialId)
{
public SgMaterial selectSgMaterialByMaterialId(String materialId) {
return sgMaterialMapper.selectSgMaterialByMaterialId(materialId);
}
@@ -41,8 +38,8 @@ public class SgMaterialServiceImpl implements ISgMaterialService
* @return 原料
*/
@Override
public List<SgMaterial> selectSgMaterialList(SgMaterial sgMaterial)
{
@DataScope(deptAlias = "sg_material_alias", userAlias = "sg_material_alias")
public List<SgMaterial> selectSgMaterialList(SgMaterial sgMaterial) {
return sgMaterialMapper.selectSgMaterialList(sgMaterial);
}
@@ -53,8 +50,10 @@ public class SgMaterialServiceImpl implements ISgMaterialService
* @return 结果
*/
@Override
public int insertSgMaterial(SgMaterial sgMaterial)
{
public int insertSgMaterial(SgMaterial sgMaterial) {
if (sgMaterialMapper.selectSgMaterialByMaterialId(sgMaterial.getMaterialId()) != null) {
throw new RuntimeException("重复的编码或名称");
}
return sgMaterialMapper.insertSgMaterial(sgMaterial);
}
@@ -65,8 +64,7 @@ public class SgMaterialServiceImpl implements ISgMaterialService
* @return 结果
*/
@Override
public int updateSgMaterial(SgMaterial sgMaterial)
{
public int updateSgMaterial(SgMaterial sgMaterial) {
return sgMaterialMapper.updateSgMaterial(sgMaterial);
}
@@ -77,8 +75,7 @@ public class SgMaterialServiceImpl implements ISgMaterialService
* @return 结果
*/
@Override
public int deleteSgMaterialByMaterialIds(String[] materialIds)
{
public int deleteSgMaterialByMaterialIds(String[] materialIds) {
return sgMaterialMapper.deleteSgMaterialByMaterialIds(materialIds);
}
@@ -89,8 +86,7 @@ public class SgMaterialServiceImpl implements ISgMaterialService
* @return 结果
*/
@Override
public int deleteSgMaterialByMaterialId(String materialId)
{
public int deleteSgMaterialByMaterialId(String materialId) {
return sgMaterialMapper.deleteSgMaterialByMaterialId(materialId);
}
}

View File

@@ -37,7 +37,7 @@ public class DdFsController extends BaseController
/**
* 查询冻精库存列表
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:list')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:list')")
@GetMapping("/list")
public TableDataInfo list(DdFs ddFs)
{
@@ -49,7 +49,7 @@ public class DdFsController extends BaseController
/**
* 导出冻精库存列表
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:export')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:export')")
@Log(title = "冻精库存", businessType = BusinessType.EXPORT)
@PostMapping("/export")
public void export(HttpServletResponse response, DdFs ddFs)
@@ -62,7 +62,7 @@ public class DdFsController extends BaseController
/**
* 获取冻精库存详细信息
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:query')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:query')")
@GetMapping(value = "/{id}")
public AjaxResult getInfo(@PathVariable("id") Long id)
{
@@ -72,7 +72,7 @@ public class DdFsController extends BaseController
/**
* 新增冻精库存
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:add')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:add')")
@Log(title = "冻精库存", businessType = BusinessType.INSERT)
@PostMapping
public AjaxResult add(@RequestBody DdFs ddFs)
@@ -83,7 +83,7 @@ public class DdFsController extends BaseController
/**
* 修改冻精库存
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:edit')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:edit')")
@Log(title = "冻精库存", businessType = BusinessType.UPDATE)
@PutMapping
public AjaxResult edit(@RequestBody DdFs ddFs)
@@ -94,7 +94,7 @@ public class DdFsController extends BaseController
/**
* 删除冻精库存
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:remove')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:remove')")
@Log(title = "冻精库存", businessType = BusinessType.DELETE)
@DeleteMapping("/{ids}")
public AjaxResult remove(@PathVariable Long[] ids)
@@ -105,7 +105,7 @@ public class DdFsController extends BaseController
/**
* 批量废弃
*/
@PreAuthorize("@ss.hasPermi('sperm:sperm:discard')")
@PreAuthorize("@ss.hasPermi('frozen:sperm:discard')")
@Log(title = "冻精库存", businessType = BusinessType.UPDATE)
@PutMapping("/discard")
public AjaxResult discard(@RequestBody List<DdFs> list) {

View File

@@ -90,7 +90,7 @@ public class DdFe extends BaseEntity
@Excel(name = "废弃原因")
private String discardTxt;
public void setId(Long id)
public void setId(Long id)
{
this.id = id;
}

View File

@@ -5,14 +5,7 @@ import javax.servlet.http.HttpServletResponse;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.DeleteMapping;
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.RestController;
import org.springframework.web.bind.annotation.*;
import com.zhyc.common.annotation.Log;
import com.zhyc.common.core.controller.BaseController;
import com.zhyc.common.core.domain.AjaxResult;
@@ -103,4 +96,9 @@ public class ScBodyMeasureController extends BaseController
{
return toAjax(scBodyMeasureService.deleteScBodyMeasureByIds(ids));
}
@GetMapping("/search_ear_numbers")
public AjaxResult searchEarNumbers(@RequestParam("query") String query){
return success(scBodyMeasureService.searchEarNumbers(query.trim()));
}
}

Some files were not shown because too many files have changed in this diff Show More