StoreController.php 93 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Events\CancelOrderEvent;
  4. use App\Events\FinishAccount;
  5. use App\Events\AuthRefundTip;
  6. use App\Events\ReceivingEvent;
  7. use App\Events\RetailOutboundEvent;
  8. use App\Events\RestoreOutboundEvent;
  9. use App\Events\TipSendingEvent;
  10. use App\Events\TipPickUpEvent;
  11. use App\Models\Address;
  12. use App\Models\OrderExpressW;
  13. use App\Models\AgentNo;
  14. use App\Models\ShowNumW;
  15. use App\Models\Goods;
  16. use App\Models\OrderCancelW;
  17. use App\Models\OrderDetail;
  18. use App\Models\OrderRefund;
  19. use App\Models\OrderRefundW;
  20. use App\Models\VipLog;
  21. use App\Models\VipLogW;
  22. use App\Models\SettingW;
  23. use Carbon\Carbon;
  24. use Overtrue\EasySms\EasySms;
  25. use App\Handlers\RefundAmount;
  26. use App\Handlers\ExpressHandler;
  27. use App\Handlers\TencentHandler;
  28. use App\Handlers\UploadImg;
  29. use App\Models\Comment;
  30. use App\Models\Order;
  31. use App\Models\StoreGoods;
  32. use App\Models\InventoryW;
  33. use App\Models\See;
  34. use App\Models\Scan;
  35. use App\Models\User;
  36. use App\Models\Store;
  37. use App\Models\UserW;
  38. use App\Models\OrderW;
  39. use App\Models\OrderShareW;
  40. use App\Models\TestUserW;
  41. use App\Models\AddressW;
  42. use App\Models\OrderDetailW;
  43. use App\Models\StoreGoodsSku;
  44. use Illuminate\Http\Request;
  45. use Intervention\Image\Facades\Image;
  46. use EasyWeChat\Factory;
  47. use GuzzleHttp\Client;
  48. use Auth;
  49. use DB;
  50. use Storage;
  51. use Cache;
  52. use Log;
  53. use Validator;
  54. use TencentCloud\Common\Credential;
  55. use TencentCloud\Common\Profile\ClientProfile;
  56. use TencentCloud\Common\Profile\HttpProfile;
  57. use TencentCloud\Common\Exception\TencentCloudSDKException;
  58. use TencentCloud\Ocr\V20181119\OcrClient;
  59. use TencentCloud\Ocr\V20181119\Models\IDCardOCRRequest;
  60. use SimpleSoftwareIO\QrCode\Facades\QrCode;
  61. class StoreController extends Controller{
  62. //获取代理店铺信息
  63. public function getStoreInfo()
  64. {
  65. $user_id=Auth::user()->id;
  66. $user=User::where('id',$user_id)->first();
  67. //测试代理版
  68. // $test_user=TestUserW::pluck('phone')->toArray();
  69. // if(!in_array($user->mobile,$test_user)){
  70. // return $this->error('450002','你无权访问该页面');
  71. // }
  72. //正式版
  73. if($user->status <> 0 || $user->cert_status <> 6 || $user->service_status <> 0 || !empty($user->deleted_at)){
  74. return $this->error('450002','你无权访问该页面');
  75. }
  76. $store=Store::where('user_id',Auth::user()->id)->first();
  77. if(empty($store)){
  78. Store::create([
  79. 'img'=>$user->headimgurl,
  80. 'name'=>$user->nickname,
  81. 'user_id'=>$user->id,
  82. 'phone'=>$user->mobile
  83. ]);
  84. $store=Store::where('user_id',Auth::user()->id)->first();
  85. }
  86. if($store->status==1){
  87. return $this->error('450004','店铺已禁用');
  88. }
  89. $arr_test=Store::getTest();
  90. if($user->headimgurl != $store->img){
  91. Log::info($store->img);
  92. $store->img=$user->headimgurl;
  93. $store->save();
  94. }
  95. if($user->mobile != $store->phone){
  96. $store->phone=$user->mobile;
  97. $store->save();
  98. }
  99. if($user->nickname != $store->name){
  100. $store->name=$user->nickname;
  101. $store->save();
  102. }
  103. $star=Comment::where('store_id',$store->id)->average('star');
  104. $store->star=floor($star);
  105. if(in_array($store->id,$arr_test)){
  106. $store->is_test=1;
  107. }else{
  108. $store->is_test=0;
  109. }
  110. $no_pay=OrderW::where('store_id',$store->id)->where('is_pay',0)->where('apply_cancel',[0,1,3])->count();
  111. $no_refund=OrderRefundW::where('store_id',$store->id)->where('status',0)->count();
  112. $no_cancel=OrderCancelW::where('store_id',$store->id)->where('status',1)->count();
  113. $see_num=See::where('store_id',$store->id)->whereDate('created_at',date('Y-m-d'))->count();
  114. $order_num=OrderW::where('store_id',$store->id)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1])
  115. ->where('is_pay',1)->whereDate('created_at',date('Y-m-d'))->count();
  116. $order_money=OrderW::where('store_id',$store->id)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1])
  117. ->where('is_pay',1)->whereDate('created_at',date('Y-m-d'))->sum('account');
  118. $wait_send_num=OrderW::where('store_id',$store->id)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1,2])
  119. ->where('is_pay',1)->where('status',1)->count();
  120. $show_num=ShowNumW::where('obj_id',$store->id)->where('obj_type',1)->where('type',1)->first();
  121. $data['show_num1']=0;
  122. if($show_num){
  123. if($show_num->num < 3){
  124. $data['show_num1']=1;
  125. $show_num->num += 1;
  126. $show_num->save();
  127. }
  128. }else{
  129. ShowNumW::create([
  130. 'obj_id'=>$store->id,
  131. 'obj_type'=>1,
  132. 'type'=>1,
  133. 'name'=>'首页操作视频',
  134. 'num'=>1,
  135. ]);
  136. }
  137. $order_money=round($order_money);
  138. $data['user']=$user;
  139. $data['store']=$store;
  140. $data['wait_send_num']=$wait_send_num?$wait_send_num:0;
  141. $data['order_num']=$order_num?$order_num:0;
  142. $data['see_num']=$see_num?$see_num:0;
  143. $data['order_money']=$order_money?$order_money:'0';
  144. $data['no_pay']=$no_pay?$no_pay:'0';
  145. $data['no_auth']=$no_refund+$no_cancel;
  146. $home_operation_video=SettingW::where('key','home.operation.video')->value('value');
  147. $data['home_operation_video']=$home_operation_video;
  148. return $this->success($data);
  149. }
  150. public function getStoreData(){
  151. $user_id=Auth::user()->id;
  152. $user=User::where('id',$user_id)->first();
  153. $store=Store::where('user_id',Auth::user()->id)->first();
  154. if($user->headimgurl != $store->img){
  155. Log::info($store->img);
  156. $store->img=$user->headimgurl;
  157. $store->save();
  158. }
  159. if($user->mobile != $store->phone){
  160. $store->phone=$user->mobile;
  161. $store->save();
  162. }
  163. if($user->nickname != $store->name){
  164. $store->name=$user->nickname;
  165. $store->save();
  166. }
  167. $star=Comment::where('store_id',$store->id)->average('star');
  168. $store->star=floor($star);
  169. $no_pay=OrderW::where('store_id',$store->id)->where('is_pay',0)->where('apply_cancel',[0,1,3])->count();
  170. $no_refund=OrderRefundW::where('store_id',$store->id)->where('status',0)->count();
  171. $no_cancel=OrderCancelW::where('store_id',$store->id)->where('status',1)->count();
  172. $see_num=See::where('store_id',$store->id)->whereDate('created_at',date('Y-m-d'))->count();
  173. $order_num=OrderW::where('store_id',$store->id)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1])
  174. ->where('is_pay',1)->whereDate('created_at',date('Y-m-d'))->count();
  175. $order_money=OrderW::where('store_id',$store->id)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1])
  176. ->where('is_pay',1)->whereDate('created_at',date('Y-m-d'))->sum('account');
  177. $wait_send_num=OrderW::where('store_id',$store->id)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1,2])
  178. ->where('is_pay',1)->where('status',1)->count();
  179. $order_money=round($order_money);
  180. $data['user']=$user;
  181. $data['store']=$store;
  182. $data['wait_send_num']=$wait_send_num?$wait_send_num:0;
  183. $data['order_num']=$order_num?$order_num:0;
  184. $data['see_num']=$see_num?$see_num:0;
  185. $data['order_money']=$order_money?$order_money:'0';
  186. $data['no_pay']=$no_pay?$no_pay:'0';
  187. $data['no_auth']=$no_refund+$no_cancel;
  188. return $this->success($data);
  189. }
  190. //获取代理个人信息
  191. public function getAgentInfo(){
  192. $store = Store::where('user_id',Auth::user()->id)->first();
  193. if(empty($store->idCard)){
  194. return $this->error('450001','店铺未认证');
  195. }
  196. $cre_num=$store->idCard;
  197. $year=substr($cre_num,6,4);
  198. if($year>1920 && $year<2020) {
  199. $year .= '-01-01';
  200. $age = Carbon::parse($year)->diffInYears();
  201. }else{
  202. $age = 0;
  203. }
  204. $num=substr($cre_num,16,1);
  205. if($num%2==0){
  206. $sex = '女';
  207. }else{
  208. $sex = '男';
  209. }
  210. $name=$store->username;
  211. $phone=$store->phone;
  212. switch(Auth::user()->level){
  213. case 1:
  214. $level='销售主管';
  215. break;
  216. case 2:
  217. $level='销售经理';
  218. break;
  219. default:
  220. $level='代理公司';
  221. }
  222. $data=['username'=>$name,'sex'=>$sex,'age'=>$age,'phone'=>$phone,'level'=>$level,'cre_num'=>$cre_num];
  223. return $this->success($data);
  224. }
  225. //同意门店协议
  226. // public function setAgree()
  227. // {
  228. // $store=Store::where('user_id',Auth::user()->id)->first();
  229. // $store->is_agree=1;
  230. // $res=$store->save();
  231. // if($res){
  232. // return $this->success([]);
  233. // }else{
  234. // return $this->error();
  235. // }
  236. // }
  237. //修改店铺信息
  238. public function editStoreInfo(Request $request)
  239. {
  240. $input=$request->all();
  241. $rules=[
  242. 'name'=>'required|max:32'
  243. ];
  244. $message=[
  245. 'name.required'=>'用户名称不能为空.',
  246. 'name.max'=>'用户名称不能大于32个字符.'
  247. ];
  248. $validator = Validator::make($input,$rules,$message);
  249. if($validator->fails()){
  250. return $this->error('400013',$validator->errors()->first());
  251. }
  252. $store_id=$input['store_id'];
  253. $name=$input['name'];
  254. $res=Store::where('id',$store_id)->update(['name'=>$name]);
  255. if($res){
  256. return $this->success([]);
  257. }else{
  258. return $this->error();
  259. }
  260. }
  261. //修改手机号
  262. public function editSms(Request $request)
  263. {
  264. $rules=[
  265. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/',
  266. 'phone_code'=>'required|size:6',
  267. ];
  268. $message=[
  269. 'phone.required'=>'手机号不能为空.',
  270. 'phone.regex'=>'手机号格式有误.',
  271. 'phone_code.required'=>'验证码不能为空.',
  272. 'phone_code.size'=>'验证码为6位字符串.',
  273. ];
  274. $validator = Validator::make($request->input(),$rules,$message);
  275. if($validator->fails()){
  276. return $this->error('400013',$validator->errors()->first());
  277. }
  278. $phone=$request->input('phone');
  279. if($phone == Store::where('user_id',Auth::user()->id)->value('phone')){
  280. return $this->error('450001','新手机号不能与旧手机号相同');
  281. }
  282. if(Store::where('phone',$phone)->first()){
  283. return $this->error('450001','新手机号已绑定店铺');
  284. }
  285. $store_id=$request->input('store_id');
  286. $phone_code=$request->input('phone_code');
  287. $code=Cache::get('sms'.$phone);
  288. if($code==$phone_code){
  289. Cache::put('sms'.$phone,$code,-1);
  290. $res=Store::where('id',$store_id)->update(['phone'=>$phone]);
  291. if($res){
  292. return $this->success([]);
  293. }
  294. }else{
  295. return $this->error('450001','验证码有误');
  296. }
  297. return $this->error();
  298. }
  299. //校验手机验证码
  300. public function checkSms(Request $request)
  301. {
  302. $rules=[
  303. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/',
  304. 'phone_code'=>'required|size:6',
  305. ];
  306. $message=[
  307. 'phone.required'=>'手机号不能为空.',
  308. 'phone.regex'=>'手机号格式有误.',
  309. 'phone_code.required'=>'验证码不能为空.',
  310. 'phone_code.size'=>'验证码为6位字符串.',
  311. ];
  312. $validator = Validator::make($request->input(),$rules,$message);
  313. if($validator->fails()){
  314. return $this->error('400013',$validator->errors()->first());
  315. }
  316. $phone=$request->input('phone');
  317. $phone_code=$request->input('phone_code');
  318. $code=Cache::get('sms'.$phone);
  319. if($code==$phone_code){
  320. Cache::put('sms'.$phone,$code,-1);
  321. return $this->success([]);
  322. }else{
  323. return $this->error('450001','验证码有误');
  324. }
  325. }
  326. //发送验证码
  327. public function sendSms(Request $request){
  328. $rules=[
  329. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/'
  330. ];
  331. $message=[
  332. 'phone.required'=>'手机号不能为空.',
  333. 'phone.regex'=>'手机号格式有误.'
  334. ];
  335. $validator = Validator::make($request->input(),$rules,$message);
  336. if($validator->fails()){
  337. return $this->error('400013',$validator->errors()->first());
  338. }
  339. $phone=$request->input('phone');
  340. $config=config('easysms');
  341. $easySms = new EasySms($config);
  342. $code = mt_rand(100000,999999);
  343. $minute=5;
  344. if($request->input('type')=='card'){
  345. $content="您正在绑定身份信息,{$code}为您的验证码,请于{$minute}分钟内填写。如非本人操作,请忽略本短信。 ";
  346. }else{
  347. $content="您正在换绑手机号,{$code}为您的更换验证码,请于{$minute}分钟内填写。如非本人操作,请忽略本短信。";
  348. }
  349. Cache::put('sms'.$phone,$code,$minute*60);
  350. try{
  351. $easySms->send($phone, ['content' =>$content ]);
  352. } catch (\Overtrue\EasySms\Exceptions\NoGatewayAvailableException $exception) {
  353. $message = $exception->getException('qcloud')->getMessage();
  354. return $this->error(40013, $message == null ? '短信发送异常' : $message);
  355. }
  356. return $this->success([]);
  357. }
  358. //分享店铺信息
  359. public function shareStore()
  360. {
  361. $store=Store::where('user_id',Auth::user()->id)->first();
  362. $store->user=Auth::user();
  363. return $this->success($store);
  364. }
  365. //修改店铺图片
  366. public function uploadStoreImg(Request $request)
  367. {
  368. $path_url = 'public/store';
  369. $path = $request->file('img')->store($path_url);
  370. if($path){
  371. $store_id=$request->input('store_id');
  372. $url = env('APP_URL').Storage::url($path);
  373. $res=Store::where('id',$store_id)->update(['img'=>$url]);
  374. if ($res) {
  375. return $this->success($url);
  376. }
  377. }
  378. return $this->error();
  379. }
  380. //上传证件照片
  381. public function uploadCertImg(Request $request)
  382. {
  383. $paths='cert/'.date("Ymd").'/';
  384. $path_url = $paths.date("His").mt_rand(10000,99999).'.jpg';
  385. if(!is_dir($paths)){
  386. mkdir($paths,0755,true);
  387. }
  388. Log::info($path_url);
  389. $type=$request->input('type');//1人像面 2国徽面
  390. $file = $request->file('img');
  391. Log::info($file);
  392. $img=Image::make($file);
  393. Log::info(json_encode($img));
  394. // \Illuminate\Support\Facades\Log::error(1);
  395. if($img->filesize() > 1024*1024){
  396. $img->resize(800, null, function ($constraint) {
  397. $constraint->aspectRatio();
  398. })->save($path_url);
  399. }else{
  400. $img->save($path_url);
  401. }
  402. $path='/'.$img->basePath();
  403. if($path){
  404. $url = env('APP_URL').$path;
  405. Log::info('%%%%%%-----%%%%%%'.$url.'--'.$path.'---'.env('APP_URL'));
  406. }else{
  407. return $this->error('450001','证件上传失败');
  408. }
  409. try{
  410. // $certInfo=json_decode($this->getCertInfo($url),true);
  411. $tenCent = new TencentHandler();
  412. $certInfo=json_decode($tenCent->getCertInfo($url),true);
  413. }catch(\Exception $e){
  414. return $this->error('450001',$e->getMessage());
  415. }
  416. if(empty($certInfo)){
  417. return $this->error('450001','上传图片有误');
  418. }
  419. $AdvancedInfo=json_decode($certInfo['AdvancedInfo'],true);
  420. Log::info(Auth::user()->nickname.'身份证图片质量指数:'.$AdvancedInfo['Quality']);
  421. if($AdvancedInfo['Quality']<=55){
  422. return $this->error('450001','身份证图片模糊');
  423. }
  424. foreach($tenCent->AdvancedInfo() as $key=>$val){
  425. if(in_array($key,$AdvancedInfo['WarnInfos']))
  426. return $this->error('450001',$val);
  427. }
  428. if($type==1){
  429. if(empty($certInfo['Name'])){
  430. return $this->error('450001','请上传人像面图片');
  431. }else{
  432. Store::where('user_id',Auth::user()->id)->update(['cardImg1'=>$url]);
  433. }
  434. }elseif($type==2){
  435. if(empty($certInfo['Authority'])){
  436. return $this->error('450001','请上传国徽面图片');
  437. }else{
  438. Store::where('user_id',Auth::user()->id)->update(['cardImg2'=>$url]);
  439. }
  440. }else{
  441. return $this->error('450001','参数有误');
  442. }
  443. $certInfo['url']=$path;
  444. return $this->success($certInfo);
  445. }
  446. //上传活体人脸核身视频
  447. public function uploadFaceImg(Request $request){
  448. $path_url = 'public/cert/video/'.date('ymd');
  449. $path = $request->file('video')->store($path_url);
  450. if($path){
  451. $url = env('APP_URL').Storage::url($path);
  452. }else{
  453. return $this->error('450001','视频上传失败');
  454. }
  455. try{
  456. $tenCent = new TencentHandler();
  457. $certInfo=json_decode($tenCent->checkFaceId($idCard,$name,$url),true);
  458. }catch(\Exception $e){
  459. return $this->error('450001',$e->getMessage());
  460. }
  461. if(empty($certInfo) || $certInfo['Sim'] < 70){
  462. return $this->error('450001','认证失败');
  463. }
  464. if($certInfo['Result']=='Success' && $certInfo['Sim'] >= 70){
  465. return $this->success([]);
  466. }
  467. }
  468. //获取证件信息
  469. // public function getCertInfo($img)
  470. // {
  471. // $cred = new Credential(env('TENCENT_SECRETID'), env('TENCENT_SECRETKEY'));
  472. // $httpProfile = new HttpProfile();
  473. // $httpProfile->setEndpoint("ocr.tencentcloudapi.com");
  474. //
  475. // $clientProfile = new ClientProfile();
  476. // $clientProfile->setHttpProfile($httpProfile);
  477. // $client = new OcrClient($cred, "ap-beijing", $clientProfile);
  478. // $req = new IDCardOCRRequest();
  479. // $params = [
  480. // 'ImageUrl'=>$img,
  481. // 'Config' => json_encode(["CopyWarn"=>true,"BorderCheckWarn"=>true,"ReshootWarn"=>true,"DetectPsWarn"=>true,"TempIdWarn"=>true,"InvalidDateWarn"=>true,"Quality"=>true,"ReflectWarn"=>true])
  482. // ];//"CropIdCard"=>true,"CropPortrait"=>true,
  483. // $req->fromJsonString(json_encode($params));
  484. // $resp = $client->IDCardOCR($req);
  485. // return $resp->toJsonString();
  486. // }
  487. //活体人脸核身
  488. // public function checkFaceId($idCard,$name,$base)
  489. // {
  490. // $cred = new Credential(env('TENCENT_SECRETID'), env('TENCENT_SECRETKEY'));
  491. // $httpProfile = new HttpProfile();
  492. // $httpProfile->setEndpoint("faceid.tencentcloudapi.com");
  493. //
  494. // $clientProfile = new ClientProfile();
  495. // $clientProfile->setHttpProfile($httpProfile);
  496. // $client = new OcrClient($cred, "ap-beijing", $clientProfile);
  497. // $req = new IDCardOCRRequest();
  498. // $params = [
  499. // 'IdCard'=>$idCard,
  500. // 'Name'=>$name,
  501. // 'VideoBase64'=>$base,
  502. // 'LivenessType'=>'SILENT',//LIP为数字模式,ACTION为动作模式,SILENT为静默模式
  503. // ];
  504. // $req->fromJsonString(json_encode($params));
  505. // $resp = $client->IDCardOCR($req);
  506. // return $resp->toJsonString();
  507. // }
  508. //门店认证
  509. // public function certStore(Request $request)
  510. // {
  511. // $input=$request->all();
  512. // $rules=[
  513. // 'name'=>'required|max:32',
  514. // 'idCard'=>'required|size:18',
  515. // 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/',
  516. // 'phone_code'=>'required|size:6',
  517. // ];
  518. // $message=[
  519. // 'name.required'=>'用户名称不能为空',
  520. // 'name.max'=>'用户名称不能大于32个字符',
  521. // 'idCard.required'=>'证件号不能为空',
  522. // 'idCard.size'=>'证件号为18个字符',
  523. // 'phone.required'=>'手机号不能为空.',
  524. // 'phone.regex'=>'手机号格式有误.',
  525. // 'phone_code.required'=>'验证码不能为空.',
  526. // 'phone_code.size'=>'验证码为6位字符串.',
  527. // ];
  528. // $validator = Validator::make($input,$rules,$message);
  529. // if($validator->fails()){
  530. // return $this->error('400013',$validator->errors()->first());
  531. // }
  532. // $store_id=$input['store_id'];
  533. // $idCard=$input['idCard'];
  534. // $name=$input['name'];
  535. // $phone=$input['phone'];
  536. // $phone_code=$input['phone_code'];
  537. // $card_name=$input['card_name'];
  538. // $card_no=$input['card_no'];
  539. // $code=Cache::get('sms'.$phone);
  540. // if($code!=$phone_code){
  541. // return $this->error('450001','验证码有误');
  542. // }
  543. // Cache::put('sms'.$phone,$code,-1);
  544. // if($name != $card_name || $idCard!=$card_no){
  545. // return $this->error('450001','证件信息与输入个人信息不一致');
  546. // }
  547. // if(Store::where('idCard',$card_no)->first()){
  548. // return $this->error('450001','证件信息已被绑定');
  549. // }
  550. // $store=Store::where('id',$store_id)->first();
  551. // if($store){
  552. // $store->idCard=$idCard;
  553. // $store->username=$name;
  554. // $store->is_cert=1;
  555. // }else{
  556. // return $this->error('450001','店铺信息有误');
  557. // }
  558. // try{
  559. // DB::Transaction(function()use($store,$idCard){
  560. // $user=User::where('id',$store->user_id)->first();
  561. // if($user){
  562. // $user->cre_num=$idCard;
  563. // $user->save();
  564. // }
  565. //
  566. // $store->save();
  567. //
  568. // },5);
  569. // return $this->success([]);
  570. // }catch(\Exception $e){
  571. // return $this->error($e->getMessage());
  572. // }
  573. // }
  574. //添加新用户
  575. public function addUser(Request $request){
  576. $rules=[
  577. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/'
  578. ];
  579. $message=[
  580. 'phone.required'=>'手机号不能为空.',
  581. 'phone.regex'=>'手机号格式有误.'
  582. ];
  583. $validator = Validator::make($request->input(),$rules,$message);
  584. if($validator->fails()){
  585. return $this->error('400013',$validator->errors()->first());
  586. }
  587. $agent_id = Auth::user()->id;
  588. $phone=$request->input('phone');
  589. $nickname=$request->input('nickname');
  590. $is_vip=$request->input('is_vip');
  591. $store = Store::where('user_id',$agent_id)->first();
  592. $agent=User::where('mobile',$phone)->whereNull('deleted_at')->first();
  593. if($agent && in_array($agent->level,[3,2])){
  594. return $this->error('450001','该手机号是代理,无法添加');
  595. }
  596. $user=UserW::where('phone',$phone)->first();
  597. try{
  598. DB::transaction(function()use(&$user,$phone,$nickname,$store,$is_vip){
  599. if(empty($user)){
  600. $user=UserW::create([
  601. 'phone'=>$phone,
  602. 'name'=>$nickname?:$phone,
  603. 'avatar' => 'http://api.tongnianshijie.com/logo.jpg',
  604. 'nickname'=>$nickname?:$phone
  605. ]);
  606. }
  607. if($is_vip==1){
  608. $user->is_vip=1;
  609. VipLogW::firstORCreate(['user_id'=>$user->id,'store_id'=>$store->id],['order_no'=>null,'type'=>1,'remark'=>'代理手动添加vip']);
  610. }else{
  611. $user->is_vip=0;
  612. }
  613. },5);
  614. return $this->success($user);
  615. }catch(\Exception $e){
  616. return $this->error($e->getMessage());
  617. }
  618. }
  619. //设置vip
  620. public function setVip(Request $request){
  621. $agent_id=Auth::user()->id;
  622. $user_id=$request->input('user_id');
  623. $store_id=Store::where('user_id',$agent_id)->value('id');
  624. VipLogW::firstORCreate(['user_id'=>$user_id,'store_id'=>$store_id],['order_no'=>null,'type'=>1,'remark'=>'代理手动设置vip']);
  625. return $this->success([]);
  626. }
  627. //取消vip
  628. public function cancelVip(Request $request){
  629. $agent_id=Auth::user()->id;
  630. $user_id=$request->input('user_id');
  631. $store_id=Store::where('user_id',$agent_id)->value('id');
  632. $vip=VipLogW::where('store_id',$store_id)->where('user_id',$user_id)->first();
  633. if(empty($vip)){
  634. return $this->error('450001','该客户不是vip');
  635. }
  636. $orders=OrderW::where('store_id',$store_id)->where('user_id',$user_id)->get();
  637. if(count($orders)>0){
  638. return $this->error('450001','该客户已下单,无法取消vip');
  639. }
  640. $vip=VipLogW::where('store_id',$store_id)->where('user_id',$user_id)->first();
  641. $vip->remark=!empty($vip->remark)?$vip->remark.'->代理删除':'代理删除';
  642. $vip->save();
  643. $vip->delete();
  644. return $this->success([]);
  645. }
  646. //获取用户数据信息
  647. public function getUserDataInfo()
  648. {
  649. $store_id = Store::where('user_id',Auth::user()->id)->value('id');
  650. //客户总数
  651. $user_num = OrderW::where('store_id', $store_id)
  652. ->where('is_pay',1)->groupBy('user_id')
  653. ->whereIn('apply_cancel',[0,1,3])
  654. ->whereIn('is_refund',[0,1,2])
  655. ->get()->count();
  656. //订单数量
  657. $order_num = OrderW::where('store_id', $store_id)
  658. ->whereIn('apply_cancel',[0,1,3])
  659. ->whereIn('is_refund',[0,1,2])
  660. ->where('is_pay',1)->count();
  661. //总交易额
  662. $sale_total = OrderW::where('store_id', $store_id)->where('is_pay',1)->sum('account');
  663. $sale_total = round($sale_total);
  664. //扫码用户
  665. $scan_user = Scan::with('user:id,nickname,avatar')->where('store_id', $store_id)
  666. ->orderByDesc('created_at')->limit(5)->get();
  667. $scan_num = Scan::has('user')->where('store_id', $store_id)->count();
  668. $scan_7_num = Scan::has('user')->where('store_id', $store_id)->whereBetween('created_at', [date("Y-m-d H:i", strtotime('-7 days')), date("Y-m-d H:i")])->count();
  669. //已购客户
  670. // $buy_num=UserW::whereHas('order', function ($query)use($store_id) {
  671. // $query->where('store_id', $store_id)->where('is_pay', 1);
  672. // })->get()->count();
  673. // $buy_user = OrderW::with('user:id,nickname,avatar,phone')
  674. // ->where('store_id',$store_id)->where('is_pay',1)
  675. // ->orderByDesc('created_at')->limit(5)->get();
  676. // $user_ids=UserW::where('store_id',$store_id)->pluck('id');
  677. $userInfo=OrderW::with('user:id,nickname,avatar,phone')->has('user')
  678. ->where('store_id',$store_id)->where('is_pay',1)
  679. ->select('user_id',DB::raw('sum(total) as total'),DB::raw('sum(account) as amount'))
  680. ->groupBy('user_id')->orderByDesc('amount')
  681. ->orderByDesc('total')->orderBy('user_id')
  682. ->limit(5)->get();
  683. $buy_7_num = OrderW::where('store_id', $store_id)
  684. ->whereBetween('created_at', [date("Y-m-d H:i", strtotime('-7 days')), date("Y-m-d H:i")])
  685. ->where('is_pay',1)
  686. ->count();
  687. $data['user_num'] = $user_num ? $user_num : 0;
  688. $data['sale_total'] = $sale_total ? $sale_total : 0;
  689. $data['scan_user'] = $scan_user ? $scan_user : [];
  690. $data['scan_num'] = $scan_num ? $scan_num : 0;
  691. $data['scan_7_num'] = $scan_7_num ? $scan_7_num : 0;
  692. // $data['buy_user'] = $buy_user ? $buy_user : [];
  693. // $data['buy_num'] = $buy_num ? $buy_num : 0;
  694. $data['order_num'] = $order_num ? $order_num : 0;
  695. $data['buy_7_num'] = $buy_7_num ? $buy_7_num : 0;
  696. $data['user_info'] = $userInfo;
  697. return $this->success($data);
  698. }
  699. //扫码用户查看更多
  700. public function getMoreScan(Request $request)
  701. {
  702. $input = $request->input();
  703. $page_index = $input['page_index'];
  704. $page_size = $input['page_size'];
  705. $num = $page_size * ($page_index - 1);
  706. $store_id = Store::where('user_id',Auth::user()->id)->value('id');
  707. $data=Scan::with('user:id,nickname,avatar')
  708. ->has('user')
  709. ->where('store_id', $store_id);
  710. $count=$data->count();
  711. $list=$data->orderByDesc('created_at')->skip($num)->limit($page_size)->get();
  712. return $this->success_list($list,'成功',$count);
  713. }
  714. //已购客户查看更多
  715. public function getMoreBuy(Request $request)
  716. {
  717. $input=$request->input();
  718. $page_index=$input['page_index'];
  719. $page_size=$input['page_size'];
  720. $num=$page_size*($page_index-1);
  721. $store_id = Store::where('user_id',Auth::user()->id)->value('id');
  722. // $data=UserW::withCount(['order'=>function($query){
  723. // $query->select(DB::raw("sum(account) as money"));
  724. // }])
  725. // ->where('store_id', $store_id)->having('order_count','>',0);
  726. $data=OrderW::with('user:id,nickname,avatar,phone')
  727. ->where('store_id',$store_id)->where('is_pay',1);
  728. $count=$data->get()->count();
  729. $list=$data->orderByDesc('created_at')->skip($num)->limit($page_size)
  730. ->get();
  731. return $this->success_list($list,'成功',$count);
  732. }
  733. //获取更多用户信息
  734. public function getMoreUserInfo(Request $request){
  735. $input=$request->input();
  736. $page_index=$input['page_index'];
  737. $page_size=$input['page_size'];
  738. $num=$page_size*($page_index-1);
  739. $store_id = Store::where('user_id',Auth::user()->id)->value('id');
  740. $data=OrderW::with('user:id,nickname,avatar,phone')->has('user')
  741. ->where('store_id',$store_id)->where('is_pay',1)
  742. ->select('user_id',DB::raw('sum(total) as total'),DB::raw('sum(account) as amount'))
  743. ->groupBy('user_id');
  744. $count=$data->get()->count();
  745. $list=$data->orderByDesc('amount')->orderByDesc('total')->orderBy('user_id')
  746. ->skip($num)->limit($page_size)->get();
  747. return $this->success_list($list,'成功',$count);
  748. }
  749. //获取用户所有订单
  750. public function getUserAllOrder(Request $request){
  751. $user_id=$request->input('user_id');
  752. $status=$request->input('status');
  753. $page_size=$request->input('page_size');
  754. $page_index=$request->input('page_index');
  755. $num=$page_size*($page_index-1);
  756. $where=[];
  757. if($status!='all'){
  758. $where['status']=$status;
  759. }
  760. $where['user_id']=$user_id;
  761. $data=OrderW::with(['user:id,nickname,phone','order_cancel'=>function($query){
  762. $query->where('using',1);}])
  763. ->where($where)
  764. ->whereIn('apply_cancel',[0,1,3])
  765. ->orderByDesc('id');
  766. $count=$data->count();
  767. $orders=$data->skip($num)->take($page_size)->get();
  768. foreach($orders as $key=>$val){
  769. $goods_ids=OrderDetailW::where('order_no',$val->order_no)->groupBy('goods_id')->pluck('goods_id');
  770. $goods=[];
  771. foreach($goods_ids as $k=>$v){
  772. $goods[$k]=StoreGoods::where('id',$v)->first();
  773. $goods[$k]->sku=OrderDetailW::where('order_no',$val->order_no)->where('goods_id',$v)->get();
  774. }
  775. $orders[$key]->goods=$goods;
  776. }
  777. return $this->success_list($orders,'成功',$count);
  778. }
  779. //获取代为下单用户信息
  780. public function getUserInfo(Request $request)
  781. {
  782. $input=$request->all();
  783. $phone=$input['phone'];
  784. $user=UserW::where('phone',$phone)->first();
  785. if(empty($user)){
  786. return $this->error('450001','用户手机号有误');
  787. }
  788. if($user->status==1){
  789. return $this->error('450001','用户已被禁用');
  790. }
  791. return $this->success($user);
  792. }
  793. //获取用户所有收货地址
  794. public function getAllAddress(Request $request)
  795. {
  796. $input=$request->All();
  797. $agent_id=Auth::user()->id;
  798. $store_id=Store::where('user_id',$agent_id)->value('id');
  799. // $address=AddressW::where('user_id',$input['id'])->orderByDesc('is_default')->orderByDesc('created_at')->get();
  800. $address=AddressW::where('user_id',$input['id'])->where('store_id',$store_id)->where('type',2)->orderByDesc('is_default')->orderByDesc('created_at')->get();
  801. return $this->success($address);
  802. }
  803. //获取收货地址
  804. public function getAddress(Request $request)
  805. {
  806. $input=$request->All();
  807. $agent_id=Auth::user()->id;
  808. $store_id=Store::where('user_id',$agent_id)->value('id');
  809. // $data['address']=AddressW::where('user_id',$input['id'])->orderByDesc('is_default')->orderByDesc('created_at')->first();
  810. $data['address']=AddressW::where('user_id',$input['id'])->where('store_id',$store_id)->where('type',2)->orderByDesc('is_default')->orderByDesc('created_at')->first();
  811. $data['store']=Store::with('address_store')->where('user_id',Auth::user()->id)->first();
  812. return $this->success($data);
  813. }
  814. //添加收货地址
  815. public function addAddress(Request $request)
  816. {
  817. $input=$request->all();
  818. $rules=[
  819. 'name'=>'required|max:32',
  820. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/',
  821. 'province'=>'required',
  822. 'city'=>'required',
  823. 'area'=>'required',
  824. 'address'=>'required|max:255',
  825. ];
  826. $message=[
  827. 'name.required'=>'收货人不能为空.',
  828. 'name.max'=>'收货人姓名不能大于32个字符.',
  829. 'phone.required'=>'手机号不能为空.',
  830. 'phone.regex'=>'手机号格式有误.',
  831. 'province.required'=>'省不能为空.',
  832. 'city.required'=>'市不能为空.',
  833. 'area.required'=>'区/县不能为空.',
  834. 'address.required'=>'详细地址不能为空.',
  835. 'address.max'=>'详细地址不能大于255个字符.'
  836. ];
  837. $validator = Validator::make($input,$rules,$message);
  838. if($validator->fails()){
  839. return $this->error('400013',$validator->errors()->first());
  840. }
  841. $count=AddressW::where('user_id',$input['user_id'])->count();
  842. if($count>=10){
  843. return $this->error('450001','用户地址数量已达上限');
  844. }
  845. if($input['is_default']==1){
  846. AddressW::where('user_id',$input['user_id'])->update(['is_default'=>0]);
  847. }
  848. $agent_id=Auth::user()->id;
  849. $store_id=Store::where('user_id',$agent_id)->value('id');
  850. $res=AddressW::create([
  851. 'name'=>$input['name'],
  852. 'phone'=>$input['phone'],
  853. 'user_id'=>$input['user_id'],
  854. 'store_id'=>$store_id,
  855. 'province'=>$input['province'],
  856. 'city'=>$input['city'],
  857. 'area'=>$input['area'],
  858. 'address'=>$input['address'],
  859. 'is_default'=>$input['is_default'],
  860. 'remark'=>$input['remark'],
  861. 'type'=>2,
  862. ]);
  863. if($res){
  864. return $this->success([]);
  865. }else{
  866. return $this->error();
  867. }
  868. }
  869. //修改收货地址
  870. public function updateAddress(Request $request)
  871. {
  872. $input=$request->all();
  873. $rules=[
  874. 'name'=>'required|max:32',
  875. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/',
  876. 'province'=>'required',
  877. 'city'=>'required',
  878. 'area'=>'required',
  879. 'address'=>'required|max:255',
  880. ];
  881. $message=[
  882. 'name.required'=>'收货人不能为空.',
  883. 'name.max'=>'收货人姓名不能大于32个字符.',
  884. 'phone.required'=>'手机号不能为空.',
  885. 'phone.regex'=>'手机号格式有误.',
  886. 'province.required'=>'省不能为空.',
  887. 'city.required'=>'市不能为空.',
  888. 'area.required'=>'区/县不能为空.',
  889. 'address.required'=>'详细地址不能为空.',
  890. 'address.max'=>'详细地址不能大于255个字符.'
  891. ];
  892. $validator = Validator::make($input,$rules,$message);
  893. if($validator->fails()){
  894. return $this->error('400013',$validator->errors()->first());
  895. }
  896. $address_id=$input['address_id'];
  897. $address=AddressW::where('id',$address_id)->first();
  898. if($input['is_default']==1){
  899. AddressW::where('user_id',$address->user_id)->update(['is_default'=>0]);
  900. }
  901. $res=AddressW::where('id',$address_id)->update([
  902. 'name'=>$input['name'],
  903. 'phone'=>$input['phone'],
  904. 'province'=>$input['province'],
  905. 'city'=>$input['city'],
  906. 'area'=>$input['area'],
  907. 'address'=>$input['address'],
  908. 'is_default'=>$input['is_default'],
  909. 'remark'=>$input['remark'],
  910. ]);
  911. if($res){
  912. return $this->success([]);
  913. }else{
  914. return $this->error();
  915. }
  916. }
  917. //删除收货地址
  918. public function destroyAddress(Request $request)
  919. {
  920. $res=AddressW::where('id',$request->input('id'))->delete();
  921. if($res){
  922. return $this->success([]);
  923. }else{
  924. return $this->error();
  925. }
  926. }
  927. //设为默认地址
  928. public function setDefaultAddress(Request $request)
  929. {
  930. $address=AddressW::where('id',$request->input('id'))->first();
  931. try{
  932. DB::connection('mysql_w')->transaction(function()use($address){
  933. if($address->is_default == 1) {
  934. $address->is_default = 0;
  935. $address->save();
  936. }else{
  937. $address->is_default = 1;
  938. $address->save();
  939. AddressW::where('user_id',$address->user_id)->whereNotIn('id',[$address->id])->update(['is_default'=>0]);
  940. }
  941. },5);
  942. return $this->success([]);
  943. }catch(\Exception $e){
  944. return $this->error($e->getMessage());
  945. }
  946. }
  947. //判断订单价格
  948. protected function getOrderPrice($user_id,$store_id,$num){
  949. $vipLog=VipLogW::where('user_id',$user_id)->where('store_id',$store_id)->first();
  950. if($vipLog){
  951. return 'vip_ed';//vip价格
  952. }else{
  953. if($num>=2){
  954. return 'vip_ing';//vip价格
  955. }else{
  956. return 'normal';//正常价
  957. }
  958. }
  959. }
  960. //记录下单时代理关系
  961. protected function saveAgentNoLog($user_id,$agent_id,$order_no){
  962. $one=$agent_id;
  963. $one_agent=User::where('id',$one)->first();
  964. $data=[];
  965. $data[0]['order_no'] = $order_no;
  966. $data[0]['user_id'] = $user_id;
  967. // $data[0]['agent_id'] = $one;
  968. $data[0]['level'] = $one_agent->level;
  969. $data[0]['nickname'] = $one_agent->nickname;
  970. $data[0]['phone'] = $one_agent->mobile;
  971. $data[0]['created_at'] = date("Y-m-d H:i:s");
  972. $data[0]['updated_at'] = date("Y-m-d H:i:s");
  973. if($one_agent->level==2 || $one_agent->level==1){
  974. $two=User::where('id',$one)->value('agent_id');
  975. $two_agent=User::where('id',$two)->first();
  976. $data[1]['order_no'] = $order_no;
  977. $data[1]['user_id'] = $user_id;
  978. // $data[1]['agent_id'] = $two;
  979. $data[1]['level'] = $two_agent->level;
  980. $data[1]['nickname'] = $two_agent->nickname;
  981. $data[1]['phone'] = $two_agent->mobile;
  982. $data[1]['created_at'] = date("Y-m-d H:i:s");
  983. $data[1]['updated_at'] = date("Y-m-d H:i:s");
  984. if($two_agent->level==2){
  985. $three=User::where('id',$two)->value('agent_id');
  986. $three_agent=User::where('id',$three)->first();
  987. $data[2]['order_no'] = $order_no;
  988. $data[2]['user_id'] = $user_id;
  989. // $data[2]['agent_id'] = $three;
  990. $data[2]['level'] = $three_agent->level;
  991. $data[2]['nickname'] = $three_agent->nickname;
  992. $data[2]['phone'] = $three_agent->mobile;
  993. $data[2]['created_at'] = date("Y-m-d H:i:s");
  994. $data[2]['updated_at'] = date("Y-m-d H:i:s");
  995. }
  996. }
  997. return $data;
  998. }
  999. //代下单或分享提交订单
  1000. public function submitOrderInfo(Request $request)
  1001. {
  1002. $input=$request->all();
  1003. Log::error($input);
  1004. $sku=$input['sku'];
  1005. $user=UserW::find($input['user_id']);
  1006. $agent=User::find(Auth::user()->id);
  1007. $store_id=Store::where('user_id',Auth::user()->id)->value('id');
  1008. $remark=$input['remark'];
  1009. $order_no=$this->order_no('dx');
  1010. $account=$vip_account=$cost_account=$num=0;
  1011. $data=$snapshot=[];
  1012. foreach($sku as $key=>$val){
  1013. if($val[1] > 0){
  1014. $num += $val[1];
  1015. }
  1016. }
  1017. $vip=$this->getOrderPrice($user->id,$store_id,$num);
  1018. $arr_test=Store::getTest();
  1019. foreach($sku as $key=>$val){
  1020. $sku_info=[];
  1021. $goodSku=StoreGoodsSku::with(['goods'])->where('id',$val[0])->first();
  1022. if(!array_key_exists($goodSku->goods_id,$snapshot)){
  1023. $snapshot[$goodSku->goods_id]['name']=$goodSku->goods->name;
  1024. $snapshot[$goodSku->goods_id]['main_attr']=$goodSku->goods->main_attr;
  1025. $snapshot[$goodSku->goods_id]['img']=$goodSku->goods->img;
  1026. $snapshot[$goodSku->goods_id]['price']=$goodSku->goods->price;
  1027. $snapshot[$goodSku->goods_id]['sku']=[];
  1028. }
  1029. if(in_array($store_id,$arr_test)){
  1030. $storeInventory=InventoryW::where(['store_id'=>$store_id,'goods_id'=>$goodSku->goods_id,'sku_id'=>$val[0]])->lockForUpdate()->first();
  1031. $storeInve_num=!empty($storeInventory)?$storeInventory->num:0;
  1032. if($val[1] > $storeInve_num){
  1033. return $this->error('450001','【'.$goodSku->goods->main_attr.'-'.$goodSku->type.'-'.$goodSku->size.'】库存不足');
  1034. }
  1035. }
  1036. if(empty($goodSku)){
  1037. return $this->error('450001','商品规格不存在,刷新页面重新下单');
  1038. }
  1039. if($agent->level==1){
  1040. $cost_account += $goodSku->goods->super_price * $val[1];
  1041. $data[$key]['cost_price']=$goodSku->goods->super_price;
  1042. $data[$key]['cost_account']=$goodSku->goods->super_price * $val[1];
  1043. }
  1044. if($agent->level==2){
  1045. $cost_account += $goodSku->goods->top_price * $val[1];
  1046. $data[$key]['cost_price']=$goodSku->goods->top_price;
  1047. $data[$key]['cost_account']=$goodSku->goods->top_price * $val[1];
  1048. }
  1049. if($agent->level==3){
  1050. $cost_account += $goodSku->goods->crown_price * $val[1];
  1051. $data[$key]['cost_price']=$goodSku->goods->crown_price;
  1052. $data[$key]['cost_account']=$goodSku->goods->crown_price * $val[1];
  1053. }
  1054. if($vip=='vip_ed' || $vip=='vip_ing'){
  1055. $data[$key]['price']=$goodSku->goods->vip_price;
  1056. $sku_info['price']=$goodSku->goods->vip_price;
  1057. $data[$key]['account']=$goodSku->goods->vip_price * $val[1];
  1058. $account += $goodSku->goods->vip_price * $val[1];
  1059. }else{
  1060. $data[$key]['price']=$goodSku->goods->price;
  1061. $sku_info['price']=$goodSku->goods->price;
  1062. $data[$key]['account']=$goodSku->goods->price * $val[1];
  1063. $account += $goodSku->goods->price * $val[1];
  1064. }
  1065. $data[$key]['origin_price']=$goodSku->goods->price;
  1066. $data[$key]['order_no']=$order_no;
  1067. $data[$key]['goods_id']=$goodSku->goods_id;
  1068. $data[$key]['store_id']=$store_id;
  1069. $data[$key]['user_id']=$user->id;
  1070. $data[$key]['sku_id']=$goodSku->id;
  1071. $data[$key]['num']=$val[1];
  1072. $data[$key]['size']=$goodSku->size;
  1073. $data[$key]['type']=$goodSku->type;
  1074. $data[$key]['style']=1;
  1075. $data[$key]['created_at']=date("Y-m-d H:i:s");
  1076. $data[$key]['updated_at']=date("Y-m-d H:i:s");
  1077. $sku_info['origin_price']=$goodSku->goods->price;
  1078. $sku_info['sku_id']=$goodSku->id;
  1079. $sku_info['num']=$val[1];
  1080. $sku_info['size']=$goodSku->size;
  1081. $sku_info['type']=$goodSku->type;
  1082. array_push($snapshot[$goodSku->goods_id]['sku'],$sku_info);
  1083. }
  1084. $order_data=[
  1085. 'order_no'=>$order_no,
  1086. 'store_id'=>$store_id,
  1087. 'user_id'=>$user->id,
  1088. 'remark'=>$remark,
  1089. 'status'=>0,
  1090. 'is_help'=>1,
  1091. 'op_id'=>Auth::user()->id,
  1092. 'op_name'=>Auth::user()->nickname,
  1093. 'is_pay'=>0,
  1094. 'is_tip_send'=>0,
  1095. 'is_comment'=>0,
  1096. 'total'=>$num,
  1097. 'account'=>$account,
  1098. 'cost_account'=>$cost_account,
  1099. 'snapshot'=>json_encode($snapshot)
  1100. ];
  1101. $agent_id=Store::where('id',$store_id)->value('user_id');
  1102. $agent_data=$this->saveAgentNoLog($user->id,$agent_id,$order_no);
  1103. DB::connection('mysql_w')->beginTransaction();
  1104. try{
  1105. $result=OrderW::create($order_data); //生成订单
  1106. // Log::info($result);
  1107. foreach($data as $k=>$v){
  1108. $data[$k]['order_id']=$result->id;
  1109. }
  1110. OrderDetailW::insert($data); //生成订单商品详情
  1111. AgentNo::insert( $agent_data); //代理关系
  1112. DB::connection('mysql_w')->commit();
  1113. return $this->success($order_no);
  1114. }catch(\Exception $e){
  1115. DB::connection('mysql_w')->rollback();
  1116. return $this->error('450001','提交失败',$e->getMessage());
  1117. }
  1118. }
  1119. //修改订单备注信息
  1120. public function editOrderRemark(Request $request){
  1121. $order_no=$request->input('order_no');
  1122. $remark=$request->input('remark');
  1123. $res=OrderW::where('order_no',$order_no)->update([
  1124. 'remark'=>$remark
  1125. ]);
  1126. if($res){
  1127. return $this->success([]);
  1128. }else{
  1129. return $this->error();
  1130. }
  1131. }
  1132. //分享订单
  1133. public function shareOrderInfo(Request $request)
  1134. {
  1135. $input=$request->all();
  1136. $store_id=Store::where('user_id',Auth::user()->id)->value('id');
  1137. $sku=$input['sku'];
  1138. // $user=UserW::find($input['user_id']);
  1139. $self_receive=$input['self_receive'];//不自提0 自提1
  1140. if($self_receive==1){
  1141. $address_id=Store::where('id',$store_id)->value('address_id');
  1142. }else{
  1143. $address_id=$input['address_id'];
  1144. }
  1145. $remark=$input['remark'];
  1146. $order_no=$this->order_no('fx');
  1147. $account=$vip_account=$num=0;
  1148. $data=[];
  1149. foreach($sku as $key=>$val){
  1150. $goodSku=StoreGoodsSku::with(['goods'])->where('id',$val[0])->first();
  1151. if(empty($goodSku)){
  1152. return $this->error('450001','商品规格不存在,请重新分享');
  1153. }
  1154. $account += $goodSku->goods->price * $val[1];
  1155. $num += $val[1];
  1156. $data[$key]['order_no']=$order_no;
  1157. $data[$key]['goods_id']=$goodSku->goods_id;
  1158. $data[$key]['sku_id']=$goodSku->id;
  1159. $data[$key]['num']=$val[1];
  1160. $data[$key]['price']=$goodSku->goods->price;
  1161. $data[$key]['account']=$goodSku->goods->price * $val[1];
  1162. $data[$key]['size']=$goodSku->size;
  1163. $data[$key]['type']=$goodSku->type;
  1164. $data[$key]['created_at']=date("Y-m-d H:i:s");
  1165. $data[$key]['updated_at']=date("Y-m-d H:i:s");
  1166. }
  1167. $order_data=[
  1168. 'order_no'=>$order_no,
  1169. 'store_id'=>$store_id,
  1170. 'user_id'=>$input['user_id'],
  1171. 'address_id'=>$address_id,
  1172. 'self_receive'=>$self_receive,
  1173. 'remark'=>$remark,
  1174. 'op_id'=>Auth::user()->id,
  1175. 'op_name'=>Auth::user()->nickname,
  1176. 'total'=>$num,
  1177. 'account'=>$account,
  1178. ];
  1179. DB::connection('mysql_w')->beginTransaction();
  1180. try{
  1181. OrderDetailW::insert($data);
  1182. OrderShareW::create($order_data);
  1183. DB::connection('mysql_w')->commit();
  1184. return $this->success($order_no);
  1185. }catch(\Exception $e){
  1186. DB::connection('mysql_w')->rollback();
  1187. return $this->error('450001','提交失败',$e->getMessage());
  1188. }
  1189. }
  1190. //生成订单号
  1191. public function order_no($type='dx')
  1192. {
  1193. if($type=='fx'){
  1194. $prefix = 'FX';
  1195. }else{
  1196. $prefix = 'DX';
  1197. }
  1198. $timestamp=date('ymdHis') . substr(microtime(), 2, 6);
  1199. $rand=mt_rand(10000, 99999);
  1200. $order_no=$prefix . $timestamp . $rand;
  1201. if(OrderW::where('order_no',$order_no)->first()){
  1202. $this->order_no($type);
  1203. }else{
  1204. return $order_no;
  1205. }
  1206. }
  1207. //审核订单取消
  1208. public function authOrderCancel(Request $request){
  1209. $id=$request->input('id');
  1210. $type=$request->input('type');//2通过//3驳回
  1211. $remark=$request->input('remark');
  1212. DB::connection('mysql')->beginTransaction();
  1213. DB::connection('mysql_w')->beginTransaction();
  1214. try{
  1215. $cancel=OrderCancelW::where('id',$id)->first();
  1216. $cancel->status=$type;
  1217. $cancel->remark=$remark;
  1218. $cancel->save();
  1219. $order=OrderW::where('id',$cancel->order_id)->first();
  1220. $order->apply_cancel= $type;
  1221. $order->cancel_at=date("Y-m-d H:i:s");
  1222. $order->save();
  1223. $first='取消订单被驳回';
  1224. if($type==2){//同意取消
  1225. //退款
  1226. $refund=new RefundAmount();
  1227. $res=$refund->refundAmount($cancel->order_id);
  1228. if($res[0]=='450001'){
  1229. return $this->error('450001',$res[1]);
  1230. }
  1231. if($res[0]=='450000'){
  1232. return $this->error('450001','取消订单退款失败',$res[1]);
  1233. }
  1234. //判断是否剥夺vip
  1235. if($order->vip==1){
  1236. $orders=OrderW::where('user_id',$order->user_id)
  1237. ->where('store_id',$order->store_id)
  1238. ->where('is_pay',1)
  1239. ->whereIn('apply_cancel',[0,1,3])
  1240. ->whereIn('is_refund',[0,1])
  1241. ->where('total','>=',2)
  1242. ->where('created_at','>',$order->created_at)
  1243. ->orderBy('created_at')->get();
  1244. if(count($orders)>=1){
  1245. OrderW::where('id',$orders[0]->id)->update([
  1246. 'vip'=>1
  1247. ]);
  1248. }else{
  1249. VipLogW::where('user_id',$order->user_id)->where('store_id',$order->store_id)->delete();
  1250. }
  1251. }
  1252. //判断恢复库存
  1253. $store=Store::where('id',$order->store_id)->first();
  1254. $level=User::where('id',$store->user_id)->value('level');
  1255. if($level==3){
  1256. event(new RestoreOutboundEvent($order->order_no));
  1257. }
  1258. $first='取消订单审核成功';
  1259. }
  1260. //取消订单通知
  1261. $user=UserW::where('id',$order->user_id)->first();
  1262. if($user->openId){
  1263. $data['openid']=$user->openId;
  1264. $data['data']=[
  1265. 'first' => '您的订单:'.$order->order_no.$first,
  1266. 'keyword1' => $user->nickname,
  1267. 'keyword2' => $order->order_no,
  1268. 'keyword3' => '已取消',
  1269. 'keyword4' => $order->cancel_at
  1270. ];
  1271. event(new CancelOrderEvent($data));
  1272. }
  1273. DB::connection('mysql')->commit();
  1274. DB::connection('mysql_w')->commit();
  1275. return $this->success([]);
  1276. }catch(\Exception $e){
  1277. DB::connection('mysql')->rollback();
  1278. DB::connection('mysql_w')->rollback();
  1279. return $this->error('450001','失败',$e->getMessage());
  1280. }
  1281. }
  1282. //代理取消订单
  1283. public function cancelOrder(Request $request){
  1284. $order_id=$request->input('order_id');
  1285. $order=OrderW::where('id',$order_id)->first();
  1286. // if($order->is_help==0){//用户自己下单
  1287. // return $this->error('450001','用户自己下单代理不能取消');
  1288. // }
  1289. if($order->apply_cancel==1){
  1290. return $this->error('450001','该订单正在审核中,不能再次取消');
  1291. }
  1292. if($order->apply_cancel==2){
  1293. return $this->error('450001','该订单已取消,不能再次取消');
  1294. }
  1295. DB::connection('mysql')->beginTransaction();
  1296. DB::connection('mysql_w')->beginTransaction();
  1297. try {
  1298. //退款
  1299. if($order->is_pay==1){
  1300. $refund=new RefundAmount();
  1301. $res=$refund->refundAmount($order->id);
  1302. if($res[0]=='450001'){
  1303. return $this->error('450001',$res[1]);
  1304. }
  1305. if($res[0]=='450000'){
  1306. return $this->error('450001','退款失败',$res[1]);
  1307. }
  1308. }
  1309. //判断是否剥夺vip
  1310. if($order->vip==1){
  1311. $orders=OrderW::where('user_id',$order->user_id)
  1312. ->where('store_id',$order->store_id)
  1313. ->where('is_pay',1)
  1314. ->whereIn('apply_cancel',[0,1,3])
  1315. ->whereIn('is_refund',[0,1])
  1316. ->where('total','>=',2)
  1317. ->where('created_at','>',$order->created_at)
  1318. ->orderBy('created_at')->get();
  1319. if(count($orders)>=1){
  1320. OrderW::where('id',$orders[0]->id)->update([
  1321. 'vip'=>1
  1322. ]);
  1323. }else{
  1324. VipLogW::where('user_id',$order->user_id)->where('store_id',$order->store_id)->delete();
  1325. }
  1326. }
  1327. //判断恢复库存
  1328. $store=Store::where('id',$order->store_id)->first();
  1329. $level=User::where('id',$store->user_id)->value('level');
  1330. if($level==3){
  1331. event(new RestoreOutboundEvent($order->order_no));
  1332. }
  1333. //取消订单
  1334. OrderW::where('id', $order_id)->update([
  1335. 'apply_cancel'=>2,
  1336. 'cancel_at'=>date("Y-m-d H:i:s")
  1337. ]);
  1338. OrderCancelW::where('user_id',$order->user_id)
  1339. ->where('store_id',$order->store_id)
  1340. ->where('order_id',$order->id)->update(['using'=>0]);
  1341. OrderCancelW::create([
  1342. 'user_id' =>$order->user_id,
  1343. 'store_id'=>$order->store_id,
  1344. 'order_id'=>$order->id,
  1345. 'status' =>2,
  1346. 'using' =>1,
  1347. 'type' =>2, //代理取消订单
  1348. 'reason' =>'代理取消订单'
  1349. ]);
  1350. //取消订单通知
  1351. $user=UserW::where('id',$order->user_id)->first();
  1352. if($user->openId){
  1353. $data['openid']=$user->openId;
  1354. $data['data']=[
  1355. 'first' => '您的订单:'.$order->order_no.'已被代理成功取消',
  1356. 'keyword1' => $user->nickname,
  1357. 'keyword2' => $order->order_no,
  1358. 'keyword3' => '已取消',
  1359. 'keyword4' => date("Y-m-d H:i:s")
  1360. ];
  1361. event(new CancelOrderEvent($data));
  1362. }
  1363. DB::connection('mysql')->commit();
  1364. DB::connection('mysql_w')->commit();
  1365. return $this->success([]);
  1366. }catch(\Exception $e){
  1367. DB::connection('mysql')->rollback();
  1368. DB::connection('mysql_w')->rollback();
  1369. return $this->error('450001','失败',$e->getMessage());
  1370. }
  1371. }
  1372. //获取订单状态数量
  1373. public function getOrderStatusNum(Request $request){
  1374. $store=Store::where('user_id',Auth::user()->id)->first();
  1375. $user_id=$request->input('user_id');
  1376. if($user_id){
  1377. $where['user_id']=$user_id;
  1378. }
  1379. $where['store_id']=$store->id;
  1380. $data=OrderW::where($where)->whereIn('apply_cancel',[0,1,3])->whereIn('is_refund',[0,1,2]);
  1381. $data1=clone $data;
  1382. $data2=clone $data;
  1383. $data3=clone $data;
  1384. $num['noPay']=$data->where('status',0)->count();
  1385. $num['noSend']=$data1->where('status',1)->count();
  1386. $num['noReceive']=$data2->where('status',2)->count();
  1387. $num['Finish']=$data3->where('status',3)->count();
  1388. return $this->success($num);
  1389. }
  1390. //获取订单列表
  1391. public function getOrderList(Request $request)
  1392. {
  1393. $input=$request->all();
  1394. $status=$input['status'];
  1395. $page_index=$input['page_index'];
  1396. $page_size=$input['page_size'];
  1397. $order_no=$input['order_no'];
  1398. $num=$page_size*($page_index-1);
  1399. $where=$wheres=[];
  1400. if($status!='all'){
  1401. $where['status']=$status;
  1402. }
  1403. if($order_no){
  1404. $wheres=function($query)use($order_no){
  1405. $query->where('order_no','like','%'.$order_no.'%');
  1406. };
  1407. }
  1408. $store=Store::where('user_id',Auth::user()->id)->first();
  1409. $where['store_id']=$store->id;
  1410. $data=OrderW::with(['user:id,nickname,phone','order_cancel'=>function($query){
  1411. $query->where('using',1);}])->where($where)->where($wheres)->whereIn('apply_cancel',[0,1,3])
  1412. ->whereIn('is_refund',[0,1,2])
  1413. ->orderByDesc('updated_at')->orderByDesc('id');
  1414. $count=$data->count();
  1415. $orders=$data->skip($num)->take($page_size)->get();
  1416. foreach($orders as $key=>$val){
  1417. if($val->status==3 && $val->is_refund > 0){
  1418. $order_refund = OrderRefundW::where('order_no',$val->order_no)->get();
  1419. if($order_refund){
  1420. $orders[$key]->refund_goods=$order_refund;
  1421. }
  1422. }
  1423. $goods_ids=OrderDetailW::where('order_no',$val->order_no)->groupBy('goods_id')->pluck('goods_id');
  1424. $goods=[];
  1425. foreach($goods_ids as $k=>$v){
  1426. $goods[$k]=StoreGoods::where('id',$v)->select('id','name','img','main_attr')->first();
  1427. $goods[$k]->imgs=str_replace('http://','https://',$goods[$k]->img);
  1428. $goods[$k]->sku=OrderDetailW::where('order_no',$val->order_no)
  1429. ->where('goods_id',$v)->select('price','num')->get();
  1430. }
  1431. $goods_infos=OrderDetailW::with('goods:id,img,name,main_attr')->where('order_no',$val->order_no)
  1432. ->groupBy('goods_id')->select(DB::raw('price','sum(num) as num'))->first();
  1433. $orders[$key]->goods=$goods;
  1434. }
  1435. return $this->success_list($orders,'成功',$count);
  1436. }
  1437. //获取订单列表
  1438. public function getOrderList1(Request $request)
  1439. {
  1440. $input=$request->all();
  1441. $status=$input['status'];
  1442. $page_index=$input['page_index'];
  1443. $page_size=$input['page_size'];
  1444. $order_no=$input['order_no'];
  1445. $num=$page_size*($page_index-1);
  1446. $where=$wheres=[];
  1447. if($status!='all'){
  1448. $where['status']=$status;
  1449. }
  1450. if($order_no){
  1451. $wheres=function($query)use($order_no){
  1452. $query->where('order_no','like','%'.$order_no.'%');
  1453. };
  1454. }
  1455. $store=Store::where('user_id',Auth::user()->id)->first();
  1456. $where['store_id']=$store->id;
  1457. $data=OrderW::with(['user:id,nickname,phone','order_cancel'=>function($query){
  1458. $query->where('using',1);}])->where($where)->where($wheres)->whereIn('apply_cancel',[0,1,3])
  1459. ->whereIn('is_refund',[0,1,2])
  1460. ->orderByDesc('updated_at')->orderByDesc('id');
  1461. $count=$data->count();
  1462. $orders=$data->skip($num)->take($page_size)->get();
  1463. foreach($orders as $key=>$val){
  1464. if($val->status==3 && $val->is_refund > 0){
  1465. $order_refund = OrderRefundW::where('order_no',$val->order_no)->get();
  1466. if($order_refund){
  1467. $orders[$key]->refund_goods=$order_refund;
  1468. }
  1469. }
  1470. $orders[$key]->goods=json_decode($val->snapshot,true);
  1471. }
  1472. return $this->success_list($orders,'成功',$count);
  1473. }
  1474. //获取订单列表
  1475. public function getOrderLists(Request $request)
  1476. {
  1477. $input=$request->all();
  1478. $status=$input['status'];
  1479. $page_index=$input['page_index'];
  1480. $page_size=$input['page_size'];
  1481. $order_no=$input['order_no'];
  1482. $num=$page_size*($page_index-1);
  1483. $where=$wheres=[];
  1484. if($status!='all'){
  1485. $where['status']=$status;
  1486. }
  1487. if($order_no){
  1488. $wheres=function($query)use($order_no){
  1489. $query->where('order_no','like','%'.$order_no.'%');
  1490. };
  1491. }
  1492. $store=Store::where('user_id',Auth::user()->id)->first();
  1493. $where['store_id']=$store->id;
  1494. $data=OrderW::with(['user:id,nickname,phone','order_cancel'=>function($query){
  1495. $query->where('using',1);}])->where($where)->where($wheres)->whereIn('apply_cancel',[0,1,3])
  1496. ->whereIn('is_refund',[0,1,2])
  1497. ->orderByDesc('updated_at')->orderByDesc('id');
  1498. $count=$data->count();
  1499. $orders=$data->skip($num)->take($page_size)->get();
  1500. foreach($orders as $key=>$val){
  1501. if($val->status==3 && $val->is_refund > 0){
  1502. $order_refund = OrderRefundW::where('order_no',$val->order_no)->get();
  1503. if($order_refund){
  1504. $orders[$key]->refund_goods=$order_refund;
  1505. }
  1506. }
  1507. $goods=OrderDetailW::with('goods:id,img,name,main_attr')->where('order_id',$val->id)
  1508. ->groupBy('goods_id')->select('goods_id','price',DB::raw('sum(num) as num'))->get();
  1509. foreach($goods as $k=>$v){
  1510. $goods[$k]->goods->imgs=str_replace('http://','https://',$v->goods->img);
  1511. }
  1512. $orders[$key]->goods=$goods;
  1513. }
  1514. return $this->success_list($orders,'成功',$count);
  1515. }
  1516. //获取退货订单详情
  1517. public function getRefundOrderDetail(Request $request){
  1518. $order_no=$request->input('order_no');
  1519. $order_refund=OrderRefundW::where('order_no',$order_no)->get();
  1520. foreach($order_refund as $key => $val){
  1521. $goods_ids = OrderDetailW::where('order_no', $val->refund_no)->groupBy('goods_id')->pluck('goods_id');
  1522. $goods = [];
  1523. foreach ($goods_ids as $k => $v) {
  1524. $goods[$k] = StoreGoods::where('id', $v)->first();
  1525. $goods[$k]->sku = OrderDetailW::where('order_no', $val->refund_no)->where('goods_id', $v)->get();
  1526. }
  1527. $order_refund[$key]->goods=$goods;
  1528. }
  1529. return $this->success($order_refund);
  1530. }
  1531. //获取id订单信息
  1532. public function getOrderInfo(Request $request)
  1533. {
  1534. $input=$request->all();
  1535. $id=$input['id'];
  1536. $order=OrderW::withTrashed()->with(['user:id,nickname,phone','address'])->where('id',$id)->first();
  1537. $goods_ids=OrderDetailW::where('order_no',$order->order_no)->groupBy('goods_id')->pluck('goods_id');
  1538. $goods=[];
  1539. foreach($goods_ids as $key=>$val){
  1540. $goods[$key]=StoreGoods::where('id',$val)->first();
  1541. $goods[$key]->sku=OrderDetailW::where('order_no',$order->order_no)->where('goods_id',$val)->get();
  1542. }
  1543. $order->goods=$goods;
  1544. return $this->success($order);
  1545. }
  1546. //根据订单号查询订单
  1547. public function getOrderNoInfo(Request $request)
  1548. {
  1549. $input=$request->all();
  1550. $order_no=$input['order_no'];
  1551. $order=OrderW::withTrashed()->with(['order_cancel','user:id,nickname,phone,avatar','address'])->where('order_no',$order_no)->first();
  1552. if(empty($order)){
  1553. return $this->error('450001','订单号有误');
  1554. }
  1555. $goods_ids=OrderDetailW::where('order_no',$order->order_no)->groupBy('goods_id')->pluck('goods_id');
  1556. $goods=[];
  1557. foreach($goods_ids as $key=>$val){
  1558. $goods[$key]=StoreGoods::where('id',$val)->first();
  1559. $goods[$key]->imgs=str_replace('http://','https://',$goods[$key]->img);
  1560. $goods[$key]->sku=OrderDetailW::where('order_no',$order->order_no)->where('goods_id',$val)->get();
  1561. }
  1562. $order->goods=$goods;
  1563. return $this->success($order);
  1564. }
  1565. //回复评价
  1566. public function addComment(Request $request){
  1567. $input=$request->all();
  1568. $rules=[
  1569. 'content'=>'required|max:255',
  1570. ];
  1571. $message=[
  1572. 'content.required'=>'评价内容不能为空.',
  1573. 'content.max'=>'评价内容不能大于255个字符.'
  1574. ];
  1575. $validator = Validator::make($input,$rules,$message);
  1576. if($validator->fails()){
  1577. return $this->error('400013',$validator->errors()->first());
  1578. }
  1579. $store_id=Store::where('user_id',Auth::user()->id)->value('id');
  1580. $res=Comment::create([
  1581. 'content'=>$input['content'],
  1582. 'comment_id'=>$input['comment_id'],
  1583. 'store_id'=>$store_id,
  1584. 'is_reply'=>2,
  1585. 'is_see'=>0
  1586. ]);
  1587. if($res){
  1588. return $this->success([]);
  1589. }else{
  1590. return $this->error();
  1591. }
  1592. }
  1593. //查看所有评价
  1594. public function getComment(Request $request){
  1595. $input=$request->all();
  1596. $page_index=$input['page_index'];
  1597. $page_size=$input['page_size'];
  1598. $num=$page_size*($page_index-1);
  1599. $store_id=Store::where('user_id',Auth::user()->id)->value('id');
  1600. $count= Comment::where('store_id',$store_id)->where('comment_id',0)->count();
  1601. $list= Comment::with(['comment','store:id,name,img','user:id,avatar,nickname,phone'])
  1602. ->where('store_id',$store_id)->where('comment_id',0)
  1603. ->orderByDesc('id')
  1604. ->skip($num)->take($page_size)->get();
  1605. return $this->success_list($list,'',$count);
  1606. }
  1607. //用户自提
  1608. public function oneSelfTake(Request $request){
  1609. $order_no=$request->input('order_no');
  1610. $order=OrderW::with('address')->where('order_no',$order_no)->first();
  1611. $order->status=2; //已备货,可自提
  1612. $order->express_time = date("Y-m-d H:i:s"); //备货完成时间
  1613. $res=$order->save();
  1614. if($res){
  1615. /* 已备货通知 */
  1616. $user=UserW::where('id',$order->user_id)->first();
  1617. if($user->openId){
  1618. $address=null;
  1619. if($order->address){
  1620. $address=$order->address->province.$order->address->city.$order->address->area.$order->address->address;
  1621. }
  1622. $mes['openid']=$user->openId;
  1623. $mes['data']=[
  1624. 'first' => '您的订单已完成备货,请前往提货',
  1625. 'keyword1' => $order_no,
  1626. 'keyword2' => $order->created_at,
  1627. 'keyword3' => '已备货,可自提',
  1628. 'keyword4' => $address,
  1629. 'remark' => '点击链接进入系统,查看详情',
  1630. ];
  1631. event(new TipPickUpEvent($mes));
  1632. }
  1633. return $this->success([]);
  1634. }else{
  1635. return $this->error();
  1636. }
  1637. }
  1638. //获取所有快递公司信息
  1639. public function getExpressCode(){
  1640. return $this->success(ExpressHandler::getExpressCode());
  1641. }
  1642. //上传订单快递号
  1643. public function addOrderExpressNo(Request $request){
  1644. $input=$request->all();
  1645. $rules=[
  1646. 'express_no' =>'required',
  1647. 'express_company'=>'required',
  1648. 'express_time' =>'required'
  1649. // 'address_id' =>'required'
  1650. ];
  1651. $message=[
  1652. 'express_no.required' =>'发货单号不能为空.',
  1653. 'express_company.required'=>'物流公司不能为空.',
  1654. 'express_time.required' =>'发货时间不能为空.',
  1655. // 'address_id.required' =>'收货地址不能为空.',
  1656. ];
  1657. $validator = Validator::make($input,$rules,$message);
  1658. if($validator->fails()){
  1659. return $this->error('400013',$validator->errors()->first());
  1660. }
  1661. $status=OrderW::where('order_no',$input['order_no'])->value('status');
  1662. if($status > 1){
  1663. return $this->error('450001','该订单已发货');
  1664. }
  1665. $res=OrderW::where('order_no',$input['order_no'])->update([
  1666. 'address_id'=>$input['address_id'],
  1667. 'self_receive'=>0,
  1668. 'express_no'=>str_replace(' ','', $input['express_no']),
  1669. 'express_company'=>$input['express_company'],
  1670. 'express_code'=>$input['express_code'],
  1671. 'express_state'=>0,
  1672. 'express_phone'=>$input['express_phone'],
  1673. 'express_time'=>$input['express_time'],
  1674. 'status'=>2,
  1675. ]);
  1676. // OrderExpressW::create([
  1677. // 'order_no'=>$input['order_no'],
  1678. // 'express_no'=>str_replace(' ','', $input['express_no']),
  1679. // 'express_company'=>$input['express_company'],
  1680. // 'express_code'=>$input['express_code'],
  1681. // 'express_state'=>0,
  1682. // 'express_phone'=>$input['express_phone'],
  1683. // 'express_receive_time'=>null,
  1684. // ]);
  1685. if($res){
  1686. Log::info($input['order_no']);
  1687. $order=OrderW::with('address')->where('order_no',$input['order_no'])->first();
  1688. $user=UserW::where('id',$order->user_id)->first();
  1689. //已发货短信通知
  1690. $phone=$user->phone;
  1691. $config=config('easysms');
  1692. $easySms = new EasySms($config);
  1693. $express=$order->express_company.$order->express_no;
  1694. Log::info($express);
  1695. $content="您购买的健康内裤已发货,快递单号是{$express},请注意查收。";
  1696. try{
  1697. $easySms->send($phone, ['content' =>$content ]);
  1698. } catch (\Overtrue\EasySms\Exceptions\NoGatewayAvailableException $exception) {
  1699. $message = $exception->getException('qcloud')->getMessage();
  1700. Log::info('物流发货短信异常:'.json_encode($message));
  1701. }
  1702. //已发货公众号通知
  1703. if($user->openId){
  1704. Log::info($user->openId);
  1705. if($order->address){
  1706. $address=$order->address->name.' '.$order->address->phone.' '.$order->address->province.$order->address->city.$order->address->area.$order->address->address;
  1707. }else{
  1708. $address='无收件信息';
  1709. }
  1710. $mes['openid']=$user->openId;
  1711. $mes['data']=[
  1712. 'first' => '您的订单已发货,请注意查收',
  1713. 'keyword1' => $order->order_no,
  1714. 'keyword2' => $order->express_time,
  1715. 'keyword3' => $order->express_company,
  1716. 'keyword4' => $order->express_no,
  1717. 'keyword5' => $address,
  1718. ];
  1719. Log::info(json_encode($mes));
  1720. event(new TipSendingEvent($mes));
  1721. }
  1722. return $this->success([]);
  1723. }else{
  1724. return $this->error();
  1725. }
  1726. }
  1727. //查询订单物流信息
  1728. public function getOrderExpress(Request $request){
  1729. $order_no=$request->input('order_no');
  1730. $order=OrderW::with('address')->where('order_no',$order_no)->first();
  1731. if(empty($order)){
  1732. return $this->error('450001','订单信息有误');
  1733. }
  1734. if($order->express_state==3){ //已签收
  1735. $express=json_decode($order->express_info,true);
  1736. }else{ //未签收
  1737. $CustomerName = null;
  1738. if($order->express_code =='SF'){
  1739. $CustomerName = substr($order->express_phone,-4);
  1740. }
  1741. $express=new ExpressHandler();
  1742. $express=$express->search($order->express_no, $order->express_code, $order->order_no, $CustomerName);
  1743. $express=json_decode(json_encode($express),'true');
  1744. if(isset($express['Traces']) && !empty($express['Traces'])){
  1745. foreach ($express['Traces'] as $key=>$val){
  1746. $express['Traces'][$key]['AcceptTime']=date("Y-m-d H:i:s",substr($val['AcceptTime'],0,strlen($val['AcceptTime'])-3));
  1747. }
  1748. OrderW::where('order_no',$order_no)->update([
  1749. 'express_info'=>json_encode($express),
  1750. 'express_receive_time'=>array_pop($express['Traces'])['AcceptTime'],
  1751. 'express_state'=>$express['State']
  1752. ]);
  1753. }
  1754. }
  1755. $data['express']=$express;
  1756. $data['express_state']=$order->express_state;
  1757. $data['express_code']=$order->express_code;
  1758. $data['express_company']=$order->express_company;
  1759. $data['express_no']=$order->express_no;
  1760. $data['express_time']=$order->express_time;
  1761. $data['express_phone']=$order->express_phone;
  1762. return $this->success($data);
  1763. }
  1764. //修改店铺地址
  1765. public function editStoreAddress(Request $request){
  1766. $user_id=Auth::user()->id;
  1767. // $user=User::where('id',$user_id)->first();
  1768. // $store_id=Store::where('user_id',$user_id)->value('id');
  1769. $res=Store::where('user_id',$user_id)
  1770. ->update([
  1771. 'province'=>$request->input('province'),
  1772. 'city'=>$request->input('city'),
  1773. 'area'=>$request->input('area'),
  1774. 'address'=>$request->input('address'),
  1775. ]);
  1776. // $address=AddressW::where('store_id',$store_id)->first();
  1777. // if($address){
  1778. // $address->province=$request->input('province');
  1779. // $address->city=$request->input('city');
  1780. // $address->area=$request->input('area');
  1781. // $address->address=$request->input('address');
  1782. // $res=$address->save();
  1783. // }else{
  1784. // $res=AddressW::create([
  1785. // 'store_id'=>$store_id,
  1786. // 'name'=>$user->nickname,
  1787. // 'phone'=>$user->mobile,
  1788. // 'province'=>$request->input('province'),
  1789. // 'city'=>$request->input('city'),
  1790. // 'area'=>$request->input('area'),
  1791. // 'address'=>$request->input('address'),
  1792. // 'is_default'=>0
  1793. // ]);
  1794. // }
  1795. if($res){
  1796. return $this->success([]);
  1797. }else{
  1798. return $this->error();
  1799. }
  1800. }
  1801. //获取微信位置授权
  1802. public function getSignPackage(){
  1803. $app=app('wechat.official_account');
  1804. $url='http://api.app.jiuweiyun.cn/api/gzh';
  1805. $app->jssdk->setUrl($url);
  1806. $data=$app->jssdk->buildConfig(array('openLocation','getLocation','chooseImage', 'uploadImage', 'downloadImage','updateAppMessageShareData', 'updateTimelineShareData','scanQRCode'), true);
  1807. return $this->success($data);
  1808. }
  1809. //根据经纬度获取地理位置信息
  1810. public function getAddressInfo(Request $request){
  1811. $location=$request->input('location');
  1812. $key='d2785d78de492f2cc7047a09690bdb4d';
  1813. $client=new Client();
  1814. $url='https://restapi.amap.com/v3/geocode/regeo?key='.$key.'&location='.$location;
  1815. $result=$client->request('GET',$url);
  1816. $res = json_decode($result->getBody()->getContents());
  1817. return $this->success($res);
  1818. }
  1819. //提交退货订单
  1820. public function submitRefundOrder(Request $request)
  1821. {
  1822. $sku = $request->input('sku');
  1823. $reason = $request->input('reason');
  1824. $reason_all = $request->input('reason_all');
  1825. $img = $request->input('img');
  1826. $origin_order_no=$request->input('origin_order_no');
  1827. $origin_order=OrderW::where('order_no',$origin_order_no)->first();
  1828. if($origin_order->is_refund==1){
  1829. return $this->error('450001','该订单存在正在审核中的退货订单');
  1830. }
  1831. if($origin_order->is_refund==3){
  1832. return $this->error('450001','该订单已全部退货');
  1833. }
  1834. $refund_no=OrderW::order_no('th');
  1835. $account = $total = 0;
  1836. $list = $sku_ids = [];
  1837. foreach($sku as $key=>$val){
  1838. if($val[1] > 0){
  1839. $order_detail=OrderDetailW::with(['goods'])->where('id',$val[0])->first();
  1840. if($order_detail->num < $val[1]){
  1841. $num = $order_detail->num;
  1842. }else{
  1843. $num = $val[1];
  1844. }
  1845. $list[$key]['num']=$num;
  1846. $list[$key]['price']=$order_detail->price;
  1847. $list[$key]['account']=$order_detail->price * $num;
  1848. $list[$key]['order_no']=$refund_no;
  1849. $list[$key]['goods_id']=$order_detail->goods_id;
  1850. $list[$key]['sku_id']=$order_detail->sku_id;
  1851. $list[$key]['size']=$order_detail->size;
  1852. $list[$key]['type']=$order_detail->type;
  1853. $list[$key]['style']=2;
  1854. $list[$key]['created_at']=date("Y-m-d H:i:s");
  1855. $list[$key]['updated_at']=date("Y-m-d H:i:s");
  1856. $total += $num;
  1857. $account += $order_detail->price * $num;
  1858. }
  1859. }
  1860. $data=[
  1861. 'refund_no'=>$refund_no,
  1862. 'order_no'=>$origin_order_no,
  1863. 'store_id'=>$origin_order->store_id,
  1864. 'user_id'=>$origin_order->user_id,
  1865. 'reason'=>$reason,
  1866. 'reason_all'=>$reason_all,
  1867. 'total'=>$total,
  1868. 'account'=>$account,
  1869. 'img'=>json_encode($img),
  1870. 'status'=>0,
  1871. 'op_name'=> Auth::user()->nickname,
  1872. 'op_type'=>2,
  1873. 'remark'=>null,
  1874. ];
  1875. try{
  1876. DB::connection('mysql_w')->transaction(function ()use($list,$data,$origin_order_no,$account){
  1877. OrderDetailW::insert($list);
  1878. OrderRefundW::create($data);
  1879. OrderW::where('order_no',$origin_order_no)->update(['is_refund'=>1]);
  1880. },5);
  1881. //申请退货提醒
  1882. $user=UserW::where('id',$origin_order->user_id)->first();
  1883. if($user->openId){
  1884. $data['openid']=$user->openId;
  1885. $data['data']=[
  1886. 'first' => '代理提交了新的退单信息',
  1887. 'keyword1' => $origin_order->order_no,
  1888. 'keyword2' => '代理退货,退款金额:'.number_format($account,2)
  1889. ];
  1890. event(new AuthRefundTip($data));
  1891. }
  1892. return $this->success($refund_no);
  1893. }catch(\Exception $e){
  1894. return $this->error('450001',$e->getMessage());
  1895. }
  1896. }
  1897. //获取退款订单原始信息
  1898. public function getOriginOrderInfo(Request $request)
  1899. {
  1900. $order_no=$request->input('order_no');
  1901. $data=OrderW::with(['address','order_cancel'=>function($query){$query->where('using',1);},'store:id,name,img,phone']);
  1902. $order=$data->where('order_no',$order_no)->first()->toArray();
  1903. if(empty($order)){
  1904. return $this->error('450001','订单不存在');
  1905. }
  1906. $goods_ids=OrderDetailW::where('order_no',$order['order_no'])->groupBy('goods_id')->pluck('goods_id');
  1907. $goods=[];
  1908. foreach($goods_ids as $key=>$val){
  1909. $goods[$val]=StoreGoods::select('id','name','img','main_attr')->where('id',$val)->first()->toArray();
  1910. $order_details=OrderDetailW::where('order_no',$order['order_no'])->where('goods_id',$val)->get()->toArray();
  1911. if(count($order_details)>0){
  1912. $sku=[];
  1913. foreach($order_details as $k=>$v){
  1914. $sku[$v['sku_id']]=$v;
  1915. }
  1916. $goods[$val]['sku']=$sku;
  1917. $goods[$val]['price']=$order_details[0]['price'];
  1918. }
  1919. }
  1920. $order['goods']=$goods;
  1921. $refund_nos=OrderRefundW::where('order_no',$order_no)->whereIn('status',[0,1,3])->pluck('refund_no');
  1922. $refund_goods_ids=OrderDetailW::whereIn('order_no',$refund_nos)->groupBy('goods_id')->pluck('goods_id');
  1923. $refunds=[];
  1924. foreach($refund_goods_ids as $key=>$val){
  1925. $refunds[$val]=StoreGoods::select('id','name','img','main_attr')->where('id',$val)->first()->toArray();
  1926. $refunds_details=OrderDetailW::select('goods_id','sku_id','type','size', DB::raw('sum(num) as num'))
  1927. ->whereIn('order_no',$refund_nos)->where('goods_id',$val)->groupBy('sku_id')->get()->toArray();
  1928. if(count($refunds_details)>0){
  1929. $sku=[];
  1930. foreach($refunds_details as $k=>$v){
  1931. $sku[$v['sku_id']]=$v;
  1932. }
  1933. $refunds[$val]['sku']=$sku;
  1934. }
  1935. }
  1936. $order['refunds']=$refunds;
  1937. $products=[];
  1938. foreach($goods as $key=>$val){
  1939. $products[$key]= $goods[$key];
  1940. $sku=[];
  1941. foreach($val['sku'] as $k=>$v){
  1942. if(empty($refunds[$key]['sku'][$k])){
  1943. unset($products[$key]['sku']);
  1944. $sku[$k]= $goods[$key]['sku'][$k];
  1945. }else{
  1946. if($goods[$key]['sku'][$k]['num'] > $refunds[$key]['sku'][$k]['num']){
  1947. unset($products[$key]['sku']);
  1948. $sku[$k] = $goods[$key]['sku'][$k];
  1949. $sku[$k]['num']=$goods[$key]['sku'][$k]['num'] - $refunds[$key]['sku'][$k]['num'];
  1950. }else{
  1951. unset($products[$key]['sku']);
  1952. }
  1953. }
  1954. }
  1955. $products[$key]['sku']= $sku;
  1956. if(empty($products[$key]['sku'])){
  1957. unset($products[$key]);
  1958. }
  1959. }
  1960. $order['products']=$products;
  1961. return $this->success($order);
  1962. }
  1963. //上传退货图片
  1964. public function uploadRefundOrderImg(Request $request){
  1965. $path_url = 'public/refund';
  1966. $path = $request->file('img')->store($path_url);
  1967. if($path){
  1968. $url = env('APP_URL'). Storage::url($path);
  1969. return $this->success($url);
  1970. }
  1971. return $this->error();
  1972. }
  1973. //取消退货审核
  1974. public function cancelRefundOrder(Request $request){
  1975. $refund_id=$request->input('refund_id');
  1976. $refund=OrderRefundW::where('id',$refund_id)->first();
  1977. if(empty($refund)){
  1978. return $this->error('450001','退货单不存在');
  1979. }
  1980. try{
  1981. DB::connection('mysql_w')->transaction(function()use($refund){
  1982. OrderRefundW::where('id',$refund->id)->delete();
  1983. $auth_count=OrderRefundW::where('order_no',$refund->order_no)->where('status',0)->count();
  1984. if($auth_count>=1){
  1985. OrderW::where('order_no',$refund->order_no)->update([
  1986. 'is_refund'=>1
  1987. ]);
  1988. }else{
  1989. $count=OrderRefundW::where('order_no',$refund->order_no)->where('status',1)->count();
  1990. if($count>=1){
  1991. OrderW::where('order_no',$refund->order_no)->update([
  1992. 'is_refund'=>2
  1993. ]);
  1994. }else{
  1995. OrderW::where('order_no',$refund->order_no)->update([
  1996. 'is_refund'=>0
  1997. ]);
  1998. }
  1999. }
  2000. },5);
  2001. return $this->success([]);
  2002. }catch(\Exception $e){
  2003. return $this->error('450001',$e->getMessage());
  2004. }
  2005. }
  2006. //上传签名图片
  2007. public function uploadQianMingImg(Request $request){
  2008. $base64_img=$request->input('img');
  2009. // Log::info('aaa---aaa---aaa'.$base64_img);
  2010. preg_match('/^(data:\s*image\/(\w+);base64,)/',$base64_img,$res);
  2011. // Log::info('aaa-----aaa-----aaa-----aaa'.json_encode($res));
  2012. $base64_img=base64_decode(str_replace($res[1],'', $base64_img));
  2013. $img_name=$this->randomKeys(18).'.jpg';
  2014. $path_url = 'qianming/'.date("Ymd").'/'.$img_name;
  2015. $ans=Storage::disk('public')->put($path_url, $base64_img);
  2016. if($ans){
  2017. return $this->success(env('APP_URL').Storage::url($path_url));
  2018. }
  2019. return $this->error();
  2020. }
  2021. function randomKeys($length){
  2022. $pattern = '1234567890abcdefghijklmnopqrstuvwxyz';
  2023. $key='';
  2024. for($i=0;$i<$length;$i++)
  2025. {
  2026. $key .= $pattern{mt_rand(0,strlen($pattern)-1)};//生成php随机数
  2027. }
  2028. return $key;
  2029. }
  2030. //代理确认收货
  2031. public function agentSureReceiveOrder(Request $request){
  2032. $order_no=$request->input('order_no');
  2033. $order=OrderW::where('order_no',$order_no)->first();
  2034. if($order->status==3){
  2035. return $this->error('450001','订单已完成');
  2036. }
  2037. try{
  2038. DB::connection('mysql_w')->transaction(function()use($order_no,$order,$request){
  2039. $order->status=3;
  2040. $order->order_status=2;
  2041. $order->self_receive=0;//代理收货
  2042. $order->express_receive_time=date("Y-m-d H:i:s");//订单签收时间
  2043. $order->save();
  2044. },5);
  2045. event(new FinishAccount($order_no));
  2046. $user=UserW::where('id',$order->user_id)->first();
  2047. //已签收短信通知
  2048. $phone=$user->phone;
  2049. $config=config('easysms');
  2050. $easySms = new EasySms($config);
  2051. $content="您购买的健康内裤被代理标记为确认签收。若已收到货物,请忽略此短信;若没有收到,请及时联系代理商查询。 ";
  2052. try{
  2053. $easySms->send($phone, ['content' =>$content ]);
  2054. } catch (\Overtrue\EasySms\Exceptions\NoGatewayAvailableException $exception) {
  2055. $message = $exception->getException('qcloud')->getMessage();
  2056. Log::info('代理确认收货短信异常:'.json_encode($message));
  2057. }
  2058. return $this->success([]);
  2059. }catch(\Exception $e){
  2060. Log::info('签收失败2---'.json_encode($e->getMessage()));
  2061. return $this->error('450001',$e->getMessage());
  2062. }
  2063. }
  2064. //代理端确认收货
  2065. public function sureReceiveOrder(Request $request){
  2066. $order_no=$request->input('order_no');
  2067. $signature=$request->input('signature');
  2068. $order=OrderW::where('order_no',$order_no)->first();
  2069. if($order->status==3){
  2070. return $this->error('450001','订单已完成');
  2071. }
  2072. Log::info(json_encode($request->input()));
  2073. try{
  2074. DB::connection('mysql_w')->transaction(function()use($order_no,$order,$signature,$request){
  2075. $order->status=3;
  2076. $order->order_status=0;
  2077. $order->self_receive=1;//送货上门
  2078. $order->express_receive_time=date("Y-m-d H:i:s");//订单签收时间
  2079. $order->signature=$signature;
  2080. if(empty($order->address_id)){
  2081. $province=$request->input('province');
  2082. if(is_array($province) && !empty($province)){
  2083. $province=implode('',$province);
  2084. }
  2085. if(is_array($province) && empty($province)){
  2086. $province='';
  2087. }
  2088. $city=$request->input('city');
  2089. if(is_array($city) && !empty($city)){
  2090. $city=implode('',$city);
  2091. }
  2092. if(is_array($city) && empty($city)){
  2093. $city='';
  2094. }
  2095. $area=$request->input('area');
  2096. if(is_array($area) && !empty($area)){
  2097. $area=implode('',$area);
  2098. }
  2099. if(is_array($area) && empty($area)){
  2100. $area='';
  2101. }
  2102. Log::info('dddd-------dddd'.$province.'---'.$city.'---'.$area);
  2103. $address=AddressW::where('user_id',$order->user_id)
  2104. ->where('province',$province)->where('city',$city)
  2105. ->where('area',$area)->first();
  2106. if($address){
  2107. $order->address_id=$address->id;
  2108. }else{
  2109. $user=UserW::where('id',$order->user_id)->first();
  2110. $row=AddressW::create([
  2111. 'name'=>$user->nickname,
  2112. 'phone'=>$user->phone,
  2113. 'user_id'=>$order->user_id,
  2114. 'store_id'=>$order->store_id,
  2115. 'province'=>$province,
  2116. 'city'=>$city,
  2117. 'area'=>$area,
  2118. 'type'=>3,
  2119. 'is_default'=>0,
  2120. 'remark'=>'自动定位',
  2121. ]);
  2122. $order->address_id=$row->id;
  2123. }
  2124. }
  2125. $order->save();
  2126. },5);
  2127. event(new FinishAccount($order_no));
  2128. $user=UserW::where('id',$order->user_id)->first();
  2129. //已签收短信通知
  2130. $phone=$user->phone;
  2131. $config=config('easysms');
  2132. $easySms = new EasySms($config);
  2133. $content="您购买的健康内裤已由你本人确认签收,谢谢。";
  2134. try{
  2135. $easySms->send($phone, ['content' =>$content ]);
  2136. } catch (\Overtrue\EasySms\Exceptions\NoGatewayAvailableException $exception) {
  2137. $message = $exception->getException('qcloud')->getMessage();
  2138. Log::info('签收短信异常:'.json_encode($message));
  2139. }
  2140. //签收提醒
  2141. if($user->openId){
  2142. $data['openid']=$user->openId;
  2143. $data['data']=[
  2144. 'first' => '您的订单已被当面签收,如果没有请联系代理',
  2145. 'keyword1' => $order->order_no,
  2146. 'keyword2' => date('Y-m-d H:i:s')
  2147. ];
  2148. event(new ReceivingEvent($data));
  2149. }
  2150. return $this->success([]);
  2151. }catch(\Exception $e){
  2152. Log::info('签收失败1---'.$e->getMessage());
  2153. return $this->error('450001',$e->getMessage());
  2154. }
  2155. }
  2156. //获取客户信息
  2157. public function getUser(Request $request){
  2158. $user_id=$request->input('user_id');
  2159. $user=UserW::where('id',$user_id)->first();
  2160. $store_id=Store::where('user_id',Auth::user()->id)->value('id');
  2161. $vip_log=VipLogW::where('user_id',$user->id)->where('store_id',$store_id)->first();
  2162. if($vip_log){
  2163. $user->is_vip=1;
  2164. }else{
  2165. $user->is_vip=0;
  2166. }
  2167. $orders=OrderW::where('store_id',$store_id)->where('user_id',$user_id)->get();
  2168. if(count($orders)==0){//判断客户在店铺有没有单子
  2169. $user->has_order=0;
  2170. }else{
  2171. $user->has_order=1;
  2172. }
  2173. if($user){
  2174. return $this->success($user);
  2175. }else{
  2176. return $this->error();
  2177. }
  2178. }
  2179. //修改客户信息
  2180. public function editUser(Request $request){
  2181. $rules=[
  2182. 'name'=>'required|max:32',
  2183. 'nickname'=>'required|max:32',
  2184. 'remark'=>'max:255',
  2185. 'phone'=>'required|regex:/^1[3456789][0-9]{9}$/'
  2186. ];
  2187. $message=[
  2188. 'phone.required'=>'手机号不能为空.',
  2189. 'phone.regex'=>'手机号格式有误.',
  2190. 'name.required'=>'客户姓名不能为空.',
  2191. 'name.max'=>'客户姓名最多32个字符.',
  2192. 'nickname.required'=>'客户昵称不能为空.',
  2193. 'nickname.max'=>'客户昵称最多32个字符.',
  2194. 'remark.max'=>'备注最多255个字符.',
  2195. ];
  2196. $validator = Validator::make($request->input(),$rules,$message);
  2197. if($validator->fails()){
  2198. return $this->error('400013',$validator->errors()->first());
  2199. }
  2200. $user_id=$request->input('user_id');
  2201. $res=UserW::where('id',$user_id)->update([
  2202. 'name'=>$request->input('name'),
  2203. 'phone'=>$request->input('phone'),
  2204. 'nickname'=>$request->input('nickname'),
  2205. 'sex'=>$request->input('sex'),
  2206. 'remark'=>$request->input('remark'),
  2207. ]);
  2208. if($res){
  2209. return $this->success([]);
  2210. }else{
  2211. return $this->error();
  2212. }
  2213. }
  2214. //获取所有快递公司信息
  2215. public function getExpressCompany(Request $request){
  2216. $express=new ExpressHandler();
  2217. $expressCode=$request->input('expressCode');
  2218. $res=$express->getExpressCompany($expressCode);
  2219. return $this->success($res);
  2220. }
  2221. }