生产工序 ： 装车工序 运输工序

acquisition-business/src/main/java/cn/wise/sc/acquisition/business/controller/TProcessesDiggingController.java

+package cn.wise.sc.acquisition.business.controller;
+
+
+import cn.wise.im.common.http.R;
+import cn.wise.sc.acquisition.business.model.PageQuery;
+import cn.wise.sc.acquisition.business.model.query.TEquipmentRunQuery;
+import cn.wise.sc.acquisition.business.model.query.TProcessesDiggingQuery;
+import cn.wise.sc.acquisition.business.service.ITProcessesDiggingService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import javax.validation.constraints.NotBlank;
+
+/**
+ * <p>
+ *  前端控制器
+ * </p>
+ *
+ * @author ztw
+ * @since 2021-04-28
+ */
+@Api(tags = "生产工序-装车工序")
+@RestController
+@RequestMapping("/business/t-processes-digging")
+@Validated
+public class TProcessesDiggingController {
+
+	@Autowired
+	private ITProcessesDiggingService processesDiggingService;
+
+	@ApiOperation(value = "装车工序-今日数量统计", notes = "digDate 如果不传默认查询当天数据")
+	@GetMapping("/getTodayData")
+	public R getTodayData(String digDate) {
+		return processesDiggingService.getTodayData(digDate);
+	}
+
+
+	@ApiOperation(value = "装车工序分页")
+	@ApiImplicitParams(value = {
+			@ApiImplicitParam(name = "digDate", value = "装车时间", paramType = "query", dataType = "String")
+	})
+	@GetMapping("/getPage")
+	public R getPage(PageQuery pageQuery, String digDate) {
+		return processesDiggingService.getPage(pageQuery, digDate);
+	}
+
+
+	@ApiOperation(value = "保存装车工序")
+	@PostMapping("/save")
+	public R save(@RequestBody TProcessesDiggingQuery query) {
+		return processesDiggingService.save(query);
+	}
+
+	@ApiOperation(value = "修改装车工序")
+	@PostMapping("/update")
+	public R update(@RequestBody TProcessesDiggingQuery query) {
+		return processesDiggingService.update(query);
+	}
+
+	@ApiOperation(value = "装车工序详情")
+	@GetMapping("/getDetail/{Uid}")
+	public R getDetail(@PathVariable @NotBlank String Uid) {
+		return processesDiggingService.getDetail(Uid);
+	}
+
+
+
+
+}
+

acquisition-business/src/main/java/cn/wise/sc/acquisition/business/entity/TProcessesDigging.java

+package cn.wise.sc.acquisition.business.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.time.LocalDateTime;
+import com.baomidou.mybatisplus.annotation.TableField;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 
+ * </p>
+ *
+ * @author ztw
+ * @since 2021-04-28
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+@TableName("T_Processes_Digging")
+public class TProcessesDigging implements Serializable {
+
+    private static final long serialVersionUID=1L;
+
+    /**
+     * ID号
+     */
+
+    @TableId(value = "Uid", type = IdType.ASSIGN_UUID)
+    private String Uid;
+
+    /**
+     * 采区名称
+     */
+    @TableField("StopeName")
+    private String StopeName;
+
+    /**
+     * 平台名称
+     */
+    @TableField("StepName")
+    private String StepName;
+
+    /**
+     * 爆区名称
+     */
+    @TableField("BlastAreaName")
+    private String BlastAreaName;
+
+    /**
+     * 装车日期
+     */
+    @TableField("DigDate")
+    private LocalDateTime DigDate;
+
+    /**
+     * 项目经理
+     */
+    @TableField("Manager")
+    private String Manager;
+
+    /**
+     * 主管项目领导
+     */
+    @TableField("Supervisor")
+    private String Supervisor;
+
+    /**
+     * 生产技术部
+     */
+    @TableField("TechDepart")
+    private String TechDepart;
+
+    /**
+     * 制表人
+     */
+    @TableField("Tabulator")
+    private String Tabulator;
+
+    /**
+     * 挖机编号
+     */
+    @TableField("EquipmentID")
+    private String EquipmentID;
+
+    /**
+     * 司机
+     */
+    @TableField("Driver")
+    private String Driver;
+
+    /**
+     * 工作内容
+     */
+    @TableField("WorkType")
+    private String WorkType;
+
+    /**
+     * 挖机开始读数（H）
+     */
+    @TableField("StartTime")
+    private Float StartTime;
+
+    /**
+     * 挖机结束读数（H）
+     */
+    @TableField("EndTime")
+    private Float EndTime;
+
+    /**
+     * 挖机工作时间（H）
+     */
+    @TableField("WorkTime")
+    private Float WorkTime;
+
+    /**
+     * 完成吨位
+     */
+    @TableField("Workload")
+    private Double Workload;
+
+    /**
+     * 备注
+     */
+    @TableField("Bz")
+    private String Bz;
+
+    /**
+     * 日期标记,如:2021年01月
+     */
+    @TableField("Tag")
+    private String Tag;
+
+
+}

acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/TProcessesDiggingMapper.java

+package cn.wise.sc.acquisition.business.mapper;
+
+import cn.wise.sc.acquisition.business.entity.TProcessesDigging;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * <p>
+ *  Mapper 接口
+ * </p>
+ *
+ * @author ztw
+ * @since 2021-04-28
+ */
+public interface TProcessesDiggingMapper extends BaseMapper<TProcessesDigging> {
+
+}

acquisition-business/src/main/java/cn/wise/sc/acquisition/business/mapper/xml/TProcessesDiggingMapper.xml

+<?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="cn.wise.sc.acquisition.business.mapper.TProcessesDiggingMapper">
+
+</mapper>

acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/ITProcessesDiggingService.java

+package cn.wise.sc.acquisition.business.service;
+
+import cn.wise.im.common.http.R;
+import cn.wise.sc.acquisition.business.entity.TProcessesDigging;
+import cn.wise.sc.acquisition.business.model.PageQuery;
+import cn.wise.sc.acquisition.business.model.query.TProcessesDiggingQuery;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * <p>
+ *  服务类
+ * </p>
+ *
+ * @author ztw
+ * @since 2021-04-28
+ */
+public interface ITProcessesDiggingService extends IService<TProcessesDigging> {
+
+	R getTodayData(String digDate);
+
+	R<IPage<TProcessesDigging>> getPage(PageQuery pageQuery, String digDate);
+
+	R save(TProcessesDiggingQuery query);
+
+	R update(TProcessesDiggingQuery query);
+
+	R<TProcessesDigging> getDetail(String Uid);
+
+
+
+}

acquisition-business/src/main/java/cn/wise/sc/acquisition/business/service/impl/TProcessesDiggingServiceImpl.java

+package cn.wise.sc.acquisition.business.service.impl;
+
+import cn.wise.im.common.http.R;
+import cn.wise.sc.acquisition.business.constant.Rcode;
+import cn.wise.sc.acquisition.business.entity.TEquipmentAccount;
+import cn.wise.sc.acquisition.business.entity.TProcessesDigging;
+import cn.wise.sc.acquisition.business.mapper.TProcessesDiggingMapper;
+import cn.wise.sc.acquisition.business.model.PageQuery;
+import cn.wise.sc.acquisition.business.model.query.TEquipmentAccountQuery;
+import cn.wise.sc.acquisition.business.model.query.TProcessesDiggingQuery;
+import cn.wise.sc.acquisition.business.service.ITProcessesDiggingService;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import io.swagger.annotations.ApiModelProperty;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * <p>
+ *  服务实现类
+ * </p>
+ *
+ * @author ztw
+ * @since 2021-04-28
+ */
+@Service
+@Transactional
+public class TProcessesDiggingServiceImpl extends ServiceImpl<TProcessesDiggingMapper, TProcessesDigging> implements ITProcessesDiggingService {
+
+	@Resource
+	private TProcessesDiggingMapper processesDiggingMapper;
+
+
+	/**
+	 * 今日数量统计
+	 * @param digDate
+	 * @return
+	 */
+	@Override
+	public R getTodayData(String digDate){
+		Map<String,Object> map = new HashMap<>();
+		QueryWrapper<TProcessesDigging> qw = new QueryWrapper<>();
+		if(StringUtils.isNoneBlank(digDate)){
+			qw.apply("DATE(DigDate) = digDate");
+		}else{
+			qw.apply("DATE(DigDate) = DATE(now())");
+		}
+		List<TProcessesDigging> list =  processesDiggingMapper.selectList(qw);
+		Float workTimes = list.stream().map(p -> p.getWorkTime()).reduce(Float::sum).get();
+		Double workLoads = list.stream().mapToDouble(TProcessesDigging::getWorkload).sum();
+		map.put("workTimes",workTimes);
+		map.put("workLoads",workLoads);
+		return R.ok(map);
+
+	}
+
+	/**
+	 * 分页列表
+	 * @param pageQuery
+	 * @param digDate
+	 * @return
+	 */
+	@Override
+	public R<IPage<TProcessesDigging>> getPage(PageQuery pageQuery, String digDate) {
+		QueryWrapper<TProcessesDigging> qw = new QueryWrapper<>();
+		if(StringUtils.isNoneBlank(digDate)){
+			qw.apply("DATE(DigDate) = digDate");
+		}
+		qw.orderByDesc("DigDate");
+		IPage<TProcessesDigging> page = new Page<>(pageQuery.getPageNo(), pageQuery.getPageSize());
+		page = processesDiggingMapper.selectPage(page, qw);
+		return R.ok(page);
+	}
+
+	/**
+	 * 新增
+	 * @param query
+	 * @return
+	 */
+	@Override
+	public R save(TProcessesDiggingQuery query){
+		Rcode.NOT_PARAM.assertNotNull(query);
+		Rcode.NOT_PARAM.assertNotNull(query.getStopeName());
+		Rcode.NOT_PARAM.assertNotNull(query.getStepName());
+		Rcode.NOT_PARAM.assertNotNull(query.getBlastAreaName());
+		TProcessesDigging digging = new TProcessesDigging();
+		BeanUtils.copyProperties(query, digging);
+		processesDiggingMapper.insert(digging);
+		return R.ok();
+	}
+
+	/**
+	 * 修改
+	 * @param query
+	 * @return
+	 */
+	@Override
+	public R update(TProcessesDiggingQuery query) {
+		Rcode.NOT_PARAM.assertNotNull(query);
+		Rcode.NOT_PARAM.assertNotNull(query.getUid());
+		TProcessesDigging digging = processesDiggingMapper.selectById(query.getUid());
+		Rcode.NOT_FOUND.assertNotNull(digging);
+		BeanUtils.copyProperties(query, digging);
+		processesDiggingMapper.updateById(digging);
+		return R.ok();
+	}
+
+	/**
+	 * 详情
+	 * @param Uid
+	 * @return
+	 */
+	@Override
+	public R<TProcessesDigging> getDetail(String Uid) {
+		Rcode.NOT_PARAM.assertNotNull(Uid);
+		TProcessesDigging digging = processesDiggingMapper.selectById(Uid);
+		Rcode.NOT_FOUND.assertNotNull(digging);
+		return R.ok(digging);
+	}
+
+
+
+
+
+
+
+
+
+
+}