Purchin.php 83 KB

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