package com.example.demo.handler;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.parser.Feature;
import com.example.demo.dao.TaxiDataRepository;
import com.example.demo.model.Complex;
import com.example.demo.model.ComplexOperator;
import com.example.demo.model.roades.FlagParams;
import com.example.demo.model.roades.TaxiRealtimedata;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestMapping;
import xyz.erupt.annotation.fun.OperationHandler;
import xyz.erupt.core.exception.EruptApiErrorTip;
import xyz.erupt.core.view.EruptApiModel;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.List;

/**
 * @author liyuepeng
 * @date 2018-10-10.
 */
@Component
public class OperationHandlerImpl implements OperationHandler<TaxiRealtimedata, FlagParams> {

    @Resource
    private HttpServletRequest request; //展示自动注入功能

    @Autowired
    private TaxiDataRepository taxiDataRepository;

    @Override
    public void exec(List<TaxiRealtimedata> data, FlagParams vo, String[] param) {
        System.out.println(request.getAttributeNames());
        if(param == null || data == null) {
            return;
        }
        JSONObject parms = JSONObject.parseObject(param[0]);
        String field = parms.get("kpi").toString();
        for (int i = 0; i < data.size(); i++) {
            TaxiRealtimedata taxiRealtimedata =  data.get(i);
            if(vo.getDustflag() != null) {
                taxiRealtimedata.setDustflag(vo.getDustflag() );
            }
            if(vo.getCoflag() != null) {
                taxiRealtimedata.setCoflag(vo.getCoflag());
            }
            if(vo.getNoflag() != null) {
                taxiRealtimedata.setNoflag(vo.getNoflag());
            }
            if(vo.getNo2flag() != null) {
                taxiRealtimedata.setNo2flag(vo.getNo2flag());
            }
            taxiDataRepository.save(taxiRealtimedata);
        }
//        throw new EruptApiErrorTip(new EruptApiModel(EruptApiModel.Status.WARNING,
//                "自定义报错提示：" + request.getServletPath(), EruptApiModel.PromptWay.NOTIFY));
    }

    //1.7.3及以上版本致辞此功能
    //exec 执行成功后需要执行的 JavaScript 表达式
    public String afterJS(List<TaxiRealtimedata> data, Void vo, String[] param) {
        return "alert('自定义按钮执行成功后，执行的JS脚本')";
    }

}