Преглед на файлове

Merge remote-tracking branch 'origin/master'

my-csc-config-file.git преди 4 години
родител
ревизия
593c0062c3

+ 1 - 1
src/main/java/com/unissoft/equipmentStroe/controller/EquipmentStroeController.java

@@ -29,7 +29,7 @@ public class EquipmentStroeController {
29 29
 
30 30
     @ApiOperation(value = "分页条件查询",
31 31
             notes = "提交参数:{\"pageIndex\":1,\"pageSize\":10,\"," +
32
-                    "\"condition\":\"{'table_name':'grain_condition_record'," +
32
+                    "\"condition\":\"{'table_name':'equipment_stroe'," +
33 33
                     "'field_name':'check_list'\"}")
34 34
     @PostMapping("/authority/getPage")
35 35
     public ResultView getPage(@RequestBody PageParam pageParam) {

+ 4 - 0
src/main/java/com/unissoft/equipmentStroe/service/impl/EquipmentStroeServiceImpl.java

@@ -40,6 +40,7 @@ public class EquipmentStroeServiceImpl extends ServiceImpl<EquipmentStroeMapper,
40 40
             String equipmentNameCode = object.optString("equipment_name_code").trim();
41 41
             String standardsType = object.optString("standards_type").trim();
42 42
             String arrivalTime = object.optString("arrival_time").trim();
43
+            String state = object.optString("state").trim();
43 44
             if (!StringUtils.isEmpty(depotId)) {
44 45
                 ew.eq("depot_id", depotId);
45 46
             }
@@ -55,6 +56,9 @@ public class EquipmentStroeServiceImpl extends ServiceImpl<EquipmentStroeMapper,
55 56
             if (!StringUtils.isEmpty(standardsType)) {
56 57
                 ew.eq("standards_type", standardsType);
57 58
             }
59
+            if (!StringUtils.isEmpty(state)) {
60
+                ew.eq("state", state);
61
+            }
58 62
         }
59 63
         ew.orderByDesc("arrival_time");
60 64
         Page page = new Page();

+ 3 - 3
src/main/java/com/unissoft/mapper/EquipmentStroeMapper.java

@@ -5,11 +5,11 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5 5
 
6 6
 /**
7 7
  * <p>
8
- *  Mapper 接口
8
+ * 器材库 Mapper 接口
9 9
  * </p>
10 10
  *
11
- * @author root
12
- * @since 2020-12-15
11
+ * @author My sunShine
12
+ * @since 2021-04-15
13 13
  */
14 14
 public interface EquipmentStroeMapper extends BaseMapper<EquipmentStroe> {
15 15
 

+ 3 - 1
src/main/java/com/unissoft/mapper/EquipmentStroeMapper.xml

@@ -18,11 +18,13 @@
18 18
         <result column="management" property="management" />
19 19
         <result column="leave_time" property="leaveTime" />
20 20
         <result column="enterprise_name" property="enterpriseName" />
21
+        <result column="registrant" property="registrant" />
22
+        <result column="state" property="state" />
21 23
     </resultMap>
22 24
 
23 25
     <!-- 通用查询结果列 -->
24 26
     <sql id="Base_Column_List">
25
-        id, depot_id, equipment_category, equipment_category_name, equipment_name_code, equipment_name, standards_type, manufacturer, asset_number, equipment_number, arrival_time, management, leave_time, enterprise_name
27
+        id, depot_id, equipment_category, equipment_category_name, equipment_name_code, equipment_name, standards_type, manufacturer, asset_number, equipment_number, arrival_time, management, leave_time, enterprise_name, registrant, state
26 28
     </sql>
27 29
 
28 30
 </mapper>

+ 3 - 3
src/main/java/com/unissoft/mapper/ProcessAuditMapper.java

@@ -12,11 +12,11 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
12 12
  * </p>
13 13
  *
14 14
  * @author My sunShine
15
- * @since 2021-04-06
15
+ * @since 2021-04-15
16 16
  */
17 17
 public interface ProcessAuditMapper extends BaseMapper<ProcessAudit> {
18 18
 
19
-	 List<ProcessAudit> getToBeDone(List<Integer> list);
19
+	List<ProcessAudit> getToBeDone(List<Integer> list);
20 20
 
21
-	 List<ProcessAudit> getCurrentMonthData();
21
+	List<ProcessAudit> getCurrentMonthData();
22 22
 }

+ 5 - 2
src/main/java/com/unissoft/mapper/ProcessAuditMapper.xml

@@ -26,14 +26,17 @@
26 26
         <result column="start_date" property="startDate" />
27 27
         <result column="end_date" property="endDate" />
28 28
         <result column="to_page" property="toPage" />
29
+        <result column="equipment_name_code" property="equipmentNameCode" />
30
+        <result column="equipment_id" property="equipmentId" />
29 31
     </resultMap>
30 32
 
31 33
     <!-- 通用查询结果列 -->
32 34
     <sql id="Base_Column_List">
33
-        id, main_id, sub_id, sub_data, audit_state, operation_time, type, house_id, depot_id, from_people, to_people, result, apply_people, audit_time, process_id, ongoing_step, is_audit, apply_time, work_name, start_date, end_date, to_page
35
+        id, main_id, sub_id, sub_data, audit_state, operation_time, type, house_id, depot_id, from_people, to_people, result, apply_people, audit_time, process_id, ongoing_step, is_audit, apply_time, work_name, start_date, end_date, to_page, equipment_name_code, equipment_id
34 36
     </sql>
35 37
     
36
-     <select id="getToBeDone" parameterType="list" resultType="com.unissoft.model.ProcessAudit">
38
+    
39
+    <select id="getToBeDone" parameterType="list" resultType="com.unissoft.model.ProcessAudit">
37 40
         select
38 41
         <include refid="Base_Column_List"/>
39 42
         from process_audit pa

+ 7 - 1
src/main/java/com/unissoft/model/EnumProcessModel.java

@@ -9,7 +9,13 @@ public enum EnumProcessModel {
9 9
 	xzjh("熏蒸计划申请"),
10 10
 	sswxjh("设施维修计划"),
11 11
 	sswxys("设施维修预算"),
12
-	sbcg("设备采购");
12
+	sbcg("设备采购"),
13
+	sbwx("设备维修"),
14
+	sbly("设备领用申请"),
15
+	sbgh("设备资产转移申请"),
16
+	sbbf("设备报废"),
17
+	sbtz("设备台账"),
18
+	sbdwgl("设备定位管理");
13 19
 	
14 20
 	private String name;
15 21
 

+ 16 - 13
src/main/java/com/unissoft/model/EquipmentStroe.java

@@ -1,25 +1,24 @@
1 1
 package com.unissoft.model;
2 2
 
3
-import com.baomidou.mybatisplus.annotation.IdType;
4
-import com.baomidou.mybatisplus.annotation.TableField;
5
-import com.baomidou.mybatisplus.annotation.TableId;
6 3
 import com.baomidou.mybatisplus.annotation.TableName;
7 4
 import com.fasterxml.jackson.annotation.JsonFormat;
5
+import com.baomidou.mybatisplus.annotation.IdType;
6
+import java.util.Date;
7
+import com.baomidou.mybatisplus.annotation.TableId;
8
+import com.baomidou.mybatisplus.annotation.TableField;
9
+import java.io.Serializable;
8 10
 import io.swagger.annotations.ApiModel;
9 11
 import io.swagger.annotations.ApiModelProperty;
10 12
 import lombok.Data;
11 13
 import lombok.EqualsAndHashCode;
12 14
 
13
-import java.io.Serializable;
14
-import java.util.Date;
15
-
16 15
 /**
17 16
  * <p>
18
- * 
17
+ * 器材库
19 18
  * </p>
20 19
  *
21
- * @author root
22
- * @since 2020-12-15
20
+ * @author My sunShine
21
+ * @since 2021-04-15
23 22
  */
24 23
 @Data
25 24
 @EqualsAndHashCode(callSuper = false)
@@ -29,7 +28,7 @@ public class EquipmentStroe implements Serializable {
29 28
 
30 29
     private static final long serialVersionUID = 1L;
31 30
 
32
-    @ApiModelProperty(value = "主键")
31
+    @ApiModelProperty(value = "器材库id")
33 32
     @TableId(value = "id", type = IdType.AUTO)
34 33
     private Integer id;
35 34
 
@@ -37,7 +36,7 @@ public class EquipmentStroe implements Serializable {
37 36
     @TableField("depot_id")
38 37
     private Integer depotId;
39 38
 
40
-    @ApiModelProperty(value = "设备类别code")
39
+    @ApiModelProperty(value = "设备类别")
41 40
     @TableField("equipment_category")
42 41
     private String equipmentCategory;
43 42
 
@@ -71,7 +70,6 @@ public class EquipmentStroe implements Serializable {
71 70
 
72 71
     @ApiModelProperty(value = "到库时间")
73 72
     @TableField("arrival_time")
74
-//    @DateTimeFormat(pattern = "yyyy-MM-dd")
75 73
     @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd", timezone = "GMT+8")
76 74
     private Date arrivalTime;
77 75
 
@@ -90,6 +88,11 @@ public class EquipmentStroe implements Serializable {
90 88
 
91 89
     @ApiModelProperty(value = "登记人")
92 90
     @TableField("registrant")
93
-    private String egistrant;
91
+    private String registrant;
92
+
93
+    @ApiModelProperty(value = "该设备的状态(0:正常使用1:维修2:报废)")
94
+    @TableField("state")
95
+    private Integer state;
96
+
94 97
 
95 98
 }

+ 27 - 6
src/main/java/com/unissoft/model/ProcessAudit.java

@@ -18,7 +18,7 @@ import lombok.EqualsAndHashCode;
18 18
  * </p>
19 19
  *
20 20
  * @author My sunShine
21
- * @since 2021-04-06
21
+ * @since 2021-04-15
22 22
  */
23 23
 @Data
24 24
 @EqualsAndHashCode(callSuper = false)
@@ -151,21 +151,28 @@ public class ProcessAudit implements Serializable {
151 151
     @TableField("work_name")
152 152
     private String workName;
153 153
 
154
-    
155 154
     @ApiModelProperty(value = "办理开始时间")
156
-    @JsonFormat(shape=JsonFormat.Shape.STRING,pattern="yyyy-MM-dd HH:mm",timezone="GMT+8")
157 155
     @TableField("start_date")
156
+    @JsonFormat(shape=JsonFormat.Shape.STRING,pattern="yyyy-MM-dd HH:mm",timezone="GMT+8")
158 157
     private Date startDate;
159 158
 
160 159
     @ApiModelProperty(value = "办理结束时间")
161
-    @JsonFormat(shape=JsonFormat.Shape.STRING,pattern="yyyy-MM-dd HH:mm",timezone="GMT+8")
162 160
     @TableField("end_date")
161
+    @JsonFormat(shape=JsonFormat.Shape.STRING,pattern="yyyy-MM-dd HH:mm",timezone="GMT+8")
163 162
     private Date endDate;
164 163
 
165 164
     @ApiModelProperty(value = "办理页面url")
166 165
     @TableField("to_page")
167 166
     private String toPage;
168 167
 
168
+    @ApiModelProperty(value = "设备名称code")
169
+    @TableField("equipment_name_code")
170
+    private String equipmentNameCode;
171
+
172
+    @ApiModelProperty(value = "器材库的id")
173
+    @TableField("equipment_id")
174
+    private Integer equipmentId;
175
+
169 176
 
170 177
 
171 178
 
@@ -345,8 +352,22 @@ public class ProcessAudit implements Serializable {
345 352
 	public void setToPage(String toPage) {
346 353
 		this.toPage = toPage;
347 354
 	}
348
-    
349
-    
355
+
356
+	public String getEquipmentNameCode() {
357
+		return equipmentNameCode;
358
+	}
359
+
360
+	public void setEquipmentNameCode(String equipmentNameCode) {
361
+		this.equipmentNameCode = equipmentNameCode;
362
+	}
363
+
364
+	public Integer getEquipmentId() {
365
+		return equipmentId;
366
+	}
367
+
368
+	public void setEquipmentId(Integer equipmentId) {
369
+		this.equipmentId = equipmentId;
370
+	}
350 371
 
351 372
 
352 373
 }

+ 3 - 3
src/main/java/com/unissoft/ventilation/controller/ProcessAuditController.java

@@ -51,7 +51,7 @@ public class ProcessAuditController {
51 51
 	/**
52 52
 	 * 机械通风列表
53 53
 	 */
54
-    @ApiOperation(value = "分页条件查询", notes = "提交参数(type、houseId、depotId必填,没有houseId的就不填):{\"pageIndex\":1,\"pageSize\":10,  \"condition\":\"{\'type\':\'\',\'depotId\':\'\',\'houseId\':\'\',\'startTime\':\'\',\'endTime\':\'\'}\"}")
54
+    @ApiOperation(value = "分页条件查询", notes = "提交参数(type、houseId、depotId必填,没有houseId的就不填):{\"pageIndex\":1,\"pageSize\":10,  \"condition\":\"{\'equipmentId\':\'\',\'type\':\'\',\'depotId\':\'\',\'houseId\':\'\',\'startTime\':\'\',\'endTime\':\'\'}\"}")
55 55
     @PostMapping("/getPage")
56 56
     public ResultView getPage(@RequestBody PageParam pageParam) throws Exception{
57 57
     	Page<ProcessAudit> page = processAuditService.getPage(pageParam);
@@ -63,12 +63,12 @@ public class ProcessAuditController {
63 63
      * @param id
64 64
      * @return
65 65
      */
66
-    @ApiOperation(value = "根据id和审批状态查询", notes = "")
66
+    /*@ApiOperation(value = "根据id和审批状态查询", notes = "")
67 67
     @GetMapping("/getById/{id}")
68 68
     public ResultView getById(@PathVariable Integer id) {
69 69
     	List<Map<String,Object>> list = processAuditService.getAllById(id);
70 70
         return ResultView.success(list);
71
-    }
71
+    }*/
72 72
     
73 73
     
74 74
     /**

+ 31 - 1
src/main/java/com/unissoft/ventilation/controller/ProcessMainController.java

@@ -1,6 +1,8 @@
1 1
 package com.unissoft.ventilation.controller;
2 2
 
3 3
 
4
+import java.util.ArrayList;
5
+import java.util.HashMap;
4 6
 import java.util.List;
5 7
 import java.util.Map;
6 8
 
@@ -11,6 +13,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
11 13
 
12 14
 import org.springframework.web.bind.annotation.RestController;
13 15
 
16
+import com.unissoft.model.ProcessSub;
14 17
 import com.unissoft.result.ResultView;
15 18
 import com.unissoft.ventilation.service.ProcessMainService;
16 19
 
@@ -35,7 +38,7 @@ public class ProcessMainController {
35 38
 	
36 39
 	
37 40
 	/**
38
-	 * 获取所有主流程和子流程的数据
41
+	 * 获取所有主流程和子流程的数据   (新增时)
39 42
 	 * @param parameter
40 43
 	 * @return
41 44
 	 */
@@ -46,4 +49,31 @@ public class ProcessMainController {
46 49
         return ResultView.success(list);
47 50
     }
48 51
 	
52
+	
53
+	public static void main(String[] args) {
54
+		List<ProcessSub> list = new ArrayList<ProcessSub>();
55
+		ProcessSub ProcessSub = new ProcessSub();
56
+		ProcessSub.setAuditId(1111);
57
+		ProcessSub.setTitle("测试1");
58
+		ProcessSub ProcessSub1 = new ProcessSub();
59
+		ProcessSub1.setAuditId(2222);
60
+		ProcessSub1.setTitle("测试2");
61
+		list.add(ProcessSub1);
62
+		list.add(ProcessSub);
63
+		list.forEach(obj -> System.out.println(obj.getTitle()));
64
+		
65
+		
66
+		/*List<String> books = new ArrayList<String>(3);
67
+        books.add("TEST1");
68
+        books.add("TEST2");
69
+        books.forEach(obj -> System.out.println(obj));*/
70
+        
71
+        Map maps = new HashMap();
72
+        maps.put(1, "test1");
73
+        maps.put(2, "test2");
74
+       // maps.forEach((k, v) -> System.out.println("Key : " + k + " Value : " + v));
75
+        maps.forEach((k,v)-> System.out.println("key:"+k+"value:"+v));
76
+
77
+	}
78
+	
49 79
 }

+ 1 - 1
src/main/java/com/unissoft/ventilation/service/ProcessAuditService.java

@@ -26,7 +26,7 @@ public interface ProcessAuditService extends IService<ProcessAudit> {
26 26
 
27 27
 	Page<ProcessAudit> getPage(PageParam pageParam)throws Exception;
28 28
 
29
-	List<Map<String, Object>> getAllById(Integer id);
29
+	//List<Map<String, Object>> getAllById(Integer id);
30 30
 
31 31
 	void deleteById(Integer id);
32 32
 

+ 330 - 156
src/main/java/com/unissoft/ventilation/service/impl/ProcessAuditServiceImpl.java

@@ -11,6 +11,7 @@ import com.unissoft.dto.ProcessToBeDone;
11 11
 import com.unissoft.dto.SendNoticeVO;
12 12
 import com.unissoft.dto.SysNoticeVO;
13 13
 import com.unissoft.dto.ToBeDoneCallbackVO;
14
+import com.unissoft.equipmentStroe.service.EquipmentStroeService;
14 15
 import com.unissoft.feign.MessageFeign;
15 16
 import com.unissoft.feign.SystemFeign;
16 17
 import com.unissoft.mapper.*;
@@ -69,6 +70,9 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
69 70
 
70 71
     @Autowired
71 72
     private RestTemplate restTemplate;
73
+    
74
+    @Autowired
75
+    private EquipmentStroeService quipmentStroeServicee;
72 76
 
73 77
 
74 78
     @Override
@@ -83,6 +87,8 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
83 87
         Integer fromPeople = jsStr.optInt("fromPeople");//提交人id
84 88
         String applyTime = jsStr.optString("applyTime");//申请时间
85 89
         Integer isAudit = jsStr.optInt("isAudit");//是否提交给总经理和分公司审批
90
+        String equipmentNameCode = jsStr.optString("equipmentNameCode");//设备名称code
91
+        Integer equipmentId = jsStr.optInt("equipmentId");//器材库的id
86 92
         //获取审批人
87 93
         List<ProcessBasis> pbList = processBasisService.getBasisByType(type, null, depotId);
88 94
         Integer toPeople = pbList.get(1).getContent();
@@ -130,7 +136,16 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
130 136
             	processAudit.setWorkName(EnumProcessModel.sswxys.getName());
131 137
             }else if(type.equals("sbcg")){
132 138
             	processAudit.setWorkName(EnumProcessModel.sbcg.getName());
139
+            }else if(type.equals("sbwx")){
140
+            	processAudit.setWorkName(EnumProcessModel.sbwx.getName());
141
+            }else if(type.equals("sbly")){
142
+            	processAudit.setWorkName(EnumProcessModel.sbly.getName());
143
+            }else if(type.equals("sbgh")){
144
+            	processAudit.setWorkName(EnumProcessModel.sbgh.getName());
145
+            }else if(type.equals("sbbf")){
146
+            	processAudit.setWorkName(EnumProcessModel.sbbf.getName());
133 147
             }
148
+            
134 149
 
135 150
             if(i == 0 ){
136 151
             	processAudit.setFromPeople(fromPeople);
@@ -138,6 +153,12 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
138 153
                 if(houseId != 0 && houseId != null){
139 154
                 	processAudit.setHouseId(houseId);
140 155
                 }
156
+                if(equipmentNameCode !=null && equipmentNameCode != ""){
157
+                	processAudit.setEquipmentNameCode(equipmentNameCode);
158
+                }
159
+                if(equipmentId != 0 && equipmentId != null){
160
+                	processAudit.setEquipmentId(equipmentId);
161
+                }
141 162
                 processAudit.setDepotId(depotId);
142 163
                 processAudit.setApplyPeople(applyPeople);
143 164
                 processAudit.setApplyTime(applyTime);
@@ -161,6 +182,19 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
161 182
                 processAudit.setProcessId(uuId); //多条数据时,流程标识取第一条的
162 183
             }
163 184
             processAuditMapper.insert(processAudit);
185
+            if(type.equals("sbwx") || type.equals("sbbf") || type.equals("sbly") || type.equals("sbgh")){
186
+            	//修改器材库的状态
187
+            	EquipmentStroe entity = new EquipmentStroe();
188
+            	entity.setId(equipmentId);
189
+            	if(type.equals("sbwx")){
190
+            		entity.setState(1);
191
+            	}else if(type.equals("sbbf")){
192
+            		entity.setState(2);
193
+            	}else{
194
+            		entity.setState(0);
195
+            	}
196
+            	quipmentStroeServicee.updateById(entity);
197
+            }
164 198
         }
165 199
         
166 200
         /*
@@ -196,6 +230,18 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
196 230
         }else if(type.equals("sbcg")){
197 231
         	sysNoticeVO.setTitle(EnumProcessModel.sbcg.getName());
198 232
         	sysNoticeVO.setNoticeModule("sbcg");
233
+        }else if(type.equals("sbwx")){
234
+        	sysNoticeVO.setTitle(EnumProcessModel.sbwx.getName());
235
+        	sysNoticeVO.setNoticeModule("sbwx");
236
+        }else if(type.equals("sbly")){
237
+        	sysNoticeVO.setTitle(EnumProcessModel.sbly.getName());
238
+        	sysNoticeVO.setNoticeModule("sbly");
239
+        }else if(type.equals("sbgh")){
240
+        	sysNoticeVO.setTitle(EnumProcessModel.sbgh.getName());
241
+        	sysNoticeVO.setNoticeModule("sbgh");
242
+        }else if(type.equals("sbbf")){
243
+        	sysNoticeVO.setTitle(EnumProcessModel.sbbf.getName());
244
+        	sysNoticeVO.setNoticeModule("sbbf");
199 245
         }
200 246
         
201 247
         //根据仓房id获取仓房名称
@@ -250,40 +296,51 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
250 296
         
251 297
         if (!StringUtils.isEmpty(pageParam.getCondition())) {
252 298
             org.json.JSONObject object = new org.json.JSONObject(pageParam.getCondition());
253
-            if (StringUtils.isNotBlank(object.optString("type"))) {
254
-            	if(object.optString("type").equals("xz") || object.optString("type").equals("sswx")){
255
-            		ew.like("type",object.optString("type"));
256
-            		ew.eq("result", 1);//取第一条数据
257
-            	}else{
258
-            		ew.eq("type", object.optString("type"));
259
-                    if(object.optString("type").equals("yjbg")){//药剂保管
260
-                    	ew.eq("result", 2);//药剂保管d第一条数据
261
-                    }else{
262
-                    	ew.eq("result", 1);//取第一条数据
263
-                    }
264
-            	}
265
-            	
299
+            Integer equipmentId = object.optInt("equipmentId");
300
+            String startTime = object.optString("startTime");
301
+            String endTime = object.optString("endTime");
302
+            String type = object.optString("type");
303
+            String houseId = object.optString("houseId");
304
+            String depotId = object.optString("depotId");
305
+            
306
+            if("" != equipmentId+"" && equipmentId != 0){
307
+            	//ew.eq("equipment_id", equipmentId);
308
+            	ew.and(x -> x.eq("equipment_id", equipmentId).eq("result", 1).or().eq("equipment_id", equipmentId).eq("result", 2));
266 309
             }else{
267
-            	ew.eq("result", 1);//取第一条数据
310
+            	if (StringUtils.isNotBlank(type)) {
311
+                	if(type.equals("xz") || type.equals("sswx") || type.equals("sbly")){
312
+                		ew.like("type",type);
313
+                		ew.eq("result", 1);//取第一条数据
314
+                	}else{
315
+                		ew.eq("type", type);
316
+                        if(type.equals("yjbg")){//药剂保管
317
+                        	ew.eq("result", 2);//药剂保管d第一条数据
318
+                        }else{
319
+                        	ew.eq("result", 1);//取第一条数据
320
+                        }
321
+                	}
322
+                	
323
+                }else{
324
+                	ew.eq("result", 1);//取第一条数据
325
+                }
268 326
             }
269
-            if (StringUtils.isNotBlank(object.optString("houseId"))) {
270
-                ew.eq("house_id", object.optString("houseId"));
327
+            
328
+            if (StringUtils.isNotBlank(houseId)) {
329
+                ew.eq("house_id", houseId);
271 330
             }
272
-            if (StringUtils.isNotBlank(object.optString("depotId"))) {
273
-                ew.eq("depot_id", object.optString("depotId"));
331
+            if (StringUtils.isNotBlank(depotId)) {
332
+                ew.eq("depot_id", depotId);
274 333
             }
275 334
 
276
-            if (StringUtils.isNotBlank(object.optString("startTime")) || StringUtils.isNotBlank(object.optString("endTime"))) {
277
-                if (StringUtils.isNotBlank(object.optString("startTime")) && StringUtils.isNotBlank(object.optString("endTime")) &&
278
-                        object.optString("startTime").equals(object.optString("endTime"))) {
279
-                    ew.apply("date_format(apply_time,'%Y-%m-%d')='" + object.optString("startTime") + "'");
335
+            if (StringUtils.isNotBlank(startTime) || StringUtils.isNotBlank(endTime)) {
336
+                if (StringUtils.isNotBlank(startTime) && StringUtils.isNotBlank(endTime) &&
337
+                        startTime.equals(endTime)) {
338
+                    ew.apply("date_format(apply_time,'%Y-%m-%d')='" + startTime + "'");
280 339
                 } else {
281
-                    ew.between("apply_time", object.optString("startTime"), object.optString("endTime"));
340
+                    ew.between("apply_time", startTime, endTime);
282 341
                 }
283
-
284 342
             }
285 343
 
286
-
287 344
         }
288 345
 
289 346
         ew.orderByDesc("id");
@@ -298,7 +355,7 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
298 355
 
299 356
 
300 357
     //noUse
301
-    @Override
358
+/*@Override
302 359
     public List<Map<String, Object>> getAllById(Integer id) {
303 360
         // TODO Auto-generated method stub
304 361
         List<Map<String, Object>> list1 = new ArrayList<>();
@@ -339,7 +396,7 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
339 396
         }
340 397
 
341 398
         return list1;
342
-    }
399
+    }*/
343 400
 
344 401
 
345 402
     /**
@@ -364,9 +421,10 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
364 421
 
365 422
 
366 423
         org.json.JSONObject object = new org.json.JSONObject(pageParam.getCondition());
424
+        Integer userId = object.getInt("userId");
367 425
         QueryWrapper<ProcessAudit> ew = new QueryWrapper<>();
368
-        if (StringUtils.isNotBlank(object.optString("userId"))) {
369
-            ew.eq("to_people", object.getInt("userId"));
426
+        if (StringUtils.isNotBlank(userId+"")) {
427
+            ew.eq("to_people", userId);
370 428
             ew.eq("audit_state", 0);//已提交
371 429
             //ew.and(x->x.eq("audit_state", 0).or().isNull("audit_state"));
372 430
         }
@@ -458,6 +516,18 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
458 516
          }else if(processAudit.getType().equals("sbcg")){
459 517
         	 sysNoticeVO.setTitle(EnumProcessModel.sbcg.getName());
460 518
           	 sysNoticeVO.setNoticeModule("sbcg");
519
+         }else if(processAudit.getType().equals("sbwx")){
520
+        	 sysNoticeVO.setTitle(EnumProcessModel.sbwx.getName());
521
+          	 sysNoticeVO.setNoticeModule("sbwx");
522
+         }else if(processAudit.getType().equals("sbly")){
523
+        	 sysNoticeVO.setTitle(EnumProcessModel.sbly.getName());
524
+          	 sysNoticeVO.setNoticeModule("sbly");
525
+         }else if(processAudit.getType().equals("sbgh")){
526
+        	 sysNoticeVO.setTitle(EnumProcessModel.sbgh.getName());
527
+          	 sysNoticeVO.setNoticeModule("sbgh");
528
+         }else if(processAudit.getType().equals("sbbf")){
529
+        	 sysNoticeVO.setTitle(EnumProcessModel.sbbf.getName());
530
+          	 sysNoticeVO.setNoticeModule("sbbf");
461 531
          }
462 532
          //根据仓房id获取仓房名称
463 533
          String houseName = "";
@@ -492,81 +562,110 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
492 562
          if (processAudit.getResult().equals(1) && processAudit.getAuditState().equals(0)) { //审批状态 是0 而且是第一条数据  就是第一次审批
493 563
              //第一个人审批
494 564
 
495
-             //获取审批人
496
-             QueryWrapper<ProcessBasis> ew = new QueryWrapper<>();
497
-             ew.eq("type", processAudit.getType());
498
-             List<ProcessBasis> list = processBasisMapper.selectList(ew);
499
-             List<Integer> idList = new ArrayList<>();
500
-             for (ProcessBasis processBasis : list) {
501
-                 idList.add(processBasis.getId());
502
-             }
503
-             QueryWrapper<ProcessBasisSon> ew1 = new QueryWrapper<>();
504
-             ew1.eq("depot_id", processAudit.getDepotId());
505
-             ew1.in("zid", idList);
506
-             List<ProcessBasisSon> sonList = processBasisSonMapper.selectList(ew1);
507
-             Integer toPeople = 0;
508
-             for (int i = 0; i < sonList.size(); i++) {
509
-                 if (sonList.get(i).getContent().equals(processAudit.getToPeople())) {
510
-                     toPeople = sonList.get(i + 1).getContent();//下一个审批人的id
511
-                     break;
512
-                 }
513
-             }
514
-
515
-             processAudit.setAuditState(auditState);
516
-             processAudit.setAuditTime(auditTime);
517
-             processAuditMapper.updateById(processAudit); //更改此条数据的审批状态
518
-             if (auditState.equals(1)) {//1审批通过:,2:审批不通过
519
-                 ProcessAudit processAudit1 = new ProcessAudit();
520
-                 processAudit1.setMainId(processAudit.getMainId());
521
-                 //processAudit1.setAuditState(auditState);
522
-                 //processAudit1.setOperationTime(processAudit.getOperationTime());
523
-                 processAudit1.setType(processAudit.getType());
524
-                 processAudit1.setHouseId(processAudit.getHouseId());
525
-                 processAudit1.setDepotId(processAudit.getDepotId());
526
-                 processAudit1.setFromPeople(processAudit.getToPeople());//当前审批人是下一个审批的提交人
527
-                 processAudit1.setToPeople(toPeople);
528
-                 processAudit1.setResult(0);
529
-                 processAudit1.setAuditState(0);//已提交待审批
530
-                 processAudit1.setApplyPeople(processAudit.getApplyPeople());
531
-                 processAudit1.setProcessId(processAudit.getProcessId());
532
-                 processAudit1.setApplyTime(processAudit.getApplyTime());
533
-                 processAudit1.setOngoingStep(ongoingStep);
534
-                 if (processAudit.getType().equals("tf")) {
535
-                     processAudit1.setWorkName(EnumProcessModel.tf.getName());
536
-                 }else if(processAudit.getType().equals("yjcg")){
537
-                	 processAudit1.setWorkName(EnumProcessModel.yjcg.getName());
538
-                 }else if(processAudit.getType().equals("yjly")){
539
-                	 processAudit1.setWorkName(EnumProcessModel.yjly.getName());
540
-                 }else if(processAudit.getType().equals("xzsq")){
541
-                	 processAudit1.setWorkName(EnumProcessModel.xzsq.getName());
542
-                 }else if(processAudit.getType().equals("xzjh")){
543
-                	 processAudit1.setWorkName(EnumProcessModel.xzjh.getName());
544
-                 }else if(processAudit.getType().equals("sswxjh")){
545
-                	 processAudit1.setWorkName(EnumProcessModel.sswxjh.getName());
546
-                 }else if(processAudit.getType().equals("sswxys")){
547
-                	 processAudit1.setWorkName(EnumProcessModel.sswxys.getName());
548
-                 }else if(processAudit.getType().equals("sbcg")){
549
-                	 processAudit1.setWorkName(EnumProcessModel.sbcg.getName());
550
-                 }
551
-                 processAuditMapper.insert(processAudit1);
565
+        	 if(processAudit.getType().equals("sbly")){//设备领用 只有一级审批
566
+        		 processAudit.setAuditState(auditState);
567
+                 processAudit.setAuditTime(auditTime);
568
+                 processAudit.setOngoingStep(ongoingStep);
569
+                 processAuditMapper.updateById(processAudit); //更改此条数据的审批状态
552 570
                  
553 571
                  /**
554
-                  *  发送通知数据给下一审批
572
+                  * 发送通知数据给申请人
555 573
                   */
556
-                 sysNoticeVO.setContent(userInfo.getDepotName()+"-"+houseName+"-"+"待审批");
557
-                 sysNoticeVO.setNoticeType(InformModel.TONGGUO.getcode());//申请的时候推送  通知类型:10系统、20待办、30审批通过、40审批不通过、50警告
558
-                //获取下一审批人的信息
559
-                 ResponseEntity<String> userInfos1 = restTemplate.getForEntity(MyConstant.SYSTEM_USER + toPeople, String.class);
560
-                 if(null != userInfos1 && null != userInfos1.getBody()){
561
-                	 com.alibaba.fastjson.JSONObject jsonObjectuser1 = JSON.parseObject(userInfos1.getBody());
562
-                     SysUserPO userInfo1 = com.alibaba.fastjson.JSONObject.toJavaObject(jsonObjectuser1, SysUserPO.class);
563
-                     users.put(toPeople, userInfo1.getuName());
574
+
575
+                 if((int) auditState >= 3 || (int) auditState ==1){
576
+                 	sysNoticeVO.setNoticeType(InformModel.TONGGUO.getcode());//申请的时候推送  通知类型:10系统、20待办、30审批通过、40审批不通过、50警告
577
+                 	sysNoticeVO.setContent(userInfo.getDepotName()+"-"+houseName+"-"+"审批通过");
578
+                 }else if((int) auditState == 2){
579
+                 	sysNoticeVO.setNoticeType(InformModel.BUTONGGUO.getcode());//申请的时候推送  通知类型:10系统、20待办、30审批通过、40审批不通过、50警告
580
+                 	sysNoticeVO.setContent(userInfo.getDepotName()+"-"+houseName+"-"+"审批不通过");
564 581
                  }
565
-             }else{//不通过 发送数据给申请人
566
-             	 sysNoticeVO.setContent(userInfo.getDepotName()+"-"+houseName+"-"+"审批不通过");
567
-                 sysNoticeVO.setNoticeType(InformModel.BUTONGGUO.getcode());//申请的时候推送  通知类型:10系统、20待办、30审批通过、40审批不通过、50警告
568 582
                  users.put(processAudit.getApplyPeople(), userInfo.getuName());
569
-             }
583
+                 
584
+        	 }else{
585
+        		//获取审批人
586
+                 QueryWrapper<ProcessBasis> ew = new QueryWrapper<>();
587
+                 ew.eq("type", processAudit.getType());
588
+                 List<ProcessBasis> list = processBasisMapper.selectList(ew);
589
+                 List<Integer> idList = new ArrayList<>();
590
+                 for (ProcessBasis processBasis : list) {
591
+                     idList.add(processBasis.getId());
592
+                 }
593
+                 QueryWrapper<ProcessBasisSon> ew1 = new QueryWrapper<>();
594
+                 ew1.eq("depot_id", processAudit.getDepotId());
595
+                 ew1.in("zid", idList);
596
+                 List<ProcessBasisSon> sonList = processBasisSonMapper.selectList(ew1);
597
+                 Integer toPeople = 0;
598
+                 for (int i = 0; i < sonList.size(); i++) {
599
+                     if (sonList.get(i).getContent().equals(processAudit.getToPeople())) {
600
+                         toPeople = sonList.get(i + 1).getContent();//下一个审批人的id
601
+                         break;
602
+                     }
603
+                 }
604
+
605
+                 processAudit.setAuditState(auditState);
606
+                 processAudit.setAuditTime(auditTime);
607
+                 processAuditMapper.updateById(processAudit); //更改此条数据的审批状态
608
+                 if (auditState.equals(1)) {//1审批通过:,2:审批不通过
609
+                     ProcessAudit processAudit1 = new ProcessAudit();
610
+                     processAudit1.setMainId(processAudit.getMainId());
611
+                     //processAudit1.setAuditState(auditState);
612
+                     //processAudit1.setOperationTime(processAudit.getOperationTime());
613
+                     processAudit1.setType(processAudit.getType());
614
+                     processAudit1.setHouseId(processAudit.getHouseId());
615
+                     processAudit1.setDepotId(processAudit.getDepotId());
616
+                     processAudit1.setFromPeople(processAudit.getToPeople());//当前审批人是下一个审批的提交人
617
+                     processAudit1.setToPeople(toPeople);
618
+                     processAudit1.setResult(0);
619
+                     processAudit1.setAuditState(0);//已提交待审批
620
+                     processAudit1.setApplyPeople(processAudit.getApplyPeople());
621
+                     processAudit1.setProcessId(processAudit.getProcessId());
622
+                     processAudit1.setApplyTime(processAudit.getApplyTime());
623
+                     processAudit1.setOngoingStep(ongoingStep);
624
+                     if (processAudit.getType().equals("tf")) {
625
+                         processAudit1.setWorkName(EnumProcessModel.tf.getName());
626
+                     }else if(processAudit.getType().equals("yjcg")){
627
+                    	 processAudit1.setWorkName(EnumProcessModel.yjcg.getName());
628
+                     }else if(processAudit.getType().equals("yjly")){
629
+                    	 processAudit1.setWorkName(EnumProcessModel.yjly.getName());
630
+                     }else if(processAudit.getType().equals("xzsq")){
631
+                    	 processAudit1.setWorkName(EnumProcessModel.xzsq.getName());
632
+                     }else if(processAudit.getType().equals("xzjh")){
633
+                    	 processAudit1.setWorkName(EnumProcessModel.xzjh.getName());
634
+                     }else if(processAudit.getType().equals("sswxjh")){
635
+                    	 processAudit1.setWorkName(EnumProcessModel.sswxjh.getName());
636
+                     }else if(processAudit.getType().equals("sswxys")){
637
+                    	 processAudit1.setWorkName(EnumProcessModel.sswxys.getName());
638
+                     }else if(processAudit.getType().equals("sbcg")){
639
+                    	 processAudit1.setWorkName(EnumProcessModel.sbcg.getName());
640
+                     }else if(processAudit.getType().equals("sbwx")){
641
+                    	 processAudit1.setWorkName(EnumProcessModel.sbwx.getName());
642
+                     }else if(processAudit.getType().equals("sbbf")){
643
+                    	 processAudit1.setWorkName(EnumProcessModel.sbbf.getName());
644
+                     }else if(processAudit.getType().equals("sbly")){
645
+                    	 processAudit1.setWorkName(EnumProcessModel.sbly.getName());
646
+                     }else if(processAudit.getType().equals("sbgh")){
647
+                    	 processAudit1.setWorkName(EnumProcessModel.sbgh.getName());
648
+                     }
649
+                     processAuditMapper.insert(processAudit1);
650
+                     
651
+                     /**
652
+                      *  发送通知数据给下一审批人
653
+                      */
654
+                     sysNoticeVO.setContent(userInfo.getDepotName()+"-"+houseName+"-"+"待审批");
655
+                     sysNoticeVO.setNoticeType(InformModel.TONGGUO.getcode());//申请的时候推送  通知类型:10系统、20待办、30审批通过、40审批不通过、50警告
656
+                    //获取下一审批人的信息
657
+                     ResponseEntity<String> userInfos1 = restTemplate.getForEntity(MyConstant.SYSTEM_USER + toPeople, String.class);
658
+                     if(null != userInfos1 && null != userInfos1.getBody()){
659
+                    	 com.alibaba.fastjson.JSONObject jsonObjectuser1 = JSON.parseObject(userInfos1.getBody());
660
+                         SysUserPO userInfo1 = com.alibaba.fastjson.JSONObject.toJavaObject(jsonObjectuser1, SysUserPO.class);
661
+                         users.put(toPeople, userInfo1.getuName());
662
+                     }
663
+                 }else{//不通过 发送数据给申请人
664
+                 	 sysNoticeVO.setContent(userInfo.getDepotName()+"-"+houseName+"-"+"审批不通过");
665
+                     sysNoticeVO.setNoticeType(InformModel.BUTONGGUO.getcode());//申请的时候推送  通知类型:10系统、20待办、30审批通过、40审批不通过、50警告
666
+                     users.put(processAudit.getApplyPeople(), userInfo.getuName());
667
+                 }
668
+        	 }
570 669
          } else {
571 670
              //第二个人审批
572 671
              //修改第一条数据的状态(历史数据的状态)
@@ -691,8 +790,9 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
691 790
         int depot = 0;
692 791
         int ongoingStep = 0;
693 792
         
694
-        if(list.get(0).getType().equals("xzjh") || list.get(0).getType().equals("xzsq") || 
695
-        		list.get(0).getType().equals("sswxjh") || list.get(0).getType().equals("sswxys")){
793
+        if(list.size()>0 && (list.get(0).getType().equals("xzjh") || list.get(0).getType().equals("xzsq") || 
794
+        		list.get(0).getType().equals("sswxjh") || list.get(0).getType().equals("sswxys") ||
795
+        		list.get(0).getType().equals("sbly") || list.get(0).getType().equals("sbgh"))){
696 796
             if(list.size()>0){
697 797
             	 depot = list.get(0).getDepotId();
698 798
                  ongoingStep = Integer.valueOf(list.get(0).getOngoingStep());
@@ -723,16 +823,21 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
723 823
         //流程基础数据
724 824
         List<Map<String, Object>> process = new ArrayList<>();
725 825
         QueryWrapper<ProcessMain> ew1 = new QueryWrapper<>();
726
-        if(list.get(0).getType().equals("xzjh") || list.get(0).getType().equals("xzsq")){
727
-        	ew1.eq("type", "xz");
728
-        }else if(list.get(0).getType().equals("sswxjh") || list.get(0).getType().equals("sswxys")){
729
-        	ew1.eq("type", "sswx");
826
+        if(list.size()>0){
827
+        	if(list.get(0).getType().equals("xzjh") || list.get(0).getType().equals("xzsq")){
828
+            	ew1.eq("type", "xz");
829
+            }else if(list.get(0).getType().equals("sswxjh") || list.get(0).getType().equals("sswxys")){
830
+            	ew1.eq("type", "sswx");
831
+            }else if(list.get(0).getType().equals("sbly") || list.get(0).getType().equals("sbgh")){
832
+            	ew1.eq("type", "sbly");
833
+            }else{
834
+            	ew1.eq("type", list.get(0).getType());
835
+            }
730 836
         }else{
731
-        	ew1.eq("type", list.get(0).getType());
837
+        	ew1.eq("type", sonList.get(0).getType());
732 838
         }
733 839
         
734 840
         
735
-        
736 841
         boolean auditFirst = true; 
737 842
         List<ProcessMain> mainList = processMainMapper.selectList(ew1);
738 843
         if(mainList.size()>0){
@@ -759,19 +864,55 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
759 864
                 HashMap<String, Object> map1 = Maps.newHashMap();
760 865
                 map1.put("step", mainList.get(i));//主表数据
761 866
                 map1.put("list", subList);//子表数据
762
-                if(list.get(0).getType().equals("xzjh") || list.get(0).getType().equals("xzsq")
763
-                		|| list.get(0).getType().equals("sswxjh") || list.get(0).getType().equals("sswxys")){
764
-                	
867
+                if(list.size()>0 && (list.get(0).getType().equals("xzjh") || list.get(0).getType().equals("xzsq")
868
+                		|| list.get(0).getType().equals("sswxjh") || list.get(0).getType().equals("sswxys")
869
+                		|| list.get(0).getType().equals("sbly") || list.get(0).getType().equals("sbgh"))){
765 870
                     //审批人数据
766 871
                     if(mainList.get(i).getExistProcess().equals(0)){
767 872
                     	if(auditFirst){
768 873
                     		createAudit( mainList, list, i, map1, depot, ongoingStep);
769 874
                     		auditFirst = false;
770 875
                     	}else{
771
-                    		createAudit( mainList, list2, i, map1,depot, ongoingStep);
772
-                    		
876
+                        	createAudit( mainList, list2, i, map1,depot, ongoingStep);
773 877
                     	}
774 878
                     }
879
+                }else{
880
+                	//审批数据
881
+                	if(mainList.get(i).getExistProcess().equals(0) && list.size()>0){
882
+                    	List<ProcessBasis> pbList = processBasisService.getBasisByType(list.get(0).getType(), null, list.get(0).getDepotId());
883
+                    	if(pbList.size()>0){
884
+                    		//判断是否是通过
885
+                           	boolean flag = list.get(0).getAuditState().equals(2);
886
+                           	//保管员
887
+                   			pbList.get(0).setAuditTime(list.get(0).getApplyTime());//保管员的时间为 申请时间
888
+                   			pbList.get(0).setContent(list.get(0).getApplyPeople());//保管员为申请人
889
+                   		 	for (int j = 0; j < pbList.size(); j++) {
890
+                       		    if(j==0)continue;//保管员 不做处理
891
+                       		    //审批人
892
+                       		    ProcessBasis item = pbList.get(j);
893
+                       			if(j-1<=list.size()-1){
894
+                       				// 业务
895
+                       				ProcessAudit audit = list.get(j-1);
896
+                       				item.setAuditTime(audit.getAuditTime());
897
+                       				item.setContent(audit.getToPeople());
898
+                       				if(flag){//不通过
899
+                               			if(j-1==list.size()-1){
900
+                               				item.setAuditState(2);
901
+                               			}else{
902
+                               				item.setAuditState(1);
903
+                               			}
904
+                               		}else{
905
+                               			item.setAuditState(audit.getAuditState());
906
+                               		}
907
+                       				
908
+                       			}
909
+               			    }
910
+                   		  if(pbList.get(1).getAuditState().equals(4) || pbList.get(1).getAuditState().equals(3)){
911
+                        		pbList.get(1).setAuditState(1);
912
+                          }
913
+                   		   map1.put("audit", pbList);
914
+                    	}
915
+                	}
775 916
                 }
776 917
                 process.add(map1);
777 918
                 
@@ -779,7 +920,7 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
779 920
         }else{
780 921
         	HashMap<String, Object> map1 = Maps.newHashMap();
781 922
         	QueryWrapper<ProcessSub> ew2 = new QueryWrapper<>();
782
-            ew2.eq("type", list.get(0).getType());
923
+            ew2.eq("type", sonList.get(0).getType());
783 924
             List<ProcessSub> subList = processSubMapper.selectList(ew2);
784 925
             for (int j = 0; j < subList.size(); j++) {
785 926
                 for (int k = 0; k < sonList.size(); k++) {
@@ -793,8 +934,8 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
793 934
             map1.put("list", subList);//子表数据
794 935
             
795 936
           //审批流程信息
796
-            if(list.get(0).getType().equals("tf") || list.get(0).getType().equals("yjly") || list.get(0).getType().equals("yjcg")
797
-            		|| list.get(0).getType().equals("sbcg")){
937
+            if(list.size()>0 && (list.get(0).getType().equals("tf") || list.get(0).getType().equals("yjly") || list.get(0).getType().equals("yjcg")
938
+            		|| list.get(0).getType().equals("sbcg"))){
798 939
             	List<ProcessBasis> pbList = processBasisService.getBasisByType(list.get(0).getType(), null, list.get(0).getDepotId());
799 940
                 if(pbList.size()>0){
800 941
                 	if(pbList.get(0).getType().equals("tf") || pbList.get(0).getType().equals("yjly")){
@@ -864,8 +1005,8 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
864 1005
         map.put("process", process);
865 1006
 
866 1007
         //审批流程信息
867
-        if(list.get(0).getType().equals("tf") || list.get(0).getType().equals("yjly") || list.get(0).getType().equals("yjcg")
868
-        		|| list.get(0).getType().equals("sbcg")){
1008
+        if(list.size()>0 && (list.get(0).getType().equals("tf") || list.get(0).getType().equals("yjly") || list.get(0).getType().equals("yjcg")
1009
+        		|| list.get(0).getType().equals("sbcg"))){
869 1010
         	List<ProcessBasis> pbList = processBasisService.getBasisByType(list.get(0).getType(), null, list.get(0).getDepotId());
870 1011
             if(pbList.size()>0){
871 1012
             	if(pbList.get(0).getType().equals("tf") || pbList.get(0).getType().equals("yjly")){
@@ -941,9 +1082,11 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
941 1082
 
942 1083
         QueryWrapper<ProcessAudit> ew = new QueryWrapper<>();
943 1084
         org.json.JSONObject object = new org.json.JSONObject(pageParam.getCondition());
944
-        if (StringUtils.isNotBlank(object.optString("userId"))) {
945
-            ew.eq("apply_people", object.optString("userId"));
946
-            ew.eq("from_people", object.optString("userId"));
1085
+        String userId = object.optString("userId");
1086
+
1087
+        if (StringUtils.isNotBlank(userId)) {
1088
+            ew.eq("apply_people", userId);
1089
+            ew.eq("from_people", userId);
947 1090
         }
948 1091
         //ew.eq("result", 1);//整个流程的第一条数据
949 1092
         //只获取审批的数据
@@ -1002,9 +1145,10 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1002 1145
 
1003 1146
         QueryWrapper<ProcessAudit> ew = new QueryWrapper<>();
1004 1147
         org.json.JSONObject object = new org.json.JSONObject(pageParam.getCondition());
1005
-        if (StringUtils.isNotBlank(object.optString("userId"))) {
1148
+        String userId = object.optString("userId");
1149
+        if (StringUtils.isNotBlank(userId)) {
1006 1150
             //如果是第一个审批人 则第一条数据中状态不为0(提交)
1007
-            ew.eq("to_people", object.optString("userId"));
1151
+            ew.eq("to_people", userId);
1008 1152
             //ew.eq("result",1);//整个流程的第一条数据
1009 1153
             //ew.ne("audit_state",0);
1010 1154
 
@@ -1351,6 +1495,12 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1351 1495
          }else if(processAudit.getType().equals("sbcg")){
1352 1496
         	 sysNoticeVO.setTitle(EnumProcessModel.sbcg.getName());
1353 1497
           	 sysNoticeVO.setNoticeModule("sbcg");
1498
+         }else if(processAudit.getType().equals("sbwx")){
1499
+        	 sysNoticeVO.setTitle(EnumProcessModel.sbwx.getName());
1500
+          	 sysNoticeVO.setNoticeModule("sbwx");
1501
+         }else if(processAudit.getType().equals("sbbf")){
1502
+        	 sysNoticeVO.setTitle(EnumProcessModel.sbbf.getName());
1503
+          	 sysNoticeVO.setNoticeModule("sbbf");
1354 1504
          }
1355 1505
          //根据仓房id获取仓房名称
1356 1506
          String houseName = "";
@@ -1459,6 +1609,10 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1459 1609
                 	 processAudit1.setWorkName(EnumProcessModel.sswxys.getName());
1460 1610
                  }else if(processAudit.getType().equals("sbcg")){
1461 1611
                 	 processAudit1.setWorkName(EnumProcessModel.sbcg.getName());
1612
+                 }else if(processAudit.getType().equals("sbwx")){
1613
+                	 processAudit1.setWorkName(EnumProcessModel.sbwx.getName());
1614
+                 }else if(processAudit.getType().equals("sbbf")){
1615
+                	 processAudit1.setWorkName(EnumProcessModel.sbbf.getName());
1462 1616
                  }
1463 1617
                  processAuditMapper.insert(processAudit1);
1464 1618
                  
@@ -1580,8 +1734,9 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1580 1734
 	public void drugDetailsAdd(String parameter) throws JSONException {
1581 1735
 		JSONObject jsStr = new JSONObject(parameter);
1582 1736
         String processId = "";
1583
-        if(null != jsStr.optString("processId") && "" != jsStr.optString("processId")){
1584
-        	 processId = jsStr.optString("processId");//流程id 用于修改
1737
+        String receiveProcessId = jsStr.optString("processId");
1738
+        if(null != receiveProcessId && !receiveProcessId.equals("")){
1739
+        	 processId = receiveProcessId;//流程id 用于修改
1585 1740
         }else{
1586 1741
         	 processId = UUID.randomUUID().toString();//生成一个流程id
1587 1742
         }
@@ -1590,6 +1745,8 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1590 1745
         Integer depotId = jsStr.optInt("depotId");//库id
1591 1746
         Integer auditState = jsStr.optInt("auditState");//状态
1592 1747
         JSONArray jsonArray = jsStr.optJSONArray("subList");//子流程数据
1748
+        Integer equipmentId = jsStr.optInt("equipmentId");//状态
1749
+        String equipmentNameCode = jsStr.optString("equipmentNameCode");//状态
1593 1750
         JSONObject row = null;
1594 1751
         for (int i = 0; i < jsonArray.length(); i++) {
1595 1752
             row = jsonArray.getJSONObject(i);
@@ -1625,6 +1782,11 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1625 1782
             }else{//第一次新增
1626 1783
             	//第一条数据新增
1627 1784
                 ProcessAudit processAudit = new ProcessAudit();
1785
+                if(type.equals("sbtz")){
1786
+                	processAudit.setWorkName(EnumProcessModel.sbtz.getName());
1787
+                }else if(type.equals("sbdwgl")){
1788
+                	processAudit.setWorkName(EnumProcessModel.sbdwgl.getName());
1789
+                }
1628 1790
                 processAudit.setType(type);
1629 1791
                 processAudit.setSubData(subData);
1630 1792
                 processAudit.setSubId(subId);
@@ -1637,7 +1799,16 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1637 1799
                 SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm");
1638 1800
                 String dateString = formatter.format(date);
1639 1801
                 processAudit.setApplyTime(dateString);
1802
+                processAudit.setEquipmentId(equipmentId);
1803
+                processAudit.setEquipmentNameCode(equipmentNameCode);
1640 1804
                 processAuditMapper.insert(processAudit);
1805
+                if(type.equals("sbtz") || type.equals("sbdwgl")){
1806
+                	//修改器材库的状态
1807
+                	EquipmentStroe entity = new EquipmentStroe();
1808
+                	entity.setId(equipmentId);
1809
+                	entity.setState(0);
1810
+                	quipmentStroeServicee.updateById(entity);
1811
+                }
1641 1812
             }
1642 1813
             
1643 1814
         }
@@ -1664,38 +1835,41 @@ public class ProcessAuditServiceImpl extends ServiceImpl<ProcessAuditMapper, Pro
1664 1835
         	QueryWrapper<ProcessBasis> ew3 = new QueryWrapper<>();
1665 1836
             ew3.eq("main_id", mainList.get(i).getId());
1666 1837
             List<ProcessBasis> basisList = processBasisMapper.selectList(ew3);
1667
-            List<ProcessBasis> pbList = processBasisService.getBasisByType(basisList.get(0).getType(), null, depot);
1668
-            if(pbList.size()>0 && i <= Integer.valueOf(ongoingStep) && list.size()>0){
1669
-               	
1670
-               	//判断是否是通过
1671
-               	boolean flag = list.get(0).getAuditState().equals(2);
1672
-               	//保管员
1673
-       			pbList.get(0).setAuditTime(list.get(0).getApplyTime());//保管员的时间为 申请时间
1674
-       			pbList.get(0).setContent(list.get(0).getApplyPeople());//保管员为申请人
1675
-               	for (int j = 0; j < pbList.size(); j++) {
1676
-               		    if(j==0)continue;//保管员 不做处理
1677
-               		    //审批人
1678
-               		    ProcessBasis item = pbList.get(j);
1679
-               			if(j-1<=list.size()-1){
1680
-               				// 业务
1681
-               				ProcessAudit audit = list.get(j-1);
1682
-               					item.setAuditTime(audit.getAuditTime());
1683
-                   				item.setContent(audit.getToPeople());
1684
-                   				if(flag){//不通过
1685
-                           			if(j-1==list.size()-1){
1686
-                           				item.setAuditState(2);
1687
-                           			}else{
1688
-                           				item.setAuditState(1);
1689
-                           			}
1690
-                           		}else{
1691
-                           			item.setAuditState(audit.getAuditState());
1692
-                           		}
1693
-               			}
1694
-       			}
1695
-               	if(pbList.get(1).getAuditState().equals(4) || pbList.get(1).getAuditState().equals(3)){
1696
-               		pbList.get(1).setAuditState(1);
1697
-               	}
1838
+            if(basisList.size()>0){
1839
+                List<ProcessBasis> pbList = processBasisService.getBasisByType(basisList.get(0).getType(), null, depot);
1840
+                if(pbList.size()>0 && i <= Integer.valueOf(ongoingStep) && list.size()>0){
1841
+                   	
1842
+                   	//判断是否是通过
1843
+                   	boolean flag = list.get(0).getAuditState().equals(2);
1844
+                   	//保管员
1845
+           			pbList.get(0).setAuditTime(list.get(0).getApplyTime());//保管员的时间为 申请时间
1846
+           			pbList.get(0).setContent(list.get(0).getApplyPeople());//保管员为申请人
1847
+                   	for (int j = 0; j < pbList.size(); j++) {
1848
+                   		    if(j==0)continue;//保管员 不做处理
1849
+                   		    //审批人
1850
+                   		    ProcessBasis item = pbList.get(j);
1851
+                   			if(j-1<=list.size()-1){
1852
+                   				// 业务
1853
+                   				ProcessAudit audit = list.get(j-1);
1854
+                   					item.setAuditTime(audit.getAuditTime());
1855
+                       				item.setContent(audit.getToPeople());
1856
+                       				if(flag){//不通过
1857
+                               			if(j-1==list.size()-1){
1858
+                               				item.setAuditState(2);
1859
+                               			}else{
1860
+                               				item.setAuditState(1);
1861
+                               			}
1862
+                               		}else{
1863
+                               			item.setAuditState(audit.getAuditState());
1864
+                               		}
1865
+                   			}
1866
+           			}
1867
+                   	if(pbList.get(1).getAuditState().equals(4) || pbList.get(1).getAuditState().equals(3)){
1868
+                   		pbList.get(1).setAuditState(1);
1869
+                   	}
1870
+                }
1871
+                map1.put("audit", pbList);
1698 1872
             }
1699
-            map1.put("audit", pbList);
1873
+            
1700 1874
 	}
1701 1875
 }