duhongyu 1 month ago
parent
commit
2aad7a240a
48 changed files with 1260 additions and 260 deletions
  1. 8 0
      pom.xml
  2. 4 4
      src/main/java/com/yt/zhylplat/CodeGenerator.java
  3. 25 0
      src/main/java/com/yt/zhylplat/api/request/TBaseDriveinfoRequest.java
  4. 30 0
      src/main/java/com/yt/zhylplat/api/request/TBaseFacilityinfoRequest.java
  5. 1 0
      src/main/java/com/yt/zhylplat/api/request/TSysModulefunctionsRequest.java
  6. 36 0
      src/main/java/com/yt/zhylplat/api/request/TWoWorkorderbaseRequest.java
  7. 13 0
      src/main/java/com/yt/zhylplat/api/response/TSysModulefunctionsResponse.java
  8. 48 5
      src/main/java/com/yt/zhylplat/app/service/impl/ZhjcIrrigationBaseServiceImpl.java
  9. 38 10
      src/main/java/com/yt/zhylplat/appController/SendMessageWxController.java
  10. 6 0
      src/main/java/com/yt/zhylplat/appController/TWoWorkorderbaseAppController.java
  11. 22 7
      src/main/java/com/yt/zhylplat/appController/TodoMessageAppController.java
  12. 14 1
      src/main/java/com/yt/zhylplat/controller/TBaseDriveinfoController.java
  13. 9 4
      src/main/java/com/yt/zhylplat/controller/TEquipmentMaintenanceController.java
  14. 20 6
      src/main/java/com/yt/zhylplat/controller/TWoWorkorderbaseController.java
  15. 67 0
      src/main/java/com/yt/zhylplat/controller/TWorkReportController.java
  16. 16 0
      src/main/java/com/yt/zhylplat/dao/TWorkReportMapper.java
  17. 25 0
      src/main/java/com/yt/zhylplat/entity/TBaseDriveinfo.java
  18. 16 0
      src/main/java/com/yt/zhylplat/entity/TBaseFacilityinfo.java
  19. 45 0
      src/main/java/com/yt/zhylplat/entity/TBaseParkinfo.java
  20. 9 0
      src/main/java/com/yt/zhylplat/entity/TEquipmentMaintenance.java
  21. 7 3
      src/main/java/com/yt/zhylplat/entity/TEquipmentMaintenanceRequest.java
  22. 41 0
      src/main/java/com/yt/zhylplat/entity/TWoWorkorderbase.java
  23. 82 0
      src/main/java/com/yt/zhylplat/entity/TWorkReport.java
  24. 41 8
      src/main/java/com/yt/zhylplat/moduleGygy/controller/GygyScheduleController.java
  25. 8 0
      src/main/java/com/yt/zhylplat/moduleLhgy/controller/LhgyWorkOrderBaseAppController.java
  26. 89 84
      src/main/java/com/yt/zhylplat/moduleLhgy/service/impl/LhgyWorkOrderBaseServiceImpl.java
  27. 2 1
      src/main/java/com/yt/zhylplat/modulePest/patrolTrack/service/impl/TPestcPatrolTrackIssueServiceImpl.java
  28. 5 0
      src/main/java/com/yt/zhylplat/service/ITBaseDriveinfoService.java
  29. 2 0
      src/main/java/com/yt/zhylplat/service/ITWoWorkorderbaseService.java
  30. 1 1
      src/main/java/com/yt/zhylplat/service/TEquipmentMaintenanceService.java
  31. 27 0
      src/main/java/com/yt/zhylplat/service/TWorkReportService.java
  32. 37 0
      src/main/java/com/yt/zhylplat/service/impl/TBaseDriveinfoServiceImpl.java
  33. 2 1
      src/main/java/com/yt/zhylplat/service/impl/TBaseEmployeeinfoServiceImpl.java
  34. 9 5
      src/main/java/com/yt/zhylplat/service/impl/TEquipmentMaintenanceServiceImpl.java
  35. 7 2
      src/main/java/com/yt/zhylplat/service/impl/TPdjgWorkorderCategoryServiceImpl.java
  36. 7 6
      src/main/java/com/yt/zhylplat/service/impl/TSmsSendsmstaskServiceImpl.java
  37. 6 3
      src/main/java/com/yt/zhylplat/service/impl/TSpActivitybaseServiceImpl.java
  38. 44 1
      src/main/java/com/yt/zhylplat/service/impl/TSysUseraccountServiceImpl.java
  39. 194 94
      src/main/java/com/yt/zhylplat/service/impl/TWoWorkorderbaseServiceImpl.java
  40. 7 3
      src/main/java/com/yt/zhylplat/service/impl/TWoXctaskbaseinfoServiceImpl.java
  41. 94 0
      src/main/java/com/yt/zhylplat/service/impl/TWorkReportServiceImpl.java
  42. 85 0
      src/main/java/com/yt/zhylplat/timedTask/facilityinfo/FacilityinfoTask.java
  43. 2 2
      src/main/resources/application-pro.yml
  44. 3 3
      src/main/resources/application.yml
  45. 0 0
      src/main/resources/mapper/TEquipmentMaintenanceMapper.xml
  46. 1 1
      src/main/resources/mapper/nullTEquipmentMaintenanceMapper.xml
  47. 2 2
      target/classes/application-pro.yml
  48. 3 3
      target/classes/application.yml

+ 8 - 0
pom.xml

@@ -252,6 +252,14 @@
252 252
         </dependency>
253 253
 
254 254
 
255
+        <!-- 海康加密认证SDK -->
256
+        <dependency>
257
+            <groupId>com.hikvision.ga</groupId>
258
+            <artifactId>artemis-http-client</artifactId>
259
+            <version>1.1.3</version>
260
+        </dependency>
261
+
262
+
255 263
         <!--文件导入导出-->
256 264
         <dependency>
257 265
             <groupId>org.apache.poi</groupId>

+ 4 - 4
src/main/java/com/yt/zhylplat/CodeGenerator.java

@@ -93,10 +93,10 @@ public class CodeGenerator {
93 93
        // pc.setModuleName(scanner("模块名"));
94 94
         pc.setParent("com.yt.zhylplat");
95 95
         pc.setMapper("dao");  //设置默认的mapper为dao
96
-        pc.setService("app.service");
97
-        pc.setServiceImpl("app.service.impl");
98
-        pc.setEntity("moduleZhjc.entity");
99
-        pc.setController("app.controller");
96
+   //     pc.setService("app.service");
97
+    //    pc.setServiceImpl("app.service.impl");
98
+        //pc.setEntity("moduleZhjc.entity");
99
+    //    pc.setController("app.controller");
100 100
     //    pc.setModuleName("moduleDabj");
101 101
         mpg.setPackageInfo(pc);
102 102
 

+ 25 - 0
src/main/java/com/yt/zhylplat/api/request/TBaseDriveinfoRequest.java

@@ -267,6 +267,31 @@ public class TBaseDriveinfoRequest extends  BasePageRequest{
267 267
     @ApiModelProperty("F_WGS84X")
268 268
     private String fWgs84x;
269 269
 
270
+    @ApiModelProperty("F_Channel")
271
+    private Integer fChannel;
272
+
273
+    @ApiModelProperty("F_URL")
274
+    private String url;
275
+
276
+
277
+    public String getUrl() {
278
+        return url;
279
+    }
280
+
281
+    public void setUrl(String url) {
282
+        this.url = url;
283
+    }
284
+
285
+
286
+    public Integer getfChannel()
287
+    {
288
+        return fChannel;
289
+    }
290
+
291
+    public void setfChannel(Integer fChannel) {
292
+        this.fChannel = fChannel;
293
+    }
294
+
270 295
     public Integer getfDriveid() {
271 296
         return fDriveid;
272 297
     }

+ 30 - 0
src/main/java/com/yt/zhylplat/api/request/TBaseFacilityinfoRequest.java

@@ -259,8 +259,21 @@ public class TBaseFacilityinfoRequest extends  BasePageRequest{
259 259
     @TableField("environment")
260 260
     private String environment;
261 261
 
262
+    /**
263
+     * 到期时间
264
+     */
265
+    @ApiModelProperty(value = "到期时间")
266
+    @TableField("expiration_time")
267
+    private Date expirationTime;
262 268
 
263 269
 
270
+    /**
271
+     * 是否发送短信
272
+     */
273
+    @ApiModelProperty(value = "是否发送短信")
274
+    @TableField("is_sms")
275
+    private Integer isSms;
276
+
264 277
 
265 278
     /**
266 279
      * 字典名称1
@@ -274,6 +287,23 @@ public class TBaseFacilityinfoRequest extends  BasePageRequest{
274 287
     @TableField(exist = false)
275 288
     private String fStringname2;
276 289
 
290
+    public Date getExpirationTime() {
291
+        return expirationTime;
292
+    }
293
+
294
+    public void setExpirationTime(Date expirationTime) {
295
+        this.expirationTime = expirationTime;
296
+    }
297
+
298
+
299
+    public Integer getIsSms() {
300
+        return isSms;
301
+    }
302
+
303
+    public void setIsSms(Integer isSms) {
304
+        this.isSms = isSms;
305
+    }
306
+
277 307
     public String getfStringname4() {
278 308
         return fStringname4;
279 309
     }

+ 1 - 0
src/main/java/com/yt/zhylplat/api/request/TSysModulefunctionsRequest.java

@@ -112,6 +112,7 @@ public class TSysModulefunctionsRequest extends BasePageRequest {
112 112
     @ApiModelProperty(value = "菜单来源(1:web,2:小程序)")
113 113
     private Integer source;
114 114
 
115
+
115 116
     @ApiModelProperty(value = "小程序模块类型(1:大模块,2:小模块,3:菜单,4:按钮)")
116 117
     private Integer appletType;
117 118
 

+ 36 - 0
src/main/java/com/yt/zhylplat/api/request/TWoWorkorderbaseRequest.java

@@ -241,6 +241,13 @@ public class TWoWorkorderbaseRequest extends BasePageRequest{
241 241
 
242 242
     @ApiModelProperty(value = "推送时间")
243 243
     private String pushtime;
244
+
245
+
246
+    /**
247
+     * 抄送人
248
+     */
249
+    @ApiModelProperty(value = "抄送人")
250
+    private Integer cc;
244 251
     /**
245 252
      * 是否典型
246 253
      */
@@ -276,6 +283,10 @@ public class TWoWorkorderbaseRequest extends BasePageRequest{
276 283
     @ApiModelProperty(value = "父级id")
277 284
     private Integer parentid;
278 285
 
286
+
287
+    @ApiModelProperty("整改要求")
288
+    private  String rectification;
289
+
279 290
     @ApiModelProperty(value = "接收或者处置工单,1接收,2处置,3完结,4重新指派")
280 291
     private Integer acceptOrDispose;
281 292
 
@@ -322,6 +333,9 @@ public class TWoWorkorderbaseRequest extends BasePageRequest{
322 333
     @ApiModelProperty("weektype")
323 334
     private Integer weektype;
324 335
 
336
+    @ApiModelProperty("抄送人姓名")
337
+    private String ccName;
338
+
325 339
 
326 340
     /**
327 341
      * 工单大类对应经济运行平台监管要素编码
@@ -335,6 +349,22 @@ public class TWoWorkorderbaseRequest extends BasePageRequest{
335 349
     @TableField("patrol_id")
336 350
     private Integer patrolId;
337 351
 
352
+    public Integer getCc() {
353
+        return cc;
354
+    }
355
+
356
+    public void setCc(Integer cc) {
357
+        this.cc = cc;
358
+    }
359
+
360
+
361
+    public String getCcName() {
362
+        return ccName;
363
+    }
364
+    public void setCcName(String ccName) {
365
+        this.ccName = ccName;
366
+    }
367
+
338 368
     public Integer getfWorkorderid() {
339 369
         return fWorkorderid;
340 370
     }
@@ -1005,5 +1035,11 @@ public class TWoWorkorderbaseRequest extends BasePageRequest{
1005 1035
         this.parentid = parentid;
1006 1036
     }
1007 1037
 
1038
+    public void setRectification(String rectification) {
1039
+        this.rectification = rectification;
1040
+    }
1008 1041
 
1042
+    public String getRectification() {
1043
+        return rectification;
1044
+    }
1009 1045
 }

+ 13 - 0
src/main/java/com/yt/zhylplat/api/response/TSysModulefunctionsResponse.java

@@ -91,6 +91,19 @@ public class TSysModulefunctionsResponse{
91 91
     @ApiModelProperty("F_SysFlag")
92 92
     private Boolean fSysflag;
93 93
 
94
+
95
+    @ApiModelProperty(value = "小程序模块类型(1:大模块,2:小模块,3:菜单,4:按钮)")
96
+    private Integer appletType;
97
+
98
+
99
+    public Integer getAppletType() {
100
+        return appletType;
101
+    }
102
+
103
+    public void setAppletType(Integer appletType) {
104
+        this.appletType = appletType;
105
+    }
106
+
94 107
     public String getRoute() {
95 108
         return route;
96 109
     }

+ 48 - 5
src/main/java/com/yt/zhylplat/app/service/impl/ZhjcIrrigationBaseServiceImpl.java

@@ -9,6 +9,7 @@ import com.yt.zhylplat.base.ResultResponse;
9 9
 import com.yt.zhylplat.common.LoginUserUtil;
10 10
 import com.yt.zhylplat.enums.ResultCode;
11 11
 import com.yt.zhylplat.enums.ResultCodeEnum;
12
+import com.yt.zhylplat.moduleMap.entity.TMapPolygonGeometry;
12 13
 import com.yt.zhylplat.moduleMap.entity.TMapPolygonProperties;
13 14
 import com.yt.zhylplat.moduleMap.mapper.TMapPolygonPropertiesMapper;
14 15
 import com.yt.zhylplat.moduleZhjc.entity.ZhjcIrrigationBase;
@@ -22,10 +23,15 @@ import org.springframework.beans.BeanUtils;
22 23
 import org.springframework.beans.factory.annotation.Autowired;
23 24
 import org.springframework.stereotype.Service;
24 25
 
25
-import java.util.Date;
26
-import java.util.HashMap;
27
-import java.util.List;
28
-import java.util.Map;
26
+import java.math.BigDecimal;
27
+import java.time.LocalDate;
28
+import java.time.LocalTime;
29
+import java.time.ZoneId;
30
+import java.time.ZonedDateTime;
31
+import java.time.format.DateTimeFormatter;
32
+import java.util.*;
33
+import java.util.function.Function;
34
+import java.util.stream.Collectors;
29 35
 
30 36
 /**
31 37
  * <p>
@@ -112,14 +118,51 @@ public class ZhjcIrrigationBaseServiceImpl extends ServiceImpl<ZhjcIrrigationBas
112 118
         List<ZhjcIrrigationEfficiency> Efficiency= baseMapper.selectEfficiency();
113 119
 
114 120
         List<ZhjcIrrigationConsumption>     Consumption= baseMapper.selectConsumption();
121
+        // 获取当前日期
122
+        LocalDate today = LocalDate.now();
123
+
124
+        // 设置为当天的0点
125
+        LocalTime startOfDay = LocalTime.MIDNIGHT;
126
+
127
+        // 将日期和时间组合成一个ZonedDateTime对象,使用系统默认时区
128
+        ZonedDateTime zonedDateTime = today.atTime(startOfDay).atZone(ZoneId.systemDefault());
129
+
130
+        // 定义日期时间的格式
131
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
132
+
133
+        // 格式化输出为字符串
134
+        String formattedDateTime = zonedDateTime.format(formatter);
135
+
136
+        List<ZhjcIrrigationBase> irrigas=baseMapper.
137
+                selectList ( new QueryWrapper<ZhjcIrrigationBase>().lambda()
138
+                        .eq(ZhjcIrrigationBase::getParkId, id )
139
+                        .ge(ZhjcIrrigationBase::getStartTime,formattedDateTime));
115 140
 
116 141
 
117 142
         List<Map<String, Object>> effect=mapPolygonPropertiesMapper.
118 143
                 selectMaps( new QueryWrapper<TMapPolygonProperties>().lambda()
119 144
                 .eq(TMapPolygonProperties::getDelFlg, 0)
120 145
                         .eq(TMapPolygonProperties::getParkId, id )
121
-                .select(TMapPolygonProperties::getSurvive, TMapPolygonProperties::getIntact
146
+                .select( TMapPolygonProperties::getPolygonId, TMapPolygonProperties::getSectionName,
147
+                        TMapPolygonProperties::getSurvive, TMapPolygonProperties::getIntact
122 148
                         , TMapPolygonProperties::getComplaint));
149
+        for (Map<String, Object> map1 : effect) {
150
+
151
+            BigDecimal smartScope = irrigas.stream()
152
+                    .filter(x->x.getType()==1)
153
+                    .map(ZhjcIrrigationBase::getScope)
154
+                    .filter(Objects::nonNull)
155
+                    .reduce(BigDecimal.ZERO, BigDecimal::add);
156
+            BigDecimal manualScope = irrigas.stream()
157
+                    .filter(x->x.getType()==2)
158
+                    .map(ZhjcIrrigationBase::getScope)
159
+                    .filter(Objects::nonNull)
160
+                    .reduce(BigDecimal.ZERO, BigDecimal::add);
161
+            map1.put("smartScope",smartScope);
162
+            map1.put("manualScope",manualScope);
163
+        }
164
+
165
+
123 166
         map.put("Efficiency",Efficiency);
124 167
         map.put("Consumption",Consumption);
125 168
         map.put("effect",effect);

+ 38 - 10
src/main/java/com/yt/zhylplat/appController/SendMessageWxController.java

@@ -6,6 +6,7 @@ import com.yt.zhylplat.api.request.Template;
6 6
 import com.yt.zhylplat.api.request.TemplateParam;
7 7
 import com.yt.zhylplat.base.BaseConfiguration;
8 8
 import com.yt.zhylplat.base.ResultResponse;
9
+import com.yt.zhylplat.entity.TBaseFacilityinfo;
9 10
 import com.yt.zhylplat.entity.TWoWorkorderbase;
10 11
 import com.yt.zhylplat.enums.ResultCodeEnum;
11 12
 import com.yt.zhylplat.moduleAss.field.entity.TLhzxAssessTemplateField;
@@ -94,19 +95,34 @@ public class SendMessageWxController {
94 95
     }
95 96
 
96 97
     @GetMapping("/SendDiaryWarningMessage")
97
-    @ApiOperation("园长日记预警订阅消息推送")
98
+    @ApiOperation("派单提醒")
98 99
     public  static void SendDiaryWarningMessage(TWoWorkorderbase tWoWorkorderbase, String toUser,String title) {
100
+        String page = "pages/work_order_detail/work_order_detail?orderId=" +
101
+                tWoWorkorderbase.getfWorkorderid() + "&statusid=" + tWoWorkorderbase.getfStateid();
102
+        List<TemplateParam> templateParams = new ArrayList<>();
103
+        //事项编码
104
+        templateParams.add(TemplateParam.builder().key("character_string6").value(tWoWorkorderbase.getfFromcode()).build());
105
+        //事项名称
106
+        templateParams.add(TemplateParam.builder().key("thing19").value(tWoWorkorderbase.getfWorkordertype()).build());
107
+        //备注
108
+        templateParams.add(TemplateParam.builder().key("thing24").value(tWoWorkorderbase.getfContent()).build());
109
+        SendWX(templateParams,"zlr8Ce3V9yB3S--v6kNnp8W66a2fQO7uG-LTbPRwgdE", toUser, page);
110
+    }
99 111
 
100
-        String thing3 = "派单";
101
-        // 工单编号
102
-        String character_string = tWoWorkorderbase.getfFromcode();
103
-        String thing2 = title;//"园长日记未提交预警通知";
104
-        String thing9 = tWoWorkorderbase.getfContent();
105
-        if(thing9.length()>20){
106
-            thing9=thing9.substring(0,20);
112
+    @GetMapping("/SendDiaryWarningFacility")
113
+    @ApiOperation("设施到期提醒")
114
+    public  static void SendDiaryWarningFacility(TBaseFacilityinfo facilityinfo, String toUser, String title) {
115
+        String page = "packagePersonnel/pages/facilitiesFitness/facilitiesFitness" ;
116
+        List<TemplateParam> templateParams = new ArrayList<>();
117
+        templateParams.add(TemplateParam.builder().key("thing9").value(facilityinfo.getFName()).build());
118
+        templateParams.add(TemplateParam.builder().key("thing8").value("设备即将到期").build());
119
+        if (facilityinfo.getExpirationTime()!=null)
120
+        {
121
+            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); // 设置日期时间的格式
122
+            String dateString = sdf.format(facilityinfo.getExpirationTime()); // 将日期转换为字符串
123
+            templateParams.add(TemplateParam.builder().key("thing10").value(dateString).build());
107 124
         }
108
-        String page = "pages/work_order_detail/work_order_detail?orderId=" + tWoWorkorderbase.getfWorkorderid() + "&statusid=" + tWoWorkorderbase.getfStateid();
109
-        SendMessage(thing3, character_string, thing2, thing9, toUser, page);
125
+        SendWX(templateParams,"9k7_suAIzYn4zbC7hdOegpeNoWFpmOisq57Coh_ISrs", toUser, page);
110 126
     }
111 127
 
112 128
     @GetMapping("/sendAssessFieldMessage")
@@ -152,6 +168,18 @@ public class SendMessageWxController {
152 168
         subscribeMessage(template);
153 169
     }
154 170
 
171
+    public static void SendWX(List<TemplateParam> templateParams,
172
+                                   String templateId, String touser,String page) {
173
+
174
+        Template template = Template.builder()
175
+                .template_id(templateId)//模板 ID
176
+                .touser(touser)//用户 openid
177
+                .data(templateParams) //模板参数
178
+                .page(page)//点击消息跳转页面
179
+                .build();
180
+        subscribeMessage(template);
181
+    }
182
+
155 183
     /**
156 184
      * 发送会议提醒通知
157 185
      * @param thing1

+ 6 - 0
src/main/java/com/yt/zhylplat/appController/TWoWorkorderbaseAppController.java

@@ -67,6 +67,12 @@ public class TWoWorkorderbaseAppController {
67 67
         return itWoWorkorderbaseService.saveWorkorderbase(baseRequest.getData());
68 68
     }
69 69
 
70
+    @PostMapping("/dispatchAppOrder")
71
+    @ApiOperation(value = "小程序派单", notes = "小程序派单")
72
+    @OperationLog(operDesc = "小程序派单")
73
+    public ResultResponse dispatchAppOrder(@RequestBody  BaseRequest<TWoWorkorderbaseRequest> baseRequest) throws ParseException {
74
+        return itWoWorkorderbaseService.dispatchAppOrder(baseRequest.getData());
75
+    }
70 76
 
71 77
     @PostMapping("/acceptOrDisposeWorkOrder")
72 78
     @ApiOperation(value = "小程序工单接收或处置", notes = "小程序工单接收或处置")

+ 22 - 7
src/main/java/com/yt/zhylplat/appController/TodoMessageAppController.java

@@ -93,6 +93,7 @@ public class TodoMessageAppController {
93 93
                         .eq(TWoWorkorderbase::getfDeleteflag, 0)
94 94
 //                .eq(TWoWorkorderbase::getfWorkordertypeid, ts.getfWorkordertypeid())//工单类型
95 95
                         .ne(TWoWorkorderbase::getfStateid, 4)//工单状态不等于4
96
+                        .ne(TWoWorkorderbase::getfStateid, 3)//工单状态不等于4
96 97
                         .and(QueryWrapper -> QueryWrapper
97 98
                                 .in(collect.size() > 0, TWoWorkorderbase::getfWorkorderid, collect)
98 99
                         )
@@ -207,15 +208,29 @@ public class TodoMessageAppController {
207 208
             List<TWoWorkorderbase> list = workorderbaseService.list(new QueryWrapper<TWoWorkorderbase>().lambda()
208 209
                     .eq(TWoWorkorderbase::getfDeleteflag, 0)
209 210
                     .ne(TWoWorkorderbase::getfStateid, 4)//工单状态不等于4
210
-                    .in(baseRequest.getData().getDeptType() == 1, TWoWorkorderbase::getDeptType,0,1)//科室
211
-                    .eq(baseRequest.getData().getDeptType() != 1, TWoWorkorderbase::getDeptType,baseRequest.getData().getDeptType())//科室
212
-                    .exists("select distinct T_WO_WorkOrderTask.f_workorderid from T_WO_WorkOrderTask where f_ownerid=" + LoginUserUtil.getfUserid() + " and T_WO_WorkOrderTask.f_workorderid = T_WO_WorkOrderBase.f_workorderid and f_loseflag = 0"));
211
+                    .ne(TWoWorkorderbase::getfStateid, 3)//工单状态不等于4
212
+                    .in(baseRequest.getData().getDeptType() == 1,
213
+                            TWoWorkorderbase::getDeptType,0,1)//科室
214
+//                    .eq(baseRequest.getData().getDeptType() != 1,
215
+//                            TWoWorkorderbase::getDeptType,baseRequest.getData().getDeptType())//科室
216
+                    . and(wq ->
217
+                            wq. exists("select distinct T_WO_WorkOrderTask.f_workorderid from T_WO_WorkOrderTask where f_ownerid="
218
+                                    + LoginUserUtil.getfUserid()
219
+                                    + " and T_WO_WorkOrderTask.f_workorderid = T_WO_WorkOrderBase.f_workorderid and f_loseflag = 0")
220
+                                    .or()
221
+                                    .eq(TWoWorkorderbase::getfCreateid, LoginUserUtil.getfUserid())
222
+                    )
223
+                   );
213 224
 
214 225
             if (list.size() > 0) {
215
-                rcglCount = Math.toIntExact(list.stream().filter(workorderbase -> workorderbase.getfWorkordertypeid() == 3).count());
216
-                znfxCount = Math.toIntExact(list.stream().filter(workorderbase -> workorderbase.getfWorkordertypeid() == 4).count());
217
-                xftsCount = Math.toIntExact(list.stream().filter(workorderbase -> workorderbase.getfWorkordertypeid() == 5).count());
218
-                zxjcCount = Math.toIntExact(list.stream().filter(workorderbase -> workorderbase.getfWorkordertypeid() == 6).count());
226
+                rcglCount = Math.toIntExact(list.stream().filter(workorderbase ->
227
+                        workorderbase.getfWorkordertypeid() == 3).count());
228
+                znfxCount = Math.toIntExact(list.stream().filter(workorderbase ->
229
+                        workorderbase.getfWorkordertypeid() == 4).count());
230
+                xftsCount = Math.toIntExact(list.stream().filter(workorderbase ->
231
+                        workorderbase.getfWorkordertypeid() == 5).count());
232
+                zxjcCount = Math.toIntExact(list.stream().filter(workorderbase ->
233
+                        workorderbase.getfWorkordertypeid() == 6).count());
219 234
             }
220 235
         }
221 236
         map.put("rcglCount",rcglCount);

+ 14 - 1
src/main/java/com/yt/zhylplat/controller/TBaseDriveinfoController.java

@@ -171,6 +171,13 @@ public class TBaseDriveinfoController {
171 171
     public ResultResponse saveDriveInfo(@RequestBody BaseRequest<TBaseDriveinfoRequest> baseRequest) {
172 172
         return itBaseDriveinfoService.saveDriveInfo(baseRequest.getData());
173 173
     }
174
+    @PostMapping("/updateDriveInfo")
175
+    @ApiOperation(value = "web更新方法", notes = "web更新方法")
176
+    @OperationLog(operDesc = "web更新方法")
177
+    public ResultResponse updateDriveInfo(@RequestBody BaseRequest<TBaseDriveinfoRequest> baseRequest) {
178
+        return itBaseDriveinfoService.updateDriveInfo(baseRequest.getData());
179
+    }
180
+
174 181
     @PostMapping("/deleteDriveInfo")
175 182
     @ApiOperation(value = "web分类删除方法", notes = "web分类删除方法")
176 183
     @OperationLog(operDesc = "web分类删除方法")
@@ -202,6 +209,12 @@ public class TBaseDriveinfoController {
202 209
     {
203 210
         return itBaseDriveinfoService.selectDriveinfoList(id);
204 211
     }
205
-
212
+    @GetMapping("/GetUrl/{id}")
213
+    @ApiOperation(value = "大屏获取通道", notes = "大屏获取通道")
214
+    @OperationLog(operDesc = "大屏获取通道")
215
+    public ResultResponse GetUrl(@PathVariable int id)
216
+    {
217
+        return itBaseDriveinfoService.GetUrl(id);
218
+    }
206 219
 
207 220
 }

+ 9 - 4
src/main/java/com/yt/zhylplat/controller/TEquipmentMaintenanceController.java

@@ -3,10 +3,12 @@ package com.yt.zhylplat.controller;
3 3
 
4 4
 import com.yt.zhylplat.annotation.OperationLog;
5 5
 import com.yt.zhylplat.api.request.BaseRequest;
6
+import com.yt.zhylplat.api.request.TBaseDriveinfoRequest;
6 7
 import com.yt.zhylplat.api.request.TBaseFacilityinfoRequest;
7 8
 import com.yt.zhylplat.base.ResultResponse;
8 9
 import com.yt.zhylplat.entity.TEquipmentMaintenance;
9 10
 import com.yt.zhylplat.entity.TEquipmentMaintenanceRequest;
11
+import com.yt.zhylplat.enums.ResultCodeEnum;
10 12
 import com.yt.zhylplat.moduleMap.entity.TMapPolygonProperties;
11 13
 import com.yt.zhylplat.service.ITBaseFacilityinfoService;
12 14
 import com.yt.zhylplat.service.TEquipmentMaintenanceService;
@@ -39,14 +41,17 @@ public class TEquipmentMaintenanceController {
39 41
     }
40 42
     @ApiOperation("新增")
41 43
     @PostMapping("/")
42
-    public Boolean add(@RequestBody TEquipmentMaintenance baseRequest) {
43
-        return equipmentMaintenanceService.saveMaintenanceinfo(baseRequest);
44
+    public ResultResponse add(@RequestBody BaseRequest<TEquipmentMaintenanceRequest> baseRequest ) {
45
+        equipmentMaintenanceService.saveMaintenanceinfo(baseRequest.getData());
46
+        return  ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).message(ResultCodeEnum.SUCCESS.getMessage()).build();
47
+
44 48
     }
45 49
 
46 50
     @ApiOperation("修改")
47 51
     @PutMapping("/")
48
-    public Boolean modify(@RequestBody TEquipmentMaintenance baseRequest) {
49
-        return equipmentMaintenanceService.modify(baseRequest);
52
+    public ResultResponse modify(@RequestBody TEquipmentMaintenance baseRequest ) {
53
+           equipmentMaintenanceService.modify(baseRequest);
54
+        return  ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).message(ResultCodeEnum.SUCCESS.getMessage()).build();
50 55
     }
51 56
     @ApiOperation("删除(单个条目)")
52 57
     @DeleteMapping(value = "/{id}")

+ 20 - 6
src/main/java/com/yt/zhylplat/controller/TWoWorkorderbaseController.java

@@ -10,6 +10,7 @@ import com.yt.zhylplat.api.request.BaseRequest;
10 10
 import com.yt.zhylplat.api.request.StatusUpdate;
11 11
 import com.yt.zhylplat.api.request.TWoWorkorderbaseRequest;
12 12
 import com.yt.zhylplat.base.ResultResponse;
13
+import com.yt.zhylplat.common.LoginUserUtil;
13 14
 import com.yt.zhylplat.config.pkx.comn.ORpose;
14 15
 import com.yt.zhylplat.dao.TBaseYhcompanyMapper;
15 16
 import com.yt.zhylplat.dao.TWoWorkorderteamdealinfoMapper;
@@ -262,8 +263,17 @@ public class TWoWorkorderbaseController {
262 263
             Date calendar3 = new java.sql.Timestamp(sdf.parse(date3).getTime());
263 264
            ts.setfRemainderstarttime(calendar3);
264 265
             }
265
-            ts.setfStateid(2);
266
-            ts.setfState("派单");
266
+//            ts.setfStateid(2);
267
+//            ts.setfState("派单");
268
+            ts.setfStateid(3);
269
+            ts.setfState("处理中");
270
+            ts.setCheckdept(ts.getfYhdeptname());
271
+            ts.setChecktime(new Date());
272
+            ts.setCheckusername(LoginUserUtil.getfUsername());
273
+            ts.setfDealres("");
274
+            ts.setCheckresult("1");
275
+            ts.setDisposeresultdesc("处理中");
276
+
267 277
             return itWoWorkorderbaseService.insert(ts);
268 278
         }
269 279
     }
@@ -371,10 +381,14 @@ public class TWoWorkorderbaseController {
371 381
         int SPHJcount = 0;
372 382
         int WLWJcount = 0;
373 383
         int WLHJcount = 0;
374
-         SPHJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().equals("视频捕捉")).collect(Collectors.toList()).size();
375
-        SPWJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().equals("视频捕捉") && t.getfStateid().equals(4)).collect(Collectors.toList()).size();
376
-        WLHJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().equals("物联感知")).collect(Collectors.toList()).size();
377
-        WLWJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().equals("物联感知") && t.getfStateid().equals(4)).collect(Collectors.toList()).size();
384
+         SPHJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().
385
+                 equals("视频捕捉")).collect(Collectors.toList()).size();
386
+        SPWJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().
387
+                equals("视频捕捉") && t.getfStateid().equals(4)).collect(Collectors.toList()).size();
388
+        WLHJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref()
389
+                .equals("物联感知")).collect(Collectors.toList()).size();
390
+        WLWJcount = tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref().
391
+                equals("物联感知") && t.getfStateid().equals(4)).collect(Collectors.toList()).size();
378 392
 
379 393
         map.put("SPHJcount", SPHJcount);
380 394
         map.put("SPWJcount", SPWJcount);

+ 67 - 0
src/main/java/com/yt/zhylplat/controller/TWorkReportController.java

@@ -0,0 +1,67 @@
1
+package com.yt.zhylplat.controller;
2
+
3
+
4
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
5
+import com.yt.zhylplat.annotation.OperationLog;
6
+import com.yt.zhylplat.app.service.AppTrjcBaseService;
7
+import com.yt.zhylplat.base.ResultResponse;
8
+import com.yt.zhylplat.entity.TWorkReport;
9
+import com.yt.zhylplat.moduleZhjc.entity.ZhjcTrjcBase;
10
+import com.yt.zhylplat.service.TWorkReportService;
11
+import io.swagger.annotations.Api;
12
+import io.swagger.annotations.ApiOperation;
13
+import org.springframework.beans.factory.annotation.Autowired;
14
+import org.springframework.web.bind.annotation.*;
15
+
16
+/**
17
+ * <p>
18
+ *  前端控制器
19
+ * </p>
20
+ *
21
+ * @author YTKJ
22
+ * @since 2025-11-17
23
+ */
24
+@Api(tags = {"日周月报"})
25
+@CrossOrigin
26
+@RestController
27
+@RequestMapping("/t-work-report")
28
+public class TWorkReportController {
29
+
30
+    @Autowired
31
+    TWorkReportService workReportService;
32
+
33
+    @PostMapping("/saveWorkReportBase")
34
+    @ApiOperation(value = "日周月报新增方法", notes = "日周月报新增方法")
35
+    @OperationLog(operDesc = "日周月报新增方法")
36
+    public ResultResponse saveWorkReportBase(@RequestBody TWorkReport baseRequest) {
37
+        return workReportService.saveTWorkReport(baseRequest);
38
+    }
39
+
40
+    @PutMapping("/updateWorkReportBase")
41
+    @ApiOperation(value = "日周月报修改方法", notes = "日周月报修改方法")
42
+    @OperationLog(operDesc = "日周月报修改方法")
43
+    public ResultResponse updateWorkReportBase(@RequestBody TWorkReport baseRequest) {
44
+        return workReportService.updateTWorkReport(baseRequest);
45
+    }
46
+
47
+    @DeleteMapping("/{id}")
48
+    @ApiOperation(value = "日周月报删除方法", notes = "日周月报删除方法")
49
+    @OperationLog(operDesc = "日周月报删除方法")
50
+    public ResultResponse deleteWorkReportBase(@PathVariable Integer id) {
51
+        return workReportService.deleteTWorkReport(id);
52
+    }
53
+
54
+    @ApiOperation("根据ID查询日周月报信息")
55
+    @GetMapping(value = "/{id}")
56
+    public ResultResponse selectById(@PathVariable("id") Integer id) {
57
+        return workReportService.selectById(id);
58
+    }
59
+
60
+
61
+    @ApiOperation("分页列表")
62
+    @GetMapping("/page")
63
+    public ResultResponse page(Page page, TWorkReport zhjcTrjcBase) {
64
+        return workReportService.pageList(page,zhjcTrjcBase);
65
+    }
66
+
67
+}

+ 16 - 0
src/main/java/com/yt/zhylplat/dao/TWorkReportMapper.java

@@ -0,0 +1,16 @@
1
+package com.yt.zhylplat.dao;
2
+
3
+import com.yt.zhylplat.entity.TWorkReport;
4
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
5
+
6
+/**
7
+ * <p>
8
+ *  Mapper 接口
9
+ * </p>
10
+ *
11
+ * @author YTKJ
12
+ * @since 2025-11-17
13
+ */
14
+public interface TWorkReportMapper extends BaseMapper<TWorkReport> {
15
+
16
+}

+ 25 - 0
src/main/java/com/yt/zhylplat/entity/TBaseDriveinfo.java

@@ -12,6 +12,7 @@ package com.yt.zhylplat.entity;
12 12
     import lombok.Data;
13 13
     import lombok.EqualsAndHashCode;
14 14
     import lombok.experimental.Accessors;
15
+    import org.bouncycastle.pqc.crypto.newhope.NHOtherInfoGenerator;
15 16
 
16 17
 /**
17 18
 * <p>
@@ -272,6 +273,30 @@ package com.yt.zhylplat.entity;
272 273
         @TableField("F_WGS84X")
273 274
     private String fWgs84x;
274 275
 
276
+    @TableField("F_Channel")
277
+    private Integer fChannel;
278
+
279
+    @TableField("F_URL")
280
+    private String url;
281
+
282
+
283
+    public String getUrl() {
284
+        return url;
285
+    }
286
+
287
+    public void setUrl(String url) {
288
+        this.url = url;
289
+    }
290
+
291
+    public Integer getfChannel()
292
+    {
293
+        return fChannel;
294
+    }
295
+
296
+    public void setfChannel(Integer fChannel) {
297
+        this.fChannel = fChannel;
298
+    }
299
+
275 300
     public static long getSerialVersionUID() {
276 301
         return serialVersionUID;
277 302
     }

+ 16 - 0
src/main/java/com/yt/zhylplat/entity/TBaseFacilityinfo.java

@@ -196,4 +196,20 @@ public class TBaseFacilityinfo implements Serializable {
196 196
     @ApiModelProperty(value = "环境数据")
197 197
     @TableField("environment")
198 198
     private String environment;
199
+
200
+    /**
201
+     * 到期时间
202
+     */
203
+    @ApiModelProperty(value = "到期时间")
204
+    @TableField("expiration_time")
205
+    private Date expirationTime;
206
+
207
+
208
+    /**
209
+     * 是否发送短信
210
+     */
211
+    @ApiModelProperty(value = "是否发送短信")
212
+    @TableField("is_sms")
213
+    private Integer isSms;
214
+
199 215
 }

+ 45 - 0
src/main/java/com/yt/zhylplat/entity/TBaseParkinfo.java

@@ -325,6 +325,51 @@ public class TBaseParkinfo implements Serializable {
325 325
     @TableField("flag2")
326 326
     private Integer flag2;
327 327
 
328
+    @ApiModelProperty(value = "信用评分")
329
+    @TableField("credit_score")
330
+    private Integer creditScore;
331
+    @ApiModelProperty(value = "信用等级")
332
+    @TableField("credit_level")
333
+    private String creditLevel;
334
+    @ApiModelProperty(value = "风险评分")
335
+    @TableField("risk_score")
336
+    private Integer riskScore;
337
+    @ApiModelProperty(value = "风险等级")
338
+    @TableField("risk_level")
339
+    private String riskLevel;
340
+
341
+    public Integer getCreditScore() {
342
+        return creditScore;
343
+    }
344
+
345
+    public void setCreditScore(Integer creditScore) {
346
+        this.creditScore = creditScore;
347
+    }
348
+
349
+    public String getCreditLevel() {
350
+        return creditLevel;
351
+    }
352
+
353
+    public void setCreditLevel(String creditLevel) {
354
+        this.creditLevel = creditLevel;
355
+    }
356
+
357
+    public Integer getRiskScore() {
358
+        return riskScore;
359
+    }
360
+
361
+    public void setRiskScore(Integer riskScore) {
362
+        this.riskScore = riskScore;
363
+    }
364
+
365
+    public String getRiskLevel() {
366
+        return riskLevel;
367
+    }
368
+
369
+    public void setRiskLevel(String riskLevel) {
370
+        this.riskLevel = riskLevel;
371
+    }
372
+
328 373
 
329 374
     /**
330 375
      * 公园顶图片

+ 9 - 0
src/main/java/com/yt/zhylplat/entity/TEquipmentMaintenance.java

@@ -1,6 +1,9 @@
1 1
 package com.yt.zhylplat.entity;
2 2
 
3 3
     import java.math.BigDecimal;
4
+
5
+    import com.baomidou.mybatisplus.annotation.IdType;
6
+    import com.baomidou.mybatisplus.annotation.TableId;
4 7
     import com.baomidou.mybatisplus.annotation.TableName;
5 8
     import java.util.Date;
6 9
     import java.time.LocalDateTime;
@@ -31,6 +34,12 @@ package com.yt.zhylplat.entity;
31 34
 
32 35
     private static final long serialVersionUID = 1L;
33 36
 
37
+
38
+    @ApiModelProperty(value = "id")
39
+    @TableId(type = IdType.AUTO)
40
+    private Integer id;
41
+
42
+
34 43
             @ApiModelProperty(value = "设备编号")
35 44
         @TableField("equipment_id")
36 45
     private Integer equipmentId;

+ 7 - 3
src/main/java/com/yt/zhylplat/entity/TEquipmentMaintenanceRequest.java

@@ -1,6 +1,8 @@
1 1
 package com.yt.zhylplat.entity;
2 2
 
3
+import com.baomidou.mybatisplus.annotation.IdType;
3 4
 import com.baomidou.mybatisplus.annotation.TableField;
5
+import com.baomidou.mybatisplus.annotation.TableId;
4 6
 import com.baomidou.mybatisplus.annotation.TableName;
5 7
 import com.yt.zhylplat.api.request.BasePageRequest;
6 8
 import io.swagger.annotations.ApiModel;
@@ -28,7 +30,9 @@ import java.util.Date;
28 30
 public class TEquipmentMaintenanceRequest extends BasePageRequest {
29 31
 
30 32
     private static final long serialVersionUID = 1L;
31
-
33
+    @ApiModelProperty(value = "id")
34
+    @TableId(type = IdType.AUTO)
35
+    private Integer id;
32 36
     @ApiModelProperty(value = "设备编号")
33 37
     @TableField("equipment_id")
34 38
     private Integer equipmentId;
@@ -83,11 +87,11 @@ public class TEquipmentMaintenanceRequest extends BasePageRequest {
83 87
 
84 88
     @ApiModelProperty(value = "创建时间")
85 89
     @TableField("created_at")
86
-    private LocalDateTime createdAt;
90
+    private Date createdAt;
87 91
 
88 92
     @ApiModelProperty(value = "更新时间")
89 93
     @TableField("updated_at")
90
-    private LocalDateTime updatedAt;
94
+    private Date updatedAt;
91 95
 
92 96
     @ApiModelProperty(value = "公园id")
93 97
     @TableField("park_id")

+ 41 - 0
src/main/java/com/yt/zhylplat/entity/TWoWorkorderbase.java

@@ -410,12 +410,28 @@ public class TWoWorkorderbase implements Serializable {
410 410
 
411 411
 
412 412
     /**
413
+     * 抄送人
414
+     */
415
+    @TableField("cc")
416
+    private Integer cc;
417
+
418
+    @TableField("cc_name")
419
+    private String ccName;
420
+
421
+    /**
413 422
      * 是否典型
414 423
      */
415 424
     @TableField("F_Typical")
416 425
     private  Integer fTypical;
417 426
 
418 427
     /**
428
+     * 整改要求
429
+     */
430
+    @TableField("rectification")
431
+    private  String rectification;
432
+
433
+
434
+    /**
419 435
      * 施工单位名称
420 436
      */
421 437
     @TableField("F_SGDeptName")
@@ -568,6 +584,21 @@ public class TWoWorkorderbase implements Serializable {
568 584
         this.fRiskLevel = fRiskLevel;
569 585
     }
570 586
 
587
+    public Integer getCc() {
588
+        return cc;
589
+    }
590
+
591
+    public void setCc(Integer cc) {
592
+        this.cc = cc;
593
+    }
594
+
595
+
596
+    public String getCcName() {
597
+        return ccName;
598
+    }
599
+    public void setCcName(String ccName) {
600
+        this.ccName = ccName;
601
+    }
571 602
 
572 603
     public Date getPushtime() {
573 604
         return pushtime;
@@ -1259,4 +1290,14 @@ public class TWoWorkorderbase implements Serializable {
1259 1290
     public void setSynctimeCypt(Date synctimeCypt) {
1260 1291
         this.synctimeCypt = synctimeCypt;
1261 1292
     }
1293
+
1294
+
1295
+    public void setRectification(String rectification) {
1296
+        this.rectification = rectification;
1297
+    }
1298
+
1299
+    public String getRectification() {
1300
+        return rectification;
1301
+    }
1302
+
1262 1303
 }

+ 82 - 0
src/main/java/com/yt/zhylplat/entity/TWorkReport.java

@@ -0,0 +1,82 @@
1
+package com.yt.zhylplat.entity;
2
+
3
+    import com.baomidou.mybatisplus.annotation.IdType;
4
+    import com.baomidou.mybatisplus.annotation.TableId;
5
+    import com.baomidou.mybatisplus.annotation.TableName;
6
+    import java.util.Date;
7
+    import com.baomidou.mybatisplus.annotation.TableField;
8
+    import java.io.Serializable;
9
+    import io.swagger.annotations.ApiModel;
10
+    import io.swagger.annotations.ApiModelProperty;
11
+    import lombok.Data;
12
+    import lombok.EqualsAndHashCode;
13
+    import lombok.experimental.Accessors;
14
+
15
+/**
16
+* <p>
17
+    * 
18
+    * </p>
19
+*
20
+* @author YTKJ
21
+* @since 2025-11-17
22
+*/
23
+    @Data
24
+        @EqualsAndHashCode(callSuper = false)
25
+    @Accessors(chain = true)
26
+    @TableName("T_Work_Report")
27
+    @ApiModel(value="TWorkReport对象", description="")
28
+    public class TWorkReport implements Serializable {
29
+
30
+    private static final long serialVersionUID = 1L;
31
+
32
+
33
+    @ApiModelProperty(value = "自增id")
34
+    @TableId(value = "id", type = IdType.AUTO)
35
+    private Integer id;
36
+
37
+            @ApiModelProperty(value = "类型1日2周3月")
38
+        @TableField("type")
39
+    private Integer type;
40
+
41
+            @ApiModelProperty(value = "管养班组")
42
+        @TableField("team")
43
+    private String team;
44
+
45
+            @ApiModelProperty(value = "人数")
46
+        @TableField("number")
47
+    private Integer number;
48
+
49
+            @ApiModelProperty(value = "负责人")
50
+        @TableField("superintendent")
51
+    private String superintendent;
52
+
53
+            @ApiModelProperty(value = "工作开始时间")
54
+        @TableField("work_start_time")
55
+    private Date workStartTime;
56
+
57
+            @ApiModelProperty(value = "工作结束时间")
58
+        @TableField("work_end_time")
59
+    private Date workEndTime;
60
+
61
+            @ApiModelProperty(value = "工作内容")
62
+        @TableField("work_content")
63
+    private String workContent;
64
+
65
+            @ApiModelProperty(value = "未完成工作")
66
+        @TableField("unfinished_work")
67
+    private String unfinishedWork;
68
+
69
+            @ApiModelProperty(value = "创建时间")
70
+        @TableField("create_time")
71
+    private Date createTime;
72
+
73
+            @ApiModelProperty(value = "更新时间")
74
+        @TableField("update_time")
75
+    private Date updateTime;
76
+
77
+            @ApiModelProperty(value = "添加人")
78
+        @TableField("create_user")
79
+    private String createUser;
80
+
81
+
82
+}

+ 41 - 8
src/main/java/com/yt/zhylplat/moduleGygy/controller/GygyScheduleController.java

@@ -8,6 +8,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
8 8
 import com.yt.zhylplat.appController.SendMessageWxController;
9 9
 import com.yt.zhylplat.base.Assert;
10 10
 import com.yt.zhylplat.common.GenerateCode;
11
+import com.yt.zhylplat.common.LoginUserUtil;
11 12
 import com.yt.zhylplat.dao.TSysUseraccountMapper;
12 13
 import com.yt.zhylplat.dao.TWoWorkorderbaseMapper;
13 14
 import com.yt.zhylplat.entity.*;
@@ -178,8 +179,16 @@ public class GygyScheduleController {
178 179
                 String phone = "";
179 180
 
180 181
                 TWoWorkorderbase tWoWorkorderbase = new TWoWorkorderbase();
181
-                tWoWorkorderbase.setfStateid(2);
182
-                tWoWorkorderbase.setfState("派单");
182
+//                tWoWorkorderbase.setfStateid(2);
183
+//                tWoWorkorderbase.setfState("派单");
184
+                tWoWorkorderbase.setfStateid(3);
185
+                tWoWorkorderbase.setfState("处理中");
186
+                tWoWorkorderbase.setCheckdept(tWoWorkorderbase.getfYhdeptname());
187
+                tWoWorkorderbase.setChecktime(new Date());
188
+                tWoWorkorderbase.setCheckusername(LoginUserUtil.getfUsername());
189
+                tWoWorkorderbase.setfDealres("");
190
+                tWoWorkorderbase.setCheckresult("1");
191
+                tWoWorkorderbase.setDisposeresultdesc("处理中");
183 192
                 tWoWorkorderbase.setfWorkordertypeid(4);
184 193
                 tWoWorkorderbase.setfWorkordertype("智能发现");
185 194
                 tWoWorkorderbase.setfCustomername("智能发现");
@@ -524,8 +533,16 @@ public class GygyScheduleController {
524 533
                 String phone = "";
525 534
 
526 535
                 TWoWorkorderbase tWoWorkorderbase = new TWoWorkorderbase();
527
-                tWoWorkorderbase.setfStateid(2);
528
-                tWoWorkorderbase.setfState("派单");
536
+//                tWoWorkorderbase.setfStateid(2);
537
+//                tWoWorkorderbase.setfState("派单");
538
+                tWoWorkorderbase.setfStateid(3);
539
+                tWoWorkorderbase.setfState("处理中");
540
+                tWoWorkorderbase.setCheckdept(tWoWorkorderbase.getfYhdeptname());
541
+                tWoWorkorderbase.setChecktime(new Date());
542
+                tWoWorkorderbase.setCheckusername(LoginUserUtil.getfUsername());
543
+                tWoWorkorderbase.setfDealres("");
544
+                tWoWorkorderbase.setCheckresult("1");
545
+                tWoWorkorderbase.setDisposeresultdesc("处理中");
529 546
                 tWoWorkorderbase.setfWorkordertypeid(4);
530 547
                 tWoWorkorderbase.setfWorkordertype("智能发现");
531 548
                 tWoWorkorderbase.setfCustomername("智能发现");
@@ -752,8 +769,16 @@ public class GygyScheduleController {
752 769
                 String phone = "";
753 770
 
754 771
                 TWoWorkorderbase tWoWorkorderbase = new TWoWorkorderbase();
755
-                tWoWorkorderbase.setfStateid(2);
756
-                tWoWorkorderbase.setfState("派单");
772
+//                tWoWorkorderbase.setfStateid(2);
773
+//                tWoWorkorderbase.setfState("派单");
774
+                tWoWorkorderbase.setfStateid(3);
775
+                tWoWorkorderbase.setfState("处理中");
776
+                tWoWorkorderbase.setCheckdept(tWoWorkorderbase.getfYhdeptname());
777
+                tWoWorkorderbase.setChecktime(new Date());
778
+                tWoWorkorderbase.setCheckusername(LoginUserUtil.getfUsername());
779
+                tWoWorkorderbase.setfDealres("");
780
+                tWoWorkorderbase.setCheckresult("1");
781
+                tWoWorkorderbase.setDisposeresultdesc("处理中");
757 782
                 tWoWorkorderbase.setfWorkordertypeid(4);
758 783
                 tWoWorkorderbase.setfWorkordertype("智能发现");
759 784
                 tWoWorkorderbase.setfCustomername("智能发现");
@@ -996,8 +1021,16 @@ public class GygyScheduleController {
996 1021
         }
997 1022
         //创建工单
998 1023
         TWoWorkorderbase tWoWorkorderbase = new TWoWorkorderbase();
999
-        tWoWorkorderbase.setfStateid(2);
1000
-        tWoWorkorderbase.setfState("派单");
1024
+//        tWoWorkorderbase.setfStateid(2);
1025
+//        tWoWorkorderbase.setfState("派单");
1026
+        tWoWorkorderbase.setfStateid(3);
1027
+        tWoWorkorderbase.setfState("处理中");
1028
+        tWoWorkorderbase.setCheckdept(tWoWorkorderbase.getfYhdeptname());
1029
+        tWoWorkorderbase.setChecktime(new Date());
1030
+        tWoWorkorderbase.setCheckusername(LoginUserUtil.getfUsername());
1031
+        tWoWorkorderbase.setfDealres("");
1032
+        tWoWorkorderbase.setCheckresult("1");
1033
+        tWoWorkorderbase.setDisposeresultdesc("处理中");
1001 1034
         tWoWorkorderbase.setfWorkordertypeid(4);
1002 1035
         tWoWorkorderbase.setfWorkordertype("智能发现");
1003 1036
         tWoWorkorderbase.setfCustomername("智能发现");

+ 8 - 0
src/main/java/com/yt/zhylplat/moduleLhgy/controller/LhgyWorkOrderBaseAppController.java

@@ -79,6 +79,13 @@ public class LhgyWorkOrderBaseAppController {
79 79
         return workorderbaseService.savePatrolTrack(baseRequest.getData());
80 80
     }
81 81
 
82
+    @PostMapping("/patrolTrackIsSpeeding")
83
+    @ApiOperation(value = "绿化科小程序生成巡查记录", notes = "绿化科小程序生成巡查记录")
84
+    @OperationLog(operDesc = "绿化科小程序生成巡查记录")
85
+    public ResultResponse patrolTrackIsSpeeding(@RequestBody BaseRequest<TLhgyPatrolTrackRequest> baseRequest) {
86
+        return workorderbaseService.savePatrolTrack(baseRequest.getData());
87
+    }
88
+
82 89
     @PostMapping("/savePatrolTrackFile")
83 90
     @ApiOperation(value = "绿化科小程序巡视巡查问题上传", notes = "绿化科小程序巡视巡查问题上传")
84 91
     @OperationLog(operDesc = "绿化科小程序巡视巡查问题上传")
@@ -94,6 +101,7 @@ public class LhgyWorkOrderBaseAppController {
94 101
     }
95 102
 
96 103
 
104
+
97 105
     @PostMapping("/selectPatrolTrackByPage")
98 106
     @ApiOperation(value = "绿化科小程序查询巡视巡查", notes = "绿化科小程序查询巡视巡查")
99 107
     @OperationLog(operDesc = "绿化科小程序查询巡视巡查")

+ 89 - 84
src/main/java/com/yt/zhylplat/moduleLhgy/service/impl/LhgyWorkOrderBaseServiceImpl.java

@@ -1233,6 +1233,10 @@ public class LhgyWorkOrderBaseServiceImpl extends ServiceImpl<TWoWorkorderbaseMa
1233 1233
     }
1234 1234
 
1235 1235
 
1236
+
1237
+
1238
+
1239
+
1236 1240
     @Override
1237 1241
     @Transactional(rollbackFor = Exception.class)
1238 1242
     public ResultResponse savePatrolTrack(TLhgyPatrolTrackRequest requestData) {
@@ -1643,17 +1647,17 @@ public class LhgyWorkOrderBaseServiceImpl extends ServiceImpl<TWoWorkorderbaseMa
1643 1647
         tWoWorkorderbase.setfCode(GenerateCode.generateNo("gyykljc"));//工单编号
1644 1648
         tWoWorkorderbase.setPushtime(tWoWorkorderbase.getfCreatedate());
1645 1649
         tWoWorkorderbase.setfFromcode(GenerateCode.generateWorkFromCode());
1646
-        tWoWorkorderbase.setfStateid(2);
1647
-        tWoWorkorderbase.setfState("派单");
1650
+        tWoWorkorderbase.setfStateid(1);
1651
+        tWoWorkorderbase.setfState("日常");
1648 1652
         tWoWorkorderbase.setfFromtype("巡视巡查");
1649 1653
         tWoWorkorderbase.setfCategoryid1(27);
1650 1654
         tWoWorkorderbase.setfCategoryname1("巡视巡查");
1651 1655
         tWoWorkorderbase.setfFromref("移动巡查");
1652 1656
 
1653
-        TBaseYhcompany yhcompany = null;
1657
+     //   TBaseYhcompany yhcompany = null;
1654 1658
         String phone = "";
1655 1659
 
1656
-        List<TSysUseraccount> sysUseraccounts = new ArrayList<>();
1660
+     //   List<TSysUseraccount> sysUseraccounts = new ArrayList<>();
1657 1661
 
1658 1662
         // 巡查单
1659 1663
         TLhgyPatrolTrack patrolTrack = null;
@@ -1661,74 +1665,75 @@ public class LhgyWorkOrderBaseServiceImpl extends ServiceImpl<TWoWorkorderbaseMa
1661 1665
         TLhzxMaintenanceCompany maintenanceCompany = null;
1662 1666
         // 标段信息
1663 1667
         TLhzxSection section = null;
1664
-        Integer sectionId = null;
1665
-        String sectionName = "";
1668
+//        Integer sectionId = null;
1669
+//        String sectionName = "";
1666 1670
         // 根据巡查单id查询巡查单 区级
1667
-        if (tPestcPatrolTrackIssue.getIssueType() == 2){
1668
-            // 巡查单
1669
-            patrolTrack = patrolTrackMapper.selectById(tPestcPatrolTrackIssue.getPatrolId());
1670
-
1671
-            Assert.assertTrue(patrolTrack.getNumber3() == null, "当前巡视巡查未选择养护单位");
1672
-
1673
-            yhcompany = yhcompanyMapper.selectById(patrolTrack.getNumber3());
1674
-            Assert.assertTrue(yhcompany == null, "工单对应养护单位id无法查询到养护单位信息");
1675
-
1676
-            //根据养护单位ID + 标段ID 获取到项目经理
1677
-            List<TLhgySectionCompany> sectionCompanyList = sectionCompanyMapper.selectList(new QueryWrapper<TLhgySectionCompany>().lambda()
1678
-                    .eq(TLhgySectionCompany::getYhCompanyId, yhcompany.getfYhcompanyid())
1679
-                    .eq(TLhgySectionCompany::getSectionId, patrolTrack.getObjectId()));
1680
-            Assert.assertTrue(sectionCompanyList.size() == 0, "当前巡查标段对应的养护单位下未维护项目经理对应关系");
1681
-
1682
-            List<Integer> userIds = sectionCompanyList.stream().map(TLhgySectionCompany::getUserId).distinct().collect(Collectors.toList());
1683
-            //养护单位账号
1684
-            sysUseraccounts = tSysUseraccountMapper.selectList(new QueryWrapper<TSysUseraccount>().lambda()
1685
-                    .in(TSysUseraccount::getfUserid, userIds)
1686
-                    .eq(TSysUseraccount::getfDeleteflag, 0));
1687
-            Assert.assertTrue(sysUseraccounts.size() == 0, "当前养护单位无法查询到项目经理账户信息");
1688
-
1689
-            sectionId = patrolTrack.getObjectId();
1690
-            sectionName = patrolTrack.getObjectName();
1691
-        }// 市级
1692
-        else if (tPestcPatrolTrackIssue.getIssueType() == 1){
1693
-            // pestcPatrolTrack = pestcPatrolTrackService.selectById(tPestcPatrolTrackIssue.getPatrolId());
1694
-            Assert.assertTrue(tPestcPatrolTrackIssue.getSectionId() == null, "请选择选择标段");
1695
-            Assert.assertTrue(tPestcPatrolTrackIssue.getMaintenanceCompanyId() == null, "请选择选择养护单位");
1696
-            // 查询养护公司信息
1697
-            maintenanceCompany = maintenanceCompanyService.selectById(tPestcPatrolTrackIssue.getMaintenanceCompanyId());
1698
-            Assert.assertTrue(maintenanceCompany == null, "工单对应养护单位id无法查询到养护单位信息");
1699
-            yhcompany = yhcompanyMapper.selectById(maintenanceCompany.getOldMaintenanceCompanyId());
1700
-            // 标段信息
1701
-            section = sectionService.selectById(tPestcPatrolTrackIssue.getSectionId());
1702
-            Assert.assertTrue(section == null, "工单对应标段id无法查询到标段信息");
1703
-
1704
-            //根据养护单位ID + 标段ID 获取到项目经理
1705
-            List<TLhgySectionCompany> sectionCompanyList = sectionCompanyMapper.selectList(new QueryWrapper<TLhgySectionCompany>().lambda()
1706
-                    .eq(TLhgySectionCompany::getYhCompanyId, maintenanceCompany.getOldMaintenanceCompanyId())
1707
-                    .eq(TLhgySectionCompany::getSectionId, section.getOldSectionId()));
1708
-            Assert.assertTrue(sectionCompanyList.size() == 0, "当前巡查标段对应的养护单位下未维护项目经理对应关系");
1709
-
1710
-            List<Integer> userIds = sectionCompanyList.stream().map(TLhgySectionCompany::getUserId).distinct().collect(Collectors.toList());
1711
-            //养护单位账号
1712
-            sysUseraccounts = tSysUseraccountMapper.selectList(new QueryWrapper<TSysUseraccount>().lambda()
1713
-                    .in(TSysUseraccount::getfUserid, userIds)
1714
-                    .eq(TSysUseraccount::getfDeleteflag, 0));
1715
-            Assert.assertTrue(sysUseraccounts.size() == 0, "当前养护单位无法查询到项目经理账户信息");
1716
-
1717
-            sectionId = section.getOldSectionId();
1718
-            sectionName = section.getSectionName();
1719
-        } else {
1720
-            return -1;
1721
-        }
1722
-
1723
-        tWoWorkorderbase.setfGlsx(yhcompany.getfGlsx());
1724
-        tWoWorkorderbase.setfGlsy(yhcompany.getfGlsy());
1725
-        tWoWorkorderbase.setfYhuserid(sysUseraccounts.get(0).getfUserid());
1726
-        tWoWorkorderbase.setfYhusername(sysUseraccounts.get(0).getfUsername());
1727
-        tWoWorkorderbase.setfYhdeptid(yhcompany.getfYhcompanyid());
1728
-        tWoWorkorderbase.setfYhdeptname(yhcompany.getfDeptname());
1729
-        tWoWorkorderbase.setfRegionname(yhcompany.getfAddress());
1730
-        tWoWorkorderbase.setfSguserid(sectionId);
1731
-        tWoWorkorderbase.setfSgusername(sectionName);
1671
+        patrolTrack = patrolTrackMapper.selectById(tPestcPatrolTrackIssue.getPatrolId());
1672
+//        if (tPestcPatrolTrackIssue.getIssueType() == 2){
1673
+//            // 巡查单
1674
+//            patrolTrack = patrolTrackMapper.selectById(tPestcPatrolTrackIssue.getPatrolId());
1675
+//
1676
+//            Assert.assertTrue(patrolTrack.getNumber3() == null, "当前巡视巡查未选择养护单位");
1677
+//
1678
+//            yhcompany = yhcompanyMapper.selectById(patrolTrack.getNumber3());
1679
+//            Assert.assertTrue(yhcompany == null, "工单对应养护单位id无法查询到养护单位信息");
1680
+//
1681
+//            //根据养护单位ID + 标段ID 获取到项目经理
1682
+//            List<TLhgySectionCompany> sectionCompanyList = sectionCompanyMapper.selectList(new QueryWrapper<TLhgySectionCompany>().lambda()
1683
+//                    .eq(TLhgySectionCompany::getYhCompanyId, yhcompany.getfYhcompanyid())
1684
+//                    .eq(TLhgySectionCompany::getSectionId, patrolTrack.getObjectId()));
1685
+//            Assert.assertTrue(sectionCompanyList.size() == 0, "当前巡查标段对应的养护单位下未维护项目经理对应关系");
1686
+//
1687
+//            List<Integer> userIds = sectionCompanyList.stream().map(TLhgySectionCompany::getUserId).distinct().collect(Collectors.toList());
1688
+//            //养护单位账号
1689
+//            sysUseraccounts = tSysUseraccountMapper.selectList(new QueryWrapper<TSysUseraccount>().lambda()
1690
+//                    .in(TSysUseraccount::getfUserid, userIds)
1691
+//                    .eq(TSysUseraccount::getfDeleteflag, 0));
1692
+//            Assert.assertTrue(sysUseraccounts.size() == 0, "当前养护单位无法查询到项目经理账户信息");
1693
+//
1694
+//            sectionId = patrolTrack.getObjectId();
1695
+//            sectionName = patrolTrack.getObjectName();
1696
+//        }// 市级
1697
+//        else if (tPestcPatrolTrackIssue.getIssueType() == 1){
1698
+//            // pestcPatrolTrack = pestcPatrolTrackService.selectById(tPestcPatrolTrackIssue.getPatrolId());
1699
+//            Assert.assertTrue(tPestcPatrolTrackIssue.getSectionId() == null, "请选择选择标段");
1700
+//            Assert.assertTrue(tPestcPatrolTrackIssue.getMaintenanceCompanyId() == null, "请选择选择养护单位");
1701
+//            // 查询养护公司信息
1702
+//            maintenanceCompany = maintenanceCompanyService.selectById(tPestcPatrolTrackIssue.getMaintenanceCompanyId());
1703
+//            Assert.assertTrue(maintenanceCompany == null, "工单对应养护单位id无法查询到养护单位信息");
1704
+//            yhcompany = yhcompanyMapper.selectById(maintenanceCompany.getOldMaintenanceCompanyId());
1705
+//            // 标段信息
1706
+//            section = sectionService.selectById(tPestcPatrolTrackIssue.getSectionId());
1707
+//            Assert.assertTrue(section == null, "工单对应标段id无法查询到标段信息");
1708
+//
1709
+//            //根据养护单位ID + 标段ID 获取到项目经理
1710
+//            List<TLhgySectionCompany> sectionCompanyList = sectionCompanyMapper.selectList(new QueryWrapper<TLhgySectionCompany>().lambda()
1711
+//                    .eq(TLhgySectionCompany::getYhCompanyId, maintenanceCompany.getOldMaintenanceCompanyId())
1712
+//                    .eq(TLhgySectionCompany::getSectionId, section.getOldSectionId()));
1713
+//            Assert.assertTrue(sectionCompanyList.size() == 0, "当前巡查标段对应的养护单位下未维护项目经理对应关系");
1714
+//
1715
+//            List<Integer> userIds = sectionCompanyList.stream().map(TLhgySectionCompany::getUserId).distinct().collect(Collectors.toList());
1716
+//            //养护单位账号
1717
+//            sysUseraccounts = tSysUseraccountMapper.selectList(new QueryWrapper<TSysUseraccount>().lambda()
1718
+//                    .in(TSysUseraccount::getfUserid, userIds)
1719
+//                    .eq(TSysUseraccount::getfDeleteflag, 0));
1720
+//            Assert.assertTrue(sysUseraccounts.size() == 0, "当前养护单位无法查询到项目经理账户信息");
1721
+//
1722
+//            sectionId = section.getOldSectionId();
1723
+//            sectionName = section.getSectionName();
1724
+//        } else {
1725
+//            return -1;
1726
+//        }
1727
+
1728
+   //     tWoWorkorderbase.setfGlsx(yhcompany.getfGlsx());
1729
+   //     tWoWorkorderbase.setfGlsy(yhcompany.getfGlsy());
1730
+  //      tWoWorkorderbase.setfYhuserid(sysUseraccounts.get(0).getfUserid());
1731
+    //    tWoWorkorderbase.setfYhusername(sysUseraccounts.get(0).getfUsername());
1732
+   //     tWoWorkorderbase.setfYhdeptid(yhcompany.getfYhcompanyid());
1733
+ //       tWoWorkorderbase.setfYhdeptname(yhcompany.getfDeptname());
1734
+   //     tWoWorkorderbase.setfRegionname(yhcompany.getfAddress());
1735
+       // tWoWorkorderbase.setfSguserid(sectionId);
1736
+       // tWoWorkorderbase.setfSgusername(sectionName);
1732 1737
         tWoWorkorderbase.setRiskclassifyname("巡视巡查");//
1733 1738
         tWoWorkorderbase.setfRegionid(0);
1734 1739
         tWoWorkorderbase.setfDeleteflag(0);//
@@ -1746,8 +1751,8 @@ public class LhgyWorkOrderBaseServiceImpl extends ServiceImpl<TWoWorkorderbaseMa
1746 1751
         tWoWorkorderbase.setDeptType(2);
1747 1752
 
1748 1753
         //经济运行平台监管要素编码
1749
-        TPdjgWorkorderCategory workorderCategory = workorderCategoryService.selectByCategoryId(tWoWorkorderbase.getfCategoryid1(), 1);
1750
-        tWoWorkorderbase.setRegulationCode(workorderCategory != null ? workorderCategory.getRegulationCode() : null);
1754
+      //  TPdjgWorkorderCategory workorderCategory = workorderCategoryService.selectByCategoryId(tWoWorkorderbase.getfCategoryid1(), 1);
1755
+     //   tWoWorkorderbase.setRegulationCode(workorderCategory != null ? workorderCategory.getRegulationCode() : null);
1751 1756
 
1752 1757
         String address = "";
1753 1758
         // 区级 踏查
@@ -1835,12 +1840,12 @@ public class LhgyWorkOrderBaseServiceImpl extends ServiceImpl<TWoWorkorderbaseMa
1835 1840
         }
1836 1841
 
1837 1842
         // 如果不是养护单位自己创建的工单,给养护单位添加一条短信发送任务
1838
-        if (tWoWorkorderbase.getfCreateid() != tWoWorkorderbase.getfYhuserid()) {
1839
-            for (TSysUseraccount sysUseraccount : sysUseraccounts) {
1840
-                phone = sysUseraccount.getfMobile();
1841
-                smsSendsmstaskService.insertSmsSendTask(phone, tWoWorkorderbase.getfCreateid(), tWoWorkorderbase.getfCreatename(), tWoWorkorderbase.getfCode(), tWoWorkorderbase.getfWorkordertype());
1842
-            }
1843
-        }
1843
+//        if (tWoWorkorderbase.getfCreateid() != tWoWorkorderbase.getfYhuserid()) {
1844
+//            for (TSysUseraccount sysUseraccount : sysUseraccounts) {
1845
+//                phone = sysUseraccount.getfMobile();
1846
+//                smsSendsmstaskService.insertSmsSendTask(phone, tWoWorkorderbase.getfCreateid(), tWoWorkorderbase.getfCreatename(), tWoWorkorderbase.getfCode(), tWoWorkorderbase.getfWorkordertype());
1847
+//            }
1848
+//        }
1844 1849
 
1845 1850
         //创建工单详情
1846 1851
         TWoWorkorderdetail woWorkorderdetail = new TWoWorkorderdetail();
@@ -1849,15 +1854,15 @@ public class LhgyWorkOrderBaseServiceImpl extends ServiceImpl<TWoWorkorderbaseMa
1849 1854
 
1850 1855
         //创建工单任务单
1851 1856
         TWoWorkordertask tWoWorkordertask = new TWoWorkordertask();
1852
-        for (TSysUseraccount sysUseraccount : sysUseraccounts) {
1853
-            tWoWorkordertask = workordertaskService.insertWorkOrderTask(tWoWorkorderbase, sysUseraccount.getfUserid());
1854
-        }
1857
+//        for (TSysUseraccount sysUseraccount : sysUseraccounts) {
1858
+//            tWoWorkordertask = workordertaskService.insertWorkOrderTask(tWoWorkorderbase, sysUseraccount.getfUserid());
1859
+//        }
1855 1860
         //创建工单历史信息单(创建)
1856 1861
         TWoWorkordertaskdealinfo workordertaskdealinfo = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(tWoWorkorderbase.getfContent(), tWoWorkorderbase, 1, tWoWorkordertask.getfTaskid(), tWoWorkorderbase.getfYhdeptid(), tWoWorkorderbase.getfYhuserid());
1857 1862
         //创建工单历史信息单(派单)
1858
-        TWoWorkordertaskdealinfo workordertaskdealinfo1 = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(tWoWorkorderbase.getfContent(), tWoWorkorderbase, 2, tWoWorkordertask.getfTaskid(), tWoWorkorderbase.getfYhdeptid(), tWoWorkorderbase.getfYhuserid());
1863
+      //  TWoWorkordertaskdealinfo workordertaskdealinfo1 = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(tWoWorkorderbase.getfContent(), tWoWorkorderbase, 2, tWoWorkordertask.getfTaskid(), tWoWorkorderbase.getfYhdeptid(), tWoWorkorderbase.getfYhuserid());
1859 1864
         //上传图片至工单图片表
1860
-        insertPatrolTrackFile(zgzsFileList, tWoWorkorderbase, workordertaskdealinfo1.getfTaskinfoid());
1865
+       insertPatrolTrackFile(zgzsFileList, tWoWorkorderbase, workordertaskdealinfo.getfTaskinfoid());
1861 1866
 
1862 1867
         return tWoWorkorderbase.getfWorkorderid();
1863 1868
     }

+ 2 - 1
src/main/java/com/yt/zhylplat/modulePest/patrolTrack/service/impl/TPestcPatrolTrackIssueServiceImpl.java

@@ -319,7 +319,8 @@ public class TPestcPatrolTrackIssueServiceImpl extends ServiceImpl<TPestcPatrolT
319 319
             List<TLhzxCenterEmployeePosition> centerEmployeePositionList = centerEmployeePositionService.listByEntity(centerEmployeePosition);
320 320
             if (centerEmployeePositionList != null && centerEmployeePositionList.size() > 0){
321 321
                 // 推送给科长
322
-                smsSendsmstaskService.insertSmsSendTask(centerEmployeePositionList.get(0).getCenterTelPhone(), LoginUserUtil.getfUserid(), LoginUserUtil.getfUsername(), workOrderId + "", "日常管理养护");
322
+                smsSendsmstaskService.insertSmsSendTask(centerEmployeePositionList.get(0).getCenterTelPhone(), LoginUserUtil.getfUserid(),
323
+                        LoginUserUtil.getfUsername(), workOrderId + "", "日常管理养护");
323 324
             }
324 325
             centerEmployeePosition.setJobLevel(2);
325 326
             centerEmployeePosition.setProjectName("有害生物防控");

+ 5 - 0
src/main/java/com/yt/zhylplat/service/ITBaseDriveinfoService.java

@@ -46,6 +46,9 @@ public interface ITBaseDriveinfoService extends IService<TBaseDriveinfo> {
46 46
      * @return
47 47
      */
48 48
     ResultResponse saveDriveInfo(TBaseDriveinfoRequest baseRequest);
49
+
50
+    ResultResponse updateDriveInfo(TBaseDriveinfoRequest baseRequest);
51
+
49 52
     /**
50 53
      * web删除设备的方法
51 54
      * @param baseRequest
@@ -57,4 +60,6 @@ public interface ITBaseDriveinfoService extends IService<TBaseDriveinfo> {
57 60
 
58 61
 
59 62
     ResultResponse selectDriveinfoList(int id);
63
+
64
+    ResultResponse GetUrl(int id);
60 65
 }

+ 2 - 0
src/main/java/com/yt/zhylplat/service/ITWoWorkorderbaseService.java

@@ -240,4 +240,6 @@ public interface ITWoWorkorderbaseService extends IService<TWoWorkorderbase> {
240 240
 
241 241
 
242 242
     IPage<TWoWorkorderbase> selectsworkTypicalList(int id ,int page, int limit);
243
+
244
+    ResultResponse dispatchAppOrder(TWoWorkorderbaseRequest data);
243 245
 }

+ 1 - 1
src/main/java/com/yt/zhylplat/service/TEquipmentMaintenanceService.java

@@ -18,7 +18,7 @@ public interface TEquipmentMaintenanceService extends IService<TEquipmentMainten
18 18
 
19 19
     ResultResponse selectMaintenanceByPageList(TEquipmentMaintenanceRequest baseRequest);
20 20
 
21
-    Boolean saveMaintenanceinfo(TEquipmentMaintenance tMapPolygonProperties);
21
+    Boolean saveMaintenanceinfo(TEquipmentMaintenanceRequest tMapPolygonProperties);
22 22
 
23 23
     Boolean modify(TEquipmentMaintenance tMapPolygonProperties);
24 24
 

+ 27 - 0
src/main/java/com/yt/zhylplat/service/TWorkReportService.java

@@ -0,0 +1,27 @@
1
+package com.yt.zhylplat.service;
2
+
3
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
4
+import com.yt.zhylplat.base.ResultResponse;
5
+import com.yt.zhylplat.entity.TWorkReport;
6
+import com.baomidou.mybatisplus.extension.service.IService;
7
+
8
+/**
9
+ * <p>
10
+ *  服务类
11
+ * </p>
12
+ *
13
+ * @author YTKJ
14
+ * @since 2025-11-17
15
+ */
16
+public interface TWorkReportService extends IService<TWorkReport> {
17
+
18
+    ResultResponse saveTWorkReport(TWorkReport baseRequest);
19
+
20
+    ResultResponse updateTWorkReport(TWorkReport baseRequest);
21
+
22
+    ResultResponse deleteTWorkReport(Integer id);
23
+
24
+    ResultResponse selectById(Integer id);
25
+
26
+    ResultResponse pageList(Page page, TWorkReport WorkReport);
27
+}

+ 37 - 0
src/main/java/com/yt/zhylplat/service/impl/TBaseDriveinfoServiceImpl.java

@@ -14,6 +14,7 @@ import com.yt.zhylplat.service.ITBaseDrivecategoryService;
14 14
 import com.yt.zhylplat.service.ITBaseDriveinfoService;
15 15
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
16 16
 import com.yt.zhylplat.service.ITBaseParkinfoService;
17
+import com.yt.zhylplat.utils.StringUtil;
17 18
 import org.springframework.beans.factory.annotation.Autowired;
18 19
 import org.springframework.stereotype.Service;
19 20
 
@@ -129,6 +130,24 @@ public class TBaseDriveinfoServiceImpl extends ServiceImpl<TBaseDriveinfoMapper,
129 130
     }
130 131
 
131 132
     @Override
133
+    public ResultResponse updateDriveInfo(TBaseDriveinfoRequest baseRequest) {
134
+        TBaseDriveinfo tBaseDriveinfo =baseMapper.selectById(baseRequest.getfDriveid());
135
+         if (tBaseDriveinfo!=null)
136
+         {
137
+             if (StringUtil.isNotBlank(baseRequest.getUrl()))
138
+             {
139
+                 tBaseDriveinfo.setUrl(baseRequest.getUrl());
140
+             }
141
+             if (StringUtil.isNotBlank(baseRequest.getfImg()))
142
+             {
143
+                 tBaseDriveinfo.setfImg(baseRequest.getfImg());
144
+             }
145
+         }
146
+        baseMapper.updateById(tBaseDriveinfo);
147
+        return ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).message(ResultCodeEnum.SUCCESS.getMessage()).build();
148
+    }
149
+
150
+    @Override
132 151
     public ResultResponse deleteDriveInfo(List<TBaseDriveinfoRequest> baseRequest) {
133 152
         if (baseRequest.size() == 0) {
134 153
             return ResultResponse.builder().status(ResultCodeEnum.FAILURE_MESSAGE.getCode()).message("删除失败,传入的公园数组为空").build();
@@ -206,6 +225,7 @@ public class TBaseDriveinfoServiceImpl extends ServiceImpl<TBaseDriveinfoMapper,
206 225
 
207 226
         List<TBaseDriveinfo> Driveinfos = baseMapper.selectList(new QueryWrapper<TBaseDriveinfo>().lambda()
208 227
                         .eq(TBaseDriveinfo::getfParkid,id)
228
+                .eq(TBaseDriveinfo::getfDeleteflag,0)
209 229
                 .orderByDesc(TBaseDriveinfo::getfDriveid));
210 230
 
211 231
         return ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).
@@ -213,4 +233,21 @@ public class TBaseDriveinfoServiceImpl extends ServiceImpl<TBaseDriveinfoMapper,
213 233
                 (Driveinfos).build();
214 234
 
215 235
     }
236
+
237
+    @Override
238
+    public  ResultResponse GetUrl(int id)
239
+    {
240
+        List<TBaseDriveinfo> Driveinfos = baseMapper.selectList(new QueryWrapper<TBaseDriveinfo>().lambda()
241
+                .eq(TBaseDriveinfo::getfParkid,id)
242
+                .eq(TBaseDriveinfo::getfDeleteflag,0)
243
+                .orderByDesc(TBaseDriveinfo::getfDriveid));
244
+        for (TBaseDriveinfo driveinfo : Driveinfos) {
245
+           String url=String.format("rtsp://%s:%s@%s:%s/Streaming/Channels/%d",
246
+                   driveinfo.getfAccount(), driveinfo.getfPassword(), driveinfo.getfIp(),driveinfo.getfPort(), driveinfo.getfChannel());
247
+            driveinfo.setUrl(url);
248
+        }
249
+        return ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).
250
+                message(ResultCodeEnum.SUCCESS.getMessage()).data
251
+                        (Driveinfos).build();
252
+    }
216 253
 }

+ 2 - 1
src/main/java/com/yt/zhylplat/service/impl/TBaseEmployeeinfoServiceImpl.java

@@ -156,7 +156,8 @@ public class TBaseEmployeeinfoServiceImpl extends ServiceImpl<TBaseEmployeeinfoM
156 156
                 //如果人员科室不为空,只能查看某一科室下的
157 157
                 .eq(request.getfExpandint4() != null, TBaseEmployeeinfo::getfExpandint4, request.getfExpandint4())
158 158
                 //如果当前登录人不存在公园中,可直接通过传入公园ID查询公园下所有人员
159
-                .eq(tBaseEmployeeinfo.getfParkid() == null && request.getfParkid() >0, TBaseEmployeeinfo::getfParkid, request.getfParkid())
159
+                .eq(tBaseEmployeeinfo.getfParkid() == null &&   request.getfParkid()!=null&&
160
+                        request.getfParkid() >0, TBaseEmployeeinfo::getfParkid, request.getfParkid())
160 161
                 .like(request.getfRealname() != null, TBaseEmployeeinfo::getfRealname, request.getfRealname())
161 162
                 .eq(request.getfExpand4() != null&& !Objects.equals(request.getfExpand4(), ""), TBaseEmployeeinfo::getfExpand4, request.getfExpand4())
162 163
                 .like(request.getfDuty() != null&& !Objects.equals(request.getfDuty(), ""), TBaseEmployeeinfo::getfDuty, request.getfDuty())

+ 9 - 5
src/main/java/com/yt/zhylplat/service/impl/TEquipmentMaintenanceServiceImpl.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
6 6
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
7 7
 import com.yt.zhylplat.api.response.BasePageResponse;
8 8
 import com.yt.zhylplat.base.ResultResponse;
9
+import com.yt.zhylplat.entity.TBaseDriveinfo;
9 10
 import com.yt.zhylplat.entity.TEquipmentMaintenance;
10 11
 import com.yt.zhylplat.dao.TEquipmentMaintenanceMapper;
11 12
 import com.yt.zhylplat.entity.TEquipmentMaintenanceRequest;
@@ -33,13 +34,15 @@ public class TEquipmentMaintenanceServiceImpl extends ServiceImpl<TEquipmentMain
33 34
         Page<TEquipmentMaintenance> page=new Page<>(baseRequest.getCurrent(), baseRequest.getSize());
34 35
         LambdaQueryWrapper<TEquipmentMaintenance> queryWrapper=new QueryWrapper<TEquipmentMaintenance>().lambda();
35 36
         queryWrapper.orderByDesc(TEquipmentMaintenance::getEquipmentId);
36
-        queryWrapper.like(StringUtils.isNotEmpty(baseRequest.getEquipmentName()) ,TEquipmentMaintenance::getEquipmentName,baseRequest.getEquipmentName());
37
+        queryWrapper.like(StringUtils.isNotEmpty(baseRequest.getEquipmentName())
38
+                ,TEquipmentMaintenance::getEquipmentName,baseRequest.getEquipmentName());
37 39
         queryWrapper.eq(baseRequest.getEquipmentId()!=null && baseRequest.getEquipmentId()>0,
38 40
                 TEquipmentMaintenance::getEquipmentId,baseRequest.getEquipmentId());
39 41
         queryWrapper.like(StringUtils.isNotEmpty(baseRequest.getParkName())
40 42
                 ,TEquipmentMaintenance::getParkName,baseRequest.getParkName());
41 43
         queryWrapper.eq(baseRequest.getParkId()!=null && baseRequest.getParkId()>0,
42 44
                 TEquipmentMaintenance::getParkId,baseRequest.getParkId());
45
+        queryWrapper.orderByDesc(TEquipmentMaintenance::getId);
43 46
         IPage<TEquipmentMaintenance> IPage = baseMapper.selectPage( page,queryWrapper);
44 47
         return ResultResponse.builder()
45 48
                 .status(ResultCodeEnum.SUCCESS.getCode())
@@ -50,19 +53,20 @@ public class TEquipmentMaintenanceServiceImpl extends ServiceImpl<TEquipmentMain
50 53
     }
51 54
 
52 55
     @Override
53
-    public Boolean saveMaintenanceinfo(TEquipmentMaintenance tMapPolygonProperties) {
56
+    public Boolean saveMaintenanceinfo(TEquipmentMaintenanceRequest baseRequest) {
57
+        TEquipmentMaintenance tMapPolygonProperties = new TEquipmentMaintenance();
58
+        org.springframework.beans.BeanUtils.copyProperties(baseRequest, tMapPolygonProperties);
54 59
         return save(tMapPolygonProperties);
55 60
     }
56 61
 
57 62
     /**
58 63
      * 修改
59 64
      *
60
-     * @param tMapPolygonProperties
61 65
      * @return
62 66
      */
63 67
     @Override
64
-    public Boolean modify(TEquipmentMaintenance tMapPolygonProperties) {
65
-        return updateById(tMapPolygonProperties);
68
+    public Boolean modify(TEquipmentMaintenance baseRequest) {
69
+        return updateById(baseRequest);
66 70
     }
67 71
     /**
68 72
      * 删除

+ 7 - 2
src/main/java/com/yt/zhylplat/service/impl/TPdjgWorkorderCategoryServiceImpl.java

@@ -7,6 +7,8 @@ import com.yt.zhylplat.service.TPdjgWorkorderCategoryService;
7 7
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
8 8
 import org.springframework.stereotype.Service;
9 9
 
10
+import java.util.List;
11
+
10 12
 /**
11 13
  * <p>
12 14
  * 工单大类与经济运行平台监管要素对应关系表 服务实现类
@@ -23,11 +25,14 @@ public class TPdjgWorkorderCategoryServiceImpl extends ServiceImpl<TPdjgWorkorde
23 25
         if(categoryId == null || type == null){
24 26
             return null;
25 27
         }
26
-        TPdjgWorkorderCategory tPdjgWorkorderCategory = baseMapper.selectOne(new QueryWrapper<TPdjgWorkorderCategory>().lambda()
28
+        List<TPdjgWorkorderCategory> tPdjgWorkorderCategory = baseMapper.selectList(new QueryWrapper<TPdjgWorkorderCategory>().lambda()
27 29
             .eq(TPdjgWorkorderCategory::getDeleteFlag,0)
28 30
             .eq(TPdjgWorkorderCategory::getCategoryId,categoryId)
29 31
             .eq(TPdjgWorkorderCategory::getType,type)
30 32
         );
31
-        return tPdjgWorkorderCategory;
33
+        if (tPdjgWorkorderCategory!=null&&tPdjgWorkorderCategory.size()>0)
34
+        return tPdjgWorkorderCategory.get(0);
35
+        else
36
+            return null;
32 37
     }
33 38
 }

+ 7 - 6
src/main/java/com/yt/zhylplat/service/impl/TSmsSendsmstaskServiceImpl.java

@@ -37,12 +37,13 @@ public class TSmsSendsmstaskServiceImpl extends ServiceImpl<TSmsSendsmstaskMappe
37 37
     public void insertSmsSendTask(String mobile, Integer userId,String userName,String workCode, String type) {
38 38
         TSmsSendsmstask tSmsSendsmstask = new TSmsSendsmstask();
39 39
         Map<String, Object> map1 = new HashMap<>();
40
-        String code = "";
41
-        if(StringUtil.isEmpty(workCode)){
42
-            code = workCode;
43
-        } else {
44
-            code = workCode.substring(7,workCode.length());
45
-        }
40
+        String  code = workCode;
41
+//        if(StringUtil.isEmpty(workCode)){
42
+//            code = workCode;
43
+//        } else {
44
+//
45
+//            code = workCode.substring(7,workCode.length());
46
+//        }
46 47
         map1.put("code", code);
47 48
         map1.put("type", type);
48 49
         String string = JSONObject.toJSONString(map1);

+ 6 - 3
src/main/java/com/yt/zhylplat/service/impl/TSpActivitybaseServiceImpl.java

@@ -206,7 +206,10 @@ public class TSpActivitybaseServiceImpl extends ServiceImpl<TSpActivitybaseMappe
206 206
         tSpActivityTask.setfActivitytypeid(tSpActivitybase.getfActivitytypeid());
207 207
         tSpActivityTask.setfCreatedate(new Date());
208 208
         //申请之后 生成一条任务或者说创建了一个任务 任务的所属人id就是下一个处理人的id
209
-        tSpActivityTask.setfOwnerid(Integer.parseInt(tSpActivitybase.getfNextnameid()));
209
+        if(fNextid!=null)
210
+        {
211
+            tSpActivityTask.setfOwnerid(Integer.parseInt(tSpActivitybase.getfNextnameid()));
212
+        }
210 213
         tSpActivityTask.setfStateid(tSpActivitybase.getfStateid());//活动状态
211 214
         tSpActivityTask.setfLoseflag(0);// 0未失效 1 已失效
212 215
         tSpActivitytaskMapper.insert(tSpActivityTask);
@@ -1382,8 +1385,8 @@ public class TSpActivitybaseServiceImpl extends ServiceImpl<TSpActivitybaseMappe
1382 1385
 
1383 1386
         tSpActivitybase.setfNextnameid("");//下步审批处理人id
1384 1387
         tSpActivitybase.setfNextname("");//下步审批处理人名字
1385
-        tSpActivitybase.setfState("备案结束");
1386
-        tSpActivitybase.setfStateid(5);
1388
+        tSpActivitybase.setfState("不同意备案");
1389
+        tSpActivitybase.setfStateid(3);
1387 1390
         tSpActivitybase.setStatus("4");
1388 1391
         tSpActivitybase.setfDeleteflag(0);
1389 1392
         baseMapper.updateById(tSpActivitybase);

+ 44 - 1
src/main/java/com/yt/zhylplat/service/impl/TSysUseraccountServiceImpl.java

@@ -15,6 +15,8 @@ import com.yt.zhylplat.common.LoginUserUtil;
15 15
 import com.yt.zhylplat.dao.*;
16 16
 import com.yt.zhylplat.entity.*;
17 17
 import com.yt.zhylplat.enums.ResultCodeEnum;
18
+import com.yt.zhylplat.moduleWx.entity.TWxUserinfo;
19
+import com.yt.zhylplat.moduleWx.mapper.TWxUserinfoMapper;
18 20
 import com.yt.zhylplat.service.ITSysUseraccountService;
19 21
 import com.yt.zhylplat.utils.Aes;
20 22
 import com.yt.zhylplat.utils.HttpURLConnectionUtil;
@@ -55,6 +57,8 @@ public class TSysUseraccountServiceImpl extends ServiceImpl<TSysUseraccountMappe
55 57
 
56 58
     @Autowired
57 59
     TBaseEmployeeinfoMapper employeeinfoMapper;
60
+    @Autowired
61
+    TWxUserinfoMapper wxUserinfoMapper;
58 62
 
59 63
 
60 64
     @Override
@@ -386,7 +390,8 @@ public class TSysUseraccountServiceImpl extends ServiceImpl<TSysUseraccountMappe
386 390
     public ResultResponse getUserOpenIdAndSessionKey(TSysUseraccountRequest baseRequest){
387 391
         Assert.assertTrue(baseRequest.getCode() == null, "当前传入用户 code 为空");
388 392
         //根据微信用户 code 获取 openID
389
-        String requestUrl = "https://api.weixin.qq.com/sns/jscode2session?appid=" + BaseConfiguration.WX_APPID + "&secret=" + BaseConfiguration.WX_APPSECRET + "&js_code=" + baseRequest.getCode() + "&grant_type=authorization_code";
393
+        String requestUrl = "https://api.weixin.qq.com/sns/jscode2session?appid=" + BaseConfiguration.WX_APPID +
394
+                "&secret=" + BaseConfiguration.WX_APPSECRET + "&js_code=" + baseRequest.getCode() + "&grant_type=authorization_code";
390 395
         Map<String, String> result = new HashMap<>();
391 396
         String response = HttpURLConnectionUtil.sendGet(requestUrl);
392 397
         JSONObject OpenidJSONO = JSONObject.fromObject(response);
@@ -396,6 +401,44 @@ public class TSysUseraccountServiceImpl extends ServiceImpl<TSysUseraccountMappe
396 401
         result.put("openId", openId);
397 402
         result.put("sessionKey", sessionKey);
398 403
 
404
+
405
+        //region 添加
406
+        try
407
+        {   //同步绑定
408
+            LambdaQueryWrapper<TWxUserinfo> tLambdaQueryWrapper = new QueryWrapper<TWxUserinfo>().lambda();
409
+            tLambdaQueryWrapper.eq(TWxUserinfo::getDeleteFlag, 0);
410
+            tLambdaQueryWrapper.eq(TWxUserinfo::getWxOpenId, openId);
411
+            tLambdaQueryWrapper.eq(TWxUserinfo::getUserId, baseRequest.getfUserid());
412
+            List<TWxUserinfo> list=wxUserinfoMapper.selectList(tLambdaQueryWrapper);
413
+            if(list!=null&&list.size()>0){
414
+                list.get(0).setDeleteFlag(0);
415
+                list.get(0).setStateFlag(1);
416
+                list.get(0).setWxOpenType(0);
417
+                list.get(0).setMessageFlag(1);
418
+                list.get(0).setWxOpenId(openId);
419
+                list.get(0).setCreateTime(new Date());
420
+                list.get(0).setCreateUserid(LoginUserUtil.getfUserid());
421
+                list.get(0).setCreateUsername(LoginUserUtil.getfUsername());
422
+                wxUserinfoMapper.updateById(list.get(0));
423
+            }
424
+            else {
425
+                TWxUserinfo model=new TWxUserinfo();
426
+                model.setDeleteFlag(0);
427
+                model.setStateFlag(1);
428
+                model.setWxOpenType(0);
429
+                model.setMessageFlag(1);
430
+                model.setCreateTime(new Date());
431
+                model.setWxOpenId(openId);
432
+                model.setCreateUserid(LoginUserUtil.getfUserid());
433
+                model.setCreateUsername(LoginUserUtil.getfUsername());
434
+                wxUserinfoMapper.insert(model);
435
+            }
436
+
437
+        }
438
+        catch (Exception E){};
439
+
440
+
441
+
399 442
         return ResultResponse.builder()
400 443
                 .status(ResultCodeEnum.SUCCESS.getCode())
401 444
                 .message(ResultCodeEnum.SUCCESS.getMessage())

+ 194 - 94
src/main/java/com/yt/zhylplat/service/impl/TWoWorkorderbaseServiceImpl.java

@@ -1015,7 +1015,7 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1015 1015
             collect = new ArrayList<>();
1016 1016
             collect = noLoseWorkTask.stream().map(TWoWorkordertask::getfWorkorderid).distinct().collect(Collectors.toList());
1017 1017
         }
1018
-        unDisposeWorkOrderList = selectWorkBaseList(ts,0,collect,false,false);
1018
+        unDisposeWorkOrderList = selectWorkBaseList(ts,0,collect,1);
1019 1019
 
1020 1020
         //处理中任务(工单状态 != 4 任务表有当前用户已失效任务)
1021 1021
         List<TWoWorkordertask> loseWorkTask = tWoWorkordertaskMapper.selectList(new QueryWrapper<TWoWorkordertask>().lambda()
@@ -1026,7 +1026,7 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1026 1026
             collect = new ArrayList<>();
1027 1027
             collect = loseWorkTask.stream().map(TWoWorkordertask::getfWorkorderid).distinct().collect(Collectors.toList());
1028 1028
         }
1029
-        DisposeingWorkOrderList = selectWorkBaseList(ts,isParkCenter,collect,false,true);
1029
+        DisposeingWorkOrderList = selectWorkBaseList(ts,isParkCenter,collect,2);
1030 1030
 
1031 1031
         //已完结任务(工单状态 = 4 任务表有当前用户任务)
1032 1032
         List<TWoWorkordertask> overWorkTask = tWoWorkordertaskMapper.selectList(new QueryWrapper<TWoWorkordertask>().lambda()
@@ -1036,7 +1036,7 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1036 1036
             collect = new ArrayList<>();
1037 1037
             collect = overWorkTask.stream().map(TWoWorkordertask::getfWorkorderid).distinct().collect(Collectors.toList());
1038 1038
         }
1039
-        finishWorkOrderList = selectWorkBaseList(ts,isParkCenter,collect,true,true);
1039
+        finishWorkOrderList = selectWorkBaseList(ts,isParkCenter,collect,4);
1040 1040
 
1041 1041
         map.put("unDisposeWorkOrderList", unDisposeWorkOrderList);
1042 1042
         map.put("DisposeingWorkOrderList", DisposeingWorkOrderList);
@@ -1190,8 +1190,7 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1190 1190
     }
1191 1191
 
1192 1192
 
1193
-    private IPage selectWorkBaseList(TWoWorkorderbaseRequest ts,Integer isParkCenter,List<Integer> workTaskList,boolean state,
1194
-                                     boolean isTask){
1193
+    private IPage selectWorkBaseList(TWoWorkorderbaseRequest ts,Integer isParkCenter,List<Integer> workTaskList,int state){
1195 1194
 
1196 1195
         int current = ts.getCurrent();
1197 1196
         int size = ts.getSize();
@@ -1201,8 +1200,7 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1201 1200
         LambdaQueryWrapper<TWoWorkorderbase> lambdaQueryWrapper = new QueryWrapper<TWoWorkorderbase>().lambda()
1202 1201
                 .eq(TWoWorkorderbase::getfDeleteflag, 0)
1203 1202
                 .eq(TWoWorkorderbase::getfWorkordertypeid, ts.getfWorkordertypeid())//工单类型
1204
-                .ne(state == false, TWoWorkorderbase::getfStateid, 4)//工单状态不等于4
1205
-                .eq(state == true, TWoWorkorderbase::getfStateid, 4)//工单状态不等于4
1203
+                .eq(TWoWorkorderbase::getfStateid, state)//工单状态不等于4
1206 1204
                 .like(ts.getfSgusername() != null, TWoWorkorderbase::getfSgusername, ts.getfSgusername())
1207 1205
                 .like(ts.getfYhdeptname() != null, TWoWorkorderbase::getfYhdeptname, ts.getfYhdeptname())
1208 1206
                 .like(ts.getfYhusername() != null, TWoWorkorderbase::getfYhusername, ts.getfYhusername())
@@ -1214,7 +1212,7 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1214 1212
                 //考核结束时间
1215 1213
                 .le(ts.getEndTime() != null, TWoWorkorderbase::getfCreatedate, ts.getEndTime())
1216 1214
                 .and(isParkCenter == 0, QueryWrapper -> QueryWrapper
1217
-                        .eq(isTask, TWoWorkorderbase::getfCreateid, LoginUserUtil.getfUserid())//创建人
1215
+                        .eq(true, TWoWorkorderbase::getfCreateid, LoginUserUtil.getfUserid())//创建人
1218 1216
                         .or()
1219 1217
                         .in(workTaskList.size() > 0, TWoWorkorderbase::getfWorkorderid, workTaskList)
1220 1218
                 )
@@ -1283,7 +1281,72 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1283 1281
                 .data(BasePageResponse.builder().current((int) tWoWorkorderbaseIPage.getCurrent()).size((int) tWoWorkorderbaseIPage.getSize()).total((int) tWoWorkorderbaseIPage.getTotal()).pages((int) tWoWorkorderbaseIPage.getPages()).data(tWoWorkorderbaseIPage.getRecords()).build()).build();
1284 1282
     }
1285 1283
 
1284
+    @Transactional(rollbackFor = Exception.class)
1285
+    public ResultResponse dispatchAppOrder(TWoWorkorderbaseRequest request) {
1286
+        TSysUseraccount tSysUseraccount = null;
1287
+       // TBaseParkinfo tBaseParkinfo = null;
1288
+        TWoWorkordertaskdealinfo woWorkordertaskdealinfo = null;
1289
+        Assert.assertTrue(request.getfYhuserid()== null, "派单人不可为空");
1290
+        TWoWorkorderbase ts = baseMapper.selectById(request.getfWorkorderid());
1291
+            tSysUseraccount = tSysUseraccountMapper.selectById(request.getfYhuserid());
1292
+            Assert.assertTrue(tSysUseraccount == null, "请选择接收人");
1293
+//            ts.setfX(tBaseParkinfo.getfX());
1294
+//            ts.setfY(tBaseParkinfo.getfY());
1295
+//            ts.setfGlsx(tBaseParkinfo.getfGlsx());
1296
+//            ts.setfGlsy(tBaseParkinfo.getfGlsy());
1297
+            ts.setfYhuserid(tSysUseraccount.getfUserid());
1298
+            ts.setfYhusername(tSysUseraccount.getfUsername());
1299
+//            ts.setfYhdeptid(tBaseParkinfo.getfYhcompanyid());
1300
+//            ts.setfSgusername(tBaseParkinfo.getfParkname());
1301
+//            ts.setfYhdeptname(tBaseParkinfo.getfYhcompanyname());
1302
+//            ts.setfRegionname(tBaseParkinfo.getfStreet());
1303
+
1304
+            ts.setfStateid(2);
1305
+            ts.setfState("派单");
1306
+            ts.setCheckdept(ts.getfYhdeptname());
1307
+            baseMapper.updateById(ts);
1308
+
1309
+            //失效预警任务单
1310
+            workordertaskService.loseWorkOrderTask(ts, 1);
1311
+
1312
+            //派单任务单
1313
+            TWoWorkordertask tWoWorkordertask = workordertaskService.insertWorkOrderTask(ts,ts.getfYhuserid());
1314
+            Integer parkid=null;
1315
+            if (StringUtil.isNotBlank(tSysUseraccount.getfParkid()))
1316
+            {
1317
+                parkid= Integer.valueOf(tSysUseraccount.getfParkid());
1318
+            }
1319
+            //插入派单历史
1320
+            woWorkordertaskdealinfo = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(), ts,
1321
+                    2, tWoWorkordertask.getfTaskid(),parkid, tSysUseraccount.getfUserid());
1322
+
1323
+        //发送派单消息
1324
+        try{
1325
+            LambdaQueryWrapper<TWxUserinfo> tLambdaQueryWrapper = new QueryWrapper<TWxUserinfo>().lambda();
1326
+            tLambdaQueryWrapper.orderByDesc(TWxUserinfo::getId);
1327
+            tLambdaQueryWrapper.eq(TWxUserinfo::getDeleteFlag, 0);
1328
+            tLambdaQueryWrapper.eq(TWxUserinfo::getStateFlag, 1);
1329
+            tLambdaQueryWrapper.eq(TWxUserinfo::getUserId, tSysUseraccount.getfUserid());
1330
+            List<TWxUserinfo> wxlist =tWxUserinfoMapper.selectList(tLambdaQueryWrapper);
1331
+
1332
+            if(wxlist!=null)
1333
+            {
1334
+                if(wxlist.size()>0){
1335
+                    for(TWxUserinfo wxmodel:wxlist){
1336
+                        if(wxmodel.getWxOpenId()!=null) {
1337
+                            // 微信推送消息
1338
+                            SendMessageWxController.SendDiaryWarningMessage
1339
+                                    (ts, wxmodel.getWxOpenId(),"派单通知");
1340
+                        }
1341
+                    }
1342
+                }
1343
+            }
1344
+        }catch (Exception ignored){
1345
+        }
1346
+        return ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).message(ResultCodeEnum.SUCCESS.getMessage()).data(ts).build();
1286 1347
 
1348
+
1349
+    }
1287 1350
     @Transactional(rollbackFor = Exception.class)
1288 1351
     public ResultResponse saveWorkorderbase(Map<String, Object> map) {
1289 1352
         TSysUseraccount tSysUseraccount = null;
@@ -1295,59 +1358,86 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1295 1358
 
1296 1359
         String phone = "";
1297 1360
 
1361
+
1298 1362
         //派单
1299 1363
         if (ts.getfWorkorderid() != null) {
1300 1364
 
1301
-            Assert.assertTrue(ts.getfSguserid() == null, "未选择公园园长");
1302
-
1303
-            tBaseParkinfo = tBaseParkinfoMapper.selectById(ts.getfSguserid());
1304
-            Assert.assertTrue(tBaseParkinfo == null, "工单对应公园id无法查询到公园信息");
1365
+//            Assert.assertTrue(ts.getfSguserid() == null, "未选择公园园长");
1366
+//
1367
+//            tBaseParkinfo = tBaseParkinfoMapper.selectById(ts.getfSguserid());
1368
+//            Assert.assertTrue(tBaseParkinfo == null, "工单对应公园id无法查询到公园信息");
1369
+//
1370
+//            //公园园长信息
1371
+//            TBaseEmployeeinfo tBaseEmployeeinfo = tBaseEmployeeinfoMapper.selectOne(new QueryWrapper<TBaseEmployeeinfo>().lambda()
1372
+//                    .eq(TBaseEmployeeinfo::getfParkid, tBaseParkinfo.getfParkid())
1373
+//                    .eq(TBaseEmployeeinfo::getfExpand1, 1));
1374
+//            Assert.assertTrue(tBaseEmployeeinfo == null, "工单对应公园id无法查询到公园园长信息");
1375
+//
1376
+//            phone = tBaseEmployeeinfo.getfPhone();
1377
+//
1378
+//            tSysUseraccount = tSysUseraccountMapper.selectById(tBaseEmployeeinfo.getfExpandint3());
1379
+//            Assert.assertTrue(tSysUseraccount == null, "工单对应公园园长无法查询到公园园长用户信息");
1380
+//
1381
+//            ts.setfX(tBaseParkinfo.getfX());
1382
+//            ts.setfY(tBaseParkinfo.getfY());
1383
+//            ts.setfGlsx(tBaseParkinfo.getfGlsx());
1384
+//            ts.setfGlsy(tBaseParkinfo.getfGlsy());
1385
+//            ts.setfYhuserid(tSysUseraccount.getfUserid());
1386
+//            ts.setfYhusername(tSysUseraccount.getfUsername());
1387
+//            ts.setfYhdeptid(tBaseParkinfo.getfYhcompanyid());
1388
+//            ts.setfSgusername(tBaseParkinfo.getfParkname());
1389
+//            ts.setfYhdeptname(tBaseParkinfo.getfYhcompanyname());
1390
+//            ts.setfRegionname(tBaseParkinfo.getfStreet());
1391
+//
1392
+//            ts.setfStateid(2);
1393
+//            ts.setfState("派单");
1394
+//            ts.setCheckdept(ts.getfYhdeptname());
1395
+//            baseMapper.updateById(ts);
1396
+//
1397
+//            //失效预警任务单
1398
+//            workordertaskService.loseWorkOrderTask(ts, 1);
1399
+//
1400
+//            //派单任务单
1401
+//            TWoWorkordertask tWoWorkordertask = workordertaskService.insertWorkOrderTask(ts,ts.getfYhuserid());
1402
+//
1403
+//            //插入派单历史
1404
+//            woWorkordertaskdealinfo = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(), ts, 2, tWoWorkordertask.getfTaskid(), tBaseParkinfo.getfParkid(), tSysUseraccount.getfUserid());
1305 1405
 
1306
-            //公园园长信息
1307
-            TBaseEmployeeinfo tBaseEmployeeinfo = tBaseEmployeeinfoMapper.selectOne(new QueryWrapper<TBaseEmployeeinfo>().lambda()
1308
-                    .eq(TBaseEmployeeinfo::getfParkid, tBaseParkinfo.getfParkid())
1309
-                    .eq(TBaseEmployeeinfo::getfExpand1, 1));
1310
-            Assert.assertTrue(tBaseEmployeeinfo == null, "工单对应公园id无法查询到公园园长信息");
1311 1406
 
1312
-            phone = tBaseEmployeeinfo.getfPhone();
1313 1407
 
1314
-            tSysUseraccount = tSysUseraccountMapper.selectById(tBaseEmployeeinfo.getfExpandint3());
1315
-            Assert.assertTrue(tSysUseraccount == null, "工单对应公园园长无法查询到公园园长用户信息");
1408
+            //增加工单任务表
1409
+            TWoWorkordertask tWoWorkordertask = workordertaskService.
1410
+                    insertWorkOrderTask(ts,ts.getfSguserid() != null ? ts.getfYhuserid() : LoginUserUtil.getfUserid());
1316 1411
 
1317
-            ts.setfX(tBaseParkinfo.getfX());
1318
-            ts.setfY(tBaseParkinfo.getfY());
1319
-            ts.setfGlsx(tBaseParkinfo.getfGlsx());
1320
-            ts.setfGlsy(tBaseParkinfo.getfGlsy());
1321
-            ts.setfYhuserid(tSysUseraccount.getfUserid());
1322
-            ts.setfYhusername(tSysUseraccount.getfUsername());
1323
-            ts.setfYhdeptid(tBaseParkinfo.getfYhcompanyid());
1324
-            ts.setfSgusername(tBaseParkinfo.getfParkname());
1325
-            ts.setfYhdeptname(tBaseParkinfo.getfYhcompanyname());
1326
-            ts.setfRegionname(tBaseParkinfo.getfStreet());
1327 1412
 
1328
-            ts.setfStateid(2);
1329
-            ts.setfState("派单");
1330
-            ts.setCheckdept(ts.getfYhdeptname());
1331
-            baseMapper.updateById(ts);
1332 1413
 
1333
-            //失效预警任务单
1334
-            workordertaskService.loseWorkOrderTask(ts, 1);
1335
-
1336
-            //派单任务单
1337
-            TWoWorkordertask tWoWorkordertask = workordertaskService.insertWorkOrderTask(ts,ts.getfYhuserid());
1414
+            //增加工单历史表(一条预警)
1415
+            ts.setfStateid(1);
1416
+            if (ts.getfWorkordertypeid()==3)
1417
+            {
1418
+                ts.setfState("日常");
1419
+            }
1420
+            else
1421
+            {
1422
+                ts.setfState("预警");
1423
+            }
1424
+            TWoWorkordertaskdealinfo tWoWorkordertaskdealinfo =
1425
+                    workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(),
1426
+                            ts, 1, tWoWorkordertask.getfTaskid(), null,null);
1338 1427
 
1339
-            //插入派单历史
1340
-            woWorkordertaskdealinfo = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(), ts, 2, tWoWorkordertask.getfTaskid(), tBaseParkinfo.getfParkid(), tSysUseraccount.getfUserid());
1341 1428
             //处理工单图片
1342 1429
             if (map.get("fileInfoList") != null) {
1343 1430
                 List<TWoFileinfo> fileinfoList = JSONObject.parseArray(JSONObject.toJSONString(map.get("fileInfoList")), TWoFileinfo.class);
1344
-                woFileinfoService.insertImageList(ts, woWorkordertaskdealinfo.getfTaskinfoid(), fileinfoList);
1431
+                woFileinfoService.insertImageList(ts,tWoWorkordertaskdealinfo.getfTaskinfoid(), fileinfoList);
1345 1432
             }
1346 1433
             //处理工单附件
1347 1434
             if (map.get("wordInfoList") != null) {
1348 1435
                 List<TWoFileinfo> wordInfoList = JSONObject.parseArray(JSONObject.toJSONString(map.get("wordInfoList")), TWoFileinfo.class);
1349
-                woFileinfoService.insertWordList(ts, woWorkordertaskdealinfo.getfTaskinfoid(), wordInfoList);
1436
+                woFileinfoService.insertWordList(ts, tWoWorkordertaskdealinfo.getfTaskinfoid(), wordInfoList);
1350 1437
             }
1438
+
1439
+
1440
+
1351 1441
             return ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).message(ResultCodeEnum.SUCCESS.getMessage()).data(ts).build();
1352 1442
         } else {//保存
1353 1443
 
@@ -1368,33 +1458,40 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1368 1458
 
1369 1459
 
1370 1460
             //如果创建工单时未选择公园,默认状态为预警
1371
-            ts.setfStateid(ts.getfSguserid() != null ? 2 : 1);
1372
-            ts.setfState(ts.getfSguserid() != null ? "派单" : "预警");
1373
-
1374
-            if (ts.getfSguserid() != null) {
1375
-                tBaseParkinfo = tBaseParkinfoMapper.selectById(ts.getfSguserid());
1376
-                Assert.assertTrue(tBaseParkinfo == null, "工单对应公园id无法查询到公园信息");
1377
-
1378
-                //公园园长信息
1379
-                TBaseEmployeeinfo tBaseEmployeeinfo = tBaseEmployeeinfoMapper.selectOne(new QueryWrapper<TBaseEmployeeinfo>().lambda()
1380
-                        .eq(TBaseEmployeeinfo::getfParkid, tBaseParkinfo.getfParkid())
1381
-                        .eq(TBaseEmployeeinfo::getfExpand1, 1));
1382
-                Assert.assertTrue(tBaseEmployeeinfo == null, "工单对应公园id无法查询到公园园长信息");
1383
-
1384
-                phone = tBaseEmployeeinfo.getfPhone();
1385
-                tSysUseraccount = tSysUseraccountMapper.selectById(tBaseEmployeeinfo.getfExpandint3());
1386
-                Assert.assertTrue(tSysUseraccount == null, "工单对应公园园长无法查询到公园园长用户信息");
1387
-
1388
-                ts.setfX(tBaseParkinfo.getfX());
1389
-                ts.setfY(tBaseParkinfo.getfY());
1390
-                ts.setfGlsx(tBaseParkinfo.getfGlsx());
1391
-                ts.setfGlsy(tBaseParkinfo.getfGlsy());
1392
-                ts.setfYhuserid(tSysUseraccount.getfUserid());
1393
-                ts.setfYhusername(tSysUseraccount.getfUsername());
1394
-                ts.setfYhdeptid(tBaseParkinfo.getfYhcompanyid());
1395
-                ts.setfYhdeptname(tBaseParkinfo.getfYhcompanyname());
1396
-                ts.setfRegionname(tBaseParkinfo.getfStreet());
1461
+            ts.setfStateid(1);
1462
+            if (ts.getfWorkordertypeid()==3)
1463
+            {
1464
+                ts.setfState("日常");
1397 1465
             }
1466
+            else
1467
+            {
1468
+                ts.setfState("预警");
1469
+            }
1470
+
1471
+//            if (ts.getfSguserid() != null) {
1472
+//                tBaseParkinfo = tBaseParkinfoMapper.selectById(ts.getfSguserid());
1473
+//                Assert.assertTrue(tBaseParkinfo == null, "工单对应公园id无法查询到公园信息");
1474
+//
1475
+//                //公园园长信息
1476
+//                TBaseEmployeeinfo tBaseEmployeeinfo = tBaseEmployeeinfoMapper.selectOne(new QueryWrapper<TBaseEmployeeinfo>().lambda()
1477
+//                        .eq(TBaseEmployeeinfo::getfParkid, tBaseParkinfo.getfParkid())
1478
+//                        .eq(TBaseEmployeeinfo::getfExpand1, 1));
1479
+//                Assert.assertTrue(tBaseEmployeeinfo == null, "工单对应公园id无法查询到公园园长信息");
1480
+//
1481
+//                phone = tBaseEmployeeinfo.getfPhone();
1482
+//                tSysUseraccount = tSysUseraccountMapper.selectById(tBaseEmployeeinfo.getfExpandint3());
1483
+//                Assert.assertTrue(tSysUseraccount == null, "工单对应公园园长无法查询到公园园长用户信息");
1484
+//
1485
+//                ts.setfX(tBaseParkinfo.getfX());
1486
+//                ts.setfY(tBaseParkinfo.getfY());
1487
+//                ts.setfGlsx(tBaseParkinfo.getfGlsx());
1488
+//                ts.setfGlsy(tBaseParkinfo.getfGlsy());
1489
+//                ts.setfYhuserid(tSysUseraccount.getfUserid());
1490
+//                ts.setfYhusername(tSysUseraccount.getfUsername());
1491
+//                ts.setfYhdeptid(tBaseParkinfo.getfYhcompanyid());
1492
+//                ts.setfYhdeptname(tBaseParkinfo.getfYhcompanyname());
1493
+//                ts.setfRegionname(tBaseParkinfo.getfStreet());
1494
+//            }
1398 1495
 
1399 1496
             ts.setfSgdeptname("0,0,1,0");
1400 1497
             ts.setSyncstatus(1);
@@ -1426,28 +1523,30 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1426 1523
 
1427 1524
             //增加工单历史表(一条预警,一条派单)
1428 1525
             ts.setfStateid(1);
1429
-            TWoWorkordertaskdealinfo tWoWorkordertaskdealinfo = workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(), ts, 1, tWoWorkordertask.getfTaskid(), null,null);
1430
-
1431
-            //如果选择了公园,创建一条派单历史
1432
-            ts.setfStateid(2);
1433
-            if (ts.getfSguserid() != null) {
1434
-                woWorkordertaskdealinfo =  workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(), ts, 2, tWoWorkordertask.getfTaskid(), tBaseParkinfo.getfParkid(), tSysUseraccount.getfUserid());
1435
-            }
1526
+            TWoWorkordertaskdealinfo tWoWorkordertaskdealinfo =
1527
+                    workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(),
1528
+                            ts, 1, tWoWorkordertask.getfTaskid(), null,null);
1529
+
1530
+//            //如果选择了公园,创建一条派单历史
1531
+//            ts.setfStateid(2);
1532
+//            if (ts.getfSguserid() != null) {
1533
+//                woWorkordertaskdealinfo =  workordertaskdealinfoService.insertWorkOrderTaskDetailInfo(ts.getfContent(), ts, 2, tWoWorkordertask.getfTaskid(), tBaseParkinfo.getfParkid(), tSysUseraccount.getfUserid());
1534
+//            }
1436 1535
             //处理工单图片
1437 1536
             if (map.get("fileInfoList") != null) {
1438 1537
                 List<TWoFileinfo> fileinfoList = JSONObject.parseArray(JSONObject.toJSONString(map.get("fileInfoList")), TWoFileinfo.class);
1439
-                woFileinfoService.insertImageList(ts, ts.getfSguserid() != null ? woWorkordertaskdealinfo.getfTaskinfoid() : tWoWorkordertaskdealinfo.getfTaskinfoid(), fileinfoList);
1538
+                woFileinfoService.insertImageList(ts,tWoWorkordertaskdealinfo.getfTaskinfoid(), fileinfoList);
1440 1539
             }
1441 1540
             //处理工单附件
1442 1541
             if (map.get("wordInfoList") != null) {
1443 1542
                 List<TWoFileinfo> wordInfoList = JSONObject.parseArray(JSONObject.toJSONString(map.get("wordInfoList")), TWoFileinfo.class);
1444
-                woFileinfoService.insertWordList(ts, ts.getfSguserid() != null ? woWorkordertaskdealinfo.getfTaskinfoid() : tWoWorkordertaskdealinfo.getfTaskinfoid(), wordInfoList);
1543
+                woFileinfoService.insertWordList(ts,tWoWorkordertaskdealinfo.getfTaskinfoid(), wordInfoList);
1445 1544
             }
1446 1545
 
1447
-            //如果不是园长自己创建的工单,给园长添加一条短信发送任务
1448
-            if (ts.getfCreateid() != ts.getfYhuserid()) {
1449
-                smsSendsmstaskService.insertSmsSendTask(phone,ts.getfCreateid(),ts.getfCreatename(),ts.getfCode(),ts.getfWorkordertype());
1450
-            }
1546
+//            //如果不是园长自己创建的工单,给园长添加一条短信发送任务
1547
+//            if (ts.getfCreateid() != ts.getfYhuserid()) {
1548
+//                smsSendsmstaskService.insertSmsSendTask(phone,ts.getfCreateid(),ts.getfCreatename(),ts.getfCode(),ts.getfWorkordertype());
1549
+//            }
1451 1550
 
1452 1551
             return ResultResponse.builder().status(ResultCodeEnum.SUCCESS.getCode()).message(ResultCodeEnum.SUCCESS.getMessage()).data(ts).build();
1453 1552
         }
@@ -1489,15 +1588,6 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1489 1588
         //处置工单
1490 1589
         if (request.getAcceptOrDispose() == 2) {
1491 1590
             Assert.assertTrue(workorderbase.getfStateid() == 3,"工单已经处置,请不要重复处置");
1492
-            //公园园长信息
1493
-//            TBaseEmployeeinfo tBaseEmployeeinfo = tBaseEmployeeinfoMapper.selectOne(new QueryWrapper<TBaseEmployeeinfo>().lambda()
1494
-//                    .eq(TBaseEmployeeinfo::getfExpandint3, LoginUserUtil.getfUserid()));
1495
-//            if (tBaseEmployeeinfo == null) {
1496
-//
1497
-//                TBaseYhcompany tBaseYhcompany = tBaseYhcompanyMapper.selectOne(new QueryWrapper<TBaseYhcompany>().lambda()
1498
-//                        .eq(TBaseYhcompany::getfYhcompanyid, tBaseEmployeeinfo.getfYhcompanyid()));
1499
-//            }
1500
-
1501 1591
             if (woWorkordertaskdealinfos.size() == 0) {
1502 1592
                 tWoWorkorderbase.setJstime(new Date());
1503 1593
                 //接收任务单
@@ -1919,15 +2009,22 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
1919 2009
         tWorkorderbasLambdaQueryWrapper.eq(baseRequest.getfWorkordertypeid()>0,TWoWorkorderbase::getfWorkordertypeid,baseRequest.getfWorkordertypeid());
1920 2010
 //        tWorkorderbasLambdaQueryWrapper.in(baseRequest.getDeptType()<2,TWoWorkorderbase::getDeptType,0,1);
1921 2011
         tWorkorderbasLambdaQueryWrapper.eq(stateid!=null&&stateid>0,TWoWorkorderbase::getfStateid,stateid);
2012
+        tWorkorderbasLambdaQueryWrapper.eq(baseRequest.getfSguserid()!=null&&baseRequest.getfSguserid()>0,TWoWorkorderbase::getfSguserid,baseRequest.getfSguserid());
1922 2013
         tWorkorderbasLambdaQueryWrapper.like(baseRequest.getfSgusername()!=null&&baseRequest.getfSgusername().length()>0,TWoWorkorderbase::getfSgusername,baseRequest.getfSgusername());
1923 2014
         tWorkorderbasLambdaQueryWrapper.like(baseRequest.getfCode()!=null&&baseRequest.getfCode().length()>0,TWoWorkorderbase::getfCode,baseRequest.getfCode());
1924 2015
         tWorkorderbasLambdaQueryWrapper.apply(StringUtils.isNotBlank(queryStime), "date_format (F_CreateDate,'%Y-%m-%d') >= date_format('" + queryStime + "','%Y-%m-%d')");
1925 2016
         tWorkorderbasLambdaQueryWrapper .apply(StringUtils.isNotBlank(queryEtime), "date_format (F_CreateDate,'%Y-%m-%d') <= date_format('" + queryEtime + "','%Y-%m-%d')");
1926 2017
         IPage<TWoWorkorderbase> IPage = baseMapper.selectPage( tWorkorderbasePage,tWorkorderbasLambdaQueryWrapper);
2018
+        Integer overTime=0;
2019
+
1927 2020
         return ResultResponse.builder()
1928 2021
                 .status(ResultCodeEnum.SUCCESS.getCode())
1929 2022
                 .message(ResultCodeEnum.SUCCESS.getMessage())
1930
-                .data(BasePageResponse.builder().current((int) IPage.getCurrent()).size((int) IPage.getSize()).total((int) IPage.getTotal()).pages((int) IPage.getPages()).data(IPage.getRecords()).build()).build();
2023
+                .data(BasePageResponse.builder().current((int)
2024
+                        IPage.getCurrent()).size((int) IPage.getSize()).total((int)
2025
+                        IPage.getTotal()).pages((int) IPage.getPages()).data(IPage.getRecords() ).build()
2026
+
2027
+                ).build();
1931 2028
     }
1932 2029
 
1933 2030
     @Override
@@ -2252,6 +2349,9 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
2252 2349
         tWoWorkorderbase.setfFromcode(generateCode.generateWorkFromCode());
2253 2350
         tWoWorkorderbase.setfStateid(2);
2254 2351
         tWoWorkorderbase.setfState("派单");
2352
+
2353
+
2354
+
2255 2355
         tWoWorkorderbase.setRiskclassifyname("市民反馈");//
2256 2356
         tWoWorkorderbase.setfRegionid(0);
2257 2357
         tWoWorkorderbase.setfDeleteflag(0);//
@@ -2369,14 +2469,14 @@ private TWoWorkorderstatesMapper tWoWorkorderstatesMapper;
2369 2469
     public ResultResponse smartDiscovery(int id ) {
2370 2470
         Map<String, Object> map = new LinkedHashMap<>();
2371 2471
         List<TWoWorkorderbase> tWoWorkorderbaseslist = workorderbaseService.list(new QueryWrapper<TWoWorkorderbase>().lambda()
2372
-                .eq(TWoWorkorderbase::getfWorkordertypeid, 4)
2472
+                .eq(TWoWorkorderbase::getfWorkordertypeid, 11)
2373 2473
                 .eq(TWoWorkorderbase::getfDeleteflag,0)
2374 2474
                 .eq(TWoWorkorderbase::getfSguserid,id)
2375 2475
         );
2376 2476
         long  total=tWoWorkorderbaseslist.size();//总数
2377 2477
         long  endTotal= tWoWorkorderbaseslist.stream().filter(t -> t.getfStateid().equals(4)).count();//已完结
2378 2478
         long  tobeTotal= tWoWorkorderbaseslist.stream().filter(t -> t.getfStateid()!=4).count();//未完结
2379
-        long  IoTTotal= tWoWorkorderbaseslist.stream().filter(t -> t.getfFromref()!=null&& t.getfFromref().equals("物联感知")).count();//物联感知
2479
+        long  IoTTotal= tWoWorkorderbaseslist.stream().filter(t -> t.getfCategoryid1()==14).count();//智能预警
2380 2480
         long  bigDataTotal= tWoWorkorderbaseslist.stream().filter(t ->t.getfFromref()!=null&& t.getfFromref().equals("视频捕捉")).count();//数据分析
2381 2481
 
2382 2482
 

+ 7 - 3
src/main/java/com/yt/zhylplat/service/impl/TWoXctaskbaseinfoServiceImpl.java

@@ -127,12 +127,16 @@ TWoXccategoryinfoMapper tWoXccategoryinfoMapper;
127 127
             tWoXctaskbaseinfo.setSyncstatus(1);
128 128
             tWoXctaskbaseinfo.setfTypename("日常巡检");
129 129
            baseMapper.insert(tWoXctaskbaseinfo);
130
-            TSysUseraccount tSysUseraccount = tSysUseraccountMapper.selectOne(new QueryWrapper<TSysUseraccount>().lambda()
130
+
131
+            List<TSysUseraccount> tSysUseraccount = tSysUseraccountMapper.selectList(new QueryWrapper<TSysUseraccount>().lambda()
131 132
                     .eq(TSysUseraccount::getfParkid, tWoXctaskbaseinfo.getYhcompanyid()));
132 133
              twoxctaskusers = new TWoXctaskusers();
133 134
             twoxctaskusers.setfTaskid(tWoXctaskbaseinfo.getfTaskid());
134
-            twoxctaskusers.setfUserid(tSysUseraccount.getfUserid());
135
-            twoxctaskusers.setfUsername(tSysUseraccount.getfUsername());
135
+            if (tSysUseraccount!=null&&tSysUseraccount.size()>0)
136
+            {
137
+                twoxctaskusers.setfUserid(tSysUseraccount.get(0).getfUserid());
138
+                twoxctaskusers.setfUsername(tSysUseraccount.get(0).getfUsername());
139
+            }
136 140
             twoxctaskusers.setfState(0);
137 141
             tWoXctaskusersMapper.insert(twoxctaskusers);
138 142
 

+ 94 - 0
src/main/java/com/yt/zhylplat/service/impl/TWorkReportServiceImpl.java

@@ -0,0 +1,94 @@
1
+package com.yt.zhylplat.service.impl;
2
+
3
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
4
+import com.baomidou.mybatisplus.core.metadata.IPage;
5
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
6
+import com.yt.zhylplat.api.response.BasePageResponse;
7
+import com.yt.zhylplat.base.ResultResponse;
8
+import com.yt.zhylplat.common.LoginUserUtil;
9
+import com.yt.zhylplat.entity.TWorkReport;
10
+import com.yt.zhylplat.dao.TWorkReportMapper;
11
+import com.yt.zhylplat.enums.ResultCodeEnum;
12
+import com.yt.zhylplat.service.TWorkReportService;
13
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
14
+import org.springframework.beans.BeanUtils;
15
+import org.springframework.stereotype.Service;
16
+
17
+import java.util.*;
18
+
19
+/**
20
+ * <p>
21
+ *  服务实现类
22
+ * </p>
23
+ *
24
+ * @author YTKJ
25
+ * @since 2025-11-17
26
+ */
27
+@Service
28
+public class TWorkReportServiceImpl extends ServiceImpl<TWorkReportMapper, TWorkReport> implements TWorkReportService {
29
+
30
+    @Override
31
+    public ResultResponse saveTWorkReport(TWorkReport baseRequest) {
32
+        TWorkReport TWorkReport = new TWorkReport();
33
+        BeanUtils.copyProperties(baseRequest, TWorkReport);
34
+        TWorkReport.setCreateTime(new Date());
35
+        TWorkReport.setCreateUser(LoginUserUtil.getfUsername());
36
+        baseMapper.insert(TWorkReport);
37
+        return ResultResponse.builder()
38
+                .status(ResultCodeEnum.SUCCESS.getCode())
39
+                .message(ResultCodeEnum.SUCCESS.getMessage())
40
+                .data(TWorkReport)
41
+                .build();
42
+    }
43
+
44
+    @Override
45
+    public ResultResponse updateTWorkReport(TWorkReport baseRequest) {
46
+        TWorkReport TWorkReport = new TWorkReport();
47
+        BeanUtils.copyProperties(baseRequest, TWorkReport);
48
+        TWorkReport.setUpdateTime(new Date());
49
+        baseMapper.updateById(TWorkReport);
50
+        return ResultResponse.builder()
51
+                .status(ResultCodeEnum.SUCCESS.getCode())
52
+                .message(ResultCodeEnum.SUCCESS.getMessage())
53
+                .build();
54
+    }
55
+
56
+    @Override
57
+    public ResultResponse deleteTWorkReport(Integer id) {
58
+        baseMapper.deleteById(id);
59
+        return ResultResponse.builder()
60
+                .status(ResultCodeEnum.SUCCESS.getCode())
61
+                .message(ResultCodeEnum.SUCCESS.getMessage())
62
+                .build();
63
+    }
64
+
65
+    @Override
66
+    public ResultResponse selectById(Integer id) {
67
+        return ResultResponse.builder()
68
+                .status(ResultCodeEnum.SUCCESS.getCode())
69
+                .message(ResultCodeEnum.SUCCESS.getMessage())
70
+                .data(baseMapper.selectById(id))
71
+                .build();
72
+    }
73
+
74
+    @Override
75
+    public ResultResponse pageList(Page page, TWorkReport WorkReport) {
76
+
77
+        IPage<TWorkReport> greenlandsIPage = baseMapper.selectPage(new Page<TWorkReport>(page.getCurrent(),
78
+                page.getSize()), new QueryWrapper<TWorkReport>().lambda()
79
+                .like(WorkReport.getType() != null&&WorkReport.getType()>0, TWorkReport::getType,WorkReport.getType())
80
+                .ge (WorkReport.getWorkStartTime() != null, TWorkReport::getWorkStartTime,WorkReport.getWorkStartTime())
81
+                .le (WorkReport.getWorkEndTime() != null, TWorkReport::getWorkEndTime,WorkReport.getWorkEndTime())
82
+                .eq  (WorkReport.getTeam() != null&& !WorkReport.getTeam().equals(""), TWorkReport::getTeam,WorkReport.getTeam())
83
+                .eq  (WorkReport.getSuperintendent() != null&& !WorkReport.getSuperintendent().equals(""), TWorkReport::getSuperintendent,WorkReport.getSuperintendent())
84
+                .orderByDesc(TWorkReport::getCreateTime)
85
+        );
86
+
87
+          return ResultResponse.builder()
88
+                .status(ResultCodeEnum.SUCCESS.getCode())
89
+                .message(ResultCodeEnum.SUCCESS.getMessage())
90
+                .data(BasePageResponse.builder().current((int) greenlandsIPage.getCurrent()).size((int) greenlandsIPage.getSize()).total((int)
91
+                        greenlandsIPage.getTotal()).pages((int) greenlandsIPage.getPages()).data(greenlandsIPage.getRecords()).build()).build();
92
+    }
93
+
94
+}

+ 85 - 0
src/main/java/com/yt/zhylplat/timedTask/facilityinfo/FacilityinfoTask.java

@@ -0,0 +1,85 @@
1
+package com.yt.zhylplat.timedTask.facilityinfo;
2
+
3
+
4
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
5
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
6
+import com.baomidou.mybatisplus.core.metadata.IPage;
7
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
8
+import com.yt.zhylplat.app.service.AppITBaseFacilityinfoService;
9
+import com.yt.zhylplat.appController.SendMessageWxController;
10
+import com.yt.zhylplat.dao.TBaseFacilityinfoMapper;
11
+import com.yt.zhylplat.dao.TSysUseraccountMapper;
12
+import com.yt.zhylplat.entity.TBaseFacilityinfo;
13
+import com.yt.zhylplat.entity.TSysUseraccount;
14
+import com.yt.zhylplat.entity.VwFacilityinfo;
15
+import com.yt.zhylplat.moduleWx.entity.TWxUserinfo;
16
+import com.yt.zhylplat.moduleWx.mapper.TWxUserinfoMapper;
17
+import org.apache.commons.lang3.StringUtils;
18
+import org.springframework.beans.factory.annotation.Autowired;
19
+import org.springframework.context.annotation.Configuration;
20
+import org.springframework.scheduling.annotation.Scheduled;
21
+import java.math.BigDecimal;
22
+import java.text.ParseException;
23
+import java.util.ArrayList;
24
+import java.util.Date;
25
+import java.util.List;
26
+import java.util.stream.Collectors;
27
+
28
+
29
+@Configuration
30
+public class FacilityinfoTask {
31
+    @Autowired
32
+    TBaseFacilityinfoMapper baseFacilityinfoMapper;
33
+    @Autowired
34
+    TWxUserinfoMapper tWxUserinfoMapper;
35
+    @Autowired
36
+    TSysUseraccountMapper tSysUseraccountMapper;
37
+    /**
38
+     * 每五分钟执行一次
39
+     */
40
+    @Scheduled(cron=" 0 0/5 * * * ? ")
41
+    public void sendSms() throws ParseException {
42
+
43
+        LambdaQueryWrapper<TBaseFacilityinfo> tLambdaQueryWrapper=new QueryWrapper<TBaseFacilityinfo>().lambda()
44
+                .ge(TBaseFacilityinfo::getExpirationTime,new Date())
45
+                .eq(TBaseFacilityinfo::getIsSms,0)
46
+                .orderByAsc(TBaseFacilityinfo::getFFacilityid)
47
+                ;
48
+        List<TBaseFacilityinfo> list = baseFacilityinfoMapper.selectList(tLambdaQueryWrapper);
49
+        for(TBaseFacilityinfo item :list)
50
+        {
51
+            //发送派单消息
52
+            try{
53
+
54
+                List<TSysUseraccount> sysUseraccounts = tSysUseraccountMapper.selectList(new
55
+                        QueryWrapper<TSysUseraccount>().lambda().eq(TSysUseraccount::getfDeptid, 15).
56
+                        eq(TSysUseraccount::getfDeleteflag, 0).eq(TSysUseraccount::getfParkid, item.getFParkid().toString()));
57
+
58
+
59
+                LambdaQueryWrapper<TWxUserinfo> WxtLambdaQueryWrapper = new QueryWrapper<TWxUserinfo>().lambda();
60
+                WxtLambdaQueryWrapper.orderByDesc(TWxUserinfo::getId);
61
+                WxtLambdaQueryWrapper.eq(TWxUserinfo::getDeleteFlag, 0);
62
+                WxtLambdaQueryWrapper.eq(TWxUserinfo::getStateFlag, 1);
63
+                List<Integer> collect_all = new ArrayList<>();
64
+                collect_all = sysUseraccounts.stream().map(TSysUseraccount::getfUserid).distinct().collect(Collectors.toList());
65
+                WxtLambdaQueryWrapper.in(TWxUserinfo::getUserId, collect_all);
66
+                List<TWxUserinfo> wxlist =tWxUserinfoMapper.selectList(WxtLambdaQueryWrapper);
67
+                if(wxlist!=null)
68
+                {
69
+                    if(wxlist.size()>0){
70
+                        for(TWxUserinfo wxmodel:wxlist){
71
+                            if(wxmodel.getWxOpenId()!=null) {
72
+                                // 微信推送消息
73
+                                SendMessageWxController.SendDiaryWarningFacility
74
+                                        (item, wxmodel.getWxOpenId(),"设施到期通知");
75
+                            }
76
+                        }
77
+                    }
78
+                }
79
+            }catch (Exception ex){
80
+            }
81
+        }
82
+
83
+
84
+    }
85
+}

+ 2 - 2
src/main/resources/application-pro.yml

@@ -7,9 +7,9 @@ spring:
7 7
     type: com.alibaba.druid.pool.DruidDataSource  #数据源插件
8 8
     druid:
9 9
       driver-class-name: com.mysql.cj.jdbc.Driver  #zhylplatDB是数据库
10
-      url: jdbc:mysql://47.105.102.32:12306/zhyl_db_jz?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=Hongkong
10
+      url: jdbc:mysql://127.0.0.1:3306/zhyl_db_jz?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
11 11
       username: root
12
-      password: zhyl!@#123
12
+      password: hykj@800100
13 13
       #关闭 druid 连接池监控页面
14 14
       filter:
15 15
         config:

+ 3 - 3
src/main/resources/application.yml

@@ -5,7 +5,7 @@
5 5
 #  port: 9090    #端口配置,每个配之前需要输入 空格
6 6
 spring:
7 7
   profiles:
8
-    active: dev #生产环境%测试环境
8
+    active: pro #生产环境%测试环境
9 9
 
10 10
   #解决 springboot 升版后文件上传问题
11 11
   mvc:
@@ -91,9 +91,9 @@ token:
91 91
 #微信小程序-智慧园林
92 92
 wx:
93 93
   #微信小程序的 appId
94
-  appId: wxe1c3903a345da85b
94
+  appId: wx97a5a9e16d2ee2fa
95 95
   #微信小程序的 appSecret
96
-  appSecret: 3a1b429a26bdfa5cdd6247bcd6bccb25
96
+  appSecret: b63bd0cd6d9c026aa2153dd088b6af23
97 97
   #事项办理进度通知模板 ID
98 98
   templateId:
99 99
 

target/classes/mapper/nullTEquipmentMaintenanceMapper.xml → src/main/resources/mapper/TEquipmentMaintenanceMapper.xml


+ 1 - 1
src/main/resources/mapper/nullTEquipmentMaintenanceMapper.xml

@@ -1,5 +1,5 @@
1 1
 <?xml version="1.0" encoding="UTF-8"?>
2 2
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3
-<mapper namespace="com.yt.zhylplat.dao.TEquipmentMaintenanceMapper">
3
+<mapper namespace="com.yt.zhylplat.dao.TWorkReportMapper">
4 4
 
5 5
 </mapper>

+ 2 - 2
target/classes/application-pro.yml

@@ -7,9 +7,9 @@ spring:
7 7
     type: com.alibaba.druid.pool.DruidDataSource  #数据源插件
8 8
     druid:
9 9
       driver-class-name: com.mysql.cj.jdbc.Driver  #zhylplatDB是数据库
10
-      url: jdbc:mysql://47.105.102.32:12306/zhyl_db_jz?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=Hongkong
10
+      url: jdbc:mysql://127.0.0.1:3306/zhyl_db_jz?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull&useSSL=false&serverTimezone=GMT%2B8&autoReconnect=true&rewriteBatchedStatements=true&nullCatalogMeansCurrent=true
11 11
       username: root
12
-      password: zhyl!@#123
12
+      password: hykj@800100
13 13
       #关闭 druid 连接池监控页面
14 14
       filter:
15 15
         config:

+ 3 - 3
target/classes/application.yml

@@ -5,7 +5,7 @@
5 5
 #  port: 9090    #端口配置,每个配之前需要输入 空格
6 6
 spring:
7 7
   profiles:
8
-    active: dev #生产环境%测试环境
8
+    active: pro #生产环境%测试环境
9 9
 
10 10
   #解决 springboot 升版后文件上传问题
11 11
   mvc:
@@ -91,9 +91,9 @@ token:
91 91
 #微信小程序-智慧园林
92 92
 wx:
93 93
   #微信小程序的 appId
94
-  appId: wxe1c3903a345da85b
94
+  appId: wx97a5a9e16d2ee2fa
95 95
   #微信小程序的 appSecret
96
-  appSecret: 3a1b429a26bdfa5cdd6247bcd6bccb25
96
+  appSecret: b63bd0cd6d9c026aa2153dd088b6af23
97 97
   #事项办理进度通知模板 ID
98 98
   templateId:
99 99