```
<?php
// +------------------------------------------------------------------------------------------------
// | 【使用说明】请将本文件上传至老虎系统网站服务器：/addons/对应标识/inc/mobile/ 目录下。
// +------------------------------------------------------------------------------------------------
// | [18淘客助手api文件(老虎微信淘宝客专用-兼容所有新老版本的老虎系统)] Copyright (c) 18.LA
// +------------------------------------------------------------------------------------------------
// | 最后修改：2020年03月21日
// +------------------------------------------------------------------------------------------------
// | 官网：http://taoke.18.la/
// +------------------------------------------------------------------------------------------------
global $_W, $_GPC, $return, $cfg;
$cfg = $this->module['config'];
$return = array('state'=>'ok','code'=>1,'message'=>'','version'=>'6.1','system'=>urlencode('老虎微信淘宝客'),'updatetime'=>urlencode('2020年03月21日'));
//如果未传入有效参数
if (!isset($_GPC['key']) || !isset($_GPC['api'])) {
$return['code']=0;
$return['message']=urlencode('API接口正常');
exit(urldecode(json_encode($return)));
}
//判断密钥
if($cfg['miyao']!=$_GPC['key']){
$return['code']=0;
$return['message']=urlencode('密钥错误');
exit(urldecode(json_encode($return)));
}
//设置常用变量
$_W['uniacid']=$_GPC['i'];//公众号id
$api=$_GPC['api'];//api名称
$op=$_GPC['op'];
$dtime=time();//当前时间
$message="";
//接口验证
if($api=='verify'){
$return['code']=1;
$return['message']=urlencode('验证成功');
exit(urldecode(json_encode($return)));
}
//【订单同步】
elseif($api=='postorder'){
//获取post过来的订单内容
$content=htmlspecialchars_decode($_GPC['content']);
//json解码
$contentArr=@json_decode($content, true);
//如果数组不为空
if(!empty($contentArr)){
$orderDbTable=$this->modulename."_tkorder";//订单数据库表名
$field=tableField(tablename($orderDbTable));//获取订单表的所有字段
$resultStr="";//记录订单入库结果字符串
//遍历订单数组
foreach($contentArr as $orderID=>$orderData)
{
//查询数据库
$ord=pdo_fetch('select * from '.tablename($orderDbTable)." where weid='{$_W['uniacid']}' and orderid='{$orderID}'");
if(count($orderData)>1){//订单号相同的多个订单集合
//如果已存在
if (!empty($ord)){
$result=pdo_delete($orderDbTable,array ('orderid'=>$orderID,'weid'=>$_W['uniacid']));//删除该订单id的所有订单
}
//将所有订单ID相同的订单添加到数据库
$resultTem=1;
foreach($orderData as $data){
$newdata=orderFormat($data,$field);//格式化订单数据
//原有字段值保持不变
if (!empty($ord)){
if (!empty($ord['type'])) $newdata['type']=$ord['type'];
if (!empty($ord['zdgd'])) $newdata['zdgd']=$ord['zdgd'];
}
//添加到数据
$result=pdo_insert($orderDbTable,$newdata);
if (!empty($result)) {//添加成功
$resultTem = ($resultTem==1) ? 1 : 0;//如果上次状态为1,这次也标记为1，否则设置为0
}else{//添加失败
//尝试修改唯一索引为普通索引
orderIndex(tablename($orderDbTable));
//再重新添加一次数据
$result=pdo_insert($orderDbTable,$newdata);
if (!empty($result)){
$resultTem = ($resultTem==1) ? 1 : 0;//如果上次状态为1,这次也标记为1，否则设置为0
}else{
$resultTem=0;//将状态标记为失败
}
}
}
$resultStr=resultState($resultStr,$orderID,$resultTem);//记录订单入库状态
}else{//订单号不同的单个订单
$newdata=orderFormat($orderData[0],$field);
if (!empty($ord)){//如果已存在
if($ord['orderzt']=='订单失效'){
$resultStr=resultState($resultStr,$orderID,"1");//失效订单，无需更新，也返回更新成功
continue;//跳过本次循环
}
$result=pdo_update($orderDbTable,$newdata,array('orderid' =>$orderID,'weid'=>$_W['uniacid']));//更新数据库
if (!empty($result)) {
//更新成功
$resultStr=resultState($resultStr,$orderID,"1");
}else{
//更新失败
$resultStr=resultState($resultStr,$orderID,"0");
}
}else{
//如果不存在,添加到数据
$result=pdo_insert($orderDbTable,$newdata);
if (!empty($result)) {
//添加成功
$resultStr=resultState($resultStr,$orderID,"1");
}else{
//添加失败
$resultStr=resultState($resultStr,$orderID,"0");
}
}
}
}
returnExit($return,1,"result:".$resultStr);//code值设置为1，表示成功
}else{
returnExit($return,0,"传入订单数据不正确");//code值设置为0，表示失败
}
}
//【商品采集】
elseif($api=='postgoods'){
//获取post过来的订单内容
$content=htmlspecialchars_decode($_GPC['content']);
//json解码
$contentArr=@json_decode($content, true);
//如果数组不为空
if(!empty($contentArr['cat']) && !empty($contentArr['goods'])){
//商品分类
$cat=goodsCat(tablename($this->modulename."_fztype"),$contentArr['cat']);
if(empty($cat)){
returnExit($return,0,"分类绑定不正确");//code值设置为0，表示失败
}
//商品数据
$goodsDbTable=$this->modulename."_newtbgoods";//订单数据库表名
$field=tableField(tablename($goodsDbTable));//获取订单表的所有字段
$resultStr="";//记录订单入库结果字符串
foreach($contentArr['goods'] as $data)
{
$itemid=$data['商品ID'];
//格式化商品数据
$newdata=goodsFormat($cat,$data,$field);
//print_r($newdata);
//查询是否存在
$goodsid=pdo_fetch('select itemid from '.tablename($goodsDbTable)." where weid='{$_W['uniacid']}' and itemid='{$itemid}'");
if (empty($goodsid)){
//如果不存在，新增
$result=pdo_insert($goodsDbTable,$newdata);
}else{
//如果已存在，更新
$result=pdo_update($goodsDbTable,$newdata,array('itemid' =>$itemid,'weid'=>$_W['uniacid']));
}
//记录入库结果
if (!empty($result)) {
//添加成功
$resultStr=resultState($resultStr,$itemid,"1");
}else{
//添加失败
$resultStr=resultState($resultStr,$itemid,"0");
}
}
returnExit($return,1,"result:".$resultStr);//code值设置为1，表示成功
}else{
returnExit($return,0,"传入商品数据不正确");//code值设置为0，表示失败
}
}
//【商品管理】
elseif($api=='delgoods'){
//获取post过来的订单内容
$content=htmlspecialchars_decode($_GPC['content']);
//json解码
$contentArr=@json_decode($content, true);
//订单数据库表名
$goodsDbTable=$this->modulename."_newtbgoods";
//如果where数组不为空
if(!empty($contentArr['where']) ){
$whereArr=$contentArr['where'];
//print_r($whereArr);
//构造sql语句
if(!empty($whereArr['销量小于']) )
{
if(!empty($where)) $where.=" or ";
$where.=" itemsale<'{$whereArr['销量小于']}' ";
}
if(!empty($whereArr['价格小于'])){
if(!empty($where)) $where.=" or ";
$where.=" itemendprice<'{$whereArr['价格小于']}' ";
}
if(!empty($whereArr['价格大于'])){
if(!empty($where)) $where.=" or ";
$where.=" itemendprice>'{$whereArr['价格大于']}' ";
}
if(!empty($whereArr['佣金小于']) )
{
if(!empty($where)) $where.=" or ";
$where.=" tkmoney<'{$whereArr['佣金小于']}' ";
}
if(!empty($whereArr['佣金比例']) )
{
if(!empty($where)) $where.=" or ";
$where.=" tkrates<'{$whereArr['佣金比例']}' ";
}
if(!empty($whereArr['非天猫']) )
{
if(!empty($where)) $where.=" or ";
$where.=" shoptype!='B' ";
}
if(!empty($whereArr['非视频单']) )
{
if(!empty($where)) $where.=" or ";
$where.=" videoid='0' ";
}
if(!empty($whereArr['优惠券过期']) )
{
if(!empty($where)) $where.=" or ";
$where.="(couponendtime<>'' and couponendtime<='{$dtime}') ";
}
if(!empty($whereArr['无优惠券']) )
{
if(!empty($where)) $where.=" or ";
$where.=" (quan_id='' and couponurl='') ";
}
//echo $where;
if(!empty($where)){
//执行删除语句
$result=pdo_query("DELETE FROM " . tablename($goodsDbTable) . " WHERE weid = '{$_W['uniacid']}' and ".$where);
if(!empty($result)){
returnExit($return,1,'成功删除'.$result.'件商品');//code值设置为1，表示成功
}else{
returnExit($return,1,'暂无符合条件商品');//code值设置为1，表示成功
}
}else{
returnExit($return,0,'传入条件数据不正确');//code值设置为1，表示成功
}
}
//如果goodsid数组不为空
elseif(!empty($contentArr['goodsid']) ){
$count=0;
//遍历订单ID数组
foreach($contentArr['goodsid'] as $goodsid)
{
//查询是否存在
$itemid=pdo_fetch('select itemid from '.tablename($goodsDbTable)." where weid='{$_W['uniacid']}' and itemid='{$goodsid}'");
if (!empty($itemid)){
//如果已存在，删除
$result=pdo_delete($goodsDbTable,array('itemid' =>$itemid,'weid'=>$_W['uniacid']));
if(!empty($result)){
$count+=$result;
}
}
}
if($count>0){
returnExit($return,1,'成功删除'.$count.'件商品');//code值设置为1，表示成功
}else{
returnExit($return,1,'暂无符合条件商品');//code值设置为1，表示成功
}
}
//删除全部商品
elseif(!empty($contentArr['all']) ){
$result=pdo_delete($goodsDbTable,array('weid'=>$_W['uniacid']));
if(!empty($result)){
returnExit($return,1,'成功删除'.$result.'件商品');//code值设置为1，表示成功
}else{
returnExit($return,1,'暂无商品');//code值设置为1，表示成功
}
//无有效参数
}else{
returnExit($return,0,'传入条件数据不正确');//code值设置为1，表示成功
}
}
//【代理管理】
elseif($api=='agentadmin'){
//订单数据库表名
$agentDbTable=$this->modulename."_share";
//获取代理信息
if($_GPC['op']=='getrequest'){
//查询待审核的代理信息(一次最多查询88条)
$list=pdo_fetchall('select * from '.tablename($agentDbTable)." where weid='{$_W['uniacid']}' and dltype=2 LIMIT 88");
if (!empty($list)){
foreach($list as $key=>$data)
{
$newdata[$key]['id']=$data['from_user'];
$newdata[$key]['name']=$data['tname'];//代理姓名：tname，代理微信昵称：nickname
}
returnExit($return,1,'获取未审核代理数据成功',$newdata);//code值设置为1，表示成功
}else{
returnExit($return,1,'暂无未审核代理数据');//code值设置为1，表示成功
}
//审核代理
}elseif($_GPC['op']=='check'){
$dailimodulename="tiger_wxdaili";//代理模块名称
//获取post过来的订单内容
$content=htmlspecialchars_decode($_GPC['content']);
//json解码
$contentArr=@json_decode($content, true);
if(empty($contentArr['id']))
{
returnExit($return,0,'传入数据不正确');//code值设置为1，表示成功
}
//读取相关参数
$openid=$contentArr['id'];//用户微信ID
//设置审核数据
$data = array(
'dltype' =>1,// 代理类型 1为代理 2为未审核
'cqtype'=>1,//是否开启查券 1为开启，0为不开
'updatetime'=>time(),
);
//查询代理信息
$sharedata=pdo_fetch("select * from ".tablename($agentDbTable)." where weid='{$_W['uniacid']}' and from_user='{$openid}' ");
//读取淘宝用户ID
$memberid=(!empty($contentArr['memberid'])) ? $contentArr['memberid'] : '' ;
if(!empty($contentArr['adzoneid']) && !empty($contentArr['pid'])){
//判断普通PID是否为空
if(empty($sharedata['dlptpid']))//当普通pid为空时，才分配新的pid，防止已有pid被覆盖
{
//将pid数据追加到数组
$data['tgwid']=($contentArr['type']==2)?time():$contentArr['adzoneid'];//推广位ID(根据用户咨询了老虎系统的作者，所反馈的情况，使用渠道模式时，pid必须分配一个固定的默认pid，推广位id要填一个不存在的数字，老虎系统才能正常使用渠道id匹配订单，此处取填时间戳,如果想使用默认pid中的推广位id，请自行修改代码)
//$data['tgwid']=$contentArr['adzoneid'];//推广位ID
$data['dlptpid']=$contentArr['pid'];//普通pid，三段式，类似：mm_181818818_68516333_68516333格式
$data['dlqqpid']=$contentArr['pid'];//鹊桥pid，取普通pid一样即可
}
$memberid=explode('_',$contentArr['pid'])[1];//提取pid中的memberid
}
//查询pid对应的淘宝账号id
$tksignsql="select * from ".tablename($this->modulename."_tksign")." where weid='{$_W['uniacid']}' ";
if(!empty($memberid)) $tksignsql=$tksignsql."and memberid='{$memberid}' ";
$tksigndata=pdo_fetch($tksignsql);//根据memberid从数据库内查询
if(!empty($tksigndata['tbuid']))//如果查询到了tbuid
{
//将pid数据追加到数组
$data['tbkpidtype']=1;//1代表已绑定，0代表未绑定
$data['tbuid']=$tksigndata['tbuid'];//淘宝用户数字id
}
/****************申请拼多多PID开始****************/
$pddsdkfilename = IA_ROOT . "/addons/tiger_newhu/inc/sdk/tbk/pdd.php";
//判断sdk文件是否存在并且当前拼多多的pid值是否为空
if (file_exists($pddsdkfilename) !== false && empty($sharedata['pddpid'])) {
include $pddsdkfilename;
$pddset=pdo_fetch("select * from ".tablename('tuike_pdd_set')." where weid='{$_W['uniacid']}'");
$owner_name=$pddset['ddjbbuid'];
$pidlist=pddtgw($owner_name,1);
$datalist=$pidlist['p_id_generate_response']['p_id_list'];//p_id
$pdd_pid=$datalist[0]['p_id'];
//判断拼多多pid是否创建成功
if (!empty($pdd_pid)){
//将拼多多pid添加到数组
$data['pddpid']=$pdd_pid;
//*******保存拼多多pid到数据库*********
$pdd_pidres = pdo_fetch("SELECT * FROM " . tablename($dailimodulename."_pddpid") . " weid='{$_W['uniacid']}' and pid='{$pdd_pid}'");//查询数据库中pid是否存在
$pdd_data=array(
'weid'=>$_W['uniacid'],
'pid'=>$pdd_pid,
'createtime'=>time(),
'type'=>1,
'uid'=>$sharedata['id'],
'nickname'=>$sharedata['nickname'],
);
if(empty($pdd_pidres)){
pdo_insert($dailimodulename."_pddpid", $pdd_data);//写入到数据库
}else{
pdo_update($dailimodulename."_pddpid",$pdd_data, array('pid' => $pdd_pid));//更新
}
//*******保存拼多多pid到数据库*********
}
}
/****************申请拼多多PID结束****************/
/****************申请京东PID开始****************/
$jdsdkfilename = IA_ROOT . "/addons/tiger_newhu/inc/sdk/tbk/jd.php";
//判断sdk文件是否存在并且当前京东的pid值是否为空
if (file_exists($jdsdkfilename) !== false && empty($sharedata['jdpid'])) {
include $jdsdkfilename;
$jdset=pdo_fetch("select * from ".tablename('tuike_jd_jdset')." where weid='{$_W['uniacid']}' order by id desc");
$jdsign=pdo_fetch("select * from ".tablename('tuike_jd_jdsign')." where weid='{$_W['uniacid']}' order by id desc");
if(!empty($jdset) && !empty($jdsign)){//判断配置值是否为空
$jd_tgwname=$sharedata['id']."_".time();//京东推广位名称
$jd_cjgetarr=array();
$jd_cjgetarr['unionId']=$jdset['unionid'];
$jd_cjgetarr['key']=$jdset['jdkey'];
$jd_cjgetarr['unionType']="1";
$jd_cjgetarr['type']="4";
$jd_cjgetarr['spaceNameList']=array($jd_tgwname);
$jd_cjgetarr=array(
'positionReq'=>$jd_cjgetarr
);
$jd_tgwlist=$this->cjget("jd.union.open.position.create",$jd_cjgetarr);//生成京东推广位
$jd_tgwlist=json_decode($jd_tgwlist,true);
$jd_tgw=json_decode($jd_tgwlist['jd_union_open_position_create_response']['result'],true);
$jd_pid=$jd_tgw['data']['resultList'][$jd_tgwname];//对应代理推广位
//判断京东pid是否创建成功
if (!empty($jd_pid) && $jd_pid!='-1'){
//将京东pid添加到数组
$data['jdpid']=$jd_pid;
//*******保存京东pid到数据库*********
$jd_pidres=pdo_fetch("select * from ".tablename($dailimodulename."_jdpid")." where weid='{$_W['uniacid']}' and pid='{$jd_pid}' order by id desc "); //查询pid是否存在
$jd_data = array(
'weid' => $_W['weid'],
'type' =>1,
'nickname' => $sharedata['nickname'],
'uid'=>$sharedata['id'],
'pid' =>$jd_pid,
'tgwname' =>$jd_tgwname,
'fptime' =>time(),
'createtime' => TIMESTAMP
);
if(empty($jd_pidres)){
pdo_insert($dailimodulename."_jdpid", $jd_data);//新增
}else{
pdo_update($dailimodulename."_jdpid",$jd_data, array('pid' => $jd_pid));//更新
}
//*******保存京东pid到数据库*********
}
}
}
/****************申请京东PID结束****************/
/****************申请唯品会PID开始****************/
$wphsdkfilename = IA_ROOT."/addons/tiger_newhu/inc/sdk/wph/com/vip/adp/api/open/service/UnionPidServiceClient.php";
//判断sdk文件是否存在并且当前唯品会的pid值是否为空
if (file_exists($wphsdkfilename) !== false && empty($sharedata['wphpid'])) {
include $wphsdkfilename;
$wphsignset=pdo_fetch("select * from ".tablename('tiger_newhu_wphsign')." where weid='{$_W['uniacid']}'");
$whpsign=$wphsignset['access_token'];
if(!empty($whpsign)){//判断配置值是否为空
$pidname[0]=$sharedata['id']."_".time();//唯品会推广位名称
//生成唯品会推广位
try {
$service=\com\vip\adp\api\open\service\UnionPidServiceClient::getService();
$ctx=\Osp\Context\InvocationContextFactory::getInstance();
$ctx->setAppKey("2bc54d13");
$ctx->setAppSecret("E80CC551126603A3F53AA84F366527F3");
$ctx->setAppURL("https://gw.vipapis.com/");
$ctx->setAccessToken($whpsign);
$ctx->setLanguage("zh");
$pidGenRequest1=new \com\vip\adp\api\open\service\PidGenRequest();
$pidNameList2=$pidname;
$pidGenRequest1->pidNameList=$pidNameList2;
$pidGenRequest1->requestId="requestIdsdddd";
$res=(array)$service->genPidWithOauth($pidGenRequest1);
$res=(array)$res['pidInfoList'];
// echo "<pre>";
//print_r($res);
// exit;
} catch(\Osp\Exception\OspException $e){
//var_dump($e);
}
$wph_tgw=(array)$res[0];
$wph_tgwpid=$wph_tgw['pid'];
$wph_tgwname=$wph_tgw['pidName'];//推广位名称
$wph_tgwcreateTime=$wph_tgw['createTime'];//推广位创建时间
//判断唯品会pid是否创建成功
if (!empty($wph_tgwpid) && !empty($wph_tgwname)){
//将唯品会pid添加到数组
$data['wphpid']=$wph_tgwpid;
//*******保存唯品会pid到数据库*********
$vip_pidres=pdo_fetch("select * from ".tablename($dailimodulename."_wphpid")." where weid='{$_W['uniacid']}' and pid='{$wph_tgwpid}'"); //查询pid是否存在
$vip_data = array(
'weid'=>$_W['uniacid'],
'pid'=>$wph_tgwpid,
'tgwname'=>$wph_tgwname,
'createtime'=>time(),
'type'=>1,
'nickname' => $sharedata['nickname'],
'uid'=>$sharedata['id'],
'fptime' =>time(),
);
if(empty($vip_pidres)){
pdo_insert($dailimodulename."_wphpid", $vip_data);//新增
}else{
pdo_update($dailimodulename."_wphpid",$vip_data, array('pid' => $vip_pid));//更新
}
//*******保存唯品会pid到数据库*********
}
}
}
/****************申请唯品会PID结束****************/
//更新到数据库
$result=pdo_update($agentDbTable, $data, array('id' =>$sharedata['id'],'weid'=>$_W['uniacid']));//更新代理信息
//判断结果
if(!empty($result)){
//跨模块读取tiger_wxdaili配置
$wxdaili=pdo_fetch("select value from ".tablename('core_cache')." where `key`='we7:module_setting:{$_W['uniacid']}:tiger_wxdaili'");
if(!empty($wxdaili)){
$value=unserialize($wxdaili['value']);
$wxdaili_cfg=unserialize($value['settings']);
}else{
//微擎1.7以上版本模块配置文件保存的地方不一样
$wxdaili=pdo_fetch("select settings from ".tablename('uni_account_modules')." where `module`='tiger_wxdaili' and `uniacid`='{$_W['uniacid']}'");
$wxdaili_cfg=unserialize($wxdaili['settings']);
}
//审核成功
if(!empty($wxdaili_cfg['dlshtgtx'])){//管理员订单提交提醒
$fans=pdo_fetch("select m.uid,m.nickname,m.avatar,f.openid,m.uid,f.followtime,f.follow,m.resideprovince,m.residecity,m.gender from ".tablename('mc_members')." m inner join ".tablename('mc_mapping_fans')." f on m.uid=f.uid and f.openid='{$openid}' and f.uniacid='{$_W['uniacid']}'");
//查询代理信息
$share=pdo_fetch("select * from ".tablename($agentDbTable)." where weid='{$_W['uniacid']}' and from_user='{$openid}'");
//查询模版信息
$mb=pdo_fetch("select * from ".tablename($this->modulename."_mobanmsg")." where weid='{$_W['uniacid']}' and id='{$wxdaili_cfg['dlshtgtx']}'");
//设置消息数据
$valuedata=array(
'rmb'=>'',
'txzhanghao'=>'',//提现支付帐帐号
'dlmsg'=>$share['dlmsg'],//申请理由
'tname'=>$share['tname'],//申请人姓名
'dlsqjj'=>$_GPC['glymsg'],//代理申请拒绝原因
'tel'=>$share['tel'],
'weixin'=>$share['weixin'],
'shenhe'=>'',//'审核通过|审核不通过|资料有误请重新提交审核',
'goodstitle'=>''//'积分商城，商品名称'
);
//发送提醒消息
$msg=$this->mbmsg($openid,$mb,$mb['mbid'],$mb['turl'],$fans,'',$wxdaili_cfg,$valuedata);
}
returnExit($return,1,'代理审核成功');//code值：1成功 0失败
}else{
returnExit($return,0,'代理审核失败');//code值：1成功 0失败
}
}else{
returnExit($return,0,'传入条件数据不正确');//code值：1成功 0失败
}
}
//【拼多多订单入库】
elseif($api=='postpddorder'){
//获取post过来的订单内容
$content = htmlspecialchars_decode($_GPC['content']);
$contentArr = @json_decode($content, true);
//json解码
//判断传入订单数据是否为空
if (!empty($contentArr)) {
//定义记录订单入库结果的变量
$resultStr = "";
$goodsDbTable=$this->modulename."_pddorder";//订单数据库表名
//遍历订单数据
foreach ($contentArr as $orderid => $orderdata) {
//格式化订单数据
$newdata = orderFormatPdd($orderdata);
//查询是否存在
$row = pdo_fetch("SELECT * FROM " . tablename($goodsDbTable) . " WHERE weid='{$_W['uniacid']}' and order_sn='{$orderid}'");
if (empty($row)) {
//如果不存在，新增数据
$result = pdo_insert($goodsDbTable, $newdata);
} else {
//如果存在，更新数据
$result = pdo_update($goodsDbTable, $newdata, array('order_sn' => $orderid,'weid'=>$_W['uniacid']));
}
//记录入库结果
if (!empty($result)) {
$resultStr = resultState($resultStr, $orderid, "1");//成功
} else {
$resultStr = resultState($resultStr, $orderid, "0");//失败
}
}
returnExit($return, 1, "result:" . $resultStr);
//code值设置为1，表示成功
} else {
returnExit($return, 0, "传入订单数据不正确");
//code值设置为0，表示失败
}
}
//【京东订单入库】
elseif($api=='postjdorder'){
//获取post过来的订单内容
$content = htmlspecialchars_decode($_GPC['content']);
$contentArr = @json_decode($content, true);
//json解码
//判断传入订单数据是否为空
if (!empty($contentArr)) {
//定义记录订单入库结果的变量
$resultStr = "";
$goodsDbTable=$this->modulename."_jdorder";//订单数据库表名
//遍历订单数据
foreach ($contentArr as $orderid => $orderdata) {
$resultTem=1;
//遍历子订单数据
foreach($orderdata as $data){
//处理参数
$orderTime=strtotime($data['orderTime']);//下单时间
$finishTime=$data['finishTime'];//结算时间
$finishTime=($finishTime == 0 || $finishTime == "0")?0:strtotime($finishTime);
//格式化订单数据
$newdata=array(
'weid'=>$_W['uniacid'],
'finishTime'=>substr($finishTime , 0 , 10),
'orderEmt'=>$data['orderEmt'],
'orderId'=>$data['orderId'],
'orderTime'=>substr($orderTime , 0 , 10),
'parentId'=>$data['parentId'],
'payMonth'=>$data['payMonth'],
'plus'=>$data['plus'],
'popId'=>$data['popId'],
'actualCommission'=>$data['actualCommission'],
'actualCosPrice'=>$data['actualCosPrice'],
'actualFee'=>$data['actualFee'],
'commissionRate'=>$data['commissionRate'],
'estimateCommission'=>$data['estimateCommission'],
'estimateCosPrice'=>$data['estimateCosPrice'],
'estimateFee'=>$data['estimateFee'],
'finalRate'=>$data['finalRate'],
'firstLevel'=>$data['firstLevel'],
'frozenSkuNum'=>$data['frozenSkuNum'],
'payPrice'=>$data['payPrice'],
'pid'=>$data['pid'],
'price'=>$data['price'],
'secondLevel'=>$data['secondLevel'],
'siteId'=>$data['siteId'],
'skuId'=>$data['skuId'],
'skuName'=>$data['skuName'],
'skuNum'=>$data['skuNum'],
'skuReturnNum'=>$data['skuReturnNum'],
'spId'=>$data['positionId'],
'subSideRate'=>$data['subSideRate'],
'subUnionId'=>$data['subUnionId'],
'subsidyRate'=>$data['subsidyRate'],
'thirdLevel'=>$data['thirdLevel'],
'traceType'=>$data['traceType'],
'unionAlias'=>$data['unionAlias'],
'unionTrafficGroup'=>$data['unionTrafficGroup'],
'unionTag'=>$data['unionTag'],
'validCode'=>$data['validCode'],
'unionId'=>$data['unionId'],
'unionUserName'=>$data['unionUserName'],
'createtime'=>time()
);
//查询是否存在
$row = pdo_fetch("SELECT * FROM " . tablename($goodsDbTable) . " WHERE weid='{$_W['uniacid']}' and orderId='{$data['orderId']}' and skuId='{$data['skuId']}'" );
if (empty($row)) {
//如果不存在，新增数据
$result = pdo_insert($goodsDbTable, $newdata);
} else {
//如果存在，更新数据
$result = pdo_update($goodsDbTable, $newdata, array('weid'=>$_W['uniacid'],'orderId' => $data['orderId'],'skuId' => $data['skuId']));
}
//判断入库结果
if (!empty($result)){
$resultTem = ($resultTem==1) ? 1 : 0;//如果上次状态为1,这次也标记为1，否则设置为0
}else{
$resultTem=0;//将状态标记为失败
}
}
//记录入库结果
$resultStr = resultState($resultStr, $orderid, $resultTem);
}
returnExit($return, 1, "result:" . $resultStr);
//code值设置为1，表示成功
} else {
returnExit($return, 0, "传入订单数据不正确");
//code值设置为0，表示失败
}
}
//【唯品会订单入库】
elseif($api=='postviporder'){
//获取post过来的订单内容
$content = htmlspecialchars_decode($_GPC['content']);
$contentArr = @json_decode($content, true);
//json解码
//判断传入订单数据是否为空
if (!empty($contentArr)) {
//定义记录订单入库结果的变量
$resultStr = "";
$orderDbTable=$this->modulename."_wphorder";//订单数据库表名
//遍历订单数据
foreach ($contentArr as $orderid => $orderdata) {
//格式化订单数据
$newdata=array(
'weid'=>$_W['uniacid'],
'orderSn'=>$orderdata['orderSn'],
'status'=>$orderdata['status'],
'newCustomer'=>$orderdata['newCustomer'],
'channelTag'=>$orderdata['channelTag'],
'orderTime'=>strtotime($orderdata['orderTime']),//
'signTime'=>strtotime($orderdata['signTime']),//
'settledTime'=>strtotime($orderdata['settledTime']),//
'lastUpdateTime'=>strtotime($orderdata['lastUpdateTime']),//
'settled'=>$orderdata['settled'],
'selfBuy'=>$orderdata['selfBuy'],
'orderSubStatusName'=>$orderdata['orderSubStatusName'],
'commission'=>$orderdata['commission'],
'afterSaleChangeCommission'=>$orderdata['afterSaleChangeCommission'],
'afterSaleChangeGoodsCount'=>$orderdata['afterSaleChangeGoodsCount'],
'commissionEnterTime'=>$orderdata['commissionEnterTime'],
'orderSource'=>$orderdata['orderSource'],
'pid'=>$orderdata['pid'],
'isPrepay'=>0,//$orderdata['isPrepay']
'goodsId'=>$orderdata['goodsId'],
'goodsName'=>$orderdata['goodsName'],
'goodsThumb'=>$orderdata['goodsThumb'],
'goodsCount'=>$orderdata['goodsCount'],
'commissionTotalCost'=>$orderdata['commissionTotalCost'],
'commissionRate'=>$orderdata['commissionRate'],
'commCode'=>$orderdata['commCode'],
'commName'=>$orderdata['commName'],
'afterSaleInfo'=>$orderdata['afterSaleInfo'],
'sizeId'=>$orderdata['sizeId'],
'createtime'=>time()
);
//查询是否存在
$row = pdo_fetch("SELECT * FROM " . tablename($orderDbTable) . " WHERE weid='{$_W['uniacid']}' and orderSn='{$orderdata['orderSn']}' and goodsId='{$orderdata['goodsId']}' and sizeId='{$orderdata['sizeId']}'" );
if (empty($row)) {
//如果不存在，新增数据
$result = pdo_insert($orderDbTable, $newdata);
if (!empty($result)) {
$resultStr = resultState($resultStr, $orderid, "1");//成功
} else {
$resultStr = resultState($resultStr, $orderid, "0");//失败
}
} else {
//如果存在，更新数据
$result = pdo_update($orderDbTable, $newdata, array('weid'=>$_W['uniacid'],'orderSn' => $orderdata['orderSn'],'goodsId' => $orderdata['goodsId'],'sizeId' => $orderdata['sizeId']));
$resultStr = resultState($resultStr, $orderid, "1");
}
}
returnExit($return, 1, "result:" . $resultStr);
//code值设置为1，表示成功
} else {
returnExit($return, 0, "传入订单数据不正确");
//code值设置为0，表示失败
}
}
//【定时任务】
elseif ($api == 'timetask') {
//【加载定时任务插件文件】
if (!empty($op)) {
$timetaskfilename = IA_ROOT . "/addons/tiger_newhu/inc/mobile/18timetask_" . $op . ".inc.php";
if (file_exists($timetaskfilename) !== false) {
include $timetaskfilename;
}
}
//【京东订单同步】
if ($op == "jdorder") {
/****************京东订单同步开始****************/
//【接收参数】
$start = empty($_GPC['start']) ? 0 : trim($_GPC['start']);//开始天数(默认为0，即从当天开始)
$day = empty($_GPC['day']) ? 1 : trim($_GPC['day']);//要同步的天数(默认同步1天)
$hour=empty($_GPC['hour']) ? 24 : trim($_GPC['hour']);//每次同步几小时的订单(默认每次同步24小时)
$progress=empty($_GPC['progress']) ? 0 : trim($_GPC['progress']);//同步进度参数(默认从0开始，程序自动处理，请勿手工传入此参数)
$allcount=empty($_GPC['allcount']) ? 0 : trim($_GPC['allcount']);//记录获取订单总数的参数(默认从0开始，程序自动处理，请勿手工传入此参数)
$sleep=empty($_GPC['sleep']) ? 1 : trim($_GPC['sleep']);//执行完当前页后执行下一页的间隔时间
//【计算相关时间】
$startTime=date("Y-m-d H:i:s",strtotime("-".$start." day"));//计算开始时间
$endTime=date("Y-m-d H:i:s",strtotime("-".$day." day", strtotime($startTime)));//计算结束时间(strtotime可以接受第二个参数，类型timestamp,为指定日期)
$allHour=abs(floor((strtotime($endTime)-strtotime($startTime))/3600));//开始时间和结束时间相差小时数
$progressTime=date("Y-m-d H:i:s",strtotime("-".$progress." hours", strtotime($startTime)));//计算进度时间
//echo '开始时间：'.$startTime.' 结束时间：'.$endTime.' 相差小时数：'.$allHour.' 进度：'.$progress.'/'.$allHour;
//exit;
//【引用京东api文件】
$jdsdkfilename=IA_ROOT . "/addons/tiger_newhu/inc/sdk/tbk/jd.php";
if (file_exists($jdsdkfilename) == false) returnExit($return, 0, '你的淘客系统缺少:'.$jdsdkfilename.'文件');//判断文件是否存在
include $jdsdkfilename;
//【读取京东相关配置】
$jdset=pdo_fetch("select * from ".tablename('tuike_jd_jdset')." where weid='{$_W['uniacid']}' order by id desc");
$jdsign=pdo_fetch("select * from ".tablename('tuike_jd_jdsign')." where weid='{$_W['uniacid']}' order by id desc");
if(empty($jdset) || empty($jdsign)) returnExit($return, 0, '读取京东模块配置失败');
$thisStartTime=date("Y年m月d日H时",strtotime($progressTime));
$count=0;
//【每次同步小时数循环获取订单】
for ($i=0; $i<$hour; $i++) {
if($i>0) $progressTime=date('Y-m-d H:i:s', strtotime ("-1 hours", strtotime($progressTime)));//计算进度时间
$orderTime=date("YmdH",strtotime($progressTime));//计算要同步的订单时间(格式:年月日时,例如:2018080808)
/*获取京东订单并入库开始*/
//【通过API接口获取订单数据】
$page=1;
$res=getkhorder($jdsign['access_token'],$jdset['unionid'],$orderTime,$jdset['appkey'],$jdset['appsecret'],$page);
//【判断是否获取到数据】
if(!empty($res)){
foreach($res as $k=>$v){
$data=array(
'weid'=>$_W['uniacid'],
'finishTime'=>substr($v['finishTime'] , 0 , 10),
'orderEmt'=>$v['orderEmt'],
'orderId'=>$v['orderId'],
'orderTime'=>substr($v['orderTime'] , 0 , 10),
'parentId'=>$v['parentId'],
'payMonth'=>$v['payMonth'],
'plus'=>$v['plus'],
'popId'=>$v['popId'],
'actualCommission'=>$v['skuList'][0]['actualCommission'],
'actualCosPrice'=>$v['skuList'][0]['actualCosPrice'],
'actualFee'=>$v['skuList'][0]['actualFee'],
'commissionRate'=>$v['skuList'][0]['commissionRate'],
'estimateCommission'=>$v['skuList'][0]['estimateCommission'],
'estimateCosPrice'=>$v['skuList'][0]['estimateCosPrice'],
'estimateFee'=>$v['skuList'][0]['estimateFee'],
'finalRate'=>$v['skuList'][0]['finalRate'],
'firstLevel'=>$v['skuList'][0]['firstLevel'],
'frozenSkuNum'=>$v['skuList'][0]['frozenSkuNum'],
'payPrice'=>$v['skuList'][0]['payPrice'],
'pid'=>$v['skuList'][0]['pid'],
'price'=>$v['skuList'][0]['price'],
'secondLevel'=>$v['skuList'][0]['secondLevel'],
'siteId'=>$v['skuList'][0]['siteId'],
'skuId'=>$v['skuList'][0]['skuId'],
'skuName'=>$v['skuList'][0]['skuName'],
'skuNum'=>$v['skuList'][0]['skuNum'],
'skuReturnNum'=>$v['skuList'][0]['skuReturnNum'],
'spId'=>$v['skuList'][0]['spId'],
'subSideRate'=>$v['skuList'][0]['subSideRate'],
'subUnionId'=>$v['skuList'][0]['subUnionId'],
'subsidyRate'=>$v['skuList'][0]['subsidyRate'],
'thirdLevel'=>$v['skuList'][0]['thirdLevel'],
'traceType'=>$v['skuList'][0]['traceType'],
'unionAlias'=>$v['skuList'][0]['unionAlias'],
'unionTrafficGroup'=>$v['skuList'][0]['unionTrafficGroup'],
'unionTag'=>$v['skuList'][0]['unionTag'],
'validCode'=>$v['skuList'][0]['validCode'],
'unionId'=>$v['unionId'],
'unionUserName'=>$v['unionUserName'],
'createtime'=>time()
);
//print_r($data);
//exit;
/*订单入库开始*/
$ord=pdo_fetchall ( 'select * from ' . tablename ( $this->modulename . "_jdorder" ) . " where weid='{$_W['uniacid']}' and orderId='{$v['orderId']}'" );
if(empty($ord)){
if(!empty($data['orderId'])){
//插入数据
$a=pdo_insert ($this->modulename . "_jdorder", $data );
$count++;
}
}else{
if(!empty($v['orderId'])){
//更新数据
$b=pdo_update($this->modulename . "_jdorder",$data, array ('orderId' =>$v['orderId'],'weid'=>$_W['uniacid']));
$count++;
}
}
/*订单入库结束*/
}
}
/*获取京东订单并入库结束*/
$progress++;//进度加1
}
$thisEndTime=date("Y年m月d日H时",strtotime($progressTime));
//计算同步进度百分比
$percent=round(($progress/$allHour)*100,2);
if($percent>100) $percent=100;
//计算本轮同步成功的总数
$allcount+=$count;
//判断是否同步完成所有任务
if($progress<$allHour){
$message=($count>0)? "成功同步".$count."个京东订单(进度:".$percent."% 时间段:".$thisStartTime."-".$thisEndTime.")" : "同步京东订单成功(进度:".$percent."% 时间段:".$thisStartTime."-".$thisEndTime.")";
$return['timetaskdata'] = array('param' => 'progress=' . $progress.'&allcount='.$allcount, 'sleep' => $sleep);//返回回传参数
}else{
$message=$startTime."到".$endTime."共".$day."天的京东订单同步完毕，累计获取".$allcount."个订单!";
}
returnExit($return, 1, $message);
/****************京东订单同步结束****************/
}
//【拼多多订单同步】
elseif ($op == "pddorder") {
/****************拼多多订单同步开始****************/
//【接收参数】
$start = empty($_GPC['start']) ? 0 : trim($_GPC['start']);//开始天数(默认为0，即从当天开始)
$day = empty($_GPC['day']) ? 1 : trim($_GPC['day']);//要同步的天数(默认同步1天)
$page=empty($_GPC['page']) ? 1 : trim($_GPC['page']);//同步页码进度参数(默认从1开始，程序自动处理，请勿手工传入此参数)
$allcount=empty($_GPC['allcount']) ? 0 : trim($_GPC['allcount']);//记录获取订单总数的参数(默认从0开始，程序自动处理，请勿手工传入此参数)
$sleep=empty($_GPC['sleep']) ? 1 : trim($_GPC['sleep']);//执行完当前页后执行下一页的间隔时间
//【计算相关时间】
$startTime=date("Y-m-d H:i:s",strtotime("-".$start." day"));//计算开始时间
$endTime=date("Y-m-d H:i:s",strtotime("-".$day." day", strtotime($startTime)));//计算结束时间(strtotime可以接受第二个参数，类型timestamp,为指定日期)
//echo '开始时间：'.$startTime.' 结束时间：'.$endTime;
//exit;
//【引用拼多多api文件】
$pddsdkfilename=IA_ROOT . "/addons/tiger_newhu/inc/sdk/tbk/pdd.php";
if (file_exists($pddsdkfilename) == false) returnExit($return, 0, '你的淘客系统缺少:'.$jdsdkfilename.'文件');//判断文件是否存在
include $pddsdkfilename;
//【读取拼多多相关配置】
$pddset=pdo_fetch("select * from ".tablename('tuike_pdd_set')." where weid='{$_W['uniacid']}'");
$owner_name=$pddset['ddjbbuid'];
if(empty($pddset)) returnExit($return, 0, '读取拼多多模块配置失败');
$count=0;
//【通过API接口获取订单数据】
$start_time=strtotime($endTime);
$end_time=strtotime($startTime);
$res=pddtgworder1($owner_name,$page,$start_time,$end_time,$p_id);
//判断是否出错
if(!empty($orderlist['error_response']['error_msg'])){
returnExit($return, 1, $orderlist['error_response']['error_msg']);
}
$orderlist=$res['order_list_get_response']['order_list'];
//遍历获取到的数据
foreach($orderlist as $k=>$v){
$row = pdo_fetch("SELECT * FROM " . tablename($this->modulename.'_pddorder') . " WHERE weid='{$_W['uniacid']}' and order_sn='{$v['order_sn']}'");
$data=array(
"weid"=>$_W['uniacid'],
"order_sn" =>$v['order_sn'],
"goods_id" => $v['goods_id'],
"goods_name" => $v['goods_name'],
"goods_thumbnail_url" => $v['goods_thumbnail_url'],
"goods_quantity" => $v['goods_quantity'],
"goods_price" => $v['goods_price']/100,
"order_amount" => $v['order_amount']/100,
"order_create_time" => $v['order_create_time'],
"order_settle_time" => $v['order_settle_time'],
"order_verify_time" => $v['order_verify_time'],
"order_receive_time" => $v['order_receive_time'],
"order_pay_time" => $v['order_pay_time'],
"promotion_rate" => $v['promotion_rate']/10,
"promotion_amount" => $v['promotion_amount']/100,
"batch_no" => $v['batch_no'],
"order_status" =>$v['order_status'],
"order_status_desc" => $v['order_status_desc'],
"verify_time" => $v['verify_time'],
"order_group_success_time" => $v['order_group_success_time'],
"order_modify_at" => $v['order_modify_at'],
"status" => $v['status'],
"type" => $v['type'],
"group_id" => $v['group_id'],
"auth_duo_id" => $v['auth_duo_id'],
"custom_parameters" => $v['custom_parameters'],
"p_id" => $v['p_id'],
'createtime'=>TIMESTAMP,//最后修改时间
);
if (!empty($row)){
pdo_update($this->modulename."_pddorder", $data, array('order_sn' => $v['order_sn'],'weid'=>$_W['uniacid']));
//echo "更新订单：".$data['order_sn']."成功<br>";
}else{
pdo_insert($this->modulename."_pddorder", $data);
//echo "新订单入库：".$data['order_sn']."成功<br>";
}
$count++;
}
//计算本轮同步成功的总数
$allcount+=$count;
//判断是否获取完毕
if(!empty($orderlist)){
$message=($count>0)? "同步拼多多第".$page."页订单成功(本次获取".$count."个)" : "同步拼多多第".$page."页订单成功!";
$return['timetaskdata'] = array('param' => 'page=' . ($page+1).'&allcount='.$allcount, 'sleep' => $sleep);//返回回传参数
}else{
$message=$startTime."到".$endTime."共".$day."天的拼多多订单同步完毕，累计获取".$allcount."个订单!";
}
//输出结果并退出程序
returnExit($return, 1, $message);
/****************拼多多订单同步结束****************/
}
//【同步老虎新版代理中心三合一佣金】
elseif ($op == "newagent3") {
/****************同步老虎新版代理中心三合一佣金开始****************/
$page = max(1, intval($_GPC['page']));//获取页码参数
$taskid=max(1, intval($_GPC['taskid']));//获取任务子id参数参数
$allcount=empty($_GPC['allcount']) ? 0 : trim($_GPC['allcount']);//记录获取订单总数的参数(默认从0开始，程序自动处理，请勿手工传入此参数)
$sleep=empty($_GPC['sleep']) ? 2 : trim($_GPC['sleep']);//执行完当前页后执行下一页的间隔时间
$pagesize = 1;//每页显示1条
$total = pdo_fetchcolumn("SELECT COUNT(*) FROM " . tablename("tiger_newhu_share")." where weid='{$_W['uniacid']}' and dltype=1");//读取代理总数
$allpage=ceil($total/$pagesize)+1;//计算总页数
//读取当前页的代理数据
$data = pdo_fetch("select id from ".tablename("tiger_newhu_share")." where weid='{$_W['uniacid']}' and dltype=1 order by id LIMIT " . ($page - 1) * $pagesize . ",{$pagesize}");
//判断代理ID是否为空
if (empty($data['id'])){
//结束任务
$message="累计".$total."个代理佣金更新完毕!";
//输出结果并退出程序
//returnExit($return, 1, $message);
}
$agentid=$data['id'];//代理ID
//根据任务ID配置对应的URL
$url_do="";
$url_doname="";
$url_day="";
$url_dayname="";
switch ($taskid)
{
case 1:
$url_do="tbyj";
$url_doname="淘宝";
$url_day="1";
$url_dayname="今天";
break;
case 2:
$url_do="pddyj";
$url_doname="拼多多";
$url_day="1";
$url_dayname="今天";
break;
case 3:
$url_do="jdyj";
$url_doname="京东";
$url_day="1";
$url_dayname="今天";
break;
case 4:
$url_do="tbyj";
$url_doname="淘宝";
$url_day="2";
$url_dayname="昨天";
break;
case 5:
$url_do="pddyj";
$url_doname="拼多多";
$url_day="2";
$url_dayname="昨天";
break;
case 6:
$url_do="jdyj";
$url_doname="拼多多";
$url_day="2";
$url_dayname="昨天";
break;
case 7:
$url_do="tbyj";
$url_doname="淘宝";
$url_day="3";
$url_dayname="本月";
break;
case 8:
$url_do="pddyj";
$url_doname="拼多多";
$url_day="3";
$url_dayname="本月";
break;
case 9:
$url_do="jdyj";
$url_day="3";
$url_dayname="本月";
break;
case 10:
$url_do="tbyj";
$url_doname="淘宝";
$url_day="4";
$url_dayname="上月";
break;
case 11:
$url_do="pddyj";
$url_doname="拼多多";
$url_day="4";
$url_dayname="上月";
break;
case 12:
$url_do="jdyj";
$url_doname="京东";
$url_day="4";
$url_dayname="上月";
break;
default:
$url_do="tbyj";
$url_doname="淘宝";
$url_day="1";
$url_dayname="今天";
}
$url=$_W['siteroot']."/app/index.php?i=".$_W['uniacid']."&c=entry&do=".$url_do."&m=tiger_wxdaili&uid=".$agentid."&day=".$url_day;
$url=str_replace("//","/",$url);
//$url="https://fanyi.baidu.com/";
//echo $url;
//访问任务URL
if (function_exists('curl_init')){
$returnHtml=curl_file_get_contents($url);//如果服务器支持curl,优先使用curl获取数据
}else{
$returnHtml=file_get_contents($url);
}
//读取访问结果
$returnState=true;
if (strpos($returnHtml,',"weid":') === false) {
$returnState=false;
} else {
$returnArr = json_decode($returnHtml, true);
$returnMsg=$returnArr[0];
}
//计算同步进度百分比
$percent=round((($page*12+$taskid)/($allpage*12))*100,3);
//判断是否同步完成所有任务
if($page<$allpage){
if($returnState){
$message="更新成功(进度:".$percent."%,页码:".$page."/".$allpage.")".$returnMsg;
}else
{
$message="更新".$url_dayname.$url_doname."佣金失败(进度:".$percent."%,页码:".$page."/".$allpage.",代理ID:".$agentid.",请求URL:".$url.")";
}
$taskid++;//子任务ID加1
//如果任务ID大于12(每个代理要执行12次同步任务)
if($taskid>12)
{
$taskid=1;//初始化任务ID
$page++;//页码加1
}
$return['timetaskdata'] = array('param' => 'page=' . $page.'&taskid='.$taskid, 'sleep' => $sleep);//返回回传参数
}else{
$message="累计".$total."个代理佣金更新完毕!";
}
//输出结果并退出程序
returnExit($return, 1, $message);
/****************同步老虎新版代理中心三合一佣金开始****************/
}
//【不带返回参数测试】
elseif ($op == "test1") {
//1、执行业务函数
//2、返回结果
returnExit($return, 1, '定时任务测试1执行成功');
}
//【带传入参数、带回传参数测试】
elseif ($op == 'test2') {
//1、【接收参数】
$day = empty($_GPC['day']) ? 1 : $_GPC['day'];//接配置参数(post参数，即软件定时任务里面设置的任务参数)
$page = empty($_GPC['page']) ? 1 : $_GPC['page'];//接收页码参数(回传参数)
//2、【执行业务函数】
//3、【判断执行结果，并构造回传参数】
//判断是否执行到最后一页（我这里假设最多只有10页，具体情况根据业务代码判断是否最后一页）
if ($page >= 10) {
//执行到最后一页，不回传参数即可
$message = '本轮所有任务执行完毕';//返回信息
} else {
$page++;//页码加1
//追加回传参数 param 为下次要回传的参数字段，支持任意参数构造(命名注意不要和系统已有的post参数冲突)； sleep 是控制访问下一页的间隔时间参数，单位为秒
$return['timetaskdata'] = array('param' => 'test1=111&test2=222&page=' . $page, 'sleep' => 1);//构造回传参数(test1=111&test2=222 为其他测试参数，可以删除)
$message = '传入的day参数值为:' . $day . ',回传的page参数为：' . $page;//返回信息
}
//3、【返回结果】
returnExit($return, 1, $message);
} else {
returnExit($return, 0, '任务标识不正确');
}
}
else
{
returnExit($return,0,'未传入有效API参数');//code值设置为1，表示成功
}
// +----------------------------------------
// | 订单入库相关函数
// +----------------------------------------
//格式化订单数据
function orderFormat($data,$field){
global $_W;
//将数据存储到符合当前系统的新数组
$newData=array(
'weid'=>$_W['uniacid'],
'addtime'=>strtotime($data['创建时间']),//创建时间
'orderid'=>$data['订单编号'],//订单编号
'numid'=>$data['商品ID'],//商品ID
'shopname'=>$data['所属店铺'],//店铺名称
'title'=>$data['商品信息'],//商品标题
'orderzt'=>$data['订单状态'],//订单状态
'srbl'=>$data['收入比率'],//收入比例
'fcbl'=>$data['分成比率'],//分成比例
'fkprice'=>$data['付款金额'],//付款金额
'xgyg'=>$data['效果预估'],//效果预估
'jstime'=>strtotime($data['结算时间']),//结算时间
'pt'=>$data['成交平台'],//平台
'mtid'=>$data['来源媒体ID'],//媒体ID
'mttitle'=>$data['来源媒体名称'],//媒体名称
//'tgwid'=>$data['广告位ID'],//推广位ID
//'tgwtitle'=>$data['广告位名称'],//推广位名称
'relation_id'=>$data['渠道关系ID'],//渠道ID
'tbsbuid6'=>substr($data['订单编号'],-6),//订单后6位
'createtime'=>TIMESTAMP,
);
//过滤空推广位数据
if(!empty($data['广告位ID'])) $newData['tgwid']=$data['广告位ID'];
if(!empty($data['广告位名称'])) $newData['tgwtitle']=$data['广告位名称'];
//处理维权订单
if(strpos($data['维权状态'],"维权创建") !== false || strpos($data['维权状态'],"等待处理") !== false) {
$newData['orderzt']='订单付款';//强制将订单状态设置为：订单付款
$newData['wq']=1;//标记为维权
}
elseif(strpos($data['维权状态'],"维权成功") !== false) {
$newData['orderzt']='订单失效';//强制将订单状态设置为：订单失效
$newData['wq']=1;//标记为维权
}
elseif(strpos($str,"维权失败") !== false) {
//$data['订单状态']='订单结算';//强制将订单状态设置为：订单结算(因为订单也有可能本身是其他状态，所以此处不做处理即可)
$newData['wq']=0;//取消维权状态
}
//过滤数据库不支持的字段(因为各个版本的数据库字段有差异，所以要处理下)
foreach($newData as $key=>$value){
if(isset($field[$key]))
{
$saveData[$key]=$value;
}
}
return $saveData;
}
//将订单表orderid索引改为普通索引
function orderIndex($table){
$allIndex=pdo_fetchall("show index from".$table);
//print_r($allIndex);
foreach($allIndex as $index){
//判断orderid是否唯一索引
if($index['Key_name']=='orderid' && $index['Non_unique']==0){
//将索引修改为普通索引
$ree=pdo_query("ALTER TABLE ".$table." DROP INDEX `orderid`, ADD INDEX `orderid` (`weid`, `orderid`, `numid`) USING BTREE;");
//echo '修改索引';
return;
}
}
//echo '未修改索引';
}
// +----------------------------------------
// | 淘宝商品采集相关函数
// +----------------------------------------
//处理商品分类
function goodsCat($table,$softCat){
global $_W;
//查询数据库的分类名和对应ID
$allCat=pdo_fetchall('select title,id from '.$table." where weid='{$_W['uniacid']}'");
//print_r($allCat);
foreach($allCat as $cat){
$cat['title']=str_replace("其他","其它",$cat['title']);//兼容分类名字为“其他”时的情况
$dbCat[$cat['title']]=$cat['id'];
}
//将程序商品分类关系转化成对应的id
foreach($softCat as $key=>$value){
$value=str_replace("其他","其它",$value);//兼容分类名字为“其他”时的情况
if (isset($dbCat[$value])) $newCat[$key]=$dbCat[$value];
}
//print_r($softCat);
return $newCat;
}
//格式化商品数据
function goodsFormat($cat,$data,$field){
global $_W;
//处理采集来源
if($data['采集来源']=='大淘客'){
$data['采集来源']=1;
}elseif($data['采集来源']=='好单库'){
$data['采集来源']=2;
}elseif($data['采集来源']=='轻淘客'){
$data['采集来源']=4;
}elseif($data['采集来源']=='一手单'){
$data['采集来源']=5;
}elseif($data['采集来源']=='QQ群'){
$data['采集来源']=8;
}
//处理商品类目
if (empty($cat[$data['商品类目']])){
$data['商品类目']=0;
}else{
$data['商品类目']=$cat[$data['商品类目']];
}
$newData=array(
'weid'=>$_W['uniacid'],//公众号ID
'zy'=>$data['采集来源'],//1大淘客 2互力 3鹊桥库
'itemid'=>$data['商品ID'],//商品id
'itemtitle'=>$data['商品标题'],//商品标题
'itemshorttitle'=>$data['商品短标题'],//商品短标题
'itemdesc'=>$data['商品文案'],//商品文案
'itemprice'=>$data['商品原价'],//商品原价
'itemsale'=>$data['商品销量'],//商品销量
'itemsale2'=>$data['商品两小时销量'],//商品最近2小时销量
//'conversion_ratio'=>$data[''],//优惠券转化率
'itempic'=>$data['商品图片'],//商品主图
'fqcat'=>$data['商品类目'],//商品类目
'itemendprice'=>$data['商品券后价'],//商品券后价
'shoptype'=>$data['店铺类型'],//店铺类型 天猫(B) C店(C) 企业店铺
'userid'=>$data['卖家ID'],//卖家ID
'sellernick'=>$data['卖家昵称'],//卖家昵称
'tktype'=>$data['佣金计划'],//佣金方式(鹊桥活动 定向计划 通用计划 隐藏计划 营销计划）
'tkrates'=>$data['佣金比例'],//佣金比例
//'ctrates'=>$data[''],//村淘佣金比例
'cuntao'=>$data['是否村淘'],//是否村淘（1是）
'tkmoney'=>$data['预计佣金'],//预计可得(宝贝价格*佣金比率/100)
'tkurl'=>$data['定向计划链接'],//定向计划链接
'planlink'=>$data['营销计划链接'],//营销计划链接
'quan_id'=>$data['优惠券ID'],//优惠券ID
'couponurl'=>$data['优惠券链接'],//优惠券链接
'couponmoney'=>$data['优惠券金额'],//优惠券面额
'couponsurplus'=>$data['优惠券剩余量'],//优惠券剩余数量
'couponreceive'=>$data['优惠券领取量'],//优惠券领取数量
//'couponreceive2'=>$data[''],//2小时内优惠券领取量
'couponnum'=>$data['优惠券总数量'],//优惠券总数量
'couponexplain'=>$data['优惠券使用条件'],//优惠券说明 使用条件
'couponstarttime'=>$data['优惠券开始时间'],//优惠券开始时间
'couponendtime'=>$data['优惠券结束时间'],//优惠券结束时间
'starttime'=>$data['最后修改时间'],//发布时间
'isquality'=>$data['是否优选'],//是否优选 1为是
'item_status'=>$data['失效状态'],//产品状态：0为正常
//'report_status'=>$data[''],//举报处理情况(1为待处理；2为忽略；3为下架)
'is_brand'=>$data['是否品牌商品'],//是否为品牌产品：1为是
'is_live'=>$data['是否直播商品'],//是否为直播产品：1为是
'videoid'=>$data['商品视频ID'],//商品视频id
'activity_type'=>$data['活动类型'],//活动类型（普通活动、聚划算、淘抢购）
'createtime'=>TIMESTAMP,//最后修改时间
//'tj'=>$data[''],//1 秒杀 2 叮咚抢
//'zt'=>$data[''],//专题
//'test8888'=>'66666666',//干扰测试
//'zd'=>$data[''],//0不置顶 1置顶
//'qf'=>$data[''],//0不群发 1群发库
);
//过滤数据库不支持的字段(因为各个版本的数据库字段有差异，所以要处理下)
foreach($newData as $key=>$value){
if(isset($field[$key]))
{
$saveData[$key]=$value;
}
}
return $saveData;
}
// +----------------------------------------
// | 【拼多多】相关函数
// +----------------------------------------
//格式化拼多多订单数据
function orderFormatPdd($data)
{
global $_W;
//确保uid值不小于0
//if($data['customParameters'] < 0) $data['customParameters']=0;
//去除佣金比例中的百分号
$data['佣金比例']=str_replace("%", "", $data['佣金比例']);
$newData=array(
"weid"=>$_W['uniacid'],
"order_sn" =>$data['订单编号'],
"goods_id" => $data['商品ID'],
"goods_name" => trimExcessChar($data['商品信息']),
"goods_thumbnail_url" => $data['商品图片'],
"goods_quantity" => $data['商品数'],
"goods_price" => $data['商品价格'],
"order_amount" => $data['订单金额'],
"order_create_time" => strtotime($data['创建时间']),
"order_settle_time" => strtotime($data['结算时间']),
"order_verify_time" => strtotime($data['审核时间']),
"order_receive_time" => strtotime($data['收货时间']),
"order_pay_time" => strtotime($data['支付时间']),
"promotion_rate" => str_replace("%", "", $data['佣金比例']),
"promotion_amount" => $data['预估佣金收入'],
"batch_no" => $data['batchNo'],
"order_status" => $data['订单状态ID'],
"order_status_desc" => $data['订单状态描述'],
"verify_time" => strtotime($data['审核时间']),
"order_group_success_time" => strtotime($data['拼团成功时间']),
"order_modify_at" => strtotime($data['最后更新时间']),
//"status" => $v['status'],
"type" => $data['推广方式ID'],
"group_id" => $data['groupId'],
"auth_duo_id" => $data['duoId'],
"custom_parameters" => $data['customParameters'],
"p_id" => $data['pid'],
'createtime'=>TIMESTAMP,//最后修改时间
);
return $newData;
}
// +----------------------------------------
// | 其他函数
// +----------------------------------------
//返回json信息并退出
function returnExit($return,$code,$message,$data=''){
$return['code']=$code;
$return['message']=urlencode($message);
if(!empty($data)) $return['data']=$data;
exit(urldecode(json_encode($return)));
}
//构造返回状态结果字符串
function resultState($result,$id,$v){
if (!empty($result)) $result.='|';
$result.=$id.':'.$v;
return $result;
}
//获取数据库表的所有字段
function tableField($table){
$sqlColumns=pdo_fetchall('SHOW COLUMNS FROM '.$table);//查询表的所有字段
//处理查询结果
foreach($sqlColumns as $value)
{
if(isset($value['Field']) && isset($value['Type'])){
$sqlField[$value['Field']]=$value['Type'];
}
}
return $sqlField;
}
//去除多余的字符
function trimExcessChar($str)
{
$str = trim($str);
$str = str_replace("；", "", $str);
$str = str_replace('"', "", $str);
$str = str_replace('"', "", $str);
$str = str_replace('"', "", $str);
$str = str_replace(PHP_EOL, '', $str);
return $str;
}
//使用curl获取页面内容
function curl_file_get_contents($url){
//判断是否重定向,如果重定向,就获取重定向后的真实地址
for ($i=1; $i<=10; $i++)
{
$headers = curl_file_get_headers($url);
$url=$headers["url"];
if($headers["http_code"]<>'302' and $headers["http_code"]<>'301') break;
}
//开始获取内容
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_TIMEOUT, 5);
curl_setopt($ch, CURLOPT_USERAGENT, _USERAGENT_);
curl_setopt($ch, CURLOPT_REFERER,_REFERER_);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
$data = curl_exec($ch);
curl_close($ch);
return $data;
}
//使用curl获取http头
function curl_file_get_headers($url){
$ch = curl_init();
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
$data = curl_exec($ch);
$Headers = curl_getinfo($ch);
curl_close($ch);
return $Headers;
}
```
- 最新公告
- 软件介绍
- 初次使用
- 购买授权
- 基础配置
- 接口配置
- 牛贝淘宝客系统接口配置
- 老虎淘宝客系统接口配置
- 程序侠淘宝客系统接口配置
- 好京客四合一淘客系统接口配置
- 杨他他淘宝客系统接口配置
- 唐格时创淘客系统接口配置
- 全局配置
- 第1章 淘客订单同步
- 采集方案【推荐方案】
- 订单采集(基础)
- 订单采集(工具API)
- 订单采集(渠道API)
- 订单入库
- 第2章 淘客商品采集
- 商品采集(大淘客)
- 商品采集(好单库)
- 商品采集(轻淘客)
- 商品入库
- 商品管理
- 商品分类绑定
- 老虎淘客系统分类绑定
- 牛贝淘宝客系统分类绑定
- 程序侠淘客系统分类绑定
- 第3章 拼多多
- 拼多多API设置教程
- 拼多多订单采集使用教程
- 拼多多订单入库使用教程
- 第4章 京东
- 创建查看京东APPKEY
- 京东订单采集使用教程
- 京东订单入库使用教程
- 第5章 唯品会
- 唯品会配置教程
- 唯品会订单采集使用教程
- 唯品会订单入库使用教程
- 第6章 蘑菇街
- 蘑菇街配置教程
- 蘑菇街订单采集使用教程
- 蘑菇街订单入库使用教程
- 第7章 苏宁
- 苏宁API设置教程
- 苏宁订单采集使用教程
- 苏宁订单入库使用教程
- 第8章 多麦
- 多麦API设置教程
- 多麦订单采集使用教程
- 多麦订单入库使用教程
- 第9章 高级功能
- 万能定时任务
- 【牛贝系统】万能定时任务使用说明
- 【老虎系统】代理佣金更新
- 自动审核代理
- 第10章 常见问题
- 程序无法登录
- 阿里妈妈登陆相关问题
- 阿里旺旺安装登录教程
- 阿里妈妈账号受限解决办法
- 清理服务器日志
- 120元(1年)挂机服务器购买教程
- 推广位相关问题
- 渠道相关问题
- 过期历史教程
- 阿里妈妈登陆
- 阿里妈妈登录器(Chrome版)使用教程
- 阿里妈妈登录器(Chrome版)安装教程
- 批量创建推广位
- 开发对接文档
- 18助手对接必看说明
- 18淘客助手调试模式
- 18助手接口开发规范
- 入库POST数据说明
- 淘客订单POST数据说明
- 淘客商品POST数据说明
- 京东订单POST数据说明
- 拼多多订单POST数据说明
- 苏宁订单POST数据说明
- 唯品会订单POST数据说明
- 多麦订单POST数据说明
- 接口文件示例
- PHP接口文件示例(微擎)
- PHP接口文件示例(ThinkPHP)