<?php

namespace App\Http\Controllers\API\H5;

use App\Http\Controllers\API\AspNetZhuanController;
use App\Http\Controllers\API\XCXApiController;
use App\Http\Controllers\Controller;
use App\Services\ConfigService;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;

class UserController extends Controller
{
  public function hunjian(Request $request)
  {
    $person_id = $request->post('person_id');
    $user_info = DB::table('web_user_person')->where(['id' => $person_id])->first();
    $res = false;
    if (!!$user_info) {
      $dnet = new AspNetZhuanController();
      $res = $dnet->GetPersonInfo([
        "ghzid" => $user_info->ghzid,
        "action" => "1"
      ]);
    }
    $id_type_map = [
      '居民身份证' => '1'
    ];
    $person_info = [
      '姓名' => ''
    ];
    if (!!$res && count($res) != 0) {
      $res = $res[0];
      $person_info  = [
        '国籍' => $res['MZ'] == '外国血统' ? '外国' : '中国',
        '证件类型' => 1,
        '证件号' => $res['ID_No'] ?? '',
        '姓名' => $res['Patname'] ?? '',
        '生日' => $res['Patbdate'] ? date('Y-m-d', strtotime($res['Patbdate'])) : date('Y-m-d'),
        '民族' => $res['MZ'] ?? '',
        '现地址省市区' => [
          [
            'value' => '11',
            'text' => '北京市'
          ],
          [
            'value' => '1101',
            'text' => '市辖区'
          ],
          [
            'value' => '110101',
            'text' => '东城区'
          ],
        ],
        '现地址' => $res['Address'] ?? '',
        '详细地址省市区' => [
          [
            'value' => '11',
            'text' => '北京市'
          ],
          [
            'value' => '1101',
            'text' => '市辖区'
          ],
          [
            'value' => '110101',
            'text' => '东城区'
          ],
        ],
        '详细地址' => $res['Fulladdress'] ?? '',
        '户籍地址省市区' => [
          [
            'value' => '11',
            'text' => '北京市'
          ],
          [
            'value' => '1101',
            'text' => '市辖区'
          ],
          [
            'value' => '110101',
            'text' => '东城区'
          ],
        ],
        '户籍地址' => '',
        '工作单位' => "",
        '文化程度' => "",
        '职业' => "",
        '出生地' => "",
        '配偶姓名' => "",
        '配偶证件类型' => 0,
        '配偶证件号' => "",
        '血缘关系' => "无",
        '邮政编码' => "",
        '手机号码' => $res['Mobile'] ?? '',
      ];
    }
    return \Yz::Return(true, '获取成功', [
      'info' => $person_info
    ]);
  }
  // 获取配置更新时间
  public function info(Request $request)
  {
    $openid = $request->post('openid');
    if (!isset($openid)) return \Yz::echoError1("openid不能为空");
    $user = DB::table('web_users')->where(['openid' => $openid])->first();
    $userid = false;
    if (!$user) {
      $userid = DB::table('web_users')->insertGetId(['openid' => $openid]);
    } else {
      $userid = $user->id;
    }
    if ($userid) {
      if (self::UpdatePersonList($openid)) { //调用更新就诊人方法
        //查询默认就诊人
        $person_list = DB::table('web_user_person')->where(['user_id' => $userid, 'is_del' => 0])->get();
        $default_person = DB::table('web_user_person')->where(['user_id' => $userid, 'is_default' => 1, 'is_del' => 0])->first();
        $count = count($person_list);
        if ($count > 0 and !$default_person) {
          DB::table('web_user_person')->where(['id' => $person_list[0]->id])->update(['is_default' => 1]);
          $default_person = $person_list[0];
        }

        $info = [
          'name' => isset($default_person->name) ? $default_person->name : null,
          'sex' => isset($default_person->sex) ? $default_person->sex : null,
          'phone' => $default_person->phone,
          'id_number' => $default_person->id_number,
          'count' => $count,
          'openid' => $openid,
          'person_id' => $default_person->id,
          'married' => $default_person->married
        ];
        return \Yz::Return(true, '获取成功', [
          'info' => $info
        ]);
      }
    }
  }

  //获取名下体检人列表
  public function GetPersonList()
  {
    $openid = request('openid');
    $user = DB::table('web_users')->where(['openid' => $openid, 'status' => 1, 'is_del' => 0])->first();
    if (!$user) return \Yz::echoError1('用户不存在');
    $persons = DB::table('web_user_person')->where(['user_id' => $user->id, 'is_del' => 0])->get();
    return \Yz::Return(true, "查询完成", ['list' => $persons]);
  }

  //切换默认就诊人
  public function SetDefaultPerson()
  {
    $openid = request('openid');
    $person_id = request('person_id');
    $user = DB::table('web_users')->where(['openid' => $openid, 'status' => 1, 'is_del' => 0])->first();
    if (!$user) return \Yz::echoError1('用户不存在');
    DB::table('web_user_person')->where(['user_id' => $user->id, 'is_del' => 0, 'is_default' => 1])->update([
      'is_default' => 2
    ]);
    $u = DB::table('web_user_person')->where(['id' => $person_id, 'user_id' => $user->id, 'is_del' => 0])->update([
      'is_default' => 1
    ]);
    if ($u) {
      return \Yz::Return(true, "操作完成", []);
    } else {
      return \Yz::echoError1('操作失败');
    }
  }

  //获取就诊人基本信息 积分、预存款等
  public function GetPersonInfo()
  {
    $openid = request('openid');
    $person_id = request('person_id');
    $user = DB::table('web_users')->where(['openid' => $openid, 'status' => 1, 'is_del' => 0])->first();
    if (!$user) return \Yz::echoError1('用户不存在');
    $person = DB::table('web_user_person')->where(['user_id' => $user->id, 'is_del' => 0, 'is_default' => 1])->first();
    if (!$person) return \Yz::echoError1('查询就就诊人信息出错');
    //调用his接口查询用户积分和预存款
    $integral = 90;
    $save_money = 150;
    $coupon_count = 2; //优惠券数量

    $person->integral = $integral;
    $person->save_money = $save_money;
    $person->coupon_count = $coupon_count;
    return \Yz::Return(true, "查询完成", ['person_info' => $person]);
  }

  public function tttt()
  {
    $XCX = new XCXApiController();
    $data = [
      'wxid' => 'oosgJj-SVIxTrm_g1p213tsSHK5g'
    ];
    $res = $XCX::Post('就诊人列表', $data);
    $ApiPersonList = $res['data'];
    //dd($ApiPersonList[0]);
    $XCX::XCXDecode($ApiPersonList[0]['idNumber']);
  }
  //更新用户列表，调用远程小程序接口
  public function UpdatePersonList($openid)
  {
    $env = config('app.globals.Env');
    if ($env == 'pro') {   //如果是正式环境
      $XCX = new XCXApiController();
      $data = [
        'wxid' => $openid
      ];
      $res = $XCX::Post('就诊人列表', $data);
      $ApiPersonList = $res['data'];
      // dd($ApiPersonList);
    }
    if ($env == 'dev') { //如果是开发环境
      $ApiPersonList = [
        [
          'ghzid' => 'ghz11',
          'idNumber' => '15210219920524154X',
          'name' => '周京京',
          'phone' => '11111111111',
          'sex' => '1',
          'birthday' => '1989-01-01',
          'patientType' => '0',
          'marriage' => '1',
        ],
        [
          'ghzid' => 'ghz22',
          'idNumber' => '460026199002190013',
          'name' => '测试2',
          'phone' => '222222222',
          'sex' => '1',
          'birthday' => '1990-01-01',
          'patientType' => '1',
          'marriage' => '1',
        ],
        [
          'ghzid' => 'ghz22555',
          'idNumber' => '411329199901052356',
          'name' => '信息科1',
          'phone' => '222222222',
          'sex' => '1',
          'birthday' => '1990-01-01',
          'patientType' => '1',
          'marriage' => '1',
        ]
      ];
    }


    $user = DB::table('web_users')->where(['openid' => $openid, 'status' => 1, 'is_del' => 0])->first();
    if (!$user) return \Yz::echoError1('用户不存在');
    //库里存在的用户ghzid数组
    $db_person_ghzids = DB::table('web_user_person')->where(['user_id' => $user->id, 'is_del' => 0])->pluck('ghzid')->toArray();
    //接口返回的用户ghzids数组
    $api_person_ghzids = [];
    foreach ($ApiPersonList as $apiperson) {
      $api_person_ghzids[] = $apiperson['ghzid'];
    }
    // 取交集
    $intersection = array_intersect($db_person_ghzids, $api_person_ghzids);
    // 仅存在于 数据库里 中的ghzid
    $onlyInDb = array_diff($db_person_ghzids, $api_person_ghzids);
    // 仅存在于 api接口 中的ghzid
    $onlyInApi = array_diff($api_person_ghzids, $db_person_ghzids);
    $success_count = 0;
    foreach ($ApiPersonList as $apiperson) {
      $marriage = 0;
      if ($apiperson['marriage'] == '未婚') {
        $marriage = 2;
      }
      if ($apiperson['marriage'] == '已婚') {
        $marriage = 1;
      }
      $personInfo = [
        'ghzid' => $apiperson['ghzid'],
        'id_number' => $env == 'dev' ? $apiperson['idNumber'] : $XCX::XCXDecode($apiperson['idNumber']),
        'name' => $apiperson['name'],
        'birthday' => $apiperson['birthday'],
        'sex' => $apiperson['sex'],
        'phone' =>  $env == 'dev' ? $apiperson['phone'] : $XCX::XCXDecode($apiperson['phone']),
        'married' => $marriage,
        'user_id' => $user->id,
        'patient_type' => $apiperson['patientType'],
        'updated_at' => date('Y-m-d H:i:s')
      ];
      if (in_array($apiperson['ghzid'], $intersection)) { //双方都有的，更新
        $u = DB::table('web_user_person')->where(['user_id' => $user->id, 'ghzid' => $apiperson['ghzid']])->update($personInfo);
        if ($u) $success_count += $u;
      }
      if (in_array($apiperson['ghzid'], $onlyInApi)) { //小程序新增的 添加
        $i = DB::table('web_user_person')->insert($personInfo);
        if ($i) $success_count++;
      }
    }

    if (count($onlyInDb) > 0) { //小程序不存在的用户 ，数据进行删除
      $d = DB::table('web_user_person')->where(['user_id' => $user->id])->whereIn('ghzid', $onlyInDb)->update([
        'is_del' => 1
      ]);
      if ($d) $success_count++;
    }
    //设置默认体检人
    //    $default=DB::table('web_user_person')->where(['user_id' => $user->id,'is_del'=>0,'is_default'=>1])->get();
    //    $p_list=DB::table('web_user_person')->where(['user_id' => $user->id,'is_del'=>0])->get();
    //    if(count($p_list)>0 and  count($default)===0){
    //      DB::table('web_user_person')->where(['id'=>$p_list[0]->id])->update(['is_default'=>1]);
    //    }
    return true;
  }
}