package com.cjs.cms.biz.ration;

import java.io.File;
import java.math.BigDecimal;
import java.math.RoundingMode;
import java.net.URI;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.cjs.cms.action.user.fund.UserBalanceAction;
import com.cjs.cms.dao.quota.OtcStockRealDao;
import com.cjs.cms.dao.ration.MchPriceDao;
import com.cjs.cms.dao.ration.OtcStockJourDao;
import com.cjs.cms.dao.ration.RationNewConfigDao;
import com.cjs.cms.dao.ration.RationNewRecordDao;
import com.cjs.cms.dao.ration.RationNewUserDao;
import com.cjs.cms.dao.ration.TrustApplyDao;
import com.cjs.cms.dao.ration.TrustApplyExtDao;
import com.cjs.cms.model.pub.ResultInfo;
import com.cjs.cms.model.ration.RationNewConfigInfo;
import com.cjs.cms.model.ration.RationNewUserInfo;
import com.cjs.cms.model.user.UserInfo;
import com.cjs.cms.util.file.FileUtil;
import com.cjs.cms.util.file.TemplateUtils;
import com.cjs.cms.util.lang.DateEnum;
import com.cjs.cms.util.lang.DateUtil;
import com.cjs.cms.util.lang.StringUtil;
import com.cjs.cms.util.poi.ExcelConfig;
import com.cjs.cms.util.poi.ExcelUtil;
import com.cjs.cms.util.t2.T2Result;
import com.cjs.cms.util.t2.T2Util;
import com.cjs.cms.util.web.ActionUtil;
import com.cjs.cms.util.web.SendMessageUtil;

/**
 * 新品配售设置
 * 
 * @author tongxiaochuan
 *
 */
@Service
public class RationNewConfigBiz {

    @Value("${download.export}")
    private String             exportPath;
    Logger                     log = LogManager.getLogger();
    @Autowired
    private RationNewConfigDao rationNewConfigDao;
    @Autowired
    private RationNewUserDao   rationNewUserDao;
    @Autowired
    private TrustApplyExtDao   trustApplyExtDao;
    @Autowired
    private SendMessageUtil    sendMsgUtil;
    @Autowired
    private RationNewRecordDao rationNewRecordDao;
    @Autowired
    private TrustApplyDao      trustApplyDao;
    @Autowired
    private OtcStockJourDao    otcStockJourDao;
    @Autowired
    private OtcStockRealDao    otcStockRealDao;
    @Autowired
    private MchPriceDao        mchPriceDao;

    /**新增及修改规则*/
    @Transactional
    public String add(RationNewConfigInfo newConfig) throws Exception {
        UserInfo userInfo = ActionUtil.getUser();
        newConfig.setCreateBy(userInfo.getTruename());
        if (newConfig.getRationType().equals("1")) {
            newConfig.setRationStatus("1");
        }
        RationNewUserInfo newUser, oldUser;

        //新增
        if (StringUtil.isBlank(newConfig.getId())) {
            int result = rationNewConfigDao.insert(newConfig);
            if (result > 0) {
                for (int i = 0; i < newConfig.getUsers().size(); i++) {
                    newUser = newConfig.getUsers().get(i);
                    newUser.setRationNewConfigId(newConfig.getId());
                    newUser.setCreateBy(userInfo.getTruename());
                    rationNewUserDao.insert(newUser);
                }
            }
            return "1";
        }

        //修改规则
        rationNewConfigDao.update(newConfig);
        //获取修改之前的数据
        RationNewConfigInfo oldConfig = rationNewConfigDao.queryAllById(newConfig.getId());
        List<Integer> list = new ArrayList<Integer>();

        //修改-配售机构数量减少的情况
        if (oldConfig.getUsers().size() > newConfig.getUsers().size()) {
            //获取删除的用户信息的id
            for (int i = 0; i < oldConfig.getUsers().size(); i++) {
                oldUser = oldConfig.getUsers().get(i);
                list.add(oldUser.getId());
                for (int j = 0; j < newConfig.getUsers().size(); j++) {
                    newUser = newConfig.getUsers().get(j);
                    if (oldUser.getId().equals(newUser.getId())) {
                        list.remove(newUser.getId());
                    }
                }
            }
            //删除用户信息
            for (int i = 0; i < list.size(); i++) {
                rationNewUserDao.delete(list.get(i));
            }
        }

        //修改-配售机构数量增加的情况
        if (oldConfig.getUsers().size() < newConfig.getUsers().size()) {
            for (int i = 0; i < newConfig.getUsers().size(); i++) {
                newUser = newConfig.getUsers().get(i);
                if (StringUtil.isBlank(newUser.getId())) {
                    newUser.setRationNewConfigId(newConfig.getId());
                    newUser.setCreateBy(userInfo.getTruename());
                    rationNewUserDao.insert(newUser);
                }
            }
        }

        //修改用户信息
        for (int i = 0; i < newConfig.getUsers().size(); i++) {
            rationNewUserDao.update(newConfig.getUsers().get(i));
        }
        return "1";
    }

    /**
     * 再次配售
     */
    public ResultInfo rationAgin(Integer rationNewConfigId) {
        RationNewConfigInfo config = rationNewConfigDao.queryById(rationNewConfigId);
        if (config == null) {
            return new ResultInfo(0, "配置信息不存在");
        }
        config.setRationStatus("1");
        rationNewConfigDao.update(config);
        return new ResultInfo(1, "配售状态更改成功");
    }

    /**删除规则中users里的空RationNewUserInfo对象*/
    public RationNewConfigInfo validateNullUser(RationNewConfigInfo rationNewConfigInfo) {
        for (int i = 0; i < rationNewConfigInfo.getUsers().size(); i++) {
            if (StringUtil.isBlank(rationNewConfigInfo.getUsers().get(i).getUserId())
                || StringUtil.isBlank(rationNewConfigInfo.getUsers().get(i).getPercent())) {
                rationNewConfigInfo.getUsers().remove(i);
            }
        }
        return rationNewConfigInfo;
    }

    /**新增、修改规则验证*/
    public String valiadate(RationNewConfigInfo rationNewConfigInfo) {
        //验证配售机构是否有重复
        RationNewUserInfo user1, user2;
        for (int i = 0; i < rationNewConfigInfo.getUsers().size(); i++) {
            user1 = rationNewConfigInfo.getUsers().get(i);
            for (int j = 0; j < rationNewConfigInfo.getUsers().size(); j++) {
                user2 = rationNewConfigInfo.getUsers().get(j);
                if (i != j && user1.getUserId().equals(user2.getUserId())) {
                    return "配售机构有重复，请检查后重新填写";
                }
            }
        }

        //验证时间，确认结束时间必须大于确认开始时间
        if (rationNewConfigInfo.getConfirmEndDate().getTime() <= rationNewConfigInfo
            .getConfirmStartDate().getTime()) {
            return "确认结束时间必须大于确认开始时间";
        }
        if (rationNewConfigInfo.getId() != null) {
            RationNewConfigInfo config = rationNewConfigDao.queryById(rationNewConfigInfo.getId());
            if (StringUtil.equals(config.getRationStatus(), "0", "2", "3")) {
                return "非待配售状态不可以修改";
            }
        }
        //验证藏品代码，非作废状态的藏品代码必须是唯一的
        /*
        Map<String, Object> inMap = new HashMap<String, Object>();
        inMap.put("otcCode", rationNewConfigInfo.getOtcCode());
        inMap.put("rationStatus", "0");
        List<RationNewConfigInfo> list = rationNewConfigDao.queryByOtcCode(inMap);
        if (list.size() > 0) {
            if (StringUtil.isBlank(rationNewConfigInfo.getId())) {
                //return "该藏品代码已上市，不可重复上市";
            } else if ("1".equals(list.get(0).getRationType())) {
                if (!list.get(0).getRationStatus().equals("1")
                    && !list.get(0).getRationStatus().equals("4")) {
                    return "非待配售状态不可以修改";
                }
            }
        }*/

        if (rationNewConfigInfo.getRationType().equals("0")) {
            return "1";
        }

        //配售比例总数验证，不能大于100%
        int totalPercent = 0;
        Map<String, Object> params = new HashMap<String, Object>();
        for (int i = 0; i < rationNewConfigInfo.getUsers().size(); i++) {
            //验证用户是否存在
            params.put("client_id", rationNewConfigInfo.getUsers().get(i).getUserId());
            params.put("fund_account", rationNewConfigInfo.getUsers().get(i).getUserId());
            T2Result result = T2Util.request(params, "619832");
            if (!result.getCode().toString().equals("0")) {
                return "会员号为:" + rationNewConfigInfo.getUsers().get(i).getUserId() + "的用户不存在";
            }

            totalPercent += rationNewConfigInfo.getUsers().get(i).getPercent();
        }
        if (totalPercent > 100) {
            return "配售比例总数不能大于100%";
        }
        if (!StringUtil.isBlank(rationNewConfigInfo.getRationStatus())
            && !rationNewConfigInfo.getRationStatus().equals("1")) {
            return "只有未配售状态的规则可以修改";
        }
        return "1";
    }

    /**获取配售规则信息及对应的新品配售用户信息*/
    public RationNewConfigInfo getUserInfoByConfigId(String rationNewConfigId) {
        return rationNewConfigDao.queryAllById(Integer.parseInt(rationNewConfigId));
    }

    /**作废配售规则*/
    public int cancel(Integer rationNewConfigId) {
        return rationNewConfigDao.updateCancel(rationNewConfigId);
    }

    /**查看规则弹窗功能查询*/
    public Map<String, Object> detailTop(Integer id) {
        Map<String, Object> returnMap = new HashMap<String, Object>();
        RationNewConfigInfo config = rationNewConfigDao.queryAllById(id);
        returnMap.put("otcCode", config.getOtcCode());
        returnMap.put("otcName", config.getOtcName());
        returnMap.put("price", config.getPrice());

        Integer total = trustApplyExtDao.queryTotalCount(config.getOtcCode());
        returnMap.put("total", total);
        return returnMap;
    }

    /**查看规则功能-表格显示数据查询*/
    public List<Map<String, Object>> detailBottom(Integer id) {
        Map<String, Object> detailMap = null;
        List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();
        RationNewConfigInfo config = rationNewConfigDao.queryAllById(id);
        Map<String, Object> params = new HashMap<String, Object>();
        Integer total = trustApplyExtDao.queryTotalCount(config.getOtcCode());
        RationNewUserInfo rationUser = null;
        T2Result result, result1, result2 = null;

        for (int i = 0; i < config.getUsers().size(); i++) {
            detailMap = new HashMap<String, Object>();
            params.put("client_id", config.getUsers().get(i).getUserId());
            params.put("fund_account", config.getUsers().get(i).getUserId());
            result = T2Util.request(params, "619832");
            if (result.getCode().toString().equals("0")) {
                rationUser = config.getUsers().get(i);
                detailMap.put("clientId", result.getData().get(0).get("client_id"));
                detailMap.put("clientName", result.getData().get(0).get("client_name"));
                //查询用户手机号（权益账户周边-个人信息获取接口）
                result1 = T2Util.request(params, "619829");
                detailMap.put("mobileTel", result1.getData().get(0).get("mobile_tel"));
                detailMap.put("percent", rationUser.getPercent().doubleValue() + "%");
                //配售数量进行四舍五入，而后乘以价格
                detailMap.put("rationCost",
                    new BigDecimal(new BigDecimal(rationUser.getPercent())
                        .divide(new BigDecimal(100)).multiply(new BigDecimal(total))
                        .setScale(0, RoundingMode.HALF_UP).intValue() * config.getPrice())
                            .setScale(2, RoundingMode.HALF_UP).doubleValue());

                params.put("entrust", "7");//委托请求
                params.put("request_num", "2000");//请求行数
                result2 = T2Util.request(params, "619014");
                detailMap.put("balance", result2.getData().get(0).get("enable_balance"));
                list.add(detailMap);
            }
        }
        log.info(list);
        return list;
    }

    /**发送短信*/
    public String sendMessage(Integer id) {
        RationNewConfigInfo rationNewConfigInfo = rationNewConfigDao.queryById(id);
        if (!rationNewConfigInfo.getRationStatus().equals("1")) {
            return "只有待配售状态的规则可以发送短信";
        }

        List<Map<String, Object>> userList = trustApplyExtDao
            .queryUserListNotAgree(rationNewConfigInfo.getOtcCode());
        Map<String, Object> params = new HashMap<String, Object>();
        String content = "";
        //获取短信发送内容
        TemplateUtils template = new TemplateUtils();
        if (userList.isEmpty()) {
            return "0";
        }
        template.put("otcCode", rationNewConfigInfo.getOtcCode());
        template.put("otcName", rationNewConfigInfo.getOtcName());
        content = template.readProcessedTemplate("rationSendMsg.ftl");
        T2Result result = null;
        for (int i = 0; i < userList.size(); i++) {
            params.put("client_id", userList.get(i).get("FUND_ACCOUNT"));
            params.put("fund_account", userList.get(i).get("FUND_ACCOUNT"));
            result = T2Util.request(params, "619829");
            log.info(result);
            if (result.getCode() == 0) {
                log.info(result.getData().get(0).get("mobile_tel").toString() + "----" + content);
                sendMsgUtil.sendMsg(result.getData().get(0).get("mobile_tel").toString(), content);
            }
        }
        return "1";
    }

    /**导出验证*/
    public String exportValiadate(Integer id) {
        RationNewConfigInfo rationNewConfigInfo = rationNewConfigDao.queryAllById(id);
        if (!rationNewConfigInfo.getRationStatus().equals("3")) {
            return "只有配售成功的数据可以导出";
        }
        return "1";
    }

    /**导出确权文件*/
    @Transactional
    public File export(Integer id) throws Exception {
        String filename = "配售确权_" + DateUtil.getNow(DateEnum.UNSIGNED_DATE_TIME);
        filename = FileUtil.makeMonthDir(exportPath) + filename + ".xlsx";
        File targetFile = new File(filename);
        ExcelConfig config = new ExcelConfig();
        URI template = UserBalanceAction.class.getResource("/excel/ration_new_record.xlsx").toURI();
        Map<String, Object> params = new HashMap<String, Object>();
        params.put("preInStatus", "1");
        params.put("rationNewConfigId", id);
        params.put("registration", "0");
        params.put("rationStatus", "1");
        //查询导出的数据
        RationNewConfigInfo rationNewConfigInfo = rationNewConfigDao.queryAllById(id);
        String otcCode = rationNewConfigInfo.getOtcCode();
        List<Map<String, Object>> list = rationNewRecordDao.queryRecord(params);
        Set<String> set = new HashSet<String>();
        for (Map<String, Object> map : list) {
            set.add(map.get("apply_no").toString());
            map.put("market", "O1");
            map.put("otc_code", otcCode);
            map.put("non_circulation", "0");
            map.put("manage_type", "0");
        }

        //更新导出数据的导出状态
        rationNewRecordDao.updateExport(params);
        Map<String, Object> updateMap = new HashMap<String, Object>();
        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd hhmmss");
        String[] nowdate = sdf.format(new Date()).split(" ");
        String currDate = nowdate[0];
        String currTime = nowdate[1];
        Iterator<String> it = set.iterator();
        while (it.hasNext()) {
            updateMap.put("applyNo", it.next());
            updateMap.put("applyType", "6");
            updateMap.put("remark", "确权文件已导出");
            updateMap.put("currDate", currDate);
            updateMap.put("currTime", currTime);
            trustApplyDao.exportUpdate(updateMap);
        }

        // 先生成Excel文件
        config.setSourceTemplate(new File(template));
        config.setTargetFile(targetFile);
        config.setData(list);
        new ExcelUtil(config).writeExcel();
        return targetFile;
    }

    /**
     * 全部同意配售
     * @param id
     * @return
     */
    public String allRation(Integer id) {
        RationNewConfigInfo info = rationNewConfigDao.queryById(id);
        trustApplyExtDao.deleExtByOtcCode(info.getOtcCode());
        trustApplyExtDao.insertExtByCode(info.getOtcCode());
        return "0";
    }

    /**
     * 修改成本价
     * @param id
     * @return
     */
    @Transactional
    public Map<String, Object> changeCostPrice(Integer id) {
        Map<String, Object> outmap = new HashMap<String, Object>();
        RationNewConfigInfo configInfo = rationNewConfigDao.queryById(id);
        Map<String, Object> priceMap = mchPriceDao.queryLastPrice(configInfo.getOtcCode());
        List<Map<String, Object>> query = rationNewRecordDao.queryForCostPrice(id);
        for (Map<String, Object> map : query) {
            map.put("businessFlag", "35034");
            int existFlag = otcStockJourDao.queryRecordExist(map);
            if (existFlag > 0) {
                Double lastPrice = 0.00;
                if (Double.parseDouble(priceMap.get("LAST_PRICE").toString()) == 0.00) {
                    lastPrice = Double.parseDouble(priceMap.get("MCLOSE_PRICE").toString());
                } else {
                    lastPrice = Double.parseDouble(priceMap.get("LAST_PRICE").toString());
                }
                Double mixBalance = (lastPrice - Double.parseDouble(map.get("price").toString()))
                                    * Integer.parseInt(map.get("stockAmount").toString());
                map.put("mixBalance", mixBalance);
                otcStockRealDao.updateSumBuyBalance(map);
                rationNewRecordDao
                    .updateCostPriceStatus(Integer.parseInt(map.get("id").toString()));
            }
        }
        outmap.put("resultCode", "1");
        outmap.put("resultMsg", "修改完毕");
        return outmap;
    }

}