PriceModelController.php 46 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Imports\ExpressImport;
  4. use App\Imports\OwnerPriceDirectLogisticDetailImport;
  5. use App\Imports\OwnerPriceLogisticDetailImport;
  6. use App\Owner;
  7. use App\OwnerOutStorageRule;
  8. use App\OwnerPriceDirectLogistic;
  9. use App\OwnerPriceExpress;
  10. use App\OwnerPriceExpressProvince;
  11. use App\OwnerPriceLogistic;
  12. use App\OwnerPriceOperation;
  13. use App\Services\common\ExportService;
  14. use App\Services\LogService;
  15. use App\Services\OwnerOutStorageRuleService;
  16. use App\Services\OwnerPriceOperationService;
  17. use Illuminate\Database\Eloquent\Builder;
  18. use Illuminate\Http\Request;
  19. use Illuminate\Support\Facades\Cache;
  20. use Illuminate\Support\Facades\Gate;
  21. use Illuminate\Support\Facades\Validator;
  22. use Maatwebsite\Excel\Facades\Excel;
  23. class PriceModelController extends Controller
  24. {
  25. public function storageIndex(Request $request)
  26. {
  27. if(!Gate::allows('计费模型-仓储')){ return redirect('denied'); }
  28. $models = app('OwnerStoragePriceModelService')->paginate($request->input("id"),["unit"]);
  29. return response()->view('maintenance.priceModel.storage.index',compact("models"));
  30. }
  31. public function storageCreate()
  32. {
  33. if(!Gate::allows('计费模型-仓储-录入')){ return redirect('denied'); }
  34. $units = app('UnitService')->getSelection();
  35. return response()->view('maintenance.priceModel.storage.create',compact("units"));
  36. }
  37. public function storageStore(Request $request)
  38. {
  39. if(!Gate::allows('计费模型-仓储-录入')){ return redirect('denied'); }
  40. $this->storageValidator($request->input())->validate();
  41. app('OwnerStoragePriceModelService')->create($request->input());
  42. LogService::log(__METHOD__,"计费模型-创建仓储计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  43. return response()->redirectTo('maintenance/priceModel/storage')->with('successTip',"创建成功!");
  44. }
  45. public function storageEdit($id)
  46. {
  47. if(!Gate::allows('计费模型-仓储-编辑')){ return redirect('denied'); }
  48. $model = app('OwnerStoragePriceModelService')->find($id);
  49. $units = app('UnitService')->getSelection();
  50. return response()->view('maintenance.priceModel.storage.create',compact("units","model"));
  51. }
  52. public function storageUpdate(Request $request)
  53. {
  54. if(!Gate::allows('计费模型-仓储-编辑')){ return redirect('denied'); }
  55. app('OwnerStoragePriceModelService')->update(["id"=>$request->input("id")],[
  56. "counting_type" => $request->input("counting_type"),
  57. "using_type" => $request->input("using_type"),
  58. "minimum_area" => $request->input("minimum_area"),
  59. "price" => $request->input("price"),
  60. "discount_type" => $request->input("discount_type"),
  61. "discount_value"=> $request->input("discount_value"),
  62. "unit_id" => $request->input("unit_id"),
  63. ]);
  64. LogService::log(__METHOD__,"计费模型-修改仓储计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  65. return response()->redirectTo('maintenance/priceModel/storage')->with('successTip',"更新成功!");
  66. }
  67. public function storageDestroy($id)
  68. {
  69. app("OwnerStoragePriceModelService")->destroy($id);
  70. LogService::log(__METHOD__,"计费模型-删除仓储计费",$id);
  71. return ["success"=>true];
  72. }
  73. private function storageValidator(array $params)
  74. {
  75. return Validator::make($params,[
  76. 'counting_type'=>['required'],
  77. 'using_type'=>['required'],
  78. 'minimum_area'=>['nullable','numeric','min:0'],
  79. 'discount_value'=>['nullable','numeric','min:0'],
  80. 'price'=>['required','numeric','min:0'],
  81. 'discount_type'=>['required'],
  82. 'unit_id'=>['required','integer'],
  83. ],[
  84. 'required'=>':attribute 为必填项',
  85. 'min'=>':attribute 不得小于0',
  86. 'integer'=>':attribute 未选择',
  87. ],[
  88. 'counting_type' =>"计费类型",
  89. 'using_type' =>"用仓类型",
  90. 'minimum_area' =>"最低起租面积",
  91. 'price' =>"单价",
  92. 'discount_type' =>"减免类型",
  93. 'discount_value'=>"减免值",
  94. 'unit_id' =>"单位",
  95. ]);
  96. }
  97. public function operationIndex(Request $request){
  98. if(!Gate::allows('计费模型-作业-查询')){ return redirect('denied'); }
  99. $features = app("FeatureService")->getMapArray();
  100. OwnerPriceOperation::$features = $features;
  101. $models = app('OwnerPriceOperationService')->paginate($request->input(),["ownerPriceOperationOwners","ownerInStorageRule"=>function($query){$query->with("unit");}])->append("featureFormat");
  102. $owners = app("OwnerService")->getSelection();
  103. return response()->view('maintenance.priceModel.operation.index',compact("models","owners"));
  104. }
  105. /* 获取出库模型规则 */
  106. public function operationGetOutStorageRule(Request $request)
  107. {
  108. if(!Gate::allows('计费模型-作业-查询')){ return ["success"=>false,"data"=>"无权操作"]; }
  109. /** @var OwnerOutStorageRuleService $service */
  110. $service = app('OwnerOutStorageRuleService');
  111. $ownerOutStorageRules = $service->get(["owner_price_operation_id"=>$request->input("id")],["unit"],true)->append("featureFormat");
  112. return ["success"=>true,"data"=>$ownerOutStorageRules];
  113. }
  114. /* 修改出库模型规则 */
  115. public function updateOutStorageRule(Request $request)
  116. {
  117. if(!Gate::allows('计费模型-作业-编辑')){ return ["success"=>false,"data"=>"无权操作"]; }
  118. /** @var OwnerOutStorageRuleService $service */
  119. $service = app('OwnerOutStorageRuleService');
  120. $row = $service->update(["id"=>$request->input("id")],[
  121. "amount"=>$request->input("amount"),
  122. "unit_id"=>$request->input("unit_id"),
  123. "priority"=>$request->input("priority"),
  124. "unit_price"=>$request->input("unit_price")]);
  125. if ($row == 1){
  126. LogService::log(__METHOD__,"计费模型-修改出库规则",json_encode($request->input()));
  127. return ["success"=>true];
  128. }
  129. return ["success"=>false,"data"=>"受影响数据数为:".$row];
  130. }
  131. public function createOutStorageRule(Request $request)
  132. {
  133. if(!Gate::allows('计费模型-作业-编辑')){ return ["success"=>false,"data"=>"无权操作"]; }
  134. /** @var OwnerOutStorageRuleService $service */
  135. $service = app('OwnerOutStorageRuleService');
  136. switch ($request->input("strategy")){
  137. case "起步":
  138. $c = $service->isExist(["owner_price_operation_id"=>$request->input("owner_price_operation_id"),"strategy"=>"起步"]);
  139. if ($c > 0)return ["success"=>false,"data"=>"已存在起步策略"];
  140. break;
  141. case "默认":
  142. $c = $service->isExist(["owner_price_operation_id"=>$request->input("owner_price_operation_id"),"strategy"=>"默认"]);
  143. if ($c > 0)return ["success"=>false,"data"=>"已存在默认策略"];
  144. break;
  145. }
  146. $data = $service->create($request->input());
  147. LogService::log(__METHOD__,"计费模型-录入出库规则",json_encode($request->input()));
  148. $data->load("unit");
  149. return ["success"=>true,"data"=>$data];
  150. }
  151. public function getFeatures(Request $request)
  152. {
  153. return ["success"=>true,"data"=>app("FeatureService")->translationFeature($request->input("feature"))];
  154. }
  155. public function addFeature(Request $request)
  156. {
  157. if(!Gate::allows('计费模型-作业-编辑')){ return ["success"=>false,"data"=>"无权操作"]; }
  158. $id = $request->input("id");
  159. $features = $request->input("features");
  160. if (!$id || !$features)return ["success"=>false,"data"=>"非法参数"];
  161. $result = app("FeatureService")->analysisFeature($features);
  162. $feature = $result["feature"];
  163. $stack = [];
  164. if ($feature && ($feature[0]=='|' || $feature[0]=='&'))$feature=substr($feature,1);
  165. for ($i=0;$i<strlen($feature);$i++){
  166. if ($feature[$i] == '(')array_unshift($stack,'(');
  167. if ($feature[$i] == ')'){
  168. if (count($stack) == 0)return ["success"=>false,"data"=>"组标记错误,起始与结束标记必须对应"];
  169. array_shift($stack);
  170. }
  171. }
  172. if (count($stack) > 0)return ["success"=>false,"data"=>"组标记错误,起始与结束标记必须对应"];
  173. $row = app('OwnerOutStorageRuleService')->update(["id"=>$id],["feature"=>$feature]);
  174. if ($row != 1)return ["success"=>false,"data"=>"影响了“".$row."”行"];
  175. LogService::log(__METHOD__,"计费模型-修改出库特征",json_encode($request->input()));
  176. OwnerOutStorageRule::$features = $result["map"];
  177. $rule = app('OwnerOutStorageRuleService')->find($id)->append("featureFormat");
  178. return ["success"=>true,"data"=>["featureFormat"=>$rule->featureFormat,"feature"=>$feature]];
  179. }
  180. public function getFeature(Request $request)
  181. {
  182. $features = $request->input("features");
  183. if (!$features)return ["success"=>false,"data"=>"非法参数"];
  184. $result = app("FeatureService")->analysisFeature($features);
  185. $feature = $result["feature"];
  186. $stack = [];
  187. if ($feature && ($feature[0]=='|' || $feature[0]=='&'))$feature=substr($feature,1);
  188. for ($i=0;$i<strlen($feature);$i++){
  189. if ($feature[$i] == '(')array_unshift($stack,'(');
  190. if ($feature[$i] == ')'){
  191. if (count($stack) == 0)return ["success"=>false,"data"=>"组标记错误,起始与结束标记必须对应"];
  192. array_shift($stack);
  193. }
  194. }
  195. if (count($stack) > 0)return ["success"=>false,"data"=>"组标记错误,起始与结束标记必须对应"];
  196. return ["success"=>true,"data"=>$feature];
  197. }
  198. public function operationDestroy($id)
  199. {
  200. if(!Gate::allows('计费模型-作业-删除')){ return ["success"=>false,"data"=>"无权操作"]; }
  201. $row = app("OwnerPriceOperationService")->destroy($id);
  202. if ($row == 1){
  203. LogService::log(__METHOD__,"计费模型-删除作业计费",$id);
  204. return ["success"=>true];
  205. }
  206. return ["success"=>false,"data"=>"影响了“".$row."”行"];
  207. }
  208. public function operationCreate(){
  209. if(!Gate::allows('计费模型-作业-录入')){ return redirect('denied'); }
  210. $owners = app("OwnerService")->getSelection();
  211. $units = app('UnitService')->getSelection();
  212. return response()->view('maintenance.priceModel.operation.create',compact("owners","units"));
  213. }
  214. public function operationStore(Request $request)
  215. {
  216. if(!Gate::allows('计费模型-作业-录入')){ return redirect('denied'); }
  217. $request->offsetSet("rules",json_decode($request->input("rules"),true));
  218. $request->offsetSet("owner_id",explode(',',$request->input("owner_id")));
  219. $this->operationValidator($request->input())->validate();
  220. //录入主表
  221. /** @var OwnerPriceOperationService $service */
  222. $service = app("OwnerPriceOperationService");
  223. $ownerPriceOperation = $service->create([
  224. "operation_type" => $request->input("operation_type"),
  225. "strategy" => $request->input("strategy"),
  226. "name" => $request->input("name"),
  227. "priority" => $request->input("priority"),
  228. "remark" => $request->input("remark"),
  229. "feature" => $request->input("feature"),
  230. ]);
  231. //录入子表
  232. if ($request->input("operation_type") == '入库') $service->insertRule([
  233. "owner_price_operation_id" => $ownerPriceOperation->id,
  234. "amount" => $request->input("rules")[0]["amount"],
  235. "unit_id" => $request->input("rules")[0]["unit_id"],
  236. "unit_price" => $request->input("rules")[0]["unit_price"],
  237. ],"入库");
  238. else{
  239. $insert = [];
  240. foreach ($request->input("rules") as $rule){
  241. $insert[] = [
  242. "owner_price_operation_id" => $ownerPriceOperation->id,
  243. "amount" => $rule["amount"],
  244. "unit_id" => $rule["unit_id"],
  245. "unit_price" => $rule["unit_price"],
  246. "strategy" => $rule["strategy"],
  247. "feature" => $rule["feature"],
  248. "priority" => $rule["priority"],
  249. ];
  250. }
  251. $service->insertRule($insert);
  252. }
  253. //录入中间表
  254. /** @var OwnerPriceOperation $model */
  255. if ($request->input("owner_id"))$model->ownerPriceOperationOwners()->sync($request->input("owner_id"));
  256. LogService::log(__METHOD__,"计费模型-录入作业计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  257. return response()->redirectTo("maintenance/priceModel/operation")->with("successTip","创建“".$request->input("name")."”成功");
  258. }
  259. public function operationEdit($id)
  260. {
  261. if(!Gate::allows('计费模型-作业-编辑')){ return redirect('denied'); }
  262. $model = app('OwnerPriceOperationService')->find($id,true,["ownerPriceOperationOwners"]);
  263. $owners = app("OwnerService")->getSelection();
  264. $units = app('UnitService')->getSelection();
  265. return response()->view('maintenance.priceModel.operation.create',compact("owners","units","model"));
  266. }
  267. public function operationUpdate($id,Request $request)
  268. {
  269. if(!Gate::allows('计费模型-作业-编辑')){ return redirect('denied'); }
  270. $request->offsetSet("rules",json_decode($request->input("rules"),true));
  271. $request->offsetSet("owner_id",explode(',',$request->input("owner_id")));
  272. $this->operationValidator($request->input(),$id)->validate();
  273. /** @var OwnerPriceOperationService $service */
  274. $service = app("OwnerPriceOperationService");
  275. $model = $service->find($id);
  276. $service->findUpdate($model,[
  277. "name" => $request->input("name"),
  278. "priority" => $request->input("priority"),
  279. "remark" => $request->input("remark"),
  280. "feature" => $request->input("feature"),
  281. ]);
  282. $service->destroyRule($id, $model->operation_type);
  283. //录入子表
  284. if ($request->input("operation_type") == '入库') $service->insertRule([
  285. "owner_price_operation_id" => $model->id,
  286. "amount" => $request->input("rules")[0]["amount"],
  287. "unit_id" => $request->input("rules")[0]["unit_id"],
  288. "unit_price" => $request->input("rules")[0]["unit_price"],
  289. ],"入库");
  290. else{
  291. $insert = [];
  292. foreach ($request->input("rules") as $rule){
  293. $insert[] = [
  294. "owner_price_operation_id" => $model->id,
  295. "amount" => $rule["amount"],
  296. "unit_id" => $rule["unit_id"],
  297. "unit_price" => $rule["unit_price"],
  298. "strategy" => $rule["strategy"],
  299. "feature" => $rule["feature"],
  300. "priority" => $rule["priority"],
  301. ];
  302. }
  303. $service->insertRule($insert);
  304. }
  305. //录入中间表
  306. /** @var OwnerPriceOperation $model */
  307. if ($request->input("owner_id"))$model->ownerPriceOperationOwners()->sync($request->input("owner_id"));
  308. LogService::log(__METHOD__,"计费模型-修改作业计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  309. return response()->redirectTo("maintenance/priceModel/operation")->with("successTip","修改“".$request->input("name")."”成功");
  310. }
  311. private function operationValidator(array $params, $id= null)
  312. {
  313. return Validator::make($params,[
  314. //required_with:id
  315. 'operation_type'=>['required'],
  316. 'owner_id'=>[function ($attribute, $value, $fail)use($params,$id) {
  317. if ($params["strategy"] == '默认'){
  318. $owners = Owner::query()->whereIn("id",$value)->withCount(["ownerPriceOperations"=>function($query)use($params,$id){
  319. if ($id)$query->where('id',"!=",$id);
  320. $query->where("strategy","默认")->where("operation_type",$params["operation_type"]);
  321. }])->get();
  322. $err = [];
  323. foreach ($owners as $owner){
  324. if ($owner->owner_price_operations_count > 0)$err[] = $owner->name;
  325. }
  326. if (count($err)>0)$fail("(".implode(',',$err).') 已经绑定'.$params["operation_type"].'的默认策略');
  327. }
  328. }],
  329. 'strategy'=>['required'],
  330. 'name'=>['required',$id?"unique:owner_price_operations,name,$id":'unique:owner_price_operations,name'],
  331. 'priority'=>['required','integer','min:0','max:100'],
  332. 'rules.*.strategy'=>['required_if:operation_type,出库'],
  333. 'rules.*.amount'=>['required',"integer"],
  334. 'rules.*.unit_id'=>['required','integer'],
  335. 'rules.*.unit_price'=>['required','numeric',"min:0"],
  336. 'rules.*.priority'=>['required_if:operation_type,出库','integer','min:0','max:100'],
  337. ],[
  338. 'required'=>':attribute 为必填项',
  339. 'min'=>':attribute 不得小于0',
  340. 'integer'=>':attribute 必须为整数',
  341. 'numeric'=>':attribute 必须为数字',
  342. 'max'=>':attribute 超出最大值',
  343. 'required_if'=>':attribute 操作类型为出库时不得为空',
  344. ],[
  345. 'operation_type' =>"操作类型",
  346. 'strategy' =>"计费策略",
  347. 'name' =>"名称",
  348. 'priority' =>"优先级",
  349. ]);
  350. }
  351. public function expressIndex(Request $request){
  352. if(!Gate::allows('计费模型-快递-查询')){ return redirect('denied'); }
  353. $models = app('OwnerPriceExpressService')->paginate($request->input("id"));
  354. return response()->view('maintenance.priceModel.express.index',compact("models"));
  355. }
  356. public function expressGetDetail(Request $request)
  357. {
  358. if(!Gate::allows('计费模型-快递-查询')){ return ["success"=>false,"data"=>"无权操作"]; }
  359. $model = new OwnerPriceExpress();
  360. $model->id = $request->input("id");
  361. $model->load(["details"=>function($query){$query->with("province");}]);
  362. return ["success"=>true,"data"=>$model->details];
  363. }
  364. public function expressUpdateDetail(Request $request)
  365. {
  366. if(!Gate::allows('计费模型-快递-编辑')){ return ["success"=>false,"data"=>"无权操作"]; }
  367. $detail = $request->input("detail");
  368. if ($detail["id"]){
  369. app('OwnerPriceExpressService')->updateDetail(["id"=>$detail["id"]],[
  370. "additional_weight_price" => $detail["additional_weight_price"],
  371. "initial_weight_price" => $detail["initial_weight_price"],
  372. ]);
  373. }else{
  374. $row = app('OwnerPriceExpressService')->isExistDetail(["owner_price_express_id"=>$request->input("id"),"province_id"=>$detail["province_id"]]);
  375. if ($row>0)return ["success"=>false,"data"=>"已存在该省份计费模型"];
  376. /** @var OwnerPriceExpressProvince $detail */
  377. $detail = app('OwnerPriceExpressService')->createDetail([
  378. "owner_price_express_id" => $request->input("id"),
  379. "province_id" => $detail["province_id"],
  380. "additional_weight_price" => $detail["additional_weight_price"],
  381. "initial_weight_price" => $detail["initial_weight_price"],
  382. ]);
  383. $detail->load("province");
  384. }
  385. LogService::log(__METHOD__,"计费模型-修改快递计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  386. return ["success"=>true,"data"=>$detail];
  387. }
  388. public function expressDestroyDetail(Request $request)
  389. {
  390. if(!Gate::allows('计费模型-快递-删除')){ return ["success"=>false,"data"=>"无权操作"]; }
  391. $id = $request->input("id");
  392. if (!$id)return ["success"=>false,"data"=>"非法参数"];
  393. app("OwnerPriceExpressService")->destroyDetail($id);
  394. LogService::log(__METHOD__,"计费模型-删除快递计费",$id);
  395. return ["success"=>true];
  396. }
  397. public function expressImport(Request $request){
  398. if(!Gate::allows('计费模型-快递-录入')){ return ["success"=>false,"data"=>"无权操作"]; }
  399. $fileSuffix=$request->file('file')->getClientOriginalExtension();
  400. if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
  401. return ['success'=>false,'data'=>'不支持该文件类型'];
  402. ini_set('max_execution_time',2500);
  403. ini_set('memory_limit','1526M');
  404. $fileSuffix = ucwords($fileSuffix);
  405. /** @var OwnerPriceExpress $model */
  406. $model = app('OwnerPriceExpressService')->find($request->input("id"),["details"]);
  407. Excel::import(new ExpressImport($model),$request->file('file')->path(),null,$fileSuffix);
  408. if (Cache::has('express'))return Cache::pull('express');
  409. return ["success"=>false,"data"=>"导入发生错误,数据无响应"];
  410. }
  411. public function expressCreate(){
  412. if(!Gate::allows('计费模型-快递-录入')){ return redirect('denied'); }
  413. $logistics = app("LogisticService")->getSelection();
  414. $owners = app("OwnerService")->getSelection();
  415. return response()->view('maintenance.priceModel.express.create',compact("logistics","owners"));
  416. }
  417. public function expressStore(Request $request)
  418. {
  419. if(!Gate::allows('计费模型-快递-录入')){ return redirect('denied'); }
  420. $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
  421. $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
  422. $this->expressValidator($request->input())->validate();
  423. /** @var OwnerPriceExpress $model */
  424. $model = app("OwnerPriceExpressService")->create([
  425. "name" => $request->input("name"),
  426. "initial_weight" => $request->input("initial_weight"),
  427. "additional_weight" => $request->input("additional_weight"),
  428. ]);
  429. $model->owners()->sync($request->input("owner_id"));
  430. $model->logistics()->sync($request->input("logistic_id"));
  431. LogService::log(__METHOD__,"计费模型-录入快递计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  432. return response()->redirectTo("maintenance/priceModel/express")->with("successTip","录入“".$request->input("name")."”成功");
  433. }
  434. public function expressEdit($id)
  435. {
  436. if(!Gate::allows('计费模型-快递-编辑')){ return redirect('denied'); }
  437. /** @var OwnerPriceExpress $model */
  438. $model = app('OwnerPriceExpressService')->find($id)->append(["owner_id","logistic_id"]);
  439. $owners = app("OwnerService")->getSelection();
  440. $logistics = app('LogisticService')->getSelection();
  441. return response()->view('maintenance.priceModel.express.create',compact("owners","logistics","model"));
  442. }
  443. public function expressUpdate($id,Request $request)
  444. {
  445. if(!Gate::allows('计费模型-快递-编辑')){ return redirect('denied'); }
  446. $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
  447. $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
  448. $this->expressValidator($request->input(),$id)->validate();
  449. /** @var OwnerPriceExpress $model */
  450. app("OwnerPriceExpressService")->update(["id"=>$id],[
  451. "name" => $request->input("name"),
  452. "initial_weight" => $request->input("initial_weight"),
  453. "additional_weight" => $request->input("additional_weight"),
  454. ]);
  455. $model = new OwnerPriceExpress();
  456. $model->id = $id;
  457. $model->owners()->sync($request->input("owner_id"));
  458. $model->logistics()->sync($request->input("logistic_id"));
  459. LogService::log(__METHOD__,"计费模型-修改快递计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  460. return response()->redirectTo("maintenance/priceModel/express")->with("successTip","修改“".$request->input("name")."”成功");
  461. }
  462. private function expressValidator(array $params, $id=null)
  463. {
  464. return Validator::make($params,[
  465. 'name'=>['required',$id?"unique:owner_price_expresses,name,$id":'unique:owner_price_expresses,name'],
  466. 'initial_weight'=>['required','numeric','min:0'],
  467. 'additional_weight'=>['required','numeric','min:0'],
  468. 'owner_id'=>[function ($attribute, $value, $fail)use($id) {
  469. $owners = app("OwnerPriceExpressService")->getExistOwnerName($value,$id);
  470. if ($owners)$fail("(".implode(',',$owners).') 已经绑定计费模型');
  471. }],
  472. 'logistic_id'=>[function ($attribute, $value, $fail)use($id) {
  473. $logistics = app("OwnerPriceExpressService")->getExistLogisticName($value,$id);
  474. if ($logistics)$fail("(".implode(',',$logistics).') 已经绑定计费模型');
  475. }],
  476. ],[
  477. 'required'=>':attribute 为必填项',
  478. 'unique' => ':attribute 已存在',
  479. ],[
  480. 'name' =>"名称",
  481. 'initial_weight' =>"首重",
  482. 'additional_weight' =>"续重",
  483. ]);
  484. }
  485. public function expressDestroy($id)
  486. {
  487. if(!Gate::allows('计费模型-快递-删除')){ return ["success"=>false,"data"=>"无权操作"]; };
  488. app("OwnerPriceExpressService")->destroy($id);
  489. LogService::log(__METHOD__,"计费模型-删除快递计费",$id);
  490. return ["success"=>true];
  491. }
  492. public function logisticIndex(Request $request)
  493. {
  494. if(!Gate::allows('计费模型-物流-查询')){ return redirect('denied'); }
  495. $models = app("OwnerPriceLogisticService")->paginate($request->input("id"))->append(["unit_range_json","other_unit_range_json"]);
  496. return response()->view('maintenance.priceModel.logistic.index',compact("models"));
  497. }
  498. public function logisticCreate()
  499. {
  500. if(!Gate::allows('计费模型-物流-录入')){ return redirect('denied'); }
  501. $owners = app("OwnerService")->getSelection();
  502. $logistics = app('LogisticService')->getSelection();
  503. $units = app('UnitService')->getSelection();
  504. return response()->view('maintenance.priceModel.logistic.create',compact("owners","logistics","units"));
  505. }
  506. public function logisticStore(Request $request)
  507. {
  508. if(!Gate::allows('计费模型-物流-录入')){ return redirect('denied'); }
  509. $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
  510. $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
  511. $this->logisticValidator($request->input())->validate();
  512. /** @var OwnerPriceLogistic $model */
  513. $model = app("OwnerPriceLogisticService")->create([
  514. "name" => $request->input("name"),
  515. "pick_up_price" => $request->input("pick_up_price"),
  516. "fuel_price" => $request->input("fuel_price"),
  517. "service_price" => $request->input("service_price"),
  518. "unit_id" => $request->input("unit_id"),
  519. "unit_range" => $request->input("unit_range"),
  520. "other_unit_id" => $request->input("other_unit_id"),
  521. "other_unit_range" => $request->input("other_unit_range"),
  522. ]);
  523. $model->owners()->sync($request->input("owner_id"));
  524. $model->logistics()->sync($request->input("logistic_id"));
  525. LogService::log(__METHOD__,"计费模型-录入物流计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  526. return response()->redirectTo("maintenance/priceModel/logistic")->with("successTip","创建“".$request->input("name")."”成功");
  527. }
  528. public function logisticEdit($id)
  529. {
  530. if(!Gate::allows('计费模型-物流-编辑')){ return redirect('denied'); }
  531. $owners = app("OwnerService")->getSelection();
  532. $logistics = app('LogisticService')->getSelection();
  533. $units = app('UnitService')->getSelection();
  534. $model = app("OwnerPriceLogisticService")->find($id)->append(["owner_id","logistic_id"]);
  535. return response()->view('maintenance.priceModel.logistic.create',compact("owners","logistics","units","model"));
  536. }
  537. public function logisticUpdate($id, Request $request)
  538. {
  539. if(!Gate::allows('计费模型-物流-编辑')){ return redirect('denied'); }
  540. $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
  541. $request->offsetSet("logistic_id",explode(",",$request->input("logistic_id")));
  542. $this->logisticValidator($request->input(),$id)->validate();
  543. app("OwnerPriceLogisticService")->update(["id"=>$id],[
  544. "name" => $request->input("name"),
  545. "pick_up_price" => $request->input("pick_up_price"),
  546. "fuel_price" => $request->input("fuel_price"),
  547. "service_price" => $request->input("service_price"),
  548. "unit_id" => $request->input("unit_id"),
  549. "unit_range" => $request->input("unit_range"),
  550. "other_unit_id" => $request->input("other_unit_id"),
  551. "other_unit_range" => $request->input("other_unit_range"),
  552. ]);
  553. $model = new OwnerPriceLogistic();
  554. $model->id = $id;
  555. $model->owners()->sync($request->input("owner_id"));
  556. $model->logistics()->sync($request->input("logistic_id"));
  557. LogService::log(__METHOD__,"计费模型-修改物流计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  558. return response()->redirectTo("maintenance/priceModel/logistic")->with("successTip","修改“".$request->input("name")."”成功");
  559. }
  560. public function logisticGetDetail(Request $request)
  561. {
  562. if(!Gate::allows('计费模型-物流-查询')){ return ["success"=>false,"data"=>"无权操作"]; }
  563. $model = new OwnerPriceLogistic();
  564. $model->id = $request->input("id");
  565. $model->load(["details"=>function($query){
  566. /** @var Builder $query */
  567. $query->with(["unit","province","city"]);
  568. }]);
  569. return ["success"=>true,"data"=>$model->details];
  570. }
  571. public function expressExport($id)
  572. {
  573. if(!Gate::allows('计费模型-快递-查询')){ return ["success"=>false,"data"=>"无权操作"]; }
  574. $model = app("OwnerPriceExpressService")->find($id,[
  575. "owners","logistics","details"=>function($query){
  576. /** @var Builder $query */
  577. $query->with("province");
  578. }]);
  579. $row = ["客户","首重","续重","承运商"];
  580. $list = [[
  581. implode(",",array_column($model->owners->toArray(),"name")),
  582. $model->initial_weight,
  583. $model->additional_weight,
  584. implode(",",array_column($model->logistics->toArray(),"name")),
  585. ],[
  586. "价格名称","省","首重价格","续重价格",
  587. ]];
  588. foreach ($model->details as $detail){
  589. $list[] = [
  590. $model->name,
  591. $detail->province ? $detail->province->name : '',
  592. $detail->initial_weight_price,
  593. $detail->additional_weight_price,
  594. ];
  595. }
  596. return app(ExportService::class)->json($row,$list,"快递计费模型");
  597. }
  598. public function logisticImport(Request $request)
  599. {
  600. if(!Gate::allows('计费模型-物流-录入')){ return ["success"=>false,"data"=>"无权操作"]; }
  601. $fileSuffix=$request->file('file')->getClientOriginalExtension();
  602. if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
  603. return ['success'=>false,'data'=>'不支持该文件类型'];
  604. ini_set('max_execution_time',2500);
  605. ini_set('memory_limit','1526M');
  606. $fileSuffix = ucwords($fileSuffix);
  607. /** @var OwnerPriceLogistic $model */
  608. $model = app('OwnerPriceLogisticService')->find($request->input("id"),["unit","otherUnit","details"]);
  609. Excel::import(new OwnerPriceLogisticDetailImport($model),$request->file('file')->path(),null,$fileSuffix);
  610. if (Cache::has('logistic'))return Cache::pull('logistic');
  611. return ["success"=>false,"data"=>"导入发生错误,数据无响应"];
  612. }
  613. public function logisticExport($id)
  614. {
  615. if(!Gate::allows('计费模型-物流-查询')){ return ["success"=>false,"data"=>"无权操作"]; }
  616. $model = app("OwnerPriceLogisticService")->find($id,[
  617. "owners","logistics","unit","otherUnit","details"=>function($query){
  618. /** @var Builder $query */
  619. $query->with(["province","unit","city"]);
  620. }]);
  621. $row = ["客户","价格名称",
  622. "单位一区间/".($model->unit ? $model->unit->name : ''),
  623. "单位二区间/".($model->otherUnit ? $model->otherUnit->name : ''),
  624. "提货费","燃油附加费","信息服务费","创建时间","承运商"];
  625. $range = "";
  626. foreach (explode(",",$model->unit_range) as $str){
  627. $range .= $str."\r\n";
  628. }
  629. $otherRange = "";
  630. foreach (explode(",",$model->other_unit_range) as $str){
  631. $otherRange .= $str."\r\n";
  632. }
  633. $list = [[
  634. implode(",",array_column($model->owners->toArray(),"name")),
  635. $model->name,
  636. $range,
  637. $otherRange,
  638. $model->pick_up_price,
  639. $model->fuel_price,
  640. $model->service_price,
  641. $model->created_at,
  642. implode(",",array_column($model->logistics->toArray(),"name")),
  643. ],[
  644. "单位","区间","省份","市","单价","送货费","起始计费","起始计数","费率"
  645. ]];
  646. foreach ($model->details as $detail){
  647. $list[] = [
  648. $detail->unit ? $detail->unit->name : '',
  649. $detail->range,
  650. $detail->province ? $detail->province->name : '',
  651. $detail->city ? $detail->city->name : '',
  652. $detail->unit_price,
  653. $detail->delivery_fee,
  654. $detail->initial_fee,
  655. $detail->initial_amount,
  656. $detail->rate ? $detail->rate."%" : '',
  657. ];
  658. }
  659. return app(ExportService::class)->json($row,$list,"物流计费模型");
  660. }
  661. public function logisticUpdateDetail(Request $request)
  662. {
  663. if(!Gate::allows('计费模型-物流-编辑')){ return ["success"=>false,"data"=>"无权操作"]; }
  664. $detail = $request->input("detail");
  665. if ($detail["id"]){
  666. app('OwnerPriceLogisticService')->updateDetail(["id"=>$detail["id"]],[
  667. "unit_price" => $detail["unit_price"],
  668. "delivery_fee" => $detail["delivery_fee"],
  669. "initial_fee" => $detail["initial_fee"],
  670. "initial_amount" => $detail["initial_amount"],
  671. "rate" => $detail["rate"],
  672. ]);
  673. }else{
  674. $row = app('OwnerPriceLogisticService')->isExistDetail([
  675. "owner_price_logistic_id"=>$request->input("id"),
  676. "unit_id"=>$detail["unit_id"],
  677. "range"=>$detail["range"],
  678. "province_id"=>$detail["province_id"],
  679. "city_id"=>$detail["city_id"],
  680. ]);
  681. if ($row>0)return ["success"=>false,"data"=>"已存在该计费模型"];
  682. /** @var OwnerPriceExpressProvince $detail */
  683. $detail = app('OwnerPriceLogisticService')->createDetail([
  684. "owner_price_logistic_id"=>$request->input("id"),
  685. "unit_id"=>$detail["unit_id"],
  686. "range"=>$detail["range"],
  687. "province_id"=>$detail["province_id"],
  688. "city_id"=>$detail["city_id"],
  689. "unit_price" => $detail["unit_price"],
  690. "delivery_fee" => $detail["delivery_fee"],
  691. "initial_fee" => $detail["initial_fee"],
  692. "initial_amount" => $detail["initial_amount"],
  693. "rate" => $detail["rate"],
  694. ]);
  695. $detail->load("province","unit","city");
  696. }
  697. LogService::log(__METHOD__,"计费模型-修改物流计费详情",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  698. return ["success"=>true,"data"=>$detail];
  699. }
  700. public function logisticDestroyDetail(Request $request)
  701. {
  702. if(!Gate::allows('计费模型-物流-删除')){ return ["success"=>false,"data"=>"无权操作"]; }
  703. $id = $request->input("id");
  704. if (!$id)return ["success"=>false,"data"=>"非法参数"];
  705. app("OwnerPriceLogisticService")->destroyDetail($id);
  706. LogService::log(__METHOD__,"计费模型-删除物流计费详情",$id);
  707. return ["success"=>true];
  708. }
  709. private function logisticValidator(array $params,$id = null)
  710. {
  711. return Validator::make($params,[
  712. 'name'=>['required',$id?"unique:owner_price_logistics,name,$id":'unique:owner_price_logistics,name'],
  713. 'pick_up_price'=>['nullable','numeric','min:0'],
  714. 'fuel_price'=>['nullable','numeric','min:0'],
  715. 'service_price'=>['nullable','numeric','min:0'],
  716. 'unit_id'=>['required'],
  717. 'unit_range'=>['required',function ($attribute, $value, $fail) {
  718. $bool = app("OwnerPriceLogisticService")->checkRange($value);
  719. if (!$bool)$fail("格式错误,值必须为连续的且最后一个值不允许封闭");
  720. }],
  721. 'other_unit_id'=>['required'],
  722. 'other_unit_range'=>['required',function ($attribute, $value, $fail) {
  723. $bool = app("OwnerPriceLogisticService")->checkRange($value);
  724. if (!$bool)$fail("格式错误,值必须为连续的且最后一个值不允许封闭");
  725. }],
  726. ],[
  727. 'required'=>':attribute 为必填项',
  728. 'unique' => ':attribute 已存在',
  729. 'numeric' => ':attribute 必须为数字',
  730. 'min' => ':attribute 不得为负',
  731. ],[
  732. 'name' =>"名称",
  733. 'pick_up_price' =>"提货费",
  734. 'fuel_price' =>"燃油附加费",
  735. 'service_price' =>"信息服务费",
  736. 'unit_id' =>"单位一",
  737. 'unit_range' =>"区间值",
  738. 'other_unit_id' =>"单位二",
  739. 'other_unit_range' =>"区间值",
  740. ]);
  741. }
  742. public function directLogisticIndex(Request $request){
  743. if(!Gate::allows('计费模型-直发-查询')){ return redirect('denied'); }
  744. $models = app("OwnerPriceDirectLogisticService")->paginate($request->input("id"));
  745. return response()->view('maintenance.priceModel.directLogistic.index',compact("models"));
  746. }
  747. public function directLogisticCreate(){
  748. if(!Gate::allows('计费模型-直发-录入')){ return redirect('denied'); }
  749. $owners = app("OwnerService")->getSelection();
  750. return response()->view('maintenance.priceModel.directLogistic.create',compact("owners"));
  751. }
  752. public function directLogisticStore(Request $request)
  753. {
  754. if(!Gate::allows('计费模型-直发-录入')){ return redirect('denied'); }
  755. $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
  756. $this->directLogisticValidator($request->input())->validate();
  757. /** @var OwnerPriceDirectLogistic $model */
  758. $model = app("OwnerPriceDirectLogisticService")->create([
  759. "name" => $request->input("name"),
  760. "base_km" => $request->input("base_km"),
  761. ]);
  762. $model->owners()->sync($request->input("owner_id"));
  763. LogService::log(__METHOD__,"计费模型-录入直发车计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  764. return response()->redirectTo("maintenance/priceModel/directLogistic")->with("successTip","创建“".$request->input("name")."”成功");
  765. }
  766. public function directLogisticDestroy($id)
  767. {
  768. if(!Gate::allows('计费模型-直发-删除')){ return ["success"=>false,"data"=>"无权操作"]; }
  769. $row = app("OwnerPriceDirectLogisticService")->destroy($id);
  770. if ($row == 1){
  771. LogService::log(__METHOD__,"计费模型-删除直发车计费",$id);
  772. return ["success"=>true];
  773. }
  774. return ["success"=>false,"data"=>"影响了“".$row."”行"];
  775. }
  776. public function directLogisticEdit($id)
  777. {
  778. if(!Gate::allows('计费模型-直发-编辑')){ return redirect('denied'); }
  779. $owners = app("OwnerService")->getSelection();
  780. $model = app("OwnerPriceDirectLogisticService")->find($id)->append("owner_id");
  781. return response()->view('maintenance.priceModel.directLogistic.create',compact("model","owners"));
  782. }
  783. public function directLogisticUpdate($id, Request $request)
  784. {
  785. if(!Gate::allows('计费模型-直发-编辑')){ return redirect('denied'); }
  786. $request->offsetSet("owner_id",explode(",",$request->input("owner_id")));
  787. $this->directLogisticValidator($request->input(),$id)->validate();
  788. app("OwnerPriceDirectLogisticService")->update(["id"=>$id],[
  789. "name" => $request->input("name"),
  790. "base_km" => $request->input("base_km"),
  791. ]);
  792. $model = new OwnerPriceDirectLogistic();
  793. $model->id = $id;
  794. $model->owners()->sync($request->input("owner_id"));
  795. LogService::log(__METHOD__,"计费模型-修改直发车计费",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  796. return response()->redirectTo("maintenance/priceModel/directLogistic")->with("successTip","修改“".$request->input("name")."”成功");
  797. }
  798. public function directLogisticGetDetail(Request $request)
  799. {
  800. if(!Gate::allows('计费模型-直发-查询')){ return ["success"=>false,"data"=>"无权操作"]; }
  801. $model = new OwnerPriceDirectLogistic();
  802. $model->id = $request->input("id");
  803. $model->load(["details"=>function($query){
  804. /** @var Builder $query */
  805. $query->with("carType");
  806. }]);
  807. return ["success"=>true,"data"=>$model->details];
  808. }
  809. public function directLogisticImport(Request $request)
  810. {
  811. if(!Gate::allows('计费模型-直发-录入')){ return ["success"=>false,"data"=>"无权操作"]; }
  812. $fileSuffix=$request->file('file')->getClientOriginalExtension();
  813. if ($fileSuffix != 'xlsx' && $fileSuffix != 'xls' && $fileSuffix != 'csv')
  814. return ['success'=>false,'data'=>'不支持该文件类型'];
  815. ini_set('max_execution_time',2500);
  816. ini_set('memory_limit','1526M');
  817. $fileSuffix = ucwords($fileSuffix);
  818. $model = new OwnerPriceDirectLogistic();
  819. $model->id = $request->input("id");
  820. $model->load("details");
  821. Excel::import(new OwnerPriceDirectLogisticDetailImport($model),$request->file('file')->path(),null,$fileSuffix);
  822. if (Cache::has('directLogistic'))return Cache::pull('directLogistic');
  823. return ["success"=>false,"data"=>"导入发生错误,数据无响应"];
  824. }
  825. public function directLogisticUpdateDetail(Request $request)
  826. {
  827. if(!Gate::allows('计费模型-直发-编辑')){ return ["success"=>false,"data"=>"无权操作"]; }
  828. $detail = $request->input("detail");
  829. if ($detail["id"]){
  830. app('OwnerPriceDirectLogisticService')->updateDetail(["id"=>$detail["id"]],[
  831. "base_fee" => $detail["base_fee"],
  832. "additional_fee" => $detail["additional_fee"],
  833. ]);
  834. }else{
  835. $row = app('OwnerPriceDirectLogisticService')->isExistDetail([
  836. "owner_price_direct_logistic_id"=>$request->input("id"),
  837. "car_type_id"=>$detail["car_type_id"],
  838. ]);
  839. if ($row>0)return ["success"=>false,"data"=>"已存在该计费模型"];
  840. /** @var OwnerPriceExpressProvince $detail */
  841. $detail = app('OwnerPriceDirectLogisticService')->createDetail([
  842. "owner_price_direct_logistic_id"=>$request->input("id"),
  843. "car_type_id"=>$detail["car_type_id"],
  844. "base_fee" => $detail["base_fee"],
  845. "additional_fee" => $detail["additional_fee"],
  846. ]);
  847. $detail->load("carType");
  848. }
  849. LogService::log(__METHOD__,"计费模型-修改直发车计费详情",json_encode($request->input(),JSON_UNESCAPED_UNICODE));
  850. return ["success"=>true,"data"=>$detail];
  851. }
  852. public function directLogisticDestroyDetail(Request $request)
  853. {
  854. if(!Gate::allows('计费模型-直发-删除')){ return ["success"=>false,"data"=>"无权操作"]; }
  855. $id = $request->input("id");
  856. if (!$id)return ["success"=>false,"data"=>"非法参数"];
  857. app("OwnerPriceDirectLogisticService")->destroyDetail($id);
  858. LogService::log(__METHOD__,"计费模型-删除直发车计费详情",$id);
  859. return ["success"=>true];
  860. }
  861. private function directLogisticValidator(array $params, $id= null)
  862. {
  863. return Validator::make($params,[
  864. 'name'=>['required',$id?"unique:owner_price_direct_logistics,name,$id":'unique:owner_price_direct_logistics,name'],
  865. 'base_km'=>['required','numeric','min:0'],
  866. 'owner_id'=>[function ($attribute, $value, $fail)use($id) {
  867. $owners = app("OwnerPriceDirectLogisticService")->getExistOwnerName($value,$id);
  868. if ($owners)$fail("(".implode(',',$owners).') 已经绑定直发计费模型');
  869. }],
  870. ],[
  871. 'required'=>':attribute 为必填项',
  872. 'unique' => ':attribute 已存在',
  873. 'numeric' => ':attribute 必须为数字',
  874. 'min' => ':attribute 不得为负',
  875. ],[
  876. 'name' =>"名称",
  877. 'base_km' =>"起步公里数",
  878. ]);
  879. }
  880. }