Project.php 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181
  1. <?php
  2. namespace app\admin\controller;
  3. use app\admin\model\ActionLog;
  4. use app\admin\model\DataGroup as DataGroupModel;
  5. use app\admin\model\ProcessOrder;
  6. use think\App;
  7. use think\facade\Db;
  8. //项目
  9. class Project extends Base
  10. {
  11. public function __construct(App $app)
  12. {
  13. parent::__construct($app);
  14. }
  15. public function create(){
  16. $name = isset($this->post['name'])&&$this->post['name']!=""? trim($this->post['name']):"";
  17. if($name==""){
  18. return error_show(1004,"参数name不能为空");
  19. }
  20. $platform = isset($this->post['platform'])&&$this->post['platform']!=""? trim($this->post['platform']):"";
  21. if($platform==""){
  22. return error_show(1004,"参数platform不能为空");
  23. }
  24. $khNo = isset($this->post['khNo'])&&$this->post['khNo']!=""?trim($this->post['khNo']):"";
  25. $companyNo = isset($this->post['companyNo'])&&$this->post['companyNo']!=""?trim($this->post['companyNo']):"";
  26. if($khNo==""){
  27. return error_show(1004,"参数khNo不能为空");
  28. }
  29. if($companyNo==""){
  30. return error_show(1004,"参数companyNo不能为空");
  31. }
  32. $use_desc = isset($this->post['use_desc'])&&$this->post['use_desc']!=""?trim($this->post['use_desc']):"";
  33. $budget_total = isset($this->post['budget_total'])&&$this->post['budget_total']!=""?floatval($this->post['budget_total']):"";
  34. $arrtime = isset($this->post['arrtime'])&&$this->post['arrtime']!=""?$this->post['arrtime']:"";
  35. $endtime = isset($this->post['endtime'])&&$this->post['endtime']!=""?$this->post['endtime']:"";
  36. if($use_desc==""){
  37. return error_show(1004,"参数use_desc不能为空");
  38. }
  39. if($budget_total==""){
  40. return error_show(1004,"参数budget_total不能为空");
  41. }
  42. if($arrtime==""){
  43. return error_show(1004,"参数arrtime不能为空");
  44. }
  45. if($endtime==""){
  46. return error_show(1004,"参数endtime不能为空");
  47. }
  48. $low_rate = isset($this->post['low_rate'])&&$this->post['low_rate']!=""?floatval($this->post['low_rate']):"0";
  49. // if($low_rate==""){
  50. // return error_show(1004,"参数low_rate不能为空");
  51. // }
  52. $ladder = isset($this->post['ladder'])&&!empty($this->post['ladder'])? $this->post['ladder']:"";
  53. if($ladder==""){
  54. return error_show(1004,"参数ladder不能为空");
  55. }
  56. $token = isset($this->post['token'])&& $this->post['token']!='' ? trim($this->post['token']):"";
  57. if($token==''){
  58. return error_show(105,"参数token不能为空");
  59. }
  60. $user =GetUserInfo($token);
  61. if(empty($user)||$user['code']!=0){
  62. return error_show(1002,"用户数据不存在");
  63. }
  64. $createrid= isset($user["data"]['id']) ? $user["data"]['id'] : "";
  65. $creater= isset($user["data"]['nickname']) ? $user["data"]['nickname'] : "";
  66. Db::startTrans();
  67. try {
  68. $projectNo = makeNo("PR");
  69. $data=[
  70. "projectNo"=>$projectNo,
  71. "platform_id"=>$platform,
  72. "khNo"=>$khNo,
  73. "companyNo"=>$companyNo,
  74. "project_name"=>$name,
  75. "budget_total"=>$budget_total,
  76. "use_desc"=>$use_desc,
  77. "low_rate"=>$low_rate,
  78. "creater"=>$creater,
  79. "createrid"=>$createrid,
  80. "arrtime"=>$arrtime,
  81. "endtime"=>$endtime,
  82. "status"=>1,
  83. "is_del"=>0,
  84. "addtime"=>date("Y-m-d H:i:s"),
  85. "updatetime"=>date("Y-m-d H:i:s")
  86. ];
  87. $pro=Db::name("project")->insertGetId($data);
  88. if($pro>0){
  89. if(!empty($ladder)){
  90. $la=[];
  91. foreach ($ladder as $value){
  92. $pgNo = makeNo("PI");
  93. $temp=[];
  94. $temp['pgNo']=$pgNo;
  95. $temp['projectNo']=$projectNo;
  96. $temp['good_type']=$value['good_type'];
  97. $temp['good_name']=$value['good_name'];
  98. $temp['good_img']=$value['good_img'];
  99. $temp['cat_id']=isset($value['cat_id'])?$value['cat_id']:0;
  100. $temp['budget_price']=$value['budget_price'];
  101. $temp['num']=$value['num'];
  102. $temp['creater']=$creater;
  103. $temp['createrid']=$createrid;
  104. $temp['status']=1;
  105. $temp['is_del']=0;
  106. $temp['addtime']=date("Y-m-d H:i:s");
  107. $temp['updatetime']=date("Y-m-d H:i:s");
  108. $in = Db::name("project_info")->insert($temp,true);
  109. if($in>0){
  110. ActionLog::logAdd(['id'=>$createrid,'nickname'=>$creater], [
  111. "order_code" => $pgNo,//编码,这里是project的编码
  112. "status" => 1,//这里的status是之前的值
  113. "action_remark" => '',//备注
  114. "action_type" => "create"//新建create,编辑edit,更改状态status
  115. ], "PRI", 1, $temp);
  116. }else{
  117. Db::rollback();
  118. return error_show(1004,"项目新建失败");
  119. }
  120. }
  121. //修改状态,添加待办
  122. ActionLog::logAdd(['id'=>$createrid,'nickname'=>$creater], [
  123. "order_code" => $projectNo,//项目编码
  124. "status" =>0,//这里的status是之前的值
  125. "action_remark" => '',//备注
  126. "action_type" => "create"//新建create,编辑edit更改状态status
  127. ], "PRT", 1, $this->post);
  128. $process = ["order_code" => $projectNo, "order_id" => Db::name("project")->getLastInsID(), "order_status" =>1, "order_type" => 'PRT',"before_status"=>1];//order_status==7修改毛利率
  129. ProcessOrder::AddProcess(['id'=>$createrid,'nickname'=>$creater], $process);
  130. //修改状态,添加待办,只记录动作
  131. ActionLog::logAdd(['id'=>$createrid,'nickname'=>$creater], [
  132. "order_code" => $projectNo,//编码,这里是project的编码
  133. "status" => 1,//这里的status是之前的值
  134. "action_remark" => '',//备注
  135. "action_type" => "create"//新建create,编辑edit,更改状态status
  136. ], "PRO", 1, $this->post);
  137. $process = ["order_code" => $projectNo, "order_id" => $pro, "order_status" =>1, "order_type" =>"PRO","before_status"=>1,'holder_id'=>$data['createrid']];
  138. ProcessOrder::AddProcess(['id'=>$createrid,'nickname'=>$creater], $process);
  139. //台账记录
  140. Db::name('standing_book')
  141. ->insert([
  142. 'standBookNo' => makeNo("IO"),
  143. 'projectNo' => $projectNo,
  144. 'companyNo' => $companyNo,
  145. 'customer_code' => $khNo,
  146. 'addtime' => date('Y-m-d H:i:s'),
  147. 'updatetime' => date('Y-m-d H:i:s')
  148. ]);
  149. Db::commit();
  150. return app_show(0,"项目新建成功",['projectNo'=>$projectNo]);
  151. }
  152. }
  153. Db::rollback();
  154. return error_show(1004,"项目新建失败");
  155. }catch (\Exception $e){
  156. Db::rollback();
  157. return error_show(1004,$e->getMessage());
  158. }
  159. }
  160. public function addfeed(){
  161. $pgNo =isset($this->post['pgNo']) && $this->post['pgNo']!=""? trim($this->post['pgNo']):"";
  162. if($pgNo==""){
  163. return error_show(1004,"参数pgNo不能为空");
  164. }
  165. $projectinfo = Db::name("project_info")->where(["pgNo"=>$pgNo,"is_del"=>0])->find();
  166. if($projectinfo==false){
  167. return error_show(1004,"未找到项目阶梯信息");
  168. }
  169. $project = Db::name("project")->where(["projectNo"=>$projectinfo['projectNo'],"is_del"=>0])->find();
  170. if($project==false){
  171. return error_show(1004,"未找到项目阶梯信息");
  172. }
  173. $spuCode =isset($this->post['spuCode'])&&!empty($this->post['spuCode']) ?$this->post['spuCode']:"";
  174. if($spuCode==""){
  175. return error_show(1004,"参数spuCode不能为空");
  176. }
  177. $source =isset($this->post['source'])&&$this->post['source']!=="" ?intval($this->post['source']):"1";
  178. if($source==""){
  179. return error_show(1004,"参数source不能为空");
  180. }
  181. $good=[];
  182. if($source==1){
  183. $good=Db::name("good_platform")->alias("a")->leftJoin("good b","a.spuCode=b.spuCode")->where
  184. (["a.skuCode"=>$spuCode,"a.is_del"=>0])->select()->toArray();
  185. if(empty($good)){
  186. return error_show(1004,"未找到商品信息");
  187. }
  188. }else{
  189. $good=Db::name("consult_bids")->where(["spuCode"=>$spuCode,"is_del"=>0])->select()->toArray();
  190. if(empty($good)){
  191. return error_show(1004,"未找到商品信息");
  192. }
  193. }
  194. $token = isset($this->post['token'])&& $this->post['token']!='' ? trim($this->post['token']):"";
  195. if($token==''){
  196. return error_show(105,"参数token不能为空");
  197. }
  198. $user =GetUserInfo($token);
  199. if(empty($user)||$user['code']!=0){
  200. return error_show($user['code'],"用户数据不存在");
  201. }
  202. $createrid= isset($user["data"]['id']) ? $user["data"]['id'] : "";
  203. $creater= isset($user["data"]['nickname']) ? $user["data"]['nickname'] : "";
  204. Db::startTrans();
  205. try{
  206. $data=[];
  207. foreach ($good as $value){
  208. $temp=[];
  209. $temp['spuCode']=$value['spuCode'];
  210. $temp['skuCode']=isset($value['skuCode'])?$value['skuCode']:"";
  211. $temp['pgNo']=$projectinfo['pgNo'];
  212. $temp['projectNo']=$projectinfo['projectNo'];
  213. $temp['good_name']=$value['good_name'];
  214. $temp['good_type']=$projectinfo['good_type'];
  215. $temp['data_source']=$source;
  216. $temp['cat_id']=$value['cat_id'];
  217. $temp['budget_price']=$projectinfo['budget_price'];
  218. if($source==1){
  219. $ladd = Db::name("good_ladder")->where([["skuCode","=",$value['skuCode']],["min_num","<=",
  220. $projectinfo["num"]],["status","=",1],["is_del","=",0]])->order("min_num desc")->find();
  221. $nake =Db::name("good_nake")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->where([["min_num","<=",$projectinfo['num']]])
  222. ->order("min_num desc")->find();
  223. $origin_price=isset($nake['nake_total'])?$nake['nake_total']:"0" ;
  224. $sale_price = $ladd['sale_price'];
  225. if($value['is_gold_price']==1 && $value['is_stock']!=1){
  226. $gold = Db::name("gold_price1")
  227. ->field('id,price')
  228. ->where(["type" => $value['noble_metal'], "is_del" => 0, "status" => 1])
  229. ->order("addtime desc")
  230. ->find();
  231. //$saleprice(最终售价) = (打样费/购买数量 + 开模费/购买数量 + 商品重量* 最新金价 + 工艺费* 商品重量+包装费+加标费+证书费+产品裸价+物流费)/(1-成本售价/100);
  232. $sale_price = ($value['demo_fee'] / $projectinfo["num"] + $value['open_fee'] / $projectinfo["num"]
  233. + $value['noble_weight'] * $gold["price"] + $ladd['cost_fee'] * $value['noble_weight'] + $nake['package_fee'] + $nake['mark_fee'] + $nake['cert_fee'] + $nake['nake_fee'] + $nake['delivery_fee']);
  234. }
  235. }else{
  236. $sale_price =$value['sale_price'];
  237. $origin_price =$value['sale_price'];
  238. }
  239. $temp['sale_price']=$sale_price;
  240. $temp['origin_price']=$origin_price;
  241. $temp['num']=$projectinfo['num'];
  242. $temp['status']=0;
  243. $temp['is_del']=0;
  244. $temp['creater']=$creater;
  245. $temp['createrid']=$createrid;
  246. $temp['addtime']=date("Y-m-d H:i:s");
  247. $temp['updatetime']=date("Y-m-d H:i:s");
  248. $data[]=$temp;
  249. }
  250. $nu = Db::name("project_feedback")->insertAll($data);
  251. if($nu>0){
  252. $old_projectinfo_status = $projectinfo['status'];
  253. $projectinfo['status']=2;
  254. $projectinfo['updatetime']=date("Y-m-d H:i:s");
  255. $up = Db::name("project_info")->save($projectinfo);
  256. if($up){
  257. //修改状态,添加待办,只记录动作
  258. ActionLog::logAdd($this->post['token'], [
  259. "order_code" => $pgNo,//编码,这里是project的编码
  260. "status" => $old_projectinfo_status,//这里的status是之前的值
  261. "action_remark" => '',//备注
  262. "action_type" => "status"//新建create,编辑edit,更改状态status
  263. ], "PRI", 2, $projectinfo);
  264. $count = Db::name("project_info")->where(["projectNo"=>$projectinfo['projectNo'],"status"=>1])
  265. ->count();
  266. if($count==0){
  267. $proc =Db::name("project")->where(["projectNo"=>$projectinfo['projectNo'],"status"=>1])->save
  268. (["status"=>2,"updatetime"=>date("Y-m-d H:i:s")]);
  269. if($proc){
  270. //修改状态,添加待办
  271. ActionLog::logAdd($this->post['token'], [
  272. "order_code"=>$projectinfo['projectNo'],//项目编码
  273. "status"=>1,//这里的status是之前的值
  274. "action_remark"=>'',//备注
  275. "action_type"=>"status"//新建create,编辑edit,更改状态status
  276. ],"PRO",2,["status"=>2,"updatetime"=>date("Y-m-d H:i:s")]);
  277. ProcessOrder::AddProcess($this->post['token'],[
  278. "order_type"=>'PRO',
  279. "order_code"=>$projectinfo['projectNo'],
  280. "order_id"=>$project['id'],//这里更新是根据编码更新的,没有主键id
  281. "order_status"=>2,
  282. "before_status"=>1,
  283. 'holder_id'=>$project['createrid']
  284. ]);
  285. Db::commit();
  286. return app_show(0,"添加成功");
  287. }
  288. }
  289. }
  290. Db::commit();
  291. return app_show(0,"添加成功");
  292. }else{
  293. Db::rollback();
  294. return error_show(1004,"添加失败");
  295. }
  296. }catch (\Exception $e){
  297. Db::rollback();
  298. return error_show(1004,$e->getMessage());
  299. }
  300. }
  301. public function list()
  302. {
  303. $param = $this->request->only([
  304. 'page' => 1,
  305. 'size' => 10,
  306. 'khNo' => '',
  307. 'project_name' => '',
  308. 'status' => '',
  309. 'start' => '',
  310. 'end' => '',
  311. 'low' => '',
  312. 'up' => '',
  313. 'companyNo' => '',
  314. 'relaComNo' => '',
  315. 'platform_id' => '',
  316. 'company_name' => '',
  317. ], 'post', 'trim');
  318. // $page =isset($this->post['page'])&&$this->post['page']!=="" ? intval($this->post['page']):1;
  319. // $size =isset($this->post['size'])&&$this->post['size']!==""? intval($this->post['size']):10;
  320. $where = [["p.is_del", "=", 0]];
  321. // $khNo = isset($this->post['khNo']) &&$this->post['khNo']!==""? trim($this->post['khNo']):"";
  322. if ($param['khNo'] !== "") $where[] = ["p.khNo", "=", $param['khNo']];
  323. // $project_name = isset($this->post['project_name']) &&$this->post['project_name']!==""? trim($this->post['project_name']):"";
  324. if ($param['project_name'] !== "") $where[] = ["p.project_name", "like", '%' . $param['project_name'] . '%'];
  325. // $status = isset($this->post['status']) &&$this->post['status']!==""? intval($this->post['status']):"";
  326. if ($param['status'] !== "") $where[] = ["p.status", "=", $param['status']];
  327. // $start = isset($this->post['start'])&&$this->post['start']!=="" ? $this->post['start']:"";
  328. if ($param['start'] !== '') $where[] = ["p.addtime", ">=", $param['start']];
  329. // $end = isset($this->post['end'])&&$this->post['end']!=="" ? $this->post['end']:"";
  330. if ($param['end'] !== '') $where[] = ["p.addtime", "<=", $param['end']];
  331. // $low = isset($this->post['low'])&&$this->post['low']!=="" ? floatval($this->post['low']):"";
  332. if ($param['low'] !== '') $where[] = ["p.budget_total", ">=", $param['low']];
  333. // $up = isset($this->post['up'])&&$this->post['up']!=="" ? floatval($this->post['up']):"";
  334. if ($param['up'] !== '') $where[] = ["p.budget_total", "<=", $param['up']];
  335. // $companyNo = isset($this->post['companyNo'])&&$this->post['companyNo']!=="" ? trim($this->post['companyNo']):"";
  336. if ($param['companyNo'] !== '') $where[] = ["p.companyNo", "like", '%' . $param['companyNo'] . '%'];
  337. // $relaComNo = isset($this->post['relaComNo']) && $this->post['relaComNo'] !== "" ? trim($this->post['relaComNo']) : "";
  338. if ($param['relaComNo'] != '') $where[] = ["p.companyNo", "=", $param['relaComNo']];
  339. // $platform_id = isset($this->post['platform_id'])&&$this->post['platform_id']!=="" ? intval($this->post['platform_id']):"";
  340. if ($param['platform_id'] !== '') $where[] = ["p.platform_id", "=", $param['platform_id']];
  341. // $company_name = isset($this->post['company_name'])&&$this->post['company_name']!=="" ? trim($this->post['company_name']):"";
  342. if ($param['company_name'] !== '') $where[] = ["p.createrid", 'in', get_company_item_user_by_name($param['company_name'])];
  343. // $role=$this->checkRole();
  344. // if(!empty($role['write'])){
  345. // $where[]=["p.createrid","in",$role['write']];
  346. // }
  347. // $role = $this->checkDataShare();
  348. // if (!empty($role[DataGroupModel::$type_全部])) $where[] = ['p.createrid', 'in', $role[DataGroupModel::$type_全部]];
  349. $role = $this->checkDataShare();
  350. $hand = resign_hand_user($this->uid, 0);
  351. if (!empty($role[DataGroupModel::$type_全部])) {
  352. $arr = array_unique(array_merge($hand, $role[DataGroupModel::$type_全部]));
  353. $where[] = ['p.createrid', 'in', $arr];
  354. }
  355. // if(!empty($role['platform'])){
  356. // $where[]=["p.platform_id","in",$role['platform']];
  357. // }
  358. $count = Db::name('project')
  359. ->alias('p')
  360. ->where($where)
  361. ->count();
  362. $list = Db::name('project')
  363. ->alias('p')
  364. ->field('p.*,b.platform_name,b.platform_code')
  365. ->leftJoin('platform b', 'b.id=p.platform_id')
  366. ->where($where)
  367. ->page($param['page'], $param['size'])
  368. ->order("p.addtime desc")
  369. ->select()
  370. ->toArray();
  371. //所有创建人及所属部门
  372. $all_createrid = array_column($list, 'createrid');
  373. $item = get_company_name_by_uid($all_createrid);
  374. //所有公司编码
  375. $all_code = array_merge(array_column($list, 'khNo'), array_column($list, 'companyNo'));
  376. $headquarters = get_headquarters_code_and_name($all_code);
  377. $data = [];
  378. foreach ($list as $value) {
  379. // $info = Db::name("platform")->where(['id'=>$value['platform_id']])->find();
  380. // $value['platform_name']=isset($info['platform_name'])?$info['platform_name']:"";
  381. // $value['platform_code']=isset($info['platform_code'])?$info['platform_code']:"";
  382. // $khinfo = Db::name("customer_info")->where(["companyNo"=>$value['khNo']])->find();
  383. $value['khName'] = $headquarters[$value['khNo']] ?? '';//isset($khinfo['companyName'])?$khinfo['companyName']:"";
  384. // $company = Db::name("business")->where(["companyNo"=>$value['companyNo']])->find();
  385. $value['company'] = $headquarters[$value['companyNo']] ?? '';//isset($company['company'])?$company['company']:"";
  386. $value['company_name'] = $item[$value['createrid']];
  387. //是否具有编辑权限
  388. $value['is_allow_update'] = 0;
  389. if (in_array($this->roleid, [1, 33]) || in_array($value['createrid'], $role[DataGroupModel::$type_可编辑])) $value['is_allow_update'] = 1;
  390. $data[] = $value;
  391. }
  392. return app_show(0, "获取成功", ['list' => $data, 'count' => $count]);
  393. }
  394. public function feedlist(){
  395. $page =isset($this->post['page'])&&$this->post['page']!=="" ? intval($this->post['page']):1;
  396. $size =isset($this->post['size'])&&$this->post['size']!==""? intval($this->post['size']):10;
  397. $where=[["is_del","=",0]];
  398. $pgNo =isset($this->post['pgNo'])&&$this->post['pgNo']!==""?trim($this->post['pgNo']):"";
  399. if($pgNo!==""){
  400. $where[]=["pgNo","=",$pgNo];
  401. }
  402. $projectNo =isset($this->post['projectNo'])&&$this->post['projectNo']!==""?trim($this->post['projectNo']):"";
  403. if($projectNo!==""){
  404. $where[]=["projectNo","=",$projectNo];
  405. }
  406. $source =isset($this->post['source'])&&$this->post['source']!==""?intval($this->post['source']):"";
  407. if($source!==""){
  408. $where[]=["data_source","=",$source];
  409. }
  410. $cat_id =isset($this->post['cat_id'])&&$this->post['cat_id']!==""?intval($this->post['cat_id']):"";
  411. if($cat_id!==""){
  412. $where[]=["cat_id","=",$cat_id];
  413. }
  414. $status =isset($this->post['status'])&&$this->post['status']!==""?intval($this->post['status']):"";
  415. if($status!==""){
  416. $where[]=["status","=",$status];
  417. }
  418. $count = Db::name('project_feedback')->where($where)->count();
  419. $total = ceil($count / $size);
  420. $page = $page >= $total ? $total : $page;
  421. $list = Db::name('project_feedback')->where($where)->page($page,$size)->order("addtime desc")->select();
  422. $data=[];
  423. foreach ($list as $value){
  424. $value['can']=isset($value['cat_id'])&&$value['cat_id']!=""?made($value['cat_id']):"";
  425. if($value['data_source']==1){
  426. $good=Db::name("good_platform")->alias("a")->leftJoin("good b","a.spuCode=b.spuCode")->where
  427. (["a.skuCode"=>$value['skuCode'],"a.is_del"=>0])->find();
  428. $nake = Db::name("good_nake")->where([["spuCode","=",$value['spuCode']],["min_num","<=",
  429. $value["num"]],["is_del","=",0]])->order("min_num desc")->find();
  430. $good['unit_id'] = isset($good['good_unit'])?$good['good_unit']:"";
  431. $good['cost_desc'] = isset($good['craft_desc'])?$good['craft_desc']:"";
  432. $good['pakge_fee'] = isset($nake['package_fee'])?$nake['package_fee']:"0";
  433. $good['mark_fee'] = isset($nake['mark_fee'])?$nake['mark_fee']:"0";
  434. $good['other_fee'] = isset($nake['other_fee'])?$nake['other_fee']:"0";
  435. $good['cert_fee'] = isset($nake['cert_fee'])?$nake['cert_fee']:"0";
  436. $good['delivery_fee'] = isset($nake['delivery_fee'])?$nake['delivery_fee']:"0";
  437. $good['nake_fee'] = isset($nake['nake_fee'])?$nake['nake_fee']:"0";
  438. $good['metal_id'] = isset($good['noble_metal'])?$good['noble_metal']:"0";
  439. $spec = Db::name("good_spec")->where(["spuCode"=>$good['spuCode'],"is_del"=>0])->select()->toArray();
  440. $good['specinfo']=[];
  441. if(!empty($spec)){
  442. foreach ($spec as $vae){
  443. $specs=Db::name("specs")->where(["id"=>$vae['spec_id']])->find();
  444. $spec_value = Db::name("spec_value")->where(["id"=>$vae["spec_value_id"]])->find();
  445. $temp = ["specid"=>$vae['spec_id'],"spec_name"=>$specs['spec_name'],"spec_value_id"=>$vae['spec_value_id'],"spec_value_name"=>$spec_value["spec_value"]];
  446. $good['specinfo'][]=$temp;
  447. }
  448. }
  449. $nake =Db::name("good_nake")->where(["spuCode"=>$good['spuCode'],"is_del"=>0])->where([["min_num","<=",$value['num']]])
  450. ->order("min_num desc")->find();
  451. $good['origin_price']=$nake['nake_total'];
  452. $good['work_day']=$good['lead_time'];
  453. $good_img = $good['good_thumb_img'];
  454. }else{
  455. $good=Db::name("consult_bids")->where(["spuCode"=>$value['spuCode'],"is_del"=>0])->find();
  456. $good['specinfo'] = isset($good['specinfo'])&&$good['specinfo']!=""?json_decode($good['specinfo'],
  457. true):"";
  458. $catinfo = Db::name("cat")->where(["id"=>$good['cat_id']])->find();
  459. $budget = isset($catinfo['order_rate']) ? $catinfo['order_rate']:100;
  460. $good_img = $good['good_img'];
  461. }
  462. $nobel =\think\facade\Config::get("noble");
  463. $value['good_name'] = isset($good['good_name'])?$good['good_name']:"";
  464. // $value['good_img'] = isset($good['good_img'])?$good['good_img']:"";
  465. $value['brand_id'] = isset($good['brand_id'])?$good['brand_id']:"";
  466. $brand = Db::name("brand")->where(['id'=>$value["brand_id"]])->find();
  467. $value['brand_name'] =isset($brand['brand_name']) ? $brand['brand_name']:"";
  468. $value['specinfo'] = isset($good['specinfo'])&&$good['specinfo']!=""?$good['specinfo']:[];
  469. $value['unit_id'] = isset($good['unit_id'])?$good['unit_id']:"";
  470. $unit = Db::name("unit")->where(['id'=>$value["unit_id"]])->find();
  471. $value["unit_name"]=isset($unit['unit'])?$unit['unit']:"";
  472. $value['cost_desc'] = isset($good['cost_desc'])?$good['cost_desc']:"";
  473. $value['work_day'] = isset($good['work_day'])?$good['work_day']:"";
  474. $value['delivery_day'] = isset($good['delivery_day'])?$good['delivery_day']:"";
  475. $value['expire_day'] = isset($good['expire_day'])?$good['expire_day']:"0";
  476. $value['good_img'] = $good_img;
  477. $value['expire_day'] = isset($good['expire_day'])?$good['expire_day']:"";
  478. $value['origin_place'] = isset($good['origin_place'])?$good['origin_place']:"";
  479. $value['supplierNo'] = isset($good['supplierNo'])?$good['supplierNo']:"";
  480. $value['pay_way'] = isset($good['pay_way'])?$good['pay_way']:"";
  481. $value['tax'] = isset($good['tax'])?$good['tax']:"";
  482. $value['send_way'] = isset($good['send_way'])?$good['send_way']:"";
  483. $value['metal_id'] = isset($good['metal_id'])?$good['metal_id']:"";
  484. $value['metal_name'] = isset($nobel[$good['metal_id']])?$nobel[$good['metal_id']]:"";
  485. $value['is_gold_price'] = isset($good['is_gold_price'])?$good['is_gold_price']:"0";
  486. $value['config'] = isset($good['config'])?$good['config']:"";
  487. $value['other_config'] = isset($good['other_config'])?$good['other_config']:"";
  488. $value['weight'] = isset($good['weight'])?$good['weight']:"";
  489. $value['is_diff'] = isset($good['is_diff'])?$good['is_diff']:"0";
  490. $value['demo_fee'] = isset($good['demo_fee'])?$good['demo_fee']:"0";
  491. $value['deivery_fee'] = isset($good['deivery_fee'])?$good['deivery_fee']:"0";
  492. $value['open_fee'] = isset($good['open_fee'])?$good['open_fee']:"0";
  493. $value['pakge_fee'] = isset($good['pakge_fee'])?$good['pakge_fee']:"0";
  494. $value['nake_fee'] = isset($good['nake_fee'])?$good['nake_fee']:"0";
  495. $value['mark_fee'] = isset($good['mark_fee'])?$good['mark_fee']:"0";
  496. $value['cert_fee'] = isset($good['cert_fee'])?$good['cert_fee']:"0";
  497. $value['cost_fee'] = isset($good['cost_fee'])?$good['cost_fee']:"0";
  498. $value['rate'] = $value['sale_price'] == 0 ? 0 : round(($value['sale_price'] - $value['origin_price']) / $value['sale_price'] * 100, 2);
  499. $value['supply_area'] = isset($good['supply_area'])?$good['supply_area']:"";
  500. $data[]=$value;
  501. }
  502. return app_show(0,"获取成功",['list'=>$data,'count'=>$count]);
  503. }
  504. public function info(){
  505. $projectNo = isset($this->post['projectNo'])&&$this->post['projectNo']!==""?trim($this->post['projectNo']):"";
  506. if($projectNo==""){
  507. return error_show(1004,"参数projectNo不能为空");
  508. }
  509. $type = isset($this->post['type'])&&$this->post['type']!=="" ? intval($this->post['type']) :0;
  510. $info =Db::name("project")->where(["projectNo"=>$projectNo,"is_del"=>0])->find();
  511. if($info==false){
  512. return error_show(1004,"未找到项目信息");
  513. }
  514. $plat = Db::name("platform")->where(['id'=>$info['platform_id']])->find();
  515. $info['platform_name']=isset($plat['platform_name'])?$plat['platform_name']:"";
  516. $info['platform_code']=isset($plat['platform_code'])?$plat['platform_code']:"";
  517. $khinfo = Db::name("customer_info")->where(["companyNo"=>$info['khNo']])->find();
  518. $info['khName'] = isset($khinfo['companyName'])?$khinfo['companyName']:"";
  519. $company = Db::name("business")->where(["companyNo"=>$info['companyNo']])->find();
  520. $info['company'] = isset($company['company'])?$company['company']:"";
  521. $ladder = Db::name("project_info")->where(['projectNo'=>$projectNo,"is_del"=>0])->select()->toArray();
  522. $info['ladder']=[];
  523. if(!empty($ladder)){
  524. foreach ($ladder as $value){
  525. $value["cat_info"]=isset($value['cat_id']) &&$value['cat_id']!=""? made($value['cat_id'],[]):[];
  526. $condition = $type==0?['pgNo'=>$value['pgNo'],"is_del"=>0] : ['pgNo'=>$value['pgNo'],"is_del"=>0,"status"=>1];
  527. $feedback = Db::name("project_feedback")->where($condition)->select()->toArray();
  528. array_walk($feedback,function (&$v){
  529. $v["cat_info"]=isset($v['cat_id'])&&$v['cat_id']!=""? made($v['cat_id'],[]):[];
  530. });
  531. // $zx = Db::name("consult_info")->where(["pgNo"=>$value["pgNo"],"is_del"=>0,"bargain_status"=>0])
  532. // ->column("infoNo");
  533. // if(!empty($zx)){
  534. // $zxback = Db::name("consult_bids")->where(["infoNo"=>$zx,"is_del"=>0])->select()->toArray();
  535. // array_walk($zxback,function (&$v){
  536. // $v["cat_info"]=isset($v['cat_id'])? made($v['cat_id'],[]):[];
  537. // });
  538. // }else{
  539. // $zxback=[];
  540. // }
  541. $value['feedback']=$feedback;
  542. // $value['zxback']=$zxback;
  543. $info['ladder'][]=$value;
  544. }
  545. }
  546. return app_show(0,"获取成功",$info);
  547. }
  548. public function plan_create(){
  549. $projectNo = isset($this->post['projectNo'])&&$this->post['projectNo']!==""?trim($this->post['projectNo']):"";
  550. if($projectNo==""){
  551. return error_show(1004,"参数projectNo不能为空");
  552. }
  553. $info =Db::name("project")->where(["projectNo"=>$projectNo,"is_del"=>0])->find();
  554. if($info==false){
  555. return error_show(1004,"未找到项目信息");
  556. }
  557. if($info['low_rate']<=0){
  558. return error_show(1004,"项目毛利未设置");
  559. }
  560. if($info['status']!=3 && $info['status']!=4){
  561. return error_show(1004,"项目状态有误");
  562. }
  563. $feedback =isset($this->post['feedback'])&&!empty($this->post['feedback'])?$this->post['feedback']:"";
  564. if($feedback==""){
  565. return error_show(1004,"参数feedback不能为空");
  566. }
  567. $feedid =array_column($feedback,"feedid");
  568. $feedinfo = Db::name("project_feedback")->where(['id'=>$feedid,"projectNo"=>$projectNo,"is_del"=>0])
  569. ->select()->toArray();
  570. if(empty($feedinfo)){
  571. return error_show(1004,"反馈数据未找到");
  572. }
  573. $token = isset($this->post['token'])&& $this->post['token']!='' ? trim($this->post['token']):"";
  574. if($token==''){
  575. return error_show(105,"参数token不能为空");
  576. }
  577. $user =GetUserInfo($token);
  578. if(empty($user)||$user['code']!=0){
  579. return error_show(1002,"用户数据不存在");
  580. }
  581. $createrid= isset($user["data"]['id']) ? $user["data"]['id'] : "";
  582. $creater= isset($user["data"]['nickname']) ? $user["data"]['nickname'] : "";
  583. Db::startTrans();
  584. try {
  585. $planNo=makeNo("PL");
  586. $total=0;
  587. $num_t=0;
  588. $origia=0;
  589. $dl=[];
  590. foreach ($feedinfo as $value){
  591. $key =array_search($value['id'],$feedid);
  592. $price = $feedback[$key];
  593. // if($price['sale_price']<$value['origin_price']){
  594. // Db::rollback();
  595. // return error_show(1004,"反馈商品价格不能小于初始金额");
  596. // }
  597. if($price['good_num']<$value['num']){
  598. Db::rollback();
  599. return error_show(1004,"商品数量不能小于初始数量");
  600. }
  601. if($value['data_source']==2){
  602. $bids =Db::name("consult_info")->where(["pgNo"=>$value['pgNo'],"is_del"=>0])->find();
  603. if($bids==false){
  604. Db::rollback();
  605. return error_show(1004,"未找到反馈商品咨询单");
  606. }
  607. $old_bids_status = $bids["status"];
  608. $bids["status"]=3;
  609. $bids["updatetime"]=date("Y-m-d H:i:s");
  610. $bd=Db::name("consult_info")->save($bids);
  611. if($bd==false){
  612. Db::rollback();
  613. return error_show(1004,"反馈商品咨询单更新失败");
  614. }else{
  615. //修改状态,添加待办
  616. ActionLog::logAdd($this->post['token'], [
  617. "order_code" => $bids['infoNo'],//咨询单详情编号
  618. "status" => $old_bids_status,//这里的status是之前的值
  619. "action_remark" => '',//备注
  620. "action_type" => "status"//新建create,编辑edit,更改状态status
  621. ], "ZXD", 3, $bids);
  622. }
  623. }
  624. // $value['sale_price'] = $price['sale_price'];
  625. // $value['updatetime'] = date("Y-m-d H:i:s");
  626. // $cre=Db::name("project_feedback")->save($value);
  627. // if($cre==false){
  628. // Db::rollback();
  629. // return error_show(1004,"反馈商品价格修改失败");
  630. // }
  631. $temp=[];
  632. $temp['planNo']=$planNo;
  633. $temp['feedback_id']=$value['id'];
  634. $temp['sale_price']=$price["sale_price"];
  635. $temp['sale_num']=$price["good_num"];
  636. $temp['status']=1;
  637. $temp['is_del']=0;
  638. $temp['addtime']=date("Y-m-d H:i:s");
  639. $temp['updatetime']=date("Y-m-d H:i:s");
  640. $total+=$price['good_num']*$price["sale_price"];
  641. $origia+=$price['good_num']*$value["origin_price"];
  642. $num_t+=$price['good_num'];
  643. $dl[]=$temp;
  644. }
  645. $rate = round(($total-$origia)/$total,4)*100;
  646. if($rate<$info['low_rate']){
  647. Db::rollback();
  648. return error_show(1004,"方案毛利不能低于最低项目毛利率");
  649. }
  650. $inn=Db::name("project_plan_rela")->insertAll($dl);
  651. if($inn>0){
  652. $data=[
  653. "planNo"=>$planNo,
  654. "projectNo"=>$projectNo,
  655. "createrid"=>$createrid,
  656. "creater"=>$creater,
  657. "sale_total"=>round($total,2),
  658. "total_num"=>$num_t,
  659. "origin_total"=>round($origia,2),
  660. "sale_rate"=>$rate,
  661. "status"=>0,
  662. "is_del"=>0,
  663. "addtime"=>date("Y-m-d H:i:s"),
  664. "updatetime"=>date("Y-m-d H:i:s")
  665. ];
  666. $up =Db::name("project_plan")->insert($data);
  667. if($up){
  668. $old_project_status = $info['status'];
  669. $info['status']=4;
  670. $info['updatetime']=date("Y-m-d H:i:s");
  671. $cr =Db::name("project")->save($info);
  672. if($cr){
  673. //修改状态,添加待办
  674. ActionLog::logAdd($this->post['token'], [
  675. "order_code" => $projectNo,//项目编码
  676. "status" => $old_project_status,//这里的status是之前的值
  677. "action_remark" => '',//备注
  678. "action_type" => "status"//新建create,编辑edit,更改状态status
  679. ], "PRO", 4, $info);
  680. ProcessOrder::AddProcess($this->post['token'], [
  681. "order_type" => 'PRO',
  682. "order_code" => $projectNo,
  683. "order_id" => $info['id'],
  684. "order_status" => 4,
  685. "before_status"=>$old_project_status,
  686. 'holder_id'=>$info['createrid']
  687. ]);
  688. Db::commit();
  689. return app_show(0,"方案制作成功",["planNo"=>$planNo]);
  690. }
  691. }
  692. }
  693. Db::rollback();
  694. return error_show(1004,"方案制作失败");
  695. }catch (\Exception $e){
  696. Db::rollback();
  697. return error_show(1004,$e->getMessage());
  698. }
  699. }
  700. public function planinfo(){
  701. $planNo = isset($this->post['planNo'])&& $this->post['planNo']!==""?trim($this->post["planNo"]):"";
  702. if($planNo==""){
  703. return error_show(1004,"参数planNo不能为空");
  704. }
  705. $plan = Db::name("project_plan")->where(["planNo"=>$planNo,"is_del"=>0])->find();
  706. if($plan==false){
  707. return error_show(1004,"未找到项目方案信息");
  708. }
  709. $plan['feedback']=[];
  710. $feedback =Db::name("project_plan_rela")->where(["planNo"=>$planNo,"is_del"=>0])->column("feedback_id,sale_price,sale_num");
  711. if(!empty($feedback)){
  712. $feedid = array_column($feedback,"feedback_id");
  713. $feedlist = Db::name("project_feedback")->where(["id"=>$feedid,"is_del"=>0])->select();
  714. if(!empty($feedlist)){
  715. foreach ($feedlist as $value){
  716. $key =array_search($value['id'],$feedid);
  717. $price = $feedback[$key]['sale_price'];
  718. $value["cat_info"]=isset($value['cat_id'])&&$value['cat_id']!=""? made($value['cat_id'],[]):[];
  719. $value["sale_price"]=$price;
  720. $value["origin_num"]=$value['num'];
  721. $value["num"]=$feedback[$key]['sale_num'];
  722. $plan['feedback'][]=$value;
  723. }
  724. }
  725. }
  726. return app_show(0,"获取成功",$plan);
  727. }
  728. public function project_plan(){
  729. $projectNo = isset($this->post['projectNo'])&&$this->post['projectNo']!==""?trim($this->post['projectNo']):"";
  730. if($projectNo==""){
  731. return error_show(1004,"参数projectNo不能为空");
  732. }
  733. $type = isset($this->post['type'])&&$this->post['type']!=="" ? intval($this->post['type']) :0;
  734. $info =Db::name("project")->where(["projectNo"=>$projectNo,"is_del"=>0])->find();
  735. if($info==false){
  736. return error_show(1004,"未找到项目信息");
  737. }
  738. $plat = Db::name("platform")->where(['id'=>$info['platform_id']])->find();
  739. $info['platform_name']=isset($plat['platform_name'])?$plat['platform_name']:"";
  740. $info['platform_code']=isset($plat['platform_code'])?$plat['platform_code']:"";
  741. $khinfo = Db::name("customer_info")->where(["companyNo"=>$info['khNo']])->find();
  742. $info['khName'] = isset($khinfo['companyName'])?$khinfo['companyName']:"";
  743. if($type==1){
  744. $where = ['projectNo'=>$projectNo,"is_del"=>0,"status"=>1];
  745. }else{
  746. $where = ['projectNo'=>$projectNo,"is_del"=>0];
  747. }
  748. $ladder = Db::name("project_plan")->where($where)->order("addtime desc")->select()->toArray();
  749. $info=[];
  750. if(!empty($ladder)){
  751. foreach ($ladder as $value){
  752. $value['feedback']=[];
  753. $feedback =Db::name("project_plan_rela")->where(["planNo"=>$value['planNo'],"is_del"=>0])->column("feedback_id,sale_price,sale_num");
  754. if(!empty($feedback)){
  755. $feedid = array_column($feedback,"feedback_id");
  756. $feedlist = Db::name("project_feedback")->where(["id"=>$feedid,"is_del"=>0])->select();
  757. if(!empty($feedlist)){
  758. foreach ($feedlist as $val){
  759. $key =array_search($val['id'],$feedid);
  760. $price = $feedback[$key]['sale_price'];
  761. $val["cat_info"]=isset($val['cat_id'])&&$val['cat_id']!=""? made($val['cat_id'],[]):[];
  762. $val["origin_sale_price"]=$val['sale_price'];
  763. $val["sale_price"]=$price;
  764. $val["origin_num"]=$val['num'];
  765. $val["num"]=$feedback[$key]['sale_num'];
  766. if($val['data_source']!=1){
  767. $good=Db::name("consult_bids")->where(["spuCode"=>$val['spuCode'],"is_del"=>0])->find();
  768. $good['specinfo']=isset($good['specinfo'])&&$good['specinfo']!=""?json_decode($good['specinfo'],true):[];
  769. }else{
  770. $good=Db::name("good")->where(["spuCode"=>$val['spuCode'],"is_del"=>0])->find();
  771. $spec = Db::name("good_spec")->where(["spuCode"=>$val['spuCode'],"is_del"=>0])->select()->toArray();
  772. $good['specinfo']=[];
  773. if(!empty($spec)){
  774. foreach ($spec as $vae){
  775. $specs=Db::name("specs")->where(["id"=>$vae['spec_id']])->find();
  776. $spec_value = Db::name("spec_value")->where(["id"=>$vae["spec_value_id"]])->find();
  777. $temp = ["specid"=>$vae['spec_id'],"spec_name"=>$specs['spec_name'],"spec_value_id"=>$vae['spec_value_id'],"spec_value_name"=>$spec_value["spec_value"]];
  778. $good['specinfo'][]=$temp;
  779. }
  780. }
  781. }
  782. if(isset($good['brand_id'])){
  783. $brand =Db::name("brand")->where(["id"=>$good['brand_id']])->find();
  784. }
  785. $val['good_img']=isset($good['good_thumb_img'])&&$good['good_thumb_img']!=""?trim($good['good_thumb_img']):"";
  786. $val['brand_id']=isset($good['brand_id'])&&$good['brand_id']!=""?$good['brand_id']:"";
  787. $val['brand_name']=isset($brand['brand_name'])&&$brand['brand_name']!=""?$brand['brand_name']:"";
  788. $val['specinfo']=isset($good['specinfo'])&&$good['specinfo']!=""?$good['specinfo']:[];
  789. $value['feedback'][]=$val;
  790. }
  791. }
  792. }
  793. $info[]=$value;
  794. }
  795. }
  796. return app_show(0,"获取成功",$info);
  797. }
  798. public function feedCheck(){
  799. $feedid = isset($this->post['feedid'])&&!empty($this->post['feedid']) ? $this->post['feedid'] :[];
  800. if(empty($feedid)){
  801. return error_show(1004,"参数feedid不能为空");
  802. }
  803. $feedid=array_unique($feedid);
  804. $selec = Db::name("project_feedback")->where(["id"=>$feedid,'is_del'=>0,"status"=>0])->select()->toArray();
  805. if(empty($selec)){
  806. return error_show(1004,"反馈数据信息未找到");
  807. }
  808. $pgnos =array_column($selec,"pgNo");
  809. $infolist = Db::name("project_info")->where(['pgNo'=>$pgnos])->select()->toArray();
  810. if(empty($infolist)){
  811. return error_show(1004,"项目商品数据未找到");
  812. }
  813. Db::startTrans();
  814. try{
  815. $up = Db::name("project_feedback")->where(["id"=>$feedid,'is_del'=>0,"status"=>0])->save(["status"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
  816. if($up){
  817. foreach ($infolist as $value){
  818. $poject=Db::name("project")->where(["projectNo"=>$value['projectNo']])->find();
  819. if($poject==false){
  820. Db::rollback();
  821. return error_show(1004,"项目单未找到");
  822. }
  823. $old_projectinfo_status = $value['status'];
  824. $value['status']=3;
  825. $value['updatetime']=date("Y-m-d H:i:s");
  826. $up = Db::name("project_info")->save($value);
  827. if($up){
  828. //修改状态,添加待办,只记录动作
  829. ActionLog::logAdd($this->post['token'], [
  830. "order_code" => $value['pgNo'],//编码
  831. "status" => $old_projectinfo_status,//这里的status是之前的值
  832. "action_remark" => '',//备注
  833. "action_type" => "status"//新建create,编辑edit,更改状态status
  834. ], "PRI", 3, $value);
  835. $count = Db::name("project_info")->where(["projectNo"=>$value['projectNo'],"status"=>2])
  836. ->count();
  837. if($count==0){
  838. $proc =Db::name("project")->where(["projectNo"=>$value['projectNo']])->save
  839. (["status"=>3,"updatetime"=>date("Y-m-d H:i:s")]);
  840. if(!$proc){
  841. Db::rollback();
  842. return error_show(1004,"反馈数据选择失败");
  843. }else{
  844. //修改状态,添加待办
  845. ActionLog::logAdd($this->post['token'], [
  846. "order_code" =>$value['projectNo'],//项目编码
  847. "status" => $poject['status'],//这里的status是之前的值
  848. "action_remark" => '',//备注
  849. "action_type" => "status"//新建create,编辑edit,更改状态status
  850. ], "PRO", 3, ["status"=>3,"updatetime"=>date("Y-m-d H:i:s")]);
  851. ProcessOrder::AddProcess($this->post['token'], [
  852. "order_type" => 'PRO',
  853. "order_code" =>$value['projectNo'],
  854. "order_id" => $poject['id'],
  855. "order_status" => 3,
  856. "before_status"=>$poject['status'],
  857. 'holder_id'=>$poject['createrid']
  858. ]);
  859. }
  860. }
  861. }else{
  862. Db::rollback();
  863. return error_show(1004,"反馈数据选择失败");
  864. }
  865. }
  866. Db::commit();
  867. return app_show(0,"反馈数据选择成功");
  868. }else{
  869. Db::rollback();
  870. return error_show(1004,"反馈数据选择失败");
  871. }
  872. }catch (\Exception $e){
  873. Db::rollback();
  874. return error_show(1004,$e->getMessage());
  875. }
  876. }
  877. public function planCheck(){
  878. $planNos = isset($this->post['planNos'])&&!empty($this->post['planNos'])? $this->post['planNos'] :"";
  879. if($planNos==""){
  880. return error_show(1004,"参数planNos不能为空");
  881. }
  882. $status=isset($this->post['status'])&&$this->post['status']!=="" ? intval($this->post['status']):"";
  883. if($status==""){
  884. return error_show(1004,"参数status不能为空");
  885. }
  886. $selec = Db::name("project_plan")->where(["planNo"=>$planNos,'is_del'=>0,"status"=>0])->select()->toArray();
  887. if(empty($selec)){
  888. return error_show(1004,"项目方案数据信息未找到");
  889. }
  890. Db::startTrans();
  891. try{
  892. $up = Db::name("project_plan")->where(["planNo"=>$planNos,'is_del'=>0,"status"=>0])->save(["status"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
  893. if($up) {
  894. foreach ($selec as $value){
  895. //修改状态,添加待办,只记录动作
  896. ActionLog::logAdd($this->post['token'], [
  897. "order_code" => $value['planNo'],//编码
  898. "status" => $value['status'],//这里的status是之前的值
  899. "action_remark" => '',//备注
  900. "action_type" => "edit"//新建create,编辑edit,更改状态status
  901. ], "PRO", 1, $value);
  902. }
  903. $project = array_column($selec, "projectNo");
  904. if (empty($project)) {
  905. Db::rollback();
  906. return error_show(1004, "方案选择失败");
  907. }
  908. $pro = Db::name("project")->where(["projectNo" => $project, "status" => 4])->save(["status" => 5, "updatetime" => date("Y-m-d H:i:s")]);
  909. if ($pro) {
  910. foreach ($project as $value){
  911. $poject=Db::name("project")->where(["projectNo"=>$value])->find();
  912. if($poject==false){
  913. Db::rollback();
  914. return error_show(1004,"项目单未找到");
  915. }
  916. //修改状态,添加待办
  917. ActionLog::logAdd($this->post['token'], [
  918. "order_code" =>$value,//项目编码
  919. "status" => 4,//这里的status是之前的值
  920. "action_remark" => '',//备注
  921. "action_type" => "status"//新建create,编辑edit,更改状态status
  922. ], "PRO", 5, ["status"=>5,"updatetime"=>date("Y-m-d H:i:s")]);
  923. ProcessOrder::AddProcess($this->post['token'], [
  924. "order_type" => 'PRO',
  925. "order_code" =>$value,
  926. "order_id" => $poject['id'],
  927. "order_status" => 5,
  928. "before_status"=>4,
  929. 'holder_id'=>$poject['createrid']
  930. ]);
  931. }
  932. Db::commit();
  933. return app_show(0, "方案数据修改成功");
  934. }
  935. }
  936. Db::rollback();
  937. return error_show(1004,"方案选择失败");
  938. }catch (\Exception $e){
  939. Db::rollback();
  940. return error_show(1004,$e->getMessage());
  941. }
  942. }
  943. public function changeRate(){
  944. $projectNo = isset($this->post['projectNo'])&&$this->post['projectNo']!==""?trim($this->post['projectNo']):"";
  945. if($projectNo==""){
  946. return error_show(1004,"参数projectNo不能为空");
  947. }
  948. $info =Db::name("project")->where(["projectNo"=>$projectNo,"is_del"=>0])->find();
  949. if($info==false){
  950. return error_show(1004,"未找到项目信息");
  951. }
  952. $rate = isset($this->post['rate'])&&$this->post['rate']!=="" ?floatval($this->post['rate']):"";
  953. if($rate===""){
  954. return error_show(1004,"参数rate不能为空");
  955. }
  956. $info['low_rate']=$rate;
  957. $info['updatetime']=date("Y-m-d H:i:s");
  958. $up =Db::name("project")->save($info);
  959. if($up){
  960. return app_show(0,"利润率修改成功");
  961. }else{
  962. return error_show(1004,"利润率修改失败");
  963. }
  964. }
  965. //废弃???@wf by 22.09.01(在路由文件中没有找到这个方法)
  966. public function order(){
  967. $id = isset($this->post['id'])&& $this->post['id']!=="" ? intval($this->post['id']):"";
  968. if($id==""){
  969. return error_show(1004,"参数id不能为空");
  970. }
  971. $backinfo = Db::name("project_feedback")->where(["id"=>$id,"is_del"=>0])->find();
  972. if($backinfo==false){
  973. return error_show(1004,"未找到数据");
  974. }
  975. $prject = Db::name("project")->where(["projectNo"=>$backinfo['projectNo'],"is_del"=>0])->find();
  976. if($prject==false) {
  977. return error_show(1004, "未找到项目数据");
  978. }
  979. $send_type =isset($this->post['send_type'])&&$this->post['send_type']!=""? intval($this->post['send_type']):"";
  980. if($send_type==""){
  981. return error_show(1004,"参数send_type不能为空");
  982. }
  983. if($send_type==1){
  984. $va = isset($this->post['order_addr']) && $this->post['order_addr'] !== "" ? $this->post['order_addr'] : "";
  985. if ($va == "") {
  986. return error_show(1002, "参数order_addr不能为空");
  987. }
  988. }
  989. $plat = Db::name("platform")->where(["id"=>$prject['platform_id']])->find();
  990. $token = isset($this->post['token'])&& $this->post['token']!=="" ? trim($this->post['token']):"";
  991. if($token==""){
  992. return error_show(1004,"参数token不能为空");
  993. }
  994. $apply_id = GetUserInfo($token);
  995. if (empty($apply_id) || $apply_id['code'] != 0) {
  996. return error_show(1002, "申请人数据不存在");
  997. }
  998. $rm = isset($apply_id["data"]['id']) ? $apply_id["data"]['id'] : "";
  999. $ri = isset($apply_id["data"]['nickname']) ? $apply_id["data"]['nickname'] : "";
  1000. $orderCode = makeNo("QR");
  1001. Db::startTrans();
  1002. try{
  1003. $data = [
  1004. "orderCode" => $orderCode,
  1005. "good_code" => $backinfo['spuCode'],
  1006. "customer_code" => $prject['khNo'],
  1007. "good_name" => $backinfo['good_name'],
  1008. "good_num" => $backinfo['num'],
  1009. "order_type" =>3,
  1010. "order_source" =>3,//3项目
  1011. "item_code"=>isset($plat['platform_code'])? $plat['platform_code']:"",
  1012. "good_type"=>1,
  1013. "apply_id" => $rm,
  1014. "apply_name" => $ri,
  1015. "origin_price" =>$backinfo['nake_price'],
  1016. "sale_price" => $backinfo['sale_price'],
  1017. "post_fee" => 0,
  1018. "status" => 0,
  1019. "supplierNo" =>$prject['companyNo'],
  1020. "send_num" => 0,
  1021. "zxNo"=>$backinfo['pgNo'],
  1022. "wsend_num" => $backinfo['num'],
  1023. "send_type" => $send_type,
  1024. "send_status" => 1,
  1025. "is_del" => 0,
  1026. "addtime" => date("Y-m-d H:i:s"),
  1027. "updatetime" => date("Y-m-d H:i:s"),
  1028. 'total_price' => $backinfo['sale_price'] * $backinfo['num'],
  1029. ];
  1030. $datainfo = Db::name('sale')->insert($data, true);
  1031. if($datainfo>0){
  1032. if($send_type==1){
  1033. foreach ($va as $value) {
  1034. $temp = [];
  1035. $addrs = [];
  1036. if ($value['addr_code'] !== '' && is_array($value['addr_code'])) {
  1037. $addrs['provice_code'] = $value['addr_code'][0];
  1038. $addrs['city_code'] = $value['addr_code'][1];
  1039. $addrs['area_code'] = $value['addr_code'][2];
  1040. $addr = json_encode($addrs);
  1041. } else {
  1042. $addr = isset($value['addr_code']) ? $value['addr_code'] : '';
  1043. }
  1044. $temp['orderCode'] = $orderCode;
  1045. $temp['contactor'] = $value['contactor'];
  1046. $temp['mobile'] = $value['mobile'];
  1047. $temp['addr'] = $value['addr'];
  1048. $temp['addr_code'] = $addr;
  1049. $temp['customer_code'] = $prject['khNo'];
  1050. $temp['receipt_quantity'] = $value['receipt_quantity'];
  1051. $temp['post_fee'] = 0;
  1052. $temp['is_del'] = 0;
  1053. $temp['addtime'] = date("Y-m-d H:i:s");
  1054. $temp['updatetime'] = date("Y-m-d H:i:s");
  1055. $temp['arrive_time'] = date("Y-m-d H:i:s");
  1056. $vat[] = $temp;
  1057. }
  1058. $vmp = Db::name('order_addr')->insertAll($vat);
  1059. if ($vmp==false) {
  1060. Db::rollback();
  1061. return error_show(1004, "销售订单创建失败");
  1062. }
  1063. }
  1064. Db::name('standing_book')
  1065. ->where('projectNo', $backinfo['projectNo'])
  1066. ->update([
  1067. 'sale_id' => $datainfo,
  1068. 'orderCode' => $orderCode,
  1069. 'customer_code' => $prject['khNo'],
  1070. 'spuCode' => $backinfo['spuCode'],
  1071. 'order_type' => $data['order_type'],
  1072. 'order_source' => $data['order_source'],
  1073. 'supplierNo' => $prject['companyNo'],
  1074. 'updatetime' => date("Y-m-d H:i:s")
  1075. ]);
  1076. Db::commit();
  1077. return error_show(0, "销售订单创建成功");
  1078. }
  1079. Db::rollback();
  1080. return error_show(1004, "销售订单创建失败");
  1081. }catch (\Exception $w){
  1082. Db::rollback();
  1083. return error_show(1004, $w->getMessage());
  1084. }
  1085. }
  1086. public function feeddel(){
  1087. $feedid = isset($this->post['id'])&&!empty($this->post['id']) ? $this->post['id'] :[];
  1088. if(empty($feedid)){
  1089. return error_show(1004,"参数feedid不能为空");
  1090. }
  1091. $selec = Db::name("project_feedback")->where(["id"=>$feedid,'is_del'=>0])->select();
  1092. if(empty($selec)){
  1093. return error_show(1004,"反馈数据信息未找到");
  1094. }
  1095. $up = Db::name("project_feedback")->where(["id"=>$feedid,'is_del'=>0])->save(["is_del"=>1,"updatetime"=>date("Y-m-d H:i:s")]);
  1096. if($up){
  1097. return app_show(0,"反馈数据删除成功");
  1098. }else{
  1099. return error_show(1004,"反馈数据删除失败");
  1100. }
  1101. }
  1102. }