342 lines
12 KiB
PHP
342 lines
12 KiB
PHP
<?php
|
|
|
|
namespace app\api\controller;
|
|
|
|
use think\facade\Db;
|
|
use think\response\Json;
|
|
|
|
class PoultryBreedController extends BaseApiController
|
|
{
|
|
public array $notNeedLogin = [
|
|
'addPoultry','poultryInfo','poultryList','poultrySell','poultryStatus','poultryChangeList','poultrySearchByCode',
|
|
'addPoultryPic','poultryPicList',
|
|
'addPoultryRecord','delPoultryRecord','ediPoultryRecord','poultryRecordInfo','poultryRecordList',
|
|
'poultryEnvData'
|
|
];
|
|
|
|
//获取状态文本
|
|
private function getStatusText($status): string
|
|
{
|
|
//状态 1-健康 2-产蛋期 3-生病隔离 4-可出栏 5-已出栏
|
|
$str = '';
|
|
switch ($status) {
|
|
case 1:
|
|
$str = '健康';
|
|
break;
|
|
case 2:
|
|
$str = '产蛋期';
|
|
break;
|
|
case 3:
|
|
$str = '生病隔离中';
|
|
break;
|
|
case 4:
|
|
$str = '可出栏';
|
|
break;
|
|
case 5:
|
|
$str = '已出栏';
|
|
break;
|
|
}
|
|
return $str;
|
|
}
|
|
|
|
//添加饲养家禽
|
|
public function addPoultry(): Json
|
|
{
|
|
$params = $this->request->post(['user_id','code','kind','breed','gender','age','status','weight','pic']);
|
|
if(empty($params['user_id']) || empty($params['code']) || empty($params['kind']) || empty($params['breed']) || empty($params['gender']) || !in_array($params['gender'],[1,2]) || empty($params['age']) || empty($params['status']) || !in_array($params['status'],[1,2,3,4]) || empty($params['weight'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
//写入数据
|
|
Db::transaction(function () use($params) {
|
|
$animalId = Db::name('farmer_poultry_breed')->insertGetId([
|
|
'user_id' => $params['user_id'],
|
|
'code' => $params['code'],
|
|
'kind' => $params['kind'],
|
|
'breed' => $params['breed'],
|
|
'gender' => $params['gender'],
|
|
'age' => $params['age'],
|
|
'status' => $params['status'],
|
|
'weight' => $params['weight'],
|
|
'create_time' => time()
|
|
]);
|
|
if(!empty($params['pic'])){
|
|
Db::name('farmer_poultry_pic')->insert([
|
|
'poultry_id' => $animalId,
|
|
'pic' => $params['pic'],
|
|
'create_time' => time()
|
|
]);
|
|
}
|
|
});
|
|
//返回信息
|
|
return $this->success('添加成功',[],1,1);
|
|
}
|
|
|
|
//获取饲养家禽详情
|
|
public function poultryInfo(): Json
|
|
{
|
|
$params = $this->request->get(['poultry_id']);
|
|
if(empty($params['poultry_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$data = Db::name('farmer_poultry_breed')->where('id',$params['poultry_id'])->findOrEmpty();
|
|
if(empty($data)){
|
|
return $this->fail('数据不存在');
|
|
}
|
|
$data['pic_detail'] = Db::name('farmer_poultry_pic')->field('pic,create_time')->where('poultry_id',$params['poultry_id'])->order('id desc')->findOrEmpty();
|
|
$data['create_time'] = date('Y-m-d H:i:s',$data['create_time']);
|
|
if(!empty($data['pic_detail'])){
|
|
$data['pic_detail']['create_time'] = date('Y-m-d H:i:s',$data['pic_detail']['create_time']);
|
|
}
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//饲养家禽列表
|
|
public function poultryList(): Json
|
|
{
|
|
$params = $this->request->get(['user_id','page_no','page_size','keyword']);
|
|
if(empty($params['user_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
//设置分页参数
|
|
$pageNo = empty($params['page_no']) || $params['page_no'] < 0 ? 1 : $params['page_no'];
|
|
$pageSize = empty($params['page_size']) || $params['page_size'] < 0 ? 10 : $params['page_size'];
|
|
//设置搜素条件
|
|
$query = 'user_id = '.$params['user_id'].' and status != 5';
|
|
if(!empty($params['keyword'])){
|
|
$query .= ' and (code LIKE "%'.$params['keyword'].'%" or kind LIKE "%'.$params['keyword'].'%" or breed LIKE "%'.$params['keyword'].'%")';
|
|
}
|
|
//获取数据
|
|
$data = Db::name('farmer_poultry_breed')->whereRaw($query)->page($pageNo,$pageSize)->order('id desc')->select()->toArray();
|
|
//返回数据
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//通过编码查询动物
|
|
public function poultrySearchByCode(): Json
|
|
{
|
|
$params = $this->request->get(['code']);
|
|
if(empty($params['code'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$data = Db::name('farmer_poultry_breed')->where('code',$params['code'])->findOrEmpty();
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//更新饲养家禽状态
|
|
public function poultrySell(): Json
|
|
{
|
|
$params = $this->request->post(['poultry_id']);
|
|
if(empty($params['poultry_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$result = Db::name('farmer_poultry_breed')->where('id',$params['poultry_id'])->update(['status'=>5]);
|
|
return $result ? $this->success('更新成功',[],1,1) : $this->fail('更新失败',[],1,1);
|
|
}
|
|
|
|
//更新动物状态
|
|
public function poultryStatus(): Json
|
|
{
|
|
$params = $this->request->post(['poultry_id','status','weight']);
|
|
if(empty($params['poultry_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
if(empty($params['status']) && empty($params['weight'])){
|
|
return $this->fail('没有可更改的项');
|
|
}
|
|
//获取元数据
|
|
$data = Db::name('farmer_poultry_breed')->where('id',$params['poultry_id'])->findOrEmpty();
|
|
if(empty($data)){
|
|
return $this->fail('数据错误');
|
|
}
|
|
if(isset($params['status']) && !empty($params['status'])){
|
|
if(!in_array($params['status'],[1,2,3,4])){
|
|
return $this->fail('状态之错误');
|
|
}
|
|
}
|
|
$updateData = [];
|
|
$textData = [];
|
|
if(!empty($params['status'])){
|
|
$updateData['status'] = $params['status'];
|
|
$textData['状态变更']['原状态'] = $this->getStatusText($data['status']);
|
|
$textData['状态变更']['新状态'] = $this->getStatusText($params['status']);
|
|
}
|
|
if(!empty($params['weight'])){
|
|
$updateData['weight'] = $params['weight'];
|
|
$textData['体重变更']['原体重'] = $data['weight'];
|
|
$textData['体重变更']['新体重'] = $params['weight'];
|
|
}
|
|
//设置数据
|
|
$saveData = [
|
|
'poultry_id' => $params['poultry_id'],
|
|
'action_name' => '生长状态变更',
|
|
'action_content' => json_encode($textData),
|
|
'create_time' => time()
|
|
];
|
|
Db::transaction(function () use($params,$saveData,$updateData) {
|
|
Db::name('farmer_poultry_status')->insert($saveData);
|
|
if(!empty($updateData)) {
|
|
Db::name('farmer_poultry_breed')->where('id', $params['animal_id'])->update($updateData);
|
|
}
|
|
});
|
|
return $this->success('更新成功',[],1,1);
|
|
}
|
|
|
|
//获取状态列表
|
|
public function poultryChangeList(): Json
|
|
{
|
|
$params = $this->request->get(['poultry_id','page_no','page_size']);
|
|
if(empty($params['poultry_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
//设置分页条件
|
|
$pageNo = empty($params['page_no']) || $params['page_no'] < 0 ? 1 : $params['page_no'];
|
|
$pageSize = empty($params['page_size']) || $params['page_size'] < 0 ? 10 : $params['page_size'];
|
|
//获取数据
|
|
$data = Db::name('farmer_poultry_status')->where('poultry_id',$params['poultry_id'])->page($pageNo,$pageSize)->order('create_time desc')->select()->each(function($item){
|
|
$item['create_time'] = date('Y-m-d H:i:s',$item['create_time']);
|
|
return $item;
|
|
})->toArray();
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//上传家禽养殖情况图片
|
|
public function addPoultryPic(): Json
|
|
{
|
|
$params = $this->request->post(['poultry_id','pic']);
|
|
if(empty($params['poultry_id']) || empty($params['pic'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
//写入数据
|
|
$params['create_time'] = time();
|
|
$result = Db::name('farmer_poultry_pic')->insert($params);
|
|
//返回
|
|
return $result ? $this->success('添加成功',[],1,1) : $this->fail('添加失败',[],1,1);
|
|
}
|
|
|
|
//家禽养殖情况图片列表
|
|
public function poultryPicList(): Json
|
|
{
|
|
//获取参数
|
|
$params = $this->request->get(['poultry_id']);
|
|
if(empty($params['poultry_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$data = Db::name('farmer_poultry_pic')->where('poultry_id',$params['poultry_id'])->order('id desc')->select()->each(function($item){
|
|
$item['create_time'] = date('Y-m-d H:i:s',$item['create_time']);
|
|
return $item;
|
|
})->toArray();
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//添加饲养家禽操作记录
|
|
public function addPoultryRecord(): Json
|
|
{
|
|
$params = $this->request->post(['user_id','action_id','action_content','action_extends']);
|
|
if(empty($params['user_id']) || empty($params['action_id']) || empty($params['action_content'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
if(empty(json_decode($params['action_content']))) {
|
|
return $this->fail('参数错误');
|
|
}
|
|
Db::transaction(function () use($params) {
|
|
//写入数据
|
|
$params['create_time'] = time();
|
|
Db::name('farmer_poultry_record')->insert($params);
|
|
if(!empty($params['action_extends'])){
|
|
$extends = json_decode($params['action_extends'],true);
|
|
if($extends && !empty($extends['poultry_id'])){
|
|
foreach($extends['poultry_id'] as $v){
|
|
Db::name('farmer_poultry_status')->insert([
|
|
'poultry_id' => $v,
|
|
'action_name' => '疫苗注射记录',
|
|
'action_content' => $params['action_content'],
|
|
'create_time' => time()
|
|
]);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
//返回
|
|
return $this->success('添加成功',[],1,1);
|
|
}
|
|
|
|
//删除饲养家禽操作记录
|
|
public function delPoultryRecord(): Json
|
|
{
|
|
$params = $this->request->post(['record_id']);
|
|
if(empty($params['record_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$result = Db::name('farmer_poultry_record')->where('id',$params['record_id'])->delete();
|
|
return $result ? $this->success('删除成功',[],1,1) : $this->fail('删除失败',[],1,1);
|
|
}
|
|
|
|
//编辑饲养家禽操作记录
|
|
public function ediPoultryRecord(): Json
|
|
{
|
|
$params = $this->request->post(['record_id','action_content']);
|
|
if(empty($params['record_id']) || empty($params['action_content'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
if(empty(json_decode($params['action_content']))) {
|
|
return $this->fail('参数错误');
|
|
}
|
|
//修改数据
|
|
$result = Db::name('farmer_poultry_record')->where('id',$params['record_id'])->update(['action_content'=>$params['action_content']]);
|
|
//返回
|
|
return $result ? $this->success('修改成功',[],1,1) : $this->fail('修改失败',[],1,1);
|
|
}
|
|
|
|
//获取饲养家禽操作记录详情
|
|
public function poultryRecordInfo(): Json
|
|
{
|
|
$params = $this->request->get(['record_id']);
|
|
if(empty($params['record_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$data = Db::name('farmer_poultry_record')->where('id',$params['record_id'])->findOrEmpty();
|
|
if(empty($data)){
|
|
return $this->fail('数据不存在');
|
|
}
|
|
$data['action_content'] = json_decode($data['action_content'],true);
|
|
$data['action_detail'] = Db::name('farmer_action_detail')->where('action_id','in',$data['action_id'])->select()->toArray();
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//获取饲养家禽操作记录列表
|
|
public function poultryRecordList(): Json
|
|
{
|
|
$params = $this->request->get(['user_id','action_type_id','page_no','page_size']);
|
|
if(empty($params['user_id']) || empty($params['action_type_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
//设置分页条件
|
|
$pageNo = empty($params['page_no']) || $params['page_no'] < 0 ? 1 : $params['page_no'];
|
|
$pageSize = empty($params['page_size']) || $params['page_size'] < 0 ? 10 : $params['page_size'];
|
|
//获取操作分类下的操作id
|
|
$actions = Db::name('farmer_action')->where('type_id',$params['action_type_id'])->select()->toArray();
|
|
$actionIds = array_column($actions,'id');
|
|
//获取数据
|
|
$data = Db::name('farmer_poultry_record')->where('user_id',$params['user_id'])->where('action_id','in',$actionIds)->page($pageNo,$pageSize)->order('create_time desc')->select()->each(function($item){
|
|
$item['action_name'] = Db::name('farmer_action')->where('id',$item['action_id'])->findOrEmpty()['name'];
|
|
$item['action_content'] = json_decode($item['action_content'],true);
|
|
$item['create_time'] = date('Y-m-d H:i:s',$item['create_time']);
|
|
return $item;
|
|
})->toArray();
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
|
|
//获取农户家禽饲养环境监测数据
|
|
public function poultryEnvData(): Json
|
|
{
|
|
$params = $this->request->get(['user_id']);
|
|
if(empty($params['user_id'])){
|
|
return $this->fail('参数错误');
|
|
}
|
|
$data = Db::name('farmer_poultry_env_data')->where('user_id',$params['user_id'])->whereDay('create_time', date('Y-m-d',time()))->findOrEmpty();
|
|
if(!empty($data)){
|
|
$data['create_time'] = date('Y-m-d H:i:s',$data['create_time']);
|
|
}
|
|
return $this->success('请求成功',$data);
|
|
}
|
|
} |