<?php
namespace app\index\controller;
use think\Hook;
use app\index\controller\Acl;
use app\index\model\Opurchaseclass;
use app\index\model\Opurchaseinfo;
use app\index\model\Rpurchaseclass;
class Opurchase extends Acl {
public function main(){
return $this->fetch();
}
public function set(){
$input=input('post.');
if(isset($input['id'])){
if(isset_full($input,'tab')){
foreach ($input['tab'] as $tab_key=>$tab_vo) {
$tab_vali = $this->validate($tab_vo,'Opurchaseinfo') if($tab_vali!==true){
return json(['state'=>'error','info'=>'[ 数据表格 ]第'.($tab_key+1).'行'.$tab_vali]);
exit;
}
}
}else{
return json(['state'=>'error','info'=>'数据表格不可为空!']);
exit;
}
if(empty($input['id'])){
$input['merchant']=Session('is_merchant_id') $vali = $this->validate($input,'Opurchaseclass');
if($vali===true){
$create_info=Opurchaseclass::create(syn_sql($input,'purchaseclass'));
Hook::listen('create_opurchase',$create_info) push_log('新增采购订单[ '.$create_info['number'].' ]') $resule=['state'=>'success'];
}else{
$resule=['state'=>'error','info'=>$vali];
}
}else{
$vali = $this->validate($input,'Opurchaseclass.update');
if($vali===true){
$update_info=Opurchaseclass::update(syn_sql($input,'purchaseclass'));
Hook::listen('update_opurchase',$update_info) push_log('更新采购订单[ '.$update_info['number'].' ]') Opurchaseinfo::where(['pid'=>$update_info['id']])->delete();
$resule=['state'=>'success'];
}else{
$resule=['state'=>'error','info'=>$vali];
}
}
if($resule['state']=='success'){
$info_pid=empty($input['id'])?$create_info['id']:$update_info['id'];
foreach ($input['tab'] as $info_vo) {
$info_vo['pid']=$info_pid;
(isset_full($info_vo,'attr') && $info_vo['attr']=='-1')&&($info_vo['attr']='') Opurchaseinfo::create(syn_sql($info_vo,'purchaseinfo'));
}
}
}else{
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}
if($resule['state']=='success'&&empty($input['id'])){
empty(get_sys(['auto_auditing']))||($this->auditing([$create_info['id']],true));
}
return json($resule);
}
public function form(){
return $this->fetch();
}
public function form_list(){
$input=input('post.');
if(isset_full($input,'page') && isset_full($input,'limit')){
$sql=get_sql($input,[
'name'=>'continue',
'number'=>'full_like',
'type'=>'full_dec_1',
'start_time'=>'stime',
'end_time'=>'etime',
'user'=>'full_division_in',
'data'=>'full_like'
],'opurchaseclass') if(isset_full($input,'name')){
$goods=get_db_field('goods',['name|py'=>['like','%'.$input['name'].'%']],'id') if(empty($goods)){
sql_assign($sql,'id',[]) }else{
$info=get_db_field('opurchaseinfo',['goods'=>['in',$goods]],'pid') sql_assign($sql,'id',$info) }
}
$sql['merchant']=['in',get_auth_merchant()] $sql=auth('opurchaseclass',$sql) $count = Opurchaseclass::where ($sql)->count() $arr = Opurchaseclass::with('merchantinfo,userinfo')->where($sql)->page($input['page'],$input['limit'])->order('id desc')->select() $resule=[
'code'=>0,
'msg'=>'获取成功',
'count'=>$count,
'data'=>$arr
] }else{
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}
return json($resule);
}
public function info(){
$input=input('get.');
if(isset_full($input,'id')){
$class=Opurchaseclass::where(['id'=>$input['id']])->find();
$info=Opurchaseinfo::with('goodsinfo')->where(['pid'=>$input['id']])->select();
$this->assign('class',$class);
$this->assign('info',$info);
return $this->fetch('main');
}else{
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}
return json($resule);
}
public function auditing($arr=[],$auto=false){
(empty($arr))&&($arr=input('post.arr')) if(empty($arr)){
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}else{
$class_data=[] $info_data=[] foreach ($arr as $arr_vo) {
$class=Opurchaseclass::where(['id'=>$arr_vo])->find();
$info=Opurchaseinfo::where(['pid'=>$arr_vo])->select();
if(!empty($class['type']['nod'])){
$rpurchase=Rpurchaseclass::where(['oid'=>$class['id']])->find() if(!empty($rpurchase)){
$auto&&(push_log('自动审核采购订单[ '.$class['number'].' ]失败,原因:该订单存在订单出库操作!')) return json(['state'=>'error','info'=>'审核-采购订单[ '.$class['number'].' ]失败,原因:该订单存在订单出库操作!']);
exit;
}
}
$class_data[$arr_vo]=$class $info_data[$arr_vo]=$info }
foreach ($arr as $arr_vo) {
$class=$class_data[$arr_vo] $info=$info_data[$arr_vo] if(empty($class['type']['nod'])){
Opurchaseclass::update(['id'=>$arr_vo,'type'=>1,'auditinguser'=>Session('is_user_id'),'auditingtime'=>time()]) push_log(($auto?'自动':'').'审核采购订单[ '.$class['number'].' ]');
}else{
Opurchaseclass::update(['id'=>$arr_vo,'type'=>0,'auditinguser'=>0,'auditingtime'=>0]) push_log ('反审核采购订单[ '.$class['number'].' ]');
}
}
$resule=['state'=>'success'];
}
return $auto?true:json($resule);
}
public function del(){
$input=input('post.');
if(isset_full($input,'arr') && is_array($input['arr'])){
$class=db('purchaseclass')->where(['id'=>['in',$input['arr']]])->select()->ToArray() $data = searchdata($class,['type'=>['eq',1]]) if(empty($data)){
foreach ($class as $class_vo) {
push_log('删除采购订单[ '.$class_vo['number'].' ]') Hook::listen('del_opurchase',$class_vo['id']) }
Opurchaseclass::where(['id'=>['in',$input['arr']]])->delete();
Opurchaseinfo::where(['id'=>['in',$input['arr']]])->delete();
$resule=['state'=>'success'];
}else{
$resule=['state'=>'error','info'=>'采购订单[ '.$data[0]['number'].' ]已审核,不可删除!'];
}
}else{
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}
return json($resule);
}
public function exports(){
$input=input('get.');
if(isset($input['mode'])){
push_log('导出采购订单数据') $sql=get_sql($input,[
'name'=>'continue',
'number'=>'full_like',
'type'=>'full_dec_1',
'start_time'=>'stime',
'end_time'=>'etime',
'user'=>'full_division_in',
'data'=>'full_like',
],'opurchaseclass') if(isset_full($input,'name')){
$goods=get_db_field('goods',['name|py'=>['like','%'.$input['name'].'%']],'id') if(empty($goods)){
sql_assign($sql,'id',[]) }else{
$info=get_db_field('opurchaseinfo',['goods'=>['in',$goods]],'pid') sql_assign($sql,'id',$info) }
}
$sql['merchant']=['in',get_auth_merchant()] $sql=auth('opurchaseclass',$sql) $arr = Opurchaseclass::with('merchantinfo,userinfo')->where($sql)->order('id desc')->select() if(empty($input['mode'])){
$formfield=get_formfield('opurchase_export','array') $excel=[] array_push($excel,['type'=>'title','info'=>'采购订单列表']);
$table_cell=[] foreach ($formfield as $formfield_vo) {
$table_cell[$formfield_vo['key']]=$formfield_vo['text'];
}
$table_data=[] foreach ($arr as $arr_vo) {
$row_data=[];
foreach ($formfield as $formfield_vo) {
$val='nod_initial' foreach (explode('|',$formfield_vo['data']) as $source) {
$val=$val=='nod_initial'?$arr_vo[$source]:(isset($val[$source])?$val[$source]:'');
}
$row_data[$formfield_vo['key']]=$val }
array_push($table_data,$row_data) }
array_push($excel,['type'=>'table','info'=>['cell'=>$table_cell,'data'=>$table_data]]) export_excel('采购订单列表',$excel);
}else{
$files=[] $formfield=get_formfield('opurchase_exports','array') foreach ($arr as $arr_vo) {
$excel=[] array_push($excel,['type'=>'title','info'=>'采购订单']);
array_push($excel,['type'=>'node','info'=>[
'单据日期:'.$arr_vo['time'],
'',
'单据编号:'.$arr_vo['number'],
]]);
$info=Opurchaseinfo::where(['pid'=>$arr_vo['id']])->select();
$table_cell=[] foreach ($formfield as $formfield_vo) {
$table_cell[$formfield_vo['key']]=$formfield_vo['text'];
}
$table_data=[] foreach ($info as $info_vo) {
$row_data=[];
foreach ($formfield as $formfield_vo) {
$val='nod_initial' foreach (explode('|',$formfield_vo['data']) as $source) {
$val=$val=='nod_initial'?$info_vo[$source]:(isset($val[$source])?$val[$source]:'');
}
$row_data[$formfield_vo['key']]=$val }
array_push($table_data,$row_data) }
array_push($excel,['type'=>'table','info'=>['cell'=>$table_cell,'data'=>$table_data]]) array_push($excel,['type'=>'node','info'=>[
'制单人:'.$arr_vo['userinfo']['name'],
'',
'备注信息:'.$arr_vo['data'],
]]);
$path=export_excel($arr_vo['number'],$excel,false) array_push($files,$path) }
file_to_zip('采购订单明细',$files) }
}else{
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}
return json($resule);
}
public function prints(){
$input=input('get.');
if(isset_full($input,'id')){
$print_name='opurchase' $class=Opurchaseclass::where(['id'=>$input['id']])->find();
$info=Opurchaseinfo::where(['pid'=>$input['id']])->select();
$print_paper=get_sys(['print_paper']);
$formfield=get_formfield('opurchase_print','array') $tab_html=get_print_tab($formfield,$info);
$print=get_print($print_name);
$print_text=$print[empty($print_paper)?'paper4':'paper2'];
$this->assign('class',$class);
$this->assign('tab_html',$tab_html);
$this->assign('print_name',$print_name);
$this->assign('paper_type',$print_paper);
$this->assign('print_text',$print_text);
return $this->fetch();
}else{
$resule=['state'=>'error','info'=>'传入参数不完整!'];
}
return json($resule);
}
}