Skip to content

Z
zptz-sass-kelaidian
提交 f297a2d1 authored 作者: 窦斌's avatar 窦斌
浏览文件
操作

edit

上级 16cf9ec1
显示空白字符变更
内嵌 并排
正在显示 包含 675 行增加 和 12 行删除
app/Console/Commands/GetJdOrderCancel.php 0 → 100644
浏览文件 @ f297a2d1
<?php
namespace App\Console\Commands;
use App\Http\Controllers\Api\JdOrderApiController;
use Illuminate\Console\Command;
class GetJdOrderCancel extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'GetJdOrderCancel';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Command GetJdOrderCancel';
/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
}
/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
//
$getOrder = new JdOrderApiController();
$ret = $getOrder->getOrderCancelByJd();
print_r($ret);
}
}
app/Console/Kernel.php
浏览文件 @ f297a2d1
......@@ -20,7 +20,8 @@ class Kernel extends ConsoleKernel
Commands\GetJdSelfShhOrder::class,
Commands\DeductionFee::class,
Commands\SynJdOrderApi::class,
Commands\SynCancelAuditList::class
Commands\SynCancelAuditList::class,
Commands\GetJdOrderCancel::class
];
/**
......@@ -41,6 +42,7 @@ class Kernel extends ConsoleKernel
$schedule->command('DeductionFee')->everyFiveMinutes();//每三十分钟执行一次 everyThirtyMinutes
$schedule->command('SynJdOrderApi')->everyFiveMinutes();// 抓取京东社会化门店订单 //每五分钟执行一次
$schedule->command('SynCancelAuditList')->everyFiveMinutes();// 抓取京东社会化门店退款单 //每五分钟执行一次
$schedule->command('GetJdOrderCancel')->everyFifteenMinutes();// 抓取京东社会化门店12小时内撤销单 //每十五分钟执行一次
}
/**
......
app/Http/Controllers/Api/JdOrderApiController.php
浏览文件 @ f297a2d1
......@@ -276,7 +276,7 @@ class JdOrderApiController extends BaseController
if ($sys_num) {
$refund['sys_num'] = $sys_num['sys_num'];
if ($sys_num['order_status'] > 10) {
$msg = OrderService::getOrderListMsg($sys_num['sys_num']);
$msg = OrderService::getOrderMsg($sys_num['sys_num']);
} else {
$msg = OrderService::getOrderMsg($sys_num['sys_num']);
}
......@@ -321,6 +321,92 @@ class JdOrderApiController extends BaseController
echo "succese";
}
}
/**|---------------------------------------------------------------------------------
* @name 获取订单列表撤销单
* @retrun \Illuminate\Http\JsonResponse /multitype:array
* @author dou 2024/12/13 10:48
* |---------------------------------------------------------------------------------
*/
public function getOrderCancelByJd( ){
$startDate = date("Y-m-d H:i:s",strtotime(" -720 minute".date("Y-m-d H:i:s")));
$endDate = date("Y-m-d H:i:s");
$url = "http://116.196.75.172/index.php/SaasApiGetOrder/index?startDate=".$startDate."&endDate=".$endDate."&status=204";
$token = DB::table('jdpop_token')->where('status',1)->where('type',2)->where('pt_id',33)->select('app_key','app_secret','access_token','pt_id','auth_key')->get()->toarray();
foreach($token as $k => $vs) {
$urls = $url."&authKey=".$vs['auth_key']."&access_token=".$vs['access_token']."&app_key=".$vs['app_key']."&app_secret=".$vs['app_secret'];
$company_id = Pt::where('id',$vs['pt_id'])->value('company_id');
// echo $urls;
$res = $this->http_get($urls);
$ip = $_SERVER["REMOTE_ADDR"];
$data = json_decode($res, true);
// dump($data);
$pt_id = $vs['pt_id'];
CommonService::addLog('获取取消订单', $urls.'---'.$res, $vs['pt_id'], 'JdOrderApi-getOrderCancelByJd');
$result = $data['jingdong_omnic_order_getorderlist_responce']['result'];
$result = json_decode($result, true);
if ($result['success'] == true) {
$order_data = $result['data'];
if (!empty($order_data)) {
if (isset($order_data['data'])) {
$order_data = $order_data['data'];
foreach ($order_data as $kkk => $vvv) {
$flag = 1;
$refundlist = RefundService::getInfoByKeyValue('order_num', $vvv['salesChannelOrderId'], ['state', 'roPreNo']);
if ($refundlist) {
$rea = '退款已存在';
$flag = 2;
}
if ($flag == 1) {
$refund['order_num'] = $vvv['salesChannelOrderId'];
$refund['refund'] = 1;
$refund['content'] = '平台订单已撤销';
$refund['urgent'] = 1;
$refund['recycle_type'] = 0;
$refund['roPreNo'] = $vvv['salesChannelOrderId'];
$sys_num = OrderService::getOrderBy('order_num', $vvv['salesChannelOrderId'], ['sys_num', 'order_status', 'new_money']);
if ($sys_num) {
$refund['sys_num'] = $sys_num['sys_num'];
if ($sys_num['order_status'] > 10) {
$msg = OrderService::getOrderMsg($sys_num['sys_num']);
} else {
$msg = OrderService::getOrderMsg($sys_num['sys_num']);
}
if ($msg['orderMsgArr']) {
$msg = $msg['orderMsgArr'];
$goodsArr = [];
foreach ($msg as $ka => $va) {
$goodsArr[$ka]['goods_name'] = $va['goods_name'];
$goodsArr[$ka]['goods_price'] = $va['goods_price'];
$goodsArr[$ka]['msg_id'] = $va['id'];
$goodsArr[$ka]['goods_num'] = $va['goods_num'];
$goodsArr[$ka]['goods_id'] = $va['goods_id'];
}
$refund['goodsArr'] = $goodsArr;
$refund['goods_state'] = 2;
$refund['info_ing'] = '';
$refund['info_acc'] = '';
$refund['info_name'] = '';
$refund['addType'] = 'jdRefund';
$refund['allprice'] = $sys_num['new_money'];
$session['id'] = '1133';
$session['admin_acc'] = '系统操作';
$session['admin_groupnew'] = 7;
$rea = OrderService::lockOrder($refund, $session, '39.105.188.64');
} else {
$rea = '无订单商品';
}
} else {
$rea = '无订单号';
}
}
$return[$kkk]['lockOrder'] = $rea;
$return[$kkk]['order_num'] = $vvv['salesChannelOrderId'];
}
CommonService::addLog('添加退款单', json_encode($return), $vs['pt_id'], 'addOrderCancels');
}
}
}
}
}
}
app/Http/Controllers/Api/SynJdPopDataController.php
浏览文件 @ f297a2d1
......@@ -49,7 +49,7 @@ class SynJdPopDataController extends BaseController
$res_ult[$k]['accessToken'] = $v['access_token']; //token
$res_ult[$k]['time_start'] = $time_start; //开始时间
$res_ult[$k]['time_end'] = $time_end; //结束时间
$res_ult[$k]['setPageSize'] = 20; //每页条数
$res_ult[$k]['setPageSize'] = 10; //每页条数
$res_ult[$k]['setOrderState'] = 'WAIT_SELLER_STOCK_OUT'; //订单状态 WAIT_SELLER_STOCK_OUT 等待出库 ,TRADE_CANCELED,POP_ORDER_PAUSE,LOCKED,WAIT_GOODS_RECEIVE_CONFIRM,WAIT_SELLER_DELIVERY
$res_ult[$k]['setOptionalFields'] ='orderInfo,orderId,orderType,payType,orderTotalPrice,orderSellerPrice,open_id_buyer,open_id,orderMarkDesc,storeId,tuiHuoWuYou,taxFee,scDT,storeOrder,orderSource,customsModel,customs,parentOrderId,directParentOrderId,modified,vatInfo,logisticsId,paymentConfirmTime,returnOrder,balanceUsed,venderRemark,itemInfoList,consigneeInfo,orderEndTime,orderStartTime,orderRemark,invoiceCode,invoiceInfo,invoiceEasyInfo,orderStateRemark,orderState,sellerDiscount,orderPayment,venderId,pauseBizInfo,freightPrice'; //获取的订单字段
......@@ -62,9 +62,9 @@ class SynJdPopDataController extends BaseController
CommonService::addLog('token1--'.$v['pt_id'], $res, $v['pt_id'],'SynJdPopData-getOrder');
$data = json_decode($res,true);
if($data['jingdong_pop_order_enSearch_responce']['code']==0){
$company_id = Pt::where("id",$v['pt_id'])->value('company_id');
$order_data = $data['jingdong_pop_order_enSearch_responce']['searchorderinfo_result']['orderInfoList'];
if(!empty($order_data)){
......@@ -197,7 +197,7 @@ class SynJdPopDataController extends BaseController
}
$fullAddress = $fullAddress??$vv['consigneeInfo']['fullAddress'];
$fullAddress = str_replace("'", '', $fullAddress);
$resjdgoods = DB::table('jdgoods')->where("order_id",$vv['orderId'])->value('id');
foreach( $vv['itemInfoList'] as $ka => $va ){
if(!$resjdgoods){
......@@ -274,7 +274,7 @@ class SynJdPopDataController extends BaseController
$session['admin_groupnew'] = 7;
$session['admin_acc'] = '系统录入';
$session['id'] = 1133;
$session['company_id'] = 11;
$session['company_id'] = $company_id;
// dump($orders[$kk]);
$return = OrderaddService::addOrder($orders[$kk], $session, $ip);
// dump($return);
......
app/Http/Controllers/Common/CommonController.php
浏览文件 @ f297a2d1
......@@ -1335,10 +1335,19 @@ class CommonController extends BaseController
*/
public function getDistributor ( Request $request )
{
$session = $request->get('session_token');
if($session['admin_groupnew']==8) {
$list = DB::table('admin')
->where('admin_groupnew', 3)
->select('id', 'admin_acc', 'admin_name', 'company_name')
->get()->toarray();
}else{
$list = DB::table('admin')
->where('admin_groupnew', 2)
->where('company_id', $session['company_id'])
->select('id', 'admin_acc', 'admin_name', 'company_name')
->get()->toarray();
}
if($list){
return $this->success('操作成功', $list);
}else{
......
app/Http/Controllers/DatasBase/TipsController.php
浏览文件 @ f297a2d1
......@@ -62,7 +62,7 @@ class TipsController extends BaseController
$timeout = Orders::where('order_status',20)->where('distype',5)->count();
if($timeout>0){
$num = count($list);
$list[$num]['msg'] = "订单超时未结单";
$list[$num]['msg'] = "订单超时未接单";
$list[$num]['count'] = $timeout;
$list[$num]['url'] = 'Ordersystem/orders';
}
......
app/Http/Controllers/Dou/MyTestController.php
浏览文件 @ f297a2d1
......@@ -13,11 +13,17 @@
namespace App\Http\Controllers\Dou;
use App\Exports\BasicExport;
use App\Http\Controllers\BaseController;
use App\Http\Controllers\Orders\AotuorderController;
use App\Models\Admin;
use App\Models\OrderList;
use App\Models\OrderMsg;
use App\Models\OrderRejected;
use App\Models\Orders;
use App\Models\User;
use App\Services\CommonService;
use App\Services\OrderaddService;
use App\Services\OrderService;
use Chumper\Zipper\Zipper;
use Illuminate\Http\Request;
use BlueCity\Core\Controllers\MountingCoreController as Controller;
......@@ -26,7 +32,7 @@ use App\Services\TechnicalLevelService;
use BlueCity\Core\Inc\ErrorInc;
use DB;
class MyTestController extends Controller
class MyTestController extends BaseController
{
public function test ( Request $request ){
$input = $request->all();
......@@ -46,7 +52,7 @@ class MyTestController extends Controller
if(empty($input['method'])){
return $this->error('缺少必要参数1',ErrorInc::FAILED_PARAM);
}
$api=['getSerStatistics','getSerStatisticsDetail','BasicExport'];
$api=['getSerStatistics','getSerStatisticsDetail','BasicExport','addOrderData'];
if(!in_array($input['method'],$api)){
return $this->error('接口不参数异常',ErrorInc::INVALID_PARAM,$input);
}else {
......@@ -301,4 +307,518 @@ class MyTestController extends Controller
}
/**
* @name 同步京东POP店未出库定单
* @param Request $request
* @author du
* @date 2022/4/27
*/
public function addOrderData ($input){
$url = "http://116.196.75.172/index.php/GetOrder/index";
$url_ex = "http://116.196.75.172/index.php/GetOrder/syncExpress";//出库
$time_start = date("Y-m-d H:i:s",strtotime(" -3420 minute".date("Y-m-d H:i:s")));
$time_end = date("Y-m-d H:i:s");
$goods = DB::table('pj_goods')->select('pg_id','brand_name','pg_series','version','goods_pic_path','national_version')->get()->toarray();
$goods = CommonService::jointArrayKey($goods, 'pg_id');
$token = DB::table('jdpop_token')->where('status',1)->where('type',1)->select('app_key','app_secret','access_token','pt_id','appName')->get()->toarray();
foreach ($token as $k =>$v){
// CommonService::addLog('token', json_encode($v['app_key']), $v['pt_id'],'jd_token');
$res_ult = [];
$res_ult[$k]['appKey'] = $v['app_key']; //appkey
$res_ult[$k]['appSecret'] = $v['app_secret']; //secret
$res_ult[$k]['accessToken'] = $v['access_token']; //token
$res_ult[$k]['time_start'] = $time_start; //开始时间
$res_ult[$k]['time_end'] = $time_end; //结束时间
$res_ult[$k]['setPageSize'] = 10; //每页条数
$res_ult[$k]['setOrderState'] = 'WAIT_SELLER_STOCK_OUT'; //订单状态 WAIT_SELLER_STOCK_OUT 等待出库 ,TRADE_CANCELED,POP_ORDER_PAUSE,LOCKED,WAIT_GOODS_RECEIVE_CONFIRM,WAIT_SELLER_DELIVERY
$res_ult[$k]['setOptionalFields'] ='orderInfo,orderId,orderType,payType,orderTotalPrice,orderSellerPrice,open_id_buyer,open_id,orderMarkDesc,storeId,tuiHuoWuYou,taxFee,scDT,storeOrder,orderSource,customsModel,customs,parentOrderId,directParentOrderId,modified,vatInfo,logisticsId,paymentConfirmTime,returnOrder,balanceUsed,venderRemark,itemInfoList,consigneeInfo,orderEndTime,orderStartTime,orderRemark,invoiceCode,invoiceInfo,invoiceEasyInfo,orderStateRemark,orderState,sellerDiscount,orderPayment,venderId,pauseBizInfo,freightPrice'; //获取的订单字段
/**TRADE_CANCELED,POP_ORDER_PAUSE,LOCKED
这三个是取消的状态，还是通过获取订单那个接口，触发时间和获取订单时间一致就行，这个没有变更状态一说，所以需要你判定，比如五分钟查一次最近六分钟的取消订单，如果系统中未取消就锁定订单生成退款单，如果过系统中已经取消或者已经锁定退款单就不用管了**/
$res_ult[$k]['page'] = 1;
$res = $this->request_post($url,$res_ult[$k]);
$ip = $_SERVER["REMOTE_ADDR"];
$res='{"jingdong_pop_order_enSearch_responce":{"code":"0","request_id":"161875.39587.17333121021090126","searchorderinfo_result":{"apiResult":{"chineseErrCode":"成功","numberCode":10100000,"englishErrCode":"success","success":true},"orderTotal":35,"orderInfoList":[{"orderSellerPrice":"10.00","orderType":"22","venderRemark":"","logisticsId":"","orderId":"300473755730","sendpayMap":"{\"9\":\"2\",\"20\":\"5\",\"26\":\"2\",\"29\":\"1\",\"34\":\"3\",\"36\":\"1\",\"39\":\"1\",\"50\":\"1\",\"51\":\"6\",\"62\":\"1\",\"64\":\"2\",\"84\":\"1\",\"96\":\"1\",\"173\":\"2\",\"186\":\"1\",\"188\":\"3\",\"190\":\"2\",\"191\":\"1\",\"229\":\"1\",\"235\":\"2\",\"239\":\"2\",\"342\":\"1\",\"402\":\"3\",\"847\":\"1\",\"860\":\"1\",\"943\":\"1\",\"1007\":\"1\"}","orderRemark":"","venderId":"18433933","paymentConfirmTime":"2024-12-04 19:03:51","orderStateRemark":"等待出库","orderState":"WAIT_SELLER_STOCK_OUT","popSignMap":"{\"11\":\"1\",\"19\":\"1\"}","itemInfoList":[{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFB60/探界者/别克E5E6/本田/大众/奥迪","itemTotal":"1","outerSkuId":"","jdPrice":"608.00","invoiceContentId":"","skuId":"10127082830913","productNo":"","newStoreId":"0"},{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFB70/昂科拉/君越/创酷/科沃兹/威朗/丰田","itemTotal":"1","outerSkuId":"","jdPrice":"678.00","invoiceContentId":"","skuId":"10127082830914","productNo":"","newStoreId":"0"},{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFB80/君越/君威/威朗","itemTotal":"1","outerSkuId":"","jdPrice":"769.00","invoiceContentId":"","skuId":"10127082830915","productNo":"","newStoreId":"0"},{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFBQ85/马自达/奔腾/铃木/凯美瑞/汉兰达","itemTotal":"1","outerSkuId":"","jdPrice":"609.00","invoiceContentId":"","skuId":"10127082830916","productNo":"","newStoreId":"0"}],"payType":"4-在线支付","totalSellerReceivable":"10.000000","modified":"2024-12-04 19:04:05","freightPrice":"0.00","vatInfo":{},"balanceUsed":"0.00","orderSource":"移动端订单","invoiceInfo":"不需要开具发票","totalSellerDiscount":"2654.000000","shouldPay":"10.00","orderTotalPrice":"2664.00","storeId":"0","orderPayment":"10.00","consigneeInfo":{"town":"八五四农场","city":"鸡西市","mobile":"136*******2","county":"虎林市","telephone":"134*******7","cityId":"737","townId":"33230","provinceId":"10","province":"黑龙江","countyId":"740","fullAddress":"黑龙江鸡西市******","fullname":"张**","oaid":"ZDBjYzg5ABT5Yz05DTH47QCKVJNOXZu1Yjk1MpfVuAfLrAuYkgdrs9d5Bp2TQM4aJwTxKNDu3zmQuHGWJKJEPLnp2lNcsr3oS95J14OMddvp9OKcr8ed8KMSd0efsxC1QbLSjRc38HhZQq1AhUV2Jxhx38JXewtHLNDMiQ=="},"sellerDiscount":"2654.00","returnOrder":"0","invoiceEasyInfo":{"invoiceType":"0","invoiceContentId":"1","invoiceTitle":"个人"},"storeOrder":"","totalOriginalPrice":"2664.00","actualPay":"10.00","orderStartTime":"2024-12-04 19:03:38"},{"orderSellerPrice":"10.00","orderType":"22","venderRemark":"","logisticsId":"","orderId":"306537548398","sendpayMap":"{\"9\":\"2\",\"26\":\"2\",\"29\":\"1\",\"34\":\"3\",\"36\":\"1\",\"39\":\"1\",\"50\":\"1\",\"51\":\"6\",\"62\":\"1\",\"64\":\"3\",\"84\":\"1\",\"96\":\"1\",\"173\":\"2\",\"186\":\"1\",\"188\":\"3\",\"190\":\"2\",\"191\":\"1\",\"229\":\"1\",\"235\":\"2\",\"239\":\"2\",\"342\":\"1\",\"860\":\"1\",\"943\":\"1\",\"945\":\"1\",\"1007\":\"1\"}","orderRemark":"","venderId":"18433933","paymentConfirmTime":"2024-12-04 19:03:45","orderStateRemark":"等待出库","orderState":"WAIT_SELLER_STOCK_OUT","popSignMap":"{\"11\":\"1\",\"19\":\"1\"}","itemInfoList":[{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFB80/君越/君威/威朗","itemTotal":"1","outerSkuId":"","jdPrice":"769.00","invoiceContentId":"","skuId":"10127082830915","productNo":"","newStoreId":"0"},{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFB60/探界者/别克E5E6/本田/大众/奥迪","itemTotal":"1","outerSkuId":"","jdPrice":"608.00","invoiceContentId":"","skuId":"10127082830913","productNo":"","newStoreId":"0"},{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFB70/昂科拉/君越/创酷/科沃兹/威朗/丰田","itemTotal":"1","outerSkuId":"","jdPrice":"678.00","invoiceContentId":"","skuId":"10127082830914","productNo":"","newStoreId":"0"},{"wareId":"10027478481650","giftPoint":"0","skuName":"德科汽车电瓶启停蓄电池EFB系列 EFBQ85/马自达/奔腾/铃木/凯美瑞/汉兰达","itemTotal":"1","outerSkuId":"","jdPrice":"609.00","invoiceContentId":"","skuId":"10127082830916","productNo":"","newStoreId":"0"}],"payType":"4-在线支付","totalSellerReceivable":"10.000000","modified":"2024-12-04 19:04:05","freightPrice":"0.00","vatInfo":{},"balanceUsed":"0.00","orderSource":"移动端订单","invoiceInfo":"不需要开具发票","totalSellerDiscount":"2654.000000","shouldPay":"10.00","orderTotalPrice":"2664.00","storeId":"0","orderPayment":"10.00","consigneeInfo":{"town":"江南镇","city":"杭州市","mobile":"156*******0","county":"桐庐县","telephone":"158*******7","cityId":"1213","townId":"50207","provinceId":"15","province":"浙江","countyId":"1218","fullAddress":"浙江杭州市桐庐县******","fullname":"陈**","oaid":"N2I3NzIxABT5Yz05DTH47QCKVJNOXZu1Yjk1ModIy85ZAbUxhW/omviTzIpOU4//lMWfUJfEpEAxlJ6ozZBMc4QPnIb1c7ljRN6vP82dS2slRdr0284q4riuyKbnD/kJnmQbk5knzyKvUES/QPbPbPVL0ISQ19GJ1Ht3IQ=="},"sellerDiscount":"2654.00","returnOrder":"0","invoiceEasyInfo":{"invoiceType":"0","invoiceContentId":"1","invoiceTitle":"个人"},"storeOrder":"","totalOriginalPrice":"2664.00","actualPay":"10.00","orderStartTime":"2024-12-04 19:03:36"}]}}}';
CommonService::addLog('token1--'.$v['pt_id'], $res, $v['pt_id'],'SynJdPopData-getOrder');
$data = json_decode($res,true);
if($data['jingdong_pop_order_enSearch_responce']['code']==0){
$order_data = $data['jingdong_pop_order_enSearch_responce']['searchorderinfo_result']['orderInfoList'];
if(!empty($order_data)){
$arr_goods = [];
$arr = [];
$num = 0;
foreach($order_data as $ksa => $vsa){
if(!empty($vsa['consigneeInfo']['oaid'])) {
$orderInfos[$num]['orderId'] = $vsa['orderId'];
$orderInfos[$num]['oaid'] = $vsa['consigneeInfo']['oaid'];
$num++;
}
}
if(!empty($orderInfos)){
$poss['appKey'] = $v['app_key'];
$poss['accessToken'] = $v['access_token'];
$poss['appSecret'] = $v['app_secret'];
$poss['orderType'] = 'POP';
$poss['appName'] = $v['appName'];
$poss['orderInfos'] = json_encode($orderInfos);
$user_data=$this->https_request('http://zptzchat.bluearp.com/m/index.php/GetUserDataApi/getOaidDecrypt',$poss);
$user_data = json_decode($user_data,true);
if($user_data['jingdong_jos_order_oaid_decrypt_responce']['returnType']['code']==200){
$user_data = $user_data['jingdong_jos_order_oaid_decrypt_responce']['returnType']['data'];
$user_datas = [];
foreach($user_data as $ks => $vs){
$user_datas[$vs['orderId']] = $vs;
}
if(!empty($user_datas)){
foreach($order_data as $ka => $va){
$order_data[$ka]['user_data_dou'] = isset($user_datas[$va['orderId']])?$user_datas[$va['orderId']]:'';
}
}
}
}
// CommonService::addLog('token3', json_encode($order_data), $v['pt_id'],'jd_token');
foreach ($order_data as $kk=>$vv) {
$order_info = OrderService::getOrderBy('order_num', $vv['orderId'],['id','order_status','lock_type','sys_num','order_num','p_id','ser_id','create_time','new_customer_id','lock_type','company_id']);
$order_info = CommonService::dataToArray($order_info);
if(!empty($order_info)&&in_array($vv['orderState'], ['TRADE_CANCELED','POP_ORDER_PAUSE','LOCKED'])){
if($order_info['lock_type']==2||in_array($order_info['order_status'], [50,55])){
continue;
}else{
$datar['allprice'] = $vv['orderTotalPrice'];
$goods_arr = OrderMsg::where('sys_num',$order_info['sys_num'])->get(['id as msg_id','goods_name','goods_price','goods_id as good_id']);
$datar['goodsArr'] = CommonService::dataToArray($goods_arr);
$datar['goods_state'] = 2;//2:平台; 4:财务
$datar['sys_num'] = $order_info['sys_num'];
$datar['order_num'] = $order_info['order_num'];
$datar['apply_type'] = 1;
$datar['content'] = $vv['orderStateRemark'];
$datar['p_id'] = $order_info['p_id'];
$datar['ser_id'] = $order_info['ser_id'];
$datar['new_customer_id'] = $order_info['new_customer_id'];
$datar['order_status'] = $order_info['order_status'];
$datar['create_time'] = $order_info['create_time'];
$userArr = User::where('id',$order_info['new_customer_id'])->first();
$session['admin_groupnew'] = 7;
$session['admin_acc'] = '系统录入';
$session['id'] = 1133;
$session['company_id'] = $order_info['company_id'];
$ret = OrderService::lockByRefund($datar , $session , $userArr);
CommonService::addLog('取消订单', json_encode($ret), $vv['orderId'],'JDPOP-cancel');
continue;
}
}
// CommonService::addLog('token4', json_encode( $vv['orderId']), $v['pt_id'],'jd_token');
$exsit = OrderService::getOrderBy('order_num', $vv['orderId'],['id']);
$eisit_jd = DB::table('jd_proprietary')->where('order_id',$vv['orderId'])->value('id');
if(!$exsit||!$eisit_jd){
$flag = 1;
unset($skuId);
foreach( $vv['itemInfoList'] as $ka => $va ){
$skuId[] = "'".$va['skuId']."'";
}
$goodids = DB::table("jd_bound")->whereRaw("sku_id in (".implode(',',$skuId).")")->pluck('goods_id','sku_id')->toarray();
if(empty($goodids)){
CommonService::addLog('无sku', json_encode($skuId), $vv['orderId'],'JDPOP-无sku');
$flag = 2;
}
if($goodids){
if(count($goodids)<count($vv['itemInfoList'])){
$flag = 2;
}
}
//解密
if(isset($vv['user_data_dou'])){
$str = $vv['user_data_dou']['customerName'];
}else {
$str = $vv['consigneeInfo']['fullname'];
}
$datafullname['accessToken'] = $v['access_token'];//'e0a1c90e617f4b3a9865ed059f99c5f42ztb';
$datafullname['appKey'] = $v['app_key'];;//'41D9668E8CB81C9890A065BEC300FD84';
$datafullname['appSecret'] = $v['app_secret'];//'93bff142bf5c4422ae7bec9eb992e751';
$fullname = $this->decrypt($datafullname,$str,$vv['orderId']);
if(strpos($fullname,'<body>' )!==false){
//存另一数据库中
//是否存在
$exs_code = DB::table('jdpop_encode')->where('order_id',$vv['orderId'])->value('id');
if($exs_code){
DB::table('jdpop_encode')->where('order_id',$vv['orderId'])->update(['name_code'=>$vv['consigneeInfo']['fullname']]);
}else{
DB::table('jdpop_encode')->insert(['order_id'=>$vv['orderId'],'pt_id'=>$v['pt_id'],'name_code'=>$vv['consigneeInfo']['fullname']]);
}
$fullname = '无';
}
$fullname = $fullname??$vv['consigneeInfo']['fullname'];
if(isset($vv['user_data_dou'])){
$Address = $vv['user_data_dou']['address'];
}else {
$Address = $vv['consigneeInfo']['fullAddress'];
}
$fullAddress = $this->decrypt($datafullname,$Address,$vv['orderId']);
if(strpos($fullAddress,'<body>' )!==false){
//存另一数据库中
//是否存在
$exs_code = DB::table('jdpop_encode')->where('order_id',$vv['orderId'])->value('id');
if($exs_code){
DB::table('jdpop_encode')->where('order_id',$vv['orderId'])->update(['address_code'=>$vv['consigneeInfo']['fullAddress']]);
}else{
DB::table('jdpop_encode')->insert(['order_id'=>$vv['orderId'],'address_code'=>$vv['consigneeInfo']['fullAddress'],'pt_id'=>$v['pt_id']]);
}
$fullAddress = '无';
}
$fullAddress = $fullAddress??$vv['consigneeInfo']['fullAddress'];
$fullAddress = str_replace("'", '', $fullAddress);
$resjdgoods = DB::table('jdgoods')->where("order_id",$vv['orderId'])->value('id');
foreach( $vv['itemInfoList'] as $ka => $va ){
if(!$resjdgoods){
$sql_dgoods .= "('".$vv['orderId']."',".$v['pt_id'].",'".$va['skuId']."','".$va['skuName']."','".$va['itemTotal']."','".$va['jdPrice']."','0'),";
if(in_array($vv['orderId'], $arr_goods)){
unset($arr_goods[$kk]);
}
$arr_goods[$kk]['order_id'] = $vv['orderId'];
$arr_goods[$kk]['pt_id'] = $v['pt_id'];
$arr_goods[$kk]['sku_id'] = $va['skuId'];
$arr_goods[$kk]['item_total'] = $va['itemTotal'];
$arr_goods[$kk]['jd_price'] = $va['itemTotal'];
$arr_goods[$kk]['jd_cost'] = $va['jdPrice'];
$arr_goods[$kk]['sku_name'] = $va['skuName'];
DB::table('jdgoods')->insert($arr_goods[$kk]);
unset($arr_goods[$kk]);
}
$sys_num = 'L'.date("YmdHis").str_pad(rand(0,999),3,'0',STR_PAD_LEFT);
if($flag==1) {
$goodid = $goodids[$va['skuId']];
if($goodid){
$goods_res = $goods[$goodid];
if($goods_res['pg_series']==''){
$type = $goods_res['version'];
}else{
$type = $goods_res['pg_series']."-".$goods_res['version'];
}
$goods_name = $goods_name.$goods_res['brand_name'].",".$type.",".$goods_res['general_version'].",";
$good_brand[] = $goods_res['brand_name'];
$orderMsgData[$ka]['goods_id'] = $goodid;
$orderMsgData[$ka]['goods_name'] = $goods_res['brand_name']."-".$type;
$orderMsgData[$ka]['goods_price'] = $va['jdPrice'];//实收/商品单价
// $orderMsgData['goods_paid'] = $va['jdPrice'];//应收
$orderMsgData[$ka]['goods_num'] = $va['itemTotal'];
$orderMsgData[$ka]['goods_brand'] = $goods_res['brand_name'];
$orderMsgData[$ka]['goods_number'] = $type;
$orderMsgData[$ka]['cd_id'] = 1;
// dump($orderMsgData);
}
}
}
//添单
//转换手机号
// $data['pt_name'] = $pt_name;//店铺名
$data_m[$kk]['order_id'] = $vv['orderId'];
$data_m[$kk]['appkey'] = $v['app_key']; //appkey
$data_m[$kk]['appsecret'] = $v['app_secret']; //secret
$data_m[$kk]['acctoken'] = $v['access_token']; //token
$tel = $this->changeTelphone($data_m[$kk]);
if($flag==1){
$orders[$kk]['sys_bh'] = $sys_num;
$orders[$kk]['skb_bh'] = $vv['orderId'];
$orders[$kk]['pt_id'] = $v['pt_id'];
$orders[$kk]['ser_type'] = 1;//服务类型：1上门安装，2到店服务
$orders[$kk]['shr_name'] = $fullname;
$orders[$kk]['shr_phone'] = $tel??$vv['consigneeInfo']['telephone'];//$vv['consigneeInfo']['telephone'];//
$orders[$kk]['shr_sheng'] = $vv['consigneeInfo']['province'];//
$orders[$kk]['shr_shi'] = $vv['consigneeInfo']['city'];//
$orders[$kk]['shr_xian'] = $vv['consigneeInfo']['county'];//
$orders[$kk]['shr_adress'] = $fullAddress;//
$orders[$kk]['shr_other'] = '接单后10分钟内务必联系客户核实车型跟安装时间！不断电安装、如果无法完成 请立刻反馈我们处理~！';
$orders[$kk]['car_audit'] = 2;//1:新订单；2：可派单；3：处理中
$orders[$kk]['order_type'] = 1;//订单类型：1：普通；20加急；10：夜间
$orders[$kk]['order_time'] = $vv['orderStartTime'];
$orders[$kk]['pay_type'] = 1;//支付方式：1在线支付；2货到付款
$orders[$kk]['goods'] = $orderMsgData;
return response()->json(['Data' =>$orders, 'ErrorMessage' => '执行完毕', 'ErrorCode' => 222]);exit;
// $session = $request->get('session_token');//获取操作人信息
$session['admin_groupnew'] = 7;
$session['admin_acc'] = '系统录入';
$session['id'] = 1133;
$session['company_id'] = 11;
// dump($orders[$kk]);
$return = OrderaddService::addOrder($orders[$kk], $session, $ip);
// dump($return);
CommonService::addLog('添加定单', json_encode($return), $vv['orderId'],'jd_addOrder');
// $return['ErrorCode'] = 2;
if($return['ErrorCode']==1){
//调用京东出库
$res_ex = [];
$res_ex['appKey'] = $v['app_key']; //appkey
$res_ex['appSecret'] = $v['app_secret'];//secret
$res_ex['accessToken'] = $v['access_token']; //token
$res_ex['skb_bh'] = $vv['orderId'];//$vv['orderId'];
$res_ex['jdid'] = 1274;
$res_ex['kd_number'] = '';
$res_ex['estimateDate'] = date("Y-m-d H:i:s");
$result = $this->request_post($url_ex,$res_ex);//出库同步
$filename = 'pop_ex'.date('Ym');
CommonService::addLog('出库', json_encode($res_ex), $vv['orderId'],$filename);
$reta = json_decode($result,true);
if($reta['jingdong_pop_order_shipment_responce']['sopjosshipment_result']['success']==true){
CommonService::addLog('添单成功出库', $result, $vv['orderId'],$filename);
}else{
CommonService::addLog('添单出库失败', $result, $vv['orderId'],$filename);
}
$newOrderId = true;
}else{
$newOrderId = false;
}
}
$rea = DB::table('jd_proprietary')->where("order_id",$vv['orderId'])->value('id');
if (!$newOrderId || $flag=='2'){
//echo '添加订单信息失败';
if(!$rea){
if(in_array($vv['orderId'], array_column($arr, 'order_id'))){
unset($arr[$kk]);
}
$arr[$kk]['order_id'] = $vv['orderId'];
$arr[$kk]['admin_acc'] = '系统录入';
$arr[$kk]['pt_id'] = $v['pt_id'];
$arr[$kk]['pay_type'] = $vv['payType'];
$arr[$kk]['order_seller_price'] = $vv['orderSellerPrice'];
$arr[$kk]['freight_price'] = $vv['freightPrice'];
$arr[$kk]['order_state'] = $vv['orderState'];//'WAIT_SELLER_STOCK_OUT';
$arr[$kk]['invoice_info'] = '不需要开具发票';
$arr[$kk]['order_remark'] = '';
$arr[$kk]['order_start_time'] = $vv['orderStartTime'];
$arr[$kk]['fullname'] = $fullname;
$arr[$kk]['mobile'] = $tel??$vv['consigneeInfo']['mobile'];
$arr[$kk]['telephone'] = $tel??$vv['consigneeInfo']['telephone'];//
$arr[$kk]['province'] = $vv['consigneeInfo']['province'];
$arr[$kk]['city'] = $vv['consigneeInfo']['city'];
$arr[$kk]['county'] = $vv['consigneeInfo']['county'];
$arr[$kk]['full_address'] = $fullAddress;
$arr[$kk]['order_pay'] = $vv['orderPayment'];
$arr[$kk]['is_show'] = 1;
$arr[$kk]['parent_orderid'] = $vv['parentOrderId'];
DB::table('jd_proprietary')->insert($arr[$kk]);
unset($arr[$kk]);
}
}else{
$reas = DB::table('jd_proprietary')->where("order_id",$vv['orderId'])->value('id');
if(!$reas){
if(in_array($vv['orderId'], array_column($arr, 'order_id'))){
unset($arr[$kk]);
}
$arr[$kk]['order_id'] = $vv['orderId'];
$arr[$kk]['admin_acc'] = '系统录入';
$arr[$kk]['pt_id'] = $v['pt_id'];
$arr[$kk]['pay_type'] = $vv['payType'];
$arr[$kk]['order_seller_price'] = $vv['orderSellerPrice'];
$arr[$kk]['freight_price'] = $vv['freightPrice'];
$arr[$kk]['order_state'] = 'WAIT_SELLER_STOCK_OUT';
$arr[$kk]['invoice_info'] = '不需要开具发票';
$arr[$kk]['order_remark'] = '';
$arr[$kk]['order_start_time'] = $vv['orderStartTime'];
$arr[$kk]['fullname'] = $fullname;
$arr[$kk]['mobile'] = $tel??$vv['consigneeInfo']['mobile'];
$arr[$kk]['telephone'] = $vv['consigneeInfo']['mobile'];//
$arr[$kk]['province'] = $vv['consigneeInfo']['province'];
$arr[$kk]['city'] = $vv['consigneeInfo']['city'];
$arr[$kk]['county'] = $vv['consigneeInfo']['county'];
$arr[$kk]['full_address'] = $fullAddress;
$arr[$kk]['order_pay'] = $vv['orderPayment'];
$arr[$kk]['is_show'] = 1;
$arr[$kk]['parent_orderid'] = $vv['parentOrderId'];
DB::table('jd_proprietary')->insert($arr[$kk]);
unset($arr[$kk]);
}
}
}
}
echo '添加成功---';
}
}
echo '操作成功--****';
}
}
/**
* @name 手机号转换
* @param $data
* @param $url
* @author du
* @date 2023/12/12
* @Time: 10:51
*/
public function changeTelphone($data){
// $result = $this->request_post($url,$data);
$url = 'jx.bluearp.com/m/index.php/Automatic/TzPopOrderGetPhone';
$ret = $this->request_post($url, $data);
$result = json_decode($ret,true);
CommonService::addLog('手机号', $result['jingdong_pop_order_getmobilelist_responce']["result"]["data"][$data['order_id']]['consMobilePhone'].'----'.$ret.'---'.json_encode($data).'---'.$url, $data['order_id'],'jd_mobile');
return $result['jingdong_pop_order_getmobilelist_responce']["result"]["data"][$data['order_id']]['consMobilePhone'];
}
/**
* @name 出库
* @param $data
* @author du
* @date 2024/3/21
* @Time: 8:54
*/
public function jdOrderEx($data){
$json['orderId'] = $data['order_num'];
$json['logiCoprId'] = 1274;
$sysParams['method'] = "jingdong.pop.order.shipment";
$sysParams['access_token'] = $data['accessToken'];
$sysParams['app_key'] = $data['appKey'];//
$sysParams['timestamp'] = date("Y-m-d H:i:s");
$sysParams['v'] = '2.0';
$apiParams["360buy_param_json"] = json_encode($json);
$sysParams["sign"] = $this->generateSign(array_merge($sysParams, $apiParams),$data['appsecret']);
$apiParams = array_merge($sysParams, $apiParams);
ksort($apiParams);
foreach( $apiParams as $k => $v ){
if(strpos($v,' ')){
$urldata[] = $k."=".urlencode ($v);
}else{
$urldata[] = $k."=".$v;
}
}
$urldata = implode("&",$urldata);
//$url = "https://api-dev.jd.com/routerjson?".$urldata;
$url = "https://api.jd.com/routerjson?".$urldata;
$resp = $this->https_get($url);
echo $resp;
}
private function generateSign($params,$sec) {
if ($params != null) { // 所有请求参数按照字母先后顺序排序
ksort($params);
// 定义字符串开始 结尾所包括的字符串
$stringToBeSigned = $sec;//'eb229319be99494583fe87810b608123';//'8de8b7903e7740abb9ac6ec39f22c0e5';
// 把所有参数名和参数值串在一起
foreach ($params as $k => $v) {
$stringToBeSigned .= "$k$v";
}
unset($k, $v);
// 把venderKey加在字符串的两端
$stringToBeSigned .= $sec;//'eb229319be99494583fe87810b608123';//'8de8b7903e7740abb9ac6ec39f22c0e5';
} else {
// 定义字符串开始 结尾所包括的字符串
$stringToBeSigned = $sec;//'eb229319be99494583fe87810b608123';//'8de8b7903e7740abb9ac6ec39f22c0e5';
// 把venderKey加在字符串的两端
$stringToBeSigned .= $sec;//'eb229319be99494583fe87810b608123';//'8de8b7903e7740abb9ac6ec39f22c0e5';
}
// 使用MD5进行加密，再转化成大写
return strtoupper(md5($stringToBeSigned));
}
/**
* @name 定时解密
* @author du
* @date 2024/4/10
* @Time: 10:14
*/
public function decOrder(){
$token = DB::table('jdpop_token')->where('status',1)->select('app_key','app_secret','access_token','pt_id')->get()->toarray();
foreach ($token as $k =>$v) {
// CommonService::addLog('token', json_encode($v['app_key']), $v['pt_id'],'jd_token');
$res_ult = [];
$res_ult[$k]['appKey'] = $v['app_key']; //appkey
$res_ult[$k]['appSecret'] = $v['app_secret']; //secret
$res_ult[$k]['accessToken'] = $v['access_token']; //token
$list = DB::table('jdpop_encode')->where('is_enj',1)->where('pt_id',$v['pt_id'])->OrderBy('id','desc')->limit(10)->get();
$list = CommonService::dataToArray($list);
if($list){
foreach ($list as $item) {
$user_id = Orders::where('order_num',$item['order_id'])->value('new_customer_id');
//解密
$fullname = $this->decrypt($res_ult[$k],$item['name_code'],$item['order_id']);
// echo $fullname;
if(strpos($fullname,'<body>' )!==false){
}else{
//修改用户表
$res = User::where('id',$user_id)->update(['shr_name'=>$fullname]);
}
$address = $this->decrypt($res_ult[$k], $item['address_code'],$item['order_id']);
if(strpos($address,'<body>' )!==false){
}else{
//修改用户表
$ret = User::where('id',$user_id)->update(['shr_adress'=>$address]);
}
if($res && $ret){
DB::table('jdpop_encode')->where('order_id',$item['order_id'])->update(['is_enj'=>2]);
}
CommonService::addLog('JD', $fullname.'--'.$address, $item['order_id'],'JDPOP-dec');
}
}
}
}
/**
* @name 解密
* @param $data
* @return string
* @author du
* @date 2024/3/29
* @Time: 9:54
*/
public function decrypt($data,$str,$order_num = ''){
if(preg_match("/[\x7f-\xff]/",$str)){
return $str;
}
$data['str'] = str_replace('+', '%2B', $str);
$decrypt_data = json_encode($data);
$url = "http://jm.bluearp.com/jd/jdDecrypt?data=".$decrypt_data;
$res = (string)$this->https_request($url);
CommonService::addLog('URL', $order_num.'---'.$url.'----'.$res, 111,'url');
return $res;
}
function https_request($url, $data = null)
{
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE);
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);
if (!empty($data)) {
curl_setopt($curl, CURLOPT_POST, 1);
curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
}
curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
$output = curl_exec($curl);
curl_close($curl);
return $output;
}
}
app/Http/Controllers/Orders/AftersaleOrderController.php
浏览文件 @ f297a2d1
......@@ -712,7 +712,7 @@ class AftersaleOrderController extends BaseController
$feek_time = date('Y-m-d',strtotime("+1day")).' 17:30:00'; //明天下午5:30时间
$info['feek_time'] = $feek_time;
$info['status'] = 10; //改为处理中
$info['day_time'] = $request->input('appoint_time');
$info['day_time'] = $request->input('day_time');
$res = OrderAfter::where('id',$Input['id'])->update($info);
if ($res){
$after_num = OrderAfter::where('id',$Input['id'])->select('after_num','p_id','shr_phone')->first();
......
app/Services/AftersaleOrderService.php
浏览文件 @ f297a2d1
......@@ -370,7 +370,7 @@ class AftersaleOrderService extends Service
}elseif($v['status']==10){
$buttonData[] = 'quality,looktime_sumb';
}elseif($v['status']==30){
$buttonData[] = 'getImgContent,finish_quality,quality_bohuis';
$buttonData[] = 'getImgContent,finish_quality,quality_bohuis,lookpics';
}elseif($v['status']==40){
$buttonData[] = 'lookpics,getImgContent';
}
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论