客户线索重复检查

# Conflicts:
#	app/controller/UserController.php
#	config/constants/Constants.php

.env.example

@@ -16,4 +16,7 @@ JWT_SECRET_KEY = 'Hj3$kLm8NpQrStUvXwZ1y2C4D6E8G'
 JWT_ALGORITHM = 'HS256'
 JWT_EXPIRATION = 2592000
 
-WEBMAN_LISTEN = 'http://0.0.0.0:9007'
+WEBMAN_LISTEN = 'http://0.0.0.0:9007'
+WEBMAN_COUNT = 8
+
+RPC_DOMAIN = http://219.157.255.213:25015

.idea/www.iml

@@ -1,20 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<module type="WEB_MODULE" version="4">
-  <component name="NewModuleRootManager">
-    <content url="file://$MODULE_DIR$">
-      <sourceFolder url="file://$MODULE_DIR$/webman/." isTestSource="false" />
-      <sourceFolder url="file://$MODULE_DIR$/webman/./app" isTestSource="false" packagePrefix="app\" />
-      <sourceFolder url="file://$MODULE_DIR$/webman/./app/view/components" isTestSource="false" packagePrefix="app\View\Components\" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/composer" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/monolog/monolog" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/nikic/fast-route" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/psr/container" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/psr/log" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/workerman/coroutine" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/workerman/webman-framework" />
-      <excludeFolder url="file://$MODULE_DIR$/webman/vendor/workerman/workerman" />
-    </content>
-    <orderEntry type="inheritedJdk" />
-    <orderEntry type="sourceFolder" forTests="false" />
-  </component>
-</module>

app/controller/AreaController.php

@@ -4,7 +4,11 @@ namespace app\controller;
 
 use app\model\Area;
 use app\model\Country;
+use app\util\HttpClient;
+use app\util\RedisHelper;
 use app\util\Util;
+use support\Log;
+use support\Redis;
 use support\Request;
 
 class AreaController
@@ -41,14 +45,29 @@ class AreaController
 
     public function getCountry (Request $request)
     {
+        $list = RedisHelper::get("rpc_country");
+        $list = null;
+//        if(!$list){
+//            $res = HttpClient::get(config('const.rpc_domain') . '/country/all');
+//            if ($res['code'] != 200 && $res['data']['code'] != 0){
+//                Log::info('register_rpc',$res);
+//                return Util::fail($res, trans('register_fail'));
+//            }
+//            $list = $res['data']['data']['data'];
+//            RedisHelper::set("rpc_country", $list, 600);
+//        }
+
         $list = Country::get()->toArray();
-        $language = 'en_addr';
-        if($request->user['language'] == 'zh_CN'){
-            $language = 'cn_addr';
+        $name = 'en_addr';
+        //$language = $request->user['language'];
+        //$language = 'zh_CN';
+        $language = $request->language;
+        if($language == 'zh_CN'){
+            $name = 'cn_addr';
         }
 
         foreach ($list as &$row) {
-            $row['name'] = $row[$language];
+            $row['name'] = $row[$name];
         }
         return Util::success($list);
     }

app/controller/CarTypeController.php

@@ -17,10 +17,17 @@ class CarTypeController
     {
         $list = CarType::getAll();
 
-        if($request->user['language'] != 'zh_CN'){
-            foreach ($list as $key => &$value) {
+        //$language = $request->user['language'];
+        //$language = 'zh_CN';
+        $language = $request->language;
+        if($language == 'en'){
+            foreach ($list as &$value) {
                 $value['name'] = $value['name_en'];
             }
+        }elseif ($language == 'ru'){
+            foreach ($list as &$value) {
+                $value['name'] = $value['name_ru'];
+            }
         }
 
         return Util::success($list);

app/controller/CustomerController.php

@@ -3,11 +3,16 @@
 namespace app\controller;
 
 use app\model\Channel;
+use app\model\Corp;
 use app\model\Customer;
+use app\model\CustomerHis;
 use app\model\Follow;
+use app\model\InquiryLog;
+use app\model\User;
 use app\service\UserService;
 use app\util\Util;
 use config\constants\Constants;
+use Illuminate\Database\Eloquent\Builder;
 use support\Log;
 use support\Request;
 
@@ -29,8 +34,14 @@ class CustomerController
     {
         $grade = [];
         $gradeConstants = Constants::GRADE_EN;
-        if($request->user['language'] == 'zh_CN'){
+
+        //$language = $request->user['language'];
+        //$language = 'zh_CN';
+        $language = $request->language;
+        if($language == 'zh_CN'){
             $gradeConstants = Constants::GRADE;
+        }elseif ($language == 'ru'){
+            $gradeConstants = Constants::GRADE_RU;
         }
         foreach ($gradeConstants as $key => $value) {
             $grade[] = [
@@ -50,8 +61,13 @@ class CustomerController
     {
         $grade = [];
         $magnitudeConstants = Constants::MAGNITUDE_EN;
-        if($request->user['language'] == 'zh_CN'){
+        //$language = $request->user['language'];
+        //$language = 'zh_CN';
+        $language = $request->language;
+        if($language == 'zh_CN'){
             $magnitudeConstants = Constants::MAGNITUDE;
+        }elseif ($language == 'ru'){
+            $magnitudeConstants = Constants::MAGNITUDE_RU;
         }
         foreach ($magnitudeConstants as $key => $value) {
             $grade[] = [
@@ -71,11 +87,18 @@ class CustomerController
     {
         $list = Channel::getAll();
 
-        if($request->user['language'] != 'zh_CN'){
-            foreach ($list as $key => &$value) {
-                $value['name'] = $value['name_en'];
-            }
-        }
+        //$language = $request->user['language'];
+        //$language = 'zh_CN';
+//        $language = $request->language;
+//        if($language != 'zh_CN'){
+//            foreach ($list as &$value) {
+//                $value['name'] = $value['name_en'];
+//            }
+//        }elseif ($language == 'ru'){
+//            foreach ($list as &$value) {
+//                $value['name'] = $value['name_ru'];
+//            }
+//        }
 
         return Util::success($list);
 
@@ -129,6 +152,9 @@ class CustomerController
         $follow = $request->input('follow', ''); //跟进状态
         $keyword = $request->input('keyword', ''); //follow_last
         $follow_last = $request->input('follow_last', ''); //最后跟进：1:当天跟进客户，2:近三天跟进客户，3:近七天跟进客户
+        $tagId = $request->input('tag_id', ''); //打有某个标签的客户
+        $countryId = $request->input('country_id', ''); //打有某个标签的客户
+        $seas = $request->input('seas', ''); //公海客户
 
         $where = [];
 
@@ -136,7 +162,16 @@ class CustomerController
         if (Util::isEmpty($userId)) {
             return Util::fail(['user_id' => $userId], trans('user_none'));
         }
-        $where[] = ['user_id', $userId];
+//        $where[] = ['type', 0];
+        if($seas == 'seas'){
+            $where[] = ['user_id', 0];
+        }else{
+            $where[] = ['user_id', $userId];
+        }
+        $where[] = ['status', 1];
+        if (!empty($countryId)){
+            $where[] = ['country_id', $countryId];
+        }
         //验证权限
 //        if ($request->user['role'] != 1) {
 //            $where[] =['user_id',$userId] ;
@@ -160,29 +195,59 @@ class CustomerController
 
 
         // 执行分页查询  //关联标签tags //关联标签及分组tags.group
-        $query = Customer::where($where)
-            ->orderBy('id', 'desc');
+        $query = Customer::with('tags')->where($where)
+            ->orderBy('crm_customer.id', 'desc');
+        if(!empty($tagId)){
+            //查询有$tagId 里任意一个标签的客户
+//            $query->whereHas('tags', function($query) use ($tagId){
+//                $query->where('tag.id', $tagId);
+//            });
+
+            //查询有$tagId 里所有标签的客户
+            $tagId = explode(',', $tagId);
+            foreach ($tagId as $id) {
+                $query->whereHas('tags', function($query) use ($id){
+                    $query->where('tag_id', $id);
+                });
+            }
+        }
         if (!Util::isEmpty($keyword)) {
             $query->where(function ($query) use ($keyword) {
                 $query->where('contacts', 'like', "%{$keyword}%")
                     ->orWhere('phone', 'like', "%{$keyword}%");
             });
-
         }
         if (!Util::isEmpty($grade)) {
             $query->whereIn('grade', $grade);
-
         }
 
         $recycle = Util::getParam($request,'recycle', '');
         if ($recycle == 'recycle') {
             $query->onlyTrashed();
         }
+        if ($seas == 'seas') {
+            $user = User::where('id', $userId)->first();
+            $corpId = $user?$user->corp_id:0;
+            if($corpId == 1){
+                $query->whereIn('channel_id', [1,2,3,4,5,6,7,8]);
+            } elseif($corpId == 3) {
+                $query->whereIn('channel_id', [9,10,11]);
+            } else{
+                $query->whereIn('channel_id', [0]);
+            }
+            $query->withTrashed();
+        }
 
         $data = $query->paginate($perPage, ['*'], 'page', $page);
 
         foreach ($data->items() as &$value) {
             $value = Customer::getCustomer($value, $request);
+            if($seas == 'seas'){
+                $value['phone'] = Util::mask($value['phone']);
+                $value['email'] = Util::mask($value['email']);
+                $value['WhatsApp'] = Util::mask($value['WhatsApp']);
+                $value['seas_time'] = time()-(empty($value['deleted_at'])?strtotime($value['updated_at']):strtotime($value['deleted_at']));
+            }
         }
 
         return Util::page($data);
@@ -255,10 +320,10 @@ class CustomerController
         if (Util::isEmpty($country_id)) {
 //            return Util::fail([],'country_id'.trans('not_null'));
         }
-        $car_type_id = Util::getParam($request, 'car_type_id');
-        if (Util::isEmpty($car_type_id)) {
-            return Util::fail([], trans('car_type_not_null'));
-        }
+//        $car_type_id = Util::getParam($request, 'car_type_id');
+//        if (Util::isEmpty($car_type_id)) {
+//            return Util::fail([], trans('car_type_not_null'));
+//        }
         $contacts = Util::getParam($request, 'contacts');
         $email = Util::getParam($request, 'email');
         $phone = Util::getParam($request, 'phone');
@@ -266,16 +331,19 @@ class CustomerController
             return Util::fail([], trans('contacts_not_null'));
         }
 
+        $user = User::where(['id' => $request->user['id']])->first();
+        $whatsApp = Util::getParam($request, 'WhatsApp', '');
         $data = [
             'user_id' => $request->user['id'],
+            'corp_id' => $user->corp_id,
             'grade' => Util::getParam($request, 'grade', 0),
             'channel_id' => $channel_id,
             'country_id' => $country_id,
-            'car_type_id' => $car_type_id,
+//            'car_type_id' => $car_type_id,
             'magnitude' => Util::getParam($request, 'magnitude', 0),
             'email' => $email,
             'phone' => $phone,
-            'WhatsApp' => Util::getParam($request, 'WhatsApp', ''),
+            'WhatsApp' => $whatsApp,
             'contacts' => $contacts,
             'describe' => Util::getParam($request, 'describe'),
             'lat' => Util::getParam($request, 'lat', 0),
@@ -285,6 +353,16 @@ class CustomerController
         ];
 
         if (Util::isEmpty($id)) {
+            $data['enter_user_id'] = $request->user->uid;
+            $distinct = [
+                'email' => $email,
+                'phone' => $phone,
+                'whatsapp' => $whatsApp,
+            ];
+            $dis = $this->distinct($distinct, $user->corp_id);
+            if($dis){
+                return Util::fail([], '客户线索重复，已经有人在跟进');
+            }
             $res = Customer::create($data);
         } else {
             unset($data['grade']);
@@ -301,6 +379,148 @@ class CustomerController
         }
     }
 
+
+    public function distinct($params, $corpId){
+
+        $customer = Customer::where('corp_id', $corpId)
+            ->where((function (Builder $query) use ($params) {
+                if(!empty($params['email']))
+                    $query->Orwhere('email', '=', $params['email']);
+                if(!empty($params['phone']))
+                    $query->Orwhere('phone', '=', $params['phone']);
+                if(!empty($params['whatsApp']))
+                    $query->Orwhere('whatsApp', '=', $params['whatsApp']);
+                return $query;
+            }))
+            ->first();
+        if (!empty($customer)) {
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * 领取公海客户
+     * @param Request $request
+     * @return \support\Response
+     */
+    public function claim(Request $request)
+    {
+        $customerId = Util::getParam($request, 'customer_id');
+        $userId = $request->user['id'];
+        if (Util::isEmpty($customerId)) {
+            return Util::fail([], trans('customer_id').trans('not_null'));
+        }
+        $user = User::where(['id' => $userId])->first();
+        $data = [
+            'user_id' => $request->user['id'],
+            'obtain' => time(),
+            'corp_id' => $user->corp_id,
+        ];
+        $customer= Customer::withTrashed()->find($customerId);
+
+        if(empty($customer) || $customer->user_id != 0){
+            return Util::fail('', trans('claim_fail'));
+        }
+
+        $customer->restore();
+        $res = $customer->update($data);
+
+        //记录客户关系变化
+        $his = CustomerHis::create([
+            'customer_id' => $customerId,
+            'user_his' => 0,
+            'user_id' => $userId,
+        ]);
+        self::inquiryUpdate($customer,$request->user['id']);
+
+        if ($res) {
+            return Util::success($res, trans('success'));
+        } else {
+            return Util::fail($res, trans('fail'));
+        }
+    }
+
+
+    /**
+     * 询单修改
+     */
+    public static function inquiryUpdate($customer,$userId = null)
+    {
+        if(empty($customer->sn) || $customer->type!=1){
+            return false;
+        }
+
+        $inquiryLog = InquiryLog::where('order_no', $customer->sn)->first();
+        if(empty($inquiryLog)){
+            return false;
+        }
+        $userId = $userId??$customer->user_id;
+
+        if ($userId == 0){
+            $inquiryLog->recipient = 0;
+            $inquiryLog->t_time = time();
+            $inquiryLog->status = 1;
+            $inquiryLog->r_time = time();
+            $inquiryLog->save();
+        }else {
+            $inquiryLog->recipient = $customer->user_id;
+            $inquiryLog->t_time = time();
+            $inquiryLog->save();
+        }
+        return true;
+    }
+
+
+    /**
+     * 批量转让
+     * @param Request $request
+     * @return \support\Response
+     */
+    public function cede(Request $request)
+    {
+        $customerId = Util::getParam($request, 'customer_id');
+        $userId = Util::getParam($request, 'user_id');
+        $selfId = $request->user['id'];
+        if (Util::isEmpty($userId)) {
+            return Util::fail([], 'user_id'.trans('not_null'));
+        }
+        if (Util::isEmpty($customerId)) {
+            return Util::fail([], 'customer_id'.trans('not_null'));
+        }
+
+        $user = User::where(['id' => $userId])->first();
+        if (Util::isEmpty($user)) {
+            return Util::fail(null, trans('user_none'));
+        }
+
+        $query= Customer::where('user_id',$selfId)->where('id',$customerId);
+        $customer = $query->get();
+
+        foreach ($customer as $item) {
+            //记录客户关系变化
+            $his = CustomerHis::create([
+                'customer_id' => $item->id,
+                'user_his' => $item->user_id,
+                'user_id' => $user['id'],
+            ]);
+            self::inquiryUpdate($customer,$user->id);
+        }
+
+        $data = [
+            'user_id' => $user->id,
+            'obtain' => time(),
+        ];
+        $res = $query->update($data);
+
+
+        if ($res) {
+            return Util::success($res, trans('success'));
+        } else {
+            return Util::fail($res, trans('fail'));
+        }
+    }
+
     /**
      * 跟进状态
      * @param Request $request
@@ -456,9 +676,10 @@ class CustomerController
      */
     public function collect(Request $request)
     {
-        Log::info('send follow start',$request->all());
+        Log::info('receive collect start',$request->all());
         $user_sn = Util::getParam($request, 'user_sn'); //用户sn
-        $user_email = Util::getParam($request, 'user_email'); //邮箱
+//        $user_email = Util::getParam($request, 'user_email'); //邮箱
+        $user_id = Util::getParam($request, 'user_id'); //邮箱
         $sn = Util::getParam($request, 'order_no'); //客户sn验证客户唯一性
         $channel_id = Util::getParam($request, 'channel_id'); //渠道
         $country_id = Util::getParam($request, 'country_id'); //国家
@@ -473,27 +694,26 @@ class CustomerController
         if (Util::isEmpty($user_sn)) {
             return Util::fail([], '用户sn不能为空');
         }
-        if (Util::isEmpty($user_email)) {
-            return Util::fail([], '用户邮箱不能为空');
-        }
         if (Util::isEmpty($sn)) {
             return Util::fail([], '客户sn不能为空');
         }
 
-        $user = UserService::updateSn($user_sn, $user_email);
+//        $user = UserService::updateSn($user_sn, $user_email);
 
-        if(!$user){
-            return Util::fail($user, $user_email.'用户不存在');
-        }
+//        if(!$user){
+//            return Util::fail($user, $user_email.'用户不存在');
+//        }
 
         $res = Customer::firstOrCreate(
             ['sn' => $sn],
             [
-                'user_id' => $user->id,
+                'user_sn' => $user_sn,
+                'user_id' => $user_id,
+                'type' => 0,
                 'channel_id' => $channel_id,
                 'country_id' => $country_id,
                 'magnitude' => $magnitude,
-                'describe' => $describe,
+                'desc_collect' => $describe,
                 'phone' => $phone,
                 'email' => $email,
                 'WhatsApp' => $WhatsApp,

app/controller/FeishuController.php

@@ -5,6 +5,7 @@ namespace app\controller;
 use app\model\FeishuUser;
 use app\model\User;
 use app\util\Util;
+use config\constants\Constants;
 use support\Log;
 use support\Request;
 use support\exception\BusinessException;
@@ -53,7 +54,7 @@ class FeishuController
     public function getSign(Request $request)
     {
 
-        $res = [['id'=>'xinyouhe','name'=>'新友合'],['id'=>'mbaf','name'=>'MAGIC BRIDGE AUTO FZE']];
+        $res = Constants::SIGN;
 //        foreach ($certificate as $k => $v) {
 //            $res []=['id'=>$k,'name'=>$k];
 //        }

app/controller/FollowController.php

@@ -55,9 +55,7 @@ class FollowController
         if(Util::isEmpty($userId)){
             return Util::fail(['user_id'=>$userId],trans('user_none'));
         }
-        if($request->user['role']!=1){
-            $where['user_id'] = $userId;
-        }
+        $where['user_id'] = $userId;
 
         //跟进id
         $id = Util::getParam($request,'id');
@@ -123,10 +121,13 @@ class FollowController
         if(Util::isEmpty($type)){
             return Util::fail([],'type'.trans('not_null'));
         }
-        $picture = Util::getParam($request,'picture');
-        if(Util::isEmpty($picture)){
-            return Util::fail([],trans('picture_not_null'));
-        }
+
+         $picture = Util::getParam($request,'picture');
+         $audio_text = Util::getParam($request,'audio_text');
+         $remark = Util::getParam($request,'remark');
+         if(Util::isEmpty($picture) && Util::isEmpty($audio_text) && Util::isEmpty($remark)){
+             return Util::fail([],trans('follow_not_null'));
+         }
 
         $data = [
             'user_id'=>$request->user['id'],
@@ -135,7 +136,7 @@ class FollowController
             'picture'=>$picture,
             'remark'=>Util::getParam($request,'remark',''),
             'audio'=>Util::getParam($request,'audio',''),
-            'audio_text'=>Util::getParam($request,'audio',''),
+            'audio_text'=>Util::getParam($request,'audio_text',''),
             'lat'=>Util::getParam($request,'lat',0),
             'lng'=>Util::getParam($request,'lng',0),
             'address'=>Util::getParam($request,'address'),

app/controller/TagGroupController.php

@@ -5,6 +5,7 @@ namespace app\controller;
 use app\model\CustomerTag;
 use app\model\TagGroup;
 use app\util\Util;
+use config\constants\Constants;
 use support\Request;
 
 class TagGroupController
@@ -14,8 +15,10 @@ class TagGroupController
     public function list(Request $request)
     {
         $list = TagGroup::with('tags')->get();
-        $languageArr = config('translation.fallback_locale');
-        $language = $request->user['language'];
+        $languageArr = Constants::LANGUAGE;
+//        $language = $request->user['language'];
+        //$language = 'zh_CN';
+        $language = $request->language;
         foreach ($list as &$item) {
             $item['names'] = unserialize($item['names']);
             if (in_array($language, $languageArr)) {

app/controller/UserController.php

@@ -2,13 +2,20 @@
 
 namespace app\controller;
 
+use app\model\Corp;
 use app\model\Country;
 use app\model\FeishuUser;
 use app\model\User;
 use app\model\UserSn;
+use app\service\AuthService;
 use app\service\MailService;
+use app\service\UserService;
+use app\util\HttpClient;
 use app\util\JwtUtil;
 use app\util\Util;
+use config\constants\Constants;
+use support\exception\BusinessException;
+use support\Log;
 use support\Redis;
 use support\Request;
 
@@ -17,24 +24,40 @@ class UserController
     /**
      * 不需要登录的方法
      */
-    protected $noNeedLogin = ['login', 'sendCode', 'register'];
+    protected $noNeedLogin = ['login', 'sendCode', 'register', 'step', 'savePassword'];
 
     public function login(Request $request)
     {
         $email = Util::getParam($request, 'email');
+        $corpAbbr = Util::getParam($request, 'abbr');
         $language = Util::getParam($request, 'language');
         if (Util::isEmpty($email)) {
             return Util::fail([], trans('required_not_null'));
         }
+        if (Util::isEmpty($corpAbbr)) {
+            return Util::fail([], 'abbr'.trans('not_null'));
+        }
         $password = Util::getParam($request, 'password');
         if (Util::isEmpty($password)) {
             return Util::fail([], trans('required_not_null'));
         }
 
-        $user = User::select(['id', 'name', 'sex', 'role', 'avatar', 'email', 'password'])
-            ->where('status', 0)
-            ->where('email', $request->post('email'))
+        // 获取企业ID
+        $corpInfo = Corp::where('abbr', $corpAbbr)->first();
+        if (!$corpInfo) {
+            return Util::fail([], '公司不存在');
+        }
+        $corpId = $corpInfo->id;
+
+        $user = User::where('status', 0)
+//            ->where('email', $request->post('email'))
+            ->where('corp_id', $corpId)
+            ->OrWhere(['email' => $request->post('email'),'phone' => $request->post('email')])
             ->first();
+//        $builder = User::where('status', 0)
+//            ->where('email', $request->post('email'));
+//        $sql = str_replace(['?'], ['\'%s\''], $builder->toSql());
+//        $fullSql = vsprintf($sql, $builder->getBindings());
         if (!$user) {
             return Util::fail(['user' => $user], trans('user_none'));
         }
@@ -43,14 +66,20 @@ class UserController
         $userPassword = $user['password'];
 
         //加密
-        $hashedPassword = password_hash($password, PASSWORD_DEFAULT);
+//        $hashedPassword = password_hash($password, PASSWORD_DEFAULT);
 
         //验证密码
 //        if (!password_verify($userPassword, $hashedPassword)) {
-        if ($userPassword == $hashedPassword) {
+//        if ($userPassword == $hashedPassword) {
+
+        if (!password_verify($password, $userPassword)) {
             locale($language);
             return Util::fail([], trans('password_error'));
         }
+
+        if ($user['status'] != 1) {
+            return Util::fail([], '账号已禁用',403);
+        }
         $userId = $user['id']; // 实际从数据库获取
 
 
@@ -61,17 +90,29 @@ class UserController
         $result = $user;
         unset($result['password']);
         $result['token'] = $token;
-        $result['feishu_openid'] = FeishuUser::where('user_id', $userId)->value('open_id');
+//        $result['feishu_openid'] = FeishuUser::where('user_id', $userId)->value('open_id');
+        $result['feishu_openid'] = $result['openid']??'';
 
         if (!Util::isEmpty($language)) {
-            User::where('id', $userId)
-                ->update(['language' => $language]);
+//            User::where('id', $userId)
+//                ->update(['language' => $language]);
             locale($language);
         }
 
         return Util::success($result, trans('login_success'));
     }
 
+    public function loginNew(Request $request)
+    {
+        try {
+            $authService = new AuthService();
+            $result = $authService->uPwdLogin($request->all());
+            return Util::success($result, '登录成功');
+        } catch (\Throwable $e) {
+            Util::fail([],$e->getMessage());
+        }
+    }
+
     /**
      * 发送邮箱验证码
      * @param Request $request
@@ -110,12 +151,13 @@ class UserController
      */
     public function register(Request $request)
     {
-        $email = Util::getParam($request, 'email', 'asdf');
+        $email = Util::getParam($request, 'email', '');
         $code = Util::getParam($request, 'code');
         $sex = Util::getParam($request, 'sex', 0);
         $name = Util::getParam($request, 'name', '');
         $password = Util::getParam($request, 'password');
         $mobile = Util::getParam($request, 'mobile');
+        $corpAbbr = Util::getParam($request, 'abbr');
         $id = Util::getParam($request, 'id');
         $language = Util::getParam($request, 'language');
 
@@ -126,9 +168,9 @@ class UserController
         $res = User::select('id', 'email')
             ->where('email', $email)
             ->first();
-//        if (!Util::isEmpty($res)) {
-//            return Util::fail([], trans('email_repeat'));
-//        }
+        if (!empty($res)) {
+            return Util::fail($res, trans('email_repeat'));
+        }
 
         if (Util::isEmpty($name)) {
 //            return Util::fail([], trans('required_not_null'));
@@ -139,7 +181,7 @@ class UserController
         if ($code != $verification_code) {
             return Util::fail([], trans('code_error'));
         }
-        if(strlen($password) < 6) {
+        if(strlen($password) < 8) {
             return Util::fail([], trans('password_short'));
         }
 
@@ -147,33 +189,33 @@ class UserController
         $hashedPassword = password_hash($password, PASSWORD_DEFAULT);
 
         $data = [
-            'mobile' => $mobile,
+            'phone' => $mobile,
             'email' => $email,
             'name' => '用户_'.rand(111111, 999999),
             'sex' => $sex,
-            'role' => 1,
             'password' => $hashedPassword,
-            'status' => 0,
-            'avatar' => 'lingke_crm/logo.png'
+            'status' => 1,
+            'avatar' => ''
         ];
 
-
-        if (Util::isEmpty($id)) {
-            // 获取编号
-            $userSnModel = new UserSn();
-            $sn = $userSnModel->where('user_id', '=', 0)->inRandomOrder()->first();
-            if (!$sn) {
-                throw new BusinessException('未找到适用编号');
-            }
-            $data['sn'] = $sn['user_sn'];
-            $res = User::create($data);
-            UserSn::where(['user_sn'=>$data['sn']])->update(['user_id'=>$res['id']]);
-        } else {
-            $res = User::where('id', $id)
-                ->update($data);
-//            Log::info('update', ['res' => $res]);
-            (!$res) ?: $res = User::find($id)->toArray();
+        // 获取可用用户编号
+        $userSnModel = new UserSn();
+        $sn = $userSnModel->where('user_id', '=', 0)->inRandomOrder()->first();
+        if (!$sn) {
+            Log::error('用户注册时未找到适用编号');
+            return Util::fail([], '未找到适用编号');
         }
+        $data['sn'] = $sn->user_sn;
+
+
+        // 获取企业ID
+        $corpInfo = Corp::where('abbr', $corpAbbr)->first();
+        if (!$corpInfo) {
+            return Util::fail([], '公司不存在');
+        }
+        $data['corp_id'] = $corpInfo->id;
+
+        $res = User::create($data);
 
         unset($res['password']);
         locale($language);
@@ -184,6 +226,28 @@ class UserController
         }
     }
 
+    public function step()
+    {
+        $users = User::where(['sn'=>0])->get();
+        $r = [];
+        foreach ($users as $user) {
+            $option = ['email' => $user->email];
+            $userService = new UserService;
+            $res = $userService->createOrquery($option);
+            Log::info('register_rpc',$res);
+//            return Util::fail($res, trans('register_fail'));
+            if ($res['code'] != 200 && $res['data']['code'] != 0){
+                return Util::fail($res, trans('register_fail'));
+            }
+            $data[] = [];
+            $data['sn'] = $res['data']['data']['sn'];
+            $data['id'] = $res['data']['data']['uid'];
+            $res = User::where('id',$user->id)->update(['sn' => $data['sn'],'id' => $data['id']]);
+            $r[]=$data;
+        }
+        return Util::success($r, trans('register_success'));
+    }
+
 
     public function getInfo(Request $request)
     {
@@ -192,12 +256,32 @@ class UserController
             ->first();
         $user->toArray();
         unset($user->password);
-        $user['feishu_openid'] = FeishuUser::where('user_id', $userId)->value('open_id');
+//        $user['feishu_openid'] = FeishuUser::where('user_id', $userId)->value('open_id');
+        $user['feishu_openid'] = $user['openid']??'';
         $user['country_name'] = Country::where('id', $user['country_id'])->value('cn_addr');
-        $user['avatar_url'] = $user['avatar'];
         $ossservice = new \app\service\OssService();
-        $user['avatar'] = $user['avatar'] ? $ossservice->generatePrivateUrl($user['avatar']) : '';
-        return Util::success($user, trans('save_success'));
+        $user['avatar_url'] = $user['avatar'];
+        $user['socialize_pic_url'] = $user['socialize_pic'] ? $ossservice->generatePrivateUrl($user['socialize_pic']) : '';
+
+        // 重构数组
+        $sign = array_column(Constants::SIGN, 'name', 'id');
+        $user['company'] = isset($sign[$user['sign']])?$sign[$user['sign']]:'';
+        return Util::success($user, trans('success'));
+    }
+
+    public function getUsers(Request $request)
+    {
+        $userId = $request->user['id'];
+        $abbr = $request->input('abbr');
+        if(empty($abbr)){
+            return Util::fail([], 'abbr'.trans('not_null'));
+        }
+        $corpId = Corp::where('abbr', $abbr)->value('id');
+        $where[] = ['corp_id' , $corpId];
+        $where[] = ['status' , 1];
+        $user = User::select('id','name')->where($where)
+            ->get();
+        return Util::success($user, trans('success'));
     }
 
     /**
@@ -208,27 +292,32 @@ class UserController
      */
     public function save(Request $request)
     {
-        $name = Util::getParam($request, 'name');
-        $sex = Util::getParam($request, 'sex');
-        $position = Util::getParam($request, 'position');
-        $country_id = Util::getParam($request, 'country_id');
-        $sign = Util::getParam($request, 'sign');
         $id = $request->user['id'];
-        $avatar = Util::getParam($request, 'avatar_url');
-        $mobile = Util::getParam($request, 'mobile');
+        $avatar = Util::getParam($request, 'avatar');
+        $socializePic = Util::getParam($request, 'socialize_pic');
 
-        $data = [
-            'name' => $name,
-            'sex' => $sex,
-            'position' => $position,
-            'country_id' => $country_id,
-            'sign' => $sign,
-            'avatar' => $avatar,
-            'mobile' => $mobile
-        ];
+        $user = User::where('id', $id)->first();
+        // 只填充前端传递的字段
+        $user->fill($request->only(['name', 'sex', 'position', 'country_id', 'sign', 'mobile', 'address', 'socialize', 'socialize_pic']));
 
-        $res = User::where('id', $id)
-            ->update($data);
+        if(!Util::isEmpty($avatar)){
+            $user->avatar = $avatar;
+        }
+        if(!Util::isEmpty($socializePic)){
+            $user->socialize_pic = $socializePic;
+        }
+
+        $mobile = $user->isDirty('mobile');
+        $name = $user->isDirty('name');
+        $sign = $user->isDirty('sign');
+        if($mobile || $name || $sign){
+            $userService = new UserService;
+            $option = ['uid' => $user->id, 'phone' => $user->mobile, 'name' => $user->name, 'sign' => $user->sign, ];
+            $res = $userService->update($option);
+            Log::info('register_rpc',$res);
+        }
+
+        $res = $user->save();
 
         if ($res) {
             return Util::success($res, trans('save_success'));
@@ -249,16 +338,24 @@ class UserController
         $email = Util::getParam($request, 'email');
         $code = Util::getParam($request, 'code');
         $verification_code = Redis::get("verification_code:{$email}");
-        $id = $request->user['id'];
+//        $id = $request->user->uid;
 
         if ($code != $verification_code) {
             return Util::fail([], trans('code_error'));
         }
 
-        $res = User::where('id', $id)
+//        $res = User::where('id', $id)
+//            ->first();
+//        if($res['email'] != $email) {
+//            return Util::fail([], trans('email_consistent'));
+//        }
+
+        $user = User::where('status', 0)
+//            ->where('corp_id', $corpId)
+            ->OrWhere(['email' => $request->post('email'),'phone' => $request->post('email')])
             ->first();
-        if($res['email'] != $email) {
-            return Util::fail([], trans('email_consistent'));
+        if(!$user) {
+            return Util::fail([], trans('user_none'));
         }
 
         //加密
@@ -268,9 +365,11 @@ class UserController
         $data = [
             'password' => $hashedPassword
         ];
+        $user->password = $hashedPassword;
+        $res = $user->save();
 
-        $res = User::where('id', $id)
-            ->update($data);
+//        $res = User::where('id', $id)
+//            ->update($data);
 
         if ($res) {
             return Util::success($res, trans('save_success'));
@@ -292,11 +391,11 @@ class UserController
         if (Util::isEmpty($language)) {
             return Util::fail([], 'language' . trans('not_null'));
         }
-        if (!in_array($language, ['en', 'zh_CN'])) {
+        if (!in_array($language, Constants::LANGUAGE)) {
             return Util::fail([], trans('param_error'));
         }
         $data = [
-            'language' => $language,
+//            'language' => $language,
         ];
 
         $res = User::where('id', $id)

app/middleware/AuthMiddleware.php

@@ -77,17 +77,19 @@ class AuthMiddleware implements MiddlewareInterface
             }
 
             $userId = $decoded->sub;
-            $user = User::select(['id','name','sex','role','avatar','email','password','language','created_at'])
-                ->find($userId);
+            $user = User::find($userId);
             if(!$user){
-                return Util::fail(['user'=>$user],trans('user_none'));
+                return Util::fail(['user'=>$userId],trans('user_none'));
             }
             $user = $user->toArray();
 
             // 将用户ID存入请求对象，供后续使用
 //            $request->user = ['id' => $userId];
             $request->user = $user;
-            locale($user['language']);
+            $request->language = $request->header('fdesk-language');
+
+//            locale($user['language']);
+            locale($request->language);
             return $handler($request);
         } catch (BusinessException $e) {
             return json(['code' => 401, 'msg' => $e->getMessage()]);

app/model/Channel.php

@@ -11,7 +11,7 @@ class Channel extends Model
      *
      * @var string
      */
-    protected $table = 'channel';
+    protected $table = 'inquiry_channel';
 
     /**
      * The primary key associated with the table.
@@ -42,7 +42,7 @@ class Channel extends Model
 
     public static function getAll()
     {
-        $list = self::get()->select('id','name','name_en','status')->where('status',0)->toArray();
+        $list = self::get()->select('id','name','name_en','status')->where('status',1)->toArray();
         return $list;
     }
 }

app/model/Corp.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace app\model;
+
+
+use app\util\Util;
+use config\constants\Constants;
+use DateTimeInterface;
+use Illuminate\Support\Carbon;
+use support\Model;
+use Illuminate\Database\Eloquent\SoftDeletes;
+
+class Corp extends Model
+{
+    /**
+     * The table associated with the model.
+     *
+     * @var string
+     */
+    protected $table = 'corp';
+
+    /**
+     * The primary key associated with the table.
+     *
+     * @var string
+     */
+    protected $primaryKey = 'id';
+
+    //设置黑名单
+    protected $guarded = ['id','created_at','updated_at'];
+
+    // 指定日期字段存储格式为时间戳
+    protected $dateFormat = 'U';
+
+    /**
+     * Indicates if the model should be timestamped.
+     *
+     * @var bool
+     */
+    public $timestamps = true;
+}

app/model/Customer.php

@@ -17,7 +17,7 @@ class Customer extends Model
      *
      * @var string
      */
-    protected $table = 'customer';
+    protected $table = 'crm_customer';
 
     /**
      * The primary key associated with the table.
@@ -67,20 +67,23 @@ class Customer extends Model
      */
     public static function getCustomer($customer, $request, $tag = false)
     {
-        $language = $request->user['language'] ?: 'en';
-        $customer['grade_txt'] = $language=='en'?Constants::GRADE_EN[$customer['grade']]:Constants::GRADE[$customer['grade']];
-        $customer['magnitude_txt'] = $language=='en'?Constants::MAGNITUDE_EN[$customer['magnitude']]:Constants::MAGNITUDE[$customer['magnitude']];
-        $customer['sex_txt'] = $language=='en'?Constants::SEX_EN[$customer['sex']]:Constants::SEX[$customer['sex']];
+        //$language = $request->user['language'] ?: 'en';
+        //$language = 'zh_CN';
+        $language = $request->language;
+        $customer['grade_txt'] = Util::language($language, Constants::GRADE_EN[$customer['grade']], Constants::GRADE[$customer['grade']], Constants::GRADE_RU[$customer['grade']]);
+        $customer['magnitude'] = ($customer['magnitude']==0)?1:$customer['magnitude'];
+        $customer['magnitude_txt'] = Util::language($language, Constants::MAGNITUDE_EN[$customer['magnitude']], Constants::MAGNITUDE[$customer['magnitude']], Constants::MAGNITUDE_RU[$customer['magnitude']]);
+        $customer['sex_txt'] = Util::language($language, Constants::SEX_EN[$customer['sex']], Constants::SEX[$customer['sex']], Constants::SEX_RU[$customer['sex']]);
 
         if ($customer['grade']<=2) {
             $customer['follow'] = 0;
-            $customer['follow_txt'] = ($language == 'en' ? 'Following' : '跟进中');
+            $customer['follow_txt'] = Util::language($language,'Following','跟进中','Продолжение');
         }elseif ($customer['grade']<5) {
             $customer['follow'] = 1;
-            $customer['follow_txt'] = ($language == 'en' ? 'transacted' : '已成交');
+            $customer['follow_txt'] = Util::language($language,'transacted','已成交','Транзакция завершена');
         }else{
             $customer['follow'] = 2;
-            $customer['follow_txt'] = ($language == 'en' ? 'lost' : '已流失');
+            $customer['follow_txt'] = Util::language($language,'lost','已流失','Потерянный');
         }
 
         $where = [
@@ -96,7 +99,8 @@ class Customer extends Model
 //        $customer['updated_at'] = Util::timeTotDate($customer['updated_at']);
 
         $customer = Util::formatDate($customer,['follow_last']);
-        $nameLang = $language=='en'?'name_en':'name';
+        $nameLang = $language=='en'?'name_en':($language=='ru'?'name_ru':'name');
+        $nameLang = 'name';
         $countryLang = $language=='en'?'en_addr':'cn_addr';
         $customer['car_type_name'] = empty($customer['car_type_id'])?'':CarType::where(['id'=>$customer['car_type_id']])->value($nameLang);
         $customer['country_name'] = empty($customer['country_id'])?'':Country::where(['id'=>$customer['country_id']])->value($countryLang);
@@ -118,7 +122,14 @@ class Customer extends Model
      */
     public function tags()
     {
-        return $this->belongsToMany(Tag::class, 'customer_tag', 'customer_id', 'tag_id')
+        return $this->belongsToMany(Tag::class, 'crm_customer_tag', 'customer_id', 'tag_id')
             ->withTimestamps(); // 如果需要记录关联时间
     }
+
+
+    // 定义与 变更历史 的一对多关系
+    public function his()
+    {
+        return $this->hasMany(CustomerHis::class, 'customer_id', 'id');
+    }
 }

app/model/CustomerHis.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace app\model;
+
+
+use app\util\Util;
+use config\constants\Constants;
+use DateTimeInterface;
+use Illuminate\Support\Carbon;
+use support\Model;
+use Illuminate\Database\Eloquent\SoftDeletes;
+
+class CustomerHis extends Model
+{
+    /**
+     * The table associated with the model.
+     *
+     * @var string
+     */
+    protected $table = 'crm_customer_his';
+
+    /**
+     * The primary key associated with the table.
+     *
+     * @var string
+     */
+    protected $primaryKey = 'id';
+
+    //设置黑名单
+    protected $guarded = ['id','created_at'];
+
+    // 指定日期字段存储格式为时间戳
+    protected $dateFormat = 'U';
+
+    /**
+     * Indicates if the model should be timestamped.
+     *
+     * @var bool
+     */
+    public $timestamps = true;
+
+    protected $casts = [
+        'created_at' => 'datetime:Y-m-d H:i:s', // 指定序列化格式
+//        'created_at' => 'timestamp', // 指定序列化格式
+    ];
+
+    /**
+     * 重新格式化时间
+     * @param DateTimeInterface $date
+     * @return string
+     */
+    protected function serializeDate(DateTimeInterface $date): string
+    {
+        return $date->format(Carbon::parse($date)->toDateTimeString());
+    }
+
+    // 定义反向多对一关联
+    public function customer()
+    {
+        return $this->belongsTo(Customer::class, 'customer_id', 'id');
+    }
+
+    // 禁用 updated_at 的自动更新
+    public function setUpdatedAt($value)
+    {
+        return $this; // 不做任何操作
+    }
+}

app/model/CustomerTag.php

@@ -14,7 +14,7 @@ class CustomerTag extends Model
      *
      * @var string
      */
-    protected $table = 'customer_tag';
+    protected $table = 'crm_customer_tag';
 
     /**
      * The primary key associated with the table.

app/model/Follow.php

@@ -16,7 +16,7 @@ class Follow extends Model
      *
      * @var string
      */
-    protected $table = 'follow';
+    protected $table = 'crm_follow';
 
     /**
      * The primary key associated with the table.
@@ -38,8 +38,6 @@ class Follow extends Model
      */
     public $timestamps = true;
 
-    protected $dates = ['created_at', 'updated_at', 'follow_time'];
-
     protected $casts = [
         'updated_at' => 'datetime:Y-m-d H:i:s', // 指定序列化格式
         'created_at' => 'datetime:Y-m-d H:i:s', // 指定序列化格式
@@ -51,10 +49,16 @@ class Follow extends Model
     public static function getFollow($follow,$domain = 'https://vehicle-album.oss-cn-beijing.aliyuncs.com')
     {
         $follow['type_txt'] = Constants::FOLLOW[$follow['type']];
-        $follow['firstFollowtime'] = $follow['follow_time'];
-        $ossservice = new OssService();
-        $oss_picture = $ossservice->generatePrivateUrl($follow['picture'],86400);
-        $follow['oss_picture'] = $oss_picture;
+                $follow['firstFollowtime'] = $follow['follow_time'];
+        if (isset($follow['picture']) && !empty($follow['picture'])) {
+                $ossservice = new OssService();
+                $oss_picture = $ossservice->generatePrivateUrl($follow['picture'],86400);
+                $follow['oss_picture'] = $oss_picture;
+        }else {
+            $follow['oss_picture'] = '';
+        }
+        $follow['created_at'] = (!empty($follow['created_at']))?date('Y-m-d H:i:s',strtotime($follow['created_at'])+(3600*8)):'';
+        $follow['updated_at'] = (!empty($follow['updated_at']))?date('Y-m-d H:i:s',strtotime($follow['updated_at'])+(3600*8)):'';
 //        $follow = Util::formatDate($follow);
         return $follow;
     }

app/model/InquiryLog.php

@@ -0,0 +1,74 @@
+<?php
+
+namespace app\model;
+
+use support\Model;
+
+class InquiryLog extends Model
+{
+    /**
+     * The connection name for the model.
+     *
+     * @var string|null
+     */
+    protected $connection = 'mysql';
+    
+    /**
+     * The table associated with the model.
+     *
+     * @var string
+     */
+    protected $table = 'inquiry_log';
+
+    /**
+     * The primary key associated with the table.
+     *
+     * @var string
+     */
+    protected $primaryKey = 'id';
+
+    /**
+     * Indicates if the model should be timestamped.
+     *
+     * @var bool
+     */
+    public $timestamps = true;
+    
+    
+    protected $dateFormat = 'U';
+
+    /**
+     * 允许自动填充模型字段
+     */
+    protected $fillable = [
+        'id', 'order_no', 'enter_user_id', 'recipient', 
+        'quality', 'channel', 'email', 'tel', 'whatsapp', 
+        'country', 'contacts', 'content', 'status', 
+        'r_time', 't_time', 'created_at', 'updated_at'
+    ];
+
+    /**
+     * 不允许自动填充模型字段
+     */
+    protected $guarded = [];
+
+
+    public function enter()
+    {
+        return $this->hasOne(User::class, 'id', 'enter_user_id');
+    }
+
+    // public function recipientInfo()
+    // {
+    //     return $this->hasOne(User::class, 'id', 'recipient')->where('status', 1);
+    // }
+    public function recipientInfo()
+    {
+        return $this->hasOne(User::class, 'id', 'recipient');
+    }
+
+    public function countryInfo()
+    {
+        return $this->hasOne(Country::class, 'id', 'country');
+    }
+}

app/model/Tag.php

@@ -17,7 +17,7 @@ class Tag extends Model
      *
      * @var string
      */
-    protected $table = 'tag';
+    protected $table = 'crm_tag';
 
     /**
      * The primary key associated with the table.

app/model/TagGroup.php

@@ -17,7 +17,7 @@ class TagGroup extends Model
      *
      * @var string
      */
-    protected $table = 'tag_group';
+    protected $table = 'crm_tag_group';
 
     /**
      * The primary key associated with the table.

app/model/User.php

@@ -34,7 +34,7 @@ class User extends Model
     protected $dateFormat = 'U';
 
     //设置黑名单
-    protected $guarded = ['id','created_at','updated_at'];
+    protected $guarded = ['created_at','updated_at'];
 
     protected $casts = [
 //        'updated_at' => 'datetime:Y-m-d H:i:s', // 指定序列化格式

app/process/Task.php

@@ -4,6 +4,7 @@ namespace app\process;
 
 use app\controller\FeishuController;
 use app\model\Customer;
+use app\model\CustomerHis;
 use app\model\FeishuUser;
 use app\model\User;
 use support\Log;
@@ -15,60 +16,27 @@ class Task
 
     public function onWorkerStart()
     {
-        // 每半小时执行一次
-        new Crontab('0 */30 * * * *', function(){
+
+        // 每小时执行一次
+        new Crontab('0 10 * * * *', function(){
             echo date('Y-m-d H:i:s') . "\n";
-            Log::info('send follow start',[time()]);
-//            FeishuController::send('xinyouhe','ou_e33bb3017ada6c4781398a68e55a4696', '跟进提醒', '您有新的跟进提醒', '');
-//             $customer = Customer::where(['follow_next', '<=', time() + 3600])
-//                 ->where(['follow_next', '>', time()])
-//                 ->where(['warn', '<', 1])
-//                 ->get();
-//             foreach ($customer as $item) {
-//                 $feishuUser = FeishuUser::where(['user_id' => $item->user_id])->first();
-//                 if ($feishuUser) {
-//                     // 获取凭证
-//                     $certificate = config($this->config);
-//                     // 使用parse_url解析URL
-//                     $parsedUrl = parse_url($certificate['rUrl']);
-//                     // 获取域名和端口
-//                     $host = $parsedUrl['host'];
-//                     $port = isset($parsedUrl['port']) ? ':' . $parsedUrl['port'] : '';
-//                     $url = $host .$port. '/pages/customer/detile?id='.$customer->id;
-//                     $item->warn = 1;
-//                     $item->update();
-//                     $user = User::first()->where('id', $item->user_id);
-//                     Log::info('send',['open_id'=>$item['open_id'],'url'=>$url]);
-// //                    FeishuController::send('xinyouhe','ou_e33bb3017ada6c4781398a68e55a4696', '跟进提醒', '您有新的跟进提醒', $url);
-//                     FeishuController::send($user->sign,$feishuUser->open_id, '跟进提醒', '您有新的跟进提醒', $url);
-//                 }
-//             }
+            Log::info('send high seas start',[time()]);
 
             $where = [
-                ['follow_next', '<=', time() + 3600],
-                ['follow_next', '>', time()],
-                ['warn', '<', 1]
+                ['deleted_at', '<=', time() - 3600],
+                ['user_id', '<>', 0],
             ];
-            $customer = Customer::where($where)->get();
+            $customer = Customer::where($where)->onlyTrashed()->get();
             foreach ($customer as $item) {
-                $feishuUser = FeishuUser::where(['user_id' => $item->user_id])->first();
-                if ($feishuUser) {
-                    // 获取凭证
-                    $certificate = config('feishu.'.$feishuUser->sign);
-                    // 使用parse_url解析URL
-                    $parsedUrl = parse_url($certificate['rUrl']);
-                    // 获取域名和端口
-                    $host = $parsedUrl['host'];
-                    $port = isset($parsedUrl['port']) ? ':' . $parsedUrl['port'] : '';
-                    $url = 'http://'. $host .$port. '/pages/customer/detile?id='.$item->id;
-                    $item->warn = 1;
-                    $item->update();
-                    Log::info('send',['open_id'=>$item['open_id'],'url'=>$url]);
-                    FeishuController::send($feishuUser->sign, $feishuUser->open_id, '跟进提醒', '您有新的跟进提醒', $url);
-                }
+                $item->update(['user_id' => 0, 'deleted_at' => time()]);
+                CustomerHis::create([
+                    'customer_id' => $item->_id,
+                    'user_his' => $item->user_id,
+                    'user_id' => 0,
+                ]);
             }
 
-            Log::info('send follow start',[time()]);
+            Log::info('send high seas end',[time()]);
         });
 
     }

app/service/OssService.php

@@ -15,10 +15,10 @@ class OssService
 
     public function __construct()
     {
-        $this->accessKeyId = 'LTAI5tAGiH7bkVkmrniXnfkA';
-        $this->accessKeySecret = 'nqklJBft6t3S0A4ZvxF4ci9ni91kmm';
-        $this->bucket = 'vehicle-album';
-        $this->endpoint = 'https://oss-cn-beijing.aliyuncs.com';
+        $this->accessKeyId = getenv('OSS_ACCESSID');
+        $this->accessKeySecret = getenv('OSS_ACCESSSECRET');
+        $this->bucket = getenv('OSS_BUCKET');
+        $this->endpoint = getenv('OSS_ENDPOINT');
         $this->ossClient = new OssClient($this->accessKeyId, $this->accessKeySecret, $this->endpoint);
     }
 

app/service/UserService.php

@@ -4,9 +4,17 @@ namespace app\service;
 
 use app\model\User;
 use app\model\UserSn;
+use app\util\HttpClient;
 
 class UserService
 {
+    protected $domain;
+
+
+    public function __construct(){
+        $this->domain = config('const.rpc_domain');
+    }
+
     /**
      * 更新用户sn
      * @param $sn
@@ -15,13 +23,12 @@ class UserService
     public static function updateSn($sn, $email)
     {
         $user = User::first()
-            ->where('email',$email)
+            ->where('email', $email)
             ->first();
-        return $user;
-        if(!$user){
+        if (!$user) {
             return false;
         }
-        if($user->sn != $sn){
+        if ($user->sn != $sn) {
             UserSn::where(['sn' => $user->sn])->update(['user_id' => 0]);
             UserSn::where(['sn' => $sn])->update(['user_id' => $user->id]);
             $user->sn = $sn;
@@ -29,4 +36,28 @@ class UserService
         }
         return $user;
     }
+
+    /**
+     * 创建或查询用户
+     * @param array $data ['email'=>'','phone'=>'','company_tag'=>'','name'=>''];
+     * @return array
+     */
+    public function createOrquery(array $data)
+    {
+
+        $result = HttpClient::post($this->domain . '/user/create/query', $data);
+        return $result;
+    }
+
+    /**
+     * 创建或查询用户
+     * @param array $data ['email'=>'','phone'=>'','company_tag'=>'','name'=>''];
+     * @return array
+     */
+    public function update(array $data)
+    {
+
+        $result = HttpClient::post($this->domain . '/user/update', $data);
+        return $result;
+    }
 }

app/util/HttpClient.php

@@ -0,0 +1,227 @@
+<?php
+
+namespace app\util;
+
+use GuzzleHttp\Client;
+use GuzzleHttp\Exception\GuzzleException;
+use GuzzleHttp\Psr7\Response;
+use Psr\Http\Message\ResponseInterface;
+
+class HttpClient
+{
+    /**
+     * @var Client Guzzle客户端实例
+     */
+    private static $client;
+
+    /**
+     * 获取Guzzle客户端单例
+     * @return Client
+     */
+    private static function getClient(): Client
+    {
+        if (!self::$client) {
+            self::$client = new Client([
+                'timeout' => 10, // 默认超时时间10秒
+                'verify' => false, // 不验证SSL证书(生产环境建议设为true)
+                'http_errors' => false, // 不抛出HTTP异常，自己处理
+            ]);
+        }
+        return self::$client;
+    }
+
+    /**
+     * 发送GET请求
+     * @param string $url 请求地址
+     * @param array $query 查询参数
+     * @param array $headers 请求头
+     * @return array
+     */
+    public static function get(string $url, array $query = [], array $headers = []): array
+    {
+        $options = [
+            'query' => $query,
+            'headers' => $headers
+        ];
+        return self::request('GET', $url, $options);
+    }
+
+    /**
+     * 发送POST请求
+     * @param string $url 请求地址
+     * @param array|string $data 请求数据
+     * @param array $headers 请求头
+     * @param string $contentType 内容类型(form/json/xml)
+     * @return array
+     */
+    public static function post(string $url, $data = [], array $headers = [], string $contentType = 'form'): array
+    {
+        $options = ['headers' => $headers];
+
+        switch ($contentType) {
+            case 'json':
+                $options['json'] = $data;
+                $options['headers']['Content-Type'] = 'application/json';
+                break;
+            /*case 'xml':
+                $options['body'] = is_array($data) ? self::arrayToXml($data) : $data;
+                $options['headers']['Content-Type'] = 'application/xml';
+                break;*/
+            default: // form
+                $options['form_params'] = $data;
+                $options['headers']['Content-Type'] = 'application/x-www-form-urlencoded';
+        }
+
+        return self::request('POST', $url, $options);
+    }
+
+    /**
+     * 发送PUT请求
+     * @param string $url 请求地址
+     * @param array|string $data 请求数据
+     * @param array $headers 请求头
+     * @return array
+     */
+    public static function put(string $url, $data = [], array $headers = []): array
+    {
+        $options = [
+            'json' => $data,
+            'headers' => $headers
+        ];
+        return self::request('PUT', $url, $options);
+    }
+
+    /**
+     * 发送DELETE请求
+     * @param string $url 请求地址
+     * @param array $data 请求数据
+     * @param array $headers 请求头
+     * @return array
+     */
+    public static function delete(string $url, array $data = [], array $headers = []): array
+    {
+        $options = [
+            'json' => $data,
+            'headers' => $headers
+        ];
+        return self::request('DELETE', $url, $options);
+    }
+
+    /**
+     * 发送HTTP请求
+     * @param string $method 请求方法
+     * @param string $url 请求地址
+     * @param array $options 请求选项
+     * @return array
+     */
+    public static function request(string $method, string $url, array $options = []): array
+    {
+        try {
+            $response = self::getClient()->request($method, $url, $options);
+            return self::formatResponse($response);
+        } catch (GuzzleException $e) {
+            return [
+                'status' => false,
+                'code' => $e->getCode(),
+                'message' => $e->getMessage(),
+                'data' => null
+            ];
+        }
+    }
+
+    /**
+     * 上传文件
+     * @param string $url 请求地址
+     * @param array $files 文件数组 [['name' => 'field_name', 'path' => 'file_path']]
+     * @param array $form 其他表单数据
+     * @param array $headers 请求头
+     * @return array
+     */
+    public static function upload(string $url, array $files, array $form = [], array $headers = []): array
+    {
+        $multipart = [];
+
+        // 添加文件
+        foreach ($files as $file) {
+            if (file_exists($file['path'])) {
+                $multipart[] = [
+                    'name' => $file['name'],
+                    'contents' => fopen($file['path'], 'r'),
+                    'filename' => basename($file['path'])
+                ];
+            }
+        }
+
+        // 添加其他表单数据
+        foreach ($form as $name => $value) {
+            $multipart[] = [
+                'name' => $name,
+                'contents' => $value
+            ];
+        }
+
+        $options = [
+            'multipart' => $multipart,
+            'headers' => $headers
+        ];
+
+        return self::request('POST', $url, $options);
+    }
+
+    /**
+     * 格式化响应
+     * @param ResponseInterface $response
+     * @return array
+     */
+    private static function formatResponse(ResponseInterface $response): array
+    {
+        $contents = $response->getBody()->getContents();
+        $contentType = $response->getHeaderLine('Content-Type');
+
+        $data = $contents;
+        if (strpos($contentType, 'application/json') !== false) {
+            $data = json_decode($contents, true) ?? $contents;
+        }
+
+        return [
+            'status' => $response->getStatusCode() === 200,
+            'code' => $response->getStatusCode(),
+            'message' => $response->getReasonPhrase(),
+            'data' => $data,
+            'headers' => $response->getHeaders()
+        ];
+    }
+
+    /**
+     * 数组转XML
+     * @param array $data
+     * @param string $rootNode
+     * @return string
+     */
+    private static function arrayToXml(array $data, string $rootNode = 'root'): string
+    {
+        $xml = new \SimpleXMLElement('<' . $rootNode . '/>');
+        self::addDataToXml($xml, $data);
+        return $xml->asXML();
+    }
+
+    /**
+     * 递归添加数据到XML
+     * @param \SimpleXMLElement $xml
+     * @param array $data
+     */
+    private static function addDataToXml(\SimpleXMLElement $xml, array $data)
+    {
+        foreach ($data as $key => $value) {
+            if (is_array($value)) {
+                if (is_numeric($key)) {
+                    $key = 'item';
+                }
+                $subNode = $xml->addChild($key);
+                self::addDataToXml($subNode, $value);
+            } else {
+                $xml->addChild($key, htmlspecialchars($value));
+            }
+        }
+    }
+}

app/util/RedisHelper.php

@@ -0,0 +1,171 @@
+<?php
+namespace app\util;
+
+use support\Redis;
+use support\Log;
+
+class RedisHelper
+{
+    /**
+     * 存储数据（自动序列化数组）
+     * @param string $key 键名
+     * @param mixed $value 值
+     * @param int|null $ttl 过期时间(秒)
+     * @return bool
+     */
+    public static function set(string $key, $value, ?int $ttl = null): bool
+    {
+        try {
+            $storageValue = is_array($value) ? json_encode($value, JSON_UNESCAPED_UNICODE) : $value;
+
+            if ($ttl !== null) {
+                return Redis::setex($key, $ttl, $storageValue);
+            }
+            return Redis::set($key, $storageValue);
+        } catch (\Throwable $e) {
+            Log::error("Redis存储失败: {$e->getMessage()}", ['key' => $key]);
+            return false;
+        }
+    }
+
+    /**
+     * 获取数据（自动反序列化数组）
+     * @param string $key 键名
+     * @param mixed $default 默认值
+     * @return mixed
+     */
+    public static function get(string $key, $default = null)
+    {
+        try {
+            $value = Redis::get($key);
+
+            if ($value === false || $value === null) {
+                return $default;
+            }
+
+            // 尝试JSON解码
+            $decoded = json_decode($value, true);
+            return json_last_error() === JSON_ERROR_NONE ? $decoded : $value;
+        } catch (\Throwable $e) {
+            Log::error("Redis读取失败: {$e->getMessage()}", ['key' => $key]);
+            return $default;
+        }
+    }
+
+    /**
+     * 删除键
+     * @param string|array $keys 键名或键名数组
+     * @return int 删除的键数量
+     */
+    public static function del($keys): int
+    {
+        try {
+            return Redis::del(...(array)$keys);
+        } catch (\Throwable $e) {
+            Log::error("Redis删除失败: {$e->getMessage()}", ['keys' => $keys]);
+            return 0;
+        }
+    }
+
+    /**
+     * 检查键是否存在
+     * @param string $key 键名
+     * @return bool
+     */
+    public static function exists(string $key): bool
+    {
+        try {
+            return (bool)Redis::exists($key);
+        } catch (\Throwable $e) {
+            Log::error("Redis检查存在失败: {$e->getMessage()}", ['key' => $key]);
+            return false;
+        }
+    }
+
+    /**
+     * 设置带过期时间的缓存
+     * @param string $key 键名
+     * @param mixed $value 值
+     * @param int $ttl 过期时间(秒)
+     * @return bool
+     */
+    public static function setex(string $key, $value, int $ttl): bool
+    {
+        return self::set($key, $value, $ttl);
+    }
+
+    /**
+     * 哈希表设置字段值
+     * @param string $key 键名
+     * @param string $field 字段名
+     * @param mixed $value 值
+     * @return bool
+     */
+    public static function hSet(string $key, string $field, $value): bool
+    {
+        try {
+            $storageValue = is_array($value) ? json_encode($value, JSON_UNESCAPED_UNICODE) : $value;
+            return Redis::hSet($key, $field, $storageValue);
+        } catch (\Throwable $e) {
+            Log::error("Redis哈希设置失败: {$e->getMessage()}", ['key' => $key, 'field' => $field]);
+            return false;
+        }
+    }
+
+    /**
+     * 哈希表获取字段值
+     * @param string $key 键名
+     * @param string $field 字段名
+     * @param mixed $default 默认值
+     * @return mixed
+     */
+    public static function hGet(string $key, string $field, $default = null)
+    {
+        try {
+            $value = Redis::hGet($key, $field);
+
+            if ($value === false) {
+                return $default;
+            }
+
+            $decoded = json_decode($value, true);
+            return json_last_error() === JSON_ERROR_NONE ? $decoded : $value;
+        } catch (\Throwable $e) {
+            Log::error("Redis哈希获取失败: {$e->getMessage()}", ['key' => $key, 'field' => $field]);
+            return $default;
+        }
+    }
+
+    /**
+     * 自增计数器
+     * @param string $key 键名
+     * @param int $increment 增量
+     * @return int|false
+     */
+    public static function incr(string $key, int $increment = 1)
+    {
+        try {
+            return $increment === 1
+                ? Redis::incr($key)
+                : Redis::incrBy($key, $increment);
+        } catch (\Throwable $e) {
+            Log::error("Redis自增失败: {$e->getMessage()}", ['key' => $key]);
+            return false;
+        }
+    }
+
+    /**
+     * 获取剩余过期时间
+     * @param string $key 键名
+     * @return int 剩余秒数(-2表示键不存在，-1表示没有设置过期时间)
+     */
+    public static function ttl(string $key): int
+    {
+        try {
+            return Redis::ttl($key);
+        } catch (\Throwable $e) {
+            Log::error("Redis获取TTL失败: {$e->getMessage()}", ['key' => $key]);
+            return -2;
+        }
+    }
+}

app/util/Util.php

@@ -105,4 +105,25 @@ class Util
         return $value;
     }
 
+    /**
+     * 格式化创建时间
+     */
+    public static function language($language,$en,$zh_CN,$ru)
+    {
+        if ($language == 'zh_CN'){
+            return $zh_CN;
+        }elseif ($language == 'ru'){
+            return $ru;
+        }
+        return $en;
+    }
+
+    public static function mask($str)
+    {
+        if(empty($str)){
+            return '';
+        }
+        return substr($str, 0, 3) . '****' . substr($str, -4);
+    }
+
 }

app/view/index/privacy.html

@@ -43,7 +43,7 @@
 <body>
     <div class="container">
         <h1>隐私协议</h1>
-        <p><strong>生效日期：</strong>[2025-03]</p>
+        <p><strong>生效日期：</strong>[2024-06]</p>
 
         <h2>一、引言</h2>
         <p>欢迎使用 [领客]（以下简称“本应用”）。我们非常重视您的隐私保护，并致力于通过本隐私协议（以下简称“本协议”）向您说明我们如何收集、使用、存储和保护您的个人信息。请您在使用本应用前仔细阅读并理解本协议。</p>
@@ -92,13 +92,12 @@
         <h2>八、联系我们</h2>
         <p>如您对本协议或隐私保护有任何疑问，请联系我们：</p>
         <ul>
-            <li>邮箱：[app@hnxinyouhe.com]</li>
             <li>电话：[18137110386]</li>
-            <li>公司：[河南新友合科技有限公司]</li>
+            <li>公司：[河南晋海科技环保有限公司]</li>
         </ul>
 
         <div class="footer">
-            <p>© 2025 河南新友合科技有限公司. 保留所有权利。</p>
+            <p>© 2024 河南新友合科技环保有限公司. 保留所有权利。</p>
         </div>
     </div>
 </body>

app/view/index/user.html

@@ -43,10 +43,10 @@
 <body>
     <div class="container">
         <h1>用户协议</h1>
-        <p><strong>生效日期：</strong>[2025-03]</p>
+        <p><strong>生效日期：</strong>[2024-06]</p>
 
         <h2>一、总则</h2>
-        <p>1. 欢迎使用 [领客]（以下简称“本应用”）。本应用由 [河南新友合科技有限公司]（以下简称“我们”或“本公司”）提供。</p>
+        <p>1. 欢迎使用 [领客]（以下简称“本应用”）。本应用由 [河南晋海科技环保有限公司]（以下简称“我们”或“本公司”）提供。</p>
         <p>2. 在注册或使用本应用前，请仔细阅读本《用户协议》（以下简称“本协议”）。您一旦注册、登录或使用本应用，即表示您已充分阅读、理解并同意接受本协议的全部条款。</p>
 
         <h2>二、服务内容</h2>
@@ -90,7 +90,7 @@
         <p>2. 如因本协议产生争议，双方应友好协商解决；协商不成的，任何一方可向 管辖地 有管辖权的人民法院提起诉讼。</p>
 
         <div class="footer">
-            <p>© 2025 河南新友合科技有限公司. 保留所有权利。</p>
+            <p>© 2024 河南新友合科技有限公司. 保留所有权利。</p>
         </div>
     </div>
 </body>

composer.json

@@ -36,12 +36,12 @@
     "firebase/php-jwt": "^6.11",
     "illuminate/database": "^11.44",
     "phpmailer/phpmailer": "^6.9",
-    "shopwwi/webman-filesystem": "^2.0",
-    "iidestiny/flysystem-oss": "^4",
     "vlucas/phpdotenv": "^5.6",
     "guzzlehttp/guzzle": "^7.9",
     "webman/cache": "^2.1",
-    "workerman/crontab": "^1.0"
+    "workerman/crontab": "^1.0",
+    "shopwwi/webman-filesystem": "1.1",
+    "shopwwi/filesystem-oss": "^1.0"
   },
   "suggest": {
     "ext-event": "For better performance. "

config/const.php

@@ -0,0 +1,5 @@
+<?php
+
+return [
+    'rpc_domain' => getenv('RPC_DOMAIN'),
+];

config/constants/Constants.php

@@ -27,11 +27,19 @@ class Constants
         self::CUSTOMER_GRADE_SALES => 'After Sales',
         self::CUSTOMER_GRADE_LOSS => 'Stagnation or loss',
     ];
+    public const GRADE_RU = [
+        self::CUSTOMER_GRADE_INITIAL => 'Первоначальные контакты',
+        self::CUSTOMER_GRADE_COMMUNICATE => 'Потребности в общении',
+        self::CUSTOMER_GRADE_PLAN => 'Продвижение программы',
+        self::CUSTOMER_GRADE_DEAL => 'Этап сделки',
+        self::CUSTOMER_GRADE_SALES => 'Послепродажный этап',
+        self::CUSTOMER_GRADE_LOSS => 'Застой или потеря',
+    ];
 
     //客户重要性
-    public const CUSTOMER_MAGNITUDE_INITIAL = 0;     // 金牌商机
-    public const CUSTOMER_MAGNITUDE_COMMUNICATE = 1; // 银牌商机
-    public const CUSTOMER_MAGNITUDE_PLAN = 2; // 铜牌商机
+    public const CUSTOMER_MAGNITUDE_INITIAL = 1;     // 金牌商机
+    public const CUSTOMER_MAGNITUDE_COMMUNICATE = 2; // 银牌商机
+    public const CUSTOMER_MAGNITUDE_PLAN = 3; // 铜牌商机
 
     public const MAGNITUDE = [
         self::CUSTOMER_MAGNITUDE_INITIAL => '金牌商机',
@@ -44,6 +52,12 @@ class Constants
         self::CUSTOMER_MAGNITUDE_PLAN => 'Bronze Medal',
     ];
 
+    public const MAGNITUDE_RU = [
+        self::CUSTOMER_MAGNITUDE_INITIAL => 'Золотой бизнес',
+        self::CUSTOMER_MAGNITUDE_COMMUNICATE => 'Серебряный бизнес',
+        self::CUSTOMER_MAGNITUDE_PLAN => 'Бронзовый бизнес.',
+    ];
+
 
     //跟进类型
     public const CUSTOMER_FOLLOW_VISIT = 0;     // 线下拜访
@@ -68,10 +82,22 @@ class Constants
         self::CUSTOMER_SEX_MAN => '男',
         self::CUSTOMER_SEX_WOMAN => '女',
     ];
-
     public const SEX_EN = [
         self::CUSTOMER_SEX_UNKNOWN => 'unknown',
         self::CUSTOMER_SEX_MAN => 'man',
         self::CUSTOMER_SEX_WOMAN => 'woman',
     ];
+
+    public const SEX_RU = [
+        self::CUSTOMER_SEX_UNKNOWN => 'неизвестный',
+        self::CUSTOMER_SEX_MAN => 'мужской',
+        self::CUSTOMER_SEX_WOMAN => 'женский',
+    ];
+
+    public const SIGN = [
+        ['id' => 'xinyouhe', 'name' => '新友合'],
+        ['id' => 'mbaf', 'name' => 'MAGIC BRIDGE AUTO FZE']
+    ];
+
+   public const LANGUAGE = ['en', 'zh_CN','ru'];
 }

config/database.php

@@ -13,8 +13,8 @@ return [
             'username'    => getenv('DB_USER'),
             'password'    => getenv('DB_PASSWORD'),
             'unix_socket' => '',
-            'charset'     => 'utf8',
-            'collation'   => 'utf8_unicode_ci',
+            'charset'     => 'utf8mb4',
+            'collation'   => 'utf8mb4_general_ci',
             'prefix'      => '',
             'strict'      => true,
             'engine'      => null,

config/plugin/shopwwi/filesystem/app.php

@@ -1,4 +1,17 @@
 <?php
+/**
+ *-------------------------------------------------------------------------p*
+ * 配置文件
+ *-------------------------------------------------------------------------h*
+ * @copyright  Copyright (c) 2015-2022 Shopwwi Inc. (http://www.shopwwi.com)
+ *-------------------------------------------------------------------------c*
+ * @license    http://www.shopwwi.com        s h o p w w i . c o m
+ *-------------------------------------------------------------------------e*
+ * @link       http://www.shopwwi.com by 象讯科技 phcent.com
+ *-------------------------------------------------------------------------n*
+ * @since      shopwwi象讯·PHP商城系统Pro
+ *-------------------------------------------------------------------------t*
+ */
 
 return [
     'enable' => true,
@@ -64,21 +77,18 @@ return [
         ],
         'oss' => [
             'driver' => \Shopwwi\WebmanFilesystem\Adapter\AliyunOssAdapterFactory::class,
-//            'accessId' => 'OSS_ACCESS_ID',
-//            'accessSecret' => 'OSS_ACCESS_SECRET',
-//            'bucket' => 'OSS_BUCKET',
-//            'endpoint' => 'OSS_ENDPOINT',
-//            'url' => '', // 静态文件访问域名
-
-            'accessKey' => 'LTAI5tAGiH7bkVkmrniXnfkA',
-            'secretKey' => 'nqklJBft6t3S0A4ZvxF4ci9ni91kmm',
-            'bucket' => 'vehicle-album',
-            'endpoint' => 'https://oss-cn-beijing.aliyuncs.com',
-            'url' => '', // 静态文件访问域名
+//            'accessKey' => getenv('OSS_ACCESSID'),
+//            'secretKey' => getenv('OSS_ACCESSSECRET'),
+//            'bucket' => getenv('OSS_BUCKET'),
+//            'endpoint' => getenv('OSS_ENDPOINT'),
+            'accessId' => getenv('OSS_ACCESSID'),
+            'accessSecret' => getenv('OSS_ACCESSSECRET'),
+            'bucket' => getenv('OSS_BUCKET'),
+            'endpoint' => getenv('OSS_ENDPOINT'),
+            'url' => '' // 静态文件访问域名
             // 'timeout' => 3600,
             // 'connectTimeout' => 10,
-            'isCName' => false,
-            'prefix' => '',
+            // 'isCName' => false,
             // 'token' => null,
             // 'proxy' => null,
         ],

config/process.php

@@ -22,7 +22,7 @@ return [
     'webman' => [
         'handler' => Http::class,
         'listen' => getenv('WEBMAN_LISTEN'),
-        'count' => 8,
+        'count' => getenv('WEBMAN_COUNT'),
         'user' => '',
         'group' => '',
         'reusePort' => false,

resource/translations/en/messages.php

@@ -6,6 +6,7 @@ return [
     'login_success' => ' login success',
     'password_error' => ' password error',
     'user_none' => ' user none',
+    'user_id' => ' user ID',
     'user_login' => ' Please log in first',
     'not_null' => ' not null',
     'code_error' => ' code error',
@@ -21,13 +22,15 @@ return [
     'param_error' => ' param error',
     'required_not_null' => ' required not_ ull',
     'picture_not_null' => ' picture not null',
+    'follow_not_null' => ' The image and follow-up content cannot be empty at the same time',
     'contacts_not_null' => ' Contact person, email, and phone cannot be empty at the same time',
     'car_type_not_null' => ' preference_not_null',
     'channel_not_null' => ' channel not null',
     'email_consistent' => ' Inconsistent email addresses',
     'sign_not_null' => ' No affiliated company has been set',
-    'password_short' => ' Password cannot be less than 6 characters',
+    'password_short' => ' Password cannot be less than 8 characters',
     'id_empty' => ' ID cannot be empty',
     'customer_id' => ' customer ID',
     'tag_group_id' => ' tag group ID',
+    'claim_fail' => ' Cannot claim ownership of customers',
 ];

resource/translations/ru/messages.php

@@ -0,0 +1,36 @@
+<?php
+
+return [
+    'success' => ' Успех',
+    'fail' => ' Неудача',
+    'login_success' => ' Регистрация завершена',
+    'password_error' => ' Ошибка пароля',
+    'user_none' => ' Пользователь не существует',
+    'user_id' => ' Идентификатор пользователя',
+    'user_login' => ' Пожалуйста, войдите.',
+    'not_null' => ' Нельзя быть пустым',
+    'code_error' => ' Ошибка кода проверки',
+    'format_error' => ' Ошибка формата',
+    'email_repeat' => ' Почтовый ящик повторяется',
+    'email_error' => ' Ошибка формата почтового ящика',
+    'save_success' => ' Сохранить успешно',
+    'save_fail' => ' Ошибка сохранения',
+    'register_success' => ' Регистрация успешно',
+    'register_fail' => ' Ошибка регистрации',
+    'language_success' => ' Переключить язык успешно',
+    'language_fail' => ' Ошибка переключения языка',
+    'param_error' => ' Ошибка параметра',
+    'required_not_null' => ' Обязательное заполнение не может быть пустым.',
+    'picture_not_null' => ' Фотографии не могут быть пустыми',
+    'follow_not_null' => ' Изображение и последующий контент не могут быть пустыми одновременно.X',
+    'contacts_not_null' => ' Контакты, почтовый ящик, телефон не может быть одновременно пустым',
+    'car_type_not_null' => ' Предпочтения не могут быть пустыми',
+    'channel_not_null' => ' Каналы не могут быть пустыми',
+    'email_consistent' => ' Почтовый ящик не совпадает',
+    'sign_not_null' => ' Компания не создана',
+    'password_short' => ' Пароль не может быть меньше 8.',
+    'id_empty' => ' ID не может быть пустым',
+    'customer_id' => ' Идентификатор клиента',
+    'tag_group_id' => ' Идентификатор группы меток',
+    'claim_fail' => ' Невозможность получения принадлежащего клиенту',
+];

resource/translations/zh_CN/messages.php

@@ -6,6 +6,7 @@ return [
     'login_success' => ' 登录成功',
     'password_error' => ' 密码错误',
     'user_none' => ' 用户不存在',
+    'user_id' => ' 用户ID',
     'user_login' => ' 请先登录',
     'not_null' => ' 不能为空',
     'code_error' => ' 验证码错误',
@@ -21,13 +22,15 @@ return [
     'param_error' => ' 参数错误',
     'required_not_null' => ' 必填项不能为空',
     'picture_not_null' => ' 图片不能为空',
+    'follow_not_null' => ' 图片与跟进内容不能同时为空',
     'contacts_not_null' => ' 联系人，邮箱，电话不能同时为空',
     'car_type_not_null' => ' 偏好不能为空',
     'channel_not_null' => ' 渠道不能为空',
     'email_consistent' => ' 邮箱不一致',
     'sign_not_null' => ' 未设置所属公司',
-    'password_short' => ' 密码不能少于6位',
+    'password_short' => ' 密码不能少于8位',
     'id_empty' => ' id不能为空',
     'customer_id' => ' 客户ID',
     'tag_group_id' => ' 标签组ID',
+    'claim_fail' => ' 不能领取有归属客户',
 ];