Check.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ProcessOrder;
  4. use app\BaseController;
  5. use think\App;
  6. use think\facade\Db;
  7. use app\admin\model\ActionLog;
  8. class Check extends BaseController
  9. {
  10. public $post = "";
  11. public function __construct(App $app)
  12. {
  13. parent::__construct($app);
  14. $this->post=$this->request->post();
  15. // $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  16. // if($token==""){
  17. // return error_show(101,'token不能为空');
  18. // }
  19. // $effetc = VerifyTokens($token);
  20. // if(!empty($effetc) && $effetc['code']!=0){
  21. // return error_show($effetc['code'],$effetc['message']);
  22. // }
  23. }
  24. public function flist(){
  25. $page = isset($this->post['page']) &&$this->post['page'] !=="" ? intval($this->post['page']):1;
  26. $size = isset($this->post['size']) &&$this->post['size'] !=="" ? intval($this->post['size']):10;
  27. $condtion=[['a.is_del',"=",0],['b.is_del',"=",0],['c.is_del',"=",0]];
  28. $wsmcode =isset($this->post['wsm_code']) &&$this->post['wsm_code'] !=="" ? trim($this->post['wsm_code']):"";
  29. if($wsmcode!==""){
  30. //return error_show(1002,"仓库code不能为空");
  31. $condtion[]=['c.wsm_code',"=",$wsmcode];
  32. // $typecode= Db::name("good_stock")->where(["wsm_code"=>$wsmcode,'is_del'=>0])->column("good_type_code");
  33. }
  34. $good_code =isset($this->post['type_code']) &&$this->post['type_code'] !=="" ? trim($this->post['type_code']):"";
  35. if($good_code!=""){
  36. $condtion[]=['b.type_code',"=",$good_code];
  37. }
  38. $goodcode =isset($this->post['good_code']) &&$this->post['good_code'] !=="" ? trim($this->post['good_code'])
  39. :"";
  40. if($goodcode!=""){
  41. // $condtion['a.good_code'] = Db::raw("like '%{$goodcode}%'");
  42. $condtion[]=['a.good_code',"like","%{$goodcode}%"];
  43. }
  44. $good_name =isset($this->post['good_name']) &&$this->post['good_name'] !=="" ? trim($this->post['good_name'])
  45. :"";
  46. if($good_name!=""){
  47. // $condtion['a.good_name'] = Db::raw("like '%{$good_name}%'");
  48. $condtion[]=['a.good_name',"like","%{$good_name}%"];
  49. }
  50. $supplierNo =isset($this->post['supplierNo']) &&$this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']):"";
  51. if($supplierNo!=""){
  52. $supplier = Db::name("supplier")->where(["code"=>$supplierNo])->find();
  53. if(empty($supplier)){
  54. return error_show(1004,"未找到供应商信息");
  55. }
  56. $wsmcode = Db::name("warehouse_info")->where(["wsm_type"=>1,
  57. "is_del"=>0,"supplierNo"=>$supplierNo])->column("wsm_code");
  58. //$condtion["c.wsm_code"] = $wsmcode;
  59. $condtion[]=['c.wsm_code',"in",$wsmcode];
  60. }
  61. $stock_low =isset($this->post['stock_low']) &&$this->post['stock_low'] !=="" ? intval($this->post['stock_low'])
  62. :"";
  63. if($stock_low!=""){
  64. // $condtion['c.usable_stock'] = Db::raw(">= $stock_low");
  65. $condtion[]=['c.usable_stock',">=",$stock_low];
  66. }
  67. $stock_max =isset($this->post['stock_max']) &&$this->post['stock_max'] !=="" ? intval($this->post['stock_max'])
  68. :"";
  69. if($stock_max!=""){
  70. $condtion[]=['c.usable_stock',">=",$stock_max];
  71. }
  72. $stock_up =isset($this->post['stock_up']) &&$this->post['stock_up'] !=="" ? trim($this->post['stock_up'])
  73. :"";
  74. if($stock_up!=""){
  75. $condtion[]=['c.usable_stock',"<=",$stock_up];
  76. }
  77. $warn_low =isset($this->post['warn_low']) &&$this->post['warn_low'] !=="" ? intval($this->post['warn_low'])
  78. :"";
  79. if($warn_low!==""){
  80. // $condtion['c.warn_stock'] = Db::raw(">= $warn_low");
  81. $condtion[]=['c.warn_stock',">=",$warn_low];
  82. }
  83. $warn_up =isset($this->post['warn_up']) &&$this->post['warn_up'] !=="" ? intval($this->post['warn_up'])
  84. :"";
  85. if($warn_up!=""){
  86. // $condtion['c.warn_stock'] = Db::raw("<= {$warn_up}");
  87. $condtion[]=['c.warn_stock',"<=",$warn_up];
  88. }
  89. $cat_id =isset($this->post['cat_id']) &&$this->post['cat_id'] !=="" ? intval($this->post['cat_id']) :"";
  90. if($cat_id!=""){
  91. $at = Db::name('cat')->where(['id'=>$cat_id])->find();
  92. if(empty($at)){
  93. return error_show(1004,"未找到分类信息");
  94. }
  95. $cat=manger([$at['id']],$at['level']);
  96. $condtion[]=['a.cat_id',"in",$cat];
  97. }
  98. $count = Db::name("good_type")->alias("b")
  99. ->join("good a","a.good_code = b.good_code","left")
  100. ->join("good_stock c","c.good_type_code=b.type_code","left")
  101. ->where($condtion)->count();
  102. $page>=ceil($count/$size) ? $page=ceil($count/$size) :"";
  103. $list = Db::name("good_type")->alias("b")->join("good a","a.good_code = b.good_code","left")
  104. ->join("good_stock c","c.good_type_code=b.type_code","left")
  105. ->where($condtion)->field("c.id,a.good_code,a.good_name,a.good_desc,a.brand,a.original_price,a.cg_saler,a.good_type,a.market_fee,a.gys_code,a.unit,
  106. a.sort_f,a.sort_s,a.sort_t,b.color,b.material,b.specs,b.is_main,b.type_code,b.attribute,b.status as bstatus,a.addtime,c.wsm_code,c.usable_stock,c.warn_stock,a.updatetime,a.cat_id")
  107. ->page($page,$size)->select();
  108. $data=[];
  109. foreach ($list as $key=>$value){
  110. $supplier = Db::name("supplier")->where(["code"=>$value['gys_code']])->find();
  111. $value['supplier_name'] =isset($supplier['name']) ?$supplier['name'] :"";
  112. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")->where(["a.wsm_code"=>$value['wsm_code']])->field("a.name as wsm_name,b.name,b.code")->find();
  113. $value['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  114. $value['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  115. $value['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  116. $value['can']= isset($value['cat_id']) && $value['cat_id'] !=0 ? made($value['cat_id']):[];
  117. $data[]=$value;
  118. }
  119. return app_show(0,"获取成功",["list"=>$data,"count"=>$count]);
  120. }
  121. public function list()
  122. {
  123. $page = isset($this->post['page']) && $this->post['page'] !== "" ? intval($this->post['page']) : "1";
  124. $size = isset($this->post['size']) && $this->post['size'] !== "" ? intval($this->post['size']) : "10";
  125. $where = [['a.is_del',"=",0],['b.is_del',"=",0]];
  126. $start= isset($this->post['start']) && $this->post['start'] !== "" ? $this->post['start']:"";
  127. if ($start !="") {
  128. // $where["a.addtime"]=Db::raw(">= '{$start}'");
  129. $where[]=['a.addtime',">=",$start];
  130. }
  131. $end = isset($this->post['end']) && $this->post['end'] !== "" ? $this->post['end'] :"";
  132. if($end !=""){
  133. // $where["a.addtime"] = Db::raw("<= '{$end}'");
  134. $where[]=['a.addtime',"<=",$end];
  135. }
  136. $check_code = isset($this->post['check_code']) && $this->post['check_code'] !== "" ? trim($this->post['check_code']) : "";
  137. if ($check_code !== "") {
  138. // $where['a.check_code'] = Db::raw("like '%$check_code%'");
  139. $where[]=['a.check_code',"like","%$check_code%"];
  140. }
  141. $wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code'] !== "" ? trim($this->post['wsm_code']) : "";
  142. if ($wsm_code !== "") {
  143. // $where['a.wsm_code'] = Db::raw("like '%$wsm_code%'");
  144. $where[]=['a.wsm_code',"like","%$wsm_code%"];
  145. }
  146. $apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !== "" ? trim($this->post['apply_name']) : "";
  147. if ($apply_name !== "") {
  148. // $where['a.apply_name'] = $apply_name;
  149. $where[]=['a.apply_name',"like","%$apply_name%"];
  150. }
  151. $type = isset($this->post['type']) && $this->post['type'] !== "" ? trim($this->post['type']) : "";
  152. if ($type !== "") {
  153. // $where['a.type'] = $type;
  154. $where[]=['a.type',"=",$type];
  155. }
  156. $apply_id = isset($this->post['apply_id']) && $this->post['apply_id'] !== "" ? intval($this->post['apply_id']) : "";
  157. if ($apply_id!== "") {
  158. // $where['a.apply_id'] = $apply_id;
  159. $where[]=['a.apply_id',"=",$apply_id];
  160. }
  161. $status= isset($this->post['status']) && $this->post['status'] !== "" ? intval($this->post['status']) : "";
  162. if ($status !== "") {
  163. // $where['a.status '] = $status;
  164. $where[]=['a.status',"=",$status];
  165. }
  166. $count = Db::name('good_check')->alias('a')->join("warehouse_info b","a.wsm_code = b.wsm_code","left")
  167. ->join("supplier v","v.code=b.supplierNo","left")
  168. ->where($where)->count();
  169. $total = ceil($count / $size);
  170. $page = $page <= $total ? $page : $total;
  171. $list = Db::name('good_check')->alias('a')->join("warehouse_info b","a.wsm_code = b.wsm_code","left")
  172. ->join("supplier v","v.code=b.supplierNo","left")
  173. ->field("a.status,a.apply_id,a.apply_name,a.type,a.addtime,a.wsm_code,a.check_code,b.name,a.id,v.name as 'caname',v.code")->where($where)->page($page,$size)->order("a.id desc")->select();
  174. $data=[];
  175. foreach ($list as $key=>$value){
  176. $value['rename'] ='';
  177. if($value['apply_id']!=0){
  178. $depart = Db::name("depart_user")->alias("a")->leftJoin("company_item b","a.itemid = b.id")->where(['a.uid'=>$value['apply_id'],'a.is_del'=>0])
  179. ->column('b.name');
  180. // var_dump(Db::name("depart_user")->getLastSql());
  181. $value['rename'] =implode(",",$depart);
  182. }
  183. $data[] = $value;
  184. }
  185. return app_show(0,"获取成功",['count'=>$count,'list'=>$data]);
  186. }
  187. public function goodlist(){
  188. $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']) :"1";
  189. $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']) :"10";
  190. $where = ['is_del'=>0];
  191. $id = isset($this->post['id']) && $this->post['id'] !=="" ? intval($this->post['id']) :"";
  192. if($id==""){
  193. return error_show(1002,"参数id不能为空");
  194. }
  195. $fo = Db::name('good_check')->alias('a')->join('warehouse_info b',"b.wsm_code=a.wsm_code","left")
  196. ->join('supplier c',"c.code=b.supplierNo","left")->field("c.name,c.code,a.*")
  197. ->where(['a.id'=>$id,'a.is_del'=>0])->find();
  198. if(empty($fo)){
  199. return error_show(1003,"未找到盘点信息");
  200. }
  201. if ($fo['check_code'] !== "") {
  202. $where['check_code'] = $fo['check_code'];
  203. }
  204. $count = Db::name('check_item')->where($where)->count();
  205. $total = ceil($count / $size);
  206. $page = $page >= $total ? $total: $page;
  207. $list = Db::name('check_item')->where($where)->page($page,$size)->select();
  208. return app_show(0,"获取成功",['count'=>$count,'list'=>$list]);
  209. }
  210. public function create(){
  211. $token =isset($this->post['token']) && $this->post['token'] !=="" ? trim($this->post['token']) :"";
  212. $wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code'] !=="" ? trim($this->post['wsm_code']):"";
  213. if($wsm_code==""){
  214. return error_show(1002,"盘点仓库编号不能为空");
  215. }
  216. $type = isset($this->post['type']) && $this->post['type'] !=="" ? intval($this->post['type']) :"";
  217. if($type==""){
  218. return error_show(1002,"盘点类型不能为空");
  219. }
  220. $check_code = makeNo("CK");
  221. $apply_id=GetUserInfo($token);
  222. if(empty($apply_id)||$apply_id['code']!=0){
  223. return error_show(1002,"申请人数据不存在");
  224. }
  225. $rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
  226. $ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
  227. $status = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']) :"0";
  228. $remark = isset($this->post['remark']) && $this->post['remark'] !=="" ? intval($this->post['remark']) :"";
  229. // $dain=isset($this->post['good']) && $this->post['good'] !=="" ? trim($this->post['good']):"";
  230. // if($type==2){
  231. // if($dain==""||empty($dain)){
  232. // return error_show(1002,"商品不能为空");
  233. // }
  234. // }else{
  235. // if($type==1) {
  236. //
  237. // $dain= Db::name("good_type")->alias("b")->join("good a","a.good_code = b.good_code","left")
  238. // ->join("good_stock c","c.good_type_code = b.type_code","left")->where(['c.wsm_code'=>$wsm_code,'b.is_del'=>0,'a.is_del'=>0])->where("c.is_del=0 or c.is_del is null")
  239. // ->field("b.type_code,a.good_name")->select();
  240. // //var_dump($dain);
  241. // }
  242. // if($dain==""){
  243. // return error_show(1003,"商品不能为空");
  244. // }
  245. // }
  246. Db::startTrans();
  247. try{
  248. $data=[
  249. "check_code"=>$check_code,
  250. "wsm_code"=>$wsm_code,
  251. "type"=>$type,
  252. "status"=>$status,
  253. "remark"=>$remark,
  254. "apply_id"=>$rm,
  255. "apply_name"=>$ri,
  256. "is_del"=>0,
  257. "addtime"=>date('Y-m-d H:i:s'),
  258. "updatetime"=>date("Y-m-d H:i:s")
  259. ];
  260. $da= Db::name('good_check')->insert($data,true);
  261. // $dio=[];
  262. // if($da>0){
  263. // foreach ($dain as $value){
  264. // $st=Db::name("good_type")->alias("b")->join("good a","a.good_code = b.good_code","left")
  265. // ->join("good_stock c","c.good_type_code = b.type_code","left")->where(['c.wsm_code'=>$wsm_code,'good_type_code'=>$value['type_code'],'b.is_del'=>0,'a.is_del'=>0])->where("c.is_del=0 or c.is_del is null")
  266. // ->field("b.type_code,a.good_name,c.wsm_code,c.wait_in_stock,c.wait_out_stock,c.usable_stock,c.good_type_code,a.original_price")->find();
  267. //
  268. // $temp=[];
  269. // $temp['good_name']=$st['good_name'];
  270. // $temp['origin_price']=$st['original_price'];
  271. // $temp['good_type_code']=$st['good_type_code'];
  272. // $temp['origin_num']=$st['usable_stock'];
  273. // $temp['check_num']=0;
  274. // $temp['diff_num']=0;
  275. // $temp['status']=0;
  276. // $temp['remark']="";
  277. // $temp['is_del']=0;
  278. // $temp['check_time']=date('Y-m-d H:i:s');
  279. // $temp['check_code']=$check_code;
  280. // $temp['addtime']=date("Y-m-d H:i:s");
  281. // $temp['updatetime']=date("Y-m-d H:i:s");
  282. // $dio[] =$temp;
  283. // }
  284. // $in= Db::name('check_item')->insertAll($dio);
  285. // }
  286. if($da){
  287. $orde = ["order_code"=>$check_code,"status"=>$data['status'],"action_remark"=>'',"action_type"=>"create"];
  288. ActionLog::logAdd($this->post['token'],$orde,'qrd',$data['status'],$orde);
  289. $process=["order_code"=>$check_code,"order_id"=>$da,"order_status"=>$data['status'],"order_type"=>'PDD'];
  290. ProcessOrder::AddProcess($this->post['token'],$process);
  291. Db::commit();
  292. return error_show(0,"盘点创建成功");
  293. }else{
  294. Db::rollback();
  295. return error_show(1002,"创建失败");
  296. }
  297. }catch (\Exception $e){
  298. Db::rollback();
  299. return error_show(1005,$e->getMessage());
  300. }
  301. }
  302. public function info(){
  303. $id = isset($this->post['id']) && $this->post['id'] !=="" ? intval($this->post['id']) :"";
  304. if($id==""){
  305. return error_show(1002,"参数id不能为空");
  306. }
  307. $fo = Db::name('good_check')->alias('a')->join('warehouse_info b',"b.wsm_code=a.wsm_code","left")
  308. ->join('supplier c',"c.code=b.supplierNo","left")->field("c.name,c.code,a.*")
  309. ->where(['a.id'=>$id,'a.is_del'=>0])->find();
  310. if(empty($fo)){
  311. return error_show(1003,"未找到盘点信息");
  312. }
  313. $fi = Db::name('check_item')->where(['check_code'=>$fo['check_code'],'is_del'=>0])->select();
  314. $fo['item']=$fi;
  315. if(empty($fo)){
  316. return error_show(1002,"未找到盘点编号");
  317. }else{
  318. return app_show(0,"获取成功",$fo);
  319. }
  320. }
  321. public function edit()
  322. {
  323. $token =isset($this->post['token']) && $this->post['token'] !=="" ? trim($this->post['token']) :"";
  324. $id = isset($this->post['id']) && $this->post['id'] !== "" ? intval($this->post['id']) : "";
  325. $eid = Db::name('good_check')->where(['id' => $id, 'is_del' => 0])->find();
  326. if ($eid ==="") {
  327. return error_show(1002, "未找到盘点编号信息");
  328. }
  329. $wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code'] !== "" ? trim($this->post['wsm_code']) : "";
  330. if ($wsm_code == "") {
  331. return error_show(1002, "盘点仓库不能为空");
  332. }
  333. $type = isset($this->post['type']) && $this->post['type'] !== "" ? trim($this->post['type']) : "";
  334. $remark = isset($this->post['remark']) && $this->post['remark'] !== "" ? trim($this->post['remark']) : "";
  335. if ($type == "") {
  336. return error_show(1002, "盘点类型不能为空");
  337. }
  338. $apply_id=GetUserInfo($token);
  339. if(empty($apply_id)||$apply_id['code']!=0){
  340. return error_show(1002,"申请人数据不存在");
  341. }
  342. $rm= isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
  343. $ri= isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
  344. // $dain=isset($this->post['good']) && $this->post['good'] !=="" ? $this->post['good']:"";
  345. // if($type==2){
  346. // // var_dump($dain);
  347. // if($dain==""||empty($dain)){
  348. // return error_show(1002,"商品不能为空");
  349. // }
  350. // }else{
  351. // if($type==1) {
  352. //
  353. // $dain= Db::name("good_type")->alias("b")->join("good a","a.good_code = b.good_code","left")
  354. // ->join("good_stock c","c.good_type_code = b.type_code","left")->where(['c.wsm_code'=>$wsm_code,'b.is_del'=>0,'a.is_del'=>0])->where("c.is_del=0 or c.is_del is null")
  355. // ->field("b.type_code,a.good_name")->select();
  356. // //var_dump($dain);
  357. // }
  358. // if($dain==""){
  359. // return error_show(1003,"商品不能为空");
  360. // }
  361. // }
  362. Db::startTrans();
  363. try {
  364. $var = [
  365. "wsm_code" => $wsm_code,
  366. "type" => $type,
  367. "apply_id" => $rm,
  368. "apply_name" => $ri,
  369. "remark" => $remark,
  370. "updatetime" => date("Y-m-d H:i:s")
  371. ];
  372. $up = Db::name('good_check')->where(['id'=>$id,'is_del' => 0])->save($var);
  373. // $dn =[];
  374. // if($up>0){
  375. // foreach ($dain as $value){
  376. // $st=Db::name("good_type")->alias("b")->join("good a","a.good_code = b.good_code","left")
  377. // ->join("good_stock c","c.good_type_code = b.type_code","left")->where(['c.wsm_code'=>$wsm_code,'good_type_code'=>$value['type_code'],'b.is_del'=>0,'a.is_del'=>0])->where("c.is_del=0 or c.is_del is null")
  378. // ->field("b.type_code,a.good_name,c.wsm_code,c.wait_in_stock,c.wait_out_stock,c.usable_stock,c.good_type_code,a.original_price")->find();
  379. // $temp=[];
  380. // $temp['good_name']=$st['good_name'];
  381. // $temp['origin_price']=$st['original_price'];
  382. // $temp['good_type_code']=$st['good_type_code'];
  383. // $temp['origin_num']=$st['usable_stock'];
  384. // $temp['check_num']=0;
  385. // $temp['diff_num']=0;
  386. // $temp['status']=0;
  387. // $temp['remark']="";
  388. // $temp['is_del']=0;
  389. // $temp['check_time']=date('Y-m-d H:i:s');
  390. // $temp['check_code']=$eid['check_code'];
  391. // $temp['addtime']=date("Y-m-d H:i:s");
  392. // $temp['updatetime']=date("Y-m-d H:i:s");
  393. // $dn[] =$temp;
  394. // }
  395. // $np = Db::name('check_item')->where(['check_code'=>$eid['check_code'],'is_del'=>0])->update(['is_del'=>1,'updatetime'=>date('Y-m-d H:i:s')]);
  396. // $io = db::name('check_item')->insertAll($up);
  397. // var_dump(Db::name('check_item')->getLastSql());
  398. if ($up) {
  399. $orde = ["order_code"=>$eid['check_code'],"status"=>$eid['status'],"action_remark"=>'',"action_type"=>"edit"];
  400. ActionLog::logAdd($this->post['token'],$orde,'qrd',$eid['status'],$orde);
  401. Db::commit();
  402. return error_show(0, "盘点更新成功");
  403. }
  404. Db::rollback();
  405. return error_show(1003,"盘点更新失败");
  406. } catch (\Exception $e) {
  407. Db::rollback();
  408. return error_show(1005, $e->getMessage());
  409. }
  410. }
  411. /**
  412. * @return \think\response\Json|void
  413. * @throws \think\db\exception\DataNotFoundException
  414. * @throws \think\db\exception\DbException
  415. * @throws \think\db\exception\ModelNotFoundException
  416. */
  417. public function dell(){
  418. $id = $this->post['id'] && $this->post['id'] !=="" ? intval($this->post['id']) :"";
  419. if($id===""){
  420. return error_show(1004,"参数id不能为空");
  421. }
  422. $deln= Db::name('good_check')->where(['id'=>$id,'is_del'=>0])->find();
  423. if(empty($deln)){
  424. return error_show(1002,"未找到数据");
  425. }
  426. $sv = Db::name('good_check')->update(['id'=>$id,'is_del'=>1,'updatetime'=>date("Y-m-d H:i:s")]);
  427. if($sv){
  428. $orde = ["order_code"=>$deln['check_code'],"status"=>$deln['status'],"action_remark"=>'',"action_type"=>"delete"];
  429. ActionLog::logAdd($this->post['token'],$orde,'qrd',$deln['status'],['id'=>$id,'is_del'=>1,'updatetime'=>date("Y-m-d H:i:s")]);
  430. $process=["order_code"=>$deln['check_code'],"order_status"=>$deln['status'],"order_type"=>'PDD'];
  431. ProcessOrder::workdel($process);
  432. return error_show(0,"删除成功");
  433. }else{
  434. return error_show(1002,"删除失败");
  435. }
  436. }
  437. /**
  438. * @return \think\response\Json|void
  439. * @throws \think\db\exception\DataNotFoundException
  440. * @throws \think\db\exception\DbException
  441. * @throws \think\db\exception\ModelNotFoundException
  442. */
  443. public function statu()
  444. {
  445. $id = isset($this->post['id']) && $this->post['id'] !=="" ? intval($this->post['id']) :"";
  446. if($id==""){
  447. return error_show(1002,"盘点id不能为空");
  448. }
  449. $stauts = isset($this->post['status']) && $this->post['status'] !=="" ? intval($this->post['status']) :"";
  450. $remark = isset($this->post['remark']) && $this->post['remark'] !=="" ? trim($this->post['remark']) :"";
  451. if($stauts===""){
  452. return error_show(1002,"状态不能为空");
  453. }
  454. $st = Db::name('good_check')->where(['id'=>$id,"is_del"=>0])->find();
  455. if(empty($st)){
  456. return error_show(1002,"盘点信息未找到");
  457. }
  458. Db::startTrans();
  459. try{
  460. $temp = $st['status'];
  461. $st['status']=$stauts;
  462. $st['remark']=$remark;
  463. $st['updatetime']= date('Y-m-d H:i:s');
  464. $sv = Db::name('good_check')->save($st);
  465. if($sv){
  466. $orde = ["order_code"=>$st['check_code'],$temp,"action_remark"=>'',"action_type"=>"status"];
  467. ActionLog::logAdd($this->post['token'],$orde,'PDD',$st['status'],$orde);
  468. if($stauts==1&&$temp==2){
  469. $up = Db::name('check_item')->where(['check_code'=>$st['check_code'],"is_del"=>0])->save(['is_del'=>1,
  470. "updatetime"=>date("Y-m-d H:i:s")]);
  471. if($up==false){
  472. Db::rollback();
  473. return error_show(1003,"盘点结果删除失败");
  474. }
  475. }
  476. if($stauts==2){
  477. $nu = Db::name('check_item')->where(['check_code'=>$st['check_code'],"is_del"=>0])->select()->toArray();
  478. if(empty($nu)){
  479. Db::rollback();
  480. return error_show(1003,"未上传盘点结果");
  481. }
  482. }
  483. $process=["order_code"=>$st['check_code'],"order_id"=>$st['id'],"order_status"=>$stauts,"order_type"=>'PDD'];
  484. ProcessOrder::AddProcess($this->post['token'],$process);
  485. Db::commit();
  486. return error_show(0,"状态更新成功");
  487. }
  488. Db::rollback();
  489. return error_show(1002,"状态更新失败");
  490. }catch (\Exception $e){
  491. Db::rollback();
  492. return error_show(1002,$e->getMessage());
  493. }
  494. }
  495. public function exportGood(){
  496. $id = isset($this->post['id']) && $this->post['id'] !=="" ? intval($this->post['id']) :"";
  497. if($id==""){
  498. return error_show(1002,"参数id不能为空");
  499. }
  500. $fo = Db::name('good_check')->alias('a')->join('warehouse_info b',"b.wsm_code=a.wsm_code","left")
  501. ->join('supplier c',"c.code=b.supplierNo","left")->field("c.name,c.code,b.name,a.*")
  502. ->where(['a.id'=>$id,'a.is_del'=>0])->find();
  503. if(empty($fo)){
  504. return error_show(1003,"未找到盘点信息");
  505. }
  506. $list = Db::name("good_type")->alias("b")->join("good a","a.good_code = b.good_code","left")
  507. ->join("good_stock c","c.good_type_code=b.type_code","left")
  508. ->where(['c.wsm_code'=>$fo['wsm_code'],"a.is_del"=>0,"b.is_del"=>0,"c.is_del"=>0])->field("a.good_code '商品编码',b.type_code '商品属性编码',
  509. a.good_name '商品名称',a.good_desc '商品描述',a.brand '品牌',a.unit '单位',a.gys_code '供应商编码','' as '供应商名称',a.sort_f '一级分类',a.sort_s '二级分类',a.sort_t '三级分类',
  510. a.addtime '新建时间',c.wsm_code '仓库编码','' as '仓库名称',c.usable_stock '可用库存','' as '盘点库存'")
  511. ->select();
  512. $data=[];
  513. foreach ($list as $key=>$value){
  514. $wsm = Db::name("warehouse_info")->where(['wsm_code'=>$value['仓库编码']])->find();
  515. $supplier = Db::name("supplier")->where(["code"=>$value['供应商编码']])->find();
  516. $value['供应商名称'] =isset($supplier['name']) ?$supplier['name'] :"";
  517. $value['仓库名称'] =isset($wsm['name']) ?$wsm['name'] :"";
  518. $data[]=$value;
  519. }
  520. if(empty($data)){
  521. $data[]=["暂无商品信息"=>''];
  522. }
  523. $headerArr= array_keys($data[0]);
  524. excelSave('盘点商品',$headerArr,$data);
  525. // return app_show(0,"获取成功",$data);
  526. }
  527. public function importGood(){
  528. $id = isset($this->post['id']) && $this->post['id'] !=="" ? intval($this->post['id']) :"";
  529. if($id==""){
  530. return error_show(1002,"参数id不能为空");
  531. }
  532. $fo = Db::name('good_check')->alias('a')->join('warehouse_info b',"b.wsm_code=a.wsm_code","left")
  533. ->join('supplier c',"c.code=b.supplierNo","left")->field("c.name,c.code,b.name,a.*")
  534. ->where(['a.id'=>$id,'a.is_del'=>0])->find();
  535. if(empty($fo)){
  536. return error_show(1003,"未找到盘点信息");
  537. }
  538. if($fo['status']>=2){
  539. return error_show(1003,"盘点已提交审核,不可提交盘点数据");
  540. }
  541. $data = isset($this->post['data']) && $this->post['data'] !=="" ?$this->post['data'] :"";
  542. if($data=="" || empty($data)){
  543. return error_show(1003,"盘点数据不能为空");
  544. }
  545. $insert=[];
  546. foreach ($data as $value){
  547. if($value["value1"]==""){
  548. return error_show(1003,"商品属性code 不能为空");
  549. }
  550. if($value["value15"]===""){
  551. continue;
  552. }
  553. $stock = Db::name("good_stock")->where(["good_type_code"=>$value["value1"],"wsm_code"=>$fo['wsm_code'],
  554. "is_del"=>0])->find();
  555. $stock_num = isset($stock) ? $stock['usable_stock']:0;
  556. $insert[]=[
  557. "good_type_code"=>$value["value1"],
  558. "good_name"=>$value["value2"],
  559. "origin_price"=>0,
  560. "origin_num"=>isset($stock) ? $stock['usable_stock']:0,
  561. "check_num"=>$value["value15"],
  562. "is_profit"=>intval($value["value15"])>=$stock_num ?0:1,
  563. "diff_num"=>intval($value["value15"])>=$stock_num ?intval($value["value15"])-$stock_num:$stock_num-intval($value["value15"]),
  564. 'addtime'=>date("Y-m-d H:i:s"),
  565. 'updatetime'=>date("Y-m-d H:i:s"),
  566. "check_code"=>$fo['check_code']
  567. ];
  568. }
  569. if(empty($insert)){
  570. return error_show(1003,"盘点数据不可用");
  571. }
  572. Db::startTrans();
  573. try{
  574. $inst = Db::name("check_item")->insertAll($insert);
  575. if($inst){
  576. $check_up = Db::name("good_check")->where(["check_code"=>$fo['check_code'],"is_del"=>0])->save(["status"=>2,"updatetime"=>date("Y-m-d H:i:s")]);
  577. if($check_up){
  578. $orde = ["order_code"=>$fo['check_code'],$fo['status'],"action_remark"=>'',"action_type"=>"edit"];
  579. ActionLog::logAdd($this->post['token'],$orde,'PDD',2,["status"=>2,"updatetime"=>date("Y-m-d H:i:s")]);
  580. $process=["order_code"=>$fo['check_code'],"order_id"=>$fo['id'],"order_status"=>2,"order_type"=>'PDD'];
  581. ProcessOrder::AddProcess($this->post['token'],$process);
  582. Db::commit();
  583. return app_show(0,"盘点数据导入成功");
  584. }
  585. }
  586. Db::rollback();
  587. return error_show(1002,"盘点数据导入失败");
  588. }catch (\Exception $e){
  589. Db::rollback();
  590. return error_show(1002,"盘点数据导入失败");
  591. }
  592. }
  593. }