Resign.php 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047
  1. <?php
  2. /**
  3. * 备库申请
  4. */
  5. namespace app\admin\controller;
  6. use app\admin\model\ActionLog;
  7. use app\admin\model\DataGroup as DataGroupModel;
  8. use app\admin\model\GoodLog;
  9. use app\admin\model\ProcessOrder;
  10. use think\facade\Cache;
  11. use think\facade\Config;
  12. use think\facade\Db;
  13. use think\App;
  14. //备货
  15. class Resign extends Base
  16. {
  17. public function __construct(App $app)
  18. {
  19. parent::__construct($app);
  20. }
  21. public function list(){
  22. $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
  23. $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
  24. $where =[['p.is_del',"=",0]];
  25. $bkcode = isset($this->post['bk_code']) && $this->post['bk_code']!="" ? trim($this->post['bk_code']):"";
  26. if($bkcode!=""){
  27. //$where['p.bk_code'] = $bk_code;
  28. $where[]=['p.bk_code',"like","%{$bkcode}%"];
  29. }
  30. $good_code = isset($this->post['good_code']) && $this->post['good_code']!="" ? trim($this->post['good_code']):"";
  31. if($good_code!=""){
  32. // $where['p.good_code'] = $good_code;
  33. $where[]=['p.spuCode',"like","%{$good_code}%"];
  34. }
  35. $good_type_code = isset($this->post['good_type_code']) && $this->post['good_type_code']!="" ? trim($this->post['good_type_code']):"";
  36. if($good_type_code!=""){
  37. // $where['p.good_type_code'] = $good_type_code;
  38. $where[]=['p.good_type_code',"like","%{$good_type_code}%"];
  39. }
  40. $wsm_code = isset($this->post['wsm_code']) && $this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
  41. if($wsm_code!=""){
  42. //$where['p.wsm_code'] = $wsm_code;
  43. $where[]=['p.wsm_code',"=",$wsm_code];
  44. }
  45. $good_name = isset($this->post['good_name']) && $this->post['good_name']!="" ? trim($this->post['good_name']):"";
  46. if($good_name!=""){
  47. // $where['p.good_name'] = Db::raw(" like '%{$good_name}%'");
  48. $where[]=['p.good_name',"like","%{$good_name}%"];
  49. }
  50. $apply_name = isset($this->post['apply_name']) && $this->post['apply_name']!="" ? trim($this->post['apply_name']):"";
  51. if($apply_name!=""){
  52. // $where['p.apply_name'] =Db::Raw("like '%{$apply_name}%'");
  53. $where[]=['p.apply_name',"like","%{$apply_name}%"];
  54. }
  55. $status = isset($this->post['status']) && $this->post['status']!=="" ? intval($this->post['status']):"";
  56. if($status!==""){
  57. // $where['p.status'] = $status;
  58. $where[]=['p.status',"=",$status];
  59. }
  60. $start = isset($this->post['start']) && $this->post['start']!=="" ? $this->post['start']:"";
  61. if($start!==""){
  62. //$where['p.addtime'] = Db::Raw(">= '{$start}'");
  63. $where[]=['p.addtime',">=",$start];
  64. }
  65. $end = isset($this->post['end']) && $this->post['end']!=="" ? $this->post['end']:"";
  66. if($end!==""){
  67. // $where['p.addtime'] = Db::Raw("<= '{$end}'");
  68. $where[]=['p.addtime',"<=",$end];
  69. }
  70. // $role=$this->checkRole();
  71. $condition=[];
  72. // if(!empty($role['write']) && $this->uid!=""){
  73. // // $where[]=["a.apply_id","in",$role['write']];
  74. // $condition .="p.cgderid = {$this->uid} or p.apply_id in (".implode(',',$role['write']).")";
  75. // }
  76. //超管、库管、库管-张凯旋、boss能看到所有,其他人只能看到自己创建的和身为采购员的单子
  77. $super_roleid = array_merge([1, 33], config('app.wsm_cgder_role'));
  78. if (!in_array($this->roleid, $super_roleid)) {
  79. $role = $this->checkDataShare();
  80. $hand =resign_hand_user($this->uid,0);
  81. if (!empty($role[DataGroupModel::$type_全部])){
  82. $arr= array_unique(array_merge($hand,$role[DataGroupModel::$type_全部]));
  83. $condition[]= ["p.apply_id","in",$arr];
  84. $condition[]= ["p.cgderid","in",$hand];
  85. }
  86. // $condition .="p.cgderid in {$hand} or p.apply_id in {$hand} or p.apply_id in ("
  87. // .implode(',',$role[DataGroupModel::$type_全部]).")";
  88. }
  89. $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
  90. if ($company_name !== "") $where[] = ["p.apply_id", 'in', get_company_item_user_by_name($company_name)];
  91. $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo'] !== "" ? trim($this->post['relaComNo']) : "";
  92. if ($relaComNo !== "") $where[] = ["p.companyNo", '=', $relaComNo];
  93. $supplierNo = isset($this->post['supplierNo']) && $this->post['supplierNo'] !== "" ? trim($this->post['supplierNo']) : "";
  94. if ($supplierNo !== "") $where[] = ["p.supplierNo", '=', $supplierNo];
  95. // if(!empty($role['platform']) ){
  96. // $where[]=["p.platform_id","in",$role['platform']];
  97. // }
  98. $count=Db::name("purchease")
  99. ->alias('p')
  100. ->where($where)
  101. ->where(function ($query)use ($condition){$query->whereOr($condition);})
  102. ->count();
  103. $total = ceil($count/$size);
  104. $page = $page >= $total ? $total : $page;
  105. $list = Db::name("purchease")
  106. ->alias('p')
  107. ->where($where)
  108. ->where(function ($query)use ($condition){$query->whereOr($condition);})
  109. ->page($page,$size)
  110. ->order("p.addtime desc")
  111. ->select()
  112. ->toArray();
  113. $data=[];
  114. $all_createrid = array_column($list,'apply_id');
  115. $item = get_company_name_by_uid($all_createrid);
  116. foreach ($list as $value){
  117. $value['wsm_name']="";
  118. $value['wsm_supplier']="";
  119. $value['wsm_supplierNo']="";
  120. if($value['wsm_code']!=""){
  121. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  122. ->where(["a.wsm_code"=>$value['wsm_code']])->field("a.name as wsm_name,b.name,b.code")->find();
  123. $value['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  124. $value['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  125. $value['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  126. }
  127. $value['file_name'] ='';
  128. if($value['file_url']){
  129. $file= basename($value['file_url']);
  130. $value['file_name'] =substr($file,0,strripos($file,"_"));
  131. }
  132. $value['company_name'] = $item[$value['apply_id']]??'';
  133. //是否具有编辑权限
  134. // $value['is_allow_update'] = 0;
  135. // if (in_array($this->roleid, $super_roleid) || in_array($value['apply_id'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;
  136. $data[]=$value;
  137. }
  138. return app_show(0,"获取成功",["count"=>$count,"list"=>$data]);
  139. }
  140. public function add(){
  141. $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  142. if($token==""){
  143. return error_show(101,'token不能为空');
  144. }
  145. $good_code = isset($this->post['good_code']) && $this->post['good_code']!=""?trim($this->post['good_code']):"";
  146. if($good_code==""){
  147. return error_show(1004,"参数good_code不能为空");
  148. }
  149. $good_num = isset($this->post['good_num'])&& $this->post['good_num']!==""? intval($this->post['good_num']):"";
  150. if($good_num===""){
  151. return error_show(1004,"参数good_code不能为空");
  152. }
  153. $file_url = isset($this->post['file_url'])&& $this->post['file_url']!==""? trim($this->post['file_url']):"";
  154. if($file_url===""){
  155. return error_show(1004,"参数file_url不能为空");
  156. }
  157. $mark =isset($this->post['remark'])&&$this->post['remark']!=""?trim($this->post['remark']):"";
  158. if($mark==""){
  159. return error_show(1004,"参数remark不能为空");
  160. }
  161. $good =Db::name("good_basic")->where([["spuCode","=",$good_code],["is_del","=",0]])->find();
  162. if($good==false){
  163. return error_show(1004,"未找到商品数据");
  164. }
  165. $supplier=Db::name("supplier")->where("code","=",$good['supplierNo'])->find();
  166. if($supplier==false) return error_show(1004,"未找到供应商数据");
  167. // $bk= Db::name("purchease")->where([["spuCode","=",$good_code],["status","<>",2],["is_del","=",0]])->find();
  168. // if($bk!=false) return error_show(1004,"存在未完成备库单数据");
  169. // $cgd =Db::name("purchease_order")->where([["spuCode","=",$good_code],["status","in",[0,1]],["is_del","=",0]])->find();
  170. // if($cgd!=false) return error_show(1004,"存在未完成采购单数据");
  171. //查验仓库库存数量
  172. // $stock =Db::name("good_stock")->alias("a")->leftJoin("warehouse_info b","a.wsm_code=b.wsm_code")->where
  173. // (["spuCode"=>$good_code, "a.is_del"=>0,"a.status"=>1,"b.companyNo"=>$good['companyNo']])->field("a.id,a.usable_stock,a.wait_out_stock")->find();
  174. // if(isset($stock['usable_stock'])&& $stock['usable_stock']!=0){
  175. // return error_show(1003,"库存数量为 {$stock['usable_stock']} 无法备库");
  176. // }
  177. //校验数量
  178. $goodnake = Db::name("good_nake")
  179. ->field('id,min_num')
  180. ->where([["spuCode", "=", $good_code], ["is_del", "=", 0]])
  181. ->order("min_num asc")
  182. ->find();
  183. if (empty($goodnake)) return error_show(1004, '未找到商品成本数据');
  184. $minnum = $goodnake['min_num'];
  185. if($good['is_stock']==1 && $good['stock_moq']>0){
  186. $minnum =$good['stock_moq'];
  187. }
  188. if ($minnum > $good_num) return error_show(1004, '该商品最低采购数量为' . $minnum);
  189. $lastime = isset($this->post['lastime'])&&$this->post['lastime']!="" ? $this->post['lastime']:"";
  190. if($lastime===""){
  191. return error_show(1004,"参数lastime不能为空");
  192. }
  193. // $data = GetUserInfo($token);
  194. // if((!empty($data) && $data['code']!=0) ||empty($data) ){
  195. // return error_show($data['code'],$data['message']);
  196. // }
  197. // $userinfo = $data['data'];
  198. $bk_code=makeNo("BK");
  199. $info = [
  200. "spuCode"=>$good['spuCode'],
  201. "good_name"=>$good['good_name'],
  202. "good_num"=>$good_num,
  203. "wsm_code"=>'',
  204. "companyNo"=>$good['companyNo'],
  205. "supplierNo"=>$good['supplierNo'],
  206. "file_url"=>$file_url,
  207. "lasttime"=>$lastime,
  208. "status"=>1,
  209. "remark"=>$mark,
  210. "cgder" => $good['charger'],//$good['creater'],
  211. "cgderid" => $good['chargerid'],//$good['createrid'],
  212. "addtime"=>date("Y-m-d H:i:s"),
  213. "updatetime"=>date("Y-m-d H:i:s"),
  214. "apply_id"=>$this->uid,
  215. "apply_name"=>$this->uname,
  216. "bk_code"=>$bk_code
  217. ];
  218. $in = Db::name("purchease")->insert($info,true);
  219. if($in>0){
  220. //备库单,推给供应商负责人
  221. $order = ["order_type" => 'BHD', "order_code" => $bk_code, "order_id" => $in, "order_status" => 1, "before_status" => 1, 'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
  222. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $order);
  223. $ste = ["order_code" => $bk_code, "status" => 0, "action_remark" => '', "action_type" => "create"];
  224. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], $ste, "BHD", 1, $info);
  225. //台账记录
  226. Db::name('standing_book')
  227. ->insert([
  228. 'standBookNo' => makeNo("IO"),
  229. 'bk_code' => $bk_code,
  230. 'purchease_id' => $in,
  231. 'addtime' => date('Y-m-d H:i:s'),
  232. 'updatetime' => date('Y-m-d H:i:s')
  233. ]);
  234. return app_show(0,"新建成功",['bk_code'=>$bk_code]);
  235. }else{
  236. return error_show(1005,"新建失败");
  237. }
  238. }
  239. /**
  240. * @return \think\response\Json|void
  241. * @throws \think\db\exception\DataNotFoundException
  242. * @throws \think\db\exception\DbException
  243. * @throws \think\db\exception\ModelNotFoundException
  244. */
  245. public function copy(){
  246. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  247. if($id==""){
  248. return error_show(1001,'id不能为空');
  249. }
  250. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  251. if(empty($info)){
  252. return error_show(1002,'未找到数据');
  253. }
  254. // $data = GetUserInfo($this->post['token']);
  255. // if((!empty($data) && $data['code']!=0) ||empty($data) ){
  256. // return error_show($data['code'],$data['message']);
  257. // }
  258. //查验仓库库存数量
  259. // $stock =Db::name("good_stock")->alias("a")->leftJoin("warehouse_info b","a.wsm_code=b.wsm_code")->where
  260. // (["spuCode"=>$info['spuCode'], "a.is_del"=>0,"a.status"=>1,"b.companyNo"=>$info['companyNo']])->field("a.id,a.usable_stock,a.wait_out_stock")->find();
  261. // if(isset($stock['usable_stock'])&& $stock['usable_stock']!=0){
  262. // return error_show(1003,"库存数量为 {$stock['usable_stock']} 无法备库");
  263. // }
  264. // $userinfo = $data['data'];
  265. $bk_code=makeNo("BK");
  266. $info['bk_code']=$bk_code;
  267. $info['status']=1;
  268. $info['addtime']=date("Y-m-d H:i:s");
  269. $info['updatetime']=date("Y-m-d H:i:s");
  270. $info['apply_id']=$this->uid;
  271. $info['apply_name']=$this->uname;
  272. unset($info['id']);
  273. $in = Db::name("purchease")->insert($info,true);
  274. if($in>0){
  275. $supplier = Db::name('supplier')
  276. ->field('id,person,personid')
  277. ->where('code', $info['supplierNo'])
  278. ->findOrEmpty();
  279. $order = ["order_type" => 'BHD', "order_code" => $bk_code, "order_id" => $in, "order_status" => 1, "before_status" => 1, 'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
  280. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $order);
  281. $ste = ["order_code"=>$bk_code,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  282. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname],$ste,"BHD",1,$info);
  283. return app_show(0,"新建成功",['bk_code'=>$bk_code]);
  284. }else{
  285. return error_show(1005,"新建失败");
  286. }
  287. }
  288. /**
  289. * @return \think\response\Json|void
  290. * @throws \think\db\exception\DataNotFoundException
  291. * @throws \think\db\exception\DbException
  292. * @throws \think\db\exception\ModelNotFoundException
  293. */
  294. public function info(){
  295. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  296. if($id==""){
  297. return error_show(1001,'id不能为空');
  298. }
  299. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  300. if(empty($info)){
  301. return error_show(1002,'未找到数据');
  302. }
  303. $good =Db::name("good_basic")->where([["spuCode","=", $info['spuCode']],["is_del","=",0]])->find();
  304. if($good==false){
  305. return error_show(1004,"未找到商品数据");
  306. }
  307. $int= isset($good['cat_id']) && $good['cat_id'] !=0 ? made($good['cat_id']):[];
  308. $metal = \think\facade\Config::get("noble");
  309. $info['noble_metal']= isset($metal[$good['noble_metal']]) && $good['noble_metal'] !=''?$metal[$good['noble_metal']]:'';
  310. $info['noble_id']= isset($good['noble_metal']) && $good['noble_metal'] !='' ? $good['noble_metal']:"";
  311. $info['wsm_name']="";
  312. $info['file_name'] ='';
  313. if($info['file_url']){
  314. $file= basename($info['file_url']);
  315. $info['file_name'] =substr($file,0,strripos($file,"_"));
  316. }
  317. if($info['wsm_code']!=""){
  318. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  319. ->where(["a.wsm_code"=>$info['wsm_code']])->field("a.name as wsm_name,b.name,b.code")->find();
  320. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  321. $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  322. $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  323. }
  324. $supplier =Db::name("supplier")->where(["code"=>$info['supplierNo']])->find();
  325. $info['supplier_name'] = isset($supplier['name'])?$supplier['name']:"";
  326. $company =Db::name("business")->where(["companyNo"=>$info['companyNo']])->find();
  327. $info['company_name'] = isset($company['company'])?$company['company']:"";
  328. $info['can']=$int;
  329. return app_show(0,"获取成功",$info);
  330. }
  331. public function edit(){
  332. $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  333. if($token==""){
  334. return error_show(101,'token不能为空');
  335. }
  336. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  337. if($id==""){
  338. return error_show(1001,'id不能为空');
  339. }
  340. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  341. if(empty($info)){
  342. return error_show(1002,'未找到数据');
  343. }
  344. $customer = isset($this->post['customer_code'])&&$this->post['customer_code']!="" ?trim($this->post['customer_code']):"";
  345. if($customer==""){
  346. return error_show(1004,"参数customer_code不能为空");
  347. }
  348. $supplier = isset($this->post['supplier_code'])&&$this->post['supplier_code']!="" ?trim($this->post['supplier_code']):"";
  349. if($supplier==""){
  350. return error_show(1004,"参数supplier_code不能为空");
  351. }
  352. $good_code = isset($this->post['good_code']) && $this->post['good_code']!=""?trim($this->post['good_code']):"";
  353. if($good_code==""){
  354. return error_show(1004,"参数good_code不能为空");
  355. }
  356. $good_num = isset($this->post['good_num'])&& $this->post['good_num']!==""? intval($this->post['good_num']):"";
  357. if($good_num===""){
  358. return error_show(1004,"参数good_code不能为空");
  359. }
  360. $file_url = isset($this->post['file_url'])&& $this->post['file_url']!==""? trim($this->post['file_url']):"";
  361. if($file_url===""){
  362. return error_show(1004,"参数file_url不能为空");
  363. }
  364. $mark =isset($this->post['remark'])&&$this->post['remark']!=""?trim($this->post['remark']):"";
  365. if($mark==""){
  366. return error_show(1004,"参数remark不能为空");
  367. }
  368. $good =Db::name("good_basic")->where([["spuCode","=", $good_code],["is_del","=",0]])->find();
  369. if($good==false){
  370. return error_show(1004,"未找到商品数据");
  371. }
  372. // $data = GetUserInfo($token);
  373. // if((!empty($data) && $data['code']!=0) ||empty($data) ){
  374. // return error_show($data['code'],$data['message']);
  375. // }
  376. // $userinfo = $data['data'];
  377. $up = [
  378. "spuCode"=>$good_code,
  379. "good_name"=>$good['good_name'],
  380. "good_num"=>$good_num,
  381. // "skuCode"=>$good['skuCode'],
  382. "companyNo"=>$customer,
  383. "supplierNo"=>$supplier,
  384. "file_url"=>$file_url,
  385. "remark"=>$mark,
  386. "updatetime"=>date("Y-m-d H:i:s"),
  387. ];
  388. $in = Db::name("purchease")->where($info)->save($up);
  389. if($in){
  390. $order=["order_type"=>'BHD',"order_code"=>$info['bk_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"before_status"=>1, 'holder_id' => $info['apply_id']];
  391. ProcessOrder::AddProcess($this->post['token'],$order);
  392. $ste = ["order_code"=>$info['bk_code'],"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  393. ActionLog::logAdd($this->post['token'],$ste,"BHD",$info['status'],$up);
  394. return app_show(0,"更新成功",['bk_code'=>$info['bk_code']]);
  395. }else{
  396. return error_show(1005,"更新失败");
  397. }
  398. }
  399. public function delete(){
  400. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  401. if($id==""){
  402. return error_show(1001,'id不能为空');
  403. }
  404. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  405. if(empty($info)){
  406. return error_show(1002,'未找到数据');
  407. }
  408. $info['is_del']=1;
  409. $info['updatetime']=date("Y-m-d H:i:s");
  410. $up = Db::name("purchease")->update($info);
  411. if($up){
  412. $order=["order_type"=>'BHD',"order_code"=>$info['bk_code'],"order_id"=>$info['id'],"order_status"=>$info['status']];
  413. ProcessOrder::workdel($order);
  414. $ste = ["order_code"=>$info['bk_code'],"status"=>$info['status'],"action_remark"=>'',"action_type"=>"delete"];
  415. ActionLog::logAdd($this->post['token'],$ste,"BHD",$info['status'],$info);
  416. }
  417. return $up ? app_show(0,"删除成功"):error_show(1005,"删除失败");
  418. }
  419. public function status(){
  420. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  421. if($id==""){
  422. return error_show(1001,'id不能为空');
  423. }
  424. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  425. if(empty($info)){
  426. return error_show(1002,'未找到数据');
  427. }
  428. $status = isset($this->post['status'])&&$this->post['status']!=='' ? intval($this->post['status']) : "";
  429. if($status===""){
  430. return error_show(1001,'status不能为空');
  431. }
  432. $temp = $info['status'];
  433. $info['status']= $status;
  434. $info['updatetime']=date("Y-m-d H:i:s");
  435. $up = Db::name("purchease")->update($info);
  436. if($up){
  437. if($status==1){
  438. $supplier = Db::name('supplier')
  439. ->field('id,person,personid')
  440. ->where('code', $info['supplierNo'])
  441. ->findOrEmpty();
  442. $order = ["order_type" => 'BHD', "order_code" => $info['bk_code'], "order_id" => $info['id'], "order_status" => $status, "before_status" => $temp,'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
  443. }else $order = ["order_type" => 'BHD', "order_code" => $info['bk_code'], "order_id" => $info['id'], "order_status" => $status, "before_status" => $temp, 'holder_id' => $info['apply_id']];
  444. $order = ["order_type" => 'BHD', "order_code" => $info['bk_code'], "order_id" => $info['id'], "order_status" => $status, "before_status" => $temp, 'holder_id' => $info['apply_id']];
  445. ProcessOrder::AddProcess($this->post['token'],$order);
  446. $ste = ["order_code"=>$info['bk_code'],"status"=> $temp,"action_remark"=>'',"action_type"=>"status"];
  447. ActionLog::logAdd($this->post['token'],$ste,"BHD",$status,$info);
  448. return app_show(0,"更新成功",['bk_code'=>$info['bk_code']]);
  449. }else{
  450. return error_show(1005,"更新失败");
  451. }
  452. }
  453. public function addFeed(){
  454. $token = isset($this->post['token']) ? trim($this->post['token']) : "";
  455. if($token==""){
  456. return error_show(101,'token不能为空');
  457. }
  458. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  459. if($id==""){
  460. return error_show(1001,'id不能为空');
  461. }
  462. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  463. if(empty($info)){
  464. return error_show(1002,'未找到备库数据');
  465. }
  466. if($info['status']!=1){
  467. return error_show(1002,'备库数据状态有误');
  468. }
  469. $num = isset($this->post['num']) && $this->post['num']!=="" ? intval($this->post['num']):"";
  470. if($num==''){
  471. return error_show(1002,'参数num 不能为空或零');
  472. }
  473. $expecttime = isset($this->post['expecttime'])&&$this->post['expecttime']!=''?$this->post['expecttime'] :"";
  474. if($expecttime==''){
  475. return error_show(1002,'参数expecttime 不能为空');
  476. }
  477. $wsm_type = isset($this->post['wsm_type'])&&$this->post['wsm_type']!="" ? intval($this->post['wsm_type']):"";
  478. if($wsm_type==""){
  479. return error_show(1002,'参数wsm_type 不能为空');
  480. }
  481. $wsm_code = isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
  482. if($wsm_code==""){
  483. return error_show(1002,'参数wsm_code 不能为空');
  484. }
  485. $wsminfo = Db::name("warehouse_info")->where(['wsm_code'=>$wsm_code,"wsm_type"=>$wsm_type,"is_del"=>0])->find();
  486. if(empty($wsminfo)){
  487. return error_show(1002,'未找到仓库数据');
  488. }
  489. $supplierNo = isset($this->post['supplierNo'])&&$this->post['supplierNo']!="" ? trim($this->post['supplierNo']):"";
  490. if($supplierNo==""){
  491. return error_show(1002,'参数supplierNo 不能为空');
  492. }
  493. $supplie = Db::name("supplier")->where(['code'=>$supplierNo,"is_del"=>0])->find();
  494. if(empty($supplie)){
  495. return error_show(1002,'未找到供应商');
  496. }
  497. $good_price = isset($this->post['good_price'])&&$this->post['good_price']!=="" ? $this->post['good_price']:"";
  498. if($good_price===""){
  499. return error_show(1002,'参数good_price 不能为空');
  500. }
  501. $pakge_fee = isset($this->post['pakge_fee'])&&$this->post['pakge_fee']!=="" ? $this->post['pakge_fee']:0;
  502. $cert_fee = isset($this->post['cert_fee'])&&$this->post['cert_fee']!=="" ? $this->post['cert_fee']:0;
  503. $open_fee = isset($this->post['open_fee'])&&$this->post['open_fee']!=="" ? $this->post['open_fee']:0;
  504. $delivery_fee = isset($this->post['delivery_fee'])&&$this->post['delivery_fee']!=="" ? $this->post['delivery_fee']:0;
  505. $mark_fee = isset($this->post['mark_fee'])&&$this->post['mark_fee']!=="" ? $this->post['mark_fee']:0;
  506. $teach_fee = isset($this->post['teach_fee'])&&$this->post['teach_fee']!=="" ? $this->post['teach_fee']:0;
  507. $nake_fee = isset($this->post['nake_fee'])&&$this->post['nake_fee']!=="" ? $this->post['nake_fee']:0;
  508. $demo_fee = isset($this->post['demo_fee'])&&$this->post['demo_fee']!=="" ? $this->post['demo_fee']:0;
  509. $weight = isset($this->post['weight'])&&$this->post['weight']!=="" ? $this->post['weight']:0;
  510. $diff_weight =isset($this->post['diff_weight'])&&$this->post['diff_weight']!=="" ? $this->post['diff_weight']:0;
  511. $diff_price =isset($this->post['diff_price'])&&$this->post['diff_price']!=="" ? $this->post['diff_price']:0;
  512. $remark =isset($this->post['remark'])&&$this->post['remark']!=="" ? $this->post['remark']:'';
  513. $data = GetUserInfo($token);
  514. if((!empty($data) && $data['code']!=0) ||empty($data) ){
  515. return error_show($data['code'],$data['message']);
  516. }
  517. $userinfo = $data['data'];
  518. $data=[
  519. "bkcode"=>$info['bk_code'],
  520. "warehouse"=>$wsm_code,
  521. "wsm_type"=>$wsm_type,
  522. "num"=>$num,
  523. 'expecttime'=>$expecttime,
  524. 'supplier'=>isset($supplie) && $supplie['code']!=''? $supplie['code']:'',
  525. 'good_price'=>$good_price,
  526. 'pakge_fee'=>$pakge_fee,
  527. 'cert_fee'=>$cert_fee,
  528. 'open_fee'=>$open_fee,
  529. 'mark_fee'=>$mark_fee,
  530. 'teach_fee'=>$teach_fee,
  531. 'nake_fee'=>$nake_fee,
  532. 'demo_fee'=>$demo_fee,
  533. 'delivery_fee'=>$delivery_fee,
  534. 'weight'=>$weight,
  535. 'remark'=>$remark,
  536. 'diff_weight'=>$diff_weight,
  537. 'diff_price'=>$diff_price,
  538. 'purchaser'=>$userinfo['nickname'],
  539. 'purchaser_id'=>$userinfo['id'],
  540. "addtime"=>date("Y-m-d H:i:s"),
  541. "updatetime"=>date("Y-m-d H:i:s")
  542. ];
  543. Db::startTrans();
  544. try{
  545. $in = Db::name('purchease_feedback')->insert($data,true);
  546. if($in>0){
  547. $order=["order_type"=>'FKD',"order_code"=>$info['bk_code'],"order_id"=>$in, "order_status"=>0,"before_status"=>1];
  548. ProcessOrder::AddProcess($this->post['token'],$order);
  549. $ste = ["order_code"=>$info['bk_code'],"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  550. ActionLog::logAdd($this->post['token'],$ste,"FKD",0,$data);
  551. $temp=$info['status'];
  552. $info['status']=2;
  553. $info['wsm_code']=$wsm_code;
  554. $info['addtime']=date("Y-m-d H:i:s");
  555. $ood=Db::name('purchease')->save($info);
  556. if($ood){
  557. $order=["order_type"=>'BHD',"order_code"=>$info['bk_code'],"order_id"=>$info['id'], "order_status"=>$info['status'],"before_status"=>$temp, 'holder_id' => $info['apply_id']];
  558. ProcessOrder::AddProcess($this->post['token'],$order);
  559. $ste = ["order_code"=>$info['bk_code'],"status"=>$temp,"action_remark"=>'',"action_type"=>"status"];
  560. ActionLog::logAdd($this->post['token'],$ste,"BHD",$info['status'],$info);
  561. Db::commit();
  562. return app_show(0,"新建成功");
  563. }
  564. }
  565. Db::rollback();
  566. return error_show(1005,"新建失败");
  567. }catch (\Exception $e){
  568. Db::rollback();
  569. return error_show(1005,"新建失败");
  570. }
  571. // return $in ? app_show(0,"新建成功"):error_show(1005,"新建失败");
  572. }
  573. public function delFeed(){
  574. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  575. if($id==""){
  576. return error_show(1001,'id不能为空');
  577. }
  578. $feed = Db::name("purchease_feedback")->where(['id'=>$id,'is_del'=>0])->find();
  579. if(empty($feed)){
  580. return error_show(1004,'未找到数据');
  581. }
  582. if($feed['status']==1){
  583. return error_show(1004,'反馈数据已采用无法删除');
  584. }
  585. $feed['is_del']= 1;
  586. $feed['updatetime']=date("Y-m-d H:i:s");
  587. $up = Db::name("purchease_feedback")->update($feed);
  588. if($up){
  589. $order=["order_type"=>'FKD',"order_code"=>$feed['bk_code'],"order_id"=>$feed['id'], "order_status"=>0];
  590. ProcessOrder::workdel($order);
  591. $ste = ["order_code"=>$feed['bk_code'],"status"=>$feed['status'],"action_remark"=>'',"action_type"=>"delete"];
  592. ActionLog::logAdd($this->post['token'],$ste,"FKD",$feed['status'],$feed);
  593. }
  594. return $up ? app_show(0,"删除成功"):error_show(1005,"删除失败");
  595. }
  596. public function infoFeed(){
  597. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  598. if($id==""){
  599. return error_show(1001,'id不能为空');
  600. }
  601. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  602. if(empty($info)){
  603. return error_show(1002,'未找到备库数据');
  604. }
  605. $feed = Db::name("purchease_feedback")->where(['bkcode'=>$info['bk_code'],'is_del'=>0])->find();
  606. if(empty($feed)){
  607. return error_show(1004,'未找到反馈数据');
  608. }
  609. $feed['wsm_name']="";
  610. if($feed['warehouse']!=""){
  611. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  612. ->where(["a.wsm_code"=>$feed['warehouse']])->field("a.name as wsm_name,b.name,b.code")->find();
  613. $feed['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  614. $feed['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  615. $feed['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  616. }
  617. if($feed['supplier']!=""){
  618. $supplie = Db::name("supplier")->where(['code'=>$feed['supplier'],"is_del"=>0])->find();
  619. $feed['supplier_name'] =isset($supplie['name']) ? $supplie['name']:"";
  620. }
  621. return app_show(0,"获取成功",$feed);
  622. }
  623. public function changeFeed(){
  624. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  625. if($id==""){
  626. return error_show(1001,'id不能为空');
  627. }
  628. $feed = Db::name("purchease")->where(['id'=>$id,'is_del'=>0])->find();
  629. if(empty($feed)){
  630. return error_show(1004,'未找到数据');
  631. }
  632. $status = isset($this->post['status'])&& $this->post['status']!=='' ? intval($this->post['status']) : "";
  633. if($status==""){
  634. return error_show(1001,'参数status 不能为空');
  635. }
  636. $remark = isset($this->post['remark'])&& $this->post['remark']!=='' ? trim($this->post['remark']) : "";
  637. Db::startTrans();
  638. try{
  639. $tem =$feed['status'];
  640. $feed['remark']= $remark;
  641. $feed['status']= $status;
  642. $feed['updatetime']=date("Y-m-d H:i:s");
  643. $up = Db::name("purchease")->update($feed);
  644. if($up){
  645. if ($feed['status'] == 1) {
  646. $supplier = Db::name('supplier')
  647. ->field('id,person,personid')
  648. ->where('code', $feed['supplierNo'])
  649. ->findOrEmpty();
  650. $order = ["order_type" => 'BHD', "order_code" => $feed['bk_code'], "order_id" => $feed['id'], "order_status" => $feed['status'], "before_status" => $tem, 'holder_id' => $feed['apply_id'], 'wait_id' => $supplier['personid'], 'wait_name' => $supplier['person']];
  651. } else $order = ["order_type" => 'BHD', "order_code" => $feed['bk_code'], "order_id" => $feed['id'], "order_status" => $feed['status'], "before_status" => $tem, 'holder_id' => $feed['apply_id']];
  652. ProcessOrder::AddProcess($this->post['token'], $order);
  653. $ste = ["order_code"=>$feed['bk_code'],"status"=>$tem,"action_remark"=>'',"action_type"=>"edit"];
  654. ActionLog::logAdd($this->post['token'],$ste,"BHD",$feed['status'],$feed);
  655. if($status==3){
  656. // $ware = Db::name("warehouse_addr")->where(["wsm_code"=>$feed['warehouse'],"is_del"=>0])->find();
  657. $purse = Db::name("purchease_feedback")->where(['bkcode'=>$feed['bk_code'],"is_del"=>0])->find();
  658. if(empty($purse)){
  659. Db::rollback();
  660. return error_show(1001,'未找到备库反馈数据');
  661. }
  662. $pe = $purse['status'];
  663. $purse['status']=1;
  664. $purse['addtime']=date("Y-m-d H:i:s");
  665. $up = Db::name("purchease_feedback")->save($purse);
  666. if($up==false){
  667. Db::rollback();
  668. return error_show(1001,'备库反馈数据状态修改失败');
  669. }
  670. $order=["order_type"=>'FKD',"order_code"=>$feed['bk_code'],"order_id"=>$purse['id'],"order_status"=>$purse['status'],"before_status"=>$pe];
  671. ProcessOrder::AddProcess($this->post['token'],$order);
  672. $ste = ["order_code"=>$feed['bk_code'],"status"=>$pe,"action_remark"=>'',"action_type"=>"status"];
  673. ActionLog::logAdd($this->post['token'],$ste,"FKD",$feed['status'],$purse);
  674. $supplier = Db::name("supplier")->where(["code"=>$purse['supplier']])->find();
  675. $inw = makeNo("CG");
  676. $goodinfo=Db::name('good_basic')
  677. ->field('id,createrid,creater')
  678. ->where(['is_del'=>0,'spuCode'=>$feed['spuCode']])
  679. ->findOrEmpty();
  680. $data=[
  681. "bkcode"=>$purse['bkcode'],
  682. 'cgdNo'=>$inw,
  683. "wsm_code"=>$purse['warehouse'],
  684. "good_code"=>$feed['good_code'],
  685. "good_name"=>$feed['good_name'],
  686. "good_type_code"=>$feed['good_type_code'],
  687. "good_num"=>$feed['good_num'],
  688. "send_num"=>0,
  689. "wsend_num"=>$feed['good_num'],
  690. 'good_price'=>$purse['good_price'],
  691. "total_fee"=>$purse['good_price'],
  692. 'pakge_fee'=>$purse['pakge_fee'],
  693. 'cert_fee'=>$purse['cert_fee'],
  694. 'open_fee'=>$purse['open_fee'],
  695. 'mark_fee'=>$purse['mark_fee'],
  696. 'teach_fee'=>$purse['teach_fee'],
  697. 'nake_fee'=>$purse['nake_fee'],
  698. 'demo_fee'=>$purse['demo_fee'],
  699. 'delivery_fee'=>$purse['delivery_fee'],
  700. 'weight'=>$purse['weight'],
  701. 'diff_weight'=>$purse['diff_weight'],
  702. 'diff_fee'=>$purse['diff_price'],
  703. 'cgder_id'=>$purse['purchaser_id'],
  704. 'cgder'=>$purse['purchaser'],
  705. "remark"=>$purse['remark'],
  706. "status"=>0,
  707. 'supplierNo'=>$purse['supplier'],
  708. 'supplier_name'=>isset($supplier['name']) ? $supplier['name']:"",
  709. 'lasttime'=>$purse['expecttime'],
  710. "addtime"=>date("Y-m-d H:i:s"),
  711. "updatetime"=>date("Y-m-d H:i:s"),
  712. 'good_createrid' => $goodinfo['createrid'],
  713. 'good_creater' => $goodinfo['creater'],//商品的创建人
  714. ];
  715. $in= Db::name("purchease_order")->insert($data,true);
  716. if($in>0){
  717. //当采购单是节点0待与供应商确认,推给供应商负责人
  718. if(!isset($supplier)) $supplier = Db::name("supplier")->where(["code"=>$purse['supplier']])->find();
  719. $order=["order_type"=>'CGD',"order_code"=>$data['cgdNo'],"order_id"=>$in, "order_status"=>$data['status'],"before_status"=>0,'wait_id'=>$supplier['personid'],'wait_name'=>$supplier['person']];
  720. ProcessOrder::AddProcess($this->post['token'],$order);
  721. $ste = ["order_code"=>$inw,"status"=>$data['status'],"action_remark"=>'',"action_type"=>"create"];
  722. ActionLog::logAdd($this->post['token'],$ste,"CGD",$data['status'],$data);
  723. //将采购单数据塞入到队列中
  724. $push_data = json_encode([
  725. 'supplierNo' => $data['supplierNo'],
  726. 'type' => 1,//1销售订单(采销的采购单),2上线结果
  727. 'data' => [
  728. 'cgdNo' => $data['cgdNo'],
  729. 'spuCode' => $feed['spuCode'],
  730. 'good_name' => $data['good_name'],
  731. 'good_num' => $data['good_num'],
  732. 'good_price' => $data['good_price'],
  733. 'total_fee' => $data['total_fee'],
  734. 'weight' => $data['weight'],
  735. 'addtime' => $data['addtime'],
  736. ],
  737. ], JSON_UNESCAPED_UNICODE);
  738. // Cache::store("redis")->handler()->lPush(Config::get('app.abutment_queue'), $push_data);
  739. Db::commit();
  740. return app_show(0,"更新成功",['cgdNo'=>$inw]);
  741. }
  742. }else{
  743. if($status==4){
  744. $purse = Db::name("purchease_feedback")->where(['bkcode'=>$feed['bk_code'],"is_del"=>0])->find();
  745. if(empty($purse)){
  746. Db::rollback();
  747. return error_show(1001,'未找到备库反馈数据');
  748. }
  749. $pe=$purse['status'];
  750. $purse['status']=2;
  751. $purse['addtime']=date("Y-m-d H:i:s");
  752. $up = Db::name("purchease_feedback")->save($purse);
  753. if($up==false){
  754. Db::rollback();
  755. return error_show(1001,'备库反馈数据状态修改失败');
  756. }
  757. $order=["order_type"=>'FKD',"order_code"=>$feed['bk_code'],"order_id"=>$purse['id'],"order_status"=>$purse['status'],"before_status"=>1];
  758. ProcessOrder::AddProcess($this->post['token'],$order);
  759. $ste = ["order_code"=>$feed['bk_code'],"status"=>$pe,"action_remark"=>'',"action_type"=>"status"];
  760. ActionLog::logAdd($this->post['token'],$ste,"FKD",$feed['status'],$purse);
  761. }
  762. Db::commit();
  763. return app_show(0,"更新成功");
  764. }
  765. }
  766. Db::rollback();
  767. return error_show(1004,"更新失败");
  768. }catch (\Exception $e){
  769. Db::rollback();
  770. return error_show(1005,$e->getMessage());
  771. }
  772. }
  773. public function addwsm(){
  774. $id = isset($this->post['id']) ? intval($this->post['id']) : "";
  775. if($id==""){
  776. return error_show(1001,'id不能为空');
  777. }
  778. $info = Db::name("purchease")->where(["id"=>$id,"is_del"=>0])->find();
  779. if($info==false){
  780. return error_show(1002,'未找到备库数据');
  781. }
  782. $wsm= isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']) : "";
  783. if($wsm==""){
  784. return error_show(1004,"参数wsm_code不能为空");
  785. }
  786. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$wsm,"is_del"=>0])->find();
  787. if($wsminfo==false){
  788. return error_show(1004,"未找到仓库数据");
  789. }
  790. $info['wsm_code']=$wsm;
  791. $old_info_status = $info['status'];
  792. $info['status']=1;
  793. $info['updatetime']=date("y-m-d H;i:s");
  794. $up =Db::name("purchease")->save($info);
  795. if($up){
  796. //修改状态,添加待办
  797. ActionLog::logAdd($this->post['token'], [
  798. "order_code" => $info['bk_code'],//销售单code
  799. "status" => $old_info_status,//这里的status是之前的值
  800. "action_remark" => '',//备注
  801. "action_type" => "edit"//新建create,编辑edit,更改状态status
  802. ], "BHD", $info['status'], $info);
  803. $supplier = Db::name('supplier')
  804. ->field('id,person,personid')
  805. ->where('code', $info['supplierNo'])
  806. ->findOrEmpty();
  807. ProcessOrder::AddProcess($this->post['token'], [
  808. "order_type" => 'BHD',
  809. "order_code" => $info['bk_code'],//销售单code
  810. "order_id" => $info['id'],
  811. "order_status" => $info['status'],
  812. "before_status"=>$old_info_status,
  813. //'holder_id' => $info['apply_id'],
  814. 'wait_id' => $supplier['personid'],
  815. 'wait_name' => $supplier['person'],
  816. ]);
  817. return app_show(0,"备库单仓库选择成功");
  818. }else{
  819. return error_show(1004,"备库单仓库选择失败");
  820. }
  821. }
  822. //备库单生成采购单
  823. public function createCgd(){
  824. $bk_code=isset($this->post['bk_code'])&&$this->post['bk_code']!=="" ? trim($this->post['bk_code']):"";
  825. if($bk_code===""){
  826. return error_show(1004,"参数bk_code不能为空");
  827. }
  828. $info = Db::name("purchease")->where(["bk_code"=>$bk_code,"is_del"=>0])->find();
  829. if($info==false){
  830. return error_show(1002,'未找到备库数据');
  831. }
  832. $wsm_code =isset($this->post['wsm_code'])&&$this->post['wsm_code']!=="" ? trim($this->post['wsm_code']):'';
  833. if($wsm_code==""){
  834. return error_show(1002,'备库仓库不能为空');
  835. }
  836. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$wsm_code,"is_del"=>0])->find();
  837. if($wsminfo==false){
  838. return error_show(1002,'备库仓库未找到');
  839. }
  840. $good =Db::name("good_basic")->where([["spuCode","=",$info['spuCode']],["is_del","=",0]])->find();
  841. if($good==false){
  842. return error_show(1004,"未找到商品数据");
  843. }
  844. $supplier=Db::name("supplier")->where(["code"=>$info['supplierNo'],"is_del"=>0])->find();
  845. if($supplier==false){
  846. return error_show(1004,"未找到供应商数据");
  847. }
  848. $goodnake =Db::name("good_nake")->where([["spuCode","=",$info['spuCode']],["is_del","=",0],["min_num","<=",
  849. $info['good_num']]])->order("min_num desc")->find();
  850. if($goodnake==false){
  851. return error_show(1004,"未找到成本数据");
  852. }
  853. $top_cat = made($good['cat_id']);
  854. $top_cat_id = isset($top_cat[0]['id'])?$top_cat[0]['id']:"";
  855. if($good['is_gold_price']==1 && $top_cat_id==6){
  856. $gold = Db::name("gold_price1")->where(["type"=>$good['noble_metal'],"is_del"=>0,"status"=>1])->order("addtime desc")
  857. ->find();
  858. // $weight = $good['noble_weight']*$info['good_num'];
  859. $sale_price = round($good['demo_fee'] / $info['good_num'] + $good['open_fee'] / $info['good_num'] + $good['noble_weight'] * $gold["price"] + $goodnake['cost_fee'] * $good['noble_weight'] + $goodnake['package_fee'] + $goodnake['mark_fee'] + $goodnake['cert_fee'] +$goodnake['nake_fee'] + $goodnake['delivery_fee'],2);
  860. $total_price = round($info['good_num']*$sale_price,2);
  861. }else{
  862. $sale_price = $goodnake['nake_total'];
  863. $total_price = round($info['good_num']*$sale_price,2);
  864. }
  865. $cgdCode = makeNo("CG");
  866. $cg =["cgdNo"=>$cgdCode,
  867. "bkcode"=>$bk_code,
  868. "wsm_code"=>$wsm_code,
  869. "cgder"=>$good['creater'],
  870. "cgder_id"=>$good['createrid'],
  871. "spuCode"=>$info['spuCode'],
  872. "good_name"=>$info['good_name'],
  873. "good_num"=>$info['good_num'],
  874. "good_price"=>$sale_price,
  875. "total_fee"=>$total_price,
  876. "pakge_fee"=>isset($goodnake['package_fee'])? $goodnake['package_fee']:0,
  877. "cert_fee"=>isset($goodnake['cert_fee'])? $goodnake['cert_fee']:0,
  878. "open_fee"=>$good['open_fee'],
  879. "delivery_fee"=>isset($goodnake['delivery_fee'])? $goodnake['delivery_fee']:0,
  880. "mark_fee"=>isset($goodnake['mark_fee'])? $goodnake['mark_fee']:0,
  881. "nake_fee"=>isset($goodnake['nake_fee'])? $goodnake['nake_fee']:0,
  882. "teach_fee"=>isset($goodnake['cost_fee'])? $goodnake['cost_fee']:0,
  883. "demo_fee"=>$good['demo_fee'],
  884. "diff_weight"=>"0",
  885. "diff_fee"=>"0",
  886. "gold_price"=>"0",
  887. "supplierNo"=>$info['supplierNo'],
  888. "supplier_name"=>$supplier['name'],
  889. "companyNo"=>$info['companyNo'],
  890. "send_status"=>1,
  891. "send_num"=>"0",
  892. "wsend_num"=>$info['good_num'],
  893. "weight"=>$good['noble_weight'],
  894. "remark"=>"",
  895. "status"=>0,//0表示初始化
  896. "lasttime"=>$info['lasttime'],
  897. "is_del"=>0,
  898. "order_type" => 1,//1备库
  899. "order_source" => 0,//0备库下单
  900. "good_type"=>1,
  901. "addtime"=>date("Y-m-d H:i:s"),
  902. "updatetime"=>date("Y-m-d H:i:s"),
  903. 'good_createrid' => $good['createrid'],
  904. 'good_creater' => $good['creater'],//商品创建人
  905. ];
  906. Db::startTrans();
  907. try{
  908. $up =Db::name("purchease_order")->insert($cg,true);
  909. if($up>0){
  910. $good = Db::name("good_stock")->where(["wsm_code" =>$wsm_code, "spuCode" => $info['spuCode'], "is_del" => 0])->find();
  911. if ($good == false) {
  912. $good = [
  913. "spuCode" => $info['spuCode'],
  914. "wsm_code" => $wsm_code,
  915. "usable_stock" => 0,
  916. "wait_out_stock" => 0,
  917. "wait_in_stock" => 0,
  918. "total_stock" => 0,
  919. "addtime" => date("Y-m-d H:i:s"),
  920. "updatetime" => date("Y-m-d H:i:s"),
  921. ];
  922. $order = ["order_code" => $info['spuCode'], "status" => 1, "action_remark" => '', "action_type" => "create"];
  923. } else {
  924. $order = ["order_code" => $info['spuCode'], "status" => 1, "action_remark" => '', "action_type" => "edit"];
  925. }
  926. $good['wait_in_stock'] += $info['good_num'];
  927. $good['updatetime'] = date("Y-m-d H:i:s");
  928. $upd = Db::name("good_stock")->save($good);
  929. $good_data[] = ['good_log_code' => $cgdCode,"stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1,
  930. 'stock' => $info['good_num'], "stock_name" => "wait_in_stock"];
  931. if ($upd) {
  932. // 商品变动日志表,good_log_code字段存储采购单号
  933. $order = ["order_code" => $cgdCode, "status" => 0, "action_remark" => '', "action_type" => "create"];
  934. GoodLog::LogAdd($this->post['token'], $good_data, 'CGD');
  935. ActionLog::logAdd($this->post['token'], $order, "CGD", 0, $good);
  936. $process = ["order_code" => $cgdCode, "order_id" => $up, "order_status" => $cg['status'], "order_type" => 'CGD',"before_status"=>0,'holder_id'=>$supplier['personid'],'wait_id'=>$supplier['personid'],'wait_name'=>$supplier['person']];
  937. ProcessOrder::AddProcess($this->post['token'], $process);
  938. $info['wsm_code'] = $wsm_code;
  939. $old_info_status = $info['status'];
  940. $info['status'] = 2;
  941. $info['updatetime'] = date("Y-m-d H:i:s");
  942. $bas = Db::name("purchease")->save($info);
  943. if ($bas) {
  944. //修改状态,添加待办
  945. ActionLog::logAdd($this->post['token'], [
  946. "order_code" => $info['bk_code'],//销售单code
  947. "status" => $old_info_status,//这里的status是之前的值
  948. "action_remark" => '',//备注
  949. "action_type" => "edit"//新建create,编辑edit,更改状态status
  950. ], "BHD", $info['status'], $info);
  951. ProcessOrder::AddProcess($this->post['token'], [
  952. "order_type" => 'BHD',
  953. "order_code" => $info['bk_code'],//销售单code
  954. "order_id" => $info['id'],
  955. "order_status" => $info['status'],
  956. "before_status"=> $old_info_status,
  957. 'holder_id' => $info['apply_id']
  958. ]);
  959. //维护台账记录
  960. Db::name('standing_book')->where('bk_code', $bk_code)->update([
  961. 'spuCode' => $cg['spuCode'],
  962. 'order_type' => $cg['order_type'],
  963. 'order_source' => $cg['order_source'],
  964. 'supplierNo' => $cg['supplierNo'],
  965. 'companyNo' => $cg['companyNo'],
  966. 'cgdNo' => $cg['cgdNo'],
  967. 'updatetime' => date('Y-m-d H:i:s'),
  968. ]);
  969. //将采购单数据塞入到队列中
  970. $push_data = json_encode([
  971. 'supplierNo' => $cg['supplierNo'],
  972. 'type' => 1,//1销售订单(采销的采购单),2上线结果
  973. 'data' => [
  974. 'cgdNo' => $cg['cgdNo'],
  975. 'spuCode' => $cg['spuCode'],
  976. 'good_name' => $cg['good_name'],
  977. 'good_num' => $cg['good_num'],
  978. 'good_price' => $cg['good_price'],
  979. 'total_fee' => $cg['total_fee'],
  980. 'weight' => $cg['weight'],
  981. 'addtime' => $cg['addtime'],
  982. ],
  983. ], JSON_UNESCAPED_UNICODE);
  984. // Cache::store("redis")->handler()->lPush(Config::get('app.abutment_queue'), $push_data);
  985. Db::commit();
  986. return app_show(0, "采购单新建成功", ["cgdNo" => $cgdCode]);
  987. }
  988. }
  989. // }
  990. }
  991. Db::rollback();
  992. return error_show(1004,"采购单新建失败");
  993. }catch (\Exception $e){
  994. Db::rollback();
  995. return error_show(1004,$e->getMessage());
  996. }
  997. }
  998. }