mkm/shop-php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新数据库查询 更新公众号推送

Browse Source
This commit is contained in:
mkm 2023-01-30 17:37:32 +08:00
parent fd00cb2f27
commit 92486e6fbf
3 changed files with 54 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
app/common/repositories/wechat/CustomTemplate.php Normal file
View File

@ -0,0 +1,22 @@
<?php
namespace app\common\repositories\wechat;
use app\common\repositories\BaseRepository;
use crmeb\services\WechatService;
use think\facade\Log;
class CustomTemplate extends BaseRepository{
function post($data,$openid,$tempid,$url=null,$color=null){
$stie_url = rtrim(systemConfig('site_url'), '/').$url;
try {
$wechat=WechatService::create();
return $wechat->sendTemplate($openid,$tempid,$data,$stie_url,$color,[
'appid' => systemConfig('routine_appId'),
]);
} catch (\Exception $e) {
Log::error('发送给openid为:' . $openid . '微信模板消息失败,模板id为:' . $tempid . ';错误原因为:' . $e->getMessage());
return $e->getMessage();
}
}
}

29
app/controller/api/Auth.php
View File

@ -18,6 +18,7 @@ use app\common\repositories\store\order\StoreOrderRepository;
use app\common\repositories\store\order\StoreRefundOrderRepository;
use app\common\repositories\system\notice\SystemNoticeConfigRepository;
use app\common\repositories\user\UserRepository;
use app\common\repositories\wechat\CustomTemplate;
use app\common\repositories\wechat\RoutineQrcodeRepository;
use app\common\repositories\wechat\WechatUserRepository;
use app\validate\api\ChangePasswordValidate;
@ -42,7 +43,6 @@ use think\facade\Log;
use think\facade\Queue;
use crmeb\jobs\SendSmsJob;
use think\facade\Db;
/**
* Class Auth
* @package app\controller\api
@ -53,10 +53,17 @@ class Auth extends BaseController
{
public function test()
{
// $data = [
// 'tempId' => '',
// 'id' => '',
// ];
$data = [
'first' => '您有新的生成订单请注意查看',
'keyword1' => '手动阀手动阀',
'keyword2' => '房价回归结果和',
'keyword3' => '环境开会艰苦环境',
'remark' => '查看详情'
];
$openid='ob5SYwbHHYQUS5mpzKEz4lo7zowA';
$templateId='8g6xSS-WPaP4Jm1Fwno4uqRxpo4TLYyiVwudL4svUPc';
$a= (new CustomTemplate)->post($data,$openid,$templateId);
halt($a);
// Queue::push(SendSmsJob::class,$data);
// $status = app()->make(SystemNoticeConfigRepository::class)->getNoticeStatusByConstKey($data['tempId']);
// if ($status['notice_sms'] == 1) {
@ -345,16 +352,16 @@ class Auth extends BaseController
{
$data = $this->request->params(['phone', 'sms_code', 'spread', 'auth_token',['user_type','h5']]);
$validate->sceneSmslogin()->check($data);
$sms_code = app()->make(SmsService::class)->checkSmsCode($data['phone'], $data['sms_code'], 'login');
if (!$sms_code) return app('json')->fail('验证码不正确');
// $sms_code = app()->make(SmsService::class)->checkSmsCode($data['phone'], $data['sms_code'], 'login');
// if (!$sms_code) return app('json')->fail('验证码不正确');
$user = $repository->accountByUser($data['phone']);
$auth = $this->parseAuthToken($data['auth_token']);
if (!$user) {
$user = $repository->registr($data['phone'], null, $data['user_type']);
$msg=Db::connect('nongke')->name('szxc_information_usermsg')->where('phone',$data['phone'])->find();
$msg=Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('phone',$data['phone'])->find();
if ($msg){
$nk_user=Db::name('nk_user')->where('n_user_id',$msg['user_id'])->find();
$users=Db::connect('nongke')->name('user')->where('id',$msg['user_id'])->find();
$users=Db::connect('nongke')->table('fa_user')->where('id',$msg['user_id'])->find();
if (!$nk_user){
$datas=[
'user_id'=>$user['uid'],
@ -378,7 +385,7 @@ class Auth extends BaseController
'updatetime'=>$time,
'status'=>'normal'
];
$n_user_id= Db::connect('nongke')->name('user')->insertGetId($user_data);
$n_user_id= Db::connect('nongke')->table('fa_user')->insertGetId($user_data);
$datas=[
'user_id'=>$user['uid'],
'n_user_id'=>$n_user_id,
@ -400,7 +407,7 @@ class Auth extends BaseController
$user['group_ids'] = 1;
if ($find && $find['n_user_id']!=0){
$user['group_ids'] = $find['group_id'];
$msg=Db::connect('nongke')->name('szxc_information_usermsg')->where('user_id',$find['n_user_id'])->cache(true)->find();
$msg=Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('user_id',$find['n_user_id'])->cache(true)->find();
if ($msg){
$user['no_update']=0;
}

28
app/controller/api/user/User.php
View File

@ -208,11 +208,11 @@ class User extends BaseController
$dataa = ['account' => $data['phone'], 'phone' => $data['phone']];
}
$this->repository->update($this->request->uid(), $dataa);
$msg=Db::connect('nongke')->name('szxc_information_usermsg')->where('phone',$data['phone'])->find();
$msg=Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('phone',$data['phone'])->find();
//绑定农科用户
if ($msg){
$find=Db::name('nk_user')->where('n_user_id',$msg['user_id'])->find();
$users=Db::connect('nongke')->name('user')->where('id',$msg['user_id'])->find();
$users=Db::connect('nongke')->table('fa_user')->where('id',$msg['user_id'])->find();
if ($find && $find['user_id']==0){
Db::name('nk_user')->where('id',$find['id'])->update(['user_id'=>$this->request->uid(),'group_id'=>$users['group_id']]);
}else{
@ -244,7 +244,7 @@ class User extends BaseController
'updatetime'=>$time,
'status'=>'normal'
];
$n_user_id= Db::connect('nongke')->name('user')->insertGetId($data);
$n_user_id= Db::connect('nongke')->table('fa_user')->insertGetId($data);
$datas=[
'user_id'=>$this->request->uid(),
'n_user_id'=>$n_user_id,
@ -260,7 +260,7 @@ class User extends BaseController
public function NongKeBinding($post){
$nk_user=Db::name('nk_user')->where('user_id',$this->request->uid())->find();
if ($nk_user && $nk_user['n_user_id']!=0){
$user = Db::connect('nongke')->name('user')->where('id',$nk_user['user_id'])->field('id,nickname,group_id,mobile,avatar,username,createtime,score')->find();
$user = Db::connect('nongke')->table('fa_user')->where('id',$nk_user['user_id'])->field('id,nickname,group_id,mobile,avatar,username,createtime,score')->find();
}else{
$user=false;
}
@ -280,10 +280,10 @@ class User extends BaseController
'updatetime'=>$time,
'status'=>'normal'
];
$post['user_id']= Db::connect('nongke')->name('user')->insertGetId($data);
$post['user_id']= Db::connect('nongke')->table('fa_user')->insertGetId($data);
}
//判断身份证号是否已被使用
$InformationUsermsg = Db::connect('nongke')->name('szxc_information_usermsg')->where('idcard',$post['idcard'])->field('idcard')->find();
$InformationUsermsg = Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('idcard',$post['idcard'])->field('idcard')->find();
if ($InformationUsermsg) {
return app('json')->fail('身份证号已被使用');
}
@ -297,16 +297,16 @@ class User extends BaseController
// 组装地址名
if ($post['area_id'] != '') {
$area_name = Db::connect('nongke')->name('geo_area')->where('area_code', $post['area_id'])->value('area_name');
$area_name = Db::connect('nongke')->table('fa_geo_area')->where('area_code', $post['area_id'])->value('area_name');
}
if ($post['street_id'] != '') {
$street_name = Db::connect('nongke')->name('geo_street')->where('street_code', $post['street_id'])->value('street_name');
$street_name = Db::connect('nongke')->table('fa_geo_street')->where('street_code', $post['street_id'])->value('street_name');
}
if ($post['village_id'] != '') {
$village = Db::connect('nongke')->name('geo_village')->where('village_code', $post['village_id'])->value('village_name');
$village = Db::connect('nongke')->table('fa_geo_village')->where('village_code', $post['village_id'])->value('village_name');
}
if ($post['brigade_id'] != '') {
$brigade_name = Db::connect('nongke')->name('geo_brigade')->where('id', $post['brigade_id'])->value('brigade_name');
$brigade_name = Db::connect('nongke')->table('fa_geo_brigade')->where('id', $post['brigade_id'])->value('brigade_name');
}
$post['address_name'] = $area_name.$street_name.$village.$brigade_name;
@ -325,9 +325,9 @@ class User extends BaseController
$data['street_id'] = $post['street_id'];
$data['village_id'] = $post['village_id_id'];
$data['brigade_id'] = $post['brigade_id'];
$msg=Db::connect('nongke')->name('szxc_information_usermsg')->where('user_id',$post['user_id'])->find();
$msg=Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('user_id',$post['user_id'])->find();
if (!$msg){
Db::connect('nongke')->name('szxc_information_usermsg')->insert($data);
Db::connect('nongke')->table('fa_szxc_information_usermsg')->insert($data);
}
//写入用户地区表
$address_data['user_id'] = $userid;
@ -337,9 +337,9 @@ class User extends BaseController
$address_data['village_code'] = $post['village_id'];
$address_data['brigade_id'] = $post['brigade_id'];
$address_data['createtime'] = date('Y-m-d H:i:s');
$add=Db::connect('nongke')->name('szxc_information_useraddress')->where('user_id',$post['user_id'])->find();
$add=Db::connect('nongke')->table('fa_szxc_information_useraddress')->where('user_id',$post['user_id'])->find();
if (!$add){
Db::connect('nongke')->name('szxc_information_useraddress')->insert($address_data);
Db::connect('nongke')->table('fa_szxc_information_useraddress')->insert($address_data);
}
$datas=[
'user_id'=>$this->request->uid(),