package com.deloitte.system.service;

import cn.hutool.core.collection.CollectionUtil;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSONArray;
import com.common.core.constant.GlobalConst;
import com.common.core.enums.ResultCodeEnum;
import com.common.core.exception.BizException;
import com.common.core.service.CryptoService;
import com.common.core.utils.*;
import com.common.redis.util.RedisUtil;
import com.deloitte.system.model.CacheList;
import com.deloitte.system.model.Contact;
import com.deloitte.system.request.ContactDto;
import com.deloitte.system.request.ContactSearchDto;
import com.jfinal.plugin.activerecord.Db;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;

import static com.common.core.constant.GlobalConst.PIPL_UNCONFIRM_INSERT;
import static com.common.core.constant.GlobalConst.PIPL_UNCONFIRM_UPDATE;



@Service
public class ContactService {

    private String tableName = "contact";

    @Autowired
    private CryptoService cryptoService;

    @Autowired
    private IdUtils idWorker;

    @Autowired
    private RedisUtil redisUtil;


    public ContactDto queryForOne(String dataId) {
        Contact contact = Contact.dao.findById(dataId);
        if (!ObjectUtil.isEmpty(contact)) {
            return BeanHelper.copyAs(contact,ContactDto.class);
        }
        return null;
    }

    public List<ContactDto> insertList(List<ContactDto> contactList, String txId) {
        List<ContactDto> respList = new ArrayList<>();
        CacheList<ContactDto> dtoCacheList = new CacheList<>();
        dtoCacheList.setTableName(tableName);
        List<ContactDto> dtoItemList = new ArrayList<>();
        contactList.forEach(e -> {
            String dataId = idWorker.nextId();
            ContactDto cacheItem = BeanHelper.copyAs(e, ContactDto.class);
            cacheItem.setDataId(dataId);
            dtoItemList.add(cacheItem);

            ContactDto target = BeanHelper.copyAs(e, ContactDto.class);
            target.setDataId(dataId);
            ContactDto dto = cryptoService.encryptModelColumns(e);
            dto.setDataId(dataId);
            target.setFirstNameEncrypt(dto.getFirstName());
            target.setLastNameEncrypt(dto.getLastName());
            target.setPostcodeEncrypt(dto.getPostcode());
            target.setPostcodeDEncrypt(dto.getPostcodeD());
            target.setTitleDEncrypt(dto.getTitleD());
            target.setTitleEncrypt(dto.getTitle());
            target.setContactEnglishNameEncrypt(dto.getContactEnglishName());
            target.setEnglishAddressEncrypt(dto.getEnglishAddress());
            target.setAddress1Encrypt(dto.getAddress1());
            target.setAddress2Encrypt(dto.getAddress2());
            target.setAddress3Encrypt(dto.getAddress3());
            target.setAddress1DEncrypt(dto.getAddress1D());
            target.setAddress2DEncrypt(dto.getAddress2D());
            target.setAddress3DEncrypt(dto.getAddress3D());
            target.setFaxEncrypt(dto.getFax());
            target.setFaxDEncrypt(dto.getFaxD());
            target.setEmailDEncrypt(dto.getEmailD());
            target.setEmailEncrypt(dto.getEmail());
            target.setMobilePhoneDEncrypt(dto.getMobilePhoneD());
            target.setOtherPhoneDEncrypt(dto.getOtherPhoneD());
            target.setOtherPhoneDEncrypt(dto.getOtherPhoneD());
            target.setPhoneDEncrypt(dto.getPhoneD());
            target.setHomePhoneEncrypt(dto.getHomePhone());
            target.setMobilePhoneEncrypt(dto.getMobilePhone());
            target.setOtherPhoneEncrypt(dto.getOtherPhone());
            target.setPhoneEncrypt(dto.getPhone());
            DesensitiveUtils.format(target);
            respList.add(target);
        });
        dtoCacheList.setData(dtoItemList);
        String insertJsonString = JSONArray.toJSONString(dtoCacheList);
        String insertKey = PIPL_UNCONFIRM_INSERT + txId;
        boolean redisFlag = redisUtil.set(insertKey, insertJsonString, GlobalConst.DATA_EXPIRE);
        if (!redisFlag) {
            throw new BizException("缓存写入失败");
        }
        return respList;
    }

    /** 不存缓存，直接入库 **/
    public List<ContactDto> batchInsert(List<ContactDto> contactList) {
        List<ContactDto> respList = new ArrayList<>();
        CacheList<ContactDto> dtoCacheList = new CacheList<>();
        dtoCacheList.setTableName(tableName);
        Db.tx(() -> {
            for (ContactDto e : contactList) {
                String dataId = idWorker.nextId();
                e.setDataId(dataId);
                Contact item= BeanHelper.copyAs(e, Contact.class);
                item.set("id", dataId);
                if (!item.save()) {
                    throw new BizException(ResultCodeEnum.RT_ERROR);
                }
                ContactDto target = BeanHelper.copyAs(e, ContactDto.class);
                target.setDataId(dataId);
                ContactDto dto = cryptoService.encryptModelColumns(e);
                dto.setDataId(dataId);
                target.setFirstNameEncrypt(dto.getFirstName());
                target.setLastNameEncrypt(dto.getLastName());
                target.setPostcodeEncrypt(dto.getPostcode());
                target.setPostcodeDEncrypt(dto.getPostcodeD());
                target.setTitleDEncrypt(dto.getTitleD());
                target.setTitleEncrypt(dto.getTitle());
                target.setContactEnglishNameEncrypt(dto.getContactEnglishName());
                target.setEnglishAddressEncrypt(dto.getEnglishAddress());
                target.setAddress1Encrypt(dto.getAddress1());
                target.setAddress2Encrypt(dto.getAddress2());
                target.setAddress3Encrypt(dto.getAddress3());
                target.setAddress1DEncrypt(dto.getAddress1D());
                target.setAddress2DEncrypt(dto.getAddress2D());
                target.setAddress3DEncrypt(dto.getAddress3D());
                target.setFaxEncrypt(dto.getFax());
                target.setFaxDEncrypt(dto.getFaxD());
                target.setEmailDEncrypt(dto.getEmailD());
                target.setEmailEncrypt(dto.getEmail());
                target.setMobilePhoneDEncrypt(dto.getMobilePhoneD());
                target.setOtherPhoneDEncrypt(dto.getOtherPhoneD());
                target.setOtherPhoneDEncrypt(dto.getOtherPhoneD());
                target.setPhoneDEncrypt(dto.getPhoneD());
                target.setHomePhoneEncrypt(dto.getHomePhone());
                target.setMobilePhoneEncrypt(dto.getMobilePhone());
                target.setOtherPhoneEncrypt(dto.getOtherPhone());
                target.setPhoneEncrypt(dto.getPhone());
                DesensitiveUtils.format(target);
                respList.add(target);
            }
            return true;
        });
        return respList;
    }

    public List<ContactDto> updateList(List<ContactDto> contactList, String txId) {
        List<ContactDto> respList = new ArrayList<>();
        CacheList<ContactDto> dtoCacheList = new CacheList<>();
        dtoCacheList.setTableName(tableName);
        List<ContactDto> dtoItemList = new ArrayList<>();
        contactList.forEach(e -> {
            Contact contact = Contact.dao.findById(e.getDataId());
            ContactDto cacheItem = BeanHelper.copyAs(e, ContactDto.class);
            dtoItemList.add(cacheItem);
            ContactDto dto =BeanHelper.copyAs(BeanHelper.copy(cacheItem,contact),ContactDto.class);
            ContactDto target = BeanHelper.copyAs(dto, ContactDto.class);
            dto = cryptoService.encryptModelColumns(dto);
            target.setFirstNameEncrypt(dto.getFirstName());
            target.setLastNameEncrypt(dto.getLastName());
            target.setPostcodeEncrypt(dto.getPostcode());
            target.setPostcodeDEncrypt(dto.getPostcodeD());
            target.setTitleDEncrypt(dto.getTitleD());
            target.setTitleEncrypt(dto.getTitle());
            target.setContactEnglishNameEncrypt(dto.getContactEnglishName());
            target.setEnglishAddressEncrypt(dto.getEnglishAddress());
            target.setAddress1Encrypt(dto.getAddress1());
            target.setAddress2Encrypt(dto.getAddress2());
            target.setAddress3Encrypt(dto.getAddress3());
            target.setAddress1DEncrypt(dto.getAddress1D());
            target.setAddress2DEncrypt(dto.getAddress2D());
            target.setAddress3DEncrypt(dto.getAddress3D());
            target.setFaxEncrypt(dto.getFax());
            target.setFaxDEncrypt(dto.getFaxD());
            target.setEmailDEncrypt(dto.getEmailD());
            target.setEmailEncrypt(dto.getEmail());
            target.setMobilePhoneDEncrypt(dto.getMobilePhoneD());
            target.setOtherPhoneDEncrypt(dto.getOtherPhoneD());
            target.setPhoneDEncrypt(dto.getPhoneD());
            target.setPhoneEncrypt(dto.getPhone());
            target.setHomePhoneEncrypt(dto.getHomePhone());
            target.setMobilePhoneEncrypt(dto.getMobilePhone());
            target.setOtherPhoneEncrypt(dto.getOtherPhone());


            DesensitiveUtils.format(target);
            respList.add(target);
        });
        dtoCacheList.setData(dtoItemList);
        String updateJsonString = JSONArray.toJSONString(dtoCacheList);
        String updateKey = PIPL_UNCONFIRM_UPDATE + txId;
        boolean redisFlag = redisUtil.set(updateKey, updateJsonString,GlobalConst.DATA_EXPIRE);
        if (!redisFlag) {
            throw new BizException("缓存写入失败");
        }
        return respList;
    }

    public Boolean deleteOne(String dataId) {
        Contact contact = Contact.dao.findById(dataId);
        contact.setIsDelete(1);
        return contact.saveOrUpdate();
    }

    public Boolean undeleteOne(String dataId) {
        Contact contact = Contact.dao.findById(dataId);
        contact.setIsDelete(0);
        return contact.saveOrUpdate();
    }

    public List<ContactDto> searchList(ContactSearchDto searchDto) {
        List<String> dataIds = searchDto.getDataIds();
        String contactName = searchDto.getContactName();
        StringBuilder queryParam = new StringBuilder();
        if (CollectionUtil.isEmpty(dataIds) && StringUtils.isEmpty(contactName)) {
            //参数都为空，直接返回Null
            return null;
        } else {
            if(CollectionUtil.isNotEmpty(dataIds)){
                queryParam.append("and id in").append(dataIds.stream().collect(Collectors.joining(", ", "(", ")")));
            }
            if(StringUtils.isNotEmpty(contactName)) {
                queryParam.append("and last_name like ").append("\'%").append(contactName).append("%\'");
            }
            List<Contact> contactList = Contact.dao.findList(queryParam.toString());
            return contactList.stream()
                    .map(contact -> BeanHelper.copyAs(contact,ContactDto.class)).collect(Collectors.toList());
        }
    }

    public List<ContactDto> decryptUpdate(List<ContactDto> contactList) {
        List<ContactDto> respList =new ArrayList<>();
        String[] decryptColumn =new String[]{"first_name","last_name","postcode","postcode_d","title_d","title","phone","address3_d","address2_d","address1_d","address3","address2","address1",
        "english_address","contact_english_name","other_phone","mobile_phone","home_phone","phone_d","other_phone_d","mobile_phone_d","email","email_d","fax_d","fax"};
        Db.tx(() -> {
            for (ContactDto e : contactList) {
                Contact contact =Contact.dao.findById(e.getDataId());
                if (contact == null) {
                    throw new BizException("无效的DataId");
                }
                Contact item=new Contact();
                BeanHelper.copyEncrypt(e,item);
                cryptoService.decryptoColumnModel(item,decryptColumn);
                BeanHelper.copy(item, contact);
                contact.setSfRecordId(e.getSfRecordId());
                if (!contact.saveOrUpdate()) {
                    throw new BizException(ResultCodeEnum.RT_ERROR);
                }

                respList.add(e);
            }
            return true;
        });
        return respList;
    }

}