Commit 08d7b6c3 authored by renchao's avatar renchao

生产工序业务修改

parent 2037ac40
...@@ -10,22 +10,20 @@ import io.swagger.annotations.ApiImplicitParam; ...@@ -10,22 +10,20 @@ import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.*;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod; import javax.validation.constraints.NotBlank;
import org.springframework.web.bind.annotation.RestController;
/** /**
* <p> * <p>
* 前端控制器 * 前端控制器
* </p> * </p>
* *
* @author renchao * @author renchao
* @since 2021-04-30 * @since 2021-04-30
*/ */
@RestController @RestController
@Api(tags = "生成工序-辅助工序") @Api(tags = "生成工序-破碎工序")
@RequestMapping("/business/t-processes-crusher") @RequestMapping("/business/t-processes-crusher")
public class TProcessesCrusherController { public class TProcessesCrusherController {
...@@ -72,5 +70,19 @@ public class TProcessesCrusherController { ...@@ -72,5 +70,19 @@ public class TProcessesCrusherController {
public R insertTProcessesCrusher(@RequestBody TProcessesCrusherQuery tProcessesCrusherQuery) { public R insertTProcessesCrusher(@RequestBody TProcessesCrusherQuery tProcessesCrusherQuery) {
return itProcessesCrusherService.insertTProcessesCrusher(tProcessesCrusherQuery); return itProcessesCrusherService.insertTProcessesCrusher(tProcessesCrusherQuery);
} }
/**
* 根据uid获取破碎工序
*
* @return
*/
@ApiOperation(value = "根据uid获取破碎工序")
@GetMapping(value = "/getByUid/{uid}")
public R getByUid(@PathVariable @NotBlank String uid) {
TProcessesCrusherQuery tProcessesCrusherQuery = new TProcessesCrusherQuery();
tProcessesCrusherQuery.setUid(uid);
return itProcessesCrusherService.getByUid(tProcessesCrusherQuery);
}
} }
...@@ -3,16 +3,20 @@ package cn.wise.sc.acquisition.business.entity; ...@@ -3,16 +3,20 @@ package cn.wise.sc.acquisition.business.entity;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable; import java.io.Serializable;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
/** /**
* <p> * <p>
* *
* </p> * </p>
* *
* @author renchao * @author renchao
...@@ -24,12 +28,12 @@ import lombok.experimental.Accessors; ...@@ -24,12 +28,12 @@ import lombok.experimental.Accessors;
@TableName("T_Processes_Drilling") @TableName("T_Processes_Drilling")
public class TProcessesDrilling implements Serializable { public class TProcessesDrilling implements Serializable {
private static final long serialVersionUID=1L; private static final long serialVersionUID = 1L;
/** /**
* ID号 * ID号
*/ */
@TableId(value = "Uid", type = IdType.ASSIGN_UUID) @TableId(value = "Uid", type = IdType.ASSIGN_UUID)
private String Uid; private String Uid;
/** /**
......
...@@ -4,13 +4,15 @@ import com.baomidou.mybatisplus.annotation.TableName; ...@@ -4,13 +4,15 @@ import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable; import java.io.Serializable;
import java.time.LocalDateTime;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;
/** /**
* <p> * <p>
* *
* </p> * </p>
* *
* @author ztw * @author ztw
...@@ -31,16 +33,11 @@ public class TWeight implements Serializable { ...@@ -31,16 +33,11 @@ public class TWeight implements Serializable {
private String Uid; private String Uid;
/** /**
* 日期 * 日期 日期=日期+时间
*/ */
@TableField("Rq") @TableField("Rq")
private String Rq; private LocalDateTime Rq;
/**
* 时间
*/
@TableField("Sj")
private String Sj;
/** /**
* 矿车编号 * 矿车编号
...@@ -73,4 +70,69 @@ public class TWeight implements Serializable { ...@@ -73,4 +70,69 @@ public class TWeight implements Serializable {
private String Tag; private String Tag;
/**
* 毛重时间
*/
@TableField("Mzsj")
private LocalDateTime Mzsj;
/**
* 皮重时间
*/
@TableField("Pzsj")
private LocalDateTime Pzsj;
/**
* 操作员
*/
@TableField("Czy")
private String Czy;
/**
* 台号
*/
@TableField("Th")
private String Th;
/**
* 出入类型
*/
@TableField("Crlx")
private String Crlx;
/**
* 备用2
*/
@TableField("BeiY")
private String BeiY;
/**
* 收货
*/
@TableField("Sh")
private String Sh;
/**
* 发货
*/
@TableField("Fh")
private String Fh;
/**
* 货名
*/
@TableField("Hm")
private String Hm;
/**
* 车号
*/
@TableField("Ch")
private String Ch;
/**
* 序号
*/
@TableField("Xh")
private String Xh;
} }
...@@ -205,12 +205,12 @@ public class ProjectEnum { ...@@ -205,12 +205,12 @@ public class ProjectEnum {
* 根据value,获取label * 根据value,获取label
*/ */
public static String getLabel(int value) { public static String getLabel(int value) {
for (TSampleListType c : TSampleListType.values()) { for (TableAlias c : TableAlias.values()) {
if (c.value == value) { if (c.value == value) {
return c.label; return c.label;
} }
} }
return TSampleListType.YH.label; return TableAlias.A.label;
} }
/** /**
...@@ -239,6 +239,67 @@ public class ProjectEnum { ...@@ -239,6 +239,67 @@ public class ProjectEnum {
} }
/**
* 数据库别名字段 例如select * from TProcessesBlastdesignVolume b,会在queryWrapper中用到
*/
public enum TWeight {
JZ(1, "Jz","净重"),
RQ(2, "Rq","日期");
// 成员变量
private int value;
private String label;
private String explain;
// 构造方法
TWeight(int value, String label, String explain) {
this.value = value;
this.label = label;
this.explain = explain;
}
/**
* 根据value,获取label
*/
public static String getLabel(int value) {
for (TWeight c : TWeight.values()) {
if (c.value == value) {
return c.label;
}
}
return TWeight.JZ.label;
}
/**
* 根据label,获取value
*/
public static int getValue(String label) {
for (TWeight c : TWeight.values()) {
if (StringUtils.equalsIgnoreCase(label, c.label)) {
return c.value;
}
}
return TWeight.JZ.value;
}
public int getValue() {
return value;
}
public String getLabel() {
return label;
}
public String getexplain() {
return explain;
}
}
/** /**
* 炮孔设计模块业务枚举 * 炮孔设计模块业务枚举
*/ */
...@@ -396,8 +457,8 @@ public class ProjectEnum { ...@@ -396,8 +457,8 @@ public class ProjectEnum {
*/ */
public enum TProcessesBlastdesignHole { public enum TProcessesBlastdesignHole {
UID(1, "StopeName","采区名称"), UID(0, "Uid","uid"),
STOPE_NAME(1, "StopeName","采区名称"),
STEP_NAME(2, "StepName","平台名称"), STEP_NAME(2, "StepName","平台名称"),
Blast_Area_Name(3, "BlastAreaName","爆区名称"), Blast_Area_Name(3, "BlastAreaName","爆区名称"),
BLAST_HOLE_ID(4, "BlastHoleID","炮孔编号"), BLAST_HOLE_ID(4, "BlastHoleID","炮孔编号"),
...@@ -488,9 +549,18 @@ public class ProjectEnum { ...@@ -488,9 +549,18 @@ public class ProjectEnum {
*/ */
public enum TProcessesBlast { public enum TProcessesBlast {
UID(1, "Uid","爆破工序uid"),
BLAST_DATE(2, "BlastDate","别名a"); UID(1, "Uid","uid"),
DESIGN_DEPTH(2, "DesignDepth","设计孔深"),
HOLE_BLAST_VOLUME(3, "HoleBlastVolume","单孔爆破量"),
DEPTH(4, "Depth","实测孔深"),
HOLE_ID(5, "HoleID","炮孔编号"),
BLAST_DATE(6, "BlastDate","别名a");
// 成员变量 // 成员变量
...@@ -550,7 +620,7 @@ public class ProjectEnum { ...@@ -550,7 +620,7 @@ public class ProjectEnum {
*/ */
public enum TProcessesDrilling { public enum TProcessesDrilling {
UID(1, "Uid","uid"), UID(1, "Uid","Uid"),
DRILLING_DATE(2, "DrillingDate","穿孔日期"), DRILLING_DATE(2, "DrillingDate","穿孔日期"),
DEPTH(3, "Depth","孔深"), DEPTH(3, "Depth","孔深"),
ROW_SPACE(4, "RowSpace","排距(m)"), ROW_SPACE(4, "RowSpace","排距(m)"),
...@@ -559,7 +629,8 @@ public class ProjectEnum { ...@@ -559,7 +629,8 @@ public class ProjectEnum {
DESIGN_ROW_SPACE(7, "DesignRowSpace","设计排距(m)"), DESIGN_ROW_SPACE(7, "DesignRowSpace","设计排距(m)"),
DESIGN_HOLE_SPACE(8, "DesignHoleSpace","设计孔距(m)"), DESIGN_HOLE_SPACE(8, "DesignHoleSpace","设计孔距(m)"),
STEP_HEIGHT(9, "StepHeight","台阶高度"), STEP_HEIGHT(9, "StepHeight","台阶高度"),
HOLE_BLAST_VOLUME(10, "HoleBlastVolume","单孔爆破量"); HOLE_BLAST_VOLUME(10, "HoleBlastVolume","单孔爆破量"),
HOLE_ID(10, "HoleID","炮孔编号");
// 成员变量 // 成员变量
private int value; private int value;
......
...@@ -9,7 +9,7 @@ import org.apache.ibatis.annotations.Param; ...@@ -9,7 +9,7 @@ import org.apache.ibatis.annotations.Param;
/** /**
* <p> * <p>
* Mapper 接口 * Mapper 接口
* </p> * </p>
* *
* @author renchao * @author renchao
...@@ -19,4 +19,6 @@ public interface TProcessesBlastMapper extends BaseMapper<TProcessesBlast> { ...@@ -19,4 +19,6 @@ public interface TProcessesBlastMapper extends BaseMapper<TProcessesBlast> {
Page<TProcessesBlastVo> getPage(Page<TProcessesBlast> page, @Param("ew") QueryWrapper<TProcessesBlast> queryWrapper); Page<TProcessesBlastVo> getPage(Page<TProcessesBlast> page, @Param("ew") QueryWrapper<TProcessesBlast> queryWrapper);
TProcessesBlastVo getByQuery(@Param("ew") QueryWrapper<TProcessesBlast> queryWrapper);
} }
...@@ -20,7 +20,7 @@ public interface TProcessesBlastdesignHoleMapper extends BaseMapper<TProcessesBl ...@@ -20,7 +20,7 @@ public interface TProcessesBlastdesignHoleMapper extends BaseMapper<TProcessesBl
Page<TProcessesBlastdesignHoleVo> getPage(Page<TProcessesBlastdesignHole> page, @Param("ew") QueryWrapper<TProcessesBlastdesignHole> queryWrapper); Page<TProcessesBlastdesignHoleVo> getPage(Page<TProcessesBlastdesignHole> page, @Param("ew") QueryWrapper<TProcessesBlastdesignHole> queryWrapper);
TProcessesBlastdesignHoleVo getByUId(@Param("ew") QueryWrapper<TProcessesBlastdesignHole> queryWrapper); TProcessesBlastdesignHoleVo getByQuery(@Param("ew") QueryWrapper<TProcessesBlastdesignHole> queryWrapper);
Double getSumByCondition(@Param("condition") String condition, @Param("ew") QueryWrapper<TProcessesBlastdesignHole> queryWrapper); Double getSumByCondition(@Param("condition") String condition, @Param("ew") QueryWrapper<TProcessesBlastdesignHole> queryWrapper);
......
...@@ -9,7 +9,7 @@ import org.apache.ibatis.annotations.Param; ...@@ -9,7 +9,7 @@ import org.apache.ibatis.annotations.Param;
/** /**
* <p> * <p>
* Mapper 接口 * Mapper 接口
* </p> * </p>
* *
* @author renchao * @author renchao
...@@ -19,4 +19,6 @@ public interface TProcessesCrusherMapper extends BaseMapper<TProcessesCrusher> { ...@@ -19,4 +19,6 @@ public interface TProcessesCrusherMapper extends BaseMapper<TProcessesCrusher> {
Page<TProcessesCrusherVo> getPage(Page<TProcessesCrusher> page, @Param("ew") QueryWrapper<TProcessesCrusher> queryWrapper); Page<TProcessesCrusherVo> getPage(Page<TProcessesCrusher> page, @Param("ew") QueryWrapper<TProcessesCrusher> queryWrapper);
Page<TProcessesCrusherVo> getByQuery(@Param("ew") QueryWrapper<TProcessesCrusher> queryWrapper);
} }
...@@ -20,7 +20,7 @@ public interface TProcessesDrillingMapper extends BaseMapper<TProcessesDrilling> ...@@ -20,7 +20,7 @@ public interface TProcessesDrillingMapper extends BaseMapper<TProcessesDrilling>
Page<TProcessesDrillingVo> getPage(Page<TProcessesDrilling> page, @Param("ew") QueryWrapper<TProcessesDrilling> queryWrapper); Page<TProcessesDrillingVo> getPage(Page<TProcessesDrilling> page, @Param("ew") QueryWrapper<TProcessesDrilling> queryWrapper);
TProcessesDrillingVo getByUid(@Param("ew") QueryWrapper<TProcessesDrilling> queryWrapper); TProcessesDrillingVo getByQuery(@Param("ew") QueryWrapper<TProcessesDrilling> queryWrapper);
Double getSumByCondition(@Param("condition") String condition, @Param("ew") QueryWrapper<TProcessesDrilling> queryWrapper); Double getSumByCondition(@Param("condition") String condition, @Param("ew") QueryWrapper<TProcessesDrilling> queryWrapper);
......
package cn.wise.sc.acquisition.business.mapper; package cn.wise.sc.acquisition.business.mapper;
import cn.wise.sc.acquisition.business.entity.TWeight; import cn.wise.sc.acquisition.business.entity.TWeight;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Param;
/** /**
* <p> * <p>
...@@ -13,4 +15,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper; ...@@ -13,4 +15,6 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
*/ */
public interface TWeightMapper extends BaseMapper<TWeight> { public interface TWeightMapper extends BaseMapper<TWeight> {
Double getSumByCondition(@Param("condition") String condition, @Param("ew") QueryWrapper<TWeight> queryWrapper);
} }
...@@ -24,11 +24,11 @@ ...@@ -24,11 +24,11 @@
<sql id="TProcessesDiggingHoleColumns"> <sql id="TProcessesDiggingHoleColumns">
b.HoleBlastVolume, b.HoleBlastVolume,
b.depth ,<!-- 设计孔深,将爆破工序里的depth去掉,用设计炮孔里的替代 --> b.depth AS DesignDepth,<!-- 设计孔深,将爆破工序里的depth去掉,用设计炮孔里的替代 -->
</sql> </sql>
<sql id="TProcessesDrillingColumns"> <sql id="TProcessesDrillingColumns">
c.Depth AS DesignDepth, c.Depth,
</sql> </sql>
...@@ -50,4 +50,17 @@ ...@@ -50,4 +50,17 @@
</where> </where>
</select> </select>
<!-- 获取所有getByUid列表 -->
<select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesBlastVo">
SELECT
<include refid="TProcessesDiggingHoleColumns"/>
<include refid="TProcessesDrillingColumns"/>
<include refid="TProcessesBlastColumns"/>
FROM T_Processes_Blast a
<include refid="TProcessesBlastdesignHoleJoins"/>
<where>
${ew.sqlSegment}
</where>
</select>
</mapper> </mapper>
...@@ -48,6 +48,18 @@ ...@@ -48,6 +48,18 @@
</select> </select>
<!-- 获取所有getPage列表 -->
<select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesBlastdesignHoleVo">
SELECT
<include refid="TProcessesBlastdesignVolumeColumns"/>
<include refid="TProcessesBlastdesignHoleColumns"/>
FROM T_Processes_BlastDesign_Hole a
<include refid="TProcessesBlastdesignHoleJoins"/>
<where>
${ew.sqlSegment}
</where>
</select>
<!-- 获取所有getByQuery列表 --> <!-- 获取所有getByQuery列表 -->
<select id="getSumByCondition" resultType="Double"> <select id="getSumByCondition" resultType="Double">
SELECT SELECT
......
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
a.EquipmentID, a.EquipmentID,
a.WorkType, a.WorkType,
a.WorkTime, a.WorkTime,
a.Wcdw, -- a.Wcdw, /*吨位 查吨位表中的吨位*/
a.Price, a.Price,
a.TotalMoney, a.TotalMoney,
a.Bz, a.Bz,
...@@ -23,12 +23,20 @@ ...@@ -23,12 +23,20 @@
</sql> </sql>
<sql id="TWeightColumns"> <sql id="TWeightColumns">
b.Jz, b.Wcdw, /*吨位 替换破碎工序中的吨位*/
</sql> </sql>
<sql id="TProcessesCrusherJoins"> <sql id="TProcessesCrusherJoins">
left join T_Weight b on a.EquipmentID=b.TruckID LEFT JOIN (
SELECT
Rq,
SUM (Jz) AS Wcdw /*吨位 替换破碎工序中的吨位*/
FROM
T_Weight
GROUP BY
Rq
) b ON a.CrushDate = b.Rq
</sql> </sql>
<!-- 获取所有getPage列表 --> <!-- 获取所有getPage列表 -->
...@@ -43,4 +51,17 @@ ...@@ -43,4 +51,17 @@
</where> </where>
</select> </select>
<!-- 获取所有getPage列表 -->
<select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesBlastdesignHoleVo">
SELECT
<include refid="TWeightColumns"/>
<include refid="TProcessesCrusherColumns"/>
FROM T_Processes_Crusher a
<include refid="TProcessesCrusherJoins"/>
<where>
${ew.sqlSegment}
</where>
</select>
</mapper> </mapper>
...@@ -30,8 +30,6 @@ ...@@ -30,8 +30,6 @@
a.x, a.x,
a.y, a.y,
a.z, a.z,
-- a.HoleBlastVolume, /* 用炮孔设计的爆破量 */
a.BlastDate,
a.Operator, a.Operator,
a.Accepter, a.Accepter,
...@@ -40,35 +38,40 @@ ...@@ -40,35 +38,40 @@
</sql> </sql>
<sql id="TProcessesDiggingHoleColumns"> <sql id="TProcessesDiggingHoleColumns">
b.Depth AS DesignDepth,/*孔深(m)*/ b.Depth AS DesignDepth,
b.RowSpace AS DesignRowSpace,/*排距(m)*/ b.RowSpace AS DesignRowSpace,
b.HoleSpace AS DesignHoleSpace,/*孔距(m)*/ b.HoleSpace AS DesignHoleSpace,
b.Azimuth AS DesignAzimuth,/*方位角*/ b.Azimuth AS DesignAzimuth,
b.Inclination AS DesignInclination,/*倾角*/ b.Inclination AS DesignInclination,
b.Aperture AS DesignAperture,/*孔径(m)*/ b.Aperture AS DesignAperture,
-- b.x;/*开孔坐标X*/ b.HoleBlastVolume,
-- b.y;/*开孔坐标Y*/
-- b.z;/*开孔坐标Z*/
b.HoleBlastVolume,/* 单孔爆破量(m3)=孔距*排距*台阶高度*/
</sql> </sql>
<sql id="TProcessesBlastColumns"> <sql id="TProcessesBlastColumns">
c.BlastDate c.BlastDate,
</sql>
<sql id="TProcessesBlastdesignVolumeColumns">
d.BlastVolume,
d.DesignDate,
</sql> </sql>
<sql id="TProcessesBlastdesignHoleJoins"> <sql id="TProcessesDrillingJoins">
left join T_Processes_BlastDesign_Hole b on a.HoleID = b.BlastHoleID left join T_Processes_BlastDesign_Hole b on a.HoleID = b.BlastHoleID
left join T_Processes_Blast c on a.HoleID = c.HoleID left join T_Processes_Blast c on a.HoleID = c.HoleID
left join T_Processes_BlastDesign_Volume d on a.StopeName=d.StopeName and a.StepName=d.StepName and a.BlastAreaName=d.BlastAreaName
</sql> </sql>
<!-- 获取所有getPage列表 --> <!-- 获取所有getPage列表 -->
<select id="getPage" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo"> <select id="getPage" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo">
SELECT SELECT
<include refid="TProcessesDiggingHoleColumns"/> <include refid="TProcessesDiggingHoleColumns"/>
<include refid="TProcessesDrillingColumns"/>
<include refid="TProcessesBlastColumns"/> <include refid="TProcessesBlastColumns"/>
FROM T_Processes_Blast a <include refid="TProcessesBlastdesignVolumeColumns"/>
<include refid="TProcessesBlastdesignHoleJoins"/> <include refid="TProcessesDrillingColumns"/>
FROM T_Processes_Drilling a
<include refid="TProcessesDrillingJoins"/>
<where> <where>
${ew.sqlSegment} ${ew.sqlSegment}
</where> </where>
...@@ -76,13 +79,14 @@ ...@@ -76,13 +79,14 @@
<!-- 获取所有getPage列表 --> <!-- 获取所有getPage列表 -->
<select id="getByUid" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo"> <select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo">
SELECT SELECT
<include refid="TProcessesDiggingHoleColumns"/> <include refid="TProcessesDiggingHoleColumns"/>
<include refid="TProcessesDrillingColumns"/>
<include refid="TProcessesBlastColumns"/> <include refid="TProcessesBlastColumns"/>
FROM T_Processes_Blast a <include refid="TProcessesBlastdesignVolumeColumns"/>
<include refid="TProcessesBlastdesignHoleJoins"/> <include refid="TProcessesDrillingColumns"/>
FROM T_Processes_Drilling a
<include refid="TProcessesDrillingJoins"/>
<where> <where>
${ew.sqlSegment} ${ew.sqlSegment}
</where> </where>
...@@ -92,8 +96,7 @@ ...@@ -92,8 +96,7 @@
<select id="getSumByCondition" resultType="Double"> <select id="getSumByCondition" resultType="Double">
SELECT SELECT
sum(${condition}) sum(${condition})
FROM T_Processes_Blast a FROM T_Processes_Drilling a
<include refid="TProcessesBlastdesignHoleJoins"/>
<where> <where>
${ew.sqlSegment} ${ew.sqlSegment}
</where> </where>
......
...@@ -2,4 +2,15 @@ ...@@ -2,4 +2,15 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!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.TWeightMapper"> <mapper namespace="cn.wise.sc.acquisition.business.mapper.TWeightMapper">
<!-- 根据条件求和某字段 -->
<select id="getSumByCondition" resultType="Double">
SELECT
sum(${condition})
FROM T_Weight a
<where>
${ew.sqlSegment}
</where>
</select>
</mapper> </mapper>
...@@ -8,7 +8,7 @@ import java.time.LocalDateTime; ...@@ -8,7 +8,7 @@ import java.time.LocalDateTime;
/** /**
* <p> * <p>
* *
* </p> * </p>
* *
* @author renchao * @author renchao
...@@ -28,176 +28,205 @@ public class TProcessesDrillingQuery { ...@@ -28,176 +28,205 @@ public class TProcessesDrillingQuery {
/** /**
* 采区名称 * 采区名称
*/ */
@ApiModelProperty("StopeName") @ApiModelProperty("StopeName")
private String StopeName; private String StopeName;
/** /**
* 平台名称 * 平台名称
*/ */
@ApiModelProperty("StepName") @ApiModelProperty("StepName")
private String StepName; private String StepName;
/** /**
* 爆区名称 * 爆区名称
*/ */
@ApiModelProperty("BlastAreaName") @ApiModelProperty("BlastAreaName")
private String BlastAreaName; private String BlastAreaName;
/** /**
* 炮孔编号 * 炮孔编号
*/ */
@ApiModelProperty("HoleID") @ApiModelProperty("HoleID")
private String HoleID; private String HoleID;
/** /**
* 穿孔日期 * 穿孔日期
*/ */
@ApiModelProperty("DrillingDate") @ApiModelProperty("DrillingDate")
private LocalDateTime DrillingDate; private LocalDateTime DrillingDate;
/** /**
* 项目经理 * 项目经理
*/ */
@ApiModelProperty("Manager") @ApiModelProperty("Manager")
private String Manager; private String Manager;
/** /**
* 主管项目领导 * 主管项目领导
*/ */
@ApiModelProperty("Supervisor") @ApiModelProperty("Supervisor")
private String Supervisor; private String Supervisor;
/** /**
* 生产技术部 * 生产技术部
*/ */
@ApiModelProperty("TechDepart") @ApiModelProperty("TechDepart")
private String TechDepart; private String TechDepart;
/** /**
* 制表人 * 制表人
*/ */
@ApiModelProperty("Tabulator") @ApiModelProperty("Tabulator")
private String Tabulator; private String Tabulator;
/** /**
* 钻机编号 * 钻机编号
*/ */
@ApiModelProperty("EquipmentID") @ApiModelProperty("EquipmentID")
private String EquipmentID; private String EquipmentID;
/** /**
* 司机 * 司机
*/ */
@ApiModelProperty("Driver") @ApiModelProperty("Driver")
private String Driver; private String Driver;
/** /**
* 钻机开始读数(H) * 钻机开始读数(H)
*/ */
@ApiModelProperty("StartTime") @ApiModelProperty("StartTime")
private Float StartTime; private Float StartTime;
/** /**
* 钻机结束读数(H) * 钻机结束读数(H)
*/ */
@ApiModelProperty("EndTime") @ApiModelProperty("EndTime")
private Float EndTime; private Float EndTime;
/** /**
* 钻机工作时间(H) * 钻机工作时间(H)
*/ */
@ApiModelProperty("WorkTime") @ApiModelProperty("WorkTime")
private Float WorkTime; private Float WorkTime;
/** /**
* 孔深(m) * 孔深(m)
*/ */
@ApiModelProperty("Depth") @ApiModelProperty("Depth")
private Double Depth; private Double Depth;
/** /**
* 排距(m) * 排距(m)
*/ */
@ApiModelProperty("RowSpace") @ApiModelProperty("RowSpace")
private Double RowSpace; private Double RowSpace;
/** /**
* 孔距(m) * 孔距(m)
*/ */
@ApiModelProperty("HoleSpace") @ApiModelProperty("HoleSpace")
private Double HoleSpace; private Double HoleSpace;
/** /**
* 方位角 * 方位角
*/ */
@ApiModelProperty("Azimuth") @ApiModelProperty("Azimuth")
private Double Azimuth; private Double Azimuth;
/** /**
* 倾角 * 倾角
*/ */
@ApiModelProperty("Inclination") @ApiModelProperty("Inclination")
private Double Inclination; private Double Inclination;
/** /**
* 孔径(m) * 孔径(m)
*/ */
@ApiModelProperty("Aperture") @ApiModelProperty("Aperture")
private Double Aperture; private Double Aperture;
/** /**
* 开孔坐标X * 开孔坐标X
*/ */
@ApiModelProperty("X") @ApiModelProperty("X")
private Double x; private Double x;
/** /**
* 开孔坐标Y * 开孔坐标Y
*/ */
@ApiModelProperty("Y") @ApiModelProperty("Y")
private Double y; private Double y;
/** /**
* 开孔坐标Z * 开孔坐标Z
*/ */
@ApiModelProperty("Z") @ApiModelProperty("Z")
private Double z; private Double z;
/** /**
* 单孔爆破量(m3) * 单孔爆破量(m3)
*/ */
@ApiModelProperty("HoleBlastVolume") @ApiModelProperty("HoleBlastVolume")
private Double HoleBlastVolume; private Double HoleBlastVolume;
/** /**
* 爆破日期 * 爆破日期
*/ */
@ApiModelProperty("BlastDate") @ApiModelProperty("BlastDate")
private LocalDateTime BlastDate; private LocalDateTime BlastDate;
/** /**
* 穿孔作业人 * 穿孔作业人
*/ */
@ApiModelProperty("Operator") @ApiModelProperty("Operator")
private String Operator; private String Operator;
/** /**
* 测量验收人 * 测量验收人
*/ */
@ApiModelProperty("Accepter") @ApiModelProperty("Accepter")
private String Accepter; private String Accepter;
/** /**
* 备注 * 备注
*/ */
@ApiModelProperty("Bz") @ApiModelProperty("Bz")
private String Bz; private String Bz;
/** /**
* 日期标记,如:2021年01月 * 日期标记,如:2021年01月
*/ */
@ApiModelProperty("Tag") @ApiModelProperty("Tag")
private String Tag; private String Tag;
//以下是增加字段 需要表连接的字段 炮孔设计
@ApiModelProperty("孔深(m)")
private Double DesignDepth;
@ApiModelProperty("排距(m)")
private Double DesignRowSpace;
@ApiModelProperty("孔距(m)")
private Double DesignHoleSpace;
@ApiModelProperty("设计方位角")
private Double DesignAzimuth;
@ApiModelProperty("设计倾角")
private Double DesignInclination;
@ApiModelProperty("设计孔径")
private Double DesignAperture;
@ApiModelProperty("台阶高度")
private Double StepHeight;
//以下是增加字段 爆破设计量表
@ApiModelProperty("爆破设计量")
private Double BlastVolume;
@ApiModelProperty("设计时间")
private LocalDateTime DesignDate;
} }
...@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel; ...@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import java.time.LocalDateTime;
/** /**
* <p> * <p>
...@@ -23,18 +25,13 @@ public class TWeightQuery { ...@@ -23,18 +25,13 @@ public class TWeightQuery {
*/ */
@ApiModelProperty("Uid") @ApiModelProperty("Uid")
private String Uid; private String Uid;
/** /**
* 日期 * 日期 日期=日期+时间
*/ */
@ApiModelProperty("Rq") @ApiModelProperty("Rq")
private String Rq; private LocalDateTime Rq;
/**
* 时间
*/
@ApiModelProperty("Sj")
private String Sj;
/** /**
* 矿车编号 * 矿车编号
...@@ -67,4 +64,69 @@ public class TWeightQuery { ...@@ -67,4 +64,69 @@ public class TWeightQuery {
private String Tag; private String Tag;
/**
* 毛重时间
*/
@ApiModelProperty("Mzsj")
private LocalDateTime Mzsj;
/**
* 皮重时间
*/
@ApiModelProperty("Pzsj")
private LocalDateTime Pzsj;
/**
* 操作员
*/
@ApiModelProperty("Czy")
private String Czy;
/**
* 台号
*/
@ApiModelProperty("Th")
private String Th;
/**
* 出入类型
*/
@ApiModelProperty("Crlx")
private String Crlx;
/**
* 备用2
*/
@ApiModelProperty("BeiY")
private String BeiY;
/**
* 收货
*/
@ApiModelProperty("Sh")
private String Sh;
/**
* 发货
*/
@ApiModelProperty("Fh")
private String Fh;
/**
* 货名
*/
@ApiModelProperty("Hm")
private String Hm;
/**
* 车号
*/
@ApiModelProperty("Ch")
private String Ch;
/**
* 序号
*/
@ApiModelProperty("Xh")
private String Xh;
} }
...@@ -24,90 +24,90 @@ public class TProcessesBlastVo { ...@@ -24,90 +24,90 @@ public class TProcessesBlastVo {
*/ */
@ApiModelProperty("Uid") @ApiModelProperty("Uid")
private String Uid; private String Uid;
//
// /** /**
// * 采区名称 * 采区名称
// */ */
// @ApiModelProperty("StopeName") @ApiModelProperty("StopeName")
// private String StopeName; private String StopeName;
//
// /** /**
// * 平台名称 * 平台名称
// */ */
// @ApiModelProperty("StepName") @ApiModelProperty("StepName")
// private String StepName; private String StepName;
//
// /** /**
// * 爆区名称 * 爆区名称
// */ */
// @ApiModelProperty("BlastAreaName") @ApiModelProperty("BlastAreaName")
// private String BlastAreaName; private String BlastAreaName;
//
// /** /**
// * 炮孔编号 * 炮孔编号
// */ */
// @ApiModelProperty("HoleID") @ApiModelProperty("HoleID")
// private String HoleID; private String HoleID;
//
// /** /**
// * 爆破日期 * 爆破日期
// */ */
// @ApiModelProperty("BlastDate") @ApiModelProperty("BlastDate")
// private LocalDateTime BlastDate; private LocalDateTime BlastDate;
//
// /** /**
// * 爆破人员 * 爆破人员
// */ */
// @ApiModelProperty("BlastPeople") @ApiModelProperty("BlastPeople")
// private String BlastPeople; private String BlastPeople;
//
// /** /**
// * 验孔日期 * 验孔日期
// */ */
// @ApiModelProperty("CheckHoleDate") @ApiModelProperty("CheckHoleDate")
// private LocalDateTime CheckHoleDate; private LocalDateTime CheckHoleDate;
//
// /** /**
// * 验孔人员 * 验孔人员
// */ */
// @ApiModelProperty("CheckHolePeople") @ApiModelProperty("CheckHolePeople")
// private String CheckHolePeople; private String CheckHolePeople;
//
// /** /**
// * 项目经理 * 项目经理
// */ */
// @ApiModelProperty("Manager") @ApiModelProperty("Manager")
// private String Manager; private String Manager;
//
// /** /**
// * 主管项目领导 * 主管项目领导
// */ */
// @ApiModelProperty("Supervisor") @ApiModelProperty("Supervisor")
// private String Supervisor; private String Supervisor;
//
// /** /**
// * 生产技术部 * 生产技术部
// */ */
// @ApiModelProperty("TechDepart") @ApiModelProperty("TechDepart")
// private String TechDepart; private String TechDepart;
//
// /** /**
// * 制表人 * 制表人
// */ */
// @ApiModelProperty("Tabulator") @ApiModelProperty("Tabulator")
// private String Tabulator; private String Tabulator;
//
//
//
// @ApiModelProperty("Bz") @ApiModelProperty("Bz")
// private String Bz; private String Bz;
//
// /** /**
// * 日期标记,如:2020年11月 * 日期标记,如:2020年11月
// */ */
// @ApiModelProperty("Tag") @ApiModelProperty("Tag")
// private String Tag; private String Tag;
//
/** /**
* 实测孔深(m) * 实测孔深(m)
......
...@@ -200,7 +200,7 @@ public class TProcessesDrillingVo { ...@@ -200,7 +200,7 @@ public class TProcessesDrillingVo {
private String Tag; private String Tag;
//以下是增加字段 需要表连接的字段 //以下是增加字段 需要表连接的字段 炮孔设计
@ApiModelProperty("孔深(m)") @ApiModelProperty("孔深(m)")
private Double DesignDepth; private Double DesignDepth;
...@@ -223,5 +223,11 @@ public class TProcessesDrillingVo { ...@@ -223,5 +223,11 @@ public class TProcessesDrillingVo {
@ApiModelProperty("台阶高度") @ApiModelProperty("台阶高度")
private Double StepHeight; private Double StepHeight;
//以下是增加字段 爆破设计量表
@ApiModelProperty("爆破设计量")
private Double BlastVolume;
@ApiModelProperty("设计时间")
private LocalDateTime DesignDate;
} }
...@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel; ...@@ -4,6 +4,8 @@ import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import java.time.LocalDateTime;
/** /**
* <p> * <p>
...@@ -23,18 +25,13 @@ public class TWeightVo { ...@@ -23,18 +25,13 @@ public class TWeightVo {
*/ */
@ApiModelProperty("Uid") @ApiModelProperty("Uid")
private String Uid; private String Uid;
/** /**
* 日期 * 日期 日期=日期+时间
*/ */
@ApiModelProperty("Rq") @ApiModelProperty("Rq")
private String Rq; private LocalDateTime Rq;
/**
* 时间
*/
@ApiModelProperty("Sj")
private String Sj;
/** /**
* 矿车编号 * 矿车编号
...@@ -67,4 +64,69 @@ public class TWeightVo { ...@@ -67,4 +64,69 @@ public class TWeightVo {
private String Tag; private String Tag;
/**
* 毛重时间
*/
@ApiModelProperty("Mzsj")
private LocalDateTime Mzsj;
/**
* 皮重时间
*/
@ApiModelProperty("Pzsj")
private LocalDateTime Pzsj;
/**
* 操作员
*/
@ApiModelProperty("Czy")
private String Czy;
/**
* 台号
*/
@ApiModelProperty("Th")
private String Th;
/**
* 出入类型
*/
@ApiModelProperty("Crlx")
private String Crlx;
/**
* 备用2
*/
@ApiModelProperty("BeiY")
private String BeiY;
/**
* 收货
*/
@ApiModelProperty("Sh")
private String Sh;
/**
* 发货
*/
@ApiModelProperty("Fh")
private String Fh;
/**
* 货名
*/
@ApiModelProperty("Hm")
private String Hm;
/**
* 车号
*/
@ApiModelProperty("Ch")
private String Ch;
/**
* 序号
*/
@ApiModelProperty("Xh")
private String Xh;
} }
...@@ -23,4 +23,6 @@ public interface ITProcessesBlastService extends IService<TProcessesBlast> { ...@@ -23,4 +23,6 @@ public interface ITProcessesBlastService extends IService<TProcessesBlast> {
R insertTProcessesBlast(TProcessesBlastQuery query); R insertTProcessesBlast(TProcessesBlastQuery query);
R getByUid(TProcessesBlastQuery query); R getByUid(TProcessesBlastQuery query);
R getByHoleId(TProcessesBlastQuery query);
} }
...@@ -20,6 +20,8 @@ public interface ITProcessesBlastdesignHoleService extends IService<TProcessesBl ...@@ -20,6 +20,8 @@ public interface ITProcessesBlastdesignHoleService extends IService<TProcessesBl
R updateByUid(TProcessesBlastdesignHoleQuery query); R updateByUid(TProcessesBlastdesignHoleQuery query);
R updateByBlastHoleID(TProcessesBlastdesignHoleQuery query);
R deleteByUid(TProcessesBlastdesignHoleQuery query); R deleteByUid(TProcessesBlastdesignHoleQuery query);
R insertTProcessesBlastdesignHole(TProcessesBlastdesignHoleQuery query); R insertTProcessesBlastdesignHole(TProcessesBlastdesignHoleQuery query);
......
...@@ -18,6 +18,8 @@ public interface ITProcessesCrusherService extends IService<TProcessesCrusher> { ...@@ -18,6 +18,8 @@ public interface ITProcessesCrusherService extends IService<TProcessesCrusher> {
R getPage(TProcessesCrusherQuery tProcessesCrusherQuery, Query query); R getPage(TProcessesCrusherQuery tProcessesCrusherQuery, Query query);
R getByUid(TProcessesCrusherQuery tProcessesCrusherQuery);
R updateByUid(TProcessesCrusherQuery query); R updateByUid(TProcessesCrusherQuery query);
R insertTProcessesCrusher(TProcessesCrusherQuery query); R insertTProcessesCrusher(TProcessesCrusherQuery query);
......
...@@ -22,6 +22,10 @@ public interface ITProcessesDrillingService extends IService<TProcessesDrilling> ...@@ -22,6 +22,10 @@ public interface ITProcessesDrillingService extends IService<TProcessesDrilling>
R updateByUid(TProcessesDrillingQuery query); R updateByUid(TProcessesDrillingQuery query);
R updateByHoleId(TProcessesDrillingQuery query);
R getByUid(TProcessesDrillingQuery query); R getByUid(TProcessesDrillingQuery query);
R getByHoleId(TProcessesDrillingQuery query);
} }
...@@ -14,5 +14,8 @@ import com.baomidou.mybatisplus.extension.service.IService; ...@@ -14,5 +14,8 @@ import com.baomidou.mybatisplus.extension.service.IService;
* @since 2021-04-26 * @since 2021-04-26
*/ */
public interface ITWeightService extends IService<TWeight> { public interface ITWeightService extends IService<TWeight> {
R getByQuery(TWeightQuery query); R getByQuery(TWeightQuery query);
R getSumJz(TWeightQuery query);
} }
...@@ -6,9 +6,13 @@ import cn.wise.sc.acquisition.business.enumation.ProjectEnum; ...@@ -6,9 +6,13 @@ import cn.wise.sc.acquisition.business.enumation.ProjectEnum;
import cn.wise.sc.acquisition.business.mapper.TProcessesBlastMapper; import cn.wise.sc.acquisition.business.mapper.TProcessesBlastMapper;
import cn.wise.sc.acquisition.business.model.query.TMineStopeQuery; import cn.wise.sc.acquisition.business.model.query.TMineStopeQuery;
import cn.wise.sc.acquisition.business.model.query.TProcessesBlastQuery; import cn.wise.sc.acquisition.business.model.query.TProcessesBlastQuery;
import cn.wise.sc.acquisition.business.model.query.TProcessesBlastdesignHoleQuery;
import cn.wise.sc.acquisition.business.model.query.TProcessesDrillingQuery;
import cn.wise.sc.acquisition.business.model.vo.TProcessesBlastVo; import cn.wise.sc.acquisition.business.model.vo.TProcessesBlastVo;
import cn.wise.sc.acquisition.business.service.ITMineStopeService; import cn.wise.sc.acquisition.business.service.ITMineStopeService;
import cn.wise.sc.acquisition.business.service.ITProcessesBlastService; import cn.wise.sc.acquisition.business.service.ITProcessesBlastService;
import cn.wise.sc.acquisition.business.service.ITProcessesBlastdesignHoleService;
import cn.wise.sc.acquisition.business.service.ITProcessesDrillingService;
import cn.wise.sc.acquisition.business.util.BeanUtilsNewCopy; import cn.wise.sc.acquisition.business.util.BeanUtilsNewCopy;
import cn.wise.sc.acquisition.business.util.DateUtil; import cn.wise.sc.acquisition.business.util.DateUtil;
import cn.wise.sc.acquisition.business.wrapper.page.Query; import cn.wise.sc.acquisition.business.wrapper.page.Query;
...@@ -38,6 +42,12 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -38,6 +42,12 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
@Autowired @Autowired
private ITMineStopeService itMineStopeService; private ITMineStopeService itMineStopeService;
@Autowired
private ITProcessesBlastdesignHoleService itProcessesBlastdesignHoleService;
@Autowired
private ITProcessesDrillingService itProcessesDrillingService;
@Override @Override
public R getPage(TProcessesBlastQuery tProcessesBlastQuery, Query query) { public R getPage(TProcessesBlastQuery tProcessesBlastQuery, Query query) {
log.info(JSON.toJSONString(tProcessesBlastQuery)); log.info(JSON.toJSONString(tProcessesBlastQuery));
...@@ -46,6 +56,12 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -46,6 +56,12 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
Page<TProcessesBlast> page = new Page<>(query.getPageNum(), query.getPageSize()); Page<TProcessesBlast> page = new Page<>(query.getPageNum(), query.getPageSize());
//条件封装 //条件封装
QueryWrapper<TProcessesBlast> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesBlast> queryWrapper = new QueryWrapper<>();
queryWrapper.select(
ProjectEnum.TProcessesBlast.DEPTH.getLabel(),
ProjectEnum.TProcessesBlast.DESIGN_DEPTH.getLabel(),
ProjectEnum.TProcessesBlast.HOLE_ID.getLabel(),
ProjectEnum.TProcessesBlast.HOLE_BLAST_VOLUME.getLabel()
);
//如果设计时间不为空 因为涉及到表连接,需要创建字段别名 //如果设计时间不为空 因为涉及到表连接,需要创建字段别名
if (tProcessesBlastQuery.getBlastDate() != null) { if (tProcessesBlastQuery.getBlastDate() != null) {
StringBuilder stringBuilder = new StringBuilder(); StringBuilder stringBuilder = new StringBuilder();
...@@ -65,12 +81,21 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -65,12 +81,21 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
log.info(JSON.toJSONString(query)); log.info(JSON.toJSONString(query));
//参数校验 //参数校验
Rcode.NOT_PARAM.assertNotNull(query); Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotNull(query.getUid());
//判断数据是否存在 //判断数据是否存在
TProcessesBlast temp = baseMapper.selectById(query.getUid()); TProcessesBlast temp = baseMapper.selectById(query.getUid());
if (temp == null) { if (temp == null) {
return R.failed("数据不存在,uid:" + query.getUid()); return R.failed("数据不存在:uid:" + query.getUid());
}
//判断炮孔编号是否已经存在
if (StringUtils.isNotBlank(query.getHoleID())) {
R r = getByHoleId(query);
if (r.getData() != null) {
return R.failed("炮孔编号已存在: HoleID:" + query.getHoleID());
}
} }
//条件封装
BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp);
//判断是否需要修改关联的 矿山爆区表 //判断是否需要修改关联的 矿山爆区表
if (StringUtils.isNotBlank(query.getStepName()) if (StringUtils.isNotBlank(query.getStepName())
|| StringUtils.isNotBlank(query.getBlastAreaName()) || StringUtils.isNotBlank(query.getBlastAreaName())
...@@ -78,7 +103,6 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -78,7 +103,6 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
//判断矿山爆区表是否存在数据 不存在不能修改 //判断矿山爆区表是否存在数据 不存在不能修改
//query里不一定StopeName,StepName,BlastAreaName都有,需要从temp中拿query没有的, //query里不一定StopeName,StepName,BlastAreaName都有,需要从temp中拿query没有的,
// 所以将query有的更新到temp中,再把temp中的复制到tMineStopeQuery // 所以将query有的更新到temp中,再把temp中的复制到tMineStopeQuery
BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp);
TMineStopeQuery tMineStopeQuery = new TMineStopeQuery(); TMineStopeQuery tMineStopeQuery = new TMineStopeQuery();
BeanUtils.copyProperties(temp, tMineStopeQuery); BeanUtils.copyProperties(temp, tMineStopeQuery);
R volume = itMineStopeService.getByQuery(tMineStopeQuery); R volume = itMineStopeService.getByQuery(tMineStopeQuery);
...@@ -86,18 +110,36 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -86,18 +110,36 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
return R.failed("矿山爆区表数据不存在,StopeName,StepName,BlastAreaName"); return R.failed("矿山爆区表数据不存在,StopeName,StepName,BlastAreaName");
} }
} }
//条件封装 //判断是否修改设计孔深
TProcessesBlast tProcessesBlast = new TProcessesBlast(); if (query.getDesignDepth() != null) {
BeanUtils.copyProperties(query, tProcessesBlast); TProcessesBlastdesignHoleQuery holeQuery = new TProcessesBlastdesignHoleQuery();
holeQuery.setBlastHoleID(temp.getHoleID());
holeQuery.setDepth(query.getDepth());
R r = itProcessesBlastdesignHoleService.updateByBlastHoleID(holeQuery);
if (r.getCode() != 0) {
log.error("修改炮孔设计失败:{}", JSON.toJSONString(holeQuery));
return R.failed(r.getMsg());
}
}
//判断是否修改实测孔深
if (query.getDepth() != null) {
TProcessesDrillingQuery drillingQuery = new TProcessesDrillingQuery();
drillingQuery.setHoleID(temp.getHoleID());
drillingQuery.setDepth(query.getDepth());
R r = itProcessesDrillingService.updateByHoleId(drillingQuery);
if (r.getCode() != 0) {
log.error("修改穿孔工序失败:{}", JSON.toJSONString(drillingQuery));
return R.failed(r.getMsg());
}
}
QueryWrapper<TProcessesBlast> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesBlast> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesBlast.UID.getLabel(), query.getUid()); queryWrapper.eq(StringUtils.isNotBlank(query.getUid()), ProjectEnum.TProcessesBlast.UID.getLabel(), query.getUid());
//修改 //修改
int update = baseMapper.update(tProcessesBlast, queryWrapper); int update = baseMapper.update(temp, queryWrapper);
if (update > 0) { if (update > 0) {
return R.ok("修改成功"); return R.ok("修改成功");
} else { } else {
log.info(JSON.toJSONString(tProcessesBlast)); log.error("修改失败:{}", JSON.toJSONString(temp));
return R.failed("修改失败"); return R.failed("修改失败");
} }
} }
...@@ -115,6 +157,13 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -115,6 +157,13 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
if (query.getUid() != null) { if (query.getUid() != null) {
return R.failed("uid自动生成 不能手动设置"); return R.failed("uid自动生成 不能手动设置");
} }
//判断炮孔编号是否已经存在
if (StringUtils.isNotBlank(query.getHoleID())) {
R r = getByHoleId(query);
if (r.getData() != null) {
return R.failed("炮孔编号已存在: HoleID:" + query.getHoleID());
}
}
//条件封装 //条件封装
TProcessesBlast tProcessesDrilling = new TProcessesBlast(); TProcessesBlast tProcessesDrilling = new TProcessesBlast();
BeanUtils.copyProperties(query, tProcessesDrilling); BeanUtils.copyProperties(query, tProcessesDrilling);
...@@ -134,7 +183,25 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe ...@@ -134,7 +183,25 @@ public class TProcessesBlastServiceImpl extends ServiceImpl<TProcessesBlastMappe
//参数校验 //参数校验
Rcode.NOT_PARAM.assertNotNull(query); Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotEmpty(query.getUid());
QueryWrapper<TProcessesBlast> queryWrapper = new QueryWrapper<>();
StringBuilder uid = new StringBuilder();
uid.append(ProjectEnum.TableAlias.A.getLabel()).append(ProjectEnum.TProcessesBlast.UID.getLabel());
queryWrapper.eq(uid.toString(), query.getUid());
//查询并且返回
return R.ok(baseMapper.getByQuery(queryWrapper));
}
@Override
public R getByHoleId(TProcessesBlastQuery query) {
log.info(JSON.toJSONString(query));
//参数校验
Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getHoleID());
QueryWrapper<TProcessesBlast> queryWrapper = new QueryWrapper<>();
StringBuilder holeId = new StringBuilder();
holeId.append(ProjectEnum.TableAlias.A.getLabel()).append(ProjectEnum.TProcessesBlast.HOLE_ID.getLabel());
queryWrapper.eq(holeId.toString(), query.getHoleID());
//查询并且返回 //查询并且返回
return R.ok(baseMapper.selectById(query.getUid())); return R.ok(baseMapper.getByQuery(queryWrapper));
} }
} }
...@@ -96,11 +96,18 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -96,11 +96,18 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
log.info(JSON.toJSONString(query)); log.info(JSON.toJSONString(query));
//参数校验 //参数校验
Rcode.NOT_PARAM.assertNotNull(query); Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotNull(query.getUid());
//判断数据炮孔设计是否存在 //判断数据是否存在
TProcessesBlastdesignHole temp = baseMapper.selectById(query.getUid()); TProcessesBlastdesignHole temp = baseMapper.selectById(query.getUid());
if (temp == null) { if (temp == null) {
return R.failed("数据不存在,uid:" + query.getUid()); return R.failed("数据不存在:uid:" + query.getUid());
}
//判断炮孔编号是否存在
if (StringUtils.isNotBlank(query.getBlastHoleID())) {
R r = getByBlastHoleID(query);
if (r.getData() != null) {
return R.failed("炮孔编号已存在: BlastHoleID:" + query.getBlastHoleID());
}
} }
//判断是否需要修改关联的 设计爆区爆破量 //判断是否需要修改关联的 设计爆区爆破量
if (StringUtils.isNotBlank(query.getStepName()) if (StringUtils.isNotBlank(query.getStepName())
...@@ -121,7 +128,6 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -121,7 +128,6 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
//如果修改了孔距,排距,台阶高度 需要重新计算单孔爆破量, 单孔爆破量(m3)=孔距*排距*台阶高度 //如果修改了孔距,排距,台阶高度 需要重新计算单孔爆破量, 单孔爆破量(m3)=孔距*排距*台阶高度
//所以直接copy上面根据uid查出来的数据 copy ->非空值<- 将query的值更新到查出来的对象上 进行计算并更新到数据库即可 //所以直接copy上面根据uid查出来的数据 copy ->非空值<- 将query的值更新到查出来的对象上 进行计算并更新到数据库即可
BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp); BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp);
//判断是否修改设计爆区爆破量 的设计日期,或者设计爆区爆破量(m3) TAT //判断是否修改设计爆区爆破量 的设计日期,或者设计爆区爆破量(m3) TAT
if (query.getDesignDate() != null || query.getBlastVolume() != null) { if (query.getDesignDate() != null || query.getBlastVolume() != null) {
TProcessesBlastdesignVolumeQuery tProcessesBlastdesignVolumeQuery = new TProcessesBlastdesignHoleQuery(); TProcessesBlastdesignVolumeQuery tProcessesBlastdesignVolumeQuery = new TProcessesBlastdesignHoleQuery();
...@@ -136,8 +142,13 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -136,8 +142,13 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
return R.failed(r.getMsg()); return R.failed(r.getMsg());
} }
} }
//计算单孔爆破量 //判断是否需要重新计算爆破量
calculateHoleBlastVolume(temp); if (query.getHoleSpace() != null
|| query.getRowSpace() != null
|| query.getStepHeight() != null) {
//计算单孔爆破量
calculateHoleBlastVolume(temp);
}
QueryWrapper<TProcessesBlastdesignHole> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesBlastdesignHole> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesBlastdesignHole.UID.getLabel(), query.getUid()); queryWrapper.eq(ProjectEnum.TProcessesBlastdesignHole.UID.getLabel(), query.getUid());
//修改 //修改
...@@ -150,6 +161,26 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -150,6 +161,26 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
} }
} }
@Override
public R updateByBlastHoleID(TProcessesBlastdesignHoleQuery query) {
log.info(JSON.toJSONString(query));
//参数校验
Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotNull(query.getBlastHoleID());
//判断数据炮孔设计是否存在
//判断数据是否存在
QueryWrapper<TProcessesBlastdesignHole> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesBlastdesignHole.BLAST_HOLE_ID.getLabel(), query.getBlastHoleID());
TProcessesBlastdesignHole temp = baseMapper.selectOne(queryWrapper);
if (temp == null) {
return R.failed("数据不存在:BLAST_HOLE_ID:" + query.getBlastHoleID());
}
query.setUid(temp.getUid());
//调用基础方法修改
return updateByUid(query);
}
@Override @Override
public R deleteByUid(TProcessesBlastdesignHoleQuery query) { public R deleteByUid(TProcessesBlastdesignHoleQuery query) {
...@@ -196,6 +227,13 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -196,6 +227,13 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
if (query.getUid() != null) { if (query.getUid() != null) {
return R.failed("uid自动生成 不能手动设置"); return R.failed("uid自动生成 不能手动设置");
} }
//判断炮孔编号是否存在
if (StringUtils.isNotBlank(query.getBlastHoleID())) {
R r = getByBlastHoleID(query);
if (r.getData() != null) {
return R.failed("炮孔编号已存在: BlastHoleID:" + query.getBlastHoleID());
}
}
//查看设计爆区爆破量是否存在数据 //查看设计爆区爆破量是否存在数据
TProcessesBlastdesignVolumeQuery tProcessesBlastdesignVolumeQuery = new TProcessesBlastdesignHoleQuery(); TProcessesBlastdesignVolumeQuery tProcessesBlastdesignVolumeQuery = new TProcessesBlastdesignHoleQuery();
BeanUtils.copyProperties(query, tProcessesBlastdesignVolumeQuery); BeanUtils.copyProperties(query, tProcessesBlastdesignVolumeQuery);
...@@ -235,7 +273,7 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -235,7 +273,7 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
tProcessesBlastQuery.setTag(DateUtil.timeToStr(LocalDateTime.now(), DateUtil.FORMAT_TO_SECOND)); tProcessesBlastQuery.setTag(DateUtil.timeToStr(LocalDateTime.now(), DateUtil.FORMAT_TO_SECOND));
R r2 = itProcessesBlastService.insertTProcessesBlast(tProcessesBlastQuery); R r2 = itProcessesBlastService.insertTProcessesBlast(tProcessesBlastQuery);
if (r2.getCode() != 0) { if (r2.getCode() != 0) {
log.error("增加一条爆破工序:" + JSON.toJSONString(tProcessesDrillingQuery)); log.error("增加一条爆破工序失败:" + JSON.toJSONString(tProcessesDrillingQuery));
return R.failed(r1.getMsg()); return R.failed(r1.getMsg());
} }
return R.ok("增加成功"); return R.ok("增加成功");
...@@ -253,9 +291,11 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses ...@@ -253,9 +291,11 @@ public class TProcessesBlastdesignHoleServiceImpl extends ServiceImpl<TProcesses
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotEmpty(query.getUid());
//条件 //条件
QueryWrapper<TProcessesBlastdesignHole> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesBlastdesignHole> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesBlastdesignHole.UID.getLabel(), query.getUid()); StringBuilder uid = new StringBuilder();
uid.append(ProjectEnum.TableAlias.A.getLabel()).append(ProjectEnum.TProcessesBlastdesignHole.UID.getLabel());
queryWrapper.eq(uid.toString(), query.getUid());
//查询并且返回 //查询并且返回
return R.ok(baseMapper.getByUId(queryWrapper)); return R.ok(baseMapper.getByQuery(queryWrapper));
} }
......
...@@ -46,13 +46,28 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM ...@@ -46,13 +46,28 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM
return R.ok(tSampleListPage); return R.ok(tSampleListPage);
} }
@Override
public R getByUid(TProcessesCrusherQuery query) {
log.info(JSON.toJSONString(query));
//参数校验
Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotNull(query.getUid());
//查询并且返回
QueryWrapper<TProcessesCrusher> queryWrapper = new QueryWrapper<>();
StringBuilder uid = new StringBuilder();
uid.append(ProjectEnum.TableAlias.A.getLabel()).append(ProjectEnum.TProcessesCrusher.UID.getLabel());
queryWrapper.eq(uid.toString(), query.getUid());
//查询并且返回
return R.ok(baseMapper.getByQuery(queryWrapper));
}
@Override @Override
public R updateByUid(TProcessesCrusherQuery query) { public R updateByUid(TProcessesCrusherQuery query) {
log.info(JSON.toJSONString(query)); log.info(JSON.toJSONString(query));
//参数校验 //参数校验
Rcode.NOT_PARAM.assertNotNull(query); Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotNull(query.getUid());
//判断数据是否存在 //判断数据是否存在
TProcessesCrusher temp = baseMapper.selectById(query.getUid()); TProcessesCrusher temp = baseMapper.selectById(query.getUid());
if (temp == null) { if (temp == null) {
...@@ -63,7 +78,7 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM ...@@ -63,7 +78,7 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM
BeanUtils.copyProperties(query, tSampleList); BeanUtils.copyProperties(query, tSampleList);
QueryWrapper<TProcessesCrusher> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesCrusher> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesCrusher.UID.getLabel(), query.getUid()); queryWrapper.eq(StringUtils.isNotBlank(query.getUid()),ProjectEnum.TProcessesCrusher.UID.getLabel(), query.getUid());
//修改 //修改
int update = baseMapper.update(tSampleList, queryWrapper); int update = baseMapper.update(tSampleList, queryWrapper);
if (update > 0) { if (update > 0) {
...@@ -97,4 +112,7 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM ...@@ -97,4 +112,7 @@ public class TProcessesCrusherServiceImpl extends ServiceImpl<TProcessesCrusherM
return R.failed("增加失败"); return R.failed("增加失败");
} }
} }
} }
...@@ -7,11 +7,13 @@ import cn.wise.sc.acquisition.business.enumation.ProjectEnum; ...@@ -7,11 +7,13 @@ import cn.wise.sc.acquisition.business.enumation.ProjectEnum;
import cn.wise.sc.acquisition.business.mapper.TProcessesDrillingMapper; import cn.wise.sc.acquisition.business.mapper.TProcessesDrillingMapper;
import cn.wise.sc.acquisition.business.model.query.TMineStopeQuery; import cn.wise.sc.acquisition.business.model.query.TMineStopeQuery;
import cn.wise.sc.acquisition.business.model.query.TProcessesBlastdesignHoleQuery; import cn.wise.sc.acquisition.business.model.query.TProcessesBlastdesignHoleQuery;
import cn.wise.sc.acquisition.business.model.query.TProcessesBlastdesignVolumeQuery;
import cn.wise.sc.acquisition.business.model.query.TProcessesDrillingQuery; import cn.wise.sc.acquisition.business.model.query.TProcessesDrillingQuery;
import cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo; import cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo;
import cn.wise.sc.acquisition.business.model.vo.TProcessesProductVo; import cn.wise.sc.acquisition.business.model.vo.TProcessesProductVo;
import cn.wise.sc.acquisition.business.service.ITMineStopeService; import cn.wise.sc.acquisition.business.service.ITMineStopeService;
import cn.wise.sc.acquisition.business.service.ITProcessesBlastdesignHoleService; import cn.wise.sc.acquisition.business.service.ITProcessesBlastdesignHoleService;
import cn.wise.sc.acquisition.business.service.ITProcessesBlastdesignVolumeService;
import cn.wise.sc.acquisition.business.service.ITProcessesDrillingService; import cn.wise.sc.acquisition.business.service.ITProcessesDrillingService;
import cn.wise.sc.acquisition.business.util.BeanUtilsNewCopy; import cn.wise.sc.acquisition.business.util.BeanUtilsNewCopy;
import cn.wise.sc.acquisition.business.util.DateUtil; import cn.wise.sc.acquisition.business.util.DateUtil;
...@@ -48,6 +50,9 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -48,6 +50,9 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
@Autowired @Autowired
private ITProcessesBlastdesignHoleService itProcessesBlastdesignHoleService; private ITProcessesBlastdesignHoleService itProcessesBlastdesignHoleService;
@Autowired
private ITProcessesBlastdesignVolumeService itProcessesBlastdesignVolumeService;
@Override @Override
public R getPage(TProcessesDrillingQuery tProcessesDrillingQuery, Query query) { public R getPage(TProcessesDrillingQuery tProcessesDrillingQuery, Query query) {
log.info(JSON.toJSONString(tProcessesDrillingQuery)); log.info(JSON.toJSONString(tProcessesDrillingQuery));
...@@ -83,12 +88,15 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -83,12 +88,15 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
Double depthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper); Double depthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper);
//查询,今日合计孔深 //查询,今日合计孔深
StringBuffer drillingDate = new StringBuffer()
.append(ProjectEnum.TableAlias.A.getLabel())
.append(ProjectEnum.TProcessesDrilling.DRILLING_DATE.getLabel());
//初始化QueryWrapper //初始化QueryWrapper
LocalDateTime now = LocalDateTime.now(); LocalDateTime now = LocalDateTime.now();
queryWrapper = new QueryWrapper<>(); queryWrapper = new QueryWrapper<>();
queryWrapper queryWrapper
.ge(ProjectEnum.TProcessesDrilling.DRILLING_DATE.getLabel(), DateUtil.getBeginTimeStr(now)) .ge(drillingDate.toString(), DateUtil.getBeginTimeStr(now))
.le(ProjectEnum.TProcessesDrilling.DRILLING_DATE.getLabel(), DateUtil.getEndTimeStr(now)); .le(drillingDate.toString(), DateUtil.getEndTimeStr(now));
Double todayDepthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper); Double todayDepthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper);
...@@ -97,8 +105,8 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -97,8 +105,8 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
//初始化QueryWrapper //初始化QueryWrapper
queryWrapper = new QueryWrapper<>(); queryWrapper = new QueryWrapper<>();
queryWrapper queryWrapper
.ge(ProjectEnum.TProcessesDrilling.DRILLING_DATE.getLabel(), DateUtil.getBeginTimeStr(LocalDateTime.now().minusMonths(1).withDayOfMonth(26))) .ge(drillingDate.toString(), DateUtil.getBeginTimeStr(LocalDateTime.now().minusMonths(1).withDayOfMonth(26)))
.le(ProjectEnum.TProcessesDrilling.DRILLING_DATE.getLabel(), DateUtil.getEndTimeStr(LocalDateTime.now())); .le(drillingDate.toString(), DateUtil.getEndTimeStr(LocalDateTime.now()));
Double monthDepthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper); Double monthDepthSum = baseMapper.getSumByCondition(depth.toString(), queryWrapper);
return R.ok(new TProcessesProductVo<>(data, depthSum, todayDepthSum, monthDepthSum)); return R.ok(new TProcessesProductVo<>(data, depthSum, todayDepthSum, monthDepthSum));
...@@ -117,6 +125,13 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -117,6 +125,13 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
if (query.getUid() != null) { if (query.getUid() != null) {
return R.failed("uid自动生成 不能手动设置"); return R.failed("uid自动生成 不能手动设置");
} }
//判断炮孔编号是否已经存在
if (StringUtils.isNotBlank(query.getHoleID())) {
R r = getByHoleId(query);
if (r.getData() != null) {
return R.failed("炮孔编号已存在: HoleID:" + query.getHoleID());
}
}
//条件封装 //条件封装
TProcessesDrilling tProcessesDrilling = new TProcessesDrilling(); TProcessesDrilling tProcessesDrilling = new TProcessesDrilling();
BeanUtils.copyProperties(query, tProcessesDrilling); BeanUtils.copyProperties(query, tProcessesDrilling);
...@@ -136,12 +151,21 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -136,12 +151,21 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
log.info(JSON.toJSONString(query)); log.info(JSON.toJSONString(query));
//参数校验 //参数校验
Rcode.NOT_PARAM.assertNotNull(query); Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotNull(query.getUid());
//判断数据是否存在 //判断数据是否存在
TProcessesDrilling temp = baseMapper.selectById(query.getUid()); TProcessesDrilling temp = baseMapper.selectById(query.getUid());
if (temp == null) { if (temp == null) {
return R.failed("数据不存在,uid:" + query.getUid()); return R.failed("数据不存在:uid: " + query.getUid());
} }
//判断炮孔编号是否已经存在
if (StringUtils.isNotBlank(query.getHoleID())) {
R r = getByHoleId(query);
if (r.getData() != null) {
return R.failed("炮孔编号已存在: HoleID:" + query.getHoleID());
}
}
//条件封装
BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp);
//判断是否需要修改关联的 矿山爆区表 //判断是否需要修改关联的 矿山爆区表
if (StringUtils.isNotBlank(query.getStepName()) if (StringUtils.isNotBlank(query.getStepName())
|| StringUtils.isNotBlank(query.getBlastAreaName()) || StringUtils.isNotBlank(query.getBlastAreaName())
...@@ -149,7 +173,6 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -149,7 +173,6 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
//判断矿山爆区表是否存在数据 不存在不能修改 //判断矿山爆区表是否存在数据 不存在不能修改
//query里不一定StopeName,StepName,BlastAreaName都有,需要从temp中拿query没有的, //query里不一定StopeName,StepName,BlastAreaName都有,需要从temp中拿query没有的,
// 所以将query有的更新到temp中,再把temp中的复制到tMineStopeQuery // 所以将query有的更新到temp中,再把temp中的复制到tMineStopeQuery
BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp);
TMineStopeQuery tMineStopeQuery = new TMineStopeQuery(); TMineStopeQuery tMineStopeQuery = new TMineStopeQuery();
BeanUtils.copyProperties(temp, tMineStopeQuery); BeanUtils.copyProperties(temp, tMineStopeQuery);
R volume = itMineStopeService.getByQuery(tMineStopeQuery); R volume = itMineStopeService.getByQuery(tMineStopeQuery);
...@@ -157,21 +180,61 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -157,21 +180,61 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
return R.failed("矿山爆区表数据不存在,StopeName,StepName,BlastAreaName"); return R.failed("矿山爆区表数据不存在,StopeName,StepName,BlastAreaName");
} }
} }
//条件封装 //判断是否修改设计爆区爆破量 设计爆区爆破量(m3) TAT
BeanUtilsNewCopy.copyPropertiesIgnoreNull(query, temp); if (query.getBlastVolume() != null) {
//计算单孔爆破量 TProcessesBlastdesignVolumeQuery tProcessesBlastdesignVolumeQuery = new TProcessesBlastdesignHoleQuery();
//先获取台阶高度 tProcessesBlastdesignVolumeQuery.setStopeName(temp.getStopeName());
TProcessesBlastdesignHoleQuery holeQuery = new TProcessesBlastdesignHoleQuery(); tProcessesBlastdesignVolumeQuery.setStepName(temp.getStepName());
holeQuery.setBlastHoleID(temp.getHoleID()); tProcessesBlastdesignVolumeQuery.setBlastAreaName(temp.getBlastAreaName());
R r = itProcessesBlastdesignHoleService.getByBlastHoleID(holeQuery); tProcessesBlastdesignVolumeQuery.setBlastVolume(query.getBlastVolume());
//不为空计算台阶高度 R r = itProcessesBlastdesignVolumeService.updateByQuery(tProcessesBlastdesignVolumeQuery);
if (r.getData() != null) { if (r.getCode() != 0) {
TProcessesBlastdesignHole data = (TProcessesBlastdesignHole) r.getData(); log.info("修改设计爆区爆破量失败:{}", JSON.toJSONString(tProcessesBlastdesignVolumeQuery));
Double volume = calculateHoleBlastVolume(temp.getHoleSpace(), temp.getRowSpace(), data.getStepHeight()); return R.failed(r.getMsg());
temp.setHoleBlastVolume(volume); }
}
//判断是否修改炮孔设计
if (query.getDesignDepth() != null
|| query.getDesignRowSpace() != null
|| query.getDesignHoleSpace() != null
|| query.getDesignAzimuth() != null
|| query.getDesignInclination() != null
|| query.getDesignAperture() != null
|| query.getStepHeight() != null) {
TProcessesBlastdesignHoleQuery holeQuery = new TProcessesBlastdesignHoleQuery();
holeQuery.setBlastHoleID(temp.getHoleID());
holeQuery.setDepth(query.getDesignDepth());
holeQuery.setRowSpace(query.getDesignRowSpace());
holeQuery.setHoleSpace(query.getDesignHoleSpace());
holeQuery.setAzimuth(query.getAzimuth());
holeQuery.setInclination(query.getDesignInclination());
holeQuery.setAperture(query.getDesignAperture());
holeQuery.setStepHeight(query.getStepHeight());
R r = itProcessesBlastdesignHoleService.updateByBlastHoleID(holeQuery);
if (r.getCode() != 0) {
log.error("修改炮孔设计失败:{}", JSON.toJSONString(holeQuery));
return R.failed(r.getMsg());
}
}
//判断是否需要重新计算爆破量
if (query.getHoleSpace() != null || query.getRowSpace() != null) {
//计算单孔爆破量
//先获取炮孔设计数据台阶高度
TProcessesBlastdesignHoleQuery holeQuery = new TProcessesBlastdesignHoleQuery();
holeQuery.setBlastHoleID(temp.getHoleID());
R r = itProcessesBlastdesignHoleService.getByBlastHoleID(holeQuery);
//不为空计算单孔爆破量
if (r.getData() != null) {
TProcessesBlastdesignHole data = (TProcessesBlastdesignHole) r.getData();
Double volume = calculateHoleBlastVolume(temp.getHoleSpace(), temp.getRowSpace(), data.getStepHeight());
temp.setHoleBlastVolume(volume);
} else {
log.info("计算单孔爆破量时,获取炮孔设计为空,炮孔编号:{}", temp.getHoleID());
}
} }
QueryWrapper<TProcessesDrilling> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesDrilling> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesBlast.UID.getLabel(), query.getUid()); queryWrapper.eq(StringUtils.isNotBlank(query.getUid()), ProjectEnum.TProcessesDrilling.UID.getLabel(), query.getUid());
//修改 //修改
int update = baseMapper.update(temp, queryWrapper); int update = baseMapper.update(temp, queryWrapper);
if (update > 0) { if (update > 0) {
...@@ -183,6 +246,26 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -183,6 +246,26 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
} }
@Override
public R updateByHoleId(TProcessesDrillingQuery query) {
log.info(JSON.toJSONString(query));
//参数校验
Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotNull(query.getHoleID());
//判断数据是否存在
QueryWrapper<TProcessesDrilling> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesBlast.HOLE_ID.getLabel(), query.getHoleID());
TProcessesDrilling temp = baseMapper.selectOne(queryWrapper);
if (temp == null) {
return R.failed("数据不存在:HOLE_ID: " + query.getHoleID());
}
//条件封装
query.setUid(temp.getUid());
//调用基础方法修改
return updateByUid(query);
}
@Override @Override
public R getByUid(TProcessesDrillingQuery query) { public R getByUid(TProcessesDrillingQuery query) {
log.info(JSON.toJSONString(query)); log.info(JSON.toJSONString(query));
...@@ -191,9 +274,27 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin ...@@ -191,9 +274,27 @@ public class TProcessesDrillingServiceImpl extends ServiceImpl<TProcessesDrillin
Rcode.NOT_PARAM.assertNotEmpty(query.getUid()); Rcode.NOT_PARAM.assertNotEmpty(query.getUid());
//查询并且返回 //查询并且返回
QueryWrapper<TProcessesDrilling> queryWrapper = new QueryWrapper<>(); QueryWrapper<TProcessesDrilling> queryWrapper = new QueryWrapper<>();
queryWrapper.eq(ProjectEnum.TProcessesDrilling.UID.getLabel(), query.getUid()); StringBuilder uid = new StringBuilder();
uid.append(ProjectEnum.TableAlias.A.getLabel()).append(ProjectEnum.TProcessesDrilling.UID.getLabel());
queryWrapper.eq(uid.toString(), query.getUid());
//查询并且返回
return R.ok(baseMapper.getByQuery(queryWrapper));
}
@Override
public R getByHoleId(TProcessesDrillingQuery query) {
log.info(JSON.toJSONString(query));
//参数校验
Rcode.NOT_PARAM.assertNotNull(query);
Rcode.NOT_PARAM.assertNotEmpty(query.getHoleID());
//查询并且返回
QueryWrapper<TProcessesDrilling> queryWrapper = new QueryWrapper<>();
StringBuilder holeId = new StringBuilder();
holeId.append(ProjectEnum.TableAlias.A.getLabel()).append(ProjectEnum.TProcessesDrilling.HOLE_ID.getLabel());
queryWrapper.eq(holeId.toString(), query.getHoleID());
//查询并且返回 //查询并且返回
return R.ok(baseMapper.getByUid(queryWrapper)); return R.ok(baseMapper.getByQuery(queryWrapper));
} }
......
package cn.wise.sc.acquisition.business.service.impl; package cn.wise.sc.acquisition.business.service.impl;
import cn.wise.sc.acquisition.business.constant.Rcode;
import cn.wise.sc.acquisition.business.entity.TWeight; import cn.wise.sc.acquisition.business.entity.TWeight;
import cn.wise.sc.acquisition.business.enumation.ProjectEnum;
import cn.wise.sc.acquisition.business.mapper.TWeightMapper; import cn.wise.sc.acquisition.business.mapper.TWeightMapper;
import cn.wise.sc.acquisition.business.model.query.TWeightQuery; import cn.wise.sc.acquisition.business.model.query.TWeightQuery;
import cn.wise.sc.acquisition.business.service.ITWeightService; import cn.wise.sc.acquisition.business.service.ITWeightService;
import cn.wise.sc.acquisition.business.util.DateUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.api.R; import com.baomidou.mybatisplus.extension.api.R;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
/** /**
* <p> * <p>
* 服务实现类 * 服务实现类
* </p> * </p>
* *
* @author ztw * @author ztw
* @since 2021-04-26 * @since 2021-04-26
*/ */
@Service @Service
@Slf4j
public class TWeightServiceImpl extends ServiceImpl<TWeightMapper, TWeight> implements ITWeightService { public class TWeightServiceImpl extends ServiceImpl<TWeightMapper, TWeight> implements ITWeightService {
...@@ -25,5 +33,23 @@ public class TWeightServiceImpl extends ServiceImpl<TWeightMapper, TWeight> impl ...@@ -25,5 +33,23 @@ public class TWeightServiceImpl extends ServiceImpl<TWeightMapper, TWeight> impl
return null; return null;
} }
@Override
public R getSumJz(TWeightQuery query) {
log.info(JSON.toJSONString(query));
//参数校验
Rcode.NOT_PARAM.assertNotNull(query);
QueryWrapper<TWeight> queryWrapper = new QueryWrapper<>();
if (query.getRq() != null) {
queryWrapper
.ge(ProjectEnum.TWeight.RQ.getLabel(), DateUtil.getBeginTimeStr(query.getRq()))
.le(ProjectEnum.TWeight.RQ.getLabel(), DateUtil.getEndTimeStr(query.getRq()));
}
//查询
Double depthSum = baseMapper.getSumByCondition(new StringBuffer()
.append(ProjectEnum.TableAlias.A.getLabel())
.append(ProjectEnum.TWeight.JZ.getLabel()).toString(), queryWrapper);
return R.ok(depthSum);
}
} }
...@@ -24,11 +24,11 @@ ...@@ -24,11 +24,11 @@
<sql id="TProcessesDiggingHoleColumns"> <sql id="TProcessesDiggingHoleColumns">
b.HoleBlastVolume, b.HoleBlastVolume,
b.depth ,<!-- 设计孔深,将爆破工序里的depth去掉,用设计炮孔里的替代 --> b.depth AS DesignDepth,<!-- 设计孔深,将爆破工序里的depth去掉,用设计炮孔里的替代 -->
</sql> </sql>
<sql id="TProcessesDrillingColumns"> <sql id="TProcessesDrillingColumns">
c.Depth AS DesignDepth, c.Depth,
</sql> </sql>
...@@ -50,4 +50,17 @@ ...@@ -50,4 +50,17 @@
</where> </where>
</select> </select>
<!-- 获取所有getByUid列表 -->
<select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesBlastVo">
SELECT
<include refid="TProcessesDiggingHoleColumns"/>
<include refid="TProcessesDrillingColumns"/>
<include refid="TProcessesBlastColumns"/>
FROM T_Processes_Blast a
<include refid="TProcessesBlastdesignHoleJoins"/>
<where>
${ew.sqlSegment}
</where>
</select>
</mapper> </mapper>
...@@ -48,6 +48,18 @@ ...@@ -48,6 +48,18 @@
</select> </select>
<!-- 获取所有getPage列表 -->
<select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesBlastdesignHoleVo">
SELECT
<include refid="TProcessesBlastdesignVolumeColumns"/>
<include refid="TProcessesBlastdesignHoleColumns"/>
FROM T_Processes_BlastDesign_Hole a
<include refid="TProcessesBlastdesignHoleJoins"/>
<where>
${ew.sqlSegment}
</where>
</select>
<!-- 获取所有getByQuery列表 --> <!-- 获取所有getByQuery列表 -->
<select id="getSumByCondition" resultType="Double"> <select id="getSumByCondition" resultType="Double">
SELECT SELECT
......
...@@ -15,7 +15,7 @@ ...@@ -15,7 +15,7 @@
a.EquipmentID, a.EquipmentID,
a.WorkType, a.WorkType,
a.WorkTime, a.WorkTime,
a.Wcdw, -- a.Wcdw, /*吨位 查吨位表中的吨位*/
a.Price, a.Price,
a.TotalMoney, a.TotalMoney,
a.Bz, a.Bz,
...@@ -23,12 +23,20 @@ ...@@ -23,12 +23,20 @@
</sql> </sql>
<sql id="TWeightColumns"> <sql id="TWeightColumns">
b.Jz, b.Wcdw, /*吨位 替换破碎工序中的吨位*/
</sql> </sql>
<sql id="TProcessesCrusherJoins"> <sql id="TProcessesCrusherJoins">
left join T_Weight b on a.EquipmentID=b.TruckID LEFT JOIN (
SELECT
Rq,
SUM (Jz) AS Wcdw /*吨位 替换破碎工序中的吨位*/
FROM
T_Weight
GROUP BY
Rq
) b ON a.CrushDate = b.Rq
</sql> </sql>
<!-- 获取所有getPage列表 --> <!-- 获取所有getPage列表 -->
...@@ -43,4 +51,17 @@ ...@@ -43,4 +51,17 @@
</where> </where>
</select> </select>
<!-- 获取所有getPage列表 -->
<select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesBlastdesignHoleVo">
SELECT
<include refid="TWeightColumns"/>
<include refid="TProcessesCrusherColumns"/>
FROM T_Processes_Crusher a
<include refid="TProcessesCrusherJoins"/>
<where>
${ew.sqlSegment}
</where>
</select>
</mapper> </mapper>
...@@ -30,8 +30,6 @@ ...@@ -30,8 +30,6 @@
a.x, a.x,
a.y, a.y,
a.z, a.z,
-- a.HoleBlastVolume, /* 用炮孔设计的爆破量 */
a.BlastDate,
a.Operator, a.Operator,
a.Accepter, a.Accepter,
...@@ -40,35 +38,40 @@ ...@@ -40,35 +38,40 @@
</sql> </sql>
<sql id="TProcessesDiggingHoleColumns"> <sql id="TProcessesDiggingHoleColumns">
b.Depth AS DesignDepth,/*孔深(m)*/ b.Depth AS DesignDepth,
b.RowSpace AS DesignRowSpace,/*排距(m)*/ b.RowSpace AS DesignRowSpace,
b.HoleSpace AS DesignHoleSpace,/*孔距(m)*/ b.HoleSpace AS DesignHoleSpace,
b.Azimuth AS DesignAzimuth,/*方位角*/ b.Azimuth AS DesignAzimuth,
b.Inclination AS DesignInclination,/*倾角*/ b.Inclination AS DesignInclination,
b.Aperture AS DesignAperture,/*孔径(m)*/ b.Aperture AS DesignAperture,
-- b.x;/*开孔坐标X*/ b.HoleBlastVolume,
-- b.y;/*开孔坐标Y*/
-- b.z;/*开孔坐标Z*/
b.HoleBlastVolume,/* 单孔爆破量(m3)=孔距*排距*台阶高度*/
</sql> </sql>
<sql id="TProcessesBlastColumns"> <sql id="TProcessesBlastColumns">
c.BlastDate c.BlastDate,
</sql>
<sql id="TProcessesBlastdesignVolumeColumns">
d.BlastVolume,
d.DesignDate,
</sql> </sql>
<sql id="TProcessesBlastdesignHoleJoins"> <sql id="TProcessesDrillingJoins">
left join T_Processes_BlastDesign_Hole b on a.HoleID = b.BlastHoleID left join T_Processes_BlastDesign_Hole b on a.HoleID = b.BlastHoleID
left join T_Processes_Blast c on a.HoleID = c.HoleID left join T_Processes_Blast c on a.HoleID = c.HoleID
left join T_Processes_BlastDesign_Volume d on a.StopeName=d.StopeName and a.StepName=d.StepName and a.BlastAreaName=d.BlastAreaName
</sql> </sql>
<!-- 获取所有getPage列表 --> <!-- 获取所有getPage列表 -->
<select id="getPage" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo"> <select id="getPage" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo">
SELECT SELECT
<include refid="TProcessesDiggingHoleColumns"/> <include refid="TProcessesDiggingHoleColumns"/>
<include refid="TProcessesDrillingColumns"/>
<include refid="TProcessesBlastColumns"/> <include refid="TProcessesBlastColumns"/>
FROM T_Processes_Blast a <include refid="TProcessesBlastdesignVolumeColumns"/>
<include refid="TProcessesBlastdesignHoleJoins"/> <include refid="TProcessesDrillingColumns"/>
FROM T_Processes_Drilling a
<include refid="TProcessesDrillingJoins"/>
<where> <where>
${ew.sqlSegment} ${ew.sqlSegment}
</where> </where>
...@@ -76,13 +79,14 @@ ...@@ -76,13 +79,14 @@
<!-- 获取所有getPage列表 --> <!-- 获取所有getPage列表 -->
<select id="getByUid" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo"> <select id="getByQuery" resultType="cn.wise.sc.acquisition.business.model.vo.TProcessesDrillingVo">
SELECT SELECT
<include refid="TProcessesDiggingHoleColumns"/> <include refid="TProcessesDiggingHoleColumns"/>
<include refid="TProcessesDrillingColumns"/>
<include refid="TProcessesBlastColumns"/> <include refid="TProcessesBlastColumns"/>
FROM T_Processes_Blast a <include refid="TProcessesBlastdesignVolumeColumns"/>
<include refid="TProcessesBlastdesignHoleJoins"/> <include refid="TProcessesDrillingColumns"/>
FROM T_Processes_Drilling a
<include refid="TProcessesDrillingJoins"/>
<where> <where>
${ew.sqlSegment} ${ew.sqlSegment}
</where> </where>
...@@ -92,8 +96,7 @@ ...@@ -92,8 +96,7 @@
<select id="getSumByCondition" resultType="Double"> <select id="getSumByCondition" resultType="Double">
SELECT SELECT
sum(${condition}) sum(${condition})
FROM T_Processes_Blast a FROM T_Processes_Drilling a
<include refid="TProcessesBlastdesignHoleJoins"/>
<where> <where>
${ew.sqlSegment} ${ew.sqlSegment}
</where> </where>
......
...@@ -2,4 +2,15 @@ ...@@ -2,4 +2,15 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <!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.TWeightMapper"> <mapper namespace="cn.wise.sc.acquisition.business.mapper.TWeightMapper">
<!-- 根据条件求和某字段 -->
<select id="getSumByCondition" resultType="Double">
SELECT
sum(${condition})
FROM T_Weight a
<where>
${ew.sqlSegment}
</where>
</select>
</mapper> </mapper>
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment