Check.php 33 KB

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