package com.ibeetl.admin.console.service;

import com.google.gson.Gson;
import com.ibeetl.admin.console.dao.FundManagementApiDao;
import com.ibeetl.admin.console.dao.MoneyConsoleDao;
import com.ibeetl.admin.console.dao.OperateManageDao;
import com.ibeetl.admin.console.dao.SettingConsoleDao;
import com.ibeetl.admin.console.model.*;
import com.ibeetl.admin.console.util.DateUtil;
import com.ibeetl.admin.console.util.DoubleUtil;
import com.ibeetl.admin.core.entity.CoreSetMoney;
import com.ibeetl.admin.core.entity.CoreUser;
import com.ibeetl.admin.core.entity.XzxCityPartner;
import com.ibeetl.admin.core.service.CoreBaseService;
import com.ibeetl.admin.core.service.CorePlatformService;
import com.ibeetl.admin.core.web.JsonResult;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.lang3.StringUtils;
import org.beetl.sql.core.engine.PageQuery;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestBody;

import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.*;

@Service
@Transactional
public class FundManagementApiService extends CoreBaseService<CoreSetMoney> {

    Logger log = LoggerFactory.getLogger(this.getClass());
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    static SimpleDateFormat sdf2 = new SimpleDateFormat("yyyy-MM-dd");
    @Autowired
    FundManagementApiDao dao;
    @Autowired
    RedisService redisService;
    @Autowired
    CuserConsoleService service;
    @Autowired
    MoneyConsoleDao moneyConsoleDao;
    @Autowired
    XzxCityPartnerService cityPartnerService;
    @Autowired
    CorePlatformService platformService;
    final Base64 base64 = new Base64();

    /**
     * 查询提现列表
     * @param moneyModel
     * @return
     */
    public JsonResult<Map<String, Object>> queryFundManagementList(MoneyModel moneyModel){

        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        moneyModel.setPartnerIds(partnerIds);
        Map<String, Object> map = new HashMap<>();
        int p = moneyModel.getPage();
        p = (p - 1) * moneyModel.getLimit();
        moneyModel.setPage(p);
        if(!StringUtils.isEmpty(moneyModel.getNickName())){
            moneyModel.setNickName(new String(Base64.encodeBase64(moneyModel.getNickName().getBytes())));
        }
        List<MoneyModel> list = dao.queryMoneyList(moneyModel);
        List<String> payOrderIds = new ArrayList<>();
        for (MoneyModel model:list) {
            payOrderIds.add(model.getPayOrderId());
        }
        CoreUser currentUser = platformService.getCurrentUser();
        XzxCityPartner pa = cityPartnerService.queryById(currentUser.getId());
        String todaySuccess ="0";
        String today="0";
        if(moneyModel.getPayType()!="9"){

            MoneyModel m1 = new MoneyModel();
            m1.setStartTime(sdf2.format(new Date())+" 00:00:00");
            m1.setEndTime(sdf2.format(new Date())+" 23:59:59");
            m1.setStatus("2");
            if(payOrderIds.size()>0){
                m1.setPayOrderIds(payOrderIds);
                todaySuccess = dao.queryMoneyTodayList(m1);
            }

            if(null!=todaySuccess&&!"".equals(todaySuccess)){
                map.put("todaySuccess",DoubleUtil.roundTwo(todaySuccess));
            }else{
                map.put("todaySuccess",0);
            }
            MoneyModel m2 = new MoneyModel();
            m2.setStartTime(sdf2.format(new Date())+" 00:00:00");
            m2.setEndTime(sdf2.format(new Date())+" 23:59:59");

            if(payOrderIds.size()>0){
                m2.setPayOrderIds(payOrderIds);
                today = dao.queryMoneyTodayList(m2);
            }


            if(null!=today&&!"".equals(today)){
                map.put("today",DoubleUtil.roundTwo(today));
            }else{
                map.put("today",0);
            }

        }
        //APPROVAL_TYPE
        String approvalType = dao.queryApprovalType();
        for (MoneyModel model:list) {
            model.setApprovalType(approvalType);
            String userId = model.getCreateUserId();
            //查询当前额度
            UserAccountModel model1 = dao.getAccountByUserId(userId);
            if(null!=model1){
                if(model.getPayType().equals("9")){
                    if(null!=model.getOrderId()&&!"".equals(model.getOrderId())){
                        AccountLogModel accountLogModel = dao.getAccountLogByOrderId(model.getPayOrderId());
                        model.setOverdraftLimit(accountLogModel.getOldLimit());
                    }else{
                        model.setOverdraftLimit(model1.getOverdraftLimit());
                    }
                    model.setFixedLimit(model1.getFixedLimit());
                }else{
                    model.setFixedLimit(model1.getFixedLimit());
                    model.setOverdraftLimit(model1.getOverdraftLimit());
                }

            }else{
                model.setFixedLimit("0");
                model.setOverdraftLimit("0");
            }

            //Map<String,Object> accountlog = dao.queryOldLimitMap(model1.getAccountId());
            try {
                String nickName = "";
                if(model.getUserType().equals("1")){
                    if(model.getNickName()!=null){
                        nickName =new String(base64.decode(model.getNickName()), "UTF-8");

                    }
                }else{
                    nickName = model.getNickName();
                }

                model.setNickName(nickName);
            } catch (UnsupportedEncodingException e) {
                e.printStackTrace();
            }
            if(model.getPayType().equals("7")){

                UserModel userModel = service.queryUserById(userId);
                if (userModel == null) {
                    userModel = service.queryUserOtherInfoById(userId);
                }
                if(userModel!=null){
                    model.setName(userModel.getName());
                    model.setMobilePhone(userModel.getMobilePhone());
                }else{
                    model.setName("--");
                    model.setMobilePhone("--");
                }


            }else if(model.getPayType().equals("9")){
                //查询回收员名称和手机号
                String userType = "";
                UserModel userModel = service.queryUserById(userId);
                if (userModel == null) {
                    userModel = service.queryUserOtherInfoById(userId);
                }
                if(!"1".equals(userType)){
                    String roleName = moneyConsoleDao.queryPayInfoUserRole(userType);
                    model.setRoleName(roleName);
                }else{
                    model.setRoleName("普通用户");
                }
                if(null!=userModel){
                    model.setName(userModel.getName());
                    model.setMobilePhone(userModel.getMobilePhone());
                }else{
                    model.setName("--");
                    model.setMobilePhone("--");
                }

            }

        }
        int count = dao.queryMoneyListCount(moneyModel);
        map.put("data", list);
        map.put("count", count);
        map.put("code", 0);

        return JsonResult.success(map);
    }


    public JsonResult<Map<String,Object>> queryPayInfoDetailApi(MoneyModel moneyModel){
        Map<String,Object> map = new HashMap<>();
            if(moneyModel.getUserType().equals("1")){
                map =  dao.queryPayInfoDetail(moneyModel.getPayOrderId());
            }else{
                map =  dao.queryPayInfoDetailHS(moneyModel.getPayOrderId());
            }
        

        String userId = map.get("createUserId").toString();

        UserModel userModel = new UserModel();
        PayRequestInfoModel model = new PayRequestInfoModel();

        //提现审核详情需要查询用户订单列表（只能手机号关联）
        if(moneyModel.getUserType().equals("1")){
             userModel = service.queryUserById(userId);
        }else{
             userModel = service.queryUserOtherById(userId);
             model.setReceiverPhone(userModel.getMobilePhone());
        }
        String phone = userModel.getMobilePhone();
        if(null!=model.getReceiverPhone()&&!"".equals(model.getReceiverPhone())){
            model.setPhone("");
        }else{
            model.setPhone(phone);

        }
        int p = moneyModel.getPage();
        p = (p - 1) * moneyModel.getLimit();
        model.setPage(p);
        model.setLimit(moneyModel.getLimit());
        List<PayRequestInfoModel> orderList = dao.queryUserOrderList(model);
        for (PayRequestInfoModel reqModel:orderList) {
            reqModel.setWeight(DoubleUtil.roundThree(reqModel.getWeight()));
            reqModel.setMoney(DoubleUtil.roundTwo(reqModel.getMoney()));
        }
        map.put("data",orderList);
        map.put("count",dao.queryUserOrderCount(model));
        map.put("code",0);

        List<Map<String,Object>> totalMap = dao.queryUserOrderMoneyAndWeight(model);
        BigDecimal totalmoney = new BigDecimal("0");
        BigDecimal totalweight = new BigDecimal("0");
        for (Map<String,Object> mw:totalMap) {
            totalmoney = new BigDecimal(mw.get("money").toString()).add(totalmoney);
            totalweight = new BigDecimal(mw.get("weight").toString()).add(totalweight);
        }

        map.put("totalMoney", DoubleUtil.roundTwo(totalmoney.toString()));
        map.put("totalWeight",DoubleUtil.roundThree(totalweight.toString()));

        if(!"1".equals(map.get("usertype"))){
            String roleName = dao.queryPayInfoUserRole(map.get("usertype").toString());
            map.put("roleName",roleName);
        }else{
            map.put("roleName","普通用户");
        }

        if(map.get("status").equals("2")){
            map.put("statusName","已审核");
        }else if(map.get("status").equals("3")){
            map.put("statusName","审核未通过");
        }else{
            map.put("statusName","待审核");
        }
        //订单号，时间，重量，金额
        return JsonResult.success(map);
    }

    /**
     * 查询充值记录
     * @param moneyModel
     */
    public Map<String, Object> queryRechangeApiList(MoneyModel moneyModel){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        moneyModel.setPartnerIds(partnerIds);
        int p = moneyModel.getPage();
        p = (p - 1) * moneyModel.getLimit();
        moneyModel.setPage(p);

        if(!StringUtils.isEmpty(moneyModel.getNickName())){
            moneyModel.setPartnerName(moneyModel.getNickName());
            moneyModel.setMobilePhone(moneyModel.getNickName());
            moneyModel.setNickName(new String(Base64.encodeBase64(moneyModel.getNickName().getBytes())));
        }
        moneyModel.setPayType("1");
        Map<String, Object> m = new HashMap<>();
        //queryRechangeMoney
        String startTime =sdf2.format(new Date())+" 00:00:00";
        String endTime =sdf2.format(new Date())+" 23:59:59";
        List<String> statusList = new ArrayList<>();
        List<String> statusList1 = new ArrayList<>();

        statusList.add("1");
        statusList.add("2");
        statusList.add("3");
        statusList.add("4");
        statusList.add("5");
        //statusList.add("")
        String today = dao.queryRechangeMoney(statusList,"1",startTime,endTime,partnerIds);
        statusList1.add("2");
        statusList1.add("3");
        String todaySuccess = dao.queryRechangeMoney(statusList1,"1",startTime,endTime,partnerIds);;
       if( today==null || today.equals("")){
           today="0";
       }
        if( todaySuccess==null || todaySuccess.equals("")){
            todaySuccess="0";
        }
        //String todayT =new BigDecimal(today).add(new BigDecimal(todaySuccess)).toString();
        m.put("today",DoubleUtil.roundTwo(today));
        m.put("todaySuccess",DoubleUtil.roundTwo(todaySuccess));

        List<MoneyModel>  list1 =  dao.queryRechangeApiList(moneyModel);
        for (MoneyModel model:list1) {
            String nickName = "";
            model.setMoney(DoubleUtil.roundTwo(model.getMoney()));
            if(null!=model.getPartnerName()&&!"".equals(model.getPartnerName())){
                String payOrderId=model.getPayOrderId();
                nickName = model.getPartnerName();
                model.setMobilePhone(model.getPartnerPhone());
                if(model.getPartnerType().equals("1")){
                    model.setRoleName("城市合伙人");
                }else{
                    model.setRoleName("打包站");
                }
                RemittanceModel remittanceModel = dao.queryRemittanceInfo(payOrderId);
                model.setRemittanceModel(remittanceModel);
                if(null==model.getFee()){
                    model.setFee("0");
                }
                BigDecimal fee = new BigDecimal(model.getFee());
                model.setFee(DoubleUtil.roundTwo(fee.toString()));
            }else{
                try {
                    if(model.getNickName()!=null){
                        nickName = new String(base64.decode(model.getNickName()), "UTF-8");

                    }
                    if(null==model.getFee()){
                        model.setFee("0");
                    }
                    BigDecimal fee = new BigDecimal(model.getFee());
                    BigDecimal tMoney = new BigDecimal(model.getMoney());
                    model.setMoney(DoubleUtil.roundTwo(tMoney.toString()));
                    model.setFee(DoubleUtil.roundTwo(fee.toString()));
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
            }
            model.setNickName(nickName);
        }
        m.put("data", list1);
        m.put("count", dao.queryRechangeListApiCount(moneyModel));
        m.put("code", 0);
        return m;
    }

    public Map<String, Object> queryRechangeApiDetail(PayInfoModel model){
        PayInfoModel result = dao.queryRechangeApiDetail(model);
        Map<String, Object> map = new HashMap<>();
        if(null!=result){
            map.put("data",result);
            map.put("code",0);
            map.put("msg","查询成功");
        }else{
            map.put("code",-1);
            map.put("msg","查询失败");
        }
        return map;
    }
    public Map<String,Object> queryStorageMoneyDetailApi(PayStorageModel model) {
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);
        //查询订单列表
        String orderIds = dao.queryUserOrderByStorageId(model.getStorageId());
        String[] orderIdList = orderIds.split(",");
        List<String> orderList = new ArrayList<>();
        for (String orderId:orderIdList) {
            orderList.add(orderId);
        }
        List<PayRequestInfoModel> list = dao.queryStorageMoneyDetailApi(orderList,model.getLimit(),p);
        Map<String,Object> remap = new HashMap<>();

        List<Map<String,Object>> totalMap = dao.queryMoneyAndWeightByOrderIds(orderList);
        BigDecimal totalmoney = new BigDecimal("0");
        //BigDecimal totalweight = new BigDecimal("0");
        for (Map<String,Object> mw:totalMap) {
            totalmoney = new BigDecimal(mw.get("money").toString()).add(totalmoney);
            //totalweight = new BigDecimal(mw.get("weight").toString()).add(totalweight);
        }
        remap.put("totalmoney",totalmoney);
        remap.put("code",0);
        remap.put("data",list);
        remap.put("count",orderList.size());
        return remap;
    }
    public Map<String,Object> quotaDetail(StorageUserModel model) {
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);
        List<StorageUserModel> list = dao.quotaDetail(model);
        Map<String,Object> map = new HashMap<>();
        map.put("data",list);
        map.put("code",0);
        map.put("count",dao.quotaDetailCount(model));
        return map;
    }

    public Map<String,Object> queryStorageMoneyApi(PayStorageModel model){
        List<String> partnerIds = cityPartnerService.queryPartnerByCurrent();
        int p = model.getPage();
        p = (p - 1) * model.getLimit();
        model.setPage(p);
        model.setPartnerIds(partnerIds);
        List<PayStorageModel> modelList = dao.queryStorageMoneyApi(model);
        Map<String,Object> remap = new HashMap<>();

        //今日支出 日均支出 总支出
        PayStorageModel todayModel = new PayStorageModel();
        todayModel.setStartTime(sdf2.format(new Date())+" 00:00:00");
        todayModel.setEndTime(sdf2.format(new Date())+" 23:59:59");
        todayModel.setPartnerIds(partnerIds);
        String today = dao.queryStorageMoneyToday(todayModel);

        PayStorageModel todayModel1 = new PayStorageModel();
        todayModel1.setPartnerIds(partnerIds);
        String totalPay = dao.queryStorageMoneyToday(todayModel1);
        //计算日均支出
        String endTimeStr = dao.endStorageTime();
        int num = 0;
        BigDecimal avel = new BigDecimal("0");
        try {
             if(null!=endTimeStr&&!"".equals(endTimeStr)){
                 num = DateUtil.daysBetween(endTimeStr,sdf2.format(new Date()));

             }else{
                 num = 0 ;
             }
            if(null!=totalPay){
                if(num!=0){
                    avel  = new BigDecimal(totalPay).divide(new BigDecimal(num), 2, RoundingMode.HALF_UP);
                }else{
                    avel  = new BigDecimal(totalPay).divide(new BigDecimal("1"), 2, RoundingMode.HALF_UP);
                }
            }else{
                totalPay = "0";
            }
        } catch (ParseException e) {
            e.printStackTrace();
        }
        if(today==null){
            today="0";
        }
        remap.put("todayPay",today);
        remap.put("totalPay",totalPay);
        remap.put("averagePay",avel);
        if(null!=modelList&&modelList.size()>0){
            for (PayStorageModel resModel:modelList) {
                if(!StringUtils.isEmpty(resModel.getStorageUserName())){
                    try {
                        if(DateUtil.isBase64(resModel.getStorageUserName())){
                            resModel.setStorageUserName(new String(base64.decode(resModel.getStorageUserName()), "UTF-8"));
                        }else{
                            resModel.setStorageUserName(resModel.getStorageUserName());
                        }
                    } catch (UnsupportedEncodingException e) {
                        e.printStackTrace();
                    }
                }
            }
            remap.put("code",0);
            remap.put("data",modelList);
            remap.put("count",dao.queryStorageMoneyApiCount(model));
            remap.put("msg","返回成功");
        }else{
            remap.put("code",-1);
            remap.put("msg","没有记录");
        }
        return remap;

    }
}