清障队后台

Visuallnspection_qzd/src/main/java/com/xintong/visualinspection/visuallnspection_qzd/dao/QzdRecordDao.java

@@ -0,0 +1,21 @@
+package com.xintong.visualinspection.visuallnspection_qzd.dao;
+
+import com.xintong.visualinspection.bean.FwqCheckTask;
+import com.xintong.visualinspection.bean.QzdRecord;
+import com.xintong.visualinspection.bean.TaskStatus;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * 文件名：FwqTaskDao
+ * 版本信息：日期：2018/4/11 Copyright 江苏省交通规划设计院 Corporation 2018 版权所有.
+ */
+@Mapper
+public interface QzdRecordDao {
+    public void addRecord(QzdRecord qzdRecord);
+    public void updateRecord(QzdRecord qzdRecord);
+    public List<QzdRecord> getall(QzdRecord qzdRecord);
+    public QzdRecord getone(QzdRecord qzdRecord);
+    public void deleteRecord(QzdRecord qzdRecord);
+}

Visuallnspection_qzd/src/main/java/com/xintong/visualinspection/visuallnspection_qzd/dao/QzdTaskDao.java

@@ -0,0 +1,22 @@
+package com.xintong.visualinspection.visuallnspection_qzd.dao;
+
+import com.xintong.visualinspection.bean.QzdCheckTask;
+import com.xintong.visualinspection.bean.TaskStatus;
+import org.apache.ibatis.annotations.Mapper;
+
+import java.util.List;
+
+/**
+ * 文件名：FwqTaskDao
+ * 版本信息：日期：2018/4/11 Copyright 江苏省交通规划设计院 Corporation 2018 版权所有.
+ */
+@Mapper
+public interface QzdTaskDao {
+    public void addtask(QzdCheckTask qzdCheckTask);
+    public List<QzdCheckTask> getall(QzdCheckTask qzdCheckTask);
+    public void updateStatus(QzdCheckTask qzdCheckTask);
+    public QzdCheckTask getone(QzdCheckTask qzdCheckTask);
+    public void insertStatus(TaskStatus taskStatus);
+    public void insertStatusBatch(List<TaskStatus> taskStatusList);
+    public List<TaskStatus> getTaskStatusList(Long id);
+}

Visuallnspection_qzd/src/main/java/com/xintong/visualinspection/visuallnspection_qzd/mapper/master/RecordMapper.xml

@@ -0,0 +1,96 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xintong.visualinspection.visuallnspection_qzd.dao.QzdRecordDao">
+    <!--private Integer id;-->
+    <!--private Date creat_time;-->
+    <!--private Integer type;-->
+    <!--private String users;-->
+    <!--private Integer dept;-->
+    <!--private String addr;-->
+    <!--private Date received_time;-->
+    <!--private String car_info;-->
+    <!--private String car_user_info;-->
+    <!--private Date start_time;-->
+    <!--private Date arrive_time;-->
+    <!--private Date back_time;-->
+    <!--private Integer record_user;-->
+    <!--private Integer arrive_in_time;-->
+    <!--private Integer unimpeded_in_time;-->
+    <!--private Integer car_user_satisfaction;-->
+    <!--private String videos;-->
+    <!--private String pics;-->
+    <!--private Integer zxt_is_standard;-->
+    <!--private Integer is_explain;-->
+    <!--private Integer record_no_come;-->
+    <!--private Integer take_photo_upload;-->
+    <!--private Integer arrive_do_work;-->
+    <!--private String remarks;-->
+
+    <insert id="addRecord" useGeneratedKeys="true" keyProperty="id"
+            parameterType="com.xintong.visualinspection.bean.QzdRecord">
+        INSERT INTO record_info
+        (type,users,dept,addr,received_time,car_info,car_user_info,start_time,arrive_time,back_time,record_user,arrive_in_time,unimpeded_in_time,car_user_satisfaction,videos
+        ,pics,zxt_is_standard,is_explain,record_no_come,take_photo_upload,arrive_do_work,remarks)
+        VALUES
+        (#{type},#{users},#{dept},#{addr},#{received_time},#{car_info},#{car_user_info},#{start_time},#{arrive_time},#{back_time},#{record_user},#{arrive_in_time},#{unimpeded_in_time},#{car_user_satisfaction},#{videos}
+        ,#{pics},#{zxt_is_standard},#{is_explain},#{record_no_come},#{take_photo_upload},#{arrive_do_work},#{remarks}
+        )
+    </insert>
+
+    <update id="updateRecord" parameterType="com.xintong.visualinspection.bean.QzdRecord">
+        update
+        record_info
+        set
+        <if test="type != null">type = #{type}</if>
+        <if test="users != null">type = #{users}</if>
+        <if test="dept != null">type = #{dept}</if>
+        <if test="addr != null">type = #{addr}</if>
+        <if test="received_time != null">type = #{received_time}</if>
+        <if test="car_info != null">type = #{car_info}</if>
+        <if test="car_user_info != null">type = #{car_user_info}</if>
+        <if test="start_time != null">type = #{start_time}</if>
+        <if test="arrive_time != null">type = #{arrive_time}</if>
+        <if test="back_time != null">type = #{back_time}</if>
+        <if test="record_user != null">type = #{record_user}</if>
+        <if test="arrive_in_time != null">type = #{arrive_in_time}</if>
+        <if test="unimpeded_in_time != null">type = #{unimpeded_in_time}</if>
+        <if test="car_user_satisfaction != null">type = #{car_user_satisfaction}</if>
+        <if test="videos != null">type = #{videos}</if>
+        <if test="pics != null">type = #{pics}</if>
+        <if test="zxt_is_standard != null">type = #{zxt_is_standard}</if>
+        <if test="is_explain != null">type = #{is_explain}</if>
+        <if test="record_no_come != null">type = #{record_no_come}</if>
+        <if test="take_photo_upload != null">type = #{take_photo_upload}</if>
+        <if test="arrive_do_work != null">type = #{arrive_do_work}</if>
+        <if test="remarks != null">type = #{remarks}</if>
+        id=#{id}
+        WHERE
+        id = #{id}
+
+    </update>
+
+
+    <select id="getone" parameterType="com.xintong.visualinspection.bean.QzdRecord"
+            resultType="com.xintong.visualinspection.bean.QzdRecord">
+        select * from record_info where id = #{id}
+        ORDER BY received_time DESC
+    </select>
+
+    <select id="getall" parameterType="com.xintong.visualinspection.bean.QzdRecord"
+            resultType="com.xintong.visualinspection.bean.QzdRecord">
+        select t.*,c.check_status
+        from record_info t left join check_task c on t.id = c.record_id
+        where 1=1
+  <if test="dept != null">and t.dept = #{dept}</if>
+  <if test="startTime != null and endTime != null">and t.received_time between #{startTime} and #{endTime}</if>
+        ORDER BY t.received_time DESC
+    </select>
+
+    <delete id="deleteRecord">
+            delete  from  record_info where id = #{id}
+    </delete>
+
+
+</mapper>
+
+

Visuallnspection_qzd/src/main/java/com/xintong/visualinspection/visuallnspection_qzd/mapper/master/TaskMapper.xml

@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xintong.visualinspection.visuallnspection_qzd.dao.QzdTaskDao">
+    <resultMap id="taskStatusMap" type="com.xintong.visualinspection.bean.TaskStatus">
+        <id property="id" column="ID"/>
+        <result property="task_id" column="task_id"/>
+        <result property="update_time" column="update_time"/>
+        <result property="update_user" column="update_user"/>
+        <result property="update_username" column="update_username"/>
+        <result property="check_status" column="check_status"/>
+        <result property="check_status_name" column="check_status_name"/>
+    </resultMap>
+
+    <insert id="addtask" useGeneratedKeys="true"  keyProperty="id"  parameterType="com.xintong.visualinspection.bean.QzdCheckTask">
+        INSERT INTO check_task
+        (name,check_status,create_time,update_time,start_time,
+        	end_time,checkman,checked_dept,rule_id,remark,period_id,record_id,checked_users
+        )
+        VALUES
+        (#{name}, #{check_status},now(),now(),#{start_time},
+        	#{end_time},#{checkman},#{checked_dept},#{rule_id},#{remark},#{period_id},#{record_id},#{checked_users}
+        )
+    </insert>
+
+
+    <select id="getone" parameterType="com.xintong.visualinspection.bean.FwqCheckTask" resultType="com.xintong.visualinspection.bean.QzdCheckTask">
+        select *,CONCAT(substr(start_time,1,16),'-',substr(end_time,12,5)) as check_period from check_task where 1=1
+        <if test="id != null">AND id = #{id}</if>
+        <if test="record_id != null">AND record_id = #{record_id}</if>
+        ORDER BY start_time DESC
+    </select>
+
+    <select id="getall" parameterType="com.xintong.visualinspection.bean.FwqCheckTask" resultType="com.xintong.visualinspection.bean.QzdCheckTask">
+      select  * from  check_task
+      where 1=1
+        <if test="checked_dept != null">AND checked_dept = #{checked_dept}</if>
+        <if test="start_time != null and end_time != null">AND start_time >= #{start_time} <![CDATA[ AND end_time < #{end_time}]]> </if>
+        ORDER BY start_time DESC
+    </select>
+
+    <update id="updateStatus" parameterType="com.xintong.visualinspection.bean.QzdCheckTask" >
+        update check_task set
+        <if test="check_status != null">check_status = #{check_status},</if>
+        <if test="recheckman != null">recheckman = #{recheckman},</if>
+        update_time=now()
+        WHERE
+        id = #{id}
+    </update>
+
+
+
+
+
+
+    <insert id="insertStatus" parameterType="com.xintong.visualinspection.bean.TaskStatus">
+        INSERT INTO check_task_status
+        (task_id,update_time,update_user,update_username,check_status,
+        	check_status_name
+        )
+        VALUES
+        (#{task_id}, now(),#{update_user},#{update_username},#{check_status},
+        	#{check_status_name}
+        )
+    </insert>
+
+    <select id="getTaskStatusList" parameterType="java.lang.Long" resultMap="taskStatusMap">
+        SELECT *
+        FROM check_task_status
+        WHERE task_id = #{id}
+        order by update_time
+    </select>
+
+    <insert id="insertStatusBatch" parameterType="java.util.List">
+        INSERT INTO check_task_status
+        (task_id,update_time,update_user,update_username,check_status,
+        check_status_name
+        )
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (#{item.task_id}, #{item.update_time},#{item.update_user},#{item.update_username},#{item.check_status},
+            #{item.check_status_name}
+            )
+        </foreach>
+    </insert>
+
+</mapper>
+
+

Visuallnspection_qzd/src/main/java/com/xintong/visualinspection/visuallnspection_qzd/service/impl/RecordServiceImpl.java

@@ -0,0 +1,136 @@
+package com.xintong.visualinspection.visuallnspection_qzd.service.impl;
+
+/**
+ * 文件名：TaskServiceImpl_F
+ * 版本信息：日期：2017/4/7 Copyright 江苏省交通规划设计院 Corporation 2017 版权所有.
+ *
+ * @author wenhongquan
+ * @date 2018/04/11
+ */
+
+import com.alibaba.dubbo.config.annotation.Reference;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.xintong.visualinspection.bean.*;
+import com.xintong.visualinspection.pojo.fwq.CheckAreaData;
+import com.xintong.visualinspection.pojo.fwq.TaskData_F;
+import com.xintong.visualinspection.service.CommonService;
+import com.xintong.visualinspection.service.RecordService_Q;
+import com.xintong.visualinspection.service.TaskService_F;
+import com.xintong.visualinspection.util.Constants;
+import com.xintong.visualinspection.visuallnspection_qzd.dao.FwqTaskDao;
+import com.xintong.visualinspection.visuallnspection_qzd.dao.QzdRecordDao;
+import org.apache.poi.util.StringUtil;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+
+@com.alibaba.dubbo.config.annotation.Service(
+        version = "1.0.0",
+        application = "${dubbo.application.id}",
+        protocol = "${dubbo.protocol.id}",
+        registry = "${dubbo.registry.id}"
+)
+public class RecordServiceImpl implements RecordService_Q {
+    private static final org.slf4j.Logger logger = LoggerFactory.getLogger(RecordServiceImpl.class);
+
+    @Autowired
+    private QzdRecordDao qzdRecordDao;
+
+
+    @Reference(version = "1.0.0",
+            application = "${dubbo.application.id}",
+            registry = "${dubbo.registry.address}")
+    private CommonService commonService;
+
+    @Override
+    public Object getAllRecord(Integer page, Integer size, QzdRecord qzdRecord) {
+        if (!(page.equals(0) && size.equals(0))) {
+            PageHelper.startPage(page, size);
+        }
+
+        List<QzdRecord> qzdRecordList = qzdRecordDao.getall(qzdRecord == null ? new QzdRecord() : qzdRecord);
+
+        Map<Long, Organ> deptMap = commonService.getDeptMap();
+        Map<Long, User> userMap = commonService.getUserMap();
+        Map<String, Constant> codeMap = commonService.getCodeMap();
+       for(QzdRecord qzdRecord1 : qzdRecordList){
+            String users = qzdRecord1.getUsers();
+            if(users != null && users != ""){
+                String[] usersdata = users.split(",");
+                String names = "";
+                for(int i=0;i<usersdata.length;i++){
+                    String ids = usersdata[i];
+                    long id = Long.parseLong(ids);
+                    String username = "";
+                   // System.out.printf("=========================================", userMap.get("2732"));
+                   try {
+                       username = userMap.get(id).getTruename();
+                   }catch (Exception e){
+                       logger.error(e.getMessage());
+                   }
+                    names  = names + username;
+                    if(i<usersdata.length-1){
+                        names =  names + ",";
+                    }
+                }
+                qzdRecord1.setUserNames(names);
+            }
+            if(qzdRecord1.getDept() != null){
+                     long a = (long)qzdRecord1.getDept();
+                     qzdRecord1.setDeptName(deptMap.get(a).getOrganname());
+            }
+            }
+        if (!(page.equals(0) && size.equals(0))) {
+            return new PageInfo<QzdRecord>(qzdRecordList);
+        }
+        return qzdRecordList;
+    }
+
+    @Override
+    public void addRecord(QzdRecord qzdRecord) {
+
+        qzdRecordDao.addRecord(qzdRecord);
+    }
+
+    @Override
+    public void updateRecord(QzdRecord qzdRecord) {
+        qzdRecordDao.updateRecord(qzdRecord);
+    }
+
+    @Override
+    public QzdRecord getRecord(QzdRecord qzdRecord) {
+        QzdRecord qzdRecordList = qzdRecordDao.getone(qzdRecord);
+        Map<Long, User> userMap = commonService.getUserMap();
+        String users = qzdRecordList.getUsers();
+        if(users != null && users != ""){
+            String[] usersdata = users.split(",");
+            String names = "";
+            for(int i=0;i<usersdata.length;i++){
+                String ids = usersdata[i];
+                long id = Long.parseLong(ids);
+                String username = "";
+                // System.out.printf("=========================================", userMap.get("2732"));
+                try {
+                    username = userMap.get(id).getTruename();
+                }catch (Exception e){
+                    logger.error(e.getMessage());
+                }
+                names  = names + username;
+                if(i<usersdata.length-1){
+                    names =  names + ",";
+                }
+            }
+            qzdRecordList.setUserNames(names);
+        }
+        return qzdRecordList;
+    }
+
+    @Override
+    public void deleteRecord(QzdRecord qzdRecord){
+        qzdRecordDao.deleteRecord(qzdRecord);
+    }
+}

Visuallnspection_qzd/src/main/java/com/xintong/visualinspection/visuallnspection_qzd/service/impl/TaskService_QImpl.java

@@ -0,0 +1,166 @@
+package com.xintong.visualinspection.visuallnspection_qzd.service.impl;
+
+import com.alibaba.dubbo.config.annotation.Reference;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.xintong.visualinspection.bean.*;
+import com.xintong.visualinspection.pojo.fwq.CheckAreaData;
+import com.xintong.visualinspection.pojo.fwq.TaskData_F;
+import com.xintong.visualinspection.pojo.qzd.TaskDate_Q;
+import com.xintong.visualinspection.service.CommonService;
+import com.xintong.visualinspection.service.TaskService_Q;
+import com.xintong.visualinspection.util.Constants;
+import com.xintong.visualinspection.visuallnspection_qzd.dao.QzdTaskDao;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+
+@com.alibaba.dubbo.config.annotation.Service(
+        version = "1.0.0",
+        application = "${dubbo.application.id}",
+        protocol = "${dubbo.protocol.id}",
+        registry = "${dubbo.registry.id}"
+)
+
+public  class TaskService_QImpl implements TaskService_Q {
+
+    private static final org.slf4j.Logger logger = LoggerFactory.getLogger(RecordServiceImpl.class);
+    @Autowired
+    private QzdTaskDao qzdTaskDao;
+
+    @Reference(version = "1.0.0",
+            application = "${dubbo.application.id}",
+            registry = "${dubbo.registry.address}")
+    private CommonService commonService;
+
+    @Override
+    public Object getAllTask(Integer page, Integer size, QzdCheckTask qzdCheckTask) {
+        if (!(page.equals(0) && size.equals(0))) {
+            PageHelper.startPage(page, size);
+        }
+        if(qzdCheckTask.getCheck_status_arr()!=null){
+            qzdCheckTask.setCheck_status(null);
+        }
+        List<QzdCheckTask> QzdCheckTaskList = qzdTaskDao.getall(qzdCheckTask == null ? new QzdCheckTask() : qzdCheckTask);
+        Map<Long, Organ> deptMap = commonService.getDeptMap();
+        Map<Long, User> userMap = commonService.getUserMap();
+        Map<String, Constant> codeMap = commonService.getCodeMap();
+        for (QzdCheckTask q : QzdCheckTaskList
+                ) {
+            if (deptMap.get(q.getChecked_dept()) != null) {
+                q.setChecked_dept_name(deptMap.get(q.getChecked_dept()).getOrganname());
+            }
+            if (userMap.get(q.getCheckman()) != null) {
+                q.setCheckman_name(userMap.get(q.getCheckman()).getTruename());
+            }
+            if (q.getCheckman() != null) {
+                q.setCheckman_name(userMap.get(q.getCheckman()).getTruename());
+            }
+
+            if (q.getChecked_dept() != null) {
+                if (deptMap.get(q.getChecked_dept()) != null) {
+                    q.setChecked_dept_name(deptMap.get(q.getChecked_dept()).getOrganname());
+                }
+            }
+            if(q.getRecheckman()!=null){
+                q.setRecheckman_name(userMap.get(q.getRecheckman()).getTruename());
+            }
+            if(q.getAppeal_result()!=null){
+                q.setAppeal_result_name(codeMap.get("appeal_result" + "_" + q.getAppeal_result() + "").getCode_name());
+            }
+        }
+
+        if (!(page.equals(0) && size.equals(0))) {
+            return new PageInfo<QzdCheckTask>(QzdCheckTaskList);
+        }
+        return QzdCheckTaskList;
+    }
+
+    @Override
+    public void addTask(QzdCheckTask qzdCheckTask) {
+        qzdTaskDao.addtask(qzdCheckTask);
+        TaskStatus taskStatus = new TaskStatus();
+        taskStatus.setCheck_status(qzdCheckTask.getCheck_status());
+        taskStatus.setCheck_status_name((commonService.getCodeMap().get("task_status_" + qzdCheckTask.getCheck_status())).getCode_name());
+        User u = commonService.getUserMap().get((long) qzdCheckTask.getCheckman());
+        if (u != null) {
+            taskStatus.setUpdate_username(u.getTruename());
+        }
+        taskStatus.setTask_id((long) qzdCheckTask.getId());
+        qzdTaskDao.insertStatus(taskStatus);
+    }
+
+    @Override
+    public void updateStatus(QzdCheckTask qzdCheckTask) {
+        qzdTaskDao.updateStatus(qzdCheckTask);
+        //添加状态
+        if (qzdCheckTask.getCheck_status() != null) {
+            TaskStatus taskStatus = new TaskStatus();
+            taskStatus.setCheck_status(qzdCheckTask.getCheck_status());
+            taskStatus.setCheck_status_name((commonService.getCodeMap().get("task_status_" + qzdCheckTask.getCheck_status())).getCode_name());
+            User u = commonService.getUserMap().get((long) qzdCheckTask.getUpdate_user());
+            if (u != null) {
+                taskStatus.setUpdate_username(u.getTruename());
+            }
+            taskStatus.setTask_id((long) qzdCheckTask.getId());
+            qzdTaskDao.insertStatus(taskStatus);
+
+
+        }
+
+    }
+
+    @Override
+    public QzdCheckTask getTask(QzdCheckTask qzdCheckTask) {
+        return qzdTaskDao.getone(qzdCheckTask);
+    }
+
+    @Override
+    public void addTask(TaskDate_Q taskData_f) throws Exception {
+        List<QzdRecord> qzdRecord = taskData_f.getQzdRecord();
+        List<User> users = taskData_f.getUsers();
+        //CheckTaskPeriod p = commonService.getCheckTaskPeriod();
+//        if (p == null) {
+//            throw new Exception("所选任务超出当前稽查周期内！");
+//        }
+        try{
+            List<QzdCheckTask> tasklist = new ArrayList<>();
+            int count = tasklist.size() / users.size();
+            int u_index = 0;
+            int index = 0;
+            for (QzdRecord s : qzdRecord
+                    ) {
+                if (index++ == count) {
+                    u_index++;
+                    if (u_index == users.size()) {
+                        u_index--;
+                    }
+                }
+                try {
+                    QzdCheckTask q = new QzdCheckTask();
+                    q.setName(s.getDeptName()+s.getAddr()+"号桩"+s.getCar_info());
+                    q.setCheck_status(Constants.STATUS_ASSIGN);
+                    q.setStart_time(s.getReceived_time());
+                    q.setEnd_time(s.getBack_time());
+                    q.setCheckman((long) users.get(u_index).getId());
+                    q.setChecked_dept((long) s.getDept());
+                    q.setRule_id(6);
+                    qzdTaskDao.addtask(q);
+                }catch (Exception e){
+                    logger.error(e.getMessage());
+                }
+            }
+        }catch (Exception e){
+            logger.error(e.getMessage());
+        }
+    }
+
+    @Override
+    public List<TaskStatus> getTaskStatusList(Long id) {
+        return qzdTaskDao.getTaskStatusList(id);
+    }
+}