同步更新项目经理、供应商名称信息

examcloud-core-print-service/src/main/java/cn/com/qmth/examcloud/core/print/service/PrintingProjectService.java

@@ -22,24 +22,16 @@ public interface PrintingProjectService {
 
     /**
      * 查询印刷项目列表(分页)
-     *
-     * @param query
-     * @return
      */
     Page<PrintingProjectInfo> getPrintingProjectList(PrintingProjectQuery query);
 
     /**
      * 获取某印刷项目的信息
-     *
-     * @param id
-     * @return
      */
     PrintingProjectInfo getPrintingProjectById(Long id);
 
     /**
      * 更新印刷项目信息
-     *
-     * @param info
      */
     void updatePrintingProject(PrintingProjectInfo info);
 
@@ -49,6 +41,16 @@ public interface PrintingProjectService {
      */
     void syncPrintingProject(OrgExamInfo examInfo);
 
+    /**
+     * 同步更新项目经理名称信息
+     */
+    void syncPrintingProjectPmName(Long pmId, String pmName);
+
+    /**
+     * 同步更新供应商名称信息
+     */
+    void syncPrintingProjectSupplierName(Long supplierId, String supplierName);
+
     /**
      * 印刷项目数据初始化
      */

examcloud-core-print-service/src/main/java/cn/com/qmth/examcloud/core/print/service/impl/PrintingProjectServiceImpl.java

@@ -146,12 +146,25 @@ public class PrintingProjectServiceImpl implements PrintingProjectService {
         printingProjectRepository.save(project);
     }
 
+    @Override
+    public void syncPrintingProjectPmName(Long pmId, String pmName) {
+        String updateSql = String.format("UPDATE ec_prt_project SET pm_name = '%s' WHERE pm_id = %s", pmName, pmId);
+        jdbcTemplate.update(updateSql);
+    }
+
+    @Override
+    public void syncPrintingProjectSupplierName(Long supplierId, String supplierName) {
+        String updateSql = String.format("UPDATE ec_prt_project SET supplier_name = '%s' WHERE supplier_id = %s", supplierName, supplierId);
+        jdbcTemplate.update(updateSql);
+    }
+
     @Override
     public void initAllData() {
         //查询所有传统考试记录(实际数据未超过100条)
-        String selectSql = "SELECT em.id as examId,em.name as examName,em.root_org_id as orgId,org.name as orgName FROM ec_e_exam em "
-                + "INNER JOIN ec_b_org org ON org.id = em.root_org_id WHERE em.exam_type = 'TRADITION' ORDER BY em.id ASC";
-        List<OrgExamInfo> list = jdbcTemplate.query(selectSql, new BeanPropertyRowMapper(OrgExamInfo.class));
+        StringBuilder sql = new StringBuilder()
+                .append("SELECT em.id as examId,em.name as examName,em.root_org_id as orgId,org.name as orgName FROM ec_e_exam em ")
+                .append("INNER JOIN ec_b_org org ON org.id = em.root_org_id WHERE em.exam_type = 'TRADITION' ORDER BY em.id ASC");
+        List<OrgExamInfo> list = jdbcTemplate.query(sql.toString(), new BeanPropertyRowMapper(OrgExamInfo.class));
 
         //批量保存数据
         String insertSql = "INSERT INTO ec_prt_project(exam_id,exam_name,org_id,org_name,completed,creation_time,update_time) VALUES (?,?,?,?,?,NOW(),NOW())";

examcloud-core-print-starter/src/test/java/cn/com/qmth/examcloud/core/print/test/PrintingProjectServiceTest.java

@@ -78,6 +78,8 @@ public class PrintingProjectServiceTest {
     public void syncPrintingProjectTest() throws Exception {
         OrgExamInfo examInfo = new OrgExamInfo(1L, "武汉大学", 1L, "计算机考试");
         printingProjectService.syncPrintingProject(examInfo);
+        printingProjectService.syncPrintingProjectPmName(1L, "雷布斯");
+        printingProjectService.syncPrintingProjectSupplierName(1L, "小米公司");
     }
 
     //@Test