package cn.com.lzt.sign.controller;

import cn.com.lzt.arrangedutyoperate.dto.UserAndUserPersonnelDto;
import cn.com.lzt.common.util.DateUtil;
import cn.com.lzt.schedule.service.impl.ScheduleSuperivseRecordServiceImpl;
import cn.com.lzt.schedule.service.impl.ScheduleSuperivseServiceImpl;
import cn.com.lzt.sign.entity.*;
import cn.com.lzt.sign.service.TBSupervisionService;

import java.text.SimpleDateFormat;
import java.util.*;
import java.util.logging.Logger;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import cn.com.lzt.useroptions.entity.TBusUserOptionsEntity;
import cn.hutool.core.bean.BeanUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.daju.common.util.DataPage;
import com.daju.mix.dao.entity.TBScheduleSuperivse;
import com.daju.mix.dao.entity.TBScheduleSuperivseRecord;
import com.daju.mix.dao.mapper.TBCarScheduleTaskArrangeMapper;
import com.daju.mix.dao.service.ITBCarScheduleTaskArrangeService;
import com.daju.mix.dao.service.ITSBaseUserService;
import com.daju.mix.dao.service.impl.ScheduleStatisticsServiceImpl;
import com.daju.mix.dao.service.impl.TSBaseUserServiceImpl;
import org.apache.commons.lang.StringUtils;
import org.jeecgframework.core.common.controller.BaseController;
import org.jeecgframework.core.common.exception.BusinessException;
import org.jeecgframework.core.common.hibernate.qbc.CriteriaQuery;
import org.jeecgframework.core.common.model.json.AjaxJson;
import org.jeecgframework.core.common.model.json.DataGrid;
import org.jeecgframework.core.extend.hqlsearch.HqlGenerateUtil;
import org.jeecgframework.core.util.ContextHolderUtils;
import org.jeecgframework.core.util.ResourceUtil;
import org.jeecgframework.core.util.StringUtil;
import org.jeecgframework.tag.core.easyui.TagUtil;
import org.jeecgframework.tag.vo.datatable.SortDirection;
import org.jeecgframework.web.system.pojo.base.TSBaseUser;
import org.jeecgframework.web.system.pojo.base.TSDepart;
import org.jeecgframework.web.system.pojo.base.TSUser;
import org.jeecgframework.web.system.service.SystemService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;


/**
 * 督查奖惩签报 controller
 */
@Controller
@RequestMapping({"/tBSupervisionController"})
public class TBSupervisionController
        extends BaseController {
    private static final Logger logger = Logger.getLogger(String.valueOf(cn.com.lzt.sign.controller.TBSupervisionController.class));


    @Autowired
    private TBSupervisionService tBSupervisionService;
    //督查单据
    @Resource
    private ScheduleSuperivseServiceImpl superivseService;
    @Resource
    private ScheduleStatisticsServiceImpl scheduleStatisticsService;
    @Resource
    private ScheduleSuperivseRecordServiceImpl superivseRecordService;
    @Resource
    private TSBaseUserServiceImpl itsBaseUserService;
    @Resource
    private SystemService systemService;


    @RequestMapping(params = {"list"})
    public ModelAndView list(HttpServletRequest request) {
        /* 39 */
        return new ModelAndView("cn/com/lzt/sign/tbsupervision/tBSupervisionList");
    }

    /**
     * 获取当前登录人的审批权限集合
     *
     * @return
     * @author刘梦祥
     * @Date 2021年11月29日00:42:57
     */
    public Map<String, List<String>> getUserRuleMap() {
        //          获取当前操作人的信息
        TSUser user = ResourceUtil.getSessionUser();
        TSBaseUser tsBaseUser = this.systemService.getEntity(TSBaseUser.class, user.getId());
        DataGrid dataGrid1 = new DataGrid();
        CriteriaQuery criteriaQuery1 = new CriteriaQuery(UserAndUserPersonnelDto.class, dataGrid1);
        criteriaQuery1.eq("userid", user.getId());
        criteriaQuery1.add();
        List<UserAndUserPersonnelDto> userAndUserPersonnelDtoList = this.systemService.getListByCriteriaQuery(criteriaQuery1, true);
        Map<String, List<String>> ruleMap = new HashMap<>();
//      得到登录人的职位
        List<String> departidList = new ArrayList<>();
        if (tsBaseUser != null && tsBaseUser.getDepartid() != null) {
            departidList.add(tsBaseUser.getDepartid());
        }
//      得到操作人的岗位
        List<String> inPostidList = new ArrayList<>();
        if (userAndUserPersonnelDtoList != null && userAndUserPersonnelDtoList.size() > 0) {
            for (UserAndUserPersonnelDto userInfoDto : userAndUserPersonnelDtoList) {
                if (StringUtil.isNotEmpty(userInfoDto.getInPostid())) {
                    if (!inPostidList.contains(userInfoDto.getInPostid())) {
                        inPostidList.add(userInfoDto.getInPostid());
                    }
                }
            }
        }
        ruleMap.put("departId", departidList);
        ruleMap.put("inPostid", inPostidList);
        return ruleMap;
    }

    @RequestMapping(params = {"datagrid"})
    public void datagrid(HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) {
        StringBuffer queryStr = new StringBuffer();
        queryStr.append(" where 1 = 1 ");
        //          封装督查单据人员查询条件
        if(StringUtil.isNotEmpty(request.getParameter("supervisionBillUser"))){
            queryStr.append(" and supervision_bill_user in (select tsbu.id as userIds from t_s_base_user tsbu where tsbu.realname like \"%" + request.getParameter("supervisionBillUser") + "%\" group by tsbu.id ) ");
        }
        //          封装业务类型查询条件
        if (StringUtil.isNotEmpty(request.getParameter("supervisionType"))) {
            queryStr.append(" and supervision_type = \"" + request.getParameter("supervisionType") + "\"");
        }
        //          封装督查单据区域查询条件
        if (StringUtil.isNotEmpty(request.getParameter("supervisionBillRegion"))) {
            queryStr.append(" and supervision_bill_region = \"" + request.getParameter("supervisionBillRegion") + "\"");
        }
        //          封装责任人查询条件
        if (StringUtil.isNotEmpty(request.getParameter("supervisionDutyUser"))) {
            queryStr.append(" and supervision_duty_user in (select tsbu.id as userIds from t_s_base_user tsbu where tsbu.realname like \"%" + request.getParameter("supervisionDutyUser") + "%\" group by tsbu.id ) ");
        }
        //          封装奖惩内容查询条件
        if (StringUtil.isNotEmpty(request.getParameter("supervisionCont"))) {
            queryStr.append(" and supervision_cont like \"%" + request.getParameter("supervisionCont") + "%\"");
        }
        //          封装奖惩处理查询条件
        if (StringUtil.isNotEmpty(request.getParameter("supervisionRes"))) {
            queryStr.append(" and supervision_res like \"%" + request.getParameter("supervisionRes") + "%\"");
        }
        //          封装审批状态查询条件
        if (StringUtil.isNotEmpty(request.getParameter("supervisionApprove"))) {
            queryStr.append(" and supervision_approve = \"" + request.getParameter("supervisionApprove") + "\"");
        }
        List<Map<String, Object>> dataGridList = this.systemService.toDataGridByDataGrid(" t_b_supervision ", "supervision_spare_two", "request_id", "create_date", dataGrid, queryStr.toString());
        dataGrid.setResults(dataGridList);
        TagUtil.datagrid(response, dataGrid);
    }

    @RequestMapping(params = {"goAdd"})
    public ModelAndView goAdd(HttpServletRequest request) {
        return new ModelAndView("cn/com/lzt/sign/tbsupervision/supervisionList-add");
    }

    @RequestMapping(params = {"getSuperivseList"})
    public ModelAndView getSuperivseList(HttpServletRequest request, HttpServletResponse response, DataGrid dataGrid) {
        return new ModelAndView("cn/com/lzt/sign/tbsupervision/selectsuperivseList");
    }

    @RequestMapping(params = {"getUserName"})
    @ResponseBody
    public AjaxJson getUserName(HttpServletRequest request) {
        String name = itsBaseUserService.warningDetailDto(request.getParameter("id"));
        AjaxJson j = new AjaxJson();
        j.setSuccess(true);
        j.setObj(name);
        return j;
    }

    @RequestMapping(params = {"doAdd"})
    @ResponseBody
    public AjaxJson doAdd(TBSupervisionAddReq tbSupervisionEntity, HttpServletRequest request) {
        HttpSession session = ContextHolderUtils.getSession();
        TSUser tuser = (TSUser) session.getAttribute("LOCAL_CLINET_USER");
        AjaxJson j = new AjaxJson();
        String message = "添加成功";
        try {
            String res = tbSupervisionEntity.getSupervisionRes();
            if (tbSupervisionEntity.getPunishMoney() != null) {
                res = "罚款" + tbSupervisionEntity.getPunishMoney() + "元";
            }else if (tbSupervisionEntity.getAwardMoney() != null) {
                res = "奖励" + tbSupervisionEntity.getAwardMoney() + "元";
            }/*else if (tbSupervisionEntity.getSubSalary() != null) {
                res = "扣工资" + tbSupervisionEntity.getSubSalary() + "元";
            } else if (tbSupervisionEntity.getSubAwardMoney() != null) {
                res = "扣奖金" + tbSupervisionEntity.getSubAwardMoney() + "元";
            } */
            TBScheduleSuperivse common = superivseService.getById(tbSupervisionEntity.getSupervisionBillId());
            TBSupervisionEntity save = new TBSupervisionEntity();
            save.setSupervisionBillId(Integer.toString(common.getId()));
            save.setSupervisionBillCode(common.getCode());
            save.setSupervisionBillDate(DateUtil.changeStrToDate2(common.getSuperviseDate()));
            save.setSupervisionBillUser(common.getUserId());
            save.setSupervisionType(common.getType());
            save.setSupervisionBillRegion(common.getArea());
            save.setSupervisionAddress(common.getLocation());
            save.setSupervisionProCont(common.getContext());
            save.setSupervisionOneImgUrl(common.getImgUrl());
            save.setSupervisionDutyUser(common.getResponsibleUserId());
            save.setSupervisionClassUser(common.getLeaderUserId());
            save.setSupervisionCont(tbSupervisionEntity.getSupervisionCont());
            save.setSupervisionRes(res);
            save.setSupervisionResType(tbSupervisionEntity.getSupervisionResType());
            //审批用的
            save.setSupervisionSpareTwo(tuser.getId());
            save.setSupervisionApprove("待提交");
            //end
            TBSupervisionEntity entity = (TBSupervisionEntity) this.tBSupervisionService.getEntity(TBSupervisionEntity.class, tbSupervisionEntity.getId());
            if (Objects.isNull(entity)) {
                this.tBSupervisionService.save(save);
            } else {
                tBSupervisionService.deleteEntityById(TBSupervisionEntity.class,tbSupervisionEntity.getId());
                this.tBSupervisionService.save(save);
            }
        } catch (Exception e) {
            e.printStackTrace();
            message = "添加失败";
            throw new BusinessException(e.getMessage());
        }
        j.setMsg(message);
        return j;
    }

    @RequestMapping(params = {"goUpdate"})
    public ModelAndView goUpdate(TBSupervisionEntity supervisionEntity, HttpServletRequest request) {
        String id = supervisionEntity.getId();
        supervisionEntity = (TBSupervisionEntity) this.tBSupervisionService.getEntity(TBSupervisionEntity.class, id);
        String user = itsBaseUserService.warningDetailDto(supervisionEntity.getSupervisionBillUser());
        String dutyUser = itsBaseUserService.warningDetailDto(supervisionEntity.getSupervisionDutyUser());
        String classUser = itsBaseUserService.warningDetailDto(supervisionEntity.getSupervisionClassUser());
        supervisionEntity.setSupervisionBillUser(user);
        supervisionEntity.setSupervisionDutyUser(dutyUser);
        supervisionEntity.setSupervisionClassUser(classUser);
        TBSupervisionAddReq req = new TBSupervisionAddReq();
        BeanUtil.copyProperties(supervisionEntity, req);
        if (supervisionEntity.getSupervisionResType().equals("经济")) {
            String regEx="[^0-9]";
            Pattern p = Pattern.compile(regEx);
            Matcher m = p.matcher(supervisionEntity.getSupervisionRes());
            String money = m.replaceAll("").trim();
            if (supervisionEntity.getSupervisionRes().contains("罚款")) {
                req.setPunishMoney(Integer.valueOf(money));
            }else if (supervisionEntity.getSupervisionRes().contains("奖励")) {
                req.setAwardMoney(Integer.valueOf(money));
            }/*else if (supervisionEntity.getSupervisionRes().contains("扣工资")) {
                req.setSubSalary(Integer.valueOf(money));
            } else if (supervisionEntity.getSupervisionRes().contains("扣奖金")) {
                req.setSubAwardMoney(Integer.valueOf(money));
            } */
        }
//      整改照片路由兼容处理
        if(req.getSupervisionOneImgUrl() != null){
            if (req.getSupervisionOneImgUrl() != null && StringUtils.isNotEmpty(req.getSupervisionOneImgUrl())) {
                if (req.getSupervisionOneImgUrl().contains("http") && req.getSupervisionOneImgUrl().length() > 10) {
                    try {
                        List<String> imgUrlList = JSONObject.parseArray(req.getSupervisionOneImgUrl(), String.class);
                        req.setSupervisionOneImgUrl(imgUrlList.get(0));
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                } else {
                    List<String> imgUrlList = new ArrayList<>();
                    if (!"[null]".equals(req.getSupervisionOneImgUrl()) && !"[]".equals(req.getSupervisionOneImgUrl())) {
                        imgUrlList.add("http://47.100.210.233/" + req.getSupervisionOneImgUrl());
                        req.setSupervisionOneImgUrl(imgUrlList.get(0));
                    }
                }
            }
        }
        String supervisionBillDateStr = "";
        SimpleDateFormat simpleDateFormatYMD = new SimpleDateFormat("yyyy-MM-dd");
        supervisionBillDateStr = simpleDateFormatYMD.format(req.getSupervisionBillDate());
        request.setAttribute("supervisionBillDateStr", supervisionBillDateStr);

        request.setAttribute("supervision", req);
        return new ModelAndView("cn/com/lzt/sign/tbsupervision/supervisionList-update");
    }

    @RequestMapping(params = {"goEdit"})
    public ModelAndView goEdit(TBSupervisionEntity supervisionEntity, HttpServletRequest request) {
        String id = supervisionEntity.getId();
        supervisionEntity = (TBSupervisionEntity) this.tBSupervisionService.getEntity(TBSupervisionEntity.class, id);
        String user = itsBaseUserService.warningDetailDto(supervisionEntity.getSupervisionBillUser());
        String dutyUser = itsBaseUserService.warningDetailDto(supervisionEntity.getSupervisionDutyUser());
        String classUser = itsBaseUserService.warningDetailDto(supervisionEntity.getSupervisionClassUser());
        supervisionEntity.setSupervisionBillUser(user);
        supervisionEntity.setSupervisionDutyUser(dutyUser);
        supervisionEntity.setSupervisionClassUser(classUser);
        TBSupervisionAddReq req = new TBSupervisionAddReq();
        BeanUtil.copyProperties(supervisionEntity, req);
        if (supervisionEntity.getSupervisionResType().equals("经济")) {
            String regEx="[^0-9]";
            Pattern p = Pattern.compile(regEx);
            Matcher m = p.matcher(supervisionEntity.getSupervisionRes());
            String money = m.replaceAll("").trim();
            if (supervisionEntity.getSupervisionRes().contains("罚款")) {
                req.setPunishMoney(Integer.valueOf(money));
            }else if (supervisionEntity.getSupervisionRes().contains("奖励")) {
                req.setAwardMoney(Integer.valueOf(money));
            } /*else if (supervisionEntity.getSupervisionRes().contains("扣工资")) {
                req.setSubSalary(Integer.valueOf(money));
            } else if (supervisionEntity.getSupervisionRes().contains("扣奖金")) {
                req.setSubAwardMoney(Integer.valueOf(money));
            } */
        }

//      整改照片路由兼容处理
        if(req.getSupervisionOneImgUrl() != null){
            if (req.getSupervisionOneImgUrl() != null && StringUtils.isNotEmpty(req.getSupervisionOneImgUrl())) {
                if (req.getSupervisionOneImgUrl().contains("http") && req.getSupervisionOneImgUrl().length() > 10) {
                    try {
                        List<String> imgUrlList = JSONObject.parseArray(req.getSupervisionOneImgUrl(), String.class);
                        req.setSupervisionOneImgUrl(imgUrlList.get(0));
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                } else {
                    List<String> imgUrlList = new ArrayList<>();
                    if (!"[null]".equals(req.getSupervisionOneImgUrl()) && !"[]".equals(req.getSupervisionOneImgUrl())) {
                        imgUrlList.add("http://47.100.210.233/" + req.getSupervisionOneImgUrl());
                        req.setSupervisionOneImgUrl(imgUrlList.get(0));
                    }
                }
            }
        }
        String supervisionBillDateStr = "";
        SimpleDateFormat simpleDateFormatYMD = new SimpleDateFormat("yyyy-MM-dd");
        supervisionBillDateStr = simpleDateFormatYMD.format(req.getSupervisionBillDate());
        request.setAttribute("supervisionBillDateStr", supervisionBillDateStr);

        request.setAttribute("supervision", req);
        return new ModelAndView("cn/com/lzt/sign/tbsupervision/supervisionList-edit");
    }

    @RequestMapping(params = "doDel")
    @ResponseBody
    public AjaxJson doDel(HttpServletRequest request) {
        AjaxJson j = new AjaxJson();
        String message  = "添加成功";
        j.setSuccess(true);
        try{
            TBSupervisionEntity entity = new TBSupervisionEntity();
            entity.setId(request.getParameter("id"));
            tBSupervisionService.delete(entity);
        }catch(Exception e){
            e.printStackTrace();
            message = "添加失败";
            j.setSuccess(false);
            throw new BusinessException(e.getMessage());
        }
        j.setMsg(message);
        return j;
    }
}


/* Location:              C:\Users\86152\Desktop\qwe\!\controller\TBSupervisionController.class
 * Java compiler version: 8 (52.0)
 * JD-Core Version:       1.1.3
 */