Purchin.php 57 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ActionLog;
  4. use app\admin\model\GoodLog;
  5. use app\admin\model\ProcessOrder;
  6. use app\BaseController;
  7. use think\facade\Db;
  8. use think\App;
  9. //采购单入库
  10. class Purchin extends Base
  11. {
  12. public function __construct(App $app)
  13. {
  14. parent::__construct($app);
  15. // $this->post=$this->request->post();
  16. }
  17. public function list(){
  18. $page = isset($this->post['page']) && $this->post['page'] !==""? intval($this->post['page']):"1";
  19. $size = isset($this->post['size']) && $this->post['size'] !==""? intval($this->post['size']):"10";
  20. $where =[['a.is_del',"=",0],['b.is_del',"=",0]];
  21. $wsm_in_code=isset($this->post['wsm_in_code']) && $this->post['wsm_in_code']!==""? trim($this->post['wsm_in_code']) :"";
  22. if($wsm_in_code!=""){
  23. $where[]=["a.wsm_in_code",'like',"%$wsm_in_code%"];
  24. }
  25. $cgdNo= isset($this->post['cgdNo']) && $this->post['cgdNo'] !==""? trim($this->post['cgdNo']) :"";
  26. if($cgdNo!=""){
  27. $where[]=['a.cgdNo','like',"%$cgdNo%"];
  28. }
  29. $apply_name = isset($this->post['apply_name']) && $this->post['apply_name'] !==""? trim($this->post['apply_name']):"";
  30. if($apply_name!=""){
  31. $where[]=['a.apply_name','like',"%$apply_name%"];
  32. }
  33. $apply_id= isset($this->post['apply_id']) && $this->post['apply_id'] !==""? trim($this->post['apply_id']):"";
  34. if($apply_id!=""){
  35. $where[]=['a.apply_id','=',$apply_id];
  36. }
  37. $status= isset($this->post['status']) && $this->post['status'] !==""? trim($this->post['status']):"";
  38. if($status!=""){
  39. $where[]=['a.status','=',$status];
  40. }
  41. $start= isset($this->post['start']) && $this->post['start'] !== "" ? $this->post['start']:"";
  42. if ($start !="") {
  43. $where[]= ["a.sendtime",'>=',$start];
  44. }
  45. $end = isset($this->post['end']) && $this->post['end'] !== "" ? $this->post['end'] :"";
  46. if($end !=""){
  47. $where[]= ["a.sendtime",'<=',$end];
  48. }
  49. $order_type=isset($this->post['order_type']) && $this->post['order_type']!==""? intval($this->post['order_type']):"";
  50. if($order_type !=""){
  51. $where[]= ["b.order_type",'=',$order_type];
  52. }
  53. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  54. if($good_type_code !=""){
  55. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  56. }
  57. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  58. if($good_name !=""){
  59. $where[]= ["b.good_name",'like',"%$good_name%"];
  60. }
  61. $supplie=isset($this->post['supplier']) && $this->post['supplier']!==""? trim($this->post['supplier']):"";
  62. if($supplie !=""){
  63. $where[]= ["b.supplierNo",'like',"%$supplie%"];
  64. }
  65. $wsm_code=isset($this->post['wsm_code']) && $this->post['wsm_code']!==""? trim($this->post['wsm_code']):"";
  66. if($wsm_code !=""){
  67. $where[]= ["a.wsm_code",'=',$wsm_code];
  68. }
  69. $supplierNo =isset($this->post['supplierNo']) &&$this->post['supplierNo'] !=="" ? trim($this->post['supplierNo']):"";
  70. if($supplierNo!=""){
  71. $supplier = Db::name("supplier")->where(["code"=>$supplierNo])->find();
  72. if(empty($supplier)){
  73. return error_show(1004,"未找到供应商信息");
  74. }
  75. $wsmcode = Db::name("warehouse_info")->where([
  76. "is_del"=>0,"supplierNo"=>$supplierNo])->column("wsm_code");
  77. $where[]=['a.wsm_code',"in",$wsmcode];
  78. }
  79. $role=$this->checkRole();
  80. if(!empty($role['write'])){
  81. $where[]=["apply_id","in",$role['write']];
  82. }
  83. $count = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  84. ->where($where)->count();
  85. $total = ceil($count/$size);
  86. $page = $page >= $total ? $total : $page;
  87. $list = Db::name('purchease_in')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  88. ->where($where)->page($page,$size)
  89. ->field("a.apply_name,a.sendtime,b.order_type,a.status,a.cgdNo,a.wsm_in_code,a.send_num,a.wsm_code,b.good_name,b.spuCode,
  90. a.post_company,a.post_code,a.post_fee,a.apply_id,a.wsm_num,a.error_num,a.wait_num,a.status,a.check_name,a.checkid,b.bkcode,b.supplierNo")
  91. ->order("a.addtime desc")->select();
  92. $data=[];
  93. foreach ($list as $value){
  94. //获取规格、品牌信息
  95. if ($value['order_type'] == 3 || $value['order_type'] == 4) {
  96. $temp = Db::name('good_zixun')
  97. ->alias('gz')
  98. ->field('gz.specinfo,b.brand_name')
  99. ->join('brand b', 'b.id=gz.brand_id')
  100. ->where(['gz.spuCode' => $value['spuCode'], 'gz.is_del' => 0])
  101. ->find();
  102. $value["brand_name"] = $temp['brand_name'];
  103. $value["speclist"] = json_decode($temp['specinfo'], true);
  104. } else {
  105. $value['brand_name'] = Db::name('good_basic')
  106. ->alias('gb')
  107. ->join('brand b', 'b.id=gb.brand_id')
  108. ->where(['gb.spuCode' => $value['spuCode']])
  109. ->value('b.brand_name');
  110. $spec = Db::name("good_spec")
  111. ->where(["spuCode" => $value['spuCode'], "is_del" => 0])
  112. ->select()
  113. ->toArray();
  114. $speclist = [];
  115. if (!empty($spec)) {
  116. foreach ($spec as $val) {
  117. $temp = [];
  118. $temp['id'] = $val['id'];
  119. $temp['spuCode'] = $val['spuCode'];
  120. $temp['spec_id'] = $val['spec_id'];
  121. $temp['spec_value_id'] = $val['spec_value_id'];
  122. $sp = Db::name("specs")->where(["id" => $val['spec_id']])->find();
  123. $temp['spec_name'] = isset($sp["spec_name"]) ? $sp["spec_name"] : "";
  124. $spv = Db::name("spec_value")->where(["id" => $val['spec_value_id']])->find();
  125. $temp['spec_value'] = isset($spv["spec_value"]) ? $spv["spec_value"] : "";
  126. $speclist[] = $temp;
  127. }
  128. }
  129. $value["speclist"] = empty($speclist) ? [] : $speclist;
  130. }
  131. $wsmcode = Db::name("warehouse_info")->alias("k")->leftJoin("supplier c","k.supplierNo=c.code")
  132. ->where(["k.wsm_code"=>$value['wsm_code']])->field("k.name as wsm_name,c.name,c.code")->find();
  133. $value['wsm_name'] = $wsmcode['wsm_name'];
  134. $value['wsm_supplier'] = $wsmcode['name'];
  135. $value['wsm_supplierNo'] = $wsmcode['code'];
  136. $data[]=$value;
  137. }
  138. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  139. }
  140. public function add(){
  141. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!=""? trim($this->post['cgdNo']):"";
  142. if($cgdNo==""){
  143. return error_show(1005,"参数cgdNo 不能为空");
  144. }
  145. $cgdinfo = Db::name("purchease_order")->where(['cgdNo'=>$cgdNo,'is_del'=>0])->find();
  146. if(empty($cgdinfo)){
  147. return error_show(1005,"未找到采购单数据");
  148. }
  149. if($cgdinfo['status']==0){
  150. return error_show(1005,"采购单未发货");
  151. }
  152. $wsm_in_code = makeNo("CF");
  153. // $wsm_code = isset($this->post['wsm_code'])&&$this->post['wsm_code']!="" ? trim($this->post['wsm_code']):"";
  154. // if($wsm_code==""){
  155. // return error_show(1004,"参数 wsm_code 不能为空");
  156. // }
  157. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  158. if(empty($wsminfo)){
  159. return error_show(1004,"未找到仓库信息");
  160. }
  161. $recep = Db::name('warehouse_addr')->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  162. $sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
  163. if($sendtype==""){
  164. return error_show(1004,"参数 sendtype 不能为空");
  165. }
  166. $data = GetUserInfo($this->post['token']);
  167. if((!empty($data) && $data['code']!=0) ||empty($data) ){
  168. return error_show($data['code'],$data['message']);
  169. }
  170. $userinfo = $data['data'];
  171. $post_company = isset($this->post['post_company'])&&$this->post['post_company']!="" ? trim($this->post['post_company']):"";
  172. $post_code = isset($this->post['post_code'])&&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
  173. $post_fee = isset($this->post['post_fee'])&&$this->post['post_fee']!="" ? $this->post['post_fee']:"0";
  174. $post_time = isset($this->post['post_time'])&&$this->post['post_time']!="" ? $this->post['post_time']:date("Y-m-d H:i:s");
  175. $send_num = isset($this->post['send_num'])&&$this->post['send_num']!="" ? intval($this->post['send_num']):"";
  176. $status = isset($this->post['status'])&&$this->post['status']!="" ? intval($this->post['status']):"1 ";
  177. if($send_num==''){
  178. return error_show(1004,"参数 send_num 不能为空或零");
  179. }
  180. if($send_num>$cgdinfo['wsend_num']){
  181. return error_show(1009,"采购单剩余未发货数量不足");
  182. }
  183. // if($cgdinfo['order_type']==1||$cgdinfo['order_type']==2 ){
  184. // $goodinfo = Db::name("good_basic")->where(["spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  185. // if($goodinfo==false){
  186. // return error_show(1004,"商品数据未找到");
  187. // }
  188. // if($goodinfo['is_stock']==0){
  189. // $status=4;
  190. // }
  191. // } else {
  192. // $send_way = Db::name("good_zixun")->where(["spuCode" => $cgdinfo['spuCode'], "is_del" => 0])->value('send_way');
  193. // if ($send_way) $status = 4;
  194. // }
  195. if($sendtype==2 || $cgdinfo['order_type']!=1){
  196. $status=4;
  197. }
  198. $orin = [
  199. "wsm_in_code"=>$wsm_in_code,
  200. "cgdNo"=>$cgdNo,
  201. "wsm_code"=>$cgdinfo['wsm_code'],
  202. "wsm_reaper"=>isset($recep)&& $recep['wsm_name']!=''? $recep['wsm_name']:"",
  203. "send_num"=>$send_num,
  204. "post_company"=>$post_company,
  205. "post_code"=>$post_code,
  206. "post_fee"=>$post_fee,
  207. "sendtime"=>$post_time,
  208. "apply_id"=>$userinfo['id'],
  209. "apply_name"=>$userinfo['nickname'],
  210. "wait_num"=>0,
  211. "sendtype"=>$sendtype,
  212. "status"=>$status,
  213. "addtime"=>date("Y-m-d H:i:s"),
  214. "updatetime"=>date("Y-m-d H:i:s")
  215. ];
  216. Db::startTrans();
  217. try{
  218. $win = Db::name("purchease_in")->insert($orin,true);
  219. if($win){
  220. $sto = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"edit"];
  221. ActionLog::logAdd($this->post['token'],$sto,"RKD",$status,$this->post);
  222. $process=["order_code"=>$wsm_in_code,"order_id"=>$win,"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$status];
  223. ProcessOrder::AddProcess($this->post['token'],$process);
  224. $order = ["order_code"=>$cgdNo,"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  225. if($status==1){
  226. $cgdinfo['wsend_num']-=$send_num;
  227. $cgdinfo['send_num']+=$send_num;
  228. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  229. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  230. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  231. $up=Db::name("purchease_order")->save($cgdinfo);
  232. if($up){
  233. if($cgdinfo['order_type']!=1){
  234. $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  235. if(empty($good)) {
  236. $good=[
  237. "spuCode"=>$cgdinfo['spuCode'],
  238. "wsm_code"=>$cgdinfo['wsm_code'],
  239. "usable_stock"=>0,
  240. "wait_out_stock"=>0,
  241. "wait_in_stock"=>0,
  242. "total_stock"=>0,
  243. "addtime"=>date("Y-m-d H:i:s"),
  244. "updatetime"=>date("Y-m-d H:i:s"),
  245. ];
  246. // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  247. // "action_type"=>"create"];
  248. }else{
  249. // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  250. // "action_type"=>"edit"];
  251. }
  252. $good['wait_in_stock']+=$send_num;
  253. $good['updatetime'] = date("Y-m-d H:i:s");
  254. $upd= Db::name("good_stock")->save($good);
  255. if($upd==false){
  256. Db::rollback();
  257. return error_show(1004,"新建失败");
  258. }
  259. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  260. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  261. }
  262. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  263. $process=["order_code"=>$cgdNo,"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  264. ProcessOrder::AddProcess($this->post['token'],$process);
  265. Db::commit();
  266. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  267. }else{
  268. Db::rollback();
  269. return error_show(1004,"新建失败");
  270. }
  271. }
  272. if($status==4){
  273. $cgdinfo['wsend_num']-=$send_num;
  274. $cgdinfo['send_num']+=$send_num;
  275. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  276. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  277. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  278. $up=Db::name("purchease_order")->save($cgdinfo);
  279. if($up==false){
  280. Db::rollback();
  281. return error_show(1004,"新建失败");
  282. }
  283. $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  284. if(empty($good)) {
  285. $good=[
  286. "spuCode"=>$cgdinfo['spuCode'],
  287. "wsm_code"=>$cgdinfo['wsm_code'],
  288. "usable_stock"=>0,
  289. "wait_out_stock"=>0,
  290. "wait_in_stock"=>$send_num,
  291. "total_stock"=>0,
  292. "addtime"=>date("Y-m-d H:i:s"),
  293. "updatetime"=>date("Y-m-d H:i:s"),
  294. ];
  295. // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  296. // "action_type"=>"create"];
  297. }else{
  298. // $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  299. // "action_type"=>"edit"];
  300. }
  301. $good['wait_in_stock']-=$send_num;
  302. $good['usable_stock']+=$send_num;
  303. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  304. $good['updatetime'] = date("Y-m-d H:i:s");
  305. $upd= Db::name("good_stock")->save($good);
  306. //商品变动日志表,good_log_code字段存储采购单单号
  307. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  308. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>2,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  309. if($upd){
  310. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  311. if($cgdinfo['order_type']==1){
  312. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  313. if($bk==false){
  314. $bk=[
  315. "cgdNo"=>$cgdinfo['cgdNo'],
  316. "spuCode"=>$cgdinfo['spuCode'],
  317. "companyNo"=>$cgdinfo['companyNo'],
  318. "total_num"=>0,
  319. "merge_num"=>0,
  320. "balance_num"=>0,
  321. "status"=>1,
  322. "is_del"=>0,
  323. 'addtime'=>date("Y-m-d H:i:s"),
  324. "updatetime"=>date("Y-m-d H:i:s")
  325. ];
  326. }
  327. $bk['balance_num']+=$send_num;
  328. $bk['total_num']+=$send_num;
  329. $bk['updatetime']=date("Y-m-d H:i:s");
  330. $upcgd =Db::name("order_bk")->save($bk);
  331. if($upcgd==false){
  332. Db::rollback();
  333. return error_show(1004,"采购单数量更新失败");
  334. }
  335. }
  336. if($cgdinfo['send_status']==3 && $cgdinfo['order_type']!=1){
  337. $send=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"status"=>1])->column("outCode");
  338. if(!empty($send)){
  339. $out =Db::name("order_out")->where(["outCode"=>$send,"status"=>0])->select()
  340. ->toArray();
  341. if(!empty($out)){
  342. $up =Db::name("order_out")->where(["outCode"=>$send,"status"=>0])->update
  343. (["status"=>1,'wsm_code'=>$cgdinfo['wsm_code'],"updatetime"=>date('Y-m-d H:i:s')]);
  344. if($up==false){
  345. Db::rollback();
  346. return error_show(1004,"出库单出库失败");
  347. }else{
  348. foreach ($out as $k => $v_outCode) {
  349. //修改状态,添加待办
  350. ActionLog::logAdd($this->post['token'], [
  351. "order_code" => $v_outCode['outCode'],//出库单号
  352. "status" => 0,//这里的status是之前的值
  353. "action_remark" => '',//备注
  354. "action_type" => "status"//新建create,编辑edit,更改状态status
  355. ], "CKD", 1, $this->post);
  356. ProcessOrder::AddProcess($this->post['token'], [
  357. "order_type" => 'CKD',
  358. "order_code" => $v_outCode['outCode'],//出库单号
  359. "order_id" => $v_outCode['id'],
  360. "order_status" => 1,"before_status"=>0
  361. ]);
  362. }
  363. }
  364. $good1 = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  365. if($good1==false){
  366. Db::rollback();
  367. return error_show(1004,"未找到对应商品库存");
  368. }
  369. $out_num = intval(array_sum(array_column($out,"send_num")));
  370. if($out_num>$good1['usable_stock']){
  371. Db::rollback();
  372. return error_show(1004,"库存数量不足发货");
  373. }
  374. $good1['usable_stock']-=$out_num;
  375. $good1['wait_out_stock']+=$out_num;
  376. $good1['total_stock']=$good1['usable_stock']+$good1['wait_out_stock'];
  377. $good1['updatetime'] = date("Y-m-d H:i:s");
  378. $upd= Db::name("good_stock")->save($good1);
  379. if($upd==false){
  380. Db::rollback();
  381. return error_show(1004,"库存数量更新失败");
  382. }
  383. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_out_stock"];
  384. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  385. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  386. $sendp=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"outCode"=>$send,"status"=>1])->save (["status"=>2]);
  387. if($sendp==false){
  388. Db::rollback();
  389. return error_show(1004,"库存发货失败");
  390. }
  391. }
  392. }
  393. }
  394. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  395. $process=["order_code"=>$cgdNo,"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  396. ProcessOrder::AddProcess($this->post['token'],$process);
  397. Db::commit();
  398. return app_show(0,'商品入库成功',["wsm_in_code"=>$wsm_in_code]);
  399. }else{
  400. Db::rollback();
  401. return error_show(1002,"商品入库失败");
  402. }
  403. }
  404. Db::commit();
  405. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  406. }
  407. Db::rollback();
  408. return error_show(1004,"新建失败");
  409. }catch (\Exception $e){
  410. Db::rollback();
  411. return error_show(1004, $e->getMessage() . '|' . $e->getFile() . '|' . $e->getLine());
  412. }
  413. }
  414. public function info(){
  415. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  416. if($incode==""){
  417. return error_show(1004,"参数wsm_in_code 不为空");
  418. }
  419. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  420. if(empty($info)){
  421. return error_show(1004,"未找到数据");
  422. }
  423. $dom = Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],'is_del'=>0])->find();
  424. if($dom['order_type']==3|| $dom['order_type']==4){
  425. $goon = Db::name("good_zixun")->where(["spuCode"=>$dom['spuCode'],"is_del"=>0])->find();
  426. }else {
  427. $goon =Db::name('good_basic')->where(['spuCode'=>$dom['spuCode']])->find();
  428. }
  429. if(empty($goon)){
  430. return error_show(1002,"未找到商品数据");
  431. }
  432. $cat= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  433. $info['cgder']=$dom['cgder'];
  434. $info['spuCode']=$dom['spuCode'];
  435. $info['good_name']=$dom['good_name'];
  436. $info['skuCode']=$dom['skuCode'];
  437. $info['good_num']=$dom['good_num'];
  438. $info['good_price']=$dom['good_price'];
  439. $info['total_fee']=$dom['total_fee'];
  440. $info['diff_fee']=$dom['diff_fee'];
  441. $info['diff_weight']=$dom['diff_weight'];
  442. $info['gold_price']=$dom['gold_price'];
  443. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  444. ->leftJoin("warehouse_addr c","a.wsm_code=c.wsm_code and c.is_del=0")
  445. ->where(["a.wsm_code"=>$info['wsm_code']])->field("a.name as wsm_name,b.name,b.code,c.wsm_name as wsm_contactor,c.wsm_mobile,c.wsm_addr,c.addr_code")->find();
  446. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  447. $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  448. $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  449. $info['wsm_contactor'] =isset($wsmcode['wsm_contactor']) ? $wsmcode['wsm_contactor']:"";
  450. $info['wsm_mobile'] =isset($wsmcode['wsm_mobile']) ? $wsmcode['wsm_mobile']:"";
  451. $info['addr_code'] =isset($wsmcode['addr_code']) ? $wsmcode['addr_code']:"";
  452. $info['wsm_addr'] =isset($wsmcode['addr_code']) ? GetAddr($wsmcode['addr_code']):"";
  453. $info['wsm_addr'].=isset($wsmcode['wsm_addr']) ? $wsmcode['wsm_addr']:"";
  454. $check = Db::name("purchease_info")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")->where
  455. (['wsm_in_code'=>$incode,"a.is_del"=>0])->field("a.id,a.wsm_in_code,a.num,a.error_code,b.result as error_msg,a.error_img,remark,a.is_del")->select();
  456. $info['checkinfo']= $check;
  457. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  458. $return['return_contactor']=isset($return['return_contactor'])&&$return['return_contactor']!="" ?$return['return_contactor']:'';
  459. $return['return_addr']=isset($return['return_addr'])&&$return['return_addr']!="" ?$return['return_addr']:'';
  460. $return['return_mobile']=isset($return['return_mobile'])&&$return['return_mobile']!="" ?$return['return_mobile']:'';
  461. //以下字段临时补充到return中
  462. $return['wsm_in_code'] = $incode;
  463. $return['wsm_num'] = isset($return['wsm_num']) ? $return['wsm_num'] : 0;
  464. $return['reissue_num'] = isset($return['reissue_num']) ? $return['reissue_num'] : 0;
  465. $return['return_num'] = isset($return['return_num']) ? $return['return_num'] : 0;
  466. $return['contactor'] = $return['return_contactor'];
  467. $return['addr'] = $return['return_addr'];
  468. $return['mobile'] = $return['return_mobile'];
  469. $return['error_remark'] = isset($return['error_remark']) ? $return['error_remark'] : '';
  470. $return['remark'] = isset($return['remark']) ? $return['remark'] : '';
  471. $info['return']= $return;
  472. $info['can']=$cat;
  473. if(isset($dom['companyNo'])&&$dom['companyNo']!=""){
  474. $company = Db::name("business")->where(["companyNo"=>$dom['companyNo']])->find();
  475. }
  476. $info['company'] = isset($company['company'])?$company['company']:"";
  477. $info['companyNo'] = isset($dom['companyNo'])?$dom['companyNo']:"";
  478. $info['order_type'] = isset($dom['order_type'])?$dom['order_type']:"";
  479. return app_show(0,'获取成功',$info);
  480. }
  481. public function check(){
  482. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  483. if($incode==""){
  484. return error_show(1004,"参数wsm_in_code 不为空");
  485. }
  486. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  487. if(empty($info)){
  488. return error_show(1004,"未找到数据");
  489. }
  490. if($info['status']!=1){
  491. return error_show(1004,"发货单状态有误");
  492. }
  493. $order_num = isset($this->post['order_num']) && $this->post['order_num']!==''?intval($this->post['order_num'])
  494. :"";
  495. if($order_num===""){
  496. return error_show(1004,"参数 order_num 不为空");
  497. }
  498. $error_list = isset($this->post['error_list']) && $this->post['error_list']!==''?$this->post['error_list']:"";
  499. $result = GetUserInfo($this->post['token']);
  500. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  501. return error_show($result['code'],$result['message']);
  502. }
  503. $userinfo = $result['data'];
  504. Db::startTrans();
  505. try{
  506. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  507. $info['wsm_num'] = $order_num;
  508. $info['wait_num'] = $info['send_num'];
  509. $info['checkid'] = $userinfo['id'];
  510. $info['check_name'] = $userinfo['nickname'];
  511. $info['status'] =2;
  512. $info['error_num'] = $info['send_num']-$order_num;
  513. $info['updatetime'] = date("Y-m-d H:i:s");
  514. $up =Db::name("purchease_in")->save($info);
  515. if($up){
  516. ActionLog::logAdd($this->post['token'],$order,"RKD",2,$this->post);
  517. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$order['status']];
  518. ProcessOrder::AddProcess($this->post['token'],$process);
  519. if(!empty($error_list)){
  520. $data=[];
  521. foreach ($error_list as $value ){
  522. $temp=[];
  523. $temp['wsm_in_code']=$info['wsm_in_code'];
  524. $temp['num']=$value['num'];
  525. $temp['error_code']=$value['error_code'];
  526. $temp['error_img']=$value['error_img'];
  527. $temp['remark']=$value['remark'];
  528. $temp['is_del']=0;
  529. $temp['addtime']=date("Y-m-d H:i:s");
  530. $temp['updatetime']=date("Y-m-d H:i:s");
  531. $data[]=$temp;
  532. }
  533. $derr= Db::name("purchease_info")->insertAll($data);
  534. if($derr){
  535. Db::commit();
  536. return app_show(0,"验货完成");
  537. }else{
  538. Db::rollback();
  539. return error_show(1002,"验货数据保存失败");
  540. }
  541. }
  542. Db::commit();
  543. return app_show(0,"验货完成");
  544. }
  545. Db::rollback();
  546. return error_show(1002,"验货数据保存失败");
  547. }catch (\Exception $e){
  548. Db::rollback();
  549. return error_show(1002,$e->getMessage());
  550. }
  551. }
  552. public function status(){
  553. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  554. if($incode==""){
  555. return error_show(1004,"参数wsm_in_code 不为空");
  556. }
  557. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  558. if(empty($info)){
  559. return error_show(1004,"未找到数据");
  560. }
  561. $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  562. if($status===""){
  563. return error_show(1004,"参数status 不为空");
  564. }
  565. if($info['status']==4){
  566. return error_show(1004,"入库单已完成");
  567. }
  568. $remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']) :"";
  569. Db::startTrans();
  570. try{
  571. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"status"];
  572. $info['status'] = $status;
  573. $info['remark'] = $remark;
  574. $info['updatetime'] = date("Y-m-d H:i:s");
  575. $update = Db::name("purchease_in")->save($info);
  576. if($update){
  577. ActionLog::logAdd($this->post['token'],$order,"RKD",$status,$this->post);
  578. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$order['status']];
  579. ProcessOrder::AddProcess($this->post['token'],$process);
  580. if($status==0){
  581. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  582. if(empty($cgdinfo)){
  583. Db::rollback();
  584. return error_show(1002,"未找到采购单数据");
  585. }
  586. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  587. $cgdinfo['wsend_num']+=$info['send_num'];
  588. $cgdinfo['send_num']-=$info['send_num'];
  589. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  590. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  591. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  592. $up=Db::name("purchease_order")->save($cgdinfo);
  593. if($up){
  594. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  595. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  596. ProcessOrder::AddProcess($this->post['token'],$process);
  597. Db::commit();
  598. return app_show(0,'取消成功');
  599. }else{
  600. Db::rollback();
  601. return error_show(1002,"取消失败");
  602. }
  603. }
  604. if($status==1){
  605. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  606. if(empty($cgdinfo)){
  607. Db::rollback();
  608. return error_show(1002,"未找到采购单数据");
  609. }
  610. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  611. $cgdinfo['wsend_num']-=$info['send_num'];
  612. $cgdinfo['send_num']+=$info['send_num'];
  613. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  614. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  615. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  616. $up=Db::name("purchease_order")->save($cgdinfo);
  617. if($up){
  618. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  619. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  620. ProcessOrder::AddProcess($this->post['token'],$process);
  621. Db::commit();
  622. return app_show(0,'发货成功');
  623. }else{
  624. Db::rollback();
  625. return error_show(1002,"发货失败");
  626. }
  627. }
  628. if($status==4){
  629. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  630. if(empty($cgdinfo)){
  631. Db::rollback();
  632. return error_show(1002,"未找到采购单数据");
  633. }
  634. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  635. if(empty($good)) {
  636. $good=[
  637. "spuCode"=>$cgdinfo['spuCode'],
  638. "wsm_code"=>$info['wsm_code'],
  639. "usable_stock"=>0,
  640. "wait_out_stock"=>0,
  641. "wait_in_stock"=>$info['wsm_num'],
  642. "total_stock"=>0,
  643. "addtime"=>date("Y-m-d H:i:s"),
  644. "updatetime"=>date("Y-m-d H:i:s"),
  645. ];
  646. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  647. "action_type"=>"create"];
  648. }else{
  649. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  650. }
  651. $good['usable_stock']+=$info['wsm_num'];
  652. $good['wait_in_stock']-=$info['wsm_num'];
  653. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  654. $good['updatetime'] = date("Y-m-d H:i:s");
  655. $upd= Db::name("good_stock")->save($good);
  656. //商品变动日志表,good_log_code字段存储入库单编号
  657. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] : Db::name("good_stock")->getLastInsID(), "type" => 1, 'stock' => $info['wsm_num'], "stock_name" => "usable_stock"];
  658. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] :
  659. Db::name("good_stock")->getLastInsID(), "type" => 2, 'stock' => $info['wsm_num'], "stock_name" => "wait_in_stock"];
  660. if($upd){
  661. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  662. Db::commit();
  663. return app_show(0,'商品入库成功');
  664. }else{
  665. Db::rollback();
  666. return error_show(1002,"商品入库失败");
  667. }
  668. }
  669. Db::commit();
  670. return app_show(0,"状态修改完成");
  671. }
  672. Db::rollback();
  673. return error_show(1002,"状态修改失败");
  674. }catch (\Exception $e){
  675. Db::rollback();
  676. return error_show(1002,$e->getMessage());
  677. }
  678. }
  679. /**
  680. * @return \think\response\Json|void
  681. * @throws \think\db\exception\DataNotFoundException
  682. * @throws \think\db\exception\DbException
  683. * @throws \think\db\exception\ModelNotFoundException
  684. */
  685. public function ReturnAdd(){
  686. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  687. if($incode==""){
  688. return error_show(1004,"参数wsm_in_code 不为空");
  689. }
  690. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  691. if(empty($info)){
  692. return error_show(1004,"未找到数据");
  693. }
  694. //正常入库数量
  695. $wsm_num = isset($this->post['wsm_num']) &&$this->post['wsm_num']!=="" ? intval($this->post['wsm_num']):"" ;
  696. if($wsm_num===""){
  697. return error_show(1004,"参数wsm_num 不为空");
  698. }
  699. //补货数量
  700. $reissue_num = isset($this->post['reissue_num']) &&$this->post['reissue_num']!=="" ? intval($this->post['reissue_num']):"0" ;
  701. //退货数量
  702. $return_num = isset($this->post['return_num']) &&$this->post['return_num']!=="" ? intval($this->post['return_num']):"0" ;
  703. $contactor = isset($this->post['contactor']) &&$this->post['contactor']!=="" ? trim($this->post['contactor']):"" ;
  704. if($contactor==""){
  705. return error_show(1004,"参数contactor 不为空");
  706. }
  707. $addr = isset($this->post['addr']) &&$this->post['addr']!=="" ? trim($this->post['addr']):"" ;
  708. if($addr==""){
  709. return error_show(1004,"参数addr 不为空");
  710. }
  711. $mobile = isset($this->post['mobile']) &&$this->post['mobile']!=="" ? trim($this->post['mobile']):"" ;
  712. if($mobile==""){
  713. return error_show(1004,"参数mobile 不为空");
  714. }
  715. $error_remark = isset($this->post['error_remark']) &&$this->post['error_remark']!=="" ? trim($this->post['error_remark']):"" ;
  716. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  717. $result = GetUserInfo($this->post['token']);
  718. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  719. return error_show($result['code'],$result['message']);
  720. }
  721. $userinfo = $result['data'];
  722. Db::startTrans();
  723. try{
  724. $sto = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  725. // $info['status'] =$info['wsm_num']==$wsm_num ? 4 :5;
  726. $info['status'] = $info['send_num'] == $wsm_num ? 4 : 5;//艳蓉说,这里不能用入库数量比较,应该是用入库数量,即总数来比较
  727. $info['is_th'] =$return_num>0 ?1:0;
  728. $info['updatetime'] = date("Y-m-d H:i:s");
  729. $up= Db::name("purchease_in")->save($info);
  730. if($up){
  731. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  732. if(empty($cgdinfo)){
  733. Db::rollback();
  734. return error_show(1002,"未找到采购单数据");
  735. }
  736. if($info['status']==4){
  737. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  738. if(empty($good)) {
  739. $good=[
  740. "spuCode"=>$cgdinfo['spuCode'],
  741. "wsm_code"=>$info['wsm_code'],
  742. "usable_stock"=>0,
  743. "wait_out_stock"=>0,
  744. "wait_in_stock"=>$wsm_num,
  745. "total_stock"=>0,
  746. "addtime"=>date("Y-m-d H:i:s"),
  747. "updatetime"=>date("Y-m-d H:i:s"),
  748. ];
  749. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  750. "action_type"=>"create"];
  751. }else{
  752. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  753. }
  754. $good['usable_stock']+=$wsm_num;
  755. $good['wait_in_stock']-=$wsm_num;
  756. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  757. $good['updatetime'] = date("Y-m-d H:i:s");
  758. $upd= Db::name("good_stock")->save($good);
  759. if($upd==false){
  760. Db::rollback();
  761. return error_show(1002,"库存更新失败");
  762. }
  763. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  764. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>2, 'stock'=>$info['wsm_num'],"stock_name"=>"wait_in_stock"];
  765. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  766. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  767. if($bk==false){
  768. $bk=[
  769. "cgdNo"=>$cgdinfo['cgdNo'],
  770. "spuCode"=>$cgdinfo['spuCode'],
  771. "companyNo"=>$cgdinfo['companyNo'],
  772. "total_num"=>0,
  773. "merge_num"=>0,
  774. "balance_num"=>0,
  775. "status"=>1,
  776. "is_del"=>0,
  777. 'addtime'=>date("Y-m-d H:i:s"),
  778. "updatetime"=>date("Y-m-d H:i:s")
  779. ];
  780. }
  781. $bk['balance_num']+=$wsm_num;
  782. $bk['total_num']+=$wsm_num;
  783. $bk['updatetime']=date("Y-m-d H:i:s");
  784. $upcgd =Db::name("order_bk")->save($bk);
  785. if($upcgd==false){
  786. Db::rollback();
  787. return error_show(1004,"采购单数量更新失败");
  788. }
  789. }
  790. ActionLog::logAdd($this->post['token'],$sto,"RKD", $info['status'],$this->post);
  791. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$sto['status']];
  792. ProcessOrder::AddProcess($this->post['token'],$process);
  793. //需要在详情页把相关退货记录原样取出来,所以这里把if去掉,所有记录都入purchease_return表
  794. // if($info['status']==5){
  795. $data=[
  796. "wsm_in_code"=>$incode,
  797. "wsm_num"=>$wsm_num,
  798. "reissue_num"=>$reissue_num,
  799. "return_num"=>$return_num,
  800. "return_contactor"=>$contactor,
  801. "return_addr"=>$addr,
  802. "return_mobile"=>$mobile,
  803. "error_remark"=>$error_remark,
  804. "post_code"=>"",
  805. "post_company"=>"",
  806. "remark"=>$remark ,
  807. "apply_id"=>$userinfo['id'],
  808. "apply_name"=>$userinfo['nickname'],
  809. "status"=>0,
  810. "addtime"=>date("Y-m-d H:i:s"),
  811. "updatetime"=>date("Y-m-d H:i:s")
  812. ];
  813. $res = Db::name("purchease_return")->insert($data,true);
  814. if($res==false){
  815. Db::rollback();
  816. return error_show(1002,"验货审核失败");
  817. }
  818. $sto = ["order_code"=>$incode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  819. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",0,$data);
  820. // }
  821. Db::commit();
  822. return app_show(0,"验货审核完成");
  823. }
  824. }catch (\Exception $e){
  825. Db::rollback();
  826. return error_show(1002,$e->getMessage());
  827. }
  828. }
  829. public function ReturnSend(){
  830. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  831. if($incode==""){
  832. return error_show(1004,"参数wsm_in_code 不为空");
  833. }
  834. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  835. if(empty($info)){
  836. return error_show(1004,"未找到发货单数据");
  837. }
  838. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  839. if(empty($return)){
  840. return error_show(1004,"未找到退货单数据");
  841. }
  842. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  843. if(empty($cgdinfo)){
  844. Db::rollback();
  845. return error_show(1002,"未找到采购单数据");
  846. }
  847. $post_code = isset($this->post['post_code']) &&$this->post['post_code']!=="" ? trim($this->post['post_code']):"" ;
  848. if($post_code==""){
  849. return error_show(1004,"参数 post_code 不能为空");
  850. }
  851. $post_company = isset($this->post['post_company']) &&$this->post['post_company']!=="" ? trim($this->post['post_company']):"" ;
  852. if($post_company==""){
  853. return error_show(1004,"参数 post_company 不能为空");
  854. }
  855. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  856. $data=[
  857. "post_code"=>$post_code,
  858. "post_company"=>$post_company,
  859. "remark"=>$remark,
  860. "status"=>1,
  861. "updatetime"=>date("Y-m-d H:i:s")
  862. ];
  863. Db::startTrans();
  864. try{
  865. $up =Db::name("purchease_return")->where($return)->save($data);
  866. if($up){
  867. $sto = ["order_code"=>$info['wsm_in_code'],"status"=>$return['status'],"action_remark"=>'', "action_type"=>"edit"];
  868. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",1,$this->post);
  869. $ark=$info['status'];
  870. $info['status']=6;
  871. $info['updatetime']=date("Y-m-d H:i:s");
  872. $sa=Db::name("purchease_in")->save($info);
  873. if($sa){
  874. $stn = ["order_code"=>$info['wsm_in_code'],"status"=>$ark,"action_remark"=>'',"action_type"=>"edit"];
  875. ActionLog::logAdd($this->post['token'],$stn,"RKD",6,$info);
  876. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>6,"order_type"=>'RKD',"before_status"=>$stn['status']];
  877. ProcessOrder::AddProcess($this->post['token'],$process);
  878. if($info['status']==6){
  879. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  880. if(empty($good)) {
  881. $good=[
  882. "spuCode"=>$cgdinfo['spuCode'],
  883. "wsm_code"=>$info['wsm_code'],
  884. "usable_stock"=>0,
  885. "wait_out_stock"=>0,
  886. "wait_in_stock"=>$info['wsm_num'],
  887. "total_stock"=>0,
  888. "addtime"=>date("Y-m-d H:i:s"),
  889. "updatetime"=>date("Y-m-d H:i:s"),
  890. ];
  891. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  892. "action_type"=>"create"];
  893. }else{
  894. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  895. }
  896. $good['usable_stock']+=$info['wsm_num'];
  897. $good['wait_in_stock']-=$info['wsm_num']+$return['return_num']-$return['reissue_num'];
  898. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  899. $good['updatetime'] = date("Y-m-d H:i:s");
  900. $upd= Db::name("good_stock")->save($good);
  901. if($upd==false){
  902. Db::rollback();
  903. return error_show(1002,"库存更新失败");
  904. }
  905. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  906. $good_data[]=['good_log_code' => $incode,"stock_id"=>isset($good['id'])? $good['id']:Db::name("good_stock")->getLastInsID(),"type"=>2, 'stock'=>$good['wait_in_stock'],"stock_name"=>"wait_in_stock"];
  907. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  908. }
  909. $order = ["order_code"=>$cgdinfo['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  910. $cgdinfo['wsend_num']+=$return['reissue_num'];
  911. $cgdinfo['send_num']-=$return['return_num'];
  912. $cgdinfo['good_num']-=$return['return_num']-$return['reissue_num'];
  913. $cgdinfo['total_fee']=round($cgdinfo['good_num']*$cgdinfo['good_price'],2);
  914. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  915. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  916. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  917. $up=Db::name("purchease_order")->save($cgdinfo);
  918. if($up==false){
  919. Db::rollback();
  920. return error_show(1004,"采购单数量更新失败");
  921. }
  922. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  923. if($bk==false){
  924. $bk=[
  925. "cgdNo"=>$cgdinfo['cgdNo'],
  926. "spuCode"=>$cgdinfo['spuCode'],
  927. "companyNo"=>$cgdinfo['companyNo'],
  928. "total_num"=>0,
  929. "merge_num"=>0,
  930. "balance_num"=>0,
  931. "status"=>1,
  932. "is_del"=>0,
  933. 'addtime'=>date("Y-m-d H:i:s"),
  934. "updatetime"=>date("Y-m-d H:i:s")
  935. ];
  936. }
  937. $bk['balance_num']+=$return['wsm_num'];
  938. $bk['total_num']+=$return['wsm_num'];
  939. $bk['updatetime']=date("Y-m-d H:i:s");
  940. $upcgd =Db::name("order_bk")->save($bk);
  941. if($upcgd==false){
  942. Db::rollback();
  943. return error_show(1004,"采购单数量更新失败");
  944. }
  945. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  946. $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status']];
  947. ProcessOrder::AddProcess($this->post['token'],$process);
  948. Db::commit();
  949. return app_show(0,"退货发货成功");
  950. }else{
  951. Db::rollback();
  952. return error_show(1004,"退货发货失败");
  953. }
  954. }else{
  955. return error_show(1004,"退货发货失败");
  956. }
  957. }catch (\Exception $e){
  958. Db::rollback();
  959. return error_show(1004,$e->getMessage());
  960. }
  961. }
  962. // public function ReturnStatus(){
  963. // $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  964. // if($incode==""){
  965. // return error_show(1004,"参数wsm_in_code 不为空");
  966. // }
  967. // $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  968. // if(empty($info)){
  969. // return error_show(1004,"未找到发货单数据");
  970. // }
  971. // $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  972. // if(empty($return)){
  973. // return error_show(1004,"未找到数据");
  974. // }
  975. // if($info['status']<4){
  976. // return error_show(1004,"入库单未完成");
  977. // }
  978. // $status = isset($this->post['status'])&&$this->post['status']!="" ?$this->post['status']:"";
  979. // if($status==""){
  980. // return error_show(1004,"参数status 不为空");
  981. // }
  982. // Db::startTrans();
  983. // try{
  984. // $data=[
  985. // "status"=>$status,
  986. // "updatetime"=>date("Y-m-d H:i:s")
  987. // ];
  988. // $up =Db::name("purchease_return")->where($return)->save($data);
  989. // if($up){
  990. // $info['status']=$status==1?5:6;
  991. // $info['updatetime']=date("Y-m-d H:i:s");
  992. // $sa=Db::name("purchease_in")->save($info);
  993. // if($sa){
  994. // Db::commit();
  995. // return app_show(0,"更新成功");
  996. // }else{
  997. // Db::rollback();
  998. // return error_show(1004,"更新失败");
  999. // }
  1000. // }else{
  1001. // Db::rollback();
  1002. // return error_show(1004,"更新失败");
  1003. // }
  1004. // }catch (\Exception $e){
  1005. // Db::rollback();
  1006. // return error_show(1004,$e->getMessage());
  1007. // }
  1008. //
  1009. // }
  1010. }