|
@@ -0,0 +1,647 @@
|
|
|
|
+<?php
|
|
|
|
+/**
|
|
|
|
+ * 测试队列任务脚本入口文件
|
|
|
|
+ * Created by PhpStorm.
|
|
|
|
+ * User: phperstar
|
|
|
|
+ * Date: 2018/6/10
|
|
|
|
+ * Time: 下午4:49
|
|
|
|
+ */
|
|
|
|
+
|
|
|
|
+namespace Jobs\Controller;
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+use Jobs\Dao\DCloudUsers;
|
|
|
|
+use Jobs\Dao\DUsersTestify;
|
|
|
|
+use Jobs\Model\MTopic\Push\MPush;
|
|
|
|
+use Jobs\Model\Middleware;
|
|
|
|
+
|
|
|
|
+use Jobs\Dao\DCloudUsersCategory;
|
|
|
|
+use Jobs\Dao\DUsersCategory;
|
|
|
|
+use Jobs\Dao\DGoodsSku;
|
|
|
|
+use Jobs\Dao\DGoods;
|
|
|
|
+use Jobs\Model\Test\K3Handle;
|
|
|
|
+use Jobs\Dao\DOrder;
|
|
|
|
+
|
|
|
|
+use Jobs\Model\MTopic\Finance\MReceivable;
|
|
|
|
+
|
|
|
|
+use Mall\Framework\Db\Db;
|
|
|
|
+
|
|
|
|
+class Test
|
|
|
|
+{
|
|
|
|
+ /**
|
|
|
|
+ * php ./Public/www/index.php --c=Test --a=Test
|
|
|
|
+ */
|
|
|
|
+ public function test()
|
|
|
|
+ {
|
|
|
|
+ $objMReceivable = new MReceivable();
|
|
|
|
+ $params = [
|
|
|
|
+ 'userCenterId' => 35,
|
|
|
|
+ 'enterpriseId' => 64,
|
|
|
|
+ 'id' => 9,
|
|
|
|
+ 'type' => 5,
|
|
|
|
+ ];
|
|
|
|
+ $objMReceivable->createReceivable($params);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ public function testk3()
|
|
|
|
+ {
|
|
|
|
+ //K/3 Cloud 业务站点地址
|
|
|
|
+ $cloudUrl = "http://123.206.51.139/k3cloud/";
|
|
|
|
+
|
|
|
|
+ //登陆参数
|
|
|
|
+ $data = array(
|
|
|
|
+ '597be128163613',//帐套Id
|
|
|
|
+ '秦统业',//用户名
|
|
|
|
+ 'Cwb20141222',//密码
|
|
|
|
+ 2052//语言标识
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $cookie_jar = tempnam('./tmp','CloudSession');
|
|
|
|
+ $post_content = self::create_postdata($data);
|
|
|
|
+
|
|
|
|
+ //$result = invoke_login($cloudUrl,$post_content,$cookie_jar);
|
|
|
|
+ $loginurl = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.AuthService.ValidateUser.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($loginurl,$post_content,$cookie_jar,TRUE);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('登陆请求数据:');
|
|
|
|
+ //echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('登陆返回结果:');
|
|
|
|
+ //echo '<pre>';print_r($result);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ unset($post_content);
|
|
|
|
+ unset($result);
|
|
|
|
+ unset($data);
|
|
|
|
+ /*$data = array(
|
|
|
|
+ 'FormId'=>'STK_Inventory',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>10,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'FID ASC',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId,FMaterialId.FNumber,FStockName,FMaterialName,FBaseQty,FStockStatusId,FStockOrgId.FNumber',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId=147946",//过滤(非必录)
|
|
|
|
+ );*/
|
|
|
|
+
|
|
|
|
+ /*$k3GoodsInfo = '{"FormId":"STK_Inventory","FieldKeys":"FMaterialId.FNumber,FMaterialName,FStockUnitId.FName,FBaseQty",
|
|
|
|
+ "FilterString":"FMaterialId=147946 and ( FStockName = \'菏泽G1库\' or FStockName = \'绿源冷库\' or FStockName = \'绿源冷库3号库\' )",
|
|
|
|
+ "OrderString":"","TopRowCount":"0","StartRow":"0","Limit":"100"}';*/
|
|
|
|
+
|
|
|
|
+ $data = array(
|
|
|
|
+ 'FormId'=>'STK_Inventory',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>100,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId,FMaterialId.FNumber,FStockName,FMaterialName,FBaseQty,FStockStatusId,FStockOrgId.FNumber',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId.FNumber ='0602070004' and (FStockName = '菏泽G1库' or FStockName = '绿源冷库' or FStockName = '绿源冷库3号库') and FStockOrgId.FNumber='101' ",//过滤(非必录)
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $post_content = self::create_postdata([$data]);
|
|
|
|
+
|
|
|
|
+ $url = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($url,$post_content,$cookie_jar,false);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('及时库存请求数据:');
|
|
|
|
+ //echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('及时库存返回结果:');
|
|
|
|
+ echo '<pre>';var_dump(json_decode($result, true));
|
|
|
|
+
|
|
|
|
+ $k3Weight = 0.00;
|
|
|
|
+ $resultArray = json_decode($result, true);
|
|
|
|
+ if(!empty($resultArray)){
|
|
|
|
+ foreach ($resultArray as $key => $value){
|
|
|
|
+ $k3Weight += $value[4];
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ var_dump($k3Weight);
|
|
|
|
+ return $k3Weight;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public function testk4()
|
|
|
|
+ {
|
|
|
|
+ //K/3 Cloud 业务站点地址
|
|
|
|
+ $cloudUrl = "http://123.206.51.139/k3cloud/";
|
|
|
|
+
|
|
|
|
+ //登陆参数
|
|
|
|
+ $data = array(
|
|
|
|
+ '597be128163613',//帐套Id
|
|
|
|
+ '秦统业',//用户名
|
|
|
|
+ 'Cwb20141222',//密码
|
|
|
|
+ 2052//语言标识
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $cookie_jar = tempnam('./tmp','CloudSession');
|
|
|
|
+ $post_content = self::create_postdata($data);
|
|
|
|
+
|
|
|
|
+ //$result = invoke_login($cloudUrl,$post_content,$cookie_jar);
|
|
|
|
+ $loginurl = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.AuthService.ValidateUser.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($loginurl,$post_content,$cookie_jar,true);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ echo '<pre>';print_r('登陆请求数据:');
|
|
|
|
+ echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ echo '<pre>';print_r('登陆返回结果:');
|
|
|
|
+ echo '<pre>';print_r($result);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ unset($post_content);
|
|
|
|
+ unset($result);
|
|
|
|
+ unset($data);
|
|
|
|
+ /*$data = array(
|
|
|
|
+ 'FormId'=>'STK_Inventory',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>10,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'FID ASC',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId,FMaterialId.FNumber,FStockName,FMaterialName,FBaseQty,FStockStatusId,FStockOrgId.FNumber',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId=147946",//过滤(非必录)
|
|
|
|
+ );*/
|
|
|
|
+
|
|
|
|
+ /*$k3GoodsInfo = '{"FormId":"STK_Inventory","FieldKeys":"FMaterialId.FNumber,FMaterialName,FStockUnitId.FName,FBaseQty",
|
|
|
|
+ "FilterString":"FMaterialId=147946 and ( FStockName = \'菏泽G1库\' or FStockName = \'绿源冷库\' or FStockName = \'绿源冷库3号库\' )",
|
|
|
|
+ "OrderString":"","TopRowCount":"0","StartRow":"0","Limit":"100"}';*/
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ $data = '{"Model":{"FNumber":"xyc2218","FCreateOrgId":{"FNumber":"101"},"FUseOrgId":{"FNumber":"101"},"FName":"u5218u5e05uff08u4ebfu6210u98dfu54c1u5185u90e8u5458u5de5uff09","FTEL":"18114640037","FADDRESS":"u5c71u4e1cu7701u6d4eu5357u5e02u5386u4e0bu533au6d4bu8bd5u5730u5740","FSALDEPTID":{"FNumber":"0020"},"FSALGROUPID":{"FNumber":"16"},"FSELLER":{"FNumber":"0020"},"FCustTypeId":{"FNumber":"KHLB001_SYS"},"FTRADINGCURRID":{"FNumber":"PRE001"},"F_PAEZ_Assistant3":{"FNumber":"0101"},"F_PAEZ_Assistant5":{"FNumber":"01"}},"Creator":"u4ebfu6210u5546u57ce"}';
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $post_content = self::create_postdata(["BD_Customer",$data]);
|
|
|
|
+
|
|
|
|
+ $url = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.Save.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($url,$post_content,$cookie_jar,false);
|
|
|
|
+
|
|
|
|
+ //header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('及时库存请求数据:');
|
|
|
|
+ echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('及时库存返回结果:');
|
|
|
|
+ //file_put_contents('/tmp/11.log',var_export($result,true),FILE_APPEND);
|
|
|
|
+ V($result);
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ // 采购入库单
|
|
|
|
+ public function testk5()
|
|
|
|
+ {
|
|
|
|
+ //K/3 Cloud 业务站点地址
|
|
|
|
+ $cloudUrl = "http://123.206.51.139/k3cloud/";
|
|
|
|
+
|
|
|
|
+ //登陆参数
|
|
|
|
+ $data = array(
|
|
|
|
+ '597be128163613',//帐套Id
|
|
|
|
+ '秦统业',//用户名
|
|
|
|
+ 'Cwb20141222',//密码
|
|
|
|
+ 2052//语言标识
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $cookie_jar = tempnam('./tmp','CloudSession');
|
|
|
|
+ $post_content = self::create_postdata($data);
|
|
|
|
+
|
|
|
|
+ //$result = invoke_login($cloudUrl,$post_content,$cookie_jar);
|
|
|
|
+ $loginurl = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.AuthService.ValidateUser.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($loginurl,$post_content,$cookie_jar,TRUE);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('登陆请求数据:');
|
|
|
|
+ //echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('登陆返回结果:');
|
|
|
|
+ //echo '<pre>';print_r($result);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ unset($post_content);
|
|
|
|
+ unset($result);
|
|
|
|
+ unset($data);
|
|
|
|
+ /*$data = array(
|
|
|
|
+ 'FormId'=>'STK_Inventory',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>10,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'FID ASC',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId,FMaterialId.FNumber,FStockName,FMaterialName,FBaseQty,FStockStatusId,FStockOrgId.FNumber',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId=147946",//过滤(非必录)
|
|
|
|
+ );*/
|
|
|
|
+
|
|
|
|
+ /*$k3GoodsInfo = '{"FormId":"STK_Inventory","FieldKeys":"FMaterialId.FNumber,FMaterialName,FStockUnitId.FName,FBaseQty",
|
|
|
|
+ "FilterString":"FMaterialId=147946 and ( FStockName = \'菏泽G1库\' or FStockName = \'绿源冷库\' or FStockName = \'绿源冷库3号库\' )",
|
|
|
|
+ "OrderString":"","TopRowCount":"0","StartRow":"0","Limit":"100"}';*/
|
|
|
|
+
|
|
|
|
+ $data = array(
|
|
|
|
+ 'FormId'=>'STK_InStock',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>1,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'FBillNo desc',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId.FNumber,FID,FDate,FBillNo,FDocumentStatus,FMaterialId,FStockStatusid,FMaterialName',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId.FNumber ='01110101010001',FDocumentStatus = 'c'",//过滤(非必录)
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $post_content = self::create_postdata([$data]);
|
|
|
|
+
|
|
|
|
+ $url = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($url,$post_content,$cookie_jar,false);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('及时库存请求数据:');
|
|
|
|
+ //echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('及时库存返回结果:');
|
|
|
|
+ V(json_decode($result, true));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ // 销售退货单
|
|
|
|
+ public function testk6()
|
|
|
|
+ {
|
|
|
|
+ //K/3 Cloud 业务站点地址
|
|
|
|
+ $cloudUrl = "http://123.206.51.139/k3cloud/";
|
|
|
|
+
|
|
|
|
+ //登陆参数
|
|
|
|
+ $data = array(
|
|
|
|
+ '597be128163613',//帐套Id
|
|
|
|
+ '秦统业',//用户名
|
|
|
|
+ 'Cwb20141222',//密码
|
|
|
|
+ 2052//语言标识
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $cookie_jar = tempnam('./tmp','CloudSession');
|
|
|
|
+ $post_content = self::create_postdata($data);
|
|
|
|
+
|
|
|
|
+ //$result = invoke_login($cloudUrl,$post_content,$cookie_jar);
|
|
|
|
+ $loginurl = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.AuthService.ValidateUser.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($loginurl,$post_content,$cookie_jar,TRUE);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('登陆请求数据:');
|
|
|
|
+ //echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('登陆返回结果:');
|
|
|
|
+ //echo '<pre>';print_r($result);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ unset($post_content);
|
|
|
|
+ unset($result);
|
|
|
|
+ unset($data);
|
|
|
|
+ /*$data = array(
|
|
|
|
+ 'FormId'=>'STK_Inventory',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>10,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'FID ASC',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId,FMaterialId.FNumber,FStockName,FMaterialName,FBaseQty,FStockStatusId,FStockOrgId.FNumber',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId=147946",//过滤(非必录)
|
|
|
|
+ );*/
|
|
|
|
+
|
|
|
|
+ /*$k3GoodsInfo = '{"FormId":"STK_Inventory","FieldKeys":"FMaterialId.FNumber,FMaterialName,FStockUnitId.FName,FBaseQty",
|
|
|
|
+ "FilterString":"FMaterialId=147946 and ( FStockName = \'菏泽G1库\' or FStockName = \'绿源冷库\' or FStockName = \'绿源冷库3号库\' )",
|
|
|
|
+ "OrderString":"","TopRowCount":"0","StartRow":"0","Limit":"100"}';*/
|
|
|
|
+
|
|
|
|
+ $data = array(
|
|
|
|
+ 'FormId'=>'STK_InStock',//业务对象表单Id(必录)
|
|
|
|
+ 'TopRowCount'=>0, // 最多允许查询的数量,0或者不要此属性表示不限制
|
|
|
|
+ 'Limit'=>1,
|
|
|
|
+ 'StartRow'=>0,
|
|
|
|
+ 'OrderString'=>'FBillNo desc',
|
|
|
|
+ 'FieldKeys'=>'FMaterialId.FNumber,FID,FDate,FBillNo,FDocumentStatus,FMaterialId,FStockStatusid,FMaterialName',//字段keys,字符串类型用逗号分隔,比如"key1,key2..."(必录)
|
|
|
|
+ 'FilterString'=>"FMaterialId.FNumber ='01110101010001',FDocumentStatus = 'c'",//过滤(非必录)
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ //定义记录Cloud服务端返回的Session
|
|
|
|
+ $post_content = self::create_postdata([$data]);
|
|
|
|
+
|
|
|
|
+ $url = $cloudUrl.'Kingdee.BOS.WebApi.ServicesStub.DynamicFormService.ExecuteBillQuery.common.kdsvc';
|
|
|
|
+ $result = self::invoke_post($url,$post_content,$cookie_jar,false);
|
|
|
|
+
|
|
|
|
+ header("Content-type: text/html; charset=gb2312");
|
|
|
|
+ //echo '<pre>';print_r('及时库存请求数据:');
|
|
|
|
+ //echo '<pre>';print_r($post_content);
|
|
|
|
+
|
|
|
|
+ //echo '<pre>';print_r('及时库存返回结果:');
|
|
|
|
+ V(json_decode($result, true));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ //构造Web API请求格式
|
|
|
|
+ public function create_postdata($args) {
|
|
|
|
+ $postdata = array(
|
|
|
|
+ 'format'=>1,
|
|
|
|
+ 'useragent'=>'ApiClient',
|
|
|
|
+ 'rid'=>self::create_guid(),
|
|
|
|
+ 'parameters'=>$args,
|
|
|
|
+ 'timestamp'=>date('Y-m-d'),
|
|
|
|
+ 'v'=>'1.0'
|
|
|
|
+ );
|
|
|
|
+ return json_encode($postdata);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public function create_guid() {
|
|
|
|
+ $charid = strtoupper(md5(uniqid(mt_rand(), true)));
|
|
|
|
+ $hyphen = chr(45);// "-"
|
|
|
|
+ $uuid = chr(123)// "{"
|
|
|
|
+ .substr($charid, 0, 8).$hyphen
|
|
|
|
+ .substr($charid, 8, 4).$hyphen
|
|
|
|
+ .substr($charid,12, 4).$hyphen
|
|
|
|
+ .substr($charid,16, 4).$hyphen
|
|
|
|
+ .substr($charid,20,12)
|
|
|
|
+ .chr(125);// "}"
|
|
|
|
+ return $uuid;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public function invoke_post($url,$post_content,$cookie_jar,$isLogin)
|
|
|
|
+ {
|
|
|
|
+ $ch = curl_init($url);
|
|
|
|
+
|
|
|
|
+ $this_header = array(
|
|
|
|
+ 'Content-Type: application/json',
|
|
|
|
+ 'Content-Length: '.strlen($post_content)
|
|
|
|
+ );
|
|
|
|
+
|
|
|
|
+ curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST');
|
|
|
|
+ curl_setopt($ch, CURLOPT_HTTPHEADER, $this_header);
|
|
|
|
+ curl_setopt($ch, CURLOPT_POSTFIELDS, $post_content);
|
|
|
|
+ curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
|
|
+ if($isLogin){
|
|
|
|
+ curl_setopt($ch, CURLOPT_COOKIEJAR, $cookie_jar);
|
|
|
|
+ }
|
|
|
|
+ else{
|
|
|
|
+ curl_setopt($ch, CURLOPT_COOKIEFILE, $cookie_jar);
|
|
|
|
+ }
|
|
|
|
+ curl_setopt($ch, CURLOPT_TIMEOUT, 30);
|
|
|
|
+
|
|
|
|
+ $result = curl_exec($ch);
|
|
|
|
+ curl_close($ch);
|
|
|
|
+
|
|
|
|
+ return $result;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ public static function s_put_txt()
|
|
|
|
+ {
|
|
|
|
+
|
|
|
|
+ $objDOrder = new DOrder('pifabbc');
|
|
|
|
+ $orderData = $objDOrder->query('SELECT order_id,buyer_id,order_no,order_status,created_at,pay_money,payment_type from ns_order');
|
|
|
|
+ foreach ($orderData as $key => $value){
|
|
|
|
+ $buyerids[] = $value['buyer_id'];
|
|
|
|
+ $orderData[$value['order_id']] = $value;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ $objDusersCategory = new DUsersCategory('pifabbc');
|
|
|
|
+ $infos = $objDusersCategory ->query('SELECT
|
|
|
|
+ t.id,
|
|
|
|
+ t.user_id as user_id,
|
|
|
|
+ t.contact_phone,
|
|
|
|
+ t.legal_person,
|
|
|
|
+ r.referee_name,
|
|
|
|
+ g.group_name,
|
|
|
|
+ c.id as category_id,
|
|
|
|
+ c.category_name,
|
|
|
|
+ c.pid,
|
|
|
|
+ t.check_status,
|
|
|
|
+ t.company_address,
|
|
|
|
+ t.detail_address,
|
|
|
|
+ t.erp_no
|
|
|
|
+ FROM
|
|
|
|
+ cloud_users_testify AS t,
|
|
|
|
+ cloud_referee AS r,
|
|
|
|
+ cloud_referee_group AS g,
|
|
|
|
+ cloud_users_category AS c
|
|
|
|
+ WHERE
|
|
|
|
+ t.referrer_no = r.referee_no
|
|
|
|
+ AND t.referrer_group_no = g.group_no
|
|
|
|
+ AND t.category_id = c.id and t.user_id in ('.implode(',', $buyerids).')');
|
|
|
|
+
|
|
|
|
+ if (!empty($infos)){
|
|
|
|
+ foreach ($infos as $key => $value) {
|
|
|
|
+ if ($value['pid'] != 0) {
|
|
|
|
+ $data = self::s_handle($value);
|
|
|
|
+ }
|
|
|
|
+ $info = array_merge($value, $data);
|
|
|
|
+ $data_file = implode(',', $info);
|
|
|
|
+
|
|
|
|
+ $userData[$value['user_id']] = $data_file;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ foreach ($orderData as $key => $value){
|
|
|
|
+ $content = $userData[$value['user_id']].','.implode(',', $value);
|
|
|
|
+ file_put_contents('order.txt',$content . PHP_EOL,FILE_APPEND) ;
|
|
|
|
+ unset($content);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+// $data_file = implode(',', $file);
|
|
|
|
+//
|
|
|
|
+// file_put_contents('cat.txt', $data_file);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public static function s_handle(&$info_value)
|
|
|
|
+ {
|
|
|
|
+ $objDusersCategory = new DUsersCategory();
|
|
|
|
+ $id = $info_value['pid'];
|
|
|
|
+ $detail = $objDusersCategory->get($id);
|
|
|
|
+ if (!empty($detail)) {
|
|
|
|
+ $info_value[] = $detail['category_name'];
|
|
|
|
+ $info_value['pid'] = $detail['pid'];
|
|
|
|
+ self::s_handle($info_value);
|
|
|
|
+ }
|
|
|
|
+ return $info_value;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //php ./Jobs/Public/www/index.php --c=Test --a=userErpReset
|
|
|
|
+ public static function userErpReset(){
|
|
|
|
+ $objectDCloudUsers = new DCloudUsers();
|
|
|
|
+ $objectDUsersTestify = new DUsersTestify();
|
|
|
|
+ $fileName = 'k3id.txt';
|
|
|
|
+ /*
|
|
|
|
+ * 逐行读取TXT文件
|
|
|
|
+ */
|
|
|
|
+ $file = fopen($fileName,'r');
|
|
|
|
+
|
|
|
|
+ $content = array();
|
|
|
|
+ if(!$file){
|
|
|
|
+ return 'file open fail';
|
|
|
|
+ }else{
|
|
|
|
+ $i = 0;
|
|
|
|
+ while (!feof($file)){
|
|
|
|
+ $content = mb_convert_encoding(fgets($file),"UTF-8","GBK,ASCII,ANSI,UTF-8");
|
|
|
|
+//print_r($content);
|
|
|
|
+
|
|
|
|
+ $data = explode(',',$content);
|
|
|
|
+
|
|
|
|
+ $info = $objectDUsersTestify -> get(['erp_no' => $data[1]]);
|
|
|
|
+
|
|
|
|
+ if (empty($info)){
|
|
|
|
+ echo 0;
|
|
|
|
+ continue;
|
|
|
|
+ }else{
|
|
|
|
+ $res = $objectDUsersTestify ->update(['k3_id'=>$data[0]],['erp_no' => $data[1]]);
|
|
|
|
+
|
|
|
|
+ echo $res;
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+// fclose($file);
|
|
|
|
+// $content = array_filter($content); //数组去空
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+// return $content;
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ //php ./Jobs/Public/www/index.php --c=Test --a=resetErpNo
|
|
|
|
+ public static function resetErpNo(){
|
|
|
|
+ $log ='';
|
|
|
|
+ $objectDCloudUsers = new DCloudUsers();
|
|
|
|
+ $objectDUsersTestify = new DUsersTestify();
|
|
|
|
+ $sql = "select *from cloud_users_testify WHERE SUBSTR(erp_no,1,3) !='xyc'";
|
|
|
|
+ $data = $objectDUsersTestify ->query($sql);
|
|
|
|
+
|
|
|
|
+ $log .= 'ID,客户新编号,客户旧编号,客户推荐人编码,客户推荐人组织编码,客户推荐人电话'.PHP_EOL;
|
|
|
|
+ $K3Handle = new K3Handle();
|
|
|
|
+ foreach($data as $value){
|
|
|
|
+
|
|
|
|
+ $id = $value['id'];
|
|
|
|
+//V($value);
|
|
|
|
+
|
|
|
|
+ if(!$value['erp_no']){
|
|
|
|
+ continue;
|
|
|
|
+ }
|
|
|
|
+ $erp_no = 'xyc'.$value['user_id'];
|
|
|
|
+ $res = $objectDUsersTestify -> update(['erp_no'=>$erp_no],['id'=>$id]);
|
|
|
|
+ $res = $K3Handle ->store($value,$erp_no);
|
|
|
|
+ if ($res['code'] !=200){
|
|
|
|
+continue;
|
|
|
|
+ }
|
|
|
|
+ $log .= $id.','.$erp_no.','.$value['erp_no']?:'空'.','.$value['referrer_no'].','.$value['referrer_group_no'].','.$value['referrer_phone'].PHP_EOL;
|
|
|
|
+ }
|
|
|
|
+ file_put_contents('update_erp_no.txt',$log,FILE_APPEND);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+//php ./Jobs/Public/www/index.php --c=Test --a=export
|
|
|
|
+ public static function export(){
|
|
|
|
+
|
|
|
|
+ $objDOrder = new DOrder('pifabbc');
|
|
|
|
+ $orderData = $objDOrder->query('SELECT sum(pay_money) as order_money ,count(order_id) as total_count,buyer_id from ns_order where order_status <>5 group by buyer_id');
|
|
|
|
+ $a =[];
|
|
|
|
+ foreach ($orderData as $key => $value){
|
|
|
|
+ //$buyerids[] = $value['buyer_id'];
|
|
|
|
+ $a[$value['buyer_id']] = $value;
|
|
|
|
+ }
|
|
|
|
+ $objDusersCategory = new DUsersCategory('pifabbc');
|
|
|
|
+ $infos = $objDusersCategory ->query('SELECT
|
|
|
|
+ t.id,
|
|
|
|
+ t.user_id as user_id,
|
|
|
|
+ t.contact_phone,
|
|
|
|
+ t.legal_person,
|
|
|
|
+ r.referee_name,
|
|
|
|
+ g.group_name,
|
|
|
|
+ c.id as category_id,
|
|
|
|
+ c.category_name,
|
|
|
|
+ c.pid,
|
|
|
|
+ t.check_status,
|
|
|
|
+ t.company_address,
|
|
|
|
+ t.detail_address,
|
|
|
|
+ t.erp_no
|
|
|
|
+ FROM
|
|
|
|
+ cloud_users_testify AS t,
|
|
|
|
+ cloud_referee AS r,
|
|
|
|
+ cloud_referee_group AS g,
|
|
|
|
+ cloud_users_category AS c
|
|
|
|
+ WHERE
|
|
|
|
+ t.referrer_no = r.referee_no
|
|
|
|
+ AND t.referrer_group_no = g.group_no
|
|
|
|
+ AND t.category_id = c.id and t.user_id ');
|
|
|
|
+ $user =[];
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ if (!empty($infos)){
|
|
|
|
+ foreach ($infos as $key => $value) {
|
|
|
|
+ if ($value['pid'] != 0) {
|
|
|
|
+ $data = self::s_handle($value);
|
|
|
|
+ }
|
|
|
|
+ $user[$value['user_id']] = $data;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ foreach ($user as $key => $value){
|
|
|
|
+ echo 1 .'//';
|
|
|
|
+ echo ($key);
|
|
|
|
+// $orderMoney = $objDOrder->query("SELECT sum('pay_money') as order_money ,count('order_id') as total_count from ns_order where order_status <>5 and buyer_id = $key");
|
|
|
|
+ $lastTime = $objDOrder->query("SELECT created_at from ns_order where order_status <>5 and buyer_id = $key ORDER by order_id DESC limit 0,1");
|
|
|
|
+
|
|
|
|
+ if (isset($a[$key])){
|
|
|
|
+ $content = implode(',', $value).','.'总金额:'.$a[$key]['order_money']?:0;
|
|
|
|
+ $content .= ',订单数:'.$a[$key]['total_count']?:0 ;
|
|
|
|
+ $content .= ',最后下单时间:'.$lastTime[0]['created_at']?:0 ;
|
|
|
|
+ }else{
|
|
|
|
+ $content = implode(',', $value);
|
|
|
|
+ }
|
|
|
|
+ file_put_contents('export.txt',$content . PHP_EOL,FILE_APPEND) ;
|
|
|
|
+ unset($content);
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public function ce(){
|
|
|
|
+ $objDOrder = new DOrder('pifabbc');
|
|
|
|
+
|
|
|
|
+ $lastTime = $objDOrder->query("SELECT created_at from ns_order where order_status <>5 and buyer_id = 4739 ORDER by order_id DESC limit 0,1");
|
|
|
|
+ V($lastTime);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public function jpush()
|
|
|
|
+ {
|
|
|
|
+ $swResult = Middleware::getInstance('ThirdPartyService')->sendSwoole('Jpush', 'broadcastPush', ['alias'=>['7581'],'content'=>'优鲜供应链新版即将发布']);
|
|
|
|
+ if( !$swResult['state'] ){
|
|
|
|
+ V( $swResult['data']);
|
|
|
|
+ }else{
|
|
|
|
+ V($swResult['data']);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+}
|