package com.itstyle.mdm.service.impl;


import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.itstyle.mdm.entity.InterfaceLogData;
import com.itstyle.quartz.dynamicquery.DynamicQuery;
import com.itstyle.mdm.entity.MdmData;
import com.itstyle.quartz.entity.SysConfigEntity;
import com.itstyle.mdm.service.MdmService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.Date;
import java.util.List;
import java.util.UUID;

/**
 * MDM数据处理层实现
 */
@Service()
@Transactional(readOnly = true)
public class MdmServiceImpl implements MdmService {

    @Autowired
    private DynamicQuery dynamicQuery;

    @Override
    @Transactional
    public JSONArray saveMdmData(JSONArray recordArray,String name) {
        JSONArray newJsonArray = new JSONArray();
        int size = recordArray.size();
        Object[] params = new  Object[]{};
        MdmData mdmData = null;
        if(size != 0){
            for (int i = 0; i < size; i++) {
                String json = recordArray.get(i).toString();
                JSONObject jsonObj = JSON.parseObject(json);
                String id = jsonObj.getString("id");
                String tgcoriginalcode = jsonObj.getString("tgcoriginalcode");
                String updatedat = jsonObj.getString("updatedat");
                String updatetime = jsonObj.getString("updatetime");
                mdmData = new MdmData();
                mdmData.setType(name);
                mdmData.setId(id);
                mdmData.setTgcoriginalCode(tgcoriginalcode);
                mdmData.setUpdatedat(updatedat);
                mdmData.setUpdatetime(updatetime);
                String countSql = "SELECT mdm.uuid,mdm.id,mdm.tgcoriginalCode,mdm.updatedat,mdm.updatetime FROM mdm_data AS mdm where mdm.tgcoriginalCode='"+tgcoriginalcode+"' ";
                List<MdmData> list = dynamicQuery.nativeQueryList(MdmData.class,countSql,params);
                if(list.size()>0){
                    //说明存在数据
                    for (MdmData mdm : list) {
                        String updatetime1 = mdm.getUpdatetime();
                        if(updatetime1.equals(updatetime)){
                            //数据无变化
                            continue;
                        }
                        jsonObj.put("renewstatus","update");
                        newJsonArray.add(jsonObj);
                        //数据存在变化
                        dynamicQuery.update(mdm);//更新数据
                    }
                }else {
                    jsonObj.put("renewstatus","new");
                    newJsonArray.add(jsonObj);
                    //说明该数据为新数据
                    mdmData.setUuid(UUID.randomUUID().toString());
                    dynamicQuery.save(mdmData);
                }
            }
        }
        return newJsonArray;
    }

    @Override
    @Transactional
    public JSONArray saveMdmUnitData(JSONArray recordArray, String name) {
        JSONArray newJsonArray = new JSONArray();
        int size = recordArray.size();
        Object[] params = new  Object[]{};
        MdmData mdmData = null;
        if(size != 0){
            for (int i = 0; i < size; i++) {
                String json = recordArray.get(i).toString();
                JSONObject jsonObj = JSON.parseObject(json);
                String id = jsonObj.getString("code");
                String tgcoriginalcode = jsonObj.getString("originalcode");
                //String updatedat = jsonObj.getString("updatedat");
                String updatetime = jsonObj.getString("updatetime");
                mdmData = new MdmData();
                mdmData.setType(name);
                mdmData.setId(id);
                mdmData.setTgcoriginalCode(tgcoriginalcode);
                mdmData.setUpdatedat("");
                mdmData.setUpdatetime(updatetime);
                String countSql = "SELECT mdm.uuid,mdm.id,mdm.tgcoriginalCode,mdm.updatedat,mdm.updatetime FROM mdm_data AS mdm where mdm.tgcoriginalCode='"+tgcoriginalcode+"' ";
                List<MdmData> list = dynamicQuery.nativeQueryList(MdmData.class,countSql,params);
                if(list.size()>0){
                    //说明存在数据
                    for (MdmData mdm : list) {
                        String updatetime1 = mdm.getUpdatetime();
                        if(updatetime1.equals(updatetime)){
                            //数据无变化
                            continue;
                        }
                        jsonObj.put("renewstatus","update");
                        newJsonArray.add(jsonObj);
                        //数据存在变化
                        dynamicQuery.update(mdm);//更新数据
                    }
                }else {
                    jsonObj.put("renewstatus","new");
                    newJsonArray.add(jsonObj);
                    //说明该数据为新数据
                    mdmData.setUuid(UUID.randomUUID().toString());
                    dynamicQuery.save(mdmData);
                }
            }
        }
        return newJsonArray;
    }

    @Override
    public List<SysConfigEntity> querySysConfigs(String interfaceName) {
        Object[] params = new  Object[]{interfaceName};
        String countSql = "select id,ADDRESS as address,DESCRIPTION as description,cronExpression,isEnable,sysName,association from sys_config where isEnable='启用' and association=?";
        List<SysConfigEntity> list = dynamicQuery.nativeQueryList(SysConfigEntity.class,countSql,params);
        return list;
    }

    @Override
    @Transactional
    public int saveInterfaceLog(String uuid,String interfaceName, String url, String param, String result) {
        InterfaceLogData interfaceLogData = new InterfaceLogData();
        interfaceLogData.setUuid(uuid);
        interfaceLogData.setInterfaceName(interfaceName);
        interfaceLogData.setCreateTime(new Date());
        interfaceLogData.setPrams(param);
        interfaceLogData.setResult(result);
        interfaceLogData.setUrl(url);
        try{
            dynamicQuery.save(interfaceLogData);
            return 1;
        }catch (Exception e){
            e.printStackTrace();
            return 0;
        }
    }
}