xiaoning 1 year ago
parent dcd2b8bbb0
commit 26ead5eef5

@ -12,62 +12,87 @@ import java.io.Serializable;
/**
* <p>
*
*
* </p>
*
* @author xn
* @since 2023-09-18
* @since 2023-11-02
*/
@Data
@EqualsAndHashCode(callSuper = false)
@ApiModel(value="DmQfxq对象", description="")
@ApiModel(value="DmSygdxq对象", description="")
public class DmQfxq implements Serializable {
private static final long serialVersionUID=1L;
@ApiModelProperty(value = "船名")
@TableField("DC_CH")
private String dcCh;
@ApiModelProperty(value = "批量")
@TableField("DC_PL")
private String dcPl;
@ApiModelProperty(value = "分段")
@TableField("DC_FD")
private String dcFd;
@ApiModelProperty(value = "配送场地")
private String pscd;
@ApiModelProperty(value = "总段号")
private String zdh;
@ApiModelProperty(value = "车间主管")
private String cjzg;
@ApiModelProperty(value = "大组极重")
private Double dzjz;
@ApiModelProperty(value = "大板")
private String db;
@ApiModelProperty(value = "总装部最新分段需求期")
private String zxfdxq;
@ApiModelProperty(value = "型材")
private String xc;
@ApiModelProperty(value = "钢料需求")
private String xzglxq;
private String dzglxq;
@ApiModelProperty(value = "钢料需求")
private String xzglxqOld;
private String dzglxqOld;
@ApiModelProperty(value = "T型材")
private String txc;
@ApiModelProperty(value = "X大板")
private String xdb;
@ApiModelProperty(value = "备注")
private String bz;
@ApiModelProperty(value = "X数控件")
private String xskj;
@ApiModelProperty(value = "状态")
private String zt;
@ApiModelProperty(value = "X平铁")
private String xpt;
@ApiModelProperty(value = "X压弯")
private String xyw;
@ApiModelProperty(value = "X型材")
private String xxc;
@ApiModelProperty(value = "X二次装T型材")
private String xtxc;
@ApiModelProperty(value = "D曲板")
private String dqb;
@ApiModelProperty(value = "D型材T")
private String dxc;
@ApiModelProperty(value = "D散件")
private String dsj;
@ApiModelProperty(value = "D大板")
private String ddb;
@TableId(value = "id", type = IdType.ASSIGN_UUID)
private String id;
@ApiModelProperty(value = "编制人员")
private String bzry;
@ApiModelProperty(value = "编制日期")
private String bzrq;
private String dcCh;
private String dcPl;
private String drr;
private String drrq;
private String zt;
private int drcs=1;
@ApiModelProperty(value = "审核人员")
private String shry;
@ApiModelProperty(value = "审核日期")
private String shrq;
private String xqzt="0";
}

@ -1,6 +1,8 @@
package com.dsic.gj_erp.controller.jhgk;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.excel.EasyExcel;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
@ -8,8 +10,13 @@ import com.dsic.gj_erp.annotation.AuthFunction;
import com.dsic.gj_erp.bean.ResultBean;
import com.dsic.gj_erp.bean.jcsj.DmCbxxp;
import com.dsic.gj_erp.bean.jhgk.DmQfxq;
import com.dsic.gj_erp.bean.jhgk.DmSygdxq;
import com.dsic.gj_erp.bean.jhgk.excel.GdxqExcel;
import com.dsic.gj_erp.bean.jhgk.excel.GdxqExcel1;
import com.dsic.gj_erp.bean.jhgk.excel.QfExcel;
import com.dsic.gj_erp.exception.CustomException;
import com.dsic.gj_erp.listeners.ExcelGdxq1Listener;
import com.dsic.gj_erp.listeners.ExcelGdxqListener;
import com.dsic.gj_erp.listeners.ExcelQFListener;
import com.dsic.gj_erp.service.jcsj.DmCbxxpService;
import com.dsic.gj_erp.service.jhgk.DmQfxqService;
@ -42,10 +49,10 @@ public class DmQfxqController {
@AuthFunction
public ResultBean getList(@RequestBody DmQfxq qfxq) {
List<DmQfxq> list = service.list(new QueryWrapper<DmQfxq>()
.eq(StrUtil.isNotEmpty(qfxq.getDb()), "substring(db,0,8) ", qfxq.getDb())
.eq(StrUtil.isNotEmpty(qfxq.getXzglxq()), "substring(Xzglxq,0,8) ", qfxq.getXzglxq())
.eq(StrUtil.isNotEmpty(qfxq.getZt()), "zt", qfxq.getZt())
.orderByAsc("DC_CH,cast(dc_pl as int),DC_FD"));
return new ResultBean(list);
return new ResultBean();
}
@RequestMapping("/getCzxx")
@ -62,12 +69,24 @@ public class DmQfxqController {
@PostMapping("/upload")
@AuthFunction
@ResponseBody
public ResultBean uploadQf(@RequestParam("file") MultipartFile file, String czbh, HttpServletRequest req) throws Exception, CustomException {
public ResultBean uploadQf(@RequestParam("file") MultipartFile file, HttpServletRequest req) throws Exception, CustomException {
ExcelGdxqListener objectListener = new ExcelGdxqListener();
ExcelGdxq1Listener objectListener1 = new ExcelGdxq1Listener();
ExcelQFListener objectListener = new ExcelQFListener();
EasyExcel.read(file.getInputStream(), QfExcel.class, objectListener).sheet(0).headRowNumber(1).doRead();
List<QfExcel> objList = objectListener.getObjectList();
return service.uploadQf(objList, czbh, req);
EasyExcel.read(file.getInputStream(), GdxqExcel.class, objectListener).sheet(0).headRowNumber(1).doRead();
List<GdxqExcel> objList = objectListener.getObjectList();
EasyExcel.read(file.getInputStream(), GdxqExcel1.class, objectListener1).sheet(1).headRowNumber(1).doRead();
List<GdxqExcel1> objList1 = objectListener1.getObjectList();
List<DmQfxq> list = BeanUtil.copyToList(objList, DmQfxq.class);
List<DmQfxq> list1 = BeanUtil.copyToList(objList1, DmQfxq.class);
String username=(String) req.getAttribute("yhms");
String day= DateUtil.format(DateUtil.date(), "yyyy/MM/dd");
service.saveXzList(list,username,day);
service.saveDzList(list1,username,day);
return new ResultBean();
}
//保存

@ -49,33 +49,7 @@ public class DmSygdxqController {
.ge(StrUtil.isNotEmpty(map.get("beginTime")), "xzglxq", DateUtil.beginOfMonth(DateUtil.parseDate(map.get("beginTime"))))
.le(StrUtil.isNotEmpty(map.get("endTime")), "xzglxq", DateUtil.endOfMonth(DateUtil.parseDate(map.get("endTime"))))
.orderByAsc("dc_ch, cast(dc_pl as int),xzglxq"));
if (ObjUtil.isEmpty(list)) {
return new ResultBean();
}
// Map<String, List<DmSygdxq>> groupByZl = list.stream().collect(Collectors.groupingBy(DmSygdxq::getZl));
Map<String, Map<String, Double>> m =
list.stream()
.filter(x -> Objects.nonNull(x.getXzglxq()) && Objects.nonNull(x.getDzjz()))
.collect(Collectors.groupingBy(DmSygdxq::getDcCh
, Collectors.groupingBy(x -> x.getXzglxq().substring(5, 7)
, Collectors.summingDouble(l -> l.getDzjz())
)));
List<Json> list1 = new ArrayList<>();
for (String ch : m.keySet()) {
String str = "\"dcCh\":" +"\"" +ch+"\"" ;
for (String month : m.get(ch).keySet()) {
str += ",\"yf" + month + "\":\"" + m.get(ch).get(month)+"\"";
}
str = "{" + str + "}";
Json j = new Json(str);
list1.add(j);
}
Map map1 = new HashMap();
map1.put("hz", list1);
map1.put("list", list);
return new ResultBean(map1);
return new ResultBean(list);
}
@PostMapping("/upload")

@ -4,6 +4,7 @@ package com.dsic.gj_erp.controller.jhgk;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.dsic.gj_erp.annotation.AuthFunction;
import com.dsic.gj_erp.bean.ResultBean;
import com.dsic.gj_erp.bean.jhgk.DmYdjh;
@ -15,6 +16,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* <p>
@ -36,6 +38,7 @@ public class DmYdjhController {
public ResultBean getList(@RequestBody Map<String, String> map){
List<DmYdjh> list= service.list(new QueryWrapper<DmYdjh>()
.eq(StrUtil.isNotEmpty(map.get("dcCh")),"dc_ch",map.get("dcCh"))
.eq(StrUtil.isNotEmpty(map.get("zt")),"zt",map.get("zt"))
.ge(StrUtil.isNotEmpty(map.get("yf")), "jssj", DateUtil.beginOfMonth(DateUtil.parseDate(map.get("yf"))))
.le(StrUtil.isNotEmpty(map.get("yf")), "jssj", DateUtil.endOfMonth(DateUtil.parseDate(map.get("yf"))))
.orderByAsc("jssj,dc_ch,dc_pl")
@ -54,5 +57,23 @@ public class DmYdjhController {
public ResultBean hz(@RequestBody List<DmYdjh> list){
return new ResultBean(service.hz(list));
}
@RequestMapping("/tj")
@AuthFunction
public ResultBean tj(@RequestBody List<DmYdjh> list){
List<String> idList=list.stream().map(DmYdjh::getId).collect(Collectors.toList());
service.update(new UpdateWrapper<DmYdjh>().set("zt","1")
.in( "id",idList)
);
return new ResultBean();
}
@RequestMapping("/xf")
@AuthFunction
public ResultBean xf(@RequestBody List<DmYdjh> list){
return new ResultBean();
}
}

@ -25,4 +25,6 @@ public interface DmYdjhMapper extends BaseMapper<DmYdjh> {
List<PgdSljh> getSljh(@Param("begin") String begin, @Param("end") String end);
List<PgdPwjh> getPwjh(@Param("begin") String begin, @Param("end") String end);
List<PgdQgjh> getQgjh(@Param("begin") String begin, @Param("end") String end);
int xfbc(List<String> ids);
int tqlj(List<String> ids);
}

@ -4,6 +4,7 @@ package com.dsic.gj_erp.service.jhgk;
import com.baomidou.mybatisplus.extension.service.IService;
import com.dsic.gj_erp.bean.ResultBean;
import com.dsic.gj_erp.bean.jhgk.DmQfxq;
import com.dsic.gj_erp.bean.jhgk.DmSygdxq;
import com.dsic.gj_erp.bean.jhgk.excel.QfExcel;
import javax.servlet.http.HttpServletRequest;
@ -20,5 +21,7 @@ import java.util.Map;
*/
public interface DmQfxqService extends IService<DmQfxq> {
ResultBean uploadQf(List<QfExcel> list, String project, HttpServletRequest req);
void saveXzList(List<DmQfxq> list, String username, String day);
void saveDzList(List<DmQfxq> list, String username, String day);
}

@ -21,4 +21,5 @@ public interface DmYdjhService extends IService<DmYdjh> {
List<DmSygdMx> tjydjh();
Map<String,Object> hz(List<DmYdjh> ydjhList);
void xf(List<DmYdjh> ydjhList);
}

@ -2,15 +2,15 @@ package com.dsic.gj_erp.service.jhgk.impl;
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.dsic.gj_erp.bean.ResultBean;
import com.dsic.gj_erp.bean.jcsj.EmGcrl;
import com.dsic.gj_erp.bean.jhgk.DmQfxq;
import com.dsic.gj_erp.bean.jhgk.DmSygdxq;
import com.dsic.gj_erp.bean.jhgk.DmYdjh;
import com.dsic.gj_erp.bean.jhgk.excel.QfExcel;
import com.dsic.gj_erp.mapper.jcsj.EmGcrlMapper;
import com.dsic.gj_erp.mapper.jhgk.DmQfxqMapper;
import com.dsic.gj_erp.service.jhgk.DmQfxqService;
import com.dsic.gj_erp.service.jhgk.DmYdjhService;
@ -33,31 +33,91 @@ import java.util.stream.Collectors;
@Service
public class DmQfxqServiceImpl extends ServiceImpl<DmQfxqMapper, DmQfxq> implements DmQfxqService {
@Resource
private EmGcrlMapper gcrlMapper;
@Resource
private DmYdjhService ydjhService;
@Override
@Transactional(rollbackFor = Exception.class)
public ResultBean uploadQf(List<QfExcel> list, String project, HttpServletRequest req) {
List<DmQfxq> listForSave = new ArrayList<>();
for (QfExcel q : list) {
DmQfxq a = new DmQfxq();
BeanUtil.copyProperties(q, a);
String pl = a.getDcPl().length() == 1 ? "00" + a.getDcPl() : a.getDcPl().length() == 2 ? "0" + a.getDcPl() : a.getDcPl();
a.setDcPl(pl);
a.setBzry((String) req.getAttribute("yhms"));
a.setBzrq(DateUtil.format(DateUtil.date(), "yyyy/MM/dd"));
listForSave.add(a);
this.remove(new QueryWrapper<DmQfxq>().eq("Dc_ch", a.getDcCh()).eq("Dc_pl", a.getDcPl()).eq("Dc_fd", a.getDcFd()));
}
this.saveBatch(listForSave);
//生成月度计划信息
generateYdjh(listForSave);
return new ResultBean();
@Transactional
public void saveXzList(List<DmQfxq> list, String username, String day){
list.forEach(l->{
l.setDcPl(l.getDcPl().length() == 1 ? "00" + l.getDcPl() : l.getDcPl().length() == 2 ? "0" + l.getDcPl() : l.getDcPl());
DmQfxq qfxq=this.getOne(new QueryWrapper<DmQfxq>()
.eq("dc_ch",l.getDcCh())
.eq("dc_pl",l.getDcPl())
.eq("DC_FD",l.getDcFd())
);
if (ObjUtil.isNotEmpty(qfxq)){
l.setDrcs(qfxq.getDrcs()+1);
l.setXzglxqOld(qfxq.getXzglxq());
l.setDrr(username);
l.setDrrq(day);
//状态 2拖期 1提前
if (l.getXzglxq().compareTo(qfxq.getXzglxq())>0){
l.setXqzt("2");
}
if (l.getXzglxq().compareTo(qfxq.getXzglxq())<0){
l.setXqzt("1");
}
this.update(new UpdateWrapper<DmQfxq>()
.set("xzglxq",l.getXzglxq())
.set("xzglxq_old",l.getXzglxqOld())
.set("xdb",l.getXdb())
.set("xskj",l.getXskj())
.set("xpt",l.getXpt())
.set("xyw",l.getXyw())
.set("xxc",l.getXxc())
.set("xtxc",l.getXtxc())
.set("drcs",l.getDrcs())
.set("xqzt",l.getXqzt())
.set("drrq",l.getDrrq())
.set("drr",l.getDrr())
.eq("dc_ch",l.getDcCh())
.eq("dc_pl",l.getDcPl())
.eq("DC_FD",l.getDcFd())
);
}else {
l.setDrr(username);
l.setDrrq(day);
this.save(l);
}
});
}
@Override
@Transactional
public void saveDzList(List<DmQfxq> list,String username,String day){
list.forEach(l->{
l.setDcPl(l.getDcPl().length() == 1 ? "00" + l.getDcPl() : l.getDcPl().length() == 2 ? "0" + l.getDcPl() : l.getDcPl());
DmQfxq qfxq=this.getOne(new QueryWrapper<DmQfxq>()
.eq("dc_ch",l.getDcCh())
.eq("dc_pl",l.getDcPl())
.eq("DC_FD",l.getDcFd())
);
if (ObjUtil.isNotEmpty(qfxq)){
l.setDrr(username);
l.setDrrq(day);
this.update(new UpdateWrapper<DmQfxq>()
.set("dzglxq",l.getDzglxq())
.set("dzglxq_old",qfxq.getDzglxq())
.set("dqb",l.getDqb())
.set("dxc",l.getDxc())
.set("dsj",l.getDsj())
.set("ddb",l.getDdb())
.set("drrq",l.getDrrq())
.set("drr",l.getDrr())
.eq("dc_ch",l.getDcCh())
.eq("dc_pl",l.getDcPl())
.eq("DC_FD",l.getDcFd())
);
}else {
l.setDrr(username);
l.setDrrq(day);
this.save(l);
}
});
generateYdjh(list);
}
/**

@ -3,8 +3,10 @@ package com.dsic.gj_erp.service.jhgk.impl;
import cn.hutool.core.date.DateUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.dsic.gj_erp.bean.jcsj.EmGcrl;
import com.dsic.gj_erp.bean.jcsj.EmSbcnp;
import com.dsic.gj_erp.bean.jhgk.DmQfxq;
import com.dsic.gj_erp.bean.jhgk.DmSygdMx;
import com.dsic.gj_erp.bean.jhgk.DmYdjh;
@ -55,7 +57,7 @@ public class DmYdjhServiceImpl extends ServiceImpl<DmYdjhMapper, DmYdjh> impleme
//3.根据前方需求期,重新为三月滚动明细排产(板),排产后的数据添加到月度计划,并且反写数据到三月滚动明细
// List<DmQfxq> qfxqList= qfxqService.list(new QueryWrapper<DmQfxq>().eq("substring(db,0,8) ", DateUtil.format(DateUtil.nextMonth(),"yyyy/MM")));
int i = qfxqService.count(new QueryWrapper<DmQfxq>()
.eq("substring(db,0,8) ", "2023/08"));
.eq("substring(xzglxq,0,8) ", "2023/08"));
if (i < 1) {
System.out.println("下月的前方需求信息未导入!");
return null;
@ -83,35 +85,37 @@ public class DmYdjhServiceImpl extends ServiceImpl<DmYdjhMapper, DmYdjh> impleme
String end ="2023/08/31";
//图纸计划
List<PgdTzjh> tzjhList=tzjhService.list(new QueryWrapper<PgdTzjh>().between("qgxqrq",begin,end));
List<PgdTzjh> tzjhList=tzjhService.list(new QueryWrapper<PgdTzjh>().between("qgxqrq",begin,end).orderByAsc("czbh,pl,qgxqrq"));
if (tzjhList.size()<1){
baseMapper.getTzjh(begin,end);
tzjhList=tzjhService.list(new QueryWrapper<PgdTzjh>().between("qgxqrq",begin,end));
tzjhList=tzjhService.list(new QueryWrapper<PgdTzjh>().between("qgxqrq",begin,end)
.orderByAsc("czbh,pl,qgxqrq")
);
}
//订货清单
List<PgdDh> dhList=dhService.list(new QueryWrapper<PgdDh>().between("slxqrq",begin,end));
List<PgdDh> dhList=dhService.list(new QueryWrapper<PgdDh>().between("slxqrq",begin,end).orderByAsc("czbh,slxqrq"));
if (dhList.size()<1){
baseMapper.getDhjh(begin,end);
dhList=dhService.list(new QueryWrapper<PgdDh>().between("slxqrq",begin,end));
dhList=dhService.list(new QueryWrapper<PgdDh>().between("slxqrq",begin,end).orderByAsc("czbh,slxqrq"));
}
//上料计划
List<PgdSljh> slList=slService.list(new QueryWrapper<PgdSljh>().between("sljhrq",begin,end));
List<PgdSljh> slList=slService.list(new QueryWrapper<PgdSljh>().between("sljhrq",begin,end).orderByAsc("czbh,pl,sljhrq"));
if (slList.size()<1){
baseMapper.getSljh(begin,end);
slList=slService.list(new QueryWrapper<PgdSljh>().between("sljhrq",begin,end));
slList=slService.list(new QueryWrapper<PgdSljh>().between("sljhrq",begin,end).orderByAsc("czbh,pl,sljhrq"));
}
//抛丸计划
List<PgdPwjh> pwList=pwService.list(new QueryWrapper<PgdPwjh>().between("pwjhrq",begin,end));
List<PgdPwjh> pwList=pwService.list(new QueryWrapper<PgdPwjh>().between("pwjhrq",begin,end).orderByAsc("czbh,pl,pwjhrq"));
if (pwList.size()<1){
baseMapper.getPwjh(begin,end);
pwList=pwService.list(new QueryWrapper<PgdPwjh>().between("pwjhrq",begin,end));
pwList=pwService.list(new QueryWrapper<PgdPwjh>().between("pwjhrq",begin,end).orderByAsc("czbh,pl,pwjhrq"));
}
//切割计划
List<PgdQgjh> qgList=qgService.list(new QueryWrapper<PgdQgjh>().between("qgjhrq",begin,end));
List<PgdQgjh> qgList=qgService.list(new QueryWrapper<PgdQgjh>().between("qgjhrq",begin,end).orderByAsc("czbh,pl,qgjhrq"));
if (qgList.size()<1){
baseMapper.getQgjh(begin,end);
qgList=qgService.list(new QueryWrapper<PgdQgjh>().between("qgjhrq",begin,end));
qgList=qgService.list(new QueryWrapper<PgdQgjh>().between("qgjhrq",begin,end).orderByAsc("czbh,pl,qgjhrq"));
}
map.put("tzjhList",tzjhList);
map.put("dhList",dhList);
@ -121,4 +125,18 @@ public class DmYdjhServiceImpl extends ServiceImpl<DmYdjhMapper, DmYdjh> impleme
return map;
}
//下发 派工单状态改为编制 生成零件信息
@Override
public void xf(List<DmYdjh> ydjhList){
//修改状态
List<String> idList=ydjhList.stream().map(DmYdjh::getId).collect(Collectors.toList());
this.update(new UpdateWrapper<DmYdjh>().set("zt","2")
.in( "id",idList)
);
//修改汇总状态 改为 编制
baseMapper.xfbc(idList);
//生成对应零件信息 bom->tzjhLj
baseMapper.tqlj(idList);
}
}

@ -2,25 +2,12 @@
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.dsic.gj_erp.mapper.jhgk.DmQfxqMapper">
<!-- 通用查询映射结果 -->
<resultMap id="BaseResultMap" type="com.dsic.gj_erp.bean.jhgk.DmQfxq">
<id column="id" property="id" />
<result column="DC_CH" property="dcCh" />
<result column="DC_PL" property="dcPl" />
<result column="DC_FD" property="dcFd" />
<result column="pscd" property="pscd" />
<result column="cjzg" property="cjzg" />
<result column="db" property="db" />
<result column="xc" property="xc" />
<result column="txc" property="txc" />
<result column="bz" property="bz" />
<result column="zt" property="zt" />
</resultMap>
<select id="getYdjh" resultType="com.dsic.gj_erp.bean.jhgk.DmYdjh" parameterType="arraylist">
SELECT
dm_qfxq.DC_CH,dm_qfxq.DC_PL,
dm_qfxq.db,dm_qfxq.xc,dm_qfxq.txc,
-- dm_qfxq.xzglxq,
dm_sygd_mx.dc_ch1,
dm_sygd_mx.LQLB,
dm_sygd_mx.tzbh,
@ -91,6 +78,6 @@
dm_qfxq
left JOIN dm_sygd_mx on
dm_qfxq.dc_pl=dm_sygd_mx.dc_pl and dm_qfxq.DC_CH=dm_sygd_mx.dc_ch
ORDER BY dm_qfxq.db,dm_qfxq.DC_CH,dm_qfxq.DC_PL
ORDER BY dm_qfxq.xzglxq,dm_qfxq.DC_CH,dm_qfxq.DC_PL
</select>
</mapper>

@ -144,15 +144,15 @@
dm_sygd_mx.bcqpyld,
dm_sygd_mx.ylbhgg,t.xqsj as jssj from
( SELECT DC_CH,DC_PL,DC_FD,tzbh,xqsj,rn FROM
( SELECT dm_qfxq.db as xqsj,dm_bom.tzbh,
( SELECT dm_qfxq.xzglxq as xqsj,dm_bom.tzbh,
dm_qfxq.DC_CH,dm_qfxq.DC_PL,dm_qfxq.DC_FD,
row_number() over(partition by dm_qfxq.DC_CH,dm_qfxq.DC_PL,dm_bom.tzbh order by dm_qfxq.db ) rn
row_number() over(partition by dm_qfxq.DC_CH,dm_qfxq.DC_PL,dm_bom.tzbh order by dm_qfxq.xzglxq ) rn
from dm_qfxq LEFT JOIN dm_bom
on dm_bom.dcch = dm_qfxq.DC_CH
and dm_bom.pl = dm_qfxq.DC_PL
and dm_bom.fd = dm_qfxq.DC_FD
where
substring(dm_qfxq.db, 0, 8) =#{nextMonth}) r where r.rn=1
substring(dm_qfxq.xzglxq, 0, 8) =#{nextMonth}) r where r.rn=1
)t LEFT JOIN dm_sygd_mx
on dm_sygd_mx.dc_ch=t.DC_CH and dm_sygd_mx.dc_pl=t.DC_PL and dm_sygd_mx.tzbh=t.TZBH
order BY t.xqsj,t.DC_CH,t.DC_PL
@ -181,26 +181,33 @@
dm_czplp_new.jsq_lqb as lqbjsrq,
dm_czplp_new.xfq_tlt as tltxfrq,
dm_czplp_new.jsq_tlt as tltjsrq,
dm_ydjh.qgrq as qgxqrq,
dm_ydjh.jssj as qfxqrqxz,
dm_ydjh.gjjs_dz as qfxqrqdz,
MIN(dm_ydjh.qgrq) as qgxqrq,
MIN(dm_ydjh.jssj) as qfxqrqxz,
MIN(dm_ydjh.gjjs_dz) as qfxqrqdz,
REPLACE(CAST(CAST(NEWID()AS BINARY(10)) + CAST(GETDATE() AS BINARY(6)) AS UNIQUEIDENTIFIER),'-','')
as id
from dm_ydjh LEFT JOIN
(SELECT dm_czplp_new.DC_CH,dm_czplp_new.DC_PL,dm_czplp_new.jsq_lqb,dm_czplp_new.jsq_tlt,dm_czplp_new.xfq_lqb,dm_czplp_new.xfq_tlt,dm_czplp_new.jsq_ptb,dm_czplp_new.xfq_ptb
from dm_czplp_new
GROUP BY dm_czplp_new.DC_CH,dm_czplp_new.DC_PL,dm_czplp_new.jsq_lqb,dm_czplp_new.jsq_tlt,dm_czplp_new.xfq_lqb,dm_czplp_new.xfq_tlt,dm_czplp_new.jsq_ptb,dm_czplp_new.xfq_ptb)
dm_czplp_new
from
dm_ydjh
LEFT JOIN dm_czplp_new
on
dm_ydjh.dc_ch=dm_czplp_new.DC_CH and
dm_ydjh.dc_pl=dm_czplp_new.DC_pl
WHERE
dm_ydjh.qgrq BETWEEN #{begin} and #{end}
GROUP BY
dm_ydjh.dc_ch,
dm_ydjh.dc_pl,
dm_ydjh.dc_fd,
dm_czplp_new.xfq_lqb,
dm_czplp_new.jsq_lqb,
dm_czplp_new.xfq_tlt,
dm_czplp_new.jsq_tlt
</select>
<select id="getDhjh" resultType="com.dsic.gj_erp.bean.pgd.PgdDh">
insert into pgd_dh
(id,
czbh,
pl,
dhqdh,
wpcz,
slxqrq,
@ -216,7 +223,7 @@
SELECT
REPLACE(CAST(CAST(NEWID()AS BINARY(10)) + CAST(GETDATE() AS BINARY(6)) AS UNIQUEIDENTIFIER),'-','') as id,
dm_ydjh.dc_ch as czbh,
dm_czplp_new.dhqd as dhqdh,
dm_ydjh.dhqd as dhqdh,
dm_ydjh.jssj as qfxqrqxz,
dm_ydjh.gjjs_dz as qfxqrqdz,
dm_ydjh.slrq as slxqrq,
@ -230,13 +237,6 @@
dhxx.RKXH as wpcz
from dm_ydjh
LEFT JOIN
(SELECT DC_CH, DC_PL, dhqd
from dm_czplp_new
GROUP BY DC_CH, DC_PL, dhqd) dm_czplp_new
on
dm_ydjh.dc_ch = dm_czplp_new.DC_CH and
dm_ydjh.dc_pl = dm_czplp_new.DC_pl
LEFT JOIN
(select MS_DDJBP.CGFLM,
MS_DDJBP.DDH,
MS_DDJBP.ddmc as ddmc,
@ -261,7 +261,7 @@
and im_crklsz.HDLX <![CDATA[ <> ]]> '99'
GROUP BY MS_DDJBP.CGFLM, MS_DDJBP.DDH, MS_DDJBP.ddmc, MS_DDMXP.dc_ch, MS_DDMXP.WPHD, MS_DDMXP.WPCD,
MS_DDMXP.WPKD, MS_DDMXP.RKXH, MS_DDJBP.dhqdh) dhxx
on dhxx.dhqdh = dm_czplp_new.dhqd
on dhxx.dhqdh = dm_ydjh.dhqd
where dm_ydjh.slrq BETWEEN #{begin} and #{end}
ORDER BY dm_ydjh.dc_ch,
dm_ydjh.dc_pl
@ -311,6 +311,7 @@
dm_ydjh.dc_pl=IM_CKWPKWP.DC_pl and
dm_ydjh.tzbh=IM_CKWPKWP.DC_th
WHERE dm_ydjh.slrq BETWEEN #{begin} and #{end}
</select>
<select id="getPwjh" resultType="com.dsic.gj_erp.bean.pgd.PgdPwjh">
@ -397,4 +398,114 @@
from dm_ydjh
where dm_ydjh.qgrq BETWEEN #{begin} and #{end}
</select>
<update id="xfbc" parameterType="arraylist">
update pgd_tzjh
set zt='01'
from pgd_tzjh,dm_ydjh
where pgd_tzjh.czbh= dm_ydjh.dc_ch and pgd_tzjh.pl=dm_ydjh.dc_pl
and dm_ydjh.id in
<foreach collection="ids" index="index" item="item" open="(" separator="," close=");">
#{item}
</foreach>
update pgd_dh
set zt='01'
from pgd_dh,dm_ydjh
where pgd_dh.czbh= dm_ydjh.dc_ch and pgd_dh.dhqdh=dm_ydjh.dhqdh
and dm_ydjh.id in
<foreach collection="ids" index="index" item="item" open="(" separator="," close=");">
#{item}
</foreach>
update pgd_sljh
set zt='01'
from pgd_sljh,dm_ydjh
where pgd_sljh.czbh= dm_ydjh.dc_ch and pgd_sljh.pl=dm_ydjh.dc_pl and pgd_sljh.tlth=dm_ydjh.tzbh
and dm_ydjh.id in
<foreach collection="ids" index="index" item="item" open="(" separator="," close=");">
#{item}
</foreach>
update pgd_pwjh
set zt='01'
from pgd_pwjh,dm_ydjh
where pgd_pwjh.czbh= dm_ydjh.dc_ch and pgd_pwjh.pl=dm_ydjh.dc_pl and pgd_pwjh.tlth=dm_ydjh.tzbh
and dm_ydjh.id in
<foreach collection="ids" index="index" item="item" open="(" separator="," close=");">
#{item}
</foreach>
update pgd_qgjh
set zt='01'
from pgd_qgjh,dm_ydjh
where pgd_qgjh.czbh= dm_ydjh.dc_ch and pgd_qgjh.pl=dm_ydjh.dc_pl and pgd_qgjh.tlth=dm_ydjh.tzbh
and dm_ydjh.id in
<foreach collection="ids" index="index" item="item" open="(" separator="," close=");">
#{item}
</foreach>
</update>
<insert id="tqlj" parameterType="arraylist">
insert into dm_ydjh_lj (
id,
czbh,
pl,
fd,
kw,
zl,
tlth,
ptblx,
ljbh,
ljmc,
ljgg,
ljcz,
wpfl,
jldw,
sl,
qfxqrqxz,
qfxqrqdz,
gylx,
pklx,
pkcd,
pkbs,
dmbs,
dmcd,
qbs
)
SELECT
REPLACE(CAST(CAST(NEWID()AS BINARY(10)) + CAST(GETDATE() AS BINARY(6)) AS UNIQUEIDENTIFIER),'-','') as id,
dm_ydjh.dc_ch as czbh,
dm_ydjh.dc_pl as pl,
dm_bom.fd as fd,
dm_ydjh.kw as kw,
dm_bom.zl as zl,
dm_bom.tzbh as tlth,
'' as ptblx,
dm_bom.ljbh as ljbh,
'' as ljmc,
dm_bom.wpgg as ljgg,
dm_bom.wpcz as ljcz,
'' as wpfl,
'' as jldw,
dm_bom.ljsl as sl,
dm_qfxq.xzglxq as qfxqrqxz,
dm_qfxq.dzglxq as qfxqrqdz,
'' as gylx,
dm_bom.pklx as pklx,
dm_bom.pkcd as pkcd,
dm_bom.pkbs as pkbs,
dm_bom.dmbs as dmbs,
dm_bom.dmcd as dmcd,
dm_bom.qbs as qbs
from dm_ydjh,dm_bom
LEFT JOIN dm_qfxq on dm_qfxq.DC_CH=dm_bom.dcch and dm_qfxq.DC_PL=dm_bom.pl and dm_qfxq.DC_FD=dm_bom.fd
WHERE
dm_ydjh.dc_ch= dm_bom.dcch
and dm_ydjh.dc_pl=dm_bom.pl
and dm_ydjh.tzbh=dm_bom.tzbh
and dm_ydjh.id in
<foreach collection="ids" index="index" item="item" open="(" separator="," close=");">
#{item}
</foreach>
</insert>
</mapper>

Loading…
Cancel
Save