shiwan/admin/src/main/java/com/huimv/admin/controller/primary/AuthorizeController.java

@@ -25,7 +25,7 @@ public class AuthorizeController {
     IMenuService iMenuService;
 
     @RequestMapping("/saveAccountGroup")
-    public Result saveAccountGroup(@RequestParam(name = "accountId", required = true) String accountId, @RequestParam(name = "groupIds", required = true) String groupIds){
+    public Result saveAccountGroup(@RequestParam(name = "accountId") String accountId, @RequestParam(name = "groupIds") String groupIds){
         /*
          * 保存账号关联权限组数据
          */

shiwan/admin/src/main/java/com/huimv/admin/controller/primary/LoginController.java

@@ -66,6 +66,7 @@ public class LoginController {
         return iLoginService.logout();
     }
 
+    //获取验证码
     @RequestMapping(value = "getCheckNumber", produces = {"text/html;charset=UTF-8"})
     public void getCheckNumber(HttpServletResponse response) throws IOException {
         //创建对象

shiwan/admin/src/main/java/com/huimv/admin/controller/secondary/DaZsdaController.java

@@ -0,0 +1,38 @@
+package com.huimv.admin.controller.secondary;
+
+import com.huimv.admin.domain.secondary.DaZsda;
+import com.huimv.admin.service.secondary.DaZsdaService;
+import com.huimv.admin.utils.Result;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/DaZsda")
+public class DaZsdaController {
+
+	@Autowired
+	private DaZsdaService service;
+
+	@RequestMapping("/add")
+	public Result add(DaZsda childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(DaZsda childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , @RequestParam(required = false) Integer pageNum ,  @RequestParam(required = false)Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

shiwan/admin/src/main/java/com/huimv/admin/domain/secondary/DaJqda.java

@@ -0,0 +1,141 @@
+package com.huimv.admin.domain.secondary;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * 档案_机器档案
+ */
+@Entity
+@Table(name = "da_jqda")
+@Data
+public class DaJqda implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "ID", nullable = false)
+    private Integer ID;
+
+    /**
+     * 机器ID
+     */
+    @Column(name = "JQID")
+    private String JQID;
+
+    /**
+     * 猪舍ID
+     */
+    @Column(name = "ZSID")
+    private Integer ZSID;
+
+    /**
+     * 区划编码
+     */
+    @Column(name = "QHBM")
+    private String QHBM;
+
+    /**
+     * 目标版本
+     */
+    @Column(name = "MBBB")
+    private String MBBB;
+
+    /**
+     * ftp命令
+     */
+    @Column(name = "FTPCMD")
+    private String FTPCMD;
+
+    /**
+     * 修改人
+     */
+    @Column(name = "XGR")
+    private String XGR;
+
+    /**
+     * 修改时间
+     */
+    @Column(name = "XGSJ", nullable = false)
+    private Date XGSJ;
+
+    /**
+     * 作废标志
+     */
+    @Column(name = "ZFBZ")
+    private Integer ZFBZ;
+
+    /**
+     * 当前版本
+     */
+    @Column(name = "DQBB")
+    private String DQBB;
+
+    /**
+     * 环控当前版本
+     */
+    @Column(name = "HKDQBB")
+    private String HKDQBB;
+
+    /**
+     * 环控目标版本
+     */
+    @Column(name = "HKMBBB")
+    private String HKMBBB;
+
+    /**
+     * 环控CMD命令
+     */
+    @Column(name = "HKFTPCMD")
+    private String HKFTPCMD;
+
+    /**
+     * 料槽当前版本
+     */
+    @Column(name = "LCDQBB")
+    private String LCDQBB;
+
+    /**
+     * 料槽目标版本
+     */
+    @Column(name = "LCMBBB")
+    private String LCMBBB;
+
+    /**
+     * 料槽CMD命令
+     */
+    @Column(name = "LCFTPCMD")
+    private String LCFTPCMD;
+
+    /**
+     * 序列号
+     */
+    @Column(name = "XLH")
+    private String XLH;
+
+    /**
+     * 站点号
+     */
+    @Column(name = "ZDH")
+    private String ZDH;
+
+    @Column(name = "IMEI")
+    private String IMEI;
+
+    @Column(name = "IMSI")
+    private String IMSI;
+
+    @Column(name = "CCID")
+    private String CCID;
+
+    @Column(name = "ESIMNAME")
+    private String ESIMNAME;
+
+}

shiwan/admin/src/main/java/com/huimv/admin/domain/secondary/DaZsda.java

@@ -0,0 +1,76 @@
+package com.huimv.admin.domain.secondary;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.util.Date;
+
+@Data
+@Entity
+@Table(name = "da_zsda")
+public class DaZsda implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "MCID")
+	private Integer mcid;
+
+	@Column(name = "ZSMC")
+	private String zsmc;
+
+	@Column(name = "CSQ1")
+	private String csq1;
+
+	@Column(name = "CSQ2")
+	private String csq2;
+
+	@Column(name = "FLQ")
+	private String flq;
+
+	@Column(name = "DQLQ")
+	private String dqlq;
+
+	@Column(name = "YZJD")
+	private String yzjd;
+
+	@Column(name = "GLY")
+	private Integer gly;
+
+	@Column(name = "GLYXM")
+	private String glyxm;
+
+	@Column(name = "XGR")
+	private String xgr;
+
+	@Column(name = "XGSJ")
+	private Date xgsj;
+
+	@Column(name = "ZFBZ")
+	private Integer zfbz;
+
+	@Column(name = "ZSBZ")
+	private Integer zsbz;
+
+	@Column(name = "SSQY")
+	private Integer ssqy;
+
+	@Column(name = "LCBZ")
+	private Integer lcbz;
+
+	@Column(name = "HKBZ")
+	private Integer hkbz;
+
+	@Column(name = "ZDBZ")
+	private Integer zdbz;
+
+	@Column(name = "ZSQY")
+	private Integer zsqy;
+
+	@Column(name = "SPJK")
+	private String spjk;
+
+}

shiwan/admin/src/main/java/com/huimv/admin/repo/primary/SysAccountGroupEntityRepository.java

@@ -14,8 +14,8 @@ public interface SysAccountGroupEntityRepository extends JpaRepository<SysAccoun
 
     @Modifying
     @Transactional
-    @Query(nativeQuery = true,value = "DELETE FROM sys_account_group WHERE account_id=?1")
-    void removeAccountGroup(String accountId);
+    @Query(nativeQuery = true,value = "DELETE FROM sys_account_group WHERE group_id=?1")
+    void removeAccountGroup(String groupIds);
 
     @Query(nativeQuery = true,value = "SELECT * FROM sys_account_group WHERE account_id=?1")
     List<SysAccountGroupEntity> getGroupByAccount(String accountId);

shiwan/admin/src/main/java/com/huimv/admin/repo/secondary/DaJqdaRepo.java

@@ -0,0 +1,9 @@
+package com.huimv.admin.repo.secondary;
+
+import com.huimv.admin.domain.secondary.DaJqda;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+
+public interface DaJqdaRepo extends JpaRepository<DaJqda, Integer>, JpaSpecificationExecutor<DaJqda> {
+
+}

shiwan/admin/src/main/java/com/huimv/admin/repo/secondary/DaZsdaRepository.java

@@ -0,0 +1,17 @@
+package com.huimv.admin.repo.secondary;
+
+import com.huimv.admin.domain.secondary.DaZsda;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface DaZsdaRepository extends JpaRepository<DaZsda, Integer>, JpaSpecificationExecutor<DaZsda> {
+	
+	@Query(nativeQuery = true ,value = "select * from da_zsda where mcid like %?1% and MCID = 11 and ZFBZ = 0 limit ?2 , ?3")
+    List<DaZsda> findAll(String name, Integer startPage, Integer pageSize);
+
+    @Query(nativeQuery = true ,value = "SELECT MAX(id) FROM da_zsda ")
+    List<Integer> findMax();
+}

shiwan/admin/src/main/java/com/huimv/admin/service/primary/impl/AuthorizeServiceImpl.java

@@ -28,13 +28,17 @@ public class AuthorizeServiceImpl implements IAuthorizeService {
     @Autowired
     private SysMenuEntityRepository sysMenuEntityRepository;
 
-    @Override
+ /*   @Override
     @Transactional
     public Result saveAccountGroup(String accountId, String groupIds) {
-        /**
+        *//**
          * Step1:先删除原先的账号关联权限组数据；
          * Step2:再添加新的账号关联权限组数据；
-         */
+         *//*
+        if (groupIds == null||"".equals(groupIds)){
+            SysAccountGroupRepo.removeAccountGroup(accountId);
+            return new Result(10001, "保存账号关联权限组成功", true);
+        }
         String[] groupIdArray = groupIds.split(",");
         SysAccountGroupRepo.removeAccountGroup(accountId);
 //        for (int a = 0; a < groupIdArray.length; a++) {
@@ -48,6 +52,34 @@ public class AuthorizeServiceImpl implements IAuthorizeService {
 //            SysAccountGroupRepo.insert(Integer.parseInt(accountId),Integer.parseInt(groupIdArray[a]));
         }
         return new Result(10001, "保存账号关联权限组成功", true);
+    } */
+    @Override
+    @Transactional
+    public Result saveAccountGroup(String accountId, String groupIds) {
+        /**
+         * Step1:先删除原先的账号关联权限组数据；
+         * Step2:再添加新的账号关联权限组数据；
+         */
+        if (accountId == null||"".equals(accountId)){
+            SysAccountGroupRepo.removeAccountGroup(groupIds);
+            return new Result(10001, "保存账号关联权限组成功", true);
+        }else {
+            String[] groupIdArray = accountId.split(",");
+            SysAccountGroupRepo.removeAccountGroup(groupIds);
+//        for (int a = 0; a < groupIdArray.length; a++) {
+//            SysAccountGroupRepo.removeAccountGroup(accountId,groupIdArray[a]);
+//        }
+            for (int a = 0; a < groupIdArray.length; a++) {
+                SysAccountGroupEntity accountGroupEntity = new SysAccountGroupEntity();
+                accountGroupEntity.setAccountId(Integer.parseInt(groupIdArray[a]));
+                accountGroupEntity.setGroupId(Integer.parseInt(groupIds));
+                SysAccountGroupRepo.saveAndFlush(accountGroupEntity);
+//            SysAccountGroupRepo.insert(Integer.parseInt(accountId),Integer.parseInt(groupIdArray[a]));
+            }
+            return new Result(10001, "保存账号关联权限组成功", true);
+        }
+
+
     }
 
     @Override

shiwan/admin/src/main/java/com/huimv/admin/service/primary/impl/GroupServiceImpl.java

@@ -50,7 +50,7 @@ public class GroupServiceImpl implements IGroupService {
             this.sysGroupEntityRepository.deleteById(groupId);
             // 删除权限组关联菜单
             sysGroupMenuEntityRepository.deleteByGroupId(groupId);
-            return new Result(10001,"删除成功",true);
+            return new Result(10000,"删除成功",true);
         }catch (Exception e){
             return new Result(10001,"删除失败",false);
         }

shiwan/admin/src/main/java/com/huimv/admin/service/secondary/DaZsdaService.java

@@ -0,0 +1,23 @@
+package com.huimv.admin.service.secondary;
+
+
+import com.huimv.admin.domain.secondary.DaZsda;
+import com.huimv.admin.utils.Result;
+
+public interface DaZsdaService {
+
+   //添加
+   Result add(DaZsda entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(DaZsda entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/admin/src/main/java/com/huimv/admin/service/secondary/impl/DaZsdaServiceImpl.java

@@ -0,0 +1,109 @@
+package com.huimv.admin.service.secondary.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.huimv.admin.domain.secondary.DaJqda;
+import com.huimv.admin.domain.secondary.DaZsda;
+import com.huimv.admin.repo.secondary.DaJqdaRepo;
+import com.huimv.admin.repo.secondary.DaZsdaRepository;
+import com.huimv.admin.service.secondary.DaZsdaService;
+import com.huimv.admin.utils.Result;
+import com.huimv.admin.utils.ResultCode;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+@DS("thired")
+public class DaZsdaServiceImpl implements DaZsdaService {
+
+	@Autowired
+	private DaZsdaRepository rep;
+
+	@Autowired
+	private DaJqdaRepo jqdaRepo;
+
+	@Override
+	public Result add(DaZsda entity){
+		if (entity == null){
+
+			return new Result(ResultCode.FAIL);
+		}
+		try {
+
+			entity.setMcid(11);
+			Integer  id = rep.findMax().get(0);
+			entity.setXgsj(new Date());
+			DaJqda daJqda =new DaJqda() ;
+			daJqda.setZSID(id);
+			jqdaRepo.save(daJqda);
+			rep.save(entity);
+
+			return new Result(ResultCode.SUCCESS);
+		}catch (Exception e){
+			return new Result(ResultCode.FAIL);
+		}
+	}
+
+
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(ResultCode.FAIL);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(ResultCode.SUCCESS);
+		}catch (Exception e){
+			return new Result(ResultCode.FAIL);
+		}
+	}
+
+	@Override
+	public Result update(DaZsda entity) {
+		if (entity == null){
+			return new Result(ResultCode.FAIL);
+		}
+		try {
+			entity.setMcid(11);
+			entity.setXgsj(new Date());
+			rep.save(entity);
+			return new Result(ResultCode.SUCCESS);
+		}catch (Exception e){
+			return new Result(ResultCode.FAIL);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<DaZsda> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(ResultCode.SUCCESS,map);
+		}catch (Exception e){
+			return new Result(ResultCode.FAIL);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			DaZsda entity = rep.findById(id).get();
+			return new Result(ResultCode.SUCCESS);
+		}catch (Exception e){
+			return new Result(ResultCode.FAIL);
+		}
+	}
+}

shiwan/admin/src/main/resources/application-test.yml

@@ -33,7 +33,7 @@ spring:
 
   redis:
     database: 0
-    host: 124.71.192.190
+    host: 122.112.224.199
     port: 6379
     password: hm123456
     jedis:

shiwan/admin/src/main/resources/beans.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
+
+</beans>

shiwan/admin/src/test/java/com/huimv/admin/AdminApplicationTests.java

@@ -3,11 +3,24 @@ package com.huimv.admin;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.test.context.SpringBootTest;
 
-@SpringBootTest
+import java.io.Console;
+import java.io.IOException;
+import java.nio.channels.Channel;
+import java.util.Map;
+import java.util.Properties;
+
 class AdminApplicationTests {
 
     @Test
-    void contextLoads() {
+    void contextLoads() throws IOException {
+
+        Properties properties = System.getProperties();
+        Object o1 = System.getProperties().get("sun.desktop");
+        System.out.println(o1);
+        for (Object o : properties.keySet()) {
+            System.out.println(""+o+"-->"+properties.get(o));
+        }
+
     }
 
 }

shiwan/video/src/main/java/com/huimv/video/controller/AllDataController.java

@@ -0,0 +1,29 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkSd;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.AllDataService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.video.controller
+ * @Description : TODO
+ * @Author : yuxuexuan
+ * @Create : 2021/3/31 0031 14:00
+ **/
+@RestController
+@CrossOrigin
+@RequestMapping("/allDataController")
+public class AllDataController {
+    @Autowired
+    private AllDataService allDataService;
+
+    @RequestMapping(value="/getZsda")
+    public Result getZsda(){
+        //
+        return allDataService.getZsda();
+    }
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/CameraInfoController.java

@@ -91,4 +91,14 @@ public class CameraInfoController {
             return new Result(10001,"查询失败");
         }
     }
+
+//    @RequestMapping("/getCameraDetailsByLqid")
+//    private Result getCameraDetailsByLqid(Integer LQID){
+//        try {
+////            List list =  cameraInfoService.getCameraDetails(areaIds);
+////            return new Result(10000,"查询成功",list);
+//        }catch (Exception e){
+//            return new Result(10001,"查询失败");
+//        }
+//    }
 }

shiwan/video/src/main/java/com/huimv/video/controller/MobileUserController.java

@@ -0,0 +1,40 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.MobileUser;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.MobileUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/mobileUser")
+public class MobileUserController {
+
+	@Autowired
+	private MobileUserService service;
+
+	@RequestMapping("/register")
+	public Result add(MobileUser childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(MobileUser childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+	@RequestMapping("/login")
+	public Result login(String account, String password){ return service.login(account,password); }
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/SjHkAqController.java

@@ -0,0 +1,42 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.SjHkAqService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/SjHkAq")
+public class SjHkAqController {
+
+	@Autowired
+	private SjHkAqService service;
+
+	@RequestMapping("/add")
+	public Result add(SjHkAq childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(SjHkAq childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+	@RequestMapping("/findAllByLQID")
+	public Result findAllByLQID(Integer LQID){
+		return service.findAllByLQID(LQID);
+	}
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/SjHkDlController.java

@@ -0,0 +1,37 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkDl;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.SjHkDlService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/SjHkDl")
+public class SjHkDlController {
+
+	@Autowired
+	private SjHkDlService service;
+
+	@RequestMapping("/add")
+	public Result add(SjHkDl childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(SjHkDl childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/SjHkPhController.java

@@ -0,0 +1,37 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkPh;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.SjHkPhService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/SjHkPh")
+public class SjHkPhController {
+
+	@Autowired
+	private SjHkPhService service;
+
+	@RequestMapping("/add")
+	public Result add(SjHkPh childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(SjHkPh childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/SjHkSdController.java

@@ -0,0 +1,37 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkSd;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.SjHkSdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/SjHkSd")
+public class SjHkSdController {
+
+	@Autowired
+	private SjHkSdService service;
+
+	@RequestMapping("/add")
+	public Result add(SjHkSd childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(SjHkSd childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/SjHkSlController.java

@@ -0,0 +1,37 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkSl;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.SjHkSlService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/SjHkSl")
+public class SjHkSlController {
+
+	@Autowired
+	private SjHkSlService service;
+
+	@RequestMapping("/add")
+	public Result add(SjHkSl childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(SjHkSl childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

shiwan/video/src/main/java/com/huimv/video/controller/SjHkWdController.java

@@ -0,0 +1,37 @@
+package com.huimv.video.controller;
+
+import com.huimv.video.domain.SjHkWd;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.SjHkWdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.CrossOrigin;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@CrossOrigin
+@RequestMapping("/SjHkWd")
+public class SjHkWdController {
+
+	@Autowired
+	private SjHkWdService service;
+
+	@RequestMapping("/add")
+	public Result add(SjHkWd childcareEntity){ return service.add(childcareEntity); }
+
+	@RequestMapping("/remove")
+	public Result remove(Integer[] ids){ return service.remove(ids); }
+
+	@RequestMapping("/update")
+	public Result update(SjHkWd childcareEntity){ return service.update(childcareEntity); }
+
+	@RequestMapping("/findAllById")
+	public Result findAllById(Integer id){ return service.findAllById(id); }
+
+
+	@RequestMapping("/findAll")
+	public Result findAll(String name , Integer pageNum , Integer pageSize){
+		return service.findAll(name,pageNum,pageSize);
+	}
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/CameraInfo.java

@@ -41,4 +41,6 @@ public class CameraInfo {
     @Column(name = "remark")
     private String remark;
 
+    @Column(name = "LQID")
+    private Integer LQID;
 }

shiwan/video/src/main/java/com/huimv/video/domain/DaLqdaEntity.java

@@ -0,0 +1,571 @@
+package com.huimv.video.domain;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.sql.Date;
+import java.sql.Timestamp;
+
+/**
+ * 档案-栏期信息
+ */
+@Entity
+@Table(name = "da_lqda")
+public class DaLqdaEntity implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "ID", nullable = false)
+    private Integer ID;
+
+    /**
+     * 牧场编号
+     */
+    @Column(name = "ZSID", nullable = false)
+    private Integer ZSID;
+
+    /**
+     * 栏期名称
+     */
+    @Column(name = "LQMC")
+    private String LQMC;
+
+    /**
+     * 建栏时间
+     */
+    @Column(name = "JLSJ")
+    private Date JLSJ;
+
+    /**
+     * 计划栏结束时间
+     */
+    @Column(name = "JHLJSSJ")
+    private Date JHLJSSJ;
+
+    /**
+     * 实际栏结束时间
+     */
+    @Column(name = "SJLJSSJ")
+    private Date SJLJSSJ;
+
+    /**
+     * 入栏平均体重
+     */
+    @Column(name = "RLPJTZ")
+    private BigDecimal RLPJTZ;
+
+    /**
+     * 在栏动物数
+     */
+    @Column(name = "ZLS")
+    private BigDecimal ZLS;
+
+    /**
+     * 入栏动物数
+     */
+    @Column(name = "RLS")
+    private BigDecimal RLS;
+
+    /**
+     * 死亡动物数
+     */
+    @Column(name = "SWS")
+    private BigDecimal SWS;
+
+    /**
+     * 售出动物数
+     */
+    @Column(name = "SCS")
+    private BigDecimal SCS;
+
+    /**
+     * 隔离动物数
+     */
+    @Column(name = "GLS")
+    private BigDecimal GLS;
+
+    /**
+     * 耳标丢失数
+     */
+    @Column(name = "EBDSS")
+    private BigDecimal EBDSS;
+
+    /**
+     * 管理员
+     */
+    @Column(name = "GLY")
+    private String GLY;
+
+    /**
+     * 挑选开始日期
+     */
+    @Column(name = "TXKSRQ")
+    private Date TXKSRQ;
+
+    /**
+     * 挑选开始标识
+     */
+    @Column(name = "TXKSBZ")
+    private BigDecimal TXKSBZ;
+
+    /**
+     * 统计开始日期
+     */
+    @Column(name = "TJKSRQ")
+    private Date TJKSRQ;
+
+    /**
+     * 初始遗留饲料量
+     */
+    @Column(name = "CSYLSLL")
+    private BigDecimal CSYLSLL;
+
+    /**
+     * 结束剩余饲料量
+     */
+    @Column(name = "JSSYSLL")
+    private BigDecimal JSSYSLL;
+
+    /**
+     * 修改人
+     */
+    @Column(name = "XGR")
+    private String XGR;
+
+    /**
+     * 修改时间
+     */
+    @Column(name = "XGSJ")
+    private Timestamp XGSJ;
+
+    /**
+     * 作废标识
+     */
+    @Column(name = "ZFBZ")
+    private Integer ZFBZ;
+
+    /**
+     * 出栏数
+     */
+    @Column(name = "CLS")
+    private BigDecimal CLS;
+
+    /**
+     * 淘汰数
+     */
+    @Column(name = "TTS")
+    private BigDecimal TTS;
+
+    /**
+     * 体重统计时间
+     */
+    @Column(name = "TZTJSJ")
+    private Timestamp TZTJSJ;
+
+    /**
+     * 入栏日龄
+     */
+    @Column(name = "RLRL")
+    private String RLRL;
+
+    /**
+     * ID
+     */
+    public void setID(Integer ID) {
+        this.ID = ID;
+    }
+
+    /**
+     * ID
+     */
+    public Integer getID() {
+        return ID;
+    }
+
+    /**
+     * 牧场编号
+     */
+    public void setZSID(Integer ZSID) {
+        this.ZSID = ZSID;
+    }
+
+    /**
+     * 牧场编号
+     */
+    public Integer getZSID() {
+        return ZSID;
+    }
+
+    /**
+     * 栏期名称
+     */
+    public void setLQMC(String LQMC) {
+        this.LQMC = LQMC;
+    }
+
+    /**
+     * 栏期名称
+     */
+    public String getLQMC() {
+        return LQMC;
+    }
+
+    /**
+     * 建栏时间
+     */
+    public void setJLSJ(Date JLSJ) {
+        this.JLSJ = JLSJ;
+    }
+
+    /**
+     * 建栏时间
+     */
+    public Date getJLSJ() {
+        return JLSJ;
+    }
+
+    /**
+     * 计划栏结束时间
+     */
+    public void setJHLJSSJ(Date JHLJSSJ) {
+        this.JHLJSSJ = JHLJSSJ;
+    }
+
+    /**
+     * 计划栏结束时间
+     */
+    public Date getJHLJSSJ() {
+        return JHLJSSJ;
+    }
+
+    /**
+     * 实际栏结束时间
+     */
+    public void setSJLJSSJ(Date SJLJSSJ) {
+        this.SJLJSSJ = SJLJSSJ;
+    }
+
+    /**
+     * 实际栏结束时间
+     */
+    public Date getSJLJSSJ() {
+        return SJLJSSJ;
+    }
+
+    /**
+     * 入栏平均体重
+     */
+    public void setRLPJTZ(BigDecimal RLPJTZ) {
+        this.RLPJTZ = RLPJTZ;
+    }
+
+    /**
+     * 入栏平均体重
+     */
+    public BigDecimal getRLPJTZ() {
+        return RLPJTZ;
+    }
+
+    /**
+     * 在栏动物数
+     */
+    public void setZLS(BigDecimal ZLS) {
+        this.ZLS = ZLS;
+    }
+
+    /**
+     * 在栏动物数
+     */
+    public BigDecimal getZLS() {
+        return ZLS;
+    }
+
+    /**
+     * 入栏动物数
+     */
+    public void setRLS(BigDecimal RLS) {
+        this.RLS = RLS;
+    }
+
+    /**
+     * 入栏动物数
+     */
+    public BigDecimal getRLS() {
+        return RLS;
+    }
+
+    /**
+     * 死亡动物数
+     */
+    public void setSWS(BigDecimal SWS) {
+        this.SWS = SWS;
+    }
+
+    /**
+     * 死亡动物数
+     */
+    public BigDecimal getSWS() {
+        return SWS;
+    }
+
+    /**
+     * 售出动物数
+     */
+    public void setSCS(BigDecimal SCS) {
+        this.SCS = SCS;
+    }
+
+    /**
+     * 售出动物数
+     */
+    public BigDecimal getSCS() {
+        return SCS;
+    }
+
+    /**
+     * 隔离动物数
+     */
+    public void setGLS(BigDecimal GLS) {
+        this.GLS = GLS;
+    }
+
+    /**
+     * 隔离动物数
+     */
+    public BigDecimal getGLS() {
+        return GLS;
+    }
+
+    /**
+     * 耳标丢失数
+     */
+    public void setEBDSS(BigDecimal EBDSS) {
+        this.EBDSS = EBDSS;
+    }
+
+    /**
+     * 耳标丢失数
+     */
+    public BigDecimal getEBDSS() {
+        return EBDSS;
+    }
+
+    /**
+     * 管理员
+     */
+    public void setGLY(String GLY) {
+        this.GLY = GLY;
+    }
+
+    /**
+     * 管理员
+     */
+    public String getGLY() {
+        return GLY;
+    }
+
+    /**
+     * 挑选开始日期
+     */
+    public void setTXKSRQ(Date TXKSRQ) {
+        this.TXKSRQ = TXKSRQ;
+    }
+
+    /**
+     * 挑选开始日期
+     */
+    public Date getTXKSRQ() {
+        return TXKSRQ;
+    }
+
+    /**
+     * 挑选开始标识
+     */
+    public void setTXKSBZ(BigDecimal TXKSBZ) {
+        this.TXKSBZ = TXKSBZ;
+    }
+
+    /**
+     * 挑选开始标识
+     */
+    public BigDecimal getTXKSBZ() {
+        return TXKSBZ;
+    }
+
+    /**
+     * 统计开始日期
+     */
+    public void setTJKSRQ(Date TJKSRQ) {
+        this.TJKSRQ = TJKSRQ;
+    }
+
+    /**
+     * 统计开始日期
+     */
+    public Date getTJKSRQ() {
+        return TJKSRQ;
+    }
+
+    /**
+     * 初始遗留饲料量
+     */
+    public void setCSYLSLL(BigDecimal CSYLSLL) {
+        this.CSYLSLL = CSYLSLL;
+    }
+
+    /**
+     * 初始遗留饲料量
+     */
+    public BigDecimal getCSYLSLL() {
+        return CSYLSLL;
+    }
+
+    /**
+     * 结束剩余饲料量
+     */
+    public void setJSSYSLL(BigDecimal JSSYSLL) {
+        this.JSSYSLL = JSSYSLL;
+    }
+
+    /**
+     * 结束剩余饲料量
+     */
+    public BigDecimal getJSSYSLL() {
+        return JSSYSLL;
+    }
+
+    /**
+     * 修改人
+     */
+    public void setXGR(String XGR) {
+        this.XGR = XGR;
+    }
+
+    /**
+     * 修改人
+     */
+    public String getXGR() {
+        return XGR;
+    }
+
+    /**
+     * 修改时间
+     */
+    public void setXGSJ(Timestamp XGSJ) {
+        this.XGSJ = XGSJ;
+    }
+
+    /**
+     * 修改时间
+     */
+    public Timestamp getXGSJ() {
+        return XGSJ;
+    }
+
+    /**
+     * 作废标识
+     */
+    public void setZFBZ(Integer ZFBZ) {
+        this.ZFBZ = ZFBZ;
+    }
+
+    /**
+     * 作废标识
+     */
+    public Integer getZFBZ() {
+        return ZFBZ;
+    }
+
+    /**
+     * 出栏数
+     */
+    public void setCLS(BigDecimal CLS) {
+        this.CLS = CLS;
+    }
+
+    /**
+     * 出栏数
+     */
+    public BigDecimal getCLS() {
+        return CLS;
+    }
+
+    /**
+     * 淘汰数
+     */
+    public void setTTS(BigDecimal TTS) {
+        this.TTS = TTS;
+    }
+
+    /**
+     * 淘汰数
+     */
+    public BigDecimal getTTS() {
+        return TTS;
+    }
+
+    /**
+     * 体重统计时间
+     */
+    public void setTZTJSJ(Timestamp TZTJSJ) {
+        this.TZTJSJ = TZTJSJ;
+    }
+
+    /**
+     * 体重统计时间
+     */
+    public Timestamp getTZTJSJ() {
+        return TZTJSJ;
+    }
+
+    /**
+     * 入栏日龄
+     */
+    public void setRLRL(String RLRL) {
+        this.RLRL = RLRL;
+    }
+
+    /**
+     * 入栏日龄
+     */
+    public String getRLRL() {
+        return RLRL;
+    }
+
+    @Override
+    public String toString() {
+        return "DaLqdaEntity{" +
+                "ID=" + ID + '\'' +
+                "ZSID=" + ZSID + '\'' +
+                "LQMC=" + LQMC + '\'' +
+                "JLSJ=" + JLSJ + '\'' +
+                "JHLJSSJ=" + JHLJSSJ + '\'' +
+                "SJLJSSJ=" + SJLJSSJ + '\'' +
+                "RLPJTZ=" + RLPJTZ + '\'' +
+                "ZLS=" + ZLS + '\'' +
+                "RLS=" + RLS + '\'' +
+                "SWS=" + SWS + '\'' +
+                "SCS=" + SCS + '\'' +
+                "GLS=" + GLS + '\'' +
+                "EBDSS=" + EBDSS + '\'' +
+                "GLY=" + GLY + '\'' +
+                "TXKSRQ=" + TXKSRQ + '\'' +
+                "TXKSBZ=" + TXKSBZ + '\'' +
+                "TJKSRQ=" + TJKSRQ + '\'' +
+                "CSYLSLL=" + CSYLSLL + '\'' +
+                "JSSYSLL=" + JSSYSLL + '\'' +
+                "XGR=" + XGR + '\'' +
+                "XGSJ=" + XGSJ + '\'' +
+                "ZFBZ=" + ZFBZ + '\'' +
+                "CLS=" + CLS + '\'' +
+                "TTS=" + TTS + '\'' +
+                "TZTJSJ=" + TZTJSJ + '\'' +
+                "RLRL=" + RLRL + '\'' +
+                '}';
+    }
+}

shiwan/video/src/main/java/com/huimv/video/domain/DaZsdaEntity.java

@@ -0,0 +1,492 @@
+package com.huimv.video.domain;
+
+import javax.persistence.*;
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.sql.Timestamp;
+
+/**
+ * 档案-猪舍信息
+ */
+@Entity
+@Table(name = "da_zsda")
+public class DaZsdaEntity implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * ID
+     */
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "ID", nullable = false)
+    private Integer ID;
+
+    /**
+     * 牧场编号
+     */
+    @Column(name = "MCID", nullable = false)
+    private Integer MCID;
+
+    /**
+     * 猪舍名称
+     */
+    @Column(name = "ZSMC")
+    private String ZSMC;
+
+    /**
+     * 采食区1
+     */
+    @Column(name = "CSQ1")
+    private String CSQ1;
+
+    /**
+     * 采食区2
+     */
+    @Column(name = "CSQ2")
+    private String CSQ2;
+
+    /**
+     * 分离区
+     */
+    @Column(name = "FLQ")
+    private String FLQ;
+
+    /**
+     * 当前栏期
+     */
+    @Column(name = "DQLQ")
+    private String DQLQ;
+
+    /**
+     * 养殖阶段
+     */
+    @Column(name = "YZJD")
+    private String YZJD;
+
+    /**
+     * 管理员ID
+     */
+    @Column(name = "GLY")
+    private Integer GLY;
+
+    /**
+     * 管理员姓名
+     */
+    @Column(name = "GLYXM")
+    private String GLYXM;
+
+    /**
+     * 修改人
+     */
+    @Column(name = "XGR")
+    private String XGR;
+
+    /**
+     * 修改日期
+     */
+    @Column(name = "XGSJ")
+    private Timestamp XGSJ;
+
+    /**
+     * 作废标识
+     */
+    @Column(name = "ZFBZ")
+    private Integer ZFBZ;
+
+    /**
+     * 猪舍标志
+     */
+    @Column(name = "ZSBZ")
+    private Integer ZSBZ;
+
+    /**
+     * 所属区域
+     */
+    @Column(name = "SSQY")
+    private Integer SSQY;
+
+    /**
+     * 料槽标志 1-智能料槽 2-普通料槽
+     */
+    @Column(name = "LCBZ")
+    private Integer LCBZ;
+
+    /**
+     * 环控标志 1-智能环控 2-普通环控
+     */
+    @Column(name = "HKBZ")
+    private Integer HKBZ;
+
+    /**
+     * 置顶标志 0-不置顶 1-置顶
+     */
+    @Column(name = "ZDBZ")
+    private Integer ZDBZ;
+
+    /**
+     * 猪舍区域
+     */
+    @Column(name = "ZSQY")
+    private Integer ZSQY;
+
+    /**
+     * 视频监控
+     */
+    @Column(name = "SPJK")
+    private String SPJK;
+
+    @Transient
+    private int lqid;
+    @Transient
+    private BigDecimal dqwd;
+    @Transient
+    private BigDecimal dqsd;
+
+    public BigDecimal getDqwd() {
+        return dqwd;
+    }
+
+    public void setDqwd(BigDecimal dqwd) {
+        this.dqwd = dqwd;
+    }
+
+    public BigDecimal getDqsd() {
+        return dqsd;
+    }
+
+    public void setDqsd(BigDecimal dqsd) {
+        this.dqsd = dqsd;
+    }
+
+    public BigDecimal getDqaq() {
+        return dqaq;
+    }
+
+    public void setDqaq(BigDecimal dqaq) {
+        this.dqaq = dqaq;
+    }
+
+    @Transient
+    private BigDecimal dqaq;
+
+
+
+    public int getLqid() {
+        return lqid;
+    }
+
+    public void setLqid(int lqid) {
+        this.lqid = lqid;
+    }
+
+    /**
+     * ID
+     */
+    public void setID(Integer ID) {
+        this.ID = ID;
+    }
+
+    /**
+     * ID
+     */
+    public Integer getID() {
+        return ID;
+    }
+
+    /**
+     * 牧场编号
+     */
+    public void setMCID(Integer MCID) {
+        this.MCID = MCID;
+    }
+
+    /**
+     * 牧场编号
+     */
+    public Integer getMCID() {
+        return MCID;
+    }
+
+    /**
+     * 猪舍名称
+     */
+    public void setZSMC(String ZSMC) {
+        this.ZSMC = ZSMC;
+    }
+
+    /**
+     * 猪舍名称
+     */
+    public String getZSMC() {
+        return ZSMC;
+    }
+
+    /**
+     * 采食区1
+     */
+    public void setCSQ1(String CSQ1) {
+        this.CSQ1 = CSQ1;
+    }
+
+    /**
+     * 采食区1
+     */
+    public String getCSQ1() {
+        return CSQ1;
+    }
+
+    /**
+     * 采食区2
+     */
+    public void setCSQ2(String CSQ2) {
+        this.CSQ2 = CSQ2;
+    }
+
+    /**
+     * 采食区2
+     */
+    public String getCSQ2() {
+        return CSQ2;
+    }
+
+    /**
+     * 分离区
+     */
+    public void setFLQ(String FLQ) {
+        this.FLQ = FLQ;
+    }
+
+    /**
+     * 分离区
+     */
+    public String getFLQ() {
+        return FLQ;
+    }
+
+    /**
+     * 当前栏期
+     */
+    public void setDQLQ(String DQLQ) {
+        this.DQLQ = DQLQ;
+    }
+
+    /**
+     * 当前栏期
+     */
+    public String getDQLQ() {
+        return DQLQ;
+    }
+
+    /**
+     * 养殖阶段
+     */
+    public void setYZJD(String YZJD) {
+        this.YZJD = YZJD;
+    }
+
+    /**
+     * 养殖阶段
+     */
+    public String getYZJD() {
+        return YZJD;
+    }
+
+    /**
+     * 管理员ID
+     */
+    public void setGLY(Integer GLY) {
+        this.GLY = GLY;
+    }
+
+    /**
+     * 管理员ID
+     */
+    public Integer getGLY() {
+        return GLY;
+    }
+
+    /**
+     * 管理员姓名
+     */
+    public void setGLYXM(String GLYXM) {
+        this.GLYXM = GLYXM;
+    }
+
+    /**
+     * 管理员姓名
+     */
+    public String getGLYXM() {
+        return GLYXM;
+    }
+
+    /**
+     * 修改人
+     */
+    public void setXGR(String XGR) {
+        this.XGR = XGR;
+    }
+
+    /**
+     * 修改人
+     */
+    public String getXGR() {
+        return XGR;
+    }
+
+    /**
+     * 修改日期
+     */
+    public void setXGSJ(Timestamp XGSJ) {
+        this.XGSJ = XGSJ;
+    }
+
+    /**
+     * 修改日期
+     */
+    public Timestamp getXGSJ() {
+        return XGSJ;
+    }
+
+    /**
+     * 作废标识
+     */
+    public void setZFBZ(Integer ZFBZ) {
+        this.ZFBZ = ZFBZ;
+    }
+
+    /**
+     * 作废标识
+     */
+    public Integer getZFBZ() {
+        return ZFBZ;
+    }
+
+    /**
+     * 猪舍标志
+     */
+    public void setZSBZ(Integer ZSBZ) {
+        this.ZSBZ = ZSBZ;
+    }
+
+    /**
+     * 猪舍标志
+     */
+    public Integer getZSBZ() {
+        return ZSBZ;
+    }
+
+    /**
+     * 所属区域
+     */
+    public void setSSQY(Integer SSQY) {
+        this.SSQY = SSQY;
+    }
+
+    /**
+     * 所属区域
+     */
+    public Integer getSSQY() {
+        return SSQY;
+    }
+
+    /**
+     * 料槽标志 1-智能料槽 2-普通料槽
+     */
+    public void setLCBZ(Integer LCBZ) {
+        this.LCBZ = LCBZ;
+    }
+
+    /**
+     * 料槽标志 1-智能料槽 2-普通料槽
+     */
+    public Integer getLCBZ() {
+        return LCBZ;
+    }
+
+    /**
+     * 环控标志 1-智能环控 2-普通环控
+     */
+    public void setHKBZ(Integer HKBZ) {
+        this.HKBZ = HKBZ;
+    }
+
+    /**
+     * 环控标志 1-智能环控 2-普通环控
+     */
+    public Integer getHKBZ() {
+        return HKBZ;
+    }
+
+    /**
+     * 置顶标志 0-不置顶 1-置顶
+     */
+    public void setZDBZ(Integer ZDBZ) {
+        this.ZDBZ = ZDBZ;
+    }
+
+    /**
+     * 置顶标志 0-不置顶 1-置顶
+     */
+    public Integer getZDBZ() {
+        return ZDBZ;
+    }
+
+    /**
+     * 猪舍区域
+     */
+    public void setZSQY(Integer ZSQY) {
+        this.ZSQY = ZSQY;
+    }
+
+    /**
+     * 猪舍区域
+     */
+    public Integer getZSQY() {
+        return ZSQY;
+    }
+
+    /**
+     * 视频监控
+     */
+    public void setSPJK(String SPJK) {
+        this.SPJK = SPJK;
+    }
+
+    /**
+     * 视频监控
+     */
+    public String getSPJK() {
+        return SPJK;
+    }
+
+    @Override
+    public String toString() {
+        return "DaZsdaEntity{" +
+                "ID=" + ID +
+                ", MCID=" + MCID +
+                ", ZSMC='" + ZSMC + '\'' +
+                ", CSQ1='" + CSQ1 + '\'' +
+                ", CSQ2='" + CSQ2 + '\'' +
+                ", FLQ='" + FLQ + '\'' +
+                ", DQLQ='" + DQLQ + '\'' +
+                ", YZJD='" + YZJD + '\'' +
+                ", GLY=" + GLY +
+                ", GLYXM='" + GLYXM + '\'' +
+                ", XGR='" + XGR + '\'' +
+                ", XGSJ=" + XGSJ +
+                ", ZFBZ=" + ZFBZ +
+                ", ZSBZ=" + ZSBZ +
+                ", SSQY=" + SSQY +
+                ", LCBZ=" + LCBZ +
+                ", HKBZ=" + HKBZ +
+                ", ZDBZ=" + ZDBZ +
+                ", ZSQY=" + ZSQY +
+                ", SPJK='" + SPJK + '\'' +
+                ", lqid=" + lqid +
+                ", dqwd=" + dqwd +
+                ", dqsd=" + dqsd +
+                ", dqaq=" + dqaq +
+                '}';
+    }
+}

shiwan/video/src/main/java/com/huimv/video/domain/MobileUser.java

@@ -0,0 +1,27 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "mobile_user")
+public class MobileUser implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "id")
+	private Integer id;
+
+	@Column(name = "account")
+	private String account;
+
+	@Column(name = "password")
+	private String password;
+
+	@Column(name = "user_name")
+	private String userName;
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/SjHkAq.java

@@ -0,0 +1,33 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "sj_hk_aq")
+public class SjHkAq implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "LQID")
+	private Integer lqid;
+
+	@Column(name = "CGQID")
+	private String cgqid;
+
+	@Column(name = "DQAQ")
+	private Double dqaq;
+
+	@Column(name = "CJSJ")
+	private java.util.Date cjsj;
+
+	@Column(name = "SCSJ")
+	private java.util.Date scsj;
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/SjHkDl.java

@@ -0,0 +1,33 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "sj_hk_dl")
+public class SjHkDl implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "LQID")
+	private Integer lqid;
+
+	@Column(name = "CGQID")
+	private String cgqid;
+
+	@Column(name = "DQDL")
+	private Double dqdl;
+
+	@Column(name = "CJSJ")
+	private java.util.Date cjsj;
+
+	@Column(name = "SCSJ")
+	private java.util.Date scsj;
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/SjHkPh.java

@@ -0,0 +1,33 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "sj_hk_ph")
+public class SjHkPh implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "LQID")
+	private Integer lqid;
+
+	@Column(name = "CGQID")
+	private String cgqid;
+
+	@Column(name = "DQPH")
+	private Double dqph;
+
+	@Column(name = "CJSJ")
+	private java.util.Date cjsj;
+
+	@Column(name = "SCSJ")
+	private java.util.Date scsj;
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/SjHkSd.java

@@ -0,0 +1,33 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "sj_hk_sd")
+public class SjHkSd implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "LQID")
+	private Integer lqid;
+
+	@Column(name = "CGQID")
+	private String cgqid;
+
+	@Column(name = "DQSD")
+	private Double dqsd;
+
+	@Column(name = "CJSJ")
+	private java.util.Date cjsj;
+
+	@Column(name = "SCSJ")
+	private java.util.Date scsj;
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/SjHkSl.java

@@ -0,0 +1,33 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "sj_hk_sl")
+public class SjHkSl implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "LQID")
+	private Integer lqid;
+
+	@Column(name = "CGQID")
+	private String cgqid;
+
+	@Column(name = "DQSL")
+	private Double dqsl;
+
+	@Column(name = "CJSJ")
+	private java.util.Date cjsj;
+
+	@Column(name = "SCSJ")
+	private java.util.Date scsj;
+
+}

shiwan/video/src/main/java/com/huimv/video/domain/SjHkWd.java

@@ -0,0 +1,33 @@
+package com.huimv.video.domain;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@Table(name = "sj_hk_wd")
+public class SjHkWd implements Serializable {
+
+	@Id
+	@GeneratedValue(strategy = GenerationType.IDENTITY)
+	@Column(name = "ID")
+	private Integer id;
+
+	@Column(name = "LQID")
+	private Integer lqid;
+
+	@Column(name = "CGQID")
+	private String cgqid;
+
+	@Column(name = "DQWD")
+	private Double dqwd;
+
+	@Column(name = "CJSJ")
+	private java.util.Date cjsj;
+
+	@Column(name = "SCSJ")
+	private java.util.Date scsj;
+
+}

shiwan/video/src/main/java/com/huimv/video/repo/DaLqdaEntityRepository.java

@@ -0,0 +1,14 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.DaLqdaEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface DaLqdaEntityRepository extends JpaRepository<DaLqdaEntity, Integer>, JpaSpecificationExecutor<DaLqdaEntity> {
+
+    @Query(nativeQuery = true , value = "SELECT * FROM da_lqda WHERE id IN(SELECT MAX(id) FROM da_lqda WHERE zsid IN(?1) GROUP BY zsid)")
+    List<DaLqdaEntity> getLqid(List<Integer> zsids);
+}

shiwan/video/src/main/java/com/huimv/video/repo/DaZsdaEntityRepository.java

@@ -0,0 +1,14 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.DaZsdaEntity;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface DaZsdaEntityRepository extends JpaRepository<DaZsdaEntity, Integer>, JpaSpecificationExecutor<DaZsdaEntity> {
+
+    @Query(nativeQuery = true , value = "SELECT * FROM da_zsda WHERE mcid=?1 AND ZFBZ=0")
+    List<DaZsdaEntity> getAllZs(int mcid);
+}

shiwan/video/src/main/java/com/huimv/video/repo/MobileUserRepository.java

@@ -0,0 +1,16 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.MobileUser;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface MobileUserRepository extends JpaRepository<MobileUser, Integer>, JpaSpecificationExecutor<MobileUser> {
+	
+	@Query(nativeQuery = true ,value = "select * from mobile_user where account like %?1% limit ?2 , ?3")
+    List<MobileUser> findAll(String name, Integer startPage, Integer pageSize);
+
+    MobileUser findByAccountAndPassword(String account, String password);
+}

shiwan/video/src/main/java/com/huimv/video/repo/SjHkAqRepository.java

@@ -0,0 +1,20 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.SjHkAq;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface SjHkAqRepository extends JpaRepository<SjHkAq, Integer>, JpaSpecificationExecutor<SjHkAq> {
+	
+	@Query(nativeQuery = true ,value = "select * from sj_hk_aq where lqid like %?1% limit ?2 , ?3")
+    List<SjHkAq> findAll(String name, Integer startPage, Integer pageSize);
+
+//    @Query(nativeQuery = true ,value = "select * from sj_hk_aq where lqid like %?1% limit ?2 , ?3")
+
+    @Query(nativeQuery = true ,value = "select * from sj_hk_aq where lqid = ?1 order by id DESC limit 0 , 1")
+    List<SjHkAq> findByLqidOrderById(Integer LQID);
+
+}

shiwan/video/src/main/java/com/huimv/video/repo/SjHkDlRepository.java

@@ -0,0 +1,17 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.domain.SjHkDl;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface SjHkDlRepository extends JpaRepository<SjHkDl, Integer>, JpaSpecificationExecutor<SjHkDl> {
+	
+	@Query(nativeQuery = true ,value = "select * from sj_hk_dl where lqid like %?1% limit ?2 , ?3")
+    List<SjHkDl> findAll(String name, Integer startPage, Integer pageSize);
+
+    List<SjHkDl> findByLqidOrderById(Integer LQID);
+}

shiwan/video/src/main/java/com/huimv/video/repo/SjHkPhRepository.java

@@ -0,0 +1,17 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.domain.SjHkPh;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface SjHkPhRepository extends JpaRepository<SjHkPh, Integer>, JpaSpecificationExecutor<SjHkPh> {
+	
+	@Query(nativeQuery = true ,value = "select * from sj_hk_ph where lqid like %?1% limit ?2 , ?3")
+    List<SjHkPh> findAll(String name, Integer startPage, Integer pageSize);
+
+    List<SjHkPh> findByLqidOrderById(Integer LQID);
+}

shiwan/video/src/main/java/com/huimv/video/repo/SjHkSdRepository.java

@@ -0,0 +1,18 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.domain.SjHkSd;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface SjHkSdRepository extends JpaRepository<SjHkSd, Integer>, JpaSpecificationExecutor<SjHkSd> {
+	
+	@Query(nativeQuery = true ,value = "select * from sj_hk_sd where lqid like %?1% limit ?2 , ?3")
+    List<SjHkSd> findAll(String name, Integer startPage, Integer pageSize);
+
+    @Query(nativeQuery = true ,value = "select * from sj_hk_sd where lqid = ?1 order by id DESC limit 0 , 1")
+    List<SjHkSd> findByLqidOrderById(Integer LQID);
+}

shiwan/video/src/main/java/com/huimv/video/repo/SjHkSlRepository.java

@@ -0,0 +1,17 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.domain.SjHkSl;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface SjHkSlRepository extends JpaRepository<SjHkSl, Integer>, JpaSpecificationExecutor<SjHkSl> {
+	
+	@Query(nativeQuery = true ,value = "select * from sj_hk_sl where lqid like %?1% limit ?2 , ?3")
+    List<SjHkSl> findAll(String name, Integer startPage, Integer pageSize);
+
+    List<SjHkSl> findByLqidOrderById(Integer LQID);
+}

shiwan/video/src/main/java/com/huimv/video/repo/SjHkWdRepository.java

@@ -0,0 +1,18 @@
+package com.huimv.video.repo;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.domain.SjHkWd;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
+
+import java.util.List;
+
+public interface SjHkWdRepository extends JpaRepository<SjHkWd, Integer>, JpaSpecificationExecutor<SjHkWd> {
+	
+	@Query(nativeQuery = true ,value = "select * from sj_hk_wd where lqid like %?1% limit ?2 , ?3")
+    List<SjHkWd> findAll(String name, Integer startPage, Integer pageSize);
+
+    @Query(nativeQuery = true ,value = "select * from sj_hk_wd where lqid = ?1 order by id DESC limit 0 , 1")
+    List<SjHkWd> findByLqidOrderById(Integer LQID);
+}

shiwan/video/src/main/java/com/huimv/video/result/ResultStatus.java

@@ -0,0 +1,15 @@
+package com.huimv.video.result;
+
+public  class ResultStatus {
+	public  final static String addNull = "没有输入参数";
+	public  final static String addSuccess = "添加成功";
+	public  final static String addFailed = "添加失败";
+	public  final static String deleteNull = "没有要删除的数据";
+	public  final static String deleteSuccess = "删除成功";
+	public  final static String deleteFailed = "删除失败";
+	public  final static String updateNull = "没有要修改的数据";
+	public  final static String updateSuccess = "修改成功";
+	public  final static String updateFailed = "修改失败";
+	public  final static String findSuccess = "查询成功";
+	public  final static String findFailed = "查询失败";
+}

shiwan/video/src/main/java/com/huimv/video/service/AllDataService.java

@@ -0,0 +1,16 @@
+package com.huimv.video.service;
+
+import com.huimv.video.result.Result;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.video.service
+ * @Description : TODO
+ * @Author : yuxuexuan
+ * @Create : 2021/3/31 0031 14:06
+ **/
+public interface AllDataService {
+
+
+    Result getZsda();
+}

shiwan/video/src/main/java/com/huimv/video/service/MobileUserService.java

@@ -0,0 +1,25 @@
+package com.huimv.video.service;
+
+
+import com.huimv.video.domain.MobileUser;
+import com.huimv.video.result.Result;
+
+public interface MobileUserService {
+
+   //添加
+   Result add(MobileUser entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(MobileUser entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+
+    Result login(String account, String password);
+}

shiwan/video/src/main/java/com/huimv/video/service/SjHkAqService.java

@@ -0,0 +1,22 @@
+package com.huimv.video.service;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.result.Result;
+
+public interface SjHkAqService  {
+
+   //添加
+   Result add(SjHkAq entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(SjHkAq entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/video/src/main/java/com/huimv/video/service/SjHkDlService.java

@@ -0,0 +1,22 @@
+package com.huimv.video.service;
+
+import com.huimv.video.domain.SjHkDl;
+import com.huimv.video.result.Result;
+
+public interface SjHkDlService  {
+
+   //添加
+   Result add(SjHkDl entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(SjHkDl entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/video/src/main/java/com/huimv/video/service/SjHkPhService.java

@@ -0,0 +1,22 @@
+package com.huimv.video.service;
+
+import com.huimv.video.domain.SjHkPh;
+import com.huimv.video.result.Result;
+
+public interface SjHkPhService  {
+
+   //添加
+   Result add(SjHkPh entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(SjHkPh entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/video/src/main/java/com/huimv/video/service/SjHkSdService.java

@@ -0,0 +1,22 @@
+package com.huimv.video.service;
+
+import com.huimv.video.domain.SjHkSd;
+import com.huimv.video.result.Result;
+
+public interface SjHkSdService  {
+
+   //添加
+   Result add(SjHkSd entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(SjHkSd entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/video/src/main/java/com/huimv/video/service/SjHkSlService.java

@@ -0,0 +1,22 @@
+package com.huimv.video.service;
+
+import com.huimv.video.domain.SjHkSl;
+import com.huimv.video.result.Result;
+
+public interface SjHkSlService  {
+
+   //添加
+   Result add(SjHkSl entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(SjHkSl entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/video/src/main/java/com/huimv/video/service/SjHkWdService.java

@@ -0,0 +1,22 @@
+package com.huimv.video.service;
+
+import com.huimv.video.domain.SjHkWd;
+import com.huimv.video.result.Result;
+
+public interface SjHkWdService  {
+
+   //添加
+   Result add(SjHkWd entity);
+
+   //添加
+   Result remove(Integer[] ids);
+
+   //添加
+   Result update(SjHkWd entity);
+
+   //查询
+  Result findAll(String name, Integer pageNum, Integer pageSize);
+
+   //根据id查找
+   Result findAllById(Integer id);
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/AllDataServiceImpl.java

@@ -0,0 +1,108 @@
+package com.huimv.video.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.huimv.video.domain.*;
+import com.huimv.video.repo.*;
+import com.huimv.video.result.Result;
+import com.huimv.video.service.AllDataService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Project : huimv.shiwan
+ * @Package : com.huimv.video.service.impl
+ * @Description : TODO
+ * @Author : yuxuexuan
+ * @Create : 2021/3/31 0031 14:07
+ **/
+@Service
+public class AllDataServiceImpl implements AllDataService {
+    @Autowired
+    private DaZsdaEntityRepository zsdaEntityRepo;
+    @Autowired
+    private DaLqdaEntityRepository lqdaEntityRepo;
+
+    @Autowired
+    private SjHkAqRepository aqRepository;
+    @Autowired
+    private SjHkSdRepository sdRepository;
+    @Autowired
+    private SjHkWdRepository wdRepository;
+    @Autowired
+    private SjHkSlRepository slRepository;
+    @Autowired
+    private SjHkDlRepository dlRepository;
+    @Autowired
+    private SjHkPhRepository phRepository;
+
+
+    @Override
+    @DS("slave")
+    public Result getZsda() {
+        Integer mcid = 39;
+        //--读取所有猪舍
+        List<DaZsdaEntity> zsdsList = zsdaEntityRepo.getAllZs(mcid);
+
+        List zsidList = new ArrayList();
+        for (DaZsdaEntity zsdaEntity : zsdsList) {
+            zsidList.add(zsdaEntity.getID());
+        }
+        //--读取所有栏期
+        List<DaLqdaEntity> lqdaEntityList = lqdaEntityRepo.getLqid(zsidList);
+
+
+        List<Map> zsxx = new ArrayList();
+        Map map = new HashMap();
+        for (DaZsdaEntity zsdaEntity : zsdsList) {
+            int zsid = zsdaEntity.getID();
+
+
+            map.put("zsid", zsid);
+            map.put("zsmc", zsdaEntity.getZSMC());
+            List<Integer>  lqidList  = new ArrayList();
+            for (DaLqdaEntity lqdaEntity : lqdaEntityList) {
+                if (lqdaEntity.getZSID() == zsid) {
+                    Integer lqid = lqdaEntity.getID();
+                    map.put("lqid", lqid);
+                    lqidList.add(lqid);
+                    break;
+                }
+            }
+
+
+            for (Integer lqid : lqidList) {
+                List<SjHkAq> byLqidOrderById = aqRepository.findByLqidOrderById(lqid);
+                if ( byLqidOrderById.size()> 0){
+                    map.put("aq",byLqidOrderById.get(0).getDqaq()) ;
+                }else{
+                    map.put("aq",null) ;
+                }
+
+                List<SjHkWd> byLqidOrderById1 = wdRepository.findByLqidOrderById(lqid);
+                if ( byLqidOrderById1.size()> 0){
+                    map.put("wd",byLqidOrderById1.get(0).getDqwd()) ;
+                }else{
+                    map.put("wd",null) ;
+                }
+
+                List<SjHkSd> byLqidOrderById2 = sdRepository.findByLqidOrderById(lqid);
+                if ( byLqidOrderById2.size()> 0){
+                    map.put("sd",byLqidOrderById2.get(0).getDqsd()) ;
+                }else{
+                    map.put("sd",null) ;
+                }
+            }
+
+
+            zsxx.add(map);
+        }
+
+
+        return new Result(10000,"成功",zsxx);
+    }
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/CameraInfoServiceImpl.java

@@ -1,5 +1,6 @@
 package com.huimv.video.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.huimv.video.domain.CameraInfo;
 import com.huimv.video.domain.PastureArea;
 import com.huimv.video.repo.CameraInfoRepo;
@@ -33,16 +34,19 @@ public class CameraInfoServiceImpl implements CameraInfoService {
     private PastureAreaRepo pastureAreaRepo;
 
     @Override
+    @DS("master")
     public void save(CameraInfo cameraInfo) {
         cameraInfoRepo.save(cameraInfo);
     }
 
     @Override
+    @DS("master")
     public void update(CameraInfo cameraInfo) {
         cameraInfoRepo.save(cameraInfo);
     }
 
     @Override
+    @DS("master")
     public void delete(List<Integer> ids) {
         for (Integer id : ids) {
             cameraInfoRepo.deleteById(id);
@@ -50,6 +54,7 @@ public class CameraInfoServiceImpl implements CameraInfoService {
     }
 
     @Override
+    @DS("master")
     public List findAll() {
         List list = new ArrayList();
         List<CameraInfo> all = cameraInfoRepo.findAll();
@@ -68,6 +73,7 @@ public class CameraInfoServiceImpl implements CameraInfoService {
                 map.put("areaId",cameraInfo.getAreaId());
                 map.put("remark",cameraInfo.getRemark());
                 map.put("areaParentId",pastureArea.getParent());
+                map.put("LQID",cameraInfo.getLQID());
                 list.add(map);
             }else {
                 return list;
@@ -80,12 +86,14 @@ public class CameraInfoServiceImpl implements CameraInfoService {
     }
 
     @Override
+    @DS("master")
     public List<CameraInfo> searchAll(String name) {
 
         return cameraInfoRepo.findByNameLike(name);
     }
 
     @Override
+    @DS("master")
     public List getCameraDetails(List<Integer> areaIds) {
         List cameraDetailsList = new ArrayList();
         for (Integer areaId : areaIds) {

shiwan/video/src/main/java/com/huimv/video/service/impl/MobileUserServiceImpl.java

@@ -0,0 +1,106 @@
+package com.huimv.video.service.impl;
+
+import com.baomidou.dynamic.datasource.annotation.DS;
+import com.huimv.video.domain.MobileUser;
+import com.huimv.video.repo.MobileUserRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.MobileUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.DigestUtils;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class MobileUserServiceImpl implements MobileUserService {
+
+	@Autowired
+	private MobileUserRepository rep;
+
+	@Override
+	@DS("master")
+	public Result add(MobileUser entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000,ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	@DS("master")
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002,ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000,ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	@DS("master")
+	public Result update(MobileUser entity) {
+		if (entity == null){
+			return new Result(10002,ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000,ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	@DS("master")
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<MobileUser> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000,ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	@DS("master")
+	public Result findAllById(Integer id) {
+		try {
+			MobileUser entity = rep.findById(id).get();
+			return new Result(10000,ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001,ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	@DS("master")
+	public Result login(String account, String password) {
+		MobileUser byUserNameAndPassword = rep.findByAccountAndPassword(account, password);
+		if (byUserNameAndPassword == null){
+			return new Result(10001,"登录失败",null);
+		}
+		return new Result(10000,"登录成功",byUserNameAndPassword);
+	}
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/PastureAreaServiceImpl.java

@@ -1,5 +1,6 @@
 package com.huimv.video.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.huimv.video.domain.PastureArea;
 import com.huimv.video.repo.PastureAreaRepo;
 import com.huimv.video.service.PastureAreaService;
@@ -34,6 +35,7 @@ public class PastureAreaServiceImpl implements PastureAreaService {
     }
 
     @Override
+    @DS("master")
     public void delete(List<Integer> ids) {
         for (Integer id : ids) {
             List<PastureArea> list = pastureAreaRepo.findAllByParent(id);
@@ -47,6 +49,7 @@ public class PastureAreaServiceImpl implements PastureAreaService {
     }
 
     @Override
+    @DS("master")
     public List findAll() {
         List list  = new ArrayList();
         Sort sort = Sort.by(Sort.Direction.ASC, "sort");

shiwan/video/src/main/java/com/huimv/video/service/impl/PublicNetworkServiceImpl.java

@@ -1,5 +1,6 @@
 package com.huimv.video.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.huimv.video.domain.PublicNetwork;
 import com.huimv.video.repo.PublicNetworkRepo;
 import com.huimv.video.service.PublicNetworkService;
@@ -18,11 +19,13 @@ public class PublicNetworkServiceImpl implements PublicNetworkService {
     @Autowired
     private PublicNetworkRepo publicNetworkRepo;
     @Override
+    @DS("master")
     public void save(PublicNetwork publicNetwork) {
         publicNetworkRepo.save(publicNetwork);
     }
 
     @Override
+    @DS("master")
     public PublicNetwork getNetwork() {
         return publicNetworkRepo.findTopByIdDesc();
     }

shiwan/video/src/main/java/com/huimv/video/service/impl/SjHkAqServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.video.service.impl;
+
+import com.huimv.video.domain.SjHkAq;
+import com.huimv.video.repo.SjHkAqRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.SjHkAqService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class SjHkAqServiceImpl implements SjHkAqService {
+
+	@Autowired
+	private SjHkAqRepository rep;
+
+	@Override
+	public Result add(SjHkAq entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002, ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000, ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(SjHkAq entity) {
+		if (entity == null){
+			return new Result(10002, ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<SjHkAq> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000, ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			SjHkAq entity = rep.findById(id).get();
+			return new Result(10000, ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/SjHkDlServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.video.service.impl;
+
+import com.huimv.video.domain.SjHkDl;
+import com.huimv.video.repo.SjHkDlRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.SjHkDlService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class SjHkDlServiceImpl implements SjHkDlService {
+
+	@Autowired
+	private SjHkDlRepository rep;
+
+	@Override
+	public Result add(SjHkDl entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002, ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000, ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(SjHkDl entity) {
+		if (entity == null){
+			return new Result(10002, ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<SjHkDl> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000, ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			SjHkDl entity = rep.findById(id).get();
+			return new Result(10000, ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/SjHkPhServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.video.service.impl;
+
+import com.huimv.video.domain.SjHkPh;
+import com.huimv.video.repo.SjHkPhRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.SjHkPhService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class SjHkPhServiceImpl implements SjHkPhService {
+
+	@Autowired
+	private SjHkPhRepository rep;
+
+	@Override
+	public Result add(SjHkPh entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002, ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000, ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(SjHkPh entity) {
+		if (entity == null){
+			return new Result(10002, ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<SjHkPh> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000, ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			SjHkPh entity = rep.findById(id).get();
+			return new Result(10000, ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/SjHkSdServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.video.service.impl;
+
+import com.huimv.video.domain.SjHkSd;
+import com.huimv.video.repo.SjHkSdRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.SjHkSdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class SjHkSdServiceImpl implements SjHkSdService {
+
+	@Autowired
+	private SjHkSdRepository rep;
+
+	@Override
+	public Result add(SjHkSd entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002, ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000, ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(SjHkSd entity) {
+		if (entity == null){
+			return new Result(10002, ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<SjHkSd> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000, ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			SjHkSd entity = rep.findById(id).get();
+			return new Result(10000, ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/SjHkSlServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.video.service.impl;
+
+import com.huimv.video.domain.SjHkSl;
+import com.huimv.video.repo.SjHkSlRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.SjHkSlService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class SjHkSlServiceImpl implements SjHkSlService {
+
+	@Autowired
+	private SjHkSlRepository rep;
+
+	@Override
+	public Result add(SjHkSl entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002, ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000, ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(SjHkSl entity) {
+		if (entity == null){
+			return new Result(10002, ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<SjHkSl> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000, ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			SjHkSl entity = rep.findById(id).get();
+			return new Result(10000, ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+}

shiwan/video/src/main/java/com/huimv/video/service/impl/SjHkWdServiceImpl.java

@@ -0,0 +1,88 @@
+package com.huimv.video.service.impl;
+
+import com.huimv.video.domain.SjHkWd;
+import com.huimv.video.repo.SjHkWdRepository;
+import com.huimv.video.result.Result;
+import com.huimv.video.result.ResultStatus;
+import com.huimv.video.service.SjHkWdService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@Service
+public class SjHkWdServiceImpl implements SjHkWdService {
+
+	@Autowired
+	private SjHkWdRepository rep;
+
+	@Override
+	public Result add(SjHkWd entity){
+		if (entity == null){
+			return new Result(10002, ResultStatus.addNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.addSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.addFailed);
+		}
+	}
+
+	@Override
+	public Result remove(Integer[] ids) {
+		if (ids == null || ids.length==0){
+			return new Result(10002, ResultStatus.deleteNull);
+		}
+		try {
+			for (Integer id : ids) {
+				rep.deleteById(id);
+			}
+			return new Result(10000, ResultStatus.deleteSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.deleteFailed);
+		}
+	}
+
+	@Override
+	public Result update(SjHkWd entity) {
+		if (entity == null){
+			return new Result(10002, ResultStatus.updateNull);
+		}
+		try {
+			rep.save(entity);
+			return new Result(10000, ResultStatus.updateSuccess);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.updateFailed);
+		}
+	}
+
+	@Override
+	public Result findAll(String name , Integer pageNum , Integer pageSize) {
+		try {
+			Map map = new HashMap();
+			int size = rep.findAll().size() ;
+			Integer startPage = (pageNum-1) * pageSize;
+			List<SjHkWd> all = rep.findAll(name,startPage,pageSize);
+			map.put("total",size);
+			map.put("totalPageNum",(size  +  pageSize  - 1) / pageSize);
+			map.put("data",all);
+			
+			return new Result(10000, ResultStatus.findSuccess,map);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+
+	@Override
+	public Result findAllById(Integer id) {
+		try {
+			SjHkWd entity = rep.findById(id).get();
+			return new Result(10000, ResultStatus.findSuccess,entity);
+		}catch (Exception e){
+			return new Result(10001, ResultStatus.findFailed,null);
+		}
+	}
+}

shiwan/video/src/main/resources/application-test.yml

@@ -2,20 +2,44 @@ server:
   port: 8088
 spring:
   #------DataSource-----
+#  datasource:
+#    #url: jdbc:mysql://127.0.0.1:3306/huimv-admin?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    url: jdbc:mysql://122.112.250.26:3306/huimv-video_db?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+#    username: root
+#    password: hm123456
+#    driver-class-name: com.mysql.cj.jdbc.Driver
+#    max-active: 20
+#    max-idle: 8
+#    min-idle: 8
+#    initial-size: 10
   datasource:
-    #url: jdbc:mysql://127.0.0.1:3306/huimv-admin?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
-    url: jdbc:mysql://122.112.250.26:3306/huimv-video_db?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
-    username: root
-    password: hm123456
-    driver-class-name: com.mysql.cj.jdbc.Driver
-    max-active: 20
-    max-idle: 8
-    min-idle: 8
-    initial-size: 10
+    dynamic:
+      datasource:
+        master:
+          url: jdbc:mysql://122.112.250.26:3306/huimv-video_db?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+          username: root
+          password: hm123456
+          driver-class-name: com.mysql.cj.jdbc.Driver
+          max-active: 5
+          max-idle: 5
+          min-idle: 3
+          initial-size: 3
+        slave:
+          url: jdbc:mysql://122.112.219.87:3306/ifm?useUnicode=true&characterEncoding=UTF-8&useSSL=false&autoReconnect=true&serverTimezone=Asia/Shanghai
+          username: huimv
+          password: hm123456
+          driver-class-name: com.mysql.cj.jdbc.Driver
+          max-active: 5
+          max-idle: 5
+          min-idle: 3
+          initial-size: 3
   jpa:
-    database: mysql
     show-sql: true
-
+    database: mysql
+    hibernate:
+      ddl-auto: update
+    database-platform: org.hibernate.dialect.MySQL5InnoDBDialect
+    open-in-view: true
 
   mvc:
     view:

shiwan/video/src/main/resources/file.properties

@@ -0,0 +1,5 @@
+#Update 'creationTime' value
+#Sat Jan 09 14:26:41 CST 2021
+creationTime=Sat Jan 09 14\:26\:41 CST 2021
+id=76
+url=0\:0\:0\:0\:0\:0\:0\:1