Purchin.php 76 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ActionLog;
  4. use app\admin\model\GoodLog;
  5. use app\admin\model\GoodStockInfo;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. $condition="";
  81. if(!empty($role['write'])&& $this->uid!=''){
  82. $condition.="a.apply_id ={$this->uid} or c.contactor = {$this->uid} or sip.personid in (".implode(",",$role ['write']).")";
  83. }
  84. $company_name = isset($this->post['company_name']) && $this->post['company_name'] !== "" ? trim($this->post['company_name']) : "";
  85. if ($company_name !== "") $where[] = ["a.apply_id", 'in', get_company_item_user_by_name($company_name)];
  86. $count = Db::name('purchease_in')->alias('a')
  87. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  88. ->leftJoin('supplier sip', 'sip.code=b.supplierNo')
  89. ->leftJoin("warehouse_info c","a.wsm_code=c.wsm_code")
  90. ->where($where)->where($condition)->count();
  91. $total = ceil($count/$size);
  92. $page = $page >= $total ? $total : $page;
  93. $list = Db::name('purchease_in')
  94. ->alias('a')
  95. ->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  96. ->leftJoin('supplier sip', 'sip.code=b.supplierNo')
  97. ->leftJoin("warehouse_info c","a.wsm_code=c.wsm_code")
  98. ->leftJoin("depart_user u", "u.uid=a.apply_id AND u.is_del=0")
  99. ->where($where)
  100. ->where($condition)
  101. ->page($page,$size)
  102. ->field("a.apply_name,a.sendtime,b.order_type,b.order_source,a.status,a.cgdNo,a.wsm_in_code,a.send_num,a.wsm_code,b.good_name,b.spuCode,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,u.itemid,b.cgder_id,b.cgder,b.good_createrid,b.good_creater")
  103. ->order("a.addtime desc")
  104. ->cursor();
  105. $data=[];
  106. foreach ($list as $value){
  107. //获取规格、品牌信息
  108. if ($value['order_type'] == 3) {
  109. $temp = Db::name('good_zixun')
  110. ->alias('gz')
  111. ->field('gz.specinfo,b.brand_name')
  112. ->join('brand b', 'b.id=gz.brand_id')
  113. ->where(['gz.spuCode' => $value['spuCode'], 'gz.is_del' => 0])
  114. ->find();
  115. $value["brand_name"] = $temp['brand_name'];
  116. $value["speclist"] = json_decode($temp['specinfo'], true);
  117. } else {
  118. $value['brand_name'] = Db::name('good_basic')
  119. ->alias('gb')
  120. ->join('brand b', 'b.id=gb.brand_id')
  121. ->where(['gb.spuCode' => $value['spuCode']])
  122. ->value('b.brand_name');
  123. $spec = Db::name("good_spec")
  124. ->where(["spuCode" => $value['spuCode'], "is_del" => 0])
  125. ->select()
  126. ->toArray();
  127. $speclist = [];
  128. if (!empty($spec)) {
  129. foreach ($spec as $val) {
  130. $temp = [];
  131. $temp['id'] = $val['id'];
  132. $temp['spuCode'] = $val['spuCode'];
  133. $temp['spec_id'] = $val['spec_id'];
  134. $temp['spec_value_id'] = $val['spec_value_id'];
  135. $sp = Db::name("specs")->where(["id" => $val['spec_id']])->find();
  136. $temp['spec_name'] = isset($sp["spec_name"]) ? $sp["spec_name"] : "";
  137. $spv = Db::name("spec_value")->where(["id" => $val['spec_value_id']])->find();
  138. $temp['spec_value'] = isset($spv["spec_value"]) ? $spv["spec_value"] : "";
  139. $speclist[] = $temp;
  140. }
  141. }
  142. $value["speclist"] = empty($speclist) ? [] : $speclist;
  143. }
  144. $wsmcode = Db::name("warehouse_info")->alias("k")->leftJoin("supplier c","k.supplierNo=c.code")->where(["k.wsm_code"=>$value['wsm_code']])->field("k.name as wsm_name,c.name,c.code")->find();
  145. $value['wsm_name'] = $wsmcode['wsm_name'];
  146. $value['wsm_supplier'] = $wsmcode['name'];
  147. $value['wsm_supplierNo'] = $wsmcode['code'];
  148. $value['company_name'] = implode('/', array_column(GetPart($value['itemid']), 'name'));
  149. $data[]=$value;
  150. }
  151. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  152. }
  153. public function add(){
  154. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!=""? trim($this->post['cgdNo']):"";
  155. if($cgdNo==""){
  156. return error_show(1005,"参数cgdNo 不能为空");
  157. }
  158. $cgdinfo = Db::name("purchease_order")->where(['cgdNo'=>$cgdNo,'is_del'=>0])->find();
  159. if(empty($cgdinfo)){
  160. return error_show(1005,"未找到采购单数据");
  161. }
  162. if($cgdinfo['status']==0){
  163. return error_show(1005,"采购单未发货");
  164. }
  165. $wsm_in_code = makeNo("CF");
  166. $bn_code = makeNo("BN");
  167. $wsminfo = Db::name("warehouse_info")->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  168. if(empty($wsminfo)){
  169. return error_show(1004,"未找到仓库信息");
  170. }
  171. $recep = Db::name('warehouse_addr')->where(["wsm_code"=>$cgdinfo['wsm_code'],"is_del"=>0])->find();
  172. $sendtype = isset($this->post['sendtype'])&&$this->post['sendtype']!="" ? intval($this->post['sendtype']):"";
  173. if($sendtype==""){
  174. return error_show(1004,"参数 sendtype 不能为空");
  175. }
  176. // $data = GetUserInfo($this->post['token']);
  177. // if((!empty($data) && $data['code']!=0) ||empty($data) ){
  178. // return error_show($data['code'],$data['message']);
  179. // }
  180. // $userinfo = $data['data'];
  181. $post_company = isset($this->post['post_company'])&&$this->post['post_company']!="" ? trim($this->post['post_company']):"";
  182. $post_code = isset($this->post['post_code'])&&$this->post['post_code']!="" ? trim($this->post['post_code']):"";
  183. $post_fee = isset($this->post['post_fee'])&&$this->post['post_fee']!="" ? $this->post['post_fee']:"0";
  184. $post_time = isset($this->post['post_time'])&&$this->post['post_time']!="" ? $this->post['post_time']:date("Y-m-d H:i:s");
  185. $send_num = isset($this->post['send_num'])&&$this->post['send_num']!="" ? intval($this->post['send_num']):"";
  186. $status = isset($this->post['status'])&&$this->post['status']!="" ? intval($this->post['status']):"1 ";
  187. if($send_num==''){
  188. return error_show(1004,"参数 send_num 不能为空或零");
  189. }
  190. $wsmin_num=Db::name("purchease_in")->where([["cgdNo","=",$cgdNo],["is_del","=",0],["status","not in",[4,6]]])
  191. ->sum("send_num");
  192. if($send_num>$cgdinfo['wsend_num']-$wsmin_num){
  193. return error_show(1009,"采购单剩余未发货数量不足");
  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. "bnCode"=>$bn_code,
  202. "wsm_code"=>$cgdinfo['wsm_code'],
  203. "wsm_reaper"=>isset($recep)&& $recep['wsm_name']!=''? $recep['wsm_name']:"",
  204. "send_num"=>$send_num,
  205. "post_company"=>$post_company,
  206. "post_code"=>$post_code,
  207. "post_fee"=>$post_fee,
  208. "sendtime"=>$post_time,
  209. "apply_id"=>$this->uid,
  210. "apply_name"=>$this->uname,
  211. "wait_num"=>0,
  212. "wsm_num"=>0,
  213. "sendtype"=>$sendtype,
  214. "status"=>$status,
  215. "addtime"=>date("Y-m-d H:i:s"),
  216. "updatetime"=>date("Y-m-d H:i:s")
  217. ];
  218. Db::startTrans();
  219. try{
  220. $win = Db::name("purchease_in")->insert($orin,true);
  221. if($win){
  222. $sto = ["order_code"=>$wsm_in_code,"status"=>$status,"action_remark"=>'',"action_type"=>"edit"];
  223. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$sto,"RKD",$status,$this->post);
  224. $process=["order_code"=>$wsm_in_code,"order_id"=>$win,"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$status,'holder_id' => $orin['apply_id']];
  225. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  226. $order = ["order_code"=>$cgdNo,"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  227. //维护台账信息
  228. Db::execute("UPDATE `wsm_standing_book` SET `wsm_in_code`=CONCAT(IFNULL(`wsm_in_code`,''),',{$wsm_in_code}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE `cgdNo`='{$cgdNo}'");
  229. if($status==1){
  230. Db::commit();
  231. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  232. }
  233. if($status==4){
  234. $cgdinfo['wsend_num']-=$send_num;
  235. $cgdinfo['send_num']+=$send_num;
  236. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  237. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  238. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  239. $up=Db::name("purchease_order")->save($cgdinfo);
  240. if($up==false){
  241. Db::rollback();
  242. return error_show(1004,"新建失败");
  243. }
  244. $good = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'],"spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->lock(true)->find();
  245. if(empty($good)) {
  246. $good=[
  247. "spuCode"=>$cgdinfo['spuCode'],
  248. "wsm_code"=>$cgdinfo['wsm_code'],
  249. "usable_stock"=>0,
  250. "wait_out_stock"=>0,
  251. "wait_in_stock"=>$send_num,
  252. "total_stock"=>0,
  253. "addtime"=>date("Y-m-d H:i:s"),
  254. "updatetime"=>date("Y-m-d H:i:s"),
  255. ];
  256. }
  257. $good['wait_in_stock']-=$send_num;
  258. $good['usable_stock']+=$send_num;
  259. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  260. $good['updatetime'] = date("Y-m-d H:i:s");
  261. $upd= Db::name("good_stock")->save($good);
  262. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  263. //商品变动日志表,good_log_code字段存储采购单单号
  264. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  265. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>2,'stock'=>$send_num,"stock_name"=>"wait_in_stock"];
  266. if($upd){
  267. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  268. //todo:: 新增bn编号库存数据修改
  269. if($cgdinfo['order_type']==1){
  270. $bnin=GoodStockInfo::AddBn($stockid,$bn_code,$send_num,$cgdinfo['good_price']);
  271. if($bnin==false){
  272. Db::rollback();
  273. return error_show(1004,"库存bn数据新增失败");
  274. }
  275. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->find();
  276. if($bk==false){
  277. $bk=[
  278. "cgdNo"=>$cgdinfo['cgdNo'],
  279. "spuCode"=>$cgdinfo['spuCode'],
  280. "companyNo"=>$cgdinfo['companyNo'],
  281. "total_num"=>$send_num,
  282. "merge_num"=>0,
  283. "balance_num"=>$send_num,
  284. "status"=>1,
  285. "is_del"=>0,
  286. 'addtime'=>date("Y-m-d H:i:s"),
  287. "updatetime"=>date("Y-m-d H:i:s")
  288. ];
  289. $upcgd =Db::name("order_bk")->save($bk);
  290. }else{
  291. $where=['id'=>$bk['id'],'total_num'=>$bk['total_num'],'balance_num'=>$bk['balance_num']];
  292. $bk['balance_num']+=$send_num;
  293. $bk['total_num']+=$send_num;
  294. $bk['updatetime']=date("Y-m-d H:i:s");
  295. $upcgd =Db::name("order_bk")->where($where)->update($bk);
  296. }
  297. if($upcgd==false){
  298. Db::rollback();
  299. return error_show(1004,"采购单数量更新失败");
  300. }
  301. }
  302. if($cgdinfo['send_status']==3 && $cgdinfo['order_type']!=1){
  303. $send=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"status"=>1])->column("outCode");
  304. if(!empty($send)){
  305. $out =Db::name("order_out")->where(["outCode"=>$send,"status"=>0])->select()->toArray();
  306. if(!empty($out)){
  307. $up =Db::name("order_out")->where(["outCode"=>$send,"status"=>0])->update
  308. (["status"=>1,'wsm_code'=>$cgdinfo['wsm_code'],"updatetime"=>date('Y-m-d H:i:s')]);
  309. if($up==false){
  310. Db::rollback();
  311. return error_show(1004,"出库单出库失败");
  312. }else{
  313. //查询是否有非库存品订单
  314. $is_stock = Db::name('sale')
  315. ->where([
  316. ['is_del','=',0],
  317. ['orderCode','in',array_column($out,'orderCode')]
  318. ])->column('is_stock','orderCode');
  319. $supplier = Db::name('supplier')
  320. ->field('person,personid')
  321. ->where(['code'=>$cgdinfo['supplierNo'],'is_del'=>0])
  322. ->findOrEmpty();
  323. foreach ($out as $k => $v_outCode) {
  324. ActionLog::logAdd(['id' => $this->uid, 'nickname' => $this->uname], [
  325. "order_code" => $v_outCode['outCode'],//出库单号
  326. "status" => 0,//这里的status是之前的值
  327. "action_remark" => '',//备注
  328. "action_type" => "status"//新建create,编辑edit,更改状态status
  329. ], "CKD", 1, $this->post);
  330. if ($is_stock[$v_outCode['orderCode']] == 1) {
  331. //存品,推给库管和库管-张凯旋
  332. $roleid = config('app.wsm_cgder_role');
  333. $uids = Db::name('user_role')
  334. ->where('is_del', 0)
  335. ->whereIn('roleid', $roleid)
  336. ->column('uid');
  337. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  338. "order_type" => 'CKD',
  339. "order_code" => $v_outCode['outCode'],//出库单号
  340. "order_id" => $v_outCode['id'],
  341. "order_status" => 1,
  342. "before_status" => 0,
  343. // 'wait_id' => $supplier['personid'],
  344. // 'wait_name' => $supplier['person'],
  345. // 'holder_id' => $supplier['personid'],
  346. 'handle_user_list' => implode(',', $uids)
  347. ]);
  348. } elseif ($is_stock[$v_outCode['orderCode']] == 0 || $cgdinfo['order_type'] = 3) {
  349. //非库存品和采返商品,推给供应商负责人
  350. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  351. "order_type" => 'CKD',
  352. "order_code" => $v_outCode['outCode'],//出库单号
  353. "order_id" => $v_outCode['id'],
  354. "order_status" => 1,
  355. "before_status" => 0,
  356. 'wait_id' => $supplier['personid'],
  357. 'wait_name' => $supplier['person'],
  358. 'holder_id' => $supplier['personid'],
  359. ]);
  360. } else {
  361. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], [
  362. "order_type" => 'CKD',
  363. "order_code" => $v_outCode['outCode'],//出库单号
  364. "order_id" => $v_outCode['id'],
  365. "order_status" => 1,
  366. "before_status" => 0,
  367. 'holder_id' => $v_outCode['apply_id']
  368. ]);
  369. }
  370. }
  371. }
  372. $good1 = Db::name("good_stock")->where(["wsm_code"=>$cgdinfo['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  373. if($good1==false){
  374. Db::rollback();
  375. return error_show(1004,"未找到对应商品库存");
  376. }
  377. $out_num = intval(array_sum(array_column($out,"send_num")));
  378. if($out_num>$good1['usable_stock']){
  379. Db::rollback();
  380. return error_show(1004,"库存数量不足发货");
  381. }
  382. $good1['usable_stock']-=$out_num;
  383. $good1['wait_out_stock']+=$out_num;
  384. $good1['total_stock']=$good1['usable_stock']+$good1['wait_out_stock'];
  385. $good1['updatetime'] = date("Y-m-d H:i:s");
  386. $upd= Db::name("good_stock")->save($good1);
  387. if($upd==false){
  388. Db::rollback();
  389. return error_show(1004,"库存数量更新失败");
  390. }
  391. $stockid= isset($good['id'])?$good['id']:Db::name("good_stock")->getLastInsID();
  392. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"wait_out_stock"];
  393. $good_data[]=['good_log_code'=>$wsm_in_code,"stock_id"=>$stockid,"type"=>1,'stock'=>$send_num,"stock_name"=>"usable_stock"];
  394. GoodLog::LogAdd(['id'=>$this->uid,'nickname'=>$this->uname],$good_data,'RKD');
  395. $sendp=Db::name("order_send")->where(["cgdNo"=>$cgdNo,"outCode"=>$send,"status"=>1])->save (["status"=>2]);
  396. if($sendp==false){
  397. Db::rollback();
  398. return error_show(1004,"库存发货失败");
  399. }
  400. }
  401. }
  402. }
  403. ActionLog::logAdd(['id'=>$this->uid,'nickname'=>$this->uname],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  404. $personid = Db::name('supplier')
  405. ->where('is_del',0)
  406. ->where('code',$cgdinfo['supplierNo'])
  407. ->value('personid');
  408. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  409. $is_stock = Db::name('good_basic')
  410. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  411. ->value('is_stock');
  412. if($is_stock==1){
  413. //库存品,推给31库管人员、41库管-张凯旋
  414. $uid = Db::name('user_role')
  415. ->where([
  416. ['is_del', '=', 0],
  417. ['roleid', 'in', [31, 41]],
  418. ['status', '=', 1]
  419. ])->column('uid');
  420. $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid,'handle_user_list'=>implode(',', $uid)];
  421. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid,'handle_user_list'=>$personid]; //非库存品和采返商品,推给供应商负责人
  422. }else $process = ["order_code" => $cgdNo, "order_id" => $cgdinfo['id'], "order_status" => $cgdinfo['status'], "order_type" => 'CGD', "before_status" => $order['status'], 'holder_id' => $personid];
  423. ProcessOrder::AddProcess(['id'=>$this->uid,'nickname'=>$this->uname],$process);
  424. Db::commit();
  425. return app_show(0,'商品入库成功',["wsm_in_code"=>$wsm_in_code]);
  426. }else{
  427. Db::rollback();
  428. return error_show(1002,"商品入库失败");
  429. }
  430. }
  431. Db::commit();
  432. return app_show(0,'新建成功',["wsm_in_code"=>$wsm_in_code]);
  433. }
  434. Db::rollback();
  435. return error_show(1004,"新建失败");
  436. }catch (\Exception $e){
  437. Db::rollback();
  438. return error_show(1004, $e->getMessage() . '|' . $e->getFile() . '|' . $e->getLine());
  439. }
  440. }
  441. public function info(){
  442. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  443. if($incode==""){
  444. return error_show(1004,"参数wsm_in_code 不为空");
  445. }
  446. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  447. if(empty($info)){
  448. return error_show(1004,"未找到数据");
  449. }
  450. $dom = Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],'is_del'=>0])->find();
  451. if($dom['order_type']==3){
  452. $goon = Db::name("good_zixun")->where(["spuCode"=>$dom['spuCode'],"is_del"=>0])->find();
  453. }else {
  454. $goon =Db::name('good_basic')->where(['spuCode'=>$dom['spuCode']])->find();
  455. }
  456. if(empty($goon)){
  457. return error_show(1002,"未找到商品数据");
  458. }
  459. $cat= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  460. $info['cgder']=$dom['cgder'];
  461. $info['spuCode']=$dom['spuCode'];
  462. $info['good_name']=$dom['good_name'];
  463. $info['skuCode']=$dom['skuCode'];
  464. $info['good_num']=$dom['good_num'];
  465. $info['good_price']=$dom['good_price'];
  466. $info['total_fee']=$dom['total_fee'];
  467. $info['diff_fee']=$dom['diff_fee'];
  468. $info['diff_weight']=$dom['diff_weight'];
  469. $info['gold_price']=$dom['gold_price'];
  470. $wsmcode = Db::name("warehouse_info")->alias("a")->leftJoin("supplier b","a.supplierNo=b.code")
  471. ->leftJoin("warehouse_addr c","a.wsm_code=c.wsm_code and c.is_del=0")
  472. ->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();
  473. $info['wsm_name'] =isset($wsmcode['wsm_name']) ? $wsmcode['wsm_name']:"";
  474. $info['wsm_supplier'] =isset($wsmcode['name']) ? $wsmcode['name']:"";
  475. $info['wsm_supplierNo'] =isset($wsmcode['code']) ? $wsmcode['code']:"";
  476. $info['wsm_contactor'] =isset($wsmcode['wsm_contactor']) ? $wsmcode['wsm_contactor']:"";
  477. $info['wsm_mobile'] =isset($wsmcode['wsm_mobile']) ? $wsmcode['wsm_mobile']:"";
  478. $info['addr_code'] =isset($wsmcode['addr_code']) ? $wsmcode['addr_code']:"";
  479. $info['wsm_addr'] =isset($wsmcode['addr_code']) ? GetAddr($wsmcode['addr_code']):"";
  480. $info['wsm_addr'].=isset($wsmcode['wsm_addr']) ? $wsmcode['wsm_addr']:"";
  481. $check = Db::name("purchease_info")->alias("a")->leftJoin("result_info b","a.error_code=b.result_code")->where
  482. (['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();
  483. $info['checkinfo']= $check;
  484. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  485. $return['return_contactor']=isset($return['return_contactor'])&&$return['return_contactor']!="" ?$return['return_contactor']:'';
  486. $return['return_addr']=isset($return['return_addr'])&&$return['return_addr']!="" ?$return['return_addr']:'';
  487. $return['return_mobile']=isset($return['return_mobile'])&&$return['return_mobile']!="" ?$return['return_mobile']:'';
  488. //以下字段临时补充到return中
  489. $return['wsm_in_code'] = $incode;
  490. $return['wsm_num'] = isset($return['wsm_num']) ? $return['wsm_num'] : 0;
  491. $return['reissue_num'] = isset($return['reissue_num']) ? $return['reissue_num'] : 0;
  492. $return['return_num'] = isset($return['return_num']) ? $return['return_num'] : 0;
  493. $return['contactor'] = $return['return_contactor'];
  494. $return['addr'] = $return['return_addr'];
  495. $return['mobile'] = $return['return_mobile'];
  496. $return['error_remark'] = isset($return['error_remark']) ? $return['error_remark'] : '';
  497. $return['remark'] = isset($return['remark']) ? $return['remark'] : '';
  498. $info['return']= $return;
  499. $info['can']=$cat;
  500. if(isset($dom['companyNo'])&&$dom['companyNo']!=""){
  501. $company = Db::name("business")->where(["companyNo"=>$dom['companyNo']])->find();
  502. }
  503. $info['company'] = isset($company['company'])?$company['company']:"";
  504. $info['companyNo'] = isset($dom['companyNo'])?$dom['companyNo']:"";
  505. $info['order_type'] = isset($dom['order_type'])?$dom['order_type']:"";
  506. return app_show(0,'获取成功',$info);
  507. }
  508. public function check(){
  509. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  510. if($incode==""){
  511. return error_show(1004,"参数wsm_in_code 不为空");
  512. }
  513. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  514. if(empty($info)){
  515. return error_show(1004,"未找到数据");
  516. }
  517. if($info['status']!=1){
  518. return error_show(1004,"发货单状态有误");
  519. }
  520. $order_num = isset($this->post['order_num']) && $this->post['order_num']!==''?intval($this->post['order_num'])
  521. :"";
  522. if($order_num===""){
  523. return error_show(1004,"参数 order_num 不为空");
  524. }
  525. $error_list = isset($this->post['error_list']) && $this->post['error_list']!==''?$this->post['error_list']:"";
  526. $result = GetUserInfo($this->post['token']);
  527. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  528. return error_show($result['code'],$result['message']);
  529. }
  530. $userinfo = $result['data'];
  531. Db::startTrans();
  532. try{
  533. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  534. $info['wsm_num'] = $order_num;
  535. $info['wait_num'] = $info['send_num'];
  536. $info['checkid'] = $userinfo['id'];
  537. $info['check_name'] = $userinfo['nickname'];
  538. $info['status'] =2;
  539. $info['error_num'] = $info['send_num']-$order_num;
  540. $info['updatetime'] = date("Y-m-d H:i:s");
  541. $up =Db::name("purchease_in")->save($info);
  542. if($up){
  543. ActionLog::logAdd($this->post['token'],$order,"RKD",2,$this->post);
  544. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$order['status'],'holder_id' => $info['apply_id']];
  545. ProcessOrder::AddProcess($this->post['token'],$process);
  546. if(!empty($error_list)){
  547. $data=[];
  548. foreach ($error_list as $value ){
  549. $temp=[];
  550. $temp['wsm_in_code']=$info['wsm_in_code'];
  551. $temp['num']=$value['num'];
  552. $temp['error_code']=$value['error_code'];
  553. $temp['error_img']=$value['error_img'];
  554. $temp['remark']=$value['remark'];
  555. $temp['is_del']=0;
  556. $temp['addtime']=date("Y-m-d H:i:s");
  557. $temp['updatetime']=date("Y-m-d H:i:s");
  558. $data[]=$temp;
  559. }
  560. $derr= Db::name("purchease_info")->insertAll($data);
  561. if($derr){
  562. Db::commit();
  563. return app_show(0,"验货完成");
  564. }else{
  565. Db::rollback();
  566. return error_show(1002,"验货数据保存失败");
  567. }
  568. }
  569. Db::commit();
  570. return app_show(0,"验货完成");
  571. }
  572. Db::rollback();
  573. return error_show(1002,"验货数据保存失败");
  574. }catch (\Exception $e){
  575. Db::rollback();
  576. return error_show(1002,$e->getMessage());
  577. }
  578. }
  579. public function status(){
  580. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  581. if($incode==""){
  582. return error_show(1004,"参数wsm_in_code 不为空");
  583. }
  584. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  585. if(empty($info)){
  586. return error_show(1004,"未找到数据");
  587. }
  588. $status = isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  589. if($status===""){
  590. return error_show(1004,"参数status 不为空");
  591. }
  592. if($info['status']==4){
  593. return error_show(1004,"入库单已完成");
  594. }
  595. $remark = isset($this->post['remark'])&&$this->post['remark']!="" ? trim($this->post['remark']) :"";
  596. Db::startTrans();
  597. try{
  598. $order = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"status"];
  599. $info['status'] = $status;
  600. $info['remark'] = $remark;
  601. $info['updatetime'] = date("Y-m-d H:i:s");
  602. $update = Db::name("purchease_in")->save($info);
  603. if($update){
  604. ActionLog::logAdd($this->post['token'],$order,"RKD",$status,$this->post);
  605. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$status,"order_type"=>'RKD',"before_status"=>$order['status'],'holder_id' => $info['apply_id']];
  606. ProcessOrder::AddProcess($this->post['token'],$process);
  607. if($status==0){
  608. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  609. if(empty($cgdinfo)){
  610. Db::rollback();
  611. return error_show(1002,"未找到采购单数据");
  612. }
  613. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  614. $cgdinfo['wsend_num']+=$info['send_num'];
  615. $cgdinfo['send_num']-=$info['send_num'];
  616. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  617. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  618. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  619. $up=Db::name("purchease_order")->save($cgdinfo);
  620. if($up){
  621. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  622. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  623. // $orderinfo = Db::name('sale')
  624. // ->alias('a')
  625. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  626. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  627. // ->where([
  628. // 'a.is_del'=>0,
  629. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  630. // ])->findOrEmpty();
  631. $is_stock = Db::name('good_basic')
  632. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  633. ->value('is_stock');
  634. if($is_stock==1){
  635. //库存品,推给31库管人员、41库管-张凯旋
  636. $uid = Db::name('user_role')
  637. ->where([
  638. ['is_del', '=', 0],
  639. ['roleid', 'in', [31, 41]],
  640. ['status', '=', 1]
  641. ])->column('uid');
  642. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  643. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) {
  644. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  645. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  646. }//非库存品和采返商品,推给供应商负责人
  647. }else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  648. ProcessOrder::AddProcess(['id' => $this->uid, 'nickname' => $this->uname], $process);
  649. Db::commit();
  650. return app_show(0,'取消成功');
  651. }else{
  652. Db::rollback();
  653. return error_show(1002,"取消失败");
  654. }
  655. }
  656. if($status==1){
  657. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  658. if(empty($cgdinfo)){
  659. Db::rollback();
  660. return error_show(1002,"未找到采购单数据");
  661. }
  662. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  663. $cgdinfo['wsend_num']-=$info['send_num'];
  664. $cgdinfo['send_num']+=$info['send_num'];
  665. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  666. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  667. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  668. $up=Db::name("purchease_order")->save($cgdinfo);
  669. if($up){
  670. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  671. if($cgdinfo['status'] == 1 || $cgdinfo['status']==2){
  672. // $orderinfo = Db::name('sale')
  673. // ->alias('a')
  674. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  675. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  676. // ->where([
  677. // 'a.is_del'=>0,
  678. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  679. // ])->findOrEmpty();
  680. $is_stock = Db::name('good_basic')
  681. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  682. ->value('is_stock');
  683. if($is_stock==1){
  684. //库存品,推给31库管人员、41库管-张凯旋
  685. $uid = Db::name('user_role')
  686. ->where([
  687. ['is_del', '=', 0],
  688. ['roleid', 'in', [31, 41]],
  689. ['status', '=', 1]
  690. ])->column('uid');
  691. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  692. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) {
  693. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  694. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  695. }//非库存品和采返商品,推给供应商负责人
  696. }else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  697. ProcessOrder::AddProcess($this->post['token'],$process);
  698. Db::commit();
  699. return app_show(0,'发货成功');
  700. }else{
  701. Db::rollback();
  702. return error_show(1002,"发货失败");
  703. }
  704. }
  705. if($status==4){
  706. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  707. if(empty($cgdinfo)){
  708. Db::rollback();
  709. return error_show(1002,"未找到采购单数据");
  710. }
  711. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  712. $cgdinfo['wsend_num']-=$info['send_num'];
  713. $cgdinfo['send_num']+=$info['send_num'];
  714. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  715. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  716. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  717. $up=Db::name("purchease_order")->save($cgdinfo);
  718. if($up==false){
  719. Db::rollback();
  720. return error_show(1002,"发货失败");
  721. }
  722. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  723. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  724. // $orderinfo = Db::name('sale')
  725. // ->alias('a')
  726. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  727. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  728. // ->where([
  729. // 'a.is_del'=>0,
  730. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  731. // ])->findOrEmpty();
  732. $is_stock = Db::name('good_basic')
  733. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  734. ->value('is_stock');
  735. if($is_stock==1){
  736. //库存品,推给31库管人员、41库管-张凯旋
  737. $uid = Db::name('user_role')
  738. ->where([
  739. ['is_del', '=', 0],
  740. ['roleid', 'in', [31, 41]],
  741. ['status', '=', 1]
  742. ])->column('uid');
  743. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  744. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) {
  745. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  746. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  747. }//非库存品和采返商品,推给供应商负责人
  748. }else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  749. ProcessOrder::AddProcess($this->post['token'],$process);
  750. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  751. if(empty($good)) {
  752. $good=[
  753. "spuCode"=>$cgdinfo['spuCode'],
  754. "wsm_code"=>$info['wsm_code'],
  755. "usable_stock"=>0,
  756. "wait_out_stock"=>0,
  757. "wait_in_stock"=>$info['wsm_num'],
  758. "total_stock"=>0,
  759. "addtime"=>date("Y-m-d H:i:s"),
  760. "updatetime"=>date("Y-m-d H:i:s"),
  761. ];
  762. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  763. "action_type"=>"create"];
  764. }else{
  765. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  766. }
  767. $good['wait_in_stock']-=$info['wsm_num'];
  768. $good['usable_stock']+=$info['wsm_num'];
  769. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  770. $good['updatetime'] = date("Y-m-d H:i:s");
  771. $upd= Db::name("good_stock")->save($good);
  772. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  773. //商品变动日志表,good_log_code字段存储入库单编号
  774. $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"];
  775. $good_data[] = ['good_log_code' => $incode, "stock_id" => isset($good['id']) ? $good['id'] :
  776. Db::name("good_stock")->getLastInsID(), "type" => 2, 'stock' => $info['wsm_num'], "stock_name" => "wait_in_stock"];
  777. if($upd){
  778. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$info['wsm_num'],$cgdinfo['good_price']);
  779. if($bnin==false){
  780. Db::rollback();
  781. return error_show(1004,"库存bn数据新增失败");
  782. }
  783. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  784. Db::commit();
  785. return app_show(0,'商品入库成功');
  786. }else{
  787. Db::rollback();
  788. return error_show(1002,"商品入库失败");
  789. }
  790. }
  791. Db::commit();
  792. return app_show(0,"状态修改完成");
  793. }
  794. Db::rollback();
  795. return error_show(1002,"状态修改失败");
  796. }catch (\Exception $e){
  797. Db::rollback();
  798. return error_show(1002,$e->getMessage());
  799. }
  800. }
  801. /**
  802. * @return \think\response\Json|void
  803. * @throws \think\db\exception\DataNotFoundException
  804. * @throws \think\db\exception\DbException
  805. * @throws \think\db\exception\ModelNotFoundException
  806. */
  807. public function ReturnAdd(){
  808. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  809. if($incode==""){
  810. return error_show(1004,"参数wsm_in_code 不为空");
  811. }
  812. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  813. if(empty($info)){
  814. return error_show(1004,"未找到数据");
  815. }
  816. //正常入库数量
  817. $wsm_num = isset($this->post['wsm_num']) &&$this->post['wsm_num']!=="" ? intval($this->post['wsm_num']):"" ;
  818. if($wsm_num===""){
  819. return error_show(1004,"参数wsm_num 不为空");
  820. }
  821. //补货数量
  822. $reissue_num = isset($this->post['reissue_num']) &&$this->post['reissue_num']!=="" ? intval($this->post['reissue_num']):"0" ;
  823. //退货数量
  824. $return_num = isset($this->post['return_num']) &&$this->post['return_num']!=="" ? intval($this->post['return_num']):"0" ;
  825. $contactor = isset($this->post['contactor']) &&$this->post['contactor']!=="" ? trim($this->post['contactor']):"" ;
  826. if($contactor==""){
  827. return error_show(1004,"参数contactor 不为空");
  828. }
  829. $addr = isset($this->post['addr']) &&$this->post['addr']!=="" ? trim($this->post['addr']):"" ;
  830. if($addr==""){
  831. return error_show(1004,"参数addr 不为空");
  832. }
  833. $mobile = isset($this->post['mobile']) &&$this->post['mobile']!=="" ? trim($this->post['mobile']):"" ;
  834. if($mobile==""){
  835. return error_show(1004,"参数mobile 不为空");
  836. }
  837. $error_remark = isset($this->post['error_remark']) &&$this->post['error_remark']!=="" ? trim($this->post['error_remark']):"" ;
  838. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  839. $result = GetUserInfo($this->post['token']);
  840. if((!empty($result) && $result['code']!=0) ||empty($result) ){
  841. return error_show($result['code'],$result['message']);
  842. }
  843. $userinfo = $result['data'];
  844. Db::startTrans();
  845. try{
  846. $sto = ["order_code"=>$incode,"status"=>$info['status'],"action_remark"=>'',"action_type"=>"edit"];
  847. // $info['status'] =$info['wsm_num']==$wsm_num ? 4 :5;
  848. $info['status'] = $info['send_num'] == $wsm_num ? 4 : 5;//艳蓉说,这里不能用入库数量比较,应该是用入库数量,即总数来比较
  849. $info['is_th'] =$return_num>0 ?1:0;
  850. $info['wsm_num']= $wsm_num;
  851. $info['updatetime'] = date("Y-m-d H:i:s");
  852. $up= Db::name("purchease_in")->save($info);
  853. if($up){
  854. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  855. if(empty($cgdinfo)){
  856. Db::rollback();
  857. return error_show(1002,"未找到采购单数据");
  858. }
  859. if($info['status']==4){
  860. $order = ["order_code"=>$info['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  861. $cgdinfo['wsend_num']-=$info['send_num'];
  862. $cgdinfo['send_num']+=$info['send_num'];
  863. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  864. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  865. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  866. $up=Db::name("purchease_order")->save($cgdinfo);
  867. if($up==false){
  868. Db::rollback();
  869. return error_show(1002,"发货失败");
  870. }
  871. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  872. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  873. // $orderinfo = Db::name('sale')
  874. // ->alias('a')
  875. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  876. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  877. // ->where([
  878. // 'a.is_del'=>0,
  879. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  880. // ])->findOrEmpty();
  881. $is_stock = Db::name('good_basic')
  882. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  883. ->value('is_stock');
  884. if($is_stock==1){
  885. //库存品,推给31库管人员、41库管-张凯旋
  886. $uid = Db::name('user_role')
  887. ->where([
  888. ['is_del', '=', 0],
  889. ['roleid', 'in', [31, 41]],
  890. ['status', '=', 1]
  891. ])->column('uid');
  892. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  893. }elseif ($is_stock==0 || $cgdinfo==3) {
  894. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  895. $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];
  896. }//非库存品和采返商品,推给供应商负责人
  897. }else $process=["order_code"=>$info['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  898. ProcessOrder::AddProcess($this->post['token'],$process);
  899. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  900. if(empty($good)) {
  901. $good=[
  902. "spuCode"=>$cgdinfo['spuCode'],
  903. "wsm_code"=>$info['wsm_code'],
  904. "usable_stock"=>0,
  905. "wait_out_stock"=>0,
  906. "wait_in_stock"=>$wsm_num,
  907. "total_stock"=>0,
  908. "addtime"=>date("Y-m-d H:i:s"),
  909. "updatetime"=>date("Y-m-d H:i:s"),
  910. ];
  911. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',
  912. "action_type"=>"create"];
  913. }else{
  914. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  915. }
  916. $good['wait_in_stock']-=$wsm_num;
  917. // if($good['presale_stock']>0){
  918. // if($good['presale_stock']>=$wsm_num){
  919. // $good['presale_stock']-=$wsm_num;
  920. // $good['wait_out_stock']+=$wsm_num;
  921. // }else{
  922. // $good['presale_stock']=0;
  923. // $good['usable_stock']+=$wsm_num-$good['presale_stock'];
  924. // $good['wait_out_stock']+=$good['presale_stock'];
  925. // }
  926. // }else{
  927. $good['usable_stock']+=$wsm_num;
  928. // }
  929. // $good['usable_stock']+=$wsm_num;
  930. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  931. $good['updatetime'] = date("Y-m-d H:i:s");
  932. $upd= Db::name("good_stock")->save($good);
  933. if($upd==false){
  934. Db::rollback();
  935. return error_show(1002,"库存更新失败");
  936. }
  937. $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"];
  938. $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"];
  939. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  940. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  941. if($bk==false){
  942. $bk=[
  943. "cgdNo"=>$cgdinfo['cgdNo'],
  944. "spuCode"=>$cgdinfo['spuCode'],
  945. "companyNo"=>$cgdinfo['companyNo'],
  946. "total_num"=>0,
  947. "merge_num"=>0,
  948. "balance_num"=>0,
  949. "status"=>1,
  950. "is_del"=>0,
  951. 'addtime'=>date("Y-m-d H:i:s"),
  952. "updatetime"=>date("Y-m-d H:i:s")
  953. ];
  954. }
  955. $bk['balance_num']+=$wsm_num;
  956. $bk['total_num']+=$wsm_num;
  957. $bk['updatetime']=date("Y-m-d H:i:s");
  958. $upcgd =Db::name("order_bk")->save($bk);
  959. if($upcgd==false){
  960. Db::rollback();
  961. return error_show(1004,"采购单数量更新失败");
  962. }
  963. }
  964. ActionLog::logAdd($this->post['token'],$sto,"RKD", $info['status'],$this->post);
  965. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>$info['status'],"order_type"=>'RKD',"before_status"=>$sto['status'],'holder_id' => $info['apply_id']];
  966. ProcessOrder::AddProcess($this->post['token'],$process);
  967. //需要在详情页把相关退货记录原样取出来,所以这里把if去掉,所有记录都入purchease_return表
  968. if($info['status']==5){
  969. $returnCode=makeNo("CR");
  970. $data=[
  971. "returnCode"=>$returnCode,
  972. "wsm_in_code"=>$incode,
  973. "cgdNo"=>$cgdinfo['cgdNo'],
  974. "wsm_num"=>$wsm_num,
  975. "reissue_num"=>$reissue_num,
  976. "return_num"=>$return_num,
  977. "return_contactor"=>$contactor,
  978. "return_addr"=>$addr,
  979. "return_mobile"=>$mobile,
  980. "error_remark"=>$error_remark,
  981. "post_code"=>"",
  982. "post_company"=>"",
  983. "remark"=>$remark ,
  984. "apply_id"=>$userinfo['id'],
  985. "apply_name"=>$userinfo['nickname'],
  986. "status"=>0,
  987. "addtime"=>date("Y-m-d H:i:s"),
  988. "updatetime"=>date("Y-m-d H:i:s")
  989. ];
  990. $res = Db::name("purchease_return")->insert($data,true);
  991. if($res==false){
  992. Db::rollback();
  993. return error_show(1002,"验货审核失败");
  994. }
  995. $sto = ["order_code"=>$incode,"status"=>0,"action_remark"=>'',"action_type"=>"create"];
  996. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",0,$data);
  997. //维护台账记录
  998. // Db::name('standing_book')
  999. // ->where('wsm_in_code', $incode)
  1000. // ->update([
  1001. // 'cgdReturnCode' => $returnCode,
  1002. // 'updatetime' => date('Y-m-d H:i:s'),
  1003. // ]);
  1004. Db::execute("UPDATE `wsm_standing_book` SET `cgdReturnCode`=CONCAT(IFNULL(`cgdReturnCode`,''),',{$returnCode}'),`updatetime`='" . date('Y-m-d H:i:s') . "' WHERE FIND_IN_SET('{$incode}',`wsm_in_code`)");//这里的wsm_in_code可能有多个
  1005. }
  1006. Db::commit();
  1007. return app_show(0,"验货审核完成");
  1008. }
  1009. }catch (\Exception $e){
  1010. Db::rollback();
  1011. return error_show(1002,$e->getMessage());
  1012. }
  1013. }
  1014. public function ReturnSend(){
  1015. $incode = isset($this->post['wsm_in_code'])&&$this->post['wsm_in_code']!="" ? trim($this->post['wsm_in_code']) :"";
  1016. if($incode==""){
  1017. return error_show(1004,"参数wsm_in_code 不为空");
  1018. }
  1019. $info = Db::name("purchease_in")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1020. if(empty($info)){
  1021. return error_show(1004,"未找到发货单数据");
  1022. }
  1023. $return = Db::name("purchease_return")->where(['wsm_in_code'=>$incode,"is_del"=>0])->find();
  1024. if(empty($return)){
  1025. return error_show(1004,"未找到退货单数据");
  1026. }
  1027. $cgdinfo=Db::name("purchease_order")->where(['cgdNo'=>$info['cgdNo'],"is_del"=>0])->find();
  1028. if(empty($cgdinfo)){
  1029. Db::rollback();
  1030. return error_show(1002,"未找到采购单数据");
  1031. }
  1032. $post_code = isset($this->post['post_code']) &&$this->post['post_code']!=="" ? trim($this->post['post_code']):"" ;
  1033. if($post_code==""){
  1034. return error_show(1004,"参数 post_code 不能为空");
  1035. }
  1036. $post_company = isset($this->post['post_company']) &&$this->post['post_company']!=="" ? trim($this->post['post_company']):"" ;
  1037. if($post_company==""){
  1038. return error_show(1004,"参数 post_company 不能为空");
  1039. }
  1040. $remark = isset($this->post['remark']) &&$this->post['remark']!=="" ? trim($this->post['remark']):"" ;
  1041. $data=[
  1042. "post_code"=>$post_code,
  1043. "post_company"=>$post_company,
  1044. "remark"=>$remark,
  1045. "status"=>1,
  1046. "updatetime"=>date("Y-m-d H:i:s")
  1047. ];
  1048. Db::startTrans();
  1049. try{
  1050. $up =Db::name("purchease_return")->where($return)->save($data);
  1051. if($up){
  1052. $sto = ["order_code"=>$info['wsm_in_code'],"status"=>$return['status'],"action_remark"=>'', "action_type"=>"edit"];
  1053. ActionLog::logAdd($this->post['token'],$sto,"RKTHD",1,$this->post);
  1054. $ark=$info['status'];
  1055. $info['status']=6;
  1056. $info['updatetime']=date("Y-m-d H:i:s");
  1057. $sa=Db::name("purchease_in")->save($info);
  1058. if($sa){
  1059. $stn = ["order_code"=>$info['wsm_in_code'],"status"=>$ark,"action_remark"=>'',"action_type"=>"edit"];
  1060. ActionLog::logAdd($this->post['token'],$stn,"RKD",6,$info);
  1061. $process=["order_code"=>$info['wsm_in_code'],"order_id"=>$info['id'],"order_status"=>6,"order_type"=>'RKD',"before_status"=>$stn['status'],'holder_id' => $info['apply_id']];
  1062. ProcessOrder::AddProcess($this->post['token'],$process);
  1063. $good = Db::name("good_stock")->where(["wsm_code"=>$info['wsm_code'], "spuCode"=>$cgdinfo['spuCode'],"is_del"=>0])->find();
  1064. if(empty($good)) {
  1065. $good=[
  1066. "spuCode"=>$cgdinfo['spuCode'],
  1067. "wsm_code"=>$info['wsm_code'],
  1068. "usable_stock"=>0,
  1069. "wait_out_stock"=>0,
  1070. "wait_in_stock"=>$return['wsm_num'],
  1071. "total_stock"=>0,
  1072. "addtime"=>date("Y-m-d H:i:s"),
  1073. "updatetime"=>date("Y-m-d H:i:s"),
  1074. ];
  1075. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'',"action_type"=>"create"];
  1076. }else{
  1077. $order = ["order_code"=>$good['spuCode'],"status"=>1,"action_remark"=>'', "action_type"=>"edit"];
  1078. }
  1079. $good['wait_in_stock']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1080. $good['usable_stock']+=$return['wsm_num'];
  1081. $good['total_stock']=$good['usable_stock']+$good['wait_out_stock'];
  1082. $good['updatetime'] = date("Y-m-d H:i:s");
  1083. $upd= Db::name("good_stock")->save($good);
  1084. if($upd==false){
  1085. Db::rollback();
  1086. return error_show(1002,"库存更新失败");
  1087. }
  1088. $stockid=$good['id']?? Db::name("good_stock")->getLastInsID();
  1089. $bnin=GoodStockInfo::AddBn($stockid,$info['bnCode'],$return['wsm_num'],$cgdinfo['good_price']);
  1090. if($bnin==false){
  1091. Db::rollback();
  1092. return error_show(1004,"库存bn数据新增失败");
  1093. }
  1094. $good_data[]=['good_log_code' => $incode,"stock_id"=>$stockid,"type"=>1, 'stock'=>$info['wsm_num'],"stock_name"=>"usable_stock"];
  1095. $good_data[]=['good_log_code' => $incode,"stock_id"=>$stockid,"type"=>2, 'stock'=>$good['wait_in_stock'],"stock_name"=>"wait_in_stock"];
  1096. GoodLog::LogAdd($this->post['token'],$good_data,'RKD');
  1097. $order = ["order_code"=>$cgdinfo['cgdNo'],"status"=>$cgdinfo['status'],"action_remark"=>'',"action_type"=>"edit"];
  1098. $cgdinfo['wsend_num']-=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1099. $cgdinfo['send_num']+=$return['wsm_num']+$return['return_num']-$return['reissue_num'];
  1100. $cgdinfo['th_num']+=$return['return_num']-$return['reissue_num'];
  1101. $cgdinfo['th_fee']=round(($return['return_num']-$return['reissue_num'])*$cgdinfo['good_price'],2);
  1102. $cgdinfo['send_status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1103. $cgdinfo['status']=$cgdinfo['wsend_num']==0 ? 3:($cgdinfo['send_num']==0 ?1:2);
  1104. if($cgdinfo['th_num']==$cgdinfo['send_num']&& $cgdinfo['wsend_num']==0){
  1105. $cgdinfo['status']=4;
  1106. }
  1107. $cgdinfo['updatetime']=date("Y-m-d H:i:s");
  1108. $up=Db::name("purchease_order")->save($cgdinfo);
  1109. if($up==false){
  1110. Db::rollback();
  1111. return error_show(1004,"采购单数量更新失败");
  1112. }
  1113. $bk =Db::name("order_bk")->where(['cgdNo'=>$cgdinfo['cgdNo']])->lock(true)->find();
  1114. if($bk==false){
  1115. $bk=[
  1116. "cgdNo"=>$cgdinfo['cgdNo'],
  1117. "spuCode"=>$cgdinfo['spuCode'],
  1118. "companyNo"=>$cgdinfo['companyNo'],
  1119. "total_num"=>0,
  1120. "merge_num"=>0,
  1121. "balance_num"=>0,
  1122. "status"=>1,
  1123. "is_del"=>0,
  1124. 'addtime'=>date("Y-m-d H:i:s"),
  1125. "updatetime"=>date("Y-m-d H:i:s")
  1126. ];
  1127. }
  1128. $bk['balance_num']+=$return['wsm_num'];
  1129. $bk['total_num']+=$return['wsm_num'];
  1130. $bk['updatetime']=date("Y-m-d H:i:s");
  1131. $upcgd =Db::name("order_bk")->save($bk);
  1132. if($upcgd==false){
  1133. Db::rollback();
  1134. return error_show(1004,"采购单数量更新失败");
  1135. }
  1136. ActionLog::logAdd($this->post['token'],$order,"CGD", $cgdinfo['status'],$cgdinfo);
  1137. if($cgdinfo['status']==1 || $cgdinfo['status']==2){
  1138. // $orderinfo = Db::name('sale')
  1139. // ->alias('a')
  1140. // ->field('a.id,a.orderCode,a.is_stock,a.order_type,a.cgderid')
  1141. // ->leftJoin('order_num b','b.orderCode=a.orderCode')
  1142. // ->where([
  1143. // 'a.is_del'=>0,
  1144. // 'b.cgdNo'=>$cgdinfo['cgdNo'],
  1145. // ])->findOrEmpty();
  1146. $is_stock = Db::name('good_basic')
  1147. ->where(['is_del'=>0,'spuCode'=>$cgdinfo['spuCode']])
  1148. ->value('is_stock');
  1149. if($is_stock==1){
  1150. //库存品,推给31库管人员、41库管-张凯旋
  1151. $uid = Db::name('user_role')
  1152. ->where([
  1153. ['is_del', '=', 0],
  1154. ['roleid', 'in', [31, 41]],
  1155. ['status', '=', 1]
  1156. ])->column('uid');
  1157. $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0),'handle_user_list'=>implode(',', $uid)];
  1158. }elseif ($is_stock==0 || $cgdinfo['order_type']==3) {
  1159. $holder_id = Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0);
  1160. $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>$holder_id,'handle_user_list'=>$holder_id];//非库存品和采返商品,推给供应商负责人
  1161. }
  1162. }else $process=["order_code"=>$cgdinfo['cgdNo'],"order_id"=>$cgdinfo['id'],"order_status"=>$cgdinfo['status'],"order_type"=>'CGD',"before_status"=>$order['status'],'holder_id'=>Db::name('supplier')->where(['code' => $cgdinfo['supplierNo'], 'is_del' => 0])->value('personid', 0)];
  1163. ProcessOrder::AddProcess($this->post['token'],$process);
  1164. Db::commit();
  1165. return app_show(0,"退货发货成功");
  1166. }else{
  1167. Db::rollback();
  1168. return error_show(1004,"退货发货失败");
  1169. }
  1170. }else{
  1171. return error_show(1004,"退货发货失败");
  1172. }
  1173. }catch (\Exception $e){
  1174. Db::rollback();
  1175. return error_show(1004,$e->getMessage());
  1176. }
  1177. }
  1178. public function returnList(){
  1179. $page = isset($this->post['page']) && $this->post['page'] !=="" ? intval($this->post['page']):"1";
  1180. $size = isset($this->post['size']) && $this->post['size'] !=="" ? intval($this->post['size']):"10";
  1181. $where = [['a.is_del',"=",0],['b.is_del',"=",0]];
  1182. $cgdNo = isset($this->post['cgdNo']) && $this->post['cgdNo']!="" ? trim($this->post['cgdNo']):"";
  1183. if($cgdNo!=""){
  1184. $where[]=['a.cgdNo',"like", "%$cgdNo%"];
  1185. }
  1186. $returnCode= isset($this->post['returnCode']) && $this->post['returnCode']!="" ? trim($this->post['returnCode']):"";
  1187. if($returnCode!=""){
  1188. $where[]=['a.returnCode',"like", "%$returnCode%"];
  1189. }
  1190. $good_type_code=isset($this->post['good_type_code']) && $this->post['good_type_code']!==""? trim($this->post['good_type_code']):"";
  1191. if($good_type_code !=""){
  1192. $where[]= ["b.spuCode",'like',"%$good_type_code%"];
  1193. }
  1194. $good_name=isset($this->post['good_name']) && $this->post['good_name']!==""? trim($this->post['good_name']):"";
  1195. if($good_name !=""){
  1196. $where[]= ["b.good_name",'like',"%$good_name%"];
  1197. }
  1198. $status=isset($this->post['status']) && $this->post['status']!==""? trim($this->post['status']):"";
  1199. if($status!=""){
  1200. $where[]= ["a.status",'=',$status];
  1201. }
  1202. $count = Db::name('purchease_return')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  1203. ->where($where)->count();
  1204. $total = ceil($count / $size);
  1205. $page = $page >= $total ? $total : $page;
  1206. $list = Db::name('purchease_return')->alias('a')->join("purchease_order b","b.cgdNo=a.cgdNo","left")
  1207. ->where($where)->page($page,$size)
  1208. ->field("a.*,b.spuCode,b.good_price,b.order_type,b.good_price,b.total_fee,b.good_name")->order("a.addtime desc")
  1209. ->select();
  1210. $data=[];
  1211. foreach ($list as $value){
  1212. if($value['order_type']==3){
  1213. $goon = Db::name("good_zixun")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->find();
  1214. }else {
  1215. $goon =Db::name('good_basic')->where(['spuCode'=>$value['spuCode']])->find();
  1216. }
  1217. $value['can']= isset($goon['cat_id']) && $goon['cat_id'] !=0 ? made($goon['cat_id']):[];
  1218. $value['return_fee']= round($value['good_price']*$value['return_num'],2);
  1219. $data[]=$value;
  1220. }
  1221. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  1222. }
  1223. }