Merge remote-tracking branch 'origin/master'

op-api/op-api-system/src/main/java/com/op/system/api/RemoteDeviceService.java

@@ -30,4 +30,7 @@ public interface RemoteDeviceService {
 
 	@PostMapping("/deviceTask/createEquipmentOperationTask")
 	public R createEquipmentOperationTask();
+
+	@PostMapping("/deviceTask/equipmentBKTask")
+    public R equipmentBKTask();
 }

op-api/op-api-system/src/main/java/com/op/system/api/factory/RemoteDeviceFallbackFactory.java

@@ -42,6 +42,11 @@ public class RemoteDeviceFallbackFactory implements FallbackFactory<RemoteDevice
 			public R createEquipmentOperationTask() {
 				return R.fail("设备运行记录生成失败:" + throwable.getMessage());
 			}
+
+			@Override
+			public R equipmentBKTask() {
+				return R.fail("设备运行记录数据库备份失败"+throwable.getMessage());
+			}
 		};
 	}
 }

op-modules/op-device/src/main/java/com/op/device/controller/DeviceTaskController.java

@@ -76,4 +76,17 @@ public class DeviceTaskController {
         }
         return R.fail("设备运行记录生成失败");
     }
+
+    /**
+     * 设备运行记录数据库备份（每年）
+     * @return
+     */
+    @PostMapping("/equipmentBKTask")
+    public R equipmentBKTask() {
+        AjaxResult result = taskService.equipmentBKTask();
+        if (result.isSuccess()){
+            return R.ok("设备运行记录数据库备份成功");
+        }
+        return R.fail("设备运行记录数据库备份失败");
+    }
 }

op-modules/op-device/src/main/java/com/op/device/mapper/EquOperationMapper.java

@@ -5,7 +5,8 @@ import java.util.List;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.op.device.domain.EquOperation;
 import com.op.device.domain.EquOperationRecord;
-import io.lettuce.core.dynamic.annotation.Param;
+import org.apache.ibatis.annotations.Param;
+
 
 /**
  * 设备运行记录Mapper接口
@@ -73,4 +74,16 @@ public interface EquOperationMapper {
 
     // 校验当天运行记录数量
     int checkInsertOperation();
+
+    // 获取当前YEAR-2的备份表的运行数据第一条
+    EquOperation checkBackupOperation();
+
+    // 获取备份插入数据数量
+    int getBackupOperationNum();
+
+    // 分批次备份
+    int backupOperation(@Param("startIndex") int startIndex,@Param("batchSize") int batchSize);
+
+    // 分批次删除
+    int deleteOperation(@Param("delSize") int delSize);
 }

op-modules/op-device/src/main/java/com/op/device/service/IDeviceTaskService.java

@@ -19,4 +19,6 @@ public interface IDeviceTaskService {
     AjaxResult createMaintenancePlanTask();
 
     AjaxResult createEquipmentOperationTask();
+
+    AjaxResult equipmentBKTask();
 }

op-modules/op-device/src/main/java/com/op/device/service/impl/DeviceTaskServiceImpl.java

@@ -21,6 +21,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
+import java.time.LocalDate;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
@@ -210,6 +211,39 @@ public class DeviceTaskServiceImpl implements IDeviceTaskService {
         return success();
     }
 
+    /**
+     * 设备运行记录数据库备份（每年）
+     * @return
+     */
+    @Override
+    public AjaxResult equipmentBKTask() {
+        // 加载sf-cloud库的sys_datasource
+        SysUser sysUser = new SysUser();
+        sysUser.setUserId(1L);
+        R<List<Map<String, String>>> dateSources0 = remoteUserService.getPoolNameList(sysUser);
+        List<Map<String, String>> dateSources = dateSources0.getData();
+        ExecutorService executorService = new ThreadPoolExecutor(
+                dateSources.size(),
+                dateSources.size(),
+                0L, TimeUnit.MILLISECONDS,
+                new LinkedBlockingQueue<Runnable>());
+
+        try {
+            dateSources.forEach(dateSource -> {
+                logger.info("++++++++++++" + dateSource.get("poolName") + "++++设备运行记录数据库备份开始++++++++++");
+                Runnable run = () -> backupEquipmentOperation(dateSource.get("poolName"));
+                executorService.execute(run);
+            });
+        } catch (Exception e) {
+            logger.error("service == dataClearTask == exception", e);
+            return error("service == dataClearTask == exception");
+        } finally {
+            executorService.shutdown();
+        }
+
+        return success();
+    }
+
     public void createSpotCheckPlanFunc(String poolName){
         DynamicDataSourceContextHolder.push(poolName);// 这是数据源的key
         /**equ_plan   equ_plan_equ**/
@@ -431,7 +465,7 @@ public class DeviceTaskServiceImpl implements IDeviceTaskService {
                 operation.setCreateTime(DateUtils.getNowDate());
             }
 
-            int batchSize = 200;// 批次数量
+            int batchSize = 100;// 批次数量
 
             // 分批次处理
             int batchCount = (operationList.size() + batchSize - 1)/batchSize;// 计算批次数量
@@ -450,6 +484,40 @@ public class DeviceTaskServiceImpl implements IDeviceTaskService {
 
     }
 
+    private void backupEquipmentOperation(String poolName) {
+        DynamicDataSourceContextHolder.push(poolName);// 这是数据源的key
+        // 校验当前YEAR-2是否备份过数据
+        EquOperation check = equOperationMapper.checkBackupOperation();
+        if (check == null) {
+            // 获取插入数量
+            int insertNum = equOperationMapper.getBackupOperationNum();
+            int insertSize = 100;// 新增批次数量
+
+            // 分批次备份
+            int batchCount = (insertNum + insertSize - 1)/insertSize;// 计算批次数量
+            for (int i = 0;i < batchCount; i++) {
+                int startIndex = i * insertSize;// 索引开始值
+                int endIndex = Math.min((i + 1)*insertSize,insertNum);// 索引结束值
+
+                // 备份至数据库
+                int num = equOperationMapper.backupOperation(startIndex,insertSize);
+
+                System.out.println("数据源:"+poolName+"--->"+"第"+(i+1)+"轮备份"+"开始索引:"+startIndex+"________结束索引:"+endIndex+"________成功插入数量:"+num);
+            }
+
+            // 删除源数据库数据
+            int delSize = 100;// 删除批次数量
+            for (int i = 0; i < insertNum/delSize+1; i++) {
+                // 在源数据库中删除
+                int num = equOperationMapper.deleteOperation(delSize);
+                System.out.println("数据源:"+poolName+"--->"+"第"+(i+1)+"轮删除"+"------>成功删除数量:"+num);
+            }
+
+        }else {
+            System.out.println("数据源:"+poolName+"---->"+"年份:"+( LocalDate.now().getYear()-2) +"--->已备份");
+        }
+    }
+
     public static void main(String[] args) {
 
         int batchSize = 200;// 批次数量

op-modules/op-device/src/main/resources/mapper/device/EquOperationMapper.xml

@@ -119,6 +119,14 @@
         where CONVERT(date, create_time) = CONVERT(date, GETDATE())
     </select>
 
+    <select id="checkBackupOperation" resultMap="EquOperationResult">
+        select top 1 id from equ_operation_backup where YEAR(create_time) = YEAR(GETDATE())-2
+    </select>
+
+    <select id="getBackupOperationNum" resultType="java.lang.Integer">
+        select count(id) from equ_operation where YEAR(create_time) = YEAR(GETDATE())-2
+    </select>
+
     <insert id="insertEquOperation" parameterType="EquOperation">
         insert into equ_operation
         <trim prefix="(" suffix=")" suffixOverrides=",">
@@ -188,6 +196,15 @@
         </foreach>
     </insert>
 
+    <insert id="backupOperation">
+        insert into equ_operation_backup
+        select s.*
+        from equ_operation s
+        where YEAR (s.create_time) = YEAR (GETDATE())-2
+        ORDER BY id
+        OFFSET #{startIndex} ROWS FETCH NEXT #{batchSize} ROWS ONLY
+    </insert>
+
     <update id="updateEquOperation" parameterType="EquOperation">
         update equ_operation
         <trim prefix="SET" suffixOverrides=",">
@@ -230,4 +247,12 @@
             #{id}
         </foreach>
     </delete>
+
+    <delete id="deleteOperation">
+        delete
+        from equ_operation
+        where id in (select s.id from equ_operation s where YEAR (s.create_time) = YEAR (GETDATE())-2
+        ORDER BY id
+        OFFSET 0 ROWS FETCH NEXT #{delSize} ROWS ONLY)
+    </delete>
 </mapper>

op-modules/op-job/src/main/java/com/op/job/task/RyTask.java

@@ -144,4 +144,10 @@ public class RyTask {
 		logger.info("++设备运行记录生成任务开始++createEquipmentOperationTask+++++");
 		remoteDeviceService.createEquipmentOperationTask();
 	}
+
+	/** 每年1月1日1：50执行 **/
+	public void equipmentBKTask(){
+		logger.info("++设备运行记录+数据库备份的数据+开始++equipmentBkTask+++++");
+		remoteDeviceService.equipmentBKTask();
+	}
 }

op-modules/op-plan/src/main/java/com/op/plan/domain/ProOrderWorkorder.java

@@ -33,7 +33,7 @@ public class ProOrderWorkorder extends TreeEntity {
     private String orderId;
 
     /** 订单编码 */
-    @Excel(name = "子订单编码")
+    @Excel(name = "子订单旧编码")
     private String orderCode;
 
     /** 产品ID */
@@ -211,7 +211,7 @@ public class ProOrderWorkorder extends TreeEntity {
     }
 
     private String prepareId;
-
+    @Excel(name = "子订单新编号")
     private String workorderCodeSap;
 
     /** 批次号 */
@@ -219,9 +219,39 @@ public class ProOrderWorkorder extends TreeEntity {
     private List<StringBuilder> batchNumList;
     private List<String> batchInfo;
 
+    private String pproductCode;
+    @Excel(name = "母产品名称")
+    private String pproductName;
+    @Excel(name = "母订单新编号")
+    private String pworkorderCodeSap;
+
     /** $column.columnComment */
     private String factoryCode;
 
+    public String getPproductCode() {
+        return pproductCode;
+    }
+
+    public void setPproductCode(String pproductCode) {
+        this.pproductCode = pproductCode;
+    }
+
+    public String getPproductName() {
+        return pproductName;
+    }
+
+    public void setPproductName(String pproductName) {
+        this.pproductName = pproductName;
+    }
+
+    public String getPworkorderCodeSap() {
+        return pworkorderCodeSap;
+    }
+
+    public void setPworkorderCodeSap(String pworkorderCodeSap) {
+        this.pworkorderCodeSap = pworkorderCodeSap;
+    }
+
     public List<String> getBatchInfo() {
         return batchInfo;
     }

op-modules/op-plan/src/main/java/com/op/plan/mapper/ProOrderWorkorderMapper.java

@@ -166,5 +166,6 @@ public interface ProOrderWorkorderMapper {
     int updateWhiteWorkOrder(ProOrderWorkorder whiteOrder);
 
     ProOrderWorkorder getPWorkOrder(ProOrderWorkorder whiteOrder);
+
 }
 

op-modules/op-plan/src/main/resources/mapper/plan/ProOrderWorkorderMapper.xml

@@ -38,6 +38,11 @@
         <result property="endFlag"	column="end_flag"	/>
         <result property="carNum"	column="car_num"	/>
         <result property="sortNo"	column="sort_no"	/>
+        <result property="workorderCodeSap"	column="workorder_code_sap"	/>
+        <result property="pproductCode"	column="pproductCode"	/>
+        <result property="pproductName"	column="pproductName"	/>
+        <result property="pworkorderCodeSap" column="pworkorderCodeSap"	/>
+
     </resultMap>
 
     <sql id="selectProOrderWorkorderVo">
@@ -49,37 +54,33 @@
 	</sql>
 
     <select id="selectProOrderWorkorderList" parameterType="ProOrderWorkorder" resultMap="ProOrderWorkorderResult">
-        <include refid="selectProOrderWorkorderVo"/>
+        select  pow.workorder_id, pow.workorder_code, pow.workorder_name, pow.order_id, pow.order_code,
+                pow.product_code, pow.product_name,pow.product_spc, pow.unit, pow.quantity_split,
+               pow.route_code, pow.prod_line_code, pow.product_date,
+                pow.shift_id, pow.parent_order,pow.status, pow.prod_type,pow.factory_code,
+                pow.end_flag,pow.car_num,pow.sort_no,
+                pow.workorder_code_sap,
+                ppow.product_code pproductCode,ppow.product_name pproductName,pow.workorder_code_sap pworkorderCodeSap
+        from pro_order_workorder pow
+        left join pro_order_workorder ppow on pow.parent_order = ppow.workorder_code
         <where>
-            <if test="workorderCode != null  and workorderCode != ''"> and workorder_code like concat('%', #{workorderCode}, '%')</if>
-            <if test="workorderName != null  and workorderName != ''"> and workorder_name like concat('%', #{workorderName}, '%')</if>
-            <if test="orderId != null  and orderId != ''"> and order_id = #{orderId}</if>
-            <if test="orderCode != null  and orderCode != ''"> and order_code like concat('%', #{orderCode}, '%')</if>
-            <if test="productId != null  and productId != ''"> and product_id = #{productId}</if>
-            <if test="productCode != null  and productCode != ''"> and product_code like concat('%', #{productCode}, '%')</if>
-            <if test="productName != null  and productName != ''"> and product_name like concat('%', #{productName}, '%')</if>
-            <if test="productSpc != null  and productSpc != ''"> and product_spc = #{productSpc}</if>
-            <if test="unit != null  and unit != ''"> and unit = #{unit}</if>
-            <if test="quantityProduced != null "> and quantity_produced = #{quantityProduced}</if>
-            <if test="quantitySplit != null "> and quantity_split = #{quantitySplit}</if>
-            <if test="routeCode != null  and routeCode != ''"> and route_code = #{routeCode}</if>
-            <if test="prodLineCode != null  and prodLineCode != ''"> and prod_line_code = #{prodLineCode}</if>
-            <if test="productDate != null "> and product_date = #{productDate}</if>
-            <if test="shiftId != null  and shiftId != ''"> and shift_id = #{shiftId}</if>
-            <if test="parentOrder != null  and parentOrder != ''"> and parent_order = #{parentOrder}</if>
-            <if test="ancestors != null  and ancestors != ''"> and ancestors = #{ancestors}</if>
-            <if test="status != null  and status != ''"> and status = #{status}</if>
-            <if test="statusArray != null  and statusArray != ''"> and status in (${statusArray})</if>
-            <if test="attr1 != null  and attr1 != ''"> and attr1 = #{attr1}</if>
-            <if test="attr2 != null  and attr2 != ''"> and attr2 = #{attr2}</if>
-            <if test="attr3 != null  and attr3 != ''"> and attr3 = #{attr3}</if>
-            <if test="attr4 != null  and attr4 != ''"> and attr4 = #{attr4}</if>
-            <if test="prodType != null  and prodType != ''"> and prod_type = #{prodType}</if>
-            <if test="factoryCode != null  and factoryCode != ''"> and factory_code = #{factoryCode}</if>
-            <if test="endFlag != null  and endFlag != ''"> and end_flag = #{endFlag}</if>
-            <if test="productDateStart != null "> and CONVERT(varchar(10),product_date, 120) >= '${productDateStart}'</if>
-            <if test="productDateEnd != null "> and '${productDateEnd}%' >= CONVERT(varchar(10),product_date, 120)</if>
-            and del_flag = '0'
+            <if test="workorderCode != null  and workorderCode != ''"> and pow.workorder_code like concat('%', #{workorderCode}, '%')</if>
+            <if test="workorderName != null  and workorderName != ''"> and pow.workorder_name like concat('%', #{workorderName}, '%')</if>
+            <if test="orderId != null  and orderId != ''"> and pow.order_id = #{orderId}</if>
+            <if test="orderCode != null  and orderCode != ''"> and pow.order_code like concat('%', #{orderCode}, '%')</if>
+            <if test="productCode != null  and productCode != ''"> and pow.product_code like concat('%', #{productCode}, '%')</if>
+            <if test="productName != null  and productName != ''"> and pow.product_name like concat('%', #{productName}, '%')</if>
+            <if test="productDate != null "> and pow.product_date = #{productDate}</if>
+            <if test="shiftId != null  and shiftId != ''"> and pow.shift_id = #{shiftId}</if>
+            <if test="parentOrder != null  and parentOrder != ''"> and pow.parent_order = #{parentOrder}</if>
+            <if test="status != null  and status != ''"> and pow.status = #{status}</if>
+            <if test="statusArray != null  and statusArray != ''"> and pow.status in (${statusArray})</if>
+            <if test="prodType != null  and prodType != ''"> and pow.prod_type = #{prodType}</if>
+            <if test="factoryCode != null  and factoryCode != ''"> and pow.factory_code = #{factoryCode}</if>
+            <if test="endFlag != null  and endFlag != ''"> and pow.end_flag = #{endFlag}</if>
+            <if test="productDateStart != null "> and CONVERT(varchar(10),pow.product_date, 120) >= '${productDateStart}'</if>
+            <if test="productDateEnd != null "> and '${productDateEnd}' >= CONVERT(varchar(10),pow.product_date, 120)</if>
+            and pow.del_flag = '0'
         </where>
     </select>
 

op-modules/op-quality/src/main/java/com/op/quality/controller/QcInterfaceController.java

@@ -3,6 +3,7 @@ package com.op.quality.controller;
 import com.op.common.core.utils.StringUtils;
 import com.op.quality.domain.QcCheckType;
 import com.op.quality.domain.QcInterface;
+import com.op.quality.domain.QcLineChartDto;
 import com.op.quality.service.IQcInterfaceService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
@@ -126,4 +127,10 @@ public class QcInterfaceController {
     public List<QcInterface> getMonthOfYearContrast(@RequestBody QcInterface qcInterface) {
         return qcInterfaceService.getMonthOfYearContrast(qcInterface);
     }
+
+    @GetMapping("/getLineQcData")
+    public QcLineChartDto getLineQcData(QcInterface qcInterface) {
+        return qcInterfaceService.getLineQcData(qcInterface);
+    }
+
 }

op-modules/op-quality/src/main/java/com/op/quality/domain/QcInterface.java

@@ -47,6 +47,33 @@ public class QcInterface extends BaseEntity {
 	private List<String> data;
 	private String reasons;
 	private String typeCode;
+	private String productDateStart;
+	private String ProductDateEnd;
+	private String nameDate;
+
+	public String getNameDate() {
+		return nameDate;
+	}
+
+	public void setNameDate(String nameDate) {
+		this.nameDate = nameDate;
+	}
+
+	public String getProductDateStart() {
+		return productDateStart;
+	}
+
+	public void setProductDateStart(String productDateStart) {
+		this.productDateStart = productDateStart;
+	}
+
+	public String getProductDateEnd() {
+		return ProductDateEnd;
+	}
+
+	public void setProductDateEnd(String productDateEnd) {
+		ProductDateEnd = productDateEnd;
+	}
 
 	public String getTypeCode() {
 		return typeCode;

op-modules/op-quality/src/main/java/com/op/quality/domain/QcLineChartDto.java

@@ -0,0 +1,39 @@
+package com.op.quality.domain;
+
+import java.util.List;
+
+/**
+ * echart图返回数据
+ *
+ * @author Open Platform
+ * @date 2023-07-03
+ */
+public class QcLineChartDto {
+	private List<String> seriesNames;
+	private List<String> xAxisDatas;
+	private List<QcLineChartSeriesDto> seriesDatas;
+
+	public List<String> getSeriesNames() {
+		return seriesNames;
+	}
+
+	public void setSeriesNames(List<String> seriesNames) {
+		this.seriesNames = seriesNames;
+	}
+
+	public List<String> getxAxisDatas() {
+		return xAxisDatas;
+	}
+
+	public void setxAxisDatas(List<String> xAxisDatas) {
+		this.xAxisDatas = xAxisDatas;
+	}
+
+	public List<QcLineChartSeriesDto> getSeriesDatas() {
+		return seriesDatas;
+	}
+
+	public void setSeriesDatas(List<QcLineChartSeriesDto> seriesDatas) {
+		this.seriesDatas = seriesDatas;
+	}
+}

op-modules/op-quality/src/main/java/com/op/quality/domain/QcLineChartSeriesDto.java

@@ -0,0 +1,48 @@
+package com.op.quality.domain;
+
+import java.util.List;
+
+/**
+ * echart图返回数据
+ *
+ * @author Open Platform
+ * @date 2023-07-03
+ */
+public class QcLineChartSeriesDto {
+	private String name;
+	private String type;
+	private String stack;
+	private List<String> data;
+
+	public String getName() {
+		return name;
+	}
+
+	public void setName(String name) {
+		this.name = name;
+	}
+
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+
+	public String getStack() {
+		return stack;
+	}
+
+	public void setStack(String stack) {
+		this.stack = stack;
+	}
+
+	public List<String> getData() {
+		return data;
+	}
+
+	public void setData(List<String> data) {
+		this.data = data;
+	}
+}

op-modules/op-quality/src/main/java/com/op/quality/mapper/QcInterfaceMapper.java

@@ -41,4 +41,8 @@ public interface QcInterfaceMapper {
     Map<String, QcInterface> getMothNoOkNum(QcInterface qcInterface);
 
     List<QcCheckTaskDetail> getReasons(QcInterface dto);
+
+    List<String> getLineChartsNames(QcInterface qcInterface);
+    @MapKey("nameDate")
+    Map<String, QcInterface> getLineChartsDatas(QcInterface qcInterface);
 }

op-modules/op-quality/src/main/java/com/op/quality/service/IQcInterfaceService.java

@@ -3,6 +3,7 @@ package com.op.quality.service;
 
 import com.op.quality.domain.QcCheckType;
 import com.op.quality.domain.QcInterface;
+import com.op.quality.domain.QcLineChartDto;
 
 import java.util.List;
 import java.util.Map;
@@ -35,4 +36,6 @@ public interface IQcInterfaceService {
     QcInterface getLineDayNoOk(QcInterface qcInterface);
 
     List<QcInterface> getMonthOfYearContrast(QcInterface qcInterface);
+
+    QcLineChartDto getLineQcData(QcInterface qcInterface);
 }

op-modules/op-quality/src/main/java/com/op/quality/service/impl/QcCheckTaskIncomeServiceImpl.java

@@ -386,13 +386,16 @@ public class QcCheckTaskIncomeServiceImpl implements IQcCheckTaskIncomeService {
 		qcCheckTask.setCheckResult(result);//检验结果Y合格 N不合格
 		BigDecimal noOkQquality = new BigDecimal("0");
 		if(qcCheckTaskIncome.getaNoOkquality()!=null){
-			noOkQquality.add(qcCheckTaskIncome.getaNoOkquality());
+			noOkQquality = noOkQquality.add(qcCheckTaskIncome.getaNoOkquality());
+			qcCheckTask.setaNoOkquality(qcCheckTaskIncome.getaNoOkquality());
 		}
 		if(qcCheckTaskIncome.getbNoOkquality()!=null){
-			noOkQquality.add(qcCheckTaskIncome.getbNoOkquality());
+			noOkQquality = noOkQquality.add(qcCheckTaskIncome.getbNoOkquality());
+			qcCheckTask.setbNoOkquality(qcCheckTaskIncome.getbNoOkquality());
 		}
 		if(qcCheckTaskIncome.getcNoOkquality()!=null){
-			noOkQquality.add(qcCheckTaskIncome.getcNoOkquality());
+			noOkQquality = noOkQquality.add(qcCheckTaskIncome.getcNoOkquality());
+			qcCheckTask.setcNoOkquality(qcCheckTaskIncome.getcNoOkquality());
 		}
 		if(qcCheckTask.getNoOkQuality()==null){
 			qcCheckTask.setNoOkQuality(noOkQquality);

op-modules/op-quality/src/main/java/com/op/quality/service/impl/QcInterfaceServiceImpl.java

@@ -1,10 +1,9 @@
 package com.op.quality.service.impl;
 
+import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;
 import com.op.common.core.utils.DateUtils;
-import com.op.quality.domain.QcCheckTaskDetail;
-import com.op.quality.domain.QcInterface;
-import com.op.quality.domain.QcProCheck;
+import com.op.quality.domain.*;
 import com.op.quality.mapper.QcInterfaceMapper;
 import com.op.quality.service.IQcInterfaceService;
 import org.apache.commons.lang.StringUtils;
@@ -319,6 +318,53 @@ public class QcInterfaceServiceImpl implements IQcInterfaceService {
 		return dtos;
 	}
 
+	@Override
+	@DS("#header.poolName")
+	public QcLineChartDto getLineQcData(QcInterface qcInterface) {
+		QcLineChartDto lineChartDto = new QcLineChartDto();
+
+		Calendar calendar = Calendar.getInstance();
+		Date now = calendar.getTime();
+		calendar.set(Calendar.DAY_OF_MONTH, 1);
+		Date firstDayOfMonth = calendar.getTime();
+		DateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+		String startTime = dateFormat.format(firstDayOfMonth);
+		String endTime = dateFormat.format(now);
+		qcInterface.setProductDateStart(startTime);
+		qcInterface.setProductDateEnd(endTime);
+		//图例名称
+		List<String> seriesNames = qcInterfaceMapper.getLineChartsNames(qcInterface);
+		lineChartDto.setSeriesNames(seriesNames);
+		//日期名称数组
+		List<String> xAxisDatas = getDays(startTime,endTime);
+		lineChartDto.setxAxisDatas(xAxisDatas);
+		Map<String,QcInterface> productdatas = qcInterfaceMapper.getLineChartsDatas(qcInterface);
+		//值
+		List<QcLineChartSeriesDto> seriesDatas = new ArrayList<>();
+		QcLineChartSeriesDto lineChartSeriesDto = null;
+		for(String productName:seriesNames){
+			lineChartSeriesDto = new QcLineChartSeriesDto();
+			lineChartSeriesDto.setName(productName);
+			lineChartSeriesDto.setType("line");
+			List<String> datas = new ArrayList<>();
+			for(String dayStr:xAxisDatas) {
+				QcInterface data0 = productdatas.get(productName + dayStr);
+				if (data0 != null) {
+					BigDecimal rate = new BigDecimal(data0.getNoOkQuality())
+							.multiply(new BigDecimal(100))
+							.divide(new BigDecimal(data0.getQuality()),2,BigDecimal.ROUND_HALF_UP);
+					datas.add(rate.toString());
+				} else {
+					datas.add("0");
+				}
+			}
+			lineChartSeriesDto.setData(datas);
+			seriesDatas.add(lineChartSeriesDto);
+		}
+		lineChartDto.setSeriesDatas(seriesDatas);
+		return lineChartDto;
+	}
+
 	/**两个日期之间的所有日期**/
 	public static List<String> getDays(String startTime,String endTime) {
 

op-modules/op-quality/src/main/resources/mapper/quality/QcCheckTypeMapper.xml

@@ -48,8 +48,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 			   '检验任务' attr1
 		from qc_check_task qct
 		left join qc_check_type qc on qct.check_type = qc.order_code
-		left join qc_user_material qum on qum.material_code = qct.material_code
-		where qct.check_status = '0' and qum.user_code = #{checkManCode}
+		where qct.check_status = '0' and qct.check_man_code = #{checkManCode}
 		group by qct.check_type,qc.check_name
         union all
 		select '','',
@@ -57,8 +56,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
 			   '不合格处理' attr1
 		from qc_check_unqualified qcu
 	  left join qc_check_task qct on qcu.task_id = qct.record_id
-	  left join qc_user_material qum on qum.material_code = qct.material_code
-		where qcu.status != '2' and qum.user_code = #{checkManCode}
+		where qcu.status != '2' and qct.check_man_code = #{checkManCode}
 	</select>
 	<insert id="insertQcCheckType" parameterType="QcCheckType">
 		insert into qc_check_type

op-modules/op-quality/src/main/resources/mapper/quality/QcInterfaceMapper.xml

@@ -241,4 +241,23 @@
 		where belong_to = #{recordId}
 		  and status = 'N' and del_flag='0'
 	</select>
+    <select id="getLineChartsNames" resultType="java.lang.String">
+		select
+			distinct supplier_name
+		from qc_check_task
+		where type_code = 'produce' and del_flag = '0'
+			and CONVERT(varchar(10),income_time, 120) >= #{productDateStart}
+		  and #{productDateEnd} >= CONVERT(varchar(10),income_time, 120)
+	</select>
+	<select id="getLineChartsDatas" resultType="com.op.quality.domain.QcInterface">
+		select
+			sum(sample_quality) quality,
+			sum(noOk_quality) noOkQuality,
+			concat(supplier_name,CONVERT(varchar(10),income_time, 120)) nameDate
+		from qc_check_task
+		where type_code = 'produce' and del_flag = '0'
+			and CONVERT(varchar(10),income_time, 120) >= #{productDateStart}
+		  and #{productDateEnd} >= CONVERT(varchar(10),income_time, 120)
+		group by supplier_name,CONVERT(varchar(10),income_time, 120)
+	</select>
 </mapper>